supernova-ws / SuperNova

classes/Fleet/DbFleetStatic.php

<?php /** @noinspection SqlResolve */

/**
 * Created by Gorlum 26.04.2018 14:00
 */

namespace Fleet;

use DBAL\DbQuery;
use Exception;
use mysqli_result;
use SN;

/**
 * Class DbFleetStatic
 * @package Fleet
 *
 * deprecated
 */
class DbFleetStatic {

  /* HELPERS ******************************************************************************************************** */
  /**
   * @return DbQuery
   */
  protected static function dbq() {
    return DbQuery::build()->setTable('fleets');
  }



  /* FLEET CRUD ===================================================================================================== */
  /**
   * Inserts fleet record by ID with array
   *
   * @param array $fieldArray - [fieldName => fieldValue]
   *
   * @return int|string - fleet inserted ID or 0 if no fleets inserted
   */
  public static function fleet_insert_set_dbq($fieldArray) {
    if (!empty($fieldArray)) {
      static::dbq()
        ->setValues($fieldArray)
        ->doInsert(DbQuery::DB_INSERT_PLAIN, true);

      $fleet_id = SN::$db->db_insert_id();
    } else {
      $fleet_id = 0;
    }

    return $fleet_id;
  }

  /**
   * Updates fleet record by ID with SET
   *
   * @param int   $fleet_id
   * @param array $set   - REPLACE-set, i.e. replacement of existing values
   * @param array $delta - DELTA-set, i.e. changes to existing values
   *
   * @return array|bool|mysqli_result|null
   */
  public static function fleet_update_set($fleet_id, $set, $delta = array()) {
    $result = false;

    $fleet_id_safe   = idval($fleet_id);
    $set_string_safe = db_set_make_safe_string($set);
    !empty($delta) ? $set_string_safe = implode(',', array($set_string_safe, db_set_make_safe_string($delta, true))) : false;
    if (!empty($fleet_id_safe) && !empty($set_string_safe)) {
      $result = static::db_fleet_update_set_safe_string($fleet_id, $set_string_safe);
    }

    return $result;
  }

  /**
   * UPDATE - Updates fleet record by ID with SET
   *
   * @param int    $fleet_id
   * @param string $set_safe_string
   *
   * @return array|bool|mysqli_result|null
   */
  protected static function db_fleet_update_set_safe_string($fleet_id, $set_safe_string) {
    $fleet_id_safe = idval($fleet_id);
    if (!empty($fleet_id_safe) && !empty($set_safe_string)) {
      /** @noinspection SqlResolve */
      /** @noinspection SqlWithoutWhere */
      $result = doquery("UPDATE `{{fleets}}` SET {$set_safe_string} WHERE `fleet_id` = {$fleet_id_safe} LIMIT 1;");
    } else {
      $result = false;
    }

    return $result;
  }


  /**
   * READ - Gets fleet record by ID
   *
   * @param int $fleet_id
   *
   * @return array|false
   */
  public static function db_fleet_get($fleet_id) {
    $fleet_id_safe = idval($fleet_id);
    /** @noinspection SqlResolve */
    $result = doquery("SELECT * FROM `{{fleets}}` WHERE `fleet_id` = {$fleet_id_safe} LIMIT 1 FOR UPDATE;", true);

    return is_array($result) ? $result : false;
  }

  /**
   * DELETE
   *
   * @param $fleet_id
   *
   * @return array|bool|mysqli_result|null
   */
  public static function db_fleet_delete($fleet_id) {
    $fleet_id_safe = idval($fleet_id);
    if (!empty($fleet_id_safe)) {
      /** @noinspection SqlResolve */
      $result = doquery("DELETE FROM `{{fleets}}` WHERE `fleet_id` = {$fleet_id_safe} LIMIT 1;");
    } else {
      $result = false;
    }

    return $result;
  }



  /* FLEET LIST & COUNT CRUD ===========================================================================================*/
  /**
   * COUNT - Get fleet count by condition
   *
   * @param string $where_safe
   *
   * @return int
   */
  public static function db_fleet_count($where_safe) {
    /** @noinspection SqlResolve */
    $result = doquery("SELECT COUNT(`fleet_id`) as 'fleet_count' FROM `{{fleets}}` WHERE {$where_safe}", true);

    return !empty($result['fleet_count']) ? intval($result['fleet_count']) : 0;
  }


