*
	check_cma_requests();
	check_buyer_requests();
	check_price_requests();
	check_sales_requests();
	check_email_requests();

    	mysql_close(&mysql);
}

check_report_requests()
{
	char        *id_str;
	char        *email_str;
	char        *path_str;
	char        *report_str;
	int          i;
	int          ret;
	int          numRows;
	int          num_fields;
	const   char *ptr;

	printf("Checking reports...\n");

	buffer[0] = 0;
    	strcpy(buffer,"select report_request.id, report_request.email, report.report_name, report.path from report_request, report where sent is NULL and report_request.report_name = report.report_name");

    	if( mysql_query(&mysql,buffer) ) {
        	ptr = mysql_error(&mysql);        
        	printf("error in check_report_requests mysql_select-db\n"); fflush(stdout);
        	exit(0);
    	}

    	if( !(result = mysql_store_result(&mysql)) ){
        	ptr = mysql_error(&mysql);
        	printf("error in check_report_requests mysql_store_result\n"); fflush(stdout);
        	exit(0);
    	}

    	while( (row = mysql_fetch_row(result)) ) {
		fields     = mysql_fetch_fields(result);
		num_fields = mysql_num_fields(result);

		id_str     = get_str_value(row, fields, num_fields, "id");
		email_str  = get_str_value(row, fields, num_fields, "email");
		path_str   = get_str_value(row, fields, num_fields, "path");
		report_str = get_str_value(row, fields, num_fields, "report_name");

		printf("Sending report %s\n",report_str);

		ret=send_report(email_str, gbl_agent_email_str, path_str, report_str);	
		if (ret == 0) update_report_db(&mysql, id_str);
    	}

	printf("Done.\n");
}

check_cma_requests()
{
	char        *id_str;
	char        *name_str;
	char        *email_str;
	char        *address_str;
	char        *city_str;
	char        *state_str;
	char        *phone_str;
	int          i;
	int          ret;
	int          numRows;
	int          num_fields;
	const char  *ptr;


	buffer[0] = 0;
    	strcpy(buffer,"select id, name, phone, email, address, city, state from cma_netrequest where sent is NULL");

    	if( mysql_query(&mysql,buffer) ) {
        	ptr = mysql_error(&mysql);        
        	printf("error in check_cma_requests mysql_query: %s\n",ptr); fflush(stdout);
        	exit(0);
    	}

    	if( !(result = mysql_store_result(&mysql)) ){
        	ptr = mysql_error(&mysql);
        	printf("error in check_cma_requests mysql_store_result\n"); fflush(stdout);
        	exit(0);
    	}

    	while( (row = mysql_fetch_row(result)) ) {
		fields     = mysql_fetch_fields(result);
		num_fields = mysql_num_fields(result);

		id_str      = get_str_value(row, fields, num_fields, "id");
		name_str    = get_str_value(row, fields, num_fields, "name");
		email_str   = get_str_value(row, fields, num_fields, "email");
		phone_str   = get_str_value(row, fields, num_fields, "phone");
		address_str = get_str_value(row, fields, num_fields, "address");
		city_str    = get_str_value(row, fields, num_fields, "city");
		state_str   = get_str_value(row, fields, num_fields, "state");

		ret=send_cma_request(gbl_agent_email_str, gbl_agent_email_str, 
				     name_str,email_str,phone_str,address_str,city_str,state_str);	
		if (ret == 0) update_cma_db(&mysql, id_str);
    	}
}

