feat:合同编号规则调整 出库编号规则调整

shiyunteng

2 天以前 96119ca3973d5ea643db6a87b6a23fe404ddb8cc

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

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

import java.io.IOException;
@@ -44,12 +48,14 @@
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;

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

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

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

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

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

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

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

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

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

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

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

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

   @Override
   public R add(ContractAddDTO addDTO) {
      Contract contract = BeanUtil.copyProperties(addDTO, Contract.class);
      contract.setPartyBId(SecurityUtils.getUser().getCompId());
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      contract.setContractNo(ContractNumberGenerator.generateContractNumber());

      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingStatus("0");
      contract.setErpPushFlag("0");

      if (StrUtil.isNotEmpty(addDTO.getContractCategory()) && (
            StrUtil.equals(addDTO.getContractCategory(), "ymjgkcpmm")||StrUtil.equals(addDTO.getContractCategory(), "ymjgypmm"))) {
         contract.setExpirationDate(DateUtil.offsetDay(contract.getSignDate(),contract.getDeliveryCycle()));
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(),addDTO.getDeliveryCycle()));
      }
      List<Contract> contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));
      while (ArrayUtil.isNotEmpty(contracts.toArray())) {
         contract.setContractNo(ContractNumberGenerator.generateContractNumber());
         contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));

      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());

         }
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",smj)){
         contract.setContractNo(generateSMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",sgb)){
         contract.setContractNo(generateGYBContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",ymj)){
         contract.setContractNo(generateYMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",tfgs)){
         contract.setContractNo(generateTFContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",jxc)){
         contract.setContractNo(generateJXCContractNo());
      }

      baseMapper.insert(contract);

      if (ArrayUtil.isNotEmpty(addDTO.getContractSubjectMatter())) {
@@ -167,16 +230,39 @@
         return R.failed("当前状态无法修改合同");
      }
      Contract contract = BeanUtil.copyProperties(updateDTO, Contract.class);
      contract.setContractNo(ContractNumberGenerator.generateContractNumber());
      contract.setBillingStatus("0");
      contract.setErpPushFlag("0");
      contract.setPaidAmount(new BigDecimal("0"));
      List<Contract> contracts;
      contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));
      while (ArrayUtil.isNotEmpty(contracts.toArray())) {
         contract.setContractNo(ContractNumberGenerator.generateContractNumber());
         contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, contract.getContractNo()));
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",smj)){
         contract.setContractNo(generateSMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",sgb)){
         contract.setContractNo(generateGYBContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",ymj)){
         contract.setContractNo(generateYMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",tfgs)){
         contract.setContractNo(generateTFContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",jxc)){
         contract.setContractNo(generateJXCContractNo());
      }
      if (ObjUtil.isNotNull(updateDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(updateDTO.getSignDate(),updateDTO.getDeliveryCycle()));
      }
      if (!StrUtil.equals(updateDTO.getContractCategory(), "water_house")){
         // 假设 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())) {
@@ -273,15 +359,15 @@
      Contract contract = baseMapper.selectById(id);
      contract.setContractStatus(2);
      baseMapper.updateById(contract);
      if (StrUtil.isNotEmpty(contract.getContractCategory()) && StrUtil.equals(contract.getContractCategory(), "water_house")) {
         List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
               .eq(ContractSubjectMatter::getContractId,id));

      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
            .eq(ContractSubjectMatter::getContractId,id));
      if (StrUtil.isNotEmpty(contract.getContractCategory()) && StrUtil.equals(contract.getContractCategory(), "water_house")) {
         if (ArrayUtil.isNotEmpty(subjectMatterList.toArray())) {
            subjectMatterList.stream().forEach(contractSubjectMatter -> {
            for (ContractSubjectMatter contractSubjectMatter: subjectMatterList)  {
               if (StrUtil.equals(contract.getExecFrequency(), "1")) {
                  Long weeksTrue = DateUtil.betweenWeek(DateUtil.beginOfWeek(contract.getEffectiveDate()),
                        DateUtil.endOfWeek(contract.getExpirationDate()), true);
                        DateUtil.endOfWeek(contract.getExpirationDate()), true)+1;
                  //循环日期
                  Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfWeek(contract.getEffectiveDate()), contract.getExecDay());
                  for (int i = 0; i < weeksTrue.intValue(); i++) {
@@ -298,7 +384,7 @@
               }
               if (StrUtil.equals(contract.getExecFrequency(), "2")) {
                  Long weeksTrue = DateUtil.betweenMonth(DateUtil.beginOfMonth(contract.getEffectiveDate()),
                        DateUtil.endOfMonth(contract.getExpirationDate()), true);
                        DateUtil.endOfMonth(contract.getExpirationDate()), true)+1;
                  //循环日期
                  Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfMonth(contract.getEffectiveDate()), contract.getExecDay());
                  for (int i = 0; i < weeksTrue.intValue(); i++) {
@@ -314,11 +400,11 @@
                  }
               }
               if (StrUtil.equals(contract.getExecFrequency(), "3")) {
                  Long weeksTrue = DateUtil.betweenMonth(DateUtil.beginOfQuarter(contract.getEffectiveDate()),
                        DateUtil.endOfQuarter(contract.getExpirationDate()), true)/3;
                  Long weeksTrue = (DateUtil.betweenMonth(DateUtil.beginOfQuarter(contract.getEffectiveDate()),
                        DateUtil.endOfQuarter(contract.getExpirationDate()), true)+1)/3;

                  //循环日期
                  Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfWeek(contract.getExpirationDate()), contract.getExecDay());
                  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();
@@ -348,9 +434,9 @@
                  if (7<=endMonth&&endMonth<=12){
                     endDate = DateUtil.endOfYear(endDate);
                  }
                  Long weeksTrue = DateUtil.betweenMonth(startDate,endDate, true)/6;
                  Long weeksTrue = (DateUtil.betweenMonth(startDate,endDate, true)+1)/6;
                  //循环日期
                  Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfWeek(contract.getExpirationDate()), contract.getExecDay());
                  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();
@@ -365,7 +451,7 @@
               }
               if (StrUtil.equals(contract.getExecFrequency(), "5")) {
                  Long weeksTrue = DateUtil.betweenWeek(DateUtil.beginOfYear(contract.getEffectiveDate()),
                        DateUtil.endOfYear(contract.getExpirationDate()), true);
                        DateUtil.endOfYear(contract.getExpirationDate()), true)+1;
                  //循环日期
                  Date execDate0 = DateUtil.offsetDay(DateUtil.beginOfYear(contract.getEffectiveDate()), contract.getExecDay());
                  for (int i = 0; i < weeksTrue.intValue(); i++) {
@@ -381,7 +467,7 @@
                  }
               }

            });
            }
         }
      } else {
         ContractPaymentSchedule fitstSchedule = contractPaymentScheduleMapper.selectOne(Wrappers.<ContractPaymentSchedule>lambdaQuery().eq(ContractPaymentSchedule::getContractId, contract.getId())
@@ -475,6 +561,89 @@
//         contractPaymentScheduleMapper.updateById(fitstSchedule);
//      }
      }
      //erp推送
      JSONObject request = new JSONObject();
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      request.put("contractNo",contract.getContractNo());
      request.put("partyA",contract.getPartyA());
      request.put("partyACode",customer.getErpCompanyCode());

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

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

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

   private void savePaymentConfirm(Contract contract, ContractPaymentSchedule schedule) {
@@ -575,41 +744,43 @@
            overdueConfirm.setScheduleName(contractPaymentSchedule.getStageName());
            PaymentConfirm newLastConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
                  .orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
            overdueConfirm.setTransationAmount(StrUtil.equals(contractPaymentSchedule.getPaymentStatus() + "", "0") ?
                  contractPaymentSchedule.getPlannedAmount() :
                  contractPaymentSchedule.getPlannedAmount().subtract(contractPaymentSchedule.getActualAmount()));
            overdueConfirm.setReceivableAmount(newLastConfirm.getTotalAmount().multiply(new BigDecimal("-1")));
            overdueConfirm.setOverdueAmount(overdueConfirm.getTransationAmount());
            overdueConfirm.setTotalAmount(newLastConfirm.getTotalAmount());
            overdueConfirm.setCompId(contract.getCompId());
            //判断当前阶段是否已生成上阶段应收超期
            PaymentConfirm oiverdueConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getScheduleId, contractPaymentSchedule.getId())
                  .eq(PaymentConfirm::getBusinessType, "应收超期"));
            if (ObjUtil.isNull(oiverdueConfirm) && overdueConfirm.getTransationAmount().compareTo(new BigDecimal("0")) > 0) {
               paymentConfirmMapper.insert(overdueConfirm);
            }
            //当前逾期
            CurrentOverdue currentOverdue = new CurrentOverdue();
            currentOverdue.setBusGuestId(contract.getPartyAId());
            currentOverdue.setBusGuestName(contract.getPartyA());
            currentOverdue.setContractId(contractPaymentSchedule.getContractId());
            currentOverdue.setContractName(contractPaymentSchedule.getContractName());
            currentOverdue.setScheduleId(contractPaymentSchedule.getId());
            currentOverdue.setScheduleName(contractPaymentSchedule.getStageName());
            currentOverdue.setCompId(contract.getCompId());
            currentOverdue.setContractExpirTime(contractPaymentSchedule.getEffectiveEndDate());
            currentOverdue.setReceivableAmount(StrUtil.equals(contractPaymentSchedule.getPaymentStatus() + "", "0") ?
                  contractPaymentSchedule.getPlannedAmount() : contractPaymentSchedule.getPlannedAmount().subtract(contractPaymentSchedule.getActualAmount()));
            currentOverdue.setOverdueDuration(BigDecimal.valueOf(DateUtil.betweenDay(contractPaymentSchedule.getEffectiveEndDate(), new Date(), true)));
            CurrentOverdue overdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getContractId, currentOverdue.getContractId())
                  .eq(CurrentOverdue::getScheduleId, currentOverdue.getScheduleId()).last("limit 1"));
            if (ObjUtil.isNull(overdue)) {
               if (currentOverdue.getReceivableAmount().compareTo(new BigDecimal("0")) > 0) {
                  currentOverdueMapper.insert(currentOverdue);
            if(ObjUtil.isNotNull(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);
               }
            } else {
               overdue.setOverdueDuration(BigDecimal.valueOf(DateUtil.betweenDay(contractPaymentSchedule.getEffectiveEndDate(), new Date(), true)));
               currentOverdueMapper.updateById(overdue);
               //当前逾期
               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);
               }
            }
         });
      }
