Add debug output

Cleaned source.

.gitignore

@@ -1 +1,41 @@
-*.user
+# C++ objects and libs
+
+*.slo
+*.lo
+*.o
+*.a
+*.la
+*.lai
+*.so
+*.dll
+*.dylib
+
+# Qt-es
+
+*.pro.user
+*.pro.user.*
+moc_*.cpp
+qrc_*.cpp
+Makefile
+Makefile.*
+*-build-*
+
+#
+*.autosave
+ui_*.h
+version.h
+version.txt
+
+packages/*
+*.pro.orig
+Output/setup.exe
+.directory
+
+*~
+resources/icons/*.png
+resources/icons/*.jpg
+resources/icons/*.gif
+resources/style/*.qss
+text/*.html
+!text/*_template.html
+text/*.xml

DCPlugin.pri

@@ -10,7 +10,8 @@ HEADERS += $${PWD}/include/com.h \
     $${PWD}/include/prot.h \
     $${PWD}/include/sendWRcmd.h \
     $${PWD}/include/storeINdata.h \
-    $${PWD}/include/tslib.h
+    $${PWD}/include/tslib.h \
+    $${PWD}/include/shared_mem_buffer.h
 
 SOURCES += $${PWD}/src/com.cpp \
     $${PWD}/src/controlBus.cpp \
@@ -20,4 +21,5 @@ SOURCES += $${PWD}/src/com.cpp \
     $${PWD}/src/prot.cpp \
     $${PWD}/src/sendWRcmd.cpp \
     $${PWD}/src/storeINdata.cpp \
-    $${PWD}/src/tslib.cpp
+    $${PWD}/src/tslib.cpp \
+    $${PWD}/src/shared_mem_buffer.cpp

DCPlugin.pro

@@ -14,6 +14,8 @@ QMAKE_CXXFLAGS += -Wno-deprecated-copy
 # default
 ARCH = PTU5
 
+include(DCPlugin.pri)
+
 contains( CONFIG, DesktopLinux ) {
     QMAKE_CC = ccache $$QMAKE_CC
     QMAKE_CXX = ccache $$QMAKE_CXX
@@ -21,7 +23,6 @@ contains( CONFIG, DesktopLinux ) {
     # QMAKE_CXXFLAGS += -Wno-deprecated-ctor
     linux-clang {  QMAKE_CXXFLAGS += -Qunused-arguments   }
     ARCH = DesktopLinux
-    include(DCPlugin.pri)
 }
 
 contains( CONFIG, PTU5 ) {
@@ -31,22 +32,23 @@ contains( CONFIG, PTU5 ) {
     linux-clang {  QMAKE_CXXFLAGS += -Qunused-arguments   }
     CONFIG += link_pkgconfig
     ARCH = PTU5
-
-    # NOTE: include contents of DCPlugin.pri. Also used by ATBQT.
-    # Add new files in DCPlugin.pri.
-    include(DCPlugin.pri)
 }
 
 contains( CONFIG, PTU5_YOCTO ) {
+    greaterThan(QT_MAJOR_VERSION, 4): QT += serialport
+    PTU5BASEPATH = /opt/devel/ptu5
     ARCH = PTU5
 
     # add qmqtt lib
     #LIBS += -lQt5Qmqtt
 }
 
-TARGET   = CashAgentLib
-DESTDIR  = ../plugins
+TARGET   = ATBDeviceControllerPlugin
+#DESTDIR  = ../plugins
+INTERFACE = DeviceController
+INTERFACE_DEFINITION = $${PWD}/include/ATBAPP/DeviceControllerInterface.h
 
+DEFINES += DEVICECONTROLLERPLUGIN_LIBRARY
 
 # The following define makes your compiler emit warnings if you use
 # any Qt feature that has been marked deprecated (the exact warnings
@@ -66,3 +68,27 @@ DEFINES += QT_DEPRECATED_WARNINGS
 #else: unix:!android: target.path = /opt/$${TARGET}/bin
 #!isEmpty(target.path): INSTALLS += target
 
+# ATBAPP interface
+HEADERS += \
+    src/ATBAPP/ATBAPPplugin.h \
+    src/ATBAPP/DeviceControllerInterface.h \
+    src/ATBAPP/ATBHealthEvent.h \
+    src/ATBAPP/ATBDeviceControllerPlugin.h
+
+SOURCES += \
+    src/ATBAPP/ATBHealthEvent.cpp \
+    src/ATBAPP/ATBDeviceControllerPlugin.cpp
+
+DISTFILES += \
+    generate-version.sh
+
+
+# Define how to create version.h
+VERSION_H = $$PWD/include/version.h
+version.output = $$PWD/include/version.h
+version.commands = $$PWD/generate-version.sh $${ARCH} $${TARGET} $${INTERFACE} $${INTERFACE_DEFINITION} $${VERSION_H}
+version.depends = FORCE
+version.input = VERSION_H
+version.variable_out = HEADERS
+QMAKE_EXTRA_COMPILERS += version
+QMAKE_CLEAN += $${PWD}/include/version.h

generate-version.sh

@@ -0,0 +1,155 @@
+#!/bin/bash
+
+VERSION_STRING=""
+
+#GIT='/cygdrive/c/Program Files \(x86\)/Git/bin/git'
+GIT=git
+
+
+
+
+parse_git_branch () {
+    $GIT branch --no-color 2> /dev/null | sed -e '/^[^*]/d' -e "s/* \(.*\)/\1/"
+}
+
+
+ARCH=$1
+TARGET=$2
+INTERFACE=$3
+INTERFACE_DEFINITION=$4
+VERSION_H=$5
+
+SCRIPT=$(readlink -f $0)
+SCRIPTPATH=`dirname $SCRIPT`
+OUTPUTDIR=$(pwd)
+echo " current dir is : " $(pwd)
+echo $SCRIPT
+echo $SCRIPTPATH
+
+echo "changing dir to script path: " $SCRIPTPATH
+cd $SCRIPTPATH
+
+# set version string ##################################################################
+if [ -z $VERSION_STRING ] ; then
+  VERSION_STRING=$(date +%Y%m%d_%H%M)
+fi
+GIT_DESCRIBE=$($GIT describe)
+GIT_BRANCH=$(parse_git_branch)
+
+# extract path from branchname:
+IFS='_' read -ra TMP_ARRAY <<< "${GIT_BRANCH}"
+BRANCH_PATH=${TMP_ARRAY[0]}
+
+
+
+# detect if we have a development version:
+if [ ${#TMP_ARRAY[1]} -gt 0 ] ; then
+  DEV_SUFFIX="_dev"
+else
+  DEV_SUFFIX=""
+fi
+
+# detect if git status is dirty
+GIT_DESCRIBE_DIRTY=$($GIT describe --dirty)
+if [ "${GIT_DESCRIBE_DIRTY:(-6)}" == "-dirty" ] ; then
+  DIRTY_SUFFIX="_dirty"
+else
+  DIRTY_SUFFIX=""
+fi
+
+
+if [ -n "$DIRTY_SUFFIX" ] || [ -n "$DEV_SUFFIX" ] ; then
+  DEVDIRTY=true
+else
+  DEVDIRTY=false
+fi
+
+
+# extract interface definition 
+
+#
+#Q_DECLARE_INTERFACE(CCInterface,
+#         "eu.atb.ptu.plugin.CCInterface/2.9.0")
+# -> extract whole string within quotation marks
+INTERFACE_VERSION=$(grep 'eu.atb.ptu.plugin.' ${INTERFACE_DEFINITION})
+# get string within quotes:
+INTERFACE_VERSION=`echo ${INTERFACE_VERSION} | awk -F \" '{print $2}'`
+
+
+#
+# write version.h
+
+
+echo "     TARGET is: $TARGET"
+echo "     ARCH   is: $ARCH"
+echo " "
+echo "     PluginName: $TARGET"
+echo "     Interface:  $INTERFACE"
+echo "     InterfaceVersion: $INTERFACE_VERSION"
+echo " "
+echo "     new version is:  $VERSION_STRING"
+echo "     git describe is: $GIT_DESCRIBE"
+echo "     git branch is:   $GIT_BRANCH"
+echo "     branch-path is:  $BRANCH_PATH"
+echo "  "
+
+echo "     dev suffix:     $DEV_SUFFIX"
+echo "     dirty suffix:   $DIRTY_SUFFIX"
+
+
+PLUGIN_VERSION=${VERSION_STRING}
+#ATB_QT_GIT_DESCRIBE=${GIT_DESCRIBE}_${GIT_BRANCH}
+PLUGIN_GIT_DESCRIBE=${GIT_DESCRIBE}_${BRANCH_PATH}${DEV_SUFFIX}${DIRTY_SUFFIX}
+
+#TARGET=IngenicoZVT_CCPlugin
+
+
+# build version.h #####################################################################
+
+echo "     building new version info (version.h) ..."
+
+
+
+
+echo "#ifndef VERSION_H"   >  ${VERSION_H}
+echo "#define VERSION_H"   >> ${VERSION_H}
+echo ""                    >> ${VERSION_H}
+echo ""                    >> ${VERSION_H}
+echo "#define INTERFACE_VERSION \"${INTERFACE_VERSION}\""      >> ${VERSION_H}
+echo "#define PLUGIN_VERSION \"${PLUGIN_VERSION}\""           >> ${VERSION_H}
+echo ""                                                       >> ${VERSION_H}
+echo "#define PLUGIN_GIT_DESCRIBE \"${PLUGIN_GIT_DESCRIBE}\"" >> ${VERSION_H}
+echo ""                                                       >> ${VERSION_H}
+echo ""                                                       >> ${VERSION_H}
+
+cat <<EOT >> ${VERSION_H}
+
+const std::string pluginInfoString = R"(
+{
+    "Interface": "${INTERFACE}",
+    "InterfaceVersion": "${INTERFACE_VERSION}",
+    "PluginName": "${TARGET}",
+    "Version": "${PLUGIN_VERSION}",
+    "git-describe": "${PLUGIN_GIT_DESCRIBE}",
+}
+)";
+
+EOT
+
+echo ""                                              >> ${VERSION_H}
+echo ""                                              >> ${VERSION_H}
+if [ ${DEVDIRTY} == "true" ] ; then
+echo "#define DEVDIRTY"                              >> ${VERSION_H}
+echo ""                                              >> ${VERSION_H}
+echo ""                                              >> ${VERSION_H}
+fi
+echo "#define SYSTEM_ARCH \"${ARCH}\""               >> ${VERSION_H}
+echo "#define ARCH_${ARCH}"                          >> ${VERSION_H}
+echo ""                                              >> ${VERSION_H}
+echo "" 					     >> ${VERSION_H}
+echo "#endif //VERSION_H"  >> ${VERSION_H}
+
+
+
+
+

include/controlBus.h

@@ -170,7 +170,7 @@ uint8_t epi_getResultOfLastRequest();
     // retval: 0: in progress  1: OK  2: error
 
 
-void gpi_storeRecPayLoad(uint8_t RdDlen, uint8_t *receivedData);
+void gpi_storeRecPayLoad(uint8_t RdDlen, uint8_t const *receivedData);
     // stored by Datif
 
 uint16_t epi_getLastPayLoad(uint16_t plBufSiz, uint8_t *payLoad);

include/datIf.h

@@ -308,6 +308,8 @@ class T_datif : public QMainWindow
     QTimer *datif_trigger;
     uint8_t selectedSlaveAddr;
 
+    int datif_noResponseCtr;
+
 private slots:
     char datif_cycleSend();
     void StoredRecData();
@@ -324,12 +326,18 @@ public:
         // Sende Schreibbefehle die bereits vorher asynchron gespeichert wurden
     void send_requests(uint16_t nextWrCmd);
     void sendHighLevel(uint16_t nxtHLCmd);
+    bool areDataValid(void);
 
 signals:
     void ResponseRecieved();
         //the requested data are stored in peripheral image
         // can be loaded with epi
 
+    void datif_templatePrintFinished_OK();
+    void datif_templatePrintFinished_Err();
+
+    void datif_gotNewCoin();
+
 };
 
 #endif // CI_H

include/hwChk.h

@@ -0,0 +1,35 @@
+
+#ifndef hwchk_H
+#define hwchk_H
+
+#include <stdint.h>
+#include <QTabWidget>
+#include <QObject>
+#include "interfaces.h"
+//#include "datIf.h"
+#include <QDebug>
+#include <QSharedMemory>
+#include "hwapi.h"
+
+//class QSharedMemory;
+class hwChk :   public QObject,
+                public hwinf
+{
+    Q_OBJECT
+//    Q_PLUGIN_METADATA(IID "Atb.Psa2020.software.HWapi/1.0" )   //FILE "HWapi.json")
+//    Q_INTERFACES(hwinf)
+//private:
+//    QSharedMemory *m_sharedMem;
+
+public:
+    explicit hwChk(QWidget *parent = nullptr);
+    virtual ~hwChk();
+
+
+public:
+    hwinf *HWaccess;
+
+
+};
+
+#endif

include/sendWRcmd.h

@@ -211,6 +211,39 @@ uint8_t gpi_getUserOfSendingTextBuffer(uint8_t *para1, uint8_t *para2, uint8_t *
     // user=1: Text-Print is using this buffer
     //      2: QR-code-Printer is using this buffer
 
+#define     FDCMD_STACKDEPTH    16
+void sendFDcmd_clrStack(void);
+bool sendFDcmd_set(uint8_t nextWrCmd, uint8_t nextRdCmd, uint8_t blockNum, uint8_t dat1, uint8_t dat2, uint8_t dat3, uint8_t dat4);
+    // write Command to memory, wait for transport
+bool sendFDcmd_get(uint8_t *nextWrCmd, uint8_t *nextRdCmd, uint8_t *blockNum, uint8_t *dat1, uint8_t *dat2, uint8_t *dat3, uint8_t *dat4);
+
+uint8_t check4FDshortCmd(void);
+    // returns number of waiting command, maxFDCMD_STACKDEPTH
+
+uint8_t check4freeFDshortCmd(void);
+    // returns number of free places in short-command stack
+
+#define     FDLONG_STACKDEPTH    16
+void longFDcmd_clrStack(void);
+bool longFDcmd_set(uint8_t nextWrCmd, uint8_t nextRdCmd, uint8_t blockNum, uint8_t length, uint8_t *data);
+    // write Command to memory, wait for transport
+    // data buffer size always 64! data[64], padded with 0
+bool longFDcmd_get(uint8_t *nextWrCmd, uint8_t *nextRdCmd, uint8_t *blockNum, uint8_t *length, uint8_t *data);
+
+uint8_t check4FDlongCmd(void);
+    // returns number of waiting command
+
+uint8_t check4freeFDlongCmd(void);
+    // returns number of free places in long-command stack
+
+
+
+uint8_t epi_store64BdevParameter(uint8_t length, uint8_t *buf);
+    // HWapi writes data to be stored
+
+uint8_t epi_restore64BdevParameter(uint8_t *length, uint8_t *buf);
+
+
 
 #endif
 

include/shared_mem_buffer.h

@@ -0,0 +1,296 @@
+#ifndef SHARED_MEM_BUFFER_INCLUDED_H
+#define SHARED_MEM_BUFFER_INCLUDED_H
+
+#include <cinttypes>
+#include <atomic>
+
+#include <QSharedMemory>
+
+struct SharedMemBuffer {
+    struct rs {
+        char comportName[16]; // z.B. "COM48"
+        char baudStr[16];     // z.B. "19200"
+        int  baudNr;          // 0...5 oder -1
+        uint8_t connect;      // 0,1
+        bool portIsOpen;
+    } rs;
+
+    char AutoEmissionOn;     // 1: zyklisch Anfragen zum Slave senden
+
+    struct datif {
+        uint16_t sendingPeriod;
+        bool     sendingPer_changed;
+    } datif;
+
+#if 0
+    // controlBus.cpp
+    char        txt4comStateLine[32];
+    char        txt4HsStateLine[32];
+    char        txt4masterStateLine[32];
+    char        txt4resultStateLine[32];
+    char        txt4dataLine[32];
+    char        txt4datifReceive[32];
+    char        txt4diagWindow[32];
+    char        sndTxt4diagWindow[32];
+    bool        Sdata_serialTestResult[32];
+    uint8_t     Sdata_pProtResultOk[32];
+    uint16_t    Sdata_receivedDataLength[32];
+    uint8_t     Sdata_receivedDataBlock[64];
+
+    // datif.cpp
+    uint8_t     dif_dataStep;
+    uint8_t     dif_scanStep;
+    uint8_t     RDBLKNR;
+    uint8_t     datif_OutCmdpara1;
+    uint8_t     datif_OutCmdpara2;
+    uint8_t     datif_OutCmdpara3;
+    uint8_t     datif_OutCmdpara4;
+
+    uint16_t    datif_OutCmdpara5;
+    uint32_t    datif_OutCmdpara6;
+    uint8_t     cycl_running;
+
+    // dcBL.cpp
+    uint8_t     dcBL_LastBLcmd;   // stored the last sent cmd in order to analys response
+    uint8_t     dcBL_AtbBinFile[300000];
+    uint32_t    dcBL_fileSize;
+    uint16_t    dcBL_nrOfBlocks;
+    uint16_t    dcBL_fileCrc;
+    uint8_t     dcBL_myBuf[300000]; // same content like "dcBL_AtbBinFile" but bytewise
+
+    char        BlResp[50][32];
+    uint8_t     dcBL_step;
+    uint8_t     dcBL_state;
+    uint16_t    dcBL_BlkCtr;
+    uint16_t    dcBL_cyclCtr;
+    uint16_t    repeatCtr;
+    uint8_t     Sdata_rawData[150];
+    uint8_t     Sdata_LengthRawData;
+
+    // hwapi.cpp
+    uint16_t    hwapi_shutterTime;
+    char        ticketTemplate[1024];
+
+    // sendWRcmd.cpp
+    uint16_t    nextAsynchsendCmd0[16];
+    uint8_t     nrOfCmdsInQueue;
+    uint16_t    nextAsynchsendCmd4[8];
+    uint8_t     nextCmd4para1[8];
+    uint8_t     nextCmd4para2[8];
+    uint8_t     nextCmd4para3[8];
+    uint8_t     nextCmd4para4[8];
+    uint8_t     nrOfCmds4InQueue;
+    uint16_t    nextAsynchsendCmd8[4];
+    uint8_t     nextCmd8para1[4];
+    uint8_t     nextCmd8para2[4];
+    uint16_t    nextCmd8para3[4];
+    uint32_t    nextCmd8para4[4];
+    uint8_t     nrOfCmds8InQueue;
+    uint8_t     sendAsynchDataBuf[160]; // no stack, only ONE buffer
+    uint8_t     sendAsyDatLen;
+    uint8_t     Sdata_mdbSendBuffer[64];
+    uint8_t     Sdata_mdbSendLen;
+    uint8_t     prnDataParameters[4];
+    uint8_t     prnDataBufferUser;
+    char        Sdata_PRN_TEXT[20][64];
+    uint8_t     pPrnDataBuff;        // points to next PRINTER_BLOCK
+    uint8_t     nextFDwrCmd[16];
+    uint8_t     nextFDrdCmd[16];
+    uint8_t     nextFDblkNr[16];
+
+    uint8_t     nextFDpara1[16];
+    uint8_t     nextFDpara2[16];
+    uint8_t     nextFDpara3[16];
+    uint8_t     nextFDpara4[16];
+    uint8_t     p_nextFDcmdsInQueue;
+    uint8_t     longFDwrCmd[16];
+    uint8_t     longFDrdCmd[16];
+    uint8_t     longFDblkNr[16];
+    uint8_t     longFDlength[16];
+
+    uint8_t     longFDpara[16][64];
+    uint8_t     p_longFDcmdsInQueue;
+
+    // storeInData.cpp
+    bool        indat_savePrnPwr;
+    bool        indat_saveMifPwr;
+    bool        indat_MdbIsOn;
+#endif
+
+    uint8_t     ndbs;
+    uint8_t     pari;
+    uint8_t     nsb;
+    uint8_t     br;
+
+#define MAXNROF_GENSTR 16
+    char        genStrings[MAXNROF_GENSTR][64];
+
+#define MAXNROF_AI 4
+    uint16_t    AI_val[MAXNROF_AI];
+
+    struct DigitalInputs {
+        uint8_t doorSwitch;
+        uint8_t vaultSwitch;
+        uint8_t lockSwitch;
+        uint8_t opto;
+        uint8_t aux;
+        bool wakeFromPtu;
+        bool wakeFromMdb;
+        bool wakeFromModem;
+        bool PrnReady;
+        bool CoinAttach;
+        bool CoinEscrowOpen;
+        bool mifCardTap;
+        bool contactPwrOn;
+        bool mifarePwrOn;
+        bool rdbk_mdbTxd;
+        bool AuxPwrOn;
+        bool gsmPwrOn;
+        bool creditPwrOn;
+        bool printerPwrOn;
+        bool mdbPwrOn;
+        bool rejMot_home;
+        uint8_t npe_sensor;
+    } din;
+
+    struct DigitalOutputs {
+        uint8_t mbdRxTst;
+        uint8_t motorBits;
+        uint8_t serialSwitch;                 // serial drv on/off, Serial mux1, Serial mux2
+        uint8_t ledsAndFan;
+        uint8_t laermUndRelay;
+        uint8_t ptuWake;
+        uint8_t auxPower;
+        uint8_t coinShutter;
+        uint8_t coinEscrow;
+        uint8_t printerPower;
+    } dout;
+
+    struct Sdata {
+#define NROFMIFSTATEBYTES       40
+#define PRN_STATE_ARRAY_SIZE    20
+#define PRN_STATE_FONT_SIZE     20
+        uint8_t MIF_STATE[NROFMIFSTATEBYTES];
+        uint8_t MIF_DATA[12][64];
+        uint8_t PRN_STATE[PRN_STATE_ARRAY_SIZE];
+        uint8_t PRN_FONTS[PRN_STATE_FONT_SIZE];
+        bool mdb_busRdy;
+        bool mdb_V12on;
+        bool mdb_V5on;
+        uint8_t mdbNrOfRecData;
+        uint8_t RecBuff[40];
+        uint8_t empNrOfsettings;
+        uint8_t emp_settingsBuff[66];
+        uint8_t NrOfDeviceSetting;
+        uint8_t DeviceSettingBuff[66];
+        uint8_t NrOfMachineIDSetting;
+        uint8_t NrOfMachineIDBuff[66];
+        uint64_t slaveUID;
+        uint8_t UIDstr[8];
+#define MAXNROF_MEASURE 4
+        uint32_t measurement[MAXNROF_MEASURE];
+        bool serialTestResult;
+        uint8_t pProtResultOk;
+        uint16_t receivedDataLength;
+        uint8_t receivedDataBlock[64];
+    } Sdata;
+
+    uint8_t mif_cardType;
+    uint8_t mif_cardHolder[8];
+
+#define MEMDEPTH_GOTCOINS (16)
+    struct T_coin {
+        uint8_t valid;
+        uint8_t signal;
+        uint8_t error;
+        uint8_t pad;
+        uint16_t value;
+    } gotCoin[MEMDEPTH_GOTCOINS];
+    uint8_t ctr_gotCoin;
+
+    struct store {
+        uint32_t insertedAmount;
+        uint16_t lastCoinType[64];
+        uint16_t lastCoinValue[64];
+        uint64_t wakeSrc;
+        uint8_t rbDevParamLen;
+        uint8_t rbDevParams[66];
+        uint8_t deviceCondLen;
+        uint8_t deviceCond[66];
+        uint8_t machCondLen;
+        uint8_t machCond[66];
+        uint8_t DcBackupNrOfAccNr;
+        uint16_t DcBackupAccNr[16];    // z.Z. nur 8
+        uint8_t gotNrBlocksOfVaultRec;
+        uint8_t vaultrecord[360];
+        uint32_t amount;
+        uint16_t nrOfCoins;
+        bool    dcDataValid;
+        uint8_t wakeReason;
+        char    curPayNewCoin;
+    } store;
+
+    struct T_globTime {
+        // Reihenfolge nicht vertauschen!!!!!
+        uint8_t     hour;
+        uint8_t     minute;
+        uint8_t     second;
+        uint8_t     Year;
+        uint8_t     Month;
+        uint8_t     DayOfMonth;
+        uint8_t     DayOfWeek;          // 1=monday...7
+        uint8_t     reserve1;
+
+        uint16_t     MinutesOfToday;
+        uint16_t     reserve2;
+
+        uint32_t     SecondsOfToday;
+
+        uint8_t      IsLeapyear;
+        uint8_t      nextLeap;
+        uint8_t      lastLeap;
+        uint8_t      hoursOfWeek;
+
+        uint16_t     minOfWeek;
+        uint16_t     hoursOfMonth;
+        uint16_t     minOfMonth;
+        uint16_t     dayOfYear;
+        uint16_t     hoursOfYear;
+        uint16_t     reserve3;
+
+        uint32_t     minOfYear;
+
+        uint8_t      squareOutMode;
+        uint8_t      free1;
+        uint16_t     reserve4;
+        uint32_t     minOfMillenium;
+        // bis hierher 44byts
+        uint32_t    free2;
+        uint32_t    free3;
+        uint32_t    free4;
+    } getGlobalTime;
+
+    static QSharedMemory *getShm(std::size_t s = 0);
+    static SharedMemBuffer *getData() {
+        return (SharedMemBuffer *)getShm()->data();
+    }
+    static SharedMemBuffer const *getDataConst() {
+        return (SharedMemBuffer const *)getShm()->data();
+    }
+
+#if 0
+    static std::atomic<bool> __sharedMemLocked;
+
+    static bool sharedMemLocked() {
+        return __sharedMemLocked;
+    }
+    static void setSharedMemLocked() {
+        __sharedMemLocked = true;
+    }
+    static void setSharedMemUnlocked() {
+        __sharedMemLocked = false;
+    }
+#endif
+};
+
+#endif // SHARED_MEM_BUFFER_INCLUDED_H

include/storeINdata.h

@@ -3,12 +3,12 @@
 #define STOREINDATA_H
 
 #include <stdint.h>
-#include "tslib.h"
+//#include "tslib.h"
 #include <QString>
 
 
 #define MAXNROF_AO              3
-#define MAXNROF_GENSTR          16
+//#define MAXNROF_GENSTR          16
 #define MAXNROF_CONTR_PORTS     11
 #define MAXNROF_DIports         2
 #define MAXNROF_DOports         2
@@ -32,9 +32,6 @@ bool indat_isMifareOn();
 void indat_storeMDBisOn(bool isOn);
 bool indat_isMdbOn();
 
-
-
-
 void gpi_storeSlaveSerParams(uint8_t slaveBaudRate, uint8_t NrDataBits,
                              uint8_t parity, uint8_t NrStopBits);
 
@@ -43,23 +40,16 @@ void epi_getSlaveSerParams(uint8_t *slaveBaudRate, uint8_t *NrDataBits,
 
 QString epi_getSlaveParamSTR();
 
-
-
-
-
 void gpi_storeGenerals(uint8_t genNr, QString text);
     // 0=HW   1=SW  2=State
-
 QString epi_loadGenerals(uint8_t genNr);
 // genNr=0=HW   1=SW  2=State
 
 
-void gpi_storeUID(uint8_t *buf8byteUid);
+void gpi_storeUID(uint8_t const *buf8byteUid);
 // buffer size: 8 byte
-
 void epi_getUIDdec(uint8_t *buf8byteUid);
 // buffer size: 8 byte
-
 QString epi_getUIDstr();
 
 
@@ -73,7 +63,7 @@ QString epi_getUIDstr();
 uint8_t epi_getSquareMode();
 void gpi_backupSquareMode(uint8_t squMode);
 
-void gpi_backupTime(uint8_t *timeBuffer, uint8_t Leng);
+void gpi_backupTime(uint8_t *timeBuffer, uint8_t Leng);     // 104, <=8byte
 void epi_getTime(uint8_t *hh, uint8_t *mm, uint8_t *ss);
 void epi_getDate(uint8_t *yy, uint8_t *mm, uint8_t *dd);
 void epi_getToday(uint8_t *dow, uint16_t *minOfToday, uint32_t *secOfToday);
@@ -89,7 +79,7 @@ void epi_getSpecialYearTimeDate(uint16_t *DayOfYear, uint16_t *HoursOfYear, uint
 // ///////////////////////////////////////////////////////////////////////////////////
 
 
-#define MAXNROF_AI              4
+// #define MAXNROF_AI              4
 
 void gpi_storeAIs(uint8_t aiNr, uint16_t val);   // rs -> Sdata
 
@@ -138,185 +128,119 @@ void gpi_storeDI_optos(uint8_t indatOpto);
 uint8_t epi_getDI_optos(void);
     // bit0: opto in 1    1: opto in 2
 
-void gpi_storeDI_auxIn(uint8_t indatAuxIn);
-    // Aux0...5
-
-uint8_t epi_getDI_auxIn(void);
-    // bit0: auxin 1  ...  5: auxin 6
-
-void gpi_storeDI_ptuWake(uint8_t indat);
+uint8_t gpi_storeDI_auxIn(uint8_t indatAuxIn); // Aux0...5
+uint8_t epi_getDI_auxIn(void);                 // bit0: auxin 1  ...  5: auxin 6
 
+bool gpi_storeDI_ptuWake(bool w);
 bool epi_getDI_ptuWake(void);
 
-void gpi_storeDI_mbdWake(uint8_t indat);
-
+bool gpi_storeDI_mbdWake(bool w);
 bool epi_getDI_mdbWake(void);
 
-void gpi_storeDI_prnReady(uint8_t indat);
-
+bool gpi_storeDI_prnReady(bool ready);
 bool epi_getDI_prnReady(void);
 
-void gpi_storeDI_CoinAttach(uint8_t indat);
-
+bool gpi_storeDI_CoinAttach(bool attach);
 bool epi_getDI_CoinAttach(void);
 
-void gpi_storeDI_CoinEscrow(uint8_t indat);
-
+bool gpi_storeDI_CoinEscrow(bool ce);
 bool epi_getDI_CoinEscrow(void);
 
-void gpi_storeDI_mifareCardTapped(uint8_t indat);
-
+bool gpi_storeDI_mifareCardTapped(bool tapped);
 bool epi_getDI_mifareCardTapped(void);
 
-void gpi_storeDI_modemWake(uint8_t indat);
-
+bool gpi_storeDI_modemWake(bool w);
 bool epi_getDI_modemWake(void);
 
-
-void gpi_storeDI_contactPowerIsOn(bool di_contact_PwrOn);
-
+bool gpi_storeDI_contactPowerIsOn(bool on);
 bool epi_getDI_contactPwr(void);
 
-void gpi_storeDI_MifarePowerIsOn(bool di_mifare_PwrOn);
-
+bool gpi_storeDI_MifarePowerIsOn(bool on);
 bool epi_getDI_mifarePwr(void);
 
-void gpi_storeDI_readbackMdbTxD(bool di_rdbkMdbTxd);
-
+bool gpi_storeDI_readbackMdbTxD(bool rdbkMdbTxd);
 bool epi_getDI_mdbTxd(void);
 
-void gpi_storeDI_AuxPowerIsOn(bool di_Aux_PwrOn);
-
+bool gpi_storeDI_AuxPowerIsOn(bool on);
 bool epi_getDI_auxPwr(void);
 
-void gpi_storeDI_GsmPowerIsOn(bool di_gsm_PwrOn);
-
+bool gpi_storeDI_GsmPowerIsOn(bool on);
 bool epi_getDI_gsmPwr(void);
 
-void gpi_storeDI_CreditPowerIsOn(bool di_credit_PwrOn);
-
+bool gpi_storeDI_CreditPowerIsOn(bool on);
 bool epi_getDI_creditPwr(void);
 
-void gpi_storeDI_PrinterPowerIsOn(bool di_printer_PwrOn);
-
+bool gpi_storeDI_PrinterPowerIsOn(bool on);
 bool epi_getDI_printerPwr(void);
 
-void gpi_storeDI_MdbPowerIsOn(bool di_mdb_PwrOn);
-
+bool gpi_storeDI_MdbPowerIsOn(bool on);
 bool epi_getDI_mdbPwr(void);
 
-
-void gpi_storeDI_rejMot_home(bool di);
-
+bool gpi_storeDI_rejMot_home(bool reject);
 bool epi_getDI_rejectMotor_homepos(void);
 
-void gpi_storeDI_paperLow(uint8_t di);
-
+uint8_t gpi_storeDI_paperLow(uint8_t di);
 uint8_t epi_getDI_npe_sensor(void);
     // 0: Sensor sees paper 1: no paper 99: off
 
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
 // ///////////////////////////////////////////////////////////////////////////////////
 //          readback digital outputs
 // ///////////////////////////////////////////////////////////////////////////////////
 
-void gpi_storeDO_mdbRxTst(uint8_t do_mbdRxTst);
-
+uint8_t gpi_storeDO_mdbRxTst(uint8_t do_mbdRxTst);
 bool epi_getDO_mdbRxTestOut(void);
 
-
-void gpi_storeDO_motorOutputs(uint8_t Pwr);
-
+uint8_t gpi_storeDO_motorOutputs(uint8_t Pwr);
 uint8_t epi_getDO_motorOuts(void);
     // bit0: upper lock forward    bit 1 backward
     // bit2: lower lock forward    bit 3 backward
 
-
-void gpi_storeDO_serialSwitch(uint8_t state);
+uint8_t gpi_storeDO_serialSwitch(uint8_t state);
     // serial drv on/off, Serial mux1, Serial mux2
-
 uint8_t epi_getDO_serialSwitch(void);
     // serial drv on/off, Serial mux1, Serial mux2
 
 bool epi_getDO_serialDriverIsOn(void);
-
 bool epi_getDO_serialMux1isSetToPrinter(void);
     // mux1 off: serial is switched to printer
 
 bool epi_getDO_serialMux1isSetToModem(void);
     // mux1 on: serial is switched to modem
-
 bool epi_getDO_serialMux2isSetToCredit(void);
     // mux2 off: serial is switched to credit card terminal
-
 bool epi_getDO_serialMux2isSetToMifare(void);
     // mux2 on: serial is switched to mifare reader
 
-
-void gpi_storeDO_ledsAndFan(uint8_t ledState);
-
+uint8_t gpi_storeDO_ledsAndFan(uint8_t ledState);
 bool epi_getDO_led_coin(void);
-
 bool epi_getDO_led_front(void);
-
 bool epi_getDO_led_ticket(void);
-
 bool epi_getDO_led_pin(void);
-
 bool epi_getDO_led_start(void);
-
 bool epi_getDO_led_inside(void);
-
 bool epi_getDO_fan(void);
 
-void gpi_storeDO_sirenAndRelay(uint8_t sirenRelay);
-
+uint8_t gpi_storeDO_sirenAndRelay(uint8_t sirenRelay);
 bool epi_getDO_sirene(void);
-
 bool epi_getDO_relay(void);
 
-void gpi_storeDO_ptuWake(uint8_t state);
-
+uint8_t gpi_storeDO_ptuWake(uint8_t state);
 bool epi_getDO_ptuWake(void);
 
-void gpi_storeDO_auxPower(uint8_t pwr);
-
+uint8_t gpi_storeDO_auxPower(uint8_t pwr);
 bool epi_getDO_auxPower(void);
 
-
-void gpi_storeDO_coinShutter(uint8_t state);
-
+uint8_t gpi_storeDO_coinShutter(uint8_t state);
 bool epi_getDO_coinShutterOpen(void);
-
 bool epi_getDO_coinShutterTest(void);
 
-
-void gpi_storeDO_coinEscrow(uint8_t state);
-
+uint8_t gpi_storeDO_coinEscrow(uint8_t state);
 uint8_t epi_getDO_coinEscrow(void);
     // retval: 1:return flap is open   2:take flap is open    0:closed
 
-
-void gpi_storeDO_printerPwrOn(uint8_t state);
-
+uint8_t gpi_storeDO_printerPwrOn(uint8_t state);
 uint8_t epi_getDO_printerPwr(void);
 
-
-
 // ---------------------------------------------------------------------------------------------
 // counterchecks, make sure that DC-outputs are correct
 
@@ -363,21 +287,14 @@ bool epi_cntchk_Mot2Fon(void);
 
 uint8_t gpi_storeMdbRecData(uint8_t length, uint8_t *buf);
     // datif store received mdb data
-
 uint8_t epi_getMdbResponse(void);
      // 0=no response  1=ACK  2=NAK  3=ACK with data
-
 uint8_t epi_getMdbRecLength(void);
     // 0...31
-
 uint8_t epi_restoreMdbRecData(uint8_t *buf);
     // hwapi reads received mdb data from PI
 
-
-
-
-
-uint8_t gpi_storeMifReaderStateAndCardType(uint8_t *buf);
+uint8_t gpi_storeMifReaderStateAndCardType(uint8_t const *buf);
 
 /* data description:
 byte 0: current read state: 0=power off  1=reader-fault 2=ready
@@ -401,41 +318,24 @@ byte 32: result, always 0
 
 uint8_t epi_restoreMifState(uint8_t *buf, uint8_t maxBufferSize);
     // retval 0=OK 1=error host buffer too small
-
-void gpi_storeMifCardData(uint8_t blkNr, uint8_t *receivedData);
+bool gpi_storeMifCardData(uint8_t blkNr, uint8_t const *receivedData);
     // blkNr=0...11    receivedData[64]
-
 uint8_t epi_restoreMifData(uint8_t blkNr, uint8_t *buf, uint8_t maxBufferSize);
     // blkNr=0...11    return buf[64]
     // retval: 1=error 0=OK
 
-
-
-#define pi_prnStateArraySize    20
-#define pi_prnFontArraySize     20
-
 void epi_restorePrinterState(uint8_t *buf);
-
-void gpi_storePrinterState(uint8_t *buf);
+void gpi_storePrinterState(uint8_t const *buf);
 
 void epi_restorePrinterFonts(uint8_t *buf);
+void gpi_storePrinterFonts(uint8_t const *buf);
 
-void gpi_storePrinterFonts(uint8_t *buf);
-
-
-
-
-void gpi_storeMdbState(uint8_t busReady, uint8_t V12on, uint8_t V5on );
-
+bool gpi_storeMdbState(bool busReady, bool V12on, bool V5on);
 bool epi_restoreMdbBusReady(void);
-
 bool epi_restoreMdbV12Ready(void);
-
 bool epi_restoreMdbV5Ready(void);
 
-
-void gpi_storeMdbResponse(uint8_t leng, uint8_t *data);
-
+void gpi_storeMdbResponse(uint8_t leng, uint8_t const *data);
 void epi_restoreMdbResponse(uint8_t *leng, uint8_t *data);
     // last received mdb answer (from mdb device)
     // only needed if a special command was sent directly
@@ -444,12 +344,9 @@ void epi_restoreMdbResponse(uint8_t *leng, uint8_t *data);
     // DB2: nr of received (payload) data bytes (apart from ACK, can be 0....34)
     // DB3...DB38: rec.data (payload)
 
-
-void gpi_storeEmpSettings(uint8_t leng, uint8_t *data);
-
+void gpi_storeEmpSettings(uint8_t leng, uint8_t const *data);
 void epi_restoreEmpSettings(uint8_t *leng, uint8_t *data);
 
-
 /*
 void gpi_storeEmpCoinSignal(uint8_t leng, uint8_t *data);
 
@@ -463,25 +360,67 @@ void epi_restoreEmpCoinSignal(uint8_t *leng, uint8_t *data);
 void epi_clearEmpCoinSignal();
 */
 
