From 648a5e1947522f9bf2dbfe4f0ba6ef9d8eb789cf Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Fri, 22 Aug 2025 15:55:23 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E6=8B=9B=E9=80=BB=E8=BE=91=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9=EF=BC=8C=E6=89=8B=E5=8A=A8=E8=A1=A5=E6=8B=9B=E5=92=8C?=
 =?UTF-8?q?=E5=89=8D=E7=AB=AF=E9=87=87=E7=94=A8websokcet=E9=80=9A=E8=AE=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/njcn/dataProcess/api/DataRecallFeignClient.java    | 7 +++++++
 .../api/fallback/DataRecallFeignClientFallbackFactory.java | 7 +++++++
 2 files changed, 14 insertions(+)

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<List<String>> recall(@RequestBody RecallMessage param);
+
+    @PostMapping("/fullHourRecall")
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @ApiOperation("数据全量补招")
+    @ApiImplicitParam(name = "param", value = "参数", required = true)
+    public HttpResult<List<String>> 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<Dat
                 log.error("{}异常，降级处理，异常为：{}","补招接口调用异常",cause.toString());
                 throw new BusinessException(finalExceptionEnum);
             }
+
+            @Override
+            public HttpResult<List<String>> fullHourRecall(FullRecallMessage param) {
+                log.error("{}异常，降级处理，异常为：{}","按小时补招接口调用异常",cause.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
         };
     }
 }