From 72a76cd3ad51a520100ec59481d99118ffebd33c Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期一, 28 十月 2024 15:18:50 +0800
Subject: [PATCH] 合并代码

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java |   56 ++++++++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 44 insertions(+), 12 deletions(-)

diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java
index 6dc6368..f0b3e44 100644
--- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java
+++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java
@@ -92,7 +92,8 @@
     private TokenService tokenService;
     @Autowired
     private TOrderEvaluateService orderEvaluateService;
-    
+    @Autowired
+    private TGrantVipService tGrantVipService;
     @Resource
     private WxPaymentClient wxPaymentClient;
     
@@ -133,6 +134,15 @@
     @Resource
     private TOrderInvoiceService invoiceService;
 
+    /**
+     * 远程调用 增加管理后台赠送会员记录
+     * @return
+     */
+    @ResponseBody
+    @PostMapping(value = "/management/give/vip")
+    public R managementGiveVip(@RequestBody TGrantVip grantVip) {
+        return R.ok(tGrantVipService.save(grantVip));
+    }
 
     /**
      * 远程调用根据枪id 查询最新的订单id 用户后台结束充电
@@ -282,6 +292,14 @@
     @ApiOperation(value = "充电明细", tags = {"管理后台-支付订单-订单信息"})
     public R<List<TChargingOrderAccountingStrategy>> chargingDetail(Long orderId) {
         List<TChargingOrderAccountingStrategy> list = chargingOrderAccountingStrategyService.lambdaQuery().eq(TChargingOrderAccountingStrategy::getChargingOrderId, orderId).orderByDesc(TChargingOrderAccountingStrategy::getStartTime).list();
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        for (TChargingOrderAccountingStrategy tChargingOrderAccountingStrategy : list) {
+            String format = tChargingOrderAccountingStrategy.getCreateTime().format(formatter);
+            tChargingOrderAccountingStrategy.setStartTime(format+" "+tChargingOrderAccountingStrategy.getStartTime());
+            tChargingOrderAccountingStrategy.setEndTime(format+" "+tChargingOrderAccountingStrategy.getEndTime());
+        }
+
+
         return R.ok(list);
     }
 
@@ -327,13 +345,12 @@
     public AjaxResult<ChargingOrderInfoVO> chargingOrderInfo(String strategyId) {
         TChargingOrder byId = chargingOrderService.getById(strategyId);
         ChargingOrderInfoVO chargingOrderInfoVO = new ChargingOrderInfoVO();
-
         chargingOrderInfoVO.setCdElectronic(byId.getCurrent()!=null?byId.getCurrent().setScale(2, BigDecimal.ROUND_HALF_DOWN)+"":"");
         chargingOrderInfoVO.setCdVoltage(byId.getVoltage()!=null?byId.getVoltage().setScale(2, BigDecimal.ROUND_HALF_DOWN)+"":"");
         chargingOrderInfoVO.setSurplus(byId.getTotalElectricity()!=null?byId.getTotalElectricity().setScale(2, BigDecimal.ROUND_HALF_DOWN)+"":"");
         chargingOrderInfoVO.setTotalPower(byId.getPower()!=null?byId.getPower().setScale(2, BigDecimal.ROUND_HALF_DOWN)+"":"");
         if (byId.getAppUserCarId()!=null){
-            List<TAppUserCar> data = appUserCarClient.getCarByIds(Collections.singletonList(byId.getAppUserCarId())).getData();
+            List<TAppUserCar> data = appUserCarClient.getCarByIds(Arrays.asList(byId.getAppUserCarId())).getData();
             if (!data.isEmpty()){
                 chargingOrderInfoVO.setLicensePlate(data.get(0).getLicensePlate());
                 chargingOrderInfoVO.setVehicleBrand(data.get(0).getVehicleBrand());
@@ -790,16 +807,22 @@
         List<UploadRealTimeMonitoringData> data1 = uploadRealTimeMonitoringDataClient.getAll(mongoChargingOrderQuery).getData();
 
         List<ChargingOrderAndUploadRealTimeMonitoringDataDto> dtos = new ArrayList<>();
+        Map<String,ChargingOrderVO> map  = new HashMap<>();
         for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : data1) {
             ChargingOrderAndUploadRealTimeMonitoringDataDto dataDto = new ChargingOrderAndUploadRealTimeMonitoringDataDto();
             BeanUtils.copyProperties(uploadRealTimeMonitoringData,dataDto);
             ChargingOrderQuery dto = new ChargingOrderQuery();
+            dto.setCode(uploadRealTimeMonitoringData.getTransaction_serial_number());
             TCharingOrderVO vo = chargingOrderService.chargingOrder(dto);
-            ChargingOrderVO chargingOrderVO = vo.getList().getRecords().get(0);
-            if (chargingOrderVO!=null) {
-                BeanUtils.copyProperties(chargingOrderVO, dataDto);
+            if (!vo.getList().getRecords().isEmpty()) {
+                ChargingOrderVO chargingOrderVO = vo.getList().getRecords().get(0);
+                if (chargingOrderVO != null) {
+                    BeanUtils.copyProperties(chargingOrderVO, dataDto);
+                }
+                dtos.add(dataDto);
+            }else {
+                continue;
             }
-            dtos.add(dataDto);
         }
 
 
@@ -888,7 +911,7 @@
             start = statisticsQueryDto.getStartTime();
             end = statisticsQueryDto.getEndTime();
         }
-        List<TChargingOrder> list = chargingOrderService.lambdaQuery().ge(TChargingOrder::getStartTime, start).le(TChargingOrder::getEndTime, end).in(TChargingOrder::getSiteId, siteIds).list();
+        List<TChargingOrder> list = chargingOrderService.lambdaQuery().ge(TChargingOrder::getCreateTime, start).le(TChargingOrder::getCreateTime, end).in(TChargingOrder::getSiteId, siteIds).list();
         List<Long> chargingOrderIds = list.stream().map(TChargingOrder::getId).collect(Collectors.toList());
         chargingOrderIds.add(-1L);
         //上方饼图
@@ -1063,6 +1086,11 @@
 
         //用户标签
       List<Map<String,Object>> maps =    chargingOrderService.getUserTagCount();
+        Map<String,Object> stringObjectMap = new HashMap<>();
+        Long noTagCount =  chargingOrderService.countNoTag();
+        stringObjectMap.put("count",noTagCount);
+        maps.add(stringObjectMap);
+
         //会员标签
         List<Map<String,Object>> maps1 =  chargingOrderService.getVipCount();
 
@@ -1102,11 +1130,14 @@
             siteIds.add(statisticsQueryDto.getSiteId());
         }
         //查询评价分
-        Long aver = chargingOrderService.getAver(siteIds);
+        Double aver = chargingOrderService.getAver(siteIds);
         //查询各个分数
        List<Map<String,Object>> evaluate =  chargingOrderService.getLevelEvaluate(siteIds);
         //查询差评回复数
-        Long count = orderEvaluateService.lambdaQuery().isNotNull(TOrderEvaluate::getResponseTime).count();
+        List<Integer> mark = new ArrayList<>();
+        mark.add(1);
+        mark.add(2);
+        Long count = orderEvaluateService.lambdaQuery().in(TOrderEvaluate::getMark, mark).isNotNull(TOrderEvaluate::getResponseTime).count();
         TCharingUserEvaluateVO tCharingUserEvaluateVO = new TCharingUserEvaluateVO();
         tCharingUserEvaluateVO.setAver(aver);
         tCharingUserEvaluateVO.setEvaluate(evaluate);
@@ -1413,8 +1444,9 @@
         //将capMap的chargingCapacity除以totalRatedPower保留两位数
         capMap.forEach(map -> {
             BigDecimal chargingCapacity = (BigDecimal) map.get("chargingCapacity");
-            BigDecimal result = chargingCapacity.divide(totalRatedPower, 2, RoundingMode.HALF_UP);
-            map.put("chargingCapacity", result);
+            BigDecimal result = chargingCapacity.divide(totalRatedPower, 4, RoundingMode.HALF_UP);
+            BigDecimal multiply = result.multiply(new BigDecimal(100));
+            map.put("chargingCapacity", multiply);
         });
 
 

--
Gitblit v1.7.1