From dafeb82f6180cc30d78d0ec5d4d614ecdd8ac715 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Wed, 25 Jun 2025 15:55:36 +0800
Subject: [PATCH] agent新增产品管理 新股管理

---
 src/main/java/com/nq/controller/AgentApiController.java |   18 +++++++++++++++---
 1 files changed, 15 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/nq/controller/AgentApiController.java b/src/main/java/com/nq/controller/AgentApiController.java
index e262b1f..8677445 100644
--- a/src/main/java/com/nq/controller/AgentApiController.java
+++ b/src/main/java/com/nq/controller/AgentApiController.java
@@ -3,9 +3,11 @@
 
 import com.nq.common.ServerResponse;
 
+import com.nq.pojo.AgentUser;
 import com.nq.pojo.UserStockSubscribe;
 import com.nq.service.IAgentUserService;
 
+import com.nq.service.IUserPositionService;
 import com.nq.service.IUserStockSubscribeService;
 import com.nq.utils.PropertiesUtil;
 
@@ -51,6 +53,9 @@
     @Autowired
     IUserStockSubscribeService iUserStockSubscribeService;
 
+    @Autowired
+    IUserPositionService iUserPositionService;
+
     //代理后台登录
     @RequestMapping({"login.do"})
     @ResponseBody
@@ -87,14 +92,22 @@
                                                 @RequestParam(value = "pageSize", defaultValue = "12") int pageSize,
                                                 @RequestParam(value = "keyword", defaultValue = "") String keyword,
                                                 @RequestParam(value = "agentId", required = false) String agentId,
+                                                @RequestParam(value = "name", required = false) String name,
+                                                @RequestParam(value = "status", required = false) Integer status,
                                                 HttpServletRequest request) {
-        return this.iUserStockSubscribeService.getList(pageNum, pageSize, keyword,agentId, request);
+        String loginToken = CookieUtils.readLoginToken(request, PropertiesUtil.getProperty("agent.cookie.name"));
+        String agentJson = RedisShardedPoolUtils.get(loginToken);
+        AgentUser agentUser = (AgentUser) JsonUtil.string2Obj(agentJson, AgentUser.class);
+        if (agentUser ==null){
+            return   ServerResponse.createByError("請先登錄",null);
+        }
+        return this.iUserStockSubscribeService.getList(pageNum, pageSize, keyword,agentUser.getId().toString(),name,status, request);
     }
 
     //申购信息-添加 修改
     @RequestMapping({"saveStockSubscribe.do"})
     @ResponseBody
-    public ServerResponse saveStockSubscribe(UserStockSubscribe model, HttpServletRequest request) {
+    public ServerResponse saveStockSubscribe(UserStockSubscribe model, HttpServletRequest request) throws Exception {
         return this.iUserStockSubscribeService.save(model, request);
     }
 
@@ -104,5 +117,4 @@
     public ServerResponse delStockSubscribe(@RequestParam("id") int id, HttpServletRequest request) {
         return this.iUserStockSubscribeService.del(id, request);
     }
-
 }

--
Gitblit v1.9.3