【Dcmtk】Pacs-小型dicom数据库（sqlite）

Good

前言：
  要做一个简单的开源dcm浏览器 KISS Dicom Viewer ，小型pacs服务肯定必不可少。开发中到处找现成代码，基本上找到的资源都是一个发布版，很少有可以用来研究的源码。 KISS Dicom Viewer 目前处于开发阶段，最近几篇博客就用来记录下开发一个小型pacs数据库（Qt+Dcmtk）的过程。提供服务包括：通讯测试echo、远程查询findscu、远程下载get/move、本机存储storescp。
  Dicom协议、通讯原理等等，网上有很多优秀的中文博客来说明，这里就不介绍了。

---

  如果你需要定义自己的 dicom数据库，可以看下我整理的：

---

1. 数据库结构

  正常的完善的pacs系统的话一般是搞四张表，分别存储 PATIENT、STUDY、SERIES、IMAGE。因为我仅仅是开发一个小型的dcm浏览器，数据就建两张表 STUDY 和 IMAGE。

创建语句

1. str = "CREATE TABLE IF NOT EXISTS StudyTable("
2.           "StudyUid VARCHAR(128) PRIMARY KEY NOT NULL,"
3.           "AccNumber VARCHAR(64) NOT NULL, PatientId VARCHAR(64) NOT NULL,"
4.           "PatientName VARCHAR(64), "
5.           "PatientSex VARCHAR(2) NOT NULL,"
6.           "PatientBirth DATE NOT NULL,"
7.           "PatientAge VARCHAR(6),"
8.           "StudyTime DATETIME NOT NULL,"
9.           "Modality VARCHAR(2) NOT NULL, "
10.           "StudyDesc TEXT)";
11. str = "CREATE TABLE IF NOT EXISTS ImageTable("
12.           "ImageUid VARCHAR(128) PRIMARY KEY NOT NULL,"
13.           "SopClassUid VARCHAR(128) NOT NULL,"
14.           "SeriesUid VARCHAR(128) NOT NULL, "
15.           "StudyUid VARCHAR(128) NOT NULL,"
16.           "RefImageUid VARCHAR(128),"
17.           "ImageNo VARCHAR(16), "
18.           "ImageTime DATETIME NOT NULL,"
19.           "ImageDesc TEXT,"
20.           "ImageFile TEXT,"
21.           "FOREIGN KEY(StudyUid) REFERENCES StudyTable(StudyUid))";

复制代码

2. 数据库可视化 QSqlTableModel+QTableView

  qt对于数据库的可视化封装基本上很完善了，sqlmode+tableview 可以快速实现数据库的可视化。只有两张表 STUDY 和 IMAGE，就是上边选中STUDY后下边的IMAGE会对应弹出该STUDY的IMAGE。

1. class SqlImageModel : public QSqlTableModel {
2.     Q_OBJECT
3.   public:
4.     enum ColumnType {
5.         ImageUid,
6.         SopClassUid,
7.         SeriesUid,
8.         StudyUid,
9.         RefImageUid,
10.         ImageNo,
11.         ImageTime,
12.         ImageDesc,
13.         ImageFile,
14.         ColumnCount,
15.     };
16.     explicit SqlImageModel(QObject *parent = nullptr, QSqlDatabase db = QSqlDatabase());
17.     QVariant headerData(int section, Qt::Orientation orientation = Qt::Horizontal,
18.                         int role = Qt::DisplayRole) const;
20.     QStringList getAllImageFiles() const;
21.   Q_SIGNALS:
22.     void viewImages(const QStringList &imageFiles);
23.     void Signal_RemoveFinished();
24.   public Q_SLOTS:
25.     bool select();
26.   public Q_SLOTS:
27.     void SLot_ViewImages(const QModelIndexList &indexes);
28.     void SLot_ViewAllImages();
29.     void Slot_RemoveImages(const QModelIndexList &indexes);
30.     void Slot_RemoveAllImages();
31.     void Slot_StudySelected(const QStringList &studyUids);
34. };

复制代码

1. class SqlStudyModel : public QSqlTableModel {
2.     Q_OBJECT
3.   public:
4.     enum ColumnType {
5.         StudyUid,
6.         AccNumber,
7.         PatientId,
8.         PatientName,
9.         PatientSex,
10.         PatientBirth,
11.         PatientAge,
12.         StudyTime,
13.         Modality,
14.         StudyDesc,
15. //        ColumnCount,
16.     };
18.     explicit SqlStudyModel(QObject *parent = nullptr,
19.                            QSqlDatabase db = QSqlDatabase());
21.     QVariant headerData(int section,
22.                         Qt::Orientation orientation, int role = Qt::DisplayRole) const;
23.     QVariant data(const QModelIndex &index, int role = Qt::DisplayRole) const;
24.     QString getFirstSelectedStudyUid() const;
26.   public Q_SLOTS:
27.     bool select();
29.   Q_SIGNALS:
30.     void Signal_studySelectionChanged(const QStringList &studyUids);
31.     void Signal_NewStudy(const QSqlRecord &studyRec);
32.     void Signal_NewImage(const QSqlRecord &studyRec);
33.     void Signal_RemoveFinished();
35.   public Q_SLOTS:
36.     void Slot_SelectionChanged(const QModelIndexList &indexes);
37.     void Slot_RemoveStudies();
38.     void Slot_NewStudy(const QModelIndex &index);
39.     void Slot_NewImage(const QModelIndex &index);
41.   private:
42.     QStringList selected_study_uids_;
43.     StudyRecord *mod_study_;
44.     int modify_row_;
46. };

复制代码

