From 3a1977e8cc0c5fffbc6490f220f30116af6cce86 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 14 Jan 2026 15:17:07 +0800
Subject: [PATCH] 获取盘前交易列表

---
 src/main/java/com/nq/controller/echo/EChoController.java |   24 +++++++++++++++++++-----
 1 files changed, 19 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/nq/controller/echo/EChoController.java b/src/main/java/com/nq/controller/echo/EChoController.java
index 56946ce..17dbdc7 100644
--- a/src/main/java/com/nq/controller/echo/EChoController.java
+++ b/src/main/java/com/nq/controller/echo/EChoController.java
@@ -44,6 +44,14 @@
         return ServerResponse.createBySuccess(iEchoServices.queryList());
     }
 
+    @PostMapping("queryEchoPage.do")
+    @ResponseBody
+    public ServerResponse queryEchoPage(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum,
+                                         @RequestParam(value = "pageSize", defaultValue = "5") int pageSize,
+                                         HttpServletRequest request) {
+        return iEchoServices.queryListPage(pageNum, pageSize);
+    }
+
 
     @PostMapping("buyEcho.do")
     @ResponseBody
@@ -60,17 +68,17 @@
             }
         }
         User user = this.iUserService.getCurrentRefreshUser(request);
-        UserAssets userAssets = userAssetsServices.assetsByTypeAndUserId(EStockType.MX.getCode(), user.getId());
+        UserAssets userAssets = userAssetsServices.assetsByTypeAndUserId(EStockType.getDefault().getCode(), user.getId());
         if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
             return ServerResponse.createByErrorMsg("请先缴清待补资金", request);
         }
         if(userAssets.getAvailableBalance().compareTo(money) < 0){
-            return ServerResponse.createByErrorMsg("配资不足",request);
+            return ServerResponse.createByErrorMsg("配资不足", request);
         }
         if (iEchoServices.buyECho(eid, money, userAssets.getAccectType(), request)) {
-            return ServerResponse.createBySuccess("购买成功",request);
+            return ServerResponse.createBySuccess("购买成功", request);
         } else {
-            return ServerResponse.createByErrorMsg("购买失败",request);
+            return ServerResponse.createByErrorMsg("购买失败", request);
         }
     }
 
@@ -81,7 +89,13 @@
         return ServerResponse.createBySuccess(iEchoServices.queryOrderEcho(request));
     }
 
-
+    @PostMapping("queryOrderEchoPage.do")
+    @ResponseBody
+    public ServerResponse queryOrderEcho(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum,
+                                         @RequestParam(value = "pageSize", defaultValue = "5") int pageSize,
+                                         HttpServletRequest request) {
+        return iEchoServices.queryOrderEchoPage(pageNum, pageSize, request);
+    }
 
 
 

--
Gitblit v1.9.3