| | |
| | | @Value("${erp.switch.SaveOrderSwitch}") |
| | | private boolean SaveOrderSwitch; |
| | | |
| | | /** |
| | | * 2.保存接口 |
| | | */ |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | @Async("orderThreadPool") |
| | | public void completeAndReport(){ |
| | | if(!SaveOrderSwitch){ |
| | | public synchronized void completeAndReport() { |
| | | if (!SaveOrderSwitch) { |
| | | return; |
| | | } |
| | | List<Order> orders = orderService.selectCompletemEmo1(); |
| | | List<Order> orders = orderService.selectCompletemEmo2(); |
| | | for (Order order : orders) { |
| | | try{ |
| | | if(order.getSettle()==4){ |
| | | order.setMemo("2"); |
| | | order.setUpdateTime(new Date()); |
| | | orderService.update(order,new EntityWrapper<Order>().eq("order_no",order.getOrderNo())); |
| | | }else{ |
| | | ReturnT<String> result = saveOrderSyncHandler.start(order); |
| | | if (!result.isSuccess()) { |
| | | log.error("单据[orderNo={}]保存至erp失败", order.getOrderNo()); |
| | | } |
| | | try { |
| | | |
| | | ReturnT<String> result = saveOrderSyncHandler.start(order); |
| | | if (!result.isSuccess()) { |
| | | log.error("单据[orderNo={}]保存至erp失败", order.getOrderNo()); |
| | | } |
| | | }catch (Exception e){ |
| | | |
| | | } catch (Exception e) { |
| | | Order order1 = orderService.selectById(order.getId()); |
| | | order1.setUpdateTime(new Date()); |
| | | orderService.updateById(order1); |