print_scp.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_PRINT_SCP_HPP
#define PACS_SERVICES_PRINT_SCP_HPP
 
#include "scp_service.h"
 
#include <kcenon/pacs/core/dicom_dataset.h>
 
#include <atomic>
#include <cstdint>
#include <functional>
#include <mutex>
#include <string>
#include <unordered_map>
#include <vector>
 
namespace kcenon::pacs::services {
 
// =============================================================================
// Print Management SOP Class UIDs (PS3.4 Annex H)
// =============================================================================
 
inline constexpr std::string_view basic_film_session_sop_class_uid =
    "1.2.840.10008.5.1.1.1";
 
inline constexpr std::string_view basic_film_box_sop_class_uid =
    "1.2.840.10008.5.1.1.2";
 
inline constexpr std::string_view basic_grayscale_image_box_sop_class_uid =
    "1.2.840.10008.5.1.1.4";
 
inline constexpr std::string_view basic_color_image_box_sop_class_uid =
    "1.2.840.10008.5.1.1.4.1";
 
inline constexpr std::string_view printer_sop_class_uid =
    "1.2.840.10008.5.1.1.16";
 
inline constexpr std::string_view basic_grayscale_print_meta_sop_class_uid =
    "1.2.840.10008.5.1.1.9";
 
inline constexpr std::string_view basic_color_print_meta_sop_class_uid =
    "1.2.840.10008.5.1.1.18";
 
// =============================================================================
// Print Management Types
// =============================================================================
 
enum class printer_status {
    normal,    
    warning,   
    failure    
};
 
[[nodiscard]] inline auto to_string(printer_status status) -> std::string_view {
    switch (status) {
        case printer_status::normal:
            return "NORMAL";
        case printer_status::warning:
            return "WARNING";
        case printer_status::failure:
            return "FAILURE";
        default:
            return "NORMAL";
    }
}
 
enum class print_job_status {
    pending,     
    printing,    
    done,        
    failure      
};
 
struct film_session {
    std::string sop_instance_uid;
 
    uint32_t number_of_copies{1};
 
    std::string print_priority{"MED"};
 
    std::string medium_type{"BLUE FILM"};
 
    std::string film_destination{"MAGAZINE"};
 
    std::vector<std::string> film_box_uids;
 
    core::dicom_dataset data;
};
 
struct film_box {
    std::string sop_instance_uid;
 
    std::string film_session_uid;
 
    std::string image_display_format{"STANDARD\\1,1"};
 
    std::string film_orientation{"PORTRAIT"};
 
    std::string film_size_id{"8INX10IN"};
 
    std::vector<std::string> image_box_uids;
 
    core::dicom_dataset data;
};
 
struct image_box {
    std::string sop_instance_uid;
 
    std::string film_box_uid;
 
    uint16_t image_position{1};
 
    bool has_pixel_data{false};
 