@@ -628,16 +799,24 @@
   public R copyNewContract(Long id) {
      Contract oldContract = baseMapper.selectById(id);
      Contract newContract = BeanUtil.copyProperties(oldContract, Contract.class, "id", "createTime");
      newContract.setContractNo(ContractNumberGenerator.generateContractNumber());
      newContract.setPaidAmount(new BigDecimal("0"));
      newContract.setBillingStatus("0");
      newContract.setErpPushFlag("0");
      newContract.setContractStatus(0);
      List<Contract> contracts;
      contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, newContract.getContractNo()));
      while (ArrayUtil.isNotEmpty(contracts.toArray())) {
         newContract.setContractNo(ContractNumberGenerator.generateContractNumber());
         contracts = baseMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo, newContract.getContractNo()));
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",smj)){
         newContract.setContractNo(generateSMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",sgb)){
         newContract.setContractNo(generateGYBContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",ymj)){
         newContract.setContractNo(generateYMJContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",tfgs)){
         newContract.setContractNo(generateTFContractNo());
      }
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",jxc)){
         newContract.setContractNo(generateJXCContractNo());
      }
      baseMapper.insert(newContract);
      List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId, id));
@@ -698,7 +877,7 @@
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getCompanyName());
      map.put("companyName", customer.getRegisterName());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
