From 81409bd47e189642f0b5989e727ae6ac2894583e Mon Sep 17 00:00:00 2001 From: songyunpeng Date: Mon, 11 May 2020 18:00:39 +0800 Subject: [PATCH] =?UTF-8?q?AOP-=E6=93=8D=E4=BD=9C=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../esua/epdc/pointcommons/tools/aop/UserBehaviorAop.java | 2 ++ .../epdc/pointcommons/tools/rocketmq/dto/BehaviorDto.java | 5 +++++ .../java/com/elink/esua/epdc/mq/PointsModifyConsumer.java | 2 +- .../main/java/com/elink/esua/epdc/mq/dto/BehaviorDto.java | 7 +++++++ 4 files changed, 15 insertions(+), 1 deletion(-) diff --git a/esua-epdc/epdc-commons/epdc-commons-points-tools/src/main/java/com/elink/esua/epdc/pointcommons/tools/aop/UserBehaviorAop.java b/esua-epdc/epdc-commons/epdc-commons-points-tools/src/main/java/com/elink/esua/epdc/pointcommons/tools/aop/UserBehaviorAop.java index 2839ae0d..82f135ba 100644 --- a/esua-epdc/epdc-commons/epdc-commons-points-tools/src/main/java/com/elink/esua/epdc/pointcommons/tools/aop/UserBehaviorAop.java +++ b/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)); } diff --git a/esua-epdc/epdc-commons/epdc-commons-points-tools/src/main/java/com/elink/esua/epdc/pointcommons/tools/rocketmq/dto/BehaviorDto.java b/esua-epdc/epdc-commons/epdc-commons-points-tools/src/main/java/com/elink/esua/epdc/pointcommons/tools/rocketmq/dto/BehaviorDto.java index 6dbf3e50..31450da9 100644 --- a/esua-epdc/epdc-commons/epdc-commons-points-tools/src/main/java/com/elink/esua/epdc/pointcommons/tools/rocketmq/dto/BehaviorDto.java +++ b/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; } diff --git a/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/PointsModifyConsumer.java b/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/PointsModifyConsumer.java index e9bbee84..df5b7e39 100644 --- a/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/PointsModifyConsumer.java +++ b/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 { 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); diff --git a/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/dto/BehaviorDto.java b/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/dto/BehaviorDto.java index 269e8b25..7f176364 100644 --- a/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/mq/dto/BehaviorDto.java +++ b/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; + }