|
|
|
@@ -22,8 +22,7 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
ATBDeviceControllerPlugin::ATBDeviceControllerPlugin(QObject *parent)
|
|
|
|
|
: isMaster(false)
|
|
|
|
|
, pluginState(PLUGIN_STATE::NOT_INITIALIZED)
|
|
|
|
|
: pluginState(PLUGIN_STATE::NOT_INITIALIZED)
|
|
|
|
|
, eventReceiver(nullptr)
|
|
|
|
|
{
|
|
|
|
|
this->setParent(parent);
|
|
|
|
@@ -42,7 +41,6 @@ ATBDeviceControllerPlugin::ATBDeviceControllerPlugin(QObject *parent)
|
|
|
|
|
|
|
|
|
|
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_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_payStopByError()), this, SLOT(onCashPayStopByError()), Qt::QueuedConnection);
|
|
|
|
|
connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_payStopByTimeout()), this, SLOT(onCashPayStopByTimeout()), Qt::QueuedConnection);
|
|
|
|
@@ -75,14 +73,13 @@ PLUGIN_STATE ATBDeviceControllerPlugin::initDCPlugin(QObject *eventReceiver, con
|
|
|
|
|
this->eventReceiver = eventReceiver;
|
|
|
|
|
|
|
|
|
|
// read variables from setting
|
|
|
|
|
this->serialPortName = settings.value("ATBDeviceControllerPlugin/serialPort", "ttymxc2").toString();
|
|
|
|
|
QByteArray printerEncoding = settings.value("ATBDeviceControllerPlugin/printerEncoding", "ISO 8859-2").toString().toLatin1();
|
|
|
|
|
this->serialPortName = settings.value("DEVICE_CONTROLLER/serialPort", "ttymxc2").toString();
|
|
|
|
|
QByteArray printerEncoding = settings.value("DEVICE_CONTROLLER/printerEnconding", "ISO 8859-2").toString().toLatin1();
|
|
|
|
|
|
|
|
|
|
if (this->isMaster) {
|
|
|
|
|
// open serial port
|
|
|
|
|
hw->dc_openSerial(5, "115200", this->serialPortName, 1);
|
|
|
|
|
|
|
|
|
|
hw->dc_autoRequest(true);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
hw->dc_setNewCustomerNumber(PTUSystem::readCustomerNumber());
|
|
|
|
|
hw->dc_setNewMachineNumber(PTUSystem::readMachineNumber());
|
|
|
|
@@ -98,16 +95,6 @@ PLUGIN_STATE ATBDeviceControllerPlugin::initDCPlugin(QObject *eventReceiver, con
|
|
|
|
|
// text encoding for printer
|
|
|
|
|
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->pluginState = PLUGIN_STATE::INITIALIZED;
|
|
|
|
@@ -118,8 +105,6 @@ PLUGIN_STATE ATBDeviceControllerPlugin::initDCPlugin(QObject *eventReceiver, con
|
|
|
|
|
|
|
|
|
|
void ATBDeviceControllerPlugin::startPhysicalLayer()
|
|
|
|
|
{
|
|
|
|
|
if (!this->isMaster) return;
|
|
|
|
|
|
|
|
|
|
if (this->pluginState == PLUGIN_STATE::NOT_INITIALIZED)
|
|
|
|
|
{
|
|
|
|
|
qCritical() << "ATBDeviceControllerPlugin::startPhysicalLayer(): plugin is not initialized";
|
|
|
|
@@ -134,8 +119,6 @@ void ATBDeviceControllerPlugin::startPhysicalLayer()
|
|
|
|
|
|
|
|
|
|
void ATBDeviceControllerPlugin::stopPhysicalLayer()
|
|
|
|
|
{
|
|
|
|
|
if (!this->isMaster) return;
|
|
|
|
|
|
|
|
|
|
if (this->pluginState == PLUGIN_STATE::NOT_INITIALIZED)
|
|
|
|
|
{
|
|
|
|
|
qCritical() << "ATBDeviceControllerPlugin::startPhysicalLayer(): plugin is not initialized";
|
|
|
|
@@ -171,13 +154,11 @@ void ATBDeviceControllerPlugin::reset()
|
|
|
|
|
void ATBDeviceControllerPlugin::onChangedProgramModeToSELL()
|
|
|
|
|
{
|
|
|
|
|
hw->rtc_setDateTime();
|
|
|
|
|
hw->mdb_switchWake(0); // wakeup MDB components
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void ATBDeviceControllerPlugin::onChangedProgramModeToSERVICE()
|
|
|
|
|
{
|
|
|
|
|
//hw->dc_autoRequest(true);
|
|
|
|
|
hw->mdb_switchWake(0); // wakeup MDB components
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void ATBDeviceControllerPlugin::onChangedProgramModeToIDLE()
|
|
|
|
@@ -185,7 +166,6 @@ void ATBDeviceControllerPlugin::onChangedProgramModeToIDLE()
|
|
|
|
|
//hw->dc_autoRequest(false); // <-- TODO: ???
|
|
|
|
|
|
|
|
|
|
this->diag->diagRequest();
|
|
|
|
|
hw->mdb_switchWake(1);
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -227,19 +207,6 @@ void ATBDeviceControllerPlugin::cashAbort()
|
|
|
|
|
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 -------------------------------------------------------------
|
|
|
|
|
|
|
|
|
|
// for an external account request, e.g. by an ui-button:
|
|
|
|
@@ -343,9 +310,9 @@ void ATBDeviceControllerPlugin::private_getAccountData()
|
|
|
|
|
accountData.insert("accountStartTime", startDateTime);
|
|
|
|
|
//-------------------------------------------------------------------------
|
|
|
|
|
|
|
|
|
|
// COINS in Vault: --------------------------------------------------------
|
|
|
|
|
|
|
|
|
|
int numberOfCoinVariants = sizeof(retVR.coinsInVault)/sizeof(retVR.coinsInVault[0]);
|
|
|
|
|
|
|
|
|
|
int numberOfCoinVariants = sizeof(retVR.coinsInVault);
|
|
|
|
|
|
|
|
|
|
// DEBUG
|
|
|
|
|
qCritical() << " NumberOfCoinVariants = " << numberOfCoinVariants;
|
|
|
|
@@ -355,36 +322,14 @@ void ATBDeviceControllerPlugin::private_getAccountData()
|
|
|
|
|
|
|
|
|
|
accountData.insert("NumberOfCoinVariants", numberOfCoinVariants);
|
|
|
|
|
for (int i = 0; i < numberOfCoinVariants; ++i) {
|
|
|
|
|
accountData.insert("COIN_" + QString::number(i+1) + "_Quantity", retVR.coinsInVault[i]);
|
|
|
|
|
accountData.insert("COIN_" + QString::number(i+1) + "_Value", retVR.coinDenomination[i]);
|
|
|
|
|
accountData.insert("COIN_" + QString::number(i) + "_Quantity", retVR.coinsInVault[i]);
|
|
|
|
|
accountData.insert("COIN_" + QString::number(i) + "_Value", retVR.coinDenomination[i]);
|
|
|
|
|
|
|
|
|
|
// DEBUG
|
|
|
|
|
qCritical() << "COIN_" + QString::number(i+1) + "_Quantity = " << accountData["COIN_" + QString::number(i) + "_Quantity"];
|
|
|
|
|
qCritical() << "COIN_" + QString::number(i+1) + "_Value = " << accountData["COIN_" + QString::number(i) + "_Value"];
|
|
|
|
|
qCritical() << "COIN_" + QString::number(i) + "_Quantity = " << accountData["COIN_" + QString::number(i) + "_Quantity"];
|
|
|
|
|
qCritical() << "COIN_" + QString::number(i) + "_Value = " << accountData["COIN_" + QString::number(i) + "_Value"];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// NOTES in stacker: --------------------------------------------------------
|
|
|
|
|
|
|
|
|
|
int numberOfBillVariants = sizeof(retVR.billsInStacker)/sizeof(retVR.billsInStacker[0]);
|
|
|
|
|
|
|
|
|
|
// DEBUG
|
|
|
|
|
qCritical() << " numberOfBillVariants = " << numberOfBillVariants;
|
|
|
|
|
|
|
|
|
|
// limit numberOfBillVariants:
|
|
|
|
|
if (numberOfBillVariants > 16) { numberOfBillVariants = 16; }
|
|
|
|
|
|
|
|
|
|
accountData.insert("NumberOfBillVariants", numberOfBillVariants);
|
|
|
|
|
for (int i = 0; i < numberOfBillVariants; ++i) {
|
|
|
|
|
accountData.insert("NOTE_" + QString::number(i+1) + "_Quantity", retVR.billsInStacker[i]);
|
|
|
|
|
accountData.insert("NOTE_" + QString::number(i+1) + "_Value", retVR.billDenom[i]);
|
|
|
|
|
|
|
|
|
|
// DEBUG
|
|
|
|
|
qCritical() << "NOTE_" + QString::number(i+1) + "_Quantity = " << accountData["NOTE_" + QString::number(i+1) + "_Quantity"];
|
|
|
|
|
qCritical() << "NOTE_" + QString::number(i+1) + "_Value = " << accountData["NOTE_" + QString::number(i+1) + "_Value"];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
emit requestAccountResponse(accountData);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -417,7 +362,7 @@ void ATBDeviceControllerPlugin::onVaultDoorOpened()
|
|
|
|
|
// this is started here because we want to keep ptu awake in order to get
|
|
|
|
|
// coin box removed / inserted etc.
|
|
|
|
|
// BackgroundTask("ACCOUNT") is finished, if account message is sent to ISMAS!
|
|
|
|
|
this->dbus->startBackgroundTask("DOOR_OPEN");
|
|
|
|
|
this->dbus->startBackgroundTask("ACCOUNT");
|
|
|
|
|
|
|
|
|
|
// do not: emit this->requestModeSERVICE();
|
|
|
|
|
}
|
|
|
|
@@ -426,9 +371,6 @@ void ATBDeviceControllerPlugin::onCoinBoxRemoved()
|
|
|
|
|
{
|
|
|
|
|
qCritical() << "ATBDeviceControllerPlugin::onCoinBoxRemoved()";
|
|
|
|
|
|
|
|
|
|
// BackgroundTask("ACCOUNT") is finished, if account message is sent to ISMAS!
|
|
|
|
|
this->dbus->startBackgroundTask("ACCOUNT");
|
|
|
|
|
|
|
|
|
|
QTimer::singleShot(4000, this, SLOT(private_startAccount()));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -437,31 +379,19 @@ void ATBDeviceControllerPlugin::onCoinBoxInserted()
|
|
|
|
|
qCritical() << "ATBDeviceControllerPlugin::onCoinBoxInserted()";
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* This is called, when all CoinBox is inserted and all doors
|
|
|
|
|
* are closed.
|
|
|
|
|
*/
|
|
|
|
|
void ATBDeviceControllerPlugin::onCBinAndAllDoorsClosed()
|
|
|
|
|
{
|
|
|
|
|
qCritical() << "ATBDeviceControllerPlugin::onCBinAndAllDoorsClosed()";
|
|
|
|
|
|
|
|
|
|
QTimer::singleShot(2000, this, SIGNAL(requestModeIDLE()));
|
|
|
|
|
|
|
|
|
|
this->dbus->finishedBackgroundTask("DOOR_OPEN");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* This is called, when all no coinbox is inserted and all doors are
|
|
|
|
|
* closed.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
void ATBDeviceControllerPlugin::onAllDoorsClosed()
|
|
|
|
|
{
|
|
|
|
|
qCritical() << "ATBDeviceControllerPlugin::onAllDoorsClosed()";
|
|
|
|
|
|
|
|
|
|
emit this->requestModeIDLE();
|
|
|
|
|
this->dbus->finishedBackgroundTask("DOOR_OPEN");
|
|
|
|
|
|
|
|
|
|
// TODO: check for errors and create a machine event
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void ATBDeviceControllerPlugin::onNewVoltage(uint32_t voltage)
|
|
|
|
@@ -511,8 +441,7 @@ void ATBDeviceControllerPlugin::requestPrintTicket(nsDeviceControllerInterface::
|
|
|
|
|
memcpy((char*)dynTicketData->licensePlate, ba_licenseplate.data(), std::min(ba_licenseplate.size(),8));
|
|
|
|
|
|
|
|
|
|
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->dynDat6, ba_amount.data(), std::min(ba_amount.size(),8)); // Schoenau
|
|
|
|
|
memcpy((char*)dynTicketData->vendingPrice, ba_amount.data(), std::min(ba_amount.size(),8));
|
|
|
|
|
|
|
|
|
|
QByteArray ba_parkingEndTime = codec->fromUnicode(parkingEndDateTime.toString("hh:mm"));
|
|
|
|
|
memcpy((char*)dynTicketData->parkingEnd, ba_parkingEndTime.data(), std::min(ba_parkingEndTime.size(),8));
|
|
|
|
@@ -612,6 +541,7 @@ void ATBDeviceControllerPlugin::requestPrintReceipt(const QString & printingStri
|
|
|
|
|
{
|
|
|
|
|
QByteArray ba = printingString.toUtf8();
|
|
|
|
|
hw->prn_switchPower(true);
|
|
|
|
|
hw->prn_setFonts(8,12,0,0);
|
|
|
|
|
hw->prn_sendText(&ba);
|
|
|
|
|
QTimer::singleShot(4000, this, SLOT(onPrinterWaitForPrintingReceipt()));
|
|
|
|
|
|
|
|
|
@@ -683,9 +613,7 @@ void ATBDeviceControllerPlugin::requestPrintTicket(const QHash<QString, QVariant
|
|
|
|
|
memcpy((char*)dynTicketData->licensePlate, ba_licenseplate.data(), std::min(ba_licenseplate.size(),8));
|
|
|
|
|
|
|
|
|
|
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->dynDat6, ba_amount.data(), std::min(ba_amount.size(),8)); // Schoenau
|
|
|
|
|
|
|
|
|
|
memcpy((char*)dynTicketData->vendingPrice, ba_amount.data(), std::min(ba_amount.size(),8));
|
|
|
|
|
|
|
|
|
|
QByteArray ba_parkingEndTime = codec->fromUnicode(parkingEndDateTime.toString("hh:mm"));
|
|
|
|
|
memcpy((char*)dynTicketData->parkingEnd, ba_parkingEndTime.data(), std::min(ba_parkingEndTime.size(),8));
|
|
|
|
@@ -897,15 +825,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()
|
|
|
|
|
{
|
|
|
|
@@ -965,7 +884,7 @@ void ATBDeviceControllerPlugin::onCashPayStopByTimeout()
|
|
|
|
|
void ATBDeviceControllerPlugin::onCashPayStopedSuccess()
|
|
|
|
|
{
|
|
|
|
|
// DEBUG
|
|
|
|
|
qCritical() << "ATBDeviceControllerPlugin::onCashPayStopedSuccess()";
|
|
|
|
|
qCritical() << "ATBDeviceControllerPlugin::onCashPayStoped()";
|
|
|
|
|
|
|
|
|
|
uint32_t amountInt = this->hw->getInsertedAmount();
|
|
|
|
|
|
|
|
|
@@ -994,8 +913,7 @@ bool ATBDeviceControllerPlugin::private_loadCashAgentLib(QString pluginName)
|
|
|
|
|
|
|
|
|
|
// search list for plugin (.so) file:
|
|
|
|
|
QStringList pluginNameList;
|
|
|
|
|
pluginNameList << "/usr/lib/libCAslave.so"
|
|
|
|
|
<< "/usr/lib/libCAmaster.so"
|
|
|
|
|
pluginNameList << "/usr/lib/libCAmaster.so"
|
|
|
|
|
<< "/usr/lib/libCashAgentLib.so";
|
|
|
|
|
// using C++11 range based loop:
|
|
|
|
|
for (const auto& filename : pluginNameList) {
|
|
|
|
@@ -1021,14 +939,6 @@ bool ATBDeviceControllerPlugin::private_loadCashAgentLib(QString pluginName)
|
|
|
|
|
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();
|
|
|
|
|
pluginLoader->setFileName(pluginName);
|
|
|
|
|
|
|
|
|
|