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

user增加邀请人id，通过邀请码获取用户修改为id获取

Browse Source
This commit is contained in:
张松
2025-01-10 16:42:39 +08:00
parent 1e3cc8b217
commit a7147f875d
9 changed files with 43 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/sqx/modules/app/entity/UserEntity.java
View File

@@ -178,6 +178,11 @@ public class UserEntity implements Serializable {
*/
private String qdCode;
/**
* 邀请人id
*/
private Long inviterUserId;
/**
* 是否是新用户 1否
*/

2
src/main/java/com/sqx/modules/app/service/UserService.java
View File

@@ -233,4 +233,6 @@ public interface UserService extends IService<UserEntity> {
* 用户行为
*/
void addBlackUser(Long userId,String behavior);
UserEntity queryByInvitationCodeOrUserId(Long inviterUserId, String invitationCode);
}

21
src/main/java/com/sqx/modules/app/service/impl/UserServiceImpl.java
View File

@@ -473,7 +473,8 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
if (StringUtils.isEmpty(userInfo1.getInviterCode())) {
userInfo1.setInviterCode(commonInfoService.findOne(88).getValue());
}
UserEntity userEntity = queryByInvitationCode(userInfo1.getInviterCode());
UserEntity userEntity = queryByInvitationCodeOrUserId(userInfo1.getInviterUserId(), userInfo1.getInviterCode());
// UserEntity userEntity = queryByInvitationCode(userInfo1.getInviterCode());
if (userEntity != null && StringUtils.isEmpty(userInfo1.getQdCode())) {
userInfo1.setQdCode(userEntity.getQdCode());
}
@@ -763,7 +764,8 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
if (StringUtils.isEmpty(userInfo1.getInviterCode())) {
userInfo1.setInviterCode(commonInfoService.findOne(88).getValue());
}
UserEntity userEntity = queryByInvitationCode(userInfo1.getInviterCode());
UserEntity userEntity = queryByInvitationCodeOrUserId(userInfo1.getInviterUserId(), userInfo1.getInviterCode());
// UserEntity userEntity = queryByInvitationCode(userInfo1.getInviterCode());
//没有则生成新账号
userInfo1.setCreateTime(date);
userInfo1.setPlatform("抖音");
@@ -858,7 +860,8 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
if (StringUtils.isEmpty(userInfo1.getInviterCode())) {
userInfo1.setInviterCode(commonInfoService.findOne(88).getValue());
}
UserEntity userEntity = queryByInvitationCode(userInfo1.getInviterCode());
UserEntity userEntity = queryByInvitationCodeOrUserId(userInfo1.getInviterUserId(), userInfo1.getInviterCode());
// UserEntity userEntity = queryByInvitationCode(userInfo1.getInviterCode());
//没有则生成新账号
userInfo1.setCreateTime(date);
userInfo1.setPlatform("快手");
@@ -957,7 +960,8 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
}
} else {
userInfo.setInviterCode(commonInfoService.findOne(88).getValue());
userEntity = queryByInvitationCode(userInfo.getInviterCode());
userEntity = queryByInvitationCodeOrUserId(userInfo.getInviterUserId(), userInfo.getInviterCode());
// userEntity = queryByInvitationCode(userInfo.getInviterCode());
}
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String time = simpleDateFormat.format(new Date());
@@ -1673,4 +1677,13 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
.set(UserEntity::getPlatform, behavior)
.set(UserEntity::getUpdateTime,DateUtil.now()));
}
@Override
public UserEntity queryByInvitationCodeOrUserId(Long inviterUserId, String invitationCode) {
if (inviterUserId == null) {
return baseMapper.selectOne(new QueryWrapper<UserEntity>().eq("invitation_code", invitationCode));
}
return baseMapper.selectOne(new LambdaQueryWrapper<UserEntity>().eq(UserEntity::getUserId, inviterUserId));
}
}

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

