feat:erp石工泵合同推送

shiyunteng

7 天以前 7ffef0059ddf3d4a82de4a4a8999b4b2429fcda6

 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractServiceImpl.java

@@ -7,6 +7,9 @@
import cn.hutool.core.util.ArrayUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -14,14 +17,12 @@
import com.by4cloud.platformx.admin.api.feign.RemoteDeptService;
import com.by4cloud.platformx.business.api.feign.RemoteFlowProcessService;
import com.by4cloud.platformx.business.constant.FlowNameEnum;
import com.by4cloud.platformx.business.dto.ContracQueryDTO;
import com.by4cloud.platformx.business.dto.ContractAddDTO;
import com.by4cloud.platformx.business.dto.ContractUpdateDTO;
import com.by4cloud.platformx.business.dto.DelayOutApprovalDTO;
import com.by4cloud.platformx.business.dto.*;
import com.by4cloud.platformx.business.entity.*;
import com.by4cloud.platformx.business.mapper.*;
import com.by4cloud.platformx.business.service.ContractService;
import com.by4cloud.platformx.business.utils.ContractNumberGenerator;
import com.by4cloud.platformx.business.utils.ItemGeneratorUtil;
import com.by4cloud.platformx.business.vo.ContractDetailVo;
import com.by4cloud.platformx.common.core.util.R;
import com.by4cloud.platformx.common.data.datascope.DataScope;
@@ -33,6 +34,8 @@
import com.deepoove.poi.plugin.table.LoopRowTableRenderPolicy;
import jakarta.servlet.http.HttpServletResponse;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.ClassPathResource;
import org.springframework.stereotype.Service;

@@ -43,12 +46,14 @@
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;

/**
 * @author cd
 * @description
 * @date 2026/4/29 14:07
 **/
@Slf4j
@Service
@RequiredArgsConstructor
public class ContractServiceImpl extends ServiceImpl<ContractMapper, Contract> implements ContractService {
@@ -65,6 +70,37 @@
   private final ProductMapper productMapper;
   private final RemoteDeptService remoteDeptService;
   private final ContractDelayOutMapper contractDelayOutMapper;
   private final ErpRequestRecordMapper erpRequestRecordMapper;

   @Value("${erp.ymj}")
   private String ymjErp;

   @Value("${erp.smj}")
   private String smjErp;

   @Value("${erp.sgb}")
   private String sgbErp;

   @Value("${erp.jxc}")
   private String jxcErp;

   @Value("${erp.tfgs}")
   private String tfgsErp;

   @Value("${dept.smj}")
   private String smj;

   @Value("${dept.sgb}")
   private String sgb;

   @Value("${dept.jxc}")
   private String jxc;

   @Value("${dept.tfgs}")
   private String tfgs;

   @Value("${dept.ymj}")
   private String ymj;

