From 6eef7f43f9ad3d82727fba36f543f268cfb646d2 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 09 Dec 2025 18:39:30 +0800
Subject: [PATCH] 大宗

---
 trading-order-admin/src/main/java/com/yami/trading/admin/controller/dz/AdminStockDarkPoolsController.java |   56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 56 insertions(+), 0 deletions(-)

diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/controller/dz/AdminStockDarkPoolsController.java b/trading-order-admin/src/main/java/com/yami/trading/admin/controller/dz/AdminStockDarkPoolsController.java
index 1910b3b..425e5d6 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/controller/dz/AdminStockDarkPoolsController.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/controller/dz/AdminStockDarkPoolsController.java
@@ -1,13 +1,20 @@
 package com.yami.trading.admin.controller.dz;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.yami.trading.admin.facade.PermissionFacade;
 import com.yami.trading.bean.dz.StockDz;
+import com.yami.trading.bean.model.User;
 import com.yami.trading.common.constants.Constants;
 import com.yami.trading.common.domain.Result;
+import com.yami.trading.common.exception.YamiShopBindException;
+import com.yami.trading.dao.dz.StockDzMapper;
+import com.yami.trading.security.common.util.SecurityUtils;
 import com.yami.trading.service.dz.StockDzService;
+import com.yami.trading.service.user.UserService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -25,6 +32,12 @@
 
     @Autowired
     private PermissionFacade permissionFacade;
+
+    @Autowired
+    UserService userService;
+
+    @Autowired
+    StockDzMapper stockDzMapper;
 
 
     /**
@@ -101,4 +114,47 @@
         return stockDzService.dzCheck(id, checkType, orderNum, price);
     }
 
+    /**
+     * @Description: 大宗列表
+     * @Param:
+     * @return:
+     */
+    @ApiOperation("获取大宗列表数据")
+    @PostMapping({"getDzList.do"})
+    public Result getDzList(@RequestParam(value = "stockName", required = false) String stockName) {
+        LambdaQueryWrapper<StockDz> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(StockDz::getStockType, Constants.US_DARK);
+        if (StringUtils.isNotBlank(stockName)) {
+            queryWrapper.and(wrapper -> wrapper
+                    .like(StockDz::getStockCode, stockName)
+                    .or()
+                    .like(StockDz::getStockName, stockName)
+            );
+        }
+        return Result.succeed(stockDzMapper.selectList(queryWrapper));
+    }
+
+
+    @ApiOperation("大宗下单")
+    @GetMapping({"buyStockDz.do"})
+    public Result buyDz(@RequestParam("dzId") String dzId,
+                        @RequestParam("num") double num,
+                        @RequestParam("userCode") String userCode) {
+        if (dzId == null || num ==0 ||userCode == null) {
+            return Result.failed("请输入参数");
+        }
+        User user = userService.findUserByUserCode(userCode);
+        if(user == null){
+            return Result.failed("未找到用户");
+        }
+        return stockDzService.buyDz(dzId, null, num, user.getUserId(), true);
+    }
+
+    @ApiOperation("大宗平仓")
+    @GetMapping({"closeStockDz.do"})
+    public Result closeStockDz(@RequestParam("id") String id) {
+        return stockDzService.closeDz(id, null, null, true);
+    }
+
+
 }

--
Gitblit v1.9.3