|
@@ -7,29 +7,25 @@ HProjectDao::HProjectDao(QSqlDatabase db) : database(db) {}
|
|
bool HProjectDao::addHProject(const HProject &project) {
|
|
bool HProjectDao::addHProject(const HProject &project) {
|
|
QSqlQuery query;
|
|
QSqlQuery query;
|
|
query.prepare(
|
|
query.prepare(
|
|
- "INSERT INTO h_project (uuid, name, company_code, htid, xmbh, operator_name, "
|
|
|
|
- "operator_identity, blaster_name, blaster_identity, address_uuid, address_path, "
|
|
|
|
- "lora_address,pc_sn, "
|
|
|
|
- "det_sum, file_name, file_url, blast_status,blast_count,created_at, updated_at, "
|
|
|
|
|
|
+ "INSERT INTO h_project (uuid, name, company_code, htid, xmbh, "
|
|
|
|
+ "operator_identity, blaster_identity, safety_inspector_identity, address_uuid, address_path, "
|
|
|
|
+ "level4_address,pc_sn,det_sum, file_name, file_url, blast_status,blast_count,created_at, updated_at, "
|
|
"deleted_at, create_by, update_by) "
|
|
"deleted_at, create_by, update_by) "
|
|
- "VALUES (:uuid, :name, :companyCode, :htid, :xmbh, :operatorName, :operatorIdentity, "
|
|
|
|
- ":blasterName, :blasterIdentity, :addressUuid, :addressPath, :loraAddress, :pcSn, :detSum, "
|
|
|
|
- ":fileName, "
|
|
|
|
- ":fileUrl, :blastStatus, :blastCount,:createdAt, :updatedAt, :deletedAt, :createBy, "
|
|
|
|
- ":updateBy)");
|
|
|
|
|
|
+ "VALUES (:uuid, :name, :companyCode, :htid, :xmbh, :operatorIdentity, "
|
|
|
|
+ ":blasterIdentity, :safetyInspectorIdentity, :addressUuid, :addressPath, :level4Address, :pcSn, :detSum, "
|
|
|
|
+ ":fileName, :fileUrl, :blastStatus, :blastCount,:createdAt, :updatedAt, :deletedAt, :createBy, :updateBy)");
|
|
|
|
|
|
query.bindValue(":uuid", project.getUuid());
|
|
query.bindValue(":uuid", project.getUuid());
|
|
query.bindValue(":name", project.getName());
|
|
query.bindValue(":name", project.getName());
|
|
query.bindValue(":companyCode", project.getCompanyCode());
|
|
query.bindValue(":companyCode", project.getCompanyCode());
|
|
query.bindValue(":htid", project.getHtid());
|
|
query.bindValue(":htid", project.getHtid());
|
|
query.bindValue(":xmbh", project.getXmbh());
|
|
query.bindValue(":xmbh", project.getXmbh());
|
|
- query.bindValue(":operatorName", project.getOperatorName());
|
|
|
|
query.bindValue(":operatorIdentity", project.getOperatorIdentity());
|
|
query.bindValue(":operatorIdentity", project.getOperatorIdentity());
|
|
- query.bindValue(":blasterName", project.getBlasterName());
|
|
|
|
query.bindValue(":blasterIdentity", project.getBlasterIdentity());
|
|
query.bindValue(":blasterIdentity", project.getBlasterIdentity());
|
|
|
|
+ query.bindValue(":safetyInspectorIdentity", project.getSafetyInspectorIdentity());
|
|
query.bindValue(":addressUuid", project.getAddressUuid());
|
|
query.bindValue(":addressUuid", project.getAddressUuid());
|
|
query.bindValue(":addressPath", project.getAddressPath());
|
|
query.bindValue(":addressPath", project.getAddressPath());
|
|
- query.bindValue(":loraAddress", project.getLoraAddress());
|
|
|
|
|
|
+ query.bindValue(":level4Address", project.getLevel4Address());
|
|
query.bindValue(":blastCount", project.getBlastCount());
|
|
query.bindValue(":blastCount", project.getBlastCount());
|
|
query.bindValue(":pcSn", project.getPcSn());
|
|
query.bindValue(":pcSn", project.getPcSn());
|
|
query.bindValue(":detSum", project.getDetSum());
|
|
query.bindValue(":detSum", project.getDetSum());
|
|
@@ -42,6 +38,7 @@ bool HProjectDao::addHProject(const HProject &project) {
|
|
query.bindValue(":createBy", project.getCreateBy());
|
|
query.bindValue(":createBy", project.getCreateBy());
|
|
query.bindValue(":updateBy", project.getUpdateBy());
|
|
query.bindValue(":updateBy", project.getUpdateBy());
|
|
if (!query.exec()) {
|
|
if (!query.exec()) {
|
|
|
|
+ qDebug() << "HProjectDao::addHProject query: " << query.lastQuery() << query.lastError().text();
|
|
return false;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -57,10 +54,9 @@ bool HProjectDao::updateHProject(const HProject &project) {
|
|
"company_code = :companyCode, "
|
|
"company_code = :companyCode, "
|
|
"htid = :htid, "
|
|
"htid = :htid, "
|
|
"xmbh = :xmbh, "
|
|
"xmbh = :xmbh, "
|
|
- "operator_name = :operatorName, "
|
|
|
|
"operator_identity = :operatorIdentity, "
|
|
"operator_identity = :operatorIdentity, "
|
|
- "blaster_name = :blasterName, "
|
|
|
|
"blaster_identity = :blasterIdentity, "
|
|
"blaster_identity = :blasterIdentity, "
|
|
|
|
+ "safetyInspector_identity = :safetyInspectorIdentity, "
|
|
"address_uuid = :addressUuid, "
|
|
"address_uuid = :addressUuid, "
|
|
"address_path = :addressPath, "
|
|
"address_path = :addressPath, "
|
|
"pc_sn = :pcSn, "
|
|
"pc_sn = :pcSn, "
|
|
@@ -81,10 +77,9 @@ bool HProjectDao::updateHProject(const HProject &project) {
|
|
query.bindValue(":companyCode", project.getCompanyCode());
|
|
query.bindValue(":companyCode", project.getCompanyCode());
|
|
query.bindValue(":htid", project.getHtid());
|
|
query.bindValue(":htid", project.getHtid());
|
|
query.bindValue(":xmbh", project.getXmbh());
|
|
query.bindValue(":xmbh", project.getXmbh());
|
|
- query.bindValue(":operatorName", project.getOperatorName());
|
|
|
|
query.bindValue(":operatorIdentity", project.getOperatorIdentity());
|
|
query.bindValue(":operatorIdentity", project.getOperatorIdentity());
|
|
- query.bindValue(":blasterName", project.getBlasterName());
|
|
|
|
query.bindValue(":blasterIdentity", project.getBlasterIdentity());
|
|
query.bindValue(":blasterIdentity", project.getBlasterIdentity());
|
|
|
|
+ query.bindValue(":safetyInspectorIdentity", project.getSafetyInspectorIdentity());
|
|
query.bindValue(":addressUuid", project.getAddressUuid());
|
|
query.bindValue(":addressUuid", project.getAddressUuid());
|
|
query.bindValue(":addressPath", project.getAddressPath());
|
|
query.bindValue(":addressPath", project.getAddressPath());
|
|
query.bindValue(":pcSn", project.getPcSn());
|
|
query.bindValue(":pcSn", project.getPcSn());
|
|
@@ -107,7 +102,7 @@ bool HProjectDao::updateHProject(const HProject &project) {
|
|
|
|
|
|
bool HProjectDao::deleteHProject(const HProject &project) {
|
|
bool HProjectDao::deleteHProject(const HProject &project) {
|
|
QSqlQuery query;
|
|
QSqlQuery query;
|
|
- query.prepare("update h_project set deletion_date = :deletionDate WHERE id = :id");
|
|
|
|
|
|
+ query.prepare("update h_project set deleted_at = :deletionDate WHERE id = :id");
|
|
query.bindValue(":id", project.getId());
|
|
query.bindValue(":id", project.getId());
|
|
query.bindValue(":deletionDate", QDateTime::currentDateTime());
|
|
query.bindValue(":deletionDate", QDateTime::currentDateTime());
|
|
if (!query.exec()) {
|
|
if (!query.exec()) {
|
|
@@ -132,7 +127,7 @@ PaginatedHProjectResult HProjectDao::getAllHProjects(int page, int pageSize) {
|
|
QSqlQuery query(database);
|
|
QSqlQuery query(database);
|
|
int offset = (page - 1) * pageSize;
|
|
int offset = (page - 1) * pageSize;
|
|
query.prepare(
|
|
query.prepare(
|
|
- "SELECT * FROM h_project WHERE deletion_date IS NULL ORDER BY created_at desc LIMIT :pageSize OFFSET :offset");
|
|
|
|
|
|
+ "SELECT * FROM h_project WHERE deleted_at IS NULL ORDER BY created_at desc LIMIT :pageSize OFFSET :offset");
|
|
query.bindValue(":pageSize", pageSize);
|
|
query.bindValue(":pageSize", pageSize);
|
|
query.bindValue(":offset", offset);
|
|
query.bindValue(":offset", offset);
|
|
|
|
|
|
@@ -144,7 +139,7 @@ PaginatedHProjectResult HProjectDao::getAllHProjects(int page, int pageSize) {
|
|
qWarning() << "Query execution failed: " << query.lastError().text();
|
|
qWarning() << "Query execution failed: " << query.lastError().text();
|
|
}
|
|
}
|
|
|
|
|
|
- query.prepare("SELECT COUNT(*) FROM h_project");
|
|
|
|
|
|
+ query.prepare("SELECT COUNT(*) FROM h_project where deleted_at IS NULL");
|
|
int totalCount = 0;
|
|
int totalCount = 0;
|
|
if (query.exec() && query.next()) {
|
|
if (query.exec() && query.next()) {
|
|
totalCount = query.value(0).toInt();
|
|
totalCount = query.value(0).toInt();
|
|
@@ -157,7 +152,7 @@ PaginatedHProjectResult HProjectDao::getAllHProjectsByOpera(int page, int pageSi
|
|
QSqlQuery query(database);
|
|
QSqlQuery query(database);
|
|
int offset = (page - 1) * pageSize;
|
|
int offset = (page - 1) * pageSize;
|
|
query.prepare(
|
|
query.prepare(
|
|
- "SELECT * FROM h_project WHERE blast_status = :safeCheckedStatus and deletion_date IS NULL ORDER BY created_at "
|
|
|
|
|
|
+ "SELECT * FROM h_project WHERE blast_status = :safeCheckedStatus and deleted_at IS NULL ORDER BY created_at "
|
|
"desc "
|
|
"desc "
|
|
"LIMIT :pageSize OFFSET :offset");
|
|
"LIMIT :pageSize OFFSET :offset");
|
|
query.bindValue(":safeCheckedStatus", BlastStatus::SafeChecked);
|
|
query.bindValue(":safeCheckedStatus", BlastStatus::SafeChecked);
|
|
@@ -171,7 +166,8 @@ PaginatedHProjectResult HProjectDao::getAllHProjectsByOpera(int page, int pageSi
|
|
qWarning() << "Query execution failed: " << query.lastError().text();
|
|
qWarning() << "Query execution failed: " << query.lastError().text();
|
|
}
|
|
}
|
|
|
|
|
|
- query.prepare("SELECT COUNT(*) FROM h_project WHERE blast_status > 1");
|
|
|
|
|
|
+ query.prepare("SELECT COUNT(*) FROM h_project WHERE blast_status = :safeCheckedStatus and deleted_at IS NULL");
|
|
|
|
+ query.bindValue(":safeCheckedStatus", BlastStatus::SafeChecked);
|
|
int totalCount = 0;
|
|
int totalCount = 0;
|
|
if (query.exec() && query.next()) {
|
|
if (query.exec() && query.next()) {
|
|
totalCount = query.value(0).toInt();
|
|
totalCount = query.value(0).toInt();
|
|
@@ -197,7 +193,7 @@ QList<QSharedPointer<HProject>> HProjectDao::getRegistedProjectByAddressUuid(QLi
|
|
|
|
|
|
QString queryStr = QString(
|
|
QString queryStr = QString(
|
|
"SELECT * FROM h_project WHERE address_uuid IN (%1) "
|
|
"SELECT * FROM h_project WHERE address_uuid IN (%1) "
|
|
- "AND blast_status = %2 ORDER BY created_at")
|
|
|
|
|
|
+ "AND blast_status = %2 and deleted_at is NULL ORDER BY created_at")
|
|
.arg(placeholders)
|
|
.arg(placeholders)
|
|
.arg(BlastStatus::Registered);
|
|
.arg(BlastStatus::Registered);
|
|
|
|
|
|
@@ -223,9 +219,8 @@ QList<QSharedPointer<HProject>> HProjectDao::getRegistedProjectByAddressUuid(QLi
|
|
QList<QSharedPointer<HProject>> HProjectDao::getAllHProjectsReg() {
|
|
QList<QSharedPointer<HProject>> HProjectDao::getAllHProjectsReg() {
|
|
QList<QSharedPointer<HProject>> projects;
|
|
QList<QSharedPointer<HProject>> projects;
|
|
QSqlQuery query(database);
|
|
QSqlQuery query(database);
|
|
- query.prepare(
|
|
|
|
- QString("SELECT * FROM h_project WHERE blast_status = %1 and deletion_date is null ORDER BY created_at ")
|
|
|
|
- .arg(BlastStatus::Created));
|
|
|
|
|
|
+ query.prepare(QString("SELECT * FROM h_project WHERE blast_status = %1 and deleted_at is null ORDER BY created_at ")
|
|
|
|
+ .arg(BlastStatus::Created));
|
|
// 执行查询并打印SQL
|
|
// 执行查询并打印SQL
|
|
if (query.exec()) {
|
|
if (query.exec()) {
|
|
while (query.next()) {
|
|
while (query.next()) {
|
|
@@ -243,7 +238,7 @@ bool HProjectDao::updateBlastStatusByUuid(const QString &uuid, const QString &bl
|
|
query.prepare(
|
|
query.prepare(
|
|
"UPDATE h_project SET "
|
|
"UPDATE h_project SET "
|
|
"blast_status = :blastStatus "
|
|
"blast_status = :blastStatus "
|
|
- "WHERE uuid = :uuid and blast_status != :blastStatus");
|
|
|
|
|
|
+ "WHERE uuid = :uuid and blast_status != :blastStatus and deleted_at is NULL;");
|
|
query.bindValue(":uuid", uuid);
|
|
query.bindValue(":uuid", uuid);
|
|
query.bindValue(":blastStatus", blastStatus);
|
|
query.bindValue(":blastStatus", blastStatus);
|
|
|
|
|
|
@@ -262,10 +257,9 @@ QSharedPointer<HProject> HProjectDao::recordToProject(const QSqlRecord &record)
|
|
project->setCompanyCode(record.value("company_code").toString());
|
|
project->setCompanyCode(record.value("company_code").toString());
|
|
project->setHtid(record.value("htid").toString());
|
|
project->setHtid(record.value("htid").toString());
|
|
project->setXmbh(record.value("xmbh").toString());
|
|
project->setXmbh(record.value("xmbh").toString());
|
|
- project->setOperatorName(record.value("operator_name").toString());
|
|
|
|
project->setOperatorIdentity(record.value("operator_identity").toString());
|
|
project->setOperatorIdentity(record.value("operator_identity").toString());
|
|
- project->setBlasterName(record.value("blaster_name").toString());
|
|
|
|
project->setBlasterIdentity(record.value("blaster_identity").toString());
|
|
project->setBlasterIdentity(record.value("blaster_identity").toString());
|
|
|
|
+ project->setSafetyInspectorIdentity(record.value("safety_inspector_identity").toString());
|
|
project->setAddressUuid(record.value("address_uuid").toString());
|
|
project->setAddressUuid(record.value("address_uuid").toString());
|
|
project->setAddressPath(record.value("address_path").toString());
|
|
project->setAddressPath(record.value("address_path").toString());
|
|
project->setPcSn(record.value("pc_sn").toString());
|
|
project->setPcSn(record.value("pc_sn").toString());
|