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.UserPromiseRecord;
|
import com.yami.trading.bean.ipo.dto.SumSpotStockDto;
|
import com.yami.trading.bean.model.MoneyLog;
|
import com.yami.trading.bean.model.User;
|
import com.yami.trading.bean.model.Wallet;
|
import com.yami.trading.bean.syspara.domain.Syspara;
|
import com.yami.trading.common.constants.Constants;
|
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.MoneyLogService;
|
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.ipo.UserPromiseRecordService;
|
import com.yami.trading.service.syspara.SysparaService;
|
import com.yami.trading.service.user.UserService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.Arrays;
|
import java.util.Calendar;
|
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;
|
|
@Autowired
|
MoneyLogService moneyLogService;
|
|
@Lazy
|
@Autowired
|
UserPromiseRecordService userPromiseRecordService;
|
|
|
|
@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 (newSharesConfig.getUserApplyNums() != null && newSharesConfig.getUserApplyNums()>0){
|
if (amount.doubleValue() < newSharesConfig.getUserApplyNums()){
|
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;
|
}
|
|
//中签认缴
|
@Override
|
public Boolean subscribe(ApplyNewSharesOrder order) {
|
try {
|
NewSharesConfig newSharesConfig = newSharesConfigService.getByProductCode(order.getSymbolCode());
|
if (newSharesConfig == null) {
|
throw new BusinessException("新股不存在!");
|
}
|
Boolean isDb = false;
|
Wallet wallet = walletService.saveWalletByPartyId(order.getUserId());
|
BigDecimal amountBefore = wallet.getMoney();
|
BigDecimal amt = order.getRequiredNumber();
|
if (wallet.getMoney().compareTo(amt) >= 0) {
|
wallet.setMoney(wallet.getMoney().subtract(amt));
|
order.setSubscribedAmount(amt);
|
} else {
|
order.setSubscribedAmount(wallet.getMoney());
|
//资金不足 进入待补
|
isDb = true;
|
//BigDecimal amountToBeCovered = amt.subtract(wallet.getMoney());
|
amt = wallet.getMoney();
|
wallet.setMoney(BigDecimal.ZERO);
|
//wallet.setAmountToBeCovered(wallet.getAmountToBeCovered().add(amountToBeCovered));
|
}
|
walletService.updateById(wallet);
|
|
MoneyLog log = new MoneyLog();
|
log.setCategory(Constants.MONEYLOG_CATEGORY_IPO);
|
log.setAmountBefore(amountBefore);
|
log.setAmount(amt.negate());
|
log.setAmountAfter(amountBefore.subtract(amt).compareTo(BigDecimal.ZERO) <= 0 ?
|
BigDecimal.ZERO : amountBefore.subtract(amt));
|
log.setLog(order.getSymbolCode() + "新股认缴" + order.getOrderNo());
|
log.setUserId(order.getUserId());
|
log.setWalletType(Constants.WALLET);
|
log.setContentType(Constants.MONEYLOG_CATEGORY_IPO);
|
moneyLogService.save(log);
|
|
UserPromiseRecord userPromiseRecord = new UserPromiseRecord();
|
userPromiseRecord.setUserId(order.getUserId());
|
userPromiseRecord.setDeductNumber(order.getWinningNumber());
|
userPromiseRecord.setDeductUsdt(order.getSubscribedAmount());
|
userPromiseRecord.setStatus(isDb ? 1 : 2);
|
Calendar calendar=Calendar.getInstance();
|
if (newSharesConfig.getLockDay() > 0) {
|
calendar.add(Calendar.DAY_OF_YEAR,newSharesConfig.getLockDay());
|
userPromiseRecord.setLockEndTime(calendar.getTime());
|
} else {
|
userPromiseRecord.setLockEndTime(calendar.getTime());
|
}
|
userPromiseRecord.setNewSharesConfigId(newSharesConfig.getUuid());
|
userPromiseRecord.setProductCode(newSharesConfig.getProductCode());
|
userPromiseRecord.setProductName(newSharesConfig.getProductName());
|
userPromiseRecord.setName(newSharesConfig.getName());
|
userPromiseRecord.setOrderNo(order.getOrderNo());
|
userPromiseRecordService.save(userPromiseRecord);
|
|
return true;
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
}
|
return false;
|
}
|
|
@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));
|
}
|
|
}
|
