| | |
| | | import com.zy.api.controller.params.AgvCarriesParam; |
| | | import com.zy.api.controller.params.AgvRequestParam; |
| | | import com.zy.api.entity.CallAgvParams; |
| | | import com.zy.api.entity.dto.HKR; |
| | | import com.zy.api.enums.OrderType; |
| | | import com.zy.api.service.AgvScheduleService; |
| | | import com.zy.asrs.entity.LocCache; |
| | |
| | | task.setWrkSts(TaskStatusType.AGV_TASK_ISSUED_OUT.type); |
| | | } |
| | | |
| | | if (task.getIsNewIn().equals("M1")) { |
| | | params.setTaskType("M1"); |
| | | } |
| | | |
| | | HIKResultDTO hikResultDTO = sendAgvTask(params, HIKApiConstant.TASK_SUBMIT); |
| | | |
| | | if (hikResultDTO.isSuccess()) { |
| | |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R callback(AgvCallBackParam params) { |
| | | public HKR callback(AgvCallBackParam params) { |
| | | if (Objects.isNull(params)) { |
| | | return R.error("参数不能为空!!"); |
| | | return HKR.error("参数不能为空!!"); |
| | | } |
| | | if (Objects.isNull(params.getRobotTaskCode())) { |
| | | return R.error("任务号不能为空!!"); |
| | | return HKR.error("任务号不能为空!!"); |
| | | } |
| | | Task task = taskService.selectOne(new EntityWrapper<Task>().eq("wrk_no", params.getRobotTaskCode())); |
| | | if (Objects.isNull(task)) { |
| | | return R.error("任务信息不存在!!"); |
| | | return HKR.error("任务信息不存在!!"); |
| | | } |
| | | |
| | | if (Arrays.asList(TaskIOType.ALL_IN.type, TaskIOType.PICK_IN.type, TaskIOType.MERGE_IN.type) |
| | |
| | | if (!taskService.updateById(task)) { |
| | | throw new CoolException("状态修改失败!!"); |
| | | } |
| | | return R.ok("执行完成 !!"); |
| | | return HKR.ok("执行完成 !!"); |
| | | } |
| | | |
| | | public HIKResultDTO sendAgvTask(CallAgvParams param, String path) { |