From d454e51e06dbf7beb50551588fc58a5810295d7c Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期一, 01 一月 2024 19:28:22 +0800
Subject: [PATCH] 调整KFKA数据推送测试。

---
 src/main/java/com/fzzy/api/Constant.java |   76 +++++++++++++++++++++++++-------------
 1 files changed, 50 insertions(+), 26 deletions(-)

diff --git a/src/main/java/com/fzzy/api/Constant.java b/src/main/java/com/fzzy/api/Constant.java
index b38f697..3d0c911 100644
--- a/src/main/java/com/fzzy/api/Constant.java
+++ b/src/main/java/com/fzzy/api/Constant.java
@@ -1,13 +1,17 @@
 package com.fzzy.api;
 
+import com.alibaba.fastjson.JSON;
 import com.fzzy.api.data.ApiCommonDevice;
+import lombok.extern.slf4j.Slf4j;
 
+import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
 
 /**
  * 鍏ㄥ眬闈欐�佺被
  */
+@Slf4j
 public class Constant {
 
 
@@ -321,44 +325,64 @@
 
     public static ApiCommonDevice getCommonDeviceCache(String sn) {
         if (null == sn) return null;
+        log.info("鍦ㄧ嚎璁惧锛�" + JSON.toJSONString(contextDeviceMap));
         return contextDeviceMap.get(sn);
     }
 
-    public static void updateCacheOnline(String sn, String ip, Integer port, boolean isCreate) {
-        ApiCommonDevice device = getCommonDeviceCache(sn);
-        if (null == device && isCreate) {
+    public static ApiCommonDevice getCommonDeviceCacheByIp(String ip) {
+        if (null == ip) return null;
+
+        if (contextDeviceMap.isEmpty()) return null;
+        log.info("鍦ㄧ嚎璁惧锛�" + JSON.toJSONString(contextDeviceMap));
+        for (ApiCommonDevice device : contextDeviceMap.values()) {
+            if (ip.equals(device.getIp())) return device;
+        }
+        return null;
+    }
+    public static ApiCommonDevice getCommonDeviceCacheBySn(String sn) {
+        if (null == sn) return null;
+
+        if (contextDeviceMap.isEmpty()) return null;
+        log.info("鍦ㄧ嚎璁惧锛�" + JSON.toJSONString(contextDeviceMap));
+        for (ApiCommonDevice device : contextDeviceMap.values()) {
+            if (sn.equals(device.getSn())) return device;
+        }
+        return null;
+    }
+    public static ApiCommonDevice updateCacheOnline(String ip, Integer port) {
+        ApiCommonDevice device = getCommonDeviceCacheByIp(ip);
+
+        if (null == device) {
             device = new ApiCommonDevice();
         }
-        if (null != device) {
-            device.setIp(ip);
-            device.setPort(port);
-            device.setStatus(Constant.YN_Y);
-            device.setCode("SUCCESS");
-            device.setMsg("璁惧鍦ㄧ嚎");
-            device.setSn(ip);
-            contextDeviceMap.put(device.getSn(), device);
-        }
+        device.setIp(ip);
+        device.setPort(port);
+        device.setStatus(Constant.YN_Y);
+        device.setCode("SUCCESS");
+        device.setMsg("璁惧涓婄嚎");
+        device.setOnlineTime(new Date());
+        contextDeviceMap.put(device.getIp(), device);
+        log.info("璁惧涓婄嚎锛�" + ip);
+        return device;
     }
 
-    public static void updateCacheOffline(String sn, String ip, Integer port, boolean isCreate) {
-        ApiCommonDevice device = getCommonDeviceCache(sn);
+    public static ApiCommonDevice updateCacheOffline(String ip, Integer port) {
+        ApiCommonDevice device = getCommonDeviceCacheByIp(ip);
 
-        if (null == device && isCreate) {
-            device = new ApiCommonDevice();
+        if (null == device) {
+            return null;
         }
+        device.setIp(ip);
+        device.setPort(port);
+        device.setStatus(Constant.YN_N);
+        device.setCode("ERROR");
+        device.setMsg("璁惧绂荤嚎");
+        contextDeviceMap.put(device.getIp(), device);
 
-        if (null != device) {
-            device.setIp(ip);
-            device.setPort(port);
-            device.setStatus(Constant.YN_N);
-            device.setCode("ERROR");
-            device.setMsg("璁惧绂荤嚎");
-
-            contextDeviceMap.put(device.getSn(), device);
-        }
+        return device;
     }
 
     public static void updateCache(ApiCommonDevice device) {
-        contextDeviceMap.put(device.getSn(), device);
+        contextDeviceMap.put(device.getIp(), device);
     }
 }

--
Gitblit v1.9.3