README.md

@@ -8,7 +8,7 @@
   <img alt="Version" src="https://img.shields.io/badge/version-1.2-blue.svg?cacheSeconds=2592000" />
   <img src="https://img.shields.io/badge/node-%3E%3D%20 12.16.1-blue.svg" />
   <img src="https://img.shields.io/badge/npm-%3E%3D%206.13.4-blue.svg" />
-  <img src="https://img.shields.io/badge/php-%3E%3D7.2.24-red" />
+  <img src="https://img.shields.io/badge/php-%3E%3D7.3.0-red" />
   <a href="https://github.com/Nirongxu/vue-xuAdmin/blob/master/README.md">
     <img alt="Documentation" src="https://img.shields.io/badge/documentation-yes-brightgreen.svg" target="_blank" />
   </a>
@@ -41,6 +41,10 @@
 - vue >= 2.0
 - element >= 2.15.3
 
+## Star
+
+![](https://starchart.cc/hyperf-cms/hyperf-api.svg)
+
 ## 项目源码
 
 码云作为国内同步仓库，可解决 Github 克隆缓慢的问题，两个平台的代码都是同步更新的，按需选择

app/Command/Bilibili/BilibiliUpUserReport.php

@@ -0,0 +1,80 @@
+<?php
+namespace App\Command\Bilibili;
+
+use App\Exception\Handler\BusinessException;
+use App\Foundation\Facades\Log;
+use App\Model\Laboratory\Bilibili\UpUser;
+use App\Model\Laboratory\Bilibili\UpUserReport;
+use App\Service\Laboratory\Bilibili\UpUserService;
+use Hyperf\Crontab\Annotation\Crontab;
+use Hyperf\Di\Annotation\Inject;
+
+/**
+ * @Crontab(name="BilibiliUpUserReport", rule="00 * * * *", callback="execute", memo="BilibiliUp主数据采集定时任务")
+ */
+class BilibiliUpUserReport
+{
+    /**
+     *
+     * @Inject()
+     * @var UpUser
+     */
+    private $biliUpUser;
+
+    /**
+     * 定时记录主播数据变化情况
+     * @throws \Exception
+     */
+    public function execute()
+    {
+        try {
+            //先获取需要定时获取数据报表的Up主
+            $upUserMidList = $this->biliUpUser->newQuery()
+                ->where('timed_status', UpUser::TIMED_STATUS_ON)
+                ->pluck('mid')->toArray();
+
+            foreach ($upUserMidList as $upUserMid) {
+                //获取主播数据
+                $upUserReport = UpUserService::getInstance()->getUpUserInfoFromBilibili($upUserMid);
+
+                if (!empty($upUserReport)) {
+                    //写入数据报表
+                    $insertData['time'] = strtotime(date('Y-m-d H:i'));
+                    $insertData['mid'] = $upUserMid;
+                    $insertData['following'] = $upUserReport['following'] ?? 0;
+                    $insertData['follower'] = $upUserReport['follower'] ?? 0;
+                    $insertData['video_play'] = $upUserReport['video_play'] ?? 0;
+                    $insertData['readling'] = $upUserReport['readling'] ?? 0;
+                    $insertData['likes'] = $upUserReport['likes'] ?? 0;
+                    $insertData['recharge_month'] = $upUserReport['recharge_month'] ?? 0;
+                    $insertData['recharge_total'] = $upUserReport['recharge_total'] ?? 0;
+                    UpUserReport::query()->insert($insertData);
+
+                    //修改主播信息为最新数据
+                    $updateData['name'] = $upUserReport['name'] ?? '';
+                    $updateData['sex'] = $upUserReport['sex'] ?? '';
+                    $updateData['sign'] = $upUserReport['sign'] ?? '';
+                    $updateData['face'] = $upUserReport['face'] ?? '';
+                    $updateData['level'] = $upUserReport['level'] ?? '';
+                    $updateData['top_photo'] = $upUserReport['top_photo'] ?? '';
+                    $updateData['birthday'] = $upUserReport['birthday'] ?? '';
+                    $updateData['following'] = $upUserReport['following'] ?? 0;
+                    $updateData['follower'] = $upUserReport['follower'] ?? 0;
+                    $updateData['video_play'] = $upUserReport['video_play'] ?? 0;
+                    $updateData['readling'] = $upUserReport['readling'] ?? 0;
+                    $updateData['likes'] = $upUserReport['likes'] ?? 0;
+                    $updateData['recharge_month'] = $upUserReport['recharge_month'] ?? 0;
+                    $updateData['recharge_total'] = $upUserReport['recharge_total'] ?? 0;
+                    $updateData['live_room_info'] = $upUserReport['live_room_info'] ?? '';
+                    $updateData['updated_at'] = date('Y-m-d H:i:s');
+                    UpUser::where('mid', $upUserMid)->update($updateData);
+                }
+            }
+        }catch (\Exception $e) {
+           Log::crontabLog()->error($e->getMessage());
+           //如果报错，重新执行
+           $obj = new BilibiliUpUserReport();
+           $obj->execute();
+        }
+    }
+}

app/Command/Bilibili/BilibiliVideoReport.php

@@ -0,0 +1,73 @@
+<?php
+namespace App\Command\Bilibili;
+
+use App\Foundation\Facades\Log;
+use App\Model\Laboratory\Bilibili\Video;
+use App\Model\Laboratory\Bilibili\VideoReport;
+use App\Service\Laboratory\Bilibili\VideoService;
+use Hyperf\Crontab\Annotation\Crontab;
+use Hyperf\Di\Annotation\Inject;
+
+/**
+ * @Crontab(name="BilibiliVideoReport", rule="00 * * * *", callback="execute", memo="BilibiliUp视频数据报表采集")
+ */
+class BilibiliVideoReport
+{
+    /**
+     *
+     * @Inject()
+     * @var Video
+     */
+    private $video;
+
+    /**
+     * 定时记录视频数据变化
+     * @throws \Exception
+     */
+    public function execute()
+    {
+        try {
+            //先获取需要定时获取数据报表的Up主
+            $videoBVidList = $this->video->newQuery()
+                ->where('timed_status', Video::TIMED_STATUS_ON)
+                ->pluck('bvid')->toArray();
+
+            foreach ($videoBVidList as $bvid) {
+                //获取主播数据
+                $videoReport = VideoService::getInstance()->getVideoInfoFromBilibili($bvid);
+
+                if (!empty($videoReport)) {
+                    //写入数据报表
+                    $insertData['time'] = strtotime(date('Y-m-d H:i'));
+                    $insertData['bvid'] = $bvid;
+                    $insertData['mid'] = $videoReport['mid'];
+                    $insertData['view'] = $videoReport['view'] ?? 0;
+                    $insertData['danmaku'] = $videoReport['danmaku'] ?? 0;
+                    $insertData['reply'] = $videoReport['reply'] ?? 0;
+                    $insertData['favorite'] = $videoReport['favorite'] ?? 0;
+                    $insertData['coin'] = $videoReport['coin'] ?? 0;
+                    $insertData['likes'] = $videoReport['likes'] ?? 0;
+                    $insertData['dislike'] = $videoReport['dislike'] ?? 0;
+                    VideoReport::query()->insert($insertData);
+
+                    //修改主播信息为最新数据
+                    $updateData['view'] = $videoReport['view'] ?? 0;
+                    $updateData['danmaku'] = $videoReport['danmaku'] ?? 0;
+                    $updateData['reply'] = $videoReport['reply'] ?? 0;
+                    $updateData['favorite'] = $videoReport['favorite'] ?? 0;
+                    $updateData['coin'] = $videoReport['coin'] ?? 0;
+                    $updateData['likes'] = $videoReport['likes'] ?? 0;
+                    $updateData['dislike'] = $videoReport['dislike'] ?? 0;
+                    $updateData['owner'] = !empty($videoReport['owner']) ? json_encode($videoReport['owner']) : '';
+                    $updateData['updated_at'] = date('Y-m-d H:i:s');
+                    Video::where('bvid', $bvid)->update($updateData);
+                }
+            }
+        }catch (\Exception $e) {
+            Log::crontabLog()->error($e->getMessage());
+            //如果报错，重新执行
+            $obj = new BilibiliVideoReport();
+            $obj->execute();
+        }
+    }
+}

app/Command/InitDataSeederCommand.php

@@ -0,0 +1,58 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Command;
+
+use App\Model\Auth\User;
+use App\Model\System\DictData;
+use App\Model\System\DictType;
+use App\Model\System\GlobalConfig;
+use Hyperf\Command\Command as HyperfCommand;
+use Hyperf\Command\Annotation\Command;
+use Donjan\Permission\Models\Permission;
+use Donjan\Permission\Models\Role;
+
+/**
+ * @Command
+ */
+class InitDataSeederCommand extends HyperfCommand
+{
+    /**
+     * 执行的命令行
+     *
+     * @var string
+     */
+    protected $name = 'init:data_seeder';
+
+    public function configure()
+    {
+        parent::configure();
+        $this->setHelp('初始化数据，权限数据，字典数据');
+        $this->setDescription('初始化数据，权限数据，字典数据');
+    }
+
+    /**
+     * 命令执行方法
+     */
+    public function handle()
+    {
+        //创建权限
+        $permissionList = config('permissionData.permission_list');
+        foreach ($permissionList as $permission) {
+            if (empty(Permission::query()->find($permission['id']))) Permission::query()->insert($permission);
+            $this->line('添加权限成功----------------------------' . $permission['display_name']);
+        }
+
+        //初始化字典数据
+        $dictTypeList = config('dictData.dict_type');
+        foreach ($dictTypeList as $dictType) {
+            if (empty(DictType::query()->find($dictType['dict_id']))) DictType::query()->insert($dictType);
+        }
+        $dictDataList = config('dictData.dict_data');
+        foreach ($dictDataList as $dictData) {
+            if (empty(DictData::query()->find($dictData['dict_code']))) DictData::query()->insert($dictData);
+        }
+        $this->line('迁移字典数据成功', 'info');
+    }
+}

app/Controller/Auth/PermissionController.php

@@ -227,7 +227,7 @@ public function update(int $id)
         ];
 
         $this->verifyParams($params, $rules, $message);
-        $permission = Permission::findById($id);
+        $permission = Permission::find($id);
         $permission->parent_id = $params['parent_id'];
         $permission->type = $params['type'];
         $permission->name = $params['name'];

app/Controller/Auth/UserController.php

@@ -447,5 +447,4 @@ public function changeStatus()
 
         return $this->success([], '更改用户状态成功');
     }
-
 }

app/Controller/Common/HomeController.php

@@ -73,4 +73,25 @@ private function getOperateLog() : array
             'total' => $total
         ];
     }
+
+    /**
+     * 获取地图数据
+     * @RequestMapping(path="/world_map_data", methods="get,post")
+     * @Middlewares({
+     *     @Middleware(RequestMiddleware::class),
+     * })
+     */
+    public function getWorldMapData()
+    {
+        return $this->success($this->_getWorldMapData(), '获取地图数据成功');
+    }
+
+    /**
+     * 获取地图数据
+     * @return array
+     */
+    private function _getWorldMapData() : array
+    {
+        return config('worldMap.data');
+    }
 }

app/Controller/IndexController.php

@@ -4,9 +4,13 @@
 
 namespace App\Controller;
 
-use App\Foundation\Utils\GroupAvatar;
-use App\Model\Auth\User;
-use App\Model\Laboratory\FriendRelation;
+use App\Foundation\Facades\Log;
+use App\Foundation\Utils\Mail;
+use App\Job\EmailNotificationJob;
+use App\Model\Laboratory\Bilibili\UpUser;
+use App\Model\Laboratory\Bilibili\UpUserReport;
+use App\Service\Laboratory\Bilibili\VideoService;
+use Hyperf\DbConnection\Db;
 use Hyperf\HttpServer\Annotation\Controller;
 use Hyperf\HttpServer\Annotation\RequestMapping;
 
