DmitrMakeev
commited on
Update app.py
Browse files
app.py
CHANGED
@@ -1689,6 +1689,7 @@ def add_data_ver_cur():
|
|
1689 |
|
1690 |
DATABASE2 = 'data_gc.db'
|
1691 |
|
|
|
1692 |
def verify_phone_number2(phone_number):
|
1693 |
if verifikation_start == "1":
|
1694 |
full_url_ver = f"{wa_url}{wa_ak}{ws_url_ver}{wa_api_key}"
|
@@ -1703,6 +1704,7 @@ def verify_phone_number2(phone_number):
|
|
1703 |
else:
|
1704 |
return "false"
|
1705 |
|
|
|
1706 |
def parse_csv_data(data):
|
1707 |
parsed_data = []
|
1708 |
for item in data:
|
@@ -1712,6 +1714,7 @@ def parse_csv_data(data):
|
|
1712 |
parsed_data.append(dict(zip(headers, row)))
|
1713 |
return parsed_data
|
1714 |
|
|
|
1715 |
def insert_data2(data, template_key):
|
1716 |
global current_curator_index
|
1717 |
conn = sqlite3.connect(DATABASE2)
|
@@ -1783,11 +1786,13 @@ def insert_data2(data, template_key):
|
|
1783 |
finally:
|
1784 |
conn.close()
|
1785 |
|
|
|
1786 |
def verify_api_key():
|
1787 |
api_key = request.args.get('api_sys')
|
1788 |
if api_key != "fasSd345D":
|
1789 |
return jsonify({"error": "Invalid API key"}), 403
|
1790 |
|
|
|
1791 |
@app.route('/upload_csv', methods=['POST'])
|
1792 |
def upload_csv():
|
1793 |
if 'file' not in request.files:
|
@@ -1800,7 +1805,7 @@ def upload_csv():
|
|
1800 |
csv_input = csv.DictReader(stream)
|
1801 |
data = [row for row in csv_input]
|
1802 |
parsed_data = parse_csv_data(data)
|
1803 |
-
insert_data2(parsed_data, 'avp')
|
1804 |
return jsonify({"message": "Data uploaded and inserted successfully"})
|
1805 |
return jsonify({"error": "Invalid file format"}), 400
|
1806 |
|
|
|
1689 |
|
1690 |
DATABASE2 = 'data_gc.db'
|
1691 |
|
1692 |
+
# Функция для верификации номера телефона через внешний API
|
1693 |
def verify_phone_number2(phone_number):
|
1694 |
if verifikation_start == "1":
|
1695 |
full_url_ver = f"{wa_url}{wa_ak}{ws_url_ver}{wa_api_key}"
|
|
|
1704 |
else:
|
1705 |
return "false"
|
1706 |
|
1707 |
+
# Функция для парсинга данных из CSV
|
1708 |
def parse_csv_data(data):
|
1709 |
parsed_data = []
|
1710 |
for item in data:
|
|
|
1714 |
parsed_data.append(dict(zip(headers, row)))
|
1715 |
return parsed_data
|
1716 |
|
1717 |
+
# Функция для вставки данных в базу данных
|
1718 |
def insert_data2(data, template_key):
|
1719 |
global current_curator_index
|
1720 |
conn = sqlite3.connect(DATABASE2)
|
|
|
1786 |
finally:
|
1787 |
conn.close()
|
1788 |
|
1789 |
+
# Функция для проверки API ключа
|
1790 |
def verify_api_key():
|
1791 |
api_key = request.args.get('api_sys')
|
1792 |
if api_key != "fasSd345D":
|
1793 |
return jsonify({"error": "Invalid API key"}), 403
|
1794 |
|
1795 |
+
# Маршрут для загрузки CSV файла и вставки данных в базу данных
|
1796 |
@app.route('/upload_csv', methods=['POST'])
|
1797 |
def upload_csv():
|
1798 |
if 'file' not in request.files:
|
|
|
1805 |
csv_input = csv.DictReader(stream)
|
1806 |
data = [row for row in csv_input]
|
1807 |
parsed_data = parse_csv_data(data)
|
1808 |
+
insert_data2(parsed_data, 'avp')
|
1809 |
return jsonify({"message": "Data uploaded and inserted successfully"})
|
1810 |
return jsonify({"error": "Invalid file format"}), 400
|
1811 |
|