fix:内包间任务异常

This commit is contained in:
zhangzq
2024-12-31 11:16:01 +08:00
parent b8459ca550
commit f173546356
11 changed files with 12 additions and 7 deletions

View File

@@ -17,6 +17,7 @@ import org.nl.modules.wql.util.SpringContextHolder;
import org.nl.wms.sch.AcsTaskDto;
import org.nl.wms.sch.manage.AbstractAcsTask;
import org.nl.wms.sch.manage.TaskStatusEnum;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;
@@ -27,6 +28,7 @@ import static org.nl.wms.util.TaskUtil.getRoutePlanCode;
/**
* Created by Lxy on 2021/12/22.
*/
@Service
public class TwoOutTask extends AbstractAcsTask {
private final String THIS_CLASS = TwoOutTask.class.getName();

View File

@@ -67,7 +67,7 @@ public class ShiftingTask extends AbstractAcsTask {
.priority(r.getPriority())
.remark(r.getRemark())
.product_area(r.getProduct_area())
.agv_action_type(r.getVehicle_code2())
.agv_action_type(PackageInfoIvtEnum.AGV_ACTION_TYPE.code("普通任务"))
.agv_system_type(PackageInfoIvtEnum.AGV_SYSTEM_TYPE.code("1楼诺宝任务"))
.build();
resultList.add(dto);

View File

@@ -199,7 +199,7 @@ public class AutoSendDjqToGzq {
} else {
task1.put("task_status", StringUtils.isBlank(pointCode4) ? TaskStatusEnum.SURE_START.getCode() : TaskStatusEnum.START_AND_POINT.getCode());
}
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("移库任务"));
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("普通任务"));
task1.put("task_type", PackageInfoIvtEnum.TASK_TYPE.code("待检区移库任务"));
task1.put("vehicle_code", shallowIvt.getContainer_name());
task1.put("point_code1", shallowIvt.getPoint_code());

View File

@@ -159,7 +159,7 @@ public class AutoSendGzqToDjq {
String taskId = djqTask.createTask(task);
//移库任务
JSONObject task1 = new JSONObject();
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("移库任务"));
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("普通任务"));
task1.put("task_type", PackageInfoIvtEnum.TASK_TYPE.code("待检区移库任务"));
task1.put("vehicle_code", groupIvtList.get(0).getContainer_name());
task1.put("point_code1", pointCode2);

View File

@@ -128,7 +128,7 @@ public class AutoSendMzToDjq {
String taskId = djqTask.createTask(task);
//移库任务
JSONObject task1 = new JSONObject();
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("移库任务"));
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("普通任务"));
task1.put("task_type", PackageInfoIvtEnum.TASK_TYPE.code("待检区移库任务"));
task1.put("vehicle_code", groupIvtList.get(0).getContainer_name());
task1.put("point_code1", pointCode2);

View File

@@ -192,7 +192,7 @@ public class AutoSendVehicleToDjq extends Prun{
taskId = sendGzqKzjTask.createTask(task);
task1.put("task_type", PackageInfoIvtEnum.TASK_TYPE.code("管制区移库任务"));
}
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("移库任务"));
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("普通任务"));
task1.put("vehicle_code", groupIvtList.get(0).getContainer_name());
task1.put("point_code1", pointCode2);
task1.put("point_code2", deepPointCode);

View File

@@ -240,7 +240,7 @@ public class AutoSendVehicleToKzj {
taskType = task.getString("task_type").equals(PackageInfoIvtEnum.TASK_TYPE.code("补空(待检区->空载具缓存位)")) ? PackageInfoIvtEnum.TASK_TYPE.code("待检区移库任务") : PackageInfoIvtEnum.TASK_TYPE.code("管制区移库任务");
JSONObject task1 = new JSONObject();
task1.put("task_type", taskType);
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("移库任务"));
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("普通任务"));
if (existTask != null) {
task1.put("task_status", StringUtils.isBlank(pointCode4) ? TaskStatusEnum.SURE_START.getCode() : TaskStatusEnum.SURE_END.getCode());
} else {

View File

@@ -130,7 +130,7 @@ public class TaskQueue {
JSONObject task1 = new JSONObject();
String pointCode2 = packageinfoivtService.getDjqShiftingPoint(shallowIvt, true);
task1.put("task_status", StringUtils.isBlank(pointCode2) ? TaskStatusEnum.SURE_START.getCode() : TaskStatusEnum.START_AND_POINT.getCode());
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("移库任务"));
task1.put("vehicle_code2", PackageInfoIvtEnum.AGV_ACTION_TYPE.code("普通任务"));
task1.put("task_type", PackageInfoIvtEnum.TASK_TYPE.code("待检区移库任务"));
task1.put("vehicle_code", shallowIvt.getContainer_name());
task1.put("point_code1", shallowIvt.getPoint_code());

View File

@@ -105,6 +105,7 @@ public class InBoxManageServiceImpl implements InBoxManageService {
.eq("point_code1", whereJson.getString("device_code"))
.eq("vehicle_code", whereJson.getString("box_no"))
.eq("task_type", "010702")
.eq("is_delete", "0")
.lt("task_status", TaskStatusEnum.FINISHED.getCode()));
if (count>0){
return;

View File

@@ -74,6 +74,7 @@ public class InVehicleManageServiceImpl implements InVehicleManageService {
.eq("point_code1", whereJson.getString("device_code"))
.eq("vehicle_code", whereJson.getString("vehicle_code"))
.eq("task_type", "010705")
.eq("is_delete", "0")
.lt("task_status", TaskStatusEnum.EXECUTING.getCode()));
if (count>0){
return;

View File

@@ -2040,6 +2040,7 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
.eq("point_code1", whereJson.getString("device_code"))
.eq("task_type", "010703")
.eq("vehicle_code2", whereJson.getString("vehicle_code"))
.eq("is_delete", "0")
.lt("task_status", TaskStatusEnum.EXECUTING.getCode()));
if (count>0){
log.info("acs申请入库任务以存在直接跳过"+whereJson.getString("vehicle_code"));