up

app/Jobs/FiveSecondTaskJob.php

@@ -47,7 +47,9 @@ class FiveSecondTaskJob implements ShouldQueue
             Log::info('🚀 开始执行5秒任务: ' . now());
             
             // 你的业务逻辑
-            $latestIssue = IssueService::getLatestIssue(); // 获取最新的期号
+            IssueService::getLatestIssue(); // 获取最新的期号
+
+            IssueService::syncCloseIssue(); // 同步封盘的期号
             // Log::info('✅ 获取到最新期号: ' . ($latestIssue ?? '无'));
             
             // 重要：使用类名而不是 self()，避免递归

app/Services/IssueService.php

@@ -617,4 +617,17 @@ class IssueService extends BaseService
         // $oldList = self::findAll(['status' => self::model()::STATUS_CLOSE]);    // 获取所有封盘的期号
         return $result;
     }
+
+    // 停止下注
+    public static function syncCloseIssue()
+    {
+
+        $list = self::model()::where('status', self::model()::STATUS_BETTING)
+                ->where('end_time', '<', date('Y-m-d H:i:s',time() + 20)) // 提前20秒
+                ->get();
+
+        foreach($list as $k => $v){
+            self::closeBetting($v->id);
+        }
+    }
 }