Bladeren bron

增加日志打印

humuyu 3 jaren geleden
bovenliggende
commit
ce7a7459ac

+ 2 - 0
eladmin-system/src/main/java/me/zhengjie/application/admin/controller/OrderRoomIdController.java

@@ -151,7 +151,9 @@ public class OrderRoomIdController {
 		if (socketObj == null) {
 			return AppBaseResponse.success();
 		}
+	
 		String businessNo = socketObj.getString("businessNo");
+		log.info("pc端取消公证员绑定人员:{} ",businessNo);
 		appRelatePc.removeNotary(businessNo, socketObj.getString("accountId"));
 //		Set<String> notarys = appRelatePc.getBindNotary(businessNo);
 //		if (CollectionUtils.isEmpty(notarys) || notarys.size() == 1) {

+ 5 - 1
eladmin-system/src/main/java/me/zhengjie/base/websocket/AppPcBindSocketIo.java

@@ -18,6 +18,8 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.corundumstudio.socketio.SocketIOClient;
 
+import lombok.extern.slf4j.Slf4j;
+import me.zhengjie.application.admin.controller.OrderRoomIdController;
 import me.zhengjie.utils.RedisUtils;
 
 /**
@@ -26,6 +28,7 @@ import me.zhengjie.utils.RedisUtils;
  *
  */
 @Component
+@Slf4j
 public class AppPcBindSocketIo {
 	public final static String PREFIX_BUSINESS_NO = "business-no-";
 	@Autowired
@@ -112,6 +115,7 @@ public class AppPcBindSocketIo {
 			// 直接删除这条数据
 			delBusinessNo(businessNo);
 			// TDOO 发送给app。取消了视频通话
+			log.info("推送给app消息{}",businessNo);
 			sendAppMsg(businessNo);
 		} else {
 			notarys.remove(username);
@@ -149,7 +153,7 @@ public class AppPcBindSocketIo {
 					businessNo = key;
 			}
 		}
-
+		log.info("app失去连接:{} ",businessNo);
 		removeNotary(getBindNo(businessNo), notary);
 //		String key = (String) redisUtils.get(PREFIX_BUSINESS_NO + businessNo);
 //		JSONArray json = JSON.parseArray((String) redisUtils.get(key));

+ 0 - 1
eladmin-system/src/main/java/me/zhengjie/base/websocket/SocketEventListenner.java

@@ -133,7 +133,6 @@ public class SocketEventListenner {
 	}
 
 	// 消息接收入口,当接收到消息后,查找发送目标客户端,并且向该客户端发送消息,且给自己发送消息
-
 	@OnEvent("appRegisterEvent")
 	public void appRegisterEvent(SocketIOClient client, AckRequest request, Map<String, String> map) throws Exception {
 		HandshakeData shakeData = client.getHandshakeData();