int_guild.cpp 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967
  1. // Copyright (c) rAthena Dev Teams - Licensed under GNU GPL
  2. // For more information, see LICENCE in the main folder
  3. #include "int_guild.hpp"
  4. #include <memory>
  5. #include <unordered_map>
  6. #include <stdlib.h>
  7. #define __STDC_WANT_LIB_EXT1__ 1
  8. #include <string.h>
  9. #include "../common/cbasetypes.hpp"
  10. #include "../common/malloc.hpp"
  11. #include "../common/mmo.hpp"
  12. #include "../common/showmsg.hpp"
  13. #include "../common/socket.hpp"
  14. #include "../common/strlib.hpp"
  15. #include "../common/timer.hpp"
  16. #include "char.hpp"
  17. #include "char_mapif.hpp"
  18. #include "inter.hpp"
  19. using namespace rathena;
  20. #define GS_MEMBER_UNMODIFIED 0x00
  21. #define GS_MEMBER_MODIFIED 0x01
  22. #define GS_MEMBER_NEW 0x02
  23. #define GS_POSITION_UNMODIFIED 0x00
  24. #define GS_POSITION_MODIFIED 0x01
  25. // LSB = 0 => Alliance, LSB = 1 => Opposition
  26. #define GUILD_ALLIANCE_TYPE_MASK 0x01
  27. #define GUILD_ALLIANCE_REMOVE 0x08
  28. static const char dataToHex[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'};
  29. // int guild_id -> struct guild*
  30. static std::unordered_map<int32, std::shared_ptr<struct guild>> guild_db;
  31. static std::unordered_map<int32, std::shared_ptr<struct guild_castle>> castle_db;
  32. int mapif_parse_GuildLeave(int fd,int guild_id,uint32 account_id,uint32 char_id,int flag,const char *mes);
  33. int mapif_guild_broken(int guild_id,int flag);
  34. bool guild_check_empty( std::shared_ptr<struct guild> g );
  35. int guild_calcinfo( std::shared_ptr<struct guild> g );
  36. int mapif_guild_basicinfochanged(int guild_id,int type,const void *data,int len);
  37. int mapif_guild_info( int fd, std::shared_ptr<struct guild> g );
  38. int inter_guild_tosql( std::shared_ptr<struct guild> g, int flag );
  39. int guild_checkskill( std::shared_ptr<struct guild> g, int id );
  40. TIMER_FUNC(guild_save_timer){
  41. static int last_id = 0; //To know in which guild we were.
  42. int state = 0; //0: Have not reached last guild. 1: Reached last guild, ready for save. 2: Some guild saved, don't do further saving.
  43. if( last_id == 0 ) //Save the first guild in the list.
  44. state = 1;
  45. for( auto it = guild_db.begin(); it != guild_db.end(); ){
  46. std::shared_ptr<struct guild> g = it->second;
  47. if( state == 0 && g->guild_id == last_id )
  48. state++; //Save next guild in the list.
  49. else if( state == 1 && g->save_flag&GS_MASK )
  50. {
  51. inter_guild_tosql(g, g->save_flag&GS_MASK);
  52. g->save_flag &= ~GS_MASK;
  53. //Some guild saved.
  54. last_id = g->guild_id;
  55. state++;
  56. }
  57. // Nothing to save, guild is ready for removal.
  58. if( g->save_flag == GS_REMOVE ){
  59. if (charserv_config.save_log)
  60. ShowInfo("Guild Unloaded (%d - %s)\n", g->guild_id, g->name);
  61. it = guild_db.erase( it );
  62. }else{
  63. it++;
  64. }
  65. }
  66. if( state != 2 ) //Reached the end of the guild db without saving.
  67. last_id = 0; //Reset guild saved, return to beginning.
  68. state = guild_db.size();
  69. if( state < 1 ) state = 1; //Calculate the time slot for the next save.
  70. add_timer(tick + (charserv_config.autosave_interval)/state, guild_save_timer, 0, 0);
  71. return 0;
  72. }
  73. int inter_guild_removemember_tosql(uint32 char_id)
  74. {
  75. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE from `%s` where `char_id` = '%d'", schema_config.guild_member_db, char_id) )
  76. Sql_ShowDebug(sql_handle);
  77. if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `guild_id` = '0' WHERE `char_id` = '%d'", schema_config.char_db, char_id) )
  78. Sql_ShowDebug(sql_handle);
  79. return 0;
  80. }
  81. // Save guild into sql
  82. int inter_guild_tosql( std::shared_ptr<struct guild> g, int flag ){
  83. // Table guild (GS_BASIC_MASK)
  84. // GS_EMBLEM `emblem_len`,`emblem_id`,`emblem_data`
  85. // GS_CONNECT `connect_member`,`average_lv`
  86. // GS_MES `mes1`,`mes2`
  87. // GS_LEVEL `guild_lv`,`max_member`,`exp`,`next_exp`,`skill_point`
  88. // GS_BASIC `name`,`master`,`char_id`
  89. // GS_MEMBER `guild_member` (`guild_id`,`char_id`,`exp`,`position`)
  90. // GS_POSITION `guild_position` (`guild_id`,`position`,`name`,`mode`,`exp_mode`)
  91. // GS_ALLIANCE `guild_alliance` (`guild_id`,`opposition`,`alliance_id`,`name`)
  92. // GS_EXPULSION `guild_expulsion` (`guild_id`,`account_id`,`name`,`mes`)
  93. // GS_SKILL `guild_skill` (`guild_id`,`id`,`lv`)
  94. // temporary storage for str convertion. They must be twice the size of the
  95. // original string to ensure no overflows will occur. [Skotlex]
  96. char t_info[256];
  97. char esc_name[NAME_LENGTH*2+1];
  98. char esc_master[NAME_LENGTH*2+1];
  99. char new_guild = 0;
  100. int i=0;
  101. if (g->guild_id<=0 && g->guild_id != -1) return 0;
  102. #ifdef NOISY
  103. ShowInfo("Save guild request (" CL_BOLD "%d" CL_RESET " - flag 0x%x).",g->guild_id, flag);
  104. #endif
  105. Sql_EscapeStringLen(sql_handle, esc_name, g->name, strnlen(g->name, NAME_LENGTH));
  106. Sql_EscapeStringLen(sql_handle, esc_master, g->master, strnlen(g->master, NAME_LENGTH));
  107. *t_info = '\0';
  108. // Insert a new guild the guild
  109. if (flag&GS_BASIC && g->guild_id == -1)
  110. {
  111. strcat(t_info, " guild_create");
  112. // Create a new guild
  113. if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `%s` "
  114. "(`name`,`master`,`guild_lv`,`max_member`,`average_lv`,`char_id`) "
  115. "VALUES ('%s', '%s', '%d', '%d', '%d', '%d')",
  116. schema_config.guild_db, esc_name, esc_master, g->guild_lv, g->max_member, g->average_lv, g->member[0].char_id) )
  117. {
  118. Sql_ShowDebug(sql_handle);
  119. return 0; //Failed to create guild!
  120. }
  121. else
  122. {
  123. g->guild_id = (int)Sql_LastInsertId(sql_handle);
  124. new_guild = 1;
  125. }
  126. }
  127. // If we need an update on an existing guild or more update on the new guild
  128. if (((flag & GS_BASIC_MASK) && !new_guild) || ((flag & (GS_BASIC_MASK & ~GS_BASIC)) && new_guild))
  129. {
  130. StringBuf buf;
  131. bool add_comma = false;
  132. StringBuf_Init(&buf);
  133. StringBuf_Printf(&buf, "UPDATE `%s` SET ", schema_config.guild_db);
  134. if (flag & GS_EMBLEM)
  135. {
  136. char emblem_data[sizeof(g->emblem_data)*2+1];
  137. char* pData = emblem_data;
  138. strcat(t_info, " emblem");
  139. // Convert emblem_data to hex
  140. //TODO: why not use binary directly? [ultramage]
  141. for(i=0; i<g->emblem_len; i++){
  142. *pData++ = dataToHex[(g->emblem_data[i] >> 4) & 0x0F];
  143. *pData++ = dataToHex[g->emblem_data[i] & 0x0F];
  144. }
  145. *pData = 0;
  146. StringBuf_Printf(&buf, "`emblem_len`=%d, `emblem_id`=%d, `emblem_data`='%s'", g->emblem_len, g->emblem_id, emblem_data);
  147. add_comma = true;
  148. }
  149. if (flag & GS_BASIC)
  150. {
  151. strcat(t_info, " basic");
  152. if( add_comma )
  153. StringBuf_AppendStr(&buf, ", ");
  154. else
  155. add_comma = true;
  156. StringBuf_Printf(&buf, "`name`='%s', `master`='%s', `char_id`=%d", esc_name, esc_master, g->member[0].char_id);
  157. if (g->last_leader_change)
  158. StringBuf_Printf(&buf, ", `last_master_change`=FROM_UNIXTIME(%d)", g->last_leader_change);
  159. }
  160. if (flag & GS_CONNECT)
  161. {
  162. strcat(t_info, " connect");
  163. if( add_comma )
  164. StringBuf_AppendStr(&buf, ", ");
  165. else
  166. add_comma = true;
  167. StringBuf_Printf(&buf, "`connect_member`=%d, `average_lv`=%d", g->connect_member, g->average_lv);
  168. }
  169. if (flag & GS_MES)
  170. {
  171. char esc_mes1[sizeof(g->mes1)*2+1];
  172. char esc_mes2[sizeof(g->mes2)*2+1];
  173. strcat(t_info, " mes");
  174. if( add_comma )
  175. StringBuf_AppendStr(&buf, ", ");
  176. else
  177. add_comma = true;
  178. Sql_EscapeStringLen(sql_handle, esc_mes1, g->mes1, strnlen(g->mes1, sizeof(g->mes1)));
  179. Sql_EscapeStringLen(sql_handle, esc_mes2, g->mes2, strnlen(g->mes2, sizeof(g->mes2)));
  180. StringBuf_Printf(&buf, "`mes1`='%s', `mes2`='%s'", esc_mes1, esc_mes2);
  181. }
  182. if (flag & GS_LEVEL)
  183. {
  184. strcat(t_info, " level");
  185. if( add_comma )
  186. StringBuf_AppendStr(&buf, ", ");
  187. //else //last condition using add_coma setting
  188. // add_comma = true;
  189. StringBuf_Printf(&buf, "`guild_lv`=%d, `skill_point`=%d, `exp`=%" PRIu64 ", `next_exp`=%" PRIu64 ", `max_member`=%d", g->guild_lv, g->skill_point, g->exp, g->next_exp, g->max_member);
  190. }
  191. StringBuf_Printf(&buf, " WHERE `guild_id`=%d", g->guild_id);
  192. if( SQL_ERROR == Sql_Query(sql_handle, "%s", StringBuf_Value(&buf)) )
  193. Sql_ShowDebug(sql_handle);
  194. StringBuf_Destroy(&buf);
  195. }
  196. if (flag&GS_MEMBER)
  197. {
  198. strcat(t_info, " members");
  199. // Update only needed players
  200. for(i=0;i<g->max_member;i++){
  201. struct guild_member *m = &g->member[i];
  202. if (!m->modified)
  203. continue;
  204. if(m->account_id) {
  205. //Since nothing references guild member table as foreign keys, it's safe to use REPLACE INTO
  206. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`char_id`,`exp`,`position`) "
  207. "VALUES ('%d','%d','%" PRIu64 "','%d')",
  208. schema_config.guild_member_db, g->guild_id, m->char_id, m->exp, m->position ) )
  209. Sql_ShowDebug(sql_handle);
  210. if (m->modified&GS_MEMBER_NEW || new_guild == 1)
  211. {
  212. if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `guild_id` = '%d' WHERE `char_id` = '%d'",
  213. schema_config.char_db, g->guild_id, m->char_id) )
  214. Sql_ShowDebug(sql_handle);
  215. }
  216. m->modified = GS_MEMBER_UNMODIFIED;
  217. }
  218. }
  219. }
  220. if (flag&GS_POSITION){
  221. strcat(t_info, " positions");
  222. //printf("- Insert guild %d to guild_position\n",g->guild_id);
  223. for(i=0;i<MAX_GUILDPOSITION;i++){
  224. struct guild_position *p = &g->position[i];
  225. if (!p->modified)
  226. continue;
  227. Sql_EscapeStringLen(sql_handle, esc_name, p->name, strnlen(p->name, NAME_LENGTH));
  228. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`position`,`name`,`mode`,`exp_mode`) VALUES ('%d','%d','%s','%d','%d')",
  229. schema_config.guild_position_db, g->guild_id, i, esc_name, p->mode, p->exp_mode) )
  230. Sql_ShowDebug(sql_handle);
  231. p->modified = GS_POSITION_UNMODIFIED;
  232. }
  233. }
  234. if (flag&GS_ALLIANCE)
  235. {
  236. // Delete current alliances
  237. // NOTE: no need to do it on both sides since both guilds in memory had
  238. // their info changed, not to mention this would also mess up oppositions!
  239. // [Skotlex]
  240. //if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id`='%d' OR `alliance_id`='%d'", guild_alliance_db, g->guild_id, g->guild_id) )
  241. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id`='%d'", schema_config.guild_alliance_db, g->guild_id) )
  242. {
  243. Sql_ShowDebug(sql_handle);
  244. }
  245. else
  246. {
  247. //printf("- Insert guild %d to guild_alliance\n",g->guild_id);
  248. for(i=0;i<MAX_GUILDALLIANCE;i++)
  249. {
  250. struct guild_alliance *a=&g->alliance[i];
  251. if(a->guild_id>0)
  252. {
  253. Sql_EscapeStringLen(sql_handle, esc_name, a->name, strnlen(a->name, NAME_LENGTH));
  254. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`opposition`,`alliance_id`,`name`) "
  255. "VALUES ('%d','%d','%d','%s')",
  256. schema_config.guild_alliance_db, g->guild_id, a->opposition, a->guild_id, esc_name) )
  257. Sql_ShowDebug(sql_handle);
  258. }
  259. }
  260. }
  261. }
  262. if (flag&GS_EXPULSION){
  263. strcat(t_info, " expulsions");
  264. //printf("- Insert guild %d to guild_expulsion\n",g->guild_id);
  265. for(i=0;i<MAX_GUILDEXPULSION;i++){
  266. struct guild_expulsion *e=&g->expulsion[i];
  267. if(e->account_id>0){
  268. char esc_mes[sizeof(e->mes)*2+1];
  269. Sql_EscapeStringLen(sql_handle, esc_name, e->name, strnlen(e->name, NAME_LENGTH));
  270. Sql_EscapeStringLen(sql_handle, esc_mes, e->mes, strnlen(e->mes, sizeof(e->mes)));
  271. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`account_id`,`name`,`mes`) "
  272. "VALUES ('%d','%d','%s','%s')", schema_config.guild_expulsion_db, g->guild_id, e->account_id, esc_name, esc_mes) )
  273. Sql_ShowDebug(sql_handle);
  274. }
  275. }
  276. }
  277. if (flag&GS_SKILL){
  278. strcat(t_info, " skills");
  279. //printf("- Insert guild %d to guild_skill\n",g->guild_id);
  280. for(i=0;i<MAX_GUILDSKILL;i++){
  281. if (g->skill[i].id>0 && g->skill[i].lv>0){
  282. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`id`,`lv`) VALUES ('%d','%d','%d')",
  283. schema_config.guild_skill_db, g->guild_id, g->skill[i].id, g->skill[i].lv) )
  284. Sql_ShowDebug(sql_handle);
  285. }
  286. }
  287. }
  288. if (charserv_config.save_log)
  289. ShowInfo("Saved guild (%d - %s):%s\n",g->guild_id,g->name,t_info);
  290. return 1;
  291. }
  292. // Read guild from sql
  293. std::shared_ptr<struct guild> inter_guild_fromsql( int32 guild_id ){
  294. char* data;
  295. size_t len;
  296. char* p;
  297. int i;
  298. if( guild_id <= 0 ){
  299. return nullptr;
  300. }
  301. std::shared_ptr<struct guild> g = util::umap_find( guild_db, guild_id );
  302. if( g != nullptr ){
  303. return g;
  304. }
  305. #ifdef NOISY
  306. ShowInfo("Guild load request (%d)...\n", guild_id);
  307. #endif
  308. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT g.`name`,c.`name`,g.`guild_lv`,g.`connect_member`,g.`max_member`,g.`average_lv`,g.`exp`,g.`next_exp`,g.`skill_point`,g.`mes1`,g.`mes2`,g.`emblem_len`,g.`emblem_id`,COALESCE(UNIX_TIMESTAMP(g.`last_master_change`),0), g.`emblem_data` "
  309. "FROM `%s` g LEFT JOIN `%s` c ON c.`char_id` = g.`char_id` WHERE g.`guild_id`='%d'", schema_config.guild_db, schema_config.char_db, guild_id) )
  310. {
  311. Sql_ShowDebug(sql_handle);
  312. return nullptr;
  313. }
  314. // Guild does not exists.
  315. if( SQL_SUCCESS != Sql_NextRow( sql_handle ) ){
  316. return nullptr;
  317. }
  318. g = std::make_shared<struct guild>();
  319. g->guild_id = guild_id;
  320. Sql_GetData(sql_handle, 0, &data, &len); memcpy(g->name, data, zmin(len, NAME_LENGTH));
  321. Sql_GetData(sql_handle, 1, &data, &len); memcpy(g->master, data, zmin(len, NAME_LENGTH));
  322. Sql_GetData(sql_handle, 2, &data, NULL); g->guild_lv = atoi(data);
  323. Sql_GetData(sql_handle, 3, &data, NULL); g->connect_member = atoi(data);
  324. Sql_GetData(sql_handle, 4, &data, NULL); g->max_member = atoi(data);
  325. if( g->max_member > MAX_GUILD )
  326. { // Fix reduction of MAX_GUILD [PoW]
  327. ShowWarning("Guild %d:%s specifies higher capacity (%d) than MAX_GUILD (%d)\n", guild_id, g->name, g->max_member, MAX_GUILD);
  328. g->max_member = MAX_GUILD;
  329. }
  330. Sql_GetData(sql_handle, 5, &data, NULL); g->average_lv = atoi(data);
  331. Sql_GetData(sql_handle, 6, &data, NULL); g->exp = strtoull(data, NULL, 10);
  332. Sql_GetData(sql_handle, 7, &data, NULL); g->next_exp = strtoull(data, nullptr, 10);
  333. Sql_GetData(sql_handle, 8, &data, NULL); g->skill_point = atoi(data);
  334. Sql_GetData(sql_handle, 9, &data, &len); memcpy(g->mes1, data, zmin(len, sizeof(g->mes1)));
  335. Sql_GetData(sql_handle, 10, &data, &len); memcpy(g->mes2, data, zmin(len, sizeof(g->mes2)));
  336. Sql_GetData(sql_handle, 11, &data, &len); g->emblem_len = atoi(data);
  337. Sql_GetData(sql_handle, 12, &data, &len); g->emblem_id = atoi(data);
  338. Sql_GetData(sql_handle, 13, &data, NULL); g->last_leader_change = atoi(data);
  339. Sql_GetData(sql_handle, 14, &data, &len);
  340. // convert emblem data from hexadecimal to binary
  341. //TODO: why not store it in the db as binary directly? [ultramage]
  342. for( i = 0, p = g->emblem_data; i < g->emblem_len; ++i, ++p )
  343. {
  344. if( *data >= '0' && *data <= '9' )
  345. *p = *data - '0';
  346. else if( *data >= 'a' && *data <= 'f' )
  347. *p = *data - 'a' + 10;
  348. else if( *data >= 'A' && *data <= 'F' )
  349. *p = *data - 'A' + 10;
  350. *p <<= 4;
  351. ++data;
  352. if( *data >= '0' && *data <= '9' )
  353. *p |= *data - '0';
  354. else if( *data >= 'a' && *data <= 'f' )
  355. *p |= *data - 'a' + 10;
  356. else if( *data >= 'A' && *data <= 'F' )
  357. *p |= *data - 'A' + 10;
  358. ++data;
  359. }
  360. // load guild member info
  361. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `c`.`account_id`,`m`.`char_id`,`c`.`hair`,`c`.`hair_color`,`c`.`sex`,`c`.`class`,`c`.`base_level`,`m`.`exp`,`c`.`online`,`m`.`position`,`c`.`name`,coalesce(UNIX_TIMESTAMP(`c`.`last_login`),0) "
  362. "FROM `%s` `m` INNER JOIN `%s` `c` on `c`.`char_id`=`m`.`char_id` WHERE `m`.`guild_id`='%d' ORDER BY `position`", schema_config.guild_member_db, schema_config.char_db, guild_id) )
  363. {
  364. Sql_ShowDebug(sql_handle);
  365. return nullptr;
  366. }
  367. for( i = 0; i < g->max_member && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
  368. {
  369. struct guild_member* m = &g->member[i];
  370. Sql_GetData(sql_handle, 0, &data, NULL); m->account_id = atoi(data);
  371. Sql_GetData(sql_handle, 1, &data, NULL); m->char_id = atoi(data);
  372. Sql_GetData(sql_handle, 2, &data, NULL); m->hair = atoi(data);
  373. Sql_GetData(sql_handle, 3, &data, NULL); m->hair_color = atoi(data);
  374. Sql_GetData(sql_handle, 4, &data, NULL);
  375. switch( *data ){
  376. case 'F':
  377. m->gender = SEX_FEMALE;
  378. break;
  379. case 'M':
  380. m->gender = SEX_MALE;
  381. break;
  382. default:
  383. ShowWarning( "inter_guild_fromsql: Unsupported gender %c for char_id %u. Defaulting to male...\n", *data, m->char_id );
  384. m->gender = SEX_MALE;
  385. break;
  386. }
  387. Sql_GetData(sql_handle, 5, &data, NULL); m->class_ = atoi(data);
  388. Sql_GetData(sql_handle, 6, &data, NULL); m->lv = atoi(data);
  389. Sql_GetData(sql_handle, 7, &data, NULL); m->exp = strtoull(data, NULL, 10);
  390. Sql_GetData(sql_handle, 8, &data, NULL); m->online = atoi(data);
  391. Sql_GetData(sql_handle, 9, &data, NULL); m->position = atoi(data);
  392. if( m->position >= MAX_GUILDPOSITION ) // Fix reduction of MAX_GUILDPOSITION [PoW]
  393. m->position = MAX_GUILDPOSITION - 1;
  394. Sql_GetData(sql_handle, 10, &data, &len); memcpy(m->name, data, zmin(len, NAME_LENGTH));
  395. Sql_GetData(sql_handle, 11, &data, NULL); m->last_login = atoi(data);
  396. m->modified = GS_MEMBER_UNMODIFIED;
  397. }
  398. //printf("- Read guild_position %d from sql \n",guild_id);
  399. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `position`,`name`,`mode`,`exp_mode` FROM `%s` WHERE `guild_id`='%d'", schema_config.guild_position_db, guild_id) )
  400. {
  401. Sql_ShowDebug(sql_handle);
  402. return nullptr;
  403. }
  404. while( SQL_SUCCESS == Sql_NextRow(sql_handle) )
  405. {
  406. int position;
  407. struct guild_position* gpos;
  408. Sql_GetData(sql_handle, 0, &data, NULL); position = atoi(data);
  409. if( position < 0 || position >= MAX_GUILDPOSITION )
  410. continue;// invalid position
  411. gpos = &g->position[position];
  412. Sql_GetData(sql_handle, 1, &data, &len); memcpy(gpos->name, data, zmin(len, NAME_LENGTH));
  413. Sql_GetData(sql_handle, 2, &data, NULL); gpos->mode = atoi(data);
  414. Sql_GetData(sql_handle, 3, &data, NULL); gpos->exp_mode = atoi(data);
  415. gpos->modified = GS_POSITION_UNMODIFIED;
  416. }
  417. //printf("- Read guild_alliance %d from sql \n",guild_id);
  418. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `opposition`,`alliance_id`,`name` FROM `%s` WHERE `guild_id`='%d'", schema_config.guild_alliance_db, guild_id) )
  419. {
  420. Sql_ShowDebug(sql_handle);
  421. return nullptr;
  422. }
  423. for( i = 0; i < MAX_GUILDALLIANCE && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
  424. {
  425. struct guild_alliance* a = &g->alliance[i];
  426. Sql_GetData(sql_handle, 0, &data, NULL); a->opposition = atoi(data);
  427. Sql_GetData(sql_handle, 1, &data, NULL); a->guild_id = atoi(data);
  428. Sql_GetData(sql_handle, 2, &data, &len); memcpy(a->name, data, zmin(len, NAME_LENGTH));
  429. }
  430. //printf("- Read guild_expulsion %d from sql \n",guild_id);
  431. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `account_id`,`name`,`mes` FROM `%s` WHERE `guild_id`='%d'", schema_config.guild_expulsion_db, guild_id) )
  432. {
  433. Sql_ShowDebug(sql_handle);
  434. return nullptr;
  435. }
  436. for( i = 0; i < MAX_GUILDEXPULSION && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
  437. {
  438. struct guild_expulsion *e = &g->expulsion[i];
  439. Sql_GetData(sql_handle, 0, &data, NULL); e->account_id = atoi(data);
  440. Sql_GetData(sql_handle, 1, &data, &len); memcpy(e->name, data, zmin(len, NAME_LENGTH));
  441. Sql_GetData(sql_handle, 2, &data, &len); memcpy(e->mes, data, zmin(len, sizeof(e->mes)));
  442. }
  443. //printf("- Read guild_skill %d from sql \n",guild_id);
  444. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `id`,`lv` FROM `%s` WHERE `guild_id`='%d' ORDER BY `id`", schema_config.guild_skill_db, guild_id) )
  445. {
  446. Sql_ShowDebug(sql_handle);
  447. return nullptr;
  448. }
  449. for(i = 0; i < MAX_GUILDSKILL; i++)
  450. { //Skill IDs must always be initialized. [Skotlex]
  451. g->skill[i].id = i + GD_SKILLBASE;
  452. }
  453. while( SQL_SUCCESS == Sql_NextRow(sql_handle) )
  454. {
  455. int id;
  456. Sql_GetData(sql_handle, 0, &data, NULL); id = atoi(data) - GD_SKILLBASE;
  457. if( id < 0 || id >= MAX_GUILDSKILL )
  458. continue;// invalid guild skill
  459. Sql_GetData(sql_handle, 1, &data, NULL); g->skill[id].lv = atoi(data);
  460. }
  461. Sql_FreeResult(sql_handle);
  462. // Add to cache
  463. guild_db[g->guild_id] = g;
  464. // But set it to be removed, in case it is not needed for long.
  465. g->save_flag |= GS_REMOVE;
  466. if (charserv_config.save_log)
  467. ShowInfo("Guild loaded (%d - %s)\n", guild_id, g->name);
  468. return g;
  469. }
  470. /**
  471. * Get the max storage size of a guild.
  472. * @param guild_id: Guild ID to search
  473. * @return Guild storage max size
  474. */
  475. uint16 inter_guild_storagemax(int guild_id)
  476. {
  477. #ifdef OFFICIAL_GUILD_STORAGE
  478. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  479. uint16 max = 0;
  480. if( g == nullptr ){
  481. ShowError("Guild %d not found!\n", guild_id);
  482. return 0;
  483. }
  484. max = guild_checkskill(g, GD_GUILD_STORAGE);
  485. if (max)
  486. max *= 100;
  487. return max;
  488. #else
  489. return MAX_GUILD_STORAGE;
  490. #endif
  491. }
  492. // `guild_castle` (`castle_id`, `guild_id`, `economy`, `defense`, `triggerE`, `triggerD`, `nextTime`, `payTime`, `createTime`, `visibleC`, `visibleG0`, `visibleG1`, `visibleG2`, `visibleG3`, `visibleG4`, `visibleG5`, `visibleG6`, `visibleG7`)
  493. int inter_guildcastle_tosql( std::shared_ptr<struct guild_castle> gc ){
  494. StringBuf buf;
  495. int i;
  496. StringBuf_Init(&buf);
  497. StringBuf_Printf(&buf, "REPLACE INTO `%s` SET `castle_id`='%d', `guild_id`='%d', `economy`='%d', `defense`='%d', "
  498. "`triggerE`='%d', `triggerD`='%d', `nextTime`='%d', `payTime`='%d', `createTime`='%d', `visibleC`='%d'",
  499. schema_config.guild_castle_db, gc->castle_id, gc->guild_id, gc->economy, gc->defense,
  500. gc->triggerE, gc->triggerD, gc->nextTime, gc->payTime, gc->createTime, gc->visibleC);
  501. for (i = 0; i < MAX_GUARDIANS; ++i)
  502. StringBuf_Printf(&buf, ", `visibleG%d`='%d'", i, gc->guardian[i].visible);
  503. if (SQL_ERROR == Sql_Query(sql_handle, StringBuf_Value(&buf)))
  504. Sql_ShowDebug(sql_handle);
  505. else if(charserv_config.save_log)
  506. ShowInfo("Saved guild castle (%d)\n", gc->castle_id);
  507. StringBuf_Destroy(&buf);
  508. return 0;
  509. }
  510. // Read guild_castle from SQL
  511. std::shared_ptr<struct guild_castle> inter_guildcastle_fromsql( int castle_id ){
  512. char *data;
  513. int i;
  514. StringBuf buf;
  515. std::shared_ptr<struct guild_castle> gc = util::umap_find( castle_db, castle_id );
  516. if( gc != nullptr ){
  517. return gc;
  518. }
  519. StringBuf_Init(&buf);
  520. StringBuf_AppendStr(&buf, "SELECT `castle_id`, `guild_id`, `economy`, `defense`, `triggerE`, "
  521. "`triggerD`, `nextTime`, `payTime`, `createTime`, `visibleC`");
  522. for (i = 0; i < MAX_GUARDIANS; ++i)
  523. StringBuf_Printf(&buf, ", `visibleG%d`", i);
  524. StringBuf_Printf(&buf, " FROM `%s` WHERE `castle_id`='%d'", schema_config.guild_castle_db, castle_id);
  525. if (SQL_ERROR == Sql_Query(sql_handle, StringBuf_Value(&buf))) {
  526. Sql_ShowDebug(sql_handle);
  527. StringBuf_Destroy(&buf);
  528. return NULL;
  529. }
  530. StringBuf_Destroy(&buf);
  531. gc = std::make_shared<struct guild_castle>();
  532. gc->castle_id = castle_id;
  533. if (SQL_SUCCESS == Sql_NextRow(sql_handle)) {
  534. Sql_GetData(sql_handle, CD_GUILD_ID, &data, NULL); gc->guild_id = atoi(data);
  535. Sql_GetData(sql_handle, CD_CURRENT_ECONOMY, &data, NULL); gc->economy = atoi(data);
  536. Sql_GetData(sql_handle, CD_CURRENT_DEFENSE, &data, NULL); gc->defense = atoi(data);
  537. Sql_GetData(sql_handle, CD_INVESTED_ECONOMY, &data, NULL); gc->triggerE = atoi(data);
  538. Sql_GetData(sql_handle, CD_INVESTED_DEFENSE, &data, NULL); gc->triggerD = atoi(data);
  539. Sql_GetData(sql_handle, CD_NEXT_TIME, &data, NULL); gc->nextTime = atoi(data);
  540. Sql_GetData(sql_handle, CD_PAY_TIME, &data, NULL); gc->payTime = atoi(data);
  541. Sql_GetData(sql_handle, CD_CREATE_TIME, &data, NULL); gc->createTime = atoi(data);
  542. Sql_GetData(sql_handle, CD_ENABLED_KAFRA, &data, NULL); gc->visibleC = atoi(data);
  543. for (i = CD_ENABLED_GUARDIAN00; i < CD_MAX; i++) {
  544. Sql_GetData(sql_handle, i, &data, NULL); gc->guardian[i - CD_ENABLED_GUARDIAN00].visible = atoi(data);
  545. }
  546. }
  547. Sql_FreeResult(sql_handle);
  548. castle_db[gc->castle_id] = gc;
  549. if (charserv_config.save_log)
  550. ShowInfo("Loaded guild castle (%d - guild %d)\n", castle_id, gc->guild_id);
  551. return gc;
  552. }
  553. int inter_guild_CharOnline(uint32 char_id, int guild_id)
  554. {
  555. int i;
  556. if (guild_id == -1) {
  557. //Get guild_id from the database
  558. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT guild_id FROM `%s` WHERE char_id='%d'", schema_config.char_db, char_id) )
  559. {
  560. Sql_ShowDebug(sql_handle);
  561. return 0;
  562. }
  563. if( SQL_SUCCESS == Sql_NextRow(sql_handle) )
  564. {
  565. char* data;
  566. Sql_GetData(sql_handle, 0, &data, NULL);
  567. guild_id = atoi(data);
  568. }
  569. else
  570. {
  571. guild_id = 0;
  572. }
  573. Sql_FreeResult(sql_handle);
  574. }
  575. if (guild_id == 0)
  576. return 0; //No guild...
  577. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  578. if( g == nullptr ){
  579. ShowError("Character %d's guild %d not found!\n", char_id, guild_id);
  580. return 0;
  581. }
  582. //Member has logged in before saving, tell saver not to delete
  583. if(g->save_flag & GS_REMOVE)
  584. g->save_flag &= ~GS_REMOVE;
  585. //Set member online
  586. ARR_FIND( 0, g->max_member, i, g->member[i].char_id == char_id );
  587. if( i < g->max_member )
  588. {
  589. g->member[i].online = 1;
  590. g->member[i].modified = GS_MEMBER_MODIFIED;
  591. }
  592. return 1;
  593. }
  594. int inter_guild_CharOffline(uint32 char_id, int guild_id)
  595. {
  596. int online_count, i;
  597. if (guild_id == -1)
  598. {
  599. //Get guild_id from the database
  600. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT guild_id FROM `%s` WHERE char_id='%d'", schema_config.char_db, char_id) )
  601. {
  602. Sql_ShowDebug(sql_handle);
  603. return 0;
  604. }
  605. if( SQL_SUCCESS == Sql_NextRow(sql_handle) )
  606. {
  607. char* data;
  608. Sql_GetData(sql_handle, 0, &data, NULL);
  609. guild_id = atoi(data);
  610. }
  611. else
  612. {
  613. guild_id = 0;
  614. }
  615. Sql_FreeResult(sql_handle);
  616. }
  617. if (guild_id == 0)
  618. return 0; //No guild...
  619. //Character has a guild, set character offline and check if they were the only member online
  620. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  621. // Guild not found?
  622. if( g == nullptr ){
  623. return 0;
  624. }
  625. //Set member offline
  626. ARR_FIND( 0, g->max_member, i, g->member[i].char_id == char_id );
  627. if( i < g->max_member )
  628. {
  629. g->member[i].online = 0;
  630. g->member[i].modified = GS_MEMBER_MODIFIED;
  631. }
  632. online_count = 0;
  633. for( i = 0; i < g->max_member; i++ )
  634. if( g->member[i].online )
  635. online_count++;
  636. // Remove guild from memory if no players online
  637. if( online_count == 0 )
  638. g->save_flag |= GS_REMOVE;
  639. return 1;
  640. }
  641. const std::string GuildExpDatabase::getDefaultLocation() {
  642. return std::string(db_path) + "/exp_guild.yml";
  643. }
  644. uint64 GuildExpDatabase::parseBodyNode(const ryml::NodeRef& node) {
  645. if (!this->nodesExist(node, { "Level", "Exp" })) {
  646. return 0;
  647. }
  648. uint16 level;
  649. if (!this->asUInt16(node, "Level", level))
  650. return 0;
  651. if (level == 0) {
  652. this->invalidWarning(node, "The minimum guild level is 1.\n");
  653. return 0;
  654. }
  655. if (level >= MAX_GUILDLEVEL) {
  656. this->invalidWarning(node["Level"], "Guild level %d exceeds maximum level %d, skipping.\n", level, MAX_GUILDLEVEL);
  657. return 0;
  658. }
  659. t_exp exp;
  660. if (!this->asUInt64(node, "Exp", exp))
  661. return 0;
  662. if (exp > MAX_GUILD_EXP) {
  663. this->invalidWarning(node["Exp"], "Guild exp %" PRIu64 " exceeds max of %" PRIu64 ".\n", exp, MAX_GUILD_EXP);
  664. return 0;
  665. }
  666. std::shared_ptr<s_guild_exp_db> guild_exp = this->find(level);
  667. bool exists = guild_exp != nullptr;
  668. if (!exists) {
  669. guild_exp = std::make_shared<s_guild_exp_db>();
  670. guild_exp->level = level;
  671. }
  672. guild_exp->exp = static_cast<t_exp>(exp);
  673. if (!exists)
  674. this->put(level, guild_exp);
  675. return 1;
  676. }
  677. GuildExpDatabase guild_exp_db;
  678. void GuildExpDatabase::loadingFinished() {
  679. for (uint16 level = 1; level < MAX_GUILDLEVEL; level++) {
  680. if (this->get_nextexp(level) == 0)
  681. ShowError("Missing experience for guild level %d.\n", level);
  682. }
  683. }
  684. // Initialize guild sql and read exp_guild.yml
  685. void inter_guild_sql_init(void) {
  686. guild_exp_db.load();
  687. add_timer_func_list(guild_save_timer, "guild_save_timer");
  688. add_timer(gettick() + 10000, guild_save_timer, 0, 0);
  689. }
  690. void inter_guild_sql_final(void)
  691. {
  692. for( const auto& pair : guild_db ){
  693. std::shared_ptr<struct guild> guild = pair.second;
  694. if( guild->save_flag&GS_MASK ){
  695. inter_guild_tosql( guild, guild->save_flag&GS_MASK );
  696. }
  697. }
  698. guild_db.clear();
  699. castle_db.clear();
  700. }
  701. // Get guild_id by its name. Returns 0 if not found, -1 on error.
  702. int search_guildname(char *str)
  703. {
  704. int guild_id;
  705. char esc_name[NAME_LENGTH*2+1];
  706. Sql_EscapeStringLen(sql_handle, esc_name, str, safestrnlen(str, NAME_LENGTH));
  707. //Lookup guilds with the same name
  708. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT guild_id FROM `%s` WHERE name='%s'", schema_config.guild_db, esc_name) )
  709. {
  710. Sql_ShowDebug(sql_handle);
  711. return -1;
  712. }
  713. if( SQL_SUCCESS == Sql_NextRow(sql_handle) )
  714. {
  715. char* data;
  716. Sql_GetData(sql_handle, 0, &data, NULL);
  717. guild_id = atoi(data);
  718. }
  719. else
  720. {
  721. guild_id = 0;
  722. }
  723. Sql_FreeResult(sql_handle);
  724. return guild_id;
  725. }
  726. // Check if guild is empty
  727. bool guild_check_empty( std::shared_ptr<struct guild> g ){
  728. int i;
  729. ARR_FIND( 0, g->max_member, i, g->member[i].account_id > 0 );
  730. //Let the calling function handle the guild removal in case they need
  731. //to do something else with it before freeing the data. [Skotlex]
  732. return i < g->max_member ? false : true; // not empty
  733. }
  734. t_exp GuildExpDatabase::get_nextexp(uint16 level) {
  735. std::shared_ptr<s_guild_exp_db> guild_exp = guild_exp_db.find(level);
  736. return ((guild_exp == nullptr) ? 0 : guild_exp->exp);
  737. }
  738. int guild_checkskill( std::shared_ptr<struct guild> g, int id ){
  739. int idx = id - GD_SKILLBASE;
  740. return idx < 0 || idx >= MAX_GUILDSKILL ? 0 : g->skill[idx].lv;
  741. }
  742. int guild_calcinfo( std::shared_ptr<struct guild> g ){
  743. int i,c;
  744. struct guild before = *g; // Save guild current values
  745. if(g->guild_lv<=0)
  746. g->guild_lv = 1;
  747. g->next_exp = guild_exp_db.get_nextexp(g->guild_lv);
  748. // Consume guild exp and increase guild level
  749. while(g->exp >= g->next_exp && g->next_exp > 0 && g->guild_lv < MAX_GUILDLEVEL){
  750. g->exp-=g->next_exp;
  751. g->guild_lv++;
  752. g->skill_point++;
  753. g->next_exp = guild_exp_db.get_nextexp(g->guild_lv);
  754. }
  755. // Set the max number of members, Guild Extention skill - currently adds 6 to max per skill lv.
  756. g->max_member = 16 + guild_checkskill(g, GD_EXTENSION) * 6;
  757. if(g->max_member > MAX_GUILD)
  758. {
  759. ShowError("Guild %d:%s has capacity for too many guild members (%d), max supported is %d\n", g->guild_id, g->name, g->max_member, MAX_GUILD);
  760. g->max_member = MAX_GUILD;
  761. }
  762. // Compute the guild average level
  763. g->average_lv=0;
  764. g->connect_member=0;
  765. for(i=c=0;i<g->max_member;i++)
  766. {
  767. if(g->member[i].account_id>0)
  768. {
  769. if (g->member[i].lv >= 0)
  770. {
  771. g->average_lv+=g->member[i].lv;
  772. c++;
  773. }
  774. else
  775. {
  776. ShowWarning("Guild %d:%s, member %d:%s has an invalid level %d\n", g->guild_id, g->name, g->member[i].char_id, g->member[i].name, g->member[i].lv);
  777. }
  778. if(g->member[i].online)
  779. g->connect_member++;
  780. }
  781. }
  782. if(c)
  783. g->average_lv /= c;
  784. // Check if guild stats has change
  785. if(g->max_member != before.max_member || g->guild_lv != before.guild_lv || g->skill_point != before.skill_point )
  786. {
  787. g->save_flag |= GS_LEVEL;
  788. mapif_guild_info(-1,g);
  789. return 1;
  790. }
  791. return 0;
  792. }
  793. //-------------------------------------------------------------------
  794. // Packet sent to map server
  795. int mapif_guild_created( int fd, uint32 account_id, std::shared_ptr<struct guild> g ){
  796. WFIFOHEAD(fd, 10);
  797. WFIFOW(fd,0)=0x3830;
  798. WFIFOL(fd,2)=account_id;
  799. if(g != NULL)
  800. {
  801. WFIFOL(fd,6)=g->guild_id;
  802. ShowInfo("int_guild: Guild created (%d - %s)\n",g->guild_id,g->name);
  803. } else
  804. WFIFOL(fd,6)=0;
  805. WFIFOSET(fd,10);
  806. return 0;
  807. }
  808. // Guild not found
  809. int mapif_guild_noinfo(int fd,int guild_id)
  810. {
  811. unsigned char buf[12];
  812. WBUFW(buf,0)=0x3831;
  813. WBUFW(buf,2)=8;
  814. WBUFL(buf,4)=guild_id;
  815. ShowWarning("int_guild: info not found %d\n",guild_id);
  816. if(fd<0)
  817. chmapif_sendall(buf,8);
  818. else
  819. chmapif_send(fd,buf,8);
  820. return 0;
  821. }
  822. // Send guild info
  823. int mapif_guild_info( int fd, std::shared_ptr<struct guild> g ){
  824. unsigned char buf[8+sizeof(struct guild)];
  825. WBUFW(buf,0)=0x3831;
  826. WBUFW(buf,2)=4+sizeof(struct guild);
  827. memcpy( buf + 4, g.get(), sizeof( struct guild ) );
  828. if(fd<0)
  829. chmapif_sendall(buf,WBUFW(buf,2));
  830. else
  831. chmapif_send(fd,buf,WBUFW(buf,2));
  832. return 0;
  833. }
  834. // ACK member add
  835. int mapif_guild_memberadded(int fd,int guild_id,uint32 account_id,uint32 char_id,int flag)
  836. {
  837. WFIFOHEAD(fd, 15);
  838. WFIFOW(fd,0)=0x3832;
  839. WFIFOL(fd,2)=guild_id;
  840. WFIFOL(fd,6)=account_id;
  841. WFIFOL(fd,10)=char_id;
  842. WFIFOB(fd,14)=flag;
  843. WFIFOSET(fd,15);
  844. return 0;
  845. }
  846. // ACK member leave
  847. int mapif_guild_withdraw(int guild_id,uint32 account_id,uint32 char_id,int flag, const char *name, const char *mes)
  848. {
  849. unsigned char buf[55+NAME_LENGTH];
  850. WBUFW(buf, 0)=0x3834;
  851. WBUFL(buf, 2)=guild_id;
  852. WBUFL(buf, 6)=account_id;
  853. WBUFL(buf,10)=char_id;
  854. WBUFB(buf,14)=flag;
  855. memcpy(WBUFP(buf,15),mes,40);
  856. memcpy(WBUFP(buf,55),name,NAME_LENGTH);
  857. chmapif_sendall(buf,55+NAME_LENGTH);
  858. ShowInfo("int_guild: guild withdraw (%d - %d: %s - %s)\n",guild_id,account_id,name,mes);
  859. return 0;
  860. }
  861. // Send short member's info
  862. int mapif_guild_memberinfoshort( std::shared_ptr<struct guild> g, int idx ){
  863. unsigned char buf[19];
  864. WBUFW(buf, 0)=0x3835;
  865. WBUFL(buf, 2)=g->guild_id;
  866. WBUFL(buf, 6)=g->member[idx].account_id;
  867. WBUFL(buf,10)=g->member[idx].char_id;
  868. WBUFB(buf,14)=(unsigned char)g->member[idx].online;
  869. WBUFW(buf,15)=g->member[idx].lv;
  870. WBUFW(buf,17)=g->member[idx].class_;
  871. chmapif_sendall(buf,19);
  872. return 0;
  873. }
  874. // Send guild broken
  875. int mapif_guild_broken(int guild_id,int flag)
  876. {
  877. unsigned char buf[7];
  878. WBUFW(buf,0)=0x3836;
  879. WBUFL(buf,2)=guild_id;
  880. WBUFB(buf,6)=flag;
  881. chmapif_sendall(buf,7);
  882. ShowInfo("int_guild: Guild broken (%d)\n",guild_id);
  883. return 0;
  884. }
  885. // Send guild message
  886. int mapif_guild_message(int guild_id,uint32 account_id,char *mes,int len, int sfd)
  887. {
  888. unsigned char buf[512];
  889. if (len > 500)
  890. len = 500;
  891. WBUFW(buf,0)=0x3837;
  892. WBUFW(buf,2)=len+12;
  893. WBUFL(buf,4)=guild_id;
  894. WBUFL(buf,8)=account_id;
  895. memcpy(WBUFP(buf,12),mes,len);
  896. chmapif_sendallwos(sfd, buf,len+12);
  897. return 0;
  898. }
  899. // Send basic info
  900. int mapif_guild_basicinfochanged(int guild_id,int type,const void *data,int len)
  901. {
  902. unsigned char buf[2048];
  903. if (len > 2038)
  904. len = 2038;
  905. WBUFW(buf, 0)=0x3839;
  906. WBUFW(buf, 2)=len+10;
  907. WBUFL(buf, 4)=guild_id;
  908. WBUFW(buf, 8)=type;
  909. memcpy(WBUFP(buf,10),data,len);
  910. chmapif_sendall(buf,len+10);
  911. return 0;
  912. }
  913. // Send member info
  914. int mapif_guild_memberinfochanged(int guild_id,uint32 account_id,uint32 char_id, int type,const void *data,int len)
  915. {
  916. unsigned char buf[2048];
  917. if (len > 2030)
  918. len = 2030;
  919. WBUFW(buf, 0)=0x383a;
  920. WBUFW(buf, 2)=len+18;
  921. WBUFL(buf, 4)=guild_id;
  922. WBUFL(buf, 8)=account_id;
  923. WBUFL(buf,12)=char_id;
  924. WBUFW(buf,16)=type;
  925. memcpy(WBUFP(buf,18),data,len);
  926. chmapif_sendall(buf,len+18);
  927. return 0;
  928. }
  929. // ACK guild skill up
  930. int mapif_guild_skillupack(int guild_id,uint16 skill_id,uint32 account_id)
  931. {
  932. unsigned char buf[14];
  933. WBUFW(buf, 0)=0x383c;
  934. WBUFL(buf, 2)=guild_id;
  935. WBUFL(buf, 6)=skill_id;
  936. WBUFL(buf,10)=account_id;
  937. chmapif_sendall(buf,14);
  938. return 0;
  939. }
  940. // ACK guild alliance
  941. int mapif_guild_alliance(int guild_id1,int guild_id2,uint32 account_id1,uint32 account_id2,int flag,const char *name1,const char *name2)
  942. {
  943. unsigned char buf[19+2*NAME_LENGTH];
  944. WBUFW(buf, 0)=0x383d;
  945. WBUFL(buf, 2)=guild_id1;
  946. WBUFL(buf, 6)=guild_id2;
  947. WBUFL(buf,10)=account_id1;
  948. WBUFL(buf,14)=account_id2;
  949. WBUFB(buf,18)=flag;
  950. memcpy(WBUFP(buf,19),name1,NAME_LENGTH);
  951. memcpy(WBUFP(buf,19+NAME_LENGTH),name2,NAME_LENGTH);
  952. chmapif_sendall(buf,19+2*NAME_LENGTH);
  953. return 0;
  954. }
  955. // Send a guild position desc
  956. int mapif_guild_position( std::shared_ptr<struct guild> g, int idx ){
  957. unsigned char buf[12 + sizeof(struct guild_position)];
  958. WBUFW(buf,0)=0x383b;
  959. WBUFW(buf,2)=sizeof(struct guild_position)+12;
  960. WBUFL(buf,4)=g->guild_id;
  961. WBUFL(buf,8)=idx;
  962. memcpy(WBUFP(buf,12),&g->position[idx],sizeof(struct guild_position));
  963. chmapif_sendall(buf,WBUFW(buf,2));
  964. return 0;
  965. }
  966. // Send the guild notice
  967. int mapif_guild_notice( std::shared_ptr<struct guild> g ){
  968. unsigned char buf[256];
  969. WBUFW(buf,0)=0x383e;
  970. WBUFL(buf,2)=g->guild_id;
  971. memcpy(WBUFP(buf,6),g->mes1,MAX_GUILDMES1);
  972. memcpy(WBUFP(buf,66),g->mes2,MAX_GUILDMES2);
  973. chmapif_sendall(buf,186);
  974. return 0;
  975. }
  976. // Send emblem data
  977. int mapif_guild_emblem( std::shared_ptr<struct guild> g ){
  978. unsigned char buf[12 + sizeof(g->emblem_data)];
  979. WBUFW(buf,0)=0x383f;
  980. WBUFW(buf,2)=g->emblem_len+12;
  981. WBUFL(buf,4)=g->guild_id;
  982. WBUFL(buf,8)=g->emblem_id;
  983. memcpy(WBUFP(buf,12),g->emblem_data,g->emblem_len);
  984. chmapif_sendall(buf,WBUFW(buf,2));
  985. return 0;
  986. }
  987. // Send the guild emblem_id (version)
  988. int mapif_guild_emblem_version( std::shared_ptr<struct guild> g ){
  989. unsigned char buf[10];
  990. WBUFW(buf, 0) = 0x3841;
  991. WBUFL(buf, 2) = g->guild_id;
  992. WBUFL(buf, 6) = g->emblem_id;
  993. chmapif_sendall(buf, 10);
  994. return 0;
  995. }
  996. int mapif_guild_master_changed( std::shared_ptr<struct guild> g, int aid, int cid, time_t time ){
  997. unsigned char buf[18];
  998. WBUFW(buf,0)=0x3843;
  999. WBUFL(buf,2)=g->guild_id;
  1000. WBUFL(buf,6)=aid;
  1001. WBUFL(buf,10)=cid;
  1002. WBUFL(buf,14)=(uint32)time;
  1003. chmapif_sendall(buf,18);
  1004. return 0;
  1005. }
  1006. int mapif_guild_castle_dataload(int fd, int sz, int *castle_ids)
  1007. {
  1008. int num = (sz - 4) / sizeof(int);
  1009. int len = 4 + num * sizeof( struct guild_castle );
  1010. int i;
  1011. WFIFOHEAD(fd, len);
  1012. WFIFOW(fd, 0) = 0x3840;
  1013. WFIFOW(fd, 2) = len;
  1014. for (i = 0; i < num; i++) {
  1015. std::shared_ptr<struct guild_castle> gc = inter_guildcastle_fromsql( *(castle_ids++) );
  1016. memcpy( WFIFOP( fd, 4 + i * sizeof( struct guild_castle ) ), gc.get(), sizeof( struct guild_castle ) );
  1017. }
  1018. WFIFOSET(fd, len);
  1019. return 0;
  1020. }
  1021. //-------------------------------------------------------------------
  1022. // Packet received from map server
  1023. // Guild creation request
  1024. int mapif_parse_CreateGuild(int fd,uint32 account_id,char *name,struct guild_member *master)
  1025. {
  1026. int i=0;
  1027. #ifdef NOISY
  1028. ShowInfo("Creating Guild (%s)\n", name);
  1029. #endif
  1030. if(search_guildname(name) != 0){
  1031. ShowInfo("int_guild: guild with same name exists [%s]\n",name);
  1032. mapif_guild_created(fd,account_id,NULL);
  1033. return 0;
  1034. }
  1035. // Check Authorised letters/symbols in the name of the character
  1036. if (charserv_config.char_config.char_name_option == 1) { // only letters/symbols in char_name_letters are authorised
  1037. for (i = 0; i < NAME_LENGTH && name[i]; i++)
  1038. if (strchr(charserv_config.char_config.char_name_letters, name[i]) == NULL) {
  1039. mapif_guild_created(fd,account_id,NULL);
  1040. return 0;
  1041. }
  1042. } else if (charserv_config.char_config.char_name_option == 2) { // letters/symbols in char_name_letters are forbidden
  1043. for (i = 0; i < NAME_LENGTH && name[i]; i++)
  1044. if (strchr(charserv_config.char_config.char_name_letters, name[i]) != NULL) {
  1045. mapif_guild_created(fd,account_id,NULL);
  1046. return 0;
  1047. }
  1048. }
  1049. std::shared_ptr<struct guild> g = std::make_shared<struct guild>();
  1050. memset( g.get(), 0, sizeof( struct guild ) );
  1051. memcpy(g->name,name,NAME_LENGTH);
  1052. memcpy(g->master,master->name,NAME_LENGTH);
  1053. memcpy(&g->member[0],master,sizeof(struct guild_member));
  1054. g->member[0].modified = GS_MEMBER_MODIFIED;
  1055. // Set default positions
  1056. g->position[0].mode = GUILD_PERM_DEFAULT;
  1057. strcpy(g->position[0].name,"GuildMaster");
  1058. strcpy(g->position[MAX_GUILDPOSITION-1].name,"Newbie");
  1059. g->position[0].modified = g->position[MAX_GUILDPOSITION-1].modified = GS_POSITION_MODIFIED;
  1060. for(i=1;i<MAX_GUILDPOSITION-1;i++) {
  1061. sprintf(g->position[i].name,"Position %d",i+1);
  1062. g->position[i].modified = GS_POSITION_MODIFIED;
  1063. }
  1064. // Initialize guild property
  1065. g->max_member=16;
  1066. g->average_lv=master->lv;
  1067. g->connect_member=1;
  1068. for(i=0;i<MAX_GUILDSKILL;i++)
  1069. g->skill[i].id=i + GD_SKILLBASE;
  1070. g->guild_id= -1; //Request to create guild.
  1071. // Create the guild
  1072. if (!inter_guild_tosql(g,GS_BASIC|GS_POSITION|GS_SKILL|GS_MEMBER)) {
  1073. //Failed to Create guild....
  1074. ShowError("Failed to create Guild %s (Guild Master: %s)\n", g->name, g->master);
  1075. mapif_guild_created(fd,account_id,NULL);
  1076. return 0;
  1077. }
  1078. ShowInfo("Created Guild %d - %s (Guild Master: %s)\n", g->guild_id, g->name, g->master);
  1079. // Add to cache
  1080. guild_db[g->guild_id] = g;
  1081. // Report to client
  1082. mapif_guild_created(fd,account_id,g);
  1083. mapif_guild_info(fd,g);
  1084. if(charserv_config.log_inter)
  1085. inter_log("guild %s (id=%d) created by master %s (id=%d)\n",
  1086. name, g->guild_id, master->name, master->account_id );
  1087. return 0;
  1088. }
  1089. // Return guild info to client
  1090. int mapif_parse_GuildInfo(int fd,int guild_id)
  1091. {
  1092. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1093. if( g != nullptr ){
  1094. if (!guild_calcinfo(g))
  1095. mapif_guild_info(fd,g);
  1096. }else
  1097. mapif_guild_noinfo(fd,guild_id); // Failed to load info
  1098. return 0;
  1099. }
  1100. // Add member to guild
  1101. int mapif_parse_GuildAddMember(int fd,int guild_id,struct guild_member *m)
  1102. {
  1103. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1104. if( g == nullptr ){
  1105. // Failed to add
  1106. mapif_guild_memberadded(fd,guild_id,m->account_id,m->char_id,1);
  1107. return 0;
  1108. }
  1109. // Find an empty slot
  1110. for( int i = 0; i < g->max_member; i++ ){
  1111. if(g->member[i].account_id==0)
  1112. {
  1113. memcpy(&g->member[i],m,sizeof(struct guild_member));
  1114. g->member[i].modified = (GS_MEMBER_NEW | GS_MEMBER_MODIFIED);
  1115. mapif_guild_memberadded(fd,guild_id,m->account_id,m->char_id,0);
  1116. if (!guild_calcinfo(g)) //Send members if it was not invoked.
  1117. mapif_guild_info(-1,g);
  1118. g->save_flag |= GS_MEMBER;
  1119. if (g->save_flag&GS_REMOVE)
  1120. g->save_flag&=~GS_REMOVE;
  1121. return 0;
  1122. }
  1123. }
  1124. // Failed to add
  1125. mapif_guild_memberadded(fd,guild_id,m->account_id,m->char_id,1);
  1126. return 0;
  1127. }
  1128. // Delete member from guild
  1129. int mapif_parse_GuildLeave(int fd, int guild_id, uint32 account_id, uint32 char_id, int flag, const char *mes)
  1130. {
  1131. int i;
  1132. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1133. if( g == nullptr ){
  1134. // Unknown guild, just update the player
  1135. if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `guild_id`='0' WHERE `account_id`='%d' AND `char_id`='%d'", schema_config.char_db, account_id, char_id) )
  1136. Sql_ShowDebug(sql_handle);
  1137. // mapif_guild_withdraw(guild_id,account_id,char_id,flag,g->member[i].name,mes);
  1138. return 0;
  1139. }
  1140. // Find the member
  1141. ARR_FIND( 0, g->max_member, i, g->member[i].account_id == account_id && g->member[i].char_id == char_id );
  1142. if( i == g->max_member )
  1143. {
  1144. //TODO member not found
  1145. return 0;
  1146. }
  1147. if( flag )
  1148. { // Write expulsion reason
  1149. // Find an empty slot
  1150. int j;
  1151. ARR_FIND( 0, MAX_GUILDEXPULSION, j, g->expulsion[j].account_id == 0 );
  1152. if( j == MAX_GUILDEXPULSION )
  1153. {
  1154. // Expulsion list is full, flush the oldest one
  1155. for( j = 0; j < MAX_GUILDEXPULSION - 1; j++ )
  1156. g->expulsion[j] = g->expulsion[j+1];
  1157. j = MAX_GUILDEXPULSION-1;
  1158. }
  1159. // Save the expulsion entry
  1160. g->expulsion[j].account_id = account_id;
  1161. safestrncpy(g->expulsion[j].name, g->member[i].name, NAME_LENGTH);
  1162. safestrncpy(g->expulsion[j].mes, mes, 40);
  1163. }
  1164. mapif_guild_withdraw(guild_id,account_id,char_id,flag,g->member[i].name,mes);
  1165. inter_guild_removemember_tosql(g->member[i].char_id);
  1166. memset(&g->member[i],0,sizeof(struct guild_member));
  1167. if( guild_check_empty(g) )
  1168. mapif_parse_BreakGuild(-1,guild_id); //Break the guild.
  1169. else {
  1170. //Update member info.
  1171. if (!guild_calcinfo(g))
  1172. mapif_guild_info(fd,g);
  1173. g->save_flag |= GS_EXPULSION;
  1174. }
  1175. return 0;
  1176. }
  1177. // Change member info
  1178. int mapif_parse_GuildChangeMemberInfoShort(int fd,int guild_id,uint32 account_id,uint32 char_id,int online,int lv,int class_)
  1179. {
  1180. // Could speed up by manipulating only guild_member
  1181. int i,sum,c;
  1182. int prev_count, prev_alv;
  1183. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1184. if( g == nullptr ){
  1185. return 0;
  1186. }
  1187. ARR_FIND( 0, g->max_member, i, g->member[i].account_id == account_id && g->member[i].char_id == char_id );
  1188. if( i < g->max_member )
  1189. {
  1190. g->member[i].online = online;
  1191. g->member[i].lv = lv;
  1192. g->member[i].class_ = class_;
  1193. g->member[i].modified = GS_MEMBER_MODIFIED;
  1194. mapif_guild_memberinfoshort(g,i);
  1195. }
  1196. prev_count = g->connect_member;
  1197. prev_alv = g->average_lv;
  1198. g->average_lv = 0;
  1199. g->connect_member = 0;
  1200. c = 0;
  1201. sum = 0;
  1202. for( i = 0; i < g->max_member; i++ )
  1203. {
  1204. if( g->member[i].account_id > 0 )
  1205. {
  1206. sum += g->member[i].lv;
  1207. c++;
  1208. }
  1209. if( g->member[i].online )
  1210. g->connect_member++;
  1211. }
  1212. if( c ) // this check should always succeed...
  1213. {
  1214. g->average_lv = sum / c;
  1215. if( g->connect_member != prev_count || g->average_lv != prev_alv )
  1216. g->save_flag |= GS_CONNECT;
  1217. if( g->save_flag & GS_REMOVE )
  1218. g->save_flag &= ~GS_REMOVE;
  1219. }
  1220. g->save_flag |= GS_MEMBER; //Update guild member data
  1221. return 0;
  1222. }
  1223. // BreakGuild
  1224. int mapif_parse_BreakGuild(int fd,int guild_id)
  1225. {
  1226. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1227. if( g == nullptr ){
  1228. return 0;
  1229. }
  1230. // Delete guild from sql
  1231. //printf("- Delete guild %d from guild\n",guild_id);
  1232. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '%d'", schema_config.guild_db, guild_id) )
  1233. Sql_ShowDebug(sql_handle);
  1234. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '%d'", schema_config.guild_member_db, guild_id) )
  1235. Sql_ShowDebug(sql_handle);
  1236. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '%d'", schema_config.guild_castle_db, guild_id) )
  1237. Sql_ShowDebug(sql_handle);
  1238. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '%d'", schema_config.guild_storage_db, guild_id) )
  1239. Sql_ShowDebug(sql_handle);
  1240. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '%d' OR `alliance_id` = '%d'", schema_config.guild_alliance_db, guild_id, guild_id) )
  1241. Sql_ShowDebug(sql_handle);
  1242. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '%d'", schema_config.guild_position_db, guild_id) )
  1243. Sql_ShowDebug(sql_handle);
  1244. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '%d'", schema_config.guild_skill_db, guild_id) )
  1245. Sql_ShowDebug(sql_handle);
  1246. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '%d'", schema_config.guild_expulsion_db, guild_id) )
  1247. Sql_ShowDebug(sql_handle);
  1248. //printf("- Update guild %d of char\n",guild_id);
  1249. if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `guild_id`='0' WHERE `guild_id`='%d'", schema_config.char_db, guild_id) )
  1250. Sql_ShowDebug(sql_handle);
  1251. mapif_guild_broken(guild_id,0);
  1252. if(charserv_config.log_inter)
  1253. inter_log("guild %s (id=%d) broken\n",g->name,guild_id);
  1254. // Remove the guild from memory. [Skotlex]
  1255. guild_db.erase( guild_id );
  1256. return 0;
  1257. }
  1258. // Forward Guild message to others map servers
  1259. int mapif_parse_GuildMessage(int fd,int guild_id,uint32 account_id,char *mes,int len)
  1260. {
  1261. return mapif_guild_message(guild_id,account_id,mes,len, fd);
  1262. }
  1263. // Modification of the guild
  1264. int mapif_parse_GuildBasicInfoChange(int fd,int guild_id,int type,const char *data,int len)
  1265. {
  1266. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1267. if( g == nullptr ){
  1268. return 0;
  1269. }
  1270. short data_value = *((short *)data);
  1271. switch(type) {
  1272. case GBI_GUILDLV:
  1273. if (data_value > 0 && g->guild_lv + data_value <= MAX_GUILDLEVEL) {
  1274. g->guild_lv += data_value;
  1275. g->skill_point += data_value;
  1276. } else if (data_value < 0 && g->guild_lv + data_value >= 1)
  1277. g->guild_lv += data_value;
  1278. mapif_guild_info(-1, g);
  1279. g->save_flag |= GS_LEVEL;
  1280. return 0;
  1281. default:
  1282. ShowError("int_guild: GuildBasicInfoChange: Unknown type %d\n",type);
  1283. break;
  1284. }
  1285. mapif_guild_basicinfochanged(guild_id,type,data,len);
  1286. return 0;
  1287. }
  1288. /**
  1289. * Receive a modification request for the guildmember
  1290. * @param fd : map-serv link
  1291. * @param guild_id : Guild to alter
  1292. * @param account_id : Player aid to alter
  1293. * @param char_id : Player cid to alter
  1294. * @param type : Type of modification
  1295. * @param data : Value of modification
  1296. * @param len : Size of value
  1297. * @return
  1298. */
  1299. int mapif_parse_GuildMemberInfoChange(int fd,int guild_id,uint32 account_id,uint32 char_id,int type,const char *data,int len)
  1300. {
  1301. // Could make some improvement in speed, because only change guild_member
  1302. int i;
  1303. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1304. if( g == nullptr ){
  1305. return 0;
  1306. }
  1307. // Search the member
  1308. for(i=0;i<g->max_member;i++)
  1309. if( g->member[i].account_id==account_id &&
  1310. g->member[i].char_id==char_id )
  1311. break;
  1312. // Not Found
  1313. if(i==g->max_member){
  1314. ShowWarning("int_guild: GuildMemberChange: Not found %d,%d in guild (%d - %s)\n",
  1315. account_id,char_id,guild_id,g->name);
  1316. return 0;
  1317. }
  1318. switch(type)
  1319. {
  1320. case GMI_POSITION:
  1321. {
  1322. g->member[i].position=*((short *)data);
  1323. g->member[i].modified = GS_MEMBER_MODIFIED;
  1324. mapif_guild_memberinfochanged(guild_id,account_id,char_id,type,data,len);
  1325. g->save_flag |= GS_MEMBER;
  1326. break;
  1327. }
  1328. case GMI_EXP:
  1329. { // EXP
  1330. t_exp old_exp=g->member[i].exp;
  1331. g->member[i].exp=*((t_exp *)data);
  1332. g->member[i].modified = GS_MEMBER_MODIFIED;
  1333. if (g->member[i].exp > old_exp)
  1334. {
  1335. t_exp exp = g->member[i].exp - old_exp;
  1336. // Compute gained exp
  1337. if (charserv_config.guild_exp_rate != 100)
  1338. exp = exp*(charserv_config.guild_exp_rate)/100;
  1339. // Update guild exp
  1340. g->exp = util::safe_addition_cap(g->exp, exp, MAX_GUILD_EXP);
  1341. guild_calcinfo(g);
  1342. mapif_guild_basicinfochanged(guild_id,GBI_EXP,&g->exp,sizeof(g->exp));
  1343. g->save_flag |= GS_LEVEL;
  1344. }
  1345. mapif_guild_memberinfochanged(guild_id,account_id,char_id,type,data,len);
  1346. g->save_flag |= GS_MEMBER;
  1347. break;
  1348. }
  1349. case GMI_HAIR:
  1350. {
  1351. g->member[i].hair=*((short *)data);
  1352. g->member[i].modified = GS_MEMBER_MODIFIED;
  1353. mapif_guild_memberinfochanged(guild_id,account_id,char_id,type,data,len);
  1354. g->save_flag |= GS_MEMBER; //Save new data.
  1355. break;
  1356. }
  1357. case GMI_HAIR_COLOR:
  1358. {
  1359. g->member[i].hair_color=*((short *)data);
  1360. g->member[i].modified = GS_MEMBER_MODIFIED;
  1361. mapif_guild_memberinfochanged(guild_id,account_id,char_id,type,data,len);
  1362. g->save_flag |= GS_MEMBER; //Save new data.
  1363. break;
  1364. }
  1365. case GMI_GENDER:
  1366. {
  1367. g->member[i].gender=*((short *)data);
  1368. g->member[i].modified = GS_MEMBER_MODIFIED;
  1369. mapif_guild_memberinfochanged(guild_id,account_id,char_id,type,data,len);
  1370. g->save_flag |= GS_MEMBER; //Save new data.
  1371. break;
  1372. }
  1373. case GMI_CLASS:
  1374. {
  1375. g->member[i].class_=*((short *)data);
  1376. g->member[i].modified = GS_MEMBER_MODIFIED;
  1377. mapif_guild_memberinfochanged(guild_id,account_id,char_id,type,data,len);
  1378. g->save_flag |= GS_MEMBER; //Save new data.
  1379. break;
  1380. }
  1381. case GMI_LEVEL:
  1382. {
  1383. g->member[i].lv=*((short *)data);
  1384. g->member[i].modified = GS_MEMBER_MODIFIED;
  1385. mapif_guild_memberinfochanged(guild_id,account_id,char_id,type,data,len);
  1386. g->save_flag |= GS_MEMBER; //Save new data.
  1387. break;
  1388. }
  1389. default:
  1390. ShowError("int_guild: GuildMemberInfoChange: Unknown type %d\n",type);
  1391. break;
  1392. }
  1393. return 0;
  1394. }
  1395. int inter_guild_sex_changed(int guild_id,uint32 account_id,uint32 char_id, short gender)
  1396. {
  1397. return mapif_parse_GuildMemberInfoChange(0, guild_id, account_id, char_id, GMI_GENDER, (const char*)&gender, sizeof(gender));
  1398. }
  1399. int inter_guild_charname_changed(int guild_id,uint32 account_id, uint32 char_id, char *name)
  1400. {
  1401. int i, flag = 0;
  1402. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1403. if( g == nullptr ){
  1404. ShowError("inter_guild_charrenamed: Can't find guild %d.\n", guild_id);
  1405. return 0;
  1406. }
  1407. ARR_FIND(0, g->max_member, i, g->member[i].char_id == char_id);
  1408. if( i == g->max_member )
  1409. {
  1410. ShowError("inter_guild_charrenamed: Can't find character %d in the guild\n", char_id);
  1411. return 0;
  1412. }
  1413. if( !strcmp(g->member[i].name, g->master) )
  1414. {
  1415. safestrncpy(g->master, name, NAME_LENGTH);
  1416. flag |= GS_BASIC;
  1417. }
  1418. safestrncpy(g->member[i].name, name, NAME_LENGTH);
  1419. g->member[i].modified = GS_MEMBER_MODIFIED;
  1420. flag |= GS_MEMBER;
  1421. if( !inter_guild_tosql(g, flag) )
  1422. return 0;
  1423. mapif_guild_info(-1,g);
  1424. return 0;
  1425. }
  1426. // Change a position desc
  1427. int mapif_parse_GuildPosition(int fd,int guild_id,int idx,struct guild_position *p)
  1428. {
  1429. // Could make some improvement in speed, because only change guild_position
  1430. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1431. if( g == nullptr || idx < 0 || idx >= MAX_GUILDPOSITION ){
  1432. return 0;
  1433. }
  1434. memcpy(&g->position[idx],p,sizeof(struct guild_position));
  1435. mapif_guild_position(g,idx);
  1436. g->position[idx].modified = GS_POSITION_MODIFIED;
  1437. g->save_flag |= GS_POSITION; // Change guild_position
  1438. return 0;
  1439. }
  1440. // Guild Skill UP
  1441. int mapif_parse_GuildSkillUp(int fd,int guild_id,uint16 skill_id,uint32 account_id,int max)
  1442. {
  1443. int idx = skill_id - GD_SKILLBASE;
  1444. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1445. if( g == nullptr || idx < 0 || idx >= MAX_GUILDSKILL ){
  1446. return 0;
  1447. }
  1448. if(g->skill_point>0 && g->skill[idx].id>0 && g->skill[idx].lv<max )
  1449. {
  1450. g->skill[idx].lv++;
  1451. g->skill_point--;
  1452. if (!guild_calcinfo(g))
  1453. mapif_guild_info(-1,g);
  1454. mapif_guild_skillupack(guild_id,skill_id,account_id);
  1455. g->save_flag |= (GS_LEVEL|GS_SKILL); // Change guild & guild_skill
  1456. if (skill_id == GD_GUILD_STORAGE)
  1457. inter_guild_tosql(g, g->save_flag); // Force save for GD_GUILD_STORAGE
  1458. }
  1459. return 0;
  1460. }
  1461. //Manual deletion of an alliance when partnering guild does not exists. [Skotlex]
  1462. int mapif_parse_GuildDeleteAlliance( std::shared_ptr<struct guild> g, int guild_id, uint32 account_id1, uint32 account_id2, int flag ){
  1463. int i;
  1464. char name[NAME_LENGTH];
  1465. ARR_FIND( 0, MAX_GUILDALLIANCE, i, g->alliance[i].guild_id == guild_id );
  1466. if( i == MAX_GUILDALLIANCE )
  1467. return -1;
  1468. strcpy(name, g->alliance[i].name);
  1469. g->alliance[i].guild_id=0;
  1470. mapif_guild_alliance(g->guild_id,guild_id,account_id1,account_id2,flag,g->name,name);
  1471. g->save_flag |= GS_ALLIANCE;
  1472. return 0;
  1473. }
  1474. /**
  1475. * Alliance modification
  1476. * @param fd
  1477. * @param guild_id1
  1478. * @param guild_id2
  1479. * @param account_id1
  1480. * @param account_id2
  1481. * @param flag
  1482. * @return
  1483. */
  1484. int mapif_parse_GuildAlliance(int fd,int guild_id1,int guild_id2,uint32 account_id1,uint32 account_id2,int flag)
  1485. {
  1486. // Could speed up
  1487. std::shared_ptr<struct guild> g[2];
  1488. int j,i;
  1489. g[0] = inter_guild_fromsql(guild_id1);
  1490. g[1] = inter_guild_fromsql(guild_id2);
  1491. // Requested to remove an alliance with a not found guild.
  1492. if( g[0] != nullptr && g[1] == nullptr && ( flag & GUILD_ALLIANCE_REMOVE ) ){
  1493. return mapif_parse_GuildDeleteAlliance(g[0], guild_id2, account_id1, account_id2, flag); //Try to do a manual removal of said guild.
  1494. }
  1495. if( g[0] == nullptr || g[1] == nullptr ){
  1496. return 0;
  1497. }
  1498. if(flag&GUILD_ALLIANCE_REMOVE)
  1499. {
  1500. // Remove alliance/opposition, in case of alliance, remove on both side
  1501. for(i=0;i<2-(flag&GUILD_ALLIANCE_TYPE_MASK);i++)
  1502. {
  1503. ARR_FIND( 0, MAX_GUILDALLIANCE, j, g[i]->alliance[j].guild_id == g[1-i]->guild_id && g[i]->alliance[j].opposition == (flag&GUILD_ALLIANCE_TYPE_MASK) );
  1504. if( j < MAX_GUILDALLIANCE )
  1505. g[i]->alliance[j].guild_id = 0;
  1506. }
  1507. }
  1508. else
  1509. {
  1510. // Add alliance, in case of alliance, add on both side
  1511. for(i=0;i<2-(flag&GUILD_ALLIANCE_TYPE_MASK);i++)
  1512. {
  1513. // Search an empty slot
  1514. ARR_FIND( 0, MAX_GUILDALLIANCE, j, g[i]->alliance[j].guild_id == 0 );
  1515. if( j < MAX_GUILDALLIANCE )
  1516. {
  1517. g[i]->alliance[j].guild_id=g[1-i]->guild_id;
  1518. memcpy(g[i]->alliance[j].name,g[1-i]->name,NAME_LENGTH);
  1519. // Set alliance type
  1520. g[i]->alliance[j].opposition = flag&GUILD_ALLIANCE_TYPE_MASK;
  1521. }
  1522. }
  1523. }
  1524. // Send on all map the new alliance/opposition
  1525. mapif_guild_alliance(guild_id1,guild_id2,account_id1,account_id2,flag,g[0]->name,g[1]->name);
  1526. // Mark the two guild to be saved
  1527. g[0]->save_flag |= GS_ALLIANCE;
  1528. g[1]->save_flag |= GS_ALLIANCE;
  1529. return 1;
  1530. }
  1531. // Change guild message
  1532. int mapif_parse_GuildNotice(int fd,int guild_id,const char *mes1,const char *mes2)
  1533. {
  1534. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1535. if( g == nullptr ){
  1536. return 0;
  1537. }
  1538. memcpy(g->mes1,mes1,MAX_GUILDMES1);
  1539. memcpy(g->mes2,mes2,MAX_GUILDMES2);
  1540. g->save_flag |= GS_MES; //Change mes of guild
  1541. inter_guild_tosql(g, g->save_flag);
  1542. return mapif_guild_notice(g);
  1543. }
  1544. int mapif_parse_GuildEmblem(int fd,int len,int guild_id,int dummy,const char *data)
  1545. {
  1546. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1547. if( g == nullptr ){
  1548. return 0;
  1549. }
  1550. if (len > sizeof(g->emblem_data))
  1551. len = sizeof(g->emblem_data);
  1552. memcpy(g->emblem_data,data,len);
  1553. g->emblem_len=len;
  1554. g->emblem_id++;
  1555. g->save_flag |= GS_EMBLEM; //Change guild
  1556. return mapif_guild_emblem(g);
  1557. }
  1558. int mapif_parse_GuildCastleDataLoad(int fd, int len, int *castle_ids)
  1559. {
  1560. return mapif_guild_castle_dataload(fd, len, castle_ids);
  1561. }
  1562. int mapif_parse_GuildCastleDataSave(int fd, int castle_id, int index, int value)
  1563. {
  1564. std::shared_ptr<struct guild_castle> gc = inter_guildcastle_fromsql( castle_id );
  1565. if( gc == nullptr ){
  1566. ShowError("mapif_parse_GuildCastleDataSave: castle id=%d not found\n", castle_id);
  1567. return 0;
  1568. }
  1569. switch (index) {
  1570. case CD_GUILD_ID:
  1571. if (charserv_config.log_inter && gc->guild_id != value) {
  1572. int gid = (value) ? value : gc->guild_id;
  1573. std::shared_ptr<struct guild> g = util::umap_find( guild_db, gid );
  1574. inter_log("guild %s (id=%d) %s castle id=%d\n",
  1575. (g) ? g->name : "??", gid, (value) ? "occupy" : "abandon", castle_id);
  1576. }
  1577. gc->guild_id = value;
  1578. break;
  1579. case CD_CURRENT_ECONOMY: gc->economy = value; break;
  1580. case CD_CURRENT_DEFENSE: gc->defense = value; break;
  1581. case CD_INVESTED_ECONOMY: gc->triggerE = value; break;
  1582. case CD_INVESTED_DEFENSE: gc->triggerD = value; break;
  1583. case CD_NEXT_TIME: gc->nextTime = value; break;
  1584. case CD_PAY_TIME: gc->payTime = value; break;
  1585. case CD_CREATE_TIME: gc->createTime = value; break;
  1586. case CD_ENABLED_KAFRA: gc->visibleC = value; break;
  1587. default:
  1588. if (index >= CD_ENABLED_GUARDIAN00 && index < CD_MAX) {
  1589. gc->guardian[index - CD_ENABLED_GUARDIAN00].visible = value;
  1590. break;
  1591. }
  1592. ShowError("mapif_parse_GuildCastleDataSave: not found index=%d\n", index);
  1593. return 0;
  1594. }
  1595. inter_guildcastle_tosql(gc);
  1596. return 0;
  1597. }
  1598. int mapif_parse_GuildMasterChange(int fd, int guild_id, const char* name, int len)
  1599. {
  1600. struct guild_member gm;
  1601. int pos;
  1602. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1603. if( g == nullptr || len > NAME_LENGTH ){
  1604. return 0;
  1605. }
  1606. // Find member (name)
  1607. for (pos = 0; pos < g->max_member && strncmp(g->member[pos].name, name, len); pos++);
  1608. if (pos == g->max_member)
  1609. return 0; //Character not found??
  1610. // Switch current and old GM
  1611. memcpy(&gm, &g->member[pos], sizeof (struct guild_member));
  1612. memcpy(&g->member[pos], &g->member[0], sizeof(struct guild_member));
  1613. memcpy(&g->member[0], &gm, sizeof(struct guild_member));
  1614. // Switch positions
  1615. g->member[pos].position = g->member[0].position;
  1616. g->member[pos].modified = GS_MEMBER_MODIFIED;
  1617. g->member[0].position = 0; //Position 0: guild Master.
  1618. g->member[0].modified = GS_MEMBER_MODIFIED;
  1619. // Store changing time
  1620. g->last_leader_change = time(NULL);
  1621. safestrncpy(g->master, name, len);
  1622. if (len < NAME_LENGTH)
  1623. g->master[len] = '\0';
  1624. ShowInfo("int_guild: Guildmaster Changed to %s (Guild %d - %s)\n",g->master, guild_id, g->name);
  1625. g->save_flag |= (GS_BASIC|GS_MEMBER); //Save main data and member data.
  1626. return mapif_guild_master_changed(g, g->member[0].account_id, g->member[0].char_id, g->last_leader_change);
  1627. }
  1628. int mapif_parse_GuildEmblemVersion(int fd, int guild_id, int version)
  1629. {
  1630. std::shared_ptr<struct guild> g = inter_guild_fromsql( guild_id );
  1631. if (g == nullptr)
  1632. return 0;
  1633. g->emblem_len = 0;
  1634. g->emblem_id = version;
  1635. g->save_flag |= GS_EMBLEM;
  1636. mapif_guild_emblem_version(g);
  1637. return 1;
  1638. }
  1639. // Communication from the map server
  1640. // - Can analyzed only one by one packet
  1641. // Data packet length that you set to inter.cpp
  1642. //- Shouldn't do checking and packet length, RFIFOSKIP is done by the caller
  1643. // Must Return
  1644. // 1 : ok
  1645. // 0 : error
  1646. int inter_guild_parse_frommap(int fd)
  1647. {
  1648. RFIFOHEAD(fd);
  1649. switch(RFIFOW(fd,0)) {
  1650. case 0x3030: mapif_parse_CreateGuild(fd,RFIFOL(fd,4),RFIFOCP(fd,8),(struct guild_member *)RFIFOP(fd,32)); break;
  1651. case 0x3031: mapif_parse_GuildInfo(fd,RFIFOL(fd,2)); break;
  1652. case 0x3032: mapif_parse_GuildAddMember(fd,RFIFOL(fd,4),(struct guild_member *)RFIFOP(fd,8)); break;
  1653. case 0x3033: mapif_parse_GuildMasterChange(fd,RFIFOL(fd,4),RFIFOCP(fd,8),RFIFOW(fd,2)-8); break;
  1654. case 0x3034: mapif_parse_GuildLeave(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOL(fd,10),RFIFOB(fd,14),RFIFOCP(fd,15)); break;
  1655. case 0x3035: mapif_parse_GuildChangeMemberInfoShort(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOL(fd,10),RFIFOB(fd,14),RFIFOW(fd,15),RFIFOW(fd,17)); break;
  1656. case 0x3036: mapif_parse_BreakGuild(fd,RFIFOL(fd,2)); break;
  1657. case 0x3037: mapif_parse_GuildMessage(fd,RFIFOL(fd,4),RFIFOL(fd,8),RFIFOCP(fd,12),RFIFOW(fd,2)-12); break;
  1658. case 0x3039: mapif_parse_GuildBasicInfoChange(fd,RFIFOL(fd,4),RFIFOW(fd,8),RFIFOCP(fd,10),RFIFOW(fd,2)-10); break;
  1659. case 0x303A: mapif_parse_GuildMemberInfoChange(fd,RFIFOL(fd,4),RFIFOL(fd,8),RFIFOL(fd,12),RFIFOW(fd,16),RFIFOCP(fd,18),RFIFOW(fd,2)-18); break;
  1660. case 0x303B: mapif_parse_GuildPosition(fd,RFIFOL(fd,4),RFIFOL(fd,8),(struct guild_position *)RFIFOP(fd,12)); break;
  1661. case 0x303C: mapif_parse_GuildSkillUp(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOL(fd,10),RFIFOL(fd,14)); break;
  1662. case 0x303D: mapif_parse_GuildAlliance(fd,RFIFOL(fd,2),RFIFOL(fd,6),RFIFOL(fd,10),RFIFOL(fd,14),RFIFOB(fd,18)); break;
  1663. case 0x303E: mapif_parse_GuildNotice(fd,RFIFOL(fd,2),RFIFOCP(fd,6),RFIFOCP(fd,66)); break;
  1664. case 0x303F: mapif_parse_GuildEmblem(fd,RFIFOW(fd,2)-12,RFIFOL(fd,4),RFIFOL(fd,8),RFIFOCP(fd,12)); break;
  1665. case 0x3040: mapif_parse_GuildCastleDataLoad(fd,RFIFOW(fd,2),(int *)RFIFOP(fd,4)); break;
  1666. case 0x3041: mapif_parse_GuildCastleDataSave(fd,RFIFOW(fd,2),RFIFOB(fd,4),RFIFOL(fd,5)); break;
  1667. case 0x3042: mapif_parse_GuildEmblemVersion(fd, RFIFOL(fd, 2), RFIFOL(fd, 6)); break;
  1668. default:
  1669. return 0;
  1670. }
  1671. return 1;
  1672. }
  1673. //Leave request from the server (for deleting character from guild)
  1674. int inter_guild_leave(int guild_id, uint32 account_id, uint32 char_id)
  1675. {
  1676. return mapif_parse_GuildLeave(-1, guild_id, account_id, char_id, 0, "** Character Deleted **");
  1677. }
  1678. int inter_guild_broken(int guild_id)
  1679. {
  1680. return mapif_guild_broken(guild_id, 0);
  1681. }