明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
2024-09-27 d153ca8d05991566bed18eed1ae25f0af3c1cc70 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java


@@ -33,6 +33,7 @@


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.feignClient.ChargingOrderAccountingStrategyClient;


import com.ruoyi.order.api.model.*;


import com.ruoyi.order.api.query.ChargingOrderQuery;


@@ -47,14 +48,9 @@


import com.ruoyi.order.service.TChargingOrderService;


import com.ruoyi.order.service.TOrderEvaluateService;


import com.ruoyi.order.service.*;


import com.ruoyi.other.api.domain.TCoupon;


import com.ruoyi.other.api.domain.TGoods;


import com.ruoyi.other.api.domain.*;


import com.ruoyi.order.vo.ChargingOrderListInfoVO;


import com.ruoyi.other.api.domain.TIntegralRule;


import com.ruoyi.other.api.feignClient.IntegralRuleClient;


import com.ruoyi.other.api.feignClient.OtherClient;


import com.ruoyi.other.api.feignClient.RoleSiteClient;


import com.ruoyi.other.api.feignClient.UserSiteClient;


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;


@@ -70,6 +66,7 @@


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.StringUtils;




import javax.annotation.Resource;


@@ -154,6 +151,9 @@




   @Resource


   private AccountingStrategyDetailOrderClient accountingStrategyDetailOrderClient;


	


   @Resource


   private AccountingStrategyOrderClient accountingStrategyOrderClient;




   @Resource


   private AccountingStrategyClient accountingStrategyClient;


@@ -181,6 +181,15 @@




   @Resource


   private IntegralRuleClient integralRuleClient;


	


   @Resource


   private VipClient vipClient;


	


   @Resource


   private UserTagClient userTagClient;


	


   @Resource


   private AppUserTagClient appUserTagClient;




   //计数器


   private Map<String, Integer> counter_map = new HashMap<>();


@@ -417,7 +426,7 @@


      //构建新的待支付订单


      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);


@@ -431,7 +440,28 @@


      chargingOrder.setRechargePaymentStatus(1);


      chargingOrder.setRechargeAmount(addChargingOrder.getPaymentAmount());


      chargingOrder.setAppCouponId(addChargingOrder.getAppUserCouponId());


      if(null != appUser.getVipId()){


      chargingOrder.setVipDiscount(new BigDecimal(10));


      chargingOrder.setVipDiscountAmount(BigDecimal.ZERO);


		


      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.getInfo(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());


@@ -439,19 +469,14 @@


         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);




      //添加订单的计费策略


      TAccountingStrategy accountingStrategy = accountingStrategyClient.getAccountingStrategyById(tChargingGun.getAccountingStrategyId()).getData();


      List<TAccountingStrategyDetail> strategyDetailList = accountingStrategyDetailClient.getListByAccountingStrategyId(tChargingGun.getAccountingStrategyId()).getData();


      List<TAccountingStrategyDetail> strategyDetailList = accountingStrategyDetailClient.getListByAccountingStrategyId(accountingStrategyId).getData();


      AccountingStrategyOrder accountingStrategyOrder = new AccountingStrategyOrder();


      BeanUtils.copyProperties(accountingStrategy, accountingStrategyOrder);


      accountingStrategyOrder.setChargingOrderId(chargingOrder.getId());


@@ -473,7 +498,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);


      }


