Compare commits

..

12 Commits

Author SHA1 Message Date
d5f7a45a57 Extend getString(). 2023-11-16 08:47:52 +01:00
18c98abc5b Implement getPluginInfoList() and extend getString(). 2023-11-16 08:47:03 +01:00
bdf2886aa4 Implement initVMCPlugin(), initPlugin(). 2023-11-16 08:45:47 +01:00
b1304df2bf Add signals and add pluginInfoList. 2023-11-16 08:44:25 +01:00
cf5d950647 Add getState(), getLastError(), getLastErrorDescription(), getString(), onChangedProgramModeToSELL(), onChangedProgramModeToSERVICE(),
nChangedProgramModeToIDLE(), onChangedProgramModeToOOO(), startPhysicalLayer(),
stopPhysicalLayer(), reboot(), reset().
Add signals printTicketFinished,...,Error.
2023-11-16 08:41:14 +01:00
ed99b7f3a3 Minor: remove initPlugin()-implementation. 2023-11-16 08:40:06 +01:00
62c3758bd1 Derive interface from QObject (to enable usage of qobject_cast) and UnifiedDCVMCInterface. 2023-11-16 08:38:46 +01:00
5d2bb75fca Extend enums in nsDeviceControllerInterface. 2023-11-16 08:38:13 +01:00
2313b6bd42 Moved enums to ATBAPPplugin.h.
Removed signals.
2023-11-16 08:36:16 +01:00
bf59e2d4b9 Add enums describing plugin status: PLUGIN_STATE, RESULT_STATE, CASH_STATE,
TICKET_VARIANT, STEP.
2023-11-16 08:34:34 +01:00
7e708d6897 do some experiments 2023-11-10 13:23:05 +01:00
603e6a20b6 do some expermiments 2023-11-10 13:22:35 +01:00
10 changed files with 746 additions and 1559 deletions

View File

@@ -9,7 +9,7 @@ QT += serialport
INCLUDEPATH += $${PWD}/plugins INCLUDEPATH += $${PWD}/plugins
INCLUDEPATH += $${PWD}/include INCLUDEPATH += $${PWD}/include
QMAKE_CXXFLAGS += -Wno-deprecated-copy QMAKE_CXXFLAGS += -Wno-deprecated-copy -O
# default # default
ARCH = PTU5 ARCH = PTU5
@@ -49,6 +49,8 @@ INTERFACE_DEFINITION = $${PWD}/src/ATBAPP/DeviceControllerInterface.h
DEFINES += DEVICECONTROLLERPLUGIN_LIBRARY DEFINES += DEVICECONTROLLERPLUGIN_LIBRARY
DEFINES += USE_DC_VMC_UNIFICATION
# The following define makes your compiler emit warnings if you use # The following define makes your compiler emit warnings if you use
# any Qt feature that has been marked deprecated (the exact warnings # any Qt feature that has been marked deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the # depend on your compiler). Please consult the documentation of the
@@ -77,6 +79,7 @@ HEADERS += \
src/ATBAPP/ATBMachineEvent.h \ src/ATBAPP/ATBMachineEvent.h \
src/ATBAPP/ATBDeviceControllerPlugin.h \ src/ATBAPP/ATBDeviceControllerPlugin.h \
src/ATBAPP/Utils.h \ src/ATBAPP/Utils.h \
src/ATBAPP/UnifiedDCVMCInterface.h \
src/ATBAPP/support/DBusControllerInterface.h \ src/ATBAPP/support/DBusControllerInterface.h \
src/ATBAPP/support/JSON.h \ src/ATBAPP/support/JSON.h \
src/ATBAPP/support/PTUSystem.h src/ATBAPP/support/PTUSystem.h

File diff suppressed because it is too large Load Diff

View File

@@ -5,18 +5,63 @@
* a simple class with only one method for plugin info * a simple class with only one method for plugin info
*/ */
#include <QObject> #include <QObject>
#include <QString> #include <QStringList>
class ATBAPPplugin struct ATBAPPplugin {
{ enum class PLUGIN_STATE : quint8 {
NOT_INITIALIZED = 0,
INITIALIZED = 1
};
enum class RESULT_STATE : quint8 {
SUCCESS = 1, // operation was successfull
ERROR_BACKEND, // error from backend (e.g. backend replies with error)
ERROR_NETWORK,
ERROR_TIMEOUT, // the operation timed out
ERROR_PROCESS, // internal plugin error, should not occur (this is a bug in implementation)
ERROR_BUSY,
ERROR_STATE,
ERROR_RETRY, // retry operation
INFO // informational (e.g. display a message, log something etc.)
};
enum class CASH_STATE : quint8 {
CACHE_EMPTY, // Cache still empty, default state
CACHE_INPUT, // Coins are in Cache
OVERPAYED,
/* t.b.d. */
};
enum class TICKET_VARIANT : quint8 {
PARKING_TICKET,
RECEIPT,
ERROR_RECEIPT,
START_RECEIPT, // e.g. Szeged Start
STOP_RECEIPT, // e.g. Szeged Stop
};
enum class STEP : quint8 {
UP = 1,
DOWN = 2
};
enum class TERMINAL_STATE : quint8 {
NOT_AVAILABLE = 1,
AVAILABLE,
PREPARED_FOR_VENDING,
BUSY,
NEEDS_MAINTENANCE
};
public: virtual const QString &getPluginInfo() = 0;
virtual const QString & getPluginInfo() = 0; virtual QStringList getPluginInfoList() {
return QStringList(QString());
}
}; };
using PLUGIN_STATE = ATBAPPplugin::PLUGIN_STATE;
using RESULT_STATE = ATBAPPplugin::RESULT_STATE;
using CASH_STATE = ATBAPPplugin::CASH_STATE;
using TICKET_VARIANT = ATBAPPplugin::TICKET_VARIANT;
using STEP = ATBAPPplugin::STEP;
using TERMINAL_STATE = ATBAPPplugin::TERMINAL_STATE;
Q_DECLARE_INTERFACE(ATBAPPplugin, Q_DECLARE_INTERFACE(ATBAPPplugin,
"eu.atb.ptu.plugin.ATBAPPplugin/0.9") "eu.atb.ptu.plugin.ATBAPPplugin/0.9")
#endif // ATBAPPPLUGIN_H #endif // ATBAPPPLUGIN_H

