From f6e955d57bf5e885afde54a8c6eefe80bc1bec26 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期四, 30 十一月 2023 17:00:06 +0800
Subject: [PATCH] #出入库任务下发

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  284 +++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 207 insertions(+), 77 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 a52189a..c66b089 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -4,7 +4,10 @@
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Cools;
+import com.core.common.R;
 import com.core.exception.CoolException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.zy.asrs.domain.enums.TaskStatusType;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
 import com.zy.asrs.mapper.*;
@@ -22,6 +25,7 @@
 import com.zy.core.model.CrnSlave;
 import com.zy.core.model.DevpSlave;
 import com.zy.core.model.Task;
+import com.zy.core.model.command.CommandPackage;
 import com.zy.core.model.command.CrnCommand;
 import com.zy.core.model.protocol.CrnProtocol;
 import com.zy.core.model.protocol.StaProtocol;
@@ -38,8 +42,11 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.io.IOException;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 /**
  * 绔嬩綋浠撳簱WCS绯荤粺涓绘祦绋嬩笟鍔�
@@ -74,6 +81,11 @@
     private ConfigService configService;
     @Autowired
     private StaDescMapper staDescMapper;
+    @Autowired
+    private CommandInfoService commandInfoService;
+
+    @Autowired
+    private OpenServiceImpl openServiceImpl;
 
     @Value("${wms.url}")
     private String wmsUrl;
@@ -143,6 +155,7 @@
                         TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(workNo));
                         if (taskWrk != null) {
                             taskWrk.setMemo(errMsg);//灏嗛敊璇爜瀛樺叆澶囨敞瀛楁杩涜灞曠ず
+                            taskWrkMapper.updateById(taskWrk);
                         }
                         continue;
                     }
@@ -153,7 +166,29 @@
                     }
                     String barcode = barcodeThread.getBarcode();
                     if(!Cools.isEmpty(barcode)) {
-
+//                        ToWmsDTO toWmsDTO = new ToWmsDTO();
+//                        Map<String, Object> map = new HashMap<>();
+//                        map.put("x-api-key","7a15b5db-29b6-552c-8cff-0cfec3756da2");
+//                        List<Integer> list = openServiceImpl.getInEnableRoadway();
+//
+//                        //TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo());
+//                        toWmsDTO.setWarehouseId("1688469798893297665");
+//                        toWmsDTO.setContainerCode(param.getContainerCode());
+//                        toWmsDTO.setApplyType("TUNNEL");
+//                        toWmsDTO.setWharfSource(null);
+//                        toWmsDTO.setCanInboundTunnels(list);
+//                        String response = null;
+//                        try {
+//                            response = new HttpHandler.Builder()
+//                                    .setHeaders(map)
+//                                    .setUri(wmsUrl)
+//                                    .setPath("wcsManager/wcsInterface/inboundTaskApply")
+//                                    .setJson(JSON.toJSONString(toWmsDTO))
+//                                    .build()
+//                                    .doPost();
+//                        }catch (Exception e){
+//
+//                        }
                     }
                 }
 
@@ -202,31 +237,26 @@
                                     && crnProtocol.forkPosType == CrnForkPosType.HOME) {
                                 // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
 
-                                // 涓嬪彂绔欑偣淇℃伅
-                                staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue());
-                                String targetPoint = taskWrk.getTargetPoint();
-                                int i = Integer.parseInt(targetPoint);
-                                staProtocol.setStaNo((short)i);
-                                if (!CommandUtils.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol))) {
-                                    continue;
+                                //鍙栧嚭杈撻�佺嚎鍛戒护
+                                List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo());
+                                if (commandInfos.isEmpty()) {
+                                    continue;//鍛戒护绌�
                                 }
 
-                                // 鏇存柊宸ヤ綔妗g姸鎬佷负14
-                                taskWrk.setWrkSts(14);
-                                if (taskWrkMapper.updateById(taskWrk) != 0) {
-                                    // 澶嶄綅鍫嗗灈鏈�
-                                    crnThread.setResetFlag(true);
-
-                                    //鏇存柊搴撲綅鐘舵��
-                                    LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint());
-                                    locMast.setLocSts("O");//O.绌哄簱浣�
-                                    locMast.setBarcode("");//鎵樼洏鐮�
-                                    locMast.setModiTime(new Date());
-                                    locMast.setModiUser(9999L);
-                                    locMastService.updateById(locMast);
-                                } else {
-                                    log.error("鏇存柊宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负14澶辫触锛侊紒锛� [宸ヤ綔鍙�:{}]", taskWrk.getWrkNo());
+//                                CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);//鍙栧嚭鍛戒护鎶ユ枃
+//                                CrnCommand crnCommand = JSON.parseObject(commandPackage.getCommand().toString(), CrnCommand.class);
+                                Integer commandStep = taskWrk.getCommandStep();
+                                CommandInfo commandInfo = commandInfos.get(commandStep);
+                                CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);//鍙栧嚭鍛戒护鎶ユ枃
+                                //StaProtocol staProtocol1 = JSON.parseObject(commandInfo.getCommand(), StaProtocol.class);
+                                StaProtocol staProtocol1 = JSON.parseObject(commandPackage.getCommand().toString(), StaProtocol.class);
+                                if (!MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol1))) {
+                                    log.error("杈撻�佺嚎鍛戒护涓嬫柟澶辫触锛侊紒锛� [宸ヤ綔鍙�:{}]", taskWrk.getWrkNo());
+                                    continue;//鍛戒护涓嬪彂澶辫触
                                 }
+
+                                // 澶嶄綅鍫嗗灈鏈�
+                                crnThread.setResetFlag(true);
 
                             }
                         }
@@ -240,7 +270,7 @@
     /**
      * 鍏ュ嚭搴�  ===>>  鍫嗗灈鏈哄叆鍑哄簱浣滀笟涓嬪彂
      */