@@ -524,42 +549,84 @@


      


      //根据当前充值的金额和计费模板算出充电的金额


      BigDecimal rechargeAmount = chargingOrder.getRechargeAmount();


      //计算充电金额，会员需要将折扣金额加入到充电总金额中


      TChargingGun chargingGun = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();


      AccountingStrategyDetailOrder strategyDetail = accountingStrategyDetailOrderClient.getNowAccountingStrategyDetailOrder(chargingOrder.getId()).getData();


      //总单价


      BigDecimal totalUnitPrice = strategyDetail.getServiceCharge().add(strategyDetail.getElectrovalence());


      //计算能充电的度数


      BigDecimal degrees = rechargeAmount.divide(totalUnitPrice);


      BigDecimal rechargeAmount1 = new BigDecimal(rechargeAmount.toString());


      Long now = System.currentTimeMillis();


      //根据支付金额，获取出使用的计费策略明细


      //计算电费金额和服务费


      BigDecimal serviceCharge = strategyDetail.getServiceCharge().multiply(degrees);


      BigDecimal electrovalence = strategyDetail.getElectrovalence().multiply(degrees);




      //再处理会员折扣


      BigDecimal discount = BigDecimal.ZERO;


      BigDecimal serviceCharge = BigDecimal.ZERO;


      BigDecimal electrovalence = BigDecimal.ZERO;


      BigDecimal discountAmount = BigDecimal.ZERO;


      BigDecimal discount = chargingOrder.getVipDiscount();


      //先根据额定功率计算出每秒充电度数，然后计算出支付金额能充多少度电


      TChargingGun tChargingGun = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();


      BigDecimal s_degrees = tChargingGun.getRatedPower().divide(new BigDecimal(3600));


		


		


      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);


      List<AccountingStrategyDetailOrder> list = accountingStrategyDetailOrderClient.getAllAccountingStrategyDetailOrder(chargingOrder.getId()).getData();


      for (AccountingStrategyDetailOrder accountingStrategyDetailOrder : list) {


         AccountingStrategyOrder accountingStrategyOrder = accountingStrategyOrderClient.getAccountingStrategyOrderById(accountingStrategyDetailOrder.getAccountingStrategyOrderId()).getData();


         Integer start = Integer.valueOf(accountingStrategyDetailOrder.getStartTime().replaceAll(":", ""));


         String[] split = accountingStrategyDetailOrder.getEndTime().split(":");


         if(now >= start){


            Calendar calendar = Calendar.getInstance();


            calendar.set(Calendar.HOUR_OF_DAY, Integer.valueOf(split[0]));


            calendar.set(Calendar.MINUTE, Integer.valueOf(split[1]));


            //到此策略结束的秒数


            long m = (calendar.getTimeInMillis() - now) / 1000;


            //每度电的单价


            BigDecimal total_unit = accountingStrategyDetailOrder.getElectrovalence().add(accountingStrategyDetailOrder.getServiceCharge());


            //每秒需要支付的金额


            BigDecimal multiply = s_degrees.multiply(total_unit);


            //计算充值金额能充多长时间的电


            long times = rechargeAmount1.divide(multiply, 0, RoundingMode.DOWN).longValue();


            if(times > m){


               //充电时间跨度两个计费策略，需要继续对下一个策略进行计算


               electrovalence = accountingStrategyDetailOrder.getElectrovalence().multiply(s_degrees).multiply(new BigDecimal(m));


               serviceCharge = accountingStrategyDetailOrder.getServiceCharge().multiply(s_degrees).multiply(new BigDecimal(m));


               discountAmount = discountAmount.add(serviceCharge.multiply((new BigDecimal(10).subtract(discount)).divide(new BigDecimal(10))));


               rechargeAmount1 = rechargeAmount1.subtract(multiply.multiply(new BigDecimal(m)));


            }else{


               electrovalence = accountingStrategyDetailOrder.getElectrovalence().multiply(s_degrees).multiply(new BigDecimal(times));


               serviceCharge = accountingStrategyDetailOrder.getServiceCharge().multiply(s_degrees).multiply(new BigDecimal(times));


               discountAmount = discountAmount.add(serviceCharge.multiply((new BigDecimal(10).subtract(discount)).divide(new BigDecimal(10))));


               break;


            }


         }


      }


      electrovalence = electrovalence.add(discount);


      if(discountAmount.compareTo(BigDecimal.ZERO) >= 0){


         //计算会员最大优惠金额


         if(null != appUser.getVipId()){


            TVip vip = vipClient.getInfo(appUser.getVipId()).getData();


            BigDecimal maximumDeduction = vip.getMaximumDeduction();


            //普通会员有最高优惠限制


            if(vip.getType() == 1 && discountAmount.compareTo(maximumDeduction) > 0){


               discountAmount = maximumDeduction;


            }


				


            //判断会员是否还有充电优惠次数


            GetAppUserVipDetail getAppUserVipDetail = new GetAppUserVipDetail();


            getAppUserVipDetail.setAppUserId(chargingOrder.getAppUserId());


            getAppUserVipDetail.setVipId(appUser.getVipId());


            TAppUserVipDetail data = appUserVipDetailClient.getAppUserVipDetail(getAppUserVipDetail).getData();


            if(data.getChargeNum() > 0){


               data.setChargeNum(data.getChargeNum() - 1);


               appUserVipDetailClient.updateAppUserVipDetail(data);


               //会员有充电优惠次数，直接将优惠金额加入到充电费用中增加充电时长


               electrovalence = electrovalence.add(discountAmount);


            }


         }


      }


      chargingOrder.setChargeAmount(electrovalence);


      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);


