summaryrefslogtreecommitdiff
path: root/src/char_sql/int_party.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/char_sql/int_party.c')
-rw-r--r--src/char_sql/int_party.c935
1 files changed, 0 insertions, 935 deletions
diff --git a/src/char_sql/int_party.c b/src/char_sql/int_party.c
deleted file mode 100644
index 45237de..0000000
--- a/src/char_sql/int_party.c
+++ /dev/null
@@ -1,935 +0,0 @@
-//
-// original code from athena
-// SQL conversion by hack
-//
-
-#include "char.h"
-#include "strlib.h"
-#include "socket.h"
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-
-static struct party *party_pt;
-static int party_newid = 100;
-
-int mapif_party_broken (int party_id, int flag);
-int party_check_empty (struct party *p);
-int mapif_parse_PartyLeave (int fd, int party_id, int account_id);
-
-// Save party to mysql
-int inter_party_tosql (int party_id, struct party *p)
-{
- // 'party' ('party_id','name','exp','item','leader')
-
- char t_name[100];
- char t_member[24];
- int party_member = 0, party_online_member = 0;
- int party_exist = 0;
- int leader_id = 0;
- int i = 0;
-
- printf ("(\033[1;64m%d\033[0m) Request save party - ", party_id);
-
- jstrescapecpy (t_name, p->name);
-
- if (p == NULL || party_id == 0 || p->party_id == 0
- || party_id != p->party_id)
- {
- printf ("- Party pointer or party_id error \n");
- return 0;
- }
-
- // Check if party exists
- sprintf (tmp_sql, "SELECT count(*) FROM `%s` WHERE `party_id`='%d'",
- party_db, party_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error - %s\n", mysql_error (&mysql_handle));
- return 0;
- }
- sql_res = mysql_store_result (&mysql_handle);
- if (sql_res != NULL && mysql_num_rows (sql_res) > 0)
- {
- sql_row = mysql_fetch_row (sql_res);
- party_exist = atoi (sql_row[0]);
- //printf("- Check if party %d exists : %s\n",party_id,party_exist==0?"No":"Yes");
- }
- mysql_free_result (sql_res); //resource free
-
- if (party_exist > 0)
- {
- // Check members in party
- sprintf (tmp_sql, "SELECT count(*) FROM `%s` WHERE `party_id`='%d'",
- char_db, party_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error - %s\n", mysql_error (&mysql_handle));
- return 0;
- }
- sql_res = mysql_store_result (&mysql_handle);
- if (sql_res != NULL && mysql_num_rows (sql_res) > 0)
- {
- sql_row = mysql_fetch_row (sql_res);
-
- party_member = atoi (sql_row[0]);
- // printf("- Check members in party %d : %d \n",party_id,party_member);
-
- }
- mysql_free_result (sql_res); //resource free
-
- party_online_member = 0;
- i = 0;
- while (i < MAX_PARTY)
- {
- if (p->member[i].account_id > 0)
- party_online_member++;
- i++;
- }
-
- //if (party_online_member==0) printf("- No member online \n"); else printf("- Some member %d online \n", party_online_member);
-
- if (party_member <= 0 && party_online_member == 0)
- {
-
- // Delete the party, if has no member.
- sprintf (tmp_sql, "DELETE FROM `%s` WHERE `party_id`='%d'",
- party_db, party_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error - %s\n",
- mysql_error (&mysql_handle));
- }
- // printf("No member in party %d, break it \n",party_id);
- memset (p, 0, sizeof (struct party));
- return 0;
- }
- else
- {
- // Update party information, if exists
-
- int i = 0;
-
- for (i = 0; i < MAX_PARTY; i++)
- {
-
- if (p->member[i].account_id > 0)
- {
- sprintf (tmp_sql,
- "UPDATE `%s` SET `party_id`='%d', `online`='%d' WHERE `account_id`='%d' AND `name`='%s'",
- char_db, party_id, p->member[i].online,
- p->member[i].account_id, jstrescapecpy (t_member,
- p->member
- [i].name));
- //printf("%s",tmp_sql);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (update `char`)- %s\n",
- mysql_error (&mysql_handle));
- }
- }
- }
-
- sprintf (tmp_sql,
- "UPDATE `%s` SET `name`='%s', `exp`='%d', `item`='%d', `leader_id`=`leader_id` WHERE `party_id`='%d'",
- party_db, t_name, p->exp, p->item, party_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (inset/update `party`)- %s\n",
- mysql_error (&mysql_handle));
- }
-
- // printf("- Update party %d information \n",party_id);
- }
- }
- else
- {
- // Add new party, if not exist
- int i = 0;
- while (i < MAX_PARTY
- && ((p->member[i].account_id > 0 && p->member[i].leader == 0)
- || (p->member[i].account_id < 0)))
- i++;
- if (i < MAX_PARTY)
- leader_id = p->member[i].account_id;
- sprintf (tmp_sql,
- "INSERT INTO `%s` (`party_id`, `name`, `exp`, `item`, `leader_id`) VALUES ('%d', '%s', '%d', '%d', '%d')",
- party_db, party_id, t_name, p->exp, p->item, leader_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (inset/update `party`)- %s\n",
- mysql_error (&mysql_handle));
- return 0;
- }
-
- sprintf (tmp_sql,
- "UPDATE `%s` SET `party_id`='%d', `online`='1' WHERE `account_id`='%d' AND `name`='%s'",
- char_db, party_id, leader_id, jstrescapecpy (t_member,
- p->
- member
- [i].name));
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (inset/update `party`)- %s\n",
- mysql_error (&mysql_handle));
- }
-
- //printf("- Insert new party %d \n",party_id);
- }
-
- printf ("Party save success\n");
- return 0;
-
-}
-
-// Read party from mysql
-int inter_party_fromsql (int party_id, struct party *p)
-{
- int leader_id = 0;
- printf ("(\033[1;64m%d\033[0m) Request load party - ", party_id);
-
- memset (p, 0, sizeof (struct party));
-
- sprintf (tmp_sql,
- "SELECT `party_id`, `name`,`exp`,`item`, `leader_id` FROM `%s` WHERE `party_id`='%d'",
- party_db, party_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (select `party`)- %s\n",
- mysql_error (&mysql_handle));
- return 0;
- }
-
- sql_res = mysql_store_result (&mysql_handle);
- if (sql_res != NULL && mysql_num_rows (sql_res) > 0)
- {
- sql_row = mysql_fetch_row (sql_res);
- // printf("- Read party %d from MySQL\n",party_id);
- p->party_id = party_id;
- strcpy (p->name, sql_row[1]);
- p->exp = atoi (sql_row[2]);
- p->item = atoi (sql_row[3]);
- leader_id = atoi (sql_row[4]);
- }
- else
- {
- mysql_free_result (sql_res);
- // printf("- Cannot find party %d \n",party_id);
- return 0;
- }
-
- mysql_free_result (sql_res);
-
- // Load members
- sprintf (tmp_sql,
- "SELECT `account_id`, `name`,`base_level`,`last_map`,`online` FROM `%s` WHERE `party_id`='%d'",
- char_db, party_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (select `party`)- %s\n",
- mysql_error (&mysql_handle));
- return 0;
- }
- sql_res = mysql_store_result (&mysql_handle);
- if (sql_res != NULL && mysql_num_rows (sql_res) > 0)
- {
- int i;
- for (i = 0; (sql_row = mysql_fetch_row (sql_res)); i++)
- {
- struct party_member *m = &p->member[i];
- m->account_id = atoi (sql_row[0]);
- if (m->account_id == leader_id)
- m->leader = 1;
- else
- m->leader = 0;
- strncpy (m->name, sql_row[1], sizeof (m->name));
- m->lv = atoi (sql_row[2]);
- strncpy (m->map, sql_row[3], sizeof (m->map));
- m->online = atoi (sql_row[4]);
- }
- // printf("- %d members found in party %d \n",i,party_id);
- }
- mysql_free_result (sql_res);
-
- printf ("Party load success\n");
- return 0;
-
-}
-
-int inter_party_sql_init ()
-{
- int i;
-
- //memory alloc
- printf ("interserver party memory initialize.... (%d byte)\n",
- sizeof (struct party));
- party_pt = calloc (sizeof (struct party), 1);
-
- sprintf (tmp_sql, "UPDATE `%s` SET `online`='0'", char_db);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (update `char`)- %s\n",
- mysql_error (&mysql_handle));
- }
-
- sprintf (tmp_sql, "SELECT count(*) FROM `%s`", party_db);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error - %s\n", mysql_error (&mysql_handle));
- }
- sql_res = mysql_store_result (&mysql_handle);
- sql_row = mysql_fetch_row (sql_res);
- printf ("total party data -> '%s'.......\n", sql_row[0]);
- i = atoi (sql_row[0]);
- mysql_free_result (sql_res);
-
- if (i > 0)
- {
- //set party_newid
- sprintf (tmp_sql, "SELECT max(`party_id`) FROM `%s`", party_db);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error - %s\n", mysql_error (&mysql_handle));
- }
-
- sql_res = mysql_store_result (&mysql_handle);
-
- sql_row = mysql_fetch_row (sql_res);
- party_newid = atoi (sql_row[0]) + 1;
- mysql_free_result (sql_res);
- }
-
- printf ("set party_newid: %d.......\n", party_newid);
-
- return 0;
-}
-
-// Search for the party according to its name
-struct party *search_partyname (char *str)
-{
- struct party *p = NULL;
- int leader_id = 0;
- char t_name[24];
-
- sprintf (tmp_sql,
- "SELECT `party_id`, `name`,`exp`,`item`,`leader_id` FROM `%s` WHERE `name`='%s'",
- party_db, jstrescapecpy (t_name, str));
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (select `party`)- %s\n",
- mysql_error (&mysql_handle));
- }
- sql_res = mysql_store_result (&mysql_handle);
- if (sql_res == NULL || mysql_num_rows (sql_res) <= 0)
- {
- mysql_free_result (sql_res);
- return p;
- }
- sql_row = mysql_fetch_row (sql_res);
- p = party_pt;
- p->party_id = atoi (sql_row[0]);
- strcpy (p->name, sql_row[1]);
- p->exp = atoi (sql_row[2]);
- p->item = atoi (sql_row[3]);
- leader_id = atoi (sql_row[4]);
- mysql_free_result (sql_res);
-
- // Load members
- sprintf (tmp_sql,
- "SELECT `account_id`, `name`,`base_level`,`last_map`,`online` FROM `%s` WHERE `party_id`='%d'",
- char_db, p->party_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (select `party`)- %s\n",
- mysql_error (&mysql_handle));
- return 0;
- }
- sql_res = mysql_store_result (&mysql_handle);
- if (sql_res != NULL && mysql_num_rows (sql_res) > 0)
- {
- int i;
- for (i = 0; (sql_row = mysql_fetch_row (sql_res)); i++)
- {
- struct party_member *m = &p->member[i];
- m->account_id = atoi (sql_row[0]);
- if (m->account_id == leader_id)
- m->leader = 1;
- else
- m->leader = 0;
- strncpy (m->name, sql_row[1], sizeof (m->name));
- m->lv = atoi (sql_row[2]);
- strncpy (m->map, sql_row[3], sizeof (m->map));
- m->online = atoi (sql_row[4]);
- }
- printf ("- %d members found in party %d \n", i, p->party_id);
- }
- mysql_free_result (sql_res);
-
- return p;
-}
-
-// EXP公平分配できるかチェック
-int party_check_exp_share (struct party *p)
-{
- int i;
- int maxlv = 0, minlv = 0x7fffffff;
- for (i = 0; i < MAX_PARTY; i++)
- {
- int lv = p->member[i].lv;
- if (p->member[i].online)
- {
- if (lv < minlv)
- minlv = lv;
- if (maxlv < lv)
- maxlv = lv;
- }
- }
- return (maxlv == 0 || maxlv - minlv <= party_share_level);
-}
-
-// Is there any member in the party?
-int party_check_empty (struct party *p)
-{
- int i;
- if (p == NULL || p->party_id == 0)
- return 1;
-// printf("party check empty %08X\n",(int)p);
- for (i = 0; i < MAX_PARTY; i++)
- {
-// printf("%d acc=%d\n",i,p->member[i].account_id);
- if (p->member[i].account_id > 0)
- {
- return 0;
- }
- }
- // If there is no member, then break the party
- mapif_party_broken (p->party_id, 0);
- inter_party_tosql (p->party_id, p);
- return 1;
-}
-
-// Check if a member is in two party, not necessary :)
-int party_check_conflict (int party_id, int account_id, char *nick)
-{
- return 0;
-}
-
-//-------------------------------------------------------------------
-// map serverへの通信
-
-// パーティ作成可否
-int mapif_party_created (int fd, int account_id, struct party *p)
-{
- WFIFOW (fd, 0) = 0x3820;
- WFIFOL (fd, 2) = account_id;
- if (p != NULL)
- {
- WFIFOB (fd, 6) = 0;
- WFIFOL (fd, 7) = p->party_id;
- memcpy (WFIFOP (fd, 11), p->name, 24);
- printf ("int_party: created! %d %s\n", p->party_id, p->name);
- }
- else
- {
- WFIFOB (fd, 6) = 1;
- WFIFOL (fd, 7) = 0;
- memcpy (WFIFOP (fd, 11), "error", 24);
- }
- WFIFOSET (fd, 35);
- return 0;
-}
-
-// パーティ情報見つからず
-int mapif_party_noinfo (int fd, int party_id)
-{
- WFIFOW (fd, 0) = 0x3821;
- WFIFOW (fd, 2) = 8;
- WFIFOL (fd, 4) = party_id;
- WFIFOSET (fd, 8);
- printf ("int_party: info not found %d\n", party_id);
- return 0;
-}
-
-// パーティ情報まとめ送り
-int mapif_party_info (int fd, struct party *p)
-{
- unsigned char buf[1024];
- WBUFW (buf, 0) = 0x3821;
- memcpy (buf + 4, p, sizeof (struct party));
- WBUFW (buf, 2) = 4 + sizeof (struct party);
- if (fd < 0)
- mapif_sendall (buf, WBUFW (buf, 2));
- else
- mapif_send (fd, buf, WBUFW (buf, 2));
-// printf("int_party: info %d %s\n",p->party_id,p->name);
- return 0;
-}
-
-// パーティメンバ追加可否
-int mapif_party_memberadded (int fd, int party_id, int account_id, int flag)
-{
- WFIFOW (fd, 0) = 0x3822;
- WFIFOL (fd, 2) = party_id;
- WFIFOL (fd, 6) = account_id;
- WFIFOB (fd, 10) = flag;
- WFIFOSET (fd, 11);
- return 0;
-}
-
-// パーティ設定変更通知
-int mapif_party_optionchanged (int fd, struct party *p, int account_id,
- int flag)
-{
- unsigned char buf[16];
- WBUFW (buf, 0) = 0x3823;
- WBUFL (buf, 2) = p->party_id;
- WBUFL (buf, 6) = account_id;
- WBUFW (buf, 10) = p->exp;
- WBUFW (buf, 12) = p->item;
- WBUFB (buf, 14) = flag;
- if (flag == 0)
- mapif_sendall (buf, 15);
- else
- mapif_send (fd, buf, 15);
- //printf("int_party: option changed %d %d %d %d %d\n",p->party_id,account_id,p->exp,p->item,flag);
- return 0;
-}
-
-// パーティ脱退通知
-int mapif_party_leaved (int party_id, int account_id, char *name)
-{
- unsigned char buf[64];
- WBUFW (buf, 0) = 0x3824;
- WBUFL (buf, 2) = party_id;
- WBUFL (buf, 6) = account_id;
- memcpy (WBUFP (buf, 10), name, 24);
- mapif_sendall (buf, 34);
- //printf("int_party: party leaved %d %d %s\n",party_id,account_id,name);
- return 0;
-}
-
-// パーティマップ更新通知
-int mapif_party_membermoved (struct party *p, int idx)
-{
- unsigned char buf[32];
- WBUFW (buf, 0) = 0x3825;
- WBUFL (buf, 2) = p->party_id;
- WBUFL (buf, 6) = p->member[idx].account_id;
- memcpy (WBUFP (buf, 10), p->member[idx].map, 16);
- WBUFB (buf, 26) = p->member[idx].online;
- WBUFW (buf, 27) = p->member[idx].lv;
- mapif_sendall (buf, 29);
- return 0;
-}
-
-// パーティ解散通知
-int mapif_party_broken (int party_id, int flag)
-{
- unsigned char buf[16];
- WBUFW (buf, 0) = 0x3826;
- WBUFL (buf, 2) = party_id;
- WBUFB (buf, 6) = flag;
- mapif_sendall (buf, 7);
- //printf("int_party: broken %d\n",party_id);
- return 0;
-}
-
-// パーティ内発言
-int mapif_party_message (int party_id, int account_id, char *mes, int len)
-{
- unsigned char buf[512];
- WBUFW (buf, 0) = 0x3827;
- WBUFW (buf, 2) = len + 12;
- WBUFL (buf, 4) = party_id;
- WBUFL (buf, 8) = account_id;
- memcpy (WBUFP (buf, 12), mes, len);
- mapif_sendall (buf, len + 12);
- return 0;
-}
-
-//-------------------------------------------------------------------
-// map serverからの通信
-
-// Create Party
-int mapif_parse_CreateParty (int fd, int account_id, char *name, char *nick,
- char *map, int lv)
-{
- struct party *p;
- if ((p = search_partyname (name)) != NULL)
- {
-// printf("int_party: same name party exists [%s]\n",name);
- mapif_party_created (fd, account_id, NULL);
- return 0;
- }
- p = party_pt;
- if (p == NULL)
- {
- printf ("int_party: out of memory !\n");
- mapif_party_created (fd, account_id, NULL);
- return 0;
- }
- memset (p, 0, sizeof (struct party));
- p->party_id = party_newid++;
- memcpy (p->name, name, 24);
- p->exp = 0;
- p->item = 0;
- p->member[0].account_id = account_id;
- memcpy (p->member[0].name, nick, 24);
- memcpy (p->member[0].map, map, 16);
- p->member[0].leader = 1;
- p->member[0].online = 1;
- p->member[0].lv = lv;
-
- inter_party_tosql (p->party_id, p);
-
- mapif_party_created (fd, account_id, p);
- mapif_party_info (fd, p);
-
- return 0;
-}
-
-// パーティ情報要求
-int mapif_parse_PartyInfo (int fd, int party_id)
-{
- struct party *p = party_pt;
- if (p == NULL)
- {
- printf ("int_party: out of memory !\n");
- return 0;
- }
- inter_party_fromsql (party_id, p);
-
- if (p->party_id >= 0)
- mapif_party_info (fd, p);
- else
- mapif_party_noinfo (fd, party_id);
- return 0;
-}
-
-// パーティ追加要求
-int mapif_parse_PartyAddMember (int fd, int party_id, int account_id,
- char *nick, char *map, int lv)
-{
- struct party *p;
- int i;
-
- p = party_pt;
- if (p == NULL)
- {
- printf ("int_party: out of memory !\n");
- return 0;
- }
- inter_party_fromsql (party_id, p);
-
- if (p->party_id <= 0)
- {
- mapif_party_memberadded (fd, party_id, account_id, 1);
- return 0;
- }
-
- for (i = 0; i < MAX_PARTY; i++)
- {
- if (p->member[i].account_id == 0)
- {
- int flag = 0;
-
- p->member[i].account_id = account_id;
- memcpy (p->member[i].name, nick, 24);
- memcpy (p->member[i].map, map, 16);
- p->member[i].leader = 0;
- p->member[i].online = 1;
- p->member[i].lv = lv;
- mapif_party_memberadded (fd, party_id, account_id, 0);
- mapif_party_info (-1, p);
-
- if (p->exp > 0 && !party_check_exp_share (p))
- {
- p->exp = 0;
- flag = 0x01;
- }
- if (flag)
- mapif_party_optionchanged (fd, p, 0, 0);
-
- inter_party_tosql (party_id, p);
- return 0;
- }
- }
- mapif_party_memberadded (fd, party_id, account_id, 1);
- //inter_party_tosql(party_id, p);
- return 0;
-}
-
-// パーティー設定変更要求
-int mapif_parse_PartyChangeOption (int fd, int party_id, int account_id,
- int exp, int item)
-{
- struct party *p;
- int flag = 0;
-
- p = party_pt;
- if (p == NULL)
- {
- printf ("int_party: out of memory !\n");
- return 0;
- }
-
- inter_party_fromsql (party_id, p);
-
- if (p->party_id <= 0)
- {
- return 0;
- }
-
- p->exp = exp;
- if (exp > 0 && !party_check_exp_share (p))
- {
- flag |= 0x01;
- p->exp = 0;
- }
-
- p->item = item;
-
- mapif_party_optionchanged (fd, p, account_id, flag);
- inter_party_tosql (party_id, p);
- return 0;
-}
-
-// パーティ脱退要求
-int mapif_parse_PartyLeave (int fd, int party_id, int account_id)
-{
- char t_member[24];
- struct party *p = party_pt;
- if (p == NULL)
- {
- printf ("int_party: out of memory !\n");
- return 0;
- }
-
- inter_party_fromsql (party_id, p);
-
- if (p->party_id >= 0)
- {
- int i, j;
- for (i = 0; i < MAX_PARTY; i++)
- {
-
- if (p->member[i].account_id == account_id)
- {
- //printf("p->member[i].account_id = %d , account_id = %d \n",p->member[i].account_id,account_id);
- mapif_party_leaved (party_id, account_id, p->member[i].name);
-
- // Update char information, does the name need encoding?
- sprintf (tmp_sql,
- "UPDATE `%s` SET `party_id`='0', `online`='1' WHERE `party_id`='%d' AND `name`='%s'",
- char_db, party_id, jstrescapecpy (t_member,
- p->
- member[i].name));
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (update `char`)- %s\n",
- mysql_error (&mysql_handle));
- }
-// printf("Delete member %s from MySQL \n", p->member[i].name);
-
- if (p->member[i].leader == 1)
- {
- for (j = 0; j < MAX_PARTY; j++)
- {
- //printf("j = %d , p->member[j].account_id = %d , p->member[j].account_id = %d \n",j,p->member[j].account_id,p->member[j].account_id);
- if (p->member[j].account_id > 0 && j != i)
- {
- mapif_party_leaved (party_id,
- p->member[j].account_id,
- p->member[j].name);
- // Update char information, does the name need encoding?
- sprintf (tmp_sql,
- "UPDATE `%s` SET `party_id`='0', `online`='1' WHERE `party_id`='%d' AND `name`='%s'",
- char_db, party_id,
- jstrescapecpy (t_member,
- p->member[i].name));
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf
- ("DB server Error (update `char`)- %s\n",
- mysql_error (&mysql_handle));
- }
-// printf("Delete member %s from MySQL \n", p->member[j].name);
- }
- }
- // Delete the party, if has no member.
- sprintf (tmp_sql,
- "DELETE FROM `%s` WHERE `party_id`='%d'",
- party_db, party_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error - %s\n",
- mysql_error (&mysql_handle));
- }
-// printf("Leader breaks party %d \n",party_id);
- memset (p, 0, sizeof (struct party));
- }
- else
- memset (&p->member[i], 0, sizeof (struct party_member));
-
- break;
-
- }
- }
- if (party_check_empty (p) == 0)
- mapif_party_info (-1, p); // まだ人がいるのでデータ送信
- /*
- * else
- * inter_party_tosql(party_id,p); // Break the party if no member
- */
- }
- else
- {
- sprintf (tmp_sql,
- "UPDATE `%s` SET `party_id`='0' WHERE `party_id`='%d' AND `account_id`='%d' AND `online`='1'",
- char_db, party_id, account_id);
- if (mysql_query (&mysql_handle, tmp_sql))
- {
- printf ("DB server Error (update `char`)- %s\n",
- mysql_error (&mysql_handle));
- }
- }
- return 0;
-}
-
-// When member goes to other map
-int mapif_parse_PartyChangeMap (int fd, int party_id, int account_id,
- char *map, int online, int lv)
-{
- struct party *p;
- int i;
-
- p = party_pt;
- if (p == NULL)
- {
- printf ("int_party: out of memory !\n");
- return 0;
- }
- inter_party_fromsql (party_id, p);
-
- if (p->party_id <= 0)
- {
- return 0;
- }
- for (i = 0; i < MAX_PARTY; i++)
- {
- if (p->member[i].account_id == account_id)
- {
- int flag = 0;
-
- memcpy (p->member[i].map, map, 16);
- p->member[i].online = online;
- p->member[i].lv = lv;
- mapif_party_membermoved (p, i);
-
- if (p->exp > 0 && !party_check_exp_share (p))
- {
- p->exp = 0;
- flag = 1;
- }
- if (flag)
- mapif_party_optionchanged (fd, p, 0, 0);
- break;
- }
- }
- inter_party_tosql (party_id, p);
- return 0;
-}
-
-// パーティ解散要求
-int mapif_parse_BreakParty (int fd, int party_id)
-{
- struct party *p;
-
- p = party_pt;
- if (p == NULL)
- {
- printf ("int_party: out of memory !\n");
- return 0;
- }
-
- inter_party_fromsql (party_id, p);
-
- if (p->party_id <= 0)
- {
- return 0;
- }
- inter_party_tosql (party_id, p);
-
- mapif_party_broken (fd, party_id);
- return 0;
-}
-
-// パーティメッセージ送信
-int mapif_parse_PartyMessage (int fd, int party_id, int account_id, char *mes,
- int len)
-{
- return mapif_party_message (party_id, account_id, mes, len);
-}
-
-// パーティチェック要求
-int mapif_parse_PartyCheck (int fd, int party_id, int account_id, char *nick)
-{
- return party_check_conflict (party_id, account_id, nick);
-}
-
-// map server からの通信
-// ・１パケットのみ解析すること
-// ・パケット長データはinter.cにセットしておくこと
-// ・パケット長チェックや、RFIFOSKIPは呼び出し元で行われるので行ってはならない
-// ・エラーなら0(false)、そうでないなら1(true)をかえさなければならない
-int inter_party_parse_frommap (int fd)
-{
- switch (RFIFOW (fd, 0))
- {
- case 0x3020:
- mapif_parse_CreateParty (fd, RFIFOL (fd, 2), RFIFOP (fd, 6),
- RFIFOP (fd, 30), RFIFOP (fd, 54),
- RFIFOW (fd, 70));
- break;
- case 0x3021:
- mapif_parse_PartyInfo (fd, RFIFOL (fd, 2));
- break;
- case 0x3022:
- mapif_parse_PartyAddMember (fd, RFIFOL (fd, 2), RFIFOL (fd, 6),
- RFIFOP (fd, 10), RFIFOP (fd, 34),
- RFIFOW (fd, 50));
- break;
- case 0x3023:
- mapif_parse_PartyChangeOption (fd, RFIFOL (fd, 2), RFIFOL (fd, 6),
- RFIFOW (fd, 10), RFIFOW (fd, 12));
- break;
- case 0x3024:
- mapif_parse_PartyLeave (fd, RFIFOL (fd, 2), RFIFOL (fd, 6));
- break;
- case 0x3025:
- mapif_parse_PartyChangeMap (fd, RFIFOL (fd, 2), RFIFOL (fd, 6),
- RFIFOP (fd, 10), RFIFOB (fd, 26),
- RFIFOW (fd, 27));
- break;
- case 0x3026:
- mapif_parse_BreakParty (fd, RFIFOL (fd, 2));
- break;
- case 0x3027:
- mapif_parse_PartyMessage (fd, RFIFOL (fd, 4), RFIFOL (fd, 8),
- RFIFOP (fd, 12), RFIFOW (fd, 2) - 12);
- break;
- case 0x3028:
- mapif_parse_PartyCheck (fd, RFIFOL (fd, 2), RFIFOL (fd, 6),
- RFIFOP (fd, 10));
- break;
- default:
- return 0;
- }
- return 1;
-}
-
-// サーバーから脱退要求（キャラ削除用）
-int inter_party_leave (int party_id, int account_id)
-{
- return mapif_parse_PartyLeave (-1, party_id, account_id);
-}
generated by cgit v1.2.3-60-g2f50 (git 2.42.0) at 2024-06-27 20:49:39 +0000