| | |
|---|
| | | String firstElement = redisService.getFirstElement(name); |
|---|
| | | if (firstElement != null) { |
|---|
| | | String[] split = firstElement.toString().split("_"); |
|---|
| | | // 如果市未处理 创建新任务 |
|---|
| | | // 如果未处理 创建新任务 |
|---|
| | | if (split[2].equals("0")) { |
|---|
| | | String value = split[0] + "_" + split[1] + "_1" + "_"+split[3] + "_"+ split[4] + "_"+ split[5] + "_"+ split[6] + "_"+ split[7]; |
|---|
| | | // 状态改为处理中 |
|---|
| | | // redisService.updateFirst(name, split[0] + "_" + split[1] + "_1"+split[3]+split[4]+split[5]+split[6]); |
|---|
| | | redisService.updateFirst(name, value); |
|---|
| | | threadPoolTaskExecutor.submit(() -> { |
|---|
| | | orderProcess(name, firstElement.toString()); |
|---|
| | | }); |
|---|
| | |
|---|
| | | |
|---|
| | | // |
|---|
| | | // VehiclePositionVo vehiclePositionVo1 = vehiclePositionVo; |
|---|
| | | |
|---|
| | | |
|---|
| | | RLock lock = redissonClient.getLock("FIND_CAR_" + vehiclePositionVo.getVin()); |
|---|
| | | lock.lock(10, TimeUnit.SECONDS); |
|---|
| | | System.err.println("队列："+quoteName+" 车辆："+vehiclePositionVo.getVin()+"订单"+orderNo); |
|---|
| | | try { |
|---|
| | | // VehiclePosition vehiclePosition = vehiclePositionService.findByVehicleId(vehiclePositionVo.getVehicle_id()); |
|---|
| | | R<XpVehicle> vehiclePositionR = xpVehicleClient.findByVehicleVin(vehiclePositionVo.getVin()); |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | BaseVehicleUserDto baseVehicleUserDto = userVehicleClient.addTaxiPassenger(addTaxiPassengerVo); |
|---|
| | | if (baseVehicleUserDto.getCode() == 200) { |
|---|
| | | if (baseVehicleUserDto!=null && baseVehicleUserDto.getCode() == 200) { |
|---|
| | | // TODO 下单 |
|---|
| | | // 绑定成功 弹出这个队列第一个订单 |
|---|
| | | redisService.popFirstElement(quoteName); |
|---|
