🍜Hyperf3.1使用websocket实现数据大屏

基于Hyperf+ WebSocket+redis实现数据大屏的实时推送

1. 安装扩展#

安装 websocket 服务端

1
composer require hyperf/websocket-server

2. 配置server#

在config/autoload/server.php增加配置

1
<?php
2

3
declare(strict_types=1);
4
/**
5
 * This file is part of Hyperf.
6
 *
7
 * @link     https://www.hyperf.io
8
 * @document https://hyperf.wiki
9
 * @contact  group@hyperf.io
10
 * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
11
 */
12
use Hyperf\Server\Event;
13
use Hyperf\Server\Server;
14
use Swoole\Constant;
15

16
return [
17
    'mode' => SWOOLE_PROCESS,
18
    'servers' => [
19
        [
20
            'name' => 'http',
21
            'type' => Server::SERVER_HTTP,
22
            'host' => '0.0.0.0',
23
            'port' => 9501,
24
            'sock_type' => SWOOLE_SOCK_TCP,
25
            'callbacks' => [
26
                Event::ON_REQUEST => [Hyperf\HttpServer\Server::class, 'onRequest'],
27
            ],
28
            'options' => [
29
                // Whether to enable request lifecycle event
30
                'enable_request_lifecycle' => false,
31
            ],
32
        ],
33
        // 增加部分
34
        [
35
            'name' => 'wsDataScreen',
36
            'type' => Server::SERVER_WEBSOCKET,
37
            'host' => '0.0.0.0',
38
            'port' => 9503,
39
            'sock_type' => SWOOLE_SOCK_TCP,
40
            'callbacks' => [
41
                Event::ON_HAND_SHAKE => [Hyperf\WebSocketServer\Server::class, 'onHandShake'],
42
                Event::ON_MESSAGE => [Hyperf\WebSocketServer\Server::class, 'onMessage'],
43
                Event::ON_CLOSE => [Hyperf\WebSocketServer\Server::class, 'onClose'],
44
            ],
45
            'settings' => [
46
                // 心跳检测配置
47
                'heartbeat_idle_time' => 600,  // 连接最大空闲时间（秒）
48
                'heartbeat_check_interval' => 60, // 心跳检测间隔（秒）
49
                'open_websocket_ping_frame' => false, // 开启PING帧自动回复
50
//                'open_websocket_pong_frame' => true, // 开启PONG帧处理
51
            ],
52
        ],
53
    ],
54
    'settings' => [
55
        Constant::OPTION_ENABLE_COROUTINE => true, // 开启内置协程
56
        Constant::OPTION_WORKER_NUM => swoole_cpu_num(), // 设置启动的 Worker 进程数
57
        Constant::OPTION_PID_FILE => BASE_PATH . '/runtime/hyperf.pid', // master 进程的 PID
58
        Constant::OPTION_OPEN_TCP_NODELAY => true, // TCP 连接发送数据时会关闭 Nagle 合并算法，立即发往客户端连接
59
        Constant::OPTION_MAX_COROUTINE => 100000, // 设置当前工作进程最大协程数量
60
        Constant::OPTION_OPEN_HTTP2_PROTOCOL => true, // 启用 HTTP2 协议解析
61
        Constant::OPTION_MAX_REQUEST => 100000, // 设置 worker 进程的最大任务数
62
        Constant::OPTION_SOCKET_BUFFER_SIZE => 2 * 1024 * 1024, // 配置客户端连接的缓存区长度
63
        Constant::OPTION_BUFFER_OUTPUT_SIZE => 2 * 1024 * 1024,
64

65
        // 添加任务工作进程配置
66
        'task_worker_num' => swoole_cpu_num(), // 根据服务器CPU核心数设置
67
        'task_enable_coroutine' => true, // 启用协程支持
68
    ],
69
    'callbacks' => [
70
        Event::ON_WORKER_START => [Hyperf\Framework\Bootstrap\WorkerStartCallback::class, 'onWorkerStart'],
71
        Event::ON_PIPE_MESSAGE => [Hyperf\Framework\Bootstrap\PipeMessageCallback::class, 'onPipeMessage'],
72
        Event::ON_WORKER_EXIT => [Hyperf\Framework\Bootstrap\WorkerExitCallback::class, 'onWorkerExit'],
73

74
        Event::ON_TASK => [Hyperf\Framework\Bootstrap\TaskCallback::class, 'onTask'],
75
        Event::ON_FINISH => [Hyperf\Framework\Bootstrap\FinishCallback::class, 'onFinish'],
76
    ],
77
];

3. 配置路由#

在config/routes.php下新增

1
Router::addServer('wsDataScreen', function () {
2
    Router::get('/wsDataScreen/ws', \App\Module\DataScreen\Controller\WebSocketController::class);
3
});

4. 中间件配置#

可以在config/autoload/middlewares.php配置中间件，但是只有握手阶段会走该中间件，所以我这里不配置，因为我需要发送消息阶段也需要鉴权

1
'wsDataScreen' => [
2
//        \App\Middleware\DataScreenAuthMiddleware::class
3
    ]

5. 创建控制器#

在Module/DataScreen/Controller/WebSocketController.php下创建控制器

1
<?php
2
//declare(strict_types=1);
3

4
namespace App\Module\DataScreen\Controller;
5

6
use App\Common\Enum\AuthGuardEnum;
7
use App\Common\Trait\RedisKeyTrait;
8
use App\Middleware\DataScreenAuthMiddleware;
9
use App\Module\DataScreen\Business\WebSocketBusiness;
10
use App\Module\DataScreen\Enum\RedisKeyEnum;
11
use App\Module\DataScreen\Repository\AdminDataRuleRepository;
12
use App\Module\DataScreen\Request\WebSocketRequest;
13
use Hyperf\WebSocketServer\Context;
14
use Hyperf\Contract\OnCloseInterface;
15
use Hyperf\Contract\OnMessageInterface;
16
use Hyperf\Contract\OnOpenInterface;
17
use Hyperf\Di\Annotation\Inject;
18
use Hyperf\Engine\WebSocket\Frame;
19
use Hyperf\Engine\WebSocket\Response;
20
use Hyperf\Redis\Redis;
21
use Hyperf\Validation\Contract\ValidatorFactoryInterface;
22
use Hyperf\WebSocketServer\Constant\Opcode;
23
use Qbhy\HyperfAuth\AuthManager;
24

25

26
class WebSocketController implements OnMessageInterface, OnOpenInterface, OnCloseInterface
27
{
28
    use RedisKeyTrait;
29

30
    #[Inject]
31
    protected AuthManager $auth;
32

33
    #[Inject]
34
    private Redis $redis;
35

36
    #[Inject]
37
    private ValidatorFactoryInterface $validationFactory;
38

39
    #[Inject]
40
    private WebSocketRequest $webSocketRequest;
41

42
    #[Inject]
43
    private AdminDataRuleRepository $adminDataRuleRepository;
44

45
    #[Inject]
46
    private WebSocketBusiness $webSocketBusiness;
47

48

49
    public function onMessage($server, $frame): void
50
    {
51
        $alive_key = $this->generateKeyPrefix(RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD, version: 0);
52
        $response = (new Response($server))->init($frame);
53
        // 客户端ID
54
        $fd = $frame->fd;
55

56
        // 获取用户信息
57
        $user = Context::get("user:{$fd}");
58
        if (!$user) {
59
            $server->disconnect($fd, 401, '请先登录');
60
            return;
61
        }
62

63
        // 获取用户数据权限
64
        $data_rule = Context::get("user_data_rule:{$user->id}");
65

66

67
        if($frame->opcode == Opcode::TEXT && $frame->data == 'ping') {
68
            // 手动处理心跳帧
69
            $response->push(new Frame(opcode: Opcode::TEXT, payloadData: 'pong'));
70
            // 添加到存活列表
71
            $this->redis->sAdd($alive_key, $fd);
72
            // 续期
73
            $this->redis->expire($alive_key, RedisKeyEnum::ALIVE_TTL);
74
            return;
75
        }
76

77
        try {
78
            $data = json_decode($frame->data, true, 512, JSON_THROW_ON_ERROR);
79

80
            // 使用验证器验证数据
81
            $validator = $this->validationFactory->make(
82
                $data,
83
                $this->webSocketRequest->rules($data),
84
                $this->webSocketRequest->messages()
85
            );
86

87
            if ($validator->fails()) {
88
                $error = $validator->errors()->first();
89
                throw new \InvalidArgumentException($error);
90
            }
91

92
            // 统一参数
93
            $params = $this->webSocketBusiness->formatParams($data, $data_rule);
94

95
            // redis存储 客户端=>筛选条件
96
            $this->webSocketBusiness->storeClientFilters($fd, $params);
97

98
            // 立即返回当前数据
99
            $census_data = $this->webSocketBusiness->getCurrentData($params);
100

101
            $response->push(new Frame(payloadData: responseSuccess($census_data)));
102

103
        } catch (\Throwable $e) {
104
            $response->push(new Frame(payloadData: responseError($e->getMessage())));
105
        }
106
    }
107

108
    public function onClose($server, int $fd, int $reactorId): void
109
    {
110
        // 移除存活列表集合中指定的fd
111
        $alive_key = $this->generateKeyPrefix(RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD, version: 0);
112
        $this->redis->sRem($alive_key, $fd);
113
        // 移除fd的筛选
114
        $filter_key = $this->generateKeyPrefix(RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD_FILTER);
115
        $this->redis->hDel($filter_key, $fd);
116
    }
117

118
    public function onOpen($server, $request): void
119
    {
120
        $response = (new Response($server))->init($request);
121
        try {
122

123
            if (!$this->auth->guard(AuthGuardEnum::DATA_SCREEN_JWT)->check()) {
124
                throw new \RuntimeException('请先登录', 401);
125
            }
126

127
            // 将用户信息存储在上下文中，以便后续使用
128
            $user = $this->auth->guard(AuthGuardEnum::DATA_SCREEN_JWT)->user();
129
            if (empty($user)) {
130
                throw new \RuntimeException('请先登录', 401);
131
            }
132

133
            Context::set("user:{$request->fd}", $user);
134

135
            // 查询用户的数据权限
136
            $data_rule = $this->adminDataRuleRepository->getAdminDataRuleByAdminId($user->id);
137
            Context::set("user_data_rule:{$user->id}", $data_rule);
138

139
            $alive_key = $this->generateKeyPrefix(RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD, version: 0);
140

141
            // 添加到存活列表
142
            $this->redis->sAdd($alive_key, $request->fd);
143
            // 续期
144
            $this->redis->expire($alive_key, RedisKeyEnum::ALIVE_TTL);
145

146
            $response->push(new Frame(payloadData: responseSuccess('连接成功')));
147
        } catch (\Throwable $e) {
148
            if ($e->getCode() == 401) {
149
                $server->disconnect($request->fd, 401, $e->getMessage());
150
                return;
151
            }
152
            $response->push(new Frame(payloadData: responseError($e->getMessage())));
153
        }
154

155
    }
156
}

