This commit is contained in:
陆一凡 2025-03-11 17:22:55 +08:00
parent b91fc80b85
commit bf1be14fbb

View File

@ -185,24 +185,29 @@ public class AppTaskController extends BaseController
@Anonymous
public AjaxResult receiveTaskResult(@RequestBody TaskResultFeedRequest feedBackRequest)
{
logger.info("反馈任务状态:{}", JSON.toJSONString(feedBackRequest));
// 判断请求参数是否齐全
if (feedBackRequest == null
|| StringUtils.isEmpty(feedBackRequest.getTaskId())
|| feedBackRequest.getTaskStatus() == null
|| StringUtils.isEmpty(feedBackRequest.getVehicleNo())) {
logger.info("缺少请求数据。");
return error("缺少请求数据。");
}
// 判断任务状态是否正确
if (!wcsTaskStatusList.contains(feedBackRequest.getTaskStatus())) {
logger.info("任务状态码反馈不正确。");
return error("任务状态码反馈不正确。");
}
// 查询任务号
AppWcsTask thisFbWcsTask = appWcsTaskService.selectAppWcsTaskByWcsTaskId(feedBackRequest.getTaskId());
if (thisFbWcsTask == null) {
logger.info("反馈的任务号不存在。");
return error("反馈的任务号不存在。");
}
// 判断反馈的任务号与数据库中是否一致
if (Objects.equals(thisFbWcsTask.getWcsTaskStatus(), feedBackRequest.getTaskStatus())) {
logger.info("请勿重复反馈相同任务状态。");
return error("请勿重复反馈相同任务状态。");
}
AppTask wmsTaskQuery = new AppTask();
@ -233,6 +238,7 @@ public class AppTaskController extends BaseController
// appTaskService.batchUpdateAppTask(thisWmsTaskList);
updateAppTask(thisWmsTaskList);
}
logger.info("反馈任务完成成功。");
return success("反馈任务完成成功。");
}
if (998 == feedBackRequest.getTaskStatus()) {
@ -248,6 +254,7 @@ public class AppTaskController extends BaseController
// appTaskService.batchUpdateAppTask(thisWmsTaskList);
updateAppTask(thisWmsTaskList);
}
logger.info("反馈任务取消成功。");
return success("反馈任务取消成功。");
}
if (999 == feedBackRequest.getTaskStatus()) {
@ -262,6 +269,7 @@ public class AppTaskController extends BaseController
// appTaskService.batchUpdateAppTask(thisWmsTaskList);
updateAppTask(thisWmsTaskList);
}
logger.info("反馈任务异常成功。");
return success("反馈任务异常成功。");
}
@ -280,6 +288,7 @@ public class AppTaskController extends BaseController
@Anonymous
public AjaxResult sendLocation(@RequestBody WcsLocationRequest wcsStackerTask)
{
logger.info("接受wcs请求的入库请求,请求参数,{}",JSON.toJSONString(wcsStackerTask));
if(ObjectUtil.isEmpty(wcsStackerTask.getPoint())||
ObjectUtil.isEmpty(wcsStackerTask.getVehicleNo())){
return error("缺少请求数据");