From 8e01a40be0a7ba61ece12870332b35a1fa3bfcd5 Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期五, 02 一月 2026 10:26:41 +0800
Subject: [PATCH] 1.新增agv状态请求离开 2.修复无法自动生成移库任务

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  314 +++++++++++++++++++++++----------------------------
 1 files changed, 143 insertions(+), 171 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 986bd05..473fa61 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -101,6 +101,8 @@
 
     @Autowired
     private HikUtils hikUtils;
+    @Autowired
+    private AgvTaskServiceImpl agvTaskService;
 
     /**
      * 缁勬墭
@@ -129,6 +131,38 @@
                 //LED
                 LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed());
 
+                // 灏哄妫�娴嬪紓甯�
+                boolean back = false;
+                String errMsg = "";
+                if (staProtocol.isFrontError()) {
+                    errMsg = "鍓嶈秴闄�";
+                    back = true;
+                }
+                if (!back && staProtocol.isBackError()) {
+                    errMsg = "鍚庤秴闄�";
+                    back = true;
+                }
+                if (!back && staProtocol.isHighError()) {
+                    errMsg = "楂樿秴闄�";
+                    back = true;
+                }
+                if (!back && staProtocol.isLeftError()) {
+                    errMsg = "宸﹁秴闄�";
+                    back = true;
+                }
+                if (!back && staProtocol.isRightError()) {
+                    errMsg = "鍙宠秴闄�";
+                    back = true;
+                }
+                if (!back && staProtocol.isWeightError()) {
+                    errMsg = "瓒呴噸";
+                    back = true;
+                }
+                if (!back && staProtocol.isBarcodeError()) {
+                    errMsg = "鎵爜澶辫触";
+                    back = true;
+                }
+
                 // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
                 if (!staProtocol.isLoading()) {
                     continue;
@@ -137,14 +171,39 @@
                 if (staProtocol.isAutoing()
                         && staProtocol.isInEnable()
                         && !staProtocol.isEmptyMk()
-                        && staProtocol.getWorkNo() == 9999
+                        && staProtocol.getWorkNo() >9990
+                        && staProtocol.isEmptyOutType()
                         && staProtocol.isPakMk()) {
                     News.warnNoLog("" + mark + " - 0" + " - 寮�濮嬫墽琛�");
+                    Short wrkNo = 9981;
+                    Short bark = 303;
+                    if(staProtocol.getSiteId()==304){
+                        wrkNo = 9982;
+                        bark = 306;
+                    }else if(staProtocol.getSiteId()==307){
+                        wrkNo = 9983;
+                        bark = 307;
+                    }
+
+                    if (back) {
+                        // led 寮傚父鏄剧ず
+                        if (ledThread != null) {
+                            String errorMsg = errMsg;
+                            MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
+                        }
+                        log.error("杈撻�佺嚎寮傚父缁勬墭閫�鍥�={}",errMsg);
+                        staProtocol.setWorkNo( wrkNo);
+
+                        staProtocol.setStaNo(bark);
+//                        devpThread.setPakMk(staProtocol.getSiteId(), false);
+                        boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                        continue;
+                    }
 
                     String barcode = barcodeThread.getBarcode();
                     if (!Cools.isEmpty(barcode)) {
                         News.info("" + mark + " - 1" + " - {}鍙锋潯鐮佹壂鎻忓櫒妫�娴嬫潯鐮佷俊鎭細{}", inSta.getBarcode(), barcode);
-                        if ("NG".endsWith(barcode) || "NoRead".equals(barcode) || "empty".equals(barcode)) {
+                        if ("NG".endsWith(barcode) || "NoRead".equals(barcode) || "empty".equals(barcode)|| "00000000".equals(barcode)) {
 //                            staProtocol.setWorkNo((short) 9992);
 //                            staProtocol.setStaNo(inSta.getBackSta().shortValue());
 //                            devpThread.setPakMk(staProtocol.getSiteId(), false);
@@ -155,6 +214,12 @@
                                 String errorMsg = "鎵爜澶辫触锛岃閲嶈瘯";
                                 MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
                             }
+                            log.error("杈撻�佺嚎寮傚父缁勬墭閫�鍥�={}",errMsg);
+                            staProtocol.setWorkNo( wrkNo);
+
+                            staProtocol.setStaNo(bark);
+//                        devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                             continue;
                         }
                     } else {
@@ -169,6 +234,12 @@
                             String errorMsg = "鎵爜澶辫触锛岃閲嶈瘯";
                             MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
                         }
+                        log.error("杈撻�佺嚎寮傚父缁勬墭閫�鍥�={}",errMsg);
+                        staProtocol.setWorkNo( wrkNo);
+
+                        staProtocol.setStaNo(bark);
+//                        devpThread.setPakMk(staProtocol.getSiteId(), false);
+                        boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                         continue;
                     }
 
@@ -283,6 +354,12 @@
                                 String errorMsg = jsonObject.getString("msg");
                                 MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
                             }
+                            log.error("杈撻�佺嚎寮傚父缁勬墭閫�鍥�={}",errMsg);
+                            staProtocol.setWorkNo( wrkNo);
+
+                            staProtocol.setStaNo(bark);
+//                        devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                         }
 
                     } catch (Exception e) {
@@ -540,7 +617,7 @@
                     if (staProtocol.isAutoing()
                             && staProtocol.isLoading()
                             && staProtocol.isInEnable()
-                            && staProtocol.getWorkNo() > 0
+                            && staProtocol.getWorkNo() == 9991
                             && staProtocol.isPakMk()) {
                         News.warnNoLog("" + mark + " - 0" + " - 寮�濮嬫墽琛�");
 
@@ -549,7 +626,21 @@
                         if (barcodeThread == null) {
                             continue;
                         }
+
+                        String name="401";
+                        if (staProtocol.getSiteId()==402){
+                            name = "402";
+                        }
+                        String bar = "";
+                        Config name1 = configService.selectOne(new EntityWrapper<Config>().eq("name", name));
+                        if (!Cools.isEmpty(name1)) {
+                            bar = name1.getValue();
+                        }
+
                         String barcode = barcodeThread.getBarcode();
+                        if (barcode.equals("00000000")){
+                            barcode = bar;
+                        }
                         if (!Cools.isEmpty(barcode)) {
                             News.info("" + mark + " - 1" + " - {}鍙锋潯鐮佹壂鎻忓櫒妫�娴嬫潯鐮佷俊鎭細{}", insta.getBarcode(), barcode);
                             if ("NG".endsWith(barcode) || "NoRead".equals(barcode)) {
@@ -606,7 +697,8 @@
                                 throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。澶辫触");
                             }
                             // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗�
-                            if (wrkMastMapper.saveWrkMastLog(wrkMast.getWrkNo()) == 0) {
+
+                            if (!wrkMastLogService.save(wrkMast.getWrkNo())) {
                                 throw new CoolException("淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗eけ璐�");
                             }
 
@@ -704,7 +796,7 @@
                 staProtocol = staProtocol.clone();
             }
 
-            if (staProtocol.isAutoing() && staProtocol.isLoading() && (staProtocol.getWorkNo() == 0 || staProtocol.getStaNo() == null)) {
+            if (staProtocol.isAutoing() && staProtocol.isLoading()) {
                 CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, wrkMast.getCrnNo());
                 CrnProtocol crnProtocol = crnThread.getCrnProtocol();
 
@@ -718,9 +810,6 @@
                             .eq("loc_no", wrkMast.getSourceLocNo()));
 
                     short staNo = wrkMast.getStaNo().shortValue();
-                    if (wrkMast.getStaNo() == 1004) {
-                        staNo = 2003;
-                    }
 
                     // 涓嬪彂绔欑偣淇℃伅
                     staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue());
@@ -1168,14 +1257,14 @@
                 }
                 //鏌ヨ鍦ㄥ簱淇℃伅
                 LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
-                        .eq("loc_sts", "R")
+                        .in("loc_sts", "R","P")
                         .eq("loc_no", wrkMast.getSourceLocNo()));
                 if (Cools.isEmpty(locMast)) {
                     News.error("鍑哄簱 ===>> 搴撲綅涓病鏈夎繖绗旇祫鏂�", wrkMast.getSourceLocNo());
                     continue;
                 }
                 //鍫嗗灈鏈烘帴椹崇珯鐐规病鏈夌┖鏂欐灦
-                if(staProtocol.getSiteId()==307&&!staProtocol.isEmptyOutType()&&(Cools.isEmpty(wrkMast.getCtnType())||wrkMast.getCtnType()==0)){
+                if(!staProtocol.isEmptyOutType()&&(Cools.isEmpty(wrkMast.getCtnType())||wrkMast.getCtnType()==0)){
                     //璇锋眰wms涓嬪彂agv鎼繍绌烘枡鏋跺埌鍫嗗灈鏈烘帴椹崇珯鐐逛换鍔�
                     try {
                         HashMap<String,Object> hashMap=new HashMap<>();
@@ -1198,17 +1287,17 @@
                         TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                     }
                 }
-                Boolean config = true;
 
-                if (staProtocol.getSiteId()==307 && !staProtocol.isEmptyOutType()){
-                    config = false;
-                }
-
-                // 鍒ゆ柇鍫嗗灈鏈哄嚭搴撶珯鐘舵��
+                // 鍒ゆ柇鍫嗗灈鏈哄嚭搴撶珯鐘舵��&& staProtocol.isOutEnable()
                 if (staProtocol.isAutoing() && !staProtocol.isLoading() && staDetl.getCanouting() != null && staDetl.getCanouting().equals("Y")
-                        && staProtocol.getWorkNo() == 0 && staProtocol.isOutEnable() && config) {
+                        && staProtocol.isEmptyOutType()) {
                     // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
 
+                    //鍒ゆ柇鏄惁鏈夋鍦ㄦ墽琛屼腑鐨凙GV浠诲姟
+                    List<AgvTask> agvTasks = agvTaskService.selectList(new EntityWrapper<AgvTask>().eq("wrk_sts", 302).eq("source_sta_no", staProtocol.getSiteId()));
+                    if (agvTasks != null && agvTasks.size() > 0) {
+                        continue;
+                    }
                     // 鍫嗗灈鏈烘帶鍒惰繃婊�
                     if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) {
 //                        continue;
@@ -1288,16 +1377,6 @@
                         }
                         break;
                     }
-                }else if ((staProtocol.getSiteId()==304 || staProtocol.getSiteId()==301) && staProtocol.isAutoing()
-                        && (staProtocol.isLoading() || staProtocol.getWorkNo() != 0)) {
-                    if (staProtocol.getSiteId() == 304){
-                        wrkMast.setSourceStaNo(301);
-
-                    }else {
-                        wrkMast.setSourceStaNo(304);
-                    }
-                    wrkMast.setModiTime(new  Date());
-                    wrkMastMapper.updateById(wrkMast);
                 }
 
             }
@@ -1805,10 +1884,7 @@
                 // 绔欑偣鏉′欢鍒ゆ柇
                 if (staProtocol.isAutoing()
                         && staProtocol.isInEnable()
-                        && staProtocol.isEmptyMk()
-                        && (staProtocol.getWorkNo() ==0)
                         && staProtocol.isPakMk()
-//                        && staProtocol.getEmptyInType() == 1
                 ) {
                     News.warnNoLog("" + mark + " - 0" + " - 寮�濮嬫墽琛岋細绌烘爤鏉垮垵濮嬪寲鍏ュ簱,鍙夎溅鍏ュ簱绔欐斁璐�");
 
@@ -1841,7 +1917,6 @@
 
                     try {
                         LocTypeDto locTypeDto = new LocTypeDto(staProtocol);
-
                         SearchLocParam param = new SearchLocParam();
                         param.setIoType(10);
                         param.setSourceStaNo(emptyInSta.getStaNo());
@@ -2021,9 +2096,8 @@
             DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, led.getDevpPlcId());
             // 鍛戒护闆嗗悎
             List<LedCommand> commands = new ArrayList<>();
-//            // 宸ヤ綔妗i泦鍚�
-//            List<WrkMast> wrkMasts = new ArrayList<>();
-            List<Integer> workNoList = new ArrayList<>();
+            // 宸ヤ綔妗i泦鍚�
+            List<WrkMast> wrkMasts = new ArrayList<>();
             for (Integer staNo : led.getStaArr()) {
                 // 鑾峰彇鍙夎溅绔欑偣
                 StaProtocol staProtocol = devpThread.getStation().get(staNo);
@@ -2032,48 +2106,20 @@
                 } else {
                     staProtocol = staProtocol.clone();
                 }
-                Integer wrkNo = null;
-                Integer ioType = null;
-                Integer targetStaNo = null;
-                String sourceLocNo = null;
-                String locNo = null;
-                String barcode = null;
-
                 // 鑾峰彇宸ヤ綔妗f暟鎹�
                 WrkMast wrkMast = wrkMastMapper.selectById(staProtocol.getWorkNo());
 //                if (null == wrkMast || wrkMast.getWrkSts() < 14 || wrkMast.getIoType() < 100) { continue; }
                 if (null == wrkMast) {
-                    List<WrkMastLog> wrkMastLogs = wrkMastLogService.selectList(new EntityWrapper<WrkMastLog>()
-                            .eq("wrk_no", staProtocol.getWorkNo())
-                            .orderBy("modi_time", false)
-                    );
-                    if (wrkMastLogs.isEmpty()) {
-                        continue;
-                    }
-
-                    WrkMastLog wrkMastLog = wrkMastLogs.get(0);
-                    wrkNo = wrkMastLog.getWrkNo();
-                    ioType = wrkMastLog.getIoType();
-                    sourceLocNo = wrkMastLog.getSourceLocNo();
-                    locNo = wrkMastLog.getLocNo();
-                    targetStaNo = wrkMastLog.getStaNo();
-                    barcode = wrkMastLog.getBarcode();
-                }else {
-                    wrkNo = wrkMast.getWrkNo();
-                    ioType = wrkMast.getIoType();
-                    sourceLocNo = wrkMast.getSourceLocNo();
-                    locNo = wrkMast.getLocNo();
-                    targetStaNo = wrkMast.getStaNo();
-                    barcode = wrkMast.getBarcode();
+                    continue;
                 }
-                News.warnNoLog("" + mark + " - 0" + " - 寮�濮嬫墽琛�:鍑哄簱  ===>> 宸ヤ綔妗d俊鎭啓鍏ed鏄剧ず鍣�");
-                workNoList.add(wrkNo);
+                News.warnNoLog(""+mark+" - 0"+" - 寮�濮嬫墽琛�:鍑哄簱  ===>> 宸ヤ綔妗d俊鎭啓鍏ed鏄剧ず鍣�");
+                wrkMasts.add(wrkMast);
                 // 缁勮鍛戒护
                 LedCommand ledCommand = new LedCommand();
-                ledCommand.setWorkNo(wrkNo);
-                ledCommand.setIoType(ioType);
+                ledCommand.setWorkNo(wrkMast.getWrkNo());
+                ledCommand.setIoType(wrkMast.getIoType());
                 // 鍑哄簱妯″紡
-                switch (ioType) {
+                switch (wrkMast.getIoType()) {
                     case 1:
                         ledCommand.setTitle("鍏ㄦ澘鍏ュ簱");
                         break;
@@ -2106,104 +2152,34 @@
                         ledCommand.setTitle("骞舵澘鍏ュ簱");
                         break;
                     default:
-                        News.error("" + mark + " - 1" + " - 浠诲姟鍏ュ嚭搴撶被鍨嬮敊璇紒锛侊紒[宸ヤ綔鍙凤細{}] [鍏ュ嚭搴撶被鍨嬶細{}]", wrkNo, ioType);
+                        News.error(""+mark+" - 1"+" - 浠诲姟鍏ュ嚭搴撶被鍨嬮敊璇紒锛侊紒[宸ヤ綔鍙凤細{}] [鍏ュ嚭搴撶被鍨嬶細{}]", wrkMast.getWrkNo(), wrkMast.getIoType());
                         break;
                 }
-                ledCommand.setSourceLocNo(sourceLocNo);
-                ledCommand.setLocNo(locNo);
-                ledCommand.setStaNo(targetStaNo);
-                ledCommand.setBarcode(barcode);
+                ledCommand.setSourceLocNo(wrkMast.getSourceLocNo());
+                ledCommand.setLocNo(wrkMast.getLocNo());
+                ledCommand.setStaNo(wrkMast.getStaNo());
 //                ledCommand.setSourceStaNo(wrkMast.getSourceStaNo());
-                if (ioType != 110 && ioType != 10) {
-                    List<WrkDetl> wrkDetls = wrkDetlService.findByWorkNo(wrkNo);
-
-                    if (!wrkDetls.isEmpty()) {
-                        WrkDetl wrkDetl = wrkDetls.get(0);
-                        double anfme = 0D;
-                        double weight = 0D;
-                        for (WrkDetl detl : wrkDetls) {
-                            anfme += detl.getAnfme();
-                            weight += detl.getWeight();
-                            wrkDetl.setAnfme(anfme);
-                            wrkDetl.setWeight(weight);
-                        }
-
-                        List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>()
-                                .eq("loc_no", wrkMast.getSourceLocNo()));
-                        double totalAnfme = 0D;
-                        double totalWeight = 0D;
-                        for (LocDetl locDetl : locDetls) {
-                            totalAnfme += locDetl.getAnfme();
-                            totalWeight += locDetl.getWeight();
-                        }
-                        wrkDetl.setStockNum(totalAnfme);
-                        wrkDetl.setStockNum2(totalWeight);
-
-                        ledCommand.getMatDtos().add(new MatDto(
-                                wrkDetl.getMatnr()
-                                , wrkDetl.getMaktx()
-                                , wrkDetl.getAnfme()
-                                , wrkDetl.getWeight()
-                                , wrkDetl.getStockNum()
-                                , wrkDetl.getStockNum2()
-                                , wrkDetl.getSpecs()
-                                , wrkDetl.getSku()
-                                , wrkDetl.getZpallet()
-                                , wrkDetl.getModel()
-                                , wrkDetl.getSupp()
-                                , wrkDetl.getKpCstmrName()
-                                , wrkDetl.getOrderNo()
-                                , wrkDetl.getCstateid$()
-                        ));
-
-                    }else {
-                        List<WrkDetlLog> wrkDetlLogs = wrkDetlLogService.selectTodayByWrkNo(wrkNo);
-                        if(!wrkDetlLogs.isEmpty()) {
-                            WrkDetlLog wrkDetlLog = wrkDetlLogs.get(0);
-
-                            double anfme = 0D;
-                            double weight = 0D;
-                            for (WrkDetlLog detl : wrkDetlLogs) {
-                                anfme += detl.getAnfme();
-                                weight += detl.getWeight();
-                                wrkDetlLog.setAnfme(anfme);
-                                wrkDetlLog.setWeight(weight);
+                if (wrkMast.getIoType() != 110 && wrkMast.getIoType() != 10) {
+                    List<WrkDetl> wrkDetls = wrkDetlService.findByWorkNo(wrkMast.getWrkNo());
+                    try{
+                        if (wrkMast.getIoType()>100){
+                            for (WrkDetl wrkDetl : wrkDetls){
+                                LocDetl locDetl = locDetlService.selectMatnrSpecs(wrkDetl.getMatnr(), wrkDetl.getSpecs(), wrkMast.getSourceLocNo());
+                                wrkDetl.setWeight(locDetl.getAnfme());
                             }
-
-                            List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>()
-                                    .eq("loc_no", sourceLocNo));
-                            double totalAnfme = 0D;
-                            double totalWeight = 0D;
-                            for (LocDetl locDetl : locDetls) {
-                                totalAnfme += locDetl.getAnfme();
-                                totalWeight += locDetl.getWeight();
+                        }else {
+                            for (WrkDetl wrkDetl : wrkDetls){
+                                wrkDetl.setWeight(wrkDetl.getAnfme());
                             }
-                            wrkDetlLog.setStockNum(totalAnfme);
-                            wrkDetlLog.setStockNum2(totalWeight);
-
-                            ledCommand.getMatDtos().add(new MatDto(
-                                    wrkDetlLog.getMatnr()
-                                    , wrkDetlLog.getMaktx()
-                                    , wrkDetlLog.getAnfme()
-                                    , wrkDetlLog.getWeight()
-                                    , wrkDetlLog.getStockNum()
-                                    , wrkDetlLog.getStockNum2()
-                                    , wrkDetlLog.getSpecs()
-                                    , wrkDetlLog.getSku()
-                                    , wrkDetlLog.getZpallet()
-                                    , wrkDetlLog.getModel()
-                                    , wrkDetlLog.getSupp()
-                                    , wrkDetlLog.getKpCstmrName()
-                                    , wrkDetlLog.getOrderNo()
-                                    , wrkDetlLog.getCstateid$()
-                            ));
                         }
+                    }catch (Exception e){
+                        log.error("宸ヤ綔妗f鏄庣粏杈撳叆鐢佃鏈哄け璐�1锛氬紓甯镐俊鎭�==銆�"+e);
                     }
-
+                    wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(),wrkDetl.getWeight(),wrkDetl.getSpecs(),wrkDetl.getSku())));
                 }
                 commands.add(ledCommand);
             }
-            Set<Integer> workNos = new HashSet<>(workNoList);
+            Set<Integer> workNos = wrkMasts.stream().map(WrkMast::getWrkNo).collect(Collectors.toSet());
             // 鑾峰彇LED绾跨▼
             LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, led.getId());
             // 鐩稿悓宸ヤ綔鍙烽泦鍚堝垯杩囨护
@@ -2234,22 +2210,19 @@
                 if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(3, commands))) {
                     News.error("{}鍙稬ED鍛戒护涓嬪彂澶辫触锛侊紒锛乕ip锛歿}] [port锛歿}]", led.getId(), led.getIp(), led.getPort());
                     continue;
-                } else {
+                }else {
                     ledThread.setLedMk(false);
                 }
             }
 
             try {
                 // 淇敼涓绘。led鏍囪
-                for (Integer wrkNo : workNoList) {
-                    WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", wrkNo));
-                    if (wrkMast != null) {
-                        wrkMast.setOveMk("Y");
-                        wrkMast.setModiTime(new Date());
-                        if (wrkMastMapper.updateById(wrkMast) == 0) {
-                            News.errorNoLog("" + mark + " - 4" + " - 鏇存柊宸ヤ綔妗eけ璐�");
-                            throw new CoolException("鏇存柊宸ヤ綔妗eけ璐�");
-                        }
+                for (WrkMast wrkMast : wrkMasts) {
+                    wrkMast.setOveMk("Y");
+                    wrkMast.setModiTime(new Date());
+                    if (wrkMastMapper.updateById(wrkMast) == 0) {
+                        News.errorNoLog(""+mark+" - 4"+" - 鏇存柊宸ヤ綔妗eけ璐�");
+                        throw new CoolException("鏇存柊宸ヤ綔妗eけ璐�");
                     }
                 }
 
@@ -2262,7 +2235,7 @@
             }
 
         }
-        News.infoNoLog("" + mark + " - 0" + " - 鍑哄簱  ===>> 宸ヤ綔妗d俊鎭啓鍏ed鏄剧ず鍣ㄦ墽琛屽畬鎴�");
+        News.infoNoLog(""+mark+" - 0"+" - 鍑哄簱  ===>> 宸ヤ綔妗d俊鎭啓鍏ed鏄剧ず鍣ㄦ墽琛屽畬鎴�");
     }
 
     /**
@@ -2270,7 +2243,7 @@
      */
     public synchronized void ledReset(Integer mark) {
 
-        News.warnNoLog("" + mark + " - 0" + " - 寮�濮嬫墽琛�:鍏朵粬  ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅");
+        News.warnNoLog(""+mark+" - 0"+" - 寮�濮嬫墽琛�:鍏朵粬  ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅");
         for (LedSlave led : slaveProperties.getLed()) {
 
             // 鑾峰彇杈撻�佺嚎plc绾跨▼
@@ -2294,13 +2267,13 @@
             if (reset && !ledThread.isLedMk()) {
                 ledThread.setLedMk(true);
                 if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(4, new ArrayList<>()))) {
-                    News.error("" + mark + " - 1" + " - {}鍙稬ED鍛戒护涓嬪彂澶辫触锛侊紒锛乕ip锛歿}] [port锛歿}]", led.getId(), led.getIp(), led.getPort());
+                    News.error(""+mark+" - 1"+" - {}鍙稬ED鍛戒护涓嬪彂澶辫触锛侊紒锛乕ip锛歿}] [port锛歿}]", led.getId(), led.getIp(), led.getPort());
                 } else {
 
                 }
             }
         }
-        News.infoNoLog("" + mark + " - 0" + " - 鎵ц瀹屾垚锛氬叾浠�  ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅");
+        News.infoNoLog(""+mark+" - 0"+" - 鎵ц瀹屾垚锛氬叾浠�  ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅");
     }
 
     /**
@@ -2436,7 +2409,6 @@
             int workNo = commonService.getWorkNo(0);
             // 淇濆瓨宸ヤ綔妗�
             WrkMast wrkMast = new WrkMast();
-            wrkMast.setId();
             wrkMast.setWrkNo(workNo);
             wrkMast.setIoTime(new Date());
             wrkMast.setWrkSts(11L); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID

--
Gitblit v1.9.1