fix: convert tabs to spaces in usersync/index.dspy to resolve TabError

This commit is contained in:
yumoqing 2026-05-12 18:20:24 +08:00
parent f1ed6ad151
commit 3bb57dafd7

View File

@ -71,34 +71,34 @@ async with db.sqlorContext(dbname) as sor:
) )
return json.dumps(result, ensure_ascii=False) return json.dumps(result, ensure_ascii=False)
# 否则自己创建apikey # 否则自己创建apikey
# 检查apikey是否已存在 # 检查apikey是否已存在
existing = await sor.R('downapikey', { existing = await sor.R('downapikey', {
'dappid': dappid, 'dappid': dappid,
'duserid': user_id, 'duserid': user_id,
'dorgid': user_orgid 'dorgid': user_orgid
}) })
if existing: if existing:
# 验证用户是否存在 # 验证用户是否存在
user_check = await sor.R('users', {'id': existing[0].userid}) user_check = await sor.R('users', {'id': existing[0].userid})
if not user_check: if not user_check:
# 脏数据downapikey 存在但用户已删除,清理后重新创建 # 脏数据downapikey 存在但用户已删除,清理后重新创建
await sor.D('downapikey', {'id': existing[0].id}) await sor.D('downapikey', {'id': existing[0].id})
existing = None existing = None
else: else:
apikey = password_decode(existing[0].apikey) apikey = password_decode(existing[0].apikey)
return json.dumps({ return json.dumps({
'status': 'success', 'status': 'success',
'data': [{ 'data': [{
'user_id': user_id, 'user_id': user_id,
'username': user_data.get('username', ''), 'username': user_data.get('username', ''),
'apikey': apikey, 'apikey': apikey,
'status': 'existing' 'status': 'existing'
}] }]
}, ensure_ascii=False) }, ensure_ascii=False)
# 创建新apikey # 创建新apikey
apikey_id = getID() apikey_id = getID()
apikey_value = getID() apikey_value = getID()
@ -167,56 +167,56 @@ async with db.sqlorContext(dbname) as sor:
'status': result.get('message', 'created'), 'status': result.get('message', 'created'),
'result_status': result.get('status') 'result_status': result.get('status')
}) })
else: else:
# 检查apikey是否已存在 # 检查apikey是否已存在
existing = await sor.R('downapikey', { existing = await sor.R('downapikey', {
'dappid': dappid, 'dappid': dappid,
'duserid': user_id, 'duserid': user_id,
'dorgid': user_orgid 'dorgid': user_orgid
}) })
if existing: if existing:
# 验证用户是否存在 # 验证用户是否存在
user_check = await sor.R('users', {'id': existing[0].userid}) user_check = await sor.R('users', {'id': existing[0].userid})
if not user_check: if not user_check:
# 脏数据,清理后重新创建 # 脏数据,清理后重新创建
await sor.D('downapikey', {'id': existing[0].id}) await sor.D('downapikey', {'id': existing[0].id})
existing = None existing = None
else: else:
apikey = password_decode(existing[0].apikey) apikey = password_decode(existing[0].apikey)
result_data.append({ result_data.append({
'user_id': user_id, 'user_id': user_id,
'username': user_data.get('username', ''), 'username': user_data.get('username', ''),
'apikey': apikey, 'apikey': apikey,
'status': 'existing' 'status': 'existing'
}) })
continue continue
else: else:
# 创建新apikey # 创建新apikey
apikey_id = getID() apikey_id = getID()
apikey_value = getID() apikey_value = getID()
ns = { ns = {
'id': apikey_id, 'id': apikey_id,
'dappid': dappid, 'dappid': dappid,
'dorgid': user_orgid, 'dorgid': user_orgid,
'duserid': user_id, 'duserid': user_id,
'orgid': user_orgid, 'orgid': user_orgid,
'userid': user_id, 'userid': user_id,
'apikey': password_encode(apikey_value), 'apikey': password_encode(apikey_value),
'enabled': '1', 'enabled': '1',
'created_at': datetime.now().strftime('%Y-%m-%d'), 'created_at': datetime.now().strftime('%Y-%m-%d'),
'expired_date': '9999-12-31' 'expired_date': '9999-12-31'
} }
await sor.C('downapikey', ns) await sor.C('downapikey', ns)
result_data.append({ result_data.append({
'user_id': user_id, 'user_id': user_id,
'username': user_data.get('username', ''), 'username': user_data.get('username', ''),
'apikey': apikey_value, 'apikey': apikey_value,
'status': 'created' 'status': 'created'
}) })
return json.dumps({ return json.dumps({
'status': 'success', 'status': 'success',