我的股票功能更新

src/main/java/com/yingpai/gupiao/controller/StockDataController.java

@@ -5,6 +5,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import com.yingpai.gupiao.domain.vo.Result;
 import com.yingpai.gupiao.domain.vo.StockInfoVO;
 import com.yingpai.gupiao.util.StockUtils;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
@@ -19,6 +20,7 @@ import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 
+@Slf4j
 @RestController
 @RequestMapping("/api/stock")
 public class StockDataController {
@@ -46,7 +48,7 @@ public class StockDataController {
      */
     @GetMapping("/fetch")
     public Result<List<StockInfoVO>> fetchStockData(@RequestParam("codes") String codes) {
-        System.out.println("[股票查询] 请求参数: " + codes);
+        log.info("[股票查询] 请求参数: {}", codes);
         
         List<StockInfoVO> dataList = new ArrayList<>();
         String[] codeArray = codes.split(",");
@@ -63,7 +65,7 @@ public class StockDataController {
             }
         }
 
-        System.out.println("[股票查询] 返回结果: " + dataList);
+        log.debug("[股票查询] 返回结果: {}", dataList);
         return Result.success(dataList);
     }
 
@@ -79,11 +81,11 @@ public class StockDataController {
      */
     @GetMapping("/index")
     public Result<StockInfoVO> fetchIndexData(@RequestParam("code") String code) {
-        System.out.println("[指数查询] 请求参数: " + code);
+        log.info("[指数查询] 请求参数: {}", code);
         
         StockInfoVO indexInfo = fetchIndexInfo(code);
         
-        System.out.println("[指数查询] 返回结果: " + indexInfo);
+        log.debug("[指数查询] 返回结果: {}", indexInfo);
         return Result.success(indexInfo);
     }
 
@@ -108,7 +110,7 @@ public class StockDataController {
 
         try {
             HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
-            System.out.println("[指数 " + code + "] 响应: " + response.body());
+            log.debug("[指数 {}] 响应: {}", code, response.body());
 
             if (response.statusCode() == 200) {
                 JsonNode root = objectMapper.readTree(response.body());
@@ -133,7 +135,7 @@ public class StockDataController {
                 }
             }
         } catch (Exception e) {
-            System.err.println("[指数 " + code + "] 异常: " + e.getMessage());
+            log.error("[指数 {}] 异常: {}", code, e.getMessage());
         }
 
         return null;
@@ -164,7 +166,7 @@ public class StockDataController {
 
         try {
             HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
-            System.out.println("[" + code + "] 响应: " + response.body());
+            log.debug("[{}] 响应: {}", code, response.body());
 
             if (response.statusCode() == 200) {
                 JsonNode root = objectMapper.readTree(response.body());
@@ -189,7 +191,7 @@ public class StockDataController {
                 }
             }
         } catch (Exception e) {
-            System.err.println("[" + code + "] 异常: " + e.getMessage());
+            log.error("[{}] 异常: {}", code, e.getMessage());
         }
 
         return null;
@@ -255,7 +257,7 @@ public class StockDataController {
                 }
             }
         } catch (Exception e) {
-            System.err.println("[趋势数据] 获取失败: " + e.getMessage());
+            log.error("[趋势数据] 获取失败: {}", e.getMessage());
         }
         
         // 如果没有获取到趋势数据，返回空列表
@@ -283,7 +285,7 @@ public class StockDataController {
         try {
             return new BigDecimal(value);
         } catch (NumberFormatException e) {
-            System.err.println("无法解析数字字段 [" + fieldName + "]: " + value);
+            log.warn("无法解析数字字段 [{}]: {}", fieldName, value);
             return null;
         }
     }

src/main/java/com/yingpai/gupiao/service/impl/UserStockServiceImpl.java

@@ -7,6 +7,7 @@ import com.yingpai.gupiao.domain.vo.UserStockVO;
 import com.yingpai.gupiao.mapper.UserStockMapper;
 import com.yingpai.gupiao.service.UserStockService;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
@@ -18,6 +19,7 @@ import java.util.List;
 /**
  * 用户自选股票服务实现
  */
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class UserStockServiceImpl implements UserStockService {
@@ -28,19 +30,19 @@ public class UserStockServiceImpl implements UserStockService {
     
     @Override
     public List<UserStockVO> getUserStocks(Long userId) {
-        System.out.println("[查询股票] userId=" + userId);
+        log.info("[查询股票] userId={}", userId);
         
         LambdaQueryWrapper<UserStock> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(UserStock::getUserId, userId)
                .orderByDesc(UserStock::getAddDate);
         
         List<UserStock> stocks = userStockMapper.selectList(wrapper);
-        System.out.println("[查询股票] 查询到 " + stocks.size() + " 条记录");
+        log.info("[查询股票] 查询到 {} 条记录", stocks.size());
         
         List<UserStockVO> result = new ArrayList<>();
         
         for (UserStock stock : stocks) {
-            System.out.println("[查询股票] 股票: " + stock.getStockCode() + " - " + stock.getStockName());
+            log.debug("[查询股票] 股票: {} - {}", stock.getStockCode(), stock.getStockName());
             UserStockVO vo = UserStockVO.builder()
                     .stockCode(stock.getStockCode())
                     .stockName(stock.getStockName())
@@ -55,11 +57,11 @@ public class UserStockServiceImpl implements UserStockService {
     
     @Override
     public boolean addStock(Long userId, AddUserStockDTO dto) {
-        System.out.println("[添加股票] userId=" + userId + ", stockCode=" + dto.getStockCode() + ", stockName=" + dto.getStockName());
+        log.info("[添加股票] userId={}, stockCode={}, stockName={}", userId, dto.getStockCode(), dto.getStockName());
         
         // 检查是否已存在
         if (isStockAdded(userId, dto.getStockCode())) {
-            System.out.println("[添加股票] 股票已存在，跳过添加");
+            log.info("[添加股票] 股票已存在，跳过添加");
             return false;
         }
         
@@ -69,7 +71,7 @@ public class UserStockServiceImpl implements UserStockService {
                 price = new BigDecimal(dto.getCurrentPrice());
             }
         } catch (NumberFormatException e) {
-            System.err.println("[添加股票] 价格解析失败: " + dto.getCurrentPrice());
+            log.warn("[添加股票] 价格解析失败: {}", dto.getCurrentPrice());
         }
         
         UserStock userStock = UserStock.builder()
@@ -81,7 +83,7 @@ public class UserStockServiceImpl implements UserStockService {
                 .build();
         
         int result = userStockMapper.insert(userStock);
-        System.out.println("[添加股票] 插入结果: " + result);
+        log.info("[添加股票] 插入结果: {}", result);
         return result > 0;
     }