其中使用到了RedisKeyTrait特征，主要是为了生成用户筛选唯一的ke y

1
<?php
2
declare (strict_types=1);
3

4
namespace App\Common\Trait;
5

6
use App\Module\DataScreen\Enum\RedisKeyEnum;
7
use function Hyperf\Config\config;
8

9
trait RedisKeyTrait
10
{
11
    /**
12
     * 生成前缀
13
     * @param string $key
14
     * @param string $module
15
     * @param string $other_key
16
     * @return string
17
     */
18
    public function generateKeyPrefix(string $key, string $module = RedisKeyEnum::MODULE_DATA_SCREEN, string $other_key = '', int $version = 1): string
19
    {
20
        $env = config('app_env');
21
        $version_str = !empty($version) ? "_v{$version}" : '';
22
        return "{$module}_{$env}_{$key}{$other_key}{$version_str}";
23
    }
24

25
    /**
26
     * 生成根据筛选条件定义的key
27
     * @param array $params
28
     * @return string
29
     */
30
    public function generateFilterGroupKey(array $params): string
31
    {
32
        return implode('_', array_merge(...array_map(fn($k, $v) => [$k, $v], array_keys($params), $params)));
33
    }
34
}

使用到常量

1
<?php
2
declare (strict_types=1);
3

4
namespace App\Module\DataScreen\Enum;
5

6
class RedisKeyEnum
7
{
8
    // 存活时间
9
    const ALIVE_TTL = 7200;
10
    // 应用名称-数据大屏
11
    const MODULE_DATA_SCREEN = 'DataScreen';
12

13
    const MODULE_DATA_CENTER = 'DataCenter';
14

15
    // 存活的客户端key
16
    const REDIS_KEY_WEBSOCKET_FD = 'websocket_active_fd';
17
    // 客户端的筛选
18
    const REDIS_KEY_WEBSOCKET_FD_FILTER = 'websocket_fd_filter';
19
    // 筛选分组下的数据
20
    const REDIS_KEY_WEBSOCKET_FD_FILTER_GROUP = 'websocket_fd_filter_group';
21

22
    // 平台商品关联货品缓存
23
    const REDIS_KEY_WDT_GOODS_LINK = 'wdt_goods_link';
24

25
    // 交易漏斗缓存
26
    const REDIS_KEY_WDT_ORDER_TRANSFORM = 'wdt_order_transform';
27
    // 核心交易
28
    const REDIS_KEY_WDT_ORDER_CORE_API = 'wdt_order_core_api';
29
    // 订单结构
30
    const REDIS_KEY_WDT_ORDER_STRUCT = 'wdt_order_struct';
31
    // 售后
32
    const REDIS_KEY_WDT_ORDER_AFTER_SALE = 'wdt_order_after_sale';
33
    // 退款top
34
    const REDIS_KEY_WDT_ORDER_REFUND_TOP = 'wdt_order_refund_top';
35
    // 库存
36
    const REDIS_KEY_WDT_CENSUS_STOCK = 'wdt_census_stock';
37

38
    // 各地库存
39
    const REDIS_KEY_WDT_WAREHOUSE_STOCK = 'wdt_warehouse_stock';
40

41
    // 地图
42
    const REDIS_KEY_WDT_OVERVIEW_MAP = 'wdt_overview_map';
43

44
    // 退款占比
45
    const REDIS_KEY_WDT_REFUND_RATE = 'wdt_refund_rate';
46

47
    // 入账金额折线图
48
    const REDIS_KEY_WDT_PAY_MAP  = 'wdt_pay_map';
49
}

验证器验证规则

1
<?php
2
declare (strict_types=1);
3

4
namespace App\Module\DataScreen\Request;
5

6
use Carbon\Carbon;
7

8
class WebSocketRequest
9
{
10
    /**
11
     * 验证规则
12
     */
13
    public function rules(array $requestData): array
14
    {
15
        return [
16
            'module' => 'required|in:1,2,3,4,5,6,7,8',
17
            'platform' => 'required|in:0,1,2',
18
            'date_type'  => 'required|in:0,1',
19
            'date_value' => 'required_if:date_type,0|in:0,1,2,3,4',
20
            'date_start' => [
21
                'required_if:date_type,1',
22
                'date',
23
                'date_format:Y-m-d',
24
                'before_or_equal:date_end',
25
                function ($attr, $value, $fail) use ($requestData) {
26
                    if (($requestData['date_type'] ?? 0) == 1 && !empty($requestData['date_end'] ?? '')) {
27
                        $start = Carbon::parse($value);
28
                        $end = Carbon::parse($requestData['date_end']);
29

30
                        if ($start->diffInDays($end) > 31) {
31
                            $fail('日期范围不能超过31天');
32
                        }
33
                    }
34
                }
35
            ],
36
            'date_end' => 'required_if:date_type,1|date|date_format:Y-m-d|after_or_equal:date_start',
37
            'module_user_id' => [
38
                'required_if:module,5,6,7',
39
                'not_in:undefined',
40
            ],
41
            'position' => 'required|in:0,1,2',
42
            'fx_user_date_start' => [
43
                'required_if:position,1,2',
44
                'date',
45
                'date_format:Y-m-d',
46
                'before_or_equal:fx_user_date_end',
47
                function ($attr, $value, $fail) use ($requestData) {
48
                    if (!empty($requestData['fx_user_date_end'] ?? '')) {
49
                        $start = Carbon::parse($value);
50
                        $end = Carbon::parse($requestData['fx_user_date_end']);
51

52
                        if ($start->diffInDays($end) > 31) {
53
                            $fail('日期范围不能超过31天');
54
                        }
55
                    }
56
                }
57
            ],
58
            'fx_user_date_end' => 'required_if:position,1,2|date|date_format:Y-m-d|after_or_equal:fx_user_date_start',
59
            'fx_user_page' => 'required_if:position,1,2|numeric|min:1',
60
        ];
61
    }
62

63
    /**
64
     * 自定义错误消息
65
     */
66
    public function messages(): array
67
    {
68
        return [
69
            'module.required' => '模块不能为空',
70
            'module.in' => '模块参数非法',
71

72
            'module_user_id.required_if' => '相关用户ID不能为空',
73
            'module_user_id.not_in' => '相关用户ID不能为空！',
74

75
            'platform.required' => '平台不能为空',
76
            'platform.in' => '平台参数非法',
77

78
            'date_type.required' => '时间类型不能为空',
79
            'date_type.in' => '时间类型参数非法',
80

81
            'date_value.required_if' => '时间筛选不能为空',
82
            'date_value.in' => '时间筛选参数非法',
83

84
            'date_start.required_if' => '开始时间不能为空',
85
            'date_start.date' => '开始时间参数非法',
86
            'date_start.date_format' => '开始时间格式必须为YYYY-MM-DD',
87
            'date_start.before_or_equal' => '开始时间参数必须小于等于结束时间',
88

89
            'date_end.required_if' => '结束时间不能为空',
90
            'date_end.date' => '结束时间参数非法',
91
            'date_end.date_format' => '结束时间格式必须为YYYY-MM-DD',
92
            'date_end.before_or_equal' => '结束时间参数必须小于等于开始时间',
93

94
            'position.required' => '当前停留的位置参数不能为空',
95

96
            'fx_user_date_start.required_if' => '开始时间不能为空',
97
            'fx_user_date_start.date' => '开始时间参数非法',
98
            'fx_user_date_start.date_format' => '开始时间格式必须为YYYY-MM-DD',
99
            'fx_user_date_start.before_or_equal' => '开始时间参数必须小于等于结束时间',
100

101
            'fx_user_date_end.required_if' => '结束时间不能为空',
102
            'fx_user_date_end.date' => '结束时间参数非法',
103
            'fx_user_date_end.date_format' => '结束时间格式必须为YYYY-MM-DD',
104
            'fx_user_date_end.before_or_equal' => '结束时间参数必须小于等于开始时间',
105

106
            'fx_user_page.required_if' => '页码不能为空',
107
            'fx_user_page.numeric' => '页码必须为数字',
108
            'fx_user_page.min' => '页码最小值为1',
109
        ];
110
    }
111
}

