From c564930d687e421e4e35d7fcafadc6d11ff23b9c Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 05 十一月 2024 19:07:44 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java |  189 +++++++++++++++++++++++++++--------------------
 1 files changed, 109 insertions(+), 80 deletions(-)

diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java
index 7a966e0..4eec6ac 100644
--- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java
+++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java
@@ -289,6 +289,7 @@
 			for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : dataList) {
 				if(!sdf.format(uploadRealTimeMonitoringData.getCreate_time()).equals(t)){
 					dataLists.add(uploadRealTimeMonitoringData);
+					t = sdf.format(uploadRealTimeMonitoringData.getCreate_time());
 				}
 			}
 			
@@ -460,7 +461,6 @@
 		chargingOrder.setVipDiscountAmount(BigDecimal.ZERO);
 		chargingOrder.setOrderSource(0);
 		chargingOrder.setTitle("【充电桩充电】" + chargingPile.getNumber() + "号桩/" + tChargingGun.getCode() + "号枪");
-		chargingOrder.setStatus(1);
 		
 		Site site = siteClient.getSiteByIds(Arrays.asList(tChargingGun.getSiteId())).getData().get(0);
 		Integer accountingStrategyId = tChargingGun.getAccountingStrategyId();
@@ -524,7 +524,7 @@
 		if(2 == addChargingOrder.getPaymentType()){
 			AliPaymentReq req = new AliPaymentReq();
 			req.setOutTradeNo(chargingOrder.getCode());
-			req.setTotalAmount(chargingOrder.getPaymentAmount().toString());
+			req.setTotalAmount(addChargingOrder.getPaymentAmount().toString());
 			req.setSubject("充电充值");
 			req.setBuyerOpenId(appUser.getAliOpenid());
 			req.setBody("充电充值");
@@ -671,7 +671,7 @@
 		platformStartCharging.setCard_number(chargingOrder.getId().toString());
 		platformStartCharging.setAccount_balance(account_balance);
 		
-		log.error(chargingOrder.getCode() + ":-------------------远程调起开始充电请求-------------------" + platformStartCharging.toString());
+		log.info(chargingOrder.getCode() + ":-------------------远程调起开始充电请求-------------------" + platformStartCharging.toString());
 		sendMessageClient.platformStartCharging(platformStartCharging);
 		//异步线程检测远程启动的应答结果。如果失败,则需要全额退款
 		Long id = chargingOrder.getId();
@@ -699,7 +699,7 @@
 		String code = chargingOrder.getCode();
 		String key = "AQJC_" + chargingOrder.getChargingGunId();
 		List<PlatformStartChargingReply> data = platformStartChargingReplyClient.getPlatformStartChargingReply(code).getData();
-		log.error(code + ":-------------------开始检查调起充电结果-------------------" + data.toString());
+		log.info(code + ":-------------------开始检查调起充电结果-------------------" + data.toString());
 		if(data.size() != 0){
 			PlatformStartChargingReply platformStartChargingReply = data.get(1);
 			Integer startup_result = platformStartChargingReply.getStartup_result();
@@ -741,7 +741,7 @@
 			return true;
 		}else{
 			Integer counter = boot_failed_map.get(code);
-			log.error(code + ":-------------------未上传开启充电结果-------------------" + counter);
+			log.info(code + ":-------------------未上传开启充电结果-------------------" + counter);
 			PreChargeCheck preChargeCheck1 = redisService.getCacheObject(key);
 			//5分钟内未启动成功,退回金额。
 			if(null == counter || counter < 300){
@@ -837,7 +837,7 @@
 	 * @param code
 	 */
 	public void refund(String code){
-		log.error(code + ":-------------------充电启动失败,执行退款-------------------");
+		log.info(code + ":-------------------充电启动失败,执行退款-------------------");
 		TChargingOrder chargingOrder = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, code));
 		if(chargingOrder.getStatus() == 2){
 			Integer rechargePaymentType = chargingOrder.getRechargePaymentType();
@@ -1007,8 +1007,8 @@
 			platformStopCharging.setCharging_pile_code(chargingPile.getCode());
 			platformStopCharging.setCharging_gun_code(chargingGun.getCode());
 			sendMessageClient.platformStopCharging(platformStopCharging);
-			log.error(code1 + ":-------------------远程停止充电请求-------------------");
-			log.error(platformStopCharging.toString());
+			log.info(code1 + ":-------------------远程停止充电请求-------------------");
+			log.info(platformStopCharging.toString());
 		});
 		return AjaxResult.success();
 	}
