From 5bb3ad3944ff229baff1d8bb92caf55d816ee68b Mon Sep 17 00:00:00 2001 From: jiazx0107@163.com <jiazx0107@163.com> Date: 星期六, 02 十二月 2023 18:34:45 +0800 Subject: [PATCH] 提交粮情协议1 --- src/main/java/com/fzzy/api/Constant.java | 54 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 54 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/fzzy/api/Constant.java b/src/main/java/com/fzzy/api/Constant.java index 981ae0e..b38f697 100644 --- a/src/main/java/com/fzzy/api/Constant.java +++ b/src/main/java/com/fzzy/api/Constant.java @@ -1,9 +1,15 @@ package com.fzzy.api; +import com.fzzy.api.data.ApiCommonDevice; + +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"; @@ -307,4 +313,52 @@ */ 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 void updateCacheOnline(String sn, String ip, Integer port, boolean isCreate) { + ApiCommonDevice device = getCommonDeviceCache(sn); + if (null == device && isCreate) { + 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); + } + } + + public static void updateCacheOffline(String sn, String ip, Integer port, boolean isCreate) { + ApiCommonDevice device = getCommonDeviceCache(sn); + + if (null == device && isCreate) { + device = new ApiCommonDevice(); + } + + if (null != device) { + device.setIp(ip); + device.setPort(port); + device.setStatus(Constant.YN_N); + device.setCode("ERROR"); + device.setMsg("璁惧绂荤嚎"); + + contextDeviceMap.put(device.getSn(), device); + } + } + + public static void updateCache(ApiCommonDevice device) { + contextDeviceMap.put(device.getSn(), device); + } } -- Gitblit v1.9.3