From 274d294b2ef7becbd8fde538a8562502ab3163a3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=93=AD=E5=9D=A4?=
 <10372463+ming-kun@user.noreply.gitee.com>
Date: Thu, 2 Apr 2026 23:03:13 +0800
Subject: [PATCH] 	modified:  
 app/amazon/__pycache__/del_brand.cpython-39.pyc 	modified:  
 app/amazon/__pycache__/main.cpython-39.pyc 	modified:   app/amazon/main.py
 	modified:   app/main.py

---
 .../__pycache__/del_brand.cpython-39.pyc      | Bin 14781 -> 14794 bytes
 app/amazon/__pycache__/main.cpython-39.pyc    | Bin 14950 -> 15382 bytes
 app/amazon/main.py                            |  89 +++++++++++-------
 app/main.py                                   |   4 +-
 4 files changed, 58 insertions(+), 35 deletions(-)

diff --git a/app/amazon/__pycache__/del_brand.cpython-39.pyc b/app/amazon/__pycache__/del_brand.cpython-39.pyc
index 656d6827168b03c4140699dc9e3145499e900dd6..950b0df98164e4a88fbd7cf2cd41892d68926f4a 100644
GIT binary patch
delta 126
zcmdm6e5#l?k(ZZ?0SFEYoy#=X$SY&SxMi}IQ3zw)<a#3ql`QTQz7)<B{$8e9mJ*&C
zmS)Bjfoztd07izw4TS+UEWr$#f}8Ifu`#NpgA8F{cwk>8R#A{xl3}H<pORS??U0gK
alBippT^d_t0F<80WO9j7VDnXz7c2m|-y}u=

