Commit graph

439 commits

Author SHA1 Message Date
etreschenkov
8ebf8175da Block Kafka event writer on empty queue 2026-07-15 07:59:42 +03:00
etreschenkov
9e7c084712 Deduplicate Kafka signal processors 2026-07-15 07:59:15 +03:00
etreschenkov
50c346018b KafkaSignalProcessor refactoring 2026-07-14 15:02:11 +03:00
etreschenkov
292c288efe Refactor Kafka monitoring processing 2026-07-14 10:42:26 +03:00
Mikhail Trofimov
005e228bba Get rid of InquiryDateDeserializer; Changed ack mode 2026-07-10 09:52:39 +03:00
Mikhail Trofimov
55700d46aa Fix inaccuracy 2026-07-09 17:00:41 +03:00
Mikhail Trofimov
77f217e0f8 Minor refactoring 2026-07-09 16:51:21 +03:00
Mikhail Trofimov
59b074b2da get rid of setting reject status 2026-07-06 09:56:30 +03:00
Mikhail Trofimov
7004a1b7e3 get rid of external_package_name, FID_CHANGED, PROCESSING_REPEATED, NO_FID 2026-07-06 09:54:30 +03:00
Mikhail Trofimov
0cfe976670 Added ReportNameRegistry to store generated report names for hits writing 2026-07-05 14:15:41 +03:00
Mikhail Trofimov
2d75350f75 get rid of kafka producer bean 2026-07-05 12:57:52 +03:00
Mikhail Trofimov
20ec6871d5 get rid of InnRegnumPair record 2026-07-05 12:22:55 +03:00
Mikhail Trofimov
bcfe0328f0 Fix chache selecting for LP 2026-07-05 11:56:40 +03:00
Mikhail Trofimov
bbc7c64acf Fix bean creating; fix has fid logic (NO_FID status) 2026-07-05 11:40:50 +03:00
Mikhail Trofimov
e115919f1a Async db writing 2026-07-04 19:10:41 +03:00
Mikhail Trofimov
5d09e25e87 LP: Added restore logic 2026-07-04 18:33:48 +03:00
Mikhail Trofimov
d84763b754 Added separate executors 2026-07-04 18:26:36 +03:00
Mikhail Trofimov
2c0525d28d Save last downloaded report name 2026-07-03 17:54:56 +03:00
Mikhail Trofimov
4bd58624ed Added hits inserting 2026-07-03 17:25:54 +03:00
Mikhail Trofimov
1813647170 Added hits field to ddl 2026-07-03 16:40:03 +03:00
Mikhail Trofimov
d3fc6ce7e8 Added enew env for lp batch size saving 2026-07-03 15:59:31 +03:00
Mikhail Trofimov
e6edf52d16 Added env vars for 2 types of pipelines 2026-07-03 15:55:51 +03:00
Mikhail Trofimov
a93ed1ccb4 Fix monitoring process destroy 2026-07-03 15:29:11 +03:00
Mikhail Trofimov
0c977947cd LP: aAdded updating fids for lp; Added abstraction for PipelineOrchestrators 2026-07-03 15:27:24 +03:00
Mikhail Trofimov
9a9ba6b803 LP: added last rejecting date calculating 2026-07-03 09:32:25 +03:00
Mikhail Trofimov
bc78b389e7 NP: get rid of unused kick pipelines;
LP: added lp kick pipelines with data loading
2026-07-02 17:09:39 +03:00
Mikhail Trofimov
012d7085ad LP: added build for fids loading 2026-07-02 16:11:37 +03:00
Mikhail Trofimov
e94df35c76 LP: added LpFidEnricher 2026-07-02 15:37:08 +03:00
Mikhail Trofimov
58e7f9ef4b NP: delete unused data classes 2026-07-02 12:50:45 +03:00
Mikhail Trofimov
44512925f4 NP: get rid of SignalRestService and personal data loading/saving 2026-07-02 12:50:07 +03:00
Mikhail Trofimov
2709eaeb19 LP: added flags update by cron 2026-06-30 16:51:28 +03:00
Mikhail Trofimov
05ae297474 LP: added dummy LpPipelinePackageFabric 2026-06-30 15:43:07 +03:00
Mikhail Trofimov
ef5aaf418a LP: Rename PipelinePackageFabric to NpPipelinePackageFabric 2026-06-30 15:18:13 +03:00
Mikhail Trofimov
3921087946 LP: added subject registration 2026-06-30 14:06:52 +03:00
Mikhail Trofimov
6767a8c204 LP: added package registration 2026-06-30 13:50:25 +03:00
Mikhail Trofimov
15c651debd LP: added package validation 2026-06-30 12:56:53 +03:00
Mikhail Trofimov
50b8eeee89 Increase batch 2026-06-30 12:25:47 +03:00
Mikhail Trofimov
ecbea33a7e Added kafka settings to props 2026-06-29 16:51:14 +03:00
Mikhail Trofimov
d958d73609 Fix lp UserPackageLegalData selecting 2026-06-29 15:55:57 +03:00
Mikhail Trofimov
a3a1debe45 Drain ivents from queue 2026-06-29 15:45:42 +03:00
Mikhail Trofimov
c5ace5e151 Fix Source selecting 2026-06-29 15:21:47 +03:00
Mikhail Trofimov
a1f4b86f99 Added zipping response 2026-06-29 10:55:49 +03:00
Mikhail Trofimov
61f2420ca4 Added writing to xml for lp 2026-06-25 15:16:35 +03:00
Mikhail Trofimov
a7a59c0c10 Added processing for legal persons 2026-06-25 14:48:12 +03:00
Mikhail Trofimov
5982819965 Added writing to xml for np 2026-06-25 11:31:03 +03:00
ialbert
1f142cf2a8 KafkaMonitoringService graceful shutdown 2026-06-24 17:45:47 +03:00
Mikhail Trofimov
c0421f28af minor fix 2026-06-24 11:26:40 +03:00
Mikhail Trofimov
b9973f8cdd Added signals_segment_map table; complete data preparing for natural persons 2026-06-24 11:04:04 +03:00
Mikhail Trofimov
ec93c4b726 Use semaphore instead of AtomicInteger counter 2026-06-23 15:35:35 +03:00
Mikhail Trofimov
d9f23cdff9 Prepare data for writing 2026-06-22 17:21:51 +03:00