From 10dc23317e848cea946d92018c2a5f9bd5a19adc Mon Sep 17 00:00:00 2001 From: xjs <1294405880@qq.com> Date: Sat, 26 Feb 2022 18:23:16 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E7=BD=91=E7=BB=9C=E6=97=B6=E9=97=B4a?= =?UTF-8?q?pi=E5=AE=9A=E6=97=B6=E6=A3=80=E6=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/xjs/consts/ApiConst.java | 6 ++++ .../xjs/common/task/CheckApiStatusTask.java | 28 +++++++++++++++++-- .../xjs/time/controller/TimeController.java | 6 ++-- .../time/factory/impl/TimeFactoryImpl.java | 6 ++-- 4 files changed, 37 insertions(+), 9 deletions(-) diff --git a/xjs-business/xjs-business-common/src/main/java/com/xjs/consts/ApiConst.java b/xjs-business/xjs-business-common/src/main/java/com/xjs/consts/ApiConst.java index 14db02ad..8c2b65a6 100644 --- a/xjs-business/xjs-business-common/src/main/java/com/xjs/consts/ApiConst.java +++ b/xjs-business/xjs-business-common/src/main/java/com/xjs/consts/ApiConst.java @@ -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响应参数及名称----------------------------------- diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/task/CheckApiStatusTask.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/task/CheckApiStatusTask.java index 75d23c9f..1ad0e068 100644 --- a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/task/CheckApiStatusTask.java +++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/task/CheckApiStatusTask.java @@ -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状态
@@ -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 diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/time/controller/TimeController.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/time/controller/TimeController.java index 73976c96..364e24c3 100644 --- a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/time/controller/TimeController.java +++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/time/controller/TimeController.java @@ -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()); } diff --git a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/time/factory/impl/TimeFactoryImpl.java b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/time/factory/impl/TimeFactoryImpl.java index 00c92acd..864f88b5 100644 --- a/xjs-business/xjs-business-openapi/src/main/java/com/xjs/time/factory/impl/TimeFactoryImpl.java +++ b/xjs-business/xjs-business-openapi/src/main/java/com/xjs/time/factory/impl/TimeFactoryImpl.java @@ -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("时间接口调用异常"); }