|
|
@ -114,6 +114,9 @@ def update_cine(request): |
|
|
|
cmd_dict[cmd['process']] = [cmd['id']] |
|
|
|
cmd_dict[cmd['process']] = [cmd['id']] |
|
|
|
print(cmd_dict) |
|
|
|
print(cmd_dict) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# 初始化redis |
|
|
|
|
|
|
|
redis_conn = get_redis_connection() |
|
|
|
|
|
|
|
|
|
|
|
# 增加状态 |
|
|
|
# 增加状态 |
|
|
|
update_status = { |
|
|
|
update_status = { |
|
|
|
'git': {'result': '', 'msg': ''}, |
|
|
|
'git': {'result': '', 'msg': ''}, |
|
|
@ -125,8 +128,8 @@ def update_cine(request): |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
cinema_update_status[cinema_ip] = copy.deepcopy(update_status) |
|
|
|
cinema_update_status[cinema_ip] = copy.deepcopy(update_status) |
|
|
|
redis_conn = get_redis_connection() |
|
|
|
|
|
|
|
redis_conn.set(f'cinema_update_status_{cinema_ip}', json.dumps(update_status), 10*60) |
|
|
|
# redis_conn.set(f'cinema_update_status_{cinema_ip}', json.dumps(update_status), 10*60) |
|
|
|
print("ws调试", cinema_update_status) |
|
|
|
print("ws调试", cinema_update_status) |
|
|
|
|
|
|
|
|
|
|
|
short_release = req.get('version') |
|
|
|
short_release = req.get('version') |
|
|
|