Commit 4bf27a2b authored by liqin's avatar liqin 💬

Merge branch 'master' of http://111.203.232.171:8888/licc/shop-mall into master

parents bc247b43 c11ce44d
...@@ -40,7 +40,7 @@ ...@@ -40,7 +40,7 @@
<module>wisenergy-service</module> <module>wisenergy-service</module>
<!--<module>wisenergy-shiro</module>--> <!--<module>wisenergy-shiro</module>-->
<module>wisenergy-web-admin</module> <module>wisenergy-web-admin</module>
<module>wisenergy-system</module>
</modules> </modules>
<!--POM属性变量--> <!--POM属性变量-->
......
package cn.wisenergy.service.app; package cn.wisenergy.service.app;
import org.springframework.stereotype.Service;
/**
* @author 86187
*/
public interface AerialDeliveryUserService { public interface AerialDeliveryUserService {
/** /**
* 空投池用户随机分配推荐人邀请码 * 空投池用户随机分配推荐人邀请码
......
...@@ -8,7 +8,6 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; ...@@ -8,7 +8,6 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.annotation.Id;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
......
...@@ -7,6 +7,7 @@ import cn.wisenergy.model.app.UsersDto; ...@@ -7,6 +7,7 @@ import cn.wisenergy.model.app.UsersDto;
import cn.wisenergy.model.vo.AerialDeliveryVo; import cn.wisenergy.model.vo.AerialDeliveryVo;
import cn.wisenergy.model.vo.UserPoolVo; import cn.wisenergy.model.vo.UserPoolVo;
import cn.wisenergy.service.Manager.RegistUserMoudleInitManager; import cn.wisenergy.service.Manager.RegistUserMoudleInitManager;
import cn.wisenergy.service.app.AerialDeliveryUserService;
import cn.wisenergy.service.app.UserLevelService; import cn.wisenergy.service.app.UserLevelService;
import cn.wisenergy.service.app.UserService; import cn.wisenergy.service.app.UserService;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
...@@ -47,6 +48,9 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U ...@@ -47,6 +48,9 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U
@Autowired @Autowired
private RegistUserMoudleInitManager registUserMoudleInit; private RegistUserMoudleInitManager registUserMoudleInit;
@Autowired
private AerialDeliveryUserService aerialDeliveryUserService;
@Autowired @Autowired
private RedisUtils redisUtils; private RedisUtils redisUtils;
...@@ -124,18 +128,18 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U ...@@ -124,18 +128,18 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U
String inviteCode = "0"; String inviteCode = "0";
beInvitedCode = "1"; beInvitedCode = "1";
int userLevel = 0; int userLevel = 0;
int frozen=0; int frozen = 0;
String headImage = Constants.Common.HEAD_POTRAIT; String headImage = Constants.Common.HEAD_POTRAIT;
usersMapper.insertbyint(userId, inviteCode, beInvitedCode, userLevel, headImage,frozen); usersMapper.insertbyint(userId, inviteCode, beInvitedCode, userLevel, headImage, frozen);
//初始化六张表 //初始化六张表
registUserMoudleInit.registUserMoudleInit(userId); registUserMoudleInit.registUserMoudleInit(userId);
} else { } else {
//插入用户手机号与推荐人邀请码 //插入用户手机号与推荐人邀请码
String inviteCode = "0"; String inviteCode = "0";
int userLevel = 0; int userLevel = 0;
int frozen=0; int frozen = 0;
String headImage = Constants.Common.HEAD_POTRAIT; String headImage = Constants.Common.HEAD_POTRAIT;
usersMapper.insertbyint(userId, inviteCode, beInvitedCode, userLevel, headImage,frozen); usersMapper.insertbyint(userId, inviteCode, beInvitedCode, userLevel, headImage, frozen);
//初始化六张表 //初始化六张表
registUserMoudleInit.registUserMoudleInit(userId); registUserMoudleInit.registUserMoudleInit(userId);
//用户的被邀请码,查询到推荐人用户,根据推荐人用户的邀请码查询/修改 //用户的被邀请码,查询到推荐人用户,根据推荐人用户的邀请码查询/修改
...@@ -159,8 +163,8 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U ...@@ -159,8 +163,8 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U
int idbc = Integer.valueOf(idb); int idbc = Integer.valueOf(idb);
//获取注册用户的id //获取注册用户的id
User use= usersMapper.getByUserId(userId); User use = usersMapper.getByUserId(userId);
int ida =use.getId(); int ida = use.getId();
//判断被邀请用户的创建时间是否比推荐人的用户时间晚 //判断被邀请用户的创建时间是否比推荐人的用户时间晚
if (idbc > ida) { if (idbc > ida) {
...@@ -178,14 +182,14 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U ...@@ -178,14 +182,14 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U
//根据插入的用户手机号,查询用户唯一ID //根据插入的用户手机号,查询用户唯一ID
if(null== usersMapper.getuserIdById(userId)|| "".equals(usersMapper.getuserIdById(userId))){ if (null == usersMapper.getuserIdById(userId) || "".equals(usersMapper.getuserIdById(userId))) {
Map map =new HashMap(); Map map = new HashMap();
map.put("code",1); map.put("code", 1);
map.put("msg","该用户不存在!"); map.put("msg", "该用户不存在!");
return map; return map;
} }
long yqm=usersMapper.getuserIdById(userId); long yqm = usersMapper.getuserIdById(userId);
//用户唯一ID调用生成6位邀请码 //用户唯一ID调用生成6位邀请码
String inviteCode = ShareCodeUtil.idToCode(yqm); String inviteCode = ShareCodeUtil.idToCode(yqm);
Integer userLevel = 0; Integer userLevel = 0;
...@@ -317,7 +321,10 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U ...@@ -317,7 +321,10 @@ public class UserServiceImpl extends ServiceImpl<UsersMapper, User> implements U
return R.error("推荐人不能是自己!"); return R.error("推荐人不能是自己!");
} }
//4、设置用户被邀请码 //更新推荐用户的等级或者直推人数
aerialDeliveryUserService.userSetBeinviteCode(userId, userCode.getUserId());
//5、设置用户被邀请码
user.setBeInvitedCode(inviteCode); user.setBeInvitedCode(inviteCode);
int count = usersMapper.edit(user); int count = usersMapper.edit(user);
if (count == 0) { if (count == 0) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment