| | |
|---|
| | | log.info("通知ESS输送线流动请求地址：{}，请求参数：{}", "http://192.168.2.200:9046/conveyor/moveContainer", JSONObject.toJSONString(conveyorStarParam));
|
|---|
| | | HttpHeaders headers = new HttpHeaders();
|
|---|
| | | headers.add("Content-Type", "application/json");
|
|---|
| | | headers.add("api-version", "v2.0");
|
|---|
| | | HttpEntity httpEntity = new HttpEntity<>(conveyorStarParam, headers);
|
|---|
| | | // 调用三方接口，将任务推送至ESS平台
|
|---|
| | | ResponseEntity<String> exchange = restTemplate.exchange("http://192.168.2.200:9046/conveyor/moveContainer", HttpMethod.POST, httpEntity, String.class);
|
|---|
| | |
|---|
| | | /**
|
|---|
| | | * 生成自动盘点任务
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0/50 * * * * ?")
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | // @Scheduled(cron = "0/50 * * * * ?")
|
|---|
| | | // @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void genCheckTask() {
|
|---|
| | | Loc locs = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocStsId, LocStsType.F.val()).orderByAsc(Loc::getLocNo).last("limit 1"));
|
|---|
| | | if (Objects.isNull(locs)) {
|
|---|
| | |
|---|
| | | log.info("下发入库任务请求地址：{}，请求参数：{}", "http://192.168.2.200:9046/task/create", JSONObject.toJSONString(tasksParam));
|
|---|
| | | HttpHeaders headers = new HttpHeaders();
|
|---|
| | | headers.add("Content-Type", "application/json");
|
|---|
| | | headers.add("api-version", "v2.0");
|
|---|
| | | HttpEntity httpEntity = new HttpEntity<>(tasksParam, headers);
|
|---|
| | | // 请求
|
|---|
| | | ResponseEntity<String> exchange = restTemplate.exchange("http://192.168.2.200:9046/task/create", HttpMethod.POST, httpEntity, String.class);
|
|---|
