map = new HashMap<>();
+ for (Status element : Status.values()) {
+ map.put(element.getValue(), element);
+ }
+ ENUM_MAP = Collections.unmodifiableMap(map);
+ }
+
+ public static Status get(Integer value) {
+ if (value == null) {
+ return null;
+ }
+ return ENUM_MAP.get(value);
+ }
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/enums/SystemCode.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/enums/SystemCode.java
new file mode 100644
index 0000000..458d32e
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/enums/SystemCode.java
@@ -0,0 +1,17 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.enums;
+
+/**
+ * @author wsk
+ * @version $Id: SystemCode.java, v 0.1 2024-10-17 17:56 wsk
+ */
+public class SystemCode {
+
+ /** 默认版本 */
+ public static String VERSION = "1";
+
+ /** 默认事件码 */
+ public static String EVENTCODE = "00001001";
+}
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/BizRuntimeException.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/BizRuntimeException.java
new file mode 100644
index 0000000..f38ff88
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/BizRuntimeException.java
@@ -0,0 +1,130 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.exception;
+
+/**
+ * @author wsk
+ * @version $Id: BizRuntimeException.java, v 0.1 2024-10-17 17:46 wsk
+ */
+/**
+ * Runtime业务异常
+ *
+ * @author cihun
+ */
+public class BizRuntimeException extends RuntimeException implements DigestLogException {
+
+ private static final long serialVersionUID = 4823673135679689193L;
+ /**
+ * 错误码
+ */
+ private String errorCode;
+
+ public String getErrorCode() {
+ return errorCode;
+ }
+
+ // ~~~ 构造方法
+
+ /**
+ * default
+ */
+ public BizRuntimeException() {
+ super();
+ }
+
+ /**
+ * 创建一个BizRuntimeException
+ *
+ * @param errorMessage 错误描述
+ */
+ public BizRuntimeException(final String errorMessage) {
+ super(errorMessage);
+ }
+
+ /**
+ * 创建一个BizRuntimeException
+ *
+ * @param errorMessage 错误描述
+ * @param cause 异常
+ */
+ public BizRuntimeException(final String errorMessage, final Throwable cause) {
+ super(errorMessage, cause);
+ }
+
+ /**
+ * 创建一个BizRuntimeException
+ *
+ * @param cause 异常
+ */
+ public BizRuntimeException(Throwable cause) {
+ super(cause);
+ }
+
+ /**
+ * 创建一个BizRuntimeException
+ *
+ * @param errorCode 错误码
+ * @param errorMessage 错误描述
+ */
+ public BizRuntimeException(final String errorCode, final String errorMessage) {
+ this(errorCode, errorMessage, null);
+ }
+
+// /**
+// * 创建一个BizRuntimeException
+// *
+// * @param errorCode 错误码
+// * @param errorMessage 错误描述
+// * @param errorContext 错误上下文
+// */
+// public BizRuntimeException(final String errorCode, final String errorMessage, final ErrorContext errorContext) {
+// super(errorMessage);
+// this.errorCode = errorCode;
+// this.errorContext = errorContext;
+// }
+
+ /**
+ * 创建一个BizRuntimeException
+ *
+ * @param errorCode 错误码
+ * @param errorMessage 错误描述
+ * @param cause 异常
+ */
+ public BizRuntimeException(final String errorCode, final String errorMessage, final Throwable cause) {
+ super(errorMessage, cause);
+ this.errorCode = errorCode;
+ }
+
+// // ~~~ 重写方法
+//
+// /**
+// * @see java.lang.Throwable#toString()
+// */
+// @Override
+// public final String toString() {
+// return String.format(" %s [errorCode=%s, errorMsg=%s, errorContext=%s]", getClass()
+// .getSimpleName(), errorCode, getLocalizedMessage());
+// }
+
+ // ~~~ 容器方法
+
+ /**
+ * Setter method for property errorCode.
+ *
+ * @param errorCode value to be assigned to property errorCode
+ */
+ public void setErrorCode(String errorCode) {
+ this.errorCode = errorCode;
+ }
+
+ @Override
+ public String getTagErrorCode() {
+ return this.errorCode;
+ }
+
+ @Override
+ public String getTagErrorMsg() {
+ return this.getMessage();
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/DigestLogException.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/DigestLogException.java
new file mode 100644
index 0000000..b751002
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/DigestLogException.java
@@ -0,0 +1,25 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.exception;
+
+/**
+ * @author wsk
+ * @version $Id: DigestLogException.java, v 0.1 2024-10-17 17:47 wsk
+ */
+public interface DigestLogException {
+
+ /**
+ * 获取错误码
+ *
+ * @return
+ */
+ String getTagErrorCode();
+
+ /**
+ * 获取错误详情
+ *
+ * @return
+ */
+ String getTagErrorMsg();
+}
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/ElectromagneticBizRuntimeException.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/ElectromagneticBizRuntimeException.java
new file mode 100644
index 0000000..b13ec2e
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/ElectromagneticBizRuntimeException.java
@@ -0,0 +1,71 @@
+/**
+ * Alibaba.com Inc. Copyright (c) 2004-2021 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.exception;
+
+
+import electromagnetic.data.framework.share.constants.ElectromagneticConstants;
+import electromagnetic.data.framework.share.enums.ElectromagneticSceneIncidentEnum;
+import electromagnetic.data.framework.share.enums.ErrorEnum;
+import electromagnetic.data.framework.share.enums.ResultCodeEnum;
+
+/**
+ * @version v 0.1
+ */
+
+public class ElectromagneticBizRuntimeException extends BizRuntimeException {
+
+
+ private static final long serialVersionUID = -1395535251101232205L;
+
+ public static ElectromagneticBizRuntimeException of(ElectromagneticSceneIncidentEnum incident, ErrorEnum error){
+ String errorCode = ElectromagneticConstants.PREFIX_CODE+error.getCodeLevel()+error.getCodeType()+ ElectromagneticConstants.CODE +incident.getCode() + error.getCode();
+ String message = error.getErrorDesc();
+ return new ElectromagneticBizRuntimeException(errorCode, message);
+ }
+
+ public static ElectromagneticBizRuntimeException of(ElectromagneticSceneIncidentEnum incident, ErrorEnum error, Throwable cause){
+ String errorCode = ElectromagneticConstants.PREFIX_CODE+error.getCodeLevel()+error.getCodeType()+ ElectromagneticConstants.CODE +incident.getCode() + error.getCode();
+ String message = error.getErrorDesc();
+ return new ElectromagneticBizRuntimeException(errorCode, message, cause);
+ }
+
+
+ public static ElectromagneticBizRuntimeException of(ElectromagneticSceneIncidentEnum incident, ErrorEnum error, String extendMsg){
+ String errorCode = ElectromagneticConstants.PREFIX_CODE+error.getCodeLevel()+error.getCodeType()+ ElectromagneticConstants.CODE +incident.getCode() + error.getCode();
+ String message = error.getErrorDesc() +"@"+ extendMsg;
+ return new ElectromagneticBizRuntimeException(errorCode, message);
+ }
+
+
+
+ public static ElectromagneticBizRuntimeException of(ElectromagneticSceneIncidentEnum incident, ResultCodeEnum error){
+ String errorCode = error.getResultCode(ElectromagneticConstants.CODE +incident.getCode());
+ String message = error.getResultMsg();
+ return new ElectromagneticBizRuntimeException(errorCode, message);
+ }
+
+ public static ElectromagneticBizRuntimeException of(ElectromagneticSceneIncidentEnum incident, ResultCodeEnum error, Throwable cause){
+ String errorCode = error.getResultCode(ElectromagneticConstants.CODE +incident.getCode());
+ String message = error.getResultMsg();
+ return new ElectromagneticBizRuntimeException(errorCode, message, cause);
+ }
+
+
+ public static ElectromagneticBizRuntimeException of(ElectromagneticSceneIncidentEnum incident, ResultCodeEnum error, String extendMsg){
+ String errorCode = error.getResultCode(ElectromagneticConstants.CODE +incident.getCode());
+ String message = error.getResultMsg() +"@"+ extendMsg;
+ return new ElectromagneticBizRuntimeException(errorCode, message);
+ }
+
+
+
+ private ElectromagneticBizRuntimeException(String errorCode, String errorMsg){
+ super(errorCode, errorMsg);
+ }
+
+ private ElectromagneticBizRuntimeException(String errorCode, String message, Throwable cause) {
+ super(errorCode,message, cause);
+ }
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/IllegalParameterException.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/IllegalParameterException.java
new file mode 100644
index 0000000..551f375
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/IllegalParameterException.java
@@ -0,0 +1,23 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.exception;
+
+/**
+ * 非法参数异常扩展
+ * @author wsk
+ * @version $Id: IllegalParameterException.java, v 0.1 2024-10-20 19:02 wsk
+ */
+public class IllegalParameterException extends BizRuntimeException {
+
+ private static final long serialVersionUID = -469578593324154948L;
+
+ public IllegalParameterException(String message) {
+ super("ILLEGAL_PARAM", message);
+ }
+
+ public IllegalParameterException(String message, Throwable cause) {
+ super("ILLEGAL_PARAM", message, cause);
+ }
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/LoggerConstant.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/LoggerConstant.java
new file mode 100644
index 0000000..cb75565
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/exception/LoggerConstant.java
@@ -0,0 +1,46 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.exception;
+
+/**
+ * @author wsk
+ * @version $Id: LoggerConstant.java, v 0.1 2024-10-18 18:04 wsk
+ */
+public class LoggerConstant {
+
+ /**
+ * 异步任务日志
+ */
+ public static final String TASK_SCHEDULER_LOG = "TASK-SCHEDULER";
+
+ /**
+ * 消息监听日志
+ */
+ public static final String MSG_LISTEN = "MSG-LISTEN";
+
+ /**
+ * 严重告警日志
+ */
+ public static final String SERIOUS_ALERT = "SERIOUS-ALERT";
+
+ /**
+ * 业务日志
+ */
+ public static final String DOMAIN_SERVICE = "DOMAIN-SERVICE";
+
+ /**
+ * 业务失败日志
+ */
+ public static final String DOMAIN_ERROR = "DOMAIN-ERROR";
+
+ /**
+ * 业务摘要日志
+ */
+ public static final String DOMAIN_DIGEST = "DOMAIN-DIGEST";
+
+ /**
+ * 调用外部系统日志
+ */
+ public static final String INTEGRATION = "INTEGRATION";
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/id/IdWorker.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/id/IdWorker.java
new file mode 100644
index 0000000..ac842ca
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/id/IdWorker.java
@@ -0,0 +1,161 @@
+/**
+ * Copyright (c) 2004-2022 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.id;
+
+import java.lang.management.ManagementFactory;
+import java.net.InetAddress;
+import java.net.NetworkInterface;
+
+/**
+ * @author wsk
+ * @version $Id: IdWorker.java, v 0.1 2022-06-20 16:41 wsk.pt Exp $$
+ */
+public class IdWorker {
+
+ private static IdWorker idWorker=new IdWorker();
+
+ // 时间起始标记点，作为基准，一般取系统的最近时间（一旦确定不能变动）
+ private final static long twepoch = 1288834974657L;
+ // 机器标识位数
+ private final static long workerIdBits = 5L;
+ // 数据中心标识位数
+ private final static long datacenterIdBits = 5L;
+ // 机器ID最大值
+ private final static long maxWorkerId = -1L ^ (-1L << workerIdBits);
+ // 数据中心ID最大值
+ private final static long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);
+ // 毫秒内自增位
+ private final static long sequenceBits = 12L;
+ // 机器ID偏左移12位
+ private final static long workerIdShift = sequenceBits;
+ // 数据中心ID左移17位
+ private final static long datacenterIdShift = sequenceBits + workerIdBits;
+ // 时间毫秒左移22位
+ private final static long timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits;
+
+ private final static long sequenceMask = -1L ^ (-1L << sequenceBits);
+ /* 上次生产id时间戳 */
+ private static long lastTimestamp = -1L;
+ // 0，并发控制
+ private long sequence = 0L;
+
+ private final long workerId;
+ // 数据标识id部分
+ private final long datacenterId;
+
+ public IdWorker(){
+ this.datacenterId = getDatacenterId(maxDatacenterId);
+ this.workerId = getMaxWorkerId(datacenterId, maxWorkerId);
+ }
+ /**
+ * @param workerId
+ * 工作机器ID
+ * @param datacenterId
+ * 序列号
+ */
+ public IdWorker(long workerId, long datacenterId) {
+ if (workerId > maxWorkerId || workerId < 0) {
+ throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId));
+ }
+ if (datacenterId > maxDatacenterId || datacenterId < 0) {
+ throw new IllegalArgumentException(String.format("datacenter Id can't be greater than %d or less than 0", maxDatacenterId));
+ }
+ this.workerId = workerId;
+ this.datacenterId = datacenterId;
+ }
+ /**
+ * 获取下一个ID
+ *
+ * @return
+ */
+ public synchronized long nextId() {
+ long timestamp = timeGen();
+ if (timestamp < lastTimestamp) {
+ throw new RuntimeException(String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", lastTimestamp - timestamp));
+ }
+
+ if (lastTimestamp == timestamp) {
+ // 当前毫秒内，则+1
+ sequence = (sequence + 1) & sequenceMask;
+ if (sequence == 0) {
+ // 当前毫秒内计数满了，则等待下一秒
+ timestamp = tilNextMillis(lastTimestamp);
+ }
+ } else {
+ sequence = 0L;
+ }
+ lastTimestamp = timestamp;
+ // ID偏移组合生成最终的ID，并返回ID
+ long nextId = ((timestamp - twepoch) << timestampLeftShift)
+ | (datacenterId << datacenterIdShift)
+ | (workerId << workerIdShift) | sequence;
+
+ return nextId;
+ }
+
+ private long tilNextMillis(final long lastTimestamp) {
+ long timestamp = this.timeGen();
+ while (timestamp <= lastTimestamp) {
+ timestamp = this.timeGen();
+ }
+ return timestamp;
+ }
+
+ private long timeGen() {
+ return System.currentTimeMillis();
+ }
+
+ /**
+ *
+ * 获取 maxWorkerId
+ *
+ */
+ protected static long getMaxWorkerId(long datacenterId, long maxWorkerId) {
+ StringBuffer mpid = new StringBuffer();
+ mpid.append(datacenterId);
+ String name = ManagementFactory.getRuntimeMXBean().getName();
+ if (!name.isEmpty()) {
+ /*
+ * GET jvmPid
+ */
+ mpid.append(name.split("@")[0]);
+ }
+ /*
+ * MAC + PID 的 hashcode 获取16个低位
+ */
+ return (mpid.toString().hashCode() & 0xffff) % (maxWorkerId + 1);
+ }
+
+ /**
+ *
+ * 数据标识id部分
+ *
+ */
+ protected static long getDatacenterId(long maxDatacenterId) {
+ long id = 0L;
+ try {
+ InetAddress ip = InetAddress.getLocalHost();
+ NetworkInterface network = NetworkInterface.getByInetAddress(ip);
+ if (network == null) {
+ id = 1L;
+ } else {
+ byte[] mac = network.getHardwareAddress();
+ id = ((0x000000FF & (long) mac[mac.length - 1])
+ | (0x0000FF00 & (((long) mac[mac.length - 2]) << 8))) >> 6;
+ id = id % (maxDatacenterId + 1);
+ }
+ } catch (Exception e) {
+ System.out.println(" getDatacenterId: " + e.getMessage());
+ }
+ return id;
+ }
+ public static long getSnowFlakeId(){
+ return idWorker.nextId();
+ }
+
+ public static String getSnowFlakeIdString(){
+ return String.valueOf(getSnowFlakeId());
+ }
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/DateUtil.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/DateUtil.java
new file mode 100644
index 0000000..3dfb6a9
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/DateUtil.java
@@ -0,0 +1,330 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.log;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.TimeZone;
+
+/**
+ * @author wsk
+ * @version $Id: DateUtil.java, v 0.1 2024-10-20 18:45 wsk
+ */
+public class DateUtil {
+ /** 日志 */
+ private final static Logger logger = LoggerFactory.getLogger(DateUtil.class);
+
+ /** yyyy-MM-dd */
+ public static String DATE_FORMAT_001 = "yyyy-MM-dd";
+
+ /** yyyyMMdd */
+ public static String DATE_FORMAT_002 = "yyyyMMdd";
+
+ /** yyyy-MM-dd HH:mm:ss */
+ public static String DATE_FORMAT_003 = "yyyy-MM-dd HH:mm:ss";
+
+ /** yyyy-MM-dd HH:mm:ss.S */
+ public static String DATE_FORMAT_004 = "yyyy-MM-dd HH:mm:ss.S";
+
+ /** yyyy-MM-dd'T'HH:mm:ssZ */
+ public static String DATE_FORMAT_005 = "yyyy-MM-dd'T'HH:mm:ssZ";
+
+ /** yyyy-MM-dd'T'HH:mm:ss */
+ public static String DATE_FORMAT_006 = "yyyy-MM-dd'T'HH:mm:ss";
+
+ /** yyyy-MM-dd'T'HH:mm:ss */
+ public static String DATE_FORMAT_007 = "HHmmss";
+
+ /** yyyy-MM-dd'T'HH:mm:ss */
+ public static String DATE_FORMAT_008 = "HHmm";
+
+ /**
+ * 不允许实例化
+ */
+ private DateUtil() {
+ //forbidden
+ }
+
+ /**
+ * 按照指定的格式，格式化时间
+ *
+ * @param srcDate 需要转换的date
+ * @param format 指定的格式
+ * @return 具有format格式的date，是一个new Date
+ * @throws ParseException 转换出错
+ */
+ public static Date format(Date srcDate, String format) {
+
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(format);
+
+ //格式化
+ String dateStr = simpleDateFormat.format(srcDate);
+
+ return parse(dateStr, format);
+
+ }
+
+ /**
+ * 返回yyyyMMdd
+ * @param srcDate
+ * @return
+ */
+ public static String formatDate(Date srcDate) {
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(DATE_FORMAT_002);
+ return simpleDateFormat.format(srcDate);
+ }
+
+ /**
+ * 获取日期 指定格式的字符串
+ *
+ * @param date 日期
+ * @param format 格式
+ * @return
+ */
+ public static String getFormatDate(Date date, String format) {
+ SimpleDateFormat formate = null;
+ if (null == format) {
+ formate = new SimpleDateFormat(DATE_FORMAT_003);
+ } else {
+ formate = new SimpleDateFormat(format);
+ }
+ return formate.format(date);
+ }
+
+ /**
+ * 返回
+ * @param srcDate
+ * @return
+ */
+ public static String formatTime(Date srcDate) {
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(DATE_FORMAT_007);
+ return simpleDateFormat.format(srcDate);
+ }
+
+ /**
+ * 根据字符串和指定的格式，返回期望格式的时间
+ *
+ * @param dateStr 日期字符串
+ * @param format 输入的格式
+ * @return 具有format格式的date，是一个new Date
+ * @throws RuntimeException 格式转换出错
+ */
+ public static Date parse(String dateStr, String format) {
+
+ SimpleDateFormat formater = new SimpleDateFormat(format);
+
+ try {
+ return formater.parse(dateStr);
+ } catch (ParseException e) {
+ LogUtils.error(logger,"日期string转换Date失败，日期={0},format={1}",dateStr,format);
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 按分钟偏移,根据{@code source}得到{@code minute}分钟之后的日期
+ *
+ * @param source
+ * , 要求非空
+ * @param minute
+ * , 分钟数,可以为负
+ * @return 新创建的Date对象
+ * @throws 如果source为null, 会抛出IllegalArgumentException异常
+ * @author xueye.duanxy
+ */
+ public static Date addMinutes(Date source, int minute) {
+ return addDate(source, Calendar.MINUTE, minute);
+ }
+
+ /**
+ * 在指定时间后，加上指定的秒数
+ *
+ * @param srcDate
+ * @param secs
+ * @return
+ */
+ public static Date addSeconds(Date srcDate, long secs) {
+ return new Date(srcDate.getTime() + (secs * 1000));
+ }
+
+ /**
+ * 获取第period天凌晨时间
+ * @return
+ */
+ public static Date getTheNextMorningTime(int period) {
+ return getTime(Calendar.DATE, period);
+ }
+
+ /**
+ * 根据calendarUnit获取凌晨时间
+ * @param calendarUnit
+ * @param period
+ * @return
+ */
+ private static Date getTime(int calendarUnit, int period) {
+ if (period <= 0) {
+ throw new RuntimeException("period <= 0");
+ }
+ Calendar calendar = Calendar.getInstance();
+ calendar.add(calendarUnit, period);
+
+ Date date = calendar.getTime();
+ SimpleDateFormat formatter = new SimpleDateFormat(DATE_FORMAT_001);
+ String dateString = formatter.format(date);
+
+ Date ret = null;
+ try {
+ ret = formatter.parse(dateString);
+ } catch (ParseException e) {
+ throw new RuntimeException(e);
+ }
+
+ return ret;
+ }
+
+ /**
+ * 比较字符串时间
+ *
+ * @param date1
+ * @param date2
+ * @param format
+ * @return
+ */
+ public static int compareDate(String date1, String date2, String format) {
+ return parse(date1, format).compareTo(parse(date2, format));
+ }
+
+ /**
+ * 获取本周指定星期天数
+ * 如获取本周星期一：getDateOfThisWeek(new Date(), Calendar.MONDAY)
+ *
+ * @param date
+ * @param dayOfWeek {@link Calendar#DAY_OF_WEEK}
+ * @return
+ */
+ public static Date getDateOfThisWeek(Date date, int dayOfWeek) {
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(date);
+
+ // 获得当前日期是一个星期的第几天
+ int currentDayOfWeek = cal.get(Calendar.DAY_OF_WEEK);
+
+ // 查找日期等于当前日期，直接返回
+ if (currentDayOfWeek == dayOfWeek) {
+ return cal.getTime();
+ }
+
+ // 临界点,如果当前时间为星期天，先跳到本周六，然后减去 (7-dayOfWeek) 天
+ if (Calendar.SUNDAY == currentDayOfWeek) {
+ cal.add(Calendar.DAY_OF_MONTH, -1);
+ currentDayOfWeek = cal.get(Calendar.DAY_OF_WEEK);
+ }
+
+ // 临界点,如果要查找的时间为星期天，先跳到下周这个时刻，然后减去 (7-dayOfWeek) 天
+ if (Calendar.SUNDAY == dayOfWeek) {
+ cal.add(Calendar.DAY_OF_MONTH, 7);
+ currentDayOfWeek = cal.get(Calendar.DAY_OF_WEEK);
+ }
+
+ // 根据要获取的星期值 - 当前星期值的差值计算需要获取的日期
+ cal.add(Calendar.DATE, dayOfWeek - currentDayOfWeek);
+ return cal.getTime();
+ }
+
+ /**
+ * 获取下周指定星期天数
+ *
+ * @param date
+ * @param dayOfWeek
+ * @return
+ */
+ public static Date getDateOfNextWeek(Date date, int dayOfWeek) {
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(getDateOfThisWeek(date, dayOfWeek));
+ cal.add(Calendar.DATE, 7);
+ return cal.getTime();
+ }
+
+ /**
+ * 获取上周指定星期天数
+ *
+ * @param date
+ * @param dayOfWeek
+ * @return
+ */
+ public static Date getDateOfLastWeek(Date date, int dayOfWeek) {
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(getDateOfThisWeek(date, dayOfWeek));
+ cal.add(Calendar.DATE, -7);
+ return cal.getTime();
+ }
+
+ /**
+ * 获取指定时区的凌晨零点
+ * @param timeZoneId
+ * @return
+ */
+ public static Date getDayBegin(Date date, String timeZoneId) {
+ SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT_001);
+ sdf.setLenient(false);
+ sdf.setTimeZone(TimeZone.getTimeZone(timeZoneId));
+ String dateString = sdf.format(date);
+ try {
+ return sdf.parse(dateString);
+ } catch (ParseException e) {
+ return null;
+ }
+ }
+
+ /**
+ * 获取n天前
+ * @param days
+ * @return
+ */
+ public static Date getDaysBefore(Date date, int days) {
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(date);
+ cal.add(Calendar.DATE, - days);
+ return cal.getTime();
+ }
+
+ /**
+ * 带时区解析日期 结果为服务器时区时间
+ * @param date yyyy-MM-dd
+ * @param zoneId
+ * @return
+ */
+ public static Date parserWithZone(String date, String zoneId) {
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(DATE_FORMAT_001);
+ simpleDateFormat.setLenient(false);
+ simpleDateFormat.setTimeZone(TimeZone.getTimeZone(zoneId));
+ try {
+ return simpleDateFormat.parse(date);
+ } catch (ParseException e) {
+ return null;
+ }
+ }
+
+
+ // ---------------------------------------- Private 函数 ------------------------------------------
+
+ /**
+ * Add Date并且返回一个新的日历对象
+ */
+ private static Date addDate(Date date, int calendarField, int amount) {
+ if (date == null) {
+ throw new IllegalArgumentException("The date must not be null");
+ }
+
+ Calendar c = Calendar.getInstance();
+ c.setTime(date);
+ c.add(calendarField, amount);
+ return c.getTime();
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/DigestValue.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/DigestValue.java
new file mode 100644
index 0000000..8e31fce
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/DigestValue.java
@@ -0,0 +1,30 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.log;
+
+import java.lang.annotation.*;
+
+/**
+ * @author wsk
+ * @version $Id: DigestValue.java, v 0.1 2024-10-20 18:47 wsk
+ */
+@Documented
+@Target({ElementType.FIELD})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface DigestValue {
+
+ /**
+ * 顺序号（默认0，表示不指定顺序，按字段顺序排序）
+ *
+ * @return
+ */
+ int value() default 0;
+
+ /**
+ * 脱敏类型
+ *
+ * @return
+ */
+ Class shieldType() default Shield.class;
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/LogDigestBaseInfo.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/LogDigestBaseInfo.java
new file mode 100644
index 0000000..21c299b
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/LogDigestBaseInfo.java
@@ -0,0 +1,157 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.log;
+
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.util.Date;
+
+/**
+ * @author wsk
+ * @version $Id: LogDigestBaseInfo.java, v 0.1 2024-10-20 18:45 wsk
+ */
+public class LogDigestBaseInfo {
+
+ /** 服务门面 */
+ private String facadeName;
+
+ /** 服务方法 */
+ private String methodName;
+
+ /** 调用方应用名 */
+ private String appName;
+
+ /** 调用方主机ip */
+ private String hostIp;
+
+ /** traceId */
+ private String traceId;
+
+ /** 服务开始时间 */
+ private final long startTime;
+
+ /**
+ * 默认构造函数
+ */
+ public LogDigestBaseInfo() {
+ this.startTime = System.currentTimeMillis();
+ }
+
+ /**
+ * @see Object#toString()
+ */
+ @Override
+ public String toString() {
+ return ToStringBuilder.reflectionToString(this, ToStringStyle.SHORT_PREFIX_STYLE);
+ }
+
+ /**
+ * 获取yyyyMMddHHmmssSSS格式的开始时间字符串
+ *
+ * @return
+ */
+ public String getStartDateFormat() {
+ return DateUtil.getFormatDate(new Date(startTime), "yyyyMMddHHmmssSSS");
+ }
+
+ /**
+ * Getter method for property facadeName.
+ *
+ * @return property value of facadeName
+ */
+ public String getFacadeName() {
+ return facadeName;
+ }
+
+ /**
+ * Setter method for property facadeName.
+ *
+ * @param facadeName value to be assigned to property facadeName
+ */
+ public void setFacadeName(String facadeName) {
+ this.facadeName = facadeName;
+ }
+
+ /**
+ * Getter method for property methodName.
+ *
+ * @return property value of methodName
+ */
+ public String getMethodName() {
+ return methodName;
+ }
+
+ /**
+ * Setter method for property methodName.
+ *
+ * @param methodName value to be assigned to property methodName
+ */
+ public void setMethodName(String methodName) {
+ this.methodName = methodName;
+ }
+
+ /**
+ * Getter method for property appName.
+ *
+ * @return property value of appName
+ */
+ public String getAppName() {
+ return appName;
+ }
+
+ /**
+ * Setter method for property appName.
+ *
+ * @param appName value to be assigned to property appName
+ */
+ public void setAppName(String appName) {
+ this.appName = appName;
+ }
+
+ /**
+ * Getter method for property hostIp.
+ *
+ * @return property value of hostIp
+ */
+ public String getHostIp() {
+ return hostIp;
+ }
+
+ /**
+ * Setter method for property hostIp.
+ *
+ * @param hostIp value to be assigned to property hostIp
+ */
+ public void setHostIp(String hostIp) {
+ this.hostIp = hostIp;
+ }
+
+ /**
+ * Getter method for property traceId.
+ *
+ * @return property value of traceId
+ */
+ public String getTraceId() {
+ return traceId;
+ }
+
+ /**
+ * Setter method for property traceId.
+ *
+ * @param traceId value to be assigned to property traceId
+ */
+ public void setTraceId(String traceId) {
+ this.traceId = traceId;
+ }
+
+ /**
+ * Getter method for property startTime.
+ *
+ * @return property value of startTime
+ */
+ public long getStartTime() {
+ return startTime;
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/LogUtils.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/LogUtils.java
new file mode 100644
index 0000000..bd3f1e4
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/LogUtils.java
@@ -0,0 +1,455 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.log;
+
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.builder.ReflectionToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+import org.apache.commons.lang3.reflect.FieldUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.lang.reflect.Field;
+import java.text.DateFormat;
+import java.text.MessageFormat;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * @author wsk
+ * @version $Id: LogUtils.java, v 0.1 2024-10-20 18:37 wsk
+ */
+@Slf4j
+public class LogUtils {
+
+ /** 资产交换报文日志 */
+ private static final Logger LOGGER = LoggerFactory.getLogger(LogUtils.class);
+
+ /** 摘要日志的内容分隔符 */
+ public static final String SEP = ",";
+
+ /** 修饰符 */
+ private static final char RIGHT_TAG = ']';
+
+ /** 修饰符 */
+ private static final char LEFT_TAG = '[';
+
+
+ /** 全日志模式 */
+ private static boolean printAllMode = false;
+
+ /** 格式化开始符号 */
+ public static final String FMT_BEGIN = "[(";
+
+ /** 格式化中间符号 */
+ public static final String FMT_MIDDLE = ")(";
+
+ /** 格式化结束符号 */
+ public static final String FMT_END = ")]";
+
+ /** 数组开始符号 */
+ public static final String ARR_BEGIN = "[";
+
+ /** 数组结束符号 */
+ public static final String ARR_END = "]";
+
+ /** 毫秒 */
+ public static final String MS = "ms";
+
+ /** 没有值时日志上以-替代 */
+ public static final String NONE = "-";
+
+ /** 逗号 */
+ public static final String COMMA = ",";
+
+ /** 点号 */
+ public static final String DOT = ".";
+
+ /** 业务成功标识 */
+ public static final String YES = "Y";
+
+ /** 业务失败标识 */
+ public static final String NO = "N";
+
+ /** 下划线 */
+ public static final String UNDERLINE = "_";
+
+ /** 未知错误 */
+ public static final String UNKNOW_ERROR = "UNKNOW_ERROR";
+
+ /** 完整日期格式 */
+ private final static String FULL_DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";
+
+ /**
+ * 屏蔽构造函数
+ */
+ private LogUtils() {}
+
+ /**
+ *
+ * 生成通知级别日志
+ *
+ *
+ * 根据带参数的日志模板和参数集合，生成info级别日志
+ * 带参数的日志模板中以{数字}表示待替换为变量的日志点，如a={0}，表示用参数集合中index为0的参数替换{0}处
+ *
+ *
+ * @param logger logger引用
+ * @param model 带参数的日志模板
+ * @param parameters 参数集合
+ */
+ public static void info(Logger logger, String model, Object... parameters) {
+ if (logger.isInfoEnabled()) {
+ logger.info(MessageFormat.format(model,parameters));
+ }
+ }
+
+ /**
+ * 打印info级别日志信息(适用于没有参数场景下)
+ *
+ * @param logger logger引用
+ * @param message 日志信息
+ */
+ public static void info(Logger logger, String message) {
+ logger.info(message);
+ }
+
+ /**
+ *
+ * 生成调试级别日志
+ *
+ *
+ * 根据带参数的日志模板和参数集合，生成debug级别日志
+ * 带参数的日志模板中以{数字}表示待替换为变量的日志点，如a={0}，表示用参数集合中index为0的参数替换{0}处
+ *
+ *
+ * @param logger logger引用
+ * @param model 带参数的日志模板
+ * @param parameters 参数集合
+ */
+ public static void debug(Logger logger, String model, Object... parameters) {
+ if (logger.isDebugEnabled()) {
+ logger.debug(MessageFormat.format(model,parameters));
+ }
+ }
+
+ /**
+ *
+ * 生成警告级别日志
+ *
+ *
+ * 根据带参数的日志模板和参数集合，生成warn级别日志
+ * 带参数的日志模板中以{数字}表示待替换为变量的日志点，如a={0}，表示用参数集合中index为0的参数替换{0}处
+ *
+ *
+ * @param logger logger引用
+ * @param model 带参数的日志模板
+ * @param parameters 参数集合
+ */
+ public static void warn(Logger logger, String model, Object... parameters) {
+ if (logger.isWarnEnabled()) {
+ logger.warn(MessageFormat.format(model,parameters));
+ }
+ }
+
+ /**
+ *
+ * 生成警告级别日志
+ *
+ *
+ * 带异常堆栈
+ *
+ *
+ * @param e
+ * @param logger
+ * @param template
+ * @param parameters
+ */
+ public static void warn(Throwable e, Logger logger, String template, Object... parameters) {
+ if (logger.isWarnEnabled()) {
+ logger.warn(MessageFormat.format(template,parameters),e);
+ }
+ }
+
+ /**
+ *
+ * 生成错误级别日志
+ *
+ *
+ * 根据带参数的日志模板和参数集合，生成error级别日志
+ * 带参数的日志模板中以{数字}表示待替换为变量的日志点，如a={0}，表示用参数集合中index为0的参数替换{0}处
+ *
+ *
+ * @param e 错误异常堆栈
+ * @param logger logger引用
+ * @param template 带参数的日志模板
+ * @param parameters 参数集合
+ */
+ public static void error(Throwable e, Logger logger, String template, Object... parameters) {
+ if (logger.isErrorEnabled()) {
+ logger.error(MessageFormat.format(template,parameters),e);
+ }
+ }
+
+ /**
+ *
+ * 生成错误级别日志
+ *
+ *
+ * 根据带参数的日志模板和参数集合，生成error级别日志
+ * 带参数的日志模板中以{数字}表示待替换为变量的日志点，如a={0}，表示用参数集合中index为0的参数替换{0}处
+ *
+ *
+ * @param logger logger引用
+ * @param model 带参数的日志模板
+ * @param parameters 参数集合
+ */
+ public static void error(Logger logger, String model, Object... parameters) {
+ if (logger.isErrorEnabled()) {
+ logger.error(MessageFormat.format(model,parameters));
+ }
+ }
+
+ /**
+ * 打印error日志。
+ *
+ * ERROR日志记录尽量使用{@link }，避免日志的重复记录
+ *
+ * @param logger 日志对象
+ * @param e 异常信息
+ * @param objs 任意个要输出到日志的参数
+ */
+ public static void error(Logger logger, Throwable e, Object... objs) {
+ logger.error(getLogString(objs), e);
+ }
+
+ /**
+ * 生成输出到日志的字符串
+ *
+ * @param objs 任意个要输出到日志的参数
+ * @return 日志字符串
+ */
+ public static String getLogString(Object... objs) {
+ StringBuilder log = new StringBuilder();
+ log.append(LEFT_TAG);
+// log.append(fetchInvokeId()).append(SEP);
+// log.append(fetchLoadTestStamp()).append(SEP);
+// log.append(fetchTntInstId()).append(SEP);
+ // 预留扩展位
+ log.append(SEP).append(RIGHT_TAG);
+
+ if (objs != null) {
+ for (Object o : objs) {
+ log.append(o);
+ }
+ }
+ return log.toString();
+ }
+
+ /**
+ * 全日志模式日志输出
+ *
+ * @param object 待输出日志对象
+ * @return 输出日志
+ */
+ public static String objectToLog(Object object) {
+ if (object == null) {
+ return null;
+ }
+
+ if (printAllMode) {
+ return ReflectionToStringBuilder.toString(object, ToStringStyle.SHORT_PREFIX_STYLE);
+ }
+
+ return object.toString();
+ }
+
+ /**
+ * 生成用于唯一标识一次业务调用流程的uuid
+ *
+ * 调用场景只有两处：
+ * 外部接口入口处
+ * 异步任务入口处
+ *
+ *
+ * @param pdSeqNo 业务流水号
+ * @return uuid
+ */
+ public static String generateBusinessFlowUUID(String pdSeqNo) {
+ return String.format("%s-%s", pdSeqNo, UUID.randomUUID().toString());
+ }
+
+
+ /**
+ * 对dal-digest日志进行格式化: [(tracerId)(dsId,call.method,Y,1ms)]
+ * @param dsId 数据源id
+ * @param method 方法
+ * @param hasError 是否有异常
+ * @param elapseTimeInMillis 时间in ms
+ * @return 格式化串
+ */
+ public static void logDALDigest(Logger logger, String dsId, String method, boolean hasError,
+ long elapseTimeInMillis, long dataSize) {
+ if (logger.isInfoEnabled()) {
+ StringBuilder sb = new StringBuilder();
+ sb.append(FMT_BEGIN);
+
+ sb.append(ifBlank(dsId)).append(COMMA).append(method).append(COMMA)
+ .append(hasError ? NO : YES).append(COMMA).append(elapseTimeInMillis).append(MS)
+ .append(COMMA).append(dataSize).append(COMMA).append(FMT_END);
+ logger.info(sb.toString());
+ }
+ }
+
+ /**
+ * 对第三方调用日志进行格式化: [(tracerId)(dsId,call.method,Y,1ms)]
+ *
+ * @param classMethod 方法
+ * @param success 是否处理成功
+ * @param errorCode 错误码
+ * @param spendTime 时间in ms
+ * @return 格式化串
+ */
+ public static void logSalDigest(Logger logger, String classMethod, boolean success, String errorCode,
+ long spendTime, String request, String result) {
+ if (logger.isInfoEnabled()) {
+ StringBuilder sb = new StringBuilder();
+ sb.append(FMT_BEGIN);
+ sb.append(ifBlank(classMethod)).append(COMMA).append(success ? "Y" : "N").append(COMMA)
+ .append(ifBlank(errorCode)).append(COMMA).append(String.valueOf(spendTime))
+ .append(COMMA).append(FMT_MIDDLE);
+
+ sb.append(ifBlank(request)).append(COMMA).append(FMT_MIDDLE);
+
+ sb.append(ifBlank(result)).append(COMMA).append(FMT_END);
+
+ logger.info(sb.toString());
+ }
+ }
+
+ /**
+ * 打印API-DIGEST日志
+ *
+ * @param baseInfo
+ * @param success
+ * @param errorCode
+ * @param spendTime
+ * @param request
+ * @param result
+ */
+ public static void logApiDigest(LogDigestBaseInfo baseInfo, boolean success, String errorCode,
+ long spendTime, String request, String result) {
+ if (LOGGER.isInfoEnabled()) {
+ StringBuilder sb = new StringBuilder();
+ sb.append(FMT_BEGIN);
+ sb.append(ifBlank(baseInfo.getTraceId())).append(FMT_MIDDLE);
+ sb.append(ifBlank(baseInfo.getFacadeName())).append(DOT)
+ .append(ifBlank(baseInfo.getMethodName()));
+ sb.append(COMMA).append(success ? "Y" : "N").append(COMMA).append(ifBlank(errorCode))
+ .append(COMMA).append(String.valueOf(spendTime));
+ sb.append(COMMA).append(ifBlank(baseInfo.getStartDateFormat())).append(COMMA)
+ .append(ifBlank(baseInfo.getAppName())).append(COMMA)
+ .append(ifBlank(baseInfo.getHostIp())).append(COMMA).append(FMT_MIDDLE);
+
+ sb.append(ifBlank(request)).append(COMMA).append(FMT_MIDDLE);
+
+ sb.append(ifBlank(result)).append(COMMA).append(FMT_END);
+
+ LOGGER.info(sb.toString());
+ }
+ }
+
+ /**
+ * 入参为null或者空串时,返回"-",否则返回自身
+ *
+ * @param value 入参字符串
+ * @return 入参为null或者空串时, 返回"-",否则返回自身
+ */
+ private static String ifBlank(String value) {
+ return StringUtils.isBlank(value) ? NONE : value;
+ }
+
+ /**
+ * 获取摘要日志
+ *
+ * @return
+ */
+ public static String getDigestLog(Object obj) {
+ if (null == obj) {
+ return NONE;
+ }
+
+ List> digestValueList = Lists.newArrayList();
+
+ Collections.sort(retrieveDigestValues(obj, obj.getClass(), digestValueList), DIGEST_VALUE_SORTER);
+
+ Object[] digestValues = new Object[digestValueList.size()];
+ int i = 0;
+ for (Map.Entry digestValue : digestValueList) {
+ digestValues[i++] = digestValue.getKey();
+ }
+
+ return getDigestLog(digestValues);
+ }
+
+ /**
+ * 按"yyyy-MM-dd hh:mm:ss"的格式输出日期
+ *
+ * @param date 日期对象
+ * @return 格式化后的字符串
+ */
+ public static String toFullDateString(Date date) {
+ if (null == date) {
+ return null;
+ }
+
+ DateFormat df = new SimpleDateFormat(FULL_DATE_FORMAT);
+ df.setLenient(false);
+ return df.format(date);
+ }
+
+ /**
+ * 获取摘要日志
+ *
+ * @return
+ */
+ private static List> retrieveDigestValues(Object obj, Class clazz,
+ final List> digestValueList) {
+
+ if (null == obj || clazz == null || clazz == Object.class) {
+ return digestValueList;
+ }
+
+ for (Field field : clazz.getDeclaredFields()) {
+ DigestValue digestValueAnnotation = field.getAnnotation(DigestValue.class);
+ if (digestValueAnnotation != null) {
+ try {
+ digestValueList.add(Maps.immutableEntry(ShieldUtil.shieldByType(digestValueAnnotation.shieldType(),
+ FieldUtils.readField(field, obj, true)),
+ digestValueAnnotation.value()));
+ } catch (IllegalAccessException ex) {
+ LogUtils.error(LOGGER, ex, "摘要字段值获取失败，field:{0}", field.toString());
+ }
+ }
+ }
+
+ // 获取父类定义的摘要字段
+ return retrieveDigestValues(obj, clazz.getSuperclass(), digestValueList);
+ }
+
+ /**
+ * 摘要值排序器
+ */
+ private static final Comparator> DIGEST_VALUE_SORTER = new Comparator>() {
+
+ @Override
+ public int compare(Map.Entry o1, Map.Entry o2) {
+
+ return o1.getValue().compareTo(o2.getValue());
+ }
+ };
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/ServiceResultHandleUtil.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/ServiceResultHandleUtil.java
new file mode 100644
index 0000000..3b00e67
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/ServiceResultHandleUtil.java
@@ -0,0 +1,102 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.log;
+
+import electromagnetic.data.framework.share.common.ParamsConstants;
+import electromagnetic.data.framework.share.enums.ElectromagneticCommonErrorEnum;
+import electromagnetic.data.framework.share.enums.ElectromagneticSceneIncidentEnum;
+import electromagnetic.data.framework.share.exception.BizRuntimeException;
+import electromagnetic.data.framework.share.exception.ElectromagneticBizRuntimeException;
+import electromagnetic.data.framework.share.model.ElectromagneticPaginationResult;
+import electromagnetic.data.framework.share.model.ElectromagneticResult;
+import electromagnetic.data.framework.share.model.PageModel;
+import electromagnetic.data.framework.share.result.CallbackResult;
+import electromagnetic.data.framework.share.exception.IllegalParameterException;
+
+import javax.xml.bind.ValidationException;
+import java.util.Optional;
+
+/**
+ * @author wsk
+ * @version $Id: ServiceResultHandleUtil.java, v 0.1 2024-10-20 19:01 wsk
+ */
+public class ServiceResultHandleUtil {
+
+ public static ElectromagneticResult serviceError(Throwable t) {
+ ElectromagneticResult result = new ElectromagneticResult<>();
+ result.setSuccess(Boolean.FALSE);
+ if (t instanceof ValidationException) {
+ result.setErrorCode(ElectromagneticBizRuntimeException.of(ElectromagneticSceneIncidentEnum.GENERAL_ILLEGAL_PARAMS, ElectromagneticCommonErrorEnum.ILLEGAL_PARAMS).getErrorCode());
+ result.setErrorMessage(t.getCause().getMessage());
+ } else if (t instanceof IllegalParameterException) {
+ result.setErrorCode(ElectromagneticBizRuntimeException.of(ElectromagneticSceneIncidentEnum.GENERAL_ILLEGAL_PARAMS, ElectromagneticCommonErrorEnum.ILLEGAL_PARAMS).getErrorCode());
+ result.setErrorMessage(ElectromagneticCommonErrorEnum.ILLEGAL_PARAMS.getErrorDesc() + "@" + t.getLocalizedMessage());
+ } else if (t instanceof BizRuntimeException) {
+ result.setErrorCode(((BizRuntimeException) t).getErrorCode());
+ result.setErrorMessage((t).getMessage());
+ } else {
+ result.setErrorCode(ElectromagneticBizRuntimeException.of(ElectromagneticSceneIncidentEnum.GENERAL_SYSTEM_ERROR, ElectromagneticCommonErrorEnum.SYSTEM_ERROR).getErrorCode());
+ result.setErrorMessage(ElectromagneticCommonErrorEnum.SYSTEM_ERROR.getErrorDesc() + "@" + t.getLocalizedMessage());
+ }
+ return result;
+ }
+
+ public static ElectromagneticPaginationResult servicePageError(Throwable t) {
+ ElectromagneticPaginationResult result = new ElectromagneticPaginationResult<>();
+ result.setSuccess(Boolean.FALSE);
+ result.setPageIndex(ParamsConstants.NUM_ONE);
+ result.setPageSize(ParamsConstants.NUM_ONE);
+ result.setTotalCount(ParamsConstants.NUM_ONE);
+ if (t instanceof IllegalParameterException) {
+ result.setErrorCode(ElectromagneticBizRuntimeException.of(ElectromagneticSceneIncidentEnum.GENERAL_ILLEGAL_PARAMS, ElectromagneticCommonErrorEnum.ILLEGAL_PARAMS).getErrorCode());
+ result.setErrorMessage(ElectromagneticCommonErrorEnum.ILLEGAL_PARAMS.getErrorDesc() + "@" + t.getLocalizedMessage());
+ } else if (t instanceof BizRuntimeException) {
+ result.setErrorCode(((BizRuntimeException) t).getErrorCode());
+ result.setErrorMessage((t).getMessage());
+ } else {
+ result.setErrorCode(ElectromagneticBizRuntimeException.of(ElectromagneticSceneIncidentEnum.GENERAL_SYSTEM_ERROR, ElectromagneticCommonErrorEnum.SYSTEM_ERROR).getErrorCode());
+ result.setErrorMessage(ElectromagneticCommonErrorEnum.SYSTEM_ERROR.getErrorDesc() + "@" + t.getLocalizedMessage());
+ }
+ return result;
+ }
+
+
+ public static ElectromagneticResult convertDomainResult2ServiceResult(CallbackResult domainResult) {
+ ElectromagneticResult serviceResult = new ElectromagneticResult<>();
+ serviceResult.setData(domainResult.getBusinessObject());
+ serviceResult.setSuccess(domainResult.isSuccess());
+ serviceResult.setErrorCode(domainResult.getResultCode());
+ serviceResult.setErrorMessage(domainResult.getResultMessage());
+ return serviceResult;
+ }
+
+ public static ElectromagneticPaginationResult convertDomainResult2ServicePageResult(CallbackResult> domainResult) {
+ ElectromagneticPaginationResult serviceResult = new ElectromagneticPaginationResult<>();
+ serviceResult.setSuccess(domainResult.isSuccess());
+ if (domainResult.getBusinessObject() != null) {
+ Optional.ofNullable(domainResult.getBusinessObject()).ifPresent(v -> serviceResult.setData(v.getModel()));
+ Optional.ofNullable(domainResult.getBusinessObject()).ifPresent(v -> serviceResult.setPageIndex((v.getPageIndex())));
+ Optional.ofNullable(domainResult.getBusinessObject()).ifPresent(v -> serviceResult.setPageSize((v.getPageSize())));
+ Optional.ofNullable(domainResult.getBusinessObject()).ifPresent(v -> serviceResult.setTotalCount((v.getTotalCount())));
+ } else {
+ serviceResult.setPageIndex(1);
+ serviceResult.setTotalCount(0);
+ serviceResult.setPageSize(10);
+
+ }
+ serviceResult.setErrorCode(domainResult.getResultCode());
+ serviceResult.setErrorMessage(domainResult.getResultMessage());
+ return serviceResult;
+ }
+
+
+ public static ElectromagneticResult convertDomainPageResult2ServiceResult(CallbackResult> domainResult) {
+ ElectromagneticResult serviceResult = new ElectromagneticResult<>();
+ serviceResult.setSuccess(domainResult.isSuccess());
+ Optional.ofNullable(domainResult.getBusinessObject()).ifPresent(v -> serviceResult.setData(v.getModel()));
+ serviceResult.setErrorCode(domainResult.getResultCode());
+ serviceResult.setErrorMessage(domainResult.getResultMessage());
+ return serviceResult;
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/Shield.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/Shield.java
new file mode 100644
index 0000000..309ce26
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/Shield.java
@@ -0,0 +1,31 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.log;
+
+/**
+ * 屏蔽器接口
+ * @author wsk
+ * @version $Id: Shield.java, v 0.1 2024-10-20 18:47 wsk
+ */
+public interface Shield {
+
+ /**
+ * 隐藏符
+ */
+ public static final char SHIELD_CHAR = '*';
+
+ /**
+ * 隐藏敏感信息
+ *
+ * @param fieldValue 需要屏蔽的值，一般是字符串
+ * @return
+ */
+ public String shield(Object fieldValue, String[] addition);
+
+ /**
+ * 是否返回空串
+ * @return
+ */
+ public boolean isClean();
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/ShieldUtil.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/ShieldUtil.java
new file mode 100644
index 0000000..d6ba1f1
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/log/ShieldUtil.java
@@ -0,0 +1,37 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.log;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * @author wsk
+ * @version $Id: ShieldUtil.java, v 0.1 2024-10-20 18:48 wsk
+ */
+public class ShieldUtil {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(ShieldUtil.class);
+ /**
+ * 按指定类型进行脱敏
+ *
+ * @param type
+ * @param data
+ * @return
+ */
+ public static final Object shieldByType(Class type, Object data) {
+ try {
+ if (type == Shield.class || data == null || type.isInterface()) {
+ return data;
+ }
+
+ Shield shield = type.getDeclaredConstructor().newInstance();
+ return shield.shield(data, null);
+ } catch (Exception e) {
+ LOGGER.error("脱敏类型配置错误，无法创建实例！" + type.getName(), e);
+ }
+
+ return data;
+ }
+}
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/BaseRequest.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/BaseRequest.java
new file mode 100644
index 0000000..5b2b098
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/BaseRequest.java
@@ -0,0 +1,56 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.model;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author wsk
+ * @version $Id: BaseRequest.java, v 0.1 2024-10-18 18:46 wsk
+ */
+@Data
+public class BaseRequest implements Serializable {
+
+ private static final long serialVersionUID = -9017146892952264211L;
+
+ /**
+ * 操作用户id
+ */
+ private String userId;
+
+ /**
+ * 用户部门
+ */
+ private String department;
+
+ /**
+ * 用户名
+ */
+ private String userName;
+
+ /**
+ * 调用服务ip
+ */
+ private String ip;
+
+ /**
+ * 调用服务app name
+ */
+ private String appName;
+ /**
+ *人员编码
+ */
+ private String personNo;
+ /**
+ *人员姓名
+ */
+ private String personName;
+ /**
+ * 权限码
+ */
+ private String permissionCode;
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticPaginationInfo.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticPaginationInfo.java
new file mode 100644
index 0000000..71b2816
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticPaginationInfo.java
@@ -0,0 +1,145 @@
+/**
+ * Copyright (c) 2004-2020 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.model;
+
+/**
+ * 分页对象
+ *
+ * @author
+ * @version $Id: DataplatformPaginationInfo.java, v 0.1 2020-12-25 16:54 Exp $$
+ */
+public class ElectromagneticPaginationInfo {
+ /**
+ * 数据对象传给前台的json
+ */
+ private T data;
+ /**
+ * 当前页数
+ */
+ private Integer pageIndex;
+ /**
+ * 每页显示多少记录数
+ */
+ private Integer PageSize;
+ /**
+ * 总记录数量
+ */
+ private Integer pageTotal;
+
+ /**
+ * 总页数
+ */
+ private Integer PageCount;
+
+ public ElectromagneticPaginationInfo(T data, Integer pageIndex, Integer pageSize, Integer pageTotal, Integer pageCount) {
+ this.data = data;
+ this.pageIndex = pageIndex;
+ PageSize = pageSize;
+ this.pageTotal = pageTotal;
+ PageCount = pageCount;
+ }
+
+ public ElectromagneticPaginationInfo() {
+ }
+
+ /**
+ * Getter method for property data.
+ *
+ * @return property value of data
+ */
+ public T getData() {
+ return data;
+ }
+
+ /**
+ * Setter method for property data.
+ *
+ * @param data value to be assigned to property data
+ */
+ public void setData(T data) {
+ this.data = data;
+ }
+
+ /**
+ * Getter method for property pageIndex.
+ *
+ * @return property value of pageIndex
+ */
+ public Integer getPageIndex() {
+ return pageIndex;
+ }
+
+ /**
+ * Setter method for property pageIndex.
+ *
+ * @param pageIndex value to be assigned to property pageIndex
+ */
+ public void setPageIndex(Integer pageIndex) {
+ this.pageIndex = pageIndex;
+ }
+
+ /**
+ * Getter method for property PageSize.
+ *
+ * @return property value of PageSize
+ */
+ public Integer getPageSize() {
+ return PageSize;
+ }
+
+ /**
+ * Setter method for property PageSize.
+ *
+ * @param pageSize value to be assigned to property PageSize
+ */
+ public void setPageSize(Integer pageSize) {
+ PageSize = pageSize;
+ }
+
+ /**
+ * Getter method for property pageTotal.
+ *
+ * @return property value of pageTotal
+ */
+ public Integer getPageTotal() {
+ return pageTotal;
+ }
+
+ /**
+ * Setter method for property pageTotal.
+ *
+ * @param pageTotal value to be assigned to property pageTotal
+ */
+ public void setPageTotal(Integer pageTotal) {
+ this.pageTotal = pageTotal;
+ }
+
+ /**
+ * Getter method for property PageCount.
+ *
+ * @return property value of PageCount
+ */
+ public Integer getPageCount() {
+ return PageCount;
+ }
+
+ /**
+ * Setter method for property PageCount.
+ *
+ * @param pageCount value to be assigned to property PageCount
+ */
+ public void setPageCount(Integer pageCount) {
+ PageCount = pageCount;
+ }
+ @Override
+ public String toString() {
+ return "PaginationInfo{" +
+ "data=" + data +
+ ", pageIndex=" + pageIndex +
+ ", PageSize=" + PageSize +
+ ", pageTotal=" + pageTotal +
+ ", PageCount=" + PageCount +
+ '}';
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticPaginationResult.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticPaginationResult.java
new file mode 100644
index 0000000..1613b2a
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticPaginationResult.java
@@ -0,0 +1,193 @@
+/**
+ * Alibaba.com Inc. Copyright (c) 2004-2020 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.model;
+
+import electromagnetic.data.framework.share.result.Message;
+import electromagnetic.data.framework.share.result.ResultModel;
+
+import java.io.Serializable;
+
+/**
+ * 封装返回给前台数据(含分页)
+ * @author
+ * @version v 0.1
+ * @Date 2020-12-25 15:03
+ */
+
+
+public class ElectromagneticPaginationResult implements Serializable, ResultModel {
+
+ private static final long serialVersionUID = 2918761644445008514L;
+
+ /**
+ * 请求成功还是失败
+ */
+ private Boolean success;
+
+ private String errorCode;
+
+ private String errorMessage;
+
+ private Integer totalCount;
+
+ private Integer pageIndex;
+
+ private Integer pageSize;
+
+ /**
+ * 数据对象传给前台的json
+ */
+ private T data;
+
+ public ElectromagneticPaginationResult() {
+ }
+
+ public ElectromagneticPaginationResult(Boolean success, String errorCode, String errorMessage, Integer totalCount,
+ Integer pageIndex, Integer pageSize, T data) {
+ this.success = success;
+ this.errorCode = errorCode;
+ this.errorMessage = errorMessage;
+ this.totalCount = totalCount;
+ this.pageIndex = pageIndex;
+ this.pageSize = pageSize;
+ this.data = data;
+ }
+
+ @Override
+ public T getData() {
+ return (T) data;
+ }
+
+ @Override
+ public int getPageIndex() {
+ return pageIndex;
+ }
+
+ @Override
+ public Integer getTotalCount() {
+ return totalCount;
+ }
+
+ @Override
+ public int getPageSize() {
+ return pageSize;
+ }
+
+ /**
+ * Getter method for property success.
+ *
+ * @return property value of success
+ */
+ public Boolean getSuccess() {
+ return success;
+ }
+
+ /**
+ * Setter method for property success.
+ *
+ * @param success value to be assigned to property success
+ */
+ public void setSuccess(Boolean success) {
+ this.success = success;
+ }
+
+
+ /**
+ * Setter method for property totalCount.
+ *
+ * @param totalCount value to be assigned to property totalCount
+ */
+ public void setTotalCount(Integer totalCount) {
+ this.totalCount = totalCount;
+ }
+
+ /**
+ * Setter method for property pageIndex.
+ *
+ * @param pageIndex value to be assigned to property pageIndex
+ */
+ public void setPageIndex(Integer pageIndex) {
+ this.pageIndex = pageIndex;
+ }
+
+ /**
+ * Getter method for property errorCode.
+ *
+ * @return property value of errorCode
+ */
+ public String getErrorCode() {
+ return errorCode;
+ }
+
+ /**
+ * Setter method for property errorCode.
+ *
+ * @param errorCode value to be assigned to property errorCode
+ */
+ public void setErrorCode(String errorCode) {
+ this.errorCode = errorCode;
+ }
+
+ /**
+ * Getter method for property errorMsg.
+ *
+ * @return property value of errorMsg
+ */
+ public String getErrorMessage() {
+ return errorMessage;
+ }
+
+ /**
+ * Setter method for property errorMsg.
+ *
+ * @param errorMessage value to be assigned to property errorMsg
+ */
+ public void setErrorMessage(String errorMessage) {
+ this.errorMessage = errorMessage;
+ }
+
+ /**
+ * Setter method for property pageSize.
+ *
+ * @param pageSize value to be assigned to property pageSize
+ */
+ public void setPageSize(Integer pageSize) {
+ this.pageSize = pageSize;
+ }
+
+ /**
+ * Setter method for property data.
+ *
+ * @param data value to be assigned to property data
+ */
+ public void setData(T data) {
+ this.data = data;
+ }
+
+ @Override
+ public Integer getStatus() {
+ return success ? 1 : 0;
+ }
+
+ @Override
+ public Message getMessage() {
+ Message msg = new Message(this.getErrorMessage());
+ //页面展示时，防止出现null状况
+ msg.setCode("");
+ return msg;
+ }
+
+ @Override
+ public String toString() {
+ return "PaginationResult{" +
+ "success=" + success +
+ ", errorCode='" + errorCode + '\'' +
+ ", errorMessage='" + errorMessage + '\'' +
+ ", totalCount=" + totalCount +
+ ", pageIndex=" + pageIndex +
+ ", pageSize=" + pageSize +
+ ", data=" + data +
+ '}';
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticRequest.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticRequest.java
new file mode 100644
index 0000000..846c382
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticRequest.java
@@ -0,0 +1,186 @@
+/**
+ * Alibaba.com Inc. Copyright (c) 2004-2020 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.model;
+
+import java.io.Serializable;
+
+/**
+ * 用于存储页面请求带过来的用户相关信息
+ * @author
+ * @version v 0.1
+ * @Date 2020-12-25 14:56
+ */
+
+public class ElectromagneticRequest implements Serializable {
+
+ private static final long serialVersionUID = -9017146892952264211L;
+
+ /**
+ * 操作用户id
+ */
+ private String userId;
+
+ /**
+ * 用户部门
+ */
+ private String department;
+
+ /**
+ * 用户名
+ */
+ private String userName;
+
+ /**
+ * 调用服务ip
+ */
+ private String ip;
+
+ /**
+ * 调用服务app name
+ */
+ private String appName;
+ /**
+ *人员编码
+ */
+ private String personNo;
+ /**
+ *人员姓名
+ */
+ private String personName;
+ /**
+ * 權限嗎
+ */
+ private String permissionCode;
+
+
+
+
+ public ElectromagneticRequest(String userId, String department, String userName, String ip, String appName, String personNo, String personName, String permissionCode) {
+ this.userId = userId;
+ this.department = department;
+ this.userName = userName;
+ this.ip = ip;
+ this.appName = appName;
+ this.personNo = personNo;
+ this.personName = personName;
+ this.permissionCode = permissionCode;
+ }
+
+ public ElectromagneticRequest() {
+
+ }
+ public String getPersonNo() {
+ return personNo;
+ }
+
+ public void setPersonNo(String personNo) {
+ this.personNo = personNo;
+ }
+
+ public String getPersonName() {
+ return personName;
+ }
+
+ public void setPersonName(String personName) {
+ this.personName = personName;
+ }
+ /**
+ * Getter method for property userId.
+ *
+ * @return property value of userId
+ */
+ public String getUserId() {
+ return userId;
+ }
+
+ /**
+ * Setter method for property userId.
+ *
+ * @param userId value to be assigned to property userId
+ */
+ public void setUserId(String userId) {
+ this.userId = userId;
+ }
+
+ /**
+ * Getter method for property department.
+ *
+ * @return property value of department
+ */
+ public String getDepartment() {
+ return department;
+ }
+
+ /**
+ * Setter method for property department.
+ *
+ * @param department value to be assigned to property department
+ */
+ public void setDepartment(String department) {
+ this.department = department;
+ }
+
+ /**
+ * Getter method for property userName.
+ *
+ * @return property value of userName
+ */
+ public String getUserName() {
+ return userName;
+ }
+
+ /**
+ * Setter method for property userName.
+ *
+ * @param userName value to be assigned to property userName
+ */
+ public void setUserName(String userName) {
+ this.userName = userName;
+ }
+
+ /**
+ * Getter method for property ip.
+ *
+ * @return property value of ip
+ */
+ public String getIp() {
+ return ip;
+ }
+
+ /**
+ * Setter method for property ip.
+ *
+ * @param ip value to be assigned to property ip
+ */
+ public void setIp(String ip) {
+ this.ip = ip;
+ }
+
+ /**
+ * Getter method for property appName.
+ *
+ * @return property value of appName
+ */
+ public String getAppName() {
+ return appName;
+ }
+
+ /**
+ * Setter method for property appName.
+ *
+ * @param appName value to be assigned to property appName
+ */
+ public void setAppName(String appName) {
+ this.appName = appName;
+ }
+
+
+ public String getPermissionCode() {
+ return permissionCode;
+ }
+
+ public void setPermissionCode(String permissionCode) {
+ this.permissionCode = permissionCode;
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResult.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResult.java
new file mode 100644
index 0000000..b0d3637
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResult.java
@@ -0,0 +1,135 @@
+/**
+ * Copyright (c) 2004-2021 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.model;
+
+import electromagnetic.data.framework.share.result.Message;
+import electromagnetic.data.framework.share.result.Result;
+
+import java.io.Serializable;
+
+/**
+ * 封装给返回前台数据(无分页)
+ *
+ * @author
+ */
+public class ElectromagneticResult implements Serializable, Result {
+
+ private static final long serialVersionUID = -6408526187818056594L;
+ /**
+ * 请求成功还是失败
+ */
+ private Boolean success;
+
+ /**
+ * 错误码
+ */
+ private String errorCode;
+
+ /**
+ * 错误消息
+ */
+ private String errorMessage;
+
+ /**
+ * 数据对象传给前台的json
+ */
+ private T data;
+
+ public ElectromagneticResult() {
+
+ }
+
+ public ElectromagneticResult(Boolean success, String errorCode, String errorMessage, T data) {
+ this.success = success;
+ this.errorCode = errorCode;
+ this.errorMessage = errorMessage;
+ this.data = data;
+ }
+
+ /**
+ * Getter method for property success.
+ *
+ * @return property value of success
+ */
+ public Boolean getSuccess() {
+ return success;
+ }
+
+ /**
+ * Setter method for property success.
+ *
+ * @param success value to be assigned to property success
+ */
+ public void setSuccess(Boolean success) {
+ this.success = success;
+ }
+
+
+ /**
+ * Getter method for property data.
+ *
+ * @return property value of data
+ */
+ public T getData() {
+ return data;
+ }
+
+ /**
+ * Setter method for property data.
+ *
+ * @param data value to be assigned to property data
+ */
+ public void setData(T data) {
+ this.data = data;
+ }
+
+ @Override
+ public Integer getStatus() {
+ return success ? 1 : 0;
+ }
+
+ /**
+ * Getter method for property errorCode.
+ *
+ * @return property value of errorCode
+ */
+ public String getErrorCode() {
+ return errorCode;
+ }
+
+ /**
+ * Setter method for property errorCode.
+ *
+ * @param errorCode value to be assigned to property errorCode
+ */
+ public void setErrorCode(String errorCode) {
+ this.errorCode = errorCode;
+ }
+
+ /**
+ * Getter method for property errorMsg.
+ *
+ * @return property value of errorMsg
+ */
+ public String getErrorMessage() {
+ return errorMessage;
+ }
+
+ /**
+ * Setter method for property errorMsg.
+ *
+ * @param errorMessage value to be assigned to property errorMsg
+ */
+ public void setErrorMessage(String errorMessage) {
+ this.errorMessage = errorMessage;
+ }
+
+ @Override
+ public Message getMessage() {
+ Message msg = new Message(this.getErrorMessage());
+ //页面展示时，防止出现null状况
+ msg.setCode("");
+ return msg;
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResultMessage.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResultMessage.java
new file mode 100644
index 0000000..039bb9d
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResultMessage.java
@@ -0,0 +1,79 @@
+/**
+ * Copyright (c) 2004-2020 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.model;
+
+/**
+ * 前端错误信息
+ *
+ * @author
+ * @version $Id: ElectromagneticResultMessage.java, v 0.1 2020-12-31 10:35 Exp $$
+ */
+public class ElectromagneticResultMessage {
+ private Integer code;
+ private String message;
+ private String description;
+
+ public ElectromagneticResultMessage(){
+
+ }
+ public ElectromagneticResultMessage(Integer code, String message, String description) {
+ this.code = code;
+ this.message = message;
+ this.description = description;
+ }
+
+ /**
+ * Getter method for property code.
+ *
+ * @return property value of code
+ */
+ public Integer getCode() {
+ return code;
+ }
+
+ /**
+ * Setter method for property code.
+ *
+ * @param code value to be assigned to property code
+ */
+ public void setCode(Integer code) {
+ this.code = code;
+ }
+
+ /**
+ * Getter method for property message.
+ *
+ * @return property value of message
+ */
+ public String getMessage() {
+ return message;
+ }
+
+ /**
+ * Setter method for property message.
+ *
+ * @param message value to be assigned to property message
+ */
+ public void setMessage(String message) {
+ this.message = message;
+ }
+
+ /**
+ * Getter method for property description.
+ *
+ * @return property value of description
+ */
+ public String getDescription() {
+ return description;
+ }
+
+ /**
+ * Setter method for property description.
+ *
+ * @param description value to be assigned to property description
+ */
+ public void setDescription(String description) {
+ this.description = description;
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResultUtil.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResultUtil.java
new file mode 100644
index 0000000..e34cd86
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/ElectromagneticResultUtil.java
@@ -0,0 +1,69 @@
+/**
+ * Copyright (c) 2004-2021 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.model;
+
+
+import electromagnetic.data.framework.share.enums.ErrorEnum;
+import electromagnetic.data.framework.share.result.CallbackResult;
+
+/**
+ * 返回结果转换工具类
+ *
+ * @version $Id: DataCenterResultUtil.java, v 0.1 2021-01-11 16:57 Exp $$
+ */
+public class ElectromagneticResultUtil {
+
+ public static ElectromagneticResult convertToResult(CallbackResult callbackResult) {
+ ElectromagneticResult electromagneticResult = new ElectromagneticResult<>();
+ electromagneticResult.setSuccess(callbackResult.isSuccess());
+ electromagneticResult.setData(callbackResult.getBusinessObject());
+ electromagneticResult.setErrorCode(callbackResult.getResultCode());
+ electromagneticResult.setErrorMessage(callbackResult.getResultMessage());
+ return electromagneticResult;
+ }
+
+ public static ElectromagneticPaginationResult convertToPaginationResult(CallbackResult> callbackResult) {
+ ElectromagneticPaginationResult electromagneticPaginationResult = new ElectromagneticPaginationResult<>();
+ ElectromagneticPaginationInfo electromagneticPaginationInfo = callbackResult.getBusinessObject();
+
+ electromagneticPaginationResult.setSuccess(callbackResult.isSuccess());
+ if (callbackResult.isFailure()) {
+ electromagneticPaginationResult.setErrorCode(callbackResult.getResultCode());
+ electromagneticPaginationResult.setErrorMessage(callbackResult.getResultMessage());
+ return electromagneticPaginationResult;
+ }
+ if (electromagneticPaginationInfo != null) {
+ electromagneticPaginationResult.setData(electromagneticPaginationInfo.getData());
+ electromagneticPaginationResult.setPageIndex(electromagneticPaginationInfo.getPageIndex());
+ electromagneticPaginationResult.setPageSize(electromagneticPaginationInfo.getPageSize());
+ electromagneticPaginationResult.setTotalCount(electromagneticPaginationInfo.getPageTotal());
+ }
+
+ return electromagneticPaginationResult;
+ }
+
+ public static ElectromagneticResult success(T data){
+ ElectromagneticResult electromagneticResult = new ElectromagneticResult<>();
+ electromagneticResult.setSuccess(true);
+ electromagneticResult.setData(data);
+ return electromagneticResult;
+ }
+
+
+ public static ElectromagneticResult fail(String code , String msg){
+ ElectromagneticResult electromagneticResult = new ElectromagneticResult<>();
+ electromagneticResult.setSuccess(false);
+ electromagneticResult.setErrorCode(code);
+ electromagneticResult.setErrorMessage(msg);
+ return electromagneticResult;
+ }
+
+ public static ElectromagneticResult fail(ErrorEnum errorEnum){
+ ElectromagneticResult electromagneticResult = new ElectromagneticResult<>();
+ electromagneticResult.setSuccess(false);
+ electromagneticResult.setErrorCode(errorEnum.getCode());
+ electromagneticResult.setErrorMessage(errorEnum.getErrorMessage());
+ return electromagneticResult;
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/PageModel.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/PageModel.java
new file mode 100644
index 0000000..8584470
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/model/PageModel.java
@@ -0,0 +1,80 @@
+/**
+ * Alibaba.com Inc. Copyright (c) 2004-2021 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.model;
+
+/**
+ * @author
+ * @version v 0.1
+ * @Date 2021-01-08 15:28
+ */
+
+public class PageModel {
+
+ private static final int DEFAULT_SIZE = 20;
+
+ private int totalCount = 0;
+
+ private int pageIndex = 1;
+
+ private int pageSize = DEFAULT_SIZE;
+
+ private T model;
+
+ /**
+ * Getter method for property model.
+ *
+ * @return property value of model
+ */
+ public T getModel() {
+ return model;
+ }
+
+ /**
+ * Setter method for property model.
+ *
+ * @param model value to be assigned to property model
+ */
+ public void setModel(T model) {
+ this.model = model;
+ }
+
+
+
+ public static int getFromIndex(int pIndex, int pSize) {
+ pIndex = pIndex <= 1 ? 1 : pIndex;
+ pSize = pSize <= 1 ? 1 : pSize;
+ return (pIndex - 1) * pSize;
+ }
+
+ public static int getEndIndex(int pIndex, int pSize, int totalCount) {
+ pIndex = pIndex <= 1 ? 1 : pIndex;
+ pSize = pSize <= 1 ? 1 : pSize;
+ return (pIndex - 1) * pSize + pSize <= totalCount ? (pIndex - 1) * pSize + pSize : totalCount;
+ }
+
+ public int getTotalCount() {
+ return totalCount;
+ }
+
+ public void setTotalCount(int totalCount) {
+ this.totalCount = totalCount;
+ }
+
+ public int getPageIndex() {
+ return pageIndex;
+ }
+
+ public void setPageIndex(int pageIndex) {
+ this.pageIndex = pageIndex;
+ }
+
+ public int getPageSize() {
+ return pageSize;
+ }
+
+ public void setPageSize(int pageSize) {
+ this.pageSize = pageSize;
+ }
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/monitor/MonitorLogModel.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/monitor/MonitorLogModel.java
new file mode 100644
index 0000000..1aad122
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/monitor/MonitorLogModel.java
@@ -0,0 +1,24 @@
+package electromagnetic.data.framework.share.monitor;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ *
+ * @date:2023/4/3
+ * @description:
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class MonitorLogModel {
+ private Long cost;
+ private String method;
+ private Boolean success;
+ private String errorCode;
+ private String errorMsg;
+ private String data;
+ private Object[] args;
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/monitor/MonitorLogUtil.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/monitor/MonitorLogUtil.java
new file mode 100644
index 0000000..969df4d
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/monitor/MonitorLogUtil.java
@@ -0,0 +1,53 @@
+package electromagnetic.data.framework.share.monitor;
+
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ *
+ * @date:2023/4/3
+ * @description:
+ */
+public class MonitorLogUtil {
+ private static Logger LOGGER = LoggerFactory.getLogger("COMMON-MONITOR");
+ private static final String SEPARATOR = "|";
+ private static final String DEFAULT_IDENTITY = "MONITOR_LOG_PATTERN";
+
+ public static void infoLog(MonitorLogModel model) {
+ LOGGER.info("|MONITOR_LOG_PATTERN|{}|",buildeLogModel(model));
+ }
+
+ public static void errorLog(MonitorLogModel model, Throwable throwable) {
+ LOGGER.error("|MONITOR_LOG_PATTERN|{}|||",buildeLogModel(model),throwable); }
+
+ public static void monitorLog(MonitorLogModel model,String identity, String ... args) {
+ StringBuilder sb = new StringBuilder(buildeLogModel(model));
+ if (args != null && args.length != 0 ) {
+ for (int i = 0; i < args.length; i++) {
+ sb.append(SEPARATOR).append(args[i]);
+ }
+ }
+ LOGGER.info("|{}|{}|",identity,sb);
+ }
+
+ private static String buildeLogModel(MonitorLogModel model) {
+ Object[] args = model.getArgs();
+ StringBuilder params = new StringBuilder();
+ if (args != null && args.length != 0 ) {
+ for (int i = 0; i < args.length; i++) {
+ params.append(StringUtils.trimToEmpty(String.valueOf(args[i])));
+ params.append(",");
+ }
+ }
+ StringBuilder sb = new StringBuilder();
+ sb.append(model.getCost()).append(SEPARATOR)
+ .append(StringUtils.isNotEmpty(model.getMethod()) ? model.getMethod() : "null").append(SEPARATOR)
+ .append(model.getSuccess()).append(SEPARATOR)
+ .append(StringUtils.isNotEmpty(model.getErrorCode()) ? model.getErrorCode() : "null").append(SEPARATOR)
+ .append(StringUtils.isNotEmpty(model.getErrorMsg()) ? model.getErrorMsg() : "null").append(SEPARATOR)
+ .append(StringUtils.isNotEmpty(model.getData()) ? model.getData() : "null").append(SEPARATOR)
+ .append(StringUtils.isNotEmpty(params.toString()) ? params.toString() : "null");
+ return sb.toString();
+ }
+}
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/CallbackResult.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/CallbackResult.java
new file mode 100644
index 0000000..954938e
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/CallbackResult.java
@@ -0,0 +1,209 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.result;
+
+import java.io.Serializable;
+
+/**
+ * @author wsk
+ * @version $Id: CallbackResult.java, v 0.1 2024-10-17 18:00 wsk
+ */
+public class CallbackResult implements Serializable {
+ private static final long serialVersionUID = -604009540188492829L;
+
+ /**
+ * 可以继续执行，或者提交事务
+ */
+ public final static int SUCCESS = 1;
+
+ /**
+ * 不能继续执行，或者回滚事务
+ */
+ public final static int FAILURE = -1;
+
+ /**
+ * 表征事务状态，默认事务提交
+ */
+ private int statusCode = SUCCESS;
+
+ /**
+ * 代表业务语义的结果代码，主要用在发生回滚，进行异常throw的场景
+ */
+ private String resultCode;
+ /**
+ * 代表业务语义的结果描述，主要用在发生回滚，进行异常throw的场景
+ */
+ private String resultMessage;
+ /**
+ * 发生的异常信息
+ */
+ private Throwable throwable;
+
+ /**
+ * 与该结果关联的业务主体
+ */
+ private T businessObject;
+ /**
+ * 是否幂等
+ */
+ private boolean isIdempotent = false;
+
+ public int getStatusCode() {
+ return statusCode;
+ }
+
+ public void setStatusCode(int statusCode) {
+ this.statusCode = statusCode;
+ }
+
+ public String getResultCode() {
+ return resultCode;
+ }
+
+ public void setResultCode(String resultCode) {
+ this.resultCode = resultCode;
+ }
+
+ public String getResultMessage() {
+ return resultMessage;
+ }
+
+ public void setResultMessage(String resultMessage) {
+ this.resultMessage = resultMessage;
+ }
+
+ public Throwable getThrowable() {
+ return throwable;
+ }
+
+ public void setThrowable(Throwable throwable) {
+ this.throwable = throwable;
+ }
+
+ public T getBusinessObject() {
+ return businessObject;
+ }
+
+ public void setBusinessObject(T businessObject) {
+ this.businessObject = businessObject;
+ }
+
+ public boolean isIdempotent() {
+ return isIdempotent;
+ }
+
+ public void setIdempotent(boolean idempotent) {
+ isIdempotent = idempotent;
+ }
+
+ /**
+ * 禁止用户直接构造该对象，必须通过业务方法构造
+ */
+ private CallbackResult(int statusCode, String resultCode, String resultMessage, Throwable throwable, T businessObject) {
+ this.statusCode = statusCode;
+ this.resultMessage = resultMessage;
+ this.resultCode = resultCode;
+ this.throwable = throwable;
+ this.businessObject = businessObject;
+ }
+
+ // ------------------ 辅助方法 --------------------------------------
+
+ /**
+ * 直接构造成功状况下的回调结果对象
+ */
+ public static CallbackResult success() {
+ return success(null);
+ }
+
+ /**
+ * 直接构造成功状况下的回调结果对象，同时设置业务代码
+ *
+ * @param
+ *
+ *
+ * @return
+ */
+ public static CallbackResult success(T businessObject) {
+ return success(null, businessObject);
+ }
+
+ /**
+ * 直接构造成功状况下的回调结果对象，同时设置业务代码
+ *
+ * @param resultCode
+ * @return
+ */
+ public static CallbackResult success(String resultCode, T businessObject) {
+ return success(resultCode, null, businessObject);
+ }
+ /**
+ * 直接构造成功状况下的回调结果对象，同时设置业务代码、业务对象
+ *
+ * @param resultCode
+ * @return
+ */
+ public static CallbackResult success(String resultCode, String resultMessage, T businessObject) {
+ return new CallbackResult(SUCCESS, resultCode, resultMessage, null, businessObject);
+ }
+
+ /**
+ * 直接构造失败状况下的回调结果对象，同时设置业务代码
+ *
+ * @param resultCode
+ * @return
+ */
+ public static CallbackResult failure(String resultCode, String resultMessage) {
+ return failure(resultCode, resultMessage, null, null);
+ }
+
+ /**
+ * 直接构造失败状况下的回调结果对象，同时设置业务代码、异常
+ *
+ * @param resultCode
+ * @return
+ */
+ public static CallbackResult failure(String resultCode, String resultMessage, Throwable throwable) {
+ return failure(resultCode, resultMessage, throwable, null);
+ }
+
+ /**
+ * 直接构造失败状况下的回调结果对象，同时设置业务代码、异常、业务对象
+ *
+ * @param resultCode
+ * @return
+ */
+ public static CallbackResult failure(String resultCode, String resultMessage, Throwable throwable, T businessObject) {
+ return new CallbackResult(FAILURE, resultCode, resultMessage, throwable, businessObject);
+ }
+
+ /**
+ * 检查服务处理是否成功
+ *
+ * @return 成功返回true，否则返回false
+ */
+ public boolean isSuccess() {
+ return statusCode == SUCCESS;
+ }
+
+ /**
+ * 检查服务处理是否失败
+ *
+ * @return 失败返回true，否则返回false
+ */
+ public boolean isFailure() {
+ return statusCode == FAILURE;
+ }
+
+ /**
+ * 检查业务对象是否为NULL，以便于外部方法判断是否进行其它处理
+ *
+ * @return
+ */
+ public boolean isNullBusinessObject() {
+ return null == this.businessObject;
+ }
+
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/CommonError.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/CommonError.java
new file mode 100644
index 0000000..9c2f9ee
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/CommonError.java
@@ -0,0 +1,124 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.result;
+
+import java.io.Serializable;
+
+/**
+ * @author wsk
+ * @version $Id: CommonError.java, v 0.1 2024-10-17 18:16 wsk
+ */
+public class CommonError implements Serializable {
+
+ /** 序列ID */
+ private static final long serialVersionUID = -1995797200806571697L;
+
+ /** 错误编码 */
+ private ResultCode errorCode;
+
+ /** 错误描述 */
+ private String errorMsg;
+
+ /** 错误发生系统 */
+ private String location;
+
+ // ~~~ 构造方法
+
+ /**
+ * 默认构造方法
+ */
+ public CommonError() {
+ }
+
+ /**
+ * 构造方法
+ *
+ * @param code
+ * @param msg
+ */
+ public CommonError(ResultCode code, String msg, String location) {
+ this.errorCode = code;
+ this.errorMsg = msg;
+ this.location = location;
+ }
+
+ // ~~~ 公共方法
+
+ /**
+ * 转化为简单字符串表示。
+ *
+ * @return
+ */
+ public String toDigest() {
+
+ return errorCode + "@" + location;
+ }
+
+ // ~~~ 重写方法
+
+ /**
+ * @see Object#toString()
+ */
+ @Override
+ public String toString() {
+
+ return errorCode + "@" + location + "::" + errorMsg;
+ }
+
+ // ~~~ bean方法
+
+ /**
+ * Getter method for property errorCode.
+ *
+ * @return property value of errorCode
+ */
+ public ResultCode getErrorCode() {
+ return errorCode;
+ }
+
+ /**
+ * Setter method for property errorCode.
+ *
+ * @param errorCode value to be assigned to property errorCode
+ */
+ public void setErrorCode(ResultCode errorCode) {
+ this.errorCode = errorCode;
+ }
+
+ /**
+ * Getter method for property errorMsg.
+ *
+ * @return property value of errorMsg
+ */
+ public String getErrorMsg() {
+ return errorMsg;
+ }
+
+ /**
+ * Setter method for property errorMsg.
+ *
+ * @param errorMsg value to be assigned to property errorMsg
+ */
+ public void setErrorMsg(String errorMsg) {
+ this.errorMsg = errorMsg;
+ }
+
+ /**
+ * Getter method for property location.
+ *
+ * @return property value of location
+ */
+ public String getLocation() {
+ return location;
+ }
+
+ /**
+ * Setter method for property location.
+ *
+ * @param location value to be assigned to property location
+ */
+ public void setLocation(String location) {
+ this.location = location;
+ }
+}
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ErrorContext.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ErrorContext.java
new file mode 100644
index 0000000..94fcbd7
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ErrorContext.java
@@ -0,0 +1,264 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.result;
+
+/**
+ * @author wsk
+ * @version $Id: ErrorContext.java, v 0.1 2024-10-17 17:27 wsk
+ */
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 错误上下文对象
+ * 错误上下文对象包含标准错误对象的堆栈，和第三方错误信息。
+ *
+ * @author
+ * @version $Id: ErrorContext.java, v 0.1 2020-12-02 6:18 PM Exp $$
+ */
+public class ErrorContext implements Serializable {
+
+ /** 序列ID */
+ private static final long serialVersionUID = 3939009139641299179L;
+
+ /** 默认分隔符 */
+ private static final String SPLIT = "|";
+
+ /** 错误堆栈集合 */
+ private List errorStack = new ArrayList();
+
+ /** 第三方错误原始信息 */
+ private String thirdPartyError;
+
+ /** 错误变量映射 */
+ private Map errorVariableMap = new HashMap();
+
+ /**
+ * 默认构造方法。
+ */
+ public ErrorContext() {
+ // 默认构造方法
+ }
+
+ /**
+ * 构造方法。
+ *
+ * @param errorCode 错误码。
+ */
+ public ErrorContext(ResultCode errorCode) {
+ this.addError(errorCode);
+ }
+
+ /**
+ * 构造方法。
+ *
+ * @param thirdPartyError 第三方错误。
+ */
+ public ErrorContext(String thirdPartyError) {
+ this.thirdPartyError = thirdPartyError;
+ }
+
+ /**
+ * 获取错误变量值映射Map
+ *
+ * @return 错误变量值映射Map
+ */
+ public Map fetchErrorVarMap() {
+ return errorVariableMap;
+ }
+
+ /**
+ * 设置错误变量的变量值,变量名和变量值是K-V映射，故后set的会覆盖先前set的同名变量
+ *
+ * @param variableName
+ * 错误变量名
+ * @param variableValue
+ * 错误变量值
+ */
+ public void setErrorVariable(String variableName, String variableValue) {
+ errorVariableMap.put(variableName, variableValue);
+ }
+
+
+ /**
+ * 获取当前错误对象。
+ *
+ * @return 当前错误码对象
+ */
+ public ResultCode fetchCurrentError() {
+ if (errorStack != null && errorStack.size() > 0) {
+ return errorStack.get(errorStack.size() - 1);
+ }
+
+ return null;
+ }
+
+ /**
+ * 获取当前错误码。
+ *
+ * @return 当前错误码字符串
+ */
+ public String fetchCurrentErrorCode() {
+ ResultCode resultCode = fetchCurrentError();
+ return (resultCode == null) ? null : resultCode.fetchResultCode();
+ }
+
+ /**
+ * 获取原始错误对象。
+ *
+ * @return 原始错误码对象
+ */
+ public ResultCode fetchRootError() {
+ if (errorStack != null && errorStack.size() > 0) {
+ return errorStack.get(0);
+ }
+
+ return null;
+ }
+
+ /**
+ * 向堆栈中添加错误对象。
+ *
+ * @param error 错误码
+ */
+ public void addError(ResultCode error) {
+ if (errorStack == null) {
+ errorStack = new ArrayList();
+ }
+
+ errorStack.add(error);
+ }
+
+ /**
+ * 向堆栈中添加错误对象。
+ *
+ * @param error 错误码
+ */
+ public void addError(CommonError error) {
+ if (errorStack == null) {
+ errorStack = new ArrayList();
+ }
+
+ errorStack.add(error.getErrorCode());
+ }
+
+ /**
+ * 获取字符串形式的错误码堆栈
+ *
+ * @return 错误码堆栈
+ */
+ @Deprecated
+ public String fetchErrorCodeStack() {
+ StringBuffer sb = new StringBuffer();
+ for (int i = errorStack.size(); i > 0; i--) {
+ if (i == errorStack.size()) {
+ sb.append(errorStack.get(i - 1));
+ } else {
+ sb.append(SPLIT).append(errorStack.get(i - 1));
+ }
+ }
+
+ return sb.toString();
+ }
+
+ /**
+ * 获取字符串形式的错误码堆栈digest
+ *
+ * @return 错误码堆栈
+ */
+ public String fetchErrorCodeStackDigest() {
+ StringBuffer sb = new StringBuffer();
+ for (int i = errorStack.size(); i > 0; i--) {
+ if (i == errorStack.size()) {
+ sb.append(errorStack.get(i - 1));
+ } else {
+ sb.append(SPLIT).append(errorStack.get(i - 1));
+ }
+ }
+
+ return sb.toString();
+ }
+
+ /**
+ * 构建错误上下文digest输出。
+ *
+ * @return 错误摘要日志
+ */
+ public String toDigest() {
+
+ StringBuffer sb = new StringBuffer();
+
+ //错误堆栈
+ sb.append(fetchErrorCodeStackDigest());
+
+ //第三方错误
+// if (StringUtils.isNotBlank(thirdPartyError)) {
+// sb.append("#");
+// sb.append(thirdPartyError);
+// }
+
+ return sb.toString();
+ }
+
+ /**
+ * Getter method for property errorStack.
+ *
+ * @return property value of errorStack
+ */
+ public List getErrorStack() {
+ return errorStack;
+ }
+
+ /**
+ * Setter method for property errorStack.
+ *
+ * @param errorStack value to be assigned to property errorStack
+ */
+ public void setErrorStack(List errorStack) {
+ this.errorStack = errorStack;
+ }
+
+ /**
+ * Getter method for property thirdPartyError.
+ *
+ * @return property value of thirdPartyError
+ */
+ public String getThirdPartyError() {
+ return thirdPartyError;
+ }
+
+ /**
+ * Setter method for property thirdPartyError.
+ *
+ * @param thirdPartyError value to be assigned to property thirdPartyError
+ */
+ public void setThirdPartyError(String thirdPartyError) {
+ this.thirdPartyError = thirdPartyError;
+ }
+
+ /**
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString() {
+ StringBuffer sb = new StringBuffer();
+
+ //错误堆栈
+ sb.append("errorStack=[");
+ sb.append(fetchErrorCodeStackDigest());
+ sb.append("],");
+
+ //第三方错误
+ sb.append("thirdPartyError=[");
+ sb.append(thirdPartyError);
+ sb.append("]");
+
+ return sb.toString();
+ }
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ErrorContextUtil.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ErrorContextUtil.java
new file mode 100644
index 0000000..9327f63
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ErrorContextUtil.java
@@ -0,0 +1,70 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.result;
+
+/**
+ * @author wsk
+ * @version $Id: ErrorContextUtil.java, v 0.1 2024-10-17 18:20 wsk
+ */
+public class ErrorContextUtil {
+
+ /** 系统名称 */
+ private static String systemName;
+
+ /**
+ * 将构造好的标准错误对象放入一个现有的错误上下文，并返回这个现有的错误上下文，如果现有的上下文为空，则构建一个新的错误上下文返回。
+ *
会自动添加当前系统名至标准错误对象中。
+ *
+ * @param errorContext 错误上下文
+ * @param resultCode 标准错误对象
+ * @return 错误上下文
+ */
+ public static ErrorContext addErrorContext(ErrorContext errorContext, ResultCode resultCode) {
+
+ if (null == errorContext) {
+ errorContext = new ErrorContext();
+ }
+
+ if (resultCode == null) {
+ return errorContext;
+ }
+
+ resultCode.setSystemName(systemName);
+
+ errorContext.addError(resultCode);
+
+ return errorContext;
+ }
+
+ /**
+ *
根据错误码和错误英文简称，构建标准错误对象，并放入错误上下文，如果现有的上下文为空，则构建一个新的错误上下文返回。
+ *
会自动添加当前系统名至标准错误对象中。
+ *
+ * @param errorContext 错误上下文
+ * @param errorCode 错误码
+ * @param errorName 错误英文名称
+ * @param description 错误描述
+ * @return 错误上下文
+ */
+ @Deprecated
+ public static ErrorContext addErrorContext(ErrorContext errorContext, String errorCode,
+ String errorName, String description) {
+
+ ResultCode resultCode = new ResultCode(errorCode, errorName, description);
+
+ return addErrorContext(errorContext, resultCode);
+ }
+
+ // ~~~ bean方法
+
+ /**
+ * Setter method for property systemName.
+ *
+ * @param systemName value to be assigned to property systemName
+ */
+ public void setSystemName(String systemName) {
+ ErrorContextUtil.systemName = systemName;
+ }
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/Message.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/Message.java
new file mode 100644
index 0000000..8a9cdf7
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/Message.java
@@ -0,0 +1,104 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.result;
+
+import electromagnetic.data.framework.share.enums.ResultCodeEnum;
+
+/**
+ * @author wsk
+ * @version $Id: Message.java, v 0.1 2024-10-17 17:24 wsk
+ */
+public class Message {
+ /**
+ * 返回结果码
+ */
+ private String code;
+ /**
+ * 返回结果信息
+ */
+ private String message;
+ /**
+ * 返回错误明细
+ */
+ private ErrorContext errorContext;
+
+ public Message(String messageStr) {
+ this.message = messageStr;
+ }
+
+ public Message(ResultCodeEnum resultCodeEnum) {
+ this.message = resultCodeEnum.getResultMsg();
+ this.code = resultCodeEnum.getResultCode();
+ }
+
+ public Message(ResultCodeEnum resultCodeEnum, ErrorContext errorContext) {
+ this.message = resultCodeEnum.getResultMsg();
+ this.code = resultCodeEnum.getResultCode();
+ this.errorContext = errorContext;
+ }
+
+ public String getCode() {
+ return code;
+ }
+
+ public Message setCode(String code) {
+ this.code = code;
+ return this;
+ }
+
+ public String getMessage() {
+ return message;
+ }
+
+ public Message setMessage(String message) {
+ this.message = message;
+ return this;
+ }
+
+ /**
+ * Getter method for property errorContext.
+ *
+ * @return property value of errorContext
+ */
+ public ErrorContext getErrorContext() {
+ return errorContext;
+ }
+
+ /**
+ * Setter method for property errorContext.
+ *
+ * @param errorContext value to be assigned to property errorContext
+ */
+ public void setErrorContext(ErrorContext errorContext) {
+ this.errorContext = errorContext;
+ }
+
+ /**
+ * 增加一个错误码。
+ *
+ * @param errorCode 错误码。
+ */
+ public void addErrorCode(ResultCode errorCode) {
+ ErrorContextUtil.addErrorContext(errorContext, errorCode);
+ }
+
+ /**
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString() {
+ StringBuilder builder = new StringBuilder();
+ builder.append("code = ");
+ builder.append(code);
+ builder.append(", message = ");
+ builder.append(message);
+ builder.append(", ");
+ builder.append("BaseResult [");
+ builder.append("errorContext=");
+ builder.append(errorContext);
+ builder.append("]");
+ return builder.toString();
+ }
+
+}
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/Result.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/Result.java
new file mode 100644
index 0000000..56359ba
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/Result.java
@@ -0,0 +1,27 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.result;
+
+/**
+ * @author wsk
+ * @version $Id: Result.java, v 0.1 2024-10-17 17:23 wsk
+ */
+public interface Result {
+
+ /**
+ * 返回状态
+ *
+ * @return
+ */
+ Integer getStatus();
+
+ /**
+ * 返回消息
+ *
+ * @return
+ */
+ Message getMessage();
+
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ResultCode.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ResultCode.java
new file mode 100644
index 0000000..c471164
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ResultCode.java
@@ -0,0 +1,403 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.result;
+
+import java.io.Serializable;
+
+/**
+ * @author wsk
+ * @version $Id: ResultCode.java, v 0.1 2024-10-17 17:29 wsk
+ */
+public class ResultCode implements Serializable {
+
+ /** 序列ID */
+ private static final long serialVersionUID = 3951948353107763580L;
+
+ /** 结果码固定前缀 */
+ protected static final String PREFIX = "CE";
+
+ /** 结果码版本 */
+ private String version;
+
+ /** 结果码级别[第9位]，INFO-1,WARN-3,ERROR-5,FATAL-7，参见ResultCodeLevel定义 */
+ private String codeLevel;
+
+ /** 结果码类型[第10位]，SUCCESS-0,BIZ_ERROR-1,SYS_ERROR-2,THIRD_ERROR-3，参见ResultCodeType定义 */
+ private String codeType;
+
+ /** 系统编号[第11-13位]，见SystemCode定义 */
+ private String systemCode;
+
+ /** 系统名称 */
+ private String systemName;
+
+ /** 具体结果码[第14-17位] */
+ private String errorSpecific;
+
+ /** 错误英文简称 */
+ private String errorName;
+
+ /** 结果码信息描述，可空 */
+ private String description;
+
+ // ~~~ 构造方法
+
+ /**
+ * 默认构造方法。
+ */
+ public ResultCode() {
+ // 默认构造方法。
+ }
+
+ /**
+ * 构造方法。
+ *
+ * @param resultCode 结果码字符串
+ */
+ public ResultCode(String resultCode) {
+
+ //结果码长度检查
+ checkStringLength(resultCode, 16);
+
+ //拆分结果码
+ spliteResultCode(resultCode);
+ }
+
+ /**
+ * 构造方法。
+ *
+ * @param resultCode 结果码字符串
+ * @param errorName 错误码英文简称
+ */
+ public ResultCode(String resultCode, String errorName) {
+ this(resultCode);
+ this.errorName = errorName;
+ }
+
+ /**
+ * 构造方法。
+ *
+ * @param resultCode 结果码字符串
+ * @param errorName 错误码英文简称
+ * @param description 结果码信息描述
+ */
+ public ResultCode(String resultCode, String errorName, String description) {
+ this(resultCode);
+ this.errorName = errorName;
+ this.description = description;
+ }
+
+ /**
+ * 构造方法。
+ *
+ * @param version 版本
+ * @param codeLevel 结果码级别
+ * @param codeType 结果码类型
+ * @param systemCode 系统编号
+ * @param errorSpecific 具体错误码
+ */
+ public ResultCode(String version, String codeLevel, String codeType, String systemCode, String errorSpecific) {
+ this.version = version;
+ this.codeLevel = codeLevel;
+ this.codeType = codeType;
+ this.systemCode = systemCode;
+ this.errorSpecific = errorSpecific;
+ }
+
+ /**
+ * 构造方法。
+ *
+ * @param version 版本
+ * @param codeLevel 结果码级别
+ * @param codeType 结果码类型
+ * @param systemCode 系统编号
+ * @param errorSpecific 具体错误码
+ * @param errorName 错误码英文简称
+ */
+ public ResultCode(String version, String codeLevel, String codeType, String systemCode, String errorSpecific,
+ String errorName) {
+ this(version, codeLevel, codeType, systemCode, errorSpecific);
+ this.errorName = errorName;
+ }
+
+ // ~~~ 公有方法
+
+ /**
+ * 组装返回码字符串。
+ *
+ * @return 返回码字符串
+ */
+ public String fetchResultCode() {
+ StringBuffer sb = new StringBuffer();
+
+ sb.append(PREFIX);
+ sb.append(version);
+ sb.append(codeLevel);
+ sb.append(codeType);
+ sb.append(systemCode);
+ sb.append(errorSpecific);
+
+ return sb.toString();
+ }
+
+ /**
+ * 组装返回码字符串。 解决enum 单利线程安全问题
+ *
+ * @param eventCode
+ * @return 返回码字符串
+ */
+ public String fetchResultCode(String eventCode) {
+ StringBuffer sb = new StringBuffer();
+
+ sb.append(PREFIX);
+ sb.append(version);
+ sb.append(codeLevel);
+ sb.append(codeType);
+ sb.append(eventCode);
+ sb.append(errorSpecific);
+
+ return sb.toString();
+ }
+
+ /**
+ * 构建错误对象digest
+ *
+ * @return 错误码摘要日志
+ */
+// public String toDigest() {
+//
+// //组装结果码字符串
+// String resultCode = fetchResultCode();
+//
+// if (StringUtils.isNotBlank(errorName)) {
+// resultCode = resultCode + "@" + errorName;
+// } else {
+// resultCode = resultCode + "@";
+// }
+//
+// if (StringUtils.isNotBlank(systemName)) {
+// resultCode = resultCode + "@" + systemName;
+// } else {
+// resultCode = resultCode + "@";
+// }
+//
+// return resultCode;
+// }
+
+ // ~~~ 重写方法
+
+ /**
+ * @see java.lang.Object#toString()
+ */
+ @Override
+ public String toString() {
+
+ //错误完整性检查
+ checkStringLength(this.version, 1);
+ checkStringLength(this.codeLevel, 1);
+ checkStringLength(this.codeType, 1);
+ checkStringLength(this.systemCode, 8);
+ checkStringLength(this.errorSpecific, 3);
+
+ //组装结果码字符串
+ String resultCode = fetchResultCode();
+
+// if (StringUtils.isNotBlank(errorName)) {
+// resultCode = resultCode + "@" + errorName;
+// }
+
+ return resultCode;
+ }
+
+ /**
+ * @see java.lang.Object#hashCode()
+ */
+ @Override
+ public int hashCode() {
+ return this.fetchResultCode().hashCode();
+ }
+
+ /**
+ * @see java.lang.Object#equals(java.lang.Object)
+ */
+ @Override
+ public boolean equals(Object obj) {
+
+ if (obj == this) {
+ return true;
+ }
+
+ if (obj == null) {
+ return false;
+ }
+ return false;
+
+// return StringUtils.equals(this.fetchResultCode(), (((ResultCode) obj).fetchResultCode()));
+ }
+
+ // ~~~ 内部方法
+
+ /**
+ * 解析和拆分结果码。
+ *
+ * @param resultCode 结果码字符串
+ */
+ private void spliteResultCode(String resultCode) {
+ if (!resultCode.startsWith(PREFIX)) {
+ throw new IllegalArgumentException();
+ }
+
+ char[] chars = resultCode.toCharArray();
+
+ // 旧：CIC_RS_100000200
+ // 新：CE15112000201001
+
+ this.version = "" + chars[2];
+ this.codeLevel = "" + chars[3];
+ this.codeType = "" + chars[4];
+ this.systemCode = "" + chars[5] + chars[6] + chars[7] + chars[8] + chars[9] + chars[10] + chars[11] + chars[12];
+ this.errorSpecific = "" + chars[13] + chars[14] + chars[15];
+ }
+
+ /**
+ * 字符串长度检查。
+ *
+ * @param resultCode 结果码字符串
+ * @param length 长度
+ */
+ private void checkStringLength(String resultCode, int length) {
+ if (resultCode == null || resultCode.length() != length) {
+ throw new IllegalArgumentException();
+ }
+ }
+
+ // ~~~ bean方法
+
+ /**
+ * Getter method for property codeLevel.
+ *
+ * @return property value of codeLevel
+ */
+ public String getCodeLevel() {
+ return codeLevel;
+ }
+
+ /**
+ * Setter method for property codeLevel.
+ *
+ * @param codeLevel value to be assigned to property codeLevel
+ */
+ public void setCodeLevel(String codeLevel) {
+ this.codeLevel = codeLevel;
+ }
+
+ /**
+ * Getter method for property codeType.
+ *
+ * @return property value of codeType
+ */
+ public String getCodeType() {
+ return codeType;
+ }
+
+ /**
+ * Setter method for property codeType.
+ *
+ * @param codeType value to be assigned to property codeType
+ */
+ public void setCodeType(String codeType) {
+ this.codeType = codeType;
+ }
+
+ /**
+ * Getter method for property systemCode.
+ *
+ * @return property value of systemCode
+ */
+ public String getSystemCode() {
+ return systemCode;
+ }
+
+ /**
+ * Setter method for property systemCode.
+ *
+ * @param systemCode value to be assigned to property systemCode
+ */
+ public void setSystemCode(String systemCode) {
+ this.systemCode = systemCode;
+ }
+
+ /**
+ * Getter method for property errorSpecific.
+ *
+ * @return property value of errorSpecific
+ */
+ public String getErrorSpecific() {
+ return errorSpecific;
+ }
+
+ /**
+ * Setter method for property errorSpecific.
+ *
+ * @param errorSpecific value to be assigned to property errorSpecific
+ */
+ public void setErrorSpecific(String errorSpecific) {
+ this.errorSpecific = errorSpecific;
+ }
+
+ /**
+ * Getter method for property description.
+ *
+ * @return property value of description
+ */
+ public String getDescription() {
+ return description;
+ }
+
+ /**
+ * Setter method for property description.
+ *
+ * @param description value to be assigned to property description
+ */
+ public void setDescription(String description) {
+ this.description = description;
+ }
+
+ /**
+ * Getter method for property systemName.
+ *
+ * @return property value of systemName
+ */
+ public String getSystemName() {
+ return systemName;
+ }
+
+ /**
+ * Setter method for property systemName.
+ *
+ * @param systemName value to be assigned to property systemName
+ */
+ public void setSystemName(String systemName) {
+ this.systemName = systemName;
+ }
+
+ /**
+ * Getter method for property errorName.
+ *
+ * @return property value of errorName
+ */
+ public String getErrorName() {
+ return errorName;
+ }
+
+ /**
+ * Setter method for property errorName.
+ *
+ * @param errorName value to be assigned to property errorName
+ */
+ public void setErrorName(String errorName) {
+ this.errorName = errorName;
+ }
+
+}
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ResultModel.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ResultModel.java
new file mode 100644
index 0000000..660f08d
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/result/ResultModel.java
@@ -0,0 +1,41 @@
+/**
+ * Copyright (c) 2004-2024 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.result;
+
+/**
+ * @author wsk
+ * @version $Id: ResultModel.java, v 0.1 2024-10-17 17:23 wsk
+ */
+public interface ResultModel extends Result {
+ /**
+ * 返回结果模型
+ *
+ * @return
+ */
+ T getData();
+
+ /**
+ * 页面编码，从1开始
+ *
+ * @return
+ */
+ int getPageIndex();
+
+ /**
+ * 记录总数量
+ *
+ * 有时可能只要分页数据，不要总数
+ *
+ *
+ * @return
+ */
+ Integer getTotalCount();
+
+ /**
+ * 每页大小
+ *
+ * @return
+ */
+ int getPageSize();
+}
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/sign/AESUtils.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/sign/AESUtils.java
new file mode 100644
index 0000000..480e5b6
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/sign/AESUtils.java
@@ -0,0 +1,134 @@
+/**
+ * Copyright (c) 2004-2022 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.sign;
+
+/**
+ * @author wsk
+ * @version $Id: AESUtils.java, v 0.1 2022-07-06 14:57 wsk.pt Exp $$
+ */
+
+import javax.crypto.*;
+import javax.crypto.spec.SecretKeySpec;
+import java.io.UnsupportedEncodingException;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.security.SecureRandom;
+
+/**
+ * Description: [AES对称加密和解密]
+ * @description:
+ * @author:
+ * @create: 2022/07/06 10:52
+ */
+public class AESUtils {
+
+ /**
+ * Discription:[加密]
+ * Created on 2022/07/06 10:52
+ * @param content 明文 用JSON.toJSONString(Map map)转换的json字符串
+ * @param key 加解密规则 访客系统提供key
+ * @return String 密文
+ */
+ public static String ecodes(String content, String key) {
+ if (content == null || content.length() < 1) {
+ return null;
+ }
+ try {
+ KeyGenerator kgen = KeyGenerator.getInstance("AES");
+ SecureRandom random= SecureRandom.getInstance("SHA1PRNG");
+ random.setSeed(key.getBytes());
+ kgen.init(128, random);
+ SecretKey secretKey = kgen.generateKey();
+ byte[] enCodeFormat = secretKey.getEncoded();
+ SecretKeySpec secretKeySpec = new SecretKeySpec(enCodeFormat, "AES");
+ Cipher cipher = Cipher.getInstance("AES");
+ byte[] byteContent = content.getBytes("utf-8");
+ cipher.init(Cipher.ENCRYPT_MODE, secretKeySpec);
+ byte[] byteRresult = cipher.doFinal(byteContent);
+ StringBuffer sb = new StringBuffer();
+ for (int i = 0; i < byteRresult.length; i++) {
+ String hex = Integer.toHexString(byteRresult[i] & 0xFF);
+ if (hex.length() == 1) {
+ hex = '0' + hex;
+ }
+ sb.append(hex.toUpperCase());
+ }
+ return sb.toString();
+ } catch (NoSuchAlgorithmException e) {
+ e.printStackTrace();
+ } catch (NoSuchPaddingException e) {
+ e.printStackTrace();
+ } catch (InvalidKeyException e) {
+ e.printStackTrace();
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ } catch (IllegalBlockSizeException e) {
+ e.printStackTrace();
+ } catch (BadPaddingException e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+ /**
+ * Discription:[解密]
+ * Created on 2022/07/06 10:52
+ * @param content 密文
+ * @param key 加解密规则
+ * @return String 明文
+ */
+ public static String dcodes(String content, String key) {
+ if (content == null || content.length() < 1) {
+ return null;
+ }
+ if (content.trim().length() < 19) {
+ return content;
+ }
+ byte[] byteRresult = new byte[content.length() / 2];
+ for (int i = 0; i < content.length() / 2; i++) {
+ int high = Integer.parseInt(content.substring(i * 2, i * 2 + 1), 16);
+ int low = Integer.parseInt(content.substring(i * 2 + 1, i * 2 + 2), 16);
+ byteRresult[i] = (byte) (high * 16 + low);
+ }
+ try {
+ KeyGenerator kgen = KeyGenerator.getInstance("AES");
+ SecureRandom random=SecureRandom.getInstance("SHA1PRNG");
+ random.setSeed(key.getBytes());
+ kgen.init(128, random);
+ SecretKey secretKey = kgen.generateKey();
+ byte[] enCodeFormat = secretKey.getEncoded();
+ SecretKeySpec secretKeySpec = new SecretKeySpec(enCodeFormat, "AES");
+ Cipher cipher = Cipher.getInstance("AES");
+ cipher.init(Cipher.DECRYPT_MODE, secretKeySpec);
+ byte[] result = cipher.doFinal(byteRresult);
+ return new String(result);
+ } catch (NoSuchAlgorithmException e) {
+ e.printStackTrace();
+ } catch (NoSuchPaddingException e) {
+ e.printStackTrace();
+ } catch (InvalidKeyException e) {
+ e.printStackTrace();
+ } catch (IllegalBlockSizeException e) {
+ e.printStackTrace();
+ } catch (BadPaddingException e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+// public static void main(String[] args) {
+// try {
+//
+// String miwen = AESUtils.ecodes("{\"id\":1759,\"reservationId\":1511867174251,\"visitingPurpose\":1,\"officeBuildingId\":1,\"officeBuildingName\":\"1\",\"cityId\":1,\"cityName\":\"1\",\"reservationStatus\":1,\"visitorName\":\"1 \",\"visitorAreaCode\":\"1\",\"visitorPhone\":\"1\",\"visitorEmail\":null,\"remark\":null,\"visitingTime\":1,\"visitorNum\":1,\"visitingUnit\":null,\"messageNum\":null,\"photoUrl\":null,\"receptionUserName\":\"1\",\"receptionUserDomainAccount\":\"1\",\"visitingInvitationCode\":null,\"createUser\":\"1\",\"createTime\":1,\"createUserDomainAccount\":null,\"updateTime\":null,\"signTime\":null,\"alreadySignedInNum\":null,\"alreadySignedOutNum\":null,\"accompanyPersons\":null,\"visitingReason\":null,\"field1\":null,\"field2\":null,\"field3\":null,\"field4\":null,\"field5\":null,\"approveStatus\":1,\"levelOneName\":null,\"levelTwoName\":null,\"createPlatform\":1}",
+// "555");
+// System.out.println("miwen : " + miwen);
+//
+// String mingwen = AESUtils.dcodes(miwen, "555");
+// System.out.println("mingwen : " + mingwen);
+//
+// } catch (Exception e) {
+// e.printStackTrace();
+// }
+// }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/sign/SingHelper.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/sign/SingHelper.java
new file mode 100644
index 0000000..dc286c1
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/sign/SingHelper.java
@@ -0,0 +1,148 @@
+package electromagnetic.data.framework.share.sign;
+
+
+import java.security.MessageDigest;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * 加密工具
+ *
+ * @author wsk
+ * @version $Id: SingHelper.java, v 0.1 2022-07-01 11:44 wsk.pt Exp $$
+ */
+public class SingHelper {
+ /**
+ * 检验参数签名
+ *
+ * @param params 调用者传入的参数
+ * @param secret 签名的secret
+ * @param ，格式为secret+(参数名+参数值.
+ * ..)+secret的大写md5值
+ * @return
+ */
+ @SuppressWarnings({"unchecked", "rawtypes"})
+ public static String createSign(Map params, String secret) {
+ //按参数名asscic码排序
+ List names = new ArrayList();
+ Set keyset = params.keySet();
+ for (Object key : keyset) {
+ names.add(String.valueOf(key));
+ }
+ Collections.sort(names);
+ String strSign = secret;
+ for (String name : names) {
+ strSign += name + getString(params, name, "");
+ }
+ strSign += secret;
+ String newSign = md5(strSign).toUpperCase();
+ return newSign;
+ }
+
+ public static char[] hexDigits ={'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C','D', 'E', 'F'};
+
+ public static String md5(String string) {
+ try {
+ MessageDigest md5 = MessageDigest.getInstance("MD5");
+ byte[] bytes = md5.digest(string.getBytes("utf-8"));
+ char[] chars = new char[bytes.length * 2];
+
+ for (int i = 0; i < bytes.length; ++i) {
+ int b = bytes[i];
+ chars[i * 2] = hexDigits[(b & 240) >> 4];
+ chars[i * 2 + 1] = hexDigits[b & 15];
+ }
+ return new String(chars);
+ } catch (Exception var6) {
+ return null;
+ }
+ }
+
+ public static String getString(Map params, String key, String
+ defaultValue) {
+ String temp = null;
+ if (params.get(key) == null) {
+ return defaultValue;
+ } else if (params.get(key).getClass().isArray()) {
+ temp = getArray(params, key)[0];
+ } else {
+ temp = params.get(key).toString();
+ }
+ if (temp != null) {
+ temp = temp.replaceAll("%", "\\%");
+ }
+ if (temp == null) {
+ return defaultValue;
+ }
+ return temp;
+ }
+
+ public static String getString(Map params, String key) {
+ return getString(params, key, null);
+ }
+
+ public static String[] getArray(Map params, String key) {
+ return getArray(params, key, null);
+ }
+
+ public static String[] getArray(Map params, String
+ key, String[] defaultValue) {
+ if (params == null) {
+ return defaultValue;
+ }
+ if (params.get(key) == null) {
+ return defaultValue;
+ }
+ try {
+ String[] values = (String[]) params.get(key);
+ return values;
+ } catch (ClassCastException e) {
+ return defaultValue;
+
+ }
+ }
+
+ public static Date signDate(String date, String format) {
+ if (date == null || date.equals("")) {
+ return null;
+ }
+ if (format == null || format.equals("")) {
+ format = "yyyy-MM-dd HH:mm:ss";
+ }
+ try {
+ return new SimpleDateFormat(format).parse(date);
+ } catch (ParseException e) {
+ return null;
+ }
+ }
+
+// public static void main(String[] args) {
+// Map m = new HashMap<>();
+// m.put("cid",null);
+// m.put("certType","identificationCard");
+// m.put("certId","610113197202030463");
+// //必传参数
+// m.put("appId", "BST21543866410458361856");
+// //必传参数
+// m.put("timestamp", System.currentTimeMillis()+"");
+// /**
+// * secret 是根据appid获取的
+// */
+// String sign =createSign(m,"A8AD975B86D364E302946E68A1910EABCE54DC457A34E623");
+// System.out.println("Test.main-----:"+sign);
+// m.put("sign", sign);
+// System.out.println(sign);
+// StringBuffer url=new StringBuffer();
+//
+// url.append("http://platform.cic.inter/cic-pc-dataplatform-tagservice/tag/newPersonPortrait?");
+// url.append("cid="+m.get("cid"));
+// url.append("&certType="+m.get("certType"));
+// url.append("&certId="+m.get("certId"));
+// url.append("&appId="+m.get("appId"));
+// url.append("×tamp="+m.get("timestamp"));
+// url.append("&sign="+m.get("sign"));
+// System.out.println(url);
+// }
+
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/spi/ProxyUtils.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/spi/ProxyUtils.java
new file mode 100644
index 0000000..bcab3b0
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/spi/ProxyUtils.java
@@ -0,0 +1,29 @@
+/**
+ * Copyright (c) 2004-2021 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.spi;
+
+import org.springframework.aop.TargetSource;
+import org.springframework.aop.framework.Advised;
+import org.springframework.aop.support.AopUtils;
+
+/**
+ * @version $Id: A.java, v 0.1 2021-06-17 10:14 Exp $$
+ */
+public class ProxyUtils {
+ public static T getProxyTarget(Object proxy) {
+ if (!AopUtils.isAopProxy(proxy)) {
+ throw new IllegalStateException("Target must be a proxy");
+ }
+ TargetSource targetSource = ((Advised) proxy).getTargetSource();
+ return getTarget(targetSource);
+ }
+
+ private static T getTarget(TargetSource targetSource) {
+ try {
+ return (T) targetSource.getTarget();
+ } catch (Exception e) {
+ throw new IllegalStateException(e);
+ }
+ }
+}
\ No newline at end of file
diff --git a/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/spi/ServiceLoaderUtil.java b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/spi/ServiceLoaderUtil.java
new file mode 100644
index 0000000..83e16ad
--- /dev/null
+++ b/electromagnetic-framework/src/main/java/electromagnetic/data/framework/share/spi/ServiceLoaderUtil.java
@@ -0,0 +1,42 @@
+/**
+ * Copyright (c) 2004-2021 All Rights Reserved.
+ */
+package electromagnetic.data.framework.share.spi;
+
+
+import com.google.common.collect.Maps;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.ServiceLoader;
+
+/**
+ * @version $Id: ServiceLoaderUtil.java, v 0.1 2021-06-15 10:20 Exp $$
+ */
+public class ServiceLoaderUtil {
+
+ static Map> mapList = Maps.newConcurrentMap();
+
+ public static T getspi(Class cla){
+ if(mapList.get(cla.getClass().getName())!=null&&mapList.get(cla.getClass().getName()).size()>0){
+ return (T)mapList.get(cla.getClass().getName()).get(0);
+ }else {
+ List