库存合同：生产订货单审核通过后才能锁价

 package com.lframework.xingyun.sc.bo.contract;
 package com.lframework.xingyun.sc.bo.contract;
 
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.lframework.starter.common.constants.StringPool;
 import com.lframework.starter.common.constants.StringPool;
 import com.lframework.starter.web.core.bo.BaseBo;
 import com.lframework.starter.web.core.bo.BaseBo;
@@ -480,6 +481,12 @@ public class GetContractDistributorStandardBo extends BaseBo<ContractDistributor
     private Boolean canSplit;
     private Boolean canSplit;
 
 
     /**
     /**
+     * 是否可锁价
+     */
+    @ApiModelProperty(value = "是否可锁价")
+    private Boolean canPriceLock;
+
+    /**
      * 创建人
      * 创建人
      */
      */
     @ApiModelProperty(value = "创建人")
     @ApiModelProperty(value = "创建人")

@@ -240,6 +240,12 @@ public class QueryContractDistributorStandardBo extends BaseBo<ContractDistribut
     @ApiModelProperty(value = "是否可拆分")
     @ApiModelProperty(value = "是否可拆分")
     private Boolean canSplit;
     private Boolean canSplit;
 
 
+    /**
+     * 是否可锁价
+     */
+    @ApiModelProperty(value = "是否可锁价")
+    private Boolean canPriceLock;
+
 
 
     public QueryContractDistributorStandardBo() {
     public QueryContractDistributorStandardBo() {
 
 

@@ -369,6 +369,12 @@ public class ContractDistributorStandard extends BaseEntity implements BaseDto {
     private Boolean canSplit;
     private Boolean canSplit;
 
 
     /**
     /**
+     * 是否可锁价
+     */
+    @TableField(exist = false)
+    private Boolean canPriceLock;
+
+    /**
      * 剩余锁规数量
      * 剩余锁规数量
      */
      */
     @TableField(exist = false)
     @TableField(exist = false)

@@ -216,6 +216,7 @@ public class ContractDistributorStandardServiceImpl extends
 
 
         List<ContractDistributorStandard> datas = getBaseMapper().query(vo);
         List<ContractDistributorStandard> datas = getBaseMapper().query(vo);
         CollectionUtils.emptyIfNull(datas).forEach(data -> data.setCanSplit(isCanSplit(data)));
         CollectionUtils.emptyIfNull(datas).forEach(data -> data.setCanSplit(isCanSplit(data)));
+        fillCanPriceLock(datas);
         return datas;
         return datas;
     }
     }
 
 
@@ -236,6 +237,7 @@ public class ContractDistributorStandardServiceImpl extends
         }
         }
         data.setCanEdit(canEdit);
         data.setCanEdit(canEdit);
         fillRemainingQuantity(data);
         fillRemainingQuantity(data);
+        fillCanPriceLock(data);
 
 
         // 获取当前人员的待办任务数据
         // 获取当前人员的待办任务数据
         List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo(), SecurityUtil.getCurrentUser().getId());
         List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo(), SecurityUtil.getCurrentUser().getId());
@@ -305,6 +307,102 @@ public class ContractDistributorStandardServiceImpl extends
         return true;
         return true;
     }
     }
 
 
