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