Merge remote-tracking branch 'origin/test' into test

This commit is contained in:
Tankaikai
2025-01-09 11:48:33 +08:00
7 changed files with 157 additions and 155 deletions

View File

@@ -52,7 +52,7 @@ public class AppUserPrizeExchangeController {
@PostMapping("/receive")
@ApiOperation("领取满签奖励")
public Result receive(@RequestAttribute("userId") Long userId) {
userService.addBlackUser(userId);
userService.addBlackUser(userId,"领取满签奖励");
return Result.success();
}
}

View File

@@ -17,7 +17,6 @@ import java.math.BigDecimal;
/**
* 用户
*
*/
@Data
@ApiModel("用户")
@@ -132,6 +131,7 @@ public class UserEntity implements Serializable {
* 来源 app 小程序 公众号
*/
@Excel(name = "渠道来源", orderNum = "9")
@TableField(select = false)
private String platform;
/**
@@ -149,7 +149,7 @@ public class UserEntity implements Serializable {
/**
* 邀请人邀请码
*/
@Excel(name = "邀请人邀请码", orderNum = "6",width = 15)
@Excel(name = "邀请人邀请码", orderNum = "6", width = 15)
@TableField("inviter_code")
private String inviterCode;

View File

@@ -1,6 +1,7 @@
package com.sqx.modules.app.interceptor;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -94,9 +95,7 @@ public class AuthorizationInterceptor extends HandlerInterceptorAdapter {
log.warn("用户地址跳动频繁,封禁: {}", userId);
if (!redisService.isSetUserState(userId)) {
ThreadUtil.execAsync(() -> {
userService.update(null, new LambdaUpdateWrapper<UserEntity>()
.eq(UserEntity::getUserId, userId)
.set(UserEntity::getStatus, 0));
userService.addBlackUser(userId,"IP频繁跳动");
});
}
throw new CzgException("ip跳动过于频繁请联系管理员解封");

View File

@@ -241,6 +241,7 @@ public interface UserService extends IService<UserEntity> {
/**
* 封禁拉黑用户
* 用户行为
*/
void addBlackUser(Long userId);
void addBlackUser(Long userId,String behavior);
}

View File

@@ -1705,8 +1705,8 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
}
@Override
public void addBlackUser(Long userId) {
log.info("异常用户id, 异常操作: {}", userId);
public void addBlackUser(Long userId,String behavior) {
log.info("异常用户id, 异常操作: {},{}", userId,behavior);
UserInfo userInfo = userInfoService.getOne(new LambdaQueryWrapper<UserInfo>().eq(UserInfo::getUserId, userId));
if (userInfo != null && StrUtil.isNotBlank(userInfo.getCertNo())) {
TbUserBlacklist userBlacklist = new TbUserBlacklist();
@@ -1716,6 +1716,8 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
}
update(null, new LambdaUpdateWrapper<UserEntity>().eq(UserEntity::getUserId, userId)
.set(UserEntity::getStatus, 0).set(UserEntity::getUpdateTime,DateUtil.now()));
.set(UserEntity::getStatus, 0)
.set(UserEntity::getPlatform, behavior)
.set(UserEntity::getUpdateTime,DateUtil.now()));
}
}

View File

@@ -239,7 +239,7 @@ public class DiscSpinningController {
@RequestMapping("/app/discSpinning/receive")
@Login
public Result receive(@RequestAttribute("userId") Long userId) {
userService.addBlackUser(userId);
userService.addBlackUser(userId,"转盘奖项领取");
return Result.success().put("data", 1);
}

View File

@@ -111,7 +111,7 @@ public class TaskCenterController {
@Debounce(value = "#userId,#id")
public Result taskReceive(@ApiIgnore @RequestAttribute("userId") Long userId, Long id) {
if (id != null && id == 19) {
userService.addBlackUser(userId);
userService.addBlackUser(userId,"任务中心领取");
}
return taskCenterService.taskReceive(userId, id);
}