|
@@ -529,6 +529,14 @@ public class RiskServiceImpl extends ReflectUtil implements RiskService {
|
|
|
* 风控锁定用户
|
|
* 风控锁定用户
|
|
|
*/
|
|
*/
|
|
|
private void riskLockUser(String userId, String riskCode, String tempName, String errMsg) {
|
|
private void riskLockUser(String userId, String riskCode, String tempName, String errMsg) {
|
|
|
|
|
+ //增加用户风控记录
|
|
|
|
|
+ RiskBannedParam param = new RiskBannedParam();
|
|
|
|
|
+ param.setUserId(userId);
|
|
|
|
|
+ param.setBannedLimit(24);
|
|
|
|
|
+ param.setOperator("系统风控");
|
|
|
|
|
+ param.setBannedReason(tempName);
|
|
|
|
|
+ param.setOperatorName("系统风控");
|
|
|
|
|
+ addBannedRecord(Collections.singletonList(userId),param);
|
|
|
//懒得引入mq,因而利用线程池创建延迟定时任务修改用户状态,主线程继续执行,避免循环调用产生的死锁
|
|
//懒得引入mq,因而利用线程池创建延迟定时任务修改用户状态,主线程继续执行,避免循环调用产生的死锁
|
|
|
ScheduledExecutorService scheduled = Executors.newSingleThreadScheduledExecutor();
|
|
ScheduledExecutorService scheduled = Executors.newSingleThreadScheduledExecutor();
|
|
|
scheduled.schedule(()->{
|
|
scheduled.schedule(()->{
|