From 7c0127773885de45b3ff55f80e3c7bf7c5f5a3a3 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 09 Jun 2020 15:10:25 +0800
Subject: [PATCH] 20200609  代码提交

---
 src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java |   87 ++++++++++++++++---------------------------
 1 files changed, 33 insertions(+), 54 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java b/src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java
index bab36aa..7f14be4 100644
--- a/src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java
@@ -8,6 +8,9 @@
 import com.xcong.excoin.modules.platform.entity.PlatformCnyUsdtExchangeEntity;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.xcong.excoin.common.LoginUserUtils;
 import com.xcong.excoin.common.enumerates.CoinTypeEnum;
@@ -15,6 +18,9 @@
 import com.xcong.excoin.common.response.Result;
 import com.xcong.excoin.modules.coin.dao.MemberAccountMoneyChangeDao;
 import com.xcong.excoin.modules.coin.entity.MemberAccountMoneyChange;
+import com.xcong.excoin.modules.coin.entity.OrderCoinsDealEntity;
+import com.xcong.excoin.modules.coin.mapper.MemberAccountMoneyChangeMapper;
+import com.xcong.excoin.modules.coin.parameter.dto.RecordsPageDto;
 import com.xcong.excoin.modules.coin.parameter.vo.MemberAccountMoneyChangeInfoVo;
 import com.xcong.excoin.modules.coin.parameter.vo.MemberAgentIntoInfoVo;
 import com.xcong.excoin.modules.coin.parameter.vo.MemberWalletAgentInfoVo;
@@ -344,72 +350,45 @@
     }
 
     @Override