-    public synchronized void crnIoExecute(){
+    public synchronized void crnIoExecute() throws IOException {
         for (CrnSlave crn : slaveProperties.getCrn()) {
             // 鑾峰彇鍫嗗灈鏈轰俊鎭�
             CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());
@@ -285,7 +315,7 @@
     /**
      * 鍏ュ簱  ===>>  鍫嗗灈鏈虹珯鍒板簱浣�
      */
-    public void crnStnToLoc(CrnSlave slave, CrnProtocol crnProtocol){
+    public void crnStnToLoc(CrnSlave slave, CrnProtocol crnProtocol) throws IOException {
         for (CrnSlave.CrnStn crnStn : slave.getCrnInStn()) {
             List<StaDesc> staDescs = staDescMapper.selectList(new EntityWrapper<StaDesc>().eq("crn_no", slave.getId()).eq("crn_stn", crnStn.getStaNo()));
             for (StaDesc staDesc : staDescs) {
@@ -327,20 +357,17 @@
                     continue;
                 }
 
-                // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
-                CrnCommand crnCommand = new CrnCommand();
-                crnCommand.setCrnNo(slave.getId()); // 鍫嗗灈鏈虹紪鍙�
-                crnCommand.setTaskNo(taskWrk.getWrkNo().shortValue()); // 宸ヤ綔鍙�
-                crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
-                crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡:  搴撲綅绉昏浆
-                crnCommand.setSourcePosX(crnStn.getBay().shortValue());     // 婧愬簱浣嶅垪
-                crnCommand.setSourcePosY(crnStn.getLev().shortValue());     // 婧愬簱浣嶅眰
-                crnCommand.setSourcePosZ(crnStn.getRow().shortValue());     // 婧愬簱浣嶆帓
-                crnCommand.setDestinationPosX(Utils.getBayShort(taskWrk.getTargetPoint()));     // 鐩爣搴撲綅鍒�
-                crnCommand.setDestinationPosY(Utils.getLevShort(taskWrk.getTargetPoint()));     // 鐩爣搴撲綅灞�
-                crnCommand.setDestinationPosZ(Utils.getRowShort(taskWrk.getTargetPoint()));     // 鐩爣搴撲綅鎺�
-                crnCommand.setCommand((short)1);
-                if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) {
+                //鍙栧嚭鍛戒护
+                List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo());
+                Integer commandStep = taskWrk.getCommandStep();
+                if (commandInfos.isEmpty()) {
+                    continue;//鍛戒护绌�
+                }
+                CommandInfo commandInfo = commandInfos.get(commandStep);
+                CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);//鍙栧嚭鍛戒护鎶ユ枃
+                CrnCommand crnCommand = JSON.parseObject(commandPackage.getCommand().toString(), CrnCommand.class);
+
+                if (!MessageQueue.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) {
                     log.error("鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand));
                 } else {
                     // 淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓�
@@ -351,6 +378,31 @@
                         log.error("淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", taskWrk.getWrkNo());
                     }
                 }
+
+//                // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
+//                CrnCommand crnCommand = new CrnCommand();
+//                crnCommand.setCrnNo(slave.getId()); // 鍫嗗灈鏈虹紪鍙�
+//                crnCommand.setTaskNo(taskWrk.getWrkNo().shortValue()); // 宸ヤ綔鍙�
+//                crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
+//                crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡:  搴撲綅绉昏浆
+//                crnCommand.setSourcePosX(crnStn.getBay().shortValue());     // 婧愬簱浣嶅垪
+//                crnCommand.setSourcePosY(crnStn.getLev().shortValue());     // 婧愬簱浣嶅眰
+//                crnCommand.setSourcePosZ(crnStn.getRow().shortValue());     // 婧愬簱浣嶆帓
+//                crnCommand.setDestinationPosX(Utils.getBayShort(taskWrk.getTargetPoint()));     // 鐩爣搴撲綅鍒�
+//                crnCommand.setDestinationPosY(Utils.getLevShort(taskWrk.getTargetPoint()));     // 鐩爣搴撲綅灞�
+//                crnCommand.setDestinationPosZ(Utils.getRowShort(taskWrk.getTargetPoint()));     // 鐩爣搴撲綅鎺�
+//                crnCommand.setCommand((short)1);
+//                if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) {
+//                    log.error("鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand));
+//                } else {
+//                    // 淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓�
+//                    Date now = new Date();
+//                    taskWrk.setWrkSts(3);
+//                    taskWrk.setModiTime(now);
+//                    if (taskWrkMapper.updateById(taskWrk) == 0) {
+//                        log.error("淇敼宸ヤ綔妗g姸鎬� 2.璁惧涓婅蛋 => 3.鍚婅溅鍏ュ簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", taskWrk.getWrkNo());
+//                    }
+//                }
             }
 
             return;
@@ -446,20 +498,17 @@
                             }
                         }
 
