[yxf] 1 month ago
parent
commit
f122009fb4
  1. 63
      im-admin-ui/src/api/im/autoReply/index.ts
  2. 95
      im-admin-ui/src/api/im/autoReply/types.ts
  3. 293
      im-admin-ui/src/views/im/autoReply/index.vue
  4. 22
      im-admin-ui/src/views/index.vue
  5. 105
      im-admin/ruoyi-im/src/main/java/org/dromara/im/controller/ImAutoReplyController.java
  6. 74
      im-admin/ruoyi-im/src/main/java/org/dromara/im/domain/ImAutoReply.java
  7. 63
      im-admin/ruoyi-im/src/main/java/org/dromara/im/domain/bo/ImAutoReplyBo.java
  8. 73
      im-admin/ruoyi-im/src/main/java/org/dromara/im/domain/vo/ImAutoReplyVo.java
  9. 15
      im-admin/ruoyi-im/src/main/java/org/dromara/im/mapper/ImAutoReplyMapper.java
  10. 68
      im-admin/ruoyi-im/src/main/java/org/dromara/im/service/IImAutoReplyService.java
  11. 199
      im-admin/ruoyi-im/src/main/java/org/dromara/im/service/impl/ImAutoReplyServiceImpl.java
  12. 7
      im-admin/ruoyi-im/src/main/resources/mapper/im/ImAutoReplyMapper.xml

63
im-admin-ui/src/api/im/autoReply/index.ts

@ -0,0 +1,63 @@
import request from '@/utils/request';
import { AxiosPromise } from 'axios';
import { AutoReplyVO, AutoReplyForm, AutoReplyQuery } from '@/api/im/autoReply/types';
/**
*
* @param query
* @returns {*}
*/
export const listAutoReply = (query?: AutoReplyQuery): AxiosPromise<AutoReplyVO[]> => {
return request({
url: '/im/autoReply/list',
method: 'get',
params: query
});
};
/**
*
* @param id
*/
export const getAutoReply = (id: string | number): AxiosPromise<AutoReplyVO> => {
return request({
url: '/im/autoReply/' + id,
method: 'get'
});
};
/**
*
* @param data
*/
export const addAutoReply = (data: AutoReplyForm) => {
return request({
url: '/im/autoReply',
method: 'post',
data: data
});
};
/**
*
* @param data
*/
export const updateAutoReply = (data: AutoReplyForm) => {
return request({
url: '/im/autoReply',
method: 'put',
data: data
});
};
/**
*
* @param id
*/
export const delAutoReply = (id: string | number | Array<string | number>) => {
return request({
url: '/im/autoReply/' + id,
method: 'delete'
});
};

95
im-admin-ui/src/api/im/autoReply/types.ts

@ -0,0 +1,95 @@
export interface AutoReplyVO {
/**
* ID
*/
id: string | number;
/**
*
*/
replyName: string;
/**
* 0-1-
*/
replyType: number;
/**
*
*/
replyTitle: string;
/**
*
*/
replyContent: string;
/**
* Url
*/
replyContentUrl: string;
}
export interface AutoReplyForm extends BaseEntity {
/**
* ID
*/
id?: string | number;
/**
*
*/
replyName?: string;
/**
* 0-1-
*/
replyType?: number;
/**
*
*/
replyTitle?: string;
/**
*
*/
replyContent?: string;
/**
*
*/
remark?: string;
}
export interface AutoReplyQuery extends PageQuery {
/**
*
*/
replyName?: string;
/**
* 0-1-
*/
replyType?: number;
/**
*
*/
replyTitle?: string;
/**
*
*/
replyContent?: string;
/**
*
*/
params?: any;
}

293
im-admin-ui/src/views/im/autoReply/index.vue

