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


@@ -1,9 +1,7 @@


package com.ruoyi.order.service.impl;




import cn.hutool.core.date.DateUtil;


import com.alibaba.fastjson2.JSON;


import com.alibaba.fastjson2.JSONObject;


import com.baomidou.mybatisplus.annotation.TableField;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


@@ -34,7 +32,6 @@


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;


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


@@ -58,15 +55,11 @@


import com.ruoyi.payment.api.model.WxPaymentRefundModel;


import com.ruoyi.payment.api.vo.*;


import com.ruoyi.system.api.feignClient.SysUserClient;


import com.sun.org.apache.bcel.internal.generic.NEW;


import io.seata.spring.annotation.GlobalTransactional;


import io.swagger.annotations.ApiModelProperty;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


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;


@@ -550,7 +543,9 @@


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


      BigDecimal rechargeAmount = chargingOrder.getRechargeAmount();


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


      Long now = System.currentTimeMillis();


      SimpleDateFormat sdf = new SimpleDateFormat("HHmm");


      Long now = Long.valueOf(sdf.format(new Date()));


      Long nowTimeMillis = System.currentTimeMillis();


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


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


      BigDecimal serviceCharge = BigDecimal.ZERO;


@@ -559,20 +554,27 @@


      BigDecimal discount = chargingOrder.getVipDiscount();


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


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


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


      BigDecimal s_degrees = tChargingGun.getRatedPower().divide(new BigDecimal(3600), 6, RoundingMode.HALF_EVEN);




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


      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(":", ""));


         Integer end = Integer.valueOf(accountingStrategyDetailOrder.getEndTime().replaceAll(":", ""));


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


         if(now >= start){


         if(now >= start && now < end){


            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;


            if(null == nowTimeMillis){


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


               Calendar calendar1 = Calendar.getInstance();


               calendar1.set(Calendar.HOUR_OF_DAY, Integer.valueOf(split1[0]));


               calendar1.set(Calendar.MINUTE, Integer.valueOf(split1[1]));


               nowTimeMillis = calendar.getTimeInMillis();


            }


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


            //每度电的单价


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


            //每秒需要支付的金额


@@ -585,6 +587,7 @@


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


               nowTimeMillis = null;


            }else{


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


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


@@ -1833,6 +1836,11 @@


   }




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


   }


@@ -1880,6 +1888,8 @@




   @Resource


   private TShoppingOrderService shoppingOrderService;


   @Resource


   private TShoppingOrderRefundService shoppingOrderRefundService;


   @Override


   public R payRefund(PayOrderRefundDto payOrderQueryDto) {


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


@@ -1914,6 +1924,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);


               }


            }


@@ -1927,6 +1940,9 @@


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


                  this.baseMapper.updateById(tChargingOrder);


                     chargingOrderRefundService.save(chargingOrderRefund);




               }


@@ -1939,8 +1955,8 @@


         }


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


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


            TChargingOrderRefund chargingOrderRefund = new TChargingOrderRefund();


            chargingOrderRefund.setChargingOrderId(tChargingOrder.getId());


            TShoppingOrderRefund chargingOrderRefund = new TShoppingOrderRefund();


            chargingOrderRefund.setShoppingOrderId(tChargingOrder.getId());


            chargingOrderRefund.setRefundAmount(payOrderQueryDto.getRefundAmount());


            chargingOrderRefund.setRefundStatus(1);


            chargingOrderRefund.setPayType(tChargingOrder.getPaymentType());


@@ -1969,7 +1985,10 @@


               model.setAmount(amount);


               R<String> orderR = wxPaymentClient.refundOrderR(model);


               if(200 == orderR.getCode()){


                  chargingOrderRefundService.save(chargingOrderRefund);


                  tChargingOrder.setRefundStatus(2);


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


                  shoppingOrderService.updateById(tChargingOrder);


                  shoppingOrderRefundService.save(chargingOrderRefund);


               }


            }




@@ -1982,7 +2001,12 @@


               RefundResp resp = aliPaymentClient.refund(dto).getData();


               if(null != resp){


                  SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-DDTHH:mm:ss+TIMEZONE");


                  chargingOrderRefundService.save(chargingOrderRefund);




                  tChargingOrder.setRefundStatus(2);


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


                  shoppingOrderService.updateById(tChargingOrder);




                  shoppingOrderRefundService.save(chargingOrderRefund);




               }


            }


@@ -2426,6 +2450,11 @@


      return this.baseMapper.countAllUserData();


   }




   @Override


   public List<Map<String, Object>> needElec1(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {


      return this.baseMapper.needElec1(siteIds,statisticsQueryDto);


   }




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