From 6165ec1fa1703b93d34baf8c7fd5357c7d3fe7d5 Mon Sep 17 00:00:00 2001
From: liyj <1617420630@qq.com>
Date: Tue, 13 Jan 2026 16:41:54 +0800
Subject: [PATCH] =?UTF-8?q?=E6=80=9D=E8=BF=85=E5=AE=A2=E6=88=B7=E7=AB=AF?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E7=BD=91=E7=BB=9C=E8=B6=85=E6=97=B6?=
 =?UTF-8?q?=E4=B8=8D=E6=96=AD=E8=BD=AF=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../client/Schedule/DynamicTaskScheduler.java | 26 ++++++++++++++++---
 1 file changed, 23 insertions(+), 3 deletions(-)

diff --git a/client/src/main/java/com/small/client/Schedule/DynamicTaskScheduler.java b/client/src/main/java/com/small/client/Schedule/DynamicTaskScheduler.java
index 9cec2163..6cbd16b6 100644
--- a/client/src/main/java/com/small/client/Schedule/DynamicTaskScheduler.java
+++ b/client/src/main/java/com/small/client/Schedule/DynamicTaskScheduler.java
@@ -34,7 +34,7 @@ public class DynamicTaskScheduler {
         this.sxDataService = sxDataService;
     }
 
-   @PostConstruct
+    @PostConstruct
     public void initTasks() {
         try {
             //初始化 start
@@ -109,8 +109,28 @@ public class DynamicTaskScheduler {
             refreshTime=DateUtil.formatDateTime(dataBaseInfo.getRefreshTime());
             commentModel.setSyncTime(refreshTime);
         }
-        sxDataService.syncStoreData(dataBaseInfo,commentModel);//同步网上售卖流水
-
+        int i=0;
+        boolean isException=false;
+        while (i<3){
+            try {
+                sxDataService.syncStoreData(dataBaseInfo,commentModel);//同步网上售卖流水
+                break;
+            }catch (Exception e){
+                i++;
+                try {
+                    Thread.sleep(Long.parseLong("3000"));
+                } catch (InterruptedException ex) {
+                    log.info(ex.getMessage());
+                }
+                if(i==3){
+                    log.info(e.getMessage());
+                    isException=true;
+                }
+            }
+        }
+        if(isException){
+            return;
+        }
         if(StringUtils.isNotEmpty(refreshTime)){//有刷新时间，证明不是全量，需要判断是否有新商品，有新商品才同步品牌和分类
             if(sxDataService.isNewShop(dataBaseInfo,refreshTime)){
                 sxDataService.SyncBranchList(dataBaseInfo,commentModel);