@@ -867,7 +1046,7 @@
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getCompanyName());
      map.put("companyName", customer.getRegisterName());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
@@ -953,7 +1132,7 @@
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getCompanyName());
      map.put("companyName", customer.getRegisterName());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
@@ -1088,7 +1267,7 @@
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getCompanyName());
      map.put("companyName", customer.getRegisterName());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
@@ -1148,6 +1327,8 @@
      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("applyName",SecurityUtils.getUser().getUsername());
      map.put("applyTime",DateUtil.format(delayOut.getApplyTime(),DatePattern.NORM_DATETIME_FORMAT));
@@ -1165,7 +1346,428 @@

   @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 (ArrayUtil.isEmpty(addDTO.getContractSubjectMatter().toArray())){
         return R.failed("请添加标的物");
      }
      if (ArrayUtil.isEmpty(addDTO.getContractPaymentSchedule().toArray())){
         return R.failed("请添加付款阶段或付款阶段缺少");
      }
      if (!isValidPaymentStages(addDTO.getContractPaymentSchedule())){
         return R.failed("付款阶段信息异常");
      }
      if (addDTO.getContractPaymentSchedule().stream().map(item->item.getPaymentRatio()).reduce(BigDecimal.ZERO,BigDecimal::add)
            .compareTo(new BigDecimal("100.00"))!=0){
         return R.failed("付款阶段比例异常");
      }
      Contract contract = BeanUtil.copyProperties(addDTO, Contract.class);
      contract.setErpContractNo(contract.getContractNo());
      contract.setPartyBId(SecurityUtils.getUser().getCompId());
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      contract.setContractStatus(2);
      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingStatus("0");
      contract.setErpPushFlag("1");
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(),addDTO.getDeliveryCycle()));
      }

      contract.setContractNo(generateGYBContractNo());

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

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

         }
      }
      baseMapper.insert(contract);

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

      }

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

      }


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

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

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

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

         }
      }
      baseMapper.updateById(contract);

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

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

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

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

      }

      return R.ok();
   }

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

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

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

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

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

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

   /**
    * 生成格式为: 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;
   }

}