NewUserLogThread.java

package util;

import common.context.AppUtils;
import common.model.User;
import common.model.UserLog;
import common.repository.UserLogRepository;
import common.repository.UserRepository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.servlet.http.HttpServletRequest;
import java.util.Date;

/**
 * Created by zxy on 2017/12/15.
 */
public class NewUserLogThread
        extends Thread
{
    protected Logger logger = LoggerFactory.getLogger(NewUserLogThread.class);

    private UserLogRepository userLogRepository = AppUtils.getApplicationContext().getBean(UserLogRepository.class);

    private UserRepository userRepository = AppUtils.getApplicationContext().getBean(UserRepository.class);
    //操作用户
    private String operaAccount;
    //操作用户名
    private String accountName;
    //操作对象的类型：OperateObjectTypeEnum
    private String operateObjectType;
    //客户管理和系统账号管理是操作对象的账号，以后再加别的模块再定
    private String operateObject;
    //操作类型：“创建账号”“编辑账号”“录入缴费信息”“录入回访信息”“处理过期提醒”等等，如果都定下来有哪些，可以做一个字典
    private String operateType;
    //操作前的对象数据
    private String oldObject;
    //操作后的对象数据
    private String newObject;
    //为了获取ip及解析地点
    private HttpServletRequest request;

    /**
     * 传入内容为对象
     * UserLogThread userlog = new UserLogThread("zxy@reyun.com", "zxy", OperateObjectTypeEnum.CUSTOMER.getKey(), "app", "查看app", request);
     * userlog.start();
     */
    public NewUserLogThread(String operaAccount, String accountName, String operateObjectType, String operateObject, String operateType, String oldObject, String newObject, HttpServletRequest request) {
        this.operaAccount = operaAccount;
        this.accountName = accountName;
        this.operateObjectType = operateObjectType;
        this.operateObject = operateObject;
        this.operateType = operateType;
        this.oldObject = oldObject;
        this.newObject = newObject;
        this.request = request;
    }


    @Override
    public void run()
    {
        try
        {
            UserLog audit = new UserLog();
            audit.setOperaAccount(this.operaAccount);
            audit.setAccountName(this.accountName);
            audit.setOperateObjectType(this.operateObjectType);
            audit.setOperateObject(this.operateObject);
            audit.setOperateTime(DateUtil.format(new Date(), DateUtil.C_TIME_PATTON_DEFAULT));
            audit.setOperateType(this.operateType);
            audit.setOldObject(this.oldObject);
            audit.setNewObject(this.newObject);
            User user = userRepository.findByEmail(this.operaAccount);
            audit.setRole(user.getRole());

            if (this.request != null) {
                String ipAddr = IPAddrUtil.getIpAddrNew(request);
                audit.setIp(ipAddr);
                if(ValidateUtil.isValid(ipAddr)){
                    String locationFromIpAddr = IPAddrUtil.getLocationFromIpAddr(ipAddr);
                    audit.setLocation(locationFromIpAddr);
                }
            }


            userLogRepository.save(audit);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}