Commit fa7b9dc2 LN

1

1 个父辈 c8940fb3
...@@ -741,7 +741,17 @@ public class TaskService implements ITaskService { ...@@ -741,7 +741,17 @@ public class TaskService implements ITaskService {
} }
return false; return false;
} }
public boolean hasNowExeTask(String cid, int type) {
for (DataLog task : taskMap.values()) {
if (task.isCancel() || task.isFinished() || task.isEnd()) {
continue;
}
if (task.isExecuting() && type == task.getType() && task.getCid().equals(cid)) {
return true;
}
}
return false;
}
/** /**
* 获取正在执行出库(或入库)的 boxID,用作出入库时分配仓位,防止卡死的问题 * 获取正在执行出库(或入库)的 boxID,用作出入库时分配仓位,防止卡死的问题
*/ */
......
...@@ -120,10 +120,10 @@ public class SmdXlBoxHandler { ...@@ -120,10 +120,10 @@ public class SmdXlBoxHandler {
// return statusBean; // return statusBean;
// } // }
//判断如果有执行中的入库任务,直接返回 //判断如果有执行中的入库任务,直接返回
if(taskService.hasExecutingTask(statusBean.getCid(), StorageConstants.OP.CHECKOUT)){ if(taskService.hasNowExeTask(statusBean.getCid(), StorageConstants.OP.CHECKOUT)){
return statusBean; return statusBean;
} }
if(taskService.hasExecutingTask(statusBean.getCid(), StorageConstants.OP.PUT_IN)){ if(taskService.hasNowExeTask(statusBean.getCid(), StorageConstants.OP.PUT_IN)){
return statusBean; return statusBean;
} }
for (DataLog task : queueTasks) { for (DataLog task : queueTasks) {
......
支持 Markdown 格式
你添加了 0 到此讨论。请谨慎行事。
Finish editing this message first!