package project.c2c.internal;
|
|
import java.text.DecimalFormat;
|
import java.text.MessageFormat;
|
import java.util.Arrays;
|
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.apache.commons.lang3.ObjectUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import email.EmailSendService;
|
import kernel.bo.RecordObjectMapper;
|
import kernel.exception.BusinessException;
|
import kernel.util.Arith;
|
import kernel.util.DateUtils;
|
import kernel.util.StringUtils;
|
import kernel.util.ThreadUtils;
|
import kernel.web.ApplicationUtil;
|
import kernel.web.Page;
|
import kernel.web.PagedQueryDao;
|
import project.Constants;
|
import project.RedisKeys;
|
import project.c2c.C2cAdvert;
|
import project.c2c.C2cAdvertLock;
|
import project.c2c.C2cAdvertService;
|
import project.c2c.C2cLock;
|
import project.c2c.C2cOrder;
|
import project.c2c.C2cOrderService;
|
import project.c2c.C2cPaymentMethod;
|
import project.c2c.C2cPaymentMethodService;
|
import project.c2c.C2cUser;
|
import project.c2c.C2cUserService;
|
import project.data.DataService;
|
import project.log.MoneyLog;
|
import project.log.MoneyLogService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.redis.RedisHandler;
|
import project.syspara.SysparaService;
|
import project.tip.TipConstants;
|
import project.tip.TipService;
|
import project.user.UserDataService;
|
import project.user.kyc.Kyc;
|
import project.user.kyc.KycHighLevel;
|
import project.user.kyc.KycHighLevelService;
|
import project.user.kyc.KycService;
|
import project.wallet.Wallet;
|
import project.wallet.WalletExtend;
|
import project.wallet.WalletService;
|
import project.wallet.rate.ExchangeRateService;
|
import smsbao.SmsSendService;
|
|
public class C2cOrderServiceImpl implements C2cOrderService {
|
private static final Logger logger=LoggerFactory.getLogger(C2cOrderServiceImpl.class);
|
private PagedQueryDao pagedDao;
|
private RedisHandler redisHandler;
|
private JdbcTemplate jdbcTemplate;
|
private C2cAdvertService c2cAdvertService;
|
private C2cUserService c2cUserService;
|
private DataService dataService;
|
private ExchangeRateService exchangeRateService;
|
private WalletService walletService;
|
private MoneyLogService moneyLogService;
|
private C2cPaymentMethodService c2cPaymentMethodService;
|
private UserDataService userDataService;
|
private TipService tipService;
|
private SysparaService sysparaService;
|
private KycService kycService;
|
private KycHighLevelService kycHighLevelService;
|
private PartyService partyService;
|
private SmsSendService smsSendService;
|
private EmailSendService emailSendService;
|
|
public C2cOrder get(String order_no) {
|
C2cOrder order = (C2cOrder) this.redisHandler.get(RedisKeys.C2C_ORDER_NO + order_no);
|
if (null != order) {
|
return order;
|
} else {
|
List<C2cOrder> list = jdbcTemplate.query("SELECT * FROM T_C2C_ORDER WHERE ORDER_NO=?", RecordObjectMapper.newInstance(C2cOrder.class), order_no);
|
if (list.size() > 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
}
|
|
public List<C2cOrder> getByPayId(String payId) {
|
return jdbcTemplate.query("SELECT * FROM T_C2C_ORDER WHERE PAYMENT_METHOD_ID=? and STATE IN('0','1')", RecordObjectMapper.newInstance(C2cOrder.class), payId);
|
}
|
|
|
public void save(C2cOrder entity) {
|
String insertSql = "INSERT INTO T_C2C_ORDER(UUID,PARTY_ID,C2C_USER_ID,C2C_ADVERT_ID,PAYMENT_METHOD_ID,ORDER_TYPE,ORDER_NO,STATE,C2C_USER_TYPE,C2C_USER_CODE,"
|
+ "C2C_USER_NICK_NAME,C2C_USER_HEAD_IMG,C2C_USER_PARTY_ID,C2C_USER_PARTY_CODE,C2C_USER_PARTY_NAME,DIRECTION,CURRENCY,SYMBOL,PAY_RATE,SYMBOL_VALUE,COIN_AMOUNT,"
|
+ "EXPIRE_TIME,AMOUNT,AMOUNT_USDT,METHOD_TYPE,METHOD_NAME,METHOD_IMG,REAL_NAME,PARAM_NAME1,PARAM_VALUE1,PARAM_NAME2,PARAM_VALUE2,PARAM_NAME3,PARAM_VALUE3,PARAM_NAME4,"
|
+ "PARAM_VALUE4,PARAM_NAME5,PARAM_VALUE5,PARAM_NAME6,PARAM_VALUE6,PARAM_NAME7,PARAM_VALUE7,PARAM_NAME8,PARAM_VALUE8,PARAM_NAME9,PARAM_VALUE9,PARAM_NAME10,PARAM_VALUE10,"
|
+ "PARAM_NAME11,PARAM_VALUE11,PARAM_NAME12,PARAM_VALUE12,PARAM_NAME13,PARAM_VALUE13,PARAM_NAME14,PARAM_VALUE14,PARAM_NAME15,PARAM_VALUE15,QRCODE,REMARK,CREATE_TIME,HANDLE_TIME,CLOSE_TIME,PAY_TIME,CANCEL_TIME) "
|
+ "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
|
jdbcTemplate.update(insertSql,entity.getId(),entity.getPartyId(),entity.getC2cUserId(),entity.getC2cAdvertId(),entity.getPaymentMethodId(),
|
entity.getOrderType(),entity.getOrderNo(),entity.getState(),entity.getC2cUserType(),entity.getC2cUserCode(),
|
entity.getC2cUserNickName(),entity.getC2cUserHeadImg(),entity.getC2cUserPartyId(),entity.getC2cUserPartyCode(),entity.getC2cUserPartyName(),entity.getDirection(),
|
entity.getCurrency(),entity.getSymbol(),entity.getPayRate(),entity.getSymbolValue(),entity.getCoinAmount(),
|
entity.getExpireTime(),entity.getAmount(),entity.getAmountUsdt(),entity.getMethodType(),entity.getMethodName(),entity.getMethodImg(),entity.getRealName(),
|
entity.getParamName1(),entity.getParamValue1(),entity.getParamName2(),entity.getParamValue2(),entity.getParamName3(),entity.getParamValue3(),
|
entity.getParamName4(),entity.getParamValue4(),entity.getParamName5(),entity.getParamValue5(),entity.getParamName6(),entity.getParamValue6(),
|
entity.getParamName7(),entity.getParamValue7(),entity.getParamName8(),entity.getParamValue8(),entity.getParamName9(),entity.getParamValue9(),
|
entity.getParamName10(),entity.getParamValue10(),entity.getParamName11(),entity.getParamValue11(),entity.getParamName12(),entity.getParamValue12(),
|
entity.getParamName13(),entity.getParamValue13(),entity.getParamName14(),entity.getParamValue14(),entity.getParamName15(),entity.getParamValue15(),
|
entity.getQrcode(),entity.getRemark(),entity.getCreateTime(),entity.getHandleTime(),entity.getCloseTime(),entity.getPayTime(),entity.getCancelTime());
|
|
this.redisHandler.setSync(RedisKeys.C2C_ORDER_NO + entity.getOrderNo(), entity);
|
|
// 订单自动取消时间和确认收款超时时间（0未付款/1已付款）
|
Map<String, Long> map = (Map<String, Long>) this.redisHandler.get(RedisKeys.C2C_ORDER_NO_EXPIRE_TIME);
|
if (null == map) {
|
map = new ConcurrentHashMap<String, Long>();
|
}
|
map.put(entity.getOrderNo() + "_auto_cancel", entity.getCreateTime().getTime() + entity.getExpireTime() * 60 * 1000);
|
map.put(entity.getOrderNo() + "_expire", entity.getCreateTime().getTime() + entity.getExpireTime() * 60 * 1000 * 2);
|
this.redisHandler.setSync(RedisKeys.C2C_ORDER_NO_EXPIRE_TIME, map);
|
|
// 用户未结束订单数量（0未付款/1已付款/2申诉中/5已超时）
|
Map<String, Long> ocMap = (Map<String, Long>) this.redisHandler.get(RedisKeys.C2C_NOFINISH_ORDER_COUNT);
|
if (null == ocMap) {
|
ocMap = new ConcurrentHashMap<String, Long>();
|
}
|
Long count = ocMap.get(entity.getPartyId());
|
if (null == count) {
|
ocMap.put(entity.getPartyId(), 1L);
|
} else {
|
ocMap.put(entity.getPartyId(), count + 1);
|
}
|
this.redisHandler.setSync(RedisKeys.C2C_NOFINISH_ORDER_COUNT, ocMap);
|
}
|
|
public synchronized void update(C2cOrder entity) {
|
if (null == entity) {
|
return;
|
}
|
String updateSql="UPDATE T_C2C_ORDER SET STATE=?,DIRECTION=?,CURRENCY=?,SYMBOL=?,PAY_RATE=?,SYMBOL_VALUE=?,COIN_AMOUNT=?,EXPIRE_TIME=?,"
|
+ "AMOUNT=?,AMOUNT_USDT=?,METHOD_TYPE=?,METHOD_NAME=?,METHOD_IMG=?,REAL_NAME=?,PARAM_NAME1=?,PARAM_VALUE1=?,PARAM_NAME2=?,"
|
+ "PARAM_VALUE2=?,PARAM_NAME3=?,PARAM_VALUE3=?,PARAM_NAME4=?,PARAM_VALUE4=?,PARAM_NAME5=?,PARAM_VALUE5=?,PARAM_NAME6=?,"
|
+ "PARAM_VALUE6=?,PARAM_NAME7=?,PARAM_VALUE7=?,PARAM_NAME8=?,PARAM_VALUE8=?,PARAM_NAME9=?,PARAM_VALUE9=?,PARAM_NAME10=?,"
|
+ "PARAM_VALUE10=?,PARAM_NAME11=?,PARAM_VALUE11=?,PARAM_NAME12=?,PARAM_VALUE12=?,PARAM_NAME13=?,PARAM_VALUE13=?,PARAM_NAME14=?,"
|
+ "PARAM_VALUE14=?,PARAM_NAME15=?,PARAM_VALUE15=?,QRCODE=?,REMARK=?,HANDLE_TIME=?,CLOSE_TIME=?,PAY_TIME=?,CANCEL_TIME=? WHERE UUID=?";
|
jdbcTemplate.update(updateSql,entity.getState(),entity.getDirection(),
|
entity.getCurrency(),entity.getSymbol(),entity.getPayRate(),entity.getSymbolValue(),entity.getCoinAmount(),
|
entity.getExpireTime(),entity.getAmount(),entity.getAmountUsdt(),entity.getMethodType(),entity.getMethodName(),entity.getMethodImg(),entity.getRealName(),
|
entity.getParamName1(),entity.getParamValue1(),entity.getParamName2(),entity.getParamValue2(),entity.getParamName3(),entity.getParamValue3(),
|
entity.getParamName4(),entity.getParamValue4(),entity.getParamName5(),entity.getParamValue5(),entity.getParamName6(),entity.getParamValue6(),
|
entity.getParamName7(),entity.getParamValue7(),entity.getParamName8(),entity.getParamValue8(),entity.getParamName9(),entity.getParamValue9(),
|
entity.getParamName10(),entity.getParamValue10(),entity.getParamName11(),entity.getParamValue11(),entity.getParamName12(),entity.getParamValue12(),
|
entity.getParamName13(),entity.getParamValue13(),entity.getParamName14(),entity.getParamValue14(),entity.getParamName15(),entity.getParamValue15(),
|
entity.getQrcode(),entity.getRemark(),entity.getHandleTime(),entity.getCloseTime(),entity.getPayTime(),entity.getCancelTime(),entity.getId());
|
|
if (null != entity && Arrays.asList("0", "1").contains(entity.getState())) {
|
// 只有未付款和已付款的订单存入redis
|
this.redisHandler.setSync(RedisKeys.C2C_ORDER_NO + entity.getOrderNo(), entity);
|
} else {
|
this.redisHandler.remove(RedisKeys.C2C_ORDER_NO + entity.getOrderNo());
|
}
|
|
// 订单自动取消时间和确认收款超时时间（0未付款/1已付款）
|
Map<String, Long> map = (Map<String, Long>) this.redisHandler.get(RedisKeys.C2C_ORDER_NO_EXPIRE_TIME);
|
if (null == map) {
|
map = new ConcurrentHashMap<String, Long>();
|
}
|
if (!Arrays.asList("0", "1").contains(entity.getState())) {
|
map.remove(entity.getOrderNo() + "_auto_cancel");
|
map.remove(entity.getOrderNo() + "_expire");
|
} else {
|
if (Arrays.asList("0").contains(entity.getState())) {
|
map.put(entity.getOrderNo() + "_auto_cancel", entity.getCreateTime().getTime() + entity.getExpireTime() * 60 * 1000);
|
map.put(entity.getOrderNo() + "_expire", entity.getCreateTime().getTime() + entity.getExpireTime() * 60 * 1000 * 2);
|
} else if (Arrays.asList("1").contains(entity.getState())) {
|
map.put(entity.getOrderNo() + "_auto_cancel", entity.getCreateTime().getTime() + entity.getExpireTime() * 60 * 1000);
|
map.put(entity.getOrderNo() + "_expire", entity.getPayTime().getTime() + entity.getExpireTime() * 60 * 1000);
|
}
|
}
|
this.redisHandler.setSync(RedisKeys.C2C_ORDER_NO_EXPIRE_TIME, map);
|
}
|
|
/*
|
* 用户未结束订单数量（0未付款/1已付款/2申诉中/5已超时）减1
|
*/
|
public void updateNofinishOrderCount(C2cOrder entity) {
|
Map<String, Long> ocMap = (Map<String, Long>) this.redisHandler.get(RedisKeys.C2C_NOFINISH_ORDER_COUNT);
|
if (null == ocMap) {
|
ocMap = new ConcurrentHashMap<String, Long>();
|
}
|
Long count = ocMap.get(entity.getPartyId());
|
if (null == count) {
|
ocMap.put(entity.getPartyId(), 0L);
|
} else {
|
ocMap.put(entity.getPartyId(), count - 1 <= 0 ? 0 : count - 1);
|
}
|
this.redisHandler.setSync(RedisKeys.C2C_NOFINISH_ORDER_COUNT, ocMap);
|
}
|
|
/*
|
* 获取 用户未结束订单数量
|
*/
|
public Long getNofinishOrderCount(String partyId,String direction) {
|
List<C2cOrder> c2cOrderList = jdbcTemplate.query("SELECT * FROM T_C2C_ORDER where STATE = '0' AND PARTY_ID =? AND DIRECTION =?",
|
RecordObjectMapper.newInstance(C2cOrder.class), partyId,direction);
|
if(ObjectUtils.isNotEmpty(c2cOrderList)) {
|
return (long)c2cOrderList.size();
|
}
|
return 0l;
|
}
|
|
public Page pagedQuery(int pageNo, int pageSize, String direction, String state, String loginPartyId, boolean isC2cUser,String startTime, String endTime) {
|
|
StringBuffer queryString = new StringBuffer();
|
|
queryString.append(" SELECT ");
|
queryString.append(" ord.UUID id, ord.PARTY_ID party_id, ord.ORDER_NO order_no, ord.STATE state, ord.C2C_USER_NICK_NAME c2c_user_nick_name, ord.C2C_USER_HEAD_IMG c2c_user_head_img, ord.DIRECTION direction, ord.CURRENCY currency, ord.SYMBOL symbol, ord.PAY_RATE pay_rate, ");
|
queryString.append(" ord.SYMBOL_VALUE symbol_value, ord.COIN_AMOUNT coin_amount, ord.AMOUNT amount, DATE_FORMAT(ord.CREATE_TIME, '%Y-%m-%d %H:%i:%S') create_time ");
|
|
queryString.append(" FROM T_C2C_ORDER ord ");
|
queryString.append(" WHERE 1=1 ");
|
if (!StringUtils.isNullOrEmpty(startTime)) {
|
queryString.append("AND DATE(CREATE_TIME)>=DATE('"+startTime+" 00:00:00') ");
|
}
|
|
if (!StringUtils.isNullOrEmpty(endTime)) {
|
queryString.append("AND DATE(CREATE_TIME)<=DATE('"+endTime+" 23:59:59') ");
|
}
|
Map<String, Object> parameters = new HashMap<String, Object>();
|
|
if (StringUtils.isNotEmpty(direction)) {
|
queryString.append(" AND ord.DIRECTION = :direction ");
|
parameters.put("direction", direction);
|
}
|
|
if (StringUtils.isNotEmpty(state)) {
|
queryString.append(" AND ord.STATE = :state ");
|
parameters.put("state", Integer.valueOf(state).intValue());
|
}
|
|
if (isC2cUser) {
|
if (StringUtils.isNotEmpty(loginPartyId)) {
|
queryString.append(" AND ord.C2C_USER_PARTY_ID = :loginPartyId ");
|
parameters.put("loginPartyId", loginPartyId);
|
}
|
} else {
|
if (StringUtils.isNotEmpty(loginPartyId)) {
|
queryString.append(" AND ord.PARTY_ID = :loginPartyId ");
|
parameters.put("loginPartyId", loginPartyId);
|
}
|
}
|
|
queryString.append(" order by ord.CREATE_TIME desc ");
|
|
Page page = this.pagedDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
|
// 金额默认保留2位
|
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")));
|
data.put("symbol", data.get("symbol").toString().toUpperCase());
|
}
|
|
return page;
|
}
|
|
public List<C2cOrder> findByPartyIdAndToday(String partyId, String direction, String state) {
|
if (StringUtils.isEmptyString(state)) {
|
List<C2cOrder> list = jdbcTemplate.query("SELECT * FROM T_C2C_ORDER WHERE PARTY_ID = ? AND DIRECTION = ? and DateDiff(CREATE_TIME, NOW()) = 0 ",
|
RecordObjectMapper.newInstance(C2cOrder.class), partyId, direction);
|
return list;
|
}
|
List<C2cOrder> list = jdbcTemplate.query("SELECT * FROM T_C2C_ORDER WHERE PARTY_ID = ? AND DIRECTION = ? and DateDiff(CREATE_TIME, NOW()) = 0 AND STATE = ?",
|
RecordObjectMapper.newInstance(C2cOrder.class), partyId, direction, state);
|
return list;
|
}
|
|
public List<C2cOrder> findNoEndingSellOrders(String loginPartyId) {
|
List<C2cOrder> list = jdbcTemplate.query("SELECT * FROM T_C2C_ORDER WHERE STATE IN ('0','1','2','5') AND DIRECTION = 'sell' AND PARTY_ID = ?",
|
RecordObjectMapper.newInstance(C2cOrder.class), loginPartyId);
|
return list;
|
}
|
|
/*
|
* 查询未完结订单数量，根据广告ID
|
*/
|
public Long findNoEndingOrdersCountByAdvertId(String c2cAdvertId) {
|
List find = jdbcTemplate.queryForList(" SELECT COUNT(*) FROM T_C2C_ORDER WHERE C2C_ADVERT_ID = ? AND STATE IN ('0','1','2','5') ", String.class, c2cAdvertId);
|
return CollectionUtils.isEmpty(find) ? 0L : (null == find.get(0) ? 0L : Long.valueOf(find.get(0).toString()));
|
}
|
|
public void saveOpen(C2cOrder c2cOrder,String remark) {
|
logger.error("saveOpen start:"+remark);
|
C2cAdvert c2cAdvert = this.c2cAdvertService.findById(c2cOrder.getC2cAdvertId());
|
if (null == c2cAdvert) {
|
throw new BusinessException("广告不存在");
|
}
|
|
if (1 != c2cAdvert.getOnSale()) {
|
throw new BusinessException("广告已下架");
|
}
|
|
Party party = this.partyService.cachePartyBy(c2cOrder.getPartyId(), false);
|
if (null == party) {
|
throw new BusinessException("用户信息不存在");
|
}
|
|
C2cUser c2cUser = this.c2cUserService.get(c2cAdvert.getC2cUserId());
|
if (null == c2cUser) {
|
throw new BusinessException("承兑商不存在");
|
}
|
|
Party c2cParty = this.partyService.cachePartyBy(c2cUser.getC2cUserPartyId(), false);
|
if (null == c2cParty) {
|
throw new BusinessException("承兑商的用户信息不存在");
|
}
|
|
C2cPaymentMethod method = this.c2cPaymentMethodService.get(c2cOrder.getPaymentMethodId());
|
if (null == method) {
|
throw new BusinessException("支付方式不存在");
|
}
|
|
if (C2cAdvert.DIRECTION_SELL.equals(c2cAdvert.getDirection())) {
|
|
if (!party.getWithdraw_authority()) {
|
throw new BusinessException( "无权限");
|
}
|
|
this.checkSellAuth(c2cOrder.getPartyId());
|
this.checkSellNum(c2cOrder.getPartyId());
|
|
if (!method.getPartyId().equals(c2cOrder.getPartyId())) {
|
throw new BusinessException("支付方式不匹配该用户");
|
}
|
} else {
|
|
if (!method.getPartyId().equals(c2cUser.getC2cUserPartyId())) {
|
throw new BusinessException("支付方式不匹配该承兑商");
|
}
|
}
|
|
c2cOrder.setC2cUserType(c2cUser.getC2cUserType());
|
c2cOrder.setC2cUserCode(c2cUser.getC2cUserCode());
|
c2cOrder.setC2cUserNickName(c2cUser.getNickName());
|
c2cOrder.setC2cUserHeadImg(c2cUser.getHeadImg());
|
c2cOrder.setC2cUserPartyId(c2cUser.getC2cUserPartyId());
|
c2cOrder.setC2cUserPartyCode(c2cParty.getUsercode());
|
c2cOrder.setC2cUserPartyName(c2cParty.getUsername());
|
c2cOrder.setDirection(c2cAdvert.getDirection());
|
c2cOrder.setCurrency(c2cAdvert.getCurrency());
|
c2cOrder.setSymbol(c2cAdvert.getSymbol());
|
c2cOrder.setPayRate(c2cAdvert.getPayRate());
|
c2cOrder.setSymbolValue(c2cAdvert.getSymbolValue());
|
c2cOrder.setExpireTime(c2cAdvert.getExpireTime());
|
c2cOrder.setMethodType(method.getMethodType());
|
c2cOrder.setMethodName(method.getMethodName());
|
c2cOrder.setMethodImg(method.getMethodImg());
|
c2cOrder.setRealName(method.getRealName());
|
c2cOrder.setParamName1(method.getParamName1());
|
c2cOrder.setParamValue1(method.getParamValue1());
|
c2cOrder.setParamName2(method.getParamName2());
|
c2cOrder.setParamValue2(method.getParamValue2());
|
c2cOrder.setParamName3(method.getParamName3());
|
c2cOrder.setParamValue3(method.getParamValue3());
|
c2cOrder.setParamName4(method.getParamName4());
|
c2cOrder.setParamValue4(method.getParamValue4());
|
c2cOrder.setParamName5(method.getParamName5());
|
c2cOrder.setParamValue5(method.getParamValue5());
|
c2cOrder.setParamName6(method.getParamName6());
|
c2cOrder.setParamValue6(method.getParamValue6());
|
c2cOrder.setParamName7(method.getParamName7());
|
c2cOrder.setParamValue7(method.getParamValue7());
|
c2cOrder.setParamName8(method.getParamName8());
|
c2cOrder.setParamValue8(method.getParamValue8());
|
c2cOrder.setParamName9(method.getParamName9());
|
c2cOrder.setParamValue9(method.getParamValue9());
|
c2cOrder.setParamName10(method.getParamName10());
|
c2cOrder.setParamValue10(method.getParamValue10());
|
c2cOrder.setParamName11(method.getParamName11());
|
c2cOrder.setParamValue11(method.getParamValue11());
|
c2cOrder.setParamName12(method.getParamName12());
|
c2cOrder.setParamValue12(method.getParamValue12());
|
c2cOrder.setParamName13(method.getParamName13());
|
c2cOrder.setParamValue13(method.getParamValue13());
|
c2cOrder.setParamName14(method.getParamName14());
|
c2cOrder.setParamValue14(method.getParamValue14());
|
c2cOrder.setParamName15(method.getParamName15());
|
c2cOrder.setParamValue15(method.getParamValue15());
|
c2cOrder.setQrcode(method.getQrcode());
|
c2cOrder.setCreateTime(new Date());
|
c2cOrder.setHandleTime(null);
|
c2cOrder.setCloseTime(DateUtils.addMinute(c2cOrder.getCreateTime(), c2cOrder.getExpireTime()));
|
c2cOrder.setPayTime(null);
|
c2cOrder.setCancelTime(null);
|
|
// 币种单价
|
double symbolValue = c2cAdvert.getSymbolValue();
|
if (C2cAdvert.DIRECTION_BUY.equals(c2cAdvert.getDirection())) {
|
// 买币
|
this.saveBuy(c2cOrder, c2cAdvert, symbolValue,remark);
|
} else if (C2cAdvert.DIRECTION_SELL.equals(c2cAdvert.getDirection())) {
|
// 卖币
|
this.saveSell(c2cOrder, c2cAdvert, symbolValue,remark);
|
} else {
|
throw new BusinessException("买卖方式不正确");
|
}
|
|
this.tipService.saveNewTip(c2cOrder.getId().toString(), TipConstants.C2C_ORDER,remark);
|
this.c2cSendMessageByState(c2cOrder, "0");
|
logger.error("saveOpen end:"+remark);
|
}
|
|
private void saveBuy(C2cOrder c2cOrder, C2cAdvert c2cAdvert, double symbol_value,String remark) {
|
logger.error("saveBuy start:"+remark);
|
DecimalFormat df = new DecimalFormat("#.########");
|
|
if (C2cOrder.ORDER_TYPE_BY_AMOUNT.equals(c2cOrder.getOrderType())) {
|
// 按支付金额支付
|
|
// 币种数量 = 支付金额/币种单价
|
double coin_amount = Double.valueOf(df.format(Arith.div(c2cOrder.getAmount(), symbol_value))).doubleValue();
|
|
if (coin_amount > c2cAdvert.getCoinAmount()) {
|
throw new BusinessException("该广告剩余数量不足");
|
}
|
|
c2cOrder.setCoinAmount(coin_amount);
|
c2cOrder.setAmountUsdt(Double.valueOf(df.format(Arith.mul(coin_amount, c2cAdvert.getSymbolClose()))).doubleValue());
|
c2cAdvert.setCoinAmount(Double.valueOf(df.format(Arith.sub(c2cAdvert.getCoinAmount(), coin_amount))).doubleValue());
|
c2cAdvert.setDeposit(Double.valueOf(df.format(Arith.sub(c2cAdvert.getDeposit(), c2cOrder.getAmountUsdt()))).doubleValue());
|
} else {
|
// 按币种数量支付
|
|
if (c2cOrder.getCoinAmount() > c2cAdvert.getCoinAmount()) {
|
throw new BusinessException("该广告剩余数量不足");
|
}
|
|
c2cOrder.setAmount(Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), symbol_value))).doubleValue());
|
c2cOrder.setAmountUsdt(Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), c2cAdvert.getSymbolClose()))).doubleValue());
|
c2cAdvert.setCoinAmount(Double.valueOf(df.format(Arith.sub(c2cAdvert.getCoinAmount(), c2cOrder.getCoinAmount()))).doubleValue());
|
c2cAdvert.setDeposit(Double.valueOf(df.format(Arith.sub(c2cAdvert.getDeposit(), c2cOrder.getAmountUsdt()))).doubleValue());
|
}
|
logger.error("buy save start:"+remark);
|
this.save(c2cOrder);
|
logger.error("buy save end:"+remark);
|
// 买入金额需要在区间内
|
if (c2cOrder.getAmount() > c2cAdvert.getInvestmentMax() || c2cOrder.getAmount() < c2cAdvert.getInvestmentMin()) {
|
throw new BusinessException("金额不在购买区间");
|
}
|
// 保存资金日志
|
|
c2cAdvert.setSortIndex(0);
|
this.c2cAdvertService.update(c2cAdvert);
|
logger.error("saveBuy end:"+remark);
|
}
|
|
private void saveSell(C2cOrder c2cOrder, C2cAdvert c2cAdvert, double symbol_value,String remark) {
|
logger.error("saveSell start::"+remark);
|
DecimalFormat df = new DecimalFormat("#.########");
|
|
if (C2cOrder.ORDER_TYPE_BY_AMOUNT.equals(c2cOrder.getOrderType())) {
|
// 按支付金额支付
|
|
// 币种数量 = 支付金额/币种单价
|
double coin_amount = Double.valueOf(df.format(Arith.div(c2cOrder.getAmount(), symbol_value)));
|
c2cOrder.setCoinAmount(coin_amount);
|
c2cOrder.setAmountUsdt(Double.valueOf(df.format(Arith.mul(coin_amount, c2cAdvert.getSymbolClose()))).doubleValue());
|
} else {
|
// 按币种数量支付
|
c2cOrder.setAmount(Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), symbol_value))));
|
c2cOrder.setAmountUsdt(Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), c2cAdvert.getSymbolClose()))).doubleValue());
|
}
|
this.save(c2cOrder);
|
// 买入金额需要在区间内
|
if (c2cOrder.getAmount() > c2cAdvert.getInvestmentMax() || c2cOrder.getAmount() < c2cAdvert.getInvestmentMin()) {
|
throw new BusinessException("金额不在购买区间");
|
}
|
|
double amountBefore = 0d;
|
double amountAfter = 0d;
|
|
if ("usdt".equalsIgnoreCase(c2cAdvert.getSymbol())) {
|
|
Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
|
if (c2cOrder.getCoinAmount() > wallet.getMoney()) {
|
throw new BusinessException("用户剩余数量不足");
|
}
|
|
amountBefore = wallet.getMoney();
|
amountAfter = Double.valueOf(df.format(Arith.sub(wallet.getMoney(), c2cOrder.getCoinAmount()))).doubleValue();
|
this.walletService.update(c2cOrder.getPartyId(), Arith.sub(0, c2cOrder.getCoinAmount()));
|
} else {
|
|
WalletExtend walletExtend = this.walletService.saveExtendByPara(c2cOrder.getPartyId(), c2cOrder.getSymbol());
|
|
if (c2cOrder.getCoinAmount() > walletExtend.getAmount()) {
|
throw new BusinessException("用户剩余数量不足");
|
}
|
|
amountBefore = walletExtend.getAmount();
|
amountAfter = Double.valueOf(df.format(Arith.sub(walletExtend.getAmount(), c2cOrder.getCoinAmount()))).doubleValue();
|
this.walletService.updateExtend(c2cOrder.getPartyId(), c2cOrder.getSymbol(), Arith.sub(0, c2cOrder.getCoinAmount()));
|
}
|
|
|
// 保存资金日志
|
MoneyLog moneylog = new MoneyLog();
|
moneylog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
|
moneylog.setAmount_before(amountBefore);
|
moneylog.setAmount(Arith.sub(0, c2cOrder.getCoinAmount()));
|
moneylog.setAmount_after(amountAfter);
|
moneylog.setLog("c2c卖币，币种[" + c2cOrder.getSymbol() + "]，订单号[" + c2cOrder.getOrderNo() + "]");
|
moneylog.setPartyId(c2cOrder.getPartyId());
|
moneylog.setWallettype(c2cOrder.getSymbol());
|
moneylog.setContent_type(Constants.MONEYLOG_CONTENT_C2C_SELL);
|
moneyLogService.save(moneylog);
|
|
|
|
|
c2cAdvert.setSortIndex(0);
|
this.c2cAdvertService.update(c2cAdvert);
|
}
|
|
/**
|
* 检测用户可卖币次数
|
*/
|
public void checkSellNum(String partyId) {
|
// 当日提现次数是否超过
|
Object obj = this.sysparaService.find("c2c_sell_limit_num");
|
if (null != obj) {
|
double c2c_sell_limit_num = Double.valueOf(this.sysparaService.find("c2c_sell_limit_num").getValue());
|
List<C2cOrder> c2cOrders = this.findByPartyIdAndToday(partyId, C2cAdvert.DIRECTION_SELL, null);
|
|
if (c2c_sell_limit_num > 0 && c2cOrders != null) {
|
if (c2cOrders.size() >= c2c_sell_limit_num) {
|
throw new BusinessException(1, "当日可提现次数不足");
|
}
|
}
|
}
|
}
|
|
/**
|
* 检测用户可卖币权限
|
*/
|
public void checkSellAuth(String partyId) {
|
Kyc party_kyc = this.kycService.get(partyId);
|
Object objKyc = this.sysparaService.find("c2c_sell_by_kyc");
|
if (null != objKyc) {
|
if (!(party_kyc.getStatus() == 2) && "true".equals(this.sysparaService.find("c2c_sell_by_kyc").getValue())) {
|
throw new BusinessException(401, "无权限");
|
}
|
}
|
KycHighLevel party_kycHighLevel = this.kycHighLevelService.get(partyId);
|
Object objKycHigh = this.sysparaService.find("c2c_sell_by_high_kyc");
|
if (null != objKycHigh) {
|
if (!(party_kycHighLevel.getStatus() == 2) && "true".equals(this.sysparaService.find("c2c_sell_by_high_kyc").getValue())) {
|
throw new BusinessException(1, "请先通过高级认证");
|
}
|
}
|
}
|
|
// public void saveOpenQuick(C2cOrder c2cOrder) {
|
//
|
// C2cPaymentMethod method = this.c2cPaymentMethodService.get(c2cOrder.getPaymentMethodId());
|
// if (null == method) {
|
// throw new BusinessException("支付方式不存在");
|
// }
|
//
|
// Page page = null;
|
// if (C2cOrder.ORDER_TYPE_BY_AMOUNT.equals(c2cOrder.getOrderType())) {
|
// // 按支付金额支付
|
// page = this.c2cAdvertService.pagedQueryQuick(1, 1, c2cOrder.getCurrency(), c2cOrder.getSymbol(), c2cOrder.getDirection(), c2cOrder.getAmount(), -1, method.getMethodConfigId());
|
// } else {
|
// // 按币种数量支付
|
// page = this.c2cAdvertService.pagedQueryQuick(1, 1, c2cOrder.getCurrency(), c2cOrder.getSymbol(), c2cOrder.getDirection(), -1, c2cOrder.getCoinAmount(), method.getMethodConfigId());
|
// }
|
//
|
// if (CollectionUtils.isNotEmpty(page.getElements())) {
|
//
|
// Map<String, Object> advertMap = (Map<String, Object>) page.getElements().get(0);
|
//
|
// String c2cAdvertId = advertMap.get("id").toString();
|
// c2cOrder.setC2cAdvertId(c2cAdvertId);
|
// String c2cUserId = advertMap.get("c2c_user_id").toString();
|
// c2cOrder.setC2cUserId(c2cUserId);
|
//
|
// if (C2cAdvert.DIRECTION_BUY.equals(advertMap.get("direction").toString())) {
|
// // 买币 订单存承兑商支付方式
|
// } else if (C2cAdvert.DIRECTION_SELL.equals(advertMap.get("direction").toString())) {
|
// // 卖币 订单存用户支付方式
|
//
|
// C2cUser c2cUser = this.c2cUserService.get(c2cUserId);
|
// if (null == c2cUser) {
|
// throw new BusinessException("承兑商不存在");
|
// }
|
//
|
// Map<String, C2cPaymentMethod> methodMap = this.c2cPaymentMethodService.getByPartyId(c2cUser.getC2cUserPartyId());
|
// if (null == methodMap) {
|
// throw new BusinessException("未找到符合条件的承兑商广告");
|
// }
|
//
|
// boolean found = false;
|
// for (String id : methodMap.keySet()) {
|
// C2cPaymentMethod cpm = methodMap.get(id);
|
// if (null != cpm && cpm.getMethodConfigId().equals(method.getMethodConfigId())) {
|
// c2cOrder.setPaymentMethodId(cpm.getId().toString());
|
// found = true;
|
// break;
|
// }
|
// }
|
// if (!found) {
|
// throw new BusinessException("未找到符合条件的承兑商广告");
|
// }
|
//
|
// } else {
|
// throw new BusinessException("买卖方式不正确");
|
// }
|
//
|
// boolean lock = false;
|
//
|
// try {
|
//
|
// int i = 0;
|
// while (true) {
|
//
|
// if (C2cAdvertLock.add(c2cAdvertId)) {
|
// lock = true;
|
// this.saveOpen(c2cOrder);
|
// // 处理完退出
|
// break;
|
// }
|
// i++;
|
// if (i == 100) {
|
// // 尝试100次没获取到，则先退出
|
// throw new BusinessException(1, "请稍后再试");
|
// }
|
//
|
// }
|
//
|
// } catch (BusinessException e) {
|
// throw e;
|
// } catch (Throwable t) {
|
// throw t;
|
// } finally {
|
// if (lock) {
|
// ThreadUtils.sleep(200);
|
// // 事务提交
|
// C2cAdvertLock.remove(c2cAdvertId);
|
// }
|
// }
|
//
|
// } else {
|
// throw new BusinessException("未找到符合条件的承兑商广告");
|
// }
|
// }
|
|
public void saveOpenQuickApply(C2cOrder c2cOrder) {
|
|
C2cPaymentMethod method = this.c2cPaymentMethodService.get(c2cOrder.getPaymentMethodId());
|
if (null == method) {
|
throw new BusinessException("支付方式不存在");
|
}
|
|
C2cAdvert c2cAdvert = this.c2cAdvertService.get(c2cOrder.getC2cAdvertId());
|
if (null == c2cAdvert) {
|
throw new BusinessException("广告不存在");
|
}
|
|
c2cOrder.setC2cUserId(c2cAdvert.getC2cUserId());
|
|
if (C2cAdvert.DIRECTION_BUY.equals(c2cAdvert.getDirection())) {
|
// 买币 订单存承兑商支付方式
|
|
C2cUser c2cUser = this.c2cUserService.get(c2cAdvert.getC2cUserId());
|
if (null == c2cUser) {
|
throw new BusinessException("承兑商不存在");
|
}
|
|
Map<String, C2cPaymentMethod> methodMap = this.c2cPaymentMethodService.getByPartyId(c2cUser.getC2cUserPartyId());
|
if (null == methodMap) {
|
throw new BusinessException("承兑商支付方式不存在");
|
}
|
|
boolean found = false;
|
for (String id : methodMap.keySet()) {
|
C2cPaymentMethod cpm = methodMap.get(id);
|
if (null != cpm && cpm.getMethodConfigId().equals(method.getMethodConfigId())) {
|
c2cOrder.setPaymentMethodId(cpm.getId().toString());
|
found = true;
|
break;
|
}
|
}
|
if (!found) {
|
throw new BusinessException("承兑商支付方式不存在");
|
}
|
|
} else if (C2cAdvert.DIRECTION_SELL.equals(c2cAdvert.getDirection())) {
|
// 卖币 订单存用户支付方式
|
} else {
|
throw new BusinessException("买卖方式不正确");
|
}
|
|
boolean lock = false;
|
String partyId = c2cOrder.getPartyId();
|
try {
|
|
if (!C2cLock.add(partyId)) {
|
throw new BusinessException("Please try again later");
|
}
|
lock = true;
|
|
this.saveOpen(c2cOrder,"");
|
|
} catch (BusinessException e) {
|
throw e;
|
} catch (Throwable t) {
|
throw t;
|
} finally {
|
if (lock) {
|
C2cLock.remove(partyId);
|
}
|
}
|
}
|
|
/**
|
* 订单取消
|
* @param role: user/用户；c2c_user/承兑商；manager/承兑商管理员、root和admin；timer/订单自动取消定时器；
|
*/
|
public synchronized void saveOrderCancel(C2cOrder c2cOrder, String role) {
|
|
DecimalFormat df = new DecimalFormat("#.########");
|
|
if ("4".equals(c2cOrder.getState())) {
|
throw new BusinessException("该订单已取消");
|
}
|
|
if ("manager".equals(role)) {
|
if (!("0".equals(c2cOrder.getState()) || "1".equals(c2cOrder.getState()) || "2".equals(c2cOrder.getState()) || "5".equals(c2cOrder.getState()))) {
|
throw new BusinessException("当前订单不为待付款、已付款、申诉中或已超时状态，无法取消");
|
}
|
} else {
|
if (!"0".equals(c2cOrder.getState())) {
|
throw new BusinessException("当前订单不为待付款状态，无法取消");
|
}
|
}
|
|
if (C2cOrder.DIRECTION_BUY.equals(c2cOrder.getDirection())) {
|
// 买币
|
|
boolean lock = false;
|
|
try {
|
|
if (C2cAdvertLock.add(c2cOrder.getC2cAdvertId())) {
|
lock = true;
|
C2cAdvert c2cAdvert = this.c2cAdvertService.findById(c2cOrder.getC2cAdvertId());
|
c2cAdvert.setCoinAmount(Double.valueOf(df.format(Arith.add(c2cAdvert.getCoinAmount(), c2cOrder.getCoinAmount()))).doubleValue());
|
c2cAdvert.setDeposit(Double.valueOf(df.format(Arith.add(c2cAdvert.getDeposit(), c2cOrder.getAmountUsdt()))).doubleValue());
|
this.c2cAdvertService.update(c2cAdvert);
|
}
|
|
} finally {
|
if (lock) {
|
ThreadUtils.sleep(100);
|
// 事务提交
|
C2cAdvertLock.remove(c2cOrder.getC2cAdvertId());
|
}
|
}
|
|
} else if (C2cOrder.DIRECTION_SELL.equals(c2cOrder.getDirection())) {
|
// 卖币
|
|
// 用户钱包退还
|
double amountBefore = 0d;
|
double amountAfter = 0d;
|
|
if ("usdt".equalsIgnoreCase(c2cOrder.getSymbol())) {
|
Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
|
amountBefore = wallet.getMoney();
|
amountAfter = Double.valueOf(df.format(Arith.add(wallet.getMoney(), c2cOrder.getCoinAmount()))).doubleValue();
|
this.walletService.update(c2cOrder.getPartyId().toString(), c2cOrder.getCoinAmount());
|
} else {
|
WalletExtend walletExtend = this.walletService.saveExtendByPara(c2cOrder.getPartyId(), c2cOrder.getSymbol());
|
amountBefore = walletExtend.getAmount();
|
amountAfter = walletExtend.getAmount();
|
this.walletService.updateExtend(c2cOrder.getPartyId().toString(), c2cOrder.getSymbol(), c2cOrder.getCoinAmount());
|
}
|
|
// 保存资金日志
|
MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
|
moneyLog.setAmount_before(amountBefore);
|
moneyLog.setAmount(c2cOrder.getCoinAmount());
|
moneyLog.setAmount_after(amountAfter);
|
moneyLog.setLog("c2c订单取消，描述[" + c2cOrder.getRemark() + "]");
|
moneyLog.setPartyId(c2cOrder.getPartyId());
|
moneyLog.setWallettype(c2cOrder.getSymbol());
|
moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_C2C_CANCEL);
|
|
this.moneyLogService.save(moneyLog);
|
}
|
|
c2cOrder.setState("4");
|
c2cOrder.setCancelTime(new Date());
|
this.update(c2cOrder);
|
this.updateNofinishOrderCount(c2cOrder);
|
|
this.tipService.deleteTip(c2cOrder.getId().toString());
|
|
this.c2cSendMessageByState(c2cOrder, "4");
|
|
// 取消次数加1
|
String partyIdCancel = "";
|
if ("user".equals(role)) {
|
partyIdCancel = c2cOrder.getPartyId();
|
} else if ("c2c_user".equals(role)) {
|
partyIdCancel = c2cOrder.getC2cUserPartyId();
|
}
|
if (!"".equals(partyIdCancel)) {
|
Map<String, Integer> map = (Map<String, Integer>) this.redisHandler.get(RedisKeys.C2C_ORDER_CANCEL_DAY_TIMES);
|
if (null == map) {
|
map = new ConcurrentHashMap<String, Integer>();
|
}
|
if (null == map.get(partyIdCancel)) {
|
map.put(partyIdCancel, 1);
|
} else {
|
map.put(partyIdCancel, map.get(partyIdCancel) + 1);
|
}
|
this.redisHandler.setSync(RedisKeys.C2C_ORDER_CANCEL_DAY_TIMES, map);
|
}
|
}
|
|
/**
|
* 订单放行
|
*/
|
public void saveOrderPass(C2cOrder c2cOrder) {
|
|
DecimalFormat df = new DecimalFormat("#.########");
|
|
C2cAdvert c2cAdvert = this.c2cAdvertService.get(c2cOrder.getC2cAdvertId());
|
if (null == c2cAdvert) {
|
throw new BusinessException("广告不存在");
|
}
|
|
// double symbolClose = symbolClose(c2cOrder.getSymbol());
|
double symbolClose = c2cAdvert.getSymbolClose();
|
|
if (C2cOrder.DIRECTION_BUY.equals(c2cOrder.getDirection())) {
|
// 买币
|
|
// 给用户账户添加相应的币种数量
|
double amountBefore = 0d;
|
double amountAfter = 0d;
|
|
if ("usdt".equalsIgnoreCase(c2cOrder.getSymbol())) {
|
Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
|
amountBefore = wallet.getMoney();
|
amountAfter = Double.valueOf(df.format(Arith.add(wallet.getMoney(), c2cOrder.getCoinAmount()))).doubleValue();
|
this.walletService.update(c2cOrder.getPartyId().toString(), c2cOrder.getCoinAmount());
|
} else {
|
WalletExtend walletExtend = this.walletService.saveExtendByPara(c2cOrder.getPartyId(), c2cOrder.getSymbol());
|
amountBefore = walletExtend.getAmount();
|
amountAfter = Double.valueOf(df.format(Arith.add(walletExtend.getAmount(), c2cOrder.getCoinAmount()))).doubleValue();
|
this.walletService.updateExtend(c2cOrder.getPartyId().toString(), c2cOrder.getSymbol(), c2cOrder.getCoinAmount());
|
}
|
|
// 保存资金日志
|
MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
|
moneyLog.setAmount_before(amountBefore);
|
moneyLog.setAmount(c2cOrder.getCoinAmount());
|
moneyLog.setAmount_after(amountAfter);
|
moneyLog.setLog("c2c订单购买放行，订单号[" + c2cOrder.getOrderNo() + "]");
|
moneyLog.setPartyId(c2cOrder.getPartyId());
|
moneyLog.setWallettype(c2cOrder.getSymbol());
|
moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_OTC_BUY);
|
moneyLogService.save(moneyLog);
|
|
// usdt价值=币种数量*行情价
|
if ("usdt".equalsIgnoreCase(c2cOrder.getSymbol())) {
|
this.userDataService.saveRechargeHandle(c2cOrder.getPartyId(), c2cOrder.getCoinAmount(), c2cOrder.getSymbol());
|
} else {
|
this.userDataService.saveRechargeHandle(c2cOrder.getPartyId(), c2cOrder.getCoinAmount(), c2cOrder.getSymbol());
|
}
|
|
} else if (C2cOrder.DIRECTION_SELL.equals(c2cOrder.getDirection())) {
|
// 卖币
|
|
if (C2cAdvertLock.add(c2cOrder.getC2cAdvertId())) {
|
c2cAdvert.setCoinAmount(Double.valueOf(df.format(Arith.add(c2cAdvert.getCoinAmount(), c2cOrder.getCoinAmount()))).doubleValue());
|
c2cAdvert.setDeposit(Double.valueOf(df.format(Arith.add(c2cAdvert.getDeposit(), c2cOrder.getAmountUsdt()))).doubleValue());
|
this.c2cAdvertService.update(c2cAdvert);
|
}
|
|
// usdt价值=币种数量*行情价
|
if ("usdt".equalsIgnoreCase(c2cOrder.getSymbol())) {
|
this.userDataService.saveWithdrawHandle(c2cOrder.getPartyId(), c2cOrder.getCoinAmount(), 0d, "usdt");
|
} else {
|
this.userDataService.saveWithdrawHandle(c2cOrder.getPartyId(), Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), symbolClose))).doubleValue(), 0d, c2cOrder.getSymbol());
|
}
|
}
|
|
// 订单完成
|
c2cOrder.setState("3");
|
c2cOrder.setHandleTime(new Date());
|
this.update(c2cOrder);
|
this.updateNofinishOrderCount(c2cOrder);
|
|
C2cUser c2cUser = this.c2cUserService.get(c2cOrder.getC2cUserId());
|
if (null == c2cUser) {
|
throw new BusinessException("承兑商不存在");
|
}
|
if (C2cOrder.DIRECTION_BUY.equals(c2cOrder.getDirection())) {
|
// 买币
|
c2cUser.setBuyAmount(c2cUser.getBuyAmount() + c2cOrder.getAmountUsdt());
|
c2cUser.setBuySuccessOrders(c2cUser.getBuySuccessOrders() + 1);
|
} else if (C2cOrder.DIRECTION_SELL.equals(c2cOrder.getDirection())) {
|
// 卖币
|
c2cUser.setSellAmount(c2cUser.getSellAmount() + c2cOrder.getAmountUsdt());
|
c2cUser.setSellSuccessOrders(c2cUser.getSellSuccessOrders() + 1);
|
}
|
c2cUser.setTotalAmount(c2cUser.getTotalAmount() + c2cOrder.getAmountUsdt());
|
c2cUser.setTotalSuccessOrders(c2cUser.getTotalSuccessOrders() + 1);
|
|
if (C2cOrder.DIRECTION_SELL.equals(c2cOrder.getDirection())) {
|
// 卖币
|
// 用户出售承兑商付款 相当于给承兑商账户充值了保证金
|
c2cUser.setDepositOpen(Double.valueOf(df.format(Arith.add(c2cUser.getDepositOpen(), c2cOrder.getAmountUsdt()))).doubleValue());
|
}
|
|
this.c2cUserService.update(c2cUser);
|
|
this.tipService.deleteTip(c2cOrder.getId().toString());
|
|
this.c2cSendMessageByState(c2cOrder, "3");
|
}
|
|
// private double symbolClose(String symbol) {
|
// double close = 0d;
|
// if (symbol.equals("usdt")) {
|
// close = 1;
|
// } else {
|
// List<Realtime> list = this.dataService.realtime(symbol);
|
// if (list.size() == 0) {
|
// return 0;
|
// }
|
// Realtime realtime = list.get(0);
|
// close = realtime.getClose();
|
// }
|
// return close;
|
// }
|
|
/*
|
* C2C发送短信和邮件通知
|
*/
|
public void c2cSendMessageByState(C2cOrder order, String state) {
|
return;
|
|
// Party party = this.partyService.cachePartyBy(order.getPartyId(), false);
|
// if (null == party) {
|
// throw new BusinessException("用户不存在");
|
// }
|
//
|
// Party c2cParty = this.partyService.cachePartyBy(order.getC2cUserPartyId(), false);
|
// if (null == c2cParty) {
|
// throw new BusinessException("承兑商不存在");
|
// }
|
//
|
// C2cUser c2cUser = this.c2cUserService.getByPartyId(order.getC2cUserPartyId());
|
// if (null == c2cUser) {
|
// throw new BusinessException("承兑商不存在");
|
// }
|
//
|
// // C2C短信和邮件通知内容
|
// String c2c_send_msg_content = this.sysparaService.find("c2c_send_msg_content").getValue();
|
// if (StringUtils.isNullOrEmpty(c2c_send_msg_content)) {
|
// log.error("System parameter c2c_send_msg_content have not configured.");
|
// return;
|
// }
|
//
|
// // C2C短信和邮件通知内容:
|
// // BUY_CREAT_ORDER##您在交易所的订单{0}已提交,请向承兑商付款{1}{2},这是一条自动消息请不要回复
|
// // &&SELL_CREAT_ORDER##您在交易所的有新的订单{0},请向用户付款{1}{2},这是一条自动消息请不要回复
|
// // &&PAY_FINISH##您在交易所的订单{0}已成功付款{1}{2},请确定收款放币,这是一条自动消息请不要回复
|
// // &&APPEAL##您在交易所的订单{0}已提交申诉,请耐心等待处理,这是一条自动消息请不要回复
|
// // &&SUCCEED##您在交易所的订单{0}已放币{1}{2},请确认查收,这是一条自动消息请不要回复
|
// // &&CANCELLED##您在交易所的订单{0}已取消,这是一条自动消息请不要回复
|
// // &&EXPIRED##您在交易所的订单{0}已超时,这是一条自动消息请不要回复
|
//
|
// Map<String, String> msgMap = new HashMap<String, String>();
|
// String[] msgArray = c2c_send_msg_content.split("&&");
|
// for (int i = 0; i < msgArray.length; i++) {
|
// String[] msg = msgArray[i].split("##");
|
// msgMap.put(msg[0], msg[1]);
|
// }
|
//
|
// String userPhone = party.getPhone();
|
// String userEmail = party.getEmail();
|
// String c2cUserPhone = c2cParty.getPhone();
|
// String c2cUserEmail = c2cParty.getEmail();
|
//
|
// String userContent = "";
|
// String c2cUserContent = "";
|
//
|
// // 订单状态：0未付款/1已付款/2申诉中/3已完成/4已取消/5已超时
|
// switch (state) {
|
// case "0":
|
// if ("buy".equals(order.getDirection())) {
|
// userContent = MessageFormat.format(msgMap.get("BUY_CREAT_ORDER"), new Object[] { order.getOrderNo(), order.getAmount(), order.getCurrency() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(userPhone, userContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(userEmail, userContent);
|
// }
|
// } else {
|
// c2cUserContent = MessageFormat.format(msgMap.get("SELL_CREAT_ORDER"), new Object[] { order.getOrderNo(), order.getAmount(), order.getCurrency() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserPhone, c2cUserContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserEmail, c2cUserContent);
|
// }
|
// }
|
// break;
|
// case "1":
|
// if ("buy".equals(order.getDirection())) {
|
// c2cUserContent = MessageFormat.format(msgMap.get("PAY_FINISH"), new Object[] { order.getOrderNo(), order.getAmount(), order.getCurrency() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserPhone, c2cUserContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserEmail, c2cUserContent);
|
// }
|
// } else {
|
// userContent = MessageFormat.format(msgMap.get("PAY_FINISH"), new Object[] { order.getOrderNo(), order.getAmount(), order.getCurrency() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(userPhone, userContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(userEmail, userContent);
|
// }
|
// }
|
// break;
|
// case "2":
|
// if ("buy".equals(order.getDirection())) {
|
// userContent = MessageFormat.format(msgMap.get("APPEAL"), new Object[] { order.getOrderNo() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(userPhone, userContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(userEmail, userContent);
|
// }
|
// } else {
|
// c2cUserContent = MessageFormat.format(msgMap.get("APPEAL"), new Object[] { order.getOrderNo() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserPhone, c2cUserContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserEmail, c2cUserContent);
|
// }
|
// }
|
// break;
|
// case "3":
|
// if ("buy".equals(order.getDirection())) {
|
// userContent = MessageFormat.format(msgMap.get("SUCCEED"), new Object[] { order.getOrderNo(), order.getCoinAmount(), order.getSymbol() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(userPhone, userContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(userEmail, userContent);
|
// }
|
// } else {
|
// c2cUserContent = MessageFormat.format(msgMap.get("SUCCEED"), new Object[] { order.getOrderNo(), order.getCoinAmount(), order.getSymbol() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserPhone, c2cUserContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserEmail, c2cUserContent);
|
// }
|
// }
|
// break;
|
// case "4":
|
// break;
|
// case "5":
|
// userContent = MessageFormat.format(msgMap.get("EXPIRED"), new Object[] { order.getOrderNo() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(userPhone, userContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(userEmail, userContent);
|
// }
|
// c2cUserContent = MessageFormat.format(msgMap.get("EXPIRED"), new Object[] { order.getOrderNo() });
|
// if (1 == c2cUser.getOrderSmsNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserPhone, c2cUserContent);
|
// }
|
// if (1 == c2cUser.getOrderMailNoticeOpen()) {
|
// this.c2cSendMessage(c2cUserEmail, c2cUserContent);
|
// }
|
// break;
|
// default:
|
// break;
|
// }
|
}
|
|
public void c2cSendMessage(String target, String content) {
|
|
if (target.indexOf("@") == -1) {
|
// 短信
|
|
// 发送的短信接口类型
|
String send_code_type = this.sysparaService.find("send_code_type").getValue();
|
if (StringUtils.isNullOrEmpty(send_code_type)) {
|
logger.error("System parameter send_code_type have not configured.");
|
return;
|
}
|
|
if ("tiantian".equals(send_code_type)) {
|
this.smsSendService.send(target, content);
|
logger.info(MessageFormat.format("tiantian--target:{0},content:{1}", target, content));
|
} else if ("smsbao".equals(send_code_type)) {
|
this.smsSendService.send(target, content);
|
logger.info(MessageFormat.format("smsbao--target:{0},content:{1}", target, content));
|
}
|
|
} else {
|
// 邮件
|
|
this.emailSendService.sendEmail(target, content, content);
|
logger.info(MessageFormat.format("email--target:{0},content:{1}", target, content));
|
}
|
}
|
|
public void setPagedDao(PagedQueryDao pagedDao) {
|
this.pagedDao = pagedDao;
|
}
|
|
public void setRedisHandler(RedisHandler redisHandler) {
|
this.redisHandler = redisHandler;
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public void setC2cAdvertService(C2cAdvertService c2cAdvertService) {
|
this.c2cAdvertService = c2cAdvertService;
|
}
|
|
public void setC2cUserService(C2cUserService c2cUserService) {
|
this.c2cUserService = c2cUserService;
|
}
|
|
public void setDataService(DataService dataService) {
|
this.dataService = dataService;
|
}
|
|
public void setExchangeRateService(ExchangeRateService exchangeRateService) {
|
this.exchangeRateService = exchangeRateService;
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setMoneyLogService(MoneyLogService moneyLogService) {
|
this.moneyLogService = moneyLogService;
|
}
|
|
public void setC2cPaymentMethodService(C2cPaymentMethodService c2cPaymentMethodService) {
|
this.c2cPaymentMethodService = c2cPaymentMethodService;
|
}
|
|
public void setUserDataService(UserDataService userDataService) {
|
this.userDataService = userDataService;
|
}
|
|
public void setTipService(TipService tipService) {
|
this.tipService = tipService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setKycService(KycService kycService) {
|
this.kycService = kycService;
|
}
|
|
public void setKycHighLevelService(KycHighLevelService kycHighLevelService) {
|
this.kycHighLevelService = kycHighLevelService;
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setSmsSendService(SmsSendService smsSendService) {
|
this.smsSendService = smsSendService;
|
}
|
|
public void setEmailSendService(EmailSendService emailSendService) {
|
this.emailSendService = emailSendService;
|
}
|
|
}
|
