+ در این صفحه «منتزر» یعنی همین سامانه: اپ مشتری (جایی که مشتری ثبت‌نام، احراز هویت و سفارش می‌کند و مانده‌اش را می‌بیند) و + پنل مدیریت (همین پنل، جایی که محصول و دسته‌بندی تعریف می‌شود). «حسابداری» یعنی نرم‌افزار حسابداری مغازه (ته‌حساب یا زرین). +
++ منتزر و حسابداری هر کدام گروه‌بندی خودشان را دارند. این تب می‌گوید هر چیز در منتزر با کدام گروه در حسابداری متناظر است؛ + خودِ مشتری‌ها و محصول‌ها اینجا وصل نمی‌شوند (آن‌ها در تب «لینک‌ها» دیده می‌شوند). +
++ تغییر این تنظیمات فقط روی موارد بعدی اثر دارد؛ حساب‌ها و کارساخته‌هایی که قبلاً ساخته شده‌اند جابه‌جا نمی‌شوند. در آخر «ذخیره» را بزنید. +
+kind=listGorooheHesabha&token=SECRET failed
', 500)); + const err = await z.listCustomerGroups(s).catch((e) => e); + expect(err.message).toContain('HTTP 500 — Server Error'); + expect(err.message).toContain('failed'); + expect(err.message).not.toContain('SECRET'); + + http.mockReturnValueOnce(reply({ state: false, msg: 'شناسه نامعتبر' }, 400)); + await expect(z.listCustomerGroups(s)).rejects.toThrow('HTTP 400 — شناسه نامعتبر'); + }); + it('lists the different envelopes Zarrin uses', () => { const { listOf, fullJalali } = __zarrinInternals; expect(listOf({ data: [1] })).toEqual([1]); @@ -70,17 +81,76 @@ describe('wire format', () => { }); describe('customers', () => { - it('pages with Get100Account and fills groups from listhesabha', async () => { - const page = Array.from({ length: 100 }, (_, i) => ({ code: 81 + i, name: 'n', namKhanevadegi: `f${i}`, mobile: i === 0 ? '09121112233' : '' })); - http - .mockReturnValueOnce(reply({ state: true, msg: '', date: page })) - .mockReturnValueOnce(reply({ data: [{ id: '81', nam: 'حسین اصغری', gorooh: 'مشتری (خریدار)', tell: '021', mobile: '09121112233', codeMeli: '' }] })); + it('lists every account with its group from one listhesabha call', async () => { + http.mockReturnValueOnce( + reply({ + data: [ + { id: '81', nam: 'حسین اصغری', gorooh: 'مشتری (خریدار)', tell: '021', mobile: '09121112233', codeMeli: '' }, + { id: '82', nam: 'آرین یوسفی', gorooh: 'سازنده (تامین کننده)', tell: '', mobile: '', codeMeli: '' }, + ], + }), + ); const res = await z.listCustomers(s, null); - expect(url(0).searchParams.get('id')).toBe('0'); - expect(url(1).searchParams.get('az')).toBe('81'); - expect(url(1).searchParams.get('ta')).toBe('180'); + expect(http).toHaveBeenCalledTimes(1); + expect(url(0).searchParams.get('kind')).toBe('listhesabha'); + expect(url(0).searchParams.get('az')).toBe('1'); + expect(res.items).toHaveLength(2); expect(res.items[0]).toMatchObject({ code: '81', name: 'حسین اصغری', mobile: '09121112233', groupName: 'مشتری (خریدار)', phone: '021' }); - expect(res.next).toBe('181'); + expect(res.items[1].mobile).toBeNull(); + expect(res.next).toBeNull(); + }); + + it('finds by mobile with searchAccount, keeping exact matches only', async () => { + http.mockReturnValueOnce( + reply({ + state: true, + msg: '', + date: [ + { code: 84, name: 'سعید', namKhanevadegi: 'رجایی', mobile: '09121995971' }, + { code: 90, name: 'x', namKhanevadegi: 'y', mobile: '09121995972' }, + ], + }), + ); + const found = await z.findCustomersByMobile(s, '09121995971'); + expect(url(0).searchParams.get('kind')).toBe('searchAccount'); + expect(found.map((c) => c.code)).toEqual(['84']); + expect(found[0].name).toBe('سعید رجایی'); + }); + + it('falls back to listhesabha when searchAccount is missing (bare 400)', async () => { + http + .mockReturnValueOnce(reply('', 400)) + .mockReturnValueOnce(reply({ data: [{ id: '84', nam: 'رجایی * سعید', gorooh: 'مشتری (خریدار)', mobile: '09121995971' }, { id: '85', nam: 'z', mobile: '' }] })); + const found = await z.findCustomersByMobile(s, '09121995971'); + expect(url(1).searchParams.get('kind')).toBe('listhesabha'); + expect(found.map((c) => c.code)).toEqual(['84']); + }); + + it('does not hide other errors behind the fallback', async () => { + http.mockReturnValueOnce(reply('', 500)); + await expect(z.findCustomersByMobile(s, '09121995971')).rejects.toThrow('HTTP 500'); + }); + + it('lists karsakhte groups with goroohSakhte when the installation has it', async () => { + http.mockReturnValueOnce(reply({ state: true, detail: 'OK', data: [{ id: '26', name: 'النگو' }] })); + expect(await z.listKarSakhteGroups!(s)).toEqual([{ id: '26', name: 'النگو' }]); + expect(http).toHaveBeenCalledTimes(1); + }); + + it('scans karsakhte groups with infogorooh when goroohSakhte is missing, skipping ids that fail', async () => { + http.mockImplementation((req) => { + const u = new URL(req.url); + if (u.searchParams.get('kind') === 'goroohSakhte') return reply('', 400); + const id = u.searchParams.get('id'); + if (id === '26') return reply({ data: [{ nam: 'النگو', code: 26 }] }); + if (id === '115') return reply({ data: [{ nam: 'سکه', code: 115 }] }); + if (id === '3') return reply('', 500); + return reply('{\n "data": \n ]\n}'); + }); + expect(await z.listKarSakhteGroups!(s)).toEqual([ + { id: '26', name: 'النگو' }, + { id: '115', name: 'سکه' }, + ]); }); it('keeps the account in its group on edit', async () => { diff --git a/apps/api/src/modules/accounting-sync/providers/zarrin.provider.ts b/apps/api/src/modules/accounting-sync/providers/zarrin.provider.ts index cd3d4a6..209de7d 100644 --- a/apps/api/src/modules/accounting-sync/providers/zarrin.provider.ts +++ b/apps/api/src/modules/accounting-sync/providers/zarrin.provider.ts @@ -40,11 +40,51 @@ import { const STATEMENT_PAGE = 250; const CHANGE_WINDOW = 50; const MAX_STATEMENT_PAGES = 20; +const ALL_CODES = { az: 1, ta: 999999 }; +const GROUP_SCAN_MAX = 300; +const GROUP_SCAN_CONCURRENCY = 10; function endpoint(s: ProviderSettings) { return s.baseUrl.trim(); } +class ZarrinHttpError extends AccountingProviderError { + constructor( + message: string, + body: string, + readonly status: number, + ) { + super(message, false, body, status === 404); + } +} + +/** + * Installations lack some documented kinds (v228 has no Get100Account, + * goroohSakhte or getinfoByPhone) and answer them with a bare 400. + */ +function isMissingKind(err: unknown) { + return err instanceof ZarrinHttpError && err.status === 400; +} + +/** + * What the server said on a non-2xx reply, short enough for the admin screen. + * Error pages may echo the request URL, so the token is scrubbed. + */ +function errorBodyText(body: string, token: string) { + let text = body; + try { + const j = parseLooseJson(body) as any; + const o = typeof j === 'string' && /^\s*[{[]/.test(j) ? parseLooseJson(j) : j; + if (o && typeof o === 'object') text = str(o.msg) ?? str(o.detail) ?? str(o.message) ?? str(o.Message) ?? str(o.title) ?? JSON.stringify(o); + else if (typeof o === 'string') text = o; + } catch { + text = body.replace(/<(script|style)[\s\S]*?<\/\1>/gi, ' ').replace(/<[^>]+>/g, ' '); + } + if (token) for (const t of new Set([token, encodeURIComponent(token)])) text = text.split(t).join('***'); + text = text.replace(/\s+/g, ' ').trim(); + return text.length > 200 ? `${text.slice(0, 200)}…` : text; +} + async function call( s: ProviderSettings, kind: string, @@ -73,7 +113,8 @@ async function call( } if (res.status < 200 || res.status >= 300) { - throw new AccountingProviderError(`زرین (${kind}): HTTP ${res.status}`, false, res.body.slice(0, 500), res.status === 404); + const reason = errorBodyText(res.body, s.token); + throw new ZarrinHttpError(`زرین (${kind}): HTTP ${res.status}${reason ? ` — ${reason}` : ''}`, res.body.slice(0, 500), res.status); } let json: unknown; @@ -96,7 +137,7 @@ async function call( return json as Record