@@ -1163,7 +1163,7 @@
 					failure_cause = "其他";
 					break;
 			}
-			log.error(code1 + ":停机失败:订单号:{},失败原因:{}", order.getCode(), failure_cause);
+			log.info(code1 + ":停机失败:订单号:{},失败原因:{}", order.getCode(), failure_cause);
 		}else{
 			TChargingOrder chargingOrder = new TChargingOrder();
 			chargingOrder.setId(order.getId());
@@ -1274,7 +1274,7 @@
 			electronicMoney = electronicMoney.add(chargingOrderVO.getElectrovalence());
 			serviceMoney = serviceMoney.add(chargingOrderVO.getServiceCharge());
 
-			income = income.add(chargingOrderVO.getOrderAmount());
+			income = income.add(chargingOrderVO.getPaymentAmount());
 
 
 
@@ -1298,9 +1298,9 @@
 				payOrderDto.setFinalAmount(payOrderDto.getOrderAmount());
 			}
 			if (payOrderDto.getType()==1&&payOrderDto.getStatus()==3){
-				payOrderDto.setFinalAmount(payOrderDto.getRechargeAmount());
-				payOrderDto.setOrderAmount(payOrderDto.getRechargeAmount());
-				payOrderDto.setPaymentAmount(payOrderDto.getRechargeAmount());
+				payOrderDto.setFinalAmount(payOrderDto.getOrderAmount());
+				payOrderDto.setOrderAmount(payOrderDto.getOrderAmount());
+				payOrderDto.setPaymentAmount(payOrderDto.getOrderAmount());
 			}
 		}
 		pageInfo.setRecords(list);
@@ -1412,7 +1412,7 @@
 			chargingOrderListVO.setChargingCapacity(chargingOrderListVO.getElectricity());
 			BigDecimal bigDecimal = new BigDecimal("0.006");
 			if (chargingOrderListVO.getOrderAmount()!=null){
-				chargingOrderListVO.setCommissionAmount(chargingOrderListVO.getOrderAmount().multiply(bigDecimal));
+				chargingOrderListVO.setCommissionAmount(chargingOrderListVO.getPaymentAmount().multiply(bigDecimal));
 			}
 			chargingOrderListVO.setPaymentAmount(chargingOrderListVO.getPaymentAmount());
 			chargingOrderListVO.setUid(chargingOrderListVO.getId()+"");
@@ -1440,10 +1440,20 @@
 			// 获取开始SOC 结束soc
 			if (chargingOrderListVO.getCode()!=null){
 				List<UploadRealTimeMonitoringData> data6 = uploadRealTimeMonitoringDataClient.getDataByOrderCode(chargingOrderListVO.getCode()).getData();
+
 			if (data6!=null && !data6.isEmpty()){
-					// 第一条数据soc为开始 最后一条数据soc为结束soc
-					chargingOrderListVO.setEndSoc(data6.get(0).getSoc().toString());
-					chargingOrderListVO.setStartSoc(data6.get(data6.size()-1).getSoc().toString());
+				int min = 100;
+				int max = 0;
+				for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : data6) {
+					if (uploadRealTimeMonitoringData.getSoc()>max){
+						max = uploadRealTimeMonitoringData.getSoc();
+					}
+					if (uploadRealTimeMonitoringData.getSoc()!=0 &&uploadRealTimeMonitoringData.getSoc()<min){
+						min = uploadRealTimeMonitoringData.getSoc();
+					}
+				}
+					chargingOrderListVO.setEndSoc(max+"");
+					chargingOrderListVO.setStartSoc(min+"");
 				}
 			}
 
