Compare commits

..

No commits in common. "bfc0c9dcc6a2e7e64e93daa3c0f6a8736ed83dea" and "8b52bbb00ff4d8feb8b50bd740da985a57a08c6b" have entirely different histories.

5 changed files with 23 additions and 45 deletions

View File

@ -313,15 +313,10 @@ public class ApiCuMemberTransferController extends BaseController {
Integer toPkAccount = accountServiceApi.getPkAccount(pkAccount).getData(); Integer toPkAccount = accountServiceApi.getPkAccount(pkAccount).getData();
CuMemberTransfer cuMemberTransfer = CuMemberTransfer.builder().pkMember(pkMember) CuMemberTransfer cuMemberTransfer = CuMemberTransfer.builder().pkMember(pkMember)
.pkAccount(pkAccount) .pkAccount(pkAccount).transferCode(code).toPkMember(toPkMember)
.transferCode(code) .pkToAccount(toPkAccount).pkRate(currencyDTO.getPkId())
.toPkMember(toPkMember) .transferMoney(transferMoney).remarks(cuMemberTransferParam.getRemarks())
.pkToAccount(toPkAccount) .serviceCharge(serviceRatio).issuedAmount(issuedAmount)
.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);

View File

@ -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;
@ -84,16 +83,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;
} }
@ -167,14 +159,11 @@ 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);
} }

View File

@ -125,10 +125,8 @@ public class CuMemberWithdrawServiceImpl extends ServiceImpl<CuMemberWithdrawMap
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
@Override @Override
public Integer saveMemberWithdrawInfo(CuMemberWithdraw cuMemberWithdraw) { public Integer saveMemberWithdrawInfo(CuMemberWithdraw cuMemberWithdraw) {
int row = baseMapper.insert(cuMemberWithdraw); Integer row = baseMapper.insert(cuMemberWithdraw);
if (this.updateTradeAndBalancd(cuMemberWithdraw, EOperationMethod.INSERT) == 0) { this.updateTradeAndBalancd(cuMemberWithdraw, EOperationMethod.INSERT);
throw new ServiceException("提现失败,请确认后重试");
}
return row; return row;
} }
@ -148,15 +146,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 cuMemberAccountService.updateMemberAccountByMemberCode(param); return cuMemberAccountService.updateMemberAccountByMemberCode(param);
} }

View File

@ -233,9 +233,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">

View File

@ -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();