ソースを参照

fix: 兼容旧包风控请求参数

hidewnd 4 日 前
コミット
80d5759c72

+ 6 - 2
yt-risk/risk-manage/src/main/java/com/ytpm/service/impl/RiskCheckServiceImpl.java

@@ -125,20 +125,24 @@ public class RiskCheckServiceImpl implements RiskCheckService {
         //增加用户风控记录
         riskUserService.addSystemBannedRecord(dyzUser, riskCode, bannedReason, bannedLimit);
         YtApp app = appMapper.selectRiskApp(dyzUser.getAppId());
-        YtPlatformUserApp platformUserApp = appMapper.selectParentApp(app.getSuperiorId());
+        YtPlatformUserApp platformUserApp = app == null ? null : appMapper.selectParentApp(app.getSuperiorId());
+        if(platformUserApp == null){
+            platformUserApp = appMapper.selectParentApp(dyzUser.getAppId());
+        }
         if (platformUserApp != null && StringUtils.isNotEmpty(platformUserApp.getServiceName())) {
             Integer chagneStatus =UserStatusEnum.LOCK.getCode();
             if ("344".equals(riskCode) || "345".equals(riskCode)) {
                 chagneStatus = UserStatusEnum.VISITOR_LOCK.getCode();
             }
             Integer finalChangeStatus = chagneStatus;
+            String serviceName = platformUserApp.getServiceName();
             scheduledExecutorService.schedule(() -> {
                 YtDyzUser next = new YtDyzUser();
                 next.setUserId(dyzUser.getUserId());
                 next.setUserStatus(finalChangeStatus);
                 next.setRiskCode(riskCode);
                 next.setRiskReason(bannedReason);
-                feignInvoker.invoke(platformUserApp.getServiceName(), "updateUserInfo", next);
+                feignInvoker.invoke(serviceName, "updateUserInfo", next);
             }, 300, TimeUnit.MILLISECONDS);
         }
         redisService.setTimeOutHoursStr("unlock_" + dyzUser.getUserId(), dyzUser.getAppId(), bannedLimit);