去掉mangodb

pom.xml

@@ -45,11 +45,6 @@
       <version>3.0.0-SNAPSHOT</version>
     </dependency>
 
-    <dependency>
-      <groupId>com.fdkankan</groupId>
-      <artifactId>4dkankan-utils-mongodb</artifactId>
-      <version>3.0.0-SNAPSHOT</version>
-    </dependency>
 
 
     <dependency>
@@ -108,7 +103,11 @@
       <version>1.2.83</version>
     </dependency>
 
-
+    <dependency>
+      <groupId>org.projectlombok</groupId>
+      <artifactId>lombok</artifactId>
+      <version>1.18.20</version>
+    </dependency>
 
     <dependency>
       <groupId>org.springframework.boot</groupId>

src/main/java/com/fdkankan/manage/aop/InnerVisitLogInterceptor.java

@@ -1,21 +1,5 @@
 package com.fdkankan.manage.aop;
 
-import cn.dev33.satoken.stp.StpUtil;
-import cn.hutool.core.util.StrUtil;
-import cn.hutool.extra.servlet.ServletUtil;
-import cn.hutool.http.ContentType;
-import cn.hutool.http.useragent.UserAgent;
-import cn.hutool.http.useragent.UserAgentUtil;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
-import com.fdkankan.common.constant.ServerCode;
-import com.fdkankan.manage.config.SaTokenConfigure;
-import com.fdkankan.manage.entity.OperLog;
-import com.fdkankan.manage.entity.SysUser;
-import com.fdkankan.manage.service.ISysUserService;
-import com.fdkankan.redis.util.RedisUtil;
-import lombok.extern.slf4j.Slf4j;
-import org.aspectj.lang.JoinPoint;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
 import org.aspectj.lang.annotation.Aspect;
@@ -23,18 +7,11 @@ import org.aspectj.lang.annotation.Pointcut;
 import org.aspectj.lang.reflect.MethodSignature;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.stereotype.Component;
-import org.springframework.util.ObjectUtils;
-import org.springframework.util.StringUtils;
 import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.context.request.ServletRequestAttributes;
-import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletRequest;
-import java.util.*;
 
 @Component
 @Aspect

src/main/java/com/fdkankan/manage/aop/VisitLogInterceptor.java

@@ -9,12 +9,13 @@ import cn.hutool.http.useragent.UserAgentUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.common.constant.ServerCode;
+import com.fdkankan.common.util.SecurityUtil;
 import com.fdkankan.manage.config.SaTokenConfigure;
-import com.fdkankan.manage.entity.OperLog;
+import com.fdkankan.manage.entity.SysLog;
 import com.fdkankan.manage.entity.SysUser;
+import com.fdkankan.manage.service.ISysLogService;
 import com.fdkankan.manage.service.ISysUserService;
 import com.fdkankan.redis.util.RedisUtil;
-import lombok.extern.slf4j.Slf4j;
 import org.aspectj.lang.JoinPoint;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
@@ -23,7 +24,6 @@ import org.aspectj.lang.annotation.Pointcut;
 import org.aspectj.lang.reflect.MethodSignature;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
 import org.springframework.util.StringUtils;
@@ -36,14 +36,13 @@ import java.util.*;
 
 @Component
 @Aspect
