diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/PmsStatisticsSpecialMonitorFeignClient.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/PmsStatisticsSpecialMonitorFeignClient.java index cec3dd59c..b94a5d533 100644 --- a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/PmsStatisticsSpecialMonitorFeignClient.java +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/PmsStatisticsSpecialMonitorFeignClient.java @@ -3,6 +3,7 @@ package com.njcn.prepare.harmonic.api.newalgorithm; import com.njcn.common.pojo.constant.ServerInfo; import com.njcn.common.pojo.response.HttpResult; +import com.njcn.prepare.harmonic.api.newalgorithm.fallback.PmsStatisticsSpecialMonitorFeignClientFallbackFactory; import com.njcn.prepare.harmonic.pojo.param.LineParam; import io.swagger.annotations.ApiOperation; import org.springframework.web.bind.annotation.PostMapping; @@ -11,7 +12,7 @@ import org.springframework.web.bind.annotation.RequestBody; @org.springframework.cloud.openfeign.FeignClient( value = ServerInfo.PREPARE_BOOT,//对应模块名 path = "/pmsStatisticsSpecialMonitor",//对应controller请求类 - fallbackFactory = RStatAbnormalFeignClientFallbackFactory.class//服务降级处理类 + fallbackFactory = PmsStatisticsSpecialMonitorFeignClientFallbackFactory.class//服务降级处理类 ) public interface PmsStatisticsSpecialMonitorFeignClient { diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/RMpInfluenceFallbackFactory.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/RMpInfluenceFallbackFactory.java index 62e9d8f3c..4c26820e4 100644 --- a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/RMpInfluenceFallbackFactory.java +++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/RMpInfluenceFallbackFactory.java @@ -12,7 +12,7 @@ import org.springframework.stereotype.Component; @Slf4j @Component -public class rMpInfluenceFallbackFactory implements FallbackFactory { +public class RMpInfluenceFallbackFactory implements FallbackFactory { @Override public RMpInfluenceFeignClient create(Throwable throwable) { Enum exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK; diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/rMpInfluenceFallbackFactory.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/rMpInfluenceFallbackFactory.java deleted file mode 100644 index 4c26820e4..000000000 --- a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/rMpInfluenceFallbackFactory.java +++ /dev/null @@ -1,33 +0,0 @@ -package com.njcn.prepare.harmonic.api.newalgorithm.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.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient; -import com.njcn.prepare.harmonic.pojo.param.LineParam; -import com.njcn.prepare.harmonic.utils.PrepareEnumUtil; -import feign.hystrix.FallbackFactory; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -@Slf4j -@Component -public class RMpInfluenceFallbackFactory implements FallbackFactory { - @Override - public RMpInfluenceFeignClient create(Throwable throwable) { - Enum exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK; - if (throwable.getCause() instanceof BusinessException) { - BusinessException businessException = (BusinessException)throwable.getCause(); - exceptionEnum = PrepareEnumUtil.getExceptionEnum(businessException.getResult()); - } - - Enum finalExceptionEnum = exceptionEnum; - return new RMpInfluenceFeignClient() { - @Override - public HttpResult rMpInfluenceMHandler(LineParam jobParam) { - log.error("{}异常,降级处理,异常为:{}", "影响特性: ", throwable.toString()); - throw new BusinessException(finalExceptionEnum); - } - }; - } -}