| | |
| | | package com.zy.asrs.task.kingdee; |
| | | |
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
| | | import com.zy.asrs.entity.Order; |
| | | import com.zy.asrs.service.OrderService; |
| | | import com.zy.asrs.task.core.ReturnT; |
| | |
| | | @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.selectComplete(); |
| | | List<Order> orders = orderService.selectCompletemEmo2(); |
| | | for (Order order : orders) { |
| | | try{ |
| | | try { |
| | | |
| | | ReturnT<String> result = saveOrderSyncHandler.start(order); |
| | | if (!result.isSuccess()) { |
| | | log.error("单据[orderNo={}]提交至erp失败", order.getOrderNo()); |
| | | 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); |