From 583d0c0d31f3de2ae87043660706cfa0cb8f1126 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期四, 17 七月 2025 17:52:02 +0800
Subject: [PATCH] Merge branch 'dev' of http://120.76.84.145:10101/gitblit/r/java/mx_charging_pile into dev

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java |   79 ++++++++++++++++++++++++++++++++-------
 1 files changed, 65 insertions(+), 14 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 90f2041..9fce2fd 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
@@ -58,6 +58,7 @@
 import com.ruoyi.order.dto.*;
 import com.ruoyi.order.service.*;
 import com.ruoyi.order.util.PreviousSixMonths;
+import com.ruoyi.order.util.mongodb.service.UploadRealTimeMonitoringDataService;
 import com.ruoyi.order.vo.EndOfChargePageInfo;
 import com.ruoyi.order.vo.StatisticsOfBatteryVO;
 import com.ruoyi.order.vo.WatchChargingOrderVo;
@@ -150,7 +151,7 @@
     @Resource
     private TOrderInvoiceService invoiceService;
     @Resource
-    private UploadRealTimeMonitoringDataClient uploadRealTimeMonitoringDataClient;
+    private UploadRealTimeMonitoringDataService uploadRealTimeMonitoringDataService;
     @Resource
     private PartnerClient partnerClient;
     @Resource
@@ -853,7 +854,17 @@
                                          @RequestParam("attach") String attach) {
         chargingOrderService.chargingOrderCallback(2, out_trade_no, transaction_id, attach);
     }
-    
+    /**
+     * 支付宝H5支付成功后的回调
+     */
+    @ResponseBody
+    @PostMapping(value = "/chargingOrderALIH5Callback")
+    public void chargingOrderALIH5Callback(@RequestParam("out_trade_no") String out_trade_no,
+                                         @RequestParam("transaction_id") String transaction_id,
+                                         @RequestParam("attach") String attach) {
+        chargingOrderService.chargingOrderCallback(3, out_trade_no, transaction_id, attach);
+    }
+
     
     /**
      *
@@ -1108,6 +1119,7 @@
     public R<Map<String,Object>> total() {
         //count近6个月的数据
         Long userId = tokenService.getLoginUser().getUserid();
+        SysUser sysUser = sysUserClient.getSysUser(userId).getData();
         //获取当前登录的siteIds
         List<Integer> siteIds = new ArrayList<>();
         List<GetSiteListDTO> data9 = siteClient.getSiteListByUserId(userId).getData();
@@ -1119,17 +1131,23 @@
             siteIds.add(-1);
         }
         Map<String,Object>  map = chargingOrderService.countAll(siteIds);
-        BigDecimal data = parkingLotClient.getRecordAmount().getData();
-        if (map ==null){
-            map = new HashMap<String,Object>();
+        if(1 == sysUser.getObjectId()){
+            BigDecimal data = parkingLotClient.getRecordAmount().getData();
+            if (map ==null){
+                map = new HashMap<String,Object>();
+            }
+            map.put("parkingAmount",data);
+            BigDecimal data1 =   shoppingOrderService.getSumAmount();
+            map.put("shopAmount",data1);
+            BigDecimal data2 =   vipOrderService.getSumAmout();
+            map.put("vipAmount",data2);
+        }else{
+            map.put("parkingAmount",0);
+            map.put("shopAmount",0);
+            map.put("vipAmount",0);
         }
-        map.put("parkingAmount",data);
-        BigDecimal data1 =   shoppingOrderService.getSumAmount();
-        map.put("shopAmount",data1);
-        BigDecimal data2 =   vipOrderService.getSumAmout();
-        map.put("vipAmount",data2);
         List<TChargingOrder> list = chargingOrderService.lambdaQuery().eq(TChargingOrder::getStatus, 5).eq(TChargingOrder::getDelFlag, 0)
-                .eq(TChargingOrder::getRechargePaymentStatus, 2).list();
+                .eq(TChargingOrder::getRechargePaymentStatus, 2).in(TChargingOrder::getSiteId, siteIds).list();
         BigDecimal sharingAmount = BigDecimal.ZERO;
         BigDecimal commissionAmount = BigDecimal.ZERO;
         //计算list中electrovalence的总和
@@ -1245,7 +1263,7 @@
     @GetMapping(value = "/watch/deletes")
     @ApiOperation(value = "监控订单-删除", tags = {"管理后台-订单管理"})
     public R watchChargingOrder(@RequestParam String id) {
-        uploadRealTimeMonitoringDataClient.delete(id);
+        uploadRealTimeMonitoringDataService.delete(id);
         return R.ok();
     }
     
@@ -1264,8 +1282,10 @@
      */
     @PostMapping(value = "/getOrderByCode/{code}")
     public R<TChargingOrder> getOrderByCode(@PathVariable("code") String code){
-        return R.ok(chargingOrderService.getOne(Wrappers.lambdaQuery(TChargingOrder.class)
-                .eq(TChargingOrder::getCode,code)));
+        TChargingOrder one = chargingOrderService.getOne(Wrappers.lambdaQuery(TChargingOrder.class)
+                .eq(TChargingOrder::getCode, code));
+        one.setIdStr(one.getId().toString());
+        return R.ok(one);
     }
     
     
@@ -2381,4 +2401,35 @@
         return R.ok(chargingOrderService.getSumDegreeBySiteIds(SiteIds));
     }
 
+
+    @GetMapping(value = "/getOrderIdByUserId")
+    @ApiOperation(value = "H5查询当前用户正在充电中的订单id集合", tags = {"H5-首页-用户充电订单信息"})
+    public R<String> getOrderIdByUserId() {
+        Long userId = tokenService.getLoginUserApplet().getUserId();
+        TChargingOrder chargingOrder = chargingOrderService.getOne(Wrappers.lambdaQuery(TChargingOrder.class)
+                .eq(TChargingOrder::getAppUserId, userId)
+                .in(TChargingOrder::getStatus, Arrays.asList(1,2,3,4))
+                .orderByDesc(TChargingOrder::getCreateTime)
+                .last("LIMIT 1"));
+        if(Objects.isNull(chargingOrder)){
+            return R.ok();
+        }
+        return R.ok(String.valueOf(chargingOrder.getId()));
+    }
+
+//    @GetMapping(value = "/getOrderByCode")
+//    @ApiOperation(value = "H5通过编号查询订单", tags = {"H5-首页-用户充电订单信息"})
+//    public R<String> getOrderByCode(@RequestParam("code") String code) {
+//        Long userId = tokenService.getLoginUserApplet().getUserId();
+//        TChargingOrder chargingOrder = chargingOrderService.getOne(Wrappers.lambdaQuery(TChargingOrder.class)
+//                .eq(TChargingOrder::getAppUserId, userId)
+//                .in(TChargingOrder::getStatus, Arrays.asList(1,2,3,4))
+//                .orderByDesc(TChargingOrder::getCreateTime)
+//                .last("LIMIT 1"));
+//        if(Objects.isNull(chargingOrder)){
+//            return R.ok();
+//        }
+//        return R.ok(String.valueOf(chargingOrder.getId()));
+//    }
+
 }

--
Gitblit v1.7.1