管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2022-10-10 e145880a9ce786108df18bf139e062e3de3c714a
1
已修改13个文件
136 ■■■■■ 文件已修改
data/db.sql 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/aspect/LogAspect.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/config/InitConfig.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/config/ScheduleConfig.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/all/FileController.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/sys/OperateEntity.java 20 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/helper/EnumHelper.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/helper/RestHelper.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/interceptor/AuthInterceptor.java 49 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/all/FileService.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/all/ScheduleService.java 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/logback-spring.xml 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/sys/OperateMapper.xml 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
data/db.sql
@@ -264,11 +264,14 @@
select * from lf.sys_login;
select * from lf.sys_login_2022;
select * from lf.sys_login_2024;
select a.*,b.uname from lf.sys_login a inner join lf.sys_user b on a.userid = b.id;
----------------------------------------------------------------------------------------------------- 6.操作日志表
-- DROP TABLE IF EXISTS lf.sys_operate;
create table lf.sys_operate(
  id serial8,
  modular varchar(60),
  module1 varchar(50),
  module2 varchar(50),
  url varchar(1024),
  ip varchar(30),
  exec bigint,
@@ -295,6 +298,8 @@
comment on table lf.sys_operate is '操作日志表';
comment on column lf.sys_operate.id is '主键ID';
comment on column lf.sys_operate.modular is '操作模块:如 数据管理\目录管理';
comment on column lf.sys_operate.modular1 is '一级模块:如 数据管理';
comment on column lf.sys_operate.modular2 is '二级模块:如 目录管理';
comment on column lf.sys_operate.url is '操作网址';
comment on column lf.sys_operate.ip is 'IP地址';
comment on column lf.sys_operate.exec is '操作时间:单位为毫秒';
@@ -304,6 +309,11 @@
comment on column lf.sys_operate.optime is '操作时间';
comment on column lf.sys_operate.bak is '备注';
alter table lf.sys_operate add column modular1 varchar(50);
alter table lf.sys_operate add column modular2 varchar(50);
select split_part(modular,'\',1),split_part(modular,'\',2) from lf.sys_operate;
update lf.sys_operate set modular1=split_part(modular,'\',1),modular2=split_part(modular,'\',2);
/*insert into lf.sys_operate (modular,url,ip,type) values ('数据管理\目录管理','data/manage/update','192.168.20.106',5);
insert into lf.sys_operate (modular,url,ip,type,optime) values ('数据管理\目录管理','data/manage/delete','192.168.20.107',4,'2024-01-02');*/
src/main/java/com/lf/server/aspect/LogAspect.java
@@ -44,6 +44,8 @@
    private final static String DOWNLOAD = "download";
    private final static String SPLIT = "\\";
    private static final Log log = LogFactory.getLog(LogAspect.class);
    @Pointcut("@annotation(com.lf.server.aspect.SysLog)")
@@ -90,7 +92,9 @@
            // 设置模块
            Api api = clazz.getAnnotation(Api.class);
            if (api != null) {
                oe.setModular(api.tags()[0]);
                String[] strs = api.tags()[0].split(SPLIT);
                oe.setModular1(strs[0]);
                oe.setModular1(strs[1]);
            }
            // 设置类名\方法名、类别
@@ -110,7 +114,7 @@
            operateService.insertOperate(oe);
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
    }
src/main/java/com/lf/server/config/InitConfig.java
@@ -24,9 +24,9 @@
        try {
            pathHelper.init();
            log.info("*****************系统启动完毕*****************");
            log.info("*****************系统启动完毕*****************" + "\n");
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
    }
}
src/main/java/com/lf/server/config/ScheduleConfig.java
@@ -39,7 +39,7 @@
            WebSocketService.broadCastInfo(json);
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
    }
@@ -55,7 +55,7 @@
            WebSocketService.broadCastInfo(json);
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
    }
}
src/main/java/com/lf/server/controller/all/FileController.java
@@ -117,7 +117,7 @@
            outputStream.close();
            fileInputStream.close();
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
    }
}
src/main/java/com/lf/server/entity/sys/OperateEntity.java
@@ -15,6 +15,10 @@
    private String modular;
    private String modular1;
    private String modular2;
    private String url;
    private String ip;
@@ -47,6 +51,22 @@
        this.modular = modular;
    }
    public String getModular1() {
        return modular1;
    }
    public void setModular1(String modular1) {
        this.modular1 = modular1;
    }
    public String getModular2() {
        return modular2;
    }
    public void setModular2(String modular2) {
        this.modular2 = modular2;
    }
    public String getUrl() {
        return url;
    }
src/main/java/com/lf/server/helper/EnumHelper.java
@@ -47,8 +47,8 @@
                    break;
                }
            }
        } catch (Exception e) {
            log.error(e.getMessage());
        } catch (Exception ex) {
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
        return result;
    }
@@ -75,8 +75,8 @@
                    break;
                }
            }
        } catch (Exception e) {
            log.error(e.getMessage());
        } catch (Exception ex) {
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
        return result;
    }
src/main/java/com/lf/server/helper/RestHelper.java
@@ -150,7 +150,7 @@
            return EntityUtils.toString(entity, StaticData.TEXT_ENCODER);
        } catch (Exception ex) {
            log.error(ex);
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
            return getErrorInfo(uri, ex);
        }
@@ -178,7 +178,7 @@
            return EntityUtils.toString(entity, StaticData.TEXT_ENCODER);
        } catch (Exception ex) {
            log.error(ex);
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
            return getErrorInfo(uri, ex);
        }
