package com.nq.service.impl;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
import cn.hutool.core.util.ObjectUtil;
|
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.pojo.*;
|
import com.nq.service.*;
|
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.PremarketStockVO;
|
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 IUserPositionService iUserPositionService;
|
@Autowired
|
private SiteTaskLogMapper siteTaskLogMapper;
|
@Autowired
|
private UserMapper userMapper;
|
@Autowired
|
private StockIndexMapper stockIndexMapper;
|
@Autowired
|
private IStockIndexService iStockIndexService;
|
@Autowired
|
private IUserIndexPositionService iUserIndexPositionService;
|
@Autowired
|
private IStockFuturesService iStockFuturesService;
|
@Autowired
|
private ISiteSettingService iSiteSettingService;
|
|
@Autowired
|
private IUserAssetsServices iUserAssetsServices;
|
|
@Autowired
|
private ISiteProductService iSiteProductService;
|
|
@Autowired
|
private IStockConfigServices iStockConfigServices;
|
|
@Autowired
|
private StockBuySettingMapper stockBuySettingMapper;
|
|
@Autowired
|
private ITradingHourService tradingHourService;
|
|
@Autowired
|
private IPriceServices priceServices;
|
|
@Autowired
|
private UserPositionMapper userPositionMapper;
|
|
@Autowired
|
IStockService iStockService;
|
|
@Override
|
@org.springframework.transaction.annotation.Transactional(rollbackFor = Exception.class)
|
public ServerResponse addOrder(String stockId, Integer buyNum, Integer buyType, Integer lever, BigDecimal profitTarget, BigDecimal stopTarget, BigDecimal targetPrice, HttpServletRequest request) {
|
User user = this.iUserService.getCurrentRefreshUser(request);
|
|
if (user == null) {
|
return ServerResponse.createByErrorMsg("请先登录", request);
|
}
|
|
try {
|
synchronized (user.getId()) {
|
// 获取系统设置
|
SiteProduct siteProduct = iSiteProductService.getProductSetting();
|
if (siteProduct.getRealNameDisplay() && user.getIsActive() != 2) {
|
return ServerResponse.createByErrorMsg("挂单失败，请先实名认证", request);
|
}
|
|
if (siteProduct.getRealNameDisplay() && user.getIsLock().intValue() == 1) {
|
return ServerResponse.createByErrorMsg("挂单失败，帐户已被锁定", request);
|
}
|
|
// 验证目标价格
|
if (targetPrice == null || targetPrice.compareTo(BigDecimal.ZERO) <= 0) {
|
return ServerResponse.createByErrorMsg("挂单失败，目标价格必须大于0", request);
|
}
|
|
// 获取股票信息
|
Stock stock = stockMapper.findStockByCode(stockId);
|
if (stock == null) {
|
return ServerResponse.createByErrorMsg("挂单失败，股票代码不存在", request);
|
}
|
|
// 判断股票是否被锁定
|
if (stock.getIsLock() != 0) {
|
return ServerResponse.createByErrorMsg("挂单失败，股票被锁定", request);
|
}
|
|
// 手续费率
|
BigDecimal siteSettingBuyFee = new BigDecimal(iStockConfigServices.queryByKey(com.nq.enums.EConfigKey.BUY_HANDLING_CHARGE.getCode()).getCValue());
|
|
// 处理购买数量（手数转换）
|
StockBuySetting stockBuySetting = stockBuySettingMapper.selectOne(new QueryWrapper<com.nq.pojo.StockBuySetting>().eq("accets_type", stock.getStockType()));
|
if (stockBuySetting != null && stockBuySetting.getHandsNum() != null && stockBuySetting.getStockNum() != null) {
|
if (buyNum < stockBuySetting.getHandsNum()) {
|
return ServerResponse.createByErrorMsg("最低购买手数" + stockBuySetting.getHandsNum(), request);
|
}
|
buyNum = buyNum * stockBuySetting.getStockNum();
|
}
|
|
// 获取用户资产
|
UserAssets userAssets = iUserAssetsServices.assetsByTypeAndUserId(stock.getStockType(), user.getId());
|
|
// 验证最高购买数量
|
com.nq.pojo.StockConfig maxBuyConfig = iStockConfigServices.queryByKey(com.nq.enums.EConfigKey.MAX_BUY.getCode());
|
if (buyNum > Integer.parseInt(maxBuyConfig.getCValue())) {
|
return ServerResponse.createByErrorMsg("最高购买数量" + maxBuyConfig.getCValue(), request);
|
}
|
|
// 检查待补资金
|
if (userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0) {
|
return ServerResponse.createByErrorMsg("请先缴清待补资金", request);
|
}
|
|
// 使用目标价格计算需要冻结的金额
|
BigDecimal buyAmt = targetPrice.multiply(new BigDecimal(buyNum)).divide(new BigDecimal(lever), 4, RoundingMode.HALF_UP);
|
// 手续费
|
BigDecimal orderFree = siteSettingBuyFee.multiply(buyAmt);
|
BigDecimal needFreezeAmt = buyAmt.add(orderFree);
|
|
// 资金校验（考虑配资比例）
|
BigDecimal fundratio = new BigDecimal(user.getFundRatio()).divide(new BigDecimal(100));
|
BigDecimal availableBalance = fundratio.multiply(userAssets.getAvailableBalance());
|
if (availableBalance.compareTo(needFreezeAmt) < 0) {
|
return ServerResponse.createByErrorMsg("挂单失败，配资不足", request);
|
}
|
|
// 检查是否已有相同股票的挂单
|
UserPendingorder existingOrder = userPendingorderMapper.selectOne(new QueryWrapper<UserPendingorder>()
|
.eq("user_id", user.getId())
|
.eq("stock_id", stockId)
|
.eq("status", 0));
|
if (existingOrder != null) {
|
return ServerResponse.createByErrorMsg("该股票已有挂单，请勿重复挂单", request);
|
}
|
|
// 创建挂单记录
|
UserPendingorder userPendingorder = new UserPendingorder();
|
userPendingorder.setUserId(user.getId());
|
userPendingorder.setStockId(stockId);
|
userPendingorder.setBuyNum(buyNum);
|
userPendingorder.setBuyType(buyType);
|
userPendingorder.setLever(lever);
|
userPendingorder.setProfitTarget(profitTarget);
|
userPendingorder.setStopTarget(stopTarget);
|
userPendingorder.setNowPrice(new BigDecimal(0));
|
userPendingorder.setTargetPrice(targetPrice);
|
userPendingorder.setAddTime(new Date());
|
userPendingorder.setStatus(0);
|
|
int ret = userPendingorderMapper.insert(userPendingorder);
|
if (ret > 0) {
|
// 冻结资金
|
iUserAssetsServices.availablebalanceChange(stock.getStockType(), user.getId(),
|
com.nq.enums.EUserAssets.PENDING_ORDER_FREEZE, needFreezeAmt.negate(), "挂单冻结资金", "");
|
return ServerResponse.createBySuccessMsg("挂单成功，资金已冻结", request);
|
}
|
return ServerResponse.createByErrorMsg("挂单失败", request);
|
}
|
} catch (Exception e) {
|
log.error("挂单异常：{}", e.getMessage(), e);
|
return ServerResponse.createByErrorMsg("挂单异常：" + e.getMessage(), request);
|
}
|
}
|
|
@Override
|
public ServerResponse orderList(HttpServletRequest request) {
|
|
String property = PropertiesUtil.getProperty("user.cookie.name");
|
String header = request.getHeader(property);
|
// log.info("header:{}",header);
|
if (header != null) {
|
String userJson = RedisShardedPoolUtils.get(header);
|
User user = (User) JsonUtil.string2Obj(userJson, User.class);
|
// log.info("user:{}",user);
|
if (user != null) {
|
List<UserPendingorder> userPendingorders = userPendingorderMapper.selectList(new QueryWrapper<UserPendingorder>().eq("user_id", user.getId()).eq("status",0));
|
|
List UserPendingorderList = new ArrayList();
|
|
|
for (UserPendingorder userPendingorder : userPendingorders) {
|
UserPendingorderVO userPendingorderVO = new UserPendingorderVO();
|
//挂单-指数
|
//挂单-股票
|
Stock stock = stockMapper.findStockByCode(userPendingorder.getStockId());
|
StockListVO stockListVO = new StockListVO();
|
stockListVO = StockApi.getStockRealTime(
|
stock);
|
String nowPrice = stockListVO.getNowPrice();
|
if (nowPrice == null) {
|
nowPrice = String.valueOf(0);
|
}
|
userPendingorderVO.setNowPrice(new BigDecimal(nowPrice));
|
userPendingorderVO.setStockName(stock.getStockName());
|
userPendingorderVO.setStockGid(stock.getStockType());
|
userPendingorderVO.setStockId(stock.getStockCode());
|
userPendingorderVO.setBuyNum(userPendingorder.getBuyNum());
|
userPendingorderVO.setBuyType(userPendingorder.getBuyType());
|
userPendingorderVO.setLever(userPendingorder.getLever());
|
userPendingorderVO.setProfitTarget(userPendingorder.getProfitTarget());
|
userPendingorderVO.setStopTarget(userPendingorder.getStopTarget());
|
userPendingorderVO.setTargetPrice(userPendingorder.getTargetPrice());
|
userPendingorderVO.setAddTime(userPendingorder.getAddTime());
|
userPendingorderVO.setStatus(userPendingorder.getStatus());
|
userPendingorderVO.setId(userPendingorder.getId());
|
UserPendingorderList.add(userPendingorderVO);
|
}
|
return ServerResponse.createBySuccess(UserPendingorderList);
|
}
|
}
|
return ServerResponse.createByErrorMsg("数据异常");
|
|
}
|
|
@Override
|
public void orderTask() {
|
// 查询所有待处理的挂单
|
List<UserPendingorder> userPendingorders = userPendingorderMapper.selectList(new QueryWrapper<UserPendingorder>().eq("status", 0));
|
log.info("当前有挂单数量：{}", userPendingorders.size());
|
|
|
|
List<PremarketStockVO> premarketStock = iStockService.getPremarketStock();
|
|
Map<String, PremarketStockVO> stockMap = premarketStock.stream()
|
.collect(Collectors.toMap(
|
PremarketStockVO::getCode,
|
stock -> stock
|
));
|
|
|
orderLoop: for (UserPendingorder userPendingorder : userPendingorders) {
|
try {
|
// 参数校验
|
if (userPendingorder.getUserId() == null || userPendingorder.getStockId() == null
|
|| userPendingorder.getBuyNum() == null || userPendingorder.getBuyType() == null
|
|| userPendingorder.getLever() == null || userPendingorder.getTargetPrice() == null) {
|
continue;
|
}
|
|
// 获取股票信息
|
Stock stock = stockMapper.findStockByCode(userPendingorder.getStockId());
|
if (stock == null) {
|
log.error("挂单转持仓失败，股票不存在：{}", userPendingorder.getStockId());
|
userPendingorder.setStatus(2);
|
this.userPendingorderMapper.updateById(userPendingorder);
|
continue;
|
}
|
PremarketStockVO p = stockMap.get(stock.getStockCode());
|
// 获取当前价格
|
BigDecimal nowPrice = priceServices.getNowPrice(stock.getStockCode());
|
if(ObjectUtil.isEmpty(p)){
|
|
if (nowPrice.compareTo(BigDecimal.ZERO) == 0) {
|
continue;
|
}
|
|
// 判断价格是否达到目标价格：当前价格 <= 挂单价就买入
|
if (nowPrice.compareTo(userPendingorder.getTargetPrice()) > 0) {
|
// 当前价格大于挂单价，继续等待
|
continue;
|
}
|
|
// 价格达到目标价格，先进行验证
|
// 判断股票是否在可交易时间段
|
Boolean b = tradingHourService.timeCheck(stock.getStockCode(), stock.getStockType());
|
if (!b) {
|
continue;
|
}
|
}else{
|
// 判断价格是否达到目标价格：当前价格 <= 挂单价就买入
|
if (p.getPrice().compareTo(userPendingorder.getTargetPrice()) > 0) {
|
// 当前价格大于挂单价，继续等待
|
continue;
|
}
|
nowPrice = p.getPrice();
|
}
|
|
|
// 检查股票是否被锁定
|
if (stock.getIsLock() != 0) {
|
log.info("挂单转持仓失败，股票被锁定：{}", stock.getStockCode());
|
userPendingorder.setStatus(2);
|
this.userPendingorderMapper.updateById(userPendingorder);
|
continue;
|
}
|
|
// 检查是否有配额
|
if (!priceServices.isLimitUpBuy(stock.getStockCode())) {
|
continue;
|
}
|
|
// 获取用户信息
|
User user = this.userMapper.selectById(userPendingorder.getUserId());
|
if (user == null) {
|
continue;
|
}
|
|
// 执行买入逻辑（在 synchronized 块内）
|
synchronized (userPendingorder.getUserId()) {
|
// 再次检查挂单状态，防止并发处理
|
UserPendingorder checkOrder = userPendingorderMapper.selectById(userPendingorder.getId());
|
if (checkOrder == null || checkOrder.getStatus() != 0) {
|
// 挂单已被处理，跳过本次循环
|
continue orderLoop;
|
}
|
|
// 手续费率
|
BigDecimal siteSettingBuyFee = new BigDecimal(iStockConfigServices.queryByKey(com.nq.enums.EConfigKey.BUY_HANDLING_CHARGE.getCode()).getCValue());
|
|
// 计算买入金额和手续费（使用当前价格）
|
BigDecimal buyAmt = nowPrice.multiply(new BigDecimal(userPendingorder.getBuyNum())).divide(new BigDecimal(userPendingorder.getLever()), 4, RoundingMode.HALF_UP);
|
BigDecimal orderFree = siteSettingBuyFee.multiply(buyAmt);
|
|
// 计算挂单时冻结的金额（用于解冻）
|
BigDecimal targetBuyAmt = userPendingorder.getTargetPrice().multiply(new BigDecimal(userPendingorder.getBuyNum())).divide(new BigDecimal(userPendingorder.getLever()), 4, RoundingMode.HALF_UP);
|
BigDecimal targetOrderFree = siteSettingBuyFee.multiply(targetBuyAmt);
|
BigDecimal freezeAmt = targetBuyAmt.add(targetOrderFree);
|
|
// 先解冻挂单冻结的资金
|
iUserAssetsServices.availablebalanceChange(stock.getStockType(), userPendingorder.getUserId(),
|
com.nq.enums.EUserAssets.PENDING_ORDER_UNFREEZE, freezeAmt, "挂单触发解冻资金", "");
|
|
// 创建 UserPosition，与 buy.do 逻辑完全一致
|
UserPosition userPosition = new UserPosition();
|
if (userPendingorder.getProfitTarget() != null && userPendingorder.getProfitTarget().compareTo(BigDecimal.ZERO) > 0) {
|
userPosition.setProfitTargetPrice(userPendingorder.getProfitTarget());
|
}
|
if (userPendingorder.getStopTarget() != null && userPendingorder.getStopTarget().compareTo(BigDecimal.ZERO) > 0) {
|
userPosition.setStopTargetPrice(userPendingorder.getStopTarget());
|
}
|
userPosition.setPositionType(user.getAccountType());
|
userPosition.setPositionSn(com.nq.utils.KeyUtils.getUniqueKey());
|
userPosition.setUserId(userPendingorder.getUserId());
|
userPosition.setNickName(user.getRealName());
|
userPosition.setAgentId(user.getAgentId());
|
userPosition.setStockCode(stock.getStockCode());
|
userPosition.setStockName(stock.getStockName());
|
userPosition.setStockGid(stock.getStockType());
|
userPosition.setStockSpell(stock.getStockSpell());
|
userPosition.setBuyOrderId(com.nq.utils.stock.GeneratePosition.getPositionId());
|
userPosition.setBuyOrderTime(new Date());
|
userPosition.setBuyOrderPrice(nowPrice);
|
userPosition.setOrderDirection((userPendingorder.getBuyType().intValue() == 0) ? "买涨" : "买跌");
|
userPosition.setOrderNum(userPendingorder.getBuyNum());
|
if (stock.getStockPlate() != null) {
|
userPosition.setStockPlate(stock.getStockPlate());
|
}
|
userPosition.setIsLock(Integer.valueOf(0));
|
userPosition.setOrderLever(userPendingorder.getLever());
|
userPosition.setOrderTotalPrice(buyAmt);
|
userPosition.setOrderFee(orderFree);
|
userPosition.setOrderSpread(BigDecimal.ZERO);
|
userPosition.setSpreadRatePrice(BigDecimal.ZERO);
|
BigDecimal profit_and_lose = new BigDecimal("0");
|
userPosition.setProfitAndLose(profit_and_lose);
|
userPosition.setAllProfitAndLose(profit_and_lose.add(orderFree));
|
userPosition.setOrderStayDays(Integer.valueOf(0));
|
userPosition.setOrderStayFee(BigDecimal.ZERO);
|
|
// 插入持仓记录
|
userPositionMapper.insert(userPosition);
|
|
// 扣款和手续费，与 buy.do 完全一致
|
iUserAssetsServices.availablebalanceChange(stock.getStockType(), userPendingorder.getUserId(),
|
com.nq.enums.EUserAssets.BUY, buyAmt.negate(), "", "");
|
iUserAssetsServices.availablebalanceChange(stock.getStockType(), userPendingorder.getUserId(),
|
com.nq.enums.EUserAssets.HANDLING_CHARGE, orderFree, "", "");
|
|
// 更新挂单状态
|
userPendingorder.setStatus(1);
|
this.userPendingorderMapper.updateById(userPendingorder);
|
|
log.info("挂单转持仓成功，挂单id：{}，股票：{}", userPendingorder.getId(), stock.getStockCode());
|
}
|
} catch (Exception e) {
|
log.error("挂单转持仓失败，挂单id：{}", userPendingorder.getId(), e);
|
userPendingorder.setStatus(2);
|
this.userPendingorderMapper.updateById(userPendingorder);
|
}
|
}
|
log.info("===========挂单任务结束==========");
|
}
|
|
//删除
|
@Override
|
@org.springframework.transaction.annotation.Transactional(rollbackFor = Exception.class)
|
public ServerResponse delOrder(Integer id, HttpServletRequest request) {
|
User user = this.iUserService.getCurrentRefreshUser(request);
|
if (user == null) {
|
return ServerResponse.createByErrorMsg("请先登录", request);
|
}
|
|
try {
|
UserPendingorder userPendingorder = this.userPendingorderMapper.selectById(id);
|
if (userPendingorder == null) {
|
return ServerResponse.createByErrorMsg("挂单不存在", request);
|
}
|
|
if (user.getId().intValue() != userPendingorder.getUserId().intValue()) {
|
return ServerResponse.createByErrorMsg("该挂单不属于您", request);
|
}
|
|
// 检查挂单状态，只有待处理的挂单才能取消
|
if (userPendingorder.getStatus() != 0) {
|
return ServerResponse.createByErrorMsg("该挂单已处理，无法取消", request);
|
}
|
|
// 获取股票信息以确定资产类型
|
Stock stock = stockMapper.findStockByCode(userPendingorder.getStockId());
|
if (stock == null) {
|
return ServerResponse.createByErrorMsg("股票不存在", request);
|
}
|
|
// 计算需要解冻的金额（根据挂单参数重新计算）
|
BigDecimal siteSettingBuyFee = new BigDecimal(iStockConfigServices.queryByKey(com.nq.enums.EConfigKey.BUY_HANDLING_CHARGE.getCode()).getCValue());
|
BigDecimal buyAmt = userPendingorder.getTargetPrice().multiply(new BigDecimal(userPendingorder.getBuyNum())).divide(new BigDecimal(userPendingorder.getLever()), 4, RoundingMode.HALF_UP);
|
BigDecimal orderFree = siteSettingBuyFee.multiply(buyAmt);
|
BigDecimal needUnfreezeAmt = buyAmt.add(orderFree);
|
|
// 解冻资金
|
iUserAssetsServices.availablebalanceChange(stock.getStockType(), user.getId(),
|
com.nq.enums.EUserAssets.PENDING_ORDER_UNFREEZE, needUnfreezeAmt, "取消挂单解冻资金", "");
|
|
// 删除挂单记录
|
int delCount = this.userPendingorderMapper.deleteById(id);
|
if (delCount > 0) {
|
return ServerResponse.createBySuccessMsg("取消挂单成功，资金已解冻", request);
|
}
|
return ServerResponse.createByErrorMsg("取消挂单失败", request);
|
} catch (Exception e) {
|
log.error("取消挂单异常：{}", e.getMessage(), e);
|
return ServerResponse.createByErrorMsg("取消挂单异常：" + e.getMessage(), request);
|
}
|
}
|
|
|
@Override
|
public ServerResponse orderListByAdmin(int pageNum, int pageSize, String keywords, String status, HttpServletRequest request) {
|
PageHelper.startPage(pageNum, pageSize);
|
QueryWrapper<UserPendingorder> queryWrapper = new QueryWrapper();
|
if (keywords != null && !keywords.equals("")) {
|
queryWrapper.like("stock_id", keywords).or().like("user_id", keywords);
|
}
|
if (status != null && !status.equals("")) {
|
queryWrapper.eq("status", status);
|
}
|
queryWrapper.orderByDesc("id");
|
List<UserPendingorder> stockSubscribeList = this.userPendingorderMapper.selectList(queryWrapper);
|
List UserPendingorderList = new ArrayList();
|
for (UserPendingorder userPendingorder : stockSubscribeList) {
|
UserPendingorderVO userPendingorderVO = new UserPendingorderVO();
|
//挂单-指数
|
if (userPendingorder.getStockId().contains("sh") || userPendingorder.getStockId().contains("sz") || userPendingorder.getStockId().contains("hk") || userPendingorder.getStockId().contains("us")) {
|
StockIndex model = stockIndexMapper.selectIndexByCode(userPendingorder.getStockId().replace("sh", "").replace("sz", "").replace("hk", "").replace("us", ""));
|
|
MarketVO marketVO = this.iStockIndexService.querySingleIndex(model.getIndexGid());
|
userPendingorderVO.setNowPrice(new BigDecimal(marketVO.getNowPrice()));
|
userPendingorderVO.setStockName(model.getIndexName());
|
userPendingorderVO.setStockId(model.getIndexGid());
|
|
} else {
|
//挂单-股票
|
Stock stock = stockMapper.findStockByCode(userPendingorder.getStockId());
|
StockListVO stockListVO = new StockListVO();
|
if (stock.getStockType().equals("hk")) {
|
String hk = RedisShardedPoolUtils.get(stock.getStockGid(), 1);
|
stockListVO = StockApi.otherStockListVO(hk);
|
} else if (stock.getStockType().equals("us")) {
|
String us = RedisShardedPoolUtils.get(stock.getStockGid(), 2);
|
stockListVO = StockApi.otherStockListVO(us);
|
} else {
|
stockListVO = StockApi.getStockRealTime(
|
stock);
|
}
|
String nowPrice = stockListVO.getNowPrice();
|
if (nowPrice == null) {
|
nowPrice = String.valueOf(0);
|
}
|
userPendingorderVO.setNowPrice(new BigDecimal(nowPrice));
|
userPendingorderVO.setStockName(stock.getStockName());
|
userPendingorderVO.setStockId(stock.getStockCode());
|
}
|
userPendingorderVO.setBuyNum(userPendingorder.getBuyNum());
|
userPendingorderVO.setBuyType(userPendingorder.getBuyType());
|
userPendingorderVO.setLever(userPendingorder.getLever());
|
userPendingorderVO.setProfitTarget(userPendingorder.getProfitTarget());
|
userPendingorderVO.setStopTarget(userPendingorder.getStopTarget());
|
userPendingorderVO.setTargetPrice(userPendingorder.getTargetPrice());
|
userPendingorderVO.setAddTime(userPendingorder.getAddTime());
|
userPendingorderVO.setStatus(userPendingorder.getStatus());
|
userPendingorderVO.setId(userPendingorder.getId());
|
UserPendingorderList.add(userPendingorderVO);
|
}
|
PageInfo pageInfo = new PageInfo(stockSubscribeList);
|
pageInfo.setList(UserPendingorderList);
|
return ServerResponse.createBySuccess(pageInfo);
|
}
|
|
@Override
|
public ServerResponse updateOrderByAdmin(UserPendingorder userPendingorder) {
|
if (userPendingorder.getId() == null) {
|
return ServerResponse.createByErrorMsg("id不能为空");
|
}
|
int updateCount = this.userPendingorderMapper.updateById(userPendingorder);
|
if (updateCount > 0) {
|
return ServerResponse.createBySuccessMsg("修改成功");
|
}
|
return ServerResponse.createByErrorMsg("修改失败");
|
|
}
|
|
@Override
|
public ServerResponse addOrderByAdmin(String phone, String buyNum, String code, String buyType, String lever, String targetPrice, HttpServletRequest request) {
|
if (StringUtils.isBlank(phone) || StringUtils.isBlank(buyNum) || StringUtils.isBlank(buyType) || StringUtils.isBlank(lever) || StringUtils.isBlank(targetPrice)) {
|
return ServerResponse.createByErrorMsg("参数不能为空");
|
}
|
|
User user = this.userMapper.selectOne(new QueryWrapper<User>().eq("phone", phone));
|
if (user == null) {
|
return ServerResponse.createByErrorMsg("用户不存在");
|
}
|
Stock stock = stockMapper.findStockByCode(code);
|
if (stock == null) {
|
return ServerResponse.createByErrorMsg("股票不存在");
|
}
|
UserPendingorder userPendingorder = new UserPendingorder();
|
userPendingorder.setUserId(user.getId());
|
userPendingorder.setStockId(code);
|
userPendingorder.setBuyNum(Integer.valueOf(buyNum));
|
userPendingorder.setBuyType(Integer.valueOf(buyType));
|
userPendingorder.setLever(Integer.valueOf(lever));
|
userPendingorder.setTargetPrice(new BigDecimal(targetPrice));
|
userPendingorder.setAddTime(new Date());
|
userPendingorder.setStatus(0);
|
userPendingorder.setNowPrice(new BigDecimal(0));
|
int insert = this.userPendingorderMapper.insert(userPendingorder);
|
if (insert > 0) {
|
return ServerResponse.createBySuccessMsg("添加成功");
|
}
|
return ServerResponse.createByErrorMsg("添加失败");
|
|
}
|
|
@Override
|
public ServerResponse delOrderByAdmin(Integer id) {
|
if (id == null) {
|
return ServerResponse.createByErrorMsg("id不能为空");
|
}
|
int delete = this.userPendingorderMapper.deleteById(id);
|
if (delete > 0) {
|
return ServerResponse.createBySuccessMsg("删除成功");
|
}
|
return ServerResponse.createByErrorMsg("删除失败");
|
}
|
}
|
