From 3adff2c549121bc166f49aa8de681265cd87b2d9 Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期四, 19 六月 2025 09:49:09 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  321 +++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 274 insertions(+), 47 deletions(-)

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 ac3afb1..a6f9389 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -29,6 +29,7 @@
 import com.zy.core.enums.*;
 import com.zy.core.model.CrnSlave;
 import com.zy.core.model.DevpSlave;
+import com.zy.core.model.LedSlave;
 import com.zy.core.model.Task;
 import com.zy.core.model.command.CommandPackage;
 import com.zy.core.model.command.CrnCommand;
@@ -36,6 +37,7 @@
 import com.zy.core.model.protocol.StaProtocol;
 import com.zy.core.properties.SlaveProperties;
 import com.zy.core.thread.BarcodeThread;
+import com.zy.core.thread.LedThread;
 import com.zy.core.thread.SiemensDevpThread;
 import com.zy.system.entity.Config;
 import com.zy.system.service.ConfigService;
@@ -113,13 +115,15 @@
     private CrnController crnController;
     @Autowired
     private SiteController siteController;
+    @Autowired
+    private TaskWrkLogService taskWrkLogService;
 
     /**
      * 鍫嗗灈鏈烘紨绀�  ===>> 搴撲綅绉昏浆
      */
     public synchronized void crnDemoOfLocMove1() {
         try {
-            List <BasCrnp> basCrnps =basCrnpService.selectList(new EntityWrapper<BasCrnp>());
+            List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>());
             for (BasCrnp crn : basCrnps) {
                 if (!crn.getEmpIn().equals("1")) {
                     continue;
@@ -131,7 +135,7 @@
                 if (crnProtocol == null) {
                     continue;
                 }
-                TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("crn_no",crn.getCrnNo()).eq("io_type",3));
+                TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("crn_no", crn.getCrnNo()).eq("io_type", 3));
                 if (taskWrk1 != null) {
                     continue;
                 }
@@ -141,7 +145,7 @@
 
                     LocMast sourceLoc = locMastService.queryDemoSourceLoc(crn.getCrnNo());
 
-                    LocMast loc = locMastService.queryDemoLoc(crn.getCrnNo(),sourceLoc.getLocType1());
+                    LocMast loc = locMastService.queryDemoLoc(crn.getCrnNo(), sourceLoc.getLocType1());
                     if (null == sourceLoc || null == loc) {
                         continue;
                     }
@@ -152,7 +156,7 @@
                     // 淇濆瓨宸ヤ綔妗�
                     TaskWrk taskWrk = new TaskWrk();
                     taskWrk.setWrkNo(workNo);
-                    taskWrk.setTaskNo(workNo+"");//浠诲姟鍙�
+                    taskWrk.setTaskNo(workNo + "");//浠诲姟鍙�
                     taskWrk.setWrkSts(11); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID
                     taskWrk.setIoType(3); // 鍏ュ嚭搴撶姸鎬侊細 3.搴撴牸绉昏浇
                     taskWrk.setIoPri(13);
@@ -164,7 +168,7 @@
                     int res = taskWrkMapper.insert(taskWrk);
                     if (res == 0) {
                         throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
-                    }else {
+                    } else {
                         loc.setCtnKind(1);
                         locMastService.updateById(loc);
                     }
@@ -302,6 +306,8 @@
                     }
                     Short workNo = staProtocol.getWorkNo();
                     Short stano = staProtocol.getStaNo();
+                    //led
+                    LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed());
 
                     // 灏哄妫�娴嬪紓甯�
                     boolean back = false;
@@ -341,33 +347,41 @@
                             && staProtocol.isPakMk()) {
                         // 鑾峰彇鏉$爜鎵弿浠俊鎭�
                         BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, inSta.getBarcode());
