feat:标的物变更 合同审核流程改为推送合同中心通过后上传盖章签字件 履约进度新增合同补录按钮

shiyunteng

2026-09-17 ca019747743a76f9348fcac99385c91736a36638

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

@@ -1,35 +1,74 @@
package com.by4cloud.platformx.business.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
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.excel.EasyExcel;
import com.alibaba.excel.ExcelReader;
import com.alibaba.excel.read.metadata.ReadSheet;
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;
import com.by4cloud.platformx.business.dto.ContractAddDTO;
import com.by4cloud.platformx.business.dto.ContractUpdateDTO;
import com.by4cloud.platformx.admin.api.entity.SysDept;
import com.by4cloud.platformx.admin.api.entity.SysDictItem;
import com.by4cloud.platformx.admin.api.feign.RemoteDeptService;
import com.by4cloud.platformx.admin.api.feign.RemoteDictService;
import com.by4cloud.platformx.business.api.feign.RemoteFlowProcessService;
import com.by4cloud.platformx.business.constant.FlowNameEnum;
import com.by4cloud.platformx.business.dto.*;
import com.by4cloud.platformx.business.entity.*;
import com.by4cloud.platformx.business.mapper.*;
import com.by4cloud.platformx.business.service.ContractPaymentScheduleProcessService;
import com.by4cloud.platformx.business.service.ContractPaymentScheduleService;
import com.by4cloud.platformx.business.service.ContractService;
import com.by4cloud.platformx.business.utils.ContractNumberGenerator;
import com.by4cloud.platformx.business.vo.ContractDetailVo;
import com.by4cloud.platformx.business.utils.BatchInsertListener;
import com.by4cloud.platformx.business.utils.ItemGeneratorUtil;
import com.by4cloud.platformx.business.utils.NetworkFileToBase64;
import com.by4cloud.platformx.business.vo.*;
import com.by4cloud.platformx.common.core.util.R;
import com.by4cloud.platformx.common.data.datascope.DataScope;
import com.by4cloud.platformx.common.security.util.SecurityUtils;
import com.by4cloud.platformx.flow.task.dto.ProcessInstanceParamDto;
import com.deepoove.poi.XWPFTemplate;
import com.deepoove.poi.config.Configure;
import com.deepoove.poi.data.RowRenderData;
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 org.springframework.web.multipart.MultipartFile;

import java.io.Serializable;
import java.io.IOException;
import java.io.OutputStream;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.math.RoundingMode;
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 {
@@ -39,42 +78,186 @@
   private final ContractPaymentScheduleProcessMapper contractPaymentScheduleProcessMapper;
   private final PaymentConfirmMapper paymentConfirmMapper;
   private final CurrentOverdueMapper currentOverdueMapper;
   private final BusinessCustomerMapper businessCustomerMapper;
   private final MeterReadRecordMapper meterReadRecordMapper;
   private final ContractExecDateMapper contractExecDateMapper;
   private final RemoteFlowProcessService remoteFlowProcessService;
   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;
   private final ContractOutBoundMapper contractOutBoundMapper;
   private final RemoteDictService remoteDictService;
   private final ContractPaymentScheduleProcessService processService;
   private final ContractSubjectMatterChangeMapper changeMapper;
   private final ContractApprovalMapper contractApprovalMapper;

   @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.smjsc}")
   private String smjsc;

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

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

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

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

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

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

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

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

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

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

   @Override
   public R add(ContractAddDTO addDTO) {
      Contract contract = BeanUtil.copyProperties(addDTO,Contract.class);
      Contract contract = BeanUtil.copyProperties(addDTO, Contract.class);
      contract.setPartyBId(SecurityUtils.getUser().getCompId());
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      contract.setContractNo(ContractNumberGenerator.generateContractNumber());
      contract.setBillingStatus("0");
      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())
               && StrUtil.isEmpty(bc.getCreditCode())) {
            return R.failed("请完善客户ERP编码或组织机构代码");
         }
      }

      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingStatus("1");
      contract.setBillingAmout(new BigDecimal("0"));
      contract.setErpPushFlag("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.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 (CollUtil.isEmpty(addDTO.getContractSubjectMatter())) {
         return R.failed("标的物不能为空");
      }

      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
            StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
         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);

      if (ArrayUtil.isNotEmpty(addDTO.getContractSubjectMatter())){
      if (CollUtil.isNotEmpty(addDTO.getContractSubjectMatter())) {
         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()));
            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())){
      if (CollUtil.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.setEffectiveDate(DateUtil.offsetDay(contract.getSignDate(),contractPaymentScheduleAddDTO.getAgreedDays()));
            if (contractPaymentScheduleAddDTO.getStageName().equals("合同签订")) {
               schedule.setEffectiveEndDate(DateUtil.offsetDay(contract.getSignDate(), contractPaymentScheduleAddDTO.getAgreedDays()));
            }
            if (ObjUtil.isNotNull(schedule.getEffectiveDate())) {
               if (schedule.getEffectiveDate().before(DateUtil.date())) {
@@ -83,24 +266,31 @@
                  schedule.setFulfillmentStatus(0);
               }
            }
            schedule.setPaymentStatus(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("货到签收")){
            if (contractPaymentScheduleAddDTO.getStageName().equals("货到签收")) {
               contract.setArrivalScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("调试完成或验收")){
            if (contractPaymentScheduleAddDTO.getStageName().equals("调试完成或验收")) {
               contract.setAcceptScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("质保金")) {
               contract.setWarrantyScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         });

      }



      return R.ok();
@@ -109,38 +299,124 @@
   @Override
   public R edit(ContractUpdateDTO updateDTO) {
      Contract entity = baseMapper.selectById(updateDTO.getId());
      if (!StrUtil.equals(entity.getContractStatus()+"","0")){
      if (!StrUtil.equals(entity.getContractStatus() + "", "0")) {
         return R.failed("当前状态无法修改合同");
      }
      Contract contract = BeanUtil.copyProperties(updateDTO,Contract.class);
      contract.setContractNo(ContractNumberGenerator.generateContractNumber());
      if (StrUtil.isEmpty(updateDTO.getPartyA())) {
         BusinessCustomer bc = businessCustomerMapper.selectById(updateDTO.getPartyAId());
         if (ObjUtil.isNotNull(bc)) {
            updateDTO.setPartyA(bc.getCompanyName());
         }
         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.setBillingStatus("1");
      contract.setErpPushFlag("0");
      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingAmout(new BigDecimal("0"));
      contract.setNickName(SecurityUtils.getUser().getNickname());
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
            StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
         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);

      if (ArrayUtil.isNotEmpty(updateDTO.getContractSubjectMatter())){
         contractSubjectMatterMapper.delete(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId,contract.getId()));
      if (CollUtil.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.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()) &&
                  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()));
      if (CollUtil.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 subjectMatter = BeanUtil.copyProperties(contractPaymentScheduleAddDTO, ContractPaymentSchedule.class);
            subjectMatter.setContractId(contract.getId());
            subjectMatter.setContractName(contract.getContractName());
            subjectMatter.setPlannedAmount(contract.getAmount().multiply(subjectMatter.getPaymentRatio().divide(new BigDecimal("100"))));
            subjectMatter.setStageOrder(currentIndex);
            contractPaymentScheduleMapper.insert(subjectMatter);
            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);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("质保金")) {
               contract.setWarrantyScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         });

      }
