| | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|---|
| | | import com.zy.asrs.framework.common.R;
|
|---|
| | | import com.zy.asrs.framework.exception.CoolException;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.entity.domain.EssTaskStatus;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.entity.enums.EssTaskStatus;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.entity.request.*;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.services.WcsApiService;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.Task;
|
|---|
| | |
|---|
| | | import org.springframework.stereotype.Service;
|
|---|
| | | import org.springframework.transaction.annotation.Transactional;
|
|---|
| | |
|
|---|
| | | import java.util.Date;
|
|---|
| | | import java.util.List;
|
|---|
| | |
|
|---|
| | | @Slf4j
|
|---|
| | |
|---|
| | | .set(Task::getOriginLoc, arrivedParam.getSlotCode())
|
|---|
| | | .eq(Task::getBarcode, arrivedParam.getContainerCode()));
|
|---|
| | | } else {
|
|---|
| | | //容器到达时更新任务状态为：入库完成，定时任务根据状态码更新库存
|
|---|
| | | //当状态为入库完成时，更新库存信息
|
|---|
| | | // boolean update = taskService.update(new LambdaUpdateWrapper<Task>()
|
|---|
| | | // .set(Task::getTaskSts, TaskStsType.COMPLETE_OUT.id)
|
|---|
| | | // .set(Task::getOriginLoc, arrivedParam.getSlotCode())
|
|---|
| | | // .eq(Task::getBarcode, arrivedParam.getContainerCode()));
|
|---|
| | | //fixme 容器到达状态更改为播种中...
|
|---|
| | | boolean update = taskService.update(new LambdaUpdateWrapper<Task>()
|
|---|
| | | .set(Task::getTaskSts, TaskStsType.WCS_EXECUTE_OUT_ARRIVED.id)
|
|---|
| | | .set(Task::getTaskSts, TaskStsType.WAVE_SEED.id)
|
|---|
| | | .set(Task::getOriginLoc, arrivedParam.getSlotCode())
|
|---|
| | | .eq(Task::getBarcode, arrivedParam.getContainerCode()));
|
|---|
| | |
|
|---|
| | |
|---|
| | | }
|
|---|
| | | } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //上报完成状态
|
|---|
| | | if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.id || task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.id) {
|
|---|
| | | //出库任务完成，修改状态为播种中，定时任务生成播种波次
|
|---|
| | | taskStsType = TaskStsType.WAVE_SEED;
|
|---|
| | | //出库任务完成，修改状态为容器到达，定时任务生成播种波次
|
|---|
| | | taskStsType = TaskStsType.WCS_EXECUTE_OUT_TASK_DONE;
|
|---|
| | | } else {
|
|---|
| | | String errMsg = "任务编号：" + task.getTaskNo() + "状态为不匹配，" + "不能执行：" + TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.desc + "任务";
|
|---|
| | | log.error(errMsg);
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 容器流动通知
|
|---|
| | | * @param code
|
|---|
| | | * @return
|
|---|
| | | */
|
|---|
| | | @Override
|
|---|
| | | public R containerConveryor(String code) {
|
|---|
| | | List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getBarcode, code));
|
|---|
| | | if (tasks.isEmpty()) {
|
|---|
| | | return R.error("容器码任务不存在！！");
|
|---|
| | | } else if (tasks.size() > 1){
|
|---|
| | | return R.error("容器码任务错误！！");
|
|---|
| | | }
|
|---|
| | | tasks.forEach(task -> {
|
|---|
| | | // try {
|
|---|
| | | // ConveyorStarParam conveyorStarParam = new ConveyorStarParam();
|
|---|
| | | // conveyorStarParam.setSlotCode(task.getOriginLoc())
|
|---|
| | | // .setContainerCode(task.getBarcode());
|
|---|
| | | // if (task.getTaskType() == 101) { //任务类型为101全盘出库，直接取下容器，传200
|
|---|
| | | // conveyorStarParam.setDirection("200");
|
|---|
| | | // } else if (task.getTaskType() == 103) { //如果为任务类型为103，需走回库操作，传100
|
|---|
| | | // conveyorStarParam.setDirection("100");
|
|---|
| | | // }
|
|---|
| | | // //调用三方接口，将任务推送至ESS平台
|
|---|
| | | // MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
|
|---|
| | | // // 设置请求参数
|
|---|
| | | // params.add("params", JSONObject.toJSONString(conveyorStarParam));
|
|---|
| | | // log.info("请求地址：{}，请求参数：{}", Constant.CONVEYOR_START, JSONObject.toJSONString(conveyorStarParam));
|
|---|
| | | // HttpHeaders headers = new HttpHeaders();
|
|---|
| | | // headers.add("Content-Type", "application/json");
|
|---|
| | | // HttpEntity httpEntity = new HttpEntity<>(params, headers);
|
|---|
| | | // // 请求
|
|---|
| | | // ResponseEntity<String> exchange = restTemplate.exchange(Constant.CONVEYOR_START, HttpMethod.POST, httpEntity, String.class);
|
|---|
| | | // log.info("下发流动通知 返回结果：{}", exchange);
|
|---|
| | | // if (exchange.getBody() == null) {
|
|---|
| | | // throw new CoolException("下发流动通知失败！！");
|
|---|
| | | // } else {
|
|---|
| | | // CommonReponse commonReponse = JSON.toJavaObject(JSON.parseObject(exchange.getBody()), CommonReponse.class);
|
|---|
| | | // if (commonReponse.getCode() == 0) {
|
|---|
| | | //流动通知下发完成后，修改任务状态为输送线流动中。。
|
|---|
| | | //TODO 判断任务是否为103拣料出库，103拣料流动后修改为4（RCS容器流动任务已下发）
|
|---|
| | | if (task.getTaskType() == 103) {
|
|---|
| | | workService.pickTask(task.getId());
|
|---|
| | | // taskService.update(new LambdaUpdateWrapper<Task>().eq(Task::getId, task.getId()).set(Task::getTaskSts, TaskStsType.WCS_CONVEYOR_START))
|
|---|
| | | } else {
|
|---|
| | | taskService.update(new LambdaUpdateWrapper<Task>()
|
|---|
| | | .eq(Task::getId, task.getId())
|
|---|
| | | .set(Task::getTaskSts, TaskStsType.COMPLETE_OUT.id));
|
|---|
| | | }
|
|---|
| | | // log.info(task.getTaskNo() + "下发流动通知" + commonReponse.getMsg());
|
|---|
| | | // } else {
|
|---|
| | | // throw new CoolException("下发流动通知失败！！");
|
|---|
| | | // }
|
|---|
| | | // }
|
|---|
| | | // } catch (Exception ex) {
|
|---|
| | | // log.error(ex.getMessage());
|
|---|
| | | // } finally {
|
|---|
| | | // //如果异常修改禁用状态
|
|---|
| | | // taskService.update(new LambdaUpdateWrapper<Task>().set(Task::getStatus, 0)
|
|---|
| | | // .set(Task::getUpdateTime, new Date())
|
|---|
| | | // .eq(Task::getId, task.getId()));
|
|---|
| | | // }
|
|---|
| | | });
|
|---|
| | | return R.ok();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