@@ -1627,7 +1637,8 @@
 		chargingOrderListInfoVO.setStatus(chargingOrder.getStatus());
 		BigDecimal bigDecimal = new BigDecimal("0.006");
 		if (chargingOrder.getOrderAmount()!=null){
-			chargingOrderListInfoVO.setCommissionAmount(chargingOrder.getOrderAmount().multiply(bigDecimal));
+			BigDecimal multiply = chargingOrder.getPaymentAmount().multiply(bigDecimal);
+			chargingOrderListInfoVO.setCommissionAmount(multiply.setScale(2, BigDecimal.ROUND_HALF_UP));
 		}
 		chargingOrderListInfoVO.setElectrovalence(chargingOrder.getElectrovalence());
 		chargingOrderListInfoVO.setServiceCharge(chargingOrder.getServiceCharge());
@@ -1661,6 +1672,7 @@
 				}
 			}
 		}
+		chargingOrderListInfoVO.setChargingCapacity(chargingOrder.getChargingCapacity());
 
 		chargingOrderListInfoVO.setEndMode(chargingOrder.getEndMode());
 
@@ -1676,10 +1688,18 @@
 					}
 				}
 				if (!data6.isEmpty()){
-					// 第一条数据soc为开始 最后一条数据soc为结束soc
-					chargingOrderListInfoVO.setStartSoc(data6.get(data6.size()-1).getSoc().toString());
-					chargingOrderListInfoVO.setEndSoc(data6.get(0).getSoc().toString());
-					chargingOrderListInfoVO.setChargingCapacity(data6.get(data6.size()-1).getCharging_degree());
+						int min = 100;
+						int max = 0;
+						for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : data6) {
+							if (uploadRealTimeMonitoringData.getSoc()>max){
+								max = uploadRealTimeMonitoringData.getSoc();
+							}
+							if (uploadRealTimeMonitoringData.getSoc()!=0 &&uploadRealTimeMonitoringData.getSoc()<min){
+								min = uploadRealTimeMonitoringData.getSoc();
+							}
+						}
+					chargingOrderListInfoVO.setEndSoc(max+"");
+					chargingOrderListInfoVO.setStartSoc(min+"");
 
 					SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 					for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : data6) {
@@ -1806,7 +1826,7 @@
 		
 		//获取订单的计费策略
 		List<AccountingStrategyDetailOrder> accountingStrategyDetailOrderList = accountingStrategyDetailOrderClient.getAllAccountingStrategyDetailOrder(chargingOrder.getId()).getData();
-		
+		accountingStrategyDetailOrderList.get(accountingStrategyDetailOrderList.size() - 1).setEndTime("23:59");
 		//开始处理计费明细数据和优惠数据
 		chargingOrderAccountingStrategyService.remove(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>().eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrder.getId()));
 		SimpleDateFormat sdfs = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -1909,26 +1929,26 @@
 			}
 			
 			//已充电总度数
