FeiDaBaoKai/wms_serve_xugongteji
13
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码更新：

Browse Source 
回退一部分。
This commit is contained in:
梁州 2025-01-20 14:37:34 +08:00
parent 38baf12e7b
commit 21be3eed9e
2 changed files with 56 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ruoyi-quartz/pom.xml
View File

@ -38,12 +38,6 @@
<groupId>com.ruoyi</groupId> <groupId>com.ruoyi</groupId>
<artifactId>ruoyi-system</artifactId> <artifactId>ruoyi-system</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.ruoyi</groupId>
<artifactId>ruoyi-admin</artifactId>
<version>3.8.9</version>
<scope>compile</scope>
</dependency>
</dependencies> </dependencies>

114
ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/TaskExecutor.java
View File

@ -9,8 +9,6 @@ import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.http.HttpUtils; import com.ruoyi.common.utils.http.HttpUtils;
import com.ruoyi.common.utils.uuid.IdUtils; import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.system.service.ISysConfigService; import com.ruoyi.system.service.ISysConfigService;
import com.ruoyi.web.domain.WcsCommonResponse;
import com.ruoyi.web.domain.WcsStackerTaskRequest;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -93,66 +91,66 @@ public class TaskExecutor {
* 任务状态为0 * 任务状态为0
*/ */
public void sendWcsTask() { public void sendWcsTask() {
// 查询出所有的待下发的wcs任务 // // 查询出所有的待下发的wcs任务
AppWcsTask wcsTaskQuery = new AppWcsTask(); // AppWcsTask wcsTaskQuery = new AppWcsTask();
wcsTaskQuery.setWcsTaskStatus(0); // wcsTaskQuery.setWcsTaskStatus(0);
List<AppWcsTask> wcsTaskList = appWcsTaskService.selectAppWcsTaskList(wcsTaskQuery); // List<AppWcsTask> wcsTaskList = appWcsTaskService.selectAppWcsTaskList(wcsTaskQuery);
if (wcsTaskList == null || wcsTaskList.isEmpty()) { // if (wcsTaskList == null || wcsTaskList.isEmpty()) {
// 没有待下发的任务，跳过任务 // // 没有待下发的任务，跳过任务
return; // return;
} // }
// 获取请求地址 // // 获取请求地址
String url = sysConfigService.selectConfigByKey("wcs.url"); // String url = sysConfigService.selectConfigByKey("wcs.url");
if (StringUtils.isEmpty(url)) { // if (StringUtils.isEmpty(url)) {
// 查询不到wcs任务发送地址 // // 查询不到wcs任务发送地址
return; // return;
} // }
for (AppWcsTask appWcsTask : wcsTaskList) { // for (AppWcsTask appWcsTask : wcsTaskList) {
// 添加wcs任务请求 // // 添加wcs任务请求
WcsStackerTaskRequest wcsStackerTaskRequest = getWcsStackerTaskRequest(appWcsTask); // WcsStackerTaskRequest wcsStackerTaskRequest = getWcsStackerTaskRequest(appWcsTask);
// 发送http请求---请求5次 // // 发送http请求---请求5次
for (int i = 0; i < 5; i++) { // for (int i = 0; i < 5; i++) {
try { // try {
WcsCommonResponse wcsCommonResponse = JSON.parseObject(HttpUtils.sendPost(url, JSON.toJSONString(wcsStackerTaskRequest)), WcsCommonResponse.class); // WcsCommonResponse wcsCommonResponse = JSON.parseObject(HttpUtils.sendPost(url, JSON.toJSONString(wcsStackerTaskRequest)), WcsCommonResponse.class);
//
if (wcsCommonResponse == null) { // if (wcsCommonResponse == null) {
continue; // continue;
} // }
if (wcsCommonResponse.getCode() == 0) { // if (wcsCommonResponse.getCode() == 0) {
// 返回ok // // 返回ok
appWcsTask.setWcsTaskStatus(1);// 已经发送成功 // appWcsTask.setWcsTaskStatus(1);// 已经发送成功
} else { // } else {
// 返回error // // 返回error
appWcsTask.setWcsTaskStatus(999);// 任务异常 // appWcsTask.setWcsTaskStatus(999);// 任务异常
} // }
appWcsTask.setSendTime(new Date()); // appWcsTask.setSendTime(new Date());
appWcsTaskService.updateAppWcsTask(appWcsTask); // appWcsTaskService.updateAppWcsTask(appWcsTask);
// 请求成功，不再发送 // // 请求成功，不再发送
break; // break;
} catch (Exception e) { // } catch (Exception e) {
logger.error("任务发送异常。{}", JSON.toJSONString(e)); // logger.error("任务发送异常。{}", JSON.toJSONString(e));
} // }
} // }
} // }
} }
/** // /**
* 创建wcs请求 // * 创建wcs请求
* @param appWcsTask 任务 // * @param appWcsTask 任务
* @return 请求详情 // * @return 请求详情
*/ // */
private WcsStackerTaskRequest getWcsStackerTaskRequest(AppWcsTask appWcsTask) { // private WcsStackerTaskRequest getWcsStackerTaskRequest(AppWcsTask appWcsTask) {
WcsStackerTaskRequest wcsStackerTaskRequest = new WcsStackerTaskRequest(); // WcsStackerTaskRequest wcsStackerTaskRequest = new WcsStackerTaskRequest();
wcsStackerTaskRequest.setTaskId(appWcsTask.getWcsTaskId()); // wcsStackerTaskRequest.setTaskId(appWcsTask.getWcsTaskId());
wcsStackerTaskRequest.setTaskType(appWcsTask.getWcsTaskType()); // wcsStackerTaskRequest.setTaskType(appWcsTask.getWcsTaskType());
wcsStackerTaskRequest.setPriority(appWcsTask.getTaskPriority()); // wcsStackerTaskRequest.setPriority(appWcsTask.getTaskPriority());
wcsStackerTaskRequest.setOrigin(appWcsTask.getOrigin()); // wcsStackerTaskRequest.setOrigin(appWcsTask.getOrigin());
wcsStackerTaskRequest.setDestination(appWcsTask.getDestination()); // wcsStackerTaskRequest.setDestination(appWcsTask.getDestination());
wcsStackerTaskRequest.setVehicleNo(appWcsTask.getVehicleId()); // wcsStackerTaskRequest.setVehicleNo(appWcsTask.getVehicleId());
return wcsStackerTaskRequest; // return wcsStackerTaskRequest;
} // }
} }