php_server.cpp.svn-base

sigmadesign smp8623 gui source code ,bingo

/* -------------------------------------------------------------------------
 * php_server.cpp - php server functions
 * Copyright (C) 2008 Dimitar Atanasov <[e-mail]>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * -------------------------------------------------------------------------
 */

#include "common.h"
#include "servers.h"
#include <fcntl.h>


void billing(std::string &req, int cfd)
{
	int RoomNo = 0;

	DECODE_BEGIN(req)
		EXTRACT("RN(\\d+)", RoomNo)
	DECODE_END()

	BEGIN_DB()

		std::ostringstream guest_q;
		guest_q << "SELECT GuestNo FROM Room WHERE RoomID=" << RoomNo;
		mysqlpp::StoreQueryResult guest_res = qr.store(guest_q.str().c_str());

		if(guest_res.num_rows() == 0)
		{
			END_DB_RETURN()
			return;
		}

		int GuestNo = guest_res[0][0];

		if(ctxt.is_in_php(RoomNo))
		{
			ctxt.insert_php(cfd, RoomNo, 0, 0);
			std::ostringstream msg;

			std::string RoomName = get_room_name(qr, RoomNo);
			msg << "XR|RN"<<RoomName<<"|G#"<< GuestNo << "|";

			if(ctxt.conf->second_interface)
				send_to_pms(msg, ctxt.pmssock2);
			else
				send_to_pms(msg);
		}
	END_DB()
}

void posting(std::string &req, int cfd)
{
	int RoomNo = 0;
	int Amount = 0;
	int PostingType = 0;

	DECODE_BEGIN(req)
		EXTRACT("RN(\\d+)", RoomNo)
		EXTRACT("TA(\\d+)", Amount)
		EXTRACT("TP(\\d+)", PostingType)
	DECODE_END()

	if(RoomNo == 0)
		return;

	make_gen(RoomNo, Amount, PostingType, cfd, "PHP", 0, "", 0);
}

void who_is (std::string &req, int cfd)
{
	int RoomNo = 0;

	DECODE_BEGIN(req)
		EXTRACT("RN(\\d+)", RoomNo)
	DECODE_END()

	BEGIN_DB()

		int HType = get_h_type(qr, RoomNo);

		std::ostringstream msg;

		msg << "WI|RN" << RoomNo << "|TV";

		if(HType == 0)
			msg << "TN|\r\n";
		else if(HType == 1)
			msg << "TU|\r\n";
		else
			msg << "TM|\r\n";

		send(cfd, msg.str().c_str(), msg.str().length(), 0);
	END_DB()
}

void target_temp(std::string &req, int cfd)
{
	int RoomNo = 0;
	int Amount = 0;

	DECODE_BEGIN(req)
		EXTRACT("RN(\\d+)", RoomNo)
		EXTRACT("MP(\\d+)", Amount)
	DECODE_END()

	if(Amount >= 15 and Amount <= 30)
	{
		BEGIN_DB()

			std::ostringstream temp_zone;
			temp_zone << "UPDATE RoomTZone SET TargetT = " << Amount <<" WHERE RoomID =" << RoomNo;
			mysqlpp::SimpleResult res = qr.execute(temp_zone.str().c_str());

			std::ostringstream msg;
			msg << "TS|RN" << RoomNo;

			//if(res.rows() > 0)
			{

				int season = get_season(qr);

				std::ostringstream temp_q;
				temp_q << "SELECT TZoneID, DefaultGuestT_EmptyRoom,Mode FROM RoomTZone WHERE RoomID=" << RoomNo;
				mysqlpp::StoreQueryResult temp_res = qr.store(temp_q.str().c_str());

				for(uint16 i = 0; i < temp_res.num_rows(); i++)
				{
					std::ostringstream msg_rc;

					msg_rc.fill('0');
					msg_rc << "CLMT:"<< std::setw(2) << temp_res[i][0] - 1 << season << std::setw(2) << Amount << std::setw(2) << temp_res[i][1] << temp_res[i][2] << "*";

					std::string ip = get_rc_ip(qr, RoomNo);
					send_to_rc(ip, msg_rc);
				}

				msg << "|ASOK|\r\n";
			}
			//else
			//	msg << "|ASUR|\r\n";

			send(cfd, msg.str().c_str(), msg.str().length(), 0);
		END_DB()
	}
}

void wake_up(std::string &req, int cfd)
{
	int RoomNo = 0;

	DECODE_BEGIN(req)
		EXTRACT("RN(\\d+)", RoomNo)
	DECODE_END()

	std::ostringstream msg;

	msg << "WA|RN" << RoomNo << "|ASOK|\r\n";
	send(cfd, msg.str().c_str(), msg.str().length(), 0);

	process_command(req);
}

void indicator(std::string &req, int cfd)
{
	int RoomNo = 0;
	int GreenIndic = 0;
	int RedIndic = 0;

	DECODE_BEGIN(req)
		EXTRACT("RN(\\d+)", RoomNo)
		EXTRACT("GI(\\d+)", GreenIndic)
		EXTRACT("RI(\\d+)", RedIndic)
	DECODE_END()

	BEGIN_DB()

		std::ostringstream room_status_q;
		room_status_q << "UPDATE RoomStatus SET GreenIndic=" << GreenIndic << ", RedIndic=" << RedIndic << " WHERE RoomID=" << RoomNo;
		mysqlpp::SimpleResult res = qr.execute(room_status_q.str().c_str());

		std::ostringstream msg;
		msg << "CS|RN" << RoomNo;

		//if(res.rows() > 0)
		{
			std::ostringstream msg_rc;

			msg_rc.fill('0');
			msg_rc << "INDC:"<< GreenIndic << RedIndic << "*";

			std::string ip = get_rc_ip(qr, RoomNo);
			send_to_rc(ip, msg_rc);

			msg << "|ASOK|\r\n";
		}
	//	else
	//		msg << "|ASUR|\r\n";

		send(cfd, msg.str().c_str(), msg.str().length(), 0);
	END_DB()
}