-			BigDecimal electrovalenc = strategyDetail.getElectrovalence().multiply(sharp_peak_charge).setScale(2, RoundingMode.DOWN);
-			BigDecimal originalServicePrice = strategyDetail.getServiceCharge().multiply(sharp_peak_charge).setScale(2, RoundingMode.DOWN);
+			BigDecimal electrovalenc = strategyDetail.getElectrovalence().multiply(sharp_peak_charge).setScale(2, RoundingMode.HALF_EVEN);
+			BigDecimal originalServicePrice = strategyDetail.getServiceCharge().multiply(sharp_peak_charge).setScale(2, RoundingMode.HALF_EVEN);
 			BigDecimal serviceCharge = originalServicePrice;
 			BigDecimal vipDiscountAmount = BigDecimal.ZERO;
 			//计算优惠金额
 			if(null != chargingOrder.getVipDiscount()){
-				vipDiscountAmount = serviceCharge.multiply(new BigDecimal(1).subtract(chargingOrder.getVipDiscount())).setScale(2, RoundingMode.DOWN);
-				serviceCharge = serviceCharge.multiply(chargingOrder.getVipDiscount()).setScale(2, RoundingMode.DOWN);
+				vipDiscountAmount = serviceCharge.multiply(new BigDecimal(1).subtract(chargingOrder.getVipDiscount())).setScale(2, RoundingMode.HALF_EVEN);
+				serviceCharge = serviceCharge.multiply(chargingOrder.getVipDiscount()).setScale(2, RoundingMode.HALF_EVEN);
 			}
 			chargingOrderAccountingStrategy.setChargingCapacity(sharp_peak_charge);
-			chargingOrderAccountingStrategy.setPeriodElectricPrice(electrovalenc.setScale(2, RoundingMode.DOWN));
-			chargingOrderAccountingStrategy.setPeriodServicePrice(serviceCharge.setScale(2, RoundingMode.DOWN));
-			chargingOrderAccountingStrategy.setPeriodOriginalServicePrice(originalServicePrice.setScale(2, RoundingMode.DOWN));
-			chargingOrderAccountingStrategy.setVipDiscountAmount(vipDiscountAmount.setScale(2, RoundingMode.DOWN));
+			chargingOrderAccountingStrategy.setPeriodElectricPrice(electrovalenc);
+			chargingOrderAccountingStrategy.setPeriodServicePrice(serviceCharge);
+			chargingOrderAccountingStrategy.setPeriodOriginalServicePrice(originalServicePrice);
+			chargingOrderAccountingStrategy.setVipDiscountAmount(vipDiscountAmount);
 			chargingOrderAccountingStrategy.setCreateTime(LocalDateTime.now());
 			chargingOrderAccountingStrategyService.save(chargingOrderAccountingStrategy);
 			
-			periodElectricPrice_total = periodElectricPrice_total.add(electrovalenc.setScale(2, RoundingMode.DOWN));
-			periodServicePrice_total = periodServicePrice_total.add(originalServicePrice.setScale(2, RoundingMode.DOWN));
-			total = total.add(electrovalenc.add(originalServicePrice.setScale(2, RoundingMode.DOWN)));
+			periodElectricPrice_total = periodElectricPrice_total.add(electrovalenc);
+			periodServicePrice_total = periodServicePrice_total.add(originalServicePrice);
+			total = total.add(electrovalenc.add(originalServicePrice));
 		}
 		
 		
@@ -1939,6 +1959,7 @@
 		//总金额(充值金额+会员折扣金额)
 		BigDecimal decimal = rechargeAmount.add(vipDiscountAmount);
 		//退款金额(已经计算了折扣优惠部分)
+		//如果充电总金额未使用完,则需要退回费用=(原金额/总金额)*(总金额-实际充电金额)
 		BigDecimal refundAmount = rechargeAmount.divide(decimal, new MathContext(4, RoundingMode.HALF_EVEN)).multiply(decimal.subtract(total));
 		BigDecimal orderAmount = BigDecimal.valueOf(total.doubleValue());
 		BigDecimal payAmount = BigDecimal.valueOf(total.doubleValue());
@@ -1957,8 +1978,6 @@
 				
 				//服务费折扣
 				discountAmount = periodServicePrice_total.multiply((new BigDecimal(1).subtract(chargingOrder.getVipDiscount())));
-				periodServicePrice_total = periodServicePrice_total.multiply(chargingOrder.getVipDiscount());
-				
 				TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();
 				BigDecimal maximumDeduction = vip.getMaximumDeduction();
 				//普通会员有最高优惠限制
