20210304 最大跟随人数

xiaoyong931011

2021-03-04 d7a26f3570e65d4364b30b4650f01618f2c33cc6

 src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java

@@ -16,6 +16,7 @@
import com.xcong.excoin.utils.*;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.web.bind.annotation.RequestBody;



import com.baomidou.mybatisplus.core.metadata.IPage;

import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;

@@ -39,6 +40,7 @@
import com.xcong.excoin.modules.documentary.dao.FollowTraderLabelDao;

import com.xcong.excoin.modules.documentary.dao.FollowTraderProfitDetailDao;

import com.xcong.excoin.modules.documentary.dao.FollowTraderProfitInfoDao;

import com.xcong.excoin.modules.documentary.dto.BeTraderDto;

import com.xcong.excoin.modules.documentary.dto.CancelDocumentaryOrderSetDto;

import com.xcong.excoin.modules.documentary.dto.DocumentaryOrderSetDto;

import com.xcong.excoin.modules.documentary.dto.FollowFollowerNoticeDto;

@@ -60,6 +62,7 @@
import com.xcong.excoin.modules.documentary.entity.FollowTraderLabelEntity;

import com.xcong.excoin.modules.documentary.entity.FollowTraderProfitInfoEntity;

import com.xcong.excoin.modules.documentary.service.DocumentaryService;

import com.xcong.excoin.modules.documentary.vo.BeTraderConditionVo;

import com.xcong.excoin.modules.documentary.vo.DocumentaryOrderInfoVo;

import com.xcong.excoin.modules.documentary.vo.DocumentaryOrderSetInfoVo;

import com.xcong.excoin.modules.documentary.vo.FollowFollowerNoticeVo;

@@ -284,7 +287,43 @@
      }else {

         followInfoVo.setNickname(phone);

      }

		


      List<ContractHoldOrderEntity> myFollowOrder = followFollowerProfitDao.getFollowOrderNowRecords(memberId);



      BigDecimal totalBondAmount = BigDecimal.ZERO;

      BigDecimal profitOrLess = BigDecimal.ZERO;

      if (CollUtil.isNotEmpty(myFollowOrder)) {

         for(ContractHoldOrderEntity contractHoldOrderEntity : myFollowOrder) {

            BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(contractHoldOrderEntity.getSymbol())));

            BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(contractHoldOrderEntity.getSymbol());



            // 盈亏

            BigDecimal rewardRatio = BigDecimal.ZERO;

            // 开多

            if (contractHoldOrderEntity.OPENING_TYPE_MORE == contractHoldOrderEntity.getOpeningType()) {

               // (最新价-开仓价)*规格*张数

               rewardRatio = newPrice.subtract(contractHoldOrderEntity.getOpeningPrice()).multiply(lotNumber).multiply(new BigDecimal(contractHoldOrderEntity.getSymbolCnt()));

               // 开空

            } else {

               // (开仓价-最新价)*规格*张数

               rewardRatio = contractHoldOrderEntity.getOpeningPrice().subtract(newPrice).multiply(lotNumber).multiply(new BigDecimal(contractHoldOrderEntity.getSymbolCnt()));

            }



            if (member.getIsProfit() == MemberEntity.IS_PROFIT_Y) {

               PlatformTradeSettingEntity tradeSettingEntity = cacheSettingUtils.getTradeSetting();

               if (rewardRatio.compareTo(BigDecimal.ZERO) > -1) {

                  rewardRatio = rewardRatio.multiply(BigDecimal.ONE.subtract(tradeSettingEntity.getProfitParam()));

               }

            }



            profitOrLess = profitOrLess.add(rewardRatio).setScale(2, BigDecimal.ROUND_DOWN);

            totalBondAmount = totalBondAmount.add(contractHoldOrderEntity.getBondAmount()).setScale(2, BigDecimal.ROUND_DOWN);

         }

      }



      followInfoVo.setTotalAmount(totalBondAmount);

      followInfoVo.setTotalProfitOrLess(profitOrLess);



      BigDecimal totalPrincipals =  BigDecimal.ZERO;

      BigDecimal totalProfits =  BigDecimal.ZERO;

      Map<String, Object> columnMap = new HashMap<>();

