package com.gear.customer.swx.biz.impl;
|
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.gear.common.constant.SwxConstons;
|
import com.gear.common.core.redis.RedisCache;
|
import com.gear.common.exception.CustomerException;
|
import com.gear.customer.swx.biz.SwxBizOrder;
|
import com.gear.customer.swx.config.DelayQueueRabbitConfig;
|
import com.gear.customer.swx.vo.request.SwxBuyOptionsVo;
|
import com.gear.customer.swx.vo.request.SwxBuySmartVo;
|
import com.gear.customer.swx.vo.response.SwxBuyOptionsInfo;
|
import com.gear.customer.swx.vo.response.SwxUserInfoVo;
|
import com.gear.swx.domain.*;
|
import com.gear.swx.service.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.logging.log4j.util.Strings;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDateTime;
|
import java.time.ZoneId;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
@Component
|
@Slf4j
|
public class SwxBizOrderImpl implements SwxBizOrder {
|
|
private static final Logger lg = LoggerFactory.getLogger("orderFile");
|
private static final Logger logger = LoggerFactory.getLogger(SwxBizOrderImpl.class);
|
|
@Autowired
|
private ISwxSmartOrderService swxSmartOrderService;
|
|
@Autowired
|
private ISwxUserService swxUserService;
|
|
@Autowired
|
private ISwxMarketService swxMarketService;
|
|
@Autowired
|
private ISwxMarketSmartService swxMarketSmartService;
|
|
@Autowired
|
private ISwxMoneyLogService swxMoneyLogService;
|
|
@Autowired
|
private ISwxOrderService swxOrderService;
|
|
@Autowired
|
private ISwxOptionsOrderService swxOptionsOrderService;
|
|
@Autowired
|
private ISwxMarketOptionsService swxMarketOptionsService;
|
|
@Autowired
|
private RedisCache redisCache;
|
|
@Autowired
|
private ISwxSettingsService swxSettingsService;
|
|
@Autowired
|
RabbitTemplate rabbitTemplate;
|
@Autowired
|
private ISwxUserLevelService swxUserLevelService;
|
@Override
|
public String buySmart(SwxBuySmartVo vo, String userId, String virtually) throws CustomerException {
|
|
if (!SwxConstons.SWX_CUSTOMER_USER_ORDER_TYPE_TRUE.equals(virtually)){
|
throw new CustomerException("10008");
|
}
|
//获取用户信息
|
SwxUser swxUser = swxUserService.getById(userId);
|
if (swxUser == null){
|
throw new CustomerException("10009");
|
}
|
//获取产品
|
SwxMarketSmart swxMarketSmart = swxMarketSmartService.getById(vo.getMarketId());
|
if (swxMarketSmart == null || !Objects.equals(swxMarketSmart.getStatus(), SwxConstons.NOMARL_STATUS_YES)){
|
throw new CustomerException("10010");
|
}
|
//当天是否存在相同订单
|
if (swxSmartOrderService.checkRepeatOrder(userId, vo.getMarketId(), vo.getAllDay())) {
|
//已购买相同产品，请勿重复购买
|
throw new CustomerException("10024");
|
}
|
//获取用户是否有足够钱购买,用户余额为用户余额减保证金占用
|
if((swxUser.getAmount().subtract(swxUser.getBondAmount())).compareTo(vo.getAmount()) < 0) {
|
throw new CustomerException("10011");
|
}
|
String rateInfoStr = swxMarketSmart.getSmartInfo();
|
BigDecimal rate = null;
|
BigDecimal max = null;
|
BigDecimal min = null;
|
JSONArray jsonArray = JSONArray.parseArray(rateInfoStr);
|
for(int i = 0; i < jsonArray.size(); i++){
|
JSONObject object = jsonArray.getJSONObject(i);
|
Integer days = object.getInteger("days");
|
if (days.intValue() == vo.getAllDay().intValue()){
|
rate = new BigDecimal(object.getString("rate"));
|
max = new BigDecimal(object.getString("max"));
|
min = new BigDecimal(object.getString("min"));
|
break;
|
}
|
}
|
|
if (rate == null || max == null || min == null){
|
throw new CustomerException("10012");
|
}
|
|
if(vo.getAmount().compareTo(max) >0 || vo.getAmount().compareTo(min) < 0){
|
throw new CustomerException("10013");
|
}
|
LocalDateTime localDateTime = LocalDateTime.now();
|
LocalDateTime afterDays = localDateTime.plusDays(1);
|
SwxSmartOrder swxSmartOrder = new SwxSmartOrder();
|
BeanUtils.copyProperties(vo,swxSmartOrder);
|
swxSmartOrder.setUserId(userId);
|
swxSmartOrder.setMarketId(swxMarketSmart.getId());
|
swxSmartOrder.setCurrentDay(0);
|
swxSmartOrder.setBuyTime(new Date());
|
swxSmartOrder.setRate(rate);
|
swxSmartOrder.setNextProfitTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:00").format(Date.from(afterDays.atZone(ZoneId.systemDefault()).toInstant())));
|
swxSmartOrder.setProfitType(swxMarketSmart.getProfitType());
|
SwxMarket swxMarket = swxMarketService.getById(swxMarketSmart.getMId());
|
swxSmartOrder.setMarketName(swxMarket.getAppName());
|
swxSmartOrder.setMarketCode(swxMarket.getCode());
|
swxSmartOrder.setAddRate(BigDecimal.ZERO);
|
//获取加息
|
if(!Strings.isEmpty(swxUser.getLevel())){
|
SwxUserLevel userLevel = swxUserLevelService.getById(swxUser.getLevel());
|
if (userLevel != null){
|
swxSmartOrder.setAddRate(userLevel.getEquity1());
|
}
|
}
|
lg.info("购买智能交易订单，产品id=‘{}’Rate=‘{}’", vo.getMarketId(), swxSmartOrder.getRate());
|
//计算当期收益
|
swxSmartOrder.setCurrentProfit(swxSmartOrder.getAmount().multiply(swxSmartOrder.getRate().add(swxSmartOrder.getAddRate())).divide(new BigDecimal(100)).multiply(BigDecimal.valueOf(swxSmartOrder.getAllDay())).setScale(2,BigDecimal.ROUND_HALF_UP));
|
swxSmartOrderService.save(swxSmartOrder);
|
//修改用户余额,插入资金日志
|
SwxMoneyLog moneyLog = new SwxMoneyLog();
|
moneyLog.setInfo("购买智能交易，产品为："+swxMarketSmart.getMId()+"，总额为："+vo.getAmount()+"日利率为:"+vo.getRate());
|
moneyLog.setStatus(SwxConstons.SWX_EXAMINE_STATUS_YES);
|
moneyLog.setType(SwxConstons.SWX_MONEY_LOG_TYPE_BUY_SMART);
|
moneyLog.setSymbol(SwxConstons.SWX_MONEY_TYPE_PAY);
|
moneyLog.setTitle("购买智能交易");
|
moneyLog.setOldAmount(swxUser.getAmount());
|
swxUser.setAmount(swxUser.getAmount().subtract(vo.getAmount()));
|
swxUserService.updateById(swxUser);
|
moneyLog.setNowAmount(swxUser.getAmount());
|
moneyLog.setUserId(swxUser.getId());
|
moneyLog.setBusiId(vo.getId());
|
moneyLog.setMoney(vo.getAmount());
|
swxMoneyLogService.save(moneyLog);
|
|
//插入订单总表
|
// SwxOrder swxOrder = new SwxOrder();
|
// swxOrder.setUserId(userId);
|
// swxOrder.setType(SwxConstons.SWX_ORDER_TYPE_SMART);
|
// swxOrder.setStatus(SwxConstons.SWX_ORDER_STATUS_SMART_WAIT);
|
// swxOrder.setMId(swxMarketSmart.getMId());
|
// swxOrder.setBuyType(SwxConstons.SWX_ORDER_BUY_TYPE_HY);
|
// swxOrderService.save(swxOrder);
|
// return "购买成功";
|
return "20004";
|
}
|
|
@Override
|
public IPage<SwxOrder> listOrder(String userId, String virtually,Integer pageNo,Integer pageSize) throws CustomerException {
|
SwxUser swxUser = swxUserService.getById(userId);
|
if (swxUser == null){
|
throw new CustomerException("10009");
|
}
|
Page<SwxOrder> page = new Page<SwxOrder>(pageNo, pageSize);
|
IPage<SwxOrder> pageList = swxOrderService.page(page, new QueryWrapper<SwxOrder>().lambda().eq(SwxOrder::getUserId,userId));
|
return pageList;
|
}
|
|
@Override
|
public IPage<SwxSmartOrder> listSmartOrder(String userId, String virtually, Integer pageNo, Integer pageSize) {
|
SwxUser swxUser = swxUserService.getById(userId);
|
if (swxUser == null){
|
throw new CustomerException("10009");
|
}
|
Page<SwxSmartOrder> page = new Page<SwxSmartOrder>(pageNo, pageSize);
|
QueryWrapper<SwxSmartOrder> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(SwxSmartOrder::getUserId,userId);
|
queryWrapper.lambda().orderByDesc(SwxSmartOrder::getCreateTime);
|
IPage<SwxSmartOrder> pageList = swxSmartOrderService.page(page, queryWrapper);
|
return pageList;
|
}
|
|
@Override
|
public String buyOptionsTrue(SwxBuyOptionsVo vo, String userId, String virtually) throws CustomerException {
|
if (!SwxConstons.SWX_CUSTOMER_USER_ORDER_TYPE_TRUE.equals(virtually)){
|
throw new CustomerException("10008");
|
}
|
//获取用户信息
|
SwxUser swxUser = swxUserService.getById(userId);
|
if (swxUser == null){
|
throw new CustomerException("10009");
|
}
|
SwxUserInfoVo infoVo = new SwxUserInfoVo();
|
BeanUtils.copyProperties(swxUser,infoVo);
|
//获取订单
|
SwxOptionsOrder order = getSwxOptionsOrderBuyInfo(vo,swxUser);
|
order.setOrderType(1);
|
|
BigDecimal yue = infoVo.getAmount().subtract(infoVo.getBondAmount()).subtract(order.getTradeFee());
|
|
//判断资金是否足够
|
if ((yue).compareTo(vo.getAmount()) < 0){
|
throw new CustomerException("10011");
|
}
|
|
swxUser.setAmount(swxUser.getAmount().subtract(vo.getAmount()).subtract(order.getTradeFee()));
|
swxUserService.updateById(swxUser);
|
swxOptionsOrderService.save(order);
|
String id = order.getId();
|
//推送给消息队列
|
Map<String,Object> messageMap = new HashMap<>();
|
messageMap.put("id",id);
|
messageMap.put("istrue",1);
|
messageMap.put("userId",userId);
|
Integer timeSeconds = vo.getLimitTime() * 1000;
|
rabbitTemplate.convertAndSend(DelayQueueRabbitConfig.ORDER_EXCHANGE, DelayQueueRabbitConfig.ORDER_ROUTING_KEY, messageMap, message->{
|
message.getMessageProperties().setExpiration(timeSeconds+"");
|
return message;
|
});
|
return id;
|
}
|
|
private SwxOptionsOrder getSwxOptionsOrderBuyInfo(SwxBuyOptionsVo vo,SwxUser swxUser) throws CustomerException{
|
//获取产品
|
SwxMarketOptions swxMarketOptions = swxMarketOptionsService.getById(vo.getOptionsId());
|
if (swxMarketOptions == null || swxMarketOptions.getStatus() != SwxConstons.NOMARL_STATUS_YES){
|
throw new CustomerException("10014");
|
}
|
|
//获取产品
|
SwxMarket swxMarket = swxMarketService.getById(swxMarketOptions.getMId());
|
if (swxMarket == null){
|
throw new CustomerException("10014");
|
}
|
|
//获取可交易时间
|
if (!getCanTradeTime(swxMarketOptions.getCanTradeDateType(),swxMarketOptions.getCanTradeDate(),swxMarketOptions.getCanTradeTime())) {
|
throw new CustomerException("10015");
|
}
|
|
if (vo.getAmount() == null || vo.getAmount().compareTo(BigDecimal.ZERO) <= 0){
|
throw new CustomerException("10016");
|
}
|
|
//获取利润
|
String rateInfoStr = swxMarketOptions.getOptionsInfo();
|
BigDecimal rate = null;
|
JSONArray jsonArray = JSONArray.parseArray(rateInfoStr);
|
for(int i = 0; i < jsonArray.size(); i++){
|
JSONObject object = jsonArray.getJSONObject(i);
|
Integer days = object.getInteger("seconds");
|
if (days.intValue() == vo.getLimitTime().intValue()){
|
rate = new BigDecimal(object.getString("rate"));
|
break;
|
}
|
}
|
if (rate == null){
|
throw new CustomerException("10017");
|
}
|
|
//获取概率
|
SwxSettings percentSettins = swxSettingsService.getOne(new QueryWrapper<SwxSettings>().lambda().eq(SwxSettings::getParamKey,"options_win_percent"));
|
if(percentSettins == null){
|
throw new CustomerException("10018");
|
}
|
|
//获取手续费
|
SwxSettings tradeFeeSettings = swxSettingsService.getOne(new QueryWrapper<SwxSettings>().lambda().eq(SwxSettings::getParamKey,"default_trade_fee"));
|
if(percentSettins == null){
|
throw new CustomerException("10018");
|
}
|
BigDecimal tradeFee = vo.getAmount().multiply(new BigDecimal(tradeFeeSettings.getParamValue())).divide(new BigDecimal(100));
|
|
//创建订单
|
SwxOptionsOrder swxOptionsOrder = new SwxOptionsOrder();
|
BeanUtils.copyProperties(vo,swxOptionsOrder);
|
swxOptionsOrder.setMarketName(swxMarket.getAppName());
|
swxOptionsOrder.setMarketCode(swxMarket.getCode());
|
swxOptionsOrder.setMarketType(swxMarket.getType());
|
swxOptionsOrder.setRate(rate);
|
//获取概率，存入是否会赢
|
swxOptionsOrder.setOptionsId(swxMarketOptions.getId());
|
swxOptionsOrder.setUserId(swxUser.getId());
|
swxOptionsOrder.setMarketId(swxMarketOptions.getMId());
|
swxOptionsOrder.setStatus(0);
|
//判断用户是否设置包输包赢
|
boolean isWin;
|
if (swxUser.getBw() != 0){
|
if (swxUser.getBw() == 1){
|
isWin = true;
|
}else{
|
isWin = false;
|
}
|
}else{
|
isWin = checkWin(Integer.parseInt(percentSettins.getParamValue()));
|
}
|
//判断是否赢，来设置显示平仓价
|
BigDecimal endPrice = BigDecimal.ZERO;
|
BigDecimal fd = (vo.getBuyPrice().multiply(getRandom(10)).divide(new BigDecimal(1000))).setScale(4, RoundingMode.HALF_UP);
|
if (isWin){
|
if(vo.getType() == 1){
|
endPrice = vo.getBuyPrice().add(fd);
|
}else{
|
endPrice = vo.getBuyPrice().subtract(fd);
|
}
|
}else{
|
if(vo.getType() == 1){
|
endPrice = vo.getBuyPrice().subtract(fd);
|
}else{
|
endPrice = vo.getBuyPrice().add(fd);
|
}
|
}
|
swxOptionsOrder.setResultType(isWin ? 1 : 2);
|
swxOptionsOrder.setEndPrice(endPrice);
|
swxOptionsOrder.setIncome(vo.getAmount().multiply(rate).divide(new BigDecimal(100)));
|
swxOptionsOrder.setTradeFee(tradeFee);
|
return swxOptionsOrder;
|
|
}
|
@Override
|
public String buyOptionsVirtually(SwxBuyOptionsVo vo, String userId, String virtually) throws CustomerException {
|
if (!SwxConstons.SWX_CUSTOMER_USER_ORDER_TYPE_VIRTRUAL.equals(virtually)){
|
throw new CustomerException("10008");
|
}
|
//获取用户信息
|
SwxUser swxUser = swxUserService.getById(userId);
|
if (swxUser == null){
|
throw new CustomerException("10009");
|
}
|
SwxUserInfoVo infoVo;
|
if (redisCache.hasKey("SWX-CUSTOMER-VERTURAL-"+userId)){
|
infoVo= redisCache.getCacheObject("SWX-CUSTOMER-VERTURAL-"+userId);
|
}else{
|
infoVo = new SwxUserInfoVo();
|
BeanUtils.copyProperties(swxUser,infoVo);
|
infoVo.setVirtuallyAmount(new BigDecimal(1000000));
|
infoVo.setVirtuallyBondAmount(new BigDecimal(0));
|
redisCache.setCacheObject("SWX-CUSTOMER-VERTURAL-"+swxUser.getId(),infoVo,604800L, TimeUnit.SECONDS);
|
}
|
//获取订单
|
SwxOptionsOrder order = getSwxOptionsOrderBuyInfo(vo,swxUser);
|
order.setOrderType(2);
|
BigDecimal yue = infoVo.getVirtuallyAmount().subtract(infoVo.getVirtuallyBondAmount());
|
//判断资金是否足够
|
if ((yue.subtract(order.getTradeFee())).compareTo(vo.getAmount()) < 0){
|
throw new CustomerException("10011");
|
}
|
// String id = UUID.randomUUID().toString();
|
infoVo.setVirtuallyAmount(yue.subtract(vo.getAmount()).subtract(order.getTradeFee()));
|
// //修改redis值
|
// order.setId(id);
|
// order.setCreateTime(new Date());
|
Long exprise = redisCache.getExpire("SWX-CUSTOMER-VERTURAL-"+userId);
|
if(exprise <= 0){
|
exprise = 604800L;
|
}
|
redisCache.setCacheObject("SWX-CUSTOMER-VERTURAL-"+userId,infoVo,exprise,TimeUnit.SECONDS);
|
// //将订单信息加入缓存中
|
// Long orderExprise = redisCache.getExpire("SWX-CUSTOMER-VERTURAL-OPTIONS-"+userId);
|
// List<SwxOptionsOrder> list = new ArrayList<>();
|
// list.add(order);
|
// redisCache.setCacheList("SWX-CUSTOMER-VERTURAL-OPTIONS-"+userId,list);
|
// if (orderExprise <= 0){
|
// orderExprise = 604800L;
|
// }
|
// redisCache.expire("SWX-CUSTOMER-VERTURAL-OPTIONS-"+userId,orderExprise,TimeUnit.SECONDS);
|
swxOptionsOrderService.save(order);
|
String id = order.getId();
|
//推送给消息队列
|
Map<String,Object> messageMap = new HashMap<>();
|
messageMap.put("id",id);
|
messageMap.put("istrue",2);
|
messageMap.put("userId",userId);
|
Integer timeSeconds = vo.getLimitTime() * 1000;
|
rabbitTemplate.convertAndSend(DelayQueueRabbitConfig.ORDER_EXCHANGE, DelayQueueRabbitConfig.ORDER_ROUTING_KEY, messageMap, message->{
|
message.getMessageProperties().setExpiration(timeSeconds+"");
|
return message;
|
});
|
return id;
|
}
|
|
|
|
@Override
|
public IPage<SwxBuyOptionsInfo> listOptionsOrder(String userId, String virtually, Integer pageNo, Integer pageSize) throws CustomerException {
|
if (!SwxConstons.SWX_CUSTOMER_USER_ORDER_TYPE_TRUE.equals(virtually) && !SwxConstons.SWX_CUSTOMER_USER_ORDER_TYPE_VIRTRUAL.equals(virtually)){
|
throw new CustomerException("10008");
|
}
|
//获取用户信息
|
SwxUser swxUser = swxUserService.getById(userId);
|
if (swxUser == null){
|
throw new CustomerException("10009");
|
}
|
Page<SwxBuyOptionsInfo> result = new Page<>();
|
Page<SwxOptionsOrder> page = new Page<>(pageNo,pageSize);
|
QueryWrapper<SwxOptionsOrder> swxOptionsOrderQueryWrapper = new QueryWrapper<>();
|
swxOptionsOrderQueryWrapper.lambda().eq(SwxOptionsOrder::getUserId,userId);
|
swxOptionsOrderQueryWrapper.lambda().orderByDesc(SwxOptionsOrder::getCreateTime);
|
if (SwxConstons.SWX_CUSTOMER_USER_ORDER_TYPE_VIRTRUAL.equals(virtually)){
|
swxOptionsOrderQueryWrapper.lambda().eq(SwxOptionsOrder::getOrderType,2);
|
}else {
|
swxOptionsOrderQueryWrapper.lambda().eq(SwxOptionsOrder::getOrderType,1);
|
}
|
IPage<SwxOptionsOrder> pageList = swxOptionsOrderService.page(page,swxOptionsOrderQueryWrapper);
|
result.setTotal(pageList.getTotal());
|
List<SwxBuyOptionsInfo> records = new ArrayList<>();
|
for (SwxOptionsOrder item : pageList.getRecords()){
|
SwxBuyOptionsInfo info = new SwxBuyOptionsInfo();
|
BeanUtils.copyProperties(item,info);
|
if (item.getStatus() == 0){
|
info.setEndPrice(BigDecimal.ZERO);
|
info.setResultType(null);
|
}
|
records.add(info);
|
}
|
result.setRecords(records);
|
// if (SwxConstons.SWX_CUSTOMER_USER_ORDER_TYPE_VIRTRUAL.equals(virtually)){
|
//获取redis中缓存
|
// Integer size = redisCache.getCacheListSize("SWX-CUSTOMER-VERTURAL-OPTIONS-"+userId).intValue();
|
// result.setTotal(size);
|
// if (size > 0){
|
// Integer begin = (size - (pageNo * pageSize)) <= 0 ? 0 : (size - (pageNo * pageSize));
|
// Integer end =size - ((pageNo-1) * pageSize) - 1;
|
// List<SwxOptionsOrder> list = redisCache.getCacheList("SWX-CUSTOMER-VERTURAL-OPTIONS-"+userId,begin,end);
|
// List<SwxBuyOptionsInfo> records = new ArrayList<>();
|
// for (SwxOptionsOrder item : list){
|
// SwxBuyOptionsInfo info = new SwxBuyOptionsInfo();
|
// BeanUtils.copyProperties(item,info);
|
// if (item.getStatus() == 0){
|
// info.setEndPrice(BigDecimal.ZERO);
|
// info.setResultType(null);
|
// }
|
// records.add(info);
|
// }
|
// Collections.reverse(records);
|
// result.setRecords(records);
|
// }
|
//
|
// }else{
|
// Page<SwxOptionsOrder> page = new Page<>(pageNo,pageSize);
|
// QueryWrapper<SwxOptionsOrder> swxOptionsOrderQueryWrapper = new QueryWrapper<>();
|
// swxOptionsOrderQueryWrapper.lambda().eq(SwxOptionsOrder::getUserId,userId);
|
// swxOptionsOrderQueryWrapper.lambda().orderByDesc(SwxOptionsOrder::getCreateTime);
|
// IPage<SwxOptionsOrder> pageList = swxOptionsOrderService.page(page,swxOptionsOrderQueryWrapper);
|
// result.setTotal(pageList.getTotal());
|
// List<SwxBuyOptionsInfo> records = new ArrayList<>();
|
// for (SwxOptionsOrder item : pageList.getRecords()){
|
// SwxBuyOptionsInfo info = new SwxBuyOptionsInfo();
|
// BeanUtils.copyProperties(item,info);
|
// if (item.getStatus() == 0){
|
// info.setEndPrice(BigDecimal.ZERO);
|
// info.setResultType(null);
|
// }
|
// records.add(info);
|
// }
|
// result.setRecords(records);
|
// }
|
return result;
|
}
|
|
@Override
|
public SwxBuyOptionsInfo getOptionsOrderById(String userId, String virtually, String id) {
|
SwxOptionsOrder swxOptionsOrder = null;
|
if (SwxConstons.SWX_CUSTOMER_USER_ORDER_TYPE_VIRTRUAL.equals(virtually)){
|
List<SwxOptionsOrder> list = redisCache.getCacheList("SWX-CUSTOMER-VERTURAL-OPTIONS-"+userId);
|
for (SwxOptionsOrder item : list){
|
if (item.getId().equals(id)){
|
swxOptionsOrder = item ;
|
break;
|
}
|
}
|
}else{
|
swxOptionsOrder= swxOptionsOrderService.getById(id);
|
}
|
if (swxOptionsOrder != null){
|
SwxBuyOptionsInfo info = new SwxBuyOptionsInfo();
|
BeanUtils.copyProperties(swxOptionsOrder,info);
|
if (info.getStatus() == 0){
|
info.setEndPrice(BigDecimal.ZERO);
|
info.setResultType(null);
|
}
|
return info;
|
}
|
return null;
|
}
|
|
|
private BigDecimal getRandom(Integer randomMax){
|
Random random = new Random();
|
Double randomFloat = random.nextDouble() * 10;
|
return new BigDecimal(randomFloat).setScale(4, RoundingMode.HALF_UP);
|
}
|
|
private boolean checkWin(Integer persont){
|
Random random = new Random();
|
int randomNumber = random.nextInt(100);
|
return persont >= randomNumber;
|
}
|
|
/**
|
* 是否可交易时间
|
* @param tradeDateType 可交易日期类型
|
* @param tradeDate 可交易日期
|
* @param tradeTime 可交易时间
|
* @return
|
*/
|
private boolean getCanTradeTime(Integer tradeDateType,String tradeDate,String tradeTime){
|
logger.info("校验时间");
|
logger.info("tradeDateType"+tradeDateType);
|
logger.info("tradeDate"+tradeDate);
|
logger.info("tradeTime"+tradeTime);
|
Date date = new Date();
|
boolean canTradeDayFlag = false;
|
String[] cantrade = tradeDate.replace("[", "").replace("]", "").split(",");
|
String currentDay = "";
|
logger.info("data"+date);
|
if (tradeDateType == 1){
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); // 定义日期格式
|
currentDay = dateFormat.format(date).split("-")[2]; // 将日期转换为字
|
}else if(tradeDateType == 2){
|
// 周
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(date);
|
currentDay = calendar.get(Calendar.DAY_OF_WEEK)+"";
|
}else if(tradeDateType == 3){
|
//余额
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); // 定义日期格式
|
currentDay = dateFormat.format(date).split("-")[1]; // 将日期转换为字
|
}
|
logger.info("currentDay= "+currentDay);
|
for (String item : cantrade){
|
if (item.equals("\""+currentDay+"\"")){
|
canTradeDayFlag = true;
|
break;
|
}
|
}
|
if (canTradeDayFlag){
|
String[] canTradeTime = tradeTime.replace("[", "").replace("]", "").split(",");
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(date);
|
int hour = calendar.get(Calendar.HOUR_OF_DAY);
|
String hourStr =hour < 10 ? "\"0"+hour+"\"" : "\""+hour+"\"";
|
logger.info("hourStr= "+hourStr);
|
for (String item : canTradeTime){
|
if (item.equals(hourStr)){
|
return true;
|
}
|
}
|
}
|
return false;
|
}
|
|
|
}
|