@@ -578,7 +645,7 @@


            PreChargeCheck preChargeCheck1 = redisService.getCacheObject(key);


            //状态为5的时候，硬件会间隔60秒后再次检测，依然未插枪，则不启动充电


            //因这里是间隔5秒执行检测，所以累计次数在30次以上


            if(failure_cause == 5 && null == counter || counter < 35){


            if(failure_cause == 5 && (null == counter || counter < 35)){


               counter++;


               counter_map.put(code, counter);


               //启动失败


@@ -627,7 +694,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);


@@ -644,7 +711,7 @@


            model.setOut_trade_no(chargingOrder.getCode());


            model.setOut_refund_no(chargingOrderRefund.getRefundCode());


            model.setReason("充电失败，取消充电订单");


            model.setNotify_url("http://221.182.45.100: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());


@@ -759,7 +826,65 @@


      chargingOrder.setStatus(4);


      chargingOrder.setEndMode(1);


      this.updateById(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);


            }


         }


      }


		


		


      //异步线程处理停机


      ExecutorService cachedThreadPool = Executors.newFixedThreadPool(1);


      cachedThreadPool.execute(()->{


@@ -821,13 +946,24 @@


         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.getInfo(appUser1.getVipId()).getData();


            Integer doubleIntegration = vip.getDoubleIntegration();


            //双倍积分


            if(1 == doubleIntegration){


               num1 *= 2;


            }


         }


			


         GetInviteUser query = new GetInviteUser();


         query.setAppUserId(appUser.getInviteUserId());


         query.setAppUserId(appUser1.getId());


         query.setBeInvitedAppUserId(chargingOrder.getAppUserId());


         TInviteUser inviteUser = inviteUserClient.getInviteUser(query).getData();


         if(null == inviteUser){


            inviteUser = new TInviteUser();


            inviteUser.setAppUserId(appUser.getInviteUserId());


            inviteUser.setAppUserId(appUser1.getId());


            inviteUser.setBeInvitedAppUserId(chargingOrder.getAppUserId());


            inviteUser.setAward(num1);


            inviteUser.setCreateTime(LocalDateTime.now());


@@ -836,11 +972,10 @@


            inviteUser.setAward(num1);


            inviteUserClient.updateInviteUser(inviteUser);


         }


         TAppUser appUser1 = appUserClient.getUserById(appUser.getInviteUserId()).getData();


         TAppUserIntegralChange appUserIntegralChange = new TAppUserIntegralChange();


         String code = Math.random() * 1000 + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS"));


         String code = Double.valueOf(Math.random() * 1000).intValue() + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS"));


         appUserIntegralChange.setCode(code);


         appUserIntegralChange.setAppUserId(appUser.getInviteUserId());


         appUserIntegralChange.setAppUserId(appUser1.getId());


         appUserIntegralChange.setChangeType(5);


         appUserIntegralChange.setHistoricalIntegral(appUser1.getPoints());


         appUserIntegralChange.setCurrentIntegral(appUser1.getPoints() + num1);


@@ -888,7 +1023,33 @@


      chargingOrder.setStatus(5);


      chargingOrder.setPaymentAmount(payAmount);


      this.updateById(chargingOrder);




		


      //添加积分


      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.getInfo(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());


         appUserClient.updateAppUser(appUser);


         appUserIntegralChangeClient.addAppUserIntegralChange(appUserIntegralChange);


      }


		


      //计算优惠券


      if(null != chargingOrder.getAppCouponId()){


         //判断实际充电金额是否满足优惠券使用条件，如果不满足则不适用优惠券。


@@ -937,7 +1098,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(refundAmount);


         chargingOrderRefund.setRefundStatus(1);


         chargingOrderRefund.setPayType(rechargePaymentType);


@@ -954,7 +1115,7 @@


            model.setOut_trade_no(chargingOrder.getCode());


            model.setOut_refund_no(chargingOrderRefund.getRefundCode());


            model.setReason("充电完成退款");


            model.setNotify_url("http://221.182.45.100:9000/order/t-charging-order/chargingOrderStartupFailureWxRefund");


            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());


