flt_flying_fleet_handler2.php ➔ flt_flying_fleet_handler()

Complexity

Conditions	45
Paths	167

Size

Total Lines	267
Code Lines	137

Duplication

Lines	14
Ratio	5.24 %

Importance

Changes	3
Bugs	0	Features	0

<?php
function flt_flying_fleet_handler($skip_fleet_update = false) {
  if (true) {

Avoid IF statements that are always true or false

    if(!defined('IN_AJAX')) {
      print('<div style="color: red; font-size: 300%">Fleet handler is disabled</div>');
      pdump('Fleet handler is disabled');
    }

    return;
  }
  /*

  [*] Нужно ли заворачивать ВСЕ в одну транзакцию?
      С одной стороны - да, что бы данные были гарантированно на момент снапшота
      С другой стороны - нет, потому что при большой активности это все будет блокировать слишком много рядов, да и таймаут будет большой для ожидания всего разлоченного
      Стоит завернуть каждую миссию отдельно? Это сильно увеличит количество запросов, зато так же сильно снизит количество блокировок.

      Resume: НЕТ! Надо оставить все в одной транзакции! Так можно будет поддерживать consistency кэша. Там буквально сантисекунды блокировки

  [*] Убрать кэшированние данных о пользователях и планета. Офигенно освободит память - проследить!
      НЕТ! Считать, скольким флотам нужна будет инфа и кэшировать только то, что используется больше раза!
      Заодно можно будет исключить перересчет очередей/ресурсов - сильно ускорит дело!
      Особенно будет актуально, когда все бонусы будут в одной таблице
      Ну и никто не заставляет как сейчас брать ВСЕ из таблицы - только по полям. Гемор, но не сильный - сделать запрос по группам sn_data
      И писать в БД только один раз результат

  [*] Нужно ли на этом этапе знать полную информацию о флотах?
      Заблокировать флоты можно и неполным запросом. Блокировка флотов - это не страшно. Ну, не пройдет одна-две отмены - так никто и не гарантировал реалтайма!
      С одной стороны - да, уменьшит количество запросов
      С другой стооны - расход памяти
      Все равно надо будет знать полную инфу о флоте в момент обработки

  [*] Сделать тестовую БД для расчетов

  [*] Но не раньше, чем переписать все миссии

  */

  if (
    classSupernova::$config->game_disable != GAME_DISABLE_NONE
    ||
    $skip_fleet_update
    ||
    SN_TIME_NOW - strtotime(classSupernova::$config->fleet_update_last) <= classSupernova::$config->fleet_update_interval

The property fleet_update_last does not exist on object<classConfig>. Since you implemented __get, maybe consider adding a @property annotation.

  ) {
    return;
  }

  sn_db_transaction_start();

  // Watchdog timer
  if (classSupernova::$config->db_loadItem('fleet_update_lock')) {
    if (defined('DEBUG_FLYING_FLEETS')) {
      $random = 0;
    } else {
      $random = mt_rand(90, 120);
    }

    if (SN_TIME_NOW - strtotime(classSupernova::$config->fleet_update_lock) <= $random) {

The property fleet_update_lock does not exist on object<classConfig>. Since you implemented __get, maybe consider adding a @property annotation.

      sn_db_transaction_rollback();

      return;
    } else {
      classSupernova::$debug->warning('Flying fleet handler was locked too long - watchdog unlocked', 'FFH Error', 504);
    }
  }

  classSupernova::$config->db_saveItem('fleet_update_lock', SN_TIME_SQL);
  classSupernova::$config->db_saveItem('fleet_update_last', SN_TIME_SQL);
  sn_db_transaction_commit();

//log_file('Начинаем обсчёт флотов');

//log_file('Обсчёт ракет');
  sn_db_transaction_start();
  coe_o_missile_calculate();
  sn_db_transaction_commit();

  $fleet_event_list = array();
  $missions_used = array();

  $objFleetList = FleetList::dbGetFleetListCurrentTick();
  foreach ($objFleetList->_container as $objFleet) {
    set_time_limit(15);
    // TODO - Унифицировать код с темплейтным разбором эвентов на планете!
    $missions_used[$objFleet->mission_type] = 1;
    if ($objFleet->time_arrive_to_target <= SN_TIME_NOW && !$objFleet->isReturning()) {

This code seems to be duplicated across your project.

      $fleet_event_list[] = array(
        'object'      => $objFleet,
        'fleet_time'  => $objFleet->time_arrive_to_target,
        'fleet_event' => EVENT_FLT_ARRIVE,
      );
    }

    if ($objFleet->time_mission_job_complete > 0 && $objFleet->time_mission_job_complete <= SN_TIME_NOW && !$objFleet->isReturning()) {

This code seems to be duplicated across your project.

      $fleet_event_list[] = array(
        'object'      => $objFleet,
        'fleet_time'  => $objFleet->time_mission_job_complete,
        'fleet_event' => EVENT_FLT_ACOMPLISH,
      );
    }

    if ($objFleet->time_return_to_source <= SN_TIME_NOW) {
      $fleet_event_list[] = array(
        'object'      => $objFleet,
        'fleet_time'  => $objFleet->time_return_to_source,
        'fleet_event' => EVENT_FLT_RETURN,
      );
    }
  }

//log_file('Сортировка и подгрузка модулей');
  uasort($fleet_event_list, 'flt_flyingFleetsSort');

// TODO: Грузить только используемые модули из $missions_used
  $mission_files = array(
    MT_ATTACK    => 'flt_mission_attack',
    MT_ACS       => 'flt_mission_attack',
    MT_DESTROY   => 'flt_mission_attack',
    MT_TRANSPORT => 'flt_mission_transport',
    MT_RELOCATE  => 'flt_mission_relocate',
    MT_HOLD      => 'flt_mission_hold',
    MT_SPY       => 'flt_mission_spy',
    MT_COLONIZE  => 'flt_mission_colonize',
    MT_RECYCLE   => 'flt_mission_recycle',
//    MT_MISSILE => 'flt_mission_missile.php',

43% of this comment could be valid code. Did you maybe forget this after debugging?

    MT_EXPLORE   => 'flt_mission_explore',
  );
  foreach ($missions_used as $mission_id => $cork) {
    require_once(SN_ROOT_PHYSICAL . "includes/includes/{$mission_files[$mission_id]}" . DOT_PHP_EX);
  }

//log_file('Обработка миссий');
  $sn_groups_mission = sn_get_groups('missions');
  foreach ($fleet_event_list as $fleet_event) {
    // Watchdog timer
    // If flying fleet handler works more then 10 seconds - stopping it
    // Let next run handle rest of fleets
    if(time() - SN_TIME_NOW > 10) {
      $debug->warning('Flying fleet handler standard routine works more then 10 seconds - watchdog unlocked', 'FFH Warning', 504);

The variable $debug does not exist. Did you forget to declare it?

      break;
    }

    // TODO: Указатель тут потом сделать
    // TODO: СЕЙЧАС НАДО ПРОВЕРЯТЬ ПО БАЗЕ - А ЖИВОЙ ЛИ ФЛОТ?!
    if (empty($fleet_event['object'])) {
      // Fleet was destroyed in course of previous actions
      continue;
    }

    /**
     * @var Fleet $objFleet
     */
    $objFleet = $fleet_event['object'];
//    $objFleet = new Fleet();

56% of this comment could be valid code. Did you maybe forget this after debugging?

//    $objFleet->parse_db_row($fleet_row);

    // TODO Обернуть всё в транзакции. Начинать надо заранее, блокируя все таблицы внутренним локом SELECT 1 FROM {{users}}
    sn_db_transaction_start();
    classSupernova::$config->db_saveItem('fleet_update_last', SN_TIME_SQL);


    $mission_data = $sn_groups_mission[$objFleet->mission_type];

    // Формируем запрос, блокирующий сразу все нужные записи
    // TODO - два уровня блокировки. "Просто" блокировка - и для атаки
    $objFleet->dbLockFlying($mission_data);

    $objFleet->dbLoad($objFleet->dbId);

    if (!$objFleet->dbId) {
      // Fleet was destroyed in course of previous actions
      sn_db_transaction_commit();
      continue;
    }

    if ($fleet_event['fleet_event'] == EVENT_FLT_RETURN) {
      // Fleet returns to planet
      $objFleet->shipsLand(true);
      sn_db_transaction_commit();
      continue;
    }

    if ($fleet_event['fleet_event'] == EVENT_FLT_ARRIVE && $objFleet->isReturning()) {
      // При событии EVENT_FLT_ARRIVE флот всегда должен иметь fleet_mess == 0
      // В противном случае это означает, что флот уже был обработан ранее - например, при САБе
      sn_db_transaction_commit();
      continue;
    }

    // TODO: Здесь тоже указатели
    // TODO: Кэширование
    // TODO: Выбирать только нужные поля

    $objMission = new Mission($objFleet);
    $objMission->fleet = $objFleet;
    $objMission->src_user = $mission_data['src_user'] || $mission_data['src_planet'] ? DBStaticUser::db_user_by_id($objFleet->playerOwnerId, true) : null;

It seems like $mission_data['src_user'] || $mission_data['src_planet'] ? \DBStatic\DBStaticUser::db_user_by_id($objFleet->playerOwnerId, true) : null can be null. However, the property $src_user is declared as array. Maybe change the type of the property to array|null or add a type check?

    $objMission->src_planet = $mission_data['src_planet'] ? DBStaticPlanet::db_planet_by_vector($objFleet->launch_coordinates_typed(), '', true, '`id`, `id_owner`, `name`') : null;
    $objMission->dst_user = $mission_data['dst_user'] || $mission_data['dst_planet'] ? DBStaticUser::db_user_by_id($objFleet->target_owner_id, true) : null;

It seems like $mission_data['dst_user'] || $mission_data['dst_planet'] ? \DBStatic\DBStaticUser::db_user_by_id($objFleet->target_owner_id, true) : null can be null. However, the property $dst_user is declared as array. Maybe change the type of the property to array|null or add a type check?

    // шпионаж не дает нормальный ID fleet_end_planet_id 'dst_planet'
    $objMission->dst_planet = $mission_data['dst_planet'] ? DBStaticPlanet::db_planet_by_vector($objFleet->target_coordinates_typed(), '', true, '`id`, `id_owner`, `name`') : null;
    $objMission->fleet_event = $fleet_event['fleet_event'];

    // Fleet that have planet destination is returned
    if($mission_data['dst_planet'] && empty($objMission->dst_planet['id_owner'])) {
      $objFleet->markReturnedAndSave();
      sn_db_transaction_commit();
      continue;
    }

    if (!empty($objMission->dst_planet['id_owner'])) {
      $update_result = sys_o_get_updated($objMission->dst_planet['id_owner'], $objMission->dst_planet['id'], $objFleet->time_arrive_to_target);
      $objMission->dst_user = !empty($objMission->dst_user) ? $update_result['user'] : null;
      $objMission->dst_planet = $update_result['planet'];
    }

    switch ($objFleet->mission_type) {
      // Для боевых атак нужно обновлять по САБу и по холду - таки надо возвращать данные из обработчика миссий!
      case MT_ACS:
      case MT_ATTACK:
      case MT_DESTROY:
        flt_mission_attack($objMission);
      break;

      case MT_TRANSPORT:
        flt_mission_transport($objMission);
      break;

      case MT_HOLD:
        flt_mission_hold($objMission);
      break;

      case MT_RELOCATE:
        flt_mission_relocate($objMission);
      break;

      case MT_EXPLORE:
        flt_mission_explore($objMission);
      break;

      case MT_RECYCLE:
        flt_mission_recycle($objMission);
      break;

      case MT_COLONIZE:
        flt_mission_colonize($objMission);
      break;

      case MT_SPY:
        flt_mission_spy($objMission);
      break;

      case MT_MISSILE:  // Missiles !!
      break;

//      default:

58% of this comment could be valid code. Did you maybe forget this after debugging?

//        doDelete("DELETE FROM `{{_fleets}}` WHERE `fleet_id` = '{$fleet_row['fleet_id']}' LIMIT 1;");
//      break;
    }
    sn_db_transaction_commit();
  }
  sn_db_transaction_start();
  classSupernova::$config->db_saveItem('fleet_update_last', SN_TIME_SQL);
  classSupernova::$config->db_saveItem('fleet_update_lock', '');
  sn_db_transaction_commit();

//  log_file('Закончили обсчёт флотов');

67% of this comment could be valid code. Did you maybe forget this after debugging?

}