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

fix: add_pricing_program_timing 补充 sor.C() 插入新记录

Browse Source
This commit is contained in:
yumoqing 2026-07-14 17:58:43 +08:00
parent 25457aff6d
commit cea95f98ec
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pricing/pricing.py
View File

@ -4,6 +4,7 @@ from ahserver.serverenv import ServerEnv
from ahserver.filestorage import FileStorage from ahserver.filestorage import FileStorage
from sqlor.dbpools import DBPools, get_sor_context from sqlor.dbpools import DBPools, get_sor_context
from appPublic.log import debug, exception, info, MyLogger from appPublic.log import debug, exception, info, MyLogger
from appPublic.uniqueID import getID
from appPublic.timeUtils import curDateString from appPublic.timeUtils import curDateString
from appPublic.dictObject import DictObject from appPublic.dictObject import DictObject
from appPublic.jsonConfig import getConfig from appPublic.jsonConfig import getConfig
@ -1063,6 +1064,9 @@ async def add_pricing_program_timing(env, sor, ns):
prev = await sor.R('pricing_program_timing', {'ppid': ppid, 'expired_date': '9999-12-31'}) prev = await sor.R('pricing_program_timing', {'ppid': ppid, 'expired_date': '9999-12-31'})
if prev: if prev:
await sor.U('pricing_program_timing', {'id': prev[0].id, 'expired_date': enabled_date}) await sor.U('pricing_program_timing', {'id': prev[0].id, 'expired_date': enabled_date})
# 插入新记录
ns['id'] = ns.get('id') or getID()
await sor.C('pricing_program_timing', ns)
def load_pricing(): def load_pricing():