View File

@@ -22,8 +22,7 @@
ATBDeviceControllerPlugin::ATBDeviceControllerPlugin(QObject *parent) ATBDeviceControllerPlugin::ATBDeviceControllerPlugin(QObject *parent)
: isMaster(false) : pluginState(PLUGIN_STATE::NOT_INITIALIZED)
, pluginState(PLUGIN_STATE::NOT_INITIALIZED)
, eventReceiver(nullptr) , eventReceiver(nullptr)
{ {
this->setParent(parent); this->setParent(parent);
@@ -40,12 +39,11 @@ ATBDeviceControllerPlugin::ATBDeviceControllerPlugin(QObject *parent)
//connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_templatePrintFinished_OK()), this, SLOT(onPrintFinishedOK()), Qt::QueuedConnection); //connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_templatePrintFinished_OK()), this, SLOT(onPrintFinishedOK()), Qt::QueuedConnection);
//connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_templatePrintFinished_Err()), this, SLOT(onPrintFinishedERR()), Qt::QueuedConnection); //connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_templatePrintFinished_Err()), this, SLOT(onPrintFinishedERR()), Qt::QueuedConnection);
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_gotNewCoin()), this, SLOT(onCashGotCoin()), Qt::QueuedConnection); connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_gotNewCoin()), this, SLOT(onCashGotCoin()), Qt::QueuedConnection);
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByMax()), this, SLOT(onCashPayStopByMax()), Qt::QueuedConnection); connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByMax()), this, SLOT(onCashPayStopByMax()), Qt::QueuedConnection);
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByPushbutton()), this, SLOT(onCashPayStopByPushbutton()), Qt::QueuedConnection); connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByEscrow()), this, SLOT(onCashPayStopByEscrow()), Qt::QueuedConnection);
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByEscrow()), this, SLOT(onCashPayStopByEscrow()), Qt::QueuedConnection); connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByError()), this, SLOT(onCashPayStopByError()), Qt::QueuedConnection);
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByError()), this, SLOT(onCashPayStopByError()), Qt::QueuedConnection); connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByTimeout()), this, SLOT(onCashPayStopByTimeout()), Qt::QueuedConnection);
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByTimeout()), this, SLOT(onCashPayStopByTimeout()), Qt::QueuedConnection);
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_doorServiceDoorOpened()), this, SLOT(onServiceDoorOpened()), Qt::QueuedConnection); // switch to ModeSERVICE connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_doorServiceDoorOpened()), this, SLOT(onServiceDoorOpened()), Qt::QueuedConnection); // switch to ModeSERVICE
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_doorVaultDoorOpened()), this, SLOT(onVaultDoorOpened()), Qt::QueuedConnection); // Screen?? with message connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_doorVaultDoorOpened()), this, SLOT(onVaultDoorOpened()), Qt::QueuedConnection); // Screen?? with message
@@ -70,19 +68,44 @@ ATBDeviceControllerPlugin::ATBDeviceControllerPlugin(QObject *parent)
ATBDeviceControllerPlugin::~ATBDeviceControllerPlugin() {} ATBDeviceControllerPlugin::~ATBDeviceControllerPlugin() {}
PLUGIN_STATE ATBDeviceControllerPlugin::initVMCPlugin(QObject *eventReceiver,
QObject *atbSystem,
QObject *hmiConfig,
const QSettings &settings) {
Q_UNUSED(eventReceiver);
Q_UNUSED(atbSystem);
Q_UNUSED(hmiConfig);
Q_UNUSED(settings);
return PLUGIN_STATE::NOT_INITIALIZED;
}
PLUGIN_STATE ATBDeviceControllerPlugin::initPlugin(QObject *eventReceiver,
QObject *atbSystem,
QObject *hmiConfig,
QSettings const &settings) {
Q_UNUSED(atbSystem);
Q_UNUSED(hmiConfig);
return initDCPlugin(eventReceiver, settings);
}
PLUGIN_STATE ATBDeviceControllerPlugin::initPlugin(QObject *eventReceiver, QSettings const &settings) {
return initDCPlugin(eventReceiver, settings);
}
PLUGIN_STATE ATBDeviceControllerPlugin::initDCPlugin(QObject *eventReceiver, const QSettings & settings) PLUGIN_STATE ATBDeviceControllerPlugin::initDCPlugin(QObject *eventReceiver, const QSettings & settings)
{ {
this->eventReceiver = eventReceiver; this->eventReceiver = eventReceiver;
// read variables from setting // read variables from setting
this->serialPortName = settings.value("ATBDeviceControllerPlugin/serialPort", "ttymxc2").toString(); this->serialPortName = settings.value("DEVICE_CONTROLLER/serialPort", "ttymxc2").toString();
QByteArray printerEncoding = settings.value("ATBDeviceControllerPlugin/printerEncoding", "ISO 8859-2").toString().toLatin1(); QByteArray printerEncoding = settings.value("DEVICE_CONTROLLER/printerEnconding", "ISO 8859-2").toString().toLatin1();
if (this->isMaster) { // open serial port
// open serial port hw->dc_openSerial(5, "115200", this->serialPortName, 1);
hw->dc_openSerial(5, "115200", this->serialPortName, 1);
hw->dc_autoRequest(true); hw->dc_autoRequest(true);
}
hw->dc_setNewCustomerNumber(PTUSystem::readCustomerNumber()); hw->dc_setNewCustomerNumber(PTUSystem::readCustomerNumber());
hw->dc_setNewMachineNumber(PTUSystem::readMachineNumber()); hw->dc_setNewMachineNumber(PTUSystem::readMachineNumber());
@@ -98,16 +121,6 @@ PLUGIN_STATE ATBDeviceControllerPlugin::initDCPlugin(QObject *eventReceiver, con
// text encoding for printer // text encoding for printer
this->codec = QTextCodec::codecForName(printerEncoding); this->codec = QTextCodec::codecForName(printerEncoding);
if (this->codec == nullptr) {
printerEncoding = "ISO 8859-1";
qCritical() << "ATBDeviceControllerPlugin: ERROR: printer encoding \"" << printerEncoding << "\" is not supported!";
qCritical() << " ... use default encoding: " << printerEncoding;
this->codec = QTextCodec::codecForName(printerEncoding);
}
else {
qCritical() << "ATBDeviceControllerPlugin: Set printer encoding to " << printerEncoding;
}
this->diag->init(this->hw, this->eventReceiver); this->diag->init(this->hw, this->eventReceiver);
this->pluginState = PLUGIN_STATE::INITIALIZED; this->pluginState = PLUGIN_STATE::INITIALIZED;
@@ -118,8 +131,6 @@ PLUGIN_STATE ATBDeviceControllerPlugin::initDCPlugin(QObject *eventReceiver, con
void ATBDeviceControllerPlugin::startPhysicalLayer() void ATBDeviceControllerPlugin::startPhysicalLayer()
{ {
if (!this->isMaster) return;
if (this->pluginState == PLUGIN_STATE::NOT_INITIALIZED) if (this->pluginState == PLUGIN_STATE::NOT_INITIALIZED)
{ {
qCritical() << "ATBDeviceControllerPlugin::startPhysicalLayer(): plugin is not initialized"; qCritical() << "ATBDeviceControllerPlugin::startPhysicalLayer(): plugin is not initialized";
@@ -134,8 +145,6 @@ void ATBDeviceControllerPlugin::startPhysicalLayer()
void ATBDeviceControllerPlugin::stopPhysicalLayer() void ATBDeviceControllerPlugin::stopPhysicalLayer()
{ {
if (!this->isMaster) return;
if (this->pluginState == PLUGIN_STATE::NOT_INITIALIZED) if (this->pluginState == PLUGIN_STATE::NOT_INITIALIZED)
{ {
qCritical() << "ATBDeviceControllerPlugin::startPhysicalLayer(): plugin is not initialized"; qCritical() << "ATBDeviceControllerPlugin::startPhysicalLayer(): plugin is not initialized";
@@ -224,19 +233,6 @@ void ATBDeviceControllerPlugin::cashAbort()
this->currentCashState = CASH_STATE::CACHE_EMPTY; this->currentCashState = CASH_STATE::CACHE_EMPTY;
} }
// Coin/Cash processing variants ----------------------------------------------
nsDeviceControllerInterface::COIN_PROCESSOR ATBDeviceControllerPlugin::coinProcessor()
{
return this->diag->coinProcessorType;
}
nsDeviceControllerInterface::BILL_ACCEPTOR ATBDeviceControllerPlugin::billAcceptor()
{
return this->diag->billAcceptor;
}
// TASKS: Account ------------------------------------------------------------- // TASKS: Account -------------------------------------------------------------
// for an external account request, e.g. by an ui-button: // for an external account request, e.g. by an ui-button:
@@ -486,8 +482,7 @@ void ATBDeviceControllerPlugin::requestPrintTicket(nsDeviceControllerInterface::
memcpy((char*)dynTicketData->licensePlate, ba_licenseplate.data(), std::min(ba_licenseplate.size(),8)); memcpy((char*)dynTicketData->licensePlate, ba_licenseplate.data(), std::min(ba_licenseplate.size(),8));
QByteArray ba_amount = codec->fromUnicode(printingData["amount"].toString()); QByteArray ba_amount = codec->fromUnicode(printingData["amount"].toString());
memcpy((char*)dynTicketData->vendingPrice, ba_amount.data(), std::min(ba_amount.size(),8)); // Szeged memcpy((char*)dynTicketData->vendingPrice, ba_amount.data(), std::min(ba_amount.size(),8));
memcpy((char*)dynTicketData->dynDat6, ba_amount.data(), std::min(ba_amount.size(),8)); // Schoenau
QByteArray ba_parkingEndTime = codec->fromUnicode(parkingEndDateTime.toString("hh:mm")); QByteArray ba_parkingEndTime = codec->fromUnicode(parkingEndDateTime.toString("hh:mm"));
memcpy((char*)dynTicketData->parkingEnd, ba_parkingEndTime.data(), std::min(ba_parkingEndTime.size(),8)); memcpy((char*)dynTicketData->parkingEnd, ba_parkingEndTime.data(), std::min(ba_parkingEndTime.size(),8));
@@ -658,9 +653,7 @@ void ATBDeviceControllerPlugin::requestPrintTicket(const QHash<QString, QVariant
memcpy((char*)dynTicketData->licensePlate, ba_licenseplate.data(), std::min(ba_licenseplate.size(),8)); memcpy((char*)dynTicketData->licensePlate, ba_licenseplate.data(), std::min(ba_licenseplate.size(),8));
QByteArray ba_amount = codec->fromUnicode(printingData["amount"].toString()); QByteArray ba_amount = codec->fromUnicode(printingData["amount"].toString());
memcpy((char*)dynTicketData->vendingPrice, ba_amount.data(), std::min(ba_amount.size(),8)); // Szeged memcpy((char*)dynTicketData->vendingPrice, ba_amount.data(), std::min(ba_amount.size(),8));
memcpy((char*)dynTicketData->dynDat6, ba_amount.data(), std::min(ba_amount.size(),8)); // Schoenau
QByteArray ba_parkingEndTime = codec->fromUnicode(parkingEndDateTime.toString("hh:mm")); QByteArray ba_parkingEndTime = codec->fromUnicode(parkingEndDateTime.toString("hh:mm"));
memcpy((char*)dynTicketData->parkingEnd, ba_parkingEndTime.data(), std::min(ba_parkingEndTime.size(),8)); memcpy((char*)dynTicketData->parkingEnd, ba_parkingEndTime.data(), std::min(ba_parkingEndTime.size(),8));
@@ -872,15 +865,6 @@ void ATBDeviceControllerPlugin::onCashGotCoin()
""); "");
} }
void ATBDeviceControllerPlugin::onCashPayStopByPushbutton()
{
// DEBUG
qCritical() << "ATBDeviceControllerPlugin::onCashPayStopByPushbutton()";
// we need new cash value in application...
QTimer::singleShot(500, this, SLOT(onCashPayStopedSuccess()));
}
void ATBDeviceControllerPlugin::onCashPayStopByMax() void ATBDeviceControllerPlugin::onCashPayStopByMax()
{ {
@@ -940,7 +924,7 @@ void ATBDeviceControllerPlugin::onCashPayStopByTimeout()
void ATBDeviceControllerPlugin::onCashPayStopedSuccess() void ATBDeviceControllerPlugin::onCashPayStopedSuccess()
{ {
// DEBUG // DEBUG
qCritical() << "ATBDeviceControllerPlugin::onCashPayStopedSuccess()"; qCritical() << "ATBDeviceControllerPlugin::onCashPayStoped()";
uint32_t amountInt = this->hw->getInsertedAmount(); uint32_t amountInt = this->hw->getInsertedAmount();
@@ -969,8 +953,7 @@ bool ATBDeviceControllerPlugin::private_loadCashAgentLib(QString pluginName)
// search list for plugin (.so) file: // search list for plugin (.so) file:
QStringList pluginNameList; QStringList pluginNameList;
pluginNameList << "/usr/lib/libCAslave.so" pluginNameList << "/usr/lib/libCAmaster.so"
<< "/usr/lib/libCAmaster.so"
<< "/usr/lib/libCashAgentLib.so"; << "/usr/lib/libCashAgentLib.so";
// using C++11 range based loop: // using C++11 range based loop:
for (const auto& filename : pluginNameList) { for (const auto& filename : pluginNameList) {
@@ -996,14 +979,6 @@ bool ATBDeviceControllerPlugin::private_loadCashAgentLib(QString pluginName)
return false; return false;
} }
if (pluginName.contains("slave", Qt::CaseInsensitive)) {
this->isMaster = false;
}
else
if (pluginName.contains("master", Qt::CaseInsensitive)) {
this->isMaster = true;
}
QPluginLoader* pluginLoader = new QPluginLoader(); QPluginLoader* pluginLoader = new QPluginLoader();
pluginLoader->setFileName(pluginName); pluginLoader->setFileName(pluginName);
@@ -1096,12 +1071,12 @@ PLUGIN_STATE ATBDeviceControllerPlugin::getState()
return this->pluginState; return this->pluginState;
} }
QString & ATBDeviceControllerPlugin::getLastError() QString const &ATBDeviceControllerPlugin::getLastError()
{ {
return this->errorCode; return this->errorCode;
} }
const QString & ATBDeviceControllerPlugin::getLastErrorDescription() QString const &ATBDeviceControllerPlugin::getLastErrorDescription()
{ {
return this->errorDescription; return this->errorDescription;
} }
@@ -1111,10 +1086,15 @@ const QString & ATBDeviceControllerPlugin::getPluginInfo()
return this->pluginInfo; return this->pluginInfo;
} }
QStringList ATBDeviceControllerPlugin::getPluginInfoList() {
pluginInfoList.clear();
return pluginInfoList;
}
const QString ATBDeviceControllerPlugin::getString(nsDeviceControllerInterface::RESULT_STATE resultState)
QString const &ATBDeviceControllerPlugin::getString(nsDeviceControllerInterface::RESULT_STATE resultState)
{ {
QString str; static QString str;
switch (resultState) { switch (resultState) {
case nsDeviceControllerInterface::RESULT_STATE::SUCCESS: case nsDeviceControllerInterface::RESULT_STATE::SUCCESS:
@@ -1135,6 +1115,15 @@ const QString ATBDeviceControllerPlugin::getString(nsDeviceControllerInterface::
case nsDeviceControllerInterface::RESULT_STATE::INFO: case nsDeviceControllerInterface::RESULT_STATE::INFO:
str = QString("RESULT_STATE::INFO"); str = QString("RESULT_STATE::INFO");
break; break;
case nsDeviceControllerInterface::RESULT_STATE::ERROR_NETWORK:
str = QString("RESULT_STATE::ERROR_NETWORK");
break;
case nsDeviceControllerInterface::RESULT_STATE::ERROR_BUSY:
str = QString("RESULT_STATE::ERROR_BUSY");
break;
case nsDeviceControllerInterface::RESULT_STATE::ERROR_STATE:
str = QString("RESULT_STATE::ERROR_STATE");
break;
} }
return str; return str;

View File

@@ -13,19 +13,16 @@
#include "interfaces.h" #include "interfaces.h"
#include <unistd.h>
class DBusControllerInterface; class DBusControllerInterface;
class QTextCodec; class QTextCodec;
using namespace nsDeviceControllerInterface; // using namespace nsDeviceControllerInterface;
class QSettings; class QSettings;
class ATBDeviceControllerPlugin : class ATBDeviceControllerPlugin : public DeviceControllerInterface
public DeviceControllerInterface
{ {
Q_OBJECT Q_OBJECT
Q_INTERFACES(ATBAPPplugin) Q_INTERFACES(ATBAPPplugin)
@@ -36,11 +33,14 @@ class ATBDeviceControllerPlugin :
public: public:
explicit ATBDeviceControllerPlugin(QObject *parent = nullptr); explicit ATBDeviceControllerPlugin(QObject *parent = nullptr);
~ATBDeviceControllerPlugin(); virtual ~ATBDeviceControllerPlugin();
// ---------------------------------------------------------------------------- // ----------------------------------------------------------------------------
// interface: // interface:
PLUGIN_STATE initDCPlugin(QObject *eventReceiver, const QSettings & settings); virtual PLUGIN_STATE initPlugin(QObject *eventReceiver, QObject *atbSystem, QObject *hmiConfig, QSettings const &settings) override;
virtual PLUGIN_STATE initPlugin(QObject *eventReceiver, QSettings const &settings) override;
virtual PLUGIN_STATE initVMCPlugin(QObject *eventReceiver, QObject *atbSystem, QObject *hmiConfig, const QSettings & settings) override;
virtual PLUGIN_STATE initDCPlugin(QObject *eventReceiver, const QSettings & settings) override;
// TASKS: Cash handling ------------------------------------------------------- // TASKS: Cash handling -------------------------------------------------------
void requestStartCashInput(const QString & amount); void requestStartCashInput(const QString & amount);
@@ -48,10 +48,6 @@ public:
void cashCollect(); void cashCollect();
void cashAbort(); void cashAbort();
// read coin/cash processing variants -----------------------------------------
nsDeviceControllerInterface::COIN_PROCESSOR coinProcessor();
nsDeviceControllerInterface::BILL_ACCEPTOR billAcceptor();
// TASKS: printing ------------------------------------------------------------ // TASKS: printing ------------------------------------------------------------
void requestPrintTicket(const QHash<QString, QVariant> & printingData); void requestPrintTicket(const QHash<QString, QVariant> & printingData);
void requestPrintTicket(nsDeviceControllerInterface::TICKET_VARIANT ticketVariant, const QHash<QString, QVariant> & printingData); void requestPrintTicket(nsDeviceControllerInterface::TICKET_VARIANT ticketVariant, const QHash<QString, QVariant> & printingData);
@@ -62,36 +58,99 @@ public:
void requestAccount(); void requestAccount();
// mandantory ATBAPP plugin methods: ------------------------------------------ // mandantory ATBAPP plugin methods: ------------------------------------------
nsDeviceControllerInterface::PLUGIN_STATE getState(); nsDeviceControllerInterface::PLUGIN_STATE getState() override;
QString & getLastError(); QString const &getLastError() override;
const QString & getLastErrorDescription(); QString const &getLastErrorDescription() override;
const QString & getPluginInfo(); virtual QStringList getPluginInfoList() override;
virtual const QString &getPluginInfo() override;
// helpers e.g. for debug / log // helpers e.g. for debug / log
const QString getString(nsDeviceControllerInterface::RESULT_STATE resultState);; virtual QString const &getString(RESULT_STATE resultState) override;
public slots: public slots:
void onChangedProgramModeToSELL(); virtual void onChangedProgramModeToSELL() override;
void onChangedProgramModeToSERVICE(); virtual void onChangedProgramModeToSERVICE() override;
void onChangedProgramModeToIDLE(); virtual void onChangedProgramModeToIDLE() override;
void onChangedProgramModeToOOO(); virtual void onChangedProgramModeToOOO() override;
void startPhysicalLayer(); virtual void startPhysicalLayer() override;
void stopPhysicalLayer(); virtual void stopPhysicalLayer() override;
void reboot(); virtual void reboot() override;
void reset(); virtual void reset() override;
signals: signals:
// public Signals are defined in interface void printTicketFinished(RESULT_STATE resultState,
const QString & errorCode,
const QString & errorDescription);
void printReceiptFinished(RESULT_STATE resultState,
const QString & errorCode,
const QString & errorDescription);
/**
* emitted on e.g. a coin input
*/
void cashInputEvent(RESULT_STATE resultState,
CASH_STATE cashState,
const QString & newCashValue,
/* additional variables? */
const QString & errorCode,
const QString & errorDescription);
/**
* emitted if cashInput has been stopped, e.g. in result to task requestStopCashInput():
* -> shutter is blocked
* -> no cash input is possible
* -> coins are in cache
*/
void cashInputFinished(RESULT_STATE resultState,
const QString & newCashValue,
/* additional variables? */
const QString & errorCode,
const QString & errorDescription);
/**
* emitted e.g. if service door is opened
*/
void requestModeSERVICE();
/**
* emitted e.g. if doors are closed
*/
void requestModeIDLE();
/**
* emitted e.g. on severe errors
*/
void requestModeOOO();
/**
* emitted e.g. if service door is opened
*/
void requestAccountResponse(const QHash<QString, QVariant> & accountData);
/**
* emitted on error
* depending on errorCode:
* -> interrupt selling process
* -> machine can go to state OOO
* -> send error event to ISMAS
* -> ...
*/
void Error(
/* additional variables? */
const QString & errorCode,
const QString & errorDescription);
private: private:
QString errorCode; QString errorCode;
QString errorDescription; QString errorDescription;
QString pluginInfo; QString pluginInfo;
QStringList pluginInfoList;
QList<int> templateList; QList<int> templateList;
@@ -99,8 +158,6 @@ private:
bool useDebug; bool useDebug;
bool isMaster;
PLUGIN_STATE pluginState; PLUGIN_STATE pluginState;
QObject* eventReceiver; QObject* eventReceiver;
@@ -142,7 +199,6 @@ private slots:
void onCashGotCoin(); void onCashGotCoin();
void onCashPayStopedSuccess(); void onCashPayStopedSuccess();
void onCashPayStopByMax(); void onCashPayStopByMax();
void onCashPayStopByPushbutton();
void onCashPayStopByEscrow(); void onCashPayStopByEscrow();
void onCashPayStopByError(); void onCashPayStopByError();
void onCashPayStopByTimeout(); void onCashPayStopByTimeout();

View File

@@ -7,8 +7,6 @@
DeviceControllerDiag::DeviceControllerDiag(QObject *parent) DeviceControllerDiag::DeviceControllerDiag(QObject *parent)
: QObject(parent) : QObject(parent)
, coinProcessorType(nsDeviceControllerInterface::COIN_PROCESSOR::ESCROW)
, billAcceptor(nsDeviceControllerInterface::BILL_ACCEPTOR::NO)
, eventReceiver(nullptr) , eventReceiver(nullptr)
, isRequestRunning(false) , isRequestRunning(false)
, flagInterruptDiag(false) , flagInterruptDiag(false)
@@ -212,16 +210,6 @@ void DeviceControllerDiag::sub_componentAssessment()
} }
// ----------------------------------------------------------------------------------------------- // -----------------------------------------------------------------------------------------------
switch (devPara.kindOfCoinChecker) {
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 (devPara.kindOfCoinChecker==1 || devPara.kindOfCoinChecker==2) // 0: without 1=EMP820 2=EMP900 3=currenza c² (MW)
{ {
if (modCond.coinEscrow>=200) { if (modCond.coinEscrow>=200) {
@@ -254,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) if ( modCond.billReader>=200 && devPara.BillAcceptor>0)
{ {

View File

@@ -7,8 +7,6 @@
#include "ATBMachineEvent.h" #include "ATBMachineEvent.h"
#include "interfaces.h" #include "interfaces.h"
#include "DeviceControllerInterface.h"
namespace DeviceController { namespace DeviceController {
Q_NAMESPACE Q_NAMESPACE
@@ -64,9 +62,6 @@ public:
void init(hwinf* hw, QObject* eventReceiver); void init(hwinf* hw, QObject* eventReceiver);
nsDeviceControllerInterface::COIN_PROCESSOR coinProcessorType;
nsDeviceControllerInterface::BILL_ACCEPTOR billAcceptor;
public slots: public slots:
void diagRequest(); void diagRequest();
@@ -90,8 +85,6 @@ private:
QSet<DeviceController::State> machineEventSet; QSet<DeviceController::State> machineEventSet;
private slots: private slots:
void onDiagRequestTimeoutTimerTimeout(); void onDiagRequestTimeoutTimerTimeout();

View File

@@ -7,24 +7,23 @@
#include <QString> #include <QString>
#include "ATBAPPplugin.h" #include "ATBAPPplugin.h"
#include "UnifiedDCVMCInterface.h"
namespace nsDeviceControllerInterface { namespace nsDeviceControllerInterface {
enum class PLUGIN_STATE : quint8; using PLUGIN_STATE = ATBAPPplugin::PLUGIN_STATE;
enum class RESULT_STATE : quint8; using RESULT_STATE = ATBAPPplugin::RESULT_STATE;
enum class CASH_STATE : quint8; using CASH_STATE = ATBAPPplugin::CASH_STATE;
enum class TICKET_VARIANT : quint8; using TICKET_VARIANT = ATBAPPplugin::TICKET_VARIANT;
enum class COIN_PROCESSOR : quint8;
enum class BILL_ACCEPTOR : quint8;
} }
class DeviceControllerInterface : public QObject, public UnifiedDCVMCInterface
class DeviceControllerInterface : public QObject
, public ATBAPPplugin
{ {
Q_OBJECT Q_OBJECT
Q_INTERFACES(ATBAPPplugin) Q_INTERFACES(ATBAPPplugin)
Q_INTERFACES(UnifiedDCVMCInterface)
public: public:
virtual ~DeviceControllerInterface() {} virtual ~DeviceControllerInterface() {}
/** /**
@@ -33,8 +32,7 @@ public:
* @param settings * @param settings
* @return * @return
*/ */
virtual nsDeviceControllerInterface::PLUGIN_STATE initDCPlugin(QObject *eventReceiver, virtual PLUGIN_STATE initDCPlugin(QObject *eventReceiver, const QSettings & settings) = 0;
const QSettings & settings) = 0;
// TASKS: Cash handling ------------------------------------------------------- // TASKS: Cash handling -------------------------------------------------------
/** /**
@@ -62,13 +60,10 @@ public:
// TASKS: printing ------------------------------------------------------------ // TASKS: printing ------------------------------------------------------------
virtual void requestPrintTicket(const QHash<QString, QVariant> & printingData) = 0; virtual void requestPrintTicket(const QHash<QString, QVariant> & printingData) = 0;
virtual void requestPrintTicket(nsDeviceControllerInterface::TICKET_VARIANT ticketVariant, const QHash<QString, QVariant> & printingData) = 0; virtual void requestPrintTicket(TICKET_VARIANT ticketVariant, const QHash<QString, QVariant> & printingData) = 0;
virtual void requestPrintReceipt(const QHash<QString, QVariant> & printingData) = 0; virtual void requestPrintReceipt(const QHash<QString, QVariant> & printingData) = 0;
virtual void requestPrintReceipt(const QString & printingString) = 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: // mandantory ATBAPP plugin methods:
virtual nsDeviceControllerInterface::PLUGIN_STATE getState() = 0; virtual nsDeviceControllerInterface::PLUGIN_STATE getState() = 0;
@@ -79,7 +74,7 @@ public:
// -> ATBAPPplugin::getPluginInfo() // -> ATBAPPplugin::getPluginInfo()
// helpers e.g. for debug / log // helpers e.g. for debug / log
virtual const QString getString(nsDeviceControllerInterface::RESULT_STATE resultState) = 0; virtual const QString &getString(nsDeviceControllerInterface::RESULT_STATE resultState) = 0;
public slots: public slots:
virtual void onChangedProgramModeToSELL() = 0; virtual void onChangedProgramModeToSELL() = 0;
@@ -92,7 +87,6 @@ public slots:
virtual void reboot() = 0; virtual void reboot() = 0;
virtual void reset() = 0; virtual void reset() = 0;
signals: signals:
void printTicketFinished(nsDeviceControllerInterface::RESULT_STATE resultState, void printTicketFinished(nsDeviceControllerInterface::RESULT_STATE resultState,
const QString & errorCode, const QString & errorCode,
@@ -123,7 +117,6 @@ signals:
const QString & errorCode, const QString & errorCode,
const QString & errorDescription); const QString & errorDescription);
/** /**
* emitted e.g. if service door is opened * emitted e.g. if service door is opened
*/ */
@@ -145,9 +138,6 @@ signals:
void requestAccountResponse(const QHash<QString, QVariant> & accountData); void requestAccountResponse(const QHash<QString, QVariant> & accountData);
/** /**
* emitted on error * emitted on error
* depending on errorCode: * depending on errorCode:
@@ -163,52 +153,7 @@ signals:
}; };
Q_DECLARE_INTERFACE(DeviceControllerInterface, Q_DECLARE_INTERFACE(DeviceControllerInterface,
"eu.atb.ptu.plugin.DeviceControllerInterface/1.0.1") "eu.atb.ptu.plugin.DeviceControllerInterface/1.0")
namespace nsDeviceControllerInterface {
enum class PLUGIN_STATE : quint8 {
NOT_INITIALIZED = 0,
INITIALIZED = 1
};
enum class RESULT_STATE : quint8 {
SUCCESS = 1, // operation was successfull
ERROR_BACKEND, // error from backend (e.g. backend replies with error)
ERROR_TIMEOUT, // the operation timed out
ERROR_PROCESS, // internal plugin error, should not occur (this is a bug in implementation)
ERROR_RETRY, // retry operation
INFO // informational (e.g. display a message, log something etc.)
};
enum class CASH_STATE : quint8 {
CACHE_EMPTY, // Cache still empty, default state
CACHE_INPUT, // Coins are in Cache
OVERPAYED,
/* t.b.d. */
};
enum class TICKET_VARIANT : quint8 {
PARKING_TICKET,
RECEIPT,
ERROR_RECEIPT,
START_RECEIPT, // e.g. Szeged Start
STOP_RECEIPT, // e.g. Szeged Stop
};
enum class COIN_PROCESSOR : quint8 {
CHANGER,
ESCROW
};
enum class BILL_ACCEPTOR : quint8 {
YES,
NO
};
}
#endif // DEVICECONTROLLERINTERFACE_H #endif // DEVICECONTROLLERINTERFACE_H

View File

@@ -0,0 +1,19 @@
#include "DeviceControllerInterface.h"
using UNIFIED_PLUGIN_STATE = UnifiedDCVMCInterface<DeviceControllerInterface>::UNIFIED_PLUGIN_STATE;
template<>
UNIFIED_PLUGIN_STATE UnifiedDCVMCInterface<DeviceControllerInterface>::initPlugin(QObject *eventReceiver, QSettings const &settings) {
switch(static_cast<DeviceControllerInterface*>(this)->initDCPlugin(eventReceiver, settings)) {
case nsDeviceControllerInterface::PLUGIN_STATE::INITIALIZED:
return UNIFIED_PLUGIN_STATE::INITIALIZED;
case nsDeviceControllerInterface::PLUGIN_STATE::NOT_INITIALIZED:
return UNIFIED_PLUGIN_STATE::NOT_INITIALIZED;
}
return UNIFIED_PLUGIN_STATE::NOT_INITIALIZED;
}

View File

@@ -0,0 +1,62 @@
#ifndef UNIFIED_DCVMC_INTERFACE_H_INCLUDED
#define UNIFIED_DCVMC_INTERFACE_H_INCLUDED
#include <QObject>
#include <QSettings>
#include <QtPlugin>
#include <QSettings>
#include <QString>
#include "ATBAPPplugin.h"
class UnifiedDCVMCInterface : public ATBAPPplugin {
Q_INTERFACES(ATBAPPplugin)
public:
explicit UnifiedDCVMCInterface() = default;
virtual ~UnifiedDCVMCInterface() = default;
virtual QStringList getPluginInfoList() = 0;
virtual const QString &getPluginInfo() = 0;
// mandantory ATBAPP plugin methods:
virtual PLUGIN_STATE getState() = 0;
virtual QString const &getLastError() = 0;
virtual QString const &getLastErrorDescription() = 0;
virtual PLUGIN_STATE initPlugin(QObject *eventReceiver,
QObject *atbSystem,
QObject *hmiConfig,
QSettings const &settings) = 0;
virtual PLUGIN_STATE initPlugin(QObject *eventReceiver, QSettings const &settings) = 0;
virtual PLUGIN_STATE initDCPlugin(QObject *eventReceiver,
const QSettings & settings) = 0;
virtual PLUGIN_STATE initVMCPlugin(QObject *eventReceiver,
QObject *atbSystem, QObject *hmiConfig,
const QSettings & settings) = 0;
virtual QString const &getString(RESULT_STATE resultState) = 0;
public slots:
virtual void onChangedProgramModeToSELL() = 0;
virtual void onChangedProgramModeToSERVICE() = 0;
virtual void onChangedProgramModeToIDLE() = 0;
virtual void onChangedProgramModeToOOO() = 0;
virtual void startPhysicalLayer() = 0;
virtual void stopPhysicalLayer() = 0;
virtual void reboot() = 0;
virtual void reset() = 0;
};
Q_DECLARE_INTERFACE(UnifiedDCVMCInterface,
"eu.atb.ptu.plugin.UnifiedDCVMCInterface/1.0")
#endif // UNIFIED_DCVMC_INTERFACE_H_INCLUDED