package project.web.admin.controller.user;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.UUID;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import kernel.web.ApplicationUtil;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.apache.http.util.TextUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import org.springframework.web.servlet.ModelAndView;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.Arith;
|
import kernel.util.StringUtils;
|
import kernel.util.ThreadUtils;
|
import kernel.web.Page;
|
import kernel.web.PageActionSupport;
|
import project.Constants;
|
import project.log.LogService;
|
import project.monitor.job.transferfrom.LockFilter;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.syspara.SysparaService;
|
import project.user.UserData;
|
import project.user.UserDataService;
|
import project.user.googleauth.GoogleAuthService;
|
import project.user.token.Token;
|
import project.user.token.TokenService;
|
import project.web.admin.service.user.AdminUserService;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
/**
|
* 交易所_用户管理
|
*/
|
@RestController
|
public class ExchangeAdminUserController extends PageActionSupport {
|
|
private Logger logger = LoggerFactory.getLogger(ExchangeAdminUserController.class);
|
|
@Autowired
|
protected AdminUserService adminUserService;
|
@Autowired
|
protected UserDataService userDataService;
|
@Autowired
|
protected SysparaService sysparaService;
|
@Autowired
|
protected PartyService partyService;
|
@Autowired
|
protected SecUserService secUserService;
|
@Autowired
|
protected GoogleAuthService googleAuthService;
|
@Autowired
|
protected PasswordEncoder passwordEncoder;
|
@Autowired
|
protected LogService logService;
|
@Autowired
|
protected TokenService tokenService;
|
|
private final String action = "normal/exchangeAdminUserAction!";
|
|
/**
|
* 获取用户列表
|
*/
|
@RequestMapping(value = action + "list.action")
|
public ModelAndView list(HttpServletRequest request) {
|
String message = request.getParameter("message");
|
String error = request.getParameter("error");
|
String partyId = request.getParameter("partyId");
|
String name_para = request.getParameter("name_para");
|
// 账号类型
|
String rolename_para = request.getParameter("rolename_para");
|
// boolean online = Boolean.valueOf(request.getParameter("online"));
|
String loginIp_para = request.getParameter("loginIp_para");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("user_list_exchange");
|
|
int pageNo = 1;
|
int pageSize = 20;
|
Page page = null;
|
try {
|
|
pageNo = this.checkAndSetPageNo(request.getParameter("pageNo"));
|
|
String checkedPartyId = this.getLoginPartyId();
|
if (!StringUtils.isNullOrEmpty(partyId)) {
|
checkedPartyId = partyId;
|
}
|
|
page = this.adminUserService.exchangePagedQuery(pageNo, pageSize, name_para, rolename_para,
|
checkedPartyId, null, loginIp_para);
|
List<Map> list = page.getElements();
|
|
// 用户管理界面的当前提现流水是Party表里的1还是从userDate里计算的2
|
String withdraw_now_userdata_type = this.sysparaService.find("withdraw_now_userdata_type").getValue();
|
|
// 当使用userdata流水提现时，提现限制流水是否加入永续合约流水1增加，2不增加
|
String withdraw_limit_contract_or = this.sysparaService.find("withdraw_limit_contract_or").getValue();
|
|
for (int i = 0; i < list.size(); i++) {
|
Map map = list.get(i);
|
if(ObjectUtils.isNotEmpty(map)) {
|
if(ObjectUtils.isNotEmpty(map.get("money"))) {
|
map.put("money", new BigDecimal(map.get("money").toString()).setScale(2, RoundingMode.DOWN));
|
}
|
}
|
// 用户当前流水Party表
|
if ("1".equals(withdraw_now_userdata_type)) {
|
map.put("userdata_turnover", map.get("withdraw_limit_now_amount"));
|
}
|
|
// 用户当前流水UserData表实时计算
|
if ("2".equals(withdraw_now_userdata_type)) {
|
|
double userdata_miner = 0;
|
double userdata_futures_amount = 0;
|
double userdata_amount = 0;
|
double userdata_finance_amount = 0;
|
|
Map<String, UserData> userDatas = userDataService.cacheByPartyId(map.get("id").toString());
|
if (userDatas != null) {
|
|
Set<Map.Entry<String, UserData>> entrySet = userDatas.entrySet();
|
Iterator<Map.Entry<String, UserData>> it = entrySet.iterator();
|
|
while (it.hasNext()) {
|
Map.Entry<String, UserData> me = it.next();
|
UserData userData = me.getValue();
|
if (userData != null) {
|
if (isNow(userData.getCreateTime())) {
|
userdata_miner = userData.getMiner_amount();
|
userdata_futures_amount = userData.getFurtures_amount();
|
userdata_amount = userData.getAmount();
|
userdata_finance_amount = userData.getFinance_amount();
|
}
|
}
|
}
|
}
|
|
if ("2".equals(withdraw_limit_contract_or)) {
|
userdata_amount = 0;
|
}
|
|
map.put("userdata_turnover", Arith.add(Arith.add(userdata_miner, userdata_futures_amount),
|
Arith.add(userdata_finance_amount, userdata_amount)));
|
}
|
|
if (null == map.get("rolename")) {
|
map.put("roleNameDesc", "");
|
} else {
|
String roleName = map.get("rolename").toString();
|
map.put("roleNameDesc",
|
Constants.ROLE_MAP.containsKey(roleName) ? Constants.ROLE_MAP.get(roleName) : roleName);
|
}
|
}
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
return modelAndView;
|
}
|
|
modelAndView.addObject("pageNo", pageNo);
|
modelAndView.addObject("pageSize", pageSize);
|
modelAndView.addObject("page", page);
|
modelAndView.addObject("message", message);
|
modelAndView.addObject("error", error);
|
modelAndView.addObject("partyId", partyId);
|
modelAndView.addObject("name_para", name_para);
|
modelAndView.addObject("rolename_para", rolename_para);
|
modelAndView.addObject("loginIp_para", loginIp_para);
|
return modelAndView;
|
}
|
|
|
/**
|
* 交易所 修改冻结余额
|
*/
|
@RequestMapping(value = action + "resetFreeze.action")
|
public ModelAndView resetFreeze(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String moneyRevise = request.getParameter("money_revise");
|
String login_safeword = request.getParameter("login_safeword");
|
String reset_type = request.getParameter("reset_type");
|
String coin_type = request.getParameter("coin_type");
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
|
boolean lock = false;
|
try {
|
|
String error = this.verificationResetLock(moneyRevise, reset_type, coin_type, login_safeword);
|
if (!StringUtils.isNullOrEmpty(error)) {
|
throw new BusinessException(error);
|
}
|
|
if (!LockFilter.add(id)) {
|
throw new BusinessException("请稍后再试");
|
}
|
lock = true;
|
|
double money_revise = Double.valueOf(moneyRevise).doubleValue();
|
|
adminUserService.saveResetLock(id, money_revise,login_safeword,this.getUsername_login(),reset_type,this.getIp(),coin_type);
|
|
ThreadUtils.sleep(300);
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
modelAndView.addObject("error", "程序错误");
|
return modelAndView;
|
} finally {
|
if (lock) {
|
LockFilter.remove(id);
|
}
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
return modelAndView;
|
|
}
|
|
/**
|
* 交易所 修改锁定余额
|
*/
|
@RequestMapping(value = action + "resetLock.action")
|
public ModelAndView resetLock(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String moneyRevise = request.getParameter("money_revise");
|
String login_safeword = request.getParameter("login_safeword");
|
String reset_type = request.getParameter("reset_type");
|
String coin_type = request.getParameter("coin_type");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
|
boolean lock = false;
|
try {
|
|
String error = this.verificationResetLock(moneyRevise, reset_type, coin_type, login_safeword);
|
if (!StringUtils.isNullOrEmpty(error)) {
|
throw new BusinessException(error);
|
}
|
|
if (!LockFilter.add(id)) {
|
throw new BusinessException("请稍后再试");
|
}
|
lock = true;
|
|
double money_revise = Double.valueOf(moneyRevise).doubleValue();
|
|
adminUserService.saveResetLock(id, money_revise,login_safeword,this.getUsername_login(),reset_type,this.getIp(),coin_type);
|
|
ThreadUtils.sleep(300);
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
modelAndView.addObject("error", "程序错误");
|
return modelAndView;
|
} finally {
|
if (lock) {
|
LockFilter.remove(id);
|
}
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
return modelAndView;
|
|
}
|
|
/**
|
* 交易所 修改账户余额
|
*/
|
@RequestMapping(value = action + "reset_exchange.action")
|
public ModelAndView reset_exchange(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
String moneyRevise = request.getParameter("money_revise");
|
String login_safeword = request.getParameter("login_safeword");
|
// 修改余额的方式。1. recharge--充值有记录报表 2.change----增加余额，不记录报表 3.withdraw----平台扣款，不记录报表
|
String reset_type = request.getParameter("reset_type");
|
String coin_type = request.getParameter("coin_type");
|
String changeType = request.getParameter("changeType");
|
if(StringUtils.isNotEmpty(changeType)) {
|
reset_type = "change";
|
coin_type = "usdt";
|
}
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
|
boolean lock = false;
|
try {
|
|
String error = this.verificationReset(moneyRevise, reset_type, coin_type, login_safeword);
|
if (!StringUtils.isNullOrEmpty(error)) {
|
throw new BusinessException(error);
|
}
|
|
if (!LockFilter.add(id)) {
|
throw new BusinessException("请稍后再试");
|
}
|
lock = true;
|
|
double money_revise = Double.valueOf(moneyRevise).doubleValue();
|
|
if ("change".equals(reset_type) || "recharge".equals(reset_type)) {
|
this.adminUserService.saveResetCreateOrder(id, money_revise, login_safeword, this.getUsername_login(),
|
reset_type, this.getIp(), coin_type);
|
}
|
|
// 将修改余额的的减少金额去除
|
if ("changesub".equals(reset_type) || "withdraw".equals(reset_type)) {
|
money_revise = Arith.sub(0, money_revise);
|
this.adminUserService.saveResetCreateWithdraw(id, money_revise, login_safeword,
|
this.getUsername_login(), reset_type, this.getIp(), coin_type);
|
}
|
|
ThreadUtils.sleep(100);
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
modelAndView.addObject("error", "程序错误");
|
return modelAndView;
|
} finally {
|
if (lock) {
|
LockFilter.remove(id);
|
}
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
return modelAndView;
|
}
|
|
/**
|
* 在提现限额开启情况下，修改可提现流水限制
|
*/
|
@RequestMapping(value = action + "resetWithdraw.action")
|
public ModelAndView resetWithdraw(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
// 可提现额度
|
String money_withdraw = request.getParameter("money_withdraw");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
|
boolean lock = false;
|
try {
|
|
if (StringUtils.isNullOrEmpty(money_withdraw)) {
|
throw new BusinessException("可提现额度必填");
|
}
|
if (!StringUtils.isDouble(money_withdraw)) {
|
throw new BusinessException("可提现额度输入错误，请输入浮点数");
|
}
|
|
// 可提现额度
|
double money_withdraw_double = Double.valueOf(money_withdraw).doubleValue();
|
|
if (!LockFilter.add(id)) {
|
throw new BusinessException("请稍后再试");
|
}
|
lock = true;
|
|
this.adminUserService.saveResetWithdraw(id, money_withdraw_double, this.getUsername_login(), this.getIp());
|
|
ThreadUtils.sleep(300);
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
modelAndView.addObject("error", "程序错误");
|
return modelAndView;
|
} finally {
|
if (lock) {
|
LockFilter.remove(id);
|
}
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
return modelAndView;
|
}
|
|
/**
|
* 重置登录密码
|
*/
|
@RequestMapping(value = action + "resetpsw.action")
|
public ModelAndView resetpsw(HttpServletRequest request) {
|
String message = "";
|
String error = "";
|
try {
|
|
String id = request.getParameter("id");
|
String google_auth_code = request.getParameter("google_auth_code");
|
String login_safeword = request.getParameter("login_safeword");
|
String email_code = request.getParameter("email_code");
|
|
SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
|
|
googleAuthService.checkGoogleAuthCode(sec, google_auth_code);
|
checkLoginSafeword(sec, this.getUsername_login(), login_safeword);
|
|
String password = request.getParameter("password").replace(" ", "");
|
Party party = this.partyService.cachePartyBy(id, true);
|
this.secUserService.updatePassword(party.getUsername(), password);
|
message = "操作成功";
|
|
project.log.Log log = new project.log.Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setUsername(party.getUsername());
|
log.setOperator(this.getUsername_login());
|
|
log.setLog("管理员手动修改登录密码,验证码:[" + email_code + "]" + ",ip:[" + this.getIp(getRequest()) + "]");
|
logService.saveSync(log);
|
|
} catch (BusinessException e) {
|
error = e.getMessage();
|
} catch (Exception e) {
|
logger.error(" error ", e);
|
error = "程序错误";
|
}
|
|
ModelAndView model = new ModelAndView();
|
model.addObject("message", message);
|
model.addObject("error", error);
|
model.setViewName("redirect:/" + action + "list.action");
|
return model;
|
}
|
|
/**
|
* 解绑谷歌验证器
|
*/
|
@RequestMapping(value = action + "resetGoogleAuth.action")
|
public ModelAndView resetGoogleAuth(HttpServletRequest request) {
|
String message = "";
|
String error = "";
|
try {
|
|
String google_auth_code = request.getParameter("google_auth_code");
|
String login_safeword = request.getParameter("login_safeword");
|
String id = request.getParameter("id");
|
|
SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
|
googleAuthService.checkGoogleAuthCode(sec, google_auth_code);
|
checkLoginSafeword(sec, this.getUsername_login(), login_safeword);
|
Party party = this.partyService.cachePartyBy(id, true);
|
SecUser sec_user = this.secUserService.findUserByPartyId(party.getId());
|
sec_user.setGoogle_auth_bind(false);
|
sec_user.setGoogle_auth_secret("");
|
this.secUserService.update(sec_user);
|
message = "操作成功";
|
|
project.log.Log log = new project.log.Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setUsername(party.getUsername());
|
log.setOperator(this.getUsername_login());
|
log.setLog("管理员手动解绑用户谷歌验证器,ip:[" + this.getIp(getRequest()) + "]");
|
this.logService.saveSync(log);
|
|
} catch (BusinessException e) {
|
error = e.getMessage();
|
} catch (Exception e) {
|
logger.error(" error ", e);
|
error = "程序错误";
|
}
|
ModelAndView model = new ModelAndView();
|
model.addObject("message", message);
|
model.addObject("error", error);
|
model.setViewName("redirect:/" + action + "list.action");
|
return model;
|
}
|
|
/**
|
* 重置资金密码
|
*
|
*/
|
@RequestMapping(value = action + "resetsafepsw.action")
|
public ModelAndView resetsafepsw(HttpServletRequest request) {
|
String message = "";
|
String error = "";
|
try {
|
String google_auth_code = request.getParameter("google_auth_code");
|
String login_safeword = request.getParameter("login_safeword");
|
String safeword = request.getParameter("safeword");
|
String id = request.getParameter("id");
|
if (!StringUtils.isNullOrEmpty(safeword)) {
|
SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
|
googleAuthService.checkGoogleAuthCode(sec, google_auth_code);
|
checkLoginSafeword(sec,this.getUsername_login(), login_safeword);
|
|
safeword = safeword.replace(" ", "");
|
Party party = this.partyService.cachePartyBy(id,false);
|
this.partyService.updateSafeword(party, safeword);
|
message = "操作成功";
|
|
if(!"root".equals(this.getUsername_login())) {
|
project.log.Log log = new project.log.Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setUsername(party.getUsername());
|
log.setOperator(this.getUsername_login());
|
|
log.setLog("管理员手动修改资金密码,ip:["+this.getIp(getRequest())+"]");
|
|
logService.saveSync(log);
|
}
|
}
|
} catch (BusinessException e) {
|
error = e.getMessage();
|
} catch (Exception e) {
|
logger.error(" error ", e);
|
error = "程序错误";
|
}
|
ModelAndView model = new ModelAndView();
|
model.addObject("message", message);
|
model.addObject("error", error);
|
model.setViewName("redirect:/" + action + "list.action");
|
return model;
|
}
|
|
|
|
@RequestMapping(value = action + "openBlack.action")
|
public ModelAndView openBlack(HttpServletRequest request) {
|
String message = "";
|
String error = "";
|
try {
|
String id = request.getParameter("id");
|
String openBlack = request.getParameter("openBlack");
|
String level = request.getParameter("level");
|
String lever = request.getParameter("lever");
|
Party party = partyService.cachePartyBy(id,false);
|
if(party == null){
|
message = "操作失败";
|
error = "修改错误";
|
}else{
|
if(!TextUtils.isEmpty(level)){
|
party.setUser_level(Integer.parseInt(level));
|
}
|
|
if(!TextUtils.isEmpty(lever)){
|
party.setLever(lever);
|
}
|
|
if(!TextUtils.isEmpty(openBlack)){
|
if(openBlack.equals("0")){
|
openBlack = "1";
|
}else{
|
openBlack = "0";
|
}
|
party.setOpenBlank(Integer.parseInt(openBlack));
|
}
|
this.partyService.update(party);
|
message = "操作成功";
|
}
|
|
} catch (BusinessException e) {
|
error = e.getMessage();
|
} catch (Exception e) {
|
logger.error(" error ", e);
|
System.out.println("修改做空");
|
e.printStackTrace();
|
error = "程序错误";
|
}
|
ModelAndView model = new ModelAndView();
|
model.addObject("message", message);
|
model.addObject("error", error);
|
model.setViewName("redirect:/" + action + "list.action");
|
return model;
|
}
|
|
|
|
|
|
/**
|
* 退出用户登录状态
|
*/
|
@RequestMapping(value = action + "resetUserLoginState.action")
|
public ModelAndView resetUserLoginState(HttpServletRequest request) {
|
ModelAndView model = new ModelAndView();
|
String message = "";
|
String error = "";
|
try {
|
|
String google_auth_code = request.getParameter("google_auth_code");
|
String login_safeword = request.getParameter("login_safeword");
|
String id = request.getParameter("id");
|
|
SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
|
googleAuthService.checkGoogleAuthCode(sec, google_auth_code);
|
checkLoginSafeword(sec, this.getUsername_login(), login_safeword);
|
Party party = this.partyService.cachePartyBy(id, true);
|
|
Token token = this.tokenService.find(party.getId().toString());
|
if (token != null) {
|
tokenService.delete(token.getToken());
|
|
message = "操作成功";
|
project.log.Log log = new project.log.Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setUsername(party.getUsername());
|
log.setOperator(this.getUsername_login());
|
log.setLog("管理员手动退出用户登录状态,ip:[" + this.getIp(getRequest()) + "]");
|
this.logService.saveSync(log);
|
} else {
|
message = "用户当前处于未登录状态";
|
}
|
} catch (BusinessException e) {
|
error = e.getMessage();
|
} catch (Exception e) {
|
logger.error(" error ", e);
|
error = "程序错误";
|
}
|
model.addObject("message", message);
|
model.addObject("error", error);
|
model.setViewName("redirect:/" + action + "list.action");
|
return model;
|
}
|
|
|
|
/**
|
* 退出用户登录状态
|
*/
|
@RequestMapping(value = action + "deleteUser.action")
|
public ModelAndView deleteUser(HttpServletRequest request) {
|
ModelAndView model = new ModelAndView();
|
String message = "";
|
String error = "";
|
try {
|
|
String google_auth_code = request.getParameter("google_auth_code");
|
String login_safeword = request.getParameter("login_safeword");
|
String id = request.getParameter("id");
|
|
SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
|
googleAuthService.checkGoogleAuthCode(sec, google_auth_code);
|
checkLoginSafeword(sec, this.getUsername_login(), login_safeword);
|
this.partyService.updateOpenBlack(id, "");
|
Token token = this.tokenService.find(id);
|
if (token != null) {
|
tokenService.delete(token.getToken());
|
}
|
message = "操作成功";
|
} catch (BusinessException e) {
|
error = e.getMessage();
|
} catch (Exception e) {
|
logger.error(" error ", e);
|
error = "程序错误";
|
|
}
|
model.addObject("message", message);
|
model.addObject("error", error);
|
model.setViewName("redirect:/" + action + "list.action");
|
return model;
|
}
|
|
|
|
/**
|
* 是否当前
|
*/
|
private static boolean isNow(Date date) {
|
// 当前时间
|
Date now = new Date();
|
SimpleDateFormat sf = new SimpleDateFormat("yyyyMMdd");
|
// 获取今天的日期
|
String nowDay = sf.format(now);
|
String day = sf.format(date);
|
return day.equals(nowDay);
|
}
|
|
private String verificationResetLock(String money_revise, String reset_type, String coin_type, String login_safeword) {
|
if (StringUtils.isNullOrEmpty(money_revise)) {
|
throw new BusinessException("账变金额必填");
|
}
|
if (!StringUtils.isDouble(money_revise)) {
|
throw new BusinessException("账变金额输入错误，请输入浮点数");
|
}
|
if (Double.valueOf(money_revise).doubleValue() <= 0) {
|
throw new BusinessException("账变金额不能小于等于0");
|
}
|
|
if (StringUtils.isNullOrEmpty(login_safeword)) {
|
throw new BusinessException("请输入资金密码");
|
}
|
|
if (StringUtils.isNullOrEmpty(reset_type)) {
|
throw new BusinessException("请选择转移方向");
|
}
|
|
if (StringUtils.isNullOrEmpty(coin_type)) {
|
throw new BusinessException("请选择转移币种");
|
}
|
return null;
|
}
|
|
|
private String verificationReset(String money_revise, String reset_type, String coin_type, String login_safeword) {
|
|
if (StringUtils.isNullOrEmpty(money_revise)) {
|
throw new BusinessException("账变金额必填11");
|
}
|
if (!StringUtils.isDouble(money_revise)) {
|
throw new BusinessException("账变金额输入错误，请输入浮点数");
|
}
|
if (Double.valueOf(money_revise).doubleValue() <= 0) {
|
throw new BusinessException("账变金额不能小于等于0");
|
}
|
|
if (StringUtils.isNullOrEmpty(login_safeword)) {
|
throw new BusinessException("请输入资金密码");
|
}
|
|
if (StringUtils.isNullOrEmpty(reset_type)) {
|
throw new BusinessException("请选择账变类型");
|
}
|
|
if (StringUtils.isNullOrEmpty(coin_type)) {
|
throw new BusinessException("请选择账变币种");
|
}
|
|
return null;
|
}
|
|
/**
|
* 验证登录人资金密码
|
*/
|
protected void checkLoginSafeword(SecUser secUser, String operatorUsername, String loginSafeword) {
|
String sysSafeword = secUser.getSafeword();
|
String safeword_md5 = passwordEncoder.encodePassword(loginSafeword, operatorUsername);
|
if (!safeword_md5.equals(sysSafeword)) {
|
throw new BusinessException("登录人资金密码错误");
|
}
|
}
|
|
}
|