其中使用到了查询用户拥有的数据权限（无需关注）

1
<?php
2
declare(strict_types=1);
3
namespace App\Module\DataScreen\Repository;
4

5
use App\Common\Utils\BaseRepository;
6
use App\Module\DataScreen\Model\Admin;
7
use App\Module\DataScreen\Model\AdminDataRule;
8
use App\Module\DataScreen\Model\DataRule;
9

10
class AdminDataRuleRepository extends BaseRepository
11
{
12
    public function __construct()
13
    {
14
        $this->setModel(new AdminDataRule());
15
    }
16

17
    public function getByAdminId($adminId)
18
    {
19
        return $this->getModel()::query()->where('admin_id', $adminId)->get();
20
    }
21

22

23
    /**
24
     * 获取用户的数据权限
25
     * @param int $adminId
26
     * @return array
27
     */
28
    public function getAdminDataRuleByAdminId(int $adminId): array
29
    {
30
        $table_name = $this->getModel()->getTable();
31
        $data_rule_table_name = (new DataRule())->getTable();
32
        return $this->getModel()::query()
33
            ->select([
34
                "{$table_name}.admin_id",
35
                "{$data_rule_table_name}.type",
36
                "{$data_rule_table_name}.step_type",
37
                "{$data_rule_table_name}.rule_id",
38
                "{$data_rule_table_name}.source_id",
39
            ])
40
            ->where("{$table_name}.admin_id", $adminId)
41
            ->join($data_rule_table_name, "{$table_name}.rule_id", '=', "{$data_rule_table_name}.id")
42
            ->get()->toArray();
43
    }
44

45

46
    /**
47
     * 删除旧的数据权限
48
     * @param int $adminId
49
     * @return int|mixed
50
     */
51
    public function deleteOldDataRules(int $adminId): mixed
52
    {
53
        return $this->getModel()::query()->where('admin_id', $adminId)->delete();
54
    }
55

56
}

6. 创建服务层#

创建Module/DataScreen/Business/WebSocketBusiness.php

1
<?php
2
declare (strict_types=1);
3

4
namespace App\Module\DataScreen\Business;
5

6
use App\Common\Trait\RedisKeyTrait;
7
use App\Module\DataScreen\Common\Trait\DataCenterTrait;
8
use App\Module\DataScreen\Common\Trait\DataRuleTrait;
9
use App\Module\DataScreen\Enum\RedisKeyEnum;
10
use App\Module\DataScreen\Enum\WebSocketEnum;
11
use Carbon\Carbon;
12
use Hyperf\Di\Annotation\Inject;
13
use Hyperf\Redis\Redis;
14

