From 5030f3d30ccc1bd16db371c6970a48103aff9191 Mon Sep 17 00:00:00 2001
From: yyt <306727702@qq.com>
Date: 星期一, 03 六月 2024 13:56:57 +0800
Subject: [PATCH] 380新产品,优化

---
 jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java |   19 +++++++++++++++++--
 1 files changed, 17 insertions(+), 2 deletions(-)

diff --git a/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java b/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
index 1db0ce5..49742b7 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
@@ -105,8 +105,23 @@
                             SNCodeObject = miloService.readFromOpcUa("CFL4HX.OP060.Code").getValue();
                         }
                         if (null != SNCodeObject){
+                            String XT="";
+                            String CZ="";
                             String SNCode = SNCodeObject.toString();
-                            passingStationCollectionServiceImpl.sendMessage("P0SQ0-01FZ01-1000;T231224116;DBBBBA*P0SQ0-041000-1002;T2312020675;DAABBA;S500003","OP060");
+                            DaParamCollection ParamCollection = new DaParamCollection();
+                            ParamCollection.setSfcCode(SNCode);
+                            List<DaParamCollection> DaParamCollectionlist=daParamCollectionService.selectDaParamCollectionList(ParamCollection);
+                            List<DaParamCollection> XTParamCollection = DaParamCollectionlist.stream().filter(x -> "绠变綋".equals(x.getParamName())).collect(Collectors.toList());
+                            if (CollUtil.isNotEmpty(XTParamCollection)){
+                                DaParamCollection lastOne = XTParamCollection.get(0);
+                                XT = lastOne.getParamValue();
+                            }
+                            List<DaParamCollection> CZParamCollection = DaParamCollectionlist.stream().filter(x -> "鏇茶酱".equals(x.getParamName())).collect(Collectors.toList());
+                            if (CollUtil.isNotEmpty(CZParamCollection)){
+                                DaParamCollection lastOne = CZParamCollection.get(0);
+                                CZ = lastOne.getParamValue();
+                            }
+                            passingStationCollectionServiceImpl.sendMessage(XT+"*"+CZ,"OP060");
                         }
                     }
                 }
@@ -187,7 +202,7 @@
                 if (StrUtil.isNotBlank(a)){
                     int input = Integer.parseInt(a);
                     ReadWriteEntity entity = new ReadWriteEntity(parts[0]+"."+parts[1]+".CodeCheckFeed", input);
-                    logger.info("-------鐩戝惉鍒�,{}鐨凜odeCheck鐨勪俊鍙�",Node);
+                    logger.info("鍙戝姩鏈哄彿锛歿},鐩戝惉鍒皗}鐨凜odeCheck鐨勪俊鍙�",SNCode,Node);
                     miloService.writeToOpcByte(entity);
                     logger.info("鐩戝惉鍒拌繑鍥瀋odecheckfeed淇″彿锛寋}",entity);
                     //棣栫珯浼犺緭璁㈠崟鍙�

--
Gitblit v1.9.3