check_buyer_requests()
{
	char        *id_str;
	char        *name_str;
	char        *email_str;
	char        *phone_str;
	int          i;
	int          ret;
	int          numRows;
	int          num_fields;
	const char  *ptr;


	buffer[0] = 0;
    	strcpy(buffer,"select id, name, phone, email from buyer_request where sent is NULL");

    	if( mysql_query(&mysql,buffer) ) {
        	ptr = mysql_error(&mysql);        
        	printf("error in check_buyer_requests mysql_query: %s\n",ptr); fflush(stdout);
        	exit(0);
    	}

    	if( !(result = mysql_store_result(&mysql)) ){
        	ptr = mysql_error(&mysql);
        	printf("error in check_buyer_requests mysql_store_result\n"); fflush(stdout);
        	exit(0);
    	}

    	while( (row = mysql_fetch_row(result)) ) {
		fields     = mysql_fetch_fields(result);
		num_fields = mysql_num_fields(result);

		id_str     = get_str_value(row, fields, num_fields, "id");
		name_str   = get_str_value(row, fields, num_fields, "name");
		email_str  = get_str_value(row, fields, num_fields, "email");
		phone_str  = get_str_value(row, fields, num_fields, "phone");

		ret=send_buyer_request(gbl_agent_email_str, gbl_agent_email_str, 
				     name_str, email_str, phone_str);	
		if (ret == 0) update_buyer_db(&mysql, id_str);
    	}
}


check_sales_requests()
{
	char        *id_str;
	char        *name_str;
	char        *email_str;
	char        *phone_str;
	int          i;
	int          ret;
	int          numRows;
	int          num_fields;
	const char  *ptr;


	buffer[0] = 0;
    	strcpy(buffer,"select id, name, phone, email from area_sales_request where sent is NULL");

    	if( mysql_query(&mysql,buffer) ) {
        	ptr = mysql_error(&mysql);        
        	printf("error in check_sales_request mysql_query: %s\n",ptr); fflush(stdout);
        	exit(0);
    	}

    	if( !(result = mysql_store_result(&mysql)) ){
        	ptr = mysql_error(&mysql);
        	printf("error in check_sales_requests mysql_store_result\n"); fflush(stdout);
        	exit(0);
    	}

    	while( (row = mysql_fetch_row(result)) ) {
		fields     = mysql_fetch_fields(result);
		num_fields = mysql_num_fields(result);

		id_str     = get_str_value(row, fields, num_fields, "id");
		name_str   = get_str_value(row, fields, num_fields, "name");
		email_str  = get_str_value(row, fields, num_fields, "email");
		phone_str  = get_str_value(row, fields, num_fields, "phone");

		ret=send_sales_request(gbl_agent_email_str,gbl_agent_email_str, 
				     name_str, email_str, phone_str);	
		if (ret == 0) update_sales_db(&mysql, id_str);
    	}
}



check_price_requests()
{
	char        *id_str;
	char        *name_str;
	char        *email_str;
	char        *phone_str;
	int          i;
	int          ret;
	int          numRows;
	int          num_fields;
	const char  *ptr;


	buffer[0] = 0;
    	strcpy(buffer,"select id, name, phone, email from price_request where sent is NULL");

    	if( mysql_query(&mysql,buffer) ) {
        	ptr = mysql_error(&mysql);        
        	printf("error in check_price_requests mysql_query: %s\n",ptr); fflush(stdout);
        	exit(0);
    	}

    	if( !(result = mysql_store_result(&mysql)) ){
        	ptr = mysql_error(&mysql);
        	printf("error in check_price_requests mysql_store_result\n"); fflush(stdout);
        	exit(0);
    	}

    	while( (row = mysql_fetch_row(result)) ) {
		fields     = mysql_fetch_fields(result);
		num_fields = mysql_num_fields(result);

		id_str     = get_str_value(row, fields, num_fields, "id");
		name_str   = get_str_value(row, fields, num_fields, "name");
		email_str  = get_str_value(row, fields, num_fields, "email");
		phone_str  = get_str_value(row, fields, num_fields, "phone");

		ret=send_price_request(gbl_agent_email_str,gbl_agent_email_str, 
				     name_str, email_str, phone_str);	
		if (ret == 0) update_price_db(&mysql, id_str);
    	}
}