1. class SqlStudyTabView : public KissTabView {
2.     Q_OBJECT
3.   public:
4.     explicit SqlStudyTabView(QAbstractTableModel *model, QWidget *parent = nullptr);
5.     ~SqlStudyTabView() {}
6.   Q_SIGNALS:
7.     void Signal_ViewImages();
8.     void Signal_RemoveStudies();
9.     void Singal_StudySelectionChanged(const QModelIndexList &indexes);
10.   protected slots:
11.     void selectionChanged(const QItemSelection &selected,
12.                           const QItemSelection &deselected);
13.     void contextMenuEvent(QContextMenuEvent *e);
14.   private:
15.     void SetupContextMenu();
16.     void HideColumns();
17.   private:
18.     QStringList study_uids_;
19.     QAction *view_image_;
20.     QAction *remove_study_;
21. };

复制代码

1. class SqlImageTabView : public KissTabView {
2.     Q_OBJECT
3.   public:
4.     explicit SqlImageTabView(QAbstractTableModel *model, QWidget *parent = nullptr);
5.     ~SqlImageTabView() {}
6.   Q_SIGNALS:
7.     void Signal_ViewImages(const QModelIndexList &indexes);
8.     void Signal_RemoveImages(const QModelIndexList &indexes);
9.   private:
10.     void SetupContextMenu();
11.     void HideColumns();
12.   private:
13.     QAction *view_image_action_;
14.     QAction *remove_image_action_;
15. };

复制代码

3. 数据库查询

  QSqlTableModel可以很快速便捷的实现模型的检索

1. void StudyExplorerWidget::SetStudyFilter() {
2.     QString filter, temp;
3.     if (ui->fromCheckBox->isChecked()) {
4.         filter = QString("StudyTime>\'%1\'").arg(
5.                      ui->fromDateTimeEdit->dateTime().toString("yyyy-MM-dd hh:mm:ss"));
6.     }
7.     if (ui->toCheckBox->isChecked()) {
8.         if (!filter.isEmpty()) {
9.             filter.append(" and ");
10.         }
11.         filter.append(QString("StudyTime<\'%1\'").arg(
12.                           ui->toDateTimeEdit->dateTime().toString("yyyy-MM-dd hh:mm:ss")));
13.     }
14.     if (!ui->modalityCombo->currentText().isEmpty()) {
15.         if (!filter.isEmpty()) {
16.             filter.append(" and ");
17.         }
18.         filter.append(QString("Modality=\'%1\'").arg(ui->modalityCombo->currentText()));
19.     }
20.     if (!ui->patientIDEdit->text().isEmpty()) {
21.         temp = ui->patientIDEdit->text();
22.         temp.replace(QChar('*'), QChar('%'));
23.         temp.replace(QChar('?'), QChar('_'));
24.         if (!filter.isEmpty()) {
25.             filter.append(" and ");
26.         }
27.         filter.append(QString("PatientId LIKE \'%%1%\'").arg(temp));
28.     }
29.     if (!ui->patientNameEdit->text().isEmpty()) {
30.         temp = ui->patientNameEdit->text();
31.         temp.replace(QChar('*'), QChar('%'));
32.         temp.replace(QChar('?'), QChar('_'));
33.         if (!filter.isEmpty()) {
34.             filter.append(" and ");
35.         }
36.         filter.append(QString("PatientName LIKE \'%%1%\'").arg(temp));
37.     }
38.     if (!ui->accNumberEdit->text().isEmpty()) {
39.         temp = ui->accNumberEdit->text();
40.         temp.replace(QChar('*'), QChar('%'));
41.         temp.replace(QChar('?'), QChar('_'));
42.         if (!filter.isEmpty()) {
43.             filter.append(" and ");
44.         }
45.         filter.append(QString("AccNumber LIKE \'%%1%\'").arg(temp));
46.     }
47.     this->RefreshReadStudyModel(filter);
48. }
50. void StudyExplorerWidget::RefreshReadStudyModel(const QString &filter) {
51.     bool close = false;
52.     if(DbManager::IsOpenedDb()) {
53.     } else {
54.         if (DbManager::OpenDb()) {
55.             close = true;
56.         }
57.     }
58.     study_model_->setFilter(filter);
59.     study_model_->select();
60.     if(close) {
61.         DbManager::CloseDb();
62.     }
63. }

复制代码

4. 数据库增删改查

  需求很简单，我这里使用sql语句实现。

1. #ifndef STUDYDAO_H
2. #define STUDYDAO_H
4. #include "Db/dbmanager.h"
6. class StudyRecord;
7. class ImageRecord;
9. class StudyDao : public QObject {
10.     Q_OBJECT
11.   public:
12.     static const QString study_table_name_;
13.     static const QString image_table_name_;
14.   public:
15.     explicit StudyDao(QObject *parent = nullptr);
16.     virtual ~StudyDao() override;
17.     bool InsertStudyToDb(const StudyRecord &study, bool imported = false);
18.     bool RemoveStudyFromDb(const QString &study_uid);
19.     bool VerifyStudyByStuid(const QString &study_uid);
20.     //
21.     bool InsertImageToDb(const ImageRecord &image, bool imported = false);
22.     bool RemoveImageFromDb(const QString &image_uid, bool updateStudy = true);
23.     bool RemoveAllImagesOfStudyFromDb(const QString &study_uid, bool updateStudy = true);
24.     bool UpdateImageFile(const QString &image_uid, const QString &image_file);
25.     bool VerifyImageByIMmuid(const QString &image_uid);
26.   public:
27.     static bool Initial();
28.   private:
29.     static bool CreateTable();
30.     static bool CheckTable();
31.   private:
32. };
34. #endif // STUDYDAO_H

复制代码

