yumoqing/accounting
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2024-12-13 11:34:08 +08:00
parent 41661535ba
commit ba5b74b447
1 changed files with 23 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
accounting/openaccount.py
View File

@ -5,7 +5,7 @@ from appPublic.registerfunction import RegisterFunction
from appPublic.log import debug, exception
from datetime import datetime
async def openAccount(sor, accounting_orgid, orgid, account_config):
async def openAccount(sor, accounting_orgid, orgid, account_config, org1id=None):
ns = {
'id':getID(),
'accounting_orgid':accounting_orgid,
@ -14,18 +14,27 @@ async def openAccount(sor, accounting_orgid, orgid, account_config):
'balance_at':account_config['balance_side'],
'max_detailno':0
}
if org1id:
ns['org1id'] = org1id;
debug(f'openAccount(), {ns=}')
await sor.C('account', ns.copy())
print(ns, 'opened')
async def openPartyAccounts(sor, accounting_orgid, orgid, party_type):
async def openPartyAccounts(sor, accounting_orgid, orgid, party_type, org1id=None, party1_type=None):
addon_cond = " and a.party1type is NULL "
ns = {'partytype':party_type}
if party1_type:
addon_cond = " and a.party1type = ${party1type}$ "
ns['party1type'] = party1_type
sql = """select a.*, b.id as subjectid, b.balance_side from account_config a, subject b
where a.subjectname = b.name
where a.subjectname = b.name """
+ addon_cond + """
and a.partytype=${partytype}$ """
recs = await sor.sqlExe(sql, {'partytype':party_type})
recs = await sor.sqlExe(sql, ns)
# print(f'select account_config {recs=}', party_type)
for r in recs:
await openAccount(sor, accounting_orgid, orgid, r)
await openAccount(sor, accounting_orgid, orgid, r, org1id=org1id)
async def _openPartyAccounts(accounting_orgid, orgid, party_type):
db = DBPools()
@ -78,4 +87,13 @@ async def openAllProviderAccounts(sor, accounting_orgid):
for r in recs:
await openProviderAccounts(sor, accounting_orgid, r['id'])
async def openRetailRelationshipAccounts(sor, accounting_orgid, providerid, resellerid):
db = DBPools()
async with db.sqlorContext(DBNAME()) as sor:
await openPartyAccounts(sor, accounting_orgid, providerid, PARTY_PROVIDER,
org1id=resellerid,
party1_type=PARTY_RESELLER)
await openPartyAccounts(sor, accounting_orgid, resellerid, PARTY_RESELLER,
org1id=providerid,
party1_type=PARTY_PROVIDER)