增加风控解禁记录

yt-arena/arena-service/src/main/java/com/ytpm/arena/monitor/RedisKeyExpirationListener.java

@@ -3,8 +3,10 @@ package com.ytpm.arena.monitor;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.arena.dao.AppUserMapper;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.risk.enums.BannedTypeEnum;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.data.redis.connection.Message;
 import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
@@ -25,6 +27,8 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
 
     @Resource
     private AppUserMapper appUserMapper;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * Creates new {@link } for {@code __keyevent@*__:expired} messages.
@@ -55,6 +59,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
             dyzUser.setUserId(arr[1]);
             dyzUser.setUserStatus(1);
             appUserMapper.updateUser(dyzUser);
+            riskFeign.addBlockingRecord(arr[1]);
         }
     }
 

yt-ios-lemon/lemon-ios-service/src/main/java/com/ytpm/lemonios/monitor/RedisKeyExpirationListener.java

@@ -2,9 +2,11 @@ package com.ytpm.lemonios.monitor;
 
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.app.model.YtDyzUser;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.lemonios.dao.AppUserMapper;
 import com.ytpm.risk.enums.BannedTypeEnum;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.data.redis.connection.Message;
 import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
@@ -25,6 +27,8 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
 
     @Resource
     private AppUserMapper appUserMapper;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * Creates new {@link } for {@code __keyevent@*__:expired} messages.
@@ -55,6 +59,7 @@ public class RedisKeyExpirationListener extends KeyExpirationEventMessageListene
             dyzUser.setUserId(arr[1]);
             dyzUser.setUserStatus(1);
             appUserMapper.updateUser(dyzUser);
+            riskFeign.addBlockingRecord(arr[1]);
         }
     }