@@ -593,8 +632,23 @@
   public Result getDocumentaryOrderSetInfo(String tradeId) {

      //获取用户ID

        Long memberId = LoginUserUtils.getAppLoginUser().getId();

        log.info("跟单---点击跟单或者编辑---"+memberId+"参数"+tradeId);

        DocumentaryOrderSetInfoVo documentaryOrderSetInfoVo = new DocumentaryOrderSetInfoVo();

        long parseLong = Long.parseLong(tradeId);

        
        //只能跟随一个人

        Map<String, Object> columnMaps = new HashMap<>();

        columnMaps.put("member_id", memberId);

        List<FollowFollowerSettingEntity> followFollowerSettingEntityAllows = followFollowerSettingDao.selectByMap(columnMaps);

        if(CollUtil.isNotEmpty(followFollowerSettingEntityAllows)) {

           for(FollowFollowerSettingEntity followFollowerSettingEntityAllow : followFollowerSettingEntityAllows) {

              Long tradeIdAllow = followFollowerSettingEntityAllow.getTraderId();

              if(parseLong != tradeIdAllow) {

                 return Result.fail(MessageSourceUtils.getString("documentary_service_0015"));

              }

           }

        }

        
        //获取【跟随者设置】数据

        FollowFollowerSettingEntity followFollowerSettingEntity = followFollowerSettingDao.selectOneBymemberIdAndTradeId(memberId,parseLong);



@@ -621,8 +675,12 @@
        documentaryOrderSetInfoVo.setFollowCnt(followCnt);

        

        Integer maxFollowCnt = followFollowerSettingEntity.getMaxFollowCnt();

        documentaryOrderSetInfoVo.setMaxFollowCnt(maxFollowCnt);

        
        if(maxFollowCnt > 0){

           documentaryOrderSetInfoVo.setMaxFollowCnt(maxFollowCnt.toString());

      }else {

         documentaryOrderSetInfoVo.setMaxFollowCnt("");

      }

        log.info(memberId + "-最大持仓张数-"+maxFollowCnt.toString());

      return Result.ok(documentaryOrderSetInfoVo);

   }