15
class WebSocketBusiness
16
{
17
    use RedisKeyTrait;
18
    use DataCenterTrait;
19
    use DataRuleTrait;
20

21
    #[Inject]
22
    private Redis $redis;
23

24
    /**
25
     * 统一参数格式
26
     * @param array $data 传递参数
27
     * @param array $data_rule 数据权限
28
     * @return array
29
     */
30
    public function formatParams(array $data, array $data_rule): array
31
    {
32
        $params = [
33
            // 模块 1兵工场 2机构 3分销者 4产品 5单兵工场页面
34
            'module' => intval($data['module'] ?? WebSocketEnum::MODULE_BING_GONG_CHANG),
35
            // 模块相关用户ID
36
            'module_user_id' => trim($data['module_user_id'] ?? ''),
37
            // 平台 1快手 2视频号 3抖音
38
            'platform' => intval($data['platform'] ?? WebSocketEnum::PLATFORM_KS),
39
            // 时间类型：0时间选择 1自定义时间
40
            'date_type' => intval($data['date_type'] ?? WebSocketEnum::DATE_TYPE_SELECT),
41
            // 时间选择 1今日 2昨日 3本月 4上月（当时间类型为0时必传 为1的时候传0）
42
            'date_value' => intval($data['date_value'] ?? 0),
43
            // 开始时间（当时间类型为1时必传 为0的时候传''）
44
            'date_start' => trim($data['date_start'] ?? ''),
45
            // 结束时间（当时间类型为1时必传 为0的时候传''）
46
            'date_end' => trim($data['date_end'] ?? ''),
47

48
            // 当前页面：0首页 1分销者数据详情
49
            'position' => intval($data['position'] ?? WebSocketEnum::POSITION_INDEX),
50
            // 分销者数据详情时间筛选-开始时间
51
            'fx_user_date_start' => trim($data['fx_user_date_start'] ?? ''),
52
            // 分销者数据详情时间筛选-结束时间
53
            'fx_user_date_end' => trim($data['fx_user_date_end'] ?? ''),
54
            // 分销者用户编号
55
            'fx_user_no' => trim($data['fx_user_no'] ?? ''),
56
            // 分销者数据详情页码
57
            'fx_user_page' => intval($data['fx_user_page'] ?? 1),
58
        ];
59

60
        // 时间筛选
61
        [$params['start_time'], $params['end_time']] = getTimeByType($params['date_type'], $params['date_value'], $params['date_start'], $params['date_end']);
62
        // 分销者详情数据时间
63
        [$params['fx_user_start_time'], $params['fx_user_end_time']] = getTimeByType(
64
            WebSocketEnum::DATE_TYPE_DIY,
65
            0,
66
            $params['fx_user_date_start'],
67
            $params['fx_user_date_end']
68
        );
69

70
        $params = array_merge($params, $this->getDataRuleParams($params, $data_rule));
71

72
        ksort($params);
73
        return $params;
74
    }
75

76
    public function storeClientFilters(int $fd, array $params): void
77
    {
78
        $json_params = json_encode($params, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
79

80
        $filter_key = $this->generateKeyPrefix(RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD_FILTER);
81
        // 存储客户端筛选条件
82
        $this->redis->hSet($filter_key, strval($fd), $json_params);
83
    }
84

85

86
    /**
87
     * 获取当前数据
88
     * @param array $params
89
     * @return array
90
     * @throws \RedisException
91
     */
92
    public function getCurrentData(array $params): array
93
    {
94
        // 查询是否有缓存
95
        $other_key = $this->generateFilterGroupKey($params);
96
        $filter_group_key = $this->generateKeyPrefix(
97
            RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD_FILTER_GROUP,
98
            RedisKeyEnum::MODULE_DATA_SCREEN,
99
            ":{$other_key}");
100
        $cache_data = $this->redis->get($filter_group_key) ?: '';
101
        $data_raw = !empty($cache_data) ? json_decode($cache_data, true) : [];
102
        $data = ($data_raw['data'] ?? []) ?: [];
103
        // 数据版本号
104
        $last_version = ($data_raw['version'] ?? 0) ?: 0;
105
        if (!empty($data)) {
106
            return $data;
107
        }
108

109
        // 实时查询
110
        $data = $this->dataCenter($params);
111
        // 设置缓存数据
112
        $this->redis->set($filter_group_key, json_encode(['filter' => $params, 'data' => $data, 'version' => $last_version + 1, 'update_time' => time()]));
113
        $this->redis->expire($filter_group_key, 7200);
114

115
        return $data;
116
    }
117

118

119

120
}

其中使用到了数据查询模块常量

1
<?php
2
declare (strict_types=1);
3

4
namespace App\Module\DataScreen\Enum;
5

6
class WebSocketEnum
7
{
8
    /** 模块 */
9
    const MODULE_BING_GONG_CHANG = 1;
10
    const MODULE_INSTITUTION = 2;
11
    const MODULE_FX_USER = 3;
12
    const MODULE_FX_PRODUCT = 4;
13
    const MODULE_SINGLE_BING_GONG_CHANG = 5;
14
    const MODULE_SINGLE_INSTITUTION = 6;
15
    const MODULE_SINGLE_FACTORY_FX_USER = 7;
16
    // 旺店通
17
    const MODULE_WANG_DAN_TONG = 8;
18

19
    const MODULE_DESC = [
20
        self::MODULE_BING_GONG_CHANG => '兵工场',
21
        self::MODULE_INSTITUTION => '机构',
22
        self::MODULE_FX_USER => '分销者',
23
        self::MODULE_FX_PRODUCT => '产品',
24
        self::MODULE_SINGLE_BING_GONG_CHANG => '单兵工场',
25
        self::MODULE_SINGLE_INSTITUTION => '单机构',
26
        self::MODULE_SINGLE_FACTORY_FX_USER => '分销者实时数据汇总',
27
        self::MODULE_WANG_DAN_TONG => '旺店通',
28
    ];
29

30
    /** 平台 */
31
    const PLATFORM_KS = 1;
32
    const PLATFORM_SPH = 2;
33
    const PLATFORM_DY = 3;
34
    const PLATFORM_WDT = 0;
35

36
    const PLATFORM_DESC = [
37
        self::PLATFORM_KS => '快手',
38
        self::PLATFORM_SPH => '视频号',
39
        self::PLATFORM_DY => '抖音',
40
        self::PLATFORM_WDT => '旺店通',
41
    ];
42

43

44
    /** 时间类型 */
45
    const DATE_TYPE_SELECT = 0;
46
    const DATE_TYPE_DIY = 1;
47

48
    const DATE_TYPE_DESC = [
49
        self::DATE_TYPE_SELECT => '时间选择',
50
        self::DATE_TYPE_DIY => '自定义时间',
51
    ];
52

53
    /** 时间选择 */
54
    const DATE_SELECT_TODAY = 1;
55
    const DATE_SELECT_YESTERDAY = 2;
56
    const DATE_SELECT_THIS_MONTH = 3;
57
    const DATE_SELECT_LAST_MONTH = 4;
58
    // 时间选择描述
59
    const DATE_SELECT_DESC = [
60
        self::DATE_SELECT_TODAY => '今日',
61
        self::DATE_SELECT_YESTERDAY => '昨日',
62
        self::DATE_SELECT_THIS_MONTH => '本月',
63
        self::DATE_SELECT_LAST_MONTH => '上月',
64
    ];
65

66
    // 上期的描述
67
    const DATE_PREVIOUS_DESC = [
68
        self::DATE_SELECT_TODAY => '昨日',
69
        self::DATE_SELECT_YESTERDAY => '前日',
70
        self::DATE_SELECT_THIS_MONTH => '上月',
71
        self::DATE_SELECT_LAST_MONTH => '前月',
72
    ];
73

74
    // 循环类型
75
    const FOR_TYPE_HOUR = 0;
76
    const FOR_TYPE_DAY = 1;
77

78
    const FOR_TYPE_DESC = [
79
        self::FOR_TYPE_HOUR => '小时',
80
        self::FOR_TYPE_DAY => '天',
81
    ];
82

83

84
    /** 当前停留的块 */
85
    const POSITION_INDEX = 0;
86
    const POSITION_FX_USER_DETAIL = 1;
87
    const POSITION_INSTITUTION_PARTNER_DETAIL = 2;
88

89
    const POSITION_DESC = [
90
        self::POSITION_INDEX => '首页',
91
        self::POSITION_FX_USER_DETAIL => '分销者数据详情',
92
        self::POSITION_INSTITUTION_PARTNER_DETAIL => '机构招商数据详情',
93
    ];
94
    // 默认页码
95
    const DEFAULT_PAGE = 10;
96
}

其中使用到了助手函数主要是获取开始时间、结束时间、以及折线图需要的数据

1
if (!function_exists('getTimeByType')) {
2
    /**
3
     * 根据时间类型获取时间
4
     */
5
    function getTimeByType(int $date_type, int $date_value = 0, string $date_start = '', string $date_end = ''): array
6
    {
7
        $start_time = $end_time = $for_i = $for_type = 0;
8
        if ($date_type == WebSocketEnum::DATE_TYPE_SELECT) {
9
            switch ($date_value) {
10
                case WebSocketEnum::DATE_SELECT_TODAY:
11
                    $start_time = Carbon::today()->startOfDay()->timestamp;
12
                    $end_time = Carbon::today()->endOfDay()->timestamp;
13
                    $for_type = WebSocketEnum::FOR_TYPE_HOUR;
14
                    $for_i = 23;
15
                    break;
16
                case WebSocketEnum::DATE_SELECT_YESTERDAY:
17
                    $start_time = Carbon::yesterday()->startOfDay()->timestamp;
18
                    $end_time = Carbon::yesterday()->endOfDay()->timestamp;
19
                    $for_type = WebSocketEnum::FOR_TYPE_HOUR;
20
                    $for_i = 23;
21
                    break;
22
                case WebSocketEnum::DATE_SELECT_THIS_MONTH:
23
                    $start_time_handler = Carbon::now()->startOfMonth();
24
                    $end_time_handler = Carbon::now()->endOfMonth();
25
                    $for_i = $end_time_handler->diffInDays($start_time_handler);
26
                    $start_time = $start_time_handler->timestamp;
27
                    $end_time = $end_time_handler->timestamp;
28
                    $for_type = WebSocketEnum::FOR_TYPE_DAY;
29
                    break;
30
                case WebSocketEnum::DATE_SELECT_LAST_MONTH:
31
                    $start_time_handler = Carbon::now()->subMonth()->startOfMonth();
32
                    $end_time_handler = Carbon::now()->subMonth()->endOfMonth();
33
                    $for_i = $end_time_handler->diffInDays($start_time_handler);
34
                    $start_time = $start_time_handler->timestamp;
35
                    $end_time = $end_time_handler->timestamp;
36
                    $for_type = WebSocketEnum::FOR_TYPE_DAY;
37
                    break;
38
            }
39
        } elseif ($date_type == WebSocketEnum::DATE_TYPE_DIY) {
40
            if (empty($date_start) && empty($date_end)) {
41
                return [$start_time, $end_time, $for_type, $for_i];
42
            }
43
            $start_time_handler = Carbon::parse($date_start)->startOfDay();
44
            $end_time_handler = Carbon::parse($date_end)->endOfDay();
45
            if ($start_time_handler->isSameDay($end_time_handler)) {
46
                $for_type = WebSocketEnum::FOR_TYPE_HOUR;
47
                $for_i = 23;
48
            } else {
49
                $for_type = WebSocketEnum::FOR_TYPE_DAY;
50
                $for_i = $end_time_handler->diffInDays($start_time_handler);
51
            }
52
            $start_time = $start_time_handler->timestamp;
53
            $end_time = $end_time_handler->timestamp;
54
        }
55

56
        return [$start_time, $end_time, $for_type, $for_i];
57
    }
58
}

还使用到了DataRuleTrait特征，主要是获取当前用户可查看的数据范围ID列表

1
<?php
2
declare (strict_types=1);
3

4
namespace App\Module\DataScreen\Common\Trait;
5

6
use App\Module\DataScreen\Enum\DataRuleEnum;
7
use App\Module\DataScreen\Enum\WebSocketEnum;
8

9
trait DataRuleTrait
10
{
11

12
    /**
13
     * 数据权限
14
     * @param array $params
15
     * @param array $data_rule
16
     * @return string[]
17
     */
18
    public function getDataRuleParams(array $params, array $data_rule): array
19
    {
20
        $return_data = [
21
            'rule_source_ids' => ''
22
        ];
23

24
        $data_rule_data = [];
25
        foreach ($data_rule as $rule) {
26
            $data_rule_data[$rule['type']][$rule['step_type']][] = $rule['source_id'];
27
        }
28

29
        $module = intval($params['module']);
30
        if (!in_array($module, [WebSocketEnum::MODULE_BING_GONG_CHANG, WebSocketEnum::MODULE_INSTITUTION])) {
31
            return $return_data;
32
        }
33

34
        $return_data['rule_source_ids'] = '-1';
35
        if ($module == WebSocketEnum::MODULE_BING_GONG_CHANG) {
36
            $rule_source_ids = ($data_rule_data[DataRuleEnum::TYPE_FACTORY][DataRuleEnum::STEP_TYPE_FACTORY] ?? []) ?: [];
37
            $return_data['rule_source_ids'] = !empty($rule_source_ids) ? implode(',', $rule_source_ids) : '-1';
38
            return $return_data;
39
        }
40

41
        if ($module == WebSocketEnum::MODULE_INSTITUTION) {
42
            $step_type = DataRuleEnum::PLATFORM_STEP_TYPE_MAP[intval($params['platform'])];
43
            $rule_source_ids = ($data_rule_data[DataRuleEnum::TYPE_INSTITUTION][$step_type] ?? []) ?: [];
44
            $return_data['rule_source_ids'] = !empty($rule_source_ids) ? implode(',', $rule_source_ids) : '-1';
45
            return $return_data;
46
        }
47

48
        return $return_data;
49
    }
50
}

7. 创建数据查询特征#

创建数据查询中心特征Module/DataScreen/Common/Trait/DataCenterTrait.php，无需关注业务逻辑只需要关注中心方法dataCenter()即可，每个Business需要有public WebSocketParam $params;属性

1
<?php
2
declare (strict_types=1);
3

4
namespace App\Module\DataScreen\Common\Trait;
5

6
use App\Module\DataScreen\Business\OrderCensusBusiness;
7
use App\Module\DataScreen\Business\OrderChartBusiness;
8
use App\Module\DataScreen\Business\OrderRankBusiness;
9
use App\Module\DataScreen\Business\ProductBusiness;
10
use App\Module\DataScreen\Business\SendSampleBusiness;
11
use App\Module\DataScreen\Business\WdtOriginOrderBusiness;
12
use App\Module\DataScreen\Common\Params\WebSocketParam;
13
use App\Module\DataScreen\Enum\WebSocketEnum;
14
use Hyperf\Di\Annotation\Inject;
15

16
trait DataCenterTrait
17
{
18

19
    #[Inject]
20
    private WebSocketParam $webSocketParam;
21

22
    #[Inject]
23
    private OrderCensusBusiness $orderCensusBusiness;
24

25
    #[Inject]
26
    private SendSampleBusiness $sendSampleBusiness;
27

28

29
    #[Inject]
30
    private OrderRankBusiness $orderRankBusiness;
31

32
    #[Inject]
33
    private OrderChartBusiness $orderChartBusiness;
34

35
    #[Inject]
36
    private ProductBusiness $productBusiness;
37

38
    /**
39
     * 数据统一处理
40
     * @param array $params
41
     * @return array
42
     */
43
    public function dataCenter(array $params): array
44
    {
45

46
        $return_data = [];
47
        switch ($params['module']) {
48
            case WebSocketEnum::MODULE_BING_GONG_CHANG:
49
                // 兵工场模块
50
                $return_data = $this->getBingGongChangModule($params);
51
                break;
52
            case WebSocketEnum::MODULE_INSTITUTION:
53
                // 机构模块
54
                $return_data = $this->getInstitutionModule($params);
55
                break;
56
            case WebSocketEnum::MODULE_FX_USER:
57
                // 分销者模块
58
                $return_data = $this->getFxUserModule($params);
59
                break;
60
            case WebSocketEnum::MODULE_FX_PRODUCT:
61
                // 产品模块
62
                $return_data = $this->getProductModule($params);
63
                break;
64
            case WebSocketEnum::MODULE_SINGLE_BING_GONG_CHANG:
65
                // 单兵工场模块
66
                $return_data = $this->getSingleBingGongChangModule($params);
67
                break;
68
            case WebSocketEnum::MODULE_SINGLE_INSTITUTION:
69
                // 单机构模块
70
                $return_data = $this->getSingleInstitutionModule($params);
71
                break;
72
            case WebSocketEnum::MODULE_SINGLE_FACTORY_FX_USER:
73
                // 分销者实时数据汇总模块
74
                $return_data = $this->getSingleFactoryFxUserModule($params);
75
                break;
76
            case WebSocketEnum::MODULE_WANG_DAN_TONG:
77
                // 产品模块
78
                $return_data = $this->getWdtModule($params);
79
                break;
80
        }
81
        return $return_data;
82
    }
83

84

85
    /**
86
     * 获取兵工场模块数据
87
     * @param array $params
88
     * @return array
89
     */
90
    public function getBingGongChangModule(array $params): array
91
    {
92
        return match ($params['position']) {
93
            WebSocketEnum::POSITION_FX_USER_DETAIL => $this->getBingGongChangFxUserPosition($params),
94
            default => $this->getBingGongChangIndexPosition($params),
95
        };
96
    }
97

98
    /**
99
     * 获取单兵工场模块数据
100
     * @param array $params
101
     * @return array
102
     */
103
    public function getSingleBingGongChangModule(array $params): array
104
    {
105
        return match ($params['position']) {
106
            WebSocketEnum::POSITION_FX_USER_DETAIL => $this->getBingGongChangFxUserPosition($params),
107
            default => $this->getSingleBingGongChangIndexPosition($params),
108
        };
109
    }
110

111
    /**
112
     * 获取机构模块数据
113
     * @param array $params
114
     * @return array
115
     */
116
    public function getInstitutionModule(array $params): array
117
    {
118
        return match ($params['position']) {
119
            WebSocketEnum::POSITION_INSTITUTION_PARTNER_DETAIL => $this->getInstitutionPartnerPosition($params),
120
            default => $this->getInstitutionIndexPosition($params),
121
        };
122
    }
123

124
    /**
125
     * 获取单机构模块数据
126
     * @param array $params
127
     * @return array
128
     */
129
    public function getSingleInstitutionModule(array $params): array
130
    {
131
        return match ($params['position']) {
132
            WebSocketEnum::POSITION_INSTITUTION_PARTNER_DETAIL => $this->getInstitutionPartnerPosition($params),
133
            default => $this->getSingleInstitutionIndexPosition($params),
134
        };
135
    }
136

137
    /**
138
     * 获取分销者实时数据汇总模块数据
139
     * @param array $params
140
     * @return array
141
     */
142
    public function getSingleFactoryFxUserModule(array $params): array
143
    {
144
        return $this->getSingleFactoryFxUserIndexPosition($params);
145
    }
146

147
    /**
148
     * 获取机构招商数据详情
149
     * @param array $params
150
     * @return array
151
     */
152
    protected function getInstitutionPartnerPosition(array $params): array
153
    {
154
        // 参数服务
155
        $paramService = new WebSocketParam();
156
        fillProperty($params, $paramService);
157

158
        // 排行
159
        $orderRankService = new OrderRankBusiness();
160
        $orderRankService->params = $paramService;
161

162
        return [
163
            'institution_partner_detail_rank_block' => $orderRankService->getInstitutionPartnerDetailBlock(),
164
        ];
165
    }
166

167
    /**
168
     * 机构首页数据
169
     * @param array $params
170
     * @return array
171
     */
172
    protected function getInstitutionIndexPosition(array $params): array
173
    {
174
        // 参数服务
175
        $paramService = new WebSocketParam();
176
        fillProperty($params, $paramService);
177
        // 汇总
178
        $orderCensusService = new OrderCensusBusiness();
179
        $orderCensusService->params = $paramService;
180

181
        // 申样
182
        $sendSampleService = new SendSampleBusiness();
183
        $sendSampleService->params = $paramService;
184

185
        // 排行
186
        $orderRankService = new OrderRankBusiness();
187
        $orderRankService->params = $paramService;
188

189
        // 图表
190
        $orderChartService = new OrderChartBusiness();
191
        $orderChartService->params = $paramService;
192

193

194
        // 领样数据
195
        $send_sample_data = [
196
            // 领样数
197
            'current_send_sample_count' => formatWithUnit($sendSampleService->getSendSampleCount(), 0),
198
            // 申样发货数
199
            'current_express_sample_count' => formatWithUnit($sendSampleService->getExpressSampleCount(), 0),
200
        ];
201

202
        return [
203
            // gmv中心块
204
            'gmv_block' => $orderCensusService->getGmvBlock(),
205
            // 销售数据（左上）
206
            'sales_block' => array_merge($orderCensusService->getSalesBlock(), $send_sample_data),
207
            // 招商排行（左下）
208
            'institution_partner_rank_block' => $orderRankService->getInstitutionPartnerRankBlock(),
209
            // 订单折线图（右上）
210
            'sales_chart_block' => $orderChartService->getLineChartBlock(),
211
            // 机构销售榜单（右下）
212
            'institution_sales_rank_block' => $orderRankService->getInstitutionSalesRankBlock(),
213
            // 机构销售概况（中心饼图）
214
            'institution_sales_pie_block' => $orderChartService->getInstitutionSalesPieBlock(),
215
        ];
216
    }
217

218
    /**
219
     * 获取分销者实时数据汇总首页数据
220
     * @param array $params
221
     * @return array
222
     */
223
    protected function getSingleFactoryFxUserIndexPosition(array $params): array
224
    {
225
        // 参数服务
226
        $paramService = new WebSocketParam();
227
        fillProperty($params, $paramService);
228

229
        // 汇总
230
        $orderCensusService = new OrderCensusBusiness();
231
        $orderCensusService->params = $paramService;
232

233
        // 申样
234
        $sendSampleService = new SendSampleBusiness();
235
        $sendSampleService->params = $paramService;
236

237
        // 排行
238
        $orderRankService = new OrderRankBusiness();;
239
        $orderRankService->params = $paramService;
240

241

242

243
        // 领样数据
244
        $send_sample_data = [
245
            // 领样数
246
            'current_send_sample_count' => formatWithUnit($sendSampleService->getSendSampleCount(), 0),
247
            // 去重达人数
248
            'current_distinct_talent_num' => formatWithUnit($sendSampleService->getDistinctTalentNum(), 0),
249
        ];
250

251
        // 分销者总数
252
        $fx_user_count = $orderCensusService->getFxUserCount();
253

254
        return [
255
            // gmv中心块
256
            'gmv_block' => array_merge($orderCensusService->getGmvBlock(), compact('fx_user_count')),
257
            // 销售数据（左上）
258
            'sales_block' => array_merge($orderCensusService->getSalesBlock(), $send_sample_data),
259
            // 小组排行（左下）
260
            'fx_user_group_rank_block' => $orderRankService->getFxUserGroupRankBlock(),
261
            // 分销者销售红榜（右上）
262
            'fx_user_red_sales_block' => $orderRankService->getCommonFxUserRankBlock(),
263
            // 分销者销售黑榜（右下）
264
            'fx_user_black_sales_block' => $orderRankService->getCommonFxUserRankBlock('ASC'),
265
            // 分销者详情
266
            'fx_user_detail_block' => $orderRankService->getFxUserDetailBlock(),
267
        ];
268
    }
269

270

271
    /**
272
     * 单机构首页数据
273
     * @param array $params
274
     * @return array
275
     */
276
    protected function getSingleInstitutionIndexPosition(array $params): array
277
    {
278
        // 参数服务
279
        $paramService = new WebSocketParam();
280
        fillProperty($params, $paramService);
281

282
        // 汇总
283
        $orderCensusService = new OrderCensusBusiness();
284
        $orderCensusService->params = $paramService;
285

286
        // 申样
287
        $sendSampleService = new SendSampleBusiness();
288
        $sendSampleService->params = $paramService;
289

290
        // 排行
291
        $orderRankService = new OrderRankBusiness();
292
        $orderRankService->params = $paramService;
293

294
        // 图表
295
        $orderChartService = new OrderChartBusiness();
296
        $orderChartService->params = $paramService;
297

298
        // 领样数据
299
        $send_sample_data = [
300
            // 领样数
301
            'current_send_sample_count' => formatWithUnit($sendSampleService->getSendSampleCount(), 0),
302
            // 申样发货数
303
            'current_express_sample_count' => formatWithUnit($sendSampleService->getExpressSampleCount(), 0),
304
        ];
305

306
        return [
307
            // gmv中心块
308
            'gmv_block' => $orderCensusService->getGmvBlock(),
309
            // 销售数据（左上）
310
            'sales_block' => array_merge($orderCensusService->getSalesBlock(), $send_sample_data),
311
            // 招商排行（左下）
312
            'institution_partner_rank_block' => $orderRankService->getInstitutionPartnerRankBlock(),
313
            // 订单折线图（右上）
314
            'sales_chart_block' => $orderChartService->getLineChartBlock(),
315
            // 产品分类（右下）
316
            'category_sales_pie_block' => $orderChartService->getCategorySalesPieBlock(),
317
            // 兵工场销售占比（中心饼图）
318
            'bing_factory_sales_pie_block' => $orderChartService->getBingFactorySalesPieBlock(),
319
        ];
320
    }
321

322

323
    /**
324
     * 兵工场首页数据
325
     * @param array $params
326
     * @return array
327
     */
328
    protected function getBingGongChangIndexPosition(array $params): array
329
    {
330

331

332
        // 参数服务
333
        $paramService = new WebSocketParam();
334
        fillProperty($params, $paramService);
335

336
        // 汇总
337
        $orderCensusService = new OrderCensusBusiness();
338
        $orderCensusService->params = $paramService;
339

340
        // 申样
341
        $sendSampleService = new SendSampleBusiness();
342
        $sendSampleService->params = $paramService;
343

344
        // 排行
345
        $orderRankService = new OrderRankBusiness();
346
        $orderRankService->params = $paramService;
347

348
        // 图表
349
        $orderChartService = new OrderChartBusiness();
350
        $orderChartService->params = $paramService;
351

352
        // 领样数据
353
        $send_sample_data = [
354
            // 领样数
355
            'current_send_sample_count' => formatWithUnit($sendSampleService->getSendSampleCount(), 0),
356
            // 去重达人数
357
            'current_distinct_talent_num' => formatWithUnit($sendSampleService->getDistinctTalentNum(), 0),
358
        ];
359

360
        return [
361
            // gmv中心块
362
            'gmv_block' => $orderCensusService->getGmvBlock(),
363
            // 销售数据（左上）
364
            'sales_block' => array_merge($orderCensusService->getSalesBlock(), $send_sample_data),
365
            // 分销者销售排行（左下）
366
            'fx_user_rank_block' => $orderRankService->getFxUserRankBlock(),
367
            // 订单折线图（右上）
368
            'sales_chart_block' => $orderChartService->getLineChartBlock(),
369
            // 兵工场排行（右下）
370
            'bing_factory_rank_block' => $orderRankService->getBingFactoryRankBlock(),
371
            // 兵工场地图
372
            'bing_factory_map_block' => $orderChartService->getBingFactoryMapBlock(),
373
        ];
374
    }
375

376

377
    /**
378
     * 单兵工场首页数据
379
     * @param array $params
380
     * @return array
381
     */
382
    protected function getSingleBingGongChangIndexPosition(array $params): array
383
    {
384
        // 参数服务
385
        $paramService = new WebSocketParam();
386
        fillProperty($params, $paramService);
387

388
        // 汇总
389
        $orderCensusService = new OrderCensusBusiness();
390
        $orderCensusService->params = $paramService;
391

392
        // 申样
393
        $sendSampleService = new SendSampleBusiness();
394
        $sendSampleService->params = $paramService;
395

396
        // 排行
397
        $orderRankService = new OrderRankBusiness();
398
        $orderRankService->params = $paramService;
399

400
        // 图表
401
        $orderChartService = new OrderChartBusiness();
402
        $orderChartService->params = $paramService;
403

404
        // 领样数据
405
        $send_sample_data = [
406
            // 领样数
407
            'current_send_sample_count' => formatWithUnit($sendSampleService->getSendSampleCount(), 0),
408
            // 去重达人数
409
            'current_distinct_talent_num' => formatWithUnit($sendSampleService->getDistinctTalentNum(), 0),
410
        ];
411

412
        return [
413
            // gmv中心块
414
            'gmv_block' => $orderCensusService->getGmvBlock(),
415
            // 销售数据（左上）
416
            'sales_block' => array_merge($orderCensusService->getSalesBlock(), $send_sample_data),
417
            // 分销者销售排行（左下）
418
            'fx_user_rank_block' => $orderRankService->getFxUserRankBlock(),
419
            // 订单折线图（右上）
420
            'sales_chart_block' => $orderChartService->getLineChartBlock(),
421
            // 热销产品排行（右下）
422
            'product_rank_block' => $orderRankService->getProductRankBlock(),
423
            // 机构销售占比
424
            'institution_sales_pie_block' => $orderChartService->getInstitutionSalesPieBlock(),
425
        ];
426
    }
427

428
    /**
429
     * 兵工场-分销者详情数据
430
     * @param array $params
431
     * @return array
432
     */
433
    protected function getBingGongChangFxUserPosition(array $params): array
434
    {
435
        // 参数服务
436
        $paramService = new WebSocketParam();
437
        fillProperty($params, $paramService);
438

439
        // 排行
440
        $orderRankService = new OrderRankBusiness();
441
        $orderRankService->params = $paramService;
442

443
        return [
444
            'fx_user_detail_rank_block' => $orderRankService->getFxUserDetailBlock(),
445
        ];
446
    }
447

448

449
    /**
450
     * 分销者-分销者详情数据
451
     * @param array $params
452
     * @return array
453
     */
454
    protected function getFxUserDetailPosition(array $params): array
455
    {
456
        // 参数服务
457
        $paramService = new WebSocketParam();
458
        fillProperty($params, $paramService);
459

460
        // 排行
461
        $orderRankService = new OrderRankBusiness();
462
        $orderRankService->params = $paramService;
463

464
        return [
465
            'fx_user_detail_rank_block' => $orderRankService->getFxUserDetailBlock(),
466
        ];
467
    }
468

469

470
    /**
471
     * 分销者首页数据
472
     * @param array $params
473
     * @return array
474
     */
475
    protected function getFxUserIndexPosition(array $params): array
476
    {
477
        // 参数服务
478
        $paramService = new WebSocketParam();
479
        fillProperty($params, $paramService);
480

481
        // 汇总
482
        $orderCensusService = new OrderCensusBusiness();
483
        $orderCensusService->params = $paramService;
484

485
        // 申样
486
        $sendSampleService = new SendSampleBusiness();
487
        $sendSampleService->params = $paramService;
488

489
        // 排行
490
        $orderRankService = new OrderRankBusiness();
491
        $orderRankService->params = $paramService;
492

493
        // 图表
494
        $orderChartService = new OrderChartBusiness();
495
        $orderChartService->params = $paramService;
496

497
        // 领样数据
498
        $send_sample_data = [
499
            // 领样数
500
            'current_send_sample_count' => formatWithUnit($sendSampleService->getSendSampleCount(), 0),
501
            // 去重达人数
502
            'current_distinct_talent_num' => formatWithUnit($sendSampleService->getDistinctTalentNum(), 0),
503
        ];
504

505
        return [
506
            // gmv中心块
507
            'gmv_block' => $orderCensusService->getGmvBlock(),
508
            // 销售数据（左上）
509
            'sales_block' => array_merge($orderCensusService->getSalesBlock(), $send_sample_data),
510
            // 分销者销售排行（左下）
511
            'fx_user_rank_block' => $orderRankService->getFxUserRankBlock(),
512
            // 订单折线图（右上）
513
            'sales_chart_block' => $orderChartService->getLineChartBlock(),
514
            // 达人销售排行（右下）
515
            'customers_sales_rank_block' => $orderRankService->getCustomersSalesRankBlock(),
516
            // 地图
517
            'fx_user_map_block' => $orderChartService->getFxUserMapBlock(),
518
        ];
519
    }
520

521
    /**
522
     * 分销者模块
523
     * @param array $params
524
     * @return array
525
     */
526
    public function getFxUserModule(array $params): array
527
    {
528
        return match ($params['position']) {
529
            WebSocketEnum::POSITION_FX_USER_DETAIL => $this->getFxUserDetailPosition($params),
530
            default => $this->getFxUserIndexPosition($params),
531
        };
532
    }
533

534
    /**
535
     * 产品模块
536
     * @param array $params
537
     * @return array
538
     */
539
    public function getProductModule(array $params): array
540
    {
541
        // 参数服务
542
        $paramService = new WebSocketParam();
543
        fillProperty($params, $paramService);
544

545
        // 产品
546
        $productService = new ProductBusiness();
547
        $productService->params = $paramService;
548

549
        $orderChartService = new OrderChartBusiness();
550
        $orderChartService->params = $paramService;
551

552
        return [
553
            // gmv中心块
554
            'gmv_block' => $productService->getGmvBlock(),
555
            // 产品地图数据
556
            'region_block' => $productService->getRegionBlock(),
557
            // 产品数据汇总（左上）
558
            'product_census_block' => $productService->getProductCensusBlock(),
559
            // 出单产品增长情况（左下）
560
            'product_sales_chart_block' => $productService->getProductSalesChartBlock(),
561
            // 产品销售排行榜（右上）
562
            'product_sales_rank_block' => $productService->getProductSalesRandBlock(),
563
            // 产品分类占比（右下）
564
            'product_category_chart_block' => $orderChartService->getCategorySalesPieBlock(),
565
        ];
566
    }
567

568

569
    /**
570
     * 旺店通模块
571
     * @param array $params
572
     * @return array
573
     */
574
    public function getWdtModule(array $params): array
575
    {
576
        // 参数服务
577
        $paramService = new WebSocketParam();
578
        fillProperty($params, $paramService);
579

580
        // 旺店通订单
581
        $wdtOrderService = new WdtOriginOrderBusiness();
582
        $wdtOrderService->params = $paramService;
583

584
        return [
585
            // gmv中心块
586
            'gmv_block' => $wdtOrderService->getGmvBlock(),
587
            // 店铺资金流向 中
588
            'fund_flow_block' => $wdtOrderService->getFundFlowBlock(),
589
            // 成交排行榜（左上）
590
            'deal_rank_block' => $wdtOrderService->getDealRankBlock(),
591
            // 订单监控 右上
592
            'order_monitor_block' => $wdtOrderService->getOrderMonitorBlock(),
593
            // 店铺销售占比 左下
594
            'shop_sales_proportion_block' => $wdtOrderService->getShopSalesProportionBlock(),
595
            // 仓库信息，右下
596
            'warehouse_info_block' => $wdtOrderService->getWarehouseInfoBlock(),
597
            // 仓库信息详情
598
//            'warehouse_info_detail_block' => $wdtOrderService->getWarehouseInfoDetailBlock(),
599
        ];
600
    }
601
}

其中使用到了Module/DataScreen/Common/Params/WebSocketParam.php,为了参数统一

1
<?php
2
declare (strict_types=1);
3

4
namespace App\Module\DataScreen\Common\Params;
5

6
class WebSocketParam
7
{
8
    // 平台
9
    public int $platform;
10
    // 模块
11
    public int $module;
12
    // 开始时间
13
    public int $start_time;
14
    // 结束时间
15
    public int $end_time;
16
    // 开始时间 字符
17
    public string $date_start;
18
    // 结束时间 字符
19
    public string $date_end;
20
    // 时间类型
21
    public int $date_type;
22
    // 时间值
23
    public int $date_value;
24
    // 当前位置
25
    public int $position;
26
    // 分销者详情开始时间
27
    public int $fx_user_start_time;
28
    // 分销者详情结束时间
29
    public int $fx_user_end_time;
30
    // 分销者详情开始时间 字符
31
    public string $fx_user_date_start;
32
    // 分销者详情结束时间 字符
33
    public string $fx_user_date_end;
34
    // 分销者详情编号
35
    public string $fx_user_no;
36
    // 分销者详情页码
37
    public int $fx_user_page;
38

39
    // 模块相关用户ID
40
    public string $module_user_id = '';
41

42
    // 用户ID
43
//    public int $user_id;
44

45
    // 数据权限ID
46
    public string $rule_source_ids = '';
47

48
}

使用到了助手函数填充类属性

1
if (!function_exists('fillProperty')) {
2
    /**
3
     * 使用反射填充属性
4
     * @param array $params
5
     * @param object $instance
6
     */
7
    function fillProperty(array $params, object $instance): void
8
    {
9
        $ref = new ReflectionObject($instance);
10
        foreach ($params as $key => $value) {
11
            if ($ref->hasProperty($key)) {
12
                $prop = $ref->getProperty($key);
13
                $prop->setAccessible(true); // 允许访问 protected/private
14
                $prop->setValue($instance, $value);
15
            }
16
        }
17
    }
18
}

8. 测试#

请求ws://127.0.0.1:9503/wsDataScreen/ws测试连接是否成功

由于做了jwt鉴权需要带上token参数，目前我这里token不需要过期

我这里的发送参数类似这样，根据不同模块参数值变化

1
{
2
    "module":8,
3
    "platform":0,
4
    "date_type":1,
5
    "date_value":0,
6
    "date_start":"2025-08-12",
7
    "date_end":"2025-09-10",
8
    "position":0,
9
    "fx_user_date_start":"2025-02-12",
10
    "fx_user_date_end":"2025-03-10",
11
    "fx_user_page":1,
12
    "fx_user_no":""
13
}

9. 创建定时任务#

创建Command/DataScreenPushCommand.php文件定时查询数据是否变化推送对应客户端

这里注意：手动运行command会推送失败因为命令行的生命周期不一样，没有启动对应的websocket服务，定时任务可以正常推送。

1
<?php
2

3
declare(strict_types=1);
4

5
namespace App\Command;
6

7
use App\Service\DataScreenPushService;
8
use Hyperf\Command\Command as HyperfCommand;
9
use Hyperf\Command\Annotation\Command;
10
use Hyperf\Crontab\Annotation\Crontab;
11
use Hyperf\Di\Annotation\Inject;
12
use Psr\Container\ContainerInterface;
13
use Psr\Log\LoggerInterface;
14
use Hyperf\WebSocketServer\Sender;
15

16
#[Command]
17
#[Crontab(
18
    rule: "*\/1 * * * *",
19
    name: "dataScreenPush",
20
    type: "command",
21
    singleton: true,
22
    callback: [
23
        'command' => 'dataScreen:push',
24
        '--disable-event-dispatcher' => true,
25
    ],
26
    memo: "数据大屏消息推送",
27
    enable: false,
28
)]
29
class DataScreenPushCommand extends HyperfCommand
30
{
31
    #[Inject]
32
    protected Sender $sender;
33
    public function __construct(
34
        protected ContainerInterface $container,
35
        protected DataScreenPushService $service,
36
        protected LoggerInterface $logger
37
    )
38
    {
39
        parent::__construct('dataScreen:push');
40
    }
41

42
    public function configure()
43
    {
44
        parent::configure();
45
        $this->setDescription('数据大屏消息推送');
46
    }
47

48
    public function handle()
49
    {
50
        try {
51
            $start = microtime(true);
52

53
            $this->service->pushDataScreen();
54

55
            $duration = round(microtime(true) - $start, 2);
56
            $this->info("数据大屏消息推送操作完成，耗时：{$duration}秒");
57
        } catch (\Throwable $e) {
58
            // 简单记录错误
59
            $this->logger->error('数据大屏消息推送系统错误', [
60
                'error' => $e->getMessage(),
61
                'file' => $e->getFile(),
62
                'line' => $e->getLine()
63
            ]);
64
            $this->info('数据大屏消息推送系统错误！' . var_export($e->getMessage(), true));
65
        }
66

67
    }
68
}

创建服务Service/DataScreenPushService.php

1
<?php
2

3
namespace App\Service;
4

5
use App\Common\Trait\RedisKeyTrait;
6
use App\Module\DataScreen\Common\Trait\DataCenterTrait;
7
use App\Module\DataScreen\Enum\RedisKeyEnum;
8
use Hyperf\Di\Annotation\Inject;
9
use Hyperf\Redis\Redis;
10
use Hyperf\WebSocketServer\Sender;
11
use Psr\Log\LoggerInterface;
12

13
class DataScreenPushService
14
{
15
    use RedisKeyTrait;
16
    use DataCenterTrait;
17

18
    // 客户端=>筛选的key
19
    protected string $filter_key;
20

21
    // 存活客户端的key
22
    protected string $alive_key;
23

24
    #[Inject]
25
    private Redis $redis;
26

27
    #[Inject]
28
    private LoggerInterface $logger;
29

30
    #[Inject]
31
    private Sender $sender;
32
    public function pushDataScreen(): void
33
    {
34
        $this->filter_key = $this->generateKeyPrefix(RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD_FILTER);
35
        $this->alive_key = $this->generateKeyPrefix(RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD, version: 0);
36
        // 处理redis数据
37
        $fds = $this->dealRedisData();
38

39
        if (empty($fds)) {
40
            $this->logger->error('没有存活的客户端');
41
            return;
42
        }
43

44
        try {
45
            $filter_group_version = [];
46
            $filter_group_map_need_push = [];
47
            foreach ($fds as $fd) {
48
                $fd = intval($fd);
49
                if (!$this->sender->check($fd)) {
50
                    $this->redis->sRem($this->alive_key, $fd);
51
                    $this->redis->hDel($this->filter_key, $fd);
52
                    continue;
53
                }
54

55
                // 获取筛选条件
56
                $params_raw = $this->redis->hGet($this->filter_key, strval($fd));
57
                $params = json_decode($params_raw ?: '', true);
58
                if (empty($params)) {
59
                    $this->logger->error("客户端{$fd}没有筛选条件");
60
                    continue;
61
                }
62

63
                // 参数转换字符串
64
                $other_key = $this->generateFilterGroupKey($params);
65

66
                // 查询该筛选下的数据
67
                $filter_group_key = $this->generateKeyPrefix(
68
                    RedisKeyEnum::REDIS_KEY_WEBSOCKET_FD_FILTER_GROUP,
69
                    RedisKeyEnum::MODULE_DATA_SCREEN,
70
                    ":{$other_key}");
71
                $last_data_raw = $this->redis->get($filter_group_key);
72
                $last_data = json_decode($last_data_raw ?: '', true) ?: [];
73

74
                // 当前版本号
75
                $last_version = ($last_data['version'] ?? 0) ?: 0;
76
                !isset($filter_group_version[$filter_group_key]) && $filter_group_version[$filter_group_key] = $last_version;
77

78
                if ($filter_group_version[$filter_group_key] < $last_version) {
79
                    // 该筛选查询过了且数据有变化 则直接推送
80
                    if (!empty($filter_group_map_need_push[$filter_group_key] ?? 0)) {
81
                        $this->pushHandler($fd, $last_data['data'] ?: [], $params);
82
                    }
83
                    continue;
84
                }
85

86
                // 查询数据
87
                try {
88
                    $data = $this->dataCenter($params) ?: [];
89
                } catch (\Throwable $e) {
90
                    $this->logger->error('查询数据异常：参数为：' . json_encode($params) . '，异常原因：' . $e->getMessage());
91
                    continue;
92
                }
93

94
                $this->redis->set($filter_group_key, json_encode(['filter' => $params, 'data' => $data, 'version' => $filter_group_version[$filter_group_key] + 1, 'update_time' => time()]));
95
                $this->redis->expire($filter_group_key, 7200);
96

97
                if (($last_data['data'] ?? []) != $data) {
98
                    $filter_group_map_need_push[$filter_group_key] = 1;
99
                    $this->pushHandler($fd, $data, $params);
100
                }
101
            }
102
        } catch (\Throwable $e) {
103
            $this->logger->error('数据大屏消息推送消息异常：' . $e->getMessage());
104
        }
105
    }
106

107
    /**
108
     * 推送消息
109
     * @param int $fd
110
     * @param array $data
111
     * @param array $last_filter_param
112
     * @return bool
113
     * @throws \RedisException
114
     */
115
    protected function pushHandler(int $fd, array $data, array $last_filter_param): bool
116
    {
117
        // 检查客户端是否在线
118
        if (!$this->sender->check($fd)) {
119
            $this->redis->sRem($this->alive_key, $fd);
120
            $this->redis->hDel($this->filter_key, $fd);
121
            return false;
122
        }
123

124
        // 再次检查筛选条件是否变化
125
        $params_raw = $this->redis->hGet($this->filter_key, strval($fd));
126
        $params = json_decode($params_raw ?: '', true);
127
        if ($params != $last_filter_param) {
128
            return false;
129
        }
130

131
        // 推送消息
132
        return $this->sender->push($fd, responseSuccess($data));
133
    }
134

135
    /**
136
     * 对比数据不同处
137
     * @param array $last_data
138
     * @param array $data
139
     * @return array
140
     */
141
    protected function compareData(array $last_data, array $data): array
142
    {
143
        if (empty($last_data) || empty($data)) {
144
            return $data;
145
        }
146

147
        $return_data = [];
148
        foreach ($data as $key => $value) {
149
            if (!isset($last_data[$key])) {
150
                $return_data[$key] = $value;
151
                continue;
152
            }
153
            if ($value != $last_data[$key]) {
154
                $return_data[$key] = $value;
155
            }
156
        }
157
        return $return_data;
158
    }
159

160
    /**
161
     * 处理redis数据
162
     * @return array
163
     */
164
    protected function dealRedisData(): array
165
    {
166
        try {
167
            // 存活的fd
168
            $fds = $this->getAliveFds();
169

170
            // 客户端对应的筛选
171
            if (empty($fds)) {
172
                $this->redis->del($this->filter_key);
173
                return [];
174
            }
175

176
            // 获取所有key
177
            $all_filter_fd = $this->redis->hKeys($this->filter_key);
178
            foreach ($all_filter_fd as $fd_item) {
179
                if (!in_array($fd_item, $fds)) {
180
                    // 删除不存在的fd
181
                    $this->redis->hDel($this->filter_key, $fd_item);
182
                }
183
            }
184
            return $fds;
185
        } catch (\Throwable $e) {
186
            $this->logger->error("操作redis出现错误：" . $e->getMessage());
187
            return [];
188
        }
189

190
    }
191

192
    /**
193
     * 获取存活的客户端
194
     * @return array
195
     * @throws \RedisException
196
     */
197
    protected function getAliveFds(): array
198
    {
199
        return $this->redis->sMembers($this->alive_key) ?: [];
200
    }
201
}

