From a41a64cab7a8c05c65f4b92fef82acf805d1d9b2 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期六, 26 十月 2024 11:03:25 +0800
Subject: [PATCH] bug修改

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java |   56 +++++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 39 insertions(+), 17 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 cb256b4..c74c027 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 用户后台结束充电
@@ -289,7 +299,7 @@
             tChargingOrderAccountingStrategy.setEndTime(format+" "+tChargingOrderAccountingStrategy.getEndTime());
         }
 
-        
+
         return R.ok(list);
     }
 
@@ -341,12 +351,12 @@
         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(Arrays.asList(byId.getAppUserCarId())).getData();
-            if (!data.isEmpty()){
-                chargingOrderInfoVO.setLicensePlate(data.get(0).getLicensePlate());
-                chargingOrderInfoVO.setVehicleBrand(data.get(0).getVehicleBrand());
-                chargingOrderInfoVO.setVehicleModel(data.get(0).getVehicleModel());
-                chargingOrderInfoVO.setVehicleUse(data.get(0).getVehicleUse());
+            TAppUserCar data = appUserCarClient.getCarById(byId.getAppUserCarId()+"").getData();
+            if (data!=null){
+                chargingOrderInfoVO.setLicensePlate(data.getLicensePlate());
+                chargingOrderInfoVO.setVehicleBrand(data.getVehicleBrand());
+                chargingOrderInfoVO.setVehicleModel(data.getVehicleModel());
+                chargingOrderInfoVO.setVehicleUse(data.getVehicleUse());
             }
         }
         // 时段总服务费
@@ -794,24 +804,33 @@
 //        }
 //        Set<String> strings = map.keySet();
 
-
+        mongoChargingOrderQuery.setPageSize(10);
         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);
+                }
+                BeanUtils.copyProperties(uploadRealTimeMonitoringData,dataDto);
+                dataDto.setStartTime(uploadRealTimeMonitoringData.getStartTime());
+                dataDto.setEndTime(uploadRealTimeMonitoringData.getEndTime()==null?null:uploadRealTimeMonitoringData.getEndTime());
+                dataDto.setStatus(chargingOrderVO.getStatus());
+                dtos.add(dataDto);
+            }else {
+                continue;
             }
-            dtos.add(dataDto);
         }
-
+        for (int i = 0; i < dtos.size(); i++) {
+            dtos.get(i).setIndex(i);
+        }
 
         return R.ok(dtos);
     }
@@ -1121,7 +1140,10 @@
         //查询各个分数
        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);

--
Gitblit v1.7.1