   @Override
   public R add(ContractAddDTO addDTO) {
@@ -76,9 +112,20 @@
      contract.setBillingStatus("0");
      contract.setErpPushFlag("0");

      if (StrUtil.isNotEmpty(addDTO.getContractCategory()) && (
            StrUtil.equals(addDTO.getContractCategory(), "ymjgkcpmm")||StrUtil.equals(addDTO.getContractCategory(), "ymjgypmm"))) {
         contract.setExpirationDate(DateUtil.offsetDay(contract.getSignDate(),contract.getDeliveryCycle()));
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(),addDTO.getDeliveryCycle()));
      }

      if (!StrUtil.equals(addDTO.getContractCategory(), "water_house")){
         // 假设 list 是你的 List<ContractSubjectMatterAddDTO>
         Optional<ContractSubjectMatterAddDTO> maxDateObj = addDTO.getContractSubjectMatter().stream()
               .filter(item -> item.getPlannedDeliveryDate() != null) // 过滤掉日期为空的项，避免 NullPointerException
               .max(Comparator.comparing(ContractSubjectMatterAddDTO::getPlannedDeliveryDate));

         if (maxDateObj.isPresent()) {
            contract.setExpirationDate(maxDateObj.get().getPlannedDeliveryDate());

         }
      }
      List<Contract> contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));
      while (ArrayUtil.isNotEmpty(contracts.toArray())) {
@@ -176,6 +223,21 @@
         contract.setContractNo(ContractNumberGenerator.generateContractNumber());
         contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));
      }
      if (ObjUtil.isNotNull(updateDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(updateDTO.getSignDate(),updateDTO.getDeliveryCycle()));
      }
      if (!StrUtil.equals(updateDTO.getContractCategory(), "water_house")){
         // 假设 list 是你的 List<ContractSubjectMatterAddDTO>
         Optional<ContractSubjectMatterAddDTO> maxDateObj = updateDTO.getContractSubjectMatter().stream()
               .filter(item -> item.getPlannedDeliveryDate() != null) // 过滤掉日期为空的项，避免 NullPointerException
               .max(Comparator.comparing(ContractSubjectMatterAddDTO::getPlannedDeliveryDate));

         if (maxDateObj.isPresent()) {
            contract.setExpirationDate(maxDateObj.get().getPlannedDeliveryDate());

         }
      }

      baseMapper.updateById(contract);

      if (ArrayUtil.isNotEmpty(updateDTO.getContractSubjectMatter())) {
@@ -272,10 +334,10 @@
      Contract contract = baseMapper.selectById(id);
      contract.setContractStatus(2);
      baseMapper.updateById(contract);
      if (StrUtil.isNotEmpty(contract.getContractCategory()) && StrUtil.equals(contract.getContractCategory(), "water_house")) {

         List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
               .eq(ContractSubjectMatter::getContractId,id));

      if (StrUtil.isNotEmpty(contract.getContractCategory()) && StrUtil.equals(contract.getContractCategory(), "water_house")) {
         if (ArrayUtil.isNotEmpty(subjectMatterList.toArray())) {
            for (ContractSubjectMatter contractSubjectMatter: subjectMatterList)  {
               if (StrUtil.equals(contract.getExecFrequency(), "1")) {
@@ -474,6 +536,85 @@
//         contractPaymentScheduleMapper.updateById(fitstSchedule);
//      }
      }
      //erp推送
      JSONObject request = new JSONObject();
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      request.put("contractNo",contract.getContractNo());
      request.put("partyA",contract.getPartyA());
      request.put("partyACode",customer.getErpCompanyCode());

      if (StrUtil.equals(contract.getPartyBId()+"",ymj)&&StrUtil.isNotEmpty(ymjErp)){
         request.put("customerCode",customer.getErpCompanyCode());
         request.put("currencyId","RMB");
         request.put("signDate",DateUtil.format(contract.getSignDate(),DatePattern.NORM_DATETIME_PATTERN));
         request.put("dateDeliver",DateUtil.format(contract.getExpirationDate(),DatePattern.NORM_DATETIME_PATTERN));
         request.put("moneySum",contract.getAmount());
         request.put("signManner","面签");
         request.put("salesman",contract.getCreateBy());
         if (ArrayUtil.isNotEmpty(subjectMatterList.toArray())){
            JSONArray subjectMatter = new JSONArray();
            subjectMatterList.stream().forEach(contractSubjectMatter -> {
               JSONObject subjectMatterItem = new JSONObject();
               subjectMatterItem.put("itemNo",ItemGeneratorUtil.nextId());
               subjectMatterItem.put("salePrice",contractSubjectMatter.getUnitPrice());
               subjectMatterItem.put("qtyRequired",contractSubjectMatter.getQuantity());
               subjectMatterItem.put("money",contractSubjectMatter.getQuantity().multiply(contractSubjectMatter.getUnitPrice()));
               Product product = productMapper.selectOne(Wrappers.<Product>lambdaQuery().eq(Product::getCompId,contract.getCompId())
                     .eq(Product::getErpCode,contractSubjectMatter.getMaterialCode()));
               if (ObjUtil.isNotNull(product)){
                  subjectMatterItem.put("taxRate",new BigDecimal(product.getTaxRate()).divide(new BigDecimal("100")));
               }
               subjectMatterItem.put("dateDeliver",ObjUtil.isNotNull(contractSubjectMatter.getPlannedDeliveryDate())?
                     DateUtil.format(contractSubjectMatter.getPlannedDeliveryDate(),DatePattern.NORM_DATETIME_PATTERN):
                     DateUtil.format(contract.getExpirationDate(),DatePattern.NORM_DATETIME_PATTERN));
               subjectMatter.add(subjectMatterItem);
            });
            request.put("details",subjectMatter);
         }
         log.info("一煤机合同推送erp入参：{}",request.toJSONString());
         String result = HttpUtil.post(ymjErp,request.toJSONString());
         log.info("一煤机合同推送erp回参：{}",result);
         //保存请求记录
         saveErpRequestRecord("ymj",request.toJSONString(),result);
         //更新合同erp推送标识
         contract.setErpPushFlag("1");
         baseMapper.updateById(contract);
      }
      if (StrUtil.equals(contract.getPartyBId()+"",smj)&&StrUtil.isNotEmpty(smjErp)){
         log.info("石煤机合同推送erp入参：{}",request.toJSONString());
         String result = HttpUtil.post(ymjErp,request.toJSONString());
         log.info("石煤机合同推送erp回参：{}",result);
         //保存请求记录
         saveErpRequestRecord("smj",request.toJSONString(),result);
         //更新合同erp推送标识
         contract.setErpPushFlag("1");
         baseMapper.updateById(contract);
      }

      if (StrUtil.equals(contract.getPartyBId()+"",jxc)&&StrUtil.isNotEmpty(jxcErp)){
         log.info("机械厂合同推送erp入参：{}",request.toJSONString());
         String result = HttpUtil.post(ymjErp,request.toJSONString());
         log.info("机械厂合同推送erp回参：{}",result);
         //保存请求记录
         saveErpRequestRecord("jxc",request.toJSONString(),result);
         //更新合同erp推送标识
         contract.setErpPushFlag("1");
         baseMapper.updateById(contract);
      }
      if (StrUtil.equals(contract.getPartyBId()+"",tfgs)&&StrUtil.isNotEmpty(tfgsErp)){
         //通方公司通过系统录入
      }
      if (StrUtil.equals(contract.getPartyBId()+"",sgb)&&StrUtil.isNotEmpty(sgbErp)){
         //石工泵主动推送系统
      }
   }

   private void saveErpRequestRecord(String ymj, String toJSONString, String result) {
      ErpRequestRecord record = new ErpRequestRecord();
      record.setErpName(ymj);
      record.setRequestParams(toJSONString);
      record.setResponseParams(result);
      erpRequestRecordMapper.insert(record);
   }

   private void savePaymentConfirm(Contract contract, ContractPaymentSchedule schedule) {
@@ -574,6 +715,7 @@
            overdueConfirm.setScheduleName(contractPaymentSchedule.getStageName());
            PaymentConfirm newLastConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
                  .orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
            if(ObjUtil.isNotNull(newLastConfirm)){
            overdueConfirm.setTransationAmount(StrUtil.equals(contractPaymentSchedule.getPaymentStatus() + "", "0") ?
                  contractPaymentSchedule.getPlannedAmount() :
                  contractPaymentSchedule.getPlannedAmount().subtract(contractPaymentSchedule.getActualAmount()));
@@ -609,6 +751,7 @@
            } else {
               overdue.setOverdueDuration(BigDecimal.valueOf(DateUtil.betweenDay(contractPaymentSchedule.getEffectiveEndDate(), new Date(), true)));
               currentOverdueMapper.updateById(overdue);
               }
            }
         });
      }
