feat(Qscmf): 添加健康检查控制器和队列监控功能

src/Library/Qscmf/Builder/ListSearchType/SelectText/SelectText.class.php

@@ -34,12 +34,9 @@ static public function parse(array $keys_rule, array $get_data): array
         }
     }
 
-    public function tableSearchAntdRender($options, $listBuilder): array
+    public function tableSearchAntdRender($options, $listBuilder): \AntdAdmin\Component\Table\ColumnType\SelectText
     {
-        $key = new Select('key', $options['title']);
-        $key->setValueEnum($options['options']);
-
-        $word = new Text('word', '');
-        return [$key, $word];
+        $column = new \AntdAdmin\Component\Table\ColumnType\SelectText('key:word', '');
+        return $column->setValueEnum($options['options']);
     }
 }

src/Library/Qscmf/Controller/HealthCheckController.class.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace Qscmf\Controller;
+
+use Think\Controller;
+
+class HealthCheckController extends Controller
+{ 
+    public function resque(){
+        $queue = I('get.queue');
+        if (!$queue){
+            $this->error('参数错误');
+        }
+
+        $tick = S('health_tick_queue_'.$queue);
+
+        if (time() - $tick > 60){
+            send_http_status(500);
+            echo 'ERROR: queue check fail - '.$queue;
+            return;
+        }
+
+        echo $tick. ' health check success.';
+    }
+}

src/Library/Qscmf/Lib/Tp3Resque/Resque/Worker.class.php

@@ -170,6 +170,10 @@ public function work($interval = 5)
 				break;
 			}
 
+			foreach ($this->queues as $queue) { 
+				S('health_tick_queue_'.$queue, time());
+			}
+
 			$this->log("round start:" . convert(memory_get_usage(true)));
 
 			if (!$this->paused