package project.c2c.internal;
|
|
import java.text.DecimalFormat;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import kernel.bo.RecordObjectMapper;
|
import kernel.exception.BusinessException;
|
import kernel.util.Arith;
|
import kernel.util.StringUtils;
|
import kernel.web.Page;
|
import kernel.web.PagedQueryDao;
|
import project.Constants;
|
import project.RedisKeys;
|
import project.c2c.C2cAdvert;
|
import project.c2c.C2cAdvertService;
|
import project.c2c.C2cOrder;
|
import project.c2c.C2cPaymentMethod;
|
import project.data.DataService;
|
import project.data.model.Realtime;
|
import project.item.ItemService;
|
import project.item.model.Item;
|
import project.redis.RedisHandler;
|
import project.syspara.SysparaService;
|
import project.wallet.rate.ExchangeRate;
|
import project.wallet.rate.ExchangeRateService;
|
|
public class C2cAdvertServiceImpl implements C2cAdvertService {
|
|
private PagedQueryDao pagedDao;
|
private RedisHandler redisHandler;
|
private ExchangeRateService exchangeRateService;
|
private ItemService itemService;
|
private DataService dataService;
|
private SysparaService sysparaService;
|
private JdbcTemplate jdbcTemplate;
|
|
public Page pagedQuery(int pageNo, int pageSize, String c2c_user_id, String direction, String currency, String symbol, String amount,
|
Integer on_sale, Integer closed, boolean is_c2c_user) {
|
|
StringBuffer queryString = new StringBuffer();
|
|
Map<String, Object> parameters = new HashMap<String, Object>();
|
|
// queryString.append(" SELECT ");
|
// queryString.append(" advert.UUID id, advert.DIRECTION direction, advert.CURRENCY currency, advert.SYMBOL symbol, advert.PAY_RATE pay_rate, advert.PAY_TYPE pay_type, ");
|
// queryString.append(" advert.SYMBOL_VALUE symbol_value, advert.COIN_AMOUNT coin_amount, advert.INVESTMENT_MIN investment_min, advert.INVESTMENT_MAX investment_max, ");
|
// queryString.append(" advert.DEPOSIT deposit, advert.DEPOSIT_OPEN deposit_open, advert.ON_SALE on_sale, advert.SORT_INDEX sort_index, ");
|
// queryString.append(" advert.EXPIRE_TIME expire_time, advert.TRANSACTION_TERMS transaction_terms, advert.ORDER_MSG order_msg, ");
|
// queryString.append(" advert.REMARK remark, advert.CREATE_TIME create_time, advert.UPDATE_TIME update_time, ");
|
// queryString.append(" c2c_user.UUID c2c_user_id, c2c_user.NICK_NAME nick_name, c2c_user.HEAD_IMG head_img, c2c_user.C2C_USER_TYPE c2c_user_type, c2c_user.C2C_USER_CODE c2c_user_code, ");
|
// queryString.append(" party.UUID party_id, party.USERCODE user_code, party.USERNAME user_name ");
|
//
|
// queryString.append(" FROM T_C2C_ADVERT advert ");
|
// queryString.append(" LEFT JOIN T_C2C_USER c2c_user ON c2c_user.UUID = advert.C2C_USER_ID ");
|
// queryString.append(" LEFT JOIN PAT_PARTY party ON party.UUID = c2c_user.C2C_USER_PARTY_ID ");
|
// queryString.append(" WHERE 1=1 ");
|
// queryString.append(" AND advert.ON_SALE = 1 ");
|
|
if (is_c2c_user) {
|
queryString.append(" SELECT ");
|
queryString.append(" advert.UUID id, advert.C2C_USER_ID c2c_user_id, advert.DIRECTION direction, advert.CURRENCY currency, advert.SYMBOL symbol, advert.PAY_TYPE pay_type, ");
|
queryString.append(" advert.SYMBOL_VALUE symbol_value, advert.COIN_AMOUNT coin_amount, advert.INVESTMENT_MIN investment_min, advert.INVESTMENT_MAX investment_max, ");
|
queryString.append(" advert.ON_SALE on_sale, advert.TRANSACTION_TERMS transaction_terms ");
|
|
queryString.append(" FROM T_C2C_ADVERT advert ");
|
queryString.append(" WHERE 1=1 ");
|
|
if (StringUtils.isNotEmpty(c2c_user_id)) {
|
queryString.append(" AND advert.C2C_USER_ID = :c2c_user_id ");
|
parameters.put("c2c_user_id", c2c_user_id);
|
}
|
} else {
|
queryString.append(" SELECT ");
|
queryString.append(" advert.UUID id, advert.C2C_USER_ID c2c_user_id, advert.DIRECTION direction, advert.CURRENCY currency, advert.SYMBOL symbol, advert.PAY_TYPE pay_type, ");
|
queryString.append(" advert.SYMBOL_VALUE symbol_value, advert.COIN_AMOUNT coin_amount, advert.INVESTMENT_MIN investment_min, advert.INVESTMENT_MAX investment_max, ");
|
queryString.append(" advert.ON_SALE on_sale, advert.TRANSACTION_TERMS transaction_terms, c2c_user.NICK_NAME nick_name, c2c_user.HEAD_IMG head_img, ");
|
queryString.append(" c2c_user.THIRTY_DAYS_ORDER thirty_days_order, c2c_user.THIRTY_DAYS_ORDER_RATIO thirty_days_order_ratio, ");
|
queryString.append(" param_base_set.THIRTY_DAYS_ORDER thirty_days_order_base, param_base_set.THIRTY_DAYS_ORDER_RATIO thirty_days_order_ratio_base ");
|
|
queryString.append(" FROM T_C2C_ADVERT advert ");
|
queryString.append(" LEFT JOIN T_C2C_USER c2c_user ON c2c_user.UUID = advert.C2C_USER_ID ");
|
queryString.append(" LEFT JOIN T_C2C_USER_PARAM_BASE_SET param_base_set ON c2c_user.C2C_USER_PARTY_ID = param_base_set.C2C_USER_PARTY_ID ");
|
queryString.append(" WHERE 1=1 ");
|
|
if (StringUtils.isNotEmpty(c2c_user_id)) {
|
queryString.append(" AND advert.C2C_USER_ID != :c2c_user_id ");
|
parameters.put("c2c_user_id", c2c_user_id);
|
}
|
}
|
|
if (StringUtils.isNotEmpty(direction)) {
|
queryString.append(" AND advert.DIRECTION = :direction ");
|
parameters.put("direction", direction);
|
}
|
|
if (StringUtils.isNotEmpty(currency)) {
|
queryString.append(" AND advert.CURRENCY = :currency ");
|
parameters.put("currency", currency);
|
}
|
|
if (StringUtils.isNotEmpty(symbol)) {
|
queryString.append(" AND advert.SYMBOL = :symbol ");
|
parameters.put("symbol", symbol);
|
}
|
|
if (StringUtils.isNotEmpty(amount)) {
|
double amount_double = Double.valueOf(amount).doubleValue();
|
queryString.append(" AND (advert.COIN_AMOUNT * advert.SYMBOL_VALUE) >= :amount_double ");
|
parameters.put("amount_double", amount_double);
|
}
|
|
if (null != on_sale) {
|
queryString.append(" AND advert.ON_SALE = :on_sale ");
|
parameters.put("on_sale", on_sale);
|
}
|
|
if (null != closed) {
|
queryString.append(" AND advert.CLOSED = :closed ");
|
parameters.put("closed", closed);
|
}
|
|
if (C2cAdvert.DIRECTION_BUY.equals(direction)) {
|
// 用户买币从低到高
|
queryString.append(" order by advert.SYMBOL_VALUE asc ");
|
} else if (C2cAdvert.DIRECTION_SELL.equals(direction)) {
|
// 用户卖币从高到低
|
queryString.append(" order by advert.SYMBOL_VALUE desc ");
|
} else {
|
queryString.append(" order by advert.SORT_INDEX desc,advert.CREATE_TIME desc ");
|
}
|
|
Page page = this.pagedDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
|
DecimalFormat df = new DecimalFormat("#.##");
|
// 币种默认保留8位
|
DecimalFormat dfCoin = new DecimalFormat("#.########");
|
|
for (Map<String, Object> data : (List<Map<String, Object>>) page.getElements()) {
|
data.put("symbol_value", df.format(data.get("symbol_value")));
|
data.put("coin_amount", dfCoin.format(data.get("coin_amount")));
|
}
|
|
return page;
|
}
|
|
public Page pagedQueryQuick(int pageNo, int pageSize, String currency, String symbol, String direction, double amount, double coinAmount, String method_config_id) {
|
|
StringBuffer queryString = new StringBuffer();
|
|
queryString.append(" SELECT ");
|
queryString.append(" advert.UUID id, advert.C2C_USER_ID c2c_user_id, advert.DIRECTION direction ");
|
|
queryString.append(" FROM T_C2C_ADVERT advert ");
|
queryString.append(" WHERE 1=1 ");
|
queryString.append(" AND advert.ON_SALE = 1 ");
|
queryString.append(" AND advert.CLOSED = 0 ");
|
|
Map<String, Object> parameters = new HashMap<String, Object>();
|
|
if (StringUtils.isNotEmpty(direction)) {
|
queryString.append(" AND advert.DIRECTION = :direction ");
|
parameters.put("direction", direction);
|
}
|
|
if (StringUtils.isNotEmpty(currency)) {
|
queryString.append(" AND advert.CURRENCY = :currency ");
|
parameters.put("currency", currency);
|
}
|
|
if (StringUtils.isNotEmpty(symbol)) {
|
queryString.append(" AND advert.SYMBOL = :symbol ");
|
parameters.put("symbol", symbol);
|
}
|
|
if (amount > 0d) {
|
// 按支付金额支付
|
queryString.append(" AND advert.INVESTMENT_MIN <= :amount ");
|
queryString.append(" AND advert.INVESTMENT_MAX >= :amount ");
|
queryString.append(" AND advert.COIN_AMOUNT >= (:amount / advert.SYMBOL_VALUE)");
|
parameters.put("amount", amount);
|
}
|
|
if (coinAmount > 0d) {
|
// 按币种数量支付
|
queryString.append(" AND advert.COIN_AMOUNT >= :coinAmount ");
|
queryString.append(" AND advert.INVESTMENT_MIN <= (:coinAmount * advert.SYMBOL_VALUE)");
|
queryString.append(" AND advert.INVESTMENT_MAX >= (:coinAmount * advert.SYMBOL_VALUE)");
|
parameters.put("coinAmount", coinAmount);
|
}
|
|
if (StringUtils.isNotEmpty(method_config_id)) {
|
queryString.append(" AND advert.PAY_TYPE like :method_config_id ");
|
parameters.put("method_config_id", "%" + method_config_id + "%");
|
}
|
|
queryString.append(" order by advert.SORT_INDEX desc,advert.CREATE_TIME desc ");
|
|
Page page = this.pagedDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
return page;
|
}
|
|
/*
|
* 获取 用户所有支付方式 最优价格广告
|
*/
|
public Map<String, Map<String, Object>> getBestPriceAdvert(String currency, String symbol, String direction, String order_type, double amount, double coinAmount, List<C2cPaymentMethod> cpmList) {
|
|
Map<String, Map<String, Object>> retMap = new HashMap<String, Map<String,Object>>();
|
|
Set<String> methodConfigIdSet = new HashSet<String>();
|
for (int i = 0; i < cpmList.size(); i++) {
|
C2cPaymentMethod cpm = cpmList.get(i);
|
if (null != cpm) {
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("id", cpm.getId().toString());
|
map.put("payment_method_id", cpm.getId().toString());
|
map.put("method_name", cpm.getMethodName());
|
map.put("method_img", cpm.getMethodImg());
|
map.put("method_img_path", Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + cpm.getMethodImg());
|
map.put("advert_id", "");
|
map.put("advert_price", 0D);
|
retMap.put(cpm.getId().toString(), map);
|
methodConfigIdSet.add(cpm.getMethodConfigId());
|
}
|
}
|
|
// 支付方式模板 对应的最低最高价格
|
Map<String, String> advertIdMap = new HashMap<String, String>();
|
Map<String, Double> minPriceMap = new HashMap<String, Double>();
|
Map<String, Double> maxPriceMap = new HashMap<String, Double>();
|
|
Map<String, Double> mapPrice = (Map<String, Double>) this.redisHandler.get(RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + currency + symbol + direction);
|
if (null == mapPrice || 0 == mapPrice.size()) {
|
return retMap;
|
} else {
|
for (String id : mapPrice.keySet()) {
|
C2cAdvert advert = this.get(id);
|
|
if (0 == advert.getOnSale()) {
|
continue;
|
}
|
|
if (1 == advert.getClosed()) {
|
continue;
|
}
|
|
if (C2cOrder.ORDER_TYPE_BY_AMOUNT.equals(order_type)) {
|
// 按支付金额支付
|
if (amount < advert.getInvestmentMin() || amount > advert.getInvestmentMax() || advert.getCoinAmount() < Arith.div(amount, advert.getSymbolValue())) {
|
continue;
|
}
|
} else {
|
// 按币种数量支付
|
double amount1 = Arith.mul(coinAmount, advert.getSymbolValue());
|
if (amount1 < advert.getInvestmentMin() || amount1 > advert.getInvestmentMax() || advert.getCoinAmount() < coinAmount) {
|
continue;
|
}
|
}
|
|
String payType = advert.getPayType();
|
if (StringUtils.isEmptyString(payType)) {
|
continue;
|
}
|
String[] payTypeArr = payType.split(",");
|
for (int i = 0; i < payTypeArr.length; i++) {
|
String mci = payTypeArr[i];
|
if (methodConfigIdSet.contains(mci)) {
|
|
if (C2cAdvert.DIRECTION_BUY.equals(direction)) {
|
// 买币
|
Double nowMin = minPriceMap.get(mci);
|
if (null == nowMin) {
|
minPriceMap.put(mci, advert.getSymbolValue());
|
advertIdMap.put(mci, advert.getId().toString());
|
} else {
|
if (nowMin.doubleValue() > advert.getSymbolValue()) {
|
minPriceMap.put(mci, advert.getSymbolValue());
|
advertIdMap.put(mci, advert.getId().toString());
|
}
|
}
|
} else if (C2cAdvert.DIRECTION_SELL.equals(direction)) {
|
// 卖币
|
Double nowMax = maxPriceMap.get(mci);
|
if (null == nowMax) {
|
maxPriceMap.put(mci, advert.getSymbolValue());
|
advertIdMap.put(mci, advert.getId().toString());
|
} else {
|
if (nowMax.doubleValue() < advert.getSymbolValue()) {
|
maxPriceMap.put(mci, advert.getSymbolValue());
|
advertIdMap.put(mci, advert.getId().toString());
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
for (int i = 0; i < cpmList.size(); i++) {
|
C2cPaymentMethod cpm = cpmList.get(i);
|
if (null != cpm) {
|
|
Map<String, Object> map = retMap.get(cpm.getId().toString());
|
|
if (C2cAdvert.DIRECTION_BUY.equals(direction)) {
|
// 买币
|
Double minPrice = minPriceMap.get(cpm.getMethodConfigId());
|
if (null != minPrice) {
|
map.put("advert_id", advertIdMap.get(cpm.getMethodConfigId()));
|
map.put("advert_price", minPrice);
|
}
|
} else if (C2cAdvert.DIRECTION_SELL.equals(direction)) {
|
// 卖币
|
Double maxPrice = maxPriceMap.get(cpm.getMethodConfigId());
|
if (null != maxPrice) {
|
map.put("advert_id", advertIdMap.get(cpm.getMethodConfigId()));
|
map.put("advert_price", maxPrice);
|
}
|
}
|
|
retMap.put(cpm.getId().toString(), map);
|
}
|
}
|
|
Map<String, Map<String, Object>> resMap = new HashMap<String, Map<String, Object>>();
|
for (String id : retMap.keySet()) {
|
Map<String, Object> map = retMap.get(id);
|
if (null != map && null != map.get("advert_id") && null != map.get("advert_price")
|
&& StringUtils.isNotEmpty(map.get("advert_id").toString()) && 0 != ((Double) map.get("advert_price")).doubleValue()) {
|
resMap.put(id, map);
|
}
|
}
|
|
return resMap;
|
}
|
|
public C2cAdvert get(String id) {
|
return (C2cAdvert) this.redisHandler.get(RedisKeys.C2C_ADVERT_ID + id);
|
}
|
|
public List<C2cAdvert> getByC2cUserId(String c2c_user_id) {
|
Map<String, C2cAdvert> map = (Map<String, C2cAdvert>) this.redisHandler.get(RedisKeys.C2C_ADVERT_C2C_USER_ID + c2c_user_id);
|
if (null == map || map.isEmpty()) {
|
return new ArrayList<C2cAdvert>();
|
} else {
|
List<C2cAdvert> list = new ArrayList<C2cAdvert>();
|
for (C2cAdvert advert : map.values()) {
|
if (null != advert) {
|
list.add(advert);
|
}
|
}
|
return list;
|
}
|
}
|
|
public void save(C2cAdvert entity) {
|
if (null == entity) {
|
return;
|
}
|
|
String insertSql = "INSERT INTO T_C2C_ADVERT(UUID,C2C_USER_ID,DIRECTION,CURRENCY,SYMBOL,SYMBOL_CLOSE,PAY_RATE,PAY_TYPE,SYMBOL_VALUE,COIN_AMOUNT,INVESTMENT_MIN,INVESTMENT_MAX,DEPOSIT,DEPOSIT_OPEN,ON_SALE,CLOSED,SORT_INDEX,EXPIRE_TIME,TRANSACTION_TERMS,ORDER_MSG,REMARK,CREATE_TIME,UPDATE_TIME) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
jdbcTemplate.update(
|
insertSql,entity.getId(),entity.getC2cUserId(),entity.getDirection(),
|
entity.getCurrency(),entity.getSymbol(),entity.getSymbolClose(),entity.getPayRate(),
|
entity.getPayType(),entity.getSymbolValue(),entity.getCoinAmount(),entity.getInvestmentMin(),
|
entity.getInvestmentMax(),entity.getDeposit(),entity.getDepositOpen(),entity.getOnSale(),
|
entity.getClosed(),entity.getSortIndex(),entity.getExpireTime(),entity.getTransactionTerms(),
|
entity.getOrderMsg(),entity.getRemark(),entity.getCreateTime(),entity.getUpdateTime());
|
|
this.redisHandler.setSync(RedisKeys.C2C_ADVERT_ID + entity.getId().toString(), entity);
|
|
// 承兑商的广告
|
Map<String, C2cAdvert> map = (Map<String, C2cAdvert>) this.redisHandler.get(RedisKeys.C2C_ADVERT_C2C_USER_ID + entity.getC2cUserId());
|
if (null == map) {
|
map = new ConcurrentHashMap<String, C2cAdvert>();
|
}
|
map.put(entity.getId().toString(), entity);
|
this.redisHandler.setSync(RedisKeys.C2C_ADVERT_C2C_USER_ID + entity.getC2cUserId(), map);
|
|
// 广告上架币种单价
|
Map<String, Double> mapPrice = (Map<String, Double>) this.redisHandler.get(
|
RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + entity.getCurrency() + entity.getSymbol() + entity.getDirection());
|
if (null == mapPrice) {
|
mapPrice = new ConcurrentHashMap<String, Double>();
|
}
|
mapPrice.put(entity.getId().toString(), entity.getSymbolValue());
|
this.redisHandler.setSync(RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + entity.getCurrency() + entity.getSymbol() + entity.getDirection(), mapPrice);
|
}
|
|
public void update(C2cAdvert entity) {
|
if (null == entity) {
|
return;
|
}
|
C2cAdvert oldEntity = (C2cAdvert) this.redisHandler.get(RedisKeys.C2C_ADVERT_ID + entity.getId().toString());
|
|
String updateSql = "UPDATE T_C2C_ADVERT SET C2C_USER_ID=?, DIRECTION=?, CURRENCY=?, SYMBOL=?, SYMBOL_CLOSE=?, PAY_RATE=?, PAY_TYPE=?, SYMBOL_VALUE=?, COIN_AMOUNT=?, INVESTMENT_MIN=?, INVESTMENT_MAX=?, DEPOSIT=?, DEPOSIT_OPEN=?, ON_SALE=?, CLOSED=?, SORT_INDEX=?, EXPIRE_TIME=?, TRANSACTION_TERMS=?, ORDER_MSG=?, REMARK=?, UPDATE_TIME=? WHERE UUID=?";
|
jdbcTemplate.update(updateSql, entity.getC2cUserId(), entity.getDirection(), entity.getCurrency(), entity.getSymbol(), entity.getSymbolClose(), entity.getPayRate(), entity.getPayType(),
|
entity.getSymbolValue(), entity.getCoinAmount(), entity.getInvestmentMin(), entity.getInvestmentMax(), entity.getDeposit(), entity.getDepositOpen(), entity.getOnSale(), entity.getClosed(), entity.getSortIndex(), entity.getExpireTime(), entity.getTransactionTerms(),
|
entity.getOrderMsg(), entity.getRemark(), entity.getUpdateTime(), entity.getId());
|
|
this.redisHandler.setSync(RedisKeys.C2C_ADVERT_ID + entity.getId().toString(), entity);
|
|
// 承兑商的广告
|
Map<String, C2cAdvert> map = (Map<String, C2cAdvert>) this.redisHandler.get(RedisKeys.C2C_ADVERT_C2C_USER_ID + entity.getC2cUserId());
|
if (null == map) {
|
map = new ConcurrentHashMap<String, C2cAdvert>();
|
}
|
map.put(entity.getId().toString(), entity);
|
this.redisHandler.setSync(RedisKeys.C2C_ADVERT_C2C_USER_ID + entity.getC2cUserId(), map);
|
|
// 广告上架币种单价
|
if (null != oldEntity && (!oldEntity.getCurrency().equals(entity.getCurrency())
|
|| !oldEntity.getSymbol().equals(entity.getSymbol())
|
|| !oldEntity.getDirection().equals(entity.getDirection()))) {
|
// 删除之前的
|
Map<String, Double> mapPriceOld = (Map<String, Double>) this.redisHandler.get(
|
RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + oldEntity.getCurrency() + oldEntity.getSymbol() + oldEntity.getDirection());
|
if (null != mapPriceOld) {
|
this.redisHandler.remove(RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + oldEntity.getCurrency() + oldEntity.getSymbol() + oldEntity.getDirection());
|
}
|
}
|
Map<String, Double> mapPrice = (Map<String, Double>) this.redisHandler.get(
|
RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + entity.getCurrency() + entity.getSymbol() + entity.getDirection());
|
if (null == mapPrice) {
|
mapPrice = new ConcurrentHashMap<String, Double>();
|
}
|
mapPrice.put(entity.getId().toString(), entity.getSymbolValue());
|
this.redisHandler.setSync(RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + entity.getCurrency() + entity.getSymbol() + entity.getDirection(), mapPrice);
|
}
|
|
public void delete(String id) {
|
C2cAdvert entity = this.get(id);
|
if (entity != null) {
|
|
C2cAdvert oldEntity = (C2cAdvert) this.redisHandler.get(RedisKeys.C2C_ADVERT_ID + entity.getId().toString());
|
|
jdbcTemplate.update("DELETE FROM T_C2C_ADVERT WHERE UUID=?", entity.getId());
|
|
this.redisHandler.remove(RedisKeys.C2C_ADVERT_ID + entity.getId().toString());
|
|
Map<String, C2cAdvert> map = (Map<String, C2cAdvert>) this.redisHandler.get(RedisKeys.C2C_ADVERT_C2C_USER_ID + entity.getC2cUserId());
|
if (map != null && !map.isEmpty()) {
|
map.remove(id);
|
} else {
|
map = new ConcurrentHashMap<String, C2cAdvert>();
|
}
|
this.redisHandler.setSync(RedisKeys.C2C_ADVERT_C2C_USER_ID + entity.getC2cUserId(), map);
|
|
Map<String, Double> mapPriceOld = (Map<String, Double>) this.redisHandler.get(
|
RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + oldEntity.getCurrency() + oldEntity.getSymbol() + oldEntity.getDirection());
|
if (null != mapPriceOld) {
|
this.redisHandler.remove(RedisKeys.C2C_ADVERT_CURRENCY_SYMBOL_DIRECTION + oldEntity.getCurrency() + oldEntity.getSymbol() + oldEntity.getDirection());
|
}
|
}
|
}
|
|
public C2cAdvert findById(String id) {
|
List<C2cAdvert> list = jdbcTemplate.query("SELECT * FROM T_C2C_ADVERT WHERE UUID=?", RecordObjectMapper.newInstance(C2cAdvert.class), id);
|
if (null != list && list.size() > 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
|
/**
|
* 获取 支付币种Map
|
*/
|
public Map<String, String> getCurrencyMap() {
|
|
// 获取 C2C支付币种配置
|
Map<String, String> curMap = this.getC2cSyspara("c2c_advert_currency");
|
if (null == curMap) {
|
curMap = new HashMap<String, String>();
|
}
|
|
Map<String, String> currencyMap = new HashMap<String, String>();
|
|
List<ExchangeRate> exchangeRateList = this.exchangeRateService.findBy(Constants.OUT_OR_IN_DEFAULT);
|
for (ExchangeRate er : exchangeRateList) {
|
if (curMap.keySet().contains(er.getCurrency())) {
|
currencyMap.put(er.getCurrency(), String.format("%s(%s)", er.getCurrency(), er.getName()));
|
}
|
}
|
return currencyMap;
|
}
|
|
/**
|
* 获取 上架币种Map
|
*/
|
public Map<String, String> getSymbolMap() {
|
|
// 获取 C2C上架币种配置
|
Map<String, String> symMap = this.getC2cSyspara("c2c_advert_symbol");
|
if (null == symMap) {
|
symMap = new HashMap<String, String>();
|
}
|
|
Map<String, String> symbolMap = new HashMap<String, String>();
|
|
List<Item> itemList = this.itemService.cacheGetAll();
|
if (symMap.keySet().contains("USDT")) {
|
symbolMap.put("usdt", "USDT");
|
}
|
for (Item item : itemList) {
|
if (symMap.keySet().contains(item.getSymbol().toUpperCase())) {
|
symbolMap.put(item.getSymbol(), item.getSymbol().toUpperCase());
|
}
|
}
|
return symbolMap;
|
}
|
|
/**
|
* 计算广告参数
|
*/
|
public Map<String, Object> getComputeValue(double deposit_total, String currency, String symbol, double coin_amount, double symbol_value) {
|
|
Map<String, Object> result = new HashMap<String, Object>();
|
|
double symbol_close = 0d;
|
|
if (symbol.equals("usdt")) {
|
symbol_close = 1;
|
} else {
|
List<Realtime> list = this.dataService.realtime(symbol);
|
if (0 == list.size()) {
|
// throw new BusinessException(symbol.toUpperCase() + "行情获取异常，请重试");
|
throw new BusinessException("行情获取异常，请重试");
|
}
|
Realtime realtime = list.get(0);
|
symbol_close = realtime.getClose();
|
}
|
|
if (0 == symbol_close) {
|
// throw new BusinessException(symbol.toUpperCase() + "行情获取异常，请重试");
|
throw new BusinessException("行情获取异常，请重试");
|
}
|
|
ExchangeRate ex = this.exchangeRateService.findBy(Constants.OUT_OR_IN_DEFAULT, currency);
|
|
// 支付比率=支付币种汇率*上架币种实时行情价/币种单价；例如，支付比率95%，1USDT=7.3CNY*1*95%=6.935CNY
|
double payRate = Arith.mul(Arith.div(Arith.mul(ex.getRata(), symbol_close), symbol_value), 100);
|
|
// 广告保证金=交易币种数量*上架币种实时行情价
|
double depositOpen = Arith.mul(coin_amount, symbol_close);
|
|
// 支付币种市价=支付币种汇率*上架币种实时行情价；
|
double price = Arith.mul(ex.getRata(), symbol_close);
|
|
// 交易币种数量=广告派单额度/上架币种实时行情价
|
double coinAmountMax = Arith.div(deposit_total, symbol_close);
|
|
// 最小支付金额
|
double investmentMinLimit = 0;
|
|
// C2C承兑商广告：单笔订单最低限额不能低于（支付币种金额折算成USDT）
|
Object obj = this.sysparaService.find("c2c_user_advert_investment_min_limit");
|
if (null != obj) {
|
String c2c_user_advert_investment_min_limit = this.sysparaService.find("c2c_user_advert_investment_min_limit").getValue();
|
if (!StringUtils.isEmptyString(c2c_user_advert_investment_min_limit)) {
|
double limit_usdt = Double.valueOf(c2c_user_advert_investment_min_limit).doubleValue();
|
investmentMinLimit = Arith.mul(Arith.div(limit_usdt, symbol_close), symbol_value);
|
}
|
}
|
|
// 最大支付金额
|
double investmentMaxLimit = Arith.mul(coinAmountMax, symbol_value);
|
|
DecimalFormat df = new DecimalFormat("#.########");
|
|
result.put("pay_rate", (int) payRate);
|
result.put("deposit_open", df.format(new Double(depositOpen)));
|
result.put("all_deposit", df.format(Arith.sub(deposit_total, depositOpen)));
|
result.put("symbol_close", df.format(new Double(symbol_close)));
|
result.put("price", df.format(new Double(price)));
|
result.put("coin_amount_max", df.format(new Double(coinAmountMax)));
|
result.put("investment_min_limit", df.format(new Double(investmentMinLimit)));
|
result.put("investment_max_limit", df.format(new Double(investmentMaxLimit)));
|
return result;
|
}
|
|
/**
|
* 获取所有上架币种单价
|
*/
|
public Map<String, String> getAllSymbolPrice(String currency) {
|
|
DecimalFormat df = new DecimalFormat("#.##");
|
|
Map<String, String> allPrice = new HashMap<String, String>();
|
|
ExchangeRate ex = this.exchangeRateService.findBy(Constants.OUT_OR_IN_DEFAULT, currency);
|
|
Map<String, String> allSymbol = this.getC2cSyspara("c2c_advert_symbol");
|
if (null == allSymbol || 0 == allSymbol.size()) {
|
return new HashMap<String, String>();
|
}
|
|
for (String symbol : allSymbol.keySet()) {
|
symbol = symbol.toLowerCase();
|
double symbol_close = 0d;
|
|
if (symbol.equals("usdt")) {
|
symbol_close = 1;
|
} else {
|
List<Realtime> list = this.dataService.realtime(symbol);
|
if (0 == list.size()) {
|
continue;
|
}
|
Realtime realtime = list.get(0);
|
symbol_close = realtime.getClose();
|
}
|
if (0 == symbol_close) {
|
continue;
|
}
|
|
// 支付币种市价=支付币种汇率*上架币种实时行情价；
|
double price = Arith.mul(ex.getRata(), symbol_close);
|
allPrice.put(symbol, df.format(new Double(price)));
|
}
|
|
return allPrice;
|
}
|
|
/*
|
* 获取 C2C支付方式类型、C2C支付币种配置、C2C上架币种配置、C2C广告支付时效
|
*/
|
public Map<String, String> getC2cSyspara(String syspara) {
|
|
if ("c2c_payment_method_type".equals(syspara)) {
|
|
// C2C支付方式类型
|
Map<String, String> pmtMap = new HashMap<String, String>();
|
Object obj = this.sysparaService.find("c2c_payment_method_type");
|
if (null != obj) {
|
String pmtStr = this.sysparaService.find("c2c_payment_method_type").getValue().toString();
|
String[] pmtArray = pmtStr.split("&&");
|
for (int i = 0; i < pmtArray.length; i++) {
|
String[] pmt = pmtArray[i].split("##");
|
pmtMap.put(pmt[0], pmt[1]);
|
}
|
return pmtMap;
|
}
|
} else if ("c2c_advert_currency".equals(syspara)) {
|
|
// C2C支付币种配置
|
Map<String, String> acMap = new HashMap<String, String>();
|
Object obj = this.sysparaService.find("c2c_advert_currency");
|
if (null != obj) {
|
String acStr = this.sysparaService.find("c2c_advert_currency").getValue().toString();
|
String[] acArray = acStr.split("&&");
|
for (int i = 0; i < acArray.length; i++) {
|
String[] ac = acArray[i].split("##");
|
acMap.put(ac[0], ac[1]);
|
}
|
return acMap;
|
}
|
} else if ("c2c_advert_symbol".equals(syspara)) {
|
|
// C2C上架币种配置
|
Map<String, String> asMap = new HashMap<String, String>();
|
Object obj = this.sysparaService.find("c2c_advert_symbol");
|
if (null != obj) {
|
String asStr = this.sysparaService.find("c2c_advert_symbol").getValue().toString();
|
String[] asArray = asStr.split("##");
|
for (int i = 0; i < asArray.length; i++) {
|
asMap.put(asArray[i], asArray[i]);
|
}
|
return asMap;
|
}
|
} else if ("c2c_advert_expire_time".equals(syspara)) {
|
|
// C2C广告支付时效
|
Map<String, String> aetMap = new HashMap<String, String>();
|
Object obj = this.sysparaService.find("c2c_advert_expire_time");
|
if (null != obj) {
|
String aetStr = this.sysparaService.find("c2c_advert_expire_time").getValue().toString();
|
String[] aetArray = aetStr.split("&&");
|
for (int i = 0; i < aetArray.length; i++) {
|
String[] aet = aetArray[i].split("##");
|
aetMap.put(aet[0], aet[1]);
|
}
|
return aetMap;
|
}
|
}
|
|
return new HashMap<String, String>();
|
}
|
|
/*
|
* 获取 语种说明
|
*/
|
public String getLanguageIntro() {
|
Map<String, String> langMap = Constants.LANGUAGE;
|
String retStr = "";
|
for (String lang : langMap.keySet()) {
|
String langName = langMap.get(lang);
|
if (StringUtils.isEmptyString(retStr)) {
|
retStr = lang + " " + langName;
|
} else {
|
retStr += "; " + lang + " " + langName;
|
}
|
}
|
return retStr + ";";
|
}
|
|
/*
|
* 获取 支付方式类型说明
|
*/
|
public String getMethodTypeIntro() {
|
Map<String, String> pmtMap = this.getC2cSyspara("c2c_payment_method_type");
|
String retStr = "";
|
for (String pmt : pmtMap.keySet()) {
|
String pmtName = pmtMap.get(pmt);
|
if (StringUtils.isEmptyString(retStr)) {
|
retStr = pmt + " " + pmtName;
|
} else {
|
retStr += "; " + pmt + " " + pmtName;
|
}
|
}
|
return retStr + ";";
|
}
|
|
public void setPagedDao(PagedQueryDao pagedDao) {
|
this.pagedDao = pagedDao;
|
}
|
|
public void setRedisHandler(RedisHandler redisHandler) {
|
this.redisHandler = redisHandler;
|
}
|
|
public void setExchangeRateService(ExchangeRateService exchangeRateService) {
|
this.exchangeRateService = exchangeRateService;
|
}
|
|
public void setItemService(ItemService itemService) {
|
this.itemService = itemService;
|
}
|
|
public void setDataService(DataService dataService) {
|
this.dataService = dataService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
}
|
