| | |
|---|
| | | @Autowired |
|---|
| | | private PushUtil pushUtil; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private ITDriverWorkService driverWorkService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private ITDriverService driverService; |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | public void orderDetail(Integer orderId, Model model) { |
|---|
| | | // 订单信息 |
|---|
| | | TOrder tOrder = tOrderMapper.selectById(orderId); |
|---|
| | | model.addAttribute("id",orderId); |
|---|
| | | model.addAttribute("createTime",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(tOrder.getCreateTime()));//下单时间 |
|---|
| | | model.addAttribute("code",tOrder.getCode());//订单编号 |
|---|
| | | model.addAttribute("source",tOrder.getSource());//订单来源 |
|---|
| | |
|---|
| | | |
|---|
| | | // 查询用户 |
|---|
| | | TAppUser tAppUser = tAppUserMapper.selectById(tOrder.getUserId()); |
|---|
| | | model.addAttribute("userName",tAppUser.getNickname()); |
|---|
| | | model.addAttribute("userPhone",tAppUser.getPhone()); |
|---|
| | | model.addAttribute("havDiscount",tAppUser.getHavDiscount()); |
|---|
| | | if(1 == tAppUser.getHavDiscount()){ |
|---|
| | | // 计算9折优惠金额 |
|---|
| | | BigDecimal multiply = tOrder.getOrderMoney().multiply(new BigDecimal("0.1")).setScale(2); |
|---|
| | | model.addAttribute("multiply",multiply); |
|---|
| | | if(null != tAppUser){ |
|---|
| | | model.addAttribute("userName",tAppUser.getNickname()); |
|---|
| | | model.addAttribute("userPhone",tAppUser.getPhone()); |
|---|
| | | model.addAttribute("havDiscount",tAppUser.getHavDiscount()); |
|---|
| | | if(1 == tAppUser.getHavDiscount()){ |
|---|
| | | // 计算9折优惠金额 |
|---|
| | | BigDecimal multiply = tOrder.getOrderMoney().multiply(new BigDecimal("0.1")).setScale(2); |
|---|
| | | model.addAttribute("multiply",multiply); |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | model.addAttribute("userName",tOrder.getUserName()); |
|---|
| | | model.addAttribute("userPhone",tOrder.getUserPhone()); |
|---|
| | | model.addAttribute("havDiscount", 0); |
|---|
| | | model.addAttribute("multiply",0D); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 查询司机 |
|---|
| | |
|---|
| | | .where("'" + geocode.getCity() + "' like CONCAT('%', city, '%') and '" + geocode.getDistrict() + "' like CONCAT('%', district, '%') ")); |
|---|
| | | city = null != weatherCity ? weatherCity.getId().toString() : ""; |
|---|
| | | } |
|---|
| | | tOrder.setCreateTime(new Date()); |
|---|
| | | tOrder = getOrderPrice(1, d, 0, tOrder, city); |
|---|
| | | tOrder.setState(101); |
|---|
| | | tOrder.setStatus(1); |
|---|
| | | tOrder.setCreateTime(new Date()); |
|---|
| | | this.insert(tOrder); |
|---|
| | | //推送状态 |
|---|
| | | pushOrder(tOrder); |
|---|
| | |
|---|
| | | JSONObject jsonObject = JSON.parseObject(systemConfig.getContent()); |
|---|
| | | JSONArray chargeStandard = jsonObject.getJSONArray("ChargeStandard"); |
|---|
| | | JSONObject extraCost = jsonObject.getJSONObject("ExtraCost"); |
|---|
| | | Date date = new Date(); |
|---|
| | | Date date = order.getCreateTime(); |
|---|
| | | |
|---|
| | | boolean b = true; |
|---|
| | | for (int i = 1; i < chargeStandard.size(); i++) {//各种时间段 |
|---|
| | |
|---|
| | | Double num8 = jsonObject1.getDouble("num8");//超过num8每num10公里收取num11 |
|---|
| | | |
|---|
| | | String[] split = num1.split(":"); |
|---|
| | | Integer hour1 = Integer.valueOf(split[0]); |
|---|
| | | Calendar s = Calendar.getInstance(); |
|---|
| | | s.setTime(date); |
|---|
| | | s.set(Calendar.HOUR_OF_DAY, Integer.valueOf(split[0])); |
|---|
| | | s.set(Calendar.HOUR_OF_DAY, hour1); |
|---|
| | | s.set(Calendar.MINUTE, Integer.valueOf(split[1])); |
|---|
| | | s.set(Calendar.SECOND, 0); |
|---|
| | | |
|---|
| | | split = num2.split(":"); |
|---|
| | | Integer hour2 = Integer.valueOf(split[0]); |
|---|
| | | Calendar e = Calendar.getInstance(); |
|---|
| | | e.setTime(date); |
|---|
| | | e.set(Calendar.HOUR_OF_DAY, Integer.valueOf(split[0])); |
|---|
| | | e.set(Calendar.HOUR_OF_DAY, hour2); |
|---|
| | | e.set(Calendar.MINUTE, Integer.valueOf(split[1])); |
|---|
| | | e.set(Calendar.SECOND, 0); |
|---|
| | | |
|---|
| | | if(hour1 > hour2){ |
|---|
| | | if(s.getTimeInMillis() > date.getTime()){ |
|---|
| | | s.set(Calendar.DAY_OF_YEAR, s.get(Calendar.DAY_OF_YEAR) - 1); |
|---|
| | | }else{ |
|---|
| | | e.set(Calendar.DAY_OF_YEAR, e.get(Calendar.DAY_OF_YEAR) + 1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(date.getTime() >= s.getTimeInMillis() && date.getTime() < e.getTimeInMillis()){ |
|---|
| | | b = false; |
|---|
| | |
|---|
| | | * 合适司：积分 > 评分 > 距离 |
|---|
| | | * 3.司机没有接单直接将订单置入大厅 |
|---|
| | | */ |
|---|
| | | TSystemConfig systemConfig = systemConfigService.selectOne(new EntityWrapper<TSystemConfig>().eq("type", 1)); |
|---|
| | | if(null == systemConfig){ |
|---|
| | | return; |
|---|
| | | try { |
|---|
| | | boolean lock = redisUtil.lock(5); |
|---|
| | | if(!lock){ |
|---|
| | | int num1 = 1; |
|---|
| | | while (num1 <= 10){ |
|---|
| | | Thread.sleep(3000);//等待3秒 |
|---|
| | | lock = redisUtil.lock(5); |
|---|
| | | if(lock){ |
|---|
| | | break; |
|---|
| | | }else{ |
|---|
| | | num1++; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if(!lock){ |
|---|
| | | redisUtil.unlock(); |
|---|
| | | order.setHallOrder(1); |
|---|
| | | this.updateById(order); |
|---|
| | | ExtraPushOrder(order); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | TSystemConfig systemConfig = systemConfigService.selectOne(new EntityWrapper<TSystemConfig>().eq("type", 1)); |
|---|
| | | if(null == systemConfig){ |
|---|
| | | redisUtil.unlock(); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | JSONObject jsonObject = JSON.parseObject(systemConfig.getContent()); |
|---|
| | | Double num3 = jsonObject.getDouble("num3");//推单最大范围 |
|---|
| | | Integer num4 = jsonObject.getInteger("num4");//接单时间 |
|---|
| | | String startLat = order.getStartLat(); |
|---|
| | | String startLng = order.getStartLng(); |
|---|
| | | |
|---|
| | | //1 |
|---|
| | | //找到中心点 |
|---|
| | | GeoJsonPoint geoJsonPoint = new GeoJsonPoint(Double.valueOf(startLng), Double.valueOf(startLat)); |
|---|
| | | Double num = num3 / 1000;//范围公里 |
|---|
| | | //构造半径 |
|---|
| | | Distance distanceR = new Distance(num, Metrics.KILOMETERS); |
|---|
| | | //画圆 |
|---|
| | | Circle circle = new Circle(geoJsonPoint, distanceR); |
|---|
| | | // 构造query对象 |
|---|
| | | Query query = Query.query(Criteria.where("location").withinSphere(circle)); |
|---|
| | | List<Location> locations = mongoTemplate.find(query, Location.class); |
|---|
| | | List<Integer> driverIds = locations.stream().map(Location::getDriverId).collect(Collectors.toList()); |
|---|
| | | Integer driver = null; |
|---|
| | | TYouTuiDriver youTuiDriver1 = null; |
|---|
| | | if(driverIds.size() > 0){ |
|---|
| | | List<TYouTuiDriver> youTuiDrivers = youTuiDriverService.selectList(new EntityWrapper<TYouTuiDriver>().in("driverId", driverIds) |
|---|
| | | .eq("state", 2).last(" and (surplusQuantity > 0 or now() < endTime) and now() < failureTime")); |
|---|
| | | Double d = null; |
|---|
| | | for (TYouTuiDriver youTuiDriver : youTuiDrivers) { |
|---|
| | | String value = redisUtil.getValue("DRIVER" + youTuiDriver.getDriverId()); |
|---|
| | | if(ToolUtil.isEmpty(value)){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | TDriver driver1 = driverService.selectById(youTuiDriver.getDriverId()); |
|---|
| | | if(driver1.getServerStatus() == 2 || driver1.getOpenOrderQRCode() == 1){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | TDriverWork driverWork = driverWorkService.selectOne(new EntityWrapper<TDriverWork>().eq("driverId", driver1.getId()).eq("status", 1)); |
|---|
| | | if(null == driverWork){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | Map<String, Double> distance = GeodesyUtil.getDistance(value, order.getStartLng() + "," + order.getStartLat()); |
|---|
| | | Double wgs84 = distance.get("WGS84"); |
|---|
| | | if(d == null || d.compareTo(wgs84) > 0){ |
|---|
| | | d = wgs84; |
|---|
| | | driver = youTuiDriver.getDriverId(); |
|---|
| | | youTuiDriver1 = youTuiDriver; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(null != youTuiDriver1 && youTuiDriver1.getType() == 1){ |
|---|
| | | youTuiDriver1.setSurplusQuantity(youTuiDriver1.getSurplusQuantity() - 1); |
|---|
| | | youTuiDriverService.updateById(youTuiDriver1); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //开始范围查找 |
|---|
| | | if(null == driver){ |
|---|
| | | for (int i = 1; i < 4; i++) { |
|---|
| | | if(null != driver){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | num = jsonObject.getDouble("num" + i) / 1000;//范围公里 |
|---|
| | | //构造半径 |
|---|
| | | distanceR = new Distance(num, Metrics.KILOMETERS); |
|---|
| | | //画圆 |
|---|
| | | circle = new Circle(geoJsonPoint, distanceR); |
|---|
| | | // 构造query对象 |
|---|
| | | query = Query.query(Criteria.where("location").withinSphere(circle)); |
|---|
| | | locations = mongoTemplate.find(query, Location.class); |
|---|
| | | |
|---|
| | | driverIds = locations.stream().map(Location::getDriverId).collect(Collectors.toList()); |
|---|
| | | if(driverIds.size() > 0){ |
|---|
| | | List<TDriver> drivers = driverService.selectList(new EntityWrapper<TDriver>().eq("approvalStatus", 2) |
|---|
| | | .eq("serverStatus", 1).eq("openOrderQRCode", 0).eq("status", 1).in("id", driverIds)); |
|---|
| | | if(drivers.size() == 0){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | Integer integral = null; |
|---|
| | | Double score = null; |
|---|
| | | Double d = null; |
|---|
| | | for (TDriver driver1 : drivers) { |
|---|
| | | String value = redisUtil.getValue("DRIVER" + driver1.getId()); |
|---|
| | | if(ToolUtil.isEmpty(value)){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | TDriverWork driverWork = driverWorkService.selectOne(new EntityWrapper<TDriverWork>().eq("driverId", driver1.getId()).eq("status", 1)); |
|---|
| | | if(null == driverWork){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(integral == null || integral.compareTo(driver1.getIntegral()) < 0){//积分大 |
|---|
| | | integral = driver1.getIntegral(); |
|---|
| | | score = driver1.getScore(); |
|---|
| | | driver = driver1.getId(); |
|---|
| | | Map<String, Double> distance = GeodesyUtil.getDistance(value, order.getStartLng() + "," + order.getStartLat()); |
|---|
| | | Double wgs84 = distance.get("WGS84"); |
|---|
| | | d = wgs84; |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if(integral.compareTo(driver1.getIntegral()) == 0 && score.compareTo(driver1.getScore()) < 0){//积分相同对比评分 |
|---|
| | | integral = driver1.getIntegral(); |
|---|
| | | score = driver1.getScore(); |
|---|
| | | driver = driver1.getId(); |
|---|
| | | Map<String, Double> distance = GeodesyUtil.getDistance(value, order.getStartLng() + "," + order.getStartLat()); |
|---|
| | | Double wgs84 = distance.get("WGS84"); |
|---|
| | | d = wgs84; |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if(integral.compareTo(driver1.getIntegral()) == 0 && score.compareTo(driver1.getScore()) == 0){//积分相同/评分相同对比距离 |
|---|
| | | Map<String, Double> distance = GeodesyUtil.getDistance(value, order.getStartLng() + "," + order.getStartLat()); |
|---|
| | | Double wgs84 = distance.get("WGS84"); |
|---|
| | | if(d.compareTo(wgs84) > 0){ |
|---|
| | | d = wgs84; |
|---|
| | | integral = driver1.getIntegral(); |
|---|
| | | score = driver1.getScore(); |
|---|
| | | driver = driver1.getId(); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(null != driver){ |
|---|
| | | TDriver tDriver = driverService.selectById(driver); |
|---|
| | | tDriver.setServerStatus(2); |
|---|
| | | driverService.updateById(tDriver); |
|---|
| | | |
|---|
| | | pushUtil.pushGrabOrder(driver, 2, order.getId(), num4); |
|---|
| | | //创建定时任务处理订单到大厅 |
|---|
| | | new Timer().schedule(new TimerTask() { |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | TOrder order1 = TOrderServiceImpl.this.selectById(order.getId()); |
|---|
| | | if(order1.getState() == 101 || order1.getState() == 201){ |
|---|
| | | tDriver.setServerStatus(1); |
|---|
| | | driverService.updateById(tDriver); |
|---|
| | | |
|---|
| | | order1.setHallOrder(1); |
|---|
| | | TOrderServiceImpl.this.updateById(order1); |
|---|
| | | |
|---|
| | | ExtraPushOrder(order1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }, num4 * 1000); |
|---|
| | | }else{ |
|---|
| | | order.setHallOrder(1); |
|---|
| | | this.updateById(order); |
|---|
| | | ExtraPushOrder(order); |
|---|
| | | } |
|---|
| | | redisUtil.unlock(); |
|---|
| | | }catch (Exception e){ |
|---|
| | | redisUtil.unlock(); |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | JSONObject jsonObject = JSON.parseObject(systemConfig.getContent()); |
|---|
| | | Double num3 = jsonObject.getDouble("num3");//推单最大范围 |
|---|
| | | Integer num4 = jsonObject.getInteger("num4");//接单时间 |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void ExtraPushOrder(TOrder order){ |
|---|
| | | String startLat = order.getStartLat(); |
|---|
| | | String startLng = order.getStartLng(); |
|---|
| | | |
|---|
| | | //1 |
|---|
| | | //找到中心点 |
|---|
| | | GeoJsonPoint geoJsonPoint = new GeoJsonPoint(Double.valueOf(startLng), Double.valueOf(startLat)); |
|---|
| | | Double num = num3 / 1000;//范围公里 |
|---|
| | | Double num = 5D;//范围公里 |
|---|
| | | //构造半径 |
|---|
| | | Distance distanceR = new Distance(num, Metrics.KILOMETERS); |
|---|
| | | //画圆 |
|---|
| | |
|---|
| | | Query query = Query.query(Criteria.where("location").withinSphere(circle)); |
|---|
| | | List<Location> locations = mongoTemplate.find(query, Location.class); |
|---|
| | | List<Integer> driverIds = locations.stream().map(Location::getDriverId).collect(Collectors.toList()); |
|---|
| | | Integer driver = null; |
|---|
| | | TYouTuiDriver youTuiDriver1 = null; |
|---|
| | | if(driverIds.size() > 0){ |
|---|
| | | List<TYouTuiDriver> youTuiDrivers = youTuiDriverService.selectList(new EntityWrapper<TYouTuiDriver>().in("driverId", driverIds) |
|---|
| | | .eq("state", 2).last(" and (surplusQuantity > 0 or now() < endTime) and now() < failureTime")); |
|---|
| | | Double d = null; |
|---|
| | | for (TYouTuiDriver youTuiDriver : youTuiDrivers) { |
|---|
| | | String value = redisUtil.getValue("DRIVER" + youTuiDriver.getDriverId()); |
|---|
| | | if(ToolUtil.isEmpty(value)){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | Map<String, Double> distance = GeodesyUtil.getDistance(value, order.getStartLng() + "," + order.getStartLat()); |
|---|
| | | Double wgs84 = distance.get("WGS84"); |
|---|
| | | if(d == null || d.compareTo(wgs84) > 0){ |
|---|
| | | d = wgs84; |
|---|
| | | driver = youTuiDriver.getDriverId(); |
|---|
| | | youTuiDriver1 = youTuiDriver; |
|---|
| | | } |
|---|
| | | if(driverIds.size() == 0){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | List<TDriverWork> tDriverWorks = driverWorkService.selectList(new EntityWrapper<TDriverWork>().in("driverId", driverIds).eq("status", 1)); |
|---|
| | | driverIds = tDriverWorks.stream().map(TDriverWork::getDriverId).collect(Collectors.toList()); |
|---|
| | | List<TDriver> drivers = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("approvalStatus", 2) |
|---|
| | | .eq("serverStatus", 1).eq("openOrderQRCode", 0).eq("status", 1).in("id", driverIds)); |
|---|
| | | if(drivers.size() == 0){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | for (TDriver driver1 : drivers) { |
|---|
| | | String value = redisUtil.getValue("DRIVER" + driver1.getId()); |
|---|
| | | if (ToolUtil.isEmpty(value)) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(null != youTuiDriver1 && youTuiDriver1.getType() == 1){ |
|---|
| | | youTuiDriver1.setSurplusQuantity(youTuiDriver1.getSurplusQuantity() - 1); |
|---|
| | | youTuiDriverService.updateById(youTuiDriver1); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //开始范围查找 |
|---|
| | | if(null == driver){ |
|---|
| | | for (int i = 1; i < 4; i++) { |
|---|
| | | if(null != driver){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | num = jsonObject.getDouble("num" + i) / 1000;//范围公里 |
|---|
| | | //构造半径 |
|---|
| | | distanceR = new Distance(num, Metrics.KILOMETERS); |
|---|
| | | //画圆 |
|---|
| | | circle = new Circle(geoJsonPoint, distanceR); |
|---|
| | | // 构造query对象 |
|---|
| | | query = Query.query(Criteria.where("location").withinSphere(circle)); |
|---|
| | | locations = mongoTemplate.find(query, Location.class); |
|---|
| | | |
|---|
| | | driverIds = locations.stream().map(Location::getDriverId).collect(Collectors.toList()); |
|---|
| | | if(driverIds.size() > 0){ |
|---|
| | | List<TDriver> drivers = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("approvalStatus", 2).eq("serverStatus", 1).eq("status", 1).in("id", driverIds)); |
|---|
| | | if(drivers.size() == 0){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | Integer integral = null; |
|---|
| | | Double score = null; |
|---|
| | | Double d = null; |
|---|
| | | for (TDriver driver1 : drivers) { |
|---|
| | | if(integral == null || integral.compareTo(driver1.getIntegral()) < 0){//积分大 |
|---|
| | | integral = driver1.getIntegral(); |
|---|
| | | score = driver1.getScore(); |
|---|
| | | driver = driver1.getId(); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if(integral.compareTo(driver1.getIntegral()) == 0 && score.compareTo(driver1.getScore()) < 0){//积分相同对比评分 |
|---|
| | | integral = driver1.getIntegral(); |
|---|
| | | score = driver1.getScore(); |
|---|
| | | driver = driver1.getId(); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if(integral.compareTo(driver1.getIntegral()) == 0 && score.compareTo(driver1.getScore()) == 0){//积分相同/评分相同对比距离 |
|---|
| | | String value = redisUtil.getValue("DRIVER" + driver1.getId()); |
|---|
| | | if(ToolUtil.isEmpty(value)){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | Map<String, Double> distance = GeodesyUtil.getDistance(value, order.getStartLng() + "," + order.getStartLat()); |
|---|
| | | Double wgs84 = distance.get("WGS84"); |
|---|
| | | if(d == null || d.compareTo(wgs84) > 0){ |
|---|
| | | d = wgs84; |
|---|
| | | driver = driver1.getId(); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(null != driver){ |
|---|
| | | pushUtil.pushGrabOrder(driver, 2, order.getId(), num4); |
|---|
| | | //创建定时任务处理订单到大厅 |
|---|
| | | new Timer().schedule(new TimerTask() { |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | TOrder order1 = TOrderServiceImpl.this.selectById(order.getId()); |
|---|
| | | if(order1.getState() == 101 || order1.getState() == 201){ |
|---|
| | | order1.setHallOrder(1); |
|---|
| | | TOrderServiceImpl.this.updateById(order1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }, num4 * 1000); |
|---|
| | | }else{ |
|---|
| | | order.setHallOrder(1); |
|---|
| | | this.updateById(order); |
|---|
| | | pushUtil.pushGrabOrderExtras(driver1.getId(), 2); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
