From ec72fc1827d3e46a99d302dd3c9ca61411c70943 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Thu, 24 Jul 2025 14:41:25 +0800
Subject: [PATCH] 修改

---
 src/main/java/com/nq/service/impl/StockSubscribeServiceImpl.java |   19 +++++++++++--------
 1 files changed, 11 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/nq/service/impl/StockSubscribeServiceImpl.java b/src/main/java/com/nq/service/impl/StockSubscribeServiceImpl.java
index 61d9db3..b57068e 100644
--- a/src/main/java/com/nq/service/impl/StockSubscribeServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/StockSubscribeServiceImpl.java
@@ -1,11 +1,11 @@
 package com.nq.service.impl;
 
-import cn.hutool.core.convert.Convert;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
+import com.nq.common.ResponseCode;
 import com.nq.common.ServerResponse;
 import com.nq.dao.StockMapper;
 import com.nq.dao.UserPositionMapper;
@@ -14,14 +14,13 @@
 import com.nq.service.IStockSubscribeService;
 import com.nq.dao.StockSubscribeMapper;
 import com.nq.service.IUserService;
-import com.nq.vo.stock.ai.StockAiOrderTypeVO;
+import com.nq.vo.subscribe.StockSubscribeVO;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
-import javax.xml.stream.events.EntityDeclaration;
 import java.util.Date;
 import java.util.List;
 
@@ -39,9 +38,6 @@
 
     @Autowired
     UserStockSubscribeMapper userStockSubscribeMapper;
-
-    @Autowired
-    StockMapper stockMapper;
 
     @Autowired
     UserPositionMapper userPositionMapper;
@@ -195,7 +191,7 @@
     @Override
     public ServerResponse listPageInfo(int pageNum, int pageSize, HttpServletRequest request) {
         try {
-            QueryWrapper<StockSubscribe> queryWrapper = new QueryWrapper();
+            /*QueryWrapper<StockSubscribe> queryWrapper = new QueryWrapper();
             //显示 0
             queryWrapper.eq("zt", 0);
             queryWrapper.eq("type", 1);
@@ -204,7 +200,14 @@
             PageHelper.startPage(pageNum, pageSize);
             List<StockSubscribe> stockSubscribeList = this.stockSubscribeMapper.selectList(queryWrapper);
             // 获取分页信息
-            PageInfo<StockSubscribe> pageInfo = new PageInfo<>(stockSubscribeList);
+            PageInfo<StockSubscribe> pageInfo = new PageInfo<>(stockSubscribeList);*/
+            User user = this.iUserService.getCurrentRefreshUser(request);
+            if (user == null) {
+                return ServerResponse.createByErrorCodeMsg(ResponseCode.NEED_LOGIN.getCode(),"请先登录", request);
+            }
+            PageHelper.startPage(pageNum, pageSize);
+            List<StockSubscribeVO> subscribeVOs = stockSubscribeMapper.selectStockSubscribeVO(0 ,1 ,user.getId());
+            PageInfo<StockSubscribeVO> pageInfo = new PageInfo<>(subscribeVOs);
 
             Date newDate = new Date();
             pageInfo.getList().forEach(stockSubscribe -> {

--
Gitblit v1.9.3