root/lanzhouhailiang_one
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

opt:优化任务更新代码

Browse Source
This commit is contained in:
DESKTOP-5DIJMF9\admin
2025-03-06 13:21:48 +08:00
parent 793fdc62db
commit 002b9550a9
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java
View File

@@ -190,13 +190,17 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
if (ObjectUtil.isEmpty(taskObj)){ if (ObjectUtil.isEmpty(taskObj)){
throw new BadRequestException("未找到任务标识为：" + task_id + "的任务！"); throw new BadRequestException("未找到任务标识为：" + task_id + "的任务！");
} }
if (StrUtil.isNotEmpty(row.getString("car_no"))) {
WQLObject.getWQLObject("SCH_BASE_Task")
.update(MapOf.of("car_no",row.getString("car_no")),"task_id = '" + task_id + "'");
}
// 任务处理类 // 任务处理类
String processing_class = taskObj.getString("handle_class"); String processing_class = taskObj.getString("handle_class");
if (StrUtil.isEmpty(processing_class)) { if (StrUtil.isEmpty(processing_class)) {
throw new BadRequestException("当前任务的处理类未找到！"); throw new BadRequestException("当前任务的处理类未找到！");
} }
AbstractAcsTask abstractTask = (AbstractAcsTask)SpringContextHolder.getBean(Class.forName(taskObj.getString("handle_class"))); AbstractAcsTask abstractTask = (AbstractAcsTask)SpringContextHolder.getBean(Class.forName(taskObj.getString("handle_class")));
abstractTask.updateTaskStatus(taskObj,Task_Status_Convers.get(row.getString("task_status"))); abstractTask.updateTaskStatus(row,Task_Status_Convers.get(row.getString("task_status")));
} else { } else {
throw new BadRequestException("任务标识为：" + task_id + "的任务正在操作中！"); throw new BadRequestException("任务标识为：" + task_id + "的任务正在操作中！");
} }