123

ace-common/src/main/java/com/github/wxiaoqi/security/common/util/HttpContextUtils.java

+package com.github.wxiaoqi.security.common.util;
+
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+
+public class HttpContextUtils {
+
+
+    public static HttpServletRequest getHttpServletRequest() {
+        return ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+    }
+}

ace-common/src/main/java/com/github/wxiaoqi/security/common/util/IPUtils.java

+package com.github.wxiaoqi.security.common.util;
+
+import javax.servlet.http.HttpServletRequest;
+
+public class IPUtils {
+
+    /**
+     * 获取IP地址
+     *
+     * 使用Nginx等反向代理软件， 则不能通过request.getRemoteAddr()获取IP地址
+     * 如果使用了多级反向代理的话，X-Forwarded-For的值并不止一个，而是一串IP地址，X-Forwarded-For中第一个非unknown的有效IP字符串，则为真实IP地址
+     */
+    public static String getIpAddr(HttpServletRequest request) {
+
+        String ip = request.getHeader("x-forwarded-for");
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("Proxy-Client-IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("WL-Proxy-Client-IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getRemoteAddr();
+        }
+        return "0:0:0:0:0:0:0:1".equals(ip) ? "127.0.0.1" : ip;
+    }
+}

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/entity/SysLog.java

@@ -49,6 +49,11 @@ public class SysLog implements Serializable {
     private Integer operateType;
 
 
+    @Column(name = "operation")
+    @ApiModelProperty("描述")
+    private String operation;
+
+
 
     @Column(name = "time")
     @ApiModelProperty("操作时间")

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/aop/GlobalLog.java

+package com.xxfc.platform.vehicle.aop;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.METHOD)
+public @interface GlobalLog {
+	int type() default 0;
+	String value() default "";
+}

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/aop/LogAspect.java

+package com.xxfc.platform.vehicle.aop;
+
+
+import com.github.wxiaoqi.security.common.util.HttpContextUtils;
+import com.github.wxiaoqi.security.common.util.IPUtils;
+import com.xxfc.platform.vehicle.biz.SysLogBiz;
+import com.xxfc.platform.vehicle.entity.SysLog;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Pointcut;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.LocalVariableTableParameterNameDiscoverer;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.http.HttpServletRequest;
+import java.lang.reflect.Method;
+
+@Aspect
+@Component
+public class LogAspect {
+
+
+    @Autowired
+    SysLogBiz sysLogBiz;
+
+
+    @Pointcut("@annotation(com.xxfc.platform.vehicle.aop.GlobalLog)")
+    public void pointcut() { }
+
+    @Around("pointcut()")
+    public Object around(ProceedingJoinPoint point) {
+        Object result = null;
+        long beginTime = System.currentTimeMillis();
+        try {
+            // 执行方法
+            result = point.proceed();
+        } catch (Throwable e) {
+            e.printStackTrace();
+        }
+        // 执行时长(毫秒)
+        long time = System.currentTimeMillis() - beginTime;
+        // 保存日志
+        saveLog(point, time);
+        return result;
+    }
+
+    private void saveLog(ProceedingJoinPoint joinPoint, long time) {
+        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
+        Method method = signature.getMethod();
+        SysLog sysLog = new SysLog();
+        GlobalLog logAnnotation = method.getAnnotation(GlobalLog.class);
+        if (logAnnotation != null) {
+            // 注解上的描述
+            sysLog.setOperation(logAnnotation.value());
+            sysLog.setType(logAnnotation.type());
+        }
+        // 请求的方法名
+        String className = joinPoint.getTarget().getClass().getName();
+        String methodName = signature.getName();
+        sysLog.setMethod(className + "." + methodName + "()");
+        // 请求的方法参数值
+        Object[] args = joinPoint.getArgs();
+        // 请求的方法参数名称
+        LocalVariableTableParameterNameDiscoverer u = new LocalVariableTableParameterNameDiscoverer();
+        String[] paramNames = u.getParameterNames(method);
+
+        if (args != null && paramNames != null) {
+            String vehicleId = null;
+            String params = "";
+            Integer state = 0;
+            for (int i = 0; i < args.length; i++) {
+                params += "  " + paramNames[i] + ": " + args[i];
+                if (paramNames[i].contains("id"))
+                    vehicleId = args[i].toString();
+                if (paramNames[i].contains("state"))
+                    state = Integer.parseInt(args[i].toString());
+            }
+            sysLog.setParams(params);
+            sysLog.setVehicleId(vehicleId);
+            sysLog.setOperateType(state);
+        }
+        // 获取request
+        HttpServletRequest request = HttpContextUtils.getHttpServletRequest();
+        // 设置IP地址
+        sysLog.setIp(IPUtils.getIpAddr(request));
+
+        sysLog.setTime(time);
+        // 保存系统日志
+        sysLogBiz.addLog(sysLog);
+    }
+}

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/SysLogBiz.java

+package com.xxfc.platform.vehicle.biz;
+
+
+
+import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import com.github.wxiaoqi.security.common.exception.BaseException;
+import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.vehicle.entity.SysLog;
+import com.xxfc.platform.vehicle.entity.Vehicle;
+import com.xxfc.platform.vehicle.entity.VehicleUseTime;
+import com.xxfc.platform.vehicle.mapper.SysLogMapper;
+import com.xxfc.platform.vehicle.mapper.VehicleUseTimeMapper;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.List;
+
+
+@Service
+@Slf4j
+public class SysLogBiz extends BaseBiz<SysLogMapper, SysLog> {
+
+
+
+    @Autowired
+    VehicleBiz vehicleBiz;
+
+
+
+     public  void  addLog(SysLog sysLog){
+         String vehicleId = sysLog.getVehicleId();
+         if (StringUtils.isBlank(vehicleId) ){
+             throw  new BaseException("参数不能为空", ResultCode.FAILED_CODE);
+         }
+         Vehicle vehicle = vehicleBiz.selectById(vehicleId);
+         if (vehicle == null ){
+             throw  new BaseException("商品不存在", ResultCode.FAILED_CODE);
+         }
+         sysLog.setComapnyId(vehicle.getManageCompanyId());
+         insertSelective(sysLog);
+     }
+
+
+
+
+
+
+
+
+
+
+
+}

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/mapper/SysLogMapper.java

+package com.xxfc.platform.vehicle.mapper;
+
+
+import com.xxfc.platform.vehicle.entity.SysLog;
+import tk.mybatis.mapper.additional.idlist.SelectByIdListMapper;
+import tk.mybatis.mapper.common.Mapper;
+
+public interface SysLogMapper extends Mapper<SysLog>, SelectByIdListMapper<SysLog,Long> {
+
+}
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/AppVehicleController.java

@@ -3,6 +3,7 @@ package com.xxfc.platform.vehicle.rest;
 import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.vehicle.aop.GlobalLog;
 import com.xxfc.platform.vehicle.biz.VehicleApplyBiz;
 import com.xxfc.platform.vehicle.biz.VehicleBiz;
 import com.xxfc.platform.vehicle.entity.Vehicle;
@@ -43,6 +44,7 @@ public class AppVehicleController extends BaseController<VehicleBiz> {
 
     @PostMapping("updVehicle")
     @ApiModelProperty("更新商品信息")
+    @GlobalLog(type = 1,value = "商家操作上下架")
     public  ObjectRestResponse updVehicle(@RequestBody Vehicle vehicle) {
         return baseBiz.updState(vehicle);
     }