40 lines
1.9 KiB
Plaintext
40 lines
1.9 KiB
Plaintext
async def add_cpcwidget(params_kw={}):
|
||
ns = params_kw.copy()
|
||
cpcid = params_kw.get('cpcid')
|
||
clusterid = params_kw.get('clusterid')
|
||
type = params_kw.get('type')
|
||
model = params_kw.get('model')
|
||
stock = params_kw.get('stock')
|
||
add_opt = params_kw.get('add_opt', 'no')
|
||
if (not cpcid) or (not clusterid):
|
||
return {'status': False,'msg': '无算力中心ID或集群ID'}
|
||
id = params_kw.id
|
||
if not id or len(id) > 32:
|
||
id = uuid()
|
||
ns['id'] = id
|
||
|
||
db = DBPools()
|
||
dbname = 'kboss'
|
||
async with db.sqlorContext(dbname) as sor:
|
||
ns["update_time"] = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
|
||
kw = ns.copy()
|
||
# 插入前先判断是否已存在
|
||
uniquejson = {'cpcid':cpcid, 'clusterid':clusterid, 'type': type, 'model':model}
|
||
cpcwidgets = await sor.R('cpcwidget', uniquejson)
|
||
if len(cpcwidgets) >= 1:
|
||
debug(f'cpcwidget 记录 {uniquejson} 已存在! 是否增加库存: {add_opt}')
|
||
if str(add_opt) == 'yes':
|
||
debug(f'-- 该部件已存在，增加库存{stock}个单位，但若结果为负则设为0')
|
||
bsql = f'''update cpcwidget set stock = case when cpcid = '{cpcid}' and type = '{type}' and clusterid = '{clusterid}' and model = '{model}' then greatest(stock + {stock}, 0) else stock end'''
|
||
debug(f'库存增加sql: {bsql}')
|
||
await sor.sqlExe(bsql, {})
|
||
return {'status': True,'msg': f'该部件已存在，新增库存数:{stock}成功','data': uniquejson}
|
||
else:
|
||
debug(f'该部件已存在，该模式只可编辑价格！')
|
||
return {'status': False,'msg': '该部件已存在，请前往编辑价格！'}
|
||
r = await sor.C('cpcwidget', kw)
|
||
return {'status': True,'msg': '新增算力部件成功','data': kw}
|
||
return {'status': False,'msg': '新增算力部件失败'}
|
||
|
||
ret = await add_cpcwidget(params_kw)
|
||
return ret |