From d98e2b4b6ecc3da47030a8b188944f27f1e40662 Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期二, 05 八月 2025 14:29:42 +0800 Subject: [PATCH] 修改bug --- UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java | 43 +++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 41 insertions(+), 2 deletions(-) diff --git a/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java b/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java index ffc0899..c2d2d11 100644 --- a/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java +++ b/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java @@ -49,6 +49,8 @@ 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; @@ -2228,7 +2230,7 @@ }else{ //拉起支付 TradePayOff1Data tradePayOff1Data = new TradePayOff1Data(); - tradePayOff1Data.setPartnerPayId("PR" + orderPrivateCar.getId()); + tradePayOff1Data.setPartnerPayId(orderPrivateCar.getTravelId()); tradePayOff1Data.setTotalFee(Double.valueOf(orderMoney * 100).intValue() + ""); tradePayOff1Data.setRetUrl(path); tradePayOff1Data.setClientIp(ip); @@ -2244,8 +2246,45 @@ } 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) { -- Gitblit v1.7.1