From f7ed73841b806f36bd5f058e1a01386e66437076 Mon Sep 17 00:00:00 2001 From: wzy <wzy19931122ai@163.com> Date: Wed, 08 Jun 2022 22:46:45 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 13 +++--- src/main/resources/mapper/dapp/DappFundFlowDao.xml | 11 +++++ src/main/resources/mapper/dapp/DappMemberDao.xml | 11 +++++ src/main/java/cc/mrbird/febs/dapp/mapper/DappMemberDao.java | 3 + src/main/java/cc/mrbird/febs/dapp/mapper/DappFundFlowDao.java | 6 ++- src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 18 ++++---- 6 files changed, 45 insertions(+), 17 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/dapp/mapper/DappFundFlowDao.java b/src/main/java/cc/mrbird/febs/dapp/mapper/DappFundFlowDao.java index 3d46f26..5ad72cf 100644 --- a/src/main/java/cc/mrbird/febs/dapp/mapper/DappFundFlowDao.java +++ b/src/main/java/cc/mrbird/febs/dapp/mapper/DappFundFlowDao.java @@ -6,8 +6,10 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.ibatis.annotations.Param; +import java.math.BigDecimal; import java.util.Date; import java.util.List; +import java.util.Map; public interface DappFundFlowDao extends BaseMapper<DappFundFlowEntity> { @@ -15,9 +17,9 @@ List<DappFundFlowEntity> selectListForMemberAndDay(@Param("memberId") Long memberId, @Param("type") int type); - DappFundFlowEntity selectMineFundFlowByMemberIdAndTime(@Param("time") Long memberId, @Param("time") Date time); - DappFundFlowEntity selectByFromHash(@Param("txHash") String txHash, @Param("status") Integer status); List<DappFundFlowEntity> selectFundFlowListByAddress(@Param("address") String address, @Param("status") Integer status); + + Map<String, BigDecimal> selectAmountTotalByType(@Param("memberId") Long memberId); } diff --git a/src/main/java/cc/mrbird/febs/dapp/mapper/DappMemberDao.java b/src/main/java/cc/mrbird/febs/dapp/mapper/DappMemberDao.java index 8402e8f..d233533 100644 --- a/src/main/java/cc/mrbird/febs/dapp/mapper/DappMemberDao.java +++ b/src/main/java/cc/mrbird/febs/dapp/mapper/DappMemberDao.java @@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.ibatis.annotations.Param; +import java.math.BigDecimal; import java.util.List; /** @@ -25,4 +26,6 @@ List<DappMemberEntity> selectAgentMemberList(@Param("list") List<String> inviteIds, @Param("size") Integer size); List<DappMemberEntity> selectParentsList(@Param("list") List<String> inviteIds, @Param("size") Integer size); + + BigDecimal selectAllBalance(@Param("accountType") String accountType); } diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java index 6e99a21..580de8f 100644 --- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java @@ -45,16 +45,17 @@ private final DappOnlineTransferDao dappOnlineTransferDao; private final ChainProducer chainProducer; - private final String[] ADDRESS_PREFIX = {"T", "0x"}; + @Override public Map<String, Object> findTotalInComeAndList() { - DappMineDataEntity dataMine = dappSystemDao.selectMineDataForOne(); - + List<DappMemberEntity> addresses = dappMemberDao.selectList(null); + DappMemberEntity mineAddress = dappMemberDao.selectByAddress(ChainEnum.BSC_TFC.getAddress(), null); + BigDecimal coinCnt = dappMemberDao.selectAllBalance("normal"); Map<String, Object> result = new HashMap<>(); - result.put("total", 6000); - result.put("addreessCnt", 1234); - result.put("coinCnt", 4000); + result.put("total", mineAddress.getBalance()); + result.put("addreessCnt", addresses.size()); + result.put("coinCnt", coinCnt); return result; } diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java index 03eb81a..d823788 100644 --- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java @@ -48,18 +48,16 @@ @Override public WalletInfoVo walletInfo() { -// DappMemberEntity member = LoginUserUtil.getAppUser(); -// DappWalletCoinEntity walletCoin = dappWalletCoinDao.selectByMemberId(member.getId()); -// DappWalletMineEntity walletMine = dappWalletMineDao.selectByMemberId(member.getId()); + DappMemberEntity member = LoginUserUtil.getAppUser(); + Map<String, BigDecimal> map = dappFundFlowDao.selectAmountTotalByType(member.getId()); WalletInfoVo walletInfo = new WalletInfoVo(); -// walletInfo.setInviteId(member.getInviteId()); -// walletInfo.setTotalMine(walletMine.getTotalAmount()); -// walletInfo.setAvailableMine(walletMine.getAvailableAmount()); -// walletInfo.setAvailableWallet(walletCoin.getAvailableAmount()); walletInfo.setTotalChild(10000); - walletInfo.setTotalChild(41451); + walletInfo.setDirectCnt(100); + walletInfo.setTotalChildCoin(BigDecimal.valueOf(1)); + walletInfo.setTeamReward(map.get("teamReward")); + walletInfo.setMiningAmount(map.get("mine")); return walletInfo; } @@ -136,7 +134,9 @@ DappMemberEntity member = LoginUserUtil.getAppUser(); DappFundFlowEntity dappFundFlowEntity = new DappFundFlowEntity(); - dappFundFlowEntity.setType(recordInPageDto.getType()); + if (recordInPageDto.getType() != null && recordInPageDto.getType() != 0) { + dappFundFlowEntity.setType(recordInPageDto.getType()); + } dappFundFlowEntity.setMemberId(member.getId()); IPage<DappFundFlowEntity> records = dappFundFlowDao.selectInPage(page, dappFundFlowEntity); return records.getRecords(); diff --git a/src/main/resources/mapper/dapp/DappFundFlowDao.xml b/src/main/resources/mapper/dapp/DappFundFlowDao.xml index b29ced5..a8f1abd 100644 --- a/src/main/resources/mapper/dapp/DappFundFlowDao.xml +++ b/src/main/resources/mapper/dapp/DappFundFlowDao.xml @@ -49,4 +49,15 @@ and a.status=#{status} </if> </select> + + <select id="selectAmountTotalByType" resultType="java.util.HashMap"> + select + case when type=1 then amount end buy, + case when type=2 then amount end sale, + case when type=3 then amount end mine, + case when type=4 then amount end teamReward + from (select type, sum(amount) amount from dapp_fund_flow + where member_id=#{memberId} + ) a + </select> </mapper> \ No newline at end of file diff --git a/src/main/resources/mapper/dapp/DappMemberDao.xml b/src/main/resources/mapper/dapp/DappMemberDao.xml index 6341fcc..7e97645 100644 --- a/src/main/resources/mapper/dapp/DappMemberDao.xml +++ b/src/main/resources/mapper/dapp/DappMemberDao.xml @@ -74,4 +74,15 @@ limit ${size} </if> </select> + + <select id="selectAllBalance" resultType="java.math.BigDecimal"> + select ifnull(sum(balance), 0) + from dapp_member + <where> + 1=1 + <if test="accountType != null"> + and account_type=#{accountType} + </if> + </where> + </select> </mapper> \ No newline at end of file -- Gitblit v1.9.1