Feature
Jira Legacy | ||||||
---|---|---|---|---|---|---|
|
...
Step№ | Module | Task | Event published on task completion | ||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
1 | mod-data-import | Sends a batch of records to Kafka queue | DI_RAW_RECORDS_CHUNK_READ | ||||||||
2 | mod-source-record-manager | Reads batches from the queue, validate them and publishes events - since JobProfile contains an action for MARC_Bib update, original records are not saved in mod-srs. | DI_MARC_AUTHORITY_FOR_UPDATE_RECEIVED | ||||||||
3 | mod-source-record-storage | Tries to find entity according to match criteria, matches the incoming Marc Holdings record to the existing SRS Marc Holdings record, puts a matched record to Kafka queue. Matching works now only by 001 and 999 ff $s. Matching 010 $a or other tags requires implementing a spike
| DI_SRS_MARC_AUTHORITY_RECORD_MATCHED if the only 1 record found DI_SRS_MARC_AUTHORITY_RECORD_NOT_MATCHED if 0 or more than 1 record is found | ||||||||
4 | mod-source-record-storage | Receives the event from itself, modifies the record from the payload, retrieves and updates an existing SRS record by the modified version | DI_SRS_MARC_AUTHORITY_RECORD_MODIFIED_READY_FOR_POST_PROCESSING | ||||||||
5 | mod-inventory | Generates FOLIO Authority record from Marc SRS using default mapping rules, updates the existing FOLIO record (in mod-inventory-storage) by the generated version | DI_INVENTORY_AUTHORITY_UPDATED if there are other actions in the profile DI_COMPLETE if no more actions in profile |