From e02812df9217d3e50a368a8234c07c60c64c0ff4 Mon Sep 17 00:00:00 2001
From: shiyunteng <shiyunteng@example.com>
Date: 星期三, 05 八月 2026 08:34:26 +0800
Subject: [PATCH] feat:新增石煤机 机械厂模版合同/客户数据主数据同步接口/合同履约进度新增质保结束操作/合同开票状态 修改为待开 可开 已开/出库逻辑完善

---
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java |  644 ++++++++++++++++++++++++++++++----------------------------
 1 files changed, 336 insertions(+), 308 deletions(-)

diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java
index 675784b..43eec9f 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java
@@ -62,6 +62,7 @@
 	private final PaymentSlipMapper paymentSlipMapper;
 	private final BipRequestRecordMapper bipRequestRecordMapper;
 	private final ContractExecDateMapper contractExecDateMapper;
+	private final MeterReadRecordMapper meterReadRecordMapper;
 	private final RemoteDeptService remoteDeptService;
 	private final RedisTemplate redisTemplate;
 
@@ -84,9 +85,7 @@
 			if (ObjUtil.isNull(contract)) {
 				return R.failed("鍚堝悓鏌ヨ澶辫触锛岃妫�鏌ュ悎鍚岀紪鍙�");
 			}
-			BusinessCustomer customer = businessCustomerService.getOne(Wrappers.<BusinessCustomer>lambdaQuery()
-					.eq(StrUtil.isNotBlank(addDTO.getBusGuestName()), BusinessCustomer::getRegisterName, addDTO.getBusGuestName())
-					.eq(StrUtil.isNotBlank(addDTO.getBusGuestId()), BusinessCustomer::getId, addDTO.getBusGuestId()));
+			BusinessCustomer customer = businessCustomerService.getById(contract.getPartyAId());
 			if (ObjUtil.isNull(customer)) {
 				return R.failed("瀹㈠晢鏌ヨ澶辫触锛岃妫�鏌ュ鍟�");
 			}
@@ -98,8 +97,21 @@
 				lastTotal = lastConfirm.getTotalAmount();
 			}
 
+
 			//杞叆
 			if (StrUtil.equals(addDTO.getInOrOut(), "1")) {
+
+
+				//鏂板浠樻鍗�
+				PaymentSlip slip = new PaymentSlip();
+				slip.setBusGuestId(customer.getId());
+				slip.setBusGuestName(customer.getRegisterName());
+				slip.setPayeeCompId(SecurityUtils.getUser().getCompId());
+				slip.setPaymentTime(addDTO.getConfirmTime());
+				slip.setPaymentAmount(addDTO.getTransationAmount());
+				slip.setPayType(addDTO.getPayType());
+				paymentSlipMapper.insert(slip);
+
 				BigDecimal newtotal = addDTO.getTransationAmount().add(lastTotal);
 				PaymentConfirm entity = new PaymentConfirm();
 				entity.setContractId(contract.getId());
@@ -130,60 +142,61 @@
 					entity.setConfirmTime(new Date());
 					baseMapper.insert(entity);
 				}
-				//鏇存柊浠樻闃舵浠樻
-				List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
-						.eq(ContractPaymentSchedule::getContractId, contract.getId()).ne(ContractPaymentSchedule::getPaymentStatus, 2).ne(ContractPaymentSchedule::getPaymentStatus, 3)
-						.orderByAsc(ContractPaymentSchedule::getCreateTime));
-				if (ArrayUtil.isNotEmpty(scheduleList.toArray())) {
-					BigDecimal remain = addDTO.getTransationAmount();
-					for (ContractPaymentSchedule schedule : scheduleList) {
-						BigDecimal lastRemain = remain;
-						remain = remain.subtract(StrUtil.equals(schedule.getPaymentStatus() + "", "0") ? schedule.getPlannedAmount() :
-								schedule.getPlannedAmount().subtract(schedule.getActualAmount()));
-						if (remain.compareTo(new BigDecimal("0")) >= 0) {
-							schedule.setActualAmount(schedule.getPlannedAmount());
-							schedule.setPaymentDate(addDTO.getConfirmTime());
-							schedule.setPaymentStatus(2);
-							contractPaymentScheduleMapper.updateById(schedule);
-							//鏌ヨ鏄惁鏈夊綋鍓嶉�炬湡
-							CurrentOverdue currentOverdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getScheduleId, schedule.getId())
-									.eq(CurrentOverdue::getContractId, schedule.getContractId()).last("limit 1"));
-							if (ObjUtil.isNotNull(currentOverdue)) {
-								//鏂板閫炬湡鍘嗗彶
-								HistoryOverdue historyOverdue = BeanUtil.copyProperties(currentOverdue, HistoryOverdue.class, "id");
-								historyOverdue.setPaymentTime(addDTO.getConfirmTime());
-								historyOverdue.setCompId(schedule.getCompId());
-								historyOverdueMapper.insert(historyOverdue);
-								//鍒犻櫎褰撳墠閫炬湡
-								currentOverdueMapper.deleteById(currentOverdue);
+
+					//鏇存柊浠樻闃舵浠樻
+					List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
+							.eq(ContractPaymentSchedule::getContractId, contract.getId()).ne(ContractPaymentSchedule::getPaymentStatus, 2).ne(ContractPaymentSchedule::getPaymentStatus, 3)
+							.orderByAsc(ContractPaymentSchedule::getCreateTime));
+					if (ArrayUtil.isNotEmpty(scheduleList.toArray())) {
+						BigDecimal remain = addDTO.getTransationAmount();
+						for (ContractPaymentSchedule schedule : scheduleList) {
+							BigDecimal lastRemain = remain;
+							remain = remain.subtract(StrUtil.equals(schedule.getPaymentStatus() + "", "0") ? schedule.getPlannedAmount() :
+									schedule.getPlannedAmount().subtract(schedule.getActualAmount()));
+							if (remain.compareTo(new BigDecimal("0")) >= 0) {
+								schedule.setActualAmount(schedule.getPlannedAmount());
+								schedule.setPaymentDate(addDTO.getConfirmTime());
+								schedule.setPaymentStatus(2);
+								contractPaymentScheduleMapper.updateById(schedule);
+								//鏌ヨ鏄惁鏈夊綋鍓嶉�炬湡
+								CurrentOverdue currentOverdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getScheduleId, schedule.getId())
+										.eq(CurrentOverdue::getContractId, schedule.getContractId()).last("limit 1"));
+								if (ObjUtil.isNotNull(currentOverdue)) {
+									//鏂板閫炬湡鍘嗗彶
+									HistoryOverdue historyOverdue = BeanUtil.copyProperties(currentOverdue, HistoryOverdue.class, "id");
+									historyOverdue.setPaymentTime(addDTO.getConfirmTime());
+									historyOverdue.setCompId(schedule.getCompId());
+									historyOverdueMapper.insert(historyOverdue);
+									//鍒犻櫎褰撳墠閫炬湡
+									currentOverdueMapper.deleteById(currentOverdue);
+								}
+							} else {
+								schedule.setActualAmount(StrUtil.equals(schedule.getPaymentStatus() + "", "0") ? schedule.getPlannedAmount().add(remain) :
+										schedule.getActualAmount().add(lastRemain));
+								schedule.setPaymentDate(addDTO.getConfirmTime());
+								schedule.setPaymentStatus(1);
+								contractPaymentScheduleMapper.updateById(schedule);
+								//鏌ヨ鏄惁鏈夊綋鍓嶉�炬湡
+								CurrentOverdue currentOverdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getScheduleId, schedule.getId())
+										.eq(CurrentOverdue::getContractId, schedule.getContractId()).last("limit 1"));
+								if (ObjUtil.isNotNull(currentOverdue)) {
+									//鏂板閫炬湡鍘嗗彶
+									HistoryOverdue historyOverdue = BeanUtil.copyProperties(currentOverdue, HistoryOverdue.class, "id");
+									historyOverdue.setReceivableAmount(lastRemain);
+									historyOverdue.setPaymentTime(addDTO.getConfirmTime());
+									historyOverdue.setCompId(schedule.getCompId());
+									historyOverdueMapper.insert(historyOverdue);
+									//鏇存柊褰撳墠閫炬湡
+									currentOverdue.setReceivableAmount(schedule.getPlannedAmount().subtract(schedule.getActualAmount()));
+									currentOverdueMapper.updateById(currentOverdue);
+								}
+								break;
 							}
