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 |   34 +++++++++++++++++++++++++---------
 1 files changed, 25 insertions(+), 9 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..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 用户后台结束充电
@@ -289,7 +299,7 @@
             tChargingOrderAccountingStrategy.setEndTime(format+" "+tChargingOrderAccountingStrategy.getEndTime());
         }
 
-        
+
         return R.ok(list);
     }
 
@@ -335,7 +345,6 @@
     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)+"":"");
@@ -798,18 +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);
         }
 
 
@@ -1121,7 +1134,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