计划任务

app/Controller/Api/v1/PlantaskController.php

@@ -0,0 +1,49 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Controller\Api\v1;
+
+use App\Controller\AbstractController;
+use App\Utils\AppResult;
+use App\Service\QueueService;
+use App\Utils\AppResult;
+use App\Utils\LogUtil;
+use App\Utils\RedisUtil;
+use Hyperf\DbConnection\Db;
+use Hyperf\Di\Annotation\Inject;
+
+/**
+ * Demo
+ * 示例
+ */
+class PlantaskController extends AbstractController
+{
+    // 日志模块名称
+    const LOG_MODULE = 'v1/PlantaskController';
+
+    #[Inject]
+    protected QueueService $service;
+
+    //每月初自动结算上个月的业绩
+    public function auto_yeji(){
+        $date = date('Ym').'01';
+
+        //找一个没结算的
+        $wallet = Db::table('user_wallet')->where('last_jiesuan_date','<',$date)->orderBy('id asc')->get();
+        if(empty($wallet)){
+            echo $date.'没有了';
+            exit;
+        }
+
+        $wallet = json_decode(json_encode($wallet),true);
+        foreach($wallet as $key => $one){
+            dump($one);
+            //$this->service->playerPush($one, 0);
+        }
+
+
+    }
+
+
+}

routes/api/routes.php

@@ -22,15 +22,15 @@ use App\Controller\Api\v1\LiveController;
  * Version 1.0
  */
 Router::addGroup('/v1', function () {
-    Router::addRoute(['GET','POST'],'/demo', [DemoController::class, 'index']);
+    Router::addRoute(['GET','POST'],'/plantask/autoyeji', [PlantaskController::class, 'autoyeji']);
 
     // 该 Group 下的所有路由都将应用配置的中间件
-    Router::addGroup('/notify', function () {
+    /*Router::addGroup('/notify', function () {
         Router::get('/tencent/im/callback', [TencentImController::class, 'callback']);
-    });
+    });*/
 
     // 需登录
-    Router::addGroup('/auth', function () {
+    /*Router::addGroup('/auth', function () {
 
         Router::post('/common/config', [CommonController::class, 'config']);
         Router::post('/common/get_user_sig', [CommonController::class, 'get_user_sig']);
@@ -63,5 +63,5 @@ Router::addGroup('/v1', function () {
         Router::post('/live/keyword_filter_add', [LiveController::class, 'keyword_filter_add']);
         Router::post('/live/keyword_filter_del', [LiveController::class, 'keyword_filter_del']);
 
-    }, ['middleware' => [ApiSign::class]]);
+    }, ['middleware' => [ApiSign::class]]);*/
 });