async def HpcLdapDelete(ns={}): """ 账号删除 :param ns: :return: """ db = DBPools() async with db.sqlorContext('kboss') as sor: try: if ns.get('orgid'): # 首先判断当前的账号是否已经同步过 sync_status_li = await sor.R('jncs_syncinfo', {'customerid': ns.get('orgid')}) sync_status_list = [item['sync_status'] for item in sync_status_li] if '1' in sync_status_list: return { 'status': False, 'msg': '用户已经同步过, 账号只能绑定一次, 强制删除可联系后台, 删除后将清空原来购买的所有核时' } else: # 首先删除账号表中账号 await sor.U('jncs_usermapping', {'id': ns.get('id'), 'del_flg': '1'}) # 删除订单中绑定的账号 update_sql = """UPDATE jncs_syncinfo SET clustercode = NULL, queuecode = NULL where customerid = '%s';""" % ns.get('orgid') await sor.sqlExe(update_sql, {}) return { 'status': True, 'msg': '删除济南超算账号成功' } else: await sor.U('jncs_usermapping', {'id': ns.get('id'), 'del_flg': '1'}) return { 'status': True, 'msg': '删除济南超算账号成功' } except Exception as e: raise e return { 'status': False, 'msg': '删除济南超算账号失败' } ret = await HpcLdapDelete(params_kw) return ret