Refactor dialog package.

This commit is contained in:
Krad
2022-06-13 11:21:44 +08:00
parent 9a233251dc
commit 69a506ff94
27 changed files with 870 additions and 828 deletions

View File

@@ -1,35 +1,44 @@
//
// Created by Krad on 2021/10/12.
//
#include "ShimLib/ShimLib.h"
#include "DeviceManager.h"
#include "../event/EventCenter.h"
#include <QVariant>
#include <QTimerEvent>
#include <QDate>
#include <qdebug.h>
#include "appvals/AppGlobalValues.h"
#include "json/ScanJson.h"
#include "json/jsonobject.h"
#include "ShimLib/ShimLib.h"
#include "event/EventCenter.h"
#define TRIGGER_EVENT EventCenter::Default()->triggerEvent
#define THROW_ERROR(errormsg)\
TRIGGER_EVENT(GUIEvents::GUIErrorRaise, nullptr, (QObject*)&errormsg);
namespace {
const char* names[3] = {"Initializing","Scanning", "CE Measuring"};
const int PREVIEW_IMAGE_WH = 140;
}
const char* getStatusString(int status)
{
switch (status) {
case SCANNING:
return "SCANNING";
case READY:
return "Ready";
case BUSY:
return "BUSY";
case ERROR:
return "ERROR";
}
return "";
case SCANNING:
return "SCANNING";
case READY:
return "Ready";
case BUSY:
return "BUSY";
case ERROR:
return "ERROR";
default:
return nullptr;
}
}
std::string getJsonFromPatInf(QObject* obj)
@@ -37,241 +46,102 @@ std::string getJsonFromPatInf(QObject* obj)
return ((QString*)obj)->toStdString();
}
void ErrorCallback(const char* msg)
void errorCallback(const char* msg)
{
DeviceManager::Default()->emitErrorCallback(msg);
}
void DeviceManager::emitErrorCallback(const char *msg) {
errorOccurred=true;
printf("Error Callback , message:%s\r\n", msg);
QString m(msg);
emit raiseGlobalError( m);
const char * getPhaseName(int phase){
return names[phase-1];
}
void DeviceManager::initDevice() {
InitLib(ErrorCallback);
InitLib(errorCallback);
deviceInfTimerID = startTimer(10000);
mDeviceInfTimerID = startTimer(10000);
// empty scan
connect(EventCenter::Default(), &EventCenter::RequestEmptyScan, [=](QObject* sender, QObject* detail) {
std::string json = getJsonFromPatInf(detail);
startScan(json.c_str(), true);
});
startScan(getJsonFromPatInf(detail).c_str(), true);
});
// Patient scan
connect(EventCenter::Default(), &EventCenter::RequestPatientScan, [=](QObject* sender, QObject* detail) {
std::string json = getJsonFromPatInf(detail);
qDebug() << json.c_str();
if (!json.empty())
{
startScan(json.c_str());
}
});
startScan(getJsonFromPatInf(detail).c_str());
});
// Continue Scan
connect(EventCenter::Default(), &EventCenter::RequestContinueScan, [=](QObject* sender, QObject* detail) {
postContinueCommand(true);
});
// stop
connect(EventCenter::Default(), &EventCenter::RequestStop, [=]() {
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "Stop request status, status:%s" << getStatusString(inf.status);
// check device status=========================================
//device is ready return
if (inf.status != SCANNING) {
//double check
QThread::msleep(100);
inf = GetStatus();
if (inf.status != SCANNING){
TRIGGER_EVENT(GUIEvents::ResponseStop, nullptr, nullptr);
return;
}
}
AppGlobalValues::setInProcessing(true);
TRIGGER_EVENT(GUIEvents::InvokeOperationStart, nullptr, nullptr);
//ScanControl fail
qDebug() << "Request stop!";
if (timerID != -1)killTimer(timerID);
if (ScanControl(STOP)) {
qDebug() << "Stop fail!";
QString msg("Stop operation fail!");
THROW_ERROR(msg);
qDebug() << "Error thrown!";
lastStatus = -1;
previewing = false;
QString s("%1 %2");
s = s.arg(QDateTime::currentDateTime().toString("yyyy/MM/dd HH:mm:ss"), msg);
TRIGGER_EVENT(GUIEvents::GlobalBannerMessage, nullptr, (QObject*)&msg);
return;
}
lastStatus = -1;
previewing = false;
QString s("%1 %2");
s = s.arg(QDateTime::currentDateTime().toString("yyyy/MM/dd HH:mm:ss"), ("Scan Stopped!"));
TRIGGER_EVENT(GUIEvents::GlobalBannerMessage, nullptr, (QObject*)&s);
// preview end
TRIGGER_EVENT(GUIEvents::InvokeOperationEnd, nullptr, nullptr);
TRIGGER_EVENT(GUIEvents::ResponseStop, nullptr, nullptr);
AppGlobalValues::setInProcessing(false);
});
connect(EventCenter::Default(), &EventCenter::RequestStop,this, &DeviceManager::stopScan);
// preview
connect(EventCenter::Default(), &EventCenter::RequestPreviewScan, [=]() {
// check device status=========================================
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "PreviewScan request status, status:" << getStatusString(inf.status);
if (inf.status == READY)
{
AppGlobalValues::setInProcessing(true);
TRIGGER_EVENT(GUIEvents::InvokeOperationStart, nullptr, nullptr);
//ScanControl
qDebug() << "Request preview!";
if (!ScanControl(PREVIEW_SCAN))
{
qDebug() << "Preview success!";
// lastStatus = SCANNING;
previewing = true;
// timerID = startTimer(500);
TRIGGER_EVENT(GUIEvents::ResponsePreview, nullptr, nullptr);
// end scan without prompt
TRIGGER_EVENT(GUIEvents::InvokeOperationEnd, nullptr, nullptr);
QString s("Device Previewing!");
TRIGGER_EVENT(GUIEvents::GlobalBannerMessage, nullptr, (QObject*)&s);
return;
}
}
qDebug() << "Preview fail!";
QString msg(inf.status != READY ? "Can't start preview,Device is not ready!" : "Start preview operation fail!");
THROW_ERROR(msg);
qDebug() << "Error thrown!";
});
connect(EventCenter::Default(), &EventCenter::RequestPreviewScan,this, &DeviceManager::startPreview);
// init the preview data caller thread
previewDataCaller = QThread::create([=]() {
while (!endLoop)
{
if (!previewing) {
QThread::sleep(3);
continue;
}
// check device status=========================================
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "GetPreviewData request status, status:" << getStatusString(inf.status);
// device is preview scanning, try get preview data
if (inf.status == SCANNING) {
qDebug() << "Preview data reader read start!";
const char* data = GetPreviewData();
if (!data){
continue;
}
qDebug() << "Preview data reader read end!";
QByteArray bytes = QByteArray::fromRawData(data, 140 * 140);
//double check
if (!previewing) {
qDebug() << "Preview data reader long sleep!";
QThread::sleep(3);
continue;
}
qDebug() << "Preview data response event start!";
TRIGGER_EVENT(GUIEvents::ResponsePreviewData, nullptr, (QObject*)(&bytes));
qDebug() << "Preview data response event end!";
}
else{
// lastStatus = READY;
previewing = false;
AppGlobalValues::setInProcessing(false);
QThread::sleep(3);
}
QThread::msleep(100);
}
});
previewDataCaller->start();
initPreviewThread();
}
const char * getPhaseName(int phase){
const char* names[3] = {"Initializing","Scanning", "CE Measuring"};
return names[phase-1];
}
void DeviceManager::timerEvent(QTimerEvent* event) {
if (event->timerId() == deviceInfTimerID) {
QString temp = QString(GetDeviceInfo(MEAN_TEMPERATURE));
TRIGGER_EVENT(GUIEvents::ResponseDeviceTemperature, nullptr, (QObject *) &temp);
void DeviceManager::startScan(const char* json, bool empty) {
if (!json) return;
//clear last error state first
mErrorOccurred = false;
// check device status=========================================
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "Scan start request status, status:" << getStatusString(inf.status);
if (inf.status != READY) {
QString errMsg("Device is not ready, start scan operation fail!status is %1");
errMsg = errMsg.arg(getStatusString(inf.status));
THROW_ERROR(errMsg)
return;
}
//scanning progress timer
//error exit, callback error
if (errorOccurred) {
timerID = event->timerId();
exitScanTimer();
static QString msg = "Start scan...";
AppGlobalValues::setInProcessing(true);
TRIGGER_EVENT(GUIEvents::InvokeOperationStart, nullptr, (QObject*)&msg);
qDebug() << "SetScanInfo>>>>>>>>>>>>>>>>>>>>";
AppGlobalValues::setEmptyScanFlag(empty);
int ret = SetScanInfo(json, empty ? 1 : 0);
if (ret) {
qDebug() << ">>>>>>>>>>>>>>>>>>>>SetScanInfo failed";
THROW_ERROR("Transfer patient information fail!")
return;
}
// previewing exit
if (previewing) {
QString msg("Device is previewing, exit current operation!");
THROW_ERROR(msg);
} else {
// check device status=========================================
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "Scanning request status, status:" << getStatusString(inf.status);
//设备正常扫描中
if (inf.status == SCANNING) {
scanProcess(inf.progress);
return;
} else {
//未发生错误并且,之前状态是扫描,代表正常扫描完成
if (lastStatus == SCANNING && ! errorOccurred) {
prepareFinishScan();
}
//一般不会出现其他情况
// else {
// QString msg("Unknown error in scanning progress timer");
// THROW_ERROR(msg);
// }
}
}
exitScanTimer();
qDebug() << ">>>>>>>>>>>>>>>>>>>>SetScanInfo success";
postScanCommand();
}
void DeviceManager::scanProcess(int sProgress) {
void DeviceManager::scanProcess(int aProgress) {
qDebug() << "current output path:" << getScanOutputPath();
lastStatus = SCANNING;
mLastStatus = SCANNING;
//normal scan pending
int phase = sProgress / 100 + 1;
int progress = sProgress % 100;
int phase = aProgress / 100 + 1;
int progress = aProgress % 100;
// scan with phase 3 has a different message
QString extraMsg = (AppGlobalValues::EmptyScanFlag().toBool() ||
(scanPhase != 3)) ? "": ", patient can leave";
QVariant var(QString("%1%3\r\n progress:%2%").arg(getPhaseName(scanPhase)).arg(progress).arg(extraMsg));
(mScanPhase != 3)) ? "" : ", patient can leave";
QVariant var(QString("%1%3\r\n progress:%2%").arg(getPhaseName(mScanPhase)).arg(progress).arg(extraMsg));
TRIGGER_EVENT(InvokeOperationProgress, nullptr, (QObject *) &var);
// 300 means finished
if (sProgress == 300) return;
if (aProgress == 300) return;
//phase control
//no change return
if (scanPhase == phase) return;
if (mScanPhase == phase) return;
// error phase
if (phase > 3 || scanPhase > phase) {
if (phase > 3 || mScanPhase > phase) {
QString errorMsg = QString("Error Scan Phase code, current Phase code:%1, new Phase code:%2!").arg(
scanPhase).arg(phase);
mScanPhase).arg(phase);
THROW_ERROR(errorMsg)
exitScanTimer();
return;
}
// enter phase 2
if ((scanPhase = phase) == 2) {
if ((mScanPhase = phase) == 2) {
if (!AppGlobalValues::EmptyScanFlag().toBool() && JsonObject::Instance()->getScanConfirm()) {
var.setValue(QString("Waiting for operator to start scan!\r\n Click \"Next\" to continue!"));
TRIGGER_EVENT(InvokeOperationPending, nullptr, (QObject *) &var);
exitScanTimer();
}
//empty scan no pending, auto continue
//empty scan no pending, auto continue
else {
postContinueCommand();
}
@@ -279,12 +149,30 @@ void DeviceManager::scanProcess(int sProgress) {
}
void DeviceManager::exitScanTimer() {
qDebug() << "Scanning progress Timer exit";
if (timerID>0)killTimer(timerID);
timerID = -1;
lastStatus = -1;
previewing = false;
void DeviceManager::postScanCommand() {
qDebug() << "ScanControl start>>>>>>>>>>>>>>>>>>>>>";
if (!ScanControl(SCAN)) {
qDebug() << ">>>>>>>>>>>>>>>>>>>>>ScanControl success";
//set current state
mLastStatus = SCANNING;
mPreviewing = false;
mScanPhase = 1;
qDebug() << "Start progress timer";
mTimerID = startTimer(500);
return;
}
//ScanControl fail
THROW_ERROR("ScanControl start fail!")
qDebug() << ">>>>>>>>>>>>>>>>>>>>>ScanControl failed";
}
void DeviceManager::postContinueCommand(bool useTimer) {
if (!ScanControl(SCAN_CONTINUE)) {
if (useTimer)mTimerID = startTimer(500);
return;
}
//ScanControl fail
THROW_ERROR("ScanControl start fail!")
}
void DeviceManager::prepareFinishScan() {
@@ -294,10 +182,6 @@ void DeviceManager::prepareFinishScan() {
// stop normal scan with prompt
TRIGGER_EVENT(InvokeOperationEnd, nullptr, (QObject *) &var);
AppGlobalValues::setInProcessing(false);
// log, no need
// QString s("%1 %2");
// s = s.arg(QDateTime::currentDateTime().toString("yyyy/MM/dd HH:mm:ss")).arg("Scan finished");
// TRIGGER_EVENT(GlobalBannerMessage, nullptr, (QObject *) &s);
// get output data path
QString outputPath = GetDeviceInfo(DEV_OUTPATH);
@@ -314,76 +198,185 @@ void DeviceManager::prepareFinishScan() {
// save json
ScanJson::Current()->save();
} else {
QString msg("Scan Output Path error!");
THROW_ERROR(msg);
THROW_ERROR("Scan Output Path error!")
}
}
void DeviceManager::startScan(const char* json, bool empty) {
//clear last error state first
errorOccurred = false;
// check device status=========================================
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "Scan start request status, status:" << getStatusString(inf.status);
if (inf.status != READY) {
QString errmsg("Device is not ready, start scan operation fail!status is %1");
errmsg = errmsg.arg(getStatusString(inf.status));
THROW_ERROR(errmsg);
return;
}
static QString msg = "Start scan...";
AppGlobalValues::setInProcessing(true);
TRIGGER_EVENT(GUIEvents::InvokeOperationStart, nullptr, (QObject*)&msg);
qDebug() << "SetScanInfo>>>>>>>>>>>>>>>>>>>>";
AppGlobalValues::setEmptyScanFlag(empty);
int ret = SetScanInfo(json, empty ? 1 : 0);
if (ret) {
qDebug() << ">>>>>>>>>>>>>>>>>>>>SetScanInfo failed";
QString errmsg("Transfer patient information fail!");
qDebug() << "Error thrown";
THROW_ERROR(errmsg);
return;
}
qDebug() << ">>>>>>>>>>>>>>>>>>>>SetScanInfo success";
void DeviceManager::stopScan() {
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "Stop request status, status:%s" << getStatusString(inf.status);
postScanCommand();
}
void DeviceManager::postScanCommand() {
qDebug() << "ScanControl start>>>>>>>>>>>>>>>>>>>>>";
if (!ScanControl(SCAN)) {
qDebug() << ">>>>>>>>>>>>>>>>>>>>>ScanControl success";
//set current state
lastStatus = SCANNING;
previewing = false;
scanPhase = 1;
qDebug() << "Start progress timer";
timerID = startTimer(500);
// check device status=========================================
//device is ready return
if (inf.status != SCANNING) {
//double check
QThread::msleep(100);
inf = GetStatus();
if (inf.status != SCANNING) {
TRIGGER_EVENT(ResponseStop, nullptr, nullptr);
return;
}
}
AppGlobalValues::setInProcessing(true);
TRIGGER_EVENT(InvokeOperationStart, nullptr, nullptr);
//ScanControl fail
qDebug() << "Request stop!";
if (mTimerID != -1)killTimer(mTimerID);
if (ScanControl(STOP)) {
qDebug() << "Stop fail!";
QString msg("Stop operation fail!");
THROW_ERROR(msg)
qDebug() << "Error thrown!";
mLastStatus = -1;
mPreviewing = false;
QString s("%1 %2");
s = s.arg(QDateTime::currentDateTime().toString("yyyy/MM/dd HH:mm:ss"), msg);
TRIGGER_EVENT(GlobalBannerMessage, nullptr, (QObject *) &msg);
return;
}
//ScanControl fail
QString errmsg("ScanControl start fail!");
THROW_ERROR(errmsg);
qDebug() << ">>>>>>>>>>>>>>>>>>>>>ScanControl failed";
mLastStatus = -1;
mPreviewing = false;
QString s("%1 %2");
s = s.arg(QDateTime::currentDateTime().toString("yyyy/MM/dd HH:mm:ss"), ("Scan Stopped!"));
TRIGGER_EVENT(GlobalBannerMessage, nullptr, (QObject *) &s);
// preview end
TRIGGER_EVENT(InvokeOperationEnd, nullptr, nullptr);
TRIGGER_EVENT(ResponseStop, nullptr, nullptr);
AppGlobalValues::setInProcessing(false);
}
void DeviceManager::postContinueCommand(bool useTimer) {
if (!ScanControl(SCAN_CONTINUE)) {
if (useTimer)timerID = startTimer(500);
return;
}
//ScanControl fail
QString errmsg("ScanControl start fail!");
THROW_ERROR(errmsg);
void DeviceManager::exitScanTimer() {
qDebug() << "Scanning progress Timer exit";
if (mTimerID > 0)killTimer(mTimerID);
mTimerID = -1;
mLastStatus = -1;
mPreviewing = false;
}
void DeviceManager::close() {
#ifdef _WIN32
StopDevice();
#endif
previewDataCaller->terminate();
delete previewDataCaller;
mPreviewDataCaller->terminate();
delete mPreviewDataCaller;
}
void DeviceManager::initPreviewThread() {
mPreviewDataCaller = QThread::create([=]() {
while (!mEndLoop) {
if (!mPreviewing) {
QThread::sleep(3);
continue;
}
// check device status=========================================
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "GetPreviewData request status, status:" << getStatusString(inf.status);
// device is preview scanning, try get preview data
if (inf.status == SCANNING) {
qDebug() << "Preview data reader read start!";
const char *data = GetPreviewData();
if (!data) {
continue;
}
qDebug() << "Preview data reader read end!";
QByteArray bytes = QByteArray::fromRawData(data, PREVIEW_IMAGE_WH * PREVIEW_IMAGE_WH);
//double check
if (!mPreviewing) {
qDebug() << "Preview data reader long sleep!";
QThread::sleep(3);
continue;
}
qDebug() << "Preview data response event start!";
TRIGGER_EVENT(ResponsePreviewData, nullptr, (QObject *) (&bytes));
qDebug() << "Preview data response event end!";
} else {
mPreviewing = false;
AppGlobalValues::setInProcessing(false);
QThread::sleep(3);
}
QThread::msleep(100);
}
});
mPreviewDataCaller->start();
}
void DeviceManager::startPreview() {// check device status=========================================
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "PreviewScan request status, status:" << getStatusString(inf.status);
if (inf.status == READY)
{
AppGlobalValues::setInProcessing(true);
TRIGGER_EVENT(InvokeOperationStart, nullptr, nullptr);
//ScanControl
qDebug() << "Request preview!";
if (!ScanControl(PREVIEW_SCAN))
{
qDebug() << "Preview success!";
// lastStatus = SCANNING;
mPreviewing = true;
// timerID = startTimer(500);
TRIGGER_EVENT(ResponsePreview, nullptr, nullptr);
// end scan without prompt
TRIGGER_EVENT(InvokeOperationEnd, nullptr, nullptr);
QString s("Device Previewing!");
TRIGGER_EVENT(GlobalBannerMessage, nullptr, (QObject*)&s);
return;
}
}
qDebug() << "Preview fail!";
QString msg(inf.status != READY ? "Can't start preview,Device is not ready!" : "Start preview operation fail!");
THROW_ERROR(msg)
qDebug() << "Error thrown!";
}
void DeviceManager::timerEvent(QTimerEvent* event) {
if (event->timerId() == mDeviceInfTimerID) {
QString temp = QString(GetDeviceInfo(MEAN_TEMPERATURE));
TRIGGER_EVENT(GUIEvents::ResponseDeviceTemperature, nullptr, (QObject *) &temp);
return;
}
//scanning progress timer
//error exit, callback error
if (mErrorOccurred) {
mTimerID = event->timerId();
exitScanTimer();
return;
}
// previewing exit
if (mPreviewing) {
THROW_ERROR("Device is previewing, exit current operation!")
} else {
// check device status=========================================
qDebug() << "GetStatus";
StatusInfo inf = GetStatus();
qDebug() << "Scanning request status, status:" << getStatusString(inf.status);
//设备正常扫描中
if (inf.status == SCANNING) {
scanProcess(inf.progress);
return;
} else {
//未发生错误并且,之前状态是扫描,代表正常扫描完成
if (mLastStatus == SCANNING && ! mErrorOccurred) {
prepareFinishScan();
}
//一般不会出现其他情况
// else {
// QString msg("Unknown error in scanning progress timer");
// THROW_ERROR(msg);
// }
}
}
exitScanTimer();
}
void DeviceManager::emitErrorCallback(const char *msg) {
mErrorOccurred = true;
QString m(msg);
emit raiseGlobalError( m);
}
QString DeviceManager::getSoftwareVersion() {

View File

@@ -7,18 +7,24 @@
#include <QObject>
#include <QThread>
class DeviceManager :public QObject {
Q_OBJECT
class DeviceManager : public QObject {
Q_OBJECT
public:
static DeviceManager* Default(){
static DeviceManager *Default() {
static DeviceManager manager;
return &manager;
}
DeviceManager() = default;
~DeviceManager() override = default ;
DeviceManager(const DeviceManager&) = delete;
DeviceManager operator=(const DeviceManager&) = delete;
~DeviceManager() override = default;
DeviceManager(const DeviceManager &) = delete;
DeviceManager operator=(const DeviceManager &) = delete;
/**
* init device, include Shimlib and it's error call back,
* deviceInfTimer to get temperature of water, and the
@@ -29,32 +35,36 @@ public:
/**
* close and release the device reference resource.
*/
void close();
void close();
/**
* Get Firm ware version
* @return Firm ware version
*/
QString getSoftwareVersion();
static QString getSoftwareVersion();
/**
* Get Scan data output path
* @return Scan data output path
*/
QString getScanOutputPath();
static QString getScanOutputPath();
void setErrorOccurred(bool v){
errorOccurred = v;
void setErrorOccurred(bool v) {
mErrorOccurred = v;
}
bool getErrorOccurred(){
return errorOccurred;
bool getErrorOccurred() {
return mErrorOccurred;
}
void emitErrorCallback(const char * msg);
signals:
void emitErrorCallback(const char *msg);
signals:
void raiseGlobalError(QString msg);
protected:
void timerEvent(QTimerEvent* event) override;
void timerEvent(QTimerEvent *event) override;
private:
/**
@@ -62,11 +72,11 @@ private:
* @param json The patient information json string
* @param empty Empty scan flag
*/
void startScan(const char* json, bool empty = false);
void startScan(const char *json, bool empty = false);
/**
* Post Scan start command to Shimlib
*/
/**
* Post Scan start command to Shimlib
*/
void postScanCommand();
/**
@@ -89,16 +99,24 @@ private:
* Process scan progress change
* @param Scan progress
*/
void scanProcess(int progress);
void scanProcess(int aProgress);
void initPreviewThread();
void stopScan();
void startPreview();
int mScanPhase = 1;
volatile int mTimerID = -1;
int mDeviceInfTimerID = -1;
int mLastStatus = -1;
bool mPreviewing = false;
volatile bool mEndLoop = false;
volatile bool mErrorOccurred = false;
QThread *mPreviewDataCaller = nullptr;
int scanPhase = 1;
volatile int timerID = -1;
int deviceInfTimerID = -1;
int lastStatus = -1;
bool previewing = false;
volatile bool endLoop = false;
volatile bool errorOccurred = false;
QThread* previewDataCaller = nullptr;
};