From f7a99591d83efd59af37b257e30d12f10291f4ef Mon Sep 17 00:00:00 2001
From: yyt <306727702@qq.com>
Date: 星期六, 17 二月 2024 08:51:23 +0800
Subject: [PATCH] 更新OPCUA

---
 jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java |   64 ++++++++++++++++++++++++++++++++
 1 files changed, 64 insertions(+), 0 deletions(-)

diff --git a/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java b/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java
index f044527..1d5f7ab 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/cert/MethodName.java
@@ -88,4 +88,68 @@
                 break;
         }
     }
+
+    public void SNRetrieval(String Node, String value) throws Exception {
+        String[] parts = Node.split("[.]");
+        if(value=="1") {
+            //SN鍙锋绱�
+            ClientHandler clientHandler=new ClientHandler();
+            NodeEntity SN_node= NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".SNCode").value("").type("").build();
+            String SNCode=clientHandler.read(SN_node);
+
+            String a=daPassingStationCollectionService.SelectSN(SNCode);
+
+            // 1:OK鍙敓浜� 2:NG涓嶅彲鐢熶骇 3:NG鍙繑宸� 4:PC妫�绱㈠け璐ワ紙鏃犺褰曪級5:PC妫�绱㈠け璐ワ紙杞欢锛�
+            NodeEntity node1= NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".CodeCheckFeed").value(a).type("short").build();
+            Boolean out1=clientHandler.write(node1);
+            DaPassingStationCollection PassingStationCollection=new DaPassingStationCollection();
+            PassingStationCollection.setSfcCode(SNCode);
+            PassingStationCollection.setLocationCode(parts[1]);
+            PassingStationCollection.setInboundTime(new Date());
+            daPassingStationCollectionService.insertDaPassingStationCollection(PassingStationCollection);
+        }
+    }
+    public void SaveData(String Node, String value) throws Exception {
+        String[] parts = Node.split("[.]");
+        if(value=="1") {
+            //閲囬泦鏁版嵁鏈�缁堜繚瀛�
+            ClientHandler clientHandler=new ClientHandler();
+            NodeEntity SN_node= NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".SNCode").value("").type("").build();
+            String SNCode=clientHandler.read(SN_node);
+            List<DaCollectionParamConf> b;
+            DaCollectionParamConf daCollectionParamConf=new DaCollectionParamConf();
+            daCollectionParamConf.setGatherAddress(parts[0]+"."+parts[1]);
+            b=collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf);
+
+            List<NodeId> nodeId = b.stream().map(info -> {
+                NodeId nodeid = new NodeId(2,info.getGatherAddress());
+                return nodeid;
+            }).collect(Collectors.toList());
+            List<DataValue> s=readValues(nodeId);
+            //淇濆瓨PLC閲囬泦鏁版嵁
+            for(int i=0;i<nodeId.size();i++)
+            {
+                DaParamCollection Config=new DaParamCollection();
+                Config.setParamCode(nodeId.get(i).getIdentifier().toString().split("[.]")[2]);
+                Config.setLocationCode(nodeId.get(i).getIdentifier().toString().split("[.]")[1]);
+                Config.setParamValue(s.get(i).getValue().getValue().toString());
+                Config.setSfcCode(SNCode);
+                Config.setParamName(b.get(i).getGatherAddress());
+                daParamCollectionService.insertDaParamCollection(Config);
+            }
+            //鏇存柊鍑虹珯鏃堕棿锛岃绠楄妭鎷嶃��
+            DaPassingStationCollection PSC=new DaPassingStationCollection();
+            PSC.setSfcCode(SNCode);
+            List<DaPassingStationCollection> LPSC=daPassingStationCollectionService.selectDaPassingStationCollectionList(PSC);
+            if(LPSC != null && LPSC.size() > 0){
+                LPSC.get(0).setOutboundTime(new Date());
+                LPSC.get(0).setCollectionTime(new Date());
+                LPSC.get(0).setBeatTime(Long.toString(Math.abs(new Date().getTime() - LPSC.get(0).getInboundTime().getTime())));
+                daPassingStationCollectionService.updateDaPassingStationCollection(LPSC.get(0));
+            }
+            //璇锋眰鏈�缁堜繚瀛樺弽棣�:1 淇濆瓨瀹屾垚 2 淇濆瓨澶辫触 3 淇濆瓨澶辫触锛屾暟鎹綅瓒呴暱
+            NodeEntity node1= NodeEntity.builder().index(2).identifier(parts[0]+"."+parts[1]+".SaveFeedLast").value("1").type("short").build();
+            Boolean out1=clientHandler.write(node1);
+        }
+    }
 }

--
Gitblit v1.9.3