feat(api): 实现用户浏览记录功能

- 在Recommend服务中添加用户浏览记录的保存、查询和统计接口
- 实现浏览记录的数据库表结构和MyBatis映射
- 将浏览记录相关功能从Essential服务迁移到Recommend服务
- 更新前端API调用，移除用户详情接口中的浏览记录参数
- 移除原有的浏览记录相关实体类和控制器方法
- 添加浏览记录的POJO类和相关服务实现

LiangZhiYUMao/pages/mine/visited-by-me.vue

@@ -16,13 +16,8 @@
     </view>
     
     <!-- 浏览记录列表 -->
-    <scroll-view 
-      class="history-list" 
-      scroll-y="true" 
-      @scrolltolower="loadMore"
-      lower-threshold="50"
-    >
-      <view class="history-item" v-for="item in browseHistory" :key="item.userId" @click="goUserDetail(item.userId)">
+    <scroll-view class="history-list" scroll-y="true">
+      <view class="history-item" v-for="item in browseHistory" :key="item.id" @click="goUserDetail(item.userId)">
         <image class="user-avatar" :src="item.avatar" mode="aspectFill"></image>
         <view class="user-info">
           <view class="user-basic">
@@ -43,14 +38,6 @@
           <text class="browse-icon">👁️</text>
         </view>
       </view>
-      
-      <!-- 加载更多提示 -->
-      <view class="load-more" v-if="hasMore && !loading">
-        <text class="load-more-text">上拉加载更多</text>
-      </view>
-      <view class="load-more" v-if="!hasMore && browseHistory.length > 0">
-        <text class="load-more-text">没有更多数据了</text>
-      </view>
     </scroll-view>
   </view>
 </template>
