package com.yami.trading.service.ipo.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.yami.trading.bean.data.domain.Realtime;
|
import com.yami.trading.bean.exchange.ExchangeApplyOrder;
|
import com.yami.trading.bean.ipo.ApplyNewSharesOrder;
|
import com.yami.trading.bean.ipo.NewSharesConfig;
|
import com.yami.trading.bean.ipo.dto.SumSpotStockDto;
|
import com.yami.trading.bean.model.User;
|
import com.yami.trading.bean.syspara.domain.Syspara;
|
import com.yami.trading.common.exception.BusinessException;
|
import com.yami.trading.common.exception.YamiShopBindException;
|
import com.yami.trading.common.util.DateUtil;
|
import com.yami.trading.common.util.RandomUtil;
|
import com.yami.trading.dao.ipo.ApplyNewSharesOrderSharesMapper;
|
import com.yami.trading.service.WalletService;
|
import com.yami.trading.service.data.DataService;
|
import com.yami.trading.service.data.RealtimeService;
|
import com.yami.trading.service.exchange.ExchangeApplyOrderService;
|
import com.yami.trading.service.ipo.ApplyNewSharesOrderService;
|
import com.yami.trading.service.ipo.NewSharesConfigService;
|
import com.yami.trading.service.syspara.SysparaService;
|
import com.yami.trading.service.user.UserService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.Arrays;
|
import java.util.List;
|
|
@Service
|
public class ApplyNewSharesOrderServiceImpl extends ServiceImpl<ApplyNewSharesOrderSharesMapper, ApplyNewSharesOrder> implements ApplyNewSharesOrderService {
|
|
@Autowired
|
NewSharesConfigService newSharesConfigService;
|
|
|
@Autowired
|
RealtimeService realtimeService;
|
|
@Autowired
|
ExchangeApplyOrderService exchangeApplyOrderService;
|
|
@Autowired
|
DataService dataService;
|
|
|
@Autowired
|
SysparaService sysparaService;
|
|
@Autowired
|
UserService userService;
|
|
|
@Autowired
|
WalletService walletService;
|
|
|
|
@Override
|
@Transactional
|
public void apply(BigDecimal amount, String userId,String code) {
|
NewSharesConfig newSharesConfig= newSharesConfigService.getByProductCode(code);
|
if (newSharesConfig==null){
|
throw new BusinessException("新股不存在或未发布");
|
}
|
newSharesConfig.setAppliedSubscribeNumber(amount.add(new BigDecimal(newSharesConfig.getAppliedSubscribeNumber())).intValue());
|
if (newSharesConfig.getAppliedSubscribeNumber()<=0){
|
throw new BusinessException("股票数申购数不足!");
|
}
|
|
if (amount.doubleValue()>newSharesConfig.getDefaultLimit().doubleValue()){
|
throw new BusinessException("股票数抽签数大于限购数!");
|
}
|
if (newSharesConfig.getAppliedSubscribeNumber()>newSharesConfig.getSubscribeTotalNumber()){
|
throw new BusinessException("抽签数量大于总抽签股数");
|
}
|
List<ApplyNewSharesOrder> applyNewSharesOrders= findByProductCodeAndUserId(newSharesConfig.getProductCode(),userId);
|
if (CollectionUtil.isNotEmpty(applyNewSharesOrders)){
|
throw new BusinessException("已经有申购订单在申购中,请勿重复申请");
|
}
|
newSharesConfigService.updateById(newSharesConfig);
|
ApplyNewSharesOrder applyNewSharesOrder=new ApplyNewSharesOrder();
|
applyNewSharesOrder.setSubNumber(amount);
|
applyNewSharesOrder.setRequiredSubscribe(amount.multiply(newSharesConfig.getUnderwritingPrice()));
|
applyNewSharesOrder.setSymbolName(newSharesConfig.getName());
|
applyNewSharesOrder.setSymbolCode(newSharesConfig.getProductCode());
|
applyNewSharesOrder.setSubPrice(newSharesConfig.getUnderwritingPrice());
|
applyNewSharesOrder.setUserId(userId);
|
applyNewSharesOrder.setStatus(1);
|
applyNewSharesOrder.setOrderNo(DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
|
save(applyNewSharesOrder);
|
}
|
|
public List<ApplyNewSharesOrder> findByProductCodeAndUserId(String productCode, String userId){
|
|
|
return list(Wrappers.<ApplyNewSharesOrder>query().lambda().eq(ApplyNewSharesOrder::getSymbolCode,productCode).
|
eq(ApplyNewSharesOrder::getUserId,userId).eq(ApplyNewSharesOrder::getStatus,1));
|
|
}
|
|
@Override
|
public List<ApplyNewSharesOrder> findByOrderNo(List<String> orderNo) {
|
return list(Wrappers.<ApplyNewSharesOrder>query().lambda().in(ApplyNewSharesOrder::getOrderNo,orderNo));}
|
|
@Override
|
public Page pageData(Page page, String orderNo, String symbolCode, String symbolName, String userName, int status , List<String> children) {
|
return baseMapper.pageData(page,orderNo,symbolCode,symbolName,userName,status , children);
|
}
|
|
@Override
|
public ApplyNewSharesOrder findByOrderNo(String orderNo) {
|
return getOne(Wrappers.<ApplyNewSharesOrder>query().lambda().eq(ApplyNewSharesOrder::getOrderNo,orderNo));
|
}
|
|
@Override
|
public List<SumSpotStockDto> sumSpotStock(String userId) {
|
|
return baseMapper.sumSpotStock(userId);
|
}
|
|
@Override
|
public BigDecimal sumWinningNumberByUserId(String userId,String symbolCode) {
|
BigDecimal sumWinningNumber= baseMapper.sumWinningNumberByUserId(userId,symbolCode);
|
if (sumWinningNumber==null){
|
sumWinningNumber=new BigDecimal(0);
|
}
|
return sumWinningNumber;
|
}
|
|
@Transactional
|
public void sell(String orderNo, String userId) {
|
ApplyNewSharesOrder applyNewSharesOrder= findByOrderNo(orderNo);
|
if (applyNewSharesOrder==null){
|
throw new YamiShopBindException("现股不存在");
|
}
|
if (applyNewSharesOrder.getStatus()!=2){
|
throw new YamiShopBindException("现股未中签");
|
}
|
applyNewSharesOrder.setSell(1);
|
updateById(applyNewSharesOrder);
|
// List<UserPromiseRecord> list= userPromiseRecordService.findByOrderNo(applyNewSharesOrder.getOrderNo());
|
// for (UserPromiseRecord userPromiseRecord:list){
|
// userPromiseRecord.setShow(0);
|
// }
|
// userPromiseRecordService.updateBatchById(list);
|
// 委托数量
|
String volume = applyNewSharesOrder.getWinningNumber().doubleValue()+"";
|
String symbol = applyNewSharesOrder.getSymbolCode();
|
String partyId =userId;
|
User party = userService.getById(partyId);
|
if (!party.isEnabled()) {
|
throw new YamiShopBindException("用户已禁用");
|
}
|
Syspara syspara = sysparaService.find("stop_user_internet");
|
String stopUserInternet = syspara.getSvalue();
|
if(org.apache.commons.lang3.StringUtils.isNotEmpty(stopUserInternet)) {
|
String[] stopUsers = stopUserInternet.split(",");
|
if(Arrays.asList(stopUsers).contains(party.getUserName())){
|
throw new YamiShopBindException("无网络");
|
}
|
}
|
List<Realtime> realtimes = dataService.realtime(symbol);
|
double close = 1;
|
if (CollectionUtil.isNotEmpty(realtimes)) {
|
close = realtimes.get(0).getClose();
|
} else {
|
throw new YamiShopBindException("行情数据，获取失败!");
|
}
|
ExchangeApplyOrder order = new ExchangeApplyOrder();
|
order.setPartyId(partyId);
|
order.setSymbol(symbol);
|
order.setOffset(ExchangeApplyOrder.OFFSET_CLOSE);
|
order.setVolume(Double.valueOf(volume));
|
order.setPrice(close);
|
order.setOrderPriceType("opponent");
|
order.setClosePrice(close);
|
// 限价单 && limit order的交易价格 为空
|
if ("limit".equals(order.getOrderPriceType()) && order.getPrice() == null) {
|
order.setPrice(close);
|
}
|
// 该方法已经修改成闪兑用了 币币交易联系卡尔
|
// exchangeApplyOrderService.saveCreate(order);
|
}
|
|
@Override
|
public List<ApplyNewSharesOrder> findByStatus(String productCode,int status) {
|
return list(Wrappers.<ApplyNewSharesOrder>query().lambda().eq(ApplyNewSharesOrder::getSymbolCode,productCode).eq(ApplyNewSharesOrder::getStatus,status));
|
}
|
|
}
|
