黔云通
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
liujie
7 天以前 2e9e8c6680f6bc152f14f0acb7d565027460fd95 
 DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java


@@ -29,7 +29,6 @@


import com.stylefeng.guns.modular.taxi.dao.OrderTaxiMapper;


import com.stylefeng.guns.modular.taxi.model.OrderTaxi;


import com.stylefeng.guns.modular.taxi.service.IOrderTaxiService;


import io.rong.models.response.TokenResult;


import org.apache.shiro.authc.SimpleAuthenticationInfo;


import org.apache.shiro.authc.UsernamePasswordToken;


import org.apache.shiro.authc.credential.HashedCredentialsMatcher;


@@ -44,7 +43,7 @@


import javax.servlet.http.HttpServletRequest;


import java.math.BigDecimal;


import java.text.SimpleDateFormat;


import java.time.LocalDateTime;


import java.time.LocalDate;


import java.util.*;


import java.util.concurrent.TimeUnit;




@@ -156,7 +155,7 @@


        List<Driver> drivers = driverMapper.queryIdleDriver(type, companyId);


        List<Driver> list = new ArrayList<>();


        for(Driver driver : drivers){


            String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(driver.getId()));


            String value = (String) redisTemplate.opsForValue().get("dache:DRIVER" + String.valueOf(driver.getId()));


            if(null != value){


                Map<String, Double> distance1 = geodesyUtil.getDistance(lon + "," + lat, value);


                double d = Double.valueOf(distance1.get("WGS84")).doubleValue();


@@ -173,7 +172,7 @@


        List<Driver> drivers = driverMapper.queryIdleDriver_(type, serverCarModelId, companyId);


        List<Driver> list = new ArrayList<>();


        for(Driver driver : drivers){


            String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(driver.getId()));


            String value = (String) redisTemplate.opsForValue().get("dache:DRIVER" + String.valueOf(driver.getId()));


            if(null != value){


                Map<String, Double> distance1 = geodesyUtil.getDistance(lon + "," + lat, value);


                double d = Double.valueOf(distance1.get("WGS84")).doubleValue();


@@ -401,15 +400,19 @@


        driver.setSex(registeredWarpper.getSex());


        driver.setIdCard(registeredWarpper.getIdCard());






        driver.setArea(registeredWarpper.getArea());


        driver.setAreaCode(registeredWarpper.getAreaCode());


        driver.setAreaCode(registeredWarpper.getPlaceOfEmployment());


        driver.setCity(registeredWarpper.getCity());


        driver.setCityCode(registeredWarpper.getCityCode());


        driver.setProvince(registeredWarpper.getProvince());


        driver.setProvinceCode(registeredWarpper.getProvinceCode());


        driver.setCompanyId(registeredWarpper.getCompanyId());


        if(registeredWarpper.getCompanyId()==null){


            return ResultUtil.error("请选择服务商");


        }




        String code = registeredWarpper.getAreaCode();


        String code = registeredWarpper.getPlaceOfEmployment();


        Company query = companyCityService.query(code);


        if(null == query){


            return ResultUtil.error("选择从业地暂未开通业务");


@@ -559,8 +562,8 @@


        loginWarpper.setToken(token);


        loginWarpper.setAppid(UUIDUtil.getRandomCode());


        loginWarpper.setState(ToolUtil.isEmpty(driver.getIdCard()) ? 1 : 0);


        TokenResult token1 = RongCloudUtil.getToken(driver.getId().toString(), driver.getName(), driver.getHeadImgUrl());


        loginWarpper.setRongYunToken(token1.getToken());


//        TokenResult token1 = RongCloudUtil.getToken(driver.getId().toString(), driver.getName(), driver.getHeadImgUrl());


//        loginWarpper.setRongYunToken(token1.getToken());




        //创建高德猎鹰的终端数据


//        String tid = gdFalconUtil.createTerminal(phone);


@@ -1326,7 +1329,7 @@


        String s = JwtTokenUtil.generateToken(String.valueOf(driver.getId()));


        redisTemplate.opsForValue().set(s.substring(s.length() - 32), String.valueOf(driver.getId()), 7, TimeUnit.DAYS);


        redisTemplate.opsForValue().set(driver.getPhone(), s.substring(s.length() - 32));


        redisTemplate.opsForValue().set("DRIVER_" + driver.getId(), s);


        redisTemplate.opsForValue().set("dache:DRIVER_" + driver.getId(), s);


    


    


        LoginWarpper loginWarpper = new LoginWarpper();


@@ -1422,7 +1425,7 @@


        String s = JwtTokenUtil.generateToken(String.valueOf(driver.getId()));


        redisTemplate.opsForValue().set(s.substring(s.length() - 32), String.valueOf(driver.getId()), 7, TimeUnit.DAYS);


        redisTemplate.opsForValue().set(driver.getPhone(), s.substring(s.length() - 32));


        redisTemplate.opsForValue().set("DRIVER_" + driver.getId(), s);


        redisTemplate.opsForValue().set("dache:DRIVER_" + driver.getId(), s);


    


    


        LoginWarpper loginWarpper = new LoginWarpper();


@@ -1508,7 +1511,7 @@


        String s = JwtTokenUtil.generateToken(String.valueOf(driver.getId()));


        redisTemplate.opsForValue().set(s.substring(s.length() - 32), String.valueOf(driver.getId()), 7, TimeUnit.DAYS);


        redisTemplate.opsForValue().set(driver.getPhone(), s.substring(s.length() - 32));


        redisTemplate.opsForValue().set("DRIVER_" + driver.getId(), s);


        redisTemplate.opsForValue().set("dache:DRIVER_" + driver.getId(), s);


    


    


        LoginWarpper loginWarpper = new LoginWarpper();


@@ -1616,9 +1619,9 @@


        Driver driver = driverMapper.selectById(id);


        String key = (String) redisTemplate.opsForValue().get(driver.getPhone());


        redisTemplate.delete(key);//删除个人信息数据


        redisTemplate.delete("DRIVER_" + driver.getPhone());//删除后台冻结相关缓存


        redisTemplate.delete("DRIVER_" + id);//清除存储的token


        redisTemplate.delete("DEVICE_" + id);//清除车载端登录的标识


        redisTemplate.delete("dache:DRIVER_" + driver.getPhone());//删除后台冻结相关缓存


        redisTemplate.delete("dache:DRIVER_" + id);//清除存储的token


        redisTemplate.delete("dache:DEVICE_" + id);//清除车载端登录的标识


        return ResultUtil.success();


    }




@@ -1626,23 +1629,23 @@


    public DriverIndexVo queryHomeDataFromDriver(Integer uid) {


        DriverIndexVo driverIndexVo = new DriverIndexVo();


        // 获取快车订单


        List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().ne("state", 10).eq("driverId", uid).like("insertTime", LocalDateTime.now().toString()));


        List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().in("state", Arrays.asList(7, 8, 9)).eq("driverId", uid).like("insertTime", LocalDate.now().toString()));


        // 跨城订单


        List<OrderCrossCity> orderCrossCities = orderCrossCityMapper.selectList(new EntityWrapper<OrderCrossCity>().ne("state", 10).eq("driverId", uid).like("insertTime", LocalDateTime.now().toString()));


        List<OrderCrossCity> orderCrossCities = orderCrossCityMapper.selectList(new EntityWrapper<OrderCrossCity>().in("state", Arrays.asList(7, 8, 9)).eq("driverId", uid).like("insertTime", LocalDate.now().toString()));


        // 出租车订单


        List<OrderTaxi> orderTaxis = orderTaxiMapper.selectList(new EntityWrapper<OrderTaxi>().ne("state", 10).eq("driverId", uid).like("insertTime", LocalDateTime.now().toString()));


        List<OrderTaxi> orderTaxis = orderTaxiMapper.selectList(new EntityWrapper<OrderTaxi>().in("state", Arrays.asList(7, 8, 9)).eq("driverId", uid).like("insertTime", LocalDate.now().toString()));


        driverIndexVo.setTodayOrderNum(orderPrivateCars.size() + orderCrossCities.size() + orderTaxis.size());






        double sum = orderPrivateCars.stream().mapToDouble(OrderPrivateCar::getOrderMoney).sum();


        double sum1 = orderCrossCities.stream().mapToDouble(OrderCrossCity::getOrderMoney).sum();


        double sum2 = orderTaxis.stream().mapToDouble(OrderTaxi::getOrderMoney).sum();


        double sum2 = orderTaxis.stream().filter(e->e.getOrderMoney()!=null).mapToDouble(OrderTaxi::getOrderMoney).sum();


        driverIndexVo.setTodayOrderMoney(new BigDecimal(sum +sum1+sum2));






        BigDecimal reduce = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("promotionDriverId", uid).like("insertTime", LocalDateTime.now().toString())).stream().map(OrderPrivateCar::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal reduce1 = orderCrossCityMapper.selectList(new EntityWrapper<OrderCrossCity>().eq("promotionDriverId", uid).like("insertTime", LocalDateTime.now().toString())).stream().map(OrderCrossCity::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal reduce2 = orderTaxiMapper.selectList(new EntityWrapper<OrderTaxi>().eq("promotionDriverId", uid).like("insertTime", LocalDateTime.now().toString())).stream().map(OrderTaxi::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal reduce = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("promotionDriverId", uid).like("insertTime", LocalDate.now().toString())).stream().map(OrderPrivateCar::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal reduce1 = orderCrossCityMapper.selectList(new EntityWrapper<OrderCrossCity>().eq("promotionDriverId", uid).like("insertTime", LocalDate.now().toString())).stream().map(OrderCrossCity::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal reduce2 = orderTaxiMapper.selectList(new EntityWrapper<OrderTaxi>().eq("promotionDriverId", uid).like("insertTime", LocalDate.now().toString())).stream().map(OrderTaxi::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        driverIndexVo.setTodayPromotionMoney(reduce.add(reduce1).add(reduce2));


        return driverIndexVo;


    };


@@ -1661,9 +1664,9 @@


        List<OrderTaxi> orderTaxis = orderTaxiMapper.selectList(new EntityWrapper<OrderTaxi>().ne("state", 10).eq("driverId", uid));


        DriverOrderDataVo driverOrderDataVo = new DriverOrderDataVo();


        driverOrderDataVo.setAllOrderNum(orderPrivateCars.size() + orderCrossCities.size() + orderTaxis.size());


        long count = orderPrivateCars.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).count();


        long count1 = orderCrossCities.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).count();


        long count2 = orderTaxis.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).count();


        long count = orderPrivateCars.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).count();


        long count1 = orderCrossCities.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).count();


        long count2 = orderTaxis.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).count();


        driverOrderDataVo.setTodayOrderNum((int) (count+count1+count2));




        Date date = new Date();


