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