Browse Source

修改askai

newdev_shunjiawei
tanlongsheng 1 year ago
parent
commit
6559b31a6f
  1. 50
      lib/data/services/deapsound_ai_service.dart
  2. 140
      lib/modules/meeting/views/ai_bottom_sheet.dart

50
lib/data/services/deapsound_ai_service.dart

@ -2,7 +2,6 @@ import 'dart:convert';
import 'package:http/http.dart' as http; import 'package:http/http.dart' as http;
import '../../core/utils/logger.dart';
import '../models/appconfig.dart'; import '../models/appconfig.dart';
import 'ai_service.dart'; import 'ai_service.dart';
@ -60,27 +59,18 @@ class DeapsoundAIService implements AiService {
String? userProperties, String? userProperties,
}) async* { }) async* {
final client = http.Client(); final client = http.Client();
final url = Uri.parse('https://api.deapsound.com/ai/funcchat'); final url = Uri.parse(baseUrl);
List contextsList = [];
String msg = '';
for (var i = 0; i < messages.length; i++) {
Map item = messages[i];
if (i < messages.length - 1) {
if (item['role'] == 'user') {
contextsList.add(item['content']);
}
} else {
msg = item['content'];
}
}
final headers = { final headers = {
'Content-Type': 'application/json', 'Content-Type': 'application/json',
'Authorization': apiKey, 'Authorization': 'Bearer $apiKey',
}; };
final requestBody = {"contexts": contextsList, "msg": msg}; final requestBody = {
"model": model,
"messages": messages,
"stream": true,
};
try { try {
final request = http.Request('POST', url) final request = http.Request('POST', url)
@ -88,7 +78,6 @@ class DeapsoundAIService implements AiService {
..body = jsonEncode(requestBody); ..body = jsonEncode(requestBody);
final response = await client.send(request); final response = await client.send(request);
//流式处理响应数据
await for (final chunk in response.stream await for (final chunk in response.stream
.transform(utf8.decoder) .transform(utf8.decoder)
.transform(const LineSplitter())) { .transform(const LineSplitter())) {
@ -96,28 +85,19 @@ class DeapsoundAIService implements AiService {
if (chunk.startsWith('data:')) { if (chunk.startsWith('data:')) {
final jsonStr = chunk.substring(5).trim(); final jsonStr = chunk.substring(5).trim();
if (jsonStr == '[DONE]') {
break;
}
try { final data = jsonDecode(jsonStr);
final data = jsonDecode(jsonStr); final content = data['choices'][0]['delta']['content'] ?? '';
if (data['role'] == 'card') { if (content.isNotEmpty) {
yield data['meta']; yield content;
if (data['meta']['musicaudio'] != null) {
break;
}
}
if (data['role'] == 'ai') {
String content = data['content'] ?? '';
if (content.isNotEmpty) {
yield content;
}
}
} catch (e) {
Logger.error('JSON解析错误: ${e.toString()}');
} }
} }
} }
} catch (e) { } catch (e) {
Logger.error('请求异常: ${e.toString()}'); throw Exception('Unknown error');
} finally { } finally {
client.close(); client.close();
} }

140
lib/modules/meeting/views/ai_bottom_sheet.dart

@ -1,8 +1,11 @@
import 'dart:async';
import 'package:flutter/material.dart'; import 'package:flutter/material.dart';
import 'package:flutter_markdown/flutter_markdown.dart'; import 'package:flutter_markdown/flutter_markdown.dart';
import 'package:flutter_screenutil/flutter_screenutil.dart'; import 'package:flutter_screenutil/flutter_screenutil.dart';
import 'package:get/get.dart'; import 'package:get/get.dart';
import '../../../data/services/deapsound_ai_service.dart';
import '../controllers/meeting_details_controller.dart'; import '../controllers/meeting_details_controller.dart';
class AIBottomSheet extends StatefulWidget { class AIBottomSheet extends StatefulWidget {
@ -14,6 +17,10 @@ class AIBottomSheet extends StatefulWidget {
class _AIBottomSheetState extends State<AIBottomSheet> { class _AIBottomSheetState extends State<AIBottomSheet> {
final _controller = Get.find<MeetingDetailsController>(); final _controller = Get.find<MeetingDetailsController>();
final ScrollController _scrollController = ScrollController();
final _deapsoundAI = DeapsoundAIService();
StreamSubscription? _aiResponseSubscription;
final TextEditingController _texController = TextEditingController(); final TextEditingController _texController = TextEditingController();
@ -30,6 +37,8 @@ class _AIBottomSheetState extends State<AIBottomSheet> {
@override @override
void dispose() { void dispose() {
_texController.dispose(); _texController.dispose();
_scrollController.dispose();
_aiResponseSubscription?.cancel();
super.dispose(); super.dispose();
} }
@ -80,12 +89,13 @@ class _AIBottomSheetState extends State<AIBottomSheet> {
? Align( ? Align(
alignment: Alignment.topCenter, alignment: Alignment.topCenter,
child: ListView.builder( child: ListView.builder(
controller: _scrollController,
itemCount: _dataList.length, itemCount: _dataList.length,
shrinkWrap: true, shrinkWrap: true,
reverse: true, reverse: true,
itemBuilder: (BuildContext context, int index) { itemBuilder: (BuildContext context, int index) {
Map data = _dataList[index]; Map data = _dataList[index];
return _item(data, index == 0); return _item(data);
}, },
), ),
) )
@ -97,47 +107,35 @@ class _AIBottomSheetState extends State<AIBottomSheet> {
); );
} }
Widget _item(Map data, bool isBorder) { Widget _item(Map data) {
return Container( return Column(
padding: EdgeInsets.symmetric(vertical: 20.w), children: [
decoration: BoxDecoration( Container(
border: isBorder padding: EdgeInsets.symmetric(vertical: 10.w),
? null alignment: Alignment.centerRight,
: Border( child: Container(
bottom: BorderSide( padding: EdgeInsets.all(10.w),
width: 1, decoration: BoxDecoration(
color: Colors.grey[400]!, color: Colors.grey[200],
), borderRadius: BorderRadius.circular(12.r),
), ),
), child: Text(
child: Column( data['user'],
children: [ style: TextStyle(
Align( fontSize: 14.sp,
alignment: Alignment.centerRight,
child: Container(
padding: EdgeInsets.all(10.w),
decoration: BoxDecoration(
color: Colors.grey[200],
borderRadius: BorderRadius.circular(12.r),
),
child: Text(
data['user'],
style: TextStyle(
fontSize: 14.sp,
),
), ),
), ),
), ),
if (data['assistant'].isNotEmpty) ),
Container( if (data['assistant'].isNotEmpty)
padding: EdgeInsets.symmetric(vertical: 20.w), Container(
alignment: Alignment.centerLeft, padding: EdgeInsets.symmetric(vertical: 10.w),
child: MarkdownBody( alignment: Alignment.centerLeft,
data: data['assistant'], child: MarkdownBody(
), data: data['assistant'],
), ),
], ),
), ],
); );
} }
@ -256,11 +254,11 @@ class _AIBottomSheetState extends State<AIBottomSheet> {
width: 26.w, width: 26.w,
height: 26.w, height: 26.w,
decoration: BoxDecoration( decoration: BoxDecoration(
color: Colors.grey, color: _isLoading ? Colors.black87 : Colors.grey,
borderRadius: BorderRadius.circular(26.r), borderRadius: BorderRadius.circular(26.r),
), ),
child: Icon( child: Icon(
Icons.arrow_upward, _isLoading ? Icons.pause : Icons.arrow_upward,
size: 18.w, size: 18.w,
color: Colors.white, color: Colors.white,
), ),
@ -273,47 +271,31 @@ class _AIBottomSheetState extends State<AIBottomSheet> {
void _sendMessage(String value) { void _sendMessage(String value) {
if (_isLoading || value.isEmpty) return; if (_isLoading || value.isEmpty) return;
setState(() {
_isLoading = true;
});
_dataList.insert(0, {
'user': value,
'assistant': '''
# 角色
你是一名卓越的会议记录专家,拥有超强的信息归纳与细分能力。不仅能高效处理各类通用场景会议,精准提炼会议核心内容,为后续思维导图生成奠定坚实基础,还能将整理好的会议记录巧妙转化为清晰直观的思维导图。
## 技能
### 技能 1: 通用会议内容深度细分
1. 深入全面剖析给定的通用场景会议内容,精准区分不同主题板块,如会议目标、讨论事项、决策结果、行动安排、问题与挑战等。
2. 对每个主题板块进行细致分解,形成具体要点与细节。若涉及人员,人员名称保留[],清晰明确其角色与贡献;涉及流程,梳理出关键步骤与节点。
3. 以层次分明、逻辑紧密的方式整理细分内容,使其契合思维导图的结构特点。
===回复示例===
- **会议目标**:
- 目标 1:[详细且全面阐述目标 1]
- 目标 2:[如有多个目标,依次详细罗列]
- **讨论事项**:
- 事项 1:
- 观点 1:[详细说明提出观点 1 的人员及具体内容]
- 观点 2:[详细阐述不同观点及相关人员]
- 事项 2:[按此格式详细罗列其他讨论事项]
- **决策结果**:
- 决策 1:[具体且完整表述决策内容]
- 决策 2:[详细列出其他决策]
- **行动安排**:
- 任务 1:
- 负责人:[具体姓名]
- 时间节点:[精确到具体时间]
- 任务内容:[详细描述任务具体内容]
- 任务 2:[依此格式详细罗列其他任务]
- **问题与挑战**:
- 问题 1:[具体清晰描述问题]
- 挑战 1:[详细说明面临的挑战及相关说明]
===示例结束===
''',
});
_texController.clear(); _texController.clear();
setState(() { setState(() {
_isLoading = false; _isLoading = true;
_dataList.insert(0, {
'user': value,
'assistant': '',
});
}); });
_scrollController.jumpTo(0);
final responseStream = _deapsoundAI.sendMessageStream(
messages: [
{'role': 'user', 'content': value},
],
);
_aiResponseSubscription = responseStream.listen(
(chunk) {
setState(() {
_dataList.first['assistant'] += chunk;
});
},
onDone: () {
setState(() {
_isLoading = false;
});
},
);
} }
} }

Loading…
Cancel
Save