| | |
| | | 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; |
| | |
| | | private final MesRohInDataService mesRohInDataService; |
| | | private final PurchaseOrderDetailService purchaseOrderDetailService; |
| | | private final PurchaseOrderCompareMapper purchaseOrderCompareMapper; |
| | | private final PurchaseOrderDetailMapper purchaseOrderDetailMapper; |
| | | |
| | | /** |
| | | * 同步采购订单明细数据 |
| | |
| | | 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(); |
| | |
| | | |
| | | // 计算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) { |