async def HpcAccessTime(ns={}): """ 更新用户跳转到济南超算的登录时间 :param ns: :return: """ orgid = ns.get('orgid') userid = await get_user() db = DBPools() async with db.sqlorContext('kboss') as sor: current_time = time.strftime('%Y-%m-%d %H:%M:%S') try: if userid: orgid_li = await sor.R('users', {'id': userid}) orgid = orgid_li[0].get('orgid') update_sql = """update jncs_usermapping set last_access = '%s' where orgid = '%s';""" % (current_time, orgid) await sor.sqlExe(update_sql, {}) return { 'status': True, 'msg': 'sync user login time success: %s' % str(current_time) } except Exception as e: return { 'status': False, 'msg': 'sync user login time failed: %s' % str(current_time), 'err': e } ret = await HpcAccessTime(params_kw) return ret