  /**
   * LIST - Get fleet list by condition
   *
   * @param string $where_safe
   *
   * @return array[]
   *
   * TODO - This function should NOT be used to query fleets to all planets - some aggregate function should be used
   */
  public static function db_fleet_list($where_safe, $for_update = DB_SELECT_FOR_UPDATE) {
    $row_list = [];

    $dbq = DbQuery::build()
      ->setTable('fleets');

    if (!empty($where_safe)) {
      $dbq->setWhereArrayDanger([$where_safe]);
    }

    if ($for_update == DB_SELECT_FOR_UPDATE) {
      $dbq->setForUpdate(DbQuery::DB_FOR_UPDATE);
    }

    $query = $dbq->doSelect();

    while ($row = db_fetch($query)) {

The function db_fetch() has been deprecated.

      $row_list[$row['fleet_id']] = $row;
    }

    return $row_list;
  }

  /**
   * LIST DELETE
   *
   * @param $owner_id
   *
   * @return array|bool|mysqli_result|null
   * @deprecated
   *
   * TODO - fleets should be deleted by DB itself via InnoDB FOREIHN KEY
   */
  public static function db_fleet_list_delete_by_owner($owner_id) {
    return doquery("DELETE FROM `{{fleets}}` WHERE `fleet_owner` = '{$owner_id}';");
  }

  /**
   * LIST STAT - DEPRECATED
   *
   * @return array|bool|mysqli_result|null
   *
   * TODO - deprecated
   */
  public static function db_fleet_list_query_all_stat() {
    return doquery("SELECT fleet_owner, fleet_array, fleet_resource_metal, fleet_resource_crystal, fleet_resource_deuterium FROM `{{fleets}}`;");
  }



  /* FLEET FUNCTIONS ===================================================================================================*/
  /**
   * Sends fleet back
   *
   * @param $fleet_row
   *
   * @return array|bool|mysqli_result|null
   *
   * TODO - Add another field which mark fleet as processed/completed task on destination point
   * By this flag fleet dispatcher should immediately return fleet (change STATUS/mess flag) to source planet
   */
  public static function fleet_send_back(&$fleet_row) {
    $fleet_id = round(!empty($fleet_row['fleet_id']) ? $fleet_row['fleet_id'] : $fleet_row);
    if (!$fleet_id) {
      return false;
    }

    $result = static::fleet_update_set($fleet_id, array(
      'fleet_mess' => 1,
    ));

    return $result;
  }


  /* FLEET COUNT FUNCTIONS =============================================================================================*/
  /**
   * Get flying fleet count
   *
   * @param int $player_id  - Player ID
   * @param int $mission_id - mission ID. "0" means "all"
   *
   * @return int
   *
   * TODO - Player lock should be issued before to prevent fleet number change
   */
  public static function fleet_count_flying($player_id, $mission_id = 0) {
    $player_id_safe = idval($player_id);
    if (!empty($player_id_safe)) {
      $mission_id_safe = intval($mission_id);
      $result          = static::db_fleet_count(
        "`fleet_owner` = {$player_id_safe}" .
        ($mission_id_safe ? " AND `fleet_mission` = {$mission_id_safe}" : '')
      );
    } else {
      $result = 0;
    }

    return $result;
  }

  /**
   * Returns amount of incoming fleets to planet
   *
   * @param int $galaxy
   * @param int $system
   * @param int $planet
   *
   * @return int
   *
   * TODO - Через fleet_list_by_planet_coords() ????
   */
  public static function fleet_count_incoming($galaxy, $system, $planet) {
    return static::db_fleet_count(
      "(`fleet_start_galaxy` = {$galaxy} AND `fleet_start_system` = {$system} AND `fleet_start_planet` = {$planet})
    OR
    (`fleet_end_galaxy` = {$galaxy} AND `fleet_end_system` = {$system} AND `fleet_end_planet` = {$planet})"
    );
  }

  /* FLEET LIST FUNCTIONS =============================================================================================*/
  /**
   * Get fleet list by owner
   *
   * @param int $fleet_owner_id - Fleet owner record/ID. Can't be empty
   *
   * @return array[]
   */
  public static function fleet_list_by_owner_id($fleet_owner_id) {
    $fleet_owner_id_safe = idval($fleet_owner_id);

    return $fleet_owner_id_safe ? static::db_fleet_list("`fleet_owner` = {$fleet_owner_id_safe}", DB_SELECT_PLAIN) : array();
  }

