mirror of https://github.com/ZhongFuCheng3y/austin
parent
a65e154bfd
commit
dfa35752c2
@ -0,0 +1,42 @@
|
|||||||
|
package com.java3y.austin.domain;
|
||||||
|
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Builder;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
import java.util.Set;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 埋点信息
|
||||||
|
* @author 3y
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
@Builder
|
||||||
|
@AllArgsConstructor
|
||||||
|
@NoArgsConstructor
|
||||||
|
public class AnchorInfo {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 发送用户
|
||||||
|
*/
|
||||||
|
private Set<String> ids;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 具体点位
|
||||||
|
*/
|
||||||
|
private int state;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 业务Id(数据追踪使用)
|
||||||
|
* 生成逻辑参考 TaskInfoUtils
|
||||||
|
*/
|
||||||
|
private Long businessId;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 生成时间
|
||||||
|
*/
|
||||||
|
private long timestamp;
|
||||||
|
|
||||||
|
}
|
@ -0,0 +1,34 @@
|
|||||||
|
package com.java3y.austin.domain;
|
||||||
|
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Builder;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* 日志参数
|
||||||
|
* @author 3y
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
@Builder
|
||||||
|
@AllArgsConstructor
|
||||||
|
@NoArgsConstructor
|
||||||
|
public class LogParam {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 需要记录的日志
|
||||||
|
*/
|
||||||
|
private Object object;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 标识日志的业务
|
||||||
|
*/
|
||||||
|
private String bizType;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 生成时间
|
||||||
|
*/
|
||||||
|
private long timestamp;
|
||||||
|
|
||||||
|
}
|
@ -1,9 +1,28 @@
|
|||||||
package com.java3y.austin.dto;
|
package com.java3y.austin.dto;
|
||||||
|
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Builder;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author 3y
|
* @author 3y
|
||||||
*/
|
*/
|
||||||
|
@Data
|
||||||
|
@Builder
|
||||||
|
@AllArgsConstructor
|
||||||
|
@NoArgsConstructor
|
||||||
public class EmailContentModel extends ContentModel {
|
public class EmailContentModel extends ContentModel {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 标题
|
||||||
|
*/
|
||||||
|
private String title;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 内容(可写入HTML)
|
||||||
|
*/
|
||||||
|
private String content;
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -0,0 +1,31 @@
|
|||||||
|
package com.java3y.austin.enums;
|
||||||
|
|
||||||
|
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Getter;
|
||||||
|
import lombok.ToString;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 打点信息枚举
|
||||||
|
*
|
||||||
|
* @author 3y
|
||||||
|
*/
|
||||||
|
@Getter
|
||||||
|
@ToString
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum AnchorState {
|
||||||
|
|
||||||
|
RECEIVE(10, "成功消费Kafka"),
|
||||||
|
DISCARD(20, "消费被丢弃"),
|
||||||
|
CONTENT_DEDUPLICATION(30, "消息被内容去重"),
|
||||||
|
RULE_DEDUPLICATION(40, "消息被频次去重"),
|
||||||
|
WHITE_LIST(50, "白名单过滤"),
|
||||||
|
SEND_SUCCESS(60, "消息下发成功"),
|
||||||
|
SEND_FAIL(70, "消息下发失败"),
|
||||||
|
;
|
||||||
|
|
||||||
|
|
||||||
|
private Integer code;
|
||||||
|
private String description;
|
||||||
|
|
||||||
|
}
|
@ -0,0 +1,51 @@
|
|||||||
|
package com.java3y.austin.utils;
|
||||||
|
|
||||||
|
import cn.monitor4all.logRecord.bean.LogDTO;
|
||||||
|
import cn.monitor4all.logRecord.service.CustomLogListener;
|
||||||
|
import com.alibaba.fastjson.JSON;
|
||||||
|
import com.java3y.austin.domain.AnchorInfo;
|
||||||
|
import com.java3y.austin.domain.LogParam;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import java.util.Date;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 所有的日志都存在
|
||||||
|
*/
|
||||||
|
@Slf4j
|
||||||
|
@Component
|
||||||
|
public class LogUtils extends CustomLogListener {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 方法切面的日志 @OperationLog 所产生
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public void createLog(LogDTO logDTO) throws Exception {
|
||||||
|
log.info(JSON.toJSONString(logDTO));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 记录当前对象信息
|
||||||
|
*/
|
||||||
|
public static void print(LogParam logParam) {
|
||||||
|
logParam.setTimestamp(System.currentTimeMillis());
|
||||||
|
log.info(JSON.toJSONString(logParam));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 记录打点信息
|
||||||
|
*/
|
||||||
|
public static void print(AnchorInfo anchorInfo) {
|
||||||
|
anchorInfo.setTimestamp(System.currentTimeMillis());
|
||||||
|
log.info(JSON.toJSONString(anchorInfo));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 记录当前对象信息和打点信息
|
||||||
|
*/
|
||||||
|
public static void print(LogParam logParam,AnchorInfo anchorInfo) {
|
||||||
|
print(anchorInfo);
|
||||||
|
print(logParam);
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in new issue