([]);
+ const [loading, setLoading] = useState(true);
+ const [error, setError] = useState('');
+
+ useEffect(() => {
+ panelRef.current?.scrollIntoView({ behavior: 'smooth', block: 'nearest' });
+ }, []);
+
+ useEffect(() => {
+ let cancelled = false;
+ void (async () => {
+ setLoading(true);
+ setError('');
+ try {
+ const rows = await fetchHealthTimeline(days);
+ if (!cancelled) setTimeline(rows as TimelineDay[]);
+ } catch (err) {
+ if (!cancelled) {
+ setError(err instanceof Error ? err.message : '读取 Timeline 失败');
+ }
+ } finally {
+ if (!cancelled) setLoading(false);
+ }
+ })();
+ return () => {
+ cancelled = true;
+ };
+ }, [days]);
+
+ return (
+
+
+ 健康 Timeline（近 {days} 天）
+ {onClose ? (
+
+ ) : null}
+
+ {loading ? 加载中…
: null}
+ {error ? {error}
: null}
+ {!loading && !error && timeline.length === 0 ? (
+ 还没有确认过的健康记录。回复「1」开始录入。
+ ) : null}
+ {!loading && timeline.length > 0 ? (
+
+ {timeline.map((day) => (
+ -
+
{day.date}
+
+ {Object.values(day.metrics).map((metric) => (
+ -
+ {metric.label}: {metric.value}
+ {metric.context ? ` · ${metric.context}` : ''}
+
+ ))}
+
+
+ ))}
+
+ ) : null}
+
+ );
+}
diff --git a/src/components/MindSpacePageDetail.tsx b/src/components/MindSpacePageDetail.tsx
index daca376..8fbe5dd 100644
--- a/src/components/MindSpacePageDetail.tsx
+++ b/src/components/MindSpacePageDetail.tsx
@@ -41,6 +41,13 @@ import { MindSpaceDeletePlazaOption } from './MindSpaceDeletePlazaOption';
import { MindSpacePublishSuccess } from './MindSpacePublishSuccess';
import { MindSpacePageDataOpsPanel } from './MindSpacePageDataOpsPanel';
import { prepareHtmlPageBrandMarkers } from '../../mindspace-page-tag.mjs';
+import {
+ defaultAccessModeForCategory,
+ filterAccessModesForCategory,
+ filterPageDataDatasetsForCategory,
+ healthCategoryPageDataDefaults,
+ isHealthCategoryCode,
+} from '../../health-mindspace.mjs';
type AccessMode = MindSpacePublishCheck['accessMode'];
@@ -330,8 +337,11 @@ export function MindSpacePageDetail({
void listPageDataDatasets()
.then((datasets) => {
if (cancelled) return;
- setPageDataDatasets(datasets);
- setPageDataDataset((current) => current || datasets[0]?.name || '');
+ const filtered = page?.categoryCode
+ ? filterPageDataDatasetsForCategory(page.categoryCode, datasets)
+ : datasets;
+ setPageDataDatasets(filtered);
+ setPageDataDataset((current) => current || filtered[0]?.name || '');
})
.catch((err) => {
if (cancelled) return;
@@ -343,7 +353,18 @@ export function MindSpacePageDetail({
return () => {
cancelled = true;
};
- }, [publishOpen]);
+ }, [publishOpen, page?.categoryCode]);
+
+ useEffect(() => {
+ if (!publishOpen || !isHealthCategoryCode(page?.categoryCode ?? '')) return;
+ const defaults = healthCategoryPageDataDefaults();
+ setPageDataEnabled(true);
+ setPageDataRead(defaults.read);
+ setPageDataInsert(defaults.insert);
+ setPageDataUpdate(defaults.update);
+ setPageDataSoftDelete(defaults.softDelete);
+ setAccessMode((current) => defaultAccessModeForCategory(page?.categoryCode ?? '', current));
+ }, [publishOpen, page?.categoryCode]);
useEffect(() => {
if (!publishOpen || !page?.id) return;
@@ -419,7 +440,9 @@ export function MindSpacePageDetail({
setPreviewKey((value) => value + 1);
setTemplateId(next.templateId);
setUrlSlug(next.publication?.urlSlug ?? slugFromTitle(next.title, next.id));
- setAccessMode(next.publication?.accessMode ?? 'public');
+ setAccessMode(
+ defaultAccessModeForCategory(next.categoryCode, next.publication?.accessMode ?? 'public'),
+ );
setAccessPassword('');
setExpiresAt(
next.publication?.expiresAt
@@ -1252,13 +1275,20 @@ export function MindSpacePageDetail({
setFixNotice(null);
}}
>
- {Object.entries(ACCESS_MODE_LABELS).map(([value, label]) => (
+ {Object.entries(
+ filterAccessModesForCategory(page?.categoryCode ?? '', ACCESS_MODE_LABELS),
+ ).map(([value, label]) => (
))}
+ {isHealthCategoryCode(page?.categoryCode ?? '') ? (
+
+ 健康档案区禁止完全公开发布；分享请使用口令或登录访问，并绑定脱敏摘要 dataset。
+
+ ) : null}
{PAGE_DATA_PUBLISH_MODES.has(accessMode) ? (
- {['oa', 'public'].includes(selectedCategory.code) && (
+ {['oa', 'public', 'health'].includes(selectedCategory.code) && (
)}
+ {selectedCategory.code === 'health' ? (
+ showPage(pageId)} />
+ ) : null}
+
{selectedCategory.code === 'draft' ? (
pages.length > 0 ? (
<>
@@ -3188,7 +3211,8 @@ export function MindSpaceView({
{space.categories
- .filter((category) => ['oa', 'public', 'health', 'archive'].includes(category.code))
+ .filter((category) => ['oa', 'public', 'archive'].includes(category.code)
+ || (category.code === 'health' && healthEnabled))
.map((category) => (
;
+ pendingValues: Record | null;
+};
+
+type HealthCommit = {
+ confirmed?: boolean;
+ values?: {
+ metricSet?: string;
+ systolic?: number;
+ diastolic?: number;
+ context?: 'morning' | 'evening' | 'other';
+ observedAt?: number;
+ valueNum?: number;
+ symptomCode?: string;
+ severity?: number;
+ };
+};
+
+function extractionToTurnText(extraction: {
+ metricSet: string;
+ values: Record;
+}) {
+ if (extraction.metricSet === 'blood_pressure') {
+ const { systolic, diastolic } = extraction.values;
+ return `${systolic}/${diastolic}`;
+ }
+ if (extraction.metricSet === 'heart_rate' && extraction.values.hr != null) {
+ return `心率 ${extraction.values.hr}`;
+ }
+ if (extraction.metricSet === 'weight' && extraction.values.weight != null) {
+ return `体重 ${extraction.values.weight}`;
+ }
+ if (extraction.metricSet === 'spo2' && extraction.values.spo2 != null) {
+ return `血氧 ${extraction.values.spo2}`;
+ }
+ if (extraction.metricSet === 'temperature' && extraction.values.temperature != null) {
+ return `体温 ${extraction.values.temperature}`;
+ }
+ return '';
+}
+
+function channelMetricHint(wrapper: HealthSessionWrapper | null) {
+ const metricSet = wrapper?.channelState?.metricSet;
+ return typeof metricSet === 'string' ? metricSet : null;
+}
+
+function isDocumentUploadMode(wrapper: HealthSessionWrapper | null) {
+ return wrapper?.channelState?.action === HEALTH_ACTIONS.DOCUMENT;
+}
+
+function channelStateStep(wrapper: HealthSessionWrapper | null) {
+ const step = wrapper?.channelState?.step;
+ return typeof step === 'string' ? step : 'idle';
+}
+
+function buildHealthMessage(
+ role: 'user' | 'assistant',
+ text: string,
+ messageId?: string,
+): Message {
+ const trimmed = text.trim();
+ return {
+ id: messageId ?? `health-${role}-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`,
+ role,
+ created: Math.floor(Date.now() / 1000),
+ content: [{ type: 'text', text: trimmed }],
+ metadata: {
+ userVisible: true,
+ agentVisible: true,
+ displayText: trimmed,
+ },
+ };
+}
+
+function formatTimelineChatSummary(
+ timeline: Array<{
+ date: string;
+ metrics: Record;
+ }>,
+) {
+ if (!timeline.length) {
+ return [
+ '近 14 天还没有确认过的健康记录。',
+ '完整档案请打开：/space?category=health',
+ '回复「1」继续录入。',
+ ].join('\n');
+ }
+
+ const previewDays = timeline.slice(0, 7);
+ const lines = previewDays.flatMap((day) => {
+ const metrics = Object.values(day.metrics)
+ .map((metric) => {
+ const context = metric.context ? ` · ${metric.context}` : '';
+ return `${metric.label} ${metric.value}${context}`;
+ })
+ .join('；');
+ return metrics ? [`${day.date}：${metrics}`] : [];
+ });
+
+ return [
+ `近 14 天共 ${timeline.length} 天有确认记录：`,
+ ...lines,
+ timeline.length > previewDays.length
+ ? `… 其余 ${timeline.length - previewDays.length} 天见下方 Timeline 卡片`
+ : '',
+ '完整档案请打开：/space?category=health',
+ '回复「1」继续录入。',
+ ]
+ .filter(Boolean)
+ .join('\n');
+}
+
+export function useHealthChannel({
+ enabled,
+ newSession,
+}: {
+ enabled?: boolean;
+ newSession: () => Promise;
+}) {
+ const [active, setActive] = useState(false);
+ const [showTimeline, setShowTimeline] = useState(false);
+ const [unreadAlerts, setUnreadAlerts] = useState([]);
+ const [alertsGateOpen, setAlertsGateOpen] = useState(true);
+ const [acknowledgingAlerts, setAcknowledgingAlerts] = useState(false);
+ const [overlayMessages, setOverlayMessages] = useState([]);
+ const sessionRef = useRef(null);
+ const sourceRefRef = useRef(null);
+ const draftKeyRef = useRef(null);
+
+ const appendMessages = useCallback((items: Message[]) => {
+ setOverlayMessages((current) => [...current, ...items]);
+ }, []);
+
+ const resetChannel = useCallback(() => {
+ sessionRef.current = null;
+ setActive(false);
+ setShowTimeline(false);
+ setUnreadAlerts([]);
+ setAlertsGateOpen(true);
+ setAcknowledgingAlerts(false);
+ setOverlayMessages([]);
+ }, []);
+
+ const deactivateChannel = useCallback(() => {
+ sessionRef.current = null;
+ setActive(false);
+ setShowTimeline(false);
+ setUnreadAlerts([]);
+ setAlertsGateOpen(true);
+ }, []);
+
+ const openAlertsGateWithMenu = useCallback(() => {
+ setAlertsGateOpen(true);
+ appendMessages([buildHealthMessage('assistant', HEALTH_MENU_TEXT)]);
+ }, [appendMessages]);
+
+ const acknowledgeAllAlerts = useCallback(async () => {
+ setAcknowledgingAlerts(true);
+ try {
+ await acknowledgeAllHealthAlerts();
+ setUnreadAlerts([]);
+ openAlertsGateWithMenu();
+ } catch (error) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ error instanceof Error ? error.message : '确认提醒失败，请稍后重试。',
+ ),
+ ]);
+ } finally {
+ setAcknowledgingAlerts(false);
+ }
+ }, [appendMessages, openAlertsGateWithMenu]);
+
+ const persistCommit = useCallback(async (commit: HealthCommit) => {
+ const values = commit.values;
+ if (!values?.metricSet && values?.systolic == null) return;
+ await saveHealthObservation({
+ ...values,
+ confirmed: true,
+ source: sourceRefRef.current ? 'photo' : 'manual',
+ sourceRef: values.sourceRef ?? sourceRefRef.current ?? null,
+ } as Record);
+ sourceRefRef.current = null;
+ draftKeyRef.current = null;
+ }, []);
+
+ const finalizeTurn = useCallback(
+ async (result: ReturnType) => {
+ if (result.session) {
+ sessionRef.current = result.session as HealthSessionWrapper;
+ setActive(true);
+ } else {
+ deactivateChannel();
+ }
+
+ if (result.commit) {
+ try {
+ await persistCommit(result.commit as HealthCommit);
+ } catch (error) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ error instanceof Error ? error.message : '保存失败，请稍后重试。',
+ ),
+ ]);
+ }
+ }
+ },
+ [appendMessages, deactivateChannel, persistCommit],
+ );
+
+ const enterChannel = useCallback(
+ async ({
+ userText,
+ messageId,
+ seedText,
+ showRedirect = false,
+ }: {
+ userText?: string;
+ messageId?: string;
+ seedText?: string;
+ showRedirect?: boolean;
+ } = {}) => {
+ if (!enabled) return;
+
+ await newSession();
+ sessionRef.current = null;
+ setOverlayMessages([]);
+ setActive(true);
+ setAlertsGateOpen(true);
+ setUnreadAlerts([]);
+ void bootstrapHealthWorkspace().catch(() => undefined);
+
+ const alerts = await fetchHealthUnreadAlerts().catch(() => []);
+ if (alerts.length > 0) {
+ setUnreadAlerts(alerts);
+ setAlertsGateOpen(false);
+ sessionRef.current = {
+ channelState: {
+ sessionKind: 'health',
+ channel: 'h5',
+ step: 'idle',
+ action: null,
+ metricSet: null,
+ context: null,
+ pendingDraftId: null,
+ lastPrompt: null,
+ },
+ pendingValues: null,
+ };
+ const initialMessages: Message[] = [];
+ if (userText?.trim()) {
+ initialMessages.push(buildHealthMessage('user', userText, messageId));
+ }
+ if (showRedirect) {
+ initialMessages.push(buildHealthMessage('assistant', HEALTH_REDIRECT_COPY));
+ }
+ initialMessages.push(
+ buildHealthMessage(
+ 'assistant',
+ '你有未读健康提醒。请先阅读上方提醒并点击「我知道了」，确认后才会显示功能菜单。',
+ ),
+ );
+ appendMessages(initialMessages);
+ return;
+ }
+
+ const enterResult = applyHealthChannelTurn({
+ channel: 'h5',
+ session: null,
+ text: '',
+ forceEnter: true,
+ });
+
+ let welcome = enterResult.reply ?? HEALTH_MENU_TEXT;
+ if (showRedirect) {
+ welcome = `${HEALTH_REDIRECT_COPY}\n\n${welcome}`;
+ }
+
+ sessionRef.current = (enterResult.session as HealthSessionWrapper | null) ?? null;
+
+ const initialMessages: Message[] = [];
+ if (userText?.trim()) {
+ initialMessages.push(buildHealthMessage('user', userText, messageId));
+ }
+ initialMessages.push(buildHealthMessage('assistant', welcome));
+ appendMessages(initialMessages);
+
+ const seed = seedText?.trim();
+ if (!seed) return;
+
+ const turnResult = applyHealthChannelTurn({
+ channel: 'h5',
+ session: sessionRef.current,
+ text: seed,
+ });
+ if (!turnResult.handled) return;
+
+ if (!showRedirect) {
+ appendMessages([buildHealthMessage('user', seed)]);
+ }
+ appendMessages([buildHealthMessage('assistant', turnResult.reply ?? '')]);
+ await finalizeTurn(turnResult);
+ },
+ [appendMessages, enabled, finalizeTurn, newSession],
+ );
+
+ const handleChannelSubmit = useCallback(
+ async (
+ text: string,
+ options?: {
+ messageId?: string;
+ msgType?: string;
+ hasImages?: boolean;
+ imageUrls?: string[];
+ },
+ ) => {
+ if (!enabled) return false;
+
+ const trimmed = text.trim();
+ const imageUrls = options?.imageUrls ?? [];
+ const hasImages = Boolean(options?.hasImages && imageUrls.length > 0);
+ const msgType = hasImages && !trimmed ? 'image' : options?.msgType ?? 'text';
+ const displayText = trimmed || (hasImages ? '(图片)' : '');
+
+ if (!active) {
+ if (isHealthEnterText(trimmed)) {
+ await enterChannel({ userText: trimmed, messageId: options?.messageId });
+ return true;
+ }
+ if (shouldRedirectOrdinaryChatToHealth(trimmed)) {
+ await enterChannel({
+ userText: trimmed,
+ messageId: options?.messageId,
+ seedText: trimmed,
+ showRedirect: true,
+ });
+ return true;
+ }
+ return false;
+ }
+
+ if (!alertsGateOpen) {
+ if (displayText) {
+ appendMessages([buildHealthMessage('user', displayText, options?.messageId)]);
+ }
+ if (isHealthAlertsAckText(trimmed)) {
+ await acknowledgeAllAlerts();
+ return true;
+ }
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ '请先阅读上方提醒并点击「我知道了」，或回复「知道了」确认已读。',
+ ),
+ ]);
+ return true;
+ }
+
+ if (hasImages && imageUrls[0]) {
+ appendMessages([
+ buildHealthMessage('user', displayText, options?.messageId),
+ ]);
+
+ if (isDocumentUploadMode(sessionRef.current)) {
+ appendMessages([buildHealthMessage('assistant', '正在归档报告…')]);
+ try {
+ const archiveResult = await archiveHealthDocument({ imageUrl: imageUrls[0] });
+ const ocr = archiveResult?.ocr as { title?: string; extractedMetrics?: Array<{ name: string; value: string }> } | null;
+ sessionRef.current = {
+ channelState: {
+ sessionKind: 'health',
+ channel: 'h5',
+ step: 'idle',
+ action: null,
+ metricSet: null,
+ context: null,
+ pendingDraftId: null,
+ lastPrompt: null,
+ },
+ pendingValues: null,
+ };
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ ocr?.extractedMetrics?.length
+ ? `报告已归档。OCR 提取到 ${ocr.extractedMetrics.length} 项指标（${ocr.title ?? '报告'}），关键数值仍需你确认后才会写入基线。回复「1」手输录入，或「0」退出。`
+ : '报告已归档到健康档案。若有关键数值，请回复「1」手输录入确认。回复「0」退出通道。',
+ ),
+ ]);
+ } catch (error) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ error instanceof Error ? error.message : '报告归档失败，请稍后重试。',
+ ),
+ ]);
+ }
+ return true;
+ }
+
+ appendMessages([buildHealthMessage('assistant', '正在识别图片读数…')]);
+ try {
+ const response = await extractHealthImage({
+ imageUrl: imageUrls[0],
+ metricSet: channelMetricHint(sessionRef.current),
+ });
+ sourceRefRef.current = typeof response?.sourceRef === 'string' ? response.sourceRef : null;
+ draftKeyRef.current = typeof response?.draftKey === 'string' ? response.draftKey : null;
+ const extraction = response?.extraction;
+ const turnText = extraction?.ok ? extractionToTurnText(extraction) : '';
+ if (!turnText) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ '未能从图片识别可靠读数。请先回复「1」选择录入类型，或手输数值（如 137/82）。',
+ ),
+ ]);
+ return true;
+ }
+ const turnResult = applyHealthChannelTurn({
+ channel: 'h5',
+ session: sessionRef.current,
+ text: turnText,
+ msgType: 'text',
+ });
+ if (!turnResult.handled) {
+ appendMessages([
+ buildHealthMessage('assistant', '识别完成，但当前步骤无法录入。请按菜单选择后再发送图片。'),
+ ]);
+ return true;
+ }
+ appendMessages([buildHealthMessage('assistant', turnResult.reply ?? '')]);
+ await finalizeTurn(turnResult);
+ return true;
+ } catch (error) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ error instanceof Error ? error.message : '图片识别失败，请手输数值（如 137/82）。',
+ ),
+ ]);
+ return true;
+ }
+ }
+
+ if (
+ trimmed
+ && channelStateStep(sessionRef.current) === 'idle'
+ && isHealthEnterText(trimmed)
+ ) {
+ appendMessages([
+ buildHealthMessage('user', displayText, options?.messageId),
+ buildHealthMessage('assistant', HEALTH_MENU_TEXT),
+ ]);
+ return true;
+ }
+
+ if (
+ trimmed
+ && channelStateStep(sessionRef.current) === 'idle'
+ && looksLikeHealthQuickAssess(trimmed)
+ && !looksLikeHealthReportPageRequest(trimmed)
+ ) {
+ appendMessages([buildHealthMessage('user', displayText, options?.messageId)]);
+ try {
+ const summary = await fetchHealthAssessSummary();
+ appendMessages([buildHealthMessage('assistant', summary)]);
+ } catch (error) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ error instanceof Error ? error.message : '暂时无法生成健康评估，请稍后重试。',
+ ),
+ ]);
+ }
+ return true;
+ }
+
+ if (
+ trimmed
+ && channelStateStep(sessionRef.current) === 'idle'
+ && looksLikeHealthReportPageRequest(trimmed)
+ ) {
+ appendMessages([buildHealthMessage('user', displayText, options?.messageId)]);
+ try {
+ const report = await createHealthReportPage();
+ const lines = [
+ report.summary || '已基于你的健康档案生成报告页。',
+ report.url ? `报告页（已落盘）：${report.url}` : '',
+ '如需进一步解读，可继续提问；回复「1」录入，「0」退出。',
+ ].filter(Boolean);
+ appendMessages([buildHealthMessage('assistant', lines.join('\n\n'))]);
+ } catch (error) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ error instanceof Error
+ ? `${error.message}\n\n可先回复「1」录入数据，或稍后再试。`
+ : '暂时无法生成报告页，请稍后重试。',
+ ),
+ ]);
+ }
+ return true;
+ }
+
+ if (trimmed === '4' && channelStateStep(sessionRef.current) === 'idle') {
+ appendMessages([buildHealthMessage('user', displayText, options?.messageId)]);
+ setShowTimeline(true);
+ try {
+ const timeline = await fetchHealthTimeline(14);
+ appendMessages([
+ buildHealthMessage('assistant', formatTimelineChatSummary(timeline)),
+ ]);
+ } catch (error) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ error instanceof Error
+ ? `${error.message}\n\n完整档案请打开：/space?category=health\n回复「1」继续录入。`
+ : '已展开近 14 天健康 Timeline。完整档案请打开：/space?category=health\n回复「1」继续录入。',
+ ),
+ ]);
+ }
+ return true;
+ }
+
+ if (trimmed === '3' && channelStateStep(sessionRef.current) === 'idle') {
+ appendMessages([buildHealthMessage('user', displayText, options?.messageId)]);
+ try {
+ const summary = await fetchHealthAssessSummary();
+ appendMessages([buildHealthMessage('assistant', summary)]);
+ } catch (error) {
+ appendMessages([
+ buildHealthMessage(
+ 'assistant',
+ error instanceof Error ? error.message : '暂时无法生成健康评估，请稍后重试。',
+ ),
+ ]);
+ }
+ return true;
+ }
+
+ const turnResult = applyHealthChannelTurn({
+ channel: 'h5',
+ session: sessionRef.current,
+ text: trimmed,
+ msgType,
+ });
+ if (!turnResult.handled) return false;
+
+ appendMessages([
+ buildHealthMessage('user', displayText, options?.messageId),
+ buildHealthMessage('assistant', turnResult.reply ?? ''),
+ ]);
+ await finalizeTurn(turnResult);
+ return true;
+ },
+ [active, alertsGateOpen, acknowledgeAllAlerts, appendMessages, enabled, enterChannel, finalizeTurn],
+ );
+
+ const exitChannel = useCallback(() => {
+ appendMessages([
+ buildHealthMessage('assistant', '已退出健康通道。之后的消息会回到普通聊天。'),
+ ]);
+ deactivateChannel();
+ }, [appendMessages, deactivateChannel]);
+
+ return {
+ active,
+ showTimeline,
+ setShowTimeline,
+ overlayMessages,
+ unreadAlerts,
+ alertsGateOpen,
+ acknowledgingAlerts,
+ acknowledgeAllAlerts,
+ enterChannel,
+ exitChannel,
+ handleChannelSubmit,
+ };
+}
diff --git a/src/index.css b/src/index.css
index 816b537..e047c48 100644
--- a/src/index.css
+++ b/src/index.css
@@ -1081,6 +1081,19 @@ body,
justify-content: flex-end;
}
+.health-channel-banner {
+ display: flex;
+ align-items: center;
+ justify-content: space-between;
+ gap: 12px;
+}
+
+.health-channel-banner-body {
+ display: flex;
+ flex-direction: column;
+ gap: 4px;
+}
+
.health-page {
max-width: 720px;
margin: 0 auto;
@@ -1135,6 +1148,175 @@ body,
list-style: none;
}
+.health-timeline-panel {
+ margin: 0 0 12px;
+ padding: 12px 14px;
+ border-radius: var(--radius-md);
+ background: var(--color-bg-elevated);
+ border: 1px solid var(--color-border);
+ color: var(--color-text-primary);
+}
+
+.health-timeline-panel-header {
+ display: flex;
+ align-items: center;
+ justify-content: space-between;
+ gap: 8px;
+ margin-bottom: 8px;
+}
+
+.health-timeline-date {
+ font-weight: 600;
+ font-size: 13px;
+ margin-bottom: 4px;
+}
+
+.health-mindspace-panel {
+ margin-bottom: 16px;
+ padding: 14px 16px;
+ border-radius: var(--radius-md);
+ background: rgba(16, 185, 129, 0.06);
+ border: 1px solid rgba(16, 185, 129, 0.18);
+}
+
+.health-mindspace-panel-header {
+ display: flex;
+ align-items: center;
+ justify-content: space-between;
+ gap: 8px;
+ margin-bottom: 10px;
+}
+
+.health-mindspace-badge {
+ font-size: 12px;
+ color: #047857;
+ background: rgba(16, 185, 129, 0.12);
+ padding: 2px 8px;
+ border-radius: 999px;
+}
+
+.health-mindspace-stat {
+ margin: 0 0 8px;
+ font-size: 14px;
+}
+
+.health-mindspace-stats {
+ display: flex;
+ flex-wrap: wrap;
+ gap: 10px 16px;
+ margin: 0 0 12px;
+ font-size: 13px;
+ color: var(--color-text-secondary);
+}
+
+.health-mindspace-open-page {
+ margin: 0 0 12px;
+}
+
+.health-mindspace-assess,
+.health-mindspace-documents {
+ margin-top: 12px;
+}
+
+.health-mindspace-document-list {
+ margin: 8px 0 0;
+ padding-left: 18px;
+ font-size: 13px;
+ color: var(--color-text-secondary);
+}
+
+.health-mindspace-preview {
+ margin: 0 0 10px;
+ padding: 10px 12px;
+ border-radius: var(--radius-sm);
+ background: rgba(255, 255, 255, 0.65);
+ font-size: 12px;
+ line-height: 1.5;
+ white-space: pre-wrap;
+ overflow: auto;
+}
+
+.health-mindspace-tips {
+ margin: 0;
+ padding-left: 18px;
+ font-size: 13px;
+ color: var(--color-text-secondary);
+}
+
+.health-alerts-panel {
+ margin: 0 0 12px;
+ padding: 14px 16px;
+ border-radius: var(--radius-md);
+ border: 1px solid var(--color-border-warning);
+ background: var(--color-bg-warning);
+ color: var(--color-text-primary);
+}
+
+.health-alerts-panel-header {
+ display: flex;
+ align-items: center;
+ justify-content: space-between;
+ gap: 8px;
+ margin-bottom: 8px;
+}
+
+.health-alerts-badge {
+ font-size: 12px;
+ padding: 2px 8px;
+ border-radius: 999px;
+ background: rgba(245, 158, 11, 0.18);
+}
+
+.health-alerts-hint {
+ margin: 0 0 10px;
+ font-size: 13px;
+ color: var(--color-text-secondary);
+ line-height: 1.5;
+}
+
+.health-alerts-list {
+ margin: 0 0 12px;
+ padding-left: 0;
+ list-style: none;
+ display: flex;
+ flex-direction: column;
+ gap: 8px;
+}
+
+.health-alerts-list li {
+ display: flex;
+ gap: 8px;
+ align-items: flex-start;
+ font-size: 13px;
+ line-height: 1.45;
+}
+
+.health-alert-severity {
+ flex: 0 0 auto;
+ font-size: 11px;
+ font-weight: 600;
+ padding: 2px 6px;
+ border-radius: var(--radius-sm);
+}
+
+.health-alert-critical .health-alert-severity {
+ background: rgba(239, 68, 68, 0.15);
+ color: #b91c1c;
+}
+
+.health-alert-watch .health-alert-severity {
+ background: rgba(245, 158, 11, 0.18);
+ color: #b45309;
+}
+
+.health-alerts-ack-btn {
+ width: 100%;
+}
+
+.mindspace-card-health {
+ border-color: rgba(16, 185, 129, 0.25);
+}
+
.text-error {
color: var(--color-text-error);
}
diff --git a/src/routes/MindSpaceRoute.tsx b/src/routes/MindSpaceRoute.tsx
index b5f0de9..d52146b 100644
--- a/src/routes/MindSpaceRoute.tsx
+++ b/src/routes/MindSpaceRoute.tsx
@@ -2,19 +2,25 @@ import { matchPath, useLocation, useNavigate, useSearchParams } from 'react-rout
import { MindSpaceView } from '../components/MindSpaceView';
import type { MindSpaceSaveCategory, PortalUser } from '../types';
-const CATEGORY_CODES = new Set(['draft', 'oa', 'private', 'public']);
+const CATEGORY_CODES = new Set(['draft', 'oa', 'private', 'public', 'health']);
-function parseCategory(value: string | null): MindSpaceSaveCategory | null {
- if (!value || !CATEGORY_CODES.has(value as MindSpaceSaveCategory)) return null;
+function parseCategory(value: string | null, healthEnabled = true): MindSpaceSaveCategory | 'health' | null {
+ if (!value) return null;
+ if (value === 'health') {
+ return healthEnabled ? 'health' : null;
+ }
+ if (!CATEGORY_CODES.has(value as MindSpaceSaveCategory)) return null;
return value as MindSpaceSaveCategory;
}
export function MindSpaceRoute({
user,
onLogout,
+ healthEnabled = true,
}: {
user: PortalUser;
onLogout: () => void;
+ healthEnabled?: boolean;
}) {
const navigate = useNavigate();
const location = useLocation();
@@ -22,11 +28,12 @@ export function MindSpaceRoute({
const pageMatch = matchPath('/space/page/:pageId', location.pathname);
const achievementsMatch = matchPath('/space/achievements', location.pathname);
const pageId = pageMatch?.params.pageId ?? null;
- const categoryCode = parseCategory(searchParams.get('category'));
+ const categoryCode = parseCategory(searchParams.get('category'), healthEnabled);
return (
+
+
+
+
+
+ 健康 Timeline 摘要
+
+
+
+ 本人健康 Timeline 摘要
+ 此页仅供口令/登录访问。数据来自你确认过的健康记录，不是医疗诊断。
+ 加载中…
+
+
+
+
diff --git a/user-auth.mjs b/user-auth.mjs
index 57b7d37..0d6568e 100644
--- a/user-auth.mjs
+++ b/user-auth.mjs
@@ -55,6 +55,7 @@ import {
resolveSkillMap,
syncSkillsToWorkspace,
} from './skills-registry.mjs';
+import { HEALTH_ASSISTANT_SKILL_NAME, isMemindHealthEnabled } from './health-feature.mjs';
import { initializeDefaultSpace } from './mindspace.mjs';
export const USER_COOKIE = 'tkmind_user_session';
@@ -311,12 +312,18 @@ export function createUserAuth(pool, options = {}) {
};
const resolveUserSkillMap = async (user) => {
+ let skillMap;
if (!user || user.role === 'admin') {
- return Object.fromEntries(skillCatalog.map((item) => [item.name, true]));
+ skillMap = Object.fromEntries(skillCatalog.map((item) => [item.name, true]));
+ } else {
+ const roleDefaults = await listSkillGrants('role', 'user');
+ const userOverrides = await listSkillGrants('user', user.id);
+ skillMap = resolveSkillMap(roleDefaults, userOverrides, skillCatalog);
}
- const roleDefaults = await listSkillGrants('role', 'user');
- const userOverrides = await listSkillGrants('user', user.id);
- return resolveSkillMap(roleDefaults, userOverrides, skillCatalog);
+ if (isMemindHealthEnabled()) {
+ skillMap[HEALTH_ASSISTANT_SKILL_NAME] = true;
+ }
+ return skillMap;
};
const syncUserSkillsForUser = async (user) => {
diff --git a/wechat-mp.mjs b/wechat-mp.mjs
index ed3ce37..1682cee 100644
--- a/wechat-mp.mjs
+++ b/wechat-mp.mjs
@@ -1673,6 +1673,9 @@ export function createWechatMpService({
logger = console,
healthChannelStore = null,
healthObservationStore = null,
+ healthObservationService = null,
+ healthDocumentStore = null,
+ healthEventStore = null,
env = process.env,
}) {
const resolvedHealthChannelStore =
@@ -4167,7 +4170,9 @@ export function createWechatMpService({
intent,
inbound,
store: resolvedHealthChannelStore,
- observationStore: healthObservationStore,
+ observationService: healthObservationService ?? null,
+ documentStore: healthDocumentStore ?? null,
+ eventStore: healthEventStore ?? null,
}).catch((err) => {
logger.warn?.(
'WeChat MP health channel failed open:',
diff --git a/wechat/handlers/health.mjs b/wechat/handlers/health.mjs
index c7db4bb..04eb25a 100644
--- a/wechat/handlers/health.mjs
+++ b/wechat/handlers/health.mjs
@@ -1,5 +1,7 @@
import { isMemindHealthEnabled } from '../../health-feature.mjs';
import { applyHealthWechatTurn } from '../../health-wechat-turn.mjs';
+import { formatHealthAlertsPreamble, isHealthAlertsAckText } from '../../health-event-notification.mjs';
+import { parseHealthAssetIdFromUrl } from '../../health-document-store.mjs';
export async function handleWechatHealthChannel({
enabled = isMemindHealthEnabled(),
@@ -7,7 +9,9 @@ export async function handleWechatHealthChannel({
intent,
inbound,
store,
- observationStore = null,
+ observationService = null,
+ documentStore = null,
+ eventStore = null,
now = Date.now(),
} = {}) {
if (!enabled || !userId || !store) return null;
@@ -17,6 +21,11 @@ export async function handleWechatHealthChannel({
const text = String(intent?.agentText ?? intent?.displayText ?? '').trim();
const eventKey = String(inbound?.eventKey ?? '').trim();
const msgType = String(intent?.msgType ?? inbound?.msgType ?? 'text').toLowerCase();
+ const imageUrl = String(intent?.media?.publicUrl ?? intent?.imageUrl ?? '').trim();
+
+ if (session && isHealthAlertsAckText(text) && eventStore?.acknowledgeAll) {
+ await eventStore.acknowledgeAll(userId).catch(() => 0);
+ }
const result = applyHealthWechatTurn({
session,
@@ -33,30 +42,32 @@ export async function handleWechatHealthChannel({
store.clear(userId);
}
- if (result.commit && observationStore) {
- const values = result.commit.values;
- const observedAt = values.observedAt ?? now;
- await observationStore.insert(userId, {
- confirmed: true,
- observedAt,
- metricType: 'bp_systolic',
- valueNum: values.systolic,
- unit: 'mmHg',
- context: values.context,
- source: 'wechat',
- qualityFlag: 'ok',
- });
- await observationStore.insert(userId, {
- confirmed: true,
- observedAt,
- metricType: 'bp_diastolic',
- valueNum: values.diastolic,
- unit: 'mmHg',
- context: values.context,
- source: 'wechat',
- qualityFlag: 'ok',
- });
+ if (result.commit?.type === 'document' && documentStore) {
+ if (imageUrl) {
+ await documentStore.insert(userId, {
+ confirmed: true,
+ imageUrl,
+ assetId: parseHealthAssetIdFromUrl(imageUrl),
+ source: 'wechat',
+ });
+ }
+ } else if (result.commit && observationService) {
+ await observationService.commitFromPending(
+ userId,
+ result.commit.values ?? result.commit,
+ result.commit.source ?? 'wechat',
+ );
}
- return result.reply;
+ let reply = result.reply;
+ const entered = !session && result.session;
+ if (entered && eventStore?.listUnreadAlerts) {
+ const alerts = await eventStore.listUnreadAlerts(userId, { limit: 10 }).catch(() => []);
+ const preamble = formatHealthAlertsPreamble(alerts);
+ if (preamble) {
+ reply = `${preamble}\n\n${reply ?? ''}`.trim();
+ }
+ }
+
+ return reply;
}