  /**
   * Get fleet list flying/returning to planet/system coordinates
   *
   * @param int $galaxy
   * @param int $system
   * @param int $planet      - planet position. "0" means "any"
   * @param int $planet_type - planet type. "PT_ALL" means "any type"
   *
   * @return array
   * TODO - safe params
   */
  public static function fleet_list_by_planet_coords($galaxy, $system, $planet = 0, $planet_type = PT_ALL, $for_phalanx = false) {
    return static::db_fleet_list(
      "(
    fleet_start_galaxy = {$galaxy}
    AND fleet_start_system = {$system}" .
      ($planet ? " AND fleet_start_planet = {$planet}" : '') .
      ($planet_type != PT_ALL ? " AND fleet_start_type = {$planet_type}" : '') .
      ($for_phalanx ? '' : " AND fleet_mess = 1") .
      ")
    OR
    (
    fleet_end_galaxy = {$galaxy}
    AND fleet_end_system = {$system}" .
      ($planet ? " AND fleet_end_planet = {$planet}" : '') .
      ($planet_type != PT_ALL ? " AND fleet_end_type = {$planet_type} " : '') .
      ($for_phalanx ? '' : " AND fleet_mess = 0") .
      ")"
      , DB_SELECT_PLAIN
    );
  }

  /**
   * Fleets on hold on planet orbit
   *
   * @param int $galaxy
   * @param int $system
   * @param int $planet
   * @param int $planet_type
   * @param int $ube_time
   *
   * @return array
   *
   * TODO - safe params
   */
  public static function fleet_list_on_hold($galaxy, $system, $planet, $planet_type, $ube_time) {
    /** @noinspection PhpRedundantOptionalArgumentInspection */
    return DbFleetStatic::db_fleet_list(
      "`fleet_end_galaxy` = {$galaxy}
    AND `fleet_end_system` = {$system}
    AND `fleet_end_planet` = {$planet}
    AND `fleet_end_type` = {$planet_type}
    AND `fleet_start_time` <= {$ube_time}
    AND `fleet_end_stay` >= {$ube_time}
    AND `fleet_mess` = 0"
      , DB_SELECT_FOR_UPDATE
    );
  }

  /**
   * Get aggressive fleet list of chosen player on selected planet
   *
   * @param $fleet_owner_id
   * @param $planet_row
   *
   * @return array
   */
  public static function fleet_list_bashing($fleet_owner_id, $planet_row) {
    return static::db_fleet_list(
      "`fleet_end_galaxy` = {$planet_row['galaxy']}
    AND `fleet_end_system` = {$planet_row['system']}
    AND `fleet_end_planet` = {$planet_row['planet']}
    AND `fleet_end_type`   = {$planet_row['planet_type']}
    AND `fleet_owner` = {$fleet_owner_id}
    AND `fleet_mission` IN (" . MT_ATTACK . "," . MT_AKS . "," . MT_DESTROY . ")
    AND `fleet_mess` = 0"
      , DB_SELECT_FOR_UPDATE
    );
  }

  /**
   * Get fleets in group
   *
   * @param $group_id
   *
   * @return array
   */
  public static function fleet_list_by_group($group_id) {
    return static::db_fleet_list("`fleet_group` = {$group_id}", DB_SELECT_FOR_UPDATE);
  }



  /* MISSILE CRUD *******************************************************************************************************/
  /* MISSILE LIST & COUNT CRUD =========================================================================================*/
  /**
   * LIST - Get missile attack list by condition
   *
   * @param string $where      - WHERE condition - SQL SAFE!
   * @param bool   $for_update - lock record with FOR UPDATE statement
   *
   * @return array - lift of fleet records from DB
   */
  public static function db_missile_list($where, $for_update = DB_SELECT_FOR_UPDATE) {
    $row_list = [];

    /** @noinspection SqlResolve */
    $query = doquery(
      "SELECT * FROM `{{iraks}}`" .
      (!empty($where) ? " WHERE {$where}" : '') .
      ($for_update == DB_SELECT_FOR_UPDATE ? " FOR UPDATE" : '')
    );
    while ($row = db_fetch($query)) {

The function db_fetch() has been deprecated.

      $row_list[$row['id']] = $row;
    }

    return $row_list;
  }



  /* FLEET/MISSILES LIST FUNCTIONS =====================================================================================*/
  /**
   * Get fleet and missile list by coordinates
   *
   * @param array $coordinates
   * @param bool  $for_phalanx - If true - this is phalanx scan so limiting output with fleet_mess
   *
   * @return array
   */
  public static function fleet_and_missiles_list_by_coordinates($coordinates, $for_phalanx = false) {
    if (empty($coordinates) || !is_array($coordinates)) {
      return array();
    }

    $fleet_db_list = static::fleet_list_by_planet_coords($coordinates['galaxy'], $coordinates['system'], $coordinates['planet'], $coordinates['planet_type'], $for_phalanx);

    $missile_db_list = static::db_missile_list(
      "(
      fleet_start_galaxy = {$coordinates['galaxy']}
      AND fleet_start_system = {$coordinates['system']}
      AND fleet_start_planet = {$coordinates['planet']}
      AND fleet_start_type = {$coordinates['planet_type']}
    )
    OR
    (
      fleet_end_galaxy = {$coordinates['galaxy']}
      AND fleet_end_system = {$coordinates['system']}
      AND fleet_end_planet = {$coordinates['planet']}
      AND fleet_end_type = {$coordinates['planet_type']}
    )"
      , DB_SELECT_PLAIN
    );

    missile_list_convert_to_fleet($missile_db_list, $fleet_db_list);

    return $fleet_db_list;
  }