1. #include "studydao.h"
2. #include <Global/KissGlobal>
5. const QString StudyDao::study_table_name_ = "StudyTable";
6. const QString StudyDao::image_table_name_ = "ImageTable";
8. StudyDao::StudyDao(QObject *parent):
9.     QObject(parent) {
10. }
12. StudyDao::~StudyDao() {
13. }
15. bool StudyDao::InsertStudyToDb(const StudyRecord &study, bool imported) {
16.     Q_UNUSED(imported)
17.     bool success = false;
18.     if(DbManager::OpenDb()) {
19.         QMap<QString, QVariant> data;
20.         data.insert("StudyUid", study.study_uid_);
21.         data.insert("AccNumber", study.acc_number_);
22.         data.insert("PatientId", study.patient_id_);
23.         data.insert("PatientName", study.patient_name_);
24.         data.insert("PatientSex", study.patient_sex_);
25.         if(study.patient_birth_.toString("yyyy-MM-dd").isEmpty()) {
26.             data.insert("PatientBirth", "");
27.         } else {
28.             data.insert("PatientBirth", study.patient_birth_.toString("yyyy-MM-dd"));
29.         }
30.         data.insert("PatientAge", study.patient_age_);
31.         data.insert("StudyTime", study.study_time_.toString(NORMAL_DATETIME_FORMAT));
32.         data.insert("Modality", study.modality_);
33.         data.insert("StudyDesc", study.study_desc_);
34.         if (DbManager::insert(study_table_name_, data)) {
35.             success = true;
36.         }
37.     }
38.     DbManager::CloseDb();
39.     return success;
40. }
42. bool StudyDao::RemoveStudyFromDb(const QString &study_uid) {
43.     bool success = false;
44.     if (study_uid.isEmpty()) {
45.         return false;
46.     }
47.     if(DbManager::OpenDb()) {
48.         QString where = QString("StudyUid = '%1'").arg(study_uid);
49.         if (DbManager::remove(study_table_name_, where)) {
50.             success = true;
51.         }
52.     }
53.     DbManager::CloseDb();
54.     this->RemoveAllImagesOfStudyFromDb(study_uid, false);
55.     return success;
56. }
58. /**
59. * @brief StudyDao::VerifyStudyByStuid
60. * @param study_uid
61. * @return
62. */
63. bool StudyDao::VerifyStudyByStuid(const QString &study_uid) {
64.     bool success = false;
65.     if (study_uid.isEmpty()) {
66.         return false;
67.     }
68.     if(DbManager::OpenDb()) {
69.         QStringList key_list;
70.         key_list.append("StudyUid");
71.         QString where = QString("StudyUid = '%1'").arg(study_uid);
72.         QList<QMap<QString, QVariant>> res;
73.         if (DbManager::select(study_table_name_, key_list, res, where)) {
74.             if (res.size() == 1) {
75.                 success = true;
76.             }
77.         }
78.     }
79.     DbManager::CloseDb();
80.     return success;
81. }
83. bool StudyDao::InsertImageToDb(const ImageRecord &image, bool imported) {
84.     Q_UNUSED(imported)
85.     bool success = false;
86.     if(DbManager::OpenDb()) {
87.         QMap<QString, QVariant> data;
88.         data.insert("ImageUid", image.image_uid_);
89.         data.insert("SopClassUid", image.sop_class_uid_);
90.         data.insert("SeriesUid", image.series_uid_);
91.         data.insert("StudyUid", image.study_uid_);
92.         data.insert("RefImageUid", image.ref_image_uid_);
93.         data.insert("ImageNo", image.image_number_);
94.         data.insert("ImageTime", image.image_yime_.toString(NORMAL_DATETIME_FORMAT));
95.         data.insert("ImageDesc", image.image_desc_);
96.         data.insert("ImageFile", image.image_file_);
97.         if (DbManager::insert(image_table_name_, data)) {
98.             success = true;
99.         }
100.     }
101.     DbManager::CloseDb();
102.     return success;
103. }
105. bool StudyDao::RemoveImageFromDb(const QString &image_uid, bool updateStudy) {
106.     Q_UNUSED(updateStudy)
107.     bool success = false;
108.     // select data && Remove file
109.     if (image_uid.isEmpty()) {
110.         return false;
111.     }
112.     if (DbManager::OpenDb()) {
113.         QStringList key_list;
114.         key_list.append("ImageFile");
115.         QString where = QString("ImageUid = '%1'").arg(image_uid);
116.         QList<QMap<QString, QVariant>> res;
117.         if (DbManager::select(image_table_name_, key_list, res, where)) {
118.             if (res.size() == 1) {
119.                 const QMap<QString, QVariant> &res0 = res.at(0);
120.                 if (res0.size() == 1) {
121.                     QString image_file = res0.value("ImageFile").toString();
122.                     QString file = QString("./DcmFile/%2").arg(image_file);
123.                     // QString dir_name = file.left(file.lastIndexOf('/'));
124.                     FileUtil::DeleteFileOrFolder(file);
125.                     success = true;
126.                 } else {
127.                 }
128.             } else {
129.             }
130.         }
131.     }
132.     DbManager::CloseDb();
133.     // remove data
134.     if(DbManager::OpenDb()) {
135.         QString where = QString("ImageUid = '%1'").arg(image_uid);
136.         if (DbManager::remove(image_table_name_, where)) {
137.             success = true;
138.         }
139.     }
140.     DbManager::CloseDb();
141.     return success;
142. }
144. bool StudyDao::RemoveAllImagesOfStudyFromDb(
145.     const QString &study_uid, bool updateStudy) {
146.     Q_UNUSED(updateStudy)
147.     if (study_uid.isEmpty()) {
148.         return false;
149.     }
150.     bool result = false;
151.     //
152.     QStringList image_uids;
153.     // select data
154.     if (DbManager::OpenDb()) {
155.         QStringList key_list;
156.         key_list.append("ImageUid");
157.         QString where = QString("StudyUid = '%1'").arg(study_uid);
158.         QList<QMap<QString, QVariant>> res;
159.         if (DbManager::select(image_table_name_, key_list, res, where)) {
160.             if (res.size() >= 1) {
161.                 for (int i = 0; i < res.size(); i++) {
162.                     const QMap<QString, QVariant> &res0 = res.at(i);
163.                     if (res0.size() == 1) {
164.                         image_uids << res0.value("ImageUid").toString();
165.                     }
166.                 }
167.             }
168.         }
169.     }
170.     DbManager::CloseDb();
171.     // remove data
172.     foreach (auto var, image_uids) {
173.         RemoveImageFromDb(var);
174.     }
175.     return result;
176. }
178. bool StudyDao::UpdateImageFile(const QString &image_uid, const QString &image_file) {
179.     if (image_uid.isEmpty()) {
180.         return false;
181.     }
182.     if (image_file.isEmpty()) {
183.         return false;
184.     }
185.     bool result = false;
186.     // Create StudyTable
187.     QString str ;
188.     str = "UPDATE ImageTable SET ImageFile=%1 WHERE ImageUid=%2";
189.     str = str.arg(image_uid, image_file);
190.     result = DbManager::ExecSqlStr(str);
191.     return result;
192. }
194. bool StudyDao::VerifyImageByIMmuid(const QString &image_uid) {
195.     bool success = false;
196.     if (image_uid.isEmpty()) {
197.         return false;
198.     }
199.     if(DbManager::OpenDb()) {
200.         QStringList key_list;
201.         key_list.append("ImageUid");
202.         QString where = QString("ImageUid = '%1'").arg(image_uid);
203.         QList<QMap<QString, QVariant>> res;
204.         if (DbManager::select(image_table_name_, key_list, res, where)) {
205.             if (res.size() == 1) {
206.                 success = true;
207.             }
208.         }
209.     }
210.     DbManager::CloseDb();
211.     return success;
212. }
214. bool StudyDao::Initial() {
215.     bool result = false;
216.     if (DbManager::OpenDb()) {
217.         bool exist;
218.         if (DbManager::IsExistTable(study_table_name_, exist)) {
219.             if (!exist) {
220.                 result = CreateTable();
221.             } else {
222.                 if (CheckTable()) {
223.                     result = true;
224.                 } else {
225.                     if (DbManager::RemoveTable(study_table_name_)) {
226.                         result = CreateTable();
227.                     }
228.                 }
229.             }
230.         }
231.     }
232.     DbManager::CloseDb();
233.     return result;
234. }
236. bool StudyDao::CreateTable() {
237.     bool result = false;
238.     // Create StudyTable
239.     QString str ;
240.     str = "CREATE TABLE IF NOT EXISTS StudyTable("
241.           "StudyUid VARCHAR(128) PRIMARY KEY NOT NULL,"
242.           "AccNumber VARCHAR(64) NOT NULL, PatientId VARCHAR(64) NOT NULL,"
243.           "PatientName VARCHAR(64), "
244.           "PatientSex VARCHAR(2) NOT NULL,"
245.           "PatientBirth DATE NOT NULL,"
246.           "PatientAge VARCHAR(6),"
247.           "StudyTime DATETIME NOT NULL,"
248.           "Modality VARCHAR(2) NOT NULL, "
249.           "StudyDesc TEXT)";
250.     result = DbManager::ExecSqlStr(str);
251.     str = "CREATE INDEX IF NOT EXISTS IX_StudyTable_StudyDate ON StudyTable(StudyTime)";
252.     result = DbManager::ExecSqlStr(str);
253.     // Create ImageTable
254.     str = "CREATE TABLE IF NOT EXISTS ImageTable("
255.           "ImageUid VARCHAR(128) PRIMARY KEY NOT NULL,"
256.           "SopClassUid VARCHAR(128) NOT NULL,"
257.           "SeriesUid VARCHAR(128) NOT NULL, "
258.           "StudyUid VARCHAR(128) NOT NULL,"
259.           "RefImageUid VARCHAR(128),"
260.           "ImageNo VARCHAR(16), "
261.           "ImageTime DATETIME NOT NULL,"
262.           "ImageDesc TEXT,"
263.           "ImageFile TEXT,"
264.           "FOREIGN KEY(StudyUid) REFERENCES StudyTable(StudyUid))";
265.     result = DbManager::ExecSqlStr(str);
266.     str = "CREATE INDEX IF NOT EXISTS IX_ImageTable_ImageTime ON ImageTable(ImageTime)";
267.     result = DbManager::ExecSqlStr(str);
268.     return result;
269. }
271. bool StudyDao::CheckTable() {
272.     bool ok1 = false;
273.     bool ok2 = false;
274.     if (DbManager::IsExistTable(study_table_name_, ok1) &&
275.             DbManager::IsExistTable(image_table_name_, ok2) ) {
276.         if (ok1 && ok2) {
277.             return true;
278.         }
279.     }
280.     return false;
281. }

