From 6a9cf62f7ca4b45c48a571c63fd484c186070a0e Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期五, 19 一月 2024 23:53:12 +0800
Subject: [PATCH] 增加油罐仓的解析2

---
 src/main/java/com/fzzy/gateway/GatewayUtils.java |   58 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 58 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/fzzy/gateway/GatewayUtils.java b/src/main/java/com/fzzy/gateway/GatewayUtils.java
index 076834c..a0aa2d3 100644
--- a/src/main/java/com/fzzy/gateway/GatewayUtils.java
+++ b/src/main/java/com/fzzy/gateway/GatewayUtils.java
@@ -3,6 +3,7 @@
 import com.fzzy.api.Constant;
 import com.fzzy.api.data.ApiCommonDevice;
 import com.fzzy.api.data.GatewayDeviceType;
+import com.fzzy.gateway.data.GrainCableData;
 import com.fzzy.gateway.entity.GatewayDevice;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Component;
@@ -57,6 +58,16 @@
             if (deviceSn.equals(device.getDeviceSn())) return device;
         }
 
+        return null;
+    }
+
+    public static GatewayDevice getCacheByDeviceSIp(String ip) {
+        Collection<GatewayDevice> list = allCacheDevice();
+        if (null == list || list.isEmpty()) return null;
+
+        for (GatewayDevice device : list) {
+            if (ip.equals(device.getIp())) return device;
+        }
         return null;
     }
 
@@ -116,4 +127,51 @@
     public static Collection<GatewayDevice> listDeviceWeight() {
         return cacheMapDeviceWeight.values();
     }
+
+    public static GatewayDevice getCacheByDepotSysId(String depotSysId) {
+
+        if (null == depotSysId) return null;
+        Collection<GatewayDevice> list = allCacheDevice();
+        if (null == list || list.isEmpty()) return null;
+
+        for (GatewayDevice device : list) {
+            if (null == device.getDepotIdSys()) continue;
+            if (depotSysId.equals(device.getDepotIdSys())) return device;
+        }
+        return null;
+    }
+
+
+    public static GrainCableData getCableData(GatewayDevice gatewayDevice) {
+        String cableRule = gatewayDevice.getCableRule();
+        String cableCir = gatewayDevice.getCableCir();
+
+        GrainCableData result = new GrainCableData();
+
+        int cableY, cableX;
+        String[] attCable = cableRule.split("-");
+        int cableZ = Integer.valueOf(attCable[0]);
+        if (StringUtils.isEmpty(cableCir)) {
+            cableY = Integer.valueOf(attCable[1]);
+            cableX = Integer.valueOf(attCable[2]);
+        } else {
+            String[] attCir = cableCir.split("-");
+            cableZ = Integer.valueOf(attCir[0]);
+            cableY = 1;
+            cableX = 0;
+            //閽堝澶氬湀璁$畻
+            for (int i = 0; i < cableCir.length(); i++) {
+                cableX += Integer.valueOf(attCir[i]);
+            }
+
+            result.setCir(true);
+        }
+
+        result.setCableY(cableY);
+        result.setCableZ(cableZ);
+        result.setCableX(cableX);
+        result.setSumNum(cableZ * cableY * cableX);
+
+        return result;
+    }
 }

--
Gitblit v1.9.3