delta 113
zcmX?AytkM)k(ZZ?0SNB$oXu3($SY&SxM8xEQ3zwy<a#3qg$3Lxd<z+CSxR_nSehAA
z__JAx0vH(z*AxcSumm$`3T%FC#KtIF6bdw;O01$Fu_VJvUq2<YEZQL@u_RHqIJ-1<
QGQY_sMxM=&OkS`607fk$Q~&?~

diff --git a/app/amazon/__pycache__/main.cpython-39.pyc b/app/amazon/__pycache__/main.cpython-39.pyc
index d1ed31bff55cdf0e43aab707dd70a14818a9106e..dcbaa46daffc12b2ce2eec3fbfeab419953cec77 100644
GIT binary patch
delta 4228
zcmb7HeQaFC5r4b)?%mzHcc1>e`0Uuum(NaOJC5@Kab=1jBmp;H#9(5K$r@ri*txxP
z9J~8+0f!_CjWAk3YGPBnO4Fv$5^6*vNKuPawW`{xLakc4YH39;F%lAOrHVhQLTC1!
z&nBWsJ!|L9+qXMAvorIX@s0G0$AdkAfT_W+?c}ff-h1q|;1y!xdn=4oT>gYSYxG(y
zI%&xLv=Z5(NuNAUS0Y<F>7JdYZ&;*rwj-1!<X+hlNkn$T&N)viJ#_SFFG~=<Q;tLq
zlb!M}kqNS0CZjK}?1mM*3&<fCkcD3em@texVWg&KTMOPHnRXVkE#Yp{x?Z;ff~LdA
zv<b@LDQHZa)>t{Kn4vf$v}wYY3wlvwl~XR}nW01@ur_&OtQ5XQgh#-Bp$j6c8N;?Z
zw84jUEghVoqsNJ6`-wKzCITR_idD~0JE-KXpdu*kq89(pJG8O2!UG3=SN^nU9hsL;
z7PpW|*;rgfw!loC%QbpT&0T=GQu+Jh3&vhBgYT0gB|jqjWpnBKWVejP`pNzBRO}#m
zK>jsmuL<#TT$H~K{s_Fz`FL+?_(;0DkMSP-yh}d4Y#rq>`RcNI^B~MzfRQ>a=a=0V
z(21AENg**PC8e^pY-h&cgSaV)1h1GsfkYh<1MZLq$ilAx7z>8F@dogPpl}0(QMdt*
z;$4qxz<bqg=)wcH>rPYQ9VfsUQ|=i;G@<pogiCms=RDl`Hs-Z`%x9ZvUHHaHn>InZ
zYHa`5FO&#ViSP?Qvr04&5fDD0!6}at<d?1SrX3czqFSwvq)lPrQB#yf(V-pMgBmNa
ztrOOu={y^>22GG@zW@ogDa;ANEw#5$c;xkXEQ2Z+LqO#A4}KY(?wcT^44jT9)u`1a
zO0UxVc{+=I!Fhh+V^*m)pz*zF&$O2<L+z7$@$}T|N?wtYS0;QJI6gk*cErIa3*yiV
zx8)YbjN3MZu}>Q-1_J^!5Upx!ISPa5+^ZC&qw$=gTh!Nzyo&UH%k0pMg^TL8_T_F&
z-IN>LyPQ>mO9KM=D#ZsCU(G@=A4&&>ms#T!Qtr<OsU5Z>!j%rGv^$p$371N{70jp7
z?wnj(Q5L&fskT~#(WCkBSR*3xk&2QGrk)EDFCc;<1ZMk`dF{$P*Jwq~yp19P`qZe<
ziz;~u5e0d*d4s>$CkC@NYqkLie=lBYqHg$~5ZKvEr{sqffA>EQJU@(NyS%x)oa~YA
z%9Z3%SzB2dK7`YSNcJOPva|9s>6N7F8~%H60^y85CSR^Pu<?Fi6A``@XKIl=h~xnz
zeL&`1>7GaDJiPZY$l$}gALj>TbM-ysA$g*@q@ln`_b<#(u2kKQTZiP2s|(3d`Mc_d
z$ipb!*OTfS?CwkVKEX%ibI}6x2+V#ABh@dPR@@$m65U0Kmjp?e6w@eKCNnFFg5FQP
zG)yeAfm&p&Op=1a%%P#-!89LD_#CV_2_l?x7Xib@xf4h-NECFaG68S+D}fP!p`hb#
z{WH*EI?%y%h$lb50|D=w%#HBC0D9S0kBwmxQ1IaDI$#3|k744tm{*wKbe{+^Qvrlu
z1mNAu0Yp&tu58MLasc6C!L(0=asUCrn*)fj9Xb&LfKX2dAo>9sSmZph!|If1+AqQi
z!wRNcm~YNI(+4O3NSqZy%|UI7lr{(-Iq6VQTz4lYCdlA#nQli|iJcQ=7l<%q%w@Z9
ztR2$X5`}<AMWP7A9TpL0LTpBq$WjpjgZ!dEcC9MQL_4rZk>npB;detucmbK-g^WNG
zH>vgUB_@`miLA_qU4VniyoKEh?@P@FxeX!;HEV;2hypMTI99RLG!rW3f;wb%(?dZK
zU?u_^EIp!*ue!w(F$eS0#<U0Oq(Z9XromHSqCTL*t~c3=r3bK;dHK(-uJ`3{RsL-C
z*1OQilWa|Hz2o_sytz74<^pIe=;Y#^N~gq9o#b6>Zuf(~lbf6ik<YAI6+6JFFaUOZ
zfVDVW!c@bOzgkn$T?|r!5R%1sol2tP=Xzm5snK)zyG^-6A8pOK151*NHRSc9j(&@-
zSh)JxJvA>9G9u>_O^uI2hVbJ^ZbccK<496S8iBM!t283-t$l~I%TV3z071Lz?koEW
zd>O_Xojp7K!PhTkuRoQ&c8#ZD;$L#MZq=&$fV)EZ2t4>shtDI(6(1kQ`D5}wb#>$(
znOIvzdgQLP`!gX2!}7@GpxG!c9z)_l7joN>v;dhiQoTL=&|!snohIu&(%o|?-8VGI
zefZUXbSRbXb~=|t$r7MDi2{^Li{Ns{=b(!+q0`5QM!Ne3S?_UW4IjeYN0GDw=`>OU
z!`(+xyj^y$YcmB*wG)89@5}G4d#;?4{2zrMp`RF^7$3tZvH%LZ)>kyUm!PZCX0a_Y
zK-R(!aV-c#VOx!Sd3|lYA@pg=4CV$%^C;fKyuf>fDwMWQ_~5%weK*I>Nxi<Q03*;1
z(T9UT1j3N*^|1^<;<OI&=vVRQW_|z%H_T})s_-U<NgZ0U4Pwv@kWiT`lGv<htWd2g
zN*lT6NM|aNRV0>RbChfYV1g%NU$RZOp&XVD{{{@oUOk<?IQwC}Nw%xNXn;9>42i0A
zaFv=9Nf>obO~m-(Pa-*m<Y^?Qk(@#Dlx%6-+v!<S3{`E!h~Vdt<ijTsaAG1KoKAC^
zcL2X7Bu?V)5&1!5x%pLK=g`fqGQ45=%Dj^adik?%_CnnYlZ{mF*^tO64?hE&Kl5LP
z7bg5Llye^ev1x2XiNKDQPU*IbxokZRB`epwZnNEE*WlhM(}kP4RaJs$fYqKH7P|V;
zo0NH(ua7X3L34W^db>>84gD=0N02f44Hg`r{FD*|T@?1T4$uIihxZ{2Q5L~<i`^~+
zj?Ubw&-|tOUT}*7g*gSV2Q5Nrg9xyc6|)iutqgRL$+&8>$mjzQK_0+crWRnM>&ewk
zT&gV|1qBN`P3SKFufv?yJZyVTc#?5IVt6*I@Pii!zh%Q1F4>DO{q6en&9~%@mnO4k
zuimkH$4A%CX0KiT;LQ2?S6{d>`DXU)8}eEITKQgcOn$TJjz*67Ib4ccuTH^|r2;Bz
zZocwL<<iCtmdW><1i)wa#`;Y5%<1f<Gmhx>>(^J-@H$w)dr{&hl=#CR%)k9MsBvTR
zWcJdxb2_{-bK`}pA6@@iPD!OOEV%jB+3cm)=3oC7-;DbsK<2NG-+cZ%V1on6w^j0S
zm`(UO1{d#hBdwKJHm+{@9579IoovX5=$vbqA6Z1ZIWHjT(V@Xqulz@2(Vdt|Q3@G=
ziff)Q(P<FCE>3lzlo&|=ZFo#-Lg(kDh0y86iABSZ3&pS!dD+q&Ctb3$`Hxk2=$tVy
z(!(E5@d|ix$a3VcB78|6*mMp4Uk_~_PaMQa{KuSQugMW{xiSrt(n)buM4p!wx0T3u
zH<!n{EE4|I>ad^>H9oO2S|Ch<pITc=*Uoyk>?ZI}@Pk`xNxwX`^-t~{-k_KK7rzP%
AQ~&?~

delta 3800
zcmai1X>43q6@K?Ev%Xoq&3NDKvEz8HQ`a?0R5!{((rnFQ#j%~aPQBI3n>Y2+`#dF%
z+H{F<xoIVmxY#I)2uL*4sEVK!YJopUAc~NRjQB%4N%&EI@B@jh;hg*Iu??j>>zz68
z+<VWxXZ!B)n=|)J|A5cuk>GKLemQ)5;0ONO#N&p~-S8%I`3L0dDh=Pz_({1`r8zfT
zoXM3cjoeUIZ^`fKWNo!KkS631e<BnM9fdV(&V)HJIXOsU#5l;U&=5Ju?}Zl0K0Y1(
zUS&VbFwOyqD?m0LKQKXfpMW=UZFO(fhoovB)4HYJcPyRBX7D*_kr<zwK_*9~Wr-Hi
z;uRSsyg4V@H8YpXq~#EEGMLL$MpiT;os!1SsgmhmlxGbhSzaQ|bu%5-meKMR+48{(
zLMxb$zns(M{n;sLZU=KN%EnFpQBDK-BY&9FMc(9Hxn-mUB=w3iJ1JyWK^Ebk<X&?e
zhqD?d_(I<M<Y~Sq@(DT0tD+<1Bwvi4C1?0&QLDyp6yc<PBxtiS0A$T=3?`CeX5TP1
z&ZF?F{Pp|>{?q&&o?iI825;gL|6BecuS+f@*~B5sB$ppAIFQne37l^r5$eW~>jx5d
z0NHrL!07M_XO@DSnG9wVDudY$!7I;5z&nKtROYxYQO%T@bAbToSkhJqk(e~1Foij&
z^NLI)>atvPm)mliDswH6Ziq&2t>u~fg;3!UD!j}?^*jkw_?Qc*f5|BndHCtV);RjV
zT+9xc9_GcZmSh@U0p+KpGZM|Ryz}01kNw*uHA##tdzoW}SZ?NqNb6#4Htw_}qux^z
zfm2M)k7tXK9OmGEE-XmlKD9!UCr%Z~?55J_m+a<YE~-bQQOP)FI+tBEANQC#hI=R8
z+1LTBDiF36E@`$l7}1#nGEZUJib^DzX7SgGqN&4>dTvO)-1XFJ6Do=`hmpT{`KBvq
z*70?x2xn*z!4g^uQPUanWrFt!zMKX??l=9+N%aL8isrZFXJsp31({+7pmJp6k{Mu%
zsGJJwhROj6KTuo{?H0$XW&w;^CIxC(kk1$ArGj9Y0`;UbAM>xcL`~U-DO(H+!f|Rv
za)pGp7z=^6x{Rq`>i0!?YA>1^t55y~QZ{|_(*4C3(^ua3^zL`lytw3^cL=1$Fp_;d
zP+CNe@rKgM<~RuUCUbGcouvnFzmdND(!DF+PG7#0zW#pt`|p+-6jx*;c^b(ezgT*U
zT;Q>?Zw2?G0D;PQ21v4m?~a!9zn3+(orKR=$mqbKIwU<v&L9~9vZj~==hvLZ;037P
zA!8KfW4yO~-|4f+B4n=Vlg31RFp=mRNDPn1!gl%puc9@CZToQXB#<6|VtUw&5A`LI
zanxZ<ak-*tXCLZyqrSdjbMRSX2Im)NNC|S!0{JVvi3_~HqO&PTR7EB(;wM3pD+ftL
z(Fy#?;S8SC!kFWs3&wOZSHMey*{S$Ma@;g#V=fzHzJ_|m0XLCm9%U&cF93<7#TyTX
z!UwOwoYU$y%yHY8LsiI958w)clyXx|;EKcYQm3VxavReHt|+}HE#IO%_e01fg}Rs<
za>>nn)FY6^%XIkG*OA4?uUEFF{Oib~P`~MB{&i%5l2}KUpyi+U1G0!;8(Bs?aDdPi
zVg<x5VbjY30{pU;6s&vuo2sLD#}v|R%PZ#Ph|}aQDOhmp2&C{sRqiuEnrDUVRaTe<
zpagGOS#yU0!*rGf7?#blLDLWmQqL|4>Jn{>uprptWnrLE8+6AbVkF<zPYbLNf4eGA
zSlBK`3b$BTglE7x0yKnm0ug_=`MuR@z{(~Tg351UK^6wffTP9REGyY|A{)I`)5o8z
zt}5{{oq7--VcnQGOWD?_@RzF#%7WlA6~=!=E4Jya+|bK^Uft-<_>%vty5mWV-V3y5
zeZC#<+KiPd6;=ZNZ0xQWJ!1FRw%wnv>GVRBr`qi(^ABpOiiW5xkXah>GZ&;CQiZw2
z>*Wt?@=`gVDFDfsgPs&x?FctAFWfRJW&)E`Scy@Sr9MCO6psV2yB5{iV*u=%nb(v#
zv236Ci(^28fOO5t7l}Z+)t7275i-N|x>f;b#w--je<2sj5=cxW%|H%AV>QDk>pmn;
z@z(lIfVGMGLj^}*B#GC4`ttIhzIikK-o^CYyG9bF{Nwtns>8tDmTmYrX!9BTx$QQd
z1CcS!%XZY0{ru35GIE|z>^RXCwBaxVf;KSD;pFF$*eHnH<4C%ItT_^c14ewv==nxN
zcFKsN$U8ZaF#GJjCziVf7XLrYh!gj?jfv^L;c+@RW8mQhU>Z}%?FQ20NQ@@?#uCO;
z_~9KG8`}U;&Kuf17Dx|(&l7j}M-8uQDv^oGkGA9~xg^X}JByptEl@1rt{+y!H6R-g
zIu@H$fp0DRH#_SZHKs1h)Il|XHHYAx)CIhg;T8PAaxoW-1JHrYJ$IGYH@4<!kde}e
z3jKmj3FITZe5x^;0%%;;AUi#FHbUO1)GP8%g%OE{1^TQb)G2AI8#2+cNM`HSTMX=a
zB$_Q|<(SU(9!sUUs88f$9`;yM-GEi_i%5t(WMm}yYe`yF;NI9N(x3?pHKvh>yAnJn
z*?EIGX5XrqO~ysOr#V6vcu(`OlxxeC*@1(2JBZ*LuOOF6kC<+UKa+fRE8CBgwqG!Y
zNDgt|y^5o|krZc$xcL}-ehdec6JOyCEhU?=b@;{A$0u82UJ+7M5m)#>wMgm~uqHOD
zgki@kFR7L?chV#yGPqx+3RQ;*)gZLaE1IR6cn!%52oWlT#62n-M=(^>!<3C?R5YO)
zfH}+%jje7wef%*D((E#X2>vAz4X{SLeGnaO{hsn?q7$&Rc?}R-{9<%y0AdqNV!NNd
z{?@1OE#Ln!zxUP+=yLWP+0UCwD)}qBiuq#O9xgw^c<PbHf(LgN?qB^5jM~-zSgElK
z79WN?-OF3rt1CrUvl$789f^#4)|4c4G_ST-)c9nm7Id}b48p%3STQnjApM8K=^-8x
zmLsyC@Xy){$vN)X_4_hZvgR0_9x$Fs{AZ95J!-h)(YvIT|K!ny82+1M1dw3kVqke1
zSZoGH(@qxwI9K_vI`jC&j-u#Uo%kQ>Cv<3P)X(*l<cG%Pq23<JU%lILgpdyI?yMuD
Oysh&OT8qo?BL4<(&5K?D

diff --git a/app/amazon/main.py b/app/amazon/main.py
index fd8472c..a238b1a 100644
--- a/app/amazon/main.py
+++ b/app/amazon/main.py
@@ -215,6 +215,7 @@ class TaskMonitor:
             
         try:
             # 处理每个国家
+            chunk_index =1
             for country_data in countries:
                 # 检查是否收到暂停请求
                 if task_id in runing_task and runing_task[task_id].get("stop_requested", False):
@@ -222,7 +223,7 @@ class TaskMonitor:
                     break  # 跳出循环，进入finally关闭店铺
                 
                 try:
-                    self.process_country(driver, country_data, task_id, result_id, shop_data)
+                    chunk_index = self.process_country(driver, country_data, task_id, result_id, shop_data,chunk_index)
                 except Exception as e:
                     country_name = country_data.get("country", "未知")
                     self.log(f"处理国家 {country_name} 失败: {str(e)}", "ERROR")
@@ -244,7 +245,7 @@ class TaskMonitor:
                 self.log(f"店铺 {shop_name} 已从执行列表中移除")
                 
     def process_country(self, driver: AmazoneDriver, country_data: Dict[str, Any], 
-                       task_id: int, result_id: int, shop_data: Dict[str, Any]):
+                       task_id: int, result_id: int, shop_data: Dict[str, Any],chunk_index:int):
         """处理单个国家的所有ASIN
         
         Args:
@@ -294,8 +295,8 @@ class TaskMonitor:
         # 如果切换失败，回传该国家所有ASIN为失败状态
         if not switch_success:
             self.log(f"切换到国家 {country} 失败，已重试 {max_retries} 次，将所有ASIN标记为失败", "ERROR")
-            self._report_all_asins_failed(country, items, task_id, shop_data)
-            return
+            chunk_index = self._report_all_asins_failed(country, items, task_id, shop_data,chunk_index)
+            return chunk_index
             
         # 切换到库存管理页面
         try:
@@ -304,8 +305,8 @@ class TaskMonitor:
         except Exception as e:
             self.log(f"切换页面失败: {str(e)}", "ERROR")
             # 切换页面失败也回传所有ASIN为失败
-            self._report_all_asins_failed(country, items, task_id, shop_data)
-            return
+            chunk_index = self._report_all_asins_failed(country, items, task_id, shop_data,chunk_index)
+            return chunk_index
             
         # 处理每个ASIN
         file_key = shop_data.get("fileKey", "")
@@ -321,15 +322,18 @@ class TaskMonitor:
             try:
                 self.log(f"[{idx}/{len(items)}] 处理ASIN: {asin_item.get('asin', '')}")
                 self.process_asin(driver, asin_item, country, task_id, result_id, 
-                                file_key, source_filename, total_rows)
+                                file_key, source_filename, total_rows,chunk_index)
             except Exception as e:
                 asin = asin_item.get("asin", "未知")
                 self.log(f"处理ASIN {asin} 失败: {str(e)}", "ERROR")
                 # 继续处理下一个ASIN
-                
+            chunk_index += 1
+        return chunk_index
+    
+
     def process_asin(self, driver: AmazoneDriver, asin_item: Dict[str, Any], 
                     country: str, task_id: int, result_id: int, file_key: str, 
-                    source_filename: str, total_rows: int):
+                    source_filename: str, total_rows: int,chunk_index:int):
         """处理单个ASIN并回传结果
         
         Args:
@@ -445,9 +449,9 @@ class TaskMonitor:
                 "files": [{
                     "fileKey": file_key,
                     "sourceFilename": source_filename,
-                    "chunkIndex": self.chunk_index,
+                    "chunkIndex": chunk_index,
                     "chunkTotal": total_rows,
-                    "processedRows": self.chunk_index,
+                    "processedRows": chunk_index,
                     "totalRows": total_rows,
                     "currentCountry": country,
                     "currentAsin": asin,
@@ -463,13 +467,12 @@ class TaskMonitor:
             
             self.post_result(task_id, payload)
             self.log(f"ASIN {asin} 结果已回传，状态: {status}")
-            self.chunk_index += 1
             
         except Exception as e:
             self.log(f"回传结果失败: {str(e)}", "ERROR")
             
     def _report_all_asins_failed(self, country: str, items: List[Dict[str, Any]], 
-                                 task_id: int, shop_data: Dict[str, Any]):
+                                 task_id: int, shop_data: Dict[str, Any],chunk_index:int):
         """将国家下所有ASIN标记为失败并回传
         
         Args:
@@ -499,9 +502,9 @@ class TaskMonitor:
                     "files": [{
                         "fileKey": file_key,
                         "sourceFilename": source_filename,
-                        "chunkIndex": self.chunk_index,
+                        "chunkIndex": chunk_index,
                         "chunkTotal": total_rows,
-                        "processedRows": self.chunk_index,
+                        "processedRows": chunk_index,
                         "totalRows": total_rows,
                         "currentCountry": country,
                         "currentAsin": asin,
@@ -516,37 +519,57 @@ class TaskMonitor:
                 }
                 
                 self.post_result(task_id, payload)
-                self.chunk_index += 1
+                chunk_index += 1
                 self.log(f"ASIN {asin} 失败状态已回传")
                 
             except Exception as e:
                 self.log(f"回传ASIN {asin} 失败状态时出错: {str(e)}", "ERROR")
-    
+        
+        return chunk_index
+
     def post_result(self, task_id: int, payload: Dict[str, Any]):
-        """回传结果到API
+        """回传结果到API（带重试机制）
         
         Args:
             task_id: 任务ID
             payload: 结果数据
         """
         url = f"{DELETE_BRAND_API_BASE}/api/delete-brand/tasks/{task_id}/result"
+        max_retries = 3  # 最多重试3次
         
-        try:
-            response = requests.post(
-                url,
-                json=payload,
-                headers={"Content-Type": "application/json"},
-                timeout=30,
-                verify=False  # 忽略SSL证书验证
-            )
-            print("【结果提交】：",payload)
-            if response.status_code == 200:
-                self.log(f"结果回传成功: {url}")
-            else:
-                self.log(f"结果回传失败，状态码: {response.status_code}", "WARNING")
+        for retry in range(max_retries):
+            try:
+                self.log(f"尝试回传结果 (第 {retry + 1}/{max_retries} 次)")
                 
-        except Exception as e:
-            self.log(f"调用API异常: {str(e)}", "ERROR")
+                response = requests.post(
+                    url,
+                    json=payload,
+                    headers={"Content-Type": "application/json"},
+                    timeout=30,
+                    verify=False  # 忽略SSL证书验证
+                )
+                print("【结果提交】：",payload)
+                
+                if response.status_code == 200:
+                    self.log(f"结果回传成功: {url}")
+                    return  # 成功后直接返回，不再重试
+                else:
+                    self.log(f"结果回传失败，状态码: {response.status_code}", "WARNING")
+                    # 如果还有重试机会，继续重试
+                    if retry < max_retries - 1:
+                        self.log(f"准备重试... ({retry + 1}/{max_retries})")
+                        time.sleep(2)  # 等待2秒后重试
+                    else:
+                        self.log(f"已达到最大重试次数，结果回传最终失败", "ERROR")
+                    
+            except Exception as e:
+                self.log(f"调用API异常: {str(e)}", "ERROR")
+                # 如果还有重试机会，继续重试
+                if retry < max_retries - 1:
+                    self.log(f"发生异常，准备重试... ({retry + 1}/{max_retries})")
+                    time.sleep(2)  # 等待2秒后重试
+                else:
+                    self.log(f"已达到最大重试次数，结果回传最终失败", "ERROR")
             
     def update_task_status(self, task_id: int, **kwargs):
         """更新任务状态
diff --git a/app/main.py b/app/main.py
index 955832a..6dbdfa9 100644
--- a/app/main.py
+++ b/app/main.py
@@ -268,8 +268,8 @@ class WindowAPI:
                 payload = json.loads(data)
             if not isinstance(payload, (dict, list)):
                 return {'success': False, 'error': '仅支持 JSON 对象或数组'}
-            if payload.get("type") == "delete-brand-run" and payload.get("data").get("taskId") in runing_task:
-                return {'success': False, 'error': '已存在正在执行的删除品牌任务'}
+            # if payload.get("type") == "delete-brand-run" and payload.get("data").get("taskId") in runing_task:
+            #     return {'success': False, 'error': '已存在正在执行的删除品牌任务'}
             # 判断当前店铺是否正在运行中
             if payload.get("data").get("items"):
                 shop_name = payload["data"]["items"][0]["shopName"]