check_email_requests()
{
	char        *id_str;
	char        *from_email_str;
	char        *to_email_str;
	char        *subject_str;
	char        *message_str;
	char        local_message_str[600];
	int          i;
	int          ret;
	int          numRows;
	int          num_fields;
	const char  *ptr;

	buffer[0] = 0;
    	strcpy(buffer,"select id, from_email, to_email, subject, message from email_request where sent is NULL");

    	if( mysql_query(&mysql,buffer) ) {
        	ptr = mysql_error(&mysql);        
        	printf("error in check_email_requests mysql_select-db\n"); fflush(stdout);
        	exit(0);
    	}

    	if( !(result = mysql_store_result(&mysql)) ){
        	ptr = mysql_error(&mysql);
        	printf("error in check_email_requests mysql_store_result\n"); fflush(stdout);
        	exit(0);
    	}

    	while( (row = mysql_fetch_row(result)) ) {
		fields     = mysql_fetch_fields(result);
		num_fields = mysql_num_fields(result);

		id_str          = get_str_value(row, fields, num_fields, "id");
		from_email_str  = get_str_value(row, fields, num_fields, "from_email");
		to_email_str    = get_str_value(row, fields, num_fields, "to_email");
		subject_str     = get_str_value(row, fields, num_fields, "subject");
		message_str     = get_str_value(row, fields, num_fields, "message");

		local_message_str[0] = 0;
		sprintf(local_message_str,"Your Friend At Email Address: %s\n\nHas Sent You Our Website: http://www.NorthVirginiaHomes.com\n\nWith the Following Message:\n\n%s",
	                from_email_str, message_str);
		ret=send_email(to_email_str, gbl_agent_email_str, subject_str, local_message_str);	
		if (ret == 0) update_email_db(&mysql, id_str);

		local_message_str[0] = 0;
		sprintf(local_message_str,"%s\n%s\n%s\n\n%s",from_email_str,to_email_str,subject_str,message_str);
		ret=send_email(gbl_agent_email_str,gbl_agent_email_str,"Email Sent", local_message_str);	
    	}
}

send_email(char *to_email, char *from_email, char *subject, char *comments)
{
	FILE *cfp;
	FILE *headfp;
	char *s;

	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}

	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",to_email, from_email, subject);
	fprintf(headfp,"%s\n",buffer);

	fprintf(headfp,"%s\n.\n",comments);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", to_email, gbl_home_dir);
	system(buffer);

	return(0);
}

send_report(char *to_email, char *from_email, char *path, char *subject)
{
	FILE *cfp;
	FILE *headfp;
	char *s;
	char  fname[128];

	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}

	buffer[0] = 0;
	sprintf(buffer,"%s/www/reports/%s",gbl_home_dir,path);
	printf("Opening report %s\n",buffer);
	if ((cfp=fopen(buffer,"r")) == NULL)
	{
		fclose(headfp);
		return(-1);
	}

	printf("Creating Email report\n");

	buffer[0] = 0;
	sprintf(buffer,"From: %s\nMIME-Version: 1.0\nTo: %s\nSubject: %s\n",from_email,to_email,subject);
	fprintf(headfp,"%s",buffer);

	while (fgets(buffer, sizeof(buffer), cfp) != NULL)
	{
		fprintf(headfp,"%s",buffer);
	}
	fprintf(headfp,"<br>\n");

        fprintf(headfp,"<p><font face='Arial' size='2' color='#000000'>");
	fprintf(headfp,"%s<br>\n",gbl_agent_name_str);
	fprintf(headfp,"<a href='mailto:%s'>%s<br></a>\n",gbl_agent_email_str,gbl_agent_email_str);
	fprintf(headfp,"<a href='%s'>%s</a><br>\n",gbl_agent_website_str,gbl_agent_website_str);
	fprintf(headfp,"</font>\n");

	fprintf(headfp,"</body>\n");
	fprintf(headfp,"</html>\n");

	fclose(cfp);
	fclose(headfp);

	printf("Sending Email report\n");

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", to_email, gbl_home_dir);
	system(buffer);


	comments[0] = 0;
	sprintf(comments,"%s report was sent to %s",path,to_email);
	send_email(gbl_agent_email_str, gbl_agent_email_str,"** Report Request **",comments);


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}

	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",gbl_agent_txtmsg_email_str, from_email, "** Report Request **");
	fprintf(headfp,"%s",buffer);

	comments[0] = 0;
	sprintf(comments,"%s report was sent to %s.",path, to_email);
	fprintf(headfp,"%s",comments);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", gbl_agent_txtmsg_email_str, gbl_home_dir);
	system(buffer);


	return(0);
}

