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

shiyunteng

8 小时以前 e02812df9217d3e50a368a8234c07c60c64c0ff4

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

@@ -25,6 +25,9 @@
import com.by4cloud.platformx.business.service.ContractService;
import com.by4cloud.platformx.business.utils.ItemGeneratorUtil;
import com.by4cloud.platformx.business.vo.ContractDetailVo;
import com.by4cloud.platformx.business.vo.ContractInvoiceVo;
import com.by4cloud.platformx.business.vo.ContractSlipVo;
import com.by4cloud.platformx.business.vo.FourAssociationPageVo;
import com.by4cloud.platformx.common.core.util.R;
import com.by4cloud.platformx.common.data.datascope.DataScope;
import com.by4cloud.platformx.common.security.util.SecurityUtils;
@@ -73,13 +76,12 @@
   private final RemoteDeptService remoteDeptService;
   private final ContractDelayOutMapper contractDelayOutMapper;
   private final ErpRequestRecordMapper erpRequestRecordMapper;
   private final PaymentSlipMapper paymentSlipMapper;
   private final ContractInvoiceMapper contractInvoiceMapper;
   private final StringRedisTemplate redisTemplate;

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

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

   @Value("${erp.smj}")
   private String smjErp;
@@ -118,17 +120,29 @@
         if (ObjUtil.isNotNull(bc)){
            contract.setPartyA(bc.getCompanyName());
         }
         if (!StrUtil.equals(SecurityUtils.getUser().getCompId()+"",sgb)&&StrUtil.isEmpty(bc.getErpCompanyCode())){
            return R.failed("请完善客户ERP编码");
         }
      }

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

      contract.setNickName(SecurityUtils.getUser().getNickname());
      if (ObjUtil.isNotNull(addDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(addDTO.getSignDate(),addDTO.getDeliveryCycle()));
      }

      if (!StrUtil.equals(addDTO.getContractCategory(), "water_house")){
      if (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
@@ -139,6 +153,11 @@

         }
      }

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

      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",smj)){
         contract.setContractNo(generateSMJContractNo());
      }
@@ -154,14 +173,20 @@
      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())) {
         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()));
@@ -221,6 +246,10 @@
               contract.setAcceptScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("质保金")) {
               contract.setWarrantyScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         });

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

      Contract contract = BeanUtil.copyProperties(updateDTO, Contract.class);
      contract.setBillingStatus("0");
      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)){
         contract.setContractNo(generateSMJContractNo());
      }
@@ -257,7 +299,17 @@
      if (ObjUtil.isNotNull(updateDTO.getDeliveryCycle())){
         contract.setExpirationDate(DateUtil.offsetDay(updateDTO.getSignDate(),updateDTO.getDeliveryCycle()));
      }
      if (!StrUtil.equals(updateDTO.getContractCategory(), "water_house")){
      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
@@ -268,7 +320,6 @@

         }
      }

      baseMapper.updateById(contract);

      if (ArrayUtil.isNotEmpty(updateDTO.getContractSubjectMatter())) {
@@ -277,9 +328,10 @@
         updateDTO.getContractSubjectMatter().stream().forEach(contractSubjectMatterAddDTO -> {
            ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatterAddDTO, ContractSubjectMatter.class);
            subjectMatter.setContractId(contract.getId());
            subjectMatter.setContractName(contract.getContractName());
            subjectMatter.setLineNo(ItemGeneratorUtil.nextId());
            subjectMatter.setDeliveredQuantity(new BigDecimal("0"));
            subjectMatter.setDeliveryStatus(0);
            subjectMatter.setTotalAmount(contractSubjectMatterAddDTO.getQuantity().multiply(contractSubjectMatterAddDTO.getUnitPrice()));
            contractSubjectMatterMapper.insert(subjectMatter);
            //水电类必须有初次表号
            if (StrUtil.isNotEmpty(contractSubjectMatterAddDTO.getMeterReadCode()) &&
@@ -320,6 +372,10 @@
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("调试完成或验收")) {
               contract.setAcceptScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
            if (contractPaymentScheduleAddDTO.getStageName().equals("质保金")) {
               contract.setWarrantyScheduleId(schedule.getId());
               baseMapper.updateById(contract);
            }
         });
@@ -568,12 +624,14 @@
//      }
      }
      //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");
