czg_team
/
video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

15人达标奖励领取条件需要实名认证

This commit is contained in:
张松 2025-01-10 13:55:42 +08:00
parent 9976e12396
commit 3231f9c3f4
1 changed files with 18 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/main/java/com/sqx/modules/job/task/TempOrdersTask.java
View File

@ -8,14 +8,8 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.sqx.common.utils.DateUtils; import com.sqx.common.utils.DateUtils;
import com.sqx.modules.app.entity.InviteAchievement; import com.sqx.modules.app.entity.*;
import com.sqx.modules.app.entity.UserEntity; import com.sqx.modules.app.service.*;
import com.sqx.modules.app.entity.UserMoney;
import com.sqx.modules.app.entity.UserMoneyDetails;
import com.sqx.modules.app.service.InviteAchievementService;
import com.sqx.modules.app.service.UserMoneyDetailsService;
import com.sqx.modules.app.service.UserMoneyService;
import com.sqx.modules.app.service.UserService;
import com.sqx.modules.common.service.CommonInfoService; import com.sqx.modules.common.service.CommonInfoService;
import com.sqx.modules.complet.entity.CompletAward; import com.sqx.modules.complet.entity.CompletAward;
import com.sqx.modules.complet.service.CompletAwardService; import com.sqx.modules.complet.service.CompletAwardService;
@ -47,6 +41,8 @@ import javax.annotation.Resource;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@Component @Component
@ -83,13 +79,15 @@ public class TempOrdersTask {
private final InviteAchievementService inviteAchievementService; private final InviteAchievementService inviteAchievementService;
private final CourseService courseService; private final CourseService courseService;
private final SysUserMoneyDetailsService sysUserMoneyDetailsService; private final SysUserMoneyDetailsService sysUserMoneyDetailsService;
private final UserInfoService userInfoService;
private Logger logger = LoggerFactory.getLogger(getClass()); private Logger logger = LoggerFactory.getLogger(getClass());
public TempOrdersTask(InviteAchievementService inviteAchievementService, CourseService courseService, SysUserMoneyDetailsService sysUserMoneyDetailsService) { public TempOrdersTask(InviteAchievementService inviteAchievementService, CourseService courseService, SysUserMoneyDetailsService sysUserMoneyDetailsService, UserInfoService userInfoService) {
this.inviteAchievementService = inviteAchievementService; this.inviteAchievementService = inviteAchievementService;
this.courseService = courseService; this.courseService = courseService;
this.sysUserMoneyDetailsService = sysUserMoneyDetailsService; this.sysUserMoneyDetailsService = sysUserMoneyDetailsService;
this.userInfoService = userInfoService;
} }
@Scheduled(cron = "0 0/10 * * * ? ") @Scheduled(cron = "0 0/10 * * * ? ")
@ -255,11 +253,17 @@ public class TempOrdersTask {
} }
} }
int count = inviteAchievementService.count( // int count = inviteAchievementService.count(
new LambdaQueryWrapper<InviteAchievement>() // new LambdaQueryWrapper<InviteAchievement>()
.eq(InviteAchievement::getUserId, sourceUser.getUserId()) // .eq(InviteAchievement::getUserId, sourceUser.getUserId())
.eq(InviteAchievement::getState, 1)); // .eq(InviteAchievement::getState, 1));
logger.info("邀请人员: {}", count); Set<Long> byUserIdList = inviteAchievementService.list(new LambdaQueryWrapper<InviteAchievement>().eq(InviteAchievement::getUserId, sourceUser.getUserId())
.eq(InviteAchievement::getState, 1).select(InviteAchievement::getTargetUserId)).stream().map(InviteAchievement::getTargetUserId).collect(Collectors.toSet());
int count = 0;
if (!byUserIdList.isEmpty()) {
count = userInfoService.count(new LambdaQueryWrapper<UserInfo>().in(UserInfo::getUserId, byUserIdList).isNotNull(UserInfo::getAccountNo));
}
logger.info("邀请达标人员: {}", count);
//count 邀请的已达标人数 //count 邀请的已达标人数
for (CompletAward completAward : completAwardService.list(new QueryWrapper<CompletAward>().eq("invite_count", count).eq("status", 1))) { for (CompletAward completAward : completAwardService.list(new QueryWrapper<CompletAward>().eq("invite_count", count).eq("status", 1))) {
QueryWrapper<UserMoneyDetails> moneyDetailsQuery = new QueryWrapper<>(); QueryWrapper<UserMoneyDetails> moneyDetailsQuery = new QueryWrapper<>();