| | |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | /** |
| | |
| | | @Value("${erp.switch.ReviewOrderSwitch}") |
| | | private boolean ReviewOrderSwitch; |
| | | |
| | | /** |
| | | * 4.审核接口 |
| | | */ |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | @Async("orderThreadPool") |
| | | public void completeAndReport(){ |
| | | public synchronized void completeAndReport(){ |
| | | if(!ReviewOrderSwitch){ |
| | | return; |
| | | } |
| | | List<Order> orders = orderService.selectComplete(); |
| | | List<Order> orders = orderService.selectCompletemEmo4(); |
| | | for (Order order : orders) { |
| | | ReturnT<String> result = reviewOrderSyncHandler.start(order); |
| | | if (!result.isSuccess()) { |
| | | log.error("单据[orderNo={}]向erp审核失败", order.getOrderNo()); |
| | | try{ |
| | | ReturnT<String> result = reviewOrderSyncHandler.start(order); |
| | | if (!result.isSuccess()) { |
| | | log.error("单据[orderNo={}]向erp审核失败", order.getOrderNo()); |
| | | } |
| | | }catch (Exception e){ |
| | | Order order1 = orderService.selectById(order.getId()); |
| | | order1.setUpdateTime(new Date()); |
| | | orderService.updateById(order1); |
| | | } |
| | | } |
| | | } |