package com.panzhihua.sangeshenbian.aspectj; import com.alibaba.fastjson.JSONObject; import com.panzhihua.common.controller.BaseController; import com.panzhihua.common.model.vos.sangeshenbian.SystemUserVo; import com.panzhihua.common.utlis.StringUtils; import com.panzhihua.sangeshenbian.annotation.SysLog; import com.panzhihua.sangeshenbian.model.entity.*; import com.panzhihua.sangeshenbian.service.ISystemLogService; import com.panzhihua.sangeshenbian.warpper.AddSystemRole; import com.panzhihua.sangeshenbian.warpper.EditSystemRole; import com.panzhihua.sangeshenbian.warpper.PartyMemberDTO; import lombok.extern.slf4j.Slf4j; import org.aspectj.lang.JoinPoint; import org.aspectj.lang.annotation.AfterReturning; 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.stereotype.Component; import java.lang.reflect.Method; /** * 切面处理类，操作日志异常日志记录处理 * * @author wu * @date 2019/03/21 */ @Slf4j @Aspect @Component public class OperLogAspect extends BaseController { @Autowired private ISystemLogService systemLogService; /** * 设置操作日志切入点 记录操作日志 在注解的位置切入代码 */ @Pointcut("@annotation(com.panzhihua.sangeshenbian.annotation.SysLog)") public void operLogPoinCut() {} /** * 正常返回通知，拦截用户操作日志，连接点正常执行完成后执行， 如果连接点抛出异常，则不会执行 * * @param joinPoint * 切入点 * @param keys * 返回结果 */ @AfterReturning(value = "operLogPoinCut()", returning = "keys") public void saveOperLog(JoinPoint joinPoint, Object keys) { log.info("进入切面"); // 从切面织入点处通过反射机制获取织入点处的方法 MethodSignature signature = (MethodSignature)joinPoint.getSignature(); // 获取切入点所在的方法 Method method = signature.getMethod(); Object[] args = joinPoint.getArgs(); try { // 获取操作 SysLog opLog = method.getAnnotation(SysLog.class); SystemLog sysLog = new SystemLog(); JSONObject jsonResult = JSONObject.parseObject(JSONObject.toJSONString(keys)); switch (opLog.operId()){ // 登录 case 1:// 将返回结果转为JSON对象 // 提取data字段中的TokenVo信息 JSONObject data = jsonResult.getJSONObject("data"); Long userId = data.getLong("userId"); String name = data.getString("name");// 直接获取userId sysLog.setOperatorId(Long.valueOf(userId)); sysLog.setTargetName(name); break; // 职位 case 2: if(opLog.operatorCategory().contains("删除")){ String postName = jsonResult.get("data").toString(); sysLog.setTargetName(postName); }else { for (Object arg : args) { if (arg instanceof SystemPost) { SystemPost systemPost = (SystemPost) arg; sysLog.setTargetName(systemPost.getName()); } } } break; // 角色 case 3: if(opLog.operatorCategory().contains("删除")){ String postName = jsonResult.get("data").toString(); sysLog.setTargetName(postName); }else { for (Object arg : args) { if (arg instanceof AddSystemRole) { AddSystemRole systemRole = (AddSystemRole) arg; sysLog.setTargetName(systemRole.getName()); } if (arg instanceof EditSystemRole) { EditSystemRole systemRole = (EditSystemRole) arg; sysLog.setTargetName(systemRole.getName()); } } } break; // 账号 case 4: if(opLog.operatorCategory().contains("删除")){ String postName = jsonResult.get("data").toString(); sysLog.setTargetName(postName); }else { for (Object arg : args) { if (arg instanceof SystemUser) { SystemUser systemUser = (SystemUser) arg; sysLog.setTargetName(systemUser.getName()); } } } break; // 工单 case 5: for (Object arg : args) { if (arg instanceof WorkOrderItemConfig) { WorkOrderItemConfig workOrderItemConfig = (WorkOrderItemConfig) arg; // 拿到返回原来的数据 JSONObject configData = jsonResult.getJSONObject("data"); String targetName=""; // 判断是否修改了诉求处理时间 if(workOrderItemConfig.getDemandProcessingTime()!=configData.getInteger("demandProcessingTime")){ targetName += "修改诉求处理时间、"; } // 判断是否修改了市级账号诉求处理时间 if(workOrderItemConfig.getCityHandlingTime()!=configData.getInteger("cityHandlingTime") || workOrderItemConfig.getDistrictHandlingTime()!=configData.getInteger("districtHandlingTime") || workOrderItemConfig.getStreetHandlingTime()!=configData.getInteger("streetHandlingTime") || workOrderItemConfig.getCommunityHandlingTime()!=configData.getInteger("communityHandlingTime") || workOrderItemConfig.getPartyMemberHandlingTime()!=configData.getInteger("partyMemberHandlingTime")){ targetName += "修改处理超时时间、"; } if(workOrderItemConfig.getCityDeadlineReminder()!=configData.getInteger("cityDeadlineReminder") || workOrderItemConfig.getDistrictDeadlineReminder()!=configData.getInteger("districtDeadlineReminder") || workOrderItemConfig.getStreetDeadlineReminder()!=configData.getInteger("streetDeadlineReminder") || workOrderItemConfig.getCommunityDeadlineReminder()!=configData.getInteger("communityDeadlineReminder") ){ targetName += "修改临期提醒时间、"; } if(StringUtils.isNotEmpty(targetName)){ targetName= targetName.substring(0,targetName.length()-1); sysLog.setTargetName(targetName); } } } break; // 问题 case 6: if(opLog.operatorCategory().contains("删除")){ String postName = jsonResult.get("data").toString(); sysLog.setTargetName(postName); }else { for (Object arg : args) { if (arg instanceof ProblemType) { ProblemType problemType = (ProblemType) arg; sysLog.setTargetName(problemType.getName()); } } } // banner case 7: if(opLog.operatorCategory().contains("删除")){ String postName = jsonResult.get("data").toString(); sysLog.setTargetName(postName); }else { for (Object arg : args) { if (arg instanceof Banner) { Banner banner = (Banner) arg; sysLog.setTargetName(banner.getName()); } } } break; // 党员 case 8: if(opLog.operatorCategory().contains("删除")){ String postName = jsonResult.get("data").toString(); sysLog.setOperatorCategory("删除党员"); sysLog.setTargetName(postName); }else { for (Object arg : args) { if (arg instanceof PartyMemberDTO) { PartyMemberDTO memberDTO = (PartyMemberDTO) arg; sysLog.setTargetName(memberDTO.getName()); if(opLog.operatorCategory().contains("添加")){ if(memberDTO.getId()==null){ sysLog.setOperatorCategory("添加党员"); }else { sysLog.setOperatorCategory("编辑党员"); } } }else if(opLog.operatorCategory().contains("冻结")){ JSONObject freezeData = jsonResult.getJSONObject("data"); sysLog.setTargetName(freezeData.getString("name")); if(freezeData.getInteger("freezeStatus")==1){ sysLog.setOperatorCategory("冻结党员"); }else { sysLog.setOperatorCategory("解冻党员"); } }else { sysLog.setOperatorCategory(opLog.operatorCategory()); } } } break; // 党员审核 case 9: JSONObject auditData = jsonResult.getJSONObject("data"); sysLog.setTargetName(auditData.getString("name")); if(auditData.getInteger("auditStatus")==1){ sysLog.setOperatorCategory("党员审核通过"); }else { sysLog.setOperatorCategory("党员审核拒绝"); } break; // 导出 case 10: if(opLog.operatorCategory().equals("单导出")){ String type = args[1].toString(); if("1".equals(type)){ sysLog.setOperatorCategory("导出社区问题单 "); } if("2".equals(type)){ sysLog.setOperatorCategory("导出问题处理单"); } if("3".equals(type)){ sysLog.setOperatorCategory("导出协调通知单"); } String postName = jsonResult.get("data").toString(); sysLog.setTargetName(postName); } break; default: break; } if(opLog.operId()!=1){ SystemUserVo systemUserVo = this.getLoginUserInfoSanGeShenBian(); sysLog.setOperatorId(Long.valueOf(systemUserVo.getId())); } if(opLog.operId()<8){ sysLog.setOperatorCategory(opLog.operatorCategory()); } sysLog.setIp(this.getRequest().getRemoteAddr()); sysLog.setOperatorInto(opLog.operatorCategory()); if(opLog.operId()!=5 || sysLog.getTargetName()!=null){ systemLogService.save(sysLog); } } catch (Exception e) { e.printStackTrace(); } } }