quyixiao/eb-service-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

jruqwhnt

Browse Source
This commit is contained in:
quyixiao 2025-10-20 23:14:08 +08:00
parent 991ea4cf77
commit b23c130ff2
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java
View File

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