From ceb33d7020bcc1620d43cdcb9d1ea51a17c81a0d Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期三, 16 十月 2024 13:20:34 +0800
Subject: [PATCH] 整理三方接口

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   40 +++++++++++++++++++++++++++-------------
 1 files changed, 27 insertions(+), 13 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 febd4c4..6c4e932 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -12,6 +12,7 @@
 import com.zy.asrs.utils.RouteUtils;
 import com.zy.asrs.utils.Utils;
 import com.zy.asrs.utils.VersionUtils;
+import com.zy.common.constant.GhjtApiConstant;
 import com.zy.common.model.LocTypeDto;
 import com.zy.common.model.MatDto;
 import com.zy.common.model.SearchLocParam;
@@ -1591,8 +1592,10 @@
                 continue;
             }
 
+            log.info("{}鍙峰爢鍨涙満閫夊畾鐨勫嚭搴撳彛鏄瘂}",crnProtocol.getCrnNo(),crnStn.getPlatNo());
+
             // 宸ヤ綔妗g姸鎬佸垽鏂�
-            if (wrkMast.getIoType() < 100 || wrkMast.getSourceStaNo() == null) {
+            if ((wrkMast.getIoType() < 100 && wrkMast.getIoType()!=12) || wrkMast.getSourceStaNo() == null) {
                 log.error("鏌ヨ宸ヤ綔妗f暟鎹笉绗﹀悎鏉′欢--鍏ュ嚭绫诲瀷/绔欑偣, 宸ヤ綔鍙�={}锛屾簮搴撲綅={}锛屽叆鍑虹被鍨�={}", wrkMast.getWrkNo(), wrkMast.getSourceLocNo(), wrkMast.getIoType());
                 continue;
             }
@@ -1725,9 +1728,6 @@
      */
     private boolean crnEnabled(WrkMast wrkMast) {
 
-        String url = "http://192.168.14.249:8008";
-        String path = "/api/Task/DockStatus";
-
         // 鑾峰彇璇锋眰澶�
         Map<String,Object> headers = new HashMap<>();
         headers.put("digi-type","sync ");
@@ -1744,8 +1744,8 @@
         String response;
         try {
             response = new HttpHandler.Builder()
-                    .setUri(url)
-                    .setPath(path)
+                    .setUri(GhjtApiConstant.GWCS_IP_PORT)
+                    .setPath(GhjtApiConstant.GWCS_CKMT_URL)
                     .setHeaders(headers)
                     .setJson(body)
                     .build()
@@ -1758,8 +1758,8 @@
                     success = false;
                 }
             } else {
-                log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", url + path, body, response);
-                throw new CoolException("涓嬪彂鍑哄簱浠诲姟缁橤WCS(浠庡嚭搴撶爜澶村埌鍑哄簱鍙�)澶辫触");
+                log.error("纭鍑哄簱鐮佸ご鏄惁鍙敤澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", GhjtApiConstant.GWCS_IP_PORT + GhjtApiConstant.GWCS_CKMT_URL, body, response);
+                throw new CoolException("纭鍑哄簱鐮佸ご鏄惁鍙敤澶辫触");
             }
         } catch (Exception e) {
             success = false;
@@ -4636,13 +4636,20 @@
                         && crnProtocol.getForkPos() == 0) {
 
                     CrnSlave.CrnStn crnStn = null;
+                    CrnSlave.CrnStn crnStn2 = null;
                     for (CrnSlave.CrnStn crnStn1 : crn.getCrnOutStn()){
                         if(crnStn1.getStaNo().equals(wrkMast.getStaNo())){
                             crnStn = crnStn1;
                             break;
                         }
                     }
-                    if(Cools.isEmpty(crnStn)){
+                    for (CrnSlave.CrnStn crnStn1 : crn.getCrnInStn()){
+                        if(crnStn1.getStaNo().equals(wrkMast.getSourceStaNo())){
+                            crnStn2 = crnStn1;
+                            break;
+                        }
+                    }
+                    if(Cools.isEmpty(crnStn) || Cools.isEmpty(crnStn2)){
                         continue;
                     }
 
@@ -4652,13 +4659,13 @@
                     crnCommand.setTaskNo(wrkMast.getWrkNo().shortValue()); // 宸ヤ綔鍙�
                     crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
                     crnCommand.setTaskMode(CrnTaskModeType.LOC_MOVE); // 浠诲姟妯″紡:  搴撲綅绉昏浆
-                    //crnCommand.setSourcePosX(crnStn.getRow().shortValue());     // 婧愬簱浣嶆帓
-                    //crnCommand.setSourcePosY(crnStn.getBay().shortValue());     // 婧愬簱浣嶅垪
-                    //crnCommand.setSourcePosZ(crnStn.getLev().shortValue());     // 婧愬簱浣嶅眰
+                    crnCommand.setSourcePosX(crnStn2.getRow().shortValue());     // 婧愬簱浣嶆帓
+                    crnCommand.setSourcePosY(crnStn2.getBay().shortValue());     // 婧愬簱浣嶅垪
+                    crnCommand.setSourcePosZ(crnStn2.getLev().shortValue());     // 婧愬簱浣嶅眰
                     crnCommand.setDestinationPosX(crnStn.getRow().shortValue());     // 鐩爣搴撲綅鎺�
                     crnCommand.setDestinationPosY(crnStn.getBay().shortValue());     // 鐩爣搴撲綅鍒�
                     crnCommand.setDestinationPosZ(crnStn.getLev().shortValue());     // 鐩爣搴撲綅灞�
-                    crnCommand.setSourceStaNo(crnStn.getPlatNo().shortValue());     // 婧愬簱浣嶆帓
+//                    crnCommand.setSourceStaNo(crnStn.getPlatNo().shortValue());     // 婧愬簱浣嶆帓
                     if (!MessageQueue.offer(SlaveType.Crn, wrkMast.getCrnNo(), new Task(2, crnCommand))) {
                         log.error("鍫嗗灈鏈哄懡浠や笅鍙戝け璐ワ紝鍫嗗灈鏈哄彿={}锛屼换鍔℃暟鎹�={}", wrkMast.getCrnNo(), JSON.toJSON(crnCommand));
                     } else {
@@ -4677,4 +4684,11 @@
             }
         }
     }
+
+    /**
+     * 12.璺ㄥ贩閬撶Щ搴�
+     */
+    public synchronized void autoMoveLoc() {
+
+    }
 }

--
Gitblit v1.9.1