Browse Source

fix: updateAppsConfig同步忽略调用失败以兼容旧服务

hidewnd 1 tháng trước cách đây
mục cha
commit
28be692fed

+ 16 - 5
yt-middle/middle-platform/src/main/java/com/ytpm/middle/service/impl/AppServiceImpl.java

@@ -32,6 +32,8 @@ import javax.annotation.Resource;
 import java.util.Date;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 @Service
 public class AppServiceImpl implements AppService {
@@ -155,11 +157,20 @@ public class AppServiceImpl implements AppService {
         config.setTakuNativePid(app.getTakuNativePid());
         config.setTakuRewardPid(app.getTakuRewardPid());
         config.setTakuInterstitialPid(app.getTakuInterstitialPid());
-        List<String> apps = appMapper.getAppListForSuperior(app.getAppId());
-        AppConfigUpdateParam param = new AppConfigUpdateParam();
-        param.setDefaultConfig(config);
-        param.setApps(apps);
-        feignInvoker.invoke(old.getServiceName(), "updateAppsConfig", param);
+        // 忽略异常 旧服务兼容性处理
+        ExecutorService executor = Executors.newCachedThreadPool();
+        try {
+            executor.execute(() -> {
+                List<String> apps = appMapper.getAppListForSuperior(app.getAppId());
+                AppConfigUpdateParam param = new AppConfigUpdateParam();
+                param.setDefaultConfig(config);
+                param.setApps(apps);
+                feignInvoker.invoke(old.getServiceName(), "updateAppsConfig", param);
+            });
+        } catch (Exception ignored) {
+        } finally {
+            executor.shutdown();
+        }
         return Result.resultOk(RepMessage.GRANT_SUCCESS);
     }