楚江erp：根据账期数据管控发货相关接口开发（冻结）

@@ -258,4 +258,16 @@ public class ReceiptLedgerInfoController extends DefaultBaseController {
         }
         }
         return InvokeResultBuilder.success();
         return InvokeResultBuilder.success();
     }
     }
+
+
+    /**
+     * 冻结欠款客户订货单、草稿要车单数据
+     */
+    @ApiOperation("自动生成台账明细数据")
+    @GetMapping("/autoFreeze")
+    @Scheduled(cron = "0 50 2 * * ?")
+    public InvokeResult<Void> autoFreeze() {
+        receiptLedgerInfoService.autoFreeze(null);
+        return InvokeResultBuilder.success();
+    }
 }
 }

@@ -23,6 +23,7 @@ import com.lframework.xingyun.sc.service.customer.CustomerCreditHistoryService;
 import com.lframework.xingyun.sc.service.customer.CustomerCreditService;
 import com.lframework.xingyun.sc.service.customer.CustomerCreditService;
 import com.lframework.xingyun.sc.service.customer.CustomerDevelopPlanService;
 import com.lframework.xingyun.sc.service.customer.CustomerDevelopPlanService;
 import com.lframework.xingyun.sc.service.ledger.FundCoordinationService;
 import com.lframework.xingyun.sc.service.ledger.FundCoordinationService;
+import com.lframework.xingyun.sc.service.ledger.ReceiptLedgerInfoService;
 import com.lframework.xingyun.sc.service.order.*;
 import com.lframework.xingyun.sc.service.order.*;
 import com.lframework.xingyun.sc.service.purchase.ReplenishmentOrderService;
 import com.lframework.xingyun.sc.service.purchase.ReplenishmentOrderService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsOrderInfoService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsOrderInfoService;
@@ -117,6 +118,8 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
     private FundCoordinationService fundCoordinationService;
     private FundCoordinationService fundCoordinationService;
     @Resource
     @Resource
     private ShipmentsOrderInfoService shipmentsOrderInfoService;
     private ShipmentsOrderInfoService shipmentsOrderInfoService;
+    @Resource
+    private ReceiptLedgerInfoService receiptLedgerInfoService;
 
 
 
 
 
 
@@ -144,6 +147,7 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
         if (StringUtils.isBlank(businessType)) {
         if (StringUtils.isBlank(businessType)) {
             return;
             return;
         }
         }
+        String customerId = (String) variable.get("orderingUnit");
         // 获取审核结果
         // 获取审核结果
         String flowStatus = instance.getFlowStatus();
         String flowStatus = instance.getFlowStatus();
         // 更新业务数据
         // 更新业务数据
@@ -161,7 +165,7 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
                 handleStandardContractAuditData(flowStatus, businessId);
                 handleStandardContractAuditData(flowStatus, businessId);
                 break;
                 break;
             case "PURCHASE_ORDER":
             case "PURCHASE_ORDER":
-                handlePurchaseOrderData(flowStatus, businessId);
+                handlePurchaseOrderData(flowStatus, businessId, customerId);
                 break;
                 break;
             case "ORDER_CANCELLATION":
             case "ORDER_CANCELLATION":
                 handlePurchaseOrderRevokeData(flowStatus, businessId, variable);
                 handlePurchaseOrderRevokeData(flowStatus, businessId, variable);
@@ -266,7 +270,7 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
      *
      *
      * @param businessId 业务ID
      * @param businessId 业务ID
      */
      */
-    private void handlePurchaseOrderData(String flowStatus, String businessId) {
+    private void handlePurchaseOrderData(String flowStatus, String businessId, String customerId) {
         if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
         if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
                 || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
                 || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
             purchaseOrderInfoService.updateStatus(businessId, "PASS");
             purchaseOrderInfoService.updateStatus(businessId, "PASS");
@@ -275,6 +279,7 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
                 || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
                 || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
             purchaseOrderInfoService.updateStatus(businessId, "REFUSE");
             purchaseOrderInfoService.updateStatus(businessId, "REFUSE");
         }
         }
