From 945764de58898661a3f3197e58353141b5deaf91 Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期三, 22 十月 2025 16:21:15 +0800
Subject: [PATCH] 侧面输送线出入库流程对接
---
src/main/java/com/zy/asrs/task/TaskLogScheduler.java | 43 ++++++++++++++++++++-----------------------
1 files changed, 20 insertions(+), 23 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/TaskLogScheduler.java b/src/main/java/com/zy/asrs/task/TaskLogScheduler.java
index 8ea8636..71ad90a 100644
--- a/src/main/java/com/zy/asrs/task/TaskLogScheduler.java
+++ b/src/main/java/com/zy/asrs/task/TaskLogScheduler.java
@@ -10,9 +10,9 @@
import com.zy.common.utils.Synchro;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
import java.io.IOException;
@@ -33,16 +33,9 @@
@Autowired
private TaskWrkReportService taskWrkReportService;
- @Value("${wms.url}")
- private String wmsUrl;
- @Value("${wms.TaskExecCallback}")
- private String TaskExecCallback;
-
-
- @Scheduled(cron = "0/3 * * * * ? ")
- public void execute() throws IOException {
-
+ @Scheduled(cron = "0/5 * * * * ? ")
+ public synchronized void execute() throws IOException {
for (TaskWrk taskWrk : taskWrkService.selectToBeHistoryData()) {
switch (taskWrk.getStatus()) {
case 4:
@@ -50,20 +43,24 @@
case 5:
break;
}
- TaskWrkReport taskWrkReport = new TaskWrkReport();
- TaskWrkLog taskWrkLog = new TaskWrkLog();
- Synchro.Copy(taskWrk, taskWrkReport);
- Synchro.Copy(taskWrk, taskWrkLog);
- if (!taskWrkReportService.insert(taskWrkReport)) {
- throw new CoolException("杞Щ鑷充笂鎶ヨ〃" + taskWrk);
- }
- if (!wrkLogService.insert(taskWrkLog)) {
- throw new CoolException("杞巻鍙叉。澶辫触" + taskWrk);
- }
- if (!taskWrkService.deleteById(taskWrk)) {
- throw new CoolException("浠诲姟妗ｅ垹闄ゅけ璐�" + taskWrk);
- }
+ exe(taskWrk);
}
}
+ @Transactional
+ public void exe(TaskWrk taskWrk) {
+ TaskWrkReport taskWrkReport = new TaskWrkReport();
+ TaskWrkLog taskWrkLog = new TaskWrkLog();
+ Synchro.Copy(taskWrk, taskWrkReport);
+ Synchro.Copy(taskWrk, taskWrkLog);
+ if (!wrkLogService.insert(taskWrkLog)) {
+ throw new CoolException("杞巻鍙叉。澶辫触" + taskWrk);
+ }
+ if (!taskWrkService.deleteById(taskWrk)) {
+ throw new CoolException("浠诲姟妗ｅ垹闄ゅけ璐�" + taskWrk);
+ }
+ if (!taskWrkReportService.insert(taskWrkReport)) {
+ throw new CoolException("杞Щ鑷充笂鎶ヨ〃" + taskWrk);
+ }
+ }
}
--
Gitblit v1.9.1