renshen
eda10bd740
- 店铺名称由单个输入框改为可点选的多选下拉：候选里可按关键字模糊筛选、多选、全选当前结果/清空 - 提交 shop_name[]，多个店铺取并集逐个模糊匹配；保留旧的单值 shop_name 兼容 - 候选来自订单镜像中真实出现过的店铺，缓存 1 小时；单次最多 50 个店铺，超出在面板内提示 - 补充仓库层与页面层用例
313 lines
11 KiB
PHP
313 lines
11 KiB
PHP
<?php
|
||
|
||
namespace Modules\EcommerceFinance\View;
|
||
|
||
use Illuminate\Pagination\Paginator;
|
||
use Illuminate\Support\Collection;
|
||
use Illuminate\Support\Facades\Cache;
|
||
use Modules\EcommerceFinance\Repositories\OrderDataRepository;
|
||
use Modules\EcommerceFinance\Repositories\OrderDataMirrorRepository;
|
||
use Modules\EcommerceFinance\Repositories\WorkOrderMirrorRepository;
|
||
use Modules\EcommerceFinance\Services\UpstreamQueryCacheFactory;
|
||
use Symfony\Component\HttpKernel\Exception\ServiceUnavailableHttpException;
|
||
use Throwable;
|
||
|
||
class OrderDataPageData
|
||
{
|
||
private const SOURCE = 'operations_replica';
|
||
|
||
public function __construct(
|
||
private readonly OrderDataRepository $orders,
|
||
private readonly UpstreamQueryCacheFactory $caches,
|
||
private readonly ?OrderDataMirrorRepository $mirrorOrders = null,
|
||
private readonly ?WorkOrderMirrorRepository $workOrderMirror = null,
|
||
) {
|
||
}
|
||
|
||
public function afterSales(?array $filters = null, ?int $page = null, ?int $limit = null, bool $includeWorkOrders = true): array
|
||
{
|
||
$filters = $this->afterSalesFilters($filters);
|
||
[$requestPage, $requestLimit] = $this->pageSettings();
|
||
$page = max($page ?? $requestPage, 1);
|
||
$limit = min(max($limit ?? $requestLimit, 1), 100);
|
||
|
||
try {
|
||
$result = $this->afterSalesRows($filters, $page, $limit);
|
||
|
||
return [
|
||
'orderDataRows' => $this->paginator(
|
||
(array) ($result['rows'] ?? []),
|
||
$page,
|
||
$limit,
|
||
(bool) ($result['has_more'] ?? false),
|
||
),
|
||
'orderDataFilters' => $filters,
|
||
'orderDataStatus' => $result['status'] ?? [],
|
||
'orderDataError' => null,
|
||
'orderDataShopOptions' => $this->afterSalesShopOptions(),
|
||
'afterSalesWorkOrders' => $includeWorkOrders ? $this->afterSalesWorkOrders($filters) : $this->emptyAfterSalesWorkOrders(),
|
||
];
|
||
} catch (ServiceUnavailableHttpException $exception) {
|
||
return $this->failed($filters, $page, $limit, $exception->getMessage());
|
||
} catch (Throwable $exception) {
|
||
report($exception);
|
||
|
||
return $this->failed($filters, $page, $limit, '订单售后费用数据暂时无法读取，请稍后重试。');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Return the same normalized filters used by the raw after-sales page.
|
||
* Exporters and sibling views must use this contract instead of rebuilding
|
||
* date and text normalization independently.
|
||
*
|
||
* @param array<string,mixed>|null $input
|
||
* @return array{from:string,to:string,order_no:string,shop_name:string,shop_names:array<int,string>,sku_id:string}
|
||
*/
|
||
public function afterSalesFilters(?array $input = null): array
|
||
{
|
||
$input ??= request()->query();
|
||
$shopNames = $this->shopNames($input['shop_name'] ?? $input['shop_names'] ?? null);
|
||
|
||
return [
|
||
'from' => $this->date($input['from'] ?? null) ?: now()->subDays(6)->toDateString(),
|
||
'to' => $this->date($input['to'] ?? null) ?: now()->toDateString(),
|
||
'order_no' => $this->text($input['order_no'] ?? null),
|
||
// shop_name 保留单值形态，兼容只认单值的调用方；多选统一用 shop_names。
|
||
'shop_name' => $shopNames[0] ?? '',
|
||
'shop_names' => $shopNames,
|
||
'sku_id' => $this->text($input['sku_id'] ?? null),
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 店铺筛选支持多选（shop_name[]=A&shop_name[]=B），也兼容原来的单个 shop_name。
|
||
*
|
||
* @return array<int,string>
|
||
*/
|
||
private function shopNames(mixed $value): array
|
||
{
|
||
$values = is_array($value) ? $value : [$value];
|
||
$names = [];
|
||
|
||
foreach ($values as $item) {
|
||
if (! is_scalar($item)) {
|
||
continue;
|
||
}
|
||
|
||
$name = $this->text($item);
|
||
if ($name === '') {
|
||
continue;
|
||
}
|
||
|
||
$names[$name] = true;
|
||
|
||
// 单次最多 50 个店铺，避免拼出过长的 WHERE。
|
||
if (count($names) >= 50) {
|
||
break;
|
||
}
|
||
}
|
||
|
||
return array_keys($names);
|
||
}
|
||
|
||
/**
|
||
* 店铺多选候选：订单镜像里出现过的店铺名称（缓存 1 小时，避免每次页面请求都扫表去重）。
|
||
*
|
||
* @return array<int,string>
|
||
*/
|
||
public function afterSalesShopOptions(): array
|
||
{
|
||
try {
|
||
$mirror = $this->mirrorOrders ?? app(OrderDataMirrorRepository::class);
|
||
$names = Cache::remember(
|
||
'order-data.after-sales.shop-options',
|
||
now()->addHour(),
|
||
fn (): array => $mirror->shopNames(),
|
||
);
|
||
|
||
return is_array($names) ? array_values($names) : [];
|
||
} catch (Throwable $exception) {
|
||
report($exception);
|
||
|
||
return [];
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Fetch raw after-sales rows for a page. Both the page and CSV export use
|
||
* this method so source selection, filters, joins and row normalization stay
|
||
* identical. Repositories over-fetch one row to determine whether another
|
||
* page exists; the sentinel is removed before this shared contract returns.
|
||
*
|
||
* @return array{rows:array<int,array<string,mixed>>,has_more:bool,status:array<string,string>}
|
||
*/
|
||
public function afterSalesRows(array $filters, int $page, int $limit): array
|
||
{
|
||
$limit = min(max($limit, 1), 100);
|
||
$mirror = $this->mirrorOrders ?? app(OrderDataMirrorRepository::class);
|
||
if ($mirror->ready()) {
|
||
$result = $mirror->afterSales($filters, $page, $limit);
|
||
$rows = array_values((array) ($result['rows'] ?? []));
|
||
$hasMore = count($rows) > $limit;
|
||
|
||
return [
|
||
'rows' => array_slice($rows, 0, $limit),
|
||
'has_more' => $hasMore,
|
||
'status' => ['X-Caiwu-Data-Status' => 'mirror'],
|
||
];
|
||
}
|
||
|
||
$cache = $this->caches->forSource(self::SOURCE);
|
||
$result = $cache->remember(
|
||
'order-data.after-sales.list',
|
||
compact('filters', 'page', 'limit'),
|
||
fn () => $this->orders->afterSales($filters, $page, $limit),
|
||
);
|
||
$rows = array_values((array) ($result['rows'] ?? []));
|
||
|
||
return [
|
||
'rows' => array_slice($rows, 0, $limit),
|
||
'has_more' => count($rows) > $limit,
|
||
'status' => $cache->responseHeaders(),
|
||
];
|
||
}
|
||
|
||
public function promotionExpenses(): array
|
||
{
|
||
$filters = [
|
||
'date' => $this->date(request('date')),
|
||
'shop_name' => $this->text(request('shop_name')),
|
||
'sku_id' => $this->text(request('sku_id')),
|
||
];
|
||
[$page, $limit] = $this->pageSettings();
|
||
|
||
try {
|
||
$mirror = $this->mirrorOrders ?? app(OrderDataMirrorRepository::class);
|
||
if ($mirror->promotionReady()) {
|
||
$result = $mirror->promotionExpenses($filters, $page, $limit);
|
||
|
||
return [
|
||
'orderDataRows' => $this->paginator((array) ($result['rows'] ?? []), $page, $limit),
|
||
'orderDataFilters' => array_replace($filters, ['date' => $result['date'] ?? $filters['date']]),
|
||
'orderDataStatus' => ['X-Caiwu-Data-Status' => 'mirror'],
|
||
'orderDataError' => null,
|
||
];
|
||
}
|
||
|
||
$cache = $this->caches->forSource(self::SOURCE);
|
||
$result = $cache->remember(
|
||
'order-data.promotion.list',
|
||
compact('filters', 'page', 'limit'),
|
||
fn () => $this->orders->promotionExpenses($filters, $page, $limit),
|
||
);
|
||
|
||
return [
|
||
'orderDataRows' => $this->paginator((array) ($result['rows'] ?? []), $page, $limit),
|
||
'orderDataFilters' => array_replace($filters, ['date' => $result['date'] ?? $filters['date']]),
|
||
'orderDataStatus' => $cache->responseHeaders(),
|
||
'orderDataError' => null,
|
||
];
|
||
} catch (ServiceUnavailableHttpException $exception) {
|
||
return $this->failed($filters, $page, $limit, $exception->getMessage());
|
||
} catch (Throwable $exception) {
|
||
report($exception);
|
||
|
||
return $this->failed($filters, $page, $limit, '商品推广费用数据暂时无法读取，请稍后重试。');
|
||
}
|
||
}
|
||
|
||
private function failed(array $filters, int $page, int $limit, string $message): array
|
||
{
|
||
return [
|
||
'orderDataRows' => $this->paginator([], $page, $limit),
|
||
'orderDataFilters' => $filters,
|
||
'orderDataStatus' => [],
|
||
'orderDataError' => $message,
|
||
'orderDataShopOptions' => $this->afterSalesShopOptions(),
|
||
'afterSalesWorkOrders' => $this->emptyAfterSalesWorkOrders(),
|
||
];
|
||
}
|
||
|
||
/** @param array<string,string> $filters */
|
||
private function afterSalesWorkOrders(array $filters): array
|
||
{
|
||
if ($this->workOrderMirror === null) {
|
||
return $this->emptyAfterSalesWorkOrders();
|
||
}
|
||
|
||
try {
|
||
return $this->workOrderMirror->paginateAfterSales(
|
||
max((int) request('work_order_page', 1), 1),
|
||
10,
|
||
$filters,
|
||
);
|
||
} catch (Throwable) {
|
||
return $this->emptyAfterSalesWorkOrders();
|
||
}
|
||
}
|
||
|
||
/** @return array{data:list<array<string,mixed>>,total:int,page:int,per_page:int,last_page:int,ready:bool,sync_status:array<string,mixed>} */
|
||
private function emptyAfterSalesWorkOrders(): array
|
||
{
|
||
return [
|
||
'data' => [],
|
||
'total' => 0,
|
||
'page' => max((int) request('work_order_page', 1), 1),
|
||
'per_page' => 10,
|
||
'last_page' => 1,
|
||
'ready' => false,
|
||
'sync_status' => [
|
||
'ready' => false,
|
||
'code' => 'unavailable',
|
||
'last_succeeded_at' => null,
|
||
'datasets' => [],
|
||
],
|
||
];
|
||
}
|
||
|
||
private function paginator(array $rows, int $page, int $limit, ?bool $hasMore = null): Paginator
|
||
{
|
||
$paginator = new Paginator(
|
||
Collection::make($rows)->map(static fn (array $row): object => (object) $row),
|
||
$limit,
|
||
$page,
|
||
[
|
||
'path' => request()->url(),
|
||
'query' => request()->except('page'),
|
||
],
|
||
);
|
||
|
||
if ($hasMore !== null) {
|
||
$paginator->hasMorePagesWhen($hasMore);
|
||
}
|
||
|
||
return $paginator;
|
||
}
|
||
|
||
/** @return array{0:int,1:int} */
|
||
private function pageSettings(): array
|
||
{
|
||
return [
|
||
max((int) request('page', 1), 1),
|
||
min(max((int) setting('default.list_limit', 25), 1), 100),
|
||
];
|
||
}
|
||
|
||
private function text(mixed $value): string
|
||
{
|
||
return mb_substr(trim((string) $value), 0, 100);
|
||
}
|
||
|
||
private function date(mixed $value): string
|
||
{
|
||
$value = trim((string) $value);
|
||
|
||
if (preg_match('/^(\d{4})-(\d{2})-(\d{2})$/', $value, $matches) !== 1) {
|
||
return '';
|
||
}
|
||
|
||
return checkdate((int) $matches[2], (int) $matches[3], (int) $matches[1]) ? $value : '';
|
||
}
|
||
}
|