| | |
| | | |
| | | } |
| | | |
| | | @Scheduled(cron = "0/9 * * * * ? ") |
| | | @Async("orderThreadPool") |
| | | //@Scheduled(cron = "0/9 * * * * ? ") |
| | | //@Async("orderThreadPool") |
| | | public void completeAndReport2() { |
| | | Config config = configMapper.selectConfigByCode("RETURN_REPORT"); |
| | | if (config == null || config.getStatus() == 0 || Cools.isEmpty(config.getValue())) { |
| | | return; |
| | | } |
| | | |
| | | List<Order> orders = orderService.selectComplete(); |
| | | List<Order> orders = orderService.selectComplete2(); |
| | | for (Order order : orders) { |
| | | try { |
| | | ReturnT<String> result = orderSyncHandler.start(order); |
| | |
| | | log.error("订单" + order + "处理失败,异常信息:" + e); |
| | | } |
| | | } |
| | | |
| | | orders = orderService.selectComplete3(); |
| | | for (Order order : orders) { |
| | | try { |
| | | ReturnT<String> result = orderSyncHandler.start(order); |
| | | if (!result.isSuccess()) { |
| | | log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); |
| | | log.error("订单" + order + "处理失败,异常信息:" + e); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |