微爱帮监狱寄信写信工具朋友圈转发层级统计技术方案-开发者社区

一、层级追踪编码设计

// 1. 智能分享参数生成 class ShareTracker { private $redis; public function generateShareCode($userId) { // 生成11位分享码：用户ID(6)+时间(3)+随机(2) $code = substr($userId, -6) . substr(time(), -3) . str_pad(rand(0, 99), 2, '0', STR_PAD_LEFT); // Redis存储关系映射，7天有效期 $this->redis->setex("share:{$code}", 604800, json_encode([ 'user_id' => $userId, 'created_at' => time(), 'type' => 'circle' ])); return $code; } public function buildShareUrl($contentId, $shareCode) { return "https://weiai.tech/share/{$contentId}?sc={$shareCode}&t=" . base64_encode("circle_" . time()); } }

二、层级关系存储

-- 2. 转发关系链存储 CREATE TABLE wechat_share_chains ( id BIGINT PRIMARY KEY AUTO_INCREMENT, content_id VARCHAR(32) NOT NULL COMMENT '分享内容ID', -- 关系链（最多追踪10级） chain_code VARCHAR(110) NOT NULL COMMENT '层级链码: 001-002-003', root_user VARCHAR(32) NOT NULL COMMENT '根节点用户', current_user VARCHAR(32) NOT NULL COMMENT '当前分享用户', parent_user VARCHAR(32) COMMENT '上级用户', -- 层级信息 level TINYINT DEFAULT 1 COMMENT '当前层级', total_levels TINYINT DEFAULT 1 COMMENT '总层级深度', -- 统计指标 view_count INT DEFAULT 0 COMMENT '浏览次数', click_count INT DEFAULT 0 COMMENT '链接点击', share_count INT DEFAULT 0 COMMENT '再分享次数', -- 微信数据 wechat_openid VARCHAR(64) COMMENT '微信openid', share_timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP, -- 索引 INDEX idx_chain (chain_code), INDEX idx_content (content_id, level), INDEX idx_user (current_user, share_timestamp), INDEX idx_parent (parent_user, content_id), -- 约束 UNIQUE KEY uk_user_content (current_user, content_id), CHECK (level BETWEEN 1 AND 10) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='微信转发层级关系'; -- 实时统计表 CREATE TABLE share_stats_realtime ( content_id VARCHAR(32) NOT NULL, level TINYINT NOT NULL, hour_key VARCHAR(10) COMMENT '小时统计: 2025101514', -- 统计指标 total_shares INT DEFAULT 0, unique_users INT DEFAULT 0, total_views INT DEFAULT 0, total_clicks INT DEFAULT 0, -- 更新时间 last_updated TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (content_id, level, hour_key) ) COMMENT='转发实时统计';

三、实时层级分析

// 3. 实时传播分析引擎 class SpreadAnalyzer { public function trackShare($contentId, $currentUser, $parentCode = null) { // 解析层级链 if ($parentCode) { $parentChain = $this->getChainByCode($parentCode); $level = $parentChain['level'] + 1; $chainCode = $parentChain['chain_code'] . '-' . str_pad($level, 3, '0', STR_PAD_LEFT); $rootUser = $parentChain['root_user']; } else { $level = 1; $chainCode = '001'; $rootUser = $currentUser; } // 记录关系 $this->saveChain($contentId, $chainCode, $rootUser, $currentUser, $level); // 实时统计更新 $this->updateRealtimeStats($contentId, $level); // 防刷检查 $this->antiCheck($currentUser, $contentId); return [ 'level' => $level, 'chain_code' => $chainCode, 'is_root' => $level === 1 ]; } private function updateRealtimeStats($contentId, $level) { $hourKey = date('YmdH'); // Redis原子操作更新 $redisKey = "stats:{$contentId}:{$level}:{$hourKey}"; $this->redis->multi() ->hincrby($redisKey, 'total_shares', 1) ->expire($redisKey, 7200) // 2小时过期 ->exec(); // 每100次同步到数据库 if (rand(1, 100) === 1) { $this->syncToDatabase($contentId, $level, $hourKey); } } }

四、防刷与验证

// 4. 防刷保护系统 class AntiFraudSystem { private $limits = [ 'max_shares_per_hour' => 50, 'max_same_ip_per_hour' => 20, 'min_share_interval' => 10 // 秒 ]; public function validateShare($userId, $ip, $contentId) { $checks = [ $this->checkFrequency($userId), $this->checkIPLimit($ip), $this->checkInterval($userId), $this->checkBlacklist($userId, $ip) ]; return !in_array(false, $checks, true); } private function checkFrequency($userId) { $key = "freq:{$userId}:" . date('YmdH'); $count = $this->redis->incr($key); $this->redis->expire($key, 3600); return $count <= $this->limits['max_shares_per_hour']; } private function checkIPLimit($ip) { $key = "ip:{$ip}:" . date('YmdH'); $count = $this->redis->incr($key); $this->redis->expire($key, 3600); return $count <= $this->limits['max_same_ip_per_hour']; } }

五、数据可视化接口

// 5. 层级统计查询API class ShareStatsAPI { public function getSpreadTree($contentId, $maxLevel = 5) { // 获取传播树 $tree = $this->buildTree($contentId, $maxLevel); // 计算关键指标 $stats = [ 'total_users' => $this->countTotalUsers($tree), 'max_depth' => $this->getMaxDepth($tree), 'avg_breadth' => $this->getAvgBreadth($tree), 'hot_nodes' => $this->findHotNodes($tree, 5) ]; // 传播力评分 $score = $this->calculateSpreadScore($stats); return [ 'tree' => $tree, 'stats' => $stats, 'score' => $score, 'updated_at' => time() ]; } public function getUserSpreadData($userId, $days = 7) { $data = []; for ($i = $days; $i >= 0; $i--) { $date = date('Y-m-d', strtotime("-{$i} days")); $data[$date] = [ 'shares' => $this->getDailyShares($userId, $date), 'downstream' => $this->countDownstreamUsers($userId, $date), 'conversion' => $this->calculateConversion($userId, $date) ]; } return [ 'user_id' => $userId, 'period' => "{$days}天", 'data' => $data, 'summary' => $this->getUserSummary($userId, $days) ]; } }