  /**
   * Get fleet and missile list by that flies from player's planets OR to player's planets
   *
   * @param int $owner_id
   *
   * @return array
   */
  public static function fleet_and_missiles_list_incoming($owner_id) {
    $owner_id_safe = idval($owner_id);
    if (empty($owner_id_safe)) {
      return array();
    }

    $where           = "`fleet_owner` = '{$owner_id_safe}' OR `fleet_target_owner` = '{$owner_id_safe}'";
    $fleet_db_list   = static::db_fleet_list($where, DB_SELECT_PLAIN);
    $missile_db_list = static::db_missile_list($where, DB_SELECT_PLAIN);

    missile_list_convert_to_fleet($missile_db_list, $fleet_db_list);

    return $fleet_db_list;
  }



  /* ACS ****************************************************************************************************************/
  /**
   * Purges ACS list
   */
  public static function db_fleet_acs_purge() {
    DbQuery::build()
      ->setTable('aks')
      ->setWhereArrayDanger(['`id` NOT IN (SELECT DISTINCT `fleet_group` FROM `{{fleets}}`)'])
      ->doDelete();
  }

  public static function dbAcsGetById($acsId) {
    return DbQuery::build()
      ->setTable('aks')
      ->setWhereArray(['id' => $acsId])
      ->doSelectFetch();
  }

  public static function dbAcsGetByFleet($fleetId) {
    return DbQuery::build()
      ->setTable('aks')
      ->setWhereArray(['flotten' => $fleetId])
      ->doSelectFetch();
  }

  /**
   * @param int|array $fleetList [(int|string)fleetId,...]
   *
   * @return int
   */
  public static function dbAcsDelete($fleetList) {
    if (!is_array($fleetList) && !empty($fleetList)) {
      $fleetList = [$fleetList];
    }

    if (empty($fleetList)) {
      return 0;
    }

    $whereId = [];
    foreach ($fleetList as $fleetId) {
      $whereId[] = "'" . SN::$db->db_escape($fleetId) . "'";
    }

    return SN::$db->doquery("DELETE FROM `{{aks}}` WHERE `id` IN (" . implode(',', $whereId) . ")");
  }

  /**
   * @param $userToAddID
   * @param $fleetid
   *
   * @return array|bool|mysqli_result|null
   */
  public static function dbAcsAddUserByFleetId($userToAddID, $fleetid) {
    return SN::$db->doquery("UPDATE `{{aks}}` SET `eingeladen` = concat(`eingeladen`, ',{$userToAddID}') WHERE `flotten` = {$fleetid};");
  }

