package project.monitor.internal;
|
|
import java.text.MessageFormat;
|
import java.util.List;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import project.Constants;
|
import project.log.LogService;
|
import project.monitor.AdminDAppUserService;
|
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.User;
|
import project.wallet.Wallet;
|
import project.wallet.WalletService;
|
import security.Role;
|
import security.RoleService;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class AdminDAppUserServiceImpl implements AdminDAppUserService {
|
|
private LogService logService;
|
|
private RoleService roleService;
|
|
private PartyService partyService;
|
|
private WalletService walletService;
|
|
private SysparaService sysparaService;
|
|
private SecUserService secUserService;
|
|
private UserRecomService userRecomService;
|
|
@Override
|
public void save(String address, boolean login_authority, boolean withdraw_authority, boolean enabled,String remarks, String code, String operator, String ip) {
|
address = address.trim();
|
//统一转换成小写
|
address = address.toLowerCase();
|
|
//操作人为代理商时，默认添加代理商的usercode
|
SecUser sec = this.secUserService.findUserByLoginName(operator);
|
if(!StringUtils.isEmptyString(sec.getPartyId())) {
|
Party party = this.partyService.cachePartyBy(sec.getPartyId(), false);
|
for (Role role : sec.getRoles()) {
|
if (Constants.SECURITY_ROLE_AGENT.equals(role.getRoleName())||Constants.SECURITY_ROLE_AGENTLOW.equals(role.getRoleName())) {
|
code=party.getUsercode();
|
}
|
}
|
}
|
|
if (partyService.findPartyByUsername(address) != null) {
|
throw new BusinessException("地址已存在");
|
}
|
|
/**
|
* 用户code
|
*/
|
String usercode = getUsercode();
|
|
Party party_reco = null;
|
if (!StringUtils.isNullOrEmpty(code)) {
|
party_reco = this.partyService.findPartyByUsercode(code);
|
if (party_reco == null) {
|
throw new BusinessException("上级UID推荐码不正确");
|
}
|
|
}
|
|
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 party = new Party();
|
party.setUsername(address);
|
party.setLogin_authority(login_authority);
|
party.setWithdraw_authority(withdraw_authority);
|
party.setEnabled(enabled);
|
party.setRemarks(remarks);
|
party.setUsercode(usercode);
|
party.setUser_level(ever_user_level_num_custom * 10 + ever_user_level_num);
|
|
party.setRolename(Constants.SECURITY_ROLE_GUEST);
|
|
party = partyService.save(party);
|
|
User user = new User();
|
user.setPartyId(party.getId());
|
ApplicationUtil.executeInsert(user);
|
|
if (party_reco != null) {
|
UserRecom userRecom = new UserRecom();
|
userRecom.setPartyId(party.getId());
|
userRecom.setReco_id(party_reco.getId());// 父类partyId
|
this.userRecomService.save(userRecom);
|
}
|
|
/**
|
* SecUser
|
*/
|
Role role = this.roleService.findRoleByName(Constants.SECURITY_ROLE_GUEST);
|
|
SecUser secUser = new SecUser();
|
secUser.setPartyId(String.valueOf(party.getId()));
|
secUser.getRoles().add(role);
|
|
secUser.setUsername(address);
|
secUser.setEnabled(login_authority);
|
this.secUserService.saveUser(secUser);
|
|
/**
|
* usdt账户
|
*/
|
Wallet wallet = new Wallet();
|
wallet.setPartyId(party.getId().toString());
|
this.walletService.save(wallet);
|
|
/**
|
* 加入节点操作，未完成
|
*/
|
|
project.log.Log log = new project.log.Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setUsername(party.getUsername());
|
log.setOperator(operator);
|
log.setLog("ip:" + ip + ",管理员手动新增了演示用户:" + address);
|
logService.saveSync(log);
|
|
}
|
|
@Override
|
public void update(String partyId, boolean login_authority, boolean enabled, boolean withdraw_authority, Integer user_level_custom,
|
String balance_income_config,String remarks, String operatorUsername, String ip) {
|
SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
|
|
Party party = this.partyService.cachePartyBy(partyId, false);
|
|
// for (Role role : sec.getRoles()) {
|
// //代理商只能修改演示账户
|
// if (Constants.SECURITY_ROLE_AGENT.equals(role.getRoleName())||Constants.SECURITY_ROLE_AGENTLOW.equals(role.getRoleName())) {
|
// // &&party!=null&&!Constants.SECURITY_ROLE_GUEST.equals(party.getRolename())) {
|
// if(party!=null&&!Constants.SECURITY_ROLE_GUEST.equals(party.getRolename())) {
|
// throw new BusinessException("只能修改演示账户");
|
// }
|
// List<String> children = userRecomService.findChildren(sec.getPartyId());
|
// if(!children.contains(partyId)) {
|
// throw new BusinessException("只能修改自己线下的用户演示账户");
|
|
// }
|
// }
|
// }
|
String logtxt = MessageFormat.format(
|
"ip:" + ip + ",管理员手动修改了用户信息,用户名:{0},原登录权限:{1},原是否业务锁定:{2},原提现权限:{3},原备注:{4}",
|
party.getUsername(),
|
party.getLogin_authority(),
|
party.getEnabled(),
|
party.getWithdraw_authority(),
|
party.getRemarks());
|
party.setRemarks(remarks);
|
party.setLogin_authority(login_authority);
|
party.setEnabled(enabled);
|
party.setWithdraw_authority(withdraw_authority);
|
party.setBalance_income_config(balance_income_config);
|
if (null != user_level_custom) {
|
// 十进制个位表示系统级别：1/新注册；2/邮箱谷歌手机其中有一个已验证；3/用户实名认证；4/用户高级认证；
|
// 十进制十位表示自定义级别：对应在前端显示为如VIP1 VIP2等级、黄金 白银等级；
|
// 如：级别11表示：新注册的前端显示为VIP1；
|
int userLevel = party.getUser_level();
|
party.setUser_level(user_level_custom.intValue() * 10 + (int) (userLevel % 10));
|
}
|
|
this.partyService.update(party);
|
|
logtxt += MessageFormat.format(",新登录权限:{0},新是否业务锁定:{1},新提现权限:{2},新备注:{3}", party.getLogin_authority(),
|
party.getEnabled(), party.getWithdraw_authority(), party.getRemarks());
|
SecUser secUser = secUserService.findUserByPartyId(partyId);
|
secUser.setEnabled(login_authority);
|
|
this.secUserService.update(secUser);
|
|
project.log.Log log = new project.log.Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setUsername(party.getUsername());
|
log.setOperator(operatorUsername);
|
log.setLog(logtxt);
|
logService.saveSync(log);
|
}
|
|
private String getUsercode() {
|
Syspara syspara = sysparaService.find("user_uid_sequence");
|
int random = (int) (Math.random() * 3 + 1);
|
int user_uid_sequence = syspara.getInteger() + random;
|
syspara.setValue(user_uid_sequence);
|
sysparaService.update(syspara);
|
|
String usercode = String.valueOf(user_uid_sequence);
|
return usercode;
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setLogService(LogService logService) {
|
this.logService = logService;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setRoleService(RoleService roleService) {
|
this.roleService = roleService;
|
}
|
}
|