复制代码

1. #ifndef DBMANAGER_H
2. #define DBMANAGER_H
4. #include <QObject>
5. #include <QMutex>
6. #include <QSqlDatabase>
8. namespace Kiss {
9.     class DbManager : public QObject {
10.         Q_OBJECT
11.       public :
12.         enum SQLiteType {
13.             dtNull = 0,//空值类型
14.             dtInteger = 1,//有符号整数
15.             dtReal = 2,//有符号浮点数，8字节
16.             dtText = 3,//文本字符串
17.             dtBlob = 4,//根据输入类型
18.             dtVarchar_64 = 5,
19.             dtTimeStamp = 6,
20.             dtTimeStamp_NotNull = 7,
21.         };
22.       public:
23.         static bool DbInitial();
24.         static bool Deallocate();
25.         static bool CreateDbFile();
26.         static bool IsOpenedDb();
27.         static bool OpenDb();
28.         static bool CloseDb();
29.         static bool IsExistTable(const QString &table_name, bool &result);
30.         static bool CreateTable(const QString &table_name,
31.                                 const QStringList &key_list,
32.                                 const QList<SQLiteType> &type_list);
33.         static bool RemoveTable(const QString &table_name);
34.         static bool IsExistColumn(const QString &table_name,
35.                                   const QString &column_name,
36.                                   bool &result);
37.         static bool update(const QString &table_name,
38.                            const QMap<QString, QVariant> &values,
39.                            const QString &where);
40.         static bool remove(const QString &table_name,
41.                            const QString &where = "");
42.         static bool insert(const QString &table_name,
43.                            const QMap<QString, QVariant> &values);
44.         static bool select(const QString &table_name,
45.                            const QStringList &colunms,
46.                            QList<QMap<QString, QVariant>> &values,
47.                            const QString &where = "");
48.         static bool ExecSqlStr(const QString &sql_str);
49.       signals:
50.       public slots:
51.       private:
52.         explicit DbManager(QObject *parent = nullptr);
53.         virtual ~DbManager() override;
54.       public:
55.         static QSqlDatabase data_base;
56.       private:
57.         static QMutex file_mutex_;
58.         static QMutex data_mutex_;
59.         static QString db_name_;
60.         static QString file_name_;
61.         static QStringList sqlite_type_string_;
62.         static bool init_;
63.     };
64. }
66. using namespace Kiss;
67. #endif // DBMANAGER_H