@@ -699,7 +757,15 @@


   @Override

   @Transactional

   public Result beTrader() {

   public Result beTrader(@Valid BeTraderDto beTraderDto) {

      //头像

      String avatar = beTraderDto.getAvatar();

      //昵称

      String nickname = beTraderDto.getNickname();

      //宣言

      String declaration = beTraderDto.getDeclaration();

      //标签

      String labels = beTraderDto.getLabels();

      //获取用户ID

        Long memberId = LoginUserUtils.getAppLoginUser().getId();

        MemberEntity memberEntity = memberDao.selectById(memberId);

@@ -737,14 +803,25 @@
        followTraderInfoEntity.setMemberId(memberId);

        followTraderInfoEntity.setProfitRatio(BigDecimal.valueOf(0.1));

//        followTraderInfoEntity.setAvatar(FollowTraderInfoEntity.AVATAR_DEFAULT);

        String phone = memberEntity.getPhone();

        String email = memberEntity.getEmail();

        if(StrUtil.isNotEmpty(phone)) {

           followTraderInfoEntity.setNickname(phone.replaceAll("(\\d{3})\\d{4}(\\d{4})", "$1****$2"));

        }else {

           followTraderInfoEntity.setNickname(email.replaceAll("(\\w?)(\\w+)(\\w)(@\\w+\\.[a-z]+(\\.[a-z]+)?)","$1****$3$4"));

//        String phone = memberEntity.getPhone();

//        String email = memberEntity.getEmail();

//        if(StrUtil.isNotEmpty(phone)) {

//           followTraderInfoEntity.setNickname(phone.replaceAll("(\\d{3})\\d{4}(\\d{4})", "$1****$2"));

//        }else {

//           followTraderInfoEntity.setNickname(email.replaceAll("(\\w?)(\\w+)(\\w)(@\\w+\\.[a-z]+(\\.[a-z]+)?)","$1****$3$4"));

//        }

        if(StrUtil.isNotEmpty(avatar)) {

           followTraderInfoEntity.setAvatar(avatar);

        }

        followTraderInfoEntity.setDeclaration(FollowTraderInfoEntity.DECLARATION_DEFAULT);

        followTraderInfoEntity.setNickname(nickname);

        followTraderInfoEntity.setNicknameState(FollowTraderInfoEntity.STATE_Y);

        if(StrUtil.isEmpty(declaration)) {

           followTraderInfoEntity.setDeclaration(FollowTraderInfoEntity.DECLARATION_DEFAULT);

        }else {

           followTraderInfoEntity.setDeclaration(declaration);

        }

        followTraderInfoEntity.setLabels(labels);

        followTraderInfoEntity.setFollowNum(FollowTraderInfoEntity.FOLLOWNUM_DEFAULT);

        followTraderInfoEntity.setIsAll(FollowTraderInfoEntity.IS_ALL_N);

        followTraderInfoEntity.setProfitRatio(BigDecimal.ZERO);

        followTraderInfoEntity.setVerifyStatus(FollowTraderInfoEntity.VERIFYSTATUS_ING);

@@ -790,6 +867,8 @@
        tradeSetInfoVo.setAvatar(avatar);

        String nickname = followTraderInfoEntity.getNickname();

        tradeSetInfoVo.setNickname(nickname);

        Integer nicknameState = followTraderInfoEntity.getNicknameState();

        tradeSetInfoVo.setNicknameState(nicknameState);

        String declaration = followTraderInfoEntity.getDeclaration();

        tradeSetInfoVo.setDeclaration(declaration);

        Integer isOpen = followTraderInfoEntity.getIsOpen();

@@ -824,6 +903,14 @@
        String declaration = updateTradeSetInfoDto.getDeclaration();

        int isOpen = updateTradeSetInfoDto.getIsOpen();

        String labels = updateTradeSetInfoDto.getLabels();

        Integer nicknameState = followTraderInfoEntity.getNicknameState();

        if(FollowTraderInfoEntity.STATE_Y == nicknameState && !nickname.equals(followTraderInfoEntity.getNickname())) {

           return Result.ok(MessageSourceUtils.getString("member_service_0099"));

        }

        if(!nickname.equals(followTraderInfoEntity.getNickname())) {

           followTraderInfoEntity.setNickname(nickname);

           followTraderInfoEntity.setNicknameState(FollowTraderInfoEntity.STATE_Y);

        }

        followTraderInfoEntity.setLabels(labels);

        followTraderInfoEntity.setAvatar(avatar);

        followTraderInfoEntity.setNickname(nickname);

@@ -1069,6 +1156,18 @@
        long id = outFollowInfoDto.getId();

        //获取【跟随者收益】

        FollowFollowerProfitEntity followFollowerProfitEntity = followFollowerProfitDao.selectById(id);

        
        //当前有跟单合约不允许移除

        //获取【跟随者-订单关联表】

        Map<String, Object> selectColumnMap = new HashMap<>();

        selectColumnMap.put("member_id", followFollowerProfitEntity.getMemberId());

        selectColumnMap.put("trade_member_id", memberId);

        selectColumnMap.put("order_type", FollowFollowerOrderRelationEntity.ORDER_TYPE_HOLD);

        List<FollowFollowerOrderRelationEntity> followFollowerOrderRelationEntitys = followFollowerOrderRelationDao.selectByMap(selectColumnMap);

        if(CollUtil.isNotEmpty(followFollowerOrderRelationEntitys)) {

           return Result.fail(MessageSourceUtils.getString("documentary_service_0019"));

        }

        
        followFollowerProfitEntity.setIsFollow(FollowFollowerProfitEntity.IS_FOLLOW_N);

        followFollowerProfitDao.updateById(followFollowerProfitEntity);



@@ -1119,6 +1218,7 @@
      }

      MemberSettingEntity memberSettingEntity = memberSettingDao.selectMemberSettingByMemberId(memberId);

      if(ObjectUtil.isNotEmpty(memberSettingEntity)) {

         log.info(memberId + "的消息提醒状态变更");

         memberSettingEntity.setMessageReminder(0);

         memberSettingDao.updateById(memberSettingEntity);

      }

@@ -1146,6 +1246,13 @@
      }

      return Result.ok(arrayList);

   }



   @Override

   public Result beTraderCondition() {

      String type = "apply_trader_rule";

      List<BeTraderConditionVo> beTraderConditionVos = followTraderInfoDao.selectBeTraderCondition(type);

      return Result.ok(beTraderConditionVos);

   }