From 4958b031c280a35329fe75eee0ded80eb03daf7f Mon Sep 17 00:00:00 2001
From: aaron <>
Date: Sun, 27 Apr 2025 15:18:17 +0800
Subject: [PATCH] add token log

---
 .../__pycache__/crypto_agent.cpython-313.pyc  | Bin 22051 -> 24368 bytes
 cryptoai/agents/crypto_agent.py               |  43 ++++
 .../__pycache__/deepseek_api.cpython-313.pyc  | Bin 10614 -> 17149 bytes
 cryptoai/api/deepseek_api.py                  | 186 +++++++++++++++--
 cryptoai/config/config.yaml                   |  10 +-
 cryptoai/utils/token_usage.py                 | 194 ++++++++++++++++++
 6 files changed, 415 insertions(+), 18 deletions(-)
 create mode 100644 cryptoai/utils/token_usage.py

diff --git a/cryptoai/agents/__pycache__/crypto_agent.cpython-313.pyc b/cryptoai/agents/__pycache__/crypto_agent.cpython-313.pyc
index 57a923d375c0da289edf152ded8255428a1aa4cf..6900ef4ab2e4d6f7c0324ae46210f95de4664408 100644
GIT binary patch
delta 2543
zcmah~drVu`89&$8Z>}HM7rz4LngGV3ab7%9o}m~6h5*gQO$nYX8Vn;P7+sq-LERj+
zOM|9GX>yuTT1^m5lN_mPSWq|Grq4_fe^vJmXQoz`MJgubk7=w)wJQB*=Un52Xi;}0
ze?Is7e&6r=&i9?i@82ipKO?mFH5xTQqv#vW&;2j_QClmiS|<Rw2m*j3SinhGf+JZ8
zCuQxdG$5;xureDsCOt-Qa<-6_2V|@wpkS2&C2X?N5K1}-JNyT7vcrAkr>zWY!D!CJ
zI#_GK%qm&3Ldx1U87!jzwg4571vC{B8A<~&nJeUMzUXCT3pm>_=_*>-DLrz4@GVSv
zloApgDu52T4W9Kn2sgaqeV4cleXVxlAslH95IT6HwJR@W42DjOhq-7l8h$x67MzF-
z42K}yc7nJI&$fNtyCDZEO;X7SN+zK!x}!5qY5$W8wAD8?RSzQ+%Hw*T*+Y|mq1B!u
z#Zgp`M?;QgB>LU|6_OW$9rR~S&{3TSck0z}y^^L_qH@z~jDVLL?C`f$G~Cr_f{ahD
zWywlO#%oN{FNfEv>}tP+m9nyDB@D=-O-Lp86I#G3_C3avqWSw4lOfArwi$nLH`FOC
zaKS>ud!`(R)Gy6i2DAY5o3m-MO21SK_DNu!uMB7PIF4#d92v}2m@t{fFJsl&bQ!2u
zm|>wjKQ<=c!kClIh1nX1^2=Eb?kSG;RD>2GbU%sEBSh{~5V6P0F(8QXDUinq8X@v9
zf;H&?YeuWwYz+g3tq#y{%a%p~1}p%KDYh)l;#WMGej#A3V~SXlV%Ul&O^P962-K5>
zV2E(pCUD8s=_}XLXFg^;q0l%R3cbuU^|UkMHe^;m{rv9R@wGQjr{DZgJt;5gD>+^=
z$l**=Ia@YrFPFlqyg|eeK@3|ragh5vvc)FcNdBJ)=|5l1q>`SR|JSv5C#CMAkylbA
z5)(x~<$d>)+4T=DA&&_og6(A1PJOaI{{~L{{Yz^X=WCc$PAnRZ4vYqm4vdaQCUjYp
zxP%OX$^b-77P0;rOrQRPs6rgZ3}T!MA0OX5rdxq$KF$Koo3RjXG!z{PkD+qJ(4me@
zn8d*8j~3FuJF|A>97->fCt^1byb|Kjna`9i5*!b4Vz!f{d+*SsBGZq^L@{F6Y?m1B
zi4Ltz{|WW+-rF-ZOqWZ`DG-)x!NLn-NPdf_t5~G5z^&)jkVwfxCq^RC2!~sgGW_p7
z#O=j~yy4Ijw^J|@9Y9W3kj<s!DltSB4G#{SOzFhbGIv;TaD+>#j>RIV3_~NMp_C@W
z9~#VjDp7YcGg*f3Dk6#~kzh6lSB*ZndzinlnL9Zi4L1#k#-i@0T$taXa}t3_oB|ul
zd{x6Loj=`qp%Zo`V|2Mdm&e<d>B^~=TXtr4cxHHZbY?VOku0wj%4-+9gz}E1pDo+_
zr@C)Z+H)Ph?s!KxU;J09devf^Rm>=6sTpc6$nQV66k0mW_xABsN0u%9Q|%ArfHqB6
zpRb;7INvbmN*bRLjL)nv#Ytw5!0bsf9)a<E(YG99y5G{=HZr$pE1&OMs$bg0+m0mY
ze&lYkO}~2n)#=yHzc$y+S9dP?ms)xDFkkuNvbk@nZH3Y&sRDs2NK(56YWKWlu`)q5
zq30manxsnvx+F>03Uuu<U60m9<??h@g4!=moN-zFxKLKdJL`EvtRX=)BK2F{b1iYV
zQ2Z>vy@of`CaAhiCBLIlC_cb%Z{iKlC8*{{+Ge5H!*6fl4c-LRD)R1#SMqy&xLnQr
zjvl_}FmHJACe`=Ds?KsB5UK_dw0|*ok>m|^Nvd9;>VMoQB9Y}`1l?BPb+64^0B#hh
zy^Z7zr`B6T-l&nGIh<@~h+FWz_A;3R06&0^2Ks_e15dk+7kp~C*6xJ8avC~(rAoX#
z@PJ>)^WdOwn+Cst;y^c|9sb5=gRi?y$jeX&hE@IOIeBEQgNwcrg>no%H;0VkvwX^J
zLCC8eRzjl|cRKe^gy!x+M`uT_1Z^fxiUr=6oQi<I=&Y`y(Q6o4L5fr0fflH=ytX2t
ztlW@VRL<Kv^NOBM>Yak#nb5oL;CY##FT1JV0dIG{z>q2@E|8%tLAmbW-WCf~@!zOY
zv3fF<6Sf`9Kaijtk8DY*RG><K+{i)3hmq|l=vik|BlxgMjpUb&CC%mJSEVW}ckOL1
zC9jvtn#&j7Irxo4q9I_Ur<<r=xZbmepd?%!^6hdFUe`AG!}I6NnN=cPO8QbbJj&(Z
zRq6;hbEty&VBzaSFA;8=%sl6b8{<dgmP=g^0Q!8epOH2E+e0{H&N<HpK!5YS-{Zdx
zF98qtx`}V$o4wEJ<(TU(;^uIxxK+5)d)a2g%IEPnKG7*<-SP0?#Av92bHVrgCw0G6
L64vhkmLllC{e<Xd

delta 711
zcmXX^TS!z<6g}rY=H9D!?mT?V%W-s~bR?8?8X*aC7*rA_oZ|>OSH%}T8Wis}(CDMj
zenM)~Pd^zEP0)ureMJwlK1CFK7xo~3Bx+1ew4ctk_Q%@$Y}Q(vv(K4+jUPS3%AVPr
zg=nnKn+Fon8Ks5^ZDEA&Ar)zuAdMkdV+o^i#7j7p4>E*zqakhxYbH`iOe#+VRUo1&
zLaj3wfN8{D_(VlssA6AT^bx0;Pej57IpX@SbDXH$s;u&=ImqyIIMwF|O~hj`G$$$0
zT>WgIC|%99UBYGQyAhFr7j=cW5H{-W7X|R9*f&0?k9Ce*-L!QLcO@tELA_J!)2}7R
z^v>%5^(s~%Qy&G=Fpf81zG1=l*^+-tIm|{%^@=%ktjl!hyF5pPW8ZUG5xW38O-1+y
zWXDPc8$xjuV_}qc!&oeUIoK6*U?z43W-ohTKj!(jFJor{>QbP9xa~gFFC`4mlc4Rh
zFhEWV!Y~)-Vm8Any+Axzl(b69(01T=bEECMQT{Ms)_^?(v3PaaPr7{lIc?lT`wEhj
zMJ2c_p3iW0$-iZBtXp%}tR+j<k`-$J-o#sau~ha^wk_IASLMJri*paLlHX|LmZwHj
zJ&X3rWx48uT(B<Zt;xP6*|#PaFUiG!G6Llt>!;|P+m6}_^td*Q;@gV6a1A?Wk_@!?
z!y$Gq#D{CrcUm?W<`6-$^$M2LFI&%H4%Y?TaMU(w-=P+pT=&RGQadoNafIMOB8Z=)
zmlNH%#KAkJBB`8IPs;f)x{v5_x6;G=ry?0d({%HJkun#cx4j&H0ca0fGlt2w0ipq4
eVY~e)eS^skC(eOX$ApE5*!7G480^xTDB~|mHpyxL

diff --git a/cryptoai/agents/crypto_agent.py b/cryptoai/agents/crypto_agent.py
index f0394b4..209918d 100644
--- a/cryptoai/agents/crypto_agent.py
+++ b/cryptoai/agents/crypto_agent.py
@@ -490,8 +490,45 @@ class CryptoAgent:
         
         print(f"分析结果已保存到：{results_file}")
         
+        # 导出 DeepSeek API token 使用情况
+        self._export_token_usage()
+        
         return results
     
+    def _export_token_usage(self) -> None:
+        """
+        导出 DeepSeek API token 使用情况
+        """
+        try:
+            # 每天导出一次详细的JSON数据
+            today = datetime.now().strftime("%Y%m%d")
+            token_usage_dir = os.path.join(self.data_config['storage_path'], 'token_usage')
+            os.makedirs(token_usage_dir, exist_ok=True)
+            
+            json_file = os.path.join(token_usage_dir, f"deepseek_token_usage_{today}.json")
+            
+            # 如果文件不存在，导出一次
+            if not os.path.exists(json_file):
+                exported_file = self.deepseek_api.export_token_usage(json_file)
+                if exported_file:
+                    print(f"DeepSeek API token 使用情况已导出到：{exported_file}")
+            
+            # 每次都导出CSV格式的统计数据
+            csv_file = os.path.join(token_usage_dir, f"deepseek_token_usage_{today}.csv")
+            self.deepseek_api.export_token_usage(csv_file, "csv")
+            
+            # 输出当前使用情况统计
+            stats = self.deepseek_api.get_token_usage_stats()
+            print(f"DeepSeek API token 使用统计：")
+            print(f"- 总调用次数: {stats['total_calls']}")
+            print(f"- 总token数: {stats['total_tokens']}")
+            print(f"- 输入token: {stats['total_prompt_tokens']}")
+            print(f"- 输出token: {stats['total_completion_tokens']}")
+            print(f"- 平均每次调用: {stats['average_tokens_per_call']:.2f} tokens")
+            
+        except Exception as e:
+            print(f"导出 token 使用情况时出错: {e}")
+    
     def start_agent(self, run_once: bool = False) -> None:
         """
         启动智能体
@@ -504,6 +541,8 @@ class CryptoAgent:
         try:
             if run_once:
                 self.run_analysis_cycle()
+                # 导出最终的token使用情况
+                self._export_token_usage()
             else:
                 while True:
                     self.run_analysis_cycle()
@@ -515,11 +554,15 @@ class CryptoAgent:
         
         except KeyboardInterrupt:
             print("\n智能体已停止")
+            # 导出最终的token使用情况
+            self._export_token_usage()
         
         except Exception as e:
             print(f"智能体运行时出错: {e}")
             import traceback
             traceback.print_exc()
+            # 发生错误时也尝试导出token使用情况
+            self._export_token_usage()
 
     def send_notifications(self, symbol: str, analysis_data: Dict[str, Any]) -> bool:
         """
diff --git a/cryptoai/api/__pycache__/deepseek_api.cpython-313.pyc b/cryptoai/api/__pycache__/deepseek_api.cpython-313.pyc
index 0905f9738193a5fe49bd4e11400ac24e31bcc7cc..dcf42c5f12202da87988fae19b25f4b655b01c98 100644
GIT binary patch
literal 17149
zcmcJ1X>=1;wr**bW!aYTBpVO1v12R21K40}rhrKpLJYW2;sg?1Vav9NEjcAA3{Coy
z0Wec=AOr~MU~UFXZW5Hf>7ZcfkX~=CcGh}7N)i36SIv5lwc4`HuNEEBd8_Y_etVyz
zl1fH~bl=?aqRzC>Q0MHu&v*9O;`_8T9RtswLTNpU6%b-Vd^FL>_x}eXCmEJuWlu01
z4P~5+q~)9(LirPlbxKaTPQ|I#sX6sJ4X0VB<+LVBo5H0KS{<h&VJerpRo7+|yNQQo
z4CEKY(_)NOKz^Z^iic$kt6U(XX`m>Mmx!@4W<fMsD`!<r3KL^wpq9FTVKocnw1_iw
z%gox_m}oVt1m!A6heuGXaPAV6>m6>7pxw~#ak!keUO~0l+uv*7-B3|wb9Z<geRi|k
zRBfuLa@u0iUi(Y-UP-#o?snU{fpE96({Ar~+wCt{J+2q*POBI5YkFPXW`&?4)dY2y
zi|eyNk3BYLXRn=ecSHwIg0yJj`)nBaNoFg9O90a^;}oo%Q?g|+O)6HoRn?$mRRzp;
z<#rjTX4P9YTUA@N4RRG!XEo9k&}oqlmL~;j>ZE1UDAjB#q0|vdeF9|~)J<$x%cc|R
z)M@#0HiP8r**R<`)S5+Vsv6X67Usiv)7Wx08*+2tAC5`0HC@`5G)}*$LCfYw>t@{Z
ztvC~Tq(?*2FT|dWq&$<&kB&vj7Lc4-q=uNQW@nS!tQo&w1tTdWG}&yCbez-XK*<&p
zs+<Q<l@O}j2T+*^RUTW)8M_VU3L$kBFc}L>wqoPj+gY&U-X?g7nI^~`zw*KOmE)72
zkNo-Sk;%7)$FICG_4V1Q^GCw|SHtgK2@mX_cyBO#{K)Npdwt?JhXswT-(h{hzDrQ`
zxjOB=9f~LqVt@>V>F<xj>m<`|=!K9z?WW$SSOU+<EKF}y)F35i6&6`KQ!i(gHF7A4
zwaBXQuNH)}MhW>!v8^pcL1C&*FXqKV5N3_20-%<tvY2kIImK%QI$e0+SK$kX!$;nh
z&Vo+2g6noS>rC)OKe5>)B?w>IfBX1{q?~+tvuXU=*Dzm`@4P-Sd_Mf%;qc(m$qPQ+
z?%6#aPrtjlwicSH>5PhaO^2(m_N95d4YvONUPp%w^+)Y?x68R(v(j$k?3~Fg->q+P
zIX!l#r+V|Qe!Gyi!t3dAagN=Dn8OJ(D}^kN%VX=c_H(Yjeh*a~ZXu6mLLZ=wuxYVC
zPYZ~CaSN&rTW_zM!%1s3Yq@j?xeRy-+HE$s-Rk9f1x=6L)(Lt>NR{X$K?6#u+u`gM
zQo8M)^$@pnf*SMe9Ox>g+uqw1Z_SMh2(u_GtF^eHsal(jgO7E)yj+Lf+5ucs+rjPX
z_qc41cm(FER-7v<PF(*kL2I=-oDPrGDrAcb0qj~M=H@~-?x*3kmx&k{W62SHD5v0v
zE@WIVpgfXxtFR_i^3c$ZAqQVncSof#>L6DiNoUF{LX}ma!lF=4-klUxA!Ogs8t)pI
zyyCIk%I|V3htq<&3kQ@(Q@@9%86maL#=T(oSUYVVo1o_G9xvzYh%qlvXyG4W`ca6S
zWGqZujL{(@`dDNlOFDtY+hQy(mNSe+9-~kI1&Y$N$D#nik+sDbI$n$-B<@|TvPt2E
z@%29jt)#?h#F!<vKRVSGRaG?G2Ex_;6sxL)v_)OcnAP5W5Cu^o(oZzO#7W=8(a)rE
zBAJ?IQ~1cf@Zi5wr9nwSGQyvp3h(oSVj2JK;qXVVj*ncP7`pnWy{~}InK*so_JL!Q
zpB^M4rE4QI8x=s>?c~UbiTB>sd68eG%1BVVclB*^_5PrSf{AxOo;>&AMY)jTvAJO<
z1<B#cAz#o-cU9QMv#fM4wMs@U6j`@<9lf1mo(=Z&U2cavDqcd06(t7wQBVNq3r1_d
zjRQ%E(Q$Tnzsu>in>8Gw5v~+_PNyAt?441rp~5O?MQTAswt8eIx3|~h#w7)T!G|lt
z7P3eOyY1q*2=kRlg&+yRJgDjB;05xK%M=uk<<AS`&+|PJ%wIN;9#J#1a>p|31DW-{
z)?jAKfEsdUmz=9PQ!||FU&gmRH`ZngwAuJ=+xcEku+4kAhA(*OV8(zpTC*mQSu?yd
zn7L>`{Z}=k&kR*OJh&{NFT0hIGmyrapj$fa89jiIKx@Iok*`nKAaKEmtPDeBCRu5p
zCGxTpB_WBdv}eUAU}H!sD@v3VRvwjwr+_Mn+*njGnbTO*39``5Du^s-Ko*qV!!TSO
z-2f>IPknhfeCTVbEKrt&O@VNB_|jLCpL`TPb~(oSrplF@TP*CV&6R}Tr_B<G&l~&0
z$9^4^G310qiJ+ZJC4vrw=5r6>{No3}4v{A^`m{cT;wZEC!|K?9#qFJdYjLxn{K-86
z^@V~ci%W_{wuLQ&Fgc1BhbWq>!B;K5>hOge$jyhBTMIAz2z;U}9c>Ug!`?ld-PtK5
zuyhiFC$X&#cmYcr2}>^s<S+1b1@l{DEZq>uZ16o5%v^sDOSdBrKO^Dcx<F=~&lt>X
zo{@)z45?^?YzjKg0cwSy@eU=7M0{ebJODW}v$938Aj-f_WYr|hY`K?JlPUk7%BsJE
z;piscIyW&eNLg|6)3+y2e)wNt)oC*VtV%Y8C@+!~j!jXs>Gu0?+&*&=)cWL=3&8x9
zy{;XVb4`_fz--<=jP*FWd#DT~a(KdMiO!eiNH|;(V`L9!>jYF{bwk8s@7|Tb$fB-}
z6((ilB`{swQhfb1HqP(1JMGvTaByPhLWNX6&q%f%`f{`I0+ucyI+-%?==NadGY@9r
z2dm)@Df~bHfIRp8Ly$|j6cW=PR)!1*+&R4f(kwY8&QPYndRt;VJp+{zsYFG4Kbn{V
zhR6(b|3r_~sSLA0#;Rs$k&KR2vl=DCYHJYsq<GiDfOS)ETn-<5do!NQqd<S;+|+01
z$G<*5@yaD#BJWb{BPEMrA00OfTI2BK#bx6w2VV#v9e@4%-~ZlfR!<{9<c$cQV09tS
z_7bpLH?SKH1b~U1BPBw5r`=<7^a92pgl0L1<`Y5DYj>JuL{Gbs5u(~R2hfWY4}r+o
zJZ_;hk!6#R?1MJk@576L?DDFyIrV`#^?bwHz?^lV%16d38v~V%{Gv^P%C=CUX{>N=
zpm6T+^MS%8H)j{0_KcO(21;sunn1~-;OwSQZ~s{Do<Q%O2*dnR_L%%fhUt?%E+6vH
zR{ZIK%GLjK&S>XY>+^xu=Xq;aptU==uIIbT9;mQh{-iuqTsBr*6DY13-VrEn^eg;I
zzIf@KG>t(QVKgZ^f<jt_lrESS*u^|O9I}4`0KwA^k%zmW%RwGw9k7pWflT@&lYnG8
zTQnghgC48|$ivB2kq#y)iyY3kN~f$CV16<nBDTk>n%f!1)(B&YL3e;Lz@4nNNg-#P
z$_Jf&fy?n&H|>EvCWY0psZB}~oWAi-1W+bswQR$l2aHOOqgpMq!JAD3lb_b9nl`?4
z7-2?}5=UrJwIQ=ldlHTv>NXUDX%C$94Vz-eBok_YBwxa2qBhB5*1XFwP5^DmTC!-`
z@}@NoNp=>SE`Ie46j=|X$bKM2&I2iO*|Z0YBkzF}#s^a5$0=&HqV_d0Prk=6sSM0+
z(wVD`>FJp$*n%zj;@sYEg~T3#`)AiH*mV4xfxZw|bcV8``;-~6j7^t*-E`jGkg;X9
zI9j$CrI0PDSBPV?gB>cF5xK2ItP>Ae6SYx^bzy#F<xD9vml1cZPEfa9auZVmvuk2n
zYnCcXm@e6UD3*&9TTEg<8pif8@U@mLwP?{I=1iGkgmc6i@z9bIA6p4Xxl_AB+nr9s
zE?E~tdo!1LuR<MN_|nzzfh&^Tjh;Nh1HOs34~&m|DaDI1ecEiIg;SR=g@5}xpgTCy
z!wG%df2Gysw1)@IOda?*d}x@WPjbwmCt-k$q&qnKhp!%kdJ}J5nmF=GCEC9#CkEcG
z>~O!73=&3bkpaPmO1ssy?oO+CrlPN+(^|2n;>ikD$mvXCN4E;H8bOIY2(lf!RbEe5
z^&+!O(Au3~fdbHY8@J%c&2mBQaCU;tP0+*k>gC{U@9uEGaUX_6c4>hD8jaJwqt^kz
zZzEJPYr)n4rheE$`}#RNC6bdbwWOsb8s;+ZG071SAQ(Em03z}1<+gXYoSkk83(%T1
ztwj!$F2g;8F9IK)g_svjUlV&r0FIcdrhKn~6>{Q}^RR-=CP8M7;|VX;822Bg(~X8o
zvH;B{FIpM!XgacwmYL{Um|!tXWHr1f1NXAW<zLe^0X~6N%7A7DMw&SFCGgknx6U-1
z%(Db77%;#t*=H9NPS*}W3z)o%Bvo)c09&Hc)o*ult<apH?DWE{8X?MU#<Y3|=kNfD
zmWHk!+*~YMjb*y0Y`tFlV;tw=IFxfi>2P+rgp|j2cG$@cji9n)p;<={uIsQSZmb+m
zv>@vuU2xk-RfJK3%r2ymD%L)Cw;S!uc)p<zJ;%<n@9cMR2}nsOmcpoe%TGcx?oGgN
z#4w}J38WU@G@8bY=77;WW~>evtAobcG2^0uago0yXk0t6HdIjSOBw!!ztsP@e-Uq7
zHLy0KtV_uaW#k;&b8ye$Uk>F4Gb(T9<exSVvA)Ldau)kvyqRr0wf6Yh)14F{`DFgm
z(TeY~H~y$#a+d^h7T?OuJ5~5*;fdm*1vfIQ{%9x|k5(`9@Axif_2|4%k?GvCXPzCF
zoqcZb@mtvir#8H~;V+D`BKIz%%*g}8X=%lnsV-ou^X1(zHJw(5jK$|N&SU`UJGbV{
znxQSevS8tY<f-;yE?78UEPHx*Td;7Rn6mn8!NNt+6koB(Um7f2A{IXH+Y~Hpj1@Ne
zGlPYTBbh1Yg1<5;`LpjRn9^oAMdi%K!49pwkzE<00}mC{eUatcJhtGmz=FrFcLx@<
z2Ip<y>o)QmH}S@{kg?$O${~5kSU6^^3K*++^Rj?(xg@zVU~Gvchl^ohph_f7gOj1j
z$@_60le<R7=d8ZFQpV(!@^c#fYTr(N`BuL4xnS<|yy5v<dc(0N4n8raFAV4l`I2S+
zUH%vNqIEa)PlU1xd41uJtPGar4>^nf_M;Bl`a{m@|Gc|i#u)OyXB4o|1xx&!{4Kok
zQQ!r!siJ_s=(OX8zUpRH&VNQUK=wEH8epv}C2JMTH~D32N)_KMu7&vT9$vM4&3wi0
z&5e*4E!C~5)r>x(!T5aLT1GRv1moW-bZZ+G-=>+?&R2XpUj=b`0!Dq7VCcw%3<8<u
z1TxnF!~+<c^sorqs|+?RJZhnKo%W!W8n1ZZC?>-Y?q3P8tx-DFTcB<Fw8dg#4g>eI
zB0zR(wxHpKJZ)Mr77xpq_Kj^Qw$mPqnoVg^IJFjSn|Ns|p%7b#O<miDM}%pQSnf>u
z$>Y?qI!nr8Xa`_3OsNInH^P-RoXu$uo671%K<G@pFJ+p9Qh#5{bO~jeCDo$0q*>$^
zw5KLnnJsukB~M!{Cg#AHbK-F^CeBDQpe>fgfnxiGYFHCCL;OnCP@^U0uw*y;nM>tM
zsnH>|8rI6KaLbV=VdTlEXT_-XKY=<uMxFK(sI$n5;Z`~Ai63TwW0+)K25qI&sz8#>
zCIB>t90_wRsUR(R7CpR;mNa<h&pcmHT2P-Bhj;C7HOLWsZYdLc0pJL>SZ6vr+mcRz
zW5x{Qst{|$LrX@y<vPZqY>>O<03ZvU=_}I9qoD*q7J1)+x;hFw#ElQ{k)@E4q9DMF
z#|9@qxH5I=C_#g<8yYZ^kBo#5org<jxHu(cGuY2bS)#F}3i=A4I2yk4)?5>@icq@?
zHO!cGyEAJ$dTgHBIP!Aig^}B1@ALX$<m1<dCQe@(_wOC|e?0C#G46i{Z8e96;C^@N
ziwj}@E73czLl-9w9!9KsV&CnPUrR5-sPP|eu@Y_se&Y)dz6tl_@X6!9JsZ6S7`Za_
z*=K*+`|8xC%W&m9IWiC(tN&9#(&4l3g+DloF#4-6C(nO2{`Ie>etQB?6GdrL7haz_
z@*0e79lN0wngAH8<XpXWK?8shZ;1t^7p_;k-#LTNx62*82F?G`3*D%f3Etz{`@m>q
zgL_N6pzE{kj9QYwV1$Qc0=lT-o&ZhM4idDv36fy;pN2tE9^;sofGG}fX&iYHI7?8b
zltU=bfP)NOeL#??s^^;MRS6^wB#E=I??Y<vO2|BLC6<X=e69&Fa4d&5HMRE?Ku@TJ
zTh`=-<75o?@~Q-$wwkjz#M5-*lmwQ-P2G!L0Qhb}+3y0diZdk`IGY3R{@_SMtY=;~
zojU?Yw_*d&AytaQ?V_h1LB+Ye&Q5BVQ^UPK+;|X}%Gr^+3t!#vG8-s5B?jo&)CxLs
zM+i6IfN0^=(%J8Fz?y6NZM%A1woX9@#}9;|0IJF5i;yPTx9O!LR-vWS7H>QD`vSb&
zINMQd8w&`?r8hx2;?j{zcZA1y5&FNdW;L)0xsu5>4(KAvg(+pBg5q=4XR1$^@KsHG
zUh}{jxHg2Wf-?oTiYmZ-SKp_&!!S8cMW|?wPaVi^jHnbvvm#o?GzYADcQUkj=>x0p
zW@DZFck<899$0rXujJIr$6p?5zr5%3J)@O@ytaWgA$|6kz9OKnxS_8M6_%fS^30QG
zHw-*^GjH~(UB`Ew_yy_KkaxQJMn+}GR6X1sFfAN2H3v-1{^g@9f~MBNv{3mxUuB@Y
zd8~X{pnMs>yp7*%36?*_8%jeZbBCV}lq?u4X$q7y`D;c?gC*++_3$AN)rZW@q4K&=
z>BFJo@=#GJ0_B^f=CRWGfztV7r3(Y43xlPL#!6QPN>>I;SKX|t9_|U$v|Qg5tXh31
zGo^UepbqY@GIPcZrhvi31GS;izcgT217XOJEoL_d4U75Z8v}-o5Q*gv6$cG<zV!ja
zqY%b(^8yC*n4vBJWd%13OJJCpIj2(JOr?#5a_fC-eT)6uM{`HD5k|I2RuQV0KeU0b
zZ{b&2_?D+2?`c_CsH|qFczE~KitF0IqZa<@_F(ffeABc1v(H6T@*Jz|u0okPE23wz
zOZlw1yngQg8_zHzLWT8i^vis1-ncj!LJei*4DKFW_6L0_0jgzxbE7BT>#Jp})y(hJ
zy4A}Rzc<WT-K6+^y$s_`DtIS2Rp8D`KqpGqNvVZ434AF7TMSr!<V~<CnibS>f$C83
z@sT<tfT7~{-dDqe1K|%YP@kRHnOM4cNgM>gav}A7Kru<&jAH#@OT<9}TpmE5jr)JC
z<4}8ElyPWPz9^^1TNNH}-JpC6A(OZZxbcgkx1^jI;)%DS;$^O6P=#P=aw90)%iPUn
z4B5waAKHETkzrdPqmI|s5i59t(fc2rOmHBKP3DKtjV|_)(o5=}IGOj`*QZ@jKkyPf
zHjbGlo7)G&<@UqNte`Vojv0tZMXw~P;2I%En3JI3sM5Ah8<SZw*G6%!Ykj4Gj0RrY
zK<1j<f+uh<axURsG+=|9EVv>7gp=1R2!HlLrf%ZB*TW-Mq+Ts?s3h@3qk|GXNdQj~
z0}ik?%)o;<GX}l9*drnka&J36^5M82ycZ;ZN5bM1jZh3Tb?KwYk^QlrXmtu^?u9Xs
zuhUTpXx4cPfvI&m?DNRJiNl{n``o`T{MlE{x_LFCRP7xZzjh+(OEJI3H0~dn`sfw3
zNF9H3{Mu1;Iy?<9@hrr3^-wH24bhS48e;9dwr_Ie<Ecxpk6-oa7C`R4|G53uXA_6^
zPP_|t#sd>W2c|B(KXnNl90$N+*~YE~?Dph}mQ`>|{pYI($v9zzh_j;e8v|y<rztx6
zPftyJ_M2v1wJ9o!#Dzgr5cDHVRg(wL!ny#Y*?)+Hx8FT5b@aR$YPr4r#BfAh3EZ%h
zvCkYhHFbU%C}0Bz-x-?|+#^Jy*!PD;qL*B~-oCg8lIU;(u2j)kiH*+<7!lBc(<6>?
zf=m;1<gs`3IEjZ2*gnx2(Z%6_B=Z$(%kAxh&)o&3dq?2LpUf4-suaC~7MOVV;Ka!R
zV3YU+QZAA*Nz|p3a3HYCMX;(;0fl1=lb`}0h77@+Ae#5{(P~5i#nTqxk!(e_4E8~}
zfoBX6W>)5ESwxd#SSO1xIVtO8_fd>!CymP~Ii@M<RmAn@AQVNVRqAn*R9f$+>+UPb
z_xJsY_w@rBCs3-+T>&>;%9maj<e`vC8iDzzXA|&_oA}j-^BcmxV*q)9?Hj`%Tm-qQ
zuY(XOMZKBe>~iSq`%1R7b&&4?QNE}4zBYB{O{$7w=OQU5L7&mO;3RwX81x;!b|QT6
zXjFT>wlBQ@H!$338i$TPrg8pZ5uIrzs!bhU4qT5s)C~zFgA9gF14xF%>uG*NPqRs!
zIXWIw6}{*OGW22MY|d^wtr|XZ<@TvB;5>?MO>`dSn&6z)<$$||4*TRaINhBOU-<|X
zfuxVd&Sn#?$bVDw^>xrbS?Zs&191MfcG)_p(g<Js9M0mjd1OMOdBbOiCchX$jfRdv
zHn$so@<0_4^$v<^YTO@w23^7(0Rc$Z?}<*q4H)1W-R~DcLU=fdQklUQt{t@sY9eB?
z&z>{1aHuN6C?1ihmo%bY3`D&cV(LW+b;JkG;}iz0g2+z*u~FRRR8og{a2r790hL7w
zZ*@I-B5J&6p(#-vk?oMWcg0nN1U$?n1TZV6f8MDpiA5&fJAu3ug&l*Ddh6kZY$5q6
z0reXLk&im55krjBYYes&Z!@hY^#HrSdXl)LfqHuRA5l-zzJH>6nl`SVQ9Z@I4HI4I
zOjU4GHh%35I@q};>Q6WB|5VICx4PT^ewrqUnsK=uc*6)fj##0_M@|5aGF6R#<pb*q
zs^z0^gRu!Ba1{%CIMxBh$blCfS{eWl02%xMWb)OoV&KER6WsA*#RslTD+b5kervDG
zjbP%_f15aZ4uKoM4ciOoZtCiC02G0O$+KVvBLx6YtX&-ZR!STsZb^i#VYdQ>I&mJ{
z&%cBwVorSM-`#AYOi!(c@I}P8{Lfe4p^A6v^0_Jh$M}KAj!s?s1R|3kzcM-W1)x3r
zM$T@7OJTSH7Mq!PV|a3K|J2t9CWjCIT=<5bK~$16$P(aa;%F$O#bgg}r`>ouLy3%P
zs^ySOs;Q>?8%CWSy{M^Lpb{JgjZA*gIo&(Dq2>O00prqvv|CwasJZxupW~nJ;h%GW
z3fnFtIxJ&vMuagK5Fup|6_zEcFk($gIL@F>BgdK7p|6unF*(rS-G;3n9F-uCK6nVn
zj}fiOti1Uxpm`o__t6sSOvn-^K9)G%!LK3Y$sDZMxVx(YD6rXS537##qp5~6xKB{9
z+U6b5qX~M1AF`1++!?gbu_%=cxGX*3<|ytB4p#3Ji=5TffI)#xh0*IV2KIKeF_H)D
z?Xaad)ohwYP3-L&u(#{Q(s-EcHpvqEd6J3Q61xww#J-32M{MxvPW1|KNn}YVvB76}
zVOGHgf8l-nZ5Gje)FLi5V~F;^W;D)6i;>R~4H(fj2H!w6EzzPnurv3#0Oq)<8-ylm
zQRZHRo(0)21lh~Cap`Y^6XV~#Xw8^7H8k-bC&x$LpnZXEf_(v8DDhYTXdg|TLMmt5
z0Y3pE_G_;Za$-ZHCognX`1E}M1!4s~RuI308guXY=mcYK3Uv)ocEQmGEU*|vEiY&`
zbyKq|It$PNDL}J`e(iObOFl1!8dn{iI|U8eQ8A)LX+>9KE^a}^8%Uf|d??UBRusw;
zfW{0z899xDi`G;;xMZa)4`monuL)+9f08xa?sEjH9}SvUTwf71KNcz|8)^y^RD*%1
zpw5>cC|K-Y8z^{uPy<JuqVjX=&#WKL3Kmumri2Pg(FQxL2o}s8ei4WVHMg<~hvX-g
z5AE=kz5g=&9?F-;moyEoxe34gXnv=8s3$nPmd~!eRl1zt_;etzoj0`KDry`x2C~|C
zeVb_PTYi6I-_0V^Q0CdEeC>fOu=p(_7Qf|xBk1YX6?H3?GT+oI@x6$=m+Dq7SNu*>
zy|P*Hy9OD?n^o{mP&lY;h{7p{$V|TV@t;%yFp^0Hf}+u%Lm;BKmi`V2EP1%P7o!JP
z<d%ekEB>xhcqqxzO8~#f$(LdAzo#ZV_^l3DfHUR>GUg7q2QwD(+J*F_igrQq`7h20
z-7kNR8Hw(^bVj(3V0_#KcqL54qmYqQ24cIoI1T>;rh&VNjhNsCuFz;Oqqi~Sa*D_)
zo_Wb7idnWh=IT}5=dxGNTez(n@A}O0RwCnOIr-fH{Ye<TW8x~X;e7lpA^rv%eoLsc
zTH*JbUT_h%!f(W^FM4g{*V&NDuv)tuoZEw*UQQQeXsp&wSBKTg4dD>bgw5eXaJV6I
z2yHpUsoV;Dp(h5{i!X%z<OYRUb2&6Ma(I;B@DRe`{!aLaLw?~Ng_n?HB{xcr4y(=M
z;T+q%9=jWQ#d8gr7^+%udm+Ew%z}t}6|l#C=6@?&?kMwBjYEnE1Ho|14;Vxi7N~NE
zJ-!xymT%3)Uq%>6UN67y9&Ne4^P8Hxn2ao%4J30S3<TGe*V)lI*W15ICrO@tns492
zKld+u`@aNO+g&7yH0P^weWa7z>z$+Z{6=<k(Kk-)G?(9Ir{Q)d@8WpR4&JpRuzlxU
zEQ>5mSLud4!!5q7;Wg)fd6$9Y9n*5?x+TIua2=Y2fZw$F2Mq75l&_Mh%J6G2#11hW
z?VurV>*Bj#;Co&CiyruuTA<s@@Aw73=U*cXvr_(;9D<j@t^5wd>;$)RNcBJfsco{=
z@*hY;k@fOa)ja9UK=S&Wy9@-80=;U%F!Th$^;M%;qaCBhZ(2!`fBM<Gm>nrBQLU5t
zTOtgG*IVwAFtSoM8<IX2XK$TsbPf&qHVaN2Sf83pqs17GHo)BRmUez)`?t#?3}*4&
z+oKT|cbDWu9+wrVmiw}O9sYV>&*#Mv29ohX-Nj^NS*ohh*8pDdtY7;%GzCe?(%?5W
zMhcKd(hSnXzU@aOp$vw+WzH1juIQyEz$kFN1F#J^S;F&(!#IRdl*wPh7`g*<c>gJ+
z!mo%O9W7|}=oXY~TOZ#bq&^P5_-p9@T_B{fU>>pcMU#Y;r}4O;T|#AZ8Rv%<K|9c&
ze?=5Bne2~D${(53KQbBrm#O~)Q%~aQkc4eerX6FlzGJdNy3Av956%sxuDGSm7}L)F
sPCJ_~To}|ghA>(5owg{bErFZIboE~}8kzjZS$ov7#=kK5CiC$B0WqrOrT_o{

delta 2718
zcmZ`*du&tJ89(>w>vtSGj>*F@iSxL`aYG$QLgKtZFeqi*!m=h1OyUHGV0-5}0xESB
zq;?$}>d@KLYW-vMuNmzhvq)3-km_X8mjC7`TWK$>L)xkeY0}&!d$p^y?;JaY(C$e7
zo%4O?JLi1&_dSx&UgrLJymiBFw;&iF{l<QdYeneKRM;9~d9iWqW^3e10BK0$4l7vk
zp+=+$HAoZp@Ff#$p5s*MAr+3Qq9KkYrZa{xoV;v^M-qC*P@YX^5~*ZtVY+-Jo7l^+
z+F0Qb`T?3mn9~sEH4Y0Jk43Fs6DB21oRqpmO(O4e-@4)i*)(aIlqQufUV@{rQ&EHF
zMQqdL$Ms-EPr2BhT{FWu%NO=#t&;6KG&j4Kp71b@lbzVo%32lER*>C7z1hpwF0Gop
z2$GLUm1SuMliVfAU&ADiR*S3V>QujB9gD})T0DM!_}HO`3i&`dZ4uxb=x<|;91!=5
zbCN2PKZ?J!0E?K?gRSIa$?H@FL)7C7vs=1B`Mhj}ZM~i3<Pd+uMl7b*N0(hEx1!DD
zjH%zY2biTJDV{(i=Jt>WCW{zEDn}IMI<Jc4J!OdVk+1go%&LSdz!F!HL36WBr|bsk
zz%Fvt+$-0DtREtIbEw1Pdwt;Mz^#^bxB9A5lu?D}t~0de3}wgHoqG$)UhDx|L)I@}
zIGb7^gBHJqW)k~M>RBzhW;yW4GpX#^UoB<NJl5}#cdY$f4f(G%5Ryw??Sva}BZWE&
z^%VR7x(vYlq>esk>y>v??IA*Jp~f$BG`!{vXD_WgdkRVq_K;6)9i(40bMwrxXY4JO
z&nc70RePXB);sp!lD8a9hil+&!#9<VVLd*jXK*YNpSwJT<9a%k)Z^;ozN%n~cTxC1
zzScVTCk|3ydjVcT#Tr!Uz3b{)b9LoTuFkK!zW%BV+<w_7e1U8B#B{k9;WmUQD~#{}
zD=j}cT~Vz#pnfBKk|!TDc**nrTDvf@RpRKlOx|kqh~t6d3c2HPTLsPBD?rwW$E~C@
zP$LG=36VVT*F6_RJJE!LJpy1tG2kRAO}Mr+n&pJ#KoNe6#sKO>I^TdaYf>7Pg5`OZ
zn?+Hf0nKu%ZSffrZ0sQ|T@Eu8#)ss_hrjs#QofPnI4fCcQY}un+7RdURFeEI7`$S}
z^mR<r-%xP;8;fy0qZ?v61@T~}6*!iF@XV$#geaC-)Nv2BHSfPP9cOLGkkUAj%xr~=
z#>Y_N$(eKtw1z1iyS$K!&9L+`xcIgVL#P8`mIYOh6?1rMI<~Md6-y^h!Cm@~03e_q
zkJ(GQTMqKR0Qqi9{mBRJ+Sj8uqhzpPYy9_LoW2djo4xmKu7YQGZfDM2sNC~=+urxw
zRW}ZOT9jbx6P+gbwc(aw6)mfl5xcM)agHd$3eUlMMUeofd9qvdkk{IN)%}ph|2AjH
ziR4T?nYqoEK3keuypYyazFgeYKWa$p8Yb)`SJYtBi&R|&@DkeeLOs9s!u1#4XwSyh
zoSg-wlhreMO7y}ztwh-Mv+yWAI!56DfGRvuqdHAJD9X|kLGsbAHvT#yuJ(GFwgz0c
z)YaZCRI_$N%XyneJIJ+gn12J2pN3V=vvfavR|p<?@)dS!+bhlFYPXO4?dfX%=ZGkg
zr{QQ{MC7cGTzz)wD_x)Q)y(5^uVY=MRH@{2cfHIg3BgTI@$Z5I-G{BrUmAxJ)7+V*
z`W_qC)B;H_PuM}vhGst@Z%_IOCrS6-;Uc7Q-(Hg;#W7A{a%x`(H$lF$Z%@Bs2n+F~
zA<jau3<=Yz94?xAI_`&SaTLH1AgxtXiD2pnju5V|v3dxWx(NVirlUl4Eg9-l9si+w
zs{k|!E6K&aACB|p!6!5AetqDU>&=t7@iq6rA8Z3G=LSE~Y0J7c+&LUY%Mp=c55uTs
zq(fLS)sD0YD~%jow@HBH+tDNB*Zt5;;25MF3n}Z%k0)6R>5H~=)nqQ}=RD+<=#MMU
zfjLe9d>(qz*H=#_2VBiT=veqX-KX4d{T*aAPs^JX{!#MgKn>?5?+y$eIZKt56lgwR
zkwOCn_;&{3Fa=t$*he8qVF!g~3Ly&AbqoPTxPznzYp>8`V{ex@Rj5dT{`3NP_X>Jn
z9Q{~yNS0ed5y6xl{Rf?j0gu$3&E!VkcIOV>{$>$@m=EUl)zSQ=<?tpIi=is1H``Q1
zFy+O(w%U{*Uv@CDpna_{K2bPz_Do^?%$gS4q&CH{Tk6iiD=_6}RwIRD+G@{olF5a$
z@zOk>ETnKDbFq-RxHf-jliC({`6Vy)4yLS_)pAYQ@!O6~Di()0@?a?2R3{DQJh|z&
zBe`>T{6z#}er(mfI=$*!KDtT8Vn6xG@BuHY0Q&8!#o$w=W{P`>X{6zKL(C*D#2Gnw
zJ8Op0e<3xqxDX$}7vU(7hV&+Yq5y6E9x~rU)_chLClp#oAz1%Qo)fw5zaxr_`u_nt
Crgp0U

diff --git a/cryptoai/api/deepseek_api.py b/cryptoai/api/deepseek_api.py
index 06d66a2..ea5f75a 100644
--- a/cryptoai/api/deepseek_api.py
+++ b/cryptoai/api/deepseek_api.py
@@ -1,9 +1,20 @@
 import os
 import json
 import requests
-from typing import Dict, Any, List, Optional
+from typing import Dict, Any, List, Optional, Tuple
 import time
+import logging
+import datetime
 
+# 配置日志
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+    handlers=[
+        logging.FileHandler("deepseek_token_usage.log"),
+        logging.StreamHandler()
+    ]
+)
 
 class DeepSeekAPI:
     """DeepSeek API交互类，用于进行市场分析和预测"""
@@ -23,6 +34,17 @@ class DeepSeekAPI:
             "Content-Type": "application/json",
             "Authorization": f"Bearer {api_key}"
         }
+        
+        # Token 使用统计
+        self.token_usage = {
+            "total_prompt_tokens": 0,
+            "total_completion_tokens": 0,
+            "total_tokens": 0,
+            "calls": []
+        }
+        
+        # 创建日志记录器
+        self.logger = logging.getLogger("DeepSeekAPI")
     
     def analyze_market_data(self, market_data: Dict[str, Any]) -> Dict[str, Any]:
         """
@@ -41,10 +63,16 @@ class DeepSeekAPI:
         prompt = self._build_market_analysis_prompt(formatted_data)
         
         # 调用API获取分析
-        response = self._call_api(prompt)
+        response, usage = self._call_api(prompt, task_type="市场分析", symbol=market_data.get("symbol", "未知"))
         
         # 解析响应
-        return self._parse_analysis_response(response)
+        result = self._parse_analysis_response(response)
+        
+        # 添加token使用信息
+        if usage:
+            result["_token_usage"] = usage
+        
+        return result
     
     def predict_price_trend(self, symbol: str, historical_data: Dict[str, Any]) -> Dict[str, Any]:
         """
@@ -64,10 +92,16 @@ class DeepSeekAPI:
         prompt = self._build_price_prediction_prompt(symbol, formatted_data)
         
         # 调用API获取预测
-        response = self._call_api(prompt)
+        response, usage = self._call_api(prompt, task_type="价格预测", symbol=symbol)
         
         # 解析响应
-        return self._parse_prediction_response(response)
+        result = self._parse_prediction_response(response)
+        
+        # 添加token使用信息
+        if usage:
+            result["_token_usage"] = usage
+            
+        return result
     
     def generate_trading_strategy(self, symbol: str, analysis_result: Dict[str, Any], risk_level: str) -> Dict[str, Any]:
         """
@@ -85,21 +119,112 @@ class DeepSeekAPI:
         prompt = self._build_trading_strategy_prompt(symbol, analysis_result, risk_level)
         
         # 调用API获取策略
-        response = self._call_api(prompt)
+        response, usage = self._call_api(prompt, task_type="交易策略", symbol=symbol)
         
         # 解析响应
-        return self._parse_strategy_response(response)
+        result = self._parse_strategy_response(response)
+        
+        # 添加token使用信息
+        if usage:
+            result["_token_usage"] = usage
+            
+        return result
     
-    def _call_api(self, prompt: str) -> Dict[str, Any]:
+    def get_token_usage_stats(self) -> Dict[str, Any]:
+        """
+        获取Token使用统计信息
+        
+        Returns:
+            包含使用统计的字典
+        """
+        return {
+            "total_prompt_tokens": self.token_usage["total_prompt_tokens"],
+            "total_completion_tokens": self.token_usage["total_completion_tokens"],
+            "total_tokens": self.token_usage["total_tokens"],
+            "total_calls": len(self.token_usage["calls"]),
+            "average_tokens_per_call": self.token_usage["total_tokens"] / len(self.token_usage["calls"]) if self.token_usage["calls"] else 0,
+            "detailed_calls": self.token_usage["calls"][-10:]  # 仅返回最近10次调用详情
+        }
+    
+    def export_token_usage(self, file_path: str = None, format: str = "json") -> str:
+        """
+        导出Token使用数据到文件
+        
+        Args:
+            file_path: 文件路径，如果为None则自动生成
+            format: 导出格式，支持'json'或'csv'
+            
+        Returns:
+            导出文件的路径
+        """
+        if file_path is None:
+            timestamp = datetime.datetime.now().strftime("%Y%m%d_%H%M%S")
+            file_path = f"deepseek_token_usage_{timestamp}.{format}"
+        
+        try:
+            if format.lower() == "json":
+                with open(file_path, 'w', encoding='utf-8') as f:
+                    json.dump(self.token_usage, f, indent=2, ensure_ascii=False)
+            elif format.lower() == "csv":
+                import csv
+                
+                with open(file_path, 'w', newline='', encoding='utf-8') as f:
+                    writer = csv.writer(f)
+                    # 写入表头
+                    writer.writerow([
+                        "timestamp", "task_type", "symbol", "model", 
+                        "prompt_tokens", "completion_tokens", "total_tokens", 
+                        "duration_seconds"
+                    ])
+                    
+                    # 写入数据
+                    for call in self.token_usage["calls"]:
+                        writer.writerow([
+                            call.get("timestamp", ""),
+                            call.get("task_type", ""),
+                            call.get("symbol", ""),
+                            call.get("model", ""),
+                            call.get("prompt_tokens", 0),
+                            call.get("completion_tokens", 0),
+                            call.get("total_tokens", 0),
+                            call.get("duration_seconds", 0)
+                        ])
+                    
+                    # 写入总计
+                    writer.writerow([])
+                    writer.writerow([
+                        f"总计 (调用次数: {len(self.token_usage['calls'])})",
+                        "", "", "",
+                        self.token_usage["total_prompt_tokens"],
+                        self.token_usage["total_completion_tokens"],
+                        self.token_usage["total_tokens"],
+                        ""
+                    ])
+            else:
+                raise ValueError(f"不支持的格式: {format}，仅支持 'json' 或 'csv'")
+                
+            self.logger.info(f"Token使用数据已导出到: {file_path}")
+            return file_path
+            
+        except Exception as e:
+            error_msg = f"导出Token使用数据时出错: {e}"
+            self.logger.error(error_msg)
+            return ""
+    
+    def _call_api(self, prompt: str, task_type: str = "未知任务", symbol: str = "未知") -> Tuple[Dict[str, Any], Dict[str, Any]]:
         """
         调用DeepSeek API
         
         Args:
             prompt: 提示词
+            task_type: 任务类型
+            symbol: 交易对符号
             
         Returns:
-            API响应
+            (API响应, token使用信息)
         """
+        usage_info = {}
+        
         try:
             endpoint = f"{self.base_url}/chat/completions"
             
@@ -113,14 +238,48 @@ class DeepSeekAPI:
                 "max_tokens": 2000
             }
             
+            start_time = time.time()
             response = requests.post(endpoint, headers=self.headers, json=payload)
             response.raise_for_status()
+            response_data = response.json()
+            end_time = time.time()
             
-            return response.json()
+            # 记录token使用情况
+            if 'usage' in response_data:
+                prompt_tokens = response_data['usage'].get('prompt_tokens', 0)
+                completion_tokens = response_data['usage'].get('completion_tokens', 0)
+                total_tokens = response_data['usage'].get('total_tokens', 0)
+                
+                usage_info = {
+                    "prompt_tokens": prompt_tokens,
+                    "completion_tokens": completion_tokens,
+                    "total_tokens": total_tokens,
+                    "task_type": task_type,
+                    "symbol": symbol,
+                    "model": self.model,
+                    "timestamp": datetime.datetime.now().isoformat(),
+                    "duration_seconds": round(end_time - start_time, 2)
+                }
+                
+                # 更新总计
+                self.token_usage["total_prompt_tokens"] += prompt_tokens
+                self.token_usage["total_completion_tokens"] += completion_tokens
+                self.token_usage["total_tokens"] += total_tokens
+                self.token_usage["calls"].append(usage_info)
+                
+                # 记录到日志
+                self.logger.info(
+                    f"DeepSeek API调用 - 任务: {task_type}, 符号: {symbol}, "
+                    f"输入tokens: {prompt_tokens}, 输出tokens: {completion_tokens}, "
+                    f"总tokens: {total_tokens}, 耗时: {round(end_time - start_time, 2)}秒"
+                )
+            
+            return response_data, usage_info
         
         except Exception as e:
-            print(f"调用DeepSeek API时出错: {e}")
-            return {}
+            error_msg = f"调用DeepSeek API时出错: {e}"
+            self.logger.error(error_msg)
+            return {}, usage_info
     
     def _format_market_data(self, market_data: Dict[str, Any]) -> str:
         """
@@ -273,7 +432,8 @@ class DeepSeekAPI:
             return {"error": "API响应格式不正确", "raw_response": response}
         
         except Exception as e:
-            print(f"解析分析响应时出错: {e}")
+            error_msg = f"解析分析响应时出错: {e}"
+            self.logger.error(error_msg)
             return {"error": str(e), "raw_response": response}
     
     def _parse_prediction_response(self, response: Dict[str, Any]) -> Dict[str, Any]:
diff --git a/cryptoai/config/config.yaml b/cryptoai/config/config.yaml
index 24163a6..278a98b 100644
--- a/cryptoai/config/config.yaml
+++ b/cryptoai/config/config.yaml
@@ -13,17 +13,17 @@ deepseek:
 crypto:
   base_currencies:
     # - "BTC"
-    - "ETH"
-    - "BNB"
-    - "SOL"
-    # - "ADA"
+    # - "ETH"
+    # - "BNB"
+    # - "SOL"
+    - "SUI"
   quote_currency: "USDT"
   time_interval: "4h"  # 可选: 1m, 5m, 15m, 30m, 1h, 4h, 1d
 
 # 数据设置
 data:
   storage_path: "./cryptoai/data"
-  historical_days: 30
+  historical_days: 180
   update_interval: 60  # 数据更新间隔（分钟）
 
 # Agent设置
diff --git a/cryptoai/utils/token_usage.py b/cryptoai/utils/token_usage.py
new file mode 100644
index 0000000..99dd061
--- /dev/null
+++ b/cryptoai/utils/token_usage.py
@@ -0,0 +1,194 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+"""
+DeepSeek API Token使用情况分析工具
+"""
+
+import os
+import sys
+import argparse
+import json
+from typing import Dict, Any
+import pandas as pd
+from datetime import datetime
+
+# 添加项目根目录到Python路径
+sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
+
+from api.deepseek_api import DeepSeekAPI
+from utils.config_loader import ConfigLoader
+
+
+def get_deepseek_api() -> DeepSeekAPI:
+    """
+    获取已配置的DeepSeekAPI实例
+    """
+    config_loader = ConfigLoader()
+    deepseek_config = config_loader.get_deepseek_config()
+    
+    if not deepseek_config or 'api_key' not in deepseek_config:
+        print("错误: 未找到DeepSeek API配置或API密钥")
+        sys.exit(1)
+    
+    return DeepSeekAPI(
+        api_key=deepseek_config['api_key'],
+        model=deepseek_config.get('model', 'deepseek-moe-16b-chat')
+    )
+
+
+def show_token_usage_stats():
+    """
+    显示Token使用统计信息
+    """
+    api = get_deepseek_api()
+    stats = api.get_token_usage_stats()
+    
+    print("\n===== DeepSeek API Token使用统计 =====")
+    print(f"总输入Tokens: {stats['total_prompt_tokens']:,}")
+    print(f"总输出Tokens: {stats['total_completion_tokens']:,}")
+    print(f"总Tokens: {stats['total_tokens']:,}")
+    print(f"API调用次数: {stats['total_calls']}")
+    print(f"平均每次调用Tokens: {stats['average_tokens_per_call']:.2f}")
+    
+    if stats['total_calls'] > 0:
+        print("\n最近调用记录:")
+        for call in stats['detailed_calls']:
+            print(f"  - {call['timestamp']} | {call['symbol']} | {call['task_type']} | "
+                  f"输入: {call['prompt_tokens']} | 输出: {call['completion_tokens']} | "
+                  f"总计: {call['total_tokens']} | 耗时: {call['duration_seconds']}秒")
+    
+    print("\n注意: 这些统计数据仅反映当前程序运行期间的使用情况")
+
+
+def export_token_usage(format_type: str = "json", output_path: str = None):
+    """
+    导出Token使用数据
+    
+    Args:
+        format_type: 导出格式，'json'或'csv'
+        output_path: 输出文件路径
+    """
+    api = get_deepseek_api()
+    
+    if output_path is None:
+        # 如果未指定路径，则使用默认路径
+        timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
+        output_path = f"deepseek_token_usage_{timestamp}.{format_type}"
+    
+    file_path = api.export_token_usage(output_path, format_type)
+    
+    if file_path:
+        print(f"\nToken使用数据已导出到: {file_path}")
+    else:
+        print("\n导出Token使用数据失败")
+
+
+def analyze_token_usage(json_file: str = None):
+    """
+    分析Token使用数据并显示统计
+    
+    Args:
+        json_file: JSON格式的Token使用数据文件
+    """
+    try:
+        # 加载数据
+        if json_file and os.path.exists(json_file):
+            with open(json_file, 'r', encoding='utf-8') as f:
+                data = json.load(f)
+        else:
+            # 使用当前内存中的数据
+            api = get_deepseek_api()
+            data = api.token_usage
+        
+        if not data or not data.get('calls'):
+            print("没有可用的Token使用数据进行分析")
+            return
+        
+        # 转换为DataFrame进行分析
+        df = pd.DataFrame(data['calls'])
+        
+        # 按任务类型分析
+        task_analysis = df.groupby('task_type').agg({
+            'prompt_tokens': ['sum', 'mean'],
+            'completion_tokens': ['sum', 'mean'],
+            'total_tokens': ['sum', 'mean', 'count']
+        })
+        
+        # 按符号(交易对)分析
+        symbol_analysis = df.groupby('symbol').agg({
+            'total_tokens': ['sum', 'mean', 'count']
+        })
+        
+        # 计算总体统计
+        total_tokens = data['total_tokens']
+        total_calls = len(data['calls'])
+        
+        # 显示分析结果
+        print("\n===== DeepSeek API Token使用分析 =====")
+        print(f"总调用次数: {total_calls}")
+        print(f"总Token使用: {total_tokens:,}")
+        print(f"平均每次调用Token: {total_tokens / total_calls if total_calls else 0:.2f}")
+        
+        print("\n--- 按任务类型分析 ---")
+        for task, stats in task_analysis.iterrows():
+            calls = stats[('total_tokens', 'count')]
+            total = stats[('total_tokens', 'sum')]
+            avg = stats[('total_tokens', 'mean')]
+            print(f"{task}: {calls}次调用, 共{total:,}tokens, 平均{avg:.2f}tokens/次")
+        
+        print("\n--- 按交易对分析 ---")
+        for symbol, stats in symbol_analysis.iterrows():
+            calls = stats[('total_tokens', 'count')]
+            total = stats[('total_tokens', 'sum')]
+            avg = stats[('total_tokens', 'mean')]
+            print(f"{symbol}: {calls}次调用, 共{total:,}tokens, 平均{avg:.2f}tokens/次")
+        
+    except Exception as e:
+        print(f"分析Token使用数据时出错: {e}")
+
+
+def main():
+    """主函数"""
+    parser = argparse.ArgumentParser(description="DeepSeek API Token使用情况分析工具")
+    
+    subparsers = parser.add_subparsers(dest="command", help="命令")
+    
+    # 显示统计信息
+    show_parser = subparsers.add_parser("show", help="显示Token使用统计")
+    
+    # 导出使用数据
+    export_parser = subparsers.add_parser("export", help="导出Token使用数据")
+    export_parser.add_argument(
+        "--format", "-f", 
+        choices=["json", "csv"], 
+        default="json",
+        help="导出格式 (默认: json)"
+    )
+    export_parser.add_argument(
+        "--output", "-o",
+        help="输出文件路径"
+    )
+    
+    # 分析使用数据
+    analyze_parser = subparsers.add_parser("analyze", help="分析Token使用数据")
+    analyze_parser.add_argument(
+        "--input", "-i",
+        help="输入JSON文件路径，如果未指定则使用当前内存中的数据"
+    )
+    
+    args = parser.parse_args()
+    
+    if args.command == "show":
+        show_token_usage_stats()
+    elif args.command == "export":
+        export_token_usage(args.format, args.output)
+    elif args.command == "analyze":
+        analyze_token_usage(args.input)
+    else:
+        # 默认显示统计信息
+        show_token_usage_stats()
+
+
+if __name__ == "__main__":
+    main() 
\ No newline at end of file