| | |
| | | if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) { |
| | | List<Order> orders = orderService.selectComplete(); |
| | | for (Order order : orders) { |
| | | //如果是加工单则进行判断 |
| | | //如果是调拨单则进行判断 |
| | | if (order.getDocType() == 33) { |
| | | //查询库存中是否存在该订单的物料信息,存在则不处理该订单 |
| | | List<OrderDetl> orderDetlList = orderDetlService.selectByOrderId(order.getId()); |
| | |
| | | } |
| | | ReturnT<String> result = orderSyncHandler.start(order); |
| | | if (!result.isSuccess()) { |
| | | log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); |
| | | //log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | //@Scheduled(cron = "* 0/5 * * * ? ") |
| | | @Scheduled(cron = "0/5 * * * * ? ") |
| | | @Async("orderThreadPool") |
| | | public void reportOrder() { |
| | | @Scheduled(cron = "0/30 * * * * ? ") |
| | | //@Async("orderThreadPool") |
| | | public synchronized void reportOrder() { |
| | | List<Order> orderList = orderService.selectList(new EntityWrapper<Order>().in("settle", 2, 4)); |
| | | orderList.forEach(order -> { |
| | | orderSyncHandler.timelyStart(order); |