第一次提交代码

.commitlintrc.cjs

@@ -22,46 +22,33 @@ module.exports = {
   ignores: [(commit) => commit.includes('init')],
   extends: ['@commitlint/config-conventional'],
   rules: {
-    // 'body-leading-blank': [2, 'always'],
+    'body-leading-blank': [2, 'always'],
-    // 'footer-leading-blank': [1, 'always'],
+    'footer-leading-blank': [1, 'always'],
-    // 'header-max-length': [2, 'always', 108],
+    'header-max-length': [2, 'always', 108],
-    // 'subject-empty': [2, 'never'],
+    'subject-empty': [2, 'never'],
-    // 'type-empty': [2, 'never'],
+    'type-empty': [2, 'never'],
-    // 'subject-case': [0],
+    'subject-case': [0],
-    // 'type-enum': [
-    //   2,
-    //   'always',
-    //   [
-    //     'feat',
-    //     'fix',
-    //     'perf',
-    //     'style',
-    //     'docs',
-    //     'test',
-    //     'refactor',
-    //     'build',
-    //     'ci',
-    //     'chore',
-    //     'revert',
-    //     'wip',
-    //     'workflow',
-    //     'types',
-    //     'release',
-    //   ],
-    // ],
     'type-enum': [
       2,
       'always',
-      ['upd', 'feat', 'fix', 'refactor', 'docs', 'chore', 'style', 'revert'],
+      [
+        'feat',
+        'fix',
+        'perf',
+        'style',
+        'docs',
+        'test',
+        'refactor',
+        'build',
+        'ci',
+        'chore',
+        'revert',
+        'wip',
+        'workflow',
+        'types',
+        'release',
+      ],
     ],
-    'type-case': [0],
-    'type-empty': [0],
-    'scope-empty': [0],
-    'scope-case': [0],
-    'subject-full-stop': [0],
-    'subject-empty': [0],
-    'subject-case': [0],
-    'header-max-length': [0],
   },
   prompt: {
     /** @use `pnpm commit :f` */

package.json

@@ -39,7 +39,8 @@
   },
   "lint-staged": {
     "*.{js,jsx,ts,tsx}": [
-      "prettier --write"
+      "prettier --write",
+      "eslint --fix"
     ],
     "{!(package)*.json,*.code-snippets,.!(browserslist)*rc}": [
       "prettier --write--parser json"
@@ -49,6 +50,7 @@
     ],
     "*.vue": [
       "prettier --write",
+      "eslint --fix",
       "stylelint --fix"
     ],
     "*.{scss,less,styl,html}": [
@@ -137,16 +139,17 @@
     "@vben/vite-config": "workspace:*",
     "@vue/compiler-sfc": "3.4.37",
     "@vue/test-utils": "2.4.5",
+    "@microsoft/fetch-event-source":"2.0.1",
     "conventional-changelog-cli": "4.1.0",
     "cross-env": "7.0.3",
     "cz-git": "1.9.1",
     "czg": "1.9.1",
-    "emoji-picker-element": "1.12.1",
     "husky": "9.0.11",
     "lint-staged": "15.2.2",
     "micromark": "^3.1.0",
     "micromark-extension-gfm": "^2.0.1",
     "prettier": "3.3.3",
+    "emoji-picker-element": "1.12.1",
     "prettier-plugin-packagejson": "2.5.0",
     "rimraf": "5.0.5",
     "sass": "1.77.6",

src/locales/setupI18n.ts

@@ -13,7 +13,8 @@ export let i18n: ReturnType<typeof createI18n>;
 async function createI18nOptions(): Promise<I18nOptions> {
   const localeStore = useLocaleStoreWithOut();
   const locale = localeStore.getLocale;
-  const defaultLocal = await import(`./lang/${locale}`);
+  const defaultLocal = await import(`./lang/${locale}.ts`);
+  // const defaultLocal = await import(localeModuleMap[locale]);
   const message = defaultLocal.default?.message ?? {};
 
   setHtmlPageLang(locale);

src/views/chat/index.vue

@@ -31,6 +31,12 @@
   import { ContentTypeEnum } from '@/enums/httpEnum';
   import { buildUUID } from '@/utils/uuid';
   import { cloneDeep } from 'lodash-es';
+  import { getToken } from '@/utils/auth';
+
+  import { fetchEventSource } from '@microsoft/fetch-event-source';
+  import { useGlobSetting } from '@/hooks/setting';
+  import { mapState } from 'pinia';
+
   // import { register } from './lib/index.js'
   // import { register } from 'vue-advanced-chat'
 
@@ -45,6 +51,7 @@
     { name: 'underline', title: '地名检查' },
     { name: 'bold', title: '文档公司名识别' },
     { name: 'color', title: '文档相似性检查' },
+    { name: 'comment1', title: '文档结构检查' },
     { name: 'comment', title: '文档图文分析' },
   ];
 
@@ -100,6 +107,7 @@
   const currentMsgSeq = ref(1);
   const roomMessage = ref('');
   let roomIdCounter = 1;
+  const fileInfo = ref();
   const rooms = ref([
     {
       roomId: '1', //房间id(类似聊天对象id)
@@ -298,10 +306,13 @@
       disableActions: false,
       disableReactions: false,
     };
-
+    fileInfo.value = null;
     if (files) {
       message['files'] = formattedFiles(files);
       console.log(files);
+      fileInfo.value = new File([files[0].blob], files[0].name + '.' + files[0].extension, {
+        type: files[0].blob.type,
+      });
     }
 
     if (replyMessage) {
@@ -315,24 +326,26 @@
         message['replyMessage'].files = replyMessage.files;
       }
     }
-    const file = new File([files[0].blob], files[0].name + '.' + files[0].extension, {
+
-      type: files[0].blob.type,
-    });
     const data = {
-      file: file,
+      // file: file,
       content: content,
     };
     roomMsgMap[roomId].push(message);
 
     roomMessages.value = [...roomMsgMap[roomId]] as any;
-    const qingshaodeng = {
+
+    let getcontent = ref('文件上传中.....');
+    messagesLoaded.value = false;
+    let nowDate = new Date();
+    const message1 = {
       _id: currentMsgSeq.value.toString(),
       senderId: '2',
       username: users['ai'].username,
       avatar: users['ai'].avatar,
-      content: '请稍等',
+      content: getcontent.value,
-      timestamp: formatDate(new Date()),
+      timestamp: formatDate(nowDate),
-      date: formatDate(new Date()),
+      date: formatDate(nowDate),
       system: false,
       saved: true,
       distributed: true,
@@ -342,28 +355,86 @@
       disableActions: false,
       disableReactions: false,
     };
-    roomMsgMap[roomId].push(qingshaodeng);
+    roomMsgMap[roomId].push(message1);
-    roomMessages.value = [...roomMsgMap[roomId]] as any;
 
-    let getcontent = await defHttp.post({
+    roomMessages.value = [...roomMsgMap[roomId]] as any;
-      url: '/productManagement/supplierInformation/importData',
+    // 注意，下面的用法不行，不刷新
-      data,
+    //this.roomMessages = roomMsgMap[roomId]
+    // console.log(this.roomMessages);
+    messagesLoaded.value = true;
+    const { apiUrl, clientId } = useGlobSetting();
+    const ctrl = new AbortController();
+    const EventStreamContentType = 'text/event-stream; charset=utf-8';
+    let formData = new FormData();
+    formData.append('fileInfo', fileInfo.value);
+    formData.append('content', content);
+    //${apiUrl}/productManagement/supplierInformation/sse-invoke
+    let url = `${apiUrl}/productManagement/supplierInformation/sse-invoke`;
+    if (content.indexOf('地名检查') >= 0) {
+      url = `${apiUrl}/productManagement/supplierInformation/sse/checkPlaceName`;
+    } else if (content.indexOf('文档公司名识别') >= 0) {
+      url = `${apiUrl}/productManagement/supplierInformation/sse/checkCompanyName`;
+    } else if (content.indexOf('文档相似性检查') >= 0) {
+      url = `${apiUrl}/productManagement/supplierInformation/sse/checkRepeatText`;
+    } else if (content.indexOf('文档纠错') >= 0) {
+      url = `${apiUrl}/productManagement/supplierInformation/sse/checkDocumentError`;
+    } else if (content.indexOf('文档结构检查') >= 0) {
+      url = `${apiUrl}/productManagement/supplierInformation/sse/checkTitleName`;
+    } else if (content.indexOf('全功能文档分析') >= 0) {
+      url = `${apiUrl}/sse/checkDocumentAll`;
+      let uuid = buildUUID();
+      formData.append('uuid', uuid + '.' + files[0].extension);
+      try {
+        await defHttp.post({
+          url: '/productManagement/supplierInformation/upload',
+          data: formData,
           headers: {
             'Content-Type': ContentTypeEnum.FORM_DATA,
           },
-      timeout: 4 * 60 * 1000,
+          timeout: 10 * 60 * 1000,
         });
+        // 请求成功，处理响应
+        // 可以在这里对 fileRes 进行进一步处理，如显示成功消息等
+      } catch (error) {
+        // 请求失败，处理错误
+        console.error('请求失败:', error);
+        // 根据需要显示错误消息或进行其他处理
+        const message1 = {
+        _id: currentMsgSeq.value.toString(),
+        senderId: '2',
+        username: users['ai'].username,
+        avatar: users['ai'].avatar,
+        content: '**文件上传失败，请联系管理员**',
+        timestamp: formatDate(nowDate),
+        date: formatDate(nowDate),
+        system: false,
+        saved: true,
+        distributed: true,
+        seen: true,
+        deleted: false,
+        failure: false,
+        disableActions: false,
+        disableReactions: false,
+      };
+      roomMsgMap[roomId][roomMsgMap[roomId].length - 1] = message1;
+      roomMessages.value = [...roomMsgMap[roomId]] as any;
+      return;
+      }
+      
+      const fetchPromises = [];
+      for (let i = 0; i < 5; i++) {
+        if (i >= 1) {
+          let getcontent = ref('请稍等...');
           messagesLoaded.value = false;
-    // roomMsgMap[roomId].push(message);
+          let nowDate = new Date();
-    // console.log(roomMsgMap[roomId]);
           const message1 = {
             _id: currentMsgSeq.value.toString(),
             senderId: '2',
             username: users['ai'].username,
             avatar: users['ai'].avatar,
-      content: getcontent,
+            content: getcontent.value,
-      timestamp: formatDate(new Date()),
+            timestamp: formatDate(nowDate),
-      date: formatDate(new Date()),
+            date: formatDate(nowDate),
             system: false,
             saved: true,
             distributed: true,
@@ -374,12 +445,196 @@
             disableReactions: false,
           };
           roomMsgMap[roomId].push(message1);
+          roomMessages.value = [...roomMsgMap[roomId]] as any;
+        }
+
+        let url;
+        if (i === 0) {
+          url = `${apiUrl}/productManagement/supplierInformation/sse/checkDocumentAll/checkPlaceName`;
+        } else if (i === 1) {
+          url = `${apiUrl}/productManagement/supplierInformation/sse/checkDocumentAll/checkCompanyName`;
+        } else if (i === 2) {
+          url = `${apiUrl}/productManagement/supplierInformation/sse/checkDocumentAll/checkDocumentError`;
+        } else if (i === 3) {
+          url = `${apiUrl}/productManagement/supplierInformation/sse/checkDocumentAll/checkTitleName`;
+        } else if (i === 4) {
+          url = `${apiUrl}/productManagement/supplierInformation/sse/checkDocumentAll/checkRepeatText`;
+        }
+
+        // 将fetchEventSource封装为一个Promise
+        const fetchPromise = new Promise((resolve, reject) => {
+          setTimeout(() => {
+            fetchEventSource(url, {
+              method: 'POST',
+              headers: {
+                // 'Content-Type': 'application/json;charset=utf-8',//multipart/form-data;charset=UTF-8//application/json;charset=utf-8
+                Authorization: `Bearer ${getToken()}`,
+                clientId: clientId,
+              },
+              signal: ctrl.signal,
+              openWhenHidden: true,
+              body: formData,
+              async onmessage(msg: { data: string; event: string }) {
+                // ev.data里面是实时传递过来的数据
+                // 根据后端返回的数据，我这里需要将字符串转成对象
+                // let obj = JSON.parse(msg.data);
+                // // 拿到具体的内容
+
+                // getcontent.value +=msg.data.substring(getcontent.value.length);
+                getcontent.value = msg.data.replace('<br>', '\n');
+
+                console.log(getcontent.value);
+                const message1 = {
+                  _id: currentMsgSeq.value.toString(),
+                  senderId: '2',
+                  username: users['ai'].username,
+                  avatar: users['ai'].avatar,
+                  content: getcontent.value,
+                  timestamp: formatDate(nowDate),
+                  date: formatDate(nowDate),
+                  system: false,
+                  saved: true,
+                  distributed: true,
+                  seen: true,
+                  deleted: false,
+                  failure: false,
+                  disableActions: false,
+                  disableReactions: false,
+                };
+                roomMsgMap[roomId][roomMsgMap[roomId].length - (5 - i)] = message1;
 
                 roomMessages.value = [...roomMsgMap[roomId]] as any;
-    // 注意，下面的用法不行，不刷新
+                // Unicode转成中文
-    //this.roomMessages = roomMsgMap[roomId]
+              },
-    // console.log(this.roomMessages);
+              //会话发送完毕时触发
-    messagesLoaded.value = true;
+              onclose() {
+                //这里可以写结束时，你需要做的事，如果没有，可以删除
+              },
+              onerror(err) {
+                console.log('onerror', err);
+                const message1 = {
+                  _id: currentMsgSeq.value.toString(),
+                  senderId: '2',
+                  username: users['ai'].username,
+                  avatar: users['ai'].avatar,
+                  content: '**出现异常，请联系管理员**',
+                  timestamp: formatDate(nowDate),
+                  date: formatDate(nowDate),
+                  system: false,
+                  saved: true,
+                  distributed: true,
+                  seen: true,
+                  deleted: false,
+                  failure: false,
+                  disableActions: false,
+                  disableReactions: false,
+                };
+                roomMsgMap[roomId][roomMsgMap[roomId].length - (5 - i)] = message1;
+
+                roomMessages.value = [...roomMsgMap[roomId]] as any;
+                ctrl.abort();
+                throw err;
+              },
+            });
+          }, 1500);
+        });
+
+        fetchPromises.push(fetchPromise); // 将Promise添加到数组
+      }
+
+      // 使用Promise.all并发执行所有请求
+      Promise.all(fetchPromises)
+        .then(() => {
+          console.log('所有请求成功完成');
+        })
+        .catch((err) => {
+          console.error('处理过程中发生错误:', err);
+        });
+      return;
+    } else if (content.indexOf('文档图文分析') >= 0) {
+      url = `${apiUrl}/sse/checkDocumentGraphic`;
+    }
+    await fetchEventSource(url, {
+      method: 'POST',
+      headers: {
+        // 'Content-Type': 'application/json;charset=utf-8',//multipart/form-data;charset=UTF-8//application/json;charset=utf-8
+        Authorization: `Bearer ${getToken()}`,
+        clientId: clientId,
+      },
+      signal: ctrl.signal,
+      openWhenHidden: true,
+      body: formData,
+      async onmessage(msg: { data: string; event: string }) {
+        // ev.data里面是实时传递过来的数据
+        // 根据后端返回的数据，我这里需要将字符串转成对象
+        // let obj = JSON.parse(msg.data);
+        // // 拿到具体的内容
+
+        // getcontent.value +=msg.data.substring(getcontent.value.length);
+        getcontent.value = msg.data.replaceAll('<br>', '\n');
+
+        console.log(getcontent.value);
+        const message1 = {
+          _id: currentMsgSeq.value.toString(),
+          senderId: '2',
+          username: users['ai'].username,
+          avatar: users['ai'].avatar,
+          content: getcontent.value,
+          timestamp: formatDate(nowDate),
+          date: formatDate(nowDate),
+          system: false,
+          saved: true,
+          distributed: true,
+          seen: true,
+          deleted: false,
+          failure: false,
+          disableActions: false,
+          disableReactions: false,
+        };
+        roomMsgMap[roomId][roomMsgMap[roomId].length - 1] = message1;
+
+        roomMessages.value = [...roomMsgMap[roomId]] as any;
+        // Unicode转成中文
+      },
+      //会话发送完毕时触发
+      onclose() {
+        //这里可以写结束时，你需要做的事，如果没有，可以删除
+      },
+      onerror(err) {
+        console.log('onerror', err);
+        const message1 = {
+          _id: currentMsgSeq.value.toString(),
+          senderId: '2',
+          username: users['ai'].username,
+          avatar: users['ai'].avatar,
+          content: '**出现异常，请联系管理员**',
+          timestamp: formatDate(nowDate),
+          date: formatDate(nowDate),
+          system: false,
+          saved: true,
+          distributed: true,
+          seen: true,
+          deleted: false,
+          failure: false,
+          disableActions: false,
+          disableReactions: false,
+        };
+        roomMsgMap[roomId][roomMsgMap[roomId].length - 1] = message1;
+
+        roomMessages.value = [...roomMsgMap[roomId]] as any;
+        ctrl.abort();
+        throw err;
+      },
+    });
+
+    // let getcontent = await defHttp.get({
+    //   url: '/productManagement/supplierInformation/sse-invoke',
+    //   data,
+    //   // headers: {
+    //   //   'Content-Type': ContentTypeEnum.FORM_DATA,
+    //   // },
+    //   timeout: 4 * 60 * 1000,
+    // });
   }
 
   function formattedFiles(files) {