@@ -151,160 +427,2583 @@
   @Override
   public ContractDetailVo detail(Long id) {
      Contract contract = baseMapper.selectById(id);
      ContractDetailVo detailVo = BeanUtil.copyProperties(contract,ContractDetailVo.class);
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId,id));
      ContractDetailVo detailVo = BeanUtil.copyProperties(contract, ContractDetailVo.class);
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId, id));
      detailVo.setContractSubjectMatter(subjectMatterList);
      List<ContractPaymentSchedule> paymentScheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery().eq(ContractPaymentSchedule::getContractId,contract.getId()));
      List<ContractPaymentSchedule> paymentScheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery().eq(ContractPaymentSchedule::getContractId, contract.getId()));
      detailVo.setContractPaymentSchedule(paymentScheduleList);
      BusinessCustomer a = businessCustomerMapper.selectById(contract.getPartyAId());
      if (ObjUtil.isNotNull(a)) {
         detailVo.setPartyAOrgCode(a.getCreditCode());
      }
      List<ContractOutBound> outBoundList = contractOutBoundMapper.selectList(Wrappers.<ContractOutBound>lambdaQuery()
            .eq(ContractOutBound::getContractId, id).orderByAsc(ContractOutBound::getOutBoundTime));
      if (CollUtil.isNotEmpty(outBoundList)) {
         detailVo.setContractOutBound(outBoundList);
      }
      List<ContractInvoice> invoiceList = contractInvoiceMapper.selectList(Wrappers.<ContractInvoice>lambdaQuery()
            .eq(ContractInvoice::getContractId, id).orderByAsc(ContractInvoice::getCreateTime));
      if (CollUtil.isNotEmpty(invoiceList)) {
         detailVo.setContractInvoice(invoiceList);
      }
      List<PaymentSlip> slipList = paymentSlipMapper.selectList(Wrappers.<PaymentSlip>lambdaQuery()
            .eq(PaymentSlip::getContractId, id).orderByAsc(PaymentSlip::getPaymentTime));
      if (CollUtil.isNotEmpty(slipList)) {
         detailVo.setPaymentSlip(slipList);
      }
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());

      ContractInvoiceBipVo bipVo = new ContractInvoiceBipVo();
      bipVo.setDjrq(DateUtil.today());
      R<SysDept> r = remoteDeptService.getById(contract.getPartyBId());
      if (r.isOk()) {
         bipVo.setKpzz(r.getData().getBipCode());
      }

      if (ObjUtil.isNotNull(customer)) {
         detailVo.setInvoiceType(customer.getInvoiceType());
         bipVo.setYwzz(r.getData().getBipCode());
      }
      R<SysDept> rDept = remoteDeptService.getById(SecurityUtils.getUser().getDeptId());
      if (rDept.isOk()) {
         bipVo.setBm(rDept.getData().getOrgCode());
         bipVo.setHsdy(rDept.getData().getOrgCode());
      }
      bipVo.setYwy(SecurityUtils.getUser().getNickname());
      bipVo.setPzzdr(SecurityUtils.getUser().getNickname());
      bipVo.setJylx("ZBYXGLXT");
      bipVo.setWldxlx("1");
      bipVo.setKh(customer.getCreditCode());
      bipVo.setBz("人民币");
      bipVo.setFjzs("1");
      bipVo.setSfzy("是");
      bipVo.setSfnbwl("是");
      bipVo.setSfjyjs("否");
      bipVo.setDjfx("1");
      detailVo.setBipVo(bipVo);
      return detailVo;
   }

   @Override
   public Boolean takeEffect(Long id) {
   public R startApproval(Long id) {

      Contract contract = baseMapper.selectById(id);


      //简易合同无法继续后续操作
      if (StrUtil.equals(contract.getContractCategory(), "simple")) {
         return R.failed("请补充标的物和收款阶段后再进行操作！");
      }
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery().
            eq(ContractSubjectMatter::getContractId,contract.getId()));
      //合同中心审核
      JSONObject requestApply = new JSONObject();
      requestApply.put("fd_selectionmethod", "公开招标");
      requestApply.put("fd_isrelated", "是");
      requestApply.put("fd_bizId", contract.getId());
      requestApply.put("fd_remark", contract.getRemark());
      requestApply.put("fd_MainContent", "");
      requestApply.put("fd_settlementType", "00");
      requestApply.put("fd_applyType", "外销");
      if (CollUtil.isNotEmpty(subjectMatterList)) {
         requestApply.put("fd_contractsubject ", subjectMatterList.stream().map(item -> item.getMaterialName()).collect(Collectors.joining(",")));
      }
      requestApply.put("fd_docNumber", contract.getContractNo());
//      requestApply.put("fd_templateId", "19e39bb6c1edadbdb162c434274a8a18");
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
            StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
         requestApply.put("fd_templateId", tempSMJ);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
         requestApply.put("fd_templateId", tempSGB);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", ymj)) {
         requestApply.put("fd_templateId", tempYMJ);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", tfgs)) {
         requestApply.put("fd_templateId", tempTFGS);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", jxc)) {
         requestApply.put("fd_templateId", tempJXC);
      }
      requestApply.put("fd_name", contract.getContractName());
      requestApply.put("fd_signDate", DateUtil.formatDate(contract.getSignDate()));
      requestApply.put("fd_endDate", DateUtil.formatDate(contract.getExpirationDate()));
      requestApply.put("fd_contractCreater", contract.getNickName());
      requestApply.put("fd_currency", "人民币");
      requestApply.put("fd_ContractAmount", contract.getAmount());
      requestApply.put("fd_finAmount", contract.getAmount().divide(new BigDecimal("113"), 2, RoundingMode.HALF_UP)
            .multiply(new BigDecimal("87")));
      requestApply.put("fd_docStatus", "20");
      requestApply.put("fd_taxRates", 13);
      requestApply.put("fd_customerName", contract.getPartyA());
      requestApply.put("fd_systemSource", "非煤销售系统");
      requestApply.put("fd_type", "00");
      log.info("合同中心合同起草接口入参：{}", requestApply.toJSONString());
      String respApply = HttpUtil.post("https://oa.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addSupplyContractApply", requestApply.toJSONString());
      log.info("合同中心合同起草接口回参：{}", respApply);
      JSONObject applyResp = JSONObject.parseObject(respApply);
      if (!applyResp.getString("code").equals("00")){
         return R.failed("合同中心推送审核失败，原因为:{}",applyResp.getString("msg"));
      }
      //启动流程-系统自带审批流
//      ProcessInstanceParamDto dto = new ProcessInstanceParamDto();
//      Map<String, Object> map = BeanUtil.beanToMap(contract);
//      dto.setParamMap(map);
//      dto.setFlowName(FlowNameEnum.合同审批.name());
//      R r1 = remoteFlowProcessService.startProcessInstance(dto);
//      if (r1.getCode() == 1) {
//         return R.failed("流程启动失败");
//      }

      //工业泵不用审核 直接通过
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
         contract.setContractStatus(2);
         baseMapper.updateById(contract);
         return R.ok();
      }

      contract.setContractStatus(1);
      baseMapper.updateById(contract);
      ContractPaymentSchedule fitstSchedule = contractPaymentScheduleMapper.selectOne(Wrappers.<ContractPaymentSchedule>lambdaQuery().eq(ContractPaymentSchedule::getContractId,contract.getId())
            .orderByAsc(ContractPaymentSchedule::getCreateTime).last("limit 1"));
