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);
}

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

 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>