20210304 消息提醒日志

xiaoyong931011

2021-03-04 edb19b1fec14d667363b38b90dbb4585a0cc37ef

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

@@ -11,6 +11,8 @@
import javax.validation.Valid;



import com.xcong.excoin.modules.documentary.common.NoticeConstant;

import com.xcong.excoin.modules.member.entity.MemberSettingEntity;

import com.xcong.excoin.modules.member.parameter.vo.MemberMessageReminderVo;

import com.xcong.excoin.utils.*;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

@@ -41,6 +43,7 @@
import com.xcong.excoin.modules.documentary.dto.DocumentaryOrderSetDto;

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

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

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

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

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

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

@@ -57,6 +60,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;

@@ -76,6 +80,7 @@
import com.xcong.excoin.modules.documentary.vo.TraderStatusVo;

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

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

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

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

import com.xcong.excoin.modules.member.entity.MemberEntity;

import com.xcong.excoin.modules.member.entity.MemberLevelRateEntity;

@@ -124,6 +129,8 @@
    private FollowFollowerNoticeDao followFollowerNoticeDao;

    @Resource

    private FollowTraderLabelDao followTraderLabelDao;

    @Resource

    private MemberSettingDao memberSettingDao;

    

   

   @Override

@@ -143,10 +150,14 @@
   }



   @Override

   public Result getFollowTraderProfitInfo(@Valid RecordsPageDto recordsPageDto) {

        
   public Result getFollowTraderProfitInfo(@Valid FollowTraderProfitInfoDto recordsPageDto) {



      int type = recordsPageDto.getType();

        Page<FollowTraderProfitInfoVo> page = new Page<>(recordsPageDto.getPageNum(), recordsPageDto.getPageSize());

        FollowTraderProfitInfoEntity followTraderProfitInfoEntity = new FollowTraderProfitInfoEntity();

        if(FollowTraderInfoEntity.IS_SETFRIST_Y.equals(type)) {

           followTraderProfitInfoEntity.setType(type);

        }

        IPage<FollowTraderProfitInfoVo> followTraderProfitInfoList = followTraderProfitInfoDao.selectFollowTraderProfitInfoEntity(page, followTraderProfitInfoEntity);

        

        List<FollowTraderProfitInfoVo> followTraderProfitInfoVoList = followTraderProfitInfoList.getRecords();

@@ -309,38 +320,41 @@
                 MyFollowOrderVo myFollowOrderVo = new MyFollowOrderVo();

                 //获取交易员信息

               Long orderId = contractOrderEntity.getId();

               myFollowOrderVo.setOrderId(orderId);

               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();

                 myFollowOrderVo.setOrderType(orderType);

                 int leverRatio = contractOrderEntity.getLeverRatio();

                 myFollowOrderVo.setLeverRatio(leverRatio);

                 BigDecimal rewardAmount = contractOrderEntity.getRewardAmount().setScale(2, BigDecimal.ROUND_DOWN);

                 myFollowOrderVo.setRewardAmount(rewardAmount);

                 BigDecimal rewardRatio = contractOrderEntity.getRewardRatio().setScale(4, BigDecimal.ROUND_DOWN);

                 myFollowOrderVo.setRewardRatio(rewardRatio);

                 int symbolCnt = contractOrderEntity.getSymbolCnt();

                 myFollowOrderVo.setSymbolCnt(symbolCnt);

                 BigDecimal bondAmount = contractOrderEntity.getBondAmount().setScale(2, BigDecimal.ROUND_DOWN);

                 myFollowOrderVo.setBondAmount(bondAmount);

                 BigDecimal openingPrice = contractOrderEntity.getOpeningPrice().setScale(2, BigDecimal.ROUND_DOWN);

                 myFollowOrderVo.setOpeningPrice(openingPrice);

                 BigDecimal closingPrice = contractOrderEntity.getClosingPrice().setScale(2, BigDecimal.ROUND_DOWN);

                 myFollowOrderVo.setClosingPrice(closingPrice);

                 Date openingTime = contractOrderEntity.getOpeningTime();

                 myFollowOrderVo.setOpeningTime(openingTime);

                 Date closingTime = contractOrderEntity.getClosingTime();

                 myFollowOrderVo.setClosingTime(closingTime);

                 String orderNo = contractOrderEntity.getOrderNo();

                 myFollowOrderVo.setOrderNo(orderNo);

                 myFollowOrderVos.add(myFollowOrderVo);

               if(ObjectUtil.isNotEmpty(FollowFollowerOrderRelation)) {

                  myFollowOrderVo.setOrderId(orderId);

                  Long tradeId = FollowFollowerOrderRelation.getTradeId();

                  FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectById(tradeId);

                  if(ObjectUtil.isNotEmpty(followTraderInfoEntity)) {

                     String nickname = followTraderInfoEntity.getNickname();

                     myFollowOrderVo.setNickname(nickname);

                  }

                  String symbol = contractOrderEntity.getSymbol();

                  myFollowOrderVo.setSymbol(symbol);

                  int orderType = contractOrderEntity.getOrderType();

                  myFollowOrderVo.setOrderType(orderType);

                  int leverRatio = contractOrderEntity.getLeverRatio();

                  myFollowOrderVo.setLeverRatio(leverRatio);

                  BigDecimal rewardAmount = contractOrderEntity.getRewardAmount().setScale(2, BigDecimal.ROUND_DOWN);

                  myFollowOrderVo.setRewardAmount(rewardAmount);

                  BigDecimal rewardRatio = contractOrderEntity.getRewardRatio().setScale(4, BigDecimal.ROUND_DOWN);

                  myFollowOrderVo.setRewardRatio(rewardRatio);

                  int symbolCnt = contractOrderEntity.getSymbolCnt();

                  myFollowOrderVo.setSymbolCnt(symbolCnt);

                  BigDecimal bondAmount = contractOrderEntity.getBondAmount().setScale(2, BigDecimal.ROUND_DOWN);

                  myFollowOrderVo.setBondAmount(bondAmount);

                  BigDecimal openingPrice = contractOrderEntity.getOpeningPrice().setScale(2, BigDecimal.ROUND_DOWN);

                  myFollowOrderVo.setOpeningPrice(openingPrice);

                  BigDecimal closingPrice = contractOrderEntity.getClosingPrice().setScale(2, BigDecimal.ROUND_DOWN);

                  myFollowOrderVo.setClosingPrice(closingPrice);

                  Date openingTime = contractOrderEntity.getOpeningTime();

                  myFollowOrderVo.setOpeningTime(openingTime);

                  Date closingTime = contractOrderEntity.getClosingTime();

                  myFollowOrderVo.setClosingTime(closingTime);

                  String orderNo = contractOrderEntity.getOrderNo();

                  myFollowOrderVo.setOrderNo(orderNo);

                  myFollowOrderVos.add(myFollowOrderVo);

               }

              }

           }

      return Result.ok(myFollowOrderVos);

