From 15683ad5fd166be758483db028deb499e8435bf5 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 06 May 2021 15:21:09 +0800
Subject: [PATCH] 20210506 审核认证
---
src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 40 +++++++++++++++++++++++++++-------------
1 files changed, 27 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
index 9a0677e..6f27c9c 100644
--- a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
@@ -74,6 +74,7 @@
private final RedisUtils redisUtils;
private final TdFinancialReordDao tdFinancialReordDao;
+ private final TdCoinChargeDao tdCoinChargeDao;
@Override
public IPage<AgentFriendRelationEntity> findAgentInfoListInPage(AgentFriendRelationEntity agentFriendRelationEntity,
@@ -204,7 +205,7 @@
}
@Override
- @Transactional(rollbackFor = Exception.class)
+ @Transactional
public FebsResponse memberChargeUsdtConfirm(Long id) {
MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id);
@@ -261,7 +262,7 @@
}
@Override
- @Transactional(rollbackFor = Exception.class)
+ @Transactional
public FebsResponse memberChargeUsdtCancel(@NotNull(message = "{required}") Long id) {
MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id);
@@ -287,7 +288,7 @@
}
@Override
- @Transactional(rollbackFor = Exception.class)
+ @Transactional
public FebsResponse memberExtractUsdtCancel(@NotNull(message = "{required}") Long id) {
MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id);
@@ -331,7 +332,7 @@
}
@Override
- @Transactional(rollbackFor = Exception.class)
+ @Transactional
public FebsResponse memberExtractUsdtConfirm(@NotNull(message = "{required}") Long id) {
MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id);
@@ -418,7 +419,7 @@
}
@Override
- @Transactional(rollbackFor = Exception.class)
+ @Transactional
public FebsResponse memberWithdrawCoinConfirm(@NotNull(message = "{required}") Long id) throws ExecutionException, InterruptedException {
MemberCoinWithdrawEntity selectById = memberCoinWithdrawMapper.selectById(id);
@@ -436,9 +437,9 @@
}
// 转币 需要扣除手续费
amount = amount.subtract(selectById.getFeeAmount());
- if("ROC".equals(symbol) && !"Y".equals(selectById.getIsInside())){
+ if("SER".equals(symbol) && !"Y".equals(selectById.getIsInside())){
// 如果是ROC 则自动转
- String transfer = RocService.transfer(amount, address, "ROC");
+ String transfer = RocService.transfer(amount, address, "SER");
if(!"success".equals(transfer)){
FebsResponse febsResponse = new FebsResponse();
return febsResponse.fail().message(transfer);
@@ -537,6 +538,19 @@
financialReord.setCreateTime(new Date());
financialReord.setMemId(coinAddressEntity.getMemberId());
tdFinancialReordDao.insert(financialReord);
+ // 插入冲币记录
+
+ TdCoinCharge tdCoinCharge = new TdCoinCharge();
+ tdCoinCharge.setAddress(address);
+ tdCoinCharge.setAmount(amount);
+ tdCoinCharge.setMemberId(coinAddressEntity.getMemberId());
+ tdCoinCharge.setSymbol("USDT");
+ tdCoinCharge.setTag("ERC20");
+ tdCoinCharge.setTransHash("");
+ tdCoinCharge.setCreateTime(new Date());
+ tdCoinCharge.setLastAmount(amount);
+ tdCoinCharge.setStatus(1);
+ tdCoinChargeDao.insert(tdCoinCharge);
// 更新钱包
memberCoinAddressMapper.updateSuanliWallet(walletId,amount);
}
@@ -555,7 +569,7 @@
}
@Override
- @Transactional(rollbackFor = Exception.class)
+ @Transactional
public FebsResponse memberWithdrawCoinCancel(@NotNull(message = "{required}") Long id) {
MemberCoinWithdrawEntity selectById = memberCoinWithdrawMapper.selectById(id);
@@ -600,7 +614,7 @@
}
@Override
- @Transactional(rollbackFor = Exception.class)
+ @Transactional
public FebsResponse memberDetailConfirm(@Valid MemberDetailConfirmDto memberDetailConfirmDto) {
Long id = memberDetailConfirmDto.getId();
MemberEntity selectById = memberMapper.selectById(id);
@@ -773,7 +787,7 @@
//USDT充币总额+USDT提币总额
String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"USDT");
- String totalAmountUsdtBRoc = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"ROC");
+ String totalAmountUsdtBRoc = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"SER");
memberInfoDetailVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));
memberInfoDetailVo.setChargeCoinRoc(totalAmountUsdtBRoc == null ? 0 : Double.parseDouble(totalAmountUsdtBRoc));
String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealDataBymemberId(memberId);
@@ -810,7 +824,7 @@
//账户金额
String walletNum = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"USDT");
- String walletNumRoc = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"ROC");
+ String walletNumRoc = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"SER");
memberInfoDetailVo.setWalletCoinNum(walletNum == null ? 0 : Double.parseDouble(walletNum));
memberInfoDetailVo.setWalletCoinNumRoc(walletNumRoc == null ? 0 : Double.parseDouble(walletNumRoc));
//String walletCoinNum = memberMapper.selectHYZCForBasicRealDataBymemberId(memberId);
@@ -1338,7 +1352,7 @@
//USDT充币总额+USDT提币总额
String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"USDT");
- String totalAmountUsdtBRoc = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"ROC");
+ String totalAmountUsdtBRoc = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"SER");
memberInfoDetailVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));
memberInfoDetailVo.setChargeCoinRoc(totalAmountUsdtBRoc == null ? 0 : Double.parseDouble(totalAmountUsdtBRoc));
String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealDataBymemberId(memberId);
@@ -1375,7 +1389,7 @@
//账户金额
String walletNum = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"USDT");
- String walletNumRoc = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"ROC");
+ String walletNumRoc = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"SER");
memberInfoDetailVo.setWalletCoinNum(walletNum == null ? 0 : Double.parseDouble(walletNum));
memberInfoDetailVo.setWalletCoinNumRoc(walletNumRoc == null ? 0 : Double.parseDouble(walletNumRoc));
//String walletCoinNum = memberMapper.selectHYZCForBasicRealDataBymemberId(memberId);
--
Gitblit v1.9.1