From facc0ea3fa37091a98aa1e0a0d1081fd32fba28e Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期六, 27 一月 2024 11:38:29 +0800
Subject: [PATCH] 优化协议
---
src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0SessionListener.java | 28 +++++++++++++++++++++++++---
1 files changed, 25 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0SessionListener.java b/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0SessionListener.java
index 613ae98..73d8bfa 100644
--- a/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0SessionListener.java
+++ b/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0SessionListener.java
@@ -2,11 +2,15 @@
import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiCommonDevice;
+import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.SpringUtil;
+import com.fzzy.gateway.entity.GatewayDevice;
import com.fzzy.gateway.service.GatewayDeviceService;
import com.ld.io.api.IoSession;
import com.ld.io.api.IoSessionListener;
import lombok.extern.slf4j.Slf4j;
+
+import java.util.List;
/**
*
@@ -23,13 +27,31 @@
*/
@Override
public void onCreate(IoSession session) {
-
+ //娣诲姞鍒板唴瀛�
+ BhznGrainV0ServerUtils.addSession(session);
log.info("++++鏂板缓杩炴帴++++-IP={}锛孭ORT={}", session.getAddress(), session.getPort());
// 娣诲姞鑷畾涔変笟鍔D
session.setBusinessKey(BhznGrainV0ServerUtils.getServerKey(session.getAddress(), session.getPort()));
-
- //鎵ц鍒嗘満涓婄嚎
+// GatewayDeviceService gatewayDeviceService = SpringUtil.getBean(GatewayDeviceService.class);
+// List<GatewayDevice> devices = gatewayDeviceService.listAll();
+// //鎵ц鍒嗘満涓婄嚎
+// if(devices!= null && devices.size()>0){
+// ApiCommonDevice device =null;
+// for (GatewayDevice d:devices) {
+// device = new ApiCommonDevice();
+// device.setIp(d.getIp());
+// device.setPort(d.getPort());
+// device.setStatus(Constant.YN_N);
+// device.setSn(d.getDeviceSn());
+// device.setCode("ERROR");
+// device.setMsg("璁惧绂荤嚎");
+// }
+//
+//
+// contextDeviceMap.put(device.getIp(), device);
+//
+// }
Constant.updateCacheOnline(session.getAddress(), session.getPort());
}
--
Gitblit v1.9.3