Browse Source

opt:添加等待点任务日志

master
zds 4 months ago
parent
commit
baad130191
  1. 1
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/service/impl/AcsToWmsServiceImpl.java
  2. 3
      lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/POINTTask.java

1
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/service/impl/AcsToWmsServiceImpl.java

@ -232,6 +232,7 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
@Override @Override
public BaseResponse feedbackState(JSONObject param) { public BaseResponse feedbackState(JSONObject param) {
log.info("ACS任务阶段反馈最新点位,信息:{}!", param.toString());
String requestNo = param.getString("requestNo"); String requestNo = param.getString("requestNo");
String taskId = param.getString("taskId"); String taskId = param.getString("taskId");
BaseResponse result = BaseResponse.build(requestNo); BaseResponse result = BaseResponse.build(requestNo);

3
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/task/tasks/POINTTask.java

@ -310,6 +310,8 @@ public class POINTTask extends AbstractTask {
@Override @Override
protected void feedbackTaskState(JSONObject param,SchBaseTask schBaseTask, BaseResponse result) { protected void feedbackTaskState(JSONObject param,SchBaseTask schBaseTask, BaseResponse result) {
log.info("feedbackTaskState方法,param:"+param.toString());
log.info("feedbackTaskState方法,变更前schBaseTask:"+schBaseTask.toString());
if(schBaseTask.getPoint_code2().startsWith("DKT")){ if(schBaseTask.getPoint_code2().startsWith("DKT")){
//叠盘任务需要二次分配 //叠盘任务需要二次分配
SchBasePoint nextSchBasePoint= pointService.getOne(new LambdaQueryWrapper<SchBasePoint>() SchBasePoint nextSchBasePoint= pointService.getOne(new LambdaQueryWrapper<SchBasePoint>()
@ -319,6 +321,7 @@ public class POINTTask extends AbstractTask {
int qty=nextSchBasePoint.getVehicle_qty()+1; int qty=nextSchBasePoint.getVehicle_qty()+1;
if(qty <= max_qty){ if(qty <= max_qty){
schBaseTask.setPoint_code2(schBaseTask.getPoint_code2().substring(0,schBaseTask.getPoint_code2().length()-1)+qty); schBaseTask.setPoint_code2(schBaseTask.getPoint_code2().substring(0,schBaseTask.getPoint_code2().length()-1)+qty);
log.info("feedbackTaskState方法,变更后schBaseTask:"+schBaseTask.toString());
}else{ }else{
schBaseTask.setRemark("叠盘机空盘数量已达最大值:["+max_qty+"],暂时无法放置托盘!"); schBaseTask.setRemark("叠盘机空盘数量已达最大值:["+max_qty+"],暂时无法放置托盘!");
taskService.update(schBaseTask); taskService.update(schBaseTask);

Loading…
Cancel
Save