diff --git a/api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java b/api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java index d3f53e4..ab25c12 100644 --- a/api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java +++ b/api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java @@ -3,6 +3,7 @@ package com.heyu.api.listener; import com.alibaba.fastjson.JSONObject; import com.heyu.api.data.dao.vv.VvRequestLogDao; import com.heyu.api.data.entity.vv.VvRequestLogEntity; +import com.heyu.api.data.utils.DateUtils; import com.rabbitmq.client.Channel; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.annotation.RabbitHandler; @@ -15,6 +16,7 @@ import org.springframework.messaging.handler.annotation.Payload; import org.springframework.stereotype.Component; import java.io.IOException; +import java.util.Date; @Component @Slf4j @@ -33,6 +35,9 @@ public class VVUrlQueueSimpleRabbitListener { public void consumeMessage(@Payload String message, @Header(AmqpHeaders.DELIVERY_TAG) long delivertTag, Channel channel) { try { VvRequestLogEntity vvRequestLogEntity = JSONObject.parseObject(message, VvRequestLogEntity.class); + vvRequestLogEntity.setCreateTimestamp(System.currentTimeMillis()); + + vvRequestLogEntity.setCreateDay(DateUtils.formatDate(new Date(), DateUtils.YYYY_MM_DD)); vvRequestLogDao.insert(vvRequestLogEntity); } catch (Exception e) { log.error("urlStatisticQueue handle", e);