@@ -871,58 +885,59 @@
               TradeOrderInfoVo myFollowOrderVo = new TradeOrderInfoVo();

               //获取交易员信息

               Long orderId = contractHoldOrderEntity.getId();

               myFollowOrderVo.setOrderId(orderId);

               FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectTraderInfoByMemberId(memberId);

               String nickname = followTraderInfoEntity.getNickname();

               myFollowOrderVo.setNickname(nickname);

					
               String symbol = contractHoldOrderEntity.getSymbol();

               myFollowOrderVo.setSymbol(symbol);

               int orderType = contractHoldOrderEntity.getOpeningType();

               myFollowOrderVo.setOrderType(orderType);

               int leverRatio = contractHoldOrderEntity.getLeverRatio();

               myFollowOrderVo.setLeverRatio(leverRatio);

               int symbolCnt = contractHoldOrderEntity.getSymbolCnt();

               myFollowOrderVo.setSymbolCnt(symbolCnt);

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

               myFollowOrderVo.setBondAmount(bondAmount);

               BigDecimal openingPrice = contractHoldOrderEntity.getOpeningPrice().setScale(2, BigDecimal.ROUND_DOWN);

               myFollowOrderVo.setOpeningPrice(openingPrice);

               String orderNo = contractHoldOrderEntity.getOrderNo();

               myFollowOrderVo.setOrderNo(orderNo);

               Date openingTime = contractHoldOrderEntity.getCreateTime();

               myFollowOrderVo.setOpeningTime(openingTime);

					
               // 获取最新价

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

               myFollowOrderVo.setNewPrice(newPrice);

					
               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()));

               if(ObjectUtil.isNotEmpty(followTraderInfoEntity)) {

                  myFollowOrderVo.setOrderId(orderId);

                  String nickname = followTraderInfoEntity.getNickname();

                  myFollowOrderVo.setNickname(nickname);

                  String symbol = contractHoldOrderEntity.getSymbol();

                  myFollowOrderVo.setSymbol(symbol);

                  int orderType = contractHoldOrderEntity.getOpeningType();

                  myFollowOrderVo.setOrderType(orderType);

                  int leverRatio = contractHoldOrderEntity.getLeverRatio();

                  myFollowOrderVo.setLeverRatio(leverRatio);

                  int symbolCnt = contractHoldOrderEntity.getSymbolCnt();

                  myFollowOrderVo.setSymbolCnt(symbolCnt);

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

                  myFollowOrderVo.setBondAmount(bondAmount);

                  BigDecimal openingPrice = contractHoldOrderEntity.getOpeningPrice().setScale(2, BigDecimal.ROUND_DOWN);

                  myFollowOrderVo.setOpeningPrice(openingPrice);

                  String orderNo = contractHoldOrderEntity.getOrderNo();

                  myFollowOrderVo.setOrderNo(orderNo);

                  Date openingTime = contractHoldOrderEntity.getCreateTime();

                  myFollowOrderVo.setOpeningTime(openingTime);

						
                  // 获取最新价

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

                  myFollowOrderVo.setNewPrice(newPrice);

						
                  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()));

                     }

                  }

                  myFollowOrderVo.setRewardAmount(rewardRatio.setScale(2, BigDecimal.ROUND_DOWN));

						
                  // 回报率

                  BigDecimal returnRate = rewardRatio.divide(contractHoldOrderEntity.getBondAmount().subtract(contractHoldOrderEntity.getOpeningFeeAmount()), 8, BigDecimal.ROUND_DOWN);

                  myFollowOrderVo.setRewardRatio(returnRate.setScale(4, BigDecimal.ROUND_DOWN));

						
                  myFollowOrderVos.add(myFollowOrderVo);

               }

               myFollowOrderVo.setRewardAmount(rewardRatio.setScale(2, BigDecimal.ROUND_DOWN));

					
               // 回报率

               BigDecimal returnRate = rewardRatio.divide(contractHoldOrderEntity.getBondAmount().subtract(contractHoldOrderEntity.getOpeningFeeAmount()), 8, BigDecimal.ROUND_DOWN);

               myFollowOrderVo.setRewardRatio(returnRate.setScale(4, BigDecimal.ROUND_DOWN));

					
               myFollowOrderVos.add(myFollowOrderVo);

            }

         }

      

@@ -1055,6 +1070,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);



@@ -1080,6 +1107,7 @@
   }



   @Override

   @Transactional

   public Result getFollowFollowerNoticeList(FollowFollowerNoticeDto followFollowerNoticeDto) {

      //获取用户ID

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

@@ -1101,6 +1129,12 @@
            followFollowerNoticeVo.setCreateTime(createTime);

            arrayList.add(followFollowerNoticeVo);

         }

      }

      MemberSettingEntity memberSettingEntity = memberSettingDao.selectMemberSettingByMemberId(memberId);

      if(ObjectUtil.isNotEmpty(memberSettingEntity)) {

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

         memberSettingEntity.setMessageReminder(0);

         memberSettingDao.updateById(memberSettingEntity);

      }

        

      return Result.ok(arrayList);

@@ -1126,6 +1160,13 @@
      }

      return Result.ok(arrayList);

   }



   @Override

   public Result beTraderCondition() {

      String type = "apply_trader_rule";

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

      return Result.ok(beTraderConditionVos);

   }