30 lines
1.3 KiB
Plaintext
30 lines
1.3 KiB
Plaintext
async def addcp_discount(ns):
|
|
"""
|
|
客户折扣设置
|
|
"""
|
|
db = DBPools()
|
|
async with db.sqlorContext('kboss') as sor:
|
|
if ns:
|
|
offer_salemaniduser = await sor.R('users',{"id":ns['offer_salemanid']})
|
|
dictns = {}
|
|
dictns['id'] = uuid()
|
|
dictns['offer_salemanid'] = ns['offer_salemanid']
|
|
dictns['offer_orgid'] = offer_salemaniduser[0]['orgid']
|
|
dictns['bid_orgid'] = ns['customerid']
|
|
dictns['salemode'] = '0'
|
|
dictns['start_date'] = datetime.datetime.now()
|
|
dictns['end_date'] = '9999-12-31'
|
|
await sor.C('saleprotocol', dictns)
|
|
products = await sor.R('product', {'id': ns['productid']})
|
|
product_salemode = {}
|
|
product_salemode['id'] = uuid()
|
|
product_salemode['protocolid'] = dictns['id']
|
|
product_salemode['providerid'] = products[0]['providerid']
|
|
product_salemode['productid'] = ns['productid']
|
|
product_salemode['discount'] = ns['discount']
|
|
await sor.C('product_salemode', product_salemode)
|
|
return {'status': True, 'msg': '添加成功'}
|
|
return {'status': False, 'msg': '添加失败'}
|
|
|
|
ret = await addcp_discount(params_kw)
|
|
return ret |