    core::dicom_dataset data;
};
 
// =============================================================================
// Handler Types
// =============================================================================
 
using print_session_handler = std::function<network::Result<std::monostate>(
    const film_session& session)>;
 
using print_action_handler = std::function<network::Result<std::monostate>(
    const std::string& film_box_uid)>;
 
using printer_status_handler = std::function<
    network::Result<std::pair<printer_status, core::dicom_dataset>>()>;
 
// =============================================================================
// Print SCP Class
// =============================================================================
 
class print_scp final : public scp_service {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    explicit print_scp(std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~print_scp() override = default;
 
    // =========================================================================
    // Configuration
    // =========================================================================
 
    void set_session_handler(print_session_handler handler);
 
    void set_print_handler(print_action_handler handler);
 
    void set_printer_status_handler(printer_status_handler handler);
 
    // =========================================================================
    // scp_service Interface Implementation
    // =========================================================================
 
    [[nodiscard]] std::vector<std::string> supported_sop_classes() const override;
 
    [[nodiscard]] network::Result<std::monostate> handle_message(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request) override;
 
    [[nodiscard]] std::string_view service_name() const noexcept override;
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] size_t sessions_created() const noexcept;
    [[nodiscard]] size_t film_boxes_created() const noexcept;
    [[nodiscard]] size_t images_set() const noexcept;
    [[nodiscard]] size_t prints_executed() const noexcept;
    [[nodiscard]] size_t printer_queries() const noexcept;
    void reset_statistics() noexcept;
 
private:
    // =========================================================================
    // DIMSE-N Command Handlers
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> handle_n_create(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    [[nodiscard]] network::Result<std::monostate> handle_n_set(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    [[nodiscard]] network::Result<std::monostate> handle_n_get(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    [[nodiscard]] network::Result<std::monostate> handle_n_action(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    [[nodiscard]] network::Result<std::monostate> handle_n_delete(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    // =========================================================================
    // SOP-specific Create Handlers
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> create_film_session(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    [[nodiscard]] network::Result<std::monostate> create_film_box(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    // =========================================================================
    // Response Helpers
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> send_response(
        network::association& assoc,
        uint8_t context_id,
        network::dimse::command_field response_type,
        uint16_t message_id,
        std::string_view sop_class_uid,
        const std::string& sop_instance_uid,
        network::dimse::status_code status);
 
    // =========================================================================
    // UID Generation
    // =========================================================================
 
    [[nodiscard]] auto generate_uid() -> std::string;
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    print_session_handler session_handler_;
    print_action_handler print_handler_;
    printer_status_handler printer_status_handler_;
 
    std::unordered_map<std::string, film_session> sessions_;
 
    std::unordered_map<std::string, film_box> film_boxes_;
 
    std::unordered_map<std::string, image_box> image_boxes_;
 
    mutable std::mutex mutex_;
 
    std::atomic<uint32_t> uid_counter_{0};
 
    std::atomic<size_t> sessions_created_{0};
    std::atomic<size_t> film_boxes_created_{0};
    std::atomic<size_t> images_set_{0};
    std::atomic<size_t> prints_executed_{0};
    std::atomic<size_t> printer_queries_{0};
};
 
// =============================================================================
// Print-specific DICOM Tags (PS3.4 Annex H)
// =============================================================================
 
namespace print_tags {
 
inline constexpr core::dicom_tag number_of_copies{0x2000, 0x0010};
 
inline constexpr core::dicom_tag print_priority{0x2000, 0x0020};
 
inline constexpr core::dicom_tag medium_type{0x2000, 0x0030};
 
inline constexpr core::dicom_tag film_destination{0x2000, 0x0040};
 
inline constexpr core::dicom_tag film_session_label{0x2000, 0x0050};
 
inline constexpr core::dicom_tag image_display_format{0x2010, 0x0010};
 
inline constexpr core::dicom_tag film_orientation{0x2010, 0x0040};
 
inline constexpr core::dicom_tag film_size_id{0x2010, 0x0050};
 
inline constexpr core::dicom_tag magnification_type{0x2010, 0x0060};
 
inline constexpr core::dicom_tag referenced_film_session_sequence{0x2010, 0x0500};
 
inline constexpr core::dicom_tag referenced_image_box_sequence{0x2010, 0x0510};
 
inline constexpr core::dicom_tag image_position{0x2020, 0x0010};
 
inline constexpr core::dicom_tag basic_grayscale_image_sequence{0x2020, 0x0110};
 
inline constexpr core::dicom_tag basic_color_image_sequence{0x2020, 0x0111};
 
inline constexpr core::dicom_tag printer_status_tag{0x2110, 0x0010};
 
inline constexpr core::dicom_tag printer_status_info{0x2110, 0x0020};
 
inline constexpr core::dicom_tag printer_name{0x2110, 0x0030};
 
}  // namespace print_tags
 
}  // namespace kcenon::pacs::services
 
#endif  // PACS_SERVICES_PRINT_SCP_HPP