ZF/weiyu
1
0
Fork 0
mirror of https://gitee.com/270580156/weiyu.git synced 2026-05-14 03:12:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
jack ning
2025-02-16 20:45:25 +08:00
parent 3c93566f2d
commit 537c32ea09
100 changed files with 1015 additions and 713 deletions
Download Patch File Download Diff File Expand all files Collapse all files

599
deploy/server/agenticflow/assets/index-KfrT43GK.js → deploy/server/agenticflow/assets/index-BBA59LFX.js
View File

File diff suppressed because one or more lines are too long

2
deploy/server/agenticflow/assets/threadService-DC_USqBf.js → deploy/server/agenticflow/assets/threadService-CjmsKEfO.js
View File

@@ -1 +1 @@
import{r as T,u as n,a as h}from"./index-KfrT43GK.js";async function y(t){return T("/api/v1/thread/query",{method:"GET",params:{...t}})}const b={async loadThreads(t,s=3){const{setLoading:o,setError:d,setThreads:i,searchText:c,pagination:a,setPagination:l}=n.getState(),p=h.getState().currentOrg,g=async u=>{try{o(!0),d(null);const r={orgUid:p.uid,pageNumber:a.pageNumber,pageSize:a.pageSize};c&&(r.searchText=c);const e=await y(r);if(console.log("queryThreads response",r,e.data),e.data.code===200){if(l({...a,total:e.data.data.totalElements,pageNumber:e.data.data.last?a.pageNumber:a.pageNumber+1}),a.pageNumber===0)i(e.data.data.content);else{const{threads:S}=n.getState();i([...S,...e.data.data.content])}const{setThreadResult:m}=n.getState();m(e.data)}else throw new Error(e.data.message)}catch(r){if(u<s)return await new Promise(e=>setTimeout(e,1e3)),g(u+1);d(r instanceof Error?r.message:"Failed to load threads")}finally{o(!1)}};return g(1)},async resetAndLoad(){const{setPagination:t}=n.getState(),s=h.getState().currentOrg;return t({pageNumber:0,pageSize:100,total:0}),this.loadThreads(s.uid)},async loadThreadsWithFilters(t){const{setFilter:s}=n.getState();return Object.entries(t).forEach(([o,d])=>{s(o,d)}),this.resetAndLoad()}};export{b as threadService};
import{r as T,u as n,a as h}from"./index-BBA59LFX.js";async function y(t){return T("/api/v1/thread/query",{method:"GET",params:{...t}})}const b={async loadThreads(t,s=3){const{setLoading:o,setError:d,setThreads:i,searchText:c,pagination:a,setPagination:l}=n.getState(),p=h.getState().currentOrg,g=async u=>{try{o(!0),d(null);const r={orgUid:p.uid,pageNumber:a.pageNumber,pageSize:a.pageSize};c&&(r.searchText=c);const e=await y(r);if(console.log("queryThreads response",r,e.data),e.data.code===200){if(l({...a,total:e.data.data.totalElements,pageNumber:e.data.data.last?a.pageNumber:a.pageNumber+1}),a.pageNumber===0)i(e.data.data.content);else{const{threads:S}=n.getState();i([...S,...e.data.data.content])}const{setThreadResult:m}=n.getState();m(e.data)}else throw new Error(e.data.message)}catch(r){if(u<s)return await new Promise(e=>setTimeout(e,1e3)),g(u+1);d(r instanceof Error?r.message:"Failed to load threads")}finally{o(!1)}};return g(1)},async resetAndLoad(){const{setPagination:t}=n.getState(),s=h.getState().currentOrg;return t({pageNumber:0,pageSize:100,total:0}),this.loadThreads(s.uid)},async loadThreadsWithFilters(t){const{setFilter:s}=n.getState();return Object.entries(t).forEach(([o,d])=>{s(o,d)}),this.resetAndLoad()}};export{b as threadService};

2
deploy/server/agenticflow/index.html
View File

@@ -21,7 +21,7 @@
<!-- 导致无法连接mqtt服务器，暂时注释掉 -->
<!-- <meta http-equiv="Content-Security-Policy" content="script-src 'self' 'unsafe-inline';" /> -->
<title>微语</title>
<script type="module" crossorigin src="/agenticflow/assets/index-KfrT43GK.js"></script>
<script type="module" crossorigin src="/agenticflow/assets/index-BBA59LFX.js"></script>
<link rel="stylesheet" crossorigin href="/agenticflow/assets/index-Dye10Q-l.css">
</head>