Profiles parsing and saving

2017-10-11 06:53:50 +04:00
parent 736d6b9658
commit 92fa488828
20 changed files with 748 additions and 8 deletions
--- a/lib/migrations/10_update_leagues.go
+++ b/lib/migrations/10_update_leagues.go
@@ -0,0 +1,43 @@
+// i2_bot – Instinct PokememBro Bot
+// Copyright (c) 2017 Vladimir "fat0troll" Hodakov
+
+package migrations
+
+import (
+    // stdlib
+    "database/sql"
+)
+
+func UpdateLeaguesUp(tx *sql.Tx) error {
+    _, err := tx.Exec("UPDATE `leagues` SET symbol='🈸' WHERE symbol=':u7533:';")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("UPDATE `leagues` SET symbol='🈳 ' WHERE symbol=':u6e80';")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("UPDATE `leagues` SET symbol='🈵' WHERE symbol=':u7a7a:';")
+    if err != nil {
+        return err
+    }
+
+    return nil
+}
+
+func UpdateLeaguesDown(tx *sql.Tx) error {
+    _, err := tx.Exec("UPDATE `leagues` SET symbol=':u7533:' WHERE symbol='🈸';")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("UPDATE `leagues` SET symbol=':u6e80' WHERE symbol='🈳 ';")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("UPDATE `leagues` SET symbol=':u7a7a:' WHERE symbol='🈵';")
+    if err != nil {
+        return err
+    }
+
+    return nil
+}
--- a/lib/migrations/11_profile_data_additions.go
+++ b/lib/migrations/11_profile_data_additions.go
@@ -0,0 +1,84 @@
+// i2_bot – Instinct PokememBro Bot
+// Copyright (c) 2017 Vladimir "fat0troll" Hodakov
+
+package migrations
+
+import (
+    // stdlib
+    "database/sql"
+)
+
+func ProfileDataAdditionsUp(tx *sql.Tx) error {
+    _, err := tx.Exec("ALTER TABLE `profiles` ADD `pokeballs` INT(11) DEFAULT 5 NOT NULL COMMENT 'Покеболы' AFTER `level_id`;")
+    if err != nil {
+        return err
+    }
+
+    create_request := "CREATE TABLE `levels` ("
+    create_request += "`id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID уровня и его номер',"
+    create_request += "`max_exp` int(11) NOT NULL COMMENT 'Опыт для прохождения уровня',"
+    create_request += "`max_egg` int(11) NOT NULL COMMENT 'Опыт для открытия яйца',"
+    create_request += "`created_at` datetime NOT NULL COMMENT 'Добавлен в базу',"
+    create_request += "PRIMARY KEY (`id`),"
+    create_request += "UNIQUE KEY `id` (`id`),"
+    create_request += "KEY `levels_created_at` (`created_at`)"
+    create_request += ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='Уровни';"
+    _, err = tx.Exec(create_request)
+    if err != nil {
+        return err
+    }
+
+    // Insert levels
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 200, 6, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 400, 12, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 800, 24, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 1600, 48, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 3200, 96, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 6400, 192, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 12800, 384, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 25600, 768, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `levels` VALUES(NULL, 51200, 1536, NOW());")
+    if err != nil {
+        return err
+    }
+
+    return nil
+}
+
+func ProfileDataAdditionsDown(tx *sql.Tx) error {
+    _, err := tx.Exec("ALTER TABLE `profiles` DROP COLUMN `pokeballs`;")
+    if err != nil {
+        return err
+    }
+
+    _, err = tx.Exec("DROP TABLE `levels`;")
+    if err != nil {
+        return err
+    }
+
+    return nil
+}
--- a/lib/migrations/12_create_profile_relations.go
+++ b/lib/migrations/12_create_profile_relations.go
@@ -0,0 +1,36 @@
+// i2_bot – Instinct PokememBro Bot
+// Copyright (c) 2017 Vladimir "fat0troll" Hodakov
+
+package migrations
+
+import (
+    // stdlib
+    "database/sql"
+)
+
+func CreateProfileRelationsUp(tx *sql.Tx) error {
+    create_request := "CREATE TABLE `profiles_pokememes` ("
+    create_request += "`id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID связи',"
+    create_request += "`profile_id` int(11) NOT NULL COMMENT 'ID профиля',"
+    create_request += "`pokememe_id` int(11) NOT NULL COMMENT 'ID покемема',"
+    create_request += "`pokememe_lvl` int(11) NOT NULL COMMENT 'Уровень покемема',"
+    create_request += "`pokememe_rarity` varchar(191) NOT NULL DEFAULT 'common' COMMENT 'Редкость покемема',"
+    create_request += "`created_at` datetime NOT NULL COMMENT 'Добавлено в базу',"
+    create_request += "PRIMARY KEY (`id`),"
+    create_request += "UNIQUE KEY `id` (`id`),"
+    create_request += "KEY `profiles_pokememes_created_at` (`created_at`)"
+    create_request += ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='Связь Профили-Покемемы';"
+    _, err := tx.Exec(create_request)
+    if err != nil {
+        return err
+    }
+    return nil
+}
+
+func CreateProfileRelationsDown(tx *sql.Tx) error {
+    _, err := tx.Exec("DROP TABLE `profiles_pokememes`;")
+    if err != nil {
+        return err
+    }
+    return nil
+}
--- a/lib/migrations/13_create_weapons_and_add_wealth.go
+++ b/lib/migrations/13_create_weapons_and_add_wealth.go
@@ -0,0 +1,72 @@
+// i2_bot – Instinct PokememBro Bot
+// Copyright (c) 2017 Vladimir "fat0troll" Hodakov
+
+package migrations
+
+import (
+    // stdlib
+    "database/sql"
+)
+
+func CreateWeaponsAndAddWealthUp(tx *sql.Tx) error {
+    create_request := "CREATE TABLE `weapons` ("
+    create_request += "`id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID оружия',"
+    create_request += "`name` varchar(191) NOT NULL COMMENT 'Название оружия',"
+    create_request += "`power` int(11) NOT NULL COMMENT 'Атака оружия',"
+    create_request += "`price` int(11) NOT NULL COMMENT 'Цена в магазине',"
+    create_request += "`created_at` datetime NOT NULL COMMENT 'Добавлено в базу',"
+    create_request += "PRIMARY KEY (`id`),"
+    create_request += "UNIQUE KEY `id` (`id`),"
+    create_request += "KEY `weapons_created_at` (`created_at`)"
+    create_request += ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='Оружие';"
+    _, err := tx.Exec(create_request)
+    if err != nil {
+        return err
+    }
+
+    _, err = tx.Exec("INSERT INTO `weapons` VALUES(NULL, 'Бита', 2, 5, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `weapons` VALUES(NULL, 'Стальная бита', 10, 40, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `weapons` VALUES(NULL, 'Чугунная бита ', 200, 500, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `weapons` VALUES(NULL, 'Титановая бита', 2000, 10000, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `weapons` VALUES(NULL, 'Алмазная бита', 10000, 100000, NOW());")
+    if err != nil {
+        return err
+    }
+    _, err = tx.Exec("INSERT INTO `weapons` VALUES(NULL, 'Криптонитовая бита', 100000, 500000, NOW());")
+    if err != nil {
+        return err
+    }
+
+    _, err = tx.Exec("ALTER TABLE `profiles` ADD COLUMN `wealth` INT(11) NOT NULL COMMENT 'Денег на руках' AFTER `pokeballs`;")
+    if err != nil {
+        return err
+    }
+
+    return nil
+}
+
+func CreateWeaponsAndAddWealthDown(tx *sql.Tx) error {
+    _, err := tx.Exec("ALTER TABLE `profiles` DROP COLUMN `wealth`;")
+    if err != nil {
+        return err
+    }
+
+    _, err = tx.Exec("DROP TABLE `weapons`;")
+    if err != nil {
+        return err
+    }
+
+    return nil
+}
--- a/lib/migrations/migrations.go
+++ b/lib/migrations/migrations.go
@@ -24,6 +24,10 @@ func (m *Migrations) Init() {
    goose.AddNamedMigration("7_create_leagues.go", CreateLeaguesUp, CreateLeaguesDown)
    goose.AddNamedMigration("8_create_relations.go", CreateRelationsUp, CreateRelationsDown)
    goose.AddNamedMigration("9_update_locations.go", UpdateLocationsUp, UpdateLocationsDown)
+    goose.AddNamedMigration("10_update_leagues.go", UpdateLeaguesUp, UpdateLeaguesDown)
+    goose.AddNamedMigration("11_profile_data_additions.go", ProfileDataAdditionsUp, ProfileDataAdditionsDown)
+    goose.AddNamedMigration("12_create_profile_relations.go", CreateProfileRelationsUp, CreateProfileRelationsDown)
+    goose.AddNamedMigration("13_create_weapons_and_add_wealth.go", CreateWeaponsAndAddWealthUp, CreateWeaponsAndAddWealthDown)
 }

 func (m *Migrations) Migrate() error {