| | |
|---|
| | | import java.math.RoundingMode; |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.LinkedBlockingQueue; |
|---|
| | | import java.util.concurrent.ThreadPoolExecutor; |
|---|
| | | import java.util.concurrent.TimeUnit; |
|---|
| | | import java.util.concurrent.locks.Lock; |
|---|
| | | import java.util.concurrent.locks.ReentrantLock; |
|---|
| | |
|---|
| | | } |
|---|
| | | resultUtil = ResultUtil.success(payInfo.getData().getRedirectUrl()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | paymentRecordService.saveData(1, orderPrivateCar.getUserId(), 1, orderId, 1, 1, orderMoney, "", 1);//添加预支付数据 |
|---|
| | | |
|---|
| | | //创建定时任务查询订单支付状态 |
|---|
| | | ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); |
|---|
| | | threadPoolExecutor.execute(()->{ |
|---|
| | | try { |
|---|
| | | int num = 1; |
|---|
| | | int wait = 0; |
|---|
| | | while (num <= 13) { |
|---|
| | | int min = 5000; |
|---|
| | | wait += (min * num); |
|---|
| | | OrderPrivateCar orderPrivateCar1 = this.selectById(orderPrivateCar.getId()); |
|---|
| | | if (orderPrivateCar1.getState() != 7) { |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | GetTravelItineraryListRequest request = new GetTravelItineraryListRequest(); |
|---|
| | | request.setCustomerId(userInfo.getOnconUUID()); |
|---|
| | | request.setOrderNo("PR" + orderPrivateCar1.getId()); |
|---|
| | | request.setDriverId(driver.getEmpId().toString()); |
|---|
| | | ListPage<List<TravelItinerary>> travelItineraryList = OrderUtil.getTravelItineraryList(request); |
|---|
| | | TravelItinerary travelItinerary = travelItineraryList.getList().get(0); |
|---|
| | | if(travelItinerary.getStatus() != 7 || travelItinerary.getOrderStatus() == 11){ |
|---|
| | | GetPaymentInfoDataRequest getPaymentInfoDataRequest = new GetPaymentInfoDataRequest(); |
|---|
| | | getPaymentInfoDataRequest.setPartnerPayId(orderPrivateCar1.getTravelId()); |
|---|
| | | GetPaymentInfo getPaymentInfo = OrderUtil.paymentInfo(getPaymentInfoDataRequest); |
|---|
| | | payOrderPrivateCarCallback(orderPrivateCar1.getId(), getPaymentInfo.getPayId(), 1); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | Thread.sleep(wait); |
|---|
| | | num++; |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | }finally { |
|---|
| | | threadPoolExecutor.shutdown(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | }); |
|---|
| | | |
|---|
| | | } |
|---|
| | | if (payType == 2) {//支付宝支付 |
|---|
| | | if (orderMoney == 0) { |
|---|
