33 changed files with 888 additions and 30 deletions
@ -0,0 +1,17 @@
|
||||
package cn.iocoder.yudao.module.system.annotation; |
||||
|
||||
import java.lang.annotation.ElementType; |
||||
import java.lang.annotation.Retention; |
||||
import java.lang.annotation.RetentionPolicy; |
||||
import java.lang.annotation.Target; |
||||
|
||||
@Retention(RetentionPolicy.RUNTIME) |
||||
@Target(ElementType.FIELD) |
||||
public @interface PrimaryKey { |
||||
|
||||
|
||||
/** |
||||
* 主键类型，默认是 Long |
||||
*/ |
||||
Class<?> type() default Long.class; |
||||
} |
||||
@ -0,0 +1,129 @@
|
||||
package cn.iocoder.yudao.module.system.aspect; |
||||
|
||||
import cn.iocoder.yudao.framework.security.core.LoginUser; |
||||
import cn.iocoder.yudao.module.system.dal.dataobject.fieldchangelog.FieldChangeLogDO; |
||||
import cn.iocoder.yudao.module.system.dal.mysql.fieldchangelog.FieldChangeLogMapper; |
||||
import cn.iocoder.yudao.module.system.service.common.CommonService; |
||||
import cn.iocoder.yudao.module.system.service.fieldchangelog.FieldChangeLogService; |
||||
import cn.iocoder.yudao.module.system.service.user.AdminUserService; |
||||
import cn.iocoder.yudao.module.system.util.EntityUtils; |
||||
import org.aspectj.lang.ProceedingJoinPoint; |
||||
import org.aspectj.lang.annotation.Around; |
||||
import org.aspectj.lang.annotation.Aspect; |
||||
import org.aspectj.lang.annotation.Pointcut; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
import javax.annotation.Resource; |
||||
import java.lang.reflect.Field; |
||||
import java.time.LocalDateTime; |
||||
import java.util.Date; |
||||
import java.util.Map; |
||||
import java.util.Objects; |
||||
|
||||
import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUser; |
||||
|
||||
@Aspect |
||||
@Component |
||||
public class FieldChangeLogAspect { |
||||
|
||||
@Resource |
||||
private FieldChangeLogService fieldChangeLogService; |
||||
@Resource |
||||
private FieldChangeLogMapper fieldChangeLogMapper; |
||||
|
||||
@Resource |
||||
private CommonService commonService; |
||||
@Resource |
||||
private AdminUserService userService; |
||||
|
||||
// 拦截 update 方法
|
||||
@Pointcut("execution(* cn.iocoder.*.service.*.update*(..))") |
||||
public void updatePointCut() {} |
||||
|
||||
@Around("updatePointCut()") |
||||
public Object logFieldChanges(ProceedingJoinPoint point) throws Throwable { |
||||
Object[] args = point.getArgs(); |
||||
if (args.length == 0 || args[0] == null) { |
||||
return point.proceed(); // 跳过无效参数
|
||||
} |
||||
Object updatedEntity = args[0]; |
||||
|
||||
// 判断是否包含 @PrimaryKey 注解
|
||||
if (!EntityUtils.hasPrimaryKeyAnnotation(updatedEntity)) { |
||||
return point.proceed(); // 如果没有主键注解，跳过日志记录
|
||||
} |
||||
|
||||
// 使用工具类获取主键值和表名
|
||||
Long recordId = EntityUtils.getPrimaryKeyValue(updatedEntity); |
||||
String tableName = EntityUtils.getTableName(updatedEntity); |
||||
|
||||
// 动态查询原始记录
|
||||
Map<String, Object> originalRecord = commonService.findById(tableName, recordId); |
||||
|
||||
// 记录字段变更日志
|
||||
saveFieldChangeLogs(originalRecord, updatedEntity, tableName, recordId); |
||||
|
||||
return point.proceed(); // 执行原方法
|
||||
} |
||||
|
||||
|
||||
private void saveFieldChangeLogs(Map<String, Object> original, Object updatedEntity, String tableName, Long recordId) { |
||||
|
||||
final LoginUser loginUser = getLoginUser(); |
||||
|
||||
|
||||
|
||||
for (Field field : updatedEntity.getClass().getDeclaredFields()) { |
||||
field.setAccessible(true); |
||||
|
||||
try { |
||||
String fieldName = field.getName(); |
||||
|
||||
String dbFieldName = toUnderlineCase(fieldName); // 将驼峰命名转换为下划线命名
|
||||
|
||||
|
||||
Object oldValue = original.get(dbFieldName); // 获取原始值
|
||||
Object newValue = field.get(updatedEntity); // 获取新值
|
||||
|
||||
// 如果原值和新值相等，则跳过
|
||||
if ((newValue == null) || (oldValue != null && oldValue.equals(newValue))) { |
||||
continue; |
||||
} |
||||
|
||||
if (!Objects.equals(oldValue, newValue)) { |
||||
FieldChangeLogDO log = new FieldChangeLogDO(); |
||||
log.setTableName(tableName); |
||||
log.setRecordId(recordId); |
||||
log.setFieldName(fieldName); |
||||
log.setOldValue(oldValue != null ? oldValue.toString() : null); |
||||
log.setNewValue(newValue != null ? newValue.toString() : null); |
||||
log.setUserId(loginUser.getId()); |
||||
|
||||
final String realName = userService.getUser(loginUser.getId()).getRealName(); |
||||
log.setUsername(realName); |
||||
log.setOperationType("修改"); |
||||
fieldChangeLogMapper.insert(log); |
||||
} |
||||
} catch (IllegalAccessException e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 将驼峰命名转换为下划线命名 |
||||
* |
||||
* @param camelCase 驼峰格式字符串（如 contactName） |
||||
* @return 下划线格式字符串（如 contact_name） |
||||
*/ |
||||
public static String toUnderlineCase(String camelCase) { |
||||
if (camelCase == null || camelCase.isEmpty()) { |
||||
return ""; |
||||
} |
||||
// 使用正则表达式匹配驼峰命名的规则
|
||||
return camelCase.replaceAll("([a-z])([A-Z])", "$1_$2").toLowerCase(); |
||||
} |
||||
|
||||
} |
||||
|
||||
@ -0,0 +1,71 @@
|
||||
//package cn.iocoder.yudao.module.system.aspect;
|
||||
//
|
||||
//
|
||||
//import cn.iocoder.yudao.module.system.service.common.CommonService;
|
||||
//import cn.iocoder.yudao.module.system.util.EntityUtils;
|
||||
//import org.aspectj.lang.ProceedingJoinPoint;
|
||||
//import org.aspectj.lang.annotation.Around;
|
||||
//import org.aspectj.lang.annotation.Aspect;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.stereotype.Component;
|
||||
//
|
||||
//import java.util.Date;
|
||||
//import java.util.Map;
|
||||
//@Aspect
|
||||
//@Component
|
||||
//public class LogDeleteOperation {
|
||||
//
|
||||
// @Autowired
|
||||
// private CommonService commonService;
|
||||
//
|
||||
// @Autowired
|
||||
// private SysFieldChangeLogService fieldChangeLogService;
|
||||
//
|
||||
// @Around("execution(* com.ruoyi.*.service.*.delete*(..))")
|
||||
// public Object logDeleteOperation(ProceedingJoinPoint point) throws Throwable {
|
||||
// Object[] args = point.getArgs();
|
||||
// if (args.length == 0) {
|
||||
// return point.proceed();
|
||||
// }
|
||||
//
|
||||
// Object entityToDelete = args[0];
|
||||
//
|
||||
// // 判断是否包含 @PrimaryKey 注解
|
||||
// if (!EntityUtils.hasPrimaryKeyAnnotation(entityToDelete)) {
|
||||
// return point.proceed(); // 如果没有主键注解，跳过日志记录
|
||||
// }
|
||||
//
|
||||
//
|
||||
// // 使用工具类获取主键值和表名
|
||||
// Long recordId = EntityUtils.getPrimaryKeyValue(entityToDelete);
|
||||
// String tableName = EntityUtils.getTableName(entityToDelete );
|
||||
//
|
||||
// // 动态查询记录
|
||||
// Map<String, Object> originalRecord = commonService.findById(tableName, recordId);
|
||||
//
|
||||
// // 保存删除日志
|
||||
// saveDeleteLogs(originalRecord, tableName, recordId);
|
||||
//
|
||||
// return point.proceed();
|
||||
// }
|
||||
//
|
||||
// private void saveDeleteLogs(Map<String, Object> original, String tableName, Long recordId) {
|
||||
// Long userId = SecurityUtils.getLoginUser().getUserId();
|
||||
// String username = SecurityUtils.getLoginUser().getUsername();
|
||||
//
|
||||
// for (Map.Entry<String, Object> entry : original.entrySet()) {
|
||||
// SysFieldChangeLog log = new SysFieldChangeLog();
|
||||
// log.setTableName(tableName);
|
||||
// log.setRecordId(recordId);
|
||||
// log.setFieldName(entry.getKey());
|
||||
// log.setOldValue(entry.getValue() != null ? entry.getValue().toString() : null);
|
||||
// log.setNewValue(null); // 删除操作，新值为空
|
||||
// log.setUserId(userId);
|
||||
// log.setUsername(username);
|
||||
// log.setOperationType("删除");
|
||||
// log.setCreateTime(new Date());
|
||||
// fieldChangeLogService.save(log);
|
||||
// }
|
||||
// }
|
||||
//
|
||||
//}
|
||||
@ -0,0 +1,94 @@
|
||||
package cn.iocoder.yudao.module.system.controller.admin.fieldchangelog; |
||||
|
||||
import org.springframework.web.bind.annotation.*; |
||||
import org.springframework.validation.annotation.Validated; |
||||
import org.springframework.security.access.prepost.PreAuthorize; |
||||
import io.swagger.v3.oas.annotations.tags.Tag; |
||||
import io.swagger.v3.oas.annotations.Parameter; |
||||
import io.swagger.v3.oas.annotations.Operation; |
||||
import java.util.*; |
||||
import java.io.IOException; |
||||
|
||||
import cn.iocoder.yudao.framework.common.pojo.PageParam; |
||||
import cn.iocoder.yudao.framework.common.pojo.PageResult; |
||||
import cn.iocoder.yudao.framework.common.pojo.CommonResult; |
||||
import cn.iocoder.yudao.framework.common.util.object.BeanUtils; |
||||
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success; |
||||
|
||||
import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils; |
||||
|
||||
import cn.iocoder.yudao.framework.apilog.core.annotation.ApiAccessLog; |
||||
import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.*; |
||||
|
||||
import cn.iocoder.yudao.module.system.controller.admin.fieldchangelog.vo.*; |
||||
import cn.iocoder.yudao.module.system.dal.dataobject.fieldchangelog.FieldChangeLogDO; |
||||
import cn.iocoder.yudao.module.system.service.fieldchangelog.FieldChangeLogService; |
||||
|
||||
import javax.annotation.Resource; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import javax.validation.Valid; |
||||
|
||||
@Tag(name = "管理后台 - 字段变更日志") |
||||
@RestController |
||||
@RequestMapping("/system/field-change-log") |
||||
@Validated |
||||
public class FieldChangeLogController { |
||||
|
||||
@Resource |
||||
private FieldChangeLogService fieldChangeLogService; |
||||
|
||||
@PostMapping("/create") |
||||
@Operation(summary = "创建字段变更日志") |
||||
@PreAuthorize("@ss.hasPermission('system:field-change-log:create')") |
||||
public CommonResult<Long> createFieldChangeLog(@Valid @RequestBody FieldChangeLogSaveReqVO createReqVO) { |
||||
return success(fieldChangeLogService.createFieldChangeLog(createReqVO)); |
||||
} |
||||
|
||||
@PutMapping("/update") |
||||
@Operation(summary = "更新字段变更日志") |
||||
@PreAuthorize("@ss.hasPermission('system:field-change-log:update')") |
||||
public CommonResult<Boolean> updateFieldChangeLog(@Valid @RequestBody FieldChangeLogSaveReqVO updateReqVO) { |
||||
fieldChangeLogService.updateFieldChangeLog(updateReqVO); |
||||
return success(true); |
||||
} |
||||
|
||||
@DeleteMapping("/delete") |
||||
@Operation(summary = "删除字段变更日志") |
||||
@Parameter(name = "id", description = "编号", required = true) |
||||
@PreAuthorize("@ss.hasPermission('system:field-change-log:delete')") |
||||
public CommonResult<Boolean> deleteFieldChangeLog(@RequestParam("id") Long id) { |
||||
fieldChangeLogService.deleteFieldChangeLog(id); |
||||
return success(true); |
||||
} |
||||
|
||||
@GetMapping("/get") |
||||
@Operation(summary = "获得字段变更日志") |
||||
@Parameter(name = "id", description = "编号", required = true, example = "1024") |
||||
@PreAuthorize("@ss.hasPermission('system:field-change-log:query')") |
||||
public CommonResult<FieldChangeLogRespVO> getFieldChangeLog(@RequestParam("id") Long id) { |
||||
FieldChangeLogDO fieldChangeLog = fieldChangeLogService.getFieldChangeLog(id); |
||||
return success(BeanUtils.toBean(fieldChangeLog, FieldChangeLogRespVO.class)); |
||||
} |
||||
|
||||
@GetMapping("/page") |
||||
@Operation(summary = "获得字段变更日志分页") |
||||
@PreAuthorize("@ss.hasPermission('system:field-change-log:query')") |
||||
public CommonResult<PageResult<FieldChangeLogRespVO>> getFieldChangeLogPage(@Valid FieldChangeLogPageReqVO pageReqVO) { |
||||
PageResult<FieldChangeLogDO> pageResult = fieldChangeLogService.getFieldChangeLogPage(pageReqVO); |
||||
return success(BeanUtils.toBean(pageResult, FieldChangeLogRespVO.class)); |
||||
} |
||||
|
||||
@GetMapping("/export-excel") |
||||
@Operation(summary = "导出字段变更日志 Excel") |
||||
@PreAuthorize("@ss.hasPermission('system:field-change-log:export')") |
||||
@ApiAccessLog(operateType = EXPORT) |
||||
public void exportFieldChangeLogExcel(@Valid FieldChangeLogPageReqVO pageReqVO, |
||||
HttpServletResponse response) throws IOException { |
||||
pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE); |
||||
List<FieldChangeLogDO> list = fieldChangeLogService.getFieldChangeLogPage(pageReqVO).getList(); |
||||
// 导出 Excel
|
||||
ExcelUtils.write(response, "字段变更日志.xls", "数据", FieldChangeLogRespVO.class, |
||||
BeanUtils.toBean(list, FieldChangeLogRespVO.class)); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,46 @@
|
||||
package cn.iocoder.yudao.module.system.controller.admin.fieldchangelog.vo; |
||||
|
||||
import lombok.*; |
||||
import java.util.*; |
||||
import io.swagger.v3.oas.annotations.media.Schema; |
||||
import cn.iocoder.yudao.framework.common.pojo.PageParam; |
||||
import org.springframework.format.annotation.DateTimeFormat; |
||||
import java.time.LocalDateTime; |
||||
|
||||
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND; |
||||
|
||||
@Schema(description = "管理后台 - 字段变更日志分页 Request VO") |
||||
@Data |
||||
@EqualsAndHashCode(callSuper = true) |
||||
@ToString(callSuper = true) |
||||
public class FieldChangeLogPageReqVO extends PageParam { |
||||
|
||||
@Schema(description = "表名", example = "王五") |
||||
private String tableName; |
||||
|
||||
@Schema(description = "记录的主键值", example = "13548") |
||||
private Long recordId; |
||||
|
||||
@Schema(description = "字段名", example = "赵六") |
||||
private String fieldName; |
||||
|
||||
@Schema(description = "修改前值或删除前的值") |
||||
private String oldValue; |
||||
|
||||
@Schema(description = "修改后值（删除时为空）") |
||||
private String newValue; |
||||
|
||||
@Schema(description = "操作用户ID", example = "17114") |
||||
private Long userId; |
||||
|
||||
@Schema(description = "操作用户名", example = "芋艿") |
||||
private String username; |
||||
|
||||
@Schema(description = "操作时间") |
||||
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) |
||||
private LocalDateTime[] createTime; |
||||
|
||||
@Schema(description = "操作类型", example = "1") |
||||
private String operationType; |
||||
|
||||
} |
||||
@ -0,0 +1,55 @@
|
||||
package cn.iocoder.yudao.module.system.controller.admin.fieldchangelog.vo; |
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema; |
||||
import lombok.*; |
||||
import java.util.*; |
||||
import org.springframework.format.annotation.DateTimeFormat; |
||||
import java.time.LocalDateTime; |
||||
import com.alibaba.excel.annotation.*; |
||||
|
||||
@Schema(description = "管理后台 - 字段变更日志 Response VO") |
||||
@Data |
||||
@ExcelIgnoreUnannotated |
||||
public class FieldChangeLogRespVO { |
||||
|
||||
@Schema(description = "日志ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "12408") |
||||
@ExcelProperty("日志ID") |
||||
private Long id; |
||||
|
||||
@Schema(description = "表名", requiredMode = Schema.RequiredMode.REQUIRED, example = "王五") |
||||
@ExcelProperty("表名") |
||||
private String tableName; |
||||
|
||||
@Schema(description = "记录的主键值", requiredMode = Schema.RequiredMode.REQUIRED, example = "13548") |
||||
@ExcelProperty("记录的主键值") |
||||
private Long recordId; |
||||
|
||||
@Schema(description = "字段名", example = "赵六") |
||||
@ExcelProperty("字段名") |
||||
private String fieldName; |
||||
|
||||
@Schema(description = "修改前值或删除前的值") |
||||
@ExcelProperty("修改前值或删除前的值") |
||||
private String oldValue; |
||||
|
||||
@Schema(description = "修改后值（删除时为空）") |
||||
@ExcelProperty("修改后值（删除时为空）") |
||||
private String newValue; |
||||
|
||||
@Schema(description = "操作用户ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "17114") |
||||
@ExcelProperty("操作用户ID") |
||||
private Long userId; |
||||
|
||||
@Schema(description = "操作用户名", requiredMode = Schema.RequiredMode.REQUIRED, example = "芋艿") |
||||
@ExcelProperty("操作用户名") |
||||
private String username; |
||||
|
||||
@Schema(description = "操作时间", requiredMode = Schema.RequiredMode.REQUIRED) |
||||
@ExcelProperty("操作时间") |
||||
private LocalDateTime createTime; |
||||
|
||||
@Schema(description = "操作类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1") |
||||
@ExcelProperty("操作类型") |
||||
private String operationType; |
||||
|
||||
} |
||||
@ -0,0 +1,46 @@
|
||||
package cn.iocoder.yudao.module.system.controller.admin.fieldchangelog.vo; |
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema; |
||||
import lombok.*; |
||||
|
||||
import javax.validation.constraints.NotEmpty; |
||||
import javax.validation.constraints.NotNull; |
||||
import java.util.*; |
||||
|
||||
@Schema(description = "管理后台 - 字段变更日志新增/修改 Request VO") |
||||
@Data |
||||
public class FieldChangeLogSaveReqVO { |
||||
|
||||
@Schema(description = "日志ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "12408") |
||||
private Long id; |
||||
|
||||
@Schema(description = "表名", requiredMode = Schema.RequiredMode.REQUIRED, example = "王五") |
||||
@NotEmpty(message = "表名不能为空") |
||||
private String tableName; |
||||
|
||||
@Schema(description = "记录的主键值", requiredMode = Schema.RequiredMode.REQUIRED, example = "13548") |
||||
@NotNull(message = "记录的主键值不能为空") |
||||
private Long recordId; |
||||
|
||||
@Schema(description = "字段名", example = "赵六") |
||||
private String fieldName; |
||||
|
||||
@Schema(description = "修改前值或删除前的值") |
||||
private String oldValue; |
||||
|
||||
@Schema(description = "修改后值（删除时为空）") |
||||
private String newValue; |
||||
|
||||
@Schema(description = "操作用户ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "17114") |
||||
@NotNull(message = "操作用户ID不能为空") |
||||
private Long userId; |
||||
|
||||
@Schema(description = "操作用户名", requiredMode = Schema.RequiredMode.REQUIRED, example = "芋艿") |
||||
@NotEmpty(message = "操作用户名不能为空") |
||||
private String username; |
||||
|
||||
@Schema(description = "操作类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1") |
||||
@NotEmpty(message = "操作类型不能为空") |
||||
private String operationType; |
||||
|
||||
} |
||||
@ -0,0 +1,62 @@
|
||||
package cn.iocoder.yudao.module.system.dal.dataobject.fieldchangelog; |
||||
|
||||
import lombok.*; |
||||
import java.util.*; |
||||
import java.time.LocalDateTime; |
||||
import com.baomidou.mybatisplus.annotation.*; |
||||
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO; |
||||
|
||||
/** |
||||
* 字段变更日志 DO |
||||
* |
||||
* @author 芋道源码 |
||||
*/ |
||||
@TableName("sys_field_change_log") |
||||
@KeySequence("sys_field_change_log_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
|
||||
@Data |
||||
@EqualsAndHashCode(callSuper = true) |
||||
@ToString(callSuper = true) |
||||
@Builder |
||||
@NoArgsConstructor |
||||
@AllArgsConstructor |
||||
public class FieldChangeLogDO extends BaseDO { |
||||
|
||||
/** |
||||
* 日志ID |
||||
*/ |
||||
@TableId |
||||
private Long id; |
||||
/** |
||||
* 表名 |
||||
*/ |
||||
private String tableName; |
||||
/** |
||||
* 记录的主键值 |
||||
*/ |
||||
private Long recordId; |
||||
/** |
||||
* 字段名 |
||||
*/ |
||||
private String fieldName; |
||||
/** |
||||
* 修改前值或删除前的值 |
||||
*/ |
||||
private String oldValue; |
||||
/** |
||||
* 修改后值（删除时为空） |
||||
*/ |
||||
private String newValue; |
||||
/** |
||||
* 操作用户ID |
||||
*/ |
||||
private Long userId; |
||||
/** |
||||
* 操作用户名 |
||||
*/ |
||||
private String username; |
||||
/** |
||||
* 操作类型 |
||||
*/ |
||||
private String operationType; |
||||
|
||||
} |
||||
@ -0,0 +1,14 @@
|
||||
package cn.iocoder.yudao.module.system.dal.mysql.common; |
||||
|
||||
import org.apache.ibatis.annotations.Mapper; |
||||
import org.apache.ibatis.annotations.Param; |
||||
import org.apache.ibatis.annotations.Select; |
||||
|
||||
import java.util.Map; |
||||
|
||||
@Mapper |
||||
public interface CommonMapper { |
||||
|
||||
@Select("SELECT * FROM `${tableName}` WHERE id = #{id}") |
||||
Map<String, Object> selectById(@Param("tableName") String tableName, @Param("id") Long id); |
||||
} |
||||
@ -0,0 +1,34 @@
|
||||
package cn.iocoder.yudao.module.system.dal.mysql.fieldchangelog; |
||||
|
||||
import java.util.*; |
||||
|
||||
import cn.iocoder.yudao.framework.common.pojo.PageResult; |
||||
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX; |
||||
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX; |
||||
import cn.iocoder.yudao.module.system.dal.dataobject.fieldchangelog.FieldChangeLogDO; |
||||
import org.apache.ibatis.annotations.Mapper; |
||||
import cn.iocoder.yudao.module.system.controller.admin.fieldchangelog.vo.*; |
||||
|
||||
/** |
||||
* 字段变更日志 Mapper |
||||
* |
||||
* @author 芋道源码 |
||||
*/ |
||||
@Mapper |
||||
public interface FieldChangeLogMapper extends BaseMapperX<FieldChangeLogDO> { |
||||
|
||||
default PageResult<FieldChangeLogDO> selectPage(FieldChangeLogPageReqVO reqVO) { |
||||
return selectPage(reqVO, new LambdaQueryWrapperX<FieldChangeLogDO>() |
||||
.likeIfPresent(FieldChangeLogDO::getTableName, reqVO.getTableName()) |
||||
.eqIfPresent(FieldChangeLogDO::getRecordId, reqVO.getRecordId()) |
||||
.likeIfPresent(FieldChangeLogDO::getFieldName, reqVO.getFieldName()) |
||||
.eqIfPresent(FieldChangeLogDO::getOldValue, reqVO.getOldValue()) |
||||
.eqIfPresent(FieldChangeLogDO::getNewValue, reqVO.getNewValue()) |
||||
.eqIfPresent(FieldChangeLogDO::getUserId, reqVO.getUserId()) |
||||
.likeIfPresent(FieldChangeLogDO::getUsername, reqVO.getUsername()) |
||||
.betweenIfPresent(FieldChangeLogDO::getCreateTime, reqVO.getCreateTime()) |
||||
.eqIfPresent(FieldChangeLogDO::getOperationType, reqVO.getOperationType()) |
||||
.orderByDesc(FieldChangeLogDO::getId)); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,7 @@
|
||||
package cn.iocoder.yudao.module.system.service.common; |
||||
|
||||
import java.util.Map; |
||||
|
||||
public interface CommonService { |
||||
Map<String, Object> findById(String tableName, Long id); |
||||
} |
||||
@ -0,0 +1,20 @@
|
||||
package cn.iocoder.yudao.module.system.service.common; |
||||
|
||||
import cn.iocoder.yudao.module.system.dal.mysql.common.CommonMapper; |
||||
import org.apache.ibatis.annotations.Mapper; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import javax.annotation.Resource; |
||||
import java.util.Map; |
||||
|
||||
@Service |
||||
public class CommonServiceImpl implements CommonService{ |
||||
|
||||
@Resource |
||||
private CommonMapper commonMapper; |
||||
|
||||
@Override |
||||
public Map<String, Object> findById(String tableName, Long id) { |
||||
return commonMapper.selectById(tableName, id); |
||||
} |
||||
} |
||||
@ -0,0 +1,56 @@
|
||||
package cn.iocoder.yudao.module.system.service.fieldchangelog; |
||||
|
||||
import java.util.*; |
||||
import cn.iocoder.yudao.module.system.controller.admin.fieldchangelog.vo.*; |
||||
import cn.iocoder.yudao.module.system.dal.dataobject.fieldchangelog.FieldChangeLogDO; |
||||
import cn.iocoder.yudao.framework.common.pojo.PageResult; |
||||
import cn.iocoder.yudao.framework.common.pojo.PageParam; |
||||
|
||||
import javax.validation.Valid; |
||||
|
||||
/** |
||||
* 字段变更日志 Service 接口 |
||||
* |
||||
* @author 芋道源码 |
||||
*/ |
||||
public interface FieldChangeLogService { |
||||
|
||||
/** |
||||
* 创建字段变更日志 |
||||
* |
||||
* @param createReqVO 创建信息 |
||||
* @return 编号 |
||||
*/ |
||||
Long createFieldChangeLog(@Valid FieldChangeLogSaveReqVO createReqVO); |
||||
|
||||
/** |
||||
* 更新字段变更日志 |
||||
* |
||||
* @param updateReqVO 更新信息 |
||||
*/ |
||||
void updateFieldChangeLog(@Valid FieldChangeLogSaveReqVO updateReqVO); |
||||
|
||||
/** |
||||
* 删除字段变更日志 |
||||
* |
||||
* @param id 编号 |
||||
*/ |
||||
void deleteFieldChangeLog(Long id); |
||||
|
||||
/** |
||||
* 获得字段变更日志 |
||||
* |
||||
* @param id 编号 |
||||
* @return 字段变更日志 |
||||
*/ |
||||
FieldChangeLogDO getFieldChangeLog(Long id); |
||||
|
||||
/** |
||||
* 获得字段变更日志分页 |
||||
* |
||||
* @param pageReqVO 分页查询 |
||||
* @return 字段变更日志分页 |
||||
*/ |
||||
PageResult<FieldChangeLogDO> getFieldChangeLogPage(FieldChangeLogPageReqVO pageReqVO); |
||||
|
||||
} |
||||
@ -0,0 +1,75 @@
|
||||
package cn.iocoder.yudao.module.system.service.fieldchangelog; |
||||
|
||||
import org.springframework.stereotype.Service; |
||||
import org.springframework.validation.annotation.Validated; |
||||
import org.springframework.transaction.annotation.Transactional; |
||||
|
||||
import java.util.*; |
||||
import cn.iocoder.yudao.module.system.controller.admin.fieldchangelog.vo.*; |
||||
import cn.iocoder.yudao.module.system.dal.dataobject.fieldchangelog.FieldChangeLogDO; |
||||
import cn.iocoder.yudao.framework.common.pojo.PageResult; |
||||
import cn.iocoder.yudao.framework.common.pojo.PageParam; |
||||
import cn.iocoder.yudao.framework.common.util.object.BeanUtils; |
||||
|
||||
import cn.iocoder.yudao.module.system.dal.mysql.fieldchangelog.FieldChangeLogMapper; |
||||
|
||||
import javax.annotation.Resource; |
||||
|
||||
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; |
||||
import static cn.iocoder.yudao.module.system.enums.ErrorCodeConstants.*; |
||||
|
||||
/** |
||||
* 字段变更日志 Service 实现类 |
||||
* |
||||
* @author 芋道源码 |
||||
*/ |
||||
@Service |
||||
@Validated |
||||
public class FieldChangeLogServiceImpl implements FieldChangeLogService { |
||||
|
||||
@Resource |
||||
private FieldChangeLogMapper fieldChangeLogMapper; |
||||
|
||||
@Override |
||||
public Long createFieldChangeLog(FieldChangeLogSaveReqVO createReqVO) { |
||||
// 插入
|
||||
FieldChangeLogDO fieldChangeLog = BeanUtils.toBean(createReqVO, FieldChangeLogDO.class); |
||||
fieldChangeLogMapper.insert(fieldChangeLog); |
||||
// 返回
|
||||
return fieldChangeLog.getId(); |
||||
} |
||||
|
||||
@Override |
||||
public void updateFieldChangeLog(FieldChangeLogSaveReqVO updateReqVO) { |
||||
// 校验存在
|
||||
validateFieldChangeLogExists(updateReqVO.getId()); |
||||
// 更新
|
||||
FieldChangeLogDO updateObj = BeanUtils.toBean(updateReqVO, FieldChangeLogDO.class); |
||||
fieldChangeLogMapper.updateById(updateObj); |
||||
} |
||||
|
||||
@Override |
||||
public void deleteFieldChangeLog(Long id) { |
||||
// 校验存在
|
||||
validateFieldChangeLogExists(id); |
||||
// 删除
|
||||
fieldChangeLogMapper.deleteById(id); |
||||
} |
||||
|
||||
private void validateFieldChangeLogExists(Long id) { |
||||
if (fieldChangeLogMapper.selectById(id) == null) { |
||||
throw exception(FIELD_CHANGE_LOG_NOT_EXISTS); |
||||
} |
||||
} |
||||
|
||||
@Override |
||||
public FieldChangeLogDO getFieldChangeLog(Long id) { |
||||
return fieldChangeLogMapper.selectById(id); |
||||
} |
||||
|
||||
@Override |
||||
public PageResult<FieldChangeLogDO> getFieldChangeLogPage(FieldChangeLogPageReqVO pageReqVO) { |
||||
return fieldChangeLogMapper.selectPage(pageReqVO); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,57 @@
|
||||
package cn.iocoder.yudao.module.system.util; |
||||
|
||||
import cn.iocoder.yudao.module.system.annotation.PrimaryKey; |
||||
import com.baomidou.mybatisplus.annotation.TableName; |
||||
|
||||
import java.lang.reflect.Field; |
||||
|
||||
public class EntityUtils { |
||||
|
||||
/** |
||||
* 获取实体类的主键值 |
||||
* |
||||
* @param entity 实体对象 |
||||
* @return 主键值 |
||||
*/ |
||||
public static Long getPrimaryKeyValue(Object entity) { |
||||
for (Field field : entity.getClass().getDeclaredFields()) { |
||||
if (field.isAnnotationPresent(PrimaryKey.class)) { |
||||
field.setAccessible(true); |
||||
try { |
||||
return (Long) field.get(entity); // 假设主键类型为 Long
|
||||
} catch (IllegalAccessException e) { |
||||
throw new RuntimeException("无法访问主键字段的值", e); |
||||
} |
||||
} |
||||
} |
||||
throw new RuntimeException("实体类中未找到 @PrimaryKey 标记的字段"); |
||||
} |
||||
|
||||
/** |
||||
* 获取实体类对应的表名 |
||||
* |
||||
* @param entity 实体对象 |
||||
* @return 表名 |
||||
*/ |
||||
public static String getTableName(Object entity) { |
||||
TableName tableNameAnnotation = entity.getClass().getAnnotation(TableName.class); |
||||
return tableNameAnnotation != null ? tableNameAnnotation.value() : entity.getClass().getSimpleName(); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* 判断实体类是否包含 @PrimaryKey 注解的字段 |
||||
* |
||||
* @param entity 实体对象 |
||||
* @return 是否包含主键注解 |
||||
*/ |
||||
public static boolean hasPrimaryKeyAnnotation(Object entity) { |
||||
for (Field field : entity.getClass().getDeclaredFields()) { |
||||
if (field.isAnnotationPresent(PrimaryKey.class)) { |
||||
return true; // 找到带有 @PrimaryKey 的字段
|
||||
} |
||||
} |
||||
return false; // 未找到
|
||||
} |
||||
} |
||||
|
||||
Loading…
Reference in new issue