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.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.trader.TraderService;
|
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.*;
|
|
@Service
|
public class TraderServiceImpl implements TraderService {
|
|
@Resource
|
private TraderMapper traderMapper;
|
|
public Trader findById(String id) {
|
|
return traderMapper.selectById(id);
|
}
|
|
public Trader findByPartyId(String partyId) {
|
LambdaQueryWrapper<Trader> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
lambdaQueryWrapper.eq(Trader::getPartyId, partyId);
|
Trader trader = traderMapper.selectOne(lambdaQueryWrapper);
|
return trader;
|
}
|
|
@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.orderByDesc(Trader::getCreateTime);
|
|
IPage<Trader> page = traderMapper.selectPage(pageparam, new 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;
|
}
|
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");
|
map.put("profit", df2.format(Arith.add(entity.getProfit(), entity.getDeviationProfit())));
|
|
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)));
|
|
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));
|
}
|
|
|
}
|
