Helius
2020-07-31 829d77f7145514d67d957ad54dbef854440f77d3
src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java
@@ -10,6 +10,7 @@
import javax.annotation.Resource;
import javax.validation.Valid;
import org.apache.http.impl.NoConnectionReuseStrategy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -23,6 +24,7 @@
import com.xcong.excoin.modules.contract.dao.ContractHoldOrderDao;
import com.xcong.excoin.modules.contract.entity.ContractHoldOrderEntity;
import com.xcong.excoin.modules.contract.entity.ContractOrderEntity;
import com.xcong.excoin.modules.documentary.dao.FollowFollowerOrderRelationDao;
import com.xcong.excoin.modules.documentary.dao.FollowFollowerProfitDao;
import com.xcong.excoin.modules.documentary.dao.FollowFollowerSettingDao;
import com.xcong.excoin.modules.documentary.dao.FollowTraderInfoDao;
@@ -35,6 +37,7 @@
import com.xcong.excoin.modules.documentary.dto.MyFollowOrderDto;
import com.xcong.excoin.modules.documentary.dto.MyFollowTraderInfoDto;
import com.xcong.excoin.modules.documentary.dto.UpdateDocumentaryOrderSetDto;
import com.xcong.excoin.modules.documentary.entity.FollowFollowerOrderRelationEntity;
import com.xcong.excoin.modules.documentary.entity.FollowFollowerProfitEntity;
import com.xcong.excoin.modules.documentary.entity.FollowFollowerSettingEntity;
import com.xcong.excoin.modules.documentary.entity.FollowTraderInfoEntity;
@@ -94,6 +97,8 @@
    private MemberWalletContractDao memberWalletContractDao;
    @Resource
    private FollowFollowerSettingDao followFollowerSettingDao;
    @Resource
    private FollowFollowerOrderRelationDao followFollowerOrderRelationDao;
    
   
   @Override
