montzar added
This commit is contained in:
@@ -0,0 +1,388 @@
|
||||
<?php
|
||||
|
||||
namespace App\Services;
|
||||
|
||||
use App\Models\Cnt;
|
||||
use App\Models\Order;
|
||||
use Illuminate\Support\Facades\Http;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
use Symfony\Component\HttpKernel\Exception\UnprocessableEntityHttpException;
|
||||
|
||||
class MontzarService
|
||||
{
|
||||
private function config(): ConfigService
|
||||
{
|
||||
return app(ConfigService::class);
|
||||
}
|
||||
|
||||
private function baseUrl(): string
|
||||
{
|
||||
return rtrim(
|
||||
$this->config()->Config('montzar_base_url') ?: 'https://montpar.ir',
|
||||
'/'
|
||||
);
|
||||
}
|
||||
|
||||
private function endpoint(string $path): string
|
||||
{
|
||||
return $this->baseUrl() . '/' . ltrim($path, '/');
|
||||
}
|
||||
|
||||
public function montzarLogin(): string
|
||||
{
|
||||
$response = Http::timeout(10)
|
||||
->acceptJson()
|
||||
->post($this->endpoint('/server/auth/login'), [
|
||||
'mobile' => $this->config()->Config('montzar_mobile'),
|
||||
'password' => $this->config()->Config('montzar_password'),
|
||||
'provider' => 'customer',
|
||||
'type_app' => 'client',
|
||||
])
|
||||
->json();
|
||||
|
||||
$token = $response['access_token'] ?? $response['token'] ?? null;
|
||||
|
||||
if (!$token) {
|
||||
throw new \Exception('Montzar login failed: ' . json_encode($response, JSON_UNESCAPED_UNICODE));
|
||||
}
|
||||
|
||||
$this->config()->UpdateConfig('montzar_token', $token);
|
||||
|
||||
return $token;
|
||||
}
|
||||
|
||||
public function getToken(): string
|
||||
{
|
||||
$token = trim((string) $this->config()->Config('montzar_token'));
|
||||
|
||||
if (!$token) {
|
||||
$token = $this->montzarLogin();
|
||||
}
|
||||
|
||||
return $token;
|
||||
}
|
||||
|
||||
public function productList(): array
|
||||
{
|
||||
$token = $this->getToken();
|
||||
|
||||
$response = Http::timeout(7)
|
||||
->acceptJson()
|
||||
->withOptions([
|
||||
'curl' => [
|
||||
CURLOPT_IPRESOLVE => CURL_IPRESOLVE_V4,
|
||||
CURLOPT_TCP_FASTOPEN => 1,
|
||||
],
|
||||
])
|
||||
->withToken($token)
|
||||
->get($this->endpoint('/server/customer/product/list'))
|
||||
->json();
|
||||
|
||||
if ((isset($response['message']) && $response['message'] === 'no authorised') || $response === null) {
|
||||
$token = $this->montzarLogin();
|
||||
|
||||
$response = Http::timeout(7)
|
||||
->acceptJson()
|
||||
->withToken($token)
|
||||
->get($this->endpoint('/server/customer/product/list'))
|
||||
->json();
|
||||
}
|
||||
|
||||
if (!is_array($response)) {
|
||||
throw new \Exception('Montzar product list response is not array');
|
||||
}
|
||||
|
||||
return $response;
|
||||
}
|
||||
|
||||
public function sendOrder(array &$data)
|
||||
{
|
||||
$payload = $this->makeOrderPayload($data);
|
||||
$token = $this->getToken();
|
||||
|
||||
$httpResponse = $this->postToMontzar(
|
||||
$this->endpoint('/server/customer/order'),
|
||||
$token,
|
||||
$payload
|
||||
);
|
||||
|
||||
$body = $this->decodeMontzarHttpBody($httpResponse);
|
||||
|
||||
if (is_array($body) && ($body['message'] ?? null) === 'no authorised') {
|
||||
$token = $this->montzarLogin();
|
||||
|
||||
$httpResponse = $this->postToMontzar(
|
||||
$this->endpoint('/server/customer/order'),
|
||||
$token,
|
||||
$payload
|
||||
);
|
||||
|
||||
$body = $this->decodeMontzarHttpBody($httpResponse);
|
||||
}
|
||||
|
||||
$this->logMontzarOrderResponse($httpResponse, $body);
|
||||
|
||||
$parsed = $this->parseMontzarOrderResponse($body, (int) $data['direction']);
|
||||
|
||||
if (!$parsed['ok']) {
|
||||
Log::warning('Montzar order rejected', [
|
||||
'base_url' => $this->baseUrl(),
|
||||
'status' => $httpResponse->status(),
|
||||
'body' => $body,
|
||||
'raw' => $httpResponse->body(),
|
||||
'payload' => $payload,
|
||||
'reason' => $parsed['error'],
|
||||
]);
|
||||
|
||||
throw new UnprocessableEntityHttpException(
|
||||
$this->formatMontzarErrorMessage($parsed['error'], $httpResponse)
|
||||
);
|
||||
}
|
||||
|
||||
$this->syncOrderWithMontzarResponse($data, $parsed);
|
||||
|
||||
return $body;
|
||||
}
|
||||
|
||||
private function makeOrderPayload(array $data): array
|
||||
{
|
||||
$mazaneh = ((int) $data['direction'] === 1)
|
||||
? $this->config()->Config('montzar_truly_buy_mazaneh')
|
||||
: $this->config()->Config('montzar_truly_sell_mazaneh');
|
||||
|
||||
$montzarPrice = (float) $this->config()->Config('montzar_price');
|
||||
|
||||
$cash = (int) round(
|
||||
$data['total_price'] ?? ($montzarPrice * (float) $data['amount'])
|
||||
);
|
||||
|
||||
$customerName = auth('customer')->check()
|
||||
? auth('customer')->user()->name
|
||||
: ($data['customer']['name'] ?? '');
|
||||
|
||||
return [
|
||||
'mazaneh' => (int) $mazaneh,
|
||||
'amount' => (float) $data['amount'],
|
||||
'description' => $this->config()->Config('name_fa') . ' - ' . $customerName,
|
||||
'direction' => (int) $data['direction'],
|
||||
'product_id' => (int) ($this->config()->Config('montzar_product_id') ?: 25),
|
||||
'cash' => $cash,
|
||||
'input_mode' => 'gold',
|
||||
];
|
||||
}
|
||||
|
||||
private function postToMontzar(string $url, string $token, array $payload)
|
||||
{
|
||||
return Http::timeout(15)
|
||||
->acceptJson()
|
||||
->withToken($token)
|
||||
->post($url, $payload);
|
||||
}
|
||||
|
||||
private function decodeMontzarHttpBody($httpResponse): ?array
|
||||
{
|
||||
$body = $httpResponse->json();
|
||||
|
||||
if (is_array($body)) {
|
||||
return $body;
|
||||
}
|
||||
|
||||
$raw = trim((string) $httpResponse->body());
|
||||
|
||||
if ($raw === '') {
|
||||
return null;
|
||||
}
|
||||
|
||||
$decoded = json_decode($raw, true);
|
||||
|
||||
if (json_last_error() === JSON_ERROR_NONE && is_array($decoded)) {
|
||||
return $decoded;
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
private function logMontzarOrderResponse($httpResponse, $body): void
|
||||
{
|
||||
try {
|
||||
$value = $body === null
|
||||
? $httpResponse->body()
|
||||
: json_encode($body, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT);
|
||||
|
||||
// مربوط به منتزر: settings
|
||||
$this->config()->UpdateConfig('montzar_order_response', $value);
|
||||
|
||||
// عمومی: اگر در const/Cnt داری همانجا بماند
|
||||
Cnt::where('key', 'last_order_log')->update(['value' => $value]);
|
||||
} catch (\Exception $e) {
|
||||
Log::warning('Could not persist montzar order response', [
|
||||
'error' => $e->getMessage(),
|
||||
]);
|
||||
}
|
||||
}
|
||||
|
||||
private function formatMontzarErrorMessage(?string $error, $httpResponse): string
|
||||
{
|
||||
if ($error && $error !== 'پاسخ نامعتبر از سرور منتظر (اتصال یا فرمت JSON)') {
|
||||
return $error;
|
||||
}
|
||||
|
||||
$status = $httpResponse->status();
|
||||
$raw = trim((string) $httpResponse->body());
|
||||
|
||||
if ($raw === '') {
|
||||
return "خطا در ارتباط با منتظر (HTTP {$status})";
|
||||
}
|
||||
|
||||
if (stripos($raw, '<!DOCTYPE') !== false || stripos($raw, '<html') !== false) {
|
||||
return "خطا از سرویس منتظر (HTTP {$status}). پاسخ JSON دریافت نشد.";
|
||||
}
|
||||
|
||||
return mb_substr($raw, 0, 300);
|
||||
}
|
||||
|
||||
private function parseMontzarOrderResponse($body, int $direction): array
|
||||
{
|
||||
if (!is_array($body)) {
|
||||
return [
|
||||
'ok' => false,
|
||||
'provider_id' => null,
|
||||
'error' => 'پاسخ نامعتبر از سرور منتظر (اتصال یا فرمت JSON)',
|
||||
];
|
||||
}
|
||||
|
||||
if (!empty($body['message']) && is_string($body['message'])) {
|
||||
return [
|
||||
'ok' => false,
|
||||
'provider_id' => null,
|
||||
'error' => $body['message'],
|
||||
];
|
||||
}
|
||||
|
||||
$providerId = $this->extractProviderOrderId($body);
|
||||
|
||||
if ($providerId !== null) {
|
||||
return [
|
||||
'ok' => true,
|
||||
'provider_id' => $providerId,
|
||||
'error' => null,
|
||||
];
|
||||
}
|
||||
|
||||
$sideKey = $direction === 1 ? 'buy' : 'sell';
|
||||
|
||||
if (($body[$sideKey] ?? null) === true) {
|
||||
return [
|
||||
'ok' => true,
|
||||
'provider_id' => null,
|
||||
'error' => null,
|
||||
];
|
||||
}
|
||||
|
||||
foreach ($body as $item) {
|
||||
if (!is_array($item)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if (!empty($item['id']) && is_numeric($item['id'])) {
|
||||
return [
|
||||
'ok' => true,
|
||||
'provider_id' => (int) $item['id'],
|
||||
'error' => null,
|
||||
];
|
||||
}
|
||||
|
||||
if (!empty($item['order']['id'])) {
|
||||
return [
|
||||
'ok' => true,
|
||||
'provider_id' => (int) $item['order']['id'],
|
||||
'error' => null,
|
||||
];
|
||||
}
|
||||
|
||||
if (isset($item['sts']) && in_array((int) $item['sts'], [1, 2], true)) {
|
||||
return [
|
||||
'ok' => true,
|
||||
'provider_id' => !empty($item['id']) ? (int) $item['id'] : null,
|
||||
'error' => null,
|
||||
];
|
||||
}
|
||||
}
|
||||
|
||||
return [
|
||||
'ok' => false,
|
||||
'provider_id' => null,
|
||||
'error' => 'سفارشات توسط ارائه دهنده بسته شده است.',
|
||||
];
|
||||
}
|
||||
|
||||
private function extractProviderOrderId(array $body): ?int
|
||||
{
|
||||
if (!empty($body['id'])) {
|
||||
return (int) $body['id'];
|
||||
}
|
||||
|
||||
if (!empty($body['order']['id'])) {
|
||||
return (int) $body['order']['id'];
|
||||
}
|
||||
|
||||
foreach ([1, 2] as $index) {
|
||||
if (isset($body[$index]) && is_array($body[$index])) {
|
||||
if (!empty($body[$index]['id'])) {
|
||||
return (int) $body[$index]['id'];
|
||||
}
|
||||
|
||||
if (!empty($body[$index]['order']['id'])) {
|
||||
return (int) $body[$index]['order']['id'];
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
foreach (['buy', 'sell'] as $sideKey) {
|
||||
if (!isset($body[$sideKey]) || !is_array($body[$sideKey])) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if (!empty($body[$sideKey]['id'])) {
|
||||
return (int) $body[$sideKey]['id'];
|
||||
}
|
||||
|
||||
if (!empty($body[$sideKey]['order']['id'])) {
|
||||
return (int) $body[$sideKey]['order']['id'];
|
||||
}
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
private function syncOrderWithMontzarResponse(array &$data, array $parsed): void
|
||||
{
|
||||
$montzarDiff = (float) $this->config()->Config('montzar_diff');
|
||||
$montzarPrice = (float) $this->config()->Config('montzar_price');
|
||||
|
||||
$totalPriceMontzar = ((int) $data['direction'] === 1)
|
||||
? ($montzarPrice + $montzarDiff)
|
||||
: ($montzarPrice - $montzarDiff);
|
||||
|
||||
$providerOrderId = $parsed['provider_id'] ?? null;
|
||||
|
||||
if (isset($data['order']) && $data['order'] instanceof Order) {
|
||||
if ($providerOrderId !== null) {
|
||||
$data['order']->provider_id = $providerOrderId;
|
||||
}
|
||||
|
||||
if (Schema::hasColumn('orders', 'total_price_montzar')) {
|
||||
$data['order']->total_price_montzar = $totalPriceMontzar;
|
||||
}
|
||||
|
||||
$data['order']->save();
|
||||
}
|
||||
|
||||
$data['total_price_montzar'] = $totalPriceMontzar;
|
||||
|
||||
if ($providerOrderId !== null) {
|
||||
$data['provider_id'] = $providerOrderId;
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user