Compare commits

..

No commits in common. "ed21a9cb7bcb6f92a11223e3b6ceb8091c48b609" and "c08a6fcdc229eb2b784edd2bed8219cf27ab55b4" have entirely different histories.

3 changed files with 11 additions and 63 deletions

View File

@ -1,37 +1,13 @@
async def delete_user_inquiry(ns={}):
db = DBPools()
async with db.sqlorContext('kboss') as sor:
ids = ns.get('ids') or ns.get('id')
if not ids:
return {
'status': False,
'msg': '请传递id'
}
if isinstance(ids, str):
if '[' in ids:
ids = ids.replace("'", '"')
ids = json.loads(ids)
elif ',' in ids:
ids = ids.replace('"', '').replace("'", '').split(',')
else:
ids = [ids]
delete_count = 0
for inquiry_id in ids:
if not inquiry_id:
continue
ns_c = {
'id': inquiry_id
}
await sor.D('product_inquiry', ns_c)
delete_count += 1
ns_c = {
'id': ns.get('id')
}
await sor.D('product_inquiry', ns_c)
return {
'status': True,
'msg': 'delete success',
'data': {
'delete_count': delete_count
}
'msg': 'delete success'
}
ret = await delete_user_inquiry(params_kw)

View File

@ -90,8 +90,6 @@ async def search_user_inquiry(ns={}):
'consult_direction': '咨询方向',
'content': '咨询内容',
'feedback': '反馈状态',
'remark': '备注',
'create_at': '创建时间'
}
# 新增值映射字典,集中管理各字段的数值转换规则
# 转换字典键为中文

View File

@ -1,40 +1,14 @@
async def update_user_inquiry(ns={}):
db = DBPools()
async with db.sqlorContext('kboss') as sor:
ids = ns.get('ids') or ns.get('id')
if not ids:
return {
'status': False,
'msg': '请传递id'
}
if isinstance(ids, str):
if ids.startswith('['):
ids = json.loads(ids)
elif ',' in ids:
ids = ids.replace('"', '').replace("'", '').split(',')
else:
ids = [ids]
update_count = 0
for inquiry_id in ids:
if not inquiry_id:
continue
ns_c = {
'id': inquiry_id
}
if 'feedback' in ns:
ns_c['feedback'] = ns.get('feedback')
if 'remark' in ns:
ns_c['remark'] = ns.get('remark')
await sor.U('product_inquiry', ns_c)
update_count += 1
ns_c = {
'id': ns.get('id'),
'feedback': ns.get('feedback')
}
await sor.U('product_inquiry', ns_c)
return {
'status': True,
'msg': 'update success',
'data': {
'update_count': update_count
}
'msg': 'update success'
}
ret = await update_user_inquiry(params_kw)