From f87ad18f9c3175cee155c4f0c06302369ec7ea9d Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期五, 18 四月 2025 09:24:26 +0800
Subject: [PATCH] 临时屏蔽监管上传代码,暂停使用消息队列

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java |   17 ++++++++++++-----
 1 files changed, 12 insertions(+), 5 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 06e5acf..e452064 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
@@ -168,9 +168,14 @@
     @ResponseBody
     @PostMapping(value = "/getChargingStatistics")
     public R<List<TChargingOrder>> getChargingStatistics(@RequestBody ChargingStatisticeDTO dto) {
-        List<TChargingOrder> list = chargingOrderService.lambdaQuery()
-                .between(TChargingOrder::getEndTime, dto.getStartTime(), dto.getEndTime()).list();
-        return R.ok(list);
+        List<Long> collect = chargingOrderAccountingStrategyService.lambdaQuery().between(TChargingOrderAccountingStrategy::getCreateTime, dto.getStartTime(), dto.getEndTime())
+                .list().stream().map(TChargingOrderAccountingStrategy::getChargingOrderId).collect(Collectors.toList());
+        if (!collect.isEmpty()){
+            List<TChargingOrder> list = chargingOrderService.lambdaQuery()
+                    .in(TChargingOrder::getId,collect).list();
+            return R.ok(list);
+        }
+        return R.ok(new ArrayList<TChargingOrder>());
     }
 
     /**
@@ -1287,7 +1292,6 @@
             start = statisticsQueryDto.getStartTime();
             end = statisticsQueryDto.getEndTime();
         }else if (statisticsQueryDto.getDayType()==5){
-            // 获取今年1月1日的日期
             start = statisticsQueryDto.getStartTime();
             end = statisticsQueryDto.getEndTime();
             if (start.equals(end)){
@@ -1452,7 +1456,10 @@
         BigDecimal commissionAmount = BigDecimal.ZERO;
         for (Map<String, Object> map : maps) {
             BigDecimal periodElectricPrice = (BigDecimal) map.get("period_electric_price");
-            allMoney = allMoney.add(periodElectricPrice);
+            Long order_source = (Long)map.get("order_source");
+            if(2 != order_source){
+                allMoney = allMoney.add(periodElectricPrice);
+            }
             BigDecimal total_amount = (BigDecimal) map.get("total_amount");
             allMoney = allMoney.add(total_amount);
             commissionAmount = commissionAmount.add((BigDecimal) map.get("commissionAmount"));

--
Gitblit v1.7.1