diff --git a/API/rokky.py b/API/rokky.py index 4c82117..596eb4c 100644 --- a/API/rokky.py +++ b/API/rokky.py @@ -165,17 +165,35 @@ def add_product(): def update_prices(): - with open("./files/prices.json", "r") as f: prices = json.load(f) + cursor = conn.cursor() - data = [(item["price"], item["sku"]) for item in prices] + data = [] + for item in prices: + sku = item["sku"] + price = item.get("basePrice") + price_gg = item.get("baseSuggestedRetailPrice") + price_sales =item.get("discountPercentage") + is_sale = item.get("isSale") + + data.append(( + price, + price_gg, + price_sales, + is_sale, + sku + )) cursor.executemany(""" - UPDATE products - SET price = ? - WHERE sku = ? + UPDATE products + SET + price = ?, + price_gg = ?, + price_sales = ?, + insale = ? + WHERE sku = ? """, data) conn.commit() @@ -183,4 +201,4 @@ def update_prices(): # decrypt_and_unpack("prices") # decrypt_and_unpack("products") # add_product() -# update_prices() \ No newline at end of file +update_prices() \ No newline at end of file diff --git a/app/__pycache__/routes.cpython-313.pyc b/app/__pycache__/routes.cpython-313.pyc index d9f08fd..cd86576 100644 Binary files a/app/__pycache__/routes.cpython-313.pyc and b/app/__pycache__/routes.cpython-313.pyc differ diff --git a/app/routes.py b/app/routes.py index 8e7ca50..760cc7a 100644 --- a/app/routes.py +++ b/app/routes.py @@ -1,5 +1,6 @@ from flask import Blueprint, request, jsonify import sqlite3 +import json # from services.rokky import ones # from API.rok import get_order_content import logging @@ -20,10 +21,34 @@ def index1(): params = request.args.to_dict() logging.warn(f"newOrder: {params}") # Просто выводим на экран (в ответ клиенту) - - return f"Received params: {params}", 200 + # парсим данные + sku = params.get("id_d") + product_id = params.get("id_i") + email = params.get("email") + price = params.get("amount") - return "Hello GET" + # всё остальное сохраняем как JSON + content = json.dumps(params, ensure_ascii=False) + + conn = sqlite3.connect(DB_PATH) + cursor = conn.cursor() + + try: + cursor.execute(""" + INSERT INTO orders (sku, product_id, email, price, content) + VALUES (?, ?, ?, ?, ?) + """, (sku, product_id, email, price, content)) + + conn.commit() + except Exception as e: + conn.close() + return jsonify({"error": str(e)}), 500 + + conn.close() + + return jsonify({"success": True}), 200 + + # return "Hello GET" @main.route("/sales", methods=["POST", "GET"]) def index2(): @@ -52,7 +77,7 @@ def new_order(): return jsonify({"status": "ok"}), 200 -@main.route("/sku", methods=["POST"]) +@main.route("/skuChanged", methods=["POST"]) def sku(): if not request.is_json: return jsonify({"error": "Invalid content type"}), 400