天天看點

spring+springMVC+mybatis的整合 part9

行為日志的清單的分頁顯示

功能設定:

記錄基本主機資訊作業系統,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

方法和傳回

List

Dao

方法

我們方法參數的前面都加上了注解

@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內建之路