| | |
|---|
| | | } |
|---|
| | | 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.getRcsLocSts(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()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
