test
This commit is contained in:
shoopea
parent
afb12d980b
commit
b0e894221c
@ -10,512 +10,512 @@
|
||||
"obj_type": "guild"
|
||||
},
|
||||
{
|
||||
"intl_id": "unknown",
|
||||
"intl_id": "msg",
|
||||
"name": "Unknown",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "war",
|
||||
"intl_id": "msg_war",
|
||||
"name": "War report",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "guild_war",
|
||||
"intl_id": "msg_guild_war",
|
||||
"name": "Guilds war report",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "report_req",
|
||||
"intl_id": "msg_report_req",
|
||||
"name": "Player war report request",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "report_ack",
|
||||
"intl_id": "msg_report_ack",
|
||||
"name": "Player war report ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "g_report_req",
|
||||
"intl_id": "msg_g_report_req",
|
||||
"name": "Player guilds war report request",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "g_report_ack",
|
||||
"intl_id": "msg_g_report_ack",
|
||||
"name": "Player guilds war report ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "quest_res",
|
||||
"intl_id": "msg_quest_res",
|
||||
"name": "Quest result",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "duel_fight",
|
||||
"intl_id": "msg_duel_fight",
|
||||
"name": "Duel fight result",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "hero_req",
|
||||
"intl_id": "msg_hero_req",
|
||||
"name": "Hero summary request",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "hero_ack",
|
||||
"intl_id": "msg_hero_ack",
|
||||
"name": "Hero summary ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "me_req",
|
||||
"intl_id": "msg_me_req",
|
||||
"name": "Hero short summary request",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "me_ack",
|
||||
"intl_id": "msg_me_ack",
|
||||
"name": "Hero short summary ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "inv_req",
|
||||
"intl_id": "msg_inv_req",
|
||||
"name": "Inventory request",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "inv_ack",
|
||||
"intl_id": "msg_inv_ack",
|
||||
"name": "Inventory ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "pillage_inc",
|
||||
"intl_id": "msg_pillage_inc",
|
||||
"name": "Pillage incoming",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "pillage_go",
|
||||
"intl_id": "msg_pillage_go",
|
||||
"name": "Pillage go",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "pillage_timeout",
|
||||
"intl_id": "msg_pillage_timeout",
|
||||
"name": "Pillage timeout",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "pillage_win",
|
||||
"intl_id": "msg_pillage_win",
|
||||
"name": "Pillage win",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "pillage_loss",
|
||||
"intl_id": "msg_pillage_loss",
|
||||
"name": "Pillage loss",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "tribute_inc",
|
||||
"intl_id": "msg_tribute_inc",
|
||||
"name": "Tribute incoming",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "tribute_ack",
|
||||
"intl_id": "msg_tribute_ack",
|
||||
"name": "Tribute acknowledged",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "auction_announce",
|
||||
"intl_id": "msg_auction_announce",
|
||||
"name": "Auction announce",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "auction_upd_req",
|
||||
"intl_id": "msg_auction_upd_req",
|
||||
"name": "Auction update request",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "auction_upd_ack",
|
||||
"intl_id": "msg_auction_upd_ack",
|
||||
"name": "Auction update acknowledgment",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "time_ack",
|
||||
"intl_id": "msg_time_ack",
|
||||
"name": "Time Acknowledgment",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "time_req",
|
||||
"intl_id": "msg_time_req",
|
||||
"name": "Time Request",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "go",
|
||||
"intl_id": "msg_go",
|
||||
"name": "Go",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "pledge",
|
||||
"intl_id": "msg_pledge",
|
||||
"name": "Pledge",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "go_quest_req",
|
||||
"intl_id": "msg_go_quest_req",
|
||||
"name": "Go quest Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "fast_fight",
|
||||
"intl_id": "msg_fast_fight",
|
||||
"name": "Arena fast fight",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "go_arena",
|
||||
"intl_id": "msg_go_arena",
|
||||
"name": "Go arena",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "top",
|
||||
"intl_id": "msg_top",
|
||||
"name": "Top",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "menu",
|
||||
"intl_id": "msg_menu",
|
||||
"name": "Menu",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "buy_req",
|
||||
"intl_id": "msg_buy_req",
|
||||
"name": "Sell Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "sell_req",
|
||||
"intl_id": "msg_sell_req",
|
||||
"name": "Buy Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "orderbook_req",
|
||||
"intl_id": "msg_orderbook_req",
|
||||
"name": "Orderbook Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "orderbook_acl",
|
||||
"intl_id": "msg_orderbook_acl",
|
||||
"name": "Orderbook Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "withdraw_req",
|
||||
"intl_id": "msg_withdraw_req",
|
||||
"name": "Withdraw Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "withdraw_code",
|
||||
"intl_id": "msg_withdraw_code",
|
||||
"name": "Withdraw Code",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "withdraw_rcv",
|
||||
"intl_id": "msg_withdraw_rcv",
|
||||
"name": "Withdraw Received",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "stock_req",
|
||||
"intl_id": "msg_stock_req",
|
||||
"name": "Stock Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "stock_ack",
|
||||
"intl_id": "msg_stock_ack",
|
||||
"name": "Stock Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "misc_req",
|
||||
"intl_id": "msg_misc_req",
|
||||
"name": "Misc Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "misc_ack",
|
||||
"intl_id": "msg_misc_ack",
|
||||
"name": "Misc Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "union_war",
|
||||
"intl_id": "msg_union_war",
|
||||
"name": "Union war report",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "tureport_req",
|
||||
"intl_id": "msg_tureport_req",
|
||||
"name": "Trade Union War Report Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "tureport_ack",
|
||||
"intl_id": "msg_tureport_ack",
|
||||
"name": "Trade Union War Report Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "timeout",
|
||||
"intl_id": "msg_timeout",
|
||||
"name": "Generic timeout",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "go_quest_ack",
|
||||
"intl_id": "msg_go_quest_ack",
|
||||
"name": "Go Quest Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "groles_req",
|
||||
"intl_id": "msg_groles_req",
|
||||
"name": "Guild roles Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "groles_ack",
|
||||
"intl_id": "msg_groles_ack",
|
||||
"name": "Guild roles Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_res_req",
|
||||
"intl_id": "msg_gstock_res_req",
|
||||
"name": "GStock Res Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_alch_req",
|
||||
"intl_id": "msg_gstock_alch_req",
|
||||
"name": "GStock Alch Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_misc_req",
|
||||
"intl_id": "msg_gstock_misc_req",
|
||||
"name": "GStock Misc Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_rec_req",
|
||||
"intl_id": "msg_gstock_rec_req",
|
||||
"name": "GStock Rec Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_part_req",
|
||||
"intl_id": "msg_gstock_part_req",
|
||||
"name": "GStock Part Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_oth_req",
|
||||
"intl_id": "msg_gstock_oth_req",
|
||||
"name": "Gstock Oth Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_any_ack",
|
||||
"intl_id": "msg_gstock_any_ack",
|
||||
"name": "Gstock Any Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_req",
|
||||
"intl_id": "msg_gstock_req",
|
||||
"name": "GStock Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "gstock_ack",
|
||||
"intl_id": "msg_gstock_ack",
|
||||
"name": "GStock Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "busy",
|
||||
"intl_id": "msg_busy",
|
||||
"name": "Busy",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "res_stock_req",
|
||||
"intl_id": "msg_res_stock_req",
|
||||
"name": "Resources Stock Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "alch_stock_req",
|
||||
"intl_id": "msg_alch_stock_req",
|
||||
"name": "Alchemy Stock Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "misc_stock_req",
|
||||
"intl_id": "msg_misc_stock_req",
|
||||
"name": "Misc Stock Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "equip_stock_req",
|
||||
"intl_id": "msg_equip_stock_req",
|
||||
"name": "Equipment Stock Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "craft_stock_req",
|
||||
"intl_id": "msg_craft_stock_req",
|
||||
"name": "Equipment Stock Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "stock_empty",
|
||||
"intl_id": "msg_stock_empty",
|
||||
"name": "Stock Empty",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "stock_any_ack",
|
||||
"intl_id": "msg_stock_any_ack",
|
||||
"name": "Stock Any Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "g_deposit_req",
|
||||
"intl_id": "msg_g_deposit_req",
|
||||
"name": "GDeposit Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "g_deposit_ack",
|
||||
"intl_id": "msg_g_deposit_ack",
|
||||
"name": "GDeposit Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "castle_attack_req",
|
||||
"intl_id": "msg_castle_attack_req",
|
||||
"name": "Castle Attack Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "castle_attack_ack",
|
||||
"intl_id": "msg_castle_attack_ack",
|
||||
"name": "Castle Attack Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "castle_target_req",
|
||||
"intl_id": "msg_castle_target_req",
|
||||
"name": "Castle Target Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "castle_target_ack",
|
||||
"intl_id": "msg_castle_target_ack",
|
||||
"name": "Castle Target Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "castle_def_req",
|
||||
"intl_id": "msg_castle_def_req",
|
||||
"name": "Castle Defense Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "castle_def_ack",
|
||||
"intl_id": "msg_castle_def_ack",
|
||||
"name": "Castle Defense Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "back",
|
||||
"intl_id": "msg_back",
|
||||
"name": "Back",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "castle_req",
|
||||
"intl_id": "msg_castle_req",
|
||||
"name": "Castle Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "castle_ack",
|
||||
"intl_id": "msg_castle_ack",
|
||||
"name": "Castle Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "exchange_req",
|
||||
"intl_id": "msg_exchange_req",
|
||||
"name": "Exchange Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "exchange_ack",
|
||||
"intl_id": "msg_exchange_ack",
|
||||
"name": "Exchange Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "equip_req",
|
||||
"intl_id": "msg_equip_req",
|
||||
"name": "Equip Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "equip_ack",
|
||||
"intl_id": "msg_equip_ack",
|
||||
"name": "Equip Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "unequip_req",
|
||||
"intl_id": "msg_unequip_req",
|
||||
"name": "Unequip Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "unequip_ack",
|
||||
"intl_id": "msg_unequip_ack",
|
||||
"name": "Unequip Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "no_stamina",
|
||||
"intl_id": "msg_no_stamina",
|
||||
"name": "No Stamina",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "orderbook_search",
|
||||
"intl_id": "msg_orderbook_search",
|
||||
"name": "Orderbook search",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "quest_req",
|
||||
"intl_id": "msg_quest_req",
|
||||
"name": "Quest Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "quest_ack",
|
||||
"intl_id": "msg_quest_ack",
|
||||
"name": "Quest Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "battle",
|
||||
"intl_id": "msg_battle",
|
||||
"name": "Battle",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "order_cancel_req",
|
||||
"intl_id": "msg_order_cancel_req",
|
||||
"name": "Order Cancel Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "order_cancel_ack",
|
||||
"intl_id": "msg_order_cancel_ack",
|
||||
"name": "Order Cancel Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "stamina_restored",
|
||||
"intl_id": "msg_stamina_restored",
|
||||
"name": "Stamina Restored",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "quest_res_ambush",
|
||||
"intl_id": "msg_quest_res_ambush",
|
||||
"name": "Quest result with Ambush",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "heal_up",
|
||||
"intl_id": "msg_heal_up",
|
||||
"name": "Heal Up",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "arena_fight_ack",
|
||||
"intl_id": "msg_arena_fight_ack",
|
||||
"name": "Arena Fight Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "go_arena_ack",
|
||||
"intl_id": "msg_go_arena_ack",
|
||||
"name": "Go Arena Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "withdraw_nack",
|
||||
"intl_id": "msg_withdraw_nack",
|
||||
"name": "Withdraw NAck",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "pillage_defeat",
|
||||
"intl_id": "msg_pillage_defeat",
|
||||
"name": "Pillage Defeat",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "level_up_req",
|
||||
"intl_id": "msg_level_up_req",
|
||||
"name": "Level Up Req",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
{
|
||||
"intl_id": "level_up_ack",
|
||||
"intl_id": "msg_level_up_ack",
|
||||
"name": "Level Up Ack",
|
||||
"obj_type": "msg"
|
||||
},
|
||||
@ -670,17 +670,17 @@
|
||||
"obj_type": "xp"
|
||||
},
|
||||
{
|
||||
"intl_id": "forest",
|
||||
"intl_id": "quest_forest",
|
||||
"name": "Forest",
|
||||
"obj_type": "quest"
|
||||
},
|
||||
{
|
||||
"intl_id": "swamp",
|
||||
"intl_id": "quest_swamp",
|
||||
"name": "Swamp",
|
||||
"obj_type": "quest"
|
||||
},
|
||||
{
|
||||
"intl_id": "valley",
|
||||
"intl_id": "quest_valley",
|
||||
"name": "Valley",
|
||||
"obj_type": "quest"
|
||||
},
|
||||
|
||||
6
sql.go
6
sql.go
@ -434,7 +434,7 @@ func initDB() {
|
||||
ORDER BY obi.intl_id ASC;`)
|
||||
failOnError(err, "initDB : create view obj_item_name_v")
|
||||
log.Println("initDB : obj_item_name_v created ...")
|
||||
|
||||
/*
|
||||
_, err = db.Exec(`INSERT INTO code_obj_type (id, intl_id, name)
|
||||
VALUES (` + strconv.Itoa(objTypeUser) + `, "user", "User")
|
||||
,(` + strconv.Itoa(objTypeGuild) + `, "guild", "Guild")
|
||||
@ -452,7 +452,8 @@ func initDB() {
|
||||
;`)
|
||||
failOnError(err, "initDB : populate table code_obj_type")
|
||||
log.Println("initDB : code_obj_type populated ...")
|
||||
|
||||
*/
|
||||
/*
|
||||
_, err = db.Exec(`INSERT INTO code_obj_sub_type (id, intl_id, name, obj_type_id)
|
||||
VALUES (` + strconv.Itoa(objSubTypeUser) + `, "user", "User", ` + strconv.Itoa(objTypeUser) + `)
|
||||
,(` + strconv.Itoa(objSubTypeGuild) + `, "guild", "Guild", ` + strconv.Itoa(objTypeGuild) + `)
|
||||
@ -595,6 +596,7 @@ func initDB() {
|
||||
;`)
|
||||
failOnError(err, "initDB : populate table code_obj_sub_type")
|
||||
log.Println("initDB : code_obj_sub_type populated ...")
|
||||
*/
|
||||
|
||||
_, err = db.Exec(`CREATE VIEW obj_msg_vault_v AS
|
||||
SELECT obm.sender_user_id user_id
|
||||
|
||||
144
workers.go
144
workers.go
@ -338,54 +338,54 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
|
||||
err = setObjSubTypeId(objId, rule.MsgTypeID64)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId")
|
||||
switch rule.MsgTypeID64 {
|
||||
case objSubTypeMessageGRolesReq:
|
||||
case objSubTypeMessageGo:
|
||||
case objSubTypeMessageReportReq:
|
||||
case objSubTypeMessageGReportReq:
|
||||
case objSubTypeMessageHeroReq:
|
||||
case objSubTypeMessageMeReq:
|
||||
case objSubTypeMessageInventoryReq:
|
||||
case objSubTypeMessageTimeReq:
|
||||
case objSubTypeMessagePledge:
|
||||
case objSubTypeMessagePillageGo:
|
||||
case objSubTypeMessagePillageTimeout:
|
||||
case objSubTypeMessagePillageWin:
|
||||
case objSubTypeMessagePillageLoss:
|
||||
case objSubTypeMessageGoQuestReq:
|
||||
case objSubTypeMessageGoFastFight:
|
||||
case objSubTypeMessageGoArena:
|
||||
case objSubTypeMessageTop:
|
||||
case objSubTypeMessageMenu:
|
||||
case objSubTypeMessageBuyReq:
|
||||
case objSubTypeMessageSellReq:
|
||||
case objSubTypeMessageOrderbookReq:
|
||||
case objSubTypeMessageWithdrawReq:
|
||||
case objSubTypeMessageWithdrawCode:
|
||||
case objSubTypeMessageWithdrawRcv:
|
||||
case cacheObjSubType[`msg_groles_req`]:
|
||||
case cacheObjSubType[`msg_go`]:
|
||||
case cacheObjSubType[`msg_report_req`]:
|
||||
case cacheObjSubType[`msg_g_report_req`]:
|
||||
case cacheObjSubType[`msg_hero_req`]:
|
||||
case cacheObjSubType[`msg_me_req`]:
|
||||
case cacheObjSubType[`msg_inv_req`]:
|
||||
case cacheObjSubType[`msg_time_req`]:
|
||||
case cacheObjSubType[`msg_pledge`]:
|
||||
case cacheObjSubType[`msg_pillage_go`]:
|
||||
case cacheObjSubType[`msg_pillage_timeout`]:
|
||||
case cacheObjSubType[`msg_pillage_win`]:
|
||||
case cacheObjSubType[`msg_pillage_loss`]:
|
||||
case cacheObjSubType[`msg_go_quest_req`]:
|
||||
case cacheObjSubType[`msg_fast_fight`]:
|
||||
case cacheObjSubType[`msg_go_arena`]:
|
||||
case cacheObjSubType[`msg_top`]:
|
||||
case cacheObjSubType[`msg_menu`]:
|
||||
case cacheObjSubType[`msg_buy_req`]:
|
||||
case cacheObjSubType[`msg_sell_req`]:
|
||||
case cacheObjSubType[`msg_orderbook_req`]:
|
||||
case cacheObjSubType[`msg_withdraw_req`]:
|
||||
case cacheObjSubType[`msg_withdraw_code`]:
|
||||
case cacheObjSubType[`msg_withdraw_rcv`]:
|
||||
cwm, err := parseSubTypeMessageWithdrawRcv(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageWithdrawRcv.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_withdraw_rcv`].")
|
||||
for _, i := range cwm.ItemList {
|
||||
err = insertMsgItem(cwm.Msg.ObjID64, i.ItemID64, i.Quantity)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Inserting objSubTypeMessageWithdrawRcv.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Inserting cacheObjSubType[`msg_withdraw_rcv`].")
|
||||
}
|
||||
case objSubTypeMessageStockReq:
|
||||
case objSubTypeMessageMiscReq:
|
||||
case objSubTypeMessageGStockResReq:
|
||||
case objSubTypeMessageGStockAlchReq:
|
||||
case objSubTypeMessageGStockMiscReq:
|
||||
case objSubTypeMessageGStockRecReq:
|
||||
case objSubTypeMessageGStockPartReq:
|
||||
case objSubTypeMessageGStockOthReq:
|
||||
case objSubTypeMessageGStockAnyAck:
|
||||
case cacheObjSubType[`msg_stock_req`]:
|
||||
case cacheObjSubType[`msg_misc_req`]:
|
||||
case cacheObjSubType[`msg_gstock_res_req`]:
|
||||
case cacheObjSubType[`msg_gstock_alch_req`]:
|
||||
case cacheObjSubType[`msg_gstock_misc_req`]:
|
||||
case cacheObjSubType[`msg_gstock_rec_req`]:
|
||||
case cacheObjSubType[`msg_gstock_part_req`]:
|
||||
case cacheObjSubType[`msg_gstock_oth_req`]:
|
||||
case cacheObjSubType[`msg_gstock_any_ack`]:
|
||||
_, err := parseSubTypeMessageGStockAnyAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGStockAnyAck.")
|
||||
case objSubTypeMessageReportAck:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_gstock_any_ack`].")
|
||||
case cacheObjSubType[`msg_report_ack`]:
|
||||
cwm, err := parseSubTypeMessageReportAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageReportAck.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_report_ack`].")
|
||||
cwm.ObjID64 = objId
|
||||
case objSubTypeMessageQuestResultAmbush:
|
||||
case cacheObjSubType[`msg_quest_res_ambush`]:
|
||||
cwm, err := parseSubTypeMessageQuestResultAmbush(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageQuestResultAmbush.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_quest_res_ambush`].")
|
||||
if m.Date.Add(3 * time.Minute).After(time.Now().UTC()) {
|
||||
if m.ChatID64 == chtwrsbotID64 && m.TGSenderUserID64 == chtwrsbotID64 {
|
||||
s := TGCommand{
|
||||
@ -401,9 +401,9 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : clientSpreadQuestResultAmbush.")
|
||||
}
|
||||
}
|
||||
case objSubTypeMessagePillageInc:
|
||||
case cacheObjSubType[`msg_pillage_inc`]:
|
||||
cwm, err := parseSubTypeMessagePillageInc(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessagePillageInc.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_pillage_inc`].")
|
||||
cwm.ObjID64 = objId
|
||||
err = insertMsgPillageInc(cwm)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgPillageInc")
|
||||
@ -423,39 +423,39 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
|
||||
_, err = createJob(objSubTypeJobPillage, objJobPriority, m.TGUserID64, m.ObjID64, m.Date.Add(time.Duration(25+rand.Intn(35))*time.Second), b)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : createJob(JobPillage)")
|
||||
}
|
||||
case objSubTypeMessageMeAck:
|
||||
case cacheObjSubType[`msg_me_ack`]:
|
||||
cwm, err := parseSubTypeMessageMeAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageMeAck.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_me_ack`].")
|
||||
clientMsgMeAck(cwm)
|
||||
_, err = addObjXP(cwm.CWUserID64, cwm.ExpNow, cwm.ExpLvl, cwm.Level, m.Date)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : addObjXP(MeAck)")
|
||||
case objSubTypeMessageGoQuestAck:
|
||||
case cacheObjSubType[`msg_go_quest_ack`]:
|
||||
cwm, err := parseSubTypeMessageGoQuestAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGoQuestAck.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_go_quest_ack`].")
|
||||
uid, err := clientGetCWUserID64(m.TGUserID64)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Retrieving UserID64.")
|
||||
if err != nil {
|
||||
err = setObjSubTypeId(objId, objSubTypeMessageUnknown)
|
||||
err = setObjSubTypeId(objId, cacheObjSubType[`msg`])
|
||||
} else {
|
||||
clientMsgGoQuestAck(cwm)
|
||||
_, err = addObjQuest(uid, cwm.QuestTypeID, cwm.Duration, m.Date.UTC())
|
||||
}
|
||||
case objSubTypeMessageDuelFight:
|
||||
case cacheObjSubType[`msg_duel_fight`]:
|
||||
cwm, err := parseSubTypeMessageDuelFight(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageDuelFight.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_duel_fight`].")
|
||||
cwm.ObjID64 = objId
|
||||
err = insertMsgDuelFight(cwm)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgDuelFight")
|
||||
case objSubTypeMessageUnionWar:
|
||||
case cacheObjSubType[`msg_union_war`]:
|
||||
_, err := parseSubTypeMessageUnionWar(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageUnionWar.")
|
||||
case objSubTypeMessageGRolesAck:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_union_war`].")
|
||||
case cacheObjSubType[`msg_groles_ack`]:
|
||||
cwm, err := parseSubTypeMessageGRolesAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGRolesAck.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_groles_ack`].")
|
||||
clientMsgGRolesAck(cwm)
|
||||
case objSubTypeMessageAuctionAnnounce:
|
||||
case cacheObjSubType[`msg_auction_announce`]:
|
||||
cwm, err := parseSubTypeMessageAuctionAnnounce(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageAuctionAnnounce.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_auction_announce`].")
|
||||
cwm.ObjID64 = objId
|
||||
err = insertMsgAuctionAnnounce(cwm)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgAuctionAnnounce")
|
||||
@ -472,32 +472,32 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
|
||||
}
|
||||
*/
|
||||
}
|
||||
case objSubTypeMessageTimeAck:
|
||||
case cacheObjSubType[`msg_time_ack`]:
|
||||
_, err := parseSubTypeMessageTimeAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageTimeAck.")
|
||||
case objSubTypeMessageOrderbookAck:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_time_ack`].")
|
||||
case cacheObjSubType[`msg_orderbook_acl`]:
|
||||
_, err := parseSubTypeMessageOrderbookAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageOrderbookAck.")
|
||||
case objSubTypeMessageStockAck:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_orderbook_acl`].")
|
||||
case cacheObjSubType[`msg_stock_ack`]:
|
||||
_, err := parseSubTypeMessageStockAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageStockAck.")
|
||||
case objSubTypeMessageGDepositReq:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_stock_ack`].")
|
||||
case cacheObjSubType[`msg_g_deposit_req`]:
|
||||
_, err := parseSubTypeMessageGDepositReq(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGDepositReq.")
|
||||
case objSubTypeMessageGDepositAck:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_g_deposit_req`].")
|
||||
case cacheObjSubType[`msg_g_deposit_ack`]:
|
||||
cwm, err := parseSubTypeMessageGDepositAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGDepositAck.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_g_deposit_ack`].")
|
||||
err = insertMsgItem(cwm.Msg.ObjID64, cwm.ItemID64, cwm.Quantity)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Inserting objSubTypeMessageGDepositAck.")
|
||||
case objSubTypeMessageStockAnyAck:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Inserting cacheObjSubType[`msg_g_deposit_ack`].")
|
||||
case cacheObjSubType[`msg_stock_any_ack`]:
|
||||
_, err := parseSubTypeMessageStockAnyAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageStockAnyAck.")
|
||||
case objSubTypeMessageExchangeAck:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_stock_any_ack`].")
|
||||
case cacheObjSubType[`msg_exchange_ack`]:
|
||||
_, err := parseSubTypeMessageExchangeAck(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageExchangeAck.")
|
||||
case objSubTypeMessageQuestResult:
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_exchange_ack`].")
|
||||
case cacheObjSubType[`msg_quest_res`]:
|
||||
_, err := parseSubTypeMessageQuestResult(m, rule.re)
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageQuestResult.")
|
||||
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_quest_res`].")
|
||||
default:
|
||||
//log.Printf("SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Unknwon message type in rule %d : %d (%d)\n%s\n", msgParsingRules[i].ID, msgParsingRules[i].MsgTypeID64, objId, m.Text)
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user