From 4e8951a439c03e87568789cedeb62033884412db Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期二, 16 五月 2023 10:24:17 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java |   71 +++++++++++++++++++----------------
 1 files changed, 39 insertions(+), 32 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..5deea73 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;
@@ -94,8 +96,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");
@@ -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