使用到了返回函数

1
if (!function_exists('responseSuccess')) {
2
    /**
3
     * 成功响应
4
     */
5
    function responseSuccess(mixed $data = null, string $message = 'success', int $code = 200): false|string
6
    {
7
        return json_encode([
8
            'code' => $code,
9
            'message' => $message,
10
            'data' => $data,
11
            'timestamp' => time()
12
        ]);
13
    }
14
}
15

16
if (!function_exists('responseError')) {
17
    /**
18
     * 失败响应
19
     */
20
    function responseError(string $message = '', int $code = 400, mixed $data = null): false|string
21
    {
22
        return json_encode([
23
            'code' => $code,
24
            'message' => $message ?: default_error_message($code),
25
            'data' => $data,
26
            'timestamp' => time()
27
        ]);
28
    }
29
}

10. 反向代理#

配置nginx反向代理顺便升级w s为w s s

1
# 至少需要一个 Hyperf 节点，多个配置多行
2
upstream hyperf_websocket {
3
    # Hyperf WebSocket Server 的 IP 及 端口
4
    server 127.0.0.1:9503;
5
}
6

7
server {
8
    listen 80;
9
    listen 443 ssl;
10
    # 改成你的域名 可以匹配多个
11
    server_name xxx.com;
12
    # 配置 ssl  替换成自己的已经获得的域名签名文件名
13
    ssl_certificate     xxx.pem;  # pem文件的路径
14
    ssl_certificate_key  xxx.pem; # key文件的路径
15
    ssl_protocols TLSv1.1 TLSv1.2 TLSv1.3;
16
    ssl_ciphers EECDH+CHACHA20:EECDH+CHACHA20-draft:EECDH+AES128:RSA+AES128:EECDH+AES256:RSA+AES256:EECDH+3DES:RSA+3DES:!MD5;
17
    ssl_prefer_server_ciphers on;
18
    ssl_session_tickets on;
19
    ssl_session_cache shared:SSL:10m;
20
    ssl_session_timeout 10m;
21
    add_header Strict-Transport-Security "max-age=31536000";
22
    error_page 497  https://$host$request_uri;
23

24
    location / {
25
        # WebSocket Header
26
        proxy_http_version 1.1;
27
        proxy_set_header Upgrade websocket;
28
        proxy_set_header Connection "Upgrade";
29

30
        # 将客户端的 Host 和 IP 信息一并转发到对应节点
31
        proxy_set_header X-Real-IP $remote_addr;
32
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
33
        proxy_set_header Host $http_host;
34

35
        # 客户端与服务端无交互 60s 后自动断开连接，请根据实际业务场景设置
36
        proxy_read_timeout 60s ;
37

38
        # 执行代理访问真实服务器
39
        proxy_pass http://hyperf_websocket;
40
    }
41
}