@@ -1967,28 +1986,33 @@
 				}
 			}
 		}
+		//会员折扣金额
+		discountAmount = discountAmount.setScale(2, RoundingMode.HALF_EVEN);
 		payAmount = payAmount.subtract(discountAmount);
+		periodServicePrice_total = periodServicePrice_total.subtract(discountAmount);
 		
 		TChargingOrder order = new TChargingOrder();
 		order.setId(chargingOrder.getId());
 		order.setAppUserId(chargingOrder.getAppUserId());
-		if(null != chargingOrder.getEndMode() && chargingOrder.getEndMode() == 2){
-			order.setEndMode(refundAmount.compareTo(BigDecimal.ZERO) > 0 ? 2 : 3);
-		}
-		if(null == chargingOrder.getEndMode()){
+		UploadRealTimeMonitoringData uploadRealTimeMonitoringData = uploadRealTimeMonitoringDataClient.chargingOrderInfo(chargingOrder.getCode()).getData();
+		if(null != uploadRealTimeMonitoringData && null == chargingOrder.getEndMode()){
+			Integer soc = uploadRealTimeMonitoringData.getSoc();
+			order.setEndMode(soc > 98 ? 2 : 3);
+		}else{
 			order.setEndMode(1);
 		}
-		order.setResidualAmount(rechargeAmount.subtract(total).setScale(2, RoundingMode.DOWN));
+		order.setResidualAmount(rechargeAmount.subtract(total).setScale(2, RoundingMode.HALF_EVEN));
 		order.setStartTime(LocalDateTime.parse(vo.getStart_time(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SS")));
 		order.setEndTime(LocalDateTime.parse(vo.getEnd_time(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SS")));
 		order.setStatus(5);
-		order.setOrderAmount(orderAmount.setScale(2, RoundingMode.DOWN));
-		order.setVipDiscountAmount(discountAmount.setScale(2, RoundingMode.DOWN));
-		order.setElectrovalence(periodElectricPrice_total.setScale(2, RoundingMode.DOWN));
+		order.setOrderAmount(orderAmount.setScale(2, RoundingMode.HALF_EVEN));
+		order.setVipDiscountAmount(discountAmount);
+		order.setElectrovalence(periodElectricPrice_total.setScale(2, RoundingMode.HALF_EVEN));
 		order.setChargingCapacity(vo.getTotal_electricity());
 		order.setElectricity(vo.getTotal_electricity());
 		
 		//计算优惠券
+		BigDecimal couponDiscount = BigDecimal.ZERO;
 		if(null != chargingOrder.getAppCouponId()){
 			//判断实际充电金额是否满足优惠券使用条件,如果不满足则不适用优惠券。
 			TAppCoupon appCoupon = appCouponClient.getAppCouponById(chargingOrder.getAppCouponId()).getData();
@@ -2001,17 +2025,11 @@
 					BigDecimal couponDiscountAmount = tCoupon.getDiscountAmount();
 					//如果优惠金额大于服务费金额,以服务费作为最大限制
 					if(periodServicePrice_total.compareTo(couponDiscountAmount) < 0){
-						refundAmount = refundAmount.add(periodServicePrice_total);
-						order.setCouponDiscountAmount(periodServicePrice_total);
-						payAmount = payAmount.subtract(periodServicePrice_total);
+						couponDiscount = periodServicePrice_total;
 						periodServicePrice_total = BigDecimal.ZERO;
 					}else{
-						refundAmount = refundAmount.add(couponDiscountAmount);
-						order.setCouponDiscountAmount(couponDiscountAmount);
-						payAmount = payAmount.subtract(couponDiscountAmount);
-						periodServicePrice_total = periodServicePrice_total.subtract(couponDiscountAmount);
+						couponDiscount = couponDiscountAmount;
 					}
-					
 					appCoupon.setStatus(2);
 					appCouponClient.updateAppCoupon(appCoupon);
 				}else{
@@ -2028,15 +2046,10 @@
 					divide = divide.compareTo(tCoupon.getMaximumDiscountAmount()) > 0 ? tCoupon.getMaximumDiscountAmount() : divide;
 					//如果优惠金额大于服务费金额,以服务费作为最大限制
 					if(periodServicePrice_total.compareTo(divide) < 0){
-						refundAmount = refundAmount.add(periodServicePrice_total);
-						order.setCouponDiscountAmount(periodServicePrice_total);
-						payAmount = payAmount.subtract(periodServicePrice_total);
+						couponDiscount = periodServicePrice_total;
 						periodServicePrice_total = BigDecimal.ZERO;
 					}else{
-						refundAmount = refundAmount.add(divide);
-						order.setCouponDiscountAmount(divide);
-						payAmount = payAmount.subtract(divide);
-						periodServicePrice_total = periodServicePrice_total.subtract(divide);
+						couponDiscount = divide;
 					}
 					
 					appCoupon.setStatus(2);
@@ -2048,10 +2061,17 @@
 				}
 			}
 		}
-		
-		order.setServiceCharge(periodServicePrice_total.setScale(2, RoundingMode.DOWN));
-		order.setPaymentAmount(payAmount.setScale(2, RoundingMode.DOWN));
-		order.setRefundAmount(refundAmount.setScale(2, RoundingMode.DOWN));
+		//优惠券优惠金额
+		couponDiscount = couponDiscount.setScale(2, RoundingMode.HALF_EVEN);
+		refundAmount = refundAmount.add(couponDiscount);
+		payAmount = payAmount.subtract(couponDiscount);
+		if(periodServicePrice_total.compareTo(BigDecimal.ZERO) > 0){
+			periodServicePrice_total = periodServicePrice_total.subtract(couponDiscount);
+		}
+		order.setCouponDiscountAmount(couponDiscount);
+		order.setServiceCharge(periodServicePrice_total.setScale(2, RoundingMode.HALF_EVEN));
+		order.setPaymentAmount(payAmount.setScale(2, RoundingMode.HALF_EVEN));
+		order.setRefundAmount(refundAmount.setScale(2, RoundingMode.HALF_EVEN));
 		order.setRefundStatus(1);
 		this.updateById(order);
 		chargingOrder = this.getById(order.getId());
@@ -2065,8 +2085,8 @@
 				BigDecimal periodServicePrice = chargingOrderAccountingStrategy.getPeriodServicePrice();
 				BigDecimal multiply = couponDiscountAmount.multiply(periodServicePrice.divide(reduce, new MathContext(4, RoundingMode.HALF_EVEN)));
 				periodServicePrice = periodServicePrice.subtract(multiply);
-				chargingOrderAccountingStrategy.setPeriodServicePrice(periodServicePrice.setScale(2, RoundingMode.DOWN));
-				chargingOrderAccountingStrategy.setCouponDiscountAmount(multiply.setScale(2, RoundingMode.DOWN));
+				chargingOrderAccountingStrategy.setPeriodServicePrice(periodServicePrice.setScale(2, RoundingMode.HALF_EVEN));
+				chargingOrderAccountingStrategy.setCouponDiscountAmount(multiply.setScale(2, RoundingMode.HALF_EVEN));
 			}
 			chargingOrderAccountingStrategyService.updateBatchById(list);
 		}
@@ -2083,7 +2103,7 @@
 		if(null != integralRule){
 			TAppUser appUser = appUserClient.getUserById(chargingOrder.getAppUserId()).getData();
 			Integer num1 = JSON.parseObject(integralRule.getChargeCredit()).getInteger("num1");
-			Integer integral = payAmount.multiply(new BigDecimal(num1)).intValue();
+			Integer integral = chargingOrder.getServiceCharge().intValue() * num1;
 			if(null != appUser.getVipId()){
 				TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();
 				Integer doubleIntegration = vip.getDoubleIntegration();
@@ -2480,8 +2500,8 @@
 			return null;
 		}
 		TChargingOrder one = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getAppUserCarId, appUserCar.getId())
-				.eq(TChargingOrder::getDelFlag, 0).gt(TChargingOrder::getStartTime, query.getStartTime())
-				.eq(TChargingOrder::getRechargePaymentStatus, 2).ne(TChargingOrder::getStatus, 5));
+				.eq(TChargingOrder::getDelFlag, 0).between(TChargingOrder::getStartTime, query.getStartTime(), LocalDateTime.now())
+				.eq(TChargingOrder::getRechargePaymentStatus, 2).in(TChargingOrder::getStatus, Arrays.asList(4, 5)));
 		return one;
 	}
 