复制代码

1. #include "dbmanager.h"
3. #include <Global/KissGlobal>
5. QSqlDatabase DbManager::data_base;
6. QMutex DbManager::file_mutex_;
7. QMutex DbManager::data_mutex_;
8. QString DbManager::db_name_ = DB_CONNECTION_NAME;
9. QString DbManager::file_name_ = DB_NAME;
10. QStringList DbManager::sqlite_type_string_;
11. bool DbManager::init_ = false;
13. bool DbManager::DbInitial() {
14.     QMutexLocker locker(&data_mutex_);
15.     if (!init_) {
16.         init_ = true;
17.         if (QSqlDatabase::contains(db_name_)) {
18.             data_base = QSqlDatabase::database(db_name_);
19.         } else {
20.             data_base = QSqlDatabase::addDatabase("QSQLITE", db_name_);
21.         }
22.         sqlite_type_string_.append("NULL");
23.         sqlite_type_string_.append("INTEGER");
24.         sqlite_type_string_.append("REAL");
25.         sqlite_type_string_.append("TEXT");
26.         sqlite_type_string_.append("BLOB");
27.         sqlite_type_string_.append("VARCHAR ( 64 )");
28.         sqlite_type_string_.append("TimeStamp");
29.         sqlite_type_string_.append("TimeStamp NOT NULL");
30.         return true;
31.     }
32.     return true;
33. }
35. bool DbManager::Deallocate() {
36.     QMutexLocker locker(&data_mutex_);
37.     data_base = QSqlDatabase();
38.     if (QSqlDatabase::contains(db_name_)) {
39.         QSqlDatabase::removeDatabase(db_name_);
40.     }
41.     return true;
42. }
44. bool DbManager::CreateDbFile() {
45.     if (!QFile::exists(file_name_)) {
46.         QFile db_file(file_name_);
47.         if (!db_file.open(QIODevice::WriteOnly)) {
48.             db_file.close();
49.             qWarning() << "dbFile open failed";
50.             return false;
51.         }
52.         db_file.close();
53.     }
54.     return true;
55. }
57. bool DbManager::IsOpenedDb() {
58.     QMutexLocker locker(&data_mutex_);
59.     return data_base.isOpen();
60. }
62. bool DbManager::OpenDb() {
63.     file_mutex_.lock();
64.     if (!IsOpenedDb()) {
65.         QMutexLocker locker(&data_mutex_);
66.         data_base.setDatabaseName(file_name_);
67.         if (!data_base.open()) {
68.             qWarning() << "database open error:" << data_base.lastError().text();
69.             return false;
70.         }
71.     }
72.     return true;
73. }
75. bool DbManager::CloseDb() {
76.     file_mutex_.unlock();
77.     if (IsOpenedDb()) {
78.         QMutexLocker locker(&data_mutex_);
79.         data_base.close();
80.     }
81.     return true;
82. }
84. bool DbManager::IsExistTable(const QString &table_name, bool &result) {
85.     if (!IsOpenedDb()) {
86.         qWarning() << "database not open error!";
87.         return false;
88.     }
89.     QString sql_str = QString("SELECT 1 FROM sqlite_master "
90.                               "WHERE type = 'table' AND  "
91.                               "name = '%1'").arg(table_name);
92.     QMutexLocker locker(&data_mutex_);
93.     QSqlQuery query(data_base);
94.     if (query.exec(sql_str)) {
95.         if (query.next()) {
96.             qint32 sql_result = query.value(0).toInt(); //有表时返回1，无表时返回null
97.             if (sql_result) {
98.                 result = true;
99.                 return true;
100.             } else {
101.                 result = false;
102.                 return true;
103.             }
104.         } else {
105.             result = false;
106.             return true;
107.         }
108.     } else {
109.         qWarning() << "sqlstr exec error:" << data_base.lastError().text();
110.         return false;
111.     }
112. }
114. bool DbManager::CreateTable(const QString &table_name,
115.                             const QStringList &key_list,
116.                             const QList<DbManager::SQLiteType> &type_list) {
117.     if (key_list.size() != type_list.size()) {
118.         qWarning() << "keylist != typelist error";
119.         return false;
120.     }
121.     if (!IsOpenedDb()) {
122.         qWarning() << "database not open error!";
123.         return false;
124.     }
125.     QString sql_str_1 = QString("CREATE TABLE %1 (").arg(table_name);
126.     QString sql_str_2 = "%1 %2 PRIMARY KEY ,";
127.     QString sql_str_temp = "%1 %2 ,";
128.     sql_str_2 = sql_str_2
129.                 .arg(key_list.at(0))
130.                 .arg(sqlite_type_string_.at(type_list.at(0)));
131.     for (qint32 i = 1; i < type_list.size(); ++i) {
132.         sql_str_2 += sql_str_temp.arg(key_list.at(i))
133.                      .arg(sqlite_type_string_.at(type_list.at(i)));
134.     }
135.     sql_str_2 = sql_str_2.left(sql_str_2.size() - 1);
136.     QString sql_str_3 = ");";
137.     QString sql_str = sql_str_1 + sql_str_2 + sql_str_3;
138.     QMutexLocker locker(&data_mutex_);
139.     QSqlQuery query(data_base);
140.     if (query.exec(sql_str)) {
141.         return true;
142.     } else {
143.         qWarning() << "sqlstr exec error:" << data_base.lastError().text();
144.         return false;
145.     }
146. }
148. bool DbManager::RemoveTable(const QString &table_name) {
149.     if (!IsOpenedDb()) {
150.         qWarning() << "database not open error!";
151.         return false;
152.     }
153.     QString sql_str = QString("DROP TABLE '%1'").arg(table_name);
154.     QMutexLocker locker(&data_mutex_);
155.     QSqlQuery query(data_base);
156.     if (query.exec(sql_str)) {
157.         return true;
158.     } else {
159.         qWarning() << "sqlstr exec error:" << data_base.lastError().text();
160.         return false;
161.     }
162. }
164. bool DbManager::IsExistColumn(const QString &table_name,
165.                               const QString &column_name,
166.                               bool &result) {
167.     if (!IsOpenedDb()) {
168.         qWarning() << "database not open error!";
169.         return false;
170.     }
171.     QString sql_str = QString("SELECT 1 FROM sqlite_master "
172.                               "WHERE type = 'table' and "
173.                               "name = '%1' and sql like '%%2%' "
174.                              ).arg(table_name).arg(column_name);
175.     QMutexLocker locker(&data_mutex_);
176.     QSqlQuery query(data_base);
177.     if (query.exec(sql_str)) {
178.         if (query.next()) {
179.             qint32 sql_result = query.value(0).toInt(); //有此字段时返回1，无字段时返回null
180.             if (sql_result) {
181.                 result = true;
182.                 return true;
183.             } else {
184.                 result = false;
185.                 return true;
186.             }
187.         } else {
188.             result = false;
189.             return true;
190.         }
191.     } else {
192.         qWarning() << "sqlstr exec error:" << data_base.lastError().text();
193.         return false;
194.     }
195. }
197. bool DbManager::update(const QString &table_name,
198.                        const QMap<QString, QVariant> &values,
199.                        const QString &where) {
200.     if (!IsOpenedDb()) {
201.         qWarning() << "database not open error!";
202.         return false;
203.     }
204.     QString sql_str_data;
205.     QList<QString> key_list = values.keys();
206.     foreach (QString key, key_list) {
207.         if (!sql_str_data.isEmpty()) {
208.             sql_str_data += ",";
209.         }
210.         sql_str_data += QString("%1=?").arg(key);
211.     }
212.     QString sql_str;
213.     if (where.isEmpty()) {
214.         sql_str = QString("UPDATE %1 SET %2"
215.                          ).arg(table_name).arg(sql_str_data);
216.     } else {
217.         sql_str = QString("UPDATE %1 SET %2 WHERE %3"
218.                          ).arg(table_name).arg(sql_str_data).arg(where);
219.     }
220.     QMutexLocker locker(&data_mutex_);
221.     QSqlQuery query(data_base);
222.     query.prepare(sql_str);
223.     for (qint32 i = 0; i < key_list.count(); ++i) {
224.         query.bindValue(i, values.value(key_list.at(i)));
225.     }
226.     if (query.exec()) {
227.         return true;
228.     } else {
229.         qWarning() << "sqlstr exec error:" << data_base.lastError().text();
230.         return false;
231.     }
232. }
234. bool DbManager::remove(const QString &table_name,
235.                        const QString &where) {
236.     if (!IsOpenedDb()) {
237.         qWarning() << "database not open error!";
238.         return false;
239.     }
240.     QMutexLocker locker(&data_mutex_);
241.     QString sql_str = QString("DELETE FROM %1 WHERE %2"
242.                              ).arg(table_name).arg(where);
243.     QSqlQuery query(data_base);
244.     if (query.exec(sql_str)) {
245.         return true;
246.     } else {
247.         qWarning() << "sqlstr exec error:" << data_base.lastError().text();
248.         return false;
249.     }
250. }
252. bool DbManager::insert(const QString &table_name,
253.                        const QMap<QString, QVariant> &values) {
254.     if (!IsOpenedDb()) {
255.         qWarning() << "database not open error!";
256.         return false;
257.     }
258.     QString sql_str_column, sql_str_data;
259.     QList<QString> key_list = values.keys();
260.     foreach (QString key, key_list) {
261.         if (!sql_str_column.isEmpty()) {
262.             sql_str_column += ",";
263.         }
264.         sql_str_column += key;
265.         if (!sql_str_data.isEmpty()) {
266.             sql_str_data += ",";
267.         }
268.         sql_str_data += "?";
269.     }
270.     QString sql_str = QString("INSERT INTO %1(%2) VALUES(%3)")
271.                       .arg(table_name).arg(sql_str_column).arg(sql_str_data);
272.     QMutexLocker locker(&data_mutex_);
273.     QSqlQuery query(data_base);
274.     query.prepare(sql_str);
275.     for (qint32 i = 0; i < key_list.count(); ++i) {
276.         query.bindValue(i, values.value(key_list.at(i)));
277.     }
278.     if (query.exec()) {
279.         return true;
280.     } else {
281.         qWarning() << "sqlstr exec error:" << data_base.lastError().text();
282.         return false;
283.     }
284. }
286. bool DbManager::select(const QString &table_name,
287.                        const QStringList &colunms,
288.                        QList<QMap<QString, QVariant>> &values,
289.                        const QString &where) {
290.     if (!IsOpenedDb()) {
291.         qWarning() << "database not open error!";
292.         return false;
293.     }
294.     QString sql_str_columns;
295.     if (colunms.size()) {
296.         sql_str_columns = colunms.join(",");
297.     } else {
298. //        sql_str_columns = "*";
299.         qWarning() << "colunms is null";
300.         return false;
301.     }
302.     QString sql_str;
303.     if (where.isEmpty()) {
304.         sql_str = QString("SELECT %1 FROM %2")
305.                   .arg(sql_str_columns)
306.                   .arg(table_name);
307.     } else {
308.         sql_str = QString("SELECT %1 FROM %2 WHERE %3")
309.                   .arg(sql_str_columns)
310.                   .arg(table_name).arg(where);
311.     }
312.     QMutexLocker locker(&data_mutex_);
313.     QSqlQuery query(data_base);
314.     if (query.exec(sql_str)) {
315.         qint32 columns_sum = query.record().count();
316.         while (query.next()) {
317.             QMap<QString, QVariant> row;
318.             for (qint32 i = 0; i < columns_sum; ++i) {
319.                 row.insert(colunms.at(i), query.value(i));
320.             }
321.             values.append(row);
322.         }
323.         return true;
324.     } else {
325.         qWarning() << "sqlstr exec error:" << data_base.lastError();
326.         return false;
327.     }
328. }
330. bool DbManager::ExecSqlStr(const QString &sql_str) {
331.     if (!IsOpenedDb()) {
332.         qWarning() << "database not open error!";
333.         return false;
334.     }
335.     QMutexLocker locker(&data_mutex_);
336.     QSqlQuery query(data_base);
337.     if (query.exec(sql_str)) {
338.         return true;
339.     } else {
340.         qWarning() << "sqlstr exec error:" << data_base.lastError().text();
341.         return false;
342.     }
343. }
345. DbManager::DbManager(QObject *parent) : QObject(parent) {
346. }
348. DbManager::~DbManager() {
349. }

