--- trunk/FlisServer/FlisServerDlg.cpp 2007/11/30 16:03:46 110 +++ trunk/FlisServer/FlisServerDlg.cpp 2007/12/05 09:21:56 153 @@ -5,6 +5,7 @@ #include "FlisServer.h" #include "FlisServerDlg.h" #include +#include ".\flisserverdlg.h" #ifdef _DEBUG #define new DEBUG_NEW @@ -62,11 +63,10 @@ ON_WM_SYSCOMMAND() ON_WM_PAINT() ON_WM_QUERYDRAGICON() - ON_MESSAGE(UWM_MYMESSAGE, OnShowString) //}}AFX_MSG_MAP - ON_BN_CLICKED(IDC_test, OnBnClickedtest) ON_BN_CLICKED(IDCLOSE, OnBnClickedClose) ON_BN_CLICKED(IDC_GSMPIN, OnBnClickedGsmpin) + ON_BN_CLICKED(IDC_Start, OnBnClickedStart) END_MESSAGE_MAP() @@ -102,8 +102,7 @@ // TODO: Add extra initialization here StartSerial(); DBConnect(); - continueThread = true; - //AfxBeginThread(MyMainThread,0,THREAD_PRIORITY_NORMAL,0,0,NULL); + ResetSms = 0; return TRUE; // return TRUE unless you set the focus to a control } @@ -158,18 +157,45 @@ } int CFlisServerDlg::StartSerial(void) { + int Baud; - CString SerialPort = "COM3"; + ConfigFile config; + try { + config.ReadSettings(); + } catch(...) { + MessageBox("Could not open config file"); + OnOK(); + return true; + } + Baud = 1200; - if( Serial.isOpen() ){ - Serial.close(); - Serial.open( SerialPort, Baud ); + if( Serial.isOpen() ) + { + try + { + Serial.close(); + Serial.open( config.comport, Baud ); + } + catch (exception* e) + { + MessageBox( "Serial.open() exception" ); + return 0; + } } - else { - Serial.open( SerialPort, Baud ); + else + { + try + { + Serial.open( config.comport, Baud ); + } + catch (exception* e) + { + MessageBox( "Serial.open() exception 2" ); + return 0; + } } - + return 0; } @@ -178,73 +204,13 @@ std::vector buf; while(Serial.getComstat().cbInQue > 0) { - unsigned char data = Serial.readByte(); + unsigned char data = Serial.readByte(); - buf.push_back(data); + buf.push_back(data); } return buf; } -void CFlisServerDlg::OnBnClickedtest() -{ - // TODO: Add your control notification handler code here -/* -////////////////DBRead stuff////////////////// - CString testdata; - std::vector data; - data = DBRead(); - for (int i=0; i tlfnr; - vector smsdata; - tlfnr.push_back('2'); - tlfnr.push_back('9'); - tlfnr.push_back('7'); - tlfnr.push_back('2'); - tlfnr.push_back('2'); - tlfnr.push_back('6'); - tlfnr.push_back('0'); - tlfnr.push_back('3'); - - SendSmsHead(tlfnr); - - //35:29860132:75 <--- demo pakke; - smsdata.push_back('3'); - smsdata.push_back('5'); - smsdata.push_back(':'); - smsdata.push_back('2'); - smsdata.push_back('9'); - smsdata.push_back('8'); - smsdata.push_back('6'); - smsdata.push_back('0'); - smsdata.push_back('1'); - smsdata.push_back('3'); - smsdata.push_back('2'); - smsdata.push_back(':'); - smsdata.push_back('7'); - smsdata.push_back('5'); - - SendSmsData(smsdata); -///////////////Send sms stuff///////////////// -*/ -/* -////////////Start Tråd//////////////////////// - MyThread *t = new MyThread(AfxGetMainWnd()); - t->start(); -////////////Start Tråd//////////////////////// -*/ - AfxBeginThread(threadWrapper,AfxGetMainWnd()); - -} void CFlisServerDlg::writeFrame(std::vector data) { for (int i=0; i 0) - { - std::vector answer = readFrame(); - Sleep(50); - char array1[25]; - int i; - for (int i=0; i data) { @@ -311,25 +256,19 @@ CString tekst; std::vector answer = readFrame(); Sleep(50); - char array1[25]; - int i; - for (int i=0; i data) +void CFlisServerDlg::SendSmsHead(std::vector tlfnr) { vector atcommand; atcommand.push_back('a'); @@ -349,9 +288,9 @@ Sleep(5); } - for (int i=0; i CFlisServerDlg::DBRead(void) +vector CFlisServerDlg::DBReadCommands(void) { vector buffer; CString SQL, IDnr, CommandID, InstallationsID; - SQL = "select id,date_trunc('second', created) as created,executed,commandid,installationid from command WHERE executed IS NULL;"; + SQL = "select id,date_trunc('second', created) as created,executed,commandid,installationid from command WHERE executed IS NULL ORDER BY created ASC LIMIT 1;"; CRecordset rs(&db); rs.Open(AFX_DB_USE_DEFAULT_TYPE, SQL); if (rs.GetRecordCount()>0) { rs.MoveFirst(); - while(!rs.IsEOF()) - { + Commands Mycom; rs.GetFieldValue((short)0, IDnr); rs.GetFieldValue(3, CommandID); @@ -389,7 +333,7 @@ buffer.push_back(Mycom); rs.MoveNext(); - } + } rs.Close(); return buffer; @@ -397,30 +341,21 @@ void CFlisServerDlg::ReadSms() { CString tekst, oldtekst; - Sleep(950); + Sleep(950); //Holder en pause for at lade hele sms'en komme ind i serial køen. if(Serial.getComstat().cbInQue > 0) { std::vector answer = readFrame(); Sleep(50); - char array1[250]; - int i; - for (int i=0; i0) + { + rs.MoveFirst(); + rs.GetFieldValue((short)0,InstallNR); + } + rs.Close(); + + SQL.Format("insert into logtable (logtime,temperature,flamedetector,solidfuelempty,conveyorerror,powerfailure,messagenr,installationnr) Values (now(),%s,'%s','%s','%s','%s',%s,%s)",Temper, Flamme, Flis, FremFejl, PowerFail, SmsCount,InstallNR); + try + { + db.ExecuteSQL(SQL); + } + catch(CDBException* e) + { + MessageBox(e->m_strError); + } + AppendText("Sms added to Log"); + Sleep(150); } CString CFlisServerDlg::Splitter(CString& fyrdata) { @@ -492,7 +420,10 @@ void CFlisServerDlg::OnBnClickedClose() { // TODO: Add your control notification handler code here - continueThread = false; + continueThread = 0; + DeleteSms(); + + Sleep(500); if( Serial.isOpen() ) { Serial.close(); @@ -500,17 +431,55 @@ if(db.IsOpen()) { - db.Close(); + db.Close(); } - DeleteSms(); + OnOK(); + } void CFlisServerDlg::OnBnClickedGsmpin() { // TODO: Add your control notification handler code here + bool ready = true; + m_Textwindow.SetWindowText("Indsætter Pinkode, og venter på modem bliver klar"); + UpdateWindow(); SetPin(); - Sleep(5000); + Sleep(500); + + while (ready == true) + { + if (Serial.getComstat().cbInQue > 120) + { + std::vector answer = readFrame(); + CString tekst; + + for (int i=0; i -1) + { + ready = false; + } + else + { + AppendText(tekst); + } + } + Sleep(10); //Small delay to avoid busy wait + } + Sleep(100); //Give the modem a chance to send the last data + while(Serial.getComstat().cbInQue > 0) + { + Serial.readByte(); //Flush the incoming queue + Sleep(1); + } + OnBnClickedStart(); } void CFlisServerDlg::DeleteSms() { @@ -529,50 +498,8 @@ writeFrame(atcommand); Sleep(500); - if(Serial.getComstat().cbInQue > 0) - { - std::vector answer = readFrame(); - Sleep(50); - CString tekst, oldtekst; - char array1[250]; - int i; - for (int i=0; iSetWindowText(*s); - - delete s; - return 0; - -}UINT threadWrapper(LPVOID thread) +UINT threadWrapper(LPVOID thread) { CFlisServerDlg *t = (CFlisServerDlg*) thread; t->runthread(); @@ -586,41 +513,32 @@ void CFlisServerDlg::runthread() { - int count = 0; - while (continueThread = true) + while (continueThread != 0) { Reader(); } } void CFlisServerDlg::Reader() { - int ResetSms = 0; - while(1) - { - if(Serial.getComstat().cbInQue > 0) + if(Serial.getComstat().cbInQue > 0) { + Sleep(250); std::vector answer = readFrame(); Sleep(500); CString tekst, oldtekst; int lol; - char array1[250]; - int i; - for (int i=0; i= 50) + else + { + AppendText(tekst); + } + if(ResetSms == 20) { DeleteSms(); + AppendText("Sms'er slettet da vi nåede grænsen"); + } + + } + if (continueThread == 1) + { + + CString testdata, dataframe,testprint, sIDnr, sCommandID, sInstallationsID, sImei; + int commandtest = 0; + int iAll = 1; + std::vector data; + data = DBReadCommands(); + for (int i=0; i 1) + { + sInstallationsID = data[i].InstallationsID; + } } + if (commandtest > 1) + { + iAll = 0; + } + + if (sIDnr.GetLength() > 0) + { + SendConfig(sIDnr,sCommandID,sInstallationsID); + } + Sleep(500); + + CheckAcknowledges(); + Sleep(500); + } + CTime now = CTime::GetCurrentTime(); + + CTimeSpan elapsed = now-Alive.tid; + + if (elapsed.GetTotalSeconds() >= 900) + { + keepaliveandread(); + } +} +void CFlisServerDlg::SendConfig(CString IDnr,CString CommandID,CString InstallationsID) +{ + + std::vector inst; + + if (CommandID == "1") + inst = DBReadPhone("0"); + else + inst = DBReadPhone(InstallationsID); + + for ( int j=0; j < inst.size(); j++) + { + CString TlfNr, Imei, updaterate; + TlfNr.Empty(); + Imei.Empty(); + updaterate.Empty(); + + CString dataen = inst[j].InstPhoneNr; + TlfNr.Append(dataen); + CString Imeidata = inst[j].Imei; + Imei.Append(Imeidata); + CString updaterat = inst[j].Updaterate; + updaterate.Append(updaterat); + + vector tlfnr; + for (int i=0; i smsdata; + + for (int i=0; i CFlisServerDlg::DBReadPhone(CString sInstallationsID) +{ + vector buffer; + + CString SQL, phonenr, imei, updaterate, id; + Installation Myinst; + + if (sInstallationsID != "0") + { + SQL.Format("select installationphonenr, imei, updaterate, id from installation WHERE id = %s", sInstallationsID); + } + else + { + SQL.Format("select installationphonenr, imei, updaterate, id from installation"); + } + + CRecordset rs(&db); + rs.Open(AFX_DB_USE_DEFAULT_TYPE, SQL); + if (rs.GetRecordCount()>0) + { + rs.MoveFirst(); + while(!rs.IsEOF()) + { + + rs.GetFieldValue((short)0,phonenr); + rs.GetFieldValue(1,imei); + rs.GetFieldValue(2,updaterate); + rs.GetFieldValue(3,id); + + Myinst.InstPhoneNr = phonenr; + Myinst.Imei = imei; + Myinst.Updaterate = updaterate; + Myinst.instID = id; + + buffer.push_back(Myinst); + rs.MoveNext(); + } + } + rs.Close(); + return buffer; +} +int CFlisServerDlg::tversum(__int64 input) +{ + int sum = 0; + while (input > 0) + { + sum += (input %10); + input /= 10; + } + return sum; +} +void CFlisServerDlg::OnBnClickedStart() +{ +// TODO: Add your control notification handler code here + + continueThread = 1; + keepaliveandread(); + Sleep(150); + m_Textwindow.SetWindowText(CString("Server phonenr read from db: ") + Alive.Phonenr ); + AppendText("Started"); + AfxBeginThread(threadWrapper,AfxGetMainWnd()); +} +void CFlisServerDlg::AppendText(CString s) +{ + CString Tekst; + m_Textwindow.GetWindowText(Tekst); + Tekst.Append("\r\n"); + Tekst.Append(s); + m_Textwindow.SetWindowText(Tekst); + +} +void ConfigFile::ReadSettings() +{ + ifstream file("Server-Settings.ini"); + if (!file.is_open()) + throw("Could not open file"); + + char buf[200]; + while (!file.eof() ) { + file.getline(buf,200); + CString tmp(buf); + + if (tmp.GetAt(0) == '#') + continue; + + int pos = tmp.Find('='); + if (pos>0) { + CString key = tmp.Left(pos).Trim().MakeLower();; + CString value = tmp.Right(tmp.GetLength()-pos-1).Trim(); + + if (key == "host") + host = value; + else if (key == "username") + username = value; + else if (key == "password") + password = value; + else if (key == "database") + database = value; + else if (key == "comport") + comport = value; + } + + } + + file.close(); +} +void CFlisServerDlg::HandleAcknowledge(CString tlfnr) +{ + for (std::list::iterator it = Acks.begin(); it != Acks.end(); ++it) + { + Acknowledge& current = (*it); + if (current.sTlfNr == tlfnr) + { + CString SQL; + SQL.Format("UPDATE installation SET commerror = false WHERE id = %s", current.sInstallationID); + db.ExecuteSQL(SQL); + + Acks.erase(it); + + return; + } + } +} + +void CFlisServerDlg::CheckAcknowledges() +{ + CTime now = CTime::GetCurrentTime(); + for (std::list::iterator it = Acks.begin(); it != Acks.end(); ++it) + { + Acknowledge& current = (*it); + + CTimeSpan elapsed = now-current.cTime; + + if (elapsed.GetTotalSeconds() >= 300) + { + DumpAckList(); + if (current.iRetry >= 1) + { + CString SQL; + SQL.Format("UPDATE installation SET commerror = true WHERE id = %s", current.sInstallationID); + db.ExecuteSQL(SQL); + Acks.erase(it); + return; // the iterator is now invalidated, but the thread loop will make sure we are here soon again + } + else + { + SendConfig("0","2",current.sInstallationID); + current.iRetry++; + current.cTime = CTime::GetCurrentTime(); + AppendText( CString("Retry send config to ") + current.sTlfNr ); + } + } + } +} + +void CFlisServerDlg::DumpAckList() +{ + CTime now = CTime::GetCurrentTime(); + OutputDebugString("-------------------------------\n"); + int count = 0; + for (std::list::iterator it = Acks.begin(); it != Acks.end(); ++it) + { + CString msg; + msg.Format("%d:%d:%d> %4d : %s\n", now.GetHour(), now.GetMinute(), now.GetSecond(), count, (*it).sTlfNr); + OutputDebugString(msg); + count++; + } +} +vector CFlisServerDlg::keepaliveandread(void) +{ + vector buffer; + + CString SQL, name, value; + SQL = "select name, value from config;"; + CRecordset rs(&db); + try + { + rs.Open(AFX_DB_USE_DEFAULT_TYPE, SQL); + if (rs.GetRecordCount()>0) + { + rs.MoveFirst(); + rs.GetFieldValue((short)0, name); + rs.GetFieldValue(1,value); + + Alive.name = name; + Alive.value = value; + Alive.tid = CTime::GetCurrentTime(); + if(Alive.name == "phonenr") + { + Alive.Phonenr = value; + } + + buffer.push_back(Alive); + rs.MoveNext(); + } + rs.Close(); + return buffer; } + catch (char * str) + { + AppendText("Keepalive failed, closing and opening the db connection again"); + if(db.IsOpen()) + { + db.Close(); + AppendText("DB connection closed"); + } + if(!db.IsOpen()) + { + DBConnect(); + AppendText("DB connection started again"); + } + } + + } \ No newline at end of file