@@ -2572,18 +2592,19 @@
 				couponDiscount = couponDiscount.add(tChargingOrder.getCouponDiscountAmount());
 			}
 			if (tChargingOrder.getPaymentAmount()!=null){
-				paymentAmount = paymentAmount.add(tChargingOrder.getOrderAmount());
+				paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount());
+				orderCommission = orderCommission.add(tChargingOrder.getPaymentAmount().multiply(new BigDecimal("0.006"))
+						.setScale(2,BigDecimal.ROUND_DOWN));
 			}
 
 		}
+
 		// 三方交易手续费 三方收费*0.6%
 		commissionAmount = sharingAmount.multiply(new BigDecimal("0.006"));
-		// 订单手续费 订单支付金额 - 退款金额*0.6%
-		orderCommission = paymentAmount.multiply(new BigDecimal("0.006").setScale(2,RoundingMode.HALF_DOWN));
 		tSettlementConfirm.setSharingAmount(sharingAmount.setScale(2, RoundingMode.HALF_DOWN));
 		tSettlementConfirm.setCommissionAmount(commissionAmount.setScale(2, RoundingMode.HALF_DOWN));
 		tSettlementConfirm.setElectrovalence(electrovalence.setScale(2, RoundingMode.HALF_DOWN));
-		tSettlementConfirm.setServiceCharge(serviceCharge.subtract(commissionAmount).setScale(2, RoundingMode.HALF_DOWN));
+		tSettlementConfirm.setServiceCharge(serviceCharge.subtract(orderCommission).setScale(2, RoundingMode.HALF_DOWN));
 		tSettlementConfirm.setOrderCommission(orderCommission);
 		tSettlementConfirm.setVipDiscount(vipDiscount);
 		tSettlementConfirm.setCouponDiscount(couponDiscount);
