package com.nq.service.impl;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.nq.common.ServerResponse;
|
import com.nq.dao.*;
|
import com.nq.enums.EConfigKey;
|
import com.nq.enums.EUserAssets;
|
import com.nq.pojo.*;
|
import com.nq.service.*;
|
import com.nq.utils.KeyUtils;
|
import com.nq.utils.stock.GeneratePosition;
|
import com.nq.utils.timeutil.DateTimeUtil;
|
import com.nq.utils.PropertiesUtil;
|
import com.nq.utils.redis.JsonUtil;
|
import com.nq.utils.redis.RedisShardedPoolUtils;
|
import com.nq.utils.stock.sina.StockApi;
|
import com.nq.vo.foreigncurrency.ExchangeVO;
|
import com.nq.vo.position.UserPendingorderVO;
|
import com.nq.vo.stock.MarketVO;
|
import com.nq.vo.stock.StockListVO;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
/**
|
* @author Administrator
|
* @description 针对表【user_pendingorder】的数据库操作Service实现
|
* @createDate 2022-11-10 06:10:40
|
*/
|
@Service
|
@Slf4j
|
public class UserPendingorderServiceImpl extends ServiceImpl<UserPendingorderMapper, UserPendingorder>
|
implements UserPendingorderService {
|
@Autowired
|
private UserPendingorderMapper userPendingorderMapper;
|
@Autowired
|
private StockMapper stockMapper;
|
@Autowired
|
private IUserService iUserService;
|
@Autowired
|
private IUserAssetsServices iUserAssetsServices;
|
@Autowired
|
ISiteProductService iSiteProductService;
|
@Autowired
|
IStockConfigServices iStockConfigServices;
|
@Autowired
|
IPriceServices priceServices;
|
@Autowired
|
ITradingHourService tradingHourService;
|
@Override
|
public ServerResponse addOrder(Integer stockId, Integer buyNum, Integer buyType,
|
Integer lever, BigDecimal profitTarget,
|
BigDecimal stopTarget,String targetPrice, HttpServletRequest request) {
|
SiteProduct siteProduct = iSiteProductService.getProductSetting();
|
|
User user = this.iUserService.getCurrentRefreshUser(request);
|
synchronized (user.getId()){
|
if (siteProduct.getRealNameDisplay() && user.getIsActive() != 2) {
|
return ServerResponse.createByErrorMsg("订单失败，请先实名认证", request);
|
}
|
// 手续费率
|
BigDecimal siteSettingBuyFee = new BigDecimal(iStockConfigServices.queryByKey(EConfigKey.BUY_HANDLING_CHARGE.getCode()).getCValue()) ;
|
|
if (siteProduct.getRealNameDisplay() && user.getIsLock().intValue() == 1) {
|
return ServerResponse.createByErrorMsg("订单失败，帐户已被锁定", request);
|
}
|
|
Stock stock = stockMapper.selectByPrimaryKey(stockId);
|
if (stock == null) {
|
return ServerResponse.createByErrorMsg("订单失败，股票代码不存在", request);
|
}
|
//判断股票是否在可交易时间段
|
Boolean b = tradingHourService.timeCheck(stock.getStockCode());
|
if (!b) {
|
return ServerResponse.createByErrorMsg("订单失败,不在交易时间之内", request);
|
}
|
|
|
StockConfig mainBuyConfig = iStockConfigServices.queryByKey(EConfigKey.MIN_BUY.getCode());
|
|
if(buyNum<Integer.parseInt(mainBuyConfig.getCValue())){
|
return ServerResponse.createByErrorMsg("最低购买数量"+mainBuyConfig.getCValue(), request);
|
}
|
|
UserAssets userAssets = iUserAssetsServices.assetsByTypeAndUserId(stock.getStockType(), user.getId());
|
StockConfig maxBuyConfig = iStockConfigServices.queryByKey(EConfigKey.MAX_BUY.getCode());
|
if(buyNum<Integer.parseInt(mainBuyConfig.getCValue())){
|
return ServerResponse.createByErrorMsg("最高购买数量"+maxBuyConfig.getCValue(), request);
|
}
|
if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
|
return ServerResponse.createByErrorMsg("请先缴清待补资金", request);
|
}
|
if (stock.getIsLock() != 0) {
|
return ServerResponse.createByErrorMsg("订单失败,股票被锁定", request);
|
}
|
|
if (!priceServices.isLimitUpBuy(stock.getStockCode())) {
|
return ServerResponse.createByErrorMsg("暂无配额", request);
|
}
|
|
//股票类型 现价 数据源的处理
|
BigDecimal nowPrice = new BigDecimal(targetPrice);
|
|
if (nowPrice.compareTo(new BigDecimal("0")) == 0) {
|
return ServerResponse.createByErrorMsg("报价0，请稍后再试", request);
|
}
|
|
BigDecimal buyAmt = nowPrice.multiply(new BigDecimal(buyNum)).divide(new BigDecimal(lever));
|
BigDecimal orderFree = siteSettingBuyFee.multiply(buyAmt);
|
|
BigDecimal fundratio = new BigDecimal(user.getFundRatio()).divide(new BigDecimal(100));
|
BigDecimal availableBalance = fundratio.multiply(userAssets.getAvailableBalance());
|
if (availableBalance.compareTo(buyAmt.add(orderFree)) < 0) {
|
return ServerResponse.createByErrorMsg("订单失败，配资不足", request);
|
}
|
UserPendingorder userPendingorder = new UserPendingorder();
|
if (profitTarget != null && profitTarget.compareTo(new BigDecimal("0")) > 0) {
|
userPendingorder.setProfitTargetPrice(profitTarget);
|
}
|
if (stopTarget != null && stopTarget.compareTo(new BigDecimal("0")) > 0) {
|
userPendingorder.setStopTargetPrice(stopTarget);
|
}
|
userPendingorder.setPositionType(1);
|
userPendingorder.setHangingOrderType(1);
|
userPendingorder.setStockType(stock.getStockType());
|
userPendingorder.setPositionSn(KeyUtils.getUniqueKey());
|
userPendingorder.setUserId(user.getId());
|
userPendingorder.setNickName(user.getRealName());
|
userPendingorder.setAgentId(user.getAgentId());
|
userPendingorder.setStockCode(stock.getStockCode());
|
userPendingorder.setStockName(stock.getStockName());
|
userPendingorder.setStockGid(stock.getStockType());
|
userPendingorder.setStockSpell(stock.getStockSpell());
|
userPendingorder.setBuyOrderId(GeneratePosition.getPositionId());
|
userPendingorder.setBuyOrderTime(new Date());
|
userPendingorder.setBuyOrderPrice(nowPrice);
|
userPendingorder.setOrderDirection((buyType.intValue() == 0) ? "买涨" : "买跌");
|
userPendingorder.setOrderNum(buyNum);
|
if (stock.getStockPlate() != null) {
|
userPendingorder.setStockPlate(stock.getStockPlate());
|
}
|
userPendingorder.setIsLock(Integer.valueOf(0));
|
userPendingorder.setOrderLever(lever);
|
userPendingorder.setOrderTotalPrice(buyAmt);
|
// 手续费
|
|
userPendingorder.setOrderFee(orderFree);
|
userPendingorder.setOrderSpread(BigDecimal.ZERO);
|
userPendingorder.setSpreadRatePrice(BigDecimal.ZERO);
|
BigDecimal profit_and_lose = new BigDecimal("0");
|
userPendingorder.setProfitAndLose(profit_and_lose);
|
userPendingorder.setAllProfitAndLose(profit_and_lose.add(orderFree));
|
userPendingorder.setOrderStayDays(Integer.valueOf(0));
|
userPendingorder.setOrderStayFee(BigDecimal.ZERO);
|
userPendingorderMapper.insert(userPendingorder);
|
iUserAssetsServices.availablebalanceChange(stock.getStockType(), user.getId(), EUserAssets.BUY, buyAmt.negate(), "", "");
|
return ServerResponse.createBySuccessMsg("挂单成功", request);
|
}
|
}
|
|
@Override
|
public ServerResponse hjyyAddOrder(String name, Integer buyNum, Integer buyType, Integer lever, BigDecimal profitTarget, BigDecimal stopLoss, String targetPrice, HttpServletRequest request) {
|
SiteProduct siteProduct = iSiteProductService.getProductSetting();
|
|
User user = this.iUserService.getCurrentRefreshUser(request);
|
synchronized (user.getId()){
|
if (siteProduct.getRealNameDisplay() && user.getIsActive() != 2) {
|
return ServerResponse.createByErrorMsg("订单失败，请先实名认证", request);
|
}
|
// 手续费率
|
BigDecimal siteSettingBuyFee = new BigDecimal(iStockConfigServices.queryByKey(EConfigKey.BUY_HANDLING_CHARGE.getCode()).getCValue()) ;
|
|
if (siteProduct.getRealNameDisplay() && user.getIsLock().intValue() == 1) {
|
return ServerResponse.createByErrorMsg("订单失败，帐户已被锁定", request);
|
}
|
|
BigDecimal price = new BigDecimal(targetPrice);
|
|
UserAssets userAssets = iUserAssetsServices.assetsByTypeAndUserId("USD", user.getId());
|
|
if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
|
return ServerResponse.createByErrorMsg("挂单失败，请先缴清待补资金", request);
|
}
|
|
if (price.compareTo(new BigDecimal("0")) == 0) {
|
return ServerResponse.createByErrorMsg("报价0，请稍后再试", request);
|
}
|
|
BigDecimal buyAmt = price.multiply(new BigDecimal(buyNum)).divide(new BigDecimal(lever));
|
BigDecimal orderFree = siteSettingBuyFee.multiply(buyAmt);
|
|
BigDecimal fundratio = new BigDecimal(user.getFundRatio()).divide(new BigDecimal(100));
|
BigDecimal availableBalance = fundratio.multiply(userAssets.getAvailableBalance());
|
if (availableBalance.compareTo(buyAmt.add(orderFree)) < 0) {
|
return ServerResponse.createByErrorMsg("订单失败，配资不足", request);
|
}
|
UserPendingorder userPendingorder = new UserPendingorder();
|
userPendingorder.setPositionType(1);
|
userPendingorder.setHangingOrderType(1);
|
userPendingorder.setStockType("HJYY");
|
userPendingorder.setPositionSn(KeyUtils.getUniqueKey());
|
userPendingorder.setUserId(user.getId());
|
userPendingorder.setNickName(user.getRealName());
|
userPendingorder.setAgentId(user.getAgentId());
|
userPendingorder.setStockCode("HJYY");
|
userPendingorder.setStockName(name);
|
userPendingorder.setStockGid("HJYY");
|
userPendingorder.setStockSpell(name);
|
userPendingorder.setBuyOrderId(GeneratePosition.getPositionId());
|
userPendingorder.setBuyOrderTime(new Date());
|
userPendingorder.setBuyOrderPrice(price);
|
userPendingorder.setOrderDirection((buyType.intValue() == 0) ? "买涨" : "买跌");
|
userPendingorder.setOrderNum(buyNum);
|
userPendingorder.setIsLock(Integer.valueOf(0));
|
userPendingorder.setOrderLever(lever);
|
userPendingorder.setOrderTotalPrice(buyAmt);
|
// 手续费
|
userPendingorder.setOrderFee(orderFree);
|
userPendingorder.setOrderSpread(BigDecimal.ZERO);
|
userPendingorder.setSpreadRatePrice(BigDecimal.ZERO);
|
BigDecimal profit_and_lose = new BigDecimal("0");
|
userPendingorder.setProfitAndLose(profit_and_lose);
|
userPendingorder.setAllProfitAndLose(profit_and_lose.add(orderFree));
|
userPendingorder.setOrderStayDays(Integer.valueOf(0));
|
userPendingorder.setOrderStayFee(BigDecimal.ZERO);
|
userPendingorderMapper.insert(userPendingorder);
|
iUserAssetsServices.availablebalanceChange("USD", user.getId(), EUserAssets.BUY, buyAmt.negate(), "", "");
|
return ServerResponse.createBySuccessMsg("下单成功", request);
|
}
|
}
|
|
}
|
