Compare commits
No commits in common. "356aff0f5bf51165ee13086a79873cd068cdca9b" and "0867a87352251954b39c982588dbfe57556f725a" have entirely different histories.
356aff0f5b
...
0867a87352
|
|
@ -93,35 +93,16 @@
|
||||||
<artifactId>core</artifactId>
|
<artifactId>core</artifactId>
|
||||||
<version>3.5.3</version>
|
<version>3.5.3</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<!-- <dependency>
|
||||||
<groupId>cn.hutool</groupId>
|
<groupId>cn.hutool</groupId>
|
||||||
<artifactId>hutool-all</artifactId>
|
<artifactId>hutool-all</artifactId>
|
||||||
<version>5.8.35</version>
|
<version>5.8.35</version>
|
||||||
</dependency>
|
</dependency> -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.github.binarywang</groupId>
|
<groupId>com.github.binarywang</groupId>
|
||||||
<artifactId>weixin-java-pay</artifactId>
|
<artifactId>weixin-java-pay</artifactId>
|
||||||
<version>4.7.0</version>
|
<version>4.7.0</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<!-- IP地址解析库 -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>net.dreamlu</groupId>
|
|
||||||
<artifactId>mica-ip2region</artifactId>
|
|
||||||
<version>2.7.18.9</version>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.aspectj</groupId>
|
|
||||||
<artifactId>aspectjrt</artifactId>
|
|
||||||
<version>1.9.7</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.aspectj</groupId>
|
|
||||||
<artifactId>aspectjweaver</artifactId>
|
|
||||||
<version>1.9.7</version>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
<build>
|
<build>
|
||||||
|
|
|
||||||
|
|
@ -1,9 +1,7 @@
|
||||||
package com.njzscloud.supervisory;
|
package com.njzscloud.supervisory;
|
||||||
|
|
||||||
import com.njzscloud.supervisory.sys.log.utils.SpringBeanHolder;
|
|
||||||
import org.springframework.boot.SpringApplication;
|
import org.springframework.boot.SpringApplication;
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||||
import org.springframework.context.annotation.Bean;
|
|
||||||
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
||||||
|
|
||||||
@EnableScheduling
|
@EnableScheduling
|
||||||
|
|
@ -12,9 +10,4 @@ public class Main {
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
SpringApplication.run(Main.class, args);
|
SpringApplication.run(Main.class, args);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Bean
|
|
||||||
public SpringBeanHolder springContextHolder() {
|
|
||||||
return new SpringBeanHolder();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -46,21 +46,22 @@ public class MoneyAccountService extends ServiceImpl<MoneyAccountMapper, MoneyAc
|
||||||
if (moneyAccountEntity.getRechargeMoney() == null || moneyAccountEntity.getRechargeMoney().signum() <= 0) {
|
if (moneyAccountEntity.getRechargeMoney() == null || moneyAccountEntity.getRechargeMoney().signum() <= 0) {
|
||||||
throw Exceptions.clierr("充值金额需大于0");
|
throw Exceptions.clierr("充值金额需大于0");
|
||||||
}
|
}
|
||||||
MoneyAccountResult result = baseMapper.selectMoneyAccountDetailById(moneyAccountEntity.getId());
|
|
||||||
if (null == result) {
|
|
||||||
throw Exceptions.clierr("未找到该账户");
|
|
||||||
}
|
|
||||||
// 记录资金变动明细
|
// 记录资金变动明细
|
||||||
MoneyChangeDetailEntity changeDetail = new MoneyChangeDetailEntity()
|
MoneyChangeDetailEntity changeDetail = new MoneyChangeDetailEntity()
|
||||||
.setMoneyAccountId(moneyAccountEntity.getId())
|
.setMoneyAccountId(moneyAccountEntity.getId())
|
||||||
.setOldMoney(result.getMoney())
|
.setOldMoney(moneyAccountEntity.getMoney())
|
||||||
.setDelta(moneyAccountEntity.getRechargeMoney()) // 充值
|
.setDelta(moneyAccountEntity.getRechargeMoney()) // 充值
|
||||||
.setMoneyChangeCategory(MoneyChangeCategory.ChongZhi)
|
.setMoneyChangeCategory(MoneyChangeCategory.ChongZhi)
|
||||||
.setMemo("账户充值");
|
.setMemo("账户充值");
|
||||||
|
|
||||||
moneyAccountEntity.setMoney(result.getMoney().add(moneyAccountEntity.getRechargeMoney()));
|
moneyAccountEntity.setMoney(moneyAccountEntity.getMoney().add(moneyAccountEntity.getRechargeMoney()));
|
||||||
|
|
||||||
changeDetail.setNewMoney(moneyAccountEntity.getMoney());
|
changeDetail.setNewMoney(moneyAccountEntity.getMoney());
|
||||||
|
|
||||||
|
MoneyAccountResult result = baseMapper.selectMoneyAccountDetailById(moneyAccountEntity.getId());
|
||||||
|
if (null == result) {
|
||||||
|
throw Exceptions.clierr("未找到该账户");
|
||||||
|
}
|
||||||
changeDetail.setUserId(result.getUserId());
|
changeDetail.setUserId(result.getUserId());
|
||||||
changeDetail.setCompanyId(result.getStationId());
|
changeDetail.setCompanyId(result.getStationId());
|
||||||
this.updateById(moneyAccountEntity);
|
this.updateById(moneyAccountEntity);
|
||||||
|
|
|
||||||
|
|
@ -1,16 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.annotation;
|
|
||||||
|
|
||||||
import java.lang.annotation.ElementType;
|
|
||||||
import java.lang.annotation.Retention;
|
|
||||||
import java.lang.annotation.RetentionPolicy;
|
|
||||||
import java.lang.annotation.Target;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
*/
|
|
||||||
@Target(ElementType.METHOD)
|
|
||||||
@Retention(RetentionPolicy.RUNTIME)
|
|
||||||
public @interface Log {
|
|
||||||
String value() default "";
|
|
||||||
}
|
|
||||||
|
|
@ -1,86 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.aspect;
|
|
||||||
|
|
||||||
import com.njzscloud.common.security.support.UserDetail;
|
|
||||||
import com.njzscloud.common.security.util.SecurityUtil;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.SysLog;
|
|
||||||
import com.njzscloud.supervisory.sys.log.service.SysLogService;
|
|
||||||
import com.njzscloud.supervisory.sys.log.utils.StringUtils;
|
|
||||||
import com.njzscloud.supervisory.sys.log.utils.ThrowableUtil;
|
|
||||||
import com.njzscloud.supervisory.wxPay.utils.RequestHolder;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.aspectj.lang.JoinPoint;
|
|
||||||
import org.aspectj.lang.ProceedingJoinPoint;
|
|
||||||
import org.aspectj.lang.annotation.AfterThrowing;
|
|
||||||
import org.aspectj.lang.annotation.Around;
|
|
||||||
import org.aspectj.lang.annotation.Aspect;
|
|
||||||
import org.aspectj.lang.annotation.Pointcut;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletRequest;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
*/
|
|
||||||
@Component
|
|
||||||
@Aspect
|
|
||||||
@Slf4j
|
|
||||||
public class LogAspect {
|
|
||||||
|
|
||||||
private final SysLogService sysLogService;
|
|
||||||
|
|
||||||
ThreadLocal<Long> currentTime = new ThreadLocal<>();
|
|
||||||
|
|
||||||
public LogAspect(SysLogService sysLogService) {
|
|
||||||
this.sysLogService = sysLogService;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 配置切入点
|
|
||||||
*/
|
|
||||||
@Pointcut("@annotation(com.njzscloud.supervisory.sys.log.annotation.Log)")
|
|
||||||
public void logPointcut() {
|
|
||||||
// 该方法无方法体,主要为了让同类中其他方法使用此切入点
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 配置环绕通知,使用在方法logPointcut()上注册的切入点
|
|
||||||
*
|
|
||||||
* @param joinPoint join point for advice
|
|
||||||
*/
|
|
||||||
@Around("logPointcut()")
|
|
||||||
public Object logAround(ProceedingJoinPoint joinPoint) throws Throwable {
|
|
||||||
Object result;
|
|
||||||
currentTime.set(System.currentTimeMillis());
|
|
||||||
result = joinPoint.proceed();
|
|
||||||
SysLog sysLog = new SysLog("INFO",System.currentTimeMillis() - currentTime.get());
|
|
||||||
currentTime.remove();
|
|
||||||
HttpServletRequest request = RequestHolder.getHttpServletRequest();
|
|
||||||
sysLogService.save(getUsername(), StringUtils.getBrowser(request), StringUtils.getIp(request),joinPoint, sysLog);
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 配置异常通知
|
|
||||||
*
|
|
||||||
* @param joinPoint join point for advice
|
|
||||||
* @param e exception
|
|
||||||
*/
|
|
||||||
@AfterThrowing(pointcut = "logPointcut()", throwing = "e")
|
|
||||||
public void logAfterThrowing(JoinPoint joinPoint, Throwable e) {
|
|
||||||
SysLog sysLog = new SysLog("ERROR",System.currentTimeMillis() - currentTime.get());
|
|
||||||
currentTime.remove();
|
|
||||||
sysLog.setExceptionDetail(new String(ThrowableUtil.getStackTrace(e).getBytes()));
|
|
||||||
HttpServletRequest request = RequestHolder.getHttpServletRequest();
|
|
||||||
sysLogService.save(getUsername(), StringUtils.getBrowser(request), StringUtils.getIp(request), (ProceedingJoinPoint)joinPoint, sysLog);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取用户名
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
public String getUsername() {
|
|
||||||
UserDetail userDetail = SecurityUtil.loginUser();
|
|
||||||
return userDetail.getNickname();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,82 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.controller;
|
|
||||||
|
|
||||||
import com.njzscloud.common.core.utils.R;
|
|
||||||
import com.njzscloud.common.mp.support.PageParam;
|
|
||||||
import com.njzscloud.common.mp.support.PageResult;
|
|
||||||
import com.njzscloud.common.security.support.UserDetail;
|
|
||||||
import com.njzscloud.common.security.util.SecurityUtil;
|
|
||||||
import com.njzscloud.supervisory.sys.log.annotation.Log;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.SysLog;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.dto.SysLogQueryCriteria;
|
|
||||||
import com.njzscloud.supervisory.sys.log.service.SysLogService;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.springframework.web.bind.annotation.*;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import java.io.IOException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
*/
|
|
||||||
@RestController
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
@RequestMapping("/log")
|
|
||||||
public class SysLogController {
|
|
||||||
|
|
||||||
private final SysLogService sysLogService;
|
|
||||||
|
|
||||||
@Log("导出数据")
|
|
||||||
@GetMapping(value = "/export")
|
|
||||||
public void exportLog(HttpServletResponse response, SysLogQueryCriteria criteria) throws IOException {
|
|
||||||
criteria.setLogType("INFO");
|
|
||||||
sysLogService.download(sysLogService.queryAll(criteria), response);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Log("导出错误数据")
|
|
||||||
@GetMapping(value = "/error/export")
|
|
||||||
public void exportErrorLog(HttpServletResponse response, SysLogQueryCriteria criteria) throws IOException {
|
|
||||||
criteria.setLogType("ERROR");
|
|
||||||
sysLogService.download(sysLogService.queryAll(criteria), response);
|
|
||||||
}
|
|
||||||
|
|
||||||
@GetMapping
|
|
||||||
public R<PageResult<SysLog>> queryLog(SysLogQueryCriteria criteria, PageParam pageParam) {
|
|
||||||
criteria.setLogType("INFO");
|
|
||||||
return R.success(sysLogService.queryAll(criteria, pageParam));
|
|
||||||
}
|
|
||||||
|
|
||||||
@GetMapping(value = "/user")
|
|
||||||
public R<PageResult<SysLog>> queryUserLog(SysLogQueryCriteria criteria, PageParam pageParam) {
|
|
||||||
criteria.setLogType("INFO");
|
|
||||||
UserDetail userDetail = SecurityUtil.loginUser();
|
|
||||||
criteria.setUsername(userDetail.getNickname());
|
|
||||||
return R.success(sysLogService.queryAllByUser(criteria, pageParam));
|
|
||||||
}
|
|
||||||
|
|
||||||
@GetMapping(value = "/error")
|
|
||||||
public R<PageResult<SysLog>> queryErrorLog(SysLogQueryCriteria criteria, PageParam pageParam) {
|
|
||||||
criteria.setLogType("ERROR");
|
|
||||||
return R.success(sysLogService.queryAll(criteria, pageParam));
|
|
||||||
}
|
|
||||||
|
|
||||||
@GetMapping(value = "/error/{id}")
|
|
||||||
public R<Object> queryErrorLogDetail(@PathVariable Long id) {
|
|
||||||
return R.success(sysLogService.findByErrDetail(id));
|
|
||||||
}
|
|
||||||
|
|
||||||
@DeleteMapping(value = "/del/error")
|
|
||||||
@Log("删除所有ERROR日志")
|
|
||||||
public R<?> delAllErrorLog() {
|
|
||||||
sysLogService.delAllByError();
|
|
||||||
return R.success();
|
|
||||||
}
|
|
||||||
|
|
||||||
@DeleteMapping(value = "/del/info")
|
|
||||||
@Log("删除所有INFO日志")
|
|
||||||
public R<?> delAllInfoLog() {
|
|
||||||
sysLogService.delAllByInfo();
|
|
||||||
return R.success();
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,88 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.domain;
|
|
||||||
|
|
||||||
import com.alibaba.fastjson2.annotation.JSONField;
|
|
||||||
import com.baomidou.mybatisplus.annotation.*;
|
|
||||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.NoArgsConstructor;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
*/
|
|
||||||
@Getter
|
|
||||||
@Setter
|
|
||||||
@NoArgsConstructor
|
|
||||||
@TableName("sys_log")
|
|
||||||
public class SysLog implements Serializable {
|
|
||||||
|
|
||||||
@TableId(value = "log_id", type = IdType.AUTO)
|
|
||||||
private Long id;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 操作用户
|
|
||||||
*/
|
|
||||||
private String username;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 描述
|
|
||||||
*/
|
|
||||||
private String description;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 方法名
|
|
||||||
*/
|
|
||||||
private String method;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 参数
|
|
||||||
*/
|
|
||||||
private String params;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 日志类型
|
|
||||||
*/
|
|
||||||
private String logType;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 请求ip
|
|
||||||
*/
|
|
||||||
private String requestIp;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 地址
|
|
||||||
*/
|
|
||||||
private String address;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 浏览器
|
|
||||||
*/
|
|
||||||
private String browser;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 请求耗时
|
|
||||||
*/
|
|
||||||
private Long time;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 异常详细
|
|
||||||
*/
|
|
||||||
@JSONField(serialize = false)
|
|
||||||
private String exceptionDetail;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 创建日期：yyyy-MM-dd HH:mm:ss
|
|
||||||
*/
|
|
||||||
@TableField(fill = FieldFill.INSERT)
|
|
||||||
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
|
|
||||||
private LocalDateTime createTime;
|
|
||||||
|
|
||||||
public SysLog(String logType, Long time) {
|
|
||||||
this.logType = logType;
|
|
||||||
this.time = time;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,36 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.domain.dto;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
import java.sql.Timestamp;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 日志查询类
|
|
||||||
* @author Ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
public class SysLogQueryCriteria {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 模糊查询
|
|
||||||
*/
|
|
||||||
private String blurry;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 用户名称
|
|
||||||
*/
|
|
||||||
private String username;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 日志类型
|
|
||||||
*/
|
|
||||||
private String logType;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 创建时间
|
|
||||||
*/
|
|
||||||
private List<Timestamp> createTime;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,28 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.mapper;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.SysLog;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.dto.SysLogQueryCriteria;
|
|
||||||
import org.apache.ibatis.annotations.Mapper;
|
|
||||||
import org.apache.ibatis.annotations.Param;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author Ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
**/
|
|
||||||
@Mapper
|
|
||||||
public interface SysLogMapper extends BaseMapper<SysLog> {
|
|
||||||
|
|
||||||
List<SysLog> queryAll(@Param("criteria") SysLogQueryCriteria criteria);
|
|
||||||
|
|
||||||
IPage<SysLog> queryAll(@Param("criteria") SysLogQueryCriteria criteria, IPage<SysLog> page);
|
|
||||||
|
|
||||||
IPage<SysLog> queryAllByUser(@Param("criteria") SysLogQueryCriteria criteria, IPage<SysLog> page);
|
|
||||||
|
|
||||||
String getExceptionDetails(@Param("id") Long id);
|
|
||||||
|
|
||||||
void deleteByLevel(@Param("logType") String logType);
|
|
||||||
}
|
|
||||||
|
|
@ -1,83 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.service;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.extension.service.IService;
|
|
||||||
import com.njzscloud.common.mp.support.PageParam;
|
|
||||||
import com.njzscloud.common.mp.support.PageResult;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.SysLog;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.dto.SysLogQueryCriteria;
|
|
||||||
import org.aspectj.lang.ProceedingJoinPoint;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
*/
|
|
||||||
public interface SysLogService extends IService<SysLog> {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 分页查询
|
|
||||||
*
|
|
||||||
* @param criteria 查询条件
|
|
||||||
* @param pageParam 分页参数
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
PageResult<SysLog> queryAll(SysLogQueryCriteria criteria, PageParam pageParam);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询全部数据
|
|
||||||
*
|
|
||||||
* @param criteria 查询条件
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
List<SysLog> queryAll(SysLogQueryCriteria criteria);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询用户日志
|
|
||||||
*
|
|
||||||
* @param criteria 查询条件
|
|
||||||
* @param pageParam 分页参数
|
|
||||||
* @return -
|
|
||||||
*/
|
|
||||||
PageResult<SysLog> queryAllByUser(SysLogQueryCriteria criteria, PageParam pageParam);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 保存日志数据
|
|
||||||
*
|
|
||||||
* @param username 用户
|
|
||||||
* @param browser 浏览器
|
|
||||||
* @param ip 请求IP
|
|
||||||
* @param joinPoint /
|
|
||||||
* @param sysLog 日志实体
|
|
||||||
*/
|
|
||||||
void save(String username, String browser, String ip, ProceedingJoinPoint joinPoint, SysLog sysLog);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询异常详情
|
|
||||||
*
|
|
||||||
* @param id 日志ID
|
|
||||||
* @return Object
|
|
||||||
*/
|
|
||||||
Object findByErrDetail(Long id);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 导出日志
|
|
||||||
*
|
|
||||||
* @param sysLogs 待导出的数据
|
|
||||||
* @param response /
|
|
||||||
* @throws IOException /
|
|
||||||
*/
|
|
||||||
void download(List<SysLog> sysLogs, HttpServletResponse response) throws IOException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除所有错误日志
|
|
||||||
*/
|
|
||||||
void delAllByError();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除所有INFO日志
|
|
||||||
*/
|
|
||||||
void delAllByInfo();
|
|
||||||
}
|
|
||||||
|
|
@ -1,178 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.service.impl;
|
|
||||||
|
|
||||||
import cn.hutool.core.lang.Dict;
|
|
||||||
import com.alibaba.fastjson2.JSON;
|
|
||||||
import com.alibaba.fastjson2.JSONArray;
|
|
||||||
import com.alibaba.fastjson2.JSONObject;
|
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
||||||
import com.njzscloud.supervisory.order.utils.FileUtil;
|
|
||||||
import com.njzscloud.supervisory.sys.log.annotation.Log;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.SysLog;
|
|
||||||
import com.njzscloud.supervisory.sys.log.domain.dto.SysLogQueryCriteria;
|
|
||||||
import com.njzscloud.supervisory.sys.log.mapper.SysLogMapper;
|
|
||||||
import com.njzscloud.supervisory.sys.log.service.SysLogService;
|
|
||||||
import com.njzscloud.supervisory.sys.log.utils.StringUtils;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.aspectj.lang.ProceedingJoinPoint;
|
|
||||||
import org.aspectj.lang.reflect.MethodSignature;
|
|
||||||
import org.springframework.scheduling.annotation.Async;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
import org.springframework.web.bind.annotation.RequestBody;
|
|
||||||
import org.springframework.web.multipart.MultipartFile;
|
|
||||||
import com.njzscloud.common.mp.support.PageParam;
|
|
||||||
import com.njzscloud.common.mp.support.PageResult;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletRequest;
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.lang.reflect.Method;
|
|
||||||
import java.lang.reflect.Parameter;
|
|
||||||
import java.util.*;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
*/
|
|
||||||
@Service
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class SysLogServiceImpl extends ServiceImpl<SysLogMapper, SysLog> implements SysLogService {
|
|
||||||
|
|
||||||
private final SysLogMapper sysLogMapper;
|
|
||||||
// 定义敏感字段常量数组
|
|
||||||
private static final String[] SENSITIVE_KEYS = {"password"};
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public PageResult<SysLog> queryAll(SysLogQueryCriteria criteria, PageParam pageParam) {
|
|
||||||
return PageResult.of(sysLogMapper.queryAll(criteria, pageParam.toPage()));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<SysLog> queryAll(SysLogQueryCriteria criteria) {
|
|
||||||
return sysLogMapper.queryAll(criteria);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public PageResult<SysLog> queryAllByUser(SysLogQueryCriteria criteria, PageParam page) {
|
|
||||||
return PageResult.of(sysLogMapper.queryAllByUser(criteria, page.toPage()));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Async
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void save(String username, String browser, String ip, ProceedingJoinPoint joinPoint, SysLog sysLog) {
|
|
||||||
if (sysLog == null) {
|
|
||||||
throw new IllegalArgumentException("Log 不能为 null!");
|
|
||||||
}
|
|
||||||
|
|
||||||
// 获取方法签名
|
|
||||||
MethodSignature signature = (MethodSignature) joinPoint.getSignature();
|
|
||||||
Method method = signature.getMethod();
|
|
||||||
Log aopLog = method.getAnnotation(Log.class);
|
|
||||||
|
|
||||||
// 方法路径
|
|
||||||
String methodName = joinPoint.getTarget().getClass().getName() + "." + signature.getName() + "()";
|
|
||||||
|
|
||||||
// 获取参数
|
|
||||||
JSONObject params = getParameter(method, joinPoint.getArgs());
|
|
||||||
|
|
||||||
// 填充基本信息
|
|
||||||
sysLog.setRequestIp(ip);
|
|
||||||
sysLog.setAddress(StringUtils.getCityInfo(sysLog.getRequestIp()));
|
|
||||||
sysLog.setMethod(methodName);
|
|
||||||
sysLog.setUsername(username);
|
|
||||||
sysLog.setParams(JSON.toJSONString(params));
|
|
||||||
sysLog.setBrowser(browser);
|
|
||||||
sysLog.setDescription(aopLog.value());
|
|
||||||
|
|
||||||
// 如果没有获取到用户名，尝试从参数中获取
|
|
||||||
if(StringUtils.isBlank(sysLog.getUsername())){
|
|
||||||
sysLog.setUsername(params.getString("username"));
|
|
||||||
}
|
|
||||||
|
|
||||||
// 保存
|
|
||||||
save(sysLog);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 根据方法和传入的参数获取请求参数
|
|
||||||
*/
|
|
||||||
private JSONObject getParameter(Method method, Object[] args) {
|
|
||||||
JSONObject params = new JSONObject();
|
|
||||||
Parameter[] parameters = method.getParameters();
|
|
||||||
for (int i = 0; i < parameters.length; i++) {
|
|
||||||
// 过滤掉 MultiPartFile
|
|
||||||
if (args[i] instanceof MultipartFile) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
// 过滤掉 HttpServletResponse
|
|
||||||
if (args[i] instanceof HttpServletResponse) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
// 过滤掉 HttpServletRequest
|
|
||||||
if (args[i] instanceof HttpServletRequest) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
// 将RequestBody注解修饰的参数作为请求参数
|
|
||||||
RequestBody requestBody = parameters[i].getAnnotation(RequestBody.class);
|
|
||||||
if (requestBody != null) {
|
|
||||||
Object json = JSON.toJSON(args[i]);
|
|
||||||
if (json instanceof JSONArray) {
|
|
||||||
params.put("reqBodyList", json);
|
|
||||||
} else {
|
|
||||||
params.putAll((JSONObject) json);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
String key = parameters[i].getName();
|
|
||||||
params.put(key, args[i]);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// 遍历敏感字段数组并替换值
|
|
||||||
Set<String> keys = params.keySet();
|
|
||||||
for (String key : SENSITIVE_KEYS) {
|
|
||||||
if (keys.contains(key)) {
|
|
||||||
params.put(key, "******");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// 返回参数
|
|
||||||
return params;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Object findByErrDetail(Long id) {
|
|
||||||
String details = sysLogMapper.getExceptionDetails(id);
|
|
||||||
return Dict.create().set("exception", details);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void download(List<SysLog> sysLogs, HttpServletResponse response) throws IOException {
|
|
||||||
List<Map<String, Object>> list = new ArrayList<>();
|
|
||||||
for (SysLog sysLog : sysLogs) {
|
|
||||||
Map<String, Object> map = new LinkedHashMap<>();
|
|
||||||
map.put("用户名", sysLog.getUsername());
|
|
||||||
map.put("IP", sysLog.getRequestIp());
|
|
||||||
map.put("IP来源", sysLog.getAddress());
|
|
||||||
map.put("描述", sysLog.getDescription());
|
|
||||||
map.put("浏览器", sysLog.getBrowser());
|
|
||||||
map.put("请求耗时/毫秒", sysLog.getTime());
|
|
||||||
map.put("异常详情", sysLog.getExceptionDetail());
|
|
||||||
map.put("创建日期", sysLog.getCreateTime());
|
|
||||||
list.add(map);
|
|
||||||
}
|
|
||||||
FileUtil.downloadExcel(list, response, "系统日志.xlsx");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void delAllByError() {
|
|
||||||
// 删除 ERROR 级别的日志
|
|
||||||
sysLogMapper.deleteByLevel("ERROR");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
public void delAllByInfo() {
|
|
||||||
// 删除 INFO 级别的日志
|
|
||||||
sysLogMapper.deleteByLevel("INFO");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,158 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.utils;
|
|
||||||
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.beans.BeansException;
|
|
||||||
import org.springframework.beans.factory.DisposableBean;
|
|
||||||
import org.springframework.context.ApplicationContext;
|
|
||||||
import org.springframework.context.ApplicationContextAware;
|
|
||||||
import org.springframework.core.env.Environment;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author ljw
|
|
||||||
* @date 2025-10-24
|
|
||||||
*/
|
|
||||||
@Slf4j
|
|
||||||
@SuppressWarnings({"unchecked","all"})
|
|
||||||
public class SpringBeanHolder implements ApplicationContextAware, DisposableBean {
|
|
||||||
|
|
||||||
private static ApplicationContext applicationContext = null;
|
|
||||||
private static final List<CallBack> CALL_BACKS = new ArrayList<>();
|
|
||||||
private static boolean addCallback = true;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 针对 某些初始化方法，在SpringContextHolder 未初始化时 提交回调方法。
|
|
||||||
* 在SpringContextHolder 初始化后，进行回调使用
|
|
||||||
*
|
|
||||||
* @param callBack 回调函数
|
|
||||||
*/
|
|
||||||
public synchronized static void addCallBacks(CallBack callBack) {
|
|
||||||
if (addCallback) {
|
|
||||||
SpringBeanHolder.CALL_BACKS.add(callBack);
|
|
||||||
} else {
|
|
||||||
log.warn("CallBack：{} 已无法添加！立即执行", callBack.getCallBackName());
|
|
||||||
callBack.executor();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型.
|
|
||||||
*/
|
|
||||||
public static <T> T getBean(String name) {
|
|
||||||
assertContextInjected();
|
|
||||||
return (T) applicationContext.getBean(name);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型.
|
|
||||||
*/
|
|
||||||
public static <T> T getBean(Class<T> requiredType) {
|
|
||||||
assertContextInjected();
|
|
||||||
return applicationContext.getBean(requiredType);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取SpringBoot 配置信息
|
|
||||||
*
|
|
||||||
* @param property 属性key
|
|
||||||
* @param defaultValue 默认值
|
|
||||||
* @param requiredType 返回类型
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
public static <T> T getProperties(String property, T defaultValue, Class<T> requiredType) {
|
|
||||||
T result = defaultValue;
|
|
||||||
try {
|
|
||||||
result = getBean(Environment.class).getProperty(property, requiredType);
|
|
||||||
} catch (Exception ignored) {}
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取SpringBoot 配置信息
|
|
||||||
*
|
|
||||||
* @param property 属性key
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
public static String getProperties(String property) {
|
|
||||||
return getProperties(property, null, String.class);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取SpringBoot 配置信息
|
|
||||||
*
|
|
||||||
* @param property 属性key
|
|
||||||
* @param requiredType 返回类型
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
public static <T> T getProperties(String property, Class<T> requiredType) {
|
|
||||||
return getProperties(property, null, requiredType);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 检查ApplicationContext不为空.
|
|
||||||
*/
|
|
||||||
private static void assertContextInjected() {
|
|
||||||
if (applicationContext == null) {
|
|
||||||
throw new IllegalStateException("applicaitonContext属性未注入, 请在applicationContext" +
|
|
||||||
".xml中定义SpringContextHolder或在SpringBoot启动类中注册SpringContextHolder.");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 清除SpringContextHolder中的ApplicationContext为Null.
|
|
||||||
*/
|
|
||||||
private static void clearHolder() {
|
|
||||||
log.debug("清除SpringContextHolder中的ApplicationContext:"
|
|
||||||
+ applicationContext);
|
|
||||||
applicationContext = null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void destroy() {
|
|
||||||
SpringBeanHolder.clearHolder();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
|
|
||||||
if (SpringBeanHolder.applicationContext != null) {
|
|
||||||
log.warn("SpringContextHolder中的ApplicationContext被覆盖, 原有ApplicationContext为:" + SpringBeanHolder.applicationContext);
|
|
||||||
}
|
|
||||||
SpringBeanHolder.applicationContext = applicationContext;
|
|
||||||
if (addCallback) {
|
|
||||||
for (CallBack callBack : SpringBeanHolder.CALL_BACKS) {
|
|
||||||
callBack.executor();
|
|
||||||
}
|
|
||||||
CALL_BACKS.clear();
|
|
||||||
}
|
|
||||||
SpringBeanHolder.addCallback = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取 @Service 的所有 bean 名称
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
public static List<String> getAllServiceBeanName() {
|
|
||||||
return new ArrayList<>(Arrays.asList(applicationContext
|
|
||||||
.getBeanNamesForAnnotation(Service.class)));
|
|
||||||
}
|
|
||||||
|
|
||||||
interface CallBack {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 回调执行方法
|
|
||||||
*/
|
|
||||||
void executor();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 本回调任务名称
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
default String getCallBackName() {
|
|
||||||
return Thread.currentThread().getId() + ":" + this.getClass().getName();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,229 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.utils;
|
|
||||||
|
|
||||||
import cn.hutool.http.useragent.UserAgent;
|
|
||||||
import cn.hutool.http.useragent.UserAgentUtil;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import net.dreamlu.mica.ip2region.core.Ip2regionSearcher;
|
|
||||||
import net.dreamlu.mica.ip2region.core.IpInfo;
|
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletRequest;
|
|
||||||
import java.lang.reflect.Field;
|
|
||||||
import java.net.InetAddress;
|
|
||||||
import java.net.NetworkInterface;
|
|
||||||
import java.net.UnknownHostException;
|
|
||||||
import java.util.*;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author ljw
|
|
||||||
* 字符串工具类, 继承org.apache.commons.lang3.StringUtils类
|
|
||||||
*/
|
|
||||||
@Slf4j
|
|
||||||
public class StringUtils extends org.apache.commons.lang3.StringUtils {
|
|
||||||
|
|
||||||
private static final char SEPARATOR = '_';
|
|
||||||
private static final String UNKNOWN = "unknown";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 注入bean
|
|
||||||
*/
|
|
||||||
private final static Ip2regionSearcher IP_SEARCHER = SpringBeanHolder.getBean(Ip2regionSearcher.class);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 驼峰命名法工具
|
|
||||||
*
|
|
||||||
* @return toCamelCase(" hello_world ") == "helloWorld"
|
|
||||||
* toCapitalizeCamelCase("hello_world") == "HelloWorld"
|
|
||||||
* toUnderScoreCase("helloWorld") = "hello_world"
|
|
||||||
*/
|
|
||||||
public static String toCamelCase(String s) {
|
|
||||||
if (s == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
s = s.toLowerCase();
|
|
||||||
|
|
||||||
StringBuilder sb = new StringBuilder(s.length());
|
|
||||||
boolean upperCase = false;
|
|
||||||
for (int i = 0; i < s.length(); i++) {
|
|
||||||
char c = s.charAt(i);
|
|
||||||
|
|
||||||
if (c == SEPARATOR) {
|
|
||||||
upperCase = true;
|
|
||||||
} else if (upperCase) {
|
|
||||||
sb.append(Character.toUpperCase(c));
|
|
||||||
upperCase = false;
|
|
||||||
} else {
|
|
||||||
sb.append(c);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return sb.toString();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 驼峰命名法工具
|
|
||||||
*
|
|
||||||
* @return toCamelCase(" hello_world ") == "helloWorld"
|
|
||||||
* toCapitalizeCamelCase("hello_world") == "HelloWorld"
|
|
||||||
* toUnderScoreCase("helloWorld") = "hello_world"
|
|
||||||
*/
|
|
||||||
public static String toCapitalizeCamelCase(String s) {
|
|
||||||
if (s == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
s = toCamelCase(s);
|
|
||||||
return s.substring(0, 1).toUpperCase() + s.substring(1);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 驼峰命名法工具
|
|
||||||
*
|
|
||||||
* @return toCamelCase(" hello_world ") == "helloWorld"
|
|
||||||
* toCapitalizeCamelCase("hello_world") == "HelloWorld"
|
|
||||||
* toUnderScoreCase("helloWorld") = "hello_world"
|
|
||||||
*/
|
|
||||||
static String toUnderScoreCase(String s) {
|
|
||||||
if (s == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
StringBuilder sb = new StringBuilder();
|
|
||||||
boolean upperCase = false;
|
|
||||||
for (int i = 0; i < s.length(); i++) {
|
|
||||||
char c = s.charAt(i);
|
|
||||||
|
|
||||||
boolean nextUpperCase = true;
|
|
||||||
|
|
||||||
if (i < (s.length() - 1)) {
|
|
||||||
nextUpperCase = Character.isUpperCase(s.charAt(i + 1));
|
|
||||||
}
|
|
||||||
|
|
||||||
if ((i > 0) && Character.isUpperCase(c)) {
|
|
||||||
if (!upperCase || !nextUpperCase) {
|
|
||||||
sb.append(SEPARATOR);
|
|
||||||
}
|
|
||||||
upperCase = true;
|
|
||||||
} else {
|
|
||||||
upperCase = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
sb.append(Character.toLowerCase(c));
|
|
||||||
}
|
|
||||||
|
|
||||||
return sb.toString();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取ip地址
|
|
||||||
*/
|
|
||||||
public static String getIp(HttpServletRequest request) {
|
|
||||||
String ip = request.getHeader("x-forwarded-for");
|
|
||||||
if (ip == null || ip.isEmpty() || UNKNOWN.equalsIgnoreCase(ip)) {
|
|
||||||
ip = request.getHeader("Proxy-Client-IP");
|
|
||||||
}
|
|
||||||
if (ip == null || ip.isEmpty() || UNKNOWN.equalsIgnoreCase(ip)) {
|
|
||||||
ip = request.getHeader("WL-Proxy-Client-IP");
|
|
||||||
}
|
|
||||||
if (ip == null || ip.isEmpty() || UNKNOWN.equalsIgnoreCase(ip)) {
|
|
||||||
ip = request.getRemoteAddr();
|
|
||||||
}
|
|
||||||
String comma = ",";
|
|
||||||
String localhost = "127.0.0.1";
|
|
||||||
if (ip.contains(comma)) {
|
|
||||||
ip = ip.split(",")[0];
|
|
||||||
}
|
|
||||||
if (localhost.equals(ip)) {
|
|
||||||
// 获取本机真正的ip地址
|
|
||||||
try {
|
|
||||||
ip = InetAddress.getLocalHost().getHostAddress();
|
|
||||||
} catch (UnknownHostException e) {
|
|
||||||
log.error(e.getMessage(), e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return ip;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 根据ip获取详细地址
|
|
||||||
*/
|
|
||||||
public static String getCityInfo(String ip) {
|
|
||||||
IpInfo ipInfo = IP_SEARCHER.memorySearch(ip);
|
|
||||||
if (ipInfo != null) {
|
|
||||||
return ipInfo.getAddress();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取浏览器
|
|
||||||
*/
|
|
||||||
public static String getBrowser(HttpServletRequest request) {
|
|
||||||
UserAgent ua = UserAgentUtil.parse(request.getHeader("User-Agent"));
|
|
||||||
String browser = ua.getBrowser().toString() + " " + ua.getVersion();
|
|
||||||
return browser.replace(".0.0.0", "");
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获得当天是周几
|
|
||||||
*/
|
|
||||||
public static String getWeekDay() {
|
|
||||||
String[] weekDays = {"Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"};
|
|
||||||
Calendar cal = Calendar.getInstance();
|
|
||||||
cal.setTime(new Date());
|
|
||||||
|
|
||||||
int w = cal.get(Calendar.DAY_OF_WEEK) - 1;
|
|
||||||
if (w < 0) {
|
|
||||||
w = 0;
|
|
||||||
}
|
|
||||||
return weekDays[w];
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取当前机器的IP
|
|
||||||
*
|
|
||||||
* @return /
|
|
||||||
*/
|
|
||||||
public static String getLocalIp() {
|
|
||||||
try {
|
|
||||||
InetAddress candidateAddress = null;
|
|
||||||
// 遍历所有的网络接口
|
|
||||||
for (Enumeration<NetworkInterface> interfaces = NetworkInterface.getNetworkInterfaces(); interfaces.hasMoreElements(); ) {
|
|
||||||
NetworkInterface anInterface = interfaces.nextElement();
|
|
||||||
// 在所有的接口下再遍历IP
|
|
||||||
for (Enumeration<InetAddress> inetAddresses = anInterface.getInetAddresses(); inetAddresses.hasMoreElements(); ) {
|
|
||||||
InetAddress inetAddr = inetAddresses.nextElement();
|
|
||||||
// 排除loopback类型地址
|
|
||||||
if (!inetAddr.isLoopbackAddress()) {
|
|
||||||
if (inetAddr.isSiteLocalAddress()) {
|
|
||||||
// 如果是site-local地址，就是它了
|
|
||||||
return inetAddr.getHostAddress();
|
|
||||||
} else if (candidateAddress == null) {
|
|
||||||
// site-local类型的地址未被发现，先记录候选地址
|
|
||||||
candidateAddress = inetAddr;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (candidateAddress != null) {
|
|
||||||
return candidateAddress.getHostAddress();
|
|
||||||
}
|
|
||||||
// 如果没有发现 non-loopback地址.只能用最次选的方案
|
|
||||||
InetAddress jdkSuppliedAddress = InetAddress.getLocalHost();
|
|
||||||
if (jdkSuppliedAddress == null) {
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
return jdkSuppliedAddress.getHostAddress();
|
|
||||||
} catch (Exception e) {
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@SuppressWarnings({"unchecked", "all"})
|
|
||||||
public static List<Field> getAllFields(Class clazz, List<Field> fields) {
|
|
||||||
if (clazz != null) {
|
|
||||||
fields.addAll(Arrays.asList(clazz.getDeclaredFields()));
|
|
||||||
getAllFields(clazz.getSuperclass(), fields);
|
|
||||||
}
|
|
||||||
return fields;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,21 +0,0 @@
|
||||||
package com.njzscloud.supervisory.sys.log.utils;
|
|
||||||
|
|
||||||
import java.io.PrintWriter;
|
|
||||||
import java.io.StringWriter;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @author Ljw
|
|
||||||
*/
|
|
||||||
public class ThrowableUtil {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取堆栈信息
|
|
||||||
*/
|
|
||||||
public static String getStackTrace(Throwable throwable) {
|
|
||||||
StringWriter sw = new StringWriter();
|
|
||||||
try (PrintWriter pw = new PrintWriter(sw)) {
|
|
||||||
throwable.printStackTrace(pw);
|
|
||||||
return sw.toString();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,75 +0,0 @@
|
||||||
<?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="com.njzscloud.supervisory.sys.log.mapper.SysLogMapper">
|
|
||||||
<sql id="info_column">
|
|
||||||
log_id
|
|
||||||
id,description,method,params,request_ip,time,username,address,browser,exception_detail,create_time
|
|
||||||
</sql>
|
|
||||||
|
|
||||||
<sql id="error_column">
|
|
||||||
log_id
|
|
||||||
id,description,method,params,request_ip,username,address,browser,exception_detail,create_time
|
|
||||||
</sql>
|
|
||||||
|
|
||||||
<sql id="user_column">
|
|
||||||
log_id
|
|
||||||
id,description,request_ip,time,address,browser,create_time
|
|
||||||
</sql>
|
|
||||||
|
|
||||||
<sql id="query">
|
|
||||||
from sys_log
|
|
||||||
<where>
|
|
||||||
<if test="criteria.blurry != null and criteria.blurry != ''">
|
|
||||||
and (
|
|
||||||
username like concat('%',#{criteria.blurry},'%')
|
|
||||||
or description like concat('%',#{criteria.blurry},'%')
|
|
||||||
or address like concat('%',#{criteria.blurry},'%')
|
|
||||||
or request_ip like concat('%',#{criteria.blurry},'%')
|
|
||||||
or method like concat('%',#{criteria.blurry},'%')
|
|
||||||
or params like concat('%',#{criteria.blurry},'%')
|
|
||||||
)
|
|
||||||
</if>
|
|
||||||
<if test="criteria.username != null and criteria.username != ''">
|
|
||||||
and username like concat('%',#{criteria.username},'%')
|
|
||||||
</if>
|
|
||||||
<if test="criteria.logType != null and criteria.logType != ''">
|
|
||||||
and log_type = #{criteria.logType}
|
|
||||||
</if>
|
|
||||||
<if test="criteria.createTime != null and criteria.createTime.size() > 0">
|
|
||||||
and create_time between #{criteria.createTime[0]} and #{criteria.createTime[1]}
|
|
||||||
</if>
|
|
||||||
</where>
|
|
||||||
order by log_id desc
|
|
||||||
</sql>
|
|
||||||
|
|
||||||
<select id="queryAll" resultType="com.njzscloud.supervisory.sys.log.domain.SysLog">
|
|
||||||
select
|
|
||||||
<choose>
|
|
||||||
<when test="criteria.logType == 'ERROR'">
|
|
||||||
<include refid="error_column"/>
|
|
||||||
</when>
|
|
||||||
<otherwise>
|
|
||||||
<include refid="info_column"/>
|
|
||||||
</otherwise>
|
|
||||||
</choose>
|
|
||||||
<include refid="query"/>
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<select id="queryAllByUser" resultType="com.njzscloud.supervisory.sys.log.domain.SysLog">
|
|
||||||
select
|
|
||||||
<include refid="user_column"/>
|
|
||||||
<include refid="query"/>
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<delete id="deleteByLevel">
|
|
||||||
delete
|
|
||||||
from sys_log
|
|
||||||
where log_type = #{logType}
|
|
||||||
</delete>
|
|
||||||
|
|
||||||
<select id="getExceptionDetails" resultType="java.lang.String">
|
|
||||||
select exception_detail
|
|
||||||
from sys_log
|
|
||||||
where log_id = #{id}
|
|
||||||
</select>
|
|
||||||
</mapper>
|
|
||||||
Loading…
Reference in New Issue