复制代码

5. 添加数据 StoreScp

  Dcmtk Pacs 开发：StoreScp 实现
6. 添加数据 本地加载

  两个线程，一个负责打开本地dcm文件，一个往数据库添加

1. #include "importdcmfilethread.h"
3. #include <Db/KissDb>
4. #include <Global/KissGlobal>
6. #include "dcmtk/dcmdata/dcuid.h"
9. ImportDcmFileThread::ImportDcmFileThread(ImportStudyModel *model, QObject *parent) :
10.     QThread(parent) {
11.     this->abort_ = false;
12.     this->import_model_ = model;
13. }
15. void ImportDcmFileThread::run() {
16.     StudyDao dao;
17.     foreach (StudyRecord *study, import_model_->getStudyList()) {
18.         if (abort_) {
19.             break;
20.         }
21.         int images = 0;
22.         QString study_dir_name =
23.             QString("%1/%2_%3").arg(study->study_time_.date().toString("yyyyMM"),
24.                                     study->study_time_.toString(DICOM_DATETIME_FORMAT),
25.                                     study->acc_number_);
26.         if(!dao.VerifyStudyByStuid(study->study_uid_)) {
27.             dao.InsertStudyToDb(*study, true);
28.         }
29.         FileUtil::DirMake(QString("%1/%2").arg(DICOM_SAVE_PATH, study_dir_name));
30.         foreach (ImageRecord *image, study->image_list_) {
31.             bool raw = image->sop_class_uid_ == QString(UID_XRayAngiographicImageStorage);
32.             QString src_file = image->image_file_;
33.             image->image_file_ = QString("%1/%2_%3.dcm").arg(study_dir_name,
34.                                  raw ? "angio" : "", image->image_uid_);
35.             QFileInfo info(QString("%1/%2").arg(DICOM_SAVE_PATH, image->image_file_));
36.             if (FileUtil::FileCopy(src_file, QString("%1/%2").arg(DICOM_SAVE_PATH, image->image_file_))) {
37.                 if (!dao.VerifyImageByIMmuid(image->image_uid_)) {
38.                     if (dao.InsertImageToDb(*image, true)) {
39.                         images++;
40.                     } else {
41.                     }
42.                 } else {
43.                     if (dao.UpdateImageFile(image->image_uid_, image->image_file_)) {
44.                         images++;
45.                     } else {
46.                         FileUtil::DeleteFileOrFolder(
47.                             QString("%1/%2").arg(DICOM_SAVE_PATH, image->image_file_));
48.                     }
49.                 }
50.             }
51.             image->image_file_ = src_file;
52.             emit Signal_ResultReady();
53.         }
54.         study->status_ = tr("Imported: Images %1.").arg(images);
55.         import_model_->resetStudyStatus(study);
56.     }
57. }
60. void ImportDcmFileThread::SetAbort(bool yes) {
61.     abort_ = yes;
62. }

