int_guild.cpp 61 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 <cstdlib>
  5. #include <cstring>
  6. #include <memory>
  7. #include <unordered_map>
  8. #include <common/cbasetypes.hpp>
  9. #include <common/malloc.hpp>
  10. #include <common/mmo.hpp>
  11. #include <common/showmsg.hpp>
  12. #include <common/socket.hpp>
  13. #include <common/strlib.hpp>
  14. #include <common/timer.hpp>
  15. #include "char.hpp"
  16. #include "char_mapif.hpp"
  17. #include "inter.hpp"
  18. using namespace rathena;
  19. #define GS_MEMBER_UNMODIFIED 0x00
  20. #define GS_MEMBER_MODIFIED 0x01
  21. #define GS_MEMBER_NEW 0x02
  22. #define GS_POSITION_UNMODIFIED 0x00
  23. #define GS_POSITION_MODIFIED 0x01
  24. // LSB = 0 => Alliance, LSB = 1 => Opposition
  25. #define GUILD_ALLIANCE_TYPE_MASK 0x01
  26. #define GUILD_ALLIANCE_REMOVE 0x08
  27. static const char dataToHex[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'};
  28. // int32 guild_id -> CharGuild*
  29. static std::unordered_map<int32, std::shared_ptr<CharGuild>> guild_db;
  30. static std::unordered_map<int32, std::shared_ptr<struct guild_castle>> castle_db;
  31. int32 mapif_parse_GuildLeave(int32 fd,int32 guild_id,uint32 account_id,uint32 char_id,int32 flag,const char *mes);
  32. int32 mapif_guild_broken(int32 guild_id,int32 flag);
  33. bool guild_check_empty( std::shared_ptr<CharGuild> g );
  34. int32 guild_calcinfo( std::shared_ptr<CharGuild> g );
  35. int32 mapif_guild_basicinfochanged(int32 guild_id,int32 type,const void *data,int32 len);
  36. int32 mapif_guild_info( int32 fd, const struct mmo_guild &g );
  37. int32 inter_guild_tosql( mmo_guild &g, int32 flag );
  38. int32 guild_checkskill( std::shared_ptr<CharGuild> g, int32 id );
  39. TIMER_FUNC(guild_save_timer){
  40. static int32 last_id = 0; //To know in which guild we were.
  41. int32 state = 0; //0: Have not reached last guild. 1: Reached last guild, ready for save. 2: Some guild saved, don't do further saving.
  42. if( last_id == 0 ) //Save the first guild in the list.
  43. state = 1;
  44. for( auto it = guild_db.begin(); it != guild_db.end(); ){
  45. std::shared_ptr<CharGuild> g = it->second;
  46. if( state == 0 && g->guild.guild_id == last_id )
  47. state++; //Save next guild in the list.
  48. else if( state == 1 && g->save_flag&GS_MASK )
  49. {
  50. inter_guild_tosql(g->guild, g->save_flag&GS_MASK);
  51. g->save_flag &= ~GS_MASK;
  52. //Some guild saved.
  53. last_id = g->guild.guild_id;
  54. state++;
  55. }
  56. // Nothing to save, guild is ready for removal.
  57. if( g->save_flag == GS_REMOVE ){
  58. if (charserv_config.save_log)
  59. ShowInfo("Guild Unloaded (%d - %s)\n", g->guild.guild_id, g->guild.name);
  60. it = guild_db.erase( it );
  61. }else{
  62. it++;
  63. }
  64. }
  65. if( state != 2 ) //Reached the end of the guild db without saving.
  66. last_id = 0; //Reset guild saved, return to beginning.
  67. size_t count = std::max( guild_db.size(), static_cast<size_t>( 1 ) );
  68. // Calculate the time slot for the next save.
  69. add_timer( tick + charserv_config.autosave_interval / count, guild_save_timer, 0, 0 );
  70. return 0;
  71. }
  72. int32 inter_guild_removemember_tosql(uint32 char_id)
  73. {
  74. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE from `%s` where `char_id` = '%d'", schema_config.guild_member_db, char_id) )
  75. Sql_ShowDebug(sql_handle);
  76. if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `guild_id` = '0' WHERE `char_id` = '%d'", schema_config.char_db, char_id) )
  77. Sql_ShowDebug(sql_handle);
  78. return 0;
  79. }
  80. // Save mmo_guild into sql
  81. int32 inter_guild_tosql( mmo_guild &g, int32 flag ){
  82. // Table guild (GS_BASIC_MASK)
  83. // GS_EMBLEM `emblem_len`,`emblem_id`,`emblem_data`
  84. // GS_CONNECT `connect_member`,`average_lv`
  85. // GS_MES `mes1`,`mes2`
  86. // GS_LEVEL `guild_lv`,`max_member`,`exp`,`next_exp`,`skill_point`
  87. // GS_BASIC `name`,`master`,`char_id`
  88. // GS_MEMBER `guild_member` (`guild_id`,`char_id`,`exp`,`position`)
  89. // GS_POSITION `guild_position` (`guild_id`,`position`,`name`,`mode`,`exp_mode`)
  90. // GS_ALLIANCE `guild_alliance` (`guild_id`,`opposition`,`alliance_id`,`name`)
  91. // GS_EXPULSION `guild_expulsion` (`guild_id`,`account_id`,`name`,`mes`)
  92. // GS_SKILL `guild_skill` (`guild_id`,`id`,`lv`)
  93. // temporary storage for str convertion. They must be twice the size of the
  94. // original string to ensure no overflows will occur. [Skotlex]
  95. char t_info[256];
  96. char esc_name[NAME_LENGTH*2+1];
  97. char esc_master[NAME_LENGTH*2+1];
  98. char new_guild = 0;
  99. int32 i=0;
  100. if (g.guild_id<=0 && g.guild_id != -1) return 0;
  101. #ifdef NOISY
  102. ShowInfo("Save guild request (" CL_BOLD "%d" CL_RESET " - flag 0x%x).",g.guild_id, flag);
  103. #endif
  104. Sql_EscapeStringLen(sql_handle, esc_name, g.name, strnlen(g.name, NAME_LENGTH));
  105. Sql_EscapeStringLen(sql_handle, esc_master, g.master, strnlen(g.master, NAME_LENGTH));
  106. *t_info = '\0';
  107. // Insert a new guild the guild
  108. if (flag&GS_BASIC && g.guild_id == -1)
  109. {
  110. strcat(t_info, " guild_create");
  111. // Create a new guild
  112. if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `%s` "
  113. "(`name`,`master`,`guild_lv`,`max_member`,`average_lv`,`char_id`) "
  114. "VALUES ('%s', '%s', '%d', '%d', '%d', '%d')",
  115. schema_config.guild_db, esc_name, esc_master, g.guild_lv, g.max_member, g.average_lv, g.member[0].char_id) )
  116. {
  117. Sql_ShowDebug(sql_handle);
  118. return 0; //Failed to create guild!
  119. }
  120. else
  121. {
  122. g.guild_id = (int)Sql_LastInsertId(sql_handle);
  123. new_guild = 1;
  124. }
  125. }
  126. // If we need an update on an existing guild or more update on the new guild
  127. if (((flag & GS_BASIC_MASK) && !new_guild) || ((flag & (GS_BASIC_MASK & ~GS_BASIC)) && new_guild))
  128. {
  129. StringBuf buf;
  130. bool add_comma = false;
  131. StringBuf_Init(&buf);
  132. StringBuf_Printf(&buf, "UPDATE `%s` SET ", schema_config.guild_db);
  133. if (flag & GS_EMBLEM)
  134. {
  135. char emblem_data[sizeof(g.emblem_data)*2+1];
  136. char* pData = emblem_data;
  137. strcat(t_info, " emblem");
  138. // Convert emblem_data to hex
  139. //TODO: why not use binary directly? [ultramage]
  140. for(i=0; i<g.emblem_len; i++){
  141. *pData++ = dataToHex[(g.emblem_data[i] >> 4) & 0x0F];
  142. *pData++ = dataToHex[g.emblem_data[i] & 0x0F];
  143. }
  144. *pData = 0;
  145. StringBuf_Printf(&buf, "`emblem_len`=%d, `emblem_id`=%d, `emblem_data`='%s'", g.emblem_len, g.emblem_id, emblem_data);
  146. add_comma = true;
  147. }
  148. if (flag & GS_BASIC)
  149. {
  150. strcat(t_info, " basic");
  151. if( add_comma )
  152. StringBuf_AppendStr(&buf, ", ");
  153. else
  154. add_comma = true;
  155. StringBuf_Printf(&buf, "`name`='%s', `master`='%s', `char_id`=%d", esc_name, esc_master, g.member[0].char_id);
  156. if (g.last_leader_change)
  157. StringBuf_Printf(&buf, ", `last_master_change`=FROM_UNIXTIME(%d)", g.last_leader_change);
  158. }
  159. if (flag & GS_CONNECT)
  160. {
  161. strcat(t_info, " connect");
  162. if( add_comma )
  163. StringBuf_AppendStr(&buf, ", ");
  164. else
  165. add_comma = true;
  166. StringBuf_Printf(&buf, "`connect_member`=%d, `average_lv`=%d", g.connect_member, g.average_lv);
  167. }
  168. if (flag & GS_MES)
  169. {
  170. char esc_mes1[sizeof(g.mes1)*2+1];
  171. char esc_mes2[sizeof(g.mes2)*2+1];
  172. strcat(t_info, " mes");
  173. if( add_comma )
  174. StringBuf_AppendStr(&buf, ", ");
  175. else
  176. add_comma = true;
  177. Sql_EscapeStringLen(sql_handle, esc_mes1, g.mes1, strnlen(g.mes1, sizeof(g.mes1)));
  178. Sql_EscapeStringLen(sql_handle, esc_mes2, g.mes2, strnlen(g.mes2, sizeof(g.mes2)));
  179. StringBuf_Printf(&buf, "`mes1`='%s', `mes2`='%s'", esc_mes1, esc_mes2);
  180. }
  181. if (flag & GS_LEVEL)
  182. {
  183. strcat(t_info, " level");
  184. if( add_comma )
  185. StringBuf_AppendStr(&buf, ", ");
  186. //else //last condition using add_coma setting
  187. // add_comma = true;
  188. 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);
  189. }
  190. StringBuf_Printf(&buf, " WHERE `guild_id`=%d", g.guild_id);
  191. if( SQL_ERROR == Sql_Query(sql_handle, "%s", StringBuf_Value(&buf)) )
  192. Sql_ShowDebug(sql_handle);
  193. StringBuf_Destroy(&buf);
  194. }
  195. if (flag&GS_MEMBER)
  196. {
  197. strcat(t_info, " members");
  198. // Update only needed players
  199. for(i=0;i<g.max_member;i++){
  200. struct guild_member *m = &g.member[i];
  201. if (!m->modified)
  202. continue;
  203. if(m->account_id) {
  204. //Since nothing references guild member table as foreign keys, it's safe to use REPLACE INTO
  205. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`char_id`,`exp`,`position`) "
  206. "VALUES ('%d','%d','%" PRIu64 "','%d')",
  207. schema_config.guild_member_db, g.guild_id, m->char_id, m->exp, m->position ) )
  208. Sql_ShowDebug(sql_handle);
  209. if (m->modified&GS_MEMBER_NEW || new_guild == 1)
  210. {
  211. if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `guild_id` = '%d' WHERE `char_id` = '%d'",
  212. schema_config.char_db, g.guild_id, m->char_id) )
  213. Sql_ShowDebug(sql_handle);
  214. }
  215. m->modified = GS_MEMBER_UNMODIFIED;
  216. }
  217. }
  218. }
  219. if (flag&GS_POSITION){
  220. strcat(t_info, " positions");
  221. //printf("- Insert guild %d to guild_position\n",g.guild_id);
  222. for(i=0;i<MAX_GUILDPOSITION;i++){
  223. struct guild_position *p = &g.position[i];
  224. if (!p->modified)
  225. continue;
  226. Sql_EscapeStringLen(sql_handle, esc_name, p->name, strnlen(p->name, NAME_LENGTH));
  227. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`position`,`name`,`mode`,`exp_mode`) VALUES ('%d','%d','%s','%d','%d')",
  228. schema_config.guild_position_db, g.guild_id, i, esc_name, p->mode, p->exp_mode) )
  229. Sql_ShowDebug(sql_handle);
  230. p->modified = GS_POSITION_UNMODIFIED;
  231. }
  232. }
  233. if (flag&GS_ALLIANCE)
  234. {
  235. // Delete current alliances
  236. // NOTE: no need to do it on both sides since both guilds in memory had
  237. // their info changed, not to mention this would also mess up oppositions!
  238. // [Skotlex]
  239. //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) )
  240. if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id`='%d'", schema_config.guild_alliance_db, g.guild_id) )
  241. {
  242. Sql_ShowDebug(sql_handle);
  243. }
  244. else
  245. {
  246. //printf("- Insert guild %d to guild_alliance\n",g.guild_id);
  247. for(i=0;i<MAX_GUILDALLIANCE;i++)
  248. {
  249. struct guild_alliance *a=&g.alliance[i];
  250. if(a->guild_id>0)
  251. {
  252. Sql_EscapeStringLen(sql_handle, esc_name, a->name, strnlen(a->name, NAME_LENGTH));
  253. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`opposition`,`alliance_id`,`name`) "
  254. "VALUES ('%d','%d','%d','%s')",
  255. schema_config.guild_alliance_db, g.guild_id, a->opposition, a->guild_id, esc_name) )
  256. Sql_ShowDebug(sql_handle);
  257. }
  258. }
  259. }
  260. }
  261. if (flag&GS_EXPULSION){
  262. strcat(t_info, " expulsions");
  263. //printf("- Insert guild %d to guild_expulsion\n",g.guild_id);
  264. for(i=0;i<MAX_GUILDEXPULSION;i++){
  265. struct guild_expulsion *e=&g.expulsion[i];
  266. if(e->account_id>0){
  267. char esc_mes[sizeof(e->mes)*2+1];
  268. Sql_EscapeStringLen(sql_handle, esc_name, e->name, strnlen(e->name, NAME_LENGTH));
  269. Sql_EscapeStringLen(sql_handle, esc_mes, e->mes, strnlen(e->mes, sizeof(e->mes)));
  270. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`account_id`,`name`,`mes`,`char_id`) "
  271. "VALUES ('%u','%u','%s','%s','%u')", schema_config.guild_expulsion_db, g.guild_id, e->account_id, esc_name, esc_mes, e->char_id) )
  272. Sql_ShowDebug(sql_handle);
  273. }
  274. }
  275. }
  276. if (flag&GS_SKILL){
  277. strcat(t_info, " skills");
  278. //printf("- Insert guild %d to guild_skill\n",g.guild_id);
  279. for(i=0;i<MAX_GUILDSKILL;i++){
  280. if (g.skill[i].id>0 && g.skill[i].lv>0){
  281. if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`guild_id`,`id`,`lv`) VALUES ('%d','%d','%d')",
  282. schema_config.guild_skill_db, g.guild_id, g.skill[i].id, g.skill[i].lv) )
  283. Sql_ShowDebug(sql_handle);
  284. }
  285. }
  286. }
  287. if (charserv_config.save_log)
  288. ShowInfo("Saved guild (%d - %s):%s\n",g.guild_id,g.name,t_info);
  289. return 1;
  290. }
  291. // Read guild from sql
  292. std::shared_ptr<CharGuild> inter_guild_fromsql( int32 guild_id ){
  293. char* data;
  294. size_t len;
  295. char* p;
  296. int32 i;
  297. if( guild_id <= 0 ){
  298. return nullptr;
  299. }
  300. auto g = util::umap_find( guild_db, guild_id );
  301. if( g != nullptr ){
  302. return g;
  303. }
  304. #ifdef NOISY
  305. ShowInfo("Guild load request (%d)...\n", guild_id);
  306. #endif
  307. 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` "
  308. "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) )
  309. {
  310. Sql_ShowDebug(sql_handle);
  311. return nullptr;
  312. }
  313. // Guild does not exists.
  314. if( SQL_SUCCESS != Sql_NextRow( sql_handle ) ){
  315. return nullptr;
  316. }
  317. g = std::make_shared<CharGuild>();
  318. g->guild.guild_id = guild_id;
  319. Sql_GetData(sql_handle, 0, &data, &len); memcpy(g->guild.name, data, zmin(len, NAME_LENGTH));
  320. Sql_GetData(sql_handle, 1, &data, &len); memcpy(g->guild.master, data, zmin(len, NAME_LENGTH));
  321. Sql_GetData(sql_handle, 2, &data, nullptr); g->guild.guild_lv = atoi(data);
  322. Sql_GetData(sql_handle, 3, &data, nullptr); g->guild.connect_member = atoi(data);
  323. Sql_GetData(sql_handle, 4, &data, nullptr); g->guild.max_member = atoi(data);
  324. if( g->guild.max_member > MAX_GUILD )
  325. { // Fix reduction of MAX_GUILD [PoW]
  326. ShowWarning("Guild %d:%s specifies higher capacity (%d) than MAX_GUILD (%d)\n", guild_id, g->guild.name, g->guild.max_member, MAX_GUILD);
  327. g->guild.max_member = MAX_GUILD;
  328. }
  329. Sql_GetData(sql_handle, 5, &data, nullptr); g->guild.average_lv = atoi(data);
  330. Sql_GetData(sql_handle, 6, &data, nullptr); g->guild.exp = strtoull(data, nullptr, 10);
  331. Sql_GetData(sql_handle, 7, &data, nullptr); g->guild.next_exp = strtoull(data, nullptr, 10);
  332. Sql_GetData(sql_handle, 8, &data, nullptr); g->guild.skill_point = atoi(data);
  333. Sql_GetData(sql_handle, 9, &data, &len); memcpy(g->guild.mes1, data, zmin(len, sizeof(g->guild.mes1)));
  334. Sql_GetData(sql_handle, 10, &data, &len); memcpy(g->guild.mes2, data, zmin(len, sizeof(g->guild.mes2)));
  335. Sql_GetData(sql_handle, 11, &data, &len); g->guild.emblem_len = atoi(data);
  336. Sql_GetData(sql_handle, 12, &data, &len); g->guild.emblem_id = atoi(data);
  337. Sql_GetData(sql_handle, 13, &data, nullptr); g->guild.last_leader_change = atoi(data);
  338. Sql_GetData(sql_handle, 14, &data, &len);
  339. // convert emblem data from hexadecimal to binary
  340. //TODO: why not store it in the db as binary directly? [ultramage]
  341. for( i = 0, p = g->guild.emblem_data; i < g->guild.emblem_len; ++i, ++p )
  342. {
  343. if( *data >= '0' && *data <= '9' )
  344. *p = *data - '0';
  345. else if( *data >= 'a' && *data <= 'f' )
  346. *p = *data - 'a' + 10;
  347. else if( *data >= 'A' && *data <= 'F' )
  348. *p = *data - 'A' + 10;
  349. *p <<= 4;
  350. ++data;
  351. if( *data >= '0' && *data <= '9' )
  352. *p |= *data - '0';
  353. else if( *data >= 'a' && *data <= 'f' )
  354. *p |= *data - 'a' + 10;
  355. else if( *data >= 'A' && *data <= 'F' )
  356. *p |= *data - 'A' + 10;
  357. ++data;
  358. }
  359. // load guild member info
  360. 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) "
  361. "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) )
  362. {
  363. Sql_ShowDebug(sql_handle);
  364. return nullptr;
  365. }
  366. for( i = 0; i < g->guild.max_member && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
  367. {
  368. struct guild_member* m = &g->guild.member[i];
  369. Sql_GetData(sql_handle, 0, &data, nullptr); m->account_id = atoi(data);
  370. Sql_GetData(sql_handle, 1, &data, nullptr); m->char_id = atoi(data);
  371. Sql_GetData(sql_handle, 2, &data, nullptr); m->hair = atoi(data);
  372. Sql_GetData(sql_handle, 3, &data, nullptr); m->hair_color = atoi(data);
  373. Sql_GetData(sql_handle, 4, &data, nullptr);
  374. switch( *data ){
  375. case 'F':
  376. m->gender = SEX_FEMALE;
  377. break;
  378. case 'M':
  379. m->gender = SEX_MALE;
  380. break;
  381. default:
  382. ShowWarning( "inter_guild_fromsql: Unsupported gender %c for char_id %u. Defaulting to male...\n", *data, m->char_id );
  383. m->gender = SEX_MALE;
  384. break;
  385. }
  386. Sql_GetData(sql_handle, 5, &data, nullptr); m->class_ = atoi(data);
  387. Sql_GetData(sql_handle, 6, &data, nullptr); m->lv = atoi(data);
  388. Sql_GetData(sql_handle, 7, &data, nullptr); m->exp = strtoull(data, nullptr, 10);
  389. Sql_GetData(sql_handle, 8, &data, nullptr); m->online = atoi(data);
  390. Sql_GetData(sql_handle, 9, &data, nullptr); m->position = atoi(data);
  391. if( m->position >= MAX_GUILDPOSITION ) // Fix reduction of MAX_GUILDPOSITION [PoW]
  392. m->position = MAX_GUILDPOSITION - 1;
  393. Sql_GetData(sql_handle, 10, &data, &len); memcpy(m->name, data, zmin(len, NAME_LENGTH));
  394. Sql_GetData(sql_handle, 11, &data, nullptr); m->last_login = atoi(data);
  395. m->modified = GS_MEMBER_UNMODIFIED;
  396. }
  397. //printf("- Read guild_position %d from sql \n",guild_id);
  398. 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) )
  399. {
  400. Sql_ShowDebug(sql_handle);
  401. return nullptr;
  402. }
  403. while( SQL_SUCCESS == Sql_NextRow(sql_handle) )
  404. {
  405. int32 position;
  406. struct guild_position* gpos;
  407. Sql_GetData(sql_handle, 0, &data, nullptr); position = atoi(data);
  408. if( position < 0 || position >= MAX_GUILDPOSITION )
  409. continue;// invalid position
  410. gpos = &g->guild.position[position];
  411. Sql_GetData(sql_handle, 1, &data, &len); memcpy(gpos->name, data, zmin(len, NAME_LENGTH));
  412. Sql_GetData(sql_handle, 2, &data, nullptr); gpos->mode = atoi(data);
  413. Sql_GetData(sql_handle, 3, &data, nullptr); gpos->exp_mode = atoi(data);
  414. gpos->modified = GS_POSITION_UNMODIFIED;
  415. }
  416. //printf("- Read guild_alliance %d from sql \n",guild_id);
  417. 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) )
  418. {
  419. Sql_ShowDebug(sql_handle);
  420. return nullptr;
  421. }
  422. for( i = 0; i < MAX_GUILDALLIANCE && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
  423. {
  424. struct guild_alliance* a = &g->guild.alliance[i];
  425. Sql_GetData(sql_handle, 0, &data, nullptr); a->opposition = atoi(data);
  426. Sql_GetData(sql_handle, 1, &data, nullptr); a->guild_id = atoi(data);
  427. Sql_GetData(sql_handle, 2, &data, &len); memcpy(a->name, data, zmin(len, NAME_LENGTH));
  428. }
  429. //printf("- Read guild_expulsion %d from sql \n",guild_id);
  430. if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `account_id`,`name`,`mes`,`char_id` FROM `%s` WHERE `guild_id`='%d'", schema_config.guild_expulsion_db, guild_id) )
  431. {
  432. Sql_ShowDebug(sql_handle);
  433. return nullptr;
  434. }
  435. for( i = 0; i < MAX_GUILDEXPULSION && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
  436. {
  437. struct guild_expulsion *e = &g->guild.expulsion[i];
  438. Sql_GetData(sql_handle, 0, &data, nullptr); e->account_id = atoi(data);
  439. Sql_GetData(sql_handle, 1, &data, &len); memcpy(e->name, data, zmin(len, NAME_LENGTH));
  440. Sql_GetData(sql_handle, 2, &data, &len); memcpy(e->mes, data, zmin(len, sizeof(e->mes)));
  441. Sql_GetData(sql_handle, 3, &data, nullptr); e->char_id = strtoul(data, nullptr, 10);
  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->guild.skill[i].id = i + GD_SKILLBASE;
  452. }
  453. while( SQL_SUCCESS == Sql_NextRow(sql_handle) )
  454. {
  455. int32 id;
  456. Sql_GetData(sql_handle, 0, &data, nullptr); id = atoi(data) - GD_SKILLBASE;
  457. if( id < 0 || id >= MAX_GUILDSKILL )
  458. continue;// invalid guild skill
  459. Sql_GetData(sql_handle, 1, &data, nullptr); g->guild.skill[id].lv = atoi(data);
  460. }
  461. Sql_FreeResult(sql_handle);
  462. // Add to cache
  463. guild_db[g->guild.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->guild.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(int32 guild_id)
  476. {
  477. #ifdef OFFICIAL_GUILD_STORAGE
  478. auto 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. int32 inter_guildcastle_tosql( std::shared_ptr<struct guild_castle> gc ){
  494. StringBuf buf;
  495. int32 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( int32 castle_id ){
  512. char *data;
  513. int32 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 nullptr;
  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, nullptr); gc->guild_id = atoi(data);
  535. Sql_GetData(sql_handle, CD_CURRENT_ECONOMY, &data, nullptr); gc->economy = atoi(data);
  536. Sql_GetData(sql_handle, CD_CURRENT_DEFENSE, &data, nullptr); gc->defense = atoi(data);
  537. Sql_GetData(sql_handle, CD_INVESTED_ECONOMY, &data, nullptr); gc->triggerE = atoi(data);
  538. Sql_GetData(sql_handle, CD_INVESTED_DEFENSE, &data, nullptr); gc->triggerD = atoi(data);
  539. Sql_GetData(sql_handle, CD_NEXT_TIME, &data, nullptr); gc->nextTime = atoi(data);
  540. Sql_GetData(sql_handle, CD_PAY_TIME, &data, nullptr); gc->payTime = atoi(data);
  541. Sql_GetData(sql_handle, CD_CREATE_TIME, &data, nullptr); gc->createTime = atoi(data);
  542. Sql_GetData(sql_handle, CD_ENABLED_KAFRA, &data, nullptr); gc->visibleC = atoi(data);
  543. for (i = CD_ENABLED_GUARDIAN00; i < CD_MAX; i++) {
  544. Sql_GetData(sql_handle, i, &data, nullptr); 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. int32 inter_guild_CharOnline(uint32 char_id, int32 guild_id)
  554. {
  555. int32 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, nullptr);
  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. auto 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->guild.max_member, i, g->guild.member[i].char_id == char_id );
  587. if( i < g->guild.max_member )
  588. {
  589. g->guild.member[i].online = 1;
  590. g->guild.member[i].modified = GS_MEMBER_MODIFIED;
  591. }
  592. return 1;
  593. }
  594. int32 inter_guild_CharOffline(uint32 char_id, int32 guild_id)
  595. {
  596. int32 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, nullptr);
  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. auto 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->guild.max_member, i, g->guild.member[i].char_id == char_id );
  627. if( i < g->guild.max_member )
  628. {
  629. g->guild.member[i].online = 0;
  630. g->guild.member[i].modified = GS_MEMBER_MODIFIED;
  631. }
  632. online_count = 0;
  633. for( i = 0; i < g->guild.max_member; i++ )
  634. if( g->guild.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. auto guild = pair.second;
  694. if( guild->save_flag&GS_MASK ){
  695. inter_guild_tosql( guild->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. int32 search_guildname(char *str)
  703. {
  704. int32 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, nullptr);
  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<CharGuild> g ){
  728. int32 i;
  729. ARR_FIND( 0, g->guild.max_member, i, g->guild.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->guild.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. int32 guild_checkskill( std::shared_ptr<CharGuild> g, int32 id ){
  739. int32 idx = id - GD_SKILLBASE;
  740. return idx < 0 || idx >= MAX_GUILDSKILL ? 0 : g->guild.skill[idx].lv;
  741. }
  742. int32 guild_calcinfo( std::shared_ptr<CharGuild> g ){
  743. int32 i,c;
  744. struct mmo_guild before = g->guild; // Save guild current values
  745. if(g->guild.guild_lv<=0)
  746. g->guild.guild_lv = 1;
  747. g->guild.next_exp = guild_exp_db.get_nextexp(g->guild.guild_lv);
  748. // Consume guild exp and increase guild level
  749. while(g->guild.exp >= g->guild.next_exp && g->guild.next_exp > 0 && g->guild.guild_lv < MAX_GUILDLEVEL){
  750. g->guild.exp-=g->guild.next_exp;
  751. g->guild.guild_lv++;
  752. g->guild.skill_point++;
  753. g->guild.next_exp = guild_exp_db.get_nextexp(g->guild.guild_lv);
  754. }
  755. // Set the max number of members, Guild Extention skill - currently adds 6 to max per skill lv.
  756. g->guild.max_member = 16 + guild_checkskill(g, GD_EXTENSION) * 6;
  757. if(g->guild.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.guild_id, g->guild.name, g->guild.max_member, MAX_GUILD);
  760. g->guild.max_member = MAX_GUILD;
  761. }
  762. // Compute the guild average level
  763. g->guild.average_lv=0;
  764. g->guild.connect_member=0;
  765. for(i=c=0;i<g->guild.max_member;i++)
  766. {
  767. if(g->guild.member[i].account_id>0)
  768. {
  769. if (g->guild.member[i].lv >= 0)
  770. {
  771. g->guild.average_lv+=g->guild.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.guild_id, g->guild.name, g->guild.member[i].char_id, g->guild.member[i].name, g->guild.member[i].lv);
  777. }
  778. if(g->guild.member[i].online)
  779. g->guild.connect_member++;
  780. }
  781. }
  782. if(c)
  783. g->guild.average_lv /= c;
  784. // Check if guild stats has change
  785. if(g->guild.max_member != before.max_member || g->guild.guild_lv != before.guild_lv || g->guild.skill_point != before.skill_point )
  786. {
  787. g->save_flag |= GS_LEVEL;
  788. mapif_guild_info(-1,g->guild);
  789. return 1;
  790. }
  791. return 0;
  792. }
  793. //-------------------------------------------------------------------
  794. // Packet sent to map server
  795. int32 mapif_guild_created( int32 fd, uint32 account_id, struct mmo_guild *g ){
  796. WFIFOHEAD(fd, 10);
  797. WFIFOW(fd,0)=0x3830;
  798. WFIFOL(fd,2)=account_id;
  799. if(g != nullptr)
  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. int32 mapif_guild_noinfo(int32 fd,int32 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. int32 mapif_guild_info( int32 fd, const struct mmo_guild &g ){
  824. unsigned char buf[8+sizeof(struct mmo_guild)];
  825. WBUFW(buf,0)=0x3831;
  826. WBUFW(buf,2)=4+sizeof(struct mmo_guild);
  827. memcpy( buf + 4, &g, sizeof( struct mmo_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. int32 mapif_guild_memberadded(int32 fd,int32 guild_id,uint32 account_id,uint32 char_id,int32 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. int32 mapif_guild_withdraw(int32 guild_id,uint32 account_id,uint32 char_id,int32 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. int32 mapif_guild_memberinfoshort( const struct mmo_guild &g, int32 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. int32 mapif_guild_broken(int32 guild_id,int32 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. int32 mapif_guild_message(int32 guild_id,uint32 account_id,char *mes,int32 len, int32 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. int32 mapif_guild_basicinfochanged(int32 guild_id,int32 type,const void *data,int32 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. int32 mapif_guild_memberinfochanged(int32 guild_id,uint32 account_id,uint32 char_id, int32 type,const void *data,int32 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. int32 mapif_guild_skillupack(int32 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. int32 mapif_guild_alliance(int32 guild_id1,int32 guild_id2,uint32 account_id1,uint32 account_id2,int32 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. int32 mapif_guild_position( const struct mmo_guild &g, int32 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. int32 mapif_guild_notice( const struct mmo_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. int32 mapif_guild_emblem( const struct mmo_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. int32 mapif_guild_emblem_version( const struct mmo_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. int32 mapif_guild_master_changed( const struct mmo_guild &g, int32 aid, int32 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. int32 mapif_guild_castle_dataload(int32 fd, int32 sz, int32 *castle_ids)
  1007. {
  1008. int32 num = (sz - 4) / sizeof(int);
  1009. int32 len = 4 + num * sizeof( struct guild_castle );
  1010. int32 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. int32 mapif_parse_CreateGuild(int32 fd,uint32 account_id,char *name,struct guild_member *master)
  1025. {
  1026. int32 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,nullptr);
  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]) == nullptr) {
  1039. mapif_guild_created(fd,account_id,nullptr);
  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]) != nullptr) {
  1045. mapif_guild_created(fd,account_id,nullptr);
  1046. return 0;
  1047. }
  1048. }
  1049. auto g = std::make_shared<CharGuild>();
  1050. memcpy(g->guild.name,name,NAME_LENGTH);
  1051. memcpy(g->guild.master,master->name,NAME_LENGTH);
  1052. memcpy(&g->guild.member[0],master,sizeof(struct guild_member));
  1053. g->guild.member[0].modified = GS_MEMBER_MODIFIED;
  1054. // Set default positions
  1055. g->guild.position[0].mode = GUILD_PERM_DEFAULT;
  1056. strcpy(g->guild.position[0].name,"GuildMaster");
  1057. strcpy(g->guild.position[MAX_GUILDPOSITION-1].name,"Newbie");
  1058. g->guild.position[0].modified = g->guild.position[MAX_GUILDPOSITION-1].modified = GS_POSITION_MODIFIED;
  1059. for(i=1;i<MAX_GUILDPOSITION-1;i++) {
  1060. sprintf(g->guild.position[i].name,"Position %d",i+1);
  1061. g->guild.position[i].modified = GS_POSITION_MODIFIED;
  1062. }
  1063. // Initialize guild property
  1064. g->guild.max_member=16;
  1065. g->guild.average_lv=master->lv;
  1066. g->guild.connect_member=1;
  1067. for(i=0;i<MAX_GUILDSKILL;i++)
  1068. g->guild.skill[i].id=i + GD_SKILLBASE;
  1069. g->guild.guild_id= -1; //Request to create guild.
  1070. // Create the guild
  1071. if (!inter_guild_tosql(g->guild,GS_BASIC|GS_POSITION|GS_SKILL|GS_MEMBER)) {
  1072. //Failed to Create guild....
  1073. ShowError("Failed to create Guild %s (Guild Master: %s)\n", g->guild.name, g->guild.master);
  1074. mapif_guild_created(fd,account_id,nullptr);
  1075. return 0;
  1076. }
  1077. ShowInfo("Created Guild %d - %s (Guild Master: %s)\n", g->guild.guild_id, g->guild.name, g->guild.master);
  1078. // Add to cache
  1079. guild_db[g->guild.guild_id] = g;
  1080. // Report to client
  1081. mapif_guild_created(fd, account_id, &g->guild);
  1082. mapif_guild_info(fd,g->guild);
  1083. if(charserv_config.log_inter)
  1084. inter_log("guild %s (id=%d) created by master %s (id=%d)\n",
  1085. name, g->guild.guild_id, master->name, master->account_id );
  1086. return 0;
  1087. }
  1088. // Return guild info to client
  1089. int32 mapif_parse_GuildInfo(int32 fd,int32 guild_id)
  1090. {
  1091. auto g = inter_guild_fromsql( guild_id );
  1092. if( g != nullptr ){
  1093. if (!guild_calcinfo(g))
  1094. mapif_guild_info(fd,g->guild);
  1095. }else
  1096. mapif_guild_noinfo(fd,guild_id); // Failed to load info
  1097. return 0;
  1098. }
  1099. // Add member to guild
  1100. int32 mapif_parse_GuildAddMember(int32 fd,int32 guild_id,struct guild_member *m)
  1101. {
  1102. auto g = inter_guild_fromsql( guild_id );
  1103. if( g == nullptr ){
  1104. // Failed to add
  1105. mapif_guild_memberadded(fd,guild_id,m->account_id,m->char_id,1);
  1106. return 0;
  1107. }
  1108. // Find an empty slot
  1109. for( int32 i = 0; i < g->guild.max_member; i++ ){
  1110. if(g->guild.member[i].account_id==0)
  1111. {
  1112. memcpy(&g->guild.member[i],m,sizeof(struct guild_member));
  1113. g->guild.member[i].modified = (GS_MEMBER_NEW | GS_MEMBER_MODIFIED);
  1114. mapif_guild_memberadded(fd,guild_id,m->account_id,m->char_id,0);
  1115. if (!guild_calcinfo(g)) //Send members if it was not invoked.
  1116. mapif_guild_info(-1,g->guild);
  1117. g->save_flag |= GS_MEMBER;
  1118. if (g->save_flag&GS_REMOVE)
  1119. g->save_flag&=~GS_REMOVE;
  1120. return 0;
  1121. }
  1122. }
  1123. // Failed to add
  1124. mapif_guild_memberadded(fd,guild_id,m->account_id,m->char_id,1);
  1125. return 0;
  1126. }
  1127. // Delete member from guild
  1128. int32 mapif_parse_GuildLeave(int32 fd, int32 guild_id, uint32 account_id, uint32 char_id, int32 flag, const char *mes)
  1129. {
  1130. int32 i;
  1131. auto g = inter_guild_fromsql( guild_id );
  1132. if( g == nullptr ){
  1133. // Unknown guild, just update the player
  1134. 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) )
  1135. Sql_ShowDebug(sql_handle);
  1136. // mapif_guild_withdraw(guild_id,account_id,char_id,flag,g->guild.member[i].name,mes);
  1137. return 0;
  1138. }
  1139. // Find the member
  1140. ARR_FIND( 0, g->guild.max_member, i, g->guild.member[i].account_id == account_id && g->guild.member[i].char_id == char_id );
  1141. if( i == g->guild.max_member )
  1142. {
  1143. //TODO member not found
  1144. return 0;
  1145. }
  1146. if( flag )
  1147. { // Write expulsion reason
  1148. // Find an empty slot
  1149. int32 j;
  1150. ARR_FIND( 0, MAX_GUILDEXPULSION, j, g->guild.expulsion[j].account_id == 0 );
  1151. if( j == MAX_GUILDEXPULSION )
  1152. {
  1153. // Expulsion list is full, flush the oldest one
  1154. for( j = 0; j < MAX_GUILDEXPULSION - 1; j++ )
  1155. g->guild.expulsion[j] = g->guild.expulsion[j+1];
  1156. j = MAX_GUILDEXPULSION-1;
  1157. }
  1158. // Save the expulsion entry
  1159. g->guild.expulsion[j].account_id = account_id;
  1160. g->guild.expulsion[j].char_id = char_id;
  1161. safestrncpy(g->guild.expulsion[j].name, g->guild.member[i].name, NAME_LENGTH);
  1162. safestrncpy(g->guild.expulsion[j].mes, mes, 40);
  1163. }
  1164. mapif_guild_withdraw(guild_id,account_id,char_id,flag,g->guild.member[i].name,mes);
  1165. inter_guild_removemember_tosql(g->guild.member[i].char_id);
  1166. memset(&g->guild.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->guild);
  1173. g->save_flag |= GS_EXPULSION;
  1174. }
  1175. return 0;
  1176. }
  1177. // Change member info
  1178. int32 mapif_parse_GuildChangeMemberInfoShort(int32 fd,int32 guild_id,uint32 account_id,uint32 char_id,int32 online,int32 lv,int32 class_)
  1179. {
  1180. // Could speed up by manipulating only guild_member
  1181. int32 i,sum,c;
  1182. int32 prev_count, prev_alv;
  1183. auto g = inter_guild_fromsql( guild_id );
  1184. if( g == nullptr ){
  1185. return 0;
  1186. }
  1187. ARR_FIND( 0, g->guild.max_member, i, g->guild.member[i].account_id == account_id && g->guild.member[i].char_id == char_id );
  1188. if( i < g->guild.max_member )
  1189. {
  1190. g->guild.member[i].online = online;
  1191. g->guild.member[i].lv = lv;
  1192. g->guild.member[i].class_ = class_;
  1193. g->guild.member[i].modified = GS_MEMBER_MODIFIED;
  1194. mapif_guild_memberinfoshort(g->guild,i);
  1195. }
  1196. prev_count = g->guild.connect_member;
  1197. prev_alv = g->guild.average_lv;
  1198. g->guild.average_lv = 0;
  1199. g->guild.connect_member = 0;
  1200. c = 0;
  1201. sum = 0;
  1202. for( i = 0; i < g->guild.max_member; i++ )
  1203. {
  1204. if( g->guild.member[i].account_id > 0 )
  1205. {
  1206. sum += g->guild.member[i].lv;
  1207. c++;
  1208. }
  1209. if( g->guild.member[i].online )
  1210. g->guild.connect_member++;
  1211. }
  1212. if( c ) // this check should always succeed...
  1213. {
  1214. g->guild.average_lv = sum / c;
  1215. if( g->guild.connect_member != prev_count || g->guild.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. int32 mapif_parse_BreakGuild(int32 fd,int32 guild_id)
  1225. {
  1226. auto 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->guild.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. int32 mapif_parse_GuildMessage(int32 fd,int32 guild_id,uint32 account_id,char *mes,int32 len)
  1260. {
  1261. return mapif_guild_message(guild_id,account_id,mes,len, fd);
  1262. }
  1263. // Modification of the guild
  1264. int32 mapif_parse_GuildBasicInfoChange(int32 fd,int32 guild_id,int32 type,const char *data,int32 len)
  1265. {
  1266. auto 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.guild_lv + data_value <= MAX_GUILDLEVEL) {
  1274. g->guild.guild_lv += data_value;
  1275. g->guild.skill_point += data_value;
  1276. } else if (data_value < 0 && g->guild.guild_lv + data_value >= 1)
  1277. g->guild.guild_lv += data_value;
  1278. mapif_guild_info(-1, g->guild);
  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. int32 mapif_parse_GuildMemberInfoChange(int32 fd,int32 guild_id,uint32 account_id,uint32 char_id,int32 type,const char *data,int32 len)
  1300. {
  1301. // Could make some improvement in speed, because only change guild_member
  1302. int32 i;
  1303. auto g = inter_guild_fromsql( guild_id );
  1304. if( g == nullptr ){
  1305. return 0;
  1306. }
  1307. // Search the member
  1308. for(i=0;i<g->guild.max_member;i++)
  1309. if( g->guild.member[i].account_id==account_id &&
  1310. g->guild.member[i].char_id==char_id )
  1311. break;
  1312. // Not Found
  1313. if(i==g->guild.max_member){
  1314. ShowWarning("int_guild: GuildMemberChange: Not found %d,%d in guild (%d - %s)\n",
  1315. account_id,char_id,guild_id,g->guild.name);
  1316. return 0;
  1317. }
  1318. switch(type)
  1319. {
  1320. case GMI_POSITION:
  1321. {
  1322. g->guild.member[i].position=*((short *)data);
  1323. g->guild.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->guild.member[i].exp;
  1331. g->guild.member[i].exp=*((t_exp *)data);
  1332. g->guild.member[i].modified = GS_MEMBER_MODIFIED;
  1333. if (g->guild.member[i].exp > old_exp)
  1334. {
  1335. t_exp exp = g->guild.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->guild.exp = util::safe_addition_cap(g->guild.exp, exp, MAX_GUILD_EXP);
  1341. guild_calcinfo(g);
  1342. mapif_guild_basicinfochanged(guild_id,GBI_EXP,&g->guild.exp,sizeof(g->guild.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->guild.member[i].hair=*((short *)data);
  1352. g->guild.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->guild.member[i].hair_color=*((short *)data);
  1360. g->guild.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->guild.member[i].gender=*((short *)data);
  1368. g->guild.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->guild.member[i].class_=*((short *)data);
  1376. g->guild.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->guild.member[i].lv=*((short *)data);
  1384. g->guild.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. int32 inter_guild_sex_changed(int32 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. int32 inter_guild_charname_changed(int32 guild_id,uint32 account_id, uint32 char_id, char *name)
  1400. {
  1401. int32 i, flag = 0;
  1402. auto 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->guild.max_member, i, g->guild.member[i].char_id == char_id);
  1408. if( i == g->guild.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->guild.member[i].name, g->guild.master) )
  1414. {
  1415. safestrncpy(g->guild.master, name, NAME_LENGTH);
  1416. flag |= GS_BASIC;
  1417. }
  1418. safestrncpy(g->guild.member[i].name, name, NAME_LENGTH);
  1419. g->guild.member[i].modified = GS_MEMBER_MODIFIED;
  1420. flag |= GS_MEMBER;
  1421. if( !inter_guild_tosql(g->guild, flag) )
  1422. return 0;
  1423. mapif_guild_info(-1,g->guild);
  1424. return 0;
  1425. }
  1426. // Change a position desc
  1427. int32 mapif_parse_GuildPosition(int32 fd,int32 guild_id,int32 idx,struct guild_position *p)
  1428. {
  1429. // Could make some improvement in speed, because only change guild_position
  1430. auto g = inter_guild_fromsql( guild_id );
  1431. if( g == nullptr || idx < 0 || idx >= MAX_GUILDPOSITION ){
  1432. return 0;
  1433. }
  1434. memcpy(&g->guild.position[idx],p,sizeof(struct guild_position));
  1435. mapif_guild_position(g->guild,idx);
  1436. g->guild.position[idx].modified = GS_POSITION_MODIFIED;
  1437. g->save_flag |= GS_POSITION; // Change guild_position
  1438. return 0;
  1439. }
  1440. // Guild Skill UP
  1441. int32 mapif_parse_GuildSkillUp(int32 fd,int32 guild_id,uint16 skill_id,uint32 account_id,int32 max)
  1442. {
  1443. int32 idx = skill_id - GD_SKILLBASE;
  1444. auto g = inter_guild_fromsql( guild_id );
  1445. if( g == nullptr || idx < 0 || idx >= MAX_GUILDSKILL ){
  1446. return 0;
  1447. }
  1448. if(g->guild.skill_point>0 && g->guild.skill[idx].id>0 && g->guild.skill[idx].lv<max )
  1449. {
  1450. g->guild.skill[idx].lv++;
  1451. g->guild.skill_point--;
  1452. if (!guild_calcinfo(g))
  1453. mapif_guild_info(-1,g->guild);
  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->guild, 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. int32 mapif_parse_GuildDeleteAlliance( std::shared_ptr<CharGuild> &g, int32 guild_id, uint32 account_id1, uint32 account_id2, int32 flag ){
  1463. int32 i;
  1464. char name[NAME_LENGTH];
  1465. ARR_FIND( 0, MAX_GUILDALLIANCE, i, g->guild.alliance[i].guild_id == guild_id );
  1466. if( i == MAX_GUILDALLIANCE )
  1467. return -1;
  1468. strcpy(name, g->guild.alliance[i].name);
  1469. g->guild.alliance[i].guild_id=0;
  1470. mapif_guild_alliance(g->guild.guild_id,guild_id,account_id1,account_id2,flag,g->guild.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. int32 mapif_parse_GuildAlliance(int32 fd,int32 guild_id1,int32 guild_id2,uint32 account_id1,uint32 account_id2,int32 flag)
  1485. {
  1486. // Could speed up
  1487. std::shared_ptr<CharGuild> g[2];
  1488. int32 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]->guild.alliance[j].guild_id == g[1-i]->guild.guild_id && g[i]->guild.alliance[j].opposition == (flag&GUILD_ALLIANCE_TYPE_MASK) );
  1504. if( j < MAX_GUILDALLIANCE )
  1505. g[i]->guild.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]->guild.alliance[j].guild_id == 0 );
  1515. if( j < MAX_GUILDALLIANCE )
  1516. {
  1517. g[i]->guild.alliance[j].guild_id = g[1-i]->guild.guild_id;
  1518. memcpy(g[i]->guild.alliance[j].name,g[1-i]->guild.name,NAME_LENGTH);
  1519. // Set alliance type
  1520. g[i]->guild.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]->guild.name,g[1]->guild.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. int32 mapif_parse_GuildNotice(int32 fd,int32 guild_id,const char *mes1,const char *mes2)
  1533. {
  1534. auto g = inter_guild_fromsql( guild_id );
  1535. if( g == nullptr ){
  1536. return 0;
  1537. }
  1538. memcpy(g->guild.mes1,mes1,MAX_GUILDMES1);
  1539. memcpy(g->guild.mes2,mes2,MAX_GUILDMES2);
  1540. g->save_flag |= GS_MES; //Change mes of guild
  1541. inter_guild_tosql(g->guild, g->save_flag);
  1542. return mapif_guild_notice(g->guild);
  1543. }
  1544. int32 mapif_parse_GuildEmblem(int32 fd,int32 len,int32 guild_id,int32 dummy,const char *data)
  1545. {
  1546. auto g = inter_guild_fromsql( guild_id );
  1547. if( g == nullptr ){
  1548. return 0;
  1549. }
  1550. if (len > sizeof(g->guild.emblem_data))
  1551. len = sizeof(g->guild.emblem_data);
  1552. memcpy(g->guild.emblem_data,data,len);
  1553. g->guild.emblem_len=len;
  1554. g->guild.emblem_id++;
  1555. g->save_flag |= GS_EMBLEM; //Change guild
  1556. return mapif_guild_emblem(g->guild);
  1557. }
  1558. int32 mapif_parse_GuildCastleDataLoad(int32 fd, int32 len, int32 *castle_ids)
  1559. {
  1560. return mapif_guild_castle_dataload(fd, len, castle_ids);
  1561. }
  1562. int32 mapif_parse_GuildCastleDataSave(int32 fd, int32 castle_id, int32 index, int32 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. int32 gid = (value) ? value : gc->guild_id;
  1573. auto g = util::umap_find( guild_db, gid );
  1574. inter_log("guild %s (id=%d) %s castle id=%d\n",
  1575. (g) ? g->guild.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. int32 mapif_parse_GuildMasterChange(int32 fd, int32 guild_id, const char* name, int32 len)
  1599. {
  1600. struct guild_member gm;
  1601. int32 pos;
  1602. auto 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->guild.max_member && strncmp(g->guild.member[pos].name, name, len); pos++);
  1608. if (pos == g->guild.max_member)
  1609. return 0; //Character not found??
  1610. // Switch current and old GM
  1611. memcpy(&gm, &g->guild.member[pos], sizeof (struct guild_member));
  1612. memcpy(&g->guild.member[pos], &g->guild.member[0], sizeof(struct guild_member));
  1613. memcpy(&g->guild.member[0], &gm, sizeof(struct guild_member));
  1614. // Switch positions
  1615. g->guild.member[pos].position = g->guild.member[0].position;
  1616. g->guild.member[pos].modified = GS_MEMBER_MODIFIED;
  1617. g->guild.member[0].position = 0; //Position 0: guild Master.
  1618. g->guild.member[0].modified = GS_MEMBER_MODIFIED;
  1619. // Store changing time
  1620. g->guild.last_leader_change = time(nullptr);
  1621. safestrncpy(g->guild.master, name, len);
  1622. if (len < NAME_LENGTH)
  1623. g->guild.master[len] = '\0';
  1624. ShowInfo("int_guild: Guildmaster Changed to %s (Guild %d - %s)\n",g->guild.master, guild_id, g->guild.name);
  1625. g->save_flag |= (GS_BASIC|GS_MEMBER); //Save main data and member data.
  1626. return mapif_guild_master_changed(g->guild, g->guild.member[0].account_id, g->guild.member[0].char_id, g->guild.last_leader_change);
  1627. }
  1628. int32 mapif_parse_GuildEmblemVersion(int32 fd, int32 guild_id, int32 version)
  1629. {
  1630. auto g = inter_guild_fromsql( guild_id );
  1631. if (g == nullptr)
  1632. return 0;
  1633. g->guild.emblem_len = 0;
  1634. g->guild.emblem_id = version;
  1635. g->save_flag |= GS_EMBLEM;
  1636. mapif_guild_emblem_version(g->guild);
  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. int32 inter_guild_parse_frommap(int32 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),(int32 *)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. int32 inter_guild_leave(int32 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. int32 inter_guild_broken(int32 guild_id)
  1679. {
  1680. return mapif_guild_broken(guild_id, 0);
  1681. }