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

1

Browse Source
This commit is contained in:
15066119699 2025-03-11 14:45:39 +08:00
parent 652b594a29
commit 3ce5c6f762
2 changed files with 27 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
ruoyi-admin/src/main/java/com/ruoyi/web/controller/app/AppTaskController.java
View File

@ -168,7 +168,14 @@ public class AppTaskController extends BaseController
return success(appLocation);
}
private void updateAppTask(List<AppTask> appTasks){
for(AppTask appTask : appTasks){
AppTask appTask1 = new AppTask();
appTask1.setTaskId(appTask.getTaskId());
appTask1.setTaskStatus(appTask.getTaskStatus());
appTaskService.updateAppTask(appTask1);
}
}
/**
* 反馈任务状态
*/
@ -208,7 +215,8 @@ public class AppTaskController extends BaseController
if (thisWmsTaskList != null && !thisWmsTaskList.isEmpty()) {
// 更新wms任务状态
thisWmsTaskList.forEach(appTask -> appTask.setTaskStatus(2));// 执行中
appTaskService.batchUpdateAppTask(thisWmsTaskList);
// appTaskService.batchUpdateAppTask(thisWmsTaskList);
updateAppTask(thisWmsTaskList);
}
return success("反馈任务执行中成功。");
}
@ -222,7 +230,8 @@ public class AppTaskController extends BaseController
if (thisWmsTaskList != null && !thisWmsTaskList.isEmpty()) {
// 更新wms任务状态
thisWmsTaskList.forEach(appTask -> appTask.setTaskStatus(5));// 任务完成
appTaskService.batchUpdateAppTask(thisWmsTaskList);
// appTaskService.batchUpdateAppTask(thisWmsTaskList);
updateAppTask(thisWmsTaskList);
}
return success("反馈任务完成成功。");
}
@ -236,7 +245,8 @@ public class AppTaskController extends BaseController
if (thisWmsTaskList != null && !thisWmsTaskList.isEmpty()) {
// 更新wms任务状态
thisWmsTaskList.forEach(appTask -> appTask.setTaskStatus(8));// wcs取消任务
appTaskService.batchUpdateAppTask(thisWmsTaskList);
// appTaskService.batchUpdateAppTask(thisWmsTaskList);
updateAppTask(thisWmsTaskList);
}
return success("反馈任务取消成功。");
}
@ -249,7 +259,8 @@ public class AppTaskController extends BaseController
if (thisWmsTaskList != null && !thisWmsTaskList.isEmpty()) {
// 更新wms任务状态
thisWmsTaskList.forEach(appTask -> appTask.setTaskStatus(9));// 任务异常
appTaskService.batchUpdateAppTask(thisWmsTaskList);
// appTaskService.batchUpdateAppTask(thisWmsTaskList);
updateAppTask(thisWmsTaskList);
}
return success("反馈任务异常成功。");
}

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

@ -100,12 +100,22 @@ public class TaskExecutor {
}
if(!wcsTaskMap.isEmpty()) {
// 更新wms任务
appTaskService.batchUpdateAppTask(executingWmsTaskList);
//appTaskService.batchUpdateAppTask(executingWmsTaskList);
updateAppTask(executingWmsTaskList);
// 存储wcs任务
appWcsTaskService.batchInsertAppWcsTask(new ArrayList<>(wcsTaskMap.values()));
}
}
private void updateAppTask(List<AppTask> appTasks){
for(AppTask appTask : appTasks){
AppTask appTask1 = new AppTask();
appTask1.setTaskId(appTask.getTaskId());
appTask1.setWcsTaskId(appTask.getWcsTaskId());
appTask1.setTaskStatus(appTask.getTaskStatus());
appTaskService.updateAppTask(appTask1);
}
}
/**
* 发送wcs任务
* 任务状态为0