electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/mapper/EdFileInfoMapper.java

@@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.electromagnetic.industry.software.manage.pojo.models.EdFileInfo;
 import org.apache.ibatis.annotations.Mapper;
 
+import java.util.List;
+
 @Mapper
 public interface EdFileInfoMapper extends BaseMapper<EdFileInfo> {
 

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/mapper/UserMapper.java

@@ -77,7 +77,6 @@ public interface UserMapper {
 
     /**
      * 查找用户角色名称
-     *
      * @param userId
      * @return
      */

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/pojo/models/EdFileInfo.java

@@ -20,102 +20,6 @@ import java.util.Date;
 @FieldNameConstants
 public class EdFileInfo extends BaseModel{
 
-    /**
-     * 主键ID
-     */
-    @TableField(value = "id")
-    private String id;
-    /**
-     * 文件id，如果是第一个版本，则和id一致，同一个文件不同版本，file_id是一致的
-     */
-    @TableField(value = "file_id")
-    private String fileId;
-    /**
-     * 父目录id
-     */
-    @TableField(value = "parent_id")
-    private String parentId;
-    /**
-     * 文件类型
-     */
-    @TableField(value = "file_type")
-    private String fileType;
-    /**
-     * 文件名
-     */
-    @TableField(value = "file_name")
-    private String fileName;
-    /**
-     * 文件备注
-     */
-    @TableField(value = "file_note")
-    private String fileNote;
-    /**
-     * 文件内容
-     */
-    @TableField(value = "file_content")
-    private String fileContent;
-    /**
-     * 文件当前版本，文件版本号默认从100开始
-     */
-    @TableField(value = "file_version")
-    private Integer fileVersion;
-    /**
-     * 文件时间，文件编号的最后15位，精确到毫秒
-     */
-    @TableField(value = "file_time")
-    private String fileTime;
-    /**
-     * 文件路径，指到文件的父目录，有各个父目录的id加下划线组成
-     */
-    @TableField(value = "file_path")
-    private String filePath;
-    /**
-     * 数据类型，0-文件夹 1-文件
-     */
-    @TableField(value = "data_type")
-    private Integer dataType;
-    /**
-     * 数据状态，0-发布 1-占用
-     */
-    @TableField(value = "data_status")
-    private Integer dataStatus;
-    /**
-     * 文件的上一个版本号
-     */
-    @TableField(value = "pre_version")
-    private Integer preVersion;
-    /**
-     * 是否有效 0-无效 1-有效
-     */
-    @TableField(value = "effect_flag")
-    private Integer effectFlag;
-    /**
-     * 保存状态，0-上传中 1-上传成功 2-上传失败
-     */
-    @TableField(value = "save_status")
-    private Integer saveStatus;
-    /**
-     * 文件大小
-     */
-    @TableField(value = "file_size")
-    private Long fileSize;
-    /**
-     * 文件夹顺序
-     */
-    @TableField(value = "sort")
-    private Integer sort;
-    /**
-     * 文件编码
-     */
-    @TableField(value = "file_code")
-    private String fileCode;
-    /**
-     * 是否是管理员定义的系统层级目录
-     */
-    @TableField(value = "prj_dir")
-    private Boolean prjDir;
-
     public void newInit() {
         String userId = UserThreadLocal.getUserId();
         String newFileDbId = IdWorker.getSnowFlakeIdString();
@@ -130,4 +34,119 @@ public class EdFileInfo extends BaseModel {
         this.setFileId(newFileDbId);
         this.setEffectFlag(EffectFlagEnum.EFFECT.code);
     }
+
+    /**
+     * 主键ID
+     */
+    @TableField(value = "id")
+    private String id;
+
+    /**
+     * 文件id，如果是第一个版本，则和id一致，同一个文件不同版本，file_id是一致的
+     */
+    @TableField(value = "file_id")
+    private String fileId;
+
+    /**
+     * 父目录id
+     */
+    @TableField(value = "parent_id")
+    private String parentId;
+
+    /**
+     * 文件类型
+     */
+    @TableField(value = "file_type")
+    private String fileType;
+
+
+    /**
+     * 文件名
+     */
+    @TableField(value = "file_name")
+    private String fileName;
+
+    /**
+     * 文件备注
+     */
+    @TableField(value = "file_note")
+    private String fileNote;
+
+    /**
+     * 文件内容
+     */
+    @TableField(value = "file_content")
+    private String fileContent;
+
+    /**
+     * 文件当前版本，文件版本号默认从100开始
+     */
+    @TableField(value = "file_version")
+    private Integer fileVersion;
+
+    /**
+     * 文件时间，文件编号的最后15位，精确到毫秒
+     */
+    @TableField(value = "file_time")
+    private String fileTime;
+
+    /**
+     * 文件路径，指到文件的父目录，有各个父目录的id加下划线组成
+     */
+    @TableField(value = "file_path")
+    private String filePath;
+
+    /**
+     * 数据类型，0-文件夹 1-文件
+     */
+    @TableField(value = "data_type")
+    private Integer dataType;
+
+    /**
+     * 数据状态，0-发布 1-占用
+     */
+    @TableField(value = "data_status")
+    private Integer dataStatus;
+
+    /**
+     * 文件的上一个版本号
+     */
+    @TableField(value = "pre_version")
+    private Integer preVersion;
+
+    /**
+     * 是否有效 0-无效 1-有效
+     */
+    @TableField(value = "effect_flag")
+    private Integer effectFlag;
+
+    /**
+     * 保存状态，0-上传中 1-上传成功 2-上传失败
+     */
+    @TableField(value = "save_status")
+    private Integer saveStatus;
+
+    /**
+     * 文件大小
+     */
+    @TableField(value = "file_size")
+    private Long fileSize;
+
+    /**
+     * 文件夹顺序
+     */
+    @TableField(value = "sort")
+    private Integer sort;
+
+    /**
+     * 文件编码
+     */
+    @TableField(value = "file_code")
+    private String fileCode;
+
+    /**
+     * 是否是管理员定义的系统层级目录
+     */
+    @TableField(value = "prj_dir")
+    private Boolean prjDir;
 }

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/pojo/req/FileInfoQueryDTO.java

@@ -5,48 +5,30 @@ import lombok.Data;
 @Data
 public class FileInfoQueryDTO {
 
-    /**
+    /** 父文件夹id */
-     * 父文件夹id
-     */
     private String parentId;
 
-    /**
+    /** 当前页码 */
-     * 当前页码
-     */
     private Integer pageNum;
 
-    /**
+    /** 每页的数量 */
-     * 每页的数量
-     */
     private Integer pageSize;
 
-    /**
+    /** 搜索关键词 */
-     * 搜索关键词
-     */
     private String keyword;
 
-    /**
+    /** 文件类型 （0-文件夹 1-文件）*/
-     * 文件类型 （0-文件夹 1-文件）
-     */
     private Integer fileType;
 
-    /**
+    /** 上传时间（0-升序，1-降序）*/
-     * 上传时间（0-升序，1-降序）
-     */
     private Integer createdTime;
 
-    /**
+    /** 版本号（0-升序，1-降序 */
-     * 版本号（0-升序，1-降序
-     */
     private Integer fileVersion;
 
-    /**
+    /** 文件大小0-升序，1-降序） */
-     * 文件大小0-升序，1-降序）
-     */
     private Integer fileSize;
 
-    /**
+    /** 状态（0-未发布 1-已发布 2-占用） */
-     * 状态（0-未发布 1-已发布 2-占用）
-     */
     private Integer dataStatus;
 }

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/EdFileInfoService.java

@@ -15,7 +15,6 @@ public interface EdFileInfoService {
 
     /**
      * 查询文件列表
-     *
      * @param fileInfoQueryDTO
      * @return
      */
@@ -23,7 +22,6 @@ public interface EdFileInfoService {
 
     /**
      * 新建文件夹
-     *
      * @param parentId
      * @param newFolderName
      * @return
@@ -32,7 +30,6 @@ public interface EdFileInfoService {
 
     /**
      * 项目层级结构查询
-     *
      * @return
      */
     ElectromagneticResult<?> tree();
@@ -47,7 +44,6 @@ public interface EdFileInfoService {
 
     /**
      * 下载文件
-     *
      * @param id
      * @return
      */
@@ -55,14 +51,12 @@ public interface EdFileInfoService {
 
     /**
      * 更新文件信息
-     *
      * @param updateFileInfoDTO
      */
     ElectromagneticResult<?> updateFileInfo(UpdateFileInfoDTO updateFileInfoDTO);
 
     /**
      * 版本回退
-     *
      * @param fileId
      * @param targetVersion
      * @return
@@ -71,7 +65,6 @@ public interface EdFileInfoService {
 
     /**
      * 查看分片是否存在
-     *
      * @param fileChunkDTO
      * @return
      */
@@ -79,7 +72,6 @@ public interface EdFileInfoService {
 
     /**
      * 批量导入
-     *
      * @param fileChunkDTO
      * @return
      */
@@ -87,7 +79,6 @@ public interface EdFileInfoService {
 
     /**
      * 合并分片
-     *
      * @param identifier
      * @param fileName
      * @param totalChunks
@@ -97,7 +88,6 @@ public interface EdFileInfoService {
 
     /**
      * 导出
-     *
      * @param dataIdArr
      * @return
      */
@@ -105,7 +95,6 @@ public interface EdFileInfoService {
 
     /**
      * 文件上传
-     *
      * @param parentId
      * @param file
      * @param strategy
@@ -115,7 +104,6 @@ public interface EdFileInfoService {
 
     /**
      * 版本查看
-     *
      * @param fileId
      * @return
      */
@@ -123,7 +111,6 @@ public interface EdFileInfoService {
 
     /**
      * 移动文件
-     *
      * @param id
      * @param targetFolderId
      * @return
@@ -132,7 +119,6 @@ public interface EdFileInfoService {
 
     /**
      * 复制文件
-     *
      * @param id
      * @param targetFolderId
      * @return

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/PermissionService.java

@@ -23,7 +23,6 @@ public interface PermissionService {
 
     /**
      * 获得当前角色权限
-     *
      * @param roleId
      * @param fileId
      * @return
@@ -32,7 +31,6 @@ public interface PermissionService {
 
     /**
      * 用户权限列表 转换为 哈希
-     *
      * @param permissionCodes
      * @return
      */

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/RoleService.java

@@ -13,7 +13,6 @@ public interface RoleService extends IService<Role> {
 
     /**
      * 新建角色
-     *
      * @param roleDTO
      * @return
      */
@@ -21,7 +20,6 @@ public interface RoleService extends IService<Role> {
 
     /**
      * 更新角色
-     *
      * @param roleDTO
      * @return
      */
@@ -29,7 +27,6 @@ public interface RoleService extends IService<Role> {
 
     /**
      * 删除角色
-     *
      * @param roleId
      * @return
      */
@@ -37,7 +34,6 @@ public interface RoleService extends IService<Role> {
 
     /**
      * 查看角色
-     *
      * @param roleId
      * @return
      */
@@ -45,7 +41,6 @@ public interface RoleService extends IService<Role> {
 
     /**
      * 查看角色列表
-     *
      * @param rolePageDTO
      * @return
      */
@@ -60,7 +55,6 @@ public interface RoleService extends IService<Role> {
 
     /**
      * 通过角色名称查看角色权限
-     *
      * @param roleName
      * @return
      */

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/UserService.java

@@ -85,7 +85,6 @@ public interface UserService {
 
     /**
      * 重置密码
-     *
      * @param userId
      */
     Boolean resetPassword(String userId);

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/serviceimpl/CommonService.java

@@ -5,6 +5,7 @@ import cn.hutool.core.lang.Assert;
 import cn.hutool.core.lang.tree.Tree;
 import cn.hutool.core.lang.tree.TreeNodeConfig;
 import cn.hutool.core.lang.tree.TreeUtil;
+import cn.hutool.core.text.StrFormatter;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -41,9 +42,14 @@ import static com.electromagnetic.industry.software.common.cons.ElectromagneticC
 @Component
 public class CommonService {
 
+    private final EleLog log = new EleLog(CommonService.class);
     private static final Map<String, String> FILE_TYPE_ENUM = new HashMap<>();
+
     private static final Map<String, String> ID_NAME = new ConcurrentHashMap<>();
 
+    @Value("${prj.folder.max.length}")
+    private int prjFolderMaxLength;
+
     static {
         FILE_TYPE_ENUM.put(EleDataTypeEnum.FOLDER.desc, "01");
         FILE_TYPE_ENUM.put("py", "02");
@@ -66,9 +72,6 @@ public class CommonService {
         FILE_TYPE_ENUM.put("pptx", "19");
     }
 
-    private final EleLog log = new EleLog(CommonService.class);
-    @Value("${prj.folder.max.length}")
-    private int prjFolderMaxLength;
     @Getter
     private String eleDataPath;
 

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/serviceimpl/EdFileInfoServiceImpl.java

@@ -86,7 +86,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 查询文件列表
-     *
      * @param fileInfoQueryDTO
      * @return
      */
@@ -124,7 +123,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 新建文件夹
-     *
      * @param parentId
      * @param newFolderName
      * @return
@@ -137,7 +135,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 项目层级结构查询
-     *
      * @return
      */
     @Override
@@ -147,7 +144,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 删除目录
-     *
      * @param id
      * @return
      */
@@ -167,7 +163,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 下载文件
-     *
      * @param id
      * @return
      */
@@ -201,32 +196,19 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 更新文件信息
-     *
      * @param updateFileInfoDTO
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
     public ElectromagneticResult<?> updateFileInfo(UpdateFileInfoDTO updateFileInfoDTO) {
         try {
-            // 首先检查新名称是否存在
             EdFileInfo fileInfo = this.baseMapper.selectById(updateFileInfoDTO.getId());
-
-            String parentId = fileInfo.getParentId();
-            long count = this.baseMapper.selectCount(Wrappers.<EdFileInfo>lambdaQuery()
-                    .select(EdFileInfo::getFileName)
-                    .eq(EdFileInfo::getParentId, parentId)
-                    .eq(EdFileInfo::getFileName, updateFileInfoDTO.getFileName())
-                    .eq(EdFileInfo::getFileType, fileInfo.getFileType())
-                    .eq(EdFileInfo::getEffectFlag, EffectFlagEnum.EFFECT.code));
-            Assert.isTrue(count == 0, "文件名已存在");
-
-            String srcFilePath = commonService.getFileSysPath(fileInfo.getFilePath());
             this.baseMapper.update(null, Wrappers.lambdaUpdate(EdFileInfo.class)
                     .eq(EdFileInfo::getId, updateFileInfoDTO.getId())
                     .set(EdFileInfo::getFileName, updateFileInfoDTO.getFileName())
                     .set(EdFileInfo::getFileNote, updateFileInfoDTO.getFileNote()));
-            String newName = updateFileInfoDTO.getFileName() + "." + fileInfo.getFileType() + "." + fileInfo.getFileCode();
+            String sysFilePath = commonService.getFileSysPath(fileInfo.getFilePath()); // file or folder
-            fileSystemService.renameFile(srcFilePath, newName);
+            fileSystemService.renameFile(sysFilePath, updateFileInfoDTO.getFileName());
             return ElectromagneticResultUtil.success(true);
         } catch (Exception e) {
             String info = "更新文件信息失败。";
@@ -264,7 +246,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 查看分片是否存在
-     *
      * @param fileChunkDTO
      * @return
      */
@@ -292,7 +273,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 批量导入
-     *
      * @param fileChunkDTO
      * @return
      */
@@ -323,7 +303,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
      * case1: 用户上传的新文件
      * case2: 用户上传的带版本号的文件
      * case3: 用户上传的文件在线上已经被移动到其他目录
-     *
      * @param identifier
      * @param fileName
      * @param totalChunks
@@ -503,7 +482,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 导出
-     *
      * @param dataIdArr
      * @return
      */
@@ -573,7 +551,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 文件上传
-     *
      * @param parentId
      * @param file
      * @param strategy 1-跳过冲突文件 2-做版本更新 3-重命名，文件名加“_1"
@@ -751,7 +728,6 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
 
     /**
      * 复制文件
-     *
      * @param id
      * @param targetFolderId
      * @return

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/serviceimpl/EdPrjServiceImpl.java

@@ -119,7 +119,6 @@ public class EdPrjServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileInfo>
 
     /**
      * 修改项目名称
-     *
      * @param prjId
      * @param newPrjName
      * @return
@@ -164,7 +163,6 @@ public class EdPrjServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileInfo>
 
     /**
      * 删除一个项目，做逻辑删除
-     *
      * @param prjId
      * @return
      */
@@ -200,7 +198,6 @@ public class EdPrjServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileInfo>
 
     /**
      * 添加子集
-     *
      * @param parentId
      * @param folderName
      * @return
@@ -215,7 +212,6 @@ public class EdPrjServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileInfo>
 
     /**
      * 查询所有项目
-     *
      * @return
      */
     @Override
@@ -355,7 +351,6 @@ public class EdPrjServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileInfo>
 
     /**
      * 修改子集名称
-     *
      * @param id
      * @param newFolderName
      * @return

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/serviceimpl/PermissionServiceImpl.java

@@ -64,7 +64,6 @@ public class PermissionServiceImpl implements PermissionService {
 
     /**
      * 根据用户获得角色
-     *
      * @param userId
      * @return
      */
@@ -76,7 +75,6 @@ public class PermissionServiceImpl implements PermissionService {
 
     /**
      * 获得角色权限
-     *
      * @param roleId
      * @param fileId
      * @return
@@ -92,7 +90,6 @@ public class PermissionServiceImpl implements PermissionService {
 
     /**
      * 用户权限列表 转换为 哈希
-     *
      * @param permissionCodes
      * @return
      */

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/serviceimpl/RoleServiceImpl.java

@@ -20,19 +20,13 @@ import com.electromagnetic.industry.software.manage.pojo.models.UserRole;
 import com.electromagnetic.industry.software.manage.pojo.req.RoleDTO;
 import com.electromagnetic.industry.software.manage.pojo.req.RolePageDTO;
 import com.electromagnetic.industry.software.manage.pojo.req.RolePermissionDTO;
-import com.electromagnetic.industry.software.manage.service.PermissionService;
+import com.electromagnetic.industry.software.manage.service.*;
-import com.electromagnetic.industry.software.manage.service.RolePermissionService;
-import com.electromagnetic.industry.software.manage.service.RoleService;
-import com.electromagnetic.industry.software.manage.service.UserRoleService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
+import java.util.*;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
 import java.util.stream.Collectors;
 
 import static com.electromagnetic.industry.software.common.cons.ElectromagneticConstants.PRJ_PARENT_ID;
@@ -55,7 +49,6 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements Ro
 
     /**
      * 新建角色
-     *
      * @param roleDTO
      * @return
      */
@@ -87,7 +80,6 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements Ro
 
     /**
      * 更新角色
-     *
      * @param roleDTO
      * @return
      */
@@ -121,7 +113,6 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements Ro
 
     /**
      * 删除角色
-     *
      * @param roleId
      * @return
      */
@@ -144,7 +135,6 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements Ro
 
     /**
      * 查看角色
-     *
      * @param roleId
      * @return
      */
@@ -190,7 +180,6 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements Ro
 
     /**
      * 通过角色名查看角色
-     *
      * @param roleName
      * @return
      */
@@ -205,7 +194,6 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements Ro
 
     /**
      * 查看角色列表
-     *
      * @param rolePageDTO
      * @return
      */
@@ -270,7 +258,6 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements Ro
 
     /**
      * 权限层级数据扁平化
-     *
      * @param nodes
      * @param roleId
      * @return

electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/serviceimpl/UserServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.SystemClock;
 import cn.hutool.core.util.RandomUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.electromagnetic.industry.software.common.cons.UserConstants;
 import com.electromagnetic.industry.software.common.enums.ActiveEnum;
 import com.electromagnetic.industry.software.common.enums.EffectFlagEnum;
@@ -278,7 +279,6 @@ public class UserServiceImpl implements UserService {
 
     /**
      * 重置密码
-     *
      * @param userId
      */
     @Override

electrmangnetic/src/main/resources/sqlmapper/UserMapper.xml

@@ -253,10 +253,8 @@
     </update>
 
     <select id="selectUserRoles" parameterType="String" resultType="String">
-        select r.role_name
+        select r.role_name from ed_role r where r.role_id in (
-        from ed_role r
+            select ur.role_id from ed_users u
-        where r.role_id in (select ur.role_id
-                            from ed_users u
                 left join ed_user_role ur on u.user_id = ur.user_id
             where u.user_id = #{userId})
     </select>