配置好之后可以使用wss://xxx.com/wsDataScreen/ws连接了

11. 扩展#

可以安装websocket客户端测试，非必要

1
composer require hyperf/websocket-client

创建控制器

1
<?php
2
declare(strict_types=1);
3

4
namespace App\Controller;
5

6
use Hyperf\Di\Annotation\Inject;
7
use Hyperf\WebSocketClient\ClientFactory;
8
use Hyperf\WebSocketClient\Frame;
9

10
class IndexController
11
{
12
    #[Inject]
13
    protected ClientFactory $clientFactory;
14

15
    public function index()
16
    {
17
        // 对端服务的地址，如没有提供 ws:// 或 wss:// 前缀，则默认补充 ws://
18
        $host = '127.0.0.1:9503';
19
        // 通过 ClientFactory 创建 Client 对象，创建出来的对象为短生命周期对象
20
        $client = $this->clientFactory->create($host);
21
        // 向 WebSocket 服务端发送消息
22
        $client->push('HttpServer 中使用 WebSocket Client 发送数据。');
23
        // 获取服务端响应的消息，服务端需要通过 push 向本客户端的 fd 投递消息，才能获取；以下设置超时时间 2s，接收到的数据类型为 Frame 对象。
24
        /** @var Frame $msg */
25
        $msg = $client->recv(2);
26
        // 获取文本数据：$res_msg->data
27
        return $msg->data;
28
    }
29
}

