From 4403382cccf10ad69d540bb9f79bd8edc2c9bba7 Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期一, 20 十月 2025 16:10:00 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/entity/param/CombParam.java       |    6 +
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  179 +++++++++++++++++------------------
 src/main/java/com/zy/core/MainProcess.java                  |   12 +-
 src/main/java/com/zy/core/thread/SiemensDevpThread.java     |   45 ++++++---
 4 files changed, 127 insertions(+), 115 deletions(-)

diff --git a/src/main/java/com/zy/asrs/entity/param/CombParam.java b/src/main/java/com/zy/asrs/entity/param/CombParam.java
index c485ceb..5f9bb44 100644
--- a/src/main/java/com/zy/asrs/entity/param/CombParam.java
+++ b/src/main/java/com/zy/asrs/entity/param/CombParam.java
@@ -78,7 +78,11 @@
     public CombParam(List<BasArmMast> basArmMastList) {
         this.orderNo = basArmMastList.get(0).getOrderNo();
         this.combMats = new ArrayList<>();
-        this.barcode = basArmMastList.get(0).getBarcode();
+        if (basArmMastList.size()>1){
+            this.barcode = basArmMastList.get(1).getBarcode();
+        } else {
+            this.barcode = basArmMastList.get(0).getBarcode();
+        }
         List<BasArmMast> basArmMasts = new ArrayList<>();
         for (BasArmMast basArmMast : basArmMastList) {
             if (basArmMasts.isEmpty()){
diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index a828e56..47e4f08 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -260,6 +260,7 @@
                             staProtocolNew.setWorkNo(wrkMast.getWrkNo());
                             staProtocolNew.setStaNo(RouteUtils.SouStaEnd(wrkMast.getStaNo(),wrkMast.getSourceStaNo()));
                             staProtocolNew.setSiteId(staProtocol.getSiteId());
+                            devpThread.setPakMk(staProtocol.getSiteId(), false);
                             staProtocolNew.setBarcode(barcode);
                             MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocolNew));
                             if (ledThread != null) {
@@ -283,10 +284,9 @@
                         if (!result) {
                             News.error(methodName + ":鏇存柊plc绔欑偣淇℃伅澶辫触");
                             log.error("杈撻�佺嚎涓嬪彂(瀛樺湪璁惧涓婅蛋鐨勫伐浣滄。锛岀洿鎺ヤ笅鍙戯紒)==>鏇存柊plc绔欑偣淇℃伅澶辫触");
-
-//                            throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
                             continue;
                         }
+                        continue;
 
                     }
                     WrkMast checkPick = wrkMastService.selectOne(new EntityWrapper<WrkMast>()
@@ -327,41 +327,14 @@
 
                                 throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
                             }
-                        }
-//                        else if (jsonObject.getInteger("code").equals(700)) {
-//                            SearchLocParam param2 = new SearchLocParam();
-//                            param2.setBarcode(barcode);
-//                            param2.setBarcodeMat(barcodeMat);
-//                            param2.setSourceStaNo(inSta.getStaNo());
-//                            param2.setLocType1(locTypeDto.getLocType1());
-//                            String response2 = new HttpHandler.Builder()
-//                                    .setUri(wmsUrl)
-//                                    .setPath("/rpc/pakin/yk/loc/v33")
-//                                    .setJson(JSON.toJSONString(param2))
-//                                    .build()
-//                                    .doPost();
-//                            JSONObject jsonObject2 = JSON.parseObject(response2);
-//                            if (jsonObject2.getInteger("code").equals(200)) {
-//                                log.info("鑷姩缁勬墭鎴愬姛锛侊紒");
-//                                MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(3, "鑷姩缁勬墭鎴愬姛"));
-//                            } else {
-//                                MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(3, "鑷姩缁勬墭澶辫触锛侊紒锛乥arcodeMat==>"+barcodeMat));
-//                                News.error(methodName + "==>缁勬墭澶辫触:璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + "/rpc/pakin/yk/loc/v33", JSON.toJSONString(param), response2);
-//                            }
-//                            try{
-//                                Thread.sleep(500);
-//                            } catch (Exception e){
-//
-//                            }
-//                        }
-                        else {
+                        } else {
                             News.error(JSON.toJSONString(staProtocol));
                             staProtocol.setWorkNo(wrkNo);
-                            wrkNo++;
                             staProtocol.setStaNo(inSta.getBackSta().shortValue());
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
                             MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
-                            News.info("浠诲姟涓嬪彂鍒ゆ柇{}鍏ュ簱鍥為��锛歿}锛屼换鍔″彿锛歿}", inSta.getStaNo(), errMsg,wrkNo);
+                            News.info("浠诲姟涓嬪彂鍒ゆ柇{}鍏ュ簱鍥為��锛歿}锛岄敊璇紪鍙穥},浠诲姟鍙凤細{}", inSta.getStaNo(), errMsg,jsonObject.getInteger("code"),wrkNo);
+                            wrkNo++;
 //                            if (ledThread != null) {
                                 String errorMsg = jsonObject.getString("msg");
                                 if (!Cools.isEmpty(errorMsg)) {
@@ -846,7 +819,7 @@
             } else {
                 staProtocolIn = staProtocolIn.clone();
             }
-            int[] outStaNos = {1015, 2016};
+            int[] outStaNos = {1015, 2016}; //琛旀帴鍏ュ簱鐐�
             for (int outStaNo : outStaNos) {
                 StaProtocol staProtocolOut = devpThread.getStation().get(outStaNo);// 鐩樼偣鍑哄簱琛旀帴绔欑偣锛堝彲鑳芥槸 1015锛屼篃鍙兘鏄� 2016锛�
                 if (staProtocolOut == null) {
@@ -1266,61 +1239,61 @@
             // 鑾峰彇宸ヤ綔鐘舵�佷负11锛堢敓鎴愬嚭搴揑D锛夌殑鍑哄簱宸ヤ綔妗�
 //            WrkMast wrkMast = wrkMastMapper.selectPakOutStep1(slave.getId(), crnStn.getStaNo());
             List<WrkMast> wrkMasts = wrkMastMapper.selectPakOutStep11(slave.getId(), crnStn.getStaNo());
-            if (slave.getId() == 3) {
-                SiemensDevpThread devpThread1 = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, crnStn.getDevpPlcId());
-                StaProtocol staProtocol2 = devpThread1.getStation().get(1015);
-                if (staProtocol2 == null) {
-                    News.infoNoLog("" + mark + " - 2" + " - 3" + " - 鍫嗗灈鏈哄嚭搴撶珯淇℃伅(staProtocol!=null缁х画鎵ц,鍚﹀垯寰幆缁堟)锛歴taProtocol=" + staProtocol2);
-                    break;
-                } else {
-                    staProtocol2 = staProtocol2.clone();
-                }
-                WrkMast wrkMast9999 = wrkMastMapper.selectByWrkNo(9997);
-                BasDevp staDetl = basDevpService.selectById(crnStn.getStaNo());
-                if (staDetl == null) {
-                    News.error(""+mark+" - 2"+" - 5"+" - 鍑哄簱 ===>> 鍫嗗灈鏈虹珯鐐瑰湪鏁版嵁搴撲笉瀛樺湪, 绔欑偣缂栧彿={}", crnStn.getStaNo());
-                    break;
-//                    continue;
-                }
-                if(wrkMast9999 != null && staProtocol2.isAutoing() && staDetl.getCanouting() != null && staDetl.getCanouting().equals("Y")){
-                    // 鍫嗗灈鏈烘帶鍒惰繃婊�
-                    if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) {
-//                        continue;
-                        break;
-                    }
-                    // 宸茬粡瀛樺湪鍚婅溅鎵ц浠诲姟鏃讹紝鍒欒繃婊�
-                    if (wrkMastMapper.selectWorking(slave.getId()) != null) {
-                        break;
-//                        return;
-                    }
-                    // 1.鍫嗗灈鏈哄紑濮嬬Щ鍔�
-                    CrnCommand crnCommand = new CrnCommand();
-                    crnCommand.setCrnNo(slave.getId()); // 鍫嗗灈鏈虹紪鍙�
-                    crnCommand.setTaskNo((short) 9997); // 宸ヤ綔鍙�
-//                    crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
-                    crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡:  搴撲綅绉昏浆
-                    crnCommand.setSourcePosX((short) 5);     // 婧愬簱浣嶆帓
-                    crnCommand.setSourcePosY((short) 1);     // 婧愬簱浣嶅垪
-                    crnCommand.setSourcePosZ((short) 1);     // 婧愬簱浣嶅眰
-                    crnCommand.setDestinationPosX((short) 6);     // 鐩爣搴撲綅鎺�
-                    crnCommand.setDestinationPosY((short) 1);     // 鐩爣搴撲綅鍒�
-                    crnCommand.setDestinationPosZ((short) 4);     // 鐩爣搴撲綅灞�
-//                crnCommand.setTraySize(sourceSta.getLocType1() == 2);     //搴撲綅绫诲瀷
-                    if (!MessageQueue.offer(SlaveType.Crn, wrkMast9999.getCrnNo(), new Task(2, crnCommand))) {
-                        News.error("" + mark + " - 2" + " - 13" + " - 鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", wrkMast9999.getCrnNo(), JSON.toJSON(crnCommand));
-                    } else {
-                        // 淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 12.鍚婅溅鍑哄簱涓�
-                        Date now = new Date();
-                        wrkMast9999.setWrkSts(12L);
-                        wrkMast9999.setCrnStrTime(now);
-                        wrkMast9999.setModiTime(now);
-                        if (wrkMastMapper.updateById(wrkMast9999) == 0) {
-                            News.error("" + mark + " - 2" + " - 14" + " - 淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 12.鍚婅溅鍑哄簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast9999.getWrkNo());
-                        }
-                        break;
-                    }
-                }
-            }
+//            if (slave.getId() == 3) {
+//                SiemensDevpThread devpThread1 = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, crnStn.getDevpPlcId());
+//                StaProtocol staProtocol2 = devpThread1.getStation().get(1015);
+//                if (staProtocol2 == null) {
+//                    News.infoNoLog("" + mark + " - 2" + " - 3" + " - 鍫嗗灈鏈哄嚭搴撶珯淇℃伅(staProtocol!=null缁х画鎵ц,鍚﹀垯寰幆缁堟)锛歴taProtocol=" + staProtocol2);
+//                    break;
+//                } else {
+//                    staProtocol2 = staProtocol2.clone();
+//                }
+//                WrkMast wrkMast9999 = wrkMastMapper.selectByWrkNo(9997);
+//                BasDevp staDetl = basDevpService.selectById(crnStn.getStaNo());
+//                if (staDetl == null) {
+//                    News.error(""+mark+" - 2"+" - 5"+" - 鍑哄簱 ===>> 鍫嗗灈鏈虹珯鐐瑰湪鏁版嵁搴撲笉瀛樺湪, 绔欑偣缂栧彿={}", crnStn.getStaNo());
+//                    break;
+////                    continue;
+//                }
+//                if(wrkMast9999 != null && staProtocol2.isAutoing() && staDetl.getCanouting() != null && staDetl.getCanouting().equals("Y")){
+//                    // 鍫嗗灈鏈烘帶鍒惰繃婊�
+//                    if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) {
+////                        continue;
+//                        break;
+//                    }
+//                    // 宸茬粡瀛樺湪鍚婅溅鎵ц浠诲姟鏃讹紝鍒欒繃婊�
+//                    if (wrkMastMapper.selectWorking(slave.getId()) != null) {
+//                        break;
+////                        return;
+//                    }
+//                    // 1.鍫嗗灈鏈哄紑濮嬬Щ鍔�
+//                    CrnCommand crnCommand = new CrnCommand();
+//                    crnCommand.setCrnNo(slave.getId()); // 鍫嗗灈鏈虹紪鍙�
+//                    crnCommand.setTaskNo((short) 9997); // 宸ヤ綔鍙�
+////                    crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
+//                    crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡:  搴撲綅绉昏浆
+//                    crnCommand.setSourcePosX((short) 5);     // 婧愬簱浣嶆帓
+//                    crnCommand.setSourcePosY((short) 1);     // 婧愬簱浣嶅垪
+//                    crnCommand.setSourcePosZ((short) 1);     // 婧愬簱浣嶅眰
+//                    crnCommand.setDestinationPosX((short) 6);     // 鐩爣搴撲綅鎺�
+//                    crnCommand.setDestinationPosY((short) 1);     // 鐩爣搴撲綅鍒�
+//                    crnCommand.setDestinationPosZ((short) 4);     // 鐩爣搴撲綅灞�
+////                crnCommand.setTraySize(sourceSta.getLocType1() == 2);     //搴撲綅绫诲瀷
+//                    if (!MessageQueue.offer(SlaveType.Crn, wrkMast9999.getCrnNo(), new Task(2, crnCommand))) {
+//                        News.error("" + mark + " - 2" + " - 13" + " - 鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", wrkMast9999.getCrnNo(), JSON.toJSON(crnCommand));
+//                    } else {
+//                        // 淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 12.鍚婅溅鍑哄簱涓�
+//                        Date now = new Date();
+//                        wrkMast9999.setWrkSts(12L);
+//                        wrkMast9999.setCrnStrTime(now);
+//                        wrkMast9999.setModiTime(now);
+//                        if (wrkMastMapper.updateById(wrkMast9999) == 0) {
+//                            News.error("" + mark + " - 2" + " - 14" + " - 淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 12.鍚婅溅鍑哄簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast9999.getWrkNo());
+//                        }
+//                        break;
+//                    }
+//                }
+//            }
             for (WrkMast wrkMast : wrkMasts) {
                 if (wrkMast == null) {
                     continue;
@@ -2581,18 +2554,18 @@
     public synchronized void autoEmptyOut() {
         SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
         List<Integer> list = new ArrayList<>();
-        list.add(1109);list.add(2031);
+        list.add(1108);list.add(2031);
         for (Integer site:list){
             Integer emptyCount = wrkMastMapper.countPakOutEmpty(site);
             StaProtocol staProtocol = null;
-            if(emptyCount >= 2 && site == 1109){
+            if(emptyCount >= 1 && site == 1108){
                 continue;
             }else if(emptyCount == 1 && site == 2031){
                 continue;
             }
             //濡傛灉绔欑偣鍙嚭绂佺敤锛屽垯涓嶇敓鎴愮┖鐩樺嚭搴撲换鍔�
             switch (site){
-                case 1109:staProtocol = devpThread.getStation().get(site - 2);break;
+                case 1108:staProtocol = devpThread.getStation().get(site - 2);break;
                 case 2031:staProtocol = devpThread.getStation().get(site);break;
             }
             if (staProtocol == null) {
@@ -2602,7 +2575,7 @@
             }
             if (staProtocol.isAutoing()  //鑷姩
                     && !staProtocol.isLoading()  //鏃犵墿
-                    && staProtocol.isOutEnable()  //鍙嚭淇″彿
+//                    && staProtocol.isOutEnable()  //鍙嚭淇″彿
                     && staProtocol.getWorkNo() == 0
             ) {
                 Short loctype1 = 1;
@@ -4240,7 +4213,9 @@
                     List<BasArmMast> basArmMastListRuning3 = basArmMastService.selectList(
                             new EntityWrapper<BasArmMast>()
                                     .eq("arm_no", basArm.getArmNo())
-                                    .eq("sorting_line", basArm.getSortingLineSou())
+                                    .eq(
+
+                                            "sorting_line", basArm.getSortingLineSou())
                                     .eq("status", 3)
                     );
                     if (basArmMastListRuning.isEmpty() && basArmMastListRuning3.isEmpty()){
@@ -4269,6 +4244,24 @@
                                         .eq("binding_tags", basArmMast.getBindingTags())
                         );
                         if (basArmMastListOrder.size()==1){
+                            Thread.sleep(100);
+
+
+                            List<BasArmMast> basArmMastListRuningBarCode2 = basArmMastService.selectList(
+                                    new EntityWrapper<BasArmMast>()
+                                            .eq("barcode", barcode)
+                            );
+                            if (!basArmMastListRuningBarCode2.isEmpty()){
+                                int binding_tags = basArmMastService.selectCount(
+                                        new EntityWrapper<BasArmMast>()
+                                                .eq("status", 2)
+                                                .eq("binding_tags", basArmMast.getBindingTags())
+                                );
+                                if (binding_tags<2){
+                                    armTaskAssignmentCallApiLogSave(staProtocol, "鏉$爜鏁版嵁宸插瓨鍦紒锛侊紒", staProtocol.getSiteId()+"鐮佸灈浣嶇疆锛屾潯鐮佹暟鎹鍦ㄨ嚜鍔ㄧ粍鎵�===>>" + barcode, false);
+                                    continue;
+                                }
+                            }
                             OrderDetlValueResultUtil orderDetlValueResultUtil = basArmMastService.selectOrderDetlValue(basArmMast.getOrderNo(), basArmMast.getSku());
 
                             if (Cools.isEmpty(orderDetlValueResultUtil)){
diff --git a/src/main/java/com/zy/core/MainProcess.java b/src/main/java/com/zy/core/MainProcess.java
index 7939396..fe3067e 100644
--- a/src/main/java/com/zy/core/MainProcess.java
+++ b/src/main/java/com/zy/core/MainProcess.java
@@ -92,7 +92,7 @@
 
                 if (i>10){
                     //绌烘墭鐩樿嚜鍔ㄥ嚭搴�
-//                    mainService.autoEmptyOut();
+                    mainService.autoEmptyOut();
                     //绌烘墭鐩樿嚜鍔ㄥ叆搴�
                     mainService.autoEmptyIn();
                     i=0;
@@ -132,7 +132,7 @@
                 try{
                     //RGV灏忚溅鍑哄叆搴撳彇璐т笅鍙�
                     mainService.rgvIoExecute(11);
-                    if(k > 3){
+                    if(k > 2){
                         mainService.rgvOutExecute();
                         k = 0;
                     }
@@ -157,7 +157,7 @@
             try {
 
                 // 闂撮殧
-                Thread.sleep(500);
+                Thread.sleep(400);
 
                 // 绯荤粺杩愯鐘舵�佸垽鏂�
                 if (!SystemProperties.WCS_RUNNING_STATUS.get()) {
@@ -165,11 +165,11 @@
                 }
 
                 //arm浠诲姟瀹屾垚
-                mainService.armMissionAccomplished();
-                mainService.armMissionAccomplishedScanToCheckIn();
+                mainService.armMissionAccomplished();//4==>5
+                mainService.armMissionAccomplishedScanToCheckIn();//3===銆�4
 
                 //arm浠诲姟涓嬪彂
-                mainService.armTaskAssignment();
+                mainService.armTaskAssignment();//0===銆�1
 
             } catch (Exception e) {
                 e.printStackTrace();
diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 8624f3f..e51db88 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -89,7 +89,7 @@
 //        add(2045);add(2046);add(2047);add(2048);
 //        add(2101);add(2102);add(2103);add(2104);add(2105);add(2106);add(2107);add(2108);add(2109);add(2110);
 //        add(2111);add(2112);add(2113);add(2114);add(2115);add(2116);add(2117);add(2118);add(2119);add(2120);
-//        add(4001);add(4003);add(4004);add(4006);
+        add(4001);add(4003);add(4004);add(4006);
     }};
 
     // 绔欑偣鍋忕Щ閲忔槧灏勮〃
@@ -127,13 +127,13 @@
     }};
 
     public static final Map<Integer, Integer> siteErrOffsetMap = new HashMap<Integer, Integer>() {{
-        put(1036, 512);put(1103, 476);put(1047, 452);put(2037, 270);
+        put(1036, 512);put(1103, 476);put(1047, 452);put(2037, 270);put(4001,294);
 
     }};
 
     // 鐗规畩绔欑偣闆嗗悎
     private static final Set<Integer> specialSites = new HashSet<>(
-            Arrays.asList(1001,1005,1008,1011,1015,1019,1022,1025,1029, 1032,1039,2004,2001,2007,2010,2016,2013,2019,2022,2025,4001,4004));
+            Arrays.asList(1001,1005,1008,1011,1015,1019,1022,1025,1029, 1032,1039,2004,2001,2007,2010,2016,2013,2019,2022,2025,2028,4001,4004));
 
     // 鐗规畩绔欑偣闆嗗悎
     private static final Set<Integer> specialSites2 = new HashSet<>(
@@ -150,7 +150,7 @@
         add(3); add(4); add(5);
     }};
     public static final ArrayList<Integer> staNosErrList = new ArrayList<Integer>() {{
-        add(1103);add(1036);add(1047);
+        add(1103);add(1036);add(1047);add(2037);
     }};
 
     private Integer count=0;
@@ -169,9 +169,9 @@
     public static int getOffsetBySiteId2(int siteId) {
         int offset = 0;
         if (specialSites.contains(siteId)) {
-            offset = 72; // 鐗规畩绔欑偣鍗� 96
+            offset = 72; // 鐗规畩绔欑偣鍗� 72
         } else {
-            offset = 60; // 鏅�氱珯鐐瑰崰 72
+            offset = 60; // 鏅�氱珯鐐瑰崰 60
         }
         return offset;
     }
@@ -406,8 +406,14 @@
                 boolean[] status = siemensS7Net.getByteTransform().TransBool(result.Content, offset + offset3, 1);
                 staProtocol.setAutoing(!status[0]);  // 鑷姩
                 boolean[] status1 = siemensS7Net.getByteTransform().TransBool(result.Content, offset + offset3 - 4, 3);
-
-                staProtocol.setLoading(!status1[0]);  // 鏈夌墿
+                boolean[] statusErr = siemensS7Net.getByteTransform().TransBool(result.Content, offset + 54, 1);
+                boolean loading = false;
+                if(!status1[0])
+//                        && statusErr[2])
+                {
+                    loading = true;
+                }
+                staProtocol.setLoading(loading);  // 鏈夌墿
 
                 staProtocol.setInEnable(status1[2]); // 鍙叆
                 staProtocol.setOutEnable(status1[2]);// 鍙嚭
@@ -427,10 +433,12 @@
         //鏉$爜鎵弿鍣�
 
         ArrayList<Integer> barcodeList = getBarcodeList();
-        OperateResultExOne<byte[]> reasultBarcode1 = siemensS7Net.Read("DB101.780", (short) 8);//1036
-        OperateResultExOne<byte[]> reasultBarcode2 = siemensS7Net.Read("DB104.548", (short) 8);//1047
-        OperateResultExOne<byte[]> reasultBarcode3 = siemensS7Net.Read("DB102.2780", (short) 8);//1103
-        OperateResultExOne<byte[]> reasultBarcode4 = siemensS7Net.Read("DB201.344", (short) 8);
+        OperateResultExOne<byte[]> reasultBarcode1 = siemensS7Net.Read("DB101.780", (short) 4);//1036
+        OperateResultExOne<byte[]> reasultBarcode2 = siemensS7Net.Read("DB104.548", (short) 4);//1047
+        OperateResultExOne<byte[]> reasultBarcode3 = siemensS7Net.Read("DB102.2780", (short) 4);//1103
+        OperateResultExOne<byte[]> reasultBarcode4 = siemensS7Net.Read("DB201.344", (short) 4);//2037
+        OperateResultExOne<byte[]> reasultBarcode5 = siemensS7Net.Read("DB400.112", (short) 4);//4001
+
         if(barcodeList.get(0) == 0){
             if(reasultBarcode1.IsSuccess){
                 Integer barcodeId = barcodeList.get(0);
@@ -459,15 +467,22 @@
                 }
 
             }
-        }else{
+        }else if(barcodeList.get(0) == 3){
             if(reasultBarcode4.IsSuccess){
                 Integer barcodeId = barcodeList.get(0);
-                String barcode = String.valueOf(siemensS7Net.getByteTransform().TransInt32(reasultBarcode3.Content, 0));
+                String barcode = String.valueOf(siemensS7Net.getByteTransform().TransInt32(reasultBarcode4.Content, 0));
                 BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcodeId + +1);
                 if(!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) {
                     barcodeThread.setBarcode(barcode);
                 }
-
+            }
+            if(reasultBarcode5.IsSuccess){
+                Integer barcodeId = barcodeList.get(1);
+                String barcode = String.valueOf(siemensS7Net.getByteTransform().TransInt32(reasultBarcode5.Content, 0));
+                BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcodeId + +1);
+                if(!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) {
+                    barcodeThread.setBarcode(barcode);
+                }
             }
         }
 

--
Gitblit v1.9.1