package com.yami.trading.service.trader.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.yami.trading.bean.contract.domain.ContractOrder;
|
import com.yami.trading.bean.contract.dto.TraderOwnClosedAggDTO;
|
import com.yami.trading.bean.trader.domain.Trader;
|
import com.yami.trading.common.constants.Constants;
|
import com.yami.trading.common.util.Arith;
|
import com.yami.trading.common.util.StringUtils;
|
import com.yami.trading.dao.trader.TraderMapper;
|
import com.yami.trading.service.contract.ContractOrderService;
|
import com.yami.trading.service.trader.TraderService;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.math.RoundingMode;
|
import java.text.DecimalFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class TraderServiceImpl implements TraderService {
|
|
@Resource
|
private TraderMapper traderMapper;
|
@Resource
|
@Lazy
|
private ContractOrderService contractOrderService;
|
|
public Trader findById(String id) {
|
|
return traderMapper.selectById(id);
|
}
|
|
public Trader findByPartyId(String partyId) {
|
LambdaQueryWrapper<Trader> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper.eq(Trader::getPartyId, partyId)
|
.eq(Trader::getDelFlag, 0)
|
.orderByDesc(Trader::getChecked)
|
.orderByDesc(Trader::getCreateTime)
|
.last("limit 1");
|
return traderMapper.selectOne(lambdaQueryWrapper);
|
}
|
|
@Override
|
public Trader findByPartyIdAndChecked(String partyId, int checked) {
|
LambdaQueryWrapper<Trader> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper.eq(Trader::getPartyId, partyId).eq(Trader::getChecked, checked);
|
return traderMapper.selectOne(lambdaQueryWrapper);
|
}
|
|
public List<Map<String, Object>> getPaged(Page<Trader> pageparam, String name, String state) {
|
LambdaQueryWrapper<Trader> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
// StringBuffer queryString = new StringBuffer(" SELECT * ");
|
// queryString.append(" FROM ");
|
// queryString.append(" T_TRADER ");
|
// queryString.append(" where 1=1 ");
|
|
Map<String, Object> parameters = new HashMap();
|
|
if (!StringUtils.isNullOrEmpty(name)) {
|
lambdaQueryWrapper.like(Trader::getName, name);
|
// queryString.append(" and name like :name");
|
// parameters.put("name", "%" + name + "%");
|
}
|
|
if (!StringUtils.isNullOrEmpty(state)) {
|
lambdaQueryWrapper.eq(Trader::getState, state);
|
// queryString.append(" and state =:state ");
|
// parameters.put("state", state);
|
}
|
// if (!StringUtils.isNullOrEmpty(orderBy_type) && !"create_time".equals(orderBy_type)) {
|
// lambdaQueryWrapper.orderByDesc(Trader::getCreate_time);
|
//// queryString.append(" order by (" + orderBy_type + "+ DEVIATION_" + orderBy_type + ") desc ");
|
//// parameters.put("orderBy_type", orderBy_type);
|
// } else {
|
//// queryString.append(" order by create_time desc ");
|
// lambdaQueryWrapper.orderByDesc(Trader::getCreate_time);
|
// }
|
lambdaQueryWrapper.eq(Trader::getDelFlag, 0);
|
lambdaQueryWrapper.eq(Trader::getChecked, 1);
|
lambdaQueryWrapper.eq(Trader::getState, "1");
|
lambdaQueryWrapper.orderByDesc(Trader::getCreateTime);
|
|
IPage<Trader> page = traderMapper.selectPage(pageparam, lambdaQueryWrapper);
|
|
// Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
List<Map<String, Object>> data = this.bulidData(page.getRecords());
|
return data;
|
|
}
|
|
@Override
|
public void save(Trader trader) {
|
traderMapper.insert(trader);
|
}
|
|
|
|
|
private List<Map<String, Object>> bulidData(List<Trader> traders) {
|
List<Map<String, Object>> result_traders = new ArrayList();
|
DecimalFormat df2 = new DecimalFormat("#.##");
|
df2.setRoundingMode(RoundingMode.FLOOR);// 鍚戜笅鍙栨暣
|
if (traders == null) {
|
return result_traders;
|
}
|
List<String> partyIds = traders.stream()
|
.filter(Objects::nonNull)
|
.map(Trader::getPartyId)
|
.filter(pid -> !StringUtils.isNullOrEmpty(pid))
|
.collect(Collectors.toList());
|
Map<String, TraderOwnClosedAggDTO> closedAggByParty = contractOrderService.mapClosedTraderOwnAggByPartyIds(partyIds);
|
for (int i = 0; i < traders.size(); i++) {
|
Map<String, Object> map = new HashMap<String, Object>();
|
// Trader entity = BeanUtil.mapToBean(traders.get(i), Trader.class, true);
|
Trader entity = traders.get(i);
|
String path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + entity.getImg();
|
map.put("img", path);
|
map.put("id", entity.getUuid());
|
map.put("partyId", entity.getPartyId());
|
map.put("name", entity.getName());
|
map.put("remarks", entity.getRemarks());
|
// map.put("symbols", "btc;eth");
|
map.put("symbol_name", entity.getSymbols());
|
map.put("follower_max", entity.getFollowerMax());
|
|
/**
|
* 杩�3鍛ㄦ敹鐩妛eek_3_profit
|
*/
|
map.put("week_3_profit",
|
df2.format(Arith.add(entity.getWeek3Profit(), entity.getDeviationWeek3Profit())));
|
/**
|
* 杩�3鍛ㄧ疮璁￠噾棰漺eek_3_order_amount
|
*/
|
map.put("week_3_order_amount",
|
df2.format(Arith.add(entity.getWeek3OrderAmount(), entity.getDeviationWeek3OrderAmount())));
|
|
/**
|
* 杩�3鍛ㄧ泩鍒╃瑪鏁皐eek_3_order_profit
|
*/
|
map.put("week_3_order_profit",
|
df2.format(Arith.add(entity.getWeek3OrderProfit(), entity.getDeviationWeek3OrderProfit())));
|
/**
|
* 杩�3鍛ㄤ氦鏄撶瑪鏁皐eek_3_order_sum
|
*/
|
map.put("week_3_order_sum",
|
df2.format(Arith.add(entity.getWeek3OrderSum(), entity.getDeviationWeek3OrderSum())));
|
|
/**
|
* 绱閲戦order_amount
|
*/
|
map.put("order_amount",
|
df2.format(Arith.add(entity.getOrderAmount(), entity.getDeviationOrderAmount())));
|
|
// map.put("symbol_name", "BTC/USDT;ETH/USDT");
|
TraderOwnClosedAggDTO closedAgg = closedAggByParty.get(entity.getPartyId());
|
double closedProfitSum = 0D;
|
double closedMarginSum = 0D;
|
if (closedAgg != null) {
|
if (closedAgg.getClosedProfitSum() != null) {
|
closedProfitSum = closedAgg.getClosedProfitSum().doubleValue();
|
}
|
if (closedAgg.getClosedMarginSum() != null) {
|
closedMarginSum = closedAgg.getClosedMarginSum().doubleValue();
|
}
|
}
|
double historyProfit = Arith.add(closedProfitSum, entity.getDeviationProfit());
|
double historyAmountBasis = closedMarginSum > 0D
|
? Arith.add(closedMarginSum, entity.getDeviationOrderAmount())
|
: Arith.add(entity.getOrderAmount(), entity.getDeviationOrderAmount());
|
map.put("profit", df2.format(historyProfit));
|
|
map.put("order_profit", (int) Arith.add(entity.getOrderProfit(), entity.getDeviationOrderProfit()));
|
|
map.put("order_loss", (int) Arith.add(entity.getOrderLoss(), entity.getDeviationOrderLoss()));
|
map.put("order_sum", (int) Arith.add(Arith.add(entity.getOrderProfit(), entity.getOrderLoss()),
|
Arith.add(entity.getDeviationOrderProfit(), entity.getDeviationOrderLoss())));
|
map.put("follower_sum", (int) Arith.add(entity.getFollowerSum(), entity.getDeviationFollowerSum()));
|
|
map.put("follower_now", (int) Arith.add(entity.getFollowerNow(), entity.getDeviationFollowerNow()));
|
// Deviation_w
|
|
/**
|
* 杩�3鍛ㄦ敹鐩婄巼 = 杩�3鍛ㄦ敹鐩�/杩�3鍛ㄧ疮璁￠噾棰� + 杩�3鍛ㄦ敹鐩婄巼鍋忓樊鍊�
|
*/
|
map.put("week_3_profit_ratio",
|
df2.format(Arith.add(Arith.mul(entity.getDeviationWeek3ProfitRatio(), 100),
|
Arith.mul(entity.getWeek3ProfitRatio(), 100))));
|
/**
|
* 杩�3鍛ㄨ儨鐜� week_3_order_profit_ratio
|
*/
|
double week_3_order_profit_ratio = 0;
|
if(Arith.add(entity.getWeek3OrderSum(), entity.getDeviationWeek3OrderSum()) == 0) {
|
week_3_order_profit_ratio = 0;
|
}else {
|
week_3_order_profit_ratio = Arith.mul(
|
Arith.div(Arith.add(entity.getWeek3OrderProfit(), entity.getDeviationWeek3OrderProfit()),
|
Arith.add(entity.getWeek3OrderSum(), entity.getDeviationWeek3OrderSum())),
|
100);
|
}
|
|
if (week_3_order_profit_ratio > 100) {
|
week_3_order_profit_ratio = 100;
|
}
|
if (week_3_order_profit_ratio < 0) {
|
week_3_order_profit_ratio = 0;
|
}
|
|
map.put("week_3_order_profit_ratio", df2.format(week_3_order_profit_ratio));
|
|
/**
|
* 绱鏀剁泭鐜�
|
*/
|
map.put("profit_ratio", df2.format(Arith.add(Arith.mul(entity.getDeviationProfitRatio(), 100),
|
Arith.mul(entity.getProfitRatio(), 100))));
|
|
map.put("profit_share_ratio", df2.format(Arith.mul(entity.getProfitShareRatio(), 100)));
|
map.put("follow_commission_type",
|
com.yami.trading.bean.trader.FollowCommissionType.normalizeOrLegacy(entity.getFollowCommissionType()));
|
map.put("follow_commission_monthly_amount",
|
entity.getFollowCommissionMonthlyAmount() == null ? "0"
|
: entity.getFollowCommissionMonthlyAmount().stripTrailingZeros().toPlainString());
|
map.put("follow_commission_daily_pct", df2.format(Arith.mul(entity.getFollowCommissionDailyPct(), 100)));
|
|
// 累计收益/收益率：历史=合约表已平仓全品种盈亏+偏差，分母优先已平仓保证金合计（与当前持仓 deposit 一致）+偏差；再加实时持仓
|
double openProfit = 0D;
|
double openDeposit = 0D;
|
int openPositionCount = 0;
|
List<ContractOrder> openOrders = contractOrderService.findSubmittedTraderOwn(entity.getPartyId(), "");
|
if (openOrders != null && !openOrders.isEmpty()) {
|
openPositionCount = openOrders.size();
|
for (ContractOrder one : openOrders) {
|
// submitted 持仓利润实时值在缓存中，先包裹后再聚合，口径与详情页一致
|
contractOrderService.wrapProfit(one);
|
openProfit = Arith.add(openProfit, one.getProfit() == null ? 0D : one.getProfit().doubleValue());
|
openDeposit = Arith.add(openDeposit, one.getDeposit() == null ? 0D : one.getDeposit().doubleValue());
|
}
|
}
|
double totalProfit = Arith.add(historyProfit, openProfit);
|
double totalRatio = 0D;
|
double totalAmount = Arith.add(historyAmountBasis, openDeposit);
|
if (totalAmount > 0D) {
|
totalRatio = Arith.mul(Arith.div(totalProfit, totalAmount), 100);
|
}
|
map.put("history_profit", df2.format(historyProfit));
|
double historyProfitRatioOnly = 0D;
|
if (historyAmountBasis > 0D) {
|
historyProfitRatioOnly = Arith.mul(Arith.div(historyProfit, historyAmountBasis), 100);
|
} else {
|
historyProfitRatioOnly = Arith.add(Arith.mul(entity.getDeviationProfitRatio(), 100),
|
Arith.mul(entity.getProfitRatio(), 100));
|
}
|
map.put("history_profit_ratio", df2.format(historyProfitRatioOnly));
|
map.put("open_profit", df2.format(openProfit));
|
map.put("open_deposit", df2.format(openDeposit));
|
map.put("open_position_count", openPositionCount);
|
map.put("total_profit", df2.format(totalProfit));
|
map.put("total_profit_ratio", df2.format(totalRatio));
|
|
result_traders.add(map);
|
}
|
|
return result_traders;
|
|
}
|
|
|
public void update(Trader entity) {
|
int result = traderMapper.updateById(entity);
|
}
|
|
public void updateTrader(Trader entity, List<ContractOrder> orders) {
|
// List<ContractOrder> orders = contractOrderService.findSubmitted(entity.getPartyId().toString(),"","");
|
double week_3_profit = 0;
|
double week_3_order_amount = 0;;
|
if(orders != null) {
|
Date date_now = new Date();
|
for(ContractOrder order : orders) {
|
double last_days = 22;
|
try {
|
last_days = daysBetween(date_now, order.getCreateTime());
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
if (last_days <= 21 ) {
|
week_3_profit = Arith.add(week_3_profit, order.getProfit().doubleValue());
|
week_3_order_amount = Arith.add(week_3_order_amount, Arith.mul(order.getVolumeOpen().doubleValue(), order.getUnitAmount().doubleValue()));
|
}
|
}
|
if(week_3_order_amount != 0) {
|
entity.setWeek3ProfitRatio(Arith.div(week_3_profit, week_3_order_amount));
|
}else {
|
entity.setWeek3ProfitRatio(0);
|
}
|
}
|
if( entity.getOrderAmount() != 0) {
|
entity.setProfitRatio(Arith.div(entity.getProfit(), entity.getOrderAmount()));
|
}else {
|
entity.setProfitRatio(0);
|
}
|
|
update(entity);
|
}
|
|
|
public static int daysBetween(Date smdate, Date bdate) throws ParseException {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
smdate = sdf.parse(sdf.format(smdate));
|
bdate = sdf.parse(sdf.format(bdate));
|
Calendar cal = Calendar.getInstance();
|
cal.setTime(smdate);
|
long time1 = cal.getTimeInMillis();
|
cal.setTime(bdate);
|
long time2 = cal.getTimeInMillis();
|
long between_days = (time2 - time1) / (1000 * 3600 * 24);
|
|
return Integer.parseInt(String.valueOf(between_days));
|
}
|
|
|
}
|