-                        // 1.鍫嗗灈鏈哄紑濮嬬Щ鍔�
-                        CrnCommand crnCommand = new CrnCommand();
-                        crnCommand.setCrnNo(slave.getId()); // 鍫嗗灈鏈虹紪鍙�
-                        crnCommand.setTaskNo(taskWrk.getWrkNo().shortValue()); // 宸ヤ綔鍙�
-                        crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
-                        crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡:  搴撲綅绉昏浆
-                        crnCommand.setSourcePosX(Utils.getBayShort(taskWrk.getStartPoint()));     // 婧愬簱浣嶆帓
-                        crnCommand.setSourcePosY(Utils.getLevShort(taskWrk.getStartPoint()));     // 婧愬簱浣嶅垪
-                        crnCommand.setSourcePosZ(Utils.getRowShort(taskWrk.getStartPoint()));     // 婧愬簱浣嶅眰
-                        crnCommand.setDestinationPosX(crnStn.getBay().shortValue());     // 鐩爣搴撲綅鎺�
-                        crnCommand.setDestinationPosY(crnStn.getLev().shortValue());     // 鐩爣搴撲綅鍒�
-                        crnCommand.setDestinationPosZ(crnStn.getRow().shortValue());     // 鐩爣搴撲綅灞�
-                        crnCommand.setCommand((short)1);
-                        if (!CommandUtils.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) {
+                        //鍙栧嚭鍛戒护
+                        List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo());
+                        Integer commandStep = taskWrk.getCommandStep();
+                        if (commandInfos.isEmpty()) {
+                            continue;//鍛戒护绌�
+                        }
+                        CommandInfo commandInfo = commandInfos.get(commandStep);
+                        CommandPackage commandPackage = JSON.parseObject(commandInfo.getCommand(), CommandPackage.class);//鍙栧嚭鍛戒护鎶ユ枃
+                        CrnCommand crnCommand = JSON.parseObject(commandPackage.getCommand().toString(), CrnCommand.class);
+
+                        if (!MessageQueue.offer(SlaveType.Crn, taskWrk.getCrnNo(), new Task(2, crnCommand))) {
                             log.error("鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand));
                         } else {
                             // 淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 12.鍚婅溅鍑哄簱涓�
@@ -549,37 +598,68 @@
             if (crnProtocol == null) { continue; }
             //  鐘舵�侊細绛夊緟纭 骞朵笖  浠诲姟瀹屾垚浣� = 1
             if (crnProtocol.getTaskFinish() == 0 && crnProtocol.statusType == CrnStatusType.HANDLING_COMPLETED && crnProtocol.getTaskNo() != 0) {
-                // 鑾峰彇鍏ュ簱寰呯‘璁ゅ伐浣滄。
-                TaskWrk taskWrk = taskWrkMapper.selectCrnNoWorking(crn.getId(),crnProtocol.getTaskNo().intValue());
-                if (Cools.isEmpty(taskWrk)) {
-                    log.error("鍫嗗灈鏈哄浜庣瓑寰呯‘璁や笖浠诲姟瀹屾垚鐘舵�侊紝浣嗘湭鎵惧埌宸ヤ綔妗c�傚爢鍨涙満鍙�={}锛屽伐浣滃彿={}", crn.getId(), crnProtocol.getTaskNo());
+
+                //鑾峰彇鎸囦护ID
+                Integer commandId = crnProtocol.getCommandId();
+                CommandInfo commandInfo = commandInfoService.selectById(commandId);
+                if (commandInfo == null) {
+                    //鎸囦护涓嶅瓨鍦�
                     continue;
                 }
-                // 鍏ュ簱 + 搴撲綅杞Щ  ==> 4.鍏ュ簱瀹屾垚
-                if ((taskWrk.getWrkSts() == 3 && taskWrk.getIoType() == 1) || (taskWrk.getWrkSts() == 12 && taskWrk.getIoType() == 3)) {
-                    taskWrk.setWrkSts(4);
-                } else {
-                    continue;
-                }
-                Date now = new Date();
-                taskWrk.setModiTime(now);
-                Integer integerTaskWrk = taskWrkMapper.updateById(taskWrk);
-                // 淇敼鎴愬姛鍚庡浣嶅爢鍨涙満
-                if (integerTaskWrk > 0) {
+
+                commandInfo.setCommandStatus(CommandStatusType.COMPLETE.id);//鎸囦护瀹屾垚
+                commandInfo.setCompleteTime(new Date());//鎸囦护瀹屾垚鏃堕棿
+                if (commandInfoService.updateById(commandInfo)) {//淇敼鎴愬姛鍚庡浣嶅爢鍨涙満
                     // 鍫嗗灈鏈哄浣�
                     crnThread.setResetFlag(true);
-
-                    //鏇存柊搴撲綅鐘舵��
-                    LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint());
-                    locMast.setLocSts("F");//F.鍦ㄥ簱
-                    locMast.setBarcode(taskWrk.getBarcode());//鎵樼洏鐮�
-                    locMast.setModiTime(now);
-                    locMast.setModiUser(9999L);
-                    locMastService.updateById(locMast);
                 }
             }
         }
     }
+
+//    /**
+//     * 鎵ц瀵瑰伐浣滄。鐨勫畬鎴愭搷浣�
+//     */
+//    @Async
+//    public void storeFinished() {
+//        for (CrnSlave crn : slaveProperties.getCrn()) {
+//            // 鑾峰彇鍫嗗灈鏈轰俊鎭�
+//            CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());
+//            CrnProtocol crnProtocol = crnThread.getCrnProtocol();
+//            if (crnProtocol == null) { continue; }
+//            //  鐘舵�侊細绛夊緟纭 骞朵笖  浠诲姟瀹屾垚浣� = 1
+//            if (crnProtocol.getTaskFinish() == 0 && crnProtocol.statusType == CrnStatusType.HANDLING_COMPLETED && crnProtocol.getTaskNo() != 0) {
+//                // 鑾峰彇鍏ュ簱寰呯‘璁ゅ伐浣滄。
+//                TaskWrk taskWrk = taskWrkMapper.selectCrnNoWorking(crn.getId(),crnProtocol.getTaskNo().intValue());
+//                if (Cools.isEmpty(taskWrk)) {
+//                    log.error("鍫嗗灈鏈哄浜庣瓑寰呯‘璁や笖浠诲姟瀹屾垚鐘舵�侊紝浣嗘湭鎵惧埌宸ヤ綔妗c�傚爢鍨涙満鍙�={}锛屽伐浣滃彿={}", crn.getId(), crnProtocol.getTaskNo());
+//                    continue;
+//                }
+//                // 鍏ュ簱 + 搴撲綅杞Щ  ==> 4.鍏ュ簱瀹屾垚
+//                if ((taskWrk.getWrkSts() == 3 && taskWrk.getIoType() == 1) || (taskWrk.getWrkSts() == 12 && taskWrk.getIoType() == 3)) {
+//                    taskWrk.setWrkSts(4);
+//                } else {
+//                    continue;
+//                }
+//                Date now = new Date();
+//                taskWrk.setModiTime(now);
+//                Integer integerTaskWrk = taskWrkMapper.updateById(taskWrk);
+//                // 淇敼鎴愬姛鍚庡浣嶅爢鍨涙満
+//                if (integerTaskWrk > 0) {
+//                    // 鍫嗗灈鏈哄浣�
+//                    crnThread.setResetFlag(true);
+//
+//                    //鏇存柊搴撲綅鐘舵��
+//                    LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint());
+//                    locMast.setLocSts("F");//F.鍦ㄥ簱
+//                    locMast.setBarcode(taskWrk.getBarcode());//鎵樼洏鐮�
+//                    locMast.setModiTime(now);
+//                    locMast.setModiUser(9999L);
+//                    locMastService.updateById(locMast);
+//                }
+//            }
+//        }
+//    }
 
     /**
      * 鍫嗗灈鏈哄紓甯镐俊鎭褰�
@@ -715,7 +795,57 @@
             try {
                 taskWrkService.distribute(taskWrk.getTaskNo(), 9527L);
             } catch (CoolException e) {
-                e.printStackTrace();
+                log.info(e.getMessage());
+            }
+        }
+    }
+
+    //鑷姩瀹屾垚浠诲姟
+    public synchronized void autoCompleteTask() {
+        List<TaskWrk> taskWrks = taskWrkMapper.selectWorkingTask();
+        for (TaskWrk taskWrk : taskWrks) {
+            //鑾峰彇鍛戒护闆嗗悎
+            List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskWrk.getTaskNo());
+            if (taskWrk.getCommandStep() != commandInfos.size()) {
+                continue;//褰撳墠姝ュ簭娌℃湁鍒拌揪鏈�鍚庝竴鏉″懡浠�
+            }
+
+            //鍒ゆ柇鏈鍛戒护鏄惁鎵ц瀹屾垚
+            CommandInfo commandInfo = commandInfos.get(commandInfos.size() - 1);
+            if (commandInfo.getCommandStatus() != CommandStatusType.COMPLETE.id) {
+                continue;//鎸囦护鏈畬鎴�
+            }
+
+            Date now = new Date();
+            //鎸囦护宸插畬鎴愶紝鏇存柊浠诲姟
+            if (taskWrk.getIoType() == 1) {
+                //鍏ュ簱浠诲姟
+                taskWrk.setWrkSts(4);//3.鍚婅溅鍏ュ簱涓� => 4.鍏ュ簱瀹屾垚
+                taskWrk.setStatus(TaskStatusType.COMPLETE.id);
+                taskWrk.setModiTime(now);
+                taskWrkService.updateById(taskWrk);
+
+                //鏇存柊搴撲綅鐘舵��
+                LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint());
+                locMast.setLocSts("F");//F.鍦ㄥ簱
+                locMast.setBarcode(taskWrk.getBarcode());//鎵樼洏鐮�
+                locMast.setModiTime(now);
+                locMast.setModiUser(9999L);
+                locMastService.updateById(locMast);
+            } else if (taskWrk.getIoType() == 2) {
+                //鍑哄簱浠诲姟
+                taskWrk.setWrkSts(14);//12.鍚婅溅鍑哄簱涓� => 14.鍑哄簱瀹屾垚
+                taskWrk.setStatus(TaskStatusType.COMPLETE.id);
+                taskWrk.setModiTime(now);
+                taskWrkService.updateById(taskWrk);
+
+                //鏇存柊搴撲綅鐘舵��
+                LocMast locMast = locMastService.selectByLocNo(taskWrk.getStartPoint());
+                locMast.setLocSts("O");//O.绌哄簱浣�
+                locMast.setBarcode("");//鎵樼洏鐮�
+                locMast.setModiTime(now);
+                locMast.setModiUser(9999L);
+                locMastService.updateById(locMast);
             }
         }
     }

--
Gitblit v1.9.1