API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Jul 21st, 2018
21
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 110.54 KB | None | 0 0
raw download clone embed print report
  1. /*
  2. * CSStatsX SQL v. 0.7.4
  3. * by serfreeman1337 http://1337.uz/
  4. */
  5.  
  6. #include <amxmodx>
  7. #include <sqlx>
  8.  
  9. #include <fakemeta>
  10. #include <hamsandwich>
  11.  
  12. #define PLUGIN "CSStatsX SQL"
  13. #define VERSION "0.7.4"
  14. #define AUTHOR "serfreeman1337" // AKA SerSQL1337
  15.  
  16. #define LASTUPDATE "06, July (07), 2016"
  17.  
  18. #if AMXX_VERSION_NUM < 183
  19. #define MAX_PLAYERS 32
  20. #define MAX_NAME_LENGTH 32
  21. new MaxClients
  22. #endif
  23.  
  24. /* - SQL - */
  25.  
  26. new Handle:sql
  27. new Handle:sql_con
  28.  
  29. /* - КОНСТАНТЫ - */
  30.  
  31. enum _:sql_que_type // тип sql запроса
  32. {
  33. SQL_DUMMY,
  34. SQL_INITDB, // автоматическое созданием таблиц
  35. SQL_LOAD, // загрузка статистики
  36. SQL_UPDATE, // обновление
  37. SQL_INSERT, // внесение новой записи
  38. SQL_UPDATERANK, // получение ранков игроков,
  39. SQL_GETSTATS, // потоквый запрос на get_stats
  40.  
  41. // 0.7
  42. SQL_GETWSTATS, // статистика по оружию
  43. SQL_GETSESSID, // id сессии статистики за карту
  44. SQL_GETSESTATS, // статистика по картам
  45. SQL_AUTOCLEAR // чистка БД от неактивных записей
  46. }
  47.  
  48. enum _:load_state_type // состояние получение статистики
  49. {
  50. LOAD_NO, // данных нет
  51. LOAD_WAIT, // ожидание данных
  52. LOAD_NEWWAIT, // новая запись, ждем ответа
  53. LOAD_UPDATE, // перезагрузить после обновления
  54. LOAD_NEW, // новая запись
  55. LOAD_OK // есть данные
  56. }
  57.  
  58. enum _:row_ids // столбцы таблицы
  59. {
  60. ROW_ID,
  61. ROW_STEAMID,
  62. ROW_NAME,
  63. ROW_IP,
  64. ROW_SKILL,
  65. ROW_KILLS,
  66. ROW_DEATHS,
  67. ROW_HS,
  68. ROW_TKS,
  69. ROW_SHOTS,
  70. ROW_HITS,
  71. ROW_DMG,
  72. ROW_BOMBDEF,
  73. ROW_BOMBDEFUSED,
  74. ROW_BOMBPLANTS,
  75. ROW_BOMBEXPLOSIONS,
  76. ROW_H0,
  77. ROW_H1,
  78. ROW_H2,
  79. ROW_H3,
  80. ROW_H4,
  81. ROW_H5,
  82. ROW_H6,
  83. ROW_H7,
  84. ROW_ONLINETIME,
  85.  
  86. // 0.7
  87. ROW_CONNECTS,
  88. ROW_ROUNDT,
  89. ROW_WINT,
  90. ROW_ROUNDCT,
  91. ROW_WINCT,
  92.  
  93. // 0.7.2
  94. ROW_ASSISTS,
  95.  
  96. ROW_FIRSTJOIN,
  97. ROW_LASTJOIN,
  98.  
  99. // 0.7
  100. ROW_SESSIONID,
  101. ROW_SESSIONNAME
  102. }
  103.  
  104. new const row_names[row_ids][] = // имена столбцов
  105. {
  106. "id",
  107. "steamid",
  108. "name",
  109. "ip",
  110. "skill",
  111. "kills",
  112. "deaths",
  113. "hs",
  114. "tks",
  115. "shots",
  116. "hits",
  117. "dmg",
  118. "bombdef",
  119. "bombdefused",
  120. "bombplants",
  121. "bombexplosions",
  122. "h_0",
  123. "h_1",
  124. "h_2",
  125. "h_3",
  126. "h_4",
  127. "h_5",
  128. "h_6",
  129. "h_7",
  130. "connection_time",
  131.  
  132. // 0.7
  133. "connects",
  134. "roundt",
  135. "wint",
  136. "roundct",
  137. "winct",
  138.  
  139. // 0.7.2
  140. "assists",
  141.  
  142. "first_join",
  143. "last_join",
  144.  
  145. // 0.7
  146. "session_id",
  147. "session_map"
  148. }
  149.  
  150. enum _:STATS
  151. {
  152. STATS_KILLS,
  153. STATS_DEATHS,
  154. STATS_HS,
  155. STATS_TK,
  156. STATS_SHOTS,
  157. STATS_HITS,
  158. STATS_DMG,
  159.  
  160. STATS_END
  161. }
  162.  
  163. enum _:KILL_EVENT
  164. {
  165. NORMAL,
  166. SUICIDE,
  167. WORLD,
  168. WORLDSPAWN
  169. }
  170.  
  171. const QUERY_LENGTH = 1472 // размер переменной sql запроса
  172.  
  173. #define STATS2_DEFAT 0
  174. #define STATS2_DEFOK 1
  175. #define STATS2_PLAAT 2
  176. #define STATS2_PLAOK 3
  177. #define STATS2_END 4
  178.  
  179. new const task_rankupdate = 31337
  180. new const task_confin = 21337
  181. new const task_flush = 11337
  182.  
  183. #define MAX_CWEAPONS 6
  184. #define MAX_WEAPONS CSW_P90 + 1 + MAX_CWEAPONS
  185. #define HIT_END HIT_RIGHTLEG + 1
  186.  
  187. // 0.7
  188.  
  189. enum _:row_weapons_ids // столбцы таблицы
  190. {
  191. ROW_WEAPON_ID,
  192. ROW_WEAPON_PLAYER,
  193. ROW_WEAPON_NAME,
  194. ROW_WEAPON_KILLS,
  195. ROW_WEAPON_DEATHS,
  196. ROW_WEAPON_HS,
  197. ROW_WEAPON_TKS,
  198. ROW_WEAPON_SHOTS,
  199. ROW_WEAPON_HITS,
  200. ROW_WEAPON_DMG,
  201. ROW_WEAPON_H0,
  202. ROW_WEAPON_H1,
  203. ROW_WEAPON_H2,
  204. ROW_WEAPON_H3,
  205. ROW_WEAPON_H4,
  206. ROW_WEAPON_H5,
  207. ROW_WEAPON_H6,
  208. ROW_WEAPON_H7
  209. }
  210.  
  211. new const row_weapons_names[row_weapons_ids][] = // имена столбцов
  212. {
  213. "id",
  214. "player_id",
  215. "weapon",
  216. "kills",
  217. "deaths",
  218. "hs",
  219. "tks",
  220. "shots",
  221. "hits",
  222. "dmg",
  223. "h_0",
  224. "h_1",
  225. "h_2",
  226. "h_3",
  227. "h_4",
  228. "h_5",
  229. "h_6",
  230. "h_7"
  231. }
  232.  
  233. enum _:row_maps_ids
  234. {
  235. ROW_MAP_ID,
  236. ROW_MAP_SESSID,
  237. ROW_MAP_PLRID,
  238. ROW_MAP_MAP,
  239. ROW_MAP_SKILL,
  240. ROW_MAP_KILLS,
  241. ROW_MAP_DEATHS,
  242. ROW_MAP_HS,
  243. ROW_MAP_TKS,
  244. ROW_MAP_SHOTS,
  245. ROW_MAP_HITS,
  246. ROW_MAP_DMG,
  247. ROW_MAP_BOMBDEF,
  248. ROW_MAP_BOMBDEFUSED,
  249. ROW_MAP_BOMBPLANTS,
  250. ROW_MAP_BOMBEXPLOSIONS,
  251. ROW_MAP_H0,
  252. ROW_MAP_H1,
  253. ROW_MAP_H2,
  254. ROW_MAP_H3,
  255. ROW_MAP_H4,
  256. ROW_MAP_H5,
  257. ROW_MAP_H6,
  258. ROW_MAP_H7,
  259. ROW_MAP_ONLINETIME,
  260. ROW_MAP_CONNECTS,
  261. ROW_MAP_ROUNDT,
  262. ROW_MAP_WINT,
  263. ROW_MAP_ROUNDCT,
  264. ROW_MAP_WINCT,
  265. ROW_MAP_ASSISTS,
  266. ROW_MAP_FIRSTJOIN,
  267. ROW_MAP_LASTJOIN,
  268. }
  269.  
  270. /* - СТРУКТУРА ДАННЫХ - */
  271.  
  272. // 0.7
  273. enum _:STATS3_END
  274. {
  275. STATS3_CURRENTTEAM, // тек. команда игрока (определяется в начале раунда)
  276.  
  277. STATS3_CONNECT, // подключения к серверу
  278. STATS3_ROUNDT, // раунды за теров
  279. STATS3_WINT, // побед за теров
  280. STATS3_ROUNDCT, // раунды за спецов
  281. STATS3_WINCT, // побед за спецов
  282.  
  283. // 0.7.2
  284. STATS3_ASSIST // помощь в убийстве
  285. }
  286.  
  287.  
  288. enum _:sestats_array_struct
  289. {
  290. SESTATS_ID,
  291. SESTATS_PLAYERID,
  292. SESTATS_MAP[MAX_NAME_LENGTH],
  293. SESTATS_STATS[8],
  294. SESTATS_HITS[8],
  295. SESTATS_STATS2[4],
  296. SESTATS_STATS3[STATS3_END],
  297. Float:SESTATS_SKILL,
  298. SESTATS_ONLINETIME,
  299. SESTATS_FIRSTJOIN,
  300. SESTATS_LASTJOIN
  301. }
  302.  
  303. enum _:player_data_struct
  304. {
  305. PLAYER_ID, // ид игрока в базе данных
  306. PLAYER_LOADSTATE, // состояние загрузки статистики игрока
  307. PLAYER_RANK, // ранк игрока
  308. PLAYER_STATS[STATS_END], // статистика игрока
  309. PLAYER_STATSLAST[STATS_END], // разница в статистики
  310. PLAYER_HITS[HIT_END], // статистика попаданий
  311. PLAYER_HITSLAST[HIT_END], // разница в статистике попаданий
  312. PLAYER_STATS2[4], // статистика cstrike
  313. PLAYER_STATS2LAST[4], // разница
  314. Float:PLAYER_SKILL, // скилл
  315. PLAYER_ONLINE, // время онлайна
  316. // я не помню чо за diff и last, но без этого не работает XD
  317. Float:PLAYER_SKILLLAST,
  318. PLAYER_ONLINEDIFF,
  319. PLAYER_ONLINELAST,
  320.  
  321. PLAYER_NAME[MAX_NAME_LENGTH * 3],
  322. PLAYER_STEAMID[30],
  323. PLAYER_IP[16],
  324.  
  325. // 0.7
  326. PLAYER_STATS3[STATS3_END], // stast3
  327. PLAYER_STATS3LAST[STATS3_END], // stast3
  328. PLAYER_FIRSTJOIN,
  329. PLAYER_LASTJOIN
  330. }
  331.  
  332. enum _:stats_cache_struct // кеширование для get_stats
  333. {
  334. CACHE_NAME[32],
  335. CACHE_STEAMID[30],
  336. CACHE_STATS[8],
  337. CACHE_HITS[8],
  338. CACHE_SKILL,
  339. bool:CACHE_LAST,
  340.  
  341. // 0.5.1
  342. CACHE_ID,
  343. CACHE_TIME,
  344.  
  345. // 0.7
  346. CACHE_STATS2[4],
  347. CACHE_STATS3[STATS3_END],
  348. CACHE_FIRSTJOIN,
  349. CACHE_LASTJOIN
  350. }
  351.  
  352. enum _:cvar_set
  353. {
  354. CVAR_SQL_HOST,
  355. CVAR_SQL_USER,
  356. CVAR_SQL_PASS,
  357. CVAR_SQL_DB,
  358. CVAR_SQL_TABLE,
  359. CVAR_SQL_TYPE,
  360. CVAR_SQL_CREATE_DB,
  361.  
  362. CVAR_UPDATESTYLE,
  363. CVAR_RANK,
  364. CVAR_RANKFORMULA,
  365. CVAR_SKILLFORMULA,
  366. CVAR_RANKBOTS,
  367. CVAR_USEFORWARDS,
  368.  
  369. // 0.7
  370. CVAR_WEAPONSTATS,
  371. CVAR_MAPSTATS,
  372.  
  373. CVAR_AUTOCLEAR,
  374. CVAR_CACHETIME,
  375. CVAR_AUTOCLEAR_DAY,
  376.  
  377. // 0.7.2
  378. CVAR_ASSISTHP
  379. }
  380.  
  381.  
  382. // 0.7
  383. enum _:stats_cache_queue_struct
  384. {
  385. CACHE_QUE_START,
  386. CACHE_QUE_TOP,
  387. }
  388.  
  389. #define MAX_DATA_PARAMS 32
  390.  
  391. /* - ПЕРЕМЕННЫЕ - */
  392.  
  393. // 0.7
  394. new session_id,session_map[MAX_NAME_LENGTH]
  395.  
  396. new player_data[MAX_PLAYERS + 1][player_data_struct]
  397. new flush_que[QUERY_LENGTH * 3],flush_que_len
  398. new statsnum
  399.  
  400. //
  401. // Общая стата по оружию
  402. //
  403. // 1ый STATS_END + HIT_END - текущая общая статистика по оружию игрока
  404. // 2ой STATS_END + HIT_END - последнее значение player_wstats, использует для расчета разницы
  405. // последний индекс - определяет INSERT или UPDATE для запроса
  406. //
  407. new player_awstats[MAX_PLAYERS + 1][MAX_WEAPONS][((STATS_END + HIT_END) * 2) + 1]
  408.  
  409. new cvar[cvar_set]
  410.  
  411. new Trie:stats_cache_trie // дерево кеша для get_stats // ключ - ранг
  412.  
  413. new tbl_name[32]
  414.  
  415. /* - CSSTATS CORE - */
  416.  
  417. #pragma dynamic 32768
  418.  
  419. // wstats
  420. new player_wstats[MAX_PLAYERS + 1][MAX_WEAPONS][STATS_END + HIT_END]
  421.  
  422. // wstats2
  423. new player_wstats2[MAX_PLAYERS + 1][STATS2_END]
  424.  
  425. // wrstats rstats
  426. new player_wrstats[MAX_PLAYERS + 1][MAX_WEAPONS][STATS_END + HIT_END]
  427.  
  428. // vstats
  429. new player_vstats[MAX_PLAYERS + 1][MAX_PLAYERS + 1][STATS_END + HIT_END + MAX_NAME_LENGTH]
  430.  
  431. // astats
  432. new player_astats[MAX_PLAYERS + 1][MAX_PLAYERS + 1][STATS_END + HIT_END + MAX_NAME_LENGTH]
  433.  
  434. new FW_Death
  435. new FW_Damage
  436. new FW_BPlanting
  437. new FW_BPlanted
  438. new FW_BExplode
  439. new FW_BDefusing
  440. new FW_BDefused
  441. new FW_GThrow
  442.  
  443. // 0.7.2
  444. new FW_Assist
  445.  
  446. // 0.7.3
  447. new FW_Initialized
  448.  
  449. new dummy_ret
  450.  
  451. // осталось монитор прихуярить
  452.  
  453. new g_planter
  454. new g_defuser
  455.  
  456. #define WEAPON_INFO_SIZE 1 + (MAX_NAME_LENGTH * 2)
  457.  
  458. new Array:weapons_data // массив с инфой по оружию
  459. new Trie:log_ids_trie // дерево для быстрого определения id оружия по лог-коду
  460.  
  461. // 0.7
  462. new Array:stats_cache_queue
  463.  
  464. // 0.7.1
  465. new bool:weapon_stats_enabled,bool:map_stats_enabled
  466.  
  467. // 0.7.3
  468. new init_seq = -1
  469. new bool:is_ready = false
  470.  
  471. // макрос для помощи реагистрации инфы по оружию
  472. #define REG_INFO(%0,%1,%2)\
  473. weapon_info[0] = %0;\
  474. copy(weapon_info[1],MAX_NAME_LENGTH,%1);\
  475. copy(weapon_info[MAX_NAME_LENGTH ],MAX_NAME_LENGTH,%2);\
  476. ArrayPushArray(weapons_data,weapon_info);\
  477. TrieSetCell(log_ids_trie,%2,ArraySize(weapons_data) - 1)
  478.  
  479. public plugin_precache()
  480. {
  481. register_plugin(PLUGIN,VERSION,AUTHOR)
  482. register_cvar("csstatsx_sql", VERSION, FCVAR_SERVER | FCVAR_SPONLY | FCVAR_UNLOGGED)
  483.  
  484. /*
  485. * хост mysql
  486. */
  487. cvar[CVAR_SQL_HOST] = register_cvar("csstats_sql_host","127.0.0.1",FCVAR_UNLOGGED|FCVAR_PROTECTED)
  488.  
  489. /*
  490. * пользователь mysql
  491. */
  492. cvar[CVAR_SQL_USER] = register_cvar("csstats_sql_user","root",FCVAR_UNLOGGED|FCVAR_PROTECTED)
  493.  
  494. /*
  495. * пароль mysql
  496. */
  497. cvar[CVAR_SQL_PASS] = register_cvar("csstats_sql_pass","pass",FCVAR_UNLOGGED|FCVAR_PROTECTED)
  498.  
  499. /*
  500. * название БД mysql или sqlite
  501. */
  502. cvar[CVAR_SQL_DB] = register_cvar("csstats_sql_db","db",FCVAR_UNLOGGED|FCVAR_PROTECTED)
  503.  
  504. /*
  505. * название таблицы в БД
  506. */
  507. cvar[CVAR_SQL_TABLE] = register_cvar("csstats_sql_table","csstats",FCVAR_UNLOGGED|FCVAR_PROTECTED)
  508.  
  509. /*
  510. * тип бд
  511. * mysql - база данных MySQL
  512. * sqlite - локальная база данных SQLite
  513. */
  514. cvar[CVAR_SQL_TYPE] = register_cvar("csstats_sql_type","mysql")
  515.  
  516. /*
  517. * отправка запроса на создание таблицы
  518. * 0 - не отправлять запрос
  519. * 1 - отправлять запрос при загрузке карты
  520. */
  521. cvar[CVAR_SQL_CREATE_DB] = register_cvar("csstats_sql_create_db","1")
  522.  
  523. /*
  524. * как вести учет игроков
  525. * -1 - не учитывать
  526. * 0 - по нику
  527. * 1 - по steamid
  528. * 2 - по ip
  529. */
  530. cvar[CVAR_RANK] = get_cvar_pointer("csstats_rank")
  531.  
  532. if(!cvar[CVAR_RANK])
  533. cvar[CVAR_RANK] = register_cvar("csstats_rank","1")
  534.  
  535. /*
  536. * запись статистики ботов
  537. * 0 - не записывать
  538. * 1 - записывать0
  539. */
  540. cvar[CVAR_RANKBOTS] = get_cvar_pointer("csstats_rankbots")
  541.  
  542. if(!cvar[CVAR_RANKBOTS])
  543. cvar[CVAR_RANKBOTS] = register_cvar("csstats_rankbots","1")
  544.  
  545. /*
  546. * как обновлять статистику игрока в БД
  547. * -2 - при смерти и дисконнекте
  548. * -1 - в конце раунда и дисконнекте
  549. * 0 - при дисконнекте
  550. * значение больше 0 - через указанное кол-во секунд и дисконнекте
  551. */
  552. cvar[CVAR_UPDATESTYLE] = register_cvar("csstats_sql_update","10")
  553.  
  554. /*
  555. * включить собственные форварды для client_death, client_damage
  556. * 0 - выключить
  557. * 1 - включить, небоходимо, если csstats_sql используется в качестве замены модуля
  558. */
  559. cvar[CVAR_USEFORWARDS] = register_cvar("csstats_sql_forwards","0")
  560.  
  561. /*
  562. * формула расчета ранга
  563. * 0 - убйиства - смерти - тк
  564. * 1 - убийства
  565. * 2 - убийства + хедшоты
  566. * 3 - скилл
  567. * 4 - время онлайн
  568. */
  569. cvar[CVAR_RANKFORMULA] = register_cvar("csstats_sql_rankformula","0")
  570.  
  571. /*
  572. * формула расчета скилла
  573. * 0 - The ELO Method (http://fastcup.net/rating.html)
  574. */
  575. cvar[CVAR_SKILLFORMULA] = register_cvar("csstats_sql_skillformula","0")
  576.  
  577. // 0.7
  578.  
  579. /*
  580. * ведение статистики по оружию
  581. */
  582. cvar[CVAR_WEAPONSTATS] = register_cvar("csstats_sql_weapons","1")
  583.  
  584. /*
  585. * ведение статистики по картам
  586. */
  587. cvar[CVAR_MAPSTATS] = register_cvar("csstats_sql_maps","0")
  588.  
  589. /*
  590. * автоматическое удаление неактвиных игроков в БД
  591. */
  592. cvar[CVAR_AUTOCLEAR] = register_cvar("csstats_sql_autoclear","0")
  593.  
  594. /*
  595. * использование кеша для get_stats
  596. * -1 - обновлять в конце раунда или по времени csstats_sql_update
  597. * 0 - отключить использование кеша
  598. */
  599. cvar[CVAR_CACHETIME] = register_cvar("csstats_sql_cachetime","-1")
  600.  
  601. /*
  602. * автоматическая очистка всей игровой статистики в БД в определенный день
  603. */
  604. cvar[CVAR_AUTOCLEAR_DAY] = register_cvar("csstats_sql_autoclear_day","0")
  605.  
  606. /*
  607. * урон для засчитывания ассиста
  608. */
  609. cvar[CVAR_ASSISTHP] = register_cvar("csstats_sql_assisthp","50")
  610.  
  611. #if AMXX_VERSION_NUM < 183
  612. MaxClients = get_maxplayers()
  613. #endif
  614. }
  615.  
  616. public plugin_init()
  617. {
  618.  
  619. register_logevent("LogEventHooK_RoundEnd", 2, "1=Round_End")
  620. register_logevent("LogEventHooK_RoundStart", 2, "1=Round_Start")
  621.  
  622. register_event("CurWeapon","EventHook_CurWeapon","b","1=1")
  623. register_event("Damage","EventHook_Damage","b","2!0")
  624. register_event("BarTime","EventHook_BarTime","be")
  625. register_event("SendAudio","EventHook_SendAudio","a")
  626. register_event("TextMsg","EventHook_TextMsg","a")
  627.  
  628. register_srvcmd("csstats_sql_reset","SrvCmd_DBReset")
  629.  
  630. new weapon_info[WEAPON_INFO_SIZE]
  631.  
  632. //
  633. log_ids_trie = TrieCreate()
  634. // is_meele + название + логнейм
  635. weapons_data = ArrayCreate(WEAPON_INFO_SIZE)
  636.  
  637. REG_INFO(false,"","")
  638. REG_INFO(false,"p228","p228")
  639. REG_INFO(false,"","")
  640. REG_INFO(false,"scout","scout")
  641. REG_INFO(false,"hegrenade","grenade")
  642. REG_INFO(false,"xm1014","xm1014")
  643. REG_INFO(false,"c4","weapon_c4")
  644. REG_INFO(false,"mac10","mac10")
  645. REG_INFO(false,"aug","aug")
  646. REG_INFO(false,"sgrenade","grenade")
  647. REG_INFO(false,"elite","elite")
  648. REG_INFO(false,"fiveseven","fiveseven")
  649. REG_INFO(false,"ump45","ump45")
  650. REG_INFO(false,"sg550","sg550")
  651. REG_INFO(false,"galil","galil")
  652. REG_INFO(false,"famas","famas")
  653. REG_INFO(false,"usp","usp")
  654. REG_INFO(false,"glock18","glock18")
  655. REG_INFO(false,"awp","awp")
  656. REG_INFO(false,"mp5navy","mp5navy")
  657. REG_INFO(false,"m249","m249")
  658. REG_INFO(false,"m3","m3")
  659. REG_INFO(false,"m4a1","m4a1")
  660. REG_INFO(false,"tmp","tmp")
  661. REG_INFO(false,"g3sg1","g3sg1")
  662. REG_INFO(false,"flashbang","flashbang")
  663. REG_INFO(false,"deagle","deagle")
  664. REG_INFO(false,"sg552","sg552")
  665. REG_INFO(false,"ak47","ak47")
  666. REG_INFO(true,"knife","knife")
  667. REG_INFO(false,"p90","p90")
  668.  
  669. RegisterHam(Ham_Spawn,"player","HamHook_PlayerSpawn",true)
  670. }
  671.  
  672. #if AMXX_VERSION_NUM < 183
  673. public plugin_cfg()
  674. #else
  675. public OnAutoConfigsBuffered()
  676. #endif
  677. {
  678. #if AMXX_VERSION_NUM < 183
  679. // форсируем выполнение exec addons/amxmodx/configs/amxx.cfg
  680. server_exec()
  681. #endif
  682.  
  683. // читаем квары на подключение
  684. new host[128],user[64],pass[64],db[64],type[10]
  685. get_pcvar_string(cvar[CVAR_SQL_HOST],host,charsmax(host))
  686. get_pcvar_string(cvar[CVAR_SQL_USER],user,charsmax(user))
  687. get_pcvar_string(cvar[CVAR_SQL_PASS],pass,charsmax(pass))
  688. get_pcvar_string(cvar[CVAR_SQL_DB],db,charsmax(db))
  689. get_pcvar_string(cvar[CVAR_SQL_TABLE],tbl_name,charsmax(tbl_name))
  690. get_pcvar_string(cvar[CVAR_SQL_TYPE],type,charsmax(type))
  691.  
  692. // и снова здравствуй wopox3
  693. if(!SQL_SetAffinity(type))
  694. {
  695. new error_msg[128]
  696. formatex(error_msg,charsmax(error_msg),"failed to use ^"%s^" for db driver",
  697. error_msg)
  698.  
  699. set_fail_state(error_msg)
  700.  
  701. return
  702. }
  703.  
  704. sql = SQL_MakeDbTuple(host,user,pass,db)
  705.  
  706. // для поддержки utf8 ников требуется AMXX 1.8.3-dev-git3799 или выше
  707.  
  708. #if AMXX_VERSION_NUM >= 183
  709. SQL_SetCharset(sql,"utf8")
  710. #endif
  711.  
  712. weapon_stats_enabled = get_pcvar_num(cvar[CVAR_WEAPONSTATS]) == 1 ? true : false
  713. map_stats_enabled = get_pcvar_num(cvar[CVAR_MAPSTATS]) == 1 ? true : false
  714.  
  715. new query[QUERY_LENGTH * 2],que_len
  716.  
  717. new sql_data[1]
  718. sql_data[0] = SQL_INITDB
  719.  
  720. // запрос на создание таблицы
  721. if(get_pcvar_num(cvar[CVAR_SQL_CREATE_DB]))
  722. {
  723. // запрос для mysql
  724. if(strcmp(type,"mysql") == 0)
  725. {
  726. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  727. CREATE TABLE IF NOT EXISTS `%s` (\
  728. `%s` int(11) NOT NULL AUTO_INCREMENT,\
  729. `%s` varchar(30) NOT NULL,\
  730. `%s` varchar(32) NOT NULL,\
  731. `%s` varchar(16) NOT NULL,\
  732. `%s` float NOT NULL DEFAULT '0.0',\
  733. `%s` int(11) NOT NULL DEFAULT '0',\
  734. `%s` int(11) NOT NULL DEFAULT '0',\
  735. `%s` int(11) NOT NULL DEFAULT '0',",
  736.  
  737. tbl_name,
  738.  
  739. row_names[ROW_ID],
  740. row_names[ROW_STEAMID],
  741. row_names[ROW_NAME],
  742. row_names[ROW_IP],
  743. row_names[ROW_SKILL],
  744. row_names[ROW_KILLS],
  745. row_names[ROW_DEATHS],
  746. row_names[ROW_HS]
  747. )
  748.  
  749. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` int(11) NOT NULL DEFAULT '0',\
  750. `%s` int(11) NOT NULL DEFAULT '0',\
  751. `%s` int(11) NOT NULL DEFAULT '0',\
  752. `%s` int(11) NOT NULL DEFAULT '0',\
  753. `%s` int(11) NOT NULL DEFAULT '0',\
  754. `%s` int(11) NOT NULL DEFAULT '0',\
  755. `%s` int(11) NOT NULL DEFAULT '0',\
  756. `%s` int(11) NOT NULL DEFAULT '0',\
  757. `%s` int(11) NOT NULL DEFAULT '0',",
  758.  
  759. row_names[ROW_TKS],
  760. row_names[ROW_SHOTS],
  761. row_names[ROW_HITS],
  762. row_names[ROW_DMG],
  763. row_names[ROW_BOMBDEF],
  764. row_names[ROW_BOMBDEFUSED],
  765. row_names[ROW_BOMBPLANTS],
  766. row_names[ROW_BOMBEXPLOSIONS],
  767. row_names[ROW_H0]
  768. )
  769.  
  770. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` int(11) NOT NULL DEFAULT '0',\
  771. `%s` int(11) NOT NULL DEFAULT '0',\
  772. `%s` int(11) NOT NULL DEFAULT '0',\
  773. `%s` int(11) NOT NULL DEFAULT '0',\
  774. `%s` int(11) NOT NULL DEFAULT '0',\
  775. `%s` int(11) NOT NULL DEFAULT '0',\
  776. `%s` int(11) NOT NULL DEFAULT '0',\
  777. `%s` int(11) NOT NULL DEFAULT '0',",
  778.  
  779. row_names[ROW_H1],
  780. row_names[ROW_H2],
  781. row_names[ROW_H3],
  782. row_names[ROW_H4],
  783. row_names[ROW_H5],
  784. row_names[ROW_H6],
  785. row_names[ROW_H7],
  786. row_names[ROW_ONLINETIME]
  787. )
  788.  
  789. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` int(11) NOT NULL DEFAULT '0',\
  790. `%s` int(11) NOT NULL DEFAULT '0',\
  791. `%s` int(11) NOT NULL DEFAULT '0',\
  792. `%s` int(11) NOT NULL DEFAULT '0',\
  793. `%s` int(11) NOT NULL DEFAULT '0',\
  794. `%s` int(11) NOT NULL DEFAULT '0',",
  795.  
  796. row_names[ROW_CONNECTS],
  797. row_names[ROW_ROUNDT],
  798. row_names[ROW_WINT],
  799. row_names[ROW_ROUNDCT],
  800. row_names[ROW_WINCT],
  801. row_names[ROW_ASSISTS]
  802. )
  803.  
  804. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,\
  805. `%s` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',\
  806. `%s` int(11) DEFAULT NULL,\
  807. `%s` varchar(32) DEFAULT NULL,\
  808. PRIMARY KEY (%s),\
  809. KEY `%s` (`%s`(16)),\
  810. KEY `%s` (`%s`(16)),\
  811. KEY `%s` (`%s`)\
  812. ) DEFAULT CHARSET=utf8 AUTO_INCREMENT=1;",
  813.  
  814. row_names[ROW_FIRSTJOIN],
  815. row_names[ROW_LASTJOIN],
  816.  
  817. row_names[ROW_SESSIONID],
  818. row_names[ROW_SESSIONNAME],
  819.  
  820. row_names[ROW_ID],
  821. row_names[ROW_STEAMID],row_names[ROW_STEAMID],
  822. row_names[ROW_NAME],row_names[ROW_NAME],
  823. row_names[ROW_IP],row_names[ROW_IP]
  824. )
  825. }
  826. // запрос для sqlite
  827. else if(strcmp(type,"sqlite") == 0)
  828. {
  829. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  830. CREATE TABLE IF NOT EXISTS `%s` (\
  831. `%s` INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,\
  832. `%s` TEXT NOT NULL,\
  833. `%s` TEXT NOT NULL,\
  834. `%s` TEXT NOT NULL,\
  835. `%s` REAL NOT NULL DEFAULT 0.0,\
  836. `%s` INTEGER NOT NULL DEFAULT 0,\
  837. `%s` INTEGER NOT NULL DEFAULT 0,",
  838.  
  839. tbl_name,
  840.  
  841. row_names[ROW_ID],
  842. row_names[ROW_STEAMID],
  843. row_names[ROW_NAME],
  844. row_names[ROW_IP],
  845. row_names[ROW_SKILL],
  846. row_names[ROW_KILLS],
  847. row_names[ROW_DEATHS]
  848. )
  849.  
  850. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` INTEGER NOT NULL DEFAULT 0,\
  851. `%s` INTEGER NOT NULL DEFAULT 0,\
  852. `%s` INTEGER NOT NULL DEFAULT 0,\
  853. `%s` INTEGER NOT NULL DEFAULT 0,\
  854. `%s` INTEGER NOT NULL DEFAULT 0,\
  855. `%s` INTEGER NOT NULL DEFAULT 0,\
  856. `%s` INTEGER NOT NULL DEFAULT 0,\
  857. `%s` INTEGER NOT NULL DEFAULT 0,\
  858. `%s` INTEGER NOT NULL DEFAULT 0,",
  859.  
  860. row_names[ROW_HS],
  861. row_names[ROW_TKS],
  862. row_names[ROW_SHOTS],
  863. row_names[ROW_HITS],
  864. row_names[ROW_DMG],
  865. row_names[ROW_BOMBDEF],
  866. row_names[ROW_BOMBDEFUSED],
  867. row_names[ROW_BOMBPLANTS],
  868. row_names[ROW_BOMBEXPLOSIONS]
  869. )
  870.  
  871. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` INTEGER NOT NULL DEFAULT 0,\
  872. `%s` INTEGER NOT NULL DEFAULT 0,\
  873. `%s` INTEGER NOT NULL DEFAULT 0,\
  874. `%s` INTEGER NOT NULL DEFAULT 0,\
  875. `%s` INTEGER NOT NULL DEFAULT 0,\
  876. `%s` INTEGER NOT NULL DEFAULT 0,\
  877. `%s` INTEGER NOT NULL DEFAULT 0,\
  878. `%s` INTEGER NOT NULL DEFAULT 0,",
  879.  
  880. row_names[ROW_H0],
  881. row_names[ROW_H1],
  882. row_names[ROW_H2],
  883. row_names[ROW_H3],
  884. row_names[ROW_H4],
  885. row_names[ROW_H5],
  886. row_names[ROW_H6],
  887. row_names[ROW_H7]
  888. )
  889.  
  890. // 0.7
  891.  
  892. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` INTEGER NOT NULL DEFAULT 0,\
  893. `%s` INTEGER NOT NULL DEFAULT 0,\
  894. `%s` INTEGER NOT NULL DEFAULT 0,\
  895. `%s` INTEGER NOT NULL DEFAULT 0,\
  896. `%s` INTEGER NOT NULL DEFAULT 0,\
  897. `%s` INTEGER NOT NULL DEFAULT 0,\
  898. `%s` INTEGER NOT NULL DEFAULT 0,",
  899.  
  900. row_names[ROW_ONLINETIME],
  901. row_names[ROW_CONNECTS],
  902. row_names[ROW_ROUNDT],
  903. row_names[ROW_WINT],
  904. row_names[ROW_ROUNDCT],
  905. row_names[ROW_WINCT],
  906. row_names[ROW_ASSISTS]
  907. )
  908.  
  909. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,\
  910. `%s` TIMESTAMP NOT NULL DEFAULT '0000-00-00 00:00:00',\
  911. `%s` INTEGER,\
  912. `%s` TEXT\
  913. );",
  914.  
  915. row_names[ROW_FIRSTJOIN],
  916. row_names[ROW_LASTJOIN],
  917. row_names[ROW_SESSIONID],
  918. row_names[ROW_SESSIONNAME]
  919. )
  920. }
  921. else
  922. {
  923. set_fail_state("invalid ^"csstats_sql_type^" cvar value")
  924. }
  925.  
  926. DB_AddInitSeq()
  927. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,sizeof sql_data)
  928.  
  929. if(weapon_stats_enabled)
  930. {
  931. que_len = 0
  932.  
  933. // запрос для mysql
  934. if(strcmp(type,"mysql") == 0)
  935. {
  936. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  937. CREATE TABLE IF NOT EXISTS `%s_weapons` (\
  938. `%s` int(11) NOT NULL AUTO_INCREMENT,\
  939. `%s` int(11) NOT NULL,\
  940. `%s` varchar(32) NOT NULL,\
  941. `%s` int(11) NOT NULL DEFAULT '0',\
  942. `%s` int(11) NOT NULL DEFAULT '0',\
  943. `%s` int(11) NOT NULL DEFAULT '0',",
  944.  
  945. tbl_name,
  946. row_weapons_names[ROW_WEAPON_ID],
  947. row_weapons_names[ROW_WEAPON_PLAYER],
  948. row_weapons_names[ROW_WEAPON_NAME],
  949. row_weapons_names[ROW_WEAPON_KILLS],
  950. row_weapons_names[ROW_WEAPON_DEATHS],
  951. row_weapons_names[ROW_WEAPON_HS]
  952. )
  953. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` int(11) NOT NULL DEFAULT '0',\
  954. `%s` int(11) NOT NULL DEFAULT '0',\
  955. `%s` int(11) NOT NULL DEFAULT '0',\
  956. `%s` int(11) NOT NULL DEFAULT '0',",
  957.  
  958. row_weapons_names[ROW_WEAPON_TKS],
  959. row_weapons_names[ROW_WEAPON_SHOTS],
  960. row_weapons_names[ROW_WEAPON_HITS],
  961. row_weapons_names[ROW_WEAPON_DMG]
  962. )
  963. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` int(11) NOT NULL DEFAULT '0',\
  964. `%s` int(11) NOT NULL DEFAULT '0',\
  965. `%s` int(11) NOT NULL DEFAULT '0',\
  966. `%s` int(11) NOT NULL DEFAULT '0',\
  967. `%s` int(11) NOT NULL DEFAULT '0',\
  968. `%s` int(11) NOT NULL DEFAULT '0',\
  969. `%s` int(11) NOT NULL DEFAULT '0',\
  970. `%s` int(11) NOT NULL DEFAULT '0',",
  971.  
  972. row_weapons_names[ROW_WEAPON_H0],
  973. row_weapons_names[ROW_WEAPON_H1],
  974. row_weapons_names[ROW_WEAPON_H2],
  975. row_weapons_names[ROW_WEAPON_H3],
  976. row_weapons_names[ROW_WEAPON_H4],
  977. row_weapons_names[ROW_WEAPON_H5],
  978. row_weapons_names[ROW_WEAPON_H6],
  979. row_weapons_names[ROW_WEAPON_H7]
  980. )
  981. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  982. PRIMARY KEY (%s),\
  983. KEY `%s` (`%s`(16))\
  984. ) DEFAULT CHARSET=utf8 AUTO_INCREMENT=1;",
  985.  
  986. row_weapons_names[ROW_WEAPON_ID],
  987. row_weapons_names[ROW_WEAPON_NAME],
  988. row_weapons_names[ROW_WEAPON_NAME]
  989. )
  990. }
  991. // запрос для sqlite
  992. else if(strcmp(type,"sqlite") == 0)
  993. {
  994. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  995. CREATE TABLE IF NOT EXISTS `%s_weapons` (\
  996. `%s` INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,\
  997. `%s` INTEGER NOT NULL,\
  998. `%s` TEXT NOT NULL,\
  999. `%s` INTEGER NOT NULL DEFAULT 0,\
  1000. `%s` INTEGER NOT NULL DEFAULT 0,",
  1001.  
  1002. tbl_name,
  1003. row_weapons_names[ROW_WEAPON_ID],
  1004. row_weapons_names[ROW_WEAPON_PLAYER],
  1005. row_weapons_names[ROW_WEAPON_NAME],
  1006. row_weapons_names[ROW_WEAPON_KILLS],
  1007. row_weapons_names[ROW_WEAPON_DEATHS]
  1008. )
  1009. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` INTEGER NOT NULL DEFAULT 0,\
  1010. `%s` INTEGER NOT NULL DEFAULT 0,\
  1011. `%s` INTEGER NOT NULL DEFAULT 0,\
  1012. `%s` INTEGER NOT NULL DEFAULT 0,\
  1013. `%s` INTEGER NOT NULL DEFAULT 0,",
  1014.  
  1015. row_weapons_names[ROW_WEAPON_HS],
  1016. row_weapons_names[ROW_WEAPON_TKS],
  1017. row_weapons_names[ROW_WEAPON_SHOTS],
  1018. row_weapons_names[ROW_WEAPON_HITS],
  1019. row_weapons_names[ROW_WEAPON_DMG]
  1020. )
  1021. que_len += formatex(query[que_len],charsmax(query) - que_len,"`%s` INTEGER NOT NULL DEFAULT 0,\
  1022. `%s` INTEGER NOT NULL DEFAULT 0,\
  1023. `%s` INTEGER NOT NULL DEFAULT 0,\
  1024. `%s` INTEGER NOT NULL DEFAULT 0,\
  1025. `%s` INTEGER NOT NULL DEFAULT 0,\
  1026. `%s` INTEGER NOT NULL DEFAULT 0,\
  1027. `%s` INTEGER NOT NULL DEFAULT 0,\
  1028. `%s` INTEGER NOT NULL DEFAULT 0",
  1029.  
  1030. row_weapons_names[ROW_WEAPON_H0],
  1031. row_weapons_names[ROW_WEAPON_H1],
  1032. row_weapons_names[ROW_WEAPON_H2],
  1033. row_weapons_names[ROW_WEAPON_H3],
  1034. row_weapons_names[ROW_WEAPON_H4],
  1035. row_weapons_names[ROW_WEAPON_H5],
  1036. row_weapons_names[ROW_WEAPON_H6],
  1037. row_weapons_names[ROW_WEAPON_H7]
  1038. )
  1039. que_len += formatex(query[que_len],charsmax(query) - que_len,");")
  1040. }
  1041. else
  1042. {
  1043. set_fail_state("invalid ^"csstats_sql_type^" cvar value")
  1044. }
  1045.  
  1046. if(que_len)
  1047. {
  1048. DB_AddInitSeq()
  1049. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,sizeof sql_data)
  1050. }
  1051. }
  1052. }
  1053.  
  1054. DB_AutoClearOpt()
  1055.  
  1056. // обновление статистики в БД каждые n сек
  1057. if(get_pcvar_num(cvar[CVAR_UPDATESTYLE]) > 0)
  1058. {
  1059. set_task(
  1060. float(get_pcvar_num(cvar[CVAR_UPDATESTYLE])),
  1061. "DB_SaveAll",
  1062. .flags = "b"
  1063. )
  1064. }
  1065.  
  1066. if(get_pcvar_num(cvar[CVAR_USEFORWARDS]))
  1067. {
  1068. FW_Death = CreateMultiForward("client_death",ET_IGNORE,FP_CELL,FP_CELL,FP_CELL,FP_CELL,FP_CELL)
  1069. FW_Damage = CreateMultiForward("client_damage",ET_IGNORE,FP_CELL,FP_CELL,FP_CELL,FP_CELL,FP_CELL,FP_CELL)
  1070. FW_BPlanting = CreateMultiForward("bomb_planting",ET_IGNORE,FP_CELL)
  1071. FW_BPlanted = CreateMultiForward("bomb_planted",ET_IGNORE,FP_CELL)
  1072. FW_BExplode = CreateMultiForward("bomb_explode",ET_IGNORE,FP_CELL,FP_CELL)
  1073. FW_BDefusing = CreateMultiForward("bomb_defusing",ET_IGNORE,FP_CELL)
  1074. FW_BDefused = CreateMultiForward("bomb_defused",ET_IGNORE,FP_CELL)
  1075. FW_GThrow = CreateMultiForward("grenade_throw",ET_IGNORE,FP_CELL,FP_CELL,FP_CELL)
  1076.  
  1077. register_forward(FM_SetModel,"FMHook_SetModel",true)
  1078. }
  1079.  
  1080. // 0.7.2
  1081. FW_Assist = CreateMultiForward("client_assist_sql",ET_IGNORE,FP_CELL,FP_CELL,FP_CELL)
  1082.  
  1083. // 0.7.3
  1084. FW_Initialized = CreateMultiForward("csxsql_initialized",ET_IGNORE)
  1085.  
  1086. // 0.7
  1087.  
  1088. //
  1089. // запрос на получение ID сессии статистики за карту
  1090. //
  1091. if(map_stats_enabled)
  1092. {
  1093. new query[128],sql_data[1] = SQL_GETSESSID
  1094.  
  1095. formatex(query,charsmax(query),"SELECT MAX(`session_id`) FROM `%s_maps`",
  1096. tbl_name
  1097. )
  1098.  
  1099. DB_AddInitSeq()
  1100. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,sizeof sql_data)
  1101. }
  1102.  
  1103. // защита от ретардов, которые не читаю README
  1104. if(
  1105. (get_pcvar_num(cvar[CVAR_UPDATESTYLE]) == -2) ||
  1106. (get_pcvar_num(cvar[CVAR_UPDATESTYLE]) == 0)
  1107. )
  1108. {
  1109. // выключаем кеширование
  1110. set_pcvar_num(cvar[CVAR_CACHETIME],0)
  1111. }
  1112.  
  1113. DB_InitSeq()
  1114. }
  1115.  
  1116. //
  1117. // последовательность перед началом работы плагина
  1118. //
  1119. DB_AddInitSeq()
  1120. {
  1121. init_seq --
  1122. }
  1123.  
  1124. //
  1125. // проверяем выполнение последовательности инициализации
  1126. //
  1127. DB_InitSeq()
  1128. {
  1129. if(init_seq ==0)
  1130. {
  1131. log_amx("!?!?!?!?!?")
  1132. return
  1133. }
  1134.  
  1135. init_seq ++
  1136.  
  1137. // все выполнено, начинаем работу
  1138. if(init_seq == 0)
  1139. {
  1140. ExecuteForward(FW_Initialized,dummy_ret)
  1141. }
  1142. }
  1143.  
  1144. //
  1145. // Функция очистки БД от неактивных игроков
  1146. //
  1147. DB_AutoClearOpt()
  1148. {
  1149. // 0.7
  1150. new autoclear_days = get_pcvar_num(cvar[CVAR_AUTOCLEAR])
  1151.  
  1152. if(autoclear_days > 0)
  1153. {
  1154. DB_ClearTables(autoclear_days)
  1155. }
  1156.  
  1157. // полные сброс статистики в определенный день
  1158. autoclear_days = get_pcvar_num(cvar[CVAR_AUTOCLEAR_DAY])
  1159.  
  1160. if(autoclear_days > 0)
  1161. {
  1162. new s_data[10]
  1163. get_time("%d",s_data,charsmax(s_data))
  1164.  
  1165. if(str_to_num(s_data) == autoclear_days)
  1166. {
  1167. s_data[0] = 0
  1168. get_vaultdata("csxsql_clear",s_data,charsmax(s_data))
  1169.  
  1170. // проверяем не было ли сброса
  1171. if(!str_to_num(s_data))
  1172. {
  1173. set_vaultdata("csxsql_clear","1")
  1174. DB_ClearTables(-1)
  1175. }
  1176. }
  1177. /// очищяем проверку на сброс
  1178. else
  1179. {
  1180. set_vaultdata("csxsql_clear","0")
  1181. }
  1182. }
  1183. }
  1184.  
  1185. //
  1186. // Начало работы с БД
  1187. //
  1188. public csxsql_initialized()
  1189. {
  1190. is_ready = true
  1191.  
  1192. new players[MAX_PLAYERS],pnum
  1193. get_players(players,pnum)
  1194.  
  1195. // загружаем стату игроков
  1196. for(new i ; i < pnum ; i++)
  1197. {
  1198. client_putinserver(players[i])
  1199. }
  1200. }
  1201.  
  1202. public SrvCmd_DBReset()
  1203. {
  1204. DB_ClearTables(-1)
  1205. }
  1206.  
  1207. //
  1208. // Очистка таблиц от неактивных записей
  1209. //
  1210. DB_ClearTables(by_days)
  1211. {
  1212. if(by_days == -1)
  1213. {
  1214. log_amx("database reset")
  1215. }
  1216.  
  1217. new query[QUERY_LENGTH],que_len
  1218.  
  1219. new type[10]
  1220. get_pcvar_string(cvar[CVAR_SQL_TYPE],type,charsmax(type))
  1221.  
  1222. if(strcmp(type,"mysql") == 0)
  1223. {
  1224. que_len += formatex(query[que_len],charsmax(query) - que_len,"DELETE `%s`",
  1225. tbl_name
  1226. )
  1227.  
  1228. if(weapon_stats_enabled)
  1229. {
  1230. que_len += formatex(query[que_len],charsmax(query) - que_len,",`%s_weapons`",tbl_name)
  1231. }
  1232.  
  1233. if(map_stats_enabled)
  1234. {
  1235. que_len += formatex(query[que_len],charsmax(query) - que_len,",`%s_maps`",tbl_name)
  1236. }
  1237.  
  1238. que_len += formatex(query[que_len],charsmax(query) - que_len," FROM `%s`",
  1239. tbl_name
  1240. )
  1241.  
  1242. if(weapon_stats_enabled)
  1243. {
  1244. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  1245. LEFT JOIN `%s_weapons` ON `%s`.`%s` = `%s_weapons`.`%s`",
  1246. tbl_name,
  1247. tbl_name,row_names[ROW_ID],
  1248. tbl_name,row_weapons_names[ROW_WEAPON_PLAYER]
  1249. )
  1250. }
  1251.  
  1252. if(map_stats_enabled)
  1253. {
  1254. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  1255. LEFT JOIN `%s_maps` ON `%s`.`%s` = `%s_maps`.`%s`",
  1256. tbl_name,
  1257. tbl_name,row_names[ROW_ID],
  1258. tbl_name,row_weapons_names[ROW_WEAPON_PLAYER]
  1259. )
  1260. }
  1261.  
  1262. if(by_days > 0)
  1263. {
  1264. que_len += formatex(query[que_len],charsmax(query) - que_len,"WHERE `%s`.`%s` <= DATE_SUB(NOW(),INTERVAL %d DAY);",
  1265. tbl_name,row_names[ROW_LASTJOIN],by_days
  1266. )
  1267. }
  1268. else
  1269. {
  1270. que_len += formatex(query[que_len],charsmax(query) - que_len,"WHERE 1")
  1271. }
  1272. }
  1273. else if(strcmp(type,"sqlite") == 0)
  1274. {
  1275. if(weapon_stats_enabled)
  1276. {
  1277. if(by_days > 0)
  1278. {
  1279. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  1280. DELETE FROM `%s_weapons` WHERE `%s` IN (\
  1281. SELECT `%s` FROM `%s` WHERE `%s` <= DATETIME('now','-%d day')\
  1282. );",
  1283. tbl_name,row_weapons_names[ROW_WEAPON_PLAYER],
  1284. row_names[ROW_ID],tbl_name,row_names[ROW_LASTJOIN],
  1285. by_days
  1286. )
  1287. }
  1288. else
  1289. {
  1290. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  1291. DELETE FROM `%s_weapons` WHERE `%s` IN (\
  1292. SELECT `%s` FROM `%s` WHERE 1\
  1293. );",
  1294. tbl_name,row_weapons_names[ROW_WEAPON_PLAYER],
  1295. row_names[ROW_ID],tbl_name
  1296. )
  1297. }
  1298. }
  1299.  
  1300. if(map_stats_enabled)
  1301. {
  1302. if(by_days > 0)
  1303. {
  1304. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  1305. DELETE FROM `%s_maps` WHERE `%s` IN (\
  1306. SELECT `%s` FROM `%s` WHERE `%s` <= DATETIME('now','-%d day')\
  1307. );",
  1308. tbl_name,row_weapons_names[ROW_WEAPON_PLAYER],
  1309. row_names[ROW_ID],tbl_name,row_names[ROW_LASTJOIN],
  1310. by_days
  1311. )
  1312. }
  1313. else
  1314. {
  1315. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  1316. DELETE FROM `%s_maps` WHERE `%s` IN (\
  1317. SELECT `%s` FROM `%s` WHERE 1\
  1318. );",
  1319. tbl_name,row_weapons_names[ROW_WEAPON_PLAYER],
  1320. row_names[ROW_ID],tbl_name
  1321. )
  1322. }
  1323. }
  1324.  
  1325. if(by_days > 0)
  1326. {
  1327. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  1328. DELETE FROM `%s` WHERE `%s` <= DATETIME('now','-%d day');",
  1329. tbl_name,row_names[ROW_LASTJOIN],by_days
  1330. )
  1331. }
  1332. else
  1333. {
  1334. que_len += formatex(query[que_len],charsmax(query) - que_len,"\
  1335. DELETE FROM `%s` WHERE 1;",tbl_name
  1336. )
  1337. }
  1338. }
  1339.  
  1340. new sql_data[1]
  1341. sql_data[0] = SQL_AUTOCLEAR
  1342.  
  1343. DB_AddInitSeq()
  1344. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,sizeof sql_data)
  1345. }
  1346.  
  1347. public plugin_end()
  1348. {
  1349. // выполняем накопившиеся запросы при смене карты или выключении серваре
  1350. DB_FlushQuery()
  1351.  
  1352. SQL_FreeHandle(sql)
  1353.  
  1354. if(sql_con != Empty_Handle)
  1355. {
  1356. SQL_FreeHandle(sql_con)
  1357. }
  1358.  
  1359. if(stats_cache_trie)
  1360. {
  1361. TrieDestroy(stats_cache_trie)
  1362. }
  1363.  
  1364. TrieDestroy(log_ids_trie)
  1365. ArrayDestroy(weapons_data)
  1366. }
  1367.  
  1368. /*
  1369. * загружаем статистику при подключении
  1370. */
  1371. public client_putinserver(id)
  1372. {
  1373. // ждем начала работы с БД
  1374. if(!is_ready)
  1375. {
  1376. return PLUGIN_CONTINUE
  1377. }
  1378.  
  1379. reset_user_allstats(id)
  1380. reset_user_wstats(id)
  1381.  
  1382. arrayset(player_data[id],0,player_data_struct)
  1383.  
  1384. for(new wpn ; wpn < MAX_WEAPONS ; wpn ++)
  1385. {
  1386. arrayset(player_awstats[id][wpn],0,sizeof player_awstats[][])
  1387. }
  1388.  
  1389. DB_LoadPlayerData(id)
  1390.  
  1391. return PLUGIN_CONTINUE
  1392. }
  1393.  
  1394. /*
  1395. * сохраняем статистику при дисконнекте
  1396. */
  1397. #if AMXX_VERSION_NUM < 183
  1398. public client_disconnect(id)
  1399. #else
  1400. public client_disconnected(id)
  1401. #endif
  1402. {
  1403. DB_SavePlayerData(id)
  1404. }
  1405.  
  1406. public HamHook_PlayerSpawn(id)
  1407. {
  1408. reset_user_wstats(id)
  1409. }
  1410.  
  1411. //
  1412. // Регистрация выстрелов
  1413. //
  1414. public EventHook_CurWeapon(player)
  1415. {
  1416. #define LASTWEAPON 0 // id посл. оружия
  1417. #define LASTCLIP 1 // кол-во потронов посл. оружия
  1418.  
  1419. static event_tmp[MAX_PLAYERS + 1][LASTCLIP + 1] // помним послед
  1420. static weapon_id; weapon_id = read_data(2)
  1421. static clip_ammo; clip_ammo = read_data(3)
  1422.  
  1423. if(event_tmp[player][LASTWEAPON] != weapon_id) // оружие было изменено, запоминаем новое кол-во патронов
  1424. {
  1425. event_tmp[player][LASTWEAPON] = weapon_id
  1426. event_tmp[player][LASTCLIP] = clip_ammo
  1427. }
  1428. else if(event_tmp[player][LASTCLIP] > clip_ammo) // кол-во патронов в магазине уменьшилось, регистрируем выстрел
  1429. {
  1430. Stats_SaveShot(player,weapon_id)
  1431. event_tmp[player][LASTCLIP] = clip_ammo
  1432. }
  1433. }
  1434.  
  1435. //
  1436. // Регистрация попадания
  1437. //
  1438. public EventHook_Damage(player)
  1439. {
  1440. static damage_take;damage_take = read_data(2)
  1441. static dmg_inflictor;dmg_inflictor = pev(player,pev_dmg_inflictor)
  1442.  
  1443. if(pev_valid(dmg_inflictor) != 2)
  1444. {
  1445. return PLUGIN_CONTINUE
  1446. }
  1447.  
  1448. if(!(0 < dmg_inflictor <= MaxClients))
  1449. {
  1450. // урон с гранаты на данным момент не учитывается
  1451.  
  1452. return PLUGIN_CONTINUE
  1453. }
  1454.  
  1455. static weapon_id,last_hit,attacker
  1456. attacker = get_user_attacker(player,weapon_id,last_hit)
  1457.  
  1458. if(0 <= last_hit < HIT_END)
  1459. {
  1460. Stats_SaveHit(dmg_inflictor,player,damage_take,weapon_id,last_hit)
  1461. }
  1462.  
  1463. if(!is_user_alive(player))
  1464. {
  1465. if(is_user_connected(attacker))
  1466. {
  1467. Stats_SaveKill(attacker,player,weapon_id,last_hit)
  1468. }
  1469. }
  1470.  
  1471. return PLUGIN_CONTINUE
  1472. }
  1473.  
  1474. //
  1475. // Регистрация установки и дефьюза бомбы
  1476. //
  1477. public EventHook_BarTime(player)
  1478. {
  1479. new duration = read_data(1)
  1480.  
  1481. if(!duration)
  1482. {
  1483. return PLUGIN_CONTINUE
  1484. }
  1485.  
  1486. if(duration == 3)
  1487. {
  1488. g_planter = player
  1489. g_defuser = 0
  1490.  
  1491. if(FW_BPlanting)
  1492. ExecuteForward(FW_BPlanting,dummy_ret,player)
  1493. }
  1494. else
  1495. {
  1496. g_defuser = player
  1497.  
  1498. Stats_SaveBDefusing(player)
  1499. }
  1500.  
  1501. return PLUGIN_CONTINUE
  1502. }
  1503.  
  1504. public EventHook_SendAudio(player)
  1505. {
  1506. new audio_code[16]
  1507. read_data(2,audio_code,charsmax(audio_code))
  1508.  
  1509. if (!player && audio_code[7] == 'B')
  1510. {
  1511. if (audio_code[11]=='P' && g_planter)
  1512. {
  1513. Stats_SaveBPlanted(g_planter)
  1514. }
  1515. else if (audio_code[11] =='D' && g_defuser)
  1516. {
  1517. Stats_SaveBDefused(g_defuser)
  1518.  
  1519. Event_CTWin()
  1520. }
  1521. }
  1522. }
  1523.  
  1524. public EventHook_TextMsg(player)
  1525. {
  1526. new message[16]
  1527. read_data(2,message,charsmax(message))
  1528.  
  1529. if (!player)
  1530. {
  1531. // #Target_Bombed
  1532. if ((message[1]=='T' && message[8] == 'B') && g_planter)
  1533. {
  1534. Stats_SaveBExplode(g_planter)
  1535.  
  1536. g_planter = 0
  1537. g_defuser = 0
  1538.  
  1539. Event_TWin()
  1540. }
  1541. // #Terrorists_Win -- #Hostages_Not_R
  1542. else if(
  1543. (message[2] == 'e' && message[12] == 'W') ||
  1544. (message[1] == 'H' && message[14] == 'R')
  1545. )
  1546. {
  1547. Event_TWin()
  1548. }
  1549. // #Target_Saved -- #CTs_Win -- #All_Hostages_R
  1550. else if(
  1551. (message[1] == 'T' && message[8] == 'S') ||
  1552. (message[2] == 'T' && message[5] == 'W') ||
  1553. (message[1] == 'A' && message[14] == 'R')
  1554. )
  1555. {
  1556. Event_CTWin()
  1557. }
  1558.  
  1559. }
  1560. }
  1561.  
  1562. //
  1563. // Победа TERRORIST
  1564. //
  1565. Event_TWin()
  1566. {
  1567. new players[MAX_PLAYERS],pnum
  1568. get_players(players,pnum)
  1569.  
  1570. for(new i,player ; i < pnum ; i++)
  1571. {
  1572. player = players[i]
  1573.  
  1574. // считаем статистику побед по командам
  1575. if(player_data[player][PLAYER_STATS3][STATS3_CURRENTTEAM] == 1)
  1576. {
  1577. player_data[player][PLAYER_STATS3][STATS3_WINT] ++
  1578. }
  1579. }
  1580. }
  1581.  
  1582. //
  1583. // Победа CT
  1584. //
  1585. Event_CTWin()
  1586. {
  1587. new players[MAX_PLAYERS],pnum
  1588. get_players(players,pnum)
  1589.  
  1590. for(new i,player ; i < pnum ; i++)
  1591. {
  1592. player = players[i]
  1593.  
  1594. // считаем статистику побед по командам
  1595. if(player_data[player][PLAYER_STATS3][STATS3_CURRENTTEAM] == 2)
  1596. {
  1597. player_data[player][PLAYER_STATS3][STATS3_WINCT] ++
  1598. }
  1599. }
  1600. }
  1601.  
  1602. //
  1603. // Форвард grenade_throw
  1604. //
  1605. public FMHook_SetModel(ent,model[])
  1606. {
  1607. new owner = pev(ent,pev_owner)
  1608.  
  1609. new Float:dmg_time
  1610. pev(ent,pev_dmgtime,dmg_time)
  1611.  
  1612. if(dmg_time <= 0.0 || !is_user_connected(owner))
  1613. {
  1614. return FMRES_IGNORED
  1615. }
  1616.  
  1617. new classname[32]
  1618. pev(ent,pev_classname,classname,charsmax(classname))
  1619.  
  1620. if(strcmp(classname,"grenade") != 0) // реагируем только на гранаты
  1621. {
  1622. return FMRES_IGNORED
  1623. }
  1624.  
  1625. new wId
  1626.  
  1627. if(model[9] == 'h') // модель хеешки
  1628. {
  1629. wId = CSW_HEGRENADE
  1630. }
  1631. else if(model[9] == 'f') // модель флешки
  1632. {
  1633. wId = CSW_FLASHBANG
  1634. }
  1635. else if(model[9] == 's') // модель смока
  1636. {
  1637. wId = CSW_SMOKEGRENADE
  1638. }
  1639.  
  1640. ExecuteForward(FW_GThrow,dummy_ret,owner,ent,wId)
  1641.  
  1642. return FMRES_IGNORED
  1643. }
  1644.  
  1645. //
  1646. // Учет ассистов
  1647. //
  1648. Stats_SaveAssist(player,victim,assisted)
  1649. {
  1650. player_data[player][PLAYER_STATS3][STATS3_ASSIST] ++
  1651.  
  1652. ExecuteForward(FW_Assist,dummy_ret,player,victim,assisted)
  1653.  
  1654. return true
  1655. }
  1656.  
  1657. //
  1658. // Учет выстрелов
  1659. //
  1660. Stats_SaveShot(player,wpn_id)
  1661. {
  1662. player_wstats[player][0][STATS_SHOTS] ++
  1663. player_wstats[player][wpn_id][STATS_SHOTS] ++
  1664.  
  1665. player_wrstats[player][0][STATS_SHOTS] ++
  1666. player_wrstats[player][wpn_id][STATS_SHOTS] ++
  1667.  
  1668. return true
  1669. }
  1670.  
  1671. //
  1672. // Учет попадания
  1673. //
  1674. Stats_SaveHit(attacker,victim,damage,wpn_id,hit_place)
  1675. {
  1676. player_wstats[attacker][0][STATS_HITS] ++
  1677. player_wstats[attacker][0][STATS_DMG] += damage
  1678. player_wstats[attacker][0][hit_place + STATS_END] ++
  1679.  
  1680. player_wrstats[attacker][0][STATS_HITS] ++
  1681. player_wrstats[attacker][0][STATS_DMG] += damage
  1682. player_wrstats[attacker][0][hit_place + STATS_END] ++
  1683.  
  1684. player_wstats[attacker][wpn_id][STATS_DMG] += damage
  1685. player_wrstats[attacker][wpn_id][STATS_DMG] += damage
  1686. player_wstats[attacker][wpn_id][STATS_HITS] ++
  1687. player_wrstats[attacker][wpn_id][STATS_HITS] ++
  1688. player_wstats[attacker][wpn_id][hit_place + STATS_END] ++
  1689. player_wrstats[attacker][wpn_id][hit_place + STATS_END] ++
  1690.  
  1691. player_vstats[attacker][victim][STATS_HITS] ++
  1692. player_vstats[attacker][victim][STATS_DMG] += damage
  1693. player_vstats[attacker][victim][hit_place + STATS_END] ++
  1694. player_astats[victim][attacker][STATS_HITS] ++
  1695. player_astats[victim][attacker][STATS_DMG] += damage
  1696. player_astats[victim][attacker][hit_place + STATS_END] ++
  1697. player_vstats[attacker][0][STATS_HITS] ++
  1698. player_vstats[attacker][0][STATS_DMG] += damage
  1699. player_vstats[attacker][0][hit_place + STATS_END] ++
  1700. player_astats[victim][0][STATS_HITS] ++
  1701. player_astats[victim][0][STATS_DMG] += damage
  1702. player_astats[victim][0][hit_place + STATS_END] ++
  1703.  
  1704. // оружие, с которого убил для astats, vstats
  1705. new weapon_info[WEAPON_INFO_SIZE]
  1706. ArrayGetArray(weapons_data,wpn_id,weapon_info)
  1707.  
  1708. copy(player_vstats[attacker][victim][STATS_END + HIT_END],
  1709. MAX_NAME_LENGTH - 1,
  1710. weapon_info[1]
  1711. )
  1712.  
  1713. copy(player_astats[victim][attacker][STATS_END + HIT_END],
  1714. MAX_NAME_LENGTH - 1,
  1715. weapon_info[1]
  1716. )
  1717.  
  1718. if(FW_Damage)
  1719. ExecuteForward(FW_Damage,dummy_ret,attacker,victim,damage,wpn_id,hit_place,is_tk(attacker,victim))
  1720.  
  1721. return true
  1722. }
  1723.  
  1724. //
  1725. // Учет смертей
  1726. //
  1727. Stats_SaveKill(killer,victim,wpn_id,hit_place)
  1728. {
  1729. if(killer == victim) // не учитываем суицид
  1730. {
  1731. return false
  1732. }
  1733.  
  1734. if(!is_tk(killer,victim))
  1735. {
  1736. player_wstats[killer][0][STATS_KILLS] ++
  1737. player_wstats[killer][wpn_id][STATS_KILLS] ++
  1738.  
  1739. player_wrstats[killer][0][STATS_KILLS] ++
  1740. player_wrstats[killer][wpn_id][STATS_KILLS] ++
  1741.  
  1742. player_vstats[killer][victim][STATS_KILLS] ++
  1743. player_astats[victim][killer][STATS_KILLS] ++
  1744. player_vstats[killer][0][STATS_KILLS] ++
  1745. player_astats[victim][0][STATS_KILLS] ++
  1746.  
  1747. if(hit_place == HIT_HEAD)
  1748. {
  1749. player_wstats[killer][0][STATS_HS] ++
  1750. player_wstats[killer][wpn_id][STATS_HS] ++
  1751.  
  1752. player_wrstats[killer][0][STATS_HS] ++
  1753. player_wrstats[killer][wpn_id][STATS_HS] ++
  1754.  
  1755. player_vstats[killer][victim][STATS_HS] ++
  1756. player_astats[victim][killer][STATS_HS] ++
  1757. player_vstats[killer][0][STATS_HS] ++
  1758. player_astats[victim][0][STATS_HS] ++
  1759. }
  1760. }
  1761. else
  1762. {
  1763. player_wstats[killer][0][STATS_TK] ++
  1764. player_wstats[killer][wpn_id][STATS_TK] ++
  1765.  
  1766. player_wrstats[killer][0][STATS_TK] ++
  1767. player_wrstats[killer][wpn_id][STATS_TK] ++
  1768.  
  1769. player_vstats[killer][victim][STATS_TK] ++
  1770. player_astats[victim][killer][STATS_TK] ++
  1771. player_vstats[killer][0][STATS_TK] ++
  1772. player_astats[victim][0][STATS_TK] ++
  1773. }
  1774.  
  1775. player_wstats[victim][0][STATS_DEATHS] ++
  1776. player_wrstats[victim][0][STATS_DEATHS] ++
  1777.  
  1778. // смотрим ассисты
  1779. for(new i = 1,assist_hp = get_pcvar_num(cvar[CVAR_ASSISTHP]); (assist_hp) && (i <= MAX_PLAYERS) ; i++)
  1780. {
  1781. if(i == killer)
  1782. {
  1783. continue
  1784. }
  1785.  
  1786. if(player_astats[victim][i][STATS_DMG] >= assist_hp)
  1787. {
  1788. Stats_SaveAssist(i,victim,killer)
  1789. }
  1790. }
  1791.  
  1792. new victim_wpn_id = get_user_weapon(victim)
  1793.  
  1794. if(victim_wpn_id)
  1795. {
  1796. player_wstats[victim][victim_wpn_id][STATS_DEATHS] ++
  1797. player_wrstats[victim][victim_wpn_id][STATS_DEATHS] ++
  1798. }
  1799.  
  1800. if(FW_Death)
  1801. ExecuteForward(FW_Death,dummy_ret,killer,victim,wpn_id,hit_place,is_tk(killer,victim))
  1802.  
  1803. if(player_data[killer][PLAYER_LOADSTATE] == LOAD_OK && player_data[victim][PLAYER_LOADSTATE] == LOAD_OK) // скилл расчитывается только при наличии статистики из БД
  1804. {
  1805. switch(get_pcvar_num(cvar[CVAR_SKILLFORMULA])) // расчет скилла
  1806. {
  1807. case 0: // The ELO Method (http://fastcup.net/rating.html)
  1808. {
  1809. new Float:delta = 1.0 / (1.0 + floatpower(10.0,(player_data[killer][PLAYER_SKILL] - player_data[victim][PLAYER_SKILL]) / 100.0))
  1810. new Float:koeff = 0.0
  1811.  
  1812. if(player_data[killer][PLAYER_STATS][STATS_KILLS] < 100)
  1813. {
  1814. koeff = 2.0
  1815. }
  1816. else
  1817. {
  1818. koeff = 1.5
  1819. }
  1820.  
  1821. player_data[killer][PLAYER_SKILL] += (koeff * delta)
  1822. player_data[victim][PLAYER_SKILL] -= (koeff * delta)
  1823. }
  1824. }
  1825. }
  1826.  
  1827.  
  1828. // обновляем статистику в БД при смерти
  1829. if(get_pcvar_num(cvar[CVAR_UPDATESTYLE]) == -2)
  1830. {
  1831. DB_SavePlayerData(victim)
  1832. }
  1833.  
  1834.  
  1835.  
  1836. return true
  1837. }
  1838.  
  1839. //
  1840. // Учет статистики по бомба
  1841. //
  1842. Stats_SaveBDefusing(id)
  1843. {
  1844. player_wstats2[id][STATS2_DEFAT] ++
  1845.  
  1846. if(FW_BDefusing)
  1847. ExecuteForward(FW_BDefusing,dummy_ret,id)
  1848.  
  1849. return true
  1850. }
  1851.  
  1852. Stats_SaveBDefused(id)
  1853. {
  1854. player_wstats2[id][STATS2_DEFOK] ++
  1855.  
  1856. if(FW_BDefused)
  1857. ExecuteForward(FW_BDefused,dummy_ret,id)
  1858.  
  1859. return true
  1860. }
  1861.  
  1862. Stats_SaveBPlanted(id)
  1863. {
  1864. player_wstats2[id][STATS2_PLAAT] ++
  1865.  
  1866. if(FW_BPlanted)
  1867. ExecuteForward(FW_BPlanted,dummy_ret,id)
  1868.  
  1869. return true
  1870. }
  1871.  
  1872. Stats_SaveBExplode(id)
  1873. {
  1874. player_wstats2[id][STATS2_PLAOK] ++
  1875.  
  1876. if(FW_BExplode)
  1877. ExecuteForward(FW_BExplode,dummy_ret,id,g_defuser)
  1878.  
  1879. return true
  1880. }
  1881.  
  1882. /*
  1883. * изменение ника игрока
  1884. */
  1885. public client_infochanged(id)
  1886. {
  1887. new cur_name[MAX_NAME_LENGTH],new_name[MAX_NAME_LENGTH]
  1888. get_user_name(id,cur_name,charsmax(cur_name))
  1889. get_user_info(id,"name",new_name,charsmax(new_name))
  1890.  
  1891. if(strcmp(cur_name,new_name) != 0)
  1892. {
  1893. copy(player_data[id][PLAYER_NAME],charsmax(player_data[][PLAYER_NAME]),new_name)
  1894. mysql_escape_string(player_data[id][PLAYER_NAME],charsmax(player_data[][PLAYER_NAME]))
  1895.  
  1896. if(get_pcvar_num(cvar[CVAR_RANK]) == 0)
  1897. {
  1898. DB_SavePlayerData(id,true)
  1899. }
  1900. }
  1901. }
  1902.  
  1903. /*
  1904. * сбрасываем astats,vstats статистику в начале раунда
  1905. */
  1906. public LogEventHooK_RoundStart()
  1907. {
  1908. // сбрасываем wrstats, vstats, astats в начале раунда
  1909. new players[32],pnum
  1910. get_players(players,pnum)
  1911.  
  1912. for(new i,player ; i < pnum ; i++)
  1913. {
  1914. player = players[i]
  1915.  
  1916. // определяем в какой команде игрок
  1917. switch(get_user_team(player))
  1918. {
  1919. // статистика сыгранных раундов по командам
  1920. case 1:
  1921. {
  1922. player_data[player][PLAYER_STATS3][STATS3_ROUNDT] ++
  1923. player_data[player][PLAYER_STATS3][STATS3_CURRENTTEAM] = 1
  1924. }
  1925. case 2:
  1926. {
  1927. player_data[player][PLAYER_STATS3][STATS3_ROUNDCT] ++
  1928. player_data[player][PLAYER_STATS3][STATS3_CURRENTTEAM] = 2
  1929. }
  1930. }
  1931. }
  1932.  
  1933.  
  1934. }
  1935.  
  1936. //
  1937. // сохраняем статистику в конце раунда
  1938. //
  1939. public LogEventHooK_RoundEnd()
  1940. {
  1941. if(get_pcvar_num(cvar[CVAR_UPDATESTYLE]) == -1)
  1942. {
  1943. DB_SaveAll()
  1944. }
  1945. }
  1946.  
  1947. /*
  1948. * загрузка статистики игрока из базы данных
  1949. */
  1950. DB_LoadPlayerData(id)
  1951. {
  1952. // пропускаем HLTV
  1953. if(is_user_hltv(id))
  1954. {
  1955. return false
  1956. }
  1957.  
  1958. // пропускаем ботов, если отключена запись статистики ботов
  1959. if( is_user_bot(id) && !get_pcvar_num(cvar[CVAR_RANKBOTS]))
  1960. {
  1961. return false
  1962. }
  1963.  
  1964. get_user_info(id,"name",player_data[id][PLAYER_NAME],charsmax(player_data[][PLAYER_NAME]))
  1965. mysql_escape_string(player_data[id][PLAYER_NAME],charsmax(player_data[][PLAYER_NAME]))
  1966.  
  1967. get_user_authid(id,player_data[id][PLAYER_STEAMID],charsmax(player_data[][PLAYER_STEAMID]))
  1968. get_user_ip(id,player_data[id][PLAYER_IP],charsmax(player_data[][PLAYER_IP]),true)
  1969.  
  1970. // формируем SQL запрос
  1971. new query[QUERY_LENGTH],len,sql_data[2]
  1972.  
  1973. sql_data[0] = SQL_LOAD
  1974. sql_data[1] = id
  1975. player_data[id][PLAYER_LOADSTATE] = LOAD_WAIT
  1976.  
  1977. len += formatex(query[len],charsmax(query)-len,"SELECT *,(")
  1978. len += DB_QueryBuildScore(query[len],charsmax(query)-len)
  1979. len += formatex(query[len],charsmax(query)-len,"),(")
  1980. len += DB_QueryBuildStatsnum(query[len],charsmax(query)-len)
  1981. len += formatex(query[len],charsmax(query)-len,")")
  1982.  
  1983. switch(get_pcvar_num(cvar[CVAR_RANK]))
  1984. {
  1985. case 0: // статистика по нику
  1986. {
  1987. len += formatex(query[len],charsmax(query)-len," FROM `%s` AS `a` WHERE `name` = '%s'",
  1988. tbl_name,player_data[id][PLAYER_NAME]
  1989. )
  1990. }
  1991. case 1: // статистика по steamid
  1992. {
  1993. len += formatex(query[len],charsmax(query)-len," FROM `%s` AS `a` WHERE `steamid` = '%s'",
  1994. tbl_name,player_data[id][PLAYER_STEAMID]
  1995. )
  1996. }
  1997. case 2: // статистика по ip
  1998. {
  1999. len += formatex(query[len],charsmax(query)-len," FROM `%s` AS `a` WHERE `ip` = '%s'",
  2000. tbl_name,player_data[id][PLAYER_IP]
  2001. )
  2002. }
  2003. default:
  2004. {
  2005. return false
  2006. }
  2007. }
  2008.  
  2009. // отправка потокового запроса
  2010. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,sizeof sql_data)
  2011.  
  2012. return true
  2013. }
  2014.  
  2015. //
  2016. // Загрузка статистики по оружию
  2017. //
  2018. DB_LoadPlayerWstats(id)
  2019. {
  2020. if(!player_data[id][PLAYER_ID])
  2021. {
  2022. return false
  2023. }
  2024.  
  2025. new query[QUERY_LENGTH],sql_data[2]
  2026.  
  2027. sql_data[0] = SQL_GETWSTATS
  2028. sql_data[1] = id
  2029.  
  2030. formatex(query,charsmax(query),"SELECT * FROM `%s_weapons` WHERE `player_id` = '%d'",
  2031. tbl_name,player_data[id][PLAYER_ID]
  2032. )
  2033.  
  2034. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,sizeof sql_data)
  2035.  
  2036. return true
  2037.  
  2038. }
  2039.  
  2040. /*
  2041. * сохранение статистики игрока
  2042. */
  2043. DB_SavePlayerData(id,bool:reload = false)
  2044. {
  2045. if(player_data[id][PLAYER_LOADSTATE] < LOAD_NEW) // игрок не загрузился
  2046. {
  2047. return false
  2048. }
  2049.  
  2050. new query[QUERY_LENGTH],i,len
  2051. new sql_data[2]
  2052.  
  2053. sql_data[1] = id
  2054.  
  2055. new stats[8],stats2[4],hits[8]
  2056. get_user_wstats(id,0,stats,hits)
  2057. get_user_stats2(id,stats2)
  2058.  
  2059. switch(player_data[id][PLAYER_LOADSTATE])
  2060. {
  2061. case LOAD_OK: // обновление данных
  2062. {
  2063. if(reload)
  2064. {
  2065. player_data[id][PLAYER_LOADSTATE] = LOAD_UPDATE
  2066. }
  2067.  
  2068. sql_data[0] = SQL_UPDATE
  2069.  
  2070. new diffstats[sizeof player_data[][PLAYER_STATS]]
  2071. new diffstats2[sizeof player_data[][PLAYER_STATS2]]
  2072. new diffhits[sizeof player_data[][PLAYER_HITS]]
  2073. new to_save
  2074.  
  2075. len += formatex(query[len],charsmax(query) - len,"UPDATE `%s` SET",tbl_name)
  2076.  
  2077. // обновляем по разнице с предедущими данными
  2078. for(i = 0 ; i < sizeof player_data[][PLAYER_STATS] ; i++)
  2079. {
  2080. diffstats[i] = stats[i] - player_data[id][PLAYER_STATSLAST][i] // узнаем разницу
  2081. player_data[id][PLAYER_STATSLAST][i] = stats[i]
  2082.  
  2083. if(diffstats[i])
  2084. {
  2085. len += formatex(query[len],charsmax(query) - len,"%s`%s` = `%s` + %d",
  2086. !to_save ? " " : ",",
  2087. row_names[i + ROW_KILLS],
  2088. row_names[i + ROW_KILLS],
  2089. diffstats[i]
  2090. )
  2091.  
  2092. to_save ++
  2093. }
  2094. }
  2095.  
  2096. // обновляем по разнице с предедущими данными
  2097. for(i = 0 ; i < sizeof player_data[][PLAYER_STATS2] ; i++)
  2098. {
  2099. diffstats2[i] = stats2[i] - player_data[id][PLAYER_STATS2LAST][i] // узнаем разницу
  2100. player_data[id][PLAYER_STATS2LAST][i] = stats2[i]
  2101.  
  2102. if(diffstats2[i])
  2103. {
  2104. len += formatex(query[len],charsmax(query) - len,"%s`%s` = `%s` + %d",
  2105. !to_save ? " " : ",",
  2106. row_names[i + ROW_BOMBDEF],
  2107. row_names[i + ROW_BOMBDEF],
  2108. diffstats2[i]
  2109. )
  2110.  
  2111. to_save ++
  2112. }
  2113. }
  2114.  
  2115.  
  2116. new Float:diffskill = player_data[id][PLAYER_SKILL] - player_data[id][PLAYER_SKILLLAST]
  2117. player_data[id][PLAYER_SKILLLAST] = _:player_data[id][PLAYER_SKILL]
  2118.  
  2119. if(diffskill != 0.0)
  2120. {
  2121. len += formatex(query[len],charsmax(query) - len,"%s`%s` = `%s` + %.2f",
  2122. !to_save ? " " : ",",
  2123. row_names[ROW_SKILL],
  2124. row_names[ROW_SKILL],
  2125. diffskill
  2126. )
  2127.  
  2128. to_save ++
  2129. }
  2130.  
  2131. if(stats[STATS_HITS])
  2132. {
  2133. // запрос на сохранение мест попаданий
  2134. for(i = 0; i < sizeof player_data[][PLAYER_HITS] ; i++)
  2135. {
  2136. diffhits[i] = hits[i] - player_data[id][PLAYER_HITSLAST][i] // узнаем разницу
  2137. player_data[id][PLAYER_HITSLAST][i] = hits[i]
  2138.  
  2139. if(diffhits[i])
  2140. {
  2141. len += formatex(query[len],charsmax(query) - len,"%s`%s` = `%s` + '%d'",
  2142. !to_save ? " " : ",",
  2143. row_names[i + ROW_H0],row_names[i + ROW_H0],
  2144. diffhits[i]
  2145. )
  2146. }
  2147. }
  2148. }
  2149.  
  2150. // 0.7
  2151. new diffstats3[STATS3_END]
  2152.  
  2153. for(i = STATS3_CONNECT ; i < sizeof player_data[][PLAYER_STATS3] ; i++)
  2154. {
  2155. diffstats3[i] = player_data[id][PLAYER_STATS3][i] - player_data[id][PLAYER_STATS3LAST][i]
  2156. player_data[id][PLAYER_STATS3LAST][i] = player_data[id][PLAYER_STATS3][i]
  2157.  
  2158. if(diffstats3[i])
  2159. {
  2160. len += formatex(query[len],charsmax(query) - len,"%s`%s` = `%s` + '%d'",
  2161. !to_save ? " " : ",",
  2162. row_names[(i - 1) + ROW_CONNECTS],row_names[(i - 1) + ROW_CONNECTS],
  2163. diffstats3[i]
  2164. )
  2165.  
  2166. to_save ++
  2167. }
  2168. }
  2169.  
  2170. // не сохраняем только подключения
  2171. to_save --
  2172.  
  2173. // 0.7 задаем поля для тригерром статистики по картам
  2174. if(session_id)
  2175. {
  2176. len += formatex(query[len],charsmax(query) - len,"%s`%s` = '%d',`%s` = '%s'",
  2177. to_save <= 0 ? " " : ",",
  2178. row_names[ROW_SESSIONID],session_id,
  2179. row_names[ROW_SESSIONNAME],session_map
  2180. )
  2181. }
  2182.  
  2183. //
  2184. player_data[id][PLAYER_ONLINE] += get_user_time(id) - player_data[id][PLAYER_ONLINEDIFF]
  2185. player_data[id][PLAYER_ONLINEDIFF] = get_user_time(id)
  2186.  
  2187. new diffonline = player_data[id][PLAYER_ONLINE]- player_data[id][PLAYER_ONLINELAST]
  2188. player_data[id][PLAYER_ONLINELAST] = player_data[id][PLAYER_ONLINE]
  2189.  
  2190. if(diffonline)
  2191. {
  2192. len += formatex(query[len],charsmax(query) - len,"%s`%s` = `%s` + %d",
  2193. to_save <= 0 ? " " : ",",
  2194. row_names[ROW_ONLINETIME],
  2195. row_names[ROW_ONLINETIME],
  2196. diffonline
  2197. )
  2198.  
  2199. //to_save ++
  2200. }
  2201.  
  2202. // обновляем время последнего подключения, ник, ип и steamid
  2203. len += formatex(query[len],charsmax(query) - len,",\
  2204. `last_join` = CURRENT_TIMESTAMP,\
  2205. `%s` = '%s',\
  2206. `%s` = '%s'",
  2207.  
  2208.  
  2209. row_names[ROW_STEAMID],player_data[id][PLAYER_STEAMID],
  2210. row_names[ROW_IP],player_data[id][PLAYER_IP],
  2211.  
  2212. row_names[ROW_ID],player_data[id][PLAYER_ID]
  2213. )
  2214.  
  2215. if(!reload) // не обновляем ник при его смене
  2216. {
  2217. len += formatex(query[len],charsmax(query) - len,",`%s` = '%s'",
  2218. row_names[ROW_NAME],player_data[id][PLAYER_NAME]
  2219. )
  2220. }
  2221.  
  2222. len += formatex(query[len],charsmax(query) - len,"WHERE `%s` = '%d'",row_names[ROW_ID],player_data[id][PLAYER_ID])
  2223.  
  2224. if(to_save <= 0) // нечего сохранять
  2225. {
  2226. if(player_data[id][PLAYER_LOADSTATE] == LOAD_UPDATE) // релоад для обновления ника
  2227. {
  2228. player_data[id][PLAYER_LOADSTATE] = LOAD_NO
  2229. DB_LoadPlayerData(id)
  2230. }
  2231.  
  2232. return false
  2233. }
  2234. else
  2235. {
  2236. //
  2237. // Сравниваем статистику
  2238. //
  2239. for(new i ; i < sizeof player_data[][PLAYER_STATS] ; i++)
  2240. {
  2241. player_data[id][PLAYER_STATS][i] += diffstats[i]
  2242. }
  2243.  
  2244. for(new i ; i < sizeof player_data[][PLAYER_HITS] ; i++)
  2245. {
  2246. player_data[id][PLAYER_HITS][i] += diffhits[i]
  2247. }
  2248.  
  2249. for(new i ; i < sizeof player_data[][PLAYER_STATS2] ; i++)
  2250. {
  2251. player_data[id][PLAYER_STATS2][i] += diffstats2[i]
  2252. }
  2253. }
  2254. }
  2255. case LOAD_NEW: // запрос на добавление новой записи
  2256. {
  2257. sql_data[0] = SQL_INSERT
  2258.  
  2259. new Float:skill
  2260.  
  2261. switch(get_pcvar_num(cvar[CVAR_SKILLFORMULA]))
  2262. {
  2263. case 0: skill = 100.0
  2264. }
  2265.  
  2266. formatex(query,charsmax(query),"INSERT INTO `%s` \
  2267. (`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`,`%s`)\
  2268. VALUES('%s','%s','%s','%.2f','%d','%d','%d','%d','%d','%d','%d','%d','%d','%d','%d',CURRENT_TIMESTAMP)\
  2269. ",tbl_name,
  2270.  
  2271. row_names[ROW_STEAMID],
  2272. row_names[ROW_NAME],
  2273. row_names[ROW_IP],
  2274. row_names[ROW_SKILL],
  2275. row_names[ROW_KILLS],
  2276. row_names[ROW_DEATHS],
  2277. row_names[ROW_HS],
  2278. row_names[ROW_TKS],
  2279. row_names[ROW_SHOTS],
  2280. row_names[ROW_HITS],
  2281. row_names[ROW_DMG],
  2282. row_names[ROW_BOMBDEF],
  2283. row_names[ROW_BOMBDEFUSED],
  2284. row_names[ROW_BOMBPLANTS],
  2285. row_names[ROW_BOMBEXPLOSIONS],
  2286. row_names[ROW_LASTJOIN],
  2287.  
  2288. player_data[id][PLAYER_STEAMID],
  2289. player_data[id][PLAYER_NAME],
  2290. player_data[id][PLAYER_IP],
  2291.  
  2292. skill,
  2293.  
  2294. stats[STATS_KILLS],
  2295. stats[STATS_DEATHS],
  2296. stats[STATS_HS],
  2297. stats[STATS_TK],
  2298. stats[STATS_SHOTS],
  2299. stats[STATS_HITS],
  2300. stats[STATS_DMG],
  2301.  
  2302. stats2[STATS2_DEFAT],
  2303. stats2[STATS2_DEFOK],
  2304. stats2[STATS2_PLAAT],
  2305. stats2[STATS2_PLAOK]
  2306. )
  2307.  
  2308. //
  2309. // Сравниваем статистику
  2310. //
  2311. for(new i ; i < sizeof player_data[][PLAYER_STATS] ; i++)
  2312. {
  2313. player_data[id][PLAYER_STATS][i] = stats[i]
  2314. }
  2315.  
  2316. for(new i ; i < sizeof player_data[][PLAYER_HITS] ; i++)
  2317. {
  2318. player_data[id][PLAYER_HITS][i] = hits[i]
  2319. }
  2320.  
  2321. for(new i ; i < sizeof player_data[][PLAYER_STATS2] ; i++)
  2322. {
  2323. player_data[id][PLAYER_STATS2][i] = stats2[i]
  2324. }
  2325.  
  2326. player_data[id][PLAYER_SKILL] = _:player_data[id][PLAYER_SKILLLAST] = _:skill
  2327.  
  2328. if(reload)
  2329. {
  2330. player_data[id][PLAYER_LOADSTATE] = LOAD_UPDATE
  2331. }
  2332. else
  2333. {
  2334. player_data[id][PLAYER_LOADSTATE] = LOAD_NEWWAIT
  2335. }
  2336. }
  2337. }
  2338.  
  2339. if(query[0])
  2340. {
  2341. if(weapon_stats_enabled)
  2342. {
  2343. DB_SavePlayerWstats(id)
  2344. }
  2345.  
  2346. switch(sql_data[0])
  2347. {
  2348. // накапливаем запросы
  2349. case SQL_UPDATE:
  2350. {
  2351. // запросов достаточно, сбрасываем их
  2352. DB_AddQuery(query,len)
  2353.  
  2354. return true
  2355. }
  2356. }
  2357.  
  2358. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,sizeof sql_data)
  2359. }
  2360.  
  2361. return true
  2362. }
  2363.  
  2364. //
  2365. // Сохранение статистики по оружию
  2366. //
  2367. public DB_SavePlayerWstats(id)
  2368. {
  2369. if(player_data[id][PLAYER_LOADSTATE] < LOAD_OK) // игрок не загрузился
  2370. {
  2371. return false
  2372. }
  2373.  
  2374. new query[QUERY_LENGTH],len,log[MAX_NAME_LENGTH],wpn,stats_index,stats_index_last,to_save
  2375. new diff[STATS_END + HIT_END]
  2376.  
  2377. const load_index = sizeof player_awstats[][] - 1
  2378.  
  2379. // по всем оружиям
  2380. for(wpn = 0; wpn < MAX_WEAPONS ; wpn++)
  2381. {
  2382. Info_Weapon_GetLog(wpn,log,charsmax(log))
  2383.  
  2384. if(!log[0])
  2385. {
  2386. continue
  2387. }
  2388.  
  2389. to_save = 0
  2390. len = 0
  2391.  
  2392. // расчитываем разницу статисткии
  2393. for(stats_index = 0; stats_index < STATS_END + HIT_END; stats_index++)
  2394. {
  2395. stats_index_last = stats_index + (STATS_END + HIT_END)
  2396.  
  2397. diff[stats_index] = player_wstats[id][wpn][stats_index] - player_awstats[id][wpn][stats_index_last]
  2398. player_awstats[id][wpn][stats_index_last] = player_wstats[id][wpn][stats_index]
  2399. }
  2400.  
  2401. switch(player_awstats[id][wpn][load_index])
  2402. {
  2403. // новая статистика оружия
  2404. case LOAD_NEW:
  2405. {
  2406. new id_row
  2407.  
  2408. // строим запрос
  2409. len += formatex(query[len],charsmax(query) - len,"INSERT INTO `%s_weapons` (`%s`,`%s`",
  2410. tbl_name,
  2411.  
  2412. row_weapons_names[ROW_WEAPON_PLAYER],
  2413. row_weapons_names[ROW_WEAPON_NAME]
  2414. )
  2415.  
  2416. for(stats_index = 0; stats_index < STATS_END + HIT_END; stats_index++)
  2417. {
  2418. id_row = ROW_WEAPON_KILLS + stats_index
  2419.  
  2420. if(diff[stats_index])
  2421. {
  2422. len += formatex(query[len],charsmax(query) - len,",`%s`",
  2423. row_weapons_names[id_row]
  2424. )
  2425.  
  2426. to_save ++
  2427. }
  2428. }
  2429.  
  2430. if(to_save)
  2431. {
  2432. len += formatex(query[len],charsmax(query) - len,") VALUES('%d','%s'",
  2433. player_data[id][PLAYER_ID],
  2434. log
  2435. )
  2436.  
  2437. for(stats_index = 0; stats_index < STATS_END + HIT_END; stats_index++)
  2438. {
  2439. id_row = ROW_WEAPON_KILLS + stats_index
  2440.  
  2441. if(diff[stats_index])
  2442. {
  2443. len += formatex(query[len],charsmax(query) - len,",'%d'",
  2444. diff[stats_index]
  2445. )
  2446. }
  2447. }
  2448.  
  2449. len += formatex(query[len],charsmax(query) - len,")")
  2450. player_awstats[id][wpn][load_index] = _:LOAD_OK
  2451. }
  2452.  
  2453.  
  2454. }
  2455. // обновляем статистику
  2456. case LOAD_OK:
  2457. {
  2458. new id_row
  2459.  
  2460. // строим запрос
  2461. len += formatex(query[len],charsmax(query) - len,"UPDATE `%s_weapons` SET",tbl_name)
  2462.  
  2463. for(stats_index = 0; stats_index < STATS_END + HIT_END; stats_index++)
  2464. {
  2465. id_row = ROW_WEAPON_KILLS + stats_index
  2466.  
  2467. if(diff[stats_index])
  2468. {
  2469. len += formatex(query[len],charsmax(query) - len,"%s`%s` = `%s` + '%d'",
  2470. to_save ? "," : "",
  2471. row_weapons_names[id_row],
  2472. row_weapons_names[id_row],
  2473. diff[stats_index]
  2474. )
  2475.  
  2476. to_save ++
  2477. }
  2478. }
  2479.  
  2480. len += formatex(query[len],charsmax(query) - len,"WHERE `%s` = '%s' AND `%s` = '%d'",
  2481. row_weapons_names[ROW_WEAPON_NAME],log,
  2482. row_weapons_names[ROW_WEAPON_PLAYER],player_data[id][PLAYER_ID]
  2483. )
  2484. }
  2485. }
  2486.  
  2487. if(to_save)
  2488. {
  2489. DB_AddQuery(query,len)
  2490. }
  2491. }
  2492.  
  2493. return true
  2494. }
  2495.  
  2496. DB_AddQuery(query[],len)
  2497. {
  2498. if((flush_que_len + len + 1) > charsmax(flush_que))
  2499. {
  2500. DB_FlushQuery()
  2501. }
  2502.  
  2503. flush_que_len += formatex(
  2504. flush_que[flush_que_len],
  2505. charsmax(flush_que) - flush_que_len,
  2506. "%s%s",flush_que_len ? ";" : "",
  2507. query
  2508. )
  2509.  
  2510. // задание на сброс накопленных запросов
  2511. remove_task(task_flush)
  2512. set_task(0.1,"DB_FlushQuery",task_flush)
  2513. }
  2514.  
  2515. //
  2516. // Сброс накопленных запросов
  2517. //
  2518. public DB_FlushQuery()
  2519. {
  2520. if(flush_que_len)
  2521. {
  2522. new sql_data[1] = SQL_UPDATE
  2523. SQL_ThreadQuery(sql,"SQL_Handler",flush_que,sql_data,sizeof sql_data)
  2524.  
  2525. flush_que_len = 0
  2526. }
  2527. }
  2528.  
  2529. #define falos false
  2530.  
  2531. /*
  2532. * получение новых позиции в топе игроков
  2533. */
  2534. public DB_GetPlayerRanks()
  2535. {
  2536. new players[32],pnum
  2537. get_players(players,pnum)
  2538.  
  2539. new query[QUERY_LENGTH],len
  2540.  
  2541. // строим SQL запрос
  2542. len += formatex(query[len],charsmax(query) - len,"SELECT `id`,(")
  2543. len += DB_QueryBuildScore(query[len],charsmax(query) - len)
  2544. len += formatex(query[len],charsmax(query) - len,") FROM `%s` as `a` WHERE `id` IN(",tbl_name)
  2545.  
  2546. new bool:letsgo
  2547.  
  2548. for(new i,player,bool:y ; i < pnum ; i++)
  2549. {
  2550. player = players[i]
  2551.  
  2552. if(player_data[player][PLAYER_ID])
  2553. {
  2554. len += formatex(query[len],charsmax(query) - len,"%s'%d'",y ? "," : "",player_data[player][PLAYER_ID])
  2555. y = true
  2556. letsgo = true
  2557. }
  2558. }
  2559.  
  2560. len += formatex(query[len],charsmax(query) - len,")")
  2561.  
  2562. if(letsgo)
  2563. {
  2564. new data[1] = SQL_UPDATERANK
  2565. SQL_ThreadQuery(sql,"SQL_Handler",query,data,sizeof data)
  2566. }
  2567. }
  2568.  
  2569. new bool:update_cache = false
  2570.  
  2571. /*
  2572. * сохранение статистики всех игроков
  2573. */
  2574. public DB_SaveAll()
  2575. {
  2576. new players[32],pnum
  2577. get_players(players,pnum)
  2578.  
  2579. if(get_pcvar_num(cvar[CVAR_CACHETIME]) == -1)
  2580. {
  2581. update_cache = true
  2582. }
  2583.  
  2584. for(new i ; i < pnum ; i++)
  2585. {
  2586. DB_SavePlayerData(players[i])
  2587. }
  2588. }
  2589.  
  2590. /*
  2591. * запрос на просчет ранка
  2592. */
  2593. DB_QueryBuildScore(sql_que[] = "",sql_que_len = 0,bool:only_rows = falos,overide_order = 0)
  2594. {
  2595. // стандартная формула csstats (убийства-смерти-tk)
  2596.  
  2597. if(only_rows)
  2598. {
  2599. switch(overide_order ? overide_order : get_pcvar_num(cvar[CVAR_RANKFORMULA]))
  2600. {
  2601. case 1: return formatex(sql_que,sql_que_len,"`kills`")
  2602. case 2: return formatex(sql_que,sql_que_len,"`kills`+`hs`")
  2603. case 3: return formatex(sql_que,sql_que_len,"`skill`")
  2604. case 4: return formatex(sql_que,sql_que_len,"`connection_time`")
  2605. default: return formatex(sql_que,sql_que_len,"`kills`-`deaths`-`tks`")
  2606. }
  2607. }
  2608. else
  2609. {
  2610. switch(overide_order ? overide_order : get_pcvar_num(cvar[CVAR_RANKFORMULA]))
  2611. {
  2612. case 1: return formatex(sql_que,sql_que_len,"SELECT COUNT(*) FROM %s WHERE (kills)>=(a.kills)",tbl_name)
  2613. case 2: return formatex(sql_que,sql_que_len,"SELECT COUNT(*) FROM %s WHERE (kills+hs)>=(a.kills+a.hs)",tbl_name)
  2614. case 3: return formatex(sql_que,sql_que_len,"SELECT COUNT(*) FROM %s WHERE (skill)>=(a.skill)",tbl_name)
  2615. case 4: return formatex(sql_que,sql_que_len,"SELECT COUNT(*) FROM %s WHERE (connection_time)>=(a.connection_time)",tbl_name)
  2616. default: return formatex(sql_que,sql_que_len,"SELECT COUNT(*) FROM %s WHERE (kills-deaths-tks)>=(a.kills-a.deaths-a.tks)",tbl_name)
  2617. }
  2618.  
  2619.  
  2620. }
  2621.  
  2622. return 0
  2623. }
  2624.  
  2625. /*
  2626. * запрос на общее кол-во записей в БД
  2627. */
  2628. DB_QueryBuildStatsnum(sql_que[] = "",sql_que_len = 0)
  2629. {
  2630. return formatex(sql_que,sql_que_len,"SELECT COUNT(*) FROM %s WHERE 1",tbl_name)
  2631. }
  2632.  
  2633. /*
  2634. * запрос на выборку статистики по позиции
  2635. * index - начальная позиция
  2636. * index_count - кол-во выбираемых записей
  2637. */
  2638. DB_QueryBuildGetstats(query[],query_max,len = 0,index,index_count = 2,overide_order = 0)
  2639. {
  2640. // строим запрос
  2641. len += formatex(query[len],query_max-len,"SELECT *")
  2642.  
  2643. // запрос на ранк
  2644. len += formatex(query[len],query_max-len,",(")
  2645. len += DB_QueryBuildScore(query[len],query_max-len,true,overide_order)
  2646. len += formatex(query[len],query_max-len,") as `rank`")
  2647.  
  2648. // запрашиваем следующию запись
  2649. // если есть, то возврашаем нативом index + 1
  2650. len += formatex(query[len],query_max-len," FROM `%s` as `a` ORDER BY `rank` DESC LIMIT %d,%d",
  2651. tbl_name,index,index_count
  2652. )
  2653.  
  2654. return len
  2655. }
  2656.  
  2657. /*
  2658. * чтение результата get_stats запроса
  2659. */
  2660. DB_ReadGetStats(Handle:sqlQue,name[] = "",name_len = 0,authid[] = "",authid_len = 0,stats[8] = 0,hits[8] = 0,stats2[4] = 0,stats3[STATS3_END] = 0,&stats_count = 0,index)
  2661. {
  2662. stats_count = SQL_NumResults(sqlQue)
  2663.  
  2664. if(!stats_count)
  2665. {
  2666. return false
  2667. }
  2668.  
  2669. new stats_cache[stats_cache_struct]
  2670.  
  2671. switch(get_pcvar_num(cvar[CVAR_RANK]))
  2672. {
  2673. case 0: SQL_ReadResult(sqlQue,ROW_NAME,stats_cache[CACHE_STEAMID],charsmax(stats_cache[CACHE_STEAMID]))
  2674. case 1: SQL_ReadResult(sqlQue,ROW_STEAMID,stats_cache[CACHE_STEAMID],charsmax(stats_cache[CACHE_STEAMID]))
  2675. case 2: SQL_ReadResult(sqlQue,ROW_IP,stats_cache[CACHE_STEAMID],charsmax(stats_cache[CACHE_STEAMID]))
  2676. }
  2677.  
  2678. SQL_ReadResult(sqlQue,ROW_NAME,stats_cache[CACHE_NAME],charsmax(stats_cache[CACHE_NAME]))
  2679.  
  2680. copy(name,name_len,stats_cache[CACHE_NAME])
  2681. copy(authid,authid_len,stats_cache[CACHE_STEAMID])
  2682.  
  2683. new i
  2684.  
  2685. for(i = ROW_SKILL ; i <= ROW_LASTJOIN ; i++)
  2686. {
  2687. switch(i)
  2688. {
  2689. case ROW_SKILL: SQL_ReadResult(sqlQue,i,stats_cache[CACHE_SKILL])
  2690. case ROW_KILLS..ROW_DMG:
  2691. {
  2692. stats_cache[CACHE_STATS][i - ROW_KILLS] = stats[i - ROW_KILLS] = SQL_ReadResult(sqlQue,i)
  2693. }
  2694. case ROW_BOMBDEF..ROW_BOMBEXPLOSIONS:
  2695. {
  2696. stats_cache[CACHE_STATS2][i - ROW_BOMBDEF] = stats2[i - ROW_BOMBDEF] = SQL_ReadResult(sqlQue,i)
  2697. }
  2698. case ROW_H0..ROW_H7:
  2699. {
  2700. stats_cache[CACHE_HITS][i - ROW_H0] = hits[i - ROW_H0] = SQL_ReadResult(sqlQue,i)
  2701. }
  2702. // 0.7
  2703. case ROW_CONNECTS..ROW_ASSISTS:
  2704. {
  2705. stats_cache[CACHE_STATS3][((i - ROW_CONNECTS) + 1)] = stats3[((i - ROW_CONNECTS) + 1)] = SQL_ReadResult(sqlQue,i)
  2706. }
  2707. case ROW_FIRSTJOIN..ROW_LASTJOIN:
  2708. {
  2709. new date_str[32]
  2710. SQL_ReadResult(sqlQue,i,date_str,charsmax(date_str))
  2711.  
  2712. stats_cache[(CACHE_FIRSTJOIN + (i - ROW_FIRSTJOIN))] = parse_time(date_str,"%Y-%m-%d %H:%M:%S")
  2713. }
  2714. }
  2715.  
  2716. }
  2717.  
  2718. // кеширование данных
  2719. if(!stats_cache_trie)
  2720. {
  2721. stats_cache_trie = TrieCreate()
  2722. }
  2723.  
  2724. stats_cache[CACHE_LAST] = SQL_NumResults(sqlQue) <= 1
  2725. SQL_ReadResult(sqlQue,ROW_SKILL,stats_cache[CACHE_SKILL])
  2726. stats_cache[CACHE_ID] = SQL_ReadResult(sqlQue,ROW_ID)
  2727. stats_cache[CACHE_TIME] = SQL_ReadResult(sqlQue,ROW_ONLINETIME)
  2728.  
  2729. new index_str[10]
  2730. num_to_str(index,index_str,charsmax(index_str))
  2731.  
  2732. TrieSetArray(stats_cache_trie,index_str,stats_cache,stats_cache_struct)
  2733. // кешироавние данных
  2734.  
  2735. SQL_NextRow(sqlQue)
  2736.  
  2737. return SQL_MoreResults(sqlQue)
  2738. }
  2739.  
  2740. //
  2741. // Задаем очередь для обновления кеша
  2742. //
  2743. Cache_Stats_SetQueue(start_index,top)
  2744. {
  2745. // очередь уже создана
  2746. if(Cache_Stats_CheckQueue(start_index,top))
  2747. {
  2748. return false
  2749. }
  2750.  
  2751. if(!stats_cache_queue)
  2752. {
  2753. stats_cache_queue = ArrayCreate(stats_cache_queue_struct)
  2754. }
  2755.  
  2756. new length = ArraySize(stats_cache_queue)
  2757.  
  2758. new cache_queue_info[stats_cache_queue_struct]
  2759. cache_queue_info[CACHE_QUE_START] = start_index
  2760. cache_queue_info[CACHE_QUE_TOP] = top
  2761.  
  2762. if(!length) // новая очередь
  2763. {
  2764. ArrayPushArray(stats_cache_queue,cache_queue_info)
  2765. }
  2766. else // в топ
  2767. {
  2768. ArrayInsertArrayBefore(stats_cache_queue,0,cache_queue_info)
  2769. }
  2770.  
  2771. length ++
  2772.  
  2773. if(length > 5) // максимум 5 заданий в очереди
  2774. {
  2775. ArrayDeleteItem(stats_cache_queue,5)
  2776. length --
  2777. }
  2778.  
  2779. return true
  2780. }
  2781.  
  2782. //
  2783. // Обновление кеша через очередь
  2784. //
  2785. Cache_Stats_UpdateQueue()
  2786. {
  2787. if(!stats_cache_queue)
  2788. {
  2789. return false
  2790. }
  2791.  
  2792. for(new i,length = ArraySize(stats_cache_queue),cache_queue_info[stats_cache_queue_struct] ; i < length ; i++)
  2793. {
  2794. ArrayGetArray(stats_cache_queue,i,cache_queue_info)
  2795. DB_QueryTop15(0,-1,-1,-1,cache_queue_info[CACHE_QUE_START],cache_queue_info[CACHE_QUE_TOP],-1)
  2796. }
  2797.  
  2798. return true
  2799. }
  2800.  
  2801. Cache_Stats_CheckQueue(start_index,top)
  2802. {
  2803. if(!stats_cache_queue)
  2804. {
  2805. return false
  2806. }
  2807.  
  2808. for(new i,length = ArraySize(stats_cache_queue),cache_queue_info[stats_cache_queue_struct] ; i < length ; i++)
  2809. {
  2810. ArrayGetArray(stats_cache_queue,i,cache_queue_info)
  2811.  
  2812. if(start_index == cache_queue_info[0] &&
  2813. top == cache_queue_info[1]
  2814. )
  2815. {
  2816. return true
  2817. }
  2818. }
  2819.  
  2820. return false
  2821. }
  2822.  
  2823. //
  2824. // Потоковый запрос на Top15
  2825. //
  2826. DB_QueryTop15(id,plugin_id,func_id,position,start_index,top,params)
  2827. {
  2828. // кеширование
  2829. if((get_pcvar_num(cvar[CVAR_CACHETIME]) != 0) && stats_cache_trie)
  2830. {
  2831. Cache_Stats_SetQueue(start_index,top)
  2832.  
  2833. new bool:use_cache = true
  2834.  
  2835. // проверяем что требуемые данные есть в кеше
  2836. for(new i = start_index,index_str[10]; i < (start_index + top) ; i++)
  2837. {
  2838. num_to_str(i,index_str,charsmax(index_str))
  2839.  
  2840. if(!TrieKeyExists(stats_cache_trie,index_str))
  2841. {
  2842. use_cache = false
  2843. }
  2844. }
  2845.  
  2846. // юзаем кеш
  2847. if(use_cache)
  2848. {
  2849. // вызываем хандлер другого плагина
  2850.  
  2851. if(func_id > -1)
  2852. {
  2853. if(callfunc_begin_i(func_id,plugin_id))
  2854. {
  2855. callfunc_push_int(id)
  2856. callfunc_push_int(position)
  2857. callfunc_end()
  2858. }
  2859. }
  2860.  
  2861. return true
  2862. }
  2863. }
  2864. // кеширование
  2865.  
  2866. // строим новый запрос
  2867. new query[QUERY_LENGTH]
  2868.  
  2869. if(params == 5)
  2870. {
  2871. DB_QueryBuildGetstats(query,charsmax(query),.index = start_index,.index_count = top,.overide_order = get_param(5))
  2872. }
  2873. else
  2874. {
  2875. DB_QueryBuildGetstats(query,charsmax(query),.index = start_index,.index_count = top)
  2876. }
  2877.  
  2878. new sql_data[6]
  2879.  
  2880. sql_data[0] = SQL_GETSTATS
  2881. sql_data[1] = id
  2882. sql_data[2] = plugin_id
  2883. sql_data[3] = func_id
  2884. sql_data[4] = position
  2885. sql_data[5] = start_index
  2886.  
  2887. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,sizeof sql_data)
  2888.  
  2889. return true
  2890. }
  2891.  
  2892. /*
  2893. * обновляем кеш для get_stats
  2894. */
  2895. Cache_Stats_Update()
  2896. {
  2897. if(!stats_cache_trie)
  2898. return false
  2899.  
  2900. TrieClear(stats_cache_trie)
  2901.  
  2902. return true
  2903. }
  2904.  
  2905. /*
  2906. * обработка ответов на SQL запросы
  2907. */
  2908. public SQL_Handler(failstate,Handle:sqlQue,err[],errNum,data[],dataSize){
  2909. // есть ошибки
  2910. switch(failstate)
  2911. {
  2912. case TQUERY_CONNECT_FAILED: // ошибка соединения с mysql сервером
  2913. {
  2914. log_amx("SQL connection failed")
  2915. log_amx("[ %d ] %s",errNum,err)
  2916.  
  2917. return PLUGIN_HANDLED
  2918. }
  2919. case TQUERY_QUERY_FAILED: // ошибка SQL запроса
  2920. {
  2921. new lastQue[QUERY_LENGTH]
  2922. SQL_GetQueryString(sqlQue,lastQue,charsmax(lastQue)) // узнаем последний SQL запрос
  2923.  
  2924. log_amx("SQL query failed")
  2925. log_amx("[ %d ] %s",errNum,err)
  2926. log_amx("[ SQL ] %s",lastQue)
  2927.  
  2928. return PLUGIN_HANDLED
  2929. }
  2930. }
  2931.  
  2932. switch(data[0])
  2933. {
  2934. case SQL_INITDB:
  2935. {
  2936. DB_InitSeq()
  2937. }
  2938. case SQL_LOAD: // загрзука статистики игрока
  2939. {
  2940. new id = data[1]
  2941.  
  2942. if(!is_user_connected(id))
  2943. {
  2944. return PLUGIN_HANDLED
  2945. }
  2946.  
  2947. if(SQL_NumResults(sqlQue)) // считываем статистику
  2948. {
  2949. player_data[id][PLAYER_LOADSTATE] = LOAD_OK
  2950. player_data[id][PLAYER_ID] = SQL_ReadResult(sqlQue,ROW_ID)
  2951.  
  2952. // общая статистика
  2953. player_data[id][PLAYER_STATS][STATS_KILLS] = SQL_ReadResult(sqlQue,ROW_KILLS)
  2954. player_data[id][PLAYER_STATS][STATS_DEATHS] = SQL_ReadResult(sqlQue,ROW_DEATHS)
  2955. player_data[id][PLAYER_STATS][STATS_HS] = SQL_ReadResult(sqlQue,ROW_HS)
  2956. player_data[id][PLAYER_STATS][STATS_TK] = SQL_ReadResult(sqlQue,ROW_TKS)
  2957. player_data[id][PLAYER_STATS][STATS_SHOTS] = SQL_ReadResult(sqlQue,ROW_SHOTS)
  2958. player_data[id][PLAYER_STATS][STATS_HITS] = SQL_ReadResult(sqlQue,ROW_HITS)
  2959. player_data[id][PLAYER_STATS][STATS_DMG] = SQL_ReadResult(sqlQue,ROW_DMG)
  2960.  
  2961. // статистика cstrike
  2962. player_data[id][PLAYER_STATS2][STATS2_DEFAT] = SQL_ReadResult(sqlQue,ROW_BOMBDEF)
  2963. player_data[id][PLAYER_STATS2][STATS2_DEFOK] = SQL_ReadResult(sqlQue,ROW_BOMBDEFUSED)
  2964. player_data[id][PLAYER_STATS2][STATS2_PLAAT] = SQL_ReadResult(sqlQue,ROW_BOMBPLANTS)
  2965. player_data[id][PLAYER_STATS2][STATS2_PLAOK] = SQL_ReadResult(sqlQue,ROW_BOMBEXPLOSIONS)
  2966.  
  2967. // время онлайн
  2968. player_data[id][PLAYER_ONLINE] = player_data[id][PLAYER_ONLINELAST] = SQL_ReadResult(sqlQue,ROW_ONLINETIME)
  2969.  
  2970. // скилл
  2971. SQL_ReadResult(sqlQue,ROW_SKILL,player_data[id][PLAYER_SKILL])
  2972. player_data[id][PLAYER_SKILLLAST] = _:player_data[id][PLAYER_SKILL]
  2973.  
  2974. // посл подключение и первое подкчлючение
  2975. new date_str[32]
  2976.  
  2977. SQL_ReadResult(sqlQue,ROW_FIRSTJOIN,date_str,charsmax(date_str))
  2978. player_data[id][PLAYER_FIRSTJOIN] = parse_time(date_str,"%Y-%m-%d %H:%M:%S")
  2979. SQL_ReadResult(sqlQue,ROW_LASTJOIN,date_str,charsmax(date_str))
  2980. player_data[id][PLAYER_LASTJOIN] = parse_time(date_str,"%Y-%m-%d %H:%M:%S")
  2981.  
  2982. // доп. запросы
  2983. player_data[id][PLAYER_RANK] = SQL_ReadResult(sqlQue,row_ids) // ранк игрока
  2984. statsnum = SQL_ReadResult(sqlQue,row_ids + 1) // общее кол-во игроков в БД
  2985.  
  2986. // статистика попаданий
  2987. for(new i ; i < sizeof player_data[][PLAYER_HITS] ; i++)
  2988. {
  2989. player_data[id][PLAYER_HITS][i] = SQL_ReadResult(sqlQue,ROW_H0 + i)
  2990. }
  2991.  
  2992. // 0.7
  2993. for(new i = STATS3_CONNECT ; i < sizeof player_data[][PLAYER_STATS3] ; i++)
  2994. {
  2995. player_data[id][PLAYER_STATS3][i] = player_data[id][PLAYER_STATS3LAST][i] = SQL_ReadResult(sqlQue,(i - 1) + ROW_CONNECTS)
  2996.  
  2997. // плюсуем стату подключений
  2998. if(i == STATS3_CONNECT)
  2999. {
  3000. player_data[id][PLAYER_STATS3][i] ++
  3001. }
  3002. }
  3003.  
  3004. if(weapon_stats_enabled)
  3005. {
  3006. DB_LoadPlayerWstats(id)
  3007. }
  3008. }
  3009. else // помечаем как нового игрока
  3010. {
  3011. player_data[id][PLAYER_LOADSTATE] = LOAD_NEW
  3012.  
  3013. DB_SavePlayerData(id) // добавляем запись в базу данных
  3014. }
  3015. }
  3016. case SQL_INSERT: // запись новых данных
  3017. {
  3018. new id = data[1]
  3019.  
  3020. if(is_user_connected(id))
  3021. {
  3022. if(player_data[id][PLAYER_LOADSTATE] == LOAD_UPDATE)
  3023. {
  3024. player_data[id][PLAYER_LOADSTATE] = LOAD_NO
  3025. DB_LoadPlayerData(id)
  3026.  
  3027. return PLUGIN_HANDLED
  3028. }
  3029.  
  3030. player_data[id][PLAYER_ID] = SQL_GetInsertId(sqlQue) // первичный ключ
  3031. player_data[id][PLAYER_LOADSTATE] = LOAD_OK // данные загружены
  3032.  
  3033. // я упрлся 0)0)0
  3034.  
  3035. // обновляем счетчик общего кол-ва записей
  3036. statsnum++
  3037.  
  3038. if(weapon_stats_enabled)
  3039. {
  3040. DB_LoadPlayerWstats(id)
  3041. }
  3042. }
  3043.  
  3044. // обновляем позици игроков
  3045. // действие с задержкой, что-бы учесть изменения при множественном обновлении данных
  3046. if(!task_exists(task_rankupdate))
  3047. {
  3048. set_task(1.0,"DB_GetPlayerRanks",task_rankupdate)
  3049. }
  3050. }
  3051. case SQL_UPDATE: // обновление данных
  3052. {
  3053. // обновляем позици игроков
  3054. // действие с задержкой, что-бы учесть изменения при множественном обновлении данных
  3055. if(!task_exists(task_rankupdate))
  3056. {
  3057. set_task(0.1,"DB_GetPlayerRanks",task_rankupdate)
  3058. }
  3059.  
  3060. new players[MAX_PLAYERS],pnum
  3061. get_players(players,pnum)
  3062.  
  3063. for(new i,player ; i < pnum ; i++)
  3064. {
  3065. player = players[i]
  3066.  
  3067. if(player_data[player][PLAYER_LOADSTATE] == LOAD_UPDATE)
  3068. {
  3069. player_data[player][PLAYER_LOADSTATE] = LOAD_NO
  3070. DB_LoadPlayerData(player)
  3071. }
  3072. }
  3073.  
  3074. if(update_cache)
  3075. {
  3076. update_cache = false
  3077.  
  3078. Cache_Stats_Update()
  3079. Cache_Stats_UpdateQueue()
  3080. }
  3081. }
  3082. case SQL_UPDATERANK:
  3083. {
  3084. while(SQL_MoreResults(sqlQue))
  3085. {
  3086. new pK = SQL_ReadResult(sqlQue,0)
  3087. new rank = SQL_ReadResult(sqlQue,1)
  3088.  
  3089. for(new i ; i < MAX_PLAYERS ; i++)
  3090. {
  3091. if(player_data[i][PLAYER_ID] == pK) // задаем ранк по первичному ключу
  3092. {
  3093. player_data[i][PLAYER_RANK] = rank
  3094. }
  3095. }
  3096.  
  3097. SQL_NextRow(sqlQue)
  3098. }
  3099. }
  3100. case SQL_GETSTATS: // потоковый get_stats
  3101. {
  3102. new id = data[1]
  3103.  
  3104. if(id && !is_user_connected(id))
  3105. {
  3106. return PLUGIN_HANDLED
  3107. }
  3108.  
  3109. new index = data[5]
  3110. new name[32],authid[30]
  3111.  
  3112. // кешируем ответ
  3113. while(DB_ReadGetStats(sqlQue,name,charsmax(name),authid,charsmax(authid),.index = index ++))
  3114. {
  3115. }
  3116.  
  3117. if(data[3] > -1)
  3118. {
  3119. // вызываем хандлер другого плагина
  3120. if(callfunc_begin_i(data[3],data[2]))
  3121. {
  3122. callfunc_push_int(id)
  3123. callfunc_push_int(data[4])
  3124. callfunc_end()
  3125. }
  3126. }
  3127. }
  3128.  
  3129. // 0.7
  3130. case SQL_GETWSTATS:
  3131. {
  3132. new id = data[1]
  3133.  
  3134. if(!is_user_connected(id))
  3135. {
  3136. return PLUGIN_HANDLED
  3137. }
  3138.  
  3139. const load_index = sizeof player_awstats[][] - 1
  3140.  
  3141. // загружаем статистику по оружию
  3142. while(SQL_MoreResults(sqlQue))
  3143. {
  3144. new log[MAX_NAME_LENGTH]
  3145. SQL_ReadResult(sqlQue,ROW_WEAPON_NAME,log,charsmax(log))
  3146.  
  3147. new wpn = Info_Weapon_GetId(log)
  3148.  
  3149. if(wpn == -1)
  3150. {
  3151. continue
  3152. }
  3153.  
  3154. for(new i ; i < STATS_END + HIT_END ; i++)
  3155. {
  3156. player_awstats[id][wpn][i] = SQL_ReadResult(sqlQue,i + ROW_WEAPON_KILLS)
  3157. }
  3158.  
  3159. player_awstats[id][wpn][load_index] = _:LOAD_OK
  3160.  
  3161. SQL_NextRow(sqlQue)
  3162. }
  3163.  
  3164. // помечаем статистику по другим оружиям как новую
  3165. for(new wpn ; wpn < MAX_WEAPONS ; wpn++)
  3166. {
  3167. if(_:player_awstats[id][wpn][load_index] != _:LOAD_OK)
  3168. {
  3169. player_awstats[id][wpn][load_index] = _:LOAD_NEW
  3170. }
  3171. }
  3172. }
  3173. case SQL_GETSESSID:
  3174. {
  3175. session_id = SQL_ReadResult(sqlQue,0) + 1
  3176. get_mapname(session_map,charsmax(session_map))
  3177.  
  3178. DB_InitSeq()
  3179. }
  3180. // get_sestats_thread_sql
  3181. case SQL_GETSESTATS:
  3182. {
  3183. new Array:sestats_array = ArrayCreate(sestats_array_struct)
  3184. new sestats_data[sestats_array_struct]
  3185.  
  3186. while(SQL_MoreResults(sqlQue))
  3187. {
  3188. arrayset(sestats_data,0,sestats_array_struct)
  3189.  
  3190. // заполняем массив со статой сессии
  3191. for(new i = ROW_MAP_ID ; i <= ROW_MAP_LASTJOIN ; i++)
  3192. {
  3193. switch(i)
  3194. {
  3195. case ROW_MAP_ID: sestats_data[SESTATS_ID] = SQL_ReadResult(sqlQue,i)
  3196. case ROW_MAP_PLRID: sestats_data[SESTATS_PLAYERID] = SQL_ReadResult(sqlQue,i)
  3197. case ROW_MAP_MAP: SQL_ReadResult(sqlQue,i,sestats_data[SESTATS_MAP],charsmax(sestats_data[SESTATS_MAP]))
  3198. case ROW_MAP_SKILL: SQL_ReadResult(sqlQue,i,sestats_data[SESTATS_SKILL])
  3199. case ROW_MAP_KILLS..ROW_MAP_DMG: sestats_data[SESTATS_STATS][(i - ROW_MAP_KILLS)] = SQL_ReadResult(sqlQue,i)
  3200. case ROW_MAP_H0..ROW_MAP_H7: sestats_data[SESTATS_HITS][(i - ROW_MAP_H0)] = SQL_ReadResult(sqlQue,i)
  3201. case ROW_MAP_BOMBDEF..ROW_MAP_BOMBEXPLOSIONS: sestats_data[SESTATS_STATS2][(i - ROW_MAP_BOMBDEF)] = SQL_ReadResult(sqlQue,i)
  3202. case ROW_MAP_ROUNDT..ROW_MAP_ASSISTS: sestats_data[SESTATS_STATS3][((i - ROW_MAP_ROUNDT) + 1)] = SQL_ReadResult(sqlQue,i)
  3203. case ROW_MAP_ONLINETIME: sestats_data[SESTATS_ONLINETIME] = SQL_ReadResult(sqlQue,i)
  3204. case ROW_MAP_FIRSTJOIN,ROW_LASTJOIN:
  3205. {
  3206. new date_str[32]
  3207. SQL_ReadResult(sqlQue,i,date_str,charsmax(date_str))
  3208.  
  3209. sestats_data[(SESTATS_FIRSTJOIN + (i - ROW_MAP_FIRSTJOIN))] = parse_time(date_str,"%Y-%m-%d %H:%M:%S")
  3210. }
  3211. }
  3212. }
  3213.  
  3214. ArrayPushArray(sestats_array,sestats_data)
  3215.  
  3216. SQL_NextRow(sqlQue)
  3217. }
  3218.  
  3219. new func_id = data[1]
  3220. new plugin_id = data[2]
  3221.  
  3222. if(callfunc_begin_i(func_id,plugin_id))
  3223. {
  3224. callfunc_push_int(int:sestats_array)
  3225.  
  3226. // передаваемые данные
  3227. if(dataSize > 3)
  3228. {
  3229. new cb_data[MAX_DATA_PARAMS]
  3230.  
  3231. for(new i ; i < (dataSize - 3) ; i++)
  3232. {
  3233. cb_data[i] = data[(3 + i)]
  3234. }
  3235.  
  3236. callfunc_push_array(cb_data,(dataSize - 3))
  3237. callfunc_push_int((dataSize - 3))
  3238. }
  3239.  
  3240. callfunc_end()
  3241. }
  3242. else
  3243. {
  3244. log_amx("get_sestats_thread_sql callback function failed")
  3245. }
  3246. }
  3247. case SQL_AUTOCLEAR:
  3248. {
  3249. if(SQL_AffectedRows(sqlQue))
  3250. {
  3251. log_amx("deleted %d inactive entries",
  3252. SQL_AffectedRows(sqlQue)
  3253. )
  3254. }
  3255.  
  3256. DB_InitSeq()
  3257. }
  3258. }
  3259.  
  3260. return PLUGIN_HANDLED
  3261. }
  3262.  
  3263. //
  3264. // Поиск ID оружия по его лог коду
  3265. //
  3266. Info_Weapon_GetId(weapon[])
  3267. {
  3268. new weapon_info[WEAPON_INFO_SIZE]
  3269. new length = ArraySize(weapons_data)
  3270.  
  3271. for(new i ; i < length; i++)
  3272. {
  3273. ArrayGetArray(weapons_data,i,weapon_info)
  3274.  
  3275. new weapon_name[MAX_NAME_LENGTH]
  3276. copy(weapon_name,charsmax(weapon_name),weapon_info[MAX_NAME_LENGTH])
  3277.  
  3278. if(strcmp(weapon_name,weapon) == 0)
  3279. {
  3280. return i
  3281. }
  3282. }
  3283.  
  3284. return -1
  3285. }
  3286.  
  3287. //
  3288. // Поиск лог кода по ID оружия
  3289. //
  3290. Info_Weapon_GetLog(wpn_id,weapon_name[],len)
  3291. {
  3292. if(!(0 < wpn_id < ArraySize(weapons_data)))
  3293. {
  3294. formatex(weapon_name,len,"")
  3295. return
  3296. }
  3297.  
  3298. new weapon_info[WEAPON_INFO_SIZE]
  3299. ArrayGetArray(weapons_data,wpn_id,weapon_info)
  3300.  
  3301. copy(weapon_name,len,weapon_info[MAX_NAME_LENGTH])
  3302. }
  3303.  
  3304. /*
  3305. *
  3306. * API
  3307. *
  3308. */
  3309.  
  3310. #define CHECK_PLAYER(%1) \
  3311. if (%1 < 1 || %1 > MaxClients) { \
  3312. log_error(AMX_ERR_NATIVE, "Player out of range (%d)", %1); \
  3313. return 0; \
  3314. } else { \
  3315. if (!is_user_connected(%1) || pev_valid(%1) != 2) { \
  3316. log_error(AMX_ERR_NATIVE, "Invalid player %d", %1); \
  3317. return 0; \
  3318. } \
  3319. }
  3320.  
  3321. #define CHECK_PLAYERRANGE(%1) \
  3322. if(%1 < 0 || %1 > MaxClients) {\
  3323. log_error(AMX_ERR_NATIVE,"Player out of range (%d)",%1);\
  3324. return 0;\
  3325. }
  3326.  
  3327. #define CHECK_WEAPON(%1) \
  3328. if(!(0 <= %1 < ArraySize(weapons_data))){\
  3329. log_error(AMX_ERR_NATIVE,"Invalid weapon id %d",%1);\
  3330. return 0;\
  3331. }
  3332.  
  3333. public plugin_natives()
  3334. {
  3335. // default csstats
  3336. register_library("xstats")
  3337.  
  3338. register_native("get_user_wstats","native_get_user_wstats")
  3339. register_native("get_user_wrstats","native_get_user_wrstats")
  3340. register_native("get_user_stats","native_get_user_stats")
  3341. register_native("get_user_rstats","native_get_user_rstats")
  3342. register_native("get_user_vstats","native_get_user_vstats")
  3343. register_native("get_user_astats","native_get_user_astats")
  3344. register_native("reset_user_wstats","native_reset_user_wstats")
  3345. register_native("get_stats","native_get_stats")
  3346. register_native("get_statsnum","native_get_statsnum")
  3347. register_native("get_user_stats2","native_get_user_stats2")
  3348. register_native("get_stats2","native_get_stats2")
  3349.  
  3350. register_native("xmod_is_melee_wpn","native_xmod_is_melee_wpn")
  3351. register_native("xmod_get_wpnname","native_xmod_get_wpnname")
  3352. register_native("xmod_get_wpnlogname","native_xmod_get_wpnlogname")
  3353. register_native("xmod_get_maxweapons","native_xmod_get_maxweapons")
  3354. register_native("xmod_get_stats_size","native_get_statsnum")
  3355. register_native("get_map_objectives","native_get_map_objectives")
  3356.  
  3357. register_native("custom_weapon_add","native_custom_weapon_add")
  3358. register_native("custom_weapon_dmg","native_custom_weapon_dmg")
  3359. register_native("custom_weapon_shot","native_custom_weapon_shot")
  3360.  
  3361. register_library("csstatsx_sql")
  3362.  
  3363. // csstats mysql
  3364. register_native("get_statsnum_sql","native_get_statsnum")
  3365. register_native("get_user_stats_sql","native_get_user_stats")
  3366. register_native("get_stats_sql","native_get_stats")
  3367. register_native("get_stats_sql_thread","native_get_stats_thread")
  3368. register_native("get_stats2_sql","native_get_stats2")
  3369. register_native("get_user_skill","native_get_user_skill")
  3370. register_native("get_skill","native_get_skill")
  3371.  
  3372. // 0.5.1
  3373. register_native("get_user_gametime","native_get_user_gametime")
  3374. register_native("get_stats_gametime","native_get_stats_gametime")
  3375. register_native("get_user_stats_id","native_get_user_stats_id")
  3376. register_native("get_stats_id","native_get_stats_id")
  3377. register_native("update_stats_cache","native_update_stats_cache")
  3378.  
  3379. // 0.7
  3380. register_native("get_user_stats3_sql","native_get_user_stats3")
  3381. register_native("get_stats3_sql","native_get_stats3")
  3382. register_native("get_user_wstats_sql","native_get_user_wstats_sql")
  3383. register_native("get_sestats_thread_sql","native_get_sestats_thread_sql")
  3384. register_native("get_sestats_read_count","native_get_sestats_read_count")
  3385. register_native("get_sestats_read_stats","native_get_sestats_read_stats")
  3386. register_native("get_sestats_read_stats2","native_get_sestats_read_stats2")
  3387. register_native("get_sestats_read_stats3","native_get_sestats_read_stats3")
  3388. register_native("get_sestats_read_online","native_get_sestats_read_online")
  3389. register_native("get_sestats_read_skill","native_get_sestats_read_skill")
  3390. register_native("get_sestats_read_map","native_get_sestats_read_map")
  3391. register_native("get_sestats_read_stime","native_get_sestats_read_stime")
  3392. register_native("get_sestats_read_etime","native_get_sestats_read_etime")
  3393. register_native("get_sestats_free","native_get_sestats_free")
  3394. register_native("get_user_firstjoin_sql","native_get_user_firstjoin_sql")
  3395. register_native("get_user_lastjoin_sql","native_get_user_lastjoin_sql")
  3396.  
  3397. // 0.7.2
  3398. register_native("xmod_get_maxweapons_sql","native_xmod_get_maxweapons")
  3399. }
  3400.  
  3401. public native_get_user_firstjoin_sql(plugin_id,params)
  3402. {
  3403. new id = get_param(1)
  3404. CHECK_PLAYERRANGE(id)
  3405.  
  3406. if(player_data[id][PLAYER_LOADSTATE] == LOAD_NO)
  3407. {
  3408. return -1
  3409. }
  3410.  
  3411. return player_data[id][PLAYER_FIRSTJOIN]
  3412. }
  3413.  
  3414. public native_get_user_lastjoin_sql(plugin_id,params)
  3415. {
  3416. new id = get_param(1)
  3417. CHECK_PLAYERRANGE(id)
  3418.  
  3419. if(player_data[id][PLAYER_LOADSTATE] == LOAD_NO)
  3420. {
  3421. return -1
  3422. }
  3423.  
  3424. return player_data[id][PLAYER_LASTJOIN]
  3425. }
  3426.  
  3427. public native_get_sestats_read_stime(plugin_id,params)
  3428. {
  3429. new Array:sestats = Array:get_param(1)
  3430. new index = get_param(2)
  3431.  
  3432. new sestats_size = ArraySize(sestats)
  3433.  
  3434. if(!(0 <= index < sestats_size))
  3435. {
  3436. log_error(AMX_ERR_NATIVE,"Stats index out of range (%d)",index)
  3437. return 0
  3438. }
  3439.  
  3440. new sestats_data[sestats_array_struct]
  3441. ArrayGetArray(sestats,index,sestats_data)
  3442.  
  3443. return sestats_data[SESTATS_FIRSTJOIN]
  3444. }
  3445.  
  3446. public native_get_sestats_read_etime(plugin_id,params)
  3447. {
  3448. new Array:sestats = Array:get_param(1)
  3449. new index = get_param(2)
  3450.  
  3451. new sestats_size = ArraySize(sestats)
  3452.  
  3453. if(!(0 <= index < sestats_size))
  3454. {
  3455. log_error(AMX_ERR_NATIVE,"Stats index out of range (%d)",index)
  3456. return 0
  3457. }
  3458.  
  3459. new sestats_data[sestats_array_struct]
  3460. ArrayGetArray(sestats,index,sestats_data)
  3461.  
  3462. return sestats_data[SESTATS_LASTJOIN]
  3463. }
  3464.  
  3465. public native_get_sestats_free(plugin_id,params)
  3466. {
  3467. new sestats = get_param_byref(1)
  3468. ArrayDestroy(Array:sestats)
  3469. set_param_byref(1,0)
  3470. return true
  3471. }
  3472.  
  3473. public native_get_sestats_read_map(plugin_id,params)
  3474. {
  3475. new Array:sestats = Array:get_param(1)
  3476. new index = get_param(2)
  3477. new length = get_param(4)
  3478.  
  3479. new sestats_size = ArraySize(sestats)
  3480.  
  3481. if(!(0 <= index < sestats_size))
  3482. {
  3483. log_error(AMX_ERR_NATIVE,"Stats index out of range (%d)",index)
  3484. return 0
  3485. }
  3486.  
  3487. new sestats_data[sestats_array_struct]
  3488. ArrayGetArray(sestats,index,sestats_data)
  3489.  
  3490. return set_string(3,sestats_data[SESTATS_MAP],length)
  3491. }
  3492.  
  3493. public Float:native_get_sestats_read_skill(plugin_id,params)
  3494. {
  3495. new Array:sestats = Array:get_param(1)
  3496. new index = get_param(2)
  3497.  
  3498. new sestats_size = ArraySize(sestats)
  3499.  
  3500. if(!(0 <= index < sestats_size))
  3501. {
  3502. log_error(AMX_ERR_NATIVE,"Stats index out of range (%d)",index)
  3503. return 0.0
  3504. }
  3505.  
  3506. new sestats_data[sestats_array_struct]
  3507. ArrayGetArray(sestats,index,sestats_data)
  3508.  
  3509. return sestats_data[SESTATS_SKILL]
  3510. }
  3511.  
  3512. public native_get_sestats_read_online(plugin_id,params)
  3513. {
  3514. new Array:sestats = Array:get_param(1)
  3515. new index = get_param(2)
  3516.  
  3517. new sestats_size = ArraySize(sestats)
  3518.  
  3519. if(!(0 <= index < sestats_size))
  3520. {
  3521. log_error(AMX_ERR_NATIVE,"Stats index out of range (%d)",index)
  3522. return 0
  3523. }
  3524.  
  3525. new sestats_data[sestats_array_struct]
  3526. ArrayGetArray(sestats,index,sestats_data)
  3527.  
  3528. return sestats_data[SESTATS_ONLINETIME]
  3529. }
  3530.  
  3531. public native_get_sestats_read_stats(plugin_id,params)
  3532. {
  3533. new Array:sestats = Array:get_param(1)
  3534. new index = get_param(2)
  3535.  
  3536. new sestats_size = ArraySize(sestats)
  3537.  
  3538. if(!(0 <= index < sestats_size))
  3539. {
  3540. log_error(AMX_ERR_NATIVE,"Stats index out of range (%d)",index)
  3541. return 0
  3542. }
  3543.  
  3544. new sestats_data[sestats_array_struct]
  3545. ArrayGetArray(sestats,index,sestats_data)
  3546.  
  3547. set_array(3,sestats_data[SESTATS_STATS],8)
  3548. set_array(4,sestats_data[SESTATS_HITS],8)
  3549.  
  3550. index ++
  3551.  
  3552. return (index >= sestats_size) ? 0 : index
  3553. }
  3554.  
  3555. public native_get_sestats_read_stats2(plugin_id,params)
  3556. {
  3557. new Array:sestats = Array:get_param(1)
  3558. new index = get_param(2)
  3559.  
  3560. new sestats_size = ArraySize(sestats)
  3561.  
  3562. if(!(0 <= index < sestats_size))
  3563. {
  3564. log_error(AMX_ERR_NATIVE,"Stats index out of range (%d)",index)
  3565. return 0
  3566. }
  3567.  
  3568. new sestats_data[sestats_array_struct]
  3569. ArrayGetArray(sestats,index,sestats_data)
  3570.  
  3571. set_array(3,sestats_data[SESTATS_STATS2],4)
  3572.  
  3573. index ++
  3574.  
  3575. return (index >= sestats_size) ? 0 : index
  3576. }
  3577.  
  3578. public native_get_sestats_read_stats3(plugin_id,params)
  3579. {
  3580. new Array:sestats = Array:get_param(1)
  3581. new index = get_param(2)
  3582.  
  3583. new sestats_size = ArraySize(sestats)
  3584.  
  3585. if(!(0 < index < sestats_size))
  3586. {
  3587. log_error(AMX_ERR_NATIVE,"Stats index out of range (%d)",index)
  3588. return 0
  3589. }
  3590.  
  3591. new sestats_data[sestats_array_struct]
  3592. ArrayGetArray(sestats,index,sestats_data)
  3593.  
  3594. set_array(3,sestats_data[SESTATS_STATS3],STATS3_END)
  3595.  
  3596. index ++
  3597.  
  3598. return (index >= sestats_size) ? 0 : index
  3599. }
  3600.  
  3601. public native_get_sestats_read_count(plugin_id,params)
  3602. {
  3603. new Array:sestats = Array:get_param(1)
  3604.  
  3605. return ArraySize(sestats)
  3606. }
  3607.  
  3608. public native_get_sestats_thread_sql(plugin_id,params)
  3609. {
  3610. // статистика по картам выключена
  3611. if(session_id == 0)
  3612. {
  3613. return false
  3614. }
  3615.  
  3616. new callback_func[32]
  3617. get_string(2,callback_func,charsmax(callback_func))
  3618.  
  3619. new func_id = get_func_id(callback_func,plugin_id)
  3620.  
  3621. // функция ответа не найдена
  3622. if(func_id == -1)
  3623. {
  3624. log_error(AMX_ERR_NATIVE,"Callback function ^"%s^" not found",callback_func)
  3625. return false
  3626. }
  3627.  
  3628. new data_size = get_param(4)
  3629.  
  3630. if(data_size > MAX_DATA_PARAMS)
  3631. {
  3632. log_error(AMX_ERR_NATIVE,"Max data size %d reached.",MAX_DATA_PARAMS)
  3633. return false
  3634. }
  3635.  
  3636. // подготавливаем данные
  3637. new sql_data[3 + MAX_DATA_PARAMS],data_array[MAX_DATA_PARAMS]
  3638.  
  3639. sql_data[0] = SQL_GETSESTATS
  3640. sql_data[1] = func_id
  3641. sql_data[2] = plugin_id
  3642.  
  3643. // передаваемые данные
  3644. if(data_size)
  3645. {
  3646. get_array(3,data_array,data_size)
  3647.  
  3648. for(new i ; i < data_size ; i++)
  3649. {
  3650. sql_data[i + 3] = data_array[i]
  3651. }
  3652. }
  3653.  
  3654. new player_db_id = get_param(1) // ищем по ID игрока
  3655. new limit = get_param(5) // лимит на выборку
  3656.  
  3657. new query[QUERY_LENGTH]
  3658.  
  3659. formatex(query,charsmax(query),"SELECT * FROM `%s_maps` WHERE `%s` = '%d' ORDER BY `%s` DESC LIMIT %d",
  3660. tbl_name,
  3661. row_weapons_names[ROW_WEAPON_PLAYER],player_db_id,
  3662. row_names[ROW_FIRSTJOIN],limit
  3663. )
  3664. SQL_ThreadQuery(sql,"SQL_Handler",query,sql_data,3 + data_size)
  3665.  
  3666. return true
  3667. }
  3668.  
  3669. public native_get_user_wstats_sql(plugin_id,params)
  3670. {
  3671. if(params != 4)
  3672. {
  3673. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 4, passed %d",params)
  3674.  
  3675. return false
  3676. }
  3677.  
  3678. if(!weapon_stats_enabled)
  3679. {
  3680. return -1
  3681. }
  3682.  
  3683. new player_id = get_param(1)
  3684. CHECK_PLAYERRANGE(player_id)
  3685.  
  3686. new weapon_id = get_param(2)
  3687. CHECK_WEAPON(weapon_id)
  3688.  
  3689. new stats[8],bh[8]
  3690.  
  3691. const stats_index_last = (STATS_END + HIT_END)
  3692.  
  3693. for(new i ; i < STATS_END ; i++)
  3694. {
  3695. stats[i] = player_awstats[player_id][weapon_id][i] + player_awstats[player_id][weapon_id][i + stats_index_last]
  3696. }
  3697.  
  3698. // игрок не пользовался этим оружием
  3699. if(!stats[STATS_DEATHS] && !stats[STATS_SHOTS])
  3700. {
  3701. return false
  3702. }
  3703.  
  3704. for(new i = STATS_END ; i < (STATS_END + HIT_END) ; i ++)
  3705. {
  3706. bh[(i - STATS_END)] = player_awstats[player_id][weapon_id][i] + player_awstats[player_id][weapon_id][i + stats_index_last]
  3707. }
  3708.  
  3709. set_array(3,stats,sizeof stats)
  3710. set_array(4,bh,sizeof bh)
  3711.  
  3712. return true
  3713. }
  3714.  
  3715. public native_update_stats_cache()
  3716. {
  3717. return Cache_Stats_Update()
  3718. }
  3719.  
  3720. /*
  3721. * Функция возвращает онлайн время игрока
  3722. *
  3723. * native get_user_gametime(id)
  3724. */
  3725. public native_get_user_gametime(plugin_id,params)
  3726. {
  3727. new id = get_param(1)
  3728. CHECK_PLAYERRANGE(id)
  3729.  
  3730. if(player_data[id][PLAYER_LOADSTATE] == LOAD_NO)
  3731. {
  3732. return -1
  3733. }
  3734.  
  3735. return player_data[id][PLAYER_ONLINE]
  3736. }
  3737.  
  3738. /*
  3739. * Получение времени по позиции
  3740. *
  3741. * native get_stats_gametime(index,&game_time)
  3742. */
  3743. public native_get_stats_gametime(plugin_id,params)
  3744. {
  3745. new index = get_param(1) // индекс в статистике
  3746.  
  3747. // кеширование
  3748. new index_str[10],stats_cache[stats_cache_struct]
  3749. num_to_str(index,index_str,charsmax(index_str))
  3750.  
  3751. // есть информация в кеше
  3752. if(stats_cache_trie && TrieGetArray(stats_cache_trie,index_str,stats_cache,stats_cache_struct))
  3753. {
  3754. set_param_byref(2,stats_cache[CACHE_TIME])
  3755. return !stats_cache[CACHE_LAST] ? index + 1 : 0
  3756. }
  3757. // кеширование
  3758.  
  3759. return 0
  3760. }
  3761.  
  3762.  
  3763. /*
  3764. * Функция возрващает ID игрока в БД
  3765. *
  3766. * native get_user_stats_id(id)
  3767. */
  3768. public native_get_user_stats_id(plugin_id,params)
  3769. {
  3770. new id = get_param(1)
  3771. CHECK_PLAYERRANGE(id)
  3772.  
  3773. return player_data[id][PLAYER_ID]
  3774. }
  3775.  
  3776. /*
  3777. * Получение ID по позиции
  3778. *
  3779. * native get_stats_id(index,&db_id)
  3780. */
  3781. public native_get_stats_id(plugin_id,params)
  3782. {
  3783. new index = get_param(1) // индекс в статистике
  3784.  
  3785. // кеширование
  3786. new index_str[10],stats_cache[stats_cache_struct]
  3787. num_to_str(index,index_str,charsmax(index_str))
  3788.  
  3789. // есть информация в кеше
  3790. if(stats_cache_trie && TrieGetArray(stats_cache_trie,index_str,stats_cache,stats_cache_struct))
  3791. {
  3792. set_param_byref(2,stats_cache[CACHE_ID])
  3793. return !stats_cache[CACHE_LAST] ? index + 1 : 0
  3794. }
  3795. // кеширование
  3796.  
  3797. return 0
  3798. }
  3799.  
  3800. /*
  3801. * Функция возрващает скилл игрока
  3802. *
  3803. * native get_user_skill(player,&Float:skill)
  3804. */
  3805. public native_get_user_skill(plugin_id,params)
  3806. {
  3807. new id = get_param(1)
  3808. CHECK_PLAYERRANGE(id)
  3809.  
  3810. set_float_byref(2,player_data[id][PLAYER_SKILL])
  3811.  
  3812. return true
  3813. }
  3814.  
  3815.  
  3816. /*
  3817. * Получение скилла по позиции
  3818. *
  3819. * native get_skill(index,&Float:skill)
  3820. */
  3821. public native_get_skill(plugin_id,params)
  3822. {
  3823. new index = get_param(1) // индекс в статистике
  3824.  
  3825. // кеширование
  3826. new index_str[10],stats_cache[stats_cache_struct]
  3827.  
  3828. if(index < 0)
  3829. index = 0
  3830.  
  3831. num_to_str(index,index_str,charsmax(index_str))
  3832.  
  3833. // есть информация в кеше
  3834. if(stats_cache_trie && TrieGetArray(stats_cache_trie,index_str,stats_cache,stats_cache_struct))
  3835. {
  3836. set_float_byref(2,Float:stats_cache[CACHE_SKILL])
  3837. return !stats_cache[CACHE_LAST] ? index + 1 : 0
  3838. }
  3839. // кеширование
  3840.  
  3841. return 0
  3842. }
  3843.  
  3844. /*
  3845. * Добавление кастомного оружия для статистики
  3846. *
  3847. * native custom_weapon_add(const wpnname[], melee = 0, const logname[] = "")
  3848. */
  3849. public native_custom_weapon_add(plugin_id,params)
  3850. {
  3851. if(ArraySize(weapons_data) >= MAX_WEAPONS)
  3852. {
  3853. return 0
  3854. }
  3855.  
  3856. new weapon_name[MAX_NAME_LENGTH],weapon_log[MAX_NAME_LENGTH],is_melee
  3857. get_string(1,weapon_name,charsmax(weapon_name))
  3858.  
  3859. if(params >= 2) // задан флаг is_melee
  3860. is_melee = get_param(2)
  3861.  
  3862. if(params == 3) // указан лог код
  3863. {
  3864. get_string(3,weapon_log,charsmax(weapon_log))
  3865. }
  3866. else // копируем название оружия для лог кода
  3867. {
  3868. copy(weapon_log,charsmax(weapon_log),weapon_name)
  3869. }
  3870.  
  3871. // регистриурем
  3872. new weapon_info[WEAPON_INFO_SIZE]
  3873. REG_INFO(is_melee,weapon_name,weapon_info)
  3874.  
  3875. return ArraySize(weapons_data) - 1
  3876. }
  3877.  
  3878. /*
  3879. * Учет урона кастомного оружия
  3880. *
  3881. * native custom_weapon_dmg(weapon, att, vic, damage, hitplace = 0)
  3882. */
  3883. public native_custom_weapon_dmg(plugin_id,params)
  3884. {
  3885. new weapon_id = get_param(1)
  3886.  
  3887. CHECK_WEAPON(weapon_id)
  3888.  
  3889. new att = get_param(2)
  3890.  
  3891. CHECK_PLAYERRANGE(att)
  3892.  
  3893. new vic = get_param(3)
  3894.  
  3895. CHECK_PLAYERRANGE(vic)
  3896.  
  3897. new dmg = get_param(4)
  3898.  
  3899. if(dmg < 1)
  3900. {
  3901. log_error(AMX_ERR_NATIVE,"Invalid damage %d", dmg)
  3902.  
  3903. return 0
  3904. }
  3905.  
  3906. new hit_place = get_param(5)
  3907.  
  3908. return Stats_SaveHit(att,vic,dmg,weapon_id,hit_place)
  3909. }
  3910.  
  3911. /*
  3912. * Регистрация выстрела кастомного оружия
  3913. *
  3914. * native custom_weapon_shot(weapon, index)
  3915. */
  3916. public native_custom_weapon_shot(plugin_id,params)
  3917. {
  3918. new weapon_id = get_param(1)
  3919.  
  3920. CHECK_WEAPON(weapon_id)
  3921.  
  3922. new id = get_param(2)
  3923.  
  3924. CHECK_PLAYERRANGE(id)
  3925.  
  3926. return Stats_SaveShot(id,weapon_id)
  3927. }
  3928.  
  3929. /*
  3930. * Возвращает true, если оружие рукопашного боя
  3931. *
  3932. * native xmod_is_melee_wpn(wpnindex)
  3933. */
  3934. public native_xmod_is_melee_wpn(plugin_id,params)
  3935. {
  3936. new wpn_id = get_param(1)
  3937.  
  3938. CHECK_WEAPON(wpn_id)
  3939.  
  3940. new weapon_info[WEAPON_INFO_SIZE]
  3941. ArrayGetArray(weapons_data,wpn_id,weapon_info)
  3942.  
  3943. return weapon_info[0]
  3944. }
  3945.  
  3946. /*
  3947. * Получение полного названия оружия
  3948. *
  3949. * native xmod_get_wpnname(wpnindex, name[], len)
  3950. */
  3951. public native_xmod_get_wpnname(plugin_id,params)
  3952. {
  3953. new wpn_id = get_param(1)
  3954.  
  3955. CHECK_WEAPON(wpn_id)
  3956.  
  3957. new weapon_info[WEAPON_INFO_SIZE]
  3958. ArrayGetArray(weapons_data,wpn_id,weapon_info)
  3959.  
  3960. new weapon_name[MAX_NAME_LENGTH]
  3961. copy(weapon_name,charsmax(weapon_name),weapon_info[1])
  3962.  
  3963. set_string(2,weapon_name,get_param(3))
  3964.  
  3965. return strlen(weapon_name)
  3966. }
  3967.  
  3968. /*
  3969. * Получение лог кода для оружия
  3970. *
  3971. * native xmod_get_wpnlogname(wpnindex, name[], len)
  3972. */
  3973. public native_xmod_get_wpnlogname(plugin_id,params)
  3974. {
  3975. new wpn_id = get_param(1)
  3976. CHECK_WEAPON(wpn_id)
  3977.  
  3978. new weapon_name[MAX_NAME_LENGTH]
  3979. Info_Weapon_GetLog(wpn_id,weapon_name,get_param(3))
  3980.  
  3981. set_string(2,weapon_name,get_param(3))
  3982.  
  3983. return strlen(weapon_name)
  3984. }
  3985.  
  3986. /*
  3987. * Возврашение общего количества оружия для статистики
  3988. *
  3989. * native xmod_get_maxweapons()
  3990. */
  3991. public native_xmod_get_maxweapons(plugin_id,params)
  3992. {
  3993. return ArraySize(weapons_data)
  3994. }
  3995.  
  3996. public native_get_map_objectives(plugin_id,params)
  3997. {
  3998. return false
  3999. }
  4000.  
  4001. /*
  4002. * Статистика за текущую сессию
  4003. *
  4004. * native get_user_wstats(index, wpnindex, stats[8], bodyhits[8])
  4005. */
  4006. public native_get_user_wstats(plugin_id,params)
  4007. {
  4008. new id = get_param(1)
  4009.  
  4010. CHECK_PLAYERRANGE(id)
  4011.  
  4012. new wpn_id = get_param(2)
  4013.  
  4014. CHECK_WEAPON(wpn_id)
  4015.  
  4016. new stats[8],bh[8]
  4017. get_user_wstats(id,wpn_id,stats,bh)
  4018.  
  4019. set_array(3,stats,STATS_END)
  4020. set_array(4,bh,HIT_END)
  4021.  
  4022. return (stats[STATS_DEATHS] || stats[STATS_SHOTS])
  4023. }
  4024.  
  4025. /*
  4026. * Статистика за текущий раунд
  4027. *
  4028. * native get_user_wrstats(index, wpnindex, stats[8], bodyhits[8])
  4029. */
  4030. public native_get_user_wrstats(plugin_id,params)
  4031. {
  4032. new id = get_param(1)
  4033.  
  4034. CHECK_PLAYERRANGE(id)
  4035.  
  4036. new wpn_id = get_param(2)
  4037.  
  4038. CHECK_WEAPON(wpn_id)
  4039.  
  4040. if(wpn_id != 0 && !(0 < wpn_id < MAX_WEAPONS))
  4041. {
  4042. log_error(AMX_ERR_NATIVE,"Weapon index out of bounds (%d)",id)
  4043.  
  4044. return false
  4045. }
  4046.  
  4047. new stats[8],bh[8]
  4048. get_user_wrstats(id,wpn_id,stats,bh)
  4049.  
  4050. set_array(3,stats,STATS_END)
  4051. set_array(4,bh,HIT_END)
  4052.  
  4053. return (stats[STATS_DEATHS] || stats[STATS_SHOTS])
  4054. }
  4055.  
  4056.  
  4057. /*
  4058. * Получение статистики игрока
  4059. *
  4060. * native get_user_stats(index, stats[8], bodyhits[8])
  4061. */
  4062. public native_get_user_stats(plugin_id,params)
  4063. {
  4064. new id = get_param(1)
  4065.  
  4066. CHECK_PLAYERRANGE(id)
  4067.  
  4068. if(player_data[id][PLAYER_LOADSTATE] < LOAD_OK) // данные отсутствуют
  4069. {
  4070. return 0
  4071. }
  4072.  
  4073. set_array(2,player_data[id][PLAYER_STATS],8)
  4074. set_array(3,player_data[id][PLAYER_HITS],8)
  4075.  
  4076. return player_data[id][PLAYER_RANK]
  4077. }
  4078.  
  4079. /*
  4080. * Статистика за текущий раунд
  4081. *
  4082. * native get_user_rstats(index, stats[8], bodyhits[8])
  4083. */
  4084. public native_get_user_rstats(plugin_id,params)
  4085. {
  4086. new id = get_param(1)
  4087.  
  4088. CHECK_PLAYERRANGE(id)
  4089.  
  4090. new stats[8],bh[8]
  4091. get_user_rstats(id,stats,bh)
  4092.  
  4093. set_array(2,stats,STATS_END)
  4094. set_array(3,bh,HIT_END)
  4095.  
  4096. return (stats[STATS_DEATHS] || stats[STATS_SHOTS])
  4097. }
  4098. /*
  4099. * Статистика по жертвам
  4100. *
  4101. * native get_user_vstats(index, victim, stats[8], bodyhits[8], wpnname[] = "", len = 0);
  4102. */
  4103. public native_get_user_vstats(plugin_id,params)
  4104. {
  4105. if(params != 6)
  4106. {
  4107. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 6, passed %d",params)
  4108.  
  4109. return false
  4110. }
  4111.  
  4112. new id = get_param(1)
  4113. new victim = get_param(2)
  4114.  
  4115. CHECK_PLAYERRANGE(id)
  4116. CHECK_PLAYERRANGE(victim)
  4117.  
  4118. new stats[STATS_END],hits[HIT_END],wname[MAX_NAME_LENGTH]
  4119. unpack_vstats(id,victim,stats,hits,wname,charsmax(wname))
  4120.  
  4121. set_array(3,stats,STATS_END)
  4122. set_array(4,hits,HIT_END)
  4123. set_string(5,wname,get_param(6))
  4124.  
  4125. return (stats[STATS_KILLS] || stats[STATS_HITS])
  4126. }
  4127.  
  4128.  
  4129. unpack_vstats(killer,victim,stats[STATS_END],hits[HIT_END],vname[],vname_len)
  4130. {
  4131. new i,stats_i
  4132.  
  4133. for(i = 0; i < STATS_END ; i++,stats_i++)
  4134. {
  4135. stats[i]= player_vstats[killer][victim][stats_i]
  4136. }
  4137.  
  4138. for(i = 0; i < HIT_END ; i++,stats_i++)
  4139. {
  4140. hits[i]= player_vstats[killer][victim][stats_i]
  4141. }
  4142.  
  4143. copy(vname,vname_len,player_vstats[killer][victim][stats_i])
  4144. }
  4145.  
  4146. unpack_astats(attacker,victim,stats[STATS_END],hits[HIT_END],vname[],vname_len)
  4147. {
  4148. new i,stats_i
  4149.  
  4150. for(i = 0; i < STATS_END ; i++,stats_i++)
  4151. {
  4152. stats[i]= player_astats[victim][attacker][stats_i]
  4153. }
  4154.  
  4155. for(i = 0; i < HIT_END ; i++,stats_i++)
  4156. {
  4157. hits[i]= player_astats[victim][attacker][stats_i]
  4158. }
  4159.  
  4160. copy(vname,vname_len,player_astats[victim][attacker][stats_i])
  4161. }
  4162.  
  4163. /*
  4164. * Статистика по врагам
  4165. *
  4166. * native get_user_astats(index, victim, stats[8], bodyhits[8], wpnname[] = "", len = 0);
  4167. */
  4168. public native_get_user_astats(plugin_id,params)
  4169. {
  4170. if(params != 6)
  4171. {
  4172. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 6, passed %d",params)
  4173.  
  4174. return false
  4175. }
  4176.  
  4177. new id = get_param(1)
  4178. new attacker = get_param(2)
  4179.  
  4180. CHECK_PLAYERRANGE(id)
  4181. CHECK_PLAYERRANGE(attacker)
  4182.  
  4183. new stats[STATS_END],hits[HIT_END],wname[MAX_NAME_LENGTH]
  4184. unpack_astats(attacker,id,stats,hits,wname,charsmax(wname))
  4185.  
  4186. set_array(3,stats,STATS_END)
  4187. set_array(4,hits,HIT_END)
  4188. set_string(5,wname,get_param(6))
  4189.  
  4190. return (stats[STATS_KILLS] || stats[STATS_HITS])
  4191. }
  4192.  
  4193. public native_reset_user_wstats()
  4194. {
  4195. new id = get_param(1)
  4196.  
  4197. CHECK_PLAYERRANGE(id)
  4198.  
  4199. return reset_user_wstats(id)
  4200. }
  4201.  
  4202. /*
  4203. * Возвращает общее количество записей в базе данных
  4204. *
  4205. * native get_statsnum()
  4206. */
  4207. public native_get_statsnum(plugin_id,params)
  4208. {
  4209. return statsnum
  4210. }
  4211.  
  4212. /*
  4213. * Получение статистик по позиции
  4214. *
  4215. * native get_stats(index, stats[8], bodyhits[8], name[], len, authid[] = "", authidlen = 0);
  4216. */
  4217. public native_get_stats(plugin_id,params)
  4218. {
  4219. // ждем начала работы с БД
  4220. if(!is_ready)
  4221. {
  4222. return 0
  4223. }
  4224.  
  4225. if(params < 5)
  4226. {
  4227. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 5, passed %d",params)
  4228.  
  4229. return 0
  4230. }
  4231. else if(params > 5 && params != 7)
  4232. {
  4233. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 7, passed %d",params)
  4234.  
  4235. return 0
  4236. }
  4237.  
  4238. new index = get_param(1) // индекс в статистике
  4239.  
  4240. // кеширование
  4241. new index_str[10],stats_cache[stats_cache_struct]
  4242. num_to_str(index,index_str,charsmax(index_str))
  4243.  
  4244. // есть информация в кеше
  4245. if(stats_cache_trie && TrieGetArray(stats_cache_trie,index_str,stats_cache,stats_cache_struct))
  4246. {
  4247. set_array(2,stats_cache[CACHE_STATS],sizeof stats_cache[CACHE_STATS])
  4248. set_array(3,stats_cache[CACHE_HITS],sizeof stats_cache[CACHE_HITS])
  4249. set_string(4,stats_cache[CACHE_NAME],get_param(5))
  4250.  
  4251. if(params == 7)
  4252. {
  4253. set_string(6,stats_cache[CACHE_STEAMID],get_param(7))
  4254. }
  4255.  
  4256. return !stats_cache[CACHE_LAST] ? index + 1 : 0
  4257. }
  4258. // кеширование
  4259.  
  4260. /*
  4261. * прямой запрос в БД, в случае если нету данных в кеше
  4262. */
  4263.  
  4264. // открываем соединение с БД для получения актуальных данных
  4265. if(!DB_OpenConnection())
  4266. {
  4267. return false // ошибка открытия соединения
  4268. }
  4269. else
  4270. {
  4271. // задание на сброс содеинения
  4272. // чтобы не открывать новые и успеть получить сразу несколько данных за одно соединение
  4273. if(!task_exists(task_confin))
  4274. {
  4275. set_task(0.1,"DB_CloseConnection",task_confin)
  4276. }
  4277. }
  4278.  
  4279. // подготавливаем запрос в БД
  4280. new query[QUERY_LENGTH]
  4281. DB_QueryBuildGetstats(query,charsmax(query),.index = index)
  4282. new Handle:sqlQue = SQL_PrepareQuery(sql_con,query)
  4283.  
  4284. // ошибка выполнения запроса
  4285. if(!SQL_Execute(sqlQue))
  4286. {
  4287. new errNum,err[256]
  4288. errNum = SQL_QueryError(sqlQue,err,charsmax(err))
  4289.  
  4290. log_amx("SQL query failed")
  4291. log_amx("[ %d ] %s",errNum,err)
  4292. log_amx("[ SQL ] %s",query)
  4293.  
  4294. SQL_FreeHandle(sqlQue)
  4295.  
  4296. return 0
  4297. }
  4298.  
  4299. // читаем результат
  4300. new name[32],steamid[30],stats[8],hits[8],stats_count
  4301.  
  4302. DB_ReadGetStats(sqlQue,
  4303. name,charsmax(name),
  4304. steamid,charsmax(steamid),
  4305. stats,
  4306. hits,
  4307. .stats_count = stats_count,
  4308. .index = index
  4309. )
  4310.  
  4311. // статистики нет
  4312. if(!stats_count)
  4313. {
  4314. return false
  4315. }
  4316.  
  4317. SQL_FreeHandle(sqlQue)
  4318.  
  4319. // возвращаем данные натива
  4320. set_array(2,stats,sizeof player_data[][PLAYER_STATS])
  4321. set_array(3,hits,sizeof player_data[][PLAYER_HITS])
  4322. set_string(4,name,get_param(5))
  4323.  
  4324. if(params == 7)
  4325. {
  4326. set_string(6,steamid,get_param(7))
  4327. }
  4328.  
  4329. return stats_count > 1 ? index + 1 : 0
  4330. }
  4331.  
  4332. /*
  4333. * Получение статистик по позиции
  4334. *
  4335. * native get_stats2_sql(index, stats[4], authid[] = "", authidlen = 0)
  4336. */
  4337. public native_get_stats2(plugin_id,params)
  4338. {
  4339. // ждем начала работы с БД
  4340. if(!is_ready)
  4341. {
  4342. return 0
  4343. }
  4344.  
  4345. if(params < 2)
  4346. {
  4347. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 2, passed %d",params)
  4348.  
  4349. return false
  4350. }
  4351. else if(params > 2 && params != 4)
  4352. {
  4353. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 4, passed %d",params)
  4354.  
  4355. return false
  4356. }
  4357.  
  4358. new index = get_param(1) // индекс в статистике
  4359.  
  4360. // кеширование
  4361. new index_str[10],stats_cache[stats_cache_struct]
  4362. num_to_str(index,index_str,charsmax(index_str))
  4363.  
  4364. // есть информация в кеше
  4365. if(stats_cache_trie && TrieGetArray(stats_cache_trie,index_str,stats_cache,stats_cache_struct))
  4366. {
  4367. set_array(2,stats_cache[CACHE_STATS2],sizeof stats_cache[CACHE_STATS2])
  4368.  
  4369. if(params == 4)
  4370. {
  4371. set_string(3,stats_cache[CACHE_STEAMID],get_param(4))
  4372. }
  4373.  
  4374. return !stats_cache[CACHE_LAST] ? index + 1 : 0
  4375. }
  4376. // кеширование
  4377.  
  4378. /*
  4379. * прямой запрос в БД, в случае если нету данных в кеше
  4380. */
  4381.  
  4382. // открываем соединение с БД для получения актуальных данных
  4383. if(!DB_OpenConnection())
  4384. {
  4385. return false // ошибка открытия соединения
  4386. }
  4387. else
  4388. {
  4389. // задание на сброс содеинения
  4390. // чтобы не открывать новые и успеть получить сразу несколько данных за одно соединение
  4391. if(!task_exists(task_confin))
  4392. {
  4393. set_task(0.1,"DB_CloseConnection",task_confin)
  4394. }
  4395. }
  4396.  
  4397. // подготавливаем запрос в БД
  4398. new query[QUERY_LENGTH]
  4399. DB_QueryBuildGetstats(query,charsmax(query),.index = index)
  4400. new Handle:sqlQue = SQL_PrepareQuery(sql_con,query)
  4401.  
  4402. // ошибка выполнения запроса
  4403. if(!SQL_Execute(sqlQue))
  4404. {
  4405. new errNum,err[256]
  4406. errNum = SQL_QueryError(sqlQue,err,charsmax(err))
  4407.  
  4408. log_amx("SQL query failed")
  4409. log_amx("[ %d ] %s",errNum,err)
  4410. log_amx("[ SQL ] %s",query)
  4411.  
  4412. SQL_FreeHandle(sqlQue)
  4413.  
  4414. return 0
  4415. }
  4416.  
  4417. // читаем результат
  4418. new name[32],steamid[30],stats2[4],stats_count
  4419.  
  4420. DB_ReadGetStats(sqlQue,
  4421. name,charsmax(name),
  4422. steamid,charsmax(steamid),
  4423. .stats2 = stats2,
  4424. .stats_count = stats_count,
  4425. .index = index
  4426. )
  4427.  
  4428. // статистики нет
  4429. if(!stats_count)
  4430. {
  4431. return false
  4432. }
  4433.  
  4434. SQL_FreeHandle(sqlQue)
  4435.  
  4436. // возвращаем данные натива
  4437. set_array(2,stats2,sizeof player_data[][PLAYER_STATS2])
  4438.  
  4439. if(params == 4)
  4440. {
  4441. set_string(3,steamid,get_param(4))
  4442. }
  4443.  
  4444. return stats_count > 1 ? index + 1 : 0
  4445. }
  4446.  
  4447. /*
  4448. * Потоковый запрос на получение статистик по позиции
  4449. * id - для кого мы запрашиваем
  4450. * position - позиция
  4451. * top - кол-во
  4452. * callback[] - хандлер ответа
  4453. *
  4454. * native get_stats_sql_thread(id,position,top,callback[]);
  4455. */
  4456. public native_get_stats_thread(plugin_id,params)
  4457. {
  4458. // ждем начала работы с БД
  4459. if(!is_ready)
  4460. {
  4461. return false
  4462. }
  4463.  
  4464. if(params < 4)
  4465. {
  4466. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 4, passed %d",params)
  4467.  
  4468. return false
  4469. }
  4470.  
  4471. new id = get_param(1)
  4472. new position = min(statsnum,get_param(2))
  4473. new top = get_param(3)
  4474. new start_index = max((position - top),0)
  4475.  
  4476. new callback[20]
  4477. get_string(4,callback,charsmax(callback))
  4478.  
  4479. new func_id = get_func_id(callback,plugin_id)
  4480.  
  4481. if(func_id == -1)
  4482. {
  4483. log_error(AMX_ERR_NATIVE,"Unable to locate ^"%s^" handler.",callback)
  4484.  
  4485. return false
  4486. }
  4487.  
  4488. return DB_QueryTop15(id,plugin_id,func_id,position,start_index,top,params)
  4489. }
  4490.  
  4491. // 0.7
  4492. /*
  4493. * Получение статистик по позиции
  4494. *
  4495. * native get_stats3_sql(index, stats3[STATS3_END], authid[] = "", authidlen = 0)
  4496. */
  4497. public native_get_stats3(plugin_id,params)
  4498. {
  4499. // ждем начала работы с БД
  4500. if(!is_ready)
  4501. {
  4502. return 0
  4503. }
  4504.  
  4505. if(params < 2)
  4506. {
  4507. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 2, passed %d",params)
  4508.  
  4509. return false
  4510. }
  4511. else if(params > 2 && params != 4)
  4512. {
  4513. log_error(AMX_ERR_NATIVE,"Bad arguments num, expected 4, passed %d",params)
  4514.  
  4515. return false
  4516. }
  4517.  
  4518. new index = get_param(1) // индекс в статистике
  4519.  
  4520. // кеширование
  4521. new index_str[10],stats_cache[stats_cache_struct]
  4522. num_to_str(index,index_str,charsmax(index_str))
  4523.  
  4524. // есть информация в кеше
  4525. if(stats_cache_trie && TrieGetArray(stats_cache_trie,index_str,stats_cache,stats_cache_struct))
  4526. {
  4527. set_array(2,stats_cache[CACHE_STATS3],sizeof stats_cache[CACHE_STATS3])
  4528.  
  4529. if(params == 4)
  4530. {
  4531. set_string(3,stats_cache[CACHE_STEAMID],get_param(4))
  4532. }
  4533.  
  4534. return !stats_cache[CACHE_LAST] ? index + 1 : 0
  4535. }
  4536. // кеширование
  4537.  
  4538. /*
  4539. * прямой запрос в БД, в случае если нету данных в кеше
  4540. */
  4541.  
  4542. // открываем соединение с БД для получения актуальных данных
  4543. if(!DB_OpenConnection())
  4544. {
  4545. return false // ошибка открытия соединения
  4546. }
  4547. else
  4548. {
  4549. // задание на сброс содеинения
  4550. // чтобы не открывать новые и успеть получить сразу несколько данных за одно соединение
  4551. if(!task_exists(task_confin))
  4552. {
  4553. set_task(0.1,"DB_CloseConnection",task_confin)
  4554. }
  4555. }
  4556.  
  4557. // подготавливаем запрос в БД
  4558. new query[QUERY_LENGTH]
  4559. DB_QueryBuildGetstats(query,charsmax(query),.index = index)
  4560. new Handle:sqlQue = SQL_PrepareQuery(sql_con,query)
  4561.  
  4562. // ошибка выполнения запроса
  4563. if(!SQL_Execute(sqlQue))
  4564. {
  4565. new errNum,err[256]
  4566. errNum = SQL_QueryError(sqlQue,err,charsmax(err))
  4567.  
  4568. log_amx("SQL query failed")
  4569. log_amx("[ %d ] %s",errNum,err)
  4570. log_amx("[ SQL ] %s",query)
  4571.  
  4572. SQL_FreeHandle(sqlQue)
  4573.  
  4574. return 0
  4575. }
  4576.  
  4577. // читаем результат
  4578. new name[32],steamid[30],stats3[STATS3_END],stats_count
  4579.  
  4580. DB_ReadGetStats(sqlQue,
  4581. name,charsmax(name),
  4582. steamid,charsmax(steamid),
  4583. .stats3 = stats3,
  4584. .stats_count = stats_count,
  4585. .index = index
  4586. )
  4587.  
  4588. // статистики нет
  4589. if(!stats_count)
  4590. {
  4591. return false
  4592. }
  4593.  
  4594. SQL_FreeHandle(sqlQue)
  4595.  
  4596. // возвращаем данные натива
  4597. set_array(2,stats3,sizeof player_data[][PLAYER_STATS3])
  4598.  
  4599. if(params == 4)
  4600. {
  4601. set_string(3,steamid,get_param(4))
  4602. }
  4603.  
  4604. return stats_count > 1 ? index + 1 : 0
  4605. }
  4606.  
  4607. /*
  4608. * Получение статистик по позиции
  4609. *
  4610. * native get_user_stats3_sql(id,stats3[STATS3_END])
  4611. */
  4612. public native_get_user_stats3(plugin_id,params)
  4613. {
  4614. new id = get_param(1)
  4615.  
  4616. CHECK_PLAYERRANGE(id)
  4617.  
  4618. if(player_data[id][PLAYER_LOADSTATE] < LOAD_OK) // данные отсутствуют
  4619. {
  4620. return 0
  4621. }
  4622.  
  4623. set_array(2,player_data[id][PLAYER_STATS3],STATS3_END)
  4624.  
  4625. return player_data[id][PLAYER_RANK]
  4626. }
  4627.  
  4628. public native_get_user_stats2(plugin_id,params)
  4629. {
  4630. new id = get_param(1)
  4631.  
  4632. CHECK_PLAYERRANGE(id)
  4633.  
  4634. set_array(2,player_data[id][PLAYER_STATS2],sizeof player_data[][PLAYER_STATS2])
  4635.  
  4636. return true
  4637. }
  4638.  
  4639. /*
  4640. *
  4641. * ВСЯКАЯ ХРЕНЬ ДЛЯ САМОСТОЯТЕЛЬНОГО ПРОСЧЕТА СТАТИСТИКИ
  4642. *
  4643. */
  4644.  
  4645. is_tk(killer,victim)
  4646. {
  4647. if(killer == victim)
  4648. return true
  4649.  
  4650. return false
  4651. }
  4652.  
  4653. get_user_wstats(index, wpnindex, stats[8], bh[8])
  4654. {
  4655. for(new i ; i < STATS_END ; i++)
  4656. {
  4657. stats[i] = player_wstats[index][wpnindex][i]
  4658. }
  4659.  
  4660. #define krisa[%1] player_wstats[index][wpnindex][STATS_END + %1]
  4661.  
  4662. for(new i ; i < HIT_END ; i++)
  4663. {
  4664. bh[i] = krisa[i]
  4665. }
  4666. }
  4667.  
  4668. get_user_wrstats(index, wpnindex, stats[8], bh[8])
  4669. {
  4670. for(new i ; i < STATS_END ; i++)
  4671. {
  4672. stats[i] = player_wrstats[index][wpnindex][i]
  4673. }
  4674.  
  4675. for(new i ; i < HIT_END ; i++)
  4676. {
  4677. bh[i] = player_wrstats[index][wpnindex][STATS_END + i]
  4678. }
  4679. }
  4680.  
  4681. get_user_rstats(index, stats[8], bh[8])
  4682. {
  4683. for(new i ; i < STATS_END ; i++)
  4684. {
  4685. stats[i] = player_wrstats[index][0][i]
  4686. }
  4687.  
  4688. for(new i ; i < HIT_END ; i++)
  4689. {
  4690. bh[i] = player_wrstats[index][0][STATS_END + i]
  4691. }
  4692. }
  4693.  
  4694. get_user_stats2(index, stats[4])
  4695. {
  4696. for(new i ; i < STATS2_END ; i++)
  4697. {
  4698. stats[i] = player_wstats2[index][i]
  4699. }
  4700.  
  4701. return true
  4702. }
  4703.  
  4704. reset_user_wstats(index)
  4705. {
  4706. for(new i ; i < MAX_WEAPONS ; i++)
  4707. {
  4708. arrayset(player_wrstats[index][i],0,sizeof player_wrstats[][])
  4709. }
  4710.  
  4711. for(new i ; i < MAX_PLAYERS + 1 ;i++)
  4712. {
  4713. arrayset(player_vstats[index][i],0,sizeof player_vstats[][])
  4714. arrayset(player_astats[index][i],0,sizeof player_astats[][])
  4715. }
  4716.  
  4717. return true
  4718. }
  4719.  
  4720. reset_user_allstats(index)
  4721. {
  4722. for(new i ; i < MAX_WEAPONS ; i++)
  4723. {
  4724. arrayset(player_wstats[index][i],0,sizeof player_wstats[][])
  4725. }
  4726.  
  4727. arrayset(player_wstats2[index],0,sizeof player_wstats2[])
  4728.  
  4729. return true
  4730. }
  4731.  
  4732. public DB_OpenConnection()
  4733. {
  4734. if(!is_ready)
  4735. {
  4736. return false
  4737. }
  4738.  
  4739. if(sql_con != Empty_Handle)
  4740. {
  4741. return true
  4742. }
  4743.  
  4744. new errNum,err[256]
  4745. sql_con = SQL_Connect(sql,errNum,err,charsmax(err))
  4746.  
  4747. #if AMXX_VERSION_NUM >= 183
  4748. SQL_SetCharset(sql_con,"utf8")
  4749. #endif
  4750.  
  4751. if(errNum)
  4752. {
  4753. log_amx("SQL query failed")
  4754. log_amx("[ %d ] %s",errNum,err)
  4755.  
  4756. return false
  4757. }
  4758.  
  4759. return true
  4760. }
  4761.  
  4762. public DB_CloseConnection()
  4763. {
  4764. if(sql_con != Empty_Handle)
  4765. {
  4766. SQL_FreeHandle(sql_con)
  4767. sql_con = Empty_Handle
  4768. }
  4769. }
  4770.  
  4771. /********* mysql escape functions ************/
  4772. mysql_escape_string(dest[],len)
  4773. {
  4774. //copy(dest, len, source);
  4775. replace_all(dest,len,"\\","\\\\");
  4776. replace_all(dest,len,"\0","\\0");
  4777. replace_all(dest,len,"\n","\\n");
  4778. replace_all(dest,len,"\r","\\r");
  4779. replace_all(dest,len,"\x1a","\Z");
  4780. replace_all(dest,len,"'","''");
  4781. replace_all(dest,len,"^"","^"^"");
  4782. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!