@@ -71,57 +58,13 @@ export default {
   onLoad() {
     this.loadBrowseHistory()
   },
-  
-  // 下拉刷新
-  onPullDownRefresh() {
-    this.loadBrowseHistory(true)
-  },
   methods: {
     // 加载浏览记录
-    async loadBrowseHistory(isRefresh = false) {
+    async loadBrowseHistory() {
       try {
         this.loading = true
-        
-        // 从本地存储获取当前用户ID
-        const userInfo = uni.getStorageSync('userInfo')
-        if (!userInfo || !userInfo.userId) {
-          uni.showToast({
-            title: '请先登录',
-            icon: 'none'
-          })
-          return
-        }
-        
-        // 如果是刷新，则重置页码
-        if (isRefresh) {
-          this.pageNum = 1
-          this.hasMore = true
-        }
-        
-        // 如果没有更多数据，则直接返回
-        if (!this.hasMore) {
-          return
-        }
-        
-        // 调用API获取浏览记录
-        const response = await api.user.getBrowseHistory(userInfo.userId, this.pageNum, this.pageSize)
-        
-        // 处理返回数据
-        if (isRefresh) {
-          // 刷新：替换原有数据
-          this.browseHistory = response.records || []
-        } else {
-          // 加载更多：追加数据
-          this.browseHistory = this.browseHistory.concat(response.records || [])
-        }
-        
-        // 判断是否还有更多数据
-        this.hasMore = this.browseHistory.length < response.total
-        
-        // 如果还有更多数据，则页码加1
-        if (this.hasMore) {
-          this.pageNum++
-        }
+        // 不调用真实API，显示空数据
+        this.browseHistory = []
       } catch (error) {
         console.error('加载浏览记录失败:', error)
         uni.showToast({
@@ -130,10 +73,6 @@ export default {
         })
       } finally {
         this.loading = false
-        // 停止下拉刷新
-        if (isRefresh) {
-          uni.stopPullDownRefresh()
-        }
       }
     },
     
@@ -179,13 +118,6 @@ export default {
       uni.navigateTo({
         url: '/pages/recommend/index'
       })
-    },
-    
-    // 上拉加载更多
-    loadMore() {
-      if (!this.loading && this.hasMore) {
-        this.loadBrowseHistory()
-      }
     }
   }
 }
@@ -257,13 +189,6 @@ export default {
   height: calc(100vh - 88rpx);
 }
 
-.load-more {
-  text-align: center;
-  padding: 30rpx 0;
-  color: #999;
-  font-size: 24rpx;
-}
-
 .history-item {
   display: flex;
   align-items: center;

LiangZhiYUMao/utils/api.js

@@ -117,8 +117,8 @@ export default {
     getInfo: () => request({ url: '/user/info' }),
 
     // 获取指定用户的详细信息（包含简介和照片）
-    getDetailInfo: (userId, currentUserId) => request({
-      url: `/user/info?userId=${userId}${currentUserId ? `&currentUserId=${currentUserId}` : ''}`
+    getDetailInfo: (userId) => request({
+      url: `/user/info?userId=${userId}`
     }),
 
     // 查询用户是否为红娘
@@ -140,23 +140,6 @@ export default {
     updateField: (userId, fieldName, fieldValue) => request({
       url: `/user/basic/field?userId=${userId}&fieldName=${fieldName}&fieldValue=${encodeURIComponent(fieldValue)}`,
       method: 'PUT'
-    }),
-    
-    // 获取用户的浏览记录列表
-    getBrowseHistory: (userId, pageNum = 1, pageSize = 20) => request({
-      url: `/user/browse-history?userId=${userId}&pageNum=${pageNum}&pageSize=${pageSize}`
-    }),
-    
-    // 清空用户的所有浏览记录
-    clearBrowseHistory: (userId) => request({
-      url: `/user/browse-history?userId=${userId}`,
-      method: 'DELETE'
-    }),
-    
-    // 删除用户对某个特定用户的浏览记录
-    deleteBrowseHistory: (userId, visitedUserId) => request({
-      url: `/user/browse-history/one?userId=${userId}&visitedUserId=${visitedUserId}`,
-      method: 'DELETE'
     })
   },
 

service/Essential/src/main/java/com/zhentao/controller/UserController.java

@@ -1,9 +1,7 @@
 package com.zhentao.controller;
 
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.zhentao.common.Result;
 import com.zhentao.entity.User;
-import com.zhentao.service.UserBrowseUserService;
 import com.zhentao.service.UserService;
 import com.zhentao.vo.UserInfoVO;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -19,21 +17,15 @@ public class UserController {
     @Autowired
     private UserService userService;
     
-    @Autowired
-    private UserBrowseUserService userBrowseUserService;
-    
     /**
      * 获取用户信息
      * @param userId 用户ID（必传）
-     * @param currentUserId 当前登录用户ID（可选，用于添加浏览记录）
      * @return 用户信息
      */
     @GetMapping("/info")
-    public Result<UserInfoVO> getUserInfo(@RequestParam Long userId, 
-                                         @RequestParam(required = false) Long currentUserId) {
+    public Result<UserInfoVO> getUserInfo(@RequestParam Long userId) {
         System.out.println("=== UserController.getUserInfo 接收请求 ===");
         System.out.println("接收到的用户ID: " + userId + " (类型: " + userId.getClass().getSimpleName() + ")");
-        System.out.println("当前登录用户ID: " + currentUserId);
         
         try {
             // 验证用户ID
@@ -47,25 +39,6 @@ public class UserController {
             
             if (vo != null) {
                 System.out.println("✅ 查询成功，用户: " + vo.getNickname() + " (ID: " + vo.getUserId() + ")");
-                
-                // 如果当前有登录用户，且不是查看自己的信息，则添加浏览记录
-                if (currentUserId != null && currentUserId > 0 && !currentUserId.equals(userId)) {
-                    System.out.println("📝 添加浏览记录: " + currentUserId + " -> " + userId);
-                    
-                    // 异步添加浏览记录，不影响主流程
-                    new Thread(() -> {
-                        try {
-                            // 转换为Integer类型
-                            Integer visitorId = currentUserId.intValue();
-                            Integer visitedUserId = userId.intValue();
-                            userBrowseUserService.addBrowseHistory(visitorId, visitedUserId);
-                            System.out.println("✅ 浏览记录添加成功: " + visitorId + " -> " + visitedUserId);
-                        } catch (Exception e) {
-                            System.err.println("❌ 浏览记录添加失败: " + e.getMessage());
-                            e.printStackTrace();
-                        }
-                    }).start();
-                }
             } else {
                 System.out.println("❌ 查询结果为null");
             }
@@ -82,102 +55,6 @@ public class UserController {
         }
     }
     
-    /**
-     * 获取用户的浏览记录列表
-     * @param userId 用户ID（必传）
-     * @param pageNum 页码（可选，默认1）
-     * @param pageSize 每页条数（可选，默认20）
-     * @return 浏览记录分页列表
-     */
-    @GetMapping("/browse-history")
-    public Result<Page<UserInfoVO>> getBrowseHistory(@RequestParam Long userId, 
-                                                   @RequestParam(required = false, defaultValue = "1") Integer pageNum, 
-                                                   @RequestParam(required = false, defaultValue = "20") Integer pageSize) {
-        System.out.println("=== UserController.getBrowseHistory 接收请求 ===");
-        System.out.println("用户ID: " + userId + ", 页码: " + pageNum + ", 每页条数: " + pageSize);
-        
-        try {
-            // 验证用户ID
-            if (userId == null || userId <= 0) {
-                System.out.println("❌ 用户ID无效: " + userId);
-                return Result.error("用户ID无效");
-            }
-            
-            // 转换为Integer类型
-            Integer visitorId = userId.intValue();
-            Page<UserInfoVO> page = userBrowseUserService.getBrowseHistory(visitorId, pageNum, pageSize);
-            System.out.println("✅ 浏览记录查询成功，共" + page.getTotal() + "条记录");
-            
-            return Result.success(page);
-        } catch (Exception e) {
-            System.err.println("❌ 浏览记录查询失败: " + e.getMessage());
-            e.printStackTrace();
-            return Result.error("获取浏览记录失败: " + e.getMessage());
-        }
-    }
-    
-    /**
-     * 清空用户的所有浏览记录
-     * @param userId 用户ID（必传）
-     * @return 操作结果
-     */
-    @DeleteMapping("/browse-history")
-    public Result<String> clearBrowseHistory(@RequestParam Long userId) {
-        System.out.println("=== UserController.clearBrowseHistory 接收请求 ===");
-        System.out.println("用户ID: " + userId);
-        
-        try {
-            // 验证用户ID
-            if (userId == null || userId <= 0) {
-                System.out.println("❌ 用户ID无效: " + userId);
-                return Result.error("用户ID无效");
-            }
-            
-            // 转换为Integer类型
-            Integer visitorId = userId.intValue();
-            userBrowseUserService.clearBrowseHistory(visitorId);
-            System.out.println("✅ 浏览记录清空成功");
-            
-            return Result.success("浏览记录清空成功");
-        } catch (Exception e) {
-            System.err.println("❌ 浏览记录清空失败: " + e.getMessage());
-            e.printStackTrace();
-            return Result.error("清空浏览记录失败: " + e.getMessage());
-        }
-    }
-    
-    /**
-     * 删除用户对某个特定用户的浏览记录
-     * @param userId 用户ID（必传）
-     * @param visitedUserId 被浏览者ID（必传）
-     * @return 操作结果
-     */
-    @DeleteMapping("/browse-history/one")
-    public Result<String> deleteBrowseHistory(@RequestParam Long userId, @RequestParam Long visitedUserId) {
-        System.out.println("=== UserController.deleteBrowseHistory 接收请求 ===");
-        System.out.println("用户ID: " + userId + ", 被浏览者ID: " + visitedUserId);
-        
-        try {
-            // 验证用户ID
-            if (userId == null || userId <= 0 || visitedUserId == null || visitedUserId <= 0) {
-                System.out.println("❌ 用户ID或被浏览者ID无效");
-                return Result.error("用户ID或被浏览者ID无效");
-            }
-            
-            // 转换为Integer类型
-            Integer visitorId = userId.intValue();
-            Integer lookUserId = visitedUserId.intValue();
-            userBrowseUserService.deleteBrowseHistory(visitorId, lookUserId);
-            System.out.println("✅ 浏览记录删除成功");
-            
-            return Result.success("浏览记录删除成功");
-        } catch (Exception e) {
-            System.err.println("❌ 浏览记录删除失败: " + e.getMessage());
-            e.printStackTrace();
-            return Result.error("删除浏览记录失败: " + e.getMessage());
-        }
-    }
-    
     /**
      * 查询用户是否为红娘
      * @param userId 用户ID

service/Essential/src/main/java/com/zhentao/entity/UserBrowseUser.java

@@ -1,50 +0,0 @@
-package com.zhentao.entity;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-import com.baomidou.mybatisplus.annotation.FieldFill;
-import com.baomidou.mybatisplus.annotation.TableField;
-import lombok.Data;
-
-import java.io.Serializable;
-import java.util.Date;
-
-/**
- * 用户浏览用户记录实体类
- */
-@Data
-@TableName("user_look")
-public class UserBrowseUser implements Serializable {
-    private static final long serialVersionUID = 1L;
-
-    /**
-     * 主键ID
-     */
-    @TableId(type = IdType.AUTO)
-    private Integer id;
-
-    /**
-     * 用户ID（浏览者）
-     */
-    @TableField("user_id")
-    private Integer userId;
-
-    /**
-     * 用户浏览的用户ID（被浏览者）
-     */
-    @TableField("look_user_id")
-    private Integer lookUserId;
-
-    /**
-     * 创建时间
-     */
-    @TableField(value = "create_time", fill = FieldFill.INSERT)
-    private Date createTime;
-
-    /**
-     * 更新时间
-     */
-    @TableField(value = "update_time", fill = FieldFill.INSERT_UPDATE)
-    private Date updateTime;
-}

service/Essential/src/main/java/com/zhentao/mapper/UserBrowseUserMapper.java

@@ -1,35 +0,0 @@
-package com.zhentao.mapper;
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.zhentao.entity.UserBrowseUser;
-import com.zhentao.vo.UserInfoVO;
-import org.apache.ibatis.annotations.Param;
-
-import java.util.List;
-
-/**
- * 用户浏览用户记录Mapper
- */
-public interface UserBrowseUserMapper extends BaseMapper<UserBrowseUser> {
-    
-    /**
-     * 按浏览时间倒序获取用户的浏览记录，包含被浏览用户的基本信息
-     */
-    Page<UserInfoVO> getBrowseHistory(@Param("page") Page<UserInfoVO> page, @Param("visitorId") Long visitorId);
-    
-    /**
-     * 删除用户的所有浏览记录
-     */
-    int deleteByVisitorId(@Param("visitorId") Long visitorId);
-    
-    /**
-     * 删除用户对某个特定用户的浏览记录
-     */
-    int deleteByVisitorAndVisited(@Param("visitorId") Long visitorId, @Param("visitedUserId") Long visitedUserId);
-    
-    /**
-     * 获取用户最近一次浏览某个特定用户的记录
-     */
-    UserBrowseUser getLatestByVisitorAndVisited(@Param("visitorId") Long visitorId, @Param("visitedUserId") Long visitedUserId);
-}

service/Essential/src/main/java/com/zhentao/service/UserBrowseUserService.java

@@ -1,45 +0,0 @@
-package com.zhentao.service;
-
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.zhentao.entity.UserBrowseUser;
-import com.zhentao.vo.UserInfoVO;
-
-/**
- * 用户浏览用户记录Service
- */
-public interface UserBrowseUserService extends IService<UserBrowseUser> {
-    
-    /**
-     * 添加浏览记录
-     * 
-     * @param userId 浏览者ID
-     * @param lookUserId 被浏览者ID
-     */
-    void addBrowseHistory(Integer userId, Integer lookUserId);
-    
-    /**
-     * 获取用户的浏览记录列表
-     * 
-     * @param userId 浏览者ID
-     * @param pageNum 页码
-     * @param pageSize 每页条数
-     * @return 浏览记录分页列表
-     */
-    Page<UserInfoVO> getBrowseHistory(Integer userId, Integer pageNum, Integer pageSize);
-    
-    /**
-     * 清空用户的所有浏览记录
-     * 
-     * @param userId 浏览者ID
-     */
-    void clearBrowseHistory(Integer userId);
-    
-    /**
-     * 删除用户对某个特定用户的浏览记录
-     * 
-     * @param userId 浏览者ID
-     * @param lookUserId 被浏览者ID
-     */
-    void deleteBrowseHistory(Integer userId, Integer lookUserId);
-}

service/Essential/src/main/java/com/zhentao/service/impl/UserBrowseUserServiceImpl.java

@@ -1,76 +0,0 @@
-package com.zhentao.service.impl;
-
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.zhentao.entity.UserBrowseUser;
-import com.zhentao.mapper.UserBrowseUserMapper;
-import com.zhentao.service.UserBrowseUserService;
-import com.zhentao.vo.UserInfoVO;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
-import java.util.Date;
-
-/**
- * 用户浏览用户记录Service实现类
- */
-@Slf4j
-@Service
-public class UserBrowseUserServiceImpl extends ServiceImpl<UserBrowseUserMapper, UserBrowseUser> implements UserBrowseUserService {
-    
-    @Autowired
-    private UserBrowseUserMapper userBrowseUserMapper;
-    
-    /**
-     * 添加浏览记录
-     */
-    @Override
-    @Transactional(rollbackFor = Exception.class)
-    public void addBrowseHistory(Integer userId, Integer lookUserId) {
-        // 检查是否已存在浏览记录
-        UserBrowseUser existingRecord = userBrowseUserMapper.getLatestByVisitorAndVisited(userId.longValue(), lookUserId.longValue());
-        
-        if (existingRecord != null) {
-            // 已存在则删除旧记录
-            userBrowseUserMapper.deleteById(existingRecord.getId());
-        }
-        
-        // 创建新的浏览记录
-        UserBrowseUser record = new UserBrowseUser();
-        record.setUserId(userId);
-        record.setLookUserId(lookUserId);
-        
-        // 保存记录（创建时间和更新时间由MyBatis Plus自动填充）
-        this.save(record);
-    }
-    
-    /**
-     * 获取用户的浏览记录列表
-     */
-    @Override
-    public Page<UserInfoVO> getBrowseHistory(Integer userId, Integer pageNum, Integer pageSize) {
-        // 分页查询浏览记录，按浏览时间倒序
-        Page<UserInfoVO> page = new Page<>(pageNum, pageSize);
-        return userBrowseUserMapper.getBrowseHistory(page, userId.longValue());
-    }
-    
-    /**
-     * 清空用户的所有浏览记录
-     */
-    @Override
-    @Transactional(rollbackFor = Exception.class)
-    public void clearBrowseHistory(Integer userId) {
-        userBrowseUserMapper.deleteByVisitorId(userId.longValue());
-    }
-    
-    /**
-     * 删除用户对某个特定用户的浏览记录
-     */
-    @Override
-    @Transactional(rollbackFor = Exception.class)
-    public void deleteBrowseHistory(Integer userId, Integer lookUserId) {
-        userBrowseUserMapper.deleteByVisitorAndVisited(userId.longValue(), lookUserId.longValue());
-    }
-}

service/Essential/src/main/resources/com/zhentao/mapper/UserBrowseUserMapper.xml

@@ -1,79 +0,0 @@
-<?xml version="1.0" encoding="UTF-8" ?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.zhentao.mapper.UserBrowseUserMapper">
-    
-    <!-- 按浏览时间倒序获取用户的浏览记录，包含被浏览用户的基本信息 -->
-    <select id="getBrowseHistory" resultType="com.zhentao.vo.UserInfoVO">
-        SELECT 
-            u.id as userId,
-            u.nickname,
-            u.avatar,
-            u.gender,
-            u.age,
-            u.height,
-            u.weight,
-            u.education,
-            u.salary,
-            u.education_text as educationText,
-            u.salary_text as salaryText,
-            u.birth_date as birthDate,
-            u.constellation,
-            u.zodiac,
-            u.mbti,
-            u.province,
-            u.city,
-            u.area,
-            u.position,
-            u.company,
-            u.marital_status as maritalStatus,
-            u.have_children as haveChildren,
-            u.religion,
-            u.smoke,
-            u.drink,
-            u.work_industry as workIndustry,
-            u.work_status as workStatus,
-            u.housing_condition as housingCondition,
-            u.car_condition as carCondition,
-            u.self_introduction as selfIntroduction,
-            u.life_style as lifeStyle,
-            u.family_background as familyBackground,
-            u.ideal_partner as idealPartner,
-            u.is_vip as isVip,
-            u.vip_expire_time as vipExpireTime,
-            u.status,
-            u.create_time as createTime,
-            u.update_time as updateTime,
-            ul.create_time as viewTime
-        FROM 
-            user_look ul
-        LEFT JOIN 
-            users u ON ul.look_user_id = u.id
-        WHERE 
-            ul.user_id = #{visitorId}
-        ORDER BY 
-            ul.create_time DESC
-    </select>
-    
-    <!-- 删除用户的所有浏览记录 -->
-    <delete id="deleteByVisitorId">
-        DELETE FROM user_look WHERE user_id = #{visitorId}
-    </delete>
-    
-    <!-- 删除用户对某个特定用户的浏览记录 -->
-    <delete id="deleteByVisitorAndVisited">
-        DELETE FROM user_look WHERE user_id = #{visitorId} AND look_user_id = #{visitedUserId}
-    </delete>
-    
-    <!-- 获取用户最近一次浏览某个特定用户的记录 -->
-    <select id="getLatestByVisitorAndVisited" resultType="com.zhentao.entity.UserBrowseUser">
-        SELECT 
-            *
-        FROM 
-            user_look
-        WHERE 
-            user_id = #{visitorId} AND look_user_id = #{visitedUserId}
-        ORDER BY 
-            create_time DESC
-        LIMIT 1
-    </select>
-</mapper>

service/Recommend/src/main/java/com/zhentao/controller/RecommendController.java

@@ -307,20 +307,50 @@ public class RecommendController {
         }
     }
     
-    // 获取喜欢我的用户数量
-    @GetMapping("/liked-me-users-count")
-    public Result<Integer> getUsersWhoLikedMeCount(
+    // 保存用户浏览记录
+    @PostMapping("/save-look")
+    public Result<Boolean> saveUserLook(
+            @RequestParam("userId") Integer userId,
+            @RequestParam("lookUserId") Integer lookUserId
+    ) {
+        try {
+            boolean result = recommendService.saveUserLook(userId, lookUserId);
+            return Result.success(result);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return Result.error("保存浏览记录失败: " + e.getMessage());
+        }
+    }
+    
+    // 获取用户浏览的列表
+    @GetMapping("/browse-history")
+    public Result<List<RecommendUserVO>> getLookedUsers(
+            @RequestParam("userId") Integer userId,
+            @RequestParam(value = "offset", required = false, defaultValue = "0") Integer offset,
+            @RequestParam(value = "limit", required = false, defaultValue = "20") Integer limit
+    ) {
+        try {
+            List<RecommendUserVO> list = recommendService.getLookedUsers(userId, offset, limit);
+            return Result.success(list);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return Result.error("获取浏览记录失败: " + e.getMessage());
+        }
+    }
+    
+    // 获取用户浏览的用户数量
+    @GetMapping("/browse-history-count")
+    public Result<Integer> getLookedUsersCount(
             @RequestParam("userId") Integer userId
     ) {
         try {
-            Integer count = recommendService.countUsersWhoLikedMe(userId);
+            Integer count = recommendService.countLookedUsers(userId);
             return Result.success(count);
         } catch (Exception e) {
             e.printStackTrace();
-            return Result.error("获取喜欢我的用户数量失败: " + e.getMessage());
+            return Result.error("获取浏览记录数量失败: " + e.getMessage());
         }
     }
-
 }
 
 

service/Recommend/src/main/java/com/zhentao/mapper/RecommendMapper.java

@@ -54,6 +54,15 @@ public interface RecommendMapper {
     
     // 统计喜欢当前用户的用户数量
     Integer countUsersWhoLikedMe(@Param("userId") Integer userId);
+    
+    // 插入用户浏览记录
+    int insertUserLook(@Param("userId") Integer userId, @Param("lookUserId") Integer lookUserId);
+    
+    // 查询用户浏览的列表
+    List<RecommendUserVO> selectLookedUsers(@Param("userId") Integer userId, @Param("offset") Integer offset, @Param("limit") Integer limit);
+    
+    // 统计用户浏览的用户数量
+    Integer countLookedUsers(@Param("userId") Integer userId);
 }
 
 

service/Recommend/src/main/java/com/zhentao/pojo/UserLook.java

@@ -0,0 +1,52 @@
+package com.zhentao.pojo;
+
+import java.util.Date;
+
+public class UserLook {
+    private Integer id;
+    private Integer userId;
+    private Integer lookUserId;
+    private Date createTime;
+    private Date updateTime;
+
+    // getter和setter方法
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getUserId() {
+        return userId;
+    }
+
+    public void setUserId(Integer userId) {
+        this.userId = userId;
+    }
+
+    public Integer getLookUserId() {
+        return lookUserId;
+    }
+
+    public void setLookUserId(Integer lookUserId) {
+        this.lookUserId = lookUserId;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Date getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(Date updateTime) {
+        this.updateTime = updateTime;
+    }
+}

service/Recommend/src/main/java/com/zhentao/service/RecommendService.java

@@ -31,6 +31,15 @@ public interface RecommendService {
     
     // 获取喜欢当前用户的用户数量
     Integer countUsersWhoLikedMe(Integer userId);
+    
+    // 保存用户浏览记录
+    boolean saveUserLook(Integer userId, Integer lookUserId);
+    
+    // 获取用户浏览列表
+    List<RecommendUserVO> getLookedUsers(Integer userId, Integer offset, Integer limit);
+    
+    // 获取用户浏览的用户数量
+    Integer countLookedUsers(Integer userId);
 }
 
 

service/Recommend/src/main/java/com/zhentao/service/impl/RecommendServiceImpl.java

@@ -527,6 +527,52 @@ public class RecommendServiceImpl implements RecommendService {
             return 0;
         }
     }
+
+    @Override
+    public boolean saveUserLook(Integer userId, Integer lookUserId) {
+        if (userId == null || lookUserId == null) {
+            throw new IllegalArgumentException("userId and lookUserId cannot be null");
+        }
+        try {
+            int result = recommendMapper.insertUserLook(userId, lookUserId);
+            return result > 0;
+        } catch (Exception ex) {
+            log.error("saveUserLook failed", ex);
+            return false;
+        }
+    }
+
+    @Override
+    public List<RecommendUserVO> getLookedUsers(Integer userId, Integer offset, Integer limit) {
+        if (userId == null) {
+            throw new IllegalArgumentException("userId cannot be null");
+        }
+        if (limit == null || limit <= 0) {
+            limit = 20;
+        }
+        if (offset == null || offset < 0) {
+            offset = 0;
+        }
+        try {
+            return recommendMapper.selectLookedUsers(userId, offset, limit);
+        } catch (Exception ex) {
+            log.error("getLookedUsers failed", ex);
+            return java.util.Collections.emptyList();
+        }
+    }
+
+    @Override
+    public Integer countLookedUsers(Integer userId) {
+        if (userId == null) {
+            throw new IllegalArgumentException("userId cannot be null");
+        }
+        try {
+            return recommendMapper.countLookedUsers(userId);
+        } catch (Exception ex) {
+            log.error("countLookedUsers failed", ex);
+            return 0;
+        }
+    }
 }
 
 

service/Recommend/src/main/resources/mapper/RecommendMapper.xml

@@ -665,6 +665,67 @@
           AND u.status = 1
         ]]>
     </select>
+    
+    <!-- 插入用户浏览记录 -->
+    <insert id="insertUserLook">
+        <![CDATA[
+        INSERT INTO user_look (user_id, look_user_id, create_time, update_time)
+        VALUES (#{userId}, #{lookUserId}, NOW(), NOW())
+        ON DUPLICATE KEY UPDATE update_time = NOW()
+        ]]>
+    </insert>
+    
+    <!-- 查询用户浏览的列表 -->
+    <select id="selectLookedUsers" resultMap="RecommendUserMap">
+        <![CDATA[
+        SELECT DISTINCT
+            ul.create_time,
+          u.user_id,
+          u.nickname,
+          u.gender,
+          u.birth_date,
+          DATE_FORMAT(u.birth_date, '%Y-%m-%d') AS birthDate,
+          p.province_id,
+          p.city_id,
+          p.area_id,
+          pr.name AS province_name,
+          ct.name AS city_name,
+          ar.name AS area_name,
+          p.height,
+          p.weight,
+          p.education_level,
+          p.salary_range,
+          p.hobby,
+          p.star,
+          p.animal,
+          p.school_name,
+          p.job_title,
+          u.avatar_url,
+          u.last_active_at,
+          80.0 AS compatibility_score
+        FROM user_look ul
+        JOIN users u ON u.user_id = ul.look_user_id
+        LEFT JOIN user_profile p ON p.user_id = u.user_id
+        LEFT JOIN province pr ON pr.id = p.province_id
+        LEFT JOIN city ct ON ct.id = p.city_id
+        LEFT JOIN area ar ON ar.id = p.area_id
+        WHERE ul.user_id = #{userId}
+          AND u.status = 1
+        ORDER BY ul.create_time DESC
+        LIMIT #{offset}, #{limit}
+        ]]>
+    </select>
+    
+    <!-- 统计用户浏览的用户数量 -->
+    <select id="countLookedUsers" resultType="java.lang.Integer">
+        <![CDATA[
+        SELECT COUNT(*) 
+        FROM user_look ul
+        JOIN users u ON u.user_id = ul.look_user_id
+        WHERE ul.user_id = #{userId}
+          AND u.status = 1
+        ]]>
+    </select>
 </mapper>