diff --git a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataRecallFeignClient.java b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataRecallFeignClient.java index 3f1eaa5..6a8473b 100644 --- a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataRecallFeignClient.java +++ b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/DataRecallFeignClient.java @@ -7,6 +7,7 @@ import com.njcn.common.pojo.response.HttpResult; import com.njcn.dataProcess.api.fallback.DataIFeignClientFallbackFactory; import com.njcn.dataProcess.api.fallback.DataRecallFeignClientFallbackFactory; import com.njcn.dataProcess.dto.DataIDTO; +import com.njcn.dataProcess.param.FullRecallMessage; import com.njcn.dataProcess.param.LineCountEvaluateParam; import com.njcn.dataProcess.pojo.dto.CommonMinuteDto; import com.njcn.dataProcess.pojo.dto.DataIDto; @@ -32,4 +33,10 @@ public interface DataRecallFeignClient { @ApiOperation("数据补招") @ApiImplicitParam(name = "param", value = "参数", required = true) public HttpResult> recall(@RequestBody RecallMessage param); + + @PostMapping("/fullHourRecall") + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @ApiOperation("数据全量补招") + @ApiImplicitParam(name = "param", value = "参数", required = true) + public HttpResult> fullHourRecall(@RequestBody FullRecallMessage param); } diff --git a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/fallback/DataRecallFeignClientFallbackFactory.java b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/fallback/DataRecallFeignClientFallbackFactory.java index 126ee7b..240f187 100644 --- a/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/fallback/DataRecallFeignClientFallbackFactory.java +++ b/data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/api/fallback/DataRecallFeignClientFallbackFactory.java @@ -5,6 +5,7 @@ import com.njcn.common.pojo.exception.BusinessException; import com.njcn.common.pojo.response.HttpResult; import com.njcn.dataProcess.api.DataRecallFeignClient; +import com.njcn.dataProcess.param.FullRecallMessage; import com.njcn.dataProcess.util.DataProcessingEnumUtil; import com.njcn.message.message.RecallMessage; import feign.hystrix.FallbackFactory; @@ -44,6 +45,12 @@ public class DataRecallFeignClientFallbackFactory implements FallbackFactory> fullHourRecall(FullRecallMessage param) { + log.error("{}异常,降级处理,异常为:{}","按小时补招接口调用异常",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } }; } }