@@ -1253,4 +1396,244 @@
      }
   }

   @Override
   public R addContractSgb(ContractAddDTO addDTO) {
      if (ArrayUtil.isEmpty(addDTO.getContractSubjectMatter().toArray())){
         return R.failed("请添加标的物");
      }
      if (ArrayUtil.isEmpty(addDTO.getContractPaymentSchedule().toArray())){
         return R.failed("请添加付款阶段或付款阶段缺少");
      }
      if (!isValidPaymentStages(addDTO.getContractPaymentSchedule())){
         return R.failed("付款阶段信息异常");
      }
      if (addDTO.getContractPaymentSchedule().stream().map(item->item.getPaymentRatio()).reduce(BigDecimal.ZERO,BigDecimal::add)
            .compareTo(new BigDecimal("100.00"))!=0){
         return R.failed("付款阶段比例异常");
      }
      Contract contract = BeanUtil.copyProperties(addDTO, Contract.class);
      contract.setPartyBId(SecurityUtils.getUser().getCompId());
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      contract.setContractStatus(2);
      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingStatus("0");
      contract.setErpPushFlag("1");
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(),addDTO.getDeliveryCycle()));
      }
      if (!StrUtil.equals(addDTO.getContractCategory(), "water_house")){
         // 假设 list 是你的 List<ContractSubjectMatterAddDTO>
         Optional<ContractSubjectMatterAddDTO> maxDateObj = addDTO.getContractSubjectMatter().stream()
               .filter(item -> item.getPlannedDeliveryDate() != null) // 过滤掉日期为空的项，避免 NullPointerException
               .max(Comparator.comparing(ContractSubjectMatterAddDTO::getPlannedDeliveryDate));

         if (maxDateObj.isPresent()) {
            contract.setExpirationDate(maxDateObj.get().getPlannedDeliveryDate());

         }
      }
      baseMapper.insert(contract);

      if (ArrayUtil.isNotEmpty(addDTO.getContractSubjectMatter())) {
         addDTO.getContractSubjectMatter().stream().forEach(contractSubjectMatterAddDTO -> {
            ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatterAddDTO, ContractSubjectMatter.class);
            subjectMatter.setContractId(contract.getId());
            subjectMatter.setContractName(contract.getContractName());
            subjectMatter.setDeliveredQuantity(new BigDecimal("0"));
            subjectMatter.setDeliveryStatus(0);
            subjectMatter.setTotalAmount(contractSubjectMatterAddDTO.getQuantity().multiply(contractSubjectMatterAddDTO.getUnitPrice()));
            contractSubjectMatterMapper.insert(subjectMatter);
            //水电类必须有初次表号
            if (StrUtil.isNotEmpty(contractSubjectMatterAddDTO.getMeterReadCode()) &&
                  ObjUtil.isNotNull(contractSubjectMatterAddDTO.getMeterReadNum())) {
               MeterReadRecord record = BeanUtil.copyProperties(contractSubjectMatterAddDTO, MeterReadRecord.class,"id");
               record.setContractId(contract.getId());
               record.setMatterId(subjectMatter.getId());
               record.setContractName(contract.getContractName());
               record.setBusGuestId(contract.getPartyAId());
               record.setBusGuestName(contract.getPartyA());
               record.setMeterReadTime(new Date());
               meterReadRecordMapper.insert(record);
            }
            if (StrUtil.isNotEmpty(addDTO.getContractCategory()) && StrUtil.equals(addDTO.getContractCategory(), "ymjcg")
                  &&ObjUtil.isNotNull(subjectMatter.getPlannedDeliveryDate())&&ObjUtil.isNotNull(contract.getExpirationDate())
                  &&DateUtil.compare(contract.getExpirationDate(),subjectMatter.getPlannedDeliveryDate())>0) {
               contract.setExpirationDate(subjectMatter.getPlannedDeliveryDate());
               baseMapper.updateById(contract);
            }
         });

      }

      if (ArrayUtil.isNotEmpty(addDTO.getContractPaymentSchedule())) {
         AtomicInteger index = new AtomicInteger(1);
         addDTO.getContractPaymentSchedule().stream().forEach(contractPaymentScheduleAddDTO -> {
            int currentIndex = index.getAndIncrement();
            ContractPaymentSchedule schedule = BeanUtil.copyProperties(contractPaymentScheduleAddDTO, ContractPaymentSchedule.class);
            if (contractPaymentScheduleAddDTO.getStageName().equals("合同签订")) {
               schedule.setEffectiveEndDate(DateUtil.offsetDay(contract.getSignDate(), contractPaymentScheduleAddDTO.getAgreedDays()));
            }
            if (ObjUtil.isNotNull(schedule.getEffectiveDate())) {
               if (schedule.getEffectiveDate().before(DateUtil.date())) {
                  schedule.setFulfillmentStatus(1);
               } else {
                  schedule.setFulfillmentStatus(0);
               }
            }
            if (contractPaymentScheduleAddDTO.getPaymentRatio().compareTo(new BigDecimal("0")) > 0) {
               schedule.setPaymentStatus(0);
            } else {
               schedule.setPaymentStatus(3);
            }
            schedule.setContractId(contract.getId());
            schedule.setContractName(contract.getContractName());
            schedule.setPlannedAmount(contract.getAmount().multiply(schedule.getPaymentRatio().divide(new BigDecimal("100"))));
            schedule.setStageOrder(currentIndex);
            contractPaymentScheduleMapper.insert(schedule);
            if (contractPaymentScheduleAddDTO.getStageName().equals("货到签收")) {
               contract.setArrivalScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("调试完成或验收")) {
               contract.setAcceptScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         });

      }


      return R.ok(contract.getId());
   }

   @Override
   public R updateContractSgb(ContractUpdateDTO updateDTO) {
      if (ArrayUtil.isEmpty(updateDTO.getContractSubjectMatter().toArray())){
         return R.failed("请添加标的物");
      }
      if (ArrayUtil.isEmpty(updateDTO.getContractPaymentSchedule().toArray())){
         return R.failed("请添加付款阶段或付款阶段缺少");
      }
      if (!isValidPaymentStages(updateDTO.getContractPaymentSchedule())){
         return R.failed("付款阶段信息异常");
      }
      if (updateDTO.getContractPaymentSchedule().stream().map(item->item.getPaymentRatio()).reduce(BigDecimal.ZERO,BigDecimal::add)
            .compareTo(new BigDecimal("100.00"))!=0){
         return R.failed("付款阶段比例异常");
      }

      Contract contract = BeanUtil.copyProperties(updateDTO, Contract.class);
      if (ObjUtil.isNotNull(updateDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(updateDTO.getSignDate(),updateDTO.getDeliveryCycle()));
      }
      if (!StrUtil.equals(updateDTO.getContractCategory(), "water_house")){
         // 假设 list 是你的 List<ContractSubjectMatterAddDTO>
         Optional<ContractSubjectMatterAddDTO> maxDateObj = updateDTO.getContractSubjectMatter().stream()
               .filter(item -> item.getPlannedDeliveryDate() != null) // 过滤掉日期为空的项，避免 NullPointerException
               .max(Comparator.comparing(ContractSubjectMatterAddDTO::getPlannedDeliveryDate));

         if (maxDateObj.isPresent()) {
            contract.setExpirationDate(maxDateObj.get().getPlannedDeliveryDate());

         }
      }
      baseMapper.updateById(contract);

      if (ArrayUtil.isNotEmpty(updateDTO.getContractSubjectMatter())) {
         contractSubjectMatterMapper.delete(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId, contract.getId()));

         updateDTO.getContractSubjectMatter().stream().forEach(contractSubjectMatterAddDTO -> {
            ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatterAddDTO, ContractSubjectMatter.class);
            subjectMatter.setContractId(contract.getId());
            subjectMatter.setContractName(contract.getContractName());
            subjectMatter.setDeliveredQuantity(new BigDecimal("0"));
            subjectMatter.setDeliveryStatus(0);
            contractSubjectMatterMapper.insert(subjectMatter);
            //水电类必须有初次表号
            if (StrUtil.isNotEmpty(contractSubjectMatterAddDTO.getMeterReadCode()) &&
                  ObjUtil.isNotNull(contractSubjectMatterAddDTO.getMeterReadNum())) {
               meterReadRecordMapper.delete(Wrappers.<MeterReadRecord>lambdaQuery().eq(MeterReadRecord::getContractId, contract.getId()));
               MeterReadRecord record = BeanUtil.copyProperties(contractSubjectMatterAddDTO, MeterReadRecord.class,"id");
               record.setContractId(contract.getId());
               record.setMatterId(subjectMatter.getId());
               record.setContractName(contract.getContractName());
               record.setBusGuestId(contract.getPartyAId());
               record.setBusGuestName(contract.getPartyA());
               record.setMeterReadTime(new Date());
               meterReadRecordMapper.insert(record);
            }
         });
      }

      if (ArrayUtil.isNotEmpty(updateDTO.getContractPaymentSchedule())) {
         contractPaymentScheduleMapper.delete(Wrappers.<ContractPaymentSchedule>lambdaQuery().eq(ContractPaymentSchedule::getContractId, contract.getId()));

         AtomicInteger index = new AtomicInteger(1);
         updateDTO.getContractPaymentSchedule().stream().forEach(contractPaymentScheduleAddDTO -> {
            int currentIndex = index.getAndIncrement();
            ContractPaymentSchedule schedule = BeanUtil.copyProperties(contractPaymentScheduleAddDTO, ContractPaymentSchedule.class);
            schedule.setContractId(contract.getId());
            schedule.setContractName(contract.getContractName());
            schedule.setPlannedAmount(contract.getAmount().multiply(schedule.getPaymentRatio().divide(new BigDecimal("100"))));
            schedule.setStageOrder(currentIndex);
            if (contractPaymentScheduleAddDTO.getPaymentRatio().compareTo(new BigDecimal("0")) > 0) {
               schedule.setPaymentStatus(0);
            } else {
               schedule.setPaymentStatus(3);
            }
            contractPaymentScheduleMapper.insert(schedule);
            if (contractPaymentScheduleAddDTO.getStageName().equals("货到签收")) {
               contract.setArrivalScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("调试完成或验收")) {
               contract.setAcceptScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         });

      }

      return R.ok();
   }

   // 定义标准的五个阶段
   private static final Set<String> VALID_STAGES = new HashSet<>(Arrays.asList(
         "合同签订",
         "发货前",
         "货到签收",
         "调试完成或验收",
         "质保金"
   ));

   /**
    * 判断付款阶段列表是否符合标准
    * @param scheduleList 付款阶段列表
    * @return true 如果包含且仅包含标准的五个阶段，false 否则
    */
   public static boolean isValidPaymentStages(List<ContractPaymentScheduleAddDTO> scheduleList) {
      if (scheduleList == null || scheduleList.isEmpty()) {
         return false;
      }

      // 1. 提取所有非空的 stageName
      List<String> actualStages = scheduleList.stream()
            .map(ContractPaymentScheduleAddDTO::getStageName)
            .filter(stage -> stage != null && !stage.trim().isEmpty())
            .map(String::trim)
            .collect(Collectors.toList());

      // 2. 基本数量检查：必须正好是5个
      if (actualStages.size() != VALID_STAGES.size()) {
         return false;
      }

      // 3. 内容检查：所有实际阶段都必须在标准集合中
      // 使用 Set 去重后比较，防止列表中有重复阶段但总数凑够5个的情况
      Set<String> actualStageSet = new HashSet<>(actualStages);

      // 检查实际集合大小是否也为5（确保无重复）且包含于标准集合
      return VALID_STAGES.equals(actualStageSet);
   }

}