From 5a45449b87a49e00bfe196c9f1052e10591e2da2 Mon Sep 17 00:00:00 2001
From: blade <8019068@qq.com>
Date: Fri, 1 Aug 2025 16:18:36 +0800
Subject: [PATCH] support draw chart

---
 .../huge_volume_chart.cpython-312.pyc         | Bin 0 -> 23518 bytes
 core/biz/huge_volume_chart.py                 | 459 ++++++++++++++++++
 huge_volume_main.py                           | 102 +++-
 requirements.txt                              |   1 +
 sql/query/sql_playground.sql                  |   8 +-
 5 files changed, 541 insertions(+), 29 deletions(-)
 create mode 100644 core/biz/__pycache__/huge_volume_chart.cpython-312.pyc
 create mode 100644 core/biz/huge_volume_chart.py

diff --git a/core/biz/__pycache__/huge_volume_chart.cpython-312.pyc b/core/biz/__pycache__/huge_volume_chart.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..038ea1f9db9fa14cbdd34792366e33de3dfb7e6d
GIT binary patch
literal 23518
zcmeHvdr%wMxo5YYtp^}LfOw0i5nyb<Pi*5C#>U1TKVuu)qsX)XVIi27WCJ6TN$n(q
zGt3%qasy7{SW`E-qq*bUD0@>G<#BV_Ol@7VsoLrua6~#YwZ6N?lc}w(3*$+pZnA&u
zcTRV!8zHb~Cbe6)YTNjn)2F}l_1CTM`_At>ea`uHTAGo7<G=Jw^v#|oi2s33q(dVX
zo^+A~F-6b>O?rs|vWp~9S>;s?sJqkynl24KS9`Ssx-Pv~rn(G3qwyLCOkE~ir}df#
z(z?>baypbVL|RLi1!#5N%z@0VOtCJjD;w(6UTc>X=Q&+DI5&0~A=i6z2lBe|NJ2%p
zE&ZD%f#n=(o8&X8L{s+-Z>fYc+}6;)MY<;EwDG>_EqG#dfHdY_(yi~`CY&o%I&C+c
z(&=kl%|KUG#9@NAyiCxU(tW#%M%0e14-q2=$y?eE90~TiKR4(N4!GM~0hdF?=L9?h
zZhycvFyssjI%!wHjVgG1fN}Z!J%h{uu5+SFM3A690sN@*gUq$7gM-(gtnC<Z^}11|
z!~@Ej_Ca4@)KOLA@^_<_4!?b)y{g9RzV7z=T#0iKz>gaHK^`r>$m`IpT>;*3qt6p?
z_c9(D-NPRk@w$248PC8Gw`Vk?2e>!*LC%eSH{<DPAI)+NyZsG8pQn3}b~^_=zM#Jw
zJ-c-1#ln+xtYdDXi=>Gzm4ToOY0|CkrzAo-r&VrkkA_yitnJd#MYP7Pr?qZ9)aamw
zqV+EmpnDXgMgswSifMz}L>t{&+63)%v>B+(sIEsvr@gG{N)yZJP)--i8Bop;%N8hG
z#BwH-GsSWil(WQgHk7l)vK7i!v77_t9J*x9C&|T6k_Qsy(l(F~Nu{Clp;g{Ufuoeq
zkd@<LpNk3b8u%$)eA-|zFcb_pdj`F<o9R}|?}k7&i_V|?ZzxR>Au>cb6PH6of1)fG
zQrFUCK9JC=YugC|m7dP0Unz&ko>tT9`x;62Ng|{IKB5H@L_qrWiB!Kc$R&9oSy=E1
z_q8&=fKIy9kNuc*CglBTE6>r{8eDY}PmnJm)l=n5U(J7|d~3X0J$j@4nX6mBC06xk
zuYC<9Ogt;_x2~q_&s$w5afaU@r4|Uk_h*pFEZr0M+oZCbe=3=%&-k7azdy)SAj=|^
zK9x*{&nQzuXF#SRNfJ5#R5BSqqf8mn{XwP@sVwK8N+#21l*uC9A7rviWjSA8rV+Cv
zE%*UA8lzo27RT={zVYhf#5WQ($d$I(AOBVK@oRs#qViGf`yYJs<;C%-#mUzm#eVuP
zKmTUpvVUaY>Y%s9z8L$`2XDNVsJ`lApze0$@we|K>TY;^^xzGr-!tlNv48NlQ;WC$
zdhxq&EJkl7DEgr1cV5R`KgcotgT=|eS$sS4;VUwQaM8)Q0-izV5V(4`FW~XIosFAY
z?2VhN7RSHx=pSB#CrGedyMc4S?eeW`wfK|2U%dOu;!8hIG#_F--2f^^hCt*;KYROe
z_~#$|@MnwPc{M@ca}NiQAf7=QC}OWZioNtG_P0q-?z-+~06aJucOb~XJ;nQc>pPFX
z`n?3F0oQPX;PJO#La!!?z~fs%5WST|z<B&_XZK*x7eJzX_3@7*kMF;(d>NPkzq<s%
z55E5B7xL5exV&DO!>hl4dm@PgCP;9=1S>hvjO&KP;qk<m;7OA>U;>eYNU)MaU@+iH
z2=Vx(pCz?l(bKosfB%cGExz*8$KQD6(a(Oo_}!l*-X^aG735WoZD#?nX=r9}h}V03
zLta-m27vBik3ZlXyvAz+?tvj*C#W%RQs^jeQv9}j!P<(%8)Ypy;mBlAFUFe~x8EIb
zg37yxnJiSJ8uatjfa{u@_Aq{4Gvo^N@tXcYkB_I23{I%#b$|<B2m*Wz40=I8-XzH7
z#3vg6AOIc;o=Z5lD1;Sj6cP(HrE7~V5M;=*;|hnG*ZAGu9{dzoa6dvZ;4}WTr>*7k
z&`6+f(B~Xt2K(LJ0srN0W@HE;_X|OnFL1egka1tW>KVPPuw!R8f@uvyBRu7Vx8Vsm
zoujrS5Z54GLEhj0YrwrP5lbyZPX4%N!tl^)o9ejTF-_m|-0?)TTuDQ;k}KK9S+}FB
z3zYem;ie%@6?0T^cuUmEQpNMswuR!_am_qc@E&EnWx8paY>Qi~Ics&)`heQ@o~_`X
z{*L~h`Hne!HeR)ztJ)sRowMx&c4-OvspGegN7^1xjSGdP_jcad8NR?3HpC0Ja)n#x
z3b)4#Te-s4xk6|&PuU()<~U{JD4QU~JXN}2E4pX6V+dDqwwkzY6KC5rXKRexc5t>G
zbG8<ABP4g)&9pdGz)=PBRMCRH@(si5hR8<Fz9Vkm%h~tN+4sloM>zYDIr~v`n__4p
z+#pVsb5!{}Rr#qJJv3Wxb=>S=bDKDGbKKm*nOo+}yW{4AocZ9K`OuP@Fr>{>^-DU)
z<5WFI)yJtuj%u8zniond?v30Ti4<|A+v25rxY9jyrF-M0?ObX5T<H-cWDyp!h@*<)
zR2fH=J)kO{z;8<M86ID^HwXbwpW77}a1HThslw~=xmN&oq;43ne+LRvgohYYhe*Z(
zot_wiB8Ji-fw(bENQG%qK<)&M7HBd<>VB=%TF$?yeJc^*!rj)Q(kQ6ZXCPh;ZUi0)
zr}M$jrWeP5EVy3i3&4FYe(M*DU;ZBSbO{<Tu$&?9U_g2kPUyiPj_r2yHe8L~hhQ}F
z6<u%$MXU}T(*U<)P$17VL&BS|b@{<}bO-oM@!dKxA6%7=xh2m1C^!(he`XVEpN20<
z5{won8|I43r=W%Z93)_!6p@!dZu+gM0CX^JZ{h4MbN1b=x%juHyoKVjcyS9?+%i|Z
zd;G*dLxnjnZZ6@>CDUJ+H#eX*QUzPOdEVT(kWs)=1xzDw?pFT9DAvJ>5P({&2oSra
zQUa(=L{QL1JZSR1N{V5|R5Te<dB_k+lV}tITBJ~d5P4s%_<@Q3MBF3sgqF!P2Kky)
zT18`$uE_Z+nglXmhbDna*P%%fL#?`3idc%)0F@$+43VJTy5I)5Q$lqG^?v--=?{MT
zkE<0sh?EQZ>qr0aH3!%kobb9K#@*u?c96^tbZV4!`%M*Z#JY>I6~62+^4VD5h7jb!
zPz9k4fl~p#qU`Vz1boS=Yp9Equh*u$uIwshTER5MURSQp$1KF^mE5b6FQpc;aXqrs
zvY17v;~wsIdmU=Q_VJ6fh!_cVtxg0aq&^y3HG_ucMr%^qviu7qyo(E{{r?$~gjqi<
zER7d7bA`<@>p$lIB!6}XTi85Tc$TGX3uO+rZWn9cJ#Lyj0zEEv_Zv8BL-ZI+ZJ4L_
z;fgwrs*9Oes&1ZY!xh^(YWoaOY@er2;tJG(MP6i4FSZL;RC82ybQeoi&r^GGMH5Fg
z#ekw|o;rprS~;q97ARWhsq;%l+&SfQRDSp}qRK~9Yq$|)=-7=!ps=nR0p~!gzy*kX
z2p$+vIwWY14saqGTKi0NI$EDZm!f~7DKI_7Ff2AbV=B}8;NN|J@vGljZF;;Bt13p-
ze{!6LFu;BqMM(A|LT_uoI$}SMqc8gzh`#JDA8kM2VnC;`I+<}pK<zN*>f^NmPXI<R
zjWX09b+m&aJ`+nmePygOx^ce{``Az8*ykw{@o7>YhMfbm7hX5ucfl`+<|k4x9r&7T
z6@JtQ*zJM|Y=!b@RZ0_(?jZGgH-OYX3W==$2x-|l${x8i6IvpO=gGq=ma>0L5QYvF
zR>o(z$R0iqO|O#ANlj0wFi^xw>zt{>N_#?~wD`ARPJkfHbC7hS?oT>U2ZD8211St*
zrW~+pBPPi!Lj*CV@t|Q&&9~t5L`Vgx>aIrY^ip(_xD|Zp7}Ew4U1EP?5K$5U20qo8
zqb8&Uj)1lx)!x;w=q^(XO@pK<YH1xB3JGbh)!?o;6$Ks;3~3R?DA*vPAJc_&{i(WA
z6;06w{E<R@XJh(6qC4$R3@<63#e6?amOPN?GW$`WmUM*lbUK|uTkdDRC2}VT1@{z#
zjdYfRw=73)5@R@}vr|&07%U8_@mq&?e^&uf0*N8Klmlm_tM3TEhdo8DpeyK?6*R_r
zH!=J>Mk$`QJVjfI&Y^Sf=gD4EL0`F={w=Wzyes&<m0Buj1(rgVMRiw)w0Dx6IHy6W
zUqg)89QmpIqu?PDUeYK)UAvtpoe+MChL3TI0A+a69z^&p(SkuQltBZ2Od(3pugh!D
zK#@bk>#n=JLARgR;-H?_3;xp2>s`IQJwac$L-ipVhW-#4&zmH#@A34av97Z`b(+5D
zJq&|4qw0p{9tZ%mE}w4@zFl;qNJ!l?5a4wu@etCeN#UkP&63CsL%v?*mwWpHAJT}s
ziZ@-oIyejgb$1^~q^5^FCmh)fLTe0)NO-+>u(#I(tu!7Ve5S%^%rxY=4sl1obrsyZ
zddLfR1rdV`ocMk47~=ckb;DlQRkxSdjo=)6BgT$cqo1FtKneO`dA%Q;J+R=l-QGdJ
z+hLHMvFyj>SIVpC9%cYF6rmqRF6jMBzmw>^&p_2^MM~$rvJZF}2>o7g58%2jL|$P$
zxB5YD^?3V2>%Q@0)7z$N!e!ykaBI}Y+91x|wNO$XFKK#E(llv&&yqJ~zHOeq9_|TW
zh@6UyM!d1ISZAztHlHm%GjBP&kdr@k@%F{A28ZP}oV_`EowM(msr)C$e{#%ratAK5
zS9-Yvy<BM@m*bgKEtJ^r`R@3lowI4IlV*K^Y2RE)aMJXiC40(v+Zf*dz*6@J%BI_<
z>0^;Vtai5Qf#sxlb$Z9VrBW*InYTDl*>Kx1eQx@2xG~%n?qmxZ=PgZ-ic9aEzjOZH
z<vW)nl|R_{=EhiiY{yLFOxH{&d-4=}`g!)0lXYHWcY5cF2hc+b_d6OrJd^#va!BO*
zb<=`>Y|=D+eY!8~ikQP+h+bfeS~<(!nQb#Qvt_eKXLqybFR&Ng?1dh-$H(p)oU;sl
zR7{jMFKdas4ML!%>`9Qq<K8I>1%$8^VHVURA8o{y1K`c!!&j=XEp@H%F(#x!{Q>R^
z)IgW$ujD&~)U*oqO?MHF6J><40SIoS&v(LA<WVNtz>{bk+TcMrN%)FKvDX$SehLH0
zf~wWq1y`X!^-1x4q9t}2yjel%e3NAM0P_=ov}z$22G#aM$)Q!)3U)QfL>Y`l&|_hX
z5TFdaD`K=Zr8OvTl?YbQu!-Lb3C1(kH2~F*1Kfszta#z(`NGZP#}=~lrgq-mIeqrt
z#XA?nV_fmpSRq&3#$_KGZ(GPOj^{UW`Hj)anWEWivsc)?m)QKqx%|uHM;8vC0<%iv
z%+-;i=(Xq-cEiDU&27tiqNs7TQXsp=N&%B0o=qu0=CzapROS*~ML)U*_$D2xYiSkk
zPO!?XL7~PJ>J=bE1GK5)evJfrP*;3cb6@TtwIOXny+mLn&|oFIq9G=HplEsr73>7T
z6Y8=`(H@6?0v}!!zp0>k5N@ueaeRh?+6jbmuf>eOy?8CEgnkFgCmb3<2OV&tP(*P|
z2?YX**0MGt;}-n0ppM8`MjM{0j`+Uldjtw2BGAVFeMqoM*4B@kSZftTd`g|nE1Vkp
z`q-p;0SY6xM@0WSJ;vp1j23b^yT$r&4wttf(#+*GEUU?!&C6=FEo)K(<5A$-i?@O*
zFIa8i-BD9yEOuz7VkU<zI}AgbCEK15s*<cpBMfW8d<t^X#1?JjEDh13*tOV|*(&zr
znb{z_>D;@P&n;&XwyI@yN}Wbubg@ofcvhYM#=1KF<+XJhG(G@Vkv66P<Ed+tG(JT;
zI!WW#;G@BIf#G=qd~1Og*>uto($X-j3Xn~QA*vn$y1TmjRKocJXir#23QBAv*TF_!
zf&bHBCkBTxhz1!yft}RbLEGx>icyp`4JJ3qV8l;%3e7Kqdt>8a#-PNfITdUrOVTPV
zsSeR&bHRRHpX}EWgk&&N*`|<x5o}6CJZ(@h+VV_BwL%=pz+%we|9eQVfi*TG1B0Ra
zjVTSRVne)Q$9%<($z$Tj4e<H*^6%t__aL`_iOb(7)`!n=g>?}>SJ(u$mcIpth4814
zD=;z?eUU3Xu&h<(w~@<gO;PS-8;r@6SI5hCa%DT=^T$Hj#>lnEl~~n`Iu@Kc&Yr%)
zo_d}wbuMX%@|Gurx;%ICC>ZS*$qv=zG1k6=v+j&_&K3fAI@iTsdY<h99OGpNhFR|j
z+cNsD^~L2JqH-sg<(jsMdQEJb0tf+Zg^J_@tm-hbNE{#|ttIcOkOl&^63~dvQr9Z2
z4A}|pl~O{H&?*puEd}n0?F-*|qC*5ByMR?f=TjjN0gtSu*+HaJPGR^}fZT%9R|`Rb
zte{HZfukK+Et7!9A>g>i7>WqP6PV-IKq_Mn48-R#5N`mufr0o2)>g}z>sCUKVXk;{
zv>iSbaM`<7K#$mUj5*o?b8M5KyvQNa{;s)s*^m;5QXmG_0W<c`YwAGo*>wOk=Cb%3
z|35<>SZg#GQz+(ojbYreQlmhlMLML_6VHQBy#e~AbLfNnpkfXE!roH=8|y0>ufZS#
zs}1&R$WbTI#Rhb;4!V$=$tstOF4}>|s3WB#6m@O|uy_FE{=b0)`#pu;)om2@u5vnq
zGuI&SkP2N4b2&AUb}pwW8hCr;ha)pN-1ft>&D{1Aob|b7wF*NET>@G}>6xCH3$v$Y
z{j+ZN;90hK>s;}<N#nwSPBEIIr=R02^-*19IQl{?JEmnfw!UlGyKF*UD|P5(0@<;~
zetvz8z4wVU_A6^^Ea)@R{(l3w0&BJwqY52H725mym8fEs?ysQ67695mF%JJ<2P>c)
zhTw5{-|Ja{0v<?_-&0J&f+4n|o#1`3dEmef*$5cU4Zn;YWJ^hk3YF+VHkYLM5PA9)
z=;1I_jBb6J(I`ZeKaTx(XzKr;kR%(>_ML(OvE@yyt(h}#kxgh#{IG+|2j%DTw|#c}
z5YdH)BQHd=quS`%SY51`twJy!K?fCv4m#+%edOe^@V0ObTie3gcX8I;GrHLD%nP&G
zv)b9SBI4NNeAoK<<?IA@NNt5^h!|VpkJh)sUwtAg1R%0j#0pl3EP4$qgscA^t|G*Z
zdbFe?b*&PWtU<9F`={VeCt?3Jcxf?$NgkdjQV!4Su$?O61Nh*D2D0_?N3St`NDqU-
zA|eye(aM-YYJ;tMQn2WW{|Nc7!Lp4GQ?LtO(=%JP0z^NfnWqb8?w10FB<n1KyEC{q
z1m8<AFQH@<k`pjzBgxv60tQMEFr;EC_m$|^6760L8;(HD=>AV)_=*RYoxsPy#$O4l
zpX>y-ZWnve2G-WdnVVAjfDLu=4ZG(z?4CA>^Mhal2p(8UpgU>aP!3nRDcTH^haj9N
z-tkbJO;pU4ZjbGPIYban6dxfWLbq4qX-4t|y&5hotF`umY0Z+EsIHAy?cu8SEEL%n
zs_XIitv}+9Zi$(qV~JR!0>v8Dtq^Ne7fc%=*4U>ys+u;1uZR00KDKfXXKS6Qp0Ukl
z&Nk0h%?8-BPWH^_+0PHKz7cj{l->K{ySC7B9#OLgf(|M2`2XG`F;=#QU--A`J$zsS
z&+I+cnNx{A6+NRzu_XfsH1ip`mt+7@46@0-g*Qla5}sJ)Vd_x>IpSN#!(i6yco_cB
zdec^(@*ZRdGkWfm_^4-QYXFz!-=D&7?cFbdmloExi!<ZFLjnKG-~}8_K}kG+&wTzK
zfEM}9qCfhK-isp2s?aARwzi$KA6}>c_d%AmE*o^kCCh3GJFu+v9asl@qK`f9VJrHR
z9N0OPQ*>Z#Lpxh}n6n+3ZHLJ@XU?+cF0f}WvKOzg&wJP_{cOK~i6DY7^#HN}c@kwu
z$y2J2;M>V*)p9XW&<cb0>pL~16c`dwFfg+AjDssrJ`p71*M&p~Uabv@V2o=mNCbfC
z4Y;ZUr-Z)1CLO73lK@kScJyk%l!|J#%S%O-1en&4NthR*Tk%0c5434Xj|8Uxm=Ijj
z;{b`m-_Z?tZiX?W18`-4C7a@q))<Aqv?qhBHCtkc^(H{8p9=75;yuX!05A(JA$bvQ
z{g-o;3OMqNUNcL=VWP8ybr&i9WfCBJ6~tDeGJP^C!#*<!nkm0$CqXmpIPpDX?}<jo
zC443TH2&0Qai5Bpqj06JzoaWod5a3<R=***)pX&jx-gixbC={+x3IRYoOxR+Jh;lO
z)@_Q{?VGRLH+^iOV#6CdU*EX^9y0&+{KyWjY)eeXm9>iXk#k%{bJWjOv>>0k`=LM`
zxx!WKioM8H90hz>)=2`At8%>2@p=c_aFnY&wy<G8P*)uw!Nr!9FQpTeHRv9SRvCI|
zwX8N&mQ1%TS&7<)xMM%(*bftz7iu?0Y|+eUbF?ZNh#iaVnKiJdz3iz00D#~!Lon?N
zvKPrCD68pEfj_Q2KmwwyEty86*8{2>D)^YcEmFfawXrpaxT5yi>RB6m>NI=ibL{E!
z?D<RV<zDtuAKUi=aPX7I5hI2?fwB{-ODMan>P6WlRUgWZkRIfvi~Ci}r9}OH5PJ<@
zjXx`|m^QBi?ZXax2uf4n_Td~KsYbSiX+C#VZ;4c-FwH*Y*Hv(?-Pkds+0(+vHU2V$
z$G%|<QgD;0zL~xyN&t>oE5w!SQt8pRB*b-HDu^A0>0|3s8Q`mv9^9UR)_)sDL_>H2
z+=N?01dx^D0~P|9q_Uh#GD~k}%osAZ5w}d;s$Qa7bp>4em<jmdwR|*Qjd@!&Vb&01
zW~g7A60eaIDbv=a#48s?%Jg+9u?!+*#+XSl?JDJzH`+|6-A|XMX<dfSVa$S3T*@5F
z!g=<XHI$iZ&1=XQGOwHlH<kmGDQ1%6ZYfKtTR@j1zhSAQocsn9DOTvxRyyZ?uGEde
zgt5$iq#j8}D2L9wZ&OfZts#FJov)n6H<la9T2ual74m1Ll)q5Y5s)nFndHw(DSvK~
z{Ml>BpAKvL71I#M@<Q2b%3r)f{_K?Umnh`VekS>|Q_7#0B)@eH`7`L!74q9c)-~m~
zuaMuGQhvKae(N*IZ%rw`ZKeDQJ3^g)(jobW6_Y>_5J)=cGP?YJg{+l<#46%`dlD&}
z_E)T~1K3xYq87opN_aaGxXV|_Tb+VFpRS^-?{ARoeudmMtLf$E3+0~yk4M7)G1HBw
zlpHm|jljz&!5`sclCWTQ%`cV+L#;#DVizW2qDeE%Nl193ympj11r;zSGb=IO9DNGM
z^VsD&c?P>&C$r#lrM6NoEYD^B1G?eYQ1W$@{1qf0qPGq6JJAB1578_T#t8|p?Pc6<
zUvCdS9`A*j>ROl-I>^8TPw!BlD~KlY3ZG<!6~Dr(c#PM(1`!)&1y2q$!fkks3znzy
z6ay<^VHUq{R8!T^)B~$%XmnFG<EDdXqO!zOUWF_2lq+~mFXI|fP%Bs5Vrpdtuek~n
zTyeE>g>r8*KHk~e`^`J(_$_)+-POTBU~quf_4$WjP3@=#%~54~KrE&gC4G=Ma+qtV
z>_rLE59R_Syhd2fdd)rJXVAC{Px*sa5m5FE^KA`i;jFj_0TqR5sJtoQ>AnW5T^QGZ
zpEsb-fWkCYGoBX<CnK<4hR=|AIbC#r&>vvz=)UDBK{kdbt}+2s3PR#25Jq1yh~EPh
zyj8It7OjWJOY5*A@@YLDZ@>+2A8j||N~I>eNp9`uRYS0V7k?thdg<p)vO>a%tch^q
zy51|U?S|RBXiBZxHQb1jCX_UzWDBo_hxRuLS(A`83)vQ7<{<J{k_oQPh51|ifo6@#
zwJR519RO_TM-cNR;$w<1SZ<kbn%TT9(a%MXusM6?sn&<3Wh|`tgh7;ohWUa9_*P$J
z4_m`tuB<sa%9ZWsiVln)Unpycgt)TZaX2sAKUa2;HJ3bdT~!m?e2}YZi&u4URULCx
z$5?au!|ELi!e8yaWrKEeI%~Fv3*I%?FQpNMn?5drfQ2pG6ffMu6>ga;+%}iHecbfV
zhfY3GtMZJ$J#;e0Ao?uMT*+4LoHMt~TtX{etxE)4UZ#k4@)Y@(Cp}7@6S;ProoSK<
z*fVEtoh_6F_}EA|>VIH<(;Ph&BWHHZ*K~4J)wr5VtGd}g?w>q(r*^tItcD0H(>kTU
zt%uR<OELY7e^NhZIX13cpiF2@@pSGq1v6^c+@14O3#v=MnLhc2d6;bn<&2vd(`O=$
z;~DcXIY^+Nbcb`tVaadJO1|2eGl*|T65l2^w|So0^6B~NX1WpIqyJa<hRtm5#(ApY
zlZg8<tbB&`KWITWUO{e(Q-vH=2#d?r52!7Va`L9m-#$Ne`S#^-<r^Dc-xzI=?uc!P
zmd@quA2+@SuN18}KN>k4%YH!ZLFceMeZsVmkq--g{`I3?67=j}Khh<oe$-R^vNof$
zQuE8b8J!NzJJyWO2F*K;jLv2avkxw=i1knm1BOXF`B?Kzu^tJSL8V+c0*iT2oo4+d
zKN1#5HSdp3ESLs9y1Uvjbs#b9)sMQiq@zF8+Et?8l0*ilA;rY)Kq9`7WI?lDQlUYp
zO|ig6fe=-xu%E;gFM@)5;}}RcrZ*744}Eq|Izl>_gCNGtV-!t|8AAH?`CfTf<Z6Tn
z4Iv(Uq}o#^l-Of!D@2nabH80AR%BSdv@zI~3;mNYAneIz9Lu0hW0sI5lraj^xW+OA
z2}DVo162}>FQ$hwM@<AFJ%hwyEGuN}N8c%v4mz<+s^5`x2~Op!A&O298DQ8E&uI(P
zO0@m;Qc2GHH_2tGBu17Zrj@y&aL<Ws10N90XN|&8=$IkUoTy8@HF#%K|5mA9&LM6U
zWs{y3;x$7ki_RVeB7xt;JYHI))}Y^gm)uq=g%k__0|+PJgU-eCQWT>op{Hos6_8uf
zv8QSd=pUv9%`p%G_|=3X)&5qp?vTVpF$~vkh2dI51<?qDPB#F<UnEHQ2aBh2hSe8|
z8)O9$*e3C-B$(>4Y{hud4(W=V(^fR7Oy`8M;Wt*ii;Dzp7|Z@bHgJAjDBU1$5Gn6b
z{?vOwJc~3)(oH0_z;og&$-Eu5-~vczlt7NK3(O(3P+Hgu=3jn3u{iPN#mToG-+bxu
zw{OCd+26k&NsudcO@PgK@HJuAqs8w}Eq*x$jbWpo#h>3w+Uw}W1Os&6a(|y2&?(v@
zu)M{-@*2J_tZx^umkVcT$y50XHe-o1xfHa+!#(Yp@H#d@c;4J6@0{es-wH>~RTrxU
zs_3dCRmZE&jA|Q(y?(S1A1y8Y5P7f@y|3i{_P_q|%pdkLQ*g>$fn-!04D@W=!IS&X
zGShGlI9~(1JJGNu3@l`0z5!JqqDi7SpiszXKZ9O{u$Iog_}w4={zu<yv5#8u?_mej
z?6#woVzk}mw+9hMT^tX8c;~y1Vn2F3^<!!49-)z=R1q?u2@ky5H+TaggaFfnc4uVl
zP^W<NC=O!K&?m2B+yjHxVe1?hY~u*I7WQO>K*8M2z#3?`6aQE|b+V%qZvx3{28Y}}
z<{i{h4LdLKYL5@r!?}HES4Lh(yKzn-qM?ytSPO@@b@Vf+=jAnMQ%6RRiUt==J3VMy
zN#1}ScL>F6ycRy<LKLV$Pt9u~Ch!FuRw2^Z2d#uv*9P=ru=?;q5$_13x^a~^%9_Pz
z2zrwUMR?T>KP>l#eY6I9dLTNI*3uz0!$AN%$v`hp-SE(XKIhOdZ|HNQb%UsA8S)If
zy?6?Xa|kvb3h?PT6Ka4boXZsGTwJIJML$ov{Z<ejsdn-qL>3)zb+jn?^MrB}gV#_<
z(F0x{LJDglq}U!aMnf~(*qozi6@PAdxFuX4as7yT+x$cG->1hnALce6o=u<Ie4gEO
zfxU2rwLU*?c+Z+Ub@=w-sm|M-VQajs8O0nI=d63j4FKQLb6@QmhlSckguN!qryRE(
zur<xYx^3~g-CW)7cwH-J-Y|Z2I%7#?Ps?8bMCZKijI>NT=W@2eO1|O}nA6#?C*E+7
zYdH9uhC`gScJgT0_$a^ZUh$pc@aTMgQ?z@bq45WOZ}xGvx@jux_#=$dH^Uc!nvJZr
za-nL&<cWv2YSyunv+V?QpHl%sl~*m;3ch_XY>1pdyQLKEf-nP5Wiu1?qF}M}b9IN}
zb)8&Y=PVS@O&*xeoNk$}XY)32)|&S=?|3`ohZ*tBZQSOz*-G}@d3JN#+~x}_sphR4
z7px`WvfIy19)-IW+QY`Vg1X6r3-H3w%gT<Bk=jTRTfJ@Gx*ZUIPHDI{^1|y4oOSc<
zqaST0Hno#W2BLoN(h-s{m~QEB>L(2t2B)!>%J9YTF*bekJk^+ZnZHTA%!S&W@!Gvy
z?cU$i?&mDklScSPqEctJk?6NVJ2>?}usUEGY#n^7QNtbnc#wpb#^pEt`Qs+STKo~A
zO3O#fGShCSvG%5DOSC@bnI&iZY{{{COXvF*+n<-TK=S90ZG^4tBZ9=73(-bRY-MZg
zg;+ORejsi=$XO5mc}b0~{>hIt@|Sgcj})lhskIzQ)4$VlpcYR4sX3>^teH*I9?3J!
zW>HWxTVUugXlE-5J2cu~X|z!OmD$j-UH_{bTSt@rS4~<d!)~&p_J&P@K5tSwT-cg6
z0K0X0y8W9Rs<W`+7}JTY{5T}ABP`*tp}nt=fjXVM(dir*q=R7jPTuT98)xBNX5maV
zMDvC=7+GkC5e~E_H^4BPfdz8GgI)%q61=kqgD?(kX$D*VFlSKZ0hAm>NgGPgw0))>
zC5KUh=7=#9D7l4_{U|~2<xK*w*%M3`!Egp82=n@j!AxI9d;FB_BbW8f+RBINmRsJN
z-X$%RL1%1*Pf+c0KbfvAjGSE}Ae+@ZLD@%kD<t(MZQ)W0QS4aA*|)5>X}>_ia;_yc
zDm={1U(%ui@Udh+!55ddP}<XElzu{>e94-wrO8+&;zyH9_DpSuY6h;Me5sn!?kA&G
zM7bX*P1@sR^z0J?<x2$?t&g06Ybal;%+?-N&B8U5FV)(#P8I8NKOs<IX-l#8hU#HX
z{u3=KEVp)$+JcA*MczvUD#yB?;C$(Gs#a|q8HV{3D34h`#<}q3(ED-}^Mz>Jvj+Mq
z{5h3cfd`3Dlm=cDQ3PS5LO%lm8^NGHl+T2{gVCs$*K-xNM?)ppF9+wssF>dGc3mB0
ze9RDP!l49rbh%Qe)PP2iV2yVJ?tg^-NDUnv^J_$V4JEh-)eXUZA1*)hzfg@G5?%#s
zzB3YRlwF(Ys>|=`J~-$@V^Ero6YbCO!f;%l8+4Llx=-TqH>@knM~Gn~N)V*ysojER
zw=yIs5d0DTS0DjnB+2)Q9si9u@jg-dJ0fS1D1M))d7miz9g+S%QT#h1`*(x^|7E;S
z*dG$vFX`h%Hb-PH7&C9x->hd#kN!ceB2}P}Wco|$SJJ+eHhJs;P*&81YvJ7dB{Q2=
b!V#qlRf*Fwjwt`5Zb(PAkslE_!-D=F5<rpW

literal 0
HcmV?d00001

diff --git a/core/biz/huge_volume_chart.py b/core/biz/huge_volume_chart.py
new file mode 100644
index 0000000..fcab219
--- /dev/null
+++ b/core/biz/huge_volume_chart.py
@@ -0,0 +1,459 @@
+from core.db.db_huge_volume_data import DBHugeVolumeData
+from core.utils import timestamp_to_datetime, transform_date_time_to_timestamp
+import matplotlib.pyplot as plt
+import seaborn as sns
+
+from openpyxl import Workbook
+from openpyxl.drawing.image import Image
+from PIL import Image as PILImage
+import logging
+from datetime import datetime
+import pandas as pd
+import os
+import re
+import openpyxl
+from openpyxl.styles import Font
+
+logging.basicConfig(
+    level=logging.INFO, format="%(asctime)s - %(levelname)s - %(message)s"
+)
+
+sns.set_theme(style="whitegrid")
+# 设置中文
+plt.rcParams["font.sans-serif"] = ["SimHei"]
+plt.rcParams["axes.unicode_minus"] = False
+
+
+class HugeVolumeChart:
+    def __init__(
+        self,
+        data: pd.DataFrame,
+        output_folder: str = "./output/huge_volume_statistics/",
+    ):
+        """
+        初始化
+        data: 数据
+        data中的列名为：
+        symbol: 币种
+        bar: 周期
+        window_size: 窗口大小
+        huge_volume: 是否巨量
+        volume_ratio_percentile_10: 10%分位数
+        volume_ratio_percentile_10_mean: 10%分位数平均值
+        price_type: 价格类型
+        next_period: 下一个周期
+        average_return: 平均回报
+        max_return: 最大回报
+        min_return: 最小回报
+        rise_count: 上涨次数
+        rise_ratio: 上涨比例
+        fall_count: 下跌次数
+        fall_ratio: 下跌比例
+        draw_count: 持平次数
+        draw_ratio: 持平比例
+        total_count: 总次数
+        output_folder: 输出文件夹
+        """
+        self.data = data
+        # remove 1D bar
+        self.data = self.data[self.data["bar"] != "1D"]
+        self.data.reset_index(drop=True, inplace=True)
+        self.output_folder = output_folder
+        os.makedirs(self.output_folder, exist_ok=True)
+        self.temp_dir = os.path.join(self.output_folder, "temp")
+        os.makedirs(self.temp_dir, exist_ok=True)
+        self.symbol_list = self.data["symbol"].unique().tolist()
+        # sort symbol_list
+        self.symbol_list.sort()
+        self.bar_list = self.data["bar"].unique().tolist()
+        self.bar_list.sort()
+        self.window_size_list = self.data["window_size"].unique().tolist()
+        self.window_size_list.sort()
+        self.next_period_list = self.data["next_period"].unique().tolist()
+        self.next_period_list.sort()
+        self.volume_ratio_percentile_10_list = (
+            self.data["volume_ratio_percentile_10"].unique().tolist()
+        )
+        self.volume_ratio_percentile_10_list.sort()
+        self.price_type_list = self.data["price_type"].unique().tolist()
+        self.price_type_list.sort()
+
+    def plot_entrance(self, include_heatmap: bool = True, include_line: bool = True):
+        """
+        绘制上涨下跌图入口
+        """
+        charts_dict = {}
+        if include_heatmap:
+            heatmap_plot_dict = self.plot_heatmap_entrance()
+        if include_line:
+            line_plot_dict = self.plot_line_chart_entrance()
+        
+        if include_line:
+            charts_dict.update(line_plot_dict)
+        if include_heatmap:
+            charts_dict.update(heatmap_plot_dict)
+        return charts_dict
+    
+    def plot_line_chart_entrance(self):
+        """
+        绘制折线图入口
+        """
+        charts_dict = {}
+        # 根据price_type_list，得到各个price_type的平均rise_ratio，平均fall_ratio，平均draw_ratio, 平均average_return
+        total_chart_path = self.plot_pice_rise_fall(data=self.data, prefix="总体")
+        charts_dict["总体"] = {"总体": total_chart_path}
+        self.plot_window_size_rise_fall(charts_dict=charts_dict)
+        self.plot_window_size_bar_rise_fall(charts_dict=charts_dict)
+        self.plot_window_size_bar_next_period_rise_fall(charts_dict=charts_dict)
+        self.plot_symbol_rise_fall(charts_dict=charts_dict)
+        self.plot_symbol_bar_rise_fall(charts_dict=charts_dict)
+        self.plot_symbol_bar_window_size_rise_fall(charts_dict=charts_dict)
+        self.plot_symbol_bar_window_size_next_period_rise_fall(charts_dict=charts_dict)
+
+        # self.plot_symbol_bar_window_size_volume_ratio_percentile_10_mean_rise_fall(charts_dict=charts_dict)
+        # self.plot_symbol_bar_window_size_volume_ratio_percentile_10_mean_next_period_rise_fall(charts_dict=charts_dict)
+
+        self.output_excel(chart_type="line_chart", charts_dict=charts_dict)
+        return charts_dict
+
+    def plot_heatmap_entrance(self):
+        """
+        绘制热力图入口
+        """
+        charts_dict = {}
+
+        self.plot_symbol_heatmap(charts_dict=charts_dict, ratio_column="rise_ratio", title=f"Rise Ratio Heatmap by Window Size and Bar")
+        self.plot_symbol_heatmap(charts_dict=charts_dict, ratio_column="fall_ratio", title=f"Fall Ratio Heatmap by Window Size and Bar")
+        self.plot_symbol_heatmap(charts_dict=charts_dict, ratio_column="average_return", title=f"Average Return Heatmap by Window Size and Bar")
+
+        self.output_excel(chart_type="heatmap_chart", charts_dict=charts_dict)
+        return charts_dict
+
+    def plot_symbol_heatmap(self, 
+        charts_dict: dict, 
+        ratio_column: str = "rise_ratio",
+        title: str = "Rise Ratio Heatmap by Window Size and Bar"
+    ):
+        """
+        绘制symbol热力图
+        """ 
+        for symbol in self.symbol_list:
+            charts_dict[f"{symbol}_{ratio_column}_heatmap"] = {}
+            for price_type in self.price_type_list:
+                logging.info(f"绘制{symbol} {price_type} {ratio_column}热力图")
+                df = self.data[(self.data["symbol"] == symbol) & (self.data["price_type"] == price_type)]
+                pivot_table = df.pivot_table(values=ratio_column, index='window_size', columns='bar', aggfunc='mean')
+                plt.figure(figsize=(10, 6))
+                # 热力图以红色渐变为主,红色表示高，绿色表示低
+                sns.heatmap(pivot_table, annot=True, cmap='RdYlGn_r', fmt='.3f')
+                plt.xlabel('Period')
+                plt.ylabel('Window Size')
+                plt.title(f"{title} {price_type}")
+                # plt.show()
+                chart_path = os.path.join(self.temp_dir, f'{symbol}_{price_type}_{ratio_column}_heatmap.png')
+                plt.savefig(chart_path, bbox_inches='tight', dpi=100)
+                plt.close()
+                charts_dict[f"{symbol}_{ratio_column}_heatmap"][f"{symbol}_{price_type}_{ratio_column}_heatmap"] = chart_path
+
+    def plot_window_size_rise_fall(self, charts_dict: dict):
+        """
+        不区分symbol, 绘制window_size上涨下跌图
+        """
+        charts_dict["window_size"] = {}
+        for window_size in self.window_size_list:
+            data = self.data[self.data["window_size"] == window_size]
+            chart_path = self.plot_pice_rise_fall(data, prefix=f"window_size_{window_size}")
+            charts_dict["window_size"][f"window_size_{window_size}"] = chart_path
+
+    def plot_window_size_bar_rise_fall(self, charts_dict: dict):
+        """
+        不区分symbol, 根据window_size绘制bar上涨下跌图
+        """
+        charts_dict["window_size_bar"] = {}
+        for window_size in self.window_size_list:
+            for bar in self.bar_list:
+                data = self.data[
+                    (self.data["window_size"] == window_size)
+                    & (self.data["bar"] == bar)
+                ]
+                chart_path = self.plot_pice_rise_fall(
+                    data, prefix=f"window_size_{window_size}_bar_{bar}"
+                )
+                charts_dict["window_size_bar"][f"window_size_{window_size}_bar_{bar}"] = chart_path
+
+    def plot_window_size_bar_next_period_rise_fall(self, charts_dict: dict):
+        """
+        不区分symbol, 根据window_size, bar, next_period上涨下跌图
+        """
+        charts_dict["window_size_bar_period"] = {}
+        for window_size in self.window_size_list:
+            for bar in self.bar_list:
+                for next_period in self.next_period_list:
+                    data = self.data[
+                        (self.data["window_size"] == window_size)
+                        & (self.data["bar"] == bar)
+                        & (self.data["next_period"] == next_period)
+                    ]
+                    chart_path = self.plot_pice_rise_fall(
+                        data,
+                        prefix=f"window_size_{window_size}_bar_{bar}_next_period_{next_period}"
+                    )
+                    charts_dict["window_size_bar_period"][f"window_size_{window_size}_bar_{bar}_next_period_{next_period}"] = chart_path
+
+    def plot_symbol_rise_fall(self, charts_dict: dict):
+        """
+        区分symbol, 绘制symbol上涨下跌图
+        """
+        for symbol in self.symbol_list:
+            charts_dict[f"{symbol}_总体"] = {}
+            data = self.data[self.data["symbol"] == symbol]
+            chart_path = self.plot_pice_rise_fall(data, prefix=symbol)
+            charts_dict[f"{symbol}_总体"][symbol] = chart_path
+
+    def plot_symbol_bar_rise_fall(self, charts_dict: dict):
+        """
+        区分symbol, bar, 绘制symbol上涨下跌图
+        """
+        for symbol in self.symbol_list:
+            charts_dict[f"{symbol}_bar"] = {}
+            for bar in self.bar_list:
+                data = self.data[
+                    (self.data["symbol"] == symbol) & (self.data["bar"] == bar)
+                ]
+                chart_path = self.plot_pice_rise_fall(data, prefix=f"{symbol}_{bar}")
+                charts_dict[f"{symbol}_bar"][f"{symbol}_{bar}"] = chart_path
+
+    def plot_symbol_bar_window_size_rise_fall(self, charts_dict: dict):
+        """
+        区分symbol, bar, window_size, 绘制symbol上涨下跌图
+        """
+        for symbol in self.symbol_list:
+            charts_dict[f"{symbol}_bar_window_size"] = {}
+            for bar in self.bar_list:
+                for window_size in self.window_size_list:
+                    data = self.data[
+                        (self.data["symbol"] == symbol)
+                        & (self.data["bar"] == bar)
+                        & (self.data["window_size"] == window_size)
+                    ]
+                    chart_path = self.plot_pice_rise_fall(
+                        data, prefix=f"{symbol}_{bar}_ws_{window_size}"
+                    )
+                    charts_dict[f"{symbol}_bar_window_size"][f"{symbol}_{bar}_ws_{window_size}"] = chart_path
+
+    def plot_symbol_bar_window_size_next_period_rise_fall(self, charts_dict: dict):
+        """
+        区分symbol, bar, window_size, next_period, 绘制symbol上涨下跌图
+        """
+        for symbol in self.symbol_list:
+            charts_dict[f"{symbol}_bar_ws_period"] = {}
+            for bar in self.bar_list:
+                for window_size in self.window_size_list:
+                    for next_period in self.next_period_list:
+                        data = self.data[
+                            (self.data["symbol"] == symbol)
+                            & (self.data["bar"] == bar)
+                            & (self.data["window_size"] == window_size)
+                            & (self.data["next_period"] == next_period)
+                        ]
+                        chart_path = self.plot_pice_rise_fall(
+                            data,
+                            prefix=f"{symbol}_{bar}_ws_{window_size}_next_period_{next_period}"
+                        )
+                        charts_dict[f"{symbol}_bar_ws_period"][f"{symbol}_{bar}_ws_{window_size}_next_period_{next_period}"] = chart_path
+
+    def plot_symbol_bar_window_size_volume_ratio_percentile_10_mean_rise_fall(self, charts_dict: dict):
+        """
+        区分symbol, bar, window_size, volume_ratio_percentile_10_mean, 绘制symbol上涨下跌图
+        """
+        for symbol in self.symbol_list:
+            charts_dict[f"{symbol}_bar_window_size_vol_per"] = {}
+            for bar in self.bar_list:
+                for window_size in self.window_size_list:
+                    for (
+                        volume_ratio_percentile_10
+                    ) in self.volume_ratio_percentile_10_list:
+                        data = self.data[
+                            (self.data["symbol"] == symbol)
+                            & (self.data["bar"] == bar)
+                            & (self.data["window_size"] == window_size)
+                            & (
+                                self.data["volume_ratio_percentile_10"]
+                                == volume_ratio_percentile_10
+                            )
+                        ]
+                        chart_path = self.plot_pice_rise_fall(
+                            data,
+                            prefix=f"{symbol}_{bar}_ws_{window_size}_vol_per_{volume_ratio_percentile_10}"
+                        )
+                        charts_dict[f"{symbol}_bar_window_size_vol_per"][f"{symbol}_{bar}_ws_{window_size}_vol_per_{volume_ratio_percentile_10}"] = chart_path
+
+    def plot_symbol_bar_window_size_volume_ratio_percentile_10_mean_next_period_rise_fall(
+        self,
+        charts_dict: dict,
+    ):
+        """
+        区分symbol, bar, window_size, volume_ratio_percentile_10_mean, next_period, 绘制symbol上涨下跌图
+        """
+        for symbol in self.symbol_list:
+            charts_dict[f"{symbol}_bar_ws_vol_period"] = {}
+            for bar in self.bar_list:
+                for window_size in self.window_size_list:
+                    for (
+                        volume_ratio_percentile_10
+                    ) in self.volume_ratio_percentile_10_list:
+                        for next_period in self.next_period_list:
+                            data = self.data[
+                                (self.data["symbol"] == symbol)
+                                & (self.data["bar"] == bar)
+                                & (self.data["window_size"] == window_size)
+                                & (
+                                    self.data["volume_ratio_percentile_10"]
+                                    == volume_ratio_percentile_10
+                                )
+                                & (self.data["next_period"] == next_period)
+                            ]
+                            chart_path = self.plot_pice_rise_fall(
+                                data,
+                                prefix=f"{symbol}_{bar}_ws_{window_size}_vol_per_{volume_ratio_percentile_10}_next_period_{next_period}"
+                            )
+                            charts_dict[f"{symbol}_bar_ws_vol_period"][f"{symbol}_{bar}_ws_{window_size}_vol_per_{volume_ratio_percentile_10}_next_period_{next_period}"] = chart_path
+
+    def plot_pice_rise_fall(self, data: pd.DataFrame, prefix: str = ""):
+        """
+        绘制价格上涨下跌图
+        """
+        logging.info(f"绘制价格上涨下跌图: {prefix}")
+        # 根据price_type_list，得到各个price_type的平均rise_ratio，平均fall_ratio，平均draw_ratio, 平均average_return
+        price_type_data_dict = {}
+        for price_type in self.price_type_list:
+            filtered_data = data[data["price_type"] == price_type]
+            average_rise_ratio = filtered_data["rise_ratio"].mean()
+            average_fall_ratio = filtered_data["fall_ratio"].mean()
+            average_draw_ratio = filtered_data["draw_ratio"].mean()
+            average_average_return = filtered_data["average_return"].mean()
+            price_type_data_dict[price_type] = {
+                "average_rise_ratio": average_rise_ratio,
+                "average_fall_ratio": average_fall_ratio,
+                "average_draw_ratio": average_draw_ratio,
+                "average_average_return": average_average_return,
+            }
+
+        # 准备数据用于绘图
+        price_types = list(price_type_data_dict.keys())
+        rise_ratios = [
+            price_type_data_dict[pt]["average_rise_ratio"] for pt in price_types
+        ]
+        fall_ratios = [
+            price_type_data_dict[pt]["average_fall_ratio"] for pt in price_types
+        ]
+        draw_ratios = [
+            price_type_data_dict[pt]["average_draw_ratio"] for pt in price_types
+        ]
+        avg_returns = [
+            price_type_data_dict[pt]["average_average_return"] for pt in price_types
+        ]
+
+        # 创建子图，保持2x2布局
+        fig, ((ax1, ax2), (ax3, ax4)) = plt.subplots(2, 2, figsize=(15, 12))
+
+        # 绘制上涨比例
+        bars1 = ax1.bar(price_types, rise_ratios, color="green", alpha=0.7)
+        ax1.set_title(f"{prefix}总体平均上涨比例")
+        ax1.set_ylabel("上涨比例")
+        ax1.tick_params(axis="x", rotation=0)
+        ax1.bar_label(bars1, fmt="%.2f")
+
+        # 绘制下跌比例
+        bars2 = ax2.bar(price_types, fall_ratios, color="red", alpha=0.7)
+        ax2.set_title(f"{prefix}平均下跌比例")
+        ax2.set_ylabel("下跌比例")
+        ax2.tick_params(axis="x", rotation=0)
+        ax2.bar_label(bars2, fmt="%.2f")
+
+        # 绘制持平比例
+        bars3 = ax3.bar(price_types, draw_ratios, color="gray", alpha=0.7)
+        ax3.set_title(f"{prefix}平均持平比例")
+        ax3.set_ylabel("持平比例")
+        ax3.tick_params(axis="x", rotation=0)
+        ax3.bar_label(bars3, fmt="%.2f")
+
+        # 绘制平均回报
+        bars4 = ax4.bar(price_types, avg_returns, color="blue", alpha=0.7)
+        ax4.set_title(f"{prefix}平均回报")
+        ax4.set_ylabel("平均回报")
+        ax4.tick_params(axis="x", rotation=0)
+        ax4.bar_label(bars4, fmt="%.2f")
+
+        # 调整布局，增加底部空间和垂直间距以显示完整的x轴标签
+        plt.tight_layout()
+        plt.subplots_adjust(bottom=0.15, hspace=0.4)
+        # plt.show()
+        chart_path = os.path.join(self.temp_dir, f'{prefix}.png')
+        plt.savefig(chart_path, bbox_inches='tight', dpi=100)
+        plt.close()
+        return chart_path
+
+    def output_excel(self, chart_type: str, charts_dict: dict):
+        """
+        输出Excel文件，包含所有图表
+        charts_dict: 图表数据字典，格式为：
+        {
+            "sheet_name": {
+                "chart_name": "chart_path"
+            }
+        }
+        """
+        logging.info(f"输出Excel文件，包含所有{chart_type}图表")
+        file_name = f"huge_volume_{chart_type}_{datetime.now().strftime('%Y%m%d%H%M%S')}.xlsx"
+        file_path = os.path.join(self.output_folder, file_name)
+
+        # Create Excel file and worksheet
+        wb = Workbook()
+        wb.remove(wb.active)  # Remove default sheet
+
+        for sheet_name, chart_data_dict in charts_dict.items():
+            try:
+                ws = wb.create_sheet(title=sheet_name)
+                row_offset = 1
+                for chart_name, chart_path in chart_data_dict.items():
+                    # Load image to get dimensions
+                    with PILImage.open(chart_path) as img:
+                        width_px, height_px = img.size
+
+                    # Convert pixel height to Excel row height (approximate: 1 point = 1.333 pixels, 1 row ≈ 15 points for 20 pixels)
+                    pixels_per_point = 1.333
+                    points_per_row = 15  # Default row height in points
+                    pixels_per_row = (
+                        points_per_row * pixels_per_point
+                    )  # ≈ 20 pixels per row
+                    chart_rows = max(
+                        10, int(height_px / pixels_per_row)
+                    )  # Minimum 10 rows for small charts
+
+                    # Add chart title
+                    # 支持中文标题
+                    ws[f"A{row_offset}"] = chart_name.encode("utf-8").decode("utf-8")
+                    ws[f"A{row_offset}"].font = openpyxl.styles.Font(bold=True, size=12)
+                    row_offset += 2  # Add 2 rows for title and spacing
+
+                    # Insert chart image
+                    img = Image(chart_path)
+                    ws.add_image(img, f"A{row_offset}")
+
+                    # Update row offset (chart height + padding)
+                    row_offset += chart_rows + 5  # Add 5 rows for padding between charts
+            except Exception as e:
+                logging.error(f"输出Excel Sheet {sheet_name} 失败: {e}")
+                continue
+
+        # Save Excel file
+        wb.save(file_path)
+        print(f"Excel file saved as {file_path}")
+
+        for sheet_name, chart_data_dict in charts_dict.items():
+            for chart_name, chart_path in chart_data_dict.items():
+                try:
+                    os.remove(chart_path)
+                except Exception as e:
+                    logging.error(f"删除临时文件失败: {e}")
diff --git a/huge_volume_main.py b/huge_volume_main.py
index 6479ee5..cefa1ec 100644
--- a/huge_volume_main.py
+++ b/huge_volume_main.py
@@ -1,4 +1,5 @@
 from core.biz.huge_volume import HugeVolume
+from core.biz.huge_volume_chart import HugeVolumeChart
 from core.db.db_market_data import DBMarketData
 from core.db.db_huge_volume_data import DBHugeVolumeData
 from core.utils import timestamp_to_datetime, transform_date_time_to_timestamp
@@ -35,7 +36,9 @@ class HugeVolumeMain:
         self.output_folder = "./output/huge_volume_statistics/"
         os.makedirs(self.output_folder, exist_ok=True)
 
-    def batch_initial_detect_volume_spike(self, window_size: int = 50, start: str = None):
+    def batch_initial_detect_volume_spike(
+        self, window_size: int = 50, start: str = None
+    ):
         for symbol in self.market_data_main.symbols:
             for bar in self.market_data_main.bars:
                 if start is None:
@@ -43,7 +46,12 @@ class HugeVolumeMain:
                         "initial_date", "2025-05-01 00:00:00"
                     )
                 data = self.detect_volume_spike(
-                    symbol, bar, window_size, start, only_output_huge_volume=False, is_update=False
+                    symbol,
+                    bar,
+                    window_size,
+                    start,
+                    only_output_huge_volume=False,
+                    is_update=False,
                 )
                 if data is not None and len(data) > 0:
                     logging.info(f"此次初始化巨量交易数据: {len(data)}条")
@@ -66,16 +74,22 @@ class HugeVolumeMain:
             )
         if end is None:
             end = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-        logging.info(f"开始处理巨量交易数据: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}")
+        logging.info(
+            f"开始处理巨量交易数据: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}"
+        )
         data = self.db_market_data.query_market_data_by_symbol_bar(
             symbol, bar, start, end
         )
         if data is None:
-            logging.warning(f"获取行情数据失败: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}")
+            logging.warning(
+                f"获取行情数据失败: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}"
+            )
             return None
         else:
             if len(data) == 0:
-                logging.warning(f"获取行情数据为空: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}")
+                logging.warning(
+                    f"获取行情数据为空: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}"
+                )
                 return None
             else:
                 if isinstance(data, list):
@@ -93,10 +107,8 @@ class HugeVolumeMain:
         if data is not None:
             if is_update:
                 for index, row in data.iterrows():
-                    exist_huge_volume_data = (
-                        self.db_huge_volume_data.query_data_by_symbol_bar_window_size_timestamp(
-                            symbol, bar, window_size, row["timestamp"]
-                        )
+                    exist_huge_volume_data = self.db_huge_volume_data.query_data_by_symbol_bar_window_size_timestamp(
+                        symbol, bar, window_size, row["timestamp"]
                     )
                     if exist_huge_volume_data is not None:
                         # remove the exist_huge_volume_data from data
@@ -152,7 +164,9 @@ class HugeVolumeMain:
                 else:
                     logging.info(f"此次更新巨量交易数据为空")
         except Exception as e:
-            logging.error(f"更新巨量交易数据失败: {symbol} {bar} 窗口大小: {window_size} 从 {earliest_date_time} 到 {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}: {e}")
+            logging.error(
+                f"更新巨量交易数据失败: {symbol} {bar} 窗口大小: {window_size} 从 {earliest_date_time} 到 {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}: {e}"
+            )
 
     def get_seconds_by_bar(self, bar: str):
         """
@@ -214,26 +228,29 @@ class HugeVolumeMain:
         if end is None:
             end = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
         periods_text = ", ".join([str(period) for period in periods])
-        logging.info(f"开始计算巨量出现后，之后{periods_text}个周期，上涨或下跌的比例: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}")
+        logging.info(
+            f"开始计算巨量出现后，之后{periods_text}个周期，上涨或下跌的比例: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}"
+        )
         volume_statistics_data = (
             self.db_huge_volume_data.query_huge_volume_data_by_symbol_bar_window_size(
                 symbol, bar, window_size, start, end
             )
         )
         if volume_statistics_data is None or len(volume_statistics_data) == 0:
-            logging.warning(f"获取巨量交易数据为空: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}")
+            logging.warning(
+                f"获取巨量交易数据为空: {symbol} {bar} 窗口大小: {window_size} 从 {start} 到 {end}"
+            )
             return None
         else:
             if isinstance(volume_statistics_data, list):
                 volume_statistics_data = pd.DataFrame(volume_statistics_data)
             elif isinstance(volume_statistics_data, dict):
                 volume_statistics_data = pd.DataFrame([volume_statistics_data])
-        if (
-            volume_statistics_data is not None
-            and len(volume_statistics_data) > 0
-        ):
+        if volume_statistics_data is not None and len(volume_statistics_data) > 0:
             # 根据timestamp排序
-            volume_statistics_data = volume_statistics_data.sort_values(by="timestamp", ascending=True)
+            volume_statistics_data = volume_statistics_data.sort_values(
+                by="timestamp", ascending=True
+            )
             volume_statistics_data["window_size"] = window_size
             volume_statistics_data = volume_statistics_data[
                 [
@@ -279,7 +296,11 @@ class HugeVolumeMain:
         huge_volume_data_list = []
         result_data_list = []
         window_size_list = WINDOW_SIZE.get("window_sizes", None)
-        if window_size_list is None or not isinstance(window_size_list, list) or len(window_size_list) == 0:
+        if (
+            window_size_list is None
+            or not isinstance(window_size_list, list)
+            or len(window_size_list) == 0
+        ):
             window_size_list = [50, 80, 100, 120]
 
         for symbol in self.market_data_main.symbols:
@@ -296,14 +317,14 @@ class HugeVolumeMain:
             total_huge_volume_data = total_huge_volume_data.reset_index(drop=True)
             total_result_data = total_result_data.reset_index(drop=True)
             current_date = datetime.now().strftime("%Y%m%d%H%M%S")
-            file_name = (
-                f"next_periods_rise_or_fall_{current_date}.xlsx"
-            )
+            file_name = f"next_periods_rise_or_fall_{current_date}.xlsx"
             try:
                 with pd.ExcelWriter(
                     os.path.join(self.output_folder, file_name)
                 ) as writer:
-                    total_huge_volume_data.to_excel(writer, sheet_name="details", index=False)
+                    total_huge_volume_data.to_excel(
+                        writer, sheet_name="details", index=False
+                    )
                     total_result_data.to_excel(
                         writer, sheet_name="next_periods_statistics", index=False
                     )
@@ -311,10 +332,29 @@ class HugeVolumeMain:
                 logging.error(f"导出Excel文件失败: {e}")
         return total_huge_volume_data, total_result_data
 
+    def plot_huge_volume_data(
+        self,
+        data_file_path: str,
+        sheet_name: str = "next_periods_statistics",
+        output_folder: str = "./output/huge_volume_statistics/",
+    ):
+        os.makedirs(output_folder, exist_ok=True)
+        huge_volume_data = pd.read_excel(data_file_path, sheet_name=sheet_name)
+        huge_volume_chart = HugeVolumeChart(huge_volume_data)
+        include_heatmap = True
+        include_line = False
+        huge_volume_chart.plot_entrance(
+            include_heatmap=include_heatmap, include_line=include_line
+        )
+
 
 def batch_initial_detect_volume_spike(threshold: float = 2.0):
     window_sizes = WINDOW_SIZE.get("window_sizes", None)
-    if window_sizes is None or not isinstance(window_sizes, list) or len(window_sizes) == 0:
+    if (
+        window_sizes is None
+        or not isinstance(window_sizes, list)
+        or len(window_sizes) == 0
+    ):
         window_sizes = [50, 80, 100, 120]
     huge_volume_main = HugeVolumeMain(threshold)
     for window_size in window_sizes:
@@ -326,7 +366,11 @@ def batch_initial_detect_volume_spike(threshold: float = 2.0):
 
 def batch_update_volume_spike(threshold: float = 2.0):
     window_sizes = WINDOW_SIZE.get("window_sizes", None)
-    if window_sizes is None or not isinstance(window_sizes, list) or len(window_sizes) == 0:
+    if (
+        window_sizes is None
+        or not isinstance(window_sizes, list)
+        or len(window_sizes) == 0
+    ):
         window_sizes = [50, 80, 100, 120]
     huge_volume_main = HugeVolumeMain(threshold)
     for window_size in window_sizes:
@@ -337,4 +381,12 @@ if __name__ == "__main__":
     # batch_initial_detect_volume_spike(threshold=2.0)
     # batch_update_volume_spike(threshold=2.0)
     huge_volume_main = HugeVolumeMain(threshold=2.0)
-    huge_volume_main.batch_next_periods_rise_or_fall(output_excel=True)
+    # huge_volume_main.batch_next_periods_rise_or_fall(output_excel=True)
+    data_file_path = "./output/huge_volume_statistics/next_periods_rise_or_fall_stat_20250731200304.xlsx"
+    sheet_name = "next_periods_statistics"
+    output_folder = "./output/huge_volume_statistics/"
+    huge_volume_main.plot_huge_volume_data(
+        data_file_path=data_file_path,
+        sheet_name=sheet_name,
+        output_folder=output_folder,
+    )
diff --git a/requirements.txt b/requirements.txt
index 9b4c77c..4e58085 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -4,3 +4,4 @@ requests>=2.25.0
 sqlalchemy >= 2.0.41
 pymysql >= 1.1.1
 wechatpy >= 1.8.18
+seaborn >= 0.13.2
\ No newline at end of file
diff --git a/sql/query/sql_playground.sql b/sql/query/sql_playground.sql
index 558dfac..f57bcc7 100644
--- a/sql/query/sql_playground.sql
+++ b/sql/query/sql_playground.sql
@@ -1,18 +1,18 @@
 select * from crypto_market_data
-WHERE symbol='XCH-USDT-SWAP' and bar='5m' #and date_time > '2025-07-01'
+WHERE symbol='XCH-USDT' and bar='5m' #and date_time > '2025-07-01'
 order by timestamp desc;
 
 delete FROM crypto_market_data where symbol != 'XCH-USDT';
 
 select * from crypto_trade_data
-where symbol='BTC-USDT'
+where symbol='XCH-USDT'
 order by ts desc;
 
 select count(1) from crypto_trade_data;
 
 select * from crypto_huge_volume
-WHERE symbol='XCH-USDT' and bar='5m' and date_time > '2025-07-26'
-order by timestamp desc;
+WHERE symbol='XCH-USDT' and bar='5m' and window_size = 80 and date_time > '2025-07-26'
+order by timestamp;
 
 select * from crypto_huge_volume
 WHERE symbol='XCH-USDT-SWAP' and bar='5m' and date_time > '2025-07-26'