micord/ervu-lkrp-ul
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-9561: add messageId

Browse source
This commit is contained in:
gulnaz 2025-11-25 20:12:05 +03:00
parent 5e4dc38609
commit 93d276008d
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
backend/src/main/java/ru/micord/ervu/controller/ExcerptController.java
View file

@ -1,14 +1,17 @@
package ru.micord.ervu.controller; package ru.micord.ervu.controller;
import java.nio.charset.StandardCharsets;
import java.time.ZonedDateTime; import java.time.ZonedDateTime;
import java.util.Optional; import java.util.Optional;
import java.util.TimeZone; import java.util.TimeZone;
import java.util.UUID;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import ervu.client.fileupload.WebDavClient; import ervu.client.fileupload.WebDavClient;
import ervu_lkrp_ul.ervu_lkrp_ul.db_beans.public_.tables.records.ExcerptHistoryRecord; import ervu_lkrp_ul.ervu_lkrp_ul.db_beans.public_.tables.records.ExcerptHistoryRecord;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
@ -70,7 +73,11 @@ public class ExcerptController {
.getOffset().getId(); .getOffset().getId();
data.setTimeZone(offset); data.setTimeZone(offset);
data.setYear(year); data.setYear(year);
kafkaTemplate.send(requestTopic, objectMapper.writeValueAsString(data)).get(); String messageId = UUID.randomUUID().toString();
ProducerRecord<String, String> record = new ProducerRecord<>(requestTopic,
objectMapper.writeValueAsString(data));
record.headers().add("messageId", messageId.getBytes(StandardCharsets.UTF_8));
kafkaTemplate.send(record).get();
excerptHistoryDao.delete(ervuId, prnOid); excerptHistoryDao.delete(ervuId, prnOid);
excerptHistoryDao.insert(ervuId, prnOid); excerptHistoryDao.insert(ervuId, prnOid);
} }