| | |
|---|
| | | package com.zy.asrs.task; |
|---|
| | | |
|---|
| | | import com.core.common.Cools; |
|---|
| | | import com.zy.asrs.entity.CheckOrder; |
|---|
| | | import com.zy.asrs.entity.Order; |
|---|
| | | import com.zy.asrs.enums.OrderTypeEnum; |
|---|
| | | import com.zy.asrs.service.ApiLogService; |
|---|
| | | import com.zy.asrs.service.OrderService; |
|---|
| | | import com.zy.asrs.task.core.ReturnT; |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /**损溢单完结上报 */ |
|---|
| | | @Scheduled(cron = "0/30 * * * * ?") |
|---|
| | | @Async("orderThreadPool") |
|---|
| | | public void completeCheckOrderReport() { |
|---|
| | | if (!ErpReportOld){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | String erpReport = Parameter.get().getErpReport(); |
|---|
| | | if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) { |
|---|
| | | List<CheckOrder> orders = orderService.selectCompleteCheck(); |
|---|
| | | for (CheckOrder order : orders) { |
|---|
| | | try { |
|---|
| | | ReturnT<String> result = orderSyncHandler.startCheckOrderReport(order); |
|---|
| | | if (!result.isSuccess()) { |
|---|
| | | log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error(e.getMessage()); |
|---|
| | | log.error("单据[orderNo={}]上报erp失败", order.getOrderNo()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | try { |
|---|
| | | Thread.sleep(300); |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | // TODO Auto-generated catch block |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