-    public Result getWalletCoinRecords() {
+    public Result getWalletCoinRecords(RecordsPageDto recordsPageDto) {
         //获取用户ID
         Long memberId = LoginUserUtils.getAppLoginUser().getId();
-        List<MemberAccountMoneyChange> coinRecordList = memberAccountMoneyChangeDao.selectWalletCoinRecordsByMemIdTypeSymbol(memberId);
-        List<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();
-        if (CollUtil.isNotEmpty(coinRecordList)) {
-            for (MemberAccountMoneyChange memberAccountMoneyChange : coinRecordList) {
-                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();
-                memberAccountMoneyChangeInfoVo.setAmount(memberAccountMoneyChange.getAmount());
-                memberAccountMoneyChangeInfoVo.setContent(memberAccountMoneyChange.getContent());
-                memberAccountMoneyChangeInfoVo.setStatus(memberAccountMoneyChange.getStatus());
-                memberAccountMoneyChangeInfoVo.setSymbol(memberAccountMoneyChange.getSymbol());
-                memberAccountMoneyChangeInfoVo.setType(memberAccountMoneyChange.getType());
-                memberAccountMoneyChangeInfoVo.setUpdateTime(memberAccountMoneyChange.getUpdateTime());
-                arrayList.add(memberAccountMoneyChangeInfoVo);
-            }
-        }
-        return Result.ok(arrayList);
+        
+        Page<OrderCoinsDealEntity> page = new Page<>(recordsPageDto.getPageNum(), recordsPageDto.getPageSize());
+        MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();
+        memberAccountMoneyChange.setMemberId(memberId);
+        IPage<MemberAccountMoneyChange> list = memberAccountMoneyChangeDao.selectWalletCoinRecordsInPage(page, memberAccountMoneyChange);
+        Page<MemberAccountMoneyChangeInfoVo> pageEntityToPageVo = MemberAccountMoneyChangeMapper.INSTANCE.pageEntityToPageVo(list);
+        
+        return Result.ok(pageEntityToPageVo);
     }
 
     @Override
-    public Result getWalletContractRecords() {
+    public Result getWalletContractRecords(RecordsPageDto recordsPageDto) {
         //获取用户ID
         Long memberId = LoginUserUtils.getAppLoginUser().getId();
-        String symbol = MemberWalletCoinEnum.WALLETCOINCODE.getValue();
-        List<MemberAccountMoneyChange> contractRecordList = memberAccountMoneyChangeDao.selectWalletContractRecordsByMemIdTypeSymbol(symbol, memberId);
-
-        List<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();
-        if (ObjectUtil.isNotNull(contractRecordList)) {
-            for (MemberAccountMoneyChange memberAccountMoneyChange : contractRecordList) {
-                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();
-                memberAccountMoneyChangeInfoVo.setAmount(memberAccountMoneyChange.getAmount());
-                memberAccountMoneyChangeInfoVo.setContent(memberAccountMoneyChange.getContent());
-                memberAccountMoneyChangeInfoVo.setStatus(memberAccountMoneyChange.getStatus());
-                memberAccountMoneyChangeInfoVo.setSymbol(memberAccountMoneyChange.getSymbol());
-                memberAccountMoneyChangeInfoVo.setType(memberAccountMoneyChange.getType());
-                memberAccountMoneyChangeInfoVo.setUpdateTime(memberAccountMoneyChange.getUpdateTime());
-                arrayList.add(memberAccountMoneyChangeInfoVo);
-            }
-        }
-
-        return Result.ok(arrayList);
+        
+        Page<OrderCoinsDealEntity> page = new Page<>(recordsPageDto.getPageNum(), recordsPageDto.getPageSize());
+        MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();
+        memberAccountMoneyChange.setMemberId(memberId);
+        IPage<MemberAccountMoneyChange> list = memberAccountMoneyChangeDao.selectWalletContractRecordsInPage(page, memberAccountMoneyChange);
+        Page<MemberAccountMoneyChangeInfoVo> pageEntityToPageVo = MemberAccountMoneyChangeMapper.INSTANCE.pageEntityToPageVo(list);
+        
+        return Result.ok(pageEntityToPageVo);
     }
 
     @Override
-    public Result getWalletAgentRecords() {
+    public Result getWalletAgentRecords(RecordsPageDto recordsPageDto) {
         //获取用户ID
         Long memberId = LoginUserUtils.getAppLoginUser().getId();
-
-        List<MemberAccountMoneyChange> contractRecordList =
-                memberAccountMoneyChangeDao.selectWalletAgentRecordByMemIdTypeSymbol(MemberWalletCoinEnum.WALLETCOINCODE.getValue(), memberId);
-
-        List<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();
-        if (ObjectUtil.isNotNull(contractRecordList)) {
-            for (MemberAccountMoneyChange memberAccountMoneyChange : contractRecordList) {
-                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();
-                memberAccountMoneyChangeInfoVo.setAmount(memberAccountMoneyChange.getAmount());
-                memberAccountMoneyChangeInfoVo.setContent(memberAccountMoneyChange.getContent());
-                memberAccountMoneyChangeInfoVo.setStatus(memberAccountMoneyChange.getStatus());
-                memberAccountMoneyChangeInfoVo.setSymbol(memberAccountMoneyChange.getSymbol());
-                memberAccountMoneyChangeInfoVo.setType(memberAccountMoneyChange.getType());
-                memberAccountMoneyChangeInfoVo.setUpdateTime(memberAccountMoneyChange.getUpdateTime());
-                arrayList.add(memberAccountMoneyChangeInfoVo);
-            }
-        }
-        return Result.ok(arrayList);
+        
+        Page<OrderCoinsDealEntity> page = new Page<>(recordsPageDto.getPageNum(), recordsPageDto.getPageSize());
+        MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();
+        memberAccountMoneyChange.setMemberId(memberId);
+        IPage<MemberAccountMoneyChange> list = memberAccountMoneyChangeDao.selectWalletAgentRecordsInPage(page, memberAccountMoneyChange);
+        Page<MemberAccountMoneyChangeInfoVo> pageEntityToPageVo = MemberAccountMoneyChangeMapper.INSTANCE.pageEntityToPageVo(list);
+        
+        return Result.ok(pageEntityToPageVo);
     }
 
     @Override

--
Gitblit v1.9.1