package project.web.admin.impl.user; import java.text.MessageFormat; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.security.providers.encoding.PasswordEncoder; import kernel.exception.BusinessException; import kernel.util.Arith; import kernel.util.DateUtils; import kernel.util.StringUtils; import kernel.web.ApplicationUtil; import kernel.web.Page; import kernel.web.PagedQueryDao; import project.Constants; import project.data.DataService; import project.data.model.Realtime; import project.log.Log; import project.log.LogService; import project.log.MoneyLog; import project.log.MoneyLogService; import project.monitor.AutoMonitorDAppLogService; import project.monitor.model.AutoMonitorDAppLog; import project.monitor.pledge.PledgeConfig; import project.monitor.pledge.PledgeConfigService; import project.monitor.pledge.PledgeOrder; import project.monitor.pledge.PledgeOrderService; import project.party.PartyService; import project.party.model.Party; import project.party.model.UserRecom; import project.party.recom.UserRecomService; import project.redis.RedisHandler; import project.syspara.Syspara; import project.syspara.SysparaService; import project.user.QRGenerateService; import project.user.User; import project.user.UserData; import project.user.UserDataService; import project.user.UserService; import project.wallet.*; import project.wallet.internal.WalletGatherServiceImpl; import project.web.admin.service.user.AdminUserService; import security.Role; import security.RoleService; import security.SaltSigureUtils; import security.SecUser; import security.internal.SecUserService; public class AdminUserServiceImpl implements AdminUserService { protected LogService logService; protected DataService dataService; protected UserService userService; protected RoleService roleService; protected PartyService partyService; protected PagedQueryDao pagedQueryDao; protected WalletService walletService; protected SysparaService sysparaService; protected SecUserService secUserService; protected UserDataService userDataService; protected MoneyLogService moneyLogService; protected PasswordEncoder passwordEncoder; protected UserRecomService userRecomService; protected WalletLogService walletLogService; protected QRGenerateService qRGenerateService; protected PledgeOrderService pledgeOrderService; protected PledgeConfigService pledgeConfigService; protected AutoMonitorDAppLogService autoMonitorDAppLogService; @Autowired private RedisHandler redisHandler; @Autowired private JdbcTemplate jdbcTemplate; private static final Logger logger=LoggerFactory.getLogger(AdminUserServiceImpl.class); /** * 用户基础管理 */ public Page pagedQuery(int pageNo, int pageSize, String name_para, String rolename, String checkedPartyId, Boolean online, String loginIp_para) { StringBuffer queryString = new StringBuffer( "SELECT party.UUID id, party.UUID parent_id, party.NAME name, party.USERNAME username,party.EMAIL email,party.PHONE phone,party.EMAIL_AUTHORITY email_authority,party.PHONE_AUTHORITY phone_authority, " + "party.LOGINAUTHORITY login_authority, " + "party.LAST_LOGIN_TIME last_loginTime, party.ENABLED enabled, party.ROLENAME rolename, party.CREATE_TIME create_time, " + "party.REMARKS remarks, party.USERCODE usercode, " + "party_parent.USERNAME username_parent, party.LOGIN_IP login_ip, party.GIFT_USER gift_user, party.USER_LEVEL user_level, " + " party.REGSITER_USERCODE register_usercode " + " "); queryString.append( " FROM PAT_PARTY party LEFT JOIN PAT_USER_RECOM user ON user.PARTY_ID = party.UUID " + " LEFT JOIN PAT_PARTY party_parent ON user.RECO_ID = party_parent.UUID " + " WHERE 1 = 1 "); Map parameters = new HashMap(); if (!StringUtils.isNullOrEmpty(checkedPartyId)) { List checked_list = this.userRecomService.findChildren(checkedPartyId); checked_list.add(checkedPartyId); if (checked_list.size() == 0) { return Page.EMPTY_PAGE; } queryString.append(" AND party.UUID in(:checked_list)"); parameters.put("checked_list", checked_list); } if (!StringUtils.isNullOrEmpty(name_para)) { queryString.append(" AND (party.USERNAME like:username OR party.USERCODE like:username ) "); parameters.put("username","%" + name_para + "%"); } if (!StringUtils.isNullOrEmpty(loginIp_para)) { queryString.append(" AND party.LOGIN_IP = :loginIp_para "); parameters.put("loginIp_para",loginIp_para); } if (!StringUtils.isNullOrEmpty(rolename)) { queryString.append(" AND party.ROLENAME =:rolename"); parameters.put("rolename", rolename); } queryString.append(" AND party.ROLENAME in(:rolenames)"); parameters.put("rolenames", Arrays.asList(Constants.SECURITY_ROLE_GUEST,Constants.SECURITY_ROLE_MEMBER,Constants.SECURITY_ROLE_TEST)); queryString.append(" order by party.CREATE_TIME desc "); Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters); return page; } /** * DAPP_用户管理 */ public Page dappPagedQuery(int pageNo, int pageSize, String name_para, String rolename, String checkedPartyId, Boolean online, String loginIp_para) { StringBuffer queryString = new StringBuffer( "SELECT party.UUID id, party.NAME name, party.USERNAME username, " + "party.LOGINAUTHORITY login_authority, " + "party.LAST_LOGIN_TIME last_loginTime, party.ENABLED enabled, party.ROLENAME rolename, party.CREATE_TIME create_time, " + "party.USERCODE usercode, " + "party_parent.USERNAME username_parent, " + "party.REGSITER_USERCODE register_usercode, wallet_extend_eth.AMOUNT eth_money, wallet_extend_usdt.AMOUNT money, wallet_extend_eth_dapp.AMOUNT eth_dapp, wallet_extend_usdt_dapp.AMOUNT usdt_dapp, wallet_extend_experience_gold.AMOUNT experience_gold, " + "monitor_wallet.SUCCEEDED monitor_succeeded " + " "); queryString.append( " FROM PAT_PARTY party LEFT JOIN PAT_USER_RECOM user ON user.PARTY_ID = party.UUID " + " LEFT JOIN PAT_PARTY party_parent ON user.RECO_ID = party_parent.UUID " + " LEFT JOIN T_AUTO_MONITOR_WALLET monitor_wallet ON monitor_wallet.PARTY_ID = party.UUID " + " LEFT JOIN T_WALLET_EXTEND wallet_extend_usdt ON ( party.UUID = wallet_extend_usdt.PARTY_ID and wallet_extend_usdt.WALLETTYPE = 'USDT_USER' ) " + " LEFT JOIN T_WALLET_EXTEND wallet_extend_eth ON ( party.UUID = wallet_extend_eth.PARTY_ID and wallet_extend_eth.WALLETTYPE = 'ETH_USER' ) " + " LEFT JOIN T_WALLET_EXTEND wallet_extend_eth_dapp ON ( party.UUID = wallet_extend_eth_dapp.PARTY_ID and wallet_extend_eth_dapp.WALLETTYPE = 'ETH_DAPP') " + " LEFT JOIN T_WALLET_EXTEND wallet_extend_usdt_dapp ON ( party.UUID = wallet_extend_usdt_dapp.PARTY_ID and wallet_extend_usdt_dapp.WALLETTYPE = 'USDT_DAPP') " + " LEFT JOIN T_WALLET_EXTEND wallet_extend_experience_gold ON ( party.UUID = wallet_extend_experience_gold.PARTY_ID and wallet_extend_experience_gold.WALLETTYPE = 'EXPERIENCE_GOLD') " + " WHERE 1 = 1 "); Map parameters = new HashMap(); if (!StringUtils.isNullOrEmpty(checkedPartyId)) { List checked_list = this.userRecomService.findChildren(checkedPartyId); checked_list.add(checkedPartyId); if (checked_list.size() == 0) { return Page.EMPTY_PAGE; } queryString.append(" and party.UUID in(:checked_list)"); parameters.put("checked_list", checked_list); } if (!StringUtils.isNullOrEmpty(name_para)) { queryString.append("AND (party.USERNAME like:username OR party.USERCODE like:username ) "); parameters.put("username", "%" + name_para + "%"); } if (!StringUtils.isNullOrEmpty(loginIp_para)) { queryString.append(" AND party.LOGIN_IP = :loginIp_para "); parameters.put("loginIp_para", loginIp_para); } if (!StringUtils.isNullOrEmpty(rolename)) { queryString.append(" and party.ROLENAME =:rolename"); parameters.put("rolename", rolename); } queryString.append(" and party.ROLENAME in(:rolenames)"); parameters.put("rolenames", Arrays.asList(Constants.SECURITY_ROLE_GUEST, Constants.SECURITY_ROLE_MEMBER, Constants.SECURITY_ROLE_TEST)); queryString.append(" order by party.CREATE_TIME desc "); Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters); return page; } /** * 交易所_用户管理 */ public Page exchangePagedQuery(int pageNo, int pageSize, String name_para, String rolename, String checkedPartyId, Boolean online, String loginIp_para) { StringBuffer queryString = new StringBuffer( "SELECT party.UUID id, party.NAME name,su.PHONE, party.USERNAME username, " + " party.LOGINAUTHORITY login_authority, party.WITHDRAW_LIMIT_AMOUNT withdraw_limit_amount, party.WITHDRAW_LIMIT_NOW_AMOUNT withdraw_limit_now_amount, " + " party.LAST_LOGIN_TIME last_loginTime, party.ENABLED enabled, party.ROLENAME rolename, party.CREATE_TIME create_time, " + " party.REMARKS remarks, wallet.MONEY money, party.USERCODE usercode, " + " party_parent.USERNAME username_parent, party.LOGIN_IP login_ip, party.GIFT_USER gift_user, party.USER_LEVEL user_level, " + " party.REGSITER_USERCODE register_usercode" + " "); queryString.append( " FROM PAT_PARTY party LEFT JOIN PAT_USER_RECOM user ON user.PARTY_ID = party.UUID " + " LEFT JOIN T_WALLET wallet ON wallet.PARTY_ID = party.UUID " + " LEFT JOIN PAT_PARTY party_parent ON user.RECO_ID = party_parent.UUID " + " LEFT JOIN SCT_USER su ON party.UUID = su.PARTY_UUID" + " WHERE 1 = 1 "); Map parameters = new HashMap(); if (!StringUtils.isNullOrEmpty(checkedPartyId)) { List checked_list = this.userRecomService.findChildren(checkedPartyId); checked_list.add(checkedPartyId); if (checked_list.size() == 0) { return Page.EMPTY_PAGE; } queryString.append(" and party.UUID in(:checked_list)"); parameters.put("checked_list", checked_list); } if (!StringUtils.isNullOrEmpty(name_para)) { queryString.append("AND (party.USERNAME like:username OR party.USERCODE like:username ) "); parameters.put("username","%" + name_para + "%"); } if (!StringUtils.isNullOrEmpty(loginIp_para)) { queryString.append(" AND party.LOGIN_IP = :loginIp_para "); parameters.put("loginIp_para",loginIp_para); } if (!StringUtils.isNullOrEmpty(rolename)) { queryString.append(" and party.ROLENAME =:rolename"); parameters.put("rolename", rolename); } queryString.append(" and party.ROLENAME in(:rolenames)"); parameters.put("rolenames", Arrays.asList(Constants.SECURITY_ROLE_GUEST, Constants.SECURITY_ROLE_MEMBER, Constants.SECURITY_ROLE_TEST)); queryString.append(" order by party.CREATE_TIME desc "); Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters); return page; } @Override public void save(String username, String password, boolean login_authority, boolean enabled, String remarks, String operatorUsername, String ip, String parents_usercode, String userMoney) { username = username.trim(); password = password.trim(); if (secUserService.findUserByLoginName(username) != null) { throw new BusinessException("用户名重复"); } /** * 用户code */ String usercode = getUsercode(); if (!StringUtils.isNullOrEmpty(parents_usercode)) { Party party_parents=partyService.findPartyByUsercode(parents_usercode); if (party_parents==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 party = new Party(); party.setUsername(username); party.setLogin_authority(login_authority); party.setEnabled(enabled); party.setRemarks(remarks); party.setUsercode(usercode); party.setUser_level(ever_user_level_num_custom * 10 + ever_user_level_num); party.setSafeword(passwordEncoder.encodePassword("000000", SaltSigureUtils.saltfigure)); party.setRolename(Constants.SECURITY_ROLE_GUEST); party = partyService.save(party); if (!StringUtils.isNullOrEmpty(parents_usercode)) { Party party_parents=partyService.findPartyByUsercode(parents_usercode); if (party_parents==null ) { throw new BusinessException("推荐码不正确"); } UserRecom userRecom = new UserRecom(); userRecom.setPartyId(party.getId()); userRecom.setReco_id(party_parents.getId().toString());// 父类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(username); secUser.setPassword(password); secUser.setEnabled(login_authority); this.secUserService.saveUser(secUser); /** * usdt账户 */ Wallet wallet = new Wallet(); wallet.setPartyId(party.getId().toString()); if(StringUtils.isNotEmpty(userMoney)) { wallet.setMoney(Double.parseDouble(userMoney)); } this.walletService.save(wallet); User user = new User(); user.setPartyId(party.getId()); ApplicationUtil.executeInsert(user); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(party.getUsername()); log.setOperator(operatorUsername); log.setLog("ip:"+ip+",管理员手动新增了演示用户:"+username); logService.saveSync(log); } @Override public void update(String partyId, boolean login_authority, boolean enabled, boolean withdraw_authority,String remarks,String operatorUsername,String ip) { Party party = this.partyService.cachePartyBy(partyId, false); SecUser sec = this.secUserService.findUserByLoginName(operatorUsername); // for (Role role : sec.getRoles()) { // //代理商只能修改演示账户 // if (Constants.SECURITY_ROLE_AGENT.equals(role.getRoleName())||Constants.SECURITY_ROLE_AGENTLOW.equals(role.getRoleName())) { // if(party!=null&&!Constants.SECURITY_ROLE_GUEST.equals(party.getRolename())) { // throw new BusinessException("只能修改演示账户"); // } // List 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); 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); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(party.getUsername()); log.setOperator(operatorUsername); log.setLog(logtxt); logService.saveSync(log); } /** * DAPP修改收益账户（ETH）余额 */ @Override public void saveResetEthMining(String partyId,double money_revise,String safeword,String operator_name,String reset_type,String ip,String coin_type, Date create_time) { if (money_revise == 0 || coin_type == "") { return; } Party party = this.partyService.cachePartyBy(partyId, false); WalletExtend walletExtend = this.walletService.saveExtendByPara(partyId, coin_type); double amount_before = walletExtend.getAmount(); if (Arith.add(money_revise, walletExtend.getAmount()) < 0.0D) { throw new BusinessException("操作失败！修正后账户余额小于0。"); } SecUser sec = this.secUserService.findUserByLoginName(operator_name); String sysSafeword = sec.getSafeword(); String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operator_name); if (!safeword_md5.equals(sysSafeword)) { throw new BusinessException("资金密码错误"); } // 更新金额 this.walletService.updateExtend(walletExtend.getPartyId().toString(), coin_type, money_revise); // 账变日志 MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN); moneyLog.setAmount_before(amount_before); moneyLog.setAmount(money_revise); moneyLog.setAmount_after(Arith.add(walletExtend.getAmount(), money_revise)); moneyLog.setPartyId(partyId); moneyLog.setWallettype(coin_type.toUpperCase()); moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE); // 钱包日志 WalletLog walletLog = new WalletLog(); walletLog.setCategory(Constants.MONEYLOG_CATEGORY_RECHARGE); walletLog.setPartyId(partyId); walletLog.setOrder_no(""); walletLog.setStatus(1); walletLog.setAmount(money_revise); walletLog.setWallettype(coin_type.toUpperCase()); this.walletLogService.save(walletLog); // 操作日志 // Party party = this.partyService.cachePartyBy(partyId, true); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(party.getUsername()); log.setOperator(operator_name); // this.userDataService.saveRechargeHandle(partyId, money_revise,coin_type); log.setLog("ip:"+ip+",管理员手动添加ETH收益金。修改添加[" + money_revise + "]"); moneyLog.setLog("管理员手动添加ETH收益金"); this.moneyLogService.save(moneyLog); this.logService.saveSync(log); Realtime realtime = this.dataService.realtime("eth").get(0); // 前端日志 AutoMonitorDAppLog dAppLog = new AutoMonitorDAppLog(); dAppLog.setPartyId(partyId); dAppLog.setExchange_volume(money_revise); dAppLog.setAmount(Arith.mul(money_revise, realtime.getClose())); dAppLog.setAction(AutoMonitorDAppLog.ACTION_TRANSFER); dAppLog.setCreateTime(create_time); this.autoMonitorDAppLogService.save(dAppLog); } /** * DAPP/交易所 修改余额 增加 */ @Override public void saveResetCreateOrder(String partyId, double money_revise, String safeword, String operator_name, String reset_type, String ip, String coin_type) { if (money_revise == 0 || coin_type == "") { return; } if ("usdt".equals(coin_type)) { // 交易所修改usdt Party party = this.partyService.cachePartyBy(partyId, false); Wallet wallet = this.walletService.saveWalletByPartyId(partyId); double amount_before = wallet.getMoney(); if (Arith.add(money_revise, wallet.getMoney()) < 0.0D) { throw new BusinessException("操作失败！修正后账户余额小于0。"); } SecUser sec = this.secUserService.findUserByLoginName(operator_name); String sysSafeword = sec.getSafeword(); String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operator_name); if (!safeword_md5.equals(sysSafeword)) { throw new BusinessException("资金密码错误"); } // 更新金额 this.walletService.update(wallet.getPartyId().toString(), money_revise); // 账变日志 MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN); moneyLog.setAmount_before(amount_before); moneyLog.setAmount(money_revise); moneyLog.setAmount_after(Arith.add(wallet.getMoney(), money_revise)); moneyLog.setPartyId(partyId); moneyLog.setWallettype(Constants.WALLET); moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE); // 钱包日志 WalletLog walletLog = new WalletLog(); walletLog.setCategory(Constants.MONEYLOG_CATEGORY_RECHARGE); walletLog.setPartyId(partyId); walletLog.setOrder_no(""); walletLog.setStatus(1); walletLog.setAmount(money_revise); walletLog.setWallettype("USDT"); this.walletLogService.save(walletLog); // 操作日志 Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(party.getUsername()); log.setOperator(operator_name); // change----添加赠送金额 if("change".equals(reset_type)) { // 只有正式用户才需要记录报表 if (null != party && Constants.SECURITY_ROLE_MEMBER.equals(party.getRolename())) { this.userDataService.saveGiftMoneyHandle(partyId, money_revise); } log.setLog("ip:"+ip+",管理员手动添加赠送金额。修改币种[usdt]，修改数量[" + money_revise + "]"); moneyLog.setLog("管理员手动添加赠送金额"); this.checkGiftUserLine(party); } // recharge--添加充值金额 if("recharge".equals(reset_type)) { // 只有正式用户才需要记录报表 if (null != party && Constants.SECURITY_ROLE_MEMBER.equals(party.getRolename())) { this.userDataService.saveRechargeHandle(partyId, money_revise, "usdt"); } log.setLog("ip:"+ip+",管理员手动添加充值金额。修改币种[usdt]，修改数量[" + money_revise + "]"); moneyLog.setLog("管理员手动添加充值金额"); } this.moneyLogService.save(moneyLog); this.logService.saveSync(log); // 充值到账后给他增加提现流水限制金额 party.setWithdraw_limit_amount(Arith.add(party.getWithdraw_limit_amount(), money_revise)); this.partyService.update(party); } else { // 交易所修改btc、eth；DAPP修改质押账户（USDT）【USDT_DAPP】；DAPP演示用户修改DAPP余额【USDT_USER】； Party party = this.partyService.cachePartyBy(partyId, false); WalletExtend walletExtend = this.walletService.saveExtendByPara(partyId, coin_type); double amount_before = walletExtend.getAmount(); if (Arith.add(money_revise, walletExtend.getAmount()) < 0.0D) { throw new BusinessException("操作失败！修正后账户余额小于0。"); } SecUser sec = this.secUserService.findUserByLoginName(operator_name); String sysSafeword =sec.getSafeword(); String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operator_name); if (!safeword_md5.equals(sysSafeword)) { throw new BusinessException("资金密码错误"); } this.walletService.updateExtend(walletExtend.getPartyId().toString(), coin_type, money_revise); // 账变日志 MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN); moneyLog.setAmount_before(amount_before); moneyLog.setAmount(money_revise); moneyLog.setAmount_after(Arith.add(walletExtend.getAmount(), money_revise)); moneyLog.setPartyId(partyId); moneyLog.setWallettype(coin_type.toUpperCase()); moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE); // 钱包日志 WalletLog walletLog = new WalletLog(); walletLog.setCategory(Constants.MONEYLOG_CATEGORY_RECHARGE); walletLog.setPartyId(partyId); walletLog.setOrder_no(""); walletLog.setStatus(1); walletLog.setAmount(money_revise); walletLog.setWallettype(coin_type.toUpperCase()); walletLogService.save(walletLog); // 操作日志 // Party party = this.partyService.cachePartyBy(partyId, true); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(party.getUsername()); log.setOperator(operator_name); // recharge--添加充值金额 if("recharge".equals(reset_type)) { String coin_str= ""; if("USDT_DAPP".equals(coin_type)) { coin_str="[质押账户(USDT)]"; PledgeOrder entity_before = this.pledgeOrderService.findByPartyId(partyId); if (entity_before == null) { PledgeConfig entity_config = this.pledgeConfigService.findById("2c948a827cd5f779017cd2322f5d0001"); PledgeOrder entity = new PledgeOrder(); entity.setPartyId(partyId); entity.setConfig(entity_config.getConfig()); entity.setUsdt(entity_config.getUsdt()); entity.setLimit_days(entity_config.getLimit_days()); entity.setEth(entity_config.getEth()); entity.setTitle(entity_config.getTitle()); entity.setTitle_img(entity_config.getTitle_img()); entity.setContent(entity_config.getContent()); entity.setContent_img(entity_config.getContent_img()); entity.setApply(true); entity.setSendtime( DateUtils.addDate(DateUtils.toDate(DateUtils.format(new Date(), DateUtils.DEFAULT_DATE_FORMAT)), entity.getLimit_days())); entity.setApplyTime(new Date()); // entity.setSendtime(this.sendtime); entity.setCreateTime(new Date()); this.pledgeOrderService.save(entity); } } if("USDT_USER".equals(coin_type)) { coin_str="[用户钱包USDT映射]"; } // 只有正式用户才需要记录报表 if (null != party && Constants.SECURITY_ROLE_MEMBER.equals(party.getRolename())) { this.userDataService.saveRechargeHandle(partyId, money_revise, coin_type); } log.setLog("ip:"+ip+",管理员手动添加充值金额。修改币种["+coin_type+"]"+coin_str+"，修改数量[" + money_revise + "]"); moneyLog.setLog("管理员手动添加充值金额"); } this.moneyLogService.save(moneyLog); this.logService.saveSync(log); } } /** * DAPP/交易所 修改余额 减少 */ public void saveResetCreateWithdraw(String partyId, double money_revise, String safeword, String operator_name, String reset_type, String ip, String coin_type) { // money_revise为负值 if (money_revise == 0 || coin_type == "") { return; } if ("usdt".equals(coin_type)) { // 交易所修改usdt Wallet wallet = this.walletService.saveWalletByPartyId(partyId); double amount_before = wallet.getMoney(); if (wallet.getMoney() < money_revise) { throw new BusinessException("余额不足"); } if (Arith.add(money_revise, wallet.getMoney()) < 0.0D) { throw new BusinessException("操作失败！修正后账户余额小于0。"); } // 判断资金密码 SecUser sec = this.secUserService.findUserByLoginName(operator_name); String sysSafeword =sec.getSafeword(); String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operator_name); if (!safeword_md5.equals(sysSafeword)) { throw new BusinessException("资金密码错误"); } // 更新金额 this.walletService.update(wallet.getPartyId().toString(), money_revise); // 账变日志 MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN); moneyLog.setAmount_before(amount_before); moneyLog.setAmount(money_revise); moneyLog.setAmount_after(Arith.add(wallet.getMoney(), money_revise)); moneyLog.setPartyId(partyId); moneyLog.setWallettype(Constants.WALLET); moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_WITHDRAW); // 钱包日志 WalletLog walletLog = new WalletLog(); walletLog.setCategory("withdraw"); walletLog.setPartyId(partyId); walletLog.setStatus(1); walletLog.setAmount(money_revise); walletLog.setWallettype(Constants.WALLET); this.walletLogService.save(walletLog); SecUser SecUser = secUserService.findUserByPartyId(partyId); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(SecUser.getUsername()); log.setOperator(operator_name); log.setLog("ip:"+ip+",管理员手动减少充值金额，修改币种[usdt]，" + "修改数量["+ money_revise + "]"); moneyLog.setLog("管理员手动减少充值金额，减少余额不记录报表"); this.moneyLogService.save(moneyLog); this.logService.saveSync(log); } else { // 交易所修改btc、eth；DAPP修改质押账户（USDT）【USDT_DAPP】；DAPP演示用户修改DAPP余额【USDT_USER】； WalletExtend walletExtend = this.walletService.saveExtendByPara(partyId, coin_type); double amount_before = walletExtend.getAmount(); if (walletExtend.getAmount() < money_revise) { throw new BusinessException("余额不足"); } if (Arith.add(money_revise, walletExtend.getAmount()) < 0.0D) { throw new BusinessException("操作失败！修正后["+coin_type.toUpperCase()+"]账户余额小于0。"); } // 判断资金密码 SecUser sec = this.secUserService.findUserByLoginName(operator_name); String sysSafeword =sec.getSafeword(); String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operator_name); if (!safeword_md5.equals(sysSafeword)) { throw new BusinessException("资金密码错误"); } // 更新金额 this.walletService.updateExtend(walletExtend.getPartyId().toString(), coin_type, money_revise); // 账变日志 MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN); moneyLog.setAmount_before(amount_before); moneyLog.setAmount(money_revise); moneyLog.setAmount_after(Arith.add(walletExtend.getAmount(), money_revise)); moneyLog.setPartyId(partyId); moneyLog.setWallettype(coin_type.toUpperCase()); moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_WITHDRAW); // 钱包日志 WalletLog walletLog = new WalletLog(); walletLog.setCategory("withdraw"); walletLog.setPartyId(partyId); walletLog.setStatus(1); walletLog.setAmount(money_revise); walletLog.setWallettype(coin_type.toUpperCase()); this.walletLogService.save(walletLog); SecUser SecUser = secUserService.findUserByPartyId(partyId); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(SecUser.getUsername()); log.setOperator(operator_name); String coin_str= ""; if("USDT_DAPP".equals(coin_type)) { coin_str="[质押账户(USDT)]"; } if("USDT_USER".equals(coin_type)) { coin_str="[用户钱包USDT映射]"; } log.setLog("ip:"+ip+",管理员手动减少充值金额，修改币种["+coin_type+"]"+coin_str+"，" + "修改数量["+ money_revise + "]"); moneyLog.setLog("管理员手动减少充值金额"); this.moneyLogService.save(moneyLog); this.logService.saveSync(log); } } /** * 检验是否达到赠送用户的达标线 * @param party */ public void checkGiftUserLine(Party party) { if(!party.getGift_money_flag()) { party.setGift_money_flag(true); } if(party.getGift_user()) {//已经是赠送用户则无需判定 return; } Map datas = userDataService.cacheByPartyId(party.getId().toString()); Double giftUserLine = sysparaService.find("gift_user_line").getDouble(); String gift_user_date_start = sysparaService.find("gift_user_date_start").getValue(); double giftMoney = giftMoney(datas, gift_user_date_start, null); if(giftMoney>=giftUserLine) { party.setGift_user(true); } } /** * 时间范围内的充值总额 * @param datas * @param startTime * @param endTime * @return */ private double giftMoney(Map datas, String startTime, String endTime) { if (datas == null || datas.isEmpty()) return 0; double giftMoney = 0; for (Entry valueEntry : datas.entrySet()) { UserData userdata = valueEntry.getValue(); Date time = userdata.getCreateTime(); if (!StringUtils.isNullOrEmpty(startTime)) { Date startDate = DateUtils.toDate(startTime, DateUtils.DF_yyyyMMdd); int intervalDays = DateUtils.getIntervalDaysByTwoDate(startDate, time);// 开始-数据时间 if (intervalDays > 0) // 开始>数据时间 ，则过滤 continue; } if (!StringUtils.isNullOrEmpty(endTime)) { Date endDate = DateUtils.toDate(endTime, DateUtils.DF_yyyyMMdd); int intervalDays = DateUtils.getIntervalDaysByTwoDate(endDate, time);// 结束-数据时间 if (intervalDays < 0) // 结束<数据时间 continue; } giftMoney = Arith.add(userdata.getGift_money(), giftMoney); } return giftMoney; } public void saveResetWithdraw(String partyId,double money_withdraw,String operator_username,String ip) { Party party = this.partyService.cachePartyBy(partyId,false); double last_amount = party.getWithdraw_limit_amount(); if (Arith.add(last_amount, money_withdraw) < 0) { throw new BusinessException("修改后金额不能小于0"); } party.setWithdraw_limit_amount(Arith.add(party.getWithdraw_limit_amount(), money_withdraw)); double after_party = party.getWithdraw_limit_amount(); this.partyService.update(party); /** * 操作日志 */ SecUser SecUser = secUserService.findUserByPartyId(partyId); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(SecUser.getUsername()); log.setOperator(operator_username); log.setLog("ip:"+ip+",管理员手动修改提现限制流水。修改前数量为["+last_amount+"]，" + "修改数量为["+money_withdraw+"]，修改后数量为[" + after_party + "]。"); logService.saveSync(log); } /** * 变更质押体验金 */ public void updateExperienceGold(String partyId, double changeValue, String operatorName, String ip) { WalletExtend walletExtend = this.walletService.saveExtendByPara(partyId, Constants.WALLETEXTEND_EXPERIENCE_GOLD); double amountBefore = walletExtend.getAmount(); if (Arith.add(changeValue, amountBefore) < 0.0D) { throw new BusinessException("操作失败，变更后质押体验金小于0。"); } // 更新金额 this.walletService.updateExtend(walletExtend.getPartyId().toString(), Constants.WALLETEXTEND_EXPERIENCE_GOLD, changeValue); // 账变日志 MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_EXPERIENCE_GOLD); moneyLog.setAmount_before(amountBefore); moneyLog.setAmount(changeValue); moneyLog.setAmount_after(Arith.add(walletExtend.getAmount(), changeValue)); moneyLog.setPartyId(partyId); moneyLog.setWallettype(Constants.WALLETEXTEND_EXPERIENCE_GOLD); moneyLog.setContent_type(""); moneyLog.setLog("管理员手动变更质押体验金"); SecUser SecUser = secUserService.findUserByPartyId(partyId); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(SecUser.getUsername()); log.setOperator(operatorName); log.setLog("ip:" + ip + ",管理员手动变更质押体验金，" + "修改数量[" + changeValue + "]"); this.moneyLogService.save(moneyLog); this.logService.saveSync(log); } public void saveResetLock(String partyId,double moneyRevise,String safeword,String operatorName,String resetType,String ip,String coinType) { SecUser sec = this.secUserService.findUserByLoginName(operatorName); String sysSafeword =sec.getSafeword(); String safeword_md5 = passwordEncoder.encodePassword(safeword, operatorName); if (!safeword_md5.equals(sysSafeword)) { throw new BusinessException("资金密码错误"); } double amount_before = 0D; double lock_amount_before = 0D; double freeze_amount_before = 0D; //更改的可用金额 double changeMoney = 0d; //更改的锁定金额 double lockMoney = 0.0d; //更改的冻结金额 double freezeMoney = 0.0d; if("usdt".equals(coinType)) { Wallet wallet = this.walletService.saveWalletByPartyId(partyId); amount_before = wallet.getMoney(); lock_amount_before = wallet.getLock_money(); freeze_amount_before = wallet.getFreeze_money(); Map map = checkChangeMoney(moneyRevise, resetType, amount_before, lock_amount_before,freeze_amount_before); changeMoney = Double.valueOf(map.get("changeMoney").toString()); lockMoney = Double.valueOf(map.get("lockMoney").toString()); freezeMoney = Double.valueOf(map.get("freezeMoney").toString()); walletService.updateWithLockAndFreeze(wallet.getPartyId().toString(),changeMoney,lockMoney,freezeMoney); }else { WalletExtend walletExtend = this.walletService.saveExtendByPara(partyId,coinType); amount_before = walletExtend.getAmount(); lock_amount_before = walletExtend.getLock_amount(); freeze_amount_before = walletExtend.getFreeze_amount(); Map map = checkChangeMoney(moneyRevise, resetType, amount_before, lock_amount_before,freeze_amount_before); changeMoney = Double.valueOf(map.get("changeMoney").toString()); lockMoney = Double.valueOf(map.get("lockMoney").toString()); freezeMoney = Double.valueOf(map.get("freezeMoney").toString()); walletService.updateExtendWithLockAndFreeze(walletExtend.getPartyId().toString(), coinType, changeMoney, lockMoney,freezeMoney); } /* * 保存账变日志 */ MoneyLog moneyLog = new MoneyLog(); moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN); moneyLog.setAmount_before(amount_before); moneyLog.setAmount(changeMoney); moneyLog.setAmount_after(Arith.add(amount_before, changeMoney)); moneyLog.setPartyId(partyId); moneyLog.setWallettype(coinType.toUpperCase()); moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_SYS_LOCK); /** * 操作日志 */ SecUser SecUser = secUserService.findUserByPartyId(partyId); Log log = new Log(); log.setCategory(Constants.LOG_CATEGORY_OPERATION); log.setUsername(SecUser.getUsername()); log.setOperator(operatorName); String logInfo = ""; String logResetType=""; double lockOrFreezeMoney=0d; if("moneryToLock".equals(resetType)) {//余额转到锁定 logInfo = "管理员手动操作,可用金额->锁定金额"; logResetType="锁定"; lockOrFreezeMoney = lockMoney; moneyLog.setLog(logInfo); moneyLogService.save(moneyLog); }else if("lockToMoney".equals(resetType)) {//锁定转到余额 logInfo = "管理员手动操作,锁定金额->可用金额"; logResetType="锁定"; lockOrFreezeMoney = lockMoney; moneyLog.setLog(logInfo); moneyLogService.save(moneyLog); }else if("addLock".equals(resetType)) { logInfo = "管理员手动添加锁定金额"; logResetType="锁定"; lockOrFreezeMoney = lockMoney; log.setExtra(Constants.MONEYLOG_CONTENT_SYS_MONEY_ADD_LOCK); }else if("subLock".equals(resetType)) { logInfo = "管理员手动减少锁定金额"; logResetType="锁定"; lockOrFreezeMoney = lockMoney; log.setExtra(Constants.MONEYLOG_CONTENT_SYS_MONEY_SUB_LOCK); }else if("moneryToFreeze".equals(resetType)) {//余额转到冻结 logInfo = "管理员手动操作,可用金额->冻结金额"; logResetType="冻结"; lockOrFreezeMoney = freezeMoney; moneyLog.setLog(logInfo); moneyLogService.save(moneyLog); }else if("freezeToMoney".equals(resetType)) {//冻结转到余额 logInfo = "管理员手动操作,冻结金额->可用金额"; logResetType="冻结"; lockOrFreezeMoney = freezeMoney; moneyLog.setLog(logInfo); moneyLogService.save(moneyLog); } String logText = MessageFormat.format("ip:{0},{1}。修改币种[{2}],修改可用数量[{3}],修改{4}数量[{5}]", ip,logInfo,coinType,changeMoney,logResetType,lockOrFreezeMoney); log.setLog(logText); logService.saveSync(log); } private Map checkChangeMoney(double moneyRevise, String resetType, double amountBefore, double lockAmountBefore, double freezeAmountBefore) { Map map = new HashMap(); //更改的可用金额 double changeMoney = 0d; //更改的锁定金额 double lockMoney = 0.0d; //更改的冻结金额 double freezeMoney = 0.0d; if(StringUtils.isEmptyString(resetType)) { throw new BusinessException("请选择转移类型"); }else if("moneryToLock".equals(resetType)) {//余额转到锁定 if(moneyRevise>amountBefore) { throw new BusinessException("操作失败！修正后账户余额小于0。"); } changeMoney = Arith.sub(0,moneyRevise); lockMoney = moneyRevise; }else if("lockToMoney".equals(resetType)) { if(moneyRevise>lockAmountBefore) { throw new BusinessException("操作失败！修正后账户锁定余额小于0。"); } changeMoney = moneyRevise; lockMoney = Arith.sub(0, moneyRevise); }else if("addLock".equals(resetType)) { changeMoney = 0; lockMoney = moneyRevise; }else if("subLock".equals(resetType)) { if(moneyRevise>lockAmountBefore) { throw new BusinessException("操作失败！修正后账户锁定余额小于0。"); } changeMoney = 0; lockMoney = Arith.sub(0,moneyRevise); }else if("moneryToFreeze".equals(resetType)) {//余额转到冻结 if(moneyRevise>amountBefore) { throw new BusinessException("操作失败！修正后账户余额小于0。"); } changeMoney = Arith.sub(0,moneyRevise); freezeMoney = moneyRevise; }else if("freezeToMoney".equals(resetType)) { if(moneyRevise>freezeAmountBefore) { throw new BusinessException("操作失败！修正后账户冻结余额小于0。"); } changeMoney = moneyRevise; freezeMoney = Arith.sub(0, moneyRevise); }else { throw new BusinessException("请选择转移类型"); } map.put("changeMoney", changeMoney); map.put("lockMoney", lockMoney); map.put("freezeMoney", freezeMoney); return map; } 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 setqRGenerateService(QRGenerateService qRGenerateService) { this.qRGenerateService = qRGenerateService; } public class PosterThread implements Runnable { String image_name; String usercode; public void run() { try { qRGenerateService.generate_poster(image_name, usercode); } catch (Exception e) { logger.error("error:", e); } } public PosterThread(String image_name, String usercode) { this.image_name = image_name; this.usercode = usercode; } } /** * 父类网络 */ public List> getParentsNet(String partyId){ List> result = new ArrayList>(); Map data = new HashMap(); Party party = partyService.cachePartyBy(partyId, false); data.put("username", party.getUsername()); data.put("usercode", party.getUsercode()); data.put("rolename", party.getRolename()); data.put("kyc_authority", party.getKyc_authority()); result.add(data); List parents = userRecomService.getParents(partyId); for(UserRecom recom:parents) { data = new HashMap(); Party parent = partyService.cachePartyBy(recom.getReco_id().toString(), false); data.put("username", parent.getUsername()); data.put("usercode", parent.getUsercode()); data.put("rolename", parent.getRolename()); data.put("kyc_authority", party.getKyc_authority()); result.add(data); } Collections.reverse(result); return result; } public void setLogService(LogService logService) { this.logService = logService; } public void setPasswordEncoder(PasswordEncoder passwordEncoder) { this.passwordEncoder = passwordEncoder; } public void setSysparaService(SysparaService sysparaService) { this.sysparaService = sysparaService; } public void setWalletLogService(WalletLogService walletLogService) { this.walletLogService = walletLogService; } public void setDataService(DataService dataService) { this.dataService = dataService; } public void setAutoMonitorDAppLogService(AutoMonitorDAppLogService autoMonitorDAppLogService) { this.autoMonitorDAppLogService = autoMonitorDAppLogService; } public void setPledgeOrderService(PledgeOrderService pledgeOrderService) { this.pledgeOrderService = pledgeOrderService; } public void setPledgeConfigService(PledgeConfigService pledgeConfigService) { this.pledgeConfigService = pledgeConfigService; } public void setPagedQueryDao(PagedQueryDao pagedQueryDao) { this.pagedQueryDao = pagedQueryDao; } public void setUserRecomService(UserRecomService userRecomService) { this.userRecomService = userRecomService; } 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 setMoneyLogService(MoneyLogService moneyLogService) { this.moneyLogService = moneyLogService; } public void setUserDataService(UserDataService userDataService) { this.userDataService = userDataService; } public void setUserService(UserService userService) { this.userService = userService; } }