|
|
|
@ -229,8 +229,18 @@ def update_cine(request): |
|
|
|
db_compare = DbCompare(cinema_ip, short_release) |
|
|
|
db_compare = DbCompare(cinema_ip, short_release) |
|
|
|
sql_result, sql_output = db_compare.exec_diff_sql() |
|
|
|
sql_result, sql_output = db_compare.exec_diff_sql() |
|
|
|
update_status['sql']['result'] = 'success' if sql_result is True else 'fail' |
|
|
|
update_status['sql']['result'] = 'success' if sql_result is True else 'fail' |
|
|
|
update_status['result'] = 'fail' if sql_result is False else '' |
|
|
|
|
|
|
|
update_status['sql']['msg'] = sql_output |
|
|
|
update_status['sql']['msg'] = sql_output |
|
|
|
|
|
|
|
if sql_result is False: |
|
|
|
|
|
|
|
update_status['result'] = 'fail' |
|
|
|
|
|
|
|
print('最后执行状态', json.dumps(update_status)) |
|
|
|
|
|
|
|
redis_conn.set(redis_key, json.dumps(update_status), 5 * 60) |
|
|
|
|
|
|
|
# redis_conn.delete(redis_key) |
|
|
|
|
|
|
|
UpdateLog.objects.create(ip=cinema_ip, type='toolbox', origin_ver=org_ver, |
|
|
|
|
|
|
|
target_ver=short_release[:11], |
|
|
|
|
|
|
|
time=update_time, result=update_status['result'], |
|
|
|
|
|
|
|
result_detail=json.dumps(update_status)) |
|
|
|
|
|
|
|
return JsonResponse({'result': 'fail', 'ip': cinema_ip, 'msg': sql_output}) |
|
|
|
|
|
|
|
|
|
|
|
redis_conn.set(redis_key, json.dumps(update_status), 5 * 60) |
|
|
|
redis_conn.set(redis_key, json.dumps(update_status), 5 * 60) |
|
|
|
except Exception as e: |
|
|
|
except Exception as e: |
|
|
|
print('步骤三:数据库对比异常', e) |
|
|
|
print('步骤三:数据库对比异常', e) |
|
|
|
|