package project.futures.internal;
|
|
import java.text.DecimalFormat;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.Collections;
|
import java.util.Comparator;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
import org.apache.commons.collections.CollectionUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import kernel.util.Arith;
|
import kernel.util.DateUtils;
|
import kernel.web.ApplicationUtil;
|
import project.futures.FuturesPara;
|
import project.futures.FuturesParaService;
|
import project.futures.FuturesRedisKeys;
|
import project.redis.RedisHandler;
|
|
public class FuturesParaServiceImpl implements FuturesParaService {
|
|
private static final Logger logger = LoggerFactory.getLogger(FuturesParaServiceImpl.class);
|
|
private JdbcTemplate jdbcTemplate;
|
private RedisHandler redisHandler;
|
|
@Override
|
public FuturesPara cacheGet(String id) {
|
return (FuturesPara) redisHandler.get(FuturesRedisKeys.FUTURES_PARA_ID + id);
|
}
|
|
public List<FuturesPara> cacheGetBySymbolSort(String symbol) {
|
return sortPara(cacheGetBySymbol(symbol));
|
}
|
|
public List<FuturesPara> cacheGetBySymbol(String symbol) {
|
Map<String, FuturesPara> map = (Map<String, FuturesPara>) redisHandler
|
.get(FuturesRedisKeys.FUTURES_PARA_SYMBOL + symbol);
|
if (map != null && !map.isEmpty()) {
|
return new ArrayList<FuturesPara>(map.values());
|
}
|
return new ArrayList<FuturesPara>();
|
}
|
|
private List<FuturesPara> sortPara(List<FuturesPara> list) {
|
if (CollectionUtils.isEmpty(list))
|
return list;
|
// 列表按 s，m，h，d 排序
|
String[] regulation = { FuturesPara.TIMENUM_SECOND, FuturesPara.TIMENUM_MINUTE, FuturesPara.TIMENUM_HOUR,
|
FuturesPara.TIMENUM_DAY };
|
final List<String> regulationOrder = Arrays.asList(regulation);
|
Collections.sort(list, new Comparator<FuturesPara>() {
|
@Override
|
public int compare(FuturesPara o1, FuturesPara o2) {
|
// TODO Auto-generated method stub
|
int unitSort = regulationOrder.indexOf(o1.getTimeUnit()) - regulationOrder.indexOf(o2.getTimeUnit());
|
int timeSort = o1.getTimeNum() - o2.getTimeNum();
|
return unitSort == 0 ? timeSort : unitSort;
|
}
|
});
|
return list;
|
}
|
|
public void add(FuturesPara source) {
|
if (null == source) {
|
logger.error("null error,futurepara add fail ");
|
return;
|
}
|
source.setId(ApplicationUtil.getCurrentTimeUUID());
|
Object[] jdbcParams = ApplicationUtil.getInsertStatement(source);
|
String insertUserSql = (String)jdbcParams[0];
|
Object[] sqlParameters = (Object[])jdbcParams[1];
|
jdbcTemplate.update(insertUserSql, sqlParameters);
|
|
redisHandler.setSync(FuturesRedisKeys.FUTURES_PARA_ID + source.getId().toString(), source);
|
|
Map<String, FuturesPara> map = (Map<String, FuturesPara>) redisHandler
|
.get(FuturesRedisKeys.FUTURES_PARA_SYMBOL + source.getSymbol());
|
if (map == null) {
|
map = new ConcurrentHashMap<String, FuturesPara>();
|
}
|
map.put(source.getId().toString(), source);
|
redisHandler.setSync(FuturesRedisKeys.FUTURES_PARA_SYMBOL + source.getSymbol(), map);
|
}
|
|
public Map<String, Object> bulidOne(FuturesPara para) {
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("para_id", para.getId().toString());
|
map.put("symbol", para.getSymbol());
|
map.put("time_num", para.getTimeNum());
|
map.put("time_unit", para.getTimeUnit());
|
map.put("entityVersion", para.getEntityVersion());
|
map.put("timeUnitCn", para.getTimeUnitCn());
|
map.put("timestamp", para.getTimestamp());
|
map.put("now_time", DateUtils.format(new Date(),DateUtils.NORMAL_DATE_FORMAT));
|
|
DecimalFormat df = new DecimalFormat("#");
|
if (para.getProfit_ratio() < 0.01 || para.getProfit_ratio_max() < 0.01) {
|
df = new DecimalFormat("#.#");
|
}
|
|
// TMX start voaex
|
// map.put("profit_ratio", df.format(Arith.mul(para.getProfit_ratio(), 100)));
|
// TMX end
|
// if(para.getProfit_ratio() != para.getProfit_ratio_max()) {
|
map.put("profit_ratio", df.format(Arith.mul(para.getProfit_ratio(), 100)) + "~"
|
+ df.format(Arith.mul(para.getProfit_ratio_max(), 100)));
|
// }
|
|
map.put("buy_min", para.getUnit_amount());
|
map.put("unit_fee", para.getUnit_fee());
|
map.put("buy_max", para.getUnit_max_amount() <= 0 ? null : para.getUnit_max_amount());
|
return map;
|
}
|
|
public void update(FuturesPara source) {
|
|
Object[] jdbcParams = ApplicationUtil.getUpdateStatement(source, "WHERE UUID=?", new Object[] {source.getId()});
|
String updateUserSql = (String)jdbcParams[0];
|
Object[] sqlParameters = (Object[])jdbcParams[1];
|
jdbcTemplate.update(updateUserSql, sqlParameters);
|
redisHandler.setSync(FuturesRedisKeys.FUTURES_PARA_ID + source.getId().toString(), source);
|
|
Map<String, FuturesPara> map = (Map<String, FuturesPara>) redisHandler
|
.get(FuturesRedisKeys.FUTURES_PARA_SYMBOL + source.getSymbol());
|
if (map == null) {
|
map = new ConcurrentHashMap<String, FuturesPara>();
|
}
|
map.put(source.getId().toString(), source);
|
redisHandler.setSync(FuturesRedisKeys.FUTURES_PARA_SYMBOL + source.getSymbol(), map);
|
}
|
|
public void delete(FuturesPara source) {
|
String id = source.getId().toString();
|
String symbol = source.getSymbol();
|
|
jdbcTemplate.update("DELETE FROM T_FUTURES_PARA WHERE UUID=?", source.getId());
|
|
redisHandler.remove(FuturesRedisKeys.FUTURES_PARA_ID + id);
|
|
Map<String, FuturesPara> map = (Map<String, FuturesPara>) redisHandler
|
.get(FuturesRedisKeys.FUTURES_PARA_SYMBOL + symbol);
|
if (map != null && !map.isEmpty()) {
|
map.remove(id);
|
}
|
redisHandler.setSync(FuturesRedisKeys.FUTURES_PARA_SYMBOL + symbol, map);
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public void setRedisHandler(RedisHandler redisHandler) {
|
this.redisHandler = redisHandler;
|
}
|
|
}
|