@ -0,0 +1,293 @@
<template>
<div class="p-2">
<transition :enter-active-class="proxy?.animate.searchAnimate.enter" :leave-active-class="proxy?.animate.searchAnimate.leave">
<div v-show="showSearch" class="mb-[10px]">
<el-card shadow="hover">
<el-form ref="queryFormRef" :model="queryParams" :inline="true">
<el-form-item label="回复名称" prop="replyName">
<el-input v-model="queryParams.replyName" placeholder="请输入自动回复名称" clearable @keyup.enter="handleQuery" />
</el-form-item>
<el-form-item label="类型" prop="replyType">
<el-select v-model="queryParams.replyType" placeholder="请选择回复类型" clearable>
<el-option v-for="dict in file_type" :key="dict.value" :label="dict.label" :value="dict.value" />
</el-select>
</el-form-item>
<el-form-item label="标题" prop="replyTitle">
<el-input v-model="queryParams.replyTitle" placeholder="请输入自动回复标题" clearable @keyup.enter="handleQuery" />
</el-form-item>
<el-form-item>
<el-button type="primary" icon="Search" @click="handleQuery">搜索</el-button>
<el-button icon="Refresh" @click="resetQuery">重置</el-button>
</el-form-item>
</el-form>
</el-card>
</div>
</transition>
<el-card shadow="never">
<template #header>
<el-row :gutter="10" class="mb8">
<el-col :span="1.5">
<el-button v-hasPermi="['im:autoReply:add']" type="primary" plain icon="Plus" @click="handleAdd">新增</el-button>
</el-col>
<el-col :span="1.5">
<el-button v-hasPermi="['im:autoReply:edit']" type="success" plain icon="Edit" :disabled="single" @click="handleUpdate()">修改</el-button>
</el-col>
<el-col :span="1.5">
<el-button v-hasPermi="['im:autoReply:remove']" type="danger" plain icon="Delete" :disabled="multiple" @click="handleDelete()"
>删除</el-button
>
</el-col>
<right-toolbar v-model:showSearch="showSearch" @query-table="getList"></right-toolbar>
</el-row>
</template>
<el-table v-loading="loading" :data="autoReplyList" @selection-change="handleSelectionChange">
<el-table-column type="selection" width="55" align="center" />
<!-- <el-table-column label="主键ID" align="center" prop="id" v-if="true" /> -->
<el-table-column label="名称" align="center" prop="replyName" width="150" />
<el-table-column label="回复类型" align="center" prop="replyType" width="100">
<template #default="scope">
<dict-tag :options="file_type" :value="scope.row.replyType" />
</template>
</el-table-column>
<el-table-column label="自动回复标题" align="center" prop="replyTitle" width="250" />
<el-table-column label="自动回复内容" align="center" prop="replyContent" width="400">
<template #default="scope">
<div v-if="scope.row.replyType === 0">{{ scope.row.replyContent }}</div>
<div v-else-if="scope.row.replyType === 1">
<image-preview :src="scope.row.replyContent" :full-src="scope.row.replyContent" :width="50" :height="50" />
</div>
</template>
</el-table-column>
<el-table-column label="操作" align="center" class-name="small-padding fixed-width">
<template #default="scope">
<el-tooltip content="修改" placement="top">
<el-button v-hasPermi="['im:autoReply:edit']" link type="primary" icon="Edit" @click="handleUpdate(scope.row)"></el-button>
</el-tooltip>
<el-tooltip content="删除" placement="top">
<el-button v-hasPermi="['im:autoReply:remove']" link type="primary" icon="Delete" @click="handleDelete(scope.row)"></el-button>
</el-tooltip>
</template>
</el-table-column>
</el-table>
<pagination v-show="total > 0" v-model:page="queryParams.pageNum" v-model:limit="queryParams.pageSize" :total="total" @pagination="getList" />
</el-card>
<!-- 添加或修改自动回复对话框 -->
<el-dialog v-model="dialog.visible" :title="dialog.title" width="800px" append-to-body>
<el-form ref="autoReplyFormRef" :model="form" :rules="rules" label-width="80px">
<el-form-item label="回复名称" prop="replyName">
<el-input v-model="form.replyName" placeholder="请输入自动回复名称" />
</el-form-item>
<el-form-item label="回复类型" prop="replyType">
<el-select v-model="form.replyType" placeholder="请选择回复类型" @change="handleTypeChange">
<el-option v-for="dict in file_type" :key="dict.value" :label="dict.label" :value="parseInt(dict.value)"></el-option>
</el-select>
</el-form-item>
<el-form-item label="标题" prop="replyTitle">
<el-input v-model="form.replyTitle" placeholder="请输入自动回复标题" />
</el-form-item>
<el-form-item label="内容" prop="replyContent">
<div v-if="form.replyType === 0">
<el-input v-model="form.replyContent" type="textarea" :rows="4" placeholder="请输入文本内容" />
</div>
<div v-else-if="form.replyType === 1">
<image-upload v-model="form.replyContent" />
</div>
</el-form-item>
<el-form-item label="备注" prop="remark">
<el-input v-model="form.remark" type="textarea" placeholder="请输入内容" />
</el-form-item>
</el-form>
<template #footer>
<div class="dialog-footer">
<el-button :loading="buttonLoading" type="primary" @click="submitForm"> </el-button>
<el-button @click="cancel"> </el-button>
</div>
</template>
</el-dialog>
</div>
</template>
<script setup name="AutoReply" lang="ts">
import { listAutoReply, getAutoReply, delAutoReply, addAutoReply, updateAutoReply } from '@/api/im/autoReply';
import { AutoReplyVO, AutoReplyQuery, AutoReplyForm } from '@/api/im/autoReply/types';
const { proxy } = getCurrentInstance() as ComponentInternalInstance;
const { file_type } = toRefs<any>(proxy?.useDict('file_type'));
const autoReplyList = ref<AutoReplyVO[]>([]);
const buttonLoading = ref(false);
const loading = ref(true);
const showSearch = ref(true);
const ids = ref<Array<string | number>>([]);
const single = ref(true);
const multiple = ref(true);
const total = ref(0);
const queryFormRef = ref<ElFormInstance>();
const autoReplyFormRef = ref<ElFormInstance>();
const dialog = reactive<DialogOption>({
visible: false,
title: ''
});
const initFormData: AutoReplyForm = {
id: undefined,
replyName: undefined,
replyType: 0,
replyTitle: undefined,
replyContent: undefined,
remark: undefined
};
const data = reactive<PageData<AutoReplyForm, AutoReplyQuery>>({
form: { ...initFormData },
queryParams: {
pageNum: 1,
pageSize: 10,
replyName: undefined,
replyType: undefined,
replyTitle: undefined,
params: {}
},
rules: {
id: [{ required: true, message: '主键ID不能为空', trigger: 'blur' }],
replyName: [{ required: true, message: '自动回复名称不能为空', trigger: 'blur' }],
replyType: [{ required: true, message: '回复类型不能为空', trigger: 'change' }],
replyTitle: [{ required: true, message: '自动回复标题不能为空', trigger: 'blur' }],
replyContent: [
{ required: true, message: '自动回复内容不能为空', trigger: 'blur' },
{ validator: validateReplyContent, trigger: 'blur' }
]
}
});
const { queryParams, form, rules } = toRefs(data);
//
function validateReplyContent(rule: any, value: any, callback: any) {
if (form.value.replyType === 0) {
//
if (!value) {
callback(new Error('请填写文本内容'));
} else if (value.length > 500) {
callback(new Error('文本内容不能超过500个字符'));
} else {
callback();
}
} else {
//
if (!value) {
callback(new Error('请选择要上传的图片'));
} else {
callback();
}
}
}
/** 处理类型改变事件 */
const handleTypeChange = () => {
//
form.value.replyContent = undefined;
};
/** 查询自动回复列表 */
const getList = async () => {
loading.value = true;
const res = await listAutoReply(queryParams.value);
autoReplyList.value = res.rows;
total.value = res.total;
loading.value = false;
};
/** 取消按钮 */
const cancel = () => {
reset();
dialog.visible = false;
};
/** 表单重置 */
const reset = () => {
form.value = { ...initFormData };
autoReplyFormRef.value?.resetFields();
};
/** 搜索按钮操作 */
const handleQuery = () => {
queryParams.value.pageNum = 1;
getList();
};
/** 重置按钮操作 */
const resetQuery = () => {
queryFormRef.value?.resetFields();
handleQuery();
};
/** 多选框选中数据 */
const handleSelectionChange = (selection: AutoReplyVO[]) => {
ids.value = selection.map((item) => item.id);
single.value = selection.length != 1;
multiple.value = !selection.length;
};
/** 新增按钮操作 */
const handleAdd = () => {
reset();
dialog.visible = true;
dialog.title = '添加自动回复';
};
/** 修改按钮操作 */
const handleUpdate = async (row?: AutoReplyVO) => {
reset();
const _id = row?.id || ids.value[0];
const res = await getAutoReply(_id);
Object.assign(form.value, res.data);
dialog.visible = true;
dialog.title = '修改自动回复';
};
/** 提交按钮 */
const submitForm = () => {
autoReplyFormRef.value?.validate(async (valid: boolean) => {
if (valid) {
buttonLoading.value = true;
if (form.value.id) {
await updateAutoReply(form.value).finally(() => (buttonLoading.value = false));
} else {
await addAutoReply(form.value).finally(() => (buttonLoading.value = false));
}
proxy?.$modal.msgSuccess('操作成功');
dialog.visible = false;
await getList();
}
});
};
/** 删除按钮操作 */
const handleDelete = async (row?: AutoReplyVO) => {
const _ids = row?.id || ids.value;
await proxy?.$modal.confirm('是否确认删除自动回复编号为"' + _ids + '"的数据项?').finally(() => (loading.value = false));
await delAutoReply(_ids);
proxy?.$modal.msgSuccess('删除成功');
await getList();
};
/** 导出按钮操作 */
const handleExport = () => {
proxy?.download(
'im/autoReply/export',
{
...queryParams.value
},
`autoReply_${new Date().getTime()}.xlsx`
);
};
onMounted(() => {
getList();
});
</script>