//      PaymentConfirm entity = new PaymentConfirm();
//      entity.setContractId(contract.getId());
//      entity.setContractName(contract.getContractName());
//      entity.setContractNo(contract.getContractNo());
//      entity.setBusGuestId(contract.getPartyAId());
//      entity.setBusGuestName(contract.getPartyA());
//      entity.setBusinessType(fitstSchedule.getStageName()+"应收");
//      entity.setTransationAmount(new BigDecimal(fitstSchedule.getPlannedAmount()));
//      entity.setReceivableAmount(new BigDecimal(fitstSchedule.getPlannedAmount()));
//      entity.setTotalAmount(new BigDecimal("0").subtract(new BigDecimal(fitstSchedule.getPlannedAmount())));
//      entity.setConfirmTime(new Date());
//      paymentConfirmMapper.insert(entity);
      return R.ok();
   }

      if (fitstSchedule.getStageName().equals("合同签订")){
         //新增应收
         PaymentConfirm paymentConfirm = new PaymentConfirm();
         paymentConfirm.setBusinessType("合同签订应收");
         paymentConfirm.setBusGuestId(contract.getPartyAId());
         paymentConfirm.setBusGuestName(contract.getPartyA());
         paymentConfirm.setContractId(contract.getId());
         paymentConfirm.setContractName(contract.getContractName());
         paymentConfirm.setContractNo(contract.getContractNo());
         paymentConfirm.setScheduleId(fitstSchedule.getId());
         paymentConfirm.setScheduleName(fitstSchedule.getStageName());
         paymentConfirm.setConfirmTime(new Date());
         paymentConfirm.setTransationAmount(fitstSchedule.getPlannedAmount());
         paymentConfirm.setReceivableAmount(fitstSchedule.getPlannedAmount());
         paymentConfirm.setTotalAmount(fitstSchedule.getPlannedAmount().multiply(new BigDecimal("-1")));
         paymentConfirmMapper.insert(paymentConfirm);
         //新增合同履约记录
         ContractPaymentScheduleProcess process = new ContractPaymentScheduleProcess();
         process.setContractId(contract.getId());
         process.setContractName(contract.getContractName());
         process.setScheduleId(fitstSchedule.getId());
         process.setScheduleName(fitstSchedule.getStageName());
         process.setProcessDate(contract.getSignDate());
         contractPaymentScheduleProcessMapper.insert(process);
   public void takeEffect(Long id) {
      Contract contract = baseMapper.selectById(id);
      contract.setContractStatus(2);
      baseMapper.updateById(contract);
      //水电房租 执行日
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
            .eq(ContractSubjectMatter::getContractId, id));
      if (StrUtil.isNotEmpty(contract.getContractCategory()) && StrUtil.equals(contract.getContractCategory(), "water_house")) {
         handleWaterHouseCycle(contract,subjectMatterList);
         return;
      }
      //查询是否有后续阶段
      List<ContractPaymentSchedule> afterSchedule = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
            .eq(ContractPaymentSchedule::getContractId, fitstSchedule.getContractId())
            .gt(ContractPaymentSchedule::getStageOrder, fitstSchedule.getStageOrder()));
      if (ArrayUtil.isNotEmpty(afterSchedule.toArray())&&afterSchedule.size()==1){
         //最后阶段生效时间
         ContractPaymentSchedule endSchedule = afterSchedule.get(0);
         endSchedule.setEffectiveDate(DateUtil.offsetDay(new Date(),endSchedule.getAgreedDays()));
         endSchedule.setEffectiveEndDate(contract.getExpirationDate());
         contractPaymentScheduleMapper.updateById(endSchedule);
         //第一阶段生效时间
         fitstSchedule.setEffectiveDate(DateUtil.offsetDay(new Date(),fitstSchedule.getAgreedDays()));
         fitstSchedule.setEffectiveEndDate(endSchedule.getEffectiveDate());
         contractPaymentScheduleMapper.updateById(fitstSchedule);
      //资金明细
      savePaymentConfirm(contract);

         //最后阶段应收
         PaymentConfirm newConfim = new PaymentConfirm();
         newConfim.setBusinessType(endSchedule.getStageName()+"应收");
         newConfim.setBusGuestId(contract.getPartyAId());
         newConfim.setBusGuestName(contract.getPartyA());
         newConfim.setContractId(contract.getId());
         newConfim.setContractName(contract.getContractName());
         newConfim.setContractNo(contract.getContractNo());
         newConfim.setScheduleId(endSchedule.getId());
         newConfim.setScheduleName(endSchedule.getStageName());
         newConfim.setConfirmTime(new Date());
         newConfim.setTransationAmount(endSchedule.getPlannedAmount());
         newConfim.setReceivableAmount(endSchedule.getPlannedAmount());
         PaymentConfirm lastNewConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId,contract.getId())
               .orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
         BigDecimal lastNewTotal = new BigDecimal("0");
         if(ObjUtil.isNotNull(lastNewConfirm)){
            lastNewTotal = lastNewConfirm.getTotalAmount();
      //合同推送子公司
      pushSubCompany(contract,subjectMatterList);

      //合同中心推送
//      pusnContractCenter(contract,subjectMatterList);

      contract.setNextScheduleName("发货前");
      baseMapper.updateById(contract);
   }

   private void pusnContractCenter(Contract contract,List<ContractSubjectMatter> subjectMatterList) {
      new Thread(() -> {
         try {
            JSONObject requestApply = new JSONObject();
            requestApply.put("fd_selectionmethod", "公开招标");
            requestApply.put("fd_isrelated", "是");
            requestApply.put("fd_bizId", contract.getId());
            requestApply.put("fd_remark", contract.getRemark());
            requestApply.put("fd_MainContent", "");
            requestApply.put("fd_settlementType", "00");
            requestApply.put("fd_applyType", "外销");
            requestApply.put("fd_contractsubject ", subjectMatterList.stream().map(item -> item.getMaterialName()).collect(Collectors.joining(",")));
            requestApply.put("fd_docNumber", contract.getContractNo());
            requestApply.put("fd_templateId", "19e39bb6c1edadbdb162c434274a8a18");
            requestApply.put("fd_name", contract.getContractName());
            requestApply.put("fd_signDate", DateUtil.formatDate(contract.getSignDate()));
            requestApply.put("fd_endDate", DateUtil.formatDate(contract.getExpirationDate()));
            requestApply.put("fd_contractCreater", contract.getNickName());
            requestApply.put("fd_currency", "人民币");
            requestApply.put("fd_ContractAmount", contract.getAmount());
            requestApply.put("fd_finAmount", contract.getAmount().divide(new BigDecimal("113"), 2, RoundingMode.HALF_UP)
                  .multiply(new BigDecimal("87")));
            requestApply.put("fd_docStatus", "20");
            requestApply.put("fd_taxRates", 13);
            requestApply.put("fd_customerName", contract.getPartyA());
            requestApply.put("fd_systemSource", "非煤销售系统");
            requestApply.put("fd_type", "00");
            log.info("合同中心合同起草接口入参：{}", requestApply.toJSONString());
            String respApply = HttpUtil.post("https://oatest.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addSupplyContractApply", requestApply.toJSONString());
            log.info("合同中心合同起草接口回参：{}", respApply);
            JSONObject applyResp = JSONObject.parseObject(respApply);
            if (applyResp.getString("code").equals("00")) {
               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.getSignDate()));
               request.put("fd_enddate", DateUtil.formatDate(contract.getExpirationDate()));
               request.put("fd_reviewerNo", contract.getNickName());
               request.put("fd_docStatus", "20");
               request.put("fd_templateId", "19e39bb6c1edadbdb162c434274a8a18");
               request.put("fd_attName", contract.getAttachmentName());
               request.put("fd_attcontent", NetworkFileToBase64.convertNetworkFileToBase64("https://zbjt.res.jzeg.cn/api" + contract.getAttachmentUrl()));
               log.info("合同中心同步合同接口入参：{}", request.toJSONString());
               String resp = HttpUtil.post("https://oatest.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addContractReview", request.toJSONString());
               log.info("合同中心同步合同接口回参：{}", resp);
               JSONObject respJson = JSONObject.parseObject(resp);
               if (respJson.getString("code").equals("00")) {
                  contract.setCenterPushFlag("1");
                  baseMapper.updateById(contract);
               }
            }
         } catch (Exception e) {
            e.printStackTrace();
         }
         newConfim.setTotalAmount(lastNewTotal.subtract(newConfim.getReceivableAmount()));
         paymentConfirmMapper.insert(newConfim);
      }).start();
   }

   private void pushSubCompany(Contract contract,List<ContractSubjectMatter> subjectMatterList) {
      //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 (CollUtil.isNotEmpty(subjectMatterList)) {
                  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.equals(contract.getPartyBId() + "", smjsc) ||
                  StrUtil.equals(contract.getPartyBId() + "", smjzt)) && StrUtil.isNotEmpty(smjErp)) {
               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 (CollUtil.isNotEmpty(subjectMatterList)) {
                  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", "Zimafold@2026");
               log.info("石煤机合同推送获取token入参：{}", loginJson.toJSONString());
               String loginResp = HttpUtil.post(smjErp + "/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(smjErp + "/api/contract/v1/createWithDetails")
                        .header("token", dataJson.getString("token"))       // 添加认证头
                        .header("Content-Type", "application/json")         // 设置内容类型
                        .body(request.toJSONString())                        // 设置请求体
                        .execute();                                         // 执行请求.post(ymjErp,request.toJSONString());
                  log.info("石煤机合同推送erp回参：{}", response.body());
                  //保存请求记录
                  saveErpRequestRecord("smj", request.toJSONString(), response.body());
                  //更新合同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)) {
               //通方公司通过系统录入
            }

         } catch (Exception e) {
            e.printStackTrace();
         }
      }).start();

   }

   private void saveScheduleProcess(Contract contract,ContractPaymentSchedule schedule) {
      //新增合同履约记录
      ContractPaymentScheduleProcess process = new ContractPaymentScheduleProcess();
      process.setContractId(contract.getId());
      process.setContractName(contract.getContractName());
      process.setScheduleId(schedule.getId());
      process.setScheduleName(schedule.getStageName());
      process.setProcessDate(contract.getSignDate());
      contractPaymentScheduleProcessMapper.insert(process);
   }

   private void handleWaterHouseCycle(Contract contract, List<ContractSubjectMatter> subjectMatterList) {
      if (CollUtil.isNotEmpty(subjectMatterList)) {
         for (ContractSubjectMatter contractSubjectMatter : subjectMatterList) {
            if (StrUtil.equals(contract.getExecFrequency(), "1")) {
               Long weeksTrue = DateUtil.betweenWeek(DateUtil.beginOfWeek(contract.getEffectiveDate()),
                     DateUtil.endOfWeek(contract.getExpirationDate()), true) + 1;
               //循环日期
               Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfWeek(contract.getEffectiveDate()), contract.getExecDay());
               for (int i = 0; i < weeksTrue.intValue(); i++) {
                  Date execDatei = DateUtil.offsetWeek(execDate0, i);
                  ContractExecDate execDate = new ContractExecDate();
                  execDate.setContractId(contract.getId());
                  execDate.setMatterId(contractSubjectMatter.getId());
                  execDate.setExecDate(execDatei);
                  execDate.setGenFlag("0");
                  if (DateUtil.isIn(execDatei, contract.getEffectiveDate(), contract.getExpirationDate())) {
                     contractExecDateMapper.insert(execDate);
                  }
               }
            }
            if (StrUtil.equals(contract.getExecFrequency(), "2")) {
               Long weeksTrue = DateUtil.betweenMonth(DateUtil.beginOfMonth(contract.getEffectiveDate()),
                     DateUtil.endOfMonth(contract.getExpirationDate()), true) + 1;
               //循环日期
               Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfMonth(contract.getEffectiveDate()), contract.getExecDay());
               for (int i = 0; i < weeksTrue.intValue(); i++) {
                  Date execDatei = DateUtil.offsetMonth(execDate0, i);
                  ContractExecDate execDate = new ContractExecDate();
                  execDate.setContractId(contract.getId());
                  execDate.setMatterId(contractSubjectMatter.getId());
                  execDate.setExecDate(execDatei);
                  execDate.setGenFlag("0");
                  if (DateUtil.isIn(execDatei, contract.getEffectiveDate(), contract.getExpirationDate())) {
                     contractExecDateMapper.insert(execDate);
                  }
               }
            }
            if (StrUtil.equals(contract.getExecFrequency(), "3")) {
               Long weeksTrue = (DateUtil.betweenMonth(DateUtil.beginOfQuarter(contract.getEffectiveDate()),
                     DateUtil.endOfQuarter(contract.getExpirationDate()), true) + 1) / 3;

               //循环日期
               Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfQuarter(contract.getEffectiveDate()), contract.getExecDay());
               for (int i = 0; i < weeksTrue.intValue(); i++) {
                  Date execDatei = DateUtil.offsetMonth(execDate0, i * 3);
                  ContractExecDate execDate = new ContractExecDate();
                  execDate.setContractId(contract.getId());
                  execDate.setMatterId(contractSubjectMatter.getId());
                  execDate.setExecDate(execDatei);
                  execDate.setGenFlag("0");
                  if (DateUtil.isIn(execDatei, contract.getEffectiveDate(), contract.getExpirationDate())) {
                     contractExecDateMapper.insert(execDate);
                  }
               }
            }
            if (StrUtil.equals(contract.getExecFrequency(), "4")) {
               Date startDate = contract.getEffectiveDate();
               Date endDate = contract.getExpirationDate();
               Integer startMonth = DateUtil.month(contract.getEffectiveDate());
               Integer endMonth = DateUtil.month(contract.getExpirationDate());
               if (1 <= startMonth && startMonth <= 6) {
                  startDate = DateUtil.beginOfYear(startDate);
               }
               if (7 <= startMonth && startMonth <= 12) {
                  startDate = DateUtil.offsetMonth(DateUtil.beginOfYear(startDate), 6);
               }
               if (1 <= endMonth && endMonth <= 6) {
                  endDate = DateUtil.offsetMonth(DateUtil.endOfYear(endDate), -6);
               }
               if (7 <= endMonth && endMonth <= 12) {
                  endDate = DateUtil.endOfYear(endDate);
               }
               Long weeksTrue = (DateUtil.betweenMonth(startDate, endDate, true) + 1) / 6;
               //循环日期
               Date execDate0 = DateUtil.offsetDay(startDate, contract.getExecDay());
               for (int i = 0; i < weeksTrue.intValue(); i++) {
                  Date execDatei = DateUtil.offsetMonth(execDate0, i * 6);
                  ContractExecDate execDate = new ContractExecDate();
                  execDate.setContractId(contract.getId());
                  execDate.setMatterId(contractSubjectMatter.getId());
                  execDate.setExecDate(execDatei);
                  execDate.setGenFlag("0");
                  if (DateUtil.isIn(execDatei, contract.getEffectiveDate(), contract.getExpirationDate())) {
                     contractExecDateMapper.insert(execDate);
                  }
               }
            }
            if (StrUtil.equals(contract.getExecFrequency(), "5")) {
               Long weeksTrue = DateUtil.betweenWeek(DateUtil.beginOfYear(contract.getEffectiveDate()),
                     DateUtil.endOfYear(contract.getExpirationDate()), true) + 1;
               //循环日期
               Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfYear(contract.getEffectiveDate()), contract.getExecDay());
               for (int i = 0; i < weeksTrue.intValue(); i++) {
                  Date execDatei = DateUtil.offsetWeek(execDate0, i);
                  ContractExecDate execDate = new ContractExecDate();
                  execDate.setContractId(contract.getId());
                  execDate.setMatterId(contractSubjectMatter.getId());
                  execDate.setExecDate(execDatei);
                  execDate.setGenFlag("0");
                  if (DateUtil.isIn(execDatei, contract.getEffectiveDate(), contract.getExpirationDate())) {
                     contractExecDateMapper.insert(execDate);
                  }
               }
            }

         }
      }
      if(ArrayUtil.isEmpty(afterSchedule.toArray())){
         fitstSchedule.setEffectiveEndDate(contract.getExpirationDate());
         contractPaymentScheduleMapper.updateById(fitstSchedule);
   }

   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 fitstSchedule = contractPaymentScheduleMapper.selectOne(Wrappers.<ContractPaymentSchedule>lambdaQuery()
            .eq(ContractPaymentSchedule::getContractId, contract.getId())
            .eq(ContractPaymentSchedule::getStageName,"合同签订")
            .last("limit 1"));
      fitstSchedule.setEffectiveEndDate(DateUtil.offsetDay(contract.getSignDate(),fitstSchedule.getAgreedDays()));
      contractPaymentScheduleMapper.updateById(fitstSchedule);
      //报错履约记录
      saveScheduleProcess(contract,fitstSchedule);
      //保存资金明细
      if (fitstSchedule.getPaymentRatio().compareTo(new BigDecimal("0"))>0) {
         //新增应收
         PaymentConfirm currentConfim = new PaymentConfirm();
         currentConfim.setBusinessType(fitstSchedule.getStageName() + "应收");
         currentConfim.setBusGuestId(contract.getPartyAId());
         currentConfim.setBusGuestName(contract.getPartyA());
         currentConfim.setContractId(contract.getId());
         currentConfim.setContractName(contract.getContractName());
         currentConfim.setContractNo(contract.getContractNo());
         currentConfim.setScheduleId(fitstSchedule.getId());
         currentConfim.setScheduleName(fitstSchedule.getStageName());
         currentConfim.setConfirmTime(contract.getSignDate());
         currentConfim.setTransationAmount(fitstSchedule.getPlannedAmount());
         currentConfim.setReceivableAmount(fitstSchedule.getPlannedAmount());
         PaymentConfirm lastConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
               .orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
         if (ObjUtil.isNotNull(lastConfirm)) {
            currentConfim.setTotalAmount(lastConfirm.getTotalAmount().subtract(currentConfim.getTransationAmount()));
            if (contract.getContractNo().startsWith("ZB-")) {
               paymentConfirmMapper.insert(currentConfim);
            }
            return;
         }
         currentConfim.setTotalAmount(currentConfim.getTransationAmount().multiply(new BigDecimal("-1")));
         paymentConfirmMapper.insert(currentConfim);
         processService.handleBeforeRemain(currentConfim,contract);
      }
      return Boolean.TRUE;

   }

   @Override
   public R genCurrentOverdue() {
      List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
            .lt(ContractPaymentSchedule::getEffectiveEndDate, DateUtil.today())
            .ne(ContractPaymentSchedule::getPaymentStatus,"2"));
      if (ArrayUtil.isNotEmpty(scheduleList.toArray())){
            .ne(ContractPaymentSchedule::getPaymentStatus, "2")
            .ne(ContractPaymentSchedule::getPaymentStatus, 3));
      if (CollUtil.isNotEmpty(scheduleList)) {
         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)) {
               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)){
               currentOverdueMapper.insert(currentOverdue);
            }else {
               overdue.setOverdueDuration(BigDecimal.valueOf(DateUtil.betweenDay(contractPaymentSchedule.getEffectiveEndDate(),new Date(),true)));
               currentOverdueMapper.updateById(overdue);
            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);
                  }
               }
            }
         });
      }
      return R.ok();
   }

   @Override
   public R refuseApproval(Long id) {
      Contract contract = baseMapper.selectById(id);
      contract.setContractStatus(0);
      baseMapper.updateById(contract);
      return R.ok();
   }

   @Override
   public R copyNewContract(Long id) {
      Contract oldContract = baseMapper.selectById(id);
      Contract newContract = BeanUtil.copyProperties(oldContract, Contract.class, "id", "createTime");
      newContract.setOutBoundAmout(new BigDecimal("0"));
      newContract.setPaidAmount(new BigDecimal("0"));
      newContract.setBillingStatus("1");
      newContract.setErpPushFlag("0");
      newContract.setContractStatus(0);
      newContract.setBillingAmout(new BigDecimal("0"));
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
            StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
         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));
      subjectMatterList.stream().forEach(contractSubjectMatter -> {
         ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatter, ContractSubjectMatter.class, "id", "createTime");
         subjectMatter.setContractId(newContract.getId());
         subjectMatter.setDeliveryStatus(0);
         subjectMatter.setDeliveredQuantity(new BigDecimal("0"));
         subjectMatter.setRemainingQuantity(new BigDecimal("0"));
         contractSubjectMatterMapper.insert(subjectMatter);
      });
      List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery().eq(ContractPaymentSchedule::getContractId, id));
      scheduleList.stream().forEach(contractPaymentSchedule -> {
         ContractPaymentSchedule schedule = BeanUtil.copyProperties(contractPaymentSchedule, ContractPaymentSchedule.class, "id", "createTime");
         schedule.setContractId(newContract.getId());
         schedule.setPaymentStatus(0);
         schedule.setActualAmount(new BigDecimal("0"));
         schedule.setEffectiveDate(null);
         schedule.setEffectiveEndDate(null);
         contractPaymentScheduleMapper.insert(schedule);
      });
      return R.ok();
   }

   @Override
   public void exportContractYMJJGCLWord(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("no", no);
         item.put("materialName", contractSubjectMatter.getMaterialName());
         item.put("guige", contractSubjectMatter.getSpecification());
         item.put("unit", contractSubjectMatter.getUnit());
         item.put("quantity", contractSubjectMatter.getQuantity());
         item.put("danzhong", contractSubjectMatter.getSingleWight());
         item.put("zongzhong", contractSubjectMatter.getTotalWight());
         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", contract.getPartyA());
      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("companyName", 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/ymj/ymjjgclht.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 genCycleReceiced() {
      List<ContractExecDate> execDateList = contractExecDateMapper.selectList(Wrappers.<ContractExecDate>lambdaQuery()
            .le(ContractExecDate::getExecDate, DateUtil.today()).eq(ContractExecDate::getGenFlag, "0"));
      if (CollUtil.isNotEmpty(execDateList)) {
         execDateList.stream().forEach(contractExecDate -> {
            Contract contract = baseMapper.selectById(contractExecDate.getContractId());
            ContractSubjectMatter subjectMatter = contractSubjectMatterMapper.selectOne(Wrappers.<ContractSubjectMatter>lambdaQuery()
                  .eq(ContractSubjectMatter::getContractId, contractExecDate.getContractId())
                  .eq(ContractSubjectMatter::getId, contractExecDate.getMatterId()));
            //生成抄表单
            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());
               meterReadRecordMapper.insert(record);
            } else {
               //创建收款节点
               //查询上次收款节点
               ContractPaymentSchedule lastSchedule = contractPaymentScheduleMapper.selectOne(Wrappers.<ContractPaymentSchedule>lambdaQuery()
                     .eq(ContractPaymentSchedule::getContractId, contract.getId())
                     .orderByDesc(ContractPaymentSchedule::getCreateTime).last("limit 1"));
               ContractPaymentSchedule schedule = new ContractPaymentSchedule();
               schedule.setStageName("房租租赁缴费");
               schedule.setContractId(contract.getId());
               schedule.setContractName(contract.getContractName());
               schedule.setPlannedAmount(subjectMatter.getUnitPrice().multiply(subjectMatter.getQuantity()));
               schedule.setEffectiveEndDate(contractExecDate.getExecDate());
               schedule.setStageOrder(1);
               if (ObjUtil.isNotNull(lastSchedule)) {
                  schedule.setStageOrder(lastSchedule.getStageOrder() + 1);
               }
               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();
               confirm.setBusinessType("房屋租赁应收");
               confirm.setBusGuestId(contract.getPartyAId());
               confirm.setBusGuestName(contract.getPartyA());
               confirm.setContractId(contract.getId());
               confirm.setContractName(contract.getContractName());
               confirm.setContractNo(contract.getContractNo());
               confirm.setScheduleId(schedule.getId());
               confirm.setScheduleName(schedule.getStageName());
               confirm.setConfirmTime(contractExecDate.getExecDate());
               confirm.setTransationAmount(subjectMatter.getUnitPrice().multiply(subjectMatter.getQuantity()));
               confirm.setTotalAmount(confirm.getTransationAmount().multiply(new BigDecimal("-1")));
               PaymentConfirm lastConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
                     .orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
               if (ObjUtil.isNotNull(lastConfirm)) {
                  BigDecimal total = lastConfirm.getTotalAmount().add(confirm.getTotalAmount());
                  if (total.compareTo(new BigDecimal("0")) > 0) {
                     confirm.setAdvanceAmount(total);
                     confirm.setTotalAmount(total);
                  } else if (total.compareTo(new BigDecimal("0")) == 0) {
                     confirm.setTotalAmount(total);
                  } else {
                     confirm.setReceivableAmount(total.multiply(new BigDecimal("-1")));
                     confirm.setTotalAmount(total);
                  }
                  confirm.setCompId(contract.getCompId());
                  paymentConfirmMapper.insert(confirm);
               } else {
                  confirm.setReceivableAmount(confirm.getTransationAmount());
                  confirm.setTotalAmount(confirm.getReceivableAmount().multiply(new BigDecimal("-1")));
                  confirm.setCompId(contract.getCompId());
                  paymentConfirmMapper.insert(confirm);
               }
            }
            contractExecDate.setGenFlag("1");
            contractExecDateMapper.updateById(contractExecDate);
            contract.setBillingStatus("2");
            baseMapper.updateById(contract);
         });
      }
      return R.ok();
   }

   @Override
   public void exportContractYMJGYPMMWord(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("no", no);
         item.put("materialName", contractSubjectMatter.getMaterialName());
         item.put("guige", contractSubjectMatter.getSpecification());
         item.put("unit", contractSubjectMatter.getUnit());
         item.put("quantity", contractSubjectMatter.getQuantity());
         item.put("danzhong", contractSubjectMatter.getSingleWight());
         item.put("zongzhong", contractSubjectMatter.getTotalWight());
         item.put("unitPrice", contractSubjectMatter.getUnitPrice());
         item.put("price", contractSubjectMatter.getTotalAmount());
         if (no.get().equals(Integer.valueOf(0))) {
            item.put("deliveryCycle", contract.getDeliveryCycle());
         }
         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/ymj/ymjgypmmht.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 exportContractYMJGKCPMMWord(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()));
      map.put("deliveryCycle", contract.getDeliveryCycle());
      //标的物
      List<Map<String, Object>> items = new ArrayList<>();
      AtomicReference<Integer> no = new AtomicReference<>(0);
      subjectMatterList.stream().forEach(contractSubjectMatter -> {
         Map<String, Object> item = new HashMap<>();
         item.put("no", no);
         item.put("materialName", contractSubjectMatter.getMaterialName());
         item.put("guige", contractSubjectMatter.getSpecification());
         item.put("unit", contractSubjectMatter.getUnit());
         item.put("quantity", contractSubjectMatter.getQuantity());
         item.put("danzhong", contractSubjectMatter.getSingleWight());
         item.put("zongzhong", contractSubjectMatter.getTotalWight());
         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/ymj/ymjgkcpmmht.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 exportContractYMJCGWord(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()));
      map.put("environment", contract.getEnvironment());
      map.put("standard", contract.getStandard());
      map.put("useMonth", contract.getUseMonth());
      map.put("afterShipMonth", contract.getAfterShipMonth());
      map.put("shipMethod", contract.getShipMethod());
      map.put("shipAddress", contract.getShipAddress());
      map.put("packaging", contract.getPackaging());
      map.put("repairPeriod", contract.getRepairPeriod());
      map.put("repairBreachAmount", contract.getRepairBreachAmount());
      map.put("goodsShort", contract.getGoodsShort());
      map.put("goodsShortBreachAmount", contract.getGoodsShortBreachAmount());
      map.put("overdueBreachAmount", contract.getOverdueBreachAmount());
      map.put("terminateContract", contract.getTerminateContract());
      map.put("court", contract.getCourt());
      map.put("contractAttchment", contract.getContractAttchment());
      map.put("invoiceNotice", contract.getInvoiceNotice());
      map.put("city", contract.getCity());
      map.put("region", contract.getRegion());

      //标的物
      List<Map<String, Object>> items = new ArrayList<>();
      AtomicReference<Integer> no = new AtomicReference<>(0);
      subjectMatterList.stream().forEach(contractSubjectMatter -> {
         Product product = productMapper.selectOne(Wrappers.<Product>lambdaQuery().eq(Product::getErpCode, contractSubjectMatter.getMaterialCode()).last("limit 1"));
         Map<String, Object> item = new HashMap<>();
         item.put("no", no);
         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("priceTax", contractSubjectMatter.getUnitPrice().multiply(contractSubjectMatter.getQuantity()).setScale(2, RoundingMode.HALF_UP));
         item.put("priceNoTax", contractSubjectMatter.getUnitPrice().multiply(contractSubjectMatter.getQuantity())
               .subtract(contractSubjectMatter.getUnitPrice().multiply(contractSubjectMatter.getQuantity())
                     .divide(new BigDecimal("100").add(new BigDecimal(product.getTaxRate())), 2, RoundingMode.HALF_UP).multiply(new BigDecimal(product.getTaxRate())))
               .setScale(2, RoundingMode.HALF_UP));
         item.put("deliveryDate", DateUtil.formatDate(contractSubjectMatter.getPlannedDeliveryDate()));
         item.put("remarks", contractSubjectMatter.getRemarks());
         map.put("taxRate", product.getTaxRate());
         items.add(item);
         no.updateAndGet(v -> v + 1);
      });

      //付款
      List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
            .eq(ContractPaymentSchedule::getContractId, id).orderByAsc(ContractPaymentSchedule::getCreateTime));
      scheduleList.stream().forEach(contractPaymentSchedule -> {
         if (contractPaymentSchedule.getStageName().equals("合同签订")) {
            map.put("htqdbl", contractPaymentSchedule.getPaymentRatio());
            map.put("htqdje", contractPaymentSchedule.getPlannedAmount());
            map.put("htqdjr", contractPaymentSchedule.getAgreedDays());
         }
         if (contractPaymentSchedule.getStageName().equals("发货前")) {
            map.put("fhqbl", contractPaymentSchedule.getPaymentRatio());
            map.put("fhqje", contractPaymentSchedule.getPlannedAmount());
         }
         if (contractPaymentSchedule.getStageName().equals("调试完成或验收")) {
            map.put("ysbl", contractPaymentSchedule.getPaymentRatio());
            map.put("ysje", contractPaymentSchedule.getPlannedAmount());
            map.put("ysjr", contractPaymentSchedule.getAgreedDays());
         }
         if (contractPaymentSchedule.getStageName().equals("质保金")) {
            map.put("zbjbl", contractPaymentSchedule.getPaymentRatio());
            map.put("zbjje", contractPaymentSchedule.getPlannedAmount());
            map.put("zbjjr", contractPaymentSchedule.getAgreedDays());
         }
      });
      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/ymj/ymjcght.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 delayOutApproval(DelayOutApprovalDTO dto) {
      Contract contract = baseMapper.selectById(dto.getContractId());
      ContractDelayOut delayOut = BeanUtil.copyProperties(dto, ContractDelayOut.class);
      delayOut.setApplyTime(new Date());
      delayOut.setApplyName(SecurityUtils.getUser().getUsername());
      delayOut.setDelayStatus("0");
      Map<String, Object> map = new HashMap<>();
      map.put("contractId", contract.getId());
      map.put("contractName", contract.getContractName());
      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));
      //启动流程
      ProcessInstanceParamDto paramDto = new ProcessInstanceParamDto();
      paramDto.setParamMap(map);
      paramDto.setFlowName(FlowNameEnum.延期出货审批.name());
      R r1 = remoteFlowProcessService.startProcessInstance(paramDto);
      if (r1.getCode() == 1) {
         return R.failed("流程启动失败");
      }
      contractDelayOutMapper.insert(delayOut);
      return R.ok();
   }

   @Override
   public Page pageScope(Page page, ContracQueryDTO queryDTO) {
      return baseMapper.pageScope(page, queryDTO, DataScope.of("comp_id"));
   }

   @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 (CollUtil.isEmpty(addDTO.getContractSubjectMatter())) {
         return R.failed("请添加标的物");
      }
      if (CollUtil.isEmpty(addDTO.getContractPaymentSchedule())) {
         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.setCenterPushFlag("0");
      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());
      contract.setPartyA(bc.getCompanyName());
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())) {
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(), addDTO.getDeliveryCycle()));
      }
      if (ObjUtil.isNotNull(contract.getSignDate()) && ObjUtil.isNotNull(contract.getExpirationDate())) {
         Long bd = DateUtil.betweenDay(contract.getExpirationDate(), contract.getSignDate(), true);
         contract.setDeliveryCycle(bd.intValue());
      }
      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 (CollUtil.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 (CollUtil.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);
            }
         });

      }

      //推送合同中心
      pushCenter(contract.getId());
      return R.ok(contract.getContractNo());
   }

   @Override
   public R updateContractSgb(ContractUpdateDTO updateDTO) {
      if (CollUtil.isEmpty(updateDTO.getContractSubjectMatter())) {
         return R.failed("请添加标的物");
      }
      if (CollUtil.isEmpty(updateDTO.getContractPaymentSchedule())) {
         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 (CollUtil.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 (CollUtil.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 (CollUtil.isNotEmpty(page1.getRecords())) {
         page1.getRecords().stream().forEach(fourAssociationPageVo -> {
            List<PaymentSlip> slips = paymentSlipMapper.selectList(Wrappers.<PaymentSlip>lambdaQuery().eq(PaymentSlip::getContractId, fourAssociationPageVo.getId())
                  .orderByAsc(PaymentSlip::getPaymentTime));
            if (CollUtil.isNotEmpty(slips)) {
               fourAssociationPageVo.setSlipVoList(BeanUtil.copyToList(slips, ContractSlipVo.class));
            }
            List<ContractInvoice> invoices = contractInvoiceMapper.selectList(Wrappers.<ContractInvoice>lambdaQuery().eq(ContractInvoice::getContractId, fourAssociationPageVo.getId())
                  .orderByAsc(ContractInvoice::getInvoiceTime));
            if (CollUtil.isNotEmpty(invoices)) {
               fourAssociationPageVo.setInvoiceVoList(BeanUtil.copyToList(invoices, ContractInvoiceVo.class));
            }
            if (fourAssociationPageVo.getAmount().compareTo(fourAssociationPageVo.getPaidAmount()) == 0 &&
                  fourAssociationPageVo.getAmount().compareTo(fourAssociationPageVo.getBillingAmout()) == 0 &&
                  CollUtil.isNotEmpty(slips) && CollUtil.isNotEmpty(invoices)
            ) {
               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();
      }
   }

   @Override
   public R addSimple(ContractAddDTO addDTO) {
      Contract contract = BeanUtil.copyProperties(addDTO, Contract.class);
      contract.setPartyBId(SecurityUtils.getUser().getCompId());
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      if (StrUtil.isEmpty(addDTO.getPartyA())) {
         BusinessCustomer bc = businessCustomerMapper.selectById(addDTO.getPartyAId());
         if (ObjUtil.isNotNull(bc)) {
            contract.setPartyA(bc.getCompanyName());
         }
      }

      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingStatus("1");
      contract.setBillingAmout(new BigDecimal("0"));
      contract.setErpPushFlag("0");
      contract.setNickName(SecurityUtils.getUser().getNickname());

      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
            StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
         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());
      }
      baseMapper.insert(contract);
      return R.ok();
   }

   @Override
   public R pushCenter(Long id) {
      Contract contract = baseMapper.selectById(id);
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
            .eq(ContractSubjectMatter::getContractId, id));
      JSONObject requestApply = new JSONObject();
      requestApply.put("fd_selectionmethod", "公开招标");
      requestApply.put("fd_isrelated", "是");
      requestApply.put("fd_bizId", contract.getId());
      requestApply.put("fd_remark", contract.getRemark());
      requestApply.put("fd_MainContent", "");
      requestApply.put("fd_settlementType", "00");
      requestApply.put("fd_applyType", "外销");
      requestApply.put("fd_contractsubject ", subjectMatterList.stream().map(item -> item.getMaterialName()).collect(Collectors.joining(",")));
      requestApply.put("fd_docNumber", contract.getContractNo());

      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
            StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
         requestApply.put("fd_templateId", tempSMJ);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
         requestApply.put("fd_templateId", tempSGB);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", ymj)) {
         requestApply.put("fd_templateId", tempYMJ);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", tfgs)) {
         requestApply.put("fd_templateId", tempTFGS);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", jxc)) {
         requestApply.put("fd_templateId", tempJXC);
      }
      requestApply.put("fd_name", contract.getContractName());
      requestApply.put("fd_signDate", DateUtil.formatDate(contract.getSignDate()));
      requestApply.put("fd_endDate", DateUtil.formatDate(contract.getExpirationDate()));
      requestApply.put("fd_contractCreater", contract.getNickName());
      requestApply.put("fd_currency", "人民币");
      requestApply.put("fd_ContractAmount", contract.getAmount());
      requestApply.put("fd_finAmount", contract.getAmount().divide(new BigDecimal("113"), 2, RoundingMode.HALF_UP)
            .multiply(new BigDecimal("87")));
      requestApply.put("fd_docStatus", "20");
      requestApply.put("fd_taxRates", 13);
      requestApply.put("fd_customerName", contract.getPartyA());
      requestApply.put("fd_systemSource", "非煤销售系统");
      requestApply.put("fd_type", "00");
      log.info("合同中心合同起草接口入参：{}", requestApply.toJSONString());
      String respApply = HttpUtil.post("https://oa.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addSupplyContractApply", requestApply.toJSONString());
      log.info("合同中心合同起草接口回参：{}", respApply);
      JSONObject applyResp = JSONObject.parseObject(respApply);
      if (applyResp.getString("code").equals("00")) {
         contract.setCenterPushFlag("1");
         baseMapper.updateById(contract);
         return R.ok();
      }
      return R.failed("推送合同中心审核失败，原因为：{}",applyResp.getString("msg"));
   }

   @Override
   public R importContractMultiSheet(MultipartFile file) {

      // 用于收集所有 Sheet 解析后的最终结果（如果需要统一返回或处理）
      // 注意：如果数据量极大，建议在 Listener 中直接入库，不要全部加载到内存 List 中
      List<ContractExceVO> baseList = new ArrayList<>();
      List<ContractPaymentScheduleExceVO> scheduleList = new ArrayList<>();
      List<ContractSubjectMatterExceVO> matterList = new ArrayList<>();

      try (ExcelReader excelReader = EasyExcel.read(file.getInputStream()).build()) {

         // 1. 构建第一个 Sheet 的读取配置
         ReadSheet sheet0 = EasyExcel.readSheet(0)
               .headRowNumber(1) // 表头行数
               .head(ContractExceVO.class) // 指定实体类
               .registerReadListener(new BatchInsertListener<ContractExceVO>(data -> {
                  baseList.addAll(data);
                  // 建议：在这里直接调用 service 保存，而不是 addTo List，除非数据量很小
                  // contractService.saveBaseInfo(data);
               }))
               .build();

         // 2. 构建第二个 Sheet 的读取配置
         ReadSheet sheet1 = EasyExcel.readSheet(1)
               .headRowNumber(1)
               .head(ContractSubjectMatterExceVO.class)
               .registerReadListener(new BatchInsertListener<ContractSubjectMatterExceVO>(data -> {
                  matterList.addAll(data);
                  // contractService.saveSchedule(data);
               }))
               .build();

         // 3. 构建第三个 Sheet 的读取配置
         ReadSheet sheet2 = EasyExcel.readSheet(2)
               .headRowNumber(1)
               .head(ContractPaymentScheduleExceVO.class) // 注意：这里你原代码写的是 ContractPaymentScheduleExceVO，但变量是 matterList，需确认实体类是否一致
               .registerReadListener(new BatchInsertListener<ContractPaymentScheduleExceVO>(data -> {
                  scheduleList.addAll(data);
                  // contractService.saveMatter(data);
               }))
               .build();

         // 4. 依次执行读取
         // 注意：excelReader.read(sheet) 会复用同一个输入流，所以必须用 try-with-resources 确保流管理正确
         excelReader.read(sheet0);
         excelReader.read(sheet1);
         excelReader.read(sheet2);
         // 后续处理 baseList, scheduleList, matterList
         log.info("主表数据量: " + baseList.size());
         log.info("进度表数据量: " + scheduleList.size());
         log.info("标的物数据量: " + matterList.size());
         List<Map<String, String>> errList = new ArrayList<>();
         for (int i = 0; i < baseList.size(); i++) {
            ContractExceVO contractExceVO = baseList.get(i);
            if (StrUtil.isBlank(contractExceVO.getContractNo())) {
               Map<String, String> map = new HashMap<String, String>();
               map.put("lineNum", "第" + (i + 1) + "行");
               map.put("errors", "合同编号为空");
               errList.add(map);
               continue;
            }
            BusinessCustomer bc = businessCustomerMapper.selectOne(Wrappers.<BusinessCustomer>lambdaQuery()
                  .eq(BusinessCustomer::getErpCompanyCode, contractExceVO.getBcErpCode()));
            if (ObjUtil.isNull(bc)) {
               Map<String, String> map = new HashMap<String, String>();
               map.put("lineNum", "第" + (i + 1) + "行");
               map.put("errors", "客户erp编码不存在");
               errList.add(map);
               continue;
            }
            R<List<SysDictItem>> rem = remoteDictService.getDictByType("economic_matters");
            if (!rem.isOk()) {
               return R.failed("经济事项字典查询异常");
            }
            List<SysDictItem> itemList = rem.getData();
            for (SysDictItem dictItem : itemList
            ) {
               if (StrUtil.equals(contractExceVO.getEconomicMatters(), dictItem.getLabel())) {
                  contractExceVO.setEconomicMatters(dictItem.getItemValue());
                  break;
               }
            }
            R<List<SysDictItem>> rsa = remoteDictService.getDictByType("supply_attribute");
            if (!rsa.isOk()) {
               return R.failed("供应属性字典查询异常");
            }
            for (SysDictItem dictItem : rsa.getData()
            ) {
               if (StrUtil.equals(contractExceVO.getSupplyAttribute().replace(" ", ""), dictItem.getLabel())) {
                  contractExceVO.setSupplyAttribute(dictItem.getItemValue());
                  break;
               }
            }
            R<List<SysDictItem>> rssa = remoteDictService.getDictByType("server_attribute");
            if (!rssa.isOk()) {
               return R.failed("服务属性字典查询异常");
            }
            for (SysDictItem dictItem : rssa.getData()
            ) {
               if (StrUtil.equals(contractExceVO.getContractAttribute().replace(" ", ""), dictItem.getLabel())) {
                  contractExceVO.setContractAttribute(dictItem.getItemValue());
                  break;
               }
            }
            R<List<SysDictItem>> ris = remoteDictService.getDictByType("industry_sector");
            if (!ris.isOk()) {
               return R.failed("服务属性字典查询异常");
            }
            for (SysDictItem dictItem : ris.getData()
            ) {
               if (StrUtil.equals(contractExceVO.getIndustryCode(), dictItem.getLabel())) {
                  contractExceVO.setIndustryCode(dictItem.getItemValue());
                  break;
               }
            }
            List<Contract> contractList = baseMapper.selectList(Wrappers.<Contract>lambdaQuery()
                  .eq(Contract::getContractNo, contractExceVO.getContractNo()));
            if (CollUtil.isNotEmpty(contractList)) {
               Map<String, String> map = new HashMap<String, String>();
               map.put("lineNum", "第" + (i + 1) + "行");
               map.put("errors", "合同编号已存在");
               errList.add(map);
               continue;
            }
            Contract contract = BeanUtil.copyProperties(contractExceVO, Contract.class);
            if (ObjUtil.isNotNull(contract.getSignDate()) && ObjUtil.isNotNull(contract.getExpirationDate())) {
               Long bd = DateUtil.betweenDay(contract.getExpirationDate(), contract.getSignDate(), true);
               contract.setDeliveryCycle(bd.intValue());
            }
            contract.setPartyA(bc.getCompanyName());
            contract.setPartyAId(bc.getId());
            contract.setPartyB(SecurityUtils.getUser().getCompName());
            contract.setPartyBId(SecurityUtils.getUser().getCompId());
            contract.setContractStatus(2);
            contract.setPaidAmount(ObjUtil.isNotNull(contract.getPaidAmount()) ?
                  contract.getPaidAmount() : new BigDecimal("0"));
            contract.setBillingAmout(ObjUtil.isNotNull(contract.getBillingAmout()) ?
                  contract.getBillingAmout() : new BigDecimal("0"));

            if (contract.getPaidAmount().compareTo(contract.getAmount())==0&&contract.getBillingAmout().compareTo(contract.getAmount())==0){
               contract.setContractStatus(3);
            }
            contract.setBillingStatus("1");
            baseMapper.insert(contract);
            BigDecimal remainAmount = ObjUtil.isNotNull(contract.getPaidAmount()) ? contract.getPaidAmount() : new BigDecimal("0");
            List<ContractSubjectMatterExceVO> resultMatter = matterList.stream().filter(item ->
                  StrUtil.isNotBlank(item.getMaterialCode()) &&
                        StrUtil.equals(item.getContractNo(), contract.getContractNo())).collect(Collectors.toList());
            if (CollUtil.isNotEmpty(resultMatter)) {
               for (ContractSubjectMatterExceVO subMatEx : resultMatter
               ) {
                  ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(subMatEx, ContractSubjectMatter.class);
                  subjectMatter.setContractId(contract.getId());
                  subjectMatter.setDeliveredQuantity(StrUtil.isBlank(subMatEx.getDeliveredQuantity())
                        ? new BigDecimal("0") : new BigDecimal(subMatEx.getDeliveredQuantity()));
                  subjectMatter.setRemainingQuantity(subjectMatter.getQuantity().subtract(subjectMatter.getDeliveredQuantity()));
                  subjectMatter.setDeliveryStatus(subjectMatter.getRemainingQuantity().compareTo(subjectMatter.getQuantity()) == 0 ? 0
                        : subjectMatter.getRemainingQuantity().compareTo(new BigDecimal("0")) > 0 ? 1 : 2);
                  subjectMatter.setLineNo(ItemGeneratorUtil.nextId());
                  contractSubjectMatterMapper.insert(subjectMatter);
//                  if (subjectMatter.getDeliveredQuantity().compareTo(new BigDecimal("0")) > 0) {
//                     //出库单
//                     ContractOutBound outBound = new ContractOutBound();
//                     outBound.setBusGuestId(contract.getPartyAId());
//                     outBound.setBusGuestName(contract.getPartyA());
//                     outBound.setContractId(contract.getId());
//                     outBound.setContractName(contract.getContractName());
//                     outBound.setInvoiceNum(new BigDecimal("0"));
//                     outBound.setInvoiceStatus("0");
//                     outBound.setOutBoundTime(new Date());
//                     outBound.setOutBoundNum(subjectMatter.getDeliveredQuantity());
//                     outBound.setSubjectMatterName(subjectMatter.getMaterialInternalName());
//                     outBound.setSubjectMatterCode(subjectMatter.getMaterialCode());
//                     contractOutBoundMapper.insert(outBound);
//                     if (contract.getBillingAmout().compareTo(new BigDecimal("0")) == 0) {
//                        contract.setBillingStatus("2");
//                        baseMapper.updateById(contract);
//                     }
//                  }

               }
            }
            List<ContractPaymentScheduleExceVO> resultSchedule = scheduleList.stream().filter(item ->
                  StrUtil.equals(item.getContractNo(), contract.getContractNo())).collect(Collectors.toList());
            if (CollUtil.isNotEmpty(resultSchedule)) {

               for (int j = 0; j < resultSchedule.size(); j++) {
                  ContractPaymentSchedule schedule = new ContractPaymentSchedule();
                  schedule.setStageName(resultSchedule.get(j).getStageName());
                  schedule.setContractId(contract.getId());
                  schedule.setPaymentRatio(StrUtil.isBlank(resultSchedule.get(j).getPaymentRatio())
                        ? new BigDecimal("0") : new BigDecimal(resultSchedule.get(j).getPaymentRatio()));
                  schedule.setAgreedDays(StrUtil.isBlank(resultSchedule.get(j).getAgreedDays())
                        ? 0 : Integer.valueOf(resultSchedule.get(j).getAgreedDays()));
                  schedule.setPlannedAmount(contract.getAmount().multiply(schedule.getPaymentRatio())
                        .divide(new BigDecimal("100"), 2, RoundingMode.HALF_UP));
                  schedule.setPaymentStatus(0);
                  schedule.setStageOrder(j + 1);
                  if (remainAmount.compareTo(new BigDecimal("0")) > 0 && schedule.getPlannedAmount().compareTo(new BigDecimal("0")) > 0) {
                     remainAmount = remainAmount.subtract(schedule.getPlannedAmount());
                     if (remainAmount.compareTo(new BigDecimal("0")) >= 0) {
                        schedule.setPaymentStatus(2);
                        schedule.setActualAmount(schedule.getPlannedAmount());
                     }
                     if (remainAmount.compareTo(new BigDecimal("0")) < 0) {
                        schedule.setPaymentStatus(1);
                        schedule.setActualAmount(schedule.getPlannedAmount().add(remainAmount));
                     }
                  }
                  contractPaymentScheduleMapper.insert(schedule);
//                  if (schedule.getStageName().equals("质保金") && contract.getAmount().subtract(ObjUtil.isNotNull(contract.getPaidAmount()) ?
//                        contract.getPaidAmount() : new BigDecimal("0")).compareTo(new BigDecimal("0")) > 0) {
//                     PaymentConfirm confirm = new PaymentConfirm();
//                     confirm.setBusGuestId(contract.getPartyAId());
//                     confirm.setBusGuestName(contract.getPartyA());
//                     confirm.setBusinessType("质保金应收");
//                     confirm.setConfirmTime(new Date());
//                     confirm.setContractId(contract.getId());
//                     confirm.setContractName(contract.getContractName());
//                     confirm.setContractNo(contract.getContractNo());
//                     confirm.setScheduleId(schedule.getId());
//                     confirm.setScheduleName(schedule.getStageName());
//                     confirm.setTransationAmount(contract.getAmount().subtract(ObjUtil.isNotNull(contract.getPaidAmount()) ?
//                           contract.getPaidAmount() : new BigDecimal("0")));
//                     confirm.setReceivableAmount(confirm.getTransationAmount());
//                     confirm.setTotalAmount(confirm.getTransationAmount().multiply(new BigDecimal("-1")));
//                     paymentConfirmMapper.insert(confirm);
//                  }
               }
            }
         }
         if (CollUtil.isNotEmpty(errList)) {
            return R.failed(errList);
         }
      } catch (IOException e) {
         e.printStackTrace();
         return R.failed("文件解析失败: " + e.getMessage());
      }
      return R.ok();
   }


   @Override
   public R subjectChange(ContractSubjectChangeDTO changeDTO) {
      Contract contract = baseMapper.selectById(changeDTO.getId());
      if (ObjUtil.isNull(contract)){
         return R.failed("合同状态异常");
      }
      if (contract.getBillingAmout().compareTo(new BigDecimal("0"))>0){
         return R.failed("合同已开票，不能进行变更");
      }
      if (ObjUtil.isNotNull(contract.getOutBoundAmout())&&contract.getOutBoundAmout().compareTo(new BigDecimal("0"))>0){
         return R.failed("合同标的物已出库，不能进行变更");
      }
      if (CollUtil.isEmpty(changeDTO.getContractSubjectMatter())){
         return R.failed("合同变更后标的物不能为空");
      }
      BigDecimal changeAmount = changeDTO.getContractSubjectMatter().stream().map(subject->subject.getUnitPrice().multiply(subject.getQuantity())).reduce(BigDecimal.ZERO,BigDecimal::add);
      if (contract.getAmount().compareTo(changeAmount)!=0){
         return R.failed("合同变更后标的物总价必须与合同总价一致");
      }
      List<ContractSubjectMatter> beforeList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId,changeDTO.getId()));
      ContractSubjectMatterChange change = new ContractSubjectMatterChange();
      change.setContractId(contract.getId());
      change.setBeforeChange(JSONObject.toJSONString(beforeList));
      change.setAfterChange(JSONObject.toJSONString(changeDTO.getContractSubjectMatter()));
      changeMapper.insert(change);
      contractSubjectMatterMapper.delete(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId,changeDTO.getId()));
      changeDTO.getContractSubjectMatter().stream().forEach(contractSubjectMatterAddDTO -> {
         ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatterAddDTO, ContractSubjectMatter.class);
         subjectMatter.setContractId(contract.getId());
         subjectMatter.setLineNo(ItemGeneratorUtil.nextId());
         subjectMatter.setDeliveredQuantity(new BigDecimal("0"));
         subjectMatter.setDeliveryStatus(0);
         subjectMatter.setTotalAmount(contractSubjectMatterAddDTO.getQuantity().multiply(contractSubjectMatterAddDTO.getUnitPrice()));
         contractSubjectMatterMapper.insert(subjectMatter);
      });
      return R.ok();
   }

   @Override
   public Page subjectChangePage(Page page, ContracQueryDTO queryDTO) {
      return changeMapper.subjectChangePage(page,queryDTO,DataScope.of("comp_id"));
   }

   @Override
   public R subjectChangeAtt(ContractSubjectChangeAttDTO attDTO) {
      ContractSubjectMatterChange change = changeMapper.selectById(attDTO.getId());
      change.setAttachmentName(attDTO.getAttachmentName());
      change.setAttachmentUrl(attDTO.getAttachmentUrl());
      changeMapper.updateById(change);
      return R.ok();
   }

   @Override
   public R syncContractStatus(SyncContractStatusDTO dto) {
      if (StrUtil.isBlank(dto.getContractNumber())){
         return R.failed("合同编号不能为空");
      }
      if (StrUtil.isBlank(dto.getStatus())){
         return R.failed("审批状态不能为空");
      }
      if (StrUtil.isBlank(dto.getReturnPerson())){
         return R.failed("审批人不能为空");
      }
      if (StrUtil.isBlank(dto.getReturnDateTime())){
         return R.failed("审批时间不能为空");
      }
      Contract contract = baseMapper.selectOne(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo,dto.getContractNumber()).last("limit 1"));
      if(ObjUtil.isNull(contract)){
         return R.failed("合同编号不异常");
      }
      if (StrUtil.equals(dto.getStatus(),"1")){
         takeEffect(contract.getId());
      }
      if (!StrUtil.equals(dto.getStatus(),"1")){
         refuseApproval(contract.getId());
      }
      saveContractApproval(contract,dto);
      return R.ok();
   }

   private void saveContractApproval(Contract contract, SyncContractStatusDTO dto) {
      ContractApproval approval = BeanUtil.copyProperties(dto,ContractApproval.class);
      approval.setContractId(contract.getId());
      approval.setReturnDateTime(DateUtil.parseDateTime(dto.getReturnDateTime()));
      approval.setCompId(contract.getCompId());
      contractApprovalMapper.insert(approval);
   }

   @Override
   public R finallyPdf(ContractFinallyDTO attDTO) {
      Contract contract = baseMapper.selectById(attDTO.getId());
      if (ObjUtil.isNull(contract)){
         return R.failed("合同异常");
      }
      if (!StrUtil.equals(contract.getContractStatus()+"","2")){
         return R.failed("合同异常状态");
      }
      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.getSignDate()));
      request.put("fd_enddate", DateUtil.formatDate(contract.getExpirationDate()));
      request.put("fd_reviewerNo", contract.getNickName());
      request.put("fd_docStatus", "20");
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
            StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
         request.put("fd_templateId", tempSMJ);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
         request.put("fd_templateId", tempSGB);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", ymj)) {
         request.put("fd_templateId", tempYMJ);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", tfgs)) {
         request.put("fd_templateId", tempTFGS);
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", jxc)) {
         request.put("fd_templateId", tempJXC);
      }
      request.put("fd_attName", attDTO.getLastAttachmentName());
      request.put("fd_attcontent", NetworkFileToBase64.convertNetworkFileToBase64("https://zbjt.res.jzeg.cn/api" + attDTO.getLastAttachmentUrl()));
      log.info("合同中心同步合同接口入参：{}", request.toJSONString());
      String resp = HttpUtil.post("https://oa.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addContractReview", request.toJSONString());
      log.info("合同中心同步合同接口回参：{}", resp);
      JSONObject respJson = JSONObject.parseObject(resp);
      if (respJson.getString("code").equals("00")) {
         contract.setLastAttachmentName(attDTO.getLastAttachmentName());
         contract.setLastAttachmentUrl(attDTO.getLastAttachmentUrl());
         baseMapper.updateById(contract);
         return R.ok();
      }
      return R.failed("合同中心最终盖章登记PDF上传失败,原因为:{}",respJson.getString("msg"));
   }


   @Override
   public R addContractSgbHis(ContractAddDTO addDTO) {

      if (CollUtil.isEmpty(addDTO.getContractSubjectMatter())) {
         return R.failed("请添加标的物");
      }
      if (CollUtil.isEmpty(addDTO.getContractPaymentSchedule())) {
         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.setCenterPushFlag("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());
      contract.setPartyA(bc.getCompanyName());
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())) {
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(), addDTO.getDeliveryCycle()));
      }
      if (ObjUtil.isNotNull(contract.getSignDate()) && ObjUtil.isNotNull(contract.getExpirationDate())) {
         Long bd = DateUtil.betweenDay(contract.getExpirationDate(), contract.getSignDate(), true);
         contract.setDeliveryCycle(bd.intValue());
      }
      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 (CollUtil.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 (CollUtil.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 addContractHis(ContractAddDTO addDTO) {
      Contract contract = BeanUtil.copyProperties(addDTO, Contract.class);
      contract.setPartyBId(SecurityUtils.getUser().getCompId());
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      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())
               && StrUtil.isEmpty(bc.getCreditCode())) {
            return R.failed("请完善客户ERP编码或组织机构代码");
         }
      }

      contract.setBillingStatus("1");
      contract.setErpPushFlag("1");
      contract.setCenterPushFlag("1");
      contract.setContractStatus(2);
      contract.setNickName(SecurityUtils.getUser().getNickname());
      contract.setNextScheduleName("发货前");
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())) {
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(), addDTO.getDeliveryCycle()));
      }

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

      baseMapper.insert(contract);

      if (CollUtil.isNotEmpty(addDTO.getContractSubjectMatter())) {
         addDTO.getContractSubjectMatter().stream().forEach(contractSubjectMatterAddDTO -> {
            ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatterAddDTO, ContractSubjectMatter.class);
            subjectMatter.setContractId(contract.getId());
            subjectMatter.setDeliveredQuantity(ObjUtil.isNull(contractSubjectMatterAddDTO.getDeliveredQuantity())
                  ? new BigDecimal("0") : contractSubjectMatterAddDTO.getDeliveredQuantity());
            subjectMatter.setRemainingQuantity(subjectMatter.getQuantity().subtract(subjectMatter.getDeliveredQuantity()));
            subjectMatter.setDeliveryStatus(subjectMatter.getRemainingQuantity().compareTo(subjectMatter.getQuantity()) == 0 ? 0
                  : subjectMatter.getRemainingQuantity().compareTo(new BigDecimal("0")) > 0 ? 1 : 2);
            subjectMatter.setLineNo(ItemGeneratorUtil.nextId());
            contractSubjectMatterMapper.insert(subjectMatter);
         });
         List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
               .eq(ContractSubjectMatter::getContractId,contract.getId()).ne(ContractSubjectMatter::getDeliveryStatus,2));
         if (CollUtil.isEmpty(subjectMatterList)){
            contract.setNextScheduleName("货到签收");
            baseMapper.updateById(contract);
         }
      }
      BigDecimal remainAmount = ObjUtil.isNotNull(contract.getPaidAmount()) ? contract.getPaidAmount() : new BigDecimal("0");
      if (CollUtil.isNotEmpty(addDTO.getContractPaymentSchedule())) {

         for (int j = 0; j < addDTO.getContractPaymentSchedule().size(); j++) {
            ContractPaymentSchedule schedule = new ContractPaymentSchedule();
            schedule.setStageName(addDTO.getContractPaymentSchedule().get(j).getStageName());
            schedule.setContractId(contract.getId());
            schedule.setPaymentRatio(addDTO.getContractPaymentSchedule().get(j).getPaymentRatio());
            schedule.setAgreedDays(addDTO.getContractPaymentSchedule().get(j).getAgreedDays());
            schedule.setPlannedAmount(contract.getAmount().multiply(schedule.getPaymentRatio())
                  .divide(new BigDecimal("100"), 2, RoundingMode.HALF_UP));
            schedule.setPaymentStatus(0);
            schedule.setStageOrder(j + 1);
            if (remainAmount.compareTo(new BigDecimal("0")) > 0 && schedule.getPlannedAmount().compareTo(new BigDecimal("0")) > 0) {
               remainAmount = remainAmount.subtract(schedule.getPlannedAmount());
               if (remainAmount.compareTo(new BigDecimal("0")) >= 0) {
                  schedule.setPaymentStatus(2);
                  schedule.setActualAmount(schedule.getPlannedAmount());
               }
               if (remainAmount.compareTo(new BigDecimal("0")) < 0) {
                  schedule.setPaymentStatus(1);
                  schedule.setActualAmount(schedule.getPlannedAmount().add(remainAmount));
               }
            }
            contractPaymentScheduleMapper.insert(schedule);
            if (addDTO.getContractPaymentSchedule().get(j).getStageName().equals("货到签收")) {
               contract.setArrivalScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (addDTO.getContractPaymentSchedule().get(j).getStageName().equals("调试完成或验收")) {
               contract.setAcceptScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (addDTO.getContractPaymentSchedule().get(j).getStageName().equals("质保金")) {
               contract.setWarrantyScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         }
      }

      if (contract.getPaidAmount().compareTo(contract.getAmount())==0&&contract.getBillingAmout().compareTo(contract.getAmount())==0){
         contract.setContractStatus(3);
         baseMapper.updateById(contract);
      }
      return R.ok();
   }
}