-#define     MEMDEPTH_GOTCOINS       16
 
-void gpi_storeEmpCoinSignal(uint8_t leng, uint8_t *data);
+void gpi_storeEmpCoinSignal(uint8_t leng, uint8_t const *data);
 
 uint8_t epi_isNewCoinLeft(void);
     // retval: 0...16 coins left in FIFO
-
 void epi_restoreEmpCoinSignal(uint8_t *valid, uint8_t *signal, uint8_t *error, uint16_t *value);
 
+void gpi_storeRbDeviceSettings(uint8_t leng, uint8_t const *data);
+void epi_restoreRbDeviceSettings(uint8_t *leng, uint8_t *data);
 
-
-void gpi_storeDeviceSettings(uint8_t leng, uint8_t *data);
-
-void epi_restoreDeviceSettings(uint8_t *leng, uint8_t *data);
-
-void gpi_storeMachineIDsettings(uint8_t leng, uint8_t *data);
-
+void gpi_storeMachineIDsettings(uint8_t leng, uint8_t const *data);
 void epi_restoreMachineIDsettings(uint8_t *leng, uint8_t *data);
 
+void epi_clearCurrentPayment(void);
+void gpi_storeCurrentPayment(uint32_t insertedAmount, uint16_t lastCoinType, uint16_t lastCoinValue);
+
+uint32_t epi_CurrentPaymentGetAmount(void);
+uint16_t epi_CurrentPaymentGetLastCoin(void);
+
+bool epi_CurrentPaymentGetAllCoins(uint16_t *types, uint16_t *values);
+    // alle bei diesem Verkauf eingeworfenen Münzen sind gespeichert falls die jmd. braucht
+
+void gpi_storeWakeSources(uint8_t const *receivedData);
+uint64_t epi_getWakeSources(void);
+uint8_t epi_getWakeReason(void);
+
+void gpi_storeExtendedTime(uint8_t leng, uint8_t const *data);
+void epi_restoreExtendedTime(uint8_t *leng, uint8_t *data);
+
+void gpi_storeDeviceConditions(uint8_t leng, uint8_t const *data);
+void epi_restoreDeviceConditions(uint8_t *leng, uint8_t *data);
+
+void gpi_storeDynMachineConditions(uint8_t leng, uint8_t const *data);
+void epi_restoreDynMachineConditions(uint8_t *leng, uint8_t *data);
+
+void gpi_storeDCbackupAccNr(uint8_t leng, uint8_t const *data);
+void epi_restoreDCbackupAccNr(uint8_t *leng, uint16_t *accNrs);
+    // return accNrs[0..7]
+
+void epi_iniVRstorage(void);
+void gpi_storeVaultRecord(uint8_t blkNr, uint8_t const *data);
+bool epi_checkIfVaultRecordAvailable(void);
+bool epi_restoreVaultRecord(uint16_t *length, uint8_t *buf);
+    // true if completly received
+
+void gpi_storeCBlevel(uint32_t amount, uint16_t nrOfCoins);
+
+uint32_t epi_getCashBoxContent(void);
+uint16_t epi_getNrOfCoinsInCashBox(void);
+
+void gpi_storeNewMifareCard(uint8_t typ, uint8_t const *holder);
+
+uint8_t epi_mifGetCardType(uint8_t const *holder);
+    //holder[8] = name of card holder
+    // retval Type of MifareCard, 1=upper door, 2=lower door 3=test printer 4=test coins
+
+void gpi_storeDcDataValid(bool isVal);
+bool gpi_areDcDataValid();
+bool epi_areDcDataValid();
+
+
 
 #endif
 

