大宗持仓

zyy

2025-10-29 d4ab82f09c8900c603703d48a2635b54f872d122

 trading-order-service/src/main/java/com/yami/trading/service/dz/impl/StockDzServiceImpl.java

@@ -7,12 +7,16 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yami.trading.bean.contract.domain.ContractApplyOrder;
import com.yami.trading.bean.data.domain.Realtime;
import com.yami.trading.bean.dz.ExchangeApplyOrderDz;
import com.yami.trading.bean.dz.StockDz;
import com.yami.trading.bean.exchange.ExchangeApplyOrder;
import com.yami.trading.bean.item.domain.Item;
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.model.WalletExtend;
import com.yami.trading.bean.syspara.domain.Syspara;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.domain.Result;
@@ -23,7 +27,9 @@
import com.yami.trading.dao.dz.StockDzMapper;
import com.yami.trading.service.MoneyLogService;
import com.yami.trading.service.WalletService;
import com.yami.trading.service.data.DataService;
import com.yami.trading.service.dz.StockDzService;
import com.yami.trading.service.exchange.ExchangeApplyOrderService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.user.UserService;
@@ -64,6 +70,12 @@
    @Resource
    private ItemService itemService;

    @Resource
    private ExchangeApplyOrderService exchangeApplyOrderService;

    @Resource
    private DataService dataService;

    @Override
    public Result getDzList(int pageNum, int pageSize, String orderBy, String keyWords, String stockType) {
        try {
@@ -99,7 +111,7 @@
        stockDz.setStockCode(item.getSymbol());
        stockDz.setStockType(item.getType());
        stockDz.setStockSpell(item.getSymbolData());
        stockDz.setIsLock(1);
        stockDz.setIsLock(0);
        stockDz.setIsShow(1);
        stockDz.setAddTime(new Date());
        stockDz.setStockNum(Integer.valueOf(stockNum));
@@ -227,7 +239,7 @@
                throw new YamiShopBindException("股票价格0,请重试");
            }
            if (stockDz.getStockNum() > num) {
                throw new YamiShopBindException("最小购买数据" + stockDz.getStockNum());
                throw new YamiShopBindException("最小购买数量" + stockDz.getStockNum());
            }

            Wallet wallet = this.walletService.saveWalletByPartyId(partyId);
@@ -246,6 +258,7 @@
            order.setPartyId(partyId);
            order.setSymbol(stockDz.getStockCode());
            order.setSymbolValue(num);
            order.setDzId(stockDz.getUuid());
            order.setVolume(buyAmt.doubleValue());
            order.setPrice(nowPrice.doubleValue());
            order.setOrderNo(com.yami.trading.common.util.DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
@@ -265,11 +278,12 @@
            walletService.update(wallet.getUserId(), Arith.sub(0, orderAmt.doubleValue()));

            //TODO 转持仓
            this.intoPosition(order, stockDz.getStockType());

            MoneyLog log = new MoneyLog();
            log.setCategory(Constants.MONEYLOG_CATEGORY_EXCHANGE);
            String name = Constants.MONEYLOG_MAP.get(Constants.US_STOCKS);
            String type2 = Constants.MONEYLOG_MAP_TYPE.get(Constants.US_STOCKS);
            String name = Constants.MONEYLOG_MAP.get(stockDz.getStockType());
            String type2 = Constants.MONEYLOG_MAP_TYPE.get(stockDz.getStockType());
            log.setAmountBefore(amountBefore);
            log.setAmount(orderAmt.negate());
            log.setAmountAfter(amountBefore.subtract(orderAmt));
@@ -284,13 +298,13 @@
            return Result.succeed("购买成功");
        } catch (Exception e) {
            log.error(e.getMessage());
            return Result.failed("操作失败:" + e.getMessage());
        }
        return Result.failed("操作失败");
    }

    @Transactional
    @Override
    public Result dzCheck(String id, Integer checkType, double orderNum) {
    public Result dzCheck(String id, Integer checkType, Double orderNum) {
        try {
            ExchangeApplyOrderDz order = exchangeApplyOrderDzMapper.selectById(id);
            if (order == null) {
@@ -303,13 +317,13 @@
            if (checkType == 2) {
                order.setState(ExchangeApplyOrderDz.STATE_FAILED);
                exchangeApplyOrderDzMapper.updateById(order);
                throw new YamiShopBindException("审核成功");
                return Result.succeed("操作成功");
            }
            if (orderNum > order.getSymbolValue()) {
                throw new YamiShopBindException("输入数量大于用户买入数量");
            }

            StockDz stockDz = this.stockDzMapper.selectOne(new QueryWrapper<StockDz>().eq("id", order.getDzId()));
            StockDz stockDz = this.stockDzMapper.selectOne(new QueryWrapper<StockDz>().eq("uuid", order.getDzId()));
            if (stockDz == null) {
                throw new YamiShopBindException("大宗不存在");
            }
@@ -339,12 +353,12 @@
            walletService.update(wallet.getUserId(), Arith.sub(0, orderAmt.doubleValue()));

            //TODO 转持仓

            this.intoPosition(order, stockDz.getStockType());

            MoneyLog log = new MoneyLog();
            log.setCategory(Constants.MONEYLOG_CATEGORY_EXCHANGE);
            String name = Constants.MONEYLOG_MAP.get(Constants.US_STOCKS);
            String type2 = Constants.MONEYLOG_MAP_TYPE.get(Constants.US_STOCKS);
            String name = Constants.MONEYLOG_MAP.get(stockDz.getStockType());
            String type2 = Constants.MONEYLOG_MAP_TYPE.get(stockDz.getStockType());
            log.setAmountBefore(amountBefore);
            log.setAmount(orderAmt.negate());
            log.setAmountAfter(amountBefore.subtract(orderAmt));
@@ -359,8 +373,47 @@
            return Result.succeed("审核成功,订单已转客户持仓");
        } catch (Exception e) {
            log.error(e.getMessage());
            return Result.failed("操作失败:" + e.getMessage());
        }
        return Result.failed("操作失败");
    }

    public void intoPosition(ExchangeApplyOrderDz orderDz, String stockType) {
        ExchangeApplyOrder exOrder = new ExchangeApplyOrder();
        exOrder.setPartyId(orderDz.getPartyId());
        exOrder.setSymbol(orderDz.getSymbol());
        exOrder.setOffset(ExchangeApplyOrder.OFFSET_OPEN);
        exOrder.setSymbolValue(orderDz.getSymbolValue());
        exOrder.setVolume(orderDz.getVolume());
        exOrder.setPrice(orderDz.getPrice());
        exOrder.setOrderPriceType(ContractApplyOrder.ORDER_PRICE_TYPE_OPPONENT);
        exOrder.setState(ExchangeApplyOrder.STATE_CREATED);
        exOrder.setClosePrice(orderDz.getPrice());
        exOrder.setOrderNo(com.yami.trading.common.util.DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
        exOrder.setFee(orderDz.getFee());
        exOrder.setCreateTime(new Date());

        double realValue = exOrder.getSymbolValue();
        //入账
        WalletExtend walletExtend = walletService.saveExtendByPara(exOrder.getPartyId(), exOrder.getSymbol());
        double amountBeforeExtend = walletExtend.getAmount();
        this.walletService.updateExtend(walletExtend.getPartyId(), walletExtend.getWallettype(), realValue);

        MoneyLog log = new MoneyLog();
        log.setCategory(Constants.MONEYLOG_CATEGORY_EXCHANGE);
        String name = Constants.MONEYLOG_MAP.get(stockType);
        String type2 = Constants.MONEYLOG_MAP_TYPE.get(stockType);
        log.setAmountBefore(new BigDecimal(amountBeforeExtend));
        log.setAmount(BigDecimal.valueOf(realValue));
        log.setAmountAfter(BigDecimal.valueOf(amountBeforeExtend + realValue));
        log.setLog(name + type2 + "现货交易买入委托单成交，订单号[" + exOrder.getOrderNo() + "]");
        log.setUserId(exOrder.getPartyId());
        log.setSymbol(exOrder.getSymbol());
        log.setWalletType(exOrder.getSymbol());
        log.setContentType(type2 + Constants.MONEYLOG_CONTENT_OPEN);
        // 记录账变日志
        moneyLogService.save(log);

        exchangeApplyOrderService.save(exOrder);
    }