| | |
| | | * @description 已完成任务加入历史档 |
| | | * @time 2025/4/3 12:54 |
| | | */ |
| | | @Scheduled(cron = "0 0/01 * * * ? ") |
| | | @Scheduled(cron = "0/15 * * * * ? ") |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void taskLogUpdate() { |
| | | LambdaQueryWrapper<Task> queryWrapper = new LambdaQueryWrapper<Task>(); |
| | |
| | | } |
| | | List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId())); |
| | | //入库单据明细上报 |
| | | if (task.getTaskType() <= TaskType.TASK_TYPE_CHECK_IN.type) { |
| | | |
| | | if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type)) { |
| | | for (TaskItem taskItem : taskItems) { |
| | | if (Objects.isNull(taskItem.getOrderId())) { |
| | | continue; |
| | |
| | | } |
| | | |
| | | LocSiteParams locSiteParams = new LocSiteParams(); |
| | | locSiteParams.setStatus(LocStsType.getLocSts(LocStsType.LOC_STS_TYPE_O.type)) |
| | | locSiteParams.setStatus(LocStsType.getRcsLocSts(LocStsType.LOC_STS_TYPE_O.type)) |
| | | .setType("site") |
| | | .setCode(station.getStationName()); |
| | | |
| | | /**WMS基础配置链接*/ |
| | | String rcsUrl = rcsApi.getHost() + ":" + rcsApi.getPort() + RcsConstant.REPORT_SITE_STATUS; |
| | | log.info("上报已完成订单:{}, 请求参数: {}", rcsUrl, JSONObject.toJSONString(locSiteParams)); |
| | |
| | | HttpEntity httpEntity = new HttpEntity(locSiteParams, headers); |
| | | ResponseEntity<String> exchange = restTemplate.exchange(rcsUrl, HttpMethod.POST, httpEntity, String.class); |
| | | log.info("上报已完成订单,返回结果: {}", exchange); |
| | | |
| | | if (Objects.isNull(exchange.getBody())) { |
| | | throw new CoolException("修改失败!!"); |
| | | } else { |
| | |
| | | throw new CoolException(e.getMessage()); |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | } |