From 4ff5f35054ab141d915c11ad878d4dcffe7e034a Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期五, 12 五月 2023 18:43:27 +0800
Subject: [PATCH] BUG修改

---
 management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java |   67 ++++++++++++++++++---------------
 1 files changed, 37 insertions(+), 30 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 b44288e..7658f40 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
@@ -70,6 +70,8 @@
     @Autowired
     private TRegionMapper tRegionMapper;
     @Autowired
+    private TRevenueMapper tRevenueMapper;
+    @Autowired
     private ITRegionService itRegionService;
     @Autowired
     private HttpUtils httpUtils;
@@ -140,11 +142,11 @@
             }
             //累计订单量
             List<TOrder> cumulativeOrderCount = tOrders.stream().filter(order -> tDriver.getId().equals(order.getDriverId())
-                    && order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) && order.getState().equals(OrderStateEnum.FINISH.getCode())).collect(Collectors.toList());
+                    && (order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) || order.getState().equals(OrderStateEnum.FINISH.getCode()))).collect(Collectors.toList());
             tDriverResp.setCumulativeOrderCount(cumulativeOrderCount.size());
             //当月订单量
             List<TOrder> monthOrderCount = tOrders.stream().filter(order -> tDriver.getId().equals(order.getDriverId())
-                    && order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) && order.getState().equals(OrderStateEnum.FINISH.getCode())
+                    && (order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) || order.getState().equals(OrderStateEnum.FINISH.getCode()))
             && new SimpleDateFormat("yyyyMM").format(order.getCreateTime()).equals(monthDate)).collect(Collectors.toList());
             tDriverResp.setMonthOrderCount(monthOrderCount.size());
             // 拒单次数
@@ -183,11 +185,8 @@
 
         // 计算驾龄
         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);
         }
@@ -229,10 +228,10 @@
                 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","");
         }
 
         // 查询当前用户邀请了哪些人
@@ -248,11 +247,11 @@
         if(!CollectionUtils.isEmpty(tOrders)){
             //累计订单量
             List<TOrder> cumulativeOrderCount = tOrders.stream().filter(order -> tDriver.getId().equals(order.getDriverId())
-                    && order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) && order.getState().equals(OrderStateEnum.FINISH.getCode())).collect(Collectors.toList());
+                    && (order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) || order.getState().equals(OrderStateEnum.FINISH.getCode()))).collect(Collectors.toList());
             model.addAttribute("cumulativeOrderCount",cumulativeOrderCount.size());
             //当月订单量
             List<TOrder> monthOrderCount = tOrders.stream().filter(order -> tDriver.getId().equals(order.getDriverId())
-                    && order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) && order.getState().equals(OrderStateEnum.FINISH.getCode())
+                    && (order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) || order.getState().equals(OrderStateEnum.FINISH.getCode()))
                     && new SimpleDateFormat("yyyyMM").format(order.getCreateTime()).equals(monthDate)).collect(Collectors.toList());
             model.addAttribute("monthOrderCount",monthOrderCount.size());
             // 拒单次数
@@ -264,25 +263,33 @@
                     .eq("userDriverId", tDriver.getId())
                     .eq("state", 2));
             BigDecimal balance = tDriver.getBalance();
-            if(!CollectionUtils.isEmpty(tCashWithdrawals)){
-                Optional<BigDecimal> reduce = tCashWithdrawals.stream().map(TCashWithdrawal::getAmount).reduce(BigDecimal::add);
-                if(reduce.isPresent()){
-                    balance = balance.add(reduce.get());
-                }
-            }
-            List<TRechargeRecord> tRechargeRecords = tRechargeRecordMapper.selectList(new EntityWrapper<TRechargeRecord>()
-                    .eq("type", UserTypeEnum.DRIVER.getCode())
-                    .eq("userId", tDriver.getId())
-                    .eq("payType", 1)
-                    .eq("payStatus", PayStatusEnum.FINISH.getCode()));
-            if(!CollectionUtils.isEmpty(tRechargeRecords)){
-                Optional<BigDecimal> reduce = tRechargeRecords.stream().map(TRechargeRecord::getAmount).reduce(BigDecimal::add);
-                if(reduce.isPresent()){
-                    balance = balance.subtract(reduce.get());
-                }
-            }
+//            if(!CollectionUtils.isEmpty(tCashWithdrawals)){
+//                Optional<BigDecimal> reduce = tCashWithdrawals.stream().map(TCashWithdrawal::getAmount).reduce(BigDecimal::add);
+//                if(reduce.isPresent()){
+//                    balance = balance.add(reduce.get());
+//                }
+//            }
+//            List<TRechargeRecord> tRechargeRecords = tRechargeRecordMapper.selectList(new EntityWrapper<TRechargeRecord>()
+//                    .eq("type", UserTypeEnum.DRIVER.getCode())
+//                    .eq("userId", tDriver.getId())
+//                    .eq("payType", 1)
+//                    .eq("payStatus", PayStatusEnum.FINISH.getCode()));
+//            if(!CollectionUtils.isEmpty(tRechargeRecords)){
+//                Optional<BigDecimal> reduce = tRechargeRecords.stream().map(TRechargeRecord::getAmount).reduce(BigDecimal::add);
+//                if(reduce.isPresent()){
+//                    balance = balance.subtract(reduce.get());
+//                }
+//            }
+            List<TRevenue> tRevenues = tRevenueMapper.selectList(new EntityWrapper<TRevenue>()
+                    .eq("userType", 2)
+                    .eq("userId", tDriver.getId()));
+            Optional<BigDecimal> reduce = tRevenues.stream().map(TRevenue::getAmount).reduce(BigDecimal::add);
             // 减去充值金额
-            model.addAttribute("cumulativeIncome",balance);
+            if(reduce.isPresent()){
+                model.addAttribute("cumulativeIncome", reduce.get());
+            }else {
+                model.addAttribute("cumulativeIncome",0);
+            }
         }else {
             model.addAttribute("cumulativeOrderCount",0);
             model.addAttribute("monthOrderCount",0);

--
Gitblit v1.7.1