From 259e38eb55c12b501427702d551d4de61182406c Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期六, 13 十二月 2025 15:03:12 +0800
Subject: [PATCH] 接口对接功能完善

---
 src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java |  253 +++++++++++++++++++++++++++++++++-----------------
 1 files changed, 168 insertions(+), 85 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
index 02b555d..38a457c 100644
--- a/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
@@ -4,18 +4,17 @@
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.common.Cools;
 import com.core.common.SnowflakeIdWorker;
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.mes.*;
-import com.zy.asrs.entity.rcs.RcsReporterTask;
-import com.zy.asrs.entity.rcs.RcsTaskContinue;
-import com.zy.asrs.entity.rcs.RcsTaskSubmit;
-import com.zy.asrs.entity.rcs.RcsTaskTargetRoute;
+import com.zy.asrs.entity.rcs.*;
 import com.zy.asrs.mapper.AgvInfoMapper;
 import com.zy.asrs.mapper.MatItemBarcodeMapper;
 import com.zy.asrs.service.*;
 import com.zy.asrs.utils.OrderInAndOutUtil;
+import com.zy.common.model.LocDetlDto;
 import com.zy.common.model.enums.WorkNoType;
 import com.zy.common.service.CommonService;
 import lombok.extern.slf4j.Slf4j;
@@ -86,6 +85,12 @@
 
     @Resource
     private MobileService mobileService;
+
+    @Resource
+    private WrkMastService wrkMastService;
+
+    @Resource
+    private WrkDetlService wrkDetlService;
 
 
     // region MES鎺ュ彛
@@ -267,7 +272,7 @@
                 orderDetlPakin.setMaktx(mat.getMaktx());
                 orderDetlPakin.setSpecs(mat.getSpecs());
                 orderDetlPakin.setModel(mat.getModel());
-                orderDetlPakin.setStandby1(JSONObject.toJSONString(mesMat.getItemBarcode()));   // 闆朵欢浜岀淮鐮�
+                orderDetlPakin.setStandby1(barCodeListToStr(mesMat.getItemBarcode()));   // 闆朵欢浜岀淮鐮�
                 orderDetlPakin.setStandby2("1");  //淇濆瓨榻愬鎬ф鏌ユ爣璇嗭紝1 妫�鏌ワ紱0 涓嶆鏌ワ紱
                 orderDetlPakin.setCreateBy(defaultUserId);
                 orderDetlPakin.setCreateTime(now);
@@ -361,48 +366,59 @@
      * @param mesOutApply
      * @return 1 鎴愬姛锛�-1 璁㈠崟閲嶅锛�
      */
