Update app.py

app.py

@@ -3572,738 +3572,7 @@ def inventory_action(env_id):
         'id': uuid4().hex,
         'product_id': p_id,
         'tag_id': t_id,
-        'type': action,for batch in tag['stock_batches']:
-            if batch['qty'] > 0:
-                if batch['qty'] >= remaining_to_deduct:
-                    batch['qty'] -= remaining_to_deduct
-                    remaining_to_deduct = 0
-                    break
-                else:
-                    remaining_to_deduct -= batch['qty']
-                    batch['qty'] = 0
-                    
-        tag['stock'] -= qty
-        history_entry['details'] = 'Ручное списание'
-        update_tag_price_from_batches(tag)
-        
-    else:
-        return jsonify({"error": "Неизвестное действие"}), 400
-
-    if 'inventory_history' not in data:
-        data['inventory_history'] = []
-    data['inventory_history'].append(history_entry)
-    
-    save_env_data(env_id, data)
-    return jsonify({"success": True})
-
-@app.route('/<env_id>/inventory_history/<p_id>/<t_id>')
-def inventory_history(env_id, p_id, t_id):
-    data = get_env_data(env_id)
-    history = data.get('inventory_history',[])
-    item_history =[h for h in history if h.get('product_id') == p_id and h.get('tag_id') == t_id]
-    item_history.sort(key=lambda x: x['timestamp'], reverse=True)
-    return jsonify(item_history)
-
-@app.route('/<env_id>/reports')
-def reports_page(env_id):
-    data = get_env_data(env_id)
-    settings = data.get('settings', {})
-    if settings.get('env_mode') != '2in1':
-        return "Отчеты доступны только в режиме '2 в 1'", 403
-    if settings.get('admin_password_enabled') and not session.get(f'admin_auth_{env_id}'):
-        return redirect(url_for('admin_login', env_id=env_id))
-    
-    now = datetime.now(ALMATY_TZ)
-    default_start = now.replace(day=1).strftime('%Y-%m-%d')
-    default_end = now.strftime('%Y-%m-%d')
-    
-    start_date = request.args.get('start_date', default_start)
-    end_date = request.args.get('end_date', default_end)
-    
-    orders = data.get('orders', {}).values()
-    filtered_orders =[]
-    
-    for o in orders:
-        created_at = o.get('created_at', '')
-        if created_at:
-            date_part = created_at.split(' ')[0]
-            if start_date <= date_part <= end_date:
-                filtered_orders.append(o)
-    
-    total_orders = len(filtered_orders)
-    total_revenue = sum(o.get('total_price', 0) for o in filtered_orders)
-    pos_orders = sum(1 for o in filtered_orders if o.get('source') == 'pos')
-    online_orders = total_orders - pos_orders
-
-    emp_stats = {}
-    product_sales = {}
-    
-    for o in filtered_orders:
-        emp = o.get('employee_name') or 'Прямой заказ'
-        if emp not in emp_stats:
-            emp_stats[emp] = {'count': 0, 'revenue': 0}
-        emp_stats[emp]['count'] += 1
-        emp_stats[emp]['revenue'] += o.get('total_price', 0)
-        
-        for item in o.get('cart',[]):
-            name = item.get('name', 'Неизвестно')
-            qty = item.get('quantity', 0)
-            if name not in product_sales:
-                product_sales[name] = 0
-            product_sales[name] += qty
-            
-    top_products =[{'name': k, 'qty': v} for k, v in product_sales.items()]
-    top_products.sort(key=lambda x: x['qty'], reverse=True)
-
-    return render_template_string(
-        REPORTS_TEMPLATE, env_id=env_id, settings=settings, currency_code=settings.get('currency_code', 'KGS'),
-        total_orders=total_orders, total_revenue=total_revenue, pos_orders=pos_orders, online_orders=online_orders,
-        emp_stats=emp_stats, top_products=top_products[:20], start_date=start_date, end_date=end_date
-    )
-
-@app.route('/<env_id>/track_view/<product_id>', methods=['POST'])
-def track_view(env_id, product_id):
-    data = get_env_data(env_id)
-    for p in data['products']:
-        if p.get('product_id') == product_id:
-            p['views'] = p.get('views', 0) + 1
-            break
-    save_env_data(env_id, data)
-    return jsonify({"status": "ok"})
-
-@app.route('/<env_id>/product/<product_id>')
-def product_detail(env_id, product_id):
-    data = get_env_data(env_id)
-    all_products_raw = data.get('products',[])
-    settings = data.get('settings', {})
-    env_mode = settings.get('env_mode', 'external')
-    
-    products_in_stock =[]
-    for p in all_products_raw:
-        if not p.get('in_stock', True):
-            continue
-        if env_mode == '2in1':
-            valid_tags =[t for t in p.get('tags', []) if t.get('stock', 0) > 0]
-            if not valid_tags and p.get('tags',[]):
-                continue
-            p_copy = p.copy()
-            p_copy['tags'] = valid_tags
-            products_in_stock.append(p_copy)
-        else:
-            products_in_stock.append(p)
-            
-    products_sorted = sorted(products_in_stock, key=lambda p: (not p.get('is_top', False), p.get('name', '').lower()))
-    
-    product = next((p for p in products_sorted if p.get('product_id') == product_id), None)
-    if not product:
-        return "Товар не найден или отсутствует в наличии.", 404
-        
-    return render_template_string(
-        PRODUCT_DETAIL_TEMPLATE, product=product, repo_id=REPO_ID,
-        currency_code=settings.get('currency_code', 'KGS'), settings=settings, env_id=env_id
-    )
-
-@app.route('/<env_id>/create_order', methods=['POST'])
-def create_order(env_id):
-    order_data = request.get_json()
-    if not order_data or 'cart' not in order_data or not order_data['cart']:
-        return jsonify({"error": "Корзина пуста или не передана."}), 400
-    
-    data = get_env_data(env_id)
-    settings = data.get('settings', {})
-    products = data.get('products',[])
-    env_mode = settings.get('env_mode', 'external')
-
-    cart_items = order_data['cart']
-    customer_data = order_data.get('customer_data', {})
-    emp_id = order_data.get('emp_id')
-    source = order_data.get('source', 'catalog')
-    emp_name = None
-    emp_whatsapp = None
-
-    if emp_id:
-        employees = data.get('employees',[])
-        for emp in employees:
-            if emp.get('id') == emp_id:
-                emp_name = emp.get('name')
-                emp_whatsapp = emp.get('whatsapp')
-                break
-
-    total_price = 0
-    processed_cart =[]
-    order_timestamp = datetime.now(ALMATY_TZ).strftime('%Y-%m-%d %H:%M:%S')
-    
-    for item in cart_items:
-        if not all(k in item for k in ('name', 'quantity')):
-            return jsonify({"error": "Неверный формат товара в корзине."}), 400
-        try:
-            quantity = int(item['quantity'])
-            if quantity <= 0:
-                raise ValueError("Invalid quantity")
-            
-            p_id = item.get('product_id')
-            c_color = item.get('color', 'N/A')
-            tx = item.get('tag_x')
-            ty = item.get('tag_y')
-            u_type = item.get('unit_type', 'piece')
-            
-            product_ref = next((p for p in products if p.get('product_id') == p_id), None)
-            if not product_ref:
-                return jsonify({"error": f"Товар {p_id} не найден."}), 400
-                
-            tag_ref = None
-            if 'TAG_' in c_color:
-                tag_id = c_color.split('_VAR_')[0].replace('TAG_', '')
-                tag_ref = next((t for t in product_ref.get('tags',[]) if t.get('id') == tag_id), None)
-            elif item.get('id') and len(item['id'].split('-')) >= 2:
-                tag_id = item['id'].split('-')[1]
-                tag_ref = next((t for t in product_ref.get('tags',[]) if t.get('id') == tag_id), None)
-
-            price = float(item.get('price', 0))
-            discount_applied = False
-            
-            if tag_ref:
-                orig_price = float(tag_ref.get('price', 0))
-                box_price = float(tag_ref.get('box_price', orig_price))
-                box_qty = int(tag_ref.get('box_qty', 1))
-                
-                if u_type == 'piece' and box_qty > 1 and quantity >= box_qty:
-                    price = box_price / box_qty
-                    discount_applied = True
-                elif u_type == 'box':
-                    price = box_price
-                else:
-                    price = orig_price
-                
-                if env_mode == '2in1':
-                    deduction = quantity
-                    if u_type == 'box':
-                        deduction = quantity * box_qty
-                        
-                    if tag_ref.get('stock', 0) < deduction:
-                         return jsonify({"error": f"Недостаточно остатков для товара {item['name']}."}), 400
-                    
-                    if 'stock_batches' not in tag_ref:
-                        tag_ref['stock_batches'] =[{"qty": tag_ref.get('stock', 0), "price": tag_ref.get('price', 0), "box_price": tag_ref.get('box_price', 0)}]
-                    
-                    remaining_to_deduct = deduction
-                    for batch in tag_ref['stock_batches']:
-                        if batch['qty'] > 0:
-                            if batch['qty'] >= remaining_to_deduct:
-                                batch['qty'] -= remaining_to_deduct
-                                remaining_to_deduct = 0
-                                break
-                            else:
-                                remaining_to_deduct -= batch['qty']
-                                batch['qty'] = 0
-                                
-                    tag_ref['stock'] -= deduction
-                    update_tag_price_from_batches(tag_ref)
-                    
-                    if 'inventory_history' not in data:
-                        data['inventory_history'] = []
-                    data['inventory_history'].append({
-                        'id': uuid4().hex,
-                        'product_id': p_id,
-                        'tag_id': tag_ref['id'],
-                        'type': 'sale',
-                        'qty': deduction,
-                        'timestamp': order_timestamp,
-                        'details': f"Продажа ({source})"
-                    })
-
-            processed_cart.append({
-                "product_id": p_id, "name": item['name'], "price": price, "quantity": quantity,
-                "color": c_color, "photo": item.get('photo'), "tag_x": tx, "tag_y": ty, "unit_type": u_type,
-                "discount_applied": discount_applied,
-                "photo_url": f"https://huggingface.co/datasets/{REPO_ID}/resolve/main/photos/{item['photo']}" if item.get('photo') else "https://via.placeholder.com/60x60.png?text=N/A"
-            })
-            total_price += price * quantity
-        except (ValueError, TypeError) as e:
-            return jsonify({"error": "Неверная цена или количество в товаре."}), 400
-
-    order_id = f"{datetime.now(ALMATY_TZ).strftime('%Y%m%d%H%M%S')}-{uuid4().hex[:6]}"
-
-    new_order = {
-        "id": order_id, "created_at": order_timestamp, "cart": processed_cart,
-        "total_price": round(total_price, 2), "status": "new",
-        "employee_id": emp_id, "employee_name": emp_name, "employee_whatsapp": emp_whatsapp,
-        "customer_data": customer_data, "source": source
-    }
-
-    try:
-        if 'orders' not in data or not isinstance(data.get('orders'), dict):
-            data['orders'] = {}
-        data['orders'][order_id] = new_order
-        data['products'] = products 
-        save_env_data(env_id, data)
-        return jsonify({"order_id": order_id}), 201
-    except Exception:
-        return jsonify({"error": "Ошибка сервера при сохранении заказа."}), 500
-
-@app.route('/<env_id>/update_order/<order_id>', methods=['POST'])
-def update_order(env_id, order_id):
-    data = get_env_data(env_id)
-    order = data.get('orders', {}).get(order_id)
-    if not order:
-        return jsonify({"error": "Заказ не найден."}), 404
-
-    req = request.get_json()
-    idx = req.get('index')
-    action = req.get('action')
-
-    if idx is None or action not in['inc', 'dec', 'set', 'remove']:
-        return jsonify({"error": "Некорректный запрос."}), 400
-
-    try:
-        idx = int(idx)
-        cart = order.get('cart',[])
-        if idx < 0 or idx >= len(cart):
-            return jsonify({"error": "Товар не найден."}), 404
-
-        if action == 'inc':
-            cart[idx]['quantity'] += 1
-        elif action == 'dec':
-            cart[idx]['quantity'] -= 1
-            if cart[idx]['quantity'] <= 0:
-                cart.pop(idx)
-        elif action == 'set':
-            val = int(req.get('value', 1))
-            if val <= 0:
-                cart.pop(idx)
-            else:
-                cart[idx]['quantity'] = val
-        elif action == 'remove':
-            cart.pop(idx)
-
-        total = sum(float(item['price']) * int(item['quantity']) for item in cart)
-        order['total_price'] = round(total, 2)
-        order['cart'] = cart
-
-        save_env_data(env_id, data)
-        return jsonify({"success": True})
-    except Exception as e:
-        return jsonify({"error": str(e)}), 500
-
-@app.route('/<env_id>/delete_order/<order_id>', methods=['POST'])
-def delete_order(env_id, order_id):
-    data = get_env_data(env_id)
-    if 'orders' in data and order_id in data['orders']:
-        del data['orders'][order_id]
-        save_env_data(env_id, data)
-        flash("Заказ успешно удален.", "success")
-    else:
-        flash("Заказ не найден.", "error")
-    return redirect(url_for('history_page', env_id=env_id))
-
-@app.route('/<env_id>/order/<order_id>')
-def view_order(env_id, order_id):
-    data = get_env_data(env_id)
-    order = data.get('orders', {}).get(order_id)
-    settings = data.get('settings', {})
-    return render_template_string(ORDER_TEMPLATE, order=order, repo_id=REPO_ID, currency_code=settings.get('currency_code', 'KGS'), settings=settings, env_id=env_id)
-
-@app.route('/<env_id>/history')
-def history_page(env_id):
-    data = get_env_data(env_id)
-    settings = data.get('settings', {})
-    if settings.get('admin_password_enabled') and not session.get(f'admin_auth_{env_id}'):
-        return redirect(url_for('admin_login', env_id=env_id))
-    
-    orders = list(data.get('orders', {}).values())
-    orders.sort(key=lambda x: x.get('created_at', ''), reverse=True)
-    employees = data.get('employees',[])
-    return render_template_string(HISTORY_TEMPLATE, orders=orders, employees=employees, settings=settings, currency_code=settings.get('currency_code', 'KGS'), env_id=env_id)
-
-@app.route('/<env_id>/admin_ai_chat', methods=['POST'])
-def admin_ai_chat(env_id):
-    data = get_env_data(env_id)
-    settings = data.get('settings', {})
-    if settings.get('admin_password_enabled') and not session.get(f'admin_auth_{env_id}'):
-        return jsonify({"text": "Доступ запрещен."})
-        
-    if not configure_gemini():
-        return jsonify({"text": "AI не настроен."})
-    
-    req = request.get_json()
-    message = req.get('message')
-    history = req.get('history',[])
-
-    orders = data.get('orders', {})
-    products = data.get('products',[])
-
-    now = datetime.now(ALMATY_TZ)
-    current_month = now.strftime('%Y-%m')
-
-    monthly_revenue = 0
-    product_sales_counts = {}
-
-    for o in orders.values():
-        if o.get('created_at', '').startswith(current_month):
-            monthly_revenue += o.get('total_price', 0)
-        for item in o.get('cart',[]):
-            pid = item.get('product_id')
-            product_sales_counts[pid] = product_sales_counts.get(pid, 0) + item.get('quantity', 0)
-
-    sorted_views = sorted(products, key=lambda x: x.get('views', 0), reverse=True)[:5]
-    views_str_list = [f"[POST: {p['product_id']} Название: {p['name']}] (просмотров: {p.get('views', 0)})" for p in sorted_views if p.get('views', 0) > 0]
-    views_str = ", ".join(views_str_list) if views_str_list else "Нет просмотров"
-
-    sorted_sales_pids = sorted(product_sales_counts.items(), key=lambda x: x[1], reverse=True)[:5]
-    sales_str_list =[]
-    for pid, qty in sorted_sales_pids:
-        p = next((x for x in products if x['product_id'] == pid), None)
-        if p:
-            sales_str_list.append(f"[POST: {pid} Название: {p['name']}] (продано: {qty} шт)")
-    sales_str = ", ".join(sales_str_list) if sales_str_list else "Пока нет продаж"
-    
-    currency = data['settings'].get('currency_code', 'KGS')
-
-    sys_prompt = f"""Ты — умный AI-ассистент администратора магазина.
-    Текущее время (Алматы): {now.strftime('%Y-%m-%d %H:%M:%S')}.
-    Выручка за этот месяц: {monthly_revenue} {currency}.
-    Самые просматриваемые товары (Топ-5): {views_str}.
-    Самые продаваемые товары (Топ-5): {sales_str}.
-    Если упоминаешь товар, используй точный формат:[POST: <product_id> Название: <product_name>].
-    Помогай владельцу анализировать продажи и отвечать на бизнес-вопросы."""
-
-    try:
-        model = genai.GenerativeModel('gemma-3-27b-it')
-        messages =[{'role': 'user', 'parts':[{'text': sys_prompt}]}]
-        for h in history:
-            messages.append({'role': 'model' if h['role'] == 'ai' else 'user', 'parts':[{'text': h['text']}]})
-        chat = model.start_chat(history=messages)
-        resp = chat.send_message(message)
-        return jsonify({'text': resp.text})
-    except Exception as e:
-        return jsonify({'text': f"Ошибка AI: {str(e)}"})
-
-@app.route('/<env_id>/admin', methods=['GET', 'POST'])
-def admin(env_id):
-    data = get_env_data(env_id)
-    settings = data.get('settings', {})
-    
-    if settings.get('admin_password_enabled') and not session.get(f'admin_auth_{env_id}'):
-        return redirect(url_for('admin_login', env_id=env_id))
-        
-    products = data.get('products',[])
-    categories = data.get('categories',[])
-    organization_info = data.get('organization_info', {})
-    employees = data.get('employees',[])
-    blocks = data.get('blocks',[])
-
-    page = request.args.get('p', 1, type=int)
-    search_q = request.args.get('q', '').strip()
-
-    if 'orders' not in data or not isinstance(data.get('orders'), dict):
-            data['orders'] = {}
-            
-    if request.method == 'POST':
-        action = request.form.get('action')
-        try:
-            if action == 'add_block':
-                b_type = request.form.get('block_type')
-                b_title = request.form.get('block_title', '').strip()
-                b_url = request.form.get('block_url', '').strip()
-                if b_url and not b_url.startswith(('http://', 'https://')):
-                    b_url = 'https://' + b_url
-                b_content = request.form.get('block_content', '').strip()
-                blocks.append({
-                    'id': uuid4().hex[:8],
-                    'type': b_type,
-                    'title': b_title,
-                    'url': b_url,
-                    'content': b_content
-                })
-                data['blocks'] = blocks
-                save_env_data(env_id, data)
-                flash("Блок добавлен.", "success")
-            elif action == 'delete_block':
-                b_id = request.form.get('block_id')
-                data['blocks'] =[b for b in blocks if b.get('id') != b_id]
-                save_env_data(env_id, data)
-                flash("Блок удален.", "success")
-            elif action == 'move_block_up':
-                b_id = request.form.get('block_id')
-                idx = next((i for i, b in enumerate(blocks) if b.get('id') == b_id), -1)
-                if idx > 0:
-                    blocks[idx], blocks[idx-1] = blocks[idx-1], blocks[idx]
-                    data['blocks'] = blocks
-                    save_env_data(env_id, data)
-                    flash("Блок перемещен выше.", "success")
-            elif action == 'move_block_down':
-                b_id = request.form.get('block_id')
-                idx = next((i for i, b in enumerate(blocks) if b.get('id') == b_id), -1)
-                if idx != -1 and idx < len(blocks) - 1:
-                    blocks[idx], blocks[idx+1] = blocks[idx+1], blocks[idx]
-                    data['blocks'] = blocks
-                    save_env_data(env_id, data)
-                    flash("Блок перемещен ниже.", "success")
-            elif action == 'add_employee':
-                emp_name = request.form.get('emp_name', '').strip()
-                emp_whatsapp = request.form.get('emp_whatsapp', '').strip()
-                if emp_name and emp_whatsapp:
-                    emp_id = uuid4().hex[:8]
-                    employees.append({'id': emp_id, 'name': emp_name, 'whatsapp': emp_whatsapp})
-                    data['employees'] = employees
-                    save_env_data(env_id, data)
-                    flash("Сотрудник добавлен.", "success")
-            elif action == 'delete_employee':
-                emp_id = request.form.get('emp_id')
-                employees =[e for e in employees if e.get('id') != emp_id]
-                data['employees'] = employees
-                save_env_data(env_id, data)
-                flash("Сотрудник удален.", "success")
-            elif action == 'add_category':
-                category_name = request.form.get('category_name', '').strip()
-                if category_name and category_name not in categories:
-                    categories.append(category_name)
-                    data['categories'] = categories
-                    save_env_data(env_id, data)
-                    flash(f"Категория '{category_name}' успешно добавлена.", 'success')
-                elif not category_name:
-                     flash("Название категории не может быть пустым.", 'error')
-                else:
-                     flash(f"Категория '{category_name}' уже существует.", 'error')
-
-            elif action == 'delete_category':
-                category_to_delete = request.form.get('category_name')
-                if category_to_delete and category_to_delete in categories:
-                    categories.remove(category_to_delete)
-                    updated_count = 0
-                    for product in products:
-                        if product.get('category') == category_to_delete:
-                            product['category'] = 'Без категории'
-                            updated_count += 1
-                    data['categories'] = categories
-                    data['products'] = products
-                    save_env_data(env_id, data)
-                    flash(f"Категория '{category_to_delete}' удалена. {updated_count} товаров обновлено.", 'success')
-                else:
-                    flash(f"Не удалось удалить категорию '{category_to_delete}'.", 'error')
-
-            elif action == 'update_org_info':
-                organization_info['about_us'] = request.form.get('about_us', '').strip()
-                organization_info['shipping'] = request.form.get('shipping', '').strip()
-                organization_info['returns'] = request.form.get('returns', '').strip()
-                organization_info['contact'] = request.form.get('contact', '').strip()
-                data['organization_info'] = organization_info
-                save_env_data(env_id, data)
-                flash("Информация о магазине успешно обновлена.", 'success')
-            
-            elif action == 'update_settings':
-                settings['admin_password_enabled'] = 'admin_password_enabled' in request.form
-                settings['admin_password'] = request.form.get('admin_password', '').strip()
-                
-                settings['organization_name'] = request.form.get('organization_name', 'Gippo312').strip()
-                settings['whatsapp_number'] = request.form.get('whatsapp_number', '').strip()
-                settings['currency_code'] = request.form.get('currency_code', 'KGS')
-                settings['business_type'] = request.form.get('business_type', 'retail')
-                settings['color_scheme'] = request.form.get('color_scheme', 'default')
-                
-                settings['checkout_fields_enabled'] = 'checkout_fields_enabled' in request.form
-                settings['checkout_fields'] = {
-                    'name': 'cf_name' in request.form,
-                    'phone': 'cf_phone' in request.form,
-                    'city': 'cf_city' in request.form,
-                    'address': 'cf_address' in request.form,
-                    'zip': 'cf_zip' in request.form
-                }
-                settings['categories_as_lines'] = 'categories_as_lines' in request.form
-
-                avatar_file = request.files.get('chat_avatar')
-                if avatar_file and avatar_file.filename:
-                    if HF_TOKEN_WRITE:
-                        try:
-                            api = HfApi()
-                            old_avatar = settings.get('chat_avatar')
-                            if old_avatar:
-                                try: api.delete_files(repo_id=REPO_ID, paths_in_repo=[f"avatars/{old_avatar}"], repo_type="dataset", token=HF_TOKEN_WRITE)
-                                except Exception: pass
-                            ext = os.path.splitext(avatar_file.filename)[1].lower()
-                            avatar_filename = f"avatar_{env_id}_{int(time.time())}{ext}"
-                            uploads_dir = 'uploads_temp'
-                            os.makedirs(uploads_dir, exist_ok=True)
-                            temp_path = os.path.join(uploads_dir, avatar_filename)
-                            avatar_file.save(temp_path)
-                            api.upload_file(path_or_fileobj=temp_path, path_in_repo=f"avatars/{avatar_filename}", repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE)
-                            settings['chat_avatar'] = avatar_filename
-                            os.remove(temp_path)
-                            flash("Аватар успешно обновлен.", 'success')
-                        except Exception as e:
-                            flash(f"Ошибка при загрузке аватара: {e}", 'error')
-                    else:
-                        flash("HF_TOKEN (write) не настроен. Аватар не был загружен.", "warning")
-
-                data['settings'] = settings
-                save_env_data(env_id, data)
-                flash("Настройки успешно обновлены.", 'success')
-
-            elif action == 'add_product' or action == 'edit_product':
-                product_id = request.form.get('product_id')
-                product_data = {}
-                is_edit = action == 'edit_product'
-                
-                if is_edit:
-                    product_data = next((p for p in products if p.get('product_id') == product_id), None)
-                    if not product_data:
-                        flash(f"Ошибка: товар с ID {product_id} не найден.", 'error')
-                        return redirect(url_for('admin', env_id=env_id, p=page, q=search_q))
-                else:
-                    product_data['views'] = 0
-                
-                product_data['name'] = request.form.get('name', '').strip()
-                product_data['description'] = request.form.get('description', '').strip()
-                category = request.form.get('category')
-                product_data['category'] = category if category in categories else 'Без категории'
-                
-                tags_raw = request.form.get('tags_json', '[]')
-                try:
-                    parsed_tags = json.loads(tags_raw)
-                    for t in parsed_tags:
-                        if 'stock_batches' not in t:
-                            t['stock_batches'] =[{"qty": t.get('stock', 0), "price": t.get('price', 0), "box_price": t.get('box_price', 0)}]
-                    product_data['tags'] = parsed_tags
-                except:
-                    product_data['tags'] =[]
-                
-                product_data['in_stock'] = 'in_stock' in request.form
-                product_data['is_top'] = 'is_top' in request.form
-
-                if not product_data['name']:
-                    flash("Название товара обязательно.", 'error')
-                    return redirect(url_for('admin', env_id=env_id, p=page, q=search_q))
-
-                photos_files = request.files.getlist('photos')
-                if photos_files and any(f.filename for f in photos_files):
-                    if HF_TOKEN_WRITE:
-                        uploads_dir = 'uploads_temp'
-                        os.makedirs(uploads_dir, exist_ok=True)
-                        api = HfApi()
-                        new_photos_list =[]
-                        photo_limit = 10
-                        uploaded_count = 0
-                        for photo in photos_files:
-                            if uploaded_count >= photo_limit: break
-                            if photo and photo.filename:
-                                try:
-                                    ext = os.path.splitext(photo.filename)[1].lower()
-                                    if ext not in['.jpg', '.jpeg', '.png', '.gif', '.webp']: continue
-                                    safe_name = secure_filename(product_data['name'].replace(' ', '_'))[:50]
-                                    photo_filename = f"{safe_name}_{uuid4().hex[:8]}{ext}"
-                                    temp_path = os.path.join(uploads_dir, photo_filename)
-                                    photo.save(temp_path)
-                                    api.upload_file(path_or_fileobj=temp_path, path_in_repo=f"photos/{photo_filename}", repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE)
-                                    new_photos_list.append(photo_filename)
-                                    os.remove(temp_path)
-                                    uploaded_count += 1
-                                except Exception as e:
-                                    flash(f"Ошибка при загрузке фото {photo.filename}: {e}", 'error')
-                        if new_photos_list and is_edit and product_data.get('photos'):
-                            try: api.delete_files(repo_id=REPO_ID, paths_in_repo=[f"photos/{p}" for p in product_data['photos']], repo_type="dataset", token=HF_TOKEN_WRITE)
-                            except Exception: pass
-                        if new_photos_list:
-                             product_data['photos'] = new_photos_list
-                    else:
-                        flash("HF_TOKEN не настроен. Фотографии не загружены.", "warning")
-                
-                if is_edit:
-                    product_index = next((i for i, p in enumerate(products) if p.get('product_id') == product_id), -1)
-                    if product_index != -1:
-                        products[product_index] = product_data
-                        flash(f"Товар '{product_data['name']}' обновлен.", 'success')
-                else:
-                    product_data['product_id'] = uuid4().hex
-                    products.append(product_data)
-                    flash(f"Товар '{product_data['name']}' добавлен.", 'success')
-                
-                data['products'] = products
-                save_env_data(env_id, data)
-
-            elif action == 'delete_product':
-                product_id = request.form.get('product_id')
-                product_index = next((i for i, p in enumerate(products) if p.get('product_id') == product_id), -1)
-                if product_index == -1:
-                    flash(f"Ошибка удаления: товар не найден.", 'error')
-                    return redirect(url_for('admin', env_id=env_id, p=page, q=search_q))
-                deleted_product = products.pop(product_index)
-                product_name = deleted_product.get('name', 'N/A')
-                photos_to_delete = deleted_product.get('photos',[])
-                if photos_to_delete and HF_TOKEN_WRITE:
-                    try:
-                        api = HfApi()
-                        api.delete_files(repo_id=REPO_ID, paths_in_repo=[f"photos/{p}" for p in photos_to_delete], repo_type="dataset", token=HF_TOKEN_WRITE)
-                    except Exception: pass
-                data['products'] = products
-                save_env_data(env_id, data)
-                flash(f"Товар '{product_name}' удален.", 'success')
-            else:
-                 flash(f"Неизвестное действие: {action}", 'warning')
-            return redirect(url_for('admin', env_id=env_id, p=page, q=search_q))
-        except Exception as e:
-             flash(f"Ошибка при выполнении действия.", 'error')
-             return redirect(url_for('admin', env_id=env_id, p=page, q=search_q))
-
-    filtered_products = products
-    if search_q:
-        q_lower = search_q.lower()
-        filtered_products =[p for p in products if q_lower in p.get('name', '').lower() or q_lower in p.get('description', '').lower()]
-    
-    filtered_products = sorted(filtered_products, key=lambda p: p.get('name', '').lower())
-    
-    PER_PAGE = 20
-    total_items = len(filtered_products)
-    total_pages = math.ceil(total_items / PER_PAGE) if total_items > 0 else 1
-    
-    if page < 1: page = 1
-    if page > total_pages: page = total_pages
-    
-    start_idx = (page - 1) * PER_PAGE
-    end_idx = start_idx + PER_PAGE
-    paginated_products = filtered_products[start_idx:end_idx]
-
-    display_categories = sorted(categories)
-    display_organization_info = organization_info
-    display_settings = settings
-    chat_status = { "active": False, "expires_soon": False, "expires_date": "N/A" }
-    chat_avatar_url = f"https://huggingface.co/datasets/{REPO_ID}/resolve/main/avatars/{display_settings['chat_avatar']}" if display_settings.get('chat_avatar') else "https://huggingface.co/spaces/gippo312/admin/resolve/main/Picsart_25-11-04_12-02-21-390.png"
-
-    low_stock_count = 0
-    if settings.get('env_mode') == '2in1':
-        for p in products:
-            for t in p.get('tags',[]):
-                if t.get('stock', 0) <= 50:
-                    low_stock_count += 1
-
-    return render_template_string(
-        ADMIN_TEMPLATE, paginated_products=paginated_products, total_pages=total_pages, page=page, search_q=search_q, categories=display_categories,
-        organization_info=display_organization_info, chats={}, settings=display_settings, employees=employees,
-        blocks=blocks, repo_id=REPO_ID, currency_code=display_settings.get('currency_code', 'KGS'), chat_avatar_url=chat_avatar_url,
-        currencies=CURRENCIES, color_schemes=COLOR_SCHEMES, env_id=env_id, chat_status=chat_status, low_stock_count=low_stock_count
-    )
-
-@app.route('/generate_description_ai', methods=['POST'])
-def handle_generate_description_ai():
-    request_data = request.get_json()
-    base64_image = request_data.get('image')
-    language = request_data.get('language', 'Русский')
-    if not base64_image: return jsonify({"error": "Изображение не найдено в запросе."}), 400
-    try:
-        image_data = base64.b64decode(base64_image)
-        result_text = generate_ai_description_from_image(image_data, language)
-        return jsonify({"text": result_text})
-    except ValueError as ve: return jsonify({"error": str(ve)}), 400
-    except Exception as e: return jsonify({"error": f"Внутренняя ошибка сервера: {e}"}), 500
-
-if __name__ == '__main__':
-    configure_gemini()
-    download_db_from_hf()
-    load_data()
-    if HF_TOKEN_WRITE:
-        backup_thread = threading.Thread(target=periodic_backup, daemon=True)
-        backup_thread.start()
-    port = int(os.environ.get('PORT', 7860))
-    app.run(debug=False, host='0.0.0.0', port=port)
+        'type': action,
         'qty': qty,
         'timestamp': datetime.now(ALMATY_TZ).strftime('%Y-%m-%d %H:%M:%S'),
         'details': ''