@@ -1707,9 +1710,9 @@








        double count = orderPrivateCars.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).mapToDouble(OrderPrivateCar::getOrderMoney).sum();


        double count1 = orderCrossCities.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).mapToDouble(OrderCrossCity::getOrderMoney).sum();


        double count2 = orderTaxis.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).mapToDouble(OrderTaxi::getOrderMoney).sum();


        double count = orderPrivateCars.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).mapToDouble(OrderPrivateCar::getOrderMoney).sum();


        double count1 = orderCrossCities.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).mapToDouble(OrderCrossCity::getOrderMoney).sum();


        double count2 = orderTaxis.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).mapToDouble(OrderTaxi::getOrderMoney).sum();


        driverOrderDataVo.setTodayOrderMoney(new BigDecimal(count+count1+count2));






@@ -1754,9 +1757,9 @@








        BigDecimal count = orderPrivateCars.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).map(OrderPrivateCar::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal count1 = orderCrossCities.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).map(OrderCrossCity::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal count2 = orderTaxis.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDateTime.now().toString())).map(OrderTaxi::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal count = orderPrivateCars.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).map(OrderPrivateCar::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal count1 = orderCrossCities.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).map(OrderCrossCity::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal count2 = orderTaxis.stream().filter(e -> simpleDateFormat.format(e.getInsertTime()).equals(LocalDate.now().toString())).map(OrderTaxi::getPromotionMoney).reduce(BigDecimal.ZERO, BigDecimal::add);


        driverOrderDataVo.setTodayOrderMoney(count.add(count1).add(count2));






@@ -1791,16 +1794,16 @@


     */


    private void singlePointLogin(Integer id) {


        //开始验证当前账号是否在别处登录


        String value = (String) redisTemplate.opsForValue().get("DRIVER_" + id);


        String value = (String) redisTemplate.opsForValue().get("dache:DRIVER_" + id);


        if (ToolUtil.isNotEmpty(value)) {//将另外设备上的强迫下线（如果是车载端不需要下线）


            //开始清除redis中无效的数据


            Driver driver = driverMapper.selectById(id);


            String key = (String) redisTemplate.opsForValue().get("DRIVER_" + driver.getPhone());


            String key = (String) redisTemplate.opsForValue().get("dache:DRIVER_" + driver.getPhone());


            if(ToolUtil.isNotEmpty(key)){


                redisTemplate.delete(key);//删除个人信息数据


            }


            redisTemplate.delete("DRIVER_" + driver.getPhone());//删除后台冻结相关缓存


            redisTemplate.delete("DRIVER_" + id);//清除存储的token


            redisTemplate.delete("dache:DRIVER_" + driver.getPhone());//删除后台冻结相关缓存


            redisTemplate.delete("dache:DRIVER_" + id);//清除存储的token


        }


    }


    


@@ -1827,8 +1830,8 @@


                usernamePasswordToken, simpleAuthenticationInfo);


        String s = JwtTokenUtil.generateToken(String.valueOf(driver.getId()));


        redisTemplate.opsForValue().set(s.substring(s.length() - 32), String.valueOf(driver.getId()), 7, TimeUnit.DAYS);


        redisTemplate.opsForValue().set("DRIVER_" + driver.getPhone(), s.substring(s.length() - 32));


        redisTemplate.opsForValue().set("DRIVER_" + driver.getId(), s);


        redisTemplate.opsForValue().set("dache:DRIVER_" + driver.getPhone(), s.substring(s.length() - 32));


        redisTemplate.opsForValue().set("dache:DRIVER_" + driver.getId(), s);


        return s;


    }