feat:新增石煤机 机械厂模版合同/客户数据主数据同步接口/合同履约进度新增质保结束操作/合同开票状态 修改为待开 可开 已开/出库逻辑完善

shiyunteng

8 小时以前 e02812df9217d3e50a368a8234c07c60c64c0ff4

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

@@ -7,6 +7,11 @@
import cn.hutool.core.util.ArrayUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
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,15 +19,15 @@
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.business.vo.ContractInvoiceVo;
import com.by4cloud.platformx.business.vo.ContractSlipVo;
import com.by4cloud.platformx.business.vo.FourAssociationPageVo;
import com.by4cloud.platformx.common.core.util.R;
import com.by4cloud.platformx.common.data.datascope.DataScope;
import com.by4cloud.platformx.common.security.util.SecurityUtils;
@@ -33,7 +38,10 @@
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.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

import java.io.IOException;
@@ -43,12 +51,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,25 +75,110 @@
   private final ProductMapper productMapper;
   private final RemoteDeptService remoteDeptService;
   private final ContractDelayOutMapper contractDelayOutMapper;
   private final ErpRequestRecordMapper erpRequestRecordMapper;
   private final PaymentSlipMapper paymentSlipMapper;
   private final ContractInvoiceMapper contractInvoiceMapper;
   private final StringRedisTemplate redisTemplate;

   @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) {
      Contract contract = BeanUtil.copyProperties(addDTO, Contract.class);
      contract.setPartyBId(SecurityUtils.getUser().getCompId());
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      contract.setContractNo(ContractNumberGenerator.generateContractNumber());
      contract.setPaidAmount(new BigDecimal("0"));
      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 (StrUtil.isEmpty(addDTO.getPartyA())){
         BusinessCustomer bc = businessCustomerMapper.selectById(addDTO.getPartyAId());
         if (ObjUtil.isNotNull(bc)){
            contract.setPartyA(bc.getCompanyName());
         }
         if (!StrUtil.equals(SecurityUtils.getUser().getCompId()+"",sgb)&&StrUtil.isEmpty(bc.getErpCompanyCode())){
            return R.failed("请完善客户ERP编码");
         }
      }
      List<Contract> contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));
      while (ArrayUtil.isNotEmpty(contracts.toArray())) {
         contract.setContractNo(ContractNumberGenerator.generateContractNumber());
         contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));

      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingStatus("1");
      contract.setBillingAmout(new BigDecimal("0"));
      contract.setErpPushFlag("0");
      contract.setNickName(SecurityUtils.getUser().getNickname());
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(),addDTO.getDeliveryCycle()));
      }
      if (StrUtil.equals(addDTO.getContractCategory(), "water_house")){
         if(!addDTO.getContractSubjectMatter().stream().allMatch(item->StrUtil.equals(item.getMaterialCode(), "water_bill")||
               StrUtil.equals(item.getMaterialCode(), "house_rental")||StrUtil.equals(item.getMaterialCode(), "electricity_bill"))){
            return R.failed("请新增水/电代缴房屋租赁合同！");
         }
      }else {
         if(addDTO.getContractSubjectMatter().stream().anyMatch(item->StrUtil.equals(item.getMaterialCode(), "water_bill")||
               StrUtil.equals(item.getMaterialCode(), "house_rental")||StrUtil.equals(item.getMaterialCode(), "electricity_bill"))){
            return R.failed("水电代缴、房屋租赁产品只能在水/电代缴房屋租赁合同！");
         }
         // 假设 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());

         }
      }

      if (ArrayUtil.isEmpty(addDTO.getContractSubjectMatter().toArray())){
         return R.failed("标的物不能为空");
      }

      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",smj)){
         contract.setContractNo(generateSMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",sgb)){
         contract.setContractNo(generateGYBContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",ymj)){
         contract.setContractNo(generateYMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",tfgs)){
         contract.setContractNo(generateTFContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",jxc)){
         contract.setContractNo(generateJXCContractNo());
      }
      if (StrUtil.isNotEmpty(contract.getContractCategory())&&(StrUtil.equals(contract.getContractCategory(),"ymjjgcl")
            ||StrUtil.equals(contract.getContractCategory(),"ymjgypmm")||StrUtil.equals(contract.getContractCategory(),"ymjgkcpmm")
            ||StrUtil.equals(contract.getContractCategory(),"ymjcg")||StrUtil.equals(contract.getContractCategory(),"tfgsgypmm")
            ||StrUtil.equals(contract.getContractCategory(),"smjgypmm")||StrUtil.equals(contract.getContractCategory(),"jxcxsht"))
      ){
         contract.setContractName(contract.getContractName()+contract.getContractNo());
      }
      baseMapper.insert(contract);

@@ -91,7 +186,7 @@
         addDTO.getContractSubjectMatter().stream().forEach(contractSubjectMatterAddDTO -> {
            ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatterAddDTO, ContractSubjectMatter.class);
            subjectMatter.setContractId(contract.getId());
            subjectMatter.setContractName(contract.getContractName());
            subjectMatter.setLineNo(ItemGeneratorUtil.nextId());
            subjectMatter.setDeliveredQuantity(new BigDecimal("0"));
            subjectMatter.setDeliveryStatus(0);
            subjectMatter.setTotalAmount(contractSubjectMatterAddDTO.getQuantity().multiply(contractSubjectMatterAddDTO.getUnitPrice()));
@@ -151,6 +246,10 @@
               contract.setAcceptScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("质保金")) {
               contract.setWarrantyScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         });

      }
@@ -165,16 +264,61 @@
      if (!StrUtil.equals(entity.getContractStatus() + "", "0")) {
         return R.failed("当前状态无法修改合同");
      }
      if (StrUtil.isEmpty(updateDTO.getPartyA())){
         BusinessCustomer bc = businessCustomerMapper.selectById(updateDTO.getPartyAId());
         if (ObjUtil.isNotNull(bc)){
            updateDTO.setPartyA(bc.getRegisterName());
         }
         if (StrUtil.isEmpty(bc.getErpCompanyCode())||StrUtil.isEmpty(bc.getRegisterName())||
               StrUtil.isEmpty(bc.getBankName())||StrUtil.isEmpty(bc.getBankAccount())){
            return R.failed("请完善改客户数据后再添加合同");
         }
      }

      Contract contract = BeanUtil.copyProperties(updateDTO, Contract.class);
      contract.setContractNo(ContractNumberGenerator.generateContractNumber());
      contract.setBillingStatus("0");
      contract.setBillingStatus("1");
      contract.setErpPushFlag("0");
      contract.setPaidAmount(new BigDecimal("0"));
      List<Contract> contracts;
      contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));
      while (ArrayUtil.isNotEmpty(contracts.toArray())) {
         contract.setContractNo(ContractNumberGenerator.generateContractNumber());
         contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));
      contract.setBillingAmout(new BigDecimal("0"));
      contract.setNickName(SecurityUtils.getUser().getNickname());
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",smj)){
         contract.setContractNo(generateSMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",sgb)){
         contract.setContractNo(generateGYBContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",ymj)){
         contract.setContractNo(generateYMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",tfgs)){
         contract.setContractNo(generateTFContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",jxc)){
         contract.setContractNo(generateJXCContractNo());
      }
      if (ObjUtil.isNotNull(updateDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(updateDTO.getSignDate(),updateDTO.getDeliveryCycle()));
      }
      if (StrUtil.equals(updateDTO.getContractCategory(), "water_house")){
         if(!updateDTO.getContractSubjectMatter().stream().allMatch(item->StrUtil.equals(item.getMaterialCode(), "water_bill")||
               StrUtil.equals(item.getMaterialCode(), "house_rental")||StrUtil.equals(item.getMaterialCode(), "electricity_bill"))){
            return R.failed("请新增水/电代缴房屋租赁合同！");
         }
      }else {
         if(updateDTO.getContractSubjectMatter().stream().anyMatch(item->StrUtil.equals(item.getMaterialCode(), " ")||
               StrUtil.equals(item.getMaterialCode(), "house_rental")||StrUtil.equals(item.getMaterialCode(), "electricity_bill"))){
            return R.failed("水电代缴、房屋租赁产品只能在水/电代缴房屋租赁合同！");
         }
         // 假设 list 是你的 List<ContractSubjectMatterAddDTO>
         // 假设 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);

@@ -184,9 +328,10 @@
         updateDTO.getContractSubjectMatter().stream().forEach(contractSubjectMatterAddDTO -> {
            ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatterAddDTO, ContractSubjectMatter.class);
            subjectMatter.setContractId(contract.getId());
            subjectMatter.setContractName(contract.getContractName());
            subjectMatter.setLineNo(ItemGeneratorUtil.nextId());
            subjectMatter.setDeliveredQuantity(new BigDecimal("0"));
            subjectMatter.setDeliveryStatus(0);
            subjectMatter.setTotalAmount(contractSubjectMatterAddDTO.getQuantity().multiply(contractSubjectMatterAddDTO.getUnitPrice()));
            contractSubjectMatterMapper.insert(subjectMatter);
            //水电类必须有初次表号
            if (StrUtil.isNotEmpty(contractSubjectMatterAddDTO.getMeterReadCode()) &&
@@ -227,6 +372,10 @@
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("调试完成或验收")) {
               contract.setAcceptScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("质保金")) {
               contract.setWarrantyScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         });
@@ -272,10 +421,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));

      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 +623,133 @@
//         contractPaymentScheduleMapper.updateById(fitstSchedule);
//      }
      }
      //erp推送
      new Thread(()->{
         try {
            Thread.sleep(500);
            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","");
               if (ArrayUtil.isNotEmpty(subjectMatterList.toArray())){
                  JSONArray subjectMatter = new JSONArray();
                  subjectMatterList.stream().forEach(contractSubjectMatter -> {
                     JSONObject subjectMatterItem = new JSONObject();
                     subjectMatterItem.put("itemNo",contractSubjectMatter.getMaterialCode());
                     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);
               }

               JSONObject loginJson = new JSONObject();
               loginJson.put("username","admin");
               loginJson.put("password","admin123");
               log.info("一煤机合同推送获取token入参：{}",loginJson.toJSONString());
               String loginResp = HttpUtil.post(ymjErp+"/api/account/v1/login",loginJson.toJSONString());
               log.info("一煤机合同推送获取token回参：{}",loginResp);
               JSONObject respJson = JSONObject.parseObject(loginResp);
               if (respJson.getInteger("code")==0){
                  JSONObject dataJson = JSONObject.parseObject(respJson.getString("data"));
                  log.info("一煤机合同推送erp入参：{}",request.toJSONString());
                  HttpResponse response = HttpRequest.post(ymjErp+"/api/contract-staging/v1/receive")
                        .header("token", dataJson.getString("token"))       // 添加认证头
                        .header("Content-Type", "application/json")         // 设置内容类型
                        .body(request.toJSONString())                        // 设置请求体
                        .execute();                                         // 执行请求.post(ymjErp,request.toJSONString());
                  log.info("一煤机合同推送erp回参：{}",response.body());
                  //保存请求记录
                  saveErpRequestRecord("ymj",request.toJSONString(),response.body());
                  //更新合同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(smjErp,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(jxcErp,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)){
               //石工泵主动推送系统
            }
         } catch (Exception e) {
            e.printStackTrace();
         }
      }).start();
      //合同中心推送
      new Thread(()->{
         try {
            JSONObject request = new JSONObject();
            request.put("fd_docNumber",contract.getContractNo());
            request.put("fd_singer",contract.getNickName());
            request.put("fd_signTime",DateUtil.formatDate(contract.getSignDate()));
            request.put("fd_linkPerson","");
            request.put("fd_linkPhone","");
            request.put("fd_address",contract.getSignPlace());
            request.put("fd_receivedTime",DateUtil.format(contract.getCreateTime(),DatePattern.NORM_DATETIME_PATTERN));
            request.put("fd_receivedNum",1);
            request.put("fd_effedate",DateUtil.formatDate(contract.getEffectiveDate()));
            request.put("fd_enddate",DateUtil.formatDate(contract.getExpirationDate()));
            request.put("fd_reviewerNo",contract.getNickName());
            request.put("fd_docStatus","20");
            request.put("fd_templateId","");
            request.put("fd_attName",contract.getAttachmentName());
            request.put("fd_attcontent",contract.getAttachmentName());
            log.info("合同中心同步合同接口入参：{}",request.toJSONString());
            String resp = HttpUtil.post("https://oatest.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addContractReview",request.toJSONString());
            log.info("合同中心同步合同接口回参：{}",resp);
         } catch (Exception e) {
            e.printStackTrace();
         }
      }).start();
   }

   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) {
@@ -510,7 +786,7 @@
            PaymentConfirm contractLastConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, completeContract.getId())
                  .orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
            //查询客户付款完成合同中最后明细金额 有预收转入当前合同
            if (contractLastConfirm.getTotalAmount().compareTo(new BigDecimal("0")) > 0) {
            if (ObjUtil.isNotNull(contractLastConfirm)&&contractLastConfirm.getTotalAmount().compareTo(new BigDecimal("0")) > 0) {
               //新增完成付款合同 资金转出
               PaymentConfirm outConfirm = BeanUtil.copyProperties(contractLastConfirm, PaymentConfirm.class, "id", "transationAmount",
                     "advanceAmount", "receivableAmount", "overdueAmount", "totalAmount");
@@ -561,54 +837,58 @@
      if (ArrayUtil.isNotEmpty(scheduleList.toArray())) {
         scheduleList.stream().forEach(contractPaymentSchedule -> {
            Contract contract = baseMapper.selectById(contractPaymentSchedule.getContractId());
            //应收超期
            PaymentConfirm overdueConfirm = new PaymentConfirm();
            overdueConfirm.setBusinessType("应收超期");
            overdueConfirm.setBusGuestId(contract.getPartyAId());
            overdueConfirm.setBusGuestName(contract.getPartyA());
            overdueConfirm.setContractId(contract.getId());
            overdueConfirm.setContractName(contract.getContractName());
            overdueConfirm.setContractNo(contract.getContractNo());
            overdueConfirm.setConfirmTime(new Date());
            overdueConfirm.setScheduleId(contractPaymentSchedule.getId());
            overdueConfirm.setScheduleName(contractPaymentSchedule.getStageName());
            PaymentConfirm newLastConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
                  .orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
            overdueConfirm.setTransationAmount(StrUtil.equals(contractPaymentSchedule.getPaymentStatus() + "", "0") ?
                  contractPaymentSchedule.getPlannedAmount() :
                  contractPaymentSchedule.getPlannedAmount().subtract(contractPaymentSchedule.getActualAmount()));
            overdueConfirm.setReceivableAmount(newLastConfirm.getTotalAmount().multiply(new BigDecimal("-1")));
            overdueConfirm.setOverdueAmount(overdueConfirm.getTransationAmount());
            overdueConfirm.setTotalAmount(newLastConfirm.getTotalAmount());
            overdueConfirm.setCompId(contract.getCompId());
            //判断当前阶段是否已生成上阶段应收超期
            PaymentConfirm oiverdueConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getScheduleId, contractPaymentSchedule.getId())
                  .eq(PaymentConfirm::getBusinessType, "应收超期"));
            if (ObjUtil.isNull(oiverdueConfirm) && overdueConfirm.getTransationAmount().compareTo(new BigDecimal("0")) > 0) {
               paymentConfirmMapper.insert(overdueConfirm);
            }
            //当前逾期
            CurrentOverdue currentOverdue = new CurrentOverdue();
            currentOverdue.setBusGuestId(contract.getPartyAId());
            currentOverdue.setBusGuestName(contract.getPartyA());
            currentOverdue.setContractId(contractPaymentSchedule.getContractId());
            currentOverdue.setContractName(contractPaymentSchedule.getContractName());
            currentOverdue.setScheduleId(contractPaymentSchedule.getId());
            currentOverdue.setScheduleName(contractPaymentSchedule.getStageName());
            currentOverdue.setCompId(contract.getCompId());
            currentOverdue.setContractExpirTime(contractPaymentSchedule.getEffectiveEndDate());
            currentOverdue.setReceivableAmount(StrUtil.equals(contractPaymentSchedule.getPaymentStatus() + "", "0") ?
                  contractPaymentSchedule.getPlannedAmount() : contractPaymentSchedule.getPlannedAmount().subtract(contractPaymentSchedule.getActualAmount()));
            currentOverdue.setOverdueDuration(BigDecimal.valueOf(DateUtil.betweenDay(contractPaymentSchedule.getEffectiveEndDate(), new Date(), true)));
            CurrentOverdue overdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getContractId, currentOverdue.getContractId())
                  .eq(CurrentOverdue::getScheduleId, currentOverdue.getScheduleId()).last("limit 1"));
            if (ObjUtil.isNull(overdue)) {
               if (currentOverdue.getReceivableAmount().compareTo(new BigDecimal("0")) > 0) {
                  currentOverdueMapper.insert(currentOverdue);
            if (ObjUtil.isNotNull(contract)) {
               //应收超期
               PaymentConfirm overdueConfirm = new PaymentConfirm();
               overdueConfirm.setBusinessType("应收超期");
               overdueConfirm.setBusGuestId(contract.getPartyAId());
               overdueConfirm.setBusGuestName(contract.getPartyA());
               overdueConfirm.setContractId(contract.getId());
               overdueConfirm.setContractName(contract.getContractName());
               overdueConfirm.setContractNo(contract.getContractNo());
               overdueConfirm.setConfirmTime(new Date());
               overdueConfirm.setScheduleId(contractPaymentSchedule.getId());
               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()));
                  overdueConfirm.setReceivableAmount(newLastConfirm.getTotalAmount().multiply(new BigDecimal("-1")));
                  overdueConfirm.setOverdueAmount(overdueConfirm.getTransationAmount());
                  overdueConfirm.setTotalAmount(newLastConfirm.getTotalAmount());
                  overdueConfirm.setCompId(contract.getCompId());
                  //判断当前阶段是否已生成上阶段应收超期
                  PaymentConfirm oiverdueConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getScheduleId, contractPaymentSchedule.getId())
                        .eq(PaymentConfirm::getBusinessType, "应收超期"));
                  if (ObjUtil.isNull(oiverdueConfirm) && overdueConfirm.getTransationAmount().compareTo(new BigDecimal("0")) > 0) {
                     paymentConfirmMapper.insert(overdueConfirm);
                  }
                  //当前逾期
                  CurrentOverdue currentOverdue = new CurrentOverdue();
                  currentOverdue.setBusGuestId(contract.getPartyAId());
                  currentOverdue.setBusGuestName(contract.getPartyA());
                  currentOverdue.setContractId(contractPaymentSchedule.getContractId());
                  currentOverdue.setContractName(contractPaymentSchedule.getContractName());
                  currentOverdue.setScheduleId(contractPaymentSchedule.getId());
                  currentOverdue.setScheduleName(contractPaymentSchedule.getStageName());
                  currentOverdue.setCompId(contract.getCompId());
                  currentOverdue.setContractExpirTime(contractPaymentSchedule.getEffectiveEndDate());
                  currentOverdue.setReceivableAmount(StrUtil.equals(contractPaymentSchedule.getPaymentStatus() + "", "0") ?
                        contractPaymentSchedule.getPlannedAmount() : contractPaymentSchedule.getPlannedAmount().subtract(contractPaymentSchedule.getActualAmount()));
                  currentOverdue.setOverdueDuration(BigDecimal.valueOf(DateUtil.betweenDay(contractPaymentSchedule.getEffectiveEndDate(), new Date(), true)));
                  CurrentOverdue overdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getContractId, currentOverdue.getContractId())
                        .eq(CurrentOverdue::getScheduleId, currentOverdue.getScheduleId()).last("limit 1"));
                  if (ObjUtil.isNull(overdue)) {
                     if (currentOverdue.getReceivableAmount().compareTo(new BigDecimal("0")) > 0) {
                        currentOverdueMapper.insert(currentOverdue);
                     }
                  } else {
                     overdue.setOverdueDuration(BigDecimal.valueOf(DateUtil.betweenDay(contractPaymentSchedule.getEffectiveEndDate(), new Date(), true)));
                     currentOverdueMapper.updateById(overdue);
                  }
               }
            } else {
               overdue.setOverdueDuration(BigDecimal.valueOf(DateUtil.betweenDay(contractPaymentSchedule.getEffectiveEndDate(), new Date(), true)));
               currentOverdueMapper.updateById(overdue);
            }
         });
      }
