1.优化面试阶段

api/api_v1/endpoints/interview.py

@@ -1,4 +1,5 @@
 import ast
+import itertools
 import json
 import operator
 import os
@@ -1441,7 +1442,8 @@ async def login(
             'name': user.name,  # 名字
             'email': user.email,  # 邮箱
             'tel': user.tel,  # 电话
-            'user_id': user.id,  # 钉钉id
+            'user_id': user.user_id,  # 钉钉id
+            'id': user.id,  # 账号的唯一标识
             'rank': user.rank,  # 区分hr和面试官
             'token': security.create_access_token(
                 expires_delta=access_token_expires, user_id=user.user_id, email=user.email,
@@ -1497,9 +1499,20 @@ async def add_account(
     """
     创建新账号
     """
-    user_id = Unionid(data_in.unionid)
-    user_list = get_alluid_list()
-    if user_id not in user_list:
+    # user_id = Unionid(data_in.unionid)
+    # user_list = get_alluid_list()
+    # if user_id not in user_list:
+    #     return schemas.Msg(code=-9, msg="不是本公司的员工")
+    user = get_redis_alluid()
+    user_lists = [i['user_id'] for i in user]
+    user_list = list(itertools.chain.from_iterable(user_lists))
+    a = 0
+    for i in user_list:
+        if i['name'] == data_in.name:
+            user_id = i['userid']
+            a += 1
+            break
+    if a == 1:
         return schemas.Msg(code=-9, msg="不是本公司的员工")
     if is_exists := await crud.user.exists(db, {'user_id': user_id}):
         return schemas.Msg(code=-9, msg='已创建该账号')

utils/dingding.py

@@ -274,5 +274,5 @@ def get_alluid_list():
 
 if __name__ == '__main__':
     #a = user_details('16371426094531014')
-    a=get_all_uid()
+    a=get_redis_alluid()
     pprint.pprint(a)