DataInterface_SpawnSystem.cpp

#include<winsock2.h>
#include<stdio.h>
#include"DataInterface.h"

void cb_DataInterface_SpawnSystem_getSpawnPoolList(MYSQL *dbCon, diJob_spawnpool_t *job, void *cb, void *param)
{
	sint8 queryText[4096];
	sprintf(queryText, "SELECT "
		"id,mode,animType,"
		"posx,posy,posz,contextid,"
		// creature slots
		"creatureType1,creatureMinCount1,creatureMaxCount1,"
		"creatureType2,creatureMinCount2,creatureMaxCount2,"
		"creatureType3,creatureMinCount3,creatureMaxCount3,"
		"creatureType4,creatureMinCount4,creatureMaxCount4,"
		"creatureType5,creatureMinCount5,creatureMaxCount5,"
		"creatureType6,creatureMinCount6,creatureMaxCount6"
		" FROM spawnpool");
	// execute query
	if( mysql_query(dbCon, queryText) )
	{
		printf("Error in query\n");
		while(1) Sleep(1000);	
	}
	MYSQL_RES *dbResult = mysql_store_result(dbCon);
	MYSQL_ROW dbRow;
	// parse rows
	sint32 rowCount = mysql_num_rows(dbResult);
	while((dbRow = mysql_fetch_row(dbResult)))
	{
		//"id,mode,animType,"
		//"posx,posy,posz,contextid,"
		//"creatureType1,creatureMinCount1,creatureMaxCount1,"
		//"creatureType2,creatureMinCount2,creatureMaxCount2,"
		//"creatureType3,creatureMinCount3,creatureMaxCount3,"
		//"creatureType4,creatureMinCount4,creatureMaxCount4,"
		//"creatureType5,creatureMinCount5,creatureMaxCount5,"
		//"creatureType6,creatureMinCount6,creatureMaxCount6"
		sint32 idx = 0;
		// general data
		sscanf(dbRow[idx], "%d", &job->id); idx++;
		sscanf(dbRow[idx], "%d", &job->mode); idx++;
		sscanf(dbRow[idx], "%d", &job->animType); idx++;
		// location data
		sscanf(dbRow[idx], "%f", &job->posX); idx++;
		sscanf(dbRow[idx], "%f", &job->posY); idx++;
		sscanf(dbRow[idx], "%f", &job->posZ); idx++;
		sscanf(dbRow[idx], "%d", &job->contextId); idx++;
		// creature spawn slots
		for(sint32 spawnSlot=0; spawnSlot<6; spawnSlot++)
		{
			if( dbRow[idx] == NULL || dbRow[idx+1] == NULL || dbRow[idx+2] == NULL )
			{
				job->spawnSlot[spawnSlot].creatureType = 0;
				idx += 3;
				continue;
			}
			sscanf(dbRow[idx], "%d", &job->spawnSlot[spawnSlot].creatureType); idx++;
			sscanf(dbRow[idx], "%d", &job->spawnSlot[spawnSlot].countMin); idx++;
			sscanf(dbRow[idx], "%d", &job->spawnSlot[spawnSlot].countMax); idx++;
		}
		// do callback param1: mapchannel param2: list of spawnpool data
		((void (*)(void*,void*))cb)(param, job);
	}
	// call with NULL job to inform callback that we are done
	((void (*)(void*,void*))cb)(param, NULL);

	mysql_free_result(dbResult);
	DataInterface_freeJob(job);
}

void DataInterface_SpawnSystem_getSpawnPoolList(void (*cb)(void *param, diJob_spawnpool_t *jobData), void *param)
{	
	diJob_spawnpool_t *job = (diJob_spawnpool_t*)DataInterface_allocJob(sizeof(diJob_spawnpool_t));
	DataInterface_queueJob(job, cb_DataInterface_SpawnSystem_getSpawnPoolList, cb, param);
}