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 | 24 ++++++++++--------------
1 files changed, 10 insertions(+), 14 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 599d58b..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);
@@ -192,8 +188,8 @@
log.info("浠诲姟鎵ц鍙傛暟鍥炲啓:{}", JSON.toJSONString(params));
if (params.getNotifyType().equals("task")) {
//浠诲姟
- if (params.getMsgType().equals("task_complete")) {
- if (mast.getIoType() == 1 || mast.getIoType() == 10 || mast.getIoType() == 53 || mast.getIoType() == 54 || mast.getIoType() == 57) {
+ if (params.getMsgType().equals("task_complete") || params.getMsgType().equals("station_out_task_run")) {
+ 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