-						} else {
-							schedule.setActualAmount(StrUtil.equals(schedule.getPaymentStatus() + "", "0") ? schedule.getPlannedAmount().add(remain) :
-									schedule.getActualAmount().add(lastRemain));
-							schedule.setPaymentDate(addDTO.getConfirmTime());
-							schedule.setPaymentStatus(1);
-							contractPaymentScheduleMapper.updateById(schedule);
-							//鏌ヨ鏄惁鏈夊綋鍓嶉�炬湡
-							CurrentOverdue currentOverdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getScheduleId, schedule.getId())
-									.eq(CurrentOverdue::getContractId, schedule.getContractId()).last("limit 1"));
-							if (ObjUtil.isNotNull(currentOverdue)) {
-								//鏂板閫炬湡鍘嗗彶
-								HistoryOverdue historyOverdue = BeanUtil.copyProperties(currentOverdue, HistoryOverdue.class, "id");
-								historyOverdue.setReceivableAmount(lastRemain);
-								historyOverdue.setPaymentTime(addDTO.getConfirmTime());
-								historyOverdue.setCompId(schedule.getCompId());
-								historyOverdueMapper.insert(historyOverdue);
-								//鏌ヨ鍘嗗彶宸蹭粯閫炬湡閲戦
-								List<HistoryOverdue> historyOverdueList = historyOverdueMapper.selectList(Wrappers.<HistoryOverdue>lambdaQuery().eq(HistoryOverdue::getScheduleId, currentOverdue.getScheduleId()));
-								BigDecimal hisTotal = historyOverdueList.stream().map(item -> item.getReceivableAmount()).reduce(BigDecimal.ZERO, BigDecimal::add);
-								//鏇存柊褰撳墠閫炬湡
-								currentOverdue.setReceivableAmount(schedule.getPlannedAmount().subtract(hisTotal));
-								currentOverdueMapper.updateById(currentOverdue);
-							}
-							break;
 						}
 					}
 				}
