#include "SocketThreadCrusader.h" #include <iostream> #include "MonitorLogging.h" #include "convert.h" using namespace std ; SocketThreadCrusader::SocketThreadCrusader(MonitorConfiguration *config, int LOCKNUM, int PortNum) : SocketThread(config, LOCKNUM, PortNum, monitord) { telegrammCounter=0 ; } SocketThreadCrusader::~SocketThreadCrusader() { } void SocketThreadCrusader::sayWelcome() { } std::string SocketThreadCrusader::createFMSOutputString(ModuleResultBase Result) { std::string baustufeCString, richtungCString ; std::string counterCString ; std::string socketText ; baustufeCString = convertStringBoolText (Result["baustufe"]); richtungCString = convertStringBoolText (Result["richtung"]); counterCString=convertIntToString(telegrammCounter++) ; socketText = Result["datum"] // dateStr + "#![]!#" + Result["uhrzeit"] //timeStr + "#![]!#" + Result["fmskennung"] // fahrzeugKennung + "#![]!#" + Result["status"] // statusString + "#![]!#" + baustufeCString + "#![]!#" + richtungCString + "#![]!#" + Result["tki"] + "#![]!#-1#![]!#false#![]!#false#![]!#" + counterCString ; /* if ( (Result["textuebertragung"].size()>0) && (convertToInt(Result["status"])==10)) { socketText+= "#![]!#" + Result["textuebertragung"] + "#![]!#" ; } */ return socketText ; } std::string SocketThreadCrusader::createZVEIOutputString(ModuleResultBase Result) { std::string socketText ; std::string hexText ; std::string counterCString ; convertStringToHex(Result["text"],hexText) ; counterCString=convertIntToString(telegrammCounter++) ; socketText = Result["datum"] + "#![]!#" + Result["uhrzeit"] + "#![]!#" + Result["zvei"] + "#![]!#16#![]!#false#![]!#true#![]!#-1#![]!#-1#![]!#false#![]!#false#![]!#" + counterCString + "#![]!#Melderalarm#![]!#" ; return socketText ; } std::string SocketThreadCrusader::createPOCSAGOutputString(ModuleResultBase Result) { std::string socketText ; std::string hexText ; std::string counterCString ; counterCString=convertIntToString(telegrammCounter++) ; convertStringToHex(Result["text"],hexText) ; socketText = Result["datum"] + "#![]!#" + Result["uhrzeit"] + "#![]!#" + Result["ric"] + Result["subhex"] + "#![]!#17#![]!#false#![]!#true#![]!#0#![]!#-1#![]!#false#![]!#false#![]!#" + counterCString + "#![]!#" + Result["text"] + "#![]!#" ; return socketText ; } void SocketThreadCrusader::processInput() { // Anmeldung ? std::string Kommando=m_CommandBuffer ; if (Kommando.substr(0,5)=="PASS:") { std::string password=Kommando.substr(5) ; checkLogin(password) ; } else if (Kommando=="ClientCiao") { doLogout() ; } else if (Kommando.substr(8, 6) == "#![]!#") { ModuleResultBase *pfms = new ModuleResultBase(); size_t position; std::string datum, zeit, fmskennung, status, a, b, c, d, e, f, g, text; /* Status im Crusader manuell gesetzt: * 23.07.08#![]!#22:19:36#![]!#93185811#![]!#7#![]!#true#![]!#false#![]!#3#![]!#1#![]!#false#![]!#true#![]!#-1#![]!#7 TelegrammText#![]!# */ LOG_DEBUG("manueller Status von Crusader Client empfangen.") /* es wird nur FMS betrachtet */ pfms->set ("typ", "fms"); /* Feld 1: Datum */ pfms->set ("datum", Kommando.substr(0, 8)); /* Feld 2: Uhrzeit */ position = Kommando.find_first_of(CRUSADER_DELIMITER) + 6; pfms->set ("uhrzeit", Kommando.substr(position, 8)); /* Feld 3: FMS Kennung */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; fmskennung = Kommando.substr(position, 8); pfms->set ("fmskennung", fmskennung); pfms->set ("bosdezimal", convertIntToString (convertNibbleToInt (fmskennung[0]))); pfms->set ("landdezimal", convertIntToString (convertNibbleToInt (fmskennung[1]))); pfms->set ("bos", fmskennung.substr(0, 1)); pfms->set ("land", fmskennung.substr(1, 1)); pfms->set ("ort", fmskennung.substr(2, 2)); pfms->set ("kfz", fmskennung.substr(4, 4)); /* Feld 4: Fahrzeugstatus */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; status = Kommando.substr(position, 1); pfms->set ("status", status); pfms->set ("statusdezimal", convertIntToString (convertNibbleToInt (status[0]))); // TODO Status 16 bedeutet ZVEI und 17 POCSAG /* Feld 5: Baustufe */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; pfms->set ("baustufe", convertStringTextBool(Kommando.substr(position, Kommando.find_first_of(CRUSADER_DELIMITER, position) - position))); /* Feld 6: Richtung */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; pfms->set ("richtung", convertStringTextBool(Kommando.substr(position, Kommando.find_first_of(CRUSADER_DELIMITER, position) - position))); /* Feld 7: TKI */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; pfms->set ("tki", Kommando.substr(position, 1)); /* Feld 8: ? */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; /* Feld 9: ? */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; /* Feld 10: ? */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; /* Feld 11: ? */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; /* Feld 12: Text */ position = Kommando.find_first_of(CRUSADER_DELIMITER, position) + 6; pfms->set ("textuebertragung", Kommando.substr(position, Kommando.find_first_of(CRUSADER_DELIMITER, position) - position)); LOG_DEBUG("Debug(FMS vom Crusader):") pfms->Dump(); GlobalDispatcher->addResult (pfms); } else { LOG_DEBUG("received from Crusader: " << m_CommandBuffer) } } void SocketThreadCrusader::checkLogin(std::string password) { if (m_MonitorConfiguration->IsValidLogin(m_MonitorConfiguration->m_crusaderUsername,password,m_sClientIP)) { m_authenticated=true ; LOG_INFO("login accepted (crusader pw allowed): from ip " << m_sClientIP) } else { LOG_INFO("login denied (crusader pw not allowed): " << password << " from ip " << m_sClientIP) } }