safavimohadeseh78andCursor
a42261c06e
Wire outbound Invoice/Document sync after confirmed ops, store sync status with timeout lock, and keep SQL credentials out of frontend responses. Co-authored-by: Cursor <cursoragent@cursor.com>
476 lines
17 KiB
PHP
476 lines
17 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Models\Customer;
|
|
use App\Models\Shayegan;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Facades\Schema;
|
|
use Illuminate\Support\Str;
|
|
|
|
/**
|
|
* Outbound Shayegan sync — does not mutate wallets.
|
|
* Timeout rows stay timeout and are never auto-retried.
|
|
*/
|
|
class ShayeganSyncService
|
|
{
|
|
public const STATUS_PENDING = 'pending';
|
|
public const STATUS_SUCCESS = 'success';
|
|
public const STATUS_FAILED = 'failed';
|
|
public const STATUS_TIMEOUT = 'timeout';
|
|
|
|
public const TYPE_TRADE = 'trade';
|
|
public const TYPE_WALLET_CASH = 'wallet_cash';
|
|
public const TYPE_WALLET_GOLD = 'wallet_gold';
|
|
public const TYPE_CUSTOMER = 'customer';
|
|
|
|
/** InvTyp from Shayegan PDF (company view). */
|
|
public const INV_SALE = 2;
|
|
public const INV_PURCHASE = 3;
|
|
public const INV_HAVALE = 4;
|
|
public const INV_RECEIPT = 5;
|
|
|
|
/** @var ConfigService */
|
|
private $config;
|
|
|
|
/** @var ShayeganClient */
|
|
private $client;
|
|
|
|
public function __construct(ConfigService $config, ShayeganClient $client)
|
|
{
|
|
$this->config = $config;
|
|
$this->client = $client;
|
|
}
|
|
|
|
public function isSyncEnabled(): bool
|
|
{
|
|
return $this->config->isShayeganAccounting()
|
|
&& $this->client->isConfigured();
|
|
}
|
|
|
|
public function tradeMappingReady(): bool
|
|
{
|
|
return $this->config->getString('shayegan_item_copper', '') !== ''
|
|
&& $this->config->getString('shayegan_stock_number', '') !== '';
|
|
}
|
|
|
|
public function cashMappingReady(): bool
|
|
{
|
|
return $this->config->getString('shayegan_bank_account', '') !== '';
|
|
}
|
|
|
|
public function metalWalletMode(): string
|
|
{
|
|
$mode = strtolower(trim($this->config->getString('shayegan_metal_wallet_mode', 'skip')));
|
|
if (in_array($mode, ['skip', 'document', 'receipt_havale'], true)) {
|
|
return $mode;
|
|
}
|
|
|
|
return 'skip';
|
|
}
|
|
|
|
/**
|
|
* After confirmed trade: one Invoice only (no duplicate Document).
|
|
* Customer buy → company sale (InvTyp 2); customer sell → company purchase (InvTyp 3).
|
|
*
|
|
* @param array<string, mixed> $data
|
|
*/
|
|
public function recordTrade(array $data): ?Shayegan
|
|
{
|
|
if (! $this->isSyncEnabled()) {
|
|
return null;
|
|
}
|
|
if (! $this->tradeMappingReady()) {
|
|
Log::info('shayegan.trade_skipped_mapping', ['order_id' => $data['order']->id ?? null]);
|
|
return null;
|
|
}
|
|
|
|
$order = $data['order'] ?? null;
|
|
$orderId = $order ? (int) $order->id : (int) ($data['order_id'] ?? 0);
|
|
$customerId = (int) ($data['customer_id'] ?? ($order->customer_id ?? 0));
|
|
if ($customerId <= 0) {
|
|
return null;
|
|
}
|
|
|
|
$existing = $this->findExisting(self::TYPE_TRADE, $orderId > 0 ? $orderId : null, null, $customerId);
|
|
if ($existing && $this->shouldSkipSend($existing)) {
|
|
return $existing;
|
|
}
|
|
|
|
$customer = Customer::find($customerId);
|
|
$accountNumber = $this->customerAccountNumber($customer);
|
|
if ($accountNumber === '') {
|
|
return $this->markLocalFailed($existing, $customerId, $orderId, null, self::TYPE_TRADE, 'کد حساب مشتری در شایگان خالی است (moshtari_code).', null);
|
|
}
|
|
|
|
$isBuy = (int) ($data['direction'] ?? 0) === 1;
|
|
$invTyp = $isBuy ? self::INV_SALE : self::INV_PURCHASE;
|
|
$quan = $this->scaleWeight((float) ($data['number'] ?? $data['amount'] ?? 0));
|
|
$price = $this->scaleAmount((float) ($data['price'] ?? $data['fee'] ?? 0));
|
|
if ($quan <= 0) {
|
|
return $this->markLocalFailed($existing, $customerId, $orderId, null, self::TYPE_TRADE, 'مقدار وزن معامله برای شایگان صفر است.', null);
|
|
}
|
|
|
|
$guid = $existing && $existing->request_guid
|
|
? (string) $existing->request_guid
|
|
: (string) Str::uuid();
|
|
|
|
$today = date('Ymd');
|
|
$put = [[
|
|
'Body' => [[
|
|
'STNumber' => $this->config->getString('shayegan_stock_number', ''),
|
|
'STGuId' => null,
|
|
'ItemNumber' => $this->config->getString('shayegan_item_copper', ''),
|
|
'ItemGuId' => null,
|
|
'Quan' => $quan,
|
|
'Quan2' => null,
|
|
'Price' => $price > 0 ? $price : null,
|
|
'Price2' => null,
|
|
'LineDiscAmount' => null,
|
|
'LineItemDesc' => $isBuy ? 'خرید مس مشتری' : 'فروش مس مشتری',
|
|
'UpdateKind' => 0,
|
|
]],
|
|
'Expense' => [],
|
|
'InvTyp' => $invTyp,
|
|
'InvNo' => null,
|
|
'InvDescription' => $isBuy ? 'فروش مس به مشتری' : 'خرید مس از مشتری',
|
|
'InvDate' => $today,
|
|
'InvPayDue' => $today,
|
|
'AccountNumber' => $accountNumber,
|
|
'AccountGuId' => null,
|
|
'GeneralRef' => $orderId > 0 ? ('order:' . $orderId) : null,
|
|
'GuId' => $guid,
|
|
'UpdateKind' => 0,
|
|
]];
|
|
|
|
$row = $existing ?: new Shayegan();
|
|
$row->customer_id = $customerId;
|
|
$row->order_id = $orderId > 0 ? $orderId : null;
|
|
$row->withdraw_id = null;
|
|
$row->amount = $this->scaleAmount((float) ($data['total'] ?? $data['total_price'] ?? ($quan * $price)));
|
|
$row->desc = $put[0]['InvDescription'];
|
|
$row->type = self::TYPE_TRADE;
|
|
$row->date = now();
|
|
$row->endpoint = 'Invoice/Put';
|
|
$row->request_guid = $guid;
|
|
$row->data = json_encode($this->client->redactPayload([
|
|
'Config' => $this->client->buildConfig(),
|
|
'PutObject' => $put,
|
|
]), JSON_UNESCAPED_UNICODE);
|
|
$row->sync_status = self::STATUS_PENDING;
|
|
$row->sync_log = null;
|
|
$row->save();
|
|
|
|
return $this->dispatchPut($row, 'Invoice/Put', $put);
|
|
}
|
|
|
|
/**
|
|
* Rial wallet: Document only (not Invoice).
|
|
* direction: 0 deposit, 1 withdraw (same as Zarin/Tahesab wallet cash).
|
|
*
|
|
* @param array<string, mixed> $data
|
|
*/
|
|
public function recordWalletCash(array $data): ?Shayegan
|
|
{
|
|
if (! $this->isSyncEnabled()) {
|
|
return null;
|
|
}
|
|
if (! $this->cashMappingReady()) {
|
|
Log::info('shayegan.cash_skipped_mapping', ['withdraw_id' => $data['withdraw_id'] ?? null]);
|
|
return null;
|
|
}
|
|
|
|
$customerId = (int) ($data['customer_id'] ?? 0);
|
|
$withdrawId = isset($data['withdraw_id']) ? (int) $data['withdraw_id'] : null;
|
|
$customer = Customer::find($customerId);
|
|
$accountNumber = $this->customerAccountNumber($customer);
|
|
if ($accountNumber === '') {
|
|
return null;
|
|
}
|
|
|
|
$existing = $this->findExisting(self::TYPE_WALLET_CASH, null, $withdrawId, $customerId);
|
|
if ($existing && $this->shouldSkipSend($existing)) {
|
|
return $existing;
|
|
}
|
|
|
|
$isDeposit = (int) ($data['direction'] ?? 0) === 0;
|
|
$amount = $this->scaleAmount(abs((float) ($data['value'] ?? 0)));
|
|
if ($amount <= 0) {
|
|
return null;
|
|
}
|
|
|
|
$bank = $this->config->getString('shayegan_bank_account', '');
|
|
$guid = $existing && $existing->request_guid
|
|
? (string) $existing->request_guid
|
|
: (string) Str::uuid();
|
|
|
|
// Deposit: bank debit + customer credit. Withdraw: customer debit + bank credit.
|
|
if ($isDeposit) {
|
|
$body = [
|
|
['AccountNumber' => $bank, 'AmountBed' => $amount, 'AmountBes' => 0, 'RialBed' => $amount, 'RialBes' => 0, 'DocRowDesc' => 'واریز ریالی'],
|
|
['AccountNumber' => $accountNumber, 'AmountBed' => 0, 'AmountBes' => $amount, 'RialBed' => 0, 'RialBes' => $amount, 'DocRowDesc' => 'واریز ریالی مشتری'],
|
|
];
|
|
$desc = 'واریز ریالی';
|
|
} else {
|
|
$body = [
|
|
['AccountNumber' => $accountNumber, 'AmountBed' => $amount, 'AmountBes' => 0, 'RialBed' => $amount, 'RialBes' => 0, 'DocRowDesc' => 'برداشت ریالی مشتری'],
|
|
['AccountNumber' => $bank, 'AmountBed' => 0, 'AmountBes' => $amount, 'RialBed' => 0, 'RialBes' => $amount, 'DocRowDesc' => 'برداشت ریالی'],
|
|
];
|
|
$desc = 'برداشت ریالی';
|
|
}
|
|
|
|
$put = [[
|
|
'Body' => $body,
|
|
'DocDescription' => trim((string) ($data['note'] ?? '')) !== '' ? (string) $data['note'] : $desc,
|
|
'DocDate' => date('Ymd'),
|
|
'DocReference' => $withdrawId ? ('withdraw:' . $withdrawId) : null,
|
|
'GuId' => $guid,
|
|
'UpdateKind' => 0,
|
|
]];
|
|
|
|
$row = $existing ?: new Shayegan();
|
|
$row->customer_id = $customerId;
|
|
$row->order_id = null;
|
|
$row->withdraw_id = $withdrawId;
|
|
$row->amount = $amount;
|
|
$row->desc = $desc;
|
|
$row->type = self::TYPE_WALLET_CASH;
|
|
$row->date = now();
|
|
$row->endpoint = 'Document/Put';
|
|
$row->request_guid = $guid;
|
|
$row->data = json_encode($this->client->redactPayload([
|
|
'Config' => $this->client->buildConfig(),
|
|
'PutObject' => $put,
|
|
]), JSON_UNESCAPED_UNICODE);
|
|
$row->sync_status = self::STATUS_PENDING;
|
|
$row->sync_log = null;
|
|
$row->save();
|
|
|
|
return $this->dispatchPut($row, 'Document/Put', $put);
|
|
}
|
|
|
|
/**
|
|
* Product / metal wallet movement — never invent warehouse unless mode says so.
|
|
* direction: 1 deposit, 0 withdraw (walletGold convention).
|
|
*
|
|
* @param array<string, mixed> $data
|
|
*/
|
|
public function recordWalletGold(array $data): ?Shayegan
|
|
{
|
|
if (! $this->isSyncEnabled()) {
|
|
return null;
|
|
}
|
|
|
|
$mode = $this->metalWalletMode();
|
|
if ($mode === 'skip') {
|
|
return null;
|
|
}
|
|
|
|
$customerId = (int) ($data['customer_id'] ?? 0);
|
|
$withdrawId = isset($data['withdraw_id']) ? (int) $data['withdraw_id'] : null;
|
|
$customer = Customer::find($customerId);
|
|
$accountNumber = $this->customerAccountNumber($customer);
|
|
if ($accountNumber === '') {
|
|
return null;
|
|
}
|
|
|
|
$existing = $this->findExisting(self::TYPE_WALLET_GOLD, null, $withdrawId, $customerId);
|
|
if ($existing && $this->shouldSkipSend($existing)) {
|
|
return $existing;
|
|
}
|
|
|
|
$isDeposit = (int) ($data['direction'] ?? 1) === 1;
|
|
$quan = $this->scaleWeight(abs((float) ($data['value'] ?? 0)));
|
|
if ($quan <= 0) {
|
|
return null;
|
|
}
|
|
|
|
$guid = $existing && $existing->request_guid
|
|
? (string) $existing->request_guid
|
|
: (string) Str::uuid();
|
|
|
|
if ($mode === 'receipt_havale') {
|
|
if (! $this->tradeMappingReady()) {
|
|
return null;
|
|
}
|
|
$invTyp = $isDeposit ? self::INV_RECEIPT : self::INV_HAVALE;
|
|
$put = [[
|
|
'Body' => [[
|
|
'STNumber' => $this->config->getString('shayegan_stock_number', ''),
|
|
'ItemNumber' => $this->config->getString('shayegan_item_copper', ''),
|
|
'Quan' => $quan,
|
|
'Price' => null,
|
|
'LineItemDesc' => $isDeposit ? 'واریز محصول' : 'برداشت محصول',
|
|
'UpdateKind' => 0,
|
|
]],
|
|
'Expense' => [],
|
|
'InvTyp' => $invTyp,
|
|
'InvNo' => null,
|
|
'InvDescription' => $isDeposit ? 'رسید انبار (واریز محصول)' : 'حواله (برداشت محصول)',
|
|
'InvDate' => date('Ymd'),
|
|
'AccountNumber' => $accountNumber,
|
|
'GeneralRef' => $withdrawId ? ('withdraw:' . $withdrawId) : null,
|
|
'GuId' => $guid,
|
|
'UpdateKind' => 0,
|
|
]];
|
|
$endpoint = 'Invoice/Put';
|
|
$desc = $put[0]['InvDescription'];
|
|
} else {
|
|
// document mode: accounting note only — no stock invoice
|
|
$bank = $this->config->getString('shayegan_bank_account', '');
|
|
if ($bank === '') {
|
|
Log::info('shayegan.gold_document_needs_bank_or_switch_mode');
|
|
return null;
|
|
}
|
|
// Placeholder balanced zero-amount skip — without operator chart of accounts for metal,
|
|
// document mode requires explicit counterpart accounts; refuse rather than invent.
|
|
Log::info('shayegan.gold_document_needs_account_map', [
|
|
'hint' => 'Provide metal counterpart accounts or use receipt_havale after confirming warehouse semantics.',
|
|
]);
|
|
|
|
return null;
|
|
}
|
|
|
|
$row = $existing ?: new Shayegan();
|
|
$row->customer_id = $customerId;
|
|
$row->order_id = null;
|
|
$row->withdraw_id = $withdrawId;
|
|
$row->amount = $quan;
|
|
$row->desc = $desc;
|
|
$row->type = self::TYPE_WALLET_GOLD;
|
|
$row->date = now();
|
|
$row->endpoint = $endpoint;
|
|
$row->request_guid = $guid;
|
|
$row->data = json_encode($this->client->redactPayload([
|
|
'Config' => $this->client->buildConfig(),
|
|
'PutObject' => $put,
|
|
]), JSON_UNESCAPED_UNICODE);
|
|
$row->sync_status = self::STATUS_PENDING;
|
|
$row->sync_log = null;
|
|
$row->save();
|
|
|
|
return $this->dispatchPut($row, $endpoint, $put);
|
|
}
|
|
|
|
/**
|
|
* @param array<int, array<string, mixed>> $putObject
|
|
*/
|
|
private function dispatchPut(Shayegan $row, string $endpoint, array $putObject): Shayegan
|
|
{
|
|
$result = $this->client->put($endpoint, $putObject);
|
|
|
|
if (! empty($result['timeout'])) {
|
|
$row->sync_status = self::STATUS_TIMEOUT;
|
|
$row->sync_log = (string) ($result['message'] ?? 'timeout');
|
|
$row->res = json_encode(['timeout' => true, 'message' => $result['message'] ?? null], JSON_UNESCAPED_UNICODE);
|
|
$row->save();
|
|
|
|
return $row;
|
|
}
|
|
|
|
if (! empty($result['ok'])) {
|
|
$row->sync_status = self::STATUS_SUCCESS;
|
|
$row->sync_log = null;
|
|
$row->shayegan_number = $result['number'] ?? null;
|
|
$row->shayegan_guid = $result['guid'] ?? null;
|
|
$row->res = json_encode($result['body'] ?? [], JSON_UNESCAPED_UNICODE);
|
|
$row->save();
|
|
|
|
return $row;
|
|
}
|
|
|
|
$row->sync_status = self::STATUS_FAILED;
|
|
$row->sync_log = (string) ($result['message'] ?? 'failed');
|
|
$row->res = json_encode($result['body'] ?? ['message' => $result['message'] ?? null], JSON_UNESCAPED_UNICODE);
|
|
$row->save();
|
|
|
|
return $row;
|
|
}
|
|
|
|
private function shouldSkipSend(Shayegan $row): bool
|
|
{
|
|
$status = (string) $row->sync_status;
|
|
if ($status === self::STATUS_SUCCESS) {
|
|
return true;
|
|
}
|
|
// Never auto-resend after timeout without manual verification.
|
|
if ($status === self::STATUS_TIMEOUT) {
|
|
return true;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
private function findExisting(string $type, ?int $orderId, ?int $withdrawId, int $customerId): ?Shayegan
|
|
{
|
|
if (! Schema::hasTable('shayegan')) {
|
|
return null;
|
|
}
|
|
|
|
$q = Shayegan::query()->where('type', $type)->where('customer_id', $customerId);
|
|
if ($orderId) {
|
|
$q->where('order_id', $orderId);
|
|
}
|
|
if ($withdrawId) {
|
|
$q->where('withdraw_id', $withdrawId);
|
|
}
|
|
if (! $orderId && ! $withdrawId) {
|
|
return null;
|
|
}
|
|
|
|
return $q->orderByDesc('id')->first();
|
|
}
|
|
|
|
private function customerAccountNumber(?Customer $customer): string
|
|
{
|
|
if (! $customer) {
|
|
return '';
|
|
}
|
|
|
|
return trim((string) ($customer->moshtari_code ?? ''));
|
|
}
|
|
|
|
private function scaleAmount(float $amount): float
|
|
{
|
|
$scale = (float) $this->config->getString('shayegan_amount_scale', '1');
|
|
if ($scale <= 0) {
|
|
$scale = 1.0;
|
|
}
|
|
|
|
return round($amount * $scale, 4);
|
|
}
|
|
|
|
private function scaleWeight(float $weight): float
|
|
{
|
|
$scale = (float) $this->config->getString('shayegan_weight_scale', '1');
|
|
if ($scale <= 0) {
|
|
$scale = 1.0;
|
|
}
|
|
|
|
return round($weight * $scale, 6);
|
|
}
|
|
|
|
private function markLocalFailed(
|
|
?Shayegan $existing,
|
|
int $customerId,
|
|
?int $orderId,
|
|
?int $withdrawId,
|
|
string $type,
|
|
string $message,
|
|
$amount
|
|
): Shayegan {
|
|
$row = $existing ?: new Shayegan();
|
|
$row->customer_id = $customerId;
|
|
$row->order_id = $orderId;
|
|
$row->withdraw_id = $withdrawId;
|
|
$row->amount = $amount;
|
|
$row->type = $type;
|
|
$row->date = now();
|
|
$row->sync_status = self::STATUS_FAILED;
|
|
$row->sync_log = $message;
|
|
$row->save();
|
|
|
|
return $row;
|
|
}
|
|
}
|