增加定时任务查询订单状态

Pu Zhibing

2025-08-04 e9dba0136ace4a62ff5a9c30941b79fc15d10c33

增加定时任务查询订单状态

 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;
@@ -2225,8 +2227,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) {

 UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/qianyuntong/OrderUtil.java

@@ -569,6 +569,8 @@
     * @return
     */
    public static GetPaymentInfo paymentInfo(GetPaymentInfoDataRequest getPaymentInfoDataRequest) {
        getPaymentInfoDataRequest.setPartnerId("5400004");
		
        GetPaymentInfoRequest request = new GetPaymentInfoRequest();
        request.setRequstType("POST");
        request.setBusType(1);