| | |
| | | import javax.annotation.Resource; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.concurrent.locks.ReentrantLock; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | |
| | | @Resource |
| | | private ThreadPoolTaskExecutor orderThreadPool; |
| | | |
| | | private final ReentrantLock lock = new ReentrantLock(); |
| | | |
| | | // @Scheduled(cron = "0/5 * * * * ? ") |
| | | // 10分钟执行一次 |
| | | @Scheduled(cron = "0 0/10 * * * ?") |
| | | public void completeAndReport() { |
| | | if (!lock.tryLock()) { |
| | | log.info("上一次任务未执行完,跳过本次"); |
| | | return; |
| | | } |
| | | try { |
| | | String erpReport = Parameter.get().getErpReport(); |
| | | if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) { |
| | | List<Order> orders = orderService.selectComplete(); |
| | |
| | | orderSyncHandler.startNew(map); |
| | | }); |
| | | } |
| | | } |
| | | } finally { |
| | | lock.unlock(); |
| | | } |
| | | } |
| | | |