send_cma_request(char *to_email, char *from_email, char *name, char *email, char *phone, char *address, 
		 char *city, char *state)
{
	FILE *headfp;
	char *s;


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}


	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",to_email, from_email, "** CMA Request **");
	fprintf(headfp,"%s",buffer);

	buffer[0] = 0;
	sprintf(buffer,"\nName: %s\nEmail: %s\nPhone: %s\nAddress: %s\nCity: %s\nState: %s\n",
			name,email,phone,address,city,state);
	fprintf(headfp,"%s",buffer);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", to_email, gbl_home_dir);
	system(buffer);


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}
	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",gbl_agent_txtmsg_email_str, from_email, "** CMA Request **");
	fprintf(headfp,"%s",buffer);

	buffer[0] = 0;
	sprintf(buffer,"\n%s\n%s\n %s\n%s\n%s\n%s\n",name,email,phone,address,city,state);
	fprintf(headfp,"%s",buffer);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", gbl_agent_txtmsg_email_str, gbl_home_dir);
	system(buffer);

	return(0);
}

send_buyer_request(char *to_email, char *from_email, char *name, char *email, char *phone)
{
	FILE *headfp;
	char *s;


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}

	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",to_email, from_email,"** Buyer Request **");
	fprintf(headfp,"%s",buffer);

	buffer[0] = 0;
	sprintf(buffer,"\nName: %s\nEmail: %s\nPhone: %s\n",name,email,phone);
	fprintf(headfp,"%s",buffer);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", to_email, gbl_home_dir);
	system(buffer);


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}
	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",gbl_agent_txtmsg_email_str, from_email, "** Buyer Request **");
	fprintf(headfp,"%s",buffer);

	buffer[0] = 0;
	sprintf(buffer,"\n%s\n%s\n%s\n",name,email,phone);
	fprintf(headfp,"%s",buffer);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", gbl_agent_txtmsg_email_str, gbl_home_dir);
	system(buffer);

	return(0);
}


send_sales_request(char *to_email, char *from_email, char *name, char *email, char *phone)
{
	FILE *headfp;
	char *s;


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}

	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",to_email, from_email,"** Sales Request **");
	fprintf(headfp,"%s",buffer);

	buffer[0] = 0;
	sprintf(buffer,"\nName: %s\nEmail: %s\nPhone: %s\n",name,email,phone);
	fprintf(headfp,"%s",buffer);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", to_email, gbl_home_dir);
	system(buffer);


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}
	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",gbl_agent_txtmsg_email_str, from_email, "** Sales Request **");
	fprintf(headfp,"%s",buffer);

	buffer[0] = 0;
	sprintf(buffer,"\n%s\n%s\n%s\n",name,email,phone);
	fprintf(headfp,"%s",buffer);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", gbl_agent_txtmsg_email_str, gbl_home_dir);
	system(buffer);

	return(0);
}


