chris/OSCAR-code
1
0
Fork 0
mirror of https://gitlab.com/pholy/OSCAR-code.git synced 2025-04-05 10:40:42 +00:00
Code Issues Packages Projects Releases Wiki Activity
be6c04e619
OSCAR-code/sleepyhead/oximetry.cpp
Mark Watkins be6c04e619 GUI appearance tweaks
2014-05-17 21:33:33 +10:00

2165 lines
63 KiB
C++
Raw Blame History

/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 4 -*-
* vim: set ts=8 sts=4 et sw=4 tw=99:
*
* Oximetry
*
* Copyright (c) 2011-2014 Mark Watkins <jedimark@users.sourceforge.net>
*
* This file is subject to the terms and conditions of the GNU General Public
* License. See the file COPYING in the main directory of the Linux
* distribution for more details. */
#include <QApplication>
#include <QDebug>
#include <QProgressBar>
#include <QFileDialog>
#include <QMessageBox>
#include <QLabel>
#include <QLocale>
#include <QTimer>
#include <QCalendarWidget>
#include <QTextCharFormat>
#include <qextserialenumerator.h>
#include "oximetry.h"
#include "ui_oximetry.h"
#include "common_gui.h"
#include "SleepLib/loader_plugins/cms50_loader.h"
#include "SleepLib/event.h"
#include "SleepLib/calcs.h"
#include "Graphs/gFooBar.h"
#include "Graphs/gXAxis.h"
#include "Graphs/gSummaryChart.h"
#include "Graphs/gLineChart.h"
#include "Graphs/gYAxis.h"
#include "Graphs/gLineOverlay.h"
#define SERIAL_DEBUG 1
extern QLabel *qstatus2;
#include "mainwindow.h"
extern MainWindow *mainwin;
int lastpulse;
SerialOximeter::SerialOximeter(QObject *parent, QString oxiname, QString portname,
BaudRateType baud, FlowType flow, ParityType parity, DataBitsType databits,
StopBitsType stopbits) :
QObject(parent),
session(nullptr), pulse(nullptr), spo2(nullptr), plethy(nullptr), m_port(nullptr),
m_opened(false),
m_oxiname(oxiname),
m_portname(portname),
m_baud(baud),
m_flow(flow),
m_parity(parity),
m_databits(databits),
m_stopbits(stopbits)
{
machine = PROFILE.GetMachine(MT_OXIMETER);
if (!machine) {
// Create generic Serial Oximeter object..
CMS50Loader *l = dynamic_cast<CMS50Loader *>(GetLoader("CMS50"));
if (l) {
machine = l->CreateMachine(p_profile);
}
qDebug() << "Create Oximeter device";
}
timer = new QTimer(this);
connect(timer, SIGNAL(timeout()), this, SLOT(Timeout()));
import_mode = false;
m_mode = SO_WAIT;
}
SerialOximeter::~SerialOximeter()
{
if (m_opened) {
if (m_port) { m_port->close(); }
}
disconnect(timer, SIGNAL(timeout()), this, SLOT(Timeout()));
delete timer;
}
void SerialOximeter::Timeout()
{
qDebug() << "Timeout!";
if (!import_mode) { emit(liveStopped(session)); }
}
bool SerialOximeter::Open(QextSerialPort::QueryMode mode)
{
if (m_portname.isEmpty()) {
qDebug() << "Tried to open with empty portname";
return false;
}
qDebug() << "Opening serial port" << m_portname << "in mode" << mode;
if (m_opened) { // Open already?
// Just close it
if (m_port) { m_port->close(); }
}
m_portmode = mode;
m_callbacks = 0;
m_port = new QextSerialPort(m_portname, m_portmode);
m_port->setBaudRate(m_baud);
m_port->setFlowControl(m_flow);
m_port->setParity(m_parity);
m_port->setDataBits(m_databits);
m_port->setStopBits(m_stopbits);
if (m_port->open(QIODevice::ReadWrite) == true) {
// if (m_mode==QextSerialPort::EventDriven)
connect(m_port, SIGNAL(readyRead()), this, SLOT(ReadyRead()));
//connect(port, SIGNAL(dsrChanged(bool)), this, SLOT(DsrChanged(bool)));
if (!(m_port->lineStatus() & LS_DSR)) {
qDebug() << "check device is turned on";
}
qDebug() << "listening for data on" << m_port->portName();
return m_opened = true;
} else {
qDebug() << "device failed to open:" << m_port->errorString();
return m_opened = false;
}
}
void SerialOximeter::Close()
{
qDebug() << "Closing serial port" << m_portname;
if (!m_opened) {
return;
}
m_port->flush();
disconnect(m_port, 0, 0, 0); // SIGNAL(readyRead()), this, SLOT(ReadyRead()));
if (m_port) {
m_port->close();
}
//if (m_portmode==QextSerialPort::EventDriven)
m_mode = SO_OFF;
m_opened = false;
}
void SerialOximeter::setPortName(QString portname)
{
if (m_opened) {
qDebug() << "Can't change serial PortName settings while port is open!";
return;
}
m_portname = portname;
}
void SerialOximeter::setBaudRate(BaudRateType baud)
{
if (m_opened) {
qDebug() << "Can't change serial BaudRate settings while port is open!";
return;
}
m_baud = baud;
}
void SerialOximeter::setFlowControl(FlowType flow)
{
if (m_opened) {
qDebug() << "Can't change serial FlowControl settings while port is open!";
return;
}
m_flow = flow;
}
void SerialOximeter::setParity(ParityType parity)
{
if (m_opened) {
qDebug() << "Can't change serial Parity settings while port is open!";
return;
}
m_parity = parity;
}
void SerialOximeter::setDataBits(DataBitsType databits)
{
if (m_opened) {
qDebug() << "Can't change serial DataBit settings while port is open!";
return;
}
m_databits = databits;
}
void SerialOximeter::setStopBits(StopBitsType stopbits)
{
if (m_opened) {
qDebug() << "Can't change serial StopBit settings while port is open!";
return;
}
m_stopbits = stopbits;
}
void SerialOximeter::addPulse(qint64 time, EventDataType pr)
{
//EventDataType min=0,max=0;
if (pr > 0) {
if (lastpr == 0) {
if (pulse->count() == 0) {
pulse->setFirst(time);
if (session->eventlist[OXI_Pulse].size() <= 1) {
session->setFirst(OXI_Pulse, time);
if (session->first() == 0) {
session->set_first(time);
}
}
} else {
qDebug() << "Shouldn't happen in addPulse()";
}
}
pulse->AddEvent(time, pr);
session->setCount(OXI_Pulse, session->count(OXI_Pulse) + 1);
session->setLast(OXI_Pulse, time);
session->set_last(time);
} else {
if (lastpr != 0) {
if (pulse->count() > 0) {
pulse->AddEvent(time, lastpr);
this->compactToEvent(pulse);
session->setLast(OXI_Pulse, time);
pulse = session->AddEventList(OXI_Pulse, EVL_Event);
}
}
}
lastpr = pr;
emit(updatePulse(pr));
}
void SerialOximeter::addSpO2(qint64 time, EventDataType o2)
{
//EventDataType min=0,max=0;
if (o2 > 0) {
if (lasto2 == 0) {
if (spo2->count() == 0) {
spo2->setFirst(time);
if (session->eventlist[OXI_SPO2].size() <= 1) {
session->setFirst(OXI_SPO2, time);
if (session->first() == 0) {
session->set_first(time);
}
}
} else {
qDebug() << "Shouldn't happen in addSpO2()";
}
}
spo2->AddEvent(time, o2);
session->setCount(OXI_SPO2, session->count(OXI_SPO2) + 1);
session->setLast(OXI_SPO2, time);
session->set_last(time);
} else {
if (lasto2 != 0) {
if (spo2->count() > 0) {
spo2->AddEvent(time, lasto2);
this->compactToEvent(spo2);
session->setLast(OXI_SPO2, time);
spo2 = session->AddEventList(OXI_SPO2, EVL_Event);
}
}
}
lasto2 = o2;
emit(updateSpO2(o2));
}
void SerialOximeter::addPlethy(qint64 time, EventDataType pleth)
{
if (!plethy) {
plethy = new EventList(EVL_Event);
session->eventlist[OXI_Plethy].push_back(plethy);
session->setFirst(OXI_Plethy, lasttime);
plethy->setFirst(lasttime);
}
plethy->AddEvent(time, pleth);
session->setCount(OXI_Plethy, plethy->count()); // update the cache
session->setMin(OXI_Plethy, plethy->Min());
session->setMax(OXI_Plethy, plethy->Max());
session->setLast(OXI_Plethy, time);
session->set_last(time);
plethy->setLast(time);
}
void SerialOximeter::compactToWaveform(EventList *el)
{
double rate = double(el->duration()) / double(el->count());
el->setType(EVL_Waveform);
el->setRate(rate);
el->getTime().clear();
}
void SerialOximeter::compactToEvent(EventList *el)
{
if (el->count() < 2) { return; }
EventList nel(EVL_Waveform);
EventDataType t = 0, lastt = 0; //el->data(0);
qint64 ti = 0; //=el->time(0);
//nel.AddEvent(ti,lastt);
bool f = false;
qint64 lasttime = 0;
EventDataType min = 999, max = 0;
for (quint32 i = 0; i < el->count(); i++) {
t = el->data(i);
ti = el->time(i);
f = false;
if (t != 0) {
if (t != lastt) {
if (!lasttime) {
nel.setFirst(ti);
}
nel.AddEvent(ti, t);
if (t < min) { min = t; }
if (t > max) { max = t; }
lasttime = ti;
f = true;
}
} else {
if (lastt != 0) {
nel.AddEvent(ti, lastt);
lasttime = ti;
f = true;
}
}
lastt = t;
}
if (!f) {
if (t != 0) {
nel.AddEvent(ti, t);
lasttime = ti;
}
}
el->setFirst(nel.first());
el->setLast(nel.last());
el->setMin(min);
el->setMax(max);
el->getData().clear();
el->getTime().clear();
el->setCount(nel.count());
el->getData() = nel.getData();
el->getTime() = nel.getTime();
}
void SerialOximeter::compactAll()
{
if (!session) { return; }
QHash<ChannelID, QVector<EventList *> >::iterator i;
qint64 tminx = 0, tmaxx = 0, minx, maxx;
EventDataType min, max;
for (i = session->eventlist.begin(); i != session->eventlist.end(); i++) {
const ChannelID &code = i.key();
min = 999, max = 0;
minx = maxx = 0;
for (int j = 0; j < i.value().size(); j++) {
EventList *e = i.value()[j];
if ((code == OXI_SPO2) || (code == OXI_Pulse)) {
compactToEvent(e);
} else if (code == OXI_Plethy) {
compactToWaveform(e);
}
if (min > e->Min()) {
min = e->Min();
}
if (max < e->Max()) {
max = e->Max();
}
if (!minx || (minx > e->first())) {
minx = e->first();
}
if (!maxx || (maxx < e->last())) {
maxx = e->last();
}
}
if ((code == OXI_SPO2) || (code == OXI_Pulse) || (code == OXI_Plethy)) {
session->setMin(code, min);
session->setMax(code, max);
if (minx != 0) {
session->setFirst(code, minx);
if (!tminx || tminx > minx) { tminx = minx; }
}
if (maxx != 0) {
session->setLast(code, maxx);
if (!tmaxx || tmaxx < max) { tmaxx = maxx; }
}
}
}
if (tminx > 0) { session->really_set_first(tminx); }
if (tmaxx > 0) { session->really_set_last(tmaxx); }
}
Session *SerialOximeter::createSession(QDateTime date)
{
if (session) {
delete session;
}
int sid = date.toTime_t();
lasttime = qint64(sid) * 1000L;
lasto2 = lastpr = 0;
session = new Session(machine, sid);
session->SetChanged(true);
session->set_first(lasttime);
pulse = new EventList(EVL_Event);
spo2 = new EventList(EVL_Event);
plethy = nullptr;
session->eventlist[OXI_Pulse].push_back(pulse);
session->eventlist[OXI_SPO2].push_back(spo2);
session->setFirst(OXI_Pulse, lasttime);
session->setFirst(OXI_SPO2, lasttime);
pulse->setFirst(lasttime);
spo2->setFirst(lasttime);
m_callbacks = 0;
emit(sessionCreated(session));
return session;
}
bool SerialOximeter::startLive()
{
import_mode = false;
killTimers();
m_mode = SO_LIVE;
lastpr = lasto2 = 0;
buffer.clear();
if (!m_opened && !Open(QextSerialPort::EventDriven)) { return false; }
createSession();
return true;
}
void SerialOximeter::stopLive()
{
if (timer->isActive()) { timer->stop(); }
m_mode = SO_WAIT;
if (session) {
compactAll();
calcSPO2Drop(session);
calcPulseChange(session);
}
}
CMS50Serial::CMS50Serial(QObject *parent, QString portname = "") :
SerialOximeter(parent, "CMS50", portname, BAUD19200, FLOW_OFF, PAR_ODD, DATA_8, STOP_1)
{
cms50timer = new QTimer(this);
cms50timer2 = new QTimer(this);
}
CMS50Serial::~CMS50Serial()
{
delete cms50timer2;
delete cms50timer;
}
void CMS50Serial::killTimers()
{
if (cms50timer->isActive()) {
cms50timer->stop();
}
if (cms50timer2->isActive()) {
cms50timer2->stop();
}
}
void CMS50Serial::import_process()
{
if (!session) {
qDebug() << "User pushing import too many times in a row?";
return;
}
mainwin->getOximetry()->graphView()->setEmptyText(tr("Processing..."));
mainwin->getOximetry()->graphView()->redraw();
qDebug() << "CMS50 import complete. Processing" << data.size() << "bytes";
unsigned short a, pl, o2, lastpl = 0, lasto2 = 0;
int i = 0;
int size = data.size();
EventList *pulse = (session->eventlist[OXI_Pulse][0]);
EventList *spo2 = (session->eventlist[OXI_SPO2][0]);
// int d=abs(oxitime.secsTo(cpaptime));
QDateTime seltime = oxitime;
if (!cpaptime.isNull()) {
if (QMessageBox::question(mainwin, STR_MessageBox_Question,
tr("Did you remember to start your oximeter recording at exactly the same time you started your CPAP machine?"),
QMessageBox::Yes, QMessageBox::No) == QMessageBox::No) {
if (!cms50dplus) {
// Oximeter has a clock.. Hopefully the user remembered to set their clock on the device..
QMessageBox::information(mainwin, STR_MessageBox_Information,
tr("That's ok, I will use the time provided by your oximeter, however it will sync better next time if you start your oximeter recording at the same time your CPAP machine starts up.")+
"\n\n"+
STR_MessageBox_PleaseNote+": "+tr("If you haven't set your oximeter clock you will have to manually edit this time before saving this oximetry session."),
QMessageBox::Ok);
} else {
//CMS50D+, and the user didn't start at the same time.. Kludge it because they likely turned it on around about the same time anyway.
QMessageBox::information(mainwin, STR_MessageBox_Information,
tr("It looks like your oximeter doesn't provide a valid start time, I'm going to set this oximetry session starting time to the CPAP starting time anyway.")+"\n\n"+
tr("You may have to adjust it manually if you remember the real start time before saving this session.")+"\n\n"+
tr("(Also, did you remember to import todays CPAP data first?)"),
QMessageBox::Ok);
seltime = cpaptime;
}
} else {
// The best solution.. the user (hopefully) started both devices at the same time, so we pick the cpap sessions start time for optimal sync.
QMessageBox::information(mainwin, STR_MessageBox_Information,
tr("The most recent CPAP Session time has been selected as the start of your oximetry session.")+"\n\n"+
tr("If you forgot to import todays CPAP data first, go and do that now, then import again from your oximeter."),
QMessageBox::Ok);
seltime = cpaptime;
}
} else {
if (cms50dplus) {
// Worst case, CMS50D+ and no CPAP data.. the time is basically set to midnight the current day.
QMessageBox::information(mainwin, STR_MessageBox_Information,
tr("No valid start time was provided for this oximeter session.")+"\n\n"+
tr("You will likely have to adjust your oximeter sessions start time before saving."),
QMessageBox::Ok);
} else {
// No point nagging the user at all in this case.. they don't have any CPAP data loaded, so they are just using SleepyHead with the oximeter
}
}
lasttime = seltime.toTime_t();
session->SetSessionID(lasttime);
lasttime *= 1000;
//spo2->setFirst(lasttime);
EventDataType plmin = 999, plmax = 0;
EventDataType o2min = 100, o2max = 0;
int plcnt = 0, o2cnt = 0;
qint64 lastpltime = 0, lasto2time = 0;
bool first = true;
while (i < (size - 3)) {
a = data.at(i++); // low bits are supposedly the high bits of the heart rate? not here
pl = ((data.at(i++) & 0x7f) | ((a & 1) << 7)) & 0xff;
o2 = data.at(i++) & 0x7f;
// Faulty data..?
if (o2 < 50) {
o2 = 0;
}
if (pl != 0) {
if (lastpl != pl) {
if (lastpl == 0 || !pulse) {
if (first) {
session->set_first(lasttime);
first = false;
}
if (plcnt == 0) {
session->setFirst(OXI_Pulse, lasttime);
}
if (pulse && pulse->count() == 0) {
} else {
pulse = new EventList(EVL_Event);
session->eventlist[OXI_Pulse].push_back(pulse);
}
}
lastpltime = lasttime;
pulse->AddEvent(lasttime, pl);
if (pl < plmin) { plmin = pl; }
if (pl > plmax) { plmax = pl; }
plcnt++;
}
} else {
if (lastpl != 0) {
pulse->AddEvent(lasttime, pl);
lastpltime = lasttime;
plcnt++;
}
}
if (o2 != 0) {
if (lasto2 != o2) {
if (lasto2 == 0 || !spo2) {
if (first) {
session->set_first(lasttime);
first = false;
}
if (o2cnt == 0) {
session->setFirst(OXI_SPO2, lasttime);
}
if (spo2 && spo2->count() == 0) {
} else {
spo2 = new EventList(EVL_Event);
session->eventlist[OXI_SPO2].push_back(spo2);
}
}
lasto2time = lasttime;
spo2->AddEvent(lasttime, o2);
if (o2 < o2min) { o2min = o2; }
if (o2 > o2max) { o2max = o2; }
o2cnt++;
}
} else {
if (lasto2 != 0) {
spo2->AddEvent(lasttime, o2);
lasto2time = lasttime;
o2cnt++;
}
}
lasttime += 1000;
//emit(updateProgress(float(i)/float(size)));
lastpl = pl;
lasto2 = o2;
}
/*if (pulse && (lastpltime!=lasttime) && (pl!=0)) {
// lastpl==pl
pulse->AddEvent(lasttime,pl);
lastpltime=lastpltime;
plcnt++;
}
if (spo2 && (lasto2time!=lasttime) && (o2!=0)) {
spo2->AddEvent(lasttime,o2);
lasto2time=lasttime;
o2cnt++;
}*/
qint64 rlasttime = qMax(lastpltime, lasto2time);
session->set_last(rlasttime);
session->setLast(OXI_Pulse, lastpltime);
session->setLast(OXI_SPO2, lasto2time);
session->setMin(OXI_Pulse, plmin);
session->setMax(OXI_Pulse, plmax);
session->setMin(OXI_SPO2, o2min);
session->setMax(OXI_SPO2, o2max);
session->setCount(OXI_Pulse, plcnt);
session->setCount(OXI_SPO2, o2cnt);
session->UpdateSummaries();
emit(importComplete(session));
disconnect(this, SIGNAL(importProcess()), this, SLOT(import_process()));
}
void CMS50Serial::ReadyRead()
{
if (m_mode == SO_OFF) {
return;
}
static int lastbytesize = 0;
QByteArray bytes;
int available = m_port->bytesAvailable();
bytes.resize(available);
m_port->read(bytes.data(), bytes.size());
if (m_mode == SO_WAIT) {
killTimers();
// Close();
return;
}
m_callbacks++;
if (!import_mode) {
if (bytes.size() == 1) { // CMS50D+ transmits a single 0 when switching off from finger out..
if (lastbytesize != 1) {
if (timer->isActive()) {
timer->stop();
}
// Set the Shutdown timer
timer->setSingleShot(true);
timer->setInterval(10000);
timer->start();
}
qDebug() << "Oximeter switched off.. wait for timeout?" << hex << bytes.at(0);
return;
} else {
// Cancel any shutdown timer if running
if (timer->isActive()) {
timer->stop();
}
}
}
lastbytesize = available;
unsigned char c, bc = import_mode ? 0xf0 : 0x80;
int i = 0;
while ((i < available) && (((c = (unsigned char)bytes.at(i)) & bc) != bc)) {
if (buffer.length() > 0) {
// If buffer is the start of a valid but short frame, add to it..
buffer.append(c);
}// otherwise dump these bytes, as they are corrupt.
++i;
}
// Copy the rest to the buffer.
for (; i < available; ++i) {
buffer.append(bytes.at(i));
}
unsigned char pulse, spo2, pwave, pbeat;
available = buffer.length();
bool pkt_short = false;
i = 0;
short hour, minute;
bool updated = false;
QString zdata = "";
int precbytes = received_bytes;
while (i < available) {
c = (unsigned char)buffer.at(i);
if ((c & 0xf0) == 0xf0) { // Record transmit trios all start with 0xf#
if ((i + 3) >= available) {
pkt_short = true;
break;
}
if (!import_mode) { // Skip if live mode and the user bumped the upload button by mistake
i += 3;
continue;
}
imp_callbacks++;
if (!started_import) {
for (int j = 0; j < 3; j++) { zdata += QString().sprintf("%02X ", (unsigned char)buffer.at(i + j)); }
qDebug() << "Recieved Rec Header:" << zdata;
zdata = "";
}
if (c == 0xf2) { // Is this a 3 byte header trio? (there are 3 sets of these at start of record data)
if (!started_import) { // Is this a record block header? Only need the first one
hour = (unsigned char)buffer.at(i + 1) & 0x7f;
minute = (unsigned char)buffer.at(i + 2) & 0x7f;
qDebug() << QString("Receiving Oximeter transmission %1:%2").arg(hour).arg(minute);
// set importing to true or whatever..
finished_import = false;
started_import = true;
started_reading = false;
killTimers();
qDebug() << "Getting ready for import";
// Hide the connect message box
if (mainwin->getOximetry()->connectDeviceMsgBox) {
//mainwin->getOximetry()->connectDeviceMsgBox->setText("Transfering Oximetry data from device");
mainwin->getOximetry()->disconnect(mainwin->getOximetry()->connectDeviceMsgBox,
SIGNAL(buttonClicked(QAbstractButton *)), mainwin->getOximetry(), SLOT(cancel_CheckPorts()));
mainwin->getOximetry()->close();
delete mainwin->getOximetry()->connectDeviceMsgBox;
mainwin->getOximetry()->connectDeviceMsgBox = nullptr;
}
mainwin->getOximetry()->graphView()->setEmptyText(tr("Please Wait, Importing..."));
mainwin->getOximetry()->graphView()->timedRedraw(50);
QDate oda = QDate::currentDate();
QTime oti = QTime(hour,
minute); // Only CMS50E/F's have a realtime clock. CMS50D+ will set this to midnight
cms50dplus = (hour == 0)
&& (minute == 0); // Either a CMS50D+ or it's really midnight, set a flag anyway for later to help choose the right sync time
// If the oximeter record time is more than the current time, then assume it was from the day before
// Or should I use split time preference instead??? Foggy Confusements..
if (oti > QTime::currentTime()) {
oda = oda.addDays(-1);
}
oxitime = QDateTime(oda, oti);
// Convert it to UTC
oxitime = oxitime.toTimeSpec(Qt::UTC);
qDebug() << "Session start (according to CMS50)" << oxitime << hex << buffer.at(
i + 1) << buffer.at(i + 2) << ":" << dec << hour << minute ;
// As an alternative, pick the first session of the last days data..
Day *day = PROFILE.GetDay(PROFILE.LastDay(), MT_CPAP);
if (day) {
int ti = day->first() / 1000L;
cpaptime = QDateTime::fromTime_t(ti);
qDebug() << "Guessing session starting from CPAP data" << cpaptime;
} else { cpaptime = QDateTime(); } // null
qDebug() << "Record Import:" << oxitime << cpaptime;
cb_reset = 1;
// CMS50D+ needs an end timer because it just stops dead after uploading
cms50timer2->singleShot(2000, this, SLOT(resetImportTimeout()));
}
i += 3;
} else {
if (!started_import) {
// Crap.. Missed the 0xf2 headers..
m_mode = SO_WAIT;
killTimers();
emit(importAborted());
mainwin->getOximetry()->graphView()->setEmptyText(
tr("Import Failed. Wait for oximeter and try again."));
mainwin->Notify(tr("Something went wrong with reading from the Oximeter.")+"\n"+tr("Please wait for oximeter to finish tranmitting than try restarting import again."),
tr("Import Failed"));
mainwin->getOximetry()->graphView()->timedRedraw(50);
break;
}
started_reading = true; // Sometimes errornous crap is sent after data rec header
// Recording import
if ((i + 2) >= available) {
pkt_short = true;
break;
}
pulse = (unsigned char)buffer.at(i + 1) & 0x7f;
spo2 = (unsigned char)buffer.at(i + 2) & 0x7f;
data.push_back(buffer.at(i));
data.push_back(buffer.at(i + 1));
data.push_back(buffer.at(i + 2));
received_bytes += 3;
i += 3;
}
} else if ((c & 0x80) == 0x80) {
if (import_mode && started_reading) { // (Sometimes errornous bytes get transfered after header)
qDebug() << "Stopped importing due to live data";
// We were importing, but now are done
killTimers();
started_import = false;
started_reading = false;
finished_import = true;
m_mode = SO_WAIT; // Temporarily pause until complete shutdown.
emit(importProcess());
break;
}
// Standard frame.. make sure theres the full 5 byte sequence
if ((i + 4) > available) {
pkt_short = true;
break;
}
if (!import_mode) {
pwave = (unsigned char)buffer.at(i + 1);
pbeat = (unsigned char)buffer.at(i + 2);
pulse = ((unsigned char)buffer.at(i + 3) & 0x7f) | ((pbeat & 0x40) << 1);
spo2 = (unsigned char)buffer.at(i + 4) & 0x7f;
addPlethy(lasttime, pwave);
addPulse(lasttime, pulse);
addSpO2(lasttime, spo2);
lasttime += 20;
updated = true;
}
#if SERIAL_DEBUG
//qDebug() << "Live: " << pulse << spo2 << pwave << pbeat;
#endif
// whatever depending on mode..
i += 5;
} else { break; }
}
#if SERIAL_DEBUG
if ((import_mode) && (received_bytes > precbytes)) {
qDebug() << "Received Bytes" << received_bytes - precbytes; // << ":" << zdata;
}
#endif
if (i > 0) {
// Trim any processed bytes from the buffer.
buffer = buffer.mid(i);
i = 0;
// available should be < 5 or 3 here..
}
available = buffer.length();
if (available > 0) {
if ((buffer.at(0) & 0x80) != 0x80) {
buffer.clear();
}
}
if (updated) {
emit(dataChanged());
}
}
void CMS50Serial::resetDevice()
{
qDebug() << "Sending reset code to CMS50 device";
//m_port->flush();
static unsigned char b1[3] = {0xf6, 0xf6, 0xf6};
if (m_port->write((char *)b1, 3) == -1) {
qDebug() << "Couldn't write data reset bytes to CMS50";
}
}
void CMS50Serial::requestData()
{
static unsigned char b1[2] = {0xf5, 0xf5};
qDebug() << "Sending request code to CMS50 device";
if (m_port->write((char *)b1, 2) == -1) {
qDebug() << "Couldn't write data request bytes to CMS50";
}
}
bool CMS50Serial::startImport()
{
buffer.clear();
data.clear();
killTimers();
m_mode = SO_IMPORT;
import_mode = true;
started_import = false;
started_reading = false;
finished_import = false;
imptime.start();
imp_callbacks = 0;
m_callbacks = 0;
cb_reset = 0;
import_fails = 0;
failcnt = 0;
connect(this, SIGNAL(importProcess()), this, SLOT(import_process()));
if (!m_opened && !Open(QextSerialPort::EventDriven)) {
return false;
}
// doesn't need to happen until process..
createSession();
#ifdef SERIAL_DEBUG
qDebug() << "Starting startImportTimer";
#endif
startImportTimeout();
return true;
}
void CMS50Serial::stopImport() // Silently stops import dead
{
disconnect(this, SIGNAL(importProcess()), this, SLOT(import_process()));
m_mode = SO_OFF;
// killTimers();
started_import = false;
import_mode = false;
finished_import = false;
}
void CMS50Serial::startImportTimeout()
{
if ((m_mode == SO_WAIT) || (m_mode == SO_OFF)
|| finished_import
|| started_import) {
return;
}
// Wait until events really are jammed on the CMS50D+ before re-requesting data.
if (imp_callbacks == 0) { // Frozen, but still hasn't started?
int elapsed = imptime.elapsed() / 1000;
if (elapsed > 30) { // Give up after ~20 seconds
m_mode = SO_WAIT;
killTimers();
emit(importAborted());
mainwin->getOximetry()->graphView()->setEmptyText(tr("Import Failed"));
mainwin->getOximetry()->graphView()->timedRedraw(50);
return;
} else {
QString a = tr("Set Oximeter to Upload");
for (int j = 0; j < elapsed; j++) { a += "."; }
mainwin->getOximetry()->graphView()->setEmptyText(a);
mainwin->getOximetry()->graphView()->timedRedraw(50);
// Note: Newer CMS50 devices transmit from user input
requestData();
}
// Schedule another callback to make sure it's started
cms50timer->singleShot(1000, this, SLOT(startImportTimeout()));
}
}
void CMS50Serial::resetImportTimeout()
{
if ((m_mode == SO_WAIT) || (finished_import)) {
return;
}
if (imp_callbacks != cb_reset) {
// Still receiving data.. reset timer
qDebug() << "Still receiving data in resetImportTimeout()";
if (cms50timer2->isActive()) {
cms50timer2->stop();
}
cms50timer2->singleShot(2000, this, SLOT(resetImportTimeout()));
} else {
qDebug() << "Oximeter device stopped transmitting.. Transfer complete";
// We were importing, but now are done
if (!finished_import && (started_import && started_reading)) {
qDebug() << "Switching CMS50 back to live mode and finalizing import";
// Turn back on live streaming so the end of capture can be dealt with
cms50timer2->stop();
m_port->flush();
resetDevice(); // Send Reset to CMS50D+
//started_import=false;
finished_import = true;
m_mode = SO_WAIT; // Temporarily pause until complete shutdown.
emit(importProcess());
return;
}
qDebug() << "Should CMS50 resetImportTimeout reach here?";
// else what???
}
cb_reset = imp_callbacks;
}
Oximetry::Oximetry(QWidget *parent, gGraphView *shared) :
QWidget(parent),
ui(new Ui::Oximetry)
{
m_shared = shared;
ui->setupUi(this);
port = nullptr;
portname = "";
oximeter = new CMS50Serial(this);
day = new Day(oximeter->getMachine());
QVBoxLayout *framelayout = new QVBoxLayout(ui->graphArea);
ui->graphArea->setLayout(framelayout);
QFrame *border = new QFrame(ui->graphArea);
framelayout->setMargin(1);
border->setFrameShape(QFrame::StyledPanel);
framelayout->addWidget(border,1);
layout = new QHBoxLayout(ui->graphArea);
layout->setSpacing(0);
layout->setMargin(0);
layout->setContentsMargins(0, 0, 0, 0);
border->setLayout(layout);
border->setAutoFillBackground(false);
GraphView = new gGraphView(ui->graphArea, m_shared);
GraphView->setSizePolicy(QSizePolicy::Expanding, QSizePolicy::Expanding);
scrollbar = new MyScrollBar(ui->graphArea);
scrollbar->setOrientation(Qt::Vertical);
scrollbar->setSizePolicy(QSizePolicy::Maximum, QSizePolicy::Expanding);
scrollbar->setMaximumWidth(20);
GraphView->setScrollBar(scrollbar);
layout->addWidget(GraphView, 1);
layout->addWidget(scrollbar, 0);
layout->layout();
PLETHY = new gGraph(GraphView, schema::channel[OXI_Plethy].label(),
schema::channel[OXI_Plethy].units(), 120);
CONTROL = new gGraph(GraphView, tr("Control"), "", 75);
PULSE = new gGraph(GraphView, schema::channel[OXI_Pulse].label(),
schema::channel[OXI_Pulse].units(), 120);
SPO2 = new gGraph(GraphView, schema::channel[OXI_SPO2].label(), schema::channel[OXI_SPO2].units(),
120);
foobar = new gShadowArea();
CONTROL->AddLayer(foobar);
Layer *cl = new gLineChart(OXI_Plethy);
CONTROL->AddLayer(cl);
cl->SetDay(day);
CONTROL->setBlockZoom(true);
for (int i = 0; i < GraphView->size(); i++) {
gGraph *g = (*GraphView)[i];
g->AddLayer(new gXAxis(), LayerBottom, 0, gXAxis::Margin);
g->AddLayer(new gYAxis(), LayerLeft, gYAxis::Margin);
g->AddLayer(new gXGrid());
}
plethy = new gLineChart(OXI_Plethy, COLOR_Plethy, false, true);
plethy->SetDay(day);
CONTROL->AddLayer(plethy); //new gLineChart(OXI_Plethysomogram));
pulse = new gLineChart(OXI_Pulse, COLOR_Pulse, true);
//pulse->SetDay(day);
spo2 = new gLineChart(OXI_SPO2, COLOR_SPO2, true);
//spo2->SetDay(day);
PLETHY->AddLayer(plethy);
PULSE->AddLayer(lo1 = new gLineOverlayBar(OXI_PulseChange, COLOR_PulseChange, STR_TR_PC, FT_Span));
SPO2->AddLayer(lo2 = new gLineOverlayBar(OXI_SPO2Drop, COLOR_SPO2Drop, STR_TR_O2, FT_Span));
PULSE->AddLayer(pulse);
SPO2->AddLayer(spo2);
PULSE->setDay(day);
SPO2->setDay(day);
lo1->SetDay(day);
lo2->SetDay(day);
//go->SetDay(day);
GraphView->setEmptyText(tr("No Oximetry Data"));
GraphView->redraw();
on_RefreshPortsButton_clicked();
ui->RunButton->setChecked(false);
ui->saveButton->setEnabled(false);
GraphView->LoadSettings("Oximetry");
QLocale locale = QLocale::system();
QString shortformat = locale.dateFormat(QLocale::ShortFormat);
if (!shortformat.toLower().contains("yyyy")) {
shortformat.replace("yy", "yyyy");
}
ui->dateEdit->setDisplayFormat(shortformat + " HH:mm:ss");
//Qt::DayOfWeek dow=firstDayOfWeekFromLocale();
//ui->dateEdit->calendarWidget()->setFirstDayOfWeek(dow);
// Stop both calendar drop downs highlighting weekends in red
//QTextCharFormat format = ui->dateEdit->calendarWidget()->weekdayTextFormat(Qt::Saturday);
//format.setForeground(QBrush(COLOR_Text, Qt::SolidPattern));
//ui->dateEdit->calendarWidget()->setWeekdayTextFormat(Qt::Saturday, format);
//ui->dateEdit->calendarWidget()->setWeekdayTextFormat(Qt::Sunday, format);
dont_update_date = false;
}
Oximetry::~Oximetry()
{
delete ui;
}
void Oximetry::closeEvent(QCloseEvent *event)
{
delete oximeter;
GraphView->SaveSettings("Oximetry");
QWidget::closeEvent(event);
}
void Oximetry::on_RefreshPortsButton_clicked()
{
QList<QextPortInfo> ports = QextSerialEnumerator::getPorts();
ui->SerialPortsCombo->clear();
int z = 0;
QString firstport;
bool current_found = false;
const QString STR_USB = "USB";
// Windows build mixes these up
#if defined(Q_OS_WIN32) || defined(Q_OS_MAC)
#define qesPORTNAME portName
#else
#define qesPORTNAME physName
#endif
for (int i = 0; i < ports.size(); i++) {
if (!ports.at(i).friendName.isEmpty()) {
if (ports.at(i).friendName.toUpper().contains(STR_USB)) {
if (firstport.isEmpty()) { firstport = ports.at(i). qesPORTNAME; }
if (!portname.isEmpty() && ports.at(i).qesPORTNAME == portname) { current_found = true; }
ui->SerialPortsCombo->addItem(ports.at(i).qesPORTNAME);
z++;
}
} else { // Mac stuff.
if (ports.at(i).portName.toUpper().contains(STR_USB)
|| ports.at(i).portName.toUpper().contains("SPO2")) {
if (firstport.isEmpty()) { firstport = ports.at(i).portName; }
if (!portname.isEmpty() && ports.at(i).portName == portname) { current_found = true; }
ui->SerialPortsCombo->addItem(ports.at(i).portName);
z++;
}
}
qDebug() << "Serial Port:" << ports.at(i).qesPORTNAME << ports.at(i).friendName;
qDebug() << "port name:" << ports.at(i).portName;
qDebug() << "phys name:" << ports.at(i).physName;
qDebug() << "friendly name:" << ports.at(i).friendName;
qDebug() << "enumerator name:" << ports.at(i).enumName;
}
if (z > 0) {
ui->RunButton->setEnabled(true);
ui->ImportButton->setEnabled(true);
if (!current_found) { portname = firstport; }
} else {
ui->RunButton->setEnabled(false);
ui->ImportButton->setEnabled(false);
portname = "";
}
oximeter->setPortName(portname);
}
void Oximetry::serialImport()
{
connect(oximeter, SIGNAL(importComplete(Session *)), this, SLOT(import_complete(Session *)));
connect(oximeter, SIGNAL(importAborted()), this, SLOT(import_aborted()));
connect(oximeter, SIGNAL(updateProgress(float)), this, SLOT(update_progress(float)));
PLETHY->setVisible(false);
day->getSessions().clear();
GraphView->setDay(day);
//GraphView->setEmptyText(tr("Make Sure Oximeter is Ready"));
//GraphView->redraw();
cancel_Import = false;
QTimer::singleShot(100, this, SLOT(timeout_CheckPorts()));
connectDeviceMsgBox = new QMessageBox(QMessageBox::Information, tr("Connect Oximeter"),
tr("Please connect oximeter device"),
QMessageBox::Cancel);
connect(connectDeviceMsgBox, SIGNAL(buttonClicked(QAbstractButton *)), this,
SLOT(cancel_CheckPorts(QAbstractButton *)));
connectDeviceMsgBox->exec();
// QApplication::processEvents();
}
void Oximetry::cancel_CheckPorts(QAbstractButton *)
{
qDebug() << "cancel_CheckPorts()";
cancel_Import = true;
disconnect(connectDeviceMsgBox, 0, 0,
0); //SIGNAL(buttonClicked(QAbstractButton*)),this,SLOT(cancel_CheckPorts()));
disconnect(oximeter, SIGNAL(importComplete(Session *)), this, SLOT(import_complete(Session *)));
disconnect(oximeter, SIGNAL(importAborted()), this, SLOT(import_aborted()));
disconnect(oximeter, SIGNAL(updateProgress(float)), this, SLOT(update_progress(float)));
connectDeviceMsgBox->close();
delete connectDeviceMsgBox;
connectDeviceMsgBox = nullptr;
if (oximeter->isImporting()) {
oximeter->stopImport();
}
}
void Oximetry::timeout_CheckPorts()
{
if (cancel_Import) {
return;
}
if (portname == "") {
qDebug() << "restarting timeout_CheckPorts()";
on_RefreshPortsButton_clicked();
if (portname == "") {
QTimer::singleShot(1000, this, SLOT(timeout_CheckPorts()));
return;
}
}
qDebug() << "Calling oximeter->startImport()";
if (!oximeter->startImport()) {
QTimer::singleShot(1000, this, SLOT(timeout_CheckPorts()));
return;
}
qDebug() << "Success at oximeter->startImport()";
disconnect(connectDeviceMsgBox, SIGNAL(buttonClicked(QAbstractButton *)), this,
SLOT(cancel_CheckPorts(QAbstractButton *)));
connectDeviceMsgBox->close();
delete connectDeviceMsgBox;
//connectDeviceMsgBox=nullptr;
connectDeviceMsgBox = new QMessageBox(QMessageBox::Information, tr("Device Connected"),
tr("Please make sure Oximeter device is in upload mode."),
QMessageBox::Cancel);
connect(connectDeviceMsgBox, SIGNAL(buttonClicked(QAbstractButton *)), this,
SLOT(cancel_CheckPorts(QAbstractButton *)));
connectDeviceMsgBox->exec();
//mainwin->Notify(tr("Please make sure Oximeter device is in upload mode."),tr("Device Connected"));
}
void Oximetry::RedrawGraphs()
{
GraphView->redraw();
}
void Oximetry::on_SerialPortsCombo_activated(const QString &arg1)
{
portname = arg1;
oximeter->setPortName(arg1);
}
void Oximetry::live_stopped(Session *session)
{
Q_UNUSED(session);
mainwin->Notify(tr("Oximetry live recording has been terminated due to timeout."));
//qDebug () << "Live Stopped";
on_RunButton_toggled(false);
}
void Oximetry::on_RunButton_toggled(bool checked)
{
if (!checked) {
oximeter->stopLive();
ui->RunButton->setText(tr("&Start"));
ui->SerialPortsCombo->setEnabled(true);
disconnect(oximeter, SIGNAL(dataChanged()), this, SLOT(data_changed()));
disconnect(oximeter, SIGNAL(updatePulse(float)), this, SLOT(pulse_changed(float)));
disconnect(oximeter, SIGNAL(updateSpO2(float)), this, SLOT(spo2_changed(float)));
disconnect(oximeter, SIGNAL(liveStopped(Session *)), this, SLOT(live_stopped(Session *)));
ui->saveButton->setEnabled(true);
ui->ImportButton->setEnabled(true);
lo2->SetDay(day);
lo1->SetDay(day);
if (oximeter->getSession()) {
saved_starttime = oximeter->getSession()->first();
}
//CONTROL->setVisible(true);
} else {
if (oximeter->getSession() && oximeter->getSession()->IsChanged()) {
int res=askSaveSession();
if (res == 0) {
on_saveButton_clicked();
return;
} else if (res == 2) {
return;
}
} // else it's already saved.
GraphView->setEmptyText(tr("Please Wait"));
GraphView->redraw();
PLETHY->setVisible(true);
SPO2->setVisible(true);
PULSE->setVisible(true);
PLETHY->setRecMinY(0);
PLETHY->setRecMaxY(128);
PULSE->setRecMinY(60);
PULSE->setRecMaxY(100);
SPO2->setRecMinY(90);
SPO2->setRecMaxY(100);
day->getSessions().clear();
//QTimer::singleShot(10000,this,SLOT(oximeter_running_check()));
if (!oximeter->startLive()) {
mainwin->Notify(tr("Oximetry Error!\n\nSomething is wrong with the device connection."));
return;
}
ui->saveButton->setEnabled(false);
day->AddSession(oximeter->getSession());
firstPulseUpdate = true;
firstSPO2Update = true;
secondPulseUpdate = true;
secondSPO2Update = true;
qint64 f = oximeter->getSession()->first();
//day->setFirst(f);
plethy->setMinX(f);
pulse->setMinX(f);
spo2->setMinX(f);
PLETHY->SetMinX(f);
CONTROL->SetMinX(f);
PULSE->SetMinX(f);
SPO2->SetMinX(f);
//graphView()->updateScale();
/*PLETHY->setForceMinY(0);
PLETHY->setForceMaxY(128);
PULSE->setForceMinY(30);
PULSE->setForceMaxY(180);
SPO2->setForceMinY(50);
SPO2->setForceMaxY(100); */
connect(oximeter, SIGNAL(dataChanged()), this, SLOT(data_changed()));
connect(oximeter, SIGNAL(updatePulse(float)), this, SLOT(pulse_changed(float)));
connect(oximeter, SIGNAL(updateSpO2(float)), this, SLOT(spo2_changed(float)));
connect(oximeter, SIGNAL(liveStopped(Session *)), this, SLOT(live_stopped(Session *)));
CONTROL->setVisible(false);
// connect.
ui->RunButton->setText(tr("&Stop"));
ui->SerialPortsCombo->setEnabled(false);
ui->ImportButton->setEnabled(false);
}
}
void Oximetry::data_changed()
{
qint64 last = oximeter->lastTime();
qint64 first = last - 30000L;
//day->setLast(last);
plethy->setMinX(first);
plethy->setMaxX(last);
pulse->setMinX(first);
pulse->setMaxX(last);
spo2->setMinX(first);
spo2->setMaxX(last);
plethy->setMinY((oximeter->Plethy())->Min());
plethy->setMaxY((oximeter->Plethy())->Max());
pulse->setMinY((oximeter->Pulse())->Min());
pulse->setMaxY((oximeter->Pulse())->Max());
spo2->setMinY((oximeter->Spo2())->Min());
spo2->setMaxY((oximeter->Spo2())->Max());
PLETHY->SetMinY((oximeter->Plethy())->Min());
PLETHY->SetMaxY((oximeter->Plethy())->Max());
PULSE->SetMinY((oximeter->Pulse())->Min());
PULSE->SetMaxY((oximeter->Pulse())->Max());
SPO2->SetMinY((oximeter->Spo2())->Min());
SPO2->SetMaxY((oximeter->Spo2())->Max());
/*PLETHY->MinY();
PLETHY->MaxY();
PULSE->MinY();
PULSE->MaxY();
SPO2->MinY();
SPO2->MaxY(); */
PLETHY->SetMaxX(last);
PULSE->SetMaxX(last);
CONTROL->SetMaxX(last);
SPO2->SetMaxX(last);
for (int i = 0; i < GraphView->size(); i++) {
(*GraphView)[i]->SetXBounds(first, last);
}
{
int len = (last - first) / 1000L;
int h = len / 3600;
int m = (len / 60) % 60;
int s = (len % 60);
if (qstatus2) { qstatus2->setText(QString().sprintf("Rec %02i:%02i:%02i", h, m, s)); } // translation fix?
}
GraphView->updateScale();
GraphView->timedRedraw(25);
}
extern QProgressBar *qprogress;
extern QLabel *qstatus;
void DumpBytes(int blocks, unsigned char *b, int len)
{
QString a = QString::number(blocks, 16) + ": Bytes " + QString::number(len, 16) + ": ";
for (int i = 0; i < len; i++) {
a.append(QString::number(b[i], 16) + " ");
}
qDebug() << a;
}
void Oximetry::oximeter_running_check()
{
if (!oximeter->isOpen()) {
if (oximeter->callbacks() == 0) {
qDebug() << "Not sure how oximeter_running_check gets called with a closed oximeter.. Restarting import process";
//mainwin->Notify(tr("Oximeter Error\n\nThe device has not responded.. Make sure it's switched on2"));
on_ImportButton_clicked();
return;
}
}
if (oximeter->callbacks() == 0) {
mainwin->Notify(tr("Oximeter Error\n\nThe device has not responded.. Make sure it's switched on."));
if (oximeter->mode() == SO_IMPORT) { oximeter->stopImport(); }
if (oximeter->mode() == SO_LIVE) { oximeter->stopLive(); }
oximeter->destroySession();
day->getSessions().clear();
ui->SerialPortsCombo->setEnabled(true);
qstatus->setText(STR_TR_Ready);
ui->ImportButton->setEnabled(true);
ui->RunButton->setChecked(false);
ui->saveButton->setEnabled(false);
GraphView->setEmptyText(tr("Check Oximeter is Ready"));
GraphView->redraw();
}
}
// Move this code to CMS50 Importer??
void Oximetry::on_ImportButton_clicked()
{
connect(oximeter, SIGNAL(importComplete(Session *)), this, SLOT(import_complete(Session *)));
connect(oximeter, SIGNAL(importAborted()), this, SLOT(import_aborted()));
connect(oximeter, SIGNAL(updateProgress(float)), this, SLOT(update_progress(float)));
PLETHY->setVisible(false);
day->getSessions().clear();
GraphView->setDay(day);
//GraphView->setEmptyText(tr("Make Sure Oximeter is Ready"));
//GraphView->redraw();
if (!oximeter->startImport()) {
mainwin->Notify(tr("Oximeter Error\n\nThe device did not respond.. Make sure it's switched on."));
import_finished();
// disconnect(oximeter,SIGNAL(importComplete(Session*)),this,SLOT(import_complete(Session*)));
// disconnect(oximeter,SIGNAL(importAborted()),this,SLOT(import_aborted()));
// disconnect(oximeter,SIGNAL(updateProgress(float)),this,SLOT(update_progress(float)));
//qDebug() << "Error starting oximetry serial import process";
return;
}
//QTimer::singleShot(1000,this,SLOT(oximeter_running_check()));
if (qprogress) {
qprogress->setValue(0);
qprogress->setMaximum(100);
qprogress->show();
}
ui->ImportButton->setDisabled(true);
ui->SerialPortsCombo->setEnabled(false);
ui->RunButton->setText(tr("&Start"));
ui->RunButton->setChecked(false);
}
void Oximetry::import_finished()
{
if (connectDeviceMsgBox) {
connectDeviceMsgBox->close();
disconnect(connectDeviceMsgBox, SIGNAL(buttonClicked(QAbstractButton *)), this,
SLOT(cancel_CheckPorts()));
delete connectDeviceMsgBox;
connectDeviceMsgBox = nullptr;
}
disconnect(oximeter, SIGNAL(importComplete(Session *)), this, SLOT(import_complete(Session *)));
disconnect(oximeter, SIGNAL(importAborted()), this, SLOT(import_aborted()));
disconnect(oximeter, SIGNAL(updateProgress(float)), this, SLOT(update_progress(float)));
oximeter->disconnect(oximeter, SIGNAL(importProcess()), 0, 0);
// oximeter->Close();
// Hanging here.. :(
ui->SerialPortsCombo->setEnabled(true);
qstatus->setText(STR_TR_Ready);
ui->ImportButton->setDisabled(false);
ui->saveButton->setEnabled(true);
if (qprogress) {
qprogress->setValue(100);
qprogress->hide();
}
}
void Oximetry::import_aborted()
{
day->getSessions().clear();
//QMessageBox::warning(mainwin,tr("Oximeter Error"),tr("Please make sure your oximeter is switched on, and able to transmit data.\n(You may need to enter the oximeters Settings screen for it to be able to transmit.)"),QMessageBox::Ok);
mainwin->Notify(
tr("Please make sure your oximeter is switched on, and in the right mode to transmit data."),
tr("Oximeter Error!"), 5000);
//qDebug() << "Oximetry import failed";
import_finished();
}
void Oximetry::import_complete(Session *session)
{
qDebug() << "Oximetry import complete";
import_finished();
day->AddSession(oximeter->getSession());
if (!session) {
qDebug() << "Shouldn't happen";
return;
}
//calcSPO2Drop(session);
//calcPulseChange(session);
//PLETHY->setVisible(false);
CONTROL->setVisible(false);
saved_starttime = session->first();
dont_update_date = true;
ui->dateEdit->setDateTime(QDateTime::fromTime_t(saved_starttime / 1000L));
dont_update_date = false;
updateGraphs();
}
void Oximetry::pulse_changed(float p)
{
ui->pulseLCD->display(p);
return;
if (firstPulseUpdate) {
if (secondPulseUpdate) {
secondPulseUpdate = false;
} else {
firstPulseUpdate = false;
GraphView->updateScale();
}
}
}
// Only really need to do this once..
void Oximetry::spo2_changed(float o2)
{
ui->spo2LCD->display(o2);
return;
if (firstSPO2Update) {
if (secondSPO2Update) {
secondSPO2Update = false;
} else {
firstSPO2Update = false;
GraphView->updateScale();
}
}
}
void Oximetry::on_saveButton_clicked()
{
if (QMessageBox::question(this, tr("Keep This Recording?"),
tr("Would you like to save this oximetery session?"),
QMessageBox::Yes | QMessageBox::No) == QMessageBox::Yes) {
Session *session = oximeter->getSession();
// Process???
//session->UpdateSummaries();
PROFILE.RemoveSession(session);
Machine *m = oximeter->getMachine();
if (m->SessionExists(session->session())) {
m->sessionlist.erase(m->sessionlist.find(session->session()));
}
QString path = PROFILE.Get(m->properties[STR_PROP_Path]) + QString().sprintf("%08lx",
session->session());
QString f1 = path + ".000";
QString f2 = path + ".001";
QFile::remove(f1);
QFile::remove(f2);
// Forgetting to reset the session ID sucks, as it will delete sessions you don't want to delete..
session->SetSessionID(qint64(session->first()) / 1000L);
m->AddSession(session, p_profile);
oximeter->getMachine()->Save();
day->getSessions().clear();
mainwin->getDaily()->LoadDate(mainwin->getDaily()->getDate());
mainwin->getOverview()->ReloadGraphs();
GraphView->setEmptyText(tr("No Oximetry Data"));
GraphView->redraw();
}
}
void Oximetry::update_progress(float f)
{
if (qprogress) {
qprogress->setValue(f * 100.0);
QApplication::processEvents();
}
}
bool Oximetry::openSPOFile(QString filename)
{
QFile f(filename);
if (!f.open(QFile::ReadOnly)) { return false; }
QByteArray data;
data = f.readAll();
long size = data.size();
int pos = ((unsigned char)data.at(1) << 8) | (unsigned char)data.at(0);
char dchr[20];
int j = 0;
for (int i = 0; i < 18 * 2; i += 2) {
dchr[j++] = data.at(8 + i);
}
dchr[j] = 0;
QString dstr(dchr);
QDateTime date = QDateTime::fromString(dstr, "MM/dd/yy HH:mm:ss");
if (date.date().year() < 2000) { date = date.addYears(100); }
//ui->dateEdit->setDateTime(date);
day->getSessions().clear();
oximeter->createSession(date);
Session *session = oximeter->getSession();
day->AddSession(session);
session->set_first(0);
firstPulseUpdate = true;
firstSPO2Update = true;
secondPulseUpdate = true;
secondSPO2Update = true;
unsigned char o2, pr;
//quint16 pl;
qint64 tt = qint64(date.toTime_t()) * 1000L;
for (int i = pos; i < size - 5;) {
o2 = (unsigned char)(data.at(i + 4));
pr = (unsigned char)(data.at(i + 3));
//oximeter->setLastTime(tt);
oximeter->addPulse(tt, pr);
oximeter->addSpO2(tt, o2);
//pl=(unsigned char)(data.at(i+1));
//oximeter->addPlethy(tt,pl);
//pl=(unsigned char)(data.at(i+1));
//oximeter->addPlethy(tt,pl);
//pl=(unsigned char)(data.at(i+2));
//oximeter->addPlethy(tt,pl);
i += 5;
//data_changed();
tt += 1000;
}
qint64 t1 = session->first(OXI_Pulse);
qint64 t2 = session->first(OXI_SPO2);
qint64 t3 = qMin(t1, t2);
session->set_first(t3);
//day->setFirst(t3);
int zi = t3 / 1000L;
session->SetSessionID(zi);
date.fromTime_t(zi);
dont_update_date = true;
ui->dateEdit->setDateTime(date);
dont_update_date = false;
t1 = session->last(OXI_Pulse);
t2 = session->last(OXI_SPO2);
t3 = qMax(t1, t2);
session->set_last(t3);
//day->setLast(t3);
CONTROL->setVisible(false);
updateGraphs();
f.close();
ui->saveButton->setEnabled(true);
return true;
}
bool Oximetry::openSPORFile(QString filename)
{
//GraphView->setEmptyText(tr("Please Wait"));
//GraphView->redraw();
QFile f(filename);
if (!f.open(QFile::ReadOnly)) { return false; }
QByteArray data;
data = f.readAll();
long size = data.size();
int pos = ((unsigned char)data.at(1) << 8) | (unsigned char)data.at(0);
char dchr[20];
int j = 0;
for (int i = 0; i < 18 * 2; i += 2) {
dchr[j++] = data.at(8 + i);
}
dchr[j] = 0;
QString dstr(dchr);
QDateTime date = QDateTime::fromString(dstr, "MM/dd/yy HH:mm:ss");
if (date.date().year() < 2000) { date = date.addYears(100); }
day->getSessions().clear();
oximeter->createSession(date);
Session *session = oximeter->getSession();
day->AddSession(session);
session->set_first(0);
firstPulseUpdate = true;
firstSPO2Update = true;
secondPulseUpdate = true;
secondSPO2Update = true;
unsigned char o2, pr;
//quint16 pl;
qint64 tt = qint64(date.toTime_t()) * 1000L;
for (int i = pos; i < size - 2;) {
o2 = (unsigned char)(data.at(i + 1));
pr = (unsigned char)(data.at(i + 0));
oximeter->addPulse(tt, pr);
oximeter->addSpO2(tt, o2);
//pl=(unsigned char)(data.at(i+1));
i += 2;
tt += 1000;
}
qint64 t1 = session->first(OXI_Pulse);
qint64 t2 = session->first(OXI_SPO2);
qint64 t3 = qMin(t1, t2);
session->set_first(t3);
//day->setFirst(t3);
int zi = t3 / 1000L;
session->SetSessionID(zi);
date.fromTime_t(zi);
dont_update_date = true;
ui->dateEdit->setDateTime(date);
dont_update_date = false;
t1 = session->last(OXI_Pulse);
t2 = session->last(OXI_SPO2);
t3 = qMax(t1, t2);
session->set_last(t3);
//day->setLast(t3);
//PLETHY->setVisible(false);
CONTROL->setVisible(false);
updateGraphs();
f.close();
ui->saveButton->setEnabled(true);
return true;
}
void Oximetry::on_openButton_clicked()
{
if (oximeter->getSession() && oximeter->getSession()->IsChanged()) {
int res=askSaveSession();
if (res == 0) {
on_saveButton_clicked();
return;
} else if (res == 2) {
return;
}
} // else it's already saved.
QString dir = "";
QFileDialog fd(this, tr("Select an oximetry file"), dir, tr("Oximetry Files (*.spo *.spoR)"));
fd.setAcceptMode(QFileDialog::AcceptOpen);
fd.setFileMode(QFileDialog::ExistingFile);
if (fd.exec() != QFileDialog::Accepted) { return; }
QStringList filenames = fd.selectedFiles();
if (filenames.size() > 1) {
qDebug() << "Can only open one oximetry file at a time";
}
QString filename = filenames[0];
bool r = false;
if (filename.toLower().endsWith(".spo")) { r = openSPOFile(filename); }
else if (filename.toLower().endsWith(".spor")) { r = openSPORFile(filename); }
if (!r) {
mainwin->Notify(tr("Couldn't open oximetry file \"") + filename + "\".");
}
qDebug() << "opening" << filename;
}
void Oximetry::on_dateEdit_dateTimeChanged(const QDateTime &date)
{
Session *session = oximeter->getSession();
if (!session) {
return;
}
if (dont_update_date) {
return;
}
qint64 first = session->first();
//qint64 last=session->last();
qint64 tt = qint64(date.toTime_t()) * 1000L;
qint64 offset = tt - first;
if (offset != 0) {
session->SetChanged(true);
ui->saveButton->setEnabled(true);
}
session->offsetSession(offset);
updateGraphs();
}
int Oximetry::askSaveSession()
{
return QMessageBox::question(this, STR_MessageBox_Question,
tr("Current oximetry session still has unsaved data in it.")+"\n\n"+
tr("Would you like to save it first?"),
STR_MessageBox_Save, STR_MessageBox_Destroy, STR_MessageBox_Cancel, 0, 2);
}
void Oximetry::openSession(Session *session)
{
if (oximeter->getSession() && oximeter->getSession()->IsChanged()) {
int res=askSaveSession();
if (res == 0) {
on_saveButton_clicked();
return;
} else if (res == 2) {
return;
}
} // else it's already saved.
day->getSessions().clear();
day->AddSession(session);
oximeter->setSession(session);
saved_starttime = session->first();
oximeter->compactAll();
QDateTime date = QDateTime::fromTime_t(saved_starttime / 1000L);
dont_update_date = true;
ui->dateEdit->setDateTime(date);
dont_update_date = false;
updateGraphs();
}
void Oximetry::updateGraphs()
{
Session *session = oximeter->getSession();
if (!session) { return; }
qint64 first = session->first();
qint64 last = session->last();
ui->pulseLCD->display(session->Min(OXI_Pulse));
ui->spo2LCD->display(session->Min(OXI_SPO2));
pulse->setMinY(session->Min(OXI_Pulse));
pulse->setMaxY(session->Max(OXI_Pulse));
spo2->setMinY(session->Min(OXI_SPO2));
spo2->setMaxY(session->Max(OXI_SPO2));
PULSE->setRecMinY(60);
PULSE->setRecMaxY(100);
SPO2->setRecMinY(90);
SPO2->setRecMaxY(100);
//day->setFirst(first);
//day->setLast(last);
pulse->setMinY(session->Min(OXI_Pulse));
pulse->setMaxY(session->Max(OXI_Pulse));
spo2->setMinY(session->Min(OXI_SPO2));
spo2->setMaxY(session->Max(OXI_SPO2));
PULSE->setRecMinY(60);
PULSE->setRecMaxY(100);
SPO2->setRecMinY(90);
SPO2->setRecMaxY(100);
plethy->setMinX(first);
pulse->setMinX(first);
spo2->setMinX(first);
PLETHY->SetMinX(first);
CONTROL->SetMinX(first);
PULSE->SetMinX(first);
SPO2->SetMinX(first);
plethy->setMaxX(last);
pulse->setMaxX(last);
spo2->setMaxX(last);
PLETHY->SetMaxX(last);
CONTROL->SetMaxX(last);
PULSE->SetMaxX(last);
SPO2->SetMaxX(last);
PULSE->setDay(day);
SPO2->setDay(day);
for (int i = 0; i < GraphView->size(); i++) {
(*GraphView)[i]->SetXBounds(first, last);
}
{
int len = (last - first) / 1000L;
int h = len / 3600;
int m = (len / 60) % 60;
int s = (len % 60);
if (qstatus2) { qstatus2->setText(QString().sprintf("%02i:%02i:%02i", h, m, s)); }
}
GraphView->updateScale();
GraphView->redraw();
}
void Oximetry::on_resetTimeButton_clicked() //revert to original session time
{
if (oximeter->getSession()) {
//qint64 tt=ui->dateEdit->dateTime().toTime_t()*1000;
//qint64 offset=saved_starttime-tt;
//oximeter->getSession()->offsetSession(offset);
dont_update_date = false;
//ui->dateEdit->setDateTime(QDateTime::fromTime_t(saved_starttime/1000L));
ui->dateEdit->setDateTime(QDateTime::fromTime_t(saved_starttime / 1000L));
dont_update_date = false;
}
}
Reference in New Issue View Git Blame Copy Permalink