patient_reconciliation_service.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#ifndef PACS_SERVICES_PIR_PATIENT_RECONCILIATION_SERVICE_HPP
#define PACS_SERVICES_PIR_PATIENT_RECONCILIATION_SERVICE_HPP
 
#include "kcenon/pacs/core/dicom_dataset.h"
 
#include <chrono>
#include <map>
#include <optional>
#include <string>
#include <vector>
 
namespace kcenon::pacs::services::pir {
 
// =============================================================================
// PIR Operation Types
// =============================================================================
 
enum class reconciliation_type {
    demographics_update,  
    patient_merge,        
    patient_link          
};
 
// =============================================================================
// Data Structures
// =============================================================================
 
struct patient_demographics {
    std::optional<std::string> patient_name;
 
    std::optional<std::string> patient_id;
 
    std::optional<std::string> patient_birth_date;
 
    std::optional<std::string> patient_sex;
 
    std::optional<std::string> issuer_of_patient_id;
 
    std::optional<std::string> other_patient_ids;
};
 
struct demographics_update_request {
    std::string target_patient_id;
 
    patient_demographics updated_demographics;
 
    std::optional<std::string> reason;
 
    std::optional<std::string> operator_name;
};
 
struct patient_merge_request {
    std::string source_patient_id;
 
    std::string target_patient_id;
 
    std::optional<patient_demographics> target_demographics;
 
    std::optional<std::string> reason;
 
    std::optional<std::string> operator_name;
};
 
struct reconciliation_result {
    bool success{false};
 
    size_t instances_updated{0};
 
    size_t studies_affected{0};
 
    std::string error_message;
 
    reconciliation_type type;
 
    std::chrono::system_clock::time_point timestamp{
        std::chrono::system_clock::now()};
};
 
struct reconciliation_audit_record {
    std::string record_id;
 
    reconciliation_type type;
 
    std::string primary_patient_id;
    std::optional<std::string> secondary_patient_id;
 
    std::string operator_name;
 
    size_t instances_updated{0};
 
    std::chrono::system_clock::time_point timestamp;
 
    bool success{false};
};
 
// =============================================================================
// Patient Reconciliation Service
// =============================================================================
 
class patient_reconciliation_service {
public:
    patient_reconciliation_service() = default;
 
    bool add_instance(const core::dicom_dataset& dataset);
 
    [[nodiscard]] reconciliation_result update_demographics(
        const demographics_update_request& request);
 
    [[nodiscard]] reconciliation_result merge_patients(
        const patient_merge_request& request);
 
    [[nodiscard]] std::vector<core::dicom_dataset> find_instances(
        const std::string& patient_id) const;
 
    [[nodiscard]] size_t instance_count() const noexcept;
 
    [[nodiscard]] std::vector<std::string> get_patient_ids() const;
 
    [[nodiscard]] const std::vector<reconciliation_audit_record>&
    audit_trail() const noexcept;
 
    [[nodiscard]] std::vector<reconciliation_audit_record>
    audit_trail_for_patient(const std::string& patient_id) const;
 
private:
    void apply_demographics(core::dicom_dataset& dataset,
                            const patient_demographics& demographics) const;
    std::string generate_record_id() const;
 
    std::vector<core::dicom_dataset> instances_;
    std::vector<reconciliation_audit_record> audit_records_;
};
 
[[nodiscard]] std::string to_string(reconciliation_type type);
 
}  // namespace kcenon::pacs::services::pir
 
#endif  // PACS_SERVICES_PIR_PATIENT_RECONCILIATION_SERVICE_HPP