+			//闈炴埧灞嬬璧� 姘寸數
+			if (!StrUtil.equals(contract.getContractCategory(), "water_house")) {
 				//鏇存柊鍚堝悓宸蹭粯娆�
 				BigDecimal paid = new BigDecimal("0");
 				if (ObjUtil.isNotNull(contract.getPaidAmount())) {
@@ -191,10 +204,31 @@
 				}
 				paid = paid.add(addDTO.getTransationAmount());
 				contract.setPaidAmount(paid);
-				if (paid.compareTo(contract.getAmount()) > 0) {
+				if (paid.compareTo(contract.getAmount()) == 0) {
+					contract.setContractStatus(3);
 					contract.setPaidAmount(contract.getAmount());
 				}
 				contractService.updateById(contract);
+			}else {
+				List<ContractExecDate> execDateList = contractExecDateMapper.selectList(Wrappers.<ContractExecDate>lambdaQuery().eq(ContractExecDate::getContractId,contract.getId())
+						.eq(ContractExecDate::getGenFlag,"0"));
+				List<MeterReadRecord> recordList = meterReadRecordMapper.selectList(Wrappers.<MeterReadRecord>lambdaQuery()
+						.eq(MeterReadRecord::getContractId,contract.getId())
+						.isNull(MeterReadRecord::getMeterReadNum));
+				if (ArrayUtil.isEmpty(execDateList.toArray())&&ArrayUtil.isEmpty(recordList.toArray())){
+					//鏇存柊鍚堝悓宸蹭粯娆�
+					BigDecimal paid = new BigDecimal("0");
+					if (ObjUtil.isNotNull(contract.getPaidAmount())) {
+						paid = contract.getPaidAmount();
+					}
+					paid = paid.add(addDTO.getTransationAmount());
+					contract.setPaidAmount(paid);
+					if (contract.getAmount().compareTo(new BigDecimal("0"))==0&&paid.compareTo(contract.getAmount()) >= 0) {
+						contract.setContractStatus(3);
+						contract.setPaidAmount(contract.getAmount());
+					}
+					contractService.updateById(contract);
+				}
 			}
 			//杞嚭
 			if (StrUtil.equals(addDTO.getInOrOut(), "2")) {
@@ -219,209 +253,203 @@
 				entity.setConfirmTime(new Date());
 				baseMapper.insert(entity);
 			}
-			// 鏌ヨ鎵�鏈変粯娆鹃樁娈垫槸鍚﹂兘浠樻瀹屾垚
-			List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery().eq(ContractPaymentSchedule::getContractId, contract.getId()));
-			if (ArrayUtil.isNotEmpty(scheduleList.toArray())) {
-				if (scheduleList.stream().allMatch(item -> Objects.equals(item.getPaymentStatus(), 2))) {
-					contract.setContractStatus(3);
-					contractService.updateById(contract);
-				}
-				;
-			}
-		}else {
 
-			List<Contract> customerContractList = contractService.list(Wrappers.<Contract>lambdaQuery().eq(Contract::getPartyAId, addDTO.getBusGuestId())
-					.eq(Contract::getPartyBId,SecurityUtils.getUser().getCompId()).orderByAsc(Contract::getCreateTime).apply(" amount != paid_amount"));
-			if (ArrayUtil.isEmpty(customerContractList.toArray())) {
-				return R.failed("涓烘煡璇㈠埌鏈粯娆惧悎鍚�");
-			}
-			BusinessCustomer customer = businessCustomerService.getOne(Wrappers.<BusinessCustomer>lambdaQuery()
-					.eq(StrUtil.isNotBlank(addDTO.getBusGuestName()), BusinessCustomer::getRegisterName, addDTO.getBusGuestName())
-					.eq(ObjUtil.isNotNull(addDTO.getBusGuestId()), BusinessCustomer::getId, addDTO.getBusGuestId())
-					.last("limit 1"));
-			if (ObjUtil.isNull(customer)) {
-				return  R.failed("瀹㈠晢鏌ヨ澶辫触");
-			}
-			//鏂板浠樻鍗�
-			PaymentSlip slip = new PaymentSlip();
-			slip.setBusGuestId(customer.getId());
-			slip.setBusGuestName(customer.getRegisterName());
-			slip.setPayeeCompId(SecurityUtils.getUser().getCompId());
-			slip.setPaymentTime(addDTO.getConfirmTime());
-			slip.setPaymentAmount(addDTO.getTransationAmount());
-			slip.setPayType(addDTO.getPayType());
-			paymentSlipMapper.insert(slip);
-
-			BigDecimal transtionAmount = addDTO.getTransationAmount();
-			//鍓╀綑浠樻
-			BigDecimal transtionRemainAmount = transtionAmount;
-			//鏀跺埌浠樻鐨勫悎鍚�
-			List<Contract> payContractList = new ArrayList<>();
-			//浠樻瀹屾垚鐨勫悎鍚�
-			List<Contract> payCompleteContractList = new ArrayList<>();
-			//浠樻鏈畬鎴愮殑鍚堝悓
-			List<Contract> payNoCompleteContractList = new ArrayList<>();
-			//鏈夐浠樻鐨勫悎鍚�
-			List<Contract> advanceContractList = new ArrayList<>();
-			//浠樻鏃堕棿
-			Date payDate = addDTO.getConfirmTime();
-			Iterator<Contract> iterator = customerContractList.iterator();
-			while (iterator.hasNext()) {
-				Contract contract = iterator.next();
-				PaymentConfirm lastConfirm = baseMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
-						.orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
-				BigDecimal lastTotal = new BigDecimal("0");
-				if (ObjUtil.isNotNull(lastConfirm)) {
-					lastTotal = lastConfirm.getTotalAmount();
-				}else {
-
-				}
-
-				//鍚堝悓鏈�杩戞槑缁嗘�婚涓�0 鎴� > 0 鎯呭喌涓�
-				if (lastTotal.compareTo(new BigDecimal("0")) >= 0) {
-					log.info("褰撳墠鍚堝悓鍙凤細{},鏄庣粏鎬婚鏃犲簲鏀舵", contract.getContractNo());
-					advanceContractList.add(contract);
-					if (iterator.hasNext()) {
-						continue;
-					}
-				}
-
-				transtionRemainAmount = transtionRemainAmount.add(lastTotal);
-				PaymentConfirm entity = new PaymentConfirm();
-				entity.setContractId(contract.getId());
-				entity.setContractName(contract.getContractName());
-				entity.setContractNo(contract.getContractNo());
-				if (ObjUtil.isNotNull(lastConfirm)) {
-					entity.setScheduleId(lastConfirm.getScheduleId());
-					entity.setScheduleName(lastConfirm.getScheduleName());
-				}
-				entity.setBusGuestId(customer.getId());
-				entity.setBusGuestName(customer.getRegisterName());
-				entity.setBusinessType("瀹㈡埛浠樻");
-				if (transtionRemainAmount.compareTo(new BigDecimal("0")) > 0) {
-					entity.setConfirmTime(payDate);
-					// 鍒ゆ柇鏄惁鏄渶鍚庝竴涓�
-					if (!iterator.hasNext()) {
-						entity.setTransationAmount(transtionRemainAmount.subtract(lastTotal));
-						entity.setAdvanceAmount(transtionRemainAmount);
-						entity.setTotalAmount(transtionRemainAmount);
-					}else {
-						entity.setTransationAmount(lastTotal.multiply(new BigDecimal("-1")));
-						entity.setTotalAmount(new BigDecimal("0"));
-					}
-					baseMapper.insert(entity);
-					payContractList.add(contract);
-				} else if (transtionRemainAmount.compareTo(new BigDecimal("0")) == 0) {
-					entity.setTransationAmount(lastTotal.multiply(new BigDecimal("-1")));
-					entity.setTotalAmount(new BigDecimal("0"));
-					entity.setConfirmTime(payDate);
-					baseMapper.insert(entity);
-					payContractList.add(contract);
-					break;
-				} else {
-					entity.setTransationAmount(transtionRemainAmount.subtract(lastTotal));
-					entity.setReceivableAmount(transtionRemainAmount.multiply(new BigDecimal("-1")));
-					entity.setTotalAmount(transtionRemainAmount);
-					entity.setConfirmTime(payDate);
-					baseMapper.insert(entity);
-					payContractList.add(contract);
-					break;
-				}
-			}
-
-			payContractList.stream().forEach(contract -> {
-				//鏇存柊浠樻闃舵浠樻
-				List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
-						.eq(ContractPaymentSchedule::getContractId, contract.getId()).ne(ContractPaymentSchedule::getPaymentStatus, 2)
-						.ne(ContractPaymentSchedule::getPaymentStatus, 3)
-						.orderByAsc(ContractPaymentSchedule::getCreateTime));
-				if (ArrayUtil.isNotEmpty(scheduleList.toArray())) {
-					BigDecimal remain = transtionAmount;
-					for (ContractPaymentSchedule schedule : scheduleList) {
-						BigDecimal lastRemain = remain;
-						remain = lastRemain.subtract(StrUtil.equals(schedule.getPaymentStatus() + "", "0") ? schedule.getPlannedAmount() :
-								schedule.getPlannedAmount().subtract(schedule.getActualAmount()));
-						if (remain.compareTo(new BigDecimal("0")) >= 0) {
-							schedule.setActualAmount(schedule.getPlannedAmount());
-							schedule.setPaymentDate(payDate);
-							schedule.setPaymentStatus(2);
-							contractPaymentScheduleMapper.updateById(schedule);
-							//鏌ヨ鏄惁鏈夊綋鍓嶉�炬湡
-							CurrentOverdue currentOverdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getScheduleId, schedule.getId())
-									.eq(CurrentOverdue::getContractId, schedule.getContractId()).last("limit 1"));
-							if (ObjUtil.isNotNull(currentOverdue)) {
-								//鏂板閫炬湡鍘嗗彶
-								HistoryOverdue historyOverdue = BeanUtil.copyProperties(currentOverdue, HistoryOverdue.class, "id");
-								historyOverdue.setPaymentTime(payDate);
-								historyOverdue.setCompId(schedule.getCompId());
-								historyOverdueMapper.insert(historyOverdue);
-								//鍒犻櫎褰撳墠閫炬湡
-								currentOverdueMapper.deleteById(currentOverdue);
-							}
-						} else {
-							schedule.setActualAmount(StrUtil.equals(schedule.getPaymentStatus() + "", "0") ? schedule.getPlannedAmount().add(remain) :
-									schedule.getActualAmount().add(lastRemain));
-							schedule.setPaymentDate(payDate);
-							schedule.setPaymentStatus(1);
-							contractPaymentScheduleMapper.updateById(schedule);
-							//鏌ヨ鏄惁鏈夊綋鍓嶉�炬湡
-							CurrentOverdue currentOverdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getScheduleId, schedule.getId())
-									.eq(CurrentOverdue::getContractId, schedule.getContractId()).last("limit 1"));
-							if (ObjUtil.isNotNull(currentOverdue)) {
-								//鏂板閫炬湡鍘嗗彶
-								HistoryOverdue historyOverdue = BeanUtil.copyProperties(currentOverdue, HistoryOverdue.class, "id");
-								historyOverdue.setReceivableAmount(lastRemain);
-								historyOverdue.setPaymentTime(payDate);
-								historyOverdue.setCompId(schedule.getCompId());
-								historyOverdueMapper.insert(historyOverdue);
-								//鏌ヨ鍘嗗彶宸蹭粯閫炬湡閲戦
-								List<HistoryOverdue> historyOverdueList = historyOverdueMapper.selectList(Wrappers.<HistoryOverdue>lambdaQuery().eq(HistoryOverdue::getScheduleId, currentOverdue.getScheduleId()));
-								BigDecimal hisTotal = historyOverdueList.stream().map(item -> item.getReceivableAmount()).reduce(BigDecimal.ZERO, BigDecimal::add);
-								//鏇存柊褰撳墠閫炬湡
-								currentOverdue.setReceivableAmount(schedule.getPlannedAmount().subtract(hisTotal));
-								currentOverdueMapper.updateById(currentOverdue);
-							}
-							break;
-						}
-					}
-				}
-				//鍚堝悓鎵�鏈変粯娆鹃樁娈�
-				List<ContractPaymentSchedule> payComScheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
-						.eq(ContractPaymentSchedule::getContractId, contract.getId()).ne(ContractPaymentSchedule::getPaymentStatus, 0)
-						.ne(ContractPaymentSchedule::getPaymentStatus, 3));
-				if (ArrayUtil.isNotEmpty(payComScheduleList.toArray())){
-					BigDecimal payTotal = payComScheduleList.stream().map(item->StrUtil.equals(item.getPaymentStatus() + "", "2") ? item.getPlannedAmount() :
-							item.getActualAmount()).reduce(BigDecimal.ZERO,BigDecimal::add);
-					contract.setPaidAmount(payTotal);
-//					if (payComScheduleList.stream().allMatch(item -> Objects.equals(item.getPaymentStatus(), 2))) {
-//						contract.setContractStatus(3);
+		}
+//		else {
+//
+//			List<Contract> customerContractList = contractService.list(Wrappers.<Contract>lambdaQuery().eq(Contract::getPartyAId, addDTO.getBusGuestId())
+//					.eq(Contract::getPartyBId, SecurityUtils.getUser().getCompId()).orderByAsc(Contract::getCreateTime)
+//					.apply(" ((contract_category != 'water_house' and amount != paid_amount) or contract_category = 'water_house')"));
+//			if (ArrayUtil.isEmpty(customerContractList.toArray())) {
+//				return R.failed("涓烘煡璇㈠埌鏈粯娆惧悎鍚�");
+//			}
+//			BusinessCustomer customer = businessCustomerService.getOne(Wrappers.<BusinessCustomer>lambdaQuery()
+//					.eq(StrUtil.isNotBlank(addDTO.getBusGuestName()), BusinessCustomer::getRegisterName, addDTO.getBusGuestName())
+//					.eq(ObjUtil.isNotNull(addDTO.getBusGuestId()), BusinessCustomer::getId, addDTO.getBusGuestId())
+//					.last("limit 1"));
+//			if (ObjUtil.isNull(customer)) {
+//				return R.failed("瀹㈠晢鏌ヨ澶辫触");
+//			}
+//			//鏂板浠樻鍗�
+//			PaymentSlip slip = new PaymentSlip();
+//			slip.setBusGuestId(customer.getId());
+//			slip.setBusGuestName(customer.getRegisterName());
+//			slip.setPayeeCompId(SecurityUtils.getUser().getCompId());
+//			slip.setPaymentTime(addDTO.getConfirmTime());
+//			slip.setPaymentAmount(addDTO.getTransationAmount());
+//			slip.setPayType(addDTO.getPayType());
+//			paymentSlipMapper.insert(slip);
+//
+//			BigDecimal transtionAmount = addDTO.getTransationAmount();
+//			//鍓╀綑浠樻
+//			BigDecimal transtionRemainAmount = transtionAmount;
+//			//鏀跺埌浠樻鐨勫悎鍚�
+//			List<Contract> payContractList = new ArrayList<>();
+//			//浠樻瀹屾垚鐨勫悎鍚�
+//			List<Contract> payCompleteContractList = new ArrayList<>();
+//			//浠樻鏈畬鎴愮殑鍚堝悓
+//			List<Contract> payNoCompleteContractList = new ArrayList<>();
+//			//鏈夐浠樻鐨勫悎鍚�
+//			List<Contract> advanceContractList = new ArrayList<>();
+//			//浠樻鏃堕棿
+//			Date payDate = addDTO.getConfirmTime();
+//			Iterator<Contract> iterator = customerContractList.iterator();
+//			while (iterator.hasNext()) {
+//				Contract contract = iterator.next();
+//				PaymentConfirm lastConfirm = baseMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
+//						.orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
+//				BigDecimal lastTotal = new BigDecimal("0");
+//				if (ObjUtil.isNotNull(lastConfirm)) {
+//					lastTotal = lastConfirm.getTotalAmount();
+//				} else {
+//
+//				}
+//
+//				//鍚堝悓鏈�杩戞槑缁嗘�婚涓�0 鎴� > 0 鎯呭喌涓�
+//				if (lastTotal.compareTo(new BigDecimal("0")) >= 0) {
+//					log.info("褰撳墠鍚堝悓鍙凤細{},鏄庣粏鎬婚鏃犲簲鏀舵", contract.getContractNo());
+//					advanceContractList.add(contract);
+//					if (iterator.hasNext()) {
+//						continue;
 //					}
