From b4d8cb69ff3a3d35a10a7e5c487ff683b31cc9f1 Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期五, 24 二月 2023 10:06:03 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TDriverServiceImpl.java | 129 ++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 120 insertions(+), 9 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..a3d2fd9 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,13 +1,17 @@ package com.stylefeng.guns.modular.system.service.impl; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.stylefeng.guns.core.util.DateUtil; 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.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.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -15,6 +19,8 @@ import org.springframework.util.CollectionUtils; import org.springframework.util.StringUtils; +import java.io.File; +import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.time.LocalDate; import java.time.Period; @@ -49,6 +55,12 @@ private TAppUserMapper tAppUserMapper; @Autowired private TOrderRefusalMapper tOrderRefusalMapper; + @Autowired + private TRegionMapper tRegionMapper; + @Autowired + private ITRegionService itRegionService; + @Autowired + private HttpUtils httpUtils; @Override public EntityWrapper<TDriver> getPageList(String createTime, String phone, Integer status) { @@ -123,6 +135,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,6 +148,8 @@ 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("createTime",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(tDriver.getCreateTime())); // 计算驾龄 @@ -152,8 +167,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())){ + // 设置余额 + tDriver.setBalance(tDriver.getBackgroundBalance().add(tDriver.getBalance())); + model.addAttribute("balance",tDriver.getBalance()); + }else { + model.addAttribute("balance",BigDecimal.ZERO); + } // 所属代理商 TAgent tAgent = tAgentMapper.selectById(tDriver.getAgentId()); @@ -184,6 +204,16 @@ model.addAttribute("inviterPhone",""); } + // 查询当前用户邀请了哪些人 + List<TDriver> list = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("inviterId", tDriver.getId())); + if(!CollectionUtils.isEmpty(list)){ + model.addAttribute("inviterCount",list.size()); + model.addAttribute("inviterCommission",0); + }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()) @@ -197,17 +227,98 @@ // 拒单次数 List<TOrderRefusal> driverRefusalList = tOrderRefusalMapper.selectList(new EntityWrapper<TOrderRefusal>().eq("driver_id", tDriver.getId())); model.addAttribute("refusalCount",driverRefusalList.size()); + // todo 累计收入 + 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(String imgUrl) { + File file = new File(imgUrl); + String result = httpUtils.ocr("2", file); + JSONObject jsonObject = JSONObject.parseObject(result); + return jsonObject; + } + + @Override + public void 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()); + + tDriver.setCode(UUIDUtil.getNumberRandom(16)); + tDriver.setBalance(BigDecimal.ZERO); + tDriver.setBackgroundBalance(BigDecimal.ZERO); + + // 通过省市查询代理商 + List<TAgent> tAgent = tAgentMapper.selectList(new EntityWrapper<TAgent>().eq("provinceCode", province.getCode()) + .eq("cityCode", city.getCode()) + .last("LIMIT 1")); + if(!CollectionUtils.isEmpty(tAgent)){ + tDriver.setAgentId(tAgent.get(0).getId()); + } + // 查询邀约人(司机端) + List<TDriver> emergencyDriver = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("phone", tDriver.getEmergencyPhone()) + .last("LIMIT 1")); + if(!CollectionUtils.isEmpty(emergencyDriver)){ + tDriver.setInviterId(emergencyDriver.get(0).getId()); + tDriver.setInviterType(2); + } + // 通过省市区查询分公司 + List<TBranchOffice> tBranchOffice = tBranchOfficeMapper.selectList(new EntityWrapper<TBranchOffice>().eq("provinceCode", province.getCode()) + .eq("cityCode", city.getCode()) + .eq("districtCode", area.getCode()) + .last("LIMIT 1")); + if(!CollectionUtils.isEmpty(tBranchOffice)){ + tDriver.setBranchOfficeId(tBranchOffice.get(0).getId()); + } + + // ocr识别 +// JSONObject ocr = this.ocr("E:\\071bf986db0b00355c0ed190bbd3b16.png"); +// System.err.println(ocr); + } + + @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"); + return wrapper; } } -- Gitblit v1.7.1