-@Slf4j
 public class VisitLogInterceptor {
 
 	@Autowired
 	private RedisUtil redisUtil;
-
 	@Autowired
-	private MongoTemplate mongoTemplate;
+	ISysLogService sysLogService;
+
 
 	@Autowired
 	private ISysUserService userService;
@@ -115,7 +114,7 @@ public class VisitLogInterceptor {
 //			return result;
 //		}
 		//写入mongodb
-		OperLog operLog = new OperLog();
+		SysLog operLog = new SysLog();
 		operLog.setUserId(userId);
 		operLog.setUserName(userName);
 		operLog.setNickName(nickName);
@@ -128,7 +127,7 @@ public class VisitLogInterceptor {
 		operLog.setCreateTime(Calendar.getInstance().getTime());
 		operLog.setResult(msg);
 		operLog.setOperationType("manage");
-		mongoTemplate.insert(operLog);
+		sysLogService.save(operLog);
 
 		return result;
 	}

src/main/java/com/fdkankan/manage/controller/OperLogController.java

@@ -1,12 +1,10 @@
 package com.fdkankan.manage.controller;
 
 import com.fdkankan.manage.common.ResultData;
-import com.fdkankan.manage.service.OperLogService;
+import com.fdkankan.manage.service.ISysLogService;
 import com.fdkankan.manage.vo.OperLogPageParamVO;
-import com.fdkankan.mongodb.base.MongoPageResult;
 import com.fdkankan.redis.util.RedisUtil;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -19,14 +17,13 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("/service/manage/operLog")
 public class OperLogController {
 
-    @Autowired
-    MongoTemplate mongoTemplate;
 
     @Autowired
     RedisUtil redisUtil;
 
+
     @Autowired
-    private OperLogService operLogService;
+    private ISysLogService sysLogService;
 
     /**
      * 操作日志列表
@@ -36,9 +33,8 @@ public class OperLogController {
     @PostMapping("/pageOperLog")
     public ResultData pageOperLog(@RequestBody OperLogPageParamVO param){
 
-        MongoPageResult mongoPageResult = operLogService.pageOperLog(param);
 
-        return ResultData.ok(mongoPageResult);
+        return ResultData.ok(sysLogService.pageOperLog(param));
 
     }
 

src/main/java/com/fdkankan/manage/controller/SysLogController.java

@@ -0,0 +1,21 @@
+package com.fdkankan.manage.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author 
+ * @since 2024-11-07
+ */
+@RestController
+@RequestMapping("/manage/sysLog")
+public class SysLogController {
+
+}
+

src/main/java/com/fdkankan/manage/entity/OperLog.java

@@ -1,62 +0,0 @@
-package com.fdkankan.manage.entity;
-
-import com.fdkankan.mongodb.base.BaseMongoEntity;
-import lombok.Data;
-import org.springframework.data.mongodb.core.mapping.Document;
-import org.springframework.data.mongodb.core.mapping.Field;
-
-/**
- * 操作日志
- */
-@Data
-@Document("OperLog")
-public class OperLog extends BaseMongoEntity{
-
-
-    /**
-     * 用户id
-     */
-    @Field("userId")
-    private Long userId;
-
-    /**
-     * 账号
-     */
-    @Field("userName")
-    private String userName;
-
-    /**
-     * 姓名
-     */
-    @Field("nickName")
-    private String nickName;
-
-    /**请求路径*/
-    @Field("requestPath")
-    private String requestPath;
-
-    /**请求url*/
-    @Field("uri")
-    private String uri;
-
-    /**请求方式*/
-    @Field("method")
-    private String method;
-
-    /**请求方式*/
-    @Field("params")
-    private String params;
-
-    /**请求ip*/
-    @Field("ip")
-    private String ip;
-
-    @Field("browser")
-    private String browser;
-
-    @Field("result")
-    private String result;
-
-    @Field("operationType")
-    private String operationType;
-}

src/main/java/com/fdkankan/manage/entity/SysLog.java

@@ -0,0 +1,75 @@
+package com.fdkankan.manage.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 
+ * @since 2024-11-07
+ */
+@Getter
+@Setter
+@TableName("sys_log")
+public class SysLog implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    @TableField("user_id")
+    private Long userId;
+
+    @TableField("user_name")
+    private String userName;
+
+    @TableField("nick_name")
+    private String nickName;
+
+    @TableField("request_path")
+    private String requestPath;
+
+    @TableField("uri")
+    private String uri;
+
+    @TableField("method")
+    private String method;
+
+    @TableField("params")
+    private String params;
+
+    @TableField("ip")
+    private String ip;
+
+    @TableField("browser")
+    private String browser;
+
+    @TableField("result")
+    private String result;
+
+    @TableField("operation_type")
+    private String operationType;
+
+    @TableField("rec_status")
+    @TableLogic(value = "A",delval = "I")
+    private String recStatus;
+
+    @TableField("create_time")
+    private Date createTime;
+
+    @TableField("update_time")
+    private Date updateTime;
+
+
+}

src/main/java/com/fdkankan/manage/generate/AutoGenerate.java

@@ -18,7 +18,7 @@ public class AutoGenerate {
         String path =System.getProperty("user.dir");
 
         generate(path,"manage", getTables(new String[]{
-                "t_currency"
+                "sys_log"
         }));
 
 //        generate(path,"goods", getTables(new String[]{

src/main/java/com/fdkankan/manage/mapper/ISysLogMapper.java

@@ -0,0 +1,18 @@
+package com.fdkankan.manage.mapper;
+
+import com.fdkankan.manage.entity.SysLog;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 
+ * @since 2024-11-07
+ */
+@Mapper
+public interface ISysLogMapper extends BaseMapper<SysLog> {
+
+}

src/main/java/com/fdkankan/manage/service/ISysLogService.java

@@ -0,0 +1,18 @@
+package com.fdkankan.manage.service;
+
+import com.fdkankan.manage.entity.SysLog;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fdkankan.manage.vo.OperLogPageParamVO;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 
+ * @since 2024-11-07
+ */
+public interface ISysLogService extends IService<SysLog> {
+
+    Object pageOperLog(OperLogPageParamVO param);
+}

src/main/java/com/fdkankan/manage/service/OperLogService.java

@@ -1,21 +0,0 @@
-package com.fdkankan.manage.service;
-
-import com.fdkankan.manage.entity.OperLog;
-import com.fdkankan.manage.vo.OperLogPageParamVO;
-import com.fdkankan.mongodb.base.MongoPageResult;
-import com.fdkankan.mongodb.service.MongodbBaseService;
-import java.util.List;
-
-/**
- * <p>
- * TODO
- * </p>
- *
- * @author dengsixing
- * @since 2022/5/30
- **/
-public interface OperLogService extends MongodbBaseService<OperLog> {
-
-    MongoPageResult pageOperLog(OperLogPageParamVO param);
-
-}

src/main/java/com/fdkankan/manage/service/impl/OperLogServiceImpl.java

@@ -1,46 +0,0 @@
-package com.fdkankan.manage.service.impl;
-
-import cn.hutool.core.util.StrUtil;
-import com.fdkankan.manage.entity.OperLog;
-import com.fdkankan.manage.service.OperLogService;
-import com.fdkankan.manage.util.DateUtils;
-import com.fdkankan.manage.vo.OperLogPageParamVO;
-import com.fdkankan.mongodb.base.MongoPageResult;
-import com.fdkankan.mongodb.service.impl.MongodbBaseServiceImpl;
-
-import java.util.Objects;
-import org.springframework.data.mongodb.core.query.Criteria;
-import org.springframework.data.mongodb.core.query.Query;
-import org.springframework.stereotype.Service;
-
-/**
- * <p>
- * TODO
- * </p>
- *
- * @author dengsixing
- * @since 2022/5/30
- **/
-@Service
-public class OperLogServiceImpl extends MongodbBaseServiceImpl<OperLog> implements OperLogService {
-
-    @Override
-    public MongoPageResult pageOperLog(OperLogPageParamVO param) {
-
-        Query query = new Query();
-        if(StrUtil.isNotEmpty(param.getNickName())){
-            query.addCriteria(Criteria.where("nickName").regex(param.getNickName()));
-        }
-        if(StrUtil.isNotEmpty(param.getUserName())){
-            query.addCriteria(Criteria.where("userName").regex(param.getUserName()));
-        }
-        if(Objects.nonNull(param.getStartTime()) || Objects.nonNull(param.getEndTime())){
-            query.addCriteria (Criteria.where("createTime").gte(DateUtils.getDate(param.getStartTime())).lte(DateUtils.getDate(param.getEndTime())));
-        }
-        //默认按操作时间降序排序
-        param.setOrderBy("createTime");
-
-        MongoPageResult<OperLog> operLogMongoPageResult = this.pageQuery(param, query);
-        return operLogMongoPageResult;
-    }
-}

src/main/java/com/fdkankan/manage/service/impl/SysLogServiceImpl.java

@@ -0,0 +1,44 @@
+package com.fdkankan.manage.service.impl;
+
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.fdkankan.manage.common.PageInfo;
+import com.fdkankan.manage.entity.SysLog;
+import com.fdkankan.manage.mapper.ISysLogMapper;
+import com.fdkankan.manage.service.ISysLogService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fdkankan.manage.vo.OperLogPageParamVO;
+import org.springframework.stereotype.Service;
+
+import java.util.Objects;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 
+ * @since 2024-11-07
+ */
+@Service
+public class SysLogServiceImpl extends ServiceImpl<ISysLogMapper, SysLog> implements ISysLogService {
+
+
+    @Override
+    public Object pageOperLog(OperLogPageParamVO param) {
+        LambdaQueryWrapper<SysLog> wrapper = new LambdaQueryWrapper<>();
+        if(StrUtil.isNotEmpty(param.getNickName())){
+            wrapper.like(SysLog::getNickName,param.getNickName());
+        }
+        if(StrUtil.isNotEmpty(param.getUserName())){
+            wrapper.like(SysLog::getUserName,param.getUserName());
+        }
+        if(Objects.nonNull(param.getStartTime()) || Objects.nonNull(param.getEndTime())){
+            wrapper.between(SysLog::getCreateTime,param.getStartTime(),param.getEndTime());
+        }
+        wrapper.orderByDesc(SysLog::getId);
+        Page<SysLog> page = this.page(new Page<>(param.getPageNum(), param.getPageSize()), wrapper);
+        return PageInfo.PageInfo(page);
+    }
+}

src/main/java/com/fdkankan/manage/task/TaskService.java

@@ -35,7 +35,7 @@ public class TaskService {
     @Autowired
     IRtkUseLogService rtkUseLogService;
 
-    @Scheduled(cron = "0 */1 * * * ?")
+    //@Scheduled(cron = "0 */1 * * * ?")
     public void task() {
         try {
             if("aws".equals(CacheUtil.uploadType)){
@@ -48,7 +48,7 @@ public class TaskService {
 
     }
 
-    @Scheduled(cron = "0 0 * * * ?")
+    //@Scheduled(cron = "0 0 * * * ?")
     public void task2() {
         try {
             if("aws".equals(CacheUtil.uploadType)){

src/main/java/com/fdkankan/manage/vo/OperLogPageParamVO.java

@@ -1,7 +1,6 @@
 package com.fdkankan.manage.vo;
 
 import com.fdkankan.manage.util.DateUtils;
-import com.fdkankan.mongodb.base.BaseRequestMongo;
 import lombok.Data;
 
 /**
@@ -13,8 +12,9 @@ import lombok.Data;
  * @since 2022/5/31
  **/
 @Data
-public class OperLogPageParamVO extends BaseRequestMongo {
-
+public class OperLogPageParamVO  {
+    private Integer pageNum = 1;
+    private Integer pageSize= 10;
     private String nickName;
 
     private String userName;

src/main/resources/bootstrap-prod.yml

@@ -23,10 +23,10 @@ spring:
           - data-id: common-fyun-config.yaml
             group: DEFAULT_GROUP
             refresh: true
-
-          - data-id: common-mongodb-config.yaml
-            group: DEFAULT_GROUP
-            refresh: true
+#
+#          - data-id: common-mongodb-config.yaml
+#            group: DEFAULT_GROUP
+#            refresh: true
 
           - data-id: forest-config.yaml
             group: DEFAULT_GROUP

src/main/resources/mapper/manage/SysLogMapper.xml

@@ -0,0 +1,5 @@
+<?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.fdkankan.manage.mapper.ISysLogMapper">
+
+</mapper>