美文网首页spring+springmvc+mybatis(SSM)
spring+springMVC+mybatis的整合 part

spring+springMVC+mybatis的整合 part

作者: 意识流丶 | 来源:发表于2017-07-22 19:17 被阅读48次

    行为日志的列表的分页显示

    功能设定:
    记录基本主机信息操作系统,IP地址,访问的浏览器内核,Session的Id还有操作时间

    首先要设定要数据库字段,唯一的注意的地方是这边把记录行为日志的表做了个自增的ID。
    由于是记录用户登录信息的列表,那么需要先获取用户的请求内部相关的信息。也就是说我们的这个信息获取是基于用户请求设定的,那么解决思路就是从拦截器来实现。

    具体思路
    根据数据需求建表
    完成存储数据业务Dao → Service → HandlerInterceptor(拦截器)

    获取大概流程图如下所示:


    日志列表输出大概流程图如下所示:


    把数据库表user_action_log建立起来,建表代码如下:

     CREATE TABLE `user_action_log` (
     `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '自增ID',
     `login_id` varchar(20) DEFAULT NULL COMMENT '登录ID',
     `session_id` varchar(45) NOT NULL COMMENT '访问session的ID\r\n',
     `time` timestamp  COMMENT '操作时间',
     `ip_addr_v4` varchar(15) DEFAULT NULL COMMENT 'ipV4地址',
     `os_name` varchar(20) DEFAULT NULL COMMENT '操作系统名称',
     `os_version` varchar(20) DEFAULT NULL COMMENT '操作系统版本',
     `bro_name` varchar(20) DEFAULT NULL COMMENT '浏览器内核名称',
     `bro_version` varchar(20) DEFAULT NULL COMMENT '浏览器内核版本',
     `request_body` varchar(60) DEFAULT NULL COMMENT '请求体信息',
     `description` varchar(100) DEFAULT NULL COMMENT '操作描述',
     `other` varchar(150) DEFAULT NULL COMMENT '其他描述',
     `method` varchar(10) DEFAULT NULL COMMENT 'HTTP请求方法',
     PRIMARY KEY (`id`)
     ) ENGINE=InnoDB AUTO_INCREMENT=109 DEFAULT CHARSET=utf8 COMMENT='行为日志表';
    

    注:由于很难去获取用户所使用的浏览器具体名称,所以没写,获取内核的信息还是可以的
    时间的类型我是选择使用timestamp,而没有使用datetime
    具体的区别:
    http://blog.csdn.net/zgliang88/article/details/50250833

    数据库建表完成后,按照前面的思路,那就是对应着写Bean → Dao → Service然后Service提供给其他地方调用。
    行为日志的实体类UserActionLog

    public class UserActionLog implements Serializable {
        private long id;
        private String loginId, sessionId, ipAddrV4, osName, osVersion, broName, broVersion, requestBody, description, other, method;
        private Long time;
        //省略get和set以及toString方法
    }
    

    time我设置为时间戳类型,所以用Long

    对应的ActionLogDao

    public interface ActionLogDao extends Dao<UserActionLog>{
        int add(UserActionLog userActionLog);
    
        /**
         * 分页查询
         * @param offset    起始位置
         * @param limit     每页数量
         * @return
         */
        List<UserActionLog> findAll(@Param("offset") int offset, @Param("limit") int limit);
    
        int getAllCount();
    }
    

    多参数的Dao方法和返回ListDao方法
    我们方法参数的前面都加上了注解@Param(),同时在注解中填写了对应的名字
    不加会报错
    在上面的Mybatis的xml中的内容看来,是需要拿到上面参数对应的注解名字。
    我在xml文件中resultType返回数据类型设定为UserActionLog
    通过这样简单的设定就可以实现列表查找了。
    ActionLogDao.xml

    <?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="pjb.ssm.dao.ActionLogDao">
        <!--增加语句-->
        <insert id="add" parameterType="pjb.ssm.domain.UserActionLog">
            INSERT INTO
            `user_action_log`
            (`login_id`,`session_id`,`time`,`ip_addr_v4`,`os_name`,`os_version`,`bro_name`,`bro_version`,`request_body`,`description`,`other`,`method`)
            VALUES
            (#{loginId},#{sessionId},FROM_UNIXTIME(#{time}),#{ipAddrV4},#{osName},#{osVersion},#{broName},#{broVersion},#{requestBody},#{description},#{other},#{method})
        </insert>
    
        <!--分页列表:offset起始位置 limit每一页数据,DESC倒序排列-->
        <select id="findAll" resultType="pjb.ssm.domain.UserActionLog" >
            SELECT
            *
            FROM
            `user_action_log`
            ORDER BY
            `id`
            DESC
            LIMIT #{offset}, #{limit}
        </select>
        <select id="getAllCount" resultType="int" >
            SELECT
            COUNT(*)
            FROM
            `user_action_log`;
        </select>
    </mapper>
    

    行为日志业务接口层ActionLogService

    public interface ActionLogService extends BaseService<UserActionLog>{
        void add(HttpServletRequest request);
    
        List<UserActionLog> findAll(int pageNum, int pageSize);
    
        /**
         * 获取总条数
         * @return  获取总条数
         */
        int getAllCount();
    }
    

    行为日志业务实现层ActionLogServiceImpl

    @Service("actionLogService")
    public class ActionLogServiceImpl implements ActionLogService{
        @Autowired
        private ActionLogDao actionLogDao;
    
        private UserActionLog userActionLog;
        public void add(UserActionLog userActionLog) throws Exception {
        }
    
        public void add(HttpServletRequest request) {
            //获取请求参数集合
            Map<String, String[]> params = request.getParameterMap();
            String queryString = "";
            for (String key : params.keySet()) {
                String[] values = params.get(key);
                for (int i = 0; i < values.length; i++) {
                    String value = values[i];
                    queryString += key + "=" + value + "&";
                }
            }
    
    
            userActionLog = new UserActionLog();
            userActionLog.setMethod(request.getMethod());   //获取请求方式
            if (request.getHeader("x-forwarded-for") == null) { //获取请求IP
                userActionLog.setIpAddrV4(request.getRemoteAddr());
            } else {
                userActionLog.setIpAddrV4(request.getHeader("x-forwarded-for"));
            }
            userActionLog.setTime(new Date().getTime()/1000);//获取系统当前的时间戳,10位
            userActionLog.setOther(request.getHeader("User-Agent"));    //获取user-agent
            userActionLog.setSessionId(request.getSession().getId());   //获取用户操作的sessionID,必须
            userActionLog.setDescription(request.getRequestURI());  //获取访问的地址
            if (!StringUtils.isEmpty(queryString)) userActionLog.setRequestBody(queryString);   //参数集合内容不为空存入数据库
    
            try {
                UserAgent agent = new UserAgent(request.getHeader("User-Agent"));   //载入user-agent
                userActionLog.setOsVersion(System.getProperty("os.version"));//设定os版本
                userActionLog.setOsName(System.getProperty("os.name"));//设定os名称
                userActionLog.setBroName(StringUtils.isEmpty(agent.getBrowser().getName()) ? "" : agent.getBrowser().getName()); //设定浏览器内核名称
                userActionLog.setBroVersion(StringUtils.isEmpty(agent.getBrowserVersion().getVersion()) ? "" : agent.getBrowserVersion().getVersion());    //设定浏览器内核版本
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                actionLogDao.add(userActionLog);
            }
        }
    
        public List<UserActionLog> findAll(int pageNum, int pageSize) {
            //因为数据库内容是从第一条出的数据,所以我们查询的 起始位置 = 页码 * 条数 + 1;
            pageNum -= 1;
            return actionLogDao.findAll(pageNum * pageSize + 1, pageSize);
        }
    
        public int getAllCount() {
            return actionLogDao.getAllCount();
        }
    }
    

    其实时间在建表的时候已经是根据当前时间去更新了,我是想展示下如何去存时间戳
    现在ActionLogServiceImpl也完成了。

    行为日志的调用接口:ActionLogController
    其中ResponseList是返回集合json数据的实体

    @Controller
    @RequestMapping("/actionLog")
    public class ActionLogController {
        @Autowired
        ActionLogService actionLogService;
        /**
         * @param pageNum  页码
         * @param pageSize 每一页的条数
         * @return
         */
        @GetMapping("/findLogList")
        @ResponseBody
        public Object findLog(@Param("pageNum") int pageNum, @Param("pageSize") int pageSize) {
            if (pageNum <= 0) { //错误页码默认跳转到第一页
                pageNum = 1;
            }
            if (pageSize <= 0) {    //错误数据长度默认设置为10条
                pageSize = 10;
            }
            int toalNum; //总页码
            ResponseList<UserActionLog> responseObj = new ResponseList<UserActionLog>();
            try {
                toalNum = actionLogService.getAllCount();   //先把总条数赋值给总页数,作为缓存变量,减少下面算法的查找次数
                toalNum = toalNum % pageSize > 0 ? toalNum / pageSize + 1 : toalNum / pageSize;     //在每页固定条数下能不能分页完成,有余则加一页码
                List<UserActionLog> result = actionLogService.findAll(pageNum, pageSize);
                responseObj.setPageNum(pageNum);
                responseObj.setTotalNum(toalNum);
                responseObj.setPageSize(pageSize);
                if (result == null || result.size() == 0) {
                    responseObj.setCode(ResponseObj.EMPUTY);
                    responseObj.setMsg("查询结果为空");
                    return new GsonUtils().toJson(responseObj);
                }
                responseObj.setCode(ResponseObj.OK);
                responseObj.setMsg("查询成功");
                responseObj.setData(result);
                return new GsonUtils().toJson(responseObj);
            }catch (Exception e){
                e.printStackTrace();
                //查询失败
                responseObj.setCode(ResponseObj.FAILED);
                responseObj.setMsg("查询失败");
                return new GsonUtils().toJson(responseObj);
            }
        }
    }
    

    上面设置完成后,运行项目,先输入错误的网址,由于设置了拦截器,会看到它先跳转到登录界面(因为现在的用户信息位空,所以默认需要用户登录)

    下个part将把数据显示在新的页面中

    主要参考于大牛Clone丶记忆的SSM集成之路

    相关文章

      网友评论

        本文标题:spring+springMVC+mybatis的整合 part

        本文链接:https://www.haomeiwen.com/subject/igoyhxtx.html