| | |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void reportOrders(List<WkOrder> orders) { |
| | | orders.forEach(order -> { |
| | | for (WkOrder order : orders) { |
| | | if (order.getReportOnce() > 4) { |
| | | continue; |
| | | } |
| | | ReportParams params = new ReportParams(); |
| | | List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, order.getId())); |
| | | if (orderItems.isEmpty()) { |
| | |
| | | |
| | | R reported = reportMsgService.uploadReportOrders(params); |
| | | if (reported.get("code").equals(200)) { |
| | | order.setNtyStatus(1); |
| | | if (!asnOrderService.updateById(order)) { |
| | | throw new CoolException("上报状态修改失败!!"); |
| | | } |
| | | order.setNtyStatus(1); |
| | | if (!asnOrderService.updateById(order)) { |
| | | throw new CoolException("上报状态修改失败!!"); |
| | | } |
| | | } |
| | | try { |
| | | //休眠3秒 |
| | |
| | | } catch (InterruptedException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | |
| | | }); |
| | | } |
| | | } |
| | | |
| | | |