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

上级为官方 优化执行

Browse Source
This commit is contained in:
wangw
2025-01-10 17:12:25 +08:00
parent a88b6a225c
commit a8444e34e6
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java
View File

@@ -276,6 +276,9 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
@Override @Override
public Map<String, Object> updateInvite(UserEntity userEntity, String format, Long userId, BigDecimal price) { public Map<String, Object> updateInvite(UserEntity userEntity, String format, Long userId, BigDecimal price) {
if(userEntity.getUserId().equals(1L)){
return new HashMap<>();
}
Map<String, Object> result = new HashMap<>(); Map<String, Object> result = new HashMap<>();
if (userEntity != null && userId != null && price != null) { if (userEntity != null && userId != null && price != null) {
Invite invite1 = inviteDao.selectInviteByUser(userEntity.getUserId(), userId, 1); Invite invite1 = inviteDao.selectInviteByUser(userEntity.getUserId(), userId, 1);

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

@@ -164,7 +164,7 @@ public class TempOrdersTask {
UserEntity user = userService.selectUserById(order.getUserId()); UserEntity user = userService.selectUserById(order.getUserId());
UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode()); UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
// UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode()); // UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
if (byUser != null && !byUser.getUserId().equals(1L)) { if (byUser != null) {
InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(user.getUserId()); InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(user.getUserId());
if (inviteAchievement == null) { if (inviteAchievement == null) {
inviteAchievement = new InviteAchievement(); inviteAchievement = new InviteAchievement();
@@ -177,6 +177,8 @@ public class TempOrdersTask {
} else { } else {
inviteAchievementService.incrCount(inviteAchievement.getId(), inviteAchievement.getUserId(), 1); inviteAchievementService.incrCount(inviteAchievement.getId(), inviteAchievement.getUserId(), 1);
} }
}
if (byUser != null && !byUser.getUserId().equals(1L)) {
ThreadUtil.execAsync(() -> { ThreadUtil.execAsync(() -> {
ThreadUtil.sleep(1000); ThreadUtil.sleep(1000);
activities(user, byUser); activities(user, byUser);
@@ -186,7 +188,6 @@ public class TempOrdersTask {
inviteService.updateInvite(byUser, DateUtil.now(), user.getUserId(), order.getPayMoney()); inviteService.updateInvite(byUser, DateUtil.now(), user.getUserId(), order.getPayMoney());
}); });
} }
//增加剧集支付次数 //增加剧集支付次数
ThreadUtil.execAsync(() -> { ThreadUtil.execAsync(() -> {
courseService.incrWeekPayCount(order.getCourseId()); courseService.incrWeekPayCount(order.getCourseId());
@@ -266,7 +267,7 @@ public class TempOrdersTask {
System.out.println(list.stream().map(UserInfo::getCertNo).collect(Collectors.toSet())); System.out.println(list.stream().map(UserInfo::getCertNo).collect(Collectors.toSet()));
count = userInfoService.list(new LambdaQueryWrapper<UserInfo>().in(UserInfo::getUserId, byUserIdList).isNotNull(UserInfo::getAccountNo).select(UserInfo::getCertNo)) count = userInfoService.list(new LambdaQueryWrapper<UserInfo>().in(UserInfo::getUserId, byUserIdList).isNotNull(UserInfo::getAccountNo).select(UserInfo::getCertNo))
.stream().map(UserInfo::getCertNo).collect(Collectors.toSet()).size(); .stream().map(UserInfo::getCertNo).collect(Collectors.toSet()).size();
}else { } else {
return; return;
} }
logger.info("邀请达标人员: {}", count); logger.info("邀请达标人员: {}", count);