workflow-canvas.html 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324
  1. <!DOCTYPE html>
  2. <html lang="zh">
  3. <head>
  4. <meta charset="UTF-8">
  5. <meta name="viewport" content="width=device-width, initial-scale=1.0">
  6. <title>龙虾引擎 - 工作流可视化编辑器</title>
  7. <script src="https://unpkg.com/vue@3/dist/vue.global.prod.js"></script>
  8. <script src="https://unpkg.com/@vue-flow/core@latest/dist/vue-flow.umd.js"></script>
  9. <script src="https://unpkg.com/@vue-flow/background@latest/dist/vue-flow-background.umd.js"></script>
  10. <script src="https://unpkg.com/@vue-flow/minimap@latest/dist/vue-flow-minimap.umd.js"></script>
  11. <script src="https://unpkg.com/@vue-flow/controls@latest/dist/vue-flow-controls.umd.js"></script>
  12. <link href="https://unpkg.com/@vue-flow/core@latest/dist/style.css" rel="stylesheet">
  13. <link href="https://unpkg.com/@vue-flow/minimap@latest/dist/style.css" rel="stylesheet">
  14. <link href="https://unpkg.com/@vue-flow/controls@latest/dist/style.css" rel="stylesheet">
  15. <style>
  16. *{margin:0;padding:0;box-sizing:border-box}
  17. body{font-family:-apple-system,BlinkMacSystemFont,'Segoe UI',sans-serif;height:100vh;overflow:hidden}
  18. #app{display:flex;height:100vh}
  19. .sidebar{width:220px;background:#1a1a2e;color:#fff;padding:12px;overflow-y:auto;flex-shrink:0}
  20. .sidebar h3{font-size:14px;margin:8px 0;color:#e94560;border-bottom:1px solid #333;padding-bottom:4px}
  21. .node-item{background:#16213e;margin:4px 0;padding:8px;border-radius:6px;cursor:grab;font-size:12px;border:1px solid #0f3460;transition:all .2s}
  22. .node-item:hover{background:#0f3460;border-color:#e94560;transform:translateX(2px)}
  23. .node-item .type-tag{display:inline-block;background:#e94560;color:#fff;padding:1px 6px;border-radius:3px;font-size:10px;margin-right:6px}
  24. .main{flex:1;position:relative}
  25. .toolbar{position:absolute;top:10px;left:10px;z-index:10;display:flex;gap:8px}
  26. .toolbar button{padding:6px 14px;border:none;border-radius:4px;cursor:pointer;font-size:12px}
  27. .btn-primary{background:#e94560;color:#fff}
  28. .btn-secondary{background:#0f3460;color:#fff}
  29. .btn-success{background:#22c55e;color:#fff}
  30. .prop-panel{width:320px;background:#f8f9fa;border-left:2px solid #dee2e6;padding:12px;overflow-y:auto;flex-shrink:0;font-size:13px}
  31. .prop-panel h3{color:#1a1a2e;margin-bottom:10px}
  32. .prop-panel label{display:block;margin:6px 0 2px;color:#555;font-weight:600}
  33. .prop-panel input,.prop-panel textarea,.prop-panel select{width:100%;padding:6px;border:1px solid #ccc;border-radius:4px;font-size:12px;margin-bottom:6px}
  34. .prop-panel textarea{min-height:60px;font-family:monospace}
  35. .vue-flow__node{font-size:12px;min-width:120px;text-align:center}
  36. .flow-node{padding:8px 12px;border-radius:8px;border:2px solid;background:#fff;box-shadow:0 2px 6px rgba(0,0,0,.1)}
  37. .flow-node.start{border-color:#22c55e}
  38. .flow-node.ai{border-color:#8b5cf6}
  39. .flow-node.msg{border-color:#3b82f6}
  40. .flow-node.cond{border-color:#f59e0b}
  41. .flow-node.end{border-color:#ef4444}
  42. .flow-node.default{border-color:#6b7280}
  43. .node-name{font-weight:700}
  44. .node-desc{font-size:10px;color:#888;margin-top:2px}
  45. .modal-overlay{position:fixed;top:0;left:0;right:0;bottom:0;background:rgba(0,0,0,.5);display:flex;align-items:center;justify-content:center;z-index:1000}
  46. .modal{background:#fff;border-radius:12px;padding:24px;width:500px;max-height:80vh;overflow-y:auto}
  47. .modal h4{margin-bottom:12px}
  48. .modal textarea{width:100%;min-height:120px;margin:8px 0;font-family:monospace;font-size:12px;padding:8px}
  49. .modal .actions{display:flex;gap:8px;justify-content:flex-end;margin-top:12px}
  50. </style>
  51. </head>
  52. <body>
  53. <div id="app">
  54. <div class="sidebar">
  55. <h3>🦞 龙虾引擎</h3>
  56. <div v-for="(group,gname) in nodeGroups" :key="gname">
  57. <h3>{{gname}}</h3>
  58. <div class="node-item" v-for="nt in group" :key="nt.type"
  59. @dragstart="onDragStart($event,nt)" draggable="true">
  60. <span class="type-tag">{{nt.type}}</span>{{nt.name}}
  61. </div>
  62. </div>
  63. <div style="margin-top:12px;border-top:1px solid #333;padding-top:8px">
  64. <button class="btn-primary" style="width:100%;padding:8px;margin:4px 0" @click="showGenerate=true">🤖 AI生成工作流</button>
  65. <button class="btn-secondary" style="width:100%;padding:8px;margin:4px 0" @click="exportJson">📋 导出JSON</button>
  66. <button class="btn-success" style="width:100%;padding:8px;margin:4px 0" @click="saveWorkflow">💾 保存到服务器</button>
  67. <button class="btn-secondary" style="width:100%;padding:8px;margin:4px 0" @click="showLoad=true">📂 加载工作流</button>
  68. </div>
  69. </div>
  70. <div class="main" @drop="onDrop" @dragover.prevent>
  71. <div class="toolbar">
  72. <button class="btn-primary" @click="fitView()">🎯 适应视图</button>
  73. <button class="btn-secondary" @click="undo()">↩ 撤销</button>
  74. </div>
  75. <vue-flow ref="flowRef" v-model="elements" :node-types="nodeTypes"
  76. :default-edge-options="{animated:true,style:{stroke:'#64748b',strokeWidth:2}}"
  77. @node-click="onNodeClick" @connect="onConnect" style="height:100%;background:#f1f5f9">
  78. <template #node-start="props"><div class="flow-node start"><div class="node-name">🚀 {{props.data.label}}</div></div></template>
  79. <template #node-ai="props"><div class="flow-node ai"><div class="node-name">🧠 {{props.data.label}}</div></div></template>
  80. <template #node-msg="props"><div class="flow-node msg"><div class="node-name">💬 {{props.data.label}}</div></div></template>
  81. <template #node-cond="props"><div class="flow-node cond"><div class="node-name">🔀 {{props.data.label}}</div></div></template>
  82. <template #node-end="props"><div class="flow-node end"><div class="node-name">🏁 {{props.data.label}}</div></div></template>
  83. <template #node-default="props"><div class="flow-node default"><div class="node-name">📌 {{props.data.label}}</div></div></template>
  84. <vue-flow-background />
  85. <vue-flow-minimap />
  86. <vue-flow-controls />
  87. </vue-flow>
  88. </div>
  89. <div class="prop-panel" v-if="selectedNode">
  90. <h3>节点属性</h3>
  91. <label>节点编码</label><input v-model="selectedNode.data.nodeCode">
  92. <label>节点名称</label><input v-model="selectedNode.data.label">
  93. <label>节点类型</label>
  94. <select v-model.number="selectedNode.data.nodeType" @change="onTypeChange">
  95. <option v-for="nt in allNodes" :value="nt.type" :key="nt.type">{{nt.type}}-{{nt.name}}</option>
  96. </select>
  97. <label>下一节点</label><input v-model="selectedNode.data.nextNodeCode" placeholder="next_node_code">
  98. <label>话术模板</label><textarea v-model="selectedNode.data.messageTemplate" placeholder="支持 ${变量}"></textarea>
  99. <label>条件表达式</label><textarea v-model="selectedNode.data.conditionExpr" placeholder='{"field":"intent","op":"eq","value":"purchase"}'></textarea>
  100. <label>节点配置(JSON)</label><textarea v-model="selectedNode.data.nodeConfig" placeholder='{"collectFields":["1","2"]}'></textarea>
  101. <label>最大轮次</label><input v-model.number="selectedNode.data.maxRounds" type="number" min="0">
  102. <button class="btn-primary" style="width:100%;margin-top:8px;padding:8px" @click="selectedNode=null">关闭</button>
  103. </div>
  104. </div>
  105. <div class="modal-overlay" v-if="showGenerate">
  106. <div class="modal">
  107. <h4>🤖 AI生成工作流</h4>
  108. <label>需求描述</label>
  109. <textarea v-model="genReq" placeholder="例如:我需要一个旅游行业的客户跟进流程,包括意图识别、信息收集、发送方案、条件判断、创建跟进任务..."></textarea>
  110. <label>行业类型</label>
  111. <select v-model="genIndustry">
  112. <option value="travel">旅游</option><option value="medical">医美</option>
  113. <option value="education">教育</option><option value="insurance">保险</option>
  114. <option value="general">通用</option>
  115. </select>
  116. <label>已有工作流JSON(可选-迭代优化)</label>
  117. <textarea v-model="genExisting" placeholder="粘贴已有工作流JSON进行迭代优化...留空则全新生成"></textarea>
  118. <label>迭代指令(可选)</label>
  119. <input v-model="genInstruction" placeholder="如:增加关怀节点、优化话术、调整条件">
  120. <div class="actions">
  121. <button class="btn-secondary" @click="showGenerate=false">取消</button>
  122. <button class="btn-primary" @click="aiGenerate()">生成</button>
  123. </div>
  124. <div v-if="genResult" style="margin-top:12px;background:#f0fdf4;padding:10px;border-radius:6px;font-size:12px">
  125. <b>评分:{{genResult.score}}</b> {{genResult.details}}
  126. </div>
  127. </div>
  128. </div>
  129. <div class="modal-overlay" v-if="showLoad">
  130. <div class="modal">
  131. <h4>📂 加载工作流</h4>
  132. <textarea v-model="loadJson" placeholder="粘贴工作流JSON..."></textarea>
  133. <div class="actions">
  134. <button class="btn-secondary" @click="showLoad=false">取消</button>
  135. <button class="btn-primary" @click="importJson()">加载</button>
  136. </div>
  137. </div>
  138. </div>
  139. </div>
  140. <script>
  141. const {createApp,ref,computed,reactive,onMounted} = Vue
  142. const nodeGroups = {
  143. '流程控制':[{type:1,name:'开始',icon:'🚀'},{type:99,name:'结束',icon:'🏁'},{type:4,name:'等待',icon:'⏳'}],
  144. 'AI智能':[{type:2,name:'AI处理',icon:'🧠'},{type:11,name:'知识检索',icon:'🔍'}],
  145. '交互触达':[{type:3,name:'发送消息',icon:'💬'},{type:7,name:'信息收集',icon:'📋'},{type:10,name:'HTTP调用',icon:'🌐'}],
  146. '逻辑控制':[{type:5,name:'条件判断',icon:'🔀'},{type:13,name:'循环迭代',icon:'🔄'},{type:16,name:'变量赋值',icon:'📝'}],
  147. '业务操作':[{type:6,name:'创建任务',icon:'✅'},{type:8,name:'转人工',icon:'👤'},{type:9,name:'标签操作',icon:'🏷'}],
  148. '扩展能力':[{type:12,name:'代码执行',icon:'⚡'},{type:14,name:'数据库查询',icon:'🗄'},{type:15,name:'子流程',icon:'📦'}]
  149. }
  150. const allNodes = Object.values(nodeGroups).flat()
  151. const typeToCategory = {}
  152. allNodes.forEach(n => {
  153. if (n.type === 1) typeToCategory[n.type] = 'start'
  154. else if (n.type === 99) typeToCategory[n.type] = 'end'
  155. else if (n.type === 2 || n.type === 11) typeToCategory[n.type] = 'ai'
  156. else if (n.type === 3 || n.type === 7 || n.type === 10) typeToCategory[n.type] = 'msg'
  157. else if (n.type === 5 || n.type === 13 || n.type === 16) typeToCategory[n.type] = 'cond'
  158. else typeToCategory[n.type] = 'default'
  159. })
  160. const app = createApp({
  161. setup(){
  162. const flowRef = ref(null)
  163. const selectedNode = ref(null)
  164. const elements = ref([
  165. {id:'1',type:'start',position:{x:300,y:50},data:{label:'开始',nodeCode:'START',nodeType:1,nextNodeCode:'MSG_1',messageTemplate:'',conditionExpr:'',nodeConfig:'{}',maxRounds:0}},
  166. {id:'2',type:'msg',position:{x:300,y:180},data:{label:'欢迎消息',nodeCode:'MSG_1',nodeType:3,nextNodeCode:'END',messageTemplate:'您好${customerName},欢迎咨询!',conditionExpr:'',nodeConfig:'{}',maxRounds:0}},
  167. {id:'3',type:'end',position:{x:300,y:310},data:{label:'结束',nodeCode:'END',nodeType:99,nextNodeCode:'',messageTemplate:'',conditionExpr:'',nodeConfig:'{}',maxRounds:0}},
  168. {id:'e1-2',source:'1',target:'2',animated:true},
  169. ])
  170. const showGenerate = ref(false), showLoad = ref(false)
  171. const genReq = ref(''), genIndustry = ref('travel'), genExisting = ref(''), genInstruction = ref('')
  172. const genResult = ref(null), loadJson = ref('')
  173. let nodeIdCounter = elements.value.length
  174. const nodeTypes = {
  175. start:{template:'#node-start'}, ai:{template:'#node-ai'}, msg:{template:'#node-msg'},
  176. cond:{template:'#node-cond'}, end:{template:'#node-end'}, default:{template:'#node-default'}
  177. }
  178. function onDragStart(ev,nt){
  179. ev.dataTransfer.setData('application/json',JSON.stringify(nt))
  180. ev.dataTransfer.effectAllowed = 'move'
  181. }
  182. function onDrop(ev){
  183. const nt = JSON.parse(ev.dataTransfer.getData('application/json'))
  184. const pos = flowRef.value?.screenToFlowCoordinate?.({x:ev.clientX,y:ev.clientY}) || {x:ev.offsetX,y:ev.offsetY}
  185. nodeIdCounter++
  186. const cat = typeToCategory[nt.type] || 'default'
  187. elements.value.push({
  188. id:String(nodeIdCounter), type:cat, position:pos,
  189. data:{label:nt.name,nodeCode:nt.name.toUpperCase()+'_'+nodeIdCounter,nodeType:nt.type,
  190. nextNodeCode:'',messageTemplate:'',conditionExpr:'',nodeConfig:'{}',maxRounds:0}
  191. })
  192. }
  193. function onNodeClick({node}){ selectedNode.value = node }
  194. function onConnect(conn){
  195. elements.value.push({id:'e'+conn.source+'-'+conn.target,source:conn.source,target:conn.target,animated:true})
  196. }
  197. function onTypeChange(){
  198. if(selectedNode.value){
  199. selectedNode.value.type = typeToCategory[selectedNode.value.data.nodeType] || 'default'
  200. }
  201. }
  202. function fitView(){ flowRef.value?.fitView() }
  203. function undo(){ elements.value.pop() }
  204. function exportJson(){
  205. const nodes = elements.value.filter(e=>e.type&&e.data).map(e=>({nodeCode:e.data.nodeCode,nodeName:e.data.label,nodeType:e.data.nodeType,sortNo:parseInt(e.id),nextNodeCode:e.data.nextNodeCode,messageTemplate:e.data.messageTemplate||'',conditionExpr:e.data.conditionExpr||'',nodeConfig:e.data.nodeConfig||'{}',maxRounds:e.data.maxRounds||0}))
  206. const edges = elements.value.filter(e=>e.source&&e.target).map((e,i)=>({edgeKey:'EDGE_'+i,sourceNodeCode:elements.value.find(n=>n.id===e.source)?.data?.nodeCode||'',targetNodeCode:elements.value.find(n=>n.id===e.target)?.data?.nodeCode||'',edgeLabel:''}))
  207. const json = JSON.stringify({templateName:'工作流模板',description:'',nodes,edges},null,2)
  208. navigator.clipboard.writeText(json).then(()=>alert('已复制到剪贴板'))
  209. console.log(json)
  210. }
  211. async function saveWorkflow(){
  212. exportJson()
  213. const token = localStorage.getItem('company_token') || ''
  214. try{
  215. const r = await fetch('http://localhost:8006/workflow/lobster/template/save',{
  216. method:'POST',headers:{'Content-Type':'application/json','Authorization':'Bearer '+token},
  217. body:JSON.stringify(JSON.parse(await navigator.clipboard.readText()))
  218. })
  219. const d = await r.json()
  220. alert(d.code===200?'保存成功!':'保存失败: '+d.msg)
  221. }catch(e){alert('请先登录系统获取token,或在控制台复制JSON手动保存')}
  222. }
  223. async function aiGenerate(){
  224. genResult.value = null
  225. genStatus.value = 'submitting'
  226. genProgress.value = '正在提交AI生成任务...'
  227. const body = {requirement:genReq.value,industryType:genIndustry.value,modelConfig:{modelA:'doubao-lite',modelB:'doubao-lite',modelC:'doubao-lite'}}
  228. if(genExisting.value){
  229. body.existingWorkflow = genExisting.value
  230. body.modifyInstruction = genInstruction.value||'优化工作流结构'
  231. }
  232. try{
  233. /* 第一步: 提交异步任务, 立即返回recordId */
  234. const submitRes = await fetch('/workflow/ai-generator/generate',{
  235. method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify(body)
  236. })
  237. const submitData = await submitRes.json()
  238. if(submitData.code!==200||!submitData.data||!submitData.data.recordId){
  239. genStatus.value = 'error'
  240. genProgress.value = '提交失败'
  241. alert('AI生成任务提交失败')
  242. return
  243. }
  244. const recordId = submitData.data.recordId
  245. genProgress.value = 'AI正在生成工作流(模型A生成中)...'
  246. /* 第二步: 轮询任务状态, 每3秒查询一次, 最多轮询60次(3分钟) */
  247. for(let i=0;i<60;i++){
  248. await new Promise(r=>setTimeout(r,3000))
  249. const pollRes = await fetch('/workflow/ai-generator/result/'+recordId+'/detail')
  250. const pollData = await pollRes.json()
  251. if(pollData.code===200&&pollData.data){
  252. const result = pollData.data
  253. if(result.status==='completed'||result.status==='done'){
  254. genResult.value = {score:result.qualityScore||'85',details:result.suggestions||''}
  255. elements.value = parseWorkflowJson(result.workflowJson || result.nodes || result)
  256. genStatus.value = 'done'
  257. genProgress.value = 'AI生成完成! (得分:'+(result.qualityScore||85)+')'
  258. return
  259. }
  260. if(result.status==='failed'){
  261. genStatus.value = 'error'
  262. genProgress.value = '生成失败: '+(result.errorMsg||'未知错误')
  263. return
  264. }
  265. /* 进度更新 */
  266. if(i<5) genProgress.value = 'AI正在生成工作流(模型A生成中)...'
  267. else if(i<10) genProgress.value = '模型B优化中...'
  268. else genProgress.value = '模型C质检评分中...'
  269. }
  270. }
  271. genStatus.value = 'error'
  272. genProgress.value = '超时(3分钟),请重试'
  273. }catch(e){
  274. genStatus.value = 'error'
  275. genProgress.value = '请求失败: '+e.message
  276. alert('AI生成请求失败: '+e.message)
  277. }
  278. }
  279. function importJson(){
  280. try{
  281. elements.value = parseWorkflowJson(JSON.parse(loadJson.value))
  282. showLoad.value = false
  283. }catch(e){alert('JSON格式错误: '+e.message)}
  284. }
  285. function parseWorkflowJson(wf){
  286. if(typeof wf==='string') wf = JSON.parse(wf)
  287. const nodes = (wf.nodes||[]).map((n,i)=>({id:String(i+1),type:typeToCategory[n.nodeType]||'default',position:{x:300,y:50+i*130},data:{label:n.nodeName||n.name||'',nodeCode:n.nodeCode||'',nodeType:n.nodeType||3,nextNodeCode:n.nextNodeCode||'',messageTemplate:n.messageTemplate||'',conditionExpr:n.conditionExpr||'',nodeConfig:typeof n.nodeConfig==='string'?n.nodeConfig:JSON.stringify(n.nodeConfig),maxRounds:n.maxRounds||0}}))
  288. const edgeMap = {}
  289. nodes.forEach(n=>{if(n.data.nextNodeCode) edgeMap[n.data.nodeCode]=n.data.nextNodeCode})
  290. const edges = (wf.edges||[]).map((e,i)=>({id:'e'+i,source:nodes.find(n=>n.data.nodeCode===e.sourceNodeCode)?.id||'',target:nodes.find(n=>n.data.nodeCode===e.targetNodeCode)?.id||'',animated:true}))
  291. nodeIdCounter = nodes.length
  292. return [...nodes,...edges]
  293. }
  294. return {nodeGroups,allNodes,flowRef,elements,selectedNode,nodeTypes,
  295. showGenerate,showLoad,genReq,genIndustry,genExisting,genInstruction,genResult,loadJson,
  296. onDragStart,onDrop,onNodeClick,onConnect,onTypeChange,fitView,undo,exportJson,saveWorkflow,aiGenerate,importJson}
  297. }
  298. })
  299. app.component('vue-flow',VueFlow.default)
  300. app.component('vue-flow-background',VueFlowBackground.default)
  301. app.component('vue-flow-minimap',VueFlowMinimap.default)
  302. app.component('vue-flow-controls',VueFlowControls.default)
  303. app.mount('#app')
  304. </script>
  305. </body>
  306. </html>