@@ -627,16 +907,25 @@
   public R copyNewContract(Long id) {
      Contract oldContract = baseMapper.selectById(id);
      Contract newContract = BeanUtil.copyProperties(oldContract, Contract.class, "id", "createTime");
      newContract.setContractNo(ContractNumberGenerator.generateContractNumber());
      newContract.setPaidAmount(new BigDecimal("0"));
      newContract.setBillingStatus("0");
      newContract.setBillingStatus("1");
      newContract.setErpPushFlag("0");
      newContract.setContractStatus(0);
      List<Contract> contracts;
      contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, newContract.getContractNo()));
      while (ArrayUtil.isNotEmpty(contracts.toArray())) {
         newContract.setContractNo(ContractNumberGenerator.generateContractNumber());
         contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, newContract.getContractNo()));
      newContract.setBillingAmout(new BigDecimal("0"));
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",smj)){
         newContract.setContractNo(generateSMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",sgb)){
         newContract.setContractNo(generateGYBContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",ymj)){
         newContract.setContractNo(generateYMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",tfgs)){
         newContract.setContractNo(generateTFContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",jxc)){
         newContract.setContractNo(generateJXCContractNo());
      }
      baseMapper.insert(newContract);
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId, id));
@@ -697,7 +986,7 @@
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getRegisterName());
      map.put("companyName", contract.getPartyA());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
