| | |
|---|
| | | import com.zy.asrs.wms.apis.wcs.entity.request.*;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.entity.response.CommonReponse;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.services.WcsApiService;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.Task;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.TaskDetl;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.WaveSeed;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.*;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.enums.CacheSiteStatusType;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.enums.OrderPickStatus;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.enums.TaskStsType;
|
|---|
| | | import com.zy.asrs.wms.asrs.service.*;
|
|---|
| | | import io.jsonwebtoken.lang.Collections;
|
|---|
| | |
|---|
| | | import org.springframework.util.MultiValueMap;
|
|---|
| | | import org.springframework.web.client.RestTemplate;
|
|---|
| | |
|
|---|
| | | import java.math.BigDecimal;
|
|---|
| | | import java.util.Date;
|
|---|
| | | import java.util.List;
|
|---|
| | | import java.util.Map;
|
|---|
| | | import java.util.Objects;
|
|---|
| | |
|---|
| | | private TaskService taskService;
|
|---|
| | | @Autowired
|
|---|
| | | private TaskDetlService taskDetlService;
|
|---|
| | |
|
|---|
| | | @Autowired
|
|---|
| | | private CacheSiteService cacheSiteService;
|
|---|
| | | @Autowired
|
|---|
| | | private OrderService orderService;
|
|---|
| | | @Autowired
|
|---|
| | | private OrderDetlService orderDetlService;
|
|---|
| | | @Autowired
|
|---|
| | | private WaveSeedService waveSeedService;
|
|---|
| | |
|
|---|
| | | @Autowired
|
|---|
| | | private RestTemplate restTemplate;
|
|---|
| | |
|
|---|
| | | @Autowired
|
|---|
| | | private PlatformService platformService;
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | |
|---|
| | | //DONE 根据ESS返回的容器编码修改任务档中的输送线起始位置节点，及任务档容器到达状态
|
|---|
| | | taskService.update(new LambdaUpdateWrapper<Task>()
|
|---|
| | | .set(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id)
|
|---|
| | | .set(Task::getOriginLoc, arrivedParam.getSlotCode())
|
|---|
| | | //输送线节点编码，不是源库位
|
|---|
| | | // .set(Task::getOriginLoc, arrivedParam.getSlotCode())
|
|---|
| | | .eq(Task::getBarcode, arrivedParam.getContainerCode()));
|
|---|
| | | } else {
|
|---|
| | | //容器到达时更新任务状态为：入库完成，定时任务根据状态码更新库存
|
|---|
| | |
|---|
| | | .set(Task::getTaskSts, TaskStsType.WAVE_SEED.id)
|
|---|
| | | .set(Task::getOriginLoc, arrivedParam.getSlotCode())
|
|---|
| | | .eq(Task::getBarcode, arrivedParam.getContainerCode()));
|
|---|
| | | if (!update) {
|
|---|
| | | throw new CoolException("容器到达任务更新失败！！");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | }
|
|---|
| | | } else { //出库任务
|
|---|
| | | if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //上报取箱状态
|
|---|
| | | //TODO 定时器开启后，要删除 || task.getTaskType() == TaskStsType.GENERATE_OUT.id
|
|---|
| | | if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT.id || task.getTaskSts() == TaskStsType.GENERATE_OUT.id) {
|
|---|
| | | if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT.id ) {
|
|---|
| | | taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD;
|
|---|
| | | } else {
|
|---|
| | | String errMsg = "任务编号：" + task.getTaskNo() + "状态为不匹配，" + "不能执行：" + TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD.desc + "任务";
|
|---|
| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | //更新出库状态及相关字段
|
|---|
| | | taskService.update(new LambdaUpdateWrapper<Task>()
|
|---|
| | | boolean update = taskService.update(new LambdaUpdateWrapper<Task>()
|
|---|
| | | .set(Task::getRobotCode, callbackParam.getRobotCode())
|
|---|
| | | .set(Task::getSysTaskCode, callbackParam.getSysTaskCode())
|
|---|
| | | .set(Task::getTaskSts, taskStsType.id)
|
|---|
| | |
|---|
| | | .set(Task::getTaskDesc, callbackParam.getMessage())
|
|---|
| | | .eq(Task::getBarcode, callbackParam.getContainerCode())
|
|---|
| | | .eq(Task::getTaskNo, callbackParam.getTaskCode()));
|
|---|
| | |
|
|---|
| | | if (!update) {
|
|---|
| | | throw new CoolException("任务更新失败！！");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public R rfidCallback(RfidSingalRequest request) {
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | return null;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public R getPlatforms() {
|
|---|
| | | return R.ok(platformService.list(new LambdaQueryWrapper<>()));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | |
|---|
| | | * @param request
|
|---|
| | | */
|
|---|
| | | @Override
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void slapLightLogic(Map<String, Object> request) {
|
|---|
| | | String taskNo = request.get("taskNo").toString();
|
|---|
| | | String orderNo = request.get("orderNo").toString();
|
|---|
| | |
|
|---|
| | | List<CacheSite> performs = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderNo, orderNo));
|
|---|
| | | if (Objects.isNull(performs.stream().findFirst().get().getPlatformId())) {
|
|---|
| | | throw new CoolException("请打印明细，并绑定目标集货区");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | //* 1. 判断当前容器是否还有物料未拣，未拣完闪灯，拣完通知容器流动，并灭灯
|
|---|
| | | SlapLightControlParam slapParam = new SlapLightControlParam();
|
|---|
| | | MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
|
|---|
| | | //默认流动
|
|---|
| | | boolean converyor = false;
|
|---|
| | | //判断是否还有物料未拣
|
|---|
| | |
|
|---|
| | | //判断当前任务是否还有物料未拣
|
|---|
| | | if (!checked(orderNo, taskNo)) {
|
|---|
| | | //调用三方接口,闪灯不做操作
|
|---|
| | |
|
|---|
| | | // 设置请求参数
|
|---|
| | | params.add("params", JSONObject.toJSONString(slapParam));
|
|---|
| | | log.info("请求地址：{}，请求参数：{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));
|
|---|
| | |
|
|---|
| | | } else {
|
|---|
| | | //调用三方接口,来灯通知容器流动， 传灭灯参数
|
|---|
| | | //调用三方接口,灭灯通知容器流动， 传灭灯参数
|
|---|
| | | //todo 判断当前订单是否完成，完成灭灯，未完成保持拣货状态亮灯
|
|---|
| | | Order one = orderService.getOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNo, orderNo));
|
|---|
| | |
|
|---|
| | | if (Objects.isNull(one)) {
|
|---|
| | | throw new CoolException("当前订单明细不存在！！");
|
|---|
| | | }
|
|---|
| | | // //获取播种已完成的订单明细
|
|---|
| | | // List<OrderDetl> detlList = orderDetls.stream().filter(detl -> {
|
|---|
| | | // return detl.getPickStatus() == OrderPickStatus.ORDER_PICK_STATUS_DONE.val;
|
|---|
| | | // }).collect(Collectors.toList());
|
|---|
| | |
|
|---|
| | | //判断数量是否与订单明细的需求量相同，相同则订单完成
|
|---|
| | | if (one.getPickStatus() == OrderPickStatus.ORDER_PICK_STATUS_DONE.val) {
|
|---|
| | | //播种完成，释放绑定站点
|
|---|
| | | List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderNo, orderNo));
|
|---|
| | | for (CacheSite cacheSite : cacheSites) {
|
|---|
| | | if (!cacheSite.getSiteStatus().equals(CacheSiteStatusType.O.id)) {
|
|---|
| | | cacheSite.setSiteStatus(CacheSiteStatusType.O.id);
|
|---|
| | | cacheSite.setOrderId(null);
|
|---|
| | | cacheSite.setBarcode(null);
|
|---|
| | | cacheSite.setOrderNo(null);
|
|---|
| | | cacheSite.setPlatformId(null);
|
|---|
| | | cacheSite.setPlatformNo(null);
|
|---|
| | | cacheSite.setUpdateTime(new Date());
|
|---|
| | | if (!cacheSiteService.updateById(cacheSite)) {
|
|---|
| | | throw new CoolException("播种站点更新失败");
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | converyor = true;
|
|---|
| | | params.add("params", JSONObject.toJSONString(slapParam));
|
|---|
| | | log.info("请求地址：{}，请求参数：{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | HttpHeaders headers = new HttpHeaders();
|
|---|
| | | headers.add("Content-Type", "application/json");
|
|---|
| | | HttpEntity httpEntity = new HttpEntity<>(params, headers);
|
|---|
| | | // 请求
|
|---|
| | | ResponseEntity<CommonReponse> exchange = restTemplate.exchange(SystemProperties.CONVEYOR_START, HttpMethod.POST, httpEntity, CommonReponse.class);
|
|---|
| | | log.info("下发流动通知 返回结果：{}", exchange);
|
|---|
| | | if (exchange.getBody() == null) {
|
|---|
| | | throw new CoolException("下发流动通知失败！！");
|
|---|
| | | } else {
|
|---|
| | | CommonReponse response = exchange.getBody();
|
|---|
| | | if (response.getCode() == 0) {
|
|---|
| | | if (!converyor) {
|
|---|
| | | //* 2. 容器流动判断，如果料箱没有物料 code传200， 有物料传100 执行回库任务,修改任务状态为 调用containerConveryor（taskNo）方法
|
|---|
| | | containerConveryor(request.get("taskNo").toString());
|
|---|
| | | }
|
|---|
| | | if (converyor) {
|
|---|
| | | Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getTaskNo, request.get("taskNo")));
|
|---|
| | | if (Objects.isNull(task)) {
|
|---|
| | | throw new CoolException("任务不存在！！");
|
|---|
| | | }
|
|---|
| | | containerConveryor(task.getBarcode());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // HttpHeaders headers = new HttpHeaders();
|
|---|
| | | // headers.add("Content-Type", "application/json");
|
|---|
| | | // HttpEntity httpEntity = new HttpEntity<>(params, headers);
|
|---|
| | | // // 请求
|
|---|
| | | // ResponseEntity<CommonReponse> exchange = restTemplate.exchange(SystemProperties.CONVEYOR_START, HttpMethod.POST, httpEntity, CommonReponse.class);
|
|---|
| | | // log.info("下发流动通知 返回结果：{}", exchange);
|
|---|
| | | // if (exchange.getBody() == null) {
|
|---|
| | | // throw new CoolException("下发流动通知失败！！");
|
|---|
| | | // } else {
|
|---|
| | | // CommonReponse response = exchange.getBody();
|
|---|
| | | // if (response.getCode() == 0) {
|
|---|
| | | // if (!converyor) {
|
|---|
| | | // //* 2. 容器流动判断，如果料箱没有物料 code传200， 有物料传100 执行回库任务,修改任务状态为 调用containerConveryor（taskNo）方法
|
|---|
| | | // containerConveryor(request.get("taskNo").toString());
|
|---|
| | | // }
|
|---|
| | | // }
|
|---|
| | | // }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
