package project.futures.internal;
|
|
import java.math.RoundingMode;
|
import java.text.DecimalFormat;
|
import java.text.SimpleDateFormat;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.TimeZone;
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import kernel.bo.RecordObjectMapper;
|
import kernel.exception.BusinessException;
|
import kernel.util.DateUtils;
|
import kernel.util.StringUtils;
|
import project.futures.FuturesOrder;
|
import project.futures.FuturesOrderLocalService;
|
import project.futures.FuturesPara;
|
import project.futures.FuturesParaService;
|
import project.futures.FuturesRedisKeys;
|
import project.item.ItemService;
|
import project.item.model.Item;
|
import project.redis.RedisHandler;
|
|
public class FuturesOrderLocalServiceImpl implements FuturesOrderLocalService {
|
|
protected JdbcTemplate jdbcTemplate;
|
protected ItemService itemService;
|
protected RedisHandler redisHandler;
|
protected FuturesParaService futuresParaService;
|
|
public FuturesOrder cacheByOrderNo(String order_no) {
|
FuturesOrder futuresOrder = (FuturesOrder) redisHandler
|
.get(FuturesRedisKeys.FUTURES_SUBMITTED_ORDERNO + order_no);
|
// FuturesOrder futuresOrder = cache.get(order_no);
|
if (null == futuresOrder) {
|
futuresOrder = findByOrderNo(order_no);
|
}
|
return futuresOrder;
|
}
|
|
public FuturesOrder findByOrderNo(String order_no) {
|
List<FuturesOrder> list = jdbcTemplate.query("SELECT * FROM T_FUTURES_ORDER WHERE ORDER_NO=?",
|
RecordObjectMapper.newInstance(FuturesOrder.class), order_no);
|
if (list.size() > 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
|
public Map<String, Object> bulidOne(FuturesOrder order) {
|
// FuturesOrder order_cache = cache.get(order.getOrder_no());
|
FuturesOrder order_cache = (FuturesOrder) redisHandler
|
.get(FuturesRedisKeys.FUTURES_SUBMITTED_ORDERNO + order.getOrder_no());
|
if (order_cache != null) {
|
order = order_cache;
|
}
|
|
List<FuturesPara> paras = futuresParaService.cacheGetBySymbol(order.getSymbol());
|
double ratio_min = 0D;
|
double ratio_max = 0D;
|
for (int i = 0; i < paras.size(); i++) {
|
if (paras.get(i).getTimeUnit().equals(order.getTimeUnit())
|
&& paras.get(i).getTimeNum() == order.getTimeNum()) {
|
ratio_min = paras.get(i).getProfit_ratio();
|
ratio_max = paras.get(i).getProfit_ratio_max();
|
}
|
}
|
|
Item item = this.itemService.cacheBySymbol(order.getSymbol(), false);
|
if (item == null) {
|
throw new BusinessException("参数错误");
|
}
|
String decimals = "#.";
|
|
for (int i = 0; i < item.getDecimals(); i++) {
|
decimals = decimals + "#";
|
}
|
if (item.getDecimals() == 0) {
|
decimals = "#";
|
}
|
DecimalFormat df_symbol = new DecimalFormat(decimals);
|
df_symbol.setRoundingMode(RoundingMode.FLOOR);// 向下取整
|
TimeZone timeZone = TimeZone.getTimeZone("America/New_York");
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
|
sdf.setTimeZone(timeZone);
|
DecimalFormat df = new DecimalFormat("#.##");
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("order_no", order.getOrder_no());
|
map.put("name", item.getName());
|
map.put("symbol", order.getSymbol());
|
map.put("open_time", sdf.format(order.getCreate_time()));
|
if (order.getClose_time() != null) {
|
map.put("close_time", sdf.format(order.getClose_time()));
|
} else {
|
map.put("close_time", "--");
|
}
|
|
map.put("direction", order.getDirection());
|
map.put("open_price", df_symbol.format(order.getTrade_avg_price()));
|
map.put("state", order.getState());
|
map.put("amount", order.getVolume());
|
map.put("fee", order.getFee());
|
/**
|
* 收益
|
*/
|
if (order.getProfit() > 0) {
|
// if ("submitted".equals(order.getState())) {
|
// map.put("profit", df.format(Arith.mul(order.getVolume(), ratio_min)) + " " + "~ "
|
// + df.format(Arith.mul(order.getVolume(), ratio_max)));
|
// } else {
|
map.put("profit", df.format(order.getProfit()));
|
// }
|
map.put("profit_state", "1");
|
|
} else {
|
map.put("profit", df.format(order.getProfit()));
|
map.put("profit_state", "0");
|
}
|
|
map.put("volume", order.getVolume());
|
|
map.put("settlement_time", sdf.format(order.getSettlement_time()));// 交割时间
|
map.put("close_price", df_symbol.format(order.getClose_avg_price()));
|
map.put("remain_time", StringUtils.isEmptyString(order.getRemain_time()) ? "0:0:0" : order.getRemain_time());
|
map.put("time_num", order.getTimeNum());
|
map.put("time_unit", order.getTimeUnit().substring(0, 1));
|
return map;
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public void setItemService(ItemService itemService) {
|
this.itemService = itemService;
|
}
|
|
public void setRedisHandler(RedisHandler redisHandler) {
|
this.redisHandler = redisHandler;
|
}
|
|
public void setFuturesParaService(FuturesParaService futuresParaService) {
|
this.futuresParaService = futuresParaService;
|
}
|
|
}
|
