Sfoglia il codice sorgente

update: 修改 TaskSubscriber 为 TimerSubscriber

joe 4 anni fa
parent
commit
4244a61862
3 ha cambiato i file con 12 aggiunte e 12 eliminazioni
  1. 1 1
      app/event.php
  2. 3 3
      crmeb/command/Timer.php
  3. 8 8
      crmeb/subscribes/TimerSubscribe.php

+ 1 - 1
app/event.php

@@ -30,6 +30,6 @@ return [
         crmeb\subscribes\UserSubscribe::class,//用户事件订阅类
         crmeb\subscribes\MaterialSubscribe::class,//素材事件订阅类
         crmeb\subscribes\MessageSubscribe::class,//消息事件订阅类
-        crmeb\subscribes\TaskSubscribe::class,//定时任务事件订阅类
+        crmeb\subscribes\TimerSubscribe::class,//定时任务事件订阅类
     ],
 ];

+ 3 - 3
crmeb/command/Timer.php

@@ -54,7 +54,7 @@ class Timer extends Command
         Worker::$pidFile = app()->getRootPath().'timer.pid';
         $task = new Worker();
         $task->count = 1;
-        event('Task_6');
+        event('Timer_6');
         $task->onWorkerStart = [$this, 'start'];
         $task->runAll();
     }
@@ -71,10 +71,10 @@ class Timer extends Command
         $this->timer = \Workerman\Lib\Timer::add($this->interval, function () use (&$task) {
             try {
                 $now = time();
-                event('Task_2');
+                event('Timer_2');
                 foreach ($task as $sec => $time) {
                     if ($now - $time >= $sec) {
-                        event('Task_' . $sec);
+                        event('Timer_' . $sec);
                         $task[$sec] = $now;
                     }
                 }

+ 8 - 8
crmeb/subscribes/TaskSubscribe.php → crmeb/subscribes/TimerSubscribe.php

@@ -15,7 +15,7 @@ use crmeb\services\async\WechatNotify;
  * Class TaskSubscribe
  * @package crmeb\subscribes
  */
-class TaskSubscribe
+class TimerSubscribe
 {
     public function handle()
     {
@@ -25,21 +25,21 @@ class TaskSubscribe
     /**
      * 2秒钟执行的方法
      */
-    public function onTask_2()
+    public function onTimer_2()
     {
     }
 
     /**
      * 6秒钟执行的方法
      */
-    public function onTask_6()
+    public function onTimer_6()
     {
     }
 
     /**
      * 10秒钟执行的方法
      */
-    public function onTask_10()
+    public function onTimer_10()
     {
         WechatNotify::notify();
     }
@@ -47,7 +47,7 @@ class TaskSubscribe
     /**
      * 30秒钟执行的方法
      */
-    public function onTask_30()
+    public function onTimer_30()
     {
         try {
             Db::startTrans();
@@ -82,21 +82,21 @@ class TaskSubscribe
     /**
      * 60秒钟执行的方法
      */
-    public function onTask_60()
+    public function onTimer_60()
     {
     }
 
     /**
      * 180秒钟执行的方法
      */
-    public function onTask_180()
+    public function onTimer_180()
     {
     }
 
     /**
      * 300秒钟执行的方法
      */
-    public function onTask_300()
+    public function onTimer_300()
     {
         UserToken::delToken();//删除一天前的过期token
         SystemAttachment::emptyYesterdayAttachment();//清除昨日海报