zarbox added
This commit is contained in:
@@ -3,11 +3,12 @@
|
||||
namespace App\Services;
|
||||
|
||||
use App\Models\Cnt;
|
||||
use App\Models\Product;
|
||||
use App\Models\Setting;
|
||||
|
||||
class ConfigService
|
||||
{
|
||||
public const PRICE_PROVIDERS = ['montzar', 'etehadie', 'taban_gohar', 'main_product'];
|
||||
public const PRICE_PROVIDERS = ['montzar', 'etehadie', 'taban_gohar', 'main_product', 'zaarbox'];
|
||||
|
||||
public function Config($name)
|
||||
{
|
||||
@@ -82,18 +83,35 @@ class ConfigService
|
||||
}
|
||||
|
||||
/**
|
||||
* شناسه محصول آبشده پیشفرض: اول settings، بعد جدول const.
|
||||
* شناسه محصول آبشده: اول settings، بعد const.
|
||||
* مقدار settings میتواند id عددی (مثل 13) یا reading_method (مثل estjt_...) باشد.
|
||||
*/
|
||||
public function mainProductId(): ?int
|
||||
{
|
||||
$fromSettings = $this->getString('main_product', '');
|
||||
if ($fromSettings !== '' && is_numeric($fromSettings)) {
|
||||
return (int) $fromSettings;
|
||||
}
|
||||
$product = $this->mainProduct();
|
||||
|
||||
$fromConst = Cnt::where('key', 'main_product')->value('value');
|
||||
if ($fromConst !== null && $fromConst !== '' && is_numeric($fromConst)) {
|
||||
return (int) $fromConst;
|
||||
return $product?->id;
|
||||
}
|
||||
|
||||
public function mainProduct(): ?Product
|
||||
{
|
||||
foreach ([$this->getString('main_product', ''), (string) (Cnt::where('key', 'main_product')->value('value') ?? '')] as $raw) {
|
||||
$raw = trim($raw);
|
||||
if ($raw === '') {
|
||||
continue;
|
||||
}
|
||||
|
||||
if (is_numeric($raw)) {
|
||||
$product = Product::find((int) $raw);
|
||||
if ($product) {
|
||||
return $product;
|
||||
}
|
||||
}
|
||||
|
||||
$byMethod = Product::where('reading_method', $raw)->first();
|
||||
if ($byMethod) {
|
||||
return $byMethod;
|
||||
}
|
||||
}
|
||||
|
||||
return null;
|
||||
@@ -122,6 +140,11 @@ class ConfigService
|
||||
return $this->priceProvider() === 'main_product';
|
||||
}
|
||||
|
||||
public function usesZaarboxPricing(): bool
|
||||
{
|
||||
return $this->priceProvider() === 'zaarbox';
|
||||
}
|
||||
|
||||
public function UpdateConfig($name, $value)
|
||||
{
|
||||
return Setting::updateOrCreate(
|
||||
|
||||
@@ -2,6 +2,7 @@
|
||||
|
||||
namespace App\Services;
|
||||
|
||||
use App\Models\Product;
|
||||
use Illuminate\Support\Facades\Http;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
@@ -142,4 +143,34 @@ class EtehadiePriceService
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/** بهروز قیمت یک محصول از API با reading_method */
|
||||
public function syncProductFromApi(Product $product): bool
|
||||
{
|
||||
if (!$product->reading_method) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$prices = $this->fetchPriceList();
|
||||
if ($prices === null) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$RPrice = collect($prices)->firstWhere('key', $product->reading_method);
|
||||
if (empty($RPrice)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
if (($RPrice['name'] ?? '') === 'گلد دات ای از آبشده - رسمی - نقد فردا') {
|
||||
$RPrice['price'] = ($RPrice['price'] ?? 0) / 4.3318;
|
||||
}
|
||||
|
||||
ProductPriceService::syncFromReference(
|
||||
$product,
|
||||
(int) $RPrice['price'],
|
||||
(int) ($RPrice['profit'] ?? 0)
|
||||
);
|
||||
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -2,184 +2,99 @@
|
||||
|
||||
namespace App\Services;
|
||||
|
||||
use Carbon\Carbon;
|
||||
use Illuminate\Support\Facades\Cache;
|
||||
use Illuminate\Support\Collection;
|
||||
use Illuminate\Support\Facades\Http;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
class ZaarboxPriceService
|
||||
{
|
||||
private const CACHE_KEY_PREFIX = 'zaarbox_gold_prices';
|
||||
|
||||
private const CACHE_TTL_MINUTES = 35;
|
||||
|
||||
private const HISTORY_ID = 'ca3800a0-1f57-3528-b963-178f9168e04f';
|
||||
|
||||
private const PERIODS = [
|
||||
'DAILY' => ['hours' => 24, 'intervalMs' => 900000],
|
||||
'WEEKLY' => ['hours' => 168, 'intervalMs' => 7200000],
|
||||
'MONTHLY' => ['hours' => 720, 'intervalMs' => 28800000],
|
||||
];
|
||||
|
||||
private function config(): ConfigService
|
||||
public function __construct(private ConfigService $config)
|
||||
{
|
||||
return app(ConfigService::class);
|
||||
}
|
||||
|
||||
private function historyId(): string
|
||||
public function isEnabled(): bool
|
||||
{
|
||||
$chartId = $this->config()->Config('chart_id');
|
||||
|
||||
return $chartId ?: self::HISTORY_ID;
|
||||
return $this->config->usesZaarboxPricing();
|
||||
}
|
||||
|
||||
private function cacheKey(): string
|
||||
public function apiUrl(): string
|
||||
{
|
||||
return self::CACHE_KEY_PREFIX . ':' . $this->historyId();
|
||||
$url = trim((string) $this->config->getString(
|
||||
'zaarbox_api_url',
|
||||
(string) config('price_providers.zaarbox_api_url', 'https://price.zaarbox.ir/api/free')
|
||||
));
|
||||
|
||||
return $url !== '' ? $url : 'https://price.zaarbox.ir/api/free';
|
||||
}
|
||||
|
||||
public function getAllPrices(): array
|
||||
/** کلید یا id ردیف در JSON تابلو (settings: zaarbox_price_key) */
|
||||
public function priceIdentifier(): string
|
||||
{
|
||||
$cached = Cache::get($this->cacheKey());
|
||||
return trim((string) $this->config->getString(
|
||||
'zaarbox_price_key',
|
||||
(string) config('price_providers.zaarbox_price_key', '')
|
||||
));
|
||||
}
|
||||
|
||||
if (is_array($cached) && isset($cached['prices'])) {
|
||||
return $cached['prices'];
|
||||
/**
|
||||
* @return array{price: int, order_price: int, raw: array<string, mixed>|null}
|
||||
*/
|
||||
public function fetchPrice(): array
|
||||
{
|
||||
$empty = ['price' => 0, 'order_price' => 0, 'raw' => null];
|
||||
$identifier = $this->priceIdentifier();
|
||||
if ($identifier === '') {
|
||||
return $empty;
|
||||
}
|
||||
|
||||
return $this->refreshCache();
|
||||
}
|
||||
|
||||
public function refreshCache(): array
|
||||
{
|
||||
$prices = $this->fetchAllPrices();
|
||||
|
||||
Cache::put($this->cacheKey(), [
|
||||
'prices' => $prices,
|
||||
'refreshed_at' => now()->toIso8601String(),
|
||||
], now()->addMinutes(self::CACHE_TTL_MINUTES));
|
||||
|
||||
return $prices;
|
||||
}
|
||||
|
||||
private function fetchAllPrices(): array
|
||||
{
|
||||
$now = Carbon::now('UTC');
|
||||
$prices = [];
|
||||
|
||||
$responses = Http::pool(function ($pool) use ($now) {
|
||||
foreach (self::PERIODS as $key => $config) {
|
||||
$start = $now->copy()->subHours($config['hours']);
|
||||
$pool->as($key)->withHeaders([
|
||||
'Referer' => 'https://tablo.montest.ir/',
|
||||
'User-Agent' => 'Mozilla/5.0',
|
||||
])->get($this->historyUrl($start, $now));
|
||||
}
|
||||
});
|
||||
|
||||
foreach (self::PERIODS as $key => $config) {
|
||||
$response = $responses[$key] ?? null;
|
||||
$start = $now->copy()->subHours($config['hours']);
|
||||
|
||||
if (!$response || !$response->successful()) {
|
||||
Log::warning('Zaarbox price history fetch failed', [
|
||||
'period' => $key,
|
||||
'status' => $response?->status(),
|
||||
]);
|
||||
$prices[$key] = [];
|
||||
continue;
|
||||
}
|
||||
|
||||
$history = $response->json('history') ?? [];
|
||||
$prices[$key] = $this->mapHistory(
|
||||
$history,
|
||||
$this->toMillis($start),
|
||||
$this->toMillis($now),
|
||||
$config['intervalMs']
|
||||
);
|
||||
}
|
||||
|
||||
return $prices;
|
||||
}
|
||||
|
||||
private function historyUrl(Carbon $start, Carbon $end): string
|
||||
{
|
||||
$id = $this->historyId();
|
||||
|
||||
return sprintf(
|
||||
'https://price.zaarbox.ir/api/history/%s?start=%s&end=%s&limit=1000000000',
|
||||
$id,
|
||||
$this->toIso8601($start),
|
||||
$this->toIso8601($end)
|
||||
);
|
||||
}
|
||||
|
||||
private function toIso8601(Carbon $date): string
|
||||
{
|
||||
return $date->format('Y-m-d\TH:i:s') . '.' . str_pad((string) $date->millisecond, 3, '0', STR_PAD_LEFT) . 'Z';
|
||||
}
|
||||
|
||||
private function toMillis(Carbon $date): int
|
||||
{
|
||||
return ($date->getTimestamp() * 1000) + $date->millisecond;
|
||||
}
|
||||
|
||||
private function mapHistory(array $history, int $startMs, int $endMs, int $intervalMs): array
|
||||
{
|
||||
$points = [];
|
||||
|
||||
foreach ($history as $entry) {
|
||||
if (!isset($entry['time'], $entry['price'])) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$timestamp = $this->parseTimestampMs($entry['time']);
|
||||
if ($timestamp === null) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$points[] = [
|
||||
'timestamp' => $timestamp,
|
||||
'price' => (int) $entry['price'],
|
||||
];
|
||||
}
|
||||
|
||||
usort($points, fn ($a, $b) => $a['timestamp'] <=> $b['timestamp']);
|
||||
|
||||
$firstBucket = (int) (ceil($startMs / $intervalMs) * $intervalMs);
|
||||
if ($firstBucket < $startMs) {
|
||||
$firstBucket += $intervalMs;
|
||||
}
|
||||
|
||||
$result = [];
|
||||
$index = 0;
|
||||
$lastPoint = null;
|
||||
$count = count($points);
|
||||
|
||||
for ($bucket = $firstBucket; $bucket <= $endMs; $bucket += $intervalMs) {
|
||||
while ($index < $count && $points[$index]['timestamp'] <= $bucket) {
|
||||
$lastPoint = $points[$index];
|
||||
$index++;
|
||||
}
|
||||
|
||||
if ($lastPoint === null) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$result[] = [
|
||||
'value' => intdiv($lastPoint['price'], 1000),
|
||||
'timestamp' => $bucket,
|
||||
];
|
||||
}
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
private function parseTimestampMs(string $time): ?int
|
||||
{
|
||||
try {
|
||||
return $this->toMillis(Carbon::parse($time)->utc());
|
||||
} catch (\Throwable) {
|
||||
return null;
|
||||
$prices = Http::withoutVerifying()
|
||||
->timeout(20)
|
||||
->get($this->apiUrl())
|
||||
->json();
|
||||
|
||||
if (!is_array($prices)) {
|
||||
return $empty;
|
||||
}
|
||||
|
||||
$row = $this->findRow(collect($prices), $identifier);
|
||||
if (empty($row)) {
|
||||
Log::warning('Zaarbox price row not found', [
|
||||
'identifier' => $identifier,
|
||||
'api' => $this->apiUrl(),
|
||||
]);
|
||||
|
||||
return $empty;
|
||||
}
|
||||
|
||||
$base = (float) ($row['price'] ?? 0);
|
||||
$profit = (float) ($row['profit'] ?? 0);
|
||||
$orderPrice = (int) round($base + $profit);
|
||||
|
||||
return ['price' => $orderPrice, 'order_price' => $orderPrice, 'raw' => $row];
|
||||
} catch (\Throwable $e) {
|
||||
Log::warning('Zaarbox price fetch failed', ['message' => $e->getMessage()]);
|
||||
|
||||
return $empty;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* @param Collection<int, array<string, mixed>> $collection
|
||||
* @return array<string, mixed>|null
|
||||
*/
|
||||
private function findRow(Collection $collection, string $identifier): ?array
|
||||
{
|
||||
$row = $collection->firstWhere('key', $identifier);
|
||||
if (!empty($row)) {
|
||||
return $row;
|
||||
}
|
||||
|
||||
$row = $collection->firstWhere('id', $identifier);
|
||||
if (!empty($row)) {
|
||||
return $row;
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user