From c0902e7e9865781ac85b4796fd452354065ce089 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 01 Mar 2022 16:59:19 +0800
Subject: [PATCH] 20222223
---
src/main/java/com/xcong/excoin/modules/coin/service/impl/ZhiyaServiceImpl.java | 6 ++++++
src/main/java/com/xcong/excoin/modules/coin/dao/ZhiYaDao.java | 2 ++
src/main/resources/mapper/walletCoinOrder/ZhiYaDao.xml | 4 ++++
3 files changed, 12 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/coin/dao/ZhiYaDao.java b/src/main/java/com/xcong/excoin/modules/coin/dao/ZhiYaDao.java
index 3e035ac..917e7a0 100644
--- a/src/main/java/com/xcong/excoin/modules/coin/dao/ZhiYaDao.java
+++ b/src/main/java/com/xcong/excoin/modules/coin/dao/ZhiYaDao.java
@@ -2,9 +2,11 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.xcong.excoin.modules.coin.entity.ZhiYaEntity;
+import org.apache.ibatis.annotations.Param;
public interface ZhiYaDao extends BaseMapper<ZhiYaEntity> {
ZhiYaEntity selectByMemberId(Long memberId);
+ Long selectSumRewardByMemberIdAndRecordIdAndType(@Param("memberId")Long memberId, @Param("recordId")Long id, @Param("type")int i);
}
diff --git a/src/main/java/com/xcong/excoin/modules/coin/service/impl/ZhiyaServiceImpl.java b/src/main/java/com/xcong/excoin/modules/coin/service/impl/ZhiyaServiceImpl.java
index b016b77..b69f85c 100644
--- a/src/main/java/com/xcong/excoin/modules/coin/service/impl/ZhiyaServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/coin/service/impl/ZhiyaServiceImpl.java
@@ -306,6 +306,12 @@
zhiya.setFrozenBalance(gusdfrozenBalance.subtract(balance));
zhiya.setAvailableBalance(gusdAvailableBalance.add(balance));
zhiYaDao.updateById(zhiya);
+ //赎回后奖励直接去币币账户
+ Long sumReward = zhiYaDao.selectSumRewardByMemberIdAndRecordIdAndType(memberId,id,1);
+ MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.GRICE.toString());
+ memberWalletCoinEntity.setAvailableBalance(memberWalletCoinEntity.getAvailableBalance().add(new BigDecimal(sumReward)));
+ memberWalletCoinEntity.setTotalBalance(memberWalletCoinEntity.getTotalBalance().add(new BigDecimal(sumReward)));
+ memberWalletCoinDao.updateById(memberWalletCoinEntity);
//更新团队算力表
MemberEntity memberEntity = memberdao.selectById(memberId);
String refererIds = memberEntity.getRefererIds();
diff --git a/src/main/resources/mapper/walletCoinOrder/ZhiYaDao.xml b/src/main/resources/mapper/walletCoinOrder/ZhiYaDao.xml
index 8cca638..890157a 100644
--- a/src/main/resources/mapper/walletCoinOrder/ZhiYaDao.xml
+++ b/src/main/resources/mapper/walletCoinOrder/ZhiYaDao.xml
@@ -6,4 +6,8 @@
SELECT * FROM zhi_ya a where a.member_id= #{memberId}
</select>
+ <select id="selectSumRewardByMemberIdAndRecordIdAndType" resultType="long">
+ SELECT ifnull(sum(a.reward_amout),0) FROM zhiya_reward a where a.member_id= #{memberId} and a.type= #{type} and a.record_id= #{recordId}
+ </select>
+
</mapper>
--
Gitblit v1.9.1