| | |
| | | String path = resolveTaskPath(group.get(0)); |
| | | Map<String, Object> payload = new HashMap<>(); |
| | | // WCS 批量下发报文统一使用 {"tasks":[...]} 结构。 |
| | | payload.put("tasks", buildTaskPayloads(group)); |
| | | payload.put("taskList", buildTaskPayloads(group)); |
| | | String response = null; |
| | | try { |
| | | log.info("批量下发搬运任务给wcs={}", JSON.toJSONString(payload)); |
| | | response = new HttpHandler.Builder() |
| | | .setUri(wcs_address) |
| | | .setPath(path) |
| | | .setHttps(wcs_address != null && wcs_address.startsWith("https://")) |
| | | // .setHttps(wcs_address != null && wcs_address.startsWith("https://")) |
| | | .setTimeout(10, TimeUnit.SECONDS) |
| | | .setJson(JSON.toJSONString(payload)) |
| | | .build() |
| | |
| | | if (!Boolean.parseBoolean(String.valueOf(switchValue))) { |
| | | return R.ok("WCS开关关闭"); |
| | | } |
| | | HashMap<String,Object> map = new HashMap<>(); |
| | | map.put("taskList", params); |
| | | String response; |
| | | try { |
| | | log.info("调用WCS取消出库任务, request={}", JSON.toJSONString(params)); |
| | | response = new HttpHandler.Builder() |
| | | .setUri(wcs_address) |
| | | .setPath(stopOutTask) |
| | | .setHttps(wcs_address != null && wcs_address.startsWith("https://")) |
| | | // .setHttps(wcs_address != null && wcs_address.startsWith("https://")) |
| | | .setTimeout(10, TimeUnit.SECONDS) |
| | | .setJson(JSON.toJSONString(params)) |
| | | .setJson(JSON.toJSONString(map)) |
| | | .build() |
| | | .doPost(); |
| | | JSONObject jsonObject = JSON.parseObject(response == null ? "{}" : response); |