Reader

Reader - объект предназначен для чтения сущностей из базы.

Для кастомизации необходимо переименовать namespace:

namespace Modules\Activity\Panel\Models;

И установить:

const entity = 'app_activity_items';

<?php

namespace Modules\Activity\Panel\Models;

use Prologue\Framework\Database\Database;
use Prologue\Framework\Tests\TDD;


Class Reader
{
    const entity = 'app_activity_items';

    public static function getAllRecords($params)
    {
        TDD::debug($params, 'params', 'Инициализация параметров');

        $records = self::getAllRecords__selectRecords();

        TDD::debug($records, 'records', 'Извлекаем записи из базы');

        return $records;
    }

    private static function getAllRecords__selectRecords()
    {
        $arData = [];

        $database = new Database;

        $pdo = $database->init();

        $sqlQuery = 'SELECT ';
        $sqlQuery .= '* ';
        $sqlQuery .= 'FROM  ' . self::entity . ' ';
        $sqlQuery .= 'WHERE is_tmp=0 ';
        $sqlQuery .= 'LIMIT 100 ';

        $stmt = $pdo->prepare($sqlQuery);

        $stmt->execute();

        $data = $stmt->fetchAll();

        if ($data) {
            foreach ($data as $item) {
                $arData[] = self::handle($item);
            }
        }

        return $arData;
    }

    public static function getOneRecord($params)
    {
        TDD::debug($params, 'params', 'Инициализация параметров');

        $record = self::getOneRecord__selectRecord($params);

        TDD::debug($record, 'record', 'Извлекаем запись из базы');

        return $record;
    }

    private static function getOneRecord__selectRecord($params)
    {
        $database = new Database;

        $pdo = $database->init();

        $sqlQuery = 'SELECT ';
        $sqlQuery .= '* ';
        $sqlQuery .= 'FROM  ' . self::entity . ' ';
        $sqlQuery .= 'WHERE id=:id ';
        $sqlQuery .= 'LIMIT 1 ';

        $stmt = $pdo->prepare($sqlQuery);

        $stmt->execute(
            [
                'id' => $params['id']
            ]
        );

        $data = $stmt->fetch();

        return self::handle($data);
    }

    private static function handle($record)
    {
        return $record;
    }

}