includes/functions/eco_queue.php ➔ que_process()

Complexity

Conditions	41
Paths	5719

Size

Total Lines	192
Code Lines	107

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

<?php
function que_process(&$user, $planet = null, $on_time = SN_TIME_NOW) {
  sn_db_transaction_check(true);

  $que = array();

  // Блокируем пользователя. Собственно, запись о нём нам не нужна - будем использовать старую
  $user = db_user_by_id($user['id'], true);

  $time_left[$user['id']][0] = max(0, $on_time - $user['que_processed']);

$time_left was never initialized. Although not strictly required by PHP, it is generally a good practice to add $time_left = array(); before regardless.

  if($planet === null && !$time_left[$user['id']][0]) {
    // TODO
    return $que;
  }

  // Определяем, какие очереди нам нужны и получаем их
  $que_type_id = $planet === null ? QUE_RESEARCH : false;
  $planet = intval(is_array($planet) ? $planet['id'] : $planet); // В $planet у нас теперь только её ID или шаблон null/0/false
  $que = que_get($user['id'], $planet, $que_type_id, true);

It seems like $que_type_id defined by $planet === null ? QUE_RESEARCH : false on line 547 can also be of type integer; however, que_get() does only seem to accept boolean, maybe add an additional type check?

  if(empty($que['items'])) {
    return $que;
  }

  $planet_list = array();
  if($planet !== null) {
    // Если нужно изменять данные на планетах - блокируем планеты и получаем данные о них
    // TODO - от них не надо ничего, кроме ID и que_processed
    $planet_row = db_planet_list_by_user_or_planet($user['id'], $planet);
    $planet_list[$planet_row['id']] = $planet_row;
    $time_left[$planet_row['id_owner']][$planet_row['id']] = max(0, $on_time - $planet_row['que_processed']);
  }

  // Теперь в $time_left лежит время обсчета всех очередей по каждой из планеты
  if(array_sum($time_left[$user['id']]) == 0) {
    return $que;
  }

  $db_changeset = array();
  $unit_changes = array();
  foreach($que['items'] as &$que_item) {
    $que_player_id = &$que_item['que_player_id'];
    $que_planet_id = intval($que_item['que_planet_id']);

    $que_time_left = &$que['time_left'][$que_player_id][$que_planet_id][$que_item['que_type']];
    if(!isset($que_time_left)) {
      $que_time_left = $time_left[$que_player_id][$que_planet_id];
    }
    if($que_time_left <= 0 || $que_item['que_unit_amount'] <= 0) {
      continue;
    }
    // Дальше мы идем, если только осталось время в очереди И юниты к постройке

    // Вычисляем, сколько целых юнитов будет построено - от 0 до количества юнитов в очереди
    $unit_processed = min($que_item['que_unit_amount'] - 1, floor($que_time_left / $que_item['que_unit_time']));
    // Вычитаем это время из остатков
    $que_time_left -= $unit_processed * $que_item['que_unit_time'];

    // Теперь работаем с остатком времени на юните. Оно не может быть равно или меньше нуля

    // Если времени в очереди осталось не меньше, чем время текущего юнита - значит мы достроили юнит
    if($que_time_left >= $que_item['que_time_left']) {
      // Увеличиваем количество отстроенных юнитов
      $unit_processed++;
      // Вычитаем из времени очереди потраченное на постройку время
      $que_time_left -= $que_item['que_time_left'];
      // Полное время юнита равно времени нового юнита
      $que_item['que_time_left'] = $que_item['que_unit_time'];
      // Тут у нас может остатся время очереди - если постройка была не последняя
    }
    // Изменяем количество оставшихся юнитов
    $que_item['que_unit_amount'] -= $unit_processed;

    // Если еще остались юниты - значит ВСЁ оставшееся время приходится на достройку следующего юнита
    if($que_item['que_unit_amount'] > 0) {
      $que_item['que_time_left'] = $que_item['que_time_left'] - $que_time_left;
      $que_time_left = 0;
    }

    if($que_item['que_unit_amount'] <= 0) {
      $db_changeset['que'][] = array(
        'action'  => SQL_OP_DELETE,
        P_VERSION => 1,
        'where'   => array(
          "que_id" => $que_item['que_id'],
        ),
      );
    } else {
      $db_changeset['que'][] = array(
        'action'  => SQL_OP_UPDATE,
        P_VERSION => 1,
        'where'   => array(
          "que_id" => $que_item['que_id'],
        ),
        'fields'  => array(
          'que_unit_amount' => array(
            'delta' => -$unit_processed
          ),
          'que_time_left'   => array(
            'set' => $que_item['que_time_left']
          ),
        ),
      );
    }

    if($unit_processed) {
      $unit_processed_delta = $unit_processed * ($que_item['que_unit_mode'] == BUILD_CREATE ? 1 : -1);
      $unit_changes[$que_player_id][$que_planet_id][$que_item['que_unit_id']] += $unit_processed_delta;
    }
  }

  foreach($time_left as $player_id => $planet_data) {
    foreach($planet_data as $planet_id => $time_on_planet) {
      $table = $planet_id ? 'planets' : 'users';
      $id = $planet_id ? $planet_id : $player_id;
      $db_changeset[$table][] = array(
        'action'  => SQL_OP_UPDATE,
        P_VERSION => 1,
        'where'   => array(
          "id" => $id,
        ),
        'fields'  => array(
          'que_processed' => array(
            'set' => $on_time,
          ),
        ),
      );

      if(is_array($unit_changes[$player_id][$planet_id])) {
        foreach($unit_changes[$player_id][$planet_id] as $unit_id => $unit_amount) {
          $db_changeset['unit'][] = sn_db_unit_changeset_prepare($unit_id, $unit_amount, $user, $planet_id ? $planet_id : null);
        }
      }
    }
  }

  $que = que_recalculate($que);

  // TODO: Re-enable quests for Alliances
  if(!empty($unit_changes) && !$user['user_as_ally']) {
    $quest_list = qst_get_quests($user['id']);
    $quest_triggers = qst_active_triggers($quest_list);
    $quest_rewards = array();


    $xp_incoming = array();
    foreach($unit_changes as $user_id => $planet_changes) {
      foreach($planet_changes as $planet_id => $changes) {
        $planet_this = $planet_id ? classSupernova::db_get_record_by_id(LOC_PLANET, $planet_id) : array();
        foreach($changes as $unit_id => $unit_value) {
          $que_id = que_get_unit_que($unit_id);
          $unit_level_new = mrc_get_level($user, $planet_this, $unit_id, false, true) + $unit_value;
          if($que_id == QUE_STRUCTURES || $que_id == QUE_RESEARCH) {
            $build_data = eco_get_build_data($user, $planet_this, $unit_id, $unit_level_new - 1);
            $build_data = $build_data[BUILD_CREATE];
            foreach(sn_get_groups('resources_loot') as $resource_id) {
              $xp_incoming[$que_id] += $build_data[$resource_id]; // TODO - добавить конверсию рейтов обмена
            }
          }

          if(is_array($quest_triggers)) {
            // TODO: Check mutiply condition quests
            $quest_trigger_list = array_keys($quest_triggers, $unit_id);
            if(is_array($quest_trigger_list)) {
              foreach($quest_trigger_list as $quest_id) {
                $quest_unit_level = $unit_level_new;
                if(get_unit_param($unit_id, P_UNIT_TYPE) == UNIT_SHIPS) {
                  $quest_unit_level = db_unit_count_by_user_and_type_and_snid($user_id, 0, $unit_id);
                  $quest_unit_level = $quest_unit_level[$unit_id]['qty'];
                }
                if($quest_list[$quest_id]['quest_status_status'] != QUEST_STATUS_COMPLETE && $quest_list[$quest_id]['quest_unit_amount'] <= $quest_unit_level) {
                  $quest_rewards[$quest_id][$user_id][$planet_id] = $quest_list[$quest_id]['quest_rewards_list'];
                  $quest_list[$quest_id]['quest_status_status'] = QUEST_STATUS_COMPLETE;
                }
              }
            }
          }
        }
      }
    }
    // TODO: Изменить начисление награды за квесты на ту планету, на которой происходил ресеч
    qst_reward($user, $quest_rewards, $quest_list);

    foreach($xp_incoming as $que_id => $xp) {
      rpg_level_up($user, $que_id == QUE_RESEARCH ? RPG_TECH : RPG_STRUCTURE, $xp / 1000);
    }
  }

  db_changeset_apply($db_changeset);

  // TODO Сообщения о постройке

  return $que;
}