From 87f8618e3bb8bcc769884225238fb1d4d02afb43 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期六, 24 一月 2026 07:51:24 +0800
Subject: [PATCH] 1
---
zy-acs-cv/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java | 45 ++++++++++++++++++++++++++++-----------------
1 files changed, 28 insertions(+), 17 deletions(-)
diff --git a/zy-acs-cv/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java b/zy-acs-cv/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java
index 20af2ee..e87c503 100644
--- a/zy-acs-cv/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java
+++ b/zy-acs-cv/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java
@@ -278,11 +278,7 @@
Job job = jobMapper.getJobByJobNo(staProtocol.getWorkNo());
if (job != null && job.getJobSts() == 4) {
job.setJobSts(5);
- job.setRcsTime(new Date());
jobMapper.updateById(job);
- if (!fakeWms(staProtocol)) {
- throw new CoolException("浠诲姟鍙戦�佺粰RCS澶辫触," + job.getSeqNum() + " - " + job.getSeqNum());
- }
}
}
}
@@ -293,21 +289,36 @@
}
}
- public boolean fakeWms(StaProtocol staProtocol) {
- OpenBusSubmitParam openBusSubmitParam = new OpenBusSubmitParam();
- openBusSubmitParam.setBatch(DateUtils.convert(new Date()));
- List<TaskDto> taskList = new ArrayList<>();
- TaskDto taskDto = new TaskDto();
- taskDto.setSeqNum("SSX-RK" + staProtocol.getWorkNo());
- taskDto.setOriSta("1007");
- taskDto.setPriority(9527);
- taskList.add(taskDto);
- openBusSubmitParam.setTaskList(taskList);
- return sendTask(openBusSubmitParam, staProtocol);
+
+
+ @Transactional
+ public synchronized void fakeWms(Integer mark) {
+ List<Job> jobs = jobMapper.listJobByJobSts(5);
+ for (Job job : jobs) {
+ OpenBusSubmitParam openBusSubmitParam = new OpenBusSubmitParam();
+ openBusSubmitParam.setBatch(DateUtils.convert(new Date()));
+ List<TaskDto> taskList = new ArrayList<>();
+ TaskDto taskDto = new TaskDto();
+ taskDto.setSeqNum("SSX-RK" + job.getJobNo());
+ taskDto.setOriSta("1007");
+ taskDto.setPriority(9527);
+ taskList.add(taskDto);
+ openBusSubmitParam.setTaskList(taskList);
+ boolean b = sendTask(openBusSubmitParam);
+ if (b){
+ job.setJobSts(6);
+ job.setRcsTime(new Date());
+ jobMapper.updateById(job);
+ log.info("浠诲姟鍙戦�佺粰RCS鎴愬姛," + job.getSeqNum() + " - " + job.getJobNo());
+ }else {
+ log.info("浠诲姟鍙戦�佺粰RCS澶辫触," + job.getSeqNum() + " - " + job.getJobNo());
+ }
+ }
+
}
@Transactional
- public boolean sendTask(OpenBusSubmitParam openBusSubmitParam, StaProtocol staProtocol) {
+ public boolean sendTask(OpenBusSubmitParam openBusSubmitParam) {
String response = "";
try {
response = new HttpHandler.Builder()
@@ -356,7 +367,7 @@
for (StationStatus object : stationStatuses) {
if (object.getStaNo().equals(staNo + "")) {
if (object.getConveyable()) {
- return object.getSeqNum() == null ? System.currentTimeMillis() + "" : object.getSeqNum();
+ return object.getTaskNo();
} else {
log.info("绔欑偣锛歿}鐘舵�佷笉瀵�", staNo);
return null;
--
Gitblit v1.9.1