-                        if (barcodeThread == null) {
-                            continue;
-                        }
-                        String BoxNo = barcodeThread.getBarcode();
-                        TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("barcode", BoxNo));
-                        if (!Cools.isEmpty(taskWrk1)) {
-                            log.info("鎵樼洏鐮侊細" + BoxNo + "浠诲姟妗e瓨鍦�");
-                            if (taskWrk1.getIoType() == 1 && taskWrk1.getStartPoint().equals(staProtocol.getSiteId().toString())) {
-                                StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
-                                        .eq("crn_no", taskWrk1.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId()));
-                                if (Cools.isEmpty(staDesc)) {
-                                    return;
-                                } else {
-                                    continue;
+                        String BoxNo = "";
+                        if (barcodeThread != null) {
+                            BoxNo = barcodeThread.getBarcode();
+                            TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("barcode", BoxNo));
+                            if (!Cools.isEmpty(taskWrk1)) {
+                                log.info("鎵樼洏鐮侊細" + BoxNo + "浠诲姟妗e瓨鍦�");
+                                if (taskWrk1.getIoType() == 1 && taskWrk1.getStartPoint().equals(staProtocol.getSiteId().toString())) {
+                                    StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+                                            .eq("crn_no", taskWrk1.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId()));
+                                    if (Cools.isEmpty(staDesc)) {
+                                        return;
+                                    } else {
+                                        continue;
+                                    }
+                                }
+                            }
+                            if (back) {
+                                storageEscalationParam.setWCSStatus(1);
+                                storageEscalationParam.setWCSErrorMessage(storageEscalationParam.getWCSErrorMessage() + errMsg);
+                                // led 寮傚父鏄剧ず
+                                if (ledThread != null) {
+                                    String errorMsg = errMsg;
+                                    MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
                                 }
                             }
                         }
-                        if (back) {
-                            storageEscalationParam.setWCSStatus(1);
-                            storageEscalationParam.setWCSErrorMessage(storageEscalationParam.getWCSErrorMessage() + errMsg);
-                        }
-                        log.info("缁勬墭鍏ュ簱={}", storageEscalationParam);
+
+
                         storageEscalationParam.setBoxNo(BoxNo);
                         //鏄惁婊℃澘 1婊℃澘  0绌烘澘
-                        storageEscalationParam.setStaType(staProtocol.isEmptyMk()? 0:1);
+                        storageEscalationParam.setStaType(staProtocol.isEmptyMk() ? 0 : 1);
                         //搴撲綅绫诲瀷 1楂樺簱浣� 0浣庡簱浣�
-                        storageEscalationParam.setLocType(staProtocol.isHigh()? 1:0);
+                        storageEscalationParam.setLocType(staProtocol.isHigh() ? 1 : 0);
+                        storageEscalationParam.setTerminalNo(staProtocol.getSiteId());
+                        log.info("缁勬墭鍏ュ簱={}", storageEscalationParam);
                         String response = "";
                         Boolean success = false;
                         try {
@@ -389,7 +403,7 @@
                                     // 鍒涙柊涓�涓叆搴撳伐浣滄。
                                     TaskWrk taskWrk = taskWrkService.selectByTaskNo(result.getTaskNo());
                                     if (Cools.isEmpty(taskWrk)) {
-                                        taskWrk = createTask1(result, BoxNo);
+                                        taskWrk = createTask1(result, BoxNo,staProtocol.getSiteId());
                                         if (Cools.isEmpty(taskWrk)) {
                                             log.error("搴撲綅寮傚父锛屽簱浣嶅彿锛�={}", taskWrk.getOriginTargetPoint());
                                         } else {
@@ -429,6 +443,11 @@
                                             }
                                         }
                                     } else {
+                                        // led 寮傚父鏄剧ず
+                                        if (ledThread != null) {
+                                            String errorMsg = "宸叉湁鍏ュ簱浠诲姟锛侊紒锛�";
+                                            MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
+                                        }
                                         staProtocol.setWorkNo((short) 9991);
                                         staProtocol.setStaNo(inSta.getBackSta().shortValue());
                                         devpThread.setPakMk(staProtocol.getSiteId(), false);
@@ -436,12 +455,186 @@
                                     }
 
                                 } else {
+
+                                    // led 寮傚父鏄剧ず
+                                    if (ledThread != null) {
+                                        String errorMsg = jsonObject.getString("ErrorMessage");
+                                        MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
+                                    }
+
                                     staProtocol.setWorkNo((short) 9991);
                                     staProtocol.setStaNo(inSta.getBackSta().shortValue());
                                     devpThread.setPakMk(staProtocol.getSiteId(), false);
                                     MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                 }
                             }