-					if (contract.getAmount().compareTo(contract.getPaidAmount()) == 0) {
-						contract.setBillingStatus("2");
-						contract.setContractStatus(3);
-						payCompleteContractList.add(contract);
-					}
-					//浠樻 涓� 浠樻鏈叏浠�
-					if (contract.getAmount().compareTo(contract.getPaidAmount()) > 0) {
-						payNoCompleteContractList.add(contract);
-					}
-					if (StrUtil.isNotEmpty(contract.getContractCategory())&&StrUtil.equals(contract.getContractCategory(),"water_house")){
-						List<ContractExecDate> execDateList = contractExecDateMapper.selectList(Wrappers.<ContractExecDate>lambdaQuery()
-								.eq(ContractExecDate::getContractId,contract.getId()).eq(ContractExecDate::getGenFlag,"0"));
-						if (ArrayUtil.isEmpty(execDateList.toArray())){
-							List<ContractPaymentSchedule> contractPaymentScheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
-									.eq(ContractPaymentSchedule::getContractId, contract.getId()));
-							if (ArrayUtil.isNotEmpty(contractPaymentScheduleList.toArray())&&contractPaymentScheduleList.stream().allMatch(item -> Objects.equals(item.getPaymentStatus(), 2))) {
-								contract.setContractStatus(3);
-								contractService.updateById(contract);
-							}
-						}
-					}else {
-						contractService.updateById(contract);
-					}
-
-				}
-			});
+//				}
+//
+//				transtionRemainAmount = transtionRemainAmount.add(lastTotal);
+//				PaymentConfirm entity = new PaymentConfirm();
+//				entity.setContractId(contract.getId());
+//				entity.setContractName(contract.getContractName());
+//				entity.setContractNo(contract.getContractNo());
+//				if (ObjUtil.isNotNull(lastConfirm)) {
+//					entity.setScheduleId(lastConfirm.getScheduleId());
+//					entity.setScheduleName(lastConfirm.getScheduleName());
+//				}
+//				entity.setBusGuestId(customer.getId());
+//				entity.setBusGuestName(customer.getRegisterName());
+//				entity.setBusinessType("瀹㈡埛浠樻");
+//				if (transtionRemainAmount.compareTo(new BigDecimal("0")) > 0) {
+//					entity.setConfirmTime(payDate);
+//					// 鍒ゆ柇鏄惁鏄渶鍚庝竴涓�
+//					if (!iterator.hasNext()) {
+//						entity.setTransationAmount(transtionRemainAmount.subtract(lastTotal));
+//						entity.setAdvanceAmount(transtionRemainAmount);
+//						entity.setTotalAmount(transtionRemainAmount);
+//					} else {
+//						entity.setTransationAmount(lastTotal.multiply(new BigDecimal("-1")));
+//						entity.setTotalAmount(new BigDecimal("0"));
+//					}
+//					baseMapper.insert(entity);
+//					payContractList.add(contract);
+//				} else if (transtionRemainAmount.compareTo(new BigDecimal("0")) == 0) {
+//					entity.setTransationAmount(lastTotal.multiply(new BigDecimal("-1")));
+//					entity.setTotalAmount(new BigDecimal("0"));
+//					entity.setConfirmTime(payDate);
+//					baseMapper.insert(entity);
+//					payContractList.add(contract);
+//					break;
+//				} else {
+//					entity.setTransationAmount(transtionRemainAmount.subtract(lastTotal));
+//					entity.setReceivableAmount(transtionRemainAmount.multiply(new BigDecimal("-1")));
+//					entity.setTotalAmount(transtionRemainAmount);
+//					entity.setConfirmTime(payDate);
+//					baseMapper.insert(entity);
+//					payContractList.add(contract);
+//					break;
+//				}
+//			}
+//
+//			payContractList.stream().forEach(contract -> {
+//				//鏇存柊浠樻闃舵浠樻
+//				List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
+//						.eq(ContractPaymentSchedule::getContractId, contract.getId()).ne(ContractPaymentSchedule::getPaymentStatus, 2)
+//						.ne(ContractPaymentSchedule::getPaymentStatus, 3)
+//						.orderByAsc(ContractPaymentSchedule::getCreateTime));
+//				if (ArrayUtil.isNotEmpty(scheduleList.toArray())) {
+//					BigDecimal remain = transtionAmount;
+//					for (ContractPaymentSchedule schedule : scheduleList) {
+//						BigDecimal lastRemain = remain;
+//						remain = lastRemain.subtract(StrUtil.equals(schedule.getPaymentStatus() + "", "0") ? schedule.getPlannedAmount() :
+//								schedule.getPlannedAmount().subtract(schedule.getActualAmount()));
+//						if (remain.compareTo(new BigDecimal("0")) >= 0) {
+//							schedule.setActualAmount(schedule.getPlannedAmount());
+//							schedule.setPaymentDate(payDate);
+//							schedule.setPaymentStatus(2);
+//							contractPaymentScheduleMapper.updateById(schedule);
+//							//鏌ヨ鏄惁鏈夊綋鍓嶉�炬湡
+//							CurrentOverdue currentOverdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getScheduleId, schedule.getId())
+//									.eq(CurrentOverdue::getContractId, schedule.getContractId()).last("limit 1"));
+//							if (ObjUtil.isNotNull(currentOverdue)) {
+//								//鏂板閫炬湡鍘嗗彶
+//								HistoryOverdue historyOverdue = BeanUtil.copyProperties(currentOverdue, HistoryOverdue.class, "id");
+//								historyOverdue.setPaymentTime(payDate);
+//								historyOverdue.setCompId(schedule.getCompId());
+//								historyOverdueMapper.insert(historyOverdue);
+//								//鍒犻櫎褰撳墠閫炬湡
+//								currentOverdueMapper.deleteById(currentOverdue);
+//							}
+//						} else {
+//							schedule.setActualAmount(StrUtil.equals(schedule.getPaymentStatus() + "", "0") ? schedule.getPlannedAmount().add(remain) :
+//									schedule.getActualAmount().add(lastRemain));
+//							schedule.setPaymentDate(payDate);
+//							schedule.setPaymentStatus(1);
+//							contractPaymentScheduleMapper.updateById(schedule);
+//							//鏌ヨ鏄惁鏈夊綋鍓嶉�炬湡
+//							CurrentOverdue currentOverdue = currentOverdueMapper.selectOne(Wrappers.<CurrentOverdue>lambdaQuery().eq(CurrentOverdue::getScheduleId, schedule.getId())
+//									.eq(CurrentOverdue::getContractId, schedule.getContractId()).last("limit 1"));
+//							if (ObjUtil.isNotNull(currentOverdue)) {
+//								//鏂板閫炬湡鍘嗗彶
+//								HistoryOverdue historyOverdue = BeanUtil.copyProperties(currentOverdue, HistoryOverdue.class, "id");
+//								historyOverdue.setReceivableAmount(lastRemain);
+//								historyOverdue.setPaymentTime(payDate);
+//								historyOverdue.setCompId(schedule.getCompId());
+//								historyOverdueMapper.insert(historyOverdue);
+//								//鏌ヨ鍘嗗彶宸蹭粯閫炬湡閲戦
+//								List<HistoryOverdue> historyOverdueList = historyOverdueMapper.selectList(Wrappers.<HistoryOverdue>lambdaQuery().eq(HistoryOverdue::getScheduleId, currentOverdue.getScheduleId()));
+//								BigDecimal hisTotal = historyOverdueList.stream().map(item -> item.getReceivableAmount()).reduce(BigDecimal.ZERO, BigDecimal::add);
+//								//鏇存柊褰撳墠閫炬湡
+//								currentOverdue.setReceivableAmount(schedule.getPlannedAmount().subtract(hisTotal));
+//								currentOverdueMapper.updateById(currentOverdue);
+//							}
+//							break;
+//						}
+//					}
+//				}
+//				//鍚堝悓鎵�鏈変粯娆鹃樁娈�
+//				List<ContractPaymentSchedule> payComScheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
+//						.eq(ContractPaymentSchedule::getContractId, contract.getId()).ne(ContractPaymentSchedule::getPaymentStatus, 0)
+//						.ne(ContractPaymentSchedule::getPaymentStatus, 3));
+//				if (ArrayUtil.isNotEmpty(payComScheduleList.toArray())) {
+//					BigDecimal payTotal = payComScheduleList.stream().map(item -> StrUtil.equals(item.getPaymentStatus() + "", "2") ? item.getPlannedAmount() :
+//							item.getActualAmount()).reduce(BigDecimal.ZERO, BigDecimal::add);
+//					contract.setPaidAmount(payTotal);
+////					if (payComScheduleList.stream().allMatch(item -> Objects.equals(item.getPaymentStatus(), 2))) {
+////						contract.setContractStatus(3);
+////					}
+//					if (contract.getAmount().compareTo(contract.getPaidAmount()) == 0) {
+//
+//						contract.setContractStatus(3);
+//						payCompleteContractList.add(contract);
+//					}
+//					//浠樻 涓� 浠樻鏈叏浠�
+//					if (contract.getAmount().compareTo(contract.getPaidAmount()) > 0) {
+//						payNoCompleteContractList.add(contract);
+//					}
+//					if (StrUtil.isNotEmpty(contract.getContractCategory()) && StrUtil.equals(contract.getContractCategory(), "water_house")) {
+//						List<ContractExecDate> execDateList = contractExecDateMapper.selectList(Wrappers.<ContractExecDate>lambdaQuery()
+//								.eq(ContractExecDate::getContractId, contract.getId()).eq(ContractExecDate::getGenFlag, "0"));
+//						if (ArrayUtil.isEmpty(execDateList.toArray())) {
+//							List<ContractPaymentSchedule> contractPaymentScheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
+//									.eq(ContractPaymentSchedule::getContractId, contract.getId()));
+//							if (ArrayUtil.isNotEmpty(contractPaymentScheduleList.toArray()) && contractPaymentScheduleList.stream().allMatch(item -> Objects.equals(item.getPaymentStatus(), 2))) {
+//								contract.setContractStatus(3);
+//								contractService.updateById(contract);
+//							}
+//						}
+//					} else {
+//						contractService.updateById(contract);
+//					}
+//
+//				}
+//			});
 
 			//瀹㈡埛棰勪粯鏈夊墿浣� 涓� 鏈夐浠樻鐨勫悎鍚�
 //			if (transtionRemainAmount.compareTo(new BigDecimal("0")) > 0) {
