package com.zy.asrs.task.kingdee;
|
|
import com.core.common.Cools;
|
import com.zy.asrs.entity.Order;
|
import com.zy.asrs.entity.OrderPakin;
|
import com.zy.asrs.service.OrderDetlPakinService;
|
import com.zy.asrs.service.OrderPakinService;
|
import com.zy.asrs.service.OrderService;
|
import com.zy.asrs.task.core.ReturnT;
|
import com.zy.asrs.task.kingdee.handler.AutoTransferHandler;
|
import com.zy.asrs.task.kingdee.handler.AutoTransferOutHandler;
|
import com.zy.asrs.task.kingdee.handler.SaveOrderSyncHandler;
|
import com.zy.common.entity.Parameter;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
@Slf4j
|
@Component
|
public class AutoTransferScheduler {
|
|
@Autowired
|
private SaveOrderSyncHandler saveOrderSyncHandler;
|
@Autowired
|
private OrderService orderService;
|
@Autowired
|
private OrderPakinService orderPakinService;
|
@Autowired
|
private OrderDetlPakinService orderDetlPakinService;
|
@Value("${erp.switch.ReviewOrderSwitch}")
|
private boolean ReviewOrderSwitch;
|
@Autowired
|
private AutoTransferHandler autoTransferHandler;
|
@Autowired
|
private AutoTransferOutHandler autoTransferOutHandler;
|
@Scheduled(cron = "0/30 * * * * ? ")
|
@Async("orderThreadPool")
|
public void completeAndReport(){ //库内库存转换，出库对应物料及数量，更新库存明细
|
List<OrderPakin> orders = orderPakinService.selectComplete66();
|
if(orders.size() > 0){
|
for (OrderPakin order : orders) {
|
ReturnT<String> result = autoTransferHandler.start(order);//
|
if (!result.isSuccess()) {
|
log.error("单据[orderNo={}]转换失败", order.getOrderNo());
|
}
|
}
|
}
|
}
|
|
@Scheduled(cron = "0/30 * * * * ? ")
|
@Async("orderThreadPool")
|
public void completeAndReportHD(){ ///和得出库渝程上报
|
List<OrderPakin> orders = orderPakinService.selectComplete67();
|
if(orders.size() > 0){
|
for (OrderPakin order : orders) {
|
ReturnT<String> result = autoTransferOutHandler.start(order);//
|
if (!result.isSuccess()) {
|
log.error("单据[orderNo={}]转换出库上报失败", order.getOrderNo());
|
}
|
}
|
}
|
}
|
|
}
|
