| | |
| | | |
| | | if (orderTaxi.getTravelTime().getTime() > (System.currentTimeMillis() + 600000)) { |
| | | orderTaxi.setOrderType(2); |
| | | } else { |
| | | orderTaxi.setOrderType(1); |
| | | } |
| | | |
| | | |
| | |
| | | } |
| | | orderTaxiMapper.updateById(orderTaxi1); |
| | | |
| | | try { |
| | | if (orderTaxi.getType() == 2) { |
| | | List<OrderTaxi> list = orderTaxiMapper.selectList( |
| | | new EntityWrapper<OrderTaxi>() |
| | | .eq("type", 2) |
| | | .eq("userId", orderTaxi.getUserId()) |
| | | .ne("state", 1) |
| | | .eq("crossCityOrderId", orderTaxi.getCrossCityOrderId()) |
| | | .eq("place", orderTaxi.getPlace()).ne("id", orderTaxi.getId()) |
| | | ); |
| | | List<OrderPrivateCar> list1 = orderPrivateCarService.selectList( |
| | | new EntityWrapper<OrderPrivateCar>() |
| | | .eq("type", 2) |
| | | .eq("userId", orderTaxi.getUserId()) |
| | | .ne("state", 1) |
| | | .eq("crossCityOrderId", orderTaxi.getCrossCityOrderId()) |
| | | .eq("place", orderTaxi.getPlace()) |
| | | ); |
| | | for (OrderTaxi orderTaxi2 : list) { |
| | | orderTaxi2.setState(10); |
| | | orderTaxiMapper.updateById(orderTaxi2); |
| | | } |
| | | for (OrderPrivateCar orderPrivateCar : list1) { |
| | | orderPrivateCar.setState(10); |
| | | orderPrivateCarService.updateById(orderPrivateCar); |
| | | } |
| | | } |
| | | } catch (Exception ignore) { |
| | | |
| | | if(orderTaxi.getType() == 2){ |
| | | List<OrderTaxi> list = orderTaxiMapper.selectList( |
| | | new EntityWrapper<OrderTaxi>() |
| | | .eq("type", 2) |
| | | .eq("userId", orderTaxi.getUserId()) |
| | | .ne("state", 1) |
| | | .eq("crossCityOrderId", orderTaxi.getCrossCityOrderId()) |
| | | .eq("place", orderTaxi.getPlace()).ne("id", orderTaxi.getId()) |
| | | ); |
| | | List<OrderPrivateCar> list1 = orderPrivateCarService.selectList( |
| | | new EntityWrapper<OrderPrivateCar>() |
| | | .eq("type", 2) |
| | | .eq("userId", orderTaxi.getUserId()) |
| | | .ne("state", 1) |
| | | .eq("crossCityOrderId", orderTaxi.getCrossCityOrderId()) |
| | | .eq("place", orderTaxi.getPlace()) |
| | | ); |
| | | for(OrderTaxi orderTaxi2 : list){ |
| | | orderTaxi2.setState(10); |
| | | orderTaxiMapper.updateById(orderTaxi2); |
| | | } |
| | | for(OrderPrivateCar orderPrivateCar : list1){ |
| | | orderPrivateCar.setState(10); |
| | | orderPrivateCarService.updateById(orderPrivateCar); |
| | | } |
| | | } |
| | | |
| | | OrderTaxi finalOrderTaxi = orderTaxi1; |
| | | |
| | | //如果是预约单,则不修改司机为服务中 |
| | | if(orderTaxi1.getOrderType() != 2 || (orderTaxi1.getOrderType() == 2 && orderTaxi1.getTravelTime().getTime() < System.currentTimeMillis() + 600000)){ |
| | |
| | | driver1.setState(3); |
| | | driverService.updateById(driver1); |
| | | } |
| | | |
| | | System.err.println("---获取单子信息---" + orderTaxi1); |
| | | //推送相关代码-----------------start---------------- |
| | | OrderTaxi finalOrderTaxi = orderTaxi1; |
| | | new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | System.err.println("----------------------------------推送开始----------------------------"); |
| | | pushUtil.pushOrderState(1, finalOrderTaxi.getUserId(), finalOrderTaxi.getId(), 2, finalOrderTaxi.getState(),0); |
| | | pushUtil.pushOrderState(2, finalOrderTaxi.getDriverId(), finalOrderTaxi.getId(), 2, finalOrderTaxi.getState(),0); |
| | | pushUtil.pushOrderState(2, orderTaxi1.getDriverId(), orderTaxi1.getId(), 2, orderTaxi1.getState(), 0); |
| | | if(finalOrderTaxi.getType() == 2){ |
| | | pushUtil.pushFerryOrderState(1, finalOrderTaxi.getUserId(), finalOrderTaxi.getId(), 2, 2); |
| | | System.err.println("----------------------------------推送结束----------------------------"); |