MPOS / php-mpos

   * @param height int Block Height

   * @return data array Block round transactions

   **/

  public function getAllRoundTransactions($iHeight=0) {

    $this->debug->append("STA " . __METHOD__, 4);

    $stmt = $this->mysqli->prepare("

      SELECT

      t.id AS id,

      a.id AS uid,

      a.username AS username,

      a.is_anonymous,

      t.type AS type,

      t.amount AS amount

      FROM " . $this->transaction->getTableName() . " AS t

      LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id

      LEFT JOIN " . $this->user->getTableName() . " AS a ON t.account_id = a.id

      WHERE b.height = ? AND t.type = 'Credit'

      ORDER BY amount DESC");

    if ($this->checkStmt($stmt) && $stmt->bind_param('i', $iHeight) && $stmt->execute() && $result = $stmt->get_result())

      return $result->fetch_all(MYSQLI_ASSOC);

    $this->debug->append('Unable to fetch transactions');

    return $this->sqlError();

  }

  /**

   * Get transactions for round block height user id

   * @param height int Block Height

   * @param id int user id

   * @return data array Block round transactions for user id

   * @param id int user id

   * @return data array Block round transactions for user id

   **/

  public function getUserRoundTransactions($iHeight=0, $id=0) {

    $this->debug->append("STA " . __METHOD__, 4);

    $stmt = $this->mysqli->prepare("

      SELECT

      t.id AS id,

      a.username AS username,

      t.type AS type,

      t.amount AS amount

      FROM " . $this->transaction->getTableName() . " AS t

      LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id

      LEFT JOIN " . $this->user->getTableName() . " AS a ON t.account_id = a.id

      WHERE b.height = ? AND a.id = ?

      ORDER BY id ASC");

    if ($this->checkStmt($stmt) && $stmt->bind_param('ii', $iHeight, $id) && $stmt->execute() && $result = $stmt->get_result())

      return $result->fetch_all(MYSQLI_ASSOC);

    $this->debug->append('Unable to fetch transactions');

    return $this->sqlError();

  }

  /**

   * Get ALL last blocks from height for admin panel

   **/

  public function getAllReportBlocksFoundHeight($iHeight=0, $limit=10) {

    $stmt = $this->mysqli->prepare("

  /**

   * Get credit transactions for round block height for admin panel

   **/

  public function getUserRoundTransHeight($iHeight=0, $iUser) {

    $this->debug->append("STA " . __METHOD__, 4);

    $stmt = $this->mysqli->prepare("

      SELECT

      IFNULL(t.amount, 0) AS amount

      FROM " . $this->transaction->getTableName() . " AS t

      LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id

      LEFT JOIN " . $this->user->getTableName() . " AS a ON t.account_id = a.id

      WHERE b.height = ? AND t.type = 'Credit' AND t.account_id = ?");

    if ($this->checkStmt($stmt) && $stmt->bind_param('ii', $iHeight, $iUser) && $stmt->execute() && $result = $stmt->get_result())

      return $result->fetch_object()->amount;

    $this->debug->append('Unable to fetch transactions');

    return $this->sqlError();

  }

}

$roundstats = new RoundStats();

$roundstats->setDebug($debug);

$roundstats->setMysql($mysqli);

$roundstats->setConfig($config);

   * @param none

   * @return data array Workers in IDLE state and monitoring enabled

   **/

  public function getAllIdleWorkers($interval=600) {

    $this->debug->append("STA " . __METHOD__, 4);

    $stmt = $this->mysqli->prepare("

      SELECT w.account_id AS account_id, w.id AS id, w.username AS username

      FROM

      (

        SELECT username AS s_username, MAX(shares_id) AS shares_id, MAX(shares_archive_id) AS shares_archive_id

        FROM

        (

          SELECT

          s.username AS username, MAX(s.id) AS shares_id, NULL AS shares_archive_id

          FROM . " . $this->share->getTableName() . " AS s

          WHERE s.time > DATE_SUB(now(), INTERVAL ? SECOND)

          AND s.our_result = 'Y'

          GROUP BY s.username

          UNION

          SELECT

          sa.username AS username, NULL AS shares_id, MAX(sa.id) AS shares_archive_id

          FROM " . $this->share->getArchiveTableName() . " AS sa

          WHERE sa.time > DATE_SUB(now(), INTERVAL ? SECOND)

          AND sa.our_result = 'Y'

          GROUP BY sa.username

        ) AS derived0

        GROUP BY s_username

      ) AS derived1

      RIGHT JOIN " . $this->getTableName() . " AS w

      ON s_username = w.username

      WHERE w.monitor = 1

      AND shares_id IS NULL

      AND shares_archive_id IS NULL

    ");

    if ($this->checkStmt($stmt) && $stmt->bind_param('ii', $interval, $interval) && $stmt->execute() && $result = $stmt->get_result())

      return $result->fetch_all(MYSQLI_ASSOC);

    return $this->sqlError('E0054');

  }

  /**

   * Fetch a specific worker and its status

   * @param id int Worker ID

   * @return mixed array Worker details

   **/