@@ -446,7 +474,7 @@
 //
 //				}
 //			}
-		}
+//		}
 		return R.ok();
 	}
 
@@ -476,7 +504,7 @@
 				String result = HttpUtil.post(url + "/yonbip/EFI/collection/list?access_token=" + finalAccessToken, params.toJSONString());
 				log.info("SK_CX Response:{}", result);
 				//淇濆瓨璇锋眰璁板綍
-				saveBipRequestRecord(params,"<XSJZ_SK_CX_001>-鏀舵鍗曟煡璇㈡帴鍙�", result);
+				saveBipRequestRecord(params, "<XSJZ_SK_CX_001>-鏀舵鍗曟煡璇㈡帴鍙�", result);
 				JSONObject resultJson = JSONObject.parseObject(result);
 				if (resultJson.containsKey("code") && resultJson.getString("code").equals("200")) {
 					handleAndSave(bipCode, resultJson);
@@ -487,7 +515,7 @@
 		return R.ok();
 	}
 
-	private JSONObject genParams(String bipCode){
+	private JSONObject genParams(String bipCode) {
 		JSONObject params = new JSONObject();
 		params.put("pageIndex", 1);
 		params.put("pageSize", 999);
@@ -593,8 +621,8 @@
 			return;
 		}
 		//淇濆瓨浠樻鍗�
-		Boolean codeFlag = savePaymentSlip(customer,record,dept);
-		if (codeFlag){
+		Boolean codeFlag = savePaymentSlip(customer, record, dept);
+		if (codeFlag) {
 			log.error("浠樻鍗昳d锛歿},浠樻鍗曞凡瀛樺湪");
 			return;
 		}
@@ -651,7 +679,7 @@
 					entity.setTransationAmount(transtionRemainAmount.subtract(lastTotal));
 					entity.setAdvanceAmount(transtionRemainAmount);
 					entity.setTotalAmount(transtionRemainAmount);
-				}else {
+				} else {
 					entity.setTransationAmount(lastTotal.multiply(new BigDecimal("-1")));
 					entity.setTotalAmount(new BigDecimal("0"));
 				}
@@ -728,11 +756,11 @@
 			}
 			//鍚堝悓鎵�鏈変粯娆鹃樁娈�
 			List<ContractPaymentSchedule> payComScheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
