xiaoyong931011
2020-07-21 0c95f99dae780bc2552c27489ac5468d003239f5
src/main/java/com/xcong/excoin/modules/trademanage/service/impl/TradeManageServiceImpl.java
@@ -15,8 +15,10 @@
import com.xcong.excoin.common.utils.CoinTypeConvert;
import com.xcong.excoin.common.utils.RedisUtils;
import com.xcong.excoin.modules.member.entity.MemberAccountMoneyChangeEntity;
import com.xcong.excoin.modules.member.entity.MemberAuthenticationEntity;
import com.xcong.excoin.modules.member.entity.MemberEntity;
import com.xcong.excoin.modules.member.mapper.MemberAccountMoneyChangeMapper;
import com.xcong.excoin.modules.member.mapper.MemberAuthenticationMapper;
import com.xcong.excoin.modules.member.mapper.MemberMapper;
import com.xcong.excoin.modules.trademanage.entity.AgentReturnEntity;
import com.xcong.excoin.modules.trademanage.entity.ContractHoldOrderEntity;
@@ -45,6 +47,8 @@
   private final ContractOrderMapper contractHoldOrderMapper;
   
   private final AgentReturnMapper agentReturnMapper;
   private final MemberAuthenticationMapper memberAuthenticationMapper;
   
   private final RedisUtils redisUtils;
   
@@ -116,7 +120,6 @@
            }
            
         }
         selectMemberListInPage.setTotal(records.size());
      }
        return selectMemberListInPage;
   }
@@ -162,6 +165,20 @@
      
      if (records != null) {
            for (ContractHoldOrderEntity holdOrderEntity : records) {
               Long memberId = holdOrderEntity.getMemberId();
            Map<String, Object> columnMap = new HashMap<>();
            columnMap.put("member_id", memberId);
            List<MemberAuthenticationEntity> selectByMap = memberAuthenticationMapper.selectByMap(columnMap );
            if(selectByMap != null && selectByMap.size() > 0) {
               MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0);
               String firstName = memberAuthenticationEntity.getFirstName();
               String secondName = memberAuthenticationEntity.getSecondName();
               String realName = firstName + secondName;
               holdOrderEntity.setRealName(realName);
            }
               MemberEntity selectById = memberMapper.selectById(holdOrderEntity.getMemberId());
                // 获取最新价
                BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(holdOrderEntity.getSymbol())));
@@ -199,7 +216,80 @@
         QueryRequest request) {
      Page<ContractOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<ContractOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderMapper.findHistoryOrderInfoAloneInfoInPage(page, contractOrderEntity);
      List<ContractOrderEntity> records = findMemberAccountInfoListInPage.getRecords();
      if(records != null && records.size() > 0) {
         for(ContractOrderEntity contractOrderEntitys : records) {
            Long memberId = contractOrderEntitys.getMemberId();
            Map<String, Object> columnMap = new HashMap<>();
            columnMap.put("member_id", memberId);
            List<MemberAuthenticationEntity> selectByMap = memberAuthenticationMapper.selectByMap(columnMap );
            if(selectByMap != null && selectByMap.size() > 0) {
               MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0);
               String firstName = memberAuthenticationEntity.getFirstName();
               String secondName = memberAuthenticationEntity.getSecondName();
               String realName = firstName + secondName;
               contractOrderEntitys.setRealName(realName);
            }
         }
      }
      return findMemberAccountInfoListInPage;
   }
   @Override
   public IPage<MemberAccountMoneyChangeEntity> findMemberAgentReturnInfoAloneInPage(
         MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity, QueryRequest request) {
      Page<MemberAccountMoneyChangeEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<MemberAccountMoneyChangeEntity> findMemberAccountInfoListInPage =
            memberAccountMoneyChangeMapper.findMemberAgentReturnInfoAloneInPage(page, memberAccountMoneyChangeEntity);
      List<MemberAccountMoneyChangeEntity> records = findMemberAccountInfoListInPage.getRecords();
      if(records != null && records.size() > 0) {
         String selectYJByMemberId = agentReturnMapper.selectYJByMemberId();
         for(MemberAccountMoneyChangeEntity accountMoneyChangeEntity : records) {
            Long memberId = accountMoneyChangeEntity.getMemberId();
            String allAmount = memberAccountMoneyChangeMapper.selectAccountMoneyChangeByMemberId(memberId);
            Map<String, Object> columnMap = new HashMap<>();
            columnMap.put("member_id", memberId);
            List<MemberAuthenticationEntity> selectByMap = memberAuthenticationMapper.selectByMap(columnMap );
            if(selectByMap != null && selectByMap.size() > 0) {
               MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0);
               String firstName = memberAuthenticationEntity.getFirstName();
               String secondName = memberAuthenticationEntity.getSecondName();
               String realName = firstName + secondName;
               accountMoneyChangeEntity.setRealName(realName);
            }
            accountMoneyChangeEntity.setAllAmount(allAmount);
            if(memberId == 8) {
               accountMoneyChangeEntity.setAmount(BigDecimal.ZERO);
               accountMoneyChangeEntity.setAllAmount(selectYJByMemberId);
            }
         }
      }
      return findMemberAccountInfoListInPage;
   }
}