@@ -983,6 +1144,7 @@




      }




		


   }






@@ -1384,6 +1546,22 @@


      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()){


@@ -1562,7 +1740,7 @@




      //计算费用，处理退款


      endCharge(chargingOrder);




		


      //处理推荐奖励(被推荐首单奖励)


      TAppUser appUser = appUserClient.getUserById(chargingOrder.getAppUserId()).getData();


      long count = this.count(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getAppUserId, chargingOrder.getAppUserId())


@@ -1572,13 +1750,24 @@


         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.getInfo(appUser1.getVipId()).getData();


            Integer doubleIntegration = vip.getDoubleIntegration();


            //双倍积分


            if(1 == doubleIntegration){


               num1 *= 2;


            }


         }


			


         GetInviteUser query = new GetInviteUser();


         query.setAppUserId(appUser.getInviteUserId());


         query.setAppUserId(appUser1.getId());


         query.setBeInvitedAppUserId(chargingOrder.getAppUserId());


         TInviteUser inviteUser = inviteUserClient.getInviteUser(query).getData();


         if(null == inviteUser){


            inviteUser = new TInviteUser();


            inviteUser.setAppUserId(appUser.getInviteUserId());


            inviteUser.setAppUserId(appUser1.getId());


            inviteUser.setBeInvitedAppUserId(chargingOrder.getAppUserId());


            inviteUser.setAward(num1);


            inviteUser.setCreateTime(LocalDateTime.now());


@@ -1587,20 +1776,20 @@


            inviteUser.setAward(num1);


            inviteUserClient.updateInviteUser(inviteUser);


         }


         TAppUser appUser1 = appUserClient.getUserById(appUser.getInviteUserId()).getData();


         TAppUserIntegralChange appUserIntegralChange = new TAppUserIntegralChange();


         String code = Math.random() * 1000 + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS"));


         String code = Double.valueOf(Math.random() * 1000).intValue() + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS"));


         appUserIntegralChange.setCode(code);


         appUserIntegralChange.setAppUserId(appUser.getInviteUserId());


         appUserIntegralChange.setAppUserId(appUser1.getId());


         appUserIntegralChange.setChangeType(5);


         appUserIntegralChange.setHistoricalIntegral(appUser1.getPoints());


         appUserIntegralChange.setCurrentIntegral(appUser1.getPoints() + num1);


         appUserIntegralChange.setCreateTime(LocalDateTime.now());


         appUserIntegralChangeClient.addAppUserIntegralChange(appUserIntegralChange);




			


         appUser1.setPoints(appUser1.getPoints() + num1);


         appUserClient.updateAppUser(appUser1);


      }


		


   }




   /**


@@ -1683,6 +1872,8 @@


   }






   @Resource


   private TShoppingOrderService shoppingOrderService;


   @Override


   public R payRefund(PayOrderRefundDto payOrderQueryDto) {


         if (payOrderQueryDto.getType()==1){


@@ -1695,7 +1886,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("后台退款");


@@ -1709,7 +1900,7 @@


               model.setOut_refund_no(chargingOrderRefund.getRefundCode());


               model.setTransaction_id(tChargingOrder.getRechargeSerialNumber());


               model.setReason("取消订单");


               model.setNotify_url("http://221.182.45.100: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());


@@ -1740,10 +1931,61 @@






         }


         if (payOrderQueryDto.getType()==2){


            TShoppingOrder tChargingOrder = shoppingOrderService.getById(payOrderQueryDto.getOrderId());


            TChargingOrderRefund chargingOrderRefund = new TChargingOrderRefund();


            chargingOrderRefund.setChargingOrderId(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()){


                  chargingOrderRefundService.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");


                  chargingOrderRefundService.save(chargingOrderRefund);




               }


            }




         }








      return null;


      return R.ok();


   }






@@ -1782,18 +2024,25 @@


      String startTime = dto.getStartTime();


      String endTime = dto.getEndTime();


      // 将这两个时间转化为localDateTime


      tSettlementConfirm.setStartTime(LocalDateTime.parse(startTime));


      tSettlementConfirm.setEndTime(LocalDateTime.parse(endTime));


      // 创建 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", startTime, endTime);


            eq.between("start_time", localDateTime, localDateTime1);


            break;


         case 2:


            eq.between("end_time", startTime, endTime);


            eq.between("end_time", localDateTime, localDateTime1);


            break;


      }


      List<TChargingOrder> tChargingOrders = this.baseMapper.selectList(eq);


@@ -1817,13 +2066,23 @@


      BigDecimal paymentAmount = new BigDecimal("0");


      for (TChargingOrder tChargingOrder : tChargingOrders) {


         // 累加充电总度数


         chargingElectronic = chargingElectronic.add(tChargingOrder.getChargingCapacity());


         if (tChargingOrder.getChargingCapacity()!=null){


            chargingElectronic = chargingElectronic.add(tChargingOrder.getChargingCapacity());




         }


         // 累加分佣


         sharingAmount = sharingAmount.add(tChargingOrder.getSharingAmount());


         if (tChargingOrder.getSharingAmount()!=null) {


            sharingAmount = sharingAmount.add(tChargingOrder.getSharingAmount());


         }


         // 累加电费


         if (tChargingOrder.getElectrovalence()!=null) {


         electrovalence = electrovalence.add(tChargingOrder.getElectrovalence());


         }


         // 累加服务费


         serviceCharge = serviceCharge.add(tChargingOrder.getServiceCharge());


         if (tChargingOrder.getServiceCharge()!=null){


            serviceCharge = serviceCharge.add(tChargingOrder.getServiceCharge());




         }


         // 累加会员折扣


         if (tChargingOrder.getVipDiscountAmount()!=null){


            vipDiscount = vipDiscount.add(tChargingOrder.getVipDiscountAmount());


@@ -1832,11 +2091,13 @@


         if (tChargingOrder.getCouponDiscountAmount()!=null){


            couponDiscount = couponDiscount.add(tChargingOrder.getCouponDiscountAmount());


         }


         if (tChargingOrder.getRefundStatus() == 2){


         if (tChargingOrder.getRefundStatus()!=null &&tChargingOrder.getRefundStatus() == 2){


            // 如果成功退款 那么减去退款金额


            paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount().subtract(tChargingOrder.getRefundAmount()));


         }else{


            paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount());


            if (tChargingOrder.getPaymentAmount()!=null){


               paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount());


            }


         }


      }


      // 三方交易手续费 三方收费*0.6%


@@ -1852,34 +2113,36 @@


      tSettlementConfirm.setVipDiscount(vipDiscount);


      tSettlementConfirm.setCouponDiscount(couponDiscount);


      tSettlementConfirm.setSiteId(dto.getSiteId());


      tSettlementConfirm.setMeteringElectronic(dto.getData().getMeteringElectronic());


      tSettlementConfirm.setChargingElectronic(chargingElectronic);


      tSettlementConfirm.setLossElectronic(dto.getData().getLossElectronic());


      tSettlementConfirm.setIncome(chargingElectronic.add(serviceCharge));


      tSettlementConfirm.setVenue(dto.getData().getVenue());


      tSettlementConfirm.setMetering(dto.getData().getMetering());


      tSettlementConfirm.setClean(dto.getData().getClean());


      tSettlementConfirm.setMaintain(dto.getData().getMaintain());


      tSettlementConfirm.setCost(dto.getData().getVenue().add(dto.getData().getClean()).add(dto.getData().getMaintain()));


      tSettlementConfirm.setProfitMoney(new BigDecimal("0"));


      tSettlementConfirm.setNewMoney(new BigDecimal("0"));


      tSettlementConfirm.setNewSettlement(new BigDecimal("0"));


      tSettlementConfirm.setVipDiscount(vipDiscount);


      tSettlementConfirm.setCouponDiscount(couponDiscount);


      tSettlementConfirm.setSupplyElectronic(dto.getData().getSupplyElectronic());


      tSettlementConfirm.setType(dto.getType());


      tSettlementConfirm.setProportionPartner(dto.getData().getProportionPartner());


      tSettlementConfirm.setProportionMoney(dto.getData().getProportionMoney());


      tSettlementConfirm.setTotalElectronic(dto.getData().getTotalElectronic());


      tSettlementConfirm.setTotalService(dto.getData().getTotalService());


      tSettlementConfirm.setRemark(dto.getData().getRemark());


      tSettlementConfirm.setServicePartner(dto.getData().getServicePartner());


      tSettlementConfirm.setServiceMoney(dto.getData().getServiceMoney());


      tSettlementConfirm.setTotalService(dto.getData().getTotalService());


      tSettlementConfirm.setServiceRemark(dto.getData().getServiceRemark());


      tSettlementConfirm.setDistribution(dto.getData().getDistribution());


      tSettlementConfirm.setIncome(dto.getData().getElectrovalence().add(dto.getData().getServiceCharge()));




      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;


@@ -1891,14 +2154,15 @@


      List<TSettlementConfirm> list = tSettlementConfirmMapper.settlementList(pageInfo,dto);


      for (TSettlementConfirm tSettlementConfirm : list) {


         tSettlementConfirm.setUid(tSettlementConfirm.getId().toString());


         Partner data = siteClient.getPartnerR(tSettlementConfirm.getPartnerId()).getData();


         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());


            }


         }


         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);


@@ -1906,7 +2170,7 @@




      }


      pageInfo.setRecords(list);


      return null;


      return pageInfo;


   }




   @Override


@@ -2015,7 +2279,7 @@


         for (TChargingPile datum : data) {


            bigDecimal = bigDecimal.add(datum.getRatedPower());


         }


         BigDecimal bigDecimal1 = bigDecimal.divide(new BigDecimal(data.size())).setScale(2, RoundingMode.HALF_DOWN);






         tSettlementConfirm.setIncome(tSettlementConfirm.getElectrovalence().add(tSettlementConfirm.getServiceCharge()));


         // todo 计算利用率 该电站充电桩本月利用率：


@@ -2066,13 +2330,23 @@


      tSettlementConfirm.setVipDiscount(vipDiscount);


      tSettlementConfirm.setCouponDiscount(couponDiscount);


      // 本月


      BigDecimal subtract = income.subtract(beforeIncome).divide(beforeIncome).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"));


      tSettlementConfirm.setIncomePercentage(subtract+"%");


      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);


      tSettlementConfirm.setTotalPercentage(subtract1.subtract(subtract2).divide(subtract2).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"))+"%");


      tSettlementConfirm.setIncomePercentage(subtract+"%");


      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);


@@ -2081,6 +2355,71 @@


      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();


   }




   public static void main(String[] args) {


//      String format = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm:ss"));


//      String format1 = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm:ss"));