Merge branch 'whole_new' of https://gitee.com/chonggaoxiao/new_excoin into ...

Helius

2021-01-26 ad01d9ed306451f37d309304f9f1b72616a8a165

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

@@ -16,14 +16,17 @@
import org.springframework.transaction.annotation.Transactional;



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

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

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import com.taobao.api.internal.toplink.embedded.websocket.util.StringUtil;

import com.xcong.excoin.common.LoginUserUtils;

import com.xcong.excoin.common.response.Result;

import com.xcong.excoin.modules.coin.dao.OrderCoinsDao;

import com.xcong.excoin.modules.coin.parameter.dto.RecordsPageDto;

import com.xcong.excoin.modules.contract.dao.ContractHoldOrderDao;

import com.xcong.excoin.modules.contract.dao.ContractOrderDao;

import com.xcong.excoin.modules.contract.entity.ContractEntrustOrderEntity;

import com.xcong.excoin.modules.contract.entity.ContractHoldOrderEntity;

import com.xcong.excoin.modules.contract.entity.ContractOrderEntity;

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

@@ -31,6 +34,7 @@
import com.xcong.excoin.modules.documentary.dao.FollowFollowerProfitDao;

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

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

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.CancelDocumentaryOrderSetDto;

@@ -50,6 +54,7 @@
import com.xcong.excoin.modules.documentary.entity.FollowFollowerProfitEntity;

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

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

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.DocumentaryOrderInfoVo;

@@ -67,6 +72,7 @@
import com.xcong.excoin.modules.documentary.vo.TradeOrderInfoVo;

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

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

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

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

import com.xcong.excoin.modules.member.dao.MemberDao;

import com.xcong.excoin.modules.member.dao.MemberLevelRateDao;

@@ -79,6 +85,7 @@
import cn.hutool.core.collection.CollUtil;

import cn.hutool.core.util.ObjectUtil;

import cn.hutool.core.util.StrUtil;

import jnr.ffi.Struct.int16_t;

import lombok.extern.slf4j.Slf4j;



@Slf4j

@@ -115,6 +122,8 @@
    private FollowFollowerOrderRelationDao followFollowerOrderRelationDao;

    @Resource

    private FollowFollowerNoticeDao followFollowerNoticeDao;

    @Resource

    private FollowTraderLabelDao followTraderLabelDao;

    

   

   @Override

@@ -164,9 +173,38 @@
              FollowTraderProfitInfoVo.setDeclaration(declaration);

              Integer isAll = followTraderInfoEntity.getIsAll();

              FollowTraderProfitInfoVo.setIsAll(isAll);

        		
              String labels = followTraderInfoEntity.getLabels();

              if(StrUtil.isNotEmpty(labels)) {

                 String labelsName = "";

                 String[] split = labels.split(",");

                 int length = split.length;

                 for(int i = 0;i < length;i++) {

                    String string = split[i];

                    FollowTraderLabelEntity selectById = followTraderLabelDao.selectById(Long.parseLong(string));

                    labelsName = selectById.getLabels();

                    labelsName += (labelsName + ",");

                 }

                 FollowTraderProfitInfoVo.setLabels(labelsName);

              }

        		
           }

        }

      return Result.ok(followTraderProfitInfoVoList);

   }

	
   public static void main(String[] args) {

      String labels = "";

      if(StrUtil.isNotEmpty(labels)) {

         String labelsName = "";

         String[] split = labels.split(",");

         int length = split.length;

         for(int i = 0;i < length;i++) {

            String string = split[i];

            labelsName += (string + ",");

         }

         System.out.println(labelsName);

      }

   }



   @Override