+        receiptLedgerInfoService.autoFreeze(customerId);
     }
     }
 
 
     /**
     /**

@@ -32,10 +32,12 @@ import com.lframework.xingyun.sc.service.order.PurchaseOrderInfoService;
 import com.lframework.xingyun.sc.service.order.PurchaseOrderLineService;
 import com.lframework.xingyun.sc.service.order.PurchaseOrderLineService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsOrderInfoService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsOrderInfoService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsPlanDetailService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsPlanDetailService;
+import com.lframework.xingyun.sc.service.shipments.car.DraftRequestCarTicketService;
 import com.lframework.xingyun.sc.utils.CommonUtil;
 import com.lframework.xingyun.sc.utils.CommonUtil;
 import com.lframework.xingyun.sc.vo.ledger.receipt.*;
 import com.lframework.xingyun.sc.vo.ledger.receipt.*;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.BooleanUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.annotation.Transactional;
 import com.lframework.xingyun.sc.mappers.ReceiptLedgerInfoMapper;
 import com.lframework.xingyun.sc.mappers.ReceiptLedgerInfoMapper;
@@ -77,6 +79,8 @@ public class ReceiptLedgerInfoServiceImpl extends BaseMpServiceImpl<ReceiptLedge
     private ShipmentsPlanDetailService shipmentsPlanDetailService;
     private ShipmentsPlanDetailService shipmentsPlanDetailService;
     @Resource
     @Resource
     private ContractDistributorStandardService contractDistributorStandardService;
     private ContractDistributorStandardService contractDistributorStandardService;
+    @Resource
+    private DraftRequestCarTicketService draftRequestCarTicketService;
 
 
 
 
     // 定义状态优先级顺序（从高到低）
     // 定义状态优先级顺序（从高到低）
@@ -783,6 +787,71 @@ public class ReceiptLedgerInfoServiceImpl extends BaseMpServiceImpl<ReceiptLedge
         baseMapper.batchAdd(ledgerInfoList);
         baseMapper.batchAdd(ledgerInfoList);
     }
     }
 
 
+    @Override
+    public Map<String, Boolean> checkIsDebt(String customerId) {
+        LocalDateTime endTime = LocalDateTime.now();
+        LocalDateTime startTime = LocalDate.now().atStartOfDay();
+
+        LambdaQueryWrapper<ReceiptLedgerInfo> queryWrapper = Wrappers.lambdaQuery(ReceiptLedgerInfo.class);
+        queryWrapper.eq(ReceiptLedgerInfo::getDelFlag, Boolean.FALSE)
+                .ge(ReceiptLedgerInfo::getCreateTime, startTime)
+                .le(ReceiptLedgerInfo::getCreateTime, endTime);
+        if (StringUtils.isNotBlank(customerId)) {
+            queryWrapper.eq(ReceiptLedgerInfo::getCustomerId, customerId);
+        }
+        List<ReceiptLedgerInfo> ledgerInfoList = getBaseMapper().selectList(queryWrapper);
+        if (CollectionUtils.isEmpty(ledgerInfoList)) {
+            return Collections.emptyMap();
+        }
+        Map<String, Boolean> result = new HashMap<>();
+        for (ReceiptLedgerInfo ledgerInfo : ledgerInfoList) {
+            BigDecimal endAccountReceivable = ledgerInfo.getEndAccountReceivable();
+            if (endAccountReceivable.compareTo(BigDecimal.ZERO) > 0) {
+                result.put(ledgerInfo.getCustomerId(), Boolean.TRUE);
+            } else {
+                result.put(ledgerInfo.getCustomerId(), Boolean.FALSE);
+            }
+        }
+        return result;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void autoFreeze(String customerId) {
+        Map<String, Boolean> debtCustomerMap = checkIsDebt(customerId);
+        Set<String> customerIds = debtCustomerMap.keySet();
+        if (CollectionUtils.isEmpty(customerIds)) {
+            return;
+        }
+        List<PurchaseOrderInfo> orderInfoList = purchaseOrderInfoService.listByCustomerIds(new ArrayList<>(customerIds));
+        if (CollectionUtils.isEmpty(orderInfoList)) {
+            return;
+        }
+        // 按客户分组订货单
+        Map<String, List<String>> orderInfoMap = new HashMap<>();
+        for (PurchaseOrderInfo orderInfo : orderInfoList) {
+            String orderingUnit = orderInfo.getOrderingUnit();
+            List<String> list = orderInfoMap.computeIfAbsent(orderingUnit, k -> new ArrayList<>());
+            if ("PRODUCTION".equals(orderInfo.getType())) {
+                list.add(orderInfo.getId());
+            }
+        }
+        List<String> needFreezeOrderIds = new ArrayList<>();
+        for (String id : customerIds) {
+            Boolean debt = debtCustomerMap.get(id);
+            List<String> orderIds = orderInfoMap.get(id);
+            if (BooleanUtils.isTrue(debt) && CollectionUtils.isNotEmpty(orderIds)) {
+                needFreezeOrderIds.addAll(orderIds);
+            }
+        }
+        // 冻结订货单
+        purchaseOrderInfoService.freeze(needFreezeOrderIds);
+        // 冻结草稿要车单
+        draftRequestCarTicketService.freezeOrDeblocking(Boolean.TRUE, needFreezeOrderIds);
+        // 删除已有发货计划（过滤已生成发货单的）
+        shipmentsPlanDetailService.delByOrderIds(needFreezeOrderIds);
+    }
+
 
 
     /**
     /**
      * 从多个状态中获取最高优先级的状态
      * 从多个状态中获取最高优先级的状态

@@ -629,6 +629,18 @@ public class PurchaseOrderInfoServiceImpl extends BaseMpServiceImpl<PurchaseOrde
     }
     }
 
 
     @Override
     @Override
+    public void freeze(List<String> ids) {
+        if (CollectionUtils.isEmpty(ids)) {
+            return;
+        }
+        LambdaUpdateWrapper<PurchaseOrderInfo> updateWrapper = Wrappers.lambdaUpdate(PurchaseOrderInfo.class);
+        updateWrapper.set(PurchaseOrderInfo::isFreeze, Boolean.TRUE)
+                .in(PurchaseOrderInfo::getId, ids);
+        getBaseMapper().update(updateWrapper);
+    }
+
+
+    @Override
     public void cleanCacheByKey(Serializable key) {
     public void cleanCacheByKey(Serializable key) {
 
 
     }
     }

@@ -511,6 +511,22 @@ public class ShipmentsPlanDetailServiceImpl extends BaseMpServiceImpl<ShipmentsP
         getBaseMapper().deleteBatchIds(ids);
         getBaseMapper().deleteBatchIds(ids);
     }
     }
 
 
+    @Override
+    public void delByOrderIds(List<String> orderIds) {
+        if (CollectionUtils.isEmpty(orderIds)) {
+            return;
+        }
+        LambdaUpdateWrapper<ShipmentsPlanDetail> updateWrapper = Wrappers.lambdaUpdate(ShipmentsPlanDetail.class);
+        updateWrapper.eq(ShipmentsPlanDetail::getPreShipments, Boolean.FALSE)
+                .in(ShipmentsPlanDetail::getOrderId, orderIds)
+                .and(wq -> wq
+                    .isNull(ShipmentsPlanDetail::getShipmentOrderId)
+                    .or()
+                    .eq(ShipmentsPlanDetail::getShipmentOrderId, "")
+                );
+        getBaseMapper().delete(updateWrapper);
+    }
+
 
 
     /**
     /**
      * 封装发货计划明细数据
      * 封装发货计划明细数据

@@ -276,6 +276,14 @@ public class DraftRequestCarTicketServiceImpl extends BaseMpServiceImpl<DraftReq
     }
     }
 
 
     @Override
     @Override
+    public void freezeOrDeblocking(Boolean flag, List<String> orderIds) {
+        LambdaUpdateWrapper<DraftRequestCarTicket> updateWrapper = Wrappers.lambdaUpdate(DraftRequestCarTicket.class);
+        updateWrapper.set(DraftRequestCarTicket::isFreeze, flag)
+                .in(DraftRequestCarTicket::getPurchaseOrderId, orderIds);
+        getBaseMapper().update(updateWrapper);
+    }
+
+    @Override
     public void cleanCacheByKey(Serializable key) {
     public void cleanCacheByKey(Serializable key) {
 
 
     }
     }

@@ -9,6 +9,7 @@ import com.lframework.starter.web.core.components.resp.PageResult;
 
 
 import java.time.LocalDate;
 import java.time.LocalDate;
 import java.util.List;
 import java.util.List;
+import java.util.Map;
 
 
 /**
 /**
  * 应收款台账明细 Service
  * 应收款台账明细 Service
@@ -130,4 +131,16 @@ public interface ReceiptLedgerInfoService extends BaseMpService<ReceiptLedgerInf
      * @param vo
      * @param vo
      */
      */
     void depositReconciliation(UpdateReceiptLedgerInfoVo vo);
     void depositReconciliation(UpdateReceiptLedgerInfoVo vo);
