`,f.children[0].getAttribute("foo")):(f.innerHTML=e,f.textContent)},isBuiltInComponent:e=>"Transition"===e||"transition"===e?aL:"TransitionGroup"===e||"transition-group"===e?a$:void 0,getNamespace(e,t,n){let r=t?t.ns:n;if(t&&2===r)if("annotation-xml"===t.tag){if("svg"===e)return 1;t.props.some(e=>6===e.type&&"encoding"===e.name&&null!=e.value&&("text/html"===e.value.content||"application/xhtml+xml"===e.value.content))&&(r=0)}else/^m(?:[ions]|text)$/.test(t.tag)&&"mglyph"!==e&&"malignmark"!==e&&(r=0);else t&&1===r&&("foreignObject"===t.tag||"desc"===t.tag||"title"===t.tag)&&(r=0);if(0===r){if("svg"===e)return 1;if("math"===e)return 2}return r}},aD=y("passive,once,capture"),aV=y("stop,prevent,self,ctrl,shift,alt,meta,exact,middle"),aj=y("left,right"),aB=y("onkeyup,onkeydown,onkeypress"),aU=(e,t)=>s3(e)&&"onclick"===e.content.toLowerCase()?sU(t,!0):4!==e.type?sH(["(",e,`) === "onClick" ? "${t}" : (`,e,")"]):e,aH=(e,t)=>{1===e.type&&0===e.tagType&&("script"===e.tag||"style"===e.tag)&&t.removeNode()},aq=[e=>{1===e.type&&e.props.forEach((t,n)=>{let r,i;6===t.type&&"style"===t.name&&t.value&&(e.props[n]={type:7,name:"bind",arg:sU("style",!0,t.loc),exp:(r=t.value.content,i=t.loc,sU(JSON.stringify(er(r)),!1,i,3)),modifiers:[],loc:t.loc})})}],aW={cloak:()=>({props:[]}),html:(e,t,n)=>{let{exp:r,loc:i}=e;return r||n.onError(s6(54,i)),t.children.length&&(n.onError(s6(55,i)),t.children.length=0),{props:[sB(sU("innerHTML",!0,i),r||sU("",!0))]}},text:(e,t,n)=>{let{exp:r,loc:i}=e;return r||n.onError(s6(56,i)),t.children.length&&(n.onError(s6(57,i)),t.children.length=0),{props:[sB(sU("textContent",!0),r?oX(r,n)>0?r:sq(n.helperString(sy),[r],i):sU("",!0))]}},model:(e,t,n)=>{let r=ax(e,t,n);if(!r.props.length||1===t.tagType)return r;e.arg&&n.onError(s6(59,e.arg.loc));let{tag:i}=t,l=n.isCustomElement(i);if("input"===i||"textarea"===i||"select"===i||l){let s=aE,o=!1;if("input"===i||l){let r=oi(t,"type");if(r){if(7===r.type)s=aR;else if(r.value)switch(r.value.content){case"radio":s=aN;break;case"checkbox":s=aA;break;case"file":o=!0,n.onError(s6(60,e.loc))}}else t.props.some(e=>7===e.type&&"bind"===e.name&&(!e.arg||4!==e.arg.type||!e.arg.isStatic))&&(s=aR)}else"select"===i&&(s=aI);o||(r.needRuntime=n.helper(s))}else n.onError(s6(58,e.loc));return r.props=r.props.filter(e=>4!==e.key.type||"modelValue"!==e.key.content),r},on:(e,t,n)=>am(e,t,n,t=>{let{modifiers:r}=e;if(!r.length)return t;let{key:i,value:l}=t.props[0],{keyModifiers:s,nonKeyModifiers:o,eventOptionModifiers:a}=((e,t,n,r)=>{let i=[],l=[],s=[];for(let n=0;n
{let{exp:r,loc:i}=e;return r||n.onError(s6(62,i)),{props:[],needRuntime:n.helper(aP)}}},aK=Object.create(null);function az(e,t){if(!R(e))if(!e.nodeType)return S;else e=e.innerHTML;let n=e+JSON.stringify(t,(e,t)=>"function"==typeof t?t.toString():t),r=aK[n];if(r)return r;if("#"===e[0]){let t=document.querySelector(e);e=t?t.innerHTML:""}let i=T({hoistStatic:!0,onError:void 0,onWarn:S},t);!i.isCustomElement&&"u">typeof customElements&&(i.isCustomElement=e=>!!customElements.get(e));let{code:l}=function(e,t={}){return function(e,t={}){var n;let r,i=t.onError||s1,l="module"===t.mode;!0===t.prefixIdentifiers?i(s6(48)):l&&i(s6(49)),t.cacheHandlers&&i(s6(50)),t.scopeId&&!l&&i(s6(51));let s=T({},t,{prefixIdentifiers:!1}),o=R(e)?function(e,t){if(oO.reset(),oC=null,ok=null,oT="",ow=-1,oN=-1,oR.length=0,ox=e,o_=T({},ob),t){let e;for(e in t)null!=t[e]&&(o_[e]=t[e])}oO.mode="html"===o_.parseMode?1:2*("sfc"===o_.parseMode),oO.inXML=1===o_.ns||2===o_.ns;let n=t&&t.delimiters;n&&(oO.delimiterOpen=sY(n[0]),oO.delimiterClose=sY(n[1]));let r=oS=function(e,t=""){return{type:0,source:t,children:e,helpers:new Set,components:[],directives:[],hoists:[],imports:[],cached:[],temps:0,codegenNode:void 0,loc:sF}}([],e);return oO.parse(ox),r.loc=oW(0,e.length),r.children=oU(r.children),oS=null,r}(e,s):e,[a,c]=[[aw,aS,ae,aT,ai,ag,ad,aa,ab],{on:am,bind:av,model:ax}];return r=function(e,{filename:t="",prefixIdentifiers:n=!1,hoistStatic:r=!1,hmr:i=!1,cacheHandlers:l=!1,nodeTransforms:s=[],directiveTransforms:o={},transformHoist:a=null,isBuiltInComponent:c=S,isCustomElement:u=S,expressionPlugins:d=[],scopeId:h=null,slotted:p=!0,ssr:f=!1,inSSR:g=!1,ssrCssVars:m="",bindingMetadata:y=b,inline:_=!1,isTS:x=!1,onError:C=s1,onWarn:k=s2,compatConfig:T}){let w=t.replace(/\?.*$/,"").match(/([^/\\]+)\.\w+$/),N={filename:t,selfName:w&&q(B(w[1])),prefixIdentifiers:n,hoistStatic:r,hmr:i,cacheHandlers:l,nodeTransforms:s,directiveTransforms:o,transformHoist:a,isBuiltInComponent:c,isCustomElement:u,expressionPlugins:d,scopeId:h,slotted:p,ssr:f,inSSR:g,ssrCssVars:m,bindingMetadata:y,inline:_,isTS:x,onError:C,onWarn:k,compatConfig:T,root:e,helpers:new Map,components:new Set,directives:new Set,hoists:[],imports:[],cached:[],constantCache:new WeakMap,temps:0,identifiers:Object.create(null),scopes:{vFor:0,vSlot:0,vPre:0,vOnce:0},parent:null,grandParent:null,currentNode:e,childIndex:0,inVOnce:!1,helper(e){let t=N.helpers.get(e)||0;return N.helpers.set(e,t+1),e},removeHelper(e){let t=N.helpers.get(e);if(t){let n=t-1;n?N.helpers.set(e,n):N.helpers.delete(e)}},helperString:e=>`_${s$[N.helper(e)]}`,replaceNode(e){N.parent.children[N.childIndex]=N.currentNode=e},removeNode(e){let t=N.parent.children,n=e?t.indexOf(e):N.currentNode?N.childIndex:-1;e&&e!==N.currentNode?N.childIndex>n&&(N.childIndex--,N.onNodeRemoved()):(N.currentNode=null,N.onNodeRemoved()),N.parent.children.splice(n,1)},onNodeRemoved:S,addIdentifiers(e){},removeIdentifiers(e){},hoist(e){R(e)&&(e=sU(e)),N.hoists.push(e);let t=sU(`_hoisted_${N.hoists.length}`,!1,e.loc,2);return t.hoisted=e,t},cache(e,t=!1,n=!1){let r=function(e,t,n=!1,r=!1){return{type:20,index:e,value:t,needPauseTracking:n,inVOnce:r,needArraySpread:!1,loc:sF}}(N.cached.length,e,t,n);return N.cached.push(r),r}};return N}(o,n=T({},s,{nodeTransforms:[...a,...t.nodeTransforms||[]],directiveTransforms:T({},c,t.directiveTransforms||{})})),o0(o,r),n.hoistStatic&&function e(t,n,r,i=!1,l=!1){let{children:s}=t,o=[];for(let n=0;n0){if(e>=2){a.codegenNode.patchFlag=-1,o.push(a);continue}}else{let e=a.codegenNode;if(13===e.type){let t=e.patchFlag;if((void 0===t||512===t||1===t)&&oZ(a,r)>=2){let t=oY(a);t&&(e.props=r.hoist(t))}e.dynamicProps&&(e.dynamicProps=r.hoist(e.dynamicProps))}}}else if(12===a.type&&(i?0:oX(a,r))>=2){14===a.codegenNode.type&&a.codegenNode.arguments.length>0&&a.codegenNode.arguments.push("-1"),o.push(a);continue}if(1===a.type){let n=1===a.tagType;n&&r.scopes.vSlot++,e(a,t,r,!1,l),n&&r.scopes.vSlot--}else if(11===a.type)e(a,t,r,1===a.children.length,!0);else if(9===a.type)for(let n=0;ne.key===t||e.key.content===t);return n&&n.value}}o.length&&r.transformHoist&&r.transformHoist(s,r,t)}(o,void 0,r,!!oG(o)),n.ssr||function(e,t){let{helper:n}=t,{children:r}=e;if(1===r.length){let n=oG(e);if(n&&n.codegenNode){let r=n.codegenNode;13===r.type&&sz(r,t),e.codegenNode=r}else e.codegenNode=r[0]}else r.length>1&&(e.codegenNode=sD(t,n(l5),void 0,e.children,64,void 0,void 0,!0,void 0,!1))}(o,r),o.helpers=new Set([...r.helpers.keys()]),o.components=[...r.components],o.directives=[...r.directives],o.imports=r.imports,o.hoists=r.hoists,o.temps=r.temps,o.cached=r.cached,o.transformed=!0,function(e,t={}){let n=function(e,{mode:t="function",prefixIdentifiers:n="module"===t,sourceMap:r=!1,filename:i="template.vue.html",scopeId:l=null,optimizeImports:s=!1,runtimeGlobalName:o="Vue",runtimeModuleName:a="vue",ssrRuntimeModuleName:c="vue/server-renderer",ssr:u=!1,isTS:d=!1,inSSR:h=!1}){let p={mode:t,prefixIdentifiers:n,sourceMap:r,filename:i,scopeId:l,optimizeImports:s,runtimeGlobalName:o,runtimeModuleName:a,ssrRuntimeModuleName:c,ssr:u,isTS:d,inSSR:h,source:e.source,code:"",column:1,line:1,offset:0,indentLevel:0,pure:!1,map:void 0,helper:e=>`_${s$[e]}`,push(e,t=-2,n){p.code+=e},indent(){f(++p.indentLevel)},deindent(e=!1){e?--p.indentLevel:f(--p.indentLevel)},newline(){f(p.indentLevel)}};function f(e){p.push(`
+`+" ".repeat(e),0)}return p}(e,t);t.onContextCreated&&t.onContextCreated(n);let{mode:r,push:i,prefixIdentifiers:l,indent:s,deindent:o,newline:a,ssr:c}=n,u=Array.from(e.helpers),d=u.length>0,h=!l&&"module"!==r;!function(e,t){let{push:n,newline:r,runtimeGlobalName:i}=t,l=Array.from(e.helpers);if(l.length>0&&(n(`const _Vue = ${i}
+`,-1),e.hoists.length)){let e=[sl,ss,so,sa,sc].filter(e=>l.includes(e)).map(o6).join(", ");n(`const { ${e} } = _Vue
+`,-1)}(function(e,t){if(!e.length)return;t.pure=!0;let{push:n,newline:r}=t;r();for(let i=0;i0)&&a()),e.directives.length&&(o3(e.directives,"directive",n),e.temps>0&&a()),e.temps>0){i("let ");for(let t=0;t0?", ":""}_temp${t}`)}return(e.components.length||e.directives.length||e.temps)&&(i(`
+`,0),a()),c||i("return "),e.codegenNode?o5(e.codegenNode,n):i("null"),h&&(o(),i("}")),o(),i("}"),{ast:e,code:n.code,preamble:"",map:n.map?n.map.toJSON():void 0}}(o,s)}(e,T({},aF,t,{nodeTransforms:[aH,...aq,...t.nodeTransforms||[]],directiveTransforms:T({},aW,t.directiveTransforms||{}),transformHoist:null}))}(e,i),s=Function(l)();return s._rc=!0,aK[n]=s}return iM(az),e.BaseTransition=nb,e.BaseTransitionPropsValidators=nm,e.Comment=r9,e.DeprecationTypes=null,e.EffectScope=em,e.ErrorCodes={SETUP_FUNCTION:0,0:"SETUP_FUNCTION",RENDER_FUNCTION:1,1:"RENDER_FUNCTION",NATIVE_EVENT_HANDLER:5,5:"NATIVE_EVENT_HANDLER",COMPONENT_EVENT_HANDLER:6,6:"COMPONENT_EVENT_HANDLER",VNODE_HOOK:7,7:"VNODE_HOOK",DIRECTIVE_HOOK:8,8:"DIRECTIVE_HOOK",TRANSITION_HOOK:9,9:"TRANSITION_HOOK",APP_ERROR_HANDLER:10,10:"APP_ERROR_HANDLER",APP_WARN_HANDLER:11,11:"APP_WARN_HANDLER",FUNCTION_REF:12,12:"FUNCTION_REF",ASYNC_COMPONENT_LOADER:13,13:"ASYNC_COMPONENT_LOADER",SCHEDULER:14,14:"SCHEDULER",COMPONENT_UPDATE:15,15:"COMPONENT_UPDATE",APP_UNMOUNT_CLEANUP:16,16:"APP_UNMOUNT_CLEANUP"},e.ErrorTypeStrings=null,e.Fragment=r8,e.KeepAlive={name:"KeepAlive",__isKeepAlive:!0,props:{include:[String,RegExp,Array],exclude:[String,RegExp,Array],max:[String,Number]},setup(e,{slots:t}){let n=iN(),r=n.ctx,i=new Map,l=new Set,s=null,o=n.suspense,{renderer:{p:a,m:c,um:u,o:{createElement:d}}}=r,h=d("div");function p(e){nG(e),u(e,n,o,!0)}function f(e){i.forEach((t,n)=>{let r=iD(nU(t)?t.type.__asyncResolved||{}:t.type);r&&!e(r)&&g(n)})}function g(e){let t=i.get(e);!t||s&&iu(t,s)?s&&nG(s):p(t),i.delete(e),l.delete(e)}r.activate=(e,t,n,r,i)=>{let l=e.component;c(e,t,n,0,o),a(l.vnode,e,t,n,l,o,r,e.slotScopeIds,i),rW(()=>{l.isDeactivated=!1,l.a&&z(l.a);let t=e.props&&e.props.onVnodeMounted;t&&iC(t,l.parent,e)},o)},r.deactivate=e=>{let t=e.component;rZ(t.m),rZ(t.a),c(e,h,null,1,o),rW(()=>{t.da&&z(t.da);let n=e.props&&e.props.onVnodeUnmounted;n&&iC(n,t.parent,e),t.isDeactivated=!0},o)},t7(()=>[e.include,e.exclude],([e,t])=>{e&&f(t=>nW(e,t)),t&&f(e=>!nW(t,e))},{flush:"post",deep:!0});let m=null,y=()=>{null!=m&&(rY(n.subTree.type)?rW(()=>{i.set(m,nX(n.subTree))},n.subTree.suspense):i.set(m,nX(n.subTree)))};return n0(y),n2(y),n6(()=>{i.forEach(e=>{let{subTree:t,suspense:r}=n,i=nX(t);if(e.type===i.type&&e.key===i.key){nG(i);let e=i.component.da;e&&rW(e,r);return}p(e)})}),()=>{if(m=null,!t.default)return s=null;let n=t.default(),r=n[0];if(n.length>1)return s=null,n;if(!ic(r)||!(4&r.shapeFlag)&&!(128&r.shapeFlag))return s=null,r;let o=nX(r);if(o.type===r9)return s=null,o;let a=o.type,c=iD(nU(o)?o.type.__asyncResolved||{}:a),{include:u,exclude:d,max:h}=e;if(u&&(!c||!nW(u,c))||d&&c&&nW(d,c))return o.shapeFlag&=-257,s=o,r;let p=null==o.key?a:o.key,f=i.get(p);return o.el&&(o=iv(o),128&r.shapeFlag&&(r.ssContent=o)),m=p,f?(o.el=f.el,o.component=f.component,o.transition&&nk(o,o.transition),o.shapeFlag|=512,l.delete(p),l.add(p)):(l.add(p),h&&l.size>parseInt(h,10)&&g(l.values().next().value)),o.shapeFlag|=256,s=o,rY(r.type)?r:o}}},e.ReactiveEffect=ey,e.Static=r7,e.Suspense={name:"Suspense",__isSuspense:!0,process(e,t,n,r,i,l,s,o,a,c){if(null==e)!function(e,t,n,r,i,l,s,o,a){let{p:c,o:{createElement:u}}=a,d=u("div"),h=e.suspense=r2(e,i,r,t,d,n,l,s,o,a);c(null,h.pendingBranch=e.ssContent,d,null,r,h,l,s),h.deps>0?(r1(e,"onPending"),r1(e,"onFallback"),c(null,e.ssFallback,t,n,r,null,l,s),r4(h,e.ssFallback)):h.resolve(!1,!0)}(t,n,r,i,l,s,o,a,c);else{if(l&&l.deps>0&&!e.suspense.isInFallback){t.suspense=e.suspense,t.suspense.vnode=t,t.el=e.el;return}!function(e,t,n,r,i,l,s,o,{p:a,um:c,o:{createElement:u}}){let d=t.suspense=e.suspense;d.vnode=t,t.el=e.el;let h=t.ssContent,p=t.ssFallback,{activeBranch:f,pendingBranch:g,isInFallback:m,isHydrating:y}=d;if(g)d.pendingBranch=h,iu(g,h)?(a(g,h,d.hiddenContainer,null,i,d,l,s,o),d.deps<=0?d.resolve():m&&!y&&(a(f,p,n,r,i,null,l,s,o),r4(d,p))):(d.pendingId=r0++,y?(d.isHydrating=!1,d.activeBranch=g):c(g,i,d),d.deps=0,d.effects.length=0,d.hiddenContainer=u("div"),m?(a(null,h,d.hiddenContainer,null,i,d,l,s,o),d.deps<=0?d.resolve():(a(f,p,n,r,i,null,l,s,o),r4(d,p))):f&&iu(f,h)?(a(f,h,n,r,i,d,l,s,o),d.resolve(!0)):(a(null,h,d.hiddenContainer,null,i,d,l,s,o),d.deps<=0&&d.resolve()));else if(f&&iu(f,h))a(f,h,n,r,i,d,l,s,o),r4(d,h);else if(r1(t,"onPending"),d.pendingBranch=h,512&h.shapeFlag?d.pendingId=h.component.suspenseId:d.pendingId=r0++,a(null,h,d.hiddenContainer,null,i,d,l,s,o),d.deps<=0)d.resolve();else{let{timeout:e,pendingId:t}=d;e>0?setTimeout(()=>{d.pendingId===t&&d.fallback(p)},e):0===e&&d.fallback(p)}}(e,t,n,r,i,s,o,a,c)}},hydrate:function(e,t,n,r,i,l,s,o,a){let c=t.suspense=r2(t,r,n,e.parentNode,document.createElement("div"),null,i,l,s,o,!0),u=a(e,c.pendingBranch=t.ssContent,n,c,l,s);return 0===c.deps&&c.resolve(!1,!0),u},normalize:function(e){let{shapeFlag:t,children:n}=e,r=32&t;e.ssContent=r6(r?n.default:n),e.ssFallback=r?r6(n.fallback):ig(r9)}},e.Teleport=na,e.Text=r5,e.TrackOpTypes={GET:"get",HAS:"has",ITERATE:"iterate"},e.Transition=iY,e.TransitionGroup=lR,e.TriggerOpTypes={SET:"set",ADD:"add",DELETE:"delete",CLEAR:"clear"},e.VueElement=lT,e.assertNumber=function(e,t){},e.callWithAsyncErrorHandling=tD,e.callWithErrorHandling=tF,e.camelize=B,e.capitalize=q,e.cloneVNode=iv,e.compatUtils=null,e.compile=az,e.computed=iV,e.createApp=l6,e.createBlock=ia,e.createCommentVNode=function(e="",t=!1){return t?(ir(),ia(r9,null,e)):ig(r9,null,e)},e.createElementBlock=function(e,t,n,r,i,l){return io(ip(e,t,n,r,i,l,!0))},e.createElementVNode=ip,e.createHydrationRenderer=rK,e.createPropsRestProxy=function(e,t){let n={};for(let r in e)t.includes(r)||Object.defineProperty(n,r,{enumerable:!0,get:()=>e[r]});return n},e.createRenderer=function(e){return rz(e)},e.createSSRApp=l3,e.createSlots=function(e,t){for(let n=0;n{let t=r.fn(...e);return t&&(t.key=r.key),t}:r.fn)}return e},e.createStaticVNode=function(e,t){let n=ig(r7,null,e);return n.staticCount=t,n},e.createTextVNode=iy,e.createVNode=ig,e.customRef=tE,e.defineAsyncComponent=function(e){let t;I(e)&&(e={loader:e});let{loader:n,loadingComponent:r,errorComponent:i,delay:l=200,hydrate:s,timeout:o,suspensible:a=!0,onError:c}=e,u=null,d=0,h=()=>{let e;return u||(e=u=n().catch(e=>{if(e=e instanceof Error?e:Error(String(e)),c)return new Promise((t,n)=>{c(e,()=>t((d++,u=null,h())),()=>n(e),d+1)});throw e}).then(n=>e!==u&&u?u:(n&&(n.__esModule||"Module"===n[Symbol.toStringTag])&&(n=n.default),t=n,n)))};return nw({name:"AsyncComponentWrapper",__asyncLoader:h,__asyncHydrate(e,n,r){let i=!1;(n.bu||(n.bu=[])).push(()=>i=!0);let l=()=>{i||r()},o=s?()=>{let t=s(l,t=>(function(e,t){if(nL(e)&&"["===e.data){let n=1,r=e.nextSibling;for(;r;){if(1===r.nodeType){if(!1===t(r))break}else if(nL(r))if("]"===r.data){if(0==--n)break}else"["===r.data&&n++;r=r.nextSibling}}else t(e)})(e,t));t&&(n.bum||(n.bum=[])).push(t)}:l;t?o():h().then(()=>!n.isUnmounted&&o())},get __asyncResolved(){return t},setup(){let e=iw;if(nN(e),t)return()=>nH(t,e);let n=t=>{u=null,tV(t,e,13,!i)};if(a&&e.suspense)return h().then(t=>()=>nH(t,e)).catch(e=>(n(e),()=>i?ig(i,{error:e}):null));let s=tS(!1),c=tS(),d=tS(!!l);return l&&setTimeout(()=>{d.value=!1},l),null!=o&&setTimeout(()=>{if(!s.value&&!c.value){let e=Error(`Async component timed out after ${o}ms.`);n(e),c.value=e}},o),h().then(()=>{s.value=!0,e.parent&&nq(e.parent.vnode)&&e.parent.update()}).catch(e=>{n(e),c.value=e}),()=>s.value&&t?nH(t,e):c.value&&i?ig(i,{error:c.value}):r&&!d.value?nH(r,e):void 0}})},e.defineComponent=nw,e.defineCustomElement=lC,e.defineEmits=function(){return null},e.defineExpose=function(e){},e.defineModel=function(){},e.defineOptions=function(e){},e.defineProps=function(){return null},e.defineSSRCustomElement=(e,t)=>lC(e,t,l3),e.defineSlots=function(){return null},e.devtools=void 0,e.effect=function(e,t){e.effect instanceof ey&&(e=e.effect.fn);let n=new ey(e);t&&T(n,t);try{n.run()}catch(e){throw n.stop(),e}let r=n.run.bind(n);return r.effect=n,r},e.effectScope=function(e){return new em(e)},e.getCurrentInstance=iN,e.getCurrentScope=function(){return l},e.getCurrentWatcher=function(){return g},e.getTransitionRawChildren=nT,e.guardReactiveProps=im,e.h=ij,e.handleError=tV,e.hasInjectionContext=function(){return!!(iN()||rx)},e.hydrate=(...e)=>{l1().hydrate(...e)},e.hydrateOnIdle=(e=1e4)=>t=>{let n=nj(t,{timeout:e});return()=>nB(n)},e.hydrateOnInteraction=(e=[])=>(t,n)=>{R(e)&&(e=[e]);let r=!1,i=e=>{r||(r=!0,l(),t(),e.target.dispatchEvent(new e.constructor(e.type,e)))},l=()=>{n(t=>{for(let n of e)t.removeEventListener(n,i)})};return n(t=>{for(let n of e)t.addEventListener(n,i,{once:!0})}),l},e.hydrateOnMediaQuery=e=>t=>{if(e){let n=matchMedia(e);if(!n.matches)return n.addEventListener("change",t,{once:!0}),()=>n.removeEventListener("change",t);t()}},e.hydrateOnVisible=e=>(t,n)=>{let r=new IntersectionObserver(e=>{for(let n of e)if(n.isIntersecting){r.disconnect(),t();break}},e);return n(e=>{if(e instanceof Element){if(function(e){let{top:t,left:n,bottom:r,right:i}=e.getBoundingClientRect(),{innerHeight:l,innerWidth:s}=window;return(t>0&&t0&&r0&&n0&&ir.disconnect()},e.initCustomFormatter=function(){},e.initDirectivesForSSR=S,e.inject=t8,e.isMemoSame=iB,e.isProxy=tg,e.isReactive=th,e.isReadonly=tp,e.isRef=t_,e.isRuntimeOnly=()=>!d,e.isShallow=tf,e.isVNode=ic,e.markRaw=tv,e.mergeDefaults=function(e,t){let n=rc(e);for(let e in t){if(e.startsWith("__skip"))continue;let r=n[e];r?E(r)||I(r)?r=n[e]={type:r,default:t[e]}:r.default=t[e]:null===r&&(r=n[e]={default:t[e]}),r&&t[`__skip_${e}`]&&(r.skipFactory=!0)}return n},e.mergeModels=function(e,t){return e&&t?E(e)&&E(t)?e.concat(t):T({},rc(e),rc(t)):e||t},e.mergeProps=ix,e.nextTick=tz,e.nodeOps=iz,e.normalizeClass=ei,e.normalizeProps=function(e){if(!e)return null;let{class:t,style:n}=e;return t&&!R(t)&&(e.class=ei(t)),n&&(e.style=Y(n)),e},e.normalizeStyle=Y,e.onActivated=nK,e.onBeforeMount=nY,e.onBeforeUnmount=n6,e.onBeforeUpdate=n1,e.onDeactivated=nz,e.onErrorCaptured=n9,e.onMounted=n0,e.onRenderTracked=n5,e.onRenderTriggered=n8,e.onScopeDispose=function(e,t=!1){l&&l.cleanups.push(e)},e.onServerPrefetch=n4,e.onUnmounted=n3,e.onUpdated=n2,e.onWatcherCleanup=tL,e.openBlock=ir,e.patchProp=lS,e.popScopeId=function(){t1=null},e.provide=t4,e.proxyRefs=tN,e.pushScopeId=function(e){t1=e},e.queuePostFlushCb=tX,e.reactive=ta,e.readonly=tu,e.ref=tS,e.registerRuntimeCompiler=iM,e.render=l2,e.renderList=function(e,t,n,r){let i,l=n&&n[r],s=E(e);if(s||R(e)){let n=s&&th(e),r=!1,o=!1;n&&(r=!tf(e),o=tp(e),e=eU(e)),i=Array(e.length);for(let n=0,s=e.length;nt(e,n,void 0,l&&l[n]));else{let n=Object.keys(e);i=Array(n.length);for(let r=0,s=n.length;r0;return"default"!==t&&(n.name=t),ir(),ia(r8,null,[ig("slot",n,r&&r())],e?-2:64)}let l=e[t];l&&l._c&&(l._d=!1),ir();let s=l&&function e(t){return t.some(t=>!ic(t)||t.type!==r9&&(t.type!==r8||!!e(t.children)))?t:null}(l(n)),o=n.key||s&&s.key,a=ia(r8,{key:(o&&!O(o)?o:`_${t}`)+(!s&&r?"_fb":"")},s||(r?r():[]),s&&1===e._?64:-2);return!i&&a.scopeId&&(a.slotScopeIds=[a.scopeId+"-s"]),l&&l._c&&(l._d=!0),a},e.resolveComponent=function(e,t){return rt(n7,e,!0,t)||e},e.resolveDirective=function(e){return rt("directives",e)},e.resolveDynamicComponent=function(e){return R(e)?rt(n7,e,!1)||e:e||re},e.resolveFilter=null,e.resolveTransitionHooks=nS,e.setBlockTracking=is,e.setDevtoolsHook=S,e.setTransitionHooks=nk,e.shallowReactive=tc,e.shallowReadonly=function(e){return td(e,!0,e8,tr,to)},e.shallowRef=tx,e.ssrContextKey=t5,e.ssrUtils=null,e.stop=function(e){e.effect.stop()},e.toDisplayString=ep,e.toHandlerKey=W,e.toHandlers=function(e,t){let n={};for(let r in e)n[t&&/[A-Z]/.test(r)?`on:${r}`:W(r)]=e[r];return n},e.toRaw=tm,e.toRef=function(e,t,n){if(t_(e))return e;if(I(e))return new tR(e);if(!M(e)||!(arguments.length>1))return tS(e);return new tI(e,t,n)},e.toRefs=function(e){let t=E(e)?Array(e.length):{};for(let n in e)t[n]=new tI(e,n,void 0);return t},e.toValue=function(e){return I(e)?e():tT(e)},e.transformVNodeArgs=function(e){},e.triggerRef=function(e){e.dep&&e.dep.trigger()},e.unref=tT,e.useAttrs=function(){return ra().attrs},e.useCssModule=function(e="$style"){return b},e.useCssVars=function(e){let t=iN();if(!t)return;let n=t.ut=(n=e(t.proxy))=>{Array.from(document.querySelectorAll(`[data-v-owner="${t.uid}"]`)).forEach(e=>ls(e,n))},r=()=>{let r=e(t.proxy);t.ce?ls(t.ce,r):function e(t,n){if(128&t.shapeFlag){let r=t.suspense;t=r.activeBranch,r.pendingBranch&&!r.isHydrating&&r.effects.push(()=>{e(r.activeBranch,n)})}for(;t.component;)t=t.component.subTree;if(1&t.shapeFlag&&t.el)ls(t.el,n);else if(t.type===r8)t.children.forEach(t=>e(t,n));else if(t.type===r7){let{el:e,anchor:r}=t;for(;e&&(ls(e,n),e!==r);)e=e.nextSibling}}(t.subTree,r),n(r)};n1(()=>{tX(r)}),n0(()=>{t7(r,S,{flush:"post"});let e=new MutationObserver(r);e.observe(t.subTree.el.parentNode,{childList:!0}),n3(()=>e.disconnect())})},e.useHost=lw,e.useId=function(){let e=iN();return e?(e.appContext.config.idPrefix||"v")+"-"+e.ids[0]+e.ids[1]++:""},e.useModel=function(e,t,n=b){let r=iN(),i=B(t),l=H(t),s=rC(e,i),o=tE((s,o)=>{let a,c,u=b;return t9(()=>{let t=e[i];K(a,t)&&(a=t,o())}),{get:()=>(s(),n.get?n.get(a):a),set(e){let s=n.set?n.set(e):e;if(!K(s,a)&&!(u!==b&&K(e,u)))return;let d=r.vnode.props;d&&(t in d||i in d||l in d)&&(`onUpdate:${t}`in d||`onUpdate:${i}`in d||`onUpdate:${l}`in d)||(a=e,o()),r.emit(`update:${t}`,s),K(e,s)&&K(e,u)&&!K(s,c)&&o(),u=e,c=s}}});return o[Symbol.iterator]=()=>{let e=0;return{next:()=>e<2?{value:e++?s||b:o,done:!1}:{done:!0}}},o},e.useSSRContext=()=>{},e.useShadowRoot=function(){let e=lw();return e&&e.shadowRoot},e.useSlots=function(){return ra().slots},e.useTemplateRef=function(e){let t=iN(),n=tx(null);return t&&Object.defineProperty(t.refs===b?t.refs={}:t.refs,e,{enumerable:!0,get:()=>n.value,set:e=>n.value=e}),n},e.useTransitionState=nf,e.vModelCheckbox=lU,e.vModelDynamic={created(e,t,n){lG(e,t,n,null,"created")},mounted(e,t,n){lG(e,t,n,null,"mounted")},beforeUpdate(e,t,n,r){lG(e,t,n,r,"beforeUpdate")},updated(e,t,n,r){lG(e,t,n,r,"updated")}},e.vModelRadio=lq,e.vModelSelect=lW,e.vModelText=lB,e.vShow={name:"show",beforeMount(e,{value:t},{transition:n}){e[ln]="none"===e.style.display?"":e.style.display,n&&t?n.beforeEnter(e):li(e,t)},mounted(e,{value:t},{transition:n}){n&&t&&n.enter(e)},updated(e,{value:t,oldValue:n},{transition:r}){!t!=!n&&(r?t?(r.beforeEnter(e),li(e,!0),r.enter(e)):r.leave(e,()=>{li(e,!1)}):li(e,t))},beforeUnmount(e,{value:t}){li(e,t)}},e.version=iU,e.warn=S,e.watch=function(e,t,n){return t7(e,t,n)},e.watchEffect=function(e,t){return t7(e,null,t)},e.watchPostEffect=function(e,t){return t7(e,null,{flush:"post"})},e.watchSyncEffect=t9,e.withAsyncContext=function(e){let t=iN(),n=e();iE();let r=()=>{iN()!==t&&t.scope.off(),iE()};return P(n)&&(n=n.catch(e=>{throw iA(t),Promise.resolve().then(()=>Promise.resolve().then(r)),e})),[n,()=>{iA(t),Promise.resolve().then(r)}]},e.withCtx=t6,e.withDefaults=function(e,t){return null},e.withDirectives=function(e,t){if(null===t0)return e;let n=iF(t0),r=e.dirs||(e.dirs=[]);for(let e=0;e{let n=e._withKeys||(e._withKeys={}),r=t.join(".");return n[r]||(n[r]=n=>{if(!("key"in n))return;let r=H(n.key);if(t.some(e=>e===r||lZ[e]===r))return e(n)})},e.withMemo=function(e,t,n,r){let i=n[r];if(i&&iB(i,e))return i;let l=t();return l.memo=e.slice(),l.cacheIndex=r,n[r]=l},e.withModifiers=(e,t)=>{if(!e)return e;let n=e._withMods||(e._withMods={}),r=t.join(".");return n[r]||(n[r]=(n,...r)=>{for(let e=0;et6,e}({});
diff --git a/app/tests/__init__.py b/app/tests/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/app/tests/test_generation_strategy.py b/app/tests/test_generation_strategy.py
new file mode 100644
index 0000000..535c90a
--- /dev/null
+++ b/app/tests/test_generation_strategy.py
@@ -0,0 +1,89 @@
+from __future__ import annotations
+
+import unittest
+
+from server import (
+ resolve_build_workers,
+ resolve_extract_workers,
+ resolve_generation_strategy,
+ resolve_image_delivery_options,
+ resolve_memory_reclaim_options,
+ resolve_single_generation_mode,
+)
+
+
+class TestGenerationStrategy(unittest.TestCase):
+ def test_default_without_performance_uses_page_template_cache(self) -> None:
+ self.assertEqual(resolve_generation_strategy({}, total_records=1), "legacy")
+ self.assertEqual(resolve_generation_strategy({}, total_records=5), "page_template_cache")
+
+ def test_page_template_cache_requires_min_records(self) -> None:
+ cfg = {
+ "performance": {
+ "generation_strategy": "page_template_cache",
+ "template_cache_min_records": 2,
+ "single_slide_output": True,
+ }
+ }
+ self.assertEqual(resolve_generation_strategy(cfg, total_records=1), "legacy")
+ self.assertEqual(resolve_generation_strategy(cfg, total_records=2), "page_template_cache")
+
+ def test_page_template_cache_respects_single_slide_output(self) -> None:
+ cfg = {
+ "performance": {
+ "generation_strategy": "page_template_cache",
+ "template_cache_min_records": 1,
+ "single_slide_output": False,
+ }
+ }
+ self.assertEqual(resolve_generation_strategy(cfg, total_records=3), "legacy")
+
+ def test_legacy_strategy_always_returns_legacy(self) -> None:
+ cfg = {
+ "performance": {
+ "generation_strategy": "legacy",
+ "template_cache_min_records": 1,
+ "single_slide_output": True,
+ }
+ }
+ self.assertEqual(resolve_generation_strategy(cfg, total_records=20), "legacy")
+
+ def test_image_delivery_defaults(self) -> None:
+ opts = resolve_image_delivery_options({})
+ self.assertEqual(int(opts.get("max_kbps", 0)), 300)
+ self.assertEqual(int(opts.get("chunk_size", 0)), 16 * 1024)
+
+ def test_image_delivery_disable_limit(self) -> None:
+ cfg = {"performance": {"image_delivery": {"enabled": False, "max_kbps": 999}}}
+ opts = resolve_image_delivery_options(cfg)
+ self.assertEqual(int(opts.get("max_kbps", -1)), 0)
+
+ def test_single_generation_mode_defaults_enabled(self) -> None:
+ self.assertTrue(resolve_single_generation_mode({}))
+ self.assertFalse(resolve_single_generation_mode({"performance": {"single_generation_mode": False}}))
+
+ def test_build_workers_default_single(self) -> None:
+ self.assertEqual(resolve_build_workers({}, total_records=10), 1)
+ cfg = {"performance": {"max_build_workers": 3}}
+ self.assertEqual(resolve_build_workers(cfg, total_records=2), 2)
+
+ def test_extract_workers_default_single(self) -> None:
+ self.assertEqual(resolve_extract_workers({}), 1)
+ cfg = {"performance": {"max_extract_workers": 4}}
+ self.assertGreaterEqual(resolve_extract_workers(cfg), 1)
+
+ def test_memory_reclaim_defaults_enabled(self) -> None:
+ opts = resolve_memory_reclaim_options({})
+ self.assertTrue(opts["enabled"])
+ self.assertTrue(opts["gc_collect"])
+ self.assertTrue(opts["malloc_trim"])
+
+ def test_memory_reclaim_can_disable(self) -> None:
+ opts = resolve_memory_reclaim_options({"performance": {"memory_reclaim": {"enabled": False}}})
+ self.assertFalse(opts["enabled"])
+ self.assertFalse(opts["gc_collect"])
+ self.assertFalse(opts["malloc_trim"])
+
+
+if __name__ == "__main__":
+ unittest.main()
diff --git a/app/tests/test_parse_amount_split.py b/app/tests/test_parse_amount_split.py
new file mode 100644
index 0000000..39e170a
--- /dev/null
+++ b/app/tests/test_parse_amount_split.py
@@ -0,0 +1,30 @@
+from __future__ import annotations
+
+import unittest
+
+from server import load_config, parse_records
+
+
+class TestParseAmountSplit(unittest.TestCase):
+ def test_amount_before_comma_and_term_after_comma(self) -> None:
+ config = load_config()
+ raw_text = "#接龙\n11、 四马桥一潘纪君 拜访门窗商户微信提现15万，存定期一年"
+
+ result = parse_records(raw_text, config, history=[])
+
+ records = result.get("new_records", [])
+ self.assertTrue(
+ any(
+ str(item.get("branch", "")) == "四马桥"
+ and str(item.get("type", "")) == "一年期定期"
+ and str(item.get("amount", "")) == "15万"
+ for item in records
+ )
+ )
+
+ skipped_reasons = [str(x.get("reason", "")) for x in result.get("skipped", [])]
+ self.assertNotIn("amount_not_found", skipped_reasons)
+
+
+if __name__ == "__main__":
+ unittest.main()
diff --git a/app/tests/test_services.py b/app/tests/test_services.py
new file mode 100644
index 0000000..3aba629
--- /dev/null
+++ b/app/tests/test_services.py
@@ -0,0 +1,163 @@
+from __future__ import annotations
+
+import threading
+import unittest
+from pathlib import Path
+
+from services.post_ops import (
+ run_history_clear,
+ run_mark_issue,
+)
+from services.workflows import (
+ run_correction_apply_api,
+ run_generate_api,
+ run_parse_api,
+)
+
+
+class ServiceTestBase(unittest.TestCase):
+ def setUp(self) -> None:
+ self.progress_calls: list[tuple[str, str, int, str, str]] = []
+
+ def base_ctx(self) -> dict:
+ lock = threading.Lock()
+
+ def set_progress(token: str, *, status: str, stage: str, percent: int, detail: str = "", error: str = ""):
+ self.progress_calls.append((token, status, int(percent), str(stage), str(detail or error)))
+
+ return {
+ "normalize_insurance_year": lambda v: str(v) if v in {"3", "5"} else None,
+ "normalize_insurance_year_choices": lambda v: v if isinstance(v, dict) else {},
+ "load_config": lambda: {
+ "relay_handling": {
+ "dedup": {"key_fields": ["branch", "amount", "type"]},
+ "parse_rules": {"line_pattern": r"^\\d+、\\s*"},
+ }
+ },
+ "resolve_history_path": lambda config: Path("/tmp/xibao_test_history.json"),
+ "resolve_template_path": lambda config, override=None: Path("/tmp/template.pptx"),
+ "resolve_output_dir": lambda config, override=None: Path("/tmp/xibao_output"),
+ "load_history": lambda history_path: [],
+ "save_history": lambda history_path, records: None,
+ "parse_records": lambda raw_text, config, history, insurance_year_choice, insurance_year_choices: {
+ "has_trigger": True,
+ "records": [],
+ "new_records": [],
+ "skipped": [],
+ },
+ "generate_records": lambda new_records, config, template_path, output_dir, progress_cb=None: {
+ "generated_count": len(new_records),
+ "generated": list(new_records),
+ "download_images": [],
+ },
+ "set_generation_progress": set_progress,
+ "append_review_log": lambda event, payload=None: "/tmp/review.jsonl",
+ "log_parse_skipped": lambda skipped, source: 0,
+ "append_new_history": lambda history_path, history, records, key_fields: {
+ "added": len(records),
+ "total": len(history) + len(records),
+ },
+ "upsert_issue_mark": lambda **kwargs: ({"id": "issue_1", **kwargs}, True),
+ "suppress_skip_item": lambda line, reason="": ({"id": "skip_1", "line": line, "reason": reason}, True),
+ "normalize_line": lambda line, pattern: str(line or "").strip(),
+ "normalize_branch_value": lambda value, config: str(value or "").strip(),
+ "normalize_amount_text": lambda value: str(value or "").strip(),
+ "normalize_status_value": lambda value, config: str(value or "").strip(),
+ "infer_page_from_type": lambda type_keyword, config: "page_2",
+ "apply_record_overrides": lambda record, overrides, config: {**record, **(overrides or {})},
+ "render_output_filename": lambda config, record, index: f"喜报_{index}.png",
+ "validate_record_for_generation": lambda record, config: None,
+ "upsert_history_records": lambda history_path, history, records, key_fields: {
+ "added": len(records),
+ "updated": 0,
+ },
+ "infer_correction_rule_keyword": lambda **kwargs: "keyword",
+ "save_or_update_manual_rule": lambda **kwargs: {"keyword": kwargs.get("keyword", "keyword")},
+ "resolve_issue_marks_by_source_line": lambda source_line, reason="": {"count": 0, "ids": []},
+ "update_issue_mark": lambda **kwargs: {"id": kwargs.get("issue_id", "")},
+ "delete_issue_mark": lambda issue_id: True,
+ "cleanup_output_artifacts": lambda output_dir: {"removed_dirs": 0, "removed_files": 0},
+ "clear_skip_suppressions": lambda: 0,
+ "_HISTORY_LOCK": lock,
+ }
+
+
+class TestWorkflows(ServiceTestBase):
+ def test_run_parse_api_success(self) -> None:
+ ctx = self.base_ctx()
+ status, body = run_parse_api({"raw_text": "#接龙\n1、测试"}, ctx)
+ self.assertEqual(int(status), 200)
+ self.assertTrue(body.get("ok"))
+ self.assertIn("result", body)
+
+ def test_run_generate_api_requires_insurance(self) -> None:
+ ctx = self.base_ctx()
+
+ def parse_records(*args, **kwargs):
+ return {
+ "has_trigger": True,
+ "records": [],
+ "new_records": [{"branch": "营江路", "amount": "10万", "type": "一年期定期"}],
+ "skipped": [],
+ "needs_insurance_choice": True,
+ }
+
+ ctx["parse_records"] = parse_records
+ status, body = run_generate_api({"raw_text": "#接龙\n1、测试"}, ctx)
+ self.assertEqual(int(status), 400)
+ self.assertEqual(body.get("error_code"), "insurance_year_required")
+ self.assertTrue(any(item[1] == "need_input" for item in self.progress_calls))
+
+ def test_run_generate_api_success(self) -> None:
+ ctx = self.base_ctx()
+
+ def parse_records(*args, **kwargs):
+ return {
+ "has_trigger": True,
+ "records": [],
+ "new_records": [
+ {
+ "source_line": "1、营江路揽收现金10万存一年",
+ "raw_text": "营江路揽收现金10万存一年",
+ "branch": "营江路",
+ "amount": "10万",
+ "type": "一年期定期",
+ "page": "page_2",
+ "status": "揽收现金",
+ }
+ ],
+ "skipped": [],
+ "needs_insurance_choice": False,
+ "dedup_key_fields": ["branch", "amount", "type"],
+ }
+
+ ctx["parse_records"] = parse_records
+ status, body = run_generate_api({"raw_text": "#接龙\n1、测试", "save_history": True}, ctx)
+ self.assertEqual(int(status), 200)
+ self.assertTrue(body.get("ok"))
+ self.assertEqual(int(body.get("generated_count", 0)), 1)
+ self.assertTrue(any(item[1] == "done" for item in self.progress_calls))
+
+ def test_run_correction_apply_api_validation(self) -> None:
+ ctx = self.base_ctx()
+ status, body = run_correction_apply_api({}, ctx)
+ self.assertEqual(int(status), 400)
+ self.assertFalse(body.get("ok", True))
+
+
+class TestPostOps(ServiceTestBase):
+ def test_run_mark_issue_invalid_type(self) -> None:
+ ctx = self.base_ctx()
+ status, body = run_mark_issue({"mark_type": "bad", "source_line": "x"}, ctx)
+ self.assertEqual(int(status), 400)
+ self.assertIn("mark_type", body.get("error", ""))
+
+ def test_run_history_clear_success(self) -> None:
+ ctx = self.base_ctx()
+ status, body = run_history_clear(ctx)
+ self.assertEqual(int(status), 200)
+ self.assertTrue(body.get("ok"))
+
+
+if __name__ == "__main__":
+ unittest.main()
diff --git a/app/tests/test_status_alias.py b/app/tests/test_status_alias.py
new file mode 100644
index 0000000..99aa2b2
--- /dev/null
+++ b/app/tests/test_status_alias.py
@@ -0,0 +1,41 @@
+from __future__ import annotations
+
+import unittest
+
+from server import load_config, parse_records
+
+
+class TestStatusAlias(unittest.TestCase):
+ def test_collect_external_bank_maps_to_collect_other_bank(self) -> None:
+ config = load_config()
+ raw_text = "#接龙\n21、 濂溪揽收外行5.3万存一年"
+
+ result = parse_records(raw_text, config, history=[])
+ records = result.get("new_records", [])
+ self.assertTrue(
+ any(
+ str(item.get("branch", "")) == "濂溪"
+ and str(item.get("type", "")) == "一年期定期"
+ and str(item.get("status", "")) == "揽收他行"
+ for item in records
+ )
+ )
+
+ def test_transfer_external_bank_maps_to_transfer_other_bank(self) -> None:
+ config = load_config()
+ raw_text = "#接龙\n22、 潇水南路挖转外行20万存半年"
+
+ result = parse_records(raw_text, config, history=[])
+ records = result.get("new_records", [])
+ self.assertTrue(
+ any(
+ str(item.get("branch", "")) == "潇水南路"
+ and str(item.get("type", "")) == "六个月定期"
+ and str(item.get("status", "")) == "他行挖转"
+ for item in records
+ )
+ )
+
+
+if __name__ == "__main__":
+ unittest.main()
diff --git a/app/tests/test_wechat_bot_bridge_skip.py b/app/tests/test_wechat_bot_bridge_skip.py
new file mode 100644
index 0000000..d8fa260
--- /dev/null
+++ b/app/tests/test_wechat_bot_bridge_skip.py
@@ -0,0 +1,82 @@
+#!/usr/bin/env python3
+from __future__ import annotations
+
+import unittest
+from argparse import Namespace
+from pathlib import Path
+from tempfile import TemporaryDirectory
+
+from wechat_bot_bridge import WechatXibaoBridge
+
+
+class WechatBotBridgeSkipTests(unittest.TestCase):
+ def _new_bridge(self, tmp_dir: str) -> WechatXibaoBridge:
+ base = Path(tmp_dir)
+ args = Namespace(
+ wechat_base_url="http://127.0.0.1:18238",
+ xibao_base_url="http://127.0.0.1:8787",
+ wechat_auth_key="",
+ wechat_session_file=str(base / "session.json"),
+ sync_count=30,
+ poll_interval=2.0,
+ max_images=3,
+ once=True,
+ dry_run=True,
+ allow_from="",
+ state_file=str(base / "state.json"),
+ meta_file=str(base / "meta.json"),
+ daily_cleanup_time="00:10",
+ )
+ return WechatXibaoBridge(args)
+
+ def test_parse_skip_command(self) -> None:
+ with TemporaryDirectory() as tmp_dir:
+ bridge = self._new_bridge(tmp_dir)
+ cmd = bridge.parse_command("跳过3")
+ self.assertIsNotNone(cmd)
+ self.assertEqual(cmd.get("action"), "set_skip")
+ self.assertEqual(cmd.get("count"), "3")
+
+ cmd2 = bridge.parse_command("跳过（12）")
+ self.assertIsNotNone(cmd2)
+ self.assertEqual(cmd2.get("action"), "set_skip")
+ self.assertEqual(cmd2.get("count"), "12")
+
+ def test_apply_daily_skip_to_numbered_lines(self) -> None:
+ with TemporaryDirectory() as tmp_dir:
+ bridge = self._new_bridge(tmp_dir)
+ bridge.set_daily_skip("wxid_u1", 2)
+
+ raw = "#接龙\n1、第一条\n2、第二条\n3、第三条\n说明文本"
+ text, removed, requested = bridge.apply_daily_skip_to_raw_text("wxid_u1", raw)
+ self.assertEqual(requested, 2)
+ self.assertEqual(removed, 2)
+ self.assertIn("3、第三条", text)
+ self.assertNotIn("1、第一条", text)
+ self.assertNotIn("2、第二条", text)
+
+ def test_skip_zero_clears_setting(self) -> None:
+ with TemporaryDirectory() as tmp_dir:
+ bridge = self._new_bridge(tmp_dir)
+ bridge.set_daily_skip("wxid_u2", 5)
+ self.assertEqual(bridge.get_daily_skip("wxid_u2"), 5)
+ bridge.set_daily_skip("wxid_u2", 0)
+ self.assertEqual(bridge.get_daily_skip("wxid_u2"), 0)
+
+ def test_stale_daily_skip_is_invalidated(self) -> None:
+ with TemporaryDirectory() as tmp_dir:
+ bridge = self._new_bridge(tmp_dir)
+ bridge.meta["daily_skip"] = {
+ "wxid_old": {
+ "date": "2000-01-01",
+ "count": 3,
+ "updated_at": "2000-01-01T00:00:00",
+ }
+ }
+ value = bridge.get_daily_skip("wxid_old")
+ self.assertEqual(value, 0)
+ self.assertNotIn("wxid_old", bridge.meta.get("daily_skip", {}))
+
+
+if __name__ == "__main__":
+ unittest.main()
diff --git a/app/wechat_bot_bridge.py b/app/wechat_bot_bridge.py
new file mode 100644
index 0000000..c14a168
--- /dev/null
+++ b/app/wechat_bot_bridge.py
@@ -0,0 +1,1125 @@
+#!/usr/bin/env python3
+from __future__ import annotations
+
+import argparse
+import base64
+import hashlib
+import json
+import os
+import re
+import sys
+import time
+import urllib.error
+import urllib.parse
+import urllib.request
+from collections import deque
+from datetime import datetime
+from pathlib import Path
+from typing import Any, Iterable
+
+
+DEFAULT_WCPP_BASE_URL = os.environ.get("WCPP_BASE_URL", "http://127.0.0.1:18238")
+DEFAULT_XIBAO_BASE_URL = os.environ.get("XIBAO_BASE_URL", "https://zc.workyai.cn")
+DEFAULT_SESSION_FILE = Path(
+ os.environ.get("WCPP_SESSION_FILE", "/root/WeChatPadPro_test_20260227/webui/.session.json")
+)
+BASE_DIR = Path(__file__).resolve().parent
+DEFAULT_STATE_FILE = BASE_DIR / "data" / "wechat_bridge_state.json"
+DEFAULT_META_FILE = BASE_DIR / "data" / "wechat_bridge_meta.json"
+DEFAULT_DAILY_CLEANUP_TIME = os.environ.get("XIBAO_DAILY_CLEANUP_TIME", "00:10")
+RELAY_SERIAL_LINE_RE = re.compile(r"^\s*\d+\s*[、，,.．:：)\）]\s*")
+
+
+def log(msg: str) -> None:
+ stamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+ print(f"[{stamp}] {msg}", flush=True)
+
+
+def read_json_file(path: Path, fallback: Any) -> Any:
+ try:
+ if not path.exists():
+ return fallback
+ return json.loads(path.read_text(encoding="utf-8"))
+ except Exception:
+ return fallback
+
+
+def write_json_file(path: Path, data: Any) -> None:
+ path.parent.mkdir(parents=True, exist_ok=True)
+ tmp = path.with_suffix(path.suffix + ".tmp")
+ tmp.write_text(json.dumps(data, ensure_ascii=False, indent=2), encoding="utf-8")
+ tmp.replace(path)
+
+
+def parse_hhmm(text: str) -> tuple[int, int]:
+ val = str(text or "").strip()
+ m = re.match(r"^(\d{1,2}):(\d{1,2})$", val)
+ if not m:
+ return (0, 10)
+ hour = int(m.group(1))
+ minute = int(m.group(2))
+ if hour < 0 or hour > 23 or minute < 0 or minute > 59:
+ return (0, 10)
+ return (hour, minute)
+
+
+def flatten_wrapped_value(value: Any) -> Any:
+ if isinstance(value, dict):
+ for name in ("str", "string", "String", "value", "Value"):
+ if name in value and value[name] not in (None, ""):
+ return value[name]
+ return value
+
+
+def find_first_value(data: Any, keys: Iterable[str]) -> Any:
+ targets = {k.lower() for k in keys}
+ queue: list[Any] = [data]
+ while queue:
+ current = queue.pop(0)
+ if isinstance(current, dict):
+ for key, val in current.items():
+ if key.lower() in targets:
+ found = flatten_wrapped_value(val)
+ if found not in (None, "", [], {}):
+ return found
+ queue.append(val)
+ elif isinstance(current, list):
+ queue.extend(current)
+ return None
+
+
+def pick_primary_message(item: dict[str, Any]) -> dict[str, Any]:
+ add_msgs = item.get("AddMsgs")
+ if isinstance(add_msgs, list):
+ for msg in add_msgs:
+ if isinstance(msg, dict):
+ return msg
+ return item
+
+
+def summarize_message(item: Any) -> dict[str, Any]:
+ if not isinstance(item, dict):
+ text = str(item)
+ return {
+ "id": "-",
+ "type": "-",
+ "from": "-",
+ "to": "-",
+ "time": "-",
+ "content": text,
+ "raw": item,
+ }
+
+ primary = pick_primary_message(item)
+ msg_id = find_first_value(primary, ["msg_id", "new_msg_id", "MsgId", "NewMsgId", "ClientMsgId", "id"])
+ msg_type = find_first_value(primary, ["msg_type", "MsgType", "ContentType", "Type"])
+ from_user = find_first_value(
+ primary,
+ ["from_user_name", "FromUserName", "FromWxid", "Sender", "Talker", "wxid", "userName"],
+ )
+ to_user = find_first_value(primary, ["to_user_name", "ToUserName", "ToWxid", "Receiver"])
+ create_time = find_first_value(primary, ["create_time", "CreateTime", "Timestamp", "Time", "MsgTime"])
+ content = find_first_value(primary, ["text_content", "TextContent", "content", "Content", "Message", "Text"])
+ if content in (None, "", {}, []):
+ content = find_first_value(primary, ["msg_source", "MsgSource"])
+
+ def _to_text(value: Any) -> str:
+ value = flatten_wrapped_value(value)
+ if isinstance(value, (dict, list)):
+ return json.dumps(value, ensure_ascii=False)
+ if value is None:
+ return "-"
+ return str(value)
+
+ return {
+ "id": _to_text(msg_id),
+ "type": _to_text(msg_type),
+ "from": _to_text(from_user),
+ "to": _to_text(to_user),
+ "time": _to_text(create_time),
+ "content": _to_text(content),
+ "raw": item,
+ }
+
+
+def build_message_dedupe_key(msg: dict[str, Any]) -> str:
+ msg_id = str(msg.get("id") or "-")
+ msg_type = str(msg.get("type") or "-")
+ if msg_id not in {"", "-"}:
+ return f"id:{msg_id}|type:{msg_type}"
+ seed = "|".join(
+ [
+ str(msg.get("from") or "-"),
+ str(msg.get("to") or "-"),
+ str(msg.get("time") or "-"),
+ str(msg.get("content") or "")[:160],
+ ]
+ )
+ digest = hashlib.sha1(seed.encode("utf-8")).hexdigest()[:20]
+ return f"hash:{digest}|type:{msg_type}"
+
+
+class SeenStore:
+ def __init__(self, path: Path, max_size: int = 8000) -> None:
+ self.path = path
+ self.max_size = max(100, int(max_size))
+ self._queue: deque[str] = deque()
+ self._set: set[str] = set()
+ self._dirty = False
+ self.load()
+
+ def load(self) -> None:
+ raw = read_json_file(self.path, {})
+ seen = raw.get("seen") if isinstance(raw, dict) else []
+ if not isinstance(seen, list):
+ seen = []
+ for item in seen:
+ key = str(item).strip()
+ if not key or key in self._set:
+ continue
+ self._queue.append(key)
+ self._set.add(key)
+ while len(self._queue) > self.max_size:
+ old = self._queue.popleft()
+ self._set.discard(old)
+ self._dirty = False
+
+ def contains(self, key: str) -> bool:
+ return key in self._set
+
+ def add(self, key: str) -> None:
+ if not key or key in self._set:
+ return
+ self._queue.append(key)
+ self._set.add(key)
+ while len(self._queue) > self.max_size:
+ old = self._queue.popleft()
+ self._set.discard(old)
+ self._dirty = True
+
+ def flush(self, force: bool = False) -> None:
+ if not force and not self._dirty:
+ return
+ data = {
+ "updated_at": datetime.now().isoformat(timespec="seconds"),
+ "seen": list(self._queue),
+ }
+ write_json_file(self.path, data)
+ self._dirty = False
+
+
+class WechatXibaoBridge:
+ def __init__(self, args: argparse.Namespace) -> None:
+ self.wechat_base_url = str(args.wechat_base_url).rstrip("/")
+ self.xibao_base_url = str(args.xibao_base_url).rstrip("/")
+ self.auth_key = str(args.wechat_auth_key or "").strip()
+ self.session_file = Path(args.wechat_session_file).resolve()
+ self.sync_count = max(1, int(args.sync_count))
+ self.poll_interval = max(0.5, float(args.poll_interval))
+ self.max_images = max(0, int(args.max_images))
+ self.once = bool(args.once)
+ self.dry_run = bool(args.dry_run)
+ self.allow_from = {x.strip() for x in str(args.allow_from or "").split(",") if x.strip()}
+ self.seen = SeenStore(Path(args.state_file).resolve())
+ self.meta_file = Path(args.meta_file).resolve()
+ self.cleanup_hour, self.cleanup_minute = parse_hhmm(str(args.daily_cleanup_time))
+ self.explicit_auth = bool(self.auth_key)
+ self.self_wxid = ""
+ self.meta = self._load_meta()
+ self.meta_dirty = False
+ self._last_state_flush = time.time()
+ self._last_meta_flush = time.time()
+
+ def _load_meta(self) -> dict[str, Any]:
+ raw = read_json_file(self.meta_file, {})
+ if not isinstance(raw, dict):
+ raw = {}
+
+ users = raw.get("users")
+ if not isinstance(users, dict):
+ users = {}
+ else:
+ normalized_users: dict[str, Any] = {}
+ for wxid, item in users.items():
+ if not isinstance(item, dict):
+ continue
+ line_map = item.get("line_map")
+ if not isinstance(line_map, dict):
+ line_map = {}
+ line_order = item.get("line_order")
+ if not isinstance(line_order, list):
+ line_order = []
+ normalized_users[str(wxid)] = {
+ "updated_at": str(item.get("updated_at", "")),
+ "line_map": {str(k): v for k, v in line_map.items() if isinstance(v, dict)},
+ "line_order": [str(x) for x in line_order if str(x).strip()],
+ }
+ users = normalized_users
+
+ daily_cleanup = raw.get("daily_cleanup")
+ if not isinstance(daily_cleanup, dict):
+ daily_cleanup = {}
+
+ daily_skip = raw.get("daily_skip")
+ if not isinstance(daily_skip, dict):
+ daily_skip = {}
+ else:
+ normalized_daily_skip: dict[str, Any] = {}
+ for wxid, item in daily_skip.items():
+ if not isinstance(item, dict):
+ continue
+ count_raw = item.get("count")
+ try:
+ count_val = int(count_raw or 0)
+ except Exception:
+ count_val = 0
+ if count_val <= 0:
+ continue
+ normalized_daily_skip[str(wxid)] = {
+ "date": str(item.get("date", "")).strip(),
+ "count": max(1, min(count_val, 500)),
+ "updated_at": str(item.get("updated_at", "")),
+ }
+ daily_skip = normalized_daily_skip
+
+ return {
+ "updated_at": str(raw.get("updated_at", "")),
+ "users": users,
+ "daily_cleanup": {
+ "last_date": str(daily_cleanup.get("last_date", "")).strip(),
+ },
+ "daily_skip": daily_skip,
+ }
+
+ def _mark_meta_dirty(self) -> None:
+ self.meta_dirty = True
+ self.meta["updated_at"] = datetime.now().isoformat(timespec="seconds")
+
+ def _flush_meta(self, force: bool = False) -> None:
+ if not force and not self.meta_dirty:
+ return
+ write_json_file(self.meta_file, self.meta)
+ self.meta_dirty = False
+
+ def _flush_state(self, force: bool = False) -> None:
+ self.seen.flush(force=force)
+ self._flush_meta(force=force)
+
+ def _request_json(
+ self,
+ *,
+ base_url: str,
+ path: str,
+ method: str,
+ payload: dict[str, Any] | None = None,
+ key: str | None = None,
+ timeout: int = 30,
+ accept_error: bool = False,
+ ) -> tuple[int, dict[str, Any]]:
+ url = f"{base_url.rstrip('/')}{path}"
+ if key:
+ joiner = "&" if "?" in url else "?"
+ url = f"{url}{joiner}key={urllib.parse.quote(key)}"
+
+ body = None
+ headers: dict[str, str] = {}
+ if payload is not None:
+ body = json.dumps(payload, ensure_ascii=False).encode("utf-8")
+ headers["Content-Type"] = "application/json"
+
+ req = urllib.request.Request(url, data=body, method=method.upper(), headers=headers)
+ try:
+ with urllib.request.urlopen(req, timeout=timeout) as resp:
+ raw = resp.read().decode("utf-8")
+ data = json.loads(raw) if raw else {}
+ if not isinstance(data, dict):
+ data = {"raw": data}
+ return int(resp.status), data
+ except urllib.error.HTTPError as exc:
+ raw = exc.read().decode("utf-8", errors="replace")
+ try:
+ data = json.loads(raw) if raw else {}
+ except Exception:
+ data = {"ok": False, "error": raw or f"HTTP {exc.code}"}
+ if not isinstance(data, dict):
+ data = {"raw": data}
+ if accept_error:
+ return int(exc.code), data
+ raise RuntimeError(f"HTTP {exc.code}: {raw[:400]}") from exc
+ except urllib.error.URLError as exc:
+ raise RuntimeError(f"请求失败: {exc}") from exc
+
+ def _request_bytes(self, url: str, timeout: int = 45) -> tuple[bytes, str]:
+ req = urllib.request.Request(url, method="GET")
+ with urllib.request.urlopen(req, timeout=timeout) as resp:
+ data = resp.read()
+ content_type = resp.headers.get("Content-Type", "application/octet-stream")
+ content_type = content_type.split(";", 1)[0].strip() or "application/octet-stream"
+ return data, content_type
+
+ def _load_auth_from_session(self) -> str:
+ raw = read_json_file(self.session_file, {})
+ if isinstance(raw, dict):
+ key = str(raw.get("authKey", "")).strip()
+ if key:
+ return key
+ return ""
+
+ def is_key_online(self, auth_key: str) -> bool:
+ key = str(auth_key or "").strip()
+ if not key:
+ return False
+ try:
+ _, resp = self._request_json(
+ base_url=self.wechat_base_url,
+ path="/login/GetLoginStatus",
+ method="GET",
+ key=key,
+ timeout=12,
+ accept_error=True,
+ )
+ return int(resp.get("Code") or 0) == 200
+ except Exception:
+ return False
+
+ def refresh_auth_key(self, force: bool = False) -> None:
+ if self.explicit_auth and not force:
+ return
+ latest = self._load_auth_from_session()
+ if not latest:
+ return
+ if latest != self.auth_key:
+ if not self.auth_key:
+ self.auth_key = latest
+ self.self_wxid = ""
+ log(f"已更新 authKey: {self.auth_key}")
+ return
+
+ latest_online = self.is_key_online(latest)
+ current_online = self.is_key_online(self.auth_key)
+ if latest_online or not current_online:
+ self.auth_key = latest
+ self.self_wxid = ""
+ log(f"已更新 authKey: {self.auth_key}")
+ else:
+ log("检测到新的 authKey 但未在线，继续使用当前在线会话。")
+
+ def ensure_self_wxid(self) -> None:
+ if not self.auth_key or self.self_wxid:
+ return
+ try:
+ _, resp = self._request_json(
+ base_url=self.wechat_base_url,
+ path="/user/GetProfile",
+ method="GET",
+ key=self.auth_key,
+ )
+ except Exception as exc:
+ log(f"获取自身 wxid 失败: {exc}")
+ return
+ if resp.get("Code") != 200:
+ return
+ data = resp.get("Data")
+ self_id = find_first_value(data, ["wxid", "Wxid", "userName", "UserName", "to_user_name"])
+ if self_id:
+ self.self_wxid = str(self_id).strip()
+ if self.self_wxid:
+ log(f"已识别当前账号 wxid: {self.self_wxid}")
+
+ def _extract_feedback_records(self, data: dict[str, Any]) -> list[dict[str, Any]]:
+ if not isinstance(data, dict):
+ return []
+ result = data.get("result")
+ if not isinstance(result, dict):
+ return []
+ records = result.get("records")
+ if isinstance(records, list) and records:
+ return [x for x in records if isinstance(x, dict)]
+ records = result.get("new_records")
+ if isinstance(records, list) and records:
+ return [x for x in records if isinstance(x, dict)]
+ return []
+
+ def save_feedback_context(self, from_user: str, data: dict[str, Any]) -> None:
+ from_user = str(from_user or "").strip()
+ if not from_user:
+ return
+ records = self._extract_feedback_records(data)
+ if not records:
+ return
+
+ line_map: dict[str, dict[str, Any]] = {}
+ line_order: list[str] = []
+ fallback_index = 0
+ for item in records:
+ source_line = str(item.get("source_line") or item.get("raw_text") or "").strip()
+ if not source_line:
+ continue
+ line_serial = str(item.get("line_serial") or "").strip()
+ if not line_serial:
+ fallback_index += 1
+ line_serial = str(fallback_index)
+ if line_serial in line_map:
+ continue
+ line_order.append(line_serial)
+ line_map[line_serial] = {
+ "source_line": source_line,
+ "record": {
+ "source_line": source_line,
+ "raw_text": str(item.get("raw_text") or ""),
+ "branch": str(item.get("branch") or ""),
+ "amount": str(item.get("amount") or ""),
+ "type": str(item.get("type") or ""),
+ "page": str(item.get("page") or ""),
+ "status": str(item.get("status") or ""),
+ "line_serial": line_serial,
+ "line_product_index": str(item.get("line_product_index") or ""),
+ "dedup_key": str(item.get("dedup_key") or ""),
+ "signature_key": str(item.get("signature_key") or ""),
+ },
+ }
+
+ if not line_map:
+ return
+
+ users = self.meta.setdefault("users", {})
+ users[from_user] = {
+ "updated_at": datetime.now().isoformat(timespec="seconds"),
+ "line_map": line_map,
+ "line_order": line_order,
+ }
+ if len(users) > 400:
+ keys = sorted(users.keys(), key=lambda k: str(users[k].get("updated_at", "")))
+ for key in keys[:-300]:
+ users.pop(key, None)
+
+ self._mark_meta_dirty()
+
+ def resolve_feedback_item(self, from_user: str, serial: str) -> dict[str, Any] | None:
+ users = self.meta.get("users")
+ if not isinstance(users, dict):
+ return None
+ context = users.get(str(from_user or "").strip())
+ if not isinstance(context, dict):
+ return None
+ line_map = context.get("line_map")
+ if not isinstance(line_map, dict):
+ return None
+ serial_text = str(serial or "").strip()
+ if not serial_text:
+ return None
+
+ item = line_map.get(serial_text)
+ if isinstance(item, dict):
+ return item
+
+ line_order = context.get("line_order")
+ if isinstance(line_order, list) and serial_text.isdigit():
+ idx = int(serial_text) - 1
+ if 0 <= idx < len(line_order):
+ mapped_serial = str(line_order[idx]).strip()
+ item = line_map.get(mapped_serial)
+ if isinstance(item, dict):
+ return item
+ return None
+
+ def parse_feedback_command(self, text: str) -> tuple[str, str] | None:
+ content = str(text or "").strip()
+ if not content:
+ return None
+ m = re.match(r"^/?反馈\s*[+：:\-]?\s*(\d{1,4})(?:[\s，,;；:：\-]+(.*))?$", content)
+ if not m:
+ return None
+ serial = str(m.group(1)).strip()
+ note = str(m.group(2) or "").strip()
+ return serial, note
+
+ def parse_skip_command(self, text: str) -> int | None:
+ content = str(text or "").strip()
+ if not content:
+ return None
+ m = re.match(r"^/?跳过\s*[（(]?\s*(\d{1,4})\s*[)）]?\s*$", content)
+ if not m:
+ return None
+ return max(0, min(int(m.group(1)), 500))
+
+ def _today_text(self) -> str:
+ return datetime.now().strftime("%Y-%m-%d")
+
+ def set_daily_skip(self, from_user: str, count: int) -> int:
+ user = str(from_user or "").strip()
+ if not user:
+ return 0
+
+ daily_skip = self.meta.setdefault("daily_skip", {})
+ if not isinstance(daily_skip, dict):
+ daily_skip = {}
+ self.meta["daily_skip"] = daily_skip
+
+ normalized_count = max(0, min(int(count or 0), 500))
+ if normalized_count <= 0:
+ if user in daily_skip:
+ daily_skip.pop(user, None)
+ self._mark_meta_dirty()
+ return 0
+
+ daily_skip[user] = {
+ "date": self._today_text(),
+ "count": normalized_count,
+ "updated_at": datetime.now().isoformat(timespec="seconds"),
+ }
+ if len(daily_skip) > 1000:
+ keys = sorted(daily_skip.keys(), key=lambda k: str(daily_skip[k].get("updated_at", "")))
+ for key in keys[:-800]:
+ daily_skip.pop(key, None)
+
+ self._mark_meta_dirty()
+ return normalized_count
+
+ def get_daily_skip(self, from_user: str) -> int:
+ user = str(from_user or "").strip()
+ if not user:
+ return 0
+ daily_skip = self.meta.get("daily_skip")
+ if not isinstance(daily_skip, dict):
+ return 0
+ item = daily_skip.get(user)
+ if not isinstance(item, dict):
+ return 0
+
+ if str(item.get("date") or "").strip() != self._today_text():
+ daily_skip.pop(user, None)
+ self._mark_meta_dirty()
+ return 0
+
+ try:
+ count = int(item.get("count") or 0)
+ except Exception:
+ count = 0
+ if count <= 0:
+ daily_skip.pop(user, None)
+ self._mark_meta_dirty()
+ return 0
+ return max(1, min(count, 500))
+
+ def apply_daily_skip_to_raw_text(self, from_user: str, raw_text: str) -> tuple[str, int, int]:
+ requested = self.get_daily_skip(from_user)
+ if requested <= 0:
+ return raw_text, 0, 0
+
+ lines = str(raw_text or "").splitlines()
+ if not lines:
+ return raw_text, 0, requested
+
+ removed = 0
+ keep_lines: list[str] = []
+ for line in lines:
+ source = str(line)
+ if removed < requested and RELAY_SERIAL_LINE_RE.match(source.strip()):
+ removed += 1
+ continue
+ keep_lines.append(source)
+
+ normalized = "\n".join(x for x in keep_lines if str(x).strip())
+ if not normalized.strip():
+ normalized = "#接龙"
+ return normalized, removed, requested
+
+ def handle_feedback(self, from_user: str, serial: str, note: str) -> None:
+ item = self.resolve_feedback_item(from_user=from_user, serial=serial)
+ if not item:
+ self.send_text(from_user, "未找到可反馈的序号，请先发送 #接龙 生成后再反馈。")
+ return
+
+ source_line = str(item.get("source_line") or "").strip()
+ record = item.get("record") if isinstance(item.get("record"), dict) else {}
+ note_text = str(note or "").strip() or f"用户反馈序号{serial}"
+ mark_type = "recognition_error" if "识别" in note_text else "generation_error"
+
+ if self.dry_run:
+ log(
+ f"[dry-run] feedback from={from_user} serial={serial} mark_type={mark_type} "
+ f"source_line={source_line} note={note_text}"
+ )
+ self.send_text(from_user, f"反馈已接收（演练模式）：序号{serial}")
+ return
+
+ status, resp = self._request_json(
+ base_url=self.xibao_base_url,
+ path="/api/log/mark",
+ method="POST",
+ payload={
+ "mark_type": mark_type,
+ "source_line": source_line,
+ "note": f"{note_text} | from={from_user}",
+ "record": record,
+ },
+ accept_error=True,
+ timeout=40,
+ )
+ if not resp.get("ok"):
+ err = str(resp.get("error") or f"HTTP {status}").strip()
+ self.send_text(from_user, f"反馈记录失败: {err}")
+ return
+
+ issue = resp.get("issue") if isinstance(resp.get("issue"), dict) else {}
+ issue_id = str(issue.get("id") or "").strip()
+ suffix = f"，编号 {issue_id}" if issue_id else ""
+ self.send_text(from_user, f"反馈已记录：序号{serial}{suffix}")
+
+ def _clear_history_keep_feedback(self) -> bool:
+ history_path = ""
+ try:
+ _, cfg = self._request_json(
+ base_url=self.xibao_base_url,
+ path="/api/config",
+ method="GET",
+ accept_error=False,
+ timeout=20,
+ )
+ history_path = str(cfg.get("resolved_history_file") or "").strip()
+ except Exception as exc:
+ log(f"读取配置失败（history路径）: {exc}")
+
+ if history_path:
+ p = Path(history_path)
+ if p.exists() or p.parent.exists():
+ try:
+ write_json_file(p, [])
+ log(f"已清空历史文件: {p}")
+ return True
+ except Exception as exc:
+ log(f"清空历史文件失败: {exc}")
+
+ try:
+ _, resp = self._request_json(
+ base_url=self.xibao_base_url,
+ path="/api/history/clear",
+ method="POST",
+ payload={},
+ accept_error=True,
+ timeout=40,
+ )
+ if resp.get("ok"):
+ if resp.get("skipped_suppressed_cleared"):
+ log("已清空历史（附带清空了屏蔽列表）。")
+ else:
+ log("已清空历史。")
+ return True
+ log(f"清空历史失败: {resp}")
+ return False
+ except Exception as exc:
+ log(f"清空历史请求异常: {exc}")
+ return False
+
+ def maybe_run_daily_cleanup(self) -> None:
+ now = datetime.now()
+ today = now.strftime("%Y-%m-%d")
+ daily = self.meta.setdefault("daily_cleanup", {})
+ last_date = str(daily.get("last_date") or "").strip()
+ if last_date == today:
+ return
+ if (now.hour, now.minute) < (self.cleanup_hour, self.cleanup_minute):
+ return
+
+ log("开始执行每日清理：图片输出 + 历史记录（保留反馈记录）")
+ output_ok = False
+ history_ok = False
+
+ try:
+ _, resp = self._request_json(
+ base_url=self.xibao_base_url,
+ path="/api/output/clear",
+ method="POST",
+ payload={},
+ accept_error=True,
+ timeout=120,
+ )
+ output_ok = bool(resp.get("ok"))
+ if output_ok:
+ log("已清空输出图片。")
+ else:
+ log(f"清空输出图片失败: {resp}")
+ except Exception as exc:
+ log(f"清空输出图片异常: {exc}")
+
+ history_ok = self._clear_history_keep_feedback()
+
+ if output_ok and history_ok:
+ daily["last_date"] = today
+ self._mark_meta_dirty()
+ log(f"每日清理完成: {today}")
+
+ def send_text(self, to_user: str, text: str) -> None:
+ if self.dry_run:
+ log(f"[dry-run] send text to={to_user}: {text}")
+ return
+ body = {
+ "MsgItem": [
+ {
+ "MsgType": 1,
+ "ToUserName": to_user,
+ "TextContent": text,
+ }
+ ]
+ }
+ _, resp = self._request_json(
+ base_url=self.wechat_base_url,
+ path="/message/SendTextMessage",
+ method="POST",
+ payload=body,
+ key=self.auth_key,
+ timeout=30,
+ )
+ if resp.get("Code") != 200:
+ raise RuntimeError(f"SendTextMessage失败: {json.dumps(resp, ensure_ascii=False)}")
+
+ def send_image_data_uri(self, to_user: str, data_uri: str) -> None:
+ if self.dry_run:
+ log(f"[dry-run] send image to={to_user}, bytes={len(data_uri)}")
+ return
+ body = {
+ "MsgItem": [
+ {
+ "MsgType": 2,
+ "ToUserName": to_user,
+ "ImageContent": data_uri,
+ }
+ ]
+ }
+ _, resp = self._request_json(
+ base_url=self.wechat_base_url,
+ path="/message/SendImageNewMessage",
+ method="POST",
+ payload=body,
+ key=self.auth_key,
+ timeout=60,
+ )
+ if resp.get("Code") != 200:
+ raise RuntimeError(f"SendImageNewMessage失败: {json.dumps(resp, ensure_ascii=False)}")
+
+ def parse_command(self, text: str) -> dict[str, str] | None:
+ content = str(text or "").strip()
+ if not content:
+ return None
+
+ feedback = self.parse_feedback_command(content)
+ if feedback is not None:
+ serial, note = feedback
+ return {"action": "feedback", "serial": serial, "payload": note}
+
+ skip_count = self.parse_skip_command(content)
+ if skip_count is not None:
+ return {"action": "set_skip", "count": str(skip_count), "payload": ""}
+
+ lower = content.lower()
+ if lower in {"/喜报", "喜报", "#喜报", "/喜报 help", "/喜报 帮助", "喜报帮助"}:
+ return {"action": "help", "payload": ""}
+
+ prefixes = ["/喜报", "喜报", "#喜报"]
+ for prefix in prefixes:
+ if content.startswith(prefix):
+ rest = content[len(prefix) :].strip(" ：:\n\t")
+ if not rest:
+ return {"action": "help", "payload": ""}
+ rest_lower = rest.lower()
+ if rest_lower in {"help", "帮助"}:
+ return {"action": "help", "payload": ""}
+ if rest.startswith("解析"):
+ payload = rest[2:].strip(" ：:\n\t")
+ return {"action": "parse", "payload": payload}
+ if rest.startswith("生成"):
+ payload = rest[2:].strip(" ：:\n\t")
+ return {"action": "generate", "payload": payload}
+ return {"action": "generate", "payload": rest}
+
+ if "#接龙" in content:
+ return {"action": "generate", "payload": content}
+
+ return None
+
+ def normalize_raw_text(self, payload: str) -> str:
+ text = str(payload or "").strip()
+ if not text:
+ return ""
+ if "#接龙" in text:
+ return text
+ return f"#接龙\n{text}"
+
+ def format_parse_result(self, data: dict[str, Any]) -> str:
+ result = data.get("result") if isinstance(data, dict) else {}
+ if not isinstance(result, dict):
+ return "解析完成。"
+ summary = result.get("summary") if isinstance(result.get("summary"), dict) else {}
+ parsed = int(summary.get("parsed") or 0)
+ new_count = int(summary.get("new") or 0)
+ duplicate = int(summary.get("duplicate") or 0)
+ pending = int(summary.get("insurance_pending") or 0)
+ return (
+ "解析完成\n"
+ f"- 识别条数: {parsed}\n"
+ f"- 可生成: {new_count}\n"
+ f"- 重复: {duplicate}\n"
+ f"- 待选保险年限: {pending}"
+ )
+
+ def format_generate_result(self, data: dict[str, Any]) -> str:
+ result = data.get("result") if isinstance(data, dict) else {}
+ summary = result.get("summary") if isinstance(result, dict) and isinstance(result.get("summary"), dict) else {}
+ generated = int(data.get("generated_count") or 0)
+ duplicate = int(summary.get("duplicate") or 0)
+ pending = int(summary.get("insurance_pending") or 0)
+ if generated <= 0:
+ return (
+ "本次没有可生成的新记录\n"
+ f"- 重复记录: {duplicate}\n"
+ f"- 待选保险年限: {pending}"
+ )
+ return f"生成完成，本次生成 {generated} 张。若有问题请发送：反馈+序号+说明"
+
+ def compose_help_text(self) -> str:
+ return (
+ "喜报机器人用法:\n"
+ "1) /喜报 生成 + 接龙文本\n"
+ "2) /喜报 解析 + 接龙文本\n"
+ "3) 直接发送包含 #接龙 的文本\n"
+ "4) 生成有误时：反馈+序号+说明\n"
+ "5) 发送 跳过3（或 跳过(3)），当天自动跳过前3条；跳过0 取消\n"
+ "示例:\n"
+ "/喜报 生成\\n#接龙\\n1、营江路揽收现金10万存一年\n"
+ "反馈2 网点写错了\n"
+ "跳过2"
+ )
+
+ def handle_command(self, msg: dict[str, Any], command: dict[str, str]) -> None:
+ from_user = str(msg.get("from") or "").strip()
+ if not from_user:
+ return
+
+ action = command.get("action", "")
+ payload = command.get("payload", "")
+ if action == "feedback":
+ serial = str(command.get("serial") or "").strip()
+ if not serial:
+ self.send_text(from_user, "反馈格式错误，请发送：反馈+序号+说明")
+ return
+ self.handle_feedback(from_user=from_user, serial=serial, note=payload)
+ return
+
+ if action == "set_skip":
+ try:
+ count = int(str(command.get("count") or "0").strip() or "0")
+ except Exception:
+ self.send_text(from_user, "跳过格式错误，请发送：跳过3 或 跳过(3)")
+ return
+ effective = self.set_daily_skip(from_user=from_user, count=count)
+ if effective <= 0:
+ self.send_text(from_user, "已取消今日自动跳过。")
+ else:
+ self.send_text(from_user, f"已设置今日自动跳过前 {effective} 条（仅当天生效）。")
+ return
+
+ if action == "help":
+ self.send_text(from_user, self.compose_help_text())
+ return
+
+ raw_text = self.normalize_raw_text(payload)
+ if not raw_text:
+ self.send_text(from_user, "未检测到有效文本，请发送 /喜报 帮助 查看用法。")
+ return
+ raw_text, skipped_count, requested_skip = self.apply_daily_skip_to_raw_text(from_user=from_user, raw_text=raw_text)
+
+ endpoint = "/api/parse" if action == "parse" else "/api/generate"
+ start_hint = "收到，正在解析..." if action == "parse" else "收到，正在生成喜报，请稍候..."
+ if requested_skip > 0:
+ start_hint = f"{start_hint}（已跳过 {skipped_count}/{requested_skip} 条）"
+ self.send_text(from_user, start_hint)
+
+ status, resp = self._request_json(
+ base_url=self.xibao_base_url,
+ path=endpoint,
+ method="POST",
+ payload={"raw_text": raw_text, "save_history": True} if action == "generate" else {"raw_text": raw_text},
+ accept_error=True,
+ timeout=300,
+ )
+
+ if not resp.get("ok"):
+ err = str(resp.get("error") or resp.get("message") or f"HTTP {status}").strip()
+ if resp.get("error_code") == "insurance_year_required":
+ err = "包含保险记录但未指定 3年交/5年交。请在文本里写明年限后重试。"
+ self.send_text(from_user, f"处理失败: {err}")
+ return
+
+ self.save_feedback_context(from_user=from_user, data=resp)
+
+ if action == "parse":
+ self.send_text(from_user, self.format_parse_result(resp))
+ return
+
+ self.send_text(from_user, self.format_generate_result(resp))
+
+ images = resp.get("download_images")
+ if not isinstance(images, list) or not images:
+ return
+
+ send_list = images[: self.max_images] if self.max_images > 0 else []
+ for idx, item in enumerate(send_list, start=1):
+ download_url = str(item.get("download_url") or "").strip()
+ if not download_url:
+ continue
+ full_url = urllib.parse.urljoin(f"{self.xibao_base_url}/", download_url.lstrip("/"))
+ try:
+ raw, content_type = self._request_bytes(full_url, timeout=90)
+ b64 = base64.b64encode(raw).decode("ascii")
+ data_uri = f"data:{content_type};base64,{b64}"
+ self.send_image_data_uri(from_user, data_uri)
+ log(f"已回发图片 {idx}/{len(send_list)} -> {from_user}")
+ except Exception as exc:
+ self.send_text(from_user, f"第{idx}张图片回发失败: {exc}")
+
+ remain = len(images) - len(send_list)
+ if remain > 0:
+ self.send_text(from_user, f"还有 {remain} 张图片未回发（已达到单次上限 {self.max_images}）。")
+
+ def should_ignore_message(self, msg: dict[str, Any]) -> bool:
+ msg_type = str(msg.get("type") or "").strip()
+ from_user = str(msg.get("from") or "").strip()
+ to_user = str(msg.get("to") or "").strip()
+ content = str(msg.get("content") or "").strip()
+
+ if msg_type not in {"1", "01"}:
+ return True
+ if not from_user or not to_user or not content:
+ return True
+ if from_user == "filehelper":
+ return True
+ if self.self_wxid and from_user == self.self_wxid:
+ return True
+ if from_user.endswith("@chatroom") or to_user.endswith("@chatroom"):
+ return True
+ if self.allow_from and from_user not in self.allow_from:
+ return True
+ return False
+
+ def handle_polled_message(self, raw: Any) -> None:
+ msg = summarize_message(raw)
+ if self.should_ignore_message(msg):
+ return
+
+ dedupe_key = build_message_dedupe_key(msg)
+ if self.seen.contains(dedupe_key):
+ return
+ self.seen.add(dedupe_key)
+
+ cmd = self.parse_command(str(msg.get("content") or ""))
+ if not cmd:
+ return
+
+ log(
+ f"收到指令 from={msg.get('from')} id={msg.get('id')} type={msg.get('type')} "
+ f"content={str(msg.get('content') or '')[:120]}"
+ )
+ try:
+ self.handle_command(msg, cmd)
+ except Exception as exc:
+ log(f"处理指令失败: {exc}")
+ try:
+ self.send_text(str(msg.get("from") or ""), f"处理失败: {exc}")
+ except Exception:
+ pass
+
+ def poll_once(self) -> None:
+ self.refresh_auth_key(force=False)
+ if not self.auth_key:
+ log(f"未获取到 authKey（session: {self.session_file}），等待中...")
+ return
+ self.ensure_self_wxid()
+
+ _, resp = self._request_json(
+ base_url=self.wechat_base_url,
+ path="/message/HttpSyncMsg",
+ method="POST",
+ payload={"Count": self.sync_count},
+ key=self.auth_key,
+ timeout=30,
+ accept_error=False,
+ )
+
+ code = int(resp.get("Code") or 0)
+ text = str(resp.get("Text") or "").strip()
+ if code != 200:
+ if "重新登录" in text or "不存在" in text:
+ self.refresh_auth_key(force=True)
+ log(f"消息轮询返回 code={code} text={text or '-'}")
+ return
+
+ data = resp.get("Data")
+ if not isinstance(data, list) or not data:
+ return
+
+ for item in data:
+ self.handle_polled_message(item)
+
+ def run(self) -> int:
+ log("微信桥接机器人启动")
+ log(f"WeChat API: {self.wechat_base_url}")
+ log(f"喜报 API: {self.xibao_base_url}")
+ log(f"状态文件: {self.seen.path}")
+ log(f"元数据文件: {self.meta_file}")
+ log(f"每日清理时间: {self.cleanup_hour:02d}:{self.cleanup_minute:02d}")
+ if self.allow_from:
+ log(f"仅处理白名单发送者: {', '.join(sorted(self.allow_from))}")
+
+ try:
+ while True:
+ try:
+ self.maybe_run_daily_cleanup()
+ self.poll_once()
+ except Exception as exc:
+ log(f"轮询异常: {exc}")
+
+ now = time.time()
+ if now - self._last_state_flush >= 6:
+ self.seen.flush(force=False)
+ self._last_state_flush = now
+ if now - self._last_meta_flush >= 6:
+ self._flush_meta(force=False)
+ self._last_meta_flush = now
+
+ if self.once:
+ break
+ time.sleep(self.poll_interval)
+ except KeyboardInterrupt:
+ log("收到中断信号，准备退出")
+ finally:
+ self._flush_state(force=True)
+ return 0
+
+
+def parse_args(argv: list[str]) -> argparse.Namespace:
+ parser = argparse.ArgumentParser(description="Xibao <-> WeChatPadPro bridge")
+ parser.add_argument("--wechat-base-url", default=DEFAULT_WCPP_BASE_URL, help="WeChatPadPro API 地址")
+ parser.add_argument("--wechat-auth-key", default=os.environ.get("WCPP_AUTH_KEY", ""), help="WeChat authKey")
+ parser.add_argument("--wechat-session-file", default=str(DEFAULT_SESSION_FILE), help="webui 会话文件路径")
+ parser.add_argument("--xibao-base-url", default=DEFAULT_XIBAO_BASE_URL, help="喜报服务地址")
+ parser.add_argument("--poll-interval", type=float, default=2.0, help="消息轮询间隔（秒）")
+ parser.add_argument("--sync-count", type=int, default=30, help="每次轮询拉取条数")
+ parser.add_argument("--max-images", type=int, default=3, help="每次最多回发图片数量")
+ parser.add_argument("--state-file", default=str(DEFAULT_STATE_FILE), help="消息去重状态文件")
+ parser.add_argument("--meta-file", default=str(DEFAULT_META_FILE), help="反馈上下文与清理状态文件")
+ parser.add_argument("--daily-cleanup-time", default=DEFAULT_DAILY_CLEANUP_TIME, help="每日清理时间 HH:MM")
+ parser.add_argument("--allow-from", default="", help="只处理这些发送者wxid（逗号分隔）")
+ parser.add_argument("--once", action="store_true", help="只执行一次轮询")
+ parser.add_argument("--dry-run", action="store_true", help="仅打印不真正回消息")
+ return parser.parse_args(argv)
+
+
+def main(argv: list[str] | None = None) -> int:
+ args = parse_args(argv or sys.argv[1:])
+ bridge = WechatXibaoBridge(args)
+ return bridge.run()
+
+
+if __name__ == "__main__":
+ raise SystemExit(main())