+    @Transactional
     public int outBoundOrder(MesOutApply mesOutApply){
 
         // 绌烘墭鍑哄簱
         if (StringUtils.isEmpty(mesOutApply.getOrderNo()) && "01".equals(mesOutApply.getTransType())) {
             // 鐢熸垚绌烘墭鍑哄簱浠诲姟
-            mobileService.callEmptyBinOutBound(WMS_TRANS_START_STATION_1,"1",defaultUserId);
+            mobileService.callEmptyBinOutBound(mesOutApply,WMS_TRANS_START_STATION_1,"1",defaultUserId);
 
-            try {
-                if (!StringUtils.isEmpty(mesOutApply.getTaskno()) && !StringUtils.isEmpty(mesOutApply.getStationId())) {
-                    TransTask transTask = new TransTask();
-                    transTask.setTaskno(mesOutApply.getTaskno());
-                    transTask.setTaskname(mesOutApply.getTaskname());
-                    transTask.setOrderNo(mesOutApply.getOrderNo());
-                    transTask.setTransType(mesOutApply.getTransType());
-                    transTask.setCurStationId(WMS_TRANS_START_STATION_1);
-                    transTask.setNextProcess(mesOutApply.getProductLineId());
-                    transTask.setNextStationId(mesOutApply.getStationId());
-                    transTask.setItemno(WMS_ZPALLET_ID);  // 鍥哄畾涓虹┖鎵樼殑缂栫爜
-                    transTask.setQty(1);    // 绌烘墭鍙嚭1涓�
-                    transTask.setProductLineId(mesOutApply.getProductLineId());
-                    transTask.setOperateType(1);
-                    transTask.setAgvFactory(1);
-                    JSONObject sendAgvTask = submitTask(transTask);
-                    if (!"1".equals(sendAgvTask.getString("Success"))) {
-                        log.error("鍑哄簱涓嬪彂agv杩愯緭浠诲姟澶辫触锛歿}", JSONObject.toJSONString(transTask));
-                    }
-                }
-            } catch (Exception e) {
-                log.error("涓嬪彂AGV杩愯緭浠诲姟澶辫触", e);
-            }
+//            try {
+//                if (!StringUtils.isEmpty(mesOutApply.getTaskno()) && !StringUtils.isEmpty(mesOutApply.getStationId())) {
+//                    TransTask transTask = new TransTask();
+//                    transTask.setTaskno(mesOutApply.getTaskno());
+//                    transTask.setTaskname(mesOutApply.getTaskname());
+//                    transTask.setOrderNo(mesOutApply.getOrderNo());
+//                    transTask.setTransType(mesOutApply.getTransType());
+//                    transTask.setCurStationId(WMS_TRANS_START_STATION_1);
+//                    transTask.setNextProcess(mesOutApply.getProductLineId());
+//                    transTask.setNextStationId(mesOutApply.getStationId());
+//                    transTask.setItemno(WMS_ZPALLET_ID);  // 鍥哄畾涓虹┖鎵樼殑缂栫爜
+//                    transTask.setQty(1);    // 绌烘墭鍙嚭1涓�
+//                    transTask.setProductLineId(mesOutApply.getProductLineId());
+//                    transTask.setOperateType(1);
+//                    transTask.setAgvFactory(1);
+//                    JSONObject sendAgvTask = submitTask(transTask);
+//                    if (!"1".equals(sendAgvTask.getString("Success"))) {
+//                        log.error("鍑哄簱涓嬪彂agv杩愯緭浠诲姟澶辫触锛歿}", JSONObject.toJSONString(transTask));
+//                    }
+//                }
+//            } catch (Exception e) {
+//                log.error("涓嬪彂AGV杩愯緭浠诲姟澶辫触", e);
+//            }
 
             return 1;
         } else {    // 姣涘澂锛堢墿鏂欙級鍑哄簱
             // docType鏍规嵁搴撶被鍨嬬‘瀹�
             long docType = 7;
-            long settle = 1;
+            long settle = 2;
 
             // 鏍¢獙璁㈠崟鏄惁閲嶅
             OrderPakout order = orderPakoutService.selectByNo(mesOutApply.getOrderNo());
             if (order != null && !StringUtils.isEmpty(order.getOrderNo())) {
                 log.error("鍑哄簱璁㈠崟鍙烽噸澶嶏細{}",mesOutApply.getOrderNo());
                 return -1;
+            }
+            String itemBarcode = barCodeListToStr(mesOutApply.getItemBarcode());
+            // 鑷姩鍑哄簱
+            LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("standby1", itemBarcode));
+            if (locDetl == null) {
+                throw new CoolException("闆朵欢浜岀淮鐮佹病鏈夊尮閰嶅埌搴撳瓨锛�" +itemBarcode );
+            }
+            LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", locDetl.getLocNo()));
+            if (!locMast.getLocSts().equals("F")) {
+                throw new CoolException("搴撲綅鐘舵�佷笉涓篎锛�" +locMast.getLocNo() );
             }
 
             // 鐢熸垚璁㈠崟
@@ -420,6 +436,7 @@
             orderPakout.setUpdateTime(now);
             orderPakout.setMemo(JSONObject.toJSONString(mesOutApply));
             orderPakout.setPakinPakoutStatus(2);
+            orderPakout.setNumber(locMast.getBarcode()); // 鎵樼洏鏉$爜锛屼笂鎶ユ椂鐢�
             if (!orderPakoutService.insert(orderPakout)) {
                 log.error("MES淇濆瓨鍑哄簱璁㈠崟涓绘。澶辫触");
                 throw new CoolException("淇濆瓨鍑哄簱璁㈠崟涓绘。澶辫触");
@@ -431,12 +448,14 @@
             orderDetlPakout.setOrderId(orderPakout.getId());
             orderDetlPakout.setOrderNo(orderPakout.getOrderNo());
             orderDetlPakout.setAnfme(Double.valueOf(mesOutApply.getQty()));
+            orderDetlPakout.setWorkQty(orderDetlPakout.getAnfme());
             orderDetlPakout.setQty(0.0);
             orderDetlPakout.setMatnr(mat.getMatnr());
             orderDetlPakout.setMaktx(mat.getMaktx());
             orderDetlPakout.setSpecs(mat.getSpecs());
             orderDetlPakout.setModel(mat.getModel());
-            orderDetlPakout.setStandby1(barCodeListToStr(mesOutApply.getItemBarcode()));
+
+            orderDetlPakout.setStandby1(itemBarcode);
             orderDetlPakout.setCreateBy(defaultUserId);
             orderDetlPakout.setCreateTime(now);
             orderDetlPakout.setUpdateBy(defaultUserId);
@@ -448,48 +467,102 @@
                 throw new CoolException("淇濆瓨鍑哄簱璁㈠崟鏄庣粏妗eけ璐�");
             }
 
-            // 绔嬪簱鐢熸垚璁㈠崟鍚庯紝鑷姩璋冨害AGV杩愰�佸埌绔欑偣锛岀洰鍓嶅鎵樼敓鎴愬涓��
-            try {
-                if (!StringUtils.isEmpty(mesOutApply.getTaskno()) && !StringUtils.isEmpty(mesOutApply.getStationId())) {
-                    // 鎸夐浂浠朵簩缁寸爜鏌ヨ鏈夊嚑涓墭锛屽鎵樼敓鎴愬涓换鍔★紝姣忔墭瀵瑰簲闆朵欢浜岀淮鐮�
-                    String barCode = barCodeListToStr(mesOutApply.getItemBarcode());
-                    EntityWrapper<MatItemBarcode> matItemBarcodeEntityWrapper = new EntityWrapper<>();
-                    matItemBarcodeEntityWrapper.in("item_barcode", barCode);
-                    List<MatItemBarcode> barcodes = matItemBarcodeMapper.selectList(matItemBarcodeEntityWrapper);
-                     if (barcodes != null) {
-                        Map<String, List<MatItemBarcode>> map = barcodes.stream().collect(Collectors.groupingBy(MatItemBarcode::getZapplet));
-                        for (Map.Entry<String, List<MatItemBarcode>> entry : map.entrySet()) {
-                            List<MatItemBarcode> list = entry.getValue();
-                            List<String> codes = new ArrayList<>();
-                            for (MatItemBarcode zapllet : list) {
-                                codes.add(zapllet.getItemBarcode());
-                            }
+            // 鐢熸垚宸ヤ綔鍙�
+            int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(101));
+            // 鐢熸垚宸ヤ綔妗�
+            WrkMast wrkMast = new WrkMast();
+            wrkMast.setWrkNo(workNo);
+            wrkMast.setIoTime(now);
+            wrkMast.setWrkSts(11L); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID
+            wrkMast.setIoType(101); // 鍏ュ嚭搴撶姸鎬�
+            wrkMast.setIoPri(13D); // 浼樺厛绾э細13
+            wrkMast.setCrnNo(1);
+            wrkMast.setSourceStaNo("203"); // 婧愮珯
+            wrkMast.setStaNo("204"); // 鐩爣绔�
+            wrkMast.setSourceLocNo(locMast.getLocNo()); // 婧愬簱浣�
+            wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
+            wrkMast.setPicking("N"); // 鎷f枡
+            wrkMast.setExitMk("N"); // 閫�鍑�
+            wrkMast.setEmptyMk("N"); // 绌烘澘
+            wrkMast.setLinkMis("N");
+            wrkMast.setBarcode(locMast.getBarcode());
+            wrkMast.setAppeUser(defaultUserId); // 鎿嶄綔浜哄憳鏁版嵁
+            wrkMast.setAppeTime(now);
+            wrkMast.setModiUser(defaultUserId);
+            wrkMast.setModiTime(now);
+            wrkMast.setMemo(JSONObject.toJSONString(mesOutApply));
+            wrkMast.setTaskNo(mesOutApply.getTaskno());
+            wrkMast.setAgvSta(mesOutApply.getStationId());
+            wrkMastService.insert(wrkMast);
+            // 鐢熸垚宸ヤ綔妗f槑缁�
+                WrkDetl wrkDetl = new WrkDetl();
+                wrkDetl.sync(locDetl);
+                wrkDetl.setOrderNo(orderPakout.getOrderNo()); // 鎵嬪姩鍑哄簱涓嶉渶瑕佸甫鍑哄簱瀛樹腑鐨勫崟鎹紪鍙�
+                wrkDetl.setWrkNo(workNo);
+                wrkDetl.setIoTime(now);
+                wrkDetl.setAnfme(orderDetlPakout.getAnfme()); // 鏁伴噺
+                wrkDetl.setAppeTime(now);
+                wrkDetl.setAppeUser(defaultUserId);
+                wrkDetl.setModiTime(now);
+                wrkDetl.setModiUser(defaultUserId);
+//                wrkDetl.setMatnr(detlDto.getLocDetl().getMatnr());
+//                wrkDetl.setMaktx(detlDto.getLocDetl().getMaktx());
+//                wrkDetl.setUnit(detlDto.getLocDetl().getUnit());
+//                wrkDetl.setSpecs(detlDto.getLocDetl().getSpecs());
+//                wrkDetl.setUnit(detlDto.getLocDetl().getUnit());
+//                wrkDetl.setModel(detlDto.getLocDetl().getModel());
+                wrkDetlService.insert(wrkDetl);
 
-                            TransTask transTask = new TransTask();
-                            transTask.setTaskno(mesOutApply.getTaskno());
-                            transTask.setTaskname(mesOutApply.getTaskname());
-                            transTask.setOrderNo(mesOutApply.getOrderNo());
-                            transTask.setTransType(mesOutApply.getTransType());
-                            transTask.setCurStationId(WMS_TRANS_START_STATION_3);
-                            transTask.setNextProcess(mesOutApply.getProductLineId());
-                            transTask.setNextStationId(mesOutApply.getStationId());
-                            transTask.setItemno(mesOutApply.getItemno());
-                            transTask.setQty(list.size());
-                            transTask.setProductLineId(mesOutApply.getProductLineId());
-                            transTask.setItemBarcode(codes);
-                            transTask.setTuoPanId(entry.getKey());
-                            transTask.setOperateType(1);
-                            transTask.setAgvFactory(1);
-                            JSONObject sendAgvTask = submitTask(transTask);
-                            if (!"1".equals(sendAgvTask.getString("Success"))) {
-                                log.error("鍑哄簱涓嬪彂agv杩愯緭浠诲姟澶辫触", JSONObject.toJSONString(transTask));
-                            }
-                        }
-                    }
-                }
-            } catch (Exception e) {
-                log.error("涓嬪彂AGV杩愯緭浠诲姟澶辫触", e);
+            // 淇敼搴撲綅鐘舵��:   F.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害/P.鎷f枡/鐩樼偣/骞舵澘鍑哄簱涓�
+            if (locMast.getLocSts().equals("F")) {
+                locMast.setLocSts("R");
+                locMast.setModiUser(defaultUserId);
+                locMast.setModiTime(now);
+                locMastService.updateById(locMast);
             }
+            log.info("鍑哄簱浠诲姟鐢熸垚鎴愬姛锛屼换鍔″彿锛歿}",workNo);
+            // 绔嬪簱鐢熸垚璁㈠崟鍚庯紝鑷姩璋冨害AGV杩愰�佸埌绔欑偣锛岀洰鍓嶅鎵樼敓鎴愬涓��
+//            try {
+//                if (!StringUtils.isEmpty(mesOutApply.getTaskno()) && !StringUtils.isEmpty(mesOutApply.getStationId())) {
+//                    // 鎸夐浂浠朵簩缁寸爜鏌ヨ鏈夊嚑涓墭锛屽鎵樼敓鎴愬涓换鍔★紝姣忔墭瀵瑰簲闆朵欢浜岀淮鐮�
+////                    String barCode = barCodeListToStr(mesOutApply.getItemBarcode());
+////                    EntityWrapper<MatItemBarcode> matItemBarcodeEntityWrapper = new EntityWrapper<>();
+////                    matItemBarcodeEntityWrapper.in("item_barcode", barCode);
+////                    List<MatItemBarcode> barcodes = matItemBarcodeMapper.selectList(matItemBarcodeEntityWrapper);
+////                     if (barcodes != null) {
+////                        Map<String, List<MatItemBarcode>> map = barcodes.stream().collect(Collectors.groupingBy(MatItemBarcode::getZapplet));
+////                        for (Map.Entry<String, List<MatItemBarcode>> entry : map.entrySet()) {
+////                            List<MatItemBarcode> list = entry.getValue();
+////                            List<String> codes = new ArrayList<>();
+////                            for (MatItemBarcode zapllet : list) {
+////                                codes.add(zapllet.getItemBarcode());
+////                            }
+//
+//                            TransTask transTask = new TransTask();
+//                            transTask.setTaskno(mesOutApply.getTaskno());
+//                            transTask.setTaskname(mesOutApply.getTaskname());
+//                            transTask.setOrderNo(mesOutApply.getOrderNo());
+//                            transTask.setTransType(mesOutApply.getTransType());
+//                            transTask.setCurStationId(WMS_TRANS_START_STATION_3);
+//                            transTask.setNextProcess(mesOutApply.getProductLineId());
+//                            transTask.setNextStationId(mesOutApply.getStationId());
+//                            transTask.setItemno(mesOutApply.getItemno());
+//                            transTask.setQty(mesOutApply.getQty());
+//                            transTask.setProductLineId(mesOutApply.getProductLineId());
+//                            transTask.setItemBarcode(mesOutApply.getItemBarcode());
+//                            transTask.setTuoPanId(locDetl.getZpallet());
+//                            transTask.setOperateType(1);
+//                            transTask.setAgvFactory(1);
+//                            JSONObject sendAgvTask = submitTask(transTask);
+//                            if (!"1".equals(sendAgvTask.getString("Success"))) {
+//                                log.error("鍑哄簱涓嬪彂agv杩愯緭浠诲姟澶辫触", JSONObject.toJSONString(transTask));
+//                            }
+////                        }
+////                    }
+//                }
+//            } catch (Exception e) {
+//                log.error("涓嬪彂AGV杩愯緭浠诲姟澶辫触", e);
+//            }
         }
 
         return 1;
