内部使用oa后台

app/Http/Controllers/Api/TestController.php

@@ -4,6 +4,7 @@ namespace App\Http\Controllers\Api;
 
 use App\Service\WorkFlowService;
 use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Redis;
 
 class TestController extends BaseController
 {
@@ -62,4 +63,37 @@ die;
         var_dump(Hash::check('这是测试'.'72f8c912d462b1md034ff46cbedaskc80bf',$sign));
         var_dump($sign);die;
     }
+
+    public function pushLog(Request $request){
+        $request = $request->all();
+        if(isset($request['tag'])){
+            $queueName = 'log_queue'; // 队列名称
+            $logData = [
+                'tag' => $request['tag'],
+                'timestamp' => time(),
+            ];
+
+            // 推送数据到 Redis 队列
+            Redis::rpush($queueName, json_encode($logData));
+
+        }
+    }
+
+    public function getLog(){
+        $queueName = 'log_queue'; // 队列名称
+        $logData = Redis::lpop($queueName);
+
+        if ($logData) {
+            $decodedData = json_decode($logData, true);
+            return response()->json([
+                'status' => 200,
+                'data' => $decodedData,
+            ]);
+        }
+
+        return response()->json([
+            'status' => 201,
+            'data' => '',
+        ]);
+    }
 }

routes/api.php

@@ -21,6 +21,8 @@ Route::middleware('auth:api')->get('/user', function (Request $request) {
 Route::any('login', 'Api\LoginController@login');
 Route::any('test', 'Api\TestController@aa');
 Route::any('getHeaderWord', 'Api\HeaderWordController@getHeaderWord');
+//测试用
+Route::any('pushLog', 'Api\TestController@pushLog');
 //文件获取
 Route::any('uploadFiles/{file_name}', 'Api\FileUploadController@getFile');
 //获取导出规则