Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

zbj//1.r_stat_zw_alarm_count_w 调度 2.r_stat_pw_alarm_count_w 调度 3.r_stat_area_alarm_count_m 调度

Browse Source
This commit is contained in:
zhangbaojian
2023-07-04 14:02:52 +08:00
parent e6f332165e
commit 106e63193d
4 changed files with 104 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RAlarmCountJob.java Normal file
View File

@@ -0,0 +1,41 @@
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.RAlarmCountFeignClient;
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 RAlarmCountJob {
private final RAlarmCountFeignClient rAlarmCountFeignClient;
@XxlJob("rAlarmCountWHandler")
public void rStartEventDHandler(){
OrgParam orgParam = new OrgParam();
orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_WEEK));
orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_WEEK));
rAlarmCountFeignClient.rAlarmCountHandler(orgParam);
}
@XxlJob("rAlarmCountMHandler")
public void rStartEventMHandler(){
OrgParam orgParam = new OrgParam();
orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
rAlarmCountFeignClient.rAlarmCountHandler(orgParam);
}
}

22
pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/RAlarmCountFeignClient.java Normal file
View File

@@ -0,0 +1,22 @@
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.RAlarmCountFeignClientFallbackFactory;
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 = "/rAlarmCount",//对应controller请求类
fallbackFactory = RAlarmCountFeignClientFallbackFactory.class//服务降级处理类
)
public interface RAlarmCountFeignClient {
@PostMapping("/rAlarmCountHandler")
HttpResult<Boolean> rAlarmCountHandler(@RequestBody OrgParam orgParam);
}

40
pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/RAlarmCountFeignClientFallbackFactory.java Normal file
View File

@@ -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.RAlarmCountFeignClient;
import com.njcn.prepare.harmonic.api.line.RStatEventFeignClient;
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 RAlarmCountFeignClientFallbackFactory implements FallbackFactory<RAlarmCountFeignClient> {
@Override
public RAlarmCountFeignClient 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 RAlarmCountFeignClient() {
@Override
public HttpResult<Boolean> rAlarmCountHandler(OrgParam orgParam) {
log.error("{}异常，降级处理，异常为：{}", "指标告警统计: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

2
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/newalgorithm/RAlarmCountController.java
View File

@@ -52,7 +52,7 @@ public class RAlarmCountController extends BaseController {
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@PostMapping("/rAlarmCount")
@PostMapping("/rAlarmCountHandler")
@ApiOperation("指标告警统计")
@ApiImplicitParam(name = "orgParam", value = "参数", required = true)
public HttpResult<String> rAlarmCountHandler(@RequestBody @Validated OrgParam orgParam) {