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);