明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhibing.pu
2024-08-24 cc788c86acd2983d791fbd3e50a9b30335b91953 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java


@@ -1,6 +1,7 @@


package com.ruoyi.order.service.impl;




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


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


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


import com.ruoyi.account.api.feignClient.AppUserCarClient;


import com.ruoyi.account.api.feignClient.AppUserClient;


@@ -17,27 +18,35 @@


import com.ruoyi.chargingPile.api.model.TChargingPile;


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;


import com.ruoyi.common.security.utils.SecurityUtils;


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


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


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


import com.ruoyi.order.api.vo.ChargingOrderVO;


import com.ruoyi.order.api.vo.TCharingOrderVO;


import com.ruoyi.order.dto.*;


import com.ruoyi.order.mapper.TChargingOrderMapper;


import com.ruoyi.order.service.TChargingOrderAccountingStrategyService;


import com.ruoyi.order.service.TChargingOrderService;


import com.ruoyi.payment.api.feignClient.AliPaymentClient;


import com.ruoyi.payment.api.feignClient.WxPaymentClient;


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


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


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.springframework.stereotype.Service;


import org.springframework.util.StringUtils;




import javax.annotation.Resource;


import java.math.BigDecimal;


import java.text.SimpleDateFormat;


import java.time.LocalDateTime;


import java.time.ZoneOffset;


import java.time.format.DateTimeFormatter;


import java.time.temporal.ChronoUnit;


import java.util.*;


import java.util.stream.Collectors;