#define DIRTY_VACANT 		1
#define CLEAN_VACANT 		3
#define INSPECTED_VACANT 	5

void status(std::string &req, int cfd)
{
	int RoomNo = 0;

	int PHPRoomStatus = 0;
	int RoomStatus = 0;

	DECODE_BEGIN(req)
		EXTRACT("RN(\\d+)", RoomNo)
		EXTRACT("RS(\\d+)", PHPRoomStatus)
	DECODE_END()

	switch (PHPRoomStatus) {
		case 1: RoomStatus = DIRTY_VACANT; break;
		case 2: RoomStatus = CLEAN_VACANT ;break;
		case 3: RoomStatus = INSPECTED_VACANT ;break;
	}

	BEGIN_DB()

		std::ostringstream guest_q;
		guest_q << "SELECT GuestNo FROM Room WHERE RoomID=" << RoomNo;
		mysqlpp::StoreQueryResult guest_res = qr.store(guest_q.str().c_str());

		std::ostringstream msg;
		msg << "CS|RN" << RoomNo;

		if(guest_res.num_rows() > 0)
		{
			if((int) guest_res[0][0] != 0)
				RoomStatus++;
		}

			if(RoomStatus >=1 && RoomStatus <= 6)
			{
				std::ostringstream room_status_q;
				room_status_q << "UPDATE RoomStatus SET Status=" << RoomStatus << " WHERE RoomID=" << RoomNo;
				mysqlpp::SimpleResult room_status_res = qr.execute(room_status_q.str().c_str());

			//	if(room_status_res.rows() > 0)
				{
					if(ctxt.conf->using_pms)
					{
						std::string sRoomName = get_room_name(qr, RoomNo);
						std::ostringstream msg_pms;

						msg_pms << "RE|RN" << sRoomName << "|RS" << RoomStatus << "|";
						if(ctxt.conf->second_interface)
							send_to_pms(msg_pms, ctxt.pmssock2);
						else
							send_to_pms(msg_pms);
					}

					msg << "|ASOK|\r\n";
				}
				//else
				//{
				//	msg << "|ASNR|\r\n";
				//	logger(ERROR, "Error setting room stattus in RE room %d", RoomNo);
				//}
			}
			else
				msg << "|ASNR|\r\n";

		send(cfd, msg.str().c_str(), msg.str().length(), 0);
	END_DB()

}

void posting_simple_mini(std::string &req, int cfd)
{
	int RoomNo = 0;
	int MA = 0;
	int MN = 0;

	DECODE_BEGIN(req)
		EXTRACT("RN(\\d+)", RoomNo)
		EXTRACT("MA(\\d+)", MA)
		EXTRACT("M\\#(\\d+)", MN)
	DECODE_END()

	BEGIN_DB()

		if(ctxt.is_in_php(RoomNo))
		{
			ctxt.insert_php(cfd, RoomNo, 0, 0);
			std::string sRoomName = get_room_name(qr, RoomNo);

			std::ostringstream msg;
			msg << "PS|RN" << sRoomName << "|PTM|MA" << MA << "|M#" << MN << "|DA" << get_date << "|TI" << get_time <<"|";

			if(ctxt.conf->second_interface)
				send_to_pms(msg, ctxt.pmssock2);
			else
				send_to_pms(msg);
		}
	END_DB()
}

void php_msg_handler(void* msg)
{
	msg_t* _msg = static_cast<msg_t*> (msg);

	mysqlpp::Connection::thread_start();

	pcrecpp::RE("(\\s{2})").Replace("", &_msg->command);

	std::vector<std::string> msg_decomposed;
	pcrecpp::StringPiece input(_msg->command);
	std::string command;

//	int KC_ID = get_KCWS(_msg->ip);

	while(pcrecpp::RE("([\\x20-\\x7B\\x7D-\\xFF]+)\\|").Consume(&input, &command))
	{
		msg_decomposed.push_back(command);
	}

	if(msg_decomposed[0] == "XR")
	{
		billing(_msg->command, _msg->sd);

	} else if(msg_decomposed[0] == "PS")
	{
		posting(_msg->command, _msg->sd);

	} else if(msg_decomposed[0] == "WH")
	{
		who_is(_msg->command, _msg->sd);

	} else if(msg_decomposed[0] == "TT")
	{
		target_temp(_msg->command, _msg->sd);

	}else if(msg_decomposed[0] == "WD")
	{
		wake_up(_msg->command, _msg->sd);

	} else if(msg_decomposed[0] == "WC")
	{
		wake_up(_msg->command, _msg->sd);

	} else if(msg_decomposed[0] == "CI")
	{
		indicator(_msg->command, _msg->sd);

	} else if(msg_decomposed[0] == "RE")
	{
		status(_msg->command, _msg->sd);

	} else if(msg_decomposed[0] == "MS")
	{
		posting_simple_mini(_msg->command, _msg->sd);
	}

	if(_msg)
	{
		delete _msg;
		_msg = NULL;
	}

	mysqlpp::Connection::thread_end();
}

void*
php_server(void* )
{
	return server(ctxt.phpsock, ctxt.conf->php_port, ctxt.conf->php_host, php_msg_handler);
}