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 <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)
{
    printf("Error Callback , message:%s\r\n", msg);
    QString m(msg);
    THROW_ERROR(m);
}



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

    deviceInfTimerID = startTimer(1000);
    // global error flag
    connect(EventCenter::Default(),&EventCenter::GUIErrorRaise,[=](QObject* sender, QObject* detail){
        this->errorOccured = true;
    });
    // empty scan
    connect(EventCenter::Default(),&EventCenter::RequestEmptyScan,[=](QObject* sender, QObject* detail){
        std::string json= getJsonFromPatInf(detail);
        qDebug()<<json.c_str();
        processScan(json.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())
        {
            processScan(json.c_str());
        }
    });
    // 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;
                return;
            }
            lastStatus = -1;
            previewing = false;
        }
        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);
                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)
        {
            qDebug()<<"Preview data reader sleep!";
            QThread::msleep(500);
            if (!previewing) 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) continue;
                qDebug() << "Preview data response event start!";
                TRIGGER_EVENT(GUIEvents::ResponsePreviewData, nullptr, (QObject *) (&bytes));
                qDebug() << "Preview data response event end!";
            }
        }
    });
    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 (errorOccured)
        {
            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);
        } else{
            //未发生错误并且，之前状态是扫描，代表正常扫描完成
            if (lastStatus == SCANNING)
            {
                qDebug() << "Scan finished" ;
                QVariant var(true);
                qDebug() << "InvokeOperationEnd" ;
                TRIGGER_EVENT(GUIEvents::InvokeOperationEnd, nullptr, (QObject*)&var);
                lastStatus = -1;
                previewing = false;
            }
            return;
        }
        exitTimer:
        killTimer(timerID);
        timerID=-1;
        lastStatus = -1;
        previewing = false;
        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);
}