Browse Source

外呼系统开发

anderx 1 year ago
parent
commit
8d4afc926c

+ 7 - 5
src/main/java/com/goafanti/customer/service/impl/UserOutboundServiceImpl.java

@@ -22,6 +22,7 @@ import com.goafanti.customer.bo.SseResult;
 import com.goafanti.customer.service.UserOutboundService;
 import org.apache.shiro.crypto.hash.SimpleHash;
 import org.springframework.stereotype.Service;
+import org.springframework.web.socket.TextMessage;
 
 import javax.annotation.Resource;
 import java.util.HashMap;
@@ -201,14 +202,15 @@ public class UserOutboundServiceImpl extends BaseMybatisDao<CallLogMapper> imple
 
         try {
         res.sseEmitter.send(callResult);
-//            systemWebSocketHandler.sendMessageToUser(admin.getId(), new TextMessage(callResult));
-            LoggerUtils.debug(getClass(),String.format("通信成功=》%s=%s",callResult,callResultMsg));
+            systemWebSocketHandler.sendMessageToUser(admin.getId(), new TextMessage(callResult));
+//            LoggerUtils.debug(getClass(),String.format("通信成功=》%s=%s",callResult,callResultMsg));
         }catch (Exception e ){
             LoggerUtils.error(getClass(),"通信失败");
-        }finally {
-            res.sseEmitter.complete();
-            SseMap.sseEmitterMap.remove(TokenManager.getAdminId());
         }
+//        finally {
+//            res.sseEmitter.complete();
+//            SseMap.sseEmitterMap.remove(TokenManager.getAdminId());
+//        }
         return 1;
     }