+                        } catch (Exception e) {
+                            log.error("璇锋眰鍏ュ簱璋冪敤鎺ュ彛澶辫触");
+                            log.error("寮傚父淇℃伅鎵撳嵃锛�" + e);
+                            try {
+                                BasDevp basDevp = basDevpService.selectById(inSta.getStaNo());
+                                if (Cools.isEmpty(basDevp)) {
+                                    log.error("绔欑偣鍙峰紓甯�" + inSta.getStaNo());
+                                } else if (basDevp.getStaErr() != 0) {
+                                    basDevp.setStaErr(2);
+                                    basDevpService.updateById(basDevp);
+                                }
+                            } catch (Exception e1) {
+                                // 閫�鍥�
+                                log.error("鎵爜妫�娴嬬▼搴忓紓甯�" + inSta.getStaNo() + "寮傚父淇℃伅" + e1);
+                            }
+                        } finally {
+                            apiLogService.save("wms璇锋眰鍏ュ簱璐т綅鎺ュ彛"
+                                    , wmsUrl + inboundTaskApplyPath
+                                    , null
+                                    , "127.0.0.1"
+                                    , JSON.toJSONString(storageEscalationParam)
+                                    , response
+                                    , success
+                            );
+                        }
+                        log.info("鍏ュ簱璇锋眰鍙傛暟=" + JSON.toJSONString(BoxNo));
+                        log.info("鍏ュ簱璇锋眰杩斿洖鍙傛暟=" + JSON.toJSONString(response));
+                    }
+                }
+            }
+        } catch (Exception e) {
+            log.error("generateStoreWrkFile e", e);
+            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+        }
+    }
+
+    //鎷f枡鍥炲簱
+    public synchronized void PickingAndReturningToTheWarehouse() throws IOException, InterruptedException {
+        try {
+            // 鏍规嵁杈撻�佺嚎plc閬嶅巻
+            for (DevpSlave devp : slaveProperties.getDevp()) {
+                // 閬嶅巻鍏ュ簱鍙�
+                for (DevpSlave.Sta inSta : devp.getPickSta()) {
+                    StorageEscalationParam storageEscalationParam = new StorageEscalationParam();
+                    // 鑾峰彇鍏ュ簱绔欎俊鎭�
+                    DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
+                    StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
+                    if (staProtocol == null) {
+                        continue;
+                    } else {
+                        staProtocol = staProtocol.clone();
+                    }
+                    Short workNo = staProtocol.getWorkNo();
+                    //led
+                    LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed());
+
+                    // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
+                    if (staProtocol.isAutoing() && staProtocol.isLoading()
+                            && staProtocol.isInEnable()
+                            && staProtocol.isPakMk()) {
+                        // 鑾峰彇鏉$爜鎵弿浠俊鎭�
+                        String BoxNo = "";
+                        //绔欑偣鎷f枡鍥炲簱浠诲姟鏄細鏈変竴鏉�
+                        TaskWrk taskWrkk =taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("start_point",staProtocol.getSiteId()));
+                        if (!Cools.isEmpty(taskWrkk)) {
+                            continue;
+                        }
+                        if(!staProtocol.isEmptyMk()&&staProtocol.getWorkNo()<9990){
+
+                            TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("wrk_no", workNo));
+
+                            if (!Cools.isEmpty(taskWrk1)) {
+                                BoxNo = taskWrk1.getBarcode();
+                            } else {
+                                TaskWrkLog taskWrkLog = taskWrkLogService.selectOne(new EntityWrapper<TaskWrkLog>().eq("wrk_no", workNo).orderBy("modi_time", false));
+                                if (taskWrkLog != null) {
+                                    BoxNo = taskWrkLog.getBarcode();
+                                }
+                            }
+                        }
+                        log.info("缁勬墭鍏ュ簱={}", storageEscalationParam);
+                        storageEscalationParam.setBoxNo(BoxNo);
+                        //鏄惁婊℃澘 1婊℃澘  0绌烘澘
+                        storageEscalationParam.setStaType(staProtocol.isEmptyMk() ? 0 : 1);
+                        //搴撲綅绫诲瀷 1楂樺簱浣� 0浣庡簱浣�
+                        storageEscalationParam.setLocType(staProtocol.isHigh() ? 1 : 0);
+                        storageEscalationParam.setTerminalNo(staProtocol.getSiteId());
+                        String response = "";
+                        Boolean success = false;
+                        try {
+                            response = new HttpHandler.Builder()
+                                    .setUri(wmsUrl)
+                                    .setPath(inboundTaskApplyPath)
+                                    .setJson(JSON.toJSONString(storageEscalationParam))
+                                    .build()
+                                    .doPost();
+                            JSONObject jsonObject = JSON.parseObject(response);
+
+                            if (!Cools.isEmpty(response) && !Cools.isEmpty(jsonObject.get("ReturnStatus")) && jsonObject.get("ReturnStatus").equals(0) && !Cools.isEmpty(jsonObject.get("Result").toString())) {
+                                Result result = JSON.parseObject(jsonObject.get("Result").toString(), Result.class);
+
+                                // 鍒涙柊涓�涓叆搴撳伐浣滄。
+                                TaskWrk taskWrk = taskWrkService.selectByTaskNo(result.getTaskNo());
+                                if (Cools.isEmpty(taskWrk)) {
+                                    taskWrk = createTask1(result, BoxNo,staProtocol.getSiteId());
+                                    if (Cools.isEmpty(taskWrk)) {
+                                        log.error("搴撲綅寮傚父锛屽簱浣嶅彿锛�={}", taskWrk.getOriginTargetPoint());
+                                    } else {
+                                        taskWrkService.insert(taskWrk);
+                                        StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+                                                .eq("crn_no", taskWrk.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId()));
+                                        staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue());
+                                        staProtocol.setStaNo(staDesc.getCrnStn().shortValue());
+                                        MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                                        HashMap<String, Object> hashMap = new HashMap<>();
+                                        hashMap.put("TaskNo", taskWrk.getTaskNo());
+                                        try {
+                                            //寮�濮嬩笂鎶�,浠诲姟寮�濮嬫椂锛學CS鍥炶皟WMS
+                                            response = new HttpHandler.Builder()
+                                                    .setUri(wmsUrl)
+                                                    .setPath(taskStatusFeedbackPath)
+                                                    .setJson(JSON.toJSONString(hashMap))
+                                                    .build()
+                                                    .doPost();
+                                            JSONObject jsonObject1 = JSON.parseObject(response);
+                                            Boolean bool = false;
+                                            if (jsonObject1.get("ReturnStatus").equals(0)) {
+                                                taskWrk.setStatus(2);//娲惧彂浠诲姟
+                                                bool = true;
+                                                taskWrkService.updateById(taskWrk);
+                                            }
+                                            apiLogService.save("wcs寮�濮嬪叆搴撲换鍔′笂鎶ms"
+                                                    , wmsUrl + TaskExecCallback
+                                                    , null
+                                                    , "127.0.0.1"
+                                                    , JSON.toJSONString(hashMap)
+                                                    , response
+                                                    , bool
+                                            );
+                                        } catch (Exception e) {
+
+                                        }
+                                    }
+                                } else {
+                                    // led 寮傚父鏄剧ず
+                                    if (ledThread != null) {
+                                        String errorMsg = "浠诲姟宸插瓨鍦紒锛侊紒锛�";
+                                        MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
+                                    }
+                                    staProtocol.setWorkNo((short) 9991);
+                                    staProtocol.setStaNo(inSta.getBackSta().shortValue());
+                                    devpThread.setPakMk(staProtocol.getSiteId(), false);
+                                    MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                                }
+
+                            } else {
+                                // led 寮傚父鏄剧ず
+                                if (ledThread != null) {
+                                    String errorMsg = jsonObject.getString("ErrorMessage");
+                                    MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
+                                }
+                                staProtocol.setWorkNo((short) 9991);
+                                staProtocol.setStaNo(inSta.getBackSta().shortValue());
+                                devpThread.setPakMk(staProtocol.getSiteId(), false);
+                                MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                            }
+
                         } catch (Exception e) {
                             log.error("璇锋眰鍏ュ簱璋冪敤鎺ュ彛澶辫触");
                             log.error("寮傚父淇℃伅鎵撳嵃锛�" + e);
@@ -782,7 +975,7 @@
                             staProtocol.setStaNo(staDesc.getStnNo().shortValue());
                             boolean offer = false;
                             try {
-                                offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
+                                offer = MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol));
                             } catch (Exception e) {
                                 log.error("涓嬪彂杈撻�佺嚎浠诲姟澶辫触锛氬紓甯�:" + e);
                                 log.error("涓嬪彂杈撻�佺嚎浠诲姟澶辫触锛氬紓甯�:offer:" + offer);
@@ -968,7 +1161,7 @@
 
                     LocMast locMast = locMastService.selectByLocNo(taskWrk.getStartPoint());
                     //鍒ゆ柇鍏跺簱浣嶆槸鍚︿负娣卞簱浣嶏紝濡傛灉涓烘繁搴撲綅鎵惧叾娴呭簱浣嶆槸閮芥湁璐�
-                    if (locMast.getRow1() == 1 || locMast.getRow1() == 5) {
+                    if (locMast.getRow1() == 5) {
                         LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>()
                                 .eq("row1", (locMast.getRow1() + 1))
                                 .eq("bay1", locMast.getBay1())
@@ -977,9 +1170,10 @@
                             log.info(locMast.getLocNo() + "鍑烘繁搴撲綅锛屾祬搴撲綅鏈夎揣");
                             continue;
                         }
-                    } else if (locMast.getRow1() == 4 || locMast.getRow1() == 8) {
+                    }
+                    if (locMast.getRow1() == 8) {
                         LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>()
-                                .eq("row1", (locMast.getRow1() - 1))
+                                .eq("row1", (locMast.getRow1() - 1 ))
                                 .eq("bay1", locMast.getBay1())
                                 .eq("lev1", locMast.getLev1()).eq("loc_sts", "F"));
                         if (!Cools.isEmpty(locMast1)) {
@@ -1013,11 +1207,11 @@
                         if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) {
                             break;
                         }
-                        int storeCount = basDevpService.getStoreCount();
-                        if (storeCount >= maxCount) {
-                            log.error("杈撻�佺嚎鏆傚瓨鏁拌揪鍒颁笂闄恵}", storeCount);
-                            break;
-                        }
+//                        int storeCount = basDevpService.getStoreCount();
+//                        if (storeCount >= maxCount) {
+//                            log.error("杈撻�佺嚎鏆傚瓨鏁拌揪鍒颁笂闄恵}", storeCount);
+//                            break;
+//                        }
 
 
                         // 宸茬粡瀛樺湪鍚婅溅鎵ц浠诲姟鏃讹紝鍒欒繃婊�
@@ -1627,9 +1821,8 @@
         return response;
     }
 
