no message

public/tests/hook.php

@@ -35,7 +35,7 @@ $oHttp->aData = [
             'type' => 'private'
         ],
         'date' => 1610000000,
-        'text' => '222'
+        'text' => 'reply 2'
     ]
 ];
 

src/Command/Cron.php

@@ -61,6 +61,9 @@ EOL;
             $jobs->resetFreeUserBandwidth();
             $jobs->sendDailyTrafficReport();
             
+            // 每日清除前一天残留TgStep
+            $jobs->clearTgStep();
+
             if (Config::obtain('enable_detect_inactive_user')) {
                 $jobs->detectInactiveUser();
             }

src/Controllers/TestController.php

@@ -24,6 +24,15 @@ session_start();
 final class TestController extends BaseController
 {
     
+    public function test5 ()
+    {
+        $jobs = new CronService();
+        
+        $jobs->clearTgStep();
+        
+        exit;
+    }
+    
     public function test4 ()
     {
 //        session_start();

src/Controllers/TomApi/Tg/HookController.php

@@ -65,6 +65,8 @@ final class HookController
         
         if ($sText === "/break") {
             
+            $oTgStep->clearByFromId($aData["fromId"]);
+            
             $this->sendMessage("ok");
             
             http_response_code(200);exit;
@@ -72,6 +74,7 @@ final class HookController
         
         if (strpos($sText, '/reply') === 0) {
             
+            // 先清除一遍，只进行一个进程
             $oTgStep->clearByFromId($aData["fromId"]);
                  
             $iTicketId = str_replace('/reply', '', $sText);
@@ -105,6 +108,9 @@ final class HookController
                     
                     $r = @json_decode($oHttp->send(), true);
                     
+                    // 不论失败成功都清除step
+                    $oTgStep->clearByFromId($aUpdate["message"]["from"]["id"]);
+                    
                     if ($r["ret"] == 1) {
                         $sMessage = "成功";
                     } else {
@@ -121,7 +127,7 @@ final class HookController
             
         }
         
-        Http::response(200, 'ok');
+        Http::response(200, '无');
 
     }
     

src/Models/TgStep.php

@@ -20,6 +20,7 @@ final class TgStep extends Model
         $oTgStep->cmd = $sCmd;
         $oTgStep->step = $iStep;
         $oTgStep->cache = json_encode($sCache);
+        $oTgStep->date = date("Y-m-d");
         
         $oTgStep->save();
         

src/Services/Cron.php

@@ -16,6 +16,7 @@ use App\Models\Order;
 use App\Models\Paylist;
 use App\Models\SubscribeLog;
 use App\Models\User;
+use App\Models\TgStep;
 use App\Models\Zhuanfas;
 use App\Models\Ducks;
 use App\Services\TomTool\TgSendFormat;
@@ -56,6 +57,11 @@ final class Cron
         echo Tools::toDateTime(time()) . ' 数据库清理完成' . PHP_EOL;
     }
     
+    public static function clearTgStep(): void
+    {
+        TgStep::where("date", "<=", date('Y-m-d', strtotime('-1 day')))->delete();
+    }
+
     public static function detectInactiveUser(): void
     {
         $checkin_days = Config::obtain('detect_inactive_user_checkin_days');