Compare commits
No commits in common. "e912c4d222ca9d7ff1da52fb74335702bd3178b9" and "4780c5361bc8daa75f162d9f0d6374bddada5b91" have entirely different histories.
e912c4d222
...
4780c5361b
|
|
@ -336,17 +336,11 @@ public class ApiCuMemberTransferController extends BaseController {
|
||||||
//转入币种ID(从配置中获取)
|
//转入币种ID(从配置中获取)
|
||||||
Integer toPkAccount = iAccountServiceApi.getPkAccount(pkAccount).getData();
|
Integer toPkAccount = iAccountServiceApi.getPkAccount(pkAccount).getData();
|
||||||
|
|
||||||
CuMemberTransfer cuMemberTransfer = CuMemberTransfer.builder()
|
CuMemberTransfer cuMemberTransfer = CuMemberTransfer.builder().pkMember(pkMember)
|
||||||
.pkMember(pkMember)
|
.pkAccount(pkAccount).transferCode(code).toPkMember(toPkMember)
|
||||||
.pkAccount(pkAccount)
|
.pkToAccount(toPkAccount).pkRate(currencyDTO.getPkId())
|
||||||
.transferCode(code)
|
.transferMoney(transferMoney).remarks(cuMemberTransferParam.getRemarks())
|
||||||
.toPkMember(toPkMember)
|
.serviceCharge(serviceRatio).issuedAmount(issuedAmount)
|
||||||
.pkToAccount(toPkAccount)
|
|
||||||
.pkRate(currencyDTO.getPkId())
|
|
||||||
.transferMoney(transferMoney)
|
|
||||||
.remarks(cuMemberTransferParam.getRemarks())
|
|
||||||
.serviceCharge(serviceRatio)
|
|
||||||
.issuedAmount(issuedAmount)
|
|
||||||
.build();
|
.build();
|
||||||
cuMemberTransfer.setPkCountry(pkCountry);
|
cuMemberTransfer.setPkCountry(pkCountry);
|
||||||
cuMemberTransfer.setPkCreator(pkMember);
|
cuMemberTransfer.setPkCreator(pkMember);
|
||||||
|
|
@ -354,6 +348,7 @@ public class ApiCuMemberTransferController extends BaseController {
|
||||||
return toAjax(iCuMemberTransferService.saveMemberTransferInfo(cuMemberTransfer, cuMemberAccount, toMemberAccount));
|
return toAjax(iCuMemberTransferService.saveMemberTransferInfo(cuMemberTransfer, cuMemberAccount, toMemberAccount));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 判断是否走血缘
|
* 判断是否走血缘
|
||||||
*
|
*
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,6 @@ import cn.hutool.core.collection.CollUtil;
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
import com.hzs.common.core.constant.msg.FinanceMsgConstants;
|
import com.hzs.common.core.constant.msg.FinanceMsgConstants;
|
||||||
import com.hzs.common.core.enums.*;
|
import com.hzs.common.core.enums.*;
|
||||||
import com.hzs.common.core.exception.ServiceException;
|
|
||||||
import com.hzs.common.core.utils.CommonUtil;
|
import com.hzs.common.core.utils.CommonUtil;
|
||||||
import com.hzs.common.domain.member.account.CuMemberAccount;
|
import com.hzs.common.domain.member.account.CuMemberAccount;
|
||||||
import com.hzs.common.domain.member.account.CuMemberTrade;
|
import com.hzs.common.domain.member.account.CuMemberTrade;
|
||||||
|
|
@ -107,16 +106,9 @@ public class CuMemberTransferServiceImpl extends ServiceImpl<CuMemberTransferMap
|
||||||
@Transactional(rollbackFor = Exception.class)
|
@Transactional(rollbackFor = Exception.class)
|
||||||
@Override
|
@Override
|
||||||
public Integer saveMemberTransferInfo(CuMemberTransfer cuMemberTransfer, CuMemberAccount cuMemberAccount, CuMemberAccount toMemberAccount) {
|
public Integer saveMemberTransferInfo(CuMemberTransfer cuMemberTransfer, CuMemberAccount cuMemberAccount, CuMemberAccount toMemberAccount) {
|
||||||
int row = baseMapper.insert(cuMemberTransfer);
|
Integer row = baseMapper.insert(cuMemberTransfer);
|
||||||
if (row == 0) {
|
this.updateTradeAndBalancd(cuMemberTransfer, ETransferType.TRANSFER_OUT.getValue());
|
||||||
throw new ServiceException("转账失败,请确认后重试");
|
this.updateTradeAndBalancd(cuMemberTransfer, ETransferType.TRANSFER_IN.getValue());
|
||||||
}
|
|
||||||
if (this.updateTradeAndBalancd(cuMemberTransfer, ETransferType.TRANSFER_OUT.getValue()) == 0) {
|
|
||||||
throw new ServiceException("转账失败,请确认后重试");
|
|
||||||
}
|
|
||||||
if (this.updateTradeAndBalancd(cuMemberTransfer, ETransferType.TRANSFER_IN.getValue()) == 0) {
|
|
||||||
throw new ServiceException("转账失败,请确认后重试");
|
|
||||||
}
|
|
||||||
ChargingBonusDetail(cuMemberTransfer, cuMemberAccount, toMemberAccount);
|
ChargingBonusDetail(cuMemberTransfer, cuMemberAccount, toMemberAccount);
|
||||||
return row;
|
return row;
|
||||||
}
|
}
|
||||||
|
|
@ -166,6 +158,7 @@ public class CuMemberTransferServiceImpl extends ServiceImpl<CuMemberTransferMap
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 更新交易流水和余额
|
* 更新交易流水和余额
|
||||||
*
|
*
|
||||||
|
|
@ -190,13 +183,9 @@ public class CuMemberTransferServiceImpl extends ServiceImpl<CuMemberTransferMap
|
||||||
BigDecimal amount = type == (ETransferType.TRANSFER_OUT.getValue()) ? transferMoney.negate() : transferMoney;
|
BigDecimal amount = type == (ETransferType.TRANSFER_OUT.getValue()) ? transferMoney.negate() : transferMoney;
|
||||||
Integer pkAccountValue = iCuMemberBaseService.getAccountValueById(pkAccount);
|
Integer pkAccountValue = iCuMemberBaseService.getAccountValueById(pkAccount);
|
||||||
|
|
||||||
CuMemberAccountParam param = CuMemberAccountParam.builder()
|
CuMemberAccountParam param = CuMemberAccountParam.builder().pkMember(memberId)
|
||||||
.pkMember(memberId)
|
.accountType(pkAccountValue).amount(amount).pkModified(cuMemberTransfer.getPkCreator())
|
||||||
.accountType(pkAccountValue)
|
.accountClassify(ETradeClassify.TRANSFER.getValue()).pkCountry(cuMemberTransfer.getPkCountry())
|
||||||
.amount(amount)
|
|
||||||
.pkModified(cuMemberTransfer.getPkCreator())
|
|
||||||
.accountClassify(ETradeClassify.TRANSFER.getValue())
|
|
||||||
.pkCountry(cuMemberTransfer.getPkCountry())
|
|
||||||
.transferType(type).build();
|
.transferType(type).build();
|
||||||
|
|
||||||
return iCuMemberAccountService.updateMemberAccountByMemberCode(param);
|
return iCuMemberAccountService.updateMemberAccountByMemberCode(param);
|
||||||
|
|
@ -238,6 +227,7 @@ public class CuMemberTransferServiceImpl extends ServiceImpl<CuMemberTransferMap
|
||||||
return memberTrade;
|
return memberTrade;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 构造转入方交易明细
|
* 构造转入方交易明细
|
||||||
*
|
*
|
||||||
|
|
@ -302,6 +292,7 @@ public class CuMemberTransferServiceImpl extends ServiceImpl<CuMemberTransferMap
|
||||||
return remarks.toString();
|
return remarks.toString();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Object[] selectMemberTransferList(CuMemberTransferVO cuMemberTransferVO) {
|
public Object[] selectMemberTransferList(CuMemberTransferVO cuMemberTransferVO) {
|
||||||
CuMemberTransferVO memberTransferVO;
|
CuMemberTransferVO memberTransferVO;
|
||||||
|
|
@ -318,6 +309,7 @@ public class CuMemberTransferServiceImpl extends ServiceImpl<CuMemberTransferMap
|
||||||
return new Object[]{cuMemberTransferExts, cuMemberTransferVOS};
|
return new Object[]{cuMemberTransferExts, cuMemberTransferVOS};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 页面显示公用参数
|
* 页面显示公用参数
|
||||||
*
|
*
|
||||||
|
|
@ -353,3 +345,4 @@ public class CuMemberTransferServiceImpl extends ServiceImpl<CuMemberTransferMap
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -110,9 +110,7 @@ public class CuMemberWithdrawServiceImpl extends ServiceImpl<CuMemberWithdrawMap
|
||||||
public Integer saveMemberWithdrawInfo(CuMemberWithdraw cuMemberWithdraw) {
|
public Integer saveMemberWithdrawInfo(CuMemberWithdraw cuMemberWithdraw) {
|
||||||
int row = baseMapper.insert(cuMemberWithdraw);
|
int row = baseMapper.insert(cuMemberWithdraw);
|
||||||
if (row != 0) {
|
if (row != 0) {
|
||||||
if (this.updateTradeAndBalancd(cuMemberWithdraw, EOperationMethod.INSERT) == 0) {
|
this.updateTradeAndBalancd(cuMemberWithdraw, EOperationMethod.INSERT);
|
||||||
throw new ServiceException("提现失败,请确认后重试");
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
return row;
|
return row;
|
||||||
}
|
}
|
||||||
|
|
@ -132,15 +130,10 @@ public class CuMemberWithdrawServiceImpl extends ServiceImpl<CuMemberWithdrawMap
|
||||||
//提现金额
|
//提现金额
|
||||||
BigDecimal cashAmount = cuMemberWithdraw.getCashAmount();
|
BigDecimal cashAmount = cuMemberWithdraw.getCashAmount();
|
||||||
BigDecimal amount = eMethodType.equals(EOperationMethod.INSERT) ? cashAmount.negate() : cashAmount;
|
BigDecimal amount = eMethodType.equals(EOperationMethod.INSERT) ? cashAmount.negate() : cashAmount;
|
||||||
CuMemberAccountParam param = CuMemberAccountParam.builder()
|
CuMemberAccountParam param = CuMemberAccountParam.builder().pkMember(cuMemberWithdraw.getPkMember())
|
||||||
.pkMember(cuMemberWithdraw.getPkMember())
|
.accountType(accountType).amount(amount).pkModified(cuMemberWithdraw.getPkCreator())
|
||||||
.accountType(accountType)
|
.accountClassify(ETradeClassify.WITHDRAWAL.getValue()).pkCountry(cuMemberWithdraw.getPkCountry())
|
||||||
.amount(amount)
|
.transferType(ETransferType.TRANSFER_IN.getValue()).build();
|
||||||
.pkModified(cuMemberWithdraw.getPkCreator())
|
|
||||||
.accountClassify(ETradeClassify.WITHDRAWAL.getValue())
|
|
||||||
.pkCountry(cuMemberWithdraw.getPkCountry())
|
|
||||||
.transferType(ETransferType.TRANSFER_IN.getValue())
|
|
||||||
.build();
|
|
||||||
return iCuMemberAccountService.updateMemberAccountByMemberCode(param);
|
return iCuMemberAccountService.updateMemberAccountByMemberCode(param);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -241,9 +241,6 @@
|
||||||
<if test="account2 != null">
|
<if test="account2 != null">
|
||||||
and account2 + #{account2} >= 0
|
and account2 + #{account2} >= 0
|
||||||
</if>
|
</if>
|
||||||
<if test="account4 != null">
|
|
||||||
and account4 + #{account4} >= 0
|
|
||||||
</if>
|
|
||||||
</update>
|
</update>
|
||||||
|
|
||||||
<select id="queryMemberAccountByMemberCode" resultType="com.hzs.member.account.dto.CuMemberRechargeAccountParam">
|
<select id="queryMemberAccountByMemberCode" resultType="com.hzs.member.account.dto.CuMemberRechargeAccountParam">
|
||||||
|
|
|
||||||
|
|
@ -23,7 +23,11 @@ import java.util.Map;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 防止表单重复提交处理
|
* @Description: 防止表单重复提交处理
|
||||||
|
* @Author: jiang chao
|
||||||
|
* @Time: 2023/6/15 9:24
|
||||||
|
* @Classname: RepeatSubmitOldAspectAdvice
|
||||||
|
* @PackageName: com.hzs.common.core.aspect
|
||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@Aspect
|
@Aspect
|
||||||
|
|
@ -63,7 +67,7 @@ public class RepeatSubmitSimpleAspectAdvice {
|
||||||
|
|
||||||
Map<String, Object> nowDataMap = new HashMap<>();
|
Map<String, Object> nowDataMap = new HashMap<>();
|
||||||
nowDataMap.put(REPEAT_PARAMS, nowParams);
|
nowDataMap.put(REPEAT_PARAMS, nowParams);
|
||||||
nowDataMap.put(REPEAT_TIME, System.currentTimeMillis() / 1000);
|
nowDataMap.put(REPEAT_TIME, System.currentTimeMillis());
|
||||||
|
|
||||||
// 请求地址(作为存放cache的key值)
|
// 请求地址(作为存放cache的key值)
|
||||||
String url = request.getRequestURI();
|
String url = request.getRequestURI();
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,11 @@ import lombok.AllArgsConstructor;
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 转账类型
|
* @Description: 转账类型
|
||||||
|
* @Author: ljc
|
||||||
|
* @Time: 2022/9/26 10:33
|
||||||
|
* @Classname: ETransferType
|
||||||
|
* @Package_name: com.hzs.common.core.enums
|
||||||
*/
|
*/
|
||||||
@AllArgsConstructor
|
@AllArgsConstructor
|
||||||
@Getter
|
@Getter
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue