From 5ab1a38d6fb2532b26311a4e2f9fd5120227a303 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Mon, 14 Jul 2025 21:03:13 +0800
Subject: [PATCH] 地址
---
src/main/java/project/web/admin/impl/user/AdminUserServiceImpl.java | 113 +++++++++++++++++++++++++++-----------------------------
1 files changed, 54 insertions(+), 59 deletions(-)
diff --git a/src/main/java/project/web/admin/impl/user/AdminUserServiceImpl.java b/src/main/java/project/web/admin/impl/user/AdminUserServiceImpl.java
index fa92057..a6771bf 100644
--- a/src/main/java/project/web/admin/impl/user/AdminUserServiceImpl.java
+++ b/src/main/java/project/web/admin/impl/user/AdminUserServiceImpl.java
@@ -221,21 +221,21 @@
* 交易所_用户管理
*/
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, party.USERNAME username, "
+ "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.USDT_MONEY money, party.USERCODE usercode, "
+ + " 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_GATHER wallet ON wallet.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<String, Object> parameters = new HashMap<String, Object>();
@@ -494,34 +494,37 @@
if (money_revise == 0 || coin_type == "") {
return;
}
- WalletGatherService walletGatherService = new WalletGatherServiceImpl(jdbcTemplate,redisHandler,walletService);
- WalletGather walletGather = walletGatherService.getWalletGatherByPartyId(partyId,null);
+
if ("usdt".equals(coin_type)) {
// 交易所修改usdt
Party party = this.partyService.cachePartyBy(partyId, false);
- double amount_before = walletGather.getUsdtMoney();
- if (Arith.add(money_revise, walletGather.getUsdtMoney()) < 0.0D) {
+
+ 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 sysSafeword = sec.getSafeword();
String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operator_name);
if (!safeword_md5.equals(sysSafeword)) {
throw new BusinessException("资金密码错误");
}
- //修改资金账户
- walletGatherService.update(walletGather.getPartyId().toString(),coin_type,money_revise,"add");
+
+ // 更新金额
+ 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(walletGather.getUsdtMoney(), 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);
@@ -531,84 +534,75 @@
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);
-
- double amount_before = 0;
- if("btc".equals(coin_type)){
- amount_before = walletGather.getBtcMoney();
- }else if ("eth".equals(coin_type)){
- amount_before = walletGather.getEthMoney();
- }
- if (Arith.add(money_revise, amount_before) < 0.0D) {
+ 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("资金密码错误");
}
- walletGatherService.update(walletGather.getPartyId().toString(),coin_type,money_revise,"add");
- double amount = 0;
- if("btc".equals(coin_type)){
- amount = walletGather.getBtcMoney();
- }else if ("eth".equals(coin_type)){
- amount = walletGather.getEthMoney();
- }
+
+ 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(amount, 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);
@@ -618,28 +612,28 @@
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());
@@ -656,29 +650,30 @@
// 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/交易所 修改余额 减少
*/
--
Gitblit v1.9.3