AOP-操作时间

esua-epdc/epdc-commons/epdc-commons-points-tools/src/main/java/com/elink/esua/epdc/pointcommons/tools/aop/UserBehaviorAop.java

@@ -26,6 +26,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.lang.reflect.Method;
+import java.util.Date;
 
 /**
  * 积分埋点切面
@@ -159,6 +160,7 @@ public class UserBehaviorAop {
         behaviorDto.setBehavior(behaviorCode);
         behaviorDto.setReferenceId(referenceId);
         behaviorDto.setUserId(userId);
+        behaviorDto.setOperationTime(new Date());
         //发送mq
         pointsProducer.sendMessage(RocketMqConstant.MQ_TOPIC_POINTS, RocketMqConstant.MQ_TAG_POINTS, referenceId, JSONObject.toJSONString(behaviorDto));
     }

esua-epdc/epdc-commons/epdc-commons-points-tools/src/main/java/com/elink/esua/epdc/pointcommons/tools/rocketmq/dto/BehaviorDto.java

@@ -3,6 +3,7 @@ package com.elink.esua.epdc.pointcommons.tools.rocketmq.dto;
 import lombok.Data;
 
 import java.io.Serializable;
+import java.util.Date;
 
 /**
  * 用户行为DTO
@@ -40,5 +41,9 @@ public class BehaviorDto implements Serializable {
      */
     private String ortherFlag;
 
+    /**
+     * 操作时间
+     */
+    private Date operationTime;
 
 }

esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/PointsModifyConsumer.java

@@ -176,7 +176,7 @@ public class PointsModifyConsumer implements RocketMQListener<MessageExt> {
         pointsLogsAddFormDTO.setOperationType(pointsRuleResultDTO.getOperationType());
         pointsLogsAddFormDTO.setPoints(pointsRuleResultDTO.getPoints());
         pointsLogsAddFormDTO.setOperationDesc(pointsRuleResultDTO.getRuleDesc());
-        pointsLogsAddFormDTO.setOperationTime(new Date());
+        pointsLogsAddFormDTO.setOperationTime(dto.getOperationTime());
         pointsLogsAddFormDTO.setOperationMode("user");
         pointsLogsAddFormDTO.setLavePoints(userDTO.getPoints());
         PointsLogsEntity pointsLogsEntity = ConvertUtils.sourceToTarget(pointsLogsAddFormDTO, PointsLogsEntity.class);

esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/dto/BehaviorDto.java

@@ -1,8 +1,10 @@
 package com.elink.esua.epdc.mq.dto;
 
 import lombok.Data;
+import org.springframework.expression.Operation;
 
 import java.io.Serializable;
+import java.util.Date;
 
 /**
  * 用户行为DTO
@@ -40,5 +42,10 @@ public class BehaviorDto implements Serializable {
      */
     private String ortherFlag;
 
+    /**
+     * 操作时间
+     */
+    private Date operationTime;
+
 
 }