From 4eac3c56fb5700063f56442e9d70ff13f1f65958 Mon Sep 17 00:00:00 2001
From: ASUS <515617283@qq.com>
Date: Fri, 15 Aug 2025 18:43:15 +0800
Subject: [PATCH] database

---
 app/command/SpinningTask3.php | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/app/command/SpinningTask3.php b/app/command/SpinningTask3.php
index 9bc1071..e9846e3 100644
--- a/app/command/SpinningTask3.php
+++ b/app/command/SpinningTask3.php
@@ -64,8 +64,14 @@ class SpinningTask3 extends Command
     }
     public function execAsync($list)
     {
-        foreach ($list as $k => $value) {
-            pushQueue(DiscCompensateJob::class, $value);
+        foreach ($list as $k => $data) {
+            $queue = class_basename(DiscCompensateJob::class);
+            $data[] = [
+                'queueId' => uuid(),
+            ];
+            Log::info("消息队列发送消息，对列名: $queue, 携带数据: ".json_encode($data).', 延时时间: 0');
+            // 投递延迟消息，消息会在60秒后处理
+            \Webman\RedisQueue\Redis::send($queue, $data);
         }
     }
 }