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