|
|
@@ -89,7 +89,7 @@ public class STKTask {
|
|
|
log.info("开始获取深投控客商状态信息,结束:"+((System.currentTimeMillis()-date.getTime())/1000));
|
|
|
}*/
|
|
|
|
|
|
- @Scheduled(cron = "0 37 23 * * ?")
|
|
|
+ @Scheduled(cron = "0 42 23 * * ?")
|
|
|
public void getSellerOrders(){
|
|
|
log.info("开始获取深投控客商状态信息=========start=============");
|
|
|
Date date = new Date();
|
|
|
@@ -108,10 +108,17 @@ public class STKTask {
|
|
|
//异常跳过次数
|
|
|
Integer num = 0;
|
|
|
while(isBreak) {
|
|
|
+ if(num >=5){
|
|
|
+ break;
|
|
|
+ }
|
|
|
log.info("while循环获取客商数据,查询参数:{}",JSONObject.toJSONString(dto));
|
|
|
TravellingMerchantVo travellingMerchantVo = new TravellingMerchantVo();
|
|
|
try{
|
|
|
travellingMerchantVo = requestSTKService.selectTravellingMerchantList(dto, COMPLEXITY_QUERY_URL);
|
|
|
+ if(travellingMerchantVo.getCode() != 200){
|
|
|
+ num = num +1;
|
|
|
+ continue;
|
|
|
+ }
|
|
|
//获取到客商数据,数据入库
|
|
|
stkService.getCustvend(travellingMerchantVo, false);
|
|
|
}catch (Exception e){
|
|
|
@@ -119,9 +126,6 @@ public class STKTask {
|
|
|
exception = true;
|
|
|
num = num +1;
|
|
|
}
|
|
|
- if(num >=5){
|
|
|
- break;
|
|
|
- }
|
|
|
//判断没发生异常,且是最后一页条件判断==》没有下页编码,或者返回的数据量小于每次查询的每页数量
|
|
|
if (!exception && null != travellingMerchantVo && null != travellingMerchantVo.getData() && dto.getSize() > travellingMerchantVo.getData().getEndRow()){
|
|
|
isBreak = false;
|