include/tslib.h

@@ -13,6 +13,9 @@ uint32_t uchar2ulong(uint8_t Highbyte, uint8_t MHbyte, uint8_t MLbyte, uint8_t L
 
 uint8_t  uint2uchar(uint16_t uival, bool getHighB);
 
+uint8_t ulong2uchar(uint32_t ulval, uint8_t getBytNr);
+    // getBytNr: 0=LSB  3=MSB
+
 
 void delay(uint16_t MilliSec);
 
@@ -59,6 +62,7 @@ void GetShortDateString(uint8_t day, uint8_t month, uint8_t yearlow, uint8_t for
 
 
 uint16_t tslib_strlen(char *buf);
+uint16_t tslib_strlen(uint8_t *buf);
 
 void tslib_strclr(char *buf, char clrsign, uint16_t len);
 void tslib_strclr(uint8_t *buf, char clrsign, uint16_t len);
@@ -79,6 +83,8 @@ int tslib_getMinimum(int val1, int val2);
 void tslib_text2array(QByteArray text, char *aray, uint16_t maxArayLen);
     // usage:  tslib_text2array("my text", ctmp, 50);
 
+void biox_CopyBlock(uint8_t *src, uint16_t srcPos, uint8_t *dest, uint16_t destPos, uint16_t len);
+    // both buffers starting from pos 0
 
 
 #endif // TSLIB_H

src/ATBAPP/ATBAPPplugin.h

@@ -0,0 +1,22 @@
+#ifndef ATBAPPPLUGIN_H
+#define ATBAPPPLUGIN_H
+
+/***********************************************************
+ * a simple class with only one method for plugin info
+ */
+#include <QObject>
+#include <QString>
+
+class ATBAPPplugin
+{
+
+public:
+    virtual const QString & getPluginInfo() = 0;
+};
+
+Q_DECLARE_INTERFACE(ATBAPPplugin,
+                    "eu.atb.ptu.plugin.ATBAPPplugin/0.9")
+
+
+
+#endif // ATBAPPPLUGIN_H

src/ATBAPP/ATBDeviceControllerPlugin.cpp

@@ -0,0 +1,316 @@
+#include "src/ATBAPP/ATBDeviceControllerPlugin.h"
+#include "src/ATBAPP/ATBHealthEvent.h"
+
+#include <QTimer>
+#include <QTextCodec>
+
+
+ATBDeviceControllerPlugin::ATBDeviceControllerPlugin(QObject *parent) : QObject(parent),
+    pluginState(PLUGIN_STATE::NOT_INITIALIZED)
+{
+    this->pluginInfo = QString::fromUtf8(pluginInfoString.c_str());
+
+    this->hw = new hwapi();
+
+    connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_templatePrintFinished_OK()),  this, SLOT(onPrintFinishedOK()));
+    connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_templatePrintFinished_Err()), this, SLOT(onPrintFinishedERR()));
+    connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_gotNewCoin()),    this, SLOT(onCashGotCoin()));
+    connect(dynamic_cast<QObject*>(hw), SIGNAL(hwapi_vendStopByMax()), this, SLOT(onCashVendStopByMax()));
+}
+
+ATBDeviceControllerPlugin::~ATBDeviceControllerPlugin() {}
+
+PLUGIN_STATE ATBDeviceControllerPlugin::initDCPlugin(QObject *healthEventReceiver, const QSettings & settings)
+{
+    this->healthEventReceiver = healthEventReceiver;
+
+    // read variables from setting
+    QString serialPort = settings.value("DEVICE_CONTROLLER/serialPort", "ttymxc2").toString();
+    QByteArray printerEncoding = settings.value("DEVICE_CONTROLLER/printerEnconding", "ISO 8859-2").toString().toLatin1();
+
+
+
+    // open serial port
+    hw->dc_openSerial(5, "115200", serialPort, 1);
+
+
+    // text encoding for printer
+    this->codec = QTextCodec::codecForName(printerEncoding);
+
+
+
+    this->pluginState = PLUGIN_STATE::INITIALIZED;
+
+    return pluginState;
+}
+
+
+// TASKS: Cash handling -------------------------------------------------------
+void ATBDeviceControllerPlugin::requestStartCashInput(const QString & amount)
+{
+    qCritical() << "Start Cash vending with amount = " << amount;
+
+    uint32_t amountInt = static_cast<uint32_t>(amount.toUInt());
+
+    hw->cash_startPayment(amountInt);
+}
+
+void ATBDeviceControllerPlugin::requestStopCashInput()
+{
+    hw->cash_stopPayment();
+}
+
+void ATBDeviceControllerPlugin::cashCollect()
+{
+    hw->vend_success();
+}
+
+void ATBDeviceControllerPlugin::cashAbort()
+{
+    hw->vend_failed();
+}
+
+
+// TASKS: printing ------------------------------------------------------------
+void ATBDeviceControllerPlugin::requestPrintTicket(const QHash<QString, QVariant> & printingData)
+{
+    struct T_dynDat *dynTicketData = new T_dynDat;
+    memset(dynTicketData, 0, sizeof(*dynTicketData));
+
+    qCritical() << "ATBDeviceControllerPlugin::requestPrintTicket( "         << endl
+                << "     licenseplate = " << printingData["licenseplate"]    << endl
+                << "           amount = " << printingData["amount"]          << endl
+                << "       parkingEnd = " << printingData["parkingEnd"]      << endl
+                << "  currentDateTime = " << printingData["currentDateTime"] << endl;
+
+    QDateTime parkingEndDateTime = QDateTime::fromString(printingData["parkingEnd"].toString(),  Qt::ISODate);
+    QDateTime currentDateTime    = QDateTime::fromString(printingData["currentDateTime"].toString(), Qt::ISODate);
+
+    /* -----------------------------------------------------------------------------------------
+     * note: the following highly depends on printer template files!
+     * -----------------------------------------------------------------------------------------
+     */
+
+    // set dynamic printer data:
+    QByteArray ba_licenseplate = codec->fromUnicode(printingData["licenseplate"].toString());
+    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));
+
+    QByteArray ba_parkingEndTime = codec->fromUnicode(parkingEndDateTime.toString("hh:mm"));
+    memcpy((char*)dynTicketData->parkingEndTime,  ba_parkingEndTime.data(), std::min(ba_parkingEndTime.size(),8));
+
+    QByteArray ba_parkingEndDate = codec->fromUnicode(parkingEndDateTime.toString("dd.MM.yy"));
+    memcpy((char*)dynTicketData->parkingEndDate,  ba_parkingEndDate.data(), std::min(ba_parkingEndDate.size(),8));
+
+    QByteArray ba_currentDate = codec->fromUnicode(currentDateTime.toString("dd.MM.yy"));
+    memcpy((char*)dynTicketData->currentDate,  ba_currentDate.data(), std::min(ba_currentDate.size(),8));
+
+
+    // DEBUG
+    /*
+    uint8_t* buf = dynTicketData->licensePlate;
+    int length = 64;
+    for (int i = 0; i < length; ++i) {
+            fprintf(stderr, "%d %02x %c\n", i, buf[i], buf[i]);
+    }
+    fprintf(stderr, "\n");
+    */
+
+    // DEBUG
+    qCritical() << "ATBDeviceControllerPlugin::requestPrintTicket()";
+
+    if (!this->hw->dc_isPortOpen()) {
+        qCritical() << "    ... serial port is not open!";
+        this->onPrintFinishedERR();
+        return;
+    }
+
+
+    // TODO: wird hier nur 'licensePlate' gedruckt?
+    if (!this->hw->prn_sendDynamicPrnValues(dynTicketData->licensePlate)) {
+        this->errorCode = "hwapi::prn_sendDynamicPrnValues";
+        this->errorDescription = "hwapi method 'hwapi::prn_sendDynamicPrnValues' result is false";
+
+        qCritical() << "ERROR:";
+        qCritical() << "ATBDeviceControllerPlugin::requestPrintTicket( "        << endl
+                    << "     licenseplate = " << printingData["licenseplate"]   << endl
+                    << "           amount = " << printingData["amount"]         << endl
+                    << "       parkingEnd = " << printingData["parkingEnd"]     << endl
+                    << "      currentTime = " << printingData["currentTime"]    << endl
+                    << "      currentDate = " << printingData["currentDate"]    << endl;
+
+
+        this->onPrintFinishedERR();
+        return;
+    }
+
+    QTimer::singleShot(500, this, SLOT(onPrinterDataPrepared()));
+}
+
+
+
+void ATBDeviceControllerPlugin::onPrinterDataPrepared()
+{
+    this->currentTemplate = 1;
+    this->onPrinterPrintNextTemplate();
+}
+
+
+void ATBDeviceControllerPlugin::onPrinterPrintNextTemplate()
+{
+    qCritical() << "     ... print template " << this->currentTemplate;
+
+    if (!this->hw->prn_printTemplate(this->currentTemplate)) {
+        this->errorCode = "hwapi::prn_printTemplate";
+        this->errorDescription = QString("hwapi method 'hwapi::onPrinterPrintNextTemplate(%1)' result is false").arg(this->currentTemplate);
+        this->onPrintFinishedERR();
+        return;
+    }
+
+    if (this->currentTemplate >= 3) {
+        // all templates are printed
+        this->currentTemplate = 0;
+
+        // FAKE SIGNAL:
+        QTimer::singleShot(500, this, SLOT(onPrintFinishedOK()));
+    }
+    else {
+        // print next template
+        this->currentTemplate++;
+        QTimer::singleShot(1000, this, SLOT(onPrinterPrintNextTemplate()));
+    }
+
+}
+
+
+/************************************************************************************************
+ * private slots, interface to low level hwapi
+ *
+ */
+void ATBDeviceControllerPlugin::onPrintFinishedOK()
+{
+    // DEBUG
+    qCritical() << "ATBDeviceControllerPlugin::onPrintFinishedOK()";
+
+    emit this->printTicketFinished(nsDeviceControllerInterface::RESULT_STATE::SUCCESS,
+                                   "",
+                                   "");
+}
+void ATBDeviceControllerPlugin::onPrintFinishedERR()
+{
+    // DEBUG
+    qCritical() << "ATBDeviceControllerPlugin::onPrintFinishedERR()";
+
+
+    this->errorCode = "PRINTER";               // TODO: get more detailed error code from low level API
+    this->errorDescription = "Printer error";  // TODO: get more detailed error description from low level API
+
+    emit this->printTicketFinished(nsDeviceControllerInterface::RESULT_STATE::ERROR_BACKEND,
+                                   this->errorCode,
+                                   this->errorDescription);
+}
+
+
+
+/************************************************************************************************
+ * cash payment
+ */
+void ATBDeviceControllerPlugin::onCashGotCoin()
+{
+    // DEBUG
+    qCritical() << "ATBDeviceControllerPlugin::onGotCoin()";
+
+    uint32_t amountInt = this->hw->getInsertedAmount();
+
+    QString amountString = QString::number(amountInt);
+
+
+    emit this->cashInputEvent(nsDeviceControllerInterface::RESULT_STATE::SUCCESS,
+                              nsDeviceControllerInterface::CASH_STATE::CACHE_INPUT,
+                              amountString,
+                              "",
+                              "");
+}
+
+
+void ATBDeviceControllerPlugin::onCashVendStopByMax()
+{
+    // DEBUG
+    qCritical() << "ATBDeviceControllerPlugin::onCashVendStopByMax()";
+
+    uint32_t amountInt = this->hw->getInsertedAmount();
+
+    QString amountString = QString::number(amountInt);
+
+    emit this->cashInputFinished(nsDeviceControllerInterface::RESULT_STATE::SUCCESS,
+                              amountString,
+                              "",
+                              "");
+
+}
+
+/************************************************************************************************
+ * Mandatory plugin methods
+ *
+ */
+
+PLUGIN_STATE ATBDeviceControllerPlugin::getState()
+{
+    return this->pluginState;
+}
+
+QString & ATBDeviceControllerPlugin::getLastError()
+{
+    return this->errorCode;
+}
+
+const QString & ATBDeviceControllerPlugin::getLastErrorDescription()
+{
+    return this->errorDescription;
+}
+
+const QString & ATBDeviceControllerPlugin::getPluginInfo()
+{
+    return this->pluginInfo;
+}
+
+
+const QString ATBDeviceControllerPlugin::getString(nsDeviceControllerInterface::RESULT_STATE resultState)
+{
+    QString str;
+
+    switch (resultState) {
+    case nsDeviceControllerInterface::RESULT_STATE::SUCCESS:
+        str = QString("RESULT_STATE::SUCCESS");
+        break;
+    case nsDeviceControllerInterface::RESULT_STATE::ERROR_BACKEND:
+        str = QString("RESULT_STATE::ERROR_BACKEND");
+        break;
+    case nsDeviceControllerInterface::RESULT_STATE::ERROR_TIMEOUT:
+        str = QString("RESULT_STATE::ERROR_TIMEOUT");
+        break;
+    case nsDeviceControllerInterface::RESULT_STATE::ERROR_PROCESS:
+        str = QString("RESULT_STATE::ERROR_PROCESS");
+        break;
+    case nsDeviceControllerInterface::RESULT_STATE::ERROR_RETRY:
+        str = QString("RESULT_STATE::ERROR_RETRY");
+        break;
+    case nsDeviceControllerInterface::RESULT_STATE::INFO:
+        str = QString("RESULT_STATE::INFO");
+        break;
+    }
+    return str;
+
+}
+
+
+
+/************************************************************************************************
+ * ... end
+ */
+
+#if QT_VERSION < 0x050000
+Q_EXPORT_PLUGIN2( ATBDeviceControllerPlugin, ATBDeviceControllerPlugin )
+#endif

