From 05e13dc68b3db44868d9e02a10ccc330366a49c6 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期二, 08 八月 2023 11:58:36 +0800
Subject: [PATCH] 修改bug
---
management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java | 467 +++++++++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 428 insertions(+), 39 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 65a23b0..8ed368c 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
@@ -1,28 +1,49 @@
package com.stylefeng.guns.modular.system.service.impl;
+import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.stylefeng.guns.core.base.tips.SuccessTip;
+import com.stylefeng.guns.core.shiro.ShiroKit;
import com.stylefeng.guns.core.util.DateUtil;
+import com.stylefeng.guns.modular.system.controller.resp.TDriverCommissionResp;
import com.stylefeng.guns.modular.system.controller.resp.TDriverResp;
+import com.stylefeng.guns.modular.system.controller.util.HttpUtils;
+import com.stylefeng.guns.modular.system.controller.util.UUIDUtil;
import com.stylefeng.guns.modular.system.dao.*;
import com.stylefeng.guns.modular.system.enums.OrderStateEnum;
+import com.stylefeng.guns.modular.system.enums.PayStatusEnum;
+import com.stylefeng.guns.modular.system.enums.StatusEnum;
+import com.stylefeng.guns.modular.system.enums.UserTypeEnum;
import com.stylefeng.guns.modular.system.model.*;
import com.stylefeng.guns.modular.system.service.ITDriverService;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.stylefeng.guns.modular.system.service.ITRegionService;
+import org.apache.commons.io.FileUtils;
+import org.apache.poi.hdf.extractor.TC;
+import org.slf4j.Logger;
+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;
import org.springframework.util.StringUtils;
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.math.BigDecimal;
+import java.net.URL;
+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.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;
/**
@@ -49,7 +70,21 @@
private TAppUserMapper tAppUserMapper;
@Autowired
private TOrderRefusalMapper tOrderRefusalMapper;
+ @Autowired
+ private TRegionMapper tRegionMapper;
+ @Autowired
+ private TRevenueMapper tRevenueMapper;
+ @Autowired
+ private ITRegionService itRegionService;
+ @Autowired
+ private HttpUtils httpUtils;
+ @Autowired
+ private TRechargeRecordMapper tRechargeRecordMapper;
+ @Autowired
+ private TCashWithdrawalMapper tCashWithdrawalMapper;
+
+ private Logger log = LoggerFactory.getLogger(this.getClass());
@Override
public EntityWrapper<TDriver> getPageList(String createTime, String phone, Integer status) {
EntityWrapper<TDriver> wrapper = new EntityWrapper<>();
@@ -64,11 +99,20 @@
// 开始，结束时间
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");
+ // 判断是否为代理商或者分公司
+ if(Objects.requireNonNull(ShiroKit.getUser()).getRoleType() == 2){
+ // 分公司
+ wrapper.eq("branchOfficeId",ShiroKit.getUser().getObjectId());
+ }
+ if(Objects.requireNonNull(ShiroKit.getUser()).getRoleType() == 3){
+ // 代理商
+ wrapper.eq("agentId",ShiroKit.getUser().getObjectId());
+ }
return wrapper;
}
@@ -84,8 +128,10 @@
TDriverResp tDriverResp = new TDriverResp();
BeanUtils.copyProperties(tDriver,tDriverResp);
- // 设置余额
- tDriverResp.setBalance(tDriver.getBackgroundBalance().add(tDriver.getBalance()));
+ if(Objects.nonNull(tDriver.getBackgroundBalance()) && Objects.nonNull(tDriver.getBalance()) && Objects.nonNull(tDriver.getCouponBalance())){
+ // 设置余额
+ tDriverResp.setBalance(tDriver.getBackgroundBalance().add(tDriver.getBalance()).add(tDriver.getCouponBalance()));
+ }
// 所属代理商
TAgent tAgent = tAgentMapper.selectById(tDriver.getAgentId());
@@ -98,12 +144,12 @@
tDriverResp.setBranchName(tBranchOffice.getPrincipal());
}
//累计订单量
- List<TOrder> cumulativeOrderCount = tOrders.stream().filter(order -> order.getDriverId().equals(tDriver.getId())
- && order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) && order.getState().equals(OrderStateEnum.FINISH.getCode())).collect(Collectors.toList());
+ 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());
tDriverResp.setCumulativeOrderCount(cumulativeOrderCount.size());
//当月订单量
- List<TOrder> monthOrderCount = tOrders.stream().filter(order -> order.getDriverId().equals(tDriver.getId())
- && order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) && order.getState().equals(OrderStateEnum.FINISH.getCode())
+ 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()))
&& new SimpleDateFormat("yyyyMM").format(order.getCreateTime()).equals(monthDate)).collect(Collectors.toList());
tDriverResp.setMonthOrderCount(monthOrderCount.size());
// 拒单次数
@@ -123,6 +169,7 @@
model.addAttribute("id",tDriver.getId());
model.addAttribute("code",tDriver.getCode());
model.addAttribute("name",tDriver.getName());
+ model.addAttribute("avatar",tDriver.getAvatar());
model.addAttribute("phone",tDriver.getPhone());
model.addAttribute("sex",tDriver.getSex());
model.addAttribute("driverLicenseNumber",tDriver.getDriverLicenseNumber());
@@ -135,15 +182,15 @@
model.addAttribute("provinceName",tDriver.getProvinceName());
model.addAttribute("cityName",tDriver.getCityName());
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);
}
@@ -152,8 +199,13 @@
String monthDate = new SimpleDateFormat("yyyyMM").format(new Date());
- // 设置余额
- tDriver.setBalance(tDriver.getBackgroundBalance().add(tDriver.getBalance()));
+ if(Objects.nonNull(tDriver.getBackgroundBalance()) && Objects.nonNull(tDriver.getBalance()) && Objects.nonNull(tDriver.getCouponBalance())){
+ // 设置余额
+ tDriver.setBalance(tDriver.getBackgroundBalance().add(tDriver.getBalance()).add(tDriver.getCouponBalance()));
+ model.addAttribute("balance",tDriver.getBalance());
+ }else {
+ model.addAttribute("balance",BigDecimal.ZERO);
+ }
// 所属代理商
TAgent tAgent = tAgentMapper.selectById(tDriver.getAgentId());
@@ -170,44 +222,381 @@
model.addAttribute("principal","");
}
- // 查询邀请人
- if(Objects.nonNull(tDriver.getInviterType()) && 1 == tDriver.getInviterType()){
- TAppUser tAppUser = tAppUserMapper.selectById(tDriver.getInviterId());
- model.addAttribute("inviterName",tAppUser.getNickname());
- model.addAttribute("inviterPhone",tAppUser.getPhone());
- }else if(Objects.nonNull(tDriver.getInviterType()) && 2 == tDriver.getInviterType()){
- TDriver tDriver1 = tDriverMapper.selectById(tDriver.getInviterId());
- model.addAttribute("inviterName",tDriver1.getName());
- model.addAttribute("inviterPhone",tDriver1.getPhone());
+ if(Objects.nonNull(tDriver.getInviterId())){
+ // 查询邀请人
+ if(Objects.nonNull(tDriver.getInviterType()) && 1 == tDriver.getInviterType()){
+ TAppUser tAppUser = tAppUserMapper.selectById(tDriver.getInviterId());
+ model.addAttribute("inviterName",tAppUser.getNickname());
+ model.addAttribute("inviterPhone",tAppUser.getPhone());
+ }else if(Objects.nonNull(tDriver.getInviterType()) && 2 == tDriver.getInviterType()){
+ TDriver tDriver1 = tDriverMapper.selectById(tDriver.getInviterId());
+ model.addAttribute("inviterName",tDriver1.getName());
+ model.addAttribute("inviterPhone",tDriver1.getPhone());
+ }
}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());
+ }else {
+ model.addAttribute("inviterCommission",0);
+ model.addAttribute("inviterCount",0);
+ }
+
if(!CollectionUtils.isEmpty(tOrders)){
//累计订单量
- List<TOrder> cumulativeOrderCount = tOrders.stream().filter(order -> order.getDriverId().equals(tDriver.getId())
- && order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) && order.getState().equals(OrderStateEnum.FINISH.getCode())).collect(Collectors.toList());
+ 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());
model.addAttribute("cumulativeOrderCount",cumulativeOrderCount.size());
//当月订单量
- List<TOrder> monthOrderCount = tOrders.stream().filter(order -> order.getDriverId().equals(tDriver.getId())
- && order.getState().equals(OrderStateEnum.WAIT_EVALUATED.getCode()) && order.getState().equals(OrderStateEnum.FINISH.getCode())
+ 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()))
&& new SimpleDateFormat("yyyyMM").format(order.getCreateTime()).equals(monthDate)).collect(Collectors.toList());
model.addAttribute("monthOrderCount",monthOrderCount.size());
// 拒单次数
List<TOrderRefusal> driverRefusalList = tOrderRefusalMapper.selectList(new EntityWrapper<TOrderRefusal>().eq("driver_id", tDriver.getId()));
model.addAttribute("refusalCount",driverRefusalList.size());
+ // 累计收入 司机提现记录加上余额减去充值金额，为累计收入
+ List<TCashWithdrawal> tCashWithdrawals = tCashWithdrawalMapper.selectList(new EntityWrapper<TCashWithdrawal>()
+ .eq("type", UserTypeEnum.DRIVER.getCode())
+ .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());
+// }
+// }
+ 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);
+ // 减去充值金额
+ if(reduce.isPresent()){
+ model.addAttribute("cumulativeIncome", reduce.get());
+ }else {
+ model.addAttribute("cumulativeIncome",0);
+ }
}else {
- model.addAttribute("cumulativeOrderCount","");
- model.addAttribute("monthOrderCount","");
- model.addAttribute("refusalCount","");
+ model.addAttribute("cumulativeOrderCount",0);
+ model.addAttribute("monthOrderCount",0);
+ model.addAttribute("refusalCount",0);
+ // 累计收入
+ model.addAttribute("cumulativeIncome",0);
}
}
@Override
- public void detail(Integer tDriverId, Model model) {
- auditPage(tDriverId,model);
- // TODO 查询司机
- TDriver tDriver = tDriverMapper.selectById(tDriverId);
+ public JSONObject ocr(File file) {
+ String result = httpUtils.ocr("2", file);
+ return JSONObject.parseObject(result);
+ }
+
+ @Override
+ public Object addOrUpdate(TDriver tDriver) {
+ // 对省市区做处理
+ String[] split = tDriver.getAreaId().split("/");
+ // 查询省市
+ // 黑龙江省/大兴安岭地区
+ // 702/852
+ TRegion province = tRegionMapper.selectById(split[0]);
+ tDriver.setProvinceName(province.getName());
+ tDriver.setProvinceCode(province.getCode());
+
+ TRegion city = tRegionMapper.selectById(split[1]);
+ if(Objects.isNull(city)){
+ city = itRegionService.selectOne(new EntityWrapper<TRegion>().eq("name",split[1]));
+ }
+ tDriver.setCityName(city.getName());
+ tDriver.setCityCode(city.getCode());
+
+// TRegion area = tRegionMapper.selectById(split[2]);
+// if(Objects.isNull(area)){
+// area = itRegionService.selectOne(new EntityWrapper<TRegion>().eq("name",split[2]));
+// }
+// tDriver.setAreaName(area.getName());
+// tDriver.setAreaCode(area.getCode());
+ TRegion area = null;
+ if(split.length>2){
+ area = itRegionService.selectById(split[2]);
+ if(Objects.isNull(area)){
+ area = itRegionService.selectOne(new EntityWrapper<TRegion>().eq("name",split[2]));
+ }
+ tDriver.setAreaName(area.getName());
+ tDriver.setAreaCode(area.getCode());
+ }else {
+ tDriver.setAreaName(city.getName());
+ tDriver.setAreaCode(city.getCode());
+ }
+
+ // 通过省市查询代理商
+ List<TAgent> tAgent = tAgentMapper.selectList(new EntityWrapper<TAgent>().eq("provinceCode", province.getCode())
+ .eq("cityCode", city.getCode())
+ .eq("status", StatusEnum.NORMAL.getCode())
+ .last("LIMIT 1"));
+ if(!CollectionUtils.isEmpty(tAgent)){
+ tDriver.setAgentId(tAgent.get(0).getId());
+ }else {
+ return new SuccessTip(500, "该区域代理商被冻结或不存在");
+ }
+ if(StringUtils.hasLength(tDriver.getInviterPhone())){
+ // 查询邀约人（司机端）
+ List<TDriver> emergencyDriver = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("phone", tDriver.getInviterPhone())
+ .last("LIMIT 1"));
+ if(!CollectionUtils.isEmpty(emergencyDriver)){
+ tDriver.setInviterId(emergencyDriver.get(0).getId());
+ tDriver.setInviterType(2);
+ }else {
+ return new SuccessTip(500, "该邀约人:"+tDriver.getInviterName()+"不存在");
+ }
+ }
+ List<TBranchOffice> tBranchOffice;
+ if(split.length>2){
+ // 通过省市区查询分公司
+ tBranchOffice = tBranchOfficeMapper.selectList(new EntityWrapper<TBranchOffice>().eq("provinceCode", province.getCode())
+ .eq("cityCode", city.getCode())
+ .eq("status", StatusEnum.NORMAL.getCode())
+ .eq("districtCode", area.getCode())
+ .last("LIMIT 1"));
+ }else {
+ // 通过省市区查询分公司
+ tBranchOffice = tBranchOfficeMapper.selectList(new EntityWrapper<TBranchOffice>().eq("provinceCode", province.getCode())
+ .eq("cityCode", city.getCode())
+ .eq("status", StatusEnum.NORMAL.getCode())
+ .last("LIMIT 1"));
+// tBranchOffice = tBranchOfficeMapper.selectList(new EntityWrapper<TBranchOffice>().eq("provinceCode", province.getCode())
+// .eq("cityCode", city.getCode())
+// .eq("status", StatusEnum.NORMAL.getCode())
+// .eq("districtCode", city.getCode())
+// .last("LIMIT 1"));
+ }
+ if(!CollectionUtils.isEmpty(tBranchOffice)){
+ tDriver.setBranchOfficeId(tBranchOffice.get(0).getId());
+ }else {
+ return new SuccessTip(500, "该区域分公司被冻结或不存在");
+ }
+
+ // ocr识别
+// JSONObject ocr = this.ocr("E:\\071bf986db0b00355c0ed190bbd3b16.png");
+// System.err.println(ocr);
+ return null;
+ }
+
+ @Override
+ public EntityWrapper<TDriver> getCommissionPageList(String name, String phone, Integer status) {
+ EntityWrapper<TDriver> wrapper = new EntityWrapper<>();
+ // 手机号
+ if(StringUtils.hasLength(phone)){
+ wrapper.like("phone",phone);
+ }
+ // 状态
+ if(Objects.nonNull(status)){
+ wrapper.eq("status",status);
+ }
+ // 姓名
+ if(StringUtils.hasLength(name)){
+ wrapper.like("name",name);
+ }
+ wrapper.orderBy(true,"approvalStatus");
+ // 判断是否为代理商或者分公司
+ if(Objects.requireNonNull(ShiroKit.getUser()).getRoleType() == 2){
+ // 分公司
+ wrapper.eq("branchOfficeId",ShiroKit.getUser().getObjectId());
+ }
+ if(Objects.requireNonNull(ShiroKit.getUser()).getRoleType() == 3){
+ // 代理商
+ wrapper.eq("agentId",ShiroKit.getUser().getObjectId());
+ }
+ return wrapper;
+ }
+
+ @Override
+ public List<TDriverCommissionResp> getTDriverCommissionResp(List<TDriver> drivers) {
+ List<TDriverCommissionResp> commissionRespList = new ArrayList<>(drivers.size());
+ for (TDriver driver : drivers) {
+ TDriverCommissionResp commissionResp = new TDriverCommissionResp();
+ BeanUtils.copyProperties(driver,commissionResp);
+
+ // 查询代理商
+ // 所属代理商
+ TAgent tAgent = tAgentMapper.selectById(driver.getAgentId());
+ if(Objects.nonNull(tAgent)){
+ commissionResp.setAgentName(tAgent.getPrincipal());
+ }
+
+ // 关联人数
+ AtomicInteger connectedPersons = new AtomicInteger(0);
+
+ List<TDriver> inviterTwoList = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("inviterId", driver.getId()));
+ if(!CollectionUtils.isEmpty(inviterTwoList)){
+ // 推广人数
+ commissionResp.setNumberPromoters(inviterTwoList.size());
+ List<Integer> inviterTwoIds = inviterTwoList.stream().map(TDriver::getId).collect(Collectors.toList());
+ connectedPersons.addAndGet(inviterTwoList.size());
+ // 查询三级
+ List<TDriver> inviterThreeList = tDriverMapper.selectList(new EntityWrapper<TDriver>().in("inviterId", inviterTwoIds));
+ if(!CollectionUtils.isEmpty(inviterThreeList)){
+ List<Integer> inviterThreeIds = inviterThreeList.stream().map(TDriver::getId).collect(Collectors.toList());
+ connectedPersons.addAndGet(inviterThreeList.size());
+ // 查询四级
+ List<TDriver> inviterFourList = tDriverMapper.selectList(new EntityWrapper<TDriver>().in("inviterId", inviterThreeIds));
+ connectedPersons.addAndGet(inviterFourList.size());
+
+ }
+ }
+
+ commissionResp.setConnectedPersons(connectedPersons.get());
+
+ // 已提现佣金 查询该司机的佣金提现记录
+ 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.add(commissionResp.getCommission()));
+ commissionRespList.add(commissionResp);
+
+ }
+ return commissionRespList;
+ }
+
+ @Override
+ 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());
+ model.addAttribute("phone",driver.getPhone());
+ model.addAttribute("sex",driver.getSex());
+ model.addAttribute("status",driver.getStatus());
+ model.addAttribute("commission",driver.getCommission());
+ model.addAttribute("startTimeToEndTime",new SimpleDateFormat("yyyy-MM-dd").format(driver.getCreateTime()).replace("-",".")+"-"+
+ new SimpleDateFormat("yyyy-MM-dd").format(new Date()).replace("-","."));
+
+ // 所属代理商
+ TAgent tAgent = tAgentMapper.selectById(driver.getAgentId());
+ if(Objects.nonNull(tAgent)){
+ model.addAttribute("agentName",tAgent.getPrincipal());
+ }else {
+ model.addAttribute("agentName","");
+ }
+
+ // 关联人数
+ AtomicInteger connectedPersons = new AtomicInteger(0);
+ // 推广人数
+ List<TDriver> inviterTwoList = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("inviterId", driver.getId()));
+ if(!CollectionUtils.isEmpty(inviterTwoList)){
+ model.addAttribute("numberPromoters",inviterTwoList.size());
+ List<Integer> inviterTwoIds = inviterTwoList.stream().map(TDriver::getId).collect(Collectors.toList());
+ connectedPersons.addAndGet(inviterTwoList.size());
+ // 查询三级
+ List<TDriver> inviterThreeList = tDriverMapper.selectList(new EntityWrapper<TDriver>().in("inviterId", inviterTwoIds));
+ if(!CollectionUtils.isEmpty(inviterThreeList)){
+ List<Integer> inviterThreeIds = inviterThreeList.stream().map(TDriver::getId).collect(Collectors.toList());
+ connectedPersons.addAndGet(inviterThreeList.size());
+ // 查询四级
+ List<TDriver> inviterFourList = tDriverMapper.selectList(new EntityWrapper<TDriver>().in("inviterId", inviterThreeIds));
+ connectedPersons.addAndGet(inviterFourList.size());
+ }
+ }else {
+ model.addAttribute("numberPromoters",0);
+ }
+ model.addAttribute("connectedPersons",connectedPersons.get());
+ 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.add(driver.getCommission()));
+// commissionResp.setAccumulatedCommission(BigDecimal.ZERO);
+
+ }
+
+ @Override
+ public void getDataStatistics(Integer agentId, Model model,Map<String, Object> map) {
+ // 司机总数
+ Integer driverTotal = tDriverMapper.selectCount(new EntityWrapper<TDriver>()
+ .eq("agentId", agentId));
+ // 司机最近一月数量
+ LocalDateTime now = LocalDateTime.now();
+ LocalDateTime localDateTime = now.minusMonths(1);
+ Integer driverMonthTotal = tDriverMapper.selectCount(new EntityWrapper<TDriver>()
+ .eq("agentId", agentId)
+ .between("createTime", localDateTime, now));
+ model.addAttribute("driverTotal",driverTotal);
+ model.addAttribute("driverMonthTotal",driverMonthTotal);
+ map.put("driverTotal",driverTotal);
+ map.put("driverMonthTotal",driverMonthTotal);
+ }
+
+ @Override
+ public void getDataStatisticsByIds(List<Integer> ids, Model model, Map<String, Object> map) {
+ // 司机总数
+ Integer driverTotal = tDriverMapper.selectCount(new EntityWrapper<TDriver>()
+ .in("agentId", ids));
+ // 司机最近一月数量
+ LocalDateTime now = LocalDateTime.now();
+ LocalDateTime localDate = now.minusMonths(1);
+ Integer driverMonthTotal = tDriverMapper.selectCount(new EntityWrapper<TDriver>()
+ .in("agentId", ids)
+ .between("createTime", localDate, now));
+ model.addAttribute("driverTotal",driverTotal);
+ model.addAttribute("driverMonthTotal",driverMonthTotal);
+ map.put("driverTotal",driverTotal);
+ map.put("driverMonthTotal",driverMonthTotal);
}
}
--
Gitblit v1.7.1