java/QianYunTong.git

			@@ -17,6 +17,7 @@
			import com.stylefeng.guns.modular.specialTrain.server.IOrderPrivateCarService;
			import com.stylefeng.guns.modular.system.dao.*;
			import com.stylefeng.guns.modular.system.model.*;
			import com.stylefeng.guns.modular.system.model.vo.UnPayOrderVO;
			import com.stylefeng.guns.modular.system.service.*;
			import com.stylefeng.guns.modular.system.util.*;
			import com.stylefeng.guns.modular.system.warpper.*;
			@@ -26,6 +27,7 @@
			import com.stylefeng.guns.modular.taxi.service.IOrderTaxiService;
			import com.stylefeng.guns.modular.taxi.service.IPaymentRecordService;
			import com.stylefeng.guns.modular.taxi.service.ITransactionDetailsService;
			import org.springframework.beans.BeanUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.data.redis.core.RedisTemplate;
			@@ -45,6 +47,7 @@
			import java.math.RoundingMode;
			import java.text.SimpleDateFormat;
			import java.util.*;
			import java.util.concurrent.TimeUnit;
			import java.util.concurrent.locks.Lock;
			import java.util.concurrent.locks.ReentrantLock;
			import java.util.stream.Collectors;
			@@ -52,2639 +55,2723 @@

			@Service
			public class OrderPrivateCarServiceImpl extends ServiceImpl<OrderPrivateCarMapper, OrderPrivateCar> implements IOrderPrivateCarService {

			public static List<Integer> orderIds = new ArrayList<>();
			@Resource
			private OrderPrivateCarMapper orderPrivateCarMapper;
			@Resource
			private CarServiceMapper carServiceMapper;
			@Resource
			private OrderTaxiMapper orderTaxiMapper;
			@Resource
			private SensitiveWordsMapper sensitiveWordsMapper;
			@Resource
			private UserActivityDiscount1Mapper userActivityDiscount1Mapper;
			@Resource
			private SysIntegralMapper sysIntegralMapper;
			@Resource
			private OrderCrossCityMapper orderCrossCityMapper;
			@Resource
			private RegionMapper regionMapper;
			@Autowired
			private DateUtil dateUtil;
			@Autowired
			private IUserInfoService userInfoService;
			@Autowired
			private IDriverService driverService;
			@Autowired
			private IDriverServiceService driverServiceService;
			@Autowired
			private PushUtil pushUtil;
			@Autowired
			private ICompanyCityService companyCityService;
			@Autowired
			private IPushOrderService pushOrderService;
			@Autowired
			private ISystemNoticeService systemNoticeService;
			@Autowired
			private ICancleOrderService cancleOrderService;
			@Autowired
			private IOrderCancelService orderCancelService;
			@Autowired
			private RestTemplate internalRestTemplate;
			@Autowired
			private IPaymentRecordService paymentRecordService;
			@Autowired
			private ITransactionDetailsService transactionDetailsService;
			@Autowired
			private ChinaMobileUtil chinaMobileUtil;
			@Autowired
			private IIncomeService incomeService;
			@Autowired
			private IUserCouponRecordService userCouponRecordService;
			@Autowired
			private IUserRedPacketRecordService userRedPacketRecordService;
			@Autowired
			private ICompanyService companyService;
			@Autowired
			private IUserActivityRedenvelopeService userActivityRedenvelopeService;
			@Resource
			private RedisTemplate<String, Object> redisTemplate;
			@Autowired
			private GDFalconUtil gdFalconUtil;
			@Autowired
			private GDMapGeocodingUtil gdMapGeocodingUtil;
			@Autowired
			private GDMapElectricFenceUtil gdMapElectricFenceUtil;
			@Autowired
			private IOrderPositionService orderPositionService;
			@Autowired
			private PushMinistryOfTransportUtil pushMinistryOfTransportUtil;
			@Autowired
			private IOrderCrossCityService orderCrossCityService;
			@Autowired
			private IOrderTaxiService orderTaxiService;
			@Autowired
			private PayMoneyUtil payMoneyUtil;
			@Autowired
			private TAbnormalPayOrderMapper abnormalPayOrderMapper;
			@Autowired
			private ITaxiCardPaymentService taxiCardPaymentService;
			@Autowired
			private ITaxiCardService taxiCardService;
			@Autowired
			private IOpenCityService openCityService;
			@Autowired
			private IUserUserService userUserService;
			@Autowired
			private IUserTaxiCardService userTaxiCardService;
			@Autowired
			private IRegionService regionService;
			@Value("${callbackPath}")
			private String callbackPath;

			@Value("${pushMinistryOfTransport}")
			private boolean pushMinistryOfTransport;

			@Autowired
			private ITbSpellOrderRuleService spellOrderRuleService;

			@Autowired
			private GeodesyUtil geodesyUtil;

			private Lock lock = new ReentrantLock();
			@Autowired
			private AppOrderController appOrderController;

			@Resource
			private OrderPrivateCarMapper orderPrivateCarMapper;
			@Autowired
			private TDriverPromotionActivityService driverPromotionActivityService;

			/**
			* 专车下单操作
			*
			* @param serverCarModelId 服务车型id
			* @param travelTime 出行时间
			* @param reservation 是否预约（1=否，2=是）
			* @param instead 是否代下单（0=否，1=是）
			* @param startLon 起点经度
			* @param startLat 起点纬度
			* @param startAddress 起点详细地址
			* @param endLon 终点经度
			* @param endLat 终点纬度
			* @param endAddress 终点详细地址
			* @param name 乘客姓名
			* @param phone 乘客电话
			* @return
			* @throws Exception
			*/
			@Override
			public synchronized ResultUtil<BaseWarpper> saveOrderPrivateCar(Integer serverCarModelId, Date travelTime, Integer reservation, Integer instead, String placementLon, String placementLat, String startLon, String startLat,
			String startAddress, String endLon, String endLat, String endAddress, String name, String phone, Integer orderSource, Integer driverId, Integer type, Integer uid, Integer peopleNum, Integer rideType) throws Exception {
			BaseWarpper baseWarpper = new BaseWarpper();
			if (lock.tryLock()) {
			try {
			//如果出行时间大于当前10分钟则默认为预约单
			if (travelTime.getTime() > (System.currentTimeMillis() + 600000)) {
			reservation = 2;
			}
			/**
			* 1.出租车、专车、跨城有待支付的订单不能叫车
			* 2.小件物流有未完成的订单可以下跨城、专车、出租车
			* 3.出租车、专车、跨城有预约单可以下即时单
			*/
			List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
			if (orderPrivateCars.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
			if (list.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
			if (orderCrossCities1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			if (reservation == 1) {
			orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if (orderPrivateCars.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if (list.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			}

			List<OrderPrivateCar> orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, null, 3, 7, 12);
			if (orderPrivateCars1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderTaxi> list1 = orderTaxiMapper.queryByState_(uid, null, 3, 7, 12);
			if (list1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderCrossCity> orderCrossCities11 = orderCrossCityMapper.queryByState(uid, 7, 12);
			if (orderCrossCities11.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			if (reservation == 1) {
			orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if (orderPrivateCars1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			list1 = orderTaxiMapper.queryByState_(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if (list1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			}


			startAddress = startAddress.replaceAll("& #40;", "(");
			startAddress = startAddress.replaceAll("& #41;", ")");
			endAddress = endAddress.replaceAll("& #40;", "(");
			endAddress = endAddress.replaceAll("& #41;", ")");
			if ((orderSource == 1 \|\| orderSource == 3) && null == serverCarModelId) {
			return ResultUtil.error("请选择服务车型");
			}

			OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
			orderPrivateCar.setPeopleNum(peopleNum);
			orderPrivateCar.setRideType(rideType);
			orderPrivateCar.setType(type);
			orderPrivateCar.setUserId(uid);
			orderPrivateCar.setServerCarModelId(serverCarModelId);
			orderPrivateCar.setOrderNum(this.getOrderNum());
			orderPrivateCar.setPlacementLon(Double.valueOf(placementLon));
			orderPrivateCar.setPlacementLat(Double.valueOf(placementLat));
			Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
			orderPrivateCar.setPlacementAddress(geocode.get("address"));
			orderPrivateCar.setStartLon(Double.valueOf(startLon));
			orderPrivateCar.setStartLat(Double.valueOf(startLat));
			orderPrivateCar.setStartAddress(startAddress);
			orderPrivateCar.setEndLon(Double.valueOf(endLon));
			orderPrivateCar.setEndLat(Double.valueOf(endLat));
			orderPrivateCar.setEndAddress(endAddress);
			orderPrivateCar.setSubstitute(instead);
			orderPrivateCar.setPassengers(name);
			orderPrivateCar.setPassengersPhone(phone);
			// TODO: 2023/11/4 无法修改
			Map<String, String> distanceMap = gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
			orderPrivateCar.setEstimateMileage(Double.valueOf(distanceMap.get("distance")));
			orderPrivateCar.setEstimateTime(Double.valueOf(distanceMap.get("duration")) / 60);
			if (instead == 0 \|\| ToolUtil.isEmpty(orderPrivateCar.getPassengers())) {
			UserInfo userInfo = userInfoService.selectById(uid);
			if (ToolUtil.isEmpty(userInfo.getPhone())) {
			return ResultUtil.error("请先绑定手机号码");
			}
			orderPrivateCar.setPassengers(userInfo.getName());
			orderPrivateCar.setPassengersPhone(userInfo.getPhone());
			}
			orderPrivateCar.setState(1);
			orderPrivateCar.setInsertTime(new Date());
			orderPrivateCar.setTravelTime(travelTime);
			orderPrivateCar.setOrderType(reservation);
			orderPrivateCar.setOrderSource(orderSource);
			if (orderSource == 2) {//扫码下单
			Driver driver = driverService.selectById(driverId);
			if (null == driver) {
			return ResultUtil.error("司机信息有误，无法完成下单");
			}
			if (driver.getAuthState() == 1) {
			return ResultUtil.error("司机信息还未完成审核，无法完成下单");
			}
			if (driver.getAuthState() == 3) {
			return ResultUtil.error("司机账户已被冻结，无法提供服务");
			}
			if (driver.getAuthState() == 4) {
			return ResultUtil.error("司机信息未通过审核，无法提供服务");
			}
			if (driver.getState() == 1) {
			return ResultUtil.error("司机还未上线，无法提供服务");
			}
			if (driver.getState() == 3) {
			return ResultUtil.error("司机正在服务中，无法提供服务");
			}
			// Integer orderType = orderPrivateCar.getRideType()==1?1:orderPrivateCar.getRideType()==2?9:8;
			Integer orderType = 1;
			Integer integer = driverServiceService.query_(driverId, orderType);
			if (null == integer) {
			return ResultUtil.error("该司机不能服务此业务");
			}

			orderPrivateCar.setDriverId(driverId);
			orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
			driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
			orderPrivateCar.setState(2);
			orderPrivateCar.setCarId(driver.getCarId());
			CarService query1 = carServiceMapper.query(1, driver.getCarId());
			orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
			orderPrivateCar.setSnatchOrderTime(new Date());

			// //调用高德创建轨迹
			// String s = gdFalconUtil.selectTerminal(driver.getPhone());
			// String track = gdFalconUtil.createTrack(s);
			// orderPrivateCar.setTrackId(track);
			//
			//调用移动的小号接口
			// Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
			// if (String.valueOf(map.get("code")).equals("200")) {
			// orderPrivateCar.setTelX(map.get("telX"));
			// orderPrivateCar.setBindId(map.get("bindId"));
			// }

			driver.setState(3);
			driverService.updateById(driver);
			}
			//判断独享，一口价，拼车
			if (orderPrivateCar.getRideType() != 3) {
			orderPrivateCar.setTotalPeopleNum(peopleNum);
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			this.insert(orderPrivateCar);

			if (orderSource == 2) {//扫码下单
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
			}
			}).start();
			}

			//推单操作-独享
			if (orderPrivateCar.getState() == 1) {
			this.pushOrder(orderPrivateCar);
			}
			} else {
			OrderPrivateCar orderPrivateCar1 = null;
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			//判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
			List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).in("state", "2,3,4").le("totalPeopleNum", 4 - peopleNum));
			for (OrderPrivateCar order : orderList) {

			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
			if (spellOrderRule != null) {
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间

			if (travelTime.getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && travelTime.getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if (dis1 <= jsonObject.getInteger("num1") * 1000 && dis2 <= jsonObject.getInteger("num2") * 1000) {
			orderPrivateCar1 = order;
			break;
			}
			}
			}
			}
			if (orderPrivateCar1 == null) {
			orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).eq("state", 5).le("totalPeopleNum", 4 - peopleNum));
			for (OrderPrivateCar order : orderList) {
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
			if (spellOrderRule != null) {
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间
			if (travelTime.getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && travelTime.getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
			String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());

			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if (dis1 <= jsonObject.getInteger("num3") * 1000 && dis2 <= jsonObject.getInteger("num4") * 1000) {
			orderPrivateCar1 = order;
			break;
			}
			}
			}
			}
			}
			if (orderPrivateCar1 == null) {
			orderPrivateCar.setTotalPeopleNum(peopleNum);
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			this.insert(orderPrivateCar);
			this.pushOrder(orderPrivateCar);
			} else {
			Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
			orderPrivateCar.setDriverId(driverId);
			orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
			driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
			orderPrivateCar.setState(2);
			orderPrivateCar.setDriverId(driver.getId());
			orderPrivateCar.setCarId(driver.getCarId());
			CarService query1 = carServiceMapper.query(1, driver.getCarId());
			orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
			orderPrivateCar.setSnatchOrderTime(new Date());
			orderPrivateCar.setTotalPeopleNum(peopleNum + orderPrivateCar1.getTotalPeopleNum());
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			orderPrivateCar.setPid(orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid());
			this.insert(orderPrivateCar);
			//修改总订单人数
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setSpellSuccess(1);
			orderPrivateCar2.setTotalPeopleNum(peopleNum + orderPrivateCar1.getTotalPeopleNum());
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
			//
			//调用移动的小号接口
			// Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
			// if (String.valueOf(map.get("code")).equals("200")) {
			// orderPrivateCar.setTelX(map.get("telX"));
			// orderPrivateCar.setBindId(map.get("bindId"));
			// }
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
			pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);

			}
			}).start();
			List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid()));
			for (OrderPrivateCar orderPrivateCar3 : orderList1) {
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}

			}


			//添加消息
			systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);
			baseWarpper.setId(orderPrivateCar.getId());
			} catch (Exception e) {
			e.printStackTrace();
			} finally {
			lock.unlock();
			}
			} else {
			return ResultUtil.error("系统繁忙，请稍后再试！");
			}
			return ResultUtil.success(baseWarpper);
			}

			/**
			* 批量订单
			*
			* @throws Exception
			*/
			@Override
			public ResultUtil<BaseWarpper> saveOrderPrivateCars(String serverCarModel, Date travelTime, Integer reservation, Integer instead, String placementLon, String placementLat, String startLon, String startLat, String startAddress, String endLon,
			String endLat, String endAddress, String name, String phone, Integer orderSource, Integer driverId, Integer uid, Integer peopleNum) throws Exception {
			BaseWarpper baseWarpper = new BaseWarpper();
			String key = "saveOrderPrivateCar:" + uid;
			Boolean hasKey = redisTemplate.hasKey(key);
			if (!hasKey) {
			redisTemplate.opsForValue().set(key, uid, 30, TimeUnit.SECONDS);
			try {
			//如果出行时间大于当前10分钟则默认为预约单
			if (travelTime.getTime() > (System.currentTimeMillis() + 600000)) {
			reservation = 2;
			}

			/**
			* 1.出租车、专车、跨城有待支付的订单不能叫车
			* 2.小件物流有未完成的订单可以下跨城、专车、出租车
			* 3.出租车、专车、跨城有预约单可以下即时单
			*/
			List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
			if (orderPrivateCars.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
			if (list.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
			if (orderCrossCities1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			if (reservation == 1) {
			orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if (orderPrivateCars.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if (list.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			}


			List<OrderPrivateCar> orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, null, 3, 7, 12);
			if (orderPrivateCars1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderTaxi> list1 = orderTaxiMapper.queryByState_(uid, null, 3, 7, 12);
			if (list1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderCrossCity> orderCrossCities11 = orderCrossCityMapper.queryByState(uid, 7, 12);
			if (orderCrossCities11.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			if (reservation == 1) {
			orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if (orderPrivateCars1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			list1 = orderTaxiMapper.queryByState_(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if (list1.size() > 0) {
			return ResultUtil.error("有未完成的订单");
			}
			}

			startAddress = startAddress.replaceAll("& #40;", "(");
			startAddress = startAddress.replaceAll("& #41;", ")");
			endAddress = endAddress.replaceAll("& #40;", "(");
			endAddress = endAddress.replaceAll("& #41;", ")");
			if (ToolUtil.isEmpty(serverCarModel)) {
			return ResultUtil.error("请选择服务车型");
			}

			OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
			orderPrivateCar.setPeopleNum(peopleNum);
			orderPrivateCar.setType(3);
			orderPrivateCar.setUserId(uid);
			orderPrivateCar.setServerCarModel(serverCarModel);
			orderPrivateCar.setOrderNum(this.getOrderNum());
			orderPrivateCar.setPlacementLon(Double.valueOf(placementLon));
			orderPrivateCar.setPlacementLat(Double.valueOf(placementLat));
			Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
			orderPrivateCar.setPlacementAddress(geocode.get("address"));
			orderPrivateCar.setStartLon(Double.valueOf(startLon));
			orderPrivateCar.setStartLat(Double.valueOf(startLat));
			orderPrivateCar.setStartAddress(startAddress);
			orderPrivateCar.setEndLon(Double.valueOf(endLon));
			orderPrivateCar.setEndLat(Double.valueOf(endLat));
			orderPrivateCar.setEndAddress(endAddress);
			orderPrivateCar.setSubstitute(instead);
			orderPrivateCar.setPassengers(name);
			orderPrivateCar.setPassengersPhone(phone);
			// TODO: 2023/11/4 无法修改
			Map<String, String> distanceMap = gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
			orderPrivateCar.setEstimateMileage(Double.valueOf(distanceMap.get("distance")));
			orderPrivateCar.setEstimateTime(Double.valueOf(distanceMap.get("duration")) / 60);
			if (instead == 0 \|\| ToolUtil.isEmpty(orderPrivateCar.getPassengers())) {
			UserInfo userInfo = userInfoService.selectById(uid);
			if (ToolUtil.isEmpty(userInfo.getPhone())) {
			return ResultUtil.error("请先绑定手机号码");
			}
			orderPrivateCar.setPassengers(userInfo.getName());
			orderPrivateCar.setPassengersPhone(userInfo.getPhone());
			}
			orderPrivateCar.setState(1);
			orderPrivateCar.setInsertTime(new Date());
			orderPrivateCar.setTravelTime(travelTime);
			orderPrivateCar.setOrderType(reservation);
			orderPrivateCar.setOrderSource(orderSource);
			orderPrivateCar.setTotalPeopleNum(peopleNum);
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);

			@Resource
			private CarServiceMapper carServiceMapper;
			// 是否推广订单
			Integer promotion = isPromotion(uid);
			if(promotion!=null){
			orderPrivateCar.setPromotion(2);
			Driver driver = driverService.selectById(promotion);
			orderPrivateCar.setPromotionUser(driver.getName());
			orderPrivateCar.setPromotionPhone(driver.getPhone());
			orderPrivateCar.setPromotionDriverId(promotion);
			}

			@Resource
			private OrderTaxiMapper orderTaxiMapper;

			@Resource
			private SensitiveWordsMapper sensitiveWordsMapper;
			this.insert(orderPrivateCar);

			//判断独享，一口价，拼车
			JSONArray jsonArray = JSON.parseArray(serverCarModel);
			for (int i = 0; i < jsonArray.size(); i++) {
			JSONObject jsonObject1 = jsonArray.getJSONObject(i);
			Integer serverCarModelId = jsonObject1.getInteger("serverCarModelId");
			Integer rideType = jsonObject1.getInteger("rideType");
			if (0 == serverCarModelId) {
			OrderTaxi orderTaxi = new OrderTaxi();
			orderTaxi.setId(orderPrivateCar.getId());
			orderTaxi.setState(1);
			orderTaxi.setUserId(orderPrivateCar.getUserId());
			orderTaxi.setStartLon(orderPrivateCar.getStartLon());
			orderTaxi.setStartLat(orderPrivateCar.getStartLat());
			orderTaxiService.pushOrder(orderTaxi, 3);
			}

			if (rideType != 3) {
			//推单操作-独享
			this.pushOrder(orderPrivateCar.getId(), rideType, serverCarModelId, orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat());
			} else {
			OrderPrivateCar orderPrivateCar1 = null;
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			//判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
			List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).in("state", "2,3,4").le("totalPeopleNum", 4 - peopleNum));
			for (OrderPrivateCar order : orderList) {
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
			if (spellOrderRule != null) {
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间

			if (travelTime.getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && travelTime.getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if (dis1 <= jsonObject.getInteger("num1") * 1000 && dis2 <= jsonObject.getInteger("num2") * 1000) {
			orderPrivateCar1 = order;
			break;
			}
			}
			}
			}
			if (orderPrivateCar1 == null) {
			orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).eq("state", 5).le("totalPeopleNum", 4 - peopleNum));
			for (OrderPrivateCar order : orderList) {
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
			if (spellOrderRule != null) {
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间
			if (travelTime.getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && travelTime.getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
			String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());

			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if (dis1 <= jsonObject.getInteger("num3") * 1000 && dis2 <= jsonObject.getInteger("num4") * 1000) {
			orderPrivateCar1 = order;
			break;
			}
			}
			}
			}
			}
			if (orderPrivateCar1 == null) {
			this.pushOrder(orderPrivateCar.getId(), rideType, serverCarModelId, orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat());
			} else {
			Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
			orderPrivateCar.setDriverId(driverId);
			orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
			driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
			orderPrivateCar.setState(2);
			orderPrivateCar.setDriverId(driver.getId());
			orderPrivateCar.setCarId(driver.getCarId());
			CarService query1 = carServiceMapper.query(1, driver.getCarId());
			orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
			orderPrivateCar.setRideType(3);
			orderPrivateCar.setSnatchOrderTime(new Date());
			orderPrivateCar.setTotalPeopleNum(peopleNum + orderPrivateCar1.getTotalPeopleNum());
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			orderPrivateCar.setPid(orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid());
			this.insertOrUpdate(orderPrivateCar);
			//修改总订单人数
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setSpellSuccess(1);
			orderPrivateCar2.setTotalPeopleNum(peopleNum + orderPrivateCar1.getTotalPeopleNum());
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
			//
			//调用移动的小号接口
			// Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
			// if (String.valueOf(map.get("code")).equals("200")) {
			// orderPrivateCar.setTelX(map.get("telX"));
			// orderPrivateCar.setBindId(map.get("bindId"));
			// }
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
			pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);

			}
			}).start();
			List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid()));
			for (OrderPrivateCar orderPrivateCar3 : orderList1) {
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			}
			}

			//添加消息
			systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);

			baseWarpper.setId(orderPrivateCar.getId());
			} catch (Exception e) {
			e.printStackTrace();
			} finally {
			redisTemplate.delete(key);
			}
			} else {
			return ResultUtil.error("系统繁忙，请稍后再试！");
			}
			return ResultUtil.success(baseWarpper);
			}

			@Resource
			private UserActivityDiscount1Mapper userActivityDiscount1Mapper;

			@Resource
			private SysIntegralMapper sysIntegralMapper;
			private Integer isPromotion(Integer userId){
			UserInfo userInfo = userInfoService.selectById(userId);
			if(userInfo.getBindDriverId()!=null && userInfo.getBindExpireDate().getTime()<=System.currentTimeMillis()){
			String registAreaCode = userInfo.getRegistAreaCode();
			TDriverPromotionActivity tDriverPromotionActivity = driverPromotionActivityService.selectOne(new EntityWrapper<TDriverPromotionActivity>().eq("districtCode", registAreaCode).ge("startTime", new Date()).lt("endTime", new Date()).last("AND FIND_IN_SET(" + 1 + ", bizType) limit 1"));
			if(tDriverPromotionActivity!=null){
			return userInfo.getBindDriverId();
			}
			}
			return null;

			@Resource
			private OrderCrossCityMapper orderCrossCityMapper;
			}

			@Resource
			private RegionMapper regionMapper;

			@Autowired
			private DateUtil dateUtil;

			@Autowired
			private IUserInfoService userInfoService;

			@Autowired
			private IDriverService driverService;

			@Autowired
			private IDriverServiceService driverServiceService;

			@Autowired
			private PushUtil pushUtil;

			@Autowired
			private ICompanyCityService companyCityService;

			@Autowired
			private IPushOrderService pushOrderService;

			@Autowired
			private ISystemNoticeService systemNoticeService;

			@Autowired
			private ICancleOrderService cancleOrderService;

			@Autowired
			private IOrderCancelService orderCancelService;

			@Autowired
			private RestTemplate internalRestTemplate;

			@Autowired
			private IPaymentRecordService paymentRecordService;

			@Autowired
			private ITransactionDetailsService transactionDetailsService;

			@Autowired
			private ChinaMobileUtil chinaMobileUtil;

			@Autowired
			private IIncomeService incomeService;

			@Autowired
			private IUserCouponRecordService userCouponRecordService;

			@Autowired
			private IUserRedPacketRecordService userRedPacketRecordService;

			@Autowired
			private ICompanyService companyService;

			@Autowired
			private IUserActivityRedenvelopeService userActivityRedenvelopeService;

			@Resource
			private RedisTemplate<String, Object> redisTemplate;

			@Autowired
			private GDFalconUtil gdFalconUtil;

			@Autowired
			private GDMapGeocodingUtil gdMapGeocodingUtil;

			@Autowired
			private GDMapElectricFenceUtil gdMapElectricFenceUtil;

			@Autowired
			private IOrderPositionService orderPositionService;

			@Autowired
			private PushMinistryOfTransportUtil pushMinistryOfTransportUtil;

			@Autowired
			private IOrderCrossCityService orderCrossCityService;

			@Autowired
			private IOrderTaxiService orderTaxiService;

			@Autowired
			private PayMoneyUtil payMoneyUtil;

			@Autowired
			private IOrderLogisticsService orderLogisticsService;

			@Autowired
			private ITaxiCardPaymentService taxiCardPaymentService;

			@Autowired
			private ITaxiCardService taxiCardService;

			@Autowired
			private IOpenCityService openCityService;

			@Autowired
			private IUserUserService userUserService;

			@Autowired
			private IUserTaxiCardService userTaxiCardService;

			@Autowired
			private IRegionService regionService;

			public static List<Integer> orderIds = new ArrayList<>();

			@Value("${callbackPath}")
			private String callbackPath;

			@Value("${pushMinistryOfTransport}")
			private boolean pushMinistryOfTransport;

			@Autowired
			private ITbSpellOrderRuleService spellOrderRuleService;

			@Autowired
			private GeodesyUtil geodesyUtil;

			private Lock lock = new ReentrantLock();

			/**
			* 专车下单操作
			* @param serverCarModelId 服务车型id
			* @param travelTime 出行时间
			* @param reservation 是否预约（1=否，2=是）
			* @param instead 是否代下单（0=否，1=是）
			* @param startLon 起点经度
			* @param startLat 起点纬度
			* @param startAddress 起点详细地址
			* @param endLon 终点经度
			* @param endLat 终点纬度
			* @param endAddress 终点详细地址
			* @param name 乘客姓名
			* @param phone 乘客电话
			* @return
			* @throws Exception
			*/
			@Override
			public synchronized ResultUtil<BaseWarpper> saveOrderPrivateCar(Integer serverCarModelId, Date travelTime, Integer reservation, Integer instead, String placementLon, String placementLat, String startLon, String startLat,
			String startAddress, String endLon, String endLat, String endAddress, String name, String phone, Integer orderSource, Integer driverId, Integer type, Integer uid,Integer peopleNum,Integer rideType) throws Exception {
			BaseWarpper baseWarpper = new BaseWarpper();
			if (lock.tryLock()) {
			try{
			//如果出行时间大于当前10分钟则默认为预约单
			if(travelTime.getTime() > (System.currentTimeMillis() + 600000)){
			reservation = 2;
			}
			/**
			* 1.出租车、专车、跨城有待支付的订单不能叫车
			* 2.小件物流有未完成的订单可以下跨城、专车、出租车
			* 3.出租车、专车、跨城有预约单可以下即时单
			*/
			List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
			if(orderPrivateCars.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
			if(list.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
			if(orderCrossCities1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			if(reservation == 1){
			orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if(orderPrivateCars.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if(list.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			}

			List<OrderPrivateCar> orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, null, 3, 7, 12);
			if(orderPrivateCars1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderTaxi> list1 = orderTaxiMapper.queryByState_(uid, null, 3, 7, 12);
			if(list1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderCrossCity> orderCrossCities11 = orderCrossCityMapper.queryByState(uid, 7, 12);
			if(orderCrossCities11.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			if(reservation == 1){
			orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if(orderPrivateCars1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			list1 = orderTaxiMapper.queryByState_(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if(list1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			}




			startAddress = startAddress.replaceAll("& #40;", "(");
			startAddress = startAddress.replaceAll("& #41;", ")");
			endAddress = endAddress.replaceAll("& #40;", "(");
			endAddress = endAddress.replaceAll("& #41;", ")");
			if((orderSource == 1 \|\| orderSource == 3) && null == serverCarModelId){
			return ResultUtil.error("请选择服务车型");
			}

			OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
			orderPrivateCar.setPeopleNum(peopleNum);
			orderPrivateCar.setRideType(rideType);
			orderPrivateCar.setType(type);
			orderPrivateCar.setUserId(uid);
			orderPrivateCar.setServerCarModelId(serverCarModelId);
			orderPrivateCar.setOrderNum(this.getOrderNum());
			orderPrivateCar.setPlacementLon(Double.valueOf(placementLon));
			orderPrivateCar.setPlacementLat(Double.valueOf(placementLat));
			Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
			orderPrivateCar.setPlacementAddress(geocode.get("address"));
			orderPrivateCar.setStartLon(Double.valueOf(startLon));
			orderPrivateCar.setStartLat(Double.valueOf(startLat));
			orderPrivateCar.setStartAddress(startAddress);
			orderPrivateCar.setEndLon(Double.valueOf(endLon));
			orderPrivateCar.setEndLat(Double.valueOf(endLat));
			orderPrivateCar.setEndAddress(endAddress);
			orderPrivateCar.setSubstitute(instead);
			orderPrivateCar.setPassengers(name);
			orderPrivateCar.setPassengersPhone(phone);
			// TODO: 2023/11/4 无法修改
			Map<String,String> distanceMap = gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
			orderPrivateCar.setEstimateMileage(Double.valueOf(distanceMap.get("distance")));
			orderPrivateCar.setEstimateTime(Double.valueOf(distanceMap.get("duration"))/60);
			if(instead == 0 \|\| ToolUtil.isEmpty(orderPrivateCar.getPassengers())){
			UserInfo userInfo = userInfoService.selectById(uid);
			if(ToolUtil.isEmpty(userInfo.getPhone())){
			return ResultUtil.error("请先绑定手机号码");
			}
			orderPrivateCar.setPassengers(userInfo.getName());
			orderPrivateCar.setPassengersPhone(userInfo.getPhone());
			}
			orderPrivateCar.setState(1);
			orderPrivateCar.setInsertTime(new Date());
			orderPrivateCar.setTravelTime(travelTime);
			orderPrivateCar.setOrderType(reservation);
			orderPrivateCar.setOrderSource(orderSource);
			if(orderSource == 2){//扫码下单
			Driver driver = driverService.selectById(driverId);
			if(null == driver){
			return ResultUtil.error("司机信息有误，无法完成下单");
			}
			if(driver.getAuthState() == 1){
			return ResultUtil.error("司机信息还未完成审核，无法完成下单");
			}
			if(driver.getAuthState() == 3){
			return ResultUtil.error("司机账户已被冻结，无法提供服务");
			}
			if(driver.getAuthState() == 4){
			return ResultUtil.error("司机信息未通过审核，无法提供服务");
			}
			if(driver.getState() == 1){
			return ResultUtil.error("司机还未上线，无法提供服务");
			}
			if(driver.getState() == 3){
			return ResultUtil.error("司机正在服务中，无法提供服务");
			}
			// Integer orderType = orderPrivateCar.getRideType()==1?1:orderPrivateCar.getRideType()==2?9:8;
			Integer orderType = 1;
			Integer integer = driverServiceService.query_(driverId, orderType);
			if(null == integer){
			return ResultUtil.error("该司机不能服务此业务");
			}

			orderPrivateCar.setDriverId(driverId);
			orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
			driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
			orderPrivateCar.setState(2);
			orderPrivateCar.setCarId(driver.getCarId());
			CarService query1 = carServiceMapper.query(1, driver.getCarId());
			orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
			orderPrivateCar.setSnatchOrderTime(new Date());

			// //调用高德创建轨迹
			// String s = gdFalconUtil.selectTerminal(driver.getPhone());
			// String track = gdFalconUtil.createTrack(s);
			// orderPrivateCar.setTrackId(track);
			//
			//调用移动的小号接口
			Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
			if(String.valueOf(map.get("code")).equals("200")){
			orderPrivateCar.setTelX(map.get("telX"));
			orderPrivateCar.setBindId(map.get("bindId"));
			}

			driver.setState(3);
			driverService.updateById(driver);
			}
			//判断独享，一口价，拼车
			if(orderPrivateCar.getRideType()!=3){
			orderPrivateCar.setTotalPeopleNum(peopleNum);
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			this.insert(orderPrivateCar);

			if(orderSource == 2){//扫码下单
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
			}
			}).start();
			}

			//推单操作-独享
			if(orderPrivateCar.getState() == 1){
			this.pushOrder(orderPrivateCar);
			}
			}else{
			OrderPrivateCar orderPrivateCar1 = null;
			//判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
			List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).in("state","2,3,4").le("totalPeopleNum",4-peopleNum));
			for(OrderPrivateCar order:orderList){
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
			if(spellOrderRule!=null){
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间

			if(travelTime.getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")60000L && travelTime.getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")60000L){
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if(dis1<=jsonObject.getInteger("num1")1000 && dis2<=jsonObject.getInteger("num2")1000){
			orderPrivateCar1=order;
			break;
			}
			}
			}
			}
			if(orderPrivateCar1==null){
			orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).eq("state",5).le("totalPeopleNum",4-peopleNum));
			for(OrderPrivateCar order:orderList){
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
			if(spellOrderRule!=null){
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间
			if(travelTime.getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")60000L && travelTime.getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")60000L){
			String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());

			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if(dis1<=jsonObject.getInteger("num3")1000 && dis2<=jsonObject.getInteger("num4")1000){
			orderPrivateCar1=order;
			break;
			}
			}
			}
			}
			}
			if(orderPrivateCar1==null){
			orderPrivateCar.setTotalPeopleNum(peopleNum);
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			this.insert(orderPrivateCar);
			this.pushOrder(orderPrivateCar);
			}else{
			Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
			orderPrivateCar.setDriverId(driverId);
			orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
			driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
			orderPrivateCar.setState(2);
			orderPrivateCar.setDriverId(driver.getId());
			orderPrivateCar.setCarId(driver.getCarId());
			CarService query1 = carServiceMapper.query(1, driver.getCarId());
			orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
			orderPrivateCar.setSnatchOrderTime(new Date());
			orderPrivateCar.setTotalPeopleNum(peopleNum+orderPrivateCar1.getTotalPeopleNum());
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			orderPrivateCar.setPid(orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid());
			this.insert(orderPrivateCar);
			//修改总订单人数
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setSpellSuccess(1);
			orderPrivateCar2.setTotalPeopleNum(peopleNum+orderPrivateCar1.getTotalPeopleNum());
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
			//
			//调用移动的小号接口
			Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
			if(String.valueOf(map.get("code")).equals("200")){
			orderPrivateCar.setTelX(map.get("telX"));
			orderPrivateCar.setBindId(map.get("bindId"));
			}
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
			pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);

			}
			}).start();
			List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()));
			for(OrderPrivateCar orderPrivateCar3:orderList1){
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}

			}


			//添加消息
			systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);
			baseWarpper.setId(orderPrivateCar.getId());
			}catch (Exception e) {
			e.printStackTrace();
			} finally {
			lock.unlock();
			}
			}else {
			return ResultUtil.error("系统繁忙，请稍后再试！");
			}
			return ResultUtil.success(baseWarpper);
			}


			/**
			* 批量订单
			*
			* @throws Exception
			*/
			@Override
			public ResultUtil<BaseWarpper> saveOrderPrivateCars(String serverCarModel, Date travelTime, Integer reservation, Integer instead, String placementLon, String placementLat, String startLon, String startLat, String startAddress, String endLon,
			String endLat, String endAddress, String name, String phone, Integer orderSource, Integer driverId, Integer uid, Integer peopleNum) throws Exception {
			BaseWarpper baseWarpper = new BaseWarpper();
			if (lock.tryLock()) {
			try {
			//如果出行时间大于当前10分钟则默认为预约单
			if (travelTime.getTime() > (System.currentTimeMillis() + 600000)) {
			reservation = 2;
			}

			/**
			* 1.出租车、专车、跨城有待支付的订单不能叫车
			* 2.小件物流有未完成的订单可以下跨城、专车、出租车
			* 3.出租车、专车、跨城有预约单可以下即时单
			*/
			List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, null, 1, 7, 12);
			if(orderPrivateCars.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, null, 1, 7, 12);
			if(list.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderCrossCity> orderCrossCities1 = orderCrossCityMapper.queryByState(uid, 7, 12);
			if(orderCrossCities1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			if(reservation == 1){
			orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if(orderPrivateCars.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if(list.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			}


			List<OrderPrivateCar> orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, null, 3, 7, 12);
			if(orderPrivateCars1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderTaxi> list1 = orderTaxiMapper.queryByState_(uid, null, 3, 7, 12);
			if(list1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			List<OrderCrossCity> orderCrossCities11 = orderCrossCityMapper.queryByState(uid, 7, 12);
			if(orderCrossCities11.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			if(reservation == 1){
			orderPrivateCars1 = orderPrivateCarMapper.queryByState(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if(orderPrivateCars1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			list1 = orderTaxiMapper.queryByState_(uid, 1, 3, 1, 2, 3, 4, 5, 6, 7, 11, 12);
			if(list1.size() > 0){
			return ResultUtil.error("有未完成的订单");
			}
			}

			startAddress = startAddress.replaceAll("& #40;", "(");
			startAddress = startAddress.replaceAll("& #41;", ")");
			endAddress = endAddress.replaceAll("& #40;", "(");
			endAddress = endAddress.replaceAll("& #41;", ")");
			if(ToolUtil.isEmpty(serverCarModel)){
			return ResultUtil.error("请选择服务车型");
			}

			OrderPrivateCar orderPrivateCar = new OrderPrivateCar();
			orderPrivateCar.setPeopleNum(peopleNum);
			orderPrivateCar.setType(3);
			orderPrivateCar.setUserId(uid);
			orderPrivateCar.setServerCarModel(serverCarModel);
			orderPrivateCar.setOrderNum(this.getOrderNum());
			orderPrivateCar.setPlacementLon(Double.valueOf(placementLon));
			orderPrivateCar.setPlacementLat(Double.valueOf(placementLat));
			Map<String, String> geocode = gdMapGeocodingUtil.geocode(placementLon, placementLat);
			orderPrivateCar.setPlacementAddress(geocode.get("address"));
			orderPrivateCar.setStartLon(Double.valueOf(startLon));
			orderPrivateCar.setStartLat(Double.valueOf(startLat));
			orderPrivateCar.setStartAddress(startAddress);
			orderPrivateCar.setEndLon(Double.valueOf(endLon));
			orderPrivateCar.setEndLat(Double.valueOf(endLat));
			orderPrivateCar.setEndAddress(endAddress);
			orderPrivateCar.setSubstitute(instead);
			orderPrivateCar.setPassengers(name);
			orderPrivateCar.setPassengersPhone(phone);
			// TODO: 2023/11/4 无法修改
			Map<String,String> distanceMap = gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
			orderPrivateCar.setEstimateMileage(Double.valueOf(distanceMap.get("distance")));
			orderPrivateCar.setEstimateTime(Double.valueOf(distanceMap.get("duration"))/60);
			if(instead == 0 \|\| ToolUtil.isEmpty(orderPrivateCar.getPassengers())){
			UserInfo userInfo = userInfoService.selectById(uid);
			if(ToolUtil.isEmpty(userInfo.getPhone())){
			return ResultUtil.error("请先绑定手机号码");
			}
			orderPrivateCar.setPassengers(userInfo.getName());
			orderPrivateCar.setPassengersPhone(userInfo.getPhone());
			}
			orderPrivateCar.setState(1);
			orderPrivateCar.setInsertTime(new Date());
			orderPrivateCar.setTravelTime(travelTime);
			orderPrivateCar.setOrderType(reservation);
			orderPrivateCar.setOrderSource(orderSource);
			orderPrivateCar.setTotalPeopleNum(peopleNum);
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			this.insert(orderPrivateCar);

			//判断独享，一口价，拼车
			JSONArray jsonArray = JSON.parseArray(serverCarModel);
			for (int i = 0; i < jsonArray.size(); i++) {
			JSONObject jsonObject1 = jsonArray.getJSONObject(i);
			Integer serverCarModelId = jsonObject1.getInteger("serverCarModelId");
			Integer rideType = jsonObject1.getInteger("rideType");
			if(0 == serverCarModelId){
			OrderTaxi orderTaxi = new OrderTaxi();
			orderTaxi.setId(orderPrivateCar.getId());
			orderTaxi.setState(1);
			orderTaxi.setUserId(orderPrivateCar.getUserId());
			orderTaxi.setStartLon(orderPrivateCar.getStartLon());
			orderTaxi.setStartLat(orderPrivateCar.getStartLat());
			orderTaxiService.pushOrder(orderTaxi, 3);
			}

			if(rideType!=3){
			//推单操作-独享
			this.pushOrder(orderPrivateCar.getId(), rideType, serverCarModelId, orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat());
			}else{
			OrderPrivateCar orderPrivateCar1 = null;
			//判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
			List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).in("state","2,3,4").le("totalPeopleNum",4-peopleNum));
			for(OrderPrivateCar order:orderList){
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
			if(spellOrderRule!=null){
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间

			if(travelTime.getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")60000L && travelTime.getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")60000L){
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if(dis1<=jsonObject.getInteger("num1")1000 && dis2<=jsonObject.getInteger("num2")1000){
			orderPrivateCar1=order;
			break;
			}
			}
			}
			}
			if(orderPrivateCar1==null){
			orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).eq("state",5).le("totalPeopleNum",4-peopleNum));
			for(OrderPrivateCar order:orderList){
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
			if(spellOrderRule!=null){
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间
			if(travelTime.getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")60000L && travelTime.getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")60000L){
			String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());

			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if(dis1<=jsonObject.getInteger("num3")1000 && dis2<=jsonObject.getInteger("num4")1000){
			orderPrivateCar1=order;
			break;
			}
			}
			}
			}
			}
			if(orderPrivateCar1==null){
			this.pushOrder(orderPrivateCar.getId(), rideType, serverCarModelId, orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat());
			}else{
			Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
			orderPrivateCar.setDriverId(driverId);
			orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
			driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
			orderPrivateCar.setState(2);
			orderPrivateCar.setDriverId(driver.getId());
			orderPrivateCar.setCarId(driver.getCarId());
			CarService query1 = carServiceMapper.query(1, driver.getCarId());
			orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
			orderPrivateCar.setRideType(3);
			orderPrivateCar.setSnatchOrderTime(new Date());
			orderPrivateCar.setTotalPeopleNum(peopleNum+orderPrivateCar1.getTotalPeopleNum());
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			orderPrivateCar.setPid(orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid());
			this.insertOrUpdate(orderPrivateCar);
			//修改总订单人数
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setSpellSuccess(1);
			orderPrivateCar2.setTotalPeopleNum(peopleNum+orderPrivateCar1.getTotalPeopleNum());
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
			//
			//调用移动的小号接口
			Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
			if(String.valueOf(map.get("code")).equals("200")){
			orderPrivateCar.setTelX(map.get("telX"));
			orderPrivateCar.setBindId(map.get("bindId"));
			}
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
			pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);

			}
			}).start();
			List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()));
			for(OrderPrivateCar orderPrivateCar3:orderList1){
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			}
			}

			//添加消息
			systemNoticeService.addSystemNotice(1, "您的快车订单已下单成功，我们正在为您指派司机，请稍后！", orderPrivateCar.getUserId(), 1);

			baseWarpper.setId(orderPrivateCar.getId());
			}catch (Exception e) {
			e.printStackTrace();
			} finally {
			lock.unlock();
			}
			}else {
			return ResultUtil.error("系统繁忙，请稍后再试！");
			}
			return ResultUtil.success(baseWarpper);
			}

			/**
			* 下单后继续等待
			* @param id
			* @return
			* @throws Exception
			*/
			@Override
			public ResultUtil pushOrderPrivateCar(Integer id) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			if(null == orderPrivateCar){
			return ResultUtil.error("推送订单失败，订单信息有误");
			}
			if(orderPrivateCar.getState() != 1){
			return ResultUtil.error("订单已被司机接单，不能重复推送");
			}
			//处理摆渡订单的继续推单操作
			if(orderPrivateCar.getType() == 2){
			OrderCrossCityServiceImpl.pushEndMap.put(orderPrivateCar.getCrossCityOrderId(), false);//还原标识数据
			List<OrderPrivateCar> list = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
			List<Map<String, Integer>> orders = new ArrayList<>();
			for(OrderPrivateCar orderPrivateCar1 : list){
			if(orderPrivateCar1.getState() != 1){
			return ResultUtil.error("订单已被司机接单，推单取消");
			}
			Map<String, Integer> map = new HashMap<>();
			map.put("orderType", 1);
			map.put("orderId", orderPrivateCar1.getId());
			orders.add(map);
			}
			List<OrderTaxi> list1 = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
			for(OrderTaxi orderTaxi : list1){
			if(orderTaxi.getState() != 1){
			return ResultUtil.error("订单已被司机接单，推单取消");
			}
			Map<String, Integer> map = new HashMap<>();
			map.put("orderType", 2);
			map.put("orderId", orderTaxi.getId());
			orders.add(map);
			}
			//开始重新推单
			orderCrossCityService.pushOrder(orders);

			}else{
			//判断独享，一口价，拼车
			if(orderPrivateCar.getRideType()!=3){
			this.pushOrder(orderPrivateCar);
			}else{
			OrderPrivateCar orderPrivateCar1 = null;
			//判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
			List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).in("state","2,3,4").le("totalPeopleNum",4-orderPrivateCar.getPeopleNum()));
			for(OrderPrivateCar order:orderList){
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
			if(spellOrderRule!=null){
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间
			if(orderPrivateCar.getTravelTime().getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")60000L && orderPrivateCar.getTravelTime().getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")60000L){
			/**
			* 下单后继续等待
			*
			* @param id
			* @return
			* @throws Exception
			*/
			@Override
			public ResultUtil pushOrderPrivateCar(Integer id) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			if (null == orderPrivateCar) {
			return ResultUtil.error("推送订单失败，订单信息有误");
			}
			if (orderPrivateCar.getState() != 1) {
			return ResultUtil.error("订单已被司机接单，不能重复推送");
			}
			//处理摆渡订单的继续推单操作
			if (orderPrivateCar.getType() == 2) {
			OrderCrossCityServiceImpl.pushEndMap.put(orderPrivateCar.getCrossCityOrderId(), false);//还原标识数据
			List<OrderPrivateCar> list = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
			List<Map<String, Integer>> orders = new ArrayList<>();
			for (OrderPrivateCar orderPrivateCar1 : list) {
			if (orderPrivateCar1.getState() != 1) {
			return ResultUtil.error("订单已被司机接单，推单取消");
			}
			Map<String, Integer> map = new HashMap<>();
			map.put("orderType", 1);
			map.put("orderId", orderPrivateCar1.getId());
			orders.add(map);
			}
			List<OrderTaxi> list1 = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
			for (OrderTaxi orderTaxi : list1) {
			if (orderTaxi.getState() != 1) {
			return ResultUtil.error("订单已被司机接单，推单取消");
			}
			Map<String, Integer> map = new HashMap<>();
			map.put("orderType", 2);
			map.put("orderId", orderTaxi.getId());
			orders.add(map);
			}
			//开始重新推单
			orderCrossCityService.pushOrder(orders);

			} else {
			//判断独享，一口价，拼车
			if (orderPrivateCar.getRideType() != 3) {
			this.pushOrder(orderPrivateCar);
			} else {
			OrderPrivateCar orderPrivateCar1 = null;
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			//判断是否有相同线路的拼车-有直接拼成功，或者推送拼车订单
			List<OrderPrivateCar> orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).in("state", "2,3,4").le("totalPeopleNum", 4 - orderPrivateCar.getPeopleNum()));
			for (OrderPrivateCar order : orderList) {
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
			if (spellOrderRule != null) {
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间
			if (orderPrivateCar.getTravelTime().getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && orderPrivateCar.getTravelTime().getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat(), 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if(dis1<=jsonObject.getInteger("num1")1000 && dis2<=jsonObject.getInteger("num2")1000){
			orderPrivateCar1=orderPrivateCar;
			break;
			}
			}
			}
			}
			if(orderPrivateCar1==null){
			orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType",3).eq("state",5).le("totalPeopleNum",4-orderPrivateCar.getPeopleNum()));
			for(OrderPrivateCar order:orderList){
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("companyId",order.getCompanyId()));
			if(spellOrderRule!=null){
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间
			if(orderPrivateCar.getTravelTime().getTime()>=order.getTravelTime().getTime()-jsonObject.getInteger("num5")60000L && orderPrivateCar.getTravelTime().getTime()<=order.getTravelTime().getTime()+jsonObject.getInteger("num6")60000L){
			String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), order.getStartLon() + "," + order.getStartLat()).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if (dis1 <= jsonObject.getInteger("num1") * 1000 && dis2 <= jsonObject.getInteger("num2") * 1000) {
			orderPrivateCar1 = orderPrivateCar;
			break;
			}
			}
			}
			}
			if (orderPrivateCar1 == null) {
			orderList = orderPrivateCarMapper.selectList(new EntityWrapper<OrderPrivateCar>().eq("rideType", 3).eq("state", 5).le("totalPeopleNum", 4 - orderPrivateCar.getPeopleNum()));
			for (OrderPrivateCar order : orderList) {
			TbSpellOrderRule spellOrderRule = spellOrderRuleService.selectOne(new EntityWrapper<TbSpellOrderRule>().eq("openCityId", openCity.getId()));
			if (spellOrderRule != null) {
			JSONObject jsonObject = JSONObject.parseObject(spellOrderRule.getContent());
			//判断时间
			if (orderPrivateCar.getTravelTime().getTime() >= order.getTravelTime().getTime() - jsonObject.getInteger("num5") * 60000L && orderPrivateCar.getTravelTime().getTime() <= order.getTravelTime().getTime() + jsonObject.getInteger("num6") * 60000L) {
			String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(order.getDriverId()));
			// Double dis1 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value, 1).get("distance").toString());
			// Double dis2 = Double.valueOf(gdMapElectricFenceUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat(), 1).get("distance").toString());
			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if(dis1<=jsonObject.getInteger("num3")1000 && dis2<=jsonObject.getInteger("num4")1000){
			orderPrivateCar1=order;
			break;
			}
			}
			}
			}
			}
			if(orderPrivateCar1==null){
			this.pushOrder(orderPrivateCar);
			}else{
			Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
			orderPrivateCar.setDriverId(orderPrivateCar1.getDriverId());
			orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
			driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
			orderPrivateCar.setState(2);
			orderPrivateCar.setCarId(driver.getCarId());
			orderPrivateCar.setDriverId(driver.getId());
			CarService query1 = carServiceMapper.query(1, driver.getCarId());
			orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
			orderPrivateCar.setSnatchOrderTime(new Date());

			orderPrivateCar.setTotalPeopleNum(orderPrivateCar.getPeopleNum()+orderPrivateCar1.getTotalPeopleNum());
			orderPrivateCar.setPid(orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid());
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			this.updateById(orderPrivateCar);
			//修改总订单人数
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getPeopleNum()+orderPrivateCar1.getTotalPeopleNum());
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar1.getPid()==null?orderPrivateCar1.getId():orderPrivateCar1.getPid()).lt("state",6));
			//调用移动的小号接口
			Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
			if(String.valueOf(map.get("code")).equals("200")){
			orderPrivateCar.setTelX(map.get("telX"));
			orderPrivateCar.setBindId(map.get("bindId"));
			}
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
			pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
			}
			}).start();
			List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()));
			for(OrderPrivateCar orderPrivateCar3:orderList1){
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			}

			}
			return ResultUtil.success();
			}

			@Override
			public ResultUtil<BaseWarpper> queryCancleAmount(Integer id) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			if(null == orderPrivateCar){
			return ResultUtil.error("获取数据失败，订单信息有误");
			}
			double amount = 0;
			CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, orderPrivateCar.getCompanyId());
			if(null != orderPrivateCar.getDriverId() &&
			(orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < new Date().getTime()){//收费的情况
			if(null != query){
			amount += query.getMoney();
			}
			}
			BaseWarpper baseWarpper = new BaseWarpper();
			baseWarpper.setAmount(amount);
			return ResultUtil.success(baseWarpper);
			}

			@Override
			public ResultUtil addCancle(Integer id, String reason, String remark, Integer uid) throws Exception {
			if(ToolUtil.isNotEmpty(remark)){
			if(ToolUtil.isNotEmpty(remark)){
			List<SensitiveWords> sensitiveWords = sensitiveWordsMapper.selectList(null);
			for(SensitiveWords s : sensitiveWords){
			remark = remark.replaceAll(s.getContent(), "***");
			}
			}
			}

			OrderPrivateCar orderPrivateCar = this.selectById(id);
			Integer integer = null;
			if(null == orderPrivateCar){
			return ResultUtil.error("取消订单失败，订单信息有误");
			}
			// TODO: 2023/11/4 已改成计算直线距离
			Double dis1 = geodesyUtil.getDistance(orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), value).get("WGS84");
			Double dis2 = geodesyUtil.getDistance(orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), order.getEndLon() + "," + order.getEndLat()).get("WGS84");
			//判断距离
			if (dis1 <= jsonObject.getInteger("num3") * 1000 && dis2 <= jsonObject.getInteger("num4") * 1000) {
			orderPrivateCar1 = order;
			break;
			}
			}
			}
			}
			}
			if (orderPrivateCar1 == null) {
			this.pushOrder(orderPrivateCar);
			} else {
			Driver driver = driverService.selectById(orderPrivateCar1.getDriverId());
			orderPrivateCar.setDriverId(orderPrivateCar1.getDriverId());
			orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
			driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
			orderPrivateCar.setState(2);
			orderPrivateCar.setCarId(driver.getCarId());
			orderPrivateCar.setDriverId(driver.getId());
			CarService query1 = carServiceMapper.query(1, driver.getCarId());
			orderPrivateCar.setServerCarModelId(query1.getServerCarModelId());
			orderPrivateCar.setSnatchOrderTime(new Date());

			orderPrivateCar.setTotalPeopleNum(orderPrivateCar.getPeopleNum() + orderPrivateCar1.getTotalPeopleNum());
			orderPrivateCar.setPid(orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid());
			orderPrivateCar.setIsReassign(1);
			orderPrivateCar.setIsDelete(1);
			this.updateById(orderPrivateCar);
			//修改总订单人数
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getPeopleNum() + orderPrivateCar1.getTotalPeopleNum());
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar1.getPid() == null ? orderPrivateCar1.getId() : orderPrivateCar1.getPid()).lt("state", 6));
			//调用移动的小号接口
			// Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), (System.currentTimeMillis() + 86400000));
			// if (String.valueOf(map.get("code")).equals("200")) {
			// orderPrivateCar.setTelX(map.get("telX"));
			// orderPrivateCar.setBindId(map.get("bindId"));
			// }
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, 2, 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 100, 0);
			pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);
			}
			}).start();
			List<OrderPrivateCar> orderList1 = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid()));
			for (OrderPrivateCar orderPrivateCar3 : orderList1) {
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			OrderPrivateCar orderPrivateCar3 = this.selectById(orderPrivateCar.getPid());
			pushUtil.pushOrderState(1, orderPrivateCar3.getUserId(), orderPrivateCar3.getId(), 1, 13, 0);
			}
			}

			}
			return ResultUtil.success();
			}

			@Override
			public ResultUtil<BaseWarpper> queryCancleAmount(Integer id) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			if (null == orderPrivateCar) {
			return ResultUtil.error("获取数据失败，订单信息有误");
			}
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			double amount = 0;
			CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, openCity.getId());
			if (null != orderPrivateCar.getDriverId() &&
			(orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < new Date().getTime()) {//收费的情况
			if (null != query) {
			amount += query.getMoney();
			}
			}
			BaseWarpper baseWarpper = new BaseWarpper();
			baseWarpper.setAmount(amount);
			return ResultUtil.success(baseWarpper);
			}

			@Override
			public ResultUtil addCancle(Integer id, String reason, String remark, Integer uid) throws Exception {
			if (ToolUtil.isNotEmpty(remark)) {
			if (ToolUtil.isNotEmpty(remark)) {
			List<SensitiveWords> sensitiveWords = sensitiveWordsMapper.selectList(null);
			for (SensitiveWords s : sensitiveWords) {
			remark = remark.replaceAll(s.getContent(), "***");
			}
			}
			}

			OrderPrivateCar orderPrivateCar = this.selectById(id);
			Integer integer = null;
			if (null == orderPrivateCar) {
			return ResultUtil.error("取消订单失败，订单信息有误");
			}
			// if(orderPrivateCar.getState() == 4){
			// return ResultUtil.error("司机已到达预约点，取消会产生一定的费用");
			// }
			if(orderPrivateCar.getState() >= 5 && orderPrivateCar.getState() != 11){
			return ResultUtil.error("取消订单失败，不合法的操作");
			}
			Integer number1 = this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
			Integer number2 = this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
			if(number1+number2==1){
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getTotalPeopleNum()-orderPrivateCar.getPeopleNum());
			orderPrivateCar2.setSpellSuccess(0);
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));

			}else{
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getTotalPeopleNum()-orderPrivateCar.getPeopleNum());
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("pid",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
			this.update(orderPrivateCar2,new EntityWrapper<OrderPrivateCar>().eq("id",orderPrivateCar.getPid()==null?orderPrivateCar.getId():orderPrivateCar.getPid()).lt("state",6));
			}
			if(null == orderPrivateCar.getDriverId()){//没有接单的情况
			if(orderPrivateCar.getType() == 2){//摆渡车
			OrderCrossCityServiceImpl.pushEndMap.remove(orderPrivateCar.getCrossCityOrderId());//删除标识数据
			List<OrderPrivateCar> list = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
			for(OrderPrivateCar orderPrivateCar1 : list){
			orderCancelService.saveData(orderPrivateCar1.getId(), 1, "无司机接单", "无司机接单", null, null, 2, 1, uid);
			orderPrivateCar1.setState(10);
			this.updateById(orderPrivateCar1);
			}
			List<OrderTaxi> list1 = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
			for(OrderTaxi orderTaxi : list1){
			orderCancelService.saveData(orderTaxi.getId(), 2, "无司机接单", "无司机接单", null, null, 2, 1, uid);
			orderTaxi.setState(10);
			orderTaxiService.updateById(orderTaxi);
			}
			}else{
			integer = orderCancelService.saveData(id, 1, "无司机接单", "无司机接单", null, null, 2, 1, uid);
			orderPrivateCar.setState(10);
			this.updateById(orderPrivateCar);
			}
			}else {
			CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, orderPrivateCar.getCompanyId());
			if (null != query) {
			if ((orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < System.currentTimeMillis() && query.getMoney().compareTo(0D) > 0) {//收费的情况
			orderPrivateCar.setState(12);
			this.updateById(orderPrivateCar);
			integer = orderCancelService.saveData(id, 1, reason, remark, null, query.getMoney(), 1, 1, uid);
			} else {
			integer = orderCancelService.saveData(id, 1, reason, remark, null, null, 2, 1, uid);

			orderPrivateCar.setState(10);
			this.updateById(orderPrivateCar);
			}
			this.deleteTask(id);//删除定时任务

			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			System.err.println("推送取消操作---------------------");
			}
			}).start();

			//修改司机为空闲
			Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
			driver.setState(2);
			driverService.updateById(driver);

			// 解绑手机

			//解除小号绑定
			if(orderPrivateCar.getBindId() != null){
			Map<String, String> map = chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 86400000));
			}
			}else{
			return ResultUtil.error("请完善后台取消规则设置");
			}

			}

			new Thread(new Runnable() {
			@Override
			public void run() {
			if(pushMinistryOfTransport){
			//上传数据
			pushMinistryOfTransportUtil.orderCancel(orderPrivateCar.getId());
			}
			}
			}).start();

			//添加消息
			systemNoticeService.addSystemNotice(1, "您已成功取消出行订单，谢谢使用！", orderPrivateCar.getUserId(), 1);
			Map<String, Object> map = new HashMap<>();
			map.put("id", integer);
			return ResultUtil.success(map);
			}


			/**
			* 取消订单操作
			* @param id
			* @return
			* @throws Exception
			*/
			@Override
			@Transactional(propagation = Propagation.REQUIRES_NEW)
			public ResultUtil cancleOrderPrivateCar(Integer id, Integer payType, Integer cancleId, Integer type) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			Integer uid = orderPrivateCar.getUserId();
			UserInfo userInfo = userInfoService.selectById(uid);
			ResultUtil resultUtil = ResultUtil.success(new Object());

			if(null == orderPrivateCar){
			return ResultUtil.error("取消订单失败，订单信息有误", "");
			}
			if(orderPrivateCar.getState() != 12){
			return ResultUtil.error("取消订单失败，不合法的操作", "");
			}
			OrderCancel orderCancel = null;
			if(null == cancleId){
			orderCancel = orderCancelService.query(id, 1, null, null, 1);
			}else{
			orderCancel = orderCancelService.selectById(cancleId);
			}

			CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, orderPrivateCar.getCompanyId());
			if(null != query){
			if(payType == 1){//微信支付
			String value = (String) redisTemplate.opsForValue().get("appletOpenId");
			String appletsOpenId = null;
			if(ToolUtil.isNotEmpty(value)){
			JSONObject jsonObject = JSON.parseObject(value);
			appletsOpenId = jsonObject.getString(uid.toString());
			}else{
			appletsOpenId = userInfo.getAppletsOpenId();
			}
			orderCancel.setPayType(1);
			orderCancelService.updateById(orderCancel);
			String app = type == 1 ? "APP" : "JSAPI";
			resultUtil = payMoneyUtil.weixinpay("订单取消", "", id + "_1_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/wxCancelOrderTaxi", app, userInfo.getAppletsOpenId());
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 1, query.getMoney(), "", 1);//添加预支付数据
			}
			if(payType == 2){//支付宝支付
			orderCancel.setPayType(2);
			orderCancelService.updateById(orderCancel);

			resultUtil = payMoneyUtil.alipay("订单取消", "订单取消", "", id + "_1_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/aliCancelOrderTaxi");
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 2, query.getMoney(), "", 1);//添加预支付数据
			}
			if(payType == 3){//余额支付
			if (userInfo.getBalance() != null && userInfo.getBalance() < query.getMoney()) {
			return ResultUtil.error("余额不足，无法完成支付");
			}
			if (orderPrivateCar.getState() >= 5 && orderPrivateCar.getState() != 11) {
			return ResultUtil.error("取消订单失败，不合法的操作");
			}
			Integer number1 = this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
			Integer number2 = this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
			if (number1 + number2 == 1) {
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getTotalPeopleNum() - orderPrivateCar.getPeopleNum());
			orderPrivateCar2.setSpellSuccess(0);
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));

			} else {
			OrderPrivateCar orderPrivateCar2 = new OrderPrivateCar();
			orderPrivateCar2.setTotalPeopleNum(orderPrivateCar.getTotalPeopleNum() - orderPrivateCar.getPeopleNum());
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("pid", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
			this.update(orderPrivateCar2, new EntityWrapper<OrderPrivateCar>().eq("id", orderPrivateCar.getPid() == null ? orderPrivateCar.getId() : orderPrivateCar.getPid()).lt("state", 6));
			}
			if (null == orderPrivateCar.getDriverId()) {//没有接单的情况
			if (orderPrivateCar.getType() == 2) {//摆渡车
			OrderCrossCityServiceImpl.pushEndMap.remove(orderPrivateCar.getCrossCityOrderId());//删除标识数据
			List<OrderPrivateCar> list = this.selectList(new EntityWrapper<OrderPrivateCar>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
			for (OrderPrivateCar orderPrivateCar1 : list) {
			orderCancelService.saveData(orderPrivateCar1.getId(), 1, "无司机接单", "无司机接单", null, null, 2, 1, uid);
			orderPrivateCar1.setState(10);
			this.updateById(orderPrivateCar1);
			}
			List<OrderTaxi> list1 = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("type", 2).eq("crossCityOrderId", orderPrivateCar.getCrossCityOrderId()).eq("place", orderPrivateCar.getPlace()));
			for (OrderTaxi orderTaxi : list1) {
			orderCancelService.saveData(orderTaxi.getId(), 2, "无司机接单", "无司机接单", null, null, 2, 1, uid);
			orderTaxi.setState(10);
			orderTaxiService.updateById(orderTaxi);
			}
			} else {
			integer = orderCancelService.saveData(id, 1, "无司机接单", "无司机接单", null, null, 2, 1, uid);
			orderPrivateCar.setState(10);
			this.updateById(orderPrivateCar);
			}
			} else {
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, openCity.getId());
			if (null != query) {
			if ((orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < System.currentTimeMillis() && query.getMoney().compareTo(0D) > 0) {//收费的情况
			orderPrivateCar.setState(12);
			this.updateById(orderPrivateCar);
			integer = orderCancelService.saveData(id, 1, reason, remark, null, query.getMoney(), 1, 1, uid);
			} else {
			integer = orderCancelService.saveData(id, 1, reason, remark, null, null, 2, 1, uid);

			orderPrivateCar.setState(10);
			this.updateById(orderPrivateCar);
			}
			this.deleteTask(id);//删除定时任务

			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			System.err.println("推送取消操作---------------------");
			}
			}).start();

			//修改司机为空闲
			Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
			driver.setState(2);
			driverService.updateById(driver);

			// 解绑手机

			//解除小号绑定
			if (orderPrivateCar.getBindId() != null) {
			Map<String, String> map = chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 86400000));
			}
			} else {
			return ResultUtil.error("请完善后台取消规则设置");
			}

			}

			new Thread(new Runnable() {
			@Override
			public void run() {
			if (pushMinistryOfTransport) {
			//上传数据
			pushMinistryOfTransportUtil.orderCancel(orderPrivateCar.getId());
			}
			}
			}).start();

			//添加消息
			systemNoticeService.addSystemNotice(1, "您已成功取消出行订单，谢谢使用！", orderPrivateCar.getUserId(), 1);
			Map<String, Object> map = new HashMap<>();
			map.put("id", integer);
			return ResultUtil.success(map);
			}

			/**
			* 取消订单操作
			*
			* @param id
			* @return
			* @throws Exception
			*/
			@Override
			@Transactional(propagation = Propagation.REQUIRES_NEW)
			public ResultUtil cancleOrderPrivateCar(Integer id, Integer payType, Integer cancleId, Integer type) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			Integer uid = orderPrivateCar.getUserId();
			UserInfo userInfo = userInfoService.selectById(uid);
			ResultUtil resultUtil = ResultUtil.success(new Object());

			if (null == orderPrivateCar) {
			return ResultUtil.error("取消订单失败，订单信息有误", "");
			}
			if (orderPrivateCar.getState() != 12) {
			return ResultUtil.error("取消订单失败，不合法的操作", "");
			}
			OrderCancel orderCancel = null;
			if (null == cancleId) {
			orderCancel = orderCancelService.query(id, 1, null, null, 1);
			} else {
			orderCancel = orderCancelService.selectById(cancleId);
			}
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, openCity.getId());
			if (null != query) {
			if (payType == 1) {//微信支付
			String value = (String) redisTemplate.opsForValue().get("appletOpenId");
			String appletsOpenId = null;
			if (ToolUtil.isNotEmpty(value)) {
			JSONObject jsonObject = JSON.parseObject(value);
			appletsOpenId = jsonObject.getString(uid.toString());
			} else {
			appletsOpenId = userInfo.getAppletsOpenId();
			}
			orderCancel.setPayType(1);
			orderCancelService.updateById(orderCancel);
			String app = type == 1 ? "APP" : "JSAPI";
			resultUtil = payMoneyUtil.weixinpay("订单取消", "", id + "_1_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/wxCancelOrderTaxi", app, userInfo.getAppletsOpenId());
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 1, query.getMoney(), "", 1);//添加预支付数据
			}
			if (payType == 2) {//支付宝支付
			orderCancel.setPayType(2);
			orderCancelService.updateById(orderCancel);

			resultUtil = payMoneyUtil.alipay("订单取消", "订单取消", "", id + "_1_" + UUIDUtil.getRandomCode(5), query.getMoney().toString(), "/base/aliCancelOrderTaxi");
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 2, query.getMoney(), "", 1);//添加预支付数据
			}
			if (payType == 3) {//余额支付
			if (userInfo.getBalance() != null && userInfo.getBalance() < query.getMoney()) {
			return ResultUtil.error("余额不足，无法完成支付");
			}
			// resultUtil= appOrderController.moneyPay(id,userInfo.getId(),query.getMoney());
			// if(resultUtil.getCode()==500){
			// return ResultUtil.error("电子余额不足，无法完成支付");
			// }
			userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(query.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			//添加交易明细
			transactionDetailsService.saveData(uid, "快车取消订单", query.getMoney(), 2, 1, 1, 1, id);
			userInfoService.updateById(userInfo);

			//解除小号绑定
			if (orderPrivateCar.getBindId() != null) {
			chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 600000));
			}

			orderPrivateCar.setState(10);
			orderPrivateCar.setTelX("");
			orderPrivateCar.setBindId("");
			this.updateById(orderPrivateCar);

			orderCancel.setState(2);
			orderCancel.setPayType(3);
			orderCancelService.updateById(orderCancel);

			//添加已收入明细
			incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, query.getMoney());

			this.deleteTask(id);//删除定时任务

			//添加消息
			systemNoticeService.addSystemNotice(1, "您已使用余额成功支付取消订单费用，谢谢使用！", orderPrivateCar.getUserId(), 1);

			}else if(payType == 4){
			Double payMoney = orderPrivateCar.getOrderMoney();
			Integer integer = paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 4, query.getMoney(), "", 1);
			resultUtil = appOrderController.placeAnOrder(new BigDecimal(query.getMoney()), 4,id,1,integer);

			}
			}
			return resultUtil;
			}

			@Override
			public Map<String, Object> queryOrderInfo(Integer uid, Integer orderId) throws Exception {
			Map<String, Object> map = orderPrivateCarMapper.queryOrderInfo(orderId);
			if(null == map){
			OrderTaxi orderTaxi = orderTaxiService.selectOne(new EntityWrapper<OrderTaxi>()
			.eq("userId", uid)
			.eq("isDelete", 1)
			.in("state", Arrays.asList(2, 3, 4, 5, 6, 7))
			);
			return orderTaxiService.queryOrderInfo(orderTaxi.getId());
			}
			if(null != map.get("reassignNotice") && Integer.valueOf(String.valueOf(map.get("reassignNotice"))) == 2){//改派完成，重新获取了新的司机数据，开始修改数据防止继续调用
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			orderPrivateCar.setReassignNotice(0);
			this.updateById(orderPrivateCar);
			}
			if(Integer.valueOf(String.valueOf(map.get("state"))) == 11){
			map.put("state", map.get("oldState"));
			}
			if(Integer.valueOf(String.valueOf(map.get("state"))) != 8 && Integer.valueOf(String.valueOf(map.get("state"))) != 9){
			map.put("redPacketMoney", null);
			map.put("couponMoney", null);
			}

			String driverId = (String) redisTemplate.opsForValue().get("DEVICE_" + map.get("driverId"));
			map.put("device", ToolUtil.isNotEmpty(driverId) ? 2 : 1);
			map.put("orderType", 1);
			return map;
			}

			/**
			* 获取服务中的订单数据
			* @param uid
			* @return
			* @throws Exception
			*/
			@Override
			public OrderServerWarpper queryOrderServer(Integer orderId, Integer uid) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			if(null == orderPrivateCar){
			return orderTaxiService.queryOrderServer(orderId, uid);
			}
			//计算预计距离和剩余时间
			String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(orderPrivateCar.getDriverId()));
			if(null == value \|\| "".equals(value)){
			System.err.println("司机没有上传位置信息");

			//调用获取轨迹中的数据
			List<Map<String, Object>> list = orderPositionService.queryTrack(orderId, 2);
			if(list.size() > 0){
			Map<String, Object> map = list.get(list.size() - 1);
			value = map.get("lon") + "," + map.get("lat");
			}

			}

			OrderServerWarpper orderServerWarpper = new OrderServerWarpper();
			orderServerWarpper.setOrderId(orderPrivateCar.getId());
			orderServerWarpper.setOrderType(1);
			orderServerWarpper.setState(orderPrivateCar.getState());
			orderServerWarpper.setLon(null != value ? value.split(",")[0] : "0.0");
			orderServerWarpper.setLat(null != value ? value.split(",")[1] : "0.0");
			orderServerWarpper.setReassignNotice(orderPrivateCar.getReassignNotice());
			if(orderPrivateCar.getState() == 2 \|\| orderPrivateCar.getState() == 3){//前往预约地
			// TODO: 2023/11/4 无法修改
			Map<String, String> distance = gdMapElectricFenceUtil.getDistance(value, orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), 1);
			String d = "0";
			String t = "0";
			if(null == distance){
			System.err.println("查询距离出错了");
			}else{
			d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString();
			t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + "";
			}
			orderServerWarpper.setReservationMileage(d);
			orderServerWarpper.setReservationTime(t);
			orderServerWarpper.setServedMileage("0");
			orderServerWarpper.setServedTime("0");
			orderServerWarpper.setLaveMileage("0");
			orderServerWarpper.setLaveTime("0");
			}
			if(orderPrivateCar.getState() == 5 \|\| orderPrivateCar.getState() == 6){//服务中
			// TODO: 2023/11/4 无法修改
			Map<String, String> distance = gdMapElectricFenceUtil.getDistance(value, orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
			String d = "0";
			String t = "0";
			if(null == distance){
			System.err.println("查询距离出错了");
			}else{
			d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString();
			t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + "";
			}
			orderServerWarpper.setReservationMileage("0");
			orderServerWarpper.setReservationTime("0");
			orderServerWarpper.setServedMileage(String.valueOf((null == orderPrivateCar.getMileage() ? 0 : orderPrivateCar.getMileage()) / 1000));
			orderServerWarpper.setServedTime(Long.valueOf((new Date().getTime() - orderPrivateCar.getStartServiceTime().getTime()) / 60000).intValue() + "");
			orderServerWarpper.setLaveMileage(d);
			orderServerWarpper.setLaveTime(t);
			}

			return orderServerWarpper;
			}





			@Override
			public synchronized String getOrderNum() throws Exception{
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
			return "PR" + sdf.format(new Date()) + UUIDUtil.getRandomCode(5);
			}

			/**
			* 删除定时任务
			* @param orderId
			*/
			@Override
			public void deleteTask(Integer orderId){
			//发送验证码短信
			HttpHeaders headers = new HttpHeaders();
			// 以表单的方式提交
			headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
			//将请求头部和参数合成一个请求
			MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
			params.add("orderId", orderId + "");
			params.add("orderType", "1");
			HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(params, headers);
			String s = internalRestTemplate.postForObject("http://driver-server/base/netty/deleteTask", requestEntity, String.class);
			JSONObject jsonObject = JSON.parseObject(s, JSONObject.class);
			if(jsonObject.getIntValue("code") != 200){
			System.err.println("调用driver-server出错了");
			}
			}

			@Override
			public Map<String, Object> queryBalance(Integer orderId, Integer uid) throws Exception {
			Map<String, Object> map = new HashMap<>();
			UserInfo userInfo = userInfoService.selectById(uid);
			map.put("balance", userInfo.getBalance());
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			int i = userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney());
			i = i + userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney());
			map.put("coupon", i);
			return map;
			}

			@Override
			public PreferentialDataVo queryBalance1(Integer orderId, Integer uid) throws Exception {
			UserInfo userInfo = userInfoService.selectById(uid);
			PreferentialDataVo preferentialDataVo = new PreferentialDataVo();
			preferentialDataVo.setBalance(userInfo.getBalance());
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			Integer ids = userInfoService.getDiscount();
			if(ids!=null){
			List<UserActivityDiscount1> userActivityId = userActivityDiscount1Mapper.selectList(new EntityWrapper<UserActivityDiscount1>().eq("userActivityId", ids));
			if(userActivityId.size()>0){

			preferentialDataVo.setDiscount(userActivityId.get(0).getSpecial());
			}
			}
			// 查出当前用户的红包并将订单的修改
			List<UserRedPacketRecord> userRedPacketRecords = userRedPacketRecordService.selectList(new EntityWrapper<UserRedPacketRecord>().eq("userId", uid).eq("state", 1).gt("expirationTime", new Date()).gt("endTime", new Date()));
			if(userRedPacketRecords.size()>0){

			preferentialDataVo.setRedPacket(userRedPacketRecords.get(0).getMoney());
			orderPrivateCar.setRedPacketId(userRedPacketRecords.get(0).getId());
			orderPrivateCar.setRedPacketMoney(userRedPacketRecords.get(0).getMoney());
			this.updateById(orderPrivateCar);
			}


			//获取优惠券中最优数据
			List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderPrivateCar.getCompanyId()).eq("state", 1).le("money",orderPrivateCar.getOrderMoney()).in("couponUseType", Arrays.asList(0, 1)).eq("userId", uid).where("now() < expirationTime"));
			Integer id = null;
			Double price = 0d;
			Integer type = 0;
			for (UserCouponRecord userCouponRecord : list){
			if(userCouponRecord.getCouponType() == 1){//抵扣券
			if(price.compareTo(userCouponRecord.getMoney()) < 0){
			price = userCouponRecord.getMoney();
			id = userCouponRecord.getId();
			type = 1;
			}
			}else{//满减券
			if(orderPrivateCar.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) >= 0 && price.compareTo(userCouponRecord.getMoney()) < 0){
			price = userCouponRecord.getMoney();
			id = userCouponRecord.getId();
			type = 1;
			}
			}
			}

			//获取打车卡中最优数
			Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
			if(null == companyCity){
			companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
			}
			if(null == companyCity){
			companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
			}
			List<UserTaxiCard> userTaxiCards =new ArrayList<>();
			if(companyCity!=null) {
			userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().like("companyCityId", "%" + companyCity.getId() + "%")
			.in("type", Arrays.asList(1, 2, 3, 4)).eq("userId", uid).where("now() between startTime and endTime"));
			}
			//全国卡
			List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
			if(taxiCards.size() > 0) {
			List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
			.in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
			userTaxiCards.addAll(userTaxiCards2);
			}
			//亲密账户中有相同的卡优先使用自己的
			// 因为比对中只有优惠金额最高的才会被替换，所以先查找自己的数据再查找亲密账户的数据
			Map<String, Object> map = getOptimalTaxiCards(orderPrivateCar, price, id, type, userTaxiCards);
			price = Double.valueOf(map.get("price").toString());
			id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
			type = Integer.valueOf(map.get("type").toString());

			//亲密账户
			List<UserTaxiCard> userTaxiCards_ = new ArrayList<>();
			List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
			CompanyCity finalCompanyCity = companyCity;
			bindUserId.forEach(userUser -> {
			if(finalCompanyCity!=null) {
			List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(1, 2, 3, 4))
			.like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
			userTaxiCards_.addAll(userTaxiCards1);
			}

			//全国卡
			if(taxiCards.size() > 0) {
			List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
			.in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
			userTaxiCards_.addAll(userTaxiCards2);
			}
			});
			map = getOptimalTaxiCards(orderPrivateCar, price, id, type, userTaxiCards_);
			price = Double.valueOf(map.get("price").toString());
			id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
			type = Integer.valueOf(map.get("type").toString());
			System.out.println(price);
			System.out.println(orderPrivateCar.getOrderMoney());
			System.out.println(type);

			if(orderPrivateCar.getOrderMoney()!=null && price<=orderPrivateCar.getOrderMoney() \|\| type==2){
			preferentialDataVo.setDiscountAmount(price);
			preferentialDataVo.setType(type);
			preferentialDataVo.setObjectId(id);
			}
			return preferentialDataVo;
			}


			/**
			* 获取最优打车卡数据
			* @param orderPrivateCar
			* @param price
			* @param id
			* @param type
			* @param userTaxiCards
			* @throws Exception
			*/
			public Map<String, Object> getOptimalTaxiCards(OrderPrivateCar orderPrivateCar, Double price, Integer id, Integer type, List<UserTaxiCard> userTaxiCards) throws Exception{
			Map<String, Object> map = new HashMap<>();
			for(UserTaxiCard t : userTaxiCards){
			JSONObject jsonObject = JSON.parseObject(t.getContent());
			List<Integer> integers = jsonObject.getJSONArray("businessTypes").toJavaList(Integer.class);
			if(!integers.contains(1)){
			continue;
			}
			if(t.getType() == 1){//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
			Integer time = jsonObject.getInteger("time");
			if(time == 0){
			continue;
			}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			Double discount = jsonObject.getDouble("discount");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			double v = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
			if(price.compareTo(v) < 0){
			price = v;
			id = t.getId();
			type = 2;
			}
			if(price.compareTo(v) < 0){
			price = v;
			id = t.getId();
			type = 2;
			}
			}
			}

			}
			if(t.getType() == 2){//优惠卡{"businessTypes":[1,2,3],"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"fullReduction":[[50,3],[100,5],[150,10]]}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			for(int j = fullReduction.size() - 1; j >= 0; j--){
			JSONArray jsonArray = fullReduction.getJSONArray(j);
			Double p = jsonArray.getDouble(0);//满金额
			Double y = jsonArray.getDouble(1);//优惠金额
			if(orderPrivateCar.getOrderMoney().compareTo(p) >= 0 && price.compareTo(y) < 0){
			price = y;
			id = t.getId();
			type = 2;
			}
			}
			}
			}
			}
			if(t.getType() == 3){//次数卡{"businessTypes":[1,2,3],"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"time":1,"discountAmount":10}
			Integer time = jsonObject.getInteger("time");
			if(time == 0){
			continue;
			}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			Double discountAmount = jsonObject.getDouble("discountAmount");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			if(price.compareTo(discountAmount) < 0){
			price = discountAmount;
			id = t.getId();
			type = 2;
			}
			}
			}
			}
			if(t.getType() == 4){//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
			Double discount = jsonObject.getDouble("discount");//折扣
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			double v = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
			if(price.compareTo(v) < 0){
			price = v;
			id = t.getId();
			type = 2;
			}
			}
			}
			}
			}
			map.put("price", price);
			map.put("id", id);
			map.put("type", type);
			return map;
			}




			@Override
			public List<Map<String, Object>> queryCoupon(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			List<Map<String, Object>> list = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney(), pageNum, size);
			List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney(), pageNum, size);
			list.addAll(list1);
			return list;
			}

			@Override
			public List<CouponsListVo> queryCouponList(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
			pageNum = (pageNum - 1) * size;
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			List<CouponsListVo> rows = new ArrayList<>();
			List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderPrivateCar.getCompanyId())
			.eq("state", 1).in("couponUseType", Arrays.asList(0, 1)).eq("userId", uid).where("expirationTime >= now()"));
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			for (UserCouponRecord userCouponRecord : list){
			if(userCouponRecord.getCouponType() == 2){//满减券
			if(orderPrivateCar.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) < 0){
			continue;
			}
			}
			CouponsListVo couponsListVo = new CouponsListVo();
			couponsListVo.setId(userCouponRecord.getId());
			couponsListVo.setDataType(1);
			couponsListVo.setMoney(userCouponRecord.getMoney());
			couponsListVo.setUserType(userCouponRecord.getCouponUseType());
			couponsListVo.setTime(sdf.format(userCouponRecord.getExpirationTime()));
			couponsListVo.setType(userCouponRecord.getCouponType());
			couponsListVo.setFullMoney(userCouponRecord.getFullMoney());
			couponsListVo.setState(userCouponRecord.getState());
			Company company = companyService.selectById(userCouponRecord.getCompanyId());
			couponsListVo.setCompany(company.getName());
			rows.add(couponsListVo);
			}

			Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
			if(null == companyCity){
			companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
			}
			if(null == companyCity){
			companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
			}
			List<UserTaxiCard> userTaxiCards ;
			if(companyCity!=null){
			userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
			.in("type", Arrays.asList(1, 2, 3, 4)).like("companyCityId", "%" + companyCity.getId() + "%").where("now() between startTime and endTime"));
			}else {
			userTaxiCards =new ArrayList<>();
			}

			//全国卡
			List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
			if(taxiCards.size() > 0) {
			List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
			.in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
			userTaxiCards.addAll(userTaxiCards1);
			}


			//亲密账户
			List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
			CompanyCity finalCompanyCity = companyCity;
			bindUserId.forEach(userUser -> {
			if(finalCompanyCity!=null) {
			List<UserTaxiCard> taxiCardPayments1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(1, 2, 3, 4))
			.like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
			userTaxiCards.addAll(taxiCardPayments1);
			}

			//全国卡
			if(taxiCards.size() > 0) {
			List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
			.in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
			userTaxiCards.addAll(userTaxiCards1);
			}
			});

			for(UserTaxiCard t : userTaxiCards){
			try {
			CouponsListVo couponsListVo = new CouponsListVo();
			couponsListVo.setId(t.getId());
			couponsListVo.setDataType(2);
			couponsListVo.setUserType(1);
			couponsListVo.setTime(sdf.format(t.getEndTime()));
			couponsListVo.setState(1);
			couponsListVo.setTaxiCardType(t.getType());
			Company company = companyService.selectById(t.getCompanyId());
			couponsListVo.setCompany(company.getName());
			couponsListVo.setName(taxiCardService.selectById(t.getTaxiCardId()).getName());


			JSONObject jsonObject = JSON.parseObject(t.getContent());
			JSONArray businessTypes = jsonObject.getJSONArray("businessTypes");
			if(!businessTypes.toJavaList(Integer.class).contains(1)){
			continue;
			}
			if(t.getType() == 1){//{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
			Integer time = jsonObject.getInteger("time");
			if(time == 0){
			continue;
			}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
			boolean b = true;
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
			Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			b = false;
			break;
			}
			}
			if(b){
			continue;
			}
			couponsListVo.setMoney(jsonObject.getDouble("discount"));
			couponsListVo.setType(1);
			}
			if(t.getType() == 2){//{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
			boolean b = true;
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
			Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			b = false;
			break;
			}
			}
			if(b){
			continue;
			}
			JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
			b = true;
			for(int i = fullReduction.size() - 1; i >= 0; i--){
			JSONArray jsonArray = fullReduction.getJSONArray(i);
			Double m = jsonArray.getDouble(0);
			Double j = jsonArray.getDouble(1);
			if(orderPrivateCar.getOrderMoney().compareTo(m) >= 0){
			couponsListVo.setFullMoney(m);
			couponsListVo.setMoney(j);
			b = false;
			break;
			}
			}
			if(b){
			continue;
			}
			couponsListVo.setType(2);
			}
			if(t.getType() == 3){//{"businessTypes":[1,2,3],"time":1,"discountAmount":10}
			Integer time = jsonObject.getInteger("time");
			if(time == 0){
			continue;
			}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
			boolean b = true;
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
			Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			b = false;
			break;
			}
			}
			if(b){
			continue;
			}
			couponsListVo.setFullMoney(0D);
			couponsListVo.setMoney(jsonObject.getDouble("discountAmount"));
			couponsListVo.setType(2);
			}
			if(t.getType() == 4){//{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
			boolean b = true;
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
			Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			b = false;
			break;
			}
			}
			if(b){
			continue;
			}
			couponsListVo.setMoney(jsonObject.getDouble("discount"));
			couponsListVo.setType(1);
			}


			String str = "";
			TaxiCard taxiCard = taxiCardService.selectById(t.getTaxiCardId());
			if(taxiCard.getTaxiCardType() == 1){
			String[] split = taxiCard.getCompanyCityId().split(";");
			for(String c : split){
			CompanyCity companyCity1 = companyCityService.selectById(c);
			if(ToolUtil.isNotEmpty(companyCity1.getAreaCode())){
			Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getAreaCode()));
			str += region.getName() + ";";
			continue;
			}
			if(ToolUtil.isNotEmpty(companyCity1.getCityCode())){
			Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getCityCode()));
			str += region.getName() + ";";
			continue;
			}
			if(ToolUtil.isNotEmpty(companyCity1.getProvinceCode())){
			Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getProvinceCode()));
			str += region.getName() + ";";
			continue;
			}
			}
			}else{
			str = "全国;";
			}
			couponsListVo.setCity(str.substring(0, str.length() - 1));


			rows.add(couponsListVo);
			}catch (Exception e){
			e.printStackTrace();
			}
			}
			Collections.sort(rows, new Comparator<CouponsListVo>() {
			public int compare(CouponsListVo s1, CouponsListVo s2) {
			return Integer.compare(s1.getId(), s2.getId());
			}
			});

			if(rows.size() >= (pageNum + 1) * size){
			rows = rows.subList(pageNum, pageNum + size);
			}else if(pageNum < rows.size() && rows.size() < (pageNum + 1) * size){
			rows = rows.subList(pageNum, rows.size());
			}else{
			rows = new ArrayList<>();
			}
			System.out.println(rows);
			System.out.println(orderPrivateCar.getOrderMoney());
			rows = rows.stream().filter(e->e.getMoney()<=orderPrivateCar.getOrderMoney() \|\| e.getDataType()==2).collect(Collectors.toList());
			System.out.println(rows);
			return rows;
			}

			@Override
			public ResultUtil payPrivateCarOrder(Integer payType, Integer orderId, Integer couponId, Integer type) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			if(orderPrivateCar.getState() == 8 \|\| orderPrivateCar.getState() == 9){
			return ResultUtil.error("订单已完成支付，不允许重复支付", "");
			}
			if(orderPrivateCar.getState() != 7){
			return ResultUtil.error("订单不在待支付状态，不允许支付", "");
			}
			Integer uid = orderPrivateCar.getUserId();
			Double orderMoney = orderPrivateCar.getOrderMoney();
			UserInfo userInfo = userInfoService.selectById(uid);
			ResultUtil resultUtil = ResultUtil.success(new Object());
			orderPrivateCar.setCouponMoney(0D);//初始化历史数据
			orderPrivateCar.setCouponId(null);

			//计算优惠券
			UserCouponRecord userCouponRecord = null;
			if(null != couponId){
			userCouponRecord = userCouponRecordService.selectById(couponId);
			if(userCouponRecord.getCompanyId() != orderPrivateCar.getCompanyId()){
			return ResultUtil.error("优惠券不能用于此订单", "");
			}
			if(userCouponRecord.getState() == 2){
			return ResultUtil.error("优惠券已使用", "");
			}
			if(userCouponRecord.getState() == 3){
			return ResultUtil.error("优惠券已过期", "");
			}
			if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1){
			return ResultUtil.error("优惠券不能用于此类型订单", "");
			}
			if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){
			return ResultUtil.error("优惠券不能用于此订单", "");
			}
			orderMoney = orderMoney - userCouponRecord.getMoney();
			orderPrivateCar.setCouponMoney(userCouponRecord.getMoney());
			orderPrivateCar.setCouponId(couponId);
			}


			//计算红包
			UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
			if(null != query && query.getMoney().compareTo(orderMoney) < 0){
			orderMoney = orderMoney - query.getMoney();
			orderPrivateCar.setRedPacketMoney(query.getMoney());
			orderPrivateCar.setRedPacketId(query.getId());
			}

			//计算折扣
			UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
			if(null != query2){
			Double special = query2.getSpecial();
			orderPrivateCar.setDiscount(special);
			double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
			if(orderMoney.compareTo(v) > 0){
			orderPrivateCar.setDiscountMoney(orderMoney - v);
			orderPrivateCar.setActivityId(query2.getId());
			orderMoney = v;
			}
			}
			orderMoney = orderMoney < 0 ? 0 : orderMoney;
			if(payType == 1){//微信支付
			String app = type == 1 ? "APP" : "JSAPI";
			resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据
			}
			if(payType == 2) {//支付宝支付
			resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 2, orderMoney, "", 1);//添加预支付数据
			}
			if(payType == 3){//余额支付
			if(userInfo.getBalance() == null \|\| userInfo.getBalance() < orderMoney){
			return ResultUtil.error("余额不足，无法完成支付", "");
			}

			userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());

			SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
			userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分

			//添加交易明细
			transactionDetailsService.saveData(uid, "快车订单", orderMoney, 2, 1, 1, 1, orderId);
			userInfoService.updateById(userInfo);

			orderPrivateCar.setState(8);
			orderPrivateCar.setPayType(3);
			orderPrivateCar.setPayMoney(orderMoney);

			//处理优惠券和红包
			if(null != userCouponRecord){
			userCouponRecord.setState(2);
			userCouponRecord.setEndTime(new Date());
			userCouponRecordService.updateById(userCouponRecord);
			}
			if(null != query){
			query.setState(2);
			query.setEndTime(new Date());
			userRedPacketRecordService.updateById(query);
			}
			//添加收入
			Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
			orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));

			// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			}
			}).start();

			systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付，谢谢使用！", uid, 1);

			new Thread(new Runnable() {
			@Override
			public void run() {
			if(pushMinistryOfTransport){//上传数据
			pushMinistryOfTransportUtil.operatePay(orderId);
			}
			}
			}).start();
			}

			this.updateAllColumnById(orderPrivateCar);
			return resultUtil;
			}


			@Override
			@Transactional(propagation = Propagation.REQUIRES_NEW)
			public ResultUtil payPrivateCarOrder1(Integer payType, Integer orderId, Integer objectId, Integer objectType, Integer type) throws Exception {

			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			if(orderPrivateCar.getState() == 8 \|\| orderPrivateCar.getState() == 9){
			return ResultUtil.error("订单已完成支付，不允许重复支付", new ArrayList<>());
			}
			if(orderPrivateCar.getState() != 7){
			return ResultUtil.error("订单不在待支付状态，不允许支付", new ArrayList<>());
			}
			Integer uid = orderPrivateCar.getUserId();
			Double orderMoney = orderPrivateCar.getOrderMoney();
			UserInfo userInfo = userInfoService.selectById(uid);
			ResultUtil resultUtil = ResultUtil.success(new Object());
			orderPrivateCar.setCouponMoney(0D);//初始化历史数据
			orderPrivateCar.setCouponId(null);
			System.out.println("!!!"+orderMoney+"!!!!");
			//计算优惠券
			UserCouponRecord userCouponRecord = null;
			if(null != objectId && objectType == 1){
			userCouponRecord = userCouponRecordService.selectById(objectId);
			if(userCouponRecord.getCompanyId() != orderPrivateCar.getCompanyId()){
			return ResultUtil.error("优惠券不能用于此订单", new ArrayList<>());
			}
			if(userCouponRecord.getState() == 2){
			return ResultUtil.error("优惠券已使用", new ArrayList<>());
			}
			if(userCouponRecord.getState() == 3){
			return ResultUtil.error("优惠券已过期", new ArrayList<>());
			}
			if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1){
			return ResultUtil.error("优惠券不能用于此类型订单", new ArrayList<>());
			}
			if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){
			return ResultUtil.error("优惠券不能用于此订单", new ArrayList<>());
			}
			orderMoney = orderMoney - userCouponRecord.getMoney();
			orderPrivateCar.setCouponMoney(userCouponRecord.getMoney());
			orderPrivateCar.setCouponId(objectId);
			System.out.println("!!!"+orderMoney+"!!!!");
			}

			//打车卡
			UserTaxiCard userTaxiCard = null;
			if(null != objectId && objectType == 2){
			userTaxiCard = userTaxiCardService.selectById(objectId);
			TaxiCard taxiCard = taxiCardService.selectById(userTaxiCard.getTaxiCardId());
			if(taxiCard.getTaxiCardType() == 1 && userTaxiCard.getCompanyId() != orderPrivateCar.getCompanyId()){
			return ResultUtil.error("打车卡不能用于此订单", new ArrayList<>());
			}
			if(System.currentTimeMillis() > userTaxiCard.getEndTime().getTime()){
			return ResultUtil.error("打车卡已过期", new ArrayList<>());
			}
			if(userTaxiCard.getType() == 1 \|\| userTaxiCard.getType() == 3){
			Integer time = JSON.parseObject(userTaxiCard.getContent()).getInteger("time");
			if(0 == time){
			return ResultUtil.error("打车卡已使用完", new ArrayList<>());
			}
			}
			List<Integer> integers = JSON.parseObject(userTaxiCard.getContent()).getJSONArray("businessTypes").toJavaList(Integer.class);
			if(!integers.contains(1)){
			return ResultUtil.error("打车卡不能用于此类型订单", new ArrayList<>());
			}

			Double yh = 0D;
			JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
			if(userTaxiCard.getType() == 1){//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			Double discount = jsonObject.getDouble("discount");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			yh = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
			jsonObject.put("time", jsonObject.getInteger("time") - 1);
			userTaxiCard.setContent(jsonObject.toJSONString());
			break;
			}
			}

			}
			if(userTaxiCard.getType() == 2){//优惠卡{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			for(int j = fullReduction.size() - 1; j >= 0; j--){
			JSONArray jsonArray = fullReduction.getJSONArray(j);
			Double p = jsonArray.getDouble(0);//满金额
			if(orderPrivateCar.getOrderMoney().compareTo(p) >= 0){
			yh = jsonArray.getDouble(1);//优惠金额
			break;
			}
			}
			}
			}

			}
			if(userTaxiCard.getType() == 3){//次数卡{"businessTypes":[1,2,3],"time":1,"discountAmount":10}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			yh = jsonObject.getDouble("discountAmount");
			jsonObject.put("time", jsonObject.getInteger("time") - 1);
			userTaxiCard.setContent(jsonObject.toJSONString());
			}
			}

			}
			if(userTaxiCard.getType() == 4){//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
			Double discount = jsonObject.getDouble("discount");//折扣
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for(int i = 0; i < timeQuantum.size(); i++){
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if(s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()){
			yh = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
			break;
			}
			}
			}

			orderMoney = orderMoney - yh;
			orderPrivateCar.setTaxiCardId(userTaxiCard.getTaxiCardId());
			orderPrivateCar.setUserTaxiCardId(objectId);
			orderPrivateCar.setDiscountAmount(yh);
			}

			System.out.println("!!!"+orderMoney+"!!!!");

			//计算红包
			UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
			if(null != query && query.getMoney().compareTo(orderMoney) < 0){
			orderMoney = orderMoney - query.getMoney();
			orderPrivateCar.setRedPacketMoney(query.getMoney());
			orderPrivateCar.setRedPacketId(query.getId());
			}

			System.out.println("!!!"+orderMoney+"!!!!");
			//计算折扣
			UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
			if(null != query2){
			Double special = query2.getSpecial();
			orderPrivateCar.setDiscount(special);
			double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
			if(orderMoney.compareTo(v) > 0){
			orderPrivateCar.setDiscountMoney(orderMoney - v);
			orderPrivateCar.setActivityId(query2.getId());
			orderMoney = v;
			}
			}
			orderMoney = new BigDecimal(orderMoney).setScale(2, RoundingMode.HALF_UP).doubleValue();
			System.out.println("!!!"+orderMoney+"!!!!");
			orderMoney = orderMoney < 0 ? 0 : orderMoney;
			if(payType == 1){//微信支付
			if(orderMoney == 0){
			return ResultUtil.error("请使用余额支付");
			}
			String app = type == 1 ? "APP" : "JSAPI";
			resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据
			}
			if(payType == 2) {//支付宝支付
			if(orderMoney == 0){
			return ResultUtil.error("请使用余额支付");
			}
			resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 2, orderMoney, "", 1);//添加预支付数据
			}
			if(payType == 3){//余额支付
			if(userInfo.getBalance() == null \|\| userInfo.getBalance() < orderMoney){
			return ResultUtil.error("余额不足，无法完成支付");
			}
			userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(query.getMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			//添加交易明细
			transactionDetailsService.saveData(uid, "快车取消订单", query.getMoney(), 2, 1, 1, 1, id);
			userInfoService.updateById(userInfo);

			//解除小号绑定
			if (orderPrivateCar.getBindId() != null) {
			chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 600000));
			}

			orderPrivateCar.setState(10);
			orderPrivateCar.setTelX("");
			orderPrivateCar.setBindId("");
			this.updateById(orderPrivateCar);

			orderCancel.setState(2);
			orderCancel.setPayType(3);
			orderCancelService.updateById(orderCancel);

			//添加已收入明细
			incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, query.getMoney());

			this.deleteTask(id);//删除定时任务

			//添加消息
			systemNoticeService.addSystemNotice(1, "您已使用余额成功支付取消订单费用，谢谢使用！", orderPrivateCar.getUserId(), 1);

			} else if (payType == 4) {
			Double payMoney = orderPrivateCar.getOrderMoney();
			Integer integer = paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, id, 1, 4, query.getMoney(), "", 1);
			resultUtil = appOrderController.placeAnOrder(new BigDecimal(query.getMoney()), 4, id, 1, integer);

			}
			}
			return resultUtil;
			}


			@Override
			public Map<String, Object> queryOrderInfo(Integer uid, Integer orderId) throws Exception {
			Map<String, Object> map = orderPrivateCarMapper.queryOrderInfo(orderId);
			if(null == map){
			OrderTaxi orderTaxi = orderTaxiService.selectOne(new EntityWrapper<OrderTaxi>()
			.eq("userId", uid)
			.eq("isDelete", 1)
			.in("state", Arrays.asList(2, 3, 4, 5, 6, 7))
			);
			return orderTaxiService.queryOrderInfo(orderTaxi.getId());
			}
			if(null != map.get("reassignNotice") && Integer.valueOf(String.valueOf(map.get("reassignNotice"))) == 2){//改派完成，重新获取了新的司机数据，开始修改数据防止继续调用
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			orderPrivateCar.setReassignNotice(0);
			this.updateById(orderPrivateCar);
			}
			if(Integer.valueOf(String.valueOf(map.get("state"))) == 11){
			map.put("state", map.get("oldState"));
			}
			if(Integer.valueOf(String.valueOf(map.get("state"))) ==7 && (map.get("responsibilityType")==null \|\| Integer.valueOf(String.valueOf(map.get("responsibilityType")))<4)){
			map.put("appealButton", 1);
			}
			if(map.get("abnormalIntro")!=null){
			map.put("appealStatus", 1);
			}


			if(Integer.valueOf(String.valueOf(map.get("state"))) != 8 && Integer.valueOf(String.valueOf(map.get("state"))) != 9){
			map.put("redPacketMoney", null);
			map.put("couponMoney", null);
			}

			String driverId = (String) redisTemplate.opsForValue().get("DEVICE_" + map.get("driverId"));
			map.put("device", ToolUtil.isNotEmpty(driverId) ? 2 : 1);
			map.put("orderType", 1);
			return map;
			}

			/**
			* 获取服务中的订单数据
			* @param uid
			* @return
			* @throws Exception
			*/
			@Override
			public OrderServerWarpper queryOrderServer(Integer orderId, Integer uid) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			if(null == orderPrivateCar){
			return orderTaxiService.queryOrderServer(orderId, uid);
			}
			//计算预计距离和剩余时间
			String value = (String) redisTemplate.opsForValue().get("DRIVER" + String.valueOf(orderPrivateCar.getDriverId()));
			if(null == value \|\| "".equals(value)){
			System.err.println("司机没有上传位置信息");

			//调用获取轨迹中的数据
			List<Map<String, Object>> list = orderPositionService.queryTrack(orderId, 2);
			if(list.size() > 0){
			Map<String, Object> map = list.get(list.size() - 1);
			value = map.get("lon") + "," + map.get("lat");
			}

			}

			OrderServerWarpper orderServerWarpper = new OrderServerWarpper();
			orderServerWarpper.setOrderId(orderPrivateCar.getId());
			orderServerWarpper.setOrderType(1);
			orderServerWarpper.setState(orderPrivateCar.getState());
			orderServerWarpper.setLon(null != value ? value.split(",")[0] : "0.0");
			orderServerWarpper.setLat(null != value ? value.split(",")[1] : "0.0");
			orderServerWarpper.setReassignNotice(orderPrivateCar.getReassignNotice());
			if(orderPrivateCar.getState() == 2 \|\| orderPrivateCar.getState() == 3){//前往预约地
			// TODO: 2023/11/4 无法修改
			Map<String, String> distance = gdMapElectricFenceUtil.getDistance(value, orderPrivateCar.getStartLon() + "," + orderPrivateCar.getStartLat(), 1);
			String d = "0";
			String t = "0";
			if(null == distance){
			System.err.println("查询距离出错了");
			}else{
			d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString();
			t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + "";
			}
			orderServerWarpper.setReservationMileage(d);
			orderServerWarpper.setReservationTime(t);
			orderServerWarpper.setServedMileage("0");
			orderServerWarpper.setServedTime("0");
			orderServerWarpper.setLaveMileage("0");
			orderServerWarpper.setLaveTime("0");
			}
			if(orderPrivateCar.getState() == 5 \|\| orderPrivateCar.getState() == 6){//服务中
			// TODO: 2023/11/4 无法修改
			Map<String, String> distance = gdMapElectricFenceUtil.getDistance(value, orderPrivateCar.getEndLon() + "," + orderPrivateCar.getEndLat(), 1);
			String d = "0";
			String t = "0";
			if(null == distance){
			System.err.println("查询距离出错了");
			}else{
			d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString();
			t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + "";
			}
			orderServerWarpper.setReservationMileage("0");
			orderServerWarpper.setReservationTime("0");
			orderServerWarpper.setServedMileage(String.valueOf((null == orderPrivateCar.getMileage() ? 0 : orderPrivateCar.getMileage()) / 1000));
			orderServerWarpper.setServedTime(Long.valueOf((new Date().getTime() - orderPrivateCar.getStartServiceTime().getTime()) / 60000).intValue() + "");
			orderServerWarpper.setLaveMileage(d);
			orderServerWarpper.setLaveTime(t);
			}

			return orderServerWarpper;
			}


			@Override
			public synchronized String getOrderNum() throws Exception {
			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
			return "PR" + sdf.format(new Date()) + UUIDUtil.getRandomCode(5);
			}

			/**
			* 删除定时任务
			*
			* @param orderId
			*/
			@Override
			public void deleteTask(Integer orderId) {
			//发送验证码短信
			HttpHeaders headers = new HttpHeaders();
			// 以表单的方式提交
			headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
			//将请求头部和参数合成一个请求
			MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
			params.add("orderId", orderId + "");
			params.add("orderType", "1");
			HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(params, headers);
			String s = internalRestTemplate.postForObject("http://driver-server/base/netty/deleteTask", requestEntity, String.class);
			JSONObject jsonObject = JSON.parseObject(s, JSONObject.class);
			if (jsonObject.getIntValue("code") != 200) {
			System.err.println("调用driver-server出错了");
			}
			}

			@Override
			public Map<String, Object> queryBalance(Integer orderId, Integer uid) throws Exception {
			Map<String, Object> map = new HashMap<>();
			UserInfo userInfo = userInfoService.selectById(uid);
			map.put("balance", userInfo.getBalance());
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			int i = userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney());
			i = i + userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney());
			map.put("coupon", i);
			return map;
			}

			@Override
			public PreferentialDataVo queryBalance1(Integer orderId, Integer uid) throws Exception {
			UserInfo userInfo = userInfoService.selectById(uid);
			PreferentialDataVo preferentialDataVo = new PreferentialDataVo();
			preferentialDataVo.setBalance(userInfo.getBalance());
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			Integer ids = userInfoService.getDiscount();
			if (ids != null) {
			List<UserActivityDiscount1> userActivityId = userActivityDiscount1Mapper.selectList(new EntityWrapper<UserActivityDiscount1>().eq("userActivityId", ids));
			if (userActivityId.size() > 0) {

			preferentialDataVo.setDiscount(userActivityId.get(0).getSpecial());
			}
			}
			// 查出当前用户的红包并将订单的修改
			List<UserRedPacketRecord> userRedPacketRecords = userRedPacketRecordService.selectList(new EntityWrapper<UserRedPacketRecord>().eq("userId", uid).eq("state", 1).gt("expirationTime", new Date()).gt("endTime", new Date()));
			if (userRedPacketRecords.size() > 0) {

			preferentialDataVo.setRedPacket(userRedPacketRecords.get(0).getMoney());
			orderPrivateCar.setRedPacketId(userRedPacketRecords.get(0).getId());
			orderPrivateCar.setRedPacketMoney(userRedPacketRecords.get(0).getMoney());
			this.updateById(orderPrivateCar);
			}


			//获取优惠券中最优数据
			List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderPrivateCar.getCompanyId()).eq("state", 1).le("money", orderPrivateCar.getOrderMoney()).in("couponUseType", Arrays.asList(0, 1)).eq("userId", uid).where("now() < expirationTime"));
			Integer id = null;
			Double price = 0d;
			Integer type = 0;
			for (UserCouponRecord userCouponRecord : list) {
			if (userCouponRecord.getCouponType() == 1) {//抵扣券
			if (price.compareTo(userCouponRecord.getMoney()) < 0) {
			price = userCouponRecord.getMoney();
			id = userCouponRecord.getId();
			type = 1;
			}
			} else {//满减券
			if (orderPrivateCar.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) >= 0 && price.compareTo(userCouponRecord.getMoney()) < 0) {
			price = userCouponRecord.getMoney();
			id = userCouponRecord.getId();
			type = 1;
			}
			}
			}

			//获取打车卡中最优数
			Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
			if (null == companyCity) {
			companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
			}
			if (null == companyCity) {
			companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
			}
			List<UserTaxiCard> userTaxiCards = new ArrayList<>();
			if (companyCity != null) {
			userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().like("companyCityId", "%" + companyCity.getId() + "%")
			.in("type", Arrays.asList(1, 2, 3, 4)).eq("userId", uid).where("now() between startTime and endTime"));
			}
			//全国卡
			List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
			if (taxiCards.size() > 0) {
			List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
			.in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
			userTaxiCards.addAll(userTaxiCards2);
			}
			//亲密账户中有相同的卡优先使用自己的
			// 因为比对中只有优惠金额最高的才会被替换，所以先查找自己的数据再查找亲密账户的数据
			Map<String, Object> map = getOptimalTaxiCards(orderPrivateCar, price, id, type, userTaxiCards);
			price = Double.valueOf(map.get("price").toString());
			id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
			type = Integer.valueOf(map.get("type").toString());

			//亲密账户
			List<UserTaxiCard> userTaxiCards_ = new ArrayList<>();
			List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
			CompanyCity finalCompanyCity = companyCity;
			bindUserId.forEach(userUser -> {
			if (finalCompanyCity != null) {
			List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(1, 2, 3, 4))
			.like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
			userTaxiCards_.addAll(userTaxiCards1);
			}

			//全国卡
			if (taxiCards.size() > 0) {
			List<UserTaxiCard> userTaxiCards2 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
			.in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
			userTaxiCards_.addAll(userTaxiCards2);
			}
			});
			map = getOptimalTaxiCards(orderPrivateCar, price, id, type, userTaxiCards_);
			price = Double.valueOf(map.get("price").toString());
			id = null != map.get("id") ? Integer.valueOf(map.get("id").toString()) : null;
			type = Integer.valueOf(map.get("type").toString());
			System.out.println(price);
			System.out.println(orderPrivateCar.getOrderMoney());
			System.out.println(type);

			if (orderPrivateCar.getOrderMoney() != null && price <= orderPrivateCar.getOrderMoney() \|\| type == 2) {
			preferentialDataVo.setDiscountAmount(price);
			preferentialDataVo.setType(type);
			preferentialDataVo.setObjectId(id);
			}
			return preferentialDataVo;
			}

			/**
			* 获取最优打车卡数据
			*
			* @param orderPrivateCar
			* @param price
			* @param id
			* @param type
			* @param userTaxiCards
			* @throws Exception
			*/
			public Map<String, Object> getOptimalTaxiCards(OrderPrivateCar orderPrivateCar, Double price, Integer id, Integer type, List<UserTaxiCard> userTaxiCards) throws Exception {
			Map<String, Object> map = new HashMap<>();
			for (UserTaxiCard t : userTaxiCards) {
			JSONObject jsonObject = JSON.parseObject(t.getContent());
			List<Integer> integers = jsonObject.getJSONArray("businessTypes").toJavaList(Integer.class);
			if (!integers.contains(1)) {
			continue;
			}
			if (t.getType() == 1) {//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
			Integer time = jsonObject.getInteger("time");
			if (time == 0) {
			continue;
			}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			Double discount = jsonObject.getDouble("discount");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			double v = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
			if (price.compareTo(v) < 0) {
			price = v;
			id = t.getId();
			type = 2;
			}
			if (price.compareTo(v) < 0) {
			price = v;
			id = t.getId();
			type = 2;
			}
			}
			}

			}
			if (t.getType() == 2) {//优惠卡{"businessTypes":[1,2,3],"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"fullReduction":[[50,3],[100,5],[150,10]]}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			for (int j = fullReduction.size() - 1; j >= 0; j--) {
			JSONArray jsonArray = fullReduction.getJSONArray(j);
			Double p = jsonArray.getDouble(0);//满金额
			Double y = jsonArray.getDouble(1);//优惠金额
			if (orderPrivateCar.getOrderMoney().compareTo(p) >= 0 && price.compareTo(y) < 0) {
			price = y;
			id = t.getId();
			type = 2;
			}
			}
			}
			}
			}
			if (t.getType() == 3) {//次数卡{"businessTypes":[1,2,3],"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"time":1,"discountAmount":10}
			Integer time = jsonObject.getInteger("time");
			if (time == 0) {
			continue;
			}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			Double discountAmount = jsonObject.getDouble("discountAmount");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			if (price.compareTo(discountAmount) < 0) {
			price = discountAmount;
			id = t.getId();
			type = 2;
			}
			}
			}
			}
			if (t.getType() == 4) {//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
			Double discount = jsonObject.getDouble("discount");//折扣
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			double v = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
			if (price.compareTo(v) < 0) {
			price = v;
			id = t.getId();
			type = 2;
			}
			}
			}
			}
			}
			map.put("price", price);
			map.put("id", id);
			map.put("type", type);
			return map;
			}

			@Override
			public List<Map<String, Object>> queryCoupon(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			List<Map<String, Object>> list = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney(), pageNum, size);
			List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney(), pageNum, size);
			list.addAll(list1);
			return list;
			}

			@Override
			public List<CouponsListVo> queryCouponList(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
			pageNum = (pageNum - 1) * size;
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			List<CouponsListVo> rows = new ArrayList<>();
			List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("companyId", orderPrivateCar.getCompanyId())
			.eq("state", 1).in("couponUseType", Arrays.asList(0, 1)).eq("userId", uid).where("expirationTime >= now()"));
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			for (UserCouponRecord userCouponRecord : list) {
			if (userCouponRecord.getCouponType() == 2) {//满减券
			if (orderPrivateCar.getOrderMoney().compareTo(userCouponRecord.getFullMoney()) < 0) {
			continue;
			}
			}
			CouponsListVo couponsListVo = new CouponsListVo();
			couponsListVo.setId(userCouponRecord.getId());
			couponsListVo.setDataType(1);
			couponsListVo.setMoney(userCouponRecord.getMoney());
			couponsListVo.setUserType(userCouponRecord.getCouponUseType());
			couponsListVo.setTime(sdf.format(userCouponRecord.getExpirationTime()));
			couponsListVo.setType(userCouponRecord.getCouponType());
			couponsListVo.setFullMoney(userCouponRecord.getFullMoney());
			couponsListVo.setState(userCouponRecord.getState());
			Company company = companyService.selectById(userCouponRecord.getCompanyId());
			couponsListVo.setCompany(company.getName());
			rows.add(couponsListVo);
			}

			Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			CompanyCity companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("areaCode", geocode.get("districtCode")).eq("state", 1));
			if (null == companyCity) {
			companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("cityCode", geocode.get("cityCode")).eq("state", 1));
			}
			if (null == companyCity) {
			companyCity = companyCityService.selectOne(new EntityWrapper<CompanyCity>().eq("companyId", orderPrivateCar.getCompanyId()).eq("provinceCode", geocode.get("provinceCode")).eq("state", 1));
			}
			List<UserTaxiCard> userTaxiCards;
			if (companyCity != null) {
			userTaxiCards = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
			.in("type", Arrays.asList(1, 2, 3, 4)).like("companyCityId", "%" + companyCity.getId() + "%").where("now() between startTime and endTime"));
			} else {
			userTaxiCards = new ArrayList<>();
			}

			//全国卡
			List<TaxiCard> taxiCards = taxiCardService.selectList(new EntityWrapper<TaxiCard>().eq("taxiCardType", 2).in("type", Arrays.asList(1, 2, 3, 4)).eq("state", 1));
			if (taxiCards.size() > 0) {
			List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", uid)
			.in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
			userTaxiCards.addAll(userTaxiCards1);
			}


			//亲密账户
			List<UserUser> bindUserId = userUserService.selectList(new EntityWrapper<UserUser>().eq("bindUserId", uid));
			CompanyCity finalCompanyCity = companyCity;
			bindUserId.forEach(userUser -> {
			if (finalCompanyCity != null) {
			List<UserTaxiCard> taxiCardPayments1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().in("type", Arrays.asList(1, 2, 3, 4))
			.like("companyCityId", "%" + finalCompanyCity.getId() + "%").eq("userId", userUser.getUserId()).where("now() between startTime and endTime"));
			userTaxiCards.addAll(taxiCardPayments1);
			}

			//全国卡
			if (taxiCards.size() > 0) {
			List<UserTaxiCard> userTaxiCards1 = userTaxiCardService.selectList(new EntityWrapper<UserTaxiCard>().eq("userId", userUser.getUserId())
			.in("type", Arrays.asList(1, 2, 3, 4)).in("taxiCardId", taxiCards.stream().map(TaxiCard::getId).collect(Collectors.toList())).where("now() between startTime and endTime"));
			userTaxiCards.addAll(userTaxiCards1);
			}
			});

			for (UserTaxiCard t : userTaxiCards) {
			try {
			CouponsListVo couponsListVo = new CouponsListVo();
			couponsListVo.setId(t.getId());
			couponsListVo.setDataType(2);
			couponsListVo.setUserType(1);
			couponsListVo.setTime(sdf.format(t.getEndTime()));
			couponsListVo.setState(1);
			couponsListVo.setTaxiCardType(t.getType());
			Company company = companyService.selectById(t.getCompanyId());
			couponsListVo.setCompany(company.getName());
			couponsListVo.setName(taxiCardService.selectById(t.getTaxiCardId()).getName());


			JSONObject jsonObject = JSON.parseObject(t.getContent());
			JSONArray businessTypes = jsonObject.getJSONArray("businessTypes");
			if (!businessTypes.toJavaList(Integer.class).contains(1)) {
			continue;
			}
			if (t.getType() == 1) {//{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
			Integer time = jsonObject.getInteger("time");
			if (time == 0) {
			continue;
			}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
			boolean b = true;
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
			Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			b = false;
			break;
			}
			}
			if (b) {
			continue;
			}
			couponsListVo.setMoney(jsonObject.getDouble("discount"));
			couponsListVo.setType(1);
			}
			if (t.getType() == 2) {//{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
			boolean b = true;
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
			Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			b = false;
			break;
			}
			}
			if (b) {
			continue;
			}
			JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
			b = true;
			for (int i = fullReduction.size() - 1; i >= 0; i--) {
			JSONArray jsonArray = fullReduction.getJSONArray(i);
			Double m = jsonArray.getDouble(0);
			Double j = jsonArray.getDouble(1);
			if (orderPrivateCar.getOrderMoney().compareTo(m) >= 0) {
			couponsListVo.setFullMoney(m);
			couponsListVo.setMoney(j);
			b = false;
			break;
			}
			}
			if (b) {
			continue;
			}
			couponsListVo.setType(2);
			}
			if (t.getType() == 3) {//{"businessTypes":[1,2,3],"time":1,"discountAmount":10}
			Integer time = jsonObject.getInteger("time");
			if (time == 0) {
			continue;
			}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
			boolean b = true;
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
			Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			b = false;
			break;
			}
			}
			if (b) {
			continue;
			}
			couponsListVo.setFullMoney(0D);
			couponsListVo.setMoney(jsonObject.getDouble("discountAmount"));
			couponsListVo.setType(2);
			}
			if (t.getType() == 4) {//{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
			boolean b = true;
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf.parse(sdf1.format(new Date()) + " " + split[0]);
			Date e = sdf.parse(sdf1.format(new Date()) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			b = false;
			break;
			}
			}
			if (b) {
			continue;
			}
			couponsListVo.setMoney(jsonObject.getDouble("discount"));
			couponsListVo.setType(1);
			}


			String str = "";
			TaxiCard taxiCard = taxiCardService.selectById(t.getTaxiCardId());
			if (taxiCard.getTaxiCardType() == 1) {
			String[] split = taxiCard.getCompanyCityId().split(";");
			for (String c : split) {
			CompanyCity companyCity1 = companyCityService.selectById(c);
			if (ToolUtil.isNotEmpty(companyCity1.getAreaCode())) {
			Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getAreaCode()));
			str += region.getName() + ";";
			continue;
			}
			if (ToolUtil.isNotEmpty(companyCity1.getCityCode())) {
			Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getCityCode()));
			str += region.getName() + ";";
			continue;
			}
			if (ToolUtil.isNotEmpty(companyCity1.getProvinceCode())) {
			Region region = regionService.selectOne(new EntityWrapper<Region>().eq("code", companyCity1.getProvinceCode()));
			str += region.getName() + ";";
			continue;
			}
			}
			} else {
			str = "全国;";
			}
			couponsListVo.setCity(str.substring(0, str.length() - 1));


			rows.add(couponsListVo);
			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			Collections.sort(rows, new Comparator<CouponsListVo>() {
			public int compare(CouponsListVo s1, CouponsListVo s2) {
			return Integer.compare(s1.getId(), s2.getId());
			}
			});

			if (rows.size() >= (pageNum + 1) * size) {
			rows = rows.subList(pageNum, pageNum + size);
			} else if (pageNum < rows.size() && rows.size() < (pageNum + 1) * size) {
			rows = rows.subList(pageNum, rows.size());
			} else {
			rows = new ArrayList<>();
			}
			System.out.println(rows);
			System.out.println(orderPrivateCar.getOrderMoney());
			rows = rows.stream().filter(e -> e.getMoney() <= orderPrivateCar.getOrderMoney() \|\| e.getDataType() == 2).collect(Collectors.toList());
			System.out.println(rows);
			return rows;
			}

			@Override
			public ResultUtil payPrivateCarOrder(Integer payType, Integer orderId, Integer couponId, Integer type) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			if (orderPrivateCar.getState() == 8 \|\| orderPrivateCar.getState() == 9) {
			return ResultUtil.error("订单已完成支付，不允许重复支付", "");
			}
			if (orderPrivateCar.getState() != 7) {
			return ResultUtil.error("订单不在待支付状态，不允许支付", "");
			}
			Integer uid = orderPrivateCar.getUserId();
			Double orderMoney = orderPrivateCar.getOrderMoney();
			UserInfo userInfo = userInfoService.selectById(uid);
			ResultUtil resultUtil = ResultUtil.success(new Object());
			orderPrivateCar.setCouponMoney(0D);//初始化历史数据
			orderPrivateCar.setCouponId(null);

			//计算优惠券
			UserCouponRecord userCouponRecord = null;
			if (null != couponId) {
			userCouponRecord = userCouponRecordService.selectById(couponId);
			if (userCouponRecord.getCompanyId() != orderPrivateCar.getCompanyId()) {
			return ResultUtil.error("优惠券不能用于此订单", "");
			}
			if (userCouponRecord.getState() == 2) {
			return ResultUtil.error("优惠券已使用", "");
			}
			if (userCouponRecord.getState() == 3) {
			return ResultUtil.error("优惠券已过期", "");
			}
			if (userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1) {
			return ResultUtil.error("优惠券不能用于此类型订单", "");
			}
			if (userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0) {
			return ResultUtil.error("优惠券不能用于此订单", "");
			}
			orderMoney = orderMoney - userCouponRecord.getMoney();
			orderPrivateCar.setCouponMoney(userCouponRecord.getMoney());
			orderPrivateCar.setCouponId(couponId);
			}


			//计算红包
			UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
			if (null != query && query.getMoney().compareTo(orderMoney) < 0) {
			orderMoney = orderMoney - query.getMoney();
			orderPrivateCar.setRedPacketMoney(query.getMoney());
			orderPrivateCar.setRedPacketId(query.getId());
			}

			//计算折扣
			UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
			if (null != query2) {
			Double special = query2.getSpecial();
			orderPrivateCar.setDiscount(special);
			double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
			if (orderMoney.compareTo(v) > 0) {
			orderPrivateCar.setDiscountMoney(orderMoney - v);
			orderPrivateCar.setActivityId(query2.getId());
			orderMoney = v;
			}
			}
			orderMoney = orderMoney < 0 ? 0 : orderMoney;
			if (payType == 1) {//微信支付
			String app = type == 1 ? "APP" : "JSAPI";
			resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据
			}
			if (payType == 2) {//支付宝支付
			resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 2, orderMoney, "", 1);//添加预支付数据
			}
			if (payType == 3) {//余额支付
			if (userInfo.getBalance() == null \|\| userInfo.getBalance() < orderMoney) {
			return ResultUtil.error("余额不足，无法完成支付", "");
			}

			userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());

			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
			userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分

			//添加交易明细
			transactionDetailsService.saveData(uid, "快车订单", orderMoney, 2, 1, 1, 1, orderId);
			userInfoService.updateById(userInfo);

			orderPrivateCar.setState(8);
			orderPrivateCar.setPayType(3);
			orderPrivateCar.setPayMoney(orderMoney);

			//处理优惠券和红包
			if (null != userCouponRecord) {
			userCouponRecord.setState(2);
			userCouponRecord.setEndTime(new Date());
			userCouponRecordService.updateById(userCouponRecord);
			}
			if (null != query) {
			query.setState(2);
			query.setEndTime(new Date());
			userRedPacketRecordService.updateById(query);
			}
			//添加收入
			Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
			orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));

			// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			}
			}).start();

			systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付，谢谢使用！", uid, 1);

			new Thread(new Runnable() {
			@Override
			public void run() {
			if (pushMinistryOfTransport) {//上传数据
			pushMinistryOfTransportUtil.operatePay(orderId);
			}
			}
			}).start();
			}

			this.updateAllColumnById(orderPrivateCar);
			return resultUtil;
			}

			@Override
			@Transactional(propagation = Propagation.REQUIRES_NEW)
			public ResultUtil payPrivateCarOrder1(Integer payType, Integer orderId, Integer objectId, Integer objectType, Integer type) throws Exception {

			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			if (orderPrivateCar.getState() == 8 \|\| orderPrivateCar.getState() == 9) {
			return ResultUtil.error("订单已完成支付，不允许重复支付", new ArrayList<>());
			}
			if (orderPrivateCar.getState() != 7) {
			return ResultUtil.error("订单不在待支付状态，不允许支付", new ArrayList<>());
			}
			Integer uid = orderPrivateCar.getUserId();
			Double orderMoney = orderPrivateCar.getOrderMoney();
			UserInfo userInfo = userInfoService.selectById(uid);
			ResultUtil resultUtil = ResultUtil.success(new Object());
			orderPrivateCar.setCouponMoney(0D);//初始化历史数据
			orderPrivateCar.setCouponId(null);
			System.out.println("!!!" + orderMoney + "!!!!");
			//计算优惠券
			UserCouponRecord userCouponRecord = null;
			if (null != objectId && objectType == 1) {
			userCouponRecord = userCouponRecordService.selectById(objectId);
			if (userCouponRecord.getCompanyId() != orderPrivateCar.getCompanyId()) {
			return ResultUtil.error("优惠券不能用于此订单", new ArrayList<>());
			}
			if (userCouponRecord.getState() == 2) {
			return ResultUtil.error("优惠券已使用", new ArrayList<>());
			}
			if (userCouponRecord.getState() == 3) {
			return ResultUtil.error("优惠券已过期", new ArrayList<>());
			}
			if (userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1) {
			return ResultUtil.error("优惠券不能用于此类型订单", new ArrayList<>());
			}
			if (userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0) {
			return ResultUtil.error("优惠券不能用于此订单", new ArrayList<>());
			}
			orderMoney = orderMoney - userCouponRecord.getMoney();
			orderPrivateCar.setCouponMoney(userCouponRecord.getMoney());
			orderPrivateCar.setCouponId(objectId);
			System.out.println("!!!" + orderMoney + "!!!!");
			}

			//打车卡
			UserTaxiCard userTaxiCard = null;
			if (null != objectId && objectType == 2) {
			userTaxiCard = userTaxiCardService.selectById(objectId);
			TaxiCard taxiCard = taxiCardService.selectById(userTaxiCard.getTaxiCardId());
			if (taxiCard.getTaxiCardType() == 1 && userTaxiCard.getCompanyId() != orderPrivateCar.getCompanyId()) {
			return ResultUtil.error("打车卡不能用于此订单", new ArrayList<>());
			}
			if (System.currentTimeMillis() > userTaxiCard.getEndTime().getTime()) {
			return ResultUtil.error("打车卡已过期", new ArrayList<>());
			}
			if (userTaxiCard.getType() == 1 \|\| userTaxiCard.getType() == 3) {
			Integer time = JSON.parseObject(userTaxiCard.getContent()).getInteger("time");
			if (0 == time) {
			return ResultUtil.error("打车卡已使用完", new ArrayList<>());
			}
			}
			List<Integer> integers = JSON.parseObject(userTaxiCard.getContent()).getJSONArray("businessTypes").toJavaList(Integer.class);
			if (!integers.contains(1)) {
			return ResultUtil.error("打车卡不能用于此类型订单", new ArrayList<>());
			}

			Double yh = 0D;
			JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
			if (userTaxiCard.getType() == 1) {//打折次数卡{"businessTypes":[1,2,3],"time":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"],"discount":5}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			Double discount = jsonObject.getDouble("discount");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			yh = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
			jsonObject.put("time", jsonObject.getInteger("time") - 1);
			userTaxiCard.setContent(jsonObject.toJSONString());
			break;
			}
			}

			}
			if (userTaxiCard.getType() == 2) {//优惠卡{"businessTypes":[1,2,3],"fullReduction":[[50,3],[100,5],[150,10]]}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			JSONArray fullReduction = jsonObject.getJSONArray("fullReduction");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			for (int j = fullReduction.size() - 1; j >= 0; j--) {
			JSONArray jsonArray = fullReduction.getJSONArray(j);
			Double p = jsonArray.getDouble(0);//满金额
			if (orderPrivateCar.getOrderMoney().compareTo(p) >= 0) {
			yh = jsonArray.getDouble(1);//优惠金额
			break;
			}
			}
			}
			}

			}
			if (userTaxiCard.getType() == 3) {//次数卡{"businessTypes":[1,2,3],"time":1,"discountAmount":10}
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			yh = jsonObject.getDouble("discountAmount");
			jsonObject.put("time", jsonObject.getInteger("time") - 1);
			userTaxiCard.setContent(jsonObject.toJSONString());
			}
			}

			}
			if (userTaxiCard.getType() == 4) {//打折天数卡{"businessTypes":[1,2,3],"discount":5,"timeQuantum":["08:00:00 - 09:00:00","17:00:00 - 18:00:00"]}
			Double discount = jsonObject.getDouble("discount");//折扣
			JSONArray timeQuantum = jsonObject.getJSONArray("timeQuantum");//使用时间段
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			Date date = new Date();
			for (int i = 0; i < timeQuantum.size(); i++) {
			String[] split = timeQuantum.getString(i).split(" - ");
			Date s = sdf1.parse(sdf.format(date) + " " + split[0]);
			Date e = sdf1.parse(sdf.format(date) + " " + split[1]);
			if (s.getTime() <= System.currentTimeMillis() && System.currentTimeMillis() < e.getTime()) {
			yh = new BigDecimal(orderPrivateCar.getOrderMoney()).multiply(new BigDecimal((10 - discount) / 10)).setScale(2, RoundingMode.HALF_EVEN).doubleValue();
			break;
			}
			}
			}

			orderMoney = orderMoney - yh;
			orderPrivateCar.setTaxiCardId(userTaxiCard.getTaxiCardId());
			orderPrivateCar.setUserTaxiCardId(objectId);
			orderPrivateCar.setDiscountAmount(yh);
			}

			System.out.println("!!!" + orderMoney + "!!!!");

			//计算红包
			UserRedPacketRecord query = userRedPacketRecordService.query(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
			if (null != query && query.getMoney().compareTo(orderMoney) < 0) {
			orderMoney = orderMoney - query.getMoney();
			orderPrivateCar.setRedPacketMoney(query.getMoney());
			orderPrivateCar.setRedPacketId(query.getId());
			}

			System.out.println("!!!" + orderMoney + "!!!!");
			//计算折扣
			UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
			if (null != query2) {
			Double special = query2.getSpecial();
			orderPrivateCar.setDiscount(special);
			double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
			if (orderMoney.compareTo(v) > 0) {
			orderPrivateCar.setDiscountMoney(orderMoney - v);
			orderPrivateCar.setActivityId(query2.getId());
			orderMoney = v;
			}
			}
			orderMoney = new BigDecimal(orderMoney).setScale(2, RoundingMode.HALF_UP).doubleValue();
			System.out.println("!!!" + orderMoney + "!!!!");
			orderMoney = orderMoney < 0 ? 0 : orderMoney;
			if (payType == 1) {//微信支付
			if (orderMoney == 0) {
			return ResultUtil.error("请使用余额支付");
			}
			String app = type == 1 ? "APP" : "JSAPI";
			resultUtil = payMoneyUtil.weixinpay("完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/wxPayOrderTaxi", app, userInfo.getAppletsOpenId());
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据
			}
			if (payType == 2) {//支付宝支付
			if (orderMoney == 0) {
			return ResultUtil.error("请使用余额支付");
			}
			resultUtil = payMoneyUtil.alipay("完成订单", "完成订单", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), orderMoney.toString(), "/base/aliPayOrderTaxi");
			paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 2, orderMoney, "", 1);//添加预支付数据
			}
			if (payType == 3) {//余额支付
			if (userInfo.getBalance() == null \|\| userInfo.getBalance() < orderMoney) {
			return ResultUtil.error("余额不足，无法完成支付");
			}
			// if(orderMoney > 0){
			// resultUtil= appOrderController.moneyPay(orderId,userInfo.getId(),orderMoney);
			// if(resultUtil.getCode()==500){
			// return ResultUtil.error("电子余额不足，无法完成支付");
			// }
			// }
			userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());

			SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
			if(null != query1){
			userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
			}

			//添加交易明细
			transactionDetailsService.saveData(uid, "快车订单", orderMoney, 2, 1, 1, 1, orderId);
			userInfoService.updateById(userInfo);

			orderPrivateCar.setState(8);
			orderPrivateCar.setPayType(3);
			orderPrivateCar.setPayMoney(orderMoney);

			//处理优惠券和红包
			if(null != userCouponRecord){
			userCouponRecord.setState(2);
			userCouponRecord.setEndTime(new Date());
			userCouponRecordService.updateById(userCouponRecord);
			}
			//处理打车卡
			if(null != userTaxiCard){
			userTaxiCardService.updateById(userTaxiCard);
			}
			if(null != query){
			query.setState(2);
			query.setEndTime(new Date());
			userRedPacketRecordService.updateById(query);
			}

			//添加收入
			Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
			orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));

			// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			}
			}).start();

			systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付，谢谢使用！", uid, 1);

			new Thread(new Runnable() {
			@Override
			public void run() {
			if(pushMinistryOfTransport){//上传数据
			pushMinistryOfTransportUtil.operatePay(orderId);
			}
			}
			}).start();
			}else if(payType == 4){
			if(orderMoney == 0){
			return ResultUtil.error("请使用余额支付");
			}
			Integer integer = paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 4, orderMoney, "", 1);
			resultUtil = appOrderController.placeAnOrder(new BigDecimal(orderMoney), 4,orderId,6,integer);

			}

			this.updateAllColumnById(orderPrivateCar);
			return resultUtil;
			}
			@Autowired
			private AppOrderController appOrderController;

			@Override
			public synchronized ResultUtil<BaseWarpper> queryRedMoney(Integer orderId) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			Integer companyId = orderPrivateCar.getCompanyId();

			Map<String, Object> query = userActivityRedenvelopeService.query(companyId, orderPrivateCar.getTravelTime());
			Double money = 0D;
			BaseWarpper baseWarpper = new BaseWarpper();
			if(null != query){
			Integer type = Integer.valueOf(String.valueOf(query.get("type")));
			if(type == 1){//固定金额
			money = Double.valueOf(String.valueOf(query.get("money")));
			}else{//随机金额
			Double startMoney = Double.valueOf(String.valueOf(query.get("startMoney")));
			Double endMoney = Double.valueOf(String.valueOf(query.get("endMoney")));
			int i = new BigDecimal(endMoney).subtract(new BigDecimal(startMoney)).intValue();
			Random random = new Random();
			int num = random.nextInt(i);
			money = new BigDecimal(startMoney).add(new BigDecimal(num)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
			}
			//判断当前红包是否大于剩余可领取总金额
			if(money.compareTo(Double.valueOf(query.get("lavePrice").toString())) > 0){
			baseWarpper.setAmount(0D);
			return ResultUtil.success(baseWarpper);
			}
			}
			baseWarpper.setAmount(money);

			if(money > 0){
			//添加临时红包数据
			UserRedPacketRecord userRedPacketRecord = new UserRedPacketRecord();
			userRedPacketRecord.setMoney(money);
			Calendar calendar = Calendar.getInstance();
			calendar.setTime(new Date());
			calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(query.get("effective"))));
			userRedPacketRecord.setExpirationTime(calendar.getTime());
			userRedPacketRecord.setInsertTime(new Date());
			userRedPacketRecord.setCompanyId(Integer.valueOf(String.valueOf(query.get("companyId"))));
			userRedPacketRecord.setState(0);
			userRedPacketRecord.setOrderId(orderPrivateCar.getId());
			userRedPacketRecord.setOrderType(1);
			userRedPacketRecord.setUserId(orderPrivateCar.getUserId());
			userRedPacketRecordService.insert(userRedPacketRecord);
			}

			// 获取平台电子账簿当前用户电子账簿
			appOrderController.moneyPay(orderPrivateCar.getId(),orderPrivateCar.getUserId(),money);

			return ResultUtil.success(baseWarpper);
			}


			@Override
			public synchronized ResultUtil shareRedEnvelope(Integer orderId) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			UserRedPacketRecord query = userRedPacketRecordService.query_(orderPrivateCar.getUserId(), orderPrivateCar.getCompanyId(), 0, 1, null);
			if(null != query){
			Double money = query.getMoney();
			Map<String, Object> map = userActivityRedenvelopeService.query(orderPrivateCar.getCompanyId(), orderPrivateCar.getTravelTime());
			Double laveMoney = Double.valueOf(String.valueOf(map.get("laveMoney")));
			if(money.compareTo(laveMoney) > 0){
			return ResultUtil.error("手速太慢了，红包已派发完啦！");
			}
			//判断当前红包是否大于剩余可领取总金额
			if(money.compareTo(Double.valueOf(map.get("lavePrice").toString())) > 0){
			return ResultUtil.error("手速太慢了，红包已派发完啦！");
			}
			double v = new BigDecimal(laveMoney).subtract(new BigDecimal(money)).doubleValue();

			UserActivityRedenvelope id = userActivityRedenvelopeService.selectById(String.valueOf(map.get("id")));
			id.setLaveMoney(v);
			id.setLavePrice(new BigDecimal(id.getLavePrice() - money).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			userActivityRedenvelopeService.updateById(id);

			query.setState(1);
			query.setRedPacketActivityId(id.getId());
			userRedPacketRecordService.updateById(query);
			}
			return ResultUtil.success();
			}


			/**
			* 取消订单支付后的处理
			* @param id 订单=id
			* @param order_id 工行支付单号
			* @param type 1=微信，2=支付宝
			* @throws Exception
			*/
			@Override
			public void payCancelOrderPrivateCar(Integer id, String order_id, Integer type) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getUserId(), 1, Integer.valueOf(id), 1, type, 1);
			if(null != query){
			//添加交易明细
			transactionDetailsService.saveData(orderPrivateCar.getUserId(), "快车取消订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
			orderPrivateCar.setState(10);
			//解除小号绑定
			if(orderPrivateCar.getBindId() != null){
			chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 600000));
			}
			orderPrivateCar.setBindId("");
			orderPrivateCar.setTelX("");
			this.updateById(orderPrivateCar);

			query.setState(2);
			query.setCode(order_id);
			paymentRecordService.updateById(query);

			OrderCancel query1 = orderCancelService.query(query.getOrderId(), query.getOrderType(), query.getAmount(), query.getPayType(), 1);
			if (null != query1){
			query1.setState(2);
			orderCancelService.updateById(query1);
			}

			//添加已收入明细
			incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, query.getAmount());

			this.deleteTask(orderPrivateCar.getId());//删除定时任务

			// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
			userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());

			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
			if (null != query1) {
			userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分
			}

			//添加交易明细
			transactionDetailsService.saveData(uid, "快车订单", orderMoney, 2, 1, 1, 1, orderId);
			userInfoService.updateById(userInfo);

			orderPrivateCar.setState(8);
			orderPrivateCar.setPayType(3);
			orderPrivateCar.setPayMoney(orderMoney);

			//处理优惠券和红包
			if (null != userCouponRecord) {
			userCouponRecord.setState(2);
			userCouponRecord.setEndTime(new Date());
			userCouponRecordService.updateById(userCouponRecord);
			}
			//处理打车卡
			if (null != userTaxiCard) {
			userTaxiCardService.updateById(userTaxiCard);
			}
			if (null != query) {
			query.setState(2);
			query.setEndTime(new Date());
			userRedPacketRecordService.updateById(query);
			}

			//添加收入
			Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
			orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));

			// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			}
			}).start();

			systemNoticeService.addSystemNotice(1, "您已使用余额成功完成出行订单支付，谢谢使用！", uid, 1);

			new Thread(new Runnable() {
			@Override
			public void run() {
			if (pushMinistryOfTransport) {//上传数据
			pushMinistryOfTransportUtil.operatePay(orderId);
			}
			}
			}).start();
			} else if (payType == 4) {
			if (orderMoney == 0) {
			return ResultUtil.error("请使用余额支付");
			}
			Integer integer = paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 4, orderMoney, "", 1);
			resultUtil = appOrderController.placeAnOrder(new BigDecimal(orderMoney), 4, orderId, 6, integer);

			}

			this.updateAllColumnById(orderPrivateCar);
			return resultUtil;
			}

			@Override
			public synchronized ResultUtil<BaseWarpper> queryRedMoney(Integer orderId) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			Integer companyId = orderPrivateCar.getCompanyId();

			Map<String, Object> query = userActivityRedenvelopeService.query(companyId, orderPrivateCar.getTravelTime());
			Double money = 0D;
			BaseWarpper baseWarpper = new BaseWarpper();
			if (null != query) {
			Integer type = Integer.valueOf(String.valueOf(query.get("type")));
			if (type == 1) {//固定金额
			money = Double.valueOf(String.valueOf(query.get("money")));
			} else {//随机金额
			Double startMoney = Double.valueOf(String.valueOf(query.get("startMoney")));
			Double endMoney = Double.valueOf(String.valueOf(query.get("endMoney")));
			int i = new BigDecimal(endMoney).subtract(new BigDecimal(startMoney)).intValue();
			Random random = new Random();
			int num = random.nextInt(i);
			money = new BigDecimal(startMoney).add(new BigDecimal(num)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
			}
			//判断当前红包是否大于剩余可领取总金额
			if (money.compareTo(Double.valueOf(query.get("lavePrice").toString())) > 0) {
			baseWarpper.setAmount(0D);
			return ResultUtil.success(baseWarpper);
			}
			}
			baseWarpper.setAmount(money);

			if (money > 0) {
			//添加临时红包数据
			UserRedPacketRecord userRedPacketRecord = new UserRedPacketRecord();
			userRedPacketRecord.setMoney(money);
			Calendar calendar = Calendar.getInstance();
			calendar.setTime(new Date());
			calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(query.get("effective"))));
			userRedPacketRecord.setExpirationTime(calendar.getTime());
			userRedPacketRecord.setInsertTime(new Date());
			userRedPacketRecord.setCompanyId(Integer.valueOf(String.valueOf(query.get("companyId"))));
			userRedPacketRecord.setState(0);
			userRedPacketRecord.setOrderId(orderPrivateCar.getId());
			userRedPacketRecord.setOrderType(1);
			userRedPacketRecord.setUserId(orderPrivateCar.getUserId());
			userRedPacketRecordService.insert(userRedPacketRecord);
			}

			// 获取平台电子账簿当前用户电子账簿
			appOrderController.moneyPay(orderPrivateCar.getId(), orderPrivateCar.getUserId(), money);

			return ResultUtil.success(baseWarpper);
			}

			@Override
			public synchronized ResultUtil shareRedEnvelope(Integer orderId) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			UserRedPacketRecord query = userRedPacketRecordService.query_(orderPrivateCar.getUserId(), orderPrivateCar.getCompanyId(), 0, 1, null);
			if (null != query) {
			Double money = query.getMoney();
			Map<String, Object> map = userActivityRedenvelopeService.query(orderPrivateCar.getCompanyId(), orderPrivateCar.getTravelTime());
			Double laveMoney = Double.valueOf(String.valueOf(map.get("laveMoney")));
			if (money.compareTo(laveMoney) > 0) {
			return ResultUtil.error("手速太慢了，红包已派发完啦！");
			}
			//判断当前红包是否大于剩余可领取总金额
			if (money.compareTo(Double.valueOf(map.get("lavePrice").toString())) > 0) {
			return ResultUtil.error("手速太慢了，红包已派发完啦！");
			}
			double v = new BigDecimal(laveMoney).subtract(new BigDecimal(money)).doubleValue();

			UserActivityRedenvelope id = userActivityRedenvelopeService.selectById(String.valueOf(map.get("id")));
			id.setLaveMoney(v);
			id.setLavePrice(new BigDecimal(id.getLavePrice() - money).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			userActivityRedenvelopeService.updateById(id);

			query.setState(1);
			query.setRedPacketActivityId(id.getId());
			userRedPacketRecordService.updateById(query);
			}
			return ResultUtil.success();
			}

			/**
			* 取消订单支付后的处理
			*
			* @param id 订单=id
			* @param order_id 工行支付单号
			* @param type 1=微信，2=支付宝
			* @throws Exception
			*/
			@Override
			public void payCancelOrderPrivateCar(Integer id, String order_id, Integer type) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getUserId(), 1, Integer.valueOf(id), 1, type, 1);
			if (null != query) {
			//添加交易明细
			transactionDetailsService.saveData(orderPrivateCar.getUserId(), "快车取消订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
			orderPrivateCar.setState(10);
			//解除小号绑定
			if (orderPrivateCar.getBindId() != null) {
			chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(), orderPrivateCar.getTelX(), (System.currentTimeMillis() + 600000));
			}
			orderPrivateCar.setBindId("");
			orderPrivateCar.setTelX("");
			this.updateById(orderPrivateCar);

			query.setState(2);
			query.setCode(order_id);
			paymentRecordService.updateById(query);

			OrderCancel query1 = orderCancelService.query(query.getOrderId(), query.getOrderType(), query.getAmount(), query.getPayType(), 1);
			if (null != query1) {
			query1.setState(2);
			orderCancelService.updateById(query1);
			}

			//添加已收入明细
			incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, query.getAmount());

			this.deleteTask(orderPrivateCar.getId());//删除定时任务

			// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
			// new Thread(new Runnable() {
			// @Override
			// public void run() {
			// pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			// }
			// }).start();

			//添加消息
			systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : (type == 2 ? "支付宝" : "云闪付")) + "成功支付取消订单费用，谢谢使用！", orderPrivateCar.getUserId(), 1);
			} else {
			System.err.println("预支付数据异常（orderId = " + id + ")");
			}
			}

			@Override
			public void payOrderPrivateCarCallback(Integer id, String order_id, Integer type) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getUserId(), 1, Integer.valueOf(id), 1, type, 1);
			if (null != query && query.getState() == 1) {
			//添加交易明细
			transactionDetailsService.saveData(orderPrivateCar.getUserId(), "快车订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
			orderPrivateCar.setState(8);
			orderPrivateCar.setPayType(type);
			orderPrivateCar.setPayMoney(query.getAmount());

			UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
			userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
			userInfoService.updateById(userInfo);

			//处理优惠券和红包
			if (null != orderPrivateCar.getCouponId()) {
			UserCouponRecord userCouponRecord = userCouponRecordService.selectById(orderPrivateCar.getCouponId());
			userCouponRecord.setState(2);
			userCouponRecord.setEndTime(new Date());
			userCouponRecordService.updateById(userCouponRecord);
			}
			if (null != orderPrivateCar.getUserTaxiCardId()) {
			UserTaxiCard userTaxiCard = userTaxiCardService.selectById(orderPrivateCar.getUserTaxiCardId());
			if (userTaxiCard.getType() == 1 \|\| userTaxiCard.getType() == 3) {
			JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
			jsonObject.put("time", jsonObject.getInteger("time") - 1);
			userTaxiCard.setContent(jsonObject.toJSONString());
			userTaxiCardService.updateById(userTaxiCard);
			}
			}
			if (null != orderPrivateCar.getRedPacketId()) {
			UserRedPacketRecord userRedPacketRecord = userRedPacketRecordService.selectById(orderPrivateCar.getRedPacketId());
			userRedPacketRecord.setState(2);
			userRedPacketRecord.setEndTime(new Date());
			userRedPacketRecordService.updateById(userRedPacketRecord);
			}


			query.setState(2);
			query.setCode(order_id);
			paymentRecordService.updateById(query);

			//添加收入
			Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
			orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));
			this.updateById(orderPrivateCar);

			// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			}
			}).start();

			systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : (type == 2 ? "支付宝" : "云闪付")) + "成功完成出行订单支付，谢谢使用！", orderPrivateCar.getUserId(), 1);

			new Thread(new Runnable() {
			@Override
			public void run() {
			if (pushMinistryOfTransport) {//上传数据
			pushMinistryOfTransportUtil.operatePay(orderPrivateCar.getId());
			}
			}
			}).start();

			} else {
			System.err.println("预支付数据异常（orderId = " + id + ")");
			}
			}

			@Override
			public List<OrderPrivateCar> queryOrder(Integer uid, Integer... state) throws Exception {
			return orderPrivateCarMapper.queryByState_(uid, state);
			}

			@Override
			public List<Map<String, Object>> queryMyOrderList(Integer uid, Integer pageNum, Integer size) throws Exception {
			pageNum = (pageNum - 1) * size;
			List<Map<String, Object>> maps = orderPrivateCarMapper.queryMyOrderList(uid, pageNum, size);
			for (Map<String, Object> map : maps) {
			if (Integer.valueOf(String.valueOf(map.get("state"))) == 11) {
			map.put("state", map.get("oldState"));
			}
			}
			return maps;
			}

			@Override
			public List<Map<String, Object>> queryInvoiceOrder(Integer type, Date startTime, Date endTime, Double startMoney, Double endMoney, Integer uid) throws Exception {
			startTime = dateUtil.getStartOrEndDate(startTime, "start");
			endTime = dateUtil.getStartOrEndDate(endTime, "end");
			return orderPrivateCarMapper.queryInvoiceOrder(type, startTime, endTime, startMoney, endMoney, uid);
			}


			@Override
			public List<Map<String, Object>> queryMyTravelRecord(Integer uid) throws Exception {
			return orderPrivateCarMapper.queryMyTravelRecord(uid);
			}


			//添加消息
			systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信" : (type==2?"支付宝":"云闪付")) + "成功支付取消订单费用，谢谢使用！", orderPrivateCar.getUserId(), 1);
			}else{
			System.err.println("预支付数据异常（orderId = " + id + ")");
			}
			}

			@Override
			public void payOrderPrivateCarCallback(Integer id, String order_id, Integer type) throws Exception {
			OrderPrivateCar orderPrivateCar = this.selectById(id);
			PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getUserId(), 1, Integer.valueOf(id), 1, type, 1);
			if(null != query && query.getState() == 1){
			//添加交易明细
			transactionDetailsService.saveData(orderPrivateCar.getUserId(), "快车订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
			orderPrivateCar.setState(8);
			orderPrivateCar.setPayType(type);
			orderPrivateCar.setPayMoney(query.getAmount());

			UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
			SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
			userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分
			userInfoService.updateById(userInfo);

			//处理优惠券和红包
			if(null != orderPrivateCar.getCouponId()){
			UserCouponRecord userCouponRecord = userCouponRecordService.selectById(orderPrivateCar.getCouponId());
			userCouponRecord.setState(2);
			userCouponRecord.setEndTime(new Date());
			userCouponRecordService.updateById(userCouponRecord);
			}
			if(null != orderPrivateCar.getUserTaxiCardId()){
			UserTaxiCard userTaxiCard = userTaxiCardService.selectById(orderPrivateCar.getUserTaxiCardId());
			if(userTaxiCard.getType() == 1 \|\| userTaxiCard.getType() == 3){
			JSONObject jsonObject = JSON.parseObject(userTaxiCard.getContent());
			jsonObject.put("time", jsonObject.getInteger("time") - 1);
			userTaxiCard.setContent(jsonObject.toJSONString());
			userTaxiCardService.updateById(userTaxiCard);
			}
			}
			if(null != orderPrivateCar.getRedPacketId()){
			UserRedPacketRecord userRedPacketRecord = userRedPacketRecordService.selectById(orderPrivateCar.getRedPacketId());
			userRedPacketRecord.setState(2);
			userRedPacketRecord.setEndTime(new Date());
			userRedPacketRecordService.updateById(userRedPacketRecord);
			}


			query.setState(2);
			query.setCode(order_id);
			paymentRecordService.updateById(query);

			//添加收入
			Map<String, Object> map = incomeService.saveIncome(orderPrivateCar.getId(), 1, orderPrivateCar.getOrderMoney());
			orderPrivateCar.setSplitAllocation(JSON.toJSONString(map));
			this.updateById(orderPrivateCar);

			// TODO: 2020/5/24 这里需要给司机和用户推送订单状态
			new Thread(new Runnable() {
			@Override
			public void run() {
			pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0);
			}
			}).start();

			systemNoticeService.addSystemNotice(1, "您已使用" + (type == 1 ? "微信": (type==2?"支付宝":"云闪付")) + "成功完成出行订单支付，谢谢使用！", orderPrivateCar.getUserId(), 1);

			new Thread(new Runnable() {
			@Override
			public void run() {
			if(pushMinistryOfTransport){//上传数据
			pushMinistryOfTransportUtil.operatePay(orderPrivateCar.getId());
			}
			}
			}).start();

			}else{
			System.err.println("预支付数据异常（orderId = " + id + ")");
			}
			}

			@Override
			public List<OrderPrivateCar> queryOrder(Integer uid, Integer... state) throws Exception {
			return orderPrivateCarMapper.queryByState_(uid, state);
			}

			@Override
			public List<Map<String, Object>> queryMyOrderList(Integer uid, Integer pageNum, Integer size) throws Exception {
			pageNum = (pageNum - 1) * size;
			List<Map<String, Object>> maps = orderPrivateCarMapper.queryMyOrderList(uid, pageNum, size);
			for(Map<String, Object> map : maps){
			if(Integer.valueOf(String.valueOf(map.get("state"))) == 11){
			map.put("state", map.get("oldState"));
			}
			}
			return maps;
			}

			@Override
			public List<Map<String, Object>> queryInvoiceOrder(Integer type, Date startTime, Date endTime, Double startMoney, Double endMoney, Integer uid) throws Exception {
			startTime = dateUtil.getStartOrEndDate(startTime, "start");
			endTime = dateUtil.getStartOrEndDate(endTime, "end");
			return orderPrivateCarMapper.queryInvoiceOrder(type, startTime, endTime, startMoney, endMoney, uid);
			}

			public void pushOrder(Integer id, Integer rideType, Integer serverCarModelId, Double startLon, Double startLat) throws Exception{
			new Thread(new Runnable() {
			@Override
			public void run() {
			try {
			Integer orderType = rideType==1?1:rideType==2?9:8;
			orderIds.add(id);//添加记录，防止调用接口重复提醒无人接单
			String vehicle = (String) redisTemplate.opsForValue().get("VEHICLE");
			List<Integer> integers = new ArrayList<>();
			if(ToolUtil.isNotEmpty(vehicle)){
			integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
			}
			Company query = companyCityService.query(startLon.toString(), startLat.toString());//获取起点所属分公司
			List<PushOrder> querys = pushOrderService.querys(null, 1, query.getId());//获取需要推送的次数
			for(int i = 1; i <= querys.size(); i++){
			OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(id);
			if (null == orderPrivateCar \|\| orderPrivateCar.getState() > 1) {
			break;
			}
			PushOrder pushOrder = pushOrderService.querys(i, 1, query.getId()).get(0);
			System.out.println("pushOrder:"+pushOrder);
			int i2 = pushOrder.getPushTime() / 10;
			if(i2==0){
			i2=1;
			}
			for (int i1 = 0; i1 < i2 ; i1++) {
			if (orderPrivateCar.getState() > 1) {
			break;
			}
			//获取空闲司机
			List<Driver> list = driverService.queryIdleDriver(orderType, serverCarModelId, startLon, startLat, pushOrder.getPushDistance(), null);//所有附近空闲司机
			if (list.size() > 0) {
			double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
			int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
			lastIndex = lastIndex == 0 ? list.size() : lastIndex;
			list = list.subList(0, lastIndex);//获取空闲司机中占比数据
			for (Driver driver : list) {//开始进行推送
			boolean bo = false;
			for (Integer integer : integers) {
			if (integer.compareTo(driver.getId()) == 0) {
			bo = true;
			break;
			}
			}
			if (bo) {
			continue;
			}
			pushUtil.pushOrderState(2, driver.getId(), id, 1, 1, pushOrder.getPushTime());
			}
			}
			Thread.sleep(10000);//设置等待时间
			Integer state = orderPrivateCarMapper.selectById(orderPrivateCar.getId()).getState();
			if (state > 1) {
			orderIds.remove(orderPrivateCar.getId());
			break;
			}
			if (i == querys.size()) {
			pushUtil.pushEndPush(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1);
			orderIds.remove(orderPrivateCar.getId());
			}
			}
			}
			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			}).start();
			}

			@Override
			public List<Map<String, Object>> queryMyTravelRecord(Integer uid) throws Exception {
			return orderPrivateCarMapper.queryMyTravelRecord(uid);
			}

			/**
			* 推送抢单数据
			* @param orderPrivateCar
			* @throws Exception
			*/
			public void pushOrder(OrderPrivateCar orderPrivateCar) throws Exception{
			new Thread(new Runnable() {
			@Override
			public void run() {
			try {
			Integer id = orderPrivateCar.getId();
			Integer orderType = orderPrivateCar.getRideType()==1?1:orderPrivateCar.getRideType()==2?9:8;
			orderIds.add(orderPrivateCar.getId());//添加记录，防止调用接口重复提醒无人接单
			String vehicle = (String) redisTemplate.opsForValue().get("VEHICLE");
			List<Integer> integers = new ArrayList<>();
			if(ToolUtil.isNotEmpty(vehicle)){
			integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
			}
			Company query = companyCityService.query(String.valueOf(orderPrivateCar.getStartLon()), String.valueOf(orderPrivateCar.getStartLat()));//获取起点所属分公司
			List<PushOrder> querys = pushOrderService.querys(null, 1, query.getId());//获取需要推送的次数
			for(int i = 1; i <= querys.size()+5; i++){
			OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(id);
			if (null == orderPrivateCar \|\| orderPrivateCar.getState() > 1) {
			break;
			}
			PushOrder pushOrder = pushOrderService.querys(i, 1, query.getId()).get(0);
			System.out.println("pushOrder:"+pushOrder);
			int i2 = pushOrder.getPushTime() / 10;
			if(i2==0){
			i2=1;
			}
			for (int i1 = 0; i1 < i2 ; i1++) {
			if (orderPrivateCar.getState() > 1) {
			break;
			}
			//获取空闲司机
			List<Driver> list = driverService.queryIdleDriver(orderType, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机
			if (list.size() > 0) {
			double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
			int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
			lastIndex = lastIndex == 0 ? list.size() : lastIndex;
			list = list.subList(0, lastIndex);//获取空闲司机中占比数据
			for (Driver driver : list) {//开始进行推送
			boolean bo = false;
			for (Integer integer : integers) {
			if (integer.compareTo(driver.getId()) == 0) {
			bo = true;
			break;
			}
			}
			if (bo) {
			continue;
			}
			pushUtil.pushOrderState(2, driver.getId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), pushOrder.getPushTime());
			}
			}
			Thread.sleep(10000);//设置等待时间
			Integer state = orderPrivateCar.getState();
			if (state > 1) {
			orderIds.remove(orderPrivateCar.getId());
			return;
			}
			if (i == querys.size()+5 && state == 1) {
			pushUtil.pushEndPush(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1);
			orderIds.remove(orderPrivateCar.getId());
			}
			}
			}
			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			}).start();
			}


			/**
			* 获取红包使用记录
			* @param uid
			* @return
			* @throws Exception
			*/
			@Override
			public List<Map<String, Object>> queryRedEnvelope(Integer uid) throws Exception {
			return orderPrivateCarMapper.queryRedEnvelope(uid);
			}

			/**
			* 获取下单推送完后没有司机接单的提醒
			* @return
			* @throws Exception
			*/
			@Override
			public EndPushWarpper queryEndPush(Integer uid) throws Exception {
			List<OrderPrivateCar> list = orderPrivateCarMapper.queryByState(uid, null, null, 1);
			EndPushWarpper endPushWarpper = new EndPushWarpper();
			if(list.size() > 0){
			OrderPrivateCar orderPrivateCar = list.get(0);
			if(!orderIds.contains(orderPrivateCar.getId())){
			endPushWarpper.setOrderId(orderPrivateCar.getId());
			endPushWarpper.setOrderType(1);
			endPushWarpper.setState(1);
			List<PushOrder> querys = pushOrderService.querys(null, 2, orderPrivateCar.getCompanyId());//获取需要推送的次数
			int time = 0;
			for(int i = 1; i <= querys.size()+5; i++){
			PushOrder pushOrder = pushOrderService.querys(i, 2, orderPrivateCar.getCompanyId()).get(0);
			time += pushOrder.getPushTime() * 1000;
			}
			//当前时间减去推单总时间大于下单时间
			if((System.currentTimeMillis() - time) > orderPrivateCar.getInsertTime().getTime()){
			endPushWarpper.setState(2);
			}
			}
			}
			return endPushWarpper;
			}


			@Override
			@Transactional(propagation = Propagation.REQUIRES_NEW)
			public ResultUtil payThankYouFee(Integer uid, Integer orderId, Double money, Integer payType, Integer type) throws Exception {
			UserInfo userInfo = userInfoService.selectById(uid);
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			ResultUtil resultUtil = ResultUtil.success();
			if(payType == 1){//微信支付
			String app = type == 1 ? "APP" : "JSAPI";
			resultUtil = payMoneyUtil.weixinpay("感谢费", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/wxPayThankYouFee", app, userInfo.getAppletsOpenId());
			paymentRecordService.saveData(3, uid, 1, orderId, 1, 1, money, "", 1);//添加预支付数据
			}
			if(payType == 2){//支付宝支付
			resultUtil = payMoneyUtil.alipay("感谢费", "感谢费", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/aliPayThankYouFee");
			paymentRecordService.saveData(3, uid, 1, orderId, 1, 2, money, "", 1);//添加预支付数据
			}
			if(payType == 3) {//余额支付
			if (userInfo.getBalance() == null \|\| userInfo.getBalance() < money) {
			return ResultUtil.error("余额不足，无法完成支付");
			}

			/**
			* 获取下单推送完后没有司机接单的提醒
			*
			* @return
			* @throws Exception
			*/
			@Override
			public EndPushWarpper queryEndPush(Integer uid) throws Exception {
			List<OrderPrivateCar> list = orderPrivateCarMapper.queryByState(uid, null, null, 1);
			EndPushWarpper endPushWarpper = new EndPushWarpper();
			if (list.size() > 0) {
			OrderPrivateCar orderPrivateCar = list.get(0);
			if (!orderIds.contains(orderPrivateCar.getId())) {
			endPushWarpper.setOrderId(orderPrivateCar.getId());
			endPushWarpper.setOrderType(1);
			endPushWarpper.setState(1);
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			List<PushOrder> querys = pushOrderService.querys(null, 2, openCity.getId());//获取需要推送的次数
			int time = 0;
			for (int i = 1; i <= querys.size() + 5; i++) {
			int finalI = i;
			PushOrder pushOrder = querys.stream().filter(s -> s.getType() == (finalI <= 3 ? finalI : 3)).findFirst().orElse(null);
			time += pushOrder.getPushTime() * 1000;
			}
			//当前时间减去推单总时间大于下单时间
			if ((System.currentTimeMillis() - time) > orderPrivateCar.getInsertTime().getTime()) {
			endPushWarpper.setState(2);
			}
			}
			}
			return endPushWarpper;
			}

			/**
			* 获取红包使用记录
			*
			* @param uid
			* @return
			* @throws Exception
			*/
			@Override
			public List<Map<String, Object>> queryRedEnvelope(Integer uid) throws Exception {
			return orderPrivateCarMapper.queryRedEnvelope(uid);
			}

			@Override
			@Transactional(propagation = Propagation.REQUIRES_NEW)
			public ResultUtil payThankYouFee(Integer uid, Integer orderId, Double money, Integer payType, Integer type) throws Exception {
			UserInfo userInfo = userInfoService.selectById(uid);
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			ResultUtil resultUtil = ResultUtil.success();
			if (payType == 1) {//微信支付
			String app = type == 1 ? "APP" : "JSAPI";
			resultUtil = payMoneyUtil.weixinpay("感谢费", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/wxPayThankYouFee", app, userInfo.getAppletsOpenId());
			paymentRecordService.saveData(3, uid, 1, orderId, 1, 1, money, "", 1);//添加预支付数据
			}
			if (payType == 2) {//支付宝支付
			resultUtil = payMoneyUtil.alipay("感谢费", "感谢费", "", orderId + "_1_" + UUIDUtil.getRandomCode(5), money.toString(), "/base/aliPayThankYouFee");
			paymentRecordService.saveData(3, uid, 1, orderId, 1, 2, money, "", 1);//添加预支付数据
			}
			if (payType == 3) {//余额支付
			if (userInfo.getBalance() == null \|\| userInfo.getBalance() < money) {
			return ResultUtil.error("余额不足，无法完成支付");
			}
			// resultUtil= appOrderController.moneyPay(orderId,userInfo.getId(),money);
			// if(resultUtil.getCode()==500){
			// return ResultUtil.error("电子余额不足，无法完成支付");
			// }
			userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());

			SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
			userInfo.setIntegral(userInfo.getIntegral() + (money.intValue() * query1.getIntegral()));//积分

			//添加交易明细
			transactionDetailsService.saveData(uid, "快车订单-感谢费", money, 2, 1, 1, 1, orderId);
			userInfoService.updateById(userInfo);

			orderPrivateCar.setThankYouFee(money);
			this.updateById(orderPrivateCar);
			userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());

			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
			userInfo.setIntegral(userInfo.getIntegral() + (money.intValue() * query1.getIntegral()));//积分

			//添加交易明细
			transactionDetailsService.saveData(uid, "快车订单-感谢费", money, 2, 1, 1, 1, orderId);
			userInfoService.updateById(userInfo);

			orderPrivateCar.setThankYouFee(money);
			this.updateById(orderPrivateCar);

			//添加已收入明细
			incomeService.saveData(2, orderPrivateCar.getDriverId(), 6, orderPrivateCar.getId(), 1, money);
			Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
			driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driverService.updateById(driver);
			systemNoticeService.addSystemNotice(1, "您已使用余额成功完成感谢费支付，谢谢使用！", uid, 1);

			}
			if (payType == 4) {
			Double payMoney = orderPrivateCar.getThankYouFee();
			Integer integer = paymentRecordService.saveData(3, uid, 1, orderId, 1, 4, money, "", 1);
			resultUtil = appOrderController.placeAnOrder(new BigDecimal(money), 4, orderId, 11, integer);
			}
			return resultUtil;
			}

			@Override
			public void payThankYouFeeCallback(Integer orderId, String order_id, Integer payType) throws Exception {
			System.out.println(orderId + "_" + order_id + "_" + payType);
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
			System.out.println("用户" + userInfo);
			PaymentRecord query = paymentRecordService.query(3, userInfo.getId(), 1, orderId, 1, payType, 1);
			System.out.println("query:" + query);
			query.setState(2);
			query.setCode(order_id);
			paymentRecordService.updateById(query);
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			SysIntegral query1 = sysIntegralMapper.query(openCity.getId());
			System.out.println("query1:" + query1);
			userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分

			//添加交易明细
			transactionDetailsService.saveData(userInfo.getId(), "快车订单-感谢费", query.getAmount(), 2, 1, 1, 1, orderId);
			userInfoService.updateById(userInfo);

			orderPrivateCar.setThankYouFee(query.getAmount());
			this.updateById(orderPrivateCar);

			//添加已收入明细
			incomeService.saveData(2, orderPrivateCar.getDriverId(), 6, orderPrivateCar.getId(), 1, query.getAmount());
			Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
			driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driverService.updateById(driver);
			systemNoticeService.addSystemNotice(1, "您已使用" + (payType == 1 ? "微信" : (payType == 2 ? "支付宝" : "云闪付")) + "成功完成感谢费支付，谢谢使用！", userInfo.getId(), 1);
			System.out.println("出租车感谢费ok");
			}

			@Override
			public List<Map<String, Object>> queryOrderInfo2(Integer orderId, Integer state, String lon, String lat) {
			return this.baseMapper.queryOrderInfo2(orderId, state, lon, lat);
			}

			/**
			* 获取专车未支付订单
			*
			* @param uid
			* @return
			*/
			@Override
			public List<UnPayOrderVO> getUnpayPrivateOrders(Integer uid) {
			EntityWrapper<OrderPrivateCar> wrapper = new EntityWrapper<>();
			wrapper.eq("userId", uid);
			wrapper.eq("state", 7);
			//查出未支付订单
			List<OrderPrivateCar> orderPrivateCars = this.selectList(wrapper);
			List<UnPayOrderVO> unPayOrderVOList = new ArrayList<>();
			for (OrderPrivateCar order : orderPrivateCars) {
			UnPayOrderVO vo = new UnPayOrderVO();
			// 复制属性
			//添加司机信息
			DriverInfoWarpper driverInfoWarpper = new DriverInfoWarpper();
			Driver driver = driverService.selectById(order.getDriverId());
			BeanUtils.copyProperties(driver, driverInfoWarpper);
			vo.setDriverInfoWarpper(driverInfoWarpper);
			//其余信息
			BeanUtils.copyProperties(order, vo);
			unPayOrderVOList.add(vo);
			}

			return unPayOrderVOList;
			}

			public void pushOrder(Integer id, Integer rideType, Integer serverCarModelId, Double startLon, Double startLat) throws Exception {
			new Thread(new Runnable() {
			@Override
			public void run() {
			try {
			Integer orderType = rideType == 1 ? 1 : rideType == 2 ? 9 : 8;
			orderIds.add(id);//添加记录，防止调用接口重复提醒无人接单
			String vehicle = (String) redisTemplate.opsForValue().get("VEHICLE");
			List<Integer> integers = new ArrayList<>();
			if (ToolUtil.isNotEmpty(vehicle)) {
			integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
			}
			OpenCity openCity = openCityService.openCity1(startLon.toString(), startLat.toString());
			List<PushOrder> querys = pushOrderService.querys(null, 1, openCity.getId());//获取需要推送的次数
			//整轮派单结束，若无司机接单，系统自动增加派单5轮，若增加5轮后任无司机接单，则系统结束派单，乘客端显示无司机接单、是否再次打车
			for (int i = 1; i <= querys.size() + 5; i++) {
			OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(id);
			if (null == orderPrivateCar \|\| orderPrivateCar.getState() > 1) {
			break;
			}
			int finalI = i;
			PushOrder pushOrder = querys.stream().filter(s -> s.getType() == (finalI <= 3 ? finalI : 3)).findFirst().orElse(null);
			System.out.println("pushOrder:" + pushOrder);
			int i2 = pushOrder.getPushTime() / 10;
			if (i2 == 0) {
			i2 = 1;
			}
			for (int i1 = 0; i1 < i2; i1++) {
			if (orderPrivateCar.getState() > 1) {
			break;
			}
			//获取空闲司机
			List<Driver> list = driverService.queryIdleDriver(orderType, serverCarModelId, startLon, startLat, pushOrder.getPushDistance(), null);//所有附近空闲司机
			if (list.size() > 0) {
			double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
			int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
			lastIndex = lastIndex == 0 ? list.size() : lastIndex;
			list = list.subList(0, lastIndex);//获取空闲司机中占比数据
			for (Driver driver : list) {//开始进行推送
			boolean bo = false;
			for (Integer integer : integers) {
			if (integer.compareTo(driver.getId()) == 0) {
			bo = true;
			break;
			}
			}
			if (bo) {
			continue;
			}
			pushUtil.pushOrderState(2, driver.getId(), id, 1, 1, pushOrder.getPushTime());
			}
			}
			Thread.sleep(10000);//设置等待时间
			Integer state = orderPrivateCarMapper.selectById(orderPrivateCar.getId()).getState();
			if (state > 1) {
			orderIds.remove(orderPrivateCar.getId());
			break;
			}
			if (i == querys.size() + 5) {
			pushUtil.pushEndPush(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1);
			orderIds.remove(orderPrivateCar.getId());
			}
			}
			}
			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			}).start();
			}

			/**
			* 推送抢单数据
			*
			* @param orderPrivateCar
			* @throws Exception
			*/
			public void pushOrder(OrderPrivateCar orderPrivateCar) throws Exception {
			new Thread(new Runnable() {
			@Override
			public void run() {
			try {
			Integer id = orderPrivateCar.getId();
			Integer orderType = orderPrivateCar.getRideType() == 1 ? 1 : orderPrivateCar.getRideType() == 2 ? 9 : 8;
			orderIds.add(orderPrivateCar.getId());//添加记录，防止调用接口重复提醒无人接单
			String vehicle = (String) redisTemplate.opsForValue().get("VEHICLE");
			List<Integer> integers = new ArrayList<>();
			if (ToolUtil.isNotEmpty(vehicle)) {
			integers = JSON.parseArray(vehicle).toJavaList(Integer.class);
			}
			OpenCity openCity = openCityService.openCity1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
			List<PushOrder> querys = pushOrderService.querys(null, 1, openCity.getId());//获取需要推送的次数
			for (int i = 1; i <= querys.size() + 5; i++) {
			OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(id);
			if (null == orderPrivateCar \|\| orderPrivateCar.getState() > 1) {
			break;
			}
			int finalI = i;
			PushOrder pushOrder = querys.stream().filter(s -> s.getType() == (finalI <= 3 ? finalI : 3)).findFirst().orElse(null);
			System.out.println("pushOrder:" + pushOrder);
			int i2 = pushOrder.getPushTime() / 10;
			if (i2 == 0) {
			i2 = 1;
			}
			for (int i1 = 0; i1 < i2; i1++) {
			if (orderPrivateCar.getState() > 1) {
			break;
			}
			//获取空闲司机
			List<Driver> list = driverService.queryIdleDriver(orderType, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机
			if (list.size() > 0) {
			double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
			int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取）
			lastIndex = lastIndex == 0 ? list.size() : lastIndex;
			list = list.subList(0, lastIndex);//获取空闲司机中占比数据
			for (Driver driver : list) {//开始进行推送
			boolean bo = false;
			for (Integer integer : integers) {
			if (integer.compareTo(driver.getId()) == 0) {
			bo = true;
			break;
			}
			}
			if (bo) {
			continue;
			}
			pushUtil.pushOrderState(2, driver.getId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), pushOrder.getPushTime());
			}
			}
			Thread.sleep(10000);//设置等待时间
			Integer state = orderPrivateCar.getState();
			if (state > 1) {
			orderIds.remove(orderPrivateCar.getId());
			return;
			}
			if (i == querys.size() + 5 && state == 1) {
			pushUtil.pushEndPush(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1);
			orderIds.remove(orderPrivateCar.getId());
			}
			}
			}
			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			}).start();
			}




			@Override
			public void addAppeal(Integer uid, Integer orderId,String abnormalIntro, String abnormalImg) {
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			if(orderPrivateCar.getState()!=7 \|\| orderPrivateCar.getAbnormalIntro()!=null){
			throw new RuntimeException("此订单无法申诉");
			}
			orderPrivateCar.setAbnormalIntro(abnormalIntro);
			orderPrivateCar.setAbnormalImg(abnormalImg);
			orderPrivateCar.setAbnormal(1);
			this.baseMapper.updateById(orderPrivateCar);

			}

			//添加已收入明细
			incomeService.saveData(2, orderPrivateCar.getDriverId(), 6, orderPrivateCar.getId(), 1, money);
			Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
			driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driverService.updateById(driver);
			systemNoticeService.addSystemNotice(1, "您已使用余额成功完成感谢费支付，谢谢使用！", uid, 1);
			@Override
			public void promotion(Integer orderId) {
			OrderPrivateCar orderPrivateCar = this.baseMapper.selectById(orderId);
			UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
			// if(userInfo.getBindDriverId()!=null && userInfo.getBindExpireDate().getTime()<=System.currentTimeMillis()){
			// 开始绑定的后面到期也结算
			if(orderPrivateCar.getPromotionDriverId()!=null ){
			String registAreaCode = userInfo.getRegistAreaCode();
			TDriverPromotionActivity tDriverPromotionActivity = driverPromotionActivityService.selectOne(new EntityWrapper<TDriverPromotionActivity>().eq("districtCode", registAreaCode).ge("startTime", new Date()).lt("endTime", new Date()).last("AND FIND_IN_SET(" + 1 + ", bizType) limit 1"));
			if(tDriverPromotionActivity!=null){
			Double payMoney = orderPrivateCar.getPayMoney();
			BigDecimal bigDecimal = tDriverPromotionActivity.getCommissionRatio().divide(new BigDecimal(100), 2, RoundingMode.HALF_UP).multiply(new BigDecimal(payMoney)).setScale(2, RoundingMode.HALF_UP);
			orderPrivateCar.setPromotionDriverId(userInfo.getBindDriverId());
			orderPrivateCar.setPromotionMoney(bigDecimal);
			this.baseMapper.updateById(orderPrivateCar);
			}
			}

			}
			if(payType==4){
			Double payMoney = orderPrivateCar.getThankYouFee();
			Integer integer = paymentRecordService.saveData(3, uid, 1, orderId, 1, 4, money, "", 1);
			resultUtil = appOrderController.placeAnOrder(new BigDecimal(money), 4,orderId,11,integer);
			}
			return resultUtil;
			}

			@Override
			public void payThankYouFeeCallback(Integer orderId, String order_id, Integer payType) throws Exception {
			System.out.println(orderId+"_"+order_id+"_"+payType);
			OrderPrivateCar orderPrivateCar = this.selectById(orderId);
			UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
			System.out.println("用户"+userInfo);
			PaymentRecord query = paymentRecordService.query(3, userInfo.getId(), 1, orderId, 1, payType, 1);
			System.out.println("query:"+query);
			query.setState(2);
			query.setCode(order_id);
			paymentRecordService.updateById(query);
			System.out.println(orderPrivateCar.getCompanyId());
			SysIntegral query1 = sysIntegralMapper.query(orderPrivateCar.getCompanyId());
			System.out.println("query1:"+query1);
			userInfo.setIntegral(userInfo.getIntegral() + (query.getAmount().intValue() * query1.getIntegral()));//积分

			//添加交易明细
			transactionDetailsService.saveData(userInfo.getId(), "快车订单-感谢费", query.getAmount(), 2, 1, 1, 1, orderId);
			userInfoService.updateById(userInfo);

			orderPrivateCar.setThankYouFee(query.getAmount());
			this.updateById(orderPrivateCar);

			//添加已收入明细
			incomeService.saveData(2, orderPrivateCar.getDriverId(), 6, orderPrivateCar.getId(), 1, query.getAmount());
			Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
			driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
			driverService.updateById(driver);
			systemNoticeService.addSystemNotice(1, "您已使用" + (payType == 1 ? "微信" : (payType==2?"支付宝":"云闪付")) + "成功完成感谢费支付，谢谢使用！", userInfo.getId(), 1);
			System.out.println("出租车感谢费ok");
			}

			@Override
			public List<Map<String, Object>> queryOrderInfo2(Integer orderId, Integer state, String lon, String lat) {
			return this.baseMapper.queryOrderInfo2(orderId,state,lon,lat);
			}
			// 是否异常订单
			if (orderPrivateCar.getResponsibilityType() !=null && orderPrivateCar.getResponsibilityType() >2) {
			TAbnormalPayOrder tAbnormalPayOrder = abnormalPayOrderMapper.selectList(new EntityWrapper<TAbnormalPayOrder>().eq("type", 1).eq("orderNum", orderPrivateCar.getOrderNum())).stream().findFirst().orElse(null);
			if (tAbnormalPayOrder != null) {
			tAbnormalPayOrder.setPayStatus(2);
			tAbnormalPayOrder.setPayTime(new Date());
			abnormalPayOrderMapper.updateById(tAbnormalPayOrder);
			}
			}
			}
			}