From 90b3570f49b3d38432af22c7377f656472e61e67 Mon Sep 17 00:00:00 2001 From: zhangbaojian <1065122561@qq.com> Date: Tue, 4 Jul 2023 10:24:12 +0800 Subject: [PATCH] =?UTF-8?q?zbj//1.r=5Fstat=5Fevent=5Fd/m/q/m=20=E8=B0=83?= =?UTF-8?q?=E5=BA=A6=202.r=5Fstat=5Fevent=5Forg=5Fd/m/q/y=20=E8=B0=83?= =?UTF-8?q?=E5=BA=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../njcn/executor/handler/RStatEventJob.java | 59 +++++++++++++++++++ .../executor/handler/RStatEventOrgJob.java | 58 ++++++++++++++++++ .../api/line/RStatEventFeignClient.java | 21 +++++++ .../api/line/RStatEventOrgFeignClient.java | 21 +++++++ .../RStatEventFeignClientFallbackFactory.java | 41 +++++++++++++ ...tatEventOrgFeignClientFallbackFactory.java | 40 +++++++++++++ 6 files changed, 240 insertions(+) create mode 100644 pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RStatEventJob.java create mode 100644 pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RStatEventOrgJob.java create mode 100644 pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RStatEventFeignClient.java create mode 100644 pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RStatEventOrgFeignClient.java create mode 100644 pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RStatEventFeignClientFallbackFactory.java create mode 100644 pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RStatEventOrgFeignClientFallbackFactory.java diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RStatEventJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RStatEventJob.java new file mode 100644 index 000000000..da5ab99e3 --- /dev/null +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RStatEventJob.java @@ -0,0 +1,59 @@ +package com.njcn.executor.handler; + +import com.njcn.common.pojo.constant.BizParamConstant; +import com.njcn.executor.utils.CommonExecutorUtils; +import com.njcn.prepare.harmonic.api.line.HarmonicMetricFeignClient; +import com.njcn.prepare.harmonic.api.line.RStatEventFeignClient; +import com.njcn.prepare.harmonic.pojo.param.LineParam; +import com.njcn.prepare.harmonic.pojo.param.OrgParam; +import com.xxl.job.core.handler.annotation.XxlJob; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * pqs + * 暂态指标统计 + * @author zbj + * @date 2023/07/03 + */ +@Slf4j +@Component +@RequiredArgsConstructor +public class RStatEventJob { + + private final RStatEventFeignClient rStatEventFeignClient; + + @XxlJob("rStartEventDHandler") + public void rStartEventDHandler(){ + OrgParam orgParam = new OrgParam(); + orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY)); + orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY)); + rStatEventFeignClient.rStartEventHandler(orgParam); + } + + @XxlJob("rStartEventMHandler") + public void rStartEventMHandler(){ + OrgParam orgParam = new OrgParam(); + orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); + orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); + rStatEventFeignClient.rStartEventHandler(orgParam); + } + + @XxlJob("rStartEventQHandler") + public void rStartEventQHandler(){ + OrgParam orgParam = new OrgParam(); + orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_QUARTER)); + orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_QUARTER)); + rStatEventFeignClient.rStartEventHandler(orgParam); + } + + @XxlJob("rStartEventYHandler") + public void rStartEventYHandler(){ + OrgParam orgParam = new OrgParam(); + orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_YEAR)); + orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_YEAR)); + rStatEventFeignClient.rStartEventHandler(orgParam); + } + +} diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RStatEventOrgJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RStatEventOrgJob.java new file mode 100644 index 000000000..95d26c539 --- /dev/null +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RStatEventOrgJob.java @@ -0,0 +1,58 @@ +package com.njcn.executor.handler; + +import com.njcn.common.pojo.constant.BizParamConstant; +import com.njcn.executor.utils.CommonExecutorUtils; +import com.njcn.prepare.harmonic.api.line.RStatEventFeignClient; +import com.njcn.prepare.harmonic.api.line.RStatEventOrgFeignClient; +import com.njcn.prepare.harmonic.pojo.param.OrgParam; +import com.xxl.job.core.handler.annotation.XxlJob; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * pqs + * 单位暂态指标数据统计 + * @author zbj + * @date 2023/07/04 + */ +@Slf4j +@Component +@RequiredArgsConstructor +public class RStatEventOrgJob { + + private final RStatEventOrgFeignClient rStatEventOrgFeignClient; + + @XxlJob("rStartEventOrgDHandler") + public void rStartEventOrgDHandler(){ + OrgParam orgParam = new OrgParam(); + orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY)); + orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY)); + rStatEventOrgFeignClient.rStartEventOrgHandler(orgParam); + } + + @XxlJob("rStartEventOrgMHandler") + public void rStartEventOrgMHandler(){ + OrgParam orgParam = new OrgParam(); + orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); + orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); + rStatEventOrgFeignClient.rStartEventOrgHandler(orgParam); + } + + @XxlJob("rStartEventOrgQHandler") + public void rStartEventOrgQHandler(){ + OrgParam orgParam = new OrgParam(); + orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_QUARTER)); + orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_QUARTER)); + rStatEventOrgFeignClient.rStartEventOrgHandler(orgParam); + } + + @XxlJob("rStartEventOrgYHandler") + public void rStartEventOrgYHandler(){ + OrgParam orgParam = new OrgParam(); + orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_YEAR)); + orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_YEAR)); + rStatEventOrgFeignClient.rStartEventOrgHandler(orgParam); + } + +} diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RStatEventFeignClient.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RStatEventFeignClient.java new file mode 100644 index 000000000..c726e2a7a --- /dev/null +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RStatEventFeignClient.java @@ -0,0 +1,21 @@ +package com.njcn.prepare.harmonic.api.line; + +import com.njcn.common.pojo.constant.ServerInfo; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.prepare.harmonic.api.line.fallback.RStatEventFeignClientFallbackFactory; +import com.njcn.prepare.harmonic.pojo.param.OrgParam; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; + +@FeignClient( + value = ServerInfo.PREPARE_BOOT,//对应模块名 + path = "/rStartEvent",//对应controller请求类 + fallbackFactory = RStatEventFeignClientFallbackFactory.class//服务降级处理类 +) +public interface RStatEventFeignClient { + + @PostMapping("/rStartEventHandler") + HttpResult rStartEventHandler(@RequestBody OrgParam orgParam); + +} diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RStatEventOrgFeignClient.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RStatEventOrgFeignClient.java new file mode 100644 index 000000000..a3e0f53bc --- /dev/null +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RStatEventOrgFeignClient.java @@ -0,0 +1,21 @@ +package com.njcn.prepare.harmonic.api.line; + +import com.njcn.common.pojo.constant.ServerInfo; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.prepare.harmonic.api.line.fallback.RStatEventOrgFeignClientFallbackFactory; +import com.njcn.prepare.harmonic.pojo.param.OrgParam; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; + +@FeignClient( + value = ServerInfo.PREPARE_BOOT,//对应模块名 + path = "/rStartEventOrg",//对应controller请求类 + fallbackFactory = RStatEventOrgFeignClientFallbackFactory.class//服务降级处理类 +) +public interface RStatEventOrgFeignClient { + + @PostMapping("/rStartEventOrgHandler") + HttpResult rStartEventOrgHandler(@RequestBody OrgParam orgParam); + +} diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RStatEventFeignClientFallbackFactory.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RStatEventFeignClientFallbackFactory.java new file mode 100644 index 000000000..c251b78fe --- /dev/null +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RStatEventFeignClientFallbackFactory.java @@ -0,0 +1,41 @@ +package com.njcn.prepare.harmonic.api.line.fallback; + +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.exception.BusinessException; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.device.biz.utils.DeviceEnumUtil; +import com.njcn.prepare.harmonic.api.line.HarmOverLimitFeignClient; +import com.njcn.prepare.harmonic.api.line.RStatEventFeignClient; +import com.njcn.prepare.harmonic.pojo.param.LineParam; +import com.njcn.prepare.harmonic.pojo.param.OrgParam; +import feign.hystrix.FallbackFactory; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * @author zbj + */ +@Slf4j +@Component +public class RStatEventFeignClientFallbackFactory implements FallbackFactory { + + @Override + public RStatEventFeignClient create(Throwable throwable) { + Enum exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK; + if (throwable.getCause() instanceof BusinessException) { + BusinessException businessException = (BusinessException)throwable.getCause(); + exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult()); + } + + Enum finalExceptionEnum = exceptionEnum; + return new RStatEventFeignClient() { + + @Override + public HttpResult rStartEventHandler(OrgParam orgParam) { + log.error("{}异常，降级处理，异常为：{}", "暂态指标统计: ", throwable.toString()); + throw new BusinessException(finalExceptionEnum); + } + + }; + } +} diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RStatEventOrgFeignClientFallbackFactory.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RStatEventOrgFeignClientFallbackFactory.java new file mode 100644 index 000000000..2c5938c17 --- /dev/null +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RStatEventOrgFeignClientFallbackFactory.java @@ -0,0 +1,40 @@ +package com.njcn.prepare.harmonic.api.line.fallback; + +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.exception.BusinessException; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.device.biz.utils.DeviceEnumUtil; +import com.njcn.prepare.harmonic.api.line.RStatEventFeignClient; +import com.njcn.prepare.harmonic.api.line.RStatEventOrgFeignClient; +import com.njcn.prepare.harmonic.pojo.param.OrgParam; +import feign.hystrix.FallbackFactory; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * @author zbj + */ +@Slf4j +@Component +public class RStatEventOrgFeignClientFallbackFactory implements FallbackFactory { + + @Override + public RStatEventOrgFeignClient create(Throwable throwable) { + Enum exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK; + if (throwable.getCause() instanceof BusinessException) { + BusinessException businessException = (BusinessException)throwable.getCause(); + exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult()); + } + + Enum finalExceptionEnum = exceptionEnum; + return new RStatEventOrgFeignClient() { + + @Override + public HttpResult rStartEventOrgHandler(OrgParam orgParam) { + log.error("{}异常，降级处理，异常为：{}", "暂态指标统计: ", throwable.toString()); + throw new BusinessException(finalExceptionEnum); + } + + }; + } +}