add DomainEvent

Author: xlorne

springboot-starter/src/main/java/com/codingapi/springboot/framework/domain/event/DomainCreateEvent.java

@@ -1,35 +1,14 @@
 package com.codingapi.springboot.framework.domain.event;
 
-import com.codingapi.springboot.framework.event.IEvent;
 import lombok.Getter;
-import lombok.ToString;
 
 /**
  * 实体创建事件
  */
 @Getter
-@ToString
-public class DomainCreateEvent implements IEvent {
-
-    /**
-     * 实体对象
-     */
-    private final Object entity;
-
-    /**
-     * 实体类名称
-     */
-    private final String simpleName;
-
-    /**
-     * 时间戳
-     */
-    private final long timestamp;
+public class DomainCreateEvent extends DomainEvent {
 
     public DomainCreateEvent(Object entity) {
-        this.entity = entity;
-        this.simpleName = entity.getClass().getSimpleName();
-        this.timestamp = System.currentTimeMillis();
+        super(entity);
     }
-
 }

springboot-starter/src/main/java/com/codingapi/springboot/framework/domain/event/DomainDeleteEvent.java

@@ -1,35 +1,15 @@
 package com.codingapi.springboot.framework.domain.event;
 
-import com.codingapi.springboot.framework.event.IEvent;
 import lombok.Getter;
-import lombok.ToString;
 
 /**
- * 实体创建事件
+ * 实体删除事件
  */
 @Getter
-@ToString
-public class DomainDeleteEvent implements IEvent {
-
-    /**
-     * 实体对象
-     */
-    private final Object entity;
-
-    /**
-     * 实体类名称
-     */
-    private final String simpleName;
-
-    /**
-     * 时间戳
-     */
-    private final long timestamp;
+public class DomainDeleteEvent extends DomainEvent {
 
     public DomainDeleteEvent(Object entity) {
-        this.entity = entity;
-        this.simpleName = entity.getClass().getSimpleName();
-        this.timestamp = System.currentTimeMillis();
+        super(entity);
     }
 
 }

springboot-starter/src/main/java/com/codingapi/springboot/framework/domain/event/DomainEvent.java

@@ -0,0 +1,32 @@
+package com.codingapi.springboot.framework.domain.event;
+
+import com.codingapi.springboot.framework.event.IEvent;
+import lombok.Getter;
+import lombok.ToString;
+
+/**
+ * 实体事件
+ */
+@Getter
+@ToString(exclude = "entity")
+public abstract class DomainEvent implements IEvent {
+
+    /**
+     * 实体类型
+     */
+    private final Class<?> entityClass;
+    /**
+     * 时间戳
+     */
+    private final long timestamp;
+    /**
+     * 实体
+     */
+    private final Object entity;
+
+    public DomainEvent(Object entity) {
+        this.entity = entity;
+        this.entityClass = entity.getClass();
+        this.timestamp = System.currentTimeMillis();
+    }
+}

springboot-starter/src/main/java/com/codingapi/springboot/framework/domain/event/DomainPersistEvent.java

@@ -1,20 +1,14 @@
 package com.codingapi.springboot.framework.domain.event;
 
-import com.codingapi.springboot.framework.event.IEvent;
 import lombok.Getter;
-import lombok.ToString;
 
+/**
+ * 实体持久化事件
+ */
 @Getter
-@ToString
-public class DomainPersistEvent implements IEvent {
-
-    private final Object entity;
-    private final String simpleName;
-    private final long timestamp;
+public class DomainPersistEvent extends DomainEvent {
 
     public DomainPersistEvent(Object entity) {
-        this.entity = entity;
-        this.simpleName = entity.getClass().getSimpleName();
-        this.timestamp = System.currentTimeMillis();
+        super(entity);
     }
 }

springboot-starter/src/main/java/com/codingapi/springboot/framework/domain/event/FieldChangeEvent.java

@@ -1,46 +1,33 @@
 package com.codingapi.springboot.framework.domain.event;
 
-import com.codingapi.springboot.framework.event.IEvent;
 import lombok.Getter;
-import lombok.Setter;
 import lombok.ToString;
 
 /**
  * 实体字段变更事件
  */
-@Setter
 @Getter
-@ToString(exclude = {"entity"})
-public class FieldChangeEvent implements IEvent {
-
-    /**
-     * 实体对象
-     */
-    private Object entity;
-
-    /**
-     * 实体类名称
-     */
-    private String simpleName;
-
-    /**
-     * 时间戳
-     */
-    private long timestamp;
+@ToString(callSuper = true)
+public class FieldChangeEvent extends DomainEvent {
 
     /**
      * 字段名称
      */
-    private String fieldName;
+    private final String fieldName;
     /**
      * 旧的值
      */
-    private Object oldValue;
+    private final Object oldValue;
     /**
      * 新的值
      */
-    private Object newValue;
-
-
+    private final Object newValue;
+
+    public FieldChangeEvent(Object entity, String fieldName, Object oldValue, Object newValue) {
+        super(entity);
+        this.fieldName = fieldName;
+        this.oldValue = oldValue;
+        this.newValue = newValue;
+    }
 
 }

springboot-starter/src/main/java/com/codingapi/springboot/framework/domain/proxy/FieldValueInterceptor.java

@@ -145,14 +145,7 @@ private void compareAndUpdateField() throws InvocationTargetException, IllegalAc
         }
     }
 
-    private void pushEvent(String field, Object oldValue, Object newValue) {
-        FieldChangeEvent event = new FieldChangeEvent();
-        event.setEntity(target);
-        event.setSimpleName(targetClass.getSimpleName());
-        event.setFieldName(field);
-        event.setOldValue(oldValue);
-        event.setNewValue(newValue);
-        event.setTimestamp(System.currentTimeMillis());
-        EventPusher.push(event);
+    private void pushEvent(String fieldName, Object oldValue, Object newValue) {
+        EventPusher.push(new FieldChangeEvent(target,fieldName,oldValue,newValue));
     }
 }