From a85b63f3e4d933df586714ea91c69a3fd5d16b99 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期五, 06 十二月 2024 11:56:07 +0800
Subject: [PATCH] 合作商权限

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java |  103 ++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 76 insertions(+), 27 deletions(-)

diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java
index 68621dc..28352ad 100644
--- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java
+++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java
@@ -4,12 +4,15 @@
 import com.ruoyi.account.api.feignClient.AppUserClient;
 import com.ruoyi.account.api.model.TAppUser;
 import com.ruoyi.account.api.model.TAppUserCar;
+import com.ruoyi.chargingPile.api.dto.GetSiteListDTO;
 import com.ruoyi.chargingPile.api.feignClient.ChargingGunClient;
 import com.ruoyi.chargingPile.api.feignClient.ChargingPileClient;
 import com.ruoyi.chargingPile.api.feignClient.SiteClient;
 import com.ruoyi.chargingPile.api.model.Site;
 import com.ruoyi.chargingPile.api.model.TChargingGun;
 import com.ruoyi.chargingPile.api.model.TChargingPile;
+import com.ruoyi.common.core.utils.DateUtils;
+import com.ruoyi.common.security.utils.SecurityUtils;
 import com.ruoyi.integration.api.feignClient.UploadRealTimeMonitoringDataClient;
 import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData;
 import com.ruoyi.order.api.model.TChargingOrder;
@@ -40,6 +43,7 @@
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -78,8 +82,7 @@
             }
         }
         ChargingBillVO chargingBillVO = new ChargingBillVO();
-        List<TChargingOrder> exports = new ArrayList<>();
-
+        List<TChargingOrder> tChargingOrders1 = new ArrayList<>();
         String startTime1 = null;
         String startTime2 = null;
         if (StringUtils.hasLength(dto.getStartTime())){
@@ -87,6 +90,20 @@
             startTime1 = split[0];
             startTime2 = split[1];
         }
+        Long userId = SecurityUtils.getUserId();
+        //如果没传siteId,获取当前登陆人所有的siteIds
+        List<Integer> siteIds = new ArrayList<>();
+        if (dto.getSiteId()==null){
+            if (userId != null){
+                List<GetSiteListDTO> data = siteClient.getSiteListByUserId(userId).getData();
+                for (GetSiteListDTO datum : data) {
+                    siteIds.add(datum.getId());
+                }
+            }
+        }else {
+            siteIds.add(dto.getSiteId());
+        }
+        dto.setSiteIds(siteIds);
         PageInfo<ChargingBillListVO> pageInfo = new PageInfo<>(dto.getPageCurr(),dto.getPageSize());
         PageInfo<ChargingBillListVO> pageInfo1 = new PageInfo<>(1,9999999);
         List<ChargingBillListVO> list = this.baseMapper.chargingBillList1(pageInfo,dto,startTime1,startTime2);
@@ -103,7 +120,6 @@
         BigDecimal discountTotal = new BigDecimal("0");
         int orderCount = 0;
         for (ChargingBillListVO chargingBillListVO : list) {
-
             String temp = "";
             String temp1 = "";
             switch (chargingBillListVO.getType()){
@@ -154,6 +170,7 @@
             List<TChargingOrder> tChargingOrders = chargingOrderList.selectList(eq);
             int chargingSecond = 0;
             BigDecimal paymentAmount = new BigDecimal("0");
+            BigDecimal rechargeAmount = new BigDecimal("0");
             BigDecimal orderAmount = new BigDecimal("0");
             BigDecimal electrovalence = new BigDecimal("0");
             BigDecimal serviceCharge = new BigDecimal("0");
@@ -265,7 +282,7 @@
                 if (data3!=null)tChargingOrder.setUserName(data3.getName());
                 // 累加实收金额 支付结算金额
                 if (tChargingOrder.getChargeAmount()!=null){
-                    paymentAmount = paymentAmount.add(tChargingOrder.getChargeAmount());
+                    paymentAmount = paymentAmount.add(tChargingOrder.getRechargeAmount());
                 }
                 // 总金额
                 if (tChargingOrder.getOrderAmount()!=null){
@@ -274,6 +291,9 @@
                 // 累加累计电费
                 if (tChargingOrder.getElectrovalence()!=null){
                     electrovalence = electrovalence.add(tChargingOrder.getElectrovalence());
+                }
+                if (tChargingOrder.getRechargeAmount()!=null){
+                    rechargeAmount = rechargeAmount.add(tChargingOrder.getRechargeAmount());
                 }
                 List<TChargingOrderRefund> list2 = chargingOrderRefundService.lambdaQuery().eq(TChargingOrderRefund::getRefundStatus, 2)
                         .eq(TChargingOrderRefund::getChargingOrderId, tChargingOrder.getId()).list();
@@ -288,7 +308,8 @@
                 }
                 // 累加平台手续费
                 if (tChargingOrder.getOrderAmount()!=null){
-                    commissionAmount = commissionAmount.add(tChargingOrder.getPaymentAmount().multiply(BigDecimal.valueOf(0.006)));
+                    commissionAmount = commissionAmount.add(tChargingOrder.getPaymentAmount().multiply(BigDecimal.valueOf(0.006))
+                            .setScale(2,BigDecimal.ROUND_DOWN));
                 }
                 // 累加平台分佣
                 if (tChargingOrder.getSharingAmount()!=null){
@@ -300,7 +321,6 @@
                 }
 
             }
-            exports.addAll(tChargingOrders);
             // 将chargingSecond 这是以秒为单位存放的总秒数 将其转化为xx小时xx分钟xx秒
             int hours = chargingSecond / 3600;
             int minutes = (chargingSecond % 3600) / 60;
@@ -312,7 +332,7 @@
                 chargingBillVO.setPaymentAmount(BigDecimal.ZERO);
             }
 
