package com.system.log.service.internal;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.shiro.session.mgt.eis.EnterpriseCacheSessionDAO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.domain.Example;
|
import org.springframework.data.domain.ExampleMatcher;
|
import org.springframework.data.domain.Page;
|
import org.springframework.data.domain.PageRequest;
|
import org.springframework.data.jpa.domain.Specification;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.context.request.RequestAttributes;
|
import org.springframework.web.context.request.RequestContextHolder;
|
import org.springframework.web.context.request.ServletRequestAttributes;
|
|
import com.app.aspect.IpUtil;
|
import com.app.base.data.ApiResponseResult;
|
import com.app.base.data.DataGrid;
|
import com.mysql.fabric.xmlrpc.base.Params;
|
import com.system.log.dao.SysLogDao;
|
import com.system.log.entity.SysLog;
|
import com.system.log.service.SysLogService;
|
import com.system.user.entity.SysUser;
|
import com.utils.BaseService;
|
import com.utils.SearchFilter;
|
import com.utils.UserUtil;
|
import com.utils.enumeration.BasicStateEnum;
|
|
|
@Service(value = "sysLogService")
|
@Transactional(propagation = Propagation.REQUIRED)
|
public class SysLogImpl implements SysLogService {
|
|
@Autowired
|
private SysLogDao sysLogDao;
|
|
@Override
|
public ApiResponseResult add(SysLog sysLog) throws Exception {
|
// TODO Auto-generated method stub
|
sysLogDao.save(sysLog);
|
return ApiResponseResult.success("添加成功！");
|
}
|
|
/**
|
* 获取日志列表
|
* @param keyword
|
* @param pageRequest
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
@Transactional
|
public ApiResponseResult getlist(String keyword, PageRequest pageRequest) throws Exception{
|
//查询条件1
|
List<SearchFilter> filters =new ArrayList<>();
|
filters.add(new SearchFilter("isDel", SearchFilter.Operator.EQ, BasicStateEnum.FALSE.intValue()));
|
//查询2
|
List<SearchFilter> filters1 =new ArrayList<>();
|
if(StringUtils.isNotEmpty(keyword)){
|
filters1.add(new SearchFilter("username", SearchFilter.Operator.LIKE, keyword));
|
filters1.add(new SearchFilter("method", SearchFilter.Operator.LIKE, keyword));
|
filters1.add(new SearchFilter("methodName", SearchFilter.Operator.LIKE, keyword));
|
filters1.add(new SearchFilter("operation", SearchFilter.Operator.LIKE, keyword));
|
}
|
Specification<SysLog> spec = Specification.where(BaseService.and(filters, SysLog.class));
|
Specification<SysLog> spec1 = spec.and(BaseService.or(filters1, SysLog.class));
|
Page<SysLog> page = sysLogDao.findAll(spec1, pageRequest);
|
return ApiResponseResult.success().data(DataGrid.create(page.getContent(), (int) page.getTotalElements(), pageRequest.getPageNumber() + 1, pageRequest.getPageSize()));
|
}
|
|
@Override
|
public ApiResponseResult debug(String method,String methodName) {
|
// TODO Auto-generated method stub
|
try{
|
SysLog sysLog = new SysLog();
|
sysLog.setIp(getIp());
|
sysLog.setType("1");
|
sysLog.setMethod(method);
|
sysLog.setMethodName(methodName);
|
sysLog.setCreatedTime(new Date());
|
sysLogDao.save(sysLog);
|
// sysLog.setUsername(UserUtil.getSessionUser().getUserCode());
|
sysLog.setUsername(UserUtil.getSessionUser().getFcode());
|
return ApiResponseResult.success();
|
}catch(Exception e){
|
SysLog s = new SysLog();
|
s.setType("2");
|
s.setRemark("发送保存日记错误!"+e.toString());
|
sysLogDao.save(s);
|
return ApiResponseResult.failure();
|
}
|
|
}
|
|
//获取IP地址
|
private String getIp(){
|
RequestAttributes ra = RequestContextHolder.getRequestAttributes();
|
ServletRequestAttributes sra = (ServletRequestAttributes) ra;
|
HttpServletRequest request = sra.getRequest();
|
return IpUtil.getIpAddr(request);
|
}
|
|
@Override
|
public ApiResponseResult success(String method, String methodName, Object param) {
|
// TODO Auto-generated method stub
|
try{
|
SysLog sysLog = new SysLog();
|
sysLog.setIp(getIp());
|
sysLog.setType("2");
|
sysLog.setMethod(method);
|
sysLog.setMethodName(methodName);
|
sysLog.setCreatedTime(new Date());
|
sysLog.setOperation("操作成功");
|
// sysLog.setUsername(UserUtil.getSessionUser().getUserCode());
|
sysLog.setUsername(UserUtil.getSessionUser().getFcode());
|
sysLogDao.save(sysLog);
|
return ApiResponseResult.success();
|
}catch(Exception e){
|
SysLog s = new SysLog();
|
s.setType("2");
|
s.setRemark("发送保存日记错误!"+e.toString());
|
|
sysLogDao.save(s);
|
return ApiResponseResult.failure();
|
}
|
}
|
|
@Override
|
public ApiResponseResult error(String method, String methodName, Object param) {
|
// TODO Auto-generated method stub
|
try{
|
SysLog sysLog = new SysLog();
|
sysLog.setIp(getIp());
|
sysLog.setType("3");
|
sysLog.setMethod(method);
|
sysLog.setMethodName(methodName);
|
sysLog.setCreatedTime(new Date());
|
sysLog.setOperation("操作失败");
|
sysLog.setParams(param.toString());
|
// sysLog.setUsername(UserUtil.getSessionUser().getUserCode());
|
sysLog.setUsername(UserUtil.getSessionUser().getFcode());
|
sysLogDao.save(sysLog);
|
return ApiResponseResult.success();
|
}catch(Exception e){
|
SysLog s = new SysLog();
|
s.setType("2");
|
s.setRemark("发送保存日记错误!"+e.toString());
|
|
sysLogDao.save(s);
|
return ApiResponseResult.failure();
|
}
|
}
|
|
@Override
|
public ApiResponseResult login(String method, String methodName, String param) {
|
// TODO Auto-generated method stub
|
try{
|
SysLog sysLog = new SysLog();
|
sysLog.setIp(getIp());
|
sysLog.setType("1");
|
sysLog.setMethod(method);
|
sysLog.setMethodName(methodName);
|
sysLog.setCreatedTime(new Date());
|
sysLog.setParams(param.toString());
|
sysLogDao.save(sysLog);
|
return ApiResponseResult.success();
|
}catch(Exception e){
|
SysLog s = new SysLog();
|
s.setType("2");
|
s.setRemark("发送保存日记错误!"+e.toString());
|
sysLogDao.save(s);
|
return ApiResponseResult.failure();
|
}
|
}
|
}
|
