| | |
| | | ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(id); |
| | | |
| | | List<FollowFollowerSettingEntity> followerSettings = followFollowerSettingDao.selectAllFollowerSettingByTradeMemberId(holdOrderEntity.getMemberId()); |
| | | log.info("---->{}, {}", followerSettings.size(), holdOrderEntity.getMemberId()); |
| | | // 开仓价 |
| | | BigDecimal openPrice = holdOrderEntity.getOpeningPrice(); |
| | | PlatformTradeSettingEntity tradeSettingEntity = cacheSettingUtils.getTradeSetting(); |
| | |
| | | Long tradeMemberId = holdOrderEntity.getMemberId(); |
| | | if (CollUtil.isNotEmpty(followerSettings)) { |
| | | for (FollowFollowerSettingEntity followerSetting : followerSettings) { |
| | | log.info("循环开始"); |
| | | // 当前持仓张数 |
| | | Integer holdingCnt = followFollowerOrderRelationDao.selectFollowerHoldingSymbolCnt(tradeMemberId, followerSetting.getMemberId()); |
| | | |
| | |
| | | symbolCnt = followerSetting.getFollowCnt() * holdOrderEntity.getSymbolCnt(); |
| | | } |
| | | |
| | | log.info("--->>>{}, {}", symbolCnt, followerSetting.getMaxFollowCnt()); |
| | | if (followerSetting.getMaxFollowCnt() != null && followerSetting.getMaxFollowCnt() !=0) { |
| | | // 若张数+当前持仓张数大于最大持仓张数,则取最大持仓减去当前持仓,若差值小于等于0,则不下单 |
| | | if (symbolCnt + holdingCnt > followerSetting.getMaxFollowCnt()) { |
| | | symbolCnt = followerSetting.getMaxFollowCnt() - holdingCnt; |
| | | } |
| | | |
| | | log.info("--->{}, {}, {}", symbolCnt, followerSetting.getMaxFollowCnt(), holdingCnt); |
| | | if (symbolCnt <= 0) { |
| | | // LogRecordUtils.insertFollowerNotice(memberEntity.getId(), NoticeConstant.OPEN_ORDER_TITLE, StrUtil.format(NoticeConstant.OPEN_ORDER_CONTENT, holdOrderEntity.getSymbol() + "开空", openPrice, followTraderInfoEntity.getNickname())); |
| | | continue; |
| | |
| | | contractOrderEntity.setOpeningTime(new Date()); |
| | | contractHoldOrderDao.insert(followHoldOrder); |
| | | int i = contractOrderDao.insert(contractOrderEntity); |
| | | log.info("----->{}", i); |
| | | if (i > 0) { |
| | | memberWalletContractDao.increaseWalletContractBalanceById(prePaymentAmount.negate(), openFeePrice.negate(), null, walletContract.getId()); |
| | | |