239 lines
8.0 KiB
JavaScript
239 lines
8.0 KiB
JavaScript
|
/**
|
|||
|
|
* stores 聚合入口（规范 §131）
|
|||
|
|
*
|
|||
|
|
* 暴露 7 个 Store 单例 + 跨 Store 编排辅助函数 + 启动初始化 bootstrap。
|
|||
|
|
*
|
|||
|
|
* 跨 Store 编排原则：
|
|||
|
|
* - 单个 Store 自身只维护自己的状态，不直接 require 其他 Store（避免循环依赖）。
|
|||
|
|
* - 涉及多 Store 副作用的动作（如 Block 后会话停用、Mutual 后会话刷新）通过本文件
|
|||
|
|
* 暴露的辅助函数编排，调用方（页面）使用这些辅助函数而非直接组合多个 Store。
|
|||
|
|
*
|
|||
|
|
* 用法（页面）：
|
|||
|
|
* const { matchStore, appStore, blockUser } = require('../../stores');
|
|||
|
|
* await blockUser(userId, '骚扰');
|
|||
|
|
*/
|
|||
|
|
const authStore = require('./authStore');
|
|||
|
|
const userStore = require('./userStore');
|
|||
|
|
const matchStore = require('./matchStore');
|
|||
|
|
const messageStore = require('./messageStore');
|
|||
|
|
const activityStore = require('./activityStore');
|
|||
|
|
const matchmakerStore = require('./matchmakerStore');
|
|||
|
|
const appStore = require('./appStore');
|
|||
|
|
const { ROUTE, PROFILE_REVIEW, ACCOUNT_STATUS, buildPath } = require('../constants');
|
|||
|
|
|
|||
|
|
// ============ Review 状态路由守卫（P05-T12，规范 §4.3） ============
|
|||
|
|
//
|
|||
|
|
// AGENTS 第 9 条：PostgreSQL 是 Source of Truth——守卫只读 userStore.state.userState，
|
|||
|
|
// 不预判、不缓存；状态变化时由各页 onShow 调用 requireApproved 自检并跳转。
|
|||
|
|
//
|
|||
|
|
// 受保护路由分级：
|
|||
|
|
// - 'approved'：资料审核通过后方可访问（推荐/找对象/缘分中心/用户详情/活动报名）
|
|||
|
|
// - 'searching'：关系态为 searching 方可访问（部分推荐入口）
|
|||
|
|
// - 'logged_in'：仅需登录（消息/我的/设置等）
|
|||
|
|
// 审核未通过时一律引导至 REVIEW.PENDING 或 REVIEW.REJECTED。
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 受保护路由 → 所需最低审核态映射
|
|||
|
|
* 未列出的路由默认为 'logged_in'（仅需登录）
|
|||
|
|
*/
|
|||
|
|
const ROUTE_ACCESS_REQUIREMENTS = {
|
|||
|
|
// 推荐 / 找对象（PROFILE_NOT_APPROVED 错误码兜底，但客户端预拦截体验更好）
|
|||
|
|
[ROUTE.TAB.DISCOVER]: 'approved',
|
|||
|
|
[ROUTE.MAIN.DISCOVER]: 'approved',
|
|||
|
|
[ROUTE.MAIN.FATE_CENTER]: 'approved',
|
|||
|
|
[ROUTE.DETAIL.PROFILE_DETAIL]: 'approved',
|
|||
|
|
[ROUTE.DETAIL.ACTIVITY_REGISTER]: 'approved',
|
|||
|
|
// 红娘申请需审核通过
|
|||
|
|
[ROUTE.DETAIL.MATCHMAKER_APPLY]: 'approved',
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 读取当前用户的审核态（来自 userState.profileReviewStatus，仅本地读取）
|
|||
|
|
* @returns {string} PROFILE_REVIEW 值；未登录或无状态时返回 NOT_SUBMITTED
|
|||
|
|
*/
|
|||
|
|
function readReviewStatus() {
|
|||
|
|
return userStore.state.userState?.profileReviewStatus || PROFILE_REVIEW.NOT_SUBMITTED;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 根据当前审核态决定应跳转的"审核态页面"
|
|||
|
|
* @returns {string|null} 需要跳转的路径；approved 返回 null
|
|||
|
|
*/
|
|||
|
|
function getReviewRedirectPath() {
|
|||
|
|
const status = readReviewStatus();
|
|||
|
|
if (status === PROFILE_REVIEW.PENDING) return ROUTE.REVIEW.PENDING;
|
|||
|
|
if (status === PROFILE_REVIEW.NEED_EDIT || status === PROFILE_REVIEW.REJECTED) {
|
|||
|
|
return ROUTE.REVIEW.REJECTED;
|
|||
|
|
}
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 校验当前用户是否可访问指定路径
|
|||
|
|
* @param {string} path 路由常量
|
|||
|
|
* @returns {{ok: boolean, redirect?: string}} ok=true 可访问；ok=false 时 redirect 为应跳转路径
|
|||
|
|
*/
|
|||
|
|
function canAccess(path) {
|
|||
|
|
const required = ROUTE_ACCESS_REQUIREMENTS[path];
|
|||
|
|
if (!required || required === 'logged_in') return { ok: true };
|
|||
|
|
|
|||
|
|
const reviewStatus = readReviewStatus();
|
|||
|
|
const accountStatus = userStore.state.userState?.accountStatus || ACCOUNT_STATUS.NORMAL;
|
|||
|
|
|
|||
|
|
// 账号异常态优先拦截
|
|||
|
|
if (accountStatus !== ACCOUNT_STATUS.NORMAL) {
|
|||
|
|
return { ok: false, redirect: ROUTE.REVIEW.ACCOUNT_STATUS };
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (required === 'approved' && reviewStatus !== PROFILE_REVIEW.APPROVED) {
|
|||
|
|
const redirect = getReviewRedirectPath();
|
|||
|
|
return { ok: false, redirect: redirect || ROUTE.REVIEW.PENDING };
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return { ok: true };
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 守卫式导航：检查审核态后再决定跳转目标
|
|||
|
|
*
|
|||
|
|
* 用法：
|
|||
|
|
* const { guardedNavigate } = require('../../stores');
|
|||
|
|
* guardedNavigate(ROUTE.MAIN.DISCOVER); // 未审核则自动跳 review-pending
|
|||
|
|
*
|
|||
|
|
* @param {string} path 目标路由常量
|
|||
|
|
* @param {Record<string, string|number>} [params] 仅 id 类参数
|
|||
|
|
* @returns {boolean} 是否成功发起导航（true=已跳转到目标或审核页）
|
|||
|
|
*/
|
|||
|
|
function guardedNavigate(path, params) {
|
|||
|
|
const access = canAccess(path);
|
|||
|
|
if (access.ok) {
|
|||
|
|
const target = params ? buildPath(path, params) : path;
|
|||
|
|
wx.navigateTo({ url: target });
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
if (access.redirect) {
|
|||
|
|
wx.redirectTo({ url: access.redirect });
|
|||
|
|
}
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 当前用户是否已通过资料审核
|
|||
|
|
* @returns {boolean}
|
|||
|
|
*/
|
|||
|
|
function isProfileApproved() {
|
|||
|
|
return readReviewStatus() === PROFILE_REVIEW.APPROVED;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// ============ 跨 Store 编排 ============
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 拉黑用户：触发 MatchStore 与 MessageStore 同步副作用
|
|||
|
|
* - MatchStore：从推荐/Mutual 列表移除该用户
|
|||
|
|
* - MessageStore：标记对应会话不可发消息（AGENTS 第 4 条）
|
|||
|
|
* @param {string} userId
|
|||
|
|
* @param {string} [reason]
|
|||
|
|
*/
|
|||
|
|
async function blockUser(userId, reason) {
|
|||
|
|
await matchStore.block(userId, reason);
|
|||
|
|
// 查找对应会话并标记停用
|
|||
|
|
const conv = messageStore.state.conversations.find(
|
|||
|
|
(c) => c.targetUserId === userId || c.conversationId === userId,
|
|||
|
|
);
|
|||
|
|
if (conv) messageStore.markConversationBlocked(conv.conversationId);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Like 用户：若返回 mutualMatch=true，自动刷新会话列表
|
|||
|
|
* @param {string} userId
|
|||
|
|
* @returns {Promise<import('../types').LikeResult>}
|
|||
|
|
*/
|
|||
|
|
async function likeUser(userId) {
|
|||
|
|
const result = await matchStore.like(userId);
|
|||
|
|
if (result && result.mutualMatch) {
|
|||
|
|
// Mutual Match 达成，刷新会话列表，让用户能立即开始聊天
|
|||
|
|
await messageStore.fetchConversations();
|
|||
|
|
}
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 解除匹配：触发 MatchStore 与 MessageStore 同步副作用
|
|||
|
|
* @param {string} matchId
|
|||
|
|
*/
|
|||
|
|
async function unmatchConversation(matchId) {
|
|||
|
|
await matchStore.unmatch(matchId);
|
|||
|
|
messageStore.markConversationBlocked(matchId);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 成功牵手：双确认第二步（仅被请求方调用），成功后刷新 userStore 与会话列表
|
|||
|
|
* @param {string} matchId
|
|||
|
|
*/
|
|||
|
|
async function confirmSuccess(matchId) {
|
|||
|
|
const result = await matchStore.confirmSuccess(matchId);
|
|||
|
|
// 成功牵手后关系状态变化，需刷新 userState
|
|||
|
|
try { await userStore.fetchStatus(); } catch (e) { /* 不阻塞主流程 */ }
|
|||
|
|
try { await messageStore.fetchConversations(); } catch (e) { /* 同上 */ }
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// ============ 启动初始化 ============
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* App.onLaunch 调用，按依赖顺序初始化所有 Store
|
|||
|
|
* 1. appStore.init() — 拉取服务端配置（不阻塞核心）
|
|||
|
|
* 2. authStore.hydrate() — 从本地恢复登录态
|
|||
|
|
* 3. userStore.hydrate() — 从本地恢复用户状态快照
|
|||
|
|
* 4. messageStore.hydrate() — 从本地恢复未读数（兜底）
|
|||
|
|
* 5. 若已登录，异步刷新 userStore.fetchStatus()（不阻塞启动）
|
|||
|
|
*/
|
|||
|
|
async function bootstrap() {
|
|||
|
|
// 同步阶段：本地状态恢复（避免白屏）
|
|||
|
|
authStore.hydrate();
|
|||
|
|
userStore.hydrate();
|
|||
|
|
messageStore.hydrate();
|
|||
|
|
|
|||
|
|
// 异步阶段：服务端配置 + 用户状态刷新
|
|||
|
|
// 配置失败不阻塞启动；状态失败由路由守卫处理（跳登录页）
|
|||
|
|
appStore.init().catch(() => {});
|
|||
|
|
|
|||
|
|
if (authStore.state.isLoggedIn) {
|
|||
|
|
userStore.fetchStatus().catch(() => {});
|
|||
|
|
} else {
|
|||
|
|
// 未登录：跳转到登录页（使用 navigateTo 而非 redirectTo，因为首页是 Tab 页）
|
|||
|
|
setTimeout(() => {
|
|||
|
|
try {
|
|||
|
|
wx.navigateTo({ url: ROUTE.AUTH.LOGIN });
|
|||
|
|
} catch (e) {
|
|||
|
|
console.warn('[bootstrap] 跳转登录页失败:', e);
|
|||
|
|
}
|
|||
|
|
}, 300);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
module.exports = {
|
|||
|
|
// 单例 Store
|
|||
|
|
authStore,
|
|||
|
|
userStore,
|
|||
|
|
matchStore,
|
|||
|
|
messageStore,
|
|||
|
|
activityStore,
|
|||
|
|
matchmakerStore,
|
|||
|
|
appStore,
|
|||
|
|
// 跨 Store 编排辅助
|
|||
|
|
blockUser,
|
|||
|
|
likeUser,
|
|||
|
|
unmatchConversation,
|
|||
|
|
confirmSuccess,
|
|||
|
|
// Review 状态路由守卫（P05-T12）
|
|||
|
|
readReviewStatus,
|
|||
|
|
getReviewRedirectPath,
|
|||
|
|
canAccess,
|
|||
|
|
guardedNavigate,
|
|||
|
|
isProfileApproved,
|
|||
|
|
ROUTE_ACCESS_REQUIREMENTS,
|
|||
|
|
// 启动入口
|
|||
|
|
bootstrap,
|
|||
|
|
};
|