开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
recv.c
资源名称：saac.tar.gz　[点击查看]
上传用户：qys8201
上传日期：2021-12-11
资源大小：978k
文件大小：46k
源码类别：

模拟服务器

开发平台：

C/C++

recv.c：源码内容
  1. #define _RECV_C_
  3. #include "version.h"
  4. #include "main.h"
  5. #include "saacproto_util.h"
  6. #include "saacproto_serv.h"
  7. #include "recv.h"
  8. #include "char.h"
  9. #include "db.h"
  10. #include "mail.h"
  11. #include "lock.h"
  12. #include "util.h"
  14. #ifdef _SASQL
  15. #include "sasql.h"
  16. #endif
  18. // CoolFish: Family 2001/5/9
  19. #include "acfamily.h"
  20. #include "version.h"
  22. #include <stdlib.h>
  23. #include <stdio.h>
  25. char retdata[CHARDATASIZE];     
  26. char result[CHARDATASIZE];        
  28. // Spock +1 2000/11/1
  29. #define MAX_PROCESS 16777216
  30. #ifdef _VIP
  31. void saacproto_ACServerLogin_recv( int ti,char* servername , char* serverpas, int checkvip )
  32. {
  33.     login_game_server( ti , servername , serverpas, checkvip,
  34.              result , sizeof( result ) ,
  35.              retdata , sizeof( retdata ));
  37.     saacproto_ACServerLogin_send( ti ,result ,retdata );
  38. }
  39. #else
  40. void saacproto_ACServerLogin_recv( int ti,char* servername , char* serverpas )
  41. {
  42.     login_game_server( ti , servername , serverpas,
  43.              result , sizeof( result ) ,
  44.              retdata , sizeof( retdata ));
  46.     saacproto_ACServerLogin_send( ti ,result ,retdata );
  47. }
  48. #endif
  49. /*
  50.    必□丞扔□田□互失市它件玄扔□田□井日夫弘失它玄允月［
  51.    int fd : 覆擂socket
  53. */
  54. void  saacproto_ACServerLogout_recv( int ti  )
  55. {
  57.     logout_game_server( ti );
  58. }
  60. void saacproto_ACCharLoad_recv( int ti,char* id,char* pas,char* charname ,
  61.                                 int lock,char* opt , int mesgid)
  62. {
  63.     // Spock 2000/10/31
  64.     static int process = 0;
  65.     char buf[16];
  66.     // Spock end
  67. #ifdef _NewSave
  68.     int charindex = -1;
  69. #endif
  70.  
  71.     if( !is_game_server_login( ti ) ){
  72. #ifdef _NewSave
  73.         saacproto_ACCharLoad_send( ti , FAILED , "not login" , mesgid, charindex );
  74. #else
  75.         saacproto_ACCharLoad_send( ti , FAILED , "not login" , mesgid );
  76. #endif
  77.         return;
  78.     }
  79.     process++;
  80.     if ( process > MAX_PROCESS ) process = 1;
  81.     snprintf( buf , sizeof(buf) , "%d" , process );
  83. charLoadCallback(ti,0,id,pas,charname,buf,"",lock,mesgid);
  84.     // Spock 2000/10/31
  85.     //log( "读取档案: 附加作业 %s %s, 进程=%dn", id,pas,process );
  86.     // Spock end
  87. }
  89. /*
  90.    平乓仿忡绣
  92.    char *id : ID
  93.    char *pas : 天允歹□升
  94.    char *charname : 平乓仿  
  95.    char *opt : 左皿扑亦件  侬  ［ CharList及午五卞丢乒午仄化忒允树  
  96.    char *charinfo : 白央奶伙卞忡绣允月平乓仿弁正及旦  □正旦树  ［
  97.    int id : 丢永本□斥id
  98. */
  99. #ifdef _NewSave
  100. void saacproto_ACCharSave_recv( int ti, char* id,
  101.                                 char *charname,char* opt ,
  102.                                 char* charinfo , int unlock , int mesgid , int charindex )
  103. #else
  104. void saacproto_ACCharSave_recv( int ti, char* id,
  105.                                 char *charname,char* opt ,
  106.                                 char* charinfo , int unlock , int mesgid )
  107. #endif
  108. {
  109.     char process[16];
  110.     int ret;
  111.     if( !is_game_server_login(ti) ){
  112.         saacproto_ACCharSave_send( ti , FAILED , "not login" , mesgid );
  113.         return;
  114.     }
  115. #ifdef _NewSave
  116.     ret = charSave( ti, id, charname, opt, charinfo,
  117.                       unlock,mesgid, charindex );
  118. #else
  119.     ret = charSave( ti, id, charname, opt, charinfo,
  120.                       unlock,mesgid );
  121. #endif
  122.     snprintf( process , sizeof(process) , "%d" , ret );
  123. // log( "unlock:%d, process:%sn", unlock, process);
  124.     if( unlock) {
  125. dummyCallback(ti,0,id,"dummy",charname,process,"",mesgid,0);
  126.     }
  127.     log("玩家已保存保存n");
  128. }
  130. void saacproto_ACCharList_recv( int ti,char* id,char* pas , int mesgid)
  131. {
  132.     static int process=0;
  133.     char buf[10];
  135. //log(" get_charlist ");
  137.     process++;
  138.     if (process > MAX_PROCESS) process=1;
  139.     snprintf(buf, sizeof(buf), "%d", process);
  141.     if( !is_game_server_login( ti ) ){
  142.         saacproto_ACCharList_send( ti , FAILED , "not login" , mesgid );
  143.         return;
  144.     }
  145. charListCallback(ti,0,id,pas,"",buf,"0",mesgid,0);
  146.     log( "档案列表: %sn", id );
  147. }
  149. void saacproto_ACCharDelete_recv( int ti,char* id,char* pas,
  150.                                   char* charname , char *option , int mesgid)
  151. {
  153.     if( !is_game_server_login(ti) ){
  154.         saacproto_ACCharDelete_send( ti , FAILED , "not login" , mesgid );
  155.         return;
  156.     }
  157.     // Nuke
  158.     charDeleteCallback(ti,0,id,pas,charname,"0","",mesgid,0);
  159.     log( "档案删除: 附加作业 %s %sn",id , pas );
  160. }
  162. void saacproto_ACLock_recv( int ti ,char* id,int lock,int mesgid )
  163. {
  164. if( !is_game_server_login(ti) ){
  165. saacproto_ACLock_send( ti , FAILED , "not login" , mesgid );
  166. return;
  167. }
  168. // Arminius 7.25 test unlock
  169. log("ACLock recv:%dn",lock);
  170.   if (lock==2) {
  171. char buf[4096];
  172. if (GetMemLockState(getHash(id) & 0xff, id, buf)) {
  173. sprintf(retdata, "USRLOCKED:%s", buf);
  174. } else {
  175. sprintf(retdata, "USRUNLOCKED:%s", buf);
  176. }
  177. log(retdata);
  178.     } else if (lock==3) {
  179. int proc;
  180. if (DeleteMemLock(getHash(id) & 0xff, id, &proc)) {
  181. sprintf(retdata, "GMUNLOCKSUCCESS");
  182. } else {
  183. sprintf(retdata, "GMUNLOCKFAIL");
  184. }
  185. log(retdata);
  186. } else if (lock==4) {
  187. DeleteMemLockServer(id);
  188. sprintf(retdata, "GMUNLOCKALL");
  189.     } else {
  190. #ifdef _LOCK_ADD_NAME
  191. if ( lockUser( getGSName( ti ) , id , "" , "0" , lock , result,sizeof(result),
  192. retdata ,sizeof( retdata ) , "0" , "0") < 0 ) {
  193. #else
  194. if ( lockUser( getGSName( ti ) , id , "0" , lock , result,sizeof(result),
  195. retdata ,sizeof( retdata ) , "0" , "0") < 0 ) {
  196. #endif
  197. log( "锁定用户: %s 失败n" , id );
  198. } else {
  199. log( "锁定用户: %s 成功n" , id );
  200. }
  201.   }
  202.     // Spock end
  203.   saacproto_ACLock_send( ti , result , retdata , mesgid );
  204. }
  206. void saacproto_ACUCheck_recv( int ti , char *id , int status )
  207. {
  208.     if( !is_game_server_login(ti) ){
  209.         log( "服务器发现账号:%s status:%dn",
  210.              id, status );
  211.         return;
  212.     }
  214. if( status == 0 ){
  215.        log( "用户 %s 在 %s 并未锁定！n", id , getGSName( ti ) );
  216.        saacproto_ACKick_recv( ti, id, 6, -1);
  217.     } else {
  218.         log( "用户 %s 在 %s 已锁定！n", id , getGSName( ti ) );
  219. #ifdef _WAEI_KICK
  220. saacproto_ACKick_recv( ti, id, 1, -1);
  221. #endif
  222.     }
  223. }
  227. void saacproto_DBUpdateEntryString_recv( int fd,
  228.                                          char* table,
  229.                                          char* key,
  230.                                          char* value,
  231.                                          int msgid,
  232.                                          int msgid2 )
  233. {
  234.     int r;
  235.     r = dbUpdateEntryString( table, key, value );
  237. if( r != 0 ){
  238. log( "failed: DBUpdateEntryString err !!n");
  239. }
  240. /* 2003/06/26
  241.     if( r == 0 ){
  242. //        saacproto_DBUpdateEntryString_send( fd, SUCCESSFUL,table,key,
  243.                                             msgid,msgid2 );
  244.     } else {
  245. //        saacproto_DBUpdateEntryString_send( fd, FAILED,table,key,
  246.                                             msgid,msgid2 );        
  247.     }
  248. */
  249. }
  252. void saacproto_DBDeleteEntryString_recv( int fd,
  253.                                          char* table,
  254.                                          char* key,
  255.                                          int msgid,
  256.                                          int msgid2 )
  257. {
  258.     int r;
  260.     r = dbDeleteEntryString( table,key );
  261.     if( r == 0 ){
  262.         saacproto_DBDeleteEntryString_send( fd,SUCCESSFUL,table,key,
  263.                                             msgid,msgid2 );
  264.     } else {
  265.         saacproto_DBDeleteEntryString_send( fd,FAILED,table,key,
  266.                                             msgid,msgid2 );        
  267.     }
  268. }
  271. void saacproto_DBGetEntryString_recv( int fd,
  272.                                       char* table,
  273.                                       char* key,
  274.                                       int msgid,
  275.                                       int msgid2 )
  276. {
  277.     char output[16384];
  278.     int r;
  279.     r = dbGetEntryString( table, key, output, sizeof( output) );
  280.     if( r == 0 ){
  281.         saacproto_DBGetEntryString_send( fd,SUCCESSFUL,output,table,key,
  282.                                          msgid,msgid2 );
  283.     } else {
  284.         saacproto_DBGetEntryString_send( fd,FAILED,"",table,key,
  285.                                          msgid,msgid2 );        
  286.     }
  287.     
  288. }
  292. void saacproto_DBUpdateEntryInt_recv( int fd,
  293.                                    char* table,
  294.                                    char* key,
  295.                                    int value,
  296.                                    char *info,
  297.                                    int msgid,
  298.                                    int msgid2)
  299. {
  300.     if( !is_game_server_login(fd) ){
  301.         saacproto_DBUpdateEntryInt_send( fd, FAILED, "","",msgid, msgid2 );
  302.         return;
  303.     }    
  304.     if( dbUpdateEntryInt( table , key , value, info ) == 0 ){
  305.         saacproto_DBUpdateEntryInt_send(
  306.             fd , SUCCESSFUL ,table,key, msgid, msgid2 );
  307.     } else {
  308.         saacproto_DBUpdateEntryInt_send( fd , FAILED , table,key, msgid, msgid2 );        
  309.     }
  310. }
  312. #ifdef _ALLDOMAN // (不可开) Syu ADD 排行榜NPC
  313. void saacproto_UpdataStele_recv( int fd , char *cdkey , char *name , char *title ,
  314. int level , int trns , int time , int floor )
  315. {
  316. int i, min=140, minnum=-1, nameflag=-1;
  317. for ( i=0; i<MAX_HERO_LIST; i ++ ) {
  318. if( atoi( Herolist[i][6] ) <  min ) {
  319. min = atoi (Herolist[i][6]) ; 
  320. minnum=i;
  321. }
  322. if ( strcmp ( Herolist[i][0] , cdkey ) == 0 && strcmp ( Herolist[i][1] , name ) == 0 )
  323. nameflag = i ; 
  324. }
  325. if( strcmp ( cdkey , "FirstLoad") == 0 &&
  326. strcmp ( name , "LoadHerolist") == 0 &&
  327. floor == 999 )
  329. Send_A_herolist( fd );
  330. else if ( nameflag != -1 && floor > atoi(Herolist[nameflag][6]) ) {
  331. Send_S_herolist ( Herolist[nameflag][0] , Herolist[nameflag][1] , 
  332. cdkey , name , title , level , trns , floor ) ; 
  333. sprintf ( Herolist[nameflag][2] , "%s" , title ) ; 
  334. sprintf ( Herolist[nameflag][3] , "%d" , level ) ; 
  335. sprintf ( Herolist[nameflag][4] , "%d" , trns ) ; 
  336. sprintf ( Herolist[nameflag][5] , "%d" , time ) ; 
  337. sprintf ( Herolist[nameflag][6] , "%d" , floor ) ; 
  338. SAVE_herolist( fd );
  339. }else if ( nameflag == -1 && floor > min ) {
  340. Send_S_herolist ( Herolist[minnum][0] , Herolist[minnum][1] , 
  341. cdkey , name , title , level , trns , floor ) ; 
  342. sprintf ( Herolist[minnum][0] , "%s" , cdkey ) ; 
  343. sprintf ( Herolist[minnum][1] , "%s" , name  ) ; 
  344. sprintf ( Herolist[minnum][2] , "%s" , title ) ; 
  345. sprintf ( Herolist[minnum][3] , "%d" , level ) ; 
  346. sprintf ( Herolist[minnum][4] , "%d" , trns ) ; 
  347. sprintf ( Herolist[minnum][5] , "%d" , time ) ; 
  348. sprintf ( Herolist[minnum][6] , "%d" , floor ) ; 
  349. SAVE_herolist( fd );
  350. }
  351. }
  352. #endif
  354. void saacproto_DBGetEntryRank_recv( int fd,
  355.                                     char* table,
  356.                                     char* key,
  357.                                     int msgid,
  358.                                     int msgid2)
  359. {
  360.     int rk,c;
  362.     if( !is_game_server_login(fd) ){
  363.         saacproto_DBGetEntryRank_send( fd, FAILED, 0,0,"","",msgid, msgid2 );
  364.         return;
  365.     }
  366.     
  367.     dbGetEntryRank( table, key , &rk, &c );
  368.     if( rk <0 ){
  369.         saacproto_DBGetEntryRank_send(
  370.             fd, FAILED, -1, -1, table, key, msgid, msgid2 );
  371.     } else {
  372.         saacproto_DBGetEntryRank_send( fd, SUCCESSFUL,
  373.                                        rk, c, table, key, msgid, msgid2 );
  374.     }
  375. }
  378. void saacproto_DBDeleteEntryInt_recv( int fd,
  379.                                    char* table,
  380.                                    char* key,
  381.                                    int msgid,
  382.                                    int msgid2)
  383. {
  384.     if( !is_game_server_login(fd) ){
  385.         saacproto_DBDeleteEntryInt_send( fd, FAILED,"","",msgid, msgid2 );
  386.         return;
  387.     }
  388.     
  389.     if( dbDeleteEntryInt( table, key ) < 0 ){
  390.         saacproto_DBDeleteEntryInt_send(
  391.             fd, FAILED, table, key, msgid, msgid2 );
  392.     } else {
  393.         saacproto_DBDeleteEntryInt_send(
  394.             fd, SUCCESSFUL, table, key, msgid, msgid2 );
  395.     }
  396. }
  397.     
  399. void saacproto_DBGetEntryInt_recv( int fd,
  400.                                 char* table,
  401.                                 char* key,
  402.                                 int msgid,
  403.                                 int msgid2)
  404. {
  405.     int r ;
  406.     int output;
  408.     if( !is_game_server_login(fd) ){
  409.         saacproto_DBGetEntryInt_send( fd, FAILED,-1,"","",msgid, msgid2 );
  410.         return;
  411.     }
  412.     
  413.     r = dbGetEntryInt( table, key, &output );
  414.     
  415.     if( r < 0 ){
  416.         saacproto_DBGetEntryInt_send( fd,
  417.                                       FAILED, -1, table, key, msgid, msgid2);
  418.     } else {
  419.         saacproto_DBGetEntryInt_send(
  420.             fd, SUCCESSFUL, output, table, key, msgid, msgid2 );
  421.     }
  423. }
  426. void saacproto_DBGetEntryByRank_recv( int fd,
  427.                                 char* table,
  428.                                 int start, int end,
  429.                                 int msgid ,
  430.                                 int msgid2)
  431. {
  432.     char output[16384];
  433.     int r;
  435.     if( !is_game_server_login(fd) ){
  436.         saacproto_DBGetEntryByRank_send( fd, FAILED,"","",msgid, msgid2 );
  437.         return;
  438.     }
  439.     
  440.     r = dbGetEntryRankRange( table, start, end, output, sizeof( output ));
  442.     if( r < 0 ){
  443.         saacproto_DBGetEntryByRank_send(
  444.             fd, FAILED, "", table, msgid, msgid2 );
  445.     } else {
  446.         saacproto_DBGetEntryByRank_send(
  447.             fd, SUCCESSFUL, output,table, msgid, msgid2 );
  448.     }
  449. }
  451. void saacproto_DBGetEntryByCount_recv( int fd,
  452.                                        char* table,
  453.                                        int count_start,
  454.                                        int num,
  455.                                        int msgid ,
  456.                                        int msgid2)
  457. {
  458.     char output[16384];
  459.     int r;
  461.     if( !is_game_server_login(fd) ){
  462.         saacproto_DBGetEntryByCount_send(
  463.             fd, FAILED,"",table,count_start,msgid, msgid2 );
  464.         return;
  465.     }
  466.     
  467.     r = dbGetEntryCountRange( table, count_start, num, output, sizeof(output));
  469.     if( r < 0 ){
  470.         saacproto_DBGetEntryByCount_send( fd, FAILED, "", table,
  471.                                           count_start, msgid, msgid2 );
  472.     } else {
  473.         saacproto_DBGetEntryByCount_send( fd, SUCCESSFUL, output, table,
  474.                                           count_start,  msgid, msgid2 );       
  475.     }
  476. }
  478. void saacproto_Broadcast_recv( int fd, char* id, char* charname, char* message, int flag)
  479. {
  480.     if( !is_game_server_login( fd) ){
  481.         log( "Broadcast: no login. id:%s charname:%s message:%s flag:%dn",
  482.              id, charname, message , flag );
  483.         return;
  484.     }
  485.     gmsvBroadcast( fd, id, charname, message , flag );
  486. }
  489. void saacproto_Message_recv( int fd,
  490.                              char* id_from,
  491.                              char* charname_from,
  492.                              char* id_to,
  493.                              char* charname_to,
  494.                              char* message,
  495.                              int option )
  496. {
  497.     receiveMail( id_from, charname_from,
  498.                        id_to, charname_to, message, option ,0,0);
  499. }
  501. void saacproto_MessageAck_recv( int fd,
  502.                                 char* id,
  503.                                 char* charname,
  504.                                 char* result,
  505.                                 int mesgid )
  506. {
  507.     int a;
  508.     if( strcmp( result, SUCCESSFUL ) )a=0; else a =-1;
  509.     receiveMailAck( id, charname, a , mesgid );
  510. }
  512. void saacproto_MessageFlush_recv( int fd,
  513.                                   char* id,
  514.                                   char* charname )
  515. {
  516.     flushMail( fd, id , charname );
  517. }
  519. /*******************************************************
  520.  * CoolFish: Family 2001/5/18
  521.  ******************************************************/
  522. #ifdef _PERSONAL_FAME
  523. void saacproto_ACAddFM_recv( int fd, char *fmname, char *fmleadername,
  524. char *fmleaderid, int fmleaderlv, char *petname, char *petattr,
  525. char *fmrule, int fmsprite, int fmleadergrano, int fame, int charfdid)
  526. #else
  527. void saacproto_ACAddFM_recv( int fd, char *fmname, char *fmleadername,
  528. char *fmleaderid, int fmleaderlv, char *petname, char *petattr,
  529. char *fmrule, int fmsprite, int fmleadergrano, int charfdid)
  530. #endif
  531. {
  532. #ifdef _FAMILY
  533. int r = 0, index = 0;
  534. #ifdef _PERSONAL_FAME
  535. r = ACAddFM(fd, &index, fmname, fmleadername, fmleaderid, fmleaderlv,
  536.    petname, petattr, fmrule, fmsprite, fmleadergrano, fame, charfdid);
  537. #else
  538. r = ACAddFM(fd, &index, fmname, fmleadername, fmleaderid, fmleaderlv,
  539.    petname, petattr, fmrule, fmsprite, fmleadergrano, charfdid);
  540. #endif
  541. if (r < 0){
  542. saacproto_ACAddFM_send(fd, FAILED, r, index, charfdid);
  543. }else{
  544. saacproto_ACAddFM_send(fd, SUCCESSFUL, r, index, charfdid);
  545. }
  546. #endif
  547. }
  549. void saacproto_ACJoinFM_recv(int fd, char *fmname, int fmindex,
  550. #ifdef _PERSONAL_FAME // Arminius: 家族个人声望
  551. char *charname, char *charid, int charlv, int index, int fame, int charfdid)
  552. #else
  553. char *charname, char *charid, int charlv, int index, int charfdid)
  554. #endif
  555. {
  556. #ifdef _FAMILY
  557. int r = 0;
  558. #ifdef _PERSONAL_FAME // Arminius: 家族个人声望
  559. r =  ACJoinFM(fd, index, fmname, fmindex, charname, charid, charlv, fame, charfdid);
  560. #else
  561. r =  ACJoinFM(fd, index, fmname, fmindex, charname, charid, charlv, charfdid);
  562. #endif
  563. if (r < 0){
  564. saacproto_ACJoinFM_send(fd, FAILED, r, charfdid);
  565. }else{
  566. saacproto_ACJoinFM_send(fd, SUCCESSFUL, r, charfdid);
  567. }
  568. #endif
  569. }
  571. void saacproto_ACLeaveFM_recv(int fd, char *fmname, int fmindex,
  572. char *charname, char *charid, int index, int charfdid)
  573. {
  574. #ifdef _FAMILY
  575. int r = 0;
  576. r =  ACLeaveFM(index, fmname, fmindex, charname, charid);
  577. if (r < 0){
  578. saacproto_ACLeaveFM_send(fd, FAILED, r, charfdid);
  579. }else{
  580. saacproto_ACLeaveFM_send(fd, SUCCESSFUL, r, charfdid);
  581. }
  582. #endif
  583. }
  585. #ifdef _LEADERFUNCHECK
  586. void saacproto_ACDelFM_recv(int fd, char *fmname, int fmindex,
  587. int index, char *charname, char *charid, int charfdid)
  588. {
  589. int r = 0, result = 0;
  590. result = CheckLeaderQ(index, fmname, fmindex, charname, charid);
  591. if(result < 0)
  592. {
  593. saacproto_ACDelFM_send(fd, FAILED, charfdid);
  594. return;
  595. }
  596. // shan modify begin
  597. // original
  598. /*if (ChangeFMLeader(index, fmname, fmindex) < 0)    
  599. r = ACDelFM(index, fmname, fmindex); 
  600. else 
  601. r = -1;  // shan  1 -> -1
  602. if (r < 0)
  603. saacproto_ACDelFM_send(fd, FAILED, charfdid);
  604. else
  605. saacproto_ACDelFM_send(fd, SUCCESSFUL, charfdid);
  606. */   
  607. r = ACDelFM(index, fmname, fmindex); 
  608. if (r < 0)
  609. saacproto_ACDelFM_send(fd, FAILED, charfdid);
  610. else
  611. saacproto_ACDelFM_send(fd, SUCCESSFUL, charfdid);
  612. // shan end
  613. }
  614. #else
  615. void saacproto_ACDelFM_recv(int fd, char *fmname, int fmindex,
  616. int index, int charfdid)
  617. {
  618. #ifdef _FAMILY
  619. int r = 0;
  620. #ifdef _FMVER21
  621. if (ChangeFMLeader(index, fmname, fmindex) >= 0)
  622. r = ACDelFM(index, fmname, fmindex);
  623. else r = 1;
  624. #else
  625. r =  ACDelFM(index, fmname, fmindex);
  626. #endif
  627. if (r < 0){
  628. saacproto_ACDelFM_send(fd, FAILED, charfdid);
  629. }
  630. #ifdef _FMVER21
  631. else if (r == 1){
  632. }
  633. #endif
  634. else{
  635. saacproto_ACDelFM_send(fd, SUCCESSFUL, charfdid);
  636. }
  637. #endif
  638. }
  639. #endif
  641. void saacproto_ACShowFMList_recv(int fd)
  642. {
  643. #ifdef _FAMILY
  644. int r = 0;
  645. char data[150 * MAX_FAMILY];
  646. r =  ACShowFMList(data);
  647. if (r < 0){
  648. // saacproto_ACShowFMList_send(fd, FAILED, r, "Nothing");
  649. }else{
  650. saacproto_ACShowFMList_send(fd, SUCCESSFUL, r, data);
  651. }
  652. #endif
  653. }
  655. void saacproto_ACShowMemberList_recv(int fd, int index)
  656. {
  657. #ifdef _FAMILY
  658. int r = 0, fmacceptflag = 0, fmjoinnum = 0;
  659. char data[150 * MAX_MEMBERNUM];
  660. r =  ACShowFMMemberList(index, &fmacceptflag, &fmjoinnum, data);
  661. if (r < 0){
  662. // saacproto_ACShowMemberList_send(fd, FAILED, index, r,
  663. // fmacceptflag, fmjoinnum, "Nothing");
  664. }else{
  665. saacproto_ACShowMemberList_send(fd, SUCCESSFUL, index, r,
  666. fmacceptflag, fmjoinnum, data);
  667. }
  668. #endif
  669. }
  671. void saacproto_ACFMDetail_recv(int fd, char *fmname,
  672. int fmindex, int index, int charfdid)
  673. {
  674. #ifdef _FAMILY
  675. int r = 0;
  676. char data[15000];
  677. r =  ACFMDetail(index, fmname, fmindex, data);
  678. if (r < 0){
  679. // saacproto_ACFMDetail_send(fd, FAILED, "Nothing", charfdid);
  680. }else{
  681. saacproto_ACFMDetail_send(fd, SUCCESSFUL, data, charfdid);
  682. }
  683. #endif
  684. }
  686. #ifdef _FMVER21
  687. void saacproto_ACMemberJoinFM_recv(int fd, char *fmname, int fmindex,
  688. char *charname, int charindex, int index, int result, int meindex,
  689. int charfdid)
  690. #else
  691. void saacproto_ACMemberJoinFM_recv(int fd, char *fmname, int fmindex,
  692. char *charname, int charindex, int index, int result, int charfdid)
  693. #endif
  694. {
  695. int r = 0;
  696. #ifdef _FMVER21
  697.     r =  ACMemberJoinFM(index, fmname, fmindex, charname, charindex, result, meindex);
  698. #else
  699. r =  ACMemberJoinFM(index, fmname, fmindex, charname, charindex);
  700. #endif
  701. if (r < 0){
  702. saacproto_ACMemberJoinFM_send(fd, FAILED, charfdid);
  703. }else{
  704. saacproto_ACMemberJoinFM_send(fd, SUCCESSFUL, charfdid);
  705. }
  706. }
  708. #ifdef _FMVER21
  709. void saacproto_ACMemberLeaveFM_recv(int fd, char *fmname, int fmindex,
  710. char *charname, int charindex, int index, int meindex, int charfdid)
  711. #else
  712. void saacproto_ACMemberLeaveFM_recv(int fd, char *fmname, int fmindex,
  713. char *charname, int charindex, int index, int charfdid)
  714. #endif
  715. {
  716. #ifdef _FAMILY
  717. int r = 0;
  718. int flag = 1; // 主动离开家族
  719. #ifdef _FMVER21
  720. r =  ACMemberLeaveFM(index, fmname, fmindex, charname, flag,
  721. charindex, meindex);
  722. #else
  723. r =  ACMemberLeaveFM(index, fmname, fmindex, charname, flag, charindex);
  724. #endif
  725. if (r < 0){
  726. saacproto_ACMemberLeaveFM_send(fd, FAILED, charfdid);
  727. }else{
  728. saacproto_ACMemberLeaveFM_send(fd, SUCCESSFUL, charfdid);
  729. }
  730. #endif
  731. }
  733. #ifdef _FM_MODIFY
  734. void saacproto_ACFMCharLogin_recv(int fd, char *fmname, int fmindex,
  735. char *charname, char *charid, int charlv, int eventflag, int charfdid,int gsnum)
  736. #else
  737. #ifdef _FMVER21
  738. void saacproto_ACFMCharLogin_recv(int fd, char *fmname, int fmindex,
  739. char *charname, char *charid, int charlv, int eventflag, int charfdid)
  740. #else
  741. void saacproto_ACFMCharLogin_recv(int fd, char *fmname, int fmindex,
  742. char *charname, char *charid, int charlv, int charfdid)
  743. #endif
  744. #endif
  745. {
  746. #ifdef _FAMILY
  747. int r = 0, floor = 0, fmpopular = 0, joinflag = 0, fmsetupflag = 0;
  748. int flag = 0, charindex = 0;
  749. #ifdef _PERSONAL_FAME   // Arminius: 家族个人声望
  750. int charfame = 0;
  751. #endif
  752. #ifdef _NEW_MANOR_LAW
  753. int momentum = 0;
  754. #endif
  755. #ifdef _FM_MODIFY
  756. r =  ACFMCharLogin(fd, -1, fmname, fmindex, charname, charid, charlv,
  757. &floor, &fmpopular, &joinflag, &fmsetupflag, &charindex, charfdid,
  758. &charfame, eventflag,gsnum
  759. #ifdef _NEW_MANOR_LAW
  760. ,&momentum
  761. #endif
  762. );
  763. #else
  764. #ifdef _PERSONAL_FAME   // Arminius: 家族个人声望
  765. r =  ACFMCharLogin(fd, -1, fmname, fmindex, charname, charid, charlv,
  766. &floor, &fmpopular, &joinflag, &fmsetupflag, &charindex, charfdid,
  767. &charfame, eventflag);
  768. #else
  769. r =  ACFMCharLogin(fd, -1, fmname, fmindex, charname, charid, charlv,
  770. &floor, &fmpopular, &joinflag, &fmsetupflag, &charindex, charfdid);
  771. #endif
  772. #endif
  774. #ifdef _PERSONAL_FAME   // Arminius: 家族个人声望
  775. if (r < 0){
  776. saacproto_ACFMCharLogin_send(fd, FAILED, r, floor, fmpopular,
  777. joinflag, fmsetupflag, flag, charindex, charfame, charfdid
  778. #ifdef _NEW_MANOR_LAW
  779. ,momentum
  780. #endif
  781. );
  782. }else{
  783. saacproto_ACFMCharLogin_send(fd, SUCCESSFUL, r, floor, fmpopular,
  784. joinflag, fmsetupflag, flag, charindex, charfame, charfdid
  785. #ifdef _NEW_MANOR_LAW
  786. ,momentum
  787. #endif
  788. );
  789. }
  790. #else
  791. if (r < 0){
  792. saacproto_ACFMCharLogin_send(fd, FAILED, r, floor, fmpopular,
  793. joinflag, fmsetupflag, flag, charindex, charfdid);
  794. }else{
  795. saacproto_ACFMCharLogin_send(fd, SUCCESSFUL, r, floor, fmpopular,
  796. joinflag, fmsetupflag, flag, charindex, charfdid);
  797. }
  798. #endif
  800. #endif
  801. }
  803. void saacproto_ACFMCharLogout_recv(int fd, char *fmname, int fmindex,
  804. char *charname, char *charid, int charlv, int index,int charfdid)
  805. {
  806. #ifdef _FAMILY
  807. int r = 0;
  808. r =  ACFMCharLogout(index, fmname, fmindex, charname, charid, charlv,
  809. charfdid);
  810. if (r < 0){
  811. saacproto_ACFMCharLogout_send(fd, FAILED, charfdid);
  812. }else{
  813. saacproto_ACFMCharLogout_send(fd, SUCCESSFUL, charfdid);
  814. }
  815. #endif
  816. }
  818. void saacproto_ACFMReadMemo_recv(int fd, int index)
  819. {
  821. #ifdef _FAMILY
  822. int r = 0, dataindex;
  823. char data[15000];
  824. r =  ACFMReadMemo(index, &dataindex, data);
  825. if (r < 0){
  826. // saacproto_ACFMReadMemo_send(fd, FAILED, index, r, dataindex, "Nothing");
  827. }else{
  828. saacproto_ACFMReadMemo_send(fd, SUCCESSFUL, index, r, dataindex, data);
  829. }
  830. #endif
  832. }
  833.                 
  834. void saacproto_ACFMWriteMemo_recv(int fd, char *fmname, int fmindex,
  835. char *data, int index)
  836. {
  837. #ifdef _FAMILY
  838. int r = 0;
  839. r =  ACFMWriteMemo(index, fmname, fmindex, data);
  840. if (r < 0){
  841. saacproto_ACFMWriteMemo_send(fd, FAILED, index);
  842. }else{
  843. saacproto_ACFMWriteMemo_send(fd, SUCCESSFUL, index);
  844. }
  845. #endif
  846. }
  848. void saacproto_ACFMPointList_recv(int fd)
  849. {
  850. #ifdef _FAMILY
  851.         int r = 0;
  852.         char data[15000];
  853.         r =  ACFMPointList(data);
  854.         if (r < 0)
  855.         {
  856. //         saacproto_ACFMPointList_send(fd, FAILED, "nothing");
  857.         }else{
  858.          saacproto_ACFMPointList_send(fd, SUCCESSFUL, data);
  859.         }
  860. #endif
  861. }
  863. void saacproto_ACSetFMPoint_recv(int fd, char *fmname, int fmindex, 
  864. int index, int fmpointindex, int fl, int x, int y, int charfdid)
  865. {
  866. #ifdef _FAMILY
  867. int r = 0;
  868. r =  ACSetFMPoint(index, fmname, fmindex, fmpointindex, fl, x, y);
  869. if (r < 0){
  870. saacproto_ACSetFMPoint_send(fd, FAILED, r, charfdid);
  871. }else{
  872. saacproto_ACSetFMPoint_send(fd, SUCCESSFUL, r, charfdid);
  873. }
  874. #endif
  875. }
  877. void saacproto_ACFixFMPoint_recv(int fd, char *winfmname, int winfmindex, int winindex,
  878. char *losefmname, int losefmindex, int loseindex, int village)
  879. {
  880. #ifdef _FAMILY
  881. int r = 0;
  882. r =  ACFixFMPoint(winindex, winfmname, winfmindex,
  883. loseindex, losefmname, losefmindex, village);
  884. if (r < 0){
  885. saacproto_ACFixFMPoint_send(fd, FAILED, r);
  886. }else{
  887. saacproto_ACFixFMPoint_send(fd, SUCCESSFUL, r);
  888. }
  889. #endif
  890. }
  892. void saacproto_ACFMAnnounce_recv(int fd, char *fmname, int fmindex, int index,
  893.         char *data, int color)
  894. {
  895. #ifdef _FAMILY
  896. int r = 0, i = 0;
  897. r = ACFMAnnounce(fmname, fmindex, index, data, color);
  898. if (r < 0){
  899. saacproto_ACFMAnnounce_send(fd, FAILED, fmname, fmindex, index,
  900. 1, data, color);
  901. }else{
  902. extern gmsv gs[MAXCONNECTION];
  903. for (i = 0; i < MAXCONNECTION; i ++)
  904. {
  905.    if (gs[i].use && gs[i].name[0])
  906.    {
  907.       saacproto_ACFMAnnounce_send(i, SUCCESSFUL, fmname, fmindex,
  908.        index, 1, data, color);
  909.    }
  910. }
  911. }
  912. #endif
  913. }
  915. void saacproto_ACShowTopFMList_recv(int fd, int kindflag)
  916. {
  917. #ifdef _FAMILY
  918. int r = 0;
  919. char data[150 * MAX_FAMILY];
  920. strcpy(data, "");
  921. r =  ACShowTopFMList(data, sizeof(data), kindflag);
  922. if (r < 0) {
  923. // saacproto_ACShowTopFMList_send(fd, FAILED, kindflag, r, "Nothing");
  924. }else {
  925. saacproto_ACShowTopFMList_send(fd, SUCCESSFUL, kindflag, r, data);
  926. }
  927. #endif
  928. }
  930. void saacproto_ACFixFMData_recv(int fd, char *fmname, int fmindex, int index,
  931. int kindflag, char *data1, char *data2, int charindex, int charfdid)
  932. {
  933. #ifdef _FAMILY
  934. int r = 0;
  935. r =  ACFixFMData(index, fmname, fmindex, kindflag, charindex, data1, data2);
  936. if (r < 0){
  937. saacproto_ACFixFMData_send(fd, FAILED, kindflag, data1, data2, charfdid);
  938. }else{
  939. saacproto_ACFixFMData_send(fd, SUCCESSFUL, kindflag, data1, data2, charfdid);
  940. }
  941. #endif
  942. }
  944. void saacproto_ACFixFMPK_recv(int fd, char *winfmname, int winfmindex, int winindex,
  945. char *losefmname, int losefmindex, int loseindex)
  946. {
  947. #ifdef _FAMILY
  948. int r = 0;
  949. r =  ACFixFMPK(winindex, winfmname, winfmindex,
  950. loseindex, losefmname, losefmindex);
  951. if (r < 0){
  952. saacproto_ACFixFMPK_send(fd, FAILED, r, winindex,
  953. loseindex);
  954. }else{
  955. saacproto_ACFixFMPK_send(fd, SUCCESSFUL, r, winindex,
  956. loseindex);
  957. }
  958. #endif
  959. }
  961. void saacproto_ACGMFixFMData_recv(int fd, int index, char *charid, char *cmd,
  962. char *data, int charfdid)
  963. {
  964. #ifdef _FAMILY
  965. int r = 0;
  966. char fmname[256];
  967. r =  ACGMFixFMData(index, fmname, charid, cmd, data);
  968. if (r < 0){
  969. saacproto_ACGMFixFMData_send(fd, FAILED, fmname, charfdid);
  970. }
  971. else{
  972. saacproto_ACGMFixFMData_send(fd, SUCCESSFUL, fmname, charfdid);
  973. }
  974. #endif
  975. }
  977. void saacproto_ACGetFMData_recv(int fd, char *fmname, int fmindex, int index,
  978. int kindflag, int charfdid)
  979. {
  980. #ifdef _FAMILY
  981. int r = 0, data = 0;
  982. r =  ACGetFMData(index, fmname, fmindex, kindflag, &data);
  983. if (r < 0){
  984. saacproto_ACGetFMData_send(fd, FAILED, kindflag, data, charfdid);
  985. }else{
  986. saacproto_ACGetFMData_send(fd, SUCCESSFUL, kindflag, data, charfdid);
  987. }
  988. #endif
  989. }
  991. void saacproto_ACreLoadFmData_recv(int fd, int type, int data)
  992. {
  993. int i=0;
  994. extern gmsv gs[MAXCONNECTION];
  995. switch( type){
  996. case 1:
  997. log( "reload FM_DATA:%d !n", data);
  998. readOneFamilyFromTi( data);
  999. break;
  1000. case 2:
  1001. {
  1002. char data[15000];
  1003. readFMPoint( fmpointdir);
  1004. if( ACFMPointList( data) >= 0 ){
  1005. log( "reload FM_POINT !n" );
  1006. for (i=0; i<MAXCONNECTION; i++){
  1007. if( gs[i].use && gs[i].name[0] )
  1008. saacproto_ACFMPointList_send( i, SUCCESSFUL, data);
  1009. }
  1010. }
  1011. }
  1012. break;
  1013. case 3: //fmpk_list
  1014. {
  1015. int j=0;
  1016. log( "reload FMPK_LIST !n" );
  1017. FMPK_InitList();
  1018. FMPK_LoadList();
  1019. for( j=0; j<FMPKLIST_MAXNUM; j++){ 
  1020. for (i=0; i<MAXCONNECTION; i++){
  1021. if( gs[i].use && gs[i].name[0] )
  1022. saacproto_ACLoadFmPk_send(i, FMPK_GetData( j) );
  1023. }
  1024. }
  1025. }
  1026. break;
  1027. }
  1028. }
  1030. #ifdef _AC_SEND_FM_PK  // WON ADD 庄园对战列表储存在AC
  1031. #ifdef _ACFMPK_LIST
  1032. void saacproto_ACLoadFmPk_recv(int fd, int fmpks_pos)
  1033. {
  1034. if( fmpks_pos < 0 || fmpks_pos > MAX_FMPOINT) return;
  1035. saacproto_ACLoadFmPk_send( fd, FMPK_GetData( fmpks_pos-1) );
  1036. }
  1038. void saacproto_ACSendFmPk_recv(int fd, int fmpks_pos, int userindex, int flg, char *data)
  1039. {
  1040. extern  gmsv gs[MAXCONNECTION];
  1041. char buf[1024];
  1042. int i=0;
  1043. sprintf( buf, "%d|%s", fmpks_pos, data);
  1045. if( ( userindex != -1 && FMPK_GetTypeFlg( fmpks_pos-1) == 1 )||
  1046. FMPK_SetData( fmpks_pos-1, flg, buf, strlen( buf)) != 1 ){
  1047. if(userindex != -1) saacproto_ACSendFmPk_send( fd, userindex, 0);
  1048. log("err ACSendFmPk_send(%d, %d)n", userindex, 0);
  1049. return;
  1050. }
  1051. FMPK_BackUpList();
  1052. for (i=0; i<MAXCONNECTION; i++){
  1053. if( gs[i].use && gs[i].name[0] ){
  1054. saacproto_ACLoadFmPk_send(i, FMPK_GetData( fmpks_pos-1) );
  1055. }
  1056. }
  1057. //送确认讯息
  1058. if(userindex != -1) saacproto_ACSendFmPk_send( fd, userindex, 1);
  1059. }
  1060. #else
  1061. void saacproto_ACLoadFmPk_recv(int fd, int fmpks_pos)
  1062. {
  1063. if(fmpks_pos > MAX_FMPOINT){
  1064. log("n fmpks_pos(%d) too big", fmpks_pos);
  1065. }
  1066. saacproto_ACLoadFmPk_send(fd, fm_pk_list[fmpks_pos-1]);
  1067. }
  1068. void saacproto_ACSendFmPk_recv(int fd, int fmpks_pos, char *data)
  1069. {
  1070. extern  gmsv gs[MAXCONNECTION];
  1071. int i=0;
  1073. if( (fmpks_pos>MAX_FMPOINT) || (fmpks_pos<1) ){
  1074. log("n fmpks_pos(%d) err !!", fmpks_pos);
  1075. }
  1076. sprintf(fm_pk_list[fmpks_pos-1], "%d|%s", fmpks_pos, data);
  1078. for (i=0; i<MAXCONNECTION; i++){
  1079. if (gs[i].use && gs[i].name[0] && i!=fd){
  1080. saacproto_ACLoadFmPk_send(i, fm_pk_list[fmpks_pos-1]);
  1081. }
  1082. }
  1084. save_fm_pk_list();
  1085. }
  1086. #endif
  1088. #endif
  1090. void saacproto_ACManorPKAck_recv(int fd, char *data)
  1091. {
  1092. #ifdef _FAMILY
  1094. #ifdef _AC_SEND_FM_PK  // WON ADD 庄园对战列表储存在AC
  1095. // 不处理
  1096. #else
  1097. extern gmsv gs[MAXCONNECTION];
  1098. int i;
  1100. for (i=0; i<MAXCONNECTION; i++) 
  1101. {
  1102. if (gs[i].use && gs[i].name[0]) 
  1103. {
  1104. saacproto_ACManorPKAck_send(i, data);
  1105. }
  1106. }
  1107. #endif
  1109. #endif
  1110. }
  1112. #ifdef _WAEI_KICK
  1113. void saacproto_ACKick_recv( int ti ,char* id, int lock,int mesgid )
  1114. {
  1115. if( ti != -1 ) {
  1116. if( !is_game_server_login(ti) ){ //MAXCONNECTION
  1117. saacproto_ACKick_send( ti , 0 , "not login" , mesgid );
  1118. return;
  1119. }
  1120. }
  1121. sprintf(retdata, "ACTION !!");
  1122. //"LSLOCK","KICK","DEUNLOCK","UNLOCKALL","LOCK","TYPE", "UNLOCK"
  1123. switch( lock) {
  1124. case 0://LSLOCK
  1125. break;
  1126. case 1: //跨星球踢人 KICK
  1127. {
  1128. int i;
  1129. for(i=0;i<MAXCONNECTION;i++) {
  1130. if( is_game_server_login(i) ){
  1131. saacproto_ACKick_send( i , 1 , id , mesgid );
  1132. }
  1133. }
  1134. }
  1135. break;
  1136. case 2: //DEUNLOCK
  1137. break;
  1138. case 3: //UNLOCKALL
  1139. {
  1140. extern gmsv gs[MAXCONNECTION];
  1142. DeleteMemLockServer( gs[ti].name);
  1143. sprintf(retdata, "GM UNLOCK ALL");
  1144. }
  1145. break;
  1146. case 4: //LOCK
  1147. #ifdef _LOCK_ADD_NAME
  1148. if ( lockUser( getGSName( ti ) , id , "" , "0" , lock , result,sizeof(result),
  1149. retdata ,sizeof( retdata ) , "0" , "0") < 0 ) {
  1150. #else
  1151.   if ( lockUser( getGSName( ti ) , id , "0" , lock , result,sizeof(result),
  1152. retdata ,sizeof( retdata ) , "0" , "0") < 0 ) {
  1153. #endif
  1154. sprintf(retdata, "LOCK USER !!");
  1155.   }
  1156. break;
  1157. case 5: //查询玩家状态 TYPE
  1158. {
  1159. char buf[4096];
  1160. if (GetMemLockState(getHash(id) & 0xff, id, buf)) {
  1161. sprintf(retdata, "USR LOCKED: %s", buf);
  1162. } else {
  1163. sprintf(retdata, "USR UNLOCKED: %s", buf);
  1164. }
  1165. }
  1166. break;
  1167. case 6: //MEMORY UNLOCK; UNLOCK
  1168. {
  1169. char result[100], retdata[100], process[16];
  1170. int ret = 0;
  1171. #ifdef _LOCK_ADD_NAME
  1172. ret = lockUser(  getGSName(ti), id , "" , "0" , 0 , result , sizeof( result ) ,
  1173.                        retdata , sizeof( retdata ) , "0" , "0");
  1174. #else
  1175.         ret = lockUser(  getGSName(ti), id , "0" , 0 , result , sizeof( result ) ,
  1176.                        retdata , sizeof( retdata ) , "0" , "0");
  1177. #endif
  1179. if( strcmp( result , SUCCESSFUL ) == 0 ){
  1180. log( "解锁账号 %s 成功！n" , id );
  1181. } else {
  1182. log( "解锁账号 %s 失败！n" , id );
  1183. return;
  1184. }
  1186. snprintf( process , sizeof(process) , "%d" , ret );
  1187. dummyCallback(ti,0,id,"dummy",charname,process,"",mesgid,0);
  1188. }
  1189. break;
  1190. case 10: //跨星球踢人不含load该星球
  1191. {
  1192. int i;
  1193. for(i=0;i<MAXCONNECTION;i++) {
  1194. if( is_game_server_login(i) && i != ti ){
  1195. saacproto_ACKick_send( i , 1 , id , mesgid );
  1196. }
  1197. }
  1198. }
  1199. }
  1200.     saacproto_ACKick_send( ti, 0, retdata, mesgid );
  1201. }
  1203. #endif
  1205. #ifdef _SEND_EFFECT    // WON ADD 送下雪、下雨等特效
  1206. void SendEffect(char *effect)
  1207. {
  1208.     extern gmsv gs[MAXCONNECTION];
  1209. int i;
  1211. for (i=0; i<MAXCONNECTION; i++) {
  1212. if (gs[i].use && gs[i].name[0]) {
  1213. saacproto_SendEffect_send(i, effect);
  1214. }
  1215. }
  1216. }
  1217. #endif
  1219. #ifdef _AC_SEND_FM_PK  // WON ADD 庄园对战列表储存在AC
  1220. void load_fm_pk_list()
  1221. {
  1222. int i;
  1223. char *filename={"data/family/fm_pk_list.txt"};
  1224. FILE *fp;
  1226. if( !(fp=fopen(filename, "r"))  ){
  1227. return;
  1228. }
  1230. for( i=0; i<FMPKLIST_MAXNUM; i++){
  1231. char buf[256];
  1232. if( fscanf( fp, "%s", buf) == EOF ) break;
  1233. buf[strlen(buf)+1] = 0;
  1234. memcpy( fm_pk_list[i], buf, strlen(buf)+1);
  1235. }
  1237. fclose( fp);
  1238. log("n");
  1239. }
  1241. void save_fm_pk_list()
  1242. {
  1243. int i;
  1244. char *filename={"data/family/fm_pk_list.txt"};
  1245. FILE *fp;
  1247. if( !(fp=fopen(filename, "w"))  ){
  1248. return;
  1249. }
  1251. for( i=0; i<FMPKLIST_MAXNUM; i++){
  1252. fprintf(fp, "%sn", fm_pk_list[i]);
  1253. }
  1255. fclose( fp);
  1257. }
  1258. #endif
  1260. #ifdef _CHAR_POOLITEM
  1261. void saacproto_ACCharInsertPoolItem_recv( int fd, char *cdkey, int userindex, int clifdid, char *Pooldataarg)
  1262. {
  1263. if( !is_game_server_login( fd) ){
  1264.         return;
  1265.     }
  1266. if( InsertCharPoolItem( cdkey, Pooldataarg, strlen(Pooldataarg)) <= 0 ) {
  1267. log("n InsertPoolItem( %s) err!!n", cdkey);
  1268. saacproto_ACCharSavePoolItem_send( fd , FAILED , Pooldataarg, clifdid );
  1269. }
  1270. }
  1272. void saacproto_ACCharSavePoolItem_recv( int fd, char *cdkey, int userindex, int clifdid, char *Pooldataarg)
  1273. {
  1274. if( !is_game_server_login( fd) ){
  1275.         return;
  1276.     }
  1277. if( saveCharPoolItem( cdkey, Pooldataarg, strlen(Pooldataarg)) < 0 ) {
  1278. saacproto_ACCharSavePoolItem_send( fd , FAILED , Pooldataarg, clifdid );
  1279. }
  1280. }
  1282. void saacproto_ACCharGetPoolItem_recv( int fd, char *cdkey, int userindex, int clifdid, int npcid)
  1283. {
  1284. char loadbuf[CHARDATASIZE];
  1285. int ret=-1;
  1286. if( !is_game_server_login( fd) ){
  1287.         return;
  1288.     }
  1290. ret = loadCharPoolItemOne( cdkey , loadbuf , sizeof(loadbuf));
  1292. if( ret == -1 ){//找不到档案
  1293. saacproto_ACCharGetPoolItem_send( fd , FAILED, loadbuf, clifdid, npcid);
  1294. return;
  1295. }
  1296. saacproto_ACCharGetPoolItem_send( fd , SUCCESSFUL, loadbuf, clifdid, npcid);
  1297. }
  1298. #endif
  1301. #ifdef _CHAR_POOLPET
  1302. void saacproto_ACCharInsertPoolPet_recv( int fd, char *cdkey, int userindex, int clifdid, char *Pooldataarg)
  1303. {
  1304. if( !is_game_server_login( fd) ){
  1305.         return;
  1306.     }
  1307. if( InsertCharPoolPet( cdkey, Pooldataarg, strlen(Pooldataarg)) <= 0 ) {
  1308. log("n InsertPoolPet( %s) err!!n", cdkey);
  1309. saacproto_ACCharSavePoolPet_send( fd , FAILED , Pooldataarg, clifdid );
  1310. }
  1311. }
  1313. void saacproto_ACCharSavePoolPet_recv( int fd, char *cdkey, int userindex, int clifdid, char *Pooldataarg)
  1314. {
  1315. if( !is_game_server_login( fd) ){
  1316.         return;
  1317.     }
  1318. if( saveCharPoolPet( cdkey, Pooldataarg, strlen(Pooldataarg)) < 0 ) {
  1319. saacproto_ACCharSavePoolPet_send( fd , FAILED , Pooldataarg, clifdid );
  1320. }
  1321. }
  1323. void saacproto_ACCharGetPoolPet_recv( int fd, char *cdkey, int userindex, int clifdid, int npcid)
  1324. {
  1325. char loadbuf[CHARDATASIZE];
  1326. int ret=-1;
  1327. if( !is_game_server_login( fd) ){
  1328.         return;
  1329.     }
  1331. ret = loadCharPoolPetOne( cdkey , loadbuf , sizeof(loadbuf));
  1333. if( ret == -1 ){//找不到档案
  1334. saacproto_ACCharGetPoolPet_send( fd , FAILED, loadbuf, clifdid, npcid);
  1335. return;
  1336. }
  1337. saacproto_ACCharGetPoolPet_send( fd , SUCCESSFUL, loadbuf, clifdid, npcid);
  1338. }
  1339. #endif
  1341. #ifdef _ALLDOMAN // Syu ADD 排行榜NPC
  1342. void LOAD_herolist()
  1343. {
  1344. FILE *fdb;
  1345. int i, linenum=0;
  1347. char filename[256], token[512];
  1349. snprintf( filename , sizeof( filename ) ,"%s/%s" , "db/herolist","db_herolist.txt");
  1350. if( !( fdb = fopen ( filename , "r+" ) ) ) {
  1351. log("nSyu log open db_herolist.txt error!!");
  1352. return ; 
  1353. }else {
  1354. char *addr;
  1355. fread ( &token , sizeof ( token ) , 1 , fdb ) ;
  1356. fclose ( fdb ) ; 
  1357. do {
  1358. for ( i = 0 ; i < MAX_HERO_COLUMN ; i ++ ) {
  1359. easyGetTokenFromBuf( token , "|", i + 1 , Herolist[ linenum ][ i ] , sizeof( Herolist[ linenum ][ i ] ) );
  1360. }
  1361. linenum ++;
  1362. if ( (addr = strstr ( token , "n" )) ) 
  1363. strcpy ( token , addr + 1 ) ;
  1364. else 
  1365. break;
  1366. } while ( 1 ) ;
  1367. }
  1368. }
  1370. void SAVE_herolist (int fd)
  1371. {
  1372. int i ; 
  1373. FILE *fdb;
  1374. char filename[256];
  1375. snprintf( filename , sizeof( filename ) ,"%s/%s" , "db/herolist","db_herolist.txt");
  1376. if( !( fdb = fopen ( filename , "w" ) ) ) {
  1377. log("nSyu log open db_herolist.txt error!!");
  1378. return ; 
  1379. }else {
  1380. char tmp[256];
  1381. for ( i = 0 ; i < MAX_HERO_LIST ; i ++ ) {
  1382. sprintf( tmp , "%s|%s|%s|%d|%d|%d|%dn" , 
  1383. Herolist[i][0] , 
  1384. Herolist[i][1] , 
  1385. Herolist[i][2] , 
  1386. atoi (Herolist[i][3]) , 
  1387. atoi (Herolist[i][4]) , 
  1388. atoi (Herolist[i][5]) , 
  1389. atoi (Herolist[i][6]) );
  1390. fwrite(tmp, strlen(tmp), 1, fdb );
  1391. }
  1392. fclose ( fdb ) ; 
  1393. }
  1394. }
  1396. void Send_A_herolist( int fd )
  1397. {
  1398. FILE *fdb;
  1399. int lens=0;
  1400. char filename[256],buf[256];
  1403. snprintf( filename , sizeof( filename ) ,"%s/%s" , "db/herolist","db_herolist.txt");
  1404. if( !( fdb = fopen ( filename , "r+" ) ) ) {
  1405. log("n Syu log open db_herolist.txt error!!");
  1406. return ; 
  1407. }else {
  1408. char token[100 * 100];
  1409. memset( token, 0, sizeof(token));
  1410. memset( buf, 0, sizeof(buf));
  1411. while( fgets( buf , sizeof( buf ) , fdb )){
  1412. buf[strlen(buf)] = 0 ;
  1413. if( lens+strlen(buf) >= 65535 ){
  1414. saacproto_UpdataStele_send ( fd , token );
  1415. memset( token, 0, sizeof(token));
  1416. lens = 0;
  1417. }
  1418. strcat( token, buf);
  1419. lens += strlen( buf);
  1420. }
  1421. fclose ( fdb );
  1422. if( strlen( token) > 0 )
  1423. saacproto_UpdataStele_send ( fd , token ); 
  1424. }
  1425. }
  1427. void Send_S_herolist( char *ocdkey , char *oname , char *ncdkey , char *nname , 
  1428.  char *title , int level , int trns , int floor ) 
  1429. {
  1430. int i;
  1431.     extern gmsv gs[MAXCONNECTION];
  1433. for (i = 0 ; i < MAXCONNECTION ; i ++ ) {
  1434. if ( gs[i].use && gs[i].name[0] ) {
  1435. saacproto_S_UpdataStele_send( i , ocdkey , oname ,
  1436. ncdkey , nname , title
  1437. , level , trns , floor );
  1438. log("nSyu log AC Send Single to Gmsv ");
  1439. }
  1440. }
  1441. }
  1442. #endif
  1444. #define MAXUNlockM 50
  1445. #define delaytime (60*3)
  1446. UNLockMenus UNlockM[MAXUNlockM];
  1448. int UNlockM_Init( void)
  1449. {
  1450. int i;
  1451. for( i=0; i<MAXUNlockM; i++) {
  1452. memset( UNlockM[i].PlayerId, 0, sizeof( UNlockM[i].PlayerId));
  1453. UNlockM[i].use = 0;
  1454. UNlockM[i].time = 0;
  1455. }
  1457. return 1;
  1458. }
  1459. void reset_UNlockMPlayer( int ti)
  1460. {
  1461. memset( UNlockM[ti].PlayerId, 0, sizeof( UNlockM[ti].PlayerId));
  1462. UNlockM[ti].use = 0;
  1463. UNlockM[ti].time = 0;
  1464. }
  1466. int UNlockM_isBe( char *id)
  1467. {
  1468. int i;
  1469. for( i=0; i<MAXUNlockM; i++) {
  1470. if( UNlockM[i].use == 0 )continue;
  1471. if( !strcmp( UNlockM[i].PlayerId, id ) ) return 1;
  1472. }
  1473. return 0;
  1474. }
  1476. //andy add 2002/06/20
  1477. int UNlockM_addPlayer( char *id)
  1478. {
  1479. int i, post=-1;
  1481. for( i=0; i<MAXUNlockM; i++) {
  1482. if( UNlockM[i].use == 0 ){
  1483. post = i;
  1484. continue;
  1485. }
  1486. if( !strcmp( UNlockM[i].PlayerId, id ) ){
  1487. reset_UNlockMPlayer( i);
  1488. return -1;
  1489. }
  1490. }
  1491. if( post == -1 )return -1;
  1493. memset( UNlockM[post].PlayerId, 0, sizeof( UNlockM[post].PlayerId));
  1494. sprintf( UNlockM[post].PlayerId, "%s", id);
  1495. UNlockM[post].use = 1;
  1496. UNlockM[post].time = time(NULL)+delaytime;
  1498. return post;
  1499. }
  1501. //andy add 2002/06/20
  1502. int UNlockM_UnlockPlayer( void)
  1503. {
  1504. int i, nums=0;
  1505. static int UnlockClock = 0;
  1507. if( (++UnlockClock)<60 != 0 ) return 0;
  1509. //log(" UNlockM_UnlockPlayer ");
  1511. UnlockClock =0;
  1512. for( i=0; i<MAXUNlockM; i++) {
  1513. if( !UNlockM[i].use ) continue;
  1514. if( UNlockM[i].time >= time(NULL) ) continue;
  1515. if( isLocked( UNlockM[i].PlayerId ) ){
  1516. log( "等待解锁玩家: %s 还需锁定!!n", UNlockM[i].PlayerId);
  1517. }else{
  1518. log( "等待解锁玩家: %s 已经解锁!!n", UNlockM[i].PlayerId);
  1519. }
  1520. reset_UNlockMPlayer( i);
  1521. nums++;
  1522. }
  1523. //log( "等待解锁玩家: 总计 %d 个用户解锁 !!n", nums);
  1524. return nums;
  1525. }
  1528. #ifdef _ANGEL_SUMMON
  1530. extern int saveMissionTable( void );
  1532. //void saacproto_ACMissionTable_recv( int fd, int num, int type, char *data, int charaindex)
  1533. void saacproto_ACMissionTable_recv( int fd, int num, int type, char *data, char* angelinfo)
  1534. {
  1535. extern  gmsv gs[MAXCONNECTION];
  1536. int i;
  1537. char buf[1024];
  1539. if( type == 1 ) { // ask data list
  1540. if( num == -1) { // ask all data
  1541. char alldata[MAXMISSIONTABLE*100];
  1542. alldata[0]='';
  1543. for( i =0; i <MAXMISSIONTABLE; i++) {
  1544. if( missiontable[i].flag == MISSION_NONE)
  1545. continue;
  1546. sprintf( buf, "%d|%s|%s|%d|%d|%d|%d ",
  1547. i,
  1548. missiontable[i].angelinfo,
  1549. missiontable[i].heroinfo,
  1550. missiontable[i].mission,
  1551. missiontable[i].flag,
  1552. missiontable[i].time,
  1553. missiontable[i].limittime );
  1554. strcat( alldata, buf);
  1555. }
  1556. saacproto_ACMissionTable_send( fd, -1, 1, alldata, "");
  1557. return;
  1558. }
  1559. /*
  1560. else { // ask one data
  1561. sprintf( buf, "%d|%s|%s|%d|%d|%d ",
  1562. num,
  1563. missiontable[num].angelinfo,
  1564. missiontable[num].heroinfo,
  1565. missiontable[num].mission,
  1566. missiontable[num].flag,
  1567. missiontable[num].time );
  1568. saacproto_ACMissionTable_send( fd, 1, 1, buf, "");
  1569. return;
  1570. }
  1571. */
  1572. }
  1573. else if( type == 2 ) { // add data
  1574. int empty =-1;
  1576. log("n增加精灵召唤任务:%s n", data);
  1577. for( i =0; i <MAXMISSIONTABLE; i++) {
  1578. if( missiontable[i].angelinfo[0] == '' ) {
  1579. empty = i;
  1580. break;
  1581. }
  1582. }
  1583. if( empty == -1) {
  1584. saacproto_ACMissionTable_send( fd, -1, 2, "", angelinfo);
  1585. return;
  1586. }
  1588. easyGetTokenFromBuf( data, "|", 1, buf, sizeof( buf));
  1589. strcpy( missiontable[empty].angelinfo, buf);
  1590. easyGetTokenFromBuf( data, "|", 2, buf, sizeof( buf));
  1591. strcpy( missiontable[empty].heroinfo, buf);
  1592. easyGetTokenFromBuf( data, "|", 3, buf, sizeof( buf));
  1593. missiontable[empty].mission = atoi( buf);
  1594. easyGetTokenFromBuf( data, "|", 4, buf, sizeof( buf));
  1595. missiontable[empty].flag = atoi( buf);
  1596. //easyGetTokenFromBuf( data, "|", 5, buf, sizeof( buf));
  1597. //missiontable[empty].time = atoi( buf);
  1598. missiontable[empty].time = (int)time(NULL);
  1599. missiontable[empty].limittime = 1;
  1601. saveMissionTable();
  1603. sprintf( buf, "%d|%s|%s|%d|%d|%d|%d ",
  1604. empty,
  1605. missiontable[empty].angelinfo,
  1606. missiontable[empty].heroinfo,
  1607. missiontable[empty].mission,
  1608. missiontable[empty].flag,
  1609. missiontable[empty].time,
  1610. missiontable[empty].limittime );
  1612. for( i=0; i<MAXCONNECTION; i++) {
  1613. if (gs[i].use && gs[i].name[0]) {
  1614. saacproto_ACMissionTable_send( i, 1, 1, buf, "");
  1615. }
  1616. }
  1618. saacproto_ACMissionTable_send( fd, 0, 2, "", angelinfo);
  1620. return;
  1621. }
  1622. else if( type == 3 ) { // del data
  1624. delMissionTableOnedata( num);
  1626. saveMissionTable();
  1628. return;
  1629. }
  1630. else if( type == 4 ) { // change data flag
  1632. char angelinfo[64];
  1633. int limittime;
  1635. log("n增加精灵召唤任务:%s:%d n", data, num);
  1637. if( num == MISSION_DOING ) {
  1638. easyGetTokenFromBuf( data, "|", 1, buf, sizeof( buf));
  1639. strcpy( angelinfo, buf);
  1640. easyGetTokenFromBuf( data, "|", 2, buf, sizeof( buf));
  1641. limittime = atoi( buf);
  1642. }
  1643. else {
  1644. strcpy( angelinfo, data);
  1645. }
  1647. for( i =0; i <MAXMISSIONTABLE; i++) {
  1648. if( missiontable[i].angelinfo[0] == '' )
  1649. continue;
  1650. if( strcmp( missiontable[i].angelinfo, angelinfo)
  1651. && strcmp( missiontable[i].heroinfo, angelinfo) )
  1652. continue;
  1654. missiontable[i].flag = num;
  1656. missiontable[i].time = time(NULL);
  1657. if( num == MISSION_DOING ) {
  1658. missiontable[i].limittime = limittime;
  1659. }
  1661. saveMissionTable();
  1663. sprintf( buf, "%d|%s|%s|%d|%d|%d|%d ",
  1664. i,
  1665. missiontable[i].angelinfo,
  1666. missiontable[i].heroinfo,
  1667. missiontable[i].mission,
  1668. missiontable[i].flag,
  1669. missiontable[i].time,
  1670. missiontable[i].limittime );
  1671. for( i=0; i<MAXCONNECTION; i++) {
  1672. if (gs[i].use && gs[i].name[0]) {
  1673. saacproto_ACMissionTable_send( i, 1, 1, buf, "");
  1674. }
  1675. }
  1676. return;
  1677. }
  1678. }
  1679. }
  1680. #endif
  1682. #ifdef _TEACHER_SYSTEM
  1683. void saacproto_ACCheckCharacterOnLine_recv( int fd, int charaindex, char *id, char *name, int flag)
  1684. {
  1685. LockNode *ln = userlock[getHash(id) & 0xff];
  1686. // 须要确认名字
  1687. if(name != NULL){
  1688. while(ln != NULL){
  1689. if(ln->use != 0){
  1690. if(strcmp(ln->cdkey,id) == 0 && strcmp(ln->name,name) == 0){
  1691. saacproto_ACCheckCharacterOnLine_send(fd,charaindex,1,ln->server,flag);
  1692. return;
  1693. }
  1694. }
  1695. ln = ln->next;
  1696. }
  1697. // 玩家不在线上
  1698. saacproto_ACCheckCharacterOnLine_send(fd,charaindex,0,"",flag);
  1699. }
  1700. // 不须要确认名字
  1701. else{
  1702. while(ln != NULL){
  1703. if(ln->use != 0){
  1704. if(strcmp(ln->cdkey,id) == 0){
  1705. saacproto_ACCheckCharacterOnLine_send(fd,charaindex,1,ln->server,flag);
  1706. return;
  1707. }
  1708. }
  1709. ln = ln->next;
  1710. }
  1711. // 玩家不在线上
  1712. saacproto_ACCheckCharacterOnLine_send(fd,charaindex,0,"",flag);
  1713. }
  1714. }
  1715. #endif
  1717. void saacproto_ACCharLogin_recv( int fd, int clifd, char* id, char* pas, char* ip )
  1718. {
  1719. int res;
  1720. #ifdef _SASQL
  1721. if (strlen(id)==0 || strlen(pas)==0 || strlen(ip)==0){
  1722.   printf("登陆信息有错误！n");
  1723.   saacproto_ACCharLogin_send( fd, clifd, 0);
  1724.   return;
  1725. }
  1726. if (sasql_chehk_lock(id)){
  1727. printf("该账号%s禁止登陆!n",id);
  1728.   saacproto_ACCharLogin_send( fd, clifd, 0);
  1729.   return;
  1730. }
  1731. if (sasql_chehk_lock(ip)){
  1732. printf("该IP%s禁止登陆!n",ip);
  1733.   saacproto_ACCharLogin_send( fd, clifd, 0);
  1734.   return;
  1735. }
  1736. res=sasql_query(id,pas);
  1737. if (res==3){
  1738. #ifdef _SQL_REGISTER
  1739. if(!sasql_register(id,pas))
  1740. #endif
  1741. {
  1742. saacproto_ACCharLogin_send( fd, clifd, 0);
  1743.    return;
  1744. }
  1745. }else if (res!=1){
  1746. saacproto_ACCharLogin_send( fd, clifd, 0);
  1747.   return;
  1748. }
  1749. #endif
  1750. saacproto_ACCharLogin_send( fd , clifd, 1);
  1751. }
  1753. #ifdef _SASQL
  1754. void saacproto_LockLogin_recv( int fd, char* id, char* ip, int flag )
  1755. {
  1756. switch (flag){
  1757. case 0:
  1758. if(strlen(id)>0)
  1759. if(sasql_del_lock(id))
  1760. log("成功解除锁定账号:%sn",id);
  1761. if(strlen(ip)>0)
  1762. if(sasql_del_lock(ip))
  1763. log("成功解除锁定IP:%sn",ip);
  1764. break;
  1765. case 1:
  1766. if(strlen(id)>0)
  1767. if(!sasql_chehk_lock(id))
  1768. if(sasql_add_lock(id))
  1769. log("成功锁定账号:%sn",id);
  1770. if(strlen(ip)>0)
  1771. if(!sasql_chehk_lock(ip))
  1772. if(sasql_add_lock(ip))
  1773. log("成功锁定IP:%sn",ip);
  1774. break;
  1775. default:
  1776. break;
  1777. }
  1778. }
  1779. #endif