From 1d1dd1969b7a17f11fb8822af354ce1b5ceb4009 Mon Sep 17 00:00:00 2001 From: zren25 Date: Thu, 5 Jun 2025 14:12:54 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=88=9B=E5=BB=BA=E5=A7=94?= =?UTF-8?q?=E6=89=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../center/controller/EGEventSubscriptionController.java | 6 ++++++ .../ai/analytic/center/service/HuaWeiEGService.java | 9 ++++++++- 2 files changed, 14 insertions(+), 1 deletion(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/EGEventSubscriptionController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/EGEventSubscriptionController.java index 60b5bdb..dba8621 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/EGEventSubscriptionController.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/EGEventSubscriptionController.java @@ -64,6 +64,12 @@ public class EGEventSubscriptionController { return ResultDTO.success(huaWeiService.createConnection(req)); } + @PostMapping("/createAgencies") + public ResultDTO createAgencies(@RequestBody AgencyCreateReq req) { + return ResultDTO.success(huaWeiService.createAgencies(req)); + } + + /** * 创建事件订阅 * diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/HuaWeiEGService.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/HuaWeiEGService.java index 321933b..0564811 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/HuaWeiEGService.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/HuaWeiEGService.java @@ -24,7 +24,14 @@ public class HuaWeiEGService { @Resource EgClient egClient; - + public CreateAgenciesResponse createAgencies(AgencyCreateReq reqbody) { + CreateAgenciesRequest request = new CreateAgenciesRequest(); + request.setBody(reqbody); + log.info(HA_WEI_REQUEST, JSON.toJSONString(request)); + CreateAgenciesResponse response = egClient.createAgencies(request); + log.info(HA_WEI_RESPONSE, JSON.toJSONString(response)); + return response; + } /** * 发布事件到事件通道 sdk *