@@ -513,8 +586,8 @@
                     transTask.setOrderNo(mesInApply.getOrderNo());
                     transTask.setTransType(mesInApply.getTransType());
                     transTask.setCurProcess(mesInApply.getProductLineId());
-                    transTask.setCurStationId(mesInApply.getStationID());
-                    transTask.setNextStationId(WMS_TRANS_START_STATION_2);
+                    transTask.setCurStationId("A3");
+                    transTask.setNextStationId("A4");
                     transTask.setItemno(WMS_ZPALLET_ID);  // 鍥哄畾涓虹┖鎵樼殑缂栫爜
                     transTask.setQty(1);    // 绌烘墭鍙洖1涓�
                     transTask.setProductLineId(mesInApply.getProductLineId());
@@ -571,9 +644,9 @@
             orderDetlPakin.setMaktx(mat.getMaktx());
             orderDetlPakin.setSpecs(mat.getSpecs());
             orderDetlPakin.setModel(mat.getModel());
-            if (mesInApply.getProductInfo() != null) {
-                orderDetlPakin.setStandby1(JSONObject.toJSONString(mesInApply.getProductInfo())); //闆朵欢璇︽儏瀛樺湪1
-            }
+            List<String> itemBarcode = mesInApply.getProductInfo().stream().map(MesInApply.ProductInfo::getItemBarcode).collect(Collectors.toList());
+            orderDetlPakin.setStandby1(barCodeListToStr(itemBarcode)); //闆朵欢璇︽儏瀛樺湪1
+
             orderDetlPakin.setStandby2("0");  //淇濆瓨榻愬鎬ф鏌ユ爣璇嗭紝1 妫�鏌ワ紱0 涓嶆鏌ワ紱
             orderDetlPakin.setCreateBy(defaultUserId);
             orderDetlPakin.setCreateTime(now);
