wxz
4 years ago
24 changed files with 379 additions and 86 deletions
@ -1,49 +1,44 @@ |
|||
package com.epmet.enums; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 操作日志类型枚举 |
|||
*/ |
|||
public enum LogOperationTypeEnum { |
|||
LOGIN("login", "登录"), |
|||
LOGOUT("logout", "退出登录"), |
|||
ISSUE_SHIFT_PROJECT("issue_shift_project", "议题转项目"), |
|||
CLOSE_PROJECT("close_project", "项目结案"), |
|||
PROJECT_TRANSFER("project_transfer", "项目流转"), |
|||
PROJECT_RESPONSE("project_response", "响应处理"), |
|||
PROJECT_APPROVAL("project_approval", "项目立项"); |
|||
|
|||
private String type; |
|||
private String typeDisplay; |
|||
|
|||
public String getType() { |
|||
return type; |
|||
} |
|||
|
|||
public String getTypeDisplay() { |
|||
return typeDisplay; |
|||
} |
|||
|
|||
LogOperationTypeEnum(String type, String typeDisplay) { |
|||
this.type = type; |
|||
this.typeDisplay = typeDisplay; |
|||
} |
|||
|
|||
public static LogOperationTypeEnum get(String type) { |
|||
for (LogOperationTypeEnum t : LogOperationTypeEnum.values()) { |
|||
if (t.type.equals(type)) { |
|||
return t; |
|||
} |
|||
} |
|||
return null; |
|||
} |
|||
|
|||
public static String getDisplay(String type) { |
|||
LogOperationTypeEnum object = get(type); |
|||
if (object == null) { |
|||
return null; |
|||
} |
|||
return object.typeDisplay; |
|||
} |
|||
} |
|||
//package com.epmet.enums;
|
|||
//
|
|||
//import lombok.Data;
|
|||
//
|
|||
///**
|
|||
// * 操作日志类型枚举
|
|||
// */
|
|||
//public enum LogOperationTypeEnum {
|
|||
// LOGIN("login", "登录"),
|
|||
// LOGOUT("logout", "退出登录");
|
|||
//
|
|||
// private String type;
|
|||
// private String typeDisplay;
|
|||
//
|
|||
// public String getType() {
|
|||
// return type;
|
|||
// }
|
|||
//
|
|||
// public String getTypeDisplay() {
|
|||
// return typeDisplay;
|
|||
// }
|
|||
//
|
|||
// LogOperationTypeEnum(String type, String typeDisplay) {
|
|||
// this.type = type;
|
|||
// this.typeDisplay = typeDisplay;
|
|||
// }
|
|||
//
|
|||
// public static LogOperationTypeEnum get(String type) {
|
|||
// for (LogOperationTypeEnum t : LogOperationTypeEnum.values()) {
|
|||
// if (t.type.equals(type)) {
|
|||
// return t;
|
|||
// }
|
|||
// }
|
|||
// return null;
|
|||
// }
|
|||
//
|
|||
// public static String getDisplay(String type) {
|
|||
// LogOperationTypeEnum object = get(type);
|
|||
// if (object == null) {
|
|||
// return null;
|
|||
// }
|
|||
// return object.typeDisplay;
|
|||
// }
|
|||
//}
|
|||
|
|||
@ -0,0 +1,100 @@ |
|||
package com.epmet.mq.listener.listener; |
|||
|
|||
import com.alibaba.fastjson.JSON; |
|||
import com.epmet.commons.rocketmq.messages.LoginMQMsg; |
|||
import com.epmet.commons.rocketmq.messages.ProjectChangedMQMsg; |
|||
import com.epmet.commons.tools.distributedlock.DistributedLock; |
|||
import com.epmet.commons.tools.exception.ExceptionUtils; |
|||
import com.epmet.commons.tools.exception.RenException; |
|||
import com.epmet.commons.tools.utils.SpringContextUtils; |
|||
import com.epmet.entity.LogOperationEntity; |
|||
import com.epmet.service.LogOperationService; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; |
|||
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus; |
|||
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently; |
|||
import org.apache.rocketmq.common.message.MessageExt; |
|||
import org.redisson.api.RLock; |
|||
import org.slf4j.Logger; |
|||
import org.slf4j.LoggerFactory; |
|||
|
|||
import java.util.List; |
|||
import java.util.concurrent.TimeUnit; |
|||
|
|||
/** |
|||
* @author wxz |
|||
* @Description 项目操作日志监听器 |
|||
|
|||
* @return |
|||
* @date 2021.06.08 22.21 |
|||
*/ |
|||
public class ProjectOperationLogListener implements MessageListenerConcurrently { |
|||
|
|||
private Logger logger = LoggerFactory.getLogger(getClass()); |
|||
|
|||
@Override |
|||
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) { |
|||
try { |
|||
msgs.forEach(msg -> consumeMessage(msg)); |
|||
} catch (Exception e) { |
|||
logger.error(ExceptionUtils.getErrorStackTrace(e)); |
|||
return ConsumeConcurrentlyStatus.RECONSUME_LATER; |
|||
} |
|||
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; |
|||
} |
|||
|
|||
private void consumeMessage(MessageExt messageExt) { |
|||
//String tags = messageExt.getTags();
|
|||
String msg = new String(messageExt.getBody()); |
|||
logger.info("项目变动操作日志监听器-收到消息内容:{}", msg); |
|||
ProjectChangedMQMsg msgObj = JSON.parseObject(msg, ProjectChangedMQMsg.class); |
|||
|
|||
String content = StringUtils.isBlank(msgObj.getOperationBrief()) ? "" : msgObj.getOperationBrief(); |
|||
|
|||
LogOperationEntity logEntity = new LogOperationEntity(); |
|||
logEntity.setCategory(messageExt.getTopic()); |
|||
logEntity.setType(msgObj.getOperation()); |
|||
logEntity.setTypeDisplay(getOperationTypeDisplay(msgObj.getOperation())); |
|||
logEntity.setTargetId(msgObj.getProjectId()); |
|||
logEntity.setOperatorId(msgObj.getOperatorId()); |
|||
logEntity.setOperatingTime(msgObj.getOperatingTime()); |
|||
logEntity.setContent(content); |
|||
|
|||
DistributedLock distributedLock = null; |
|||
RLock lock = null; |
|||
try { |
|||
distributedLock = SpringContextUtils.getBean(DistributedLock.class); |
|||
lock = distributedLock.getLock(String.format("lock:project_operation_log:%s:%s", logEntity.getType(), logEntity.getTargetId()), |
|||
30L, 30L, TimeUnit.SECONDS); |
|||
SpringContextUtils.getBean(LogOperationService.class).log(logEntity); |
|||
} catch (RenException e) { |
|||
// 如果是我们手动抛出的异常，说明在业务可控范围内。目前不需要MQ重试
|
|||
logger.error("【RocketMQ】添加操作日志失败:".concat(ExceptionUtils.getErrorStackTrace(e))); |
|||
} catch (Exception e) { |
|||
// 不是我们自己抛出的异常，可以让MQ重试
|
|||
logger.error("【RocketMQ】添加操作日志失败:".concat(ExceptionUtils.getErrorStackTrace(e))); |
|||
throw e; |
|||
} finally { |
|||
distributedLock.unLock(lock); |
|||
} |
|||
} |
|||
|
|||
private String getOperationTypeDisplay(String type) { |
|||
switch (type) { |
|||
case "response": |
|||
return "项目响应处理"; |
|||
case "issue_shift_project": |
|||
return "议题转项目"; |
|||
case "close": |
|||
return "项目结案"; |
|||
case "return": |
|||
return "项目退回"; |
|||
case "transfer": |
|||
return "项目吹哨"; |
|||
case "created": |
|||
return "项目立项"; |
|||
default: |
|||
return null; |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,14 @@ |
|||
<?xml version="1.0" encoding="UTF-8"?> |
|||
<project xmlns="http://maven.apache.org/POM/4.0.0" |
|||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" |
|||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> |
|||
<parent> |
|||
<artifactId>epmet-auth</artifactId> |
|||
<groupId>com.epmet</groupId> |
|||
<version>2.0.0</version> |
|||
</parent> |
|||
<modelVersion>4.0.0</modelVersion> |
|||
|
|||
<artifactId>epmet-auth-client</artifactId> |
|||
|
|||
</project> |
|||
@ -0,0 +1,9 @@ |
|||
package com.epmet.auth.constants; |
|||
|
|||
/** |
|||
* 认证操作常量 |
|||
*/ |
|||
public interface AuthOperationConstants { |
|||
String LOGIN = "login"; |
|||
String LOGOUT = "logout"; |
|||
} |
|||
@ -0,0 +1,43 @@ |
|||
package com.epmet.auth.constants; |
|||
|
|||
/** |
|||
* 认证操作枚举 |
|||
*/ |
|||
public enum AuthOperationEnum { |
|||
|
|||
LOGIN(AuthOperationConstants.LOGIN, "登录"), |
|||
LOGOUT(AuthOperationConstants.LOGOUT, "退出"); |
|||
|
|||
private String operationType; |
|||
private String operationDisplay; |
|||
|
|||
AuthOperationEnum(String operationType, String operationDisplay) { |
|||
this.operationType = operationType; |
|||
this.operationDisplay = operationDisplay; |
|||
} |
|||
|
|||
public String getOperationType() { |
|||
return operationType; |
|||
} |
|||
|
|||
public String getOperationDisplay() { |
|||
return operationDisplay; |
|||
} |
|||
|
|||
public static AuthOperationEnum get(String operationType) { |
|||
for (AuthOperationEnum e : AuthOperationEnum.values()) { |
|||
if (e.getOperationType().equals(operationType)) { |
|||
return e; |
|||
} |
|||
} |
|||
return null; |
|||
} |
|||
|
|||
public static String getDisplay(String operationType) { |
|||
AuthOperationEnum obj = get(operationType); |
|||
if (obj == null) { |
|||
return null; |
|||
} |
|||
return obj.getOperationDisplay(); |
|||
} |
|||
} |
|||
Loading…
Reference in new issue