GUI/src/device/DeviceManager.cpp

//
// 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 <QDateTime>
#include <qdebug.h>

#define TRIGGER_EVENT EventCenter::Default()->triggerEvent

#define THROW_ERROR(errormsg)\
TRIGGER_EVENT(GUIEvents::GUIErrorRaise, nullptr, (QObject*)&errormsg);


const char * getStatusString(int status)
{
    switch (status) {
        case SCANNING:
            return "SCANNING";
        case READY:
            return "Ready";
        case BUSY:
            return "BUSY";
        case ERROR:
            return "ERROR";
    }
    return "";
}


std::string getJsonFromPatInf(QObject* obj)
{
    return ((QString*)obj)->toStdString();
}

void ErrorCallback(const char * msg)
{
    DeviceManager::Default()->setErrorOccurred(true);
    printf("Error Callback , message:%s\r\n", msg);
    QString m(msg);
    THROW_ERROR(m);
}



void DeviceManager::initDevice() {
    InitLib(ErrorCallback);

    deviceInfTimerID = startTimer(1000);

    // empty scan
    connect(EventCenter::Default(),&EventCenter::RequestEmptyScan,[=](QObject* sender, QObject* detail){
        std::string json= getJsonFromPatInf(detail);
        qDebug()<<json.c_str();
        void * jss = malloc(json.size());
        memcpy(jss,json.c_str(),json.size());
        processScan((char*)jss,true);
    });
    // Patient scan
    connect(EventCenter::Default(),&EventCenter::RequestPatientScan,[=](QObject* sender, QObject* detail){
        std::string json= getJsonFromPatInf(detail);
        qDebug()<<json.c_str();
        if (!json.empty())
        {
            void * jss = malloc(json.size());
            memcpy(jss,json.c_str(),json.size());
            processScan((char*)jss);
        }
    });
    // stop
    connect(EventCenter::Default(),&EventCenter::RequestStop,[=]() {
        TRIGGER_EVENT(GUIEvents::InvokeOperationStart, nullptr, nullptr);
        qDebug()<<"GetStatus";
        StatusInfo inf = GetStatus();
        qDebug()<<"Stop request status, status:%s"<<getStatusString(inf.status);
        if (inf.status == SCANNING) {
            //ScanControl fail
            qDebug()<<"Request stop!";
            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);
        }

        TRIGGER_EVENT(GUIEvents::InvokeOperationEnd, nullptr, nullptr);
        TRIGGER_EVENT(GUIEvents::ResponseStop, nullptr, nullptr);

    });
    // preview
    connect(EventCenter::Default(),&EventCenter::RequestPreviewScan,[=](){
        TRIGGER_EVENT(GUIEvents::InvokeOperationStart, nullptr, nullptr);
        qDebug()<<"GetStatus";
        StatusInfo inf = GetStatus();
        qDebug() << "PreviewScan request status, status:" << getStatusString(inf.status);
        if (inf.status==READY)
        {
            //ScanControl
            qDebug()<<"Request preview!";
            if(!ScanControl(PREVIEW_SCAN))
            {
                qDebug()<<"Preview success!";
                lastStatus = SCANNING;
                previewing = true;
//                timerID = startTimer(500);
                TRIGGER_EVENT(GUIEvents::ResponsePreview, nullptr, nullptr);
                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!";
    });

    previewDataCaller = QThread::create([=](){
        while (!endLoop)
        {
            if (!previewing) {
                qDebug()<<"Preview data reader long sleep!";
                QThread::sleep(3);
                continue;
            }
            qDebug()<<"GetStatus";
            StatusInfo inf = GetStatus();
            qDebug() << "GetPreviewData request status, status:" << getStatusString(inf.status);
            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);
                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!";
            }
            QThread::msleep(100);
        }
    });
    previewDataCaller->start();
}

void DeviceManager::timerEvent(QTimerEvent *event) {
    //scanning progress timer
    if (event->timerId() !=deviceInfTimerID)
    {
        qDebug()<<"GetStatus";
        StatusInfo inf = GetStatus();
        qDebug() << "Scanning request status, status:" << getStatusString(inf.status);
        if (errorOccurred)
        {
            qDebug() << "Error occurred, exit progress timer" << inf.progress;
            goto exitTimer;
        }
        if (previewing)
        {
            //错误timer
            goto exitTimer;
        }
        //设备正常扫描中
        if (inf.status==SCANNING)
        {
            lastStatus = SCANNING;
            //normal scan
            QVariant var(inf.progress);
            qDebug() << "Normal scan, invoke InvokeOperationProgress:" << inf.progress;
            TRIGGER_EVENT(GUIEvents::InvokeOperationProgress, nullptr, (QObject*)&var);
            return;
        } else{
            //未发生错误并且，之前状态是扫描，代表正常扫描完成
            if (lastStatus == SCANNING)
            {
                qDebug() << "Scan finished" ;
                QVariant var(true);
                qDebug() << "InvokeOperationEnd" ;
                TRIGGER_EVENT(GUIEvents::InvokeOperationEnd, nullptr, (QObject*)&var);
                lastStatus = -1;
                previewing = false;
                QString s("%1  %2");
                s = s.arg(QDateTime::currentDateTime().toString("yyyy/MM/dd HH:mm:ss")).arg("Scan finished");
                TRIGGER_EVENT(GUIEvents::GlobalBannerMessage, nullptr,(QObject*)&s);
            }
        }
        exitTimer:
        qDebug() << "Scanning progress Timer exit";
        killTimer(timerID);
        timerID=-1;
        lastStatus = -1;
        previewing = false;
//        TRIGGER_EVENT(GUIEvents::GlobalBannerMessage, nullptr,nullptr);
        return;
    } else{
        QString temp = QString(GetDeviceInfo(MEAN_TEMPERATURE));
        TRIGGER_EVENT(GUIEvents::ResponseDeviceTemperature, nullptr, (QObject*)&temp);
    }
}

void DeviceManager::processScan(const char *json, bool empty) {
    static QString msg = "Start scan...";
    TRIGGER_EVENT(GUIEvents::InvokeOperationStart, nullptr, (QObject*)&msg);
    qDebug() << "SetScanInfo>>>>>>>>>>>>>>>>>>>>" ;
    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";
    qDebug()<<"GetStatus";
    StatusInfo inf = GetStatus();
    qDebug() << "Scan start request status, status:" << getStatusString(inf.status);
    if (inf.status==READY)
    {
        //ScanControl fail
        qDebug() << "ScanControl start>>>>>>>>>>>>>>>>>>>>>";
        if(!ScanControl(SCAN)) {
            qDebug() << ">>>>>>>>>>>>>>>>>>>>>ScanControl success";
            lastStatus = SCANNING;
            qDebug() << "Start progress timer";
            timerID = startTimer(300);
            return;
        }
        qDebug() << ">>>>>>>>>>>>>>>>>>>>>ScanControl failed";
    }
    QString errmsg("Start scan operation fail!");
    THROW_ERROR(errmsg);
}