MPOS / php-mpos

  /**

   * Get next block for round stats

   **/

  public function getNextBlock($iHeight=0) {

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

      SELECT height

      FROM " . $this->block->getTableName() . "

      WHERE height > ?

      ORDER BY height ASC

      LIMIT 1");

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

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

    return $this->sqlError();

  }

  /**

   * Get prev block for round stats

  /**

   * Get prev block for round stats

   **/

  public function getPreviousBlock($iHeight=0) {

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

      SELECT height

      FROM " . $this->block->getTableName() . "

      WHERE height < ?

      ORDER BY height DESC

      LIMIT 1");

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

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

    return $this->sqlError();

  }

  /**

   * search for block height

  /**

   * search for block height

   **/

  public function searchForBlockHeight($iHeight=0) {

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

       SELECT height 

       FROM " . $this->block->getTableName() . "

       WHERE height >= ?

       ORDER BY height ASC 

       LIMIT 1");

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

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

    return $this->sqlError();

  }

  /**

   * get next block for stats paging

  /**

   * get next block for stats paging

   **/

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

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

      SELECT MAX(x.height) AS height

      FROM (

        SELECT height FROM " . $this->block->getTableName() . "

        WHERE height >= ?

        ORDER BY height ASC LIMIT ?

      ) AS x");

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

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

    return $this->sqlError();

  }

  /**

   * Get details for block height

  /**

   * Fetch the lowest needed share ID from shares

   **/

  function getMinimumShareId($iCount, $current_upstream) {

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

      SELECT MIN(b.id) AS id FROM

      (

        SELECT id, @total := @total + IF(difficulty=0, POW(2, (" . $this->config['difficulty'] . " - 16)), difficulty) AS total

        FROM $this->table, (SELECT @total := 0) AS a

        WHERE our_result = 'Y'

        AND id <= ? AND @total < ?

        ORDER BY id DESC

      ) AS b

      WHERE total <= ?");

    if ($this->checkStmt($stmt) && $stmt->bind_param('iii', $current_upstream, $iCount, $iCount) && $stmt->execute() && $result = $stmt->get_result())

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

    return $this->sqlError();

  }

  /**

   * Fetch the lowest needed share ID from archive

  /**

   * Fetch the lowest needed share ID from archive

   **/

  function getMinArchiveShareId($iCount) {

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

      SELECT MIN(b.share_id) AS share_id FROM

      (

        SELECT share_id, @total := @total + IF(difficulty=0, POW(2, (" . $this->config['difficulty'] . " - 16)), difficulty) AS total

        FROM $this->tableArchive, (SELECT @total := 0) AS a

        WHERE our_result = 'Y'

        AND @total < ?

        ORDER BY share_id DESC

      ) AS b

      WHERE total <= ?

      ");

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

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

    return $this->sqlError();

  }

}

$share = new Share();

   * @param txid int Transaction ID to start from

   * @param bool boolean True or False

   **/

  public function setArchived($account_id, $txid) {

    // Update all paid out transactions as archived

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

      UPDATE $this->table AS t

      LEFT JOIN " . $this->block->getTableName() . " AS b

      ON b.id = t.block_id

      SET t.archived = 1

      WHERE t.archived = 0

      AND (

           ( t.account_id = ? AND t.id <= ? AND b.confirmations >= ? )

        OR ( t.account_id = ? AND t.id <= ? AND b.confirmations = -1 )

        OR ( t.account_id = ? AND t.id <= ? AND t.type IN ( 'Credit_PPS', 'Donation_PPS', 'Fee_PPS', 'TXFee', 'Debit_MP', 'Debit_AP' ) )

      )");

     if ($this->checkStmt($stmt) && $stmt->bind_param('iiiiiii', $account_id, $txid, $this->config['confirmations'], $account_id, $txid, $account_id, $txid) && $stmt->execute())

      return true;

    return $this->sqlError();

  }

  /**

   * Fetch a transaction summary by type with total amounts