package com.yami.trading.service.c2c.impl;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.yami.trading.bean.c2c.C2cAdvert;
|
import com.yami.trading.bean.data.domain.Realtime;
|
import com.yami.trading.bean.item.domain.Item;
|
import com.yami.trading.bean.model.C2cTranslate;
|
import com.yami.trading.bean.rate.domain.ExchangeRate;
|
import com.yami.trading.common.constants.Constants;
|
import com.yami.trading.common.exception.YamiShopBindException;
|
import com.yami.trading.common.util.Arith;
|
import com.yami.trading.common.util.StringUtils;
|
import com.yami.trading.dao.c2c.C2cAdvertMapper;
|
import com.yami.trading.service.c2c.C2cAdvertService;
|
import com.yami.trading.service.data.DataService;
|
import com.yami.trading.service.item.ItemService;
|
import com.yami.trading.service.rate.ExchangeRateService;
|
import com.yami.trading.service.syspara.SysparaService;
|
import org.apache.ibatis.annotations.Param;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Service;
|
|
import java.text.DecimalFormat;
|
import java.util.*;
|
|
@Service
|
public class C2cAdvertServiceImpl extends ServiceImpl<C2cAdvertMapper, C2cAdvert> implements C2cAdvertService {
|
@Autowired
|
SysparaService sysparaService;
|
|
@Autowired
|
RedisTemplate redisTemplate;
|
|
@Autowired
|
ExchangeRateService exchangeRateService;
|
|
@Autowired
|
ItemService itemService;
|
|
@Autowired
|
DataService dataService;
|
|
/**
|
* 获取 上架币种Map
|
*/
|
@Override
|
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 List<C2cAdvert> getByC2cUserId(String c2c_user_id) {
|
|
return list(Wrappers.<C2cAdvert>query().lambda().eq(C2cAdvert::getC2cUserId, c2c_user_id));
|
}
|
|
|
|
|
@Override
|
public Page pagedQuery(long pageNo, long pageSize, String c2cUserCode, String c2cUserType,String userCode, String direction,String currency,String symbol){
|
Page page=new Page(pageNo,pageSize);
|
return baseMapper.pagedQuery(page,c2cUserCode,c2cUserType,userCode,direction,currency,symbol);
|
}
|
|
/**
|
* 计算广告参数
|
*/
|
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 YamiShopBindException("行情获取异常，请重试");
|
}
|
Realtime realtime = list.get(0);
|
symbol_close = realtime.getClose().doubleValue();
|
}
|
if (0 == symbol_close) {
|
// throw new BusinessException(symbol.toUpperCase() + "行情获取异常，请重试");
|
throw new YamiShopBindException("行情获取异常，请重试");
|
}
|
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().doubleValue(), symbol_close), symbol_value), 100);
|
// 广告保证金=交易币种数量*上架币种实时行情价
|
double depositOpen = Arith.mul(coin_amount, symbol_close);
|
// 支付币种市价=支付币种汇率*上架币种实时行情价；
|
double price = Arith.mul(ex.getRata().doubleValue(), 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").getSvalue();
|
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;
|
}
|
|
@Override
|
public Page pagedQuery(int page_no, int page_size, String c2c_user_id, String direction, String currency, String symbol, String amount, Integer on_sale, Integer closed, boolean is_c2c_user) {
|
Page page=new Page(page_no,page_size);
|
double amount_double=0;
|
if (StringUtils.isNotEmpty(amount)){
|
amount_double= Double.valueOf(amount).doubleValue();
|
}
|
|
|
if (is_c2c_user) {
|
|
baseMapper.pagedQueryC2cUser(page,c2c_user_id,direction,currency,symbol,
|
amount_double,on_sale,closed);
|
} else {
|
baseMapper.pagedQueryNotC2cUser(page,c2c_user_id,direction,currency,symbol,
|
amount_double,on_sale,closed);
|
}
|
DecimalFormat df = new DecimalFormat("#.##");
|
// 币种默认保留8位
|
DecimalFormat dfCoin = new DecimalFormat("#.########");
|
|
for (Map<String, Object> data : (List<Map<String, Object>>) page.getRecords()) {
|
data.put("symbol_value", df.format(data.get("symbol_value")));
|
data.put("coin_amount", dfCoin.format(data.get("coin_amount")));
|
}
|
return page;
|
}
|
|
@Override
|
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;
|
}
|
|
/*
|
* 获取 C2C支付方式类型、C2C支付币种配置、C2C上架币种配置、C2C广告支付时效
|
*/
|
|
@Override
|
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").getSvalue().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").getSvalue().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").getSvalue().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").getSvalue().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 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().doubleValue();
|
}
|
if (0 == symbol_close) {
|
continue;
|
}
|
|
// 支付币种市价=支付币种汇率*上架币种实时行情价；
|
double price = Arith.mul(ex.getRata().doubleValue(), symbol_close);
|
allPrice.put(symbol, df.format(new Double(price)));
|
}
|
|
return allPrice;
|
}
|
|
/*
|
* 获取 语种说明
|
*/
|
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 + ";";
|
}
|
|
}
|