+
+    /**
+     * 检查客户是否欠款
+     *
+     * @param customerId   客户ID
+     */
+    Map<String, Boolean> checkIsDebt(String customerId);
+
+    /**
+     * 冻结欠款客户，管控发货
+     */
+    void autoFreeze(String customerId);
 }
 }

@@ -146,4 +146,12 @@ public interface PurchaseOrderInfoService extends BaseMpService<PurchaseOrderInf
      * @param ids
      * @param ids
      */
      */
     void batchUnblock(List<String> ids);
     void batchUnblock(List<String> ids);
+
+    /**
+     * 冻结
+     * 支持批量操作
+     *
+     * @param ids   主键ID集合
+     */
+    void freeze(List<String> ids);
 }
 }

@@ -146,4 +146,12 @@ public interface ShipmentsPlanDetailService extends BaseMpService<ShipmentsPlanD
      *
      *
      */
      */
     void checkOutdated();
     void checkOutdated();
+
+    /**
+     * 根据订货单ID批量删除
+     * 过滤已生成发货单的数据
+     *
+     * @param orderIds  订货单ID集合
+     */
+    void delByOrderIds(List<String> orderIds);
 }
 }

@@ -77,4 +77,11 @@ public interface DraftRequestCarTicketService extends BaseMpService<DraftRequest
      * @return          Map<String, DraftRequestCarTicket>
      * @return          Map<String, DraftRequestCarTicket>
      */
      */
     List<DraftRequestCarTicket> listByOrderId(List<String> orderIds);
     List<DraftRequestCarTicket> listByOrderId(List<String> orderIds);
