package project.user.internal;
|
|
import java.util.Arrays;
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.Arith;
|
import kernel.util.StringUtils;
|
import kernel.util.UUIDGenerator;
|
import project.Constants;
|
import project.log.MoneyLog;
|
import project.log.MoneyLogService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.party.model.UserRecom;
|
import project.party.recom.UserRecomService;
|
import project.syspara.Syspara;
|
import project.syspara.SysparaService;
|
import project.user.LocalNormalReg;
|
import project.user.LocalUserService;
|
import project.user.UserDataService;
|
import project.user.idcode.IdentifyingCodeTimeWindowService;
|
import project.wallet.Wallet;
|
import project.wallet.WalletExtend;
|
import project.wallet.WalletService;
|
import security.Role;
|
import security.RoleService;
|
import security.SaltSigureUtils;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
import util.LockFilter;
|
import util.Strings;
|
|
public class LocalUserServiceImpl implements LocalUserService {
|
|
private RoleService roleService;
|
|
private PartyService partyService;
|
|
private WalletService walletService;
|
|
protected JdbcTemplate jdbcTemplate;
|
|
private SecUserService secUserService;
|
|
private SysparaService sysparaService;
|
|
private UserDataService userDataService;
|
|
private PasswordEncoder passwordEncoder;
|
|
private UserRecomService userRecomService;
|
|
protected MoneyLogService moneyLogService;
|
|
private IdentifyingCodeTimeWindowService identifyingCodeTimeWindowService;
|
|
public void saveRegister(LocalNormalReg reg, String type) {
|
reg.setUsername(reg.getUsername().trim());
|
reg.setPassword(reg.getPassword().trim());
|
|
if (!"null".equals(reg.getSafeword()) && !StringUtils.isEmptyString(reg.getSafeword())) {
|
reg.setSafeword(reg.getSafeword().trim());
|
}
|
|
String key = reg.getUsername();
|
String authcode = this.identifyingCodeTimeWindowService.getAuthCode(key);
|
|
if ((authcode == null) || (!authcode.equals(reg.getIdentifying_code()))) {
|
throw new BusinessException("验证码不正确");
|
}
|
|
Party party_reco = this.partyService.findPartyByUsercode(reg.getReco_usercode());
|
|
if ("true".equals(this.sysparaService.find("register_need_usercode").getValue())) {
|
if (null == party_reco) {
|
throw new BusinessException("推荐码不正确");
|
}
|
if (Constants.SECURITY_ROLE_TEST.equals(party_reco.getRolename())) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
if (!party_reco.getEnabled()) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
}
|
|
if ("true".equals(this.sysparaService.find("register_need_usercode_turn").getValue())) {
|
if (!party_reco.getRegister_usercode()) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
}
|
|
if (this.secUserService.findUserByLoginName(reg.getUsername()) != null) {
|
throw new BusinessException("用户名重复");
|
}
|
|
int ever_user_level_num = this.sysparaService.find("ever_user_level_num").getInteger();
|
int ever_user_level_num_custom = this.sysparaService.find("ever_user_level_num_custom").getInteger();
|
|
Party party = new Party();
|
party.setUsername(reg.getUsername());
|
party.setUsercode(this.getUsercode());
|
party.setUser_level(ever_user_level_num_custom * 10 + ever_user_level_num);
|
party.setSafeword(this.passwordEncoder.encodePassword(reg.getSafeword(), SaltSigureUtils.saltfigure));
|
party.setRolename(Constants.SECURITY_ROLE_MEMBER);
|
party = this.partyService.save(party);
|
|
if (type.equals("1")) {
|
// 手机注册
|
if (StringUtils.isEmptyString(reg.getUsername()) || reg.getUsername().length() > 20) {
|
throw new BusinessException("请输入正确的手机号码");
|
}
|
this.savePhone(reg.getUsername(), party.getId().toString());
|
} else {
|
// 邮箱注册
|
if (!Strings.isEmail(reg.getUsername())) {
|
throw new BusinessException("请输入正确的邮箱地址");
|
}
|
this.saveEmail(reg.getUsername(), party.getId().toString());
|
}
|
|
Role role = this.roleService.findRoleByName(Constants.SECURITY_ROLE_MEMBER);
|
|
SecUser secUser = new SecUser();
|
secUser.setPartyId(String.valueOf(party.getId()));
|
secUser.getRoles().add(role);
|
secUser.setUsername(reg.getUsername());
|
secUser.setPassword(reg.getPassword());
|
this.secUserService.saveUser(secUser);
|
|
// usdt账户
|
Wallet wallet = new Wallet();
|
wallet.setPartyId(party.getId().toString());
|
this.walletService.save(wallet);
|
|
if (party_reco != null) {
|
UserRecom userRecom = new UserRecom();
|
userRecom.setPartyId(party.getId());
|
// 父类partyId
|
userRecom.setReco_id(party_reco.getId());
|
this.userRecomService.save(userRecom);
|
}
|
|
String uuid = UUIDGenerator.getUUID();
|
String partyId = party.getId().toString();
|
String partyRecoId = party_reco != null ? party_reco.getId().toString() : "";
|
this.jdbcTemplate.execute("INSERT INTO T_USER(UUID,PARTY_ID,PARENT_PARTY_ID) VALUES('"+uuid+"','"+partyId+"','"+partyRecoId+"')");
|
|
this.userDataService.saveRegister(party.getId());
|
|
// 用户注册自动赠送金额
|
String register_gift_coin = this.sysparaService.find("register_gift_coin").getValue();
|
if (!"".equals(register_gift_coin) && register_gift_coin != null) {
|
|
String[] register_gift_coins = register_gift_coin.split(",");
|
String gift_symbol = register_gift_coins[0];
|
double gift_sum = Double.valueOf(register_gift_coins[1]);
|
|
if ("usdt".equals(gift_symbol)) {
|
|
Wallet walletExtend = this.walletService.saveWalletByPartyId(party.getId());
|
double amount_before = walletExtend.getMoney();
|
if (Arith.add(gift_sum, walletExtend.getMoney()) < 0.0D) {
|
throw new BusinessException("操作失败！修正后账户余额小于0。");
|
}
|
this.walletService.update(wallet.getPartyId().toString(), gift_sum);
|
|
// 保存账变日志
|
MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
|
moneyLog.setAmount_before(amount_before);
|
moneyLog.setAmount(gift_sum);
|
moneyLog.setAmount_after(Arith.add(walletExtend.getMoney(), gift_sum));
|
moneyLog.setPartyId(party.getId());
|
moneyLog.setWallettype(gift_symbol.toUpperCase());
|
moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE);
|
moneyLog.setLog("用户注册自动赠送金额");
|
this.moneyLogService.save(moneyLog);
|
|
} else {
|
|
WalletExtend walletExtend = this.walletService.saveExtendByPara(party.getId(), gift_symbol);
|
double amount_before = walletExtend.getAmount();
|
if (Arith.add(gift_sum, walletExtend.getAmount()) < 0.0D) {
|
throw new BusinessException("操作失败！修正后账户余额小于0。");
|
}
|
this.walletService.updateExtend(walletExtend.getPartyId().toString(), gift_symbol, gift_sum);
|
|
// 保存账变日志
|
MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
|
moneyLog.setAmount_before(amount_before);
|
moneyLog.setAmount(gift_sum);
|
moneyLog.setAmount_after(Arith.add(walletExtend.getAmount(), gift_sum));
|
moneyLog.setPartyId(party.getId());
|
moneyLog.setWallettype(gift_symbol.toUpperCase());
|
moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE);
|
moneyLog.setLog("用户注册自动赠送金额");
|
this.moneyLogService.save(moneyLog);
|
}
|
}
|
|
this.identifyingCodeTimeWindowService.delAuthCode(key);
|
}
|
|
/**
|
* 手机/邮箱注册（无验证码）
|
*/
|
public void saveRegisterNoVerifcode(LocalNormalReg reg, String type) {
|
|
reg.setUsername(reg.getUsername().trim());
|
reg.setPassword(reg.getPassword().trim());
|
|
if (!"null".equals(reg.getSafeword()) && !StringUtils.isEmptyString(reg.getSafeword())) {
|
reg.setSafeword(reg.getSafeword().trim());
|
}
|
|
Party party_reco = this.partyService.findPartyByUsercode(reg.getReco_usercode());
|
|
if ("true".equals(this.sysparaService.find("register_need_usercode").getValue())) {
|
if (null == party_reco) {
|
throw new BusinessException("推荐码不正确");
|
}
|
if (Constants.SECURITY_ROLE_TEST.equals(party_reco.getRolename())) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
if (!party_reco.getEnabled()) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
}
|
|
if ("true".equals(this.sysparaService.find("register_need_usercode_turn").getValue())) {
|
if (!party_reco.getRegister_usercode()) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
}
|
|
if (this.secUserService.findUserByLoginName(reg.getUsername()) != null) {
|
throw new BusinessException("用户名重复");
|
}
|
|
int ever_user_level_num = this.sysparaService.find("ever_user_level_num").getInteger();
|
int ever_user_level_num_custom = this.sysparaService.find("ever_user_level_num_custom").getInteger();
|
|
Party party = new Party();
|
party.setUsername(reg.getUsername());
|
party.setUsercode(this.getUsercode());
|
party.setUser_level(ever_user_level_num_custom * 10 + ever_user_level_num);
|
party.setSafeword(this.passwordEncoder.encodePassword(reg.getSafeword(), SaltSigureUtils.saltfigure));
|
party.setRolename(Constants.SECURITY_ROLE_MEMBER);
|
|
if (type.equals("1")) {
|
// 手机注册
|
if (StringUtils.isEmptyString(reg.getUsername()) || reg.getUsername().length() > 20) {
|
throw new BusinessException("请输入正确的手机号码");
|
}
|
party.setPhone(reg.getUsername());
|
party.setPhone_authority(false);
|
} else if (type.equals("2")) {
|
// 邮箱注册
|
if (!Strings.isEmail(reg.getUsername())) {
|
throw new BusinessException("请输入正确的邮箱地址");
|
}
|
party.setEmail(reg.getUsername());
|
party.setEmail_authority(false);
|
} else {
|
// 用户名注册
|
if (reg.getUsername().length() < 6 || reg.getUsername().length() > 30) {
|
throw new BusinessException("用户名必须6-30位");
|
}
|
}
|
|
party = this.partyService.save(party);
|
|
Role role = this.roleService.findRoleByName(Constants.SECURITY_ROLE_MEMBER);
|
|
SecUser secUser = new SecUser();
|
secUser.setPartyId(String.valueOf(party.getId()));
|
secUser.getRoles().add(role);
|
secUser.setUsername(reg.getUsername());
|
secUser.setPassword(reg.getPassword());
|
secUser.setPhone(reg.getPhone());
|
this.secUserService.saveUser(secUser);
|
|
// usdt账户
|
Wallet wallet = new Wallet();
|
wallet.setPartyId(party.getId().toString());
|
this.walletService.save(wallet);
|
|
if (party_reco != null) {
|
UserRecom userRecom = new UserRecom();
|
userRecom.setPartyId(party.getId());
|
// 父类partyId
|
userRecom.setReco_id(party_reco.getId());
|
this.userRecomService.save(userRecom);
|
}
|
|
String uuid = UUIDGenerator.getUUID();
|
String partyId = party.getId().toString();
|
String partyRecoId = party_reco != null ? party_reco.getId().toString() : "";
|
this.jdbcTemplate.execute("INSERT INTO T_USER(UUID,PARTY_ID,PARENT_PARTY_ID) VALUES('"+uuid+"','"+partyId+"','"+partyRecoId+"')");
|
|
this.userDataService.saveRegister(party.getId());
|
|
// 用户注册自动赠送金额
|
String register_gift_coin = this.sysparaService.find("register_gift_coin").getValue();
|
if (!"".equals(register_gift_coin) && register_gift_coin != null) {
|
|
String[] register_gift_coins = register_gift_coin.split(",");
|
String gift_symbol = register_gift_coins[0];
|
double gift_sum = Double.valueOf(register_gift_coins[1]);
|
|
if ("usdt".equals(gift_symbol)) {
|
|
Wallet walletExtend = this.walletService.saveWalletByPartyId(party.getId());
|
double amount_before = walletExtend.getMoney();
|
if (Arith.add(gift_sum, walletExtend.getMoney()) < 0.0D) {
|
throw new BusinessException("操作失败！修正后账户余额小于0。");
|
}
|
this.walletService.update(wallet.getPartyId().toString(), gift_sum);
|
|
// 保存账变日志
|
MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
|
moneyLog.setAmount_before(amount_before);
|
moneyLog.setAmount(gift_sum);
|
moneyLog.setAmount_after(Arith.add(walletExtend.getMoney(), gift_sum));
|
moneyLog.setPartyId(party.getId());
|
moneyLog.setWallettype(gift_symbol.toUpperCase());
|
moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE);
|
moneyLog.setLog("用户注册自动赠送金额");
|
this.moneyLogService.save(moneyLog);
|
|
} else {
|
|
WalletExtend walletExtend = this.walletService.saveExtendByPara(party.getId(), gift_symbol);
|
double amount_before = walletExtend.getAmount();
|
if (Arith.add(gift_sum, walletExtend.getAmount()) < 0.0D) {
|
throw new BusinessException("操作失败！修正后账户余额小于0。");
|
}
|
this.walletService.updateExtend(walletExtend.getPartyId().toString(), gift_symbol, gift_sum);
|
|
// 保存账变日志
|
MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
|
moneyLog.setAmount_before(amount_before);
|
moneyLog.setAmount(gift_sum);
|
moneyLog.setAmount_after(Arith.add(walletExtend.getAmount(), gift_sum));
|
moneyLog.setPartyId(party.getId());
|
moneyLog.setWallettype(gift_symbol.toUpperCase());
|
moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE);
|
moneyLog.setLog("用户注册自动赠送金额");
|
this.moneyLogService.save(moneyLog);
|
}
|
}
|
}
|
|
/**
|
* 体验用户注册
|
*/
|
public void saveRegisterTest(LocalNormalReg reg, String type) {
|
reg.setUsername(reg.getUsername().trim());
|
reg.setPassword(reg.getPassword().trim());
|
|
if (!"null".equals(reg.getSafeword()) && !StringUtils.isEmptyString(reg.getSafeword())) {
|
reg.setSafeword(reg.getSafeword().trim());
|
}
|
|
String test_user_code = this.sysparaService.find("test_user_code").getValue();
|
if(!"0".equals(test_user_code)) {
|
if (!reg.getReco_usercode().equals(test_user_code)) {
|
throw new BusinessException("试用码不正确");
|
}
|
}
|
|
if (this.secUserService.findUserByLoginName(reg.getUsername()) != null) {
|
throw new BusinessException("用户名重复");
|
}
|
|
int ever_user_level_num = this.sysparaService.find("ever_user_level_num").getInteger();
|
int ever_user_level_num_custom = this.sysparaService.find("ever_user_level_num_custom").getInteger();
|
|
Party party = new Party();
|
party.setUsername(reg.getUsername());
|
party.setUsercode(this.getUsercode());
|
party.setUser_level(ever_user_level_num_custom * 10 + ever_user_level_num);
|
party.setSafeword(this.passwordEncoder.encodePassword(reg.getSafeword(), SaltSigureUtils.saltfigure));
|
party.setRolename(Constants.SECURITY_ROLE_TEST);
|
|
// 用户名注册
|
if (reg.getUsername().length() < 6 || reg.getUsername().length() > 30) {
|
throw new BusinessException("用户名必须6-30位");
|
}
|
|
party = this.partyService.save(party);
|
|
Role role = this.roleService.findRoleByName(Constants.SECURITY_ROLE_TEST);
|
|
SecUser secUser = new SecUser();
|
secUser.setPartyId(String.valueOf(party.getId()));
|
secUser.getRoles().add(role);
|
secUser.setUsername(reg.getUsername());
|
secUser.setPassword(reg.getPassword());
|
this.secUserService.saveUser(secUser);
|
double test_user_money = sysparaService.find("test_user_money").getDouble();
|
// usdt账户
|
Wallet wallet = new Wallet();
|
wallet.setPartyId(party.getId().toString());
|
wallet.setMoney(test_user_money);
|
this.walletService.save(wallet);
|
|
String uuid = UUIDGenerator.getUUID();
|
String partyId = party.getId().toString();
|
String partyRecoId = "";
|
this.jdbcTemplate.execute("INSERT INTO T_USER(UUID,PARTY_ID,PARENT_PARTY_ID) VALUES('"+uuid+"','"+partyId+"','"+partyRecoId+"')");
|
this.userDataService.saveRegister(party.getId());
|
}
|
|
/**
|
* 承兑商注册
|
*/
|
public Party registerC2cUser(String username, String password, String re_password, String type, String usercode, String ip) {
|
Party party = null;
|
boolean lock = false;
|
|
try {
|
if (!LockFilter.add(username)) {
|
throw new BusinessException("重复提交");
|
}
|
|
lock = true;
|
|
if (StringUtils.isEmptyString(username)) {
|
throw new BusinessException("用户名不能为空");
|
}
|
|
if (StringUtils.isEmptyString(password)) {
|
throw new BusinessException("登录密码不能为空");
|
}
|
|
if (StringUtils.isEmptyString(re_password)) {
|
throw new BusinessException("密码确认不能为空");
|
}
|
|
if (password.length() < 6 || password.length() > 12 || re_password.length() < 6 || re_password.length() > 12) {
|
throw new BusinessException("密码必须6-12位");
|
}
|
|
if (!password.equals(re_password)) {
|
throw new BusinessException("两次输入的密码不相同");
|
}
|
|
if (StringUtils.isEmptyString(type) || !Arrays.asList("1", "2").contains(type)) {
|
throw new BusinessException("注册类型（手机或邮箱）不能为空");
|
}
|
|
LocalNormalReg reg = new LocalNormalReg();
|
reg.setUsername(username);
|
reg.setPassword(password);
|
reg.setSafeword("000000");
|
reg.setReco_usercode(usercode);
|
|
this.saveRegisterNoVerifcode(reg, type);
|
SecUser secUser = this.secUserService.findUserByLoginName(username);
|
party = this.partyService.cachePartyBy(secUser.getPartyId(), false);
|
} catch (BusinessException e) {
|
throw e;
|
} catch (Throwable t) {
|
throw t;
|
} finally {
|
if (lock) {
|
LockFilter.remove(username);
|
}
|
}
|
|
return party;
|
}
|
|
/**
|
* 无验证码注册
|
*/
|
public void saveRegisterUsername(LocalNormalReg reg) {
|
reg.setUsername(reg.getUsername().trim());
|
reg.setPassword(reg.getPassword().trim());
|
reg.setSafeword(reg.getSafeword().trim());
|
|
Party party_reco = this.partyService.findPartyByUsercode(reg.getReco_usercode());
|
// 用户注册是否需要推荐码
|
if ("true".equals(sysparaService.find("register_need_usercode").getValue())) {
|
|
if (party_reco == null) {
|
|
throw new BusinessException("推荐码不正确");
|
}
|
if (Constants.SECURITY_ROLE_TEST.equals(party_reco.getRolename())) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
if (!party_reco.getEnabled()) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
|
}
|
|
if ("true".equals(sysparaService.find("register_need_usercode_turn").getValue())) {
|
if (!party_reco.getRegister_usercode()) {
|
throw new BusinessException("推荐人无权限推荐");
|
}
|
}
|
|
if (secUserService.findUserByLoginName(reg.getUsername()) != null) {
|
throw new BusinessException("用户名重复");
|
}
|
|
/**
|
* 用户code
|
*/
|
String usercode = getUsercode();
|
|
/**
|
* party
|
*/
|
Party party = new Party();
|
party.setUsername(reg.getUsername());
|
party.setUsercode(usercode);
|
int ever_user_level_num = sysparaService.find("ever_user_level_num").getInteger();
|
int ever_user_level_num_custom = this.sysparaService.find("ever_user_level_num_custom").getInteger();
|
party.setUser_level(ever_user_level_num_custom * 10 + ever_user_level_num);
|
party.setSafeword(passwordEncoder.encodePassword(reg.getSafeword(), SaltSigureUtils.saltfigure));
|
party.setRolename(Constants.SECURITY_ROLE_MEMBER);
|
|
party = partyService.save(party);
|
|
/**
|
* SecUser
|
*/
|
Role role = this.roleService.findRoleByName(Constants.SECURITY_ROLE_MEMBER);
|
|
SecUser secUser = new SecUser();
|
secUser.setPartyId(String.valueOf(party.getId()));
|
secUser.getRoles().add(role);
|
|
secUser.setUsername(reg.getUsername());
|
|
secUser.setPassword(reg.getPassword());
|
|
this.secUserService.saveUser(secUser);
|
|
/**
|
* usdt账户
|
*/
|
Wallet wallet = new Wallet();
|
wallet.setPartyId(party.getId().toString());
|
this.walletService.save(wallet);
|
|
if (party_reco != null) {
|
UserRecom userRecom = new UserRecom();
|
userRecom.setPartyId(party.getId());
|
userRecom.setReco_id(party_reco.getId());// 父类partyId
|
this.userRecomService.save(userRecom);
|
}
|
|
String uuid = UUIDGenerator.getUUID();
|
String partyId = party.getId().toString();
|
String partyRecoId = party_reco != null?party_reco.getId().toString():"";
|
jdbcTemplate.execute("INSERT INTO T_USER(UUID,PARTY_ID,PARENT_PARTY_ID) VALUES('"+uuid+"','"+partyId+"','"+partyRecoId+"')");
|
|
this.userDataService.saveRegister(party.getId());
|
|
/**
|
* 用户注册自动赠送金额 start
|
*/
|
String register_gift_coin = sysparaService.find("register_gift_coin").getValue();
|
if (!"".equals(register_gift_coin) && register_gift_coin != null) {
|
String[] register_gift_coins = register_gift_coin.split(",");
|
String gift_symbol = register_gift_coins[0];
|
double gift_sum = Double.valueOf(register_gift_coins[1]);
|
|
if ("usdt".equals(gift_symbol)) {
|
Wallet walletExtend = this.walletService.saveWalletByPartyId(party.getId());
|
double amount_before = walletExtend.getMoney();
|
if (Arith.add(gift_sum, walletExtend.getMoney()) < 0.0D) {
|
throw new BusinessException("操作失败！修正后账户余额小于0。");
|
}
|
walletService.update(wallet.getPartyId().toString(), gift_sum);
|
/*
|
* 保存账变日志
|
*/
|
MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
|
moneyLog.setAmount_before(amount_before);
|
moneyLog.setAmount(gift_sum);
|
moneyLog.setAmount_after(Arith.add(walletExtend.getMoney(), gift_sum));
|
|
moneyLog.setPartyId(party.getId());
|
moneyLog.setWallettype(gift_symbol.toUpperCase());
|
moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE);
|
moneyLog.setLog("用户注册自动赠送金额");
|
this.moneyLogService.save(moneyLog);
|
} else {
|
WalletExtend walletExtend = this.walletService.saveExtendByPara(party.getId(), gift_symbol);
|
double amount_before = walletExtend.getAmount();
|
if (Arith.add(gift_sum, walletExtend.getAmount()) < 0.0D) {
|
throw new BusinessException("操作失败！修正后账户余额小于0。");
|
}
|
walletService.updateExtend(walletExtend.getPartyId().toString(), gift_symbol, gift_sum);
|
|
/*
|
* 保存账变日志
|
*/
|
MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
|
moneyLog.setAmount_before(amount_before);
|
moneyLog.setAmount(gift_sum);
|
moneyLog.setAmount_after(Arith.add(walletExtend.getAmount(), gift_sum));
|
|
moneyLog.setPartyId(party.getId());
|
moneyLog.setWallettype(gift_symbol.toUpperCase());
|
moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE);
|
moneyLog.setLog("用户注册自动赠送金额");
|
this.moneyLogService.save(moneyLog);
|
}
|
}
|
}
|
|
/**
|
* 无验证码注册
|
*/
|
public void saveRegisterUsernameTest(LocalNormalReg reg) {
|
reg.setUsername(reg.getUsername().trim());
|
reg.setPassword(reg.getPassword().trim());
|
reg.setSafeword(reg.getSafeword().trim());
|
|
String test_user_code = sysparaService.find("test_user_code").getValue();
|
|
if (StringUtils.isEmptyString(test_user_code) || !test_user_code.equals(reg.getReco_usercode())) {
|
throw new BusinessException("试用码不正确");
|
}
|
|
if (secUserService.findUserByLoginName(reg.getUsername()) != null) {
|
throw new BusinessException("用户名重复");
|
}
|
|
/**
|
* 用户code
|
*/
|
String usercode = getUsercode();
|
|
/**
|
* party
|
*/
|
Party party = new Party();
|
party.setUsername(reg.getUsername());
|
party.setUsercode(usercode);
|
int ever_user_level_num = sysparaService.find("ever_user_level_num").getInteger();
|
int ever_user_level_num_custom = this.sysparaService.find("ever_user_level_num_custom").getInteger();
|
party.setUser_level(ever_user_level_num_custom * 10 + ever_user_level_num);
|
party.setSafeword(passwordEncoder.encodePassword(reg.getSafeword(), SaltSigureUtils.saltfigure));
|
party.setRolename(Constants.SECURITY_ROLE_TEST);
|
// 关闭充值提现权限
|
party.setRecharge_authority(false);
|
party.setWithdraw_authority(false);
|
party = partyService.save(party);
|
|
/**
|
* SecUser
|
*/
|
Role role = this.roleService.findRoleByName(Constants.SECURITY_ROLE_TEST);
|
|
SecUser secUser = new SecUser();
|
secUser.setPartyId(String.valueOf(party.getId()));
|
secUser.getRoles().add(role);
|
|
secUser.setUsername(reg.getUsername());
|
|
secUser.setPassword(reg.getPassword());
|
|
this.secUserService.saveUser(secUser);
|
|
double test_user_money = sysparaService.find("test_user_money").getDouble();
|
/**
|
* usdt账户
|
*/
|
Wallet wallet = new Wallet();
|
wallet.setPartyId(party.getId().toString());
|
wallet.setMoney(test_user_money);
|
this.walletService.save(wallet);
|
}
|
|
private String getUsercode() {
|
Syspara syspara = this.sysparaService.find("user_uid_sequence");
|
int random = (int) (Math.random() * 3 + 1);
|
int user_uid_sequence = syspara.getInteger() + random;
|
syspara.setValue(user_uid_sequence);
|
this.sysparaService.update(syspara);
|
String usercode = String.valueOf(user_uid_sequence);
|
return usercode;
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setRoleService(RoleService roleService) {
|
this.roleService = roleService;
|
}
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
@Override
|
public String getPhone(String partyId) {
|
Party party = this.partyService.cachePartyBy(partyId, false);
|
return party.getPhone();
|
}
|
|
@Override
|
public void savePhone(String phone, String partyId) {
|
/**
|
* party
|
*/
|
Party party = this.partyService.cachePartyBy(partyId, false);
|
party.setPhone(phone);
|
party.setPhone_authority(true);
|
|
// 十进制个位表示系统级别：1/新注册；2/邮箱谷歌手机其中有一个已验证；3/用户实名认证；4/用户高级认证；
|
// 十进制十位表示自定义级别：对应在前端显示为如VIP1 VIP2等级、黄金 白银等级；
|
// 如：级别11表示：新注册的前端显示为VIP1；
|
int userLevel = party.getUser_level();
|
party.setUser_level(((int) Math.floor(userLevel / 10)) * 10 + 2);
|
|
this.partyService.update(party);
|
}
|
|
@Override
|
public String getEmail(String partyId) {
|
Party party = this.partyService.cachePartyBy(partyId, false);
|
return party.getEmail();
|
}
|
|
@Override
|
public void saveEmail(String email, String partyId) {
|
/**
|
* party
|
*/
|
Party party = this.partyService.cachePartyBy(partyId, false);
|
party.setEmail(email);
|
party.setEmail_authority(true);
|
|
// 十进制个位表示系统级别：1/新注册；2/邮箱谷歌手机其中有一个已验证；3/用户实名认证；4/用户高级认证；
|
// 十进制十位表示自定义级别：对应在前端显示为如VIP1 VIP2等级、黄金 白银等级；
|
// 如：级别11表示：新注册的前端显示为VIP1；
|
int userLevel = party.getUser_level();
|
party.setUser_level(((int) Math.floor(userLevel / 10)) * 10 + 2);
|
|
this.partyService.update(party);
|
}
|
|
public void setUserDataService(UserDataService userDataService) {
|
this.userDataService = userDataService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setIdentifyingCodeTimeWindowService(IdentifyingCodeTimeWindowService identifyingCodeTimeWindowService) {
|
this.identifyingCodeTimeWindowService = identifyingCodeTimeWindowService;
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setMoneyLogService(MoneyLogService moneyLogService) {
|
this.moneyLogService = moneyLogService;
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
}
|