12. 总结#

该流程会在握手阶段把存活的客户端fd保存在redis的DataScreen_prod_websocket_active_fd中。

数据类似

1
1161

然后记录客户端的筛选条件到redis的DataScreen_prod_websocket_fd_filter_v1中。

数据类似 3209对应

1
{
2
    "date_end": "2025-09-26",
3
    "date_start": "2025-09-25",
4
    "date_type": 1,
5
    "date_value": 0,
6
    "end_time": 1758902399,
7
    "fx_user_date_end": "",
8
    "fx_user_date_start": "",
9
    "fx_user_end_time": 0,
10
    "fx_user_no": "",
11
    "fx_user_page": 1,
12
    "fx_user_start_time": 0,
13
    "module": 8,
14
    "module_user_id": "",
15
    "platform": 1,
16
    "position": 0,
17
    "rule_source_ids": "",
18
    "start_time": 1758729600
19
}

每次查询都会记录数据缓存到DataScreen_prod_websocket_fd_filter_group:date_end__date_start__date_type_0_date_value_1_end_time_1762790399_fx_user_date_end__fx_user_date_start__fx_user_end_time_0_fx_user_no__fx_user_page_1_fx_user_start_time_0_module_8_module_user_id__platform_1_position_0_rule_source_ids__start_time_1762704000_v1hash中，为命令行校验数据变动使用，同时也加快了查询效率。

数据类似

1
{
2
    "filter": {
3
        "date_end": "",
4
        "date_start": "",
5
        "date_type": 0,
6
        "date_value": 1,
7
        "end_time": 1762790399,
8
        "fx_user_date_end": "",
9
        "fx_user_date_start": "",
10
        "fx_user_end_time": 0,
11
        "fx_user_no": "",
12
        "fx_user_page": 1,
13
        "fx_user_start_time": 0,
14
        "module": 8,
15
        "module_user_id": "",
16
        "platform": 1,
17
        "position": 0,
18
        "rule_source_ids": "",
19
        "start_time": 1762704000
20
    },
21
    "data": {},
22
    "version": 1,
23
    "update_time": 1762763257
24
}