From c88ab642a7432446157ef97975e2de1a86b25b13 Mon Sep 17 00:00:00 2001 From: swordmeng Date: Wed, 12 Feb 2025 17:54:00 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=AF=B7=E6=B1=82=E5=A4=B1?= =?UTF-8?q?=E8=B4=A5=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../fallback/DatabaseFeignFallbackFactory.java | 55 +++++++++++++++------- 1 file changed, 38 insertions(+), 17 deletions(-) diff --git a/data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java b/data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java index b339f6b..2264bca 100644 --- a/data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java +++ b/data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java @@ -5,6 +5,9 @@ import com.huaxing.feign.IDatabaseClientFeign; import com.huaxing.pojo.entity.DatabaseDTO; import com.huaxing.pojo.entity.TableDTO; import feign.hystrix.FallbackFactory; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Component; /** * @ProjectName: data-bridge @@ -15,61 +18,79 @@ import feign.hystrix.FallbackFactory; * @Date: 2025/2/12 10:29 * @Version: 1.0 */ - +@Component public class DatabaseFeignFallbackFactory implements FallbackFactory { + + private static final Logger logger = LoggerFactory.getLogger(DatabaseFeignFallbackFactory.class); + @Override public IDatabaseClientFeign create(Throwable throwable) { + + /** + * 请求失败处理 + * 1. 创建数据库 + * 2. 创建Dfs表 + * 3. 创建Stream表 + * 4. 创建Dfs和Stream表订阅 + * 5. 创建Dfs和Stream表取消订阅 + * 6. 创建Stream表订阅 + * 7. 创建Stream表取消订阅 + * 8. 添加Dfs表字段 + * 9. 添加Stream表字段 + */ return new IDatabaseClientFeign() { - /** - * 创建数据库 - * @param query - * @return - */ @Override public ResultVo createDatabase(DatabaseDTO query) { - - ResultVo.fail(throwable.getMessage()); - return null; + logger.error("调用 data-storage-api 的 createDatabase 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } @Override public ResultVo createDfsTable(TableDTO tableDTO) { - return null; + logger.error("调用 data-storage-api 的 createDfsTable 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } @Override public ResultVo createStreamTable(TableDTO tableDTO) { - return null; + logger.error("调用 data-storage-api 的 createStreamTable 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } @Override public ResultVo createDfsAndStreamTableSubscribe(TableDTO tableDTO) { - return null; + logger.error("调用 data-storage-api 的 createDfsAndStreamTableSubscribe 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } @Override public ResultVo createDfsAndStreamTableUnsubscribe(TableDTO tableDTO) { - return null; + logger.error("调用 data-storage-api 的 createDfsAndStreamTableUnsubscribe 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } @Override public ResultVo subscribeStreamTable(TableDTO tableDTO) { - return null; + logger.error("调用 data-storage-api 的 subscribeStreamTable 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } @Override public ResultVo unsubscribeStreamTable(TableDTO tableDTO) { - return null; + logger.error("调用 data-storage-api 的 unsubscribeStreamTable 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } @Override public ResultVo addDfsColumns(TableDTO tableDTO) { - return null; + logger.error("调用 data-storage-api 的 addDfsColumns 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } @Override public ResultVo addStreamColumns(TableDTO tableDTO) { - return null; + logger.error("调用 data-storage-api 的 addStreamColumns 方法失败，原因: {}", throwable.getMessage()); + return ResultVo.fail(throwable.getMessage()); } }; }