donghuang/yoqw
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

不校验已在线再次签入

Browse Source
This commit is contained in:
Shaun Chyxion 2021-01-09 11:35:44 +08:00
parent 23b7e3b272
commit ab5d1f579a
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
server/src/main/java/com/pudonghot/yo/openapi/controller/AgentStatusController.java
View File

@ -1,13 +1,13 @@
package com.pudonghot.yo.openapi.controller;
import lombok.val;
import lombok.extern.slf4j.Slf4j;
import com.pudonghot.yo.model.domain.Agent;
import com.pudonghot.yo.service.AgentService;
import org.springframework.stereotype.Controller;
import com.pudonghot.yo.model.domain.AgentStatus;
import com.pudonghot.yo.model.exception.AssertUtils;
import com.pudonghot.yo.openapi.auth.SessionAbility;
import com.pudonghot.yo.model.agentevent.AgentEvent;
import com.pudonghot.yo.service.AgentService;
import com.pudonghot.yo.service.CommonCampaignService;
import com.pudonghot.yo.openapi.response.RespAgentReady;
import com.pudonghot.yo.service.CommonAgentStatusService;
@ -16,7 +16,6 @@ import static com.pudonghot.yo.model.agentevent.EventType.*;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import static com.pudonghot.yo.model.exception.ErrorCode.AGENT_SIGNED_IN;
/**
* @author Donghuang
@ -40,12 +39,12 @@ public class AgentStatusController implements SessionAbility {
@PathVariable("account")
final String account) {
final Agent agent = agentService.findValid(getTenantId(), account);
final AgentStatus agentStatus = agentStatusService.findRegisteredAgentStatus(agent);
AssertUtils.state(agentStatus.getStatus() ==
AgentStatus.Status.OFFLINE,
AGENT_SIGNED_IN);
final String eventKey = agentStatusService.signIn(agent);
val agent = agentService.findValid(getTenantId(), account);
val agentStatus = agentStatusService.findRegisteredAgentStatus(agent);
if (agentStatus.getStatus() != AgentStatus.Status.OFFLINE) {
log.warn("Agent [{}] is signed already.", agent);
}
val eventKey = agentStatusService.signIn(agent);
agentEventService.addTempEvent(
new AgentEvent(
AgentOther_InService,