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 *