1、网络时间api定时检查

pull/254/head
xjs 4 years ago
parent b61af0185b
commit 10dc23317e

@ -232,6 +232,12 @@ public class ApiConst {
*/
public static final String GAODE_EXTENSIONS_BASE = "base";
/**
* api
*/
public static final String TTD_PID = "pubmatic";
public static final String FMT = "json";
//-----------------------api响应参数及名称-----------------------------------

@ -17,6 +17,7 @@ import com.xjs.common.client.api.lq.LqDogDiaryFeignClient;
import com.xjs.common.client.api.lq.LqPoisonChickenFeignClient;
import com.xjs.common.client.api.roll.*;
import com.xjs.common.client.api.tianxing.*;
import com.xjs.common.client.api.time.TimeFeignClient;
import com.xjs.common.client.api.youdao.YouDaoFeignClient;
import com.xjs.consts.ApiConst;
import com.xjs.properties.*;
@ -35,8 +36,8 @@ import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.List;
import static com.xjs.consts.ApiConst.DEMOTE_ERROR;
import static com.xjs.consts.ApiConst.GAODE_EXTENSIONS_BASE;
import static com.xjs.consts.ApiConst.*;
import static com.xjs.consts.ApiConst.FMT;
import static com.xjs.consts.ReqConst.ERROR;
/**
@ -153,6 +154,9 @@ public class CheckApiStatusTask {
private YouDaoFeignClient youDaoFeignClient;
@Autowired
private BaiduAssociationFeignClient baiduAssociationFeignClient;
@Autowired
private TimeFeignClient timeFeignClient;
/**
* api <br>
@ -359,6 +363,12 @@ public class CheckApiStatusTask {
};
new Thread(runCheckBaiduAssociation).start();
Runnable runCheckNetworkTime = () -> {
log.info("线程启动:" + Thread.currentThread().getName());
this.checkNetworkTime();
};
new Thread(runCheckNetworkTime).start();
//this.checkAlapiJoke();
//this.checkBaiduTranslation();
//this.checkGaodeWeather();
@ -392,6 +402,7 @@ public class CheckApiStatusTask {
//this.checkTianXingWYY();
//this.checkYouDaoTranslation();
//this.checkBaiduAssociation();
//this.checkNetworkTime();
} catch (Exception e) {
@ -402,6 +413,19 @@ public class CheckApiStatusTask {
}
/**
* API
*/
private void checkNetworkTime() {
JSONObject jsonObject = timeFeignClient.timeApi(TTD_PID, FMT);
if (!jsonObject.containsKey(DEMOTE_ERROR)) {
return;
}
String[] info = this.getAnnotationInfo(TimeFeignClient.class).get(0);
this.selectAndUpdate(info);
log.error("检查网络时间API异常");
}
/**
* API

@ -32,9 +32,9 @@ public class TimeController {
return AjaxResult.success(time);
}
@GetMapping("localhostTime")
@ApiOperation("获取本地时间")
public AjaxResult getLocalhostTime() {
@GetMapping("serviceTime")
@ApiOperation("获取服务器时间")
public AjaxResult getServiceTime() {
return AjaxResult.success(DateUtil.now());
}

@ -13,7 +13,7 @@ import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.TimeZone;
import static com.xjs.consts.ApiConst.DEMOTE_ERROR;
import static com.xjs.consts.ApiConst.*;
/**
*
@ -30,9 +30,7 @@ public class TimeFactoryImpl implements TimeFactory {
@Override
public String getTime() {
String ttd_pid = "pubmatic";
String fmt = "json";
JSONObject jsonObject = timeFeignClient.timeApi(ttd_pid, fmt);
JSONObject jsonObject = timeFeignClient.timeApi(TTD_PID, FMT);
if (jsonObject.containsKey(DEMOTE_ERROR)) {
throw new ApiException("时间接口调用异常");
}

Loading…
Cancel
Save