225 lines
7.9 KiB
PHP
225 lines
7.9 KiB
PHP
<?php
|
||
|
||
namespace Modules\EcommerceFinance\Repositories;
|
||
|
||
use Illuminate\Support\Facades\DB;
|
||
use Illuminate\Support\Facades\Schema;
|
||
use Modules\EcommerceFinance\Services\GoodsProfitAfsLookupSchema;
|
||
|
||
/**
|
||
* 订单售后费用明细：聚水潭「商品利润 → 导出明细数据 → 订单售后费用数据」原表。
|
||
*
|
||
* 原表 rpt.jst_goods_profit_kpi_items_afs 的列名是 undefined1..undefinedN，
|
||
* 中文表头放在 rpt.jst_goods_profit_kpi_items_afs_schemas（column → name）。
|
||
* 两张表都镜像到共享业务库后，页面按 schemas 映射读取字段。
|
||
*/
|
||
class GoodsProfitAfsRepository
|
||
{
|
||
public const MAIN_DATASET = 'operations_replica.rpt.jst_goods_profit_kpi_items_afs';
|
||
|
||
public const SCHEMA_DATASET = 'operations_replica.rpt.jst_goods_profit_kpi_items_afs_schemas';
|
||
|
||
private const MAIN_TABLE = 'ops_jst_goods_profit_kpi_items_afs';
|
||
|
||
private const SCHEMA_TABLE = 'ops_jst_goods_profit_kpi_items_afs_schemas';
|
||
|
||
/** @var array<string,string>|null */
|
||
private ?array $fieldColumns = null;
|
||
|
||
private ?bool $hasDateLookup = null;
|
||
|
||
public function ready(): bool
|
||
{
|
||
try {
|
||
return Schema::connection($this->connectionName())->hasTable(self::MAIN_TABLE)
|
||
&& Schema::connection($this->connectionName())->hasTable(self::SCHEMA_TABLE)
|
||
&& $this->initialSyncCompleted()
|
||
&& $this->connection()->table(self::MAIN_TABLE)->exists();
|
||
} catch (\Throwable) {
|
||
return false;
|
||
}
|
||
}
|
||
|
||
/** 首次全量同步完成前不对外使用，避免页面读到不完整的数据。 */
|
||
private function initialSyncCompleted(): bool
|
||
{
|
||
$state = $this->connection()->table('business_mirror_table_states')
|
||
->where('dataset_key', self::MAIN_DATASET)
|
||
->first(['initial_completed_at']);
|
||
|
||
return $state !== null && $state->initial_completed_at !== null;
|
||
}
|
||
|
||
/**
|
||
* 页面字段键 => 上游列名（undefinedN）。
|
||
*
|
||
* @return array<string,string>
|
||
*/
|
||
public function fieldColumns(): array
|
||
{
|
||
if ($this->fieldColumns !== null) {
|
||
return $this->fieldColumns;
|
||
}
|
||
|
||
$headers = (array) config('order_after_sales_cost.headers', []);
|
||
$map = [];
|
||
$existing = array_map(
|
||
'strtolower',
|
||
Schema::connection($this->connectionName())->getColumnListing(self::MAIN_TABLE),
|
||
);
|
||
|
||
foreach ($this->connection()->table(self::SCHEMA_TABLE)->orderBy('id')->get(['column', 'name']) as $schema) {
|
||
$label = self::normalizeLabel((string) $schema->name);
|
||
$field = $headers[$label] ?? null;
|
||
$column = (string) $schema->column;
|
||
|
||
// 同一科目出现多次（如 800105佣金 / 800105平台佣金）时保留第一次映射。
|
||
// schemas 里有 170 条，但原表只有 160 列，提前过滤掉不存在的列。
|
||
if ($field !== null && ! isset($map[$field]) && in_array(strtolower($column), $existing, true)) {
|
||
$map[$field] = $column;
|
||
}
|
||
}
|
||
|
||
return $this->fieldColumns = $map;
|
||
}
|
||
|
||
/** @param array<string,mixed> $filters */
|
||
public function covers(array $filters): bool
|
||
{
|
||
return $this->ready() && $this->filtered($filters, $this->fieldColumns())->limit(1)->exists();
|
||
}
|
||
|
||
/**
|
||
* @param array<string,mixed> $filters
|
||
* @return array{rows:list<array<string,mixed>>,has_more:bool}
|
||
*/
|
||
public function paginate(array $filters, int $page, int $limit): array
|
||
{
|
||
$page = max($page, 1);
|
||
$limit = min(max($limit, 1), 100);
|
||
$columns = $this->fieldColumns();
|
||
$select = array_values(array_unique(array_merge(['id'], array_values($columns))));
|
||
$orderColumn = $columns['order_time'] ?? null;
|
||
|
||
$query = $this->filtered($filters, $columns)->select($select);
|
||
|
||
if ($orderColumn !== null) {
|
||
$query->orderByRaw($this->dateExpression($orderColumn) . ' desc');
|
||
}
|
||
|
||
$records = $query->orderByDesc('id')->offset(($page - 1) * $limit)->limit($limit + 1)->get();
|
||
$numberKeys = array_flip((array) config('order_after_sales_cost.number_keys', []));
|
||
$rows = [];
|
||
|
||
foreach ($records as $record) {
|
||
$row = [];
|
||
|
||
foreach ($columns as $field => $column) {
|
||
$value = $record->{$column} ?? null;
|
||
|
||
if (isset($numberKeys[$field])) {
|
||
$value = $value === null ? null : (float) $value;
|
||
}
|
||
|
||
$row[$field] = is_string($value) ? trim($value) : $value;
|
||
}
|
||
|
||
$rows[] = $row;
|
||
}
|
||
|
||
return [
|
||
'rows' => array_slice($rows, 0, $limit),
|
||
'has_more' => count($rows) > $limit,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* @param array<string,mixed> $filters
|
||
* @param array<string,string> $columns
|
||
*/
|
||
private function filtered(array $filters, array $columns): \Illuminate\Database\Query\Builder
|
||
{
|
||
$query = $this->connection()->table(self::MAIN_TABLE);
|
||
$from = trim((string) ($filters['from'] ?? ''));
|
||
$to = trim((string) ($filters['to'] ?? ''));
|
||
$orderNo = trim((string) ($filters['order_no'] ?? ''));
|
||
$sku = trim((string) ($filters['sku_id'] ?? ''));
|
||
$shops = array_values(array_filter((array) ($filters['shop_names'] ?? []), static fn ($v) => trim((string) $v) !== ''));
|
||
|
||
// 原表的订单时间是字符串（如 2026/8/23 14:58:51，不补零），不能直接和 ISO 日期做字符串比较。
|
||
if (($from !== '' || $to !== '') && isset($columns['order_time'])) {
|
||
$expression = $this->dateExpression($columns['order_time']);
|
||
|
||
if ($from !== '') {
|
||
$query->whereRaw($expression . ' >= ?', [$from . ' 00:00:00']);
|
||
}
|
||
|
||
if ($to !== '') {
|
||
$query->whereRaw($expression . ' <= ?', [$to . ' 23:59:59']);
|
||
}
|
||
}
|
||
|
||
if ($shops !== [] && isset($columns['shop_name'])) {
|
||
$query->whereIn($columns['shop_name'], $shops);
|
||
}
|
||
|
||
if ($orderNo !== '') {
|
||
$query->where(function ($inner) use ($columns, $orderNo): void {
|
||
$matched = false;
|
||
|
||
foreach (['online_order_no', 'internal_order_no'] as $field) {
|
||
if (! isset($columns[$field])) {
|
||
continue;
|
||
}
|
||
|
||
$inner->orWhere($columns[$field], 'like', $orderNo . '%');
|
||
$matched = true;
|
||
}
|
||
|
||
if (! $matched) {
|
||
$inner->whereRaw('1 = 0');
|
||
}
|
||
});
|
||
}
|
||
|
||
if ($sku !== '' && isset($columns['product_code'])) {
|
||
$query->where($columns['product_code'], 'like', '%' . addcslashes($sku, '%_\\') . '%');
|
||
}
|
||
|
||
return $query;
|
||
}
|
||
|
||
private function dateExpression(string $column): string
|
||
{
|
||
// Dynamic schemas can move the source field. Keep the original parser
|
||
// until the matching additive lookup has been installed.
|
||
if ($column === 'undefined7') {
|
||
$this->hasDateLookup ??= Schema::connection($this->connectionName())
|
||
->hasColumn(self::MAIN_TABLE, GoodsProfitAfsLookupSchema::DATE_COLUMN);
|
||
if ($this->hasDateLookup) {
|
||
return '`' . GoodsProfitAfsLookupSchema::DATE_COLUMN . '`';
|
||
}
|
||
}
|
||
|
||
return "STR_TO_DATE(REPLACE(`{$column}`, '/', '-'), '%Y-%m-%d %H:%i:%s')";
|
||
}
|
||
|
||
private function connection(): \Illuminate\Database\ConnectionInterface
|
||
{
|
||
return DB::connection($this->connectionName());
|
||
}
|
||
|
||
private function connectionName(): string
|
||
{
|
||
return (string) config('upstream_mirrors.connection', 'business_mirror');
|
||
}
|
||
|
||
private static function normalizeLabel(string $label): string
|
||
{
|
||
$label = str_replace(["\u{3000}", "\u{00A0}"], ' ', $label);
|
||
$label = preg_replace('/\s+/u', ' ', $label) ?? $label;
|
||
|
||
return trim($label);
|
||
}
|
||
}
|