From 82135a39198718fce5821b770dffdea1d2372c2c Mon Sep 17 00:00:00 2001
From: zc <zc@123>
Date: 星期五, 27 六月 2025 08:48:53 +0800
Subject: [PATCH] 123
---
src/main/java/com/zy/asrs/task/WrkMastScheduler.java | 35 ++++++++++++++++++++++++++---------
1 files changed, 26 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/WrkMastScheduler.java b/src/main/java/com/zy/asrs/task/WrkMastScheduler.java
index 5c4a431..aec69ad 100644
--- a/src/main/java/com/zy/asrs/task/WrkMastScheduler.java
+++ b/src/main/java/com/zy/asrs/task/WrkMastScheduler.java
@@ -2,6 +2,7 @@
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.common.Cools;
import com.zy.asrs.domain.enums.NotifyMsgType;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.WrkMast;
@@ -74,7 +75,10 @@
}
//涓婃姤
- notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_COMPLETE, JSON.toJSONString(wrkMast));
+ if (!Cools.isEmpty(wrkMast.getWmsWrkNo())) {
+ notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_COMPLETE, JSON.toJSONString(wrkMast));
+
+ }
}
}
@@ -117,7 +121,9 @@
}
//涓婃姤
- notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_COMPLETE, JSON.toJSONString(wrkMast));
+ if (!Cools.isEmpty(wrkMast.getWmsWrkNo())) {
+ notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_COMPLETE, JSON.toJSONString(wrkMast));
+ }
}
}
@@ -180,7 +186,9 @@
}
//涓婃姤
- notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_COMPLETE, JSON.toJSONString(wrkMast));
+ if (!Cools.isEmpty(wrkMast.getWmsWrkNo())) {
+ notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_COMPLETE, JSON.toJSONString(wrkMast));
+ }
}
}
@@ -203,12 +211,17 @@
WrkMast main = wrkMastService.selectByWorkNo(wrkMast.getMainWrkNo());
if (main != null) {
if (main.getIoType() == WrkIoType.IN.id) {
- main.setWrkSts(WrkStsType.INBOUND_SHUTTLE_RUN_COMPLETE.sts);
+ main.setWrkSts(WrkStsType.COMPLETE_INBOUND.sts);
} else if (main.getIoType() == WrkIoType.OUT.id) {
- main.setWrkSts(WrkStsType.OUTBOUND_LIFT_RUN_COMPLETE.sts);
+ main.setShuttleNo(wrkMast.getShuttleNo());
+ main.setWrkSts(WrkStsType.OUTBOUND_SHUTTLE_RUN_COMPLETE.sts);
+ //閭ｆ椂鍊欐墭鐩樺湪鎻愬崌鏈洪噷锛屽垯闇�瑕侀攣浣�
+ if (!(main.getStaNo() == 1013 || main.getStaNo() == 1024)) {
+ main.setLiftNo(1);
+ }
}
main.setModiTime(new Date());
- if (wrkMastService.updateById(main)) {
+ if (!wrkMastService.updateById(main)) {
log.info("鏇存柊涓诲伐浣滄。[workNo={}]澶辫触", wrkMast.getWrkNo());
}
}
@@ -242,7 +255,9 @@
}
//涓婃姤
- notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_CHARGE_COMPLETE, JSON.toJSONString(wrkMast));
+ if (!Cools.isEmpty(wrkMast.getWmsWrkNo())) {
+ notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_CHARGE_COMPLETE, JSON.toJSONString(wrkMast));
+ }
}
}
@@ -271,7 +286,7 @@
locMastService.updateById(locMast);
} else if (wrkMast.getIoType() == WrkIoType.OUT.id) {
LocMast locMast = locMastService.queryByLoc(wrkMast.getSourceLocNo());
- locMast.setLocSts(String.valueOf(LocStsType.O));
+ locMast.setLocSts(String.valueOf(LocStsType.F));
locMast.setModiTime(new Date());
locMastService.updateById(locMast);
} else if (wrkMast.getIoType() == WrkIoType.LOC_MOVE.id) {
@@ -291,7 +306,9 @@
}
//涓婃姤
- notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_CANCEL, JSON.toJSONString(wrkMast));
+ if (!Cools.isEmpty(wrkMast.getWmsWrkNo())) {
+ notifyUtils.notify("task", 1, String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.TASK_CANCEL, JSON.toJSONString(wrkMast));
+ }
}
}
--
Gitblit v1.9.1