@@ -581,12 +639,12 @@
         request.put("dateDeliver",DateUtil.format(contract.getExpirationDate(),DatePattern.NORM_DATETIME_PATTERN));
         request.put("moneySum",contract.getAmount());
         request.put("signManner","面签");
         request.put("salesman",contract.getCreateBy());
               request.put("salesman","");
         if (ArrayUtil.isNotEmpty(subjectMatterList.toArray())){
            JSONArray subjectMatter = new JSONArray();
            subjectMatterList.stream().forEach(contractSubjectMatter -> {
               JSONObject subjectMatterItem = new JSONObject();
               subjectMatterItem.put("itemNo",ItemGeneratorUtil.nextId());
                     subjectMatterItem.put("itemNo",contractSubjectMatter.getMaterialCode());
               subjectMatterItem.put("salePrice",contractSubjectMatter.getUnitPrice());
               subjectMatterItem.put("qtyRequired",contractSubjectMatter.getQuantity());
               subjectMatterItem.put("money",contractSubjectMatter.getQuantity().multiply(contractSubjectMatter.getUnitPrice()));
@@ -602,9 +660,19 @@
            });
            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)
               .header("token", ymjToken)       // 添加认证头
                  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());
@@ -615,9 +683,11 @@
         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());
               String result = HttpUtil.post(smjErp,request.toJSONString());
         log.info("石煤机合同推送erp回参：{}",result);
         //保存请求记录
         saveErpRequestRecord("smj",request.toJSONString(),result);
@@ -628,7 +698,7 @@

      if (StrUtil.equals(contract.getPartyBId()+"",jxc)&&StrUtil.isNotEmpty(jxcErp)){
         log.info("机械厂合同推送erp入参：{}",request.toJSONString());
         String result = HttpUtil.post(ymjErp,request.toJSONString());
               String result = HttpUtil.post(jxcErp,request.toJSONString());
         log.info("机械厂合同推送erp回参：{}",result);
         //保存请求记录
         saveErpRequestRecord("jxc",request.toJSONString(),result);
@@ -642,6 +712,36 @@
      if (StrUtil.equals(contract.getPartyBId()+"",sgb)&&StrUtil.isNotEmpty(sgbErp)){
         //石工泵主动推送系统
      }
         } catch (Exception e) {
            e.printStackTrace();
         }
      }).start();
      //合同中心推送
      new Thread(()->{
         try {
            JSONObject request = new JSONObject();
            request.put("fd_docNumber",contract.getContractNo());
            request.put("fd_singer",contract.getNickName());
            request.put("fd_signTime",DateUtil.formatDate(contract.getSignDate()));
            request.put("fd_linkPerson","");
            request.put("fd_linkPhone","");
            request.put("fd_address",contract.getSignPlace());
            request.put("fd_receivedTime",DateUtil.format(contract.getCreateTime(),DatePattern.NORM_DATETIME_PATTERN));
            request.put("fd_receivedNum",1);
            request.put("fd_effedate",DateUtil.formatDate(contract.getEffectiveDate()));
            request.put("fd_enddate",DateUtil.formatDate(contract.getExpirationDate()));
            request.put("fd_reviewerNo",contract.getNickName());
            request.put("fd_docStatus","20");
            request.put("fd_templateId","");
            request.put("fd_attName",contract.getAttachmentName());
            request.put("fd_attcontent",contract.getAttachmentName());
            log.info("合同中心同步合同接口入参：{}",request.toJSONString());
            String resp = HttpUtil.post("https://oatest.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addContractReview",request.toJSONString());
            log.info("合同中心同步合同接口回参：{}",resp);
         } catch (Exception e) {
            e.printStackTrace();
         }
      }).start();
   }

   private void saveErpRequestRecord(String ymj, String toJSONString, String result) {
@@ -686,7 +786,7 @@
            PaymentConfirm contractLastConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, completeContract.getId())
                  .orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
            //查询客户付款完成合同中最后明细金额 有预收转入当前合同
            if (contractLastConfirm.getTotalAmount().compareTo(new BigDecimal("0")) > 0) {
            if (ObjUtil.isNotNull(contractLastConfirm)&&contractLastConfirm.getTotalAmount().compareTo(new BigDecimal("0")) > 0) {
               //新增完成付款合同 资金转出
               PaymentConfirm outConfirm = BeanUtil.copyProperties(contractLastConfirm, PaymentConfirm.class, "id", "transationAmount",
                     "advanceAmount", "receivableAmount", "overdueAmount", "totalAmount");
@@ -737,6 +837,7 @@
      if (ArrayUtil.isNotEmpty(scheduleList.toArray())) {
         scheduleList.stream().forEach(contractPaymentSchedule -> {
            Contract contract = baseMapper.selectById(contractPaymentSchedule.getContractId());
            if (ObjUtil.isNotNull(contract)) {
            //应收超期
            PaymentConfirm overdueConfirm = new PaymentConfirm();
            overdueConfirm.setBusinessType("应收超期");
@@ -788,6 +889,7 @@
                  currentOverdueMapper.updateById(overdue);
               }
            }
            }
         });
      }
      return R.ok();
