java/mx_charging_pile.git

			@@ -1,29 +1,21 @@
			package com.ruoyi.order.service.impl;

			import com.alibaba.fastjson2.JSON;
			import com.alibaba.fastjson2.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.baomidou.mybatisplus.core.toolkit.Wrappers;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.ruoyi.account.api.feignClient.AppUserCarClient;
			import com.ruoyi.account.api.feignClient.AppUserClient;
			import com.ruoyi.account.api.feignClient.AppUserVipDetailClient;
			import com.ruoyi.account.api.model.TAppUser;
			import com.ruoyi.account.api.model.TAppUserCar;
			import com.ruoyi.account.api.model.TAppUserVipDetail;
			import com.ruoyi.account.api.feignClient.*;
			import com.ruoyi.account.api.model.*;
			import com.ruoyi.account.api.vo.GetAppUserVipDetail;
			import com.ruoyi.chargingPile.api.feignClient.AccountingStrategyDetailClient;
			import com.ruoyi.chargingPile.api.feignClient.ChargingGunClient;
			import com.ruoyi.chargingPile.api.feignClient.ChargingPileClient;
			import com.ruoyi.chargingPile.api.feignClient.SiteClient;
			import com.ruoyi.chargingPile.api.model.Site;
			import com.ruoyi.chargingPile.api.model.TAccountingStrategyDetail;
			import com.ruoyi.chargingPile.api.model.TChargingGun;
			import com.ruoyi.chargingPile.api.model.TChargingPile;
			import com.ruoyi.account.api.vo.GetInviteUser;
			import com.ruoyi.chargingPile.api.feignClient.*;
			import com.ruoyi.chargingPile.api.model.*;
			import com.ruoyi.chargingPile.api.vo.GetChargingGunByCode;
			import com.ruoyi.common.core.domain.R;
			import com.ruoyi.common.core.dto.ChargingOrderGroup;
			import com.ruoyi.common.core.dto.ChargingPercentProvinceDto;
			import com.ruoyi.common.core.web.domain.AjaxResult;
			import com.ruoyi.common.core.web.page.BasePage;
			import com.ruoyi.common.core.web.page.PageInfo;
			import com.ruoyi.common.redis.service.RedisService;
			import com.ruoyi.common.security.service.TokenService;
			@@ -35,22 +27,30 @@
			import com.ruoyi.integration.api.model.PlatformStartCharging;
			import com.ruoyi.integration.api.model.PlatformStartChargingReply;
			import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData;
			import com.ruoyi.integration.api.feignClient.*;
			import com.ruoyi.integration.api.model.*;
			import com.ruoyi.integration.api.vo.GetPlatformStopChargingReply;
			import com.ruoyi.order.api.dto.SettlementConfirmAdd;
			import com.ruoyi.order.api.feignClient.AccountingStrategyDetailOrderClient;
			import com.ruoyi.order.api.feignClient.AccountingStrategyOrderClient;
			import com.ruoyi.order.api.model.*;
			import com.ruoyi.order.api.query.ChargingOrderQuery;
			import com.ruoyi.order.api.query.SettlementListQuery;
			import com.ruoyi.order.api.query.UploadRealTimeMonitoringDataQuery;
			import com.ruoyi.order.api.vo.ChargingOrderListVO;
			import com.ruoyi.order.api.vo.ChargingOrderTimeVO;
			import com.ruoyi.order.api.vo.ChargingOrderVO;
			import com.ruoyi.order.api.vo.TCharingOrderVO;
			import com.ruoyi.order.api.vo.*;
			import com.ruoyi.order.api.vo.PlatformStopChargingReplyVO;
			import com.ruoyi.order.dto.*;
			import com.ruoyi.order.mapper.TChargingOrderMapper;
			import com.ruoyi.order.mapper.TSettlementConfirmMapper;
			import com.ruoyi.order.service.TChargingOrderAccountingStrategyService;
			import com.ruoyi.order.service.TChargingOrderRefundService;
			import com.ruoyi.order.service.TChargingOrderService;
			import com.ruoyi.order.service.TOrderEvaluateService;
			import com.ruoyi.other.api.domain.TCoupon;
			import com.ruoyi.other.api.domain.TGoods;
			import com.ruoyi.order.service.*;
			import com.ruoyi.order.vo.EndOfChargePageInfo;
			import com.ruoyi.other.api.domain.*;
			import com.ruoyi.order.vo.ChargingOrderListInfoVO;
			import com.ruoyi.other.api.feignClient.*;
			import com.ruoyi.payment.api.feignClient.AliPaymentClient;
			import com.ruoyi.payment.api.feignClient.WxPaymentClient;
			import com.ruoyi.payment.api.model.RefundReq;
			@@ -58,19 +58,24 @@
			import com.ruoyi.payment.api.model.WxPaymentRefundModel;
			import com.ruoyi.payment.api.vo.*;
			import io.seata.spring.annotation.GlobalTransactional;
			import io.swagger.annotations.ApiModelProperty;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;
			import org.springframework.beans.BeanUtils;
			import org.springframework.stereotype.Service;
			import org.springframework.util.StringUtils;

			import javax.annotation.Resource;
			import java.lang.reflect.InvocationTargetException;
			import java.math.BigDecimal;
			import java.math.MathContext;
			import java.math.RoundingMode;
			import java.text.SimpleDateFormat;
			import java.time.LocalDate;
			import java.time.LocalDateTime;
			import java.time.ZoneOffset;
			import java.time.format.DateTimeFormatter;
			import java.time.temporal.ChronoUnit;
			import java.time.format.TextStyle;
			import java.time.temporal.WeekFields;
			import java.util.*;
			import java.util.concurrent.*;
			import java.util.stream.Collectors;
			@@ -86,9 +91,13 @@
			@Service
			public class TChargingOrderServiceImpl extends ServiceImpl<TChargingOrderMapper, TChargingOrder> implements TChargingOrderService {

			private Logger log = LoggerFactory.getLogger(TChargingOrderServiceImpl.class);

			@Resource
			private ChargingGunClient chargingGunClient;

			@Resource
			private TSettlementConfirmMapper tSettlementConfirmMapper;

			@Resource
			private SiteClient siteClient;

			@@ -99,7 +108,6 @@

			@Resource
			private ChargingPileClient chargingPileClient;


			@Resource
			private TChargingOrderAccountingStrategyService chargingOrderAccountingStrategyService;
			@@ -112,9 +120,9 @@

			@Resource
			private AliPaymentClient aliPaymentClient;



			@Resource
			private AppCouponClient appCouponClient;

			@Resource
			private AppUserVipDetailClient appUserVipDetailClient;
			@@ -133,10 +141,15 @@

			@Resource
			private TOrderEvaluateService orderEvaluateService;



			@Resource
			private AccountingStrategyDetailClient accountingStrategyDetailClient;

			@Resource
			private AccountingStrategyDetailOrderClient accountingStrategyDetailOrderClient;

			@Resource
			private AccountingStrategyClient accountingStrategyClient;

			@Resource
			private PlatformStartChargingReplyClient platformStartChargingReplyClient;
			@@ -144,8 +157,41 @@
			@Resource
			private TChargingOrderRefundService chargingOrderRefundService;

			@Resource
			private PlatformStopChargingReplyClient platformStopChargingReplyClient;

			@Resource
			private AccountingStrategyOrderService accountingStrategyOrderService;

			@Resource
			private AccountingStrategyDetailOrderService accountingStrategyDetailOrderService;

			@Resource
			private InviteUserClient inviteUserClient;

			@Resource
			private AppUserIntegralChangeClient appUserIntegralChangeClient;

			@Resource
			private IntegralRuleClient integralRuleClient;

			@Resource
			private VipClient vipClient;

			@Resource
			private UserTagClient userTagClient;

			@Resource
			private AppUserTagClient appUserTagClient;

			@Resource
			private SecurityDetectionClient securityDetectionClient;

			//计数器
			private Map<String, Integer> counter_map = new HashMap<>();

			//计数器
			private Map<String, Integer> boot_failed_map = new HashMap<>();



			@@ -379,13 +425,14 @@
			//构建新的待支付订单
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
			TChargingOrder chargingOrder = new TChargingOrder();
			String code = "CD" + Math.random() * 1000 + sdf.format(new Date());
			String code = "CD" + Double.valueOf(Math.random() * 1000).intValue() + sdf.format(new Date());
			chargingOrder.setCode(code);
			chargingOrder.setOrderType(1);
			chargingOrder.setOrderClassification(1);
			chargingOrder.setAppUserId(userId);
			chargingOrder.setAppUserCarId(addChargingOrder.getAppUserCarId());
			TChargingGun tChargingGun = chargingGunClient.getChargingGunById(addChargingOrder.getId()).getData();
			TChargingPile chargingPile = chargingPileClient.getChargingPileById(tChargingGun.getChargingPileId()).getData();
			chargingOrder.setSiteId(tChargingGun.getSiteId());
			chargingOrder.setChargingPileId(tChargingGun.getChargingPileId());
			chargingOrder.setChargingGunId(addChargingOrder.getId());
			@@ -393,7 +440,30 @@
			chargingOrder.setRechargePaymentStatus(1);
			chargingOrder.setRechargeAmount(addChargingOrder.getPaymentAmount());
			chargingOrder.setAppCouponId(addChargingOrder.getAppUserCouponId());
			if(null != appUser.getVipId()){
			chargingOrder.setVipDiscount(new BigDecimal(10));
			chargingOrder.setVipDiscountAmount(BigDecimal.ZERO);
			chargingOrder.setOrderSource(0);
			chargingOrder.setTitle("【充电桩充电】" + chargingPile.getNumber() + "号桩/" + tChargingGun.getCode() + "号枪");

			Site site = siteClient.getSiteByIds(Arrays.asList(tChargingGun.getSiteId())).getData().get(0);
			Integer accountingStrategyId = tChargingGun.getAccountingStrategyId();
			if(null == accountingStrategyId){
			//查询站点上面的计费策略
			accountingStrategyId = site.getAccountingStrategyId();
			}
			TAccountingStrategy accountingStrategy = accountingStrategyClient.getAccountingStrategyById(accountingStrategyId).getData();

			//直营站点才可以享受会员折扣
			if(null != appUser.getVipId() && 1 == site.getBusinessCategory()){
			TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();
			BigDecimal discount = null;
			if(1 == vip.getType()){
			//普通会员折扣使用积分策略上的折扣，且有最高优惠金额
			discount = accountingStrategy.getDiscount();
			}else{
			//内部会员使用会员信息设置的折扣，没有最高优惠金额
			discount = vip.getDiscount();
			}
			GetAppUserVipDetail getAppUserVipDetail = new GetAppUserVipDetail();
			getAppUserVipDetail.setAppUserId(appUser.getId());
			getAppUserVipDetail.setVipId(appUser.getVipId());
			@@ -401,15 +471,27 @@
			if(null != vipDetail){
			Integer chargeNum = vipDetail.getChargeNum();
			if(0 > chargeNum){
			chargingOrder.setVipDiscount(vipDetail.getDiscount());
			BigDecimal discountAmount = addChargingOrder.getPaymentAmount().multiply((new BigDecimal(10)
			.subtract(vipDetail.getDiscount())).divide(new BigDecimal(10))).setScale(4, BigDecimal.ROUND_HALF_EVEN);
			chargingOrder.setVipDiscountAmount(discountAmount);
			chargingOrder.setVipDiscount(discount);
			}
			}

			}
			this.save(chargingOrder);

			//添加订单的计费策略
			List<TAccountingStrategyDetail> strategyDetailList = accountingStrategyDetailClient.getListByAccountingStrategyId(accountingStrategyId).getData();
			AccountingStrategyOrder accountingStrategyOrder = new AccountingStrategyOrder();
			BeanUtils.copyProperties(accountingStrategy, accountingStrategyOrder);
			accountingStrategyOrder.setChargingOrderId(chargingOrder.getId());
			accountingStrategyOrderService.save(accountingStrategyOrder);
			List<AccountingStrategyDetailOrder> list1 = new ArrayList<>();
			for (TAccountingStrategyDetail tAccountingStrategyDetail : strategyDetailList) {
			AccountingStrategyDetailOrder accountingStrategyDetailOrder = new AccountingStrategyDetailOrder();
			BeanUtils.copyProperties(tAccountingStrategyDetail, accountingStrategyDetailOrder);
			accountingStrategyDetailOrder.setChargingOrderId(chargingOrder.getId());
			list1.add(accountingStrategyDetailOrder);
			}
			accountingStrategyDetailOrderService.saveBatch(list1);

			//会员优惠折扣将其计入增加充电时长（增加总充电金额）
			//如果充电总金额未使用完，则需要退回费用=(原金额/总金额)*(总金额-实际充电金额)
			if(1 == addChargingOrder.getPaymentType()){
			@@ -418,7 +500,7 @@
			paymentOrder.setAmount(addChargingOrder.getPaymentAmount());
			paymentOrder.setOpenId(appUser.getWxOpenid());
			paymentOrder.setDescription("充电充值");
			paymentOrder.setNotifyUrl("/order/t-charging-order/chargingOrderWXCallback");
			paymentOrder.setNotifyUrl("/payment/wx/pay/notify");
			Map<String, Object> data = wxPaymentClient.orderPay(paymentOrder).getData();
			return AjaxResult.success(data);
			}
			@@ -431,7 +513,7 @@
			req.setBody("充电充值");
			AliPaymentResp data = aliPaymentClient.payment(req).getData();
			if(null != data){
			data.setNotifyUrl(data.getNotifyUrl() + "/t-charging-order/chargingOrderALICallback");
			data.setNotifyUrl(data.getNotifyUrl() + "/order/t-charging-order/chargingOrderALICallback");
			return AjaxResult.success(data);
			}
			}
			@@ -457,7 +539,6 @@
			chargingOrder.setRechargePaymentStatus(2);
			chargingOrder.setRechargeSerialNumber(transaction_id);
			chargingOrder.setStatus(2);
			this.updateById(chargingOrder);

			//添加安全检测数据到缓存中，每步安全检测完成后需要更新缓存数据
			PreChargeCheck preChargeCheck = new PreChargeCheck();
			@@ -466,103 +547,284 @@
			preChargeCheck.setSecureConnectionDetection(false);
			preChargeCheck.setStartupSuccess(1);
			String key = "AQJC_" + chargingOrder.getChargingGunId();
			redisService.setCacheObject(key, preChargeCheck);
			redisService.setCacheObject(key, preChargeCheck, 24L, TimeUnit.HOURS);

			//根据当前充值的金额和计费模板算出充电的金额
			BigDecimal rechargeAmount = chargingOrder.getRechargeAmount();
			//计算充电金额，会员需要将折扣金额加入到充电总金额中
			TChargingGun chargingGun = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();
			TAccountingStrategyDetail strategyDetail = accountingStrategyDetailClient.getNowData(chargingGun.getAccountingStrategyId()).getData();
			//总单价
			BigDecimal totalUnitPrice = strategyDetail.getServiceCharge().add(strategyDetail.getElectrovalence());
			//计算能充电的度数
			BigDecimal degrees = rechargeAmount.divide(totalUnitPrice);
			BigDecimal rechargeAmount1 = new BigDecimal(rechargeAmount.toString());
			SimpleDateFormat sdf = new SimpleDateFormat("HHmm");
			Long now = Long.valueOf(sdf.format(new Date()));
			Long nowTimeMillis = System.currentTimeMillis();
			//根据支付金额，获取出使用的计费策略明细
			//计算电费金额和服务费
			BigDecimal serviceCharge = strategyDetail.getServiceCharge().multiply(degrees);
			BigDecimal electrovalence = strategyDetail.getElectrovalence().multiply(degrees);

			//再处理会员折扣
			BigDecimal discount = BigDecimal.ZERO;
			BigDecimal serviceCharge = BigDecimal.ZERO;
			BigDecimal discountAmount = BigDecimal.ZERO;
			BigDecimal discount = chargingOrder.getVipDiscount();
			//先根据额定功率计算出每秒充电度数，然后计算出支付金额能充多少度电
			TChargingGun tChargingGun = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();
			//1秒充电度数
			BigDecimal s_degrees = tChargingGun.getRatedPower().divide(new BigDecimal(3600), 6, RoundingMode.HALF_EVEN);

			TAppUser appUser = appUserClient.getUserById(chargingOrder.getAppUserId()).getData();
			//判断会员是否还有充电优惠次数，计算会员优惠的折扣金额
			if(null != appUser.getVipId()){
			GetAppUserVipDetail getAppUserVipDetail = new GetAppUserVipDetail();
			getAppUserVipDetail.setAppUserId(chargingOrder.getAppUserId());
			getAppUserVipDetail.setVipId(appUser.getVipId());
			TAppUserVipDetail data = appUserVipDetailClient.getAppUserVipDetail(getAppUserVipDetail).getData();
			if(data.getChargeNum() > 0){
			discount = serviceCharge.multiply(data.getDiscount().divide(new BigDecimal(10)));
			data.setChargeNum(data.getChargeNum() - 1);
			appUserVipDetailClient.updateAppUserVipDetail(data);
			if(null != data && data.getChargeNum() > 0){
			//计算折扣
			List<AccountingStrategyDetailOrder> list = accountingStrategyDetailOrderClient.getAllAccountingStrategyDetailOrder(chargingOrder.getId()).getData();
			//将数据叠加两份，处理跨天的情况
			list.addAll(list);
			boolean sta = false;
			for (AccountingStrategyDetailOrder accountingStrategyDetailOrder : list) {
			Integer start = Integer.valueOf(accountingStrategyDetailOrder.getStartTime().replaceAll(":", ""));
			Integer end = Integer.valueOf(accountingStrategyDetailOrder.getEndTime().replaceAll(":", ""));
			String[] split = accountingStrategyDetailOrder.getEndTime().split(":");
			if(sta \|\| now >= start){
			sta = true;

			Calendar end_calendar = Calendar.getInstance();
			end_calendar.set(Calendar.HOUR_OF_DAY, Integer.valueOf(split[0]));
			end_calendar.set(Calendar.MINUTE, Integer.valueOf(split[1]));
			//到此策略结束的秒数
			if(null == nowTimeMillis){
			String[] split1 = accountingStrategyDetailOrder.getStartTime().split(":");
			Calendar start_calendar = Calendar.getInstance();
			start_calendar.set(Calendar.HOUR_OF_DAY, Integer.valueOf(split1[0]));
			start_calendar.set(Calendar.MINUTE, Integer.valueOf(split1[1]));
			nowTimeMillis = start_calendar.getTimeInMillis();
			}
			//间隔秒数
			long m = (end_calendar.getTimeInMillis() - nowTimeMillis) / 1000;
			//每秒需要支付的服务费金额
			BigDecimal total_until = accountingStrategyDetailOrder.getElectrovalence().add(accountingStrategyDetailOrder.getServiceCharge());
			BigDecimal s_total_amount = s_degrees.multiply(total_until);
			//每秒需要支付的服务费金额
			BigDecimal s_server_amount = s_degrees.multiply(accountingStrategyDetailOrder.getServiceCharge());
			//计算剩余金额能充多长时间的电
			long times = rechargeAmount1.divide(s_server_amount, 0, RoundingMode.DOWN).longValue();
			if(times > m){
			//充电时间跨度两个计费策略，需要继续对下一个策略进行计算
			serviceCharge = s_server_amount.multiply(new BigDecimal(m));
			discountAmount = discountAmount.add(serviceCharge.multiply((new BigDecimal(10).subtract(discount)).divide(new BigDecimal(10))));
			rechargeAmount1 = rechargeAmount1.subtract(s_total_amount.multiply(new BigDecimal(m)));
			nowTimeMillis = null;
			}else{
			serviceCharge = s_server_amount.multiply(new BigDecimal(times));
			discountAmount = discountAmount.add(serviceCharge.multiply((new BigDecimal(10).subtract(discount)).divide(new BigDecimal(10))));
			break;
			}
			}
			}
			if(discountAmount.compareTo(BigDecimal.ZERO) >= 0){
			//计算会员最大优惠金额
			TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();
			BigDecimal maximumDeduction = vip.getMaximumDeduction();
			//普通会员有最高优惠限制
			if(vip.getType() == 1 && discountAmount.compareTo(maximumDeduction) > 0){
			discountAmount = maximumDeduction;
			}
			}
			discountAmount = discountAmount.setScale(4, RoundingMode.HALF_EVEN);
			}
			}
			electrovalence = electrovalence.add(discount);


			//机子上显示的金额为用户充值的金额+会员折扣金额
			BigDecimal account_balance = chargingOrder.getRechargeAmount().add(discountAmount).setScale(4, RoundingMode.HALF_EVEN);
			chargingOrder.setChargeAmount(account_balance);
			chargingOrder.setVipDiscountAmount(discountAmount);
			this.updateById(chargingOrder);


			TChargingPile chargingPile = chargingPileClient.getChargingPileById(chargingGun.getChargingPileId()).getData();
			TChargingPile chargingPile = chargingPileClient.getChargingPileById(tChargingGun.getChargingPileId()).getData();
			//调用远程启动充电消息
			PlatformStartCharging platformStartCharging = new PlatformStartCharging();
			platformStartCharging.setTransaction_serial_number(chargingOrder.getCode());
			platformStartCharging.setCharging_pile_code(chargingPile.getCode());
			platformStartCharging.setCharging_gun_code(chargingGun.getCode());
			platformStartCharging.setCharging_gun_code(tChargingGun.getCode());
			//使用订单id作为逻辑卡号
			platformStartCharging.setCard_number(chargingOrder.getId().toString());
			platformStartCharging.setAccount_balance(electrovalence);
			platformStartCharging.setAccount_balance(account_balance);

			log.error(chargingOrder.getCode() + "：-------------------远程调起开始充电请求-------------------" + platformStartCharging.toString());
			sendMessageClient.platformStartCharging(platformStartCharging);
			//异步线程检测远程启动的应答结果。如果失败，则需要全额退款
			String code = chargingOrder.getCode();
			Long id = chargingOrder.getId();
			//执行5分钟的定时任务检测
			ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
			scheduler.scheduleAtFixedRate(()->{
			List<PlatformStartChargingReply> data = platformStartChargingReplyClient.getPlatformStartChargingReply(code).getData();
			if(data.size() != 0){
			PlatformStartChargingReply platformStartChargingReply = data.get(1);
			Integer startup_result = platformStartChargingReply.getStartup_result();
			Integer failure_cause = platformStartChargingReply.getFailure_cause();
			Integer counter = counter_map.get(code);
			PreChargeCheck preChargeCheck1 = redisService.getCacheObject(key);
			//状态为5的时候，硬件会间隔60秒后再次检测，依然未插枪，则不启动充电
			//因这里是间隔5秒执行检测，所以累计次数在30次以上
			if(failure_cause == 5 && null == counter \|\| counter < 35){
			counter++;
			counter_map.put(code, counter);
			//启动失败
			preChargeCheck1.setStartupSuccess(3);
			preChargeCheck1.setFailureCause(failure_cause);
			redisService.setCacheObject(key, preChargeCheck1);
			return;
			}
			//清除计时器中的无效数据
			counter_map.remove(code);
			//开始处理退款
			TChargingOrder order = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, code));
			if(0 == startup_result){
			//启动失败
			preChargeCheck1.setStartupSuccess(3);
			preChargeCheck1.setFailureCause(failure_cause);
			//启动失败后取消订单，退款操作
			refund(code);
			order.setStatus(5);
			order.setEndMode(0);
			}else{
			preChargeCheck1.setStartupSuccess(2);
			order.setStatus(3);
			order.setStartTime(LocalDateTime.now());
			}
			this.updateById(order);
			redisService.setCacheObject(key, preChargeCheck1);
			//提前结束定时任务
			if(timingDetection(id)){
			scheduler.shutdown();
			}
			}, 5, 300, TimeUnit.SECONDS);
			}, 5, 1, TimeUnit.SECONDS);
			return AjaxResult.success();
			}


			/**
			* 定时检测mongodb数据库数据
			* @param id
			* @return
			*/
			public boolean timingDetection(Long id){
			TChargingOrder chargingOrder = this.getById(id);
			if(chargingOrder.getStatus() != 2){
			return true;
			}
			String code = chargingOrder.getCode();
			String key = "AQJC_" + chargingOrder.getChargingGunId();
			//获取安全校验
			com.ruoyi.integration.api.model.SecurityDetection securityDetection = securityDetectionClient.getSecurityDetection(chargingOrder.getCode()).getData();
			if(null != securityDetection){
			PreChargeCheck preChargeCheck1 = redisService.getCacheObject("AQJC_" + chargingOrder.getChargingGunId());
			if(null != preChargeCheck1){
			preChargeCheck1.setElectronicLockLock(true);
			preChargeCheck1.setInsulationTesting(true);
			preChargeCheck1.setSecureConnectionDetection(securityDetection.getSecure_connection() == 1);
			preChargeCheck1.setStartupSuccess(1);
			redisService.setCacheObject("AQJC_" + chargingOrder.getChargingGunId(), preChargeCheck1, 24L, TimeUnit.HOURS);
			}
			}

			List<PlatformStartChargingReply> data = platformStartChargingReplyClient.getPlatformStartChargingReply(code).getData();
			if(null == data){
			return false;
			}
			log.error(code + "：-------------------开始检查调起充电结果-------------------" + data.toString());
			if(data.size() != 0){
			PlatformStartChargingReply platformStartChargingReply = data.get(1);
			Integer startup_result = platformStartChargingReply.getStartup_result();
			Integer failure_cause = platformStartChargingReply.getFailure_cause();
			Integer counter = counter_map.get(code);
			PreChargeCheck preChargeCheck1 = redisService.getCacheObject(key);
			//5分钟内还未插枪则取消充电，退回金额。
			if(failure_cause == 5 && (null == counter \|\| counter < 300)){
			counter = (null == counter ? 0 : counter) + 1;
			counter_map.put(code, counter);
			//启动失败
			preChargeCheck1.setStartupSuccess(3);
			preChargeCheck1.setFailureCause(failure_cause);
			redisService.setCacheObject(key, preChargeCheck1, 24L, TimeUnit.HOURS);
			return false;
			}

			//清除计时器中的无效数据
			counter_map.remove(code);
			TChargingOrder order = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, code));
			if(0 == startup_result){
			//启动失败
			preChargeCheck1.setStartupSuccess(3);
			preChargeCheck1.setFailureCause(failure_cause);
			//启动失败后取消订单，退款操作
			refund(code);
			order.setStatus(-1);
			order.setEndMode(0);
			}else{
			//启动成功
			preChargeCheck1.setStartupSuccess(2);
			order.setStatus(3);
			order.setStartTime(LocalDateTime.now());
			}
			this.updateById(order);
			redisService.setCacheObject(key, preChargeCheck1, 24L, TimeUnit.HOURS);
			return true;
			}else{
			Integer counter = boot_failed_map.get(code);
			log.error(code + "：-------------------未上传开启充电结果-------------------" + counter);
			PreChargeCheck preChargeCheck1 = redisService.getCacheObject(key);
			//5分钟内未启动成功，退回金额。
			if(null == counter \|\| counter < 300){
			counter = (null == counter ? 0 : counter) + 1;
			boot_failed_map.put(code, counter);
			//启动失败
			preChargeCheck1.setStartupSuccess(3);
			preChargeCheck1.setFailureCause(0);
			redisService.setCacheObject(key, preChargeCheck1, 24L, TimeUnit.HOURS);
			return false;
			}

			//清除计时器中的无效数据
			boot_failed_map.remove(code);
			TChargingOrder order = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, code));
			//启动失败
			preChargeCheck1.setStartupSuccess(3);
			preChargeCheck1.setFailureCause(0);
			//启动失败后取消订单，退款操作
			refund(code);
			order.setStatus(-1);
			order.setEndMode(0);
			this.updateById(order);
			redisService.setCacheObject(key, preChargeCheck1, 24L, TimeUnit.HOURS);
			return true;
			}
			}


			/**
			* 修改安全检测数据
			* @param securityDetection
			*/
			@Override
			public void securityDetection(SecurityDetectionVO securityDetection){
			GetChargingGunByCode code = new GetChargingGunByCode();
			code.setCharging_pile_code(securityDetection.getCharging_pile_code());
			code.setCharging_gun_code(securityDetection.getCharging_gun_code());
			TChargingGun chargingGun = chargingGunClient.getChargingGunByCode(code).getData();
			PreChargeCheck preChargeCheck1 = redisService.getCacheObject("AQJC_" + chargingGun.getId());
			if(null != preChargeCheck1){
			preChargeCheck1.setElectronicLockLock(true);
			preChargeCheck1.setInsulationTesting(true);
			preChargeCheck1.setSecureConnectionDetection(securityDetection.getSecure_connection() == 1);
			redisService.setCacheObject("AQJC_" + chargingGun.getId(), preChargeCheck1, 24L, TimeUnit.HOURS);
			}
			}

			/**
			* 启动充电应答
			* @param message
			*/
			@Override
			public void startChargeSuccessfully(PlatformStartChargingReplyMessageVO message) {
			Integer startup_result = message.getStartup_result();
			Integer failure_cause = message.getFailure_cause();
			TChargingOrder order = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, message.getTransaction_serial_number()));
			if(order.getStatus() != 2){
			return;
			}
			String code = order.getCode();
			PreChargeCheck preChargeCheck1 = redisService.getCacheObject("AQJC_" + order.getChargingGunId());
			if(null != preChargeCheck1){
			preChargeCheck1.setElectronicLockLock(true);
			preChargeCheck1.setInsulationTesting(true);
			preChargeCheck1.setStartupSuccess(1);
			}
			if(0 == startup_result){
			//启动失败
			preChargeCheck1.setStartupSuccess(3);
			preChargeCheck1.setFailureCause(failure_cause);
			//启动失败后取消订单，退款操作
			refund(code);
			order.setStatus(-1);
			order.setEndMode(0);
			}else{
			//启动成功
			preChargeCheck1.setStartupSuccess(2);
			order.setStatus(3);
			order.setStartTime(LocalDateTime.now());
			}
			redisService.setCacheObject("AQJC_" + order.getChargingGunId(), preChargeCheck1, 24L, TimeUnit.HOURS);
			this.updateById(order);
			}

			/**
			* 启动失败后的退款，取消订单
			* @param code
			*/
			public void refund(String code){
			log.error(code + "：-------------------充电启动失败，执行退款-------------------");
			TChargingOrder chargingOrder = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, code));
			if(chargingOrder.getStatus() == 2){
			Integer rechargePaymentType = chargingOrder.getRechargePaymentType();
			@@ -571,7 +833,7 @@
			TChargingOrderRefund chargingOrderRefund = new TChargingOrderRefund();
			chargingOrderRefund.setChargingOrderId(chargingOrder.getId());
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
			chargingOrderRefund.setRefundCode("CDF" + sdf.format(new Date()) + (Math.random() * 1000));
			chargingOrderRefund.setRefundCode("CDF" + sdf.format(new Date()) + Double.valueOf(Math.random() * 1000).intValue());
			chargingOrderRefund.setRefundAmount(rechargeAmount);
			chargingOrderRefund.setRefundStatus(1);
			chargingOrderRefund.setPayType(rechargePaymentType);
			@@ -588,7 +850,7 @@
			model.setOut_trade_no(chargingOrder.getCode());
			model.setOut_refund_no(chargingOrderRefund.getRefundCode());
			model.setReason("充电失败，取消充电订单");
			model.setNotify_url("http://127.0.0.1:9000/order/t-charging-order/chargingOrderStartupFailureWxRefund");
			model.setNotify_url("/payment/wx/refund/notify");
			WxPaymentRefundModel.RefundAmount amount = new WxPaymentRefundModel.RefundAmount();
			amount.setRefund(rechargeAmount.multiply(new BigDecimal(100)).intValue());
			amount.setTotal(rechargeAmount.multiply(new BigDecimal(100)).intValue());
			@@ -628,13 +890,11 @@
			* @return
			*/
			public AjaxResult chargingOrderStartupFailureWxRefund(String out_refund_no, String refund_id, String tradeState, String success_time){
			if("SUCCESS".equals(tradeState)){
			TChargingOrderRefund one = chargingOrderRefundService.getOne(new LambdaQueryWrapper<TChargingOrderRefund>().eq(TChargingOrderRefund::getRefundCode, out_refund_no));
			one.setRefundSerialNumber(refund_id);
			one.setRefundStatus(2);
			one.setRefundTime(LocalDateTime.parse(success_time, DateTimeFormatter.ofPattern("yyyy-MM-DDTHH:mm:ss+TIMEZONE")));
			chargingOrderRefundService.updateById(one);
			}
			TChargingOrderRefund one = chargingOrderRefundService.getOne(new LambdaQueryWrapper<TChargingOrderRefund>().eq(TChargingOrderRefund::getRefundCode, out_refund_no));
			one.setRefundSerialNumber(refund_id);
			one.setRefundStatus(2);
			one.setRefundTime(LocalDateTime.now());
			chargingOrderRefundService.updateById(one);
			return AjaxResult.success();
			}

			@@ -650,7 +910,7 @@
			public ChargingDetails getChargingDetails(Integer id) {
			Long userId = tokenService.getLoginUserApplet().getUserId();
			TChargingOrder one = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getAppUserId, userId).eq(TChargingOrder::getChargingGunId, id)
			.in(TChargingOrder::getStatus, Arrays.asList(1, 2, 3)).eq(TChargingOrder::getRechargePaymentStatus, 2).eq(TChargingOrder::getDelFlag, 0));
			.eq(TChargingOrder::getRechargePaymentStatus, 2).eq(TChargingOrder::getDelFlag, 0).orderByDesc(TChargingOrder::getStartTime).last(" limit 0, 1"));
			if(null == one){
			return null;
			}
			@@ -693,25 +953,263 @@
			* @return
			*/
			@Override
			@GlobalTransactional(rollbackFor = Exception.class)
			public AjaxResult stopCharging(String id) {
			TChargingOrder chargingOrder = this.getById(id);
			Integer status = chargingOrder.getStatus();
			if(status != 3){
			return AjaxResult.error("还未开始充电");
			}
			if(status == 4 \|\| status == 5){
			return AjaxResult.error("不能重复操作");
			}
			chargingOrder.setStatus(4);
			chargingOrder.setEndTime(LocalDateTime.now());
			chargingOrder.setEndMode(1);
			this.updateById(chargingOrder);
			//调用硬件停止充电，停止成功后开始计算费用退款
			// todo 待完善

			String code1 = chargingOrder.getCode();
			TChargingGun chargingGun = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();
			//异步线程处理停机
			ExecutorService cachedThreadPool = Executors.newFixedThreadPool(1);
			cachedThreadPool.execute(()->{
			//调用硬件停止充电，停止成功后开始计算费用退款
			TChargingPile chargingPile = chargingPileClient.getChargingPileById(chargingOrder.getChargingPileId()).getData();
			PlatformStopCharging platformStopCharging = new PlatformStopCharging();
			platformStopCharging.setCharging_pile_code(chargingPile.getCode());
			platformStopCharging.setCharging_gun_code(chargingGun.getCode());
			sendMessageClient.platformStopCharging(platformStopCharging);
			log.error(code1 + "：-------------------远程停止充电请求-------------------");
			log.error(platformStopCharging.toString());
			//开始查询停机应答，成功后开始计费费用
			boolean stop_status = false;
			for (int i = 0; i < 60; i++) {
			TChargingOrder chargingOrder1 = this.getById(id);
			if(chargingOrder1.getStatus() != 3){
			stop_status = true;
			break;
			}
			GetPlatformStopChargingReply query = new GetPlatformStopChargingReply();
			query.setCharging_gun_code(chargingGun.getCode());
			query.setCharging_pile_code(chargingPile.getCode());
			query.setEnd_time(chargingOrder.getEndTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
			PlatformStopChargingReply reply = platformStopChargingReplyClient.getPlatformStopChargingReply(query).getData();
			log.error(code1 + "：-------------------查询远程停止充电应答-------------------");
			if(null == reply){
			log.error(code1 + "：-------------------远程停止充电应答无数据-------------------");
			try {
			Thread.sleep(1000);
			} catch (InterruptedException e) {
			throw new RuntimeException(e);
			}
			continue;
			}
			log.error(reply.toString());

			if(0 == reply.getStop_result()){
			String failure_cause = "";
			switch (reply.getFailure_cause()){
			case 0:
			failure_cause = "无";
			break;
			case 1:
			failure_cause = "设备编号不匹配";
			break;
			case 2:
			failure_cause = "枪未处于充电状态";
			break;
			case 3:
			failure_cause = "其他";
			break;
			}
			log.error(code1 + "：停机失败：订单号：{}，失败原因：{}", chargingOrder.getCode(), failure_cause);
			try {
			Thread.sleep(1000);
			} catch (InterruptedException e) {
			throw new RuntimeException(e);
			}
			}else{
			log.error(code1 + "：-------------------远程停止充电请求成功-------------------");
			stop_status = true;
			break;
			}
			}
			if(stop_status){
			chargingOrder.setEndMode(1);
			this.updateById(chargingOrder);
			}else{
			log.error(code1 + "：-------------------远程停止充电应答最终失败-------------------");
			}
			});
			return AjaxResult.success();
			}



			public void endCharge(){



			/**
			* 结束充电后处理用户标签数据
			* @param chargingOrder
			*/
			public void editUserTag(TChargingOrder chargingOrder){
			//处理用户标签数据
			List<TUserTag> data = userTagClient.getAllUserTag().getData();
			//累计充电次数
			long count1 = this.count(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getAppUserId, chargingOrder.getAppUserId())
			.eq(TChargingOrder::getRechargePaymentStatus, 2).isNotNull(TChargingOrder::getPaymentAmount).eq(TChargingOrder::getDelFlag, 0));
			List<TUserTag> userTagList1 = data.stream().filter(s -> s.getStandardCondition() == 1).collect(Collectors.toList());
			int old_times = 0;
			Integer userTagId = null;
			for (TUserTag tUserTag : userTagList1) {
			Integer times = JSON.parseObject(tUserTag.getConditions()).getInteger("times");
			//加上本次充电
			//获取最大值标签
			if((count1 + 1) >= times && old_times < times){
			userTagId = tUserTag.getId();
			old_times = times;
			}
			}
			if(null != userTagId){
			TAppUserTag appUserTag = new TAppUserTag();
			appUserTag.setAppUserId(chargingOrder.getAppUserId());
			appUserTag.setUserTagId(userTagId);
			TAppUserTag data1 = appUserTagClient.getUserTag(appUserTag).getData();
			if(null == data1){
			data1 = new TAppUserTag();
			data1.setAppUserId(chargingOrder.getAppUserId());
			data1.setUserTagId(userTagId);
			data1.setCreateTime(LocalDateTime.now());
			appUserTagClient.addUserTag(data1);
			}
			}
			//充电评率
			List<TUserTag> userTagList2 = data.stream().filter(s -> s.getStandardCondition() == 2).collect(Collectors.toList());
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			for (TUserTag tUserTag : userTagList2) {
			TAppUserTag appUserTag = new TAppUserTag();
			appUserTag.setAppUserId(chargingOrder.getAppUserId());
			appUserTag.setUserTagId(tUserTag.getId());
			TAppUserTag data1 = appUserTagClient.getUserTag(appUserTag).getData();
			if(null == data1){
			Integer day = JSON.parseObject(tUserTag.getConditions()).getInteger("day");
			Integer times = JSON.parseObject(tUserTag.getConditions()).getInteger("times");
			Calendar start = Calendar.getInstance();
			start.set(Calendar.DAY_OF_YEAR, start.get(Calendar.DAY_OF_YEAR) + day);
			count1 = this.count(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getAppUserId, chargingOrder.getAppUserId())
			.eq(TChargingOrder::getRechargePaymentStatus, 2).isNotNull(TChargingOrder::getPaymentAmount)
			.between(TChargingOrder::getStartTime, sdf.format(start.getTime()), sdf.format(new Date())).eq(TChargingOrder::getDelFlag, 0));
			//加上本次充电
			if(count1 >= times){
			data1 = new TAppUserTag();
			data1.setAppUserId(chargingOrder.getAppUserId());
			data1.setUserTagId(tUserTag.getId());
			data1.setCreateTime(LocalDateTime.now());
			appUserTagClient.addUserTag(data1);
			}
			}
			}
			}


			/**
			* 推荐奖励(被推荐首单奖励)
			* @param chargingOrder
			*/
			public void referralReward(TChargingOrder chargingOrder){
			//处理推荐奖励(被推荐首单奖励)
			TAppUser appUser = appUserClient.getUserById(chargingOrder.getAppUserId()).getData();
			long count = this.count(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getAppUserId, chargingOrder.getAppUserId())
			.eq(TChargingOrder::getStatus, 5).isNull(TChargingOrder::getEndMode).eq(TChargingOrder::getDelFlag, 0));
			if(null != appUser.getInviteUserId() && 1 == count){
			TIntegralRule integralRule = integralRuleClient.getSet().getData();
			String inviteUsersToEarnPoints = integralRule.getInviteUsersToEarnPoints();
			JSONObject jsonObject = JSON.parseObject(inviteUsersToEarnPoints);
			Integer num1 = jsonObject.getInteger("num1");

			TAppUser appUser1 = appUserClient.getUserById(appUser.getInviteUserId()).getData();
			if(null != appUser1.getVipId()){
			TVip vip = vipClient.getInfo1(appUser1.getVipId()).getData();
			Integer doubleIntegration = vip.getDoubleIntegration();
			//双倍积分
			if(1 == doubleIntegration){
			num1 *= 2;
			}
			}

			GetInviteUser query = new GetInviteUser();
			query.setAppUserId(appUser1.getId());
			query.setBeInvitedAppUserId(chargingOrder.getAppUserId());
			TInviteUser inviteUser = inviteUserClient.getInviteUser(query).getData();
			if(null == inviteUser){
			inviteUser = new TInviteUser();
			inviteUser.setAppUserId(appUser1.getId());
			inviteUser.setBeInvitedAppUserId(chargingOrder.getAppUserId());
			inviteUser.setAward(num1);
			inviteUser.setCreateTime(LocalDateTime.now());
			inviteUserClient.saveInviteUser(inviteUser);
			}else{
			inviteUser.setAward(num1);
			inviteUserClient.updateInviteUser(inviteUser);
			}
			TAppUserIntegralChange appUserIntegralChange = new TAppUserIntegralChange();
			String code = Double.valueOf(Math.random() * 1000).intValue() + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS"));
			appUserIntegralChange.setCode(code);
			appUserIntegralChange.setAppUserId(appUser1.getId());
			appUserIntegralChange.setChangeType(5);
			appUserIntegralChange.setHistoricalIntegral(appUser1.getPoints());
			appUserIntegralChange.setCurrentIntegral(appUser1.getPoints() + num1);
			appUserIntegralChange.setCreateTime(LocalDateTime.now());
			appUserIntegralChange.setOrderCode(chargingOrder.getCode());
			appUserIntegralChangeClient.addAppUserIntegralChange(appUserIntegralChange);

			appUser1.setPoints(appUser1.getPoints() + num1);
			appUserClient.updateAppUser(appUser1);
			}
			}



			/**
			* 停止充电应答结果处理
			* @param platformStopChargingReply
			*/
			@Override
			public void terminateSuccessfulResponse(PlatformStopChargingReplyVO platformStopChargingReply){
			GetChargingGunByCode code = new GetChargingGunByCode();
			code.setCharging_gun_code(platformStopChargingReply.getCharging_gun_code());
			code.setCharging_pile_code(platformStopChargingReply.getCharging_pile_code());
			TChargingGun chargingGun = chargingGunClient.getChargingGunByCode(code).getData();
			TChargingOrder order = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getChargingGunId, chargingGun.getId())
			.orderByDesc(TChargingOrder::getEndTime).eq(TChargingOrder::getRechargePaymentStatus, 2).last(" limit 0, 1"));
			if(null != order && order.getStatus() != 3){
			return;
			}

			String code1 = order.getCode();
			if(0 == platformStopChargingReply.getStop_result()){
			String failure_cause = "";
			switch (platformStopChargingReply.getFailure_cause()){
			case 0:
			failure_cause = "无";
			break;
			case 1:
			failure_cause = "设备编号不匹配";
			break;
			case 2:
			failure_cause = "枪未处于充电状态";
			break;
			case 3:
			failure_cause = "其他";
			break;
			}
			log.error(code1 + "：停机失败：订单号：{}，失败原因：{}", order.getCode(), failure_cause);
			}else{
			TChargingOrder chargingOrder = new TChargingOrder();
			chargingOrder.setId(order.getId());
			chargingOrder.setAppUserId(order.getAppUserId());
			chargingOrder.setEndMode(1);
			this.updateById(chargingOrder);
			}
			}





			@@ -755,6 +1253,12 @@
			for (ChargingOrderVO chargingOrderVO : list) {
			TChargingGun data3 = chargingGunClient.getChargingGunById(chargingOrderVO.getChargingGunId()).getData();
			TChargingPile data2 = chargingPileClient.getChargingPileById(chargingOrderVO.getChargingPileId()).getData();
			if (chargingOrderVO.getSiteId()!=null){
			List<Integer> integers = new ArrayList<>();
			integers.add(chargingOrderVO.getSiteId());
			List<Site> data = siteClient.getSiteByIds(integers).getData();
			if (!data.isEmpty())chargingOrderVO.setSiteName(data.get(0).getName());
			}
			if (data2!=null && data3!=null){
			chargingOrderVO.setTerminalName(data2.getName()+"-"+data3.getName());

			@@ -770,7 +1274,9 @@
			// 单个订单累计服务费
			BigDecimal serviceMoney1 = new BigDecimal("0");
			UploadRealTimeMonitoringData data5 = uploadRealTimeMonitoringDataClient.chargingOrderInfo(chargingOrderVO.getCode()).getData();
			chargingOrderVO.setChargingSecond(data5.getTime_remaining()*60L);
			if (data5!=null){
			chargingOrderVO.setChargingSecond(data5.getTime_remaining()*60L);
			}
			// 总收入
			if (chargingOrderVO.getRefundStatus() !=null && chargingOrderVO.getRefundStatus() == 2){
			income = income.add(chargingOrderVO.getPaymentAmount().subtract(chargingOrderVO.getRefundAmount()));
			@@ -853,35 +1359,36 @@
			}

			@Override
			public Map<String, BigDecimal> countAll(LocalDate sixBefore) {
			public Map<String, Object> countAll(LocalDate sixBefore) {
			return this.baseMapper.countAll(sixBefore);
			}

			@Override
			public List<Map<String, BigDecimal>> getSumByType(List<Long> chargingOrderIds) {
			public List<Map<String, Object>> getSumByType(List<Long> chargingOrderIds) {
			return this.baseMapper.getSumByType(chargingOrderIds);
			}

			@Override
			public List<Map<String, BigDecimal>> getDateData(List<Long> chargingOrderIds) {
			public List<Map<String, Object>> getDateData(List<Long> chargingOrderIds) {
			return this.baseMapper.getDateData(chargingOrderIds);
			}

			@Override
			public List<Map<String, BigDecimal>> getWeekData(List<Long> chargingOrderIds) {
			public List<Map<String, Object>> getWeekData(List<Long> chargingOrderIds) {
			return this.baseMapper.getWeekData(chargingOrderIds);
			}

			@Override
			public List<Map<String, BigDecimal>> getMonthData(List<Long> chargingOrderIds) {
			public List<Map<String, Object>> getMonthData(List<Long> chargingOrderIds) {
			return this.baseMapper.getMonthData(chargingOrderIds);
			}

			@Override
			public List<Map<String, BigDecimal>> getYearData(List<Long> chargingOrderIds) {
			public List<Map<String, Object>> getYearData(List<Long> chargingOrderIds) {
			return this.baseMapper.getYearData(chargingOrderIds);
			}


			@Override
			public ChargingOrderTimeVO chargingList(ChargingListQuery dto) {
			String startTime1 = null;
			@@ -894,13 +1401,7 @@
			startTime1 = split[0];
			startTime2 = split[1];
			}
			if (StringUtils.hasLength(dto.getEndTime())){
			String[] split = dto.getEndTime().split(" - ");
			endTime1 = split[0];
			endTime2 = split[1];
			}
			ChargingOrderTimeVO chargingOrderTimeVO = new ChargingOrderTimeVO();


			PageInfo<ChargingOrderListVO> pageInfo = new PageInfo<>(dto.getPageCurr(),dto.getPageSize());
			List<ChargingOrderListVO> list = this.baseMapper.chargingList(pageInfo,dto,startTime1,startTime2,endTime1,endTime2);
			@@ -912,10 +1413,12 @@
			if (!data.isEmpty()) {
			chargingOrderListVO.setSiteName(data.get(0).getName());
			}
			TChargingGun data1 = chargingGunClient.getChargingGunById(chargingOrderListVO.getChargingGunId()).getData();
			TChargingPile data2 = chargingPileClient.getChargingPileById(chargingOrderListVO.getChargingPileId()).getData();
			if (data2 != null && data1 != null) {
			chargingOrderListVO.setTerminalName(data2.getName() + "-" + data1.getName());
			if (chargingOrderListVO.getChargingGunId()!=null && chargingOrderListVO.getChargingPileId()!=null){
			TChargingGun data1 = chargingGunClient.getChargingGunById(chargingOrderListVO.getChargingGunId()).getData();
			TChargingPile data2 = chargingPileClient.getChargingPileById(chargingOrderListVO.getChargingPileId()).getData();
			if (data2 != null && data1 != null) {
			chargingOrderListVO.setTerminalName(data2.getName() + "-" + data1.getName());
			}
			}
			// 获取充电时间
			UploadRealTimeMonitoringData data5 = uploadRealTimeMonitoringDataClient.chargingOrderInfo(chargingOrderListVO.getCode()).getData();
			@@ -926,20 +1429,30 @@
			}
			}
			// 获取开始SOC 结束soc
			List<UploadRealTimeMonitoringData> data6 = uploadRealTimeMonitoringDataClient.getDataByOrderCode(chargingOrderListVO.getCode()).getData();
			if (!data6.isEmpty()){
			// 第一条数据soc为开始最后一条数据soc为结束soc
			chargingOrderListVO.setStartSoc(data6.get(0).getSoc().toString());
			chargingOrderListVO.setEndSoc(data6.get(data6.size()-1).getSoc().toString());
			if (chargingOrderListVO.getCode()!=null){
			List<UploadRealTimeMonitoringData> data6 = uploadRealTimeMonitoringDataClient.getDataByOrderCode(chargingOrderListVO.getCode()).getData();
			if (!data6.isEmpty()){
			// 第一条数据soc为开始最后一条数据soc为结束soc
			chargingOrderListVO.setStartSoc(data6.get(0).getSoc().toString());
			chargingOrderListVO.setEndSoc(data6.get(data6.size()-1).getSoc().toString());
			}
			}
			TAppUser data3 = appUserClient.getUserById(chargingOrderListVO.getAppUserId()).getData();
			List<Long> carId = new ArrayList<>();
			if (chargingOrderListVO.getAppUserCarId() != null) {
			carId.add(chargingOrderListVO.getAppUserCarId());
			List<TAppUserCar> data4 = appUserCarClient.getCarByIds(carId).getData();
			if (!data4.isEmpty()) chargingOrderListVO.setLicensePlate(data4.get(0).getLicensePlate());

			if (chargingOrderListVO.getAppUserId()!=null){
			TAppUser data3 = appUserClient.getUserById(chargingOrderListVO.getAppUserId()).getData();
			List<Long> carId = new ArrayList<>();
			if (data3!=null){
			if (chargingOrderListVO.getAppUserCarId() != null) {
			carId.add(chargingOrderListVO.getAppUserCarId());
			if (!carId.isEmpty()){
			List<TAppUserCar> data4 = appUserCarClient.getCarByIds(carId).getData();
			if (data4!=null && !data4.isEmpty()) chargingOrderListVO.setLicensePlate(data4.get(0).getLicensePlate());
			}
			}
			if (data3 != null) chargingOrderListVO.setPhone(data3.getPhone());

			}
			}
			if (data3 != null) chargingOrderListVO.setPhone(data3.getPhone());
			List<TChargingOrderAccountingStrategy> list2 = chargingOrderAccountingStrategyService.lambdaQuery()
			.eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrderListVO.getId()).list();
			// 尖峰平谷充电量度数
			@@ -965,14 +1478,25 @@
			}
			}
			total = total.add(jian).add(feng).add(ping).add(gu);
			chargingOrderListVO.setElectronicProportion(
			jian.divide(total,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%(尖)/"
			+feng.divide(total,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%(峰)/"
			+ping.divide(total,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%(平)/"
			+gu.divide(total,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%(谷)");
			if (total.compareTo(new BigDecimal("0")) != 0){
			chargingOrderListVO.setElectronicProportion(
			jian.divide(total,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%(尖)/"
			+feng.divide(total,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%(峰)/"
			+ping.divide(total,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%(平)/"
			+gu.divide(total,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%(谷)");
			}else{
			chargingOrderListVO.setElectronicProportion(
			"0"+"%(尖)/"+
			"0"+"%(峰)/"+
			"0"+"%(平)/"+
			"0"+"%(谷)");
			}

			}
			// 不分页
			List<ChargingOrderListVO> list1 = this.baseMapper.chargingList1(dto,startTime1,startTime2,endTime1,endTime2);
			PageInfo<ChargingOrderListVO> pageInfo1 = new PageInfo<>(1,999999999);
			List<ChargingOrderListVO> list1 = this.baseMapper.chargingList(pageInfo1,dto,startTime1,startTime2,endTime1,endTime2);
			chargingOrderTimeVO.setExportList(list1);
			chargingOrderTimeVO.setOrderCount(list1.size());
			// 计算充电总度数
			BigDecimal electronic = new BigDecimal("0");
			@@ -998,33 +1522,34 @@
			BigDecimal ping = new BigDecimal("0");
			BigDecimal gu = new BigDecimal("0");
			for (ChargingOrderListVO chargingOrderListVO : list1) {
			electronic = electronic.add(chargingOrderListVO.getChargingCapacity());
			paymentAmount = paymentAmount.add(chargingOrderListVO.getPaymentAmount());
			electrovalence = electrovalence.add(chargingOrderListVO.getElectrovalence());
			serviceCharge = serviceCharge.add(chargingOrderListVO.getServiceCharge());
			if (chargingOrderListVO.getChargingCapacity()!=null)electronic = electronic.add(chargingOrderListVO.getChargingCapacity());

			if (chargingOrderListVO.getPaymentAmount()!=null)paymentAmount = paymentAmount.add(chargingOrderListVO.getPaymentAmount());
			if (chargingOrderListVO.getElectrovalence()!=null)electrovalence = electrovalence.add(chargingOrderListVO.getElectrovalence());
			if (chargingOrderListVO.getServiceCharge()!=null)serviceCharge = serviceCharge.add(chargingOrderListVO.getServiceCharge());
			List<TChargingOrderAccountingStrategy> list2 = chargingOrderAccountingStrategyService.lambdaQuery()
			.eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrderListVO.getId()).list();
			for (TChargingOrderAccountingStrategy temp : list2) {
			switch (temp.getType()){
			case 1:
			jian = jian.add(temp.getChargingCapacity());
			jianElectronic = jianElectronic.add(temp.getChargingCapacity());
			jianService = jianService.add(temp.getChargingCapacity());
			if (temp.getChargingCapacity()!=null)jian = jian.add(temp.getChargingCapacity());
			if (temp.getChargingCapacity()!=null)jianElectronic = jianElectronic.add(temp.getElectrovalence());
			if (temp.getChargingCapacity()!=null)jianService = jianService.add(temp.getServiceCharge());
			break;
			case 2:
			feng = feng.add(temp.getChargingCapacity());
			fengElectronic = fengElectronic.add(temp.getChargingCapacity());
			fengService = fengService.add(temp.getChargingCapacity());
			if (temp.getChargingCapacity()!=null)feng = feng.add(temp.getChargingCapacity());
			if (temp.getChargingCapacity()!=null)fengElectronic = fengElectronic.add(temp.getElectrovalence());
			if (temp.getChargingCapacity()!=null)fengService = fengService.add(temp.getServiceCharge());
			break;
			case 3:
			ping = ping.add(temp.getChargingCapacity());
			pingElectronic = pingElectronic.add(temp.getChargingCapacity());
			pingService = pingService.add(temp.getChargingCapacity());
			if (temp.getChargingCapacity()!=null)ping = ping.add(temp.getChargingCapacity());
			if (temp.getChargingCapacity()!=null)pingElectronic = pingElectronic.add(temp.getElectrovalence());
			if (temp.getChargingCapacity()!=null)pingService = pingService.add(temp.getServiceCharge());
			break;
			case 4:
			gu = gu.add(temp.getChargingCapacity());
			guElectronic = guElectronic.add(temp.getChargingCapacity());
			guService = guService.add(temp.getChargingCapacity());
			if (temp.getChargingCapacity()!=null)gu = gu.add(temp.getChargingCapacity());
			if (temp.getChargingCapacity()!=null)guElectronic = guElectronic.add(temp.getElectrovalence());
			if (temp.getChargingCapacity()!=null)guService = guService.add(temp.getServiceCharge());
			break;
			}
			}
			@@ -1040,68 +1565,125 @@
			BigDecimal add1 = jianService.add(fengService).add(pingService).add(guService);
			// 计算尖峰平谷充电到账占比
			BigDecimal add2 = jian.add(feng).add(ping).add(gu);
			chargingOrderTimeVO.setCapacityProportion(jianElectronic+"度/"+fengElectronic+"度/"+pingElectronic+"度/"+guElectronic+"度-"
			+jianElectronic.divide(add,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+fengElectronic.divide(add,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+pingElectronic.divide(add,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+guElectronic.divide(add,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%");
			chargingOrderTimeVO.setServiceProportion(jianService+"元/"+fengService+"元/"+pingService+"元/"+guService+"元-"
			+jianService.divide(add1,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+fengService.divide(add1,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+pingService.divide(add1,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+guService.divide(add1,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%");
			chargingOrderTimeVO.setElectronicProportion(jian+"元/"+feng+"元/"+ping+"元/"+gu+"元-"
			+jian.divide(add2,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+feng.divide(add2,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+ping.divide(add2,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+gu.divide(add2,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%");
			if (add.compareTo(new BigDecimal("0"))!=0){
			chargingOrderTimeVO.setCapacityProportion(jianElectronic+"度/"+fengElectronic+"度/"+pingElectronic+"度/"+guElectronic+"度-"
			+jianElectronic.divide(add,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+fengElectronic.divide(add,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+pingElectronic.divide(add,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+guElectronic.divide(add,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%");
			chargingOrderTimeVO.setServiceProportion(jianService+"元/"+fengService+"元/"+pingService+"元/"+guService+"元-"
			+jianService.divide(add1,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+fengService.divide(add1,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+pingService.divide(add1,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+guService.divide(add1,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%");
			chargingOrderTimeVO.setElectronicProportion(jian+"元/"+feng+"元/"+ping+"元/"+gu+"元-"
			+jian.divide(add2,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+feng.divide(add2,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+ping.divide(add2,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%/"
			+gu.divide(add2,4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100"))+"%");
			}else{
			chargingOrderTimeVO.setCapacityProportion(jianElectronic+"度/"+fengElectronic+"度/"+pingElectronic+"度/"+guElectronic+"度-"
			+"0"+"%/"
			+"0"+"%/"
			+"0"+"%/"
			+"0"+"%");
			chargingOrderTimeVO.setServiceProportion(jianService+"元/"+fengService+"元/"+pingService+"元/"+guService+"元-"
			+"0"+"%/"
			+"0"+"%/"
			+"0"+"%/"
			+"0"+"%");
			chargingOrderTimeVO.setElectronicProportion(jian+"元/"+feng+"元/"+ping+"元/"+gu+"元-"
			+"0"+"%/"
			+"0"+"%/"
			+"0"+"%/"
			+"0"+"%");
			}
			pageInfo.setRecords(list);
			chargingOrderTimeVO.setList(pageInfo);
			return chargingOrderTimeVO;
			}




			@Override
			public ChargingOrderListInfoVO chargingInfo(String uid) {
			TChargingOrder chargingOrder= this.getById(uid);

			ChargingOrderListInfoVO chargingOrderListInfoVO = new ChargingOrderListInfoVO();
			chargingOrderListInfoVO.setElectrovalence(chargingOrder.getElectrovalence());
			chargingOrderListInfoVO.setServiceCharge(chargingOrder.getServiceCharge());
			if (chargingOrder.getElectrovalence()!=null && chargingOrder.getServiceCharge()!=null){
			chargingOrderListInfoVO.setTotal(chargingOrder.getElectrovalence().add(chargingOrder.getServiceCharge()));
			}else{
			chargingOrderListInfoVO.setTotal(new BigDecimal("0"));
			}
			if (chargingOrderListInfoVO.getTotal().compareTo(new BigDecimal("0"))>0){
			if (chargingOrder.getCouponDiscountAmount()!=null&& chargingOrder.getVipDiscountAmount()!=null&& chargingOrder.getSharingAmount()!=null&& chargingOrder.getCommissionAmount()!=null){
			chargingOrderListInfoVO.setRealTotal(chargingOrderListInfoVO.getTotal().subtract(chargingOrder.getCouponDiscountAmount()).subtract(chargingOrder.getVipDiscountAmount()).subtract(chargingOrder.getSharingAmount()).subtract(chargingOrder.getCommissionAmount()));
			}else{
			chargingOrderListInfoVO.setRealTotal(chargingOrderListInfoVO.getTotal());
			}
			}else{
			chargingOrderListInfoVO.setRealTotal(new BigDecimal("0"));
			}
			chargingOrderListInfoVO.setCode(chargingOrder.getCode());
			List<Site> data = siteClient.getSiteByIds(Arrays.asList(chargingOrder.getSiteId())).getData();
			if (!data.isEmpty()){
			chargingOrderListInfoVO.setSiteName(data.get(0).getName());
			chargingOrderListInfoVO.setSiteAddress(data.get(0).getAddress());
			}
			TChargingGun data1 = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();
			TChargingPile data2 = chargingPileClient.getChargingPileById(data1.getChargingPileId()).getData();

			if (data1!=null){
			chargingOrderListInfoVO.setGunCode(data1.getCode());
			chargingOrderListInfoVO.setTerminalName(data2.getName()+data1.getName());
			if (chargingOrder.getChargingGunId()!=null){
			TChargingGun data1 = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();
			if (data1!=null){
			TChargingPile data2 = chargingPileClient.getChargingPileById(data1.getChargingPileId()).getData();
			if (data2!=null){
			chargingOrderListInfoVO.setGunCode(data1.getCode());
			chargingOrderListInfoVO.setTerminalName(data2.getName()+data1.getName());
			}
			}
			}

			chargingOrderListInfoVO.setEndMode(chargingOrder.getEndMode());
			// todo 周一完善
			// chargingOrderListInfoVO.setStartSoc();
			// chargingOrderListInfoVO.setEndSoc();
			// chargingOrderListInfoVO.setChargingCapacity();
			// chargingOrderListInfoVO.setSiteId();
			// chargingOrderListInfoVO.setChargingPileId();
			// chargingOrderListInfoVO.setAppUserId();
			// chargingOrderListInfoVO.setAppUserCarId();
			// chargingOrderListInfoVO.setChargingGunId();
			// chargingOrderListInfoVO.setOrderType();
			// chargingOrderListInfoVO.setChargingSecond();
			// chargingOrderListInfoVO.setLicensePlate();
			// chargingOrderListInfoVO.setPhone();
			// chargingOrderListInfoVO.setPaymentAmount();
			// chargingOrderListInfoVO.setElectrovalence();
			// chargingOrderListInfoVO.setServiceCharge();
			// chargingOrderListInfoVO.setStartTime();
			// chargingOrderListInfoVO.setEndTime();
			// chargingOrderListInfoVO.setId();
			// chargingOrderListInfoVO.setUid();
			// chargingOrderListInfoVO.setList();

			// 获取开始SOC 结束soc
			if (chargingOrder.getCode()!=null){
			List<UploadRealTimeMonitoringData> data6 = uploadRealTimeMonitoringDataClient.getDataByOrderCode(chargingOrder.getCode()).getData();
			if (data6!=null){
			if (!data6.isEmpty()){
			// 第一条数据soc为开始最后一条数据soc为结束soc
			chargingOrderListInfoVO.setStartSoc(data6.get(0).getSoc().toString());
			chargingOrderListInfoVO.setEndSoc(data6.get(data6.size()-1).getSoc().toString());
			chargingOrderListInfoVO.setChargingCapacity(data6.get(data6.size()-1).getCharging_degree());
			chargingOrderListInfoVO.setChargingSecond(data6.get(data6.size()-1).getCumulative_charging_time()*60+"");
			SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : data6) {
			uploadRealTimeMonitoringData.setCreateTime(simpleDateFormat.format(uploadRealTimeMonitoringData.getCreate_time()));
			}
			}
			}
			chargingOrderListInfoVO.setList(data6);
			}


			return null;
			if (chargingOrder.getAppUserCarId()!=null){
			List<TAppUserCar> data3 = appUserCarClient.getCarByIds(Collections.singletonList(chargingOrder.getAppUserCarId())).getData();
			if (data3!=null && !data3.isEmpty())chargingOrderListInfoVO.setLicensePlate(data3.get(0).getLicensePlate());
			}
			chargingOrderListInfoVO.setStartTime(chargingOrder.getStartTime());
			chargingOrderListInfoVO.setEndTime(chargingOrder.getEndTime());
			chargingOrderListInfoVO.setId(chargingOrder.getId());
			chargingOrderListInfoVO.setUid(chargingOrder.getId().toString());
			chargingOrderListInfoVO.setCouponDiscountAmount(chargingOrder.getCouponDiscountAmount());
			chargingOrderListInfoVO.setVipDiscountAmount(chargingOrder.getVipDiscountAmount());
			chargingOrderListInfoVO.setSharingAmount(chargingOrder.getSharingAmount());
			chargingOrderListInfoVO.setCommissionAmount(chargingOrder.getCommissionAmount());
			// 查询费用明细列表
			List<TChargingOrderAccountingStrategy> list = chargingOrderAccountingStrategyService.lambdaQuery()
			.eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrder.getId())
			.list();
			chargingOrderListInfoVO.setList1(list);
			return chargingOrderListInfoVO;
			}


			@@ -1111,11 +1693,484 @@
			*/
			@Override
			public void chargeMonitoring(UploadRealTimeMonitoringDataQuery query) {
			// todo 需完善
			if(com.ruoyi.common.core.utils.StringUtils.isNotEmpty(query.getTransaction_serial_number())){
			//获取当前的计费策略
			TChargingOrder chargingOrder = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, query.getTransaction_serial_number()));
			AccountingStrategyDetailOrder strategyDetail = accountingStrategyDetailOrderClient.getNowAccountingStrategyDetailOrder(chargingOrder.getId()).getData();
			TChargingOrderAccountingStrategy chargingOrderAccountingStrategy = chargingOrderAccountingStrategyService.getOne(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>()
			.eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrder.getId()).orderByDesc(TChargingOrderAccountingStrategy::getCreateTime).last(" limit 0, 1"));
			if(null == chargingOrderAccountingStrategy){
			chargingOrderAccountingStrategy = new TChargingOrderAccountingStrategy();
			chargingOrderAccountingStrategy.setChargingOrderId(chargingOrder.getId());
			chargingOrderAccountingStrategy.setAccountingStrategyDetailId(strategyDetail.getId());
			chargingOrderAccountingStrategy.setType(strategyDetail.getType());
			chargingOrderAccountingStrategy.setStartTime(chargingOrder.getStartTime().format(DateTimeFormatter.ofPattern("HH:mm")));
			chargingOrderAccountingStrategy.setEndTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm")));
			chargingOrderAccountingStrategy.setElectrovalence(strategyDetail.getElectrovalence());
			chargingOrderAccountingStrategy.setServiceCharge(strategyDetail.getServiceCharge());
			chargingOrderAccountingStrategy.setCostServiceCharge(strategyDetail.getCostServiceCharge());
			//已充电总度数
			BigDecimal charging_degree = query.getCharging_degree();
			BigDecimal electrovalenc = strategyDetail.getElectrovalence().multiply(charging_degree);
			BigDecimal originalServicePrice = strategyDetail.getServiceCharge().multiply(charging_degree);
			BigDecimal serviceCharge = originalServicePrice;
			//计算优惠金额
			if(null != chargingOrder.getVipDiscount()){
			serviceCharge = serviceCharge.multiply(chargingOrder.getVipDiscount().divide(new BigDecimal(10)));
			}
			chargingOrderAccountingStrategy.setChargingCapacity(charging_degree);
			chargingOrderAccountingStrategy.setPeriodElectricPrice(electrovalenc);
			chargingOrderAccountingStrategy.setPeriodServicePrice(serviceCharge);
			chargingOrderAccountingStrategy.setPeriodOriginalServicePrice(originalServicePrice);
			chargingOrderAccountingStrategy.setCreateTime(LocalDateTime.now());
			chargingOrderAccountingStrategyService.save(chargingOrderAccountingStrategy);
			}else{
			if(chargingOrderAccountingStrategy.getAccountingStrategyDetailId().equals(strategyDetail.getId())){
			//已充电总度数
			BigDecimal charging_degree = query.getCharging_degree();
			BigDecimal chargingCapacity = chargingOrderAccountingStrategy.getChargingCapacity();
			//计算本阶段充电度数
			BigDecimal subtract = charging_degree.subtract(chargingCapacity);
			//计算本阶段费用
			BigDecimal electrovalenc = strategyDetail.getElectrovalence().multiply(subtract);
			BigDecimal originalServicePrice = strategyDetail.getServiceCharge().multiply(subtract);
			BigDecimal serviceCharge = originalServicePrice;
			//计算优惠金额
			if(null != chargingOrder.getVipDiscount()){
			serviceCharge = serviceCharge.multiply(chargingOrder.getVipDiscount().divide(new BigDecimal(10)));
			}
			//将本阶段的费用增加到总费用中
			electrovalenc = electrovalenc.add(chargingOrderAccountingStrategy.getPeriodElectricPrice());
			originalServicePrice = originalServicePrice.add(chargingOrderAccountingStrategy.getPeriodOriginalServicePrice());
			serviceCharge = serviceCharge.add(chargingOrderAccountingStrategy.getPeriodServicePrice());
			chargingOrderAccountingStrategy.setChargingCapacity(charging_degree);
			chargingOrderAccountingStrategy.setPeriodElectricPrice(electrovalenc);
			chargingOrderAccountingStrategy.setPeriodServicePrice(serviceCharge);
			chargingOrderAccountingStrategy.setPeriodOriginalServicePrice(originalServicePrice);
			chargingOrderAccountingStrategy.setEndTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm")));
			chargingOrderAccountingStrategyService.updateById(chargingOrderAccountingStrategy);
			}else{
			chargingOrderAccountingStrategy = new TChargingOrderAccountingStrategy();
			chargingOrderAccountingStrategy.setChargingOrderId(chargingOrder.getId());
			chargingOrderAccountingStrategy.setAccountingStrategyDetailId(strategyDetail.getId());
			chargingOrderAccountingStrategy.setType(strategyDetail.getType());
			chargingOrderAccountingStrategy.setStartTime(chargingOrder.getStartTime().format(DateTimeFormatter.ofPattern("HH:mm")));
			chargingOrderAccountingStrategy.setEndTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm")));
			chargingOrderAccountingStrategy.setElectrovalence(strategyDetail.getElectrovalence());
			chargingOrderAccountingStrategy.setServiceCharge(strategyDetail.getServiceCharge());
			chargingOrderAccountingStrategy.setCostServiceCharge(strategyDetail.getCostServiceCharge());
			//已充电总度数
			BigDecimal charging_degree = query.getCharging_degree();
			BigDecimal electrovalenc = strategyDetail.getElectrovalence().multiply(charging_degree);
			BigDecimal originalServicePrice = strategyDetail.getServiceCharge().multiply(charging_degree);
			BigDecimal serviceCharge = originalServicePrice;
			//计算优惠金额
			if(null != chargingOrder.getVipDiscount()){
			serviceCharge = serviceCharge.multiply(chargingOrder.getVipDiscount().divide(new BigDecimal(10)));
			}
			chargingOrderAccountingStrategy.setChargingCapacity(charging_degree);
			chargingOrderAccountingStrategy.setPeriodElectricPrice(electrovalenc);
			chargingOrderAccountingStrategy.setPeriodServicePrice(serviceCharge);
			chargingOrderAccountingStrategy.setPeriodOriginalServicePrice(originalServicePrice);
			chargingOrderAccountingStrategy.setCreateTime(LocalDateTime.now());
			chargingOrderAccountingStrategyService.save(chargingOrderAccountingStrategy);
			}
			}

			List<TChargingOrderAccountingStrategy> list = chargingOrderAccountingStrategyService.list(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>()
			.eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrder.getId()));
			//总充电金额
			BigDecimal t = BigDecimal.ZERO;
			for (TChargingOrderAccountingStrategy coas : list) {
			t = t.add(coas.getPeriodServicePrice()).add(coas.getPeriodElectricPrice());
			}
			BigDecimal residualAmount = chargingOrder.getRechargeAmount().subtract(t).setScale(4, RoundingMode.HALF_EVEN);
			chargingOrder.setResidualAmount(residualAmount);
			if(query.getOutput_current().compareTo(BigDecimal.ZERO) != 0){
			BigDecimal divide = query.getOutput_current().multiply(query.getOutput_voltage()).divide(new BigDecimal(1000));
			chargingOrder.setChargingPower(divide);
			chargingOrder.setCurrent(query.getOutput_current());
			chargingOrder.setVoltage(query.getOutput_voltage());
			chargingOrder.setPower(query.getOutput_current().multiply(query.getOutput_voltage()));
			chargingOrder.setNeedElec(query.getOutput_current());
			}
			chargingOrder.setElectricity(query.getCharging_degree());
			chargingOrder.setTotalElectricity(new BigDecimal(100 - query.getSoc()));
			this.updateById(chargingOrder);
			}
			}


			/**
			* 自动结束充电后的处理逻辑
			* @param orderCode
			*/
			@Override
			@GlobalTransactional(rollbackFor = Exception.class)
			public void endCharge(String orderCode, Integer endMode) {
			TChargingOrder order = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, orderCode));
			TChargingOrder chargingOrder = new TChargingOrder();
			chargingOrder.setId(order.getId());
			chargingOrder.setAppUserId(order.getAppUserId());
			chargingOrder.setEndMode(endMode);
			this.updateById(chargingOrder);
			}

			/**
			* 异常结束充电处理逻辑
			* @param orderCode
			*/
			@Override
			public void excelEndCharge(String orderCode) {
			endCharge(orderCode, 0);
			}


			/**
			* 停止充电返回账单后计算费用
			* @param vo
			*/
			@Override
			@GlobalTransactional(rollbackFor = Exception.class)
			public void endChargeBillingCharge(TransactionRecordMessageVO vo) {
			TChargingOrder chargingOrder = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, vo.getTransaction_serial_number()));
			Integer status = chargingOrder.getStatus();
			if(status == 4 \|\| status == 5){
			return;
			}

			//计算用户标签
			editUserTag(chargingOrder);
			//用户推荐奖励
			referralReward(chargingOrder);

			//如果使用优惠券需要判断优惠券是否满足使用条件
			//根据实际的充电金额计算退款金额退回费用=(原金额/总金额)*(总金额-实际充电金额)
			//退款金额=优惠券金额+剩余充电金额
			BigDecimal periodElectricPrice_total = BigDecimal.ZERO;
			BigDecimal periodServicePrice_total = BigDecimal.ZERO;
			BigDecimal total = BigDecimal.ZERO;

			//获取订单的计费策略
			List<AccountingStrategyDetailOrder> accountingStrategyDetailOrderList = accountingStrategyDetailOrderClient.getAllAccountingStrategyDetailOrder(chargingOrder.getId()).getData();
			chargingOrderAccountingStrategyService.remove(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>().eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrder.getId()));
			for (int i = 0; i < 12; i++) {
			Class<? extends TransactionRecordMessageVO> clazz = vo.getClass();
			try {
			String time = (String) clazz.getMethod("getTime" + (i + 1)).invoke(vo);
			if(StringUtils.hasLength(time)){
			//充电度数
			Object invoke = clazz.getMethod("getSharp_peak_charge" + (i + 1)).invoke(vo);
			BigDecimal Sharp_peak_charge = new BigDecimal(invoke.toString());
			//充电金额
			Object invoke1 = clazz.getMethod("getSharp_peak_amount" + (i + 1)).invoke(vo);
			BigDecimal sharp_peak_amount = new BigDecimal(invoke1.toString());

			String[] split = time.split("~");
			AccountingStrategyDetailOrder strategyDetail = accountingStrategyDetailOrderList.stream().filter(s -> s.getStartTime().equals(split[1]) && s.getEndTime().equals(split[2])).findFirst().get();

			TChargingOrderAccountingStrategy chargingOrderAccountingStrategy = new TChargingOrderAccountingStrategy();
			chargingOrderAccountingStrategy.setChargingOrderId(chargingOrder.getId());
			chargingOrderAccountingStrategy.setAccountingStrategyDetailId(strategyDetail.getId());
			chargingOrderAccountingStrategy.setType(strategyDetail.getType());
			chargingOrderAccountingStrategy.setStartTime(chargingOrder.getStartTime().format(DateTimeFormatter.ofPattern("HH:mm")));
			chargingOrderAccountingStrategy.setEndTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm")));
			chargingOrderAccountingStrategy.setElectrovalence(strategyDetail.getElectrovalence());
			chargingOrderAccountingStrategy.setServiceCharge(strategyDetail.getServiceCharge());
			chargingOrderAccountingStrategy.setCostServiceCharge(strategyDetail.getCostServiceCharge());
			//已充电总度数
			BigDecimal electrovalenc = strategyDetail.getElectrovalence().multiply(Sharp_peak_charge);
			BigDecimal originalServicePrice = strategyDetail.getServiceCharge().multiply(Sharp_peak_charge);
			BigDecimal serviceCharge = originalServicePrice;
			//计算优惠金额
			if(null != chargingOrder.getVipDiscount()){
			serviceCharge = serviceCharge.multiply(chargingOrder.getVipDiscount().divide(new BigDecimal(10)));
			}
			chargingOrderAccountingStrategy.setChargingCapacity(Sharp_peak_charge);
			chargingOrderAccountingStrategy.setPeriodElectricPrice(electrovalenc);
			chargingOrderAccountingStrategy.setPeriodServicePrice(serviceCharge);
			chargingOrderAccountingStrategy.setPeriodOriginalServicePrice(originalServicePrice);
			chargingOrderAccountingStrategy.setCreateTime(LocalDateTime.now());
			chargingOrderAccountingStrategyService.save(chargingOrderAccountingStrategy);

			BigDecimal periodElectricPrice = chargingOrderAccountingStrategy.getPeriodElectricPrice();
			BigDecimal periodServicePrice = chargingOrderAccountingStrategy.getPeriodOriginalServicePrice();
			periodElectricPrice_total = periodElectricPrice_total.add(periodElectricPrice);
			periodServicePrice_total = periodServicePrice_total.add(periodServicePrice);
			total = total.add(periodElectricPrice).add(periodServicePrice);
			}
			} catch (IllegalAccessException e) {
			throw new RuntimeException(e);
			} catch (InvocationTargetException e) {
			throw new RuntimeException(e);
			} catch (NoSuchMethodException e) {
			throw new RuntimeException(e);
			}
			}


			//原金额
			BigDecimal rechargeAmount = chargingOrder.getRechargeAmount();
			BigDecimal vipDiscountAmount = chargingOrder.getVipDiscountAmount();
			//总金额（充值金额+会员折扣金额）
			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());
			//折扣金额
			BigDecimal discountAmount = BigDecimal.ZERO;
			if(null != chargingOrder.getVipDiscount()){
			//服务费折扣
			discountAmount = periodServicePrice_total.multiply((new BigDecimal(10).subtract(chargingOrder.getVipDiscount())).divide(new BigDecimal(10)));

			TAppUser appUser = appUserClient.getUserById(chargingOrder.getAppUserId()).getData();
			if(null != appUser.getVipId()){
			//判断会员是否还有充电优惠次数
			GetAppUserVipDetail getAppUserVipDetail = new GetAppUserVipDetail();
			getAppUserVipDetail.setAppUserId(chargingOrder.getAppUserId());
			getAppUserVipDetail.setVipId(appUser.getVipId());
			TAppUserVipDetail data = appUserVipDetailClient.getAppUserVipDetail(getAppUserVipDetail).getData();
			if(null != data && data.getChargeNum() > 0){
			data.setChargeNum(data.getChargeNum() - 1);
			appUserVipDetailClient.updateAppUserVipDetail(data);
			}

			TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();
			BigDecimal maximumDeduction = vip.getMaximumDeduction();
			//普通会员有最高优惠限制
			if(vip.getType() == 1 && discountAmount.compareTo(maximumDeduction) > 0){
			discountAmount = maximumDeduction;
			}
			}
			payAmount = payAmount.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()){
			order.setEndMode(1);
			}
			order.setResidualAmount(rechargeAmount.subtract(total));
			order.setEndTime(LocalDateTime.now());
			order.setStatus(5);
			order.setOrderAmount(orderAmount);
			order.setVipDiscountAmount(discountAmount);
			order.setServiceCharge(periodServicePrice_total);
			order.setElectrovalence(periodElectricPrice_total);

			//计算优惠券
			if(null != chargingOrder.getAppCouponId()){
			//判断实际充电金额是否满足优惠券使用条件，如果不满足则不适用优惠券。
			TAppCoupon appCoupon = appCouponClient.getAppCouponById(chargingOrder.getAppCouponId()).getData();
			String couponJson = appCoupon.getCouponJson();
			TCoupon tCoupon = JSON.parseObject(couponJson, TCoupon.class);
			Integer preferentialMode = tCoupon.getPreferentialMode();
			if(1 == preferentialMode){
			//满减
			if(payAmount.compareTo(tCoupon.getMeetTheConditions()) >= 0){
			refundAmount = refundAmount.add(tCoupon.getDiscountAmount());
			order.setCouponDiscountAmount(tCoupon.getDiscountAmount());
			payAmount = payAmount.subtract(tCoupon.getDiscountAmount());
			}else{
			order.setAppCouponId(null);
			order.setCouponDiscountAmount(BigDecimal.ZERO);
			appCouponClient.refund(chargingOrder.getAppCouponId().toString());
			}
			}
			if(2 == preferentialMode){
			//抵扣
			if(payAmount.compareTo(tCoupon.getMeetTheConditions()) >= 0){
			//折扣金额
			BigDecimal divide = payAmount.multiply(new BigDecimal(10).subtract(tCoupon.getDiscount())).divide(new BigDecimal(10));
			divide = divide.compareTo(tCoupon.getMaximumDiscountAmount()) > 0 ? tCoupon.getMaximumDiscountAmount() : divide;
			refundAmount = refundAmount.add(divide);
			order.setCouponDiscountAmount(divide);
			payAmount = payAmount.subtract(divide);
			}else{
			order.setAppCouponId(null);
			order.setCouponDiscountAmount(BigDecimal.ZERO);
			appCouponClient.refund(chargingOrder.getAppCouponId().toString());
			}
			}
			}
			order.setPaymentAmount(payAmount);
			order.setRefundAmount(refundAmount);
			order.setRefundStatus(1);
			this.updateById(order);
			chargingOrder = this.getById(order.getId());

			// 将枪状态重置为空闲
			TChargingGun chargingGun = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();
			chargingGun.setStatus(2);
			chargingGunClient.updateChargingGunById(chargingGun);

			//添加积分
			TIntegralRule integralRule = integralRuleClient.getSet().getData();
			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();
			if(null != appUser.getVipId()){
			TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();
			Integer doubleIntegration = vip.getDoubleIntegration();
			//双倍积分
			if(1 == doubleIntegration){
			integral *= 2;
			}
			}

			TAppUserIntegralChange appUserIntegralChange = new TAppUserIntegralChange();
			appUserIntegralChange.setAppUserId(appUser.getId());
			appUserIntegralChange.setChangeType(2);
			appUserIntegralChange.setHistoricalIntegral(appUser.getPoints());
			appUser.setPoints(appUser.getPoints() + integral);
			appUserIntegralChange.setCurrentIntegral(appUser.getPoints());
			appUserIntegralChange.setCreateTime(LocalDateTime.now());
			appUserIntegralChange.setOrderCode(chargingOrder.getCode());
			appUserClient.updateAppUser(appUser);
			appUserIntegralChangeClient.addAppUserIntegralChange(appUserIntegralChange);
			}


			//开始构建退款费用
			if(refundAmount.compareTo(BigDecimal.ZERO) > 0){
			Integer rechargePaymentType = chargingOrder.getRechargePaymentType();
			//构建退款明细
			TChargingOrderRefund chargingOrderRefund = new TChargingOrderRefund();
			chargingOrderRefund.setChargingOrderId(chargingOrder.getId());
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
			chargingOrderRefund.setRefundCode("CDF" + sdf.format(new Date()) + (Double.valueOf(Math.random() * 1000).intValue()));
			chargingOrderRefund.setRefundAmount(refundAmount);
			chargingOrderRefund.setRefundStatus(1);
			chargingOrderRefund.setPayType(rechargePaymentType);
			chargingOrderRefund.setRefundStatus(1);
			chargingOrderRefund.setCode(chargingOrder.getCode());
			chargingOrderRefund.setRefundTitle("充电完成退款");
			chargingOrderRefund.setRefundContent("充电完成退款");
			chargingOrderRefund.setRefundReason("充电完成退款");
			chargingOrderRefund.setRefundRemark("充电完成退款");
			chargingOrderRefund.setRefundTotalAmount(refundAmount);
			chargingOrderRefund.setPayAmount(rechargeAmount);
			if(1 == rechargePaymentType){
			WxPaymentRefundModel model = new WxPaymentRefundModel();
			model.setOut_trade_no(chargingOrder.getCode());
			model.setOut_refund_no(chargingOrderRefund.getRefundCode());
			model.setReason("充电完成退款");
			model.setNotify_url("/payment/wx/refund/notify");
			WxPaymentRefundModel.RefundAmount amount = new WxPaymentRefundModel.RefundAmount();
			amount.setRefund(refundAmount.multiply(new BigDecimal(100)).intValue());
			amount.setTotal(rechargeAmount.multiply(new BigDecimal(100)).intValue());
			amount.setCurrency("CNY");
			model.setAmount(amount);
			R<String> orderR = wxPaymentClient.refundOrderR(model);
			if(200 == orderR.getCode()){
			chargingOrderRefundService.save(chargingOrderRefund);
			}
			}
			if(2 == rechargePaymentType){
			RefundReq dto = new RefundReq();
			dto.setOutTradeNo(chargingOrder.getCode());
			dto.setOutRequestNo(chargingOrderRefund.getCode());
			dto.setRefundAmount(refundAmount.toString());
			dto.setRefundReason("充电完成退款");
			RefundResp resp = aliPaymentClient.refund(dto).getData();
			if(null != resp){
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-DDTHH:mm:ss+TIMEZONE");
			AjaxResult success = chargingOrderStartupFailureWxRefund(resp.getOutTradeNo(), resp.getTradeNo(), "SUCCESS", sdf1.format(new Date()));
			if(success.isSuccess()){
			chargingOrderRefundService.save(chargingOrderRefund);
			}
			}
			}

			}
			}

			@Override
			public List<Map<String, Object>> getByDate(List<Long> chargingOrderIds) {
			return this.baseMapper.getByDate(chargingOrderIds);
			}

			@Override
			public List<Map<String, Object>> queryPower(List<Integer> siteIds) {
			return this.baseMapper.queryPower(siteIds);
			}

			@Override
			public Map<String, Object> qureryPowerLevel(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.queryPowerLevel(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> queryOrderCountAndMoneyBySiteIdDate(List<Integer> siteIds) {
			return this.baseMapper.queryOrderCountAndMoneyBySiteIdDate(siteIds);
			}

			@Override
			public List<Map<String, Object>> usersDay() {
			return this.baseMapper.usersDay();
			}

			@Override
			public List<Map<String, Object>> usersDay1() {
			return this.baseMapper.usersDay1();
			}

			@Override
			public List<Map<String, Object>> usersByQuery(ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.usersByQuery(statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> getUserTagCount() {
			return this.baseMapper.getUserTagCount();
			}

			@Override
			public List<Map<String, Object>> getVipCount() {
			return this.baseMapper.getVipCount();
			}

			@Override
			public List<Map<String, Object>> unitConsumption(ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.unitConsumption(statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> carUserMethod() {
			return this.baseMapper.carUserMethod();
			}

			@Override
			public List<Map<String, Object>> carUserBrand() {
			return this.baseMapper.carUserBrand();
			}

			@Override
			public Map<String, Object> countLocalCar() {
			return this.baseMapper.countLocalCar();
			}

			@Override
			public Long getAver(List<Integer> siteIds) {
			return this.baseMapper.getAver(siteIds);
			}

			@Override
			public List<Map<String, Object>> getLevelEvaluate(List<Integer> siteIds) {
			return this.baseMapper.getLevelEvaluate(siteIds);
			}


			@Resource
			private TShoppingOrderService shoppingOrderService;
			@Resource
			private TShoppingOrderRefundService shoppingOrderRefundService;
			@Override
			public R payRefund(PayOrderRefundDto payOrderQueryDto) {
			if (payOrderQueryDto.getType()==1){
			@@ -1128,7 +2183,7 @@
			chargingOrderRefund.setRefundTime(LocalDateTime.now());
			chargingOrderRefund.setCode(tChargingOrder.getCode());
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
			chargingOrderRefund.setRefundCode("GDF" + sdf.format(new Date()) + (Math.random() * 1000));
			chargingOrderRefund.setRefundCode("GDF" + sdf.format(new Date()) + (Double.valueOf(Math.random() * 1000).intValue()));
			chargingOrderRefund.setRefundTitle("后台退款");
			chargingOrderRefund.setRefundContent("后台退款");
			chargingOrderRefund.setRefundReason("后台退款");
			@@ -1142,7 +2197,7 @@
			model.setOut_refund_no(chargingOrderRefund.getRefundCode());
			model.setTransaction_id(tChargingOrder.getRechargeSerialNumber());
			model.setReason("取消订单");
			model.setNotify_url("http://127.0.0.1:9000/order/t-shopping-order/cancelShoppingOrderWxRefund");
			model.setNotify_url("/order/t-shopping-order/cancelShoppingOrderWxRefund");
			WxPaymentRefundModel.RefundAmount amount = new WxPaymentRefundModel.RefundAmount();
			amount.setRefund(payOrderQueryDto.getRefundAmount().multiply(new BigDecimal(100)).intValue());
			amount.setTotal(tChargingOrder.getPaymentAmount().multiply(new BigDecimal(100)).intValue());
			@@ -1150,6 +2205,9 @@
			model.setAmount(amount);
			R<String> orderR = wxPaymentClient.refundOrderR(model);
			if(200 == orderR.getCode()){
			tChargingOrder.setRefundStatus(2);
			tChargingOrder.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount()));
			this.baseMapper.updateById(tChargingOrder);
			chargingOrderRefundService.save(chargingOrderRefund);
			}
			}
			@@ -1163,7 +2221,10 @@
			RefundResp resp = aliPaymentClient.refund(dto).getData();
			if(null != resp){
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-DDTHH:mm:ss+TIMEZONE");
			chargingOrderRefundService.save(chargingOrderRefund);
			chargingOrderRefund.setRefundStatus(2);
			chargingOrderRefund.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount()));
			this.baseMapper.updateById(tChargingOrder);
			chargingOrderRefundService.save(chargingOrderRefund);

			}
			}
			@@ -1173,9 +2234,534 @@


			}
			if (payOrderQueryDto.getType()==2){
			TShoppingOrder tChargingOrder = shoppingOrderService.getById(payOrderQueryDto.getOrderId());
			TShoppingOrderRefund chargingOrderRefund = new TShoppingOrderRefund();
			chargingOrderRefund.setShoppingOrderId(tChargingOrder.getId());
			chargingOrderRefund.setRefundAmount(payOrderQueryDto.getRefundAmount());
			chargingOrderRefund.setRefundStatus(1);
			chargingOrderRefund.setPayType(tChargingOrder.getPaymentType());
			chargingOrderRefund.setRefundTime(LocalDateTime.now());
			chargingOrderRefund.setCode(tChargingOrder.getCode());
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
			chargingOrderRefund.setRefundCode("GDF" + sdf.format(new Date()) + (Double.valueOf(Math.random() * 1000).intValue()));
			chargingOrderRefund.setRefundTitle("后台退款");
			chargingOrderRefund.setRefundContent("后台退款");
			chargingOrderRefund.setRefundReason("后台退款");
			chargingOrderRefund.setRefundRemark("后台退款");
			chargingOrderRefund.setRefundTotalAmount(tChargingOrder.getRefundAmount().add(payOrderQueryDto.getRefundAmount()));
			chargingOrderRefund.setPayAmount(tChargingOrder.getPaymentAmount());

			if(1 == tChargingOrder.getPaymentType()){
			WxPaymentRefundModel model = new WxPaymentRefundModel();
			model.setOut_trade_no(tChargingOrder.getCode());
			model.setOut_refund_no(chargingOrderRefund.getRefundCode());
			model.setTransaction_id(tChargingOrder.getSerialNumber());
			model.setReason("取消订单");
			model.setNotify_url("/order/t-shopping-order/cancelShoppingOrderWxRefund");
			WxPaymentRefundModel.RefundAmount amount = new WxPaymentRefundModel.RefundAmount();
			amount.setRefund(payOrderQueryDto.getRefundAmount().multiply(new BigDecimal(100)).intValue());
			amount.setTotal(tChargingOrder.getPaymentAmount().multiply(new BigDecimal(100)).intValue());
			amount.setCurrency("CNY");
			model.setAmount(amount);
			R<String> orderR = wxPaymentClient.refundOrderR(model);
			if(200 == orderR.getCode()){
			tChargingOrder.setRefundStatus(2);
			tChargingOrder.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount()));
			shoppingOrderService.updateById(tChargingOrder);
			shoppingOrderRefundService.save(chargingOrderRefund);
			}
			}

			if(2 == tChargingOrder.getPaymentType()){
			RefundReq dto = new RefundReq();
			dto.setOutTradeNo(tChargingOrder.getCode());
			dto.setOutRequestNo(tChargingOrder.getCode());
			dto.setRefundAmount(payOrderQueryDto.getRefundAmount().toString());
			dto.setRefundReason("取消订单");
			RefundResp resp = aliPaymentClient.refund(dto).getData();
			if(null != resp){
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-DDTHH:mm:ss+TIMEZONE");

			tChargingOrder.setRefundStatus(2);
			tChargingOrder.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount()));
			shoppingOrderService.updateById(tChargingOrder);

			shoppingOrderRefundService.save(chargingOrderRefund);

			}
			}

			}



			return null;
			return R.ok();
			}


			/**
			* 根据车牌号和开始时间查询充电数据
			* @param query
			* @return
			*/
			@Override
			public TChargingOrder getChargingOrderByLicensePlate(GetChargingOrderByLicensePlate query) {
			TAppUserCar appUserCar = appUserCarClient.getAppUserCarByLicensePlate(query.getLicensePlate()).getData();
			if(null == appUserCar){
			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, -1));
			return one;
			}

			@Override
			public TSettlementConfirm settlementAdd(SettlementConfirmAdd dto) {
			List<Site> data = siteClient.getSiteByIds(Arrays.asList(dto.getSiteId())).getData();
			TSettlementConfirm tSettlementConfirm = new TSettlementConfirm();
			if (!data.isEmpty()){
			tSettlementConfirm.setSiteName(data.get(0).getName());
			tSettlementConfirm.setPartnerId(data.get(0).getPartnerId());
			if (data.get(0).getPartnerId()!=null){
			Partner data1 = siteClient.getPartnerR(data.get(0).getPartnerId()).getData();
			if (data1!=null){
			tSettlementConfirm.setPartnerName(data1.getName());
			tSettlementConfirm.setPartnerId(data1.getId());
			}
			}
			}
			String startTime = dto.getStartTime();
			String endTime = dto.getEndTime();
			// 将这两个时间转化为localDateTime
			// 创建 DateTimeFormatter 对象，指定格式
			DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy年MM月dd日 HH:mm:ss");

			// 将字符串解析为 LocalDateTime 对象
			LocalDateTime localDateTime = LocalDateTime.parse(startTime, formatter);
			LocalDateTime localDateTime1 = LocalDateTime.parse(endTime, formatter);
			tSettlementConfirm.setEndTime(localDateTime1);
			tSettlementConfirm.setStartTime(localDateTime);

			// 根据站点id和开始时间和结束时间和归属日期查询充电订单列表
			QueryWrapper<TChargingOrder> eq = new QueryWrapper<TChargingOrder>()
			.eq("site_id", dto.getSiteId())
			.eq("recharge_payment_status",2);
			switch (dto.getType()){
			case 1:
			eq.between("start_time", localDateTime, localDateTime1);
			break;
			case 2:
			eq.between("end_time", localDateTime, localDateTime1);
			break;
			}
			List<TChargingOrder> tChargingOrders = this.baseMapper.selectList(eq);
			// 充电电量度
			BigDecimal chargingElectronic = new BigDecimal("0");
			// 三方收费分佣
			BigDecimal sharingAmount = new BigDecimal("0");
			// 三方交易手续费三方收费*0.6%
			BigDecimal commissionAmount = new BigDecimal("0");
			// 累计电费
			BigDecimal electrovalence = new BigDecimal("0");
			// 累计服务费
			BigDecimal serviceCharge = new BigDecimal("0");
			// 订单手续费订单支付金额*0.6%
			BigDecimal orderCommission = new BigDecimal("0");
			// 会员抵扣
			BigDecimal vipDiscount = new BigDecimal("0");
			// 优惠券抵扣
			BigDecimal couponDiscount = new BigDecimal("0");
			// 支付订单金额需要减去退款金额
			BigDecimal paymentAmount = new BigDecimal("0");
			for (TChargingOrder tChargingOrder : tChargingOrders) {
			// 累加充电总度数
			if (tChargingOrder.getChargingCapacity()!=null){
			chargingElectronic = chargingElectronic.add(tChargingOrder.getChargingCapacity());

			}
			// 累加分佣
			if (tChargingOrder.getSharingAmount()!=null) {
			sharingAmount = sharingAmount.add(tChargingOrder.getSharingAmount());
			}
			// 累加电费
			if (tChargingOrder.getElectrovalence()!=null) {
			electrovalence = electrovalence.add(tChargingOrder.getElectrovalence());
			}
			// 累加服务费
			if (tChargingOrder.getServiceCharge()!=null){
			serviceCharge = serviceCharge.add(tChargingOrder.getServiceCharge());

			}
			// 累加会员折扣
			if (tChargingOrder.getVipDiscountAmount()!=null){
			vipDiscount = vipDiscount.add(tChargingOrder.getVipDiscountAmount());
			}
			// 累加优惠券折扣
			if (tChargingOrder.getCouponDiscountAmount()!=null){
			couponDiscount = couponDiscount.add(tChargingOrder.getCouponDiscountAmount());
			}
			if (tChargingOrder.getRefundStatus()!=null &&tChargingOrder.getRefundStatus() == 2){
			// 如果成功退款那么减去退款金额
			paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount().subtract(tChargingOrder.getRefundAmount()));
			}else{
			if (tChargingOrder.getPaymentAmount()!=null){
			paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount());
			}
			}
			}
			// 三方交易手续费三方收费*0.6%
			commissionAmount = sharingAmount.multiply(new BigDecimal("0.006"));
			// 订单手续费订单支付金额 - 退款金额*0.6%
			orderCommission = paymentAmount.multiply(new BigDecimal("0.006"));
			tSettlementConfirm.setSharingAmount(sharingAmount);
			tSettlementConfirm.setCommissionAmount(commissionAmount);
			tSettlementConfirm.setElectrovalence(electrovalence);
			// 服务费=总服务费-三费收费-交易手续费-交易手续费-服务费会员抵扣-服务费优惠券抵扣
			tSettlementConfirm.setServiceCharge(serviceCharge.subtract(commissionAmount).subtract(sharingAmount).subtract(orderCommission).subtract(vipDiscount).subtract(couponDiscount));
			tSettlementConfirm.setOrderCommission(orderCommission);
			tSettlementConfirm.setVipDiscount(vipDiscount);
			tSettlementConfirm.setCouponDiscount(couponDiscount);
			tSettlementConfirm.setSiteId(dto.getSiteId());
			tSettlementConfirm.setChargingElectronic(chargingElectronic);
			tSettlementConfirm.setIncome(chargingElectronic.add(serviceCharge));
			tSettlementConfirm.setProfitMoney(new BigDecimal("0"));
			tSettlementConfirm.setNewMoney(new BigDecimal("0"));
			tSettlementConfirm.setNewSettlement(new BigDecimal("0"));
			tSettlementConfirm.setVipDiscount(vipDiscount);
			tSettlementConfirm.setCouponDiscount(couponDiscount);
			tSettlementConfirm.setType(dto.getType());

			if (dto.getState() == 2){
			tSettlementConfirm.setSupplyElectronic(dto.getSupplyElectronic());
			tSettlementConfirm.setVenue(dto.getVenue());
			tSettlementConfirm.setMetering(dto.getMetering());
			tSettlementConfirm.setClean(dto.getClean());
			tSettlementConfirm.setLossElectronic(dto.getMeteringElectronic().subtract(dto.getChargingElectronic()));
			tSettlementConfirm.setMaintain(dto.getMaintain());

			tSettlementConfirm.setMeteringElectronic(dto.getMeteringElectronic());
			tSettlementConfirm.setProportionPartner(dto.getProportionPartner());
			tSettlementConfirm.setProportionMoney(dto.getProportionMoney());
			tSettlementConfirm.setTotalElectronic(dto.getTotalElectronic());
			tSettlementConfirm.setTotalService(dto.getTotalService());
			tSettlementConfirm.setRemark(dto.getRemark());
			tSettlementConfirm.setServicePartner(dto.getServicePartner());
			tSettlementConfirm.setServiceMoney(dto.getServiceMoney());
			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()));
			tSettlementConfirmMapper.insert(tSettlementConfirm);
			}
			return tSettlementConfirm;
			}

			@Override
			public PageInfo<TSettlementConfirm> settlementList(SettlementListQuery dto) {
			PageInfo<TSettlementConfirm> pageInfo = new PageInfo<>(dto.getPageCurr(),dto.getPageSize());
			List<TSettlementConfirm> list = tSettlementConfirmMapper.settlementList(pageInfo,dto);
			for (TSettlementConfirm tSettlementConfirm : list) {
			tSettlementConfirm.setUid(tSettlementConfirm.getId().toString());
			List<Site> data1 = siteClient.getSiteByIds(Arrays.asList(tSettlementConfirm.getSiteId())).getData();
			if (!data1.isEmpty()){
			tSettlementConfirm.setSiteName(data1.get(0).getName());
			Partner data = siteClient.getPartnerR(data1.get(0).getPartnerId()).getData();
			if (data!=null){
			tSettlementConfirm.setPartnerName(data.getName());
			}
			}

			String format = tSettlementConfirm.getStartTime().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm:ss"));
			String format1 = tSettlementConfirm.getEndTime().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm:ss"));
			tSettlementConfirm.setTime(format+"至"+format1);


			}
			pageInfo.setRecords(list);
			return pageInfo;
			}

			@Override
			public SettlementTotalVO settlementTotal(String time) {
			SettlementTotalVO res = new SettlementTotalVO();
			List<TSettlementConfirm> list1 = tSettlementConfirmMapper.settlementTotal(time);
			LocalDateTime parse = LocalDateTime.parse(time, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
			// 减少一个月
			LocalDateTime minus = parse.minusMonths(1);
			List<TSettlementConfirm> list2 = tSettlementConfirmMapper.settlementTotal(time);
			// 合计
			List<TSettlementConfirm> total = new ArrayList<>();

			TSettlementConfirm tSettlementConfirm1 = new TSettlementConfirm();
			BigDecimal meteringElectronic = new BigDecimal("0");
			BigDecimal chargingElectronic = new BigDecimal("0");
			BigDecimal lossElectronic = new BigDecimal("0");
			BigDecimal income = new BigDecimal("0");
			BigDecimal venue = new BigDecimal("0");
			BigDecimal metering = new BigDecimal("0");
			BigDecimal clean = new BigDecimal("0");
			BigDecimal maintain = new BigDecimal("0");
			BigDecimal cost = new BigDecimal("0");
			BigDecimal profitMoney = new BigDecimal("0");
			BigDecimal newMoney = new BigDecimal("0");
			BigDecimal newSettlement = new BigDecimal("0");
			BigDecimal supplyElectronic = new BigDecimal("0");
			BigDecimal proportionPartner = new BigDecimal("0");
			BigDecimal proportionMoney = new BigDecimal("0");
			BigDecimal totalElectronic = new BigDecimal("0");
			BigDecimal totalService = new BigDecimal("0");
			BigDecimal servicePartner = new BigDecimal("0");
			BigDecimal serviceMoney = new BigDecimal("0");
			BigDecimal sharingAmount = new BigDecimal("0");
			BigDecimal commissionAmount = new BigDecimal("0");
			BigDecimal electrovalence = new BigDecimal("0");
			BigDecimal serviceCharge = new BigDecimal("0");
			BigDecimal orderCommission = new BigDecimal("0");
			BigDecimal vipDiscount = new BigDecimal("0");
			BigDecimal couponDiscount = new BigDecimal("0");
			// tSettlementConfirm1.setIncomePercentage();
			// tSettlementConfirm1.setTotalPercentage();
			tSettlementConfirm1.setElectronicRefund(0);
			// 上月成本合计
			BigDecimal beforeCost= new BigDecimal("0");
			// 上月利润合计
			BigDecimal beforeIncome= new BigDecimal("0");
			for (TSettlementConfirm tSettlementConfirm : list1) {
			List<Site> data1 = siteClient.getSiteByIds(Arrays.asList(tSettlementConfirm.getSiteId())).getData();
			if (!data1.isEmpty()){
			tSettlementConfirm.setSiteName(data1.get(0).getName());
			}
			meteringElectronic = meteringElectronic.add(tSettlementConfirm.getMeteringElectronic());
			chargingElectronic = chargingElectronic.add(tSettlementConfirm.getChargingElectronic());
			lossElectronic = lossElectronic.add(tSettlementConfirm.getLossElectronic());
			income = income.add(tSettlementConfirm.getIncome());
			venue = venue.add(tSettlementConfirm.getVenue());
			metering = metering.add(tSettlementConfirm.getMetering());
			clean = clean.add(tSettlementConfirm.getClean());
			maintain = maintain.add(tSettlementConfirm.getMaintain());
			cost = cost.add(tSettlementConfirm.getCost());
			profitMoney = profitMoney.add(tSettlementConfirm.getProfitMoney());
			newMoney = newMoney.add(tSettlementConfirm.getNewMoney());
			newSettlement = newSettlement.add(tSettlementConfirm.getNewSettlement());
			supplyElectronic = supplyElectronic.add(tSettlementConfirm.getSupplyElectronic());
			proportionPartner = proportionPartner.add(tSettlementConfirm.getProportionPartner());
			proportionMoney = proportionMoney.add(tSettlementConfirm.getProportionMoney());
			totalElectronic = totalElectronic.add(tSettlementConfirm.getTotalElectronic());
			totalService = totalService.add(tSettlementConfirm.getTotalService());
			servicePartner = servicePartner.add(tSettlementConfirm.getServicePartner());
			serviceMoney = serviceMoney.add(tSettlementConfirm.getServiceMoney());
			sharingAmount = sharingAmount.add(tSettlementConfirm.getSharingAmount());
			commissionAmount = commissionAmount.add(tSettlementConfirm.getCommissionAmount());
			electrovalence = electrovalence.add(tSettlementConfirm.getElectrovalence());
			serviceCharge = serviceCharge.add(tSettlementConfirm.getServiceCharge());
			orderCommission = orderCommission.add(tSettlementConfirm.getOrderCommission());
			vipDiscount = vipDiscount.add(tSettlementConfirm.getVipDiscount());
			couponDiscount = couponDiscount.add(tSettlementConfirm.getCouponDiscount());

			// 查询结算确认单开始时间和结束时间的单子
			QueryWrapper<TChargingOrder> eq = new QueryWrapper<TChargingOrder>()
			.eq("site_id", tSettlementConfirm.getSiteId())
			.eq("recharge_payment_status",2);
			switch (tSettlementConfirm.getType()){
			case 1:
			eq.between("start_time", tSettlementConfirm.getStartTime(), tSettlementConfirm.getEndTime());
			break;
			case 2:
			eq.between("end_time", tSettlementConfirm.getStartTime(), tSettlementConfirm.getEndTime());
			break;
			}
			List<TChargingOrder> tChargingOrders = this.baseMapper.selectList(eq);
			Map<String,TChargingOrder> map = new HashMap<>();
			StringBuilder stringBuilder = new StringBuilder();
			for (TChargingOrder tChargingOrder : tChargingOrders) {
			stringBuilder.append(tChargingOrder.getCode()).append(",");
			}
			Long temp = 0L;
			if (StringUtils.hasLength(stringBuilder.toString())){
			List<UploadRealTimeMonitoringData> data6 = uploadRealTimeMonitoringDataClient.getOrderInfoByCodes(stringBuilder.substring(0,stringBuilder.length()-1)).getData();
			temp+=data6.stream().mapToLong(UploadRealTimeMonitoringData::getCumulative_charging_time).sum();
			}
			List<TChargingPile> data = siteClient.getPileListBySiteId(tSettlementConfirm.getSiteId()).getData();
			// 计算充电桩的功率平均值
			BigDecimal bigDecimal = new BigDecimal("0");
			for (TChargingPile datum : data) {
			bigDecimal = bigDecimal.add(datum.getRatedPower());
			}


			tSettlementConfirm.setIncome(tSettlementConfirm.getElectrovalence().add(tSettlementConfirm.getServiceCharge()));
			// todo 计算利用率该电站充电桩本月利用率：
			//利用率=充电量/（桩数量功率时间）

			for (TSettlementConfirm settlementConfirm : list2) {
			settlementConfirm.setIncome(settlementConfirm.getElectrovalence().add(settlementConfirm.getServiceCharge()));
			if (tSettlementConfirm.getSiteId().equals(settlementConfirm.getSiteId())){
			// 电站相同比较收入涨幅跌幅
			BigDecimal subtract = tSettlementConfirm.getIncome().subtract(settlementConfirm.getIncome()).divide(tSettlementConfirm.getIncome()).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"));
			tSettlementConfirm.setIncomePercentage(subtract+"%");
			// 比较总利润收入合计-成本合计
			BigDecimal subtract1 = tSettlementConfirm.getIncome().subtract(tSettlementConfirm.getCost());
			BigDecimal subtract2 = settlementConfirm.getIncome().subtract(settlementConfirm.getCost());
			tSettlementConfirm.setTotalPercentage(subtract1.subtract(subtract2).divide(subtract2).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"))+"%");
			}
			beforeCost = beforeCost.add(settlementConfirm.getCost());
			beforeIncome = beforeIncome.add(settlementConfirm.getIncome());


			}
			}
			TSettlementConfirm tSettlementConfirm = new TSettlementConfirm();
			tSettlementConfirm.setMeteringElectronic(meteringElectronic);
			tSettlementConfirm.setChargingElectronic(chargingElectronic);
			tSettlementConfirm.setLossElectronic(lossElectronic);
			tSettlementConfirm.setIncome(income);
			tSettlementConfirm.setVenue(venue);
			tSettlementConfirm.setMetering(metering);
			tSettlementConfirm.setClean(clean);
			tSettlementConfirm.setMaintain(maintain);
			tSettlementConfirm.setCost(cost);
			tSettlementConfirm.setProfitMoney(profitMoney);
			tSettlementConfirm.setNewMoney(newMoney);
			tSettlementConfirm.setNewSettlement(newSettlement);
			tSettlementConfirm.setSupplyElectronic(supplyElectronic);
			tSettlementConfirm.setProportionPartner(proportionPartner);
			tSettlementConfirm.setProportionMoney(proportionMoney);
			tSettlementConfirm.setTotalElectronic(totalElectronic);
			tSettlementConfirm.setTotalService(totalService);
			tSettlementConfirm.setServicePartner(servicePartner);
			tSettlementConfirm.setServiceMoney(serviceMoney);
			tSettlementConfirm.setSharingAmount(sharingAmount);
			tSettlementConfirm.setCommissionAmount(commissionAmount);
			tSettlementConfirm.setElectrovalence(electrovalence);
			tSettlementConfirm.setServiceCharge(serviceCharge);
			tSettlementConfirm.setOrderCommission(orderCommission);
			tSettlementConfirm.setVipDiscount(vipDiscount);
			tSettlementConfirm.setCouponDiscount(couponDiscount);
			// 本月
			if (beforeIncome.compareTo(new BigDecimal("0")) == 0){
			tSettlementConfirm.setIncomePercentage(0+"%");
			tSettlementConfirm.setIncomePercentage(0+"%");
			}else{
			BigDecimal subtract = income.subtract(beforeIncome).divide(beforeIncome).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"));
			tSettlementConfirm.setIncomePercentage(subtract+"%");
			tSettlementConfirm.setIncomePercentage(subtract+"%");

			}
			// 比较总利润收入合计-成本合计
			BigDecimal subtract1 = income.subtract(cost);
			BigDecimal subtract2 = beforeIncome.subtract(beforeCost);
			if (subtract2.compareTo(new BigDecimal("0")) == 0){
			tSettlementConfirm.setTotalPercentage(0+"%");
			}else{
			tSettlementConfirm.setTotalPercentage(subtract1.subtract(subtract2).divide(subtract2).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"))+"%");
			}
			tSettlementConfirm.setElectronicRefund(0);
			// 查询上次汇报数据进行比对涨幅跌幅
			total.add(tSettlementConfirm);
			res.setList1(list1);
			res.setList2(total);
			return res;
			}

			@Override
			public List<Map<String, Object>> countBySource(List<Integer> siteIds) {
			return this.baseMapper.countBySource(siteIds);
			}

			@Override
			public List<Map<String, Object>> equipmentUserType1(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.equipmentUserType1(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> equipmentUserType2(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.equipmentUserType2(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> equipmentMapbroke1(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.equipmentMapbroke1(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> equipmentMapbroke2(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.equipmentMapbroke2(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> equipmentMapOut1(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.equipmentMapOut1(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> equipmentMapOut2(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.equipmentMapOut2(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> needElec(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.needElec(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> getHourType(List<Integer> siteIds, ChargingDetailQueryDto statisticsQueryDto) {
			return this.baseMapper.getHourType(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> getDateType(List<Integer> siteIds, ChargingDetailQueryDto statisticsQueryDto) {
			return this.baseMapper.getDateType(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> getMonthType(List<Integer> siteIds, ChargingDetailQueryDto statisticsQueryDto) {
			return this.baseMapper.getMonthType(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> getchargingCapacity(List<Integer> siteIds, ChargingDetailQueryDto statisticsQueryDto) {
			return this.baseMapper.getchargingCapacity(siteIds,statisticsQueryDto);
			}

			@Override
			public List<Map<String, Object>> countAllUserData() {
			return this.baseMapper.countAllUserData();
			}

			@Override
			public List<Map<String, Object>> needElec1(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
			return this.baseMapper.needElec1(siteIds,statisticsQueryDto);
			}

			/**
			* 获取充电结束页面详情
			* @param id
			* @return
			*/
			@Override
			public EndOfChargePageInfo getEndOfChargePageInfo(String id) {
			EndOfChargePageInfo info = new EndOfChargePageInfo();
			TChargingOrder chargingOrder = this.getById(id);
			info.setId(id);
			info.setCode(chargingOrder.getCode());
			info.setPaymentAmount(chargingOrder.getPaymentAmount());
			info.setCouponDiscountAmount(chargingOrder.getCouponDiscountAmount());
			TAppUserIntegralChange integralChange = appUserIntegralChangeClient.getTAppUserIntegralChangeByOrderCode(chargingOrder.getCode()).getData();
			info.setIntegral(null == integralChange ? 0 : integralChange.getCurrentIntegral() - integralChange.getHistoricalIntegral());
			info.setRechargeAmount(chargingOrder.getRechargeAmount());
			info.setRefundAmount(chargingOrder.getRefundAmount());
			LocalDateTime startTime = chargingOrder.getStartTime();
			LocalDateTime endTime = chargingOrder.getEndTime();
			info.setStartDay(startTime.format(DateTimeFormatter.ofPattern("MM月dd日")) + " 周" + startTime.getDayOfWeek().getDisplayName(TextStyle.FULL, Locale.SIMPLIFIED_CHINESE));
			info.setStartHour(startTime.format(DateTimeFormatter.ofPattern("HH:mm")));
			info.setEndDay(endTime.format(DateTimeFormatter.ofPattern("MM月dd日")) + " 周" + endTime.getDayOfWeek().getDisplayName(TextStyle.FULL, Locale.SIMPLIFIED_CHINESE));
			info.setEndHour(endTime.format(DateTimeFormatter.ofPattern("HH:mm")));
			int hour = endTime.getHour() - startTime.getHour();
			int second = endTime.getSecond() - startTime.getSecond();
			info.setDuration(0 == hour ? String.format("%s分钟", second) : String.format("%s小时%s分钟", hour, second));
			return info;
			}
			}