49 lines
1.7 KiB
Plaintext
49 lines
1.7 KiB
Plaintext
debug(f'{params_kw=}')
|
|
userid = await get_user()
|
|
userorgid = await get_userorgid()
|
|
|
|
start_date = params_kw.get('start_date', '')
|
|
end_date = params_kw.get('end_date', '')
|
|
|
|
if not start_date or not end_date:
|
|
return json.dumps({'total': 0, 'rows': [], 'stats': {'total_count': 0, 'debit_sum': 0, 'credit_sum': 0}}, ensure_ascii=False, default=str)
|
|
|
|
ns = {
|
|
'orgid': userorgid,
|
|
'start_date': start_date,
|
|
'end_date': end_date,
|
|
'page': int(params_kw.get('page', 1)),
|
|
'rows': int(params_kw.get('rows', 30)),
|
|
'sort': 'acc_date desc'
|
|
}
|
|
|
|
async with get_sor_context(request._run_ns, 'accounting') as sor:
|
|
sql = """select d.acc_date, d.acc_timestamp, d.acc_dir, d.summary,
|
|
d.amount, d.balance, s.name as subject_name
|
|
from acc_detail d
|
|
join account a on d.accountid = a.id COLLATE utf8mb4_unicode_ci
|
|
join subject s on a.subjectid = s.id COLLATE utf8mb4_unicode_ci
|
|
where a.orgid = ${orgid}$
|
|
and d.acc_date >= ${start_date}$
|
|
and d.acc_date <= ${end_date}$"""
|
|
ret = await sor.sqlExe(sql, ns)
|
|
|
|
# 统计数据
|
|
stats_sql = """select
|
|
count(*) as total_count,
|
|
coalesce(sum(case when d.acc_dir = '1' then d.amount else 0 end), 0) as debit_sum,
|
|
coalesce(sum(case when d.acc_dir = '0' then d.amount else 0 end), 0) as credit_sum
|
|
from acc_detail d
|
|
join account a on d.accountid = a.id COLLATE utf8mb4_unicode_ci
|
|
where a.orgid = ${orgid}$
|
|
and d.acc_date >= ${start_date}$
|
|
and d.acc_date <= ${end_date}$"""
|
|
stats_recs = await sor.sqlExe(stats_sql, ns)
|
|
stats = {
|
|
'total_count': int(stats_recs[0].total_count) if stats_recs else 0,
|
|
'debit_sum': float(stats_recs[0].debit_sum) if stats_recs else 0,
|
|
'credit_sum': float(stats_recs[0].credit_sum) if stats_recs else 0
|
|
}
|
|
ret['stats'] = stats
|
|
return json.dumps(ret, ensure_ascii=False, default=str)
|