提交 19b009d8 作者: 刘明祎-运维用途

修改不用绑定手机号也算邀请成功

上级 0382a548
...@@ -28,4 +28,7 @@ public class WxLoginVO implements Serializable { ...@@ -28,4 +28,7 @@ public class WxLoginVO implements Serializable {
private Integer fromPort; private Integer fromPort;
@ApiModelProperty(value = "用户来源:0自然流,1海报,2抖音,3公众号,4社群,5招投标,默认0", example = "0") @ApiModelProperty(value = "用户来源:0自然流,1海报,2抖音,3公众号,4社群,5招投标,默认0", example = "0")
private Integer source; private Integer source;
@ApiModelProperty(value = "邀请人user_account_id")
private Integer rcdUserId;
} }
...@@ -9,14 +9,22 @@ import com.mmc.iuav.user.auth.AuthHandler; ...@@ -9,14 +9,22 @@ import com.mmc.iuav.user.auth.AuthHandler;
import com.mmc.iuav.user.auth.PwdUtil; import com.mmc.iuav.user.auth.PwdUtil;
import com.mmc.iuav.user.client.PayClient; import com.mmc.iuav.user.client.PayClient;
import com.mmc.iuav.user.constant.WxConstant; import com.mmc.iuav.user.constant.WxConstant;
import com.mmc.iuav.user.controller.userpoints.config.NumberOfUserPoints;
import com.mmc.iuav.user.controller.userpoints.config.UserPointsEnum;
import com.mmc.iuav.user.dao.CompanyAuthDao; import com.mmc.iuav.user.dao.CompanyAuthDao;
import com.mmc.iuav.user.dao.RealNameAuthDao; import com.mmc.iuav.user.dao.RealNameAuthDao;
import com.mmc.iuav.user.dao.RoleDao; import com.mmc.iuav.user.dao.RoleDao;
import com.mmc.iuav.user.dao.UserServiceDao;
import com.mmc.iuav.user.dao.userpoints.UserPointsDao;
import com.mmc.iuav.user.dao.userpoints.UserPointsDetailsDao;
import com.mmc.iuav.user.entity.*; import com.mmc.iuav.user.entity.*;
import com.mmc.iuav.user.entity.userpoints.UserPointsDO;
import com.mmc.iuav.user.entity.userpoints.UserPointsDetails;
import com.mmc.iuav.user.enums.UserAccountStatus; import com.mmc.iuav.user.enums.UserAccountStatus;
import com.mmc.iuav.user.model.dto.LoginSuccessDTO; import com.mmc.iuav.user.model.dto.LoginSuccessDTO;
import com.mmc.iuav.user.model.qo.LoginUserQO; import com.mmc.iuav.user.model.qo.LoginUserQO;
import com.mmc.iuav.user.model.vo.*; import com.mmc.iuav.user.model.vo.*;
import com.mmc.iuav.user.model.vo.userpoints.UserPointsVO;
import com.mmc.iuav.user.service.*; import com.mmc.iuav.user.service.*;
import com.mmc.iuav.user.service.wallet.PayWalletService; import com.mmc.iuav.user.service.wallet.PayWalletService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
...@@ -39,6 +47,14 @@ import java.util.concurrent.TimeUnit; ...@@ -39,6 +47,14 @@ import java.util.concurrent.TimeUnit;
public class AuthServiceImpl implements AuthService { public class AuthServiceImpl implements AuthService {
@Autowired @Autowired
private UserServiceDao userServiceDao;
@Autowired
private ActivityService activityService;
@Autowired
private UserPointsDao userPointsDao;
@Autowired
private UserPointsDetailsDao userPointsDetailsDao;
@Autowired
private WxService wxService; private WxService wxService;
@Autowired @Autowired
...@@ -124,6 +140,32 @@ public class AuthServiceImpl implements AuthService { ...@@ -124,6 +140,32 @@ public class AuthServiceImpl implements AuthService {
AppUserSucVO appUserSucVO = authHandler.addAppLoginCache(userAccountVO); AppUserSucVO appUserSucVO = authHandler.addAppLoginCache(userAccountVO);
appUserSucVO.setAuthStatus(companyAuthStatus); appUserSucVO.setAuthStatus(companyAuthStatus);
appUserSucVO.setSessionKey(sessionKey); appUserSucVO.setSessionKey(sessionKey);
Integer id = appUserSucVO.getUserAccountId();
Integer rcdUserId = wxLoginVO.getRcdUserId();
Integer countUser = userServiceDao.getCountUser(rcdUserId);
if (countUser != null && countUser !=0) {
// if (rcdUserId != null) {
UserRcdDO userRcd = new UserRcdDO();
userRcd.setUserAccountId(id);
userRcd.setRcdUserId(rcdUserId);
userServiceDao.insertUserRcd(userRcd);
}
/**
* 积分
*/
extracted(id);
RealNameAuthDO realNameAuthByUId = realNameAuthDao.getRealNameAuthByUId(id);
if (realNameAuthByUId != null && realNameAuthByUId.getCheckStatus() == 1) {
realNameextracted(id);
}
// 奖励邀请人
if (rcdUserId != null) {
activityService.participateActivity(0, rcdUserId, id);
}
return ResultBody.success(appUserSucVO); return ResultBody.success(appUserSucVO);
} }
...@@ -210,4 +252,45 @@ public class AuthServiceImpl implements AuthService { ...@@ -210,4 +252,45 @@ public class AuthServiceImpl implements AuthService {
stringRedisTemplate.delete(randomLoginCode); stringRedisTemplate.delete(randomLoginCode);
return ResultBody.success(loginSuccessDTO); return ResultBody.success(loginSuccessDTO);
} }
private void extracted(Integer id) {
UserPointsVO userPointsVO = new UserPointsVO(id, NumberOfUserPoints.match(0).getMessage());
//积分
UserPointsDO pointsDO = userPointsDao.selectUserPoints(userPointsVO.getUserAccountId());
UserPointsDO points = null;
if (pointsDO != null) {
Integer totalPoints = userPointsVO.getTotalPoints();
Integer totalPoints1 = pointsDO.getTotalPoints();
totalPoints += totalPoints1;
userPointsVO.setTotalPoints(totalPoints);
points = new UserPointsDO(userPointsVO);
userPointsDao.updatePoints(points);
} else if (pointsDO == null) {
points = new UserPointsDO(userPointsVO);
userPointsDao.insertPoints(points);
}
UserPointsDetails userPointsDetails = new UserPointsDetails(id, NumberOfUserPoints.match(0).getMessage(), UserPointsEnum.match(0).getMessage());
userPointsDetailsDao.insertPointsDetails(userPointsDetails);
}
private void realNameextracted(Integer id) {
UserPointsVO userPointsVO = new UserPointsVO(id, NumberOfUserPoints.match(1).getMessage());
//积分
UserPointsDO pointsDO = userPointsDao.selectUserPoints(userPointsVO.getUserAccountId());
UserPointsDO points = null;
if (pointsDO != null) {
Integer totalPoints = userPointsVO.getTotalPoints();
Integer totalPoints1 = pointsDO.getTotalPoints();
totalPoints += totalPoints1;
userPointsVO.setTotalPoints(totalPoints);
points = new UserPointsDO(userPointsVO);
userPointsDao.updatePoints(points);
} else if (pointsDO == null) {
points = new UserPointsDO(userPointsVO);
userPointsDao.insertPoints(points);
}
UserPointsDetails userPointsDetails = new UserPointsDetails(id, NumberOfUserPoints.match(1).getMessage(), UserPointsEnum.match(1).getMessage());
userPointsDetailsDao.insertPointsDetails(userPointsDetails);
}
} }
...@@ -248,28 +248,28 @@ public class UserAccountServiceImpl implements UserAccountService { ...@@ -248,28 +248,28 @@ public class UserAccountServiceImpl implements UserAccountService {
userAccount.setPhoneNum(userPhoneNumber); userAccount.setPhoneNum(userPhoneNumber);
userServiceDao.update(userAccount); userServiceDao.update(userAccount);
System.out.println(userAccount); System.out.println(userAccount);
Integer countUser = userServiceDao.getCountUser(rcdUserId); // Integer countUser = userServiceDao.getCountUser(rcdUserId);
//
if (countUser != null && countUser !=0) { // if (countUser != null && countUser !=0) {
//// if (rcdUserId != null) {
// UserRcdDO userRcd = new UserRcdDO();
// userRcd.setUserAccountId(id);
// userRcd.setRcdUserId(rcdUserId);
// userServiceDao.insertUserRcd(userRcd);
// }
//
// /**
// * 积分
// */
// extracted(id);
// RealNameAuthDO realNameAuthByUId = realNameAuthDao.getRealNameAuthByUId(id);
// if (realNameAuthByUId != null && realNameAuthByUId.getCheckStatus() == 1) {
// realNameextracted(id);
// }
// // 奖励邀请人
// if (rcdUserId != null) { // if (rcdUserId != null) {
UserRcdDO userRcd = new UserRcdDO(); // activityService.participateActivity(0, rcdUserId, id);
userRcd.setUserAccountId(id); // }
userRcd.setRcdUserId(rcdUserId);
userServiceDao.insertUserRcd(userRcd);
}
/**
* 积分
*/
extracted(id);
RealNameAuthDO realNameAuthByUId = realNameAuthDao.getRealNameAuthByUId(id);
if (realNameAuthByUId != null && realNameAuthByUId.getCheckStatus() == 1) {
realNameextracted(id);
}
// 奖励邀请人
if (rcdUserId != null) {
activityService.participateActivity(0, rcdUserId, id);
}
return ResultBody.success(); return ResultBody.success();
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论