39 lines
813 B
Python
39 lines
813 B
Python
import threading
|
|
from typing import Dict, Any
|
|
from Entity.AnchorModel import AnchorModel
|
|
|
|
# wda apple bundle id
|
|
WdaAppBundleId = "com.yolozsAgent.wda.xctrunner"
|
|
|
|
# 全局主播列表
|
|
anchorList: list[AnchorModel] = []
|
|
# 线程锁
|
|
anchorListLock = threading.Lock()
|
|
# 打招呼数据
|
|
prologueList = []
|
|
# 评论列表
|
|
commentsList = []
|
|
# 存储主播名和session_id的字典
|
|
anchorWithSession = {}
|
|
|
|
# 前端传递的token
|
|
token = ''
|
|
# 前端传递的
|
|
tenantId = 0
|
|
|
|
userId = 0
|
|
|
|
|
|
# 安全删除数据
|
|
def removeModelFromAnchorList(model: AnchorModel):
|
|
with anchorListLock:
|
|
anchorList.remove(model)
|
|
|
|
|
|
# 添加数据
|
|
def addModelToAnchorList(models: list[Dict[str, Any]]):
|
|
with anchorListLock:
|
|
for dic in models:
|
|
obj = AnchorModel.dictToModel(dic)
|
|
anchorList.append(obj)
|