-    private TaskWrk createTask1(Result result, String barcode) {
+    private TaskWrk createTask1(Result result, String barcode,Integer staNo) {
         String locNo = Utils.Fusion(result.getRow(), result.getFloor(), result.getColumn());
-
 
         Date now = new Date();
         TaskWrk taskWrk = new TaskWrk();
@@ -1638,18 +1831,13 @@
         taskWrk.setWrkNo(workNo1);
         taskWrk.setStatus(TaskStatusType.RECEIVE.id);//浠诲姟鐘舵�侊細鎺ユ敹
         taskWrk.setCreateTime(now);
-        taskWrk.setIoType(1);//浠诲姟绫诲瀷
+        taskWrk.setIoType(1);//浠诲姟绫诲瀷 鍏ュ簱
         taskWrk.setIoPri(13);//浼樺厛绾�
         taskWrk.setBarcode(barcode);//鏉$爜
-        LocMast locMast = locMastService.selectByLocNo(locNo);
-        taskWrk.setCrnNo(locMast.getCrnNo());
         taskWrk.setTargetPoint(locNo);
-        taskWrk.setStartPoint("116");
-        if (result.getAlley().equals("1")) {
-            taskWrk.setCrnNo(1);
-        } else {
-            taskWrk.setCrnNo(2);
-        }
+        taskWrk.setStartPoint(staNo+"");
+        taskWrk.setCrnNo(Integer.valueOf(result.getAlley()));//鍫嗗灈鏈哄彿
+
         if (taskWrk.getIoType() == 1) {
             taskWrk.setWrkSts(2);
             if (!Cools.isEmpty(taskWrk.getTargetPoint())) {
@@ -1701,4 +1889,43 @@
         return taskWrk;
     }
 
+    //----------------------------------------------------------鐢佃鏈烘樉绀哄鐞�----------------------------------------
+    /**
+     * 鍏朵粬  ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅
+     */
+    public synchronized void ledReset(Integer mark) {
+
+//        log.info(""+mark+" - 0"+" - 寮�濮嬫墽琛�:鍏朵粬  ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅");
+        for (LedSlave led : slaveProperties.getLed()) {
+
+            // 鑾峰彇杈撻�佺嚎plc绾跨▼
+            DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, led.getDevpPlcId());
+            // 鍛戒护闆嗗悎
+            boolean reset = true;
+            for (Integer staNo : led.getStaArr()) {
+                // 鑾峰彇鍙夎溅绔欑偣
+                StaProtocol staProtocol = devpThread.getStation().get(staNo);
+                if (staProtocol == null) {
+                    continue;
+                }
+                if (staProtocol.getWorkNo() != 0 && staProtocol.isLoading()) {
+                    reset = false;
+                    break;
+                }
+            }
+            // 鑾峰彇led绾跨▼
+            LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, led.getId());
+            // led鏄剧ず榛樿鍐呭
+            if (reset && !ledThread.isLedMk()) {
+                ledThread.setLedMk(true);
+                if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(4, new ArrayList<>()))) {
+                    log.error(""+mark+" - 1"+" - {}鍙稬ED鍛戒护涓嬪彂澶辫触锛侊紒锛乕ip锛歿}] [port锛歿}]", led.getId(), led.getIp(), led.getPort());
+                } else {
+
+                }
+            }
+        }
+//        log.info(""+mark+" - 0"+" - 鎵ц瀹屾垚锛氬叾浠�  ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅");
+    }
+
 }

--
Gitblit v1.9.1