-            chargingBillListVO.setPaymentAmount(paymentAmount);
+            chargingBillListVO.setPaymentAmount(rechargeAmount);
             chargingBillListVO.setOrderAmount(paymentAmount == null?BigDecimal.ZERO:orderAmount.subtract(sharingAmount).subtract(commissionAmount));
             chargingBillListVO.setRefundAmount(refundAmount == null?BigDecimal.ZERO:refundAmount);
             chargingBillListVO.setElectrovalence(electrovalence == null?BigDecimal.ZERO:electrovalence);
@@ -320,8 +340,8 @@
             chargingBillListVO.setCommissionAmount(commissionAmount == null?BigDecimal.ZERO:commissionAmount.setScale(2,BigDecimal.ROUND_DOWN));
             chargingBillListVO.setSharingAmount(sharingAmount == null?BigDecimal.ZERO:sharingAmount);
             chargingBillListVO.setChargingCapacity(chargingCapacity == null?BigDecimal.ZERO:chargingCapacity);
-            chargingBillListVO.setBillMoney(paymentAmount.subtract(refundAmount==null?BigDecimal.ZERO:chargingBillListVO.getRefundAmount())
-                            .subtract(commissionAmount).subtract(sharingAmount).setScale(2, BigDecimal.ROUND_DOWN));
+            chargingBillListVO.setBillMoney(rechargeAmount.subtract(refundAmount==null?BigDecimal.ZERO:refundAmount)
+                            .subtract(commissionAmount.setScale(2,BigDecimal.ROUND_DOWN)).subtract(sharingAmount).setScale(2, BigDecimal.ROUND_DOWN));
             switch (chargingBillListVO.getType()){
                 case 1:
                     chargingBillListVO.setSiteName("全站");
@@ -338,6 +358,8 @@
             // 充电时间秒
             chargingBillListVO.setChargingSecond(chargingSecond);
         }