  /**
   * @param int   $userId
   * @param int   $fleetid
   * @param array $fleet
   *
   * @return array|bool|mysqli_result|null
   */
  public static function dbAcsInsert($userId, $fleetid, $fleet) {
    return doquery("INSERT INTO `{{aks}}` SET
          `name` = '" . SN::$db->db_escape(SN::$lang['flt_acs_prefix'] . $fleetid) . "',
          `teilnehmer` = '" . $userId . "',
          `flotten` = '" . $fleetid . "',
          `ankunft` = '" . $fleet['fleet_start_time'] . "',
          `galaxy` = '" . $fleet['fleet_end_galaxy'] . "',
          `system` = '" . $fleet['fleet_end_system'] . "',
          `planet` = '" . $fleet['fleet_end_planet'] . "',
          `planet_type` = '" . $fleet['fleet_end_type'] . "',
          `eingeladen` = '" . $userId . "',
          `fleet_end_time` = '" . $fleet['fleet_end_time'] . "'");
  }

  /**
   * @return array|bool|mysqli_result|null
   */
  public static function dbAcsGetAll() {
    return doquery('SELECT * FROM `{{aks}}`;');
  }


  /**
   * @param $user
   * @param $fleet
   * @param $userToAddRecord
   *
   * @return array
   * @throws Exception
   */
  public static function acsAddUser($user, $fleet, $userToAddRecord) {
    $userToAddID = !empty($userToAddRecord['id']) ? $userToAddRecord['id'] : 0;

    if (empty($userToAddID)) {
      throw new Exception(SN::$lang['fl_aks_player_error']);
    }

    if ($fleet['fleet_target_owner'] == $userToAddID) {
      throw new Exception(SN::$lang['flt_aks_player_same']);
    }

    $aks = DbFleetStatic::dbAcsGetByFleet($fleet['fleet_id']);

    $aks = DbFleetStatic::acsAddUser2($aks, $fleet, $userToAddID, $user['id']);

    return $aks;
  }


  /**
   * @param array $aks
   * @param array $fleet
   * @param       $userToAddID
   * @param       $userId
   *
   * @return array
   *
   * @throws Exception
   */
  public static function acsAddUser2($aks, $fleet, $userToAddID, $userId) {
    $fleetid = $fleet['fleet_id'];

    if (!$aks) {
      // No AСS exists - making one
      if (!$fleet['fleet_group']) {
        DbFleetStatic::dbAcsInsert($userId, $fleetid, $fleet);
        $aks = DbFleetStatic::dbAcsGetByFleet($fleetid);

        DbFleetStatic::fleet_update_set($fleetid, array(
          'fleet_group'   => $aks['id'],
          'fleet_mission' => MT_AKS,
        ));
        $fleet['fleet_group']   = $aks['id'];
        $fleet['fleet_mission'] = MT_AKS;
      } else {
        throw new Exception(SN::$lang['fl_aks_already_in_aks']);
      }
    }

    $invited_ar = explode(",", $aks['eingeladen']);
    if (count($invited_ar) >= 5) {
      throw new Exception(SN::$lang['flt_aks_error_too_much_players']);
    }

    $acsPoints    = 0;
    $isUserExists = false;
    foreach ($invited_ar as $inv) {
      if ($userToAddID == $inv) {
        $isUserExists = true;
      }

      $invitedUserRecord = db_user_by_id($inv);

$inv of type string is incompatible with the type integer expected by parameter $user_id_unsafe of db_user_by_id().

      if (!empty($invitedUserRecord)) {
        $acsPoints += $invitedUserRecord['total_points'];
      }
    }

    $attackedPlayer = db_user_by_id($fleet['fleet_target_owner']);
    if (
      !empty($attackedPlayer['total_points'])
      &&
      SN::$gc->general->playerIs1stStrongerThen2nd($acsPoints, $attackedPlayer['total_points'])
    ) {
      throw new Exception(SN::$lang['fl_aks_too_power']);
    }


    if (self::acsIsAcsFull($aks['id'])) {
      throw new Exception(SN::$lang['fl_aks_too_power']);
    }

    if ($isUserExists) {
//      if ($userToAddID != $userId)
      throw new Exception(SN::$lang['fl_aks_player_invited_already']);
    } else {
      DbFleetStatic::dbAcsAddUserByFleetId($userToAddID, $fleetid);
      $aks['eingeladen'] .= ',' . $userToAddID;
    }

    return $aks;
  }

  /**
   * @param int $acsId
   *
   * @return bool
   */
  public static function acsIsAcsFull($acsId) {
    $fleetInAcs      = self::fleet_list_by_group($acsId);
    $isMaxSubReached = count($fleetInAcs) >= 5;

    return $isMaxSubReached;
  }

  /**
   * @param array $user
   *
   * @return array
   */
  public static function tpl_get_fleets_flying(&$user) {
    $fleet_flying_list = array();

    $fleet_flying_list[0] = DbFleetStatic::fleet_list_by_owner_id($user['id']);
    foreach ($fleet_flying_list[0] as $fleet_id => $fleet_flying_row) {
      $fleet_flying_list[$fleet_flying_row['fleet_mission']][$fleet_id] = &$fleet_flying_list[0][$fleet_id];
    }

    return $fleet_flying_list;
  }

}