@@ -2595,6 +2616,8 @@
 		tSettlementConfirm.setType(dto.getType());
 
 		if (dto.getState() == 2){
+			tSettlementConfirm.setServiceMoney(dto.getServiceCharge().subtract(dto.getVenue()).subtract(dto.getClean())
+					.subtract(dto.getMaintain()).multiply(dto.getServicePartner()));
 			tSettlementConfirm.setSupplyElectronic(dto.getSupplyElectronic());
 			tSettlementConfirm.setVenue(dto.getVenue());
 			tSettlementConfirm.setMetering(dto.getMetering());
@@ -2609,24 +2632,26 @@
 			tSettlementConfirm.setTotalService(dto.getTotalService());
 			tSettlementConfirm.setRemark(dto.getRemark());
 			tSettlementConfirm.setServicePartner(dto.getServicePartner());
-			tSettlementConfirm.setServiceMoney(dto.getServiceMoney());
-			BigDecimal subtract = new BigDecimal("1").subtract(dto.getProportionPartner().multiply(new BigDecimal("0.01")));
+			BigDecimal subtract = new BigDecimal("1").subtract(dto.getProportionPartner());
+			BigDecimal subtract9 = new BigDecimal("1").subtract(dto.getServicePartner());
 			// 总电损费用
 			BigDecimal divide = tSettlementConfirm.getProportionMoney().divide(subtract, 2, RoundingMode.HALF_DOWN);
 			// 平台承担电损
 			BigDecimal subtract1 = divide.subtract(tSettlementConfirm.getProportionMoney());
 			BigDecimal multiply = dto.getServiceMoney().multiply(subtract);
 			BigDecimal subtract2 = multiply.subtract(subtract1);
-			tSettlementConfirm.setNewMoney(subtract2);
+			tSettlementConfirm.setNewMoney(dto.getServiceCharge().subtract(dto.getVenue()).subtract(dto.getClean())
+					.subtract(dto.getMaintain()).multiply(subtract9).subtract(subtract1));
 
 			tSettlementConfirm.setTotalService(dto.getTotalService());
 			tSettlementConfirm.setServiceRemark(dto.getServiceRemark());
 			tSettlementConfirm.setDistribution(dto.getDistribution());
 			tSettlementConfirm.setIncome(dto.getElectrovalence().add(dto.getServiceCharge()));
 			tSettlementConfirm.setCost(dto.getVenue().add(dto.getClean()).add(dto.getMaintain()).add(dto.getSupplyElectronic()));
-			tSettlementConfirm.setProfitMoney(chargingElectronic.add(serviceCharge).subtract(tSettlementConfirm.getCost()));
-			tSettlementConfirm.setNewSettlement(subtract2.subtract(tSettlementConfirm.getCost()));
-
+			tSettlementConfirm.setProfitMoney(tSettlementConfirm.getIncome().subtract(tSettlementConfirm.getCost()));
+			tSettlementConfirm.setNewSettlement(tSettlementConfirm.getProfitMoney().add(tSettlementConfirm.getCost()));
+			tSettlementConfirm.setServiceMoney(dto.getServiceCharge().subtract(dto.getVenue()).subtract(dto.getClean())
+					.subtract(dto.getMaintain()).multiply(dto.getServicePartner()));
 			tSettlementConfirmMapper.insert(tSettlementConfirm);
 		}
 		return tSettlementConfirm;
