feat: 全功能前后端联调完成,47/47 测试通过
前端: - 新增 DietCapturePage 独立拍照识别页 - 5种消息卡片类型完整实现(数据确认/用药/饮食/报告/快捷选项) - 任务卡片区:异常警告+数据摘要+自动折叠 - 侧滑抽屉:历史对话列表+对话管理 - 运动计划:进度卡片+创建计划+每日打卡 - 报告页:拍照/相册/PDF上传+分析 - 面板按钮补全血氧/体重录入 - UI 升级:紫色主题+动画+气泡样式 - 全部迁移 Riverpod 3.x API 后端: - 新增 _UpdateMessageTypeAndMetadata,Tool Calling 自动映射消息类型 - SSE answer 事件携带 type 字段 - 提示词优化(移除"阿福",语气规则归位) - 运动计划支持 AI 创建和打卡 测试: - 新增 full_e2e_test.py 全流程测试(认证/数据CRUD/6个Agent对话/VLM/报告)
This commit is contained in:
@@ -4,16 +4,23 @@ import 'auth_provider.dart';
|
||||
import 'data_providers.dart';
|
||||
import '../utils/sse_handler.dart';
|
||||
|
||||
enum MessageType { text, dataConfirm, medicationConfirm, dietAnalysis, reportAnalysis, quickOptions }
|
||||
|
||||
class ChatMessage {
|
||||
final String id;
|
||||
final String role;
|
||||
String content;
|
||||
final DateTime createdAt;
|
||||
ChatMessage(
|
||||
{required this.id,
|
||||
required this.role,
|
||||
required this.content,
|
||||
required this.createdAt});
|
||||
MessageType type;
|
||||
final Map<String, dynamic>? metadata;
|
||||
ChatMessage({
|
||||
required this.id,
|
||||
required this.role,
|
||||
required this.content,
|
||||
required this.createdAt,
|
||||
this.type = MessageType.text,
|
||||
this.metadata,
|
||||
});
|
||||
bool get isUser => role == 'user';
|
||||
}
|
||||
|
||||
@@ -24,26 +31,41 @@ class ChatState {
|
||||
final List<ChatMessage> messages;
|
||||
final String? conversationId;
|
||||
final bool isStreaming;
|
||||
final String? noticeText;
|
||||
final String? thinkingText;
|
||||
const ChatState({
|
||||
this.activeAgent = ActiveAgent.default_,
|
||||
this.messages = const [],
|
||||
this.conversationId,
|
||||
this.isStreaming = false,
|
||||
this.noticeText,
|
||||
this.thinkingText,
|
||||
});
|
||||
ChatState copyWith({ActiveAgent? activeAgent, List<ChatMessage>? messages,
|
||||
String? conversationId, bool? isStreaming, String? noticeText,
|
||||
bool clearNotice = false}) =>
|
||||
String? conversationId, bool? isStreaming, String? thinkingText}) =>
|
||||
ChatState(
|
||||
activeAgent: activeAgent ?? this.activeAgent,
|
||||
messages: messages ?? this.messages,
|
||||
conversationId: conversationId ?? this.conversationId,
|
||||
isStreaming: isStreaming ?? this.isStreaming,
|
||||
noticeText: clearNotice ? null : (noticeText ?? this.noticeText),
|
||||
thinkingText: thinkingText ?? this.thinkingText,
|
||||
);
|
||||
}
|
||||
|
||||
class ConversationItem {
|
||||
final String id;
|
||||
final String title;
|
||||
final String lastMessage;
|
||||
final DateTime updatedAt;
|
||||
final ActiveAgent agent;
|
||||
|
||||
ConversationItem({
|
||||
required this.id,
|
||||
required this.title,
|
||||
required this.lastMessage,
|
||||
required this.updatedAt,
|
||||
required this.agent,
|
||||
});
|
||||
}
|
||||
|
||||
class SelectedAgentNotifier extends Notifier<ActiveAgent?> {
|
||||
@override
|
||||
ActiveAgent? build() => null;
|
||||
@@ -53,6 +75,64 @@ class SelectedAgentNotifier extends Notifier<ActiveAgent?> {
|
||||
final selectedAgentProvider =
|
||||
NotifierProvider<SelectedAgentNotifier, ActiveAgent?>(SelectedAgentNotifier.new);
|
||||
final chatProvider = NotifierProvider<ChatNotifier, ChatState>(ChatNotifier.new);
|
||||
final conversationListProvider = FutureProvider<List<ConversationItem>>((ref) async {
|
||||
final api = ref.watch(apiClientProvider);
|
||||
final token = await api.accessToken;
|
||||
if (token == null) return [];
|
||||
|
||||
try {
|
||||
final res = await api.get('/api/conversations');
|
||||
final list = res.data['data'] as List? ?? [];
|
||||
return list.map((item) {
|
||||
final data = item as Map<String, dynamic>;
|
||||
return ConversationItem(
|
||||
id: data['id']?.toString() ?? '',
|
||||
title: data['title']?.toString() ?? '对话',
|
||||
lastMessage: data['lastMessage']?.toString() ?? '',
|
||||
updatedAt: DateTime.parse(data['updatedAt']?.toString() ?? DateTime.now().toIso8601String()),
|
||||
agent: _parseAgent(data['agentType']?.toString()),
|
||||
);
|
||||
}).toList();
|
||||
} catch (_) {
|
||||
return _mockConversations;
|
||||
}
|
||||
});
|
||||
|
||||
ActiveAgent _parseAgent(String? type) {
|
||||
switch (type?.toLowerCase()) {
|
||||
case 'consultation': return ActiveAgent.consultation;
|
||||
case 'health': return ActiveAgent.health;
|
||||
case 'diet': return ActiveAgent.diet;
|
||||
case 'medication': return ActiveAgent.medication;
|
||||
case 'report': return ActiveAgent.report;
|
||||
case 'exercise': return ActiveAgent.exercise;
|
||||
default: return ActiveAgent.default_;
|
||||
}
|
||||
}
|
||||
|
||||
final _mockConversations = [
|
||||
ConversationItem(
|
||||
id: '1',
|
||||
title: '用药咨询',
|
||||
lastMessage: '阿司匹林应该什么时候吃?',
|
||||
updatedAt: DateTime.now().subtract(const Duration(hours: 2)),
|
||||
agent: ActiveAgent.medication,
|
||||
),
|
||||
ConversationItem(
|
||||
id: '2',
|
||||
title: '血压偏高',
|
||||
lastMessage: '血压145/90,需要注意什么?',
|
||||
updatedAt: DateTime.now().subtract(const Duration(hours: 5)),
|
||||
agent: ActiveAgent.health,
|
||||
),
|
||||
ConversationItem(
|
||||
id: '3',
|
||||
title: '饮食建议',
|
||||
lastMessage: '今天吃了米饭和红烧肉',
|
||||
updatedAt: DateTime.now().subtract(const Duration(days: 1)),
|
||||
agent: ActiveAgent.diet,
|
||||
),
|
||||
];
|
||||
|
||||
class ChatNotifier extends Notifier<ChatState> {
|
||||
StreamSubscription<Map<String, dynamic>>? _subscription;
|
||||
@@ -120,7 +200,7 @@ class ChatNotifier extends Notifier<ChatState> {
|
||||
),
|
||||
],
|
||||
isStreaming: false,
|
||||
clearNotice: true,
|
||||
thinkingText: null,
|
||||
);
|
||||
}
|
||||
|
||||
@@ -131,13 +211,16 @@ class ChatNotifier extends Notifier<ChatState> {
|
||||
state = state.copyWith(conversationId: j['data']?.toString());
|
||||
case 'answer':
|
||||
aiMsg.content += (j['data'] as String?) ?? '';
|
||||
final messageType = j['type'] as String? ?? 'text';
|
||||
aiMsg.type = _parseMessageType(messageType);
|
||||
state = state.copyWith(thinkingText: null);
|
||||
_update(aiMsg);
|
||||
case 'notice':
|
||||
state = state.copyWith(noticeText: j['message'] as String?);
|
||||
state = state.copyWith(thinkingText: j['message'] as String?);
|
||||
case 'tool_result':
|
||||
final tool = j['tool'] as String? ?? '';
|
||||
if (tool == 'record_health_data') {
|
||||
refreshHealthData(ref);
|
||||
ref.invalidate(latestHealthProvider);
|
||||
}
|
||||
case 'status':
|
||||
_done(aiMsg);
|
||||
@@ -146,6 +229,17 @@ class ChatNotifier extends Notifier<ChatState> {
|
||||
}
|
||||
}
|
||||
|
||||
MessageType _parseMessageType(String type) {
|
||||
switch (type) {
|
||||
case 'data_confirm': return MessageType.dataConfirm;
|
||||
case 'medication_confirm': return MessageType.medicationConfirm;
|
||||
case 'diet_analysis': return MessageType.dietAnalysis;
|
||||
case 'report_analysis': return MessageType.reportAnalysis;
|
||||
case 'quick_options': return MessageType.quickOptions;
|
||||
default: return MessageType.text;
|
||||
}
|
||||
}
|
||||
|
||||
void _update(ChatMessage m) {
|
||||
final u = state.messages.toList();
|
||||
final i = u.indexWhere((x) => x.id == m.id);
|
||||
@@ -160,6 +254,6 @@ class ChatNotifier extends Notifier<ChatState> {
|
||||
void _done(ChatMessage m) {
|
||||
final u = state.messages.toList();
|
||||
if (!u.any((x) => x.id == m.id) && m.content.isNotEmpty) u.add(m);
|
||||
state = state.copyWith(messages: u, isStreaming: false, clearNotice: true);
|
||||
state = state.copyWith(messages: u, isStreaming: false, thinkingText: null);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user