| | |
|---|
| | | if (Objects.isNull(params) || params.isEmpty()) { |
|---|
| | | throw new CoolException("参数不能为空！！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | Set<String> collect = params.stream().map(PageRequestParams::getPro_id).collect(Collectors.toSet()); |
|---|
| | | |
|---|
| | | Set<String> komccodes = params.stream().map(PageRequestParams::getPro_komcode).collect(Collectors.toSet()); |
|---|
| | | |
|---|
| | | EntityWrapper<LocDetl> wrapper = new EntityWrapper<>(); |
|---|
| | | wrapper.in(collect.isEmpty(), "pro_id", collect); |
|---|
| | | wrapper.in(komccodes.isEmpty(), "komccode", komccodes); |
|---|
| | | |
|---|
| | | List<LocDetl> detls = locDetlService.selectList(wrapper); |
|---|
| | | List<LocDetl> detls = new ArrayList<>(); |
|---|
| | | params.forEach(param -> { |
|---|
| | | List<LocDetl> selectList = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("supp_code", param.getPro_id()).eq("matnr", param.getPro_komcode())); |
|---|
| | | if (selectList != null && !selectList.isEmpty()) { |
|---|
| | | detls.addAll(selectList); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | |
|---|
| | | if (detls == null || detls.isEmpty()) { |
|---|
| | | return XSR.ok(); |
|---|
| | |
|---|
| | | try { |
|---|
| | | response = new HttpHandler.Builder() |
|---|
| | | .setUri(url + ":" + port) |
|---|
| | | .setPath(prefix + "/getOutDetailsResult") |
|---|
| | | .setPath(prefix + "/getOutDispatchResult") |
|---|
| | | .setJson(JSONObject.toJSONString(orderParams)) |
|---|
| | | .build() |
|---|
| | | .doPost(); |
|---|
| | | if (Objects.isNull(response) || response.trim().isEmpty()) { |
|---|
| | | if (!Objects.isNull(order)) { |
|---|
| | | int reportOnce = order.getReportOnce(); |
|---|
| | | reportOnce++; |
|---|
| | | order.setReportOnce(reportOnce); |
|---|
| | | orderService.updateById(order); |
|---|
| | | } |
|---|
| | | return XSR.error("外网接口无响应！！"); |
|---|
| | | } |
|---|
| | | JSONObject jsonObject = JSONObject.parseObject(response); |
|---|
