Compare commits
	
		
			1 Commits
		
	
	
		
			2.2.8
			...
			00281/Szeg
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 
						
						
							
						
						5590cabfc1
	
				 | 
					
					
						
							
								
								
									
										22
									
								
								DCPlugin.pro
									
									
									
									
									
								
							
							
						
						
									
										22
									
								
								DCPlugin.pro
									
									
									
									
									
								
							@@ -30,14 +30,7 @@ contains( CONFIG, PTU5 ) {
 | 
			
		||||
    QMAKE_CXXFLAGS += -std=c++11
 | 
			
		||||
    linux-clang {  QMAKE_CXXFLAGS += -Qunused-arguments   }
 | 
			
		||||
    CONFIG += link_pkgconfig
 | 
			
		||||
    PTU5BASEPATH = /opt/devel/ptu5
 | 
			
		||||
    ARCH = PTU5
 | 
			
		||||
 | 
			
		||||
    INCLUDEPATH += $$PTU5BASEPATH/qt/libs/deviceController/include/
 | 
			
		||||
    LIBS += -L$$PTU5BASEPATH/qt/libs/deviceController/library
 | 
			
		||||
 | 
			
		||||
    LIBS += -lCAslave
 | 
			
		||||
    LIBS += -lCAmaster
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
contains( CONFIG, PTU5_YOCTO ) {
 | 
			
		||||
@@ -45,8 +38,8 @@ contains( CONFIG, PTU5_YOCTO ) {
 | 
			
		||||
    PTU5BASEPATH = /opt/devel/ptu5
 | 
			
		||||
    ARCH = PTU5
 | 
			
		||||
 | 
			
		||||
    LIBS += -lCAslave
 | 
			
		||||
    LIBS += -lCAmaster
 | 
			
		||||
    # add qmqtt lib
 | 
			
		||||
    #LIBS += -lQt5Qmqtt
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
TARGET   = ATBDeviceControllerPlugin
 | 
			
		||||
@@ -76,6 +69,7 @@ DEFINES += QT_DEPRECATED_WARNINGS
 | 
			
		||||
 | 
			
		||||
# ATBAPP interface
 | 
			
		||||
HEADERS += \
 | 
			
		||||
    include/interfaces.h \
 | 
			
		||||
    src/ATBAPP/ATBAPPplugin.h \
 | 
			
		||||
    src/ATBAPP/DeviceControllerDiag.h \
 | 
			
		||||
    src/ATBAPP/DeviceControllerInterface.h \
 | 
			
		||||
@@ -83,12 +77,9 @@ HEADERS += \
 | 
			
		||||
    src/ATBAPP/ATBMachineEvent.h \
 | 
			
		||||
    src/ATBAPP/ATBDeviceControllerPlugin.h \
 | 
			
		||||
    src/ATBAPP/Utils.h \
 | 
			
		||||
    src/ATBAPP/support/CashUtils.h \
 | 
			
		||||
    src/ATBAPP/support/DBusControllerInterface.h \
 | 
			
		||||
    src/ATBAPP/support/JSON.h \
 | 
			
		||||
    src/ATBAPP/support/PTUSystem.h \
 | 
			
		||||
    src/ATBAPP/support/PersistentData.h \
 | 
			
		||||
    src/ATBAPP/support/Ticket.h
 | 
			
		||||
    src/ATBAPP/support/PTUSystem.h
 | 
			
		||||
 | 
			
		||||
SOURCES += \
 | 
			
		||||
    src/ATBAPP/ATBHealthEvent.cpp \
 | 
			
		||||
@@ -96,12 +87,9 @@ SOURCES += \
 | 
			
		||||
    src/ATBAPP/ATBDeviceControllerPlugin.cpp \
 | 
			
		||||
    src/ATBAPP/DeviceControllerDiag.cpp \
 | 
			
		||||
    src/ATBAPP/Utils.cpp \
 | 
			
		||||
    src/ATBAPP/support/CashUtils.cpp \
 | 
			
		||||
    src/ATBAPP/support/DBusControllerInterface.cpp \
 | 
			
		||||
    src/ATBAPP/support/JSON.cpp \
 | 
			
		||||
    src/ATBAPP/support/PTUSystem.cpp \
 | 
			
		||||
    src/ATBAPP/support/PersistentData.cpp \
 | 
			
		||||
    src/ATBAPP/support/Ticket.cpp
 | 
			
		||||
    src/ATBAPP/support/PTUSystem.cpp
 | 
			
		||||
 | 
			
		||||
DISTFILES += \
 | 
			
		||||
    generate-version.sh
 | 
			
		||||
 
 | 
			
		||||
							
								
								
									
										1902
									
								
								include/interfaces.h
									
									
									
									
									
								
							
							
						
						
									
										1902
									
								
								include/interfaces.h
									
									
									
									
									
								
							
										
											
												File diff suppressed because it is too large
												Load Diff
											
										
									
								
							
										
											
												File diff suppressed because it is too large
												Load Diff
											
										
									
								
							@@ -2,18 +2,16 @@
 | 
			
		||||
#define ATBDEVICECONTROLLERPLUGIN_H
 | 
			
		||||
 | 
			
		||||
#include <QObject>
 | 
			
		||||
#include <QLocale>
 | 
			
		||||
 | 
			
		||||
#include "src/ATBAPP/DeviceControllerInterface.h"
 | 
			
		||||
#include "src/ATBAPP/ATBAPPplugin.h"
 | 
			
		||||
#include "src/ATBAPP/DeviceControllerDiag.h"
 | 
			
		||||
#include "src/ATBAPP/support/Ticket.h"
 | 
			
		||||
 | 
			
		||||
#include "version.h"
 | 
			
		||||
 | 
			
		||||
#include "support/PersistentData.h"
 | 
			
		||||
 | 
			
		||||
#include <DeviceController/interfaces.h>
 | 
			
		||||
 | 
			
		||||
#include "interfaces.h"
 | 
			
		||||
 | 
			
		||||
#include <unistd.h>
 | 
			
		||||
 | 
			
		||||
@@ -21,11 +19,11 @@
 | 
			
		||||
class DBusControllerInterface;
 | 
			
		||||
class QTextCodec;
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
using namespace nsDeviceControllerInterface;
 | 
			
		||||
 | 
			
		||||
class QSettings;
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
class ATBDeviceControllerPlugin :
 | 
			
		||||
        public DeviceControllerInterface
 | 
			
		||||
{
 | 
			
		||||
@@ -44,18 +42,12 @@ public:
 | 
			
		||||
    // interface:
 | 
			
		||||
    PLUGIN_STATE initDCPlugin(QObject *eventReceiver, const QSettings & settings);
 | 
			
		||||
 | 
			
		||||
    void sendDeviceParameter(const QJsonObject & jsonObject);
 | 
			
		||||
 | 
			
		||||
    // TASKS: Cash handling -------------------------------------------------------
 | 
			
		||||
    void requestStartCashInput(const QString & amount);
 | 
			
		||||
    void requestStopCashInput();
 | 
			
		||||
    void cashCollect();
 | 
			
		||||
    void cashAbort();
 | 
			
		||||
 | 
			
		||||
    // read coin/cash processing variants -----------------------------------------
 | 
			
		||||
    nsDeviceControllerInterface::COIN_PROCESSOR coinProcessor();
 | 
			
		||||
    nsDeviceControllerInterface::BILL_ACCEPTOR  billAcceptor();
 | 
			
		||||
 | 
			
		||||
    // TASKS: printing ------------------------------------------------------------
 | 
			
		||||
    void requestPrintTicket(const QHash<QString, QVariant> & printingData);
 | 
			
		||||
    void requestPrintTicket(nsDeviceControllerInterface::TICKET_VARIANT ticketVariant, const QHash<QString, QVariant> & printingData);
 | 
			
		||||
@@ -97,12 +89,12 @@ private:
 | 
			
		||||
   QString errorDescription;
 | 
			
		||||
   QString pluginInfo;
 | 
			
		||||
 | 
			
		||||
   QList<int> templateList;
 | 
			
		||||
 | 
			
		||||
   QString serialPortName;
 | 
			
		||||
 | 
			
		||||
   bool useDebug;
 | 
			
		||||
 | 
			
		||||
   bool isMaster;
 | 
			
		||||
 | 
			
		||||
   PLUGIN_STATE pluginState;
 | 
			
		||||
 | 
			
		||||
   QObject* eventReceiver;
 | 
			
		||||
@@ -113,10 +105,6 @@ private:
 | 
			
		||||
 | 
			
		||||
   DeviceControllerDiag* diag;
 | 
			
		||||
 | 
			
		||||
   PersistentData *persistentData;
 | 
			
		||||
 | 
			
		||||
   uint32_t cashStartAmountInt;
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
   QTextCodec *codec;
 | 
			
		||||
 | 
			
		||||
@@ -129,23 +117,9 @@ private:
 | 
			
		||||
   // counts failed hw->log_chkIfVaultRecordAvailable()
 | 
			
		||||
   int accountCheckCounter;
 | 
			
		||||
 | 
			
		||||
   // counts faild hw->prn-getPrintResult()
 | 
			
		||||
   int printResultCheckCounter;
 | 
			
		||||
 | 
			
		||||
   // dbus
 | 
			
		||||
   int init_sc_dbus();
 | 
			
		||||
 | 
			
		||||
   // printer privates ----------------------------------------------------------------------------
 | 
			
		||||
   Ticket * currentTicket;
 | 
			
		||||
   QLocale printerLocale;
 | 
			
		||||
 | 
			
		||||
   void prepareDynTemplateData();
 | 
			
		||||
 | 
			
		||||
   void private_setupDynTemplateData_START_RECEIPT(struct T_dynDat *dynTicketData, Ticket *ticket);
 | 
			
		||||
   void private_setupDynTemplatData_STOP_RECEIPT(struct T_dynDat *dynTicketData,   Ticket *ticket);
 | 
			
		||||
   void private_setupDynTemplatData_FOOD_STAMP(struct T_dynDat *dynTicketData,     Ticket *ticket);
 | 
			
		||||
   // ---------------------------------------------------------------------------------------------
 | 
			
		||||
 | 
			
		||||
private slots:
 | 
			
		||||
   // printer
 | 
			
		||||
 | 
			
		||||
@@ -155,8 +129,6 @@ private slots:
 | 
			
		||||
   void onPrinterWaitForPrintingTicket();
 | 
			
		||||
   void onPrinterWaitForPrintingReceipt();
 | 
			
		||||
 | 
			
		||||
   void onPrinterPrepareDynTemplateData();
 | 
			
		||||
 | 
			
		||||
   void onPrintFinishedOK();
 | 
			
		||||
   void onPrintFinishedERR();
 | 
			
		||||
 | 
			
		||||
@@ -164,11 +136,9 @@ private slots:
 | 
			
		||||
   void onCashGotCoin();
 | 
			
		||||
   void onCashPayStopedSuccess();
 | 
			
		||||
   void onCashPayStopByMax();
 | 
			
		||||
   void onCashPayStopByPushbutton();
 | 
			
		||||
   void onCashPayStopByEscrow();
 | 
			
		||||
   void onCashPayStopByError();
 | 
			
		||||
   void onCashPayStopByTimeout();
 | 
			
		||||
   void onCashChangerState();
 | 
			
		||||
 | 
			
		||||
   // doors and hardware contacts
 | 
			
		||||
   void onServiceDoorOpened();
 | 
			
		||||
 
 | 
			
		||||
@@ -15,7 +15,7 @@ class ATBMachineEvent : public QEvent
 | 
			
		||||
public:
 | 
			
		||||
    explicit ATBMachineEvent(const QString & id,
 | 
			
		||||
                const QString & deviceName,              // PTU/PRINTER/DC/...
 | 
			
		||||
                EVENT_CLASS eventClass,                  // reason of event: Error/Warning/Alarm
 | 
			
		||||
                EVENT_CLASS eventClass,          // reason of event: Error/Warning/Alarm
 | 
			
		||||
                const QString & name,                    // 'Event': "E001", "W003"
 | 
			
		||||
                const int state,
 | 
			
		||||
                const QString & parameter,
 | 
			
		||||
 
 | 
			
		||||
@@ -5,22 +5,14 @@
 | 
			
		||||
#include <QUuid>
 | 
			
		||||
#include <QDebug>
 | 
			
		||||
 | 
			
		||||
#include "support/JSON.h"
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
DeviceControllerDiag::DeviceControllerDiag(PersistentData *pData, QObject *parent)
 | 
			
		||||
DeviceControllerDiag::DeviceControllerDiag(QObject *parent)
 | 
			
		||||
    : QObject(parent)
 | 
			
		||||
    , coinProcessorType(nsDeviceControllerInterface::COIN_PROCESSOR::ESCROW)
 | 
			
		||||
    , billAcceptor(nsDeviceControllerInterface::BILL_ACCEPTOR::NO)
 | 
			
		||||
    , eventReceiver(nullptr)
 | 
			
		||||
    , isRequestRunning(false)
 | 
			
		||||
    , flagInterruptDiag(false)
 | 
			
		||||
    , lastState(DeviceController::State::INITIAL_STATE)
 | 
			
		||||
    , _isErrorState(false)
 | 
			
		||||
    , pData(pData)
 | 
			
		||||
{
 | 
			
		||||
    diagRequestTimeoutTimer = new QTimer(this);
 | 
			
		||||
    diagRequestTimeoutTimer->setInterval(1000*45);
 | 
			
		||||
    diagRequestTimeoutTimer->setInterval(1000*20);  // 20s
 | 
			
		||||
    diagRequestTimeoutTimer->setSingleShot(true);
 | 
			
		||||
    connect(diagRequestTimeoutTimer, &QTimer::timeout, this, &DeviceControllerDiag::onDiagRequestTimeoutTimerTimeout);
 | 
			
		||||
}
 | 
			
		||||
@@ -36,17 +28,6 @@ void DeviceControllerDiag::init(hwinf *hw, QObject* eventReceiver)
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
void DeviceControllerDiag::diagReInit()
 | 
			
		||||
{
 | 
			
		||||
    this->machineEventSet.clear();
 | 
			
		||||
    this->_isErrorState = false;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
void DeviceControllerDiag::setTimeout(int timeout)
 | 
			
		||||
{
 | 
			
		||||
    this->diagRequestTimeoutTimer->setInterval(1000 * timeout);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
void DeviceControllerDiag::diagRequest()
 | 
			
		||||
{
 | 
			
		||||
    qCritical() << "DeviceControllerDiag::diagRequest()";
 | 
			
		||||
@@ -59,16 +40,6 @@ void DeviceControllerDiag::diagRequest()
 | 
			
		||||
    this->diagRequestTimeoutTimer->start();
 | 
			
		||||
 | 
			
		||||
    this->private_startDiag();
 | 
			
		||||
 | 
			
		||||
    // read dc-fw-version:
 | 
			
		||||
    /* note: dc_getSWVersion() returns always 32 characters (QString)...
 | 
			
		||||
     * if no version string could be read it will contain 32 null-characters:
 | 
			
		||||
     * "\u0000\u0000..."
 | 
			
		||||
     */
 | 
			
		||||
    QString dc_fw_version = hw->dc_getSWversion().remove(QChar('\0'));
 | 
			
		||||
    qCritical() << "ATBDeviceControllerPlugin: DC firmware version: " << dc_fw_version;
 | 
			
		||||
    this->pData->setDCFirmwareVersion(dc_fw_version);
 | 
			
		||||
    this->pData->serializeToFile();
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@@ -78,40 +49,12 @@ void DeviceControllerDiag::onDiagRequestTimeoutTimerTimeout()
 | 
			
		||||
    this->flagInterruptDiag = true;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
bool DeviceControllerDiag::isErrorState()
 | 
			
		||||
{
 | 
			
		||||
    return this->_isErrorState;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
bool DeviceControllerDiag::isOperatingState()
 | 
			
		||||
{
 | 
			
		||||
    return !this->_isErrorState;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
QSet<DeviceController::State> DeviceControllerDiag::getCurrentMachineState()
 | 
			
		||||
{
 | 
			
		||||
    return this->machineEventSet;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
void DeviceControllerDiag::private_startDiag()
 | 
			
		||||
{
 | 
			
		||||
    // check for DiagRequestTimeoutTimerTimeout:
 | 
			
		||||
    if (this->flagInterruptDiag) {
 | 
			
		||||
        qCritical() << "DeviceControllerDiag::private_startDiag() interrupted!";
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::E255);
 | 
			
		||||
        this->isRequestRunning  = false;
 | 
			
		||||
        this->flagInterruptDiag = false;
 | 
			
		||||
 | 
			
		||||
        // try it again, until success:
 | 
			
		||||
        QTimer::singleShot(400, this, &DeviceControllerDiag::diagRequest);
 | 
			
		||||
        /**
 | 
			
		||||
         * But please note:
 | 
			
		||||
         * - diag does currently not stop suspend (start a background task)
 | 
			
		||||
         * - diag is called again in ModeOOO wokeup()
 | 
			
		||||
         */
 | 
			
		||||
        return;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
@@ -144,8 +87,6 @@ void DeviceControllerDiag::sys_superviseSystem()
 | 
			
		||||
    if (this->flagInterruptDiag) {
 | 
			
		||||
        qCritical() << "DeviceControllerDiag::sys_superviseSystem() interrupted!";
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::E255);
 | 
			
		||||
        this->flagInterruptDiag = false;
 | 
			
		||||
        this->isRequestRunning  = false;
 | 
			
		||||
        return;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
@@ -154,8 +95,6 @@ void DeviceControllerDiag::sys_superviseSystem()
 | 
			
		||||
        // es gibt keinerlei gültige Daten vom DC
 | 
			
		||||
        qCritical() << "DeviceControllerDiag::sys_superviseSystem() no valid data!";
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::E254);
 | 
			
		||||
        this->diagRequestTimeoutTimer->stop();
 | 
			
		||||
        this->isRequestRunning  = false;
 | 
			
		||||
        return;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
@@ -178,6 +117,18 @@ void DeviceControllerDiag::sys_superviseSystem()
 | 
			
		||||
        return;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    // all doors: 99: undefined  0:closed  1:open
 | 
			
		||||
    if (dynMaCond.lowerDoor || dynMaCond.upperDoor) {
 | 
			
		||||
        // Service or battery door is open, goto INTRUSION MODE
 | 
			
		||||
        qCritical() << "DeviceControllerDiag::sys_superviseSystem() Service or battery door is open, goto INTRUSION MODE";
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::E253);
 | 
			
		||||
    }
 | 
			
		||||
    if (dynMaCond.middleDoor) {
 | 
			
		||||
        // vault door is open, goto INTRUSION MODE
 | 
			
		||||
        qCritical() << "DeviceControllerDiag::sys_superviseSystem() vault door is open, goto INTRUSION MODE";
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::E252);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    qCritical() << "      --> call  sub_componentAssessment()";
 | 
			
		||||
 | 
			
		||||
    sub_componentAssessment();
 | 
			
		||||
@@ -211,21 +162,6 @@ void DeviceControllerDiag::sub_componentAssessment()
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::A000);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    // check for open doors
 | 
			
		||||
    // all doors: 99: undefined  0:closed  1:open
 | 
			
		||||
    if (dynMaCond.lowerDoor || dynMaCond.upperDoor) {
 | 
			
		||||
        // Service or battery door is open
 | 
			
		||||
        flag_sendOperate = false;
 | 
			
		||||
        qCritical() << "DeviceControllerDiag::sys_superviseSystem() Service or battery door is open, goto INTRUSION MODE";
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::E253);
 | 
			
		||||
    }
 | 
			
		||||
    if (dynMaCond.middleDoor) {
 | 
			
		||||
        // vault door is open
 | 
			
		||||
        flag_sendOperate = false;
 | 
			
		||||
        qCritical() << "DeviceControllerDiag::sys_superviseSystem() vault door is open, goto INTRUSION MODE";
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::E252);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    // check for invalid states:
 | 
			
		||||
 | 
			
		||||
    if (modCond.rtc>=200) {
 | 
			
		||||
@@ -269,31 +205,16 @@ void DeviceControllerDiag::sub_componentAssessment()
 | 
			
		||||
        }
 | 
			
		||||
        if (modCond.coinEscrow>=200) {
 | 
			
		||||
            flag_sendOperate = false;
 | 
			
		||||
            // coinEscrow>200 is considered a warning:
 | 
			
		||||
            this->private_sendDiagEvent(DeviceController::State::W010);
 | 
			
		||||
            this->private_sendDiagEvent(DeviceController::State::E010);
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
    // -----------------------------------------------------------------------------------------------
 | 
			
		||||
 | 
			
		||||
    switch (devPara.kindOfCoinChecker) {
 | 
			
		||||
        case 0:
 | 
			
		||||
            this->coinProcessorType = nsDeviceControllerInterface::COIN_PROCESSOR::NONE;
 | 
			
		||||
            break;
 | 
			
		||||
        case 1:
 | 
			
		||||
        case 2:
 | 
			
		||||
            this->coinProcessorType = nsDeviceControllerInterface::COIN_PROCESSOR::ESCROW;
 | 
			
		||||
            break;
 | 
			
		||||
        case 3:
 | 
			
		||||
            this->coinProcessorType = nsDeviceControllerInterface::COIN_PROCESSOR::CHANGER;
 | 
			
		||||
            break;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    if (devPara.kindOfCoinChecker==1 || devPara.kindOfCoinChecker==2)  // 0: without  1=EMP820   2=EMP900    3=currenza c²	(MW)
 | 
			
		||||
    {
 | 
			
		||||
        if (modCond.coinEscrow>=200) {
 | 
			
		||||
            flag_sendOperate = false;
 | 
			
		||||
            // coinEscrow>200 is considered a warning:
 | 
			
		||||
            this->private_sendDiagEvent(DeviceController::State::W010);
 | 
			
		||||
            this->private_sendDiagEvent(DeviceController::State::E010);
 | 
			
		||||
        }
 | 
			
		||||
        if (modCond.coinSafe==201)  { // full
 | 
			
		||||
            flag_sendOperate = false;
 | 
			
		||||
@@ -321,15 +242,6 @@ void DeviceControllerDiag::sub_componentAssessment()
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    switch (devPara.BillAcceptor) {
 | 
			
		||||
        case 0:
 | 
			
		||||
            this->billAcceptor = nsDeviceControllerInterface::BILL_ACCEPTOR::NO;
 | 
			
		||||
            break;
 | 
			
		||||
        default:
 | 
			
		||||
            this->billAcceptor = nsDeviceControllerInterface::BILL_ACCEPTOR::YES;
 | 
			
		||||
            break;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    /*
 | 
			
		||||
    if ( modCond.billReader>=200 && devPara.BillAcceptor>0)
 | 
			
		||||
    {
 | 
			
		||||
@@ -365,7 +277,7 @@ void DeviceControllerDiag::sub_componentAssessment()
 | 
			
		||||
    }
 | 
			
		||||
    if (modCond.temper>=200) {
 | 
			
		||||
        flag_sendOperate = false;
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::W004);
 | 
			
		||||
        this->private_sendDiagEvent(DeviceController::State::E004);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    // check for warnings
 | 
			
		||||
@@ -412,6 +324,7 @@ void DeviceControllerDiag::private_sendDiagEvent(DeviceController::State result)
 | 
			
		||||
{
 | 
			
		||||
    qCritical() << "DeviceControllerDiag::private_sendDiagEvent() result: " << result;
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    if (this->eventReceiver == nullptr) {
 | 
			
		||||
        qCritical() << "DeviceControllerDiag: no eventReceiver";
 | 
			
		||||
        return;
 | 
			
		||||
@@ -434,81 +347,61 @@ void DeviceControllerDiag::private_sendDiagEvent(DeviceController::State result)
 | 
			
		||||
    QString parameter;
 | 
			
		||||
    switch (result) {
 | 
			
		||||
 | 
			
		||||
    case DeviceController::State::INITIAL_STATE:
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::A000:   // alarm / intrusion
 | 
			
		||||
        eventClass = EVENT_CLASS::ALARM;
 | 
			
		||||
        parameter  = "alarm / intrusion";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E002:    // real time clock error
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "real time clock error";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E003:   // voltage error
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "voltage error";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E004:   // temperature error
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "temperature error";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E007:    // coin safe full
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "coin safe full";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E008:    // bill acceptor full
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "bill acceptor full";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E009:    // no cash box
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "no cash box";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E010:    // coin escrow
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "coin escrow";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::W010:    // coin escrow
 | 
			
		||||
        eventClass = EVENT_CLASS::WARNING;
 | 
			
		||||
        parameter  = "coin escrow";
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E011:    // mem error int.ee.
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "mem error int.ee.";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E018:    // no paper
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "no paper";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E020:    // printer error
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "printer error";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E025:    // coin blocker
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "coin blocker";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E026:    // error coin validator
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "error coin validator";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E034:    // mdb error
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "mdb error";
 | 
			
		||||
        this->_isErrorState = true;
 | 
			
		||||
        break;
 | 
			
		||||
 | 
			
		||||
    case DeviceController::State::E071:   // cash box change is ongoing
 | 
			
		||||
@@ -537,21 +430,16 @@ void DeviceControllerDiag::private_sendDiagEvent(DeviceController::State result)
 | 
			
		||||
        parameter  = "no valid data from DeviceController";
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::E255:   // no valid data from DeviceController
 | 
			
		||||
        eventClass = EVENT_CLASS::ERROR;
 | 
			
		||||
        parameter  = "no valid data from DeviceController";
 | 
			
		||||
        eventClass = EVENT_CLASS::STATE;
 | 
			
		||||
        parameter  = "";
 | 
			
		||||
        qCritical() << "                ... ignore " << QMetaEnum::fromType<DeviceController::State>().valueToKey(result);
 | 
			
		||||
        return;
 | 
			
		||||
        break;
 | 
			
		||||
    case DeviceController::State::O000:   // everything is fine
 | 
			
		||||
        this->machineEventSet.clear();
 | 
			
		||||
        this->_isErrorState = false;
 | 
			
		||||
        eventClass = EVENT_CLASS::OPERATE;
 | 
			
		||||
        parameter  = "";
 | 
			
		||||
        if (this->lastState == DeviceController::State::O000) {
 | 
			
		||||
            qCritical() << "   ... everything fine, no state change -> skip sending";
 | 
			
		||||
            return;
 | 
			
		||||
        }
 | 
			
		||||
        else {
 | 
			
		||||
            qCritical() << "   ... everything fine";
 | 
			
		||||
        }
 | 
			
		||||
        qCritical() << "                ... everything fine";
 | 
			
		||||
        break;
 | 
			
		||||
 | 
			
		||||
    case DeviceController::State::W001:   // paper low
 | 
			
		||||
@@ -572,17 +460,6 @@ void DeviceControllerDiag::private_sendDiagEvent(DeviceController::State result)
 | 
			
		||||
        break;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    this->lastState = result;
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * Variant: send 'parameter' as JSON:
 | 
			
		||||
     *
 | 
			
		||||
        JSON::setPrettySerialize(false);
 | 
			
		||||
        JSON::JsonObject json = JSON::objectBuilder()
 | 
			
		||||
                  ->set("description", parameter)
 | 
			
		||||
            ->create();
 | 
			
		||||
        QString parameterJsonString = JSON::serialize(json);
 | 
			
		||||
    */
 | 
			
		||||
 | 
			
		||||
    ATBMachineEvent *machineEvent = new ATBMachineEvent(
 | 
			
		||||
                eventId,
 | 
			
		||||
@@ -594,6 +471,8 @@ void DeviceControllerDiag::private_sendDiagEvent(DeviceController::State result)
 | 
			
		||||
                ""         // second level info
 | 
			
		||||
                );
 | 
			
		||||
 | 
			
		||||
    //emit diagResponse(machineEvent);
 | 
			
		||||
 | 
			
		||||
    QCoreApplication::postEvent(eventReceiver, machineEvent);
 | 
			
		||||
 | 
			
		||||
}
 | 
			
		||||
 
 | 
			
		||||
@@ -5,13 +5,8 @@
 | 
			
		||||
#include <QSet>
 | 
			
		||||
#include <QTimer>
 | 
			
		||||
 | 
			
		||||
#include <DeviceController/interfaces.h>
 | 
			
		||||
 | 
			
		||||
#include "DeviceControllerInterface.h"
 | 
			
		||||
#include "ATBMachineEvent.h"
 | 
			
		||||
 | 
			
		||||
#include "support/PersistentData.h"
 | 
			
		||||
 | 
			
		||||
#include "interfaces.h"
 | 
			
		||||
 | 
			
		||||
namespace DeviceController {
 | 
			
		||||
    Q_NAMESPACE
 | 
			
		||||
@@ -29,7 +24,6 @@ namespace DeviceController {
 | 
			
		||||
        E008,
 | 
			
		||||
        E009,
 | 
			
		||||
        E010,
 | 
			
		||||
        W010,   // Coin Escrow
 | 
			
		||||
        E011,
 | 
			
		||||
 | 
			
		||||
        E018,
 | 
			
		||||
@@ -53,9 +47,7 @@ namespace DeviceController {
 | 
			
		||||
        W001,
 | 
			
		||||
        W002,
 | 
			
		||||
        W003,
 | 
			
		||||
        W004,
 | 
			
		||||
 | 
			
		||||
        INITIAL_STATE
 | 
			
		||||
        W004
 | 
			
		||||
    };
 | 
			
		||||
    Q_ENUM_NS(State)
 | 
			
		||||
}
 | 
			
		||||
@@ -66,34 +58,13 @@ class DeviceControllerDiag : public QObject
 | 
			
		||||
    Q_OBJECT
 | 
			
		||||
 | 
			
		||||
public:
 | 
			
		||||
    DeviceControllerDiag(PersistentData *pData, QObject *parent = nullptr);
 | 
			
		||||
    DeviceControllerDiag(QObject *parent = nullptr);
 | 
			
		||||
 | 
			
		||||
    void init(hwinf* hw, QObject* eventReceiver);
 | 
			
		||||
 | 
			
		||||
    nsDeviceControllerInterface::COIN_PROCESSOR coinProcessorType;
 | 
			
		||||
    nsDeviceControllerInterface::BILL_ACCEPTOR  billAcceptor;
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * return true, if machineEventSet contains an error
 | 
			
		||||
     */
 | 
			
		||||
    bool isErrorState();
 | 
			
		||||
    bool isOperatingState();
 | 
			
		||||
    QSet<DeviceController::State> getCurrentMachineState();
 | 
			
		||||
 | 
			
		||||
    void setTimeout(int timeout);
 | 
			
		||||
 | 
			
		||||
public slots:
 | 
			
		||||
    /**
 | 
			
		||||
     * start diag request
 | 
			
		||||
     */
 | 
			
		||||
    void diagRequest();
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * reset / re-init diag request.
 | 
			
		||||
     * Called e.g. when doors are closed.
 | 
			
		||||
     */
 | 
			
		||||
    void diagReInit();
 | 
			
		||||
 | 
			
		||||
signals:
 | 
			
		||||
    void diagResponse(ATBMachineEvent* machineEvent);
 | 
			
		||||
 | 
			
		||||
@@ -112,11 +83,7 @@ private:
 | 
			
		||||
 | 
			
		||||
    int lastVoltage;
 | 
			
		||||
 | 
			
		||||
    DeviceController::State lastState;
 | 
			
		||||
    QSet<DeviceController::State> machineEventSet;
 | 
			
		||||
    bool _isErrorState;
 | 
			
		||||
 | 
			
		||||
    PersistentData* pData;
 | 
			
		||||
 | 
			
		||||
private slots:
 | 
			
		||||
    void onDiagRequestTimeoutTimerTimeout();
 | 
			
		||||
 
 | 
			
		||||
@@ -5,7 +5,6 @@
 | 
			
		||||
 | 
			
		||||
#include <QSettings>
 | 
			
		||||
#include <QString>
 | 
			
		||||
#include <QJsonObject>
 | 
			
		||||
 | 
			
		||||
#include "ATBAPPplugin.h"
 | 
			
		||||
 | 
			
		||||
@@ -14,11 +13,6 @@ namespace nsDeviceControllerInterface {
 | 
			
		||||
    enum class RESULT_STATE : quint8;
 | 
			
		||||
    enum class CASH_STATE   : quint8;
 | 
			
		||||
    enum class TICKET_VARIANT : quint8;
 | 
			
		||||
    enum class COIN_PROCESSOR : quint8;
 | 
			
		||||
    enum class BILL_ACCEPTOR  : quint8;
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    enum class SERVICE_TEXT  : quint16;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@@ -40,12 +34,6 @@ public:
 | 
			
		||||
    virtual nsDeviceControllerInterface::PLUGIN_STATE initDCPlugin(QObject *eventReceiver,
 | 
			
		||||
                                                                   const QSettings & settings) = 0;
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * e.g. send location
 | 
			
		||||
     */
 | 
			
		||||
    virtual void sendDeviceParameter(const QJsonObject & jsonObject) = 0;
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    // TASKS: Cash handling -------------------------------------------------------
 | 
			
		||||
    /**
 | 
			
		||||
     * enables coin input
 | 
			
		||||
@@ -76,10 +64,6 @@ public:
 | 
			
		||||
    virtual void requestPrintReceipt(const QHash<QString, QVariant> & printingData) = 0;
 | 
			
		||||
    virtual void requestPrintReceipt(const QString & printingString) = 0;
 | 
			
		||||
 | 
			
		||||
    // read coin/cash processing variants
 | 
			
		||||
    virtual nsDeviceControllerInterface::COIN_PROCESSOR coinProcessor() = 0;
 | 
			
		||||
    virtual nsDeviceControllerInterface::BILL_ACCEPTOR  billAcceptor() = 0;
 | 
			
		||||
 | 
			
		||||
    // mandantory ATBAPP plugin methods:
 | 
			
		||||
    virtual nsDeviceControllerInterface::PLUGIN_STATE getState() = 0;
 | 
			
		||||
    virtual const QString & getLastError() = 0;
 | 
			
		||||
@@ -111,9 +95,6 @@ signals:
 | 
			
		||||
                                     const QString & errorCode,
 | 
			
		||||
                                     const QString & errorDescription);
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    void coinAttached();
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * emitted on e.g. a coin input
 | 
			
		||||
     */
 | 
			
		||||
@@ -132,38 +113,16 @@ signals:
 | 
			
		||||
     */
 | 
			
		||||
    void cashInputFinished(nsDeviceControllerInterface::RESULT_STATE resultState,
 | 
			
		||||
                                     const QString & newCashValue,
 | 
			
		||||
                                     const QString & coinValue,
 | 
			
		||||
                                     const QString & noteValue,
 | 
			
		||||
                                     const QString & changeValue,
 | 
			
		||||
                                     /*  additional variables? */
 | 
			
		||||
                                     const QString & errorCode,
 | 
			
		||||
                                     const QString & errorDescription);
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * emitted if cashPayment has been finished, e.g. in result to task cashCollect():
 | 
			
		||||
     *  -> ticket should be printed sucessfully
 | 
			
		||||
     *  -> coins in excrow or changer are given back to user
 | 
			
		||||
     * Provides data for logging, especially changed value
 | 
			
		||||
     */
 | 
			
		||||
    void cashPaymentFinished(nsDeviceControllerInterface::RESULT_STATE resultState,
 | 
			
		||||
                                     const QString & newCashValue,  // total inserted amount amount
 | 
			
		||||
                                     const QString & coinValue,     // inserted amount, paid with coins
 | 
			
		||||
                                     const QString & noteValue,     // inserted amount, paid with notes
 | 
			
		||||
                                     const QString & changeValue,   // amount changed by changer/escrow
 | 
			
		||||
                                     const QString & errorCode,
 | 
			
		||||
                                     const QString & errorDescription);
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * emitted e.g. if service door is opened
 | 
			
		||||
     */
 | 
			
		||||
    void requestModeSERVICE();
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * emitted e.g. if vault door is opened
 | 
			
		||||
     */
 | 
			
		||||
    void requestModeACCOUNT();
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * emitted e.g. if doors are closed
 | 
			
		||||
     */
 | 
			
		||||
@@ -180,10 +139,7 @@ signals:
 | 
			
		||||
    void requestAccountResponse(const QHash<QString, QVariant> & accountData);
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * show text messages in service mode
 | 
			
		||||
     */
 | 
			
		||||
    void showServiceText(nsDeviceControllerInterface::SERVICE_TEXT serviceText, const QString & text);
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
@@ -203,7 +159,7 @@ signals:
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
Q_DECLARE_INTERFACE(DeviceControllerInterface,
 | 
			
		||||
                    "eu.atb.ptu.plugin.DeviceControllerInterface/1.1.4")
 | 
			
		||||
                    "eu.atb.ptu.plugin.DeviceControllerInterface/1.0")
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
namespace nsDeviceControllerInterface {
 | 
			
		||||
@@ -236,27 +192,8 @@ namespace nsDeviceControllerInterface {
 | 
			
		||||
        ERROR_RECEIPT,
 | 
			
		||||
        START_RECEIPT,   // e.g. Szeged Start
 | 
			
		||||
        STOP_RECEIPT,    // e.g. Szeged Stop
 | 
			
		||||
        FOOD_STAMP
 | 
			
		||||
    };
 | 
			
		||||
 | 
			
		||||
    enum class COIN_PROCESSOR : quint8 {
 | 
			
		||||
        CHANGER,
 | 
			
		||||
        ESCROW,
 | 
			
		||||
        NONE
 | 
			
		||||
    };
 | 
			
		||||
 | 
			
		||||
    enum class BILL_ACCEPTOR  : quint8 {
 | 
			
		||||
        YES,
 | 
			
		||||
        NO
 | 
			
		||||
    };
 | 
			
		||||
 | 
			
		||||
    enum class SERVICE_TEXT  : quint16 {
 | 
			
		||||
        SERVICE_DOOR_OPENED,
 | 
			
		||||
        VAULT_DOOR_OPENED,
 | 
			
		||||
        COIN_BOX_REMOVED,
 | 
			
		||||
        COIN_BOX_INSERTED
 | 
			
		||||
        /* t.b.d. */
 | 
			
		||||
    };
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
#endif // DEVICECONTROLLERINTERFACE_H
 | 
			
		||||
 
 | 
			
		||||
@@ -1,74 +0,0 @@
 | 
			
		||||
#include "CashUtils.h"
 | 
			
		||||
 | 
			
		||||
#include <QDebug>
 | 
			
		||||
 | 
			
		||||
#define MAX_COINS 64
 | 
			
		||||
#define MAX_NOTES 16
 | 
			
		||||
 | 
			
		||||
/*****************************************************************************
 | 
			
		||||
* Get current inserted coins
 | 
			
		||||
*
 | 
			
		||||
* getAllInsertedCoins(uint16_t *types, uint16_t *values)
 | 
			
		||||
*       all inserted coins of this past transaction are stored, max 64
 | 
			
		||||
*/
 | 
			
		||||
uint32_t CashUtils::getAmountOfInsertedCoins(hwinf* hw)
 | 
			
		||||
{
 | 
			
		||||
    uint32_t result = 0;
 | 
			
		||||
 | 
			
		||||
    uint16_t types[MAX_COINS];
 | 
			
		||||
    uint16_t values[MAX_COINS];
 | 
			
		||||
    hw->getAllInsertedCoins(types, values);
 | 
			
		||||
 | 
			
		||||
    for (int i = 0; i < MAX_COINS; i++) {
 | 
			
		||||
        result += values[i];
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    return result;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
/*****************************************************************************
 | 
			
		||||
 * Get current inserted notes
 | 
			
		||||
 *
 | 
			
		||||
 * virtual uint8_t bna_getCurrentNotes(uint16_t latestBill, uint16_t *currentNotes) const =0;
 | 
			
		||||
 * returns number of collected bank notes since start-command (current transaction)
 | 
			
		||||
 *    latestBill: last accepted bank note, value in cent
 | 
			
		||||
 *    currentNotes an array with up to 16 (further) notes collected
 | 
			
		||||
 *
 | 
			
		||||
 */
 | 
			
		||||
uint32_t CashUtils::getAmountOfInsertedNotes(hwinf* hw)
 | 
			
		||||
{
 | 
			
		||||
    uint32_t result = 0;
 | 
			
		||||
    uint8_t numberOfInsertedNotes;
 | 
			
		||||
 | 
			
		||||
    uint16_t beforeArray = 0;
 | 
			
		||||
    uint16_t currentNotes[4];
 | 
			
		||||
    uint16_t afterArray = 0;
 | 
			
		||||
    numberOfInsertedNotes = hw->bna_getCurrentNotes(0, currentNotes);
 | 
			
		||||
 | 
			
		||||
    if ( (beforeArray != 0) || (afterArray != 0) ) {
 | 
			
		||||
        qCritical() << "CashUtils::getAmountOfInsertedNotes() ERROR: Array";
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    if (numberOfInsertedNotes == 99) {
 | 
			
		||||
        // Error
 | 
			
		||||
        qCritical() << "CashUtils::getAmountOfInsertedNotes() ERROR: ";
 | 
			
		||||
        for (int i = 0; i < 4; i++) {
 | 
			
		||||
        qCritical() << "   currentNotes[" << i << "] = " << currentNotes[i];
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
    else {
 | 
			
		||||
        // no error
 | 
			
		||||
        result = currentNotes[3];
 | 
			
		||||
        result = ( result << 16 ) | currentNotes[2];
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    // DEBUG
 | 
			
		||||
    qCritical() << "--------------------------------------------------";
 | 
			
		||||
    qCritical() << "CashUtils::getAmountOfInsertedNotes()";
 | 
			
		||||
    qCritical() << "          numberOfInsertedNotes = " << numberOfInsertedNotes;
 | 
			
		||||
    qCritical() << "                         result = " << result;
 | 
			
		||||
    qCritical() << "--------------------------------------------------";
 | 
			
		||||
 | 
			
		||||
    return result;
 | 
			
		||||
}
 | 
			
		||||
@@ -1,14 +0,0 @@
 | 
			
		||||
#ifndef CASHUTILS_H
 | 
			
		||||
#define CASHUTILS_H
 | 
			
		||||
 | 
			
		||||
#include <QObject>
 | 
			
		||||
#include <DeviceController/interfaces.h>
 | 
			
		||||
 | 
			
		||||
namespace CashUtils {
 | 
			
		||||
 | 
			
		||||
uint32_t getAmountOfInsertedCoins(hwinf* hw);
 | 
			
		||||
uint32_t getAmountOfInsertedNotes(hwinf* hw);
 | 
			
		||||
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
#endif // CASHUTILS_H
 | 
			
		||||
@@ -1,145 +0,0 @@
 | 
			
		||||
#include "PersistentData.h"
 | 
			
		||||
 | 
			
		||||
#include <QFile>
 | 
			
		||||
#include <QFileInfo>
 | 
			
		||||
#include <QDir>
 | 
			
		||||
#include <QDateTime>
 | 
			
		||||
#include <QDataStream>
 | 
			
		||||
#include <QDebug>
 | 
			
		||||
 | 
			
		||||
PersistentData::PersistentData(const QString &datafileName, QObject *parent)
 | 
			
		||||
    : QObject(parent)
 | 
			
		||||
    , isChangedFlag(false)
 | 
			
		||||
{
 | 
			
		||||
    // load persistant data, if available
 | 
			
		||||
    this->filename = datafileName;
 | 
			
		||||
 | 
			
		||||
    QFileInfo dataFileInfo(this->filename);
 | 
			
		||||
    QString dataFilePath = dataFileInfo.path();
 | 
			
		||||
 | 
			
		||||
    QDir dir;
 | 
			
		||||
    if ( ! dir.exists(dataFilePath)) {
 | 
			
		||||
        qCritical() << "Persistent data file does not exist!";
 | 
			
		||||
        qCritical() << "          --> create new: " << this->filename;
 | 
			
		||||
        dir.mkpath(dataFilePath);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    this->read();
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
void PersistentData::serializeToFile()
 | 
			
		||||
{
 | 
			
		||||
    if (this->isChangedFlag) {
 | 
			
		||||
        qCritical() << "PersistentData::isChanged -> save";
 | 
			
		||||
        this->save();
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
void PersistentData::save()
 | 
			
		||||
{
 | 
			
		||||
    QFile fileOut(this->filename);
 | 
			
		||||
    if (fileOut.open(QIODevice::WriteOnly))
 | 
			
		||||
    {
 | 
			
		||||
        QDataStream out(&fileOut);
 | 
			
		||||
        out.setVersion(QDataStream::Qt_4_6);
 | 
			
		||||
 | 
			
		||||
        out << this->hash;
 | 
			
		||||
        fileOut.flush();
 | 
			
		||||
        fileOut.close();
 | 
			
		||||
 | 
			
		||||
        this->isChangedFlag = false;
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
void PersistentData::read()
 | 
			
		||||
{
 | 
			
		||||
    QFile fileIn(this->filename);
 | 
			
		||||
    if (fileIn.open(QIODevice::ReadOnly))
 | 
			
		||||
    {
 | 
			
		||||
        QDataStream in(&fileIn);
 | 
			
		||||
        in.setVersion(QDataStream::Qt_4_6);
 | 
			
		||||
 | 
			
		||||
        in >> hash;
 | 
			
		||||
 | 
			
		||||
        fileIn.close();
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
QVariant PersistentData::getParameter(const QString & key) const {
 | 
			
		||||
#if defined (ARCH_DesktopLinux)
 | 
			
		||||
    // note: QVariant.toString() returns empty string for custom types
 | 
			
		||||
    qDebug() << "VendingData::getParameter() key = " << key << " value = " << hash.value(key).toString();
 | 
			
		||||
#endif
 | 
			
		||||
    return hash.value(key);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
QVariant PersistentData::getParameter(const QString & key)
 | 
			
		||||
{
 | 
			
		||||
    #if defined (ARCH_DesktopLinux)
 | 
			
		||||
    // note: QVariant.toString() returns empty string for custom types
 | 
			
		||||
    qDebug() << "VendingData::getParameter() key = " << key << " value = " << hash.value(key).toString();
 | 
			
		||||
    #endif
 | 
			
		||||
 | 
			
		||||
    return hash.value(key);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
void PersistentData::setParameter(const QString & key, QVariant value)
 | 
			
		||||
{
 | 
			
		||||
    this->isChangedFlag = true;
 | 
			
		||||
 | 
			
		||||
    #if defined (ARCH_DesktopLinux)
 | 
			
		||||
    // note: QVariant.toString() returns empty string for custom types
 | 
			
		||||
    qDebug() << "VendingData::setParameter() key = " << key << " value = " << value.toString();
 | 
			
		||||
    #endif
 | 
			
		||||
 | 
			
		||||
    this->hash.insert(key, value);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
void PersistentData::clearParameter(const QString & key)
 | 
			
		||||
{
 | 
			
		||||
    this->isChangedFlag = true;
 | 
			
		||||
    this->hash.remove(key);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
bool PersistentData::hasParameter(const QString & key) const
 | 
			
		||||
{
 | 
			
		||||
    return hash.contains(key);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
uint PersistentData::getUintParameter(const QString & key) const
 | 
			
		||||
{
 | 
			
		||||
    qDebug() << "PersistentData::getUintParameter() key = " << key << " value = " << hash.value(key).toString();
 | 
			
		||||
 | 
			
		||||
    uint returnValue = 0;
 | 
			
		||||
    bool ok;
 | 
			
		||||
 | 
			
		||||
    returnValue = hash.value(key).toString().toUInt(&ok);
 | 
			
		||||
    if (!ok) returnValue = 0;
 | 
			
		||||
 | 
			
		||||
    return returnValue;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
QList<QString> PersistentData::uniqueKeys() const {
 | 
			
		||||
    return hash.uniqueKeys();
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
void PersistentData::setDCFirmwareVersion(const QString & fw_version)
 | 
			
		||||
{
 | 
			
		||||
    // there must be a version string!
 | 
			
		||||
    if (fw_version.size() < 1) return;
 | 
			
		||||
 | 
			
		||||
    if (this->hash["dc_fw_version"].toString() != fw_version) {
 | 
			
		||||
        this->isChangedFlag = true;
 | 
			
		||||
        this->hash.insert("dc_fw_version", fw_version);
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
QString PersistentData::getDCFirmwareVersion()
 | 
			
		||||
{
 | 
			
		||||
    return this->hash["dc_fw_version"].toString();
 | 
			
		||||
}
 | 
			
		||||
@@ -1,49 +0,0 @@
 | 
			
		||||
#ifndef PERSISTENTDATA_H
 | 
			
		||||
#define PERSISTENTDATA_H
 | 
			
		||||
 | 
			
		||||
#include <QObject>
 | 
			
		||||
#include <QHash>
 | 
			
		||||
#include <QVariant>
 | 
			
		||||
#include <QList>
 | 
			
		||||
#include <QString>
 | 
			
		||||
 | 
			
		||||
class PersistentData : public QObject
 | 
			
		||||
{
 | 
			
		||||
    Q_OBJECT
 | 
			
		||||
public:
 | 
			
		||||
    explicit PersistentData(const QString &datafileName, QObject *parent = nullptr);
 | 
			
		||||
 | 
			
		||||
    void setDCFirmwareVersion(const QString & fw_version);
 | 
			
		||||
    QString getDCFirmwareVersion();
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    QVariant getParameter(const QString & key);
 | 
			
		||||
    QVariant getParameter(const QString & key) const;
 | 
			
		||||
    void setParameter(const QString & key, QVariant value);
 | 
			
		||||
    void clearParameter(const QString & key);
 | 
			
		||||
    bool hasParameter(const QString & key) const;
 | 
			
		||||
 | 
			
		||||
    uint getUintParameter(const QString & key) const;
 | 
			
		||||
    QList<QString> uniqueKeys() const;
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
public slots:
 | 
			
		||||
    void serializeToFile();
 | 
			
		||||
 | 
			
		||||
signals:
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
private:
 | 
			
		||||
    QHash<QString, QVariant> hash;
 | 
			
		||||
 | 
			
		||||
    QString dc_fw_version;
 | 
			
		||||
 | 
			
		||||
    QString filename;
 | 
			
		||||
 | 
			
		||||
    void save();
 | 
			
		||||
    void read();
 | 
			
		||||
 | 
			
		||||
    bool isChangedFlag;
 | 
			
		||||
};
 | 
			
		||||
 | 
			
		||||
#endif // PERSISTENTDATA_H
 | 
			
		||||
@@ -1,169 +0,0 @@
 | 
			
		||||
#include "Ticket.h"
 | 
			
		||||
 | 
			
		||||
#include <QDebug>
 | 
			
		||||
 | 
			
		||||
Ticket::Ticket(TICKET_VARIANT ticketVariant, QObject *parent )
 | 
			
		||||
    : QObject(parent)
 | 
			
		||||
    , ticketVariant(ticketVariant)
 | 
			
		||||
    , _hasTemplateDynData(false)
 | 
			
		||||
{
 | 
			
		||||
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
TICKET_VARIANT Ticket::variant()
 | 
			
		||||
{
 | 
			
		||||
    return this->ticketVariant;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
QList<quint8> * Ticket::templateList()
 | 
			
		||||
{
 | 
			
		||||
    return &(this->_templateList);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
bool Ticket::hasTemplateDynData()
 | 
			
		||||
{
 | 
			
		||||
    return this->_hasTemplateDynData;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
quint8 Ticket::getCurrentProcessedTemplateNumber()
 | 
			
		||||
{
 | 
			
		||||
    return this->currentProcessedTemplateNumber;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
void Ticket::setCurrentTemplateProcessed()
 | 
			
		||||
{
 | 
			
		||||
    this->currentProcessedTemplateNumber++;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
bool Ticket::initNew(TICKET_VARIANT ticketVariant, const QList<quint8> & templateList, const QHash<QString, QVariant> & printingData)
 | 
			
		||||
{
 | 
			
		||||
    this->clear();
 | 
			
		||||
 | 
			
		||||
    this->ticketVariant = ticketVariant;
 | 
			
		||||
    this->printingData = printingData;
 | 
			
		||||
    this->_templateList = templateList;
 | 
			
		||||
    this->currentProcessedTemplateNumber = 0;
 | 
			
		||||
 | 
			
		||||
    // DEBUG
 | 
			
		||||
    qCritical() << "Ticket::initNew():";
 | 
			
		||||
    qCritical() << "      -> " << ticketVariant;
 | 
			
		||||
 | 
			
		||||
    int multiplicatorInt = 1;  // default
 | 
			
		||||
 | 
			
		||||
    switch (this->ticketVariant) {
 | 
			
		||||
    case TICKET_VARIANT::PARKING_TICKET:
 | 
			
		||||
        break;
 | 
			
		||||
    case TICKET_VARIANT::RECEIPT:
 | 
			
		||||
        break;
 | 
			
		||||
    case TICKET_VARIANT::ERROR_RECEIPT:
 | 
			
		||||
        break;
 | 
			
		||||
    case TICKET_VARIANT::START_RECEIPT:
 | 
			
		||||
        this->_templateList << 21 << 22 << 23;
 | 
			
		||||
        break;
 | 
			
		||||
    case TICKET_VARIANT::STOP_RECEIPT:
 | 
			
		||||
        this->_templateList << 24 << 25 << 26;
 | 
			
		||||
        break;
 | 
			
		||||
    case TICKET_VARIANT::FOOD_STAMP:
 | 
			
		||||
         if (printingData.contains("dyn1_list")) {
 | 
			
		||||
            this->_hasTemplateDynData = true;
 | 
			
		||||
 | 
			
		||||
            this->dyn1List = printingData["dyn1_list"].toStringList();
 | 
			
		||||
            this->dyn2List = printingData["dyn2_list"].toStringList();
 | 
			
		||||
         }
 | 
			
		||||
 | 
			
		||||
         if (printingData.contains("multiplicator")) {
 | 
			
		||||
             multiplicatorInt = printingData["multiplicator"].toInt();
 | 
			
		||||
             for (int i = 1; i < multiplicatorInt; i++) {
 | 
			
		||||
                 this->_templateList << 1;
 | 
			
		||||
             }
 | 
			
		||||
             // last template:
 | 
			
		||||
             this->_templateList << 2;
 | 
			
		||||
         }
 | 
			
		||||
 | 
			
		||||
         // DEBUG FOOD_STAMP:
 | 
			
		||||
         qCritical() << "     --> printingData[\"multiplicator\"]" << multiplicatorInt;
 | 
			
		||||
 | 
			
		||||
        break;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    // DEBUG
 | 
			
		||||
    QString templateListString;
 | 
			
		||||
    for (int i =0; i < this->_templateList.size(); ++i) {
 | 
			
		||||
        templateListString.append(QString(" %1").arg(this->_templateList.at(i)));
 | 
			
		||||
    }
 | 
			
		||||
    qCritical() << "     -> templates: " << templateListString;
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    return true;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
void Ticket::clear()
 | 
			
		||||
{
 | 
			
		||||
    this->ticketVariant = TICKET_VARIANT::PARKING_TICKET;
 | 
			
		||||
    this->printingData.clear();
 | 
			
		||||
    this->_templateList.clear();
 | 
			
		||||
    this->errorCode.clear();
 | 
			
		||||
    this->errorDescription.clear();
 | 
			
		||||
 | 
			
		||||
    this->_hasTemplateDynData = false;
 | 
			
		||||
    this->dyn1List.clear();
 | 
			
		||||
    this->dyn1List.clear();
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
QString Ticket::getErrorCode()         {  return this->errorCode;        }
 | 
			
		||||
QString Ticket::getErrorDescription()  {  return this->errorDescription; }
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
/**
 | 
			
		||||
 */
 | 
			
		||||
QStringList Ticket::getDyn1List()
 | 
			
		||||
{
 | 
			
		||||
    return this->dyn1List;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
QStringList Ticket::getDyn2List()
 | 
			
		||||
{
 | 
			
		||||
    return this->dyn2List;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
QHash<QString, QVariant> & Ticket::getPrintingData()
 | 
			
		||||
{
 | 
			
		||||
    return this->printingData;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
/************************************************************************************************
 | 
			
		||||
 * operator
 | 
			
		||||
 *
 | 
			
		||||
 */
 | 
			
		||||
QDebug operator<<(QDebug debug, TICKET_VARIANT ticketVariant)
 | 
			
		||||
{
 | 
			
		||||
    switch (ticketVariant) {
 | 
			
		||||
        case TICKET_VARIANT::PARKING_TICKET:
 | 
			
		||||
            debug << "TICKET_VARIANT::PARKING_TICKET";
 | 
			
		||||
            break;
 | 
			
		||||
        case TICKET_VARIANT::RECEIPT:
 | 
			
		||||
            debug << "TICKET_VARIANT::RECEIPT";
 | 
			
		||||
            break;
 | 
			
		||||
        case TICKET_VARIANT::ERROR_RECEIPT:
 | 
			
		||||
            debug << "TICKET_VARIANT::ERROR_RECEIPT";
 | 
			
		||||
            break;
 | 
			
		||||
        case TICKET_VARIANT::START_RECEIPT:
 | 
			
		||||
            debug << "TICKET_VARIANT::START_RECEIPT";
 | 
			
		||||
            break;
 | 
			
		||||
        case TICKET_VARIANT::STOP_RECEIPT:
 | 
			
		||||
            debug << "TICKET_VARIANT::STOP_RECEIPT";
 | 
			
		||||
            break;
 | 
			
		||||
        case TICKET_VARIANT::FOOD_STAMP:
 | 
			
		||||
            debug << "TICKET_VARIANT::FOOD_STAMP";
 | 
			
		||||
            break;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    return debug;
 | 
			
		||||
}
 | 
			
		||||
@@ -1,88 +0,0 @@
 | 
			
		||||
#ifndef TICKET_H
 | 
			
		||||
#define TICKET_H
 | 
			
		||||
 | 
			
		||||
#include <QObject>
 | 
			
		||||
#include <QHash>
 | 
			
		||||
 | 
			
		||||
#include "../DeviceControllerInterface.h"
 | 
			
		||||
 | 
			
		||||
using namespace nsDeviceControllerInterface;
 | 
			
		||||
 | 
			
		||||
QDebug operator<<(QDebug debug, TICKET_VARIANT ticketVariant);
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
class Ticket : public QObject
 | 
			
		||||
{
 | 
			
		||||
    Q_OBJECT
 | 
			
		||||
 | 
			
		||||
public:
 | 
			
		||||
    Ticket(TICKET_VARIANT ticketVariant, QObject *parent = nullptr);
 | 
			
		||||
 | 
			
		||||
    bool initNew(TICKET_VARIANT ticketVariant, const QList<quint8> & templateList, const QHash<QString, QVariant> & printingData);
 | 
			
		||||
    void clear();
 | 
			
		||||
 | 
			
		||||
    TICKET_VARIANT variant();
 | 
			
		||||
 | 
			
		||||
    QList<quint8> * templateList();
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * @brief getPrintingData - generic getter for printingData
 | 
			
		||||
     * Used mainly for simple tickets (single tickets e.g. ParkingTicket)
 | 
			
		||||
     * @return
 | 
			
		||||
     */
 | 
			
		||||
    QHash<QString, QVariant> & getPrintingData();
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * @brief hasTemplateDynData
 | 
			
		||||
     * @return true, if ticket has dynamic data for each template.
 | 
			
		||||
     *
 | 
			
		||||
     * This depends on TICKET_VARIANT and printingData
 | 
			
		||||
     */
 | 
			
		||||
    bool hasTemplateDynData();
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * @brief getDyn1List
 | 
			
		||||
     * contains dynamic template data
 | 
			
		||||
     * The size of the lists must be exactly the same as the number of templates.
 | 
			
		||||
     */
 | 
			
		||||
    QStringList getDyn1List();
 | 
			
		||||
    QStringList getDyn2List();
 | 
			
		||||
 | 
			
		||||
    quint8 getCurrentProcessedTemplateNumber();
 | 
			
		||||
 | 
			
		||||
    /**
 | 
			
		||||
     * Mark current template as processed
 | 
			
		||||
     */
 | 
			
		||||
    void setCurrentTemplateProcessed();
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    // error handling
 | 
			
		||||
    QString getErrorCode();
 | 
			
		||||
    QString getErrorDescription();
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
private:
 | 
			
		||||
    TICKET_VARIANT ticketVariant;
 | 
			
		||||
 | 
			
		||||
    // printingData from application
 | 
			
		||||
    QHash<QString, QVariant> printingData;
 | 
			
		||||
 | 
			
		||||
    // templateList, from .ini or created by ticketVariant...
 | 
			
		||||
    QList<quint8> _templateList;
 | 
			
		||||
 | 
			
		||||
    bool _hasTemplateDynData;
 | 
			
		||||
 | 
			
		||||
    quint8 currentProcessedTemplateNumber;
 | 
			
		||||
 | 
			
		||||
    QStringList dyn1List;
 | 
			
		||||
    QStringList dyn2List;
 | 
			
		||||
 | 
			
		||||
    // error handling
 | 
			
		||||
    QString errorCode;
 | 
			
		||||
    QString errorDescription;
 | 
			
		||||
};
 | 
			
		||||
 | 
			
		||||
#endif // TICKET_H
 | 
			
		||||
		Reference in New Issue
	
	Block a user