/**


 * <p>


@@ -58,6 +67,8 @@


   


   @Resource


   private AppUserCarClient appUserCarClient;


   @Resource


   private AppUserClient appUserClient;


   


   @Resource


   private TChargingOrderAccountingStrategyService chargingOrderAccountingStrategyService;


@@ -69,17 +80,18 @@


   private WxPaymentClient wxPaymentClient;


   


   @Resource


   private ChargingPileClient chargingPileClient;


   private AliPaymentClient aliPaymentClient;


   


   @Resource


   private AppUserClient appUserClient;


   private ChargingPileClient chargingPileClient;


   




   @Resource


   private AppUserVipDetailClient appUserVipDetailClient;


   


	


	


	


   @Resource


   private RedisService redisService;




   /**


    * 获取小程序充电记录列表数据


    * @param query


@@ -101,6 +113,7 @@


         myChargingOrderList.setTitle(site.getName());


         myChargingOrderList.setChargingDegree(tChargingOrder.getChargingCapacity());


         String name = chargingGunClient.getAllName(tChargingOrder.getChargingGunId()).getData();


         myChargingOrderList.setChargingGunId(tChargingOrder.getChargingGunId());


         myChargingOrderList.setName(name);


         myChargingOrderList.setEndMode(tChargingOrder.getEndMode());


         BigDecimal payMoney = tChargingOrder.getStatus() < 4 ? tChargingOrder.getRechargeAmount() : tChargingOrder.getPaymentAmount();


@@ -216,11 +229,18 @@


            }


         }


         if(2 == rechargePaymentType){


			


            AliQueryOrder data = aliPaymentClient.query(tChargingOrder.getCode()).getData();


            if(null != data){


               //支付失败，删除无效的订单


               String tradeStatus = data.getTradeStatus();


               if(tradeStatus.equals("TRADE_CLOSED")){


                  this.removeById(tChargingOrder.getId());


               }


            }


         }


      }


      


      //


      //检查当前枪是否是正在使用中


      TChargingOrder one = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getChargingGunId, addChargingOrder.getId())


            .in(TChargingOrder::getStatus, Arrays.asList(1, 2, 3)).eq(TChargingOrder::getDelFlag, 0));


      if(null != one){


@@ -230,14 +250,43 @@


      one = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getChargingGunId, addChargingOrder.getId())


            .eq(TChargingOrder::getAppUserCarId, userId).eq(TChargingOrder::getRechargePaymentStatus, 1).eq(TChargingOrder::getDelFlag, 0));


      if(null != one){


		


         //查询三方支付数据，支付中直接结束三方订单


         if(1 == one.getRechargePaymentType()){


            NotifyV3PayDecodeRespBody data = wxPaymentClient.queryOrderInfo(one.getCode()).getData();


            if(null != data){


               String trade_state = data.getTrade_state();


               //支付失败，删除无效的订单


               if(trade_state.equals("REFUND") || trade_state.equals("NOTPAY") || trade_state.equals("REVOKED") || trade_state.equals("PAYERROR")){


                  this.removeById(one.getId());


               }else{


                  //结束第三方支付，删除订单


                  wxPaymentClient.close(one.getCode());


                  this.removeById(one.getId());


               }


            }


         }


         if(2 == one.getRechargePaymentType()){


            AliQueryOrder data = aliPaymentClient.query(one.getCode()).getData();


            if(null != data){


               String trade_state = data.getTradeStatus();


               //支付失败，删除无效的订单


               if(trade_state.equals("TRADE_CLOSED")){


                  this.removeById(one.getId());


               }


               if(trade_state.equals("WAIT_BUYER_PAY")){


                  //结束第三方支付，删除订单


                  aliPaymentClient.close(one.getCode());


                  this.removeById(one.getId());


               }


            }


         }


      }


      


      


      //构建新的待支付订单


      SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");


      TChargingOrder chargingOrder = new TChargingOrder();


      String code = Math.random() * 1000 + sdf.format(new Date());


      String code = "CD" + Math.random() * 1000 + sdf.format(new Date());


      chargingOrder.setCode(code);


      chargingOrder.setOrderType(1);


      chargingOrder.setOrderClassification(1);


@@ -281,7 +330,17 @@


         return AjaxResult.success(data);


      }


      if(2 == addChargingOrder.getPaymentType()){


		


         AliPaymentReq req = new AliPaymentReq();


         req.setOutTradeNo(chargingOrder.getCode());


         req.setTotalAmount(chargingOrder.getPaymentAmount().toString());


         req.setSubject("充电充值");


         req.setBuyerOpenId(appUser.getAliOpenid());


         req.setBody("充电充值");


         AliPaymentResp data = aliPaymentClient.payment(req).getData();


         if(null != data){


            data.setNotifyUrl(data.getNotifyUrl() + "/t-charging-order/chargingOrderALICallback");


            return AjaxResult.success(data);


         }


      }


      throw new RuntimeException("无效的支付方式");


   }


@@ -303,8 +362,158 @@


      }


      chargingOrder.setRechargePaymentStatus(2);


      chargingOrder.setRechargeSerialNumber(transaction_id);


      this.updateById(chargingOrder);


      //添加安全检测数据到缓存中，每步安全检测完成后需要更新缓存数据


      PreChargeCheck preChargeCheck = new PreChargeCheck();


      preChargeCheck.setElectronicLockLock(false);


      preChargeCheck.setInsulationTesting(false);


      preChargeCheck.setSecureConnectionDetection(false);


      String key = "AQJC_" + chargingOrder.getChargingGunId();


      redisService.setCacheObject(key, preChargeCheck);


      //开始检测充电桩状，将检查状态写入缓存。检测完成后开始开启充电


      //充电结束后需要计算退款剩余金额


      // todo 需要完善


      


		


      return null;


      return AjaxResult.success();


   }


	


	


   /**


    * 获取充电中的详情


    * @param id


    * @return


    */


   @Override


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


      if(null == one){


         return null;


      }


      // todo 需要完善充电实时数据


      ChargingDetails chargingDetails = new ChargingDetails();


      chargingDetails.setId(one.getId().toString());


      TChargingGun chargingGun = chargingGunClient.getChargingGunById(id).getData();


      TChargingPile chargingPile = chargingPileClient.getChargingPileById(chargingGun.getChargingPileId()).getData();


      Site site = siteClient.getSiteByIds(Arrays.asList(chargingPile.getSiteId())).getData().get(0);


      chargingDetails.setName(site.getName() + "-" + chargingPile.getName());


      chargingDetails.setCode(one.getCode());


      chargingDetails.setStatus(one.getStatus());


      return chargingDetails;


   }


	


	


   /**


    * 停止充电操作


    * @param id 订单id


    * @return


    */


   @Override


   public AjaxResult stopCharging(String id) {


      TChargingOrder chargingOrder = this.getById(id);


      Integer status = chargingOrder.getStatus();


      if(status == 4 || status == 5){


         return AjaxResult.error("不能重复操作");


      }


      chargingOrder.setStatus(4);


      chargingOrder.setEndMode(1);


      this.updateById(chargingOrder);


      //调用硬件停止充电，停止成功后开始计算费用退款


      // todo 待完善


      return AjaxResult.success();


   }






    @Override


    public TCharingOrderVO chargingOrder(ChargingOrderQuery dto) {


      TCharingOrderVO tCharingOrderVO = new TCharingOrderVO();






      String startTime1 = null;


      String startTime2 = null;


      String endTime1 = null;


      String endTime2 = null;




      if (StringUtils.hasLength(dto.getStartTime())){


         String[] split = dto.getStartTime().split(" - ");


         startTime1 = split[0];


         startTime2 = split[1];


      }


      if (StringUtils.hasLength(dto.getEndTime())){


         String[] split = dto.getEndTime().split(" - ");


         endTime1 = split[0];


         endTime2 = split[1];


      }


      if (StringUtils.hasLength(dto.getPhone())){


         List<Long> data = appUserClient.getUserIdsByPhone(dto.getPhone()).getData();


         if (data.isEmpty()){


            data.add(0L);


         }


         dto.setUserIds(data);


      }


      PageInfo<ChargingOrderVO> pageInfo = new PageInfo<>(dto.getPageCurr(),dto.getPageSize());


      List<ChargingOrderVO> list = this.baseMapper.chargingOrder(pageInfo,dto,startTime1,startTime2,endTime1,endTime2);


       BigDecimal total = new BigDecimal("0");


       long time = 0L;


       BigDecimal income = new BigDecimal("0");


       BigDecimal electronicMoney = new BigDecimal("0");


       BigDecimal serviceMoney = new BigDecimal("0");


      for (ChargingOrderVO chargingOrderVO : list) {


         total = total.add(chargingOrderVO.getChargingCapacity());


         // 充电订单 明细记录


         List<TChargingOrderAccountingStrategy> chargingOrderId = chargingOrderAccountingStrategyService.list(new QueryWrapper<TChargingOrderAccountingStrategy>()


               .eq("charging_order_id", chargingOrderVO.getId()));


         // 单个订单累计电费


         BigDecimal electronicMoney1 = new BigDecimal("0");


         // 单个订单累计服务费


         BigDecimal serviceMoney1 = new BigDecimal("0");


         LocalDateTime startTime = chargingOrderVO.getStartTime();


         LocalDateTime endTime = chargingOrderVO.getEndTime();


         // 计算时间差 秒 充电时长


         long between = ChronoUnit.SECONDS.between(startTime, endTime);


         chargingOrderVO.setChargingSecond(between);


         time += between;


         // 总收入


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


            income = income.add(chargingOrderVO.getPaymentAmount().subtract(chargingOrderVO.getRefundAmount()));


         }else{


            income = income.add(chargingOrderVO.getPaymentAmount());


         }


         for (TChargingOrderAccountingStrategy tChargingOrderAccountingStrategy : chargingOrderId) {


            // 累计电费


            electronicMoney1 = electronicMoney1.add(tChargingOrderAccountingStrategy.getElectrovalence()


                  .multiply(tChargingOrderAccountingStrategy.getChargingCapacity()));


            electronicMoney = electronicMoney.add(electronicMoney1);


            // 累计服务费


            serviceMoney1 = serviceMoney1.add(tChargingOrderAccountingStrategy.getServiceCharge());


            serviceMoney = serviceMoney.add(serviceMoney1);


         }


         chargingOrderVO.setServiceCharge(serviceMoney1);


         chargingOrderVO.setElectrovalence(electronicMoney1);


         // 充电时段数


         int size = chargingOrderId.size();


         chargingOrderVO.setCount(size);


         // 用户手机号


         TAppUser data = appUserClient.getUserById(chargingOrderVO.getAppUserId()).getData();


         if (data!=null){


            // 车牌号


            chargingOrderVO.setPhone(data.getPhone());


            List<Long> longs = new ArrayList<>();


            longs.add(chargingOrderVO.getAppUserCarId());


            List<TAppUserCar> data1 = appUserCarClient.getCarByIds(longs).getData();


            if (!data1.isEmpty()){


               chargingOrderVO.setLicensePlate(data1.get(0).getLicensePlate());


            }


         }


      }


      tCharingOrderVO.setTotal(total);


      tCharingOrderVO.setTime(time);


      tCharingOrderVO.setIncome(income);


      tCharingOrderVO.setElectronicMoney(electronicMoney);


      tCharingOrderVO.setServiceMoney(serviceMoney);


      pageInfo.setRecords(list);


      tCharingOrderVO.setList(pageInfo);


        return tCharingOrderVO;


    }


}