From ad86e0cb28f4301c4935bea43e4ebd824338390e Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期四, 18 五月 2023 16:44:46 +0800
Subject: [PATCH] BUG修改

---
 management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java |   91 +++++++++++++++++++++++++++++++++------------
 1 files changed, 66 insertions(+), 25 deletions(-)

diff --git a/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java b/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java
index 9adcdc1..d6eac87 100644
--- a/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java
+++ b/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java
@@ -24,6 +24,7 @@
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.format.annotation.DateTimeFormat;
 import org.springframework.stereotype.Service;
 import org.springframework.ui.Model;
 import org.springframework.util.CollectionUtils;
@@ -37,8 +38,10 @@
 import java.net.URLConnection;
 import java.text.SimpleDateFormat;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.time.Period;
 import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.stream.Collectors;
@@ -96,8 +99,8 @@
         // 开始,结束时间
         if(StringUtils.hasLength(createTime)){
             String[] split = createTime.split(" - ");
-            Date startTime = DateUtil.getDate_str4(split[0]);
-            Date endTime = DateUtil.getDate_str4(split[1]);
+            Date startTime = DateUtil.getDate_str3(split[0]+" 00:00:00");
+            Date endTime = DateUtil.getDate_str3(split[1]+" 23:59:59");
             wrapper.between("createTime",startTime,endTime);
         }
         wrapper.orderBy(true,"approvalStatus");
@@ -181,15 +184,13 @@
         model.addAttribute("areaName",tDriver.getAreaName());
         model.addAttribute("integral",tDriver.getIntegral());
         model.addAttribute("score",tDriver.getScore());
+        model.addAttribute("source",tDriver.getSource());
         model.addAttribute("createTime",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(tDriver.getCreateTime()));
 
         // 计算驾龄
         if(Objects.nonNull(tDriver.getFirstCertificateTime())){
-            ZoneId zoneId = ZoneId.systemDefault();
-            LocalDate firstTime = tDriver.getFirstCertificateTime().toInstant().atZone(zoneId).toLocalDate();
-            LocalDate now = tDriver.getFirstCertificateTime().toInstant().atZone(zoneId).toLocalDate();
-            Period period = Period.between(firstTime, now);
-            model.addAttribute("drivingExperience",period.getYears());
+            Period period = Period.between(LocalDate.now(), com.stylefeng.guns.modular.system.util.DateUtil.dateToLocalDate(tDriver.getFirstCertificateTime()));
+            model.addAttribute("drivingExperience",Math.max(Math.abs(period.getYears()), 1));
         }else {
             model.addAttribute("drivingExperience",0);
         }
@@ -231,17 +232,25 @@
                 TDriver tDriver1 = tDriverMapper.selectById(tDriver.getInviterId());
                 model.addAttribute("inviterName",tDriver1.getName());
                 model.addAttribute("inviterPhone",tDriver1.getPhone());
-            }else {
-                model.addAttribute("inviterName","");
-                model.addAttribute("inviterPhone","");
             }
+        }else {
+            model.addAttribute("inviterName","");
+            model.addAttribute("inviterPhone","");
         }
 
         // 查询当前用户邀请了哪些人
         List<TDriver> list = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("inviterId", tDriver.getId()));
         if(!CollectionUtils.isEmpty(list)){
+            List<TCashWithdrawal> tCashWithdrawals = tCashWithdrawalMapper.selectList(new EntityWrapper<TCashWithdrawal>()
+                    .eq("type", UserTypeEnum.DRIVER.getCode())
+                    .eq("userDriverId", tDriver.getId())
+                    .eq("businessType", 11)
+                    .eq("state", 2));
+            Optional<BigDecimal> reduce = tCashWithdrawals.stream().map(TCashWithdrawal::getAmount).reduce(BigDecimal::add);
+            BigDecimal bigDecimal = BigDecimal.ZERO;
+            reduce.ifPresent(bigDecimal::add);
+            model.addAttribute("inviterCommission",bigDecimal.add(tDriver.getCommission()));
             model.addAttribute("inviterCount",list.size());
-            model.addAttribute("inviterCommission",0);
         }else {
             model.addAttribute("inviterCommission",0);
             model.addAttribute("inviterCount",0);
@@ -288,7 +297,11 @@
                     .eq("userId", tDriver.getId()));
             Optional<BigDecimal> reduce = tRevenues.stream().map(TRevenue::getAmount).reduce(BigDecimal::add);
             // 减去充值金额