22
im-admin-ui/src/views/index.vue

@ -62,6 +62,21 @@
</div>
</el-card>
</el-col>
<el-col :span="6">
<el-card class="statistics-card">
<div class="statistics-item">
<div class="statistics-icon" style="background-color: #67c23a">
<el-icon size="24">
<ChatDotRound />
</el-icon>
</div>
<div class="statistics-content">
<div class="statistics-title">当前套餐:</div>
<div class="statistics-value2">可添加客服数量:{{ totalGroupCount }}</div>
</div>
</div>
</el-card>
</el-col>
</el-row>
<!-- 统计图表 -->
@ -515,6 +530,13 @@ const initRegistrationChart = async () => {
color: #262626;
line-height: 1;
}
.statistics-value2 {
font-size: 16px;
font-weight: 600;
color: #262626;
line-height: 1;
}
}
}

105
im-admin/ruoyi-im/src/main/java/org/dromara/im/controller/ImAutoReplyController.java

@ -0,0 +1,105 @@
package org.dromara.im.controller;
import java.util.List;
import lombok.RequiredArgsConstructor;
import jakarta.servlet.http.HttpServletResponse;
import jakarta.validation.constraints.*;
import cn.dev33.satoken.annotation.SaCheckPermission;
import org.springframework.web.bind.annotation.*;
import org.springframework.validation.annotation.Validated;
import org.dromara.common.idempotent.annotation.RepeatSubmit;
import org.dromara.common.log.annotation.Log;
import org.dromara.common.web.core.BaseController;
import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.core.domain.R;
import org.dromara.common.core.validate.AddGroup;
import org.dromara.common.core.validate.EditGroup;
import org.dromara.common.log.enums.BusinessType;
import org.dromara.common.excel.utils.ExcelUtil;
import org.dromara.im.domain.vo.ImAutoReplyVo;
import org.dromara.im.domain.bo.ImAutoReplyBo;
import org.dromara.im.service.IImAutoReplyService;
import org.dromara.common.mybatis.core.page.TableDataInfo;
/**
* 自动回复
*
* @author Blue
* @date 2026-04-13
*/
@Validated
@RequiredArgsConstructor
@RestController
@RequestMapping("/im/autoReply")
public class ImAutoReplyController extends BaseController {
private final IImAutoReplyService imAutoReplyService;
/**
* 查询自动回复列表
*/
@SaCheckPermission("im:autoReply:list")
@GetMapping("/list")
public TableDataInfo<ImAutoReplyVo> list(ImAutoReplyBo bo, PageQuery pageQuery) {
return imAutoReplyService.queryPageList(bo, pageQuery);
}
/**
* 导出自动回复列表
*/
@SaCheckPermission("im:autoReply:export")
@Log(title = "自动回复", businessType = BusinessType.EXPORT)
//@PostMapping("/export")
public void export(ImAutoReplyBo bo, HttpServletResponse response) {
List<ImAutoReplyVo> list = imAutoReplyService.queryList(bo);
ExcelUtil.exportExcel(list, "自动回复", ImAutoReplyVo.class, response);
}
/**
* 获取自动回复详细信息
*
* @param id 主键
*/
@SaCheckPermission("im:autoReply:query")
@GetMapping("/{id}")
public R<ImAutoReplyVo> getInfo(@NotNull(message = "主键不能为空")
@PathVariable Long id) {
return R.ok(imAutoReplyService.queryById(id));
}
/**
* 新增自动回复
*/
@SaCheckPermission("im:autoReply:add")
@Log(title = "自动回复", businessType = BusinessType.INSERT)
@RepeatSubmit()
@PostMapping()
public R<Void> add(@Validated(AddGroup.class) @RequestBody ImAutoReplyBo bo) {
return toAjax(imAutoReplyService.insertByBo(bo));
}
/**
* 修改自动回复
*/
@SaCheckPermission("im:autoReply:edit")
@Log(title = "自动回复", businessType = BusinessType.UPDATE)
@RepeatSubmit()
@PutMapping()
public R<Void> edit(@Validated(EditGroup.class) @RequestBody ImAutoReplyBo bo) {
return toAjax(imAutoReplyService.updateByBo(bo));
}
/**
* 删除自动回复
*
* @param ids 主键串
*/
@SaCheckPermission("im:autoReply:remove")
@Log(title = "自动回复", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public R<Void> remove(@NotEmpty(message = "主键不能为空")
@PathVariable Long[] ids) {
return toAjax(imAutoReplyService.deleteWithValidByIds(List.of(ids), true));
}
}

74
im-admin/ruoyi-im/src/main/java/org/dromara/im/domain/ImAutoReply.java

@ -0,0 +1,74 @@
package org.dromara.im.domain;
import com.fhs.core.trans.vo.TransPojo;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import java.util.Date;
/**
* 自动回复对象 im_auto_reply
*
* @author Blue
* @date 2026-04-13
*/
@Data
@TableName("im_auto_reply")
public class ImAutoReply implements TransPojo {
/**
* 主键ID
*/
@TableId(value = "id")
private Long id;
/**
* 唯一token
*/
private String uniqueToken;
/**
* 自动回复名称
*/
private String replyName;
/**
* 0-文本1-图片
*/
private Long replyType;
/**
* 自动回复标题
*/
private String replyTitle;
/**
* 自动回复内容
*/
private String replyContent;
/**
* 备注
*/
private String remark;
/**
* 创建时间
*/
private Date createdTime;
/**
* 更新时间
*/
private Date updatedTime;
/**
* 创建者ID
*/
private Long creatorId;
/**
* 更新者ID
*/
private Long updaterId;
}

63
im-admin/ruoyi-im/src/main/java/org/dromara/im/domain/bo/ImAutoReplyBo.java

@ -0,0 +1,63 @@
package org.dromara.im.domain.bo;
import org.dromara.im.domain.ImAutoReply;
import org.dromara.common.mybatis.core.domain.BaseEntity;
import org.dromara.common.core.validate.AddGroup;
import org.dromara.common.core.validate.EditGroup;
import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data;
import lombok.EqualsAndHashCode;
import jakarta.validation.constraints.*;
import org.dromara.common.translation.annotation.Translation;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.dromara.common.translation.constant.TransConstant;
/**
* 自动回复业务对象 im_auto_reply
*
* @author Blue
* @date 2026-04-13
*/
@Data
@EqualsAndHashCode(callSuper = true)
@AutoMapper(target = ImAutoReply.class, reverseConvertGenerate = false)
public class ImAutoReplyBo extends BaseEntity {
/**
* 主键ID
*/
@NotNull(message = "主键ID不能为空", groups = { EditGroup.class })
private Long id;
/**
* 自动回复名称
*/
@NotBlank(message = "自动回复名称不能为空", groups = { AddGroup.class, EditGroup.class })
private String replyName;
/**
* 0-文本1-图片
*/
@NotNull(message = "0-文本,1-图片不能为空", groups = { AddGroup.class, EditGroup.class })
private Long replyType;
/**
* 自动回复标题
*/
@NotBlank(message = "自动回复标题不能为空", groups = { AddGroup.class, EditGroup.class })
private String replyTitle;
/**
* 自动回复内容
*/
@NotBlank(message = "自动回复内容不能为空", groups = { AddGroup.class, EditGroup.class })
private String replyContent;
/**
* 备注
*/
private String remark;
}

73
im-admin/ruoyi-im/src/main/java/org/dromara/im/domain/vo/ImAutoReplyVo.java

@ -0,0 +1,73 @@
package org.dromara.im.domain.vo;
import org.dromara.common.translation.annotation.Translation;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.dromara.common.translation.constant.TransConstant;
import org.dromara.im.domain.ImAutoReply;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import org.dromara.common.excel.annotation.ExcelDictFormat;
import org.dromara.common.excel.convert.ExcelDictConvert;
import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
import java.util.Date;
/**
* 自动回复视图对象 im_auto_reply
*
* @author Blue
* @date 2026-04-13
*/
@Data
@ExcelIgnoreUnannotated
@AutoMapper(target = ImAutoReply.class)
public class ImAutoReplyVo implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* 主键ID
*/
@ExcelProperty(value = "主键ID")
private Long id;
/**
* 自动回复名称
*/
@ExcelProperty(value = "自动回复名称")
private String replyName;
/**
* 0-文本1-图片
*/
@ExcelProperty(value = "0-文本,1-图片", converter = ExcelDictConvert.class)
@ExcelDictFormat(dictType = "file_type")
private Long replyType;
/**
* 自动回复标题
*/
@ExcelProperty(value = "自动回复标题")
private String replyTitle;
/**
* 自动回复内容
*/
@ExcelProperty(value = "自动回复内容")
private String replyContent;
/**
* 自动回复内容
*/
@ExcelProperty(value = "备注")
private String remark;
}

