明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
luodangjia
2024-10-08 4c96637a005891c709662ae84edd072ad9a4a57d 
 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;


@@ -190,6 +183,9 @@


   


   @Resource


   private AppUserTagClient appUserTagClient;


	


   @Resource


   private SecurityDetectionClient securityDetectionClient;




   //计数器


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


@@ -650,6 +646,19 @@


      //执行5分钟的定时任务检测


      ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);


      scheduler.scheduleAtFixedRate(()->{


         //获取安全校验


         SecurityDetection securityDetection = securityDetectionClient.getSecurityDetection(chargingOrder.getCode()).getData();


         if(null != securityDetection){


            PreChargeCheck preChargeCheck1 =  redisService.getCacheObject("AQJC_" + chargingOrder.getChargingGunId());


            if(null != preChargeCheck1){


               preChargeCheck1.setElectronicLockLock(preChargeCheck1.getElectronicLockLock());


               preChargeCheck1.setInsulationTesting(true);


               preChargeCheck1.setSecureConnectionDetection(preChargeCheck1.getSecureConnectionDetection());


               preChargeCheck1.setStartupSuccess(1);


               redisService.setCacheObject("AQJC_" + chargingOrder.getChargingGunId(), preChargeCheck1);


            }


         }


			


         List<PlatformStartChargingReply> data = platformStartChargingReplyClient.getPlatformStartChargingReply(code).getData();


         System.err.println("-------------------开始检查调起充电结果-------------------");


         System.err.println(data.toString());


@@ -948,6 +957,9 @@


               throw new RuntimeException(failure_cause);


            }




            // 将枪状态重置为空闲


            chargingGun.setStatus(2);


            chargingGunClient.updateChargingGunById(chargingGun);


            //计算费用，处理退款


            endCharge(chargingOrder);


            break;


@@ -1853,6 +1865,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);


   }


@@ -1900,6 +1917,8 @@




   @Resource


   private TShoppingOrderService shoppingOrderService;


   @Resource


   private TShoppingOrderRefundService shoppingOrderRefundService;


   @Override


   public R payRefund(PayOrderRefundDto payOrderQueryDto) {


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


@@ -1934,6 +1953,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);


               }


            }


@@ -1947,6 +1969,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);




               }


@@ -1959,8 +1984,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());


@@ -1989,7 +2014,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);


               }


            }




@@ -2002,7 +2030,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);




               }


            }


@@ -2446,6 +2479,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"));