@@ -241,8 +246,7 @@
   public Result getHistoryMyFollowOrderRecords(@Valid MyFollowOrderDto myFollowOrderDto) {
      //获取用户ID
        Long memberId = LoginUserUtils.getAppLoginUser().getId();
        Page<MyFollowOrderVo> result = new Page<>();
        List<MyFollowOrderVo> myFollowOrderVos = result.getRecords();
        List<MyFollowOrderVo> myFollowOrderVos = new ArrayList<>();
        //历史跟单
           Page<ContractOrderEntity> page = new Page<>(myFollowOrderDto.getPageNum(), myFollowOrderDto.getPageSize());
           IPage<ContractOrderEntity> contractOrderEntitys = followFollowerProfitDao.getMyFollowOrderHistoryRecords(page, memberId);
@@ -251,6 +255,14 @@
           if(CollUtil.isNotEmpty(records)) {
              for(ContractOrderEntity contractOrderEntity : records) {
                 MyFollowOrderVo myFollowOrderVo = new MyFollowOrderVo();
                 //获取交易员信息
               Long orderId = contractOrderEntity.getId();
               FollowFollowerOrderRelationEntity FollowFollowerOrderRelation = followFollowerOrderRelationDao.selectHistoryOneByorderId(orderId);
               Long tradeId = FollowFollowerOrderRelation.getTradeId();
               FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectById(tradeId);
               String nickname = followTraderInfoEntity.getNickname();
               myFollowOrderVo.setNickname(nickname);
                 String symbol = contractOrderEntity.getSymbol();
                 myFollowOrderVo.setSymbol(symbol);
                 int orderType = contractOrderEntity.getOrderType();
@@ -287,8 +299,7 @@
      Long memberId = LoginUserUtils.getAppLoginUser().getId();
      MemberEntity member = memberDao.selectById(memberId);
      
      Page<MyFollowOrderVo> result = new Page<>();
      List<MyFollowOrderVo> myFollowOrderVos = result.getRecords();
      List<MyFollowOrderVo> myFollowOrderVos = new ArrayList<>();
         //当前跟单   
         Page<ContractHoldOrderEntity> page = new Page<>(myFollowOrderDto.getPageNum(), myFollowOrderDto.getPageSize());
         IPage<ContractHoldOrderEntity> contractHoldOrderEntitys = followFollowerProfitDao.getMyFollowOrderNowRecords(page, memberId);
@@ -297,6 +308,14 @@
         if(CollUtil.isNotEmpty(records)) {
            for(ContractHoldOrderEntity contractHoldOrderEntity : records) {
               MyFollowOrderVo myFollowOrderVo = new MyFollowOrderVo();
               //获取交易员信息
               Long orderId = contractHoldOrderEntity.getId();
               FollowFollowerOrderRelationEntity FollowFollowerOrderRelation = followFollowerOrderRelationDao.selectNowOneByorderId(orderId);
               Long tradeId = FollowFollowerOrderRelation.getTradeId();
               FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectById(tradeId);
               String nickname = followTraderInfoEntity.getNickname();
               myFollowOrderVo.setNickname(nickname);
               String symbol = contractHoldOrderEntity.getSymbol();
               myFollowOrderVo.setSymbol(symbol);
               int orderType = contractHoldOrderEntity.getOpeningType();
@@ -316,6 +335,8 @@
               
               // 获取最新价
               BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(contractHoldOrderEntity.getSymbol())));
               myFollowOrderVo.setNewPrice(newPrice);
               BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(contractHoldOrderEntity.getSymbol());
               // 盈亏
               BigDecimal rewardRatio = BigDecimal.ZERO;
@@ -353,9 +374,7 @@
   public Result getMyFollowTraderInfo(@Valid MyFollowTraderInfoDto myFollowTraderInfoDto) {
      //获取用户ID
        Long memberId = LoginUserUtils.getAppLoginUser().getId();
        Page<MyFollowTraderInfoVo> result = new Page<>();
        List<MyFollowTraderInfoVo> myFollowOrderVos = result.getRecords();
        List<MyFollowTraderInfoVo> myFollowOrderVos = new ArrayList<>();
        
        Page<FollowFollowerProfitEntity> page = new Page<>(myFollowTraderInfoDto.getPageNum(), myFollowTraderInfoDto.getPageSize());
      IPage<FollowFollowerProfitEntity> followFollowerProfitEntitys = followFollowerProfitDao.selectFollowFollowerProfitEntitys(page, memberId);
@@ -377,7 +396,7 @@
              myFollowOrderVos.add(myFollowTraderInfoVo);
           }
      }
      return Result.ok(result);
      return Result.ok(myFollowOrderVos);
   }
   @Override
@@ -530,6 +549,36 @@
      followTraderProfitInfoVo.setIsAll(isAll);
      return Result.ok(followTraderProfitInfoVo);
   }
   @Override
   @Transactional
   public Result beTrader() {
      //获取用户ID
        Long memberId = LoginUserUtils.getAppLoginUser().getId();
        MemberEntity memberEntity = memberDao.selectById(memberId);
        Integer certifyStatus = memberEntity.getCertifyStatus();
        if(MemberEntity.CERTIFY_STATUS_Y != certifyStatus) {
           return Result.ok(MessageSourceUtils.getString("member_controller_0009"));
        }
        //新增【交易员信息表】数据
        FollowTraderInfoEntity followTraderInfoEntity = new FollowTraderInfoEntity();
        followTraderInfoEntity.setMemberId(memberId);
        followTraderInfoEntity.setAvatar(FollowTraderInfoEntity.AVATAR_DEFAULT);
        String phone = memberEntity.getPhone();
        String email = memberEntity.getEmail();
        if(StrUtil.isNotEmpty(phone)) {
           followTraderInfoEntity.setNickname(phone);
        }else {
           followTraderInfoEntity.setNickname(email);
        }
        followTraderInfoEntity.setDeclaration(FollowTraderInfoEntity.DECLARATION_DEFAULT);
        followTraderInfoEntity.setIsAll(FollowTraderInfoEntity.IS_ALL_N);
        followTraderInfoEntity.setProfitRatio(BigDecimal.ZERO);
        followTraderInfoEntity.setVerifyStatus(FollowTraderInfoEntity.VERIFYSTATUS_ING);
        followTraderInfoEntity.setIsOpen(FollowTraderInfoEntity.ISOPEN_Y);
        followTraderInfoDao.insert(followTraderInfoEntity);
      return Result.ok(MessageSourceUtils.getString("member_service_0024"));
   }