1

dd

2025-10-27 11ffae1ecbe3d26863fd51262d7ffb043eb089da

 ruoyi-admin/src/main/java/com/ruoyi/web/controller/group/ImGroupController.java

@@ -1,15 +1,41 @@
package com.ruoyi.web.controller.group;

import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.im.comm.Result;
import com.ruoyi.im.config.AddTeamMembersRequest;
import com.ruoyi.im.config.CreateTeamRequest;
import com.ruoyi.im.config.AssignmentRequest;
import com.ruoyi.im.dto.UpdateUserBusinessDto;
import com.ruoyi.im.service.NeteaseTeamService;
import com.ruoyi.system.domain.NeteaseTeam;
import com.ruoyi.system.domain.SystemConfiguration;
import com.ruoyi.system.domain.UserAccount;
import com.ruoyi.system.domain.vo.GroupVo;
import com.ruoyi.system.domain.vo.UserAccountVo;
import com.ruoyi.system.mapper.SystemConfigurationMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.attribute.PosixFilePermission;
import java.nio.file.attribute.PosixFilePermissions;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.UUID;

@RestController
@RequestMapping("/im/group")
@@ -20,11 +46,48 @@
    @Autowired
    NeteaseTeamService neteaseGroupService;


    @Autowired
    private SystemConfigurationMapper systemConfigurationMapper;

    @Value("${file.upload-dir}")
    private String uploadDir;


    /**
     * 获取群组列表
     */
//    @PreAuthorize("@ss.hasPermi('im:group:list')")
    @GetMapping("/list")
    public TableDataInfo list(GroupVo vo)
    {
        // 创建查询条件包装器
        LambdaQueryWrapper<NeteaseTeam> queryWrapper = new LambdaQueryWrapper<>();

        // 只有当 keyword 不为空时才添加 OR 条件
        if (ObjectUtil.isNotEmpty(vo.getKeywords())) {
            queryWrapper.and(wrapper -> wrapper
                    .eq(NeteaseTeam::getTid, vo.getKeywords())
                    .or()
                    .eq(NeteaseTeam::getOwnerAccountId, vo.getKeywords())
                    .or()
                    .eq(NeteaseTeam::getName,vo.getKeywords())
            );
        }

        // 默认按创建时间倒序
        queryWrapper.orderByDesc(NeteaseTeam::getCreateTime);
        startPage();
        List<NeteaseTeam> list = neteaseGroupService.list(queryWrapper);
        return getDataTable(list);
    }


    /**
     * 创建群组
     */
    @PostMapping("/create")
    public AjaxResult createGroup(@Validated @RequestBody CreateTeamRequest request) {
    public AjaxResult createGroup(CreateTeamRequest request) {
        return neteaseGroupService.createGroup(request);
    }

@@ -32,7 +95,7 @@
     * 更新群组
     */
    @PostMapping("/updateCreate")
    public AjaxResult updateCreate(@Validated @RequestBody CreateTeamRequest request) {
    public AjaxResult updateCreate(CreateTeamRequest request) {
        return neteaseGroupService.updateCreate(request);
    }

@@ -40,7 +103,7 @@
     * 拉人进去
     */
    @PostMapping("/inviteTeamMembers")
    public AjaxResult inviteTeamMembers(@Validated @RequestBody AddTeamMembersRequest request) {
    public AjaxResult inviteTeamMembers( AddTeamMembersRequest request) {
        return neteaseGroupService.inviteTeamMembers(request);
    }

@@ -48,16 +111,94 @@
     * 转让群主
     */
    @PostMapping("/assignment")
    public AjaxResult assignment(@Validated @RequestBody AssignmentRequest request) {
    public AjaxResult assignment(AssignmentRequest request) {
        return neteaseGroupService.assignment(request);
    }

    /**
     * 解散
     */
    @PostMapping("/dismiss")
    public AjaxResult dismiss(@PathVariable("id") Long id) {
        return neteaseGroupService.dismiss(id);
    @GetMapping("/dismiss")
    public AjaxResult dismiss(@RequestParam(value = "groupId") Integer groupId) {
        return neteaseGroupService.dismiss(groupId);
    }


    @PostMapping("/upload")
    public Result uploadFile(@RequestParam("file") MultipartFile file) {
        try {

            SystemConfiguration systemConfiguration = systemConfigurationMapper.selectById(1);
            if(ObjectUtil.isEmpty(systemConfiguration)){
                return Result.error("文件上传失败！");
            }

            // 1. 验证文件类型
            String contentType = file.getContentType();
            if (contentType == null ||
                    (!contentType.equals("image/jpeg") &&
                            !contentType.equals("image/png") &&
                            !contentType.equals("image/gif"))) {

                return Result.error("只支持JPEG、PNG和GIF格式的图片!");
            }

            // 确保上传目录存在
            File directory = new File(uploadDir);
            if (!directory.exists()) {
                directory.mkdirs();
                // 设置目录权限为755 (rwxr-xr-x)
                setPermissions(directory, "rwxr-xr-x");
            }

            // 生成唯一文件名
            String fileName = UUID.randomUUID().toString() + "_" + file.getOriginalFilename();
            Path filePath = Paths.get(uploadDir, fileName);

            // 保存文件
            Files.write(filePath, file.getBytes());

            // 设置文件权限为644 (rw-r--r--)
            setPermissions(filePath.toFile(), "rw-r--r--");

            // 5. 调用网易云信API更新头像
            fileName = systemConfiguration.getImgUrl()+"/"+fileName;
            return Result.success("文件上传成功",fileName);
        } catch (IOException e) {
            return Result.error("文件上传失败");
        } catch (Exception e) {
            e.printStackTrace();
            log.error("设置文件权限失败！");
        }
        return Result.success();
    }

    /**
     * 设置文件/目录权限
     * @param file 文件或目录对象
     * @param perm 权限字符串，如 "rw-r--r--"
     */
    private void setPermissions(File file, String perm) throws IOException {
        // 获取当前操作系统
        String os = System.getProperty("os.name").toLowerCase();

        // 只有在Unix/Linux系统上才能设置POSIX权限
        if (os.contains("nix") || os.contains("nux") || os.contains("mac")) {
            Set<PosixFilePermission> permissions = PosixFilePermissions.fromString(perm);
            Files.setPosixFilePermissions(file.toPath(), permissions);
        } else {
            // Windows系统不支持POSIX权限，可以设置基本权限
            file.setReadable(true, false);    // 所有用户可读
            if (perm.startsWith("rw")) {
                file.setWritable(true, false); // 所有用户可写（如果权限字符串以rw开头）
            } else {
                file.setWritable(false, false);
            }

            // 如果是目录且包含执行权限，设置可执行
            if (file.isDirectory() && perm.contains("x")) {
                file.setExecutable(true, false);
            }
        }
    }
}