C / C++ / MFC

<br />
#include <stdio.h><br />
#include <afxinet.h><br />
//#include "StdAfx.h"<br />
#include "Serial.h"<br />
<br />
#define EVER ;;<br />
<br />
//my thread functions<br />
static DWORD listenThread_id;<br />
static DWORD WINAPI listenThread(LPVOID ref);<br />
<br />
<br />
char * command = "AT+CMGR=3\n";<br />
char * delcommand = "AT+CMGD=1\n";<br />
<br />
int count = 0;<br />
<br />
bool appRunning;<br />
bool sendComm, delComm, sendToDB = false;<br />
<br />
CString st;<br />
CInternetSession InternetSession;<br />
<br />
void main()<br />
{<br />
	appRunning = true;<br />
	<br />
	printf("Application Started. Press q to Quit. \n\n");<br />
<br />
	printf("Please enter a command. \n\n");<br />
<br />
	printf("Press r to read\n\n");<br />
<br />
	if (CreateThread(NULL, 0, listenThread, NULL, 0, &listenThread_id) == NULL)<br />
	{<br />
		exit(-1);<br />
	}<br />
<br />
	while (appRunning)<br />
	{<br />
		char inChar = getchar();<br />
<br />
		if (inChar == 'q')<br />
			appRunning = false;<br />
		if (inChar == 'r')<br />
			sendComm = true;<br />
		if (inChar == 's')<br />
			sendToDB = true;<br />
		if (inChar == 'd')<br />
			delComm = true;<br />
	}<br />
}<br />
<br />
static DWORD WINAPI listenThread(LPVOID ref)<br />
{<br />
	CSerial Serial;<br />
	int port=1, baud=115200;<br />
	char lpBuffer[100];<br />
<br />
	if (Serial.Open(port, baud))<br />
	{<br />
		for (EVER)<br />
		{<br />
			if (sendComm)<br />
			{<br />
				int commLength = strlen(command);<br />
				Serial.SendData(command, commLength);<br />
				sendComm=false;<br />
			}<br />
<br />
			if (delComm)<br />
			{<br />
				int commLength = strlen(delcommand);<br />
				Serial.SendData(delcommand, commLength);<br />
				delComm=false;<br />
			}<br />
<br />
			while (Serial.ReadDataWaiting() > 0)<br />
			{<br />
				int nBytesRead = Serial.ReadData(lpBuffer, 100);<br />
				for (int i=0; i<nBytesRead; i++)<br />
				{<br />
					printf("%c", lpBuffer[i]);<br />
					st += lpBuffer[i];<br />
<br />
					int newMsg = st.Find("+CMTI: \"SM\",");<br />
<br />
					if (newMsg != -1)	// Message rec'd <br />
					{<br />
						count++;<br />
						if (count == 2 && lpBuffer[i] != '1') // then the index has been added to the string st<br />
						{<br />
							switch(lpBuffer[i])<br />
							{<br />
							case '2': command = "AT+CMGR=2\n"; delcommand = "AT+CMGD=2\n";<br />
								break;<br />
							case '3': command = "AT+CMGR=3\n"; delcommand = "AT+CMGD=3\n";<br />
								break;<br />
							case '4': command = "AT+CMGR=4\n"; delcommand = "AT+CMGD=4\n";<br />
								break;<br />
							case '5': command = "AT+CMGR=5\n"; delcommand = "AT+CMGD=5\n";<br />
								break;<br />
							case '6': command = "AT+CMGR=6\n"; delcommand = "AT+CMGD=6\n";<br />
								break;<br />
							case '7': command = "AT+CMGR=7\n"; delcommand = "AT+CMGD=7\n";<br />
								break;<br />
							case '8': command = "AT+CMGR=8\n"; delcommand = "AT+CMGD=8\n";<br />
								break;<br />
							case '9': command = "AT+CMGR=9\n"; delcommand = "AT+CMGD=9\n";<br />
								break;<br />
							default: command = "";<br />
								break;<br />
							}<br />
							sendComm = true;							// Send comm to read msg<br />
							st.Empty();<br />
						}<br />
						if (count == 3 && lpBuffer[i-1] == '1' && lpBuffer[i] == '0') // index is 10<br />
						{<br />
							command = "AT+CMGR=10\n"; delcommand = "AT+CMGD=10\n";<br />
							sendComm = true;							// Send comm to read msg<br />
							st.Empty();<br />
						}<br />
						if (count == 3 && lpBuffer[i-1] == '1' && lpBuffer[i] != '0') // index is 1<br />
						{<br />
							command = "AT+CMGR=1\n"; delcommand = "AT+CMGD=1\n";<br />
							sendComm = true;							// Send comm to read msg<br />
							st.Empty();<br />
						}<br />
					}<br />
<br />
					if (st.Find("RING") != -1)<br />
					{<br />
						st.Empty();<br />
					}<br />
<br />
					if (lpBuffer[i-1] == 'O' && lpBuffer[i] == 'K' && st.GetLength() > 20)		// Flag to send string to php script for processing<br />
					{<br />
						sendToDB = true;<br />
					}<br />
				}<br />
			}<br />
<br />
			if (sendToDB)<br />
			{<br />
				CString s_url = "http://localhost/motm/logvote.php?";<br />
				CString s_var = "mess=";<br />
<br />
				CString s_urlMessage = s_url + s_var + st;<br />
		<br />
				char * urlMessage = s_urlMessage.GetBuffer(s_urlMessage.GetLength());<br />
				<br />
				if(InternetSession.OpenURL(urlMessage))<br />
				{<br />
					printf("\nSent\n");<br />
					st.Empty();								// reset the message string<br />
					delComm = true;							// Flag to delete message as it has now been sent<br />
					count = 0;<br />
				}<br />
				sendToDB = false;<br />
<br />
				delete urlMessage;<br />
			}<br />
		}<br />
	}<br />
	else<br />
<br />
		appRunning = false;<br />
<br />
	return 0;<br />
}<br />
<br />