-            reduce.ifPresent(bigDecimal -> model.addAttribute("cumulativeIncome", bigDecimal));
+            if(reduce.isPresent()){
+                model.addAttribute("cumulativeIncome", reduce.get());
+            }else {
+                model.addAttribute("cumulativeIncome",0);
+            }
         }else {
             model.addAttribute("cumulativeOrderCount",0);
             model.addAttribute("monthOrderCount",0);
@@ -434,11 +447,23 @@
             commissionResp.setConnectedPersons(connectedPersons.get());
 
             // 已提现佣金  查询该司机的佣金提现记录
-            commissionResp.setWithdrawnAmount(BigDecimal.ZERO);
-
+            List<TCashWithdrawal> tCashWithdrawals = tCashWithdrawalMapper.selectList(new EntityWrapper<TCashWithdrawal>()
+                    .eq("type", UserTypeEnum.DRIVER.getCode())
+                    .eq("userDriverId", driver.getId())
+                    .eq("businessType", 11)
+                    .eq("state", 2));
+            BigDecimal bigDecimal = BigDecimal.ZERO;
+            if(!CollectionUtils.isEmpty(tCashWithdrawals)){
+                Optional<BigDecimal> reduce = tCashWithdrawals.stream().map(TCashWithdrawal::getAmount).reduce(BigDecimal::add);
+                if(reduce.isPresent()){
+                    bigDecimal.add(reduce.get());
+                    commissionResp.setWithdrawnAmount(bigDecimal);
+                }
+            }else {
+                commissionResp.setWithdrawnAmount(bigDecimal);
+            }
             // 累计佣金  可提现佣金+已提现佣金
-            commissionResp.setAccumulatedCommission(BigDecimal.ZERO);
-
+            commissionResp.setAccumulatedCommission(bigDecimal.add(commissionResp.getCommission()));
             commissionRespList.add(commissionResp);
 
         }
@@ -446,11 +471,12 @@
     }
 
     @Override
-    public void driverCommissionDetail(Integer tDriverId, Model model) {
+    public void driverCommissionDetail(Integer tDriverId, Integer levelFlag,Model model) {
 
         // 查询司机
         TDriver driver = tDriverMapper.selectById(tDriverId);
 
+        model.addAttribute("levelFlag",levelFlag);
         // 司机信息封装
         model.addAttribute("driverId",tDriverId);
         model.addAttribute("name",driver.getName());
@@ -490,11 +516,26 @@
             model.addAttribute("numberPromoters",0);
         }
         model.addAttribute("connectedPersons",connectedPersons.get());
-        // 已提现佣金  查询该司机的佣金提现记录
-        model.addAttribute("withdrawnAmount",BigDecimal.ZERO);
+        List<TCashWithdrawal> tCashWithdrawals = tCashWithdrawalMapper.selectList(new EntityWrapper<TCashWithdrawal>()
+                .eq("type", UserTypeEnum.DRIVER.getCode())
+                .eq("userDriverId", driver.getId())
+                .eq("businessType", 11)
+                .eq("state", 2));
+        BigDecimal bigDecimal = BigDecimal.ZERO;
+        if(!CollectionUtils.isEmpty(tCashWithdrawals)){
+            Optional<BigDecimal> reduce = tCashWithdrawals.stream().map(TCashWithdrawal::getAmount).reduce(BigDecimal::add);
+            if(reduce.isPresent()){
+                bigDecimal.add(reduce.get());
+                // 已提现佣金  查询该司机的佣金提现记录
+                model.addAttribute("withdrawnAmount",bigDecimal);
+            }
+        }else {
+            // 已提现佣金  查询该司机的佣金提现记录
+            model.addAttribute("withdrawnAmount",bigDecimal);
+        }
 //        commissionResp.setWithdrawnAmount(BigDecimal.ZERO);
         // 累计佣金  可提现佣金+已提现佣金
-        model.addAttribute("accumulatedCommission",BigDecimal.ZERO);
+        model.addAttribute("accumulatedCommission",bigDecimal.add(driver.getCommission()));
 //        commissionResp.setAccumulatedCommission(BigDecimal.ZERO);
 
     }
@@ -505,11 +546,11 @@
         Integer driverTotal = tDriverMapper.selectCount(new EntityWrapper<TDriver>()
                 .eq("agentId", agentId));
         // 司机最近一月数量
-        LocalDate now = LocalDate.now();
-        LocalDate localDate = now.plusMonths(1);
+        LocalDateTime now = LocalDateTime.now();
+        LocalDateTime localDateTime = now.minusMonths(1);
         Integer driverMonthTotal = tDriverMapper.selectCount(new EntityWrapper<TDriver>()
                 .eq("agentId", agentId)
-                .between("createTime", localDate, now));
+                .between("createTime", localDateTime, now));
         model.addAttribute("driverTotal",driverTotal);
         model.addAttribute("driverMonthTotal",driverMonthTotal);
         map.put("driverTotal",driverTotal);
@@ -522,8 +563,8 @@
         Integer driverTotal = tDriverMapper.selectCount(new EntityWrapper<TDriver>()
                 .in("agentId", ids));
         // 司机最近一月数量
-        LocalDate now = LocalDate.now();
-        LocalDate localDate = now.plusMonths(1);
+        LocalDateTime now = LocalDateTime.now();
+        LocalDateTime localDate = now.minusMonths(1);
         Integer driverMonthTotal = tDriverMapper.selectCount(new EntityWrapper<TDriver>()
                 .in("agentId", ids)
                 .between("createTime", localDate, now));

--
Gitblit v1.7.1