From 707d414c0e6a8baff3ce7affec820f0fc1a13c19 Mon Sep 17 00:00:00 2001
From: skyouc <958836976@qq.com>
Date: 星期二, 24 二月 2026 09:06:04 +0800
Subject: [PATCH] no message

---
 src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java |   22 +++++++++-------------
 1 files changed, 9 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java b/src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java
index f428b29..41aec3b 100644
--- a/src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java
+++ b/src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java
@@ -127,22 +127,15 @@
      * @date 2026/1/10 13:58
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public R pubWrkToWcs(WorkTaskParams params) {
         if (Objects.isNull(params.getTaskNo())) {
             return R.error("浠诲姟鍙蜂笉鑳戒负绌猴紒锛�");
         }
-//        if (params.getType().equals("in"))
-//        if (Objects.isNull(params.getBarcode())) {
-//            return R.error("鎵樼洏鐮佷笉鑳戒负绌猴紒锛�");
-//        }
-//        if (Objects.isNull(params.getLocNo())) {
-//            return R.error("鐩爣搴撲綅涓嶈兘涓虹┖锛侊紒");
-//        }
         String url = MesConstant.PUB_TASK_IN;
         if (!Objects.isNull(params.getType()) && params.getType().equals("out")) {
             url = MesConstant.PUB_TASK_OUT;
         }
-
         log.info("鍑哄簱浠诲姟涓嬪彂鍙傛暟锛歿}", JSON.toJSONString(params));
         String response;
         try {
@@ -154,13 +147,16 @@
                     .doPost();
             Map<String, Object> result = JSON.parseObject(response, Map.class);
 
+            WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", params.getTaskNo()));
+            wrkMast.setWrkSts(12L);
+            if (!wrkMastService.updateById(wrkMast)) {
+                throw new CoolException("鏇存柊澶辫触锛侊紒");
+            }
             if (result.get("code").equals(200)) {
-                WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", params.getTaskNo()));
-                wrkMast.setWrkSts(12L);
-                wrkMastService.updateById(wrkMast);
                 //TODO 涓婃姤鏄惁鎴愬姛
             } else {
-                return R.error().add(result);
+                throw new CoolException("鍑哄簱涓嬪彂浠诲姟涓嬪彂澶辫触锛侊紒");
+//                return R.error().add(result);
             }
         } catch (IOException e) {
             throw new RuntimeException(e);
@@ -193,7 +189,7 @@
         if (params.getNotifyType().equals("task")) {
             //浠诲姟
             if (params.getMsgType().equals("task_complete")  || params.getMsgType().equals("station_out_task_run")) {
-                if (mast.getIoType() == 1 || mast.getIoType() == 10 || mast.getIoType() == 53 || mast.getIoType() == 54 || mast.getIoType() == 57) {
+                if (mast.getIoType() == 1 || mast.getIoType() == 11 || mast.getIoType() == 10 || mast.getIoType() == 53 || mast.getIoType() == 54 || mast.getIoType() == 57) {
                     mast.setWrkSts(4L);
                 } else if (mast.getIoType() == 101 || mast.getIoType() == 110 || mast.getIoType() == 103 || mast.getIoType() == 104  || mast.getIoType() == 107) {
                     mast.setWrkSts(14L);

--
Gitblit v1.9.1