blame | history | patch | commit | commitdiff | ignore whitespace
Helius
2021-03-04 36d59c12794849c1b6fbbcbd41f97ea2fe71b09c 
 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();



@@ -874,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);



            }



         }



      



@@ -1058,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);







@@ -1083,6 +1107,7 @@


   }







   @Override



   @Transactional



   public Result getFollowFollowerNoticeList(FollowFollowerNoticeDto followFollowerNoticeDto) {



      //获取用户ID



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



@@ -1104,6 +1129,11 @@


            followFollowerNoticeVo.setCreateTime(createTime);



            arrayList.add(followFollowerNoticeVo);



         }



      }



      MemberSettingEntity memberSettingEntity = memberSettingDao.selectMemberSettingByMemberId(memberId);



      if(ObjectUtil.isNotEmpty(memberSettingEntity)) {



         memberSettingEntity.setMessageReminder(0);



         memberSettingDao.updateById(memberSettingEntity);



      }



        



      return Result.ok(arrayList);



@@ -1129,6 +1159,13 @@


      }



      return Result.ok(arrayList);



   }







   @Override



   public Result beTraderCondition() {



      String type = "apply_trader_rule";



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



      return Result.ok(beTraderConditionVos);



   }