解决erp连接不关闭查询异常问题

王佳豪

2021-06-16 0ac4ebea411ca9852fd5b382cf6b9fd65a302d95

 src/main/java/com/zy/common/service/erp/task/ErpScheduler.java

@@ -7,13 +7,13 @@
import com.zy.asrs.entity.MatCode;
import com.zy.asrs.entity.WaitPakin;
import com.zy.asrs.service.MatCodeService;
import com.zy.asrs.service.OutStockMainService;
import com.zy.asrs.service.OutStockService;
import com.zy.asrs.service.WaitPakinService;
import com.zy.asrs.utils.VersionUtils;
import com.zy.common.service.erp.ErpService;
import com.zy.common.service.erp.dto.InStockDto;
import com.zy.common.service.erp.entity.CPICMO;
import com.zy.common.service.erp.entity.InStockBillEntry;
import com.zy.common.service.erp.entity.M_item;
import com.zy.common.service.erp.entity.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
@@ -30,7 +30,7 @@
 * Created by vincent on 2020/11/27
 */
@Slf4j
@Component
//@Component
public class ErpScheduler {

    @Autowired
@@ -39,6 +39,10 @@
    private MatCodeService matCodeService;
    @Autowired
    private WaitPakinService waitPakinService;
    @Autowired
    private OutStockMainService outStockMainService;
    @Autowired
    private OutStockService outStockService;

    private Map<Integer, M_item> itemMap = new HashMap<>();

@@ -187,6 +191,39 @@
        }
    }

    /**
     * 成品出库-发货通知单表头
     */
    @Scheduled(cron = "0/15 * * * * ? ")
    public void syncOutStock(){
        List<OutStockBill> result = erpService.syncOutStock();
        for (Integer i = 0; i < result.size(); i++) {
            OutStockBill main = outStockMainService.selectOne(new EntityWrapper<OutStockBill>().eq("FBrNo", result.get(i).getFBrNo()).and().eq("FInterID", result.get(i).getFInterID()));
            if (null == main) {
                if (!outStockMainService.insert(result.get(i))) {
                    log.info("出库通知主表OutStockBill同步失败");
                };
            } else {

            }
        }
    }

    /**
     * 成品出库-发货通知单表体
     */
    @Scheduled(cron = "0/15 * * * * ? ")
    public void syncOutStockDetail(){
        List<OutStockBillEntry> result = erpService.syncOutStockDetail();
        for (Integer i = 0; i < result.size(); i++) {
            OutStockBillEntry main = outStockService.selectOne(new EntityWrapper<OutStockBillEntry>().eq("FInterID", result.get(i).getFInterID()).and().eq("FEntryID", result.get(i).getFEntryID()));
            if (null == main) {
                if (!outStockService.insert(result.get(i))) {
                    log.info("出库通知明细表OutStockBillEntry同步失败");
                };
            }
        }
    }

    /**
     * 原材料出库