src/ATBAPP/ATBDeviceControllerPlugin.h

@@ -0,0 +1,125 @@
+#ifndef ATBDEVICECONTROLLERPLUGIN_H
+#define ATBDEVICECONTROLLERPLUGIN_H
+
+#include <QObject>
+
+#include "src/ATBAPP/DeviceControllerInterface.h"
+#include "src/ATBAPP/ATBAPPplugin.h"
+#include "version.h"
+
+
+
+#include "hwapi.h"
+
+#include <unistd.h>
+#include <thread>
+#include <memory>
+#include <QSharedMemory>
+
+
+class QTextCodec;
+
+
+using namespace nsDeviceControllerInterface;
+
+class QSettings;
+
+class ATBDeviceControllerPlugin : public QObject,
+        public DeviceControllerInterface
+{
+    Q_OBJECT
+    Q_INTERFACES(ATBAPPplugin)
+    Q_INTERFACES(DeviceControllerInterface)
+    #if QT_VERSION >= 0x050000
+    Q_PLUGIN_METADATA( IID "ATBDeviceControllerPlugin" )
+    #endif
+
+public:
+    explicit ATBDeviceControllerPlugin(QObject *parent = nullptr);
+    ~ATBDeviceControllerPlugin();
+
+    // ----------------------------------------------------------------------------
+    // interface:
+    PLUGIN_STATE initDCPlugin(QObject *healthEventReceiver, const QSettings & settings);
+
+    // TASKS: Cash handling -------------------------------------------------------
+    void requestStartCashInput(const QString & amount);
+    void requestStopCashInput();
+    void cashCollect();
+    void cashAbort();
+
+    // TASKS: printing ------------------------------------------------------------
+    void requestPrintTicket(const QHash<QString, QVariant> & printingData);
+
+    // mandantory ATBAPP plugin methods: ------------------------------------------
+    nsDeviceControllerInterface::PLUGIN_STATE getState();
+    QString & getLastError();
+    const QString & getLastErrorDescription();
+
+    const QString & getPluginInfo();
+
+    // helpers e.g. for debug / log
+    const QString getString(nsDeviceControllerInterface::RESULT_STATE resultState);
+
+
+
+
+
+signals:
+    void printTicketFinished(nsDeviceControllerInterface::RESULT_STATE resultState,
+                                     const QString & errorCode,
+                                     const QString & errorDescription);
+
+    void cashInputEvent(nsDeviceControllerInterface::RESULT_STATE resultState,
+                        nsDeviceControllerInterface::CASH_STATE cashState,
+                        const QString & newCashValue,
+                        const QString & errorCode,
+                        const QString & errorDescription);
+
+    void cashInputFinished(nsDeviceControllerInterface::RESULT_STATE resultState,
+                                     const QString & newCashValue,
+                                     const QString & errorCode,
+                                     const QString & errorDescription);
+
+    void requestServiceMode();
+
+    void Error(
+            const QString & errorCode,
+            const QString & errorDescription);
+
+
+
+
+private:
+   QString errorCode;
+   QString errorDescription;
+   QString pluginInfo;
+
+   int currentTemplate;
+
+
+   bool useDebug;
+
+   PLUGIN_STATE pluginState;
+
+   QObject* healthEventReceiver;
+
+   hwinf* hw;
+
+   QTextCodec *codec;
+
+private slots:
+   // printer
+
+   void onPrinterDataPrepared();
+   void onPrinterPrintNextTemplate();
+
+   void onPrintFinishedOK();
+   void onPrintFinishedERR();
+
+   // cash payment
+   void onCashGotCoin();
+   void onCashVendStopByMax();
+};
+
+#endif // ATBDEVICECONTROLLERPLUGIN_H

src/ATBAPP/ATBHealthEvent.cpp

@@ -0,0 +1,25 @@
+#include "src/ATBAPP/ATBHealthEvent.h"
+
+ATBHealthEvent::ATBHealthEvent(ATB_HEALTH_MODE mode, const QString & errorNumber, const QString & errorDescription) :
+    QEvent(ATB_HEALTH_EVENT),
+    healthMode(mode),
+    errorNumber(errorNumber),
+    errorDescription(errorDescription)
+{
+
+}
+
+QString ATBHealthEvent::getErrorNumber()
+{
+    return this->errorNumber;
+}
+
+QString ATBHealthEvent::getErrorDescription()
+{
+    return this->errorDescription;
+}
+
+ATB_HEALTH_MODE ATBHealthEvent::getMode()
+{
+    return this->healthMode;
+}

src/ATBAPP/ATBHealthEvent.h

@@ -0,0 +1,44 @@
+#ifndef ATBHEALTHEVENT_H
+#define ATBHEALTHEVENT_H
+
+#include <QEvent>
+#include <QString>
+
+enum class ATB_HEALTH_MODE : quint8;
+
+const QEvent::Type ATB_HEALTH_EVENT = static_cast<QEvent::Type>(QEvent::User + 1);
+
+
+class ATBHealthEvent : public QEvent
+{
+
+public:
+    ATBHealthEvent(ATB_HEALTH_MODE mode, const QString & errorNumber, const QString & errorDescription);
+
+    QString getErrorNumber();
+    QString getErrorDescription();
+    ATB_HEALTH_MODE getMode();
+
+signals:
+
+public slots:
+
+
+private:
+    ATB_HEALTH_MODE healthMode;
+    QString errorNumber;
+    QString errorDescription;
+};
+
+
+enum class ATB_HEALTH_MODE : quint8 {
+    WARNING,
+    ERROR,
+    WARNING_CORRECTION,
+    ERROR_CORRECTION,
+    DEBUG,
+    STATE,
+    UNSPECIFIED
+};
+
+#endif // ATBHEALTHEVENT_H

src/ATBAPP/DeviceControllerInterface.h

@@ -0,0 +1,142 @@
+#ifndef DEVICECONTROLLERINTERFACE_H
+#define DEVICECONTROLLERINTERFACE_H
+
+#include <QtPlugin>
+
+#include <QSettings>
+#include <QString>
+
+#include "ATBAPPplugin.h"
+
+namespace nsDeviceControllerInterface {
+    enum class PLUGIN_STATE : quint8;
+    enum class RESULT_STATE : quint8;
+    enum class CASH_STATE   : quint8;
+}
+
+
+class DeviceControllerInterface : public ATBAPPplugin
+{
+    Q_INTERFACES(ATBAPPplugin)
+
+public:
+    virtual ~DeviceControllerInterface() {}
+
+    virtual nsDeviceControllerInterface::PLUGIN_STATE initDCPlugin(QObject *healthEventReceiver,
+                                                                   const QSettings & settings) = 0;
+
+    // TASKS: Cash handling -------------------------------------------------------
+    /**
+     * enables coin input
+     * amount = "0": pay-up
+     * amount > "0": pay-down
+     */
+    virtual void requestStartCashInput(const QString & amount) = 0;
+
+    /**
+     * called e.g. on Button "NEXT" in pay-up (direct coin input)
+     */
+    virtual void requestStopCashInput() = 0;
+
+    /**
+     * called e.g. on Button "NEXT" in pay-up (direct coin input)
+     */
+    virtual void cashCollect() = 0;
+    virtual void cashAbort() = 0;
+
+
+
+    // TASKS: printing ------------------------------------------------------------
+    virtual void requestPrintTicket(const QHash<QString, QVariant> & printingData) = 0;
+
+
+    // mandantory ATBAPP plugin methods:
+    virtual nsDeviceControllerInterface::PLUGIN_STATE getState() = 0;
+    virtual const QString & getLastError() = 0;
+    virtual const QString & getLastErrorDescription() = 0;
+
+    // return a plugin description in JSON or XML
+    // -> ATBAPPplugin::getPluginInfo()
+
+    // helpers e.g. for debug / log
+    virtual const QString getString(nsDeviceControllerInterface::RESULT_STATE resultState) = 0;
+
+
+signals:
+    virtual void printTicketFinished(nsDeviceControllerInterface::RESULT_STATE resultState,
+                                     const QString & errorCode,
+                                     const QString & errorDescription) = 0;
+
+    /**
+     * emitted on e.g. a coin input
+     */
+    virtual void cashInputEvent(nsDeviceControllerInterface::RESULT_STATE resultState,
+                                nsDeviceControllerInterface::CASH_STATE cashState,
+                                const QString & newCashValue,
+                                /* additional variables? */
+                                const QString & errorCode,
+                                const QString & errorDescription) = 0;
+
+    /**
+     * 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
+     */
+    virtual void cashInputFinished(nsDeviceControllerInterface::RESULT_STATE resultState,
+                                     const QString & newCashValue,
+                                     /*  additional variables? */
+                                     const QString & errorCode,
+                                     const QString & errorDescription) = 0;
+
+
+    /**
+     * emitted e.g. if service door is opened
+     */
+    virtual void requestServiceMode() = 0;
+
+    /**
+     * emitted on error
+     * depending on errorCode:
+     * -> interrupt selling process
+     * -> machine can go to state OOO
+     * -> send error event to ISMAS
+     * -> ...
+     */
+    virtual void Error(
+            /*  additional variables? */
+            const QString & errorCode,
+            const QString & errorDescription) = 0;
+
+};
+
+
+Q_DECLARE_INTERFACE(DeviceControllerInterface,
+                    "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. */
+    };
+}
+
+#endif // DEVICECONTROLLERINTERFACE_H

src/com.cpp

@@ -19,7 +19,7 @@ void T_com::writeToSerial(const QByteArray &data, uint16_t sendLength)
     sendLen=sendLength;
     if (CatSerial->isOpen())
     {
-        //qDebug() << "sending..." << sendBuffer;
+        qCritical() << "sending..." << sendBuffer;
         CatSerial->write(sendBuffer);
     } else
         qDebug() << "error sending, port is not open";

src/controlBus.cpp

@@ -1,141 +1,110 @@
 #include <stdint.h>
+#include <algorithm>
+
 #include <QString>
 #include <QDebug>
 #include "tslib.h"
-//#include "controlBus.h"
+#include "shared_mem_buffer.h"
 
 // ///////////////////////////////////////////////////////////////////////////////////
 //          control serial interface   gui <--> serial
 // ///////////////////////////////////////////////////////////////////////////////////
