opt:优化CTU出库逻辑

This commit is contained in:
2025-03-18 18:26:02 +08:00
parent c32e957d9a
commit 71daa15f32
4 changed files with 17 additions and 6 deletions

View File

@@ -85,8 +85,8 @@ public class SecondFloorAgvTransferTask extends AbstractTask {
SchBaseTask schBaseTask = iSchBaseTaskService.getOne(new QueryWrapper<SchBaseTask>().eq("task_code", data.getString("task_code")));
//货架解绑
TableDataInfo tableDataInfo = wmsToAcsService.bindPodAndBerth(schBaseTask.getPoint_code3(), schBaseTask.getPoint_code1(), "0", "bindPodAndBerth");
String bindResult = "200".equals(tableDataInfo.getCode()) ? "地面站点:" + schBaseTask.getPoint_code1() + "解绑" + schBaseTask.getPoint_code3() + "指令下发CTU返回解绑成功" :
"地面站点:" + schBaseTask.getPoint_code1() + "解绑" + schBaseTask.getPoint_code3() + "指令下发CTU返回解绑失败请操作站点解绑失败原因" + tableDataInfo.getMsg();
String bindResult = "200".equals(tableDataInfo.getCode()) ?"任务:"+schBaseTask.getTask_code()+"完成,地面站点:"+ schBaseTask.getPoint_code1() + "解绑" + schBaseTask.getPoint_code3() + "指令下发CTU返回解绑成功" :
"任务:"+schBaseTask.getTask_code()+"完成,地面站点:" + schBaseTask.getPoint_code1() + "解绑" + schBaseTask.getPoint_code3() + "指令下发CTU返回解绑失败请操作站点解绑失败原因" + tableDataInfo.getMsg();
iSchBaseTaskService.update(new LambdaUpdateWrapper<SchBaseTask>()
.set(SchBaseTask::getRemark, bindResult)
.eq(SchBaseTask::getId, schBaseTask.getId()));

View File

@@ -87,12 +87,19 @@ public class SecondFloorEmptyShelfTask extends AbstractTask {
.eq(SchBasePoint::getCode, schBaseTask.getPoint_code1()));
//货架绑定
TableDataInfo tableDataInfo = iSchBasePointService.bindOrUnbind(schBaseTask.getPoint_code2(), schBaseTask.getVehicle_code(), "1");
String bindResult = "200".equals(tableDataInfo.getCode()) ? "地面站点:" + schBaseTask.getPoint_code2() + "绑定" + schBaseTask.getVehicle_code() + "指令下发CTU返回绑定成功" :
"地面站点:" + schBaseTask.getPoint_code2() + "绑定" + schBaseTask.getVehicle_code() + "指令下发CTU返回绑定失败请操作站点绑定失败原因" + tableDataInfo.getMsg();
String bindResult = "200".equals(tableDataInfo.getCode()) ? "任务:"+schBaseTask.getTask_code()+"完成,地面站点:" + schBaseTask.getPoint_code2() + "绑定" + schBaseTask.getVehicle_code() + "指令下发CTU返回绑定成功" :
"任务:"+schBaseTask.getTask_code()+"完成,地面站点:"+ schBaseTask.getPoint_code2() + "绑定" + schBaseTask.getVehicle_code() + "指令下发CTU返回绑定失败请操作站点绑定失败原因" + tableDataInfo.getMsg();
iSchBaseTaskService.update(new LambdaUpdateWrapper<SchBaseTask>()
.set(SchBaseTask::getUpdate_time, DateUtil.now())
.set(SchBaseTask::getRemark, bindResult)
.set(SchBaseTask::getUpdate_name, SecurityUtils.getCurrentNickName())
.eq(SchBaseTask::getId, schBaseTask.getId()));
//点位状态更新
iSchBasePointService.update(new LambdaUpdateWrapper<SchBasePoint>()
.set(SchBasePoint::getUpdate_time, DateUtil.now())
.set(SchBasePoint::getRemark, bindResult)
.set(SchBasePoint::getUpdate_name, SecurityUtils.getCurrentNickName())
.eq(SchBasePoint::getCode,schBaseTask.getPoint_code2()));
}
@Override

View File

@@ -49,6 +49,9 @@ public class ToPickPlatformTask extends AbstractTask {
@Autowired
private ISchBasePointService iSchBasePointService;
/**
* 拣选出库任务
*/
@Override
@Transactional
public JSONObject createTask(JSONObject from) {
@@ -84,6 +87,7 @@ public class ToPickPlatformTask extends AbstractTask {
throw new BadRequestException("创建任务失败:未找到该物料对应起点仓位");
}
String start_struct_code = struct.getStruct_code();
//移库判断
if (struct.getStor_code().equals("FStockId")){
synchronized ("FStockId"){
start_struct_code= SpringContextHolder.getBean(OutStorageTask.class).DoubleStor(struct);

View File

@@ -159,7 +159,7 @@ public class SchBaseTaskServiceImpl extends ServiceImpl<SchBaseTaskMapper, SchBa
}
if (param.getString("status").equals(StatusEnum.FORM_STATUS.code("完成"))) {
//CTU任务处理
if (task.getAcs_type().equals(StatusEnum.ACS_TYPE.code("CTU任务"))) {
if (task.getProduct_area().equals(StatusEnum.PRODUCT_AREA.code("二层车间"))) {
handleFinishTask(param, task);
return;
}