15
im-admin/ruoyi-im/src/main/java/org/dromara/im/mapper/ImAutoReplyMapper.java

@ -0,0 +1,15 @@
package org.dromara.im.mapper;
import org.dromara.im.domain.ImAutoReply;
import org.dromara.im.domain.vo.ImAutoReplyVo;
import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
/**
* 自动回复Mapper接口
*
* @author Blue
* @date 2026-04-13
*/
public interface ImAutoReplyMapper extends BaseMapperPlus<ImAutoReply, ImAutoReplyVo> {
}

68
im-admin/ruoyi-im/src/main/java/org/dromara/im/service/IImAutoReplyService.java

@ -0,0 +1,68 @@
package org.dromara.im.service;
import org.dromara.im.domain.vo.ImAutoReplyVo;
import org.dromara.im.domain.bo.ImAutoReplyBo;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.mybatis.core.page.PageQuery;
import java.util.Collection;
import java.util.List;
/**
* 自动回复Service接口
*
* @author Blue
* @date 2026-04-13
*/
public interface IImAutoReplyService {
/**
* 查询自动回复
*
* @param id 主键
* @return 自动回复
*/
ImAutoReplyVo queryById(Long id);
/**
* 分页查询自动回复列表
*
* @param bo 查询条件
* @param pageQuery 分页参数
* @return 自动回复分页列表
*/
TableDataInfo<ImAutoReplyVo> queryPageList(ImAutoReplyBo bo, PageQuery pageQuery);
/**
* 查询符合条件的自动回复列表
*
* @param bo 查询条件
* @return 自动回复列表
*/
List<ImAutoReplyVo> queryList(ImAutoReplyBo bo);
/**
* 新增自动回复
*
* @param bo 自动回复
* @return 是否新增成功
*/
Boolean insertByBo(ImAutoReplyBo bo);
/**
* 修改自动回复
*
* @param bo 自动回复
* @return 是否修改成功
*/
Boolean updateByBo(ImAutoReplyBo bo);
/**
* 校验并批量删除自动回复信息
*
* @param ids 待删除的主键集合
* @param isValid 是否进行有效性校验
* @return 是否删除成功
*/
Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid);
}