+void epi_setSerial(int BaudNr,
+                   QString BaudStr,
+                   QString ComName,
+                   uint8_t connect) {
+    memset(&SharedMemBuffer::getData()->rs.comportName[0], 0x00,
+           sizeof(SharedMemBuffer::getData()->rs.comportName));
+    strncpy(SharedMemBuffer::getData()->rs.comportName,
+            ComName.toStdString().c_str(),
+            sizeof(SharedMemBuffer::getData()->rs.comportName)-1);
 
-static QString    rs_comportName;   // z.B. "COM48"
-static QString    rs_baudStr;       // z.B. "19200"
-static int        rs_baudNr;        //0...5 oder -1
-static uint8_t    rs_connect;       // 0,1
+    memset(&SharedMemBuffer::getData()->rs.baudStr[0], 0x00,
+           sizeof(SharedMemBuffer::getData()->rs.baudStr));
+    strncpy(SharedMemBuffer::getData()->rs.baudStr,
+            BaudStr.toStdString().c_str(),
+            sizeof(SharedMemBuffer::getData()->rs.baudStr)-1);
 
-void epi_setSerial(int BaudNr, QString BaudStr, QString ComName, uint8_t connect)
-{
-//    qDebug() << "ENTER" << BaudNr << BaudStr << ComName << connect;
-
-    rs_comportName = ComName;
-    rs_baudStr     = BaudStr;
-    rs_baudNr      = BaudNr;    // 0=1200  1=9600  2=19200  3=38400  4=57600  5=115200  oder -1
-    rs_connect     = connect;     // 0/1
-
-//    qDebug() << "LEAVE" << rs_baudNr << rs_baudStr << rs_comportName << rs_connect;
+    SharedMemBuffer::getData()->rs.baudNr = BaudNr;
+    SharedMemBuffer::getData()->rs.connect = connect;
 }
 
-void epi_closeSerial(void)
-{
-    rs_connect=0;
-//    qDebug() << "ENTER/LEAVE rc_connect=0";
+void epi_closeSerial(void) {
+    SharedMemBuffer::getData()->rs.connect = 0;
 }
 
-
-void gpi_serialChanged(void)
-{
+void gpi_serialChanged(void) {
     // serial confirms that port was closed or opened
-    rs_connect=2;   // Flanke, nur 1x öffnen/schließen
-    //qDebug() << "ENTER/LEAVE rc_connect=2";
+    // rs_connect=2;   // Flanke, nur 1x öffnen/schließen
+    SharedMemBuffer::getData()->rs.connect = 2;
 }
 
-uint8_t gpi_getSerialConn(void)
-{
-    return rs_connect;
+uint8_t gpi_getSerialConn(void) {
+    return SharedMemBuffer::getDataConst()->rs.connect;
 }
 
-
-int gpi_getBaudNr(void)
-{
-    return rs_baudNr;
+int gpi_getBaudNr(void) {
+    return SharedMemBuffer::getDataConst()->rs.baudNr;
 }
 
-QString gpi_getComPortName(void)
-{
-    return rs_comportName;
+QString gpi_getComPortName(void) {
+    return SharedMemBuffer::getDataConst()->rs.comportName;
 }
 
-static bool rs_portIsOpen;
-
-void gpi_serialIsOpen(bool offen)
-{
-    //qDebug() << "ENTER/LEAVE offen=" << offen;
-    rs_portIsOpen=offen;
+void gpi_serialIsOpen(bool offen) {
+    SharedMemBuffer::getData()->rs.portIsOpen = offen;
 }
 
-bool epi_isSerialPortOpen()
-{
+bool epi_isSerialPortOpen() {
     // true: port is open   false: port is closed
-    //qDebug() << "ENTER/LEAVE offen=" << rs_portIsOpen;
-    return rs_portIsOpen;
+    return SharedMemBuffer::getDataConst()->rs.portIsOpen;
 }
 
 // ///////////////////////////////////////////////////////////////////////////////////
 //          Control transfer   gui <--> serial
 // ///////////////////////////////////////////////////////////////////////////////////
 
-
-static char       AutoEmissionOn;     // 1: zyklisch Anfragen zum Slave senden
-
-void epi_startEmmision(char start)
-{
-    AutoEmissionOn=start;
+void epi_startEmmision(char start) {
+    SharedMemBuffer::getData()->AutoEmissionOn = start;
 }
 
-bool gpi_isEmmisionOn(void)
-{
-    return AutoEmissionOn;
+bool gpi_isEmmisionOn(void) {
+    return SharedMemBuffer::getDataConst()->AutoEmissionOn;
 }
 
-//-----------------------------------------------------
-
-static uint16_t datif_sendingPeriod;
-static bool     datif_sendingPer_changed;
-
-uint16_t gpi_getPeriodicSendTimeVal()
-{
-    datif_sendingPer_changed=0;
-    if (datif_sendingPeriod<3 || datif_sendingPeriod>10000)
+uint16_t gpi_getPeriodicSendTimeVal() {
+    SharedMemBuffer::getData()->datif.sendingPer_changed = 0;
+    if ((SharedMemBuffer::getDataConst()->datif.sendingPeriod < 3) ||
+        (SharedMemBuffer::getDataConst()->datif.sendingPeriod > 10000)) {
         return 130;         // ms, default
-    else
-        return datif_sendingPeriod;
+    }
+    return SharedMemBuffer::getDataConst()->datif.sendingPeriod;
 }
 
-void epi_setPeriodicSendTimeVal(uint16_t val)
-{
-    if (val>=3 && val<10000)
-    {
-        datif_sendingPer_changed=1;
-        datif_sendingPeriod=val;
+void epi_setPeriodicSendTimeVal(uint16_t val) {
+    if (val>=3 && val<10000) {
+        SharedMemBuffer::getData()->datif.sendingPer_changed = 1;
+        SharedMemBuffer::getData()->datif.sendingPeriod = val;
     }
 }
 
-bool gpi_PeriodicSendTimeHasChanged()
-{
-    return datif_sendingPer_changed;
+bool gpi_PeriodicSendTimeHasChanged() {
+    return SharedMemBuffer::getDataConst()->datif.sendingPer_changed;
 }
 
-//-----------------------------------------------------
-
-
-//-----------------------------------------------------
-
 // ///////////////////////////////////////////////////////////////////////////////////
 //          Status Display    gui <--> serial
 // ///////////////////////////////////////////////////////////////////////////////////
 
-
 //              linke Spalte, über Connect Button
 static QString txt4comStateLine;
 
-QString epi_getTxt4comStateLine(void)
-{
+QString epi_getTxt4comStateLine(void) {
     // GUI: get Text for serial Comport-State Line
     return txt4comStateLine;
 }
 
-void gpi_setTxt4comStateLine(QString txtline)     // gpi
-{
+void gpi_setTxt4comStateLine(QString txtline) {
     // serial: write Text to be displayed in serial Comport-State line (like "connected")
     txt4comStateLine.clear();
     if (txtline=="")
@@ -144,26 +113,20 @@ void gpi_setTxt4comStateLine(QString txtline)     // gpi
         txt4comStateLine=txtline;
 }
 
-void epi_clrTxt4comStateLine()
-{
+void epi_clrTxt4comStateLine() {
     txt4comStateLine.clear();
 }
 
-
-//---------------------------------------------------------------------------------------------
-
 // rechte Spalte, oberste Statuszeile
 // I) "Handshakes" (serial Control)   flow.cpp
 // geht überhaupt was raus? kommt überhaupt was zurück?
 static QString txt4HsStateLine;
 
-QString epi_getTxt4HsStateLine(void)
-{
+QString epi_getTxt4HsStateLine(void) {
     return txt4HsStateLine;
 }
 
-void gpi_setTxt4HsStateLine(QString txtline)
-{
+void gpi_setTxt4HsStateLine(QString txtline) {
     txt4HsStateLine.clear();
     if (txtline=="")
         txt4HsStateLine.clear();
@@ -171,26 +134,19 @@ void gpi_setTxt4HsStateLine(QString txtline)
         txt4HsStateLine=txtline;
 }
 
-void epi_clrTxt4HsStateLine()
-{
+void epi_clrTxt4HsStateLine() {
     txt4HsStateLine.clear();
 }
 
-
-
-//---------------------------------------------------------------------------------------------
-
 // II) Master receive state (empfangenes Telgramm OK? crc? length?  )
 // Statuszeile Auswertung der SlaveResponse (serial Frame, CRC usw)  (prot.cpp)
 static QString txt4masterStateLine;
 
-QString epi_getTxt4masterStateLine(void)
-{
+QString epi_getTxt4masterStateLine(void) {
     return txt4masterStateLine;
 }
 
-void gpi_setTxt4masterStateLine(QString txtline)
-{
+void gpi_setTxt4masterStateLine(QString txtline) {
     txt4masterStateLine.clear();
     if (txtline=="")
         txt4masterStateLine.clear();
@@ -198,13 +154,10 @@ void gpi_setTxt4masterStateLine(QString txtline)
         txt4masterStateLine=txtline;
 }
 
-void epi_clrTxt4masterStateLine()
-{
+void epi_clrTxt4masterStateLine() {
     txt4masterStateLine.clear();
 }
 
-
-
 //---------------------------------------------------------------------------------------------
 
 // III   Slave receive (from Master) OK? if then show results, if not then show errors
@@ -214,13 +167,11 @@ void epi_clrTxt4masterStateLine()
 
 static QString txt4resultStateLine;
 
-QString epi_getTxt4resultStateLine(void)
-{
+QString epi_getTxt4resultStateLine(void) {
     return txt4resultStateLine;
 }
 
-void gpi_setTxt4resultStateLine(QString txtline)
-{
+void gpi_setTxt4resultStateLine(QString txtline) {
     txt4resultStateLine.clear();
     if (txtline=="")
         txt4resultStateLine.clear();
@@ -228,26 +179,22 @@ void gpi_setTxt4resultStateLine(QString txtline)
         txt4resultStateLine=txtline;
 }
 
-void epi_clrTxt4resultStateLine()
-{
+void epi_clrTxt4resultStateLine() {
     txt4resultStateLine.clear();
 }
 
-
 //---------------------------------------------------------------------------------------------
 
 // IV  Statuszeile Empfangsdaten
 static QString txt4dataLine;
 
-QString epi_getTxt4dataStateLine(void)
-{
+QString epi_getTxt4dataStateLine(void) {
     // GUI: get Text for serial Comport-State Line
     return txt4dataLine;
 
 }
 
-void gpi_setTxt4dataStateLine(QString txtline)
-{
+void gpi_setTxt4dataStateLine(QString txtline) {
     // serial: write Text to be displayed in serial Comport-State line (like "connected")
     txt4dataLine.clear();
     if (txtline=="")
@@ -256,8 +203,7 @@ void gpi_setTxt4dataStateLine(QString txtline)
         txt4dataLine=txtline;
 }
 
-void epi_clrTxt4dataStateLine()
-{
+void epi_clrTxt4dataStateLine() {
     txt4dataLine.clear();
 }
 
@@ -267,16 +213,11 @@ void epi_clrTxt4dataStateLine()
 
 static QString txt4datifReceive;
 
-QString epi_getTxt4datifLine(void)
-{
-
+QString epi_getTxt4datifLine(void) {
     return txt4datifReceive;
-
 }
 
-void gpi_setTxt4datifLine(QString txtline)
-{
-
+void gpi_setTxt4datifLine(QString txtline) {
     txt4datifReceive.clear();
     if (txtline=="")
         txt4datifReceive.clear();
@@ -284,8 +225,7 @@ void gpi_setTxt4datifLine(QString txtline)
         txt4datifReceive=txtline;
 }
 
-void epi_clrTxt4datifLine()
-{
+void epi_clrTxt4datifLine() {
     txt4datifReceive.clear();
 }
 
@@ -294,14 +234,11 @@ void epi_clrTxt4datifLine()
 
 static QString txt4diagWindow;
 
-QString epi_getTxt4RsDiagWin(void)
-{
+QString epi_getTxt4RsDiagWin(void) {
     return txt4diagWindow;
-
 }
 
-void gpi_setTxt4RsDiagWin(QString txtline)
-{
+void gpi_setTxt4RsDiagWin(QString txtline) {
     txt4diagWindow.clear();
     if (txtline=="")
         txt4diagWindow.clear();
@@ -309,8 +246,7 @@ void gpi_setTxt4RsDiagWin(QString txtline)
         txt4diagWindow=txtline;
 }
 
-void epi_clrTxt4RsDiagWin()
-{
+void epi_clrTxt4RsDiagWin() {
     txt4diagWindow.clear();
 }
 
@@ -318,14 +254,11 @@ void epi_clrTxt4RsDiagWin()
 
 static QString sndTxt4diagWindow;
 
-QString epi_get2ndTxt4RsDiagWin(void)
-{
+QString epi_get2ndTxt4RsDiagWin(void) {
     return sndTxt4diagWindow;
-
 }
 
-void gpi_set2ndTxt4RsDiagWin(QString txtline)
-{
+void gpi_set2ndTxt4RsDiagWin(QString txtline) {
     sndTxt4diagWindow.clear();
     if (txtline=="")
         sndTxt4diagWindow.clear();
@@ -333,90 +266,61 @@ void gpi_set2ndTxt4RsDiagWin(QString txtline)
         sndTxt4diagWindow=txtline;
 }
 
-void epi_clr2ndTxt4RsDiagWin()
-{
+void epi_clr2ndTxt4RsDiagWin() {
     sndTxt4diagWindow.clear();
 }
 
 // ///////////////////////////////////////////////////////////////////////////////////
 //          Memory for Slave responses, common data
 // ///////////////////////////////////////////////////////////////////////////////////
-
-
-static bool Sdata_serialTestResult;
-
-void gpi_storeResult_serialTestOK(bool wasOk)
-{
-    Sdata_serialTestResult=wasOk;
+void gpi_storeResult_serialTestOK(bool wasOk) {
+    SharedMemBuffer::getData()->Sdata.serialTestResult = wasOk;
 }
 
-bool epi_getResult_serialTestOK()
-{
+bool epi_getResult_serialTestOK() {
     // retval: true: test was successful, got right response
-    return Sdata_serialTestResult;
+    return SharedMemBuffer::getDataConst()->Sdata.serialTestResult;
 }
 
-
-
 // ///////////////////////////////////////////////////////////////////////////////////
 //          Store received data for hwapi
 // ///////////////////////////////////////////////////////////////////////////////////
-
-
-
-static uint8_t Sdata_pProtResultOk;
-
-void gpi_startNewRequest()
-{
-    Sdata_pProtResultOk=0;
+void gpi_startNewRequest() {
+    SharedMemBuffer::getData()->Sdata.pProtResultOk = 0;
 }
 
-void gpi_storeResultOfLastRequest(bool answisok)
-{
-    if (answisok)
-        Sdata_pProtResultOk=1;
-    else
-        Sdata_pProtResultOk=2;
+void gpi_storeResultOfLastRequest(bool answisok) {
+    SharedMemBuffer::getData()->Sdata.pProtResultOk = answisok ? 1 : 2;
 }
 
-uint8_t epi_getResultOfLastRequest()
-{
+uint8_t epi_getResultOfLastRequest() {
     // retval: 0: in progress  1: OK  2: error
-    return Sdata_pProtResultOk;
+    return SharedMemBuffer::getDataConst()->Sdata.pProtResultOk;
 }
 
-
-
-
-static uint16_t Sdata_receivedDataLength;
-static uint8_t Sdata_receivedDataBlock[64];
-
-void gpi_storeRecPayLoad(uint8_t RdDlen, uint8_t *receivedData)
-{
-    Sdata_receivedDataLength=uint16_t(RdDlen);
-    if (Sdata_receivedDataLength>64)
-        Sdata_receivedDataLength=64;
-    tslib_strclr(Sdata_receivedDataBlock,0,64);
-    tslib_strcpy(receivedData, Sdata_receivedDataBlock, Sdata_receivedDataLength);
-
+void gpi_storeRecPayLoad(uint8_t RdDlen, uint8_t const *receivedData) {
+    SharedMemBuffer::getData()->Sdata.receivedDataLength
+        = std::min(RdDlen, (uint8_t)(64));
+    memset((char *)(&SharedMemBuffer::getData()->Sdata.receivedDataBlock[0]),
+           0x00, sizeof(SharedMemBuffer::getData()->Sdata.receivedDataBlock));
+    strncpy((char *)(&SharedMemBuffer::getData()->Sdata.receivedDataBlock[0]),
+            (char const *)receivedData,
+            sizeof(SharedMemBuffer::getData()->Sdata.receivedDataBlock)-1);
 }
 
-uint16_t epi_getLastPayLoad(uint16_t plBufSiz, uint8_t *payLoad)
-{
+uint16_t epi_getLastPayLoad(uint16_t plBufSiz, uint8_t *payLoad) {
     // get data back in *pl, max 64 byte
     // retval = nr of bytes received. If host buffer too small then
     // only plBufSíz bytes are copied to pl
     // plBufSíz=size of host buffer
 
-    uint16_t ml=plBufSiz;
-    if (ml>64) ml=64;
-    if (Sdata_receivedDataLength<ml)
-        ml=Sdata_receivedDataLength;
-    tslib_strcpy(Sdata_receivedDataBlock, payLoad, ml);
-    return Sdata_receivedDataLength;
+    uint16_t ml = std::min(plBufSiz, (uint16_t)(64));
+    if (SharedMemBuffer::getDataConst()->Sdata.receivedDataLength < ml) {
+        ml = SharedMemBuffer::getDataConst()->Sdata.receivedDataLength;
+    }
+    strncpy((char *)payLoad,
+            (char const *)(&SharedMemBuffer::getData()->Sdata.receivedDataBlock[0]),
+            ml);
+
+    return SharedMemBuffer::getDataConst()->Sdata.receivedDataLength;
 }
-
-
-
-
-

src/datIf.cpp

@@ -17,6 +17,8 @@ static uint16_t datif_OutCmdpara5;
 static uint32_t datif_OutCmdpara6;
 static uint8_t cycl_running;
 
+//static bool     datif_DCdataValid;
+
 T_datif::T_datif(QWidget *parent) : QMainWindow(parent)
 {
 
@@ -46,6 +48,9 @@ T_datif::T_datif(QWidget *parent) : QMainWindow(parent)
     dif_scanStep=0;
     selectedSlaveAddr=FIX_SLAVE_ADDR;
     cycl_running=0;
+    //datif_DCdataValid=0;
+    gpi_storeDcDataValid(0);
+    datif_noResponseCtr=0;
 }
 
 void T_datif::resetChain(void)
@@ -61,6 +66,15 @@ char T_datif::datif_cycleSend()
     uint8_t  dataSendBuf[160], dataBufLen, dbl, who;
     static uint8_t BlockCounter;
 
+    uint8_t nextWrCmd, nextRdCmd, blockNum, dat1, dat2, dat3, dat4;
+    uint8_t length, data[66];
+    bool b_ret;
+
+    datif_noResponseCtr++;         // inc every 10ms    fehlt noch in SysCont
+    if (datif_noResponseCtr>500)    // seit 5s kein Lebenszeichen von DC2
+        gpi_storeDcDataValid(0);    // fehlt in SysCont
+
+
     if (cycl_running)
     {
         // request is still running, wait for response before next sending
@@ -77,6 +91,43 @@ char T_datif::datif_cycleSend()
         if (myDCIF->isSerialFree())
         #endif
         {
+            // new, from 11.4.23: direkt access to fastDevice Interface
+                // always use this three functions to send data:
+                //void myDCIF->setUserWriteData(uint16_t WriteCmd, uint16_t WrAddr, uint8_t  WrDatLen, uint8_t *data);
+                //void myDCIF->setUserWriteData(uint16_t WriteCmd, uint16_t WrAddr);
+                //void myDCIF->setUserWriteData(uint16_t WriteCmd);
+                //void myDCIF->setUserWrite1DB (uint16_t WriteCmd, uint16_t WrAddr, uint8_t val);
+                //void myDCIF->setUserWrite2DB (uint16_t WriteCmd, uint16_t WrAddr, uint8_t val0, uint8_t val1);
+
+                //void myDCIF->setUserReadData( uint16_t ReadCmd,  uint16_t RdAddr, uint16_t reserv);
+                //void myDCIF->setUserReadData( uint16_t ReadCmd,  uint16_t RdAddr);
+                //void myDCIF->setUserReadData( uint16_t ReadCmd);
+
+                //void myDCIF->sendUserData(uint16_t slaveAdr);
+
+            if (check4FDshortCmd())
+            {
+                b_ret=sendFDcmd_get(&nextWrCmd, &nextRdCmd, &blockNum, &dat1, &dat2, &dat3, &dat4);
+                if (b_ret)
+                {
+                    data[0]=dat1; data[1]=dat2; data[2]=dat3; data[3]=dat4; data[4]=0;
+                    myDCIF->setUserWriteData(nextWrCmd, blockNum, 4, data);
+                    myDCIF->setUserReadData(nextRdCmd);
+                    myDCIF->sendUserData(selectedSlaveAddr);
+                }
+            }
+
+            if (check4FDlongCmd())
+            {
+                b_ret=longFDcmd_get(&nextWrCmd, &nextRdCmd, &blockNum, &length, data);
+                if (b_ret)
+                {
+                    myDCIF->setUserWriteData(nextWrCmd, blockNum, length, data);
+                    myDCIF->setUserReadData(nextRdCmd);
+                    myDCIF->sendUserData(selectedSlaveAddr);
+                }
+            }
+
             // direct commands have highest prio (setting OUTPUTS)
             nxtAsCmd=sendWRcmd_getSendCommand0();       // command was stored by Gui
             if (nxtAsCmd>0)
@@ -169,7 +220,10 @@ char T_datif::datif_cycleSend()
                 sendINrequestsAutomatic();  // sendCyclicCmd();       // request all cyclic data sequential
             }
             else
+            {
                 dif_scanStep=0;         // always start from beginning
+                gpi_storeDcDataValid(0);    // fehlt in SysCont
+            }
         }
         #ifdef USEHANDSHAKES
         else
@@ -180,6 +234,7 @@ char T_datif::datif_cycleSend()
     } else
     {
         //qDebug()  << "com port not available";    // wird ununterbrochen ausgegeben
+        gpi_storeDcDataValid(0);    // fehlt in SysCont
     }
 
     return 0;
@@ -624,62 +679,71 @@ char T_datif::sendINrequestsAutomatic(void)
 {
     //qDebug() << "send IN request " << dif_scanStep;
 
+// one time: 105, 11,12,101,18
+// cyclic:  22,23,24,27,   102,103,104,106,107,108,109,
+
+// fehlen: 112, 113,14,17, 19,  30,31,32,33,
+//          38 on request
+
     switch (dif_scanStep)
     {
         // first 5 items are performed only one time after startup as this data never change
 
         case 0:
-            datif_sendIOrequest(0, CMD2DC_GetSerialConfig, 0);
+            datif_sendIOrequest(0, CMD2DC_GetSerialConfig, 0);      // 105
             break;
 
         case 1:
-            datif_sendIOrequest(0, CMD2DC_RdBkHWversion, 0);
+            datif_sendIOrequest(0, CMD2DC_RdBkHWversion, 0);        // 11
             break;
 
         case 2:
-            datif_sendIOrequest(0, CMD2DC_RdBkSWversion, 0);
+            datif_sendIOrequest(0, CMD2DC_RdBkSWversion, 0);        // 12
             break;
 
         case 3:
-            datif_sendIOrequest(0, CMD2DC_RdBkDCstate, 0);
+            datif_sendIOrequest(0, CMD2DC_RdBkDCstate, 0);          // 101
             break;
 
         case 4:
-            datif_sendIOrequest(0, CMD2DC_RdBkUID, 0);
+            datif_sendIOrequest(0, CMD2DC_RdBkUID, 0);              // 18
             break;
 
         // repeat cyclic from here:
         case 5:
-            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);         // 102
             break;
 
         case 6:
-            datif_sendIOrequest(0, CMD2DC_RdBkTime, 0);
+            datif_sendIOrequest(0, CMD2DC_RdBkTime, 0);             // 104
             break;
 
         case 7:
-            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            //datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            datif_sendIOrequest(0, 112, 0);
             break;
 
         case 8:
-            datif_sendIOrequest(0, CMD2DC_RdBkAnalog, 0);
+            datif_sendIOrequest(0, CMD2DC_RdBkAnalog, 0);           // 106
             break;
 
         case 9:
-            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            //datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            datif_sendIOrequest(0, 113, 0);
             break;
 
         case 10:
-            datif_sendIOrequest(0, CMD2DC_RdBkAllOutputs, 0);
+            datif_sendIOrequest(0, CMD2DC_RdBkAllOutputs, 0);       // 103
             break;
 
         case 11:
-            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            //datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            datif_sendIOrequest(0, 14, 0);
             break;
 
         case 12:
             if (indat_isPrinterOn())
-                datif_sendIOrequest(0, CMD2DC_RdBk_AllPrnData, 0);            
+                datif_sendIOrequest(0, CMD2DC_RdBk_AllPrnData, 0);      // 27
             //  datif_sendIOrequest(0, CMD2DC_RdBk_PrnState, 0);
             break;
 
@@ -690,20 +754,21 @@ char T_datif::sendINrequestsAutomatic(void)
         case 14:
             if (indat_isMifareOn())
             {
-                datif_sendIOrequest(0, CMD2DC_RdBk_MifState, 0);
+                datif_sendIOrequest(0, CMD2DC_RdBk_MifState, 0);    // 109
                 //qDebug()<<"requesting MIF reader state";
             }
             break;
 
         case 15:
-            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            //datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            datif_sendIOrequest(0, 17, 0);
             break;
 
         case 16:
             if (indat_isMifareOn())
             {
                 datif_OutCmdpara1=0;    // data block number 0 contains the Mifare-ID
-                datif_sendIOrequest(0, CMD2DC_RdBk_MifData, 1);
+                datif_sendIOrequest(0, CMD2DC_RdBk_MifData, 1);         // 24
                 // qDebug()<<"automatically requesting mif card data";
                 if (++RDBLKNR>11)
                     RDBLKNR=0;
@@ -712,23 +777,24 @@ char T_datif::sendINrequestsAutomatic(void)
             } break;
 
         case 17:
-            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            //datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            datif_sendIOrequest(0, 19, 0);
             break;
 
         case 18:
             if (indat_isMdbOn())
-                datif_sendIOrequest(0, CMD2DC_MDB_GET_STATE, 0);
+                datif_sendIOrequest(0, CMD2DC_MDB_GET_STATE, 0);        // 107
             //else
             //    dif_scanStep=24;  unsinn
             break;
 
         case 19:
-            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            datif_sendIOrequest(0, 30, 0);
             break;
 
         case 20:
             //if (indat_isMdbOn())
-                datif_sendIOrequest(0, CMD2DC_MDB_GETRESP, 0);
+                datif_sendIOrequest(0, CMD2DC_MDB_GETRESP, 0);          // 22
 
             break;
 
@@ -738,23 +804,32 @@ char T_datif::sendINrequestsAutomatic(void)
 
         case 22:
             //if (indat_isMdbOn())    // kein eigener Schalter für EMP
-                datif_sendIOrequest(0, CMD2DC_EMP_GET_ALL, 0);
+                datif_sendIOrequest(0, CMD2DC_EMP_GET_ALL, 0);          // 23
             break;
 
         case 23:
-            datif_sendIOrequest(0, CMD2DC_GetAllInputs, 0);
+            datif_sendIOrequest(0, 31, 0);
             break;
 
         case 24:
             //if (indat_isMdbOn())    // kein eigener Schalter für EMP
-                datif_sendIOrequest(0, CMD2DC_EMP_GOTCOIN, 0);
+                datif_sendIOrequest(0, CMD2DC_EMP_GOTCOIN, 0);          // 108
             break;
 
+        case 25:
+            datif_sendIOrequest(0, 32, 0);
+            break;
+
+        case 26:
+            datif_sendIOrequest(0, 33, 0);
+            break;
+
+
     }
 
     dif_scanStep++;
-    if (dif_scanStep>=25)
-        dif_scanStep=0;     //dif_scanStep=5;
+    if (dif_scanStep>26)
+        dif_scanStep=5;
 
 return 0;
 
@@ -777,6 +852,7 @@ char T_datif::isPortOpen(void)
 
 void T_datif::StoredRecData()
 {
+    datif_noResponseCtr=0;
     //qDebug() << "StoreRecData called";
     // call automatically by T_prot
     //if (myDCIF->ifDataReceived())
@@ -792,28 +868,39 @@ void T_datif::StoredRecData()
 char T_datif::loadRecDataFromFrame()
 {
     // necessary data in T_prot:
-    uint16_t readSource, uitmp;
+    uint16_t readSource, uitmp,uit2;
     uint16_t readAddress;
     //uint8_t  pp;
     uint8_t  SlaveAdr, RdDleng;
     uint8_t  receivedData[FRAME_DATALEN];
     QString  localStr;
-    //uint32_t ultmp;
+    uint32_t ultmp;
     //int portNr;
     bool ret;
     uint8_t uctmp;      // maxai
+    char ctmp;
+    static uint8_t lastResult;
+    uint8_t prnResult;
+    static uint32_t lastInsertedAmount;
+    uint32_t newInsertedAmount;
 
     ret=myDCIF->getReceivedInData(&SlaveAdr, &readSource, &readAddress,  &RdDleng, receivedData);
         // retval: data valid, only one time true, true if CommandState OK and readState OK
     gpi_storeResultOfLastRequest(ret);
+
+
+    qCritical() << "loadRecDataFromFrame() readSource = " << readSource;
+
     if (ret==false)
     {
-     //   qDebug() << "datif: rec data not valid";
+        qCritical() << "datif: rec data not valid";
         return 0;
     }
 
     gpi_storeRecPayLoad(RdDleng, receivedData); //  save for host (user of hwapi)
 
+
+    qCritical() << "loadRecDataFromFrame() readSource = " << readSource;
     //qDebug() << "\n datif: got valid data, rdsrc:" << readSource << "  rdadd:" << readAddress
      //        << "  rdlen:" << RdDleng;
 //    qDebug("datif_recData: %d %d %d %d %d %d %d %d %d %d %d %d %d %d %d %d ",
@@ -837,17 +924,18 @@ char T_datif::loadRecDataFromFrame()
 //    receivedData[1]='B';
 //    receivedData[2]='1';
 //    receivedData[3]='-';
-//    for (int ii=0; ii<4; ii++)            haut hin   :)
+
 
     for (int ii=0; ii<RdDleng; ii++)
     {
-        localStr.append(receivedData[ii]);
+        ctmp=receivedData[ii];
+        localStr.append(ctmp);
     }
 
     //qDebug() << "got HW version: " << localStr;
     switch (readSource) // = request command
     {
-        case CMD2DC_TestSerial:    // serial line check
+        case CMD2DC_TestSerial:    // serial line check         10
             ret=verifyLineTestresponse(RdDleng, receivedData);
             gpi_storeResult_serialTestOK(ret);
             if (ret==true)
@@ -856,41 +944,41 @@ char T_datif::loadRecDataFromFrame()
                 gpi_setTxt4datifLine("false");
             break;
 
-        case CMD2DC_GetSerialConfig: // get slave's RS232 config
+        case CMD2DC_GetSerialConfig: // get slave's RS232 config        105
             gpi_storeSlaveSerParams(receivedData[0], receivedData[1], receivedData[2], receivedData[3]);
             //gpi_storeSlaveBusAddr(SlaveAdr);
             break;
 
-        case CMD2DC_RdBkHWversion:
+        case CMD2DC_RdBkHWversion:                          //11
             //qDebug() << "got HW version: " << localStr;
             gpi_storeGenerals(0, localStr);
                 // 0=HW   1=SW  2=State
             //gpi_storeSlaveBusAddr(SlaveAdr);
             break;
 
-        case CMD2DC_RdBkSWversion:
+        case CMD2DC_RdBkSWversion:                          //12
             //qDebug() << "got SW version: " << localStr;
             gpi_storeGenerals(1, localStr);
             break;
 
-        case CMD2DC_RdBkDCstate:
+        case CMD2DC_RdBkDCstate:                            //101
             //qDebug() << "got DC state " << localStr;
-            localStr[8]=0;
+            //localStr[8]=0;
             gpi_storeGenerals(2, localStr);
                 // 0=HW   1=SW  2=State
             break;
 
-        case CMD2DC_RdBkUID: // getback UID in DB0....7
+        case CMD2DC_RdBkUID: // getback UID in DB0....7     18
             gpi_storeUID(receivedData);
             break;
 
-        case CMD2DC_RdBkTime: // slave returned RTC time and date
+        case CMD2DC_RdBkTime: // slave returned RTC time and date       104
             // new, FastProt: 0=dayOfWeek 1=min 2=sec 3=hours 4=year 5=month 6=dayOfYear
             gpi_backupTime(receivedData, RdDleng);   // function reads 20 bytes from the buffer
 
             break;
 
-        case CMD2DC_RdBkAnalog: // get ALL AIs 0...3, 4byte + 2byte each
+        case CMD2DC_RdBkAnalog: // get ALL AIs 0...3, 4byte + 2byte each        106
 
         //            DB0,1: Value0=Temperature
         //            DB2,3: Value1=Voltage
@@ -906,7 +994,7 @@ char T_datif::loadRecDataFromFrame()
             gpi_storeAIs(1, uitmp);
             break;
 
-        case CMD2DC_GetAllInputs:
+        case CMD2DC_GetAllInputs:           //102
         /*
     // alle DI's in einen 8byte Puffer zusammenstellen, werden in einen Rutsch zum Master gesendet
 
@@ -990,7 +1078,7 @@ char T_datif::loadRecDataFromFrame()
              gpi_storeDI_paperLow(receivedData[5]);
             break;
 
-        case CMD2DC_RdBkAllOutputs:
+        case CMD2DC_RdBkAllOutputs:     //103
 
             /*
 // alle DO's in einen 8byte Puffer zusammenstellen, werden in einen Rutsch zum Master gesendet
@@ -1048,27 +1136,29 @@ char T_datif::loadRecDataFromFrame()
             break;
 
 
-    case CMD2DC_RdBk_MifState:
+    case CMD2DC_RdBk_MifState:          //109
         // get reader status and card type
 
-        gpi_storeMifReaderStateAndCardType(receivedData);
+        //gpi_storeMifReaderStateAndCardType(receivedData);
+        gpi_storeNewMifareCard(receivedData[0], &receivedData[1]);
+
         break;
 
-    case CMD2DC_RdBk_MifData:
+    case CMD2DC_RdBk_MifData:           //24
         // one block of data (64byte) comes in
         // blkNr 0...11 in "Addr"
         gpi_storeMifCardData(readAddress, receivedData);
 //qDebug()<<"datif storing mif data: (adr/data) "<<readAddress<<receivedData;
         break;
 
-    case CMD2DC_RdBk_AtbCardType:
+    case CMD2DC_RdBk_AtbCardType:       //25
         // DC reports the type of mif-card (valid ATB card?)
 
         break;
 
 
 
-    case CMD2DC_RdBk_PrnState:      // 0x2A02
+    case CMD2DC_RdBk_PrnState:      // 110
 
         // byte 1...6 come right from printer, see printer manual
         // byte 0 = all important infos:
@@ -1080,7 +1170,7 @@ char T_datif::loadRecDataFromFrame()
         gpi_storePrinterState(receivedData);    // derzeit 10bytes      ( 0x2A02)
         break;
 
-    case CMD2DC_RdBk_PrnFonts:      //  0x2A12
+    case CMD2DC_RdBk_PrnFonts:      //  26
         //D0: font table/type
         //D1: size
         //D2: height
@@ -1094,7 +1184,7 @@ char T_datif::loadRecDataFromFrame()
         gpi_storePrinterFonts(receivedData);    // derzeit 10bytes
         break;
 
-    case CMD2DC_RdBk_AllPrnData:      // 0x2A40
+    case CMD2DC_RdBk_AllPrnData:      // 27
         gpi_storePrinterState(receivedData);    // derzeit 10bytes      ( 0x2A02)
         gpi_storePrinterFonts(&receivedData[10]);    // derzeit 10bytes
         /*
@@ -1107,7 +1197,7 @@ char T_datif::loadRecDataFromFrame()
         */
         break;
 
-    case CMD2DC_MDB_GET_STATE:
+    case CMD2DC_MDB_GET_STATE:      //107
         // DB0: mdb_bus_ready (switched on)
         // DB1: rdBackV12devicePower
         // DB2: rdBackV5busPwr
@@ -1116,7 +1206,7 @@ char T_datif::loadRecDataFromFrame()
         gpi_storeMdbState(receivedData[0],receivedData[1],receivedData[2]);
         break;
 
-    case CMD2DC_MDB_GETRESP:
+    case CMD2DC_MDB_GETRESP:        //22
         // last received mdb answer (from mdb device)
         // only needed if a special command was sent directly
         // DB0: mdb Device-Nr
@@ -1127,31 +1217,414 @@ char T_datif::loadRecDataFromFrame()
         gpi_storeMdbResponse(receivedData[2]+3, receivedData);
         break;
 
-    case CMD2DC_EMP_GET_ALL:
-        //qDebug() << "got emp parameters "<< receivedData[1];
+    case CMD2DC_EMP_GET_ALL:        //23
+        qCritical() << "got emp parameters "<< receivedData[1];
         gpi_storeEmpSettings(64, receivedData);
         break;
 
-    case CMD2DC_EMP_GOTCOIN:
+    case CMD2DC_EMP_GOTCOIN:        //108
         // DB0: 1=coin 0xFF=error 0=got nothing
         // DB1: last coin signal (value / scale)
         // DB2,3: last coin value
         // DB4: lastError from Emp
+
+        // 0: nr of stored coins
+        // 1: got  2:type  3:err  4=valL  5=valH
+
+//        qDebug() << "got emp coin "<< " " << receivedData[0] <<" " << receivedData[1]
+//                 << " " << receivedData[2]<< " " << receivedData[3]
+//                 << " " << receivedData[4]<< " " << receivedData[5]
+//                 << " " << receivedData[6]<< " " << receivedData[7];
+
         gpi_storeEmpCoinSignal(receivedData[0], &receivedData[1]);
         break;
 
-    case CMD2DC_RDBK_DEV_PARA:
-        gpi_storeDeviceSettings(RdDleng, receivedData);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+// ab hier neu:    12.4.23
+
+    case CMD2DC_RDBK_DEV_PARA:      //14
+/*
+            buf66[0]=devPara.kindOfPrinter;
+            buf66[1]=devPara.kindOfCoinChecker;
+            buf66[2]=devPara.kindOfMifareReader;
+            buf66[3]=devPara.suppressSleepMode;
+            buf66[4]=devPara.kindOfModem;
+            buf66[5]=devPara.kindOfCreditcard;
+            buf66[6]=devPara.CoinEscrow;
+            buf66[7]=devPara.CoinRejectUnit;
+            buf66[8]=devPara.CoinShutter;
+            buf66[9]=devPara.BillAcceptor;
+            buf66[10]=devPara.usevaultLock;
+            buf66[11]=devPara.autoAlarm;
+            buf66[12]=devPara.autoOpen;
+            buf66[13]=devPara.printAccReceipt;
+            buf66[14]=devPara.printDoorReceipt;
+            buf66[15]=devPara.printTokenTicket;
+            uitmp=devPara.VaultFullWarnLevel;
+            buf66[16]=swl_getOneByteFromUint(uitmp, GETLOWBYT);
+            buf66[17]=swl_getOneByteFromUint(uitmp, GETHIGHBYT);
+            uitmp=devPara.VaultFullErrorLevel;
+            buf66[18]=swl_getOneByteFromUint(uitmp, GETLOWBYT);
+            buf66[19]=swl_getOneByteFromUint(uitmp, GETHIGHBYT);
+
+*/
+        gpi_storeRbDeviceSettings(RdDleng, receivedData);
+
+
         break;
 
-    case CMD2DC_RDBK_MACH_ID:
+                    // get machine parameters and location
+    case CMD2DC_RDBK_MACH_ID:       //15
+    case 17:
+/*
+            buf66[0]=swl_getOneByteFromUint(machPara.customerNumber, GETLOWBYT);
+            buf66[1]=swl_getOneByteFromUint(machPara.customerNumber, GETHIGHBYT);
+            buf66[2]=swl_getOneByteFromUint(machPara.machineNumber, GETLOWBYT);
+            buf66[3]=swl_getOneByteFromUint(machPara.machineNumber, GETHIGHBYT);
+            buf66[4]=swl_getOneByteFromUint(machPara.borough, GETLOWBYT);
+            buf66[5]=swl_getOneByteFromUint(machPara.borough, GETHIGHBYT);
+            buf66[6]=swl_getOneByteFromUint(machPara.zone, GETLOWBYT);
+            buf66[7]=swl_getOneByteFromUint(machPara.zone, GETHIGHBYT);
+            buf66[8]=swl_getOneByteFromUint(machPara.alias, GETLOWBYT);
+            buf66[9]=swl_getOneByteFromUint(machPara.alias, GETHIGHBYT);
+            for (pp=0; pp<32; pp++)
+                buf66[10+pp]=machPara.location[pp];
+            dc2prot_setReadData(42, buf66);
+
+*/
         gpi_storeMachineIDsettings(RdDleng, receivedData);
         break;
+
+    case 19:        // get time and date and Extra values
+/*
+     buf[0]=GlobTime.Hours;
+    buf[1]=GlobTime.Min;
+    buf[2]=GlobTime.Sec;
+    buf[3]=GlobTime.Year;
+    buf[4]=GlobTime.Month;
+    buf[5]=GlobTime.Day;
+    buf[6]=GlobTime.DOW;
+    buf[7]=' ';                   // immer auf 32bit auffüllen sonst Speicherproblem beim Master!
+    uitmp=GlobTime.MinOfDay;
+    buf[8]=swl_getOneByteFromUint(uitmp, 0);
+    buf[9]=swl_getOneByteFromUint(uitmp, 1);
+    buf[10]=' ';
+    buf[11]=' ';
+    ultmp=GlobTime.SecOfDay;
+    buf[12]=swl_getOneByteFromUlong(ultmp, 0);
+    buf[13]=swl_getOneByteFromUlong(ultmp, 1);
+    buf[14]=swl_getOneByteFromUlong(ultmp, 2);
+    buf[15]=swl_getOneByteFromUlong(ultmp, 3);
+
+    buf[16]=swl_isLeap(GlobTime.Year);
+    buf[17]=swl_getNextLeapYear(GlobTime.Year);
+    buf[18]=swl_getLastLeapYear(GlobTime.Year);
+    buf[19]=swl_hoursOfThisWeek(GlobTime.DOW, GlobTime.Hours);
+
+    uitmp=swl_minutesOfThisWeek(GlobTime.DOW, GlobTime.Hours, GlobTime.Min);
+    buf[20]=swl_getOneByteFromUint(uitmp, 0);    // 0=low byte   1=high byte
+    buf[21]=swl_getOneByteFromUint(uitmp, 1);
+
+    uitmp=swl_hoursOfThisMonth(GlobTime.Day, GlobTime.Hours);
+    buf[22]=swl_getOneByteFromUint(uitmp, 0);
+    buf[23]=swl_getOneByteFromUint(uitmp, 1);
+
+    uitmp=swl_minutesOfThisMonth(GlobTime.Day, GlobTime.Hours, GlobTime.Min);
+    buf[24]=swl_getOneByteFromUint(uitmp, 0);
+    buf[25]=swl_getOneByteFromUint(uitmp, 1);
+
+    uitmp=swl_GetDaysOfYear(GlobTime.Year, GlobTime.Month, GlobTime.Day);
+    buf[26]=swl_getOneByteFromUint(uitmp, 0);
+    buf[27]=swl_getOneByteFromUint(uitmp, 1);
+
+    uitmp=swl_GetHoursOfYear(GlobTime.Year, GlobTime.Month, GlobTime.Day, GlobTime.Hours);
+    buf[28]=swl_getOneByteFromUint(uitmp, 0);
+    buf[29]=swl_getOneByteFromUint(uitmp, 1);
+    buf[30]=0;
+    buf[31]=0;
+    ultmp= swl_GetMinutesOfYear(GlobTime.Year, GlobTime.Month, GlobTime.Day,
+                                GlobTime.Hours, GlobTime.Min);
+    buf[32]=swl_getOneByteFromUlong(ultmp, 0);
+    buf[33]=swl_getOneByteFromUlong(ultmp, 1);
+    buf[34]=swl_getOneByteFromUlong(ultmp, 2);
+    buf[35]=swl_getOneByteFromUlong(ultmp, 3);
+
+    buf[36]=rtc_getSqwaveSettings();
+    buf[37]=0;
+    buf[38]=0;
+    buf[39]=0;
+
+    ultmp= 0;       // Minutes of the Millenium
+    buf[40]=swl_getOneByteFromUlong(ultmp, 0);
+    buf[41]=swl_getOneByteFromUlong(ultmp, 1);
+    buf[42]=swl_getOneByteFromUlong(ultmp, 2);
+    buf[43]=swl_getOneByteFromUlong(ultmp, 3);
+
+    dc2prot_setReadData(44, buf);
+
+ */
+        // speicher-fkt fehlt noch, gpi_backupTime ist nur kurz
+        gpi_storeExtendedTime(RdDleng, receivedData);
+
+        break;
+
+    case 111:       // get square wafe settings
+        gpi_backupSquareMode(receivedData[0]);
+        break;
+
+    case 112:       // get inserted amount in cent in sum
+        // byte 0..3: amount just paid   4,5:last coin type  6,7: last coin value
+        newInsertedAmount=uchar2ulong(receivedData[3],receivedData[2],receivedData[1],receivedData[0]);
+        uitmp=uchar2uint(receivedData[5],receivedData[4]);
+        uit2=uchar2uint(receivedData[7],receivedData[6]);
+        if (uitmp>0) // nur 1x bei neuer Münze
+        {
+            gpi_storeCurrentPayment(newInsertedAmount, uitmp, uit2);
+            //void gpi_storeCurrentPayment(uint32_t insertedAmount, uint16_t lastCoinType, uint16_t lastCoinValue)
+            if (newInsertedAmount != lastInsertedAmount)
+            {
+                emit datif_gotNewCoin();
+//qDebug()<<"emit new coin";
+
+                lastInsertedAmount=newInsertedAmount;
+            }
+qDebug()<<"   store new coin"<<newInsertedAmount<<" "<<uitmp<<" "<<uit2;
+        }
+
+        break;
+
+    case 113:       // get wake source, 8byte
+        gpi_storeWakeSources(receivedData);
+        break;
+
+    case 30:        // Get Devices Condition (warnings, errors)
+    /*
+
+    outBuf[0]=modCond.ram;
+    outBuf[1]=modCond.intEe;
+    outBuf[2]=modCond.extEe;
+    outBuf[3]=modCond.rtc;
+    outBuf[4]=modCond.boardHw;
+    outBuf[5]=modCond.printer;
+    outBuf[6]=modCond.modem;
+    outBuf[7]=modCond.signal;
+    outBuf[8]=modCond.regist;
+    outBuf[9]=modCond.mdbBus;
+    outBuf[10]=modCond.coinChecker;
+    outBuf[11]=modCond.coinEscrow;
+    outBuf[12]=modCond.mifareReader;
+    outBuf[13]=modCond.creditTerm;
+    outBuf[14]=modCond.coinReject;
+    outBuf[15]=modCond.coinSafe;
+    outBuf[16]=modCond.billSafe;
+    outBuf[17]=modCond.voltage;
+    outBuf[18]=modCond.temper;
+    outBuf[19]=modCond.poweronTest;
+    outBuf[20]=modCond.doorState;
+    outBuf[21]=modCond.doorWasOpened;
+    outBuf[22]=modCond.changer;
+    outBuf[23]=modCond.coinBlocker;
+    outBuf[24]=modCond.billReader;
+    outBuf[25]=modCond.ResetReason;
+    outBuf[26]=modCond.allModulesChecked;
+    outBuf[27]=modCond.alarmState;
+    outBuf[28]=0;
+    outBuf[29]=0;
+
+     */
+        gpi_storeDeviceConditions(RdDleng, receivedData);
+
+        break;
+
+    case 31:        // Get dynamic machine conditions (doors, voltage, alarm….)
+/*
+
+    outBuf[pBuf++]=dynCond.allDoorsDebounced;
+    outBuf[pBuf++]=dynCond.openedAuthorized;
+    outBuf[pBuf++]=dynCond.CBinDebounced;
+    outBuf[pBuf++]=dynCond.upperDoor;
+
+    outBuf[pBuf++]=dynCond.middleDoor;
+    outBuf[pBuf++]=dynCond.lowerDoor;
+    outBuf[pBuf++]=dynCond.coinBox;
+    outBuf[pBuf++]=dynCond.billBox;
+
+    outBuf[pBuf++]=dynCond.modeAbrech;
+    outBuf[pBuf++]=dynCond.onAlarm;
+    outBuf[pBuf++]=dynCond.nowCardTest;
+    outBuf[pBuf++]=dynCond.nowPayment;
+
+    outBuf[pBuf++]=dynCond.lastMifCardType;
+    outBuf[pBuf++]=dynCond.lastSDoorState;
+    outBuf[pBuf++]=dynCond.lastVDoorState;
+    outBuf[pBuf++]=dynCond.lastCBstate;
+
+    outBuf[pBuf++]=dynCond.paymentInProgress;
+    outBuf[pBuf++]=0;
+    uitmp=dynCond.U_Batt;
+    outBuf[pBuf++]=swl_getOneByteFromUint(uitmp, GETLOWBYT);
+    outBuf[pBuf++]=swl_getOneByteFromUint(uitmp, GETHIGHBYT);
+    uitmp=dynCond.Temperatur;
+    outBuf[pBuf++]=swl_getOneByteFromUint(uitmp, GETLOWBYT);
+    outBuf[pBuf++]=swl_getOneByteFromUint(uitmp, GETHIGHBYT);
+
+    uitmp=dynCond.nrCoinsInBox;	// send seperate also
+    outBuf[pBuf++]=swl_getOneByteFromUint(uitmp, GETLOWBYT);
+    outBuf[pBuf++]=swl_getOneByteFromUint(uitmp, GETHIGHBYT);
+
+    ultmp=dynCond.amountInBox;	// send seperate also
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETLOWESTBYT);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETLOWMID);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETHIGHMID);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETHIGHESTBYT);
+
+    ultmp=dynCond.totalTransVolume;
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETLOWESTBYT);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETLOWMID);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETHIGHMID);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETHIGHESTBYT);
+
+    ultmp=dynCond.totalNrOfVends;
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETLOWESTBYT);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETLOWMID);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETHIGHMID);
+    outBuf[pBuf++]=swl_getOneByteFromUlong(ultmp, GETHIGHESTBYT);
+// 36
+    outBuf[pBuf++]=dynCond.jsonValid_config;
+    outBuf[pBuf++]=dynCond.jsonValid_device;
+    outBuf[pBuf++]=dynCond.jsonValid_cash;
+    outBuf[pBuf++]=dynCond.jsonValid_print;
+    outBuf[pBuf++]=dynCond.jsonValid_serial;
+    outBuf[pBuf++]=dynCond.jsonValid_time;
+    outBuf[pBuf++]=dynCond.lastFileType;
+    outBuf[pBuf++]=0;
+
+*/
+
+        if (RdDleng>40)
+            //datif_DCdataValid=1;    // das hier sind die wichtigsten Daten, deshalb hierrein!
+            gpi_storeDcDataValid(1);
+
+        gpi_storeDynMachineConditions(RdDleng, receivedData);
+
+        prnResult=receivedData[52];
+        if (prnResult != lastResult)
+        {
+            // new result
+            if (prnResult==1)
+            {
+                emit datif_templatePrintFinished_OK();
+            } else
+            if (prnResult==2)
+            {
+                emit datif_templatePrintFinished_Err();
+            }
+
+            lastResult=prnResult;
+        }
+
+        break;
+
+    case 32:        // Get current cash level (in vault)
+                    // bytes 0..3: amount   bytes 4,5=Nr.ofCoins in vault
+        ultmp=uchar2ulong(receivedData[3],receivedData[2],receivedData[1],receivedData[0]);
+        uitmp=uchar2uint(receivedData[5],receivedData[4]);
+        gpi_storeCBlevel(ultmp, uitmp);
+        break;
+
+    case 33:        // Get all backuped acc. Numbers
+                    // 8 UINTs with acc-nr
+        gpi_storeDCbackupAccNr(RdDleng, receivedData);
+        break;
+
+    case 38:        // Get stored account record backup
+/*
+
+struct T_vaultRecord
+{
+    UCHAR startbuffer[4];		// Psa>  // never move or change this 1st entry
+    UINT AccountingNumber;
+    UINT CUNU;
+    UINT MANU;
+    UINT resint1;
+    //UINT resint2;
+
+    UCHAR label1buffer[4];	 // tim>
+    UCHAR year;
+    UCHAR month;
+    UCHAR dom;
+    UCHAR hour;
+    UCHAR min;
+    UCHAR sec;
+    UCHAR DoW;
+    UCHAR reschar3;
+
+    UCHAR label2buffer[4];	// abs>
+    ULONG AbsIncome1;
+    ULONG AbsReserve;
+    ULONG AbsNrOfCuts;
+
+//16
+    UCHAR label3buffer[4];	// mw >
+
+    // Verkauf, Tür zu:
+    ULONG VKcoinsInserted[16];		// nur für Wechsler, soviel wurde eingeworfen
+    ULONG VKcoinsReturned[6];		// nur für Wechsler, Anzahl Münzen pro Typ, soviel wurde zurückgegeben
+//88
+
+    // Service, Tür offen:
+    UINT ServCoinsInserted[16];		// nur für Wechsler, soviel wurde eingeworfen
+    UINT ServCoinsReturned[6];		// nur für Wechsler, Anzahl Münzen pro Typ, soviel wurde zurückgegeben
+    UINT resint3;
+    UINT resint4;
+    UINT currentTubeContent[6];		//  nur für Wechsler, aktueller Füllstand
+    UINT resint5;
+    UINT resint6;
+// 56
+
+    UCHAR label4buffer[4];	// box>
+    UINT coinsInVault[16];
+    UINT billsInStacker[8];
+// 48
+
+    UCHAR label5buffer[4];	// val>
+    // actually constant unless exchange rate is changed
+    UINT coinDenomination[16];	// 5..50000 (z.B. 2€ sind in Ungarn 760Ft)
+    UINT billDenom[8];
+    UINT tubeDenom[6];
+    UINT exchangeRate;
+    UINT resint9;
+
+// 64
+
+    UCHAR endofblock[4];	// end>
+// 316 byte Block im Speicher
+*/
+        // readAddress,  &RdDleng, receivedData
+        gpi_storeVaultRecord(readAddress, receivedData );   // always 64byte
+        break;
+
     }
+    readSource=0;   // 17.05.2023: to avoid multiple recording
 
     return 0;
 }
 
+// fehlen: 112, 113,14,17, 19,  30,31,32,33,
 
 // subs:
 
@@ -1246,11 +1719,15 @@ bool T_datif::verifyLineTestresponse(uint8_t RdDlen, uint8_t *receivedData)
     if (RdDlen < 16)
         return false;
     QString myStr;
+    char ctmp;
+
     myStr.clear();
     myStr.append("< Slave Response");
 
     for (int nn=0; nn<16; nn++)
-        if (myStr[nn] !=receivedData[nn])
+    {
+        ctmp=receivedData[nn];
+        if (myStr[nn] != ctmp)
         {
             //qDebug() << " datif cmd 10: got wrong string ";
             //qDebug() << myStr;
@@ -1258,6 +1735,7 @@ bool T_datif::verifyLineTestresponse(uint8_t RdDlen, uint8_t *receivedData)
             //qDebug() << nn;
             return false;
         }
+    }
     return true;
 }
 

src/hwChk.cpp

@@ -0,0 +1,25 @@
+
+#include <stdint.h>
+#include "hwChk.h"
+
+
+hwChk::hwChk(QWidget *parent) : QObject(parent)
+{
+
+//    myDCIF = new T_prot();
+// h: T_prot *myDCIF;
+
+    //myDatif = new T_datif();
+    HWaccess = new hwinf();
+
+    struct T_moduleCondition dcModCond;
+    sys_getDeviceConditions(dcModCond);
+
+
+}
+
+hwChk::~hwChk()
+{
+
+}
+

src/prot.cpp

@@ -433,7 +433,8 @@ uint8_t recBuffer[FRAME_MAXLEN];
 
     // read from "VCP":
     mySerialPort->readFromSerial(Indata, recLength);
-//qDebug()<<"prot: got data " << recLength;
+    qCritical()<<"prot: got data "  << recLength;
+    qCritical()<<"        Indata: " << Indata;
     if (recLength>FRAME_MAXLEN)
         recLength=FRAME_MAXLEN;
     for (int nn=0; nn<recLength; nn++)
@@ -443,6 +444,9 @@ uint8_t recBuffer[FRAME_MAXLEN];
     tempStr.clear();
     //uint8_t result=FramecheckInData(recBuffer, recLength);  // check input data (response from slave)
     uint8_t result=FastCheckInData(recBuffer, recLength);  // check input data (response from slave)
+
+    qCritical()<<"    FastCheckInData() result = " << result;
+
     if (result>0)
     {
         // dann anzeige

src/sendWRcmd.cpp

@@ -13,7 +13,8 @@ void sendWRcmd_INI(void)
 
     sendWRcmd_clrCmdStack();
     sendWRcmd_clrCmd4Stack();
-
+    sendFDcmd_clrStack();
+    longFDcmd_clrStack();
 }
 
 // Command Stack for commands without parameters
@@ -60,13 +61,19 @@ bool sendWRcmd_setSendCommand0(uint16_t nextCmd)
 uint16_t sendWRcmd_getSendCommand0(void)
 {
     uint16_t nxtAsynchCmd;
-    uint8_t nn;
+    uint8_t nn, ll;
     if (nrOfCmdsInQueue==0 || nrOfCmdsInQueue>CMDSTACKDEPTH)
         return 0;   // error
     nxtAsynchCmd=nextAsynchsendCmd0[0];
+
     // move Puffer down by one element
-    for (nn=0; nn<CMDSTACKDEPTH; nn++)
+    if (CMDSTACKDEPTH>0)
+        ll=CMDSTACKDEPTH-1;
+    else
+        ll=0;
+    for (nn=0; nn<ll; nn++)
         nextAsynchsendCmd0[nn]=nextAsynchsendCmd0[nn+1];
+
     if (nrOfCmdsInQueue>0)
         nrOfCmdsInQueue--;
     //qDebug() << "PI cmd queued:"<< nxtAsynchCmd << ", restored, pp now =" << nrOfCmdsInQueue;
@@ -138,7 +145,7 @@ bool sendWRcmd_setSendCommand4(uint16_t nextCmd, uint8_t dat1, uint8_t dat2, uin
 uint16_t sendWRcmd_getSendCommand4(uint8_t *dat1, uint8_t *dat2, uint8_t *dat3, uint8_t *dat4)
 {
     uint16_t nxtAsynchCmd;
-    uint8_t nn;
+    uint8_t nn, ll;
 
     if (nrOfCmds4InQueue==0 || nrOfCmds4InQueue>CMD4STACKDEPTH)
         return 0;   // error
@@ -152,7 +159,11 @@ uint16_t sendWRcmd_getSendCommand4(uint8_t *dat1, uint8_t *dat2, uint8_t *dat3,
     //            " data3: " << nextCmd4para3[0] << " data4: " << nextCmd4para4[0];
 
     // move Puffer down by one element
-    for (nn=0; nn<CMD4STACKDEPTH; nn++)
+        if (CMD4STACKDEPTH>0)
+        ll=CMD4STACKDEPTH-1;
+    else
+        ll=0;
+    for (nn=0; nn<ll; nn++)
     {
         nextAsynchsendCmd4[nn]=nextAsynchsendCmd4[nn+1];
         nextCmd4para1[nn]=nextCmd4para1[nn+1];
@@ -211,9 +222,9 @@ bool sendWRcmd_setSendCommand8(uint16_t nextCmd, uint8_t dat1, uint8_t dat2, uin
 uint16_t sendWRcmd_getSendCommand8(uint8_t *dat1, uint8_t *dat2, uint16_t *dat3, uint32_t *dat4)
 {
     uint16_t nxtAsynchCmd;
-    uint8_t nn;
+    uint8_t nn, ll;
 
-    if (nrOfCmds8InQueue==0 || nrOfCmds8InQueue>CMD4STACKDEPTH)
+    if (nrOfCmds8InQueue==0 || nrOfCmds8InQueue>CMD8STACKDEPTH)
         return 0;   // error
     nxtAsynchCmd=nextAsynchsendCmd8[0];
     *dat1=nextCmd8para1[0];
@@ -222,7 +233,11 @@ uint16_t sendWRcmd_getSendCommand8(uint8_t *dat1, uint8_t *dat2, uint16_t *dat3,
     *dat4=nextCmd8para4[0];
 
     // move buffer down by one element
-    for (nn=0; nn<CMD8STACKDEPTH; nn++)
+    if (CMD8STACKDEPTH>0)
+        ll=CMD8STACKDEPTH-1;
+    else
+        ll=0;
+    for (nn=0; nn<ll; nn++)
     {
         nextAsynchsendCmd8[nn]=nextAsynchsendCmd8[nn+1];
         nextCmd8para1[nn]=nextCmd8para1[nn+1];
@@ -433,3 +448,257 @@ uint8_t gpi_chk4remainingText(void)
 
 
 
+
+
+
+
+
+// ---------------------------------------------------------------------------------
+//   11.4.23 neu, Kommando direkt an "FastDevice"-protokoll senden, nicht mehr umsetzen
+// ---------------------------------------------------------------------------------
+
+
+// short command, 4 data bytes
+static uint8_t nextFDwrCmd[FDCMD_STACKDEPTH];
+static uint8_t nextFDrdCmd[FDCMD_STACKDEPTH];
+static uint8_t nextFDblkNr[FDCMD_STACKDEPTH];
+
+static uint8_t  nextFDpara1[FDCMD_STACKDEPTH];
+static uint8_t  nextFDpara2[FDCMD_STACKDEPTH];
+static uint8_t  nextFDpara3[FDCMD_STACKDEPTH];
+static uint8_t  nextFDpara4[FDCMD_STACKDEPTH];
+static uint8_t  p_nextFDcmdsInQueue;
+/* convention: use simple (not rotating) FIFO Stack:
+Example: nrOfCmdsInQueue=4 then
+    nextAsynchsendCmd0[0]=cmd1      // was stored as first
+    nextAsynchsendCmd0[1]=cmd2
+    nextAsynchsendCmd0[2]=cmd3
+    nextAsynchsendCmd0[3]=cmd4      // came in as last
+
+    Send: [0] first, then move buffer 1 down:
+    nextAsynchsendCmd0[0]=cmd2
+    nextAsynchsendCmd0[1]=cmd3
+    nextAsynchsendCmd0[2]=cmd4
+    nextAsynchsendCmd0[3]=0;
+    nrOfCmdsInQueue=3 now
+*/
+
+
+void sendFDcmd_clrStack(void)
+{
+    uint8_t nn;
+    for (nn=0; nn<FDCMD_STACKDEPTH; nn++)
+    {
+        nextFDwrCmd[nn]=0;
+        nextFDrdCmd[nn]=0;
+        nextFDblkNr[nn]=0;
+        nextFDpara1[nn]=0;
+        nextFDpara2[nn]=0;
+        nextFDpara3[nn]=0;
+        nextFDpara4[nn]=0;
+    }
+    p_nextFDcmdsInQueue=0;
+}
+
+bool sendFDcmd_set(uint8_t nextWrCmd, uint8_t nextRdCmd, uint8_t blockNum, uint8_t dat1, uint8_t dat2, uint8_t dat3, uint8_t dat4)
+{
+    // write Command to memory, wait for transport
+    if (p_nextFDcmdsInQueue>=FDCMD_STACKDEPTH)
+    {
+        qDebug() << "cannot save cmd because stack is full";
+        return false;           // not possible
+    }
+    nextFDwrCmd[p_nextFDcmdsInQueue]=nextWrCmd;
+    nextFDrdCmd[p_nextFDcmdsInQueue]=nextRdCmd;
+    nextFDblkNr[p_nextFDcmdsInQueue]=blockNum;
+    nextFDpara1[p_nextFDcmdsInQueue]=dat1;
+    nextFDpara2[p_nextFDcmdsInQueue]=dat2;
+    nextFDpara3[p_nextFDcmdsInQueue]=dat3;
+    nextFDpara4[p_nextFDcmdsInQueue]=dat4;
+    //qDebug() << "data with 4 data byte saved, pp=" << nrOfCmds4InQueue;
+    //qDebug() << " dat1=" << nextCmd4para1[nrOfCmds4InQueue] << " dat2=" << nextCmd4para2[nrOfCmds4InQueue]
+    //             << " dat3=" << nextCmd4para3[nrOfCmds4InQueue]  << " dat4=" << nextCmd4para4[nrOfCmds4InQueue];
+    p_nextFDcmdsInQueue++;
+    return true;                // ok, will be sent
+}
+
+bool sendFDcmd_get(uint8_t *nextWrCmd, uint8_t *nextRdCmd, uint8_t *blockNum, uint8_t *dat1, uint8_t *dat2, uint8_t *dat3, uint8_t *dat4)
+{
+    uint8_t nn, ll;
+
+    if (p_nextFDcmdsInQueue==0 || p_nextFDcmdsInQueue>FDCMD_STACKDEPTH)
+        return false;           // not possible
+
+    *nextWrCmd=nextFDwrCmd[0];
+    *nextRdCmd=nextFDrdCmd[0];
+    *blockNum=nextFDblkNr[0];
+    *dat1=nextFDpara1[0];
+    *dat2=nextFDpara2[0];
+    *dat3=nextFDpara3[0];
+    *dat4=nextFDpara4[0];
+    //qDebug() << "cmd4  restored to send from [0];  pp=" << nrOfCmds4InQueue;
+    //qDebug() << " data1: " << nextCmd4para1[0] << " data2: " << nextCmd4para2[0] <<
+    //            " data3: " << nextCmd4para3[0] << " data4: " << nextCmd4para4[0];
+
+    // move Puffer down by one element
+    if (FDCMD_STACKDEPTH>0)
+        ll=FDCMD_STACKDEPTH-1;
+    else
+        ll=0;
+    for (nn=0; nn<ll; nn++)
+    {
+        nextFDwrCmd[nn]=nextFDwrCmd[nn+1];
+        nextFDrdCmd[nn]=nextFDrdCmd[nn+1];
+        nextFDblkNr[nn]=nextFDblkNr[nn+1];
+        nextFDpara1[nn]=nextFDpara1[nn+1];
+        nextFDpara2[nn]=nextFDpara2[nn+1];
+        nextFDpara3[nn]=nextFDpara3[nn+1];
+        nextFDpara4[nn]=nextFDpara4[nn+1];
+    }
+    if (p_nextFDcmdsInQueue>0)
+        p_nextFDcmdsInQueue--;
+    //qDebug() << "cmd4  after push down: pp=" << nrOfCmds4InQueue;
+    return true;                // ok, will be sent
+}
+
+uint8_t check4FDshortCmd(void)
+{
+    // returns number of waiting command, max FDCMD_STACKDEPTH
+    return p_nextFDcmdsInQueue;
+}
+
+
+uint8_t check4freeFDshortCmd(void)
+{
+    // returns number of free places in short-command stack
+    return FDCMD_STACKDEPTH - p_nextFDcmdsInQueue;
+}
+
+
+// long command, 64 data bytes
+static uint8_t longFDwrCmd[FDLONG_STACKDEPTH];
+static uint8_t longFDrdCmd[FDLONG_STACKDEPTH];
+static uint8_t longFDblkNr[FDLONG_STACKDEPTH];
+static uint8_t longFDlength[FDLONG_STACKDEPTH];
+
+static uint8_t  longFDpara[FDLONG_STACKDEPTH][64];
+static uint8_t  p_longFDcmdsInQueue;
+
+
+void longFDcmd_clrStack(void)
+{
+    uint8_t nn, mm;
+    for (nn=0; nn<FDLONG_STACKDEPTH; nn++)
+    {
+        longFDwrCmd[nn]=0;
+        longFDrdCmd[nn]=0;
+        longFDblkNr[nn]=0;
+        longFDlength[nn]=0;
+        for (mm=0; mm<64; mm++)
+            longFDpara[nn][mm]=0;
+    }
+    p_longFDcmdsInQueue=0;
+}
+
+
+bool longFDcmd_set(uint8_t nextWrCmd, uint8_t nextRdCmd, uint8_t blockNum, uint8_t length, uint8_t *data)
+{
+    // write Command to memory, wait for transport
+    // data buffer size always 64! data[64], padded with 0
+    uint8_t nn;
+    if (p_longFDcmdsInQueue>=FDLONG_STACKDEPTH)
+    {
+        qDebug() << "cannot save cmd because stack is full";
+        return false;           // not possible
+    }
+    longFDwrCmd[p_longFDcmdsInQueue]=nextWrCmd;
+    longFDrdCmd[p_longFDcmdsInQueue]=nextRdCmd;
+    longFDblkNr[p_longFDcmdsInQueue]=blockNum;
+    longFDlength[p_longFDcmdsInQueue]=length;
+    for (nn=0; nn<64; nn++)
+        longFDpara[p_longFDcmdsInQueue][nn]=data[nn];
+
+    p_longFDcmdsInQueue++;
+    return true;                // ok, will be sent
+}
+
+bool longFDcmd_get(uint8_t *nextWrCmd, uint8_t *nextRdCmd, uint8_t *blockNum, uint8_t *length, uint8_t *data)
+{
+    uint8_t nn, mm, ll;
+
+    if (p_longFDcmdsInQueue==0 || p_longFDcmdsInQueue>FDLONG_STACKDEPTH)
+        return false;           // not possible
+
+    *nextWrCmd= longFDwrCmd[0];
+    *nextRdCmd= longFDrdCmd[0];
+    *blockNum = longFDblkNr[0];
+    *length   = longFDlength[0];
+    for (mm=0; mm<64; mm++)
+        data[mm] = longFDpara[0][mm];
+
+    // move Puffer down by one element
+    if (FDLONG_STACKDEPTH>0)
+        ll=FDLONG_STACKDEPTH-1;
+    else
+        ll=0;
+    for (nn=0; nn<ll; nn++)
+    {
+        longFDwrCmd[nn]  = longFDwrCmd[nn+1];
+        longFDrdCmd[nn]  = longFDrdCmd[nn+1];
+        longFDblkNr[nn]  = longFDblkNr[nn+1];
+        longFDlength[nn] = longFDlength[nn+1];
+
+        for (mm=0; mm<64; mm++)
+            longFDpara[nn][mm] = longFDpara[nn+1][mm];
+
+    }
+    if (p_longFDcmdsInQueue>0)
+        p_longFDcmdsInQueue--;
+
+    return true;                // ok, will be sent
+}
+
+uint8_t check4FDlongCmd(void)
+{
+    // returns number of waiting command
+    return p_longFDcmdsInQueue;
+}
+
+uint8_t check4freeFDlongCmd(void)
+{
+    // returns number of free places in command stack
+    return FDLONG_STACKDEPTH - p_longFDcmdsInQueue;
+}
+
+
+
+
+static uint8_t Sdata_DeviceParameter[64];
+static uint8_t Sdata_DevParaLen;
+
+uint8_t epi_store64BdevParameter(uint8_t length, uint8_t *buf)
+{
+    // HWapi writes data to be stored
+    uint8_t nn;
+    for (nn=0; nn<length; nn++)
+        Sdata_DeviceParameter[nn]=buf[nn];
+    for (nn=length; nn<64; nn++)
+        Sdata_DeviceParameter[nn]=0;
+
+    Sdata_DevParaLen=length;
+    return 0;
+}
+
+uint8_t epi_restore64BdevParameter(uint8_t *length, uint8_t *buf)
+{
+
+    for (uint8_t nn=0; nn<Sdata_DevParaLen; nn++)
+        buf[nn]=Sdata_DeviceParameter[nn];
+    *length=Sdata_DevParaLen;
+
+    return 0;
+}
+
+
+
+

src/shared_mem_buffer.cpp

@@ -0,0 +1,39 @@
+#include "shared_mem_buffer.h"
+
+#include <QDebug>
+#include <atomic>
+
+#ifdef QT_POSIX_IPC
+    // The POSIX backend can be explicitly selected using the -feature-ipc_posix
+    // option to the Qt configure script. If it is enabled, the QT_POSIX_IPC
+    // macro will be defined. -> we use SystemV shared memory
+#error "QT_POSIX_IPC defined"
+#else
+#include <sys/ipc.h>    // ftok
+#endif
+
+// std::atomic_bool SharedMemBuffer::__sharedMemLocked{false};
+
+QSharedMemory *SharedMemBuffer::getShm(std::size_t size) {
+    static QSharedMemory shMem;
+    if (size > 0) {
+        static const long nativeKey = ftok("/etc/os-release", 'H');
+        static const QString fkey = std::to_string(nativeKey).c_str();
+        shMem.setKey(fkey);
+        if (!shMem.isAttached()) {
+            if (shMem.create(size)) {
+                return &shMem;
+            } else {
+                if (shMem.error() == QSharedMemory::AlreadyExists) {
+                    if (shMem.attach()) {
+                        return &shMem;
+                    }
+                }
+            }
+            qCritical() << shMem.nativeKey() << shMem.key() << shMem.data()
+                        << shMem.error() << shMem.errorString();
+            return nullptr;
+        }
+    }
+    return &shMem;
+}

src/tslib.cpp

@@ -76,6 +76,23 @@ uint8_t uint2uchar(uint16_t uival, bool getHighB)
 }
 
 
+uint8_t ulong2uchar(uint32_t ulval, uint8_t getBytNr)
+{
+    // getBytNr: 0=LSB  3=MSB
+    uint32_t ultmp=ulval;
+    if (getBytNr==0)
+        return uint8_t(ultmp);
+    ultmp>>=8;
+    if (getBytNr==1)
+        return uint8_t(ultmp);
+    ultmp>>=8;
+    if (getBytNr==2)
+        return uint8_t(ultmp);
+    ultmp>>=8;
+    return uint8_t(ultmp);
+
+}
+
 void delay(uint16_t MilliSec)
 {
     QThread::msleep(uint32_t(MilliSec));
@@ -344,6 +361,15 @@ uint16_t tslib_strlen(char *buf)
     return 0;
 }
 
+uint16_t tslib_strlen(uint8_t *buf)
+{
+    uint16_t nn;
+
+    for (nn=0; nn<0xFFF0; nn++)
+        if (buf[nn]==0)
+            return nn;
+    return 0;
+}
 
 void tslib_strclr(char *buf, char clrsign, uint16_t len)
 {
@@ -555,3 +581,18 @@ uint8_t tslib_sendFlashStartAddr2BL(uint32_t startAddr, uint8_t *sendData)
 
 // -----------------------------------------------------------------------------------------------
 
+
+void biox_CopyBlock(uint8_t *src, uint16_t srcPos, uint8_t *dest, uint16_t destPos, uint16_t len)
+{
+    // both buffers starting from pos 0
+    uint16_t xx,yy,zz,ii;
+
+    xx = srcPos;
+    yy = destPos;
+    zz = len;
+
+    for (ii = 0; ii < zz; ++ii)
+    {
+        dest[yy + ii] = src[xx + ii];
+    }
+}