Update app.py
Browse files
app.py
CHANGED
@@ -831,18 +831,20 @@ def send_get_request():
|
|
831 |
except json.JSONDecodeError:
|
832 |
report_json = {}
|
833 |
|
834 |
-
messages_json_str =
|
835 |
try:
|
836 |
messages_json = json.loads(messages_json_str)
|
837 |
except json.JSONDecodeError:
|
838 |
messages_json = {}
|
839 |
|
840 |
-
|
841 |
-
user_data['messages'] = messages_json
|
842 |
|
843 |
-
# Обновление или добавление пользователя во все базы данных
|
844 |
-
for
|
845 |
-
|
|
|
|
|
|
|
846 |
|
847 |
return jsonify({'status': 'User data saved successfully'})
|
848 |
else:
|
|
|
831 |
except json.JSONDecodeError:
|
832 |
report_json = {}
|
833 |
|
834 |
+
messages_json_str = report.get('messages', '{}')
|
835 |
try:
|
836 |
messages_json = json.loads(messages_json_str)
|
837 |
except json.JSONDecodeError:
|
838 |
messages_json = {}
|
839 |
|
840 |
+
users_meta = report_json.get('usersMeta', {})
|
|
|
841 |
|
842 |
+
# Обновление или добавление каждого пользователя во все базы данных
|
843 |
+
for user_id, user_data in users_meta.items():
|
844 |
+
user_data['messages'] = messages_json
|
845 |
+
|
846 |
+
for db in DATABASES:
|
847 |
+
update_or_insert_user(db, user_data, template)
|
848 |
|
849 |
return jsonify({'status': 'User data saved successfully'})
|
850 |
else:
|