199
im-admin/ruoyi-im/src/main/java/org/dromara/im/service/impl/ImAutoReplyServiceImpl.java

@ -0,0 +1,199 @@
package org.dromara.im.service.impl;
import cn.hutool.core.date.DateUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.mybatis.core.page.PageQuery;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.RequiredArgsConstructor;
import org.dromara.common.satoken.utils.LoginHelper;
import org.dromara.im.constant.ImConstant;
import org.dromara.im.service.IImAgentService;
import org.dromara.im.util.LambdaQueryWrapperHelper;
import org.springframework.stereotype.Service;
import org.dromara.im.domain.bo.ImAutoReplyBo;
import org.dromara.im.domain.vo.ImAutoReplyVo;
import org.dromara.im.domain.ImAutoReply;
import org.dromara.im.mapper.ImAutoReplyMapper;
import org.dromara.im.service.IImAutoReplyService;
import java.util.List;
import java.util.Collection;
/**
* 自动回复Service业务层处理
*
* @author Blue
* @date 2026-04-13
*/
@RequiredArgsConstructor
@Service
@DS(ImConstant.DS_IM_PLATFORM)
public class ImAutoReplyServiceImpl implements IImAutoReplyService {
private final ImAutoReplyMapper baseMapper;
private final IImAgentService imAgentService;
/**
* 查询自动回复
*
* @param id 主键
* @return 自动回复
*/
@Override
public ImAutoReplyVo queryById(Long id){
LambdaQueryWrapper<ImAutoReply> lqw = Wrappers.lambdaQuery();
lqw.eq(ImAutoReply::getId, id);
if(!LoginHelper.isSuperAdmin()) {
LambdaQueryWrapperHelper.appendToken(lqw, ImAutoReply::getUniqueToken);
}
return baseMapper.selectVoOne(lqw);
}
/**
* 分页查询自动回复列表
*
* @param bo 查询条件
* @param pageQuery 分页参数
* @return 自动回复分页列表
*/
@Override
public TableDataInfo<ImAutoReplyVo> queryPageList(ImAutoReplyBo bo, PageQuery pageQuery) {
LambdaQueryWrapper<ImAutoReply> lqw = buildQueryWrapper(bo);
Page<ImAutoReplyVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result);
}
/**
* 查询符合条件的自动回复列表
*
* @param bo 查询条件
* @return 自动回复列表
*/
@Override
public List<ImAutoReplyVo> queryList(ImAutoReplyBo bo) {
LambdaQueryWrapper<ImAutoReply> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw);
}
private LambdaQueryWrapper<ImAutoReply> buildQueryWrapper(ImAutoReplyBo bo) {
LambdaQueryWrapper<ImAutoReply> lqw = Wrappers.lambdaQuery();
lqw.like(StringUtils.isNotBlank(bo.getReplyName()), ImAutoReply::getReplyName, bo.getReplyName());
lqw.eq(bo.getReplyType() != null, ImAutoReply::getReplyType, bo.getReplyType());
lqw.like(StringUtils.isNotBlank(bo.getReplyTitle()), ImAutoReply::getReplyTitle, bo.getReplyTitle());
lqw.like(StringUtils.isNotBlank(bo.getReplyContent()), ImAutoReply::getReplyContent, bo.getReplyContent());
if(!LoginHelper.isSuperAdmin()) {
LambdaQueryWrapperHelper.appendToken(lqw, ImAutoReply::getUniqueToken);
}
return lqw;
}
/**
* 新增自动回复
*
* @param bo 自动回复
* @return 是否新增成功
*/
@Override
public Boolean insertByBo(ImAutoReplyBo bo) {
ImAutoReply add = MapstructUtils.convert(bo, ImAutoReply.class);
if (add == null) {
return false;
}
add.setCreatorId(LoginHelper.getUserId());
add.setCreatedTime(DateUtil.date());
add.setUpdaterId(LoginHelper.getUserId());
add.setUpdatedTime(DateUtil.date());
// 如果不是超级管理员,则设置 uniqueToken
if(!LoginHelper.isSuperAdmin()) {
add.setUniqueToken(imAgentService.getTokenByUserId());
}
validEntityBeforeSave(add);
boolean flag = baseMapper.insert(add) > 0;
if (flag) {
bo.setId(add.getId());
}
return flag;
}
/**
* 修改自动回复
*
* @param bo 自动回复
* @return 是否修改成功
*/
@Override
public Boolean updateByBo(ImAutoReplyBo bo) {
ImAutoReply update = MapstructUtils.convert(bo, ImAutoReply.class);
if (update == null) {
return false;
}
validEntityBeforeSave(update);
LambdaUpdateWrapper<ImAutoReply> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.eq(ImAutoReply::getId, update.getId());
if(!LoginHelper.isSuperAdmin()) {
// 使用当前用户的 token 而不是从 bo 中获取,防止篡改
updateWrapper.eq(ImAutoReply::getUniqueToken, imAgentService.getTokenByUserId());
}
updateWrapper.set(ImAutoReply::getReplyName, update.getReplyName());
updateWrapper.set(ImAutoReply::getReplyType, update.getReplyType());
updateWrapper.set(ImAutoReply::getReplyTitle, update.getReplyTitle());
updateWrapper.set(ImAutoReply::getReplyContent, update.getReplyContent());
updateWrapper.set(ImAutoReply::getRemark, update.getRemark());
updateWrapper.set(ImAutoReply::getUpdaterId, LoginHelper.getUserId());
updateWrapper.set(ImAutoReply::getUpdatedTime, DateUtil.date());
return baseMapper.update(null, updateWrapper) > 0;
}
/**
* 保存前的数据校验
*/
private void validEntityBeforeSave(ImAutoReply entity){
//TODO 做一些数据校验,如唯一约束
}
/**
* 校验并批量删除自动回复信息
*
* @param ids 待删除的主键集合
* @param isValid 是否进行有效性校验
* @return 是否删除成功
*/
@Override
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
if(isValid){
if (ids == null || ids.isEmpty()) {
return false;
}
}
LambdaUpdateWrapper<ImAutoReply> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.in(ImAutoReply::getId, ids);
if(!LoginHelper.isSuperAdmin()) {
// 添加 uniqueToken 条件,确保只能删除当前用户的记录
updateWrapper.eq(ImAutoReply::getUniqueToken, imAgentService.getTokenByUserId());
}
return baseMapper.delete(updateWrapper) > 0;
}
}

7
im-admin/ruoyi-im/src/main/resources/mapper/im/ImAutoReplyMapper.xml

@ -0,0 +1,7 @@
<?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="org.dromara.im.mapper.ImAutoReplyMapper">
</mapper>
Loading…
Cancel
Save