send_price_request(char *to_email, char *from_email, char *name, char *email, char *phone)
{
	FILE *headfp;
	char *s;


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}

	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",to_email, from_email,"** Price Request **");
	fprintf(headfp,"%s",buffer);

	buffer[0] = 0;
	sprintf(buffer,"\nName: %s\nEmail: %s\nPhone: %s\n",name,email,phone);
	fprintf(headfp,"%s",buffer);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", to_email, gbl_home_dir);
	system(buffer);


	buffer[0] = 0;
	sprintf(buffer,"%s/tmp/auto_send.txt",gbl_home_dir);
	if ((headfp=fopen(buffer,"w")) == NULL)
	{
		return(-1);
	}
	buffer[0] = 0;
	sprintf(buffer,"To: %s\nFrom: %s\nSubject: %s\n",gbl_agent_txtmsg_email_str, from_email, "** Price Request **");
	fprintf(headfp,"%s",buffer);

	buffer[0] = 0;
	sprintf(buffer,"\n%s\n%s\n%s\n",name,email,phone);
	fprintf(headfp,"%s",buffer);

	fclose(headfp);

	buffer[0] = 0;
	sprintf(buffer,"/usr/sbin/sendmail %s < %s/tmp/auto_send.txt", gbl_agent_txtmsg_email_str, gbl_home_dir);
	system(buffer);

	return(0);
}


update_report_db(MYSQL *mysql, char *id_str)
{
	const char *ptr;

	buffer[0] = 0;
	sprintf(buffer,"update report_request set sent=now() where id = %s\n",id_str);

    	if( mysql_query(mysql,buffer) ) {
        	ptr = mysql_error(mysql);        
        	printf("error in mysql_select-db");
        	return(-1);
    	}

	return(0);
}

update_cma_db(MYSQL *mysql, char *id_str)
{
	const char *ptr;

	buffer[0] = 0;
	sprintf(buffer,"update cma_netrequest set sent=now() where id = %s\n",id_str);

    	if( mysql_query(mysql,buffer) ) {
        	ptr = mysql_error(mysql);        
        	printf("error in mysql_select-db");
        	return(-1);
    	}

	return(0);
}

update_buyer_db(MYSQL *mysql, char *id_str)
{
	const char *ptr;

	buffer[0] = 0;
	sprintf(buffer,"update buyer_request set sent=now() where id = %s\n",id_str);

    	if( mysql_query(mysql,buffer) ) {
        	ptr = mysql_error(mysql);        
        	printf("error in mysql_select-db");
        	return(-1);
    	}

	return(0);
}

update_sales_db(MYSQL *mysql, char *id_str)
{
	const char *ptr;

	buffer[0] = 0;
	sprintf(buffer,"update area_sales_request set sent=now() where id = %s\n",id_str);

    	if( mysql_query(mysql,buffer) ) {
        	ptr = mysql_error(mysql);        
        	printf("error in mysql_select-db");
        	return(-1);
    	}

	return(0);
}

update_price_db(MYSQL *mysql, char *id_str)
{
	const char *ptr;

	buffer[0] = 0;
	sprintf(buffer,"update price_request set sent=now() where id = %s\n",id_str);

    	if( mysql_query(mysql,buffer) ) {
        	ptr = mysql_error(mysql);        
        	printf("error in mysql_select-db");
        	return(-1);
    	}

	return(0);
}

update_email_db(MYSQL *mysql, char *id_str)
{
	const char *ptr;

	buffer[0] = 0;
	sprintf(buffer,"update email_request set sent=now() where id = %s\n",id_str);

    	if( mysql_query(mysql,buffer) ) {
        	ptr = mysql_error(mysql);        
        	printf("error in mysql_select-db");
        	return(-1);
    	}

	return(0);
}

char *get_str_value(MYSQL_ROW row, MYSQL_FIELD *fields, int num_fields, char *field_name)
{
	int i;

	for (i = 0; i < num_fields; i++)
	{
		if (strcmp(fields[i].name,field_name) == 0)
		{
			return(row[i]);
		}
	}
}

#include "agent_info.c"

#include "mysql_env.c"
*/