From 9906e6b188bf2c36dddc0d5adadbf02e69ea3e4b Mon Sep 17 00:00:00 2001
From: wujian <14790700720@163.com>
Date: 星期五, 25 十月 2024 09:17:29 +0800
Subject: [PATCH] add -sap

---
 jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java |   43 +++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 41 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 cb447d8..3b3b98f 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
@@ -88,7 +88,7 @@
     public void onSubscribe(String identifier, Object value) {
         String ecpStr = "";//寮傚父璁板綍鏍囪
         try {
-            if(null != value && "1".equals(value.toString())) {
+                 if(null != value && "1".equals(value.toString())) {
                 //1銆佹绱N鍙�
                 //2銆佽繃绔欏弬鏁伴噰闆�
                 //3銆佹壂鐮佹灙鏁版嵁鍥炰紶
@@ -263,6 +263,27 @@
                 List<BsOrderScheduling> queryOrderList = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderSchedulingQuery);
                 if (CollUtil.isNotEmpty(queryOrderList)){
                     a = "1";
+                    //濡傛灉鏄�佽溅鍨嬶紝鍒ゆ柇鏄惁閲嶅鎵爜
+                    if (OPCElement.OP050_CODE_CHECK.equals(Node)){
+                        String type = productNewFlag(SNCode);
+                        if (!"280".equals(type) && !"380".equals(type)){
+                            DaPassingStationCollection passCheck = new DaPassingStationCollection();
+                            passCheck.setSfcCode(SNCode);
+                            passCheck.setLocationCode("OP060");
+                            List<DaPassingStationCollection> passCheckList = passingStationCollectionServiceImpl.selectDaPassingStationCollectionList(passCheck);
+                            if (CollUtil.isNotEmpty(passCheckList)){
+                                //鏄惁杩斾慨
+                                a = "5";
+//                                RmRepairRecord repairRecordCheck = new RmRepairRecord();
+//                                repairRecordCheck.setBoxCode(SNCode);
+//                                repairRecordCheck.setProcessesCode("OP050");
+//                                List<RmRepairRecord> repairCheckList = rmRepairRecordService.selectRmRepairRecordList(repairRecordCheck);
+//                                if (CollUtil.isEmpty(repairCheckList)){
+//
+//                                }
+                            }
+                        }
+                    }
                 }else {
                     a = "4";
                 }
@@ -295,6 +316,23 @@
                 }
                 logger.info("-----杩斿洖codeCheckFeed-----,{}",a);
 //                String a="1";
+                //zz涓婄嚎宸ヤ綅鏌ヨhx绾挎槸鍚﹁繃绔欏悎鏍�
+                if (OPCElement.OP120_ZZ_CODE_CHECK.equals(Node)){
+                    //杩囩珯璁板綍
+                    DaPassingStationCollection PassingStationCollection=new DaPassingStationCollection();
+                    PassingStationCollection.setSfcCode(SNCode);
+                    PassingStationCollection.setLocationCode("OP160");
+                    List<DaPassingStationCollection> ZZOP120PassCheck = passingStationCollectionServiceImpl.selectDaPassingStationCollectionList(PassingStationCollection);
+                    if (CollUtil.isEmpty(ZZOP120PassCheck)){
+                        a = "";
+                    } else {
+                        DaPassingStationCollection passingStationCollection = ZZOP120PassCheck.get(0);
+                        String outRsSign = passingStationCollection.getOutRsSign();
+                        if (!OPCElement.QUALIFIED.equals(outRsSign)){
+                            a = "";
+                        }
+                    }
+                }
                 // 1:OK鍙敓浜� 2:NG涓嶅彲鐢熶骇 3:NG鍙繑宸� 4:PC妫�绱㈠け璐ワ紙鏃犺褰曪級5:PC妫�绱㈠け璐ワ紙杞欢锛�
                 if (StrUtil.isNotBlank(a)){
                     int input = Integer.parseInt(a);
@@ -600,7 +638,7 @@
                                 ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
                             }
                             ParamCollection.setSfcCode(SNCode);
-                            ParamCollection.setParamName(list.get(i).getCollectParameterName());
+                            ParamCollection.setParamName(list.get(i).getParameterSetName());
                             ParamCollection.setParamUpper(list.get(i).getParamUpper());
                             ParamCollection.setParamLower(list.get(i).getParamLower());
                             ParamCollection.setUnit(list.get(i).getCollectParameterUnit());
@@ -633,6 +671,7 @@
             }
             DaPassingStationCollection PassingStationCollection=new DaPassingStationCollection();
             PassingStationCollection.setSfcCode(SNCode);
+            PassingStationCollection.setProductCode(bsOrderScheduling.getModel());
             PassingStationCollection.setLocationCode(parts[1]);
             PassingStationCollection.setOutboundTime(new Date());
             PassingStationCollection.setInboundTime(new Date(new Date().getTime()-beatTime*1000));

--
Gitblit v1.9.3