@@ -806,9 +908,10 @@
      Contract oldContract = baseMapper.selectById(id);
      Contract newContract = BeanUtil.copyProperties(oldContract, Contract.class, "id", "createTime");
      newContract.setPaidAmount(new BigDecimal("0"));
      newContract.setBillingStatus("0");
      newContract.setBillingStatus("1");
      newContract.setErpPushFlag("0");
      newContract.setContractStatus(0);
      newContract.setBillingAmout(new BigDecimal("0"));
      if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"",smj)){
         newContract.setContractNo(generateSMJContractNo());
      }
@@ -883,7 +986,7 @@
      map.put("items", items);
      //定制方
      BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
      map.put("companyName", customer.getRegisterName());
      map.put("companyName", contract.getPartyA());
      map.put("legalPerson", customer.getLegalPerson());
      map.put("contactPhone", customer.getContactPhone());
      map.put("bankName", customer.getBankName());
@@ -947,6 +1050,7 @@
            if (StrUtil.isNotEmpty(subjectMatter.getMeterReadCode()) &&
                  ObjUtil.isNotNull(subjectMatter.getMeterReadNum())) {
               MeterReadRecord record = BeanUtil.copyProperties(subjectMatter, MeterReadRecord.class, "id","meterReadNum");
               record.setContractName(contract.getContractName());
               record.setMatterId(subjectMatter.getId());
               record.setBusGuestId(contract.getPartyAId());
               record.setBusGuestName(contract.getPartyA());
@@ -970,6 +1074,10 @@
               schedule.setPaymentStatus(0);
               schedule.setActualAmount(new BigDecimal("0"));
               schedule.setCompId(contract.getCompId());
               schedule.setSubjectMatterCode(subjectMatter.getMaterialCode());
               schedule.setSubjectMatterName(subjectMatter.getMaterialInternalName());
               schedule.setRemark(DateUtil.formatDate(contractExecDate.getExecDate())+schedule.getStageName());
               schedule.setInvoiceFlag("0");
               contractPaymentScheduleMapper.insert(schedule);
               //房屋租赁生成应收
               PaymentConfirm confirm = new PaymentConfirm();
@@ -1336,6 +1444,7 @@
      map.put("partyA",contract.getPartyA());
      map.put("partyB",contract.getPartyB());
      map.put("delayDay",dto.getDelayDay());
      map.put("contractNo",contract.getContractNo());
      map.put("applyName",SecurityUtils.getUser().getUsername());
      map.put("applyTime",DateUtil.format(delayOut.getApplyTime(),DatePattern.NORM_DATETIME_FORMAT));
      //启动流程
@@ -1460,8 +1569,16 @@
      contract.setPartyB(SecurityUtils.getUser().getCompName());
      contract.setContractStatus(2);
      contract.setPaidAmount(new BigDecimal("0"));
      contract.setBillingStatus("0");
      contract.setBillingStatus("1");
      contract.setErpPushFlag("1");
      contract.setBillingAmout(new BigDecimal("0"));

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


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

   @Override
@@ -1569,7 +1686,12 @@
         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()));
      }
@@ -1592,7 +1714,7 @@
         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);
@@ -1776,4 +1898,263 @@
      return "ZB-GYB-"+dateStr + seqStr;
   }

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

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

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

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

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

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

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

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

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

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



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

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

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

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

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