啊鑫
2025-05-30 a5e75aabaef8ff2dffea466f750c17a486d50cfb
src/main/java/com/gs/xky/service/PurchaseService.java
@@ -10,6 +10,7 @@
import com.gs.xky.entity.PurchaseOrderCompare;
import com.gs.xky.entity.PurchaseOrderDetail;
import com.gs.xky.mapper.PurchaseOrderCompareMapper;
import com.gs.xky.mapper.PurchaseOrderDetailMapper;
import lombok.RequiredArgsConstructor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -30,6 +31,7 @@
    private final MesRohInDataService mesRohInDataService;
    private final PurchaseOrderDetailService purchaseOrderDetailService;
    private final PurchaseOrderCompareMapper purchaseOrderCompareMapper;
    private final PurchaseOrderDetailMapper purchaseOrderDetailMapper;
    /**
     * 同步采购订单明细数据
@@ -44,6 +46,10 @@
        long currentTimeMillis = System.currentTimeMillis();
        // 限制请求时间范围为24小时
        long startDate = currentTimeMillis - (24 * 60 * 60 * 1000L);
        // 先删除已有数据,避免重复
        purchaseOrderDetailMapper.deleteByPrimaryKey();
        purchaseOrderCompareMapper.deleteByPrimaryKey();
        XkyCommonParam<PurchaseParam> param = XkyCommonParam.GetInit();
        PurchaseParam bodyParam = new PurchaseParam();
@@ -166,13 +172,14 @@
        // 计算SRM待收数量
        Integer srmPurchaseQty = detail.getTotalAnswerQty();
        Integer srmReceivedQty = detail.getTotalReceiveQty();
        Integer srmReceivedQty = detail.getPoWaitDeliveryQty() + detail.getReturnWaitDeliveryQty();
        //poWaitDeliveryQty + returnWaitDeliveryQty
        Integer srmWaitReceiveQty = srmPurchaseQty - srmReceivedQty;
        // 设置SRM数据
        compareData.setSrmPurchaseQty(srmPurchaseQty);
        compareData.setSrmReceivedQty(srmReceivedQty);
        compareData.setSrmWaitReceiveQty(srmWaitReceiveQty);
        compareData.setSrmReceivedQty(srmWaitReceiveQty);
        compareData.setSrmWaitReceiveQty(srmReceivedQty);
        // 设置ERP数据和差异
        if (erpData == null) {