@@ -2718,7 +2743,9 @@
 		BigDecimal beforeCost= new BigDecimal("0");
 		// 上月利润合计
 		BigDecimal beforeIncome= new BigDecimal("0");
+		int i = 1;
 		for (TSettlementConfirm tSettlementConfirm : list1) {
+			tSettlementConfirm.setXuhao(i);
 			tSettlementConfirm.setMetering(tSettlementConfirm.getSupplyElectronic());
 			List<Site> data1 = siteClient.getSiteByIds(Arrays.asList(tSettlementConfirm.getSiteId())).getData();
 			if (!data1.isEmpty()){
@@ -2821,6 +2848,8 @@
 
 
 			for (TSettlementConfirm settlementConfirm : list2) {
+				int value = parse.getMonth().getValue();
+				settlementConfirm.setMonth(value);
 				settlementConfirm.setIncome(settlementConfirm.getElectrovalence().add(settlementConfirm.getServiceCharge()));
 				tSettlementConfirm.setMetering(tSettlementConfirm.getSupplyElectronic());
 				if (tSettlementConfirm.getSiteId().equals(settlementConfirm.getSiteId())){
@@ -2843,11 +2872,11 @@
 					tSettlementConfirm.setTotalPercentage(bigDecimal1+"%");				}
 				beforeCost = beforeCost.add(settlementConfirm.getCost());
 				beforeIncome = beforeIncome.add(settlementConfirm.getIncome());
-
-
 			}
+			i++;
 		}
 		TSettlementConfirm tSettlementConfirm = new TSettlementConfirm();
+		tSettlementConfirm.setMonth(parse.getMonthValue());
 		tSettlementConfirm.setMeteringElectronic(meteringElectronic);
 		tSettlementConfirm.setChargingElectronic(chargingElectronic);
 		tSettlementConfirm.setLossElectronic(lossElectronic);

--
Gitblit v1.7.1