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

fix:任务完成bug修改

Browse Source
This commit is contained in:
lishuai
2024-08-01 19:18:05 +08:00
parent 522ac0f93e
commit 1d7f51601a
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/task/service/impl/TaskServiceImpl.java
View File

@@ -822,6 +822,7 @@ public class TaskServiceImpl extends CommonServiceImpl<TaskMapper, Task> impleme
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void finish(TaskIdAndStatusDTO taskIdAndStatus) { public void finish(TaskIdAndStatusDTO taskIdAndStatus) {
TaskDto entity = this.findById(taskIdAndStatus.getTask_id()); TaskDto entity = this.findById(taskIdAndStatus.getTask_id());
TaskDto updateTask = this.findById(taskIdAndStatus.getTask_id());
if (entity == null) { if (entity == null) {
throw new BadRequestException(LangProcess.msg("error_sysAuth")); throw new BadRequestException(LangProcess.msg("error_sysAuth"));
} }
@@ -840,7 +841,7 @@ public class TaskServiceImpl extends CommonServiceImpl<TaskMapper, Task> impleme
taskMapper.updateById(task); taskMapper.updateById(task);
//移除任务缓存信息 //移除任务缓存信息
this.removeByCodeFromCache(entity.getTask_code()); this.removeByCodeFromCache(entity.getTask_code());
if (!TaskStatusEnum.FINISHED.getIndex().equals(entity.getTask_status())) { if (!TaskStatusEnum.FINISHED.getIndex().equals(updateTask.getTask_status())) {
//反馈上位系统任务状态 //反馈上位系统任务状态
this.feedWmsTaskStatus(entity); this.feedWmsTaskStatus(entity);
//关闭仙工运单序列 //关闭仙工运单序列