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 return { 'status': True, 'msg': 'delete success', 'data': { 'delete_count': delete_count } } ret = await delete_user_inquiry(params_kw) return ret