+        BigDecimal bigDecimal = new BigDecimal("0");
+
         for (ChargingBillListVO chargingBillListVO : list1) {
             if (chargingBillListVO.getType()==2){
                 continue;
@@ -371,12 +393,13 @@
                 eq.eq("site_id", chargingBillListVO.getSiteId());
             }
             List<TChargingOrder> tChargingOrders = chargingOrderList.selectList(eq);
+            tChargingOrders1.addAll(tChargingOrders);
             orderCount+=tChargingOrders.size();
             chargingBillVO.setCategory("");
             chargingBillVO.setExportList(tChargingOrders);
             for (TChargingOrder tChargingOrder : tChargingOrders) {
                 if (tChargingOrder.getOrderAmount()!=null){
-                    paymentAmountTotal = paymentAmountTotal.add(tChargingOrder.getChargeAmount());
+                    paymentAmountTotal = paymentAmountTotal.add(tChargingOrder.getRechargeAmount());
                 }
 
                 // 累加订单金额
@@ -391,6 +414,11 @@
                         .eq(TChargingOrderRefund::getRefundStatus, 2).list();
                 for (TChargingOrderRefund tChargingOrderRefund : list2) {
                     refundAmountTotal =refundAmountTotal.add(tChargingOrderRefund.getRefundAmount());
+                    tChargingOrder.setRefundAmount(tChargingOrderRefund.getRefundAmount());
+                    tChargingOrder.setRefundContent(tChargingOrderRefund.getRefundReason());
+                    tChargingOrder.setRefundCode(tChargingOrderRefund.getRefundCode());
+                    tChargingOrder.setRefundTime1(DateUtils.localDateTimeToString(tChargingOrderRefund.getRefundTime()));
+                    bigDecimal = bigDecimal.add(tChargingOrderRefund.getRefundAmount());
                 }
                 // 累加累计服务费
                 if (tChargingOrder.getServiceCharge()!=null){
@@ -398,7 +426,8 @@
                 }
                 // 累加平台手续费
                 if (tChargingOrder.getOrderAmount()!=null){
-                    commissionAmountTotal = commissionAmountTotal.add(tChargingOrder.getPaymentAmount().multiply(new BigDecimal("0.006")));
+                    commissionAmountTotal = commissionAmountTotal.add(tChargingOrder.getPaymentAmount().multiply(new BigDecimal("0.006"))
+                            .setScale(2,BigDecimal.ROUND_DOWN));
                 }
                 // 累加平台分佣
                 if (tChargingOrder.getSharingAmount()!=null){
@@ -428,7 +457,11 @@
         chargingBillVO.setSharingAmount(sharingAmountTotal);
         chargingBillVO.setDiscount(discountTotal);
         chargingBillVO.setRefundAmount(refundAmountTotal);
-
+        List<TChargingOrder> collect = tChargingOrders1.stream().distinct().collect(Collectors.toList());
+        if (!collect.isEmpty()){
+            collect.get(0).setRefundAmount1(bigDecimal);
+        }
+        chargingBillVO.setExportList(collect);
         pageInfo.setRecords(list);
         chargingBillVO.setList(pageInfo);
         return chargingBillVO;
@@ -452,6 +485,19 @@
         }
         PageInfo<ChargingBillListVO> pageInfo = new PageInfo<>(dto.getPageCurr(),dto.getPageSize());
         PageInfo<ChargingBillListVO> pageInfo1 = new PageInfo<>(1,9999999);
+        Long userId = SecurityUtils.getUserId();
+        //如果没传siteId,获取当前登陆人所有的siteIds
+        List<Integer> siteIds = new ArrayList<>();
+        if (dto.getSiteId()==null){
+            if (userId != null){
+                List<GetSiteListDTO> data = siteClient.getSiteListByUserId(userId).getData();
+                for (GetSiteListDTO datum : data) {
+                    siteIds.add(datum.getId());
+                }
+            }
+        }else {
+            siteIds.add(dto.getSiteId());
+        }
         List<ChargingBillListVO> list = this.baseMapper.chargingBillList(pageInfo,dto,startTime1,startTime2);
         List<ChargingBillListVO> list1 = this.baseMapper.chargingBillList(pageInfo1,dto,startTime1,startTime2);
         BigDecimal paymentAmountTotal = new BigDecimal("0");
@@ -462,7 +508,7 @@
         BigDecimal sharingAmountTotal = new BigDecimal("0");
         BigDecimal chargingCapacityTotal = new BigDecimal("0");
         BigDecimal discountTotal = new BigDecimal("0");
-        BigDecimal refundAmount = new BigDecimal("0");
+        BigDecimal refundAmountTotal = new BigDecimal("0");
         int orderCount = 0;
         for (ChargingBillListVO chargingBillListVO : list) {
             String temp = "";
@@ -521,6 +567,7 @@
             BigDecimal commissionAmount = new BigDecimal("0");
             BigDecimal sharingAmount = new BigDecimal("0");
             BigDecimal chargingCapacity = new BigDecimal("0");
+            BigDecimal refundAmount = new BigDecimal("0");
             chargingBillVO.setCategory("");
             chargingBillListVO.setOrderCount(tChargingOrders.size());
             chargingBillVO.setExportList(tChargingOrders);
@@ -627,8 +674,8 @@
                     paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount());
                 }
                 // 总金额
-                if (tChargingOrder.getOrderAmount()!=null){
-                orderAmount = orderAmount.add(tChargingOrder.getPaymentAmount());
+                if (tChargingOrder.getRechargeAmount()!=null){
+                orderAmount = orderAmount.add(tChargingOrder.getRechargeAmount());
                 }
                 // 累加累计电费
                 if (tChargingOrder.getElectrovalence()!=null){
@@ -643,7 +690,8 @@
                 }
                 // 累加平台手续费
                 if (tChargingOrder.getOrderAmount()!=null){
-                    commissionAmount = commissionAmount.add(tChargingOrder.getPaymentAmount().multiply(BigDecimal.valueOf(0.006)));
+                    commissionAmount = commissionAmount.add(tChargingOrder.getPaymentAmount().multiply(BigDecimal.valueOf(0.006))
+                            .setScale(2,BigDecimal.ROUND_DOWN));
                 }
                 // 累加平台分佣
                 if (tChargingOrder.getSharingAmount()!=null){
@@ -661,9 +709,9 @@
             // 格式化为字符串
             String timeString = String.format("%d小时%d分钟%d秒", hours, minutes, seconds);
             chargingBillVO.setChargingTime(timeString);
+            chargingBillListVO.setOrderAmount(orderAmount.subtract(refundAmount));
 
-            chargingBillListVO.setPaymentAmount(orderAmount.subtract(commissionAmount).subtract(sharingAmount).setScale(2,BigDecimal.ROUND_DOWN));
-            chargingBillListVO.setOrderAmount(orderAmount);
+            chargingBillListVO.setPaymentAmount(chargingBillListVO.getOrderAmount().subtract(commissionAmount).subtract(sharingAmount).setScale(2,BigDecimal.ROUND_DOWN));
             chargingBillListVO.setElectrovalence(electrovalence);
             chargingBillListVO.setServiceCharge(serviceCharge.setScale(2,BigDecimal.ROUND_DOWN));
             chargingBillListVO.setCommissionAmount(commissionAmount.setScale(2,BigDecimal.ROUND_DOWN));
@@ -686,7 +734,7 @@
             chargingBillListVO.setChargingSecond(chargingSecond);
         }
         for (ChargingBillListVO chargingBillListVO : list1) {
-            if (chargingBillListVO.getType() ==1){
+            if (chargingBillListVO.getType() ==2){
                 continue;
             }
             LocalDateTime billTime = chargingBillListVO.getBillTime();
@@ -735,9 +783,9 @@
                     paymentAmountTotal = paymentAmountTotal.add(tChargingOrder.getPaymentAmount());
                 }
                 // 累加订单金额
-                if (tChargingOrder.getOrderAmount()!=null){
-                    orderAmount = orderAmount.add(tChargingOrder.getPaymentAmount());
-                    orderAmountTotal = orderAmountTotal.add(tChargingOrder.getPaymentAmount());
+                if (tChargingOrder.getRechargeAmount()!=null){
+                    orderAmount = orderAmount.add(tChargingOrder.getRechargeAmount());
+                    orderAmountTotal = orderAmountTotal.add(tChargingOrder.getRechargeAmount());
                 }
                 // 累加累计电费
                 if (tChargingOrder.getElectrovalence()!=null){
@@ -745,7 +793,7 @@
                     electrovalenceTotal = electrovalenceTotal.add(tChargingOrder.getElectrovalence());
                 }
                 if (tChargingOrder.getRefundAmount()!=null && tChargingOrder.getRefundStatus() !=null && tChargingOrder.getRefundStatus() == 2){
-                    refundAmount = refundAmount.add(tChargingOrder.getRefundAmount());
+                    refundAmountTotal = refundAmountTotal.add(tChargingOrder.getRefundAmount());
                 }
                 // 累加累计服务费
                 if (tChargingOrder.getServiceCharge()!=null){
@@ -754,8 +802,9 @@
                 }
                 // 累加平台手续费
                 if (tChargingOrder.getOrderAmount()!=null){
-                    commissionAmount = commissionAmount.add(tChargingOrder.getPaymentAmount().multiply(new BigDecimal("0.006")));
-                    commissionAmountTotal = commissionAmountTotal.add(tChargingOrder.getPaymentAmount().multiply(new BigDecimal("0.006")));
+                    commissionAmount = commissionAmount.add(tChargingOrder.getPaymentAmount().multiply(new BigDecimal("0.006")).setScale(2,BigDecimal.ROUND_DOWN));
+                    commissionAmountTotal = commissionAmountTotal.add(tChargingOrder.getPaymentAmount().multiply(new BigDecimal("0.006"))
+                            .setScale(2,BigDecimal.ROUND_DOWN));
                 }
                 // 累加平台分佣
                 if (tChargingOrder.getSharingAmount()!=null){
@@ -777,8 +826,8 @@
             }
         }
         chargingBillVO.setChargingCapacity(chargingCapacityTotal);
-        chargingBillVO.setPaymentAmount(orderAmountTotal.subtract(commissionAmountTotal).subtract(sharingAmountTotal).setScale(2, BigDecimal.ROUND_DOWN));
-        chargingBillVO.setOrderAmount(orderAmountTotal.setScale(2, BigDecimal.ROUND_DOWN));
+        chargingBillVO.setPaymentAmount(paymentAmountTotal.subtract(commissionAmountTotal).subtract(sharingAmountTotal).setScale(2, BigDecimal.ROUND_DOWN));
+        chargingBillVO.setOrderAmount(orderAmountTotal.subtract(refundAmountTotal).setScale(2, BigDecimal.ROUND_DOWN));
         chargingBillVO.setElectrovalence(electrovalenceTotal.setScale(2, BigDecimal.ROUND_DOWN));
         chargingBillVO.setServiceCharge(serviceChargeTotal.setScale(2, BigDecimal.ROUND_DOWN));
         chargingBillVO.setOrderCount(orderCount);

--
Gitblit v1.7.1