@@ -761,6 +1050,7 @@
            if (StrUtil.isNotEmpty(subjectMatter.getMeterReadCode()) &&
                  ObjUtil.isNotNull(subjectMatter.getMeterReadNum())) {
               MeterReadRecord record = BeanUtil.copyProperties(subjectMatter, MeterReadRecord.class, "id","meterReadNum");
               record.setContractName(contract.getContractName());
               record.setMatterId(subjectMatter.getId());
               record.setBusGuestId(contract.getPartyAId());
               record.setBusGuestName(contract.getPartyA());
@@ -784,6 +1074,10 @@
               schedule.setPaymentStatus(0);
               schedule.setActualAmount(new BigDecimal("0"));
               schedule.setCompId(contract.getCompId());
               schedule.setSubjectMatterCode(subjectMatter.getMaterialCode());
               schedule.setSubjectMatterName(subjectMatter.getMaterialInternalName());
               schedule.setRemark(DateUtil.formatDate(contractExecDate.getExecDate())+schedule.getStageName());
               schedule.setInvoiceFlag("0");
               contractPaymentScheduleMapper.insert(schedule);
               //房屋租赁生成应收
               PaymentConfirm confirm = new PaymentConfirm();
@@ -1150,6 +1444,7 @@
      map.put("partyA",contract.getPartyA());
      map.put("partyB",contract.getPartyB());
      map.put("delayDay",dto.getDelayDay());
      map.put("contractNo",contract.getContractNo());
      map.put("applyName",SecurityUtils.getUser().getUsername());
      map.put("applyTime",DateUtil.format(delayOut.getApplyTime(),DatePattern.NORM_DATETIME_FORMAT));
      //启动流程
@@ -1169,10 +1464,697 @@
      return baseMapper.pageScope(page,queryDTO, DataScope.of("comp_id"));
   }

   public static void main(String[] args) {
      System.out.println(DateUtil.beginOfQuarter(DateUtil.parseDate("2026-06-05")));
      System.out.println(DateUtil.endOfQuarter(DateUtil.parseDate("2026-09-30")));
      System.out.println(DateUtil.betweenMonth(DateUtil.beginOfQuarter(DateUtil.parseDate("2026-06-05")),
            DateUtil.endOfQuarter(DateUtil.parseDate("2026-09-30")),true));
   @Override
   public void exportContractTFGSGYPMMWord(Long id, HttpServletResponse response) {
      Contract contract = baseMapper.selectById(id);
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
            .eq(ContractSubjectMatter::getContractId, id).orderByAsc(ContractSubjectMatter::getCreateTime));
      Map<String, Object> map = new HashMap<>();
      //合同基本信息
      map.put("partyA", contract.getPartyA());
      map.put("partyB", contract.getPartyB());
      map.put("contractNo", contract.getContractNo());
      map.put("signPlace", contract.getSignPlace());
      map.put("signDate", DateUtil.formatDate(contract.getSignDate()));
      map.put("signDateYMD", DateUtil.format(contract.getSignDate(), DatePattern.CHINESE_DATE_PATTERN));
      map.put("total", contract.getAmount());
      map.put("amountWords", Convert.digitToChinese(contract.getAmount()));
      //标的物
      List<Map<String, Object>> items = new ArrayList<>();
      List<RowRenderData> dataList = new ArrayList<>();
      AtomicReference<Integer> no = new AtomicReference<>(0);
      subjectMatterList.stream().forEach(contractSubjectMatter -> {
         Map<String, Object> item = new HashMap<>();
         item.put("materialName", contractSubjectMatter.getMaterialName());
         item.put("guige", contractSubjectMatter.getSpecification());
         item.put("unit", contractSubjectMatter.getUnit());
         item.put("quantity", contractSubjectMatter.getQuantity());
         item.put("unitPrice", contractSubjectMatter.getUnitPrice());
         item.put("price", contractSubjectMatter.getTotalAmount());

         items.add(item);
         no.updateAndGet(v -> v + 1);
      });
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getRegisterName());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
      map.put("bankAccount", customer.getBankAccount());

      //承揽方
      R<SysDept> r = remoteDeptService.getById(contract.getPartyBId());
      SysDept dept = r.getData();
      map.put("orgName", dept.getOrgName());
      map.put("legalPerson1", StrUtil.isNotEmpty(dept.getLegalPerson()) ? dept.getLegalPerson() : "");
      map.put("entrustedAgent", StrUtil.isNotEmpty(dept.getLegalPerson()) ? "" : dept.getEntrustedAgent());
      map.put("orgContact", dept.getOrgContact());
      map.put("orgBank", dept.getOrgBank());
      map.put("orgBankAccount", dept.getOrgBankAccount());

      //生成文件名
      Long time = new Date().getTime();
      // 生成的word格式
      String formatSuffix = ".docx";
      // 拼接后的文件名
      String fileName = time + formatSuffix;//文件名  带后缀
      //导出word
      try {
         // 1. 加载模版
         // 假设模版在 resources/templates/template.docx
         ClassPathResource resource = new ClassPathResource("template/tfgs/tfgsgypmmht.docx");
         // 配置列表策略
         Configure config = Configure.builder()
               .bind("items", new LoopRowTableRenderPolicy()) // 将 items 绑定到行循环策略
               .build();
         // 2. 编译并渲染数据
         XWPFTemplate xwpfTemplate = XWPFTemplate.compile(resource.getInputStream(), config).render(map);

         // 3. 设置响应头
         response.setContentType("application/vnd.openxmlformats-officedocument.wordprocessingml.document");
         response.setCharacterEncoding("utf-8");
         response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName + ".docx");

         // 4. 写入输出流
         OutputStream out = response.getOutputStream();
         xwpfTemplate.write(out);
         out.flush();
         out.close();
         xwpfTemplate.close(); // 重要：关闭模版释放资源
      } catch (IOException e) {
         e.printStackTrace();
      }
   }

   @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.setErpContractNo(contract.getContractNo());
      contract.setPartyBId(SecurityUtils.getUser().getCompId());
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      contract.setContractStatus(2);
      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingStatus("1");
      contract.setErpPushFlag("1");
      contract.setBillingAmout(new BigDecimal("0"));

      BusinessCustomer bc = businessCustomerMapper.selectOne(Wrappers.<BusinessCustomer>lambdaQuery().eq(BusinessCustomer::getErpCompanyCode,
            addDTO.getPartyACode()).last("limit 1"));
      if (ObjUtil.isNull(bc)){
         return R.failed("erp客户编码不存在");
      }
      contract.setPartyAId(bc.getId());
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(),addDTO.getDeliveryCycle()));
      }

      contract.setContractNo(generateGYBContractNo());

      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.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.getContractNo());
   }

   @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 contractOld = baseMapper.selectOne(Wrappers.<Contract>lambdaQuery().eq(Contract::getDataId,updateDTO.getDataId()).last("limit 1"));
      if (ObjUtil.isNull(contractOld)){
         return R.failed("合同数据ID：{}不存在，请先新增后再修改",updateDTO.getDataId());
      }
      Contract contract = BeanUtil.copyProperties(updateDTO, Contract.class);
      contract.setId(contractOld.getId());
      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.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);
   }

   /**
    * 生成格式为: yyyyMMdd + 4位序列号 (例如: 20260629000001)
    */
   public  String generateSMJContractNo() {
      // 1. 获取当前日期字符串
      String dateStr = DateUtil.format(new Date(), "yyyyMMdd");

      // 2. 构建 Redis Key，按天隔离，例如: order:no:20260629
      String key = "ZB-SMJ:" + dateStr;

      // 3. Redis 原子递增，设置过期时间为2天（防止Key堆积，同时覆盖跨天边界情况）
      Long sequence = redisTemplate.opsForValue().increment(key, 1);
      redisTemplate.expire(key, 1, java.util.concurrent.TimeUnit.DAYS);

      // 4. 格式化序列号，不足6位前补0
      String seqStr = String.format("%04d", sequence);

      // 5. 拼接返回
      return "ZB-SMJ-"+dateStr + seqStr;
   }

   public  String generateYMJContractNo() {
      // 1. 获取当前日期字符串
      String dateStr = DateUtil.format(new Date(), "yyyyMMdd");

      // 2. 构建 Redis Key，按天隔离，例如: order:no:20260629
      String key = "ZB-YMJ:" + dateStr;

      // 3. Redis 原子递增，设置过期时间为2天（防止Key堆积，同时覆盖跨天边界情况）
      Long sequence = redisTemplate.opsForValue().increment(key, 1);
      redisTemplate.expire(key, 1, java.util.concurrent.TimeUnit.DAYS);

      // 4. 格式化序列号，不足6位前补0
      String seqStr = String.format("%04d", sequence);

      // 5. 拼接返回
      return "ZB-YMJ-"+dateStr + seqStr;
   }

   public  String generateJXCContractNo() {
      // 1. 获取当前日期字符串
      String dateStr = DateUtil.format(new Date(), "yyyyMMdd");

      // 2. 构建 Redis Key，按天隔离，例如: order:no:20260629
      String key = "ZB-JXC:" + dateStr;

      // 3. Redis 原子递增，设置过期时间为2天（防止Key堆积，同时覆盖跨天边界情况）
      Long sequence = redisTemplate.opsForValue().increment(key, 1);
      redisTemplate.expire(key, 1, java.util.concurrent.TimeUnit.DAYS);

      // 4. 格式化序列号，不足6位前补0
      String seqStr = String.format("%04d", sequence);

      // 5. 拼接返回
      return "ZB-JXC-"+dateStr + seqStr;
   }

   public  String generateTFContractNo() {
      // 1. 获取当前日期字符串
      String dateStr = DateUtil.format(new Date(), "yyyyMMdd");

      // 2. 构建 Redis Key，按天隔离，例如: order:no:20260629
      String key = "ZB-TF:" + dateStr;

      // 3. Redis 原子递增，设置过期时间为2天（防止Key堆积，同时覆盖跨天边界情况）
      Long sequence = redisTemplate.opsForValue().increment(key, 1);
      redisTemplate.expire(key, 1, java.util.concurrent.TimeUnit.DAYS);

      // 4. 格式化序列号，不足6位前补0
      String seqStr = String.format("%04d", sequence);

      // 5. 拼接返回
      return "ZB-TF-"+dateStr + seqStr;
   }

   public  String generateGYBContractNo() {
      // 1. 获取当前日期字符串
      String dateStr = DateUtil.format(new Date(), "yyyyMMdd");

      // 2. 构建 Redis Key，按天隔离，例如: order:no:20260629
      String key = "ZB-GYB:" + dateStr;

      // 3. Redis 原子递增，设置过期时间为2天（防止Key堆积，同时覆盖跨天边界情况）
      Long sequence = redisTemplate.opsForValue().increment(key, 1);
      redisTemplate.expire(key, 1, java.util.concurrent.TimeUnit.DAYS);

      // 4. 格式化序列号，不足6位前补0
      String seqStr = String.format("%04d", sequence);

      // 5. 拼接返回
      return "ZB-GYB-"+dateStr + seqStr;
   }

   @Override
   public R abortContractSgb(String dataId) {
      Contract contractOld = baseMapper.selectOne(Wrappers.<Contract>lambdaQuery().eq(Contract::getDataId,dataId).last("limit 1"));
      if (ObjUtil.isNull(contractOld)){
         return R.failed("合同数据ID：{}不存在，请先新增后再操作",dataId);
      }
      contractOld.setContractStatus(4);
      baseMapper.updateById(contractOld);
      return R.ok();
   }

   @Override
   public R delContractSgb(String dataId) {
      Contract contractOld = baseMapper.selectOne(Wrappers.<Contract>lambdaQuery().eq(Contract::getDataId,dataId).last("limit 1"));
      if (ObjUtil.isNull(contractOld)){
         return R.failed("合同数据ID：{}不存在，请先新增后再操作",dataId);
      }

      contractPaymentScheduleMapper.delete(Wrappers.<ContractPaymentSchedule>lambdaQuery().eq(ContractPaymentSchedule::getContractId,contractOld.getId()));
      contractSubjectMatterMapper.delete(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId,contractOld.getId()));
      paymentConfirmMapper.delete(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId,contractOld.getId()));
      baseMapper.deleteById(contractOld);
      return R.ok();
   }

   @Override
   public Page fourAssociation(Page page,ContractQueryDTO queryDTO) {
      Page<FourAssociationPageVo> page1 = baseMapper.fourAssociation(page,queryDTO,DataScope.of("comp_id"));
      if (ArrayUtil.isNotEmpty(page1.getRecords().toArray())){
         page1.getRecords().stream().forEach(fourAssociationPageVo -> {
            List<PaymentSlip> slips = paymentSlipMapper.selectList(Wrappers.<PaymentSlip>lambdaQuery().eq(PaymentSlip::getContractId,fourAssociationPageVo.getId())
                  .orderByAsc(PaymentSlip::getPaymentTime));
            if (ArrayUtil.isNotEmpty(slips.toArray())){
               fourAssociationPageVo.setSlipVoList(BeanUtil.copyToList(slips,ContractSlipVo.class));
            }
            List<ContractInvoice> invoices = contractInvoiceMapper.selectList(Wrappers.<ContractInvoice>lambdaQuery().eq(ContractInvoice::getContractId,fourAssociationPageVo.getId())
                  .orderByAsc(ContractInvoice::getInvoiceTime));
            if (ArrayUtil.isNotEmpty(invoices.toArray())){
               fourAssociationPageVo.setInvoiceVoList(BeanUtil.copyToList(invoices, ContractInvoiceVo.class));
            }
            if (fourAssociationPageVo.getAmount().compareTo(fourAssociationPageVo.getPaidAmount())==0&&
                  fourAssociationPageVo.getAmount().compareTo(fourAssociationPageVo.getBillingAmout())==0){
               fourAssociationPageVo.setAssociation("已完成");
            }
         });
      }
      return page1;
   }

   @Override
   public void exportContractSMJGYPMMWord(Long id, HttpServletResponse response) {
      Contract contract = baseMapper.selectById(id);
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
            .eq(ContractSubjectMatter::getContractId, id).orderByAsc(ContractSubjectMatter::getCreateTime));
      Map<String, Object> map = new HashMap<>();
      //合同基本信息
      map.put("partyA", contract.getPartyA());
      map.put("partyB", contract.getPartyB());
      map.put("contractNo", contract.getContractNo());
      map.put("signPlace", contract.getSignPlace());
      map.put("signDate", DateUtil.formatDate(contract.getSignDate()));
      map.put("signDateYMD", DateUtil.format(contract.getSignDate(), DatePattern.CHINESE_DATE_PATTERN));
      map.put("total", contract.getAmount());
      map.put("totalNoTax", contract.getAmount().divide(new BigDecimal("100").add(new BigDecimal("13")), 2, RoundingMode.HALF_UP)
            .multiply(new BigDecimal("87")));
      map.put("amountWords", Convert.digitToChinese(contract.getAmount()));
      //标的物
      List<Map<String, Object>> items = new ArrayList<>();
      subjectMatterList.stream().forEach(contractSubjectMatter -> {
         Map<String, Object> item = new HashMap<>();
         item.put("materialName", contractSubjectMatter.getMaterialName());
         item.put("guige", contractSubjectMatter.getSpecification());
         item.put("unit", contractSubjectMatter.getUnit());
         item.put("quantity", contractSubjectMatter.getQuantity());
         item.put("unitPrice", contractSubjectMatter.getUnitPrice());
         item.put("price", contractSubjectMatter.getTotalAmount());
         item.put("remarks", contractSubjectMatter.getRemarks());
         items.add(item);
      });
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getRegisterName());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
      map.put("bankAccount", customer.getBankAccount());

      //承揽方
      R<SysDept> r = remoteDeptService.getById(contract.getPartyBId());
      SysDept dept = r.getData();
      map.put("orgName", dept.getOrgName());
      map.put("legalPerson1", StrUtil.isNotEmpty(dept.getLegalPerson()) ? dept.getLegalPerson() : "");
      map.put("entrustedAgent", StrUtil.isNotEmpty(dept.getLegalPerson()) ? "" : dept.getEntrustedAgent());
      map.put("orgContact", dept.getOrgContact());
      map.put("orgBank", dept.getOrgBank());
      map.put("orgBankAccount", dept.getOrgBankAccount());

      //生成文件名
      Long time = new Date().getTime();
      // 生成的word格式
      String formatSuffix = ".docx";
      // 拼接后的文件名
      String fileName = time + formatSuffix;//文件名  带后缀
      //导出word
      try {
         // 1. 加载模版
         // 假设模版在 resources/templates/template.docx
         ClassPathResource resource = new ClassPathResource("template/smj/smjgypmmht.docx");
         // 配置列表策略
         Configure config = Configure.builder()
               .bind("items", new LoopRowTableRenderPolicy()) // 将 items 绑定到行循环策略
               .build();
         // 2. 编译并渲染数据
         XWPFTemplate xwpfTemplate = XWPFTemplate.compile(resource.getInputStream(), config).render(map);

         // 3. 设置响应头
         response.setContentType("application/vnd.openxmlformats-officedocument.wordprocessingml.document");
         response.setCharacterEncoding("utf-8");
         response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName + ".docx");

         // 4. 写入输出流
         OutputStream out = response.getOutputStream();
         xwpfTemplate.write(out);
         out.flush();
         out.close();
         xwpfTemplate.close(); // 重要：关闭模版释放资源
      } catch (IOException e) {
         e.printStackTrace();
      }
   }

   @Override
   public void exportContractJXCXSWord(Long id, HttpServletResponse response) {
      Contract contract = baseMapper.selectById(id);
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
            .eq(ContractSubjectMatter::getContractId, id).orderByAsc(ContractSubjectMatter::getCreateTime));
      List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
            .eq(ContractPaymentSchedule::getContractId, id).orderByAsc(ContractPaymentSchedule::getCreateTime));
      Map<String, Object> map = new HashMap<>();
      //合同基本信息
      map.put("partyA", contract.getPartyA());
      map.put("partyB", contract.getPartyB());
      map.put("contractNo", contract.getContractNo());
      map.put("signPlace", contract.getSignPlace());
      map.put("signDate", DateUtil.formatDate(contract.getSignDate()));
      map.put("signDateYMD", DateUtil.format(contract.getSignDate(), DatePattern.CHINESE_DATE_PATTERN));
      map.put("total", contract.getAmount());
      map.put("amountWords", Convert.digitToChinese(contract.getAmount()));
      //正文
      map.put("standard", contract.getStandard());
      map.put("useMonth", contract.getUseMonth());
      map.put("afterShipMonth", contract.getAfterShipMonth());
      map.put("deliveryCycle", contract.getDeliveryCycle());
      map.put("advancePayment", contract.getAdvancePayment()+"%");
      map.put("inspectDay", contract.getInspectDay());
      map.put("acceptDay", contract.getAcceptDay());
      map.put("delayAcceptDay", contract.getDelayAcceptDay());
      map.put("acceptPassDay", contract.getAcceptPassDay());
      map.put("acceptPassAmount", contract.getAcceptPassAmount()+"%");
      map.put("deliverDay", contract.getDeliverDay());
      map.put("deliverCompleteDay", contract.getDeliverCompleteDay());
      map.put("shipAddress", contract.getShipAddress());
      map.put("htqdr", scheduleList.get(0).getAgreedDays());
      map.put("htqdq", scheduleList.get(0).getPaymentRatio()+"%");
      map.put("fhqq", scheduleList.get(1).getPaymentRatio()+"%");
      map.put("dhhr", scheduleList.get(2).getAgreedDays());
      map.put("dhhq", scheduleList.get(2).getPaymentRatio()+"%");
      map.put("zbjq", scheduleList.get(4).getPaymentRatio()+"%");
      map.put("zbqm", scheduleList.get(4).getAgreedDays());
      map.put("paymentMethod", contract.getPaymentMethod());
      map.put("invoiceNotice", contract.getInvoiceNotice());
      map.put("supplierAgent", contract.getSupplierAgent());
      map.put("supplierAgentIDCard", contract.getSupplierAgentIdCard());
      map.put("buyerAgent", contract.getBuyerAgent());
      map.put("buyerAgentIDCard", contract.getBuyerAgentIdCard());
      map.put("agentAuthority", contract.getAgentAuthority());
      map.put("delayPayAdvancePayment", contract.getDelayPayAdvancePayment()+"%");
      map.put("delayPayAProcessPayment", contract.getDelayPayProcessPayment()+"%");
      map.put("receiveAdvancePaymentMonth", contract.getReceiveAdvancePaymentMonth());
      map.put("noticeSupplierAcceptDay", contract.getNoticeSupplierAcceptDay());
      map.put("overdueDay", contract.getOverdueDay());
      map.put("lossAmount", contract.getLossAmount()+"%");
      map.put("liquidatedDamagesHighSupplier", contract.getLiquidatedDamagesHighSupplier()+"%");
      map.put("overdueDayXf", contract.getOverdueDayXf());
      map.put("lossAmountXf", contract.getLossAmountXf()+"%");
      map.put("liquidatedDamagesHighBuyer", contract.getLiquidatedDamagesHighBuyer()+"%");
      map.put("contractAttchment", contract.getContractAttchment());
      map.put("totalParts", contract.getTotalParts());
      map.put("supplierPart", contract.getSupplierPart());
      map.put("buyerPart", contract.getBuyerPart());



      //标的物
      List<Map<String, Object>> items = new ArrayList<>();
      subjectMatterList.stream().forEach(contractSubjectMatter -> {
         Map<String, Object> item = new HashMap<>();
         item.put("materialName", contractSubjectMatter.getMaterialName());
         item.put("guige", contractSubjectMatter.getSpecification());
         item.put("unit", contractSubjectMatter.getUnit());
         item.put("quantity", contractSubjectMatter.getQuantity());
         item.put("unitPrice", contractSubjectMatter.getUnitPrice());
         item.put("price", contractSubjectMatter.getTotalAmount());
         item.put("remarks", contractSubjectMatter.getRemarks());
         items.add(item);
      });
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getRegisterName());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
      map.put("bankAccount", customer.getBankAccount());

      //承揽方
      R<SysDept> r = remoteDeptService.getById(contract.getPartyBId());
      SysDept dept = r.getData();
      map.put("orgName", dept.getOrgName());
      map.put("legalPerson1", StrUtil.isNotEmpty(dept.getLegalPerson()) ? dept.getLegalPerson() : "");
      map.put("entrustedAgent", StrUtil.isNotEmpty(dept.getLegalPerson()) ? "" : dept.getEntrustedAgent());
      map.put("orgContact", dept.getOrgContact());
      map.put("orgBank", dept.getOrgBank());
      map.put("orgBankAccount", dept.getOrgBankAccount());

      //生成文件名
      Long time = new Date().getTime();
      // 生成的word格式
      String formatSuffix = ".docx";
      // 拼接后的文件名
      String fileName = time + formatSuffix;//文件名  带后缀
      //导出word
      try {
         // 1. 加载模版
         // 假设模版在 resources/templates/template.docx
         ClassPathResource resource = new ClassPathResource("template/jxc/jxcxsht.docx");
         // 配置列表策略
         Configure config = Configure.builder()
               .bind("items", new LoopRowTableRenderPolicy()) // 将 items 绑定到行循环策略
               .build();
         // 2. 编译并渲染数据
         XWPFTemplate xwpfTemplate = XWPFTemplate.compile(resource.getInputStream(), config).render(map);

         // 3. 设置响应头
         response.setContentType("application/vnd.openxmlformats-officedocument.wordprocessingml.document");
         response.setCharacterEncoding("utf-8");
         response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName + ".docx");

         // 4. 写入输出流
         OutputStream out = response.getOutputStream();
         xwpfTemplate.write(out);
         out.flush();
         out.close();
         xwpfTemplate.close(); // 重要：关闭模版释放资源
      } catch (IOException e) {
         e.printStackTrace();
      }
   }
}