rev:任务校验及下发失败备注

This commit is contained in:
2024-07-22 17:00:25 +08:00
parent 2cc9059f2c
commit 92a19721ef
3 changed files with 24 additions and 1 deletions

View File

@@ -445,6 +445,9 @@ public class PdaServiceImpl implements PdaService {
Assert.notBlank(point_code, "出库点位不能为空!");
SchBasePoint point = pointService.getById(requestParam.getPoint_code());
Assert.notNull(point, point_code + "对应的点位信息不存在!");
if (point.getPoint_status().equals(PointStatusEnum.EMPTY_POINT.getCode())) {
throw new BadRequestException("回库请求失败, " + point_code + "点位为空位。");
}
if (!RegionEnum.JLHC.getRegion_code().equals(point.getRegion_code())) {
throw new BadRequestException("回库请求失败,出库点位所属区域不是" + RegionEnum.JLHC.getRegion_name());
}

View File

@@ -145,6 +145,26 @@ public abstract class AbstractTask {
}
}
taskService.updateBatchById(taskList);
} else {
JSONArray errArr = resultForAcs.getErrArr();
if (errArr.size() > 0) {
for (int i = 0; i < errArr.size(); i++) {
JSONObject jsonObject = errArr.getJSONObject(i);
String task_code = jsonObject.getString("task_code");
String message = jsonObject.getString("message");
SchBaseTask task = taskService.getByCode(task_code);
task.setRemark("下发失败," + message);
task.setUpdate_time(DateUtil.now());
taskService.updateById(task);
}
} else {
for (int i = 0; i < taskList.size(); i++) {
SchBaseTask schBaseTask = taskList.get(i);
schBaseTask.setRemark("下发失败" + resultForAcs.getMessage());
schBaseTask.setUpdate_time(DateUtil.now());
taskService.updateById(schBaseTask);
}
}
}
return resultForAcs;
}