@@ -17,43 +21,57 @@
  */
 class IndexController extends AbstractController
 {
+    public function __construct()
+    {
+
+    }
+
     /**
      * 获取用户数据列表
      * @RequestMapping(path="/test", methods="get,post")
      */
     public function index()
-    {
+   {
+       //分发队列
+       $this->queue->push(new EmailNotificationJob([
+           'title' => $params['title'],
+           'content' => $params['content'],
+       ]));
+
+//        $url = 'https://m.bilibili.com/video/BV1Q624y1q7sj';
+
 
-        $user = User::query()->get()->toArray();
-        foreach ($user as $item) {
-            foreach ($user as $key) {
-                if ($key['id'] == $item['id']) continue;
-                FriendRelation::query()->insert([
-                    'uid' => $item['id'],
-                    'friend_id' => $key['id'],
-                    'created_at' => date('Y-m-d H:i:s'),
-                    'updated_at' => date('Y-m-d H:i:s'),
-                ]);
-            }
-        }
-//       $picList = [
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face1.png',
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face2.png',
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face3.png',
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face4.png',
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face5.png',
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face6.png',
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face7.png',
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face8.png',
-//           'https://hyperf-cms.oss-cn-guangzhou.aliyuncs.com/admin_face/face9.png',
-//       ];
+//        $lastString = basename($url);
+//        $mid = explode('?', $lastString)[0] ?? '';
 //
-//       GroupAvatar::init($picList, false, '121312');
-//       $res = GroupAvatar::build();
+//        $upUser = new UpUser();
+//        $upUser->mid = $mid;
+//        $upUser->timed_status = 1;
+//        $upUser->save();
+//        return $upUser->mid;
+//        preg_match('/.*?av(\d{0,})\/?/', $url,$m);
+//        if (!isset($m[1])) {
+//            return false;
+//        }
+//        $vid = $m[1];//获取视频uid
 //
+//        return $vid;
+
+//        $infoUrl = 'https://api.bilibili.com/x/web-interface/archive/stat?aid='.$vid;//拼接得到接口地址
+//        $infoRespose =  doCurlGetRequest($infoUrl);
+//
+//        $data =  $this->bilibili($infoRespose);//获取视频抓取数据
+//        $respose = file_get_contents("https://api.bilibili.com/x/web-interface/view?aid=".$vid);
+//
+//        if (empty($respose) || !$respose) return false;
+//        $resposeData = json_decode($respose,true)['data'];
 //
-//        return $this->success([
-//            'list' => $res
-//        ]);
+//        $data['name'] = $resposeData['title'];
+//        $data['time'] = date('Y-m-d H:i:s',$resposeData['ctime']);
+//        $data['author'] =  $resposeData['owner']['name'];
+//
+//        return $data;
+
     }
+
 }