-					.eq(ContractPaymentSchedule::getContractId, contract.getId()).ne(ContractPaymentSchedule::getPaymentStatus, 0).ne(ContractPaymentSchedule::getPaymentStatus,3)
+					.eq(ContractPaymentSchedule::getContractId, contract.getId()).ne(ContractPaymentSchedule::getPaymentStatus, 0).ne(ContractPaymentSchedule::getPaymentStatus, 3)
 			);
-			if (ArrayUtil.isNotEmpty(payComScheduleList.toArray())){
-				BigDecimal payTotal = payComScheduleList.stream().map(item->StrUtil.equals(item.getPaymentStatus() + "", "0") ? item.getPlannedAmount() :
-						item.getActualAmount()).reduce(BigDecimal.ZERO,BigDecimal::add);
+			if (ArrayUtil.isNotEmpty(payComScheduleList.toArray())) {
+				BigDecimal payTotal = payComScheduleList.stream().map(item -> StrUtil.equals(item.getPaymentStatus() + "", "0") ? item.getPlannedAmount() :
+						item.getActualAmount()).reduce(BigDecimal.ZERO, BigDecimal::add);
 				contract.setPaidAmount(payTotal);
 //				if (payComScheduleList.stream().allMatch(item -> Objects.equals(item.getPaymentStatus(), 2))) {
 //					contract.setContractStatus(3);
@@ -742,7 +770,7 @@
 //					payCompleteContractList.add(contract);
 //				}
 				if (contract.getAmount().compareTo(contract.getPaidAmount()) == 0) {
-					contract.setBillingStatus("2");
+//					contract.setBillingStatus("2");
 					contract.setContractStatus(3);
 					payCompleteContractList.add(contract);
 				}
@@ -750,18 +778,18 @@
 				if (contract.getAmount().compareTo(contract.getPaidAmount()) > 0) {
 					payNoCompleteContractList.add(contract);
 				}
-				if (StrUtil.isNotEmpty(contract.getContractCategory())&&StrUtil.equals(contract.getContractCategory(),"water_house")){
+				if (StrUtil.isNotEmpty(contract.getContractCategory()) && StrUtil.equals(contract.getContractCategory(), "water_house")) {
 					List<ContractExecDate> execDateList = contractExecDateMapper.selectList(Wrappers.<ContractExecDate>lambdaQuery()
-							.eq(ContractExecDate::getContractId,contract.getId()).eq(ContractExecDate::getGenFlag,"0"));
-					if (ArrayUtil.isEmpty(execDateList)){
+							.eq(ContractExecDate::getContractId, contract.getId()).eq(ContractExecDate::getGenFlag, "0"));
+					if (ArrayUtil.isEmpty(execDateList)) {
 						List<ContractPaymentSchedule> contractPaymentScheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
 								.eq(ContractPaymentSchedule::getContractId, contract.getId()));
-						if (ArrayUtil.isNotEmpty(contractPaymentScheduleList.toArray())&&contractPaymentScheduleList.stream().allMatch(item -> Objects.equals(item.getPaymentStatus(), 2))) {
+						if (ArrayUtil.isNotEmpty(contractPaymentScheduleList.toArray()) && contractPaymentScheduleList.stream().allMatch(item -> Objects.equals(item.getPaymentStatus(), 2))) {
 							contract.setContractStatus(3);
 							contractService.updateById(contract);
 						}
 					}
-				}else {
+				} else {
 					contractService.updateById(contract);
 				}
 			}
@@ -792,19 +820,19 @@
 //		}
 	}
 
-	private Boolean savePaymentSlip(BusinessCustomer customer, JSONObject record,SysDept dept) {
+	private Boolean savePaymentSlip(BusinessCustomer customer, JSONObject record, SysDept dept) {
 		PaymentSlip slip = new PaymentSlip();
 		slip.setBusGuestId(customer.getId());
 		slip.setBusGuestName(customer.getRegisterName());
 		slip.setPayee(dept.getName());
 		slip.setPayeeCompId(dept.getDeptId());
-		slip.setPaymentTime(ObjUtil.isNotNull(record.get("billDate"))?
-				DateUtil.parse(record.getString("billDate"), DatePattern.NORM_DATETIME_FORMAT):new Date());
-		slip.setPaymentAmount(ObjUtil.isNotNull(record.get("bodyItemOriTaxExcludedAmount"))?record.getBigDecimal("bodyItemOriTaxExcludedAmount"):new BigDecimal("0"));
-		slip.setPayType(ObjUtil.isNotNull(record.get("bodyItemSettleModeName"))?record.getString("bodyItemSettleModeName"):"");
-		if (ObjUtil.isNotNull(record.get("code"))){
+		slip.setPaymentTime(ObjUtil.isNotNull(record.get("billDate")) ?
+				DateUtil.parse(record.getString("billDate"), DatePattern.NORM_DATETIME_FORMAT) : new Date());
+		slip.setPaymentAmount(ObjUtil.isNotNull(record.get("bodyItemOriTaxExcludedAmount")) ? record.getBigDecimal("bodyItemOriTaxExcludedAmount") : new BigDecimal("0"));
+		slip.setPayType(ObjUtil.isNotNull(record.get("bodyItemSettleModeName")) ? record.getString("bodyItemSettleModeName") : "");
+		if (ObjUtil.isNotNull(record.get("code"))) {
 			slip.setPaymentNumber(record.getString("code"));
-			PaymentSlip paymentSlip = paymentSlipMapper.selectOne(Wrappers.<PaymentSlip>lambdaQuery().eq(PaymentSlip::getPaymentNumber,slip.getPaymentNumber()));
+			PaymentSlip paymentSlip = paymentSlipMapper.selectOne(Wrappers.<PaymentSlip>lambdaQuery().eq(PaymentSlip::getPaymentNumber, slip.getPaymentNumber()));
 			if (ObjUtil.isNull(paymentSlip)) {
 				paymentSlipMapper.insert(slip);
 				return false;
@@ -813,8 +841,8 @@
 		return true;
 	}
 
-	public void saveNewPaymentConfirm(BusinessCustomer customer,JSONObject record,Contract contract,BigDecimal transtionRemainAmount
-		,Date payDate){
+	public void saveNewPaymentConfirm(BusinessCustomer customer, JSONObject record, Contract contract, BigDecimal transtionRemainAmount
+			, Date payDate) {
 		PaymentConfirm entity = new PaymentConfirm();
 		entity.setContractId(contract.getId());
 		entity.setContractName(contract.getContractName());
@@ -834,7 +862,7 @@
 		entity.setBusGuestId(customer.getId());
 		entity.setBusGuestName(customer.getRegisterName());
 		entity.setBusinessType("瀹㈡埛浠樻");
-		if (ObjUtil.isNotNull(record)){
+		if (ObjUtil.isNotNull(record)) {
 			entity.setIsBip(1);
 			entity.setPaymentCode(record.getString("code"));
 			entity.setPayType(record.get("bodyItemSettleModeName") != null ? record.getString("bodyItemSettleModeName").contains("鎵垮厬姹囩エ") ? 1 : 0 : null);
@@ -843,9 +871,9 @@
 		entity.setConfirmTime(payDate);
 		entity.setTransationAmount(transtionRemainAmount);
 		entity.setTotalAmount(transtionRemainAmount.add(lastTotal));
-		if (entity.getTotalAmount().compareTo(new BigDecimal("0"))>0){
+		if (entity.getTotalAmount().compareTo(new BigDecimal("0")) > 0) {
 			entity.setAdvanceAmount(entity.getTotalAmount());
-		}else if (entity.getTotalAmount().compareTo(new BigDecimal("0"))<0){
+		} else if (entity.getTotalAmount().compareTo(new BigDecimal("0")) < 0) {
 			entity.setReceivableAmount(entity.getTotalAmount().multiply(new BigDecimal("-1")));
 		}
 		baseMapper.insert(entity);
@@ -854,63 +882,63 @@
 	@Override
 	public R queryAllBusinessType() {
 		return R.ok(baseMapper.selectList(Wrappers.<PaymentConfirm>lambdaQuery().select(PaymentConfirm::getBusinessType).isNotNull(PaymentConfirm::getBusinessType)
-						.groupBy(PaymentConfirm::getBusinessType)).stream().map(PaymentConfirm::getBusinessType).collect(Collectors.toList()));
+				.groupBy(PaymentConfirm::getBusinessType)).stream().map(PaymentConfirm::getBusinessType).collect(Collectors.toList()));
 	}
 
 	@Override
 	public R queryAging() {
-		List<AgingCompanyVo> companys = contractPaymentScheduleMapper.selectAgingCompany(null,DataScope.of("comp_id"));
-		if (ArrayUtil.isEmpty(companys.toArray())){
+		List<AgingCompanyVo> companys = contractPaymentScheduleMapper.selectAgingCompany(null, DataScope.of("comp_id"));
+		if (ArrayUtil.isEmpty(companys.toArray())) {
 			return R.failed("鏆傛棤璐﹂緞");
 		}
 		List<AgingAnalysisVo> result = new ArrayList<>();
 		AgingQueryDTO queryDTO = new AgingQueryDTO();
 		List<AgingVo> agingVoList = contractPaymentScheduleMapper.selectAgingTotal(null);
-		companys.stream().forEach(company->{
+		companys.stream().forEach(company -> {
 			BusinessCustomer businessCustomer = businessCustomerService.getById(company.getCompanyId());
 			AgingAnalysisVo agingAnalysisVo = new AgingAnalysisVo();
 			agingAnalysisVo.setCompanyName(businessCustomer.getCompanyName());
 			queryDTO.setCompanyId(company.getCompanyId());
 			List<AgingVo> companyAgingVo = contractPaymentScheduleMapper.selectAgingTotal(queryDTO);
 			//琛ュ叏鏁版嵁
-			if (ArrayUtil.isEmpty(companyAgingVo.toArray())){
+			if (ArrayUtil.isEmpty(companyAgingVo.toArray())) {
 				companyAgingVo = new ArrayList<>();
-				AgingVo agingVo1 = new AgingVo("0-30澶�",new BigDecimal("0"),null);
-				AgingVo agingVo2 = new AgingVo("31-60澶�",new BigDecimal("0"),null);
-				AgingVo agingVo3 = new AgingVo("61-90澶�",new BigDecimal("0"),null);
-				AgingVo agingVo4 = new AgingVo("91-180澶�",new BigDecimal("0"),null);
-				AgingVo agingVo5 = new AgingVo("181-365澶�",new BigDecimal("0"),null);
-				AgingVo agingVo6 = new AgingVo("1骞翠互涓�",new BigDecimal("0"),null);
+				AgingVo agingVo1 = new AgingVo("0-30澶�", new BigDecimal("0"), null);
+				AgingVo agingVo2 = new AgingVo("31-60澶�", new BigDecimal("0"), null);
+				AgingVo agingVo3 = new AgingVo("61-90澶�", new BigDecimal("0"), null);
+				AgingVo agingVo4 = new AgingVo("91-180澶�", new BigDecimal("0"), null);
+				AgingVo agingVo5 = new AgingVo("181-365澶�", new BigDecimal("0"), null);
+				AgingVo agingVo6 = new AgingVo("1骞翠互涓�", new BigDecimal("0"), null);
 				companyAgingVo.add(agingVo1);
 				companyAgingVo.add(agingVo2);
 				companyAgingVo.add(agingVo3);
 				companyAgingVo.add(agingVo4);
 				companyAgingVo.add(agingVo5);
 				companyAgingVo.add(agingVo6);
-			}else {
+			} else {
 				List<String> overdueRanges = companyAgingVo.stream().map(AgingVo::getOverdueRange).collect(Collectors.toList());
-				if (!ArrayUtil.contains(overdueRanges.toArray(),"0-30澶�")){
-					AgingVo agingVo1 = new AgingVo("0-30澶�",new BigDecimal("0"),null);
+				if (!ArrayUtil.contains(overdueRanges.toArray(), "0-30澶�")) {
+					AgingVo agingVo1 = new AgingVo("0-30澶�", new BigDecimal("0"), null);
 					companyAgingVo.add(agingVo1);
 				}
-				if (!ArrayUtil.contains(overdueRanges.toArray(),"31-60澶�")){
-					AgingVo agingVo2 = new AgingVo("31-60澶�",new BigDecimal("0"),null);
+				if (!ArrayUtil.contains(overdueRanges.toArray(), "31-60澶�")) {
+					AgingVo agingVo2 = new AgingVo("31-60澶�", new BigDecimal("0"), null);
 					companyAgingVo.add(agingVo2);
 				}
-				if (!ArrayUtil.contains(overdueRanges.toArray(),"61-90澶�")){
-					AgingVo agingVo3 = new AgingVo("61-90澶�",new BigDecimal("0"),null);
+				if (!ArrayUtil.contains(overdueRanges.toArray(), "61-90澶�")) {
+					AgingVo agingVo3 = new AgingVo("61-90澶�", new BigDecimal("0"), null);
 					companyAgingVo.add(agingVo3);
 				}
-				if (!ArrayUtil.contains(overdueRanges.toArray(),"91-180澶�")){
-					AgingVo agingVo4 = new AgingVo("91-180澶�",new BigDecimal("0"),null);
+				if (!ArrayUtil.contains(overdueRanges.toArray(), "91-180澶�")) {
+					AgingVo agingVo4 = new AgingVo("91-180澶�", new BigDecimal("0"), null);
 					companyAgingVo.add(agingVo4);
 				}
-				if (!ArrayUtil.contains(overdueRanges.toArray(),"181-365澶�")){
-					AgingVo agingVo5 = new AgingVo("181-365澶�",new BigDecimal("0"),null);
+				if (!ArrayUtil.contains(overdueRanges.toArray(), "181-365澶�")) {
+					AgingVo agingVo5 = new AgingVo("181-365澶�", new BigDecimal("0"), null);
 					companyAgingVo.add(agingVo5);
 				}
-				if (!ArrayUtil.contains(overdueRanges.toArray(),"1骞翠互涓�")){
-					AgingVo agingVo6 = new AgingVo("1骞翠互涓�",new BigDecimal("0"),null);
+				if (!ArrayUtil.contains(overdueRanges.toArray(), "1骞翠互涓�")) {
+					AgingVo agingVo6 = new AgingVo("1骞翠互涓�", new BigDecimal("0"), null);
 					companyAgingVo.add(agingVo6);
 				}
 			}
@@ -939,7 +967,7 @@
 
 					if (agingAnalysisVo.getAmount().get(i) == null || agingAnalysisVo.getAmount().get(i).compareTo(BigDecimal.ZERO) == 0) {
 						return null;
-					}else {
+					} else {
 						return new BigDecimal("100");
 					}
 				})

--
Gitblit v1.9.1