600 lines
22 KiB
PHP
600 lines
22 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Http\Controllers\Admin\TahesabController;
|
|
use App\Models\Customer;
|
|
use App\Models\Tahesab;
|
|
use Illuminate\Support\Facades\Cache;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Facades\Schema;
|
|
|
|
class TahesabSyncService
|
|
{
|
|
public const STATUS_PENDING = 'pending';
|
|
public const STATUS_SUCCESS = 'success';
|
|
public const STATUS_FAILED = 'failed';
|
|
|
|
public function responseOk(mixed $response): bool
|
|
{
|
|
return is_array($response) && ! empty($response['OK']);
|
|
}
|
|
|
|
public function buildLog(mixed $response = null, ?string $extra = null): string
|
|
{
|
|
$parts = array_filter([
|
|
$extra,
|
|
is_array($response) ? json_encode($response, JSON_UNESCAPED_UNICODE) : (is_string($response) ? $response : null),
|
|
]);
|
|
|
|
return implode("\n", $parts);
|
|
}
|
|
|
|
public function markSuccess(Tahesab $tahesab, array $response, ?array $payload = null): void
|
|
{
|
|
$update = [
|
|
'sh_factor' => $response['Sh_factor'] ?? null,
|
|
'tahesab_id' => $response['OK'],
|
|
'factor_number' => $response['Factor_Number'] ?? null,
|
|
'tah_id' => $response['ID'] ?? null,
|
|
'res' => json_encode($response, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT),
|
|
'sync_status' => self::STATUS_SUCCESS,
|
|
'sync_log' => null,
|
|
];
|
|
|
|
if ($payload !== null) {
|
|
$update['data'] = json_encode($payload, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT);
|
|
}
|
|
|
|
if ($this->hasSyncColumns()) {
|
|
Tahesab::where('id', $tahesab->id)->update($update);
|
|
} else {
|
|
unset($update['sync_status'], $update['sync_log']);
|
|
Tahesab::where('id', $tahesab->id)->update($update);
|
|
}
|
|
}
|
|
|
|
public function markFailed(Tahesab $tahesab, mixed $response = null, ?string $extra = null): void
|
|
{
|
|
$update = [
|
|
'res' => is_array($response)
|
|
? json_encode($response, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT)
|
|
: (is_string($response) ? $response : null),
|
|
];
|
|
|
|
if ($this->hasSyncColumns()) {
|
|
$update['sync_status'] = self::STATUS_FAILED;
|
|
$update['sync_log'] = $this->buildLog($response, $extra);
|
|
}
|
|
|
|
Tahesab::where('id', $tahesab->id)->update($update);
|
|
}
|
|
|
|
public function isFailed(Tahesab $tahesab): bool
|
|
{
|
|
if ($this->hasSyncColumns()) {
|
|
return ($tahesab->sync_status ?? null) === self::STATUS_FAILED
|
|
|| (empty($tahesab->tahesab_id) && ($tahesab->sync_status ?? null) !== self::STATUS_SUCCESS);
|
|
}
|
|
|
|
return empty($tahesab->tahesab_id);
|
|
}
|
|
|
|
public function registerOnCreate(Customer $customer): void
|
|
{
|
|
if (! empty($customer->moshtari_code) || ! $this->isSyncEnabled()) {
|
|
return;
|
|
}
|
|
|
|
$customerId = (int) $customer->id;
|
|
|
|
dispatch(function () use ($customerId) {
|
|
$service = app(TahesabSyncService::class);
|
|
$customer = Customer::find($customerId);
|
|
if ($customer === null || ! empty($customer->moshtari_code) || ! $service->isSyncEnabled()) {
|
|
return;
|
|
}
|
|
|
|
try {
|
|
$result = $service->registerCustomer($customer);
|
|
if (! ($result['ok'] ?? false)) {
|
|
Log::warning('Tahesab auto-register on customer create failed', [
|
|
'customer_id' => $customerId,
|
|
'message' => $result['message'] ?? null,
|
|
]);
|
|
}
|
|
} catch (\Throwable $e) {
|
|
Log::warning('Tahesab auto-register on customer create threw', [
|
|
'customer_id' => $customerId,
|
|
'error' => $e->getMessage(),
|
|
]);
|
|
}
|
|
})->afterResponse();
|
|
}
|
|
|
|
public function registerCustomer(Customer $customer): array
|
|
{
|
|
$customer->refresh();
|
|
|
|
if (! empty($customer->moshtari_code)) {
|
|
return [
|
|
'ok' => true,
|
|
'message' => 'مشتری قبلاً در تهحساب ثبت شده است',
|
|
'moshtari_code' => $customer->moshtari_code,
|
|
];
|
|
}
|
|
|
|
$controller = app(TahesabController::class);
|
|
$result = $controller->createCustomerInTahesab($customer->id);
|
|
|
|
if (is_string($result)) {
|
|
return ['ok' => false, 'message' => $result];
|
|
}
|
|
|
|
$customer->refresh();
|
|
|
|
if (empty($customer->moshtari_code)) {
|
|
return ['ok' => false, 'message' => 'ثبت مشتری در تهحساب ناموفق بود'];
|
|
}
|
|
|
|
return [
|
|
'ok' => true,
|
|
'message' => 'مشتری با موفقیت در تهحساب ثبت شد',
|
|
'moshtari_code' => $customer->moshtari_code,
|
|
];
|
|
}
|
|
|
|
public function retry(Tahesab $tahesab): array
|
|
{
|
|
if (! $this->isFailed($tahesab) && ! empty($tahesab->tahesab_id)) {
|
|
return ['ok' => false, 'message' => 'این سند قبلاً در تهحساب ثبت شده است'];
|
|
}
|
|
|
|
$payload = json_decode((string) $tahesab->data, true) ?: [];
|
|
$handler = $payload['handler'] ?? $this->inferHandler($tahesab);
|
|
$controller = app(TahesabController::class);
|
|
|
|
$result = match ($handler) {
|
|
'wallet' => $controller->wallet(array_merge($payload, ['_retry_tahesab_id' => $tahesab->id]), $tahesab),
|
|
'walletGold' => $controller->walletGold(array_merge($payload, ['_retry_tahesab_id' => $tahesab->id]), $tahesab),
|
|
'storeTrade' => $controller->storeTrade(array_merge($payload, ['_retry_tahesab_id' => $tahesab->id]), $tahesab),
|
|
'goldReward' => $controller->goldReward(array_merge($payload, ['_retry_tahesab_id' => $tahesab->id]), $tahesab),
|
|
default => false,
|
|
};
|
|
|
|
$tahesab->refresh();
|
|
|
|
if ($result !== false && ! empty($tahesab->tahesab_id)) {
|
|
return ['ok' => true, 'message' => 'سند با موفقیت در تهحساب ثبت شد', 'tahesab' => $tahesab];
|
|
}
|
|
|
|
return [
|
|
'ok' => false,
|
|
'message' => $tahesab->sync_log ?: 'ارسال مجدد به تهحساب ناموفق بود',
|
|
'tahesab' => $tahesab,
|
|
];
|
|
}
|
|
|
|
private function inferHandler(Tahesab $tahesab): string
|
|
{
|
|
if ($tahesab->order_id) {
|
|
return 'storeTrade';
|
|
}
|
|
|
|
if ($tahesab->type === 'ريال') {
|
|
return 'wallet';
|
|
}
|
|
|
|
$desc = (string) $tahesab->desc;
|
|
|
|
if (str_contains($desc, 'شارژ کیف') || str_contains($desc, 'برداشت از کیف')) {
|
|
return 'walletGold';
|
|
}
|
|
|
|
return 'goldReward';
|
|
}
|
|
|
|
public function isSyncEnabled(): bool
|
|
{
|
|
$config = app(ConfigService::class);
|
|
|
|
return $config->isTahesabAccounting()
|
|
&& trim($config->getString('tahesab_host', '')) !== ''
|
|
&& trim($config->getString('tahesab_port', '')) !== ''
|
|
&& trim($config->getString('tahesab_token', '')) !== ''
|
|
&& trim($config->getString('tahesab_db', '')) !== '';
|
|
}
|
|
|
|
/** ردیفهای محلی که هنوز در تهحساب ثبت نشدهاند */
|
|
public function unsyncedRowsQuery()
|
|
{
|
|
return Tahesab::query()->where(function ($q) {
|
|
$q->where(function ($inner) {
|
|
$inner->whereNull('tahesab_id')->orWhere('tahesab_id', '');
|
|
})->orWhere('sync_status', self::STATUS_FAILED);
|
|
});
|
|
}
|
|
|
|
/**
|
|
* خلاصهٔ سندهای جاافتاده / ناموفق برای بنر ادمین.
|
|
*
|
|
* @return array{failed_rows:int,missing_withdraws:int,missing_orders:int,total:int}
|
|
*/
|
|
public function pendingSummary(?int $customerId = null): array
|
|
{
|
|
$failedRows = (int) $this->unsyncedRowsQuery()
|
|
->when($customerId, fn ($q) => $q->where('customer_id', $customerId))
|
|
->count();
|
|
$missingWithdraws = count($this->missingWithdrawIds(200, $customerId));
|
|
$missingOrders = count($this->missingOrderIds(200, $customerId));
|
|
|
|
return [
|
|
'failed_rows' => $failedRows,
|
|
'missing_withdraws' => $missingWithdraws,
|
|
'missing_orders' => $missingOrders,
|
|
'total' => $failedRows + $missingWithdraws + $missingOrders,
|
|
];
|
|
}
|
|
|
|
/**
|
|
* لیست یکپارچهٔ خطا خورده + جاافتاده برای تب ادمین.
|
|
*
|
|
* @return list<array<string, mixed>>
|
|
*/
|
|
public function pendingDocs(?int $customerId = null, int $limit = 200): array
|
|
{
|
|
$limit = max(1, min(500, $limit));
|
|
$rows = [];
|
|
|
|
$local = $this->unsyncedRowsQuery()
|
|
->with('customer')
|
|
->when($customerId, fn ($q) => $q->where('customer_id', $customerId))
|
|
->orderByDesc('id')
|
|
->limit($limit)
|
|
->get();
|
|
|
|
foreach ($local as $row) {
|
|
$arr = $row->toArray();
|
|
$arr['issue_kind'] = 'failed';
|
|
$arr['sync_target'] = ['type' => 'row', 'id' => (int) $row->id];
|
|
$rows[] = $arr;
|
|
}
|
|
|
|
$remaining = $limit - count($rows);
|
|
if ($remaining > 0) {
|
|
$withdrawIds = $this->missingWithdrawIds($remaining, $customerId);
|
|
if ($withdrawIds !== []) {
|
|
$withdraws = \App\Models\Withdraw::query()
|
|
->with('customer')
|
|
->whereIn('id', $withdrawIds)
|
|
->orderByDesc('id')
|
|
->get();
|
|
foreach ($withdraws as $w) {
|
|
$cash = (float) ($w->cash ?? 0);
|
|
$gold = (float) ($w->gold ?? 0);
|
|
$isGold = abs($gold) > 1e-9;
|
|
$rows[] = [
|
|
'id' => null,
|
|
'customer_id' => $w->customer_id,
|
|
'customer' => $w->customer,
|
|
'amount' => $isGold ? abs($gold) : abs($cash),
|
|
'type' => $isGold ? 'طلا' : 'ريال',
|
|
'desc' => 'شارژ/برداشت بدون سند محلی #'.$w->id.($w->note ? ' — '.$w->note : ''),
|
|
'withdraw_id' => (int) $w->id,
|
|
'order_id' => null,
|
|
'sync_status' => 'missing',
|
|
'sync_log' => 'سند در تهحساب ساخته نشده (جاافتاده)',
|
|
'tahesab_id' => null,
|
|
'created_at' => optional($w->created_at)?->toDateTimeString(),
|
|
'issue_kind' => 'missing',
|
|
'sync_target' => ['type' => 'withdraw', 'id' => (int) $w->id],
|
|
];
|
|
}
|
|
}
|
|
}
|
|
|
|
$remaining = $limit - count($rows);
|
|
if ($remaining > 0) {
|
|
$orderIds = $this->missingOrderIds($remaining, $customerId);
|
|
if ($orderIds !== []) {
|
|
$orders = \App\Models\Order::query()
|
|
->with(['customer', 'product'])
|
|
->whereIn('id', $orderIds)
|
|
->orderByDesc('id')
|
|
->get();
|
|
foreach ($orders as $order) {
|
|
$direction = (int) ($order->direction ?? 0);
|
|
$dirLabel = $direction === 1 ? 'خرید' : ($direction === 2 ? 'فروش' : 'سفارش');
|
|
$productTitle = $order->product->title ?? 'محصول';
|
|
$rows[] = [
|
|
'id' => null,
|
|
'customer_id' => $order->customer_id,
|
|
'customer' => $order->customer,
|
|
'amount' => (float) ($order->amount ?? 0),
|
|
'type' => 'طلا',
|
|
'desc' => $dirLabel.' '.$productTitle.' بدون سند محلی #'.$order->id,
|
|
'withdraw_id' => null,
|
|
'order_id' => (int) $order->id,
|
|
'sync_status' => 'missing',
|
|
'sync_log' => 'سند در تهحساب ساخته نشده (جاافتاده)',
|
|
'tahesab_id' => null,
|
|
'created_at' => optional($order->pay_at ?? $order->created_at)?->toDateTimeString(),
|
|
'issue_kind' => 'missing',
|
|
'sync_target' => ['type' => 'order', 'id' => (int) $order->id],
|
|
];
|
|
}
|
|
}
|
|
}
|
|
|
|
usort($rows, function ($a, $b) {
|
|
return strcmp((string) ($b['created_at'] ?? ''), (string) ($a['created_at'] ?? ''));
|
|
});
|
|
|
|
return $rows;
|
|
}
|
|
|
|
/**
|
|
* ثبت یک مورد: ردیف محلی / شارژ جاافتاده / سفارش جاافتاده.
|
|
*
|
|
* @return array{ok:bool,message:string}
|
|
*/
|
|
public function syncOne(string $type, int $id): array
|
|
{
|
|
if (! $this->isSyncEnabled()) {
|
|
return ['ok' => false, 'message' => 'همگامسازی تهحساب فعال نیست یا تنظیمات ناقص است'];
|
|
}
|
|
|
|
$controller = app(TahesabController::class);
|
|
|
|
try {
|
|
if ($type === 'row') {
|
|
$row = Tahesab::with('customer')->findOrFail($id);
|
|
|
|
return $this->retry($row);
|
|
}
|
|
if ($type === 'withdraw') {
|
|
$ok = $this->backfillWithdraw($controller, $id);
|
|
|
|
return ['ok' => $ok, 'message' => $ok ? 'سند شارژ/برداشت ثبت شد' : 'ارسال شارژ/برداشت ناموفق بود'];
|
|
}
|
|
if ($type === 'order') {
|
|
$ok = $this->backfillOrder($controller, $id);
|
|
|
|
return ['ok' => $ok, 'message' => $ok ? 'سند سفارش ثبت شد' : 'ارسال سفارش ناموفق بود'];
|
|
}
|
|
|
|
return ['ok' => false, 'message' => 'نوع نامعتبر است'];
|
|
} catch (\Throwable $e) {
|
|
report($e);
|
|
|
|
return ['ok' => false, 'message' => $e->getMessage()];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* ارسال مجدد همهٔ ناموفقها + ساخت و ارسال سندهای جاافتاده از شارژ/سفارش.
|
|
*
|
|
* @return array{ok:bool,retried:int,backfilled_withdraws:int,backfilled_orders:int,failed:int,errors:list<string>,summary:array}
|
|
*/
|
|
public function syncAllPending(int $limit = 80, ?int $customerId = null): array
|
|
{
|
|
if (! $this->isSyncEnabled()) {
|
|
return [
|
|
'ok' => false,
|
|
'retried' => 0,
|
|
'backfilled_withdraws' => 0,
|
|
'backfilled_orders' => 0,
|
|
'failed' => 0,
|
|
'errors' => ['همگامسازی تهحساب فعال نیست یا تنظیمات ناقص است'],
|
|
'summary' => $this->pendingSummary($customerId),
|
|
];
|
|
}
|
|
|
|
$retried = 0;
|
|
$backfilledWithdraws = 0;
|
|
$backfilledOrders = 0;
|
|
$failed = 0;
|
|
$errors = [];
|
|
$controller = app(TahesabController::class);
|
|
$used = 0;
|
|
|
|
$rows = $this->unsyncedRowsQuery()
|
|
->when($customerId, fn ($q) => $q->where('customer_id', $customerId))
|
|
->orderBy('id')
|
|
->limit($limit)
|
|
->get();
|
|
foreach ($rows as $row) {
|
|
$used++;
|
|
try {
|
|
$result = $this->retry($row);
|
|
if ($result['ok'] ?? false) {
|
|
$retried++;
|
|
} else {
|
|
$failed++;
|
|
$errors[] = 'سند #'.$row->id.': '.($result['message'] ?? 'ناموفق');
|
|
}
|
|
} catch (\Throwable $e) {
|
|
$failed++;
|
|
$errors[] = 'سند #'.$row->id.': '.$e->getMessage();
|
|
report($e);
|
|
}
|
|
}
|
|
|
|
foreach ($this->missingWithdrawIds(max(0, $limit - $used), $customerId) as $withdrawId) {
|
|
$used++;
|
|
try {
|
|
$ok = $this->backfillWithdraw($controller, (int) $withdrawId);
|
|
if ($ok) {
|
|
$backfilledWithdraws++;
|
|
} else {
|
|
$failed++;
|
|
$errors[] = 'شارژ/برداشت #'.$withdrawId.': ارسال به تهحساب ناموفق';
|
|
}
|
|
} catch (\Throwable $e) {
|
|
$failed++;
|
|
$errors[] = 'شارژ/برداشت #'.$withdrawId.': '.$e->getMessage();
|
|
report($e);
|
|
}
|
|
}
|
|
|
|
foreach ($this->missingOrderIds(max(0, $limit - $used), $customerId) as $orderId) {
|
|
$used++;
|
|
try {
|
|
$ok = $this->backfillOrder($controller, (int) $orderId);
|
|
if ($ok) {
|
|
$backfilledOrders++;
|
|
} else {
|
|
$failed++;
|
|
$errors[] = 'سفارش #'.$orderId.': ارسال به تهحساب ناموفق';
|
|
}
|
|
} catch (\Throwable $e) {
|
|
$failed++;
|
|
$errors[] = 'سفارش #'.$orderId.': '.$e->getMessage();
|
|
report($e);
|
|
}
|
|
}
|
|
|
|
return [
|
|
'ok' => $failed === 0,
|
|
'retried' => $retried,
|
|
'backfilled_withdraws' => $backfilledWithdraws,
|
|
'backfilled_orders' => $backfilledOrders,
|
|
'failed' => $failed,
|
|
'errors' => array_slice($errors, 0, 20),
|
|
'summary' => $this->pendingSummary($customerId),
|
|
];
|
|
}
|
|
|
|
/** @return list<int> */
|
|
private function missingWithdrawIds(int $limit, ?int $customerId = null): array
|
|
{
|
|
if ($limit <= 0 || ! Schema::hasTable('withdraws')) {
|
|
return [];
|
|
}
|
|
|
|
$linked = Tahesab::query()
|
|
->whereNotNull('withdraw_id')
|
|
->when($customerId, fn ($q) => $q->where('customer_id', $customerId))
|
|
->pluck('withdraw_id')
|
|
->all();
|
|
|
|
return \App\Models\Withdraw::query()
|
|
->where('sts', 4)
|
|
->where(function ($q) {
|
|
$q->where('cash', '!=', 0)->orWhere('gold', '!=', 0);
|
|
})
|
|
->where(function ($q) {
|
|
$q->whereNull('note')
|
|
->orWhere('note', 'not like', 'fix:intval-gold-loss%');
|
|
})
|
|
->when($customerId, fn ($q) => $q->where('customer_id', $customerId))
|
|
->when($linked !== [], fn ($q) => $q->whereNotIn('id', $linked))
|
|
->orderBy('id')
|
|
->limit($limit)
|
|
->pluck('id')
|
|
->map(fn ($id) => (int) $id)
|
|
->all();
|
|
}
|
|
|
|
/** @return list<int> */
|
|
private function missingOrderIds(int $limit, ?int $customerId = null): array
|
|
{
|
|
if ($limit <= 0 || ! Schema::hasTable('orders')) {
|
|
return [];
|
|
}
|
|
|
|
$linked = Tahesab::query()
|
|
->whereNotNull('order_id')
|
|
->when($customerId, fn ($q) => $q->where('customer_id', $customerId))
|
|
->pluck('order_id')
|
|
->all();
|
|
|
|
return \App\Models\Order::query()
|
|
->where('sts', 2)
|
|
->where('payment_sts', 4)
|
|
->whereIn('direction', [1, 2])
|
|
->when($customerId, fn ($q) => $q->where('customer_id', $customerId))
|
|
->when($linked !== [], fn ($q) => $q->whereNotIn('id', $linked))
|
|
->orderBy('id')
|
|
->limit($limit)
|
|
->pluck('id')
|
|
->map(fn ($id) => (int) $id)
|
|
->all();
|
|
}
|
|
|
|
private function backfillWithdraw(TahesabController $controller, int $withdrawId): bool
|
|
{
|
|
$withdraw = \App\Models\Withdraw::query()->find($withdrawId);
|
|
if (! $withdraw || ! $withdraw->customer_id) {
|
|
return false;
|
|
}
|
|
|
|
$cash = (float) ($withdraw->cash ?? 0);
|
|
$gold = (float) ($withdraw->gold ?? 0);
|
|
|
|
if (abs($cash) > 1e-9) {
|
|
$result = $controller->wallet([
|
|
'customer_id' => (int) $withdraw->customer_id,
|
|
'value' => abs($cash),
|
|
'direction' => $cash >= 0 ? 0 : 1,
|
|
'withdraw_id' => $withdrawId,
|
|
'note' => $withdraw->note,
|
|
]);
|
|
|
|
return $result !== false;
|
|
}
|
|
|
|
if (abs($gold) > 1e-9) {
|
|
$result = $controller->walletGold([
|
|
'customer_id' => (int) $withdraw->customer_id,
|
|
'value' => abs($gold),
|
|
'direction' => $gold >= 0 ? 1 : 0,
|
|
'withdraw_id' => $withdrawId,
|
|
'note' => $withdraw->note,
|
|
]);
|
|
|
|
return $result !== false;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
private function backfillOrder(TahesabController $controller, int $orderId): bool
|
|
{
|
|
$order = \App\Models\Order::query()->with('product')->find($orderId);
|
|
if (! $order || ! $order->customer_id) {
|
|
return false;
|
|
}
|
|
|
|
$product = $order->product;
|
|
$payload = [
|
|
'customer_id' => (int) $order->customer_id,
|
|
'amount' => (float) $order->amount,
|
|
'direction' => (int) $order->direction,
|
|
'price' => (float) $order->price,
|
|
'total_price' => (float) $order->total_price,
|
|
'pay_at' => $order->pay_at ?? $order->created_at,
|
|
'product_id' => $order->product_id ? (int) $order->product_id : null,
|
|
'product' => $product ? [
|
|
'id' => (int) $product->id,
|
|
'title' => $product->title,
|
|
'group_type' => $product->group_type,
|
|
'metal_id' => $product->metal_id,
|
|
'amount' => $product->amount,
|
|
'unit' => $product->unit,
|
|
'trade_by_quantity' => $product->trade_by_quantity,
|
|
] : ['metal_id' => 1],
|
|
'order' => ['id' => $orderId, 'product_id' => $order->product_id],
|
|
];
|
|
|
|
$result = $controller->storeTrade($payload);
|
|
|
|
return $result !== false;
|
|
}
|
|
|
|
private function hasSyncColumns(): bool
|
|
{
|
|
return Schema::hasTable('tahesab') && Schema::hasColumn('tahesab', 'sync_status');
|
|
}
|
|
}
|