From 36695821ea10197d7758babc7bc2b5dfb66dd88e Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期六, 24 六月 2023 09:30:26 +0800
Subject: [PATCH] 修改bug

---
 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java |   22 +++++++++++++++++++++-
 1 files changed, 21 insertions(+), 1 deletions(-)

diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java
index fb16d56..88cdb10 100644
--- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java
+++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java
@@ -9,6 +9,8 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.util.Set;
+
 
 /**
  * 定时任务工具类
@@ -28,6 +30,24 @@
     @Autowired
     private IYouTuiDriverService youTuiDriverService;
 
+    @Autowired
+    private RedisUtil redisUtil;
+
+
+    /**
+     * 5秒推送
+     */
+    @Scheduled(fixedRate = 1000 * 5)
+    public void task5Seconds(){
+        try {
+            Set<String> orderServices = redisUtil.getSetAllValue("orderService");
+            for (String s : orderServices) {
+                orderService.pushOrderInfo(Long.valueOf(s));//开始推送订单数据
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
 
 
 
@@ -37,7 +57,6 @@
     @Scheduled(fixedRate = 1000 * 60)
     public void taskMinute(){
         try {
-            orderService.completeCollection();
             youTuiDriverService.editState();
         } catch (Exception e) {
             e.printStackTrace();
@@ -51,6 +70,7 @@
     @Scheduled(cron = "0 0 0 * * *")
     public void taskDay(){
         try {
+            orderService.completeCollection();
             accountChangeDetailService.deductionInsurance();
         }catch (Exception e){
             e.printStackTrace();

--
Gitblit v1.7.1