+    /**
+     * 批量回填是否可锁价
+     *
+     * @param datas 合同列表
+     */
+    private void fillCanPriceLock(List<ContractDistributorStandard> datas) {
+        if (CollectionUtils.isEmpty(datas)) {
+            return;
+        }
+
+        List<ContractDistributorStandard> inventoryContracts = CollectionUtils.emptyIfNull(datas).stream()
+                .filter(Objects::nonNull)
+                .filter(this::isInventoryContract)
+                .collect(Collectors.toList());
+        if (CollectionUtils.isEmpty(inventoryContracts)) {
+            CollectionUtils.emptyIfNull(datas).stream()
+                    .filter(Objects::nonNull)
+                    .forEach(data -> data.setCanPriceLock(false));
+            return;
+        }
+
+        Set<String> contractIds = inventoryContracts.stream()
+                .map(ContractDistributorStandard::getId)
+                .filter(StringUtils::isNotBlank)
+                .collect(Collectors.toSet());
+        Set<String> approvedProductionOrderContractIds = Collections.emptySet();
+        if (CollectionUtils.isNotEmpty(contractIds)) {
+            Wrapper<PurchaseOrderInfo> orderInfoWrapper = Wrappers.lambdaQuery(PurchaseOrderInfo.class)
+                    .in(PurchaseOrderInfo::getContractId, contractIds)
+                    .eq(PurchaseOrderInfo::getType, "PRODUCTION")
+                    .eq(PurchaseOrderInfo::getExamineStatus, "PASS");
+            approvedProductionOrderContractIds = CollectionUtils.emptyIfNull(purchaseOrderInfoService.list(orderInfoWrapper)).stream()
+                    .map(PurchaseOrderInfo::getContractId)
+                    .filter(StringUtils::isNotBlank)
+                    .collect(Collectors.toSet());
+        }
+
+        Set<String> finalApprovedProductionOrderContractIds = approvedProductionOrderContractIds;
+        CollectionUtils.emptyIfNull(datas).stream()
+                .filter(Objects::nonNull)
+                .forEach(data -> data.setCanPriceLock(
+                        isCanPriceLock(data, finalApprovedProductionOrderContractIds.contains(data.getId()))));
+    }
+
+    /**
+     * 回填是否可锁价
+     *
+     * @param data 合同
+     */
+    private void fillCanPriceLock(ContractDistributorStandard data) {
+        if (data == null || StringUtils.isBlank(data.getId())) {
+            return;
+        }
+
+        boolean hasApprovedProductionOrder = false;
+        if (isInventoryContract(data)) {
+            Wrapper<PurchaseOrderInfo> orderInfoWrapper = Wrappers.lambdaQuery(PurchaseOrderInfo.class)
+                    .eq(PurchaseOrderInfo::getContractId, data.getId())
+                    .eq(PurchaseOrderInfo::getType, "PRODUCTION")
+                    .eq(PurchaseOrderInfo::getExamineStatus, "PASS");
+            hasApprovedProductionOrder = CollectionUtils.isNotEmpty(purchaseOrderInfoService.list(orderInfoWrapper));
+        }
+        data.setCanPriceLock(isCanPriceLock(data, hasApprovedProductionOrder));
+    }
+
+    /**
+     * 判断是否可锁价
+     *
+     * @param data                      合同
+     * @param hasApprovedProductionOrder 是否存在已审核通过的生产订货单
+     * @return 是否可锁价
+     */
+    private boolean isCanPriceLock(ContractDistributorStandard data, boolean hasApprovedProductionOrder) {
+        if (data == null || !isInventoryContract(data)) {
+            return false;
+        }
+        if (Boolean.TRUE.equals(data.getPriceSpecLocked())) {
+            return false;
+        }
+        if (!CustomerDevelopStatus.PASS.name().equals(data.getFormalApproved())) {
+            return false;
+        }
+        return hasApprovedProductionOrder;
+    }
+
+    /**
+     * 判断是否为库存合同
+     *
+     * @param data 合同
+     * @return 是否为库存合同
+     */
+    private boolean isInventoryContract(ContractDistributorStandard data) {
+        return data != null && ("DIST_STOCK_CONTRACT".equals(data.getType())
+                || "INTL_INVENTORY_AGMT".equals(data.getType()));
+    }
+
     @OpLog(type = OtherOpLogType.class, name = "新增合同，ID：{}", params = {"#id"})
     @OpLog(type = OtherOpLogType.class, name = "新增合同，ID：{}", params = {"#id"})
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     @Override
     @Override