Merge pull request #4 from Sanotsu/ai_tools_new_design

全面简化了“AI智能助手模块”

Author: Sanotsu

.gitignore

@@ -157,3 +157,4 @@ linux
 **/*bak*
 **/*demo*
 **/*bugreport*
+.aider*

CHANGELOG.md

@@ -2,6 +2,33 @@
 
 一些较大变更、新功能、bug 修复等记录放在此处，仅做参看的提交更新.
 
+## 0.4.0-beta.1
+
+- refactor:
+  - 重构了主页和“AI 智能助手”模块，尽量简洁化:
+    - 进入 App 首页即“助手”模块，可以选择不同平台的模型进行对话
+    - 原本“AI 智能助手”模块中工具，简化为“AI 助手”、“AI 绘图”、“AI 视频”。
+  - 大模型 API 调用**只保留兼容 openAI API 结构的**平台和模型，不再兼容其他平台自定义 API 结构。
+    - 涉及到阿里云、腾讯等平台，API 升级到 V2；移除了讯飞的大模型、阿里云的创意文字锦书模型。
+  - 支持的平台和大模型 API 不在追求多，更加选择能用和代码编写兼容好：
+    - 对话模型继续保留
+      - [百度](https://cloud.baidu.com/doc/WENXINWORKSHOP/s/Fm2vrveyu)
+      - [阿里](https://help.aliyun.com/zh/model-studio/developer-reference/compatibility-of-openai-with-dashscope)
+      - [腾讯](https://console.cloud.tencent.com/hunyuan/start)
+      - [智谱](https://open.bigmodel.cn/dev/api/normal-model/glm-4)
+      - [零一万物](https://platform.lingyiwanwu.com/docs/api-reference)
+      - [无问芯穹](https://docs.infini-ai.com/gen-studio/api/maas.html#/operations/chatCompletions)
+      - [硅基流动](https://docs.siliconflow.cn/cn/api-reference/chat-completions/chat-completions)
+    - 图片生成只保留了：
+      - 阿里云:[图像生成-通义万相 文生图 V2 版](https://help.aliyun.com/zh/model-studio/developer-reference/text-to-image-v2-api-reference)、[文生图 FLUX](https://help.aliyun.com/zh/model-studio/developer-reference/flux/)
+      - 智谱 AI: [CogView](https://open.bigmodel.cn/dev/api/image-model/cogview)
+      - 硅基流动: [创建图片生成请求](https://docs.siliconflow.cn/cn/api-reference/images/images-generations)
+    - 视频生成只保留了：
+      - 阿里云: [视频生成-通义万相](https://help.aliyun.com/zh/model-studio/developer-reference/video-generation-wanx/)
+      - 智谱 AI: [CogVideoX](https://open.bigmodel.cn/dev/api/videomodel/cogvideox)
+      - 硅基流动: [创建视频生成请求](https://docs.siliconflow.cn/cn/api-reference/videos/videos_submit)
+    - DeepSeek 官方平台暂时不能充值，可以使用其他平台部署的，比如硅基流动。
+
 ## 0.3.0-beta.1
 
 - chore:

README.md

@@ -0,0 +1,91 @@
+import 'dart:async';
+
+import '../../common/utils/tools.dart';
+
+///
+/// dio 中处理SSE的解析器
+/// 来源: https://github.com/cfug/dio/issues/1279#issuecomment-1326121953
+///
+class SseTransformer extends StreamTransformerBase<String, SseMessage> {
+  const SseTransformer();
+  @override
+  Stream<SseMessage> bind(Stream<String> stream) {
+    return Stream.eventTransformed(stream, (sink) => SseEventSink(sink));
+  }
+}
+
+class SseEventSink implements EventSink<String> {
+  final EventSink<SseMessage> _eventSink;
+
+  String? _id;
+  String _event = "message";
+  String _data = "";
+  int? _retry;
+
+  SseEventSink(this._eventSink);
+
+  @override
+  void add(String event) {
+    if (event.startsWith("id:")) {
+      _id = event.substring(3);
+      return;
+    }
+    if (event.startsWith("event:")) {
+      _event = event.substring(6);
+      return;
+    }
+    if (event.startsWith("data:")) {
+      _data = event.substring(5);
+      return;
+    }
+    if (event.startsWith("retry:")) {
+      _retry = int.tryParse(event.substring(6));
+      return;
+    }
+    if (event.isEmpty) {
+      _eventSink.add(
+        SseMessage(id: _id, event: _event, data: _data, retry: _retry),
+      );
+      _id = null;
+      _event = "message";
+      _data = "";
+      _retry = null;
+    }
+
+    // 自己加的，请求报错时不是一个正常的流的结构，是个json,直接添加即可
+    if (isJsonString(event)) {
+      _eventSink.add(
+        SseMessage(id: _id, event: _event, data: event, retry: _retry),
+      );
+
+      _id = null;
+      _event = "message";
+      _data = "";
+      _retry = null;
+    }
+  }
+
+  @override
+  void addError(Object error, [StackTrace? stackTrace]) {
+    _eventSink.addError(error, stackTrace);
+  }
+
+  @override
+  void close() {
+    _eventSink.close();
+  }
+}
+
+class SseMessage {
+  final String? id;
+  final String event;
+  final String data;
+  final int? retry;
+
+  const SseMessage({
+    this.id,
+    required this.event,
+    required this.data,
+    this.retry,
+  });
+}

_doc/screenshots/brief_version/助手工具.jpg

@@ -5,8 +5,7 @@ import 'dart:typed_data';
 import 'package:dio/dio.dart';
 import 'package:proste_logger/proste_logger.dart';
 
-import '../../common/utils/db_tools/db_helper.dart';
-import '../../common/utils/tools.dart';
+import '../../common/utils/db_tools/db_ai_tool_helper.dart';
 import '../../models/chat_competion/com_cc_req.dart';
 import '../../models/chat_competion/com_cc_resp.dart';
 import '../../common/llm_spec/cus_llm_spec.dart';
@@ -18,9 +17,10 @@ import '../gen_access_token/tencent_signature_v3.dart';
 import '../gen_access_token/zhipu_signature.dart';
 import '../get_app_key_helper.dart';
 import '../platform_keys.dart';
+import 'chat_helper.dart';
 
 final l = ProsteLogger();
-final DBHelper _dbHelper = DBHelper();
+final DBAIToolHelper _dbHelper = DBAIToolHelper();
 
 enum PlatUrl {
   tencentCCUrl,
@@ -56,94 +56,6 @@ const Map<PlatUrl, String> platUrls = {
 String infiniCCUrl(String model) =>
     "https://cloud.infini-ai.com/maas/$model/nvidia/chat/completions";
 
-///
-/// dio 中处理SSE的解析器
-/// 来源: https://github.com/cfug/dio/issues/1279#issuecomment-1326121953
-///
-class SseTransformer extends StreamTransformerBase<String, SseMessage> {
-  const SseTransformer();
-  @override
-  Stream<SseMessage> bind(Stream<String> stream) {
-    return Stream.eventTransformed(stream, (sink) => SseEventSink(sink));
-  }
-}
-
-class SseEventSink implements EventSink<String> {
-  final EventSink<SseMessage> _eventSink;
-
-  String? _id;
-  String _event = "message";
-  String _data = "";
-  int? _retry;
-
-  SseEventSink(this._eventSink);
-
-  @override
-  void add(String event) {
-    if (event.startsWith("id:")) {
-      _id = event.substring(3);
-      return;
-    }
-    if (event.startsWith("event:")) {
-      _event = event.substring(6);
-      return;
-    }
-    if (event.startsWith("data:")) {
-      _data = event.substring(5);
-      return;
-    }
-    if (event.startsWith("retry:")) {
-      _retry = int.tryParse(event.substring(6));
-      return;
-    }
-    if (event.isEmpty) {
-      _eventSink.add(
-        SseMessage(id: _id, event: _event, data: _data, retry: _retry),
-      );
-      _id = null;
-      _event = "message";
-      _data = "";
-      _retry = null;
-    }
-
-    // 自己加的，请求报错时不是一个正常的流的结构，是个json,直接添加即可
-    if (isJsonString(event)) {
-      _eventSink.add(
-        SseMessage(id: _id, event: _event, data: event, retry: _retry),
-      );
-
-      _id = null;
-      _event = "message";
-      _data = "";
-      _retry = null;
-    }
-  }
-
-  @override
-  void addError(Object error, [StackTrace? stackTrace]) {
-    _eventSink.addError(error, stackTrace);
-  }
-
-  @override
-  void close() {
-    _eventSink.close();
-  }
-}
-
-class SseMessage {
-  final String? id;
-  final String event;
-  final String data;
-  final int? retry;
-
-  const SseMessage({
-    this.id,
-    required this.event,
-    required this.data,
-    this.retry,
-  });
-}
-
 ///
 ///===========可以取消流的写法
 ///
@@ -275,8 +187,11 @@ Future<StreamWithCancel<ComCCResp>> getSseCcResponse(
     final streamController = StreamController<ComCCResp>();
     streamController.add(
       ComCCResp(
-        cusText:
-            "HTTP请求响应异常:\n\n错误代码: ${e.cusCode}\n\n错误信息: ${e.cusMsg}\n\n\n\n原始信息: ${e.errRespString}",
+        cusText: """HTTP请求响应异常:\n\n错误代码: ${e.cusCode}
+            \n\n错误信息: ${e.cusMsg}
+            \n\n错误原文: ${e.errMessage}
+            \n\n原始信息: ${e.errRespString}
+            \n\n""",
       ),
     );
     streamController.add(ComCCResp(cusText: '[DONE]-后台响应错误'));