From 9fba12aad0d68efd366ba37e8f34a1e7876cec5e Mon Sep 17 00:00:00 2001
From: yml2213 <a2213290201@gmail.com>
Date: Mon, 22 Jun 2026 15:45:48 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=87=8D=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../__pycache__/schemas.cpython-312.pyc       | Bin 5704 -> 5751 bytes
 .../routers/__pycache__/login.cpython-312.pyc | Bin 7450 -> 7497 bytes
 web/backend/routers/login.py                  |   1 +
 web/backend/schemas.py                        |   1 +
 .../__pycache__/login_service.cpython-312.pyc | Bin 8476 -> 11579 bytes
 web/backend/services/login_service.py         | 177 ++++++++++++------
 web/frontend/src/api/modules.ts               |   4 +-
 web/frontend/src/pages/LoginTasksPage.tsx     |  76 +++++++-
 8 files changed, 199 insertions(+), 60 deletions(-)

diff --git a/web/backend/__pycache__/schemas.cpython-312.pyc b/web/backend/__pycache__/schemas.cpython-312.pyc
index 6a6c628f7cd7fd040f1b655c86af34fb3dbd854a..9851552e56c01c1816a8eb0fd23f89290ce442e9 100644
GIT binary patch
delta 407
zcmX@1^IeDcG%qg~0}ymRu*j;}$h(A((Q2}zi16g2d{ROwEK%&KEUBz1tTsRum28^q
zlOOXLiN0h8@@{b_=jSDt78RxDC0F`sa!i)sS7G#>Tqr0!*_)qFM-ix`mEne<=!E2n
zl9ySeZpbTKU=g1oe3?bzhPXt7_XOc9ED}Y6KvhMalkam&Zl1#5$jBNA<fl%S5;T?%
z0?CAch)@s#GOmaPM1brr3ZI-KD8c0qVuFas$$f$ajQ*22BqvJ<eb9>miEDxgeh?80
zBKSZ=9EgYq5eXn75kw?`oXiysVuFaQ$-%;*jM0-<3Ma^=fCNEA2@n^v0*Mxe8!Q|U
zSEqn%a}cp(44qsrqQ#aDQmY9zD-Fa15tWnAh{!XhO@1SiA^>(P*cPy<X_FH~Wf`+3
Y*NJxXFf&Td;QYb>q`vS>78NrF00q}wNB{r;

delta 384
zcmeyab3%vrG%qg~0}yPwYmw!@k#`9nqt4__e7Y=^ESjv7Kk^wd`)RUIw%}KpoX9WB
zC_cHKU!3a-i$akgP)m{L<on!`n-B9hGO~sP`6-h<1&tj8Kr%rfA{ay{f(RB6!3-io
zL4+EJ5C9QiV}w8~Ul<WFd9PprqwgdR$;s|QAH1VL;+i0WA4Eih2tE)I10rHUL>!2S
z2N4M%0?pt^kQj)_oZKWF${0EMhH!#h5=an46oW7;kZ57J!NLJ?PZG%Pd=Wdw;K}Pm
zw3JgpYQZi*GdTq$0U|0U{}z#FOqnb#nj!%92iQ)q9VwIhMP(T?Ca)Fk=3!z~oWc2p
N0Z4t}n(QKG3;?+4O_~4z

diff --git a/web/backend/routers/__pycache__/login.cpython-312.pyc b/web/backend/routers/__pycache__/login.cpython-312.pyc
index d66f9860e30dc62f085f3f8cf126d0622952892e..3f5eaf1691553f8f6c35de357fe98e27dffc9e06 100644
GIT binary patch
delta 793
zcmY+CTWb?R6vuaRnQV61Y;~)-LMxSG+NQB4YHW)yN~%~)qHn#BwwtAPyJo}8#tTHP
zXdjEzc@V@G5m8YDiTw;J`T@$~LqCB;TYPrTrhRZ=e*EX0|C}>BJI}|zjVs?3MH2Yf
z+9{ZOpOoH!B=glHK6jVe!+{OoU`sHMgX914A@n}njog!3k~zq};=bgG15Zny<kA^F
zSeqlPqH2E09A&Z402*U2l>|mYOLlT>F7yh8pNb2LE9-V$ZxUkE^}B3AyoeI)wYY)P
zyb8&%T-e4#UHLX_N>f}O<&)a&l%%4b?cV6K(q?H-lOlMn*om>cJmb$4vusmNp-lUu
z91Gxlcl!@@Hh&VN3OE8d&EW=2d!<eyu$~5Z_8h1)fDD`M>Bpx)o@Ebvv<Fu~mH=hI
z0H6Z6#*r3D26PgT0zgYQ=q%Dz>SAKhrscTEAs2X<iX8p>gA~CiSu513dTuhu1J}V;
zMuM;=bRvSHKDpG^4*f-Fh)LQp>>VJ>#<Z!d*A*JN!KFn<zd`+6^V0iesbe>)UV`X6
zLD(DZGMaDy)+&Cr$^&Vi8?=mDhDFM(5{=_!FwL+=G&XVt(z1&eb=_z<Bo3Jc4mV7V
zdaY_wyY2>c%cce?u+Pz~Tmy%9o+b7x8jE`$rrf4g%U)io11X{0bHCjeEBbH&>=SG?
z(cmxSXJUN<{&BZM0B*y(hwiDp%CPmFK<2^al@=#&+O?)-oF|Xji{$#~IW&#7!-<X`
h#Ez(Tf*?9rh#dYC0=erKe9?~2i{4?S)RzDh`v>*Vxf}oh

delta 758
zcmYL`O-~a+7{_;Zx7&S5TcFr?V-;dj-LzIwuo4djYZL_WrX`lLtkPxa)|o9{KuH=d
zCL|_v!-EG;MlWW+fHyT9@MO#;8WX=jBi_6?&lch&^V|PC&;NPmWj|MTE0MiOMCI6c
zxj$j;zmE)yDlEHf9?W=W#T|a&UHGjG4vyPYH&kns{*X?TPxm7nx1mik=@yRG)|n&q
z|I4a$S`3e%5`7_NB*co`GR5K7NTvySk#^-Nl%}8L9i-Em;z-a8>-39asZ}NuY?2jk
zN{u1q&!7^OwyM1ZHMIM}sp=^GpyiP6eb-W=bfI7OH&z=ffs6r;0mc}7(Q=wC9EJ5X
zAh4eYbrGP`=L7j?WssKuLkzy$Atr7$)=YdGVzYobzzE<DV4k5MV;yuBkORO0{E*uq
ztHhVENjkRcBNty|VFJ&YKOFcv7*)GT+&Xj1s|43r<gQm94D+Z!FUL<x!G=Y;7{5^p
zc7YB2&{D%SR*2B=b=ZcuPP-l?@DfWrreEVX(SnyBo)=;dSfIfBA=_LxZ9GS}l4<E7
zi{X3pRWhaDg0$vK4Z|?oE>1(H&fqJ=Y%SL<;<WsbVLR+S#_6wQNi)C^oTovLr&8(Q
zB9SMgZaa^fEg->|c{aV-RF#*;!Cs-enKn8{we0p4__h5VM7Vu$?cmfn=nSQAIJ^L^
zptU@?<}7z?^D6Grz3g^z0?nXrN~R}(_$kMFArL)@iw^w`gFFy8KH1}g=sJCx`zS)Q
Ee}=QJ<^TWy

diff --git a/web/backend/routers/login.py b/web/backend/routers/login.py
index 3087a4e..b01700a 100644
--- a/web/backend/routers/login.py
+++ b/web/backend/routers/login.py
@@ -61,6 +61,7 @@ async def create_batch(
         proxy_config=proxy,
         log_queue=log_queue,
         loop=loop,
+        concurrency=req.concurrency,
     )
 
     batch_id = runner.batch_id
diff --git a/web/backend/schemas.py b/web/backend/schemas.py
index 7494c13..17f6dfd 100644
--- a/web/backend/schemas.py
+++ b/web/backend/schemas.py
@@ -83,6 +83,7 @@ class AccountOut(BaseModel):
 class LoginBatchRequest(BaseModel):
     account_ids: list[int]
     max_geetest_retries: int = 5
+    concurrency: int = 3  # 并发数，1-10
 
 
 class LoginTaskOut(BaseModel):
diff --git a/web/backend/services/__pycache__/login_service.cpython-312.pyc b/web/backend/services/__pycache__/login_service.cpython-312.pyc
index 0833bb013a282249da46c2b8b10b701244cb422b..f7b5690c4baea98169f88d500062aaecc1a78693 100644
GIT binary patch
literal 11579
zcmbU{YfxL)nOE;8l8^)l#6y61C<f!V4Rvs^o%oHP*~A1}k##S&u#m{rl`&qibz8T^
z38`_L491TdH_3+7X-m494c#PTy1O%VW;?Ae;ML8ov-M65wr6&xO6_fSl0W->_v%VO
zL^iV*bk29)=X~co-|L)z%gNCb@QvMB*U7pG;!l{6K4l7c_yGVz1WB|Jq>PjYWo<Gc
zmbb};Skb0{SP@iqsoGRs>Nd3u>nVepE=`+8fK@?lm#$4G!0MpB%g|;JU`^22mD83Z
zz}ldx%iLz}vb5z2X<g9TWoxqmtS1dYJCx;h<+tTSd4Z5;3_7|B+X`iboY+E;IcEsc
zbX_jaxUC4<n1jx);<jQL(JS{@qKBd6-thY~AHF(!`Q@1xul@Ohi!-mkeD9S}mp@EX
z4X)Xd@tGUnnH{}0b7kny9}LV~9=-QZH|~wTH2coT-SMBz{OTWP&Yhn<`{w;?17a_b
zGy8+l2dBR^JM_lPjiEoC{`LbLyVWD-tp|?Ll#kpK4hNq+N%^BpnC6YXh}R$P>JCy2
zMS5hsmh>?c6X>E4-rdav!XaM}V9kCi5`hGO`pw~JZ**t)XdncgYFhmMa5Tj5hCOun
zWbdYMs3UL`YUR;XBpf_Jd3(b2@j&RPw;PKeAR;^pS_cuY6Z$ydiyWtMuc49Y7)+;|
zqPqgZV1CF=f3_6#@IL?;A}9hjo4}23Q|Jikk1Qk=l#*0ZDoR}l^+<?GHKidn5Njzd
zr4w>>0O>pP(|xA_p;RxFI?|bGKqxg(>JBSuJfmvM!Od+mktXQhOldllq~(mV%}nM}
z7U&@tYeTLa;|@7#g)%E?gL&AgTry9pLFPk$TCxC2ZKMPGvjbTa@fHC$8-0xb*uH2e
zMA6YB(9P`GUp@H#xfHnwn?5r<I+rSdB<|lB1Y&^92d6LIzwv$7mp9!dQca3pUcY#E
z{HOQd{rj17?*Xy2@^bPBZ}5qm>J5+)UhfC00qXD`>E(?A9HzZ=I7sofF5gM-Q3^;W
z!gy(lp#xNeHwqgKM1_RF>w@8<-WQ@&l;V}aaJZW{K!HC>(^Sac>lcoA3cVVL74Um_
zOosa#lf?*cs)!(Ba!5hG_{9{EN*yUEQ$h+`3SUeGDTzT4F*T%A=`szZ)ajHKQaGyc
zF}V`dX_cT%d_4tr+B10)L;_POBA_pWl*8bb3m++GoDv+<kqU_sNHMfBN##tL1a-P3
zC=*LFfEMYQ&S?QGa^W|pg>-fZ5^<GYLoeY`wLUOH!v~1l2e=)ya6<EF9E3(p(Ab#9
zHgp~acxvbZ4Df{T%4jq|@+u5h@rq;ANnU#dsTN3wR{(uL5D3wT5MIX!{0Eo;uX^$X
z1w2FLjW9qH%AH~VaXtrV1{euNdxMzN&*4jYUKyc+9bb1+!f+8>jVt|q{$#_`5sHp9
z^mYXs{9%%cG?2*0U@%~0-tOLp9_mQL5ug7!6(Sp;=81qG>WHPO<kIe5UhDM+LIK9>
zJyp2yh%S|i5Jiz!AUI7V9fU2fUpb)RoYnoxX|01RazoP071v_2kgHsSu`8V}tbk$@
zXLmrPyX`2xsvp*0GA10gtfO|+Hd+yP)I&+mZD;9)7hbO%IX<>xs$$KQbFI+%?Yz<<
z?|JW39*i}hzg<#&_3-fFsS;>0tu5k;oc+p|%@1K-gg<?jAb~qBoV;}az{w*zAzt`(
zrcYR=M4~VdWx%~b#L(4H$SWcg<B`#i0UW_`T=WvmR^nct%KH-5Fnbx+wLoy1;Izhb
z`m_3Trn9D7S_fT^O;tha1Qp~pT_A*fM=Af@xup5V7}Q*B_VjjGRhnZ!#neYX&ZN0R
zXPPrerNCRV;{wIkf)Dr=$fC>g>nY4;A5S{>h%x;0$PsJHp)Yy`1Rm9#lcn)RdPDv|
zn0L_85F7?N9AyF_$}66th_8d<72Qz=q$y%L(@6xe19UH9UFYqNMvftspDOwi>eFQ_
zp-E&T1b}~o`CRjh%@@e4fs29LMq9#I#~SN6i+#v+-juLZu$GF^r^kEP$}Lltt(dJl
zulsM6BFB_e5M{Of&Ek%!K^#Qs&^$Ur{0ek-0Cr;0oyuPX=UH|yBI^Yyk(FANFxG-E
zvRKbq_MKk$_4_?3i{#4|qm(Rt_sM`(KwZ5oClxW-CE|*_L%x5p_SyxDfF%7AsqB-(
z52Rq$wd=FAS+z)AWc~|2SdSbOSr}uHHff2KX_#)K$jH$}T4z}iNOxRI7P<Sj>UwG?
z+hPCvWPQq*jMhl_izyLvq*{!7WgboRzhF*!iRs^e^R?L@58i$MwR?l#d+^<t?|t}l
zP>b&0cxC3&k6pE*nnDKrOr0ymS3IBq>C>(2T@S7d&z}C4*dFxqdzapw{lOcl_SkSv
z)s{Wm()I3-eFydTtO~H}!B5W2zIGbt@%^99yf`{DI57LOH|`C8I5YV2%*(IN>2Y>w
zB-3MR&aL4PRp+Xy@ucek1L1*-@XBKh)6J_ej6_jb-~I3gOk(Z|np|`f6nK=p#@8M2
zM(H4*({n7qP{9DGZz#o0bCSm?kafT{ydBYyzty7`<UX&VLcSwGiln~*J<;nicpL&g
zH`7w8(Ts%~Ffd@S76M>z$f|gqh<lg;ovsCXLgZ)!nX#~YBJ(nVRw-H$LW@&nU*=%*
zD&YDePT;^GcrAp*o-n&6&8|^pqPCH(ZA{d*OxCt=HfK^z7%d4yF>5GJ7|JIN<s%0Y
zRcqL)HHoVAlU3_EM{&a8VI7`?V=3!cI_cOp=1#2G#ID$sSh0;=v8{g_S6nrwV{J|G
z=6&(~?eTqw;_DB`ZHME=!}Gd!Pa51@acTc9uB5ELl{4F5KCIc5Ft3<2ui#wngljqL
zTApxiU|ky~T~AJ|7|h|ys}kia*zy&L@)owdWwLzB#J)k(-I5h^CbgV(Eays>aAoye
zVae6f;nGJsRjKK0YyY;v$friaQpmYHW82t*<_Sf-U{l<(iL(`4unjiGjm3A&1tNde
zFkp6}j-~}wA2gbdFt5*?2wug68DG$!mW_Z{<SGL9)<W)L-21Dv1iBE;_}m_$L;TQG
z2id7W9TB<V92u!(()ziiYxJpfL`>D0MFKNvzIQz(gFADC0p<mnTAf+=SWI@jmLSsY
z)0%dsi}XCyF?GZ$%q6W|f4LUOc_pceslDmB!Q4@KUhql13UVZi<++-`l9RH|q6G~h
zNvco5I{k8QdbNP(EcN;{Bv{6zGK1em_CrHzzp1%Ikh+)>Lj9b*QD@rf2&P1ui&O(*
z1MVWk##Ee>icJ`&q=XsDEpyVjZ(FaY<Yb>VW7EX6f>dxxqh#W@ZP!y8V4p6g>#WR_
zNRWijK7CBz>6UUcF}<F&&)XG!XLY7jf}lovZ^=AJr7fpLFlQ&VF~nTHgb{!XuBb9t
z3q3(P7K{t@w($EJBNb*DsR-7Zr8hWJbM}pCkVfl7rF+3A;SFYh8zg-HC&j8d(^!()
zz!^$`cmgVk<zNZ)fL3u3=vYP!$_AQGDh?7ovPyzMi6DG#5Ep$0vT!bb7*zj-FJ_QV
z<^K~q&X{37CJv&GWB5D6z>8wsBkLigS;3mWa!pcAPjPe`Ob@+sFTH*5`b(m34!kg;
zOAaJ@+PNaSTR`xOk~vlX;u+WGjjp>NT)h8_E1-SwnjRk=0t-2c2l(#$?}JBh=DlCe
zeCzV;&wheR!+ZY#KAk2PuZ@CD8uE2ft-J=z18hPULla&p@N(I6ysROL2Gt?g%m=4u
z-h4?M9$R+%A`x)PfzeKN`2s=SBt+hHcCMHXbosiyX!ugJpf~X5Ir-gTntAY_a0uU0
z(>q}ldM^h1FxZd50Sumo08|r|AXfzE0k4Tf{a{u{qNsPK{8;^iGcR5}B|qefA_H^H
z&E?e{FhdHbO4DIFYR*)cdHtRH@4nIGnwR&%w`a!3n_QkE(GXP!BCrBR&^>r#%7Y2M
z249d@flrF=rEx?UBoG9*120EMMn`~-fMdcR3`Zzl9btS-G{URFMcNf$XgpoC2LqHp
zv=#$&ihzNNUIh9e!caMUJU|Hs9j|-xq@NPps9+W|G>!6)S4SCtDBQyvI>40>IR>sZ
zALB8KX53TQ=N1gMVt~}e>(GY^ei87@DN%0o8qtHsfF_snzG{RCz#_o#ibR79FQX!e
zV@VapSk$SEUP^HOQeIFdPnCRGqncBU&gn=9H1E^I9WV=<&Nhi!)3l+KGg{8Io^8F*
z7_Z$pvF_$}cGENQjnBrb4^A7~IHUEh-Swl^eqB<&LRZS!iib9w-|%|ll&wBtTgBQ|
zy?gMz_IKJRo?%z-oU-jo*!Huw{ZqE5`!|1VE8r~o$-^=tC;!~;v%7B@OOnsY2&cP$
z^S}<yn3pgXv&Q0SW9gmTyhLv0RBk0&pynT%N0ze|_p4^EsPt;XaKoVHGZkTVC$&UQ
zt}x3rBYQ`BMgpTRjOC4K;%m3u)W-Kd$8K$pZ#fjNJUngmCY7Z*KH2S}a;~Imq?0XK
zo{ozuM%J=LOSsA<@w)YF<>OrS(s;v0wtCZK^|lF`bJxY|n_2gUN%vC|D<9=(oYq0j
zBP-#o;_OcF^>DRyiP|UF+9w`qlvtG16Gi1$ONL7>l?|%z*b0Z5f7r}bEE(MV$_}og
z_Rach^#WMA9HO1z1sZBS-#XGbCL606D;%#Fe|DmieSB|x{l54<Z+z+Vx9q+<6_1H6
zJa0B%Yo6O`?Wk`|Guk^YA73}Io&Cn{c+;Nv9&h~lj>PjJ_W4lU8;;j?PupL3WFlO(
zSHC&@&8f0w{hOza#dGlt`fPe9K6_dQNM&;?zj(A!M%YXKLMQ-dTxr#y@)g7FvWk)A
zmrej^O!*2f^o*8|ZW(PH+c<V|LeH+<5nr?O=I(g=q4;x$<F(#|<$2cf{1-_LcJf8i
zni=Qw2y%`aEvjt|#6Ra(V%S)*wLtMN&T4@FRldo&)lK}S!~=<&1*)y(nw!O1gx$Jr
zb&8wytGCrCKB~aRAJwQJ=c76W!VT8#GQ~W9gaJkoG}<F@kQdWv!CKGiITEbn#k5(l
z>PbaLcZD91RV?@<c?NZrG5LJibd(UR`z)<CgY-NEd<HCGqBE^kX1dO*^QJXjY0S<n
znk|#AmCX{5Dd%a%$n_R{lEm**#Z(d5zyT($=fX_0=(J>7FN!pRyv?GqLOYac3%=uE
zO42SU%Z7b5se!&q7c_z7e9L0sHKtsu1KtEBXj56odRr&?ANt@XAuGPKXrD2)gl9pY
z&$dfd(&(93!XLCzbk=0@B`BuOx-VH*3pl8i+GS$MO>0~8a_cfF34*#yB{&nOG<ZFf
zX3-u~r3TV?Sxx3-e4&EI*RDh#S2kR%%=9lo8C=XcMG6V4eVUktG$B3GRg2PrIiqzi
zQpZB-Gj)1%q1I|?{7fv(MDRap(cYk~i}WXp=`#I6oi&+WB#6G7J--uO?+ZTqcQI|`
zw~LGgH;FObe436aHWP=g0%y=O=$#QhY4&{vuv86Md4nre^((DjCS5Bl4eCidnhRf>
zLxAl}H<4D*<kKe=>?>hCke9v(V_KxSb#9cPOf0PpT2x56u*R>XCMZYUYQZP<BqIi{
z2~?Vmvn-$%1~oI`i^<>4mnd^J(PsqSog?f;2kr&z-*%~HChpvofh9<q1#Mqs&(&l>
zhQ4G(XkE<Mxm#+TiJ|qLOiF@csXc<&fqMnkwdQ(ioqeWQPF9X%lGX*7Ii@5S)a`{Y
zmLrt_&Dmg`CZI1<C(7*wpR_9IAx{bS^kgpnW!ACCTG1zjQnctw`p#6~rC(!bDv{E^
za+f9R4Xn?<k){jQXIY<lk=a<mDmBkPZD2j-_L=|AJaAf!=UR{Rt=$1yv?@K$D9W7l
z3y!pvIQLc`Y(TmdYDEF5^RD|vThJ9nA)PYmz#g3W?mMn1%2rp}&cs~tRmiJjO|DZW
z!7yk#5ukd!zF?5vft{ltLo_A9%RGDKJL2^}7>Al}xcvlM(xaqtuDm|;5P<eWhIkp=
zgb-qmeg*=#z{(gcU@H*9gl2zvZT9lnnRCBLJx;lJMjV9hh8nH(b6C#>f#~DDJN`0M
z1&1}-$AZ;+@BMx-dBJCmeMeDUSx^(qJQ;7m7YL$t6p5mrXEBp`=ImQ{KO9a?0f|Gf
z8=n#EDnO@bH%2v3;F|gQz-<4Zr%u3taFr|?kcuD`5^uzDHZ<Bsys<^Jzjncea*+07
z{_`04Fu<)6F3#aS1-xfD8UjNP-rV5Mibk_weJXq;nw>$orQ_AUZrp%Ht!bLXwohV!
zcg!^MNBR&3!sg%=qF`at0fag+ID!Fcxq?Ydw*v%bZS)A5vovNaF~Cisk3!(Fh-N76
zzIbb|7d^$`A&&40AKvN%P0&FsM;0iUsgg$@T=?LCV5lzoI27?((UgQ|Mw*T&TnEDI
z5VZ)<FF?6);XBtr%^0Z)@M)Z~f5|q5++l3^1}q3nQd_~$<L4jm*K+wqiTr9dzq;Rm
zx5sdEJa{5rzH02*vF+ob-|mm^eLAt%$L{q_?K%?Q>5u#WHVGU{wp9*MOtuXp*LL|M
zg3#@dgS}JX?$?9IJYlQ6WvlGp#98x)YR=aT)t|3_-8f~fPgqy6)>ZGezvq3&dsD%#
z-Z5p}nXv9-t^1~|2l_XCY|G~?j=Q$<5qF|uC0nsFzWT{&+f$q^A8p_f^3CwI@T6^Z
z+O&%=+dQ%VH|@V}pJ<IQ-9K$Vz}buM+KRcta?V-G6}UKO+0_lh8^FbHH}!8$8quQN
za(2tP9cOo3P)-|5&<@A+uCu!acHc4PCyXU5<U*^p!)x!jD&I6-Gjge@#C7%H@IkKH
zlc-+DR<GkcbqP;1>uH|!Y@Vp#Y933}G_f^JlQk{l{!eo>CDu<>`ZCjB34M+^Swq;}
z$!0>Ab53(sgBXUV47V+|!R<dX_p3OAWw7PNri@FV`iW^{i<De9vTxd03qAqBE!=Ln
zR<f>@Q?AvlwxnM_xb0(uU8=Zdq;c9<54D8LnMp(Oh+Vo1X__o=`gMAMwejkwCVD51
z$KBBL{y#V>29>vqYcI79g1<qVTg^G$h_bgEr<|)3&h@Nw{RancwEwF8=7IRW=RWeX
zkGD@b4<(#_*6E*eQiGd6E^u<y^%s<v4V<TGym5R<yyhuL8E-FH`HKy2ZJ1iJ9x&~w
z<s9YWGmL4+V|VN&L%YxKzGbgU<`IRJ$$ZJtkY4N~HDPj%?zok+ZhR}3@95tmOcUs8
zsOfxD!scde?rB?fh76V-n6^LtvAqyB{%YB985AV!RjeJ{2#yPd=XYaN#M<4Qy_B;T
zJ~XI{tb^*LiO6-}wfuz>w=C7k0+`98V!~N7((~^{4Nxps<ZhC2_M)L(=Xbrj`%@L+
zT=rQxVQNg);YQ9oCP(9CPfcsLNXO^oi1n7%{XfY@0$!Ae3;p8JGQv^*7eXfVDLN+B
zj)up5<NM=vEeZQZ*1qwJqymdS|EvZ^iRY~QJhB;%>qpBs%6C`Ef9q~pzo$y^yK>9!
zCgtyz%K`p<m38-8)$f~hdnz<>Mc$qgP28b^{CJ59b1D=FSE=?a)p%47Q1rL9wmv{+
z=E=i{IOzZMdf}yzw<}CWg9sbF@Y>85OqFQ7UNY?WdTC_r@Bj@iI(bDP#L&keO{+1}
zvM2LwQRL#QFk7`(c(az<as<3~K0hP8SK0{=*l4ts=w%py9SRkhC_J9zm3SX4a%O?6
zeh<ptB80m(!R<y{umuLl{v)44aEAC;8H8&}cNMpCEmyysTeXgJ7Jr)OP!-=X+L9`W
z;Vk4AU8p>NFsZ?mmdJA?bqMK+f}*4WAtO;*p3FhWL==?8%Np4HWl1xpErh-J!j`MM
zhIg^H$CA02WhKl7gFT6YWi0%gmM3kPX(#dvAL6KgStU~yCe<pH=|Ut)Ks37lAx244
zg~~Ca8aXz~Tnml)<JFC<tLY&DnaQoPMpfy^rX&H;*eW5Kc=jgw>%#&VZ}&dLl7}Z`
z?J`xBhz-O6ybeOC<td>DAfgfDv>O972Y74xi6FByB{xI~ro<{p2E3Z-?M9cku!W|`
z3qiQ7JVtf(E)CON;%4jd`Rr2RiI?D~#fOKG0fa&YBcl5jZBgDLyk?z41iU5Fa;fOL
zHV8wenx4c-pyZ~{VYVUjTs0y}d|aULj@Ea?2mW(GJimhV>oHg&l&%*EwwVTdjgY}F
zf}$Kwk4*M4LH>y_{eiIjfiV1$*zgHa@(JObAu48w@;?$!d_t`FBk?RtJo^bz`<eQP
TLRR%Df#F|wY6zKI7~+2c+l|A~

delta 3794
zcma(TTW}NC^{%w5_sd?%FUhim{6GdAn@1t#6%!|r04@%ufD)<*?HZ)$VeYPQOynA7
zn2z0XYdg0cpa}zHCaqIw$26TnOWWi#O{Wt%m|EE+6EeX}$d>~7YNnIkvyyC+PG`C!
zoqO&%=iYl>_nvbj^y)U-->p^?qTkQo+Yo=gcG6bET%2rKKFo$#1__M7Cb*<7q*HM&
zp-&n@1{K#Oj7d|-q~iL7IcW)5lGcz-of{JNq$A{@xKS`ADk!fq$%lB#cd9gV!j-HF
zRWV3|wj;rE8VT0R8qfiuQ1zfDXv-X!{9-d%#Wa!QOsqmr>56ez`baF*8<AeX22x;_
znJQIzgdY5fcr>*dfhUh@o<Gp%5X`5!kQH_f*#xVo7i^-wj}`2v*^pguhz`*pR@Bn9
zl&XQTPa{-NUZqe;SMc<7r{Yl0+7^+cN1w^0QX<au5MH~!E+P%4qOo*aPe#m$zPmr2
zx_9!_-7~MxzjcOWw9%TVv7{0V+S32QeMJ7PeV2Ucc9L<{uq=zhwzAkD3TnFVS?Dxq
z$96hk2L<FL=Ot5IeXCJEip7W!OC3?TCyt9LS>eKxobC@A6;=`xeGf0;BsiYz&}FPH
zibzK(IEe~X<Xzo<tIK;PJQ=>}Y93*KVj>~^p_&HDR<x2R2N~=Gd4>WX_LKMYK4t|e
z=xdn(F&RFqY@u|#oPr>SVPjlHzA?1b_yAqtNnoze2kW0OwlZy`-?)<ry!mJ2FSJZM
z*>BxA?4$yUUQ9&}Cqw~v!0Oci)&RX?;Al)16ER5+mnGH$a~%LM3$LPpD&V7oV(iE1
z7YD-`oWKiGiZ&@7kvPhxT7VuPXbWReN+*ts;eJwKYhu>Dx!%^uxC4|I1#`=vnId4o
zgTIngosYb%=gBvIqg^Y*e(IM+aUGed^R770l{1w=N6?T47-gZwu?rpg9KGzW)x^!j
z@8Ed|vHD#u9UHd;-Mm1LI|x(HTeUAxN0(*DDW|7uh|RJRGqzU-*Q*~rv5L&N8yJ?H
z(m1ICYHGPXM$p?J=mdS1jeE#ekDq@{hA0<TF<Gr(C<-@TF<xei<ROl3XDG=m8RCA>
z$Ig{?VNg~R4*;#2%d&l%Mf%tmEP_4AKRg`_BFFq{np>Zv_jyP+q|fScWtL3nT@HcC
z>KA=SHR-H(vN&5rH1SsQrI*+BWp$FE%0DBR1ansZ3OcV@vPwfe`v^kn?%a?;FlD)L
zRatMrQk18(>M~7+OjE!3YSO{Ec`jU6ri^tgsNUW+XqDHO8QBH<y3ho3Xs&div2-j;
z?cGq8T^!>Z$)`TI#-*y?OaozCRGgvvq+S#3OVurV4ZO3GzO;_4QK&dU_j?5il}l1@
zK^aQtOR;s4Zr<!LB6)N9e3e1tqh;e;AWn3AtTb*bja}rtxt4QM$tMBpbX}>sTuR;{
zll;`ePNuAm>h^SbzBpc~z6{rdenaN0Ilh}*a=ST8))McA;PFoiH4oWmiSL1v>$osH
zAL=L6E)9<Asi%dShfJ>nOUm+#BQ@T=^zx;i7ChfNtqo4IED654e;ZAtrLO(o``1%T
z+UUgr=UU9)N*w!=#3@CtT|dE$DKv*5g79M48qRAMW3G~W1fSqsqzzgFNPeblRU^Vr
z4Ot&fVtHSgo3)m2*?;-$`~SC1-mH~gA>E<|2Whb#vi{IIcBMEDFazjC?Ljoa1pVaJ
zvSyva#!`Lhmjf$Xpe^v-x&G_VfB(z*@oOh+38=u|JsuMW!jVKm(GNs$iWVnwDA3dh
z5mQW&Xf&Nk$>Erw=p;EJXCzz!3{J#2jme!r6R|Z`HFsyA*xk8tWB$jN=CA#3{?w~?
zfAgB6$F$Z$v16XS2hSwwbk$Vhc8bM5rD+$`DTa(B;#4Fll7p_b9>p#uBe6s{mW=d=
z`_otsY7|Z_4VWi4T^ot3YWZ*mng`$fZ^!PAOei{94l)TjxB`Q^YE4nJ2{EOXUA3Aj
z+_8*^2Ng?a(URS1K};yRzF0yQv7(`NaeXl?$rxU43@wOaj!07MNJ<pKa$2<(ZwDUK
z6h%865vVI7{rzH!j?r{78I$ow;6pvc@Z#W30B}PvTrNeIk)x^ffMV{8rDD=ix^F~Q
zjAAO26mf)Vp%!jkObXN5jlnv+0{~oK40jgq1h5N$4h>VtQ&i#9;Nfn-sUGPUVxnSv
z;>D=gFUQg;+6c%vXj99p>KlcVX{RMA+6XmSOT((LKu}D@(ksNGRHq_N>#o9t6(*+W
zOW{}a>R~kId)#myBTCTnsD*g}&`#m&Ca?1#Wk@%u;V02;zWU7O$;~4MvZ1-jmCQAy
zW)10r4ps0YT%NC<;{&tgN6oJXD#mw>?mF9eQG3>X%hFT`AZKHt85ynP`ceJ3ZPYev
zs3Eg02Zr6gN&N&n5y^X-CfJ{u^ZwP-k4~@1HEf|X%SV9~zuJ0f>&?L03HFx5SI{Gm
zzhFStit+8E+sC^{yJsz)yruGvw`Gc(^R|t4k93Z{M0bnk?fm$O(Gzoa-;CWiYhRXk
zIM3K7ZD$8_ts7?@n-quZc3ohkYi#Fm-r`uY*=;(b+n)W-#h#1DrYbH;7saWLD|@G1
zmqSy#avOHM!@uYGo97){F0g;ra-hI^t^1gd>iqe7--YMSJy#y;>MsP(1@nRCxxl)a
zz`A^MaISgdO!LO~n>(-Ld}GU8<NBG#_3t-sxxR+{q2}3I|8(coz_e@n@OAzz&mTS4
zZEq)YZN0ag`$(|XyPKKzU)4@!rngN?*Rof$)2X+=m+KA9^&Xz-J)GMc&8-w>o#IzE
z<Xe7W_}uW#hW3#z)h!El{nO$p>}OEJBZUw{!oe2PS3Gjo-$z>OKJrFw!`{xR$QzGO
zt((?NuerAA>Za+ox9zz-J?}`l<$LEGy)%y9uM2uA%lu1%PW;`<uG&2&P0nQO@o+hQ
zYfm*dQ_WF4$lilath>8A=p_EuwpB1wSm+lOZ7e0@!*q_JrBNJvpf`Lxo$8AnQ7<oU
zCD~T*@G_8S1^}HTP47&9LR45t<l=oyQSuuI2SCIR08&;3aLc8?P;eT3z&=}WpvI>B
zn)Ufr9r?8zzT}-;%WVr^;OIzmwW{uHVDex=4>JRD)f9|?nb6Max`G){3-bC4R={ki
zx*^x_$V^px!47i=a(d2gzp(q<?is$dPywV$WUrnWn5%A|p+8&4132vdN^*Qf`|yJu
z%t3~0D(VZW25Ybc8n*(d2LLWDJt^{FKYdt>9<oWt5|KposF)mVOXDO~eQAoOvDhZ0
zGlLoWYETE6RYDS;KdJc2K$oaEx<F(PCdXEKhM_T6bS0U+a2h;%_&AWw{UT1r=*yT+
zNyW!f_2)|<u;63Gu!*kDB*ZQFG-be}FF|8f&@v430s6sb$o3&}e2B~+qxz4Ldmb&D
dNB&RHV;`f{pP&Q8yUJjHUc)rqM*!7r{{x^kvoiny

diff --git a/web/backend/services/login_service.py b/web/backend/services/login_service.py
index ff599f0..9027cbd 100644
--- a/web/backend/services/login_service.py
+++ b/web/backend/services/login_service.py
@@ -1,8 +1,9 @@
-"""登录服务：复用 core/ 核心模块，在线程池中执行登录并推送日志。"""
+"""登录服务：复用 core/ 核心模块，在线程池中并发执行登录并推送日志。"""
 
 import asyncio
 import threading
 import uuid
+from concurrent.futures import ThreadPoolExecutor, as_completed
 from datetime import datetime
 from typing import Optional
 
@@ -16,7 +17,7 @@ from ..permissions import has_permission
 
 
 class LoginBatchRunner:
-    """批量登录执行器，在线程中运行，通过 asyncio.Queue 推送日志。"""
+    """批量登录执行器，在线程中运行，通过 ThreadPoolExecutor 并发登录多个账号。"""
 
     def __init__(
         self,
@@ -28,6 +29,7 @@ class LoginBatchRunner:
         proxy_config: Optional[ProxyConfigModel] = None,
         log_queue: Optional[asyncio.Queue] = None,
         loop: Optional[asyncio.AbstractEventLoop] = None,
+        concurrency: int = 3,
     ):
         self.db = db
         self.account_ids = account_ids
@@ -38,7 +40,10 @@ class LoginBatchRunner:
         self.log_queue = log_queue
         self.loop = loop
         self.batch_id = uuid.uuid4().hex[:12]
+        self.concurrency = max(1, min(concurrency, 10))  # 限制 1-10
         self._stop = threading.Event()
+        self._counter_lock = threading.Lock()
+        self._completed = 0
 
     def stop(self):
         self._stop.set()
@@ -86,13 +91,73 @@ class LoginBatchRunner:
 
         return None, ''
 
+    def _execute_one(self, task_id: int, acc_info: dict, proxy_dict: Optional[dict], total: int):
+        """在独立线程中执行单个账号登录，使用独立的 DB 会话。"""
+        if self._stop.is_set():
+            self._push_log("warning", f"任务已停止，跳过: {acc_info['username']}")
+            return
+
+        worker_db = SessionLocal()
+        try:
+            task = worker_db.query(LoginTask).filter(LoginTask.id == task_id).first()
+            if not task:
+                return
+
+            task.status = "running"
+            worker_db.commit()
+
+            with self._counter_lock:
+                self._completed += 1
+                current = self._completed
+
+            self._push_log("info", f"[{current}/{total}] 开始登录: {acc_info['username']}")
+
+            try:
+                account = Account(
+                    username=acc_info["username"],
+                    password=acc_info["password"],
+                    email=acc_info["email"],
+                    email_password=acc_info["email_password"],
+                    email_imap_server=acc_info["email_imap_server"] or "",
+                    email_imap_port=acc_info["email_imap_port"] or 993,
+                )
+
+                loginer = DouyuLogin(
+                    account,
+                    proxy=proxy_dict,
+                    max_geetest_retries=self.max_geetest_retries,
+                )
+                result = loginer.login()
+
+                if result.success:
+                    task.status = "success"
+                    task.cookie = result.cookie
+                    task.message = "登录成功"
+                    self._push_log("success", f"[{current}] {acc_info['username']} 登录成功")
+                else:
+                    task.status = "failed"
+                    task.message = result.message
+                    self._push_log("error", f"[{current}] {acc_info['username']} 登录失败: {result.message}")
+
+            except Exception as e:
+                task.status = "error"
+                task.message = str(e)
+                self._push_log("error", f"[{current}] {acc_info['username']} 登录异常: {e}")
+
+            task.finished_at = datetime.utcnow()
+            worker_db.commit()
+
+        finally:
+            worker_db.close()
+
     def run(self):
         """在线程中执行批量登录。"""
         batch_id = self.batch_id
-        self._push_log("info", f"批量登录任务 {batch_id} 开始，共 {len(self.account_ids)} 个账号")
+        concurrency = self.concurrency
+        self._push_log("info", f"批量登录任务 {batch_id} 开始，共 {len(self.account_ids)} 个账号，并发数: {concurrency}")
 
-        # 创建任务记录
-        tasks = []
+        # 创建任务记录（顺序执行，线程安全）
+        task_infos: list[dict] = []  # {task_id, acc_info}
         for aid in self.account_ids:
             acc = self.db.query(AccountModel).filter(AccountModel.id == aid).first()
             if not acc:
@@ -110,9 +175,26 @@ class LoginBatchRunner:
                 created_by=self.created_by,
             )
             self.db.add(task)
-            tasks.append((task, acc))
+            self.db.flush()  # 获取 task.id
+
+            task_infos.append({
+                "task_id": task.id,
+                "acc_info": {
+                    "username": acc.username,
+                    "password": acc.password,
+                    "email": acc.email,
+                    "email_password": acc.email_password,
+                    "email_imap_server": acc.email_imap_server or "",
+                    "email_imap_port": acc.email_imap_port or 993,
+                },
+            })
 
         self.db.commit()
+        total = len(task_infos)
+        if total == 0:
+            self._push_log("warning", "没有可执行的账号")
+            self._push_log("result", "")
+            return
 
         # 代理预检
         proxy_dict, proxy_msg = self._resolve_proxy()
@@ -122,57 +204,46 @@ class LoginBatchRunner:
         # 如果启用了代理但预检失败，终止任务
         if self.proxy_config and self.proxy_config.enabled and not proxy_dict:
             self._push_log("error", f"代理不可用，任务终止: {proxy_msg}")
-            for task, _ in tasks:
-                task.status = "error"
-                task.message = f"代理不可用: {proxy_msg}"
-                task.finished_at = datetime.utcnow()
-            self.db.commit()
+            for item in task_infos:
+                worker_db = SessionLocal()
+                try:
+                    task = worker_db.query(LoginTask).filter(LoginTask.id == item["task_id"]).first()
+                    if task:
+                        task.status = "error"
+                        task.message = f"代理不可用: {proxy_msg}"
+                        task.finished_at = datetime.utcnow()
+                        worker_db.commit()
+                finally:
+                    worker_db.close()
+            self._push_log("result", "")
             return
 
-        for i, (task, acc) in enumerate(tasks):
-            if self._stop.is_set():
-                self._push_log("warning", "任务已停止")
-                break
-
-            task.status = "running"
-            self.db.commit()
-
-            self._push_log("info", f"[{i+1}/{len(tasks)}] 开始登录: {acc.username}")
-
-            try:
-                account = Account(
-                    username=acc.username,
-                    password=acc.password,
-                    email=acc.email,
-                    email_password=acc.email_password,
-                    email_imap_server=acc.email_imap_server or "",
-                    email_imap_port=acc.email_imap_port or 993,
+        # 并发执行登录
+        with ThreadPoolExecutor(max_workers=concurrency) as executor:
+            futures = []
+            for item in task_infos:
+                if self._stop.is_set():
+                    self._push_log("warning", "任务已停止，跳过剩余账号")
+                    break
+                future = executor.submit(
+                    self._execute_one,
+                    item["task_id"],
+                    item["acc_info"],
+                    proxy_dict,
+                    total,
                 )
+                futures.append(future)
 
-                loginer = DouyuLogin(
-                    account,
-                    proxy=proxy_dict,
-                    max_geetest_retries=self.max_geetest_retries,
-                )
-                result = loginer.login()
-
-                if result.success:
-                    task.status = "success"
-                    task.cookie = result.cookie
-                    task.message = "登录成功"
-                    self._push_log("success", f"[{i+1}] {acc.username} 登录成功")
-                else:
-                    task.status = "failed"
-                    task.message = result.message
-                    self._push_log("error", f"[{i+1}] {acc.username} 登录失败: {result.message}")
-
-            except Exception as e:
-                task.status = "error"
-                task.message = str(e)
-                self._push_log("error", f"[{i+1}] {acc.username} 登录异常: {e}")
-
-            task.finished_at = datetime.utcnow()
-            self.db.commit()
+            # 等待所有任务完成
+            for future in as_completed(futures):
+                try:
+                    future.result()
+                except Exception as e:
+                    self._push_log("error", f"Worker 异常: {e}")
 
         self._push_log("info", f"批量登录任务 {batch_id} 完成")
         self._push_log("result", "")
+
+
+# 在模块末尾导入 SessionLocal（避免循环导入）
+from ..database import SessionLocal
diff --git a/web/frontend/src/api/modules.ts b/web/frontend/src/api/modules.ts
index b219a4f..2512f23 100644
--- a/web/frontend/src/api/modules.ts
+++ b/web/frontend/src/api/modules.ts
@@ -50,8 +50,8 @@ export const accountApi = {
 };
 
 export const loginApi = {
-  createBatch: (account_ids: number[], max_geetest_retries?: number) =>
-    api.post<any, any>('/login/batch', { account_ids, max_geetest_retries }),
+  createBatch: (account_ids: number[], max_geetest_retries?: number, concurrency?: number) =>
+    api.post<any, any>('/login/batch', { account_ids, max_geetest_retries, concurrency }),
   listTasks: (batch_id?: string) =>
     api.get<any, any[]>('/login/tasks', { params: batch_id ? { batch_id } : {} }),
   stop: (batch_id: string) => api.post<any, any>(`/login/stop/${batch_id}`),
diff --git a/web/frontend/src/pages/LoginTasksPage.tsx b/web/frontend/src/pages/LoginTasksPage.tsx
index 0a2fde7..3c067ea 100644
--- a/web/frontend/src/pages/LoginTasksPage.tsx
+++ b/web/frontend/src/pages/LoginTasksPage.tsx
@@ -1,8 +1,8 @@
 import { useEffect, useState, useRef, useMemo, useCallback } from 'react';
 import {
-  Table, Button, Select, message, Tag, Space, Card, Row, Col, Statistic, Spin,
+  Table, Button, Select, message, Tag, Space, Card, Row, Col, Statistic, Spin, InputNumber, Tooltip,
 } from 'antd';
-import { PlayCircleOutlined, StopOutlined, FilterOutlined } from '@ant-design/icons';
+import { PlayCircleOutlined, StopOutlined, FilterOutlined, ThunderboltOutlined, ReloadOutlined } from '@ant-design/icons';
 import { accountApi, loginApi } from '../api/modules';
 import { getUser, hasPerm } from '../store/auth';
 
@@ -31,6 +31,7 @@ export default function LoginTasksPage() {
   const [logs, setLogs] = useState<{ level: string; message: string }[]>([]);
   const [wsConnected, setWsConnected] = useState(false);
   const [selectedTags, setSelectedTags] = useState<string[]>([]);
+  const [concurrency, setConcurrency] = useState(3);
   const wsRef = useRef<WebSocket | null>(null);
   const user = getUser();
 
@@ -111,15 +112,16 @@ export default function LoginTasksPage() {
     return () => clearInterval(timer);
   }, [batchId]);
 
-  const handleBatchLogin = async () => {
-    if (selectedIds.length === 0) {
+  // 共享的批量登录启动逻辑
+  const startBatch = async (accountIds: number[]) => {
+    if (accountIds.length === 0) {
       message.warning('请选择账号');
       return;
     }
     setLoading(true);
     setLogs([]);
     try {
-      const result = await loginApi.createBatch(selectedIds);
+      const result = await loginApi.createBatch(accountIds, 5, concurrency);
       setBatchId(result.batch_id);
       message.success(`已创建登录任务，共 ${result.count} 个账号`);
 
@@ -148,6 +150,27 @@ export default function LoginTasksPage() {
     }
   };
 
+  const handleBatchLogin = () => startBatch(selectedIds);
+
+  // 重试当前批次所有失败的任务
+  const handleRetryFailed = () => {
+    const failedIds = tasks
+      .filter((t) => ['failed', 'error'].includes(t.status))
+      .map((t) => t.account_id);
+    if (failedIds.length === 0) {
+      message.info('没有失败的任务');
+      return;
+    }
+    startBatch(failedIds);
+  };
+
+  // 重试单个失败任务
+  const handleRetryOne = (taskId: number) => {
+    const task = tasks.find((t) => t.id === taskId);
+    if (!task) return;
+    startBatch([task.account_id]);
+  };
+
   const handleStop = async () => {
     if (batchId) {
       try {
@@ -172,6 +195,25 @@ export default function LoginTasksPage() {
     },
     { title: '消息', dataIndex: 'message', ellipsis: true },
     { title: '时间', dataIndex: 'created_at', width: 180 },
+    {
+      title: '操作',
+      width: 80,
+      render: (_: any, record: any) => {
+        if (['failed', 'error'].includes(record.status) && !wsConnected) {
+          return (
+            <Button
+              type="link"
+              size="small"
+              icon={<ReloadOutlined />}
+              onClick={() => handleRetryOne(record.id)}
+            >
+              重试
+            </Button>
+          );
+        }
+        return null;
+      },
+    },
   ];
 
   return (
@@ -252,6 +294,17 @@ export default function LoginTasksPage() {
                   </>
                 )}
               />
+              <Tooltip title="同时登录的账号数，1为顺序执行">
+                <ThunderboltOutlined style={{ color: '#888' }} />
+              </Tooltip>
+              <InputNumber
+                min={1}
+                max={10}
+                value={concurrency}
+                onChange={(v) => setConcurrency(v || 1)}
+                style={{ width: 60 }}
+                size="small"
+              />
               <Button
                 type="primary"
                 icon={<PlayCircleOutlined />}
@@ -291,6 +344,19 @@ export default function LoginTasksPage() {
           <Card
             title="任务列表"
             size="small"
+            extra={
+              !wsConnected && failedCount > 0 && (
+                <Button
+                  type="primary"
+                  size="small"
+                  icon={<ReloadOutlined />}
+                  onClick={handleRetryFailed}
+                  loading={loading}
+                >
+                  重试失败 ({failedCount})
+                </Button>
+              )
+            }
             style={{ flex: 1, display: 'flex', flexDirection: 'column', minHeight: 0 }}
             bodyStyle={{ flex: 1, overflow: 'auto', padding: 0 }}
           >