rev:更新
This commit is contained in:
@@ -240,10 +240,7 @@ public class SchBasePointServiceImpl extends ServiceImpl<SchBasePointMapper, Sch
|
||||
jsonParam.put("task_type", IOSConstant.ONE);
|
||||
jsonParam.put("task_code", taskDao.getTask_code());
|
||||
jsonParam.put("point_code", taskDao.getPoint_code2());
|
||||
AcsResponse acsResponse = wmsToAcsService.confirmAgv(jsonParam);
|
||||
if (acsResponse.getStatus() != 200) {
|
||||
throw new BadRequestException(acsResponse.getMessage());
|
||||
}
|
||||
wmsToAcsService.confirmAgv(jsonParam);
|
||||
}
|
||||
|
||||
@Override
|
||||
@@ -268,10 +265,7 @@ public class SchBasePointServiceImpl extends ServiceImpl<SchBasePointMapper, Sch
|
||||
jsonParam.put("task_type", IOSConstant.TWO);
|
||||
jsonParam.put("task_code", taskDao.getTask_code());
|
||||
jsonParam.put("point_code", taskDao.getPoint_code1());
|
||||
AcsResponse acsResponse = wmsToAcsService.confirmAgv(jsonParam);
|
||||
if (acsResponse.getStatus() != 200) {
|
||||
throw new BadRequestException(acsResponse.getMessage());
|
||||
}
|
||||
wmsToAcsService.confirmAgv(jsonParam);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -131,6 +131,7 @@ public class KwzdInTask extends AbstractTask {
|
||||
}
|
||||
// 根据传来的类型去对任务进行操作
|
||||
if (status.equals(TaskStatus.EXECUTING)) {
|
||||
this.executing(taskObj);
|
||||
taskObj.setTask_status(TaskStatus.EXECUTING.getCode());
|
||||
taskObj.setRemark("执行中");
|
||||
taskService.updateById(taskObj);
|
||||
@@ -238,4 +239,13 @@ public class KwzdInTask extends AbstractTask {
|
||||
public JSONObject resultWeigh(SchBaseTask taskObj) {
|
||||
return null;
|
||||
}
|
||||
|
||||
private void executing(SchBaseTask taskObj) {
|
||||
// 更新起点
|
||||
iSchBasePointService.update(
|
||||
new UpdateWrapper<SchBasePoint>().lambda()
|
||||
.eq(SchBasePoint::getPoint_code, taskObj.getPoint_code1())
|
||||
.set(SchBasePoint::getIng_task_code, taskObj.getTask_id())
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user