package project.web.admin.controller.user;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.apache.commons.lang3.ObjectUtils;
|
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.JsonUtils;
|
import kernel.util.PropertiesUtil;
|
import kernel.util.StringUtils;
|
import kernel.web.Page;
|
import kernel.web.PageActionSupport;
|
import project.Constants;
|
import project.log.LogService;
|
import project.monitor.AdminDAppUserService;
|
import project.monitor.AutoMonitorWalletService;
|
import project.monitor.DAppAccountService;
|
import project.monitor.pledgegalaxy.PledgeGalaxyOrderService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.party.recom.UserRecomService;
|
import project.syspara.Syspara;
|
import project.syspara.SysparaService;
|
import project.user.UserDataService;
|
import project.user.UserService;
|
import project.user.googleauth.GoogleAuthService;
|
import project.user.token.TokenService;
|
import project.web.admin.service.user.AdminAgentService;
|
import project.web.admin.service.user.AdminUserService;
|
import security.internal.SecUserService;
|
|
/**
|
* 用户基础管理
|
*/
|
@RestController
|
public class AdminUserController extends PageActionSupport {
|
|
private Logger logger = LoggerFactory.getLogger(AdminUserController.class);
|
|
@Autowired
|
protected AdminUserService adminUserService;
|
@Autowired
|
protected AdminAgentService adminAgentService;
|
@Autowired
|
protected PartyService partyService;
|
@Autowired
|
protected SecUserService secUserService;
|
@Autowired
|
protected UserService userService;
|
@Autowired
|
protected UserDataService userDataService;
|
@Autowired
|
protected LogService logService;
|
@Autowired
|
protected SysparaService sysparaService;
|
@Autowired
|
protected PasswordEncoder passwordEncoder;
|
@Autowired
|
protected GoogleAuthService googleAuthService;
|
@Autowired
|
protected TokenService tokenService;
|
@Autowired
|
protected DAppAccountService dAppAccountService;
|
@Autowired
|
protected UserRecomService userRecomService;
|
@Autowired
|
protected AutoMonitorWalletService autoMonitorWalletService;
|
@Autowired
|
protected AdminDAppUserService adminDAppUserService;
|
@Autowired
|
protected PledgeGalaxyOrderService pledgeGalaxyOrderService;
|
|
private final String action = "normal/adminUserAction!";
|
|
/**
|
* 获取用户列表
|
*/
|
@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");
|
|
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.pagedQuery(pageNo, pageSize, name_para, rolename_para,
|
checkedPartyId, online, loginIp_para);
|
|
List<Map> list = page.getElements();
|
|
for (int i = 0; i < list.size(); i++) {
|
|
Map map = list.get(i);
|
map.put("username_hide", map.get("username") == null ? null : hideAddress(map.get("username").toString(), 5));
|
map.put("username_parent_hide", map.get("username_parent") == null ? null : hideAddress(map.get("username_parent").toString(), 5));
|
map.put("online", userService.isOnline(String.valueOf(map.get("id"))));
|
|
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);
|
}
|
|
// 十进制个位表示系统级别：1/新注册；2/邮箱谷歌手机其中有一个已验证；3/用户实名认证；4/用户高级认证；
|
// 十进制十位表示自定义级别：对应在前端显示为如VIP1 VIP2等级、黄金 白银等级；
|
// 如：级别11表示：新注册的前端显示为VIP1；
|
Integer userLevel = (Integer) map.get("user_level");
|
if (null == userLevel) {
|
userLevel = 1;
|
}
|
int user_level_custom = (int) Math.floor(userLevel.intValue() / 10);
|
map.put("user_level_custom", user_level_custom);
|
|
map.put("user_level_custom_display", "VIP");
|
String user_level_custom_config = this.sysparaService.find("user_level_custom_config").getValue();
|
String[] levelArray = user_level_custom_config.split(",");
|
for (int k = 0; k < levelArray.length; k++) {
|
String[] level = levelArray[k].split("-");
|
if (level[0].equals(map.get("user_level_custom").toString())) {
|
map.put("user_level_custom_display", level[1]);
|
break;
|
}
|
}
|
}
|
|
String url = PropertiesUtil.getProperty("admin_url") + "/normal/adminUserAction!list.action";
|
this.result = JsonUtils.getJsonString(this.adminAgentService.findAgentNodes(this.getLoginPartyId(), checkedPartyId, url));
|
|
} 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("online", online);
|
modelAndView.addObject("loginIp_para", loginIp_para);
|
return modelAndView;
|
}
|
|
/**
|
* 新增 演示账号 页面
|
*/
|
@RequestMapping(value = action + "toAdd.action")
|
public ModelAndView toAdd() {
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("user_add");
|
return modelAndView;
|
}
|
|
/**
|
* 批量新增演示账号页面
|
*/
|
@RequestMapping(value = action + "toBatchAdd.action")
|
public ModelAndView toBatchAdd() {
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("user_batch_add");
|
return modelAndView;
|
}
|
|
/**
|
* 新增 演示账号
|
*/
|
@RequestMapping(value = action + "batchAdd.action")
|
public ModelAndView batchAdd(HttpServletRequest request) {
|
String userCount = request.getParameter("userCount");
|
String userMoney = request.getParameter("userMoney");
|
String username = request.getParameter("username");
|
String password = request.getParameter("password");
|
String remarks = request.getParameter("remarks");
|
// 推荐人的usercode
|
String parents_usercode = request.getParameter("parents_usercode");
|
boolean login_authority = Boolean.valueOf(request.getParameter("login_authority"));
|
boolean enabled = Boolean.valueOf(request.getParameter("enabled"));
|
|
boolean withdraw_authority = true;
|
int count = Integer.parseInt(userCount);
|
ModelAndView modelAndView = new ModelAndView();
|
for(int i = 0; i<count; i++) {
|
try {
|
|
if (StringUtils.isEmptyString(username)) {
|
throw new BusinessException("请输入用户名");
|
}
|
|
if (StringUtils.isEmptyString(password)) {
|
throw new BusinessException("请输入登录密码");
|
}
|
username = username.replace(" ", "");
|
password = password.replace(" ", "");
|
this.adminUserService.save(username+i, password, login_authority, enabled, remarks, this.getUsername_login(), this.getIp(), parents_usercode,userMoney);
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.addObject("address", "");
|
modelAndView.addObject("username", username);
|
modelAndView.addObject("password", password);
|
modelAndView.addObject("remarks", remarks);
|
modelAndView.addObject("parents_usercode", parents_usercode);
|
modelAndView.addObject("login_authority", login_authority);
|
modelAndView.addObject("enabled", enabled);
|
modelAndView.addObject("withdraw_authority", withdraw_authority);
|
modelAndView.setViewName("user_add");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.addObject("address", "");
|
modelAndView.addObject("username", username);
|
modelAndView.addObject("password", password);
|
modelAndView.addObject("remarks", remarks);
|
modelAndView.addObject("parents_usercode", parents_usercode);
|
modelAndView.addObject("login_authority", login_authority);
|
modelAndView.addObject("enabled", enabled);
|
modelAndView.addObject("withdraw_authority", withdraw_authority);
|
modelAndView.setViewName("user_add");
|
return modelAndView;
|
}
|
}
|
modelAndView.addObject("message", "操作成功");
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
}
|
|
|
/**
|
* 新增 演示账号
|
*/
|
@RequestMapping(value = action + "add.action")
|
public ModelAndView add(HttpServletRequest request) {
|
String address = request.getParameter("address");
|
String username = request.getParameter("username");
|
String password = request.getParameter("password");
|
String remarks = request.getParameter("remarks");
|
String dappExchange = request.getParameter("dappExchange");
|
// 推荐人的usercode
|
String parents_usercode = request.getParameter("parents_usercode");
|
boolean login_authority = Boolean.valueOf(request.getParameter("login_authority"));
|
boolean enabled = Boolean.valueOf(request.getParameter("enabled"));
|
|
boolean withdraw_authority = true;
|
|
ModelAndView modelAndView = new ModelAndView();
|
|
try {
|
|
// false: dapp+交易所；true: 交易所；
|
if (!this.isDappOrExchange()&&ObjectUtils.isEmpty(dappExchange)) {
|
|
if (StringUtils.isEmptyString(address)) {
|
throw new BusinessException("请输入钱包地址");
|
}
|
|
address = address.replace(" ", "");
|
// 统一处理成小写
|
address = address.toLowerCase();
|
|
this.adminDAppUserService.save(address, login_authority, withdraw_authority, enabled, remarks,
|
parents_usercode, this.getUsername_login(), this.getIp());
|
} else {
|
|
if (StringUtils.isEmptyString(username)) {
|
throw new BusinessException("请输入用户名");
|
}
|
|
if (StringUtils.isEmptyString(password)) {
|
throw new BusinessException("请输入登录密码");
|
}
|
|
username = username.replace(" ", "");
|
password = password.replace(" ", "");
|
|
this.adminUserService.save(username, password, login_authority, enabled, remarks, this.getUsername_login(), this.getIp(), parents_usercode,null);
|
}
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.addObject("address", address);
|
modelAndView.addObject("username", username);
|
modelAndView.addObject("password", password);
|
modelAndView.addObject("remarks", remarks);
|
modelAndView.addObject("parents_usercode", parents_usercode);
|
modelAndView.addObject("login_authority", login_authority);
|
modelAndView.addObject("enabled", enabled);
|
modelAndView.addObject("withdraw_authority", withdraw_authority);
|
modelAndView.setViewName("user_add");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.addObject("address", address);
|
modelAndView.addObject("username", username);
|
modelAndView.addObject("password", password);
|
modelAndView.addObject("remarks", remarks);
|
modelAndView.addObject("parents_usercode", parents_usercode);
|
modelAndView.addObject("login_authority", login_authority);
|
modelAndView.addObject("enabled", enabled);
|
modelAndView.addObject("withdraw_authority", withdraw_authority);
|
modelAndView.setViewName("user_add");
|
return modelAndView;
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
}
|
|
/**
|
* 修改 用户 页面
|
*/
|
@RequestMapping(value = action + "toUpdate.action")
|
public ModelAndView toUpdate(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
|
ModelAndView modelAndView = new ModelAndView();
|
|
try {
|
|
Party party = this.partyService.cachePartyBy(id, false);
|
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("username", party.getUsername());
|
modelAndView.addObject("remarks", party.getRemarks());
|
// 限制登录
|
modelAndView.addObject("login_authority", party.getLogin_authority());
|
// 业务锁定
|
modelAndView.addObject("enabled", party.getEnabled());
|
// 限制提现
|
modelAndView.addObject("withdraw_authority", party.getWithdraw_authority());
|
// 用户自定义等级
|
modelAndView.addObject("user_level_custom", (int) Math.floor(party.getUser_level() / 10));
|
modelAndView.addObject("balance_income_config", party.getBalance_income_config());
|
|
Map<String, String> user_level_custom_map = new HashMap<String, String>();
|
String user_level_custom_config = this.sysparaService.find("user_level_custom_config").getValue();
|
String[] levelArray = user_level_custom_config.split(",");
|
for (int i = 0; i < levelArray.length; i++) {
|
String[] level = levelArray[i].split("-");
|
user_level_custom_map.put(level[0], level[1]);
|
}
|
|
// 用户自定义等级配置
|
modelAndView.addObject("user_level_custom_map", user_level_custom_map);
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
}
|
|
modelAndView.setViewName("user_update");
|
return modelAndView;
|
}
|
|
/**
|
* 修改 用户
|
*/
|
@RequestMapping(value = action + "update.action")
|
public ModelAndView update(HttpServletRequest request) {
|
String id = request.getParameter("id");
|
boolean login_authority = Boolean.valueOf(request.getParameter("login_authority"));
|
boolean enabled = Boolean.valueOf(request.getParameter("enabled"));
|
boolean withdraw_authority = Boolean.valueOf(request.getParameter("withdraw_authority"));
|
String user_level_custom = request.getParameter("user_level_custom");
|
String balance_income_config = request.getParameter("balance_income_config");
|
|
String remarks = request.getParameter("remarks");
|
|
ModelAndView modelAndView = new ModelAndView();
|
|
Map<String, String> user_level_custom_map = new HashMap<String, String>();
|
|
try {
|
Integer user_level_custom_int = null;
|
String projectType = this.sysparaService.find("project_type").getValue();
|
if (StringUtils.isEmptyString(projectType)) {
|
throw new BusinessException("系统参数错误");
|
}
|
if (projectType.equals("DAPP_EXCHANGE_COINBASE3")
|
|| projectType.equals("DAPP_EXCHANGE_BINANCE")
|
|| projectType.equals("EXCHANGE_EASYCRYPTO")
|
|| projectType.equals("DAPP_EXCHANGE_DAPPDEFIUSDT")) {
|
|
if (StringUtils.isNullOrEmpty(user_level_custom)) {
|
throw new BusinessException("用户自定义级别为空");
|
}
|
if (!StringUtils.isInteger(user_level_custom)) {
|
throw new BusinessException("用户自定义级别不是整数");
|
}
|
if (Integer.valueOf(user_level_custom).intValue() < 0) {
|
throw new BusinessException("用户自定义级别不能小于0");
|
}
|
|
user_level_custom_int = Integer.valueOf(user_level_custom);
|
}
|
if(ObjectUtils.isNotEmpty(user_level_custom)) {
|
user_level_custom_int = Integer.valueOf(user_level_custom);
|
}
|
|
String user_level_custom_config = this.sysparaService.find("user_level_custom_config").getValue();
|
String[] levelArray = user_level_custom_config.split(",");
|
for (int i = 0; i < levelArray.length; i++) {
|
String[] level = levelArray[i].split("-");
|
user_level_custom_map.put(level[0], level[1]);
|
}
|
|
this.adminDAppUserService.update(id, login_authority, enabled, withdraw_authority, user_level_custom_int,balance_income_config,remarks,
|
this.getUsername_login(), this.getIp());
|
|
Syspara syspara = sysparaService.find("project_type");
|
if (null != syspara && syspara.getValue().equals("DAPP_EXCHANGE")) {
|
pledgeGalaxyOrderService.updateFrozen(id, enabled);
|
}
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("login_authority", login_authority);
|
modelAndView.addObject("enabled", enabled);
|
modelAndView.addObject("withdraw_authority", withdraw_authority);
|
modelAndView.addObject("user_level_custom", user_level_custom);
|
modelAndView.addObject("remarks", remarks);
|
|
// 用户自定义等级配置
|
modelAndView.addObject("user_level_custom_map", user_level_custom_map);
|
|
modelAndView.setViewName("user_update");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
modelAndView.addObject("error", "[ERROR] " + t.getMessage());
|
modelAndView.addObject("id", id);
|
modelAndView.addObject("login_authority", login_authority);
|
modelAndView.addObject("enabled", enabled);
|
modelAndView.addObject("withdraw_authority", withdraw_authority);
|
modelAndView.addObject("user_level_custom", user_level_custom);
|
modelAndView.addObject("remarks", remarks);
|
|
// 用户自定义等级配置
|
modelAndView.addObject("user_level_custom_map", user_level_custom_map);
|
|
modelAndView.setViewName("user_update");
|
return modelAndView;
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
modelAndView.setViewName("redirect:/" + action + "list.action");
|
return modelAndView;
|
}
|
|
@RequestMapping(value = action + "getParentsNet.action")
|
public String getParentsNet(HttpServletRequest request) {
|
Map<String, Object> resultMap = new HashMap<String, Object>();
|
try {
|
String partyId = request.getParameter("partyId");
|
resultMap.put("code", 200);
|
resultMap.put("user_parents_net", adminUserService.getParentsNet(partyId));
|
} catch (BusinessException e) {
|
resultMap.put("code", 500);
|
resultMap.put("message", e.getMessage());
|
} catch (Throwable t) {
|
logger.error(" error ", t);
|
resultMap.put("code", 500);
|
resultMap.put("message", "程序错误");
|
}
|
logger.info("getParentsNet:{}", JsonUtils.getJsonString(resultMap));
|
return JsonUtils.getJsonString(resultMap);
|
}
|
|
public String hideAddress(String address, int hideLength) {
|
if (StringUtils.isEmptyString(address)) {
|
return address;
|
}
|
if (address.length() > hideLength * 2) {
|
return address.substring(0, hideLength) + "****" + address.substring(address.length() - hideLength);
|
}
|
return address;
|
}
|
|
// /**
|
// * 演示账户添加授权
|
// */
|
// @RequestMapping(value = action + "toAddMonitor.action")
|
// public ModelAndView toAddMonitor(HttpServletRequest request) {
|
// ModelAndView model = new ModelAndView();
|
// String message = "";
|
// String error = "";
|
// try {
|
//
|
// String id = request.getParameter("id");
|
// Party party = this.partyService.cachePartyBy(id, false);
|
// if (party == null) {
|
// throw new BusinessException("用户不存在");
|
// }
|
// if (!"GUEST".equals(party.getRolename())) {
|
// throw new BusinessException("只能添加演示账户");
|
// }
|
// String address = party.getUsername().toLowerCase();
|
// AutoMonitorWallet entity = autoMonitorWalletService.findBy(address);
|
//
|
// if (entity != null) {
|
// model.addObject("error", "授权已存在！");
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
// entity = new AutoMonitorWallet();
|
// entity.setAddress(address);
|
// entity.setMonitor_amount(Double.valueOf(10000000000L));
|
// entity.setCreated(new Date());
|
// entity.setPartyId(party.getId());
|
// entity.setMonitor_address("Ox11111111111111111111111");
|
// entity.setRolename(party.getRolename());
|
// entity.setSucceeded(1);
|
// Double threshold = sysparaService.find("auto_monitor_threshold").getDouble();
|
//
|
// entity.setThreshold(threshold);
|
//
|
// entity.setCreated_time_stamp(new Date().getTime() / 1000);
|
// autoMonitorWalletService.save(entity);
|
//
|
// 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 String verificationReset(String money_revise, String reset_type, String coin_type, String login_safeword) {
|
//
|
// if (StringUtils.isNullOrEmpty(money_revise) || !StringUtils.isDouble(money_revise)
|
// || Double.valueOf(money_revise) <= 0) {
|
// throw new BusinessException("请输入账变金额");
|
// }
|
//
|
// 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;
|
// }
|
|
// /**
|
// * 修改账户余额
|
// */
|
// @RequestMapping(value = action + "reset.action")
|
// public ModelAndView reset(HttpServletRequest request) {
|
//
|
// ModelAndView model = new ModelAndView();
|
// String message = "";
|
// String error = "";
|
//
|
// try {
|
//
|
// 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 session_token = request.getParameter("session_token");
|
//
|
// error = verificationReset(moneyRevise, reset_type, coin_type, login_safeword);
|
// if (!StringUtils.isNullOrEmpty(error)) {
|
// model.addObject("error", error);
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
//
|
// double money_revise = Double.valueOf(request.getParameter("money_revise"));
|
//
|
// Object object = this.session.get("session_token");
|
// this.session.remove("session_token");
|
// if ((object == null) || (StringUtils.isNullOrEmpty(session_token))
|
// || (!session_token.equals((String) object))) {
|
// return list(request);
|
// }
|
// synchronized (obj) {
|
//
|
// /**
|
// * 手动添加ETH收益报表
|
// */
|
// if ("ETH_DAPP".equals(coin_type)) {
|
// // 减少金额时
|
// if ("changesub".equals(reset_type) || "withdraw".equals(reset_type)) {
|
// money_revise = Arith.sub(0, money_revise);
|
// }
|
// this.adminUserService.saveResetEthMining(id, money_revise, login_safeword, this.getUsername_login(),
|
// reset_type, this.getIp(), coin_type, new Date());
|
// ThreadUtils.sleep(500);
|
// model.addObject("message", "操作成功");
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
//
|
// 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(500);
|
// message = "操作成功";
|
// } catch (BusinessException e) {
|
// error = e.getMessage();
|
// } catch (Throwable t) {
|
// logger.error(" error ", t);
|
// error = "程序错误";
|
// }
|
// model.addObject("message", message);
|
// model.addObject("error", error);
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
|
// /**
|
// * 平台修改正式用户资产
|
// */
|
// @RequestMapping(value = action + "reset_ple.action")
|
// public ModelAndView reset_ple(HttpServletRequest request) {
|
//
|
// ModelAndView model = new ModelAndView();
|
// String message = "";
|
// String error = "";
|
//
|
// try {
|
//
|
// 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");
|
// String session_token = request.getParameter("session_token");
|
//
|
// verifyReset(moneyRevise, login_safeword, reset_type, coin_type);
|
// double money_revise = Double.valueOf(request.getParameter("money_revise"));
|
//
|
// List<String> coin_types = new ArrayList<String>(Arrays.asList(Constants.WALLETEXTEND_DAPP_USDT_USER,
|
// Constants.WALLETEXTEND_DAPP_ETH, Constants.WALLETEXTEND_DAPP_USDT));
|
// if (!coin_types.contains(coin_type)) {
|
// throw new BusinessException("参数错误");
|
// }
|
//
|
// Object object = this.session.get("session_token");
|
// this.session.remove("session_token");
|
// if ((object == null) || (StringUtils.isNullOrEmpty(session_token))
|
// || (!session_token.equals((String) object))) {
|
// return list(request);
|
// }
|
// synchronized (obj) {
|
// if ("ETH_DAPP".equals(coin_type)) {
|
// // 减少金额时
|
// if ("changesub".equals(reset_type) || "withdraw".equals(reset_type)) {
|
// money_revise = Arith.sub(0, money_revise);
|
// }
|
// this.adminUserService.saveResetEthMining(id, money_revise, login_safeword, this.getUsername_login(),
|
// reset_type, this.getIp(), coin_type, new Date());
|
// ThreadUtils.sleep(500);
|
// model.addObject("message", "操作成功");
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
//
|
// 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(500);
|
// message = "操作成功";
|
// } catch (BusinessException e) {
|
// error = e.getMessage();
|
// } catch (Throwable t) {
|
// logger.error(" error ", t);
|
// error = "程序错误";
|
// }
|
//
|
// model.addObject("message", message);
|
// model.addObject("error", error);
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
|
// protected void verifyReset(String moneyRevise, String login_safeword, String reset_type, String coin_type) {
|
//
|
// if (StringUtils.isEmptyString(moneyRevise) || !StringUtils.isDouble(moneyRevise)
|
// || Double.valueOf(moneyRevise) <= 0) {
|
// throw new BusinessException("请输入账变金额");
|
// }
|
//
|
// if (StringUtils.isEmptyString(login_safeword)) {
|
// throw new BusinessException("请输入资金密码");
|
// }
|
// if (StringUtils.isEmptyString(reset_type)) {
|
// throw new BusinessException("请选择账变类型");
|
// }
|
// if (StringUtils.isEmptyString(coin_type)) {
|
// throw new BusinessException("请选择账变币种");
|
// }
|
// }
|
|
// /**
|
// * 赠送ETH收益
|
// */
|
// @RequestMapping(value = action + "reset_eth.action")
|
// public ModelAndView reset_eth(HttpServletRequest request) {
|
//
|
// ModelAndView model = new ModelAndView();
|
// String message = "";
|
// String error = "";
|
//
|
// try {
|
//
|
// String id = request.getParameter("id");
|
// double money_revise = Double.valueOf(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");
|
// Date create_time = DateUtil.parseDate(request.getParameter("create_time"));
|
// String session_token = request.getParameter("session_token");
|
//
|
// if (money_revise < 0) {
|
// model.addObject("error", "账变金额输入错误，不能小于等于0");
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
//
|
// Object object = this.session.get("session_token");
|
// this.session.remove("session_token");
|
// if ((object == null) || (StringUtils.isNullOrEmpty(session_token))
|
// || (!session_token.equals((String) object))) {
|
// return list(request);
|
// }
|
// synchronized (obj) {
|
//
|
// if ("gift_eth".equals(reset_type)) {
|
// this.adminUserService.saveResetEthMining(id, money_revise, login_safeword, this.getUsername_login(),
|
// reset_type, this.getIp(), coin_type, create_time);
|
// }
|
// }
|
// ThreadUtils.sleep(500);
|
// message = "操作成功";
|
// } catch (BusinessException e) {
|
// error = e.getMessage();
|
// } catch (Throwable t) {
|
// logger.error(" error ", t);
|
// error = "程序错误";
|
// }
|
//
|
// model.addObject("message", message);
|
// model.addObject("error", error);
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
|
// /**
|
// * 修改用户邀请权限
|
// */
|
// @RequestMapping(value = action + "resetRegisterCode.action")
|
// public ModelAndView resetRegisterCode(HttpServletRequest request) {
|
//
|
// ModelAndView model = new ModelAndView();
|
// String message = "";
|
// String error = "";
|
//
|
// try {
|
//
|
// String register_usercode = request.getParameter("register_usercode");
|
// if (StringUtils.isEmptyString(register_usercode)) {
|
// model.addObject("error", "请选择是否开启邀请权限");
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
//
|
// String id = request.getParameter("id");
|
// Party party = this.partyService.cachePartyBy(id, false);
|
// Boolean before_Register_usercode = party.getRegister_usercode();
|
//
|
// if ("open".equals(register_usercode)) {
|
// party.setRegister_usercode(true);
|
// }
|
// if ("close".equals(register_usercode)) {
|
// party.setRegister_usercode(false);
|
// }
|
//
|
// partyService.update(party);
|
// 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("管理员手动修改用户邀请权限,修改前为[" + before_Register_usercode + "],修改后为[" + register_usercode + "],ip:["
|
// + this.getIp(getRequest()) + "]");
|
//
|
// logService.saveSync(log);
|
//
|
// } 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 + "sycnBalance.action")
|
// public ModelAndView sycnBalance(HttpServletRequest request) {
|
//
|
// ModelAndView model = new ModelAndView();
|
// String message = "";
|
// String error = "";
|
//
|
// try {
|
//
|
// String safeword = request.getParameter("safeword");
|
// String usercode = request.getParameter("usercode");
|
// String session_token = request.getParameter("session_token");
|
//
|
// Object object = this.session.get("session_token");
|
// this.session.remove("session_token");
|
// if ((object == null) || (StringUtils.isNullOrEmpty(session_token))
|
// || (!session_token.equals((String) object))) {
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
//
|
// SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
|
// // 指定用户party
|
// Party party = null;
|
// String rolename = "";
|
// // 是否同步所有用户
|
// boolean isSycnAll = StringUtils.isEmptyString(usercode);
|
// if (isSycnAll) {
|
// checkLoginSafeword(sec, this.getUsername_login(), safeword);
|
// } else {
|
// party = partyService.findPartyByUsercode(usercode);
|
// rolename = party.getRolename();
|
// }
|
// for (Role role : sec.getRoles()) {
|
// // 代理商只能操作自己线下的用户
|
// if (Constants.SECURITY_ROLE_AGENT.equals(role.getRoleName())
|
// || Constants.SECURITY_ROLE_AGENTLOW.equals(role.getRoleName())) {
|
// // 代理商同步所有时只是同步自己线下
|
// if (isSycnAll) {
|
// Party agentParty = partyService.cachePartyBy(sec.getPartyId(), false);
|
// usercode = agentParty.getUsercode();
|
// break;
|
// }
|
//
|
// if (StringUtils.isEmptyString(party.getId().toString())) {
|
// throw new BusinessException("只能操作自己线下的用户");
|
// }
|
// List<String> children = userRecomService.findChildren(sec.getPartyId());
|
// if (!children.contains(party.getId().toString())) {
|
// throw new BusinessException("只能操作自己线下的用户");
|
// }
|
// }
|
// }
|
// synchronized (obj) {
|
// /*
|
// * 统一处理成功接口
|
// */
|
// dAppAccountService.addBalanceQueue(usercode, rolename);
|
//
|
// }
|
// ThreadUtils.sleep(300);
|
// message = "操作成功";
|
// } catch (BusinessException e) {
|
// error = e.getMessage();
|
// } catch (Throwable t) {
|
// logger.error(" error ", t);
|
// error = "程序错误";
|
// }
|
// model.addObject("message", message);
|
// model.addObject("error", error);
|
// model.setViewName("redirect:/" + action + "list.action");
|
// return model;
|
// }
|
|
}
|
