bihuisong hai 1 ano
pai
achega
fd821f6460

+ 2 - 2
src/main/java/com/sooka/sponest/dataexchange/exchange/controller/ExchangeController.java

@@ -84,8 +84,8 @@ public class ExchangeController {
     // TODO: 2024/1/6 0006 订阅  被119调用  掉用event 更新redis缓存
     @PostMapping("/subscribeTo")
     @ResponseBody
-    public R<?> dataSubscribeTo() {
-        R<?> result = remoteEventBaseService.subscribeTo();
+    public R<?> dataSubscribeTo(@RequestBody List<String> list) {
+        R<?> result = remoteEventBaseService.subscribeTo(list);
         if (result.getCode() == 200) {
             redisService.deleteObject("eventKey");
             return R.ok("操作成功");

+ 1 - 1
src/main/java/com/sooka/sponest/dataexchange/remoteapi/fallback/center/event/RemoteEventBaseServiceFallbackFactory.java

@@ -30,7 +30,7 @@ public class RemoteEventBaseServiceFallbackFactory implements FallbackFactory<Re
             }
 
             @Override
-            public R<?> subscribeTo() {
+            public R<?> subscribeTo(List<String> list) {
                 return null;
             }
 

+ 1 - 1
src/main/java/com/sooka/sponest/dataexchange/remoteapi/service/center/event/RemoteEventBaseService.java

@@ -25,7 +25,7 @@ public interface RemoteEventBaseService {
     public R<?> saveDataExchangeEntity(List<DataExchangeEntity> list);
 
     @PostMapping("/subscribeTo")
-    public R<?> subscribeTo();
+    public R<?> subscribeTo(List<String> list);
 
 
     @PostMapping("/getDataSubscribeTo")