From a69402c8b67d8ce4b698d0c394d15ff43b5d99d0 Mon Sep 17 00:00:00 2001 From: jiazx0107@163.com <jiazx0107@163.com> Date: 星期四, 14 十二月 2023 23:17:41 +0800 Subject: [PATCH] 提交正来电子协议解析-3 --- src/main/java/com/fzzy/api/Constant.java | 83 ++++++++++++++++++++++++++++++++++++++--- 1 files changed, 76 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/fzzy/api/Constant.java b/src/main/java/com/fzzy/api/Constant.java index 5b8ee8c..78701d7 100644 --- a/src/main/java/com/fzzy/api/Constant.java +++ b/src/main/java/com/fzzy/api/Constant.java @@ -1,9 +1,16 @@ package com.fzzy.api; +import com.fzzy.api.data.ApiCommonDevice; + +import java.util.Date; +import java.util.HashMap; +import java.util.Map; + /** * 鍏ㄥ眬闈欐�佺被 */ public class Constant { + public static final String DEFAULT_CODE = "0"; public static final String YN_N = "N"; @@ -135,6 +142,10 @@ * 鎺ュ彛缂栫爜-1212 瀹㈡埛淇℃伅鏁版嵁鎺ュ彛 */ public static String API_CODE_1212 = "1212"; + /** + * 鎺ュ彛缂栫爜-1214 鍑哄叆搴撹褰曚俊鎭暟鎹帴鍙� + */ + public static String API_CODE_1214 = "1214"; /** * 鎺ュ彛缂栫爜-1301 瀹夊叏绠$悊鏁版嵁鎺ュ彛 @@ -198,16 +209,17 @@ */ public static String API_CODE_1405 = "1405"; + //璐㈠姟鎶ヨ〃鎺ュ彛 public static String API_CODE_1501 = "1501"; public static String API_CODE_1502 = "1502"; public static String API_CODE_1503 = "1503"; /** * 鍥芥爣鍑哄叆搴撶被鍨� */ - public static String INOUT_TYPE_14 = "14"; - public static String INOUT_TYPE_2 = "2"; - public static String INOUT_TYPE_15 = "15"; - public static String INOUT_TYPE_1 = "1"; + public static String INOUT_TYPE_14 = "14"; + public static String INOUT_TYPE_2 = "2"; + public static String INOUT_TYPE_15 = "15"; + public static String INOUT_TYPE_1 = "1"; /** * 鎿嶄綔鏍囪 @@ -282,18 +294,18 @@ /** * 绮鎬ц川 */ - public static String TRIGGER_P_LSXZ = "LSXZ"; + public static String TRIGGER_P_LSXZ = "LSXZ"; /** * 缁撶畻鏂瑰紡 */ - public static String TRIGGER_P_JSFS = "JSFS"; + public static String TRIGGER_P_JSFS = "JSFS"; /** * 缁勭粐閮ㄩ棬绫诲瀷 */ public static String DEPT_TYPE_10 = "10"; -// public static String DEPT_TYPE_11 = "11"; + // public static String DEPT_TYPE_11 = "11"; public static String DEPT_TYPE_20 = "20"; public static String DEPT_TYPE_30 = "30"; @@ -302,4 +314,61 @@ */ public static final String DEFAULT_USER_PASSWORD = "123456"; + + /** + * 鍐呭瓨鏁版嵁缂撳瓨锛岀敤浜庡瓨鍌ㄥ嚭鍏ュ簱鐩稿叧鐨勪复鏃朵俊鎭紝濡傚埛鍗¤澶囧綋鍓嶆渶鏂版暟鎹瓑銆� + */ + public static Map<String, ApiCommonDevice> contextDeviceMap = new HashMap<>(); + + public static ApiCommonDevice getCommonDeviceCache(String sn) { + if (null == sn) return null; + return contextDeviceMap.get(sn); + } + + public static ApiCommonDevice getCommonDeviceCacheByIp(String ip) { + if (null == ip) return null; + + if (contextDeviceMap.isEmpty()) return null; + + for (ApiCommonDevice device : contextDeviceMap.values()) { + if (ip.equals(device)) return device; + } + return null; + } + + public static ApiCommonDevice updateCacheOnline(String ip, Integer port) { + ApiCommonDevice device = getCommonDeviceCacheByIp(ip); + + if (null == device) { + device = new ApiCommonDevice(); + } + device.setIp(ip); + device.setPort(port); + device.setStatus(Constant.YN_Y); + device.setCode("SUCCESS"); + device.setMsg("璁惧涓婄嚎"); + device.setOnlineTime(new Date()); + contextDeviceMap.put(device.getSn(), device); + return device; + } + + public static ApiCommonDevice updateCacheOffline(String ip, Integer port) { + ApiCommonDevice device = getCommonDeviceCacheByIp(ip); + + if (null == device) { + return null; + } + 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); + } } -- Gitblit v1.9.3