@@ -458,6 +496,20 @@
      if (traderInfoEntity != null) {

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

      }

		
      //判断当前用户是否是逐仓模式

      MemberEntity selectById2 = memberDao.selectById(memberId);

      Integer contractPositionType = selectById2.getContractPositionType();

      if(ContractEntrustOrderEntity.POSITION_TYPE_ADD != contractPositionType) {

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

      }

		
      //判断交易员是否开启了跟单

      FollowTraderInfoEntity selectById = followTraderInfoDao.selectById(traderId);

      Integer isOpen = selectById.getIsOpen();

      if(FollowTraderInfoEntity.ISOPEN_Y != isOpen) {

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

      }



      FollowFollowerSettingEntity isExistSetting = followFollowerSettingDao.selectOneBymemberIdAndTradeId(memberId, traderId);

      if (isExistSetting == null) {

@@ -719,6 +771,8 @@
        FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectTraderInfoByMemberId(memberId);

        

        TradeSetInfoVo tradeSetInfoVo = new TradeSetInfoVo();

        Long id = followTraderInfoEntity.getId();

        tradeSetInfoVo.setTradeId(id);

        String avatar = followTraderInfoEntity.getAvatar();

        tradeSetInfoVo.setAvatar(avatar);

        String nickname = followTraderInfoEntity.getNickname();

@@ -727,6 +781,20 @@
        tradeSetInfoVo.setDeclaration(declaration);

        Integer isOpen = followTraderInfoEntity.getIsOpen();

        tradeSetInfoVo.setIsOpen(isOpen);

        
        String labels = followTraderInfoEntity.getLabels();

      if(StrUtil.isNotEmpty(labels)) {

         String labelsName = "";

         String[] split = labels.split(",");

         int length = split.length;

         for(int i = 0;i < length;i++) {

            String string = split[i];

            FollowTraderLabelEntity selectById = followTraderLabelDao.selectById(Long.parseLong(string));

            labelsName = selectById.getLabels();

            labelsName += (labelsName + ",");

         }

         tradeSetInfoVo.setLabels(labelsName);

      }

      return Result.ok(tradeSetInfoVo);

   }



@@ -735,10 +803,16 @@
      //获取用户ID

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

        FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectTraderInfoByMemberId(memberId);

        /**

         * todo

         * 当前交易员有合约多单，是否可以直接调整【是否带单】，是否需要在调整前【判断是否已经有带单的合约单】

         */

        String avatar = updateTradeSetInfoDto.getAvatar();

        String nickname = updateTradeSetInfoDto.getNickname();

        String declaration = updateTradeSetInfoDto.getDeclaration();

        int isOpen = updateTradeSetInfoDto.getIsOpen();

        String labels = updateTradeSetInfoDto.getLabels();

        followTraderInfoEntity.setLabels(labels);

        followTraderInfoEntity.setAvatar(avatar);

        followTraderInfoEntity.setNickname(nickname);

        followTraderInfoEntity.setDeclaration(declaration);

@@ -746,7 +820,7 @@
        followTraderInfoDao.updateById(followTraderInfoEntity);

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

   }



	
   @Override

   public Result getTradeProfitInfo() {

      //获取用户ID

@@ -1001,7 +1075,7 @@
      FollowTraderInfoEntity traderInfoEntity = followTraderInfoDao.selectTraderInfoByMemberId(memberId);



      if (traderInfoEntity != null) {

         LogRecordUtils.insertFollowerNotice(memberId, NoticeConstant.STOP_FOLLOW_TITLE, StrUtil.format(NoticeConstant.STOP_FOLLOW_CONTENT, traderInfoEntity.getNickname()));

         LogRecordUtils.insertFollowerNotice(followMemberId, NoticeConstant.STOP_FOLLOW_TITLE, StrUtil.format(NoticeConstant.STOP_FOLLOW_CONTENT, traderInfoEntity.getNickname()));

      }

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

   }

@@ -1032,6 +1106,27 @@
        

      return Result.ok(arrayList);

   }



   @Override

   public Result getTradeSetLabelInfo() {

      //获取用户ID

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

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

      List<FollowTraderLabelEntity> selectByMap = followTraderLabelDao.selectByMap(columnMap);

      ArrayList<TradeSetLabelInfoVo> arrayList = new ArrayList<>();

      if(CollUtil.isNotEmpty(selectByMap)) {

         for(FollowTraderLabelEntity followTraderLabelEntity : selectByMap) {

            TradeSetLabelInfoVo tradeSetLabelInfoVo = new TradeSetLabelInfoVo();

            Long id = followTraderLabelEntity.getId();

            String labels = followTraderLabelEntity.getLabels();

            tradeSetLabelInfoVo.setId(id);

            tradeSetLabelInfoVo.setLabels(labels);

            arrayList.add(tradeSetLabelInfoVo);

         }

      }

      return Result.ok(arrayList);

   }