2061 lines
56 KiB
C
2061 lines
56 KiB
C
#define _SASQL_C_
|
||
|
||
#include "version.h"
|
||
|
||
//#include "main.h"
|
||
#include "sasql.h"
|
||
#include "net.h"
|
||
#include "common.h"
|
||
#include "char_base.h"
|
||
#include "char_data.h"
|
||
#include "char.h"
|
||
#include "lssproto_serv.h"
|
||
#include "item.h"
|
||
#include "item_event.h"
|
||
#include "buf.h"
|
||
#include "object.h"
|
||
#include "map_deal.h"
|
||
#include "saacproto_cli.h"
|
||
#include "readmap.h"
|
||
#include "handletime.h"
|
||
#include "char_event.h"
|
||
#include "npccreate.h"
|
||
#include "addressbook.h"
|
||
#include "item_event.h"
|
||
#include "magic_base.h"
|
||
#include "magic.h"
|
||
#include "chatmagic.h"
|
||
#include "configfile.h"
|
||
#include "log.h"
|
||
#include "anim_tbl.h"
|
||
#include "encount.h"
|
||
#include "battle.h"
|
||
#include "pet_skill.h"
|
||
#include "util.h"
|
||
#include "enemy.h"
|
||
#include "npcutil.h"
|
||
#include "pet.h"
|
||
#include "family.h"
|
||
#include "defend.h"
|
||
#include "correct_bug.h"
|
||
#include <mysql/mysql.h>
|
||
|
||
extern int fmrankindex[20];
|
||
extern char fmrankname[20][50];
|
||
extern int fmrankpoint[20];
|
||
|
||
MYSQL mysql;
|
||
MYSQL serversql;
|
||
MYSQL_RES *mysql_result;
|
||
MYSQL_ROW mysql_row;
|
||
|
||
void easyGetTokenFromString2( char *src,int count,char*output,int len )
|
||
{
|
||
int i;
|
||
int counter = 0;
|
||
|
||
if( len <= 0 )return;
|
||
|
||
#define ISSPACETAB( c ) ( (c) == ' ' || (c) == '\t' )
|
||
|
||
for(i=0;;i++){
|
||
if( src[i]=='\0'){
|
||
output[0] = '\0';
|
||
return;
|
||
}
|
||
if( i > 0 && ! ISSPACETAB( src[i-1] ) &&
|
||
! ISSPACETAB( src[i] ) ){
|
||
continue;
|
||
}
|
||
|
||
if( ! ISSPACETAB( src[i]) ){
|
||
counter++;
|
||
if( counter == count){
|
||
int j;
|
||
for(j=0;j<len-1;j++){
|
||
if( src[i+j] == '\0' ||
|
||
ISSPACETAB( src[i+j] ) ){
|
||
break;
|
||
}
|
||
output[j]=src[i+j];
|
||
}
|
||
output[j]='\0';
|
||
return;
|
||
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
typedef struct tagConfig
|
||
{
|
||
char sql_IP[16];
|
||
|
||
int sql_Port;
|
||
|
||
char sql_Port1[16];
|
||
|
||
char sql_ID[16];
|
||
|
||
char sql_PS[16];
|
||
|
||
char sql_DataBase[16];
|
||
|
||
char sql_Table[16];
|
||
|
||
char sql_LOCK[16];
|
||
|
||
char sql_NAME[16];
|
||
|
||
char sql_PASS[16];
|
||
}Config;
|
||
|
||
Config sqlconfig;
|
||
|
||
int AutoReg = 0;
|
||
int openbackground;
|
||
int sameipnum = 0;
|
||
|
||
static int readConfig( char *path )
|
||
{
|
||
char buf[255];
|
||
FILE *fp;
|
||
|
||
fp = fopen( path , "r" );
|
||
if( fp == NULL ){ return -2; }
|
||
|
||
while( fgets( buf , sizeof( buf ) , fp )){
|
||
char command[255];
|
||
char param[255];
|
||
chop(buf);
|
||
|
||
easyGetTokenFromString2( buf , 1 , command , sizeof( command ));
|
||
easyGetTokenFromString2( buf , 2 , param , sizeof( param ));
|
||
|
||
if( strcmp( command , "sql_IP" ) == 0 ){
|
||
strcmp( sqlconfig.sql_IP , param ) ;
|
||
snprintf( sqlconfig.sql_IP , sizeof( sqlconfig.sql_IP) , param );
|
||
printf("\n数据库地址： %s",sqlconfig.sql_IP);
|
||
} else if( strcmp( command , "sql_Port" ) == 0 ){
|
||
sqlconfig.sql_Port = atoi( param );
|
||
snprintf( sqlconfig.sql_Port1 , sizeof( sqlconfig.sql_Port1) , param );
|
||
printf("\n数据库端口： %d",sqlconfig.sql_Port);
|
||
} else if( strcmp( command , "sql_ID" ) == 0 ){
|
||
strcmp( sqlconfig.sql_ID , param ) ;
|
||
snprintf( sqlconfig.sql_ID , sizeof( sqlconfig.sql_ID) , param );
|
||
printf("\n数据库用户： %s",sqlconfig.sql_ID);
|
||
} else if( strcmp( command , "sql_PS" ) == 0 ){
|
||
strcmp( sqlconfig.sql_PS , param ) ;
|
||
snprintf( sqlconfig.sql_PS , sizeof( sqlconfig.sql_PS) , param );
|
||
printf("\n数据库密码： %s",sqlconfig.sql_PS);
|
||
} else if( strcmp( command , "sql_DataBase" ) == 0 ){
|
||
strcmp( sqlconfig.sql_DataBase , param ) ;
|
||
snprintf( sqlconfig.sql_DataBase , sizeof( sqlconfig.sql_DataBase) , param );
|
||
printf("\n登陆数据库名：%s",sqlconfig.sql_DataBase);
|
||
} else if( strcmp( command , "sql_Table" ) == 0 ){
|
||
strcmp( sqlconfig.sql_Table , param ) ;
|
||
snprintf( sqlconfig.sql_Table , sizeof( sqlconfig.sql_Table) , param );
|
||
printf("\n用户信息表名： %s",sqlconfig.sql_Table);
|
||
} else if( strcmp( command , "sql_LOCK" ) == 0 ){
|
||
strcmp( sqlconfig.sql_LOCK , param ) ;
|
||
snprintf( sqlconfig.sql_LOCK , sizeof( sqlconfig.sql_LOCK) , param );
|
||
printf("\n用户锁定表名： %s",sqlconfig.sql_LOCK);
|
||
} else if( strcmp( command , "sql_NAME" ) == 0 ){
|
||
strcmp( sqlconfig.sql_NAME , param ) ;
|
||
snprintf( sqlconfig.sql_NAME , sizeof( sqlconfig.sql_NAME) , param );
|
||
printf("\n账号字段名称： %s",sqlconfig.sql_NAME);
|
||
} else if( strcmp( command , "sql_PASS" ) == 0 ){
|
||
strcmp( sqlconfig.sql_PASS , param ) ;
|
||
snprintf( sqlconfig.sql_PASS , sizeof( sqlconfig.sql_PASS) , param );
|
||
printf("\n密码字段名称： %s",sqlconfig.sql_PASS);
|
||
} else if( strcmp( command , "openbackground" ) == 0 ){
|
||
openbackground = atoi( param );
|
||
if(openbackground){
|
||
printf("\n后台功能： YES");
|
||
}else{
|
||
printf("\n后台功能： NO");
|
||
}
|
||
} else if( strcmp( command , "AutoReg" ) == 0 ){
|
||
AutoReg = atoi( param );
|
||
if(AutoReg){
|
||
printf("\n开放自动注册：YES");
|
||
}else{
|
||
printf("\n开放自动注册：NO");
|
||
}
|
||
} else if( strcmp( command , "SameIpNum" ) == 0 ){
|
||
sameipnum = atoi( param );
|
||
}
|
||
}
|
||
fclose(fp);
|
||
return 0;
|
||
}
|
||
|
||
BOOL sasql_init( void )
|
||
{
|
||
if( mysql_init(&mysql) == NULL & readConfig("sql.cf"))
|
||
{
|
||
printf("\n数据库初始化失败！");
|
||
exit(1);
|
||
return FALSE;
|
||
}
|
||
|
||
if( !mysql_real_connect( &mysql,
|
||
sqlconfig.sql_IP,
|
||
sqlconfig.sql_ID,//帐号
|
||
sqlconfig.sql_PS,//密码
|
||
sqlconfig.sql_DataBase,//选择的资料库
|
||
sqlconfig.sql_Port,
|
||
NULL,
|
||
0 ) )
|
||
{
|
||
printf("\n数据库连接失败！\n");
|
||
return FALSE;
|
||
}
|
||
|
||
printf("\n数据库连接成功！\n");
|
||
return TRUE;
|
||
}
|
||
|
||
int sasql_mysql_query( char *sqlstr )
|
||
{
|
||
mysql_query(&mysql,"set names 'gbk'");
|
||
return mysql_query(&mysql,sqlstr);
|
||
}
|
||
|
||
void sasql_close( void )
|
||
{
|
||
mysql_close( &mysql );
|
||
}
|
||
|
||
|
||
int sasql_query(char *nm, char *pas){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `%s`,`%s`,`SafePasswd`,`Lock` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_NAME,sqlconfig.sql_PASS,sqlconfig.sql_Table,sqlconfig.sql_NAME,nm);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(mysql_row[2]!=NULL){
|
||
if((strcmp(pas,mysql_row[1]) == 0) && (atoi(mysql_row[3])==0 || atoi(mysql_row[3])==getLockType())){
|
||
return 1;
|
||
}else{
|
||
//printf("用户%s密码错误！\n",nm);
|
||
return 2;
|
||
}
|
||
}else
|
||
{
|
||
if(strcmp(pas,mysql_row[1]) == 0 && atoi(mysql_row[3])==0){
|
||
return 1;
|
||
}else{
|
||
//printf("用户%s密码错误！\n",nm);
|
||
return 2;
|
||
}
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
//printf("用户%s未注册！\n",nm);
|
||
return 3;
|
||
}
|
||
}else{
|
||
//printf("\n数据库查找失败！\n");
|
||
return 0;
|
||
}
|
||
}
|
||
|
||
int sasql_load_query(char *nm, char *pas){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `%s`,`%s` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_NAME,sqlconfig.sql_PASS,sqlconfig.sql_Table,sqlconfig.sql_NAME,nm);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(strcmp(pas,mysql_row[1]) == 0){
|
||
return 1;
|
||
}else{
|
||
printf("用户%s密码错误！\n",nm);
|
||
return 2;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
printf("用户%s未注册！\n",nm);
|
||
return 3;
|
||
}
|
||
}else{
|
||
printf("\n数据库查找失败！\n");
|
||
return 0;
|
||
}
|
||
}
|
||
|
||
int sasql_del_query(char *nm, char *pas){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `%s`,`SafePasswd` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_NAME,sqlconfig.sql_Table,sqlconfig.sql_NAME,nm);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(mysql_row[1]!=NULL)
|
||
{
|
||
if(strcmp(pas,mysql_row[1]) == 0){
|
||
return 1;
|
||
}else{
|
||
return 2;
|
||
}
|
||
}else{
|
||
printf("用户%s密码错误！\n",nm);
|
||
return 2;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
printf("用户%s未注册！\n",nm);
|
||
return 3;
|
||
}
|
||
}else{
|
||
printf("\n数据库查找失败！\n");
|
||
return 0;
|
||
}
|
||
}
|
||
|
||
|
||
|
||
BOOL sasql_online( char *ID, char *NM, char *IP,int fame,int vigor, int flag )
|
||
{
|
||
if(openbackground){
|
||
char sqlstr[256];
|
||
if(flag==0)
|
||
sprintf(sqlstr,"update `%s` set `Online`=0,`Offline`=0 where `%s`=BINARY'%s'", sqlconfig.sql_Table, sqlconfig.sql_NAME, ID);
|
||
else if(flag==1)
|
||
{
|
||
if(strstr(NM,",")!=NULL) return FALSE;
|
||
mysql_query(&mysql,"SET NAMES 'gbk'");
|
||
sprintf(sqlstr,"update `%s` set `LoginTime`=NOW(), `IP`='%s', `OnlineName`='%s', `Online`=%d, `Path`='char/0x%x',`Fame`=%d,`Vigor`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, IP, NM, getServernumber(), getHash(ID) & 0xff,fame,vigor, sqlconfig.sql_NAME, ID);
|
||
}
|
||
else if(flag==2){
|
||
if(strstr(NM,",")!=NULL) return FALSE;
|
||
sprintf(sqlstr,"update `%s` set `LoginTime`=NOW(), `OnlineName`='%s', `Online`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, NM, getServernumber(), sqlconfig.sql_NAME, ID);
|
||
}
|
||
else if(flag==3)
|
||
sprintf(sqlstr,"update `%s` set `Online`=0,`Offline`=0 where `Online`=%d", sqlconfig.sql_Table, getServernumber());
|
||
else if(flag==4)
|
||
sprintf(sqlstr,"update `%s` set `LoginTime`=NOW(),`IP`='%s', `Online`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, IP, getServernumber(), sqlconfig.sql_NAME, ID);
|
||
else if(flag==5)
|
||
sprintf(sqlstr,"update `%s` set `Offline`=1 where `%s`=BINARY'%s'", sqlconfig.sql_Table, sqlconfig.sql_NAME, ID);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return TRUE;
|
||
}
|
||
}
|
||
printf("\n更新数据库失败！\n");
|
||
return FALSE;
|
||
}
|
||
|
||
/*
|
||
BOOL sasql_online_jqm( char *ID, char *jqm, char *IP, int logintype, char *GHid, char *GHic, char *GHsp )
|
||
{
|
||
if(openbackground){
|
||
|
||
char sqlstr[2048];
|
||
if(strstr(jqm,",")!=NULL || strstr(jqm,"+")!=NULL || strstr(jqm,"?")!=NULL || strstr(jqm,"*")!=NULL || strstr(jqm,"<")!=NULL || strstr(jqm,")")!=NULL || strstr(jqm,"^")!=NULL || strstr(jqm,"`")!=NULL || strstr(jqm,";")!=NULL)
|
||
sprintf(sqlstr,"update `%s` set `LoginTime`=NOW(),`IP`='%s',`PcId`='CUOWU', `Online`=%d,`Type`=%d,`GHid`='%s',`GHic`='%s',`GHsp`='%s' where `%s`=BINARY'%s'", sqlconfig.sql_Table, IP, getServernumber(),logintype,GHid,GHic,GHsp, sqlconfig.sql_NAME, ID);
|
||
else
|
||
sprintf(sqlstr,"update `%s` set `LoginTime`=NOW(),`IP`='%s',`PcId`='%s', `Online`=%d,`Type`=%d,`GHid`='%s',`GHic`='%s',`GHsp`='%s' where `%s`=BINARY'%s'", sqlconfig.sql_Table, IP,jqm, getServernumber(),logintype,GHid,GHic,GHsp, sqlconfig.sql_NAME, ID);
|
||
//print("\n sql: %s",sqlstr);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return TRUE;
|
||
}
|
||
}
|
||
printf("\n更新数据库失败！\n");
|
||
return FALSE;
|
||
}
|
||
*/
|
||
|
||
BOOL sasql_online_jqm( char *ID, char *jqm, char *IP,int logintype )
|
||
{
|
||
if(openbackground){
|
||
|
||
char sqlstr[256];
|
||
if(strstr(jqm,",")!=NULL || strstr(jqm,"+")!=NULL || strstr(jqm,"?")!=NULL || strstr(jqm,"*")!=NULL || strstr(jqm,"<")!=NULL || strstr(jqm,")")!=NULL || strstr(jqm,"^")!=NULL || strstr(jqm,"`")!=NULL || strstr(jqm,";")!=NULL)
|
||
sprintf(sqlstr,"update `%s` set `LoginTime`=NOW(),`IP`='%s',`PcId`='CUOWU', `Online`=%d,`Type`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, IP, getServernumber(),logintype, sqlconfig.sql_NAME, ID);
|
||
else
|
||
sprintf(sqlstr,"update `%s` set `LoginTime`=NOW(),`IP`='%s',`PcId`='%s', `Online`=%d,`Type`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, IP,jqm, getServernumber(),logintype, sqlconfig.sql_NAME, ID);
|
||
//print("\n sql: %s",sqlstr);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return TRUE;
|
||
}
|
||
}
|
||
printf("\n更新数据库失败！\n");
|
||
return FALSE;
|
||
}
|
||
|
||
#ifdef _CAX_NEWMAC_LOGIN
|
||
BOOL sasql_online_mac( char *ID, char *mac, char *IP,int logintype )
|
||
{
|
||
// if(openbackground){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"update `%s` set `LoginTime`=NOW(),`IP`='%s',`MAC`='%s', `Online`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, IP, mac , getServernumber(), sqlconfig.sql_NAME, ID);
|
||
if(!sasql_mysql_query(sqlstr)){
|
||
return TRUE;
|
||
}
|
||
// }
|
||
printf("\n更新数据库失败[mac]！\n");
|
||
return FALSE;
|
||
}
|
||
#endif
|
||
|
||
BOOL sasql_register(char *id, char *ps)
|
||
{
|
||
char sqlstr[256];
|
||
if(AutoReg!=1)return FALSE;
|
||
sprintf(sqlstr,"INSERT INTO `%s` (`%s`,`%s`,`RegTime`,`Path`,`VipPoint`) VALUES (BINARY'%s','%s',NOW(),'char/0x%x',0)",sqlconfig.sql_Table, sqlconfig.sql_NAME, sqlconfig.sql_PASS, id, ps, getHash(id) & 0xff);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
printf("\n新用户注册成功！\n");
|
||
return TRUE;
|
||
}
|
||
printf("\n新用户注册失败！\n");
|
||
return FALSE;
|
||
}
|
||
|
||
|
||
|
||
BOOL sasql_chehk_lock( char *idip )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `%s` where `%s`=BINARY'%s'", sqlconfig.sql_LOCK, sqlconfig.sql_NAME, idip);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0)
|
||
{
|
||
return TRUE;
|
||
}
|
||
else
|
||
{
|
||
return FALSE;
|
||
}
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOL sasql_add_lock( char *idip )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"INSERT INTO `%s` (`%s`) VALUES (BINARY'%s')", sqlconfig.sql_LOCK, sqlconfig.sql_NAME, idip);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
printf("\n添加锁定%s成功！\n",idip);
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOL sasql_del_lock( char *idip )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"delete from `%s` where `%s`=BINARY'%s'", sqlconfig.sql_LOCK, sqlconfig.sql_NAME, idip);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
printf("\n解除锁定%s成功！\n",idip);
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
int sasql_vippoint( char *ID, int point, int flag )
|
||
{
|
||
char sqlstr[256];
|
||
// print("\NVIPpoint1=%d\n",point);
|
||
if(strstr(ID,"'")!=NULL) return -1;
|
||
sprintf(sqlstr,"select `VipPoint` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,ID);
|
||
// printf("22222222:%s\n",sqlstr);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(flag==0){
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
if(flag==520){
|
||
sprintf(sqlstr,"update `%s` set `VipPoint`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, point,sqlconfig.sql_NAME, ID);
|
||
}else{
|
||
point+=atoi(mysql_row[0]);
|
||
sprintf(sqlstr,"update `%s` set `VipPoint`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, point,sqlconfig.sql_NAME, ID);
|
||
}
|
||
// printf("33333333:%s\n",sqlstr);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return point;
|
||
}else{
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
printf("更新会员点数失败！-- %s\n",sqlstr);
|
||
return -1;
|
||
}
|
||
|
||
|
||
int sasql_onlinenum( char *cdkey, char *IP )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `%s` where `%s`='%s' and `Online`>0 and `IP`='%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey,IP);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0){
|
||
return 0;
|
||
}
|
||
}
|
||
sprintf(sqlstr,"select count(*) from `%s` where `Online`>0 and `Offline`=0 and `IP`='%s'",sqlconfig.sql_Table,IP);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
int sasql_onlinejqmnum( char *jqm, int flag )
|
||
{
|
||
char sqlstr[256];
|
||
// sprintf(sqlstr,"select * from `%s` where `%s`='%s' and `Online`>0 and `PcId`='%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey,jqm);
|
||
// if(!mysql_query(&mysql,sqlstr)){
|
||
// int num_row=0;
|
||
// mysql_result=mysql_store_result(&mysql);
|
||
// num_row=mysql_num_rows(mysql_result);
|
||
// mysql_free_result(mysql_result);
|
||
// if(num_row>0){
|
||
// return 0;
|
||
// }
|
||
// }
|
||
if(flag == 1){
|
||
sprintf(sqlstr,"select count(*) from `%s` where `Online`=%d and `Offline`=0 and `PcId`='%s'",sqlconfig.sql_Table,getServernumber(),jqm);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
}else{
|
||
sprintf(sqlstr,"select count(*) from `%s` where `Online`>0 and `Offline`=0 and `PcId`='%s'",sqlconfig.sql_Table,jqm);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
#ifdef _CAX_NEWMAC_LOGIN
|
||
int sasql_onlinemacnum( char *mac, int flag )
|
||
{
|
||
char sqlstr[256];
|
||
if(flag == 1){
|
||
sprintf(sqlstr,"select count(*) from `%s` where `Online`=%d and `MAC`='%s'",sqlconfig.sql_Table,getServernumber(),mac);
|
||
if(!sasql_mysql_query(sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
}else{
|
||
sprintf(sqlstr,"select count(*) from `%s` where `Online`>0 and `MAC`='%s'",sqlconfig.sql_Table,mac);
|
||
if(!sasql_mysql_query(sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
}
|
||
return 0;
|
||
}
|
||
#endif
|
||
|
||
int sasql_query_safepasswd(char *id, char *safepasswd){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `SafePasswd` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,id);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(mysql_row[0]!=NULL)
|
||
{
|
||
if(strcmp(safepasswd,mysql_row[0]) == 0)
|
||
{
|
||
if(strstr(id,safepasswd)!=NULL)
|
||
return 4;
|
||
return 1;
|
||
}
|
||
else
|
||
{
|
||
printf("\n安全码输入错误！\n");
|
||
return 2;
|
||
}
|
||
}
|
||
else
|
||
{
|
||
printf("\n用户未填写安全码！\n");
|
||
return 3;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
else{
|
||
printf("\n数据库查找失败！\n");
|
||
return 0;
|
||
}
|
||
}
|
||
|
||
int sasql_add_safepasswd(char *id, char *safepasswd){
|
||
char sqlstr[256];
|
||
if(strstr(safepasswd,",")!=NULL) return 0;
|
||
sprintf(sqlstr,"update `%s` set `SafePasswd`=BINARY'%s' where `%s`=BINARY'%s'",sqlconfig.sql_Table,safepasswd,sqlconfig.sql_NAME,id);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
printf("用户%s设置安全码成功！\n",id);
|
||
return 1;
|
||
}else{
|
||
printf("\n数据库查找失败！\n");
|
||
return 0;
|
||
}
|
||
}
|
||
|
||
BOOL sasql_add_card(char *pas, int num)
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"INSERT INTO `OnlineCost` (`CostPasswd`,`CostVal`) VALUES (BINARY'%s','%d')", pas, num);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
void sasql_query_card(char *id, char *cardps,int charaindex){
|
||
char sqlstr[256];
|
||
if(strstr(id,",")!=NULL){
|
||
CHAR_talkToCli( charaindex, -1, "您的账号非法。", CHAR_COLORRED);
|
||
return;
|
||
}
|
||
if(strlen(cardps)!=16){
|
||
CHAR_talkToCli( charaindex, -1, "卡密不存在。", CHAR_COLORRED);
|
||
return;
|
||
}
|
||
if( strstr(cardps,"/")!=NULL || strstr(cardps,"*")!=NULL || strstr(cardps,"+")!=NULL || strstr(cardps,"-")!=NULL || strstr(cardps,";")!=NULL || strstr(cardps,":")!=NULL || strstr(cardps," ")!=NULL || strstr(cardps,"|")!=NULL || strstr(cardps,".")!=NULL || strstr(cardps,",")!=NULL || strstr(cardps,"'")!=NULL || strstr(cardps,"=")!=NULL || strstr(cardps,"`")!=NULL || strstr(cardps,"<")!=NULL || strstr(cardps,">")!=NULL || strstr(cardps,"!")!=NULL || strstr(cardps,"NULL")!=NULL){
|
||
CHAR_talkToCli( charaindex, -1, "卡密非法。", CHAR_COLORRED);
|
||
return;
|
||
}
|
||
sprintf(sqlstr,"select * from `OnlineCost` where `CostPasswd`=BINARY'%s'",cardps);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
int check,costval;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
check = atoi(mysql_row[4]);
|
||
costval = atoi(mysql_row[1]);
|
||
if(check == 1)
|
||
{
|
||
sprintf(sqlstr,"update `OnlineCost` set `cdkey`=BINARY'%s', `CostTime`=NOW(), `check`=0 where `CostPasswd`=BINARY'%s'",id,cardps);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
sprintf(sqlstr,"%d现金冲值成功，您现在的现金帐户金额为：%d",costval,sasql_rmbpoint(id,costval,1));
|
||
CHAR_talkToCli( charaindex, -1, sqlstr, CHAR_COLORRED);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
CHAR_talkToCli( charaindex, -1, "该冲值卡已经被使用，请勿重复使用，谢谢！", CHAR_COLORRED); //冲值卡已经使用
|
||
return;
|
||
}
|
||
}
|
||
else
|
||
{
|
||
mysql_free_result(mysql_result);
|
||
CHAR_talkToCli( charaindex, -1, "冲值卡密码填写错误，请重新填写！", CHAR_COLORRED); //冲值卡填写错误
|
||
return;
|
||
}
|
||
}
|
||
else{
|
||
printf("\n数据库查找失败！\n");
|
||
return;
|
||
}
|
||
}
|
||
|
||
|
||
#ifdef _ONLINE_SHOP
|
||
int sasql_chehk_shop( char *dataname )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `%s`", dataname);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return num_row;
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
char* sasql_query_shop( char *dataname, int startrow, int shopnum )
|
||
{
|
||
char sqlstr[256];
|
||
char shopresult[2048];
|
||
int i;
|
||
sprintf(sqlstr,"select * from `%s` LIMIT %d , %d", dataname, startrow, shopnum);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
for(i=1;i<=shopnum;i++)
|
||
{
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
if(i==1)
|
||
{
|
||
sprintf(shopresult,"%s#%s#%s#%s#%s#%s#%s|",mysql_row[0],mysql_row[1],mysql_row[2],mysql_row[3],mysql_row[4],mysql_row[5],mysql_row[6]);
|
||
}
|
||
else
|
||
{
|
||
sprintf(shopresult,"%s%s#%s#%s#%s#%s#%s#%s|",shopresult,mysql_row[0],mysql_row[1],mysql_row[2],mysql_row[3],mysql_row[4],mysql_row[5],mysql_row[6]);
|
||
}
|
||
}
|
||
mysql_free_result(mysql_result);
|
||
return shopresult;
|
||
}else
|
||
{
|
||
mysql_free_result(mysql_result);
|
||
return "err";
|
||
}
|
||
}
|
||
return "err";
|
||
}
|
||
|
||
int sasql_buy_shop( char *dataname, int startrow, int shopnum, int shopno )
|
||
{
|
||
char sqlstr[256];
|
||
int i,costnum;
|
||
sprintf(sqlstr,"select * from `%s` where `id`=%d", dataname, shopno);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
costnum = atoi(mysql_row[5])*atoi(mysql_row[4])/100;
|
||
return costnum;
|
||
}else
|
||
{
|
||
mysql_free_result(mysql_result);
|
||
return 0;
|
||
}
|
||
}
|
||
return 0;
|
||
}
|
||
#endif
|
||
|
||
char* sasql_query_question(void)
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `Question`");
|
||
if(!mysql_query(&mysql,sqlstr))
|
||
{
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0)
|
||
{
|
||
srand((unsigned)time(NULL));
|
||
int questionid;
|
||
questionid = (rand() % num_row)+1;
|
||
sprintf(sqlstr,"select * from `Question` where `id`=%d",questionid);
|
||
if(!mysql_query(&mysql,sqlstr))
|
||
{
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0)
|
||
{
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
char question[256];
|
||
sprintf(question,"%s;%s",mysql_row[1],mysql_row[2]);
|
||
return question;
|
||
}
|
||
return "err";
|
||
}
|
||
return "err";
|
||
}
|
||
return "err";
|
||
}
|
||
return "err";
|
||
}
|
||
|
||
#ifdef _ALL_ITEM
|
||
int sasql_allnum( int flag, int num, int flag1 )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `AllNum` where `id`=%d",flag);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(flag1==0){
|
||
return atoi(mysql_row[1]);
|
||
}
|
||
num+=atoi(mysql_row[1]);
|
||
sprintf(sqlstr,"update `AllNum` set `num`=%d where `id`=%d", num,flag);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return num;
|
||
}
|
||
}
|
||
}
|
||
return num;
|
||
}
|
||
#endif
|
||
|
||
BOOL sasql_craete_lock( void )
|
||
{
|
||
|
||
}
|
||
|
||
BOOL sasql_craete_userinfo( void )
|
||
{
|
||
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
#ifdef _SQL_BUY_FUNC
|
||
char *sasql_OnlineBuy( char *id, char *costpasswd )
|
||
{
|
||
char sqlstr[256];
|
||
if(strstr(id,",")!=NULL) return "提货失败，您的账号非法！";
|
||
if(strlen(costpasswd)!=16){
|
||
return "卡密不存在。";
|
||
}
|
||
if( strstr(costpasswd,"/")!=NULL || strstr(costpasswd,"*")!=NULL || strstr(costpasswd,"+")!=NULL || strstr(costpasswd,"-")!=NULL || strstr(costpasswd,";")!=NULL || strstr(costpasswd,":")!=NULL || strstr(costpasswd," ")!=NULL || strstr(costpasswd,"|")!=NULL || strstr(costpasswd,".")!=NULL || strstr(costpasswd,",")!=NULL || strstr(costpasswd,"'")!=NULL || strstr(costpasswd,"=")!=NULL || strstr(costpasswd,"`")!=NULL || strstr(costpasswd,"<")!=NULL || strstr(costpasswd,">")!=NULL || strstr(costpasswd,"!")!=NULL || strstr(costpasswd,"NULL")!=NULL){
|
||
return "卡密非法。";
|
||
}
|
||
static char token[256]="";
|
||
sprintf(sqlstr,"select `CostStr`, `check` from `OnlineBuy` where CostPasswd = BINARY'%s'", costpasswd);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(atoi(mysql_row[1]) == 1){
|
||
char *coststr = mysql_row[0];
|
||
sprintf(sqlstr,"update OnlineBuy set cdkey=BINARY'%s', CostTime=NOW(), `check`=0 where CostPasswd=BINARY'%s'", id, costpasswd);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
printf("提货卡号%s已提取！\n",costpasswd);
|
||
}
|
||
sprintf(token, "%c|%s", costpasswd[0], coststr);
|
||
|
||
return token;
|
||
}else{
|
||
return "该提货卡已使用过，请勿重复使用！";
|
||
}
|
||
}else{
|
||
return "提货失败，该提货卡密码不正确！";
|
||
}
|
||
}
|
||
return "提货失败，请与本服管理员联系！";
|
||
}
|
||
void sasql_OnlineBuy_add( char *coststr, int type, int num )
|
||
{
|
||
char sqlstr[256];
|
||
char CostPasswd[32];
|
||
int i, j, k=0;
|
||
for(i=0;i<num;i++){
|
||
memset( CostPasswd, 0, sizeof( CostPasswd ) );
|
||
CostPasswd[0]='0' + type;
|
||
for(j=1;j<16;j++){
|
||
if(rand() % 2==0){
|
||
CostPasswd[j]=(rand() % 26) + 65;
|
||
}else{
|
||
CostPasswd[j]=(rand() % 10) + 48;
|
||
}
|
||
}
|
||
sprintf(sqlstr,"INSERT INTO OnlineBuy (CostPasswd, CostStr) VALUES (BINARY'%s', '%s')", CostPasswd, coststr);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
mysql_result=mysql_store_result(&mysql);
|
||
mysql_free_result(mysql_result);
|
||
k++;
|
||
}else{
|
||
break;
|
||
}
|
||
}
|
||
if(type <= 0){
|
||
printf("成功添加%d条宠物提货卡\n", k);
|
||
}else if(type == 1){
|
||
printf("成功添加%d条物品提货卡\n", k);
|
||
}else if(type >= 2){
|
||
printf("成功添加%d条石币提货卡\n", k);
|
||
}
|
||
return ;
|
||
}
|
||
#endif
|
||
|
||
#ifdef _PET_RESET
|
||
int sasql_resetpet_point(int petno){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `Point` from `PetReset` where `PetNo`='%d'",petno);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(atoi(mysql_row[0]) >= 0){
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
return -1;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_resetbdpet_point(int petno){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `BdPoint` from `PetReset` where `PetNo`='%d'",petno);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(atoi(mysql_row[0]) > 0){
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
return -1;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
#endif
|
||
|
||
#ifdef _ZHIPIAO_SYSTEM
|
||
int sasql_zhipiao_insert(char *petno,char *cdkey,int point){
|
||
char sqlstr[256];
|
||
char ip[32];
|
||
if(strstr(cdkey,",")!=NULL) return -1;
|
||
//print("\npoint=%d\n",point);
|
||
sprintf(sqlstr,"select `IP` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(atoi(mysql_row[0]) >= 0){
|
||
sprintf(ip,mysql_row[0]);
|
||
}else{
|
||
return -1;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}
|
||
sprintf(sqlstr,"INSERT INTO ZhiPiao (PiaoNo, Point,Cdkey1,Date1,IP1) VALUES (BINARY'%s', %d,'%s',NOW(),'%s')", petno, point,cdkey,ip);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_zhipiao_query(char *piaono){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `Point`,`check` from `ZhiPiao` where `PiaoNo`='%s'",piaono);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(atoi(mysql_row[1]) == 1){
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
return 0;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_zhipiao_update(char *cdkey,char *piaono,int checktype){
|
||
if(strstr(cdkey,",")!=NULL) return -1;
|
||
char sqlstr[256];
|
||
char ip[32];
|
||
sprintf(sqlstr,"select `IP` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(atoi(mysql_row[0]) >= 0){
|
||
sprintf(ip,mysql_row[0]);
|
||
}else{
|
||
return -1;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}
|
||
sprintf(sqlstr,"update ZhiPiao set Cdkey2=BINARY'%s', Date2=NOW(), `IP2`='%s', `check`=%d where PiaoNo=BINARY'%s'", cdkey,ip ,checktype,piaono);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
#endif
|
||
#ifdef _FMRANK_POINT
|
||
int sasql_fm_query(void){
|
||
char sqlstr[256];
|
||
mysql_query(&mysql,"SET NAMES 'gbk'");
|
||
sprintf(sqlstr,"select * from `FmRank` ORDER by `Point` desc");
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
int i=0;
|
||
while((mysql_row=mysql_fetch_row(mysql_result)) && i<20){
|
||
fmrankindex[i]=atoi(mysql_row[0]);
|
||
sprintf(fmrankname[i],"%s",mysql_row[1]);
|
||
fmrankpoint[i]=atoi(mysql_row[2]);
|
||
i++;
|
||
}
|
||
mysql_free_result(mysql_result);
|
||
return i;
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_fmpoint_query(int fmindex){
|
||
char sqlstr[256];
|
||
mysql_query(&mysql,"SET NAMES 'gbk'");
|
||
sprintf(sqlstr,"select `Point` from `FmRank` where `Index`='%d'",fmindex);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_fmno_query(int fmindex){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `Index` from `FmRank` ORDER by `Point` desc");
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
int i=1;
|
||
while((mysql_row=mysql_fetch_row(mysql_result))){
|
||
if(atoi(mysql_row[0])==fmindex)
|
||
return i;
|
||
i++;
|
||
}
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_fmpoint_add(int fmindex,int point){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"update `FmRank` set `Point`=%d where `Index`=%d",point,fmindex);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_fmindex_add(int fmindex,char *fmname,int point){
|
||
char sqlstr[256];
|
||
mysql_query(&mysql,"SET NAMES 'gbk'");
|
||
sprintf(sqlstr,"INSERT INTO `FmRank` (`Index`,`Name`,`Point`) VALUES (%d,'%s',%d)",fmindex,fmname,point);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_fmindex_del(int fmindex){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"DELETE FROM `FmRank` where `Index`=%d",fmindex);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
#endif
|
||
#ifdef _ITEM_RESET
|
||
int sasql_itemreset_query(int itemid){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `ResetPoint` from `ItemReset` where `Id`='%d'",itemid);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
int sasql_itemdel_query(int itemid){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `DelPoint` from `ItemReset` where `Id`='%d'",itemid);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return -1;
|
||
}
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
#endif
|
||
|
||
int sasql_cdkey_lock(char *cdkey,int locktype){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME, cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
sprintf(sqlstr,"update `%s` set `Lock`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table,locktype,sqlconfig.sql_NAME, cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return -1;
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int sasql_ampoint( char *ID, int point, int flag )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `AmPoint` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,ID);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(flag==0){
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
point+=atoi(mysql_row[0]);
|
||
sprintf(sqlstr,"update `%s` set `AmPoint`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, point,sqlconfig.sql_NAME, ID);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return point;
|
||
}else{
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
printf("更新%s积分失败！\n",ID);
|
||
return -1;
|
||
}
|
||
|
||
#ifdef _RMB_SYSTEM
|
||
int sasql_rmbpoint( char *ID, int point, int flag )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `RMBPOINT` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,ID);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(flag==0){
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
point+=atoi(mysql_row[0]);
|
||
sprintf(sqlstr,"update `%s` set `RMBPOINT`=%d where `%s`=BINARY'%s'", sqlconfig.sql_Table, point,sqlconfig.sql_NAME, ID);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return point;
|
||
}else{
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
printf("更新%s现金失败！\n",ID);
|
||
return -1;
|
||
}
|
||
#endif
|
||
|
||
int sasql_cdkey_online( char *cdkey )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `Online` from `%s` where `%s`='%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
return 0;
|
||
}
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
int sasql_check_iponline( char *IP )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `%s` where `IP`='%s'",sqlconfig.sql_Table,IP);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0){
|
||
return 1;
|
||
}else{
|
||
return 0;
|
||
}
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
#ifdef _EV_NUM
|
||
char* sasql_ev_npcmsg( int npcno )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `EvNpc` where `No`='%d'",npcno);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return mysql_row[1];
|
||
}
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
return "err";
|
||
}
|
||
|
||
char* sasql_ev_item( void )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select count(*) from `EvItem`");
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
int itemno;
|
||
itemno = RAND(1,atoi(mysql_row[0]));
|
||
sprintf(sqlstr,"select `Id`,`MixNum`,`MaxNum` from `EvItem` where `No`='%d'",itemno);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
int itemnum = RAND(atoi(mysql_row[1]),atoi(mysql_row[2]));
|
||
sprintf(sqlstr,"%d|%d",atoi(mysql_row[0]),itemnum);
|
||
return sqlstr;
|
||
}
|
||
}
|
||
}
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
return "err";
|
||
}
|
||
|
||
char* sasql_ev_pet( void )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select count(*) from `EvPet`");
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
int petno;
|
||
petno = RAND(1,atoi(mysql_row[0]));
|
||
sprintf(sqlstr,"select `PicId`,`Name`,`MixLv`,`MaxLv` from `EvItem` where `No`='%d'",petno);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
sprintf(sqlstr,"%d|%s|%d|%d",atoi(mysql_row[0]),mysql_row[1],atoi(mysql_row[2]),atoi(mysql_row[3]));
|
||
return sqlstr;
|
||
}
|
||
}
|
||
}
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
return "err";
|
||
}
|
||
#endif
|
||
|
||
char* sasql_rand_buf( void )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select count(*) from `RandBuf`");
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
int randno;
|
||
randno = RAND(1,atoi(mysql_row[0]));
|
||
sprintf(sqlstr,"select * from `RandBuf` LIMIT %d,%d",randno-1,randno);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
sprintf(sqlstr,"%s|%s|%s|%s|%s|%s",mysql_row[0],mysql_row[1],mysql_row[2],mysql_row[3],mysql_row[4],mysql_row[5]);
|
||
return sqlstr;
|
||
}
|
||
}
|
||
}
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
return "err";
|
||
}
|
||
|
||
int sasql_check_lockmac( char *mac)
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `LockMac` where `MAC`='%s'",mac);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0){
|
||
return 1;
|
||
}else{
|
||
return 0;
|
||
}
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int sasql_check_lockpcid( char *pcid)
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `LockMac` where `PcId`='%s'",pcid);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0){
|
||
return 1;
|
||
}else{
|
||
return 0;
|
||
}
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int sasql_check_lockip( char *IP , int type )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `LockIP` where `IP`='%s' and `TYPE`=%d",IP,type);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0){
|
||
return 1;
|
||
}else{
|
||
return 0;
|
||
}
|
||
}
|
||
return -1;
|
||
}
|
||
int sasql_add_lockip(char *IP,int type,int online,int mode){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"INSERT INTO `LockIP` (`IP`,`TYPE`,`Online`,`Mode`) VALUES ('%s',%d,%d,%d)",IP,type,online,mode);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
int sasql_query_online_ip(char *IP){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `OnlineIP` where `IP`='%s'",IP);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0){
|
||
return 1;
|
||
}else{
|
||
return 0;
|
||
}
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int sasql_online_ip(char *cdkey,char *IP){
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select * from `OnlineIP` where `Name`='%s'",cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0){
|
||
sprintf(sqlstr,"update `OnlineIP` set `IP`='%s',`LoginTime`=NOW() where `Name`='%s'",IP,cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return 0;
|
||
}
|
||
}else{
|
||
sprintf(sqlstr,"INSERT INTO `OnlineIP` (`Name`,`IP`,`LoginTime`) VALUES ('%s','%s',NOW())",cdkey,IP);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
return 1;
|
||
}else{
|
||
return 0;
|
||
}
|
||
}
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int sasql_offlinenum( char *IP )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select count(*) from `%s` where `Online`=%d and `Offline`=1 and `IP`='%s'",sqlconfig.sql_Table,getServernumber(),IP);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
int sasql_offlinejqmnum( char *cdkey )
|
||
{
|
||
char sqlstr[256];
|
||
char *pcid = NULL;
|
||
sprintf(sqlstr,"select `PcId` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
pcid = mysql_row[0];
|
||
if(pcid == NULL) return 0;
|
||
sprintf(sqlstr,"select count(*) from `%s` where `Online`=%d and `Offline`>0 and `PcId`='%s'",sqlconfig.sql_Table,getServernumber(),pcid);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
}
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
char* sasql_ip( char *cdkey )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `IP` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return mysql_row[0];
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
return "err";
|
||
}
|
||
|
||
char* sasql_query_jqm( char *cdkey )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `PcId` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey);
|
||
//print("\n sqlstr=%s",sqlstr);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return mysql_row[0];
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
return "err";
|
||
}
|
||
|
||
int sasql_setVipPoint( int charaindex, int point )
|
||
{
|
||
char sqlstr[256];
|
||
char *id = CHAR_getChar(charaindex, CHAR_CDKEY);
|
||
sprintf(sqlstr,"update %s set VipPoint=%d where %s=BINARY'%s'", sqlconfig.sql_Table, point, sqlconfig.sql_NAME, id);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
//printf("用户%s当前重回币%d！\n",id,point);
|
||
return point;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int sasql_getVipPoint( int charaindex )
|
||
{
|
||
char sqlstr[256];
|
||
char *id = CHAR_getChar(charaindex, CHAR_CDKEY);
|
||
sprintf(sqlstr,"select VipPoint from `%s` where %s=BINARY'%s'", sqlconfig.sql_Table, sqlconfig.sql_NAME, id);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
// mysql_free_result(mysql_result);
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
}
|
||
// printf("\n数据库查找失败！\n");
|
||
printf("重新连接数据库[3]...");
|
||
// sasql_close();
|
||
// sasql_init();
|
||
printf("完成\n");
|
||
return -1;
|
||
}
|
||
|
||
int sasql_setVipPointForCdkey( char *id, int point )
|
||
{
|
||
if(sasql_ckeckStrint(id) == FALSE){
|
||
printf("异常字符的用户名%s\n",id);
|
||
return -1;
|
||
}
|
||
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"update %s set VipPoint=%d where %s=BINARY'%s'", sqlconfig.sql_Table, point, sqlconfig.sql_NAME, id);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
//printf("用户%s当前重回币%d！\n",id,point);
|
||
return point;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
|
||
int sasql_getVipPointForCdkey( char *id )
|
||
{
|
||
if(sasql_ckeckStrint(id) == FALSE){
|
||
printf("异常字符的用户名%s\n",id);
|
||
return -1;
|
||
}
|
||
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select VipPoint from `%s` where %s=BINARY'%s'", sqlconfig.sql_Table, sqlconfig.sql_NAME, id);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
}
|
||
// printf("\n数据库查找失败！\n");
|
||
printf("重新连接数据库[2]...");
|
||
// sasql_close();
|
||
// sasql_init();
|
||
printf("完成\n");
|
||
return -1;
|
||
}
|
||
|
||
BOOL sasql_ckeckStrint( char *str )
|
||
{
|
||
int i;
|
||
for(i=0;i<strlen(str);i++){
|
||
if((str[i] < 'a' || str[i] > 'z') && (str[i] < 'A' || str[i] > 'Z') && (str[i] < '0' || str[i] > '9') && (str[i] != '.')){
|
||
return FALSE;
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
|
||
#ifdef _CARD_PRODUCTION
|
||
/**
|
||
* 生成充值卡
|
||
*/
|
||
void sasql_OnlineCost_add( int cost, int num)
|
||
{
|
||
char sqlstr[256];
|
||
char CostPasswd[32];
|
||
memset( CostPasswd, 0, sizeof( CostPasswd ) );
|
||
int i, j, k=0;
|
||
for(i=0;i<num;i++){
|
||
for(j=0;j<16;j++){
|
||
if(rand() % 2==0){
|
||
CostPasswd[j]=(rand() % 26) + 65;
|
||
}else{
|
||
CostPasswd[j]=(rand() % 10) + 48;
|
||
}
|
||
}
|
||
sprintf(sqlstr,"INSERT INTO OnlineCost (CostPasswd, CostVal) VALUES (BINARY'%s', %d)", CostPasswd, cost);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
k++;
|
||
}else{
|
||
continue;
|
||
}
|
||
}
|
||
#ifdef _DEBUG
|
||
printf("成功添加%d条面值%d的充值卡\n", k, cost);
|
||
#endif
|
||
return ;
|
||
}
|
||
#endif
|
||
|
||
int sasql_jifenPoint( int charaindex )
|
||
{
|
||
//printf("进入了数据库\n");
|
||
char sqlstr[256];
|
||
char *id = CHAR_getChar(charaindex, CHAR_CDKEY);
|
||
sprintf(sqlstr,"select AmPoint from `%s` where %s=BINARY'%s'", sqlconfig.sql_Table, sqlconfig.sql_NAME, id);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
}
|
||
printf("更新积分点数失败\n");
|
||
return -1;
|
||
}
|
||
|
||
int sasql_setJfPoint( int charaindex, int point )
|
||
{
|
||
char sqlstr[256];
|
||
char *id = CHAR_getChar(charaindex, CHAR_CDKEY);
|
||
sprintf(sqlstr,"update %s set AmPoint=%d where %s=BINARY'%s'", sqlconfig.sql_Table, point, sqlconfig.sql_NAME, id);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
//if(!sasql_mysql_query(sqlstr)){
|
||
return point;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int sasql_xjPoint( int charaindex )
|
||
{
|
||
//printf("进入了数据库\n");
|
||
char sqlstr[256];
|
||
char *id = CHAR_getChar(charaindex, CHAR_CDKEY);
|
||
sprintf(sqlstr,"select RMBPOINT from `%s` where %s=BINARY'%s'", sqlconfig.sql_Table, sqlconfig.sql_NAME, id);
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return atoi(mysql_row[0]);
|
||
}
|
||
}
|
||
printf("更新RMB点数失败\n");
|
||
return -1;
|
||
}
|
||
|
||
int sasql_setxjPoint( int charaindex, int point )
|
||
{
|
||
char sqlstr[256];
|
||
char *id = CHAR_getChar(charaindex, CHAR_CDKEY);
|
||
sprintf(sqlstr,"update %s set RMBPOINT=%d where %s=BINARY'%s'", sqlconfig.sql_Table, point, sqlconfig.sql_NAME, id);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
//if(!sasql_mysql_query(sqlstr)){
|
||
return point;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
struct youx{
|
||
int result;
|
||
int flg;
|
||
int errnono;
|
||
char* errstr;
|
||
int fieldCount;
|
||
int rowCount;
|
||
int rowAt;
|
||
}retlua;
|
||
|
||
|
||
#ifdef _CAX_LNS_MYSQLSUOXU
|
||
void sasql_LUASQLAdv(char* sqlstr,char* filepath,char* function,int npcindex ,int charaindex,char* msg,int flg)
|
||
{
|
||
char* data = sasql_LuaAdv_QueryR(sqlstr,flg);
|
||
NPC_Lua_SQLPushAdvCallBack(retlua.result,retlua.flg,retlua.errnono,retlua.errstr,retlua.fieldCount ,retlua.rowCount ,retlua.rowAt, data,filepath,function,npcindex,charaindex,msg );
|
||
}
|
||
char* sasql_LuaAdv_QueryR(char *sqlstr,int flg)
|
||
{
|
||
int rowAtt = 0;
|
||
static char buff[1024] = "";
|
||
snprintf(buff,1024, "");
|
||
buff[1023]='\0';
|
||
/*初始化信息表*/
|
||
retlua.result = 0;//结果集ERROR
|
||
retlua.flg = flg;//分类
|
||
retlua.errnono = 0;//MYSQL错误编号
|
||
retlua.errstr = "";//MYSQL错误信息
|
||
retlua.fieldCount = 0;//查询的项目数
|
||
retlua.rowCount = 0;//查询结果集行数
|
||
retlua.rowAt = 0;//当前记录行数
|
||
|
||
|
||
if (flg == 1 || flg == 2){
|
||
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);//结果集行数
|
||
if (mysql_result == NULL)
|
||
{
|
||
retlua.result = -2;
|
||
}else if (mysql_eof(mysql_result))
|
||
{
|
||
retlua.result = -3;
|
||
}
|
||
|
||
if(num_row>0){
|
||
|
||
mysql_row = mysql_fetch_row(mysql_result);//从查询结果中取一条
|
||
|
||
retlua.errnono = mysql_errno(&mysql);//错误编号
|
||
retlua.errstr = mysql_error(&mysql);//错误信息
|
||
retlua.fieldCount = mysql_field_count(&mysql);//列数
|
||
|
||
retlua.rowCount = num_row;//结果行数量
|
||
rowAtt++;
|
||
retlua.rowAt = rowAtt;//当前行数
|
||
if (flg == 1){
|
||
mysql_free_result(mysql_result);//释放结果集
|
||
mysql_result = NULL;
|
||
rowAtt = 0;
|
||
}
|
||
|
||
int i;
|
||
for (i=0;i<retlua.fieldCount;i++)
|
||
{
|
||
snprintf(buff,sizeof(buff), "%s%s;",buff,(char*)mysql_row[i]);
|
||
}
|
||
if (num_row > 15) retlua.result = -1;
|
||
return buff;
|
||
}else {
|
||
retlua.errnono = mysql_errno(&mysql);
|
||
retlua.errstr = mysql_error(&mysql);
|
||
}
|
||
}
|
||
}else if (flg == 3){
|
||
|
||
|
||
int num_row=0;
|
||
if (mysql_result == NULL) {
|
||
retlua.result = -2;
|
||
return "结果集已经释放。";
|
||
}
|
||
num_row=mysql_num_rows(mysql_result);//结果集行数
|
||
if (mysql_eof(mysql_result))
|
||
{
|
||
retlua.result = -3;//已达到尾端，先给你提个醒，如果还继续查询，下面将会自动释放。
|
||
}
|
||
if (num_row == rowAtt) {
|
||
mysql_free_result(mysql_result);//释放结果集
|
||
mysql_result = NULL;
|
||
rowAtt = 0;
|
||
retlua.result = -3;
|
||
return "已到达尾行，自动释放结果集。";
|
||
}
|
||
if(num_row>0){
|
||
mysql_row = mysql_fetch_row(mysql_result);//从查询结果中取一条
|
||
retlua.errnono = mysql_errno(&mysql);//错误编号
|
||
retlua.errstr = mysql_error(&mysql);//错误信息
|
||
rowAtt++;
|
||
retlua.rowAt = rowAtt;//当前行数
|
||
retlua.fieldCount = mysql_field_count(&mysql);//列数
|
||
retlua.rowCount = num_row;//结果行数量
|
||
if (num_row > 15) retlua.result = -1;
|
||
int i;
|
||
for (i=0;i<retlua.fieldCount;i++)
|
||
{
|
||
snprintf(buff,sizeof(buff), "%s%s;",buff,(char*)mysql_row[i]);
|
||
}
|
||
return buff;
|
||
}else {
|
||
retlua.errnono = mysql_errno(&mysql);
|
||
retlua.errstr = mysql_error(&mysql);
|
||
}
|
||
|
||
}else if (flg == 4){
|
||
if (mysql_result == NULL) {
|
||
retlua.result = -2;
|
||
return "结果集已经释放。";
|
||
}
|
||
mysql_free_result(mysql_result);//释放结果集
|
||
mysql_result = NULL;
|
||
rowAtt = 0;
|
||
retlua.rowAt = rowAtt;//当前行数
|
||
retlua.errnono = mysql_errno(&mysql);
|
||
retlua.errstr = mysql_error(&mysql);
|
||
return "";
|
||
}
|
||
|
||
retlua.errnono = mysql_errno(&mysql);
|
||
retlua.errstr = mysql_error(&mysql);
|
||
return "";
|
||
}
|
||
void sasql_LUASQL(char* sqlstr,int row,char* filepath,char* function,int npcindex ,int charaindex,char* msg)
|
||
{
|
||
if(row == -1 )
|
||
{
|
||
mysql_query(&mysql,sqlstr);
|
||
}else{
|
||
NPC_Lua_SQLPushCallBack(sasql_Lua_QueryR(row,sqlstr),filepath,function,npcindex, charaindex,msg);
|
||
}
|
||
}
|
||
char* sasql_Lua_QueryR(int row,char *sqlstr)
|
||
{
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row = mysql_fetch_row(mysql_result);
|
||
return (char*)mysql_row[row];
|
||
}
|
||
}else
|
||
return "SQL Query ERROR";
|
||
}
|
||
#endif
|
||
|
||
#ifdef _CAX_NEWMAC_LOGIN
|
||
char* sasql_query_mac( char *cdkey )
|
||
{
|
||
char sqlstr[256];
|
||
sprintf(sqlstr,"select `MAC` from `%s` where `%s`=BINARY'%s'",sqlconfig.sql_Table,sqlconfig.sql_NAME,cdkey);
|
||
//print("\n sqlstr=%s",sqlstr);
|
||
if(!mysql_query(&mysql,sqlstr)){
|
||
int num_row=0;
|
||
mysql_result=mysql_store_result(&mysql);
|
||
num_row=mysql_num_rows(mysql_result);
|
||
if(num_row>0){
|
||
mysql_row=mysql_fetch_row(mysql_result);
|
||
mysql_free_result(mysql_result);
|
||
return mysql_row[0];
|
||
}else{
|
||
mysql_free_result(mysql_result);
|
||
}
|
||
}
|
||
return "err";
|
||
}
|
||
#endif
|