思迅客户端数据库网络超时不断软件
This commit is contained in:
parent
ad14d4f97c
commit
1671a2e1ee
@ -34,7 +34,7 @@ public class DynamicTaskScheduler {
|
|||||||
this.sxDataService = sxDataService;
|
this.sxDataService = sxDataService;
|
||||||
}
|
}
|
||||||
|
|
||||||
@PostConstruct
|
@PostConstruct
|
||||||
public void initTasks() {
|
public void initTasks() {
|
||||||
try {
|
try {
|
||||||
//初始化 start
|
//初始化 start
|
||||||
@ -109,8 +109,28 @@ public class DynamicTaskScheduler {
|
|||||||
refreshTime=DateUtil.formatDateTime(dataBaseInfo.getRefreshTime());
|
refreshTime=DateUtil.formatDateTime(dataBaseInfo.getRefreshTime());
|
||||||
commentModel.setSyncTime(refreshTime);
|
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(StringUtils.isNotEmpty(refreshTime)){//有刷新时间,证明不是全量,需要判断是否有新商品,有新商品才同步品牌和分类
|
||||||
if(sxDataService.isNewShop(dataBaseInfo,refreshTime)){
|
if(sxDataService.isNewShop(dataBaseInfo,refreshTime)){
|
||||||
sxDataService.SyncBranchList(dataBaseInfo,commentModel);
|
sxDataService.SyncBranchList(dataBaseInfo,commentModel);
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user