feat(crontab): add crontab tasks for clearing, creating, and executing scheduled tasks

Author: lihq1403

src/ConfigProvider.php

@@ -7,10 +7,18 @@
 
 namespace Dtyq\TaskScheduler;
 
+use Dtyq\TaskScheduler\Crontab\TaskSchedulerClearCrontab;
+use Dtyq\TaskScheduler\Crontab\TaskSchedulerCreateCrontab;
+use Dtyq\TaskScheduler\Crontab\TaskSchedulerExecuteCrontab;
+use Dtyq\TaskScheduler\Util\Functions;
+use Hyperf\Crontab\Crontab;
+
 class ConfigProvider
 {
     public function __invoke(): array
     {
+        $appEnv = Functions::getEnv();
+
         return [
             'dependencies' => [
             ],
@@ -23,6 +31,32 @@ public function __invoke(): array
                     ],
                 ],
             ],
+            'crontab' => [
+                (new Crontab())
+                    ->setName($appEnv . '.TaskSchedulerClearCrontab')
+                    ->setRule('0 2 * * *')
+                    ->setCallback([TaskSchedulerClearCrontab::class, 'execute'])
+                    ->setSingleton(true)
+                    ->setMutexExpires(600)
+                    ->setOnOneServer(true)
+                    ->setMemo('清理超过 n 天的调度数据'),
+                (new Crontab())
+                    ->setName($appEnv . '.TaskSchedulerCreateCrontab')
+                    ->setRule('* * * * *')
+                    ->setCallback([TaskSchedulerCreateCrontab::class, 'execute'])
+                    ->setSingleton(true)
+                    ->setMutexExpires(90)
+                    ->setOnOneServer(true)
+                    ->setMemo('创建未来 n 天的调度数据'),
+                (new Crontab())
+                    ->setName($appEnv . '.TaskSchedulerExecuteCrontab')
+                    ->setRule('* * * * *')
+                    ->setCallback([TaskSchedulerExecuteCrontab::class, 'execute'])
+                    ->setSingleton(true)
+                    ->setMutexExpires(90)
+                    ->setOnOneServer(true)
+                    ->setMemo('执行调度'),
+            ],
             'publish' => [
                 [
                     'id' => 'config',

src/Crontab/TaskSchedulerClearCrontab.php

@@ -13,13 +13,11 @@
 use Dtyq\TaskScheduler\Entity\Query\TaskSchedulerQuery;
 use Dtyq\TaskScheduler\Entity\TaskScheduler;
 use Dtyq\TaskScheduler\Service\TaskSchedulerDomainService;
-use Hyperf\Crontab\Annotation\Crontab;
 use Hyperf\Logger\LoggerFactory;
 use Psr\Log\LoggerInterface;
 
 use function Hyperf\Config\config;
 
-#[Crontab(rule: '0 2 * * *', name: 'TaskSchedulerClearCrontab', singleton: true, mutexExpires: 600, onOneServer: true, callback: 'execute', memo: '清理超过 n 天的调度数据')]
 class TaskSchedulerClearCrontab
 {
     private LoggerInterface $logger;

src/Crontab/TaskSchedulerCreateCrontab.php

@@ -11,14 +11,12 @@
 use Dtyq\TaskScheduler\Entity\Query\Page;
 use Dtyq\TaskScheduler\Entity\Query\TaskSchedulerCrontabQuery;
 use Dtyq\TaskScheduler\Service\TaskSchedulerDomainService;
-use Hyperf\Crontab\Annotation\Crontab;
 use Hyperf\Logger\LoggerFactory;
 use Psr\Log\LoggerInterface;
 use Throwable;
 
 use function Hyperf\Config\config;
 
-#[Crontab(rule: '* * * * *', name: 'TaskSchedulerCreateCrontab', singleton: true, mutexExpires: 90, onOneServer: true, callback: 'execute', memo: '创建未来 n 天的调度数据')]
 class TaskSchedulerCreateCrontab
 {
     private LoggerInterface $logger;

src/Crontab/TaskSchedulerExecuteCrontab.php

@@ -15,14 +15,12 @@
 use Dtyq\TaskScheduler\Service\TaskSchedulerDomainService;
 use Dtyq\TaskScheduler\Util\Locker;
 use Hyperf\Coroutine\Concurrent;
-use Hyperf\Crontab\Annotation\Crontab;
 use Hyperf\Logger\LoggerFactory;
 use Psr\Log\LoggerInterface;
 use Throwable;
 
 use function Hyperf\Config\config;
 
-#[Crontab(rule: '* * * * *', name: 'TaskSchedulerExecuteCrontab', singleton: true, mutexExpires: 90, onOneServer: true, callback: 'execute', memo: '执行调度')]
 class TaskSchedulerExecuteCrontab
 {
     protected Concurrent $concurrent;