2025/platformx-business-finance.git

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

			import cn.hutool.core.bean.BeanUtil;
			import cn.hutool.core.collection.CollUtil;
			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 com.baomidou.mybatisplus.core.toolkit.Wrappers;
			@@ -12,7 +12,6 @@
			import com.by4cloud.platformx.business.mapper.*;
			import com.by4cloud.platformx.business.service.ContractPaymentScheduleProcessService;
			import com.by4cloud.platformx.business.vo.ContractPaymentScheduleVo;
			import com.by4cloud.platformx.business.vo.ScheduleProcessVo;
			import com.by4cloud.platformx.common.core.util.R;
			import com.by4cloud.platformx.common.security.util.SecurityUtils;
			import com.github.yulichang.wrapper.MPJLambdaWrapper;
			@@ -45,13 +44,13 @@
			if (ObjUtil.isNull(schedule)) {
			return R.failed("履约阶段与合同不一致，请联系技术人员");
			}
			if (schedule.getStageName().equals("货到签收") && ArrayUtil.isEmpty(addDTO.getContractOutBoundIds().toArray())) {
			if (schedule.getStageName().equals("货到签收") && CollUtil.isEmpty(addDTO.getContractOutBoundIds())) {
			return R.failed("请选择到货的出库信息");
			}
			//合同
			Contract contract = contractMapper.selectById(schedule.getContractId());
			List<ContractSubjectMatter> subjectMatterList = subjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId, contract.getId()));
			if (ArrayUtil.isEmpty(subjectMatterList.toArray())) {
			if (CollUtil.isEmpty(subjectMatterList)) {
			return R.failed("该合同标的物异常，请联系技术人员");
			}
			// if (!subjectMatterList.stream().allMatch(item -> item.getDeliveryStatus() == 2)) {
			@@ -96,8 +95,8 @@
			List<ContractOutBound> contractOutBoundList = contractOutBoundMapper.selectList(Wrappers.<ContractOutBound>lambdaQuery().eq(ContractOutBound::getContractId, contract.getId())
			.isNotNull(ContractOutBound::getArrivalTime));
			if (schedule.getStageName().equals("货到签收")) {
			if (ArrayUtil.isNotEmpty(contractOutBoundList.toArray())
			&& ArrayUtil.isNotEmpty(subjectMatterList.toArray())) {
			if (CollUtil.isNotEmpty(contractOutBoundList)
			&& CollUtil.isNotEmpty(subjectMatterList)) {
			Map<String, BigDecimal> sumMap = contractOutBoundList.stream()
			.collect(Collectors.groupingBy(
			ContractOutBound::getSubjectMatterCode,
			@@ -132,7 +131,7 @@
			//客户付款完成合同
			List<Contract> customerCompleteContractList = contractMapper.selectList(Wrappers.<Contract>lambdaQuery().eq(Contract::getPartyAId, contract.getPartyAId())
			.eq(Contract::getPartyBId, SecurityUtils.getUser().getCompId()).apply(" amount = paid_amount"));
			if (ArrayUtil.isNotEmpty(customerCompleteContractList)){
			if (CollUtil.isNotEmpty(customerCompleteContractList)){
			List<BigDecimal> outAmountList = new ArrayList<>();
			for (Contract completeContract:customerCompleteContractList
			) {
			@@ -151,7 +150,7 @@
			outAmountList.add(outConfirm.getTransationAmount());
			}
			}
			if (ArrayUtil.isNotEmpty(outAmountList.toArray())){
			if (CollUtil.isNotEmpty(outAmountList)){
			BigDecimal currentSum = new BigDecimal("0");
			for (BigDecimal currentAmount:outAmountList
			) {
			@@ -194,7 +193,7 @@
			List<ContractPaymentSchedule> afterSchedule = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
			.eq(ContractPaymentSchedule::getContractId, schedule.getContractId())
			.gt(ContractPaymentSchedule::getStageOrder, schedule.getStageOrder()));
			if (ArrayUtil.isNotEmpty(afterSchedule.toArray()) && afterSchedule.size() == 1) {
			if (CollUtil.isNotEmpty(afterSchedule) && afterSchedule.size() == 1) {
			//最后阶段生效时间
			ContractPaymentSchedule endSchedule = afterSchedule.get(0);
			if (StrUtil.equals(endSchedule.getStageName(), "质保金")) {
			@@ -233,12 +232,12 @@
			contract.setNextScheduleName(endSchedule.getStageName());
			contractMapper.updateById(contract);
			}
			if (ArrayUtil.isNotEmpty(afterSchedule.toArray()) && afterSchedule.size() > 1) {
			if (CollUtil.isNotEmpty(afterSchedule) && afterSchedule.size() > 1) {
			//更新合同下个阶段
			contract.setNextScheduleName(afterSchedule.get(0).getStageName());
			contractMapper.updateById(contract);
			}
			if (ArrayUtil.isEmpty(afterSchedule.toArray())) {
			if (CollUtil.isEmpty(afterSchedule)) {
			// schedule.setEffectiveEndDate(contract.getExpirationDate());
			// contractPaymentScheduleMapper.updateById(schedule);
			//更新合同下个阶段
			@@ -255,7 +254,7 @@
			}
			}
			}
			} else {
			} else if (schedule.getStageName().equals("调试完成或验收")){
			//新增当前阶段应收
			PaymentConfirm currentConfim = new PaymentConfirm();
			currentConfim.setBusinessType(schedule.getStageName() + "应收");
			@@ -294,62 +293,63 @@
			//查询是否有后续阶段
			List<ContractPaymentSchedule> afterSchedule = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
			.eq(ContractPaymentSchedule::getContractId, schedule.getContractId())
			.gt(ContractPaymentSchedule::getStageOrder, schedule.getStageOrder()));
			if (ArrayUtil.isNotEmpty(afterSchedule.toArray()) && afterSchedule.size() == 1) {
			.gt(ContractPaymentSchedule::getStageOrder, schedule.getStageOrder())
			.gt(ContractPaymentSchedule::getPaymentRatio,"0"));
			if (CollUtil.isNotEmpty(afterSchedule) && afterSchedule.size() == 1) {
			//最后阶段生效时间
			ContractPaymentSchedule endSchedule = afterSchedule.get(0);
			if (StrUtil.equals(endSchedule.getStageName(), "质保金")) {
			endSchedule.setEffectiveEndDate(DateUtil.offsetDay(addDTO.getProcessDate(), endSchedule.getAgreedDays()));
			contractPaymentScheduleMapper.updateById(endSchedule);
			//当前阶段生效时间
			schedule.setEffectiveEndDate(DateUtil.offsetDay(addDTO.getProcessDate(), schedule.getAgreedDays()));
			contractPaymentScheduleMapper.updateById(schedule);
			//最后阶段应收
			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(schedule.getStageName());
			newConfim.setConfirmTime(addDTO.getProcessDate());
			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();
			}
			newConfim.setTotalAmount(lastNewTotal.subtract(newConfim.getReceivableAmount()));
			if (endSchedule.getPaymentRatio().compareTo(new BigDecimal("0")) > 0) {
			paymentConfirmMapper.insert(newConfim);
			//更新当前阶段付款情况
			if (lastNewTotal.compareTo(new BigDecimal("0"))>0){
			if (newConfim.getTotalAmount().compareTo(new BigDecimal("0"))>=0) {
			schedule.setPaymentStatus(2);
			schedule.setPlannedAmount(schedule.getPlannedAmount());
			contractPaymentScheduleMapper.updateById(schedule);
			}else {
			schedule.setPaymentStatus(1);
			schedule.setPlannedAmount(lastNewTotal);
			}
			}
			}

			}
			// if (StrUtil.equals(endSchedule.getStageName(), "质保金")) {
			// endSchedule.setEffectiveEndDate(DateUtil.offsetDay(addDTO.getProcessDate(), endSchedule.getAgreedDays()));
			// contractPaymentScheduleMapper.updateById(endSchedule);
			// //当前阶段生效时间
			// schedule.setEffectiveEndDate(DateUtil.offsetDay(addDTO.getProcessDate(), schedule.getAgreedDays()));
			// contractPaymentScheduleMapper.updateById(schedule);
			// //最后阶段应收
			// 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(schedule.getStageName());
			// newConfim.setConfirmTime(addDTO.getProcessDate());
			// 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();
			// }
			// newConfim.setTotalAmount(lastNewTotal.subtract(newConfim.getReceivableAmount()));
			// if (endSchedule.getPaymentRatio().compareTo(new BigDecimal("0")) > 0) {
			// paymentConfirmMapper.insert(newConfim);
			// //更新当前阶段付款情况
			// if (lastNewTotal.compareTo(new BigDecimal("0"))>0){
			// if (newConfim.getTotalAmount().compareTo(new BigDecimal("0"))>=0) {
			// schedule.setPaymentStatus(2);
			// schedule.setPlannedAmount(schedule.getPlannedAmount());
			// contractPaymentScheduleMapper.updateById(schedule);
			// }else {
			// schedule.setPaymentStatus(1);
			// schedule.setPlannedAmount(lastNewTotal);
			// }
			// }
			// }
			//
			// }
			//更新合同下个阶段
			contract.setNextScheduleName(endSchedule.getStageName());
			contractMapper.updateById(contract);
			}
			if (ArrayUtil.isNotEmpty(afterSchedule.toArray()) && afterSchedule.size() > 1) {
			if (CollUtil.isNotEmpty(afterSchedule) && afterSchedule.size() > 1) {
			//更新合同下个阶段
			contract.setNextScheduleName(afterSchedule.get(0).getStageName());
			contractMapper.updateById(contract);
			}
			if (ArrayUtil.isEmpty(afterSchedule.toArray())) {
			if (CollUtil.isEmpty(afterSchedule)) {
			// schedule.setEffectiveEndDate(contract.getExpirationDate());
			// contractPaymentScheduleMapper.updateById(schedule);
			//更新合同下个阶段
			@@ -364,6 +364,45 @@
			contractMapper.updateById(contract);
			}
			}
			}else {

			//最后阶段应收
			PaymentConfirm newConfim = new PaymentConfirm();
			newConfim.setBusinessType(schedule.getStageName() + "应收");
			newConfim.setBusGuestId(contract.getPartyAId());
			newConfim.setBusGuestName(contract.getPartyA());
			newConfim.setContractId(contract.getId());
			newConfim.setContractName(contract.getContractName());
			newConfim.setContractNo(contract.getContractNo());
			newConfim.setScheduleId(schedule.getId());
			newConfim.setScheduleName(schedule.getStageName());
			newConfim.setConfirmTime(addDTO.getProcessDate());
			newConfim.setTransationAmount(schedule.getPlannedAmount());
			newConfim.setReceivableAmount(schedule.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();
			}
			newConfim.setTotalAmount(lastNewTotal.subtract(newConfim.getReceivableAmount()));
			if (schedule.getPaymentRatio().compareTo(new BigDecimal("0")) > 0) {
			paymentConfirmMapper.insert(newConfim);
			//更新当前阶段付款情况
			if (lastNewTotal.compareTo(new BigDecimal("0"))>0){
			if (newConfim.getTotalAmount().compareTo(new BigDecimal("0"))>=0) {
			schedule.setPaymentStatus(2);
			schedule.setPlannedAmount(schedule.getPlannedAmount());
			}else {
			schedule.setPaymentStatus(1);
			schedule.setPlannedAmount(lastNewTotal);
			}
			contractPaymentScheduleMapper.updateById(schedule);
			}
			}
			//更新合同下个阶段
			contract.setNextScheduleName("");
			contractMapper.updateById(contract);
			}