From 878901826c4c51e5c226cb600519768990d42c6b Mon Sep 17 00:00:00 2001
From: lz_db <lz_db@lz.com>
Date: Thu, 4 Dec 2025 22:03:02 +0800
Subject: [PATCH] xm

---
 .gitignore                                    |   6 +
 sync/__pycache__/account_sync.cpython-311.pyc | Bin 9585 -> 9062 bytes
 sync/__pycache__/order_sync.cpython-311.pyc   | Bin 13351 -> 17527 bytes
 sync/account_sync.py                          |  12 +-
 sync/order_sync.py                            | 437 +++++++++++-------
 .../__pycache__/redis_client.cpython-311.pyc  | Bin 23340 -> 29036 bytes
 utils/redis_client.py                         | 136 +++++-
 数据库.sql                                    | 204 ++++++++
 8 files changed, 604 insertions(+), 191 deletions(-)
 create mode 100644 .gitignore
 create mode 100644 数据库.sql

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..6895f0b
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,6 @@
+test.py
+__pycache__
+logs
+.env
+*.log
+.DS_Store
\ No newline at end of file
diff --git a/sync/__pycache__/account_sync.cpython-311.pyc b/sync/__pycache__/account_sync.cpython-311.pyc
index 924a14605f16b6642b760808a7261f364a6bbf2f..68ddf98c3e9309cb2ff778d3863e0fd1888c4bba 100644
GIT binary patch
delta 1125
zcmZ{iO=uHA6o6-v-DI<AQ`0{;{kL5)YiinR#j0(^AFPNJsUQ-Bm}a*$u<5ol8?6PY
z2NCojEpziKs8~>B!GkAHo_i6>dhk>)y|h?7^yIu*w6>(f%*UJe-n{o_-fUg}c{TB-
zwpK-aY&;t%eQjM%Xn1n@SY{X_Gi1tkw5;S5AxG?3S<R^!h0qu>qfd~jSon1qp%uP@
zk&BzLTgXtCKObod`O=LNb$#hdspuNmmt1S!Wg6D;dp3eUNZhZ+`;9+_aSeMbzrd<@
zCbB4vHt|SA1~hUQGHC|6jl+*pi_(%aLo`sOI4C%F!5}T5Yhc^zAWnNm{7xj2;F^lT
za!H-7B=w8}4kB<JNQVF-naC3h@*D+i8{0|tcZm2gz8CR#bM$c4LWcd&G<L7P0blUk
z`ZY;6;9wfi2RIJM0D1u@09iJB_}xTR3z!E0kk5}6Ofz4w?Sre0@2S?-Qus7`s-49t
z_C;%qh^Nq*uMOg9uP*fs;}LJY<z)!>v&ZdDMpOy)`f`C%%dK84RMW>=I(ipHVJBgK
z3IOluD^r$RoQ4|rT^uez#sJp<2i|sHn-l+CXao*k;_%g?Gh<GbT;6lKo5)w(QrXJi
zFW7zp90Gfux`YhDsVK2%#dfJ5Ce8zL5u%A+!hiVJOCbcG<~-LgWJN<ScQ)fCFW31A
zhsTXNcC&kEycNzzIDBc+act56d-wxH2c_&*W^GIKjX)rBj^h_!C<q=02@vIrZm{p&
z>&+-FcWna5?Z4J>qlT^b^iB9GowEyeaoQ?B3|=}}c1+8rS%;MKffytcfgxEC1bV)s
z40Df)ZH<z<e2e*_uh?@v`>1^tRhet3b#?DtL+RDMb5oiNVP0)@F3oQV%k}|wQQIFf
C?DF>j

delta 1581
zcmah}O>7%Q6rS<=XT6RcJKM-^O5C_jn;1jW&;X^PO;e#(f|3J41uch_>)q6*yIwlG
zhPV_t66HrACAf1)g*a3~P$49$VnC_{5=cEFk)R^1l@MGK!L3y}!G-t6DTES>+1YR3
zyq|gVerDH>-g-Q7IUZLCjQE-H%18G!6B)YD94VCTh!(MBO{T;M7$GaFMa5Uq6!?a%
zm>tt%c8}I0<Pj@wC$xm!tM!VtY$ffKmZBs;ju9hzo*0TrKa>dh7~am%`i#&F$;X-t
zxr0GJc)a3ze(<qM$@8VDYTcJ+Om8|L@MWXunO?;<{V1YgT3!*@LC>56{bJS7o7acw
zXU*TPDCddRYxKaL@z#6vszg(KI<!FJt)D`T;GqHV%0dWR0rDZX4e1<!A8}3BtvFRS
zh^#Dti;6=y*mmS)_<SbKuPTGI(E3h!HXK%gTgzWa4f94?;m@T83O%SN_TPe3KZ5Wn
z+(kR??nQ2nUrO!G3O7+$3pf9`8U@zb0$<5y_^6`NBdvkHb}+vO4ev*oKo~>Vi!hGx
z0Kz_i+AuGsv;2|t8;x!%>>*T60QixjVdzE6>VE9l#$%(2S}c{ETGi8`Dn<QdT|aHs
z*#VSDK>0~?4$4@mp3?bbX7@G`V+^E!$9N~9c}VC4J>B{|^8<w#-yV23Kp*702c3cl
z62tXFMb|aGuCcNS{`KH}4H3@6pwIRrU>SUQ*7QncjO?zwVc6_A!jlMHb97g;BsQes
z2pS#(@RgENHR2TyI>%ji#OJcvtp`yUVWwNNJlB_)^AbCXMp=F(n+}V9I?TV#?xXzE
z?O)KHB?`hj18>Kx@ZK&1JV7W~BIn2@zS6H=kdx9Y^c-J|r1@+>ouw~JC&-fYdJyg#
zg`N-8dckD%wJ%pcxwf`+d2Qi?)y4Pm0;Nxxp1xi-SD$5$tuxc8xNHdY^MOuiDWKf|
zz<PoFpj)q&&i3<fLj6yDg~BO-U*VZ2zo_XS)v@o@u@!avhC2SH+)nf@I&V1_%PWbI
z8;Ox+x$C?Qn~>>zl3yFzKQjb03j_GUla6Dt46d>LSss}oul9mvicV#Rk$VDR65$yH
zk;o)c2>1tc|KyXo)m=|hDKvVM{1-ZQsGV2&fgNKFCZjoCLO=Mt3qJsHxo|6nUF$3E
z8LMcO%BEcxjm6@~P1z3oh1@+3v-J+yIixttzt8uF{3vMDEb|aE!4xa){tR$aqLjAz
z^&Pv6k!A8fvrS_2;@LoqE|X1Wo8*=^n>@91%hZbj3R&44-<i85B)@l&i_HB6b>ebY

diff --git a/sync/__pycache__/order_sync.cpython-311.pyc b/sync/__pycache__/order_sync.cpython-311.pyc
index 492ac4cdce3de0d32f992a20cb88c56b0072ee48..657b9c4fe44e4b9b87fbdf85cbb443e1b6a1fa11 100644
GIT binary patch
literal 17527
zcmeHvdvFt1ns2vSZ%cm4wrtCG`z;YaFc>hhd6?K>12!QxV4SduaLbNBwwaa`z#}Eh
z3`xwar{ZMEViL1a*aVcBOya$jyX%=SHBJpwk*&#WH`7~ayNW8R?#jSFcSI#raZ~qJ
z-S2ek)v{&C{Bf&p)wU0x&inD5)89Gg_kGP(y<UsKbLH)3=jT=o`yVI}dlXU6x8vZs
zfKeEQyRb2Q2*)u>MiDOA7%@Z$ez{9NrWjI;DTkC}sv*^wdPptAD_oi(4dhk0v_o3>
zRk||9bVE8ElVQ6sN_7^a)DHX#fnmRbf8sNwrxg8|Me_iMum$JUJM3;p|LO7J2PhpP
zl&*=<Q3q|2^YXn;w}+Q^I)^<x(J_9SR}6ShxEy_uN$zo+@(hbLic}d5e0v2vZ^CdK
z*bq)(Lox~<BBrnroRXbY56LOQp>QZ2iV;~+y!42SlAo0isVId*?NB7*DWyZ>&^j_C
zdF3!H`H(J6UTM8@N)37Sl*XZex)dXFN(<r4DeM$Jlm$%4;4}Bpl!HdY-(mL*zw9l6
zPTl|Pa`+eTF1<Uy^o!4y&i&@Wn{S0@rk8&Gark0z7%?sO$iRcx`Yi?IUHk&(NlHar
z_!ayUpFmPdEDjb0coTVGLUA8vL$wMIC4*3W+9(YAOY}MKL(Bsd3-hCJdrvrMUTw2E
z$DJOVjn^JUgRr@slMX(Eb__elJvPdI+HH~Xa<{`Z!fR}{VVB+Qw%OdM9rDcg8=L5f
z2~X1rdg7R4*wf@VHT<%DeAHnZn}8}OXqy{Y(<G1y#3>=%c;Ymj4aFx5rQB<bbtD54
z-HkvVpTX{^_2*R6s@rPgEwzzV7jx=jMqL~#E}N21XN5{kQ*usiWCZsul)!kkeRz1n
zJMM80$5{c<D){#^`1dUZv3oEa7MMoD@MCcnQ@AJgW<dcTeg#r~6;FL1-mOc7G!Dl+
zsQ&14EY5W41o>e?j>%)W0!eMe;+D7eGmIjBOdP~65O2u+gpY6+BrlSrKFd>kL=pYz
z#;1^sFJ&w+KIQW9`LKX8(aVI-mr^>pzb^u({c^wJX?Ww4O@f^BD}8dhEX@d2J_Ynm
z?Nd^k_u)mnq<G?p<8wk~tdzG3^Pp82eX23K(yx-VohYyKsouvf$x>@M471}`y{baI
z7JVo2lh`TZFm@8R=)HANb+Q0hI(KGi?%e$^u7uzEmwWG>O_meh8ps>Ib|!rFZ<9+T
zXZg#u>G13SM0(MFK>p{#FU5NL1d+3JA&{K)!Q7eqSAHT&9U=eH`G0=!{u|+`dD4r9
zOfFseFgd@s0wSXk$pY)M>7}U|D;fUi?7f*cNUuRs6#8@j%!Q>3|4dF2jq66dXw~1l
z`i|GQa$O(&)BP_#epI|lqLs90X!KU_a_9KS1W&je<FHXU#~i$lc2G_?$Q~z%BtFkJ
zJmGSIxUtz?E}I}%+`Lf`Ezyuo6l9(W8+DXdIB0r;<~3cXh8-t7&WUl0n$Ck}=t9(%
z*6p#=9-GjNHmN?9+dDk$aJ%^|kZs80prBchE4<3#vY&t;k2~CIsDg|>biP<0NIbFq
z$)XhbhUB1_gl55g5`@Zq_&b9|<R(qq9bNA99>#e12C>-vmHxUOyrN@uL!54i(G7)*
zO6Q6$mduq*?T#ohvYIPjd%L{zR(a>*AY0zYmG?14scvfb-MrEWCes(*$u2mb!I(C)
z*;X#w%4AzZ*#$Gou-NF%kNbngAKE^$F~*&uV|BYY-7ZGAE2734*WGT|eXC*jO)J}Q
zkZU-|)TKIBS3R|B#`Z{y6_%WLzJ2`s@xX4jpmAzfD61fX5&F&1*1d~ajLD0f!xi-i
zK{oppF8dWG=EBfd9aFlA&2HtgTbY=99L_REFkI7?Ac$#unWD|}b|Bzbot4vBnU&mQ
zcp?OphF>>&-_CY4b`scEEghTS=MN1Apw|g)XA^N<U)Z^ZxV}aKe!2?Hs*-kiy!5za
zOVL4su%(zmP>5TK4|l_Pr5^)94~gOvh;JRS81$REHBd4?F$&@mHl?JEfs!Q)&(y6b
zc{`CF(mJsj*^ySi!iW15@RzjhOhVhQC!L-AN)6_dt-KjY`-o%EKb23}i5>ZOzZy!V
z+Y;1LG3nQMvJxZrX#(h-S@uvV8%f%HDH~ndd@0*Q+I&iBZ%0$=cN;xORz#m;!eJZ*
zD3wpW(v~p&mQNKx=a*%VPa|y!$EH7qEeMIr=mT3&wO=b~PajKzjSt$RG(Ih~n$kxc
zgN;b**S@Nq{*(Bd*oJ&6cLB_AW~`p%-_-e?!KY20@<fi*ZPT9tH6?ACiJZO+pXv&1
z_rHoCx%@gGAz8aB>F6h6Wd2oi`1L;Bv7A^N{!9;gWup(AZ8Lp(bYw_rHOr^>WeG=#
zYzZIZb4ck@-UsM0rAKcCa2M(Xn&ry|n(fO1nsaH{to;CP{$bht9`kFVJlaT?J*l&?
zYEN@L&m=1FX{EeHE5x588Gn2o`EsbdPYqJ8;h0aJX3geEYfh}R8QJu@Wou1NpIy0C
zDqpe|Qr0i<xnPAOCmiyq!em(mlBdX@o2CV$FL%ZFv3RwXslwyJft)s{skLbJ(rBfv
z-1}9_$&L%}i9gSm=OadBup$Z)vzhRvu84kY*?MYAD=&%#Ng-Qlwy6@->aZ*(HJ-lx
z)ETcrd&g7tJ$@`UdB1@XraR=q5mmf6hkyHb+StJ=?&+XM-PU*rB_|GSRx<fS8=ksw
z|HEKBYuxj^u#KlwBA^m49G#eO)sxO~&k-wWUYh+pJaYw3zu}*MP#--2Cm-42Qg4Y@
zYLN}lXc-BFSBn>2C&eq>r^k*?xOn+-8-(O;C*|-a4#4-W{Wd)RcKG+Nqoew-FD!lb
z->syW{JT$=esNhc8sYG4CBIkKlfq$kOP~FJ!V-%2AjYZKZ%<!;*Yg8pPv5{kl5)U}
z-b33xj?vTN@z^%*I7y~0Yj%5}yY(dMbUg`|eTS!>jE$+D6vqU=Fq(Su1nnG#A9Q-I
zPhX{2`bVDA^(3GN9-H8^zcOlz7LTI_PAb9G*jQq}2Rrs2=;}}3h}jzLxK-@AHQIG+
zqVLvN=dEJzt<m<aLjTipBwB;eYinWv)}#?wpK1vE`pC`$&+YAbwqu}++|zZKJn&p6
zc+)nFhAwoG+(L@OHw!^a{i;RKXc8q*=m`bl^OGnQk9tDU7&{UrV=+%C7-wFhWISr+
zMc_r7Sp1f{^y!Brjl`%|10;S)eS|Wh`)xhB^wvA!*FPqcW8VK_>F?*sN9bimc^;vI
zY4q(5N8ho5PXN<|*#t~%WWq~A2C>N~h9_K!|MPcmz(xMS`HS~I{~TUgbSOkOaxvlo
zI=_3-flCbE|NP3*&t8vaYiw-1|NB`eOwtIa+-WJ~wbW7Dn0?$1m?@tz>hRdyaM^@g
zDzBgsl13v)kw)hrUUAeh>KqrYzvHhs;L<8i5@q+;c>*LMPe5_;2CX`2r^lV+qrB37
z;)G+IqR|bXCQ&WQ;fb*^r-w$phP&)3$FSGq;MMfRN%4A1jM-1|3d(WRJBngmuA}zh
z<2(T(gjWo^Cfp8-LA*W-7b8`)w=_DP@k&8Dxp~~l>%=R#&_y?&Jv<?F87|S$7!7Sd
zDf)R$Jds9_39t3S^%{of{*en^yxd-wM`S>zXToE5+3X`DaQTM|xZZmL1|PqeXFA7G
zxp-J3^u{*k9u-DTS3~7)0mO*Ol%!wb_D-YI?_}LR38>qc4p~@->U$9uQ}hy_i)9z1
zn`ucXuXtwD-Q0rnO}BF!Zsj(xxlLSd)0FCNamiFxC?{`98Icd-8dEsGc((b{aA3{F
ziMffO=hN5N{B2zRwg}dV>l+>lbOsNVTY?qAj(PbPS#13_X3aLPeEW<pBJaR+8bXGW
z3%&33zP<1KzL|Xh37FR~hU!pFa|FxHuMx<sCL+rzstK9vZ=1K@GH+ijV$FLv^PbtB
zM@p=^E<{?c>M!eq$5?VRM{bS<UuMZo9JwhL9AU`~9JwJS7||%qWe+h$b@_LQL@-sU
z<&h4nsQW0BX*zVX2M9Qp9OTGBh8zr$=DVi)+otumOzY=+SkqR{w3QLu<8ZkdAc`XB
zag5wCRnF~YEH5rPfgpEyNc6C#Bb@07V>%KtRnK;df5OFH0Y%XTUyYgSp`QGTkg@!O
z%=a=`qnR_B8Ke0>j3f-XvNnS0>x>UEePz*ih|KJclwoBxAK2cr1&5f;J#6W2u5|az
z&XA$%V>k0m8(Y`T)wQ#R_L+UCcnwptfvwocRcxHu9jbZeBil^ho$9(E9^AUHn|)>{
zTfK{`-Zj%3s%e^UU~9I`^o0$@=l22xQfZyfneY5!AKU!wqMdEtB}54%RJ%4pK)MjP
zTiX&*!~!s*buAH9Jcw#}h!Od1-ys6|foQRO(}liw`dC9XXQ+nh2hZbhAsNBsISmN{
zE9JJK`W8yA<qWlqp*BR?=JENKFSfC3cP#E_*Y0FU8@PWzG{n5{B75ivcj$;1Gt+Yi
zjUiApKfoBQtij3|tl$Y5iqYB&SXe_nXQ*eS4kCqV(LgWIv}9u000b%YdvJsV0k(4p
zV6L5CWn9kyujtt9K`wic$sP=qRt0th_6K&%4Z-V_gV3IwwwW%W7fi+G`5GYL;yr=R
z+{r7LdFAc4^KF5gcec%Ji)QWl_3(V{C&xcMzR>Z>1XIx?I@Yk8GwfyzyTb)Vv$X<N
zwf|N@Enro7#k2dEyl0@Zdc#}2Kkq%aZ+hPp{5^h@fn^uLs?w}UkW}Ppv6IpDu(}>j
z*8`qVo^iH`$+IvziGvwUsTwgS11c7{rCpxt{s5%R$E|zUV_%gOcW21H+Pov9vqXMf
zjzi$OA|LsS1%HXQOQX78Q`{w2UEijF)EjaI#N5ynA%CR|s<=_TqXq&uH7Ia1L))`W
zaWlW8yvM5ex<v_5Ut1Lr_4T$L<q-JedTnnj@y9Ku-u1*cML77sDVF!PVc)D*Ab%@?
z{A~q&IfMijLsxA97W?0@F~3<72gbA%sPM$UQ9#S*K-Kow0A<PWSSlbEuN@SEb4ot}
zU|Jl*$C5xWO5r0YWkOL1S2z`bWO3kaC5UCUc9Y8@D1lO=i=iYIPAY!6Cw>iw)Rapw
zKz78DdVuT@To>=jB=|rpqLjoz3joC75UWbQ9{bgj(Z)v(ppgQ41f^h{TAv(f253=Y
zF*;8iWPx6(RvV`jHUKWAKz%sq)Zjvh4rI%o)XOY@iJ*A~I7AI2$B#Vk&k!I*bShc)
z_)_#YKQDn5q`!>&byFpv7|uMa_USrPAyvIkPm>ak#9=vrco5K&?aNqcrhQuA4a}5Z
zJKcM(B!FPvWe=4@<x05$09Aa}fRC9{;DpMH0u9x^Ov*szCC}Tr5-O)1T1eB^d|&2D
zz((4h6)fvnmZWD{DLsopAOM^}&m@2g^sE5&ENxrHWo>0k+R9GbR`v>Q8BtpR)F!<p
z3C5o*k=BL7s+leYK*W^D0|4q80KVcYAKv*m^h_0@*`|tpIjhe(fFcHe&Z{|4`(DwP
z1f~*H$tl^XB>3E?MJr_(B%s)L0c>3nB28WYQ2+n(pd)njp-j^8`E%h-%8jKa|N3$P
zN(On71h(c$xSj%8`VGFkV{rh~pYO3GY6BoO-)C3>NG<Rgd<6oKS_rbTG-cEV$*2jc
zEG4}#CA~Z)y&ySVGGFLwCOj0GB(*Ah2AI1_1Zh!KzCxhYz5<{%mr^7HK$&SE>Sg?w
zP5)-u>Ur6p1Lct(Z`qStUedo>PeY=BF9kG3>&<VJj559|eMSoZv`#vkFb0A$Cw8Zm
z-v^&jx?TimR$RHnbnOZ&H)+44WKn5kKy#aDNxCaeg1n?GXa^dHo!c*gLKAij)Ea3i
zn3ZRwwL(n2uZU^@t$ib;lqK4OlqQHNm&B}vm=Z}$vt)Hkcq8Qja5_cqf@MasR9>Yl
z@C2a=n7`Op90g^Oet6lFx()<TRw{!=(#oK9g7g6u;a@lB)cPl^vt<?vR7)J{71jo<
z?x!48>IxE|-lr-Xhk7@7mw<iY%l{C*_S<{srv7s6y{CbF|8i|Ayl@3jlY3vjaqr6y
z?tk{-U#^{t<6Uvj{{t)-8Llk{gT+4G`||IW{$VZwREY?%MZqfsjDpw1tp<2?43^+k
zQM`ig0lrw2^g;Nc4<Ry$$YDfK5)VkmD|VMN29|iyjwo7(h%gi>6cx-iQf)cFECaX<
z=verptKs>#tWl6ms6nvf5L3zT@unzpCgNKV(O{9&NUcQIBZ4Fvjf}7)Mr-J8LVL-#
zTY(^>wNW_df?5VYCksH#@+b9-K40j=-<C}m_hX-cwIIC(N>~V9*0`2ej5r-Gitd9L
zHvxns&j_H*_u6(B7!m?(bz<ve=Tl-cHpe&^q76H!#&*}lu-)a}3Z7Uk|Av}CLwkG%
zV;aUpx1eAK?Y9RVw+0=|$Z>Yi#SOY3CFqFfppmA-i$s&ivgHUqIVl5%BOdaY^Z$T6
z=@YUGkQcz|_kaK9gLi)){+Iu@H1*4+zyCF4MVx+c3W&gI!NNwgwuyp{QBaa@LRp4@
z*w+AS;x9oGekFMS3-_-l{|omQ6eZ^WA94TH^%^m>*X{wG!LtXRf4-}4z&6m++tokN
z(fizrFGY%U^`fgmQ~-*WaN($p8$j|)?@p0|q>ZW%E(A~vy%xQC&4?hpmtK!Z3nEBT
zKcIjlS^Xw!39RJOnJ+<`xkZq(F)iYj?{PC2%r%dA(RH-O64O(}axDouig-xqL@XpK
z6t)Pe15s88hQ%OO?gjrgroh-~G18k*|5_0dv<FCN(@66u!07a5<m&{&6JySC+KPg0
zh#;9RNMw2&^2K!q^mY_PS97`pksXLUi%1tDI}zCh#9~Tl2Iy{x;8h}g@8<O)bT23c
z9By7CY6qOuDPAKQ;32OHG!-BwPtki&jeAiA`e;URKcst6To&#4k=F?(fi_{saPygC
zPEeVQk4D2un-~)Ef>MFrhkVZ=g5VB%Kag1E(RIaV#@Z6K2=oBTql?-B+K>iSP$7sr
z6gu*yir=L0cF`KJBAxCazCTT_{h>SBC1}~rD`EFa(L31jP+no6dA@nEf_ZK~bHv6J
zy@XueON{QN71R-cX9EIS{I>19EmTw-G8TmjjiCZ#sH{AqSLJB|(9hFOsUo?rf~q2F
zoahRw=2e`zl`*=Id%?!Na7^^Gx-m{S#^}bN*0PE~@kQI5O;Bl+Ze7e_OLr`KuD`~b
z4o>xkODh9g*wSXM6x0-UT;KXopfj3~sU|4@G>bKD0)KH;fcj{HE#5GrLJAPe{4Qoq
z8&}>wqZ4cc0TM1dhzAcZ<a}~O^ow*s5(?Ee%~yOl21b97S<G-}<K~6B8|xP*zuI<v
z8@sWe+t{C+{1Bk#L-=<Bg#zG@C=cT~tt%^9s%vI??;>prnP2k|5u|M?Us2lvz;Dw5
zoM{{YH@hzsJ9NO=VzC?u+c3s8jLr7lEeFh=D7D-nYmpY^<(pf9Aa`U$^suCpBb^NC
z43Q1<IV`y@pa;bY)NXFR>c8xtA6m?1>pHo*&e`re<&}Zfi~c!((0!|X9aFw8)Vh7q
zuvoQdxRx2v1lNF4C)&(`o2^XK0dOpNkRuN=<iWc&jaQFcJ~H3B@H|_yovYbCyAxHn
z@#2r?ejMz-Rlb%fUmM!kzA&&byfE;E3#v1-<odf+^;frC-ZEdXkjqxJb5-rLov2jH
z#nW@AgX`aWZT7WLOY4GRp=!bK#cn85%aYA2>4ZQzB<h3+q!Wsfs7~nMqK2^?M6Q28
z^suHwoaqo_IutTlg8Nxh<7{tSJ9M#I0M=Dd2}0VDwuCW(vZ4VTXK0u&Wer=!5Nl|-
zTk^~kR7aUeb(D!zM?gSzM6RSd`m6LrFopT1**%QG430CHgS%P7Mlr-1%&`7uL1j?~
zjx*E+x3Y%KVu&@=p|l=Q=zs&wPOyPBY!XAD>OtD4J)i}uu)-^3{{$(7DnQW$M9@0L
z0(WcIM-;ID^rUV>L=_LJkrGN152C^kF*#B~0fD-J=vGlewL+F0k*uVIdQR*ZLp}%Y
z8{%fi*UCRC#ZX$sQ^{;MXQ;VtsJ~^X4<3f`a%jjB2a&?WgZ`-%O?)=iix1$;zzf{o
z7a7}2xAwlo?0so=Q=pA2X_~KFsN>e{U`uu^_Om7347icesl9?}bOcitZ3>mu1V*{C
z#s~ocA?7Z`9Ouf`MHKOv4IPYOPa+IlEUyh5<I0*Ns#qRSPC}fMD_a}U#N)IO$JB1*
z$~HwZVv(Rmh4-c|Xyz){vt=z@SxZD8OM8eZ^{w9_0zJ{UKFY=li)ZTsX0G@dwxFIX
zsGrAg6*P<5tX)iA6%0K^<@87|XtM}SCA?fw@&s*`E^nrr)0N)VRo~K8Gc}#Rdv+23
z&CY8(!3&Pnb#b~bM%RV3UUf5D8C^xP16HK;0L_RVnii%=w>;JTkFdvmh3#nFzYhDu
z=F;9Q+4aH>b@y8NjdC0UH^^r*A#k%%27#MvwLR6Uo7VE4a@E&GN{IQoTmdm(S6jgU
zuX-8O@vm7swnE?=A@EI>b|0?zrl_N|uU+w{jY>%WQ@aA9{te$@f&jZt+h0kr?H#KA
zQsU194uL<*<^46-pGy_UUr8W;O+kMf!OM~Hg+%>@pgnYZ{WcRQ`pAgF&tiU1d;ujW
z0;pUD0G|&JK&Isnm7*4s0$e9>O0jC`6l>-cOUu)?onoWAth5^1PG33&c9xc2wPcF@
z>JKQH0{<>6DN8$6oiwjBv?`DF(!A0TluX}d3OM-#N~S1nen80-6^yhbQe(~O1PD_A
zKgIP3YLr^|Y%2*kO?=Wu<@s=cZ4KyStmSs-PE4>W&G9Q<g^xrj;Wwc^vE+*%2Q9O2
zTnbzZUwcb}Ga)^IfHRGN=K^3%KLH&mg^L(1EkmC(O26OpVbY<c4$6aSj6NeW7@}N2
z%%PqbUipcvk3I@H0FF|OxF+l#UVG5)@;bW2&xZz1pAfxZAf^Cx&g*caFFVNCXFv84
zhfOFpxiR%bAGL2vve!zWQto)UR;bR6E<I;3kfSqO0$su9FYgKL36+%3wnSt^4tb}9
z4CG&IpKFJ`|M4AT<;OitVIw-Gg0)AC2)Q9Y0TCcx-8!gnI<o|OKW8oRIlh*Va5;|V
zoq=3W!(|T=ZP6!{<16q#iRT`;u*9B~`A@$B>F`-90XDewN$}GGFm@XGkoG#6-D-ht
zka4o*2QwQ=ZAYv|*Sl3%U3SSEIB?N7=VMFixe_=s*8d=umzc3&&KBYtzD3G%#6V$T
zo56!ven$9WDEY&~RL1sWB5QD3xM{D<3$V}oD|i8=x)Cpo30{OsN@v&IfiuO1w<pg}
zGT9XZ><J$WBeP)9&KW_&yh5<A<>d$ZI|ov3+`K|CQ>D=znb(NuCs@z&>X>aPuZi1w
z_E~iFPa&U(H~$Rz5*V~_eSaOrp{nRN5P1`kDIk1ClF@BC%js)B4KFMJ(24+5fVUCc
zEaDny>C+^NRf?d68%6jKc@2@DAW{d!jTWwWvlndy5mYi+`Q&BSf*AWH5cGYYSyK>^
zEA{ZA#z}VEC&XnFdUPI(5gk@sIcp45Uo~Gg2RE^m>(NoLsD&$Pfv?;a@Q{(5RR;`L
zjhBsZjjCwoDw<j2I?lL`F>ac-hl(oFmEF3a6fQ@Bfvba;2f^^KW;0i_nKfBClQjfQ
zngcCYTQ9c;yV<G@T-64)cq3Q5F>Pz1qN>^AK<Cx&%iY04Z1o1NdIMXukt<rIL}}gZ
zP*DE4`j_hY64tzhGXof~l`GvEGS$xR4tTDfx_oM0%ht7Vb#1JvoinwE(v~Q%iWKP$
znPAZ;5Pjz3M`ck%Eig8d0m~7I9&LBcQ%un=aEl${FROziZ8xLq4&~)f^(6j;L#YA^
zBJo)Ull{}KoGt@)!=T+MCvKFLbZsMUY{rp)n*yjM8+}1PZXa`?FX(OX<vZndA-~RM
z`;ph~il(S+HfmznW)r@Arx6Y*zRgGs&}fO#8X&wJeTG24io)fH(1@TF$Lpit-VZzA
zqgNZKPLL(5AQMHbiAIuMAZnEG2*~3zu=d2iki3SG*F@xm0=@=afoRJVZ9zkDc)lg*
z{1j|CA(%=!aVM@Y!S$WG24=3ve^YUjVg?S~baLH;V$2HkAaOvZFfCRC00h=^$j|IQ
z$Q*isIbvrH*}45k#mE)txO|PGASjPu@H1}^ex8B|;!5CyB@^L{Zij%u(Ma$L|2c)1
z_KHT*O3&#NfEtS27iI);PMimo9eu3poDgN07EF=tuHly*W2Z$JRN(dBpxj6&B&w;@
z?c&sLrQd}(c<(Xy=Rja5#_<qV&PZJdD`KQBgjtv;xe%6lM)(V18E1sQ5LUuST||CR
Vfy2^Yna&J86jHuRlP(PC{{n0mHoyP?

literal 13351
zcmbVTe^49Oo!^yqg(M^pAdry6PlG|W0h3^3W9-BR|8{Y0<HROTb+T4qVS&i56x&qt
z(AG(CjwVW)oJne5b#4+XO`6i1TuWPb>ioJRGdDN8%+8?O8BaaaLhQMjJ34M=nErL&
z_g24FAm6o5%Xi<tpZmW1zTfZXec$7j(WoaNto!|DpV&+ge?SkZKqn&)UxCOqf*}~v
zPmGWQBuOwTM(tOPs0Y+IPWh=3dVn6$3}{9Q1`0;B16rI;`*j04C`<eG1A2Tf94Lgl
z#%~xg3>Zd?14dk~z+W^{JW!mhV;V52i2Veky+SZLFZrIDAU=RUISiCA^a;YLe?Y>s
zla#c3+?@BsrBTlVln)6Se_&|H%Q`8EI^yGk64mST1SR$E(MuBD9~$#}`<yCC%eaHy
zpl`%0=@4bS{-7J`QbF&<phxaVrn=<A!)?&tOTYy$F+eiJfQlgp)RV*@$*8Vq2Pj7E
zrM((2J*cWo*B(?c)D>!=V68lc_G-O!R#}SCKv`X$vZ!rk`RslurU2^d8Ld|X{8E%#
z)sKeJL)k*6&}(1}@Q3Q;zKfPILK!1dw5qKlZ?V^)7$e0LLs=7J^3u=_JxDPn@La-_
zULgibCy9&XKpA|kGO6e&%XnGzo%Xnco^v5Pu<8CsHy6ME=F*!pOW*%!>FTc@y!7f~
zbZY6R?=HR-_n@zv3Mz=8@Bfei@+NtW2xjHJ2WcO`pB!RYIjJ;)P?mvNMurI&Y83}Y
z1yAYu#Srkm>b?i}A>{!|g^5ISp)oHjX<aVgs4wVpN&2&B5H8L)?v)Bzug5zYbTRHr
z9Ly|=^ZExRoy+C%yE)F~;!r=e6Mxy-#s&hxwlOv^?DYiOyca#^+@nKY*GK@G46rT^
zSks0{0C5UGw~k$6%b@zWMajL^)Qc2BCf5pNWrDb?HC`>4Dp=53=e1TrYZJ9LUTaI(
zswb(b;)LBXNr_r3kFSSNgOIdtk0%fs4RW3|D<D||f8T?@haUquOpq|;bqa<Lr&-L9
z!IX-CvSIQ)$oU|h`$JF?H`K~BV7>YTv5p9$7f*%;f~}7fWPj3O^bR;MhH$|Ti5sfi
zR!&1Zk%G%0S|^gR3*-gjqWUy(fpi)}O;9;|LM>gLSh{}o{>SevzWU3r-oBDO??R1G
zcJcPa;;p~Wu902je{N4LzVP$f5K@%2f1Le^+)f{!!b{g;*+m~*pSb_tcjQ@&%P+n0
ziw8e^adC2{He^E8mu~!1cKJ{pBqkHG1>mEprO9Yl?czIEzKXtB8!{`Z!u#BxxVCid
z7q#Q+*2e}zXp(+)>-CUz?Y7?e`TdXI4cQ)%*;VV*vgk`nly7t}AgTS{QBZ|QJC?aT
z0lyz6tjq29yYS59BrBer$tRaA3c-MjIV;g#mJP6yZtq2pcP!`&j6%Z|&@hX-m-JlF
z%?4e#VSQG61zgDE@p7D04AOxjUIw~_nJE=`{q8Y%lt?e9g(hl~fkk75_CRLj{>LkG
zBqWoC1c<u~<Uaf+h-J#E+i}-WI(3-0p8i68=fEe%&y5h3FTpS%8U}d7K*CTuxo_p`
z4TPz3nILsLG6dB<!dGseaRY%%Fm#EAE`F_R1;Vl#YQvpFAMr}#M&bkgZj1U~EW1n9
zpOn%Nl{Bn37-B~iQi#3=mcoAqd6K1Yh={0kM3{&{*6NTeeGxU3r^4!3S{}3OC>3Ha
z@$BX^paUXwL<8+-YlC#9Fdf#s2RR?4b0Y;|Du(9Xst_*7mDj2EV9Jm}>0vZF9KsX>
z2GmEsLVgeA_}l8Ih->N>sfaeLg?HK%(FKjElAvF7*;+&SE^K*N6+;tbRS4@=y-Ukz
zD`=q7Oi|E4brF5AJd-k9n2Ix0Sf5t|=`ZU?wV;XMp3y&H6&Mg2OSUZikI+6+iTv$d
zU=Cz~;rjcqtjblhb;TkUWRO*ZWOog*fzX&MrNCWhFQFE&L6K-*&^v;JG$pyIoRs)#
z++$<jQAR3oBO&nxB+ZaJcn<8F-pBbyK}JVCUWxJ}?4$uW1V!0;U<cL^EK*p`!i-R}
z4UixeCErATFHWL^ZtgrM6{frPF_Ixw2DeP15>f%{<wE`-hhzXnSb(4ehnSy|bhu+-
zXKNsFygo<D(__qNlQz^sGt7Ef-0ziJCiTlyscy%;s=9@$o%2;YXU_>$`^BpLlYPq?
z0<!leT6Qe7?4EDgEwuEAEj`PG%D4^_!Q_k<PM=9w><gBTc}vI4Gj}!#mZPHOXp~Br
z%C8w-H%#{nrh3s-&*STB4N=u_y)V9(cO1IY4+LEmx!2_Wd$u~%K`SOv&E2x9>A`my
zp=_gAwh=T<No&Gfy<l#fH#f!x1#^pNZsE->E6X%gS@~M~x9g;Ag#?2)0Ya$ckS=|3
zPyHSz@u^eaV^)9qxTU99{aG;$afMQ%pdb=>3=OUkK2S(uG6o5&!zu;yBvvqLP)XF<
zDv8N~4-q;{vkjnjRL_$vJw$|6VY(YSLiY@A&ZDfTRYJcTi=_%1$)%~QfBf}3OVd99
z$y}U#@vGllkxe?g4cd3ASp=vg^^iBnZbk{3%xniyL4wCg`qX63p4iBE;x;%0VB{Gr
zPu>=I9^a5VdGibLK`74!flLthO3EfRiRR5eEBZ;1(7a7--nLB8y6u<<hK9*Q(}sj?
z{eo@7ylq2#r(oMI+O|&~P88dg3AJ&1qO3YL$d_$`E3siybl>z2!Q7NERYbonn$|6t
zHq4tg#JdI4Hqo?=H*H%<6qipLS;SsE4t6`lJlQ%P=~!%+3}6S+c1f)xu(eTv);=Af
zv$0&5X2{IvQhpY&HgulJ0Lx3Ih6iht&oXJk1z`Q)Ei;Qmups$tlUDf-Br!FR*EUfM
zowQAwv~ALbb=WrP6}CzLNZX{&W1IA=-lZjo;7T$K<E1%zU|@uRr?o*#Dh~u92U|nF
z?gpLP;%GbAIwaxA0Jg3nQmE)9ZDScd?xiqX2o`UZ2m$8SL<%n#g2lu4EQ<#y+-V3Q
zOOUj9KZ*iQPRm#h<d&%OE)W}<3&M>>N`>771PmV<Z@N}($N-OBwOJ4vBk(kY#)w+Z
z&8mc~c<q{Yvq)0=MuY4wC?Hk2K)hYam75G}U4v|31d<pZhvlAahl1>5h&+x+2O?V#
z!BClIyk|p0Y!ynt<`G*)gRCo%BEiBV6($=;Mvv`8$-5EhL8KRvE<|=9g0!1#0MWo@
z^^vVakYyWh%2gtHtb9Kd=Dw9NgB8}vLSzO{koU|LVDf4=EfW+nb3meoyB6DYcU&Xd
z+XTyI(XtuLo3&xV+B|P<j$3Bx1Z#(A?TFIY5N@BhY@cnoL*MzfU^yXLPUJC#i;i{w
ze?!=Y3}M?EhOjMRu30dzpEs|MJujGBMRO}}Ze3ZFA^0<~^L*tqaQ&9MvqN~|sQAQD
z`5CBSI3pU)@c3F;EVd&2euB)VNgRJHeweR32G<<md2|;H$3??&e$|z-ohL|y>cM#0
zVR<bZ&mKch8Sz<}zL!*gR%PqyR)5w_Lp<}9J!qDv0z$%AhiYLWrB>KsHOMcC<nIO;
z$!rapS#K+iY6Og8M59=N6T_ed<)G99ps}6+4N7Ngx^TgVIqT|ikS~P2V`+SzY7N~%
zBg1sctnVYbuqK8K-Kww#=6;f)B6@h=LbQSzE=W}wPGk01*7_io3px(aH>3HmK&jm^
zl+Z^EVM8pfAv1My-90dNKdxbn6e;wlF<UPxtqrUvjIp#{%x;^>u^*#k*cd4e7c;u^
zcxA+rQ`^EC=(8R8Qyk0kb7Wcx>lpnwJSzFgTEc~S_*twhNfIP6N=`jCH3HnBQvE{8
zN8v(FH3SYU;IxS;jFe>04u%RM44n+&LS>ub5+#p&i75Fj0duAhtZPBI1ikMISx(1D
zX`b(h+#IU{e8*BHha+Xdb(vz}(r}qFA2|5C<X1C?%^W$U1us-%rp9pEPKM3OkwnVF
z<uSC_UKJPvLn(WSRD>&n8#4ui2&g5)Fmhbrpp-jhZ@`7L%rVAskQ}B6Q6x*}u^a)2
zCBx-RaT2_iGbS8ULs|)rneu$~a%E3|R9*&Kj;w4l45!fmw(6E3vRJ9SH0WYV!$#08
zWnoJmt8R{1E?cH%8GO%J^(Z-|3Y)OE4w=4WfS%SzlszF=E)GmN#t(UV8X`O@z!10>
z@Y?0{=B&V8yFdQsmE*_)-+$$oi?9B}61dZT_gdfLJMZT}h;eO~Y*)LG(;j(V$F+^8
zTN+1N8f8S$&!Tw<nKX7JjnkpvV9Pd1Hx}T0$S=i7q|5hb&}VEllzV^xlFtOfno-#p
z0EZlqasSqjm;Ny-LyAKuj>798k6KsldGDp2f6;EL#Xhf{eHj19?=24@%e$Sf0*Gg)
z)4?LOC8<XP7bKcRUSJlX78b30B`x5DLF6LCAVe}?KmyKWANZIhP4Z5k<2>$Byimd5
zM551L3VLA~&3HWl#+&rCaTk2Sa~PpW^tllLJd%3cHzrZTTwqk9{Q)<_VKl_<MZF_N
zNX2M?y||IR$dxBA`uC&!49Ky{Ag2eVVhn@ej-->{6u1J*{{Vaw^zKQ|IC?kIhrU!0
z9Oj6+V5v0XMk5Nb9JmZqUUaC=0YF4l4V3)`YPtYoF5nA$06pnp`(X6E?0iqgae0HB
z{=C~Cg6{Nqg1F?d;&>_vGZ#A=&}YxaS=n)U;kFM-jBm=tT#v$zqfmqE0G*I>H|{5O
z6$$%#-ntd88A`rS9t2lGdDR<7Uh8|K58#-+YVye4a@%x=Xx}K5ZxYJ^o~e!Pm_*5h
z#c|_O+|Ac)7HT$&KruqAuK&@<+avKqLUpHD-5D)Rm>dhHb@QfmvBQFCvuN7P;|ril
zg=KPI!seJfyiA#lwnWW3XhW>&T&USOU$b-8H&?+w{S05TQ>Zy3)|`3G5Y<dm_n`IR
zw};>IU-vH)`jUD~UfUP#nJ&4z<%v7$FHQ<u4vSk3^VR*+9#k@J5vtq8>UJKkWBt+n
z_bk=1jq{ck-qMn=*1}6Pcfe@Mp&=mCg$aB8g1u$l-V#4Q+at6-A=sZ3?N0&>tgKHs
znid?b^N!Z|1;NoNIy!krXTni8y%+o+mGvvjTEc9bKKA;K=#GTBa=8vhwA?_LYXIB9
z*esP%9dri#JPbEm)#M?>*7h5o*hZncRjh8E(F^4}#By-xT8(voLIn6*)f_L0x5vld
z-^Dw(i&b4wJyfo3$YGOBsOcAL`lE)$rVa6~nXu5*D>n5m6Qw2K%>nY-QDBcPVQ++2
zDX&ALri#kz?$$QEqmOq9wOhs7t<y9#ynf@Y(>G7YpPzY7XxuI~ZlBgeou8KdwEx4?
z??3b5GXlJVbNg(s*nMP<6}pe{{ilTPQ-br<y!{k!KXq@@=IOn$^>2M6(efBXn%?S5
zJiZGeErMfnhIJvqu|;%j;T>C6Ru=6wfb4;{<;d%lBzLXV*A0AQ|D7Hn=sI>>jtJJ1
zqV*(iJqZJt*2+JOeQBr)kw4X;@iqg;c|)}ftyQ`TXgEnyxcUy22UjP`$|nzIe#y3V
z6%gUR3DR?=cm2T<;`5EWH^A**EA|ivEYw^D2@i9Y;)D8vx%IY#bitPd4JlvJG^Bi~
z*PwWb{t&7D(r!Q4t^RT=iQ?TfQ0$^qII_}SjQ<7;@RB}_!ATCbbuoGZ#}*)v%MtKw
z<n_4c;Nh16-!iJ3B%t>+A|QxKJ!}!HuYf<IH)k7CY25+gYy%%Q#*n}RMYy`!PtXTQ
zAPakA`>#Ov86P`%u+iEA+-Z62za~Oorl&5zsvhnc`yW=x++YeAtsl1aBN~!W5n<RN
z$e?zJr*V4@vI5k&HaZXItU55t(*j!7hINDBJ6|=jdhjTvd&%BCV03s)Iqi`I_Ef-F
z7(L*OoKZOoWj{sMZkxhcFgYXdM=$>R2ToN#_D;YCuvRuE;I+_jmqyM8{IJdIgI!u=
zGZkCaXq|_=1rPTCd6Sf9R+xCUGD2Qe#UO2U$lbYtJrEMGo(*k8zfbl#No=E?YDv|)
zS)vDhUO$tvWDJ~a;Lv2Nt)0O3>My$PA@8X7;uyPYyerpg;Vm&d5H5SuuC?1A@VNcl
zuGVzje}g7D<Zf7zjTm2j9In~&>G2<3e*1FVE7Wv|H63zlHpQMpd8_faA1;0Wrh>Cc
z)WjZzcKc+;l2Q>q4Um4*(0a&Ry$=ifr|GYff>KV^KDm)Xyh%Cwycf0><<A88!Y!#`
zOF;JHVBmtFINrRFDndb@pKF!3E#(S`GwdZOA?ca3t`YaB8z32r)(}$3Dz2q=KM)X?
zOr8Ml8FnmX&axvYxtR4n7xDoha^dgAVYg1Qhtz&)z|S^9Sr!eMy#OR<-{VOcfz(3I
zYOl|#w{qbP*k7S$z5_}v`QetSdYvOtR)uV1O~O(gy@2dmJ#TO%D#7<-G(rxLD7~yQ
zlvE|^8W-xe&)03AZ4~OB6ziUh9)jXc-yr$*N8pMcy=$+|{@i!k;7O=HE&{b57wyMW
zcJH3KVZpp{-n<dOiMdlWck=jJS+vxGohX4$Q{=AM_Qnyu?whk-AaKnclkbB0m}ox6
zn~x>Tj_3jTmoyY5RS-cSpg}Pz<1XH?Gy6(ZHceN@sSk^1&9`fW%7bF%!O27Sn%Wnd
zdghyY_}+e@>7>|n68X^gM_u>IY|}^ivW>i9W6GvEkWG_G(x&abQ^!~Cg-bB(6Ak-#
z!@fkBJ-RLROIb1pvSd%gr+7itqb06tfJ8fX+f|=XBt$=<%Te5h<97WX9sNn8Z4X6%
z@&paJpHeiWe5%87QzxW+rq%a!s6Q*U^t7ozYoj5KakN`u(TbrrqzE4V2UrkvVuK;C
z!1fFrP9h>|us^UD47yvLZ@UK8#R}gJLo2oUBkO7&U6(0<+Em`2bNngFwjNnCXJ_}X
zsF`C=SJlkBt;OVcO;**+&tZeItnvxQnZHk?vaIsyku{5yWtC5lteN9+Qr2WlOv!Zv
zw$xd81$zeQY>!ixXQVXg8CVm8_+-z33E>a0*!Z5oAx^V=vSpP;S&H3Wy#4Ab^NSoq
z4+nr;1L!uPLS|HXfGM2gc*`9~5E=1g7*xTqC=4l}ozxK{HVD~Zk?BELL<c4PQ)tPF
z*UOTw|I(NoeIJ|;@>&!`i;#D*VPWnbgtafKHoi4&_OKCbh0W|-E0(d%nR<VK);P56
zo*)us*67ZJy=J;&S*0$iy=$+HmA}<}y_+{Tt=zTNzk86kz!o!E0$MjkaA_#7h6JRh
z&{o5XMdiesB^%W5lN;0ub|RyR*@?!RkDb|QH<z`_d4n09#oTNJ`zS_JvV-CUcnS7J
zL|#H<5(t;YS}kS~?C^|t{MC$wTK|QbI|5`4wpQN=#ZJBzz8)6rn?(C2-n{9rVz0fP
zxLMMv{sq~oWG_<Kn7zmukz_9{KeC<wxeSGkHdUX599wGS4_TWBkn=b20BSu%JU~v7
zG!Lq#A47XXTV5M~W1KhD$y>v{P(t3f>w%a=ojlRo&yJzQ=MZ60B0a|XJTgF*bTZ0%
zE_g}O!lB5Z3&nKq=Z9RlP@mHvyOD5fG@P1*op)t(?CYpugtplqAo2zxZz6(RPx%n%
z?e8wm&UV#e#Ob7DSC<kDruO!~i<){Fktsx?h@g+MY9oIf64yF~k}J5sN0r}(*@+IE
zHN(o7(ilMs)5MgH;WU%lh#Vs+Vjyhw)7DtSt>&A}@lK)sak2jKnPWm_r&!sESLHGD
zE$dBde7#WDF4ncrv<ucPqIFB6vL@kZm_88ezjf;7sraz$T@V~yqN6JTEjGtGZf(1{
zEq*{)w?$mHMX+rZZClr9Pq02FS|0<1IBkpd-a2seK>TT;VT;(XMX1~=Rz9LeRnzo9
zocfveC)ydi(7aP@-YHb=603G49P6hK#e%mk-n<Czm!=(J(+<JWEjqdrd27_HTdp*k
zivXTtVk}zux*DH*Nx2!Y!y$>w_RlbU<$k#C?3V9>;ecp3z#9%c%GZFV(|3E@dpn5F
zJM?=S)SvIN@2ydPQAtAliy9iJLKz}y{T}>1JO?DTu!})_b$AbwK1e4=;IwfJDXLW=
zcj*U*;K<ZL19VCmNqY!EyTuo7FMjl^rE9mAUU_%%)gPl1>=xvNOdkNt+Pii_d8aCK
zW<@@LoU}g_S~!fC<tRv$SO{;(?S{I^b5muOg|fE!vNoZtT`X&#)Fz5bUk$t*m_8>I
zHHk${yf*KJm4wrbj!TcaN4)5`v<r?oGa)~U8(gmELT-ODr@-Z60v?wOA9H34pnLXJ
zM9?5u4I*gIibdNpY#Snb5!r_batTP(*#NAgYSA+iP4+F6XiOfy_ITmUstXp-XrBa|
zisYIK?aHx;AdfqD6Gpx=0g@{J5>z8kH7-+X8rCUm5WS7w5jV#@GaYf?hv0RD$6T__
zO50`{X1LkjnM)so;|(6~FmoNB594Sq>Cn*?GrhBAv&?Me$48e5c$}l=PVmQ{0=KMq
z{LGw7Jn$?|&LtIA+CB^GIJnLAL-~Inz;XV}-|=p*cxDhk<&utrBwaD9UMA4}PLF)&
zpE{k4eCsUl84|yBPJUd2KBa1)9kb?H<~AHLg6JGQ$MF46&-ugyr*J|pIYMrrE8^5L
z0k;`5zU7irq?&F<+|EyA(}O;mvsBWZg@5|Mr;u4BmiT`@LTpGrnV|_@8uN_~$<qf<
zDJ_)2^M!o|#qhxnY)sHTjJ)ll=brPs{ho8)kxMMXM6fY~PlBKh-zVhGk!Adgwp*Uc
zyI3UUNUXX41OkAHBojmpue=gOC9k{^gp>cjt^`pyfqx02XafJTQkr>UjVnRedF7QL
b3={abO!ZJCFm`PkJ@qG?^XEMIc<BENz65Y4

diff --git a/sync/account_sync.py b/sync/account_sync.py
index 063474f..dea404f 100644
--- a/sync/account_sync.py
+++ b/sync/account_sync.py
@@ -1,10 +1,7 @@
 from .base_sync import BaseSync
 from loguru import logger
-from typing import List, Dict, Any, Set
-import json
-import time
-from datetime import datetime, timedelta
-from sqlalchemy import text, and_
+from typing import List, Dict
+from sqlalchemy import text
 from models.orm_models import StrategyKX
 
 class AccountSyncBatch(BaseSync):
@@ -185,8 +182,3 @@ class AccountSyncBatch(BaseSync):
             logger.error(f"批量查询现有记录失败: {e}")
         
         return existing_records
-    
-    async def sync(self):
-        """兼容旧接口"""
-        accounts = self.get_accounts_from_redis()
-        await self.sync_batch(accounts)
\ No newline at end of file
diff --git a/sync/order_sync.py b/sync/order_sync.py
index 903c778..d5c9e2c 100644
--- a/sync/order_sync.py
+++ b/sync/order_sync.py
@@ -1,12 +1,9 @@
 from .base_sync import BaseSync
 from loguru import logger
 from typing import List, Dict, Any, Tuple
-import json
 import asyncio
 import time
-from datetime import datetime, timedelta
 from sqlalchemy import text
-import redis
 
 class OrderSyncBatch(BaseSync):
     """订单数据批量同步器"""
@@ -20,11 +17,11 @@ class OrderSyncBatch(BaseSync):
         """批量同步所有账号的订单数据"""
         try:
             logger.info(f"开始批量同步订单数据，共 {len(accounts)} 个账号")
-            return
+            
             start_time = time.time()
             
             # 1. 收集所有账号的订单数据
-            all_orders = await self._collect_all_orders(accounts)
+            all_orders = await self.redis_client._collect_all_orders(accounts)
             
             if not all_orders:
                 logger.info("无订单数据需要同步")
@@ -33,8 +30,12 @@ class OrderSyncBatch(BaseSync):
             logger.info(f"收集到 {len(all_orders)} 条订单数据")
             
             # 2. 批量同步到数据库
+            # 使用基本版本
             success, processed_count = await self._sync_orders_batch_to_db(all_orders)
             
+            # 或者使用增强版本
+            # success, results = await self._sync_orders_batch_to_db_enhanced(all_orders)
+            
             elapsed = time.time() - start_time
             if success:
                 logger.info(f"订单批量同步完成: 处理 {processed_count} 条订单，耗时 {elapsed:.2f}秒")
@@ -43,189 +44,273 @@ class OrderSyncBatch(BaseSync):
             
         except Exception as e:
             logger.error(f"订单批量同步失败: {e}")
-    
-    async def _collect_all_orders(self, accounts: Dict[str, Dict]) -> List[Dict]:
-        """收集所有账号的订单数据"""
-        all_orders = []
-        
-        try:
-            # 按交易所分组账号
-            account_groups = self._group_accounts_by_exchange(accounts)
-            
-            # 并发收集每个交易所的数据
-            tasks = []
-            for exchange_id, account_list in account_groups.items():
-                task = self._collect_exchange_orders(exchange_id, account_list)
-                tasks.append(task)
-            
-            # 等待所有任务完成并合并结果
-            results = await asyncio.gather(*tasks, return_exceptions=True)
-            
-            for result in results:
-                if isinstance(result, list):
-                    all_orders.extend(result)
-            
-        except Exception as e:
-            logger.error(f"收集订单数据失败: {e}")
-        
-        return all_orders
-    
-    def _group_accounts_by_exchange(self, accounts: Dict[str, Dict]) -> Dict[str, List[Dict]]:
-        """按交易所分组账号"""
-        groups = {}
-        for account_id, account_info in accounts.items():
-            exchange_id = account_info.get('exchange_id')
-            if exchange_id:
-                if exchange_id not in groups:
-                    groups[exchange_id] = []
-                groups[exchange_id].append(account_info)
-        return groups
-    
-    async def _collect_exchange_orders(self, exchange_id: str, account_list: List[Dict]) -> List[Dict]:
-        """收集某个交易所的订单数据"""
-        orders_list = []
-        
-        try:
-            # 并发获取每个账号的数据
-            tasks = []
-            for account_info in account_list:
-                k_id = int(account_info['k_id'])
-                st_id = account_info.get('st_id', 0)
-                task = self._get_recent_orders_from_redis(k_id, st_id, exchange_id)
-                tasks.append(task)
-            
-            results = await asyncio.gather(*tasks, return_exceptions=True)
-            
-            for result in results:
-                if isinstance(result, list):
-                    orders_list.extend(result)
-            
-            logger.debug(f"交易所 {exchange_id}: 收集到 {len(orders_list)} 条订单")
-            
-        except Exception as e:
-            logger.error(f"收集交易所 {exchange_id} 订单数据失败: {e}")
-        
-        return orders_list
-    
-    async def _get_recent_orders_from_redis(self, k_id: int, st_id: int, exchange_id: str) -> List[Dict]:
-        """从Redis获取最近N天的订单数据"""
-        try:
-            redis_key = f"{exchange_id}:orders:{k_id}"
-            
-            # 计算最近N天的日期
-            today = datetime.now()
-            recent_dates = []
-            for i in range(self.recent_days):
-                date = today - timedelta(days=i)
-                date_format = date.strftime('%Y-%m-%d')
-                recent_dates.append(date_format)
-            
-            # 使用scan获取所有符合条件的key
-            cursor = 0
-            recent_keys = []
-            
-            while True:
-                cursor, keys = self.redis_client.client.hscan(redis_key, cursor, count=1000)
-                
-                for key, _ in keys.items():
-                    key_str = key.decode('utf-8') if isinstance(key, bytes) else key
-                    
-                    if key_str == 'positions':
-                        continue
-                    
-                    # 检查是否以最近N天的日期开头
-                    for date_format in recent_dates:
-                        if key_str.startswith(date_format + '_'):
-                            recent_keys.append(key_str)
-                            break
-                
-                if cursor == 0:
-                    break
-            
-            if not recent_keys:
-                return []
-            
-            # 批量获取订单数据
-            orders_list = []
-            
-            # 分批获取，避免单次hgetall数据量太大
-            chunk_size = 500
-            for i in range(0, len(recent_keys), chunk_size):
-                chunk_keys = recent_keys[i:i + chunk_size]
-                
-                # 使用hmget批量获取
-                chunk_values = self.redis_client.client.hmget(redis_key, chunk_keys)
-                
-                for key, order_json in zip(chunk_keys, chunk_values):
-                    if not order_json:
-                        continue
-                    
-                    try:
-                        order = json.loads(order_json)
-                        
-                        # 验证时间
-                        order_time = order.get('time', 0)
-                        if order_time >= int(time.time()) - self.recent_days * 24 * 3600:
-                            # 添加账号信息
-                            order['k_id'] = k_id
-                            order['st_id'] = st_id
-                            order['exchange_id'] = exchange_id
-                            orders_list.append(order)
-                            
-                    except json.JSONDecodeError as e:
-                        logger.debug(f"解析订单JSON失败: key={key}, error={e}")
-                        continue
-            
-            return orders_list
-            
-        except Exception as e:
-            logger.error(f"获取Redis订单数据失败: k_id={k_id}, error={e}")
-            return []
-    
+
+
+
     async def _sync_orders_batch_to_db(self, all_orders: List[Dict]) -> Tuple[bool, int]:
-        """批量同步订单数据到数据库"""
+        """批量同步订单数据到数据库
+        
+        Args:
+            all_orders: 订单数据列表
+        
+        Returns:
+            Tuple[bool, int]: (是否成功, 处理的订单数量)
+        """
+        if not all_orders:
+            return True, 0
+        
+        session = self.db_manager.get_session()
+        
+        processed_count = 0
+        errors = []
+        
         try:
-            if not all_orders:
-                return True, 0
-            
-            # 转换数据
-            converted_orders = []
-            for order in all_orders:
+            # 按批次处理
+            for i in range(0, len(all_orders), self.batch_size):
+                batch_orders = all_orders[i:i + self.batch_size]
+                
                 try:
-                    order_dict = self._convert_order_data(order)
+                    session.begin()
                     
-                    # 检查完整性
-                    required_fields = ['order_id', 'symbol', 'side', 'time']
-                    if not all(order_dict.get(field) for field in required_fields):
+                    # 转换数据并准备批量插入
+                    converted_orders = []
+                    for raw_order in batch_orders:
+                        try:
+                            converted = self._convert_order_data(raw_order)
+                            
+                            # 检查必要字段
+                            if not all([
+                                converted.get('order_id'),
+                                converted.get('symbol'),
+                                converted.get('k_id'),
+                                converted.get('side')
+                            ]):
+                                logger.warning(f"订单缺少必要字段: {raw_order}")
+                                continue
+                            
+                            converted_orders.append(converted)
+                            
+                        except Exception as e:
+                            logger.error(f"转换订单数据失败: {raw_order}, error={e}")
+                            continue
+                    
+                    if not converted_orders:
+                        session.commit()
                         continue
                     
-                    converted_orders.append(order_dict)
+                    # 批量插入或更新
+                    upsert_sql = text("""
+                        INSERT INTO deh_strategy_order_new 
+                        (st_id, k_id, asset, order_id, symbol, side, price, time, 
+                        order_qty, last_qty, avg_price, exchange_id)
+                        VALUES 
+                        (:st_id, :k_id, :asset, :order_id, :symbol, :side, :price, :time,
+                        :order_qty, :last_qty, :avg_price, :exchange_id)
+                        ON DUPLICATE KEY UPDATE
+                            price = VALUES(price),
+                            time = VALUES(time),
+                            order_qty = VALUES(order_qty),
+                            last_qty = VALUES(last_qty),
+                            avg_price = VALUES(avg_price)
+                    """)
+                    
+                    result = session.execute(upsert_sql, converted_orders)
+                    processed_count += len(converted_orders)
+                    
+                    # 计算统计信息
+                    batch_size = len(converted_orders)
+                    total_affected = result.rowcount
+                    updated_count = max(0, total_affected - batch_size)
+                    inserted_count = batch_size - updated_count
+                    
+                    logger.debug(f"订单批次 {i//self.batch_size + 1}: "
+                            f"处理 {batch_size} 条, "
+                            f"插入 {inserted_count} 条, "
+                            f"更新 {updated_count} 条")
+                    
+                    session.commit()
                     
                 except Exception as e:
-                    logger.error(f"转换订单数据失败: {order}, error={e}")
-                    continue
+                    session.rollback()
+                    error_msg = f"订单批次 {i//self.batch_size + 1} 处理失败: {str(e)}"
+                    logger.error(error_msg, exc_info=True)
+                    errors.append(error_msg)
+                    # 继续处理下一个批次
             
-            if not converted_orders:
-                return True, 0
-            
-            # 使用批量工具同步
-            from utils.batch_order_sync import BatchOrderSync
-            batch_tool = BatchOrderSync(self.db_manager, self.batch_size)
-            
-            success, processed_count = batch_tool.sync_orders_batch(converted_orders)
+            if errors:
+                logger.error(f"订单同步完成但有错误: {len(errors)} 个错误")
+                for error in errors[:5]:  # 只打印前5个错误
+                    logger.error(f"错误详情: {error}")
+                if len(errors) > 5:
+                    logger.error(f"...还有 {len(errors) - 5} 个错误")
             
+            success = len(errors) == 0
             return success, processed_count
             
         except Exception as e:
-            logger.error(f"批量同步订单到数据库失败: {e}")
-            return False, 0
+            logger.error(f"订单批量同步失败: {e}", exc_info=True)
+            return False, processed_count
+        
+        finally:
+            session.close()
     
+    async def _sync_orders_batch_to_db_enhanced(self, all_orders: List[Dict]) -> Tuple[bool, Dict]:
+        """增强版：批量同步订单数据到数据库（带详细统计）
+        
+        Args:
+            all_orders: 订单数据列表
+        
+        Returns:
+            Tuple[bool, Dict]: (是否成功, 统计结果)
+        """
+        if not all_orders:
+            return True, {'total': 0, 'processed': 0, 'inserted': 0, 'updated': 0, 'errors': []}
+        
+        session = self.db_manager.get_session()
+        
+        results = {
+            'total': len(all_orders),
+            'processed': 0,
+            'inserted': 0,
+            'updated': 0,
+            'errors': [],
+            'invalid_orders': 0
+        }
+        
+        try:
+            logger.info(f"开始同步 {results['total']} 条订单数据，批次大小: {self.batch_size}")
+            
+            # 按批次处理
+            total_batches = (len(all_orders) + self.batch_size - 1) // self.batch_size
+            
+            for batch_idx in range(total_batches):
+                start_idx = batch_idx * self.batch_size
+                end_idx = start_idx + self.batch_size
+                batch_orders = all_orders[start_idx:end_idx]
+                
+                logger.debug(f"处理批次 {batch_idx + 1}/{total_batches}: "
+                            f"订单 {start_idx + 1}-{min(end_idx, len(all_orders))}")
+                
+                try:
+                    session.begin()
+                    
+                    # 转换数据
+                    converted_orders = []
+                    batch_invalid = 0
+                    
+                    for raw_order in batch_orders:
+                        try:
+                            converted = self._convert_order_data(raw_order)
+                            
+                            # 验证必要字段
+                            required_fields = ['order_id', 'symbol', 'k_id', 'side']
+                            missing_fields = [field for field in required_fields if not converted.get(field)]
+                            
+                            if missing_fields:
+                                logger.warning(f"订单缺少必要字段 {missing_fields}: {raw_order}")
+                                batch_invalid += 1
+                                continue
+                            
+                            # 验证字段长度（防止数据库错误）
+                            order_id = converted.get('order_id', '')
+                            if len(order_id) > 765:  # 根据表结构限制
+                                converted['order_id'] = order_id[:765]
+                                logger.warning(f"order_id过长已截断: {order_id}")
+                            
+                            symbol = converted.get('symbol', '')
+                            if len(symbol) > 120:
+                                converted['symbol'] = symbol[:120]
+                            
+                            side = converted.get('side', '')
+                            if len(side) > 120:
+                                converted['side'] = side[:120]
+                            
+                            converted_orders.append(converted)
+                            
+                        except Exception as e:
+                            logger.error(f"处理订单失败: {raw_order}, error={e}")
+                            batch_invalid += 1
+                            continue
+                    
+                    results['invalid_orders'] += batch_invalid
+                    
+                    if not converted_orders:
+                        session.commit()
+                        continue
+                    
+                    # 批量插入或更新
+                    upsert_sql = text("""
+                        INSERT INTO deh_strategy_order_new 
+                        (st_id, k_id, asset, order_id, symbol, side, price, time, 
+                        order_qty, last_qty, avg_price, exchange_id)
+                        VALUES 
+                        (:st_id, :k_id, :asset, :order_id, :symbol, :side, :price, :time,
+                        :order_qty, :last_qty, :avg_price, :exchange_id)
+                        ON DUPLICATE KEY UPDATE
+                            price = VALUES(price),
+                            time = VALUES(time),
+                            order_qty = VALUES(order_qty),
+                            last_qty = VALUES(last_qty),
+                            avg_price = VALUES(avg_price),
+                            updated_at = CURRENT_TIMESTAMP
+                    """)
+                    
+                    result = session.execute(upsert_sql, converted_orders)
+                    
+                    # 统计本批次结果
+                    batch_size = len(converted_orders)
+                    total_affected = result.rowcount
+                    batch_updated = max(0, total_affected - batch_size)
+                    batch_inserted = batch_size - batch_updated
+                    
+                    # 累加到总结果
+                    results['processed'] += batch_size
+                    results['inserted'] += batch_inserted
+                    results['updated'] += batch_updated
+                    
+                    logger.info(f"批次 {batch_idx + 1} 完成: "
+                            f"有效 {batch_size} 条, "
+                            f"无效 {batch_invalid} 条, "
+                            f"插入 {batch_inserted} 条, "
+                            f"更新 {batch_updated} 条")
+                    
+                    session.commit()
+                    
+                except Exception as e:
+                    session.rollback()
+                    error_msg = f"批次 {batch_idx + 1} 处理失败: {str(e)}"
+                    logger.error(error_msg, exc_info=True)
+                    results['errors'].append(error_msg)
+                    # 继续处理下一个批次
+            
+            # 最终统计
+            success_rate = results['processed'] / results['total'] * 100 if results['total'] > 0 else 0
+            
+            logger.info(f"订单同步完成: "
+                    f"总数={results['total']}, "
+                    f"处理={results['processed']}({success_rate:.1f}%), "
+                    f"插入={results['inserted']}, "
+                    f"更新={results['updated']}, "
+                    f"无效={results['invalid_orders']}, "
+                    f"错误={len(results['errors'])}")
+            
+            success = len(results['errors']) == 0
+            return success, results
+            
+        except Exception as e:
+            logger.error(f"订单批量同步失败: {e}", exc_info=True)
+            results['errors'].append(f"同步过程失败: {str(e)}")
+            return False, results
+        
+        finally:
+            session.close()
+
     def _convert_order_data(self, data: Dict) -> Dict:
         """转换订单数据格式"""
         try:
             # 安全转换函数
             def safe_float(value):
-                if value is None:
+                if value is None or value == '':
                     return None
                 try:
                     return float(value)
@@ -233,7 +318,7 @@ class OrderSyncBatch(BaseSync):
                     return None
             
             def safe_int(value):
-                if value is None:
+                if value is None or value == '':
                     return None
                 try:
                     return int(float(value))
@@ -246,9 +331,9 @@ class OrderSyncBatch(BaseSync):
                 return str(value)
             
             return {
-                'st_id': safe_int(data.get('st_id'), 0),
-                'k_id': safe_int(data.get('k_id'), 0),
-                'asset': 'USDT',
+                'st_id': safe_int(data.get('st_id')) or 0,
+                'k_id': safe_int(data.get('k_id')) or 0,
+                'asset': safe_str(data.get('asset')) or 'USDT',
                 'order_id': safe_str(data.get('order_id')),
                 'symbol': safe_str(data.get('symbol')),
                 'side': safe_str(data.get('side')),
@@ -263,8 +348,4 @@ class OrderSyncBatch(BaseSync):
         except Exception as e:
             logger.error(f"转换订单数据异常: {data}, error={e}")
             return {}
-    
-    async def sync(self):
-        """兼容旧接口"""
-        accounts = self.get_accounts_from_redis()
-        await self.sync_batch(accounts)
\ No newline at end of file
+    
\ No newline at end of file
diff --git a/utils/__pycache__/redis_client.cpython-311.pyc b/utils/__pycache__/redis_client.cpython-311.pyc
index e95d5ff6c9c814a77692b6eee0611309a032fc02..1cff97424c1790025c35c1499fd0cb41ea2a5956 100644
GIT binary patch
delta 8176
zcma)B3vgRknZ8Fa>n&MtTejtg{7@1*c53JSb`r;l>$J6##>&G{edR=sB%3R_Nz7GM
zb_-<Lv~_w~a9`9wX<ZtMcLZ#JWg8ku(=9WVvf7E!kfksrB(p5I17!p3?Ck%aD?gN`
zLyzU}p67r5^PgY;`Oek3?~>pCiWpxt7_=Out53Cr&K)^xbdjmE^$kf9R`?Y>$IHUX
zh{~@b9OUKUqKMkBj%fUvh}N%-==?fXPr~|$!Ea!BMc5cI`AreC-yA9S7e_39OT_B8
zMr?i?YgdNt5xd_WarhmClW`p!uX>E*i(Zj&-0Sc!CBM_flOE2ezJ=v(AIYi0!$*$>
z1)t(<uFa6s_4IYO_qXrq-qG1XO=KUrk{TpkGTJS3&`FtDS@oF0UqM^s^~!3<dFU@?
z9(xVsDtYf?oWJTccar$4L4IxONAfO0?9`}qk>XUn(n5%Xu2qeY68gHThB)baszFjp
zR~C&ol!GQYdw(bziuVr;N29@kcxX7<KQcTV7HXg^MgS^>68gI$5Ajf=dO0agZB!d%
z_9f6DEJav`(1_4Pk7)nSPzKqY@_`^9iV5ZP_gbIbi!~$|LsL|OH0)bX8+CQ0F4e1h
zRt}PXXMDifhTY`hU{qL%JyrquRDzd2Xxdu58VWHLKqX6{(Kk$6$hy>TO^?f9U1OGQ
zWIuh=;)8YFvTUkFQ9>6AkO^#dWi${8#tJm3p!Zt6WG@x0ys8xYZ%_T)`iPutrw5#e
z9qXZHR0mLb^VP52`11Jm)6<p02Kt_}jWkfDD^P{%Ns6+`wnEWoV3P^kv8kPY-ql8S
z&>y<il{4)PC~R?(46%{gOO}&EsqH1dQj)*W2G4TRL-%|3kPURoQwNj1=UK6Feu`X?
z5F7~y27*F0PI44sBf=(x%?Jy|(@E;I(@m9YYnf6zumjVEEp0&?NtZ43%a!%yA5)hq
ze?!P<>W%7N8TkU0*RCgBbaSo4un&g&6q3|YI#9b@#rD!qCu(cRcT)dSdyJTwDFZmq
zLkI(@*7}vQ@*y0l6tF(0INl%P1&XatBRoSt@7qQO=}&#`J-ygZBkafeK7d@&v0!*4
zD8zE=SYR*+o*EaPz{Z0Ja)kMf@D)j#Et;IJTvET1t+xoe=9eq2^#D|il`uDL4~K%$
zc+*Hghz0ut0|UdO(fH3&bjbjL{rjJ#A8bd7KDqE9PRC{+#tQIFtU#OQR7Zv3(UDkw
z%~*|N3O%;5v6IZw6O9S@4t?0zB-6c!{ZMGmO`mLYZxK*zt|$;Y6&(l-gUmquSWpnc
zSgQz!V)2|RcrqT0^3op9uils6=pFP6%}Yptey6$0eHdlmeW&RM&6~(yQ!Opc#PbIi
z^!wb_>a9NREuXgCCV%T5XS+#$(WHdDFqL|Ag;HkzBFbX>h2LP|CHhS3dKKCsS3)<e
zDM>QDg|A@SR}oNQ;cEylBQS?tP*%Tam!_aSXB-)hg)r{K`f-uMt2k%?VPWFeu=ovx
zg@x&%h+AsP?`uA?Owvc%mJvtl^|r%AB}qt`Rt1S}L0W(&SFcSr!1$cv*wJ8o!Qbvw
zRwF69XejD%2uErK3~~K@ARZ7>SfQR<hh%pR)Xiy@S8W=q#%l9EM^~?@AWf+U*L2Cr
zOZ4US52_@8pk#wLiJtKB7G=hqj|m_B#xs{R2g2bwZ<e%t1%)!}vabjlU$~oLb)0RH
z>iLKbd;N<IB{Z|4o^+)CykV!@vtSf-i|!Bc#QpX6U%oLxZ~Vifl^@b0Tk6Og^z&OP
zRo}vyo}k~{Qk`TT!SvsUm0J;3BH-5;zWMAcHLqT-IRABI3y|F74$pWF2Qx>%i^0DK
zjblp|eaUI}RuAD*(XICra+_Xg-%B4?yUYny9OFYi4Jjz8acYV}TtY1>CzUi)U2WdR
zjgvzo2VtcNO+u^T=r0=_4pI9Gfg>LNrIgT#x=A&yYOp)yyrS^<Pw3~`lFE;?8AQFH
z5DmQQVIq(--38j<vRD%JcT$RkQ7jUTV_^6pG``eJbzFfNkRynCQ4JEcyqf)Kc<l=c
zQLPpAc)HE0Q>80hgy4-knIr~tz2rJxPha0&ZZ$<~?%HmU+I=QihVeLh1SdE}lc*N;
zct}WzH{r~@8EfeW+pV1j-ZI~}u&3pu?4)dAq-Yw019U(>AVUe!GML4hAL(Gy?%m-&
zRM2OfoN2A$;ut0JX=pwl$5Sew24!AOs7;vTNQUxh$TXMZZKCFRj<<_uN_@^nN5cGw
z86*$!EO&yO;7-c>xD(_kmne=`&5Z)<swa!lap>baO-hT%O<HJ+#g-J6qU8?1u!@##
z+@bG-e-s!XVH0h9@qz(jB~Z33lzDxA`39)B-ld+LSqd$tg_eX}tSJzYa1;(rI7KVC
zFX+jGuc`0Q(<RzP2l|@mWavUnlzehujn^+Sk8#pAXC8N{C=&@tcZv>PEtZI-yz>Qh
z!Yvk0+EJM<(Ou}Fggf&CvABnW-CedI5_Ylfj$NGhW8Ni_`CYWprJWib>|+ln?IPXO
z+3U*bgx~<s0EjfFV!5L5Sbsbe2?|5>&Ccb(%YNVK>9_=w32y`BbjJd*{)YnLKy)CO
z(?H)q1WAK{Zl6;_IWim#o)Uh71O5%5S9lk*k^s76S9STfq1^3LOUEjUq}Y#17cSAy
z?%LYn67YZ$_99?(5{v*jd35-ML`3#uT^|BFiq&v(j-bjp1zUk~FgzTH3kRuZw>^om
zHm8aW3-KT?#IfM$hjXugL<l|{8XlcrOH9B}oztM4SUeCJk&gC-0A2R+=ONe+&%?pd
zC?6BvLNUttFsPE#^7Q=f*3util^TxAVE^z#L&8s?$l|tefvUQeu4Btzu&^Fgn=`TS
z9*#AlR%}-!)iCnM$^hu6x?J?pE=7^V?B1l~U5%EL5S3#;gOlba{5{IeDvr?ix>hSc
zRB`S)T5<0ZORb^&0}dc#t{GQP_-18Z>c97;-dR28s`^smsl?=gjI$-{Y?<Zc_MPOK
z*Ei++R^vAs&+9JSpIOq8UDA>9?#z03PG}}H*XJ9x7q(=U?8q+Jk@0q9y&V&pSrzB<
z(30-Q$e&YR?!H07yEWWv>j8dLw?(zXDtl`gfx=sjHITn(#{9+Nb`A=cie*r^WOZ~H
zm6v>_9UA4^auw9Ptx-bF+s5{_P<U6P-MvQsuGPJ}RsL=h!F;O{Q1}^I_m`>J`@TSu
z7cr04m;8|#9vxM92LMPpGSEc~h!NZ@Hsw!aNfvhc6+lkIb_VxR_ytz}9N`+me*(ll
zatg~i;VS*#2kObsski6%sXsUVh9qyk@zv{(KXc=m=^Kx~A-n{`db>w4B;R=YySJYI
z+~U^jFaOicZ-0GlrB5$N^ay(8TyR+phvBl?A3Qm5ED${kE+z1AOZbFLG?}LxbG#X4
zYLPDGrF?RtbQhjvomXx_;+SU<2Wjf3?iPKiG}njdrVRj+o4#*%p4QTBE!)(sSDdZW
z2QDn5#+6;IO|zWL&@`^PW-Xr>{5qepF3nn(&T^!<X~tG@)mD4ORy#SEu{CCGjcHrs
z?O7%Crsfs*s!G%965$-3z0X$k_pr)8=w+$rSL`G7@;V?mEGDYsPI_W<InmJ1IGinb
z9mpq$r{07vZk;Ow$-pZtOT3ni1-gT$BHh?pM)dSRYkA?uvaq)3-T*^;yM-UZL-<#K
zQ8+)i${R0!McQxS4Xm?c-CZ5P$YPTe?8;g6$_H%8ko|+ga3tB!g3#Y^0|*M7fFbct
z`uUNoi7qeulio{?Fd~XHW1jg#MhZ)}pmxk#;0GV$#U}W6#ttv|gu``OH><E{ddU0q
zCvBU|YpyugocCT(Uifsz*^_nl&?6h2^6O<aw0Y%{!^_cCmfyuyme1HcS8a7yY;}_l
zXKYPbTT|NBbo;vAa;7U?a$xc}0DOKJyRa^^X-{_39;pnN(I3p}52o3NwzNOE#+_D|
z#?Vtf*RF53au==IZA5;tytIA2{Nj2g<Odi7g$|f7ATZzilY;)J-6e~2^hveDoKVJb
zAM$BP#yGbMXjBn03i`w<S2NI}O+dj_aTJkHqWYY?kPR>zq7gMf)T<gCw!+4QRxFxS
zA&a2b?y;6^=9LK@%%RtCA~%GmDoYaSsT38WjxRc=egzbJeO@`n`E?0{XrNol9rQ_C
zaY>lf855>Bx@$g(#<+u)Eq4<m{Ytr`nb#C*5+$NBVHVB2HqYD0nbl$uEU^W2G*22(
z$1+jN>&8G{;ZWewdT9|!(OlR>IKoBAnH6Uupt^ESGSs{#>SMB_Tn~rDl-DOLi+LKa
zTugRFeW6TXs09W99Y2I^Kz>@I7A>gXXBRQ^gtfqwCR|7oOliG?KiUfDu~oDcwj&45
zo7FDbW8{ol!^Lanj0?fXGM5+ah57=GbxbY_Q_zn#HK>;xcxB-fz;B&#-<%kZi{tyt
zd>XQY13G}M8`q0U-Z-X&Yl;aG-Rn3!AzFBWr8;;sUO<4cI{0FilS9tJa>ddnJs>&?
z6$HNeS>USG`KjPB<e1B|DC>$ZpDRP#d<^ETq7hiDO>|+Dz2Ba2J>oi(;@NZI=5gjv
zc`m$SK?dW(g;Mc&Wr=sN*eyx5C696gvOc)rpl~3>cL?`6N9$qKuYd3a3tTs!_~+|S
ze(}Z&kKTOqZ1?q-U;E8-k1dYXW9qe1z+B4+ppOXu4ugfu2*@~kLpQ;*p!yirgb<P`
zz#Qoh{So4wkcPr7Tz|+6Y<JQ7p8(X2mH|j_W2H%V_3Qy9Bz|x_cxr>dNcE@}yD>#2
zofmP9`QGpba)ZweygCWfz*L-&0m#7{N+1&g-u~c)V_X<ycYtARM>3vM9*YeGq7q{Y
zV{HT>icMM|r9wP*A{0Nyjuq$|0g9cIkA+6=WLMw9QMgv&Ak3eCkI4?Cl~`o2LP|cC
zX*1gjIp~?w&)-?%!B~!jko(7jIUQr!gTq1uZU8atICr@LGsV~iKp4fDW;u8bDm;wY
z-(ffHz_HQj@%~t7EI60P5jnk7|8O8Y3iD{$Cif4;hNC$p%g<FYbFniJubs%tlljx{
zzo9(lD>(h|0`k!#Tspyhcmys3XPIN~9Yo`pao43?E8#P(ke;VIua(wLMzW=?r*~hs
zl|9{cw)^Ss)7xj<<)^!@*-IzZW$elNti2v6ya9Q<p=F%RILlr<H5EvEnlql}ETFS_
zTrpEo{Ziz)$keV(#j0$@s&U<nx$LUB=8Cyya(BkuoHaM6*$3FX!+CngOljHa-Lnd_
zp>)Pm^TMaEdYZ3znx{+7@3`z`a`$9Cd(P^|RTGN$OF{C`b3@ODUkJ}~+Tv;kXLpRZ
zPZZPgs=DO+&Wg#USDcM$XXA{k6680u;)MhH0Ziy-+|^gzjaS@_Q^(J@XPP!;+?%uR
z&2Yq*RL_*vUoC68Qr0weB2%_1Ted1)wrZxVYGOOEzmn?Pvue&(I&uF~>&Dm3*h*%r
zK-pO@XY&AS1ht(d<9Ic3C(B_WDz3Er^e!}5%Zme(OEVQs*@~uVZN|PXYhO3ZxeQed
zz;@*gQ^iv)Q)91fO#9Yk%h!%;VQ{5)kqLHXJRMn2$GHA_{gSD*(_*H6Teg1NEN3YO
zApmFhz|u=++_j*Gy=o>2YgQQTRo5!LFKegPW-3=^D_2e^L2BL7SNp!&H}&xJr!uu`
zvbAd_v@qzK)^GNn>wE3MxdR!P-?!%c?#tDg^<9_ane{yxU(XeHPukt{{<7wY?UQxS
z-aFH{0y6c_cF)|i5i*ULvgQS&jb_T)vSop`bXnW&+t=NmtQ(n=9kiT-Yp#kH^y%8(
z3+({-x&HwvlX30My7s1Bdtt{W)Y9K=NMLw-6+WwQwGCkGw7!Bi-FIK_ec=6%ZS!@i
zxgR%e@xtShb<4V)CdFkVfx=~zsZ&;TxuSIEhN8=>l~}Vu2{rG?F#nEP+qqi)j>X-1
zkNllRg86%tfYj3aRy~G9xL}83`Csp(pG4ZAw($46zxI~PMrE{gZzub$%U44~dz+GY
zXbMPSgj$rNhU-53))GG@y?MaEFCg{G$srU99avN&R3L0b*n;3kz^j3Pzo|&qwAV2=
ziNInVzW5e?fbczpHxaTN#0cRkX8#M}76OI|K}l%kKAQ*60rmsrW{E%-V;chU>)3y!
zdiG7oHa|p^j_KGehtCW5NYC`%{rSwHK>DG<?4hGl@h-TNF6~>JT;WodPJ5?g=eJFt
z`Zl-$6ff|XTYo&nvUftOOX)segSGC<z3B(`{nXF$>4QhofnfIFAS>Mot(~CYdHF1d
z&kOC+Grg}5Gj&Qw`tU>Pfuq^O$E1e4;C>k$>2uOVpRTEN&JaGA^cz77R_sTpM8K1U
z{kS|Tj0$r4-Y)xcB;*3J7(s=A%r|EkjfcXqru+|V!k4g46+bl+iXNr6`n-*J3Nm{O
zyD`UR#jySt_4>##KN=2h6pG={h7T9}KicMRD$+g5{%F8&t3HtC{>F!%^&i|6(Gb|R
PyW<C}{*NEi$`ty4l79|e

delta 4437
zcmaJ^dvKK1760zOAKC0?-<#*=%?1(@As~-HUPKHbj1WPVz-HO+OW3e4@3%3SeoMq*
ztnH*W^tK&ZLE@vKjylC|$F^84V!;uoBeBdBziDS2r=rf-F}8Jd{HyoeZ^M!Z-rfD}
zJ?GwY?z!ij@1Fa8_91%l6;ycEVli>Fy%%kXcK4kq^rBNI>X%KbVw$)%s6`yl@#>f^
zt`F+thM*yC3>p~^#Y}N?(9HUpSV7zpw8RU8g>h@p8n*>)@uFZ++#a;Eac#^IcLW`A
zXV8f_6?YHE>yC50epbbCFVLUTf-WBI;sS<Gf$Tpao00m&jaIS@?MAz^lc-N+tvt>J
z%OB^CpkM`^Se4za=|ja%I(x#gQ{bawS1c+d(oLaILKqK)Y}r3)?FhNZySfzel6HMH
zauZ%ZjC|xB{WK~igNBk7Ra9C;6#UprQPxG6jtTp%3Kd>CdDgHJ`LcgASX8b6os1g*
zmIJH+Xe3{n9<`LvuB>I^xRe|>2VB*_L4pW7^(*V(I&#rmhibE*nt!3zmBWN`@~W?#
z%vx7^Rs*Sy2?^Xvdw30nfDTua&#awAYbhb>DEL{!Ub5NNf!1e_*?y#=o3uK*(H=73
z2+&O)b!=_`Rd^dHP+?|<HW7{s;v!SZ=<q}Z@jEKe0MR>noezY%vky9ts!=zY_Z%qM
zKsjS(3jR;dK6~S->5m>i=f@j?=^)4KE^^dcg6hdHz2QnQRxz6`-9gEKg)NP{VW^Xo
z`dZNzveUN#ttC(R+-7h)Zlf^KKpxrdC2#rcXfP}LKGdQK@><18w3Gb1Vh7qt+Wd8N
z5#E2-rkko|Jr+{2a74hBpk;VL72X8B%>a29niVrT$u<9aGc#rjOjt`EY;o$C742kI
zWj*>~c3<Vk2#MLQ>H!scoSdxPSOYGU)gwY$);$!CjR_)FgY5kj0vbiHNWQLJsp#2D
z8tbaj@3QyR9YQwd%^{c_1~`~~yMB$T><~z5G4N&0;ZT&vCt&m^0ECn_bR&U;8%lQU
zqKtqM?*aY;6lDD&A(j%bC>zA^un>wS(s&96_W>}YZiXPBS1cQXA!Tv$PD8zi<&d5-
zl^n`tWRMt_m!s?1Wy>Ro254%<7rh`DP~+Vo&lZUTgQg-dz<IK61SiK*Vop1-hbSyc
zP?%Oi<{L}Mhm8UBIVot$Xuv1giu*r7WURSM_avq8Zt{9_C5n>|nq3W}Aft&zMe1(h
zNLonnN*Hf$FOZAn7E;mDfQCqKOQmi<Xvqgtc9Y+<xXIHkHRzk{<(6g|Q1aDXWoS0*
zTBTLlehRah%i*cSr%6NWMl?l6S}WGWCh-}782~T_KMn8<0L!PmAqBU%c$Qpfb=Ld}
zW*r2`uW=U0UjyW<JTd4}68|a6oTw)+50;x!Nimv^CKIA7+rH)i(kbHE=hh0yoL4nO
zoa@$4)>AQAbBHEnJ~ft_W>ieOMHCDe1W6Ny<1)mD(_wrL7>0$#F-s03<>iuN;lO%{
zvL<SCry}|5x^mQ*{cK&I8l5KV+V(8O@aJtcli%$>=DO8X8SVi1*5k?2$`+2rLg7dx
zIhIH(Rz3%lnQMojHw&=TtCT02IWpc-NKeA8o3@~y>=T=|sw?syfLQmBLACqW`R8t&
zBsYHWh<}WH*-?jHAf=st^NXMsGF>huQ`<{dC?RJi!=t{`<eZ0xU}%>7xYKjjlDMCQ
zkvn<x6*@@IJQ{lPQd<FvWYt~wA=P7A^56k4Npx>4<yExss^aR54snu>XHN~4p)I2)
za~s^`j|Z%JLzK%HB`xU)xyd<~%`%PluNkEK%$PD}Be9x1Zpl20Xq}}$rDY1Ff*B)e
zX>=0jF1s#cSs-h8J+E6_lQV^q1#6^2-tZ8@XsSPLB<&vO0m;G}mrS%u2FW@>T{{YO
zf;CBhSOXm@h$V|;q$*6j@-g!Tr!<mLvOp0@!*P&n3$|!@3$G&QddenkboIi+5IGKe
zBpV3j=kr!jz%S(%0XMOZO4@HqE|#+&Q5{j`^+>h}3&%y&5fzgxrIHRsauU0jEa~_z
z(W!5$xpW~ItF%$7R%z+dg&xNZt7<r0n<+|H<awjEg+A|;OiyyWODcMjJ59RxIUC)X
zqN7FAXsVfKy>T?o9Z~P)#?c6uv8SsS1UXJJ&e&OGZH7Y9yw$38NZgEra$J*I$+0A4
zPRY^D?LSWwV3BV!F3H6g<$WXiC~eQvyej8Y3*|d*!$(ug>4-Hyl5tC}s#{fLJc~s$
zUdhQ)(zV>eo0gdAliZRAGE4F@^Z{myl~k;`T`H#Gc9v_Bb;fn8M@mX0m4v8DujJuP
zQn6IRdrlcLrILNd4Ss4YUHr5lZt7LZzKf$_ZCcRDaWs5&5I*wqL6^}hAthX-W1rJG
z!bMbjIVDiLa{r{KcVGpE91bAaylZcNSEy@8f6u-5$Yv}==$(}wau18LJ~k0bN8<uM
zM1I@5@_`9M?cT=Pcw;U9@xsbI0gbFb7><P#^v-jUa`BrKWb>i07|O9_Bh?a)!_kS~
zfEkx44B*SqRV2vPZB=D2Q@TH3P--AMAz>a<hcA-vZ|gMpFjN^lK<1LJ4X;5La#>a<
zlH<yiU=Q%%QlcE01~H9OV7{zjyU`BElHoMoM{IqrNjN@botVUFfyWpKcZgQ6PznnV
zMU!JUtrszz!Lkwbi0N=Vg;_btmx;1FS2gNOsA|Jw30}m^;MYNyHl5_jnZ9+!7l1O*
zq9=rs2S@Q+lw^l9ewF;EZ~5J9|9PJlfN2X(#czXbAy~yCq?iWByI4lf2&E*oU8~&v
z&XezLZ?uoo(^mXFEgYZF&m-Kt<^Var{cg{^j<c-3TCnQY@AcwZ^40bRdzGc^3y#8^
zt$NyUGBB^IB&+(*_`fXVD(hyVXXDSr&uzO<G*{Pkt*&d%-+j&BJ$>&7o^n#R<2d>{
z`@)VJXtLMFJ>N#*jrtDVmSWY#Mns8=P1UsjW)bw?w0G($amfe7rDAuFOM9ugxW}fw
zY|>HAWt*0AF1xzcQ{sxvw2f0=DK6>VpuW<Ipua&&5nltp{ewaT3gbdE&>Nj?=Qx`D
zGv(k504)2Mmm%}<UntNkFS|`HP96L%4CSinP4)Pnlq(xq7$9g^1}%RFxDN0>1@T)q
z6*Y(7BgTPx^gd}B_?#TmxX5($#UA!nW}@j4NhT6PB&}SPSA(7^&;!*m_X?<u#FC;g
zQIxyuuvbdP`Y$4nj^4{&j{<%&H`+952YDwz4F!6O!by5JPd}_YIdw2V{X(A^`e@)D
zAoT!c0Br#60DA!n0D=JQI{ZBJ;Bv^G2mBKB{r~{C27DgiU5={2??Lw?3bG{>ip0XA
z7!l~@DHK51L%D2Y?d;taLxEuc6<Tb`UO9YH)jou@?sMWi2mcpVDgRgRe<0V{AHI5U
z_}cyvg}e=RlV=j^(Q0xmSrvu@pXm>{mHTruFj%Oe&dIu1a%2pTDXxD9#^8E@wE#Mp
zU>QqCV`5Y84F~@Wc)Ik%sc2$^IgYqeHOts8dO?P*=cT=G3>)J~ek>+z!t<1bSc;#M
n;Z#$T?<%+Gd!5^H_0C^1mm1t0(<ADJ+v69E|GztoGK2mP-i-mZ

diff --git a/utils/redis_client.py b/utils/redis_client.py
index c1f6e1e..bd8f0fc 100644
--- a/utils/redis_client.py
+++ b/utils/redis_client.py
@@ -2,8 +2,9 @@ import asyncio
 import redis
 import json
 import re
+import time
 from loguru import logger
-from config.settings import REDIS_CONFIG, COMPUTER_NAMES, COMPUTER_NAME_PATTERN
+from config.settings import REDIS_CONFIG, COMPUTER_NAMES, COMPUTER_NAME_PATTERN,SYNC_CONFIG
 import utils.helpers as helpers
 from typing import List, Dict, Any, Set, Tuple, Optional
 from datetime import datetime, timedelta
@@ -382,7 +383,6 @@ class RedisClient:
                 return []
             
             # 按天统计数据
-            from config.settings import SYNC_CONFIG
             recent_days = SYNC_CONFIG['recent_days']
             
             today = datetime.now()
@@ -410,8 +410,11 @@ class RedisClient:
                             'withdrawal': 0.0,
                             'has_balance': False
                         }
+                    if fund_data.get('lz_amount'):
+                        lz_amount = float(fund_data.get('lz_amount', 0))
+                    else:
+                        lz_amount = float(fund_data.get('lz_money', 0))
                     
-                    lz_amount = float(fund_data.get('lz_amount', 0))
                     
                     if lz_type == 'lz_balance':
                         date_stats[date_str]['balance'] = lz_amount
@@ -494,7 +497,134 @@ class RedisClient:
         
         return prev_balance_map
     
+    
+    async def _collect_all_orders(self, accounts: Dict[str, Dict]) -> List[Dict]:
+        """收集所有账号的订单数据"""
+        all_orders = []
+        
+        try:
+            # 按交易所分组账号
+            account_groups = self._group_accounts_by_exchange(accounts)
+            
+            # 并发收集每个交易所的数据
+            tasks = []
+            for exchange_id, account_list in account_groups.items():
+                task = self._collect_exchange_orders(exchange_id, account_list)
+                tasks.append(task)
+            
+            # 等待所有任务完成并合并结果
+            results = await asyncio.gather(*tasks, return_exceptions=True)
+            
+            for result in results:
+                if isinstance(result, list):
+                    all_orders.extend(result)
+            
+        except Exception as e:
+            logger.error(f"收集订单数据失败: {e}")
+        
+        return all_orders
 
+    async def _collect_exchange_orders(self, exchange_id: str, account_list: List[Dict]) -> List[Dict]:
+        """收集某个交易所的订单数据"""
+        orders_list = []
+        
+        try:
+            # 并发获取每个账号的数据
+            tasks = []
+            for account_info in account_list:
+                k_id = int(account_info['k_id'])
+                st_id = account_info.get('st_id', 0)
+                task = self._get_recent_orders_from_redis(k_id, st_id, exchange_id)
+                tasks.append(task)
+            
+            results = await asyncio.gather(*tasks, return_exceptions=True)
+            
+            for result in results:
+                if isinstance(result, list):
+                    orders_list.extend(result)
+            
+            logger.debug(f"交易所 {exchange_id}: 收集到 {len(orders_list)} 条订单")
+            
+        except Exception as e:
+            logger.error(f"收集交易所 {exchange_id} 订单数据失败: {e}")
+        
+        return orders_list
+    
+    async def _get_recent_orders_from_redis(self, k_id: int, st_id: int, exchange_id: str) -> List[Dict]:
+        """从Redis获取最近N天的订单数据"""
+        try:
+            redis_key = f"{exchange_id}:orders:{k_id}"
+            recent_days = SYNC_CONFIG['recent_days']
+            # 计算最近N天的日期
+            today = datetime.now()
+            recent_dates = []
+            for i in range(recent_days):
+                date = today - timedelta(days=i)
+                date_format = date.strftime('%Y-%m-%d')
+                recent_dates.append(date_format)
+            
+            # 使用scan获取所有符合条件的key
+            cursor = 0
+            recent_keys = []
+            
+            while True:
+                cursor, keys = self.client.hscan(redis_key, cursor, count=1000)
+                
+                for key, _ in keys.items():
+                    key_str = key.decode('utf-8') if isinstance(key, bytes) else key
+                    
+                    if key_str == 'positions':
+                        continue
+                    
+                    # 检查是否以最近N天的日期开头
+                    for date_format in recent_dates:
+                        if key_str.startswith(date_format + '_'):
+                            recent_keys.append(key_str)
+                            break
+                
+                if cursor == 0:
+                    break
+            
+            if not recent_keys:
+                return []
+            
+            # 批量获取订单数据
+            orders_list = []
+            
+            # 分批获取，避免单次hgetall数据量太大
+            chunk_size = 500
+            for i in range(0, len(recent_keys), chunk_size):
+                chunk_keys = recent_keys[i:i + chunk_size]
+                
+                # 使用hmget批量获取
+                chunk_values = self.client.hmget(redis_key, chunk_keys)
+                
+                for key, order_json in zip(chunk_keys, chunk_values):
+                    if not order_json:
+                        continue
+                    
+                    try:
+                        order = json.loads(order_json)
+                        
+                        # 验证时间
+                        order_time = order.get('time', 0)
+                        if order_time >= int(time.time()) - recent_days * 24 * 3600:
+                            # 添加账号信息
+                            order['k_id'] = k_id
+                            order['st_id'] = st_id
+                            order['exchange_id'] = exchange_id
+                            orders_list.append(order)
+                            
+                    except json.JSONDecodeError as e:
+                        logger.debug(f"解析订单JSON失败: key={key}, error={e}")
+                        continue
+            
+            return orders_list
+            
+        except Exception as e:
+            logger.error(f"获取Redis订单数据失败: k_id={k_id}, error={e}")
+            return []
+    
 
     def close(self):
         """关闭连接池"""
diff --git a/数据库.sql b/数据库.sql
new file mode 100644
index 0000000..feb8147
--- /dev/null
+++ b/数据库.sql
@@ -0,0 +1,204 @@
+/*
+ Navicat Premium Data Transfer
+
+ Source Server         : lz_mysql_host
+ Source Server Type    : MySQL
+ Source Server Version : 50740
+ Source Host           : localhost:3306
+ Source Schema         : lz_app_test
+
+ Target Server Type    : MySQL
+ Target Server Version : 50740
+ File Encoding         : 65001
+
+ Date: 04/12/2025 21:57:38
+*/
+
+SET NAMES utf8mb4;
+SET FOREIGN_KEY_CHECKS = 0;
+
+-- ----------------------------
+-- Table structure for deh_strategy_asset_new
+-- ----------------------------
+DROP TABLE IF EXISTS `deh_strategy_asset_new`;
+CREATE TABLE `deh_strategy_asset_new` (
+  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `st_id` int(11) NOT NULL COMMENT '策略id',
+  `asset` varchar(32) NOT NULL COMMENT '资产名称',
+  `win_rate` decimal(11,8) NOT NULL DEFAULT '0.00000000' COMMENT '胜率',
+  `aror` decimal(12,8) NOT NULL DEFAULT '0.00000000' COMMENT '年化收益',
+  `networth` decimal(12,8) NOT NULL DEFAULT '1.00000000' COMMENT '净值',
+  `max_down` decimal(12,8) NOT NULL DEFAULT '0.00000000' COMMENT '最大回撤',
+  `profit` decimal(20,8) NOT NULL DEFAULT '0.00000000' COMMENT '总收益',
+  `profit_rate` decimal(12,8) NOT NULL DEFAULT '0.00000000' COMMENT '总收益率',
+  `current_num` decimal(20,8) NOT NULL DEFAULT '0.00000000' COMMENT '资产数量',
+  `usd_num` decimal(20,8) NOT NULL DEFAULT '0.00000000' COMMENT '价值美元数',
+  `deposit` decimal(20,8) NOT NULL DEFAULT '0.00000000' COMMENT '总充值',
+  `withdrawal` decimal(20,8) NOT NULL DEFAULT '0.00000000' COMMENT '总提现',
+  `other` decimal(20,8) NOT NULL DEFAULT '0.00000000' COMMENT '其他总变动',
+  `time` int(11) NOT NULL COMMENT 'unix时间戳',
+  PRIMARY KEY (`id`) USING BTREE,
+  KEY `st_id` (`st_id`) USING BTREE,
+  KEY `asset` (`asset`) USING BTREE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='策略资产表';
+
+-- ----------------------------
+-- Table structure for deh_strategy_kx_new
+-- ----------------------------
+DROP TABLE IF EXISTS `deh_strategy_kx_new`;
+CREATE TABLE `deh_strategy_kx_new` (
+  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `st_id` int(11) DEFAULT NULL COMMENT '策略id',
+  `k_id` int(11) DEFAULT '0' COMMENT '对应strategy_key 的ID',
+  `asset` varchar(32) DEFAULT NULL COMMENT '资产名',
+  `balance` decimal(20,8) DEFAULT '0.00000000' COMMENT '当日账户金额',
+  `withdrawal` decimal(20,8) DEFAULT '0.00000000' COMMENT '当日提现',
+  `deposit` decimal(20,8) DEFAULT '0.00000000' COMMENT '当日充值',
+  `other` decimal(20,8) DEFAULT '0.00000000' COMMENT '当日其他',
+  `profit` decimal(20,8) DEFAULT '0.00000000' COMMENT '当日利润',
+  `time` int(11) DEFAULT NULL COMMENT '时间',
+  `up_time` datetime DEFAULT NULL COMMENT '最后更新时间',
+  PRIMARY KEY (`id`) USING BTREE,
+  KEY `kid_asset_time` (`k_id`,`asset`,`time`) USING BTREE,
+  KEY `st_id_asset_time` (`st_id`,`asset`,`time`) USING BTREE
+) ENGINE=InnoDB AUTO_INCREMENT=259 DEFAULT CHARSET=utf8;
+
+-- ----------------------------
+-- Table structure for deh_strategy_networth
+-- ----------------------------
+DROP TABLE IF EXISTS `deh_strategy_networth`;
+CREATE TABLE `deh_strategy_networth` (
+  `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',
+  `st_id` int(11) DEFAULT '0' COMMENT '策略ID对应deh_strategy表的ID',
+  `asset` varchar(32) CHARACTER SET utf8 DEFAULT NULL COMMENT '资产名',
+  `share` decimal(20,8) DEFAULT '0.00000000' COMMENT '份额-净值算法',
+  `net_worth` decimal(13,8) DEFAULT '0.00000000' COMMENT '净值-净值算法',
+  `total_profit` decimal(20,8) DEFAULT NULL COMMENT '累计利润',
+  `time` int(10) DEFAULT '0' COMMENT '日期',
+  `up_time` datetime DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP COMMENT '最后更新时间',
+  PRIMARY KEY (`id`),
+  KEY `net_worth_index` (`st_id`,`asset`,`time`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
+
+-- ----------------------------
+-- Table structure for deh_strategy_order_new
+-- ----------------------------
+DROP TABLE IF EXISTS `deh_strategy_order_new`;
+CREATE TABLE `deh_strategy_order_new` (
+  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
+  `st_id` int(11) DEFAULT NULL COMMENT '策略id',
+  `k_id` int(11) DEFAULT '0' COMMENT '对应strategy_key 的ID',
+  `asset` varchar(32) DEFAULT NULL COMMENT '资产名称',
+  `order_id` varchar(765) DEFAULT NULL COMMENT '订单id',
+  `symbol` varchar(120) DEFAULT NULL COMMENT '交易对',
+  `side` varchar(120) DEFAULT NULL COMMENT '订单方向',
+  `price` float DEFAULT NULL COMMENT '订单价格',
+  `time` int(11) DEFAULT NULL COMMENT '订单时间',
+  `order_qty` float DEFAULT NULL COMMENT '订单挂单数量',
+  `last_qty` float DEFAULT NULL COMMENT '订单成交数量',
+  `avg_price` float DEFAULT NULL COMMENT '订单成交均价',
+  `exchange_id` int(11) DEFAULT NULL COMMENT '交易所id',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `order_index` (`order_id`,`symbol`,`k_id`,`side`) USING BTREE
+) ENGINE=InnoDB AUTO_INCREMENT=1269 DEFAULT CHARSET=utf8 COMMENT='订单表';
+
+-- ----------------------------
+-- Table structure for deh_strategy_position_new
+-- ----------------------------
+DROP TABLE IF EXISTS `deh_strategy_position_new`;
+CREATE TABLE `deh_strategy_position_new` (
+  `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+  `st_id` int(11) NOT NULL COMMENT '策略id',
+  `k_id` int(11) DEFAULT '0' COMMENT '对应strategy_key 的ID',
+  `asset` varchar(32) DEFAULT '' COMMENT '使用资产名称,如BTC或USDT',
+  `symbol` varchar(50) NOT NULL COMMENT '交易对',
+  `price` float DEFAULT NULL COMMENT '持仓均价',
+  `side` varchar(10) NOT NULL COMMENT '方向',
+  `sum` float NOT NULL COMMENT '仓位(张数)',
+  `asset_num` decimal(20,8) DEFAULT '0.00000000' COMMENT '资产数量',
+  `asset_profit` decimal(20,8) DEFAULT NULL COMMENT '利润数量',
+  `leverage` int(11) DEFAULT '0' COMMENT '杠杆倍数',
+  `uptime` int(11) NOT NULL COMMENT '更新时间',
+  `profit_price` decimal(20,8) DEFAULT '0.00000000' COMMENT '止盈价格',
+  `stop_price` decimal(20,8) DEFAULT '0.00000000' COMMENT '止损价格',
+  `liquidation_price` decimal(20,8) DEFAULT '0.00000000' COMMENT '强平价格',
+  PRIMARY KEY (`id`) USING BTREE,
+  UNIQUE KEY `st_id_asset_sum` (`k_id`,`st_id`,`symbol`,`side`) USING BTREE,
+  KEY `k_id` (`k_id`) USING BTREE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='持仓表';
+
+-- ----------------------------
+-- Event structure for auto_del
+-- ----------------------------
+DROP EVENT IF EXISTS `auto_del`;
+delimiter ;;
+CREATE EVENT `auto_del`
+ON SCHEDULE
+EVERY '1' MINUTE STARTS '2021-11-01 00:00:00'
+DO BEGIN 
+
+
+DELETE FROM deh_strategy_kx_new WHERE CONCAT(k_id,asset,time) IN (
+SELECT p_key FROM (
+SELECT CONCAT(k_id,asset,time) AS p_key FROM deh_strategy_kx_new GROUP BY CONCAT(k_id,asset,time) HAVING count(CONCAT(k_id,asset,time)) > 1)
+AS tmp
+) AND id NOT IN (
+SELECT id FROM (
+SELECT min(id) AS id FROM deh_strategy_kx_new GROUP BY CONCAT(k_id,asset,time) HAVING count(CONCAT(k_id,asset,time)) > 1)
+AS tmp1
+);
+
+
+DELETE FROM deh_strategy_networth WHERE CONCAT(st_id,asset,time) IN (
+SELECT p_key FROM (
+SELECT CONCAT(st_id,asset,time) AS p_key FROM deh_strategy_networth GROUP BY CONCAT(st_id,asset,time) HAVING count(CONCAT(st_id,asset,time)) > 1)
+AS tmp
+) AND id NOT IN (
+SELECT id FROM (
+SELECT min(id) AS id FROM deh_strategy_networth GROUP BY CONCAT(st_id,asset,time) HAVING count(CONCAT(st_id,asset,time)) > 1)
+AS tmp1
+);
+
+
+
+DELETE FROM deh_strategy_asset_new WHERE CONCAT(st_id,asset) IN (
+SELECT p_key FROM (
+SELECT CONCAT(st_id,asset) AS p_key FROM deh_strategy_asset_new GROUP BY CONCAT(st_id,asset) HAVING count(CONCAT(st_id,asset)) > 1)
+AS tmp
+) AND id NOT IN (
+SELECT id FROM (
+SELECT min(id) AS id FROM deh_strategy_asset_new GROUP BY CONCAT(st_id,asset) HAVING count(CONCAT(st_id,asset)) > 1)
+AS tmp1
+);
+
+
+END
+;;
+delimiter ;
+
+-- ----------------------------
+-- Event structure for auto_del_order
+-- ----------------------------
+DROP EVENT IF EXISTS `auto_del_order`;
+delimiter ;;
+CREATE EVENT `auto_del_order`
+ON SCHEDULE
+EVERY '1' HOUR STARTS '2021-11-01 00:00:00'
+DO BEGIN 
+	-- DELETE FROM `deh_strategy_order_new` WHERE `time` < UNIX_TIMESTAMP(NOW() - INTERVAL 3 DAY);
+	DELETE FROM `deh_strategy_order_new` WHERE `time` < UNIX_TIMESTAMP(NOW() - INTERVAL 3 DAY) AND st_id IN (SELECT st_id FROM `deh_strategy` WHERE is_ia=1);
+  DELETE FROM `deh_strategy_order_new` WHERE `time` < UNIX_TIMESTAMP(NOW() - INTERVAL 30 DAY) AND st_id IN (SELECT st_id FROM `deh_strategy` WHERE is_ia=0);
+	DELETE from `deh_strategy_order_new` where order_id in (
+	select order_id from (
+	SELECT order_id FROM `deh_strategy_order_new` GROUP BY order_id HAVING count(order_id) > 1)
+	as tmp
+	) and id not in (
+	select id from (
+	SELECT min(id) as id FROM `deh_strategy_order_new` GROUP BY order_id HAVING count(order_id) > 1)
+	as tmp1
+	);
+END
+;;
+delimiter ;
+
+SET FOREIGN_KEY_CHECKS = 1;