From 13481c00f13fa3c73e88365cf02dce3279951808 Mon Sep 17 00:00:00 2001
From: Lxy <windsdreaming@163.com>
Date: Thu, 12 Mar 2026 00:03:25 +0800
Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E5=9F=BA=E7=A1=80k=E7=BA=BF?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=8E=B7=E5=8F=96=E6=88=90=E5=8A=9F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../amazingdata_adapter.cpython-311.pyc       | Bin 58195 -> 59254 bytes
 app/adapters/amazingdata_adapter.py           |  23 +++++++++++++++---
 .../__pycache__/stock_service.cpython-311.pyc | Bin 13122 -> 13378 bytes
 app/services/stock_service.py                 |  22 ++++++++---------
 4 files changed, 29 insertions(+), 16 deletions(-)

diff --git a/app/adapters/__pycache__/amazingdata_adapter.cpython-311.pyc b/app/adapters/__pycache__/amazingdata_adapter.cpython-311.pyc
index 155d636c7c70cd857206b94817ec4fc45fdd2110..09aca4c805acc69c7de62f50e0ff983e8354e77c 100644
GIT binary patch
delta 4827
zcma)A3s6&68ouX-L=y7g6_P*_LI_V$eBc97AqW-)iKX;GSA}SzfC%o*MW^&e&^}ar
zkose#wy?CiR!3LuTy3p()NS34Zv#y$%aqo3D{Xg2i?i+4b-UX=C)WUJZKrpVkN^Dd
z^Z)-jxx)wVi~e<0q<meWkWu(So8G8Vo_$04$@I`VB}Hva+L+9LJN*YyIE#o_cpO?z
z3G2<#%^c#CYbfSpPRSu%KuWn)LCP{VY*<8bs(ske!C_}FQx09HD42(^R;@Z<<J#|t
z#cO$BjpL~~Rd)<t!`_6*oY-Jvw+bt30?LlKQE7#<aREL>apB!scr`&S(mM>$m2ZfP
z;36ExCNV|1BOj<2FX*L2aZ&g6qJy?+;v(>761XUg=1wuZl5Ciq$VK9ng^R|R)F}?m
z6jAk3hru0*ztQy}0SZcU6Gh3Kg48#3nCZ!lh5DHalme?~$0Hq1JbEgdHL{!9;hoj`
z+ejpbQiJ2U)g0BWhlEpV_-1x^PSWP2mMBimsMwqlKb$()rXF#U)})|)rfp6lx%u-<
zzn|v{3OmP&;K?<JV>oHI5zu;bWC7(7EuOT9#x>QrwVYO{_~Nm_G2A*fcO-*aQ-J1l
z!Fn#5)3u<jlcW?oC!mA-sAFf3tZL1miq@zq*oQ`VoDPPpG2pct#Ic;NJBf5XAtTtg
zJ1*El&;oUV!PuHy-^wl+aTlxzGpz=@K4`-A!LA+SSBi)=gSLLe+D81;rUqzE?-;ia
z7wI7W3Xj_m6vZ%V0|p^A>#uL%Cpq9f#3xd0S-?L<vE@*dpCh{85>ciw+|5SE1b00C
znz%3~mXkAD&gd|#3?X(*BxmHp923bAS&6^6sqvU2cTDng{3qIN3L2HkoDmOxmj4h;
zA%~z-5?mX6(((A;_aDX?n}-)->^hP-u15~aoxnv8OR(B7O|+tiwah`mr*a86_%zOp
z!-o7cEcTg*XWzIviP5u<lg;=aCABGOQ}S}!G5y(4PF(=ktj39nSl8mn=A=Pa(7d3T
z%?LOM%s9%%gQ17pb5wy6`#A=&g^TGPM~<(FT^umNLyWlCpi3vvml?P(##lXc7bpUb
zL^%)O%@laJML~lTa5L)xCbI=z3>U}6b0#i<GjkR$@lftQ6`n*D<So*cdPG~ZSm{Wb
zj=Z2jj|r|SuC|p!52`j7^9Yre&ySxg7SWAUVdC7eRbOp*b?}u#U!H=&u4iYM8p&;L
z8ti;^G<$I8(ZOwp`$MgzrIiKN^1`ow#7}=%xvjj?TKPzkwXBdK2c{-Gg`)Zub4zU2
zVL@XdSc}HZZTafV3tybvJJ<n(yZ&ezWr!ncNyINsY{U^WOhLw2IA%oHI1}fak+to$
zFAwj!>DfNma!SY%Yef((zy09x^<TH_#w6yF!$P=?`DCMf&%9(rH)X=mywnNH>Ka^5
ztfIgw8K%*$!Uayi4K58<n@l3dx173pV#CdrcQ9kLR)7iL&;JOu!`0&U*blH1#z){o
z0__AoB5)nJl7*-ju3*dr<APRsn5%(dE7#cT8l5h9eL*|^VVPOF&J@Nru$A^oSGApS
z_Djh^AQj8&8thmCr%N*pm$1uznsqUMB}Ayh&N?eyEYnXrSf(9RHm&v(6110qgMb%<
z3pa@Zt4$9JZBkfln@%T7`CYaS8d+dM*~I4WWRxP(8~Mcf91Qr=Bd_quE4=cGK9#y7
z&a1NEPoF+zzr?4{^hgK7)!vxjUzvRVsSC3&&&H(i=?Q0i;fyz&xuG$&HxE&f5tbX8
zgzgGo(p0a8eEKZou3NHuE!ij1dn|=MOJRo;v-XxAZJy+_O!X}IPC_N7?pIt-&F)Rj
zJ~8fmL{Dn5FSWSGT;emAc#8W>WA{6IOp`tHuwqjB{&CmSb9&QrPT0;r+>>terQ3Qe
z3w@S_o&|m8%%e#?=4qbdo6))<ii%r8dzY>fh+!<EAEg6}W}+f2?ogDvlK$3@n1ks7
z!N)_iw_+*LdC0Hn$2G`0vKST+7e#&-MMR2e0dJTRJoEa@iJoFl@eRGfBkeQBd&2JC
z9Z>P%kC@Sz`ADj|L(S*2%eSKve@C!gl$AbPDEt-B`-DAc=~_2>iDN7BNo<UmkFhUn
z7F>QbFJV9);f>_HMYz2j`P4QEM33C<le@igH!pvz6FpXtQap{iG)-2LAi9iVO7x=3
zdNHB1tjVQu)YUkdO)R>a6l0@A*C;Wjy%G85auwa1WsSvue5#1@v0`7c7-PT8?s7TV
zO7^MMPPlRIIDEW92B)83X$nE!4jp8+MZ@hW5?E28LvO+Qiaa8Cuc8ng<)u$f6r*d9
zQ~4zN3SO+-6{*C(Z!U7(m`uzBGSuOaTa}BxhUTj28KGFnND0U=^vfFS9Zsh1shau~
z{mNwx^(<pw##XMvL^bm%{H^MD=oaMK%OXF+e$v7i@=m}|#QGlWv75t)4<?#`8oYKh
z5<%%&E!0;=p_6?4(&aRY=AU<5MQWlFlu{gKK=%PPtXr-|ccFdxMp}m8vzjP=!ip?}
zWZ<k`jN;(E>J&u?R!tKNp=I!WwF9a6MKu*Px&UvkEH3>!Nr}9aF}Dbii!P9;KfB$8
z`!a!x1pZCnHi2&l+{1AHUZ}yF{}F6;I=UXg#3LG5XBz{X>J-SxzgV|{MjFsHJc+Ep
zHk?M&_{ppHh)@+=cdbKDL(dgGoOH=h3GZfU8Z|-7nsmg$!8JDIg8!_Up>vZGts_Ms
zS8i2R)&0(_$MqVER`5-0JBgXLDFd4oHkF}m(9twQBA7v6Q#oql$31;hg#H9k&8=t)
zbTyZvcK%lL8+4d|AO6PNhK6bloZT=9{RRHHp-$qL+y>_}b0lx#d2k&Ddrbm=?HMOR
zJ7M-oy>h9&&R)L^Uy0RDCwm!Mo{xj3=iZNhk!0IJvL)|MCh`b_v>Wr9Oz`Io8rd?t
ztGW_jwQKvZS)W8Ofh8LsMqltpHx|=q6a27weApJ^>Kv(b7ffk=oW>Kfy|q-i4YSi^
zLQlI8D4&bju|*QLhbW&R%3B~}ix%zjPt&^P5?I};KtudvTlR_28u;&aCrXB8ZDUag
zw6zr>74)^Wpo=hY?gSt4f*R>AU>9j3riggjN}z@?Xyzj1?kGnypnXTWFjXQUgNtwp
z^V4_}+zr8b>pId<E97-)cO28g>aH=+)S*L5p}ix|K=Nj`V{nCHm$;3lDpOvbP@IEs
zrz0KZ^7@zV5igpqRKFJ++6tboUpGBWx`9I}&`MtO2O#DL_oN6(z(4lPRKJB^%bBet
zcqZA8kOm%t7%1DDk9P4p_Zo@OvHeN+jpkHE!`agzAUlwV24MVwJjp1V)&qIyEPv_1
zOCkDA*k@V@GoN_<oWNWHvk0_8%i%Iw5(2)%xxc#c&tbxm4Cx?A@i=w|-j+DN<;ao{
zJf@%W6=))4ADb2G@Aw$T1})774VelTd2tCU;2B&%JzPDeL=pVJv3JOZcE2qYaRO$K
zfqQRjGb-=_VvhWz62#rl8}cr$YMLaQ7#!zUo&28&JFGh$DC?oqQ`FBB*#pZeKa+(V
zy!Fg`Bn$DmKo(2R#b+G-?HOF~_jSoRg`|xb9p(GZ^^4GT;LoSx+5Pyu8C`}S&nHSx
zVX2G3^?>fZdibGD&o8@hjifvIN}!>yxwLTWiVWaNWX8XVv$ua!4X)w4DH-*H^-MG`
zzq&XCUoy45Dfp7v(OZH{@M-T1<1gJ!y*NNqB021EwpUJvi1|eyWTNF_5?4fk+~NNF
zmT4eVJ%M~OIco{E3RC^k0y}G;%h*>rnWqVJJps~q<~c&O5dZ=^36SfB=_IfV?)VG^
z`w2<@|H2$5aE!o70{%%oL#THNyiec)hJG>IxVp~CTqcZb1bX?h4_Q>!Op7%)!lQ=7
zgcy=gYVFV%KN(6z#SBUPq>R$U4u$ziIVDqWs@WPpr0_4PpJBd)*IqA|p#gr?XM0ip
Y>L?@|q8^N1UHTor=-XdV@E_^_1J(^NNB{r;

delta 3896
zcmai13s6+&6~6ync9&&=<+TqMSeD)8r5M0h6p1|I1H}gq^DvP_bg=@0^zKC>-UW;r
z9uh^5)znCekBKC~Hh3Gwu^~;Y8B{`m5K$5{I<1a2wnJKDIyF=KpSx^uQ=Hz}{W$;m
zzjOX`&VT-YFZcUoUwkU_Kknz}!_en;erNIPXFL7BndP18$1wHQdYgD}){n9rfe8Ma
z7;c;3FOX1VN{>?`XiBv1kz*qr>D(i`;SpW{ALiCGj1bVKhr>}?S*YCzCS$n49#$=9
z7-!&wq;MB$!5ArsC*z*%5klabjNK#zy~(tCy-jD{`)QUi<tn?;8A!iD<z8+HzMg9(
zk$cnh%CRXhrNt66EJ%wa1{zezOn&OP{}Q8HE|JQEqmC%gb)3Nh(-sDY-_nBd_nOou
zYooO;SP14c{A{-|O*z=psGJCjCaXs(mPRXVwS<5z-Ab%`({$dyV5n=#q7fQ#5F)7B
zBA~F@5;Tu#krl{Sv9xAdr%uqh%2{CZT*Im7pBj&#B+@MldQYB%74&tad8&%xGu#{+
zv7S#IAC*LbCPW{&lAk}W6ZCCX3<o;qX=DaL4=tHGvpw3=xii$$1WDfZ7#9hWrs!-<
zw(=%Ed)%!je~eg>VOYbf$4P?Ga~XSVsSIa1(tMd;I?gMJb<2X0u1YKR9{su=XPC!Q
zVIJ9pVW64+C!3!IK{JW8GJKAE0fyo8!1VMS+1Lij;#{p<>kPNYJ0s}VB&a!~;L8~V
z+U2EQXvhT#;ey&e2~R{R{n9;-pc-HMWJx2nH?^Z}J;ql*Vk@W2K;)GZJL8NLf+l25
zLt4;JG&7|}(S|iOTDfrk8C=r!G*}yK>sWijc5fjV4$X^9j-pJ9eTtwe@pW_Pov_HG
z%_h5N+-(WN84+NbuW?ra#|o!K2x&{e^JeB>bX(A-BZ9%>5^z`U30LKyf4-mFk1TNl
zU6M;jYv{4JZa2vjm`ru)bV8^QA((_n!7NyWsE%oGYiP4*utjqSJ#WoQUNs)5eY!_C
zhIn=(y^>}KWTGoc2+3#SXNoT^l*{7pJfzQvYQ^#uFXv}v<jv=>Gm8Ug$Bw8MELom0
zrmma@g$onH>(1VO_3*7j9VzBYdNDHz=35_Zy;FCPDpSnj$JzM=&Mdu5c0kLrea1mb
z;J!c@LfD7!CBkKxyF7;sz;239!1d)#P?ZBD8q~QpUMhYg5AWnAF1<*ZBP{RWuAty;
zFXW3}cJSN?Yv*0AuA-|Egs%|3M!1GBfM7@XoPr~o0wm{!LV8{%JE|17=e@xaJw!Z{
zTs!K+1nAxf>(|)m=Sp~NyJ9Fju|;)VZ{Als$|wVES8P*`Eqj0JkZoqm(rf1EwzA=v
zCkJDm>{9<RcOYirP|U&sbJmbKt7pc5Ij3dOHA`%}-*DXQ!MNF7Q+fgi;<AV0vIi_n
zhAc~ZDhDhpTC%T&g!UUN`*T(z8g-TZ>m8C*IS{gGC}dN=^btFsO(n`KqSAcFWQq5l
z+ePFw&>3@~Z)Lie_(CgLl$pBNm$~Tcvv{WLqE5FsS#~j5PUTCgjF=@!OmC9UQlqRl
zMYmKd`%EjRa$iiQCC|nVs4|T7&!8<ZpOFvFk>@j_c2zndKSEQl5h@C%k#;y%kWR;c
z->-uQ1xe(vnDA1vob<s<YhNH&;mq0tdLMfB9oQpgGna%#_N9vI6xdT?gg4fj$p{>=
z&r*9)B_~Hvz)icEd;^N27s<D<rYJAyI<<;dbIZ~AM}+(EX^};(Kz0B^ApEn)!aihR
z*=_?Qt_vdXiJ9xxu_QozXMG>hBgZ2GJylf4(Fj7|NJ$8}1E)*si9$>(%_2kr4I2uG
zFWlM?>&H-Dyxg_00*qyL!icqHD_PP5S2t$o-o{wc5WYnSq~H!yitQk3-$b~8@IAs^
zgufx&r!dy0#pOKrfDYkdk&cu=b43Eth-WHZWl1okI$j`C;eex?#EH-HM`a`z{#{k0
zsKOMYAmf}Ku2uPvr^L2bSe9&pqt%nxR|vdcrG>v#&n9*-ZAl5;Ovzj|1qa^Mt5>fc
z+X*N9a?51$yx6*>6>aC#B)DyBYEnrJoUKVwxNPA;%?eT~=G5Mlk+)#xwkA>!A8%Vm
zc8CGnJ6W}qkhDK{q4%{#<P_-YHz*|SU1+F(nj9B<>vs~e2MW8x{nr$3C@fz~Pv`og
zBK|{owef~=FGjczBgEehGd`|n*$>X9XmSCLHeFG;NU(KhF8NaYVrMo>wnOBuC)D+5
z{3mM19faq1J;(loh0a~e{2Qq{-p93j2MHuM>LzhJko6nne}ocRI`9<<YhtFK^mNy<
zKr3T_*LMYz8{+2OZ_5Y=W+<Y!z-us>FmMvGC_aEXa$)a<E^+#=v?R2Lx`~%@S?ISJ
zp%@h`cR@NV!u}L88BXt?<Z3FJE36Cj;H)4<@#zEq@}kM49*QTgL2i!$Y7WgJ`EdGB
zx&pJ{nrN}LO71w7tD~h&PipmNlVlLMJy^_dy@kdpN8%*oBuHvi!oed3;so)?qYhZ^
zU93OOE6X?X#cPXJi77_`jr)$rj;-w9o~mu9FC|<9E}V#o{1k!?D%&$jgV@z>LZji1
z=rJShi8=Jl=bm_EH65Hdk<NCyLS%ot!z+9{br|o(Ek>6&5EdZdyB_CCTG(%ZjbZ@&
z`D76LgA9H+ndXr_+Em9%*;AHk7=!GjK7o|$#J9w?UbH9Ku9d_BtGb>djc~BbMl~OG
zX%%NFYpib0Zl$-QvaGC-+svLk^9M}h!w=nsb9VcIwL3_=m>v@jU&()#zn0~?X$9jI
zlaSCUwsikTMjh<_#9h44KbfJe!np~Hmw0YE`;3>gXRn<59WEW$<63&T_VDAEJTGn9
z?H)fx9g;f42R$P)dIeqXjiXKYu-BsK!Td~8W#)dSBpu>{&ot=%*#Y+kov$)Lz@QJD
z8VJ(<6}@~gL3T>+5;}6-DwNG$as`_>Sl~skhu1I1y03>zmuD&h=}C1Yz?^L+h#uCP
z9(Tv|p-U^q=3iP}{c^FxQHh8DdoQteIFZy6jN>8p0A9+{9m<uWRDzI+6AqNhs5GLQ
zSI8GG;0nu%IK2NjCxQ|=TT$AHup40y!hVEbBLIRPdHCDTtw+Frm$+%tX+4J1c(%BA
z5#C2Qg>VBo*gRY}!Y2slDU8VZ%8Cs|9M)Z`8P_LPUgb$%1uNHI4+tKWqcEyqw1!co
zBziN!x>1!R`Y?Lqs9F+z86W?K;^xRvKWWJP58CD8oUc~+kgH<L&0{39Fqrs^G81Ee
P=%nwYse6whNWJ`DIOi6C

diff --git a/app/adapters/amazingdata_adapter.py b/app/adapters/amazingdata_adapter.py
index 9694dfa..a796bbb 100644
--- a/app/adapters/amazingdata_adapter.py
+++ b/app/adapters/amazingdata_adapter.py
@@ -295,14 +295,27 @@ class AmazingDataAdapter(DataSourceAdapter):
                 local_path=self.config.local_path,
                 is_local=self.config.use_local_cache
             )
+            print(f"[amazingdata_adapter _fetch_klines_sync]股本结构: {equity_dict}")
             if symbol in equity_dict:
                 equity_df = equity_dict[symbol]
-                # 获取最新的股本数据
+                print(f"[amazingdata_adapter _fetch_klines_sync]获取到 {len(equity_df)} 条股本结构数据")
+                # 获取最近交易日的 TOT_A_SHARE 作为总股本
                 if not equity_df.empty:
+                    # 按日期排序，获取最新数据
+                    if 'ANN_DATE' in equity_df.columns:
+                        equity_df = equity_df.sort_values('ANN_DATE')
                     latest_equity = equity_df.iloc[-1]
-                    tot_share = float(latest_equity.get('TOT_SHARE', 0)) * 10000  # 万股转股
-                    float_share = float(latest_equity.get('FLOAT_SHARE', 0)) * 10000  # 万股转股
-                    print(f"[amazingdata_adapter _fetch_klines_sync]总股本: {tot_share}, 流通股: {float_share}")
+                    
+                    # 获取 TOT_A_SHARE（A股总股本）
+                    tot_a_share = float(latest_equity.get('TOT_A_SHARE', 0))
+                    tot_share = tot_a_share * 10000  # 万股转股
+                    
+                    # 流通股使用 FLOAT_A_SHARE（流通A股）
+                    float_a_share = float(latest_equity.get('FLOAT_A_SHARE', 0))
+                    float_share = float_a_share * 10000  # 万股转股
+                    
+                    print(f"[amazingdata_adapter _fetch_klines_sync]最近交易日 TOT_A_SHARE: {tot_a_share} 万股, FLOAT_A_SHARE: {float_a_share} 万股")
+                    print(f"[amazingdata_adapter _fetch_klines_sync]换算后总股本: {tot_share} 股, 流通股: {float_share} 股")
                 else:
                     tot_share = 0
                     float_share = 0
@@ -377,8 +390,10 @@ class AmazingDataAdapter(DataSourceAdapter):
             # ============================================
             # 4.2 计算市值
             # ============================================
+            print(f"[amazingdata_adapter _fetch_klines_sync]close: {close}, 总股本: {tot_share}, 流通股本: {float_share}")
             total_market_cap = close * tot_share if tot_share > 0 and close > 0 else None
             float_market_cap = close * float_share if float_share > 0 and close > 0 else None
+            print(f"[amazingdata_adapter _fetch_klines_sync]总市值: {total_market_cap}, 流通市值: {float_market_cap}")
             
             # ============================================
             # 4.3 计算可交易日数
diff --git a/app/services/__pycache__/stock_service.cpython-311.pyc b/app/services/__pycache__/stock_service.cpython-311.pyc
index cdeff30a091b7c0246c4c4f109d98fc7256fd2eb..2ce52d32b2bc7366fd5d276529512a49031c4b7b 100644
GIT binary patch
delta 1401
zcmaKsZD?Cn7{~9^<ldxdlHN3(X-LyGjcJy~%%yZKPG?%%!e+Z}S}W8SLQAtQU6#yq
zGl!7cuD(rORd#d}8CVpm;20a%4<e$lFT)SQHi|13CJ26*_$8Ae!%v?7z0H{O<-q-&
z=j}evInO!wUfh52fcG<x$0doe_U?uJrT7K!*LM0t|K3jItw?hUJQynuK9CBGI4w<*
zDl}JrN3N^bgl=YmZB>?}FT`VwdATBMv*kcdm!uhoh<5T{<OsQum7Kgy+3Ap3q#~_&
zV43*$I`XPbWEPJ#2&=eLwcJ{>OVV6pO+IKwo0-*(S}RJtF<SGRJ8|+Kl?cW7ZDo!8
z{0B!Wf?S4cHdoFbEaZzhjm3q5Z2=NM;H0yq*=WjYQ!nN=LbByjc4nG)I2Y*+{;Bi5
zKBwf{^nT+twd<<dweD^_@i?$+-R%>zso!i+e6CxPz;U_SB&nOKl2Sj+2kSFi6jLM5
zFs-Z2*VOn`HU7Entn2*Xm%F~oT~UYD)S=7jP*u@ish@OEKfkVybw7fI?F1eLGQa@v
zn1JCBo0%$?nPDrIjxwAE+s>c&&4hb}sCfk1?;flT5o!LDFGd5py~!`rIByAb(!8Dt
z{7K4oxF>lg7^7Z3<@C#}TUhvsV1(Y*&jov^YgFh7I}0Pw>|PSmQ31^^fMQmW9_|ip
zrqlWZp&fO~Jc3^4h46vq%0ELF_>FKIeWE+sT=s^C5V`|+n74LJ&<JN8BlqutVNAfV
zu_HzHB-HzWy}&-;3I213f1zK9hHL8Z;jM>CGr5AsUWM;9U;=m@etG<<y@Mm{I1FzB
zZvj^KAWaG+T-GL^f#F%;IRV41y>w{0RM4{d;{MWI$(P_HEyT>m<NBf%*036~$lr;k
z=sW$J=nbMJo(To@Z(|{%GB-N=o?b?UlYn_i-R2eCsCCcE%#GL10ClbR%));^gJXO)
z9;09N<@m5I_yHo(v#|sj4wlo76v|pcWlQ|GuCUSv?*#WITWFHUlbc&l!+;YuTw1<3
zTgYWu?ge%V)?PlH+)cmhXOr<dI>XmeQBwKsRB6sk@*zT+0Q@YNA4mh^0PYj>0X+cz
zHVoZj3&0|93}^t{z()YSe5L|tfKh&B>z-(*?7G~Zu1aD)pEsv_u}>d(@DwR4cxQ}X
q-?ojGxi|eWjq-Ep7FyLWrMqc&znzAuD*g9#)AHT=pAgnAO8f<l=rMu-

delta 1213
zcmaKrO-vML7{}*<ogG+rmu0u;3M(I3aCghH;)=1NmHKr6WUT><aG5OK0Tz~Bd}pv}
ziUP4sZGuhP$Bz&Wc+hw;Ml&~KOzNfSO%qR>cxZYtu}!v#2jZ#opM`|l=zI9R&paRh
zXWr+Xc{=%Y+<VvKaY@!1I{Pr2jz080a?q&xyMw5HLb@o=%lZk!gLrvmlzEy`xZBx6
zReUtDgA^V}H1oRb=3CC%4w|yHkZWw;D6zIF_oh8v2}`uhOSe25^@o*6&92S3B-#2U
zxz4jytBJ2EFUZH)s*dOm2t+It1M0YDd^xF(i^7bW&ZK7zO^7JMF$?@>)gm3_O!ZH`
zpi~>UBA1+!udXCjR1b5ztB1ViFRl@Vj__Z#sbn{*4grUOPk|obGYds!LNn5aA&Qmx
z!dJq6fqk6wXQ+#x`x~f}|Ms`haWfDI$aIDy!QHfArh;$DxepS<oT_h&c3GzGw9srX
z(FkF`s;4h#>U1uf*L2k=sF^Wdu5Y2M=KcCE`nb=^i8%zOW1m>G!@6KWcUXXsts|1`
z4mHt=84q<=IOmack#micAAR%x)Jy!Tv5{_@N|Vd6?Eq3g0S<B~e3p7yg!^0j;W%ZX
zSSjZ6;&VLWHpKvt0#5TE;lRQX%PhLmv$KhrLPpE!;xc020)xPJh|7aRr;qoG@8P%t
z`~Z}P2y56v%vC<*IXFguQ42-4{`JgQA*ZX^{CHuD_!5GoHwb&E_~bB(@+uExfq!i6
zpkK|$t*?ldxF@vJe6qWNNN_Q7;EQE+_!$U6$!%Z4Mz43?%s%+$9iVTy&TjnQJ6Pn2
zXdAsYuSQQ+?!1Of%q$h7q9QbXE@$X5pIGA8?Yo@&5glZ2JV?VFi8qCAz+r#WE<Kx{
z$Z4w3&Wr2tcJWxem)@B7;*knk<rj%C`FTB2n6gD~BE=8LKmh0j&H!^jEszAN0ZdC=
z0v3QpU>kscRIC6sfDc#&`uO>tfpAoIJ!{@ulC1qf*52O5ka@K8207PIbBbT??WAS)
kCfBHs?<a$F$NVjsq~2o=I!Ptz{o6m~*qaZeh-RzBzc8Z=hyVZp

diff --git a/app/services/stock_service.py b/app/services/stock_service.py
index 45b5f74..3db2885 100644
--- a/app/services/stock_service.py
+++ b/app/services/stock_service.py
@@ -32,25 +32,23 @@ class StockService:
         except ValueError as e:
             raise ValueError(f"Invalid date format: {e}")
         
-        # todo 暂时不从数据库获取，后期放开
         # 获取K线数据（从数据库）
-        # items = self.repository.get_klines(
-        #     req.symbol,
-        #     req.freq,
-        #     start,
-        #     end,
-        #     req.adjust
-        # )
-        items = []  # 先不从数据库获取，直接从适配器获取
+        items = self.repository.get_klines(
+            req.symbol,
+            req.freq,
+            start,
+            end,
+            req.adjust
+        )
         
         # 如果数据库没有数据，尝试从适配器获取
         if not items:
             info(f"No data in DB for {req.symbol}, fetching from adapter...")
             items = self._fetch_from_adapter(req.symbol, req.start, req.end, req.freq)
             
-            # # 保存到数据库
-            # if items:
-            #     self._save_klines_to_db(req.symbol, req.freq, items)
+            # 保存到数据库
+            if items:
+                self._save_klines_to_db(req.symbol, req.freq, items)
         
         # 处理复权（简化实现，实际需要复权系数表）
         if req.adjust != AdjustType.NONE: