From b23c130ff2dcc2871f5a674295f2455d87d10260 Mon Sep 17 00:00:00 2001 From: quyixiao <2621048238@qq.com> Date: Mon, 20 Oct 2025 23:14:08 +0800 Subject: [PATCH] jruqwhnt --- .../heyu/api/listener/VVUrlQueueSimpleRabbitListener.java | 5 +++++ 1 file changed, 5 insertions(+) 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);