<?php

namespace Modules\EcommerceFinance\Repositories;

use Illuminate\Database\ConnectionInterface;
use Modules\EcommerceFinance\Services\InternalFlowWorkbookImporter;

/**
 * 内部流转报表读取共享业务镜像中的导入结果。
 *
 * 页面只读；数据由 InternalFlowWorkbookImporter 按整份工作簿替换导入。
 */
class InternalFlowReportRepository
{
    public const TABLE = InternalFlowWorkbookImporter::TABLE;

    /** 允许排序的列，防止把用户输入拼进 SQL。 */
    public const SORTABLE = [
        'company_name',
        'tag',
        'projected_sales',
        'invoiced_to_buyer',
        'internal_invoiced',
        'required_input_cost',
        'receipt_from_supplier',
        'receipt_from_suofeiya',
        'receipt_from_gujia',
        'internal_transfer_1',
        'internal_transfer_2',
        'internal_transfer_3',
        'receipt_total',
        'remaining_gap',
        'invoicing_ratio',
    ];

    private readonly ConnectionInterface $connection;

    public function __construct(GenericBusinessMirrorRepository $mirror)
    {
        $this->connection = $mirror->connection();
    }

    public function ready(): bool
    {
        return $this->connection->getSchemaBuilder()->hasTable(self::TABLE);
    }

    /**
     * @param  array{company_name?:string,tag?:string}  $filters
     * @return array{data: list<array<string,mixed>>, total: int}
     */
    public function paginate(int $page, int $perPage, array $filters = [], ?string $sort = null, string $direction = 'asc'): array
    {
        if (! $this->ready()) {
            return ['data' => [], 'total' => 0];
        }

        $query = $this->connection->table(self::TABLE);

        $companyName = trim((string) ($filters['company_name'] ?? ''));
        if ($companyName !== '') {
            $query->where('company_name', 'like', '%' . addcslashes($companyName, '%_\\') . '%');
        }

        $tag = trim((string) ($filters['tag'] ?? ''));
        if ($tag !== '') {
            $query->where('tag', '=', $tag);
        }

        $total = (clone $query)->count();

        $column = in_array($sort, self::SORTABLE, true) ? $sort : null;
        $direction = strtolower($direction) === 'desc' ? 'desc' : 'asc';

        if ($column !== null) {
            $query->orderBy($column, $direction)->orderBy('sort_order');
        } else {
            $query->orderBy('sort_order')->orderBy('id');
        }

        $rows = $query
            ->forPage(max($page, 1), min(max($perPage, 1), 100))
            ->get()
            ->map(static fn (object $row): array => (array) $row)
            ->all();

        return ['data' => $rows, 'total' => $total];
    }
}