复制代码

1. #include "scandcmfilethread.h"
3. #include <Global/KissGlobal>
5. #include "dcmtk/config/osconfig.h"
6. #include "dcmtk/dcmdata/dcfilefo.h"
7. #include "dcmtk/dcmdata/dcdeftag.h"
8. #include "dcmtk/dcmsr/dsrdoc.h"
9. #include "dcmtk/dcmimgle/dcmimage.h"
10. #include "dcmtk/dcmdata/dcuid.h"
13. ScanDcmFileThread::ScanDcmFileThread(QObject *parent) :
14.     QThread(parent) {
15.     this->abort_ = false;
16. }
18. void ScanDcmFileThread::run() {
19.     using namespace Kiss;
20.     foreach (QString file, file_list_) {
21.         if (abort_) {
22.             break;
23.         }
24.         StudyRecord *study = nullptr;
25.         DcmFileFormat dcmFile;
26.         OFCondition cond = dcmFile.loadFile(file.toLocal8Bit().data());
27.         DcmDataset *dset = dcmFile.getDataset();
28.         if (cond.good() && dset) {
29.             const char *value = nullptr;
30.             QString studyUid, seriesUid, instUid, sopClassUid;
31.             dset->findAndGetString(DCM_StudyInstanceUID, value);
32.             studyUid = QString::fromLatin1(value);
33.             dset->findAndGetString(DCM_SeriesInstanceUID, value);
34.             seriesUid = QString::fromLatin1(value);
35.             dset->findAndGetString(DCM_SOPInstanceUID, value);
36.             instUid = QString::fromLatin1(value);
37.             dset->findAndGetString(DCM_SOPClassUID, value);
38.             sopClassUid = QString::fromLatin1(value);
39.             if (!(studyUid.isEmpty() || seriesUid.isEmpty() ||
40.                     instUid.isEmpty() || sopClassUid.isEmpty())) {
41.                 study = new StudyRecord(studyUid);
42.                 dset->findAndGetString(DCM_AccessionNumber, value);
43.                 study->acc_number_ = QString::fromLocal8Bit(value).remove(QChar(' '));
44.                 dset->findAndGetString(DCM_PatientID, value);
45.                 study->patient_id_ = QString::fromLocal8Bit(value);
46.                 dset->findAndGetString(DCM_PatientName, value);
47.                 study->patient_name_ = QString::fromLocal8Bit(value);
48.                 dset->findAndGetString(DCM_PatientSex, value);
49.                 study->patient_sex_ = QString::fromLocal8Bit(value).remove(QChar(' '));
50.                 dset->findAndGetString(DCM_PatientBirthDate, value);
51.                 study->patient_birth_ = QDate::fromString(QString::fromLatin1(value), "yyyyMMdd");
52.                 dset->findAndGetString(DCM_PatientAge, value);
53.                 study->patient_age_ = QString::fromLocal8Bit(value).remove(QChar(' '));
54.                 dset->findAndGetString(DCM_StudyDate, value);
55.                 study->study_time_.setDate(QDate::fromString(QString::fromLatin1(value), "yyyyMMdd"));
56.                 dset->findAndGetString(DCM_StudyTime, value);
57.                 study->study_time_.setTime(formatDicomTime(QString::fromLatin1(value)));
58.                 dset->findAndGetString(DCM_StudyDescription, value);
59.                 study->study_desc_ = QString::fromLocal8Bit(value);
60.                 dset->findAndGetString(DCM_InstitutionName, value);
61.                 study->institution_ = QString::fromLocal8Bit(value);
62.                 dset->findAndGetString(DCM_Modality, value);
63.                 study->modality_ = QString::fromLatin1(value);
64.                 if (sopClassUid == UID_XRayAngiographicImageStorage ||// 造影血管
65.                         true) {
66.                     ImageRecord *image = new ImageRecord(instUid);
67.                     image->sop_class_uid_ = sopClassUid;
68.                     image->series_uid_ = seriesUid;
69.                     image->study_uid_ = studyUid;
70.                     image->image_file_ = file;
71.                     study->image_list_.append(image);
72.                     dset->findAndGetString(DCM_ReferencedSOPInstanceUID, value, true);
73.                     image->ref_image_uid_ = QString::fromLatin1(value);
74.                     dset->findAndGetString(DCM_InstanceNumber, value);
75.                     image->image_number_ = QString::fromLatin1(value);
76.                     dset->findAndGetString(DCM_SeriesDescription, value);
77.                     image->image_desc_ = QString::fromLocal8Bit(value);
78.                     dset->findAndGetString(DCM_ContentDate, value);
79.                     image->image_yime_.setDate(
80.                         QDate::fromString(QString::fromLatin1(value), "yyyyMMdd"));
81.                     dset->findAndGetString(DCM_ContentTime, value);
82.                     image->image_yime_.setTime(formatDicomTime(QString::fromLatin1(value)));
83.                 }
84.             }
85.         }
86.         if (study && (study->image_list_.isEmpty())) {
87.             delete study;
88.             study = nullptr;
89.         }
90.         emit Signal_ResultRecord(study);
91.         emit Signal_ResultReady();
92.     }
93. }
95. void ScanDcmFileThread::SetFiles(const QStringList &files) {
96.     file_list_ = files;
97. }
99. void ScanDcmFileThread::SetAbort(bool yes) {
100.     abort_ = yes;
101. }

复制代码

来源：https://blog.csdn.net/a150********/article/details/109058579
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！