@@ -196,7 +196,7 @@
            return rest.getForObject(uri, String.class);
        } catch (Exception ex) {
            log.error(ex);
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
            return getErrorInfo(uri, ex);
        }
@@ -216,7 +216,7 @@
            return rest.postForObject(uri, entity, String.class);
        } catch (Exception ex) {
            log.error(ex);
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
            return getErrorInfo(uri, ex);
        }
src/main/java/com/lf/server/interceptor/AuthInterceptor.java
@@ -4,6 +4,9 @@
import com.lf.server.entity.all.HttpStatus;
import com.lf.server.entity.all.ResponseMsg;
import com.lf.server.entity.all.StaticData;
import com.lf.server.entity.sys.UserEntity;
import com.lf.server.helper.StringHelper;
import com.lf.server.helper.WebHelper;
import com.lf.server.service.sys.TokenService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -43,37 +46,37 @@
     */
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
        //noinspection AlibabaRemoveCommentedCode
        try {
            System.out.println(request.getRequestURI().toLowerCase() + "," + (handler instanceof HandlerMethod));
//            // 非方法,无需拦截
//            if (!(handler instanceof HandlerMethod)) {
//                return true;
//            }
//
//            // 无需授权
//            if (noNeedAuth(request)) {
//                return true;
//            }
//
//            String token = WebHelper.getToken(request);
//            if (StringHelper.isNull(token)) {
//                WebHelper.write2Page(response, NO_TOKEN);
//                return false;
//            }
//
//            UsersEntity ue = tokenService.getCurrentUser(request);
//            if (ue == null) {
//                WebHelper.write2Page(response, NO_LOGIN);
//                return false;
//            }
            // 非方法,无需拦截
            if (!(handler instanceof HandlerMethod)) {
                return true;
            }
            // 无需授权
            if (noNeedAuth(request)) {
                return true;
            }
            String token = WebHelper.getToken(request);
            if (StringHelper.isNull(token)) {
                WebHelper.write2Page(response, NO_TOKEN);
                return false;
            }
            UserEntity ue = tokenService.getCurrentUser(request);
            if (ue == null) {
                WebHelper.write2Page(response, NO_LOGIN);
                return false;
            }
            //noinspection AlibabaRemoveCommentedCode
            // 权限校验
            return true;
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
            return false;
        }
    }
src/main/java/com/lf/server/service/all/FileService.java
@@ -66,7 +66,7 @@
                }
            }
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
    }
@@ -85,7 +85,7 @@
            // 以 utf-8的编码格式来解析 value值
            value = item.getString("utf-8");
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
            log.error(ex.getMessage() + ex.getStackTrace() + "\n");
        }
        // 输出到控制台
src/main/java/com/lf/server/service/all/ScheduleService.java
@@ -155,13 +155,13 @@
                // Ping通地址
                socket.connect(add, 2000);
            } catch (Exception e) {
                log.error(e.getStackTrace());
                log.error(e.getMessage() + e.getStackTrace() + "\n");
                list.add(re);
            } finally {
                try {
                    socket.close();
                } catch (Exception e) {
                    log.error(e.getStackTrace());
                } catch (Exception ex) {
                    log.error(ex.getMessage() + ex.getStackTrace() + "\n");
                }
            }
        }
src/main/resources/logback-spring.xml
@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<!-- scan 配置文件如果发生改变,将会被重新加载  scanPeriod 检测间隔时间-->
<configuration scan="true" scanPeriod="60 seconds" debug="false">
    <contextName>jcpimserver</contextName>
    <contextName>LFServer</contextName>
    <!-- 文件名称 -->
    <property name="log.name.info" value="info" />
@@ -94,7 +94,7 @@
    <logger name="com.apache.ibatis" level="DEBUG"></logger>
    <!-- additivity:是否在父(这里为root节点)输出, 默认 true; -->
    <logger name="com.jcpim"  level="INFO"  additivity="true">
    <logger name="com.lf.server"  level="INFO"  additivity="true">
        <appender-ref ref="INFO_FILE"/>
        <appender-ref ref="ERROR_FILE"/>
    </logger>
@@ -102,5 +102,4 @@
    <root level="INFO">
        <appender-ref ref="STDOUT" />
    </root>
</configuration>
src/main/resources/mapper/sys/OperateMapper.xml
@@ -42,10 +42,10 @@
    <insert id="insertOperates"   >
       insert into lf.sys_operate
        (modular,url,ip,exec,clazz,type,userid,optime,bak)
        (modular1,modular2,url,ip,exec,clazz,type,userid,optime,bak)
       values
        <foreach collection="list"   item="item" index="index" separator=","  >
            (#{modular},#{url},#{ip},#{exec},#{clazz},#{type},#{userid},now(),#{bak})
        <foreach collection="list" item="item" index="index" separator=","  >
            (#{modular1},#{modular2},#{url},#{ip},#{exec},#{clazz},#{type},#{userid},now(),#{bak})
        </foreach>
    </insert>
@@ -61,6 +61,6 @@
    </delete>
    <update id="updateOperate">
    update lf.sys_operate set modular=#{modular},url=#{url},ip=#{ip},exec=#{exec},clazz=#{clazz},type=#{type},userid=#{userid},optime=now(),bak=#{bak} where id=#{id}
    update lf.sys_operate set modular1=#{modular1},modular2=#{modular2},url=#{url},ip=#{ip},exec=#{exec},clazz=#{clazz},type=#{type},userid=#{userid},optime=now(),bak=#{bak} where id=#{id}
    </update>
</mapper>