# Create app record
org_id = params_kw.get('org_id', (await get_userorgid()) or '0')
id = params_kw.get('id', getID())
now = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")

# Decrypt keys if provided by form? No, usually Ops enters plain text, we encrypt.
ak = params_kw.get('ak', '')
sk = params_kw.get('sk', '')
env = ServerEnv()
if ak: ak = env.password_encode(ak)
if sk: sk = env.password_encode(sk)

data = {
    "id": id,
    "org_id": org_id,
    "downapp_id": params_kw.get('downapp_id', ''),
    "vendor": params_kw.get('vendor', 'volcengine'),
    "status": params_kw.get('status', 'pending'),
    "ak": ak,
    "sk": sk,
    "callback_url": params_kw.get('callback_url', ''),
    "remark": params_kw.get('remark', ''),
    "create_time": now,
    "update_time": now
}

db = DBPools()
dbname = get_module_dbname('reallife_asset')
async with db.sqlorContext(dbname) as sor:
    await sor.I("rl_app_user", data)

return {"success": True, "id": id}