2 lines
17 KiB
JavaScript
2 lines
17 KiB
JavaScript
|
|
import{a1 as V,b3 as ve,ao as x,aL as S,s as g,a6 as ee,a3 as o,aq as m,ak as l,a4 as w,aj as v,a8 as y,j as se,al as k,an as b,am as $,D as fe,a2 as te,b as oe,F as me,P as _e,ap as ye,af as ke,ay as we,ah as be,ai as ge,b4 as f,L as he,a9 as W,b5 as M,C as $e,E as Se}from"./index-Dry6uMZb.js";/* empty css */import{N as Ce,c as xe,C as Ae,S as Ie,d as Te,b as Pe,a as De}from"./index-DNloDtMO.js";import{C as Be}from"./index-spiRTnAv.js";async function Le(i){return await V.get(`/itportal/automation/sessions/${i}`)}async function Ne(i,c){return await V.post(`/itportal/automation/actions/${i}/confirm`,c)}async function Ve(i,c){return await V.post(`/itportal/automation/sessions/${i}/resolved`,c)}async function Re(i,c){return await V.post(`/itportal/automation/sessions/${i}/pause`,{reason:c||null})}async function Ue(i){return await V.post("/itportal/automation/sessions/resume",{session_id:i||null})}async function We(i){return await V.post(`/itportal/automation/sessions/${i}/resume`)}async function ze(i){return await V.get("/itportal/automation/sessions/paused",{params:{employee_id:i}})}async function Ee(i,c){return await V.post(`/itportal/automation/sessions/${i}/correct`,c)}async function Me(i,c){return await V.post(`/itportal/automation/sessions/${i}/supplement`,c)}async function Z(i){return await V.get(`/itportal/automation/sessions/${i}/info-items`)}function ie(){return localStorage.getItem("h5_token")||""}function Fe(i){const c=ie(),d=window.location.protocol==="https:"?"wss:":"ws:",a=window.location.host;return`${d}//${a}/ws/automation/${i}?token=${encodeURIComponent(c)}`}const je=ve("automation",()=>{const i=x(null),c=x(!1),d=x(null),a=x(!1),n=x(null),r=x([]),A=x(null),P=x([]),R=x(null),h=x([]),s=x(!1),p=S(()=>{var e;return((e=i.value)==null?void 0:e.status)==="resolved"}),L=S(()=>{var e;return((e=i.value)==null?void 0:e.status)==="handoff"}),D=S(()=>{var e;return((e=i.value)==null?void 0:e.status)==="paused"});async function _(e){c.value=!0;try{i.value=await Le(e)}finally{c.value=!1}}async function j(e,t){await Ne(e,t),A.value=null,n.value&&await _(n.value)}async function q(e,t){await Ve(e,t),n.value&&await _(n.value)}async function H(e){n.value&&(i.value=await Re(n.value,e))}async function O(e){const t=e?await We(e):await Ue(e);if(t.need_select){s.value=!0,P.value=t.paused_list||[];return}s.value=!1,t.session&&(i.value=t.session),t.resume_point&&(R.value=t.resume_point),t.pending_items&&t.pending_items.length>0&&g(`请补全信息:${t.pending_items.join("、")}`)}async function J(e){P.value=await ze(e)}async function G(e,t,T,C){await Ee(e,{field:t,new_value:T,old_value:C}),h.value=await Z(e)}async function K(e,t,T){await Me(e,{field:t,value:T}),h.value=await Z(e)}async function E(e){h.value=await Z(e)}function Q(e){F();const t=Fe(e),T=ie(),C=new WebSocket(t,[`bearer.${T}`]);d.value=C,n.value=e,C.onopen=()=>{a.value=!0},C.onmessage=N=>{try{const z=JSON.parse(N.data);X(z)}catch(z){console.error("[automation H5 WS] 消息解析失败",z)}},C.onclose=()=>{a.value=!1},C.onerror=()=>{a.value=!1}}function F(){d.value&&(d.value.close(),d.value=null),a.value=!1,n.value=null}function X(e){var t,T,C;if(!(e.session_id&&n.value&&e.session_id!==n.value))switch(e.type){case"automation.progress":r.value.push({type:e.type,time:I(),data:e.data}),n.value&&_(n.value);break;case"automation.action_required":A.value=((t=e.data)==null?void 0:t.action)||null,n.value&&_(n.value);break;case"automation.resolved":n.value&&_(n.value),g("问题已解决");break;case"automation.takeover":A.value=null,n.value&&_(n.value);break;case"automation.error":r.value.push({type:e.type,time:I(),data:e.data}),g("自动化处置出现异常");break;case"automation.paused":r.value.push({type:e.type,time:I(),data:e.data}),n.value&&_(n.value),g(((T=e.data)==null?void 0:T.resume_hint)||"任务已暂停");break;case"automation.resumed":r.value.push({type:e.type,time:I(),data:e.data}),n.value&&(_(n.value),E(n.value));break;case"automation.info_corrected":r.value.push({type:e.type,time:I(),data:e.data}),n.value&&E(n.value);break;case"automation.info_sup
|