From 40b94a2b7afb9acc38fcda17b5375a47ec928da8 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期日, 15 十二月 2024 01:36:00 +0800
Subject: [PATCH] 新增加功能

---
 UserAHTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java |   28 +++++++++++++++++++++++++++-
 1 files changed, 27 insertions(+), 1 deletions(-)

diff --git a/UserAHTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java b/UserAHTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java
index 9965c15..f283d43 100644
--- a/UserAHTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java
+++ b/UserAHTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java
@@ -1,10 +1,13 @@
 package com.stylefeng.guns.modular.system.util;
 
 
+import com.stylefeng.guns.core.util.ToolUtil;
+import com.stylefeng.guns.modular.specialTrain.server.IOrderPrivateCarService;
 import com.stylefeng.guns.modular.system.service.IUserCouponRecordService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
 
 
 /**
@@ -15,7 +18,30 @@
 
     @Autowired
     private IUserCouponRecordService userCouponRecordService;
-
+    
+    @Autowired
+    private IOrderPrivateCarService orderPrivateCarService;
+    
+    @Autowired
+    private RedisUtil redisUtil;
+    
+    
+    @Scheduled(fixedRate = 1000 * 10)
+    public void taskFiveSeconds(){
+        try {
+            //定时任务推送订单给司机
+            String push_order_ids = redisUtil.getListFirstValue("push_order_ids");
+            if(ToolUtil.isNotEmpty(push_order_ids)){
+                boolean b = orderPrivateCarService.pushOrder1(Integer.valueOf(push_order_ids));
+                if(!b){
+                    redisUtil.addListLeft("push_order_ids", push_order_ids);
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+    
 
 
     /**

--
Gitblit v1.7.1