+
+    /**
+     * 冻结或解封
+     *
+     * @param flag  标识符
+     */
+    void freezeOrDeblocking(Boolean flag, List<String> orderIds);
 }
 }

@@ -190,7 +190,7 @@
         from tbl_purchase_order_line ol
         from tbl_purchase_order_line ol
         inner join purchase_order_info o on ol.purchase_order_id = o.id
         inner join purchase_order_info o on ol.purchase_order_id = o.id
         left join base_data_customer c on o.ordering_unit = c.id
         left join base_data_customer c on o.ordering_unit = c.id
-        where ol.del_flag = false
+        where ol.del_flag = false and o.freeze = false
         and o.type = 'PRODUCTION' and o.examine_status = 'PASS' and o.status not in ('SHIPPED', 'DELIVERED', 'CANCEL')
         and o.type = 'PRODUCTION' and o.examine_status = 'PASS' and o.status not in ('SHIPPED', 'DELIVERED', 'CANCEL')
         and (o.revoke_status != 'UNDOING' or o.revoke_status is null)
         and (o.revoke_status != 'UNDOING' or o.revoke_status is null)
         and (o.spec_change_status != 'IN_PROGRESS' or o.spec_change_status is null)
         and (o.spec_change_status != 'IN_PROGRESS' or o.spec_change_status is null)