@@ -597,7 +670,6 @@
             waitPakin.setAppeTime(now);
             waitPakin.setModiUser(defaultUserId);
             waitPakin.setModiTime(now);
-            List<String> itemBarcode = mesInApply.getProductInfo().stream().map(MesInApply.ProductInfo::getItemBarcode).collect(Collectors.toList());
             waitPakin.setStandby1(barCodeListToStr(itemBarcode));
             waitPakinService.insert(waitPakin);
             OrderInAndOutUtil.increaseWorkQty(Boolean.TRUE, orderPakin.getId(), orderDetlPakin.getMatnr(), orderDetlPakin.getBatch(),
@@ -770,6 +842,9 @@
      * @return
      */
     public static String barCodeListToStr(List<String> list) {
+        if(list.isEmpty()) {
+            return "";
+        }
         StringBuilder stringBuilder = new StringBuilder();
         for (String str : list) {
             stringBuilder.append(str).append(",");
@@ -1047,8 +1122,14 @@
         rcsTaskSubmit.setTargetRoute(targetRouteList);
 
         // 杞彂缁欐捣搴锋垨鍗庢檽RCS
-        int success = rcsService.submitTask(rcsTaskSubmit, transTask.getAgvFactory());
-        if (success == 1) {
+        RcsReturn rcsReturn = rcsService.submitTask(rcsTaskSubmit, transTask.getAgvFactory());
+        if (rcsReturn.getCode().equals("SUCCESS")) {
+            JSONObject data = rcsReturn.getData();
+            String robotTaskCode = data.getString("robotTaskCode");
+            if (Cools.isEmpty(transTask.getTaskno())) {
+                transTask.setTaskno(robotTaskCode);
+                result.put("taskno", transTask.getTaskno());
+            }
             int workNo = commonService.getWorkNo(WorkNoType.OTHER.type);
             Date now = new Date();
             Task task = new Task();
@@ -1075,12 +1156,12 @@
             taskDetl.setIoTime(task.getIoTime());
             taskDetl.setMatnr(transTask.getItemno());
             taskDetl.setAnfme(0.0);
-            taskDetl.setStandby1(String.valueOf(transTask.getQty()));
+//            taskDetl.setStandby1(String.valueOf(transTask.getQty()));
             taskDetl.setMaktx(mat.getMaktx());
             taskDetl.setSpecs(mat.getSpecs());
             taskDetl.setOrderNo(transTask.getOrderNo());
             taskDetl.setZpallet(transTask.getTuoPanId());
-            taskDetl.setMemo(JSONObject.toJSONString(transTask.getItemBarcode()));
+            taskDetl.setMemo(barCodeListToStr(transTask.getItemBarcode()));
             taskDetl.setModiUser(defaultUserId);
             taskDetl.setModiTime(now);
             taskDetl.setAppeUser(defaultUserId);
@@ -1163,7 +1244,7 @@
      * @return
      */
     public int applyInStation(TransParent apply) {
-        String path = ("LL").equals(apply.getProductLineId()) ? "AGVTransportPalletNotice" : "AprsAGVTransportPalletNotice";
+        String path = ("LL").equals(apply.getProductLineId()) ? "AGVTransportPalletNotice" : "Aprs/AGVTransportPalletNotice";
         String url = MES_URL + path;
         String response = RcsServiceImpl.sendPost(url, JSONObject.toJSONString(apply));
         if (!StringUtils.isEmpty(response) && response.contains("Success")){
@@ -1195,7 +1276,7 @@
 //            rcsTaskContinue.setTriggerType("ROBOT");
 //            rcsTaskContinue.setTriggerCode(allow.getAgvCode());
 
-            int success = rcsService.continueTask(rcsTaskContinue, checkRcsFactory(allow.getAgvCode()));
+            int success = rcsService.continueTask(rcsTaskContinue, 1);
             mesReturn.setSuccess(success == 1 ? "1" : "2");
             mesReturn.setMessage(success == 1 ? "" : "杞彂缁橰CS澶辫触");
         }
@@ -1217,7 +1298,8 @@
             arrivalStation.setOrderNo(null);
         }
 
-        String url = MES_URL + "AGVArrivalCompleted";
+        String path = ("LL").equals(arrivalStation.getProductLineId()) ? "AGVArrivalCompleted" : "Aprs/AGVArrivalCompleted";
+        String url = MES_URL + path;
         String response = RcsServiceImpl.sendPost(url, JSONObject.toJSONString(arrivalStation));
         if (!StringUtils.isEmpty(response) && response.contains("Success")){
             MesReturn mesReturn = JSONObject.parseObject(response, MesReturn.class);
@@ -1282,7 +1364,8 @@
      */
     public int outStation(TransParent apply) {
 
-        String url = MES_URL + "AGVDepartureCompleted";
+        String path = ("LL").equals(apply.getProductLineId()) ? "AGVDepartureCompleted" : "Aprs/AGVDepartureCompleted";
+        String url = MES_URL + path;
         String response = RcsServiceImpl.sendPost(url, JSONObject.toJSONString(apply));
         if (!StringUtils.isEmpty(response) && response.contains("Success")){
             MesReturn mesReturn = JSONObject.parseObject(response, MesReturn.class);

--
Gitblit v1.9.1