@@ -189,7 +189,8 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
invite.setUserType(1);
inviteDao.insert(invite);
//同步二级
UserEntity two = userService.queryByInvitationCode(userEntity.getInviterCode());
UserEntity two = userService.queryByInvitationCodeOrUserId(userEntity.getInviterUserId(), userEntity.getInviterCode());
// UserEntity two = userService.queryByInvitationCode(userEntity.getInviterCode());
if (two != null) {
invite = new Invite();
invite.setState(0);
@@ -203,6 +204,7 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
UserEntity user = new UserEntity();
user.setUserId(userId);
user.setInviterCode(userEntity.getInvitationCode());
user.setInviterUserId(userEntity.getUserId());
userService.updateById(user);
// 金币
@@ -318,7 +320,8 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
result.put("oneUserId", userEntity.getUserId());
result.put("oneMoney", money);
}
UserEntity two = userService.queryByInvitationCode(userEntity.getInviterCode());
UserEntity two = userService.queryByInvitationCodeOrUserId(userEntity.getInviterUserId(), userEntity.getInviterCode());
// UserEntity two = userService.queryByInvitationCode(userEntity.getInviterCode());
if (two != null) {
Invite invite2 = inviteDao.selectInviteByUser(two.getUserId(), userId, 2);
if (invite2 == null) {

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

@@ -162,7 +162,8 @@ public class TempOrdersTask {
ordersService.insertOrders(order);
UserEntity user = userService.selectUserById(order.getUserId());
UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
// UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
if (byUser != null) {
InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(user.getUserId());
if (inviteAchievement == null) {

3
src/main/java/com/sqx/modules/pay/controller/app/AliPayController.java
View File

@@ -122,7 +122,8 @@ public class AliPayController {
orders.setPayTime(DateUtils.format(new Date()));
UserEntity user = userService.selectUserById(orders.getUserId());
UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
// UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
Map map = inviteService.updateInvite(byUser, format, user.getUserId(), orders.getPayMoney());
Object oneUserId = map.get("oneUserId");
if (oneUserId != null) {

6
src/main/java/com/sqx/modules/pay/service/impl/DyServiceImpl.java
View File

@@ -415,7 +415,8 @@ public class DyServiceImpl implements DyService {
ordersService.fillSysUserId(orders);
ordersService.updateById(orders);
UserEntity user = userService.selectUserById(orders.getUserId());
UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
// UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
Map map = inviteService.updateInvite(byUser, format, user.getUserId(), orders.getPayMoney());
Object oneUserId = map.get("oneUserId");
if(oneUserId!=null){
@@ -507,7 +508,8 @@ public class DyServiceImpl implements DyService {
ordersService.fillSysUserId(orders);
ordersService.updateById(orders);
UserEntity user = userService.selectUserById(orders.getUserId());
UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
// UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
Map map = inviteService.updateInvite(byUser, format, user.getUserId(), orders.getPayMoney());
Object oneUserId = map.get("oneUserId");
if(oneUserId!=null){

3
src/main/java/com/sqx/modules/pay/service/impl/KsServiceImpl.java
View File

@@ -191,7 +191,8 @@ public class KsServiceImpl implements KsService {
ordersService.fillSysUserId(orders);
ordersService.updateById(orders);
UserEntity user = userService.selectUserById(orders.getUserId());
UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
// UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
Map map = inviteService.updateInvite(byUser, format, user.getUserId(), orders.getPayMoney());
Object oneUserId = map.get("oneUserId");
if(oneUserId!=null){

6
src/main/java/com/sqx/modules/pay/service/impl/WxServiceImpl.java
View File

@@ -286,7 +286,8 @@ public class WxServiceImpl implements WxService {
orders.setStatus(1);
orders.setPayTime(DateUtils.format(new Date()));
UserEntity user = userService.selectUserById(orders.getUserId());
UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
// UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
Map map = inviteService.updateInvite(byUser, format, user.getUserId(), orders.getPayMoney());
Object oneUserId = map.get("oneUserId");
if(oneUserId!=null){
@@ -367,7 +368,8 @@ public class WxServiceImpl implements WxService {
orders.setPayTime(DateUtils.format(new Date()));
UserEntity user = userService.selectUserById(orders.getUserId());
UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
// UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
Map map = inviteService.updateInvite(byUser, format, user.getUserId(), orders.getPayMoney());
Object oneUserId = map.get("oneUserId");
if(oneUserId!=null){