|
|
@@ -13,12 +13,9 @@ import com.goafanti.common.utils.LoggerUtils;
|
|
|
import com.goafanti.common.utils.StringUtils;
|
|
|
import com.goafanti.core.mybatis.BaseMybatisDao;
|
|
|
import com.goafanti.core.mybatis.page.Pagination;
|
|
|
-import com.goafanti.core.shiro.token.TokenManager;
|
|
|
import com.goafanti.core.websocket.SystemWebSocketHandler;
|
|
|
import com.goafanti.customer.bo.InputCallNumber;
|
|
|
import com.goafanti.customer.bo.InputUserCallList;
|
|
|
-import com.goafanti.customer.bo.SseMap;
|
|
|
-import com.goafanti.customer.bo.SseResult;
|
|
|
import com.goafanti.customer.service.UserOutboundService;
|
|
|
import org.apache.shiro.crypto.hash.SimpleHash;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
@@ -198,10 +195,10 @@ public class UserOutboundServiceImpl extends BaseMybatisDao<CallLogMapper> imple
|
|
|
callLogMapper.insert(callLog);
|
|
|
pushCountUser(uid);
|
|
|
//需要关闭客户呼叫中
|
|
|
- SseResult res = SseMap.sseEmitterMap.get(TokenManager.getAdminId());
|
|
|
+// SseResult res = SseMap.sseEmitterMap.get(TokenManager.getAdminId());
|
|
|
|
|
|
try {
|
|
|
- res.sseEmitter.send(callResult);
|
|
|
+// res.sseEmitter.send(callResult);
|
|
|
systemWebSocketHandler.sendMessageToUser(admin.getId(), new TextMessage(callResult));
|
|
|
// LoggerUtils.debug(getClass(),String.format("通信成功=》%s=%s",callResult,callResultMsg));
|
|
|
}catch (Exception e ){
|