14 Commits

59 changed files with 2566 additions and 940 deletions

5
.gitignore vendored
View File

@@ -3,3 +3,8 @@
__pycache__
.env
.cursorignore
logs/
files/
Настроено/
Не настроено/
проблемные/

View File

@@ -1,11 +1,12 @@
Metadata-Version: 2.4
Name: MailOrderBot
Version: 1.0.2
Version: 1.0.4
Summary: Config manager for building applications
Author-email: Aleksei Zosimov <lesha.spb@gmail.com>
Project-URL: Homepage, https://git.lesha.spb.ru/alex/config_manager
Project-URL: Documentation, https://git.lesha.spb.ru/alex/config_manager
Project-URL: Repository, https://git.lesha.spb.ru/alex/config_manager
Project-URL: Homepage, https://git.lesha.spb.ru/alex/mail_order_bot
Project-URL: Documentation, https://git.lesha.spb.ru/alex/mail_order_bot
Project-URL: Repository, https://git.lesha.spb.ru/alex/mail_order_bot
Requires-Python: >=3.12
Description-Content-Type: text/markdown
Requires-Dist: python-dotenv>=1.0.0
Requires-Dist: config_manager@ git+https://git.lesha.spb.ru/alex/config_manager.git@master

View File

@@ -8,10 +8,11 @@ src/MailOrderBot.egg-info/top_level.txt
src/mail_order_bot/__init__.py
src/mail_order_bot/main.py
src/mail_order_bot/email_client/__init__.py
src/mail_order_bot/email_client/email_client.py
src/mail_order_bot/email_client/email_objects.py
src/mail_order_bot/email_client/client.py
src/mail_order_bot/email_client/objects.py
src/mail_order_bot/excel_processor/__init__.py
src/mail_order_bot/excel_processor/configurable_parser.py
src/mail_order_bot/excel_processor/excel_parser.py
src/mail_order_bot/excel_processor/excel_processor.py
src/mail_order_bot/excel_processor/order_position.py
src/mail_order_bot/excel_processor/parser_factory.py
src/mail_order_bot/excel_processor/processor.py

View File

@@ -1 +1,2 @@
python-dotenv>=1.0.0
config_manager@ git+https://git.lesha.spb.ru/alex/config_manager.git@master

View File

View File

@@ -0,0 +1,35 @@
import os
import hashlib
import requests
class AbcpProvider:
HOST = "https://id23089.public.api.abcp.ru"
HEADERS = {
"Accept": "application/json",
"Content-Type": "application/x-www-form-urlencoded"
}
def __init__(self):
self.base_url = self.HOST
self.login = os.getenv("ABCP_LOGIN")
password = os.getenv("ABCP_PASSWORD")
self.password = hashlib.md5(password.encode("utf-8")).hexdigest()
def get_stock(self, order):
method = "GET"
path = "/search/articles"
for position in order.positions:
params = {"number": position.sku, "brand": position.manufacturer, "withOutAnalogs": "1"}
position.stock = self._execute(path, method, params)
def _execute(self, path, method="GET", params={}, data=None):
params["userlogin"] = self.login
params["userpsw"] = self.password
response = requests.request(method, self.HOST+path, data=data, headers=self.HEADERS, params=params)
if response.status_code != 200:
raise Exception(response.text)
return response.json()

View File

@@ -0,0 +1,18 @@
"""
Пакет содержит реализацию для создания заказов из вложений.
На входе файл из вложения
Его обработка производится хендлерами, коотрые настраиваются в конфиге
На выходе - экземпляр класса, который в себе содержит
- прочитанный файл в виде pandas DataFrame
- распарсенный файл заказа с позициями
- полученные остатки
- результат проверки возможности создания заказа
Так же класс содержит методы
- для создания заказа
- для получения отредактированного файла
"""
from .processor import TaskProcessor

View File

@@ -0,0 +1,9 @@
from .abcp_clients.check_stock import GetStock
from .abcp_clients.create_order import InstantOrderTest
from .excel_parcers.basic_excel_parcer import BasicExcelParser
from .notifications.test_notifier import TestNotifier
from .validators.price_quantity_ckecker import CheckOrder

View File

@@ -0,0 +1,26 @@
import random
import logging
from mail_order_bot.attachment_handler.handlers.abstract_task import AbstractTask
logger = logging.getLogger(__name__)
def get_stock(brand, part_number):
return random.randint(0, 10)
class GetStock(AbstractTask):
def do(self) -> None:
positions = self.order.positions
for position in positions:
self._update_stock(position)
def _update_stock(self, position):
# Эмулируем получение данных
max_stock = self.config.get('max_stock',10)
stock = random.randint(0, max_stock)
price = position.requested_price
position.stock_price = price
position.stock_quantity = stock

View File

@@ -0,0 +1,37 @@
import logging
import requests
from mail_order_bot.attachment_handler.handlers.abstract_task import AbstractTask
from mail_order_bot.attachment_handler.order.auto_part_order import OrderStatus
logger = logging.getLogger(__name__)
class InstantOrderTest(AbstractTask):
URL = "https://api.telegram.org/bot{0}/sendMessage?chat_id={1}&text={2}"
def do(self) -> None:
api_key = self.config["api_key"]
chat_id = self.config["chat_id"]
if self.order.status == OrderStatus.IN_PROGRESS:
positions = self.order.positions
message = f"Запрос на создание заказа от {self.context['client']}:\n"
message += "\n".join(f"{pos.sku}: {pos.name} ({pos.order_quantity} x {pos.order_price} = {pos.total})" for pos in positions)
elif self.order.status == OrderStatus.OPERATOR_REQUIRED:
message = f"Запрос на создание заказа от {self.context['client']} отклонен - необходима ручная обработка.\n"
message += f"Причина: {self.order.reason}"
else:
message = f"Запрос на создание заказа от {self.context['client']} отклонен.\n"
message += f" Статус заказа: {self.order.status}"
#url = self.URL.format(api_key, chat_id, message)
#resp = requests.get(url).json()
print(message)
#logger.info(resp)

View File

@@ -0,0 +1,24 @@
import logging
from abc import ABC, abstractmethod
from typing import Dict, Any
from ..order.auto_part_order import AutoPartOrder
class AbstractTask(ABC):
RESULT_SECTION = "section"
"""
Абстрактный базовый класс для всех хэндлеров.
"""
def __init__(self, config: Dict[str, Any], context: Dict[str, Any], order: AutoPartOrder, *args, **kwargs) -> None:
self.config = config
self.context = context
self.order = order
@abstractmethod
def do(self) -> None:
"""
Выполняет работу над заданием
Входные и выходные данные - в self.context
Конфиг задается при инициализации
"""
raise NotImplementedError

View File

@@ -0,0 +1,141 @@
import smtplib
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
from email.mime.base import MIMEBase
from email.utils import formatdate
from email import encoders
from abc import ABC, abstractmethod
import os
class AbstractTask(ABC):
"""Базовый класс для задач"""
def __init__(self, context, config):
self.context = context
self.config = config
@abstractmethod
def do(self):
"""Метод для реализации в подклассах"""
pass
class EmailReplyTask(AbstractTask):
"""Класс для ответа на электронные письма"""
def do(self):
"""
Отправляет ответ на входящее письмо
Ожидает в self.context:
- message: email.message.Message объект входящего письма
- attachment: путь к файлу для вложения
Ожидает в self.config:
- reply_to: адрес электронной почты для копии
- smtp_host: хост SMTP сервера
- smtp_port: порт SMTP сервера
- smtp_user: пользователь SMTP
- smtp_password: пароль SMTP
- from_email: адрес отправителя
"""
incoming_message = self.context.get("message")
attachment_path = self.context.get("attacnment")
if not incoming_message:
raise ValueError("Рcontext не найдено письмо (message)")
# Получаем адрес отправителя входящего письма
from_addr = incoming_message.get("From")
if not from_addr:
raise ValueError("Входящее письмо не содержит адреса отправителя")
# Создаем ответное письмо
reply_message = MIMEMultipart()
# Заголовки ответного письма
reply_message["From"] = self.config.get("from_email", "noreply@example.com")
reply_message["To"] = from_addr
reply_message["Cc"] = self.config.get("reply_to", "")
reply_message["Subject"] = f"Re: {incoming_message.get('Subject', '')}"
reply_message["Date"] = formatdate(localtime=True)
# Тело письма
body = "Ваш заказ создан"
reply_message.attach(MIMEText(body, "plain", "utf-8"))
# Добавляем вложение если указан путь к файлу
if attachment_path and os.path.isfile(attachment_path):
self._attach_file(reply_message, attachment_path)
# Отправляем письмо
self._send_email(reply_message, from_addr)
def _attach_file(self, message, file_path):
"""
Добавляет файл в качестве вложения к письму
Args:
message: MIMEMultipart объект
file_path: путь к файлу для вложения
"""
try:
with open(file_path, "rb") as attachment:
part = MIMEBase("application", "octet-stream")
part.set_payload(attachment.read())
encoders.encode_base64(part)
file_name = os.path.basename(file_path)
part.add_header(
"Content-Disposition",
f"attachment; filename= {file_name}"
)
message.attach(part)
except FileNotFoundError:
raise FileNotFoundError(f"Файл не найден: {file_path}")
except Exception as e:
raise Exception(f"Ошибка при добавлении вложения: {str(e)}")
def _send_email(self, message, recipient):
"""
Отправляет письмо через SMTP
Args:
message: MIMEMultipart объект письма
recipient: адрес получателя
"""
try:
smtp_host = self.config.get("smtp_host")
smtp_port = self.config.get("smtp_port", 587)
smtp_user = self.config.get("smtp_user")
smtp_password = self.config.get("smtp_password")
if not all([smtp_host, smtp_user, smtp_password]):
raise ValueError("Не указаны параметры SMTP в config")
with smtplib.SMTP(smtp_host, smtp_port) as server:
server.starttls()
server.login(smtp_user, smtp_password)
# Получаем адреса получателей (основной + копия)
recipients = [recipient]
reply_to = self.config.get("reply_to")
if reply_to:
recipients.append(reply_to)
server.sendmail(
self.config.get("from_email"),
recipients,
message.as_string()
)
except smtplib.SMTPException as e:
raise Exception(f"Ошибка SMTP: {str(e)}")
except Exception as e:
raise Exception(f"Ошибка при отправке письма: {str(e)}")

View File

@@ -0,0 +1,118 @@
import logging
import pandas as pd
from typing import Dict, Any, Optional
from decimal import Decimal
from io import BytesIO
#from mail_order_bot.attachment_handler.handlers.order_position import OrderPosition
from mail_order_bot.attachment_handler.handlers.abstract_task import AbstractTask
from ...order.auto_part_position import AutoPartPosition
logger = logging.getLogger(__name__)
class BasicExcelParser(AbstractTask):
RESULT_SECTION = "positions"
"""
Универсальный парсер, настраиваемый через конфигурацию.
Подходит для большинства стандартных случаев.
"""
def do(self) -> None:
# todo сделать проверку на наличие файла и его тип
file_bytes = BytesIO(self.context.get("attachment").content) # self.context.get("attachment") #
try:
df = self._make_dataframe(file_bytes)
# Получаем маппинг колонок из конфигурации
mapping = self.config['mapping']
# Парсим строки
positions = []
for idx, row in df.iterrows():
try:
position = self._parse_row(row, mapping)
if position:
positions.append(position)
self.order.add_position(position)
except Exception as e:
logger.error(f"Ошибка парсинга строки {idx}: {e}, {row}")
continue
logger.info(f"Успешно обработано {len(positions)} позиций из {len(df)} строк")
self.context[self.RESULT_SECTION] = positions
except Exception as e:
logger.error(f"Ошибка при обработке файла: {e}")
raise Exception from e
def _parse_row(self, row: pd.Series, mapping: Dict[str, str]) -> Optional[AutoPartPosition]:
"""Парсит одну строку Excel в OrderPosition"""
# Проверяем обязательные поля
required_fields = ['article', 'price', 'quantity']
for field in required_fields:
if pd.isna(row.get(mapping[field])):
logger.warning(f"Позиция не создана - не заполнено поле {mapping[field]}")
return None
price = Decimal(str(row[mapping['price']]).replace(",", ".").strip())
quantity = int(row[mapping['quantity']])
if "total" in mapping.keys():
total = Decimal(str(row[mapping['total']]).replace(",", ".").strip())
else:
total = price * quantity
if mapping.get('name', "") in mapping.keys():
name = str(row[mapping.get('name', "")]).strip()
else:
name = ""
# Создаем объект позиции
position = AutoPartPosition(
sku=str(row[mapping['article']]).strip(),
manufacturer=str(row[mapping.get('manufacturer', "")]).strip(),
name=name,
requested_price=price,
requested_quantity=quantity,
total=total,
additional_attrs=self._extract_additional_attrs(row, mapping)
)
return position
def _extract_additional_attrs(self, row: pd.Series, mapping: Dict[str, str]) -> Dict[str, Any]:
"""Извлекает дополнительные атрибуты, не входящие в основную модель"""
additional = {}
mapped_columns = set(mapping.values())
for col in row.index:
if col not in mapped_columns and not pd.isna(row[col]):
additional[col] = row[col]
return additional
def _make_dataframe(self, bio) -> pd.DataFrame:
# Получаем все данные из файла
sheet_name = self.config.get("sheet_name", 0)
df_full = pd.read_excel(bio, sheet_name=sheet_name, header=None)
# Находим индекс строки с заголовком
key_field = self.config.get("key_field")
header_row_idx = df_full[
df_full.apply(lambda row: row.astype(str).str.contains(key_field, case=False, na=False).any(),
axis=1)].index[0]
# Считываем таблицу с правильным заголовком
df = pd.read_excel(bio, header=header_row_idx, sheet_name=sheet_name, engine='calamine') # openpyxl calamine
# Находим индекс первой строки с пустым 'Артикул'
first_empty_index = df[df[key_field].isna()].index.min()
# Обрезаем DataFrame до первой пустой строки (не включая её)
df_trimmed = df.loc[:first_empty_index - 1]
return df_trimmed

View File

@@ -0,0 +1,15 @@
import logging
from mail_order_bot.attachment_handler.handlers.abstract_task import AbstractTask
logger = logging.getLogger(__name__)
class TestNotifier(AbstractTask):
def do(self) -> None:
positions = self.context["positions"]
print(f"\nПолучено {len(positions)} позиций от {self.context["client"]}:")
for pos in positions: # Первые 5
print(f" - {pos.sku}: {pos.name} "
f"({pos.requested_quantity} x {pos.requested_price} = {pos.total})")

View File

@@ -0,0 +1,50 @@
import random
import logging
from mail_order_bot.attachment_handler.handlers.abstract_task import AbstractTask
from mail_order_bot.attachment_handler.order.auto_part_order import OrderStatus
from decimal import Decimal
import random
logger = logging.getLogger(__name__)
class CheckOrder(AbstractTask):
def do(self) -> None:
refused = 0
positions = self.order.positions
for position in positions:
self._set_order_price(position)
self._set_order_quantity(position)
if position.order_price == 0 or position.order_quantity == 0:
refused += 1
self._check_refusal_threshold(refused)
def _set_order_price(self, position):
# Эмулируем получение данных
acceptable_price_reduction = self.config.get("acceptable_price_reduction")
acceptable_price = position.stock_price* Decimal(str((1-acceptable_price_reduction/100)))
if position.requested_price < acceptable_price:
position.order_price = 0
else:
position.order_price = position.requested_price
def _set_order_quantity(self, position):
max_stock = self.config.get("max_stock", 100)
min_stock = self.config.get("min_stock", 0)
stock_quantity = random.randint(min_stock, max_stock)
position.order_quantity = max(0, min(position.stock_quantity, stock_quantity))
def _check_refusal_threshold(self, refused):
refusal_threshold_limit = self.config.get("refusal_threshold", 1)
refusal_level = refused/len(self.order.positions)
if refusal_level > refusal_threshold_limit:
self.order.status = OrderStatus.OPERATOR_REQUIRED
self.order.reason = "Превышен порог отказов"

View File

@@ -0,0 +1,34 @@
from typing import List, Optional
from .auto_part_position import AutoPartPosition
from enum import Enum
class OrderStatus(Enum):
NEW = "new"
IN_PROGRESS = "in progress"
FAILED = "failed"
COMPLETED = "completed"
OPERATOR_REQUIRED = "operator required"
INVALID = "invalid"
class AutoPartOrder:
def __init__(self):
self.positions: List[AutoPartPosition] = []
self.status = OrderStatus.NEW
self.reason = ""
def add_position(self, position: AutoPartPosition) -> None:
self.positions.append(position)
if self.status == OrderStatus.NEW:
self.status = OrderStatus.IN_PROGRESS
def find_positions(self, brand: Optional[str] = None, sku: Optional[str] = None) -> List[AutoPartPosition]:
results = self.positions
if brand is not None:
results = [p for p in results if p.manufacturer == brand]
if sku is not None:
results = [p for p in results if p.sku == sku]
return results
def __len__(self):
return len(self.positions)

View File

@@ -0,0 +1,77 @@
from typing import List, Optional
from dataclasses import dataclass, field
from typing import Dict, Any
from decimal import Decimal
@dataclass
class AutoPartPosition:
"""
Унифицированная модель позиции для заказа.
Все контрагенты приводятся к этой структуре.
"""
sku: str # Артикул товара
manufacturer: str # Производитель
name: str # Наименование
requested_price: Decimal # Цена за единицу
requested_quantity: int # Количество
total: Decimal # Общая сумма
stock_quantity: int = 0 # Остаток на складе
stock_price: Decimal = Decimal('0.0') # Цена на складе
order_quantity: int = 0 # Количество для заказа
order_price: Decimal = Decimal('0.0') # Цена в заказе
additional_attrs: Dict[str, Any] = field(default_factory=dict)
def __post_init__(self):
"""Валидация после инициализации"""
if self.requested_quantity < 0:
raise ValueError(f"Количество не может быть отрицательным: {self.requested_quantity}")
if self.requested_price < 0:
raise ValueError(f"Цена не может быть отрицательной: {self.requested_price}")
class AutoPartPosition2:
brand: str
sku: str
name: str
customer_price: float
customer_quantity: int
supplier_price: float
stock_remaining: int
def __init__(self, brand: str, sku: str, name: str,
customer_price: float, customer_quantity: int,
supplier_price: float, stock_remaining: int):
self.brand = brand
self.sku = sku
self.name = name
self.customer_price = customer_price
self.customer_quantity = customer_quantity
self.supplier_price = supplier_price
self.stock_remaining = stock_remaining
def customer_cost(self) -> float:
return self.customer_price * self.customer_quantity
def supplier_cost(self) -> float:
return self.supplier_price * self.customer_quantity
def is_available(self) -> bool:
return self.stock_remaining >= self.customer_quantity
def restock(self, amount: int) -> None:
if amount < 0:
raise ValueError("Restock amount must be non-negative")
self.stock_remaining += amount
def __post_init__(self):
if self.customer_price < 0:
raise ValueError("Customer price cannot be negative")
if self.customer_quantity < 0:
raise ValueError("Customer quantity cannot be negative")
if self.supplier_price < 0:
raise ValueError("Supplier price cannot be negative")
if self.stock_remaining < 0:
raise ValueError("Stock remaining cannot be negative")

View File

@@ -0,0 +1,34 @@
from mail_order_bot.attachment_handler.order.auto_part_order import AutoPartOrder
class Position:
def __init__(self):
pass
class AutoPartOrder
def __init__(self):
pass
class OrderRequest:
def __init__(self, attachment):
self.attachment = attachment
self.parsed = None
self.positions = []
self.status=None
def add_position(self, position):
pass
def find_positions(self):
pass
def __process(self):
pass
def get_file(self):
pass
def get_attachment(self):
pass

View File

@@ -0,0 +1,42 @@
import os
import yaml
import logging
from typing import Dict, Any
from pathlib import Path
logger = logging.getLogger(__name__)
from .order.auto_part_order import AutoPartOrder
from .handlers import *
class TaskProcessor:
def __init__(self, config_path: Path):
self.config_path = config_path
self.context = dict()
self.order = None
def process(self, client, attachment):
config = self._load_config(client)
self.context = dict()
self.order = AutoPartOrder()
self.context["client"] = client
self.context["attachment"] = attachment
self.context["status"] = client
for stage in config["pipeline"]:
handler_name = stage["handler"]
logger.info(f"Processing handler: {handler_name}")
task = globals()[handler_name](stage.get("config", None), self.context, self.order)
task.do()
return self.context
pass
def _load_config(self, client) -> Dict[str, Any]:
"""Загружает конфигурацию из YAML или JSON"""
path = os.path.join(self.config_path, client + '.yml')
with open(path, 'r', encoding='utf-8') as f:
return yaml.safe_load(f)

View File

@@ -1,11 +1,11 @@
# === Раздел с общими конфигурационными параметрами ===
update_interval: 2
work_interval: 2
# Настройки обработки =================================================================
# Раздел с общими конфигурационными параметрами ===============================
update_interval: 10
work_interval: 30
email_dir: "spareparts"
# === Логирование ===
# Логирование =================================================================
log:
version: 1
disable_existing_loggers: False
@@ -32,26 +32,27 @@ log:
maxBytes: 500000
backupCount: 10
#telegram:
# level: CRITICAL
# formatter: telegram
# class: logging_telegram_handler.TelegramHandler
# chat_id: 211945135
# alias: "PDC"
telegram:
level: CRITICAL
formatter: telegram
class: logging_telegram_handler.TelegramHandler
chat_id: 211945135
alias: "Mail order bot"
# -- Логгеры --
# Логгеры
loggers:
'':
handlers: [console, file]
handlers: [console, file, telegram]
level: INFO
propagate: False
__main__:
handlers: [console, file]
handlers: [console, file, telegram]
level: INFO
propagate: False
config_manager:
handlers: [console, file]
level: DEBUG

View File

@@ -0,0 +1,17 @@
pipeline:
- handler: "ConfigurableExcelParser"
result_section: "positions"
config:
sheet_name: 0
key_field: "Код детали"
mapping:
article: "Код детали"
manufacturer: "Производитель"
name: "Наименование"
price: "Цена\nдетали"
quantity: "Кол-\nво"
total: "Сумма"

View File

@@ -0,0 +1,32 @@
import threading
from typing import Any, Dict
class _SingletonMeta(type):
_instances = {}
_lock = threading.Lock()
def __call__(cls, *args, **kwargs):
if cls not in cls._instances:
with cls._lock:
if cls not in cls._instances:
instance = super().__call__(*args, **kwargs)
cls._instances[cls] = instance
return cls._instances[cls]
class Context(metaclass=_SingletonMeta):
def __init__(self):
# будет вызван только при первом создании
self.context = {}
self.email_client = None
def clear_context(self):
"""Очищает self.context, устанавливая его в None или пустой словарь"""
with self._lock: # потокобезопасная очистка
self.context = {}
print("Context очищен") # опциональный лог
def set_context(self, new_context: Dict[str, Any]):
"""Устанавливает новый контекст (бонусный метод)"""
with self._lock:
self.context = new_context
print("Новый контекст установлен")

View File

@@ -11,55 +11,13 @@ from email.header import decode_header
import imaplib
import smtplib
from .objects import EmailMessage, EmailAttachment
# from .objects import EmailMessage, EmailAttachment
class EmailClient:
"""
Класс для работы с электронной почтой по протоколам IMAP и SMTP.
Пример использования:
client = EmailClient(
imap_host='imap.gmail.com',
smtp_host='smtp.gmail.com',
email='your_email@gmail.com',
password='your_password'
)
# Получить новые письма
new_emails = client.get_emails()
# Отправить письмо
msg = EmailMessage(
from_addr='sender@example.com',
subj='Test',
dt=datetime.now(),
body='Hello!',
attachments=[]
)
client.send_email(msg, to_addr='recipient@example.com')
"""
def __init__(
self,
imap_host: str,
smtp_host: str,
email: str,
password: str,
imap_port: int = 993,
smtp_port: int = 587
):
"""
Инициализация клиента электронной почты.
Args:
imap_host: IMAP сервер (например, 'imap.gmail.com')
smtp_host: SMTP сервер (например, 'smtp.gmail.com')
email: Email адрес
password: Пароль или app password
imap_port: Порт IMAP (по умолчанию 993 для SSL)
smtp_port: Порт SMTP (по умолчанию 587 для TLS)
"""
def __init__(self, imap_host: str, smtp_host: str, email: str, password: str,
imap_port: int = 993, smtp_port: int = 587):
self.imap_host = imap_host
self.smtp_host = smtp_host
self.email = email
@@ -68,22 +26,65 @@ class EmailClient:
self.smtp_port = smtp_port
self.imap_conn = None
def _connect_imap(self):
"""Установить IMAP соединение"""
def connect(self):
"""Установkение IMAP соединения"""
if self.imap_conn is None:
self.imap_conn = imaplib.IMAP4_SSL(self.imap_host, self.imap_port)
self.imap_conn.login(self.email, self.password)
def _decode_header(self, header_value: str) -> str:
"""
Декодировать заголовок письма.
def disconnect(self):
"""Закрытие IMAP соединения"""
if self.imap_conn:
try:
self.imap_conn.disconnect()
self.imap_conn.logout()
except:
pass
self.imap_conn = None
Args:
header_value: Значение заголовка
def __enter__(self):
"""Поддержка контекстного менеджера"""
self.connect()
return self
Returns:
Декодированная строка
"""
def __exit__(self, exc_type, exc_val, exc_tb):
"""Поддержка контекстного менеджера"""
self.disconnect()
def get_emails_id(self, folder: str = "INBOX", only_unseen: bool = True) -> List[int]:
"""Получить список новых электронных писем."""
self.connect()
self.imap_conn.select(folder, readonly=False)
# Ищем письма
search_criteria = "(UNSEEN)" if only_unseen else "ALL"
status, messages = self.imap_conn.search(None, search_criteria)
# ToDo сделать обработку ошибок, подумать нужна ли она!
if status != "OK":
return []
email_ids = messages[0].split()
return email_ids
def get_email(self, email_id, mark_as_read: bool = True):
"""Получить список новых электронных писем."""
self.connect()
status, msg_data = self.imap_conn.fetch(email_id, "(RFC822)")
if status != "OK":
pass
# Парсим письмо
raw_email = msg_data[0][1]
msg = email.message_from_bytes(raw_email)
# Помечаем письмо как прочитанное
if mark_as_read:
self.imap_conn.store(email_id, '+FLAGS', '\\Seen')
return msg
def decode_header(self, header_value: str) -> str:
"""Декодировать заголовок письма."""
if header_value is None:
return ""
@@ -101,253 +102,3 @@ class EmailClient:
decoded_parts.append(str(part))
return ''.join(decoded_parts)
def _extract_first_sender(self, body: str):
"""
Извлекает адреса отправителей из пересылаемого сообщения по паттерну:
-------- Пересылаемое сообщение --------
07.10.2025, 16:01, Имя (email@example.com):
Кому: ...
"""
# Ищем первую секцию пересылаемого сообщения (по структуре письма)
match = re.search(
r"-{8,}\\s*Пересылаемое сообщение\\s*-{8,}.*?(\\d{2}\\.\\d{2}\\.\\d{4},\\s*\\d{2}:\\d{2},.*?)\\(([^\\)]+)\\):",
body, re.DOTALL)
emails = []
if match:
emails.append(match.group(2)) # email из первой строки пересыла
# Ищем все email в первой пересылаемой секции (например, в "Кому:")
forwarded_section = re.search(
r"^-{8,}.*?Пересылаемое сообщение.*?:$(.*?)(?:^[-=]{5,}|\\Z)",
body, re.MULTILINE | re.DOTALL)
if forwarded_section:
addresses = re.findall(r"\\b([\\w\\.-]+@[\\w\\.-]+)\\b", forwarded_section.group(1))
for addr in addresses:
if addr not in emails:
emails.append(addr)
return emails
def _extract_body(self, msg: email.message.Message) -> str:
"""
Извлечь текст письма.
Args:
msg: Объект письма
Returns:
Текст письма
"""
body = ""
if msg.is_multipart():
for part in msg.walk():
content_type = part.get_content_type()
content_disposition = str(part.get("Content-Disposition", ""))
# Ищем текстовые части без вложений
if content_type == "text/plain" and "attachment" not in content_disposition:
try:
charset = part.get_content_charset() or 'utf-8'
body += part.get_payload(decode=True).decode(charset, errors='ignore')
except:
pass
else:
try:
charset = msg.get_content_charset() or 'utf-8'
body = msg.get_payload(decode=True).decode(charset, errors='ignore')
except:
pass
return body
def _extract_attachments(self, msg: email.message.Message) -> List[EmailAttachment]:
"""
Извлечь вложения из письма.
Args:
msg: Объект письма
Returns:
Список вложений
"""
attachments = []
for part in msg.walk():
content_disposition = str(part.get("Content-Disposition", ""))
if "attachment" in content_disposition:
filename = part.get_filename()
if filename:
# Декодируем имя файла
filename = self._decode_header(filename)
# Получаем содержимое
content = part.get_payload(decode=True)
if content:
attachments.append(
EmailAttachment(filename=filename, content=content)
)
return attachments
def get_emails(
self,
folder: str = "INBOX",
only_unseen: bool = True,
mark_as_read: bool = True
) -> List[EmailMessage]:
"""
Получить список новых электронных писем.
Args:
folder: Папка для получения писем (по умолчанию "INBOX")
only_unseen: Получать только непрочитанные письма (по умолчанию True)
Returns:
Список объектов EmailMessage
"""
self._connect_imap()
# Выбираем папку
self.imap_conn.select(folder, readonly=False)
# Ищем письма
search_criteria = "(UNSEEN)" if only_unseen else "ALL"
status, messages = self.imap_conn.search(None, search_criteria)
if status != "OK":
return []
email_ids = messages[0].split()
emails = []
for email_id in email_ids:
try:
# Получаем письмо
status, msg_data = self.imap_conn.fetch(email_id, "(RFC822)")
if status != "OK":
continue
# Парсим письмо
raw_email = msg_data[0][1]
msg = email.message_from_bytes(raw_email)
# Извлекаем данные
from_addr = self._decode_header(msg.get("From", ""))
subject = self._decode_header(msg.get("Subject", ""))
# Получаем дату
date_str = msg.get("Date", "")
try:
date_tuple = email.utils.parsedate_tz(date_str)
if date_tuple:
timestamp = email.utils.mktime_tz(date_tuple)
dt = datetime.fromtimestamp(timestamp)
else:
dt = datetime.now()
except:
dt = datetime.now()
# Извлекаем тело письма
body = self._extract_body(msg)
first_sender = self._extract_first_sender(body)
# Извлекаем вложения
attachments = self._extract_attachments(msg)
# Создаем объект письма
email_obj = EmailMessage(
from_addr=from_addr,
subj=subject,
dt=dt,
body=body,
attachments=attachments,
first_sender=first_sender
)
emails.append(email_obj)
# Помечаем письмо как прочитанное
if mark_as_read:
self.imap_conn.store(email_id, '+FLAGS', '\\Seen')
except Exception as e:
print(f"Ошибка при обработке письма {email_id}: {e}")
continue
return emails
def send_email(
self,
message: EmailMessage,
to_addr: str,
cc: Optional[List[str]] = None,
bcc: Optional[List[str]] = None
):
"""
Отправить электронное письмо.
Args:
message: Объект EmailMessage для отправки
to_addr: Адрес получателя
cc: Список адресов для копии (необязательно)
bcc: Список адресов для скрытой копии (необязательно)
"""
# Создаем multipart сообщение
msg = MIMEMultipart()
msg['From'] = self.email
msg['To'] = to_addr
msg['Subject'] = message.subj
if cc:
msg['Cc'] = ', '.join(cc)
# Добавляем тело письма
msg.attach(MIMEText(message.body, 'plain', 'utf-8'))
# Добавляем вложения
for attachment in message.attachments:
part = MIMEBase('application', 'octet-stream')
part.set_payload(attachment.content)
encoders.encode_base64(part)
part.add_header(
'Content-Disposition',
f'attachment; filename= {attachment.filename}'
)
msg.attach(part)
# Формируем список всех получателей
recipients = [to_addr]
if cc:
recipients.extend(cc)
if bcc:
recipients.extend(bcc)
# Отправляем письмо
with smtplib.SMTP(self.smtp_host, self.smtp_port) as server:
server.starttls()
server.login(self.email, self.password)
server.sendmail(self.email, recipients, msg.as_string())
def close(self):
"""Закрыть IMAP соединение"""
if self.imap_conn:
try:
self.imap_conn.close()
self.imap_conn.logout()
except:
pass
self.imap_conn = None
def __enter__(self):
"""Поддержка контекстного менеджера"""
return self
def __exit__(self, exc_type, exc_val, exc_tb):
"""Поддержка контекстного менеджера"""
self.close()

View File

@@ -0,0 +1,99 @@
import re
from datetime import datetime
from typing import List, Optional
from dataclasses import dataclass
import email
from email import encoders
from email.mime.text import MIMEText
from email.mime.multipart import MIMEMultipart
from email.mime.base import MIMEBase
from email.header import decode_header
import imaplib
import smtplib
class EmailMagic:
def __init__(self, email):
self.email = email
def _decode_header(self, header_value: str) -> str:
"""Декодировать заголовок письма."""
if header_value is None:
return ""
decoded_parts = []
for part, encoding in decode_header(header_value):
if isinstance(part, bytes):
if encoding:
try:
decoded_parts.append(part.decode(encoding))
except:
decoded_parts.append(part.decode('utf-8', errors='ignore'))
else:
decoded_parts.append(part.decode('utf-8', errors='ignore'))
else:
decoded_parts.append(str(part))
return ''.join(decoded_parts)
def _extract_body(self, msg: email.message.Message) -> str:
"""Извлечь текст письма из любого типа содержимого, кроме вложений"""
body = ""
if msg.is_multipart():
for part in msg.walk():
content_disposition = str(part.get("Content-Disposition", ""))
# Пропускаем вложения
if "attachment" in content_disposition.lower():
continue
try:
charset = part.get_content_charset() or 'utf-8'
payload = part.get_payload(decode=True)
if payload:
body_piece = payload.decode(charset, errors='ignore')
body += body_piece
except Exception:
pass
else:
try:
charset = msg.get_content_charset() or 'utf-8'
payload = msg.get_payload(decode=True)
if payload:
body = payload.decode(charset, errors='ignore')
except Exception:
pass
return body
def __extract_email(self, text: str) -> str:
match = re.search(r'<([^<>]+)>', text)
if match:
return match.group(1)
return None
def _extract_first_sender(self, body: str):
"""Извлекает адреса отправителей из пересылаемого сообщения. Нужно для отладки"""
# Ищем email внутри скобок после строки "Пересылаемое сообщение"
pattern = r"Пересылаемое сообщение.*?\((.*?)\)"
match = re.search(pattern, body, re.DOTALL)
if match:
return match.group(1)
return None
def _extract_attachments(self, msg: email.message.Message) -> List[EmailAttachment]:
"""Извлечь вложения из письма."""
attachments = []
for part in msg.walk():
content_disposition = str(part.get("Content-Disposition", ""))
if "attachment" in content_disposition:
filename = part.get_filename()
if filename:
# Декодируем имя файла
filename = self._decode_header(filename)
# Получаем содержимое
content = part.get_payload(decode=True)
if content:
attachments.append(EmailAttachment(filename=filename, content=content))
return attachments

View File

@@ -1,5 +1,6 @@
from dataclasses import dataclass
from datetime import datetime
from email.message import EmailMessage
from typing import List
@@ -13,7 +14,10 @@ class EmailAttachment:
@dataclass
class EmailMessage:
"""Класс для представления электронного письма"""
message: EmailMessage
attachments: List[EmailAttachment]
from_addr: str
from_email: str
subj: str
dt: datetime
body: str

View File

@@ -0,0 +1 @@
from .processor import EmailProcessor

View File

@@ -0,0 +1,9 @@
from .abcp_clients.check_stock import GetStock
from .abcp_clients.create_order import InstantOrderTest
from .excel_parcers.order_parcer_basic import BasicExcelParser
from .notifications.test_notifier import TestNotifier
from .validators.price_quantity_ckecker import CheckOrder

View File

@@ -0,0 +1,27 @@
import random
import logging
from mail_order_bot.email_processor.handlers.abstract_task import AbstractTask
logger = logging.getLogger(__name__)
def get_stock(brand, part_number):
return random.randint(0, 10)
class GetStock(AbstractTask):
def do(self) -> None:
positions = self.order.positions
for position in positions:
self._update_stock(position)
def _update_stock(self, position):
# Эмулируем получение данных
max_stock = self.config.get('max_stock',10)
stock = random.randint(0, max_stock)
price = position.requested_price
position.stock_price = price
position.stock_quantity = stock

View File

@@ -0,0 +1,37 @@
import logging
import requests
from mail_order_bot.email_processor.handlers.abstract_task import AbstractTask
from mail_order_bot.email_processor.order.auto_part_order import OrderStatus
logger = logging.getLogger(__name__)
class InstantOrderTest(AbstractTask):
URL = "https://api.telegram.org/bot{0}/sendMessage?chat_id={1}&text={2}"
def do(self) -> None:
api_key = self.config["api_key"]
chat_id = self.config["chat_id"]
if self.order.status == OrderStatus.IN_PROGRESS:
positions = self.order.positions
message = f"Запрос на создание заказа от {self.context['client']}:\n"
message += "\n".join(f"{pos.sku}: {pos.name} ({pos.order_quantity} x {pos.order_price} = {pos.total})" for pos in positions)
elif self.order.status == OrderStatus.OPERATOR_REQUIRED:
message = f"Запрос на создание заказа от {self.context['client']} отклонен - необходима ручная обработка.\n"
message += f"Причина: {self.order.reason}"
else:
message = f"Запрос на создание заказа от {self.context['client']} отклонен.\n"
message += f" Статус заказа: {self.order.status}"
#url = self.URL.format(api_key, chat_id, message)
#resp = requests.get(url).json()
print(message)
#logger.info(resp)

View File

@@ -0,0 +1,24 @@
from abc import ABC, abstractmethod
from typing import Dict, Any
from mail_order_bot.context import Context
class AbstractTask(ABC, Context):
RESULT_SECTION = "section"
"""
Абстрактный базовый класс для всех хэндлеров.
"""
def __init__(self, config: Dict[str, Any]) -> None:
Context.__init__(self, {})
self.config = config
@abstractmethod
def do(self) -> None:
"""
Выполняет работу над заданием
Входные и выходные данные - в self.context
Конфиг задается при инициализации
"""
raise NotImplementedError

View File

@@ -0,0 +1,141 @@
import smtplib
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
from email.mime.base import MIMEBase
from email.utils import formatdate
from email import encoders
from abc import ABC, abstractmethod
import os
class AbstractTask(ABC):
"""Базовый класс для задач"""
def __init__(self, context, config):
self.context = context
self.config = config
@abstractmethod
def do(self):
"""Метод для реализации в подклассах"""
pass
class EmailReplyTask(AbstractTask):
"""Класс для ответа на электронные письма"""
def do(self):
"""
Отправляет ответ на входящее письмо
Ожидает в self.context:
- message: email.message.Message объект входящего письма
- attachment: путь к файлу для вложения
Ожидает в self.config:
- reply_to: адрес электронной почты для копии
- smtp_host: хост SMTP сервера
- smtp_port: порт SMTP сервера
- smtp_user: пользователь SMTP
- smtp_password: пароль SMTP
- from_email: адрес отправителя
"""
incoming_message = self.context.get("message")
attachment_path = self.context.get("attacnment")
if not incoming_message:
raise ValueError("Рcontext не найдено письмо (message)")
# Получаем адрес отправителя входящего письма
from_addr = incoming_message.get("From")
if not from_addr:
raise ValueError("Входящее письмо не содержит адреса отправителя")
# Создаем ответное письмо
reply_message = MIMEMultipart()
# Заголовки ответного письма
reply_message["From"] = self.config.get("from_email", "noreply@example.com")
reply_message["To"] = from_addr
reply_message["Cc"] = self.config.get("reply_to", "")
reply_message["Subject"] = f"Re: {incoming_message.get('Subject', '')}"
reply_message["Date"] = formatdate(localtime=True)
# Тело письма
body = "Ваш заказ создан"
reply_message.attach(MIMEText(body, "plain", "utf-8"))
# Добавляем вложение если указан путь к файлу
if attachment_path and os.path.isfile(attachment_path):
self._attach_file(reply_message, attachment_path)
# Отправляем письмо
self._send_email(reply_message, from_addr)
def _attach_file(self, message, file_path):
"""
Добавляет файл в качестве вложения к письму
Args:
message: MIMEMultipart объект
file_path: путь к файлу для вложения
"""
try:
with open(file_path, "rb") as attachment:
part = MIMEBase("application", "octet-stream")
part.set_payload(attachment.read())
encoders.encode_base64(part)
file_name = os.path.basename(file_path)
part.add_header(
"Content-Disposition",
f"attachment; filename= {file_name}"
)
message.attach(part)
except FileNotFoundError:
raise FileNotFoundError(f"Файл не найден: {file_path}")
except Exception as e:
raise Exception(f"Ошибка при добавлении вложения: {str(e)}")
def _send_email(self, message, recipient):
"""
Отправляет письмо через SMTP
Args:
message: MIMEMultipart объект письма
recipient: адрес получателя
"""
try:
smtp_host = self.config.get("smtp_host")
smtp_port = self.config.get("smtp_port", 587)
smtp_user = self.config.get("smtp_user")
smtp_password = self.config.get("smtp_password")
if not all([smtp_host, smtp_user, smtp_password]):
raise ValueError("Не указаны параметры SMTP в config")
with smtplib.SMTP(smtp_host, smtp_port) as server:
server.starttls()
server.login(smtp_user, smtp_password)
# Получаем адреса получателей (основной + копия)
recipients = [recipient]
reply_to = self.config.get("reply_to")
if reply_to:
recipients.append(reply_to)
server.sendmail(
self.config.get("from_email"),
recipients,
message.as_string()
)
except smtplib.SMTPException as e:
raise Exception(f"Ошибка SMTP: {str(e)}")
except Exception as e:
raise Exception(f"Ошибка при отправке письма: {str(e)}")

View File

@@ -0,0 +1,118 @@
import logging
import pandas as pd
from typing import Dict, Any, Optional
from decimal import Decimal
from io import BytesIO
#from mail_order_bot.email_processor.handlers.order_position import OrderPosition
from mail_order_bot.email_processor.handlers.abstract_task import AbstractTask
from ...order.auto_part_position import AutoPartPosition
logger = logging.getLogger(__name__)
class BasicExcelParser(AbstractTask):
RESULT_SECTION = "positions"
"""
Универсальный парсер, настраиваемый через конфигурацию.
Подходит для большинства стандартных случаев.
"""
def do(self) -> None:
# todo сделать проверку на наличие файла и его тип
file_bytes = BytesIO(self.context.get("attachment").content) # self.context.get("attachment") #
try:
df = self._make_dataframe(file_bytes)
# Получаем маппинг колонок из конфигурации
mapping = self.config['mapping']
# Парсим строки
positions = []
for idx, row in df.iterrows():
try:
position = self._parse_row(row, mapping)
if position:
positions.append(position)
self.order.add_position(position)
except Exception as e:
logger.error(f"Ошибка парсинга строки {idx}: {e}, {row}")
continue
logger.info(f"Успешно обработано {len(positions)} позиций из {len(df)} строк")
self.context[self.RESULT_SECTION] = positions
except Exception as e:
logger.error(f"Ошибка при обработке файла: {e}")
raise Exception from e
def _parse_row(self, row: pd.Series, mapping: Dict[str, str]) -> Optional[AutoPartPosition]:
"""Парсит одну строку Excel в OrderPosition"""
# Проверяем обязательные поля
required_fields = ['article', 'price', 'quantity']
for field in required_fields:
if pd.isna(row.get(mapping[field])):
logger.warning(f"Позиция не создана - не заполнено поле {mapping[field]}")
return None
price = Decimal(str(row[mapping['price']]).replace(",", ".").strip())
quantity = int(row[mapping['quantity']])
if "total" in mapping.keys():
total = Decimal(str(row[mapping['total']]).replace(",", ".").strip())
else:
total = price * quantity
if mapping.get('name', "") in mapping.keys():
name = str(row[mapping.get('name', "")]).strip()
else:
name = ""
# Создаем объект позиции
position = AutoPartPosition(
sku=str(row[mapping['article']]).strip(),
manufacturer=str(row[mapping.get('manufacturer', "")]).strip(),
name=name,
requested_price=price,
requested_quantity=quantity,
total=total,
additional_attrs=self._extract_additional_attrs(row, mapping)
)
return position
def _extract_additional_attrs(self, row: pd.Series, mapping: Dict[str, str]) -> Dict[str, Any]:
"""Извлекает дополнительные атрибуты, не входящие в основную модель"""
additional = {}
mapped_columns = set(mapping.values())
for col in row.index:
if col not in mapped_columns and not pd.isna(row[col]):
additional[col] = row[col]
return additional
def _make_dataframe(self, bio) -> pd.DataFrame:
# Получаем все данные из файла
sheet_name = self.config.get("sheet_name", 0)
df_full = pd.read_excel(bio, sheet_name=sheet_name, header=None)
# Находим индекс строки с заголовком
key_field = self.config.get("key_field")
header_row_idx = df_full[
df_full.apply(lambda row: row.astype(str).str.contains(key_field, case=False, na=False).any(),
axis=1)].index[0]
# Считываем таблицу с правильным заголовком
df = pd.read_excel(bio, header=header_row_idx, sheet_name=sheet_name, engine='calamine') # openpyxl calamine
# Находим индекс первой строки с пустым 'Артикул'
first_empty_index = df[df[key_field].isna()].index.min()
# Обрезаем DataFrame до первой пустой строки (не включая её)
df_trimmed = df.loc[:first_empty_index - 1]
return df_trimmed

View File

@@ -0,0 +1,118 @@
import logging
import pandas as pd
from typing import Dict, Any, Optional
from decimal import Decimal
from io import BytesIO
#from mail_order_bot.email_processor.handlers.order_position import OrderPosition
from mail_order_bot.email_processor.handlers.abstract_task import AbstractTask
from ...order.auto_part_position import AutoPartPosition
logger = logging.getLogger(__name__)
class BasicExcelParser(AbstractTask):
RESULT_SECTION = "positions"
"""
Универсальный парсер, настраиваемый через конфигурацию.
Подходит для большинства стандартных случаев.
"""
def do(self) -> None:
# todo сделать проверку на наличие файла и его тип
file_bytes = BytesIO(self.context.get("attachment").content) # self.context.get("attachment") #
try:
df = self._make_dataframe(file_bytes)
# Получаем маппинг колонок из конфигурации
mapping = self.config['mapping']
# Парсим строки
positions = []
for idx, row in df.iterrows():
try:
position = self._parse_row(row, mapping)
if position:
positions.append(position)
self.order.add_position(position)
except Exception as e:
logger.error(f"Ошибка парсинга строки {idx}: {e}, {row}")
continue
logger.info(f"Успешно обработано {len(positions)} позиций из {len(df)} строк")
self.context[self.RESULT_SECTION] = positions
except Exception as e:
logger.error(f"Ошибка при обработке файла: {e}")
raise Exception from e
def _parse_row(self, row: pd.Series, mapping: Dict[str, str]) -> Optional[AutoPartPosition]:
"""Парсит одну строку Excel в OrderPosition"""
# Проверяем обязательные поля
required_fields = ['article', 'price', 'quantity']
for field in required_fields:
if pd.isna(row.get(mapping[field])):
logger.warning(f"Позиция не создана - не заполнено поле {mapping[field]}")
return None
price = Decimal(str(row[mapping['price']]).replace(",", ".").strip())
quantity = int(row[mapping['quantity']])
if "total" in mapping.keys():
total = Decimal(str(row[mapping['total']]).replace(",", ".").strip())
else:
total = price * quantity
if mapping.get('name', "") in mapping.keys():
name = str(row[mapping.get('name', "")]).strip()
else:
name = ""
# Создаем объект позиции
position = AutoPartPosition(
sku=str(row[mapping['article']]).strip(),
manufacturer=str(row[mapping.get('manufacturer', "")]).strip(),
name=name,
requested_price=price,
requested_quantity=quantity,
total=total,
additional_attrs=self._extract_additional_attrs(row, mapping)
)
return position
def _extract_additional_attrs(self, row: pd.Series, mapping: Dict[str, str]) -> Dict[str, Any]:
"""Извлекает дополнительные атрибуты, не входящие в основную модель"""
additional = {}
mapped_columns = set(mapping.values())
for col in row.index:
if col not in mapped_columns and not pd.isna(row[col]):
additional[col] = row[col]
return additional
def _make_dataframe(self, bio) -> pd.DataFrame:
# Получаем все данные из файла
sheet_name = self.config.get("sheet_name", 0)
df_full = pd.read_excel(bio, sheet_name=sheet_name, header=None)
# Находим индекс строки с заголовком
key_field = self.config.get("key_field")
header_row_idx = df_full[
df_full.apply(lambda row: row.astype(str).str.contains(key_field, case=False, na=False).any(),
axis=1)].index[0]
# Считываем таблицу с правильным заголовком
df = pd.read_excel(bio, header=header_row_idx, sheet_name=sheet_name, engine='calamine') # openpyxl calamine
# Находим индекс первой строки с пустым 'Артикул'
first_empty_index = df[df[key_field].isna()].index.min()
# Обрезаем DataFrame до первой пустой строки (не включая её)
df_trimmed = df.loc[:first_empty_index - 1]
return df_trimmed

View File

@@ -0,0 +1,15 @@
import logging
from mail_order_bot.email_processor.handlers.abstract_task import AbstractTask
logger = logging.getLogger(__name__)
class TestNotifier(AbstractTask):
def do(self) -> None:
positions = self.context["positions"]
print(f"\nПолучено {len(positions)} позиций от {self.context["client"]}:")
for pos in positions: # Первые 5
print(f" - {pos.sku}: {pos.name} "
f"({pos.requested_quantity} x {pos.requested_price} = {pos.total})")

View File

@@ -0,0 +1,50 @@
import random
import logging
from mail_order_bot.email_processor.handlers.abstract_task import AbstractTask
from mail_order_bot.email_processor.order.auto_part_order import OrderStatus
from decimal import Decimal
import random
logger = logging.getLogger(__name__)
class CheckOrder(AbstractTask):
def do(self) -> None:
refused = 0
positions = self.order.positions
for position in positions:
self._set_order_price(position)
self._set_order_quantity(position)
if position.order_price == 0 or position.order_quantity == 0:
refused += 1
self._check_refusal_threshold(refused)
def _set_order_price(self, position):
# Эмулируем получение данных
acceptable_price_reduction = self.config.get("acceptable_price_reduction")
acceptable_price = position.stock_price* Decimal(str((1-acceptable_price_reduction/100)))
if position.requested_price < acceptable_price:
position.order_price = 0
else:
position.order_price = position.requested_price
def _set_order_quantity(self, position):
max_stock = self.config.get("max_stock", 100)
min_stock = self.config.get("min_stock", 0)
stock_quantity = random.randint(min_stock, max_stock)
position.order_quantity = max(0, min(position.stock_quantity, stock_quantity))
def _check_refusal_threshold(self, refused):
refusal_threshold_limit = self.config.get("refusal_threshold", 1)
refusal_level = refused/len(self.order.positions)
if refusal_level > refusal_threshold_limit:
self.order.status = OrderStatus.OPERATOR_REQUIRED
self.order.reason = "Превышен порог отказов"

View File

@@ -0,0 +1,34 @@
from typing import List, Optional
from .auto_part_position import AutoPartPosition
from enum import Enum
class OrderStatus(Enum):
NEW = "new"
IN_PROGRESS = "in progress"
FAILED = "failed"
COMPLETED = "completed"
OPERATOR_REQUIRED = "operator required"
INVALID = "invalid"
class AutoPartOrder:
def __init__(self):
self.positions: List[AutoPartPosition] = []
self.status = OrderStatus.NEW
self.reason = ""
def add_position(self, position: AutoPartPosition) -> None:
self.positions.append(position)
if self.status == OrderStatus.NEW:
self.status = OrderStatus.IN_PROGRESS
def find_positions(self, brand: Optional[str] = None, sku: Optional[str] = None) -> List[AutoPartPosition]:
results = self.positions
if brand is not None:
results = [p for p in results if p.manufacturer == brand]
if sku is not None:
results = [p for p in results if p.sku == sku]
return results
def __len__(self):
return len(self.positions)

View File

@@ -0,0 +1,77 @@
from typing import List, Optional
from dataclasses import dataclass, field
from typing import Dict, Any
from decimal import Decimal
@dataclass
class AutoPartPosition:
"""
Унифицированная модель позиции для заказа.
Все контрагенты приводятся к этой структуре.
"""
sku: str # Артикул товара
manufacturer: str # Производитель
requested_quantity: int # Количество
total: Decimal = 0 # Общая сумма
name: str = "" # Наименование
requested_price: Decimal = 0 # Цена за единицу
order_quantity: int = 0 # Количество для заказа
order_price: Decimal = Decimal('0.0') # Цена в заказе
stock: List[Dict[str, Any]] = None
additional_attrs: Dict[str, Any] = field(default_factory=dict)
def __post_init__(self):
"""Валидация после инициализации"""
if self.requested_quantity < 0:
raise ValueError(f"Количество не может быть отрицательным: {self.requested_quantity}")
if self.requested_price < 0:
raise ValueError(f"Цена не может быть отрицательной: {self.requested_price}")
class AutoPartPosition2:
brand: str
sku: str
name: str
customer_price: float
customer_quantity: int
supplier_price: float
stock_remaining: int
def __init__(self, brand: str, sku: str, name: str,
customer_price: float, customer_quantity: int,
supplier_price: float, stock_remaining: int):
self.brand = brand
self.sku = sku
self.name = name
self.customer_price = customer_price
self.customer_quantity = customer_quantity
self.supplier_price = supplier_price
self.stock_remaining = stock_remaining
def customer_cost(self) -> float:
return self.customer_price * self.customer_quantity
def supplier_cost(self) -> float:
return self.supplier_price * self.customer_quantity
def is_available(self) -> bool:
return self.stock_remaining >= self.customer_quantity
def restock(self, amount: int) -> None:
if amount < 0:
raise ValueError("Restock amount must be non-negative")
self.stock_remaining += amount
def __post_init__(self):
if self.customer_price < 0:
raise ValueError("Customer price cannot be negative")
if self.customer_quantity < 0:
raise ValueError("Customer quantity cannot be negative")
if self.supplier_price < 0:
raise ValueError("Supplier price cannot be negative")
if self.stock_remaining < 0:
raise ValueError("Stock remaining cannot be negative")

View File

@@ -0,0 +1,52 @@
import os
import yaml
import logging
from typing import Dict, Any
from pathlib import Path
logger = logging.getLogger(__name__)
from mail_order_bot.context import Context
from enum import Enum
class RequestStatus(Enum):
NEW = "new"
IN_PROGRESS = "in progress"
FAILED = "failed"
EXECUTED = "executed"
OPERATOR_REQUIRED = "operator required"
INVALID = "invalid"
class EmailProcessor(Context):
def __init__(self, configs_path: Path):
super().__init__()
self.configs_path = configs_path
self.status = RequestStatus.NEW
def process_email(self, email):
# Очистить контекст
self.context.clear()
# Сохранить письмо в контекст
self.context["email"] = email
# Определить клиента
# Определить конфиг для пайплайна
config = {}
# Запустить обработку пайплайна
for stage in config["pipeline"]:
handler_name = stage["handler"]
logger.info(f"Processing handler: {handler_name}")
task = globals()[handler_name](stage.get("config", None), self.context)
task.do()
def _load_config(self, client) -> Dict[str, Any]:
"""Загружает конфигурацию из YAML или JSON"""
path = os.path.join(self.configs_path, client + '.yml')
with open(path, 'r', encoding='utf-8') as f:
return yaml.safe_load(f)

View File

@@ -0,0 +1 @@
from .processor import ExcelProcessor

View File

@@ -0,0 +1,113 @@
import logging
import pandas as pd
from typing import Dict, Any, Optional, List
from decimal import Decimal
from .excel_parser import ExcelParser
from .order_position import OrderPosition
logger = logging.getLogger(__name__)
class ConfigurableExcelParser(ExcelParser):
"""
Универсальный парсер, настраиваемый через конфигурацию.
Подходит для большинства стандартных случаев.
"""
def parse(self, file_bytes: str) -> List[OrderPosition]:
try:
# Читаем Excel
df = self._make_dataframe(file_bytes)
# Получаем маппинг колонок из конфигурации
mapping = self.config['mapping']
# Парсим строки
positions = []
for idx, row in df.iterrows():
try:
position = self._parse_row(row, mapping)
if position:
positions.append(position)
except Exception as e:
logger.error(f"Ошибка парсинга строки {idx}: {e}, {row}")
continue
logger.info(f"Успешно обработано {len(positions)} позиций из {len(df)} строк")
return positions
except Exception as e:
logger.error(f"Ошибка при обработке файла: {e}")
raise Exception from e
def _parse_row(self, row: pd.Series, mapping: Dict[str, str]) -> Optional[OrderPosition]:
"""Парсит одну строку Excel в OrderPosition"""
# Проверяем обязательные поля
required_fields = ['article', 'price', 'quantity']
for field in required_fields:
if pd.isna(row.get(mapping[field])):
logger.warning(f"Позиция не создана - не заполнено поле {mapping[field]}")
return None
price = Decimal(str(row[mapping['price']]).replace(",", ".").strip())
quantity = int(row[mapping['quantity']])
if "total" in mapping.keys():
total = Decimal(str(row[mapping['total']]).replace(",", ".").strip())
else:
total = price * quantity
if mapping.get('name',"") in mapping.keys():
name = str(row[mapping.get('name', "")]).strip()
else:
name = ""
# Создаем объект позиции
position = OrderPosition(
article=str(row[mapping['article']]).strip(),
manufacturer=str(row[mapping.get('manufacturer',"")]).strip(),
name=name,
price=price,
quantity=quantity,
total=total,
additional_attrs=self._extract_additional_attrs(row, mapping)
)
return position
def _extract_additional_attrs(self, row: pd.Series, mapping: Dict[str, str]) -> Dict[str, Any]:
"""Извлекает дополнительные атрибуты, не входящие в основную модель"""
additional = {}
mapped_columns = set(mapping.values())
for col in row.index:
if col not in mapped_columns and not pd.isna(row[col]):
additional[col] = row[col]
return additional
def _make_dataframe(self, bio) -> pd.DataFrame:
# Получаем все данные из файла
sheet_name = self.config.get("sheet_name", 0)
df_full = pd.read_excel(bio, sheet_name=sheet_name, header=None)
# Находим индекс строки с заголовком
key_field = self.config.get("key_field")
header_row_idx = df_full[
df_full.apply(lambda row: row.astype(str).str.contains(key_field, case=False, na=False).any(),
axis=1)].index[0]
# Считываем таблицу с правильным заголовком
df = pd.read_excel(bio, header=header_row_idx, sheet_name=sheet_name, engine='calamine') #openpyxl calamine
# Находим индекс первой строки с пустым 'Артикул'
first_empty_index = df[df[key_field].isna()].index.min()
# Обрезаем DataFrame до первой пустой строки (не включая её)
df_trimmed = df.loc[:first_empty_index - 1]
return df_trimmed

View File

@@ -0,0 +1,105 @@
import logging
import pandas as pd
from typing import Dict, Any, Optional, List
from decimal import Decimal
import xlrd
from io import BytesIO
from .excel_parser import ExcelParser
from .order_position import OrderPosition
logger = logging.getLogger(__name__)
class CustomExcelParserAutoeuro(ExcelParser):
"""
Универсальный парсер, настраиваемый через конфигурацию.
Подходит для большинства стандартных случаев.
"""
def parse(self, file_bytes: BytesIO) -> List[OrderPosition]:
try:
# Читаем Excel
df = self._make_dataframe(file_bytes)
# Получаем маппинг колонок из конфигурации
mapping = self.config['mapping']
# Парсим строки
positions = []
for idx, row in df.iterrows():
try:
position = self._parse_row(row, mapping)
if position:
positions.append(position)
except Exception as e:
logger.error(f"Ошибка парсинга строки {idx}: {e}, {row}")
continue
logger.info(f"Успешно обработано {len(positions)} позиций из {len(df)} строк")
return positions
except Exception as e:
logger.error(f"Ошибка при обработке файла: {e}")
raise Exception from e
def _parse_row(self, row: pd.Series, mapping: Dict[str, str]) -> Optional[OrderPosition]:
"""Парсит одну строку Excel в OrderPosition"""
# Проверяем обязательные поля
required_fields = ['article', 'price', 'quantity']
for field in required_fields:
if pd.isna(row.get(mapping[field])):
logger.warning(f"Позиция не создана - не заполнено поле {mapping[field]}")
return None
price = Decimal(str(row[mapping['price']]).replace(",", ".").strip())
quantity = int(row[mapping['quantity']])
if "total" in mapping.keys():
total = Decimal(str(row[mapping['total']]).replace(",", ".").strip())
else:
total = price * quantity
# Создаем объект позиции
position = OrderPosition(
article=str(row[mapping['article']]).strip(),
manufacturer=str(row[mapping.get('manufacturer', "")]).strip(),
name="", #str(row[mapping.get('name', "name")]).strip(),
price=price,
quantity=quantity,
total=total,
additional_attrs=self._extract_additional_attrs(row, mapping)
)
return position
def _extract_additional_attrs(self, row: pd.Series, mapping: Dict[str, str]) -> Dict[str, Any]:
"""Извлекает дополнительные атрибуты, не входящие в основную модель"""
additional = {}
mapped_columns = set(mapping.values())
for col in row.index:
if col not in mapped_columns and not pd.isna(row[col]):
additional[col] = row[col]
return additional
def _make_dataframe(self, bio) -> pd.DataFrame:
file_bytes = bio.read()
book = xlrd.open_workbook(file_contents=file_bytes, encoding_override='cp1251')
sheet = book.sheet_by_index(self.config.get("sheet_index", 0))
data = [sheet.row_values(row) for row in range(sheet.nrows)]
df_full = pd.DataFrame(data)
key_field = self.config.get("key_field")
header_row_idx = df_full[
df_full.apply(lambda row: row.astype(str).str.contains(key_field, case=False, na=False).any(),
axis=1)].index[0]
df = df_full[header_row_idx:]
df.columns = df.iloc[0] # первая строка становится заголовком
df = df.reset_index(drop=True).drop(0).reset_index(drop=True) # удаляем первую строку и сбрасываем индекс
return df

View File

@@ -1,7 +1,12 @@
from abc import ABC, abstractmethod
from typing import List
import pandas as pd
import logging
import pandas as pd
from abc import ABC, abstractmethod
from typing import Dict, Any, List
from io import BytesIO
from .order_position import OrderPosition
logger = logging.getLogger(__name__)
@@ -15,19 +20,9 @@ class ExcelParser(ABC):
self.config = config
@abstractmethod
def parse(self, filepath: str) -> List[OrderPosition]:
def parse(self, file: BytesIO) -> List[OrderPosition]:
"""
Парсит Excel файл и возвращает список позиций.
Должен быть реализован в каждом конкретном парсере.
"""
pass
def _read_excel(self, filepath: str) -> pd.DataFrame:
"""Общий метод для чтения Excel файлов"""
return pd.read_excel(
filepath,
sheet_name=self.config.get('sheet_name', 0),
header=self.config.get('header_row', 0),
#engine='openpyxl'
engine='calamine'
)

View File

@@ -1,6 +1,15 @@
import yaml
import json
import logging
from pathlib import Path
from typing import Dict, Any, List
from .excel_parser import ExcelParser
from .configurable_parser import ConfigurableExcelParser
from .custom_parser_autoeuro import CustomExcelParserAutoeuro
logger = logging.getLogger(__name__)
class ParserFactory:
"""
@@ -10,48 +19,36 @@ class ParserFactory:
# Реестр кастомных парсеров
CUSTOM_PARSERS = {
'supplier_a': SupplierAParser,
'autoeuro.ru': CustomExcelParserAutoeuro,
# Добавляйте сюда специализированные парсеры
}
def __init__(self, config_path: str):
self.config_path = Path(config_path)
self.suppliers_config = self._load_config()
def _load_config(self) -> Dict[str, Any]:
"""Загружает конфигурацию из YAML или JSON"""
if self.config_path.suffix in ['.yaml', '.yml']:
with open(self.config_path, 'r', encoding='utf-8') as f:
return yaml.safe_load(f)
elif self.config_path.suffix == '.json':
with open(self.config_path, 'r', encoding='utf-8') as f:
return json.load(f)
else:
raise ValueError(f"Неподдерживаемый формат конфига: {self.config_path.suffix}")
def __init__(self, config: Dict[str, Any]):
self.config = config
def get_parser(self, supplier_name: str) -> ExcelParser:
"""
Возвращает парсер для указанного контрагента.
Использует кастомный парсер если есть, иначе конфигурируемый.
"""
if supplier_name not in self.suppliers_config['suppliers']:
if supplier_name not in self.config['suppliers']:
raise ValueError(
f"Контрагент '{supplier_name}' не найден в конфигурации. "
f"Доступные: {list(self.suppliers_config['suppliers'].keys())}"
f"Доступные: {list(self.config['suppliers'].keys())}"
)
config = self.suppliers_config['suppliers'][supplier_name]
config = self.config['suppliers'][supplier_name]
# Проверяем, есть ли кастомный парсер
if supplier_name in self.CUSTOM_PARSERS:
parser_class = self.CUSTOM_PARSERS[supplier_name]
logger.info(f"Используется кастомный парсер для {supplier_name}")
logger.debug(f"Используется кастомный парсер для {supplier_name}")
else:
parser_class = ConfigurableExcelParser
logger.info(f"Используется конфигурируемый парсер для {supplier_name}")
logger.debug(f"Используется конфигурируемый парсер для {supplier_name}")
return parser_class(config)
def list_suppliers(self) -> List[str]:
"""Возвращает список всех доступных контрагентов"""
return list(self.suppliers_config['suppliers'].keys())
return list(self.config['suppliers'].keys())

View File

@@ -1,31 +1,36 @@
import logging
from pathlib import Path
from decimal import Decimal
from io import BytesIO
from typing import Dict, Any, List
import yaml
import json
from .parser_factory import ParserFactory
from .order_position import OrderPosition
logger = logging.getLogger(__name__)
class ExcelProcessor:
"""
Главный класс-фасад для обработки Excel файлов.
Упрощает использование системы.
"""
def __init__(self, config_path: str = 'config/suppliers.yaml'):
self.factory = ParserFactory(config_path)
self._setup_logging()
def __init__(self, config_path: str = 'config/suppliers.yaml', ):
self.config_path = Path(config_path)
self.config = self._load_config()
self.factory = ParserFactory(self.config)
def _setup_logging(self):
"""Настройка логирования"""
logging.basicConfig(
level=logging.INFO,
format='%(asctime)s - %(name)s - %(levelname)s - %(message)s'
)
def process_file(
self,
filepath: str,
supplier_name: str,
validate: bool = True
) -> List[OrderPosition]:
def process(self, file_bytes: BytesIO, file_name: str, supplier_name: str, validate: bool = False) -> List[OrderPosition]:
"""
Обрабатывает Excel файл от контрагента.
Args:
filepath: Путь к Excel файлу
file_bytes: Байты файла
file_name: Имя файла
supplier_name: Название контрагента (из конфигурации)
validate: Выполнять ли дополнительную валидацию
@@ -34,25 +39,34 @@ class ExcelProcessor:
Raises:
ValueError: Если контрагент не найден
FileNotFoundError: Если файл не найден
"""
logger.info(f"Начало обработки файла: {filepath} для {supplier_name}")
logger.info(f"Обработка файла: {file_name} для {supplier_name}")
# Проверка существования файла
if not Path(filepath).exists():
raise FileNotFoundError(f"Файл не найден: {filepath}")
# Получаем парсер и обрабатываем
parser = self.factory.get_parser(supplier_name)
positions = parser.parse(filepath)
positions = parser.parse(file_bytes)
# Дополнительная валидация если нужна
if validate:
positions = self._validate_positions(positions)
logger.info(f"Обработка завершена: получено {len(positions)} позиций")
logger.debug(f"Обработка завершена: получено {len(positions)} позиций")
return positions
def process_file(self, file_path: str, supplier_name: str, validate: bool = False) -> List[OrderPosition]:
# Проверка существования файла
logger.debug(f"Чтение файла: {file_path}")
if not Path(file_path).exists():
raise FileNotFoundError(f"Файл не найден: {file_path}")
with open(file_path, 'rb') as file: # бинарный режим
raw_data = file.read()
bio = BytesIO(raw_data)
positions = self.process(bio, file_path, supplier_name, validate=validate)
return positions
def _validate_positions(self, positions: List[OrderPosition]) -> List[OrderPosition]:
"""Дополнительная валидация позиций"""
valid_positions = []
@@ -83,3 +97,14 @@ class ExcelProcessor:
def get_available_suppliers(self) -> List[str]:
"""Возвращает список доступных контрагентов"""
return self.factory.list_suppliers()
def _load_config(self) -> Dict[str, Any]:
"""Загружает конфигурацию из YAML или JSON"""
if self.config_path.suffix in ['.yaml', '.yml']:
with open(self.config_path, 'r', encoding='utf-8') as f:
return yaml.safe_load(f)
elif self.config_path.suffix == '.json':
with open(self.config_path, 'r', encoding='utf-8') as f:
return json.load(f)
else:
raise ValueError(f"Неподдерживаемый формат конфига: {self.config_path.suffix}")

View File

@@ -1,68 +0,0 @@
from typing import Optional
class ConfigurableExcelParser(ExcelParser):
"""
Универсальный парсер, настраиваемый через конфигурацию.
Подходит для большинства стандартных случаев.
"""
def parse(self, filepath: str) -> List[OrderPosition]:
try:
# Читаем Excel
df = self._read_excel(filepath)
# Удаляем пустые строки
df = df.dropna(how='all')
# Получаем маппинг колонок из конфигурации
mapping = self.config['mapping']
# Парсим строки
positions = []
for idx, row in df.iterrows():
try:
position = self._parse_row(row, mapping)
if position:
positions.append(position)
except Exception as e:
logger.warning(f"Ошибка парсинга строки {idx}: {e}")
continue
logger.info(f"Успешно обработано {len(positions)} позиций из {len(df)} строк")
return positions
except Exception as e:
logger.error(f"Ошибка при обработке файла {filepath}: {e}")
raise
def _parse_row(self, row: pd.Series, mapping: Dict[str, str]) -> Optional[OrderPosition]:
"""Парсит одну строку Excel в OrderPosition"""
# Проверяем обязательные поля
required_fields = ['article', 'manufacturer', 'name', 'price', 'quantity', 'total']
for field in required_fields:
if pd.isna(row.get(mapping[field])):
return None
# Создаем объект позиции
position = OrderPosition(
article=str(row[mapping['article']]).strip(),
manufacturer=str(row[mapping['manufacturer']]).strip(),
name=str(row[mapping['name']]).strip(),
price=Decimal(str(row[mapping['price']])),
quantity=int(row[mapping['quantity']]),
total=Decimal(str(row[mapping['total']])),
additional_attrs=self._extract_additional_attrs(row, mapping)
)
return position
def _extract_additional_attrs(self, row: pd.Series, mapping: Dict[str, str]) -> Dict[str, Any]:
"""Извлекает дополнительные атрибуты, не входящие в основную модель"""
additional = {}
mapped_columns = set(mapping.values())
for col in row.index:
if col not in mapped_columns and not pd.isna(row[col]):
additional[col] = row[col]
return additional

View File

@@ -1,452 +0,0 @@
2025-11-01 21:42:16,440 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:42:16,440 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:42:16,440 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:42:16,440 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:42:16,440 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:42:16,440 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:42:17,109 main [ INFO]: Check emails for new orders
2025-11-01 21:42:19,239 main [ INFO]: Check emails for new orders
2025-11-01 21:42:21,371 main [ INFO]: Check emails for new orders
2025-11-01 21:42:23,499 main [ INFO]: Check emails for new orders
2025-11-01 21:42:25,636 main [ INFO]: Check emails for new orders
2025-11-01 21:42:27,770 main [ INFO]: Check emails for new orders
2025-11-01 21:42:27,772 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:42:27,772 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:42:27,772 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:42:27,772 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:42:35,229 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:42:35,229 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:42:35,230 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:42:35,230 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:42:35,230 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:42:35,230 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:42:37,462 main [ INFO]: Check emails for new orders
2025-11-01 21:42:39,542 main [ INFO]: Check emails for new orders
2025-11-01 21:42:41,623 main [ INFO]: Check emails for new orders
2025-11-01 21:42:43,705 main [ INFO]: Check emails for new orders
2025-11-01 21:42:45,791 main [ INFO]: Check emails for new orders
2025-11-01 21:42:47,872 main [ INFO]: Check emails for new orders
2025-11-01 21:42:49,514 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:42:49,514 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:42:49,514 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:42:49,514 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:43:04,728 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:43:04,728 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:43:04,730 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:43:04,730 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:43:04,730 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:43:04,730 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:43:07,002 main [ DEBUG]: Check emails for new orders
2025-11-01 21:43:09,104 main [ DEBUG]: Check emails for new orders
2025-11-01 21:43:11,205 main [ DEBUG]: Check emails for new orders
2025-11-01 21:43:13,309 main [ DEBUG]: Check emails for new orders
2025-11-01 21:43:15,413 main [ DEBUG]: Check emails for new orders
2025-11-01 21:43:17,516 main [ DEBUG]: Check emails for new orders
2025-11-01 21:43:19,630 main [ DEBUG]: Check emails for new orders
2025-11-01 21:43:21,729 main [ DEBUG]: Check emails for new orders
2025-11-01 21:43:22,746 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:43:22,746 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:43:22,747 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:43:22,747 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:43:22,747 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:43:22,747 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:44:56,825 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:44:56,825 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:44:56,826 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:44:56,826 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:44:56,826 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:44:56,826 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:46:08,675 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:46:08,675 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:46:08,677 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:46:08,677 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:46:11,962 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:46:11,962 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:46:11,962 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:46:11,962 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:46:11,962 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:46:11,962 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:46:23,627 main [ INFO]: Fwd: Заказ 95 на поставку запчастей Detali.ru
2025-11-01 21:46:23,627 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,627 main [ INFO]: 2025-10-27 13:39:28
2025-11-01 21:46:23,627 main [ INFO]:
2025-11-01 21:46:23,627 main [ INFO]: []
2025-11-01 21:46:23,627 main [ INFO]: --------------------------------
2025-11-01 21:46:23,628 main [ INFO]: Fwd: Заказ поставщику номер 00000056685 (Сальткрока, 000426967) от ООО Нова
2025-11-01 21:46:23,628 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,628 main [ INFO]: 2025-10-27 13:39:36
2025-11-01 21:46:23,628 main [ INFO]:
2025-11-01 21:46:23,628 main [ INFO]: []
2025-11-01 21:46:23,628 main [ INFO]: --------------------------------
2025-11-01 21:46:23,628 main [ INFO]: Fwd: Заказ 00УТ-011202 ЦС 2
2025-11-01 21:46:23,628 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,628 main [ INFO]: 2025-10-27 13:39:42
2025-11-01 21:46:23,628 main [ INFO]:
2025-11-01 21:46:23,628 main [ INFO]: []
2025-11-01 21:46:23,628 main [ INFO]: --------------------------------
2025-11-01 21:46:23,628 main [ INFO]: Fwd: Заказ 00УТ-010792 Наличие
2025-11-01 21:46:23,628 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,628 main [ INFO]: 2025-10-27 13:39:50
2025-11-01 21:46:23,628 main [ INFO]:
2025-11-01 21:46:23,628 main [ INFO]: []
2025-11-01 21:46:23,628 main [ INFO]: --------------------------------
2025-11-01 21:46:23,628 main [ INFO]: Fwd: Заказ поставщику Партерра Сальткрока СПБ на Санкт-Петербург ЦКД
2025-11-01 21:46:23,628 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,628 main [ INFO]: 2025-10-27 13:40:05
2025-11-01 21:46:23,628 main [ INFO]:
2025-11-01 21:46:23,628 main [ INFO]: []
2025-11-01 21:46:23,628 main [ INFO]: --------------------------------
2025-11-01 21:46:23,628 main [ INFO]: Fwd: Заказ поставщику Партерра Сальткрока СПБ 1Д на Санкт-Петербург ЦКД
2025-11-01 21:46:23,628 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,628 main [ INFO]: 2025-10-27 13:40:10
2025-11-01 21:46:23,628 main [ INFO]:
2025-11-01 21:46:23,628 main [ INFO]: []
2025-11-01 21:46:23,628 main [ INFO]: --------------------------------
2025-11-01 21:46:23,628 main [ INFO]: Fwd: FAOrderSPB_56151479_2025-04-02-10-04-25.xlsx
2025-11-01 21:46:23,628 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,628 main [ INFO]: 2025-10-27 13:40:21
2025-11-01 21:46:23,628 main [ INFO]:
2025-11-01 21:46:23,628 main [ INFO]: []
2025-11-01 21:46:23,628 main [ INFO]: --------------------------------
2025-11-01 21:46:23,628 main [ INFO]: Fwd: Заказ компании АвтоСпутник (Автоспутник Санкт-Петербург) № 2087185 от 24.10.2025 склад Наличие
2025-11-01 21:46:23,628 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,628 main [ INFO]: 2025-10-27 13:40:28
2025-11-01 21:46:23,628 main [ INFO]:
2025-11-01 21:46:23,628 main [ INFO]: []
2025-11-01 21:46:23,629 main [ INFO]: --------------------------------
2025-11-01 21:46:23,629 main [ INFO]: Fwd: Заказ компании АвтоСпутник (Автоспутник Санкт-Петербург) № 2085697 от 23.10.2025 склад ЦС 5 дней
2025-11-01 21:46:23,629 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,629 main [ INFO]: 2025-10-27 13:40:32
2025-11-01 21:46:23,629 main [ INFO]:
2025-11-01 21:46:23,629 main [ INFO]: []
2025-11-01 21:46:23,629 main [ INFO]: --------------------------------
2025-11-01 21:46:23,629 main [ INFO]: Fwd: заказ Юником Санкт-Петербург Заказ СПФ00000007980
2025-11-01 21:46:23,629 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,629 main [ INFO]: 2025-10-27 13:40:40
2025-11-01 21:46:23,629 main [ INFO]:
2025-11-01 21:46:23,629 main [ INFO]: []
2025-11-01 21:46:23,629 main [ INFO]: --------------------------------
2025-11-01 21:46:23,629 main [ INFO]: Fwd: заказ Юником Санкт-Петербург Заказ СПФ00000007928
2025-11-01 21:46:23,629 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,629 main [ INFO]: 2025-10-27 13:41:46
2025-11-01 21:46:23,629 main [ INFO]:
2025-11-01 21:46:23,629 main [ INFO]: []
2025-11-01 21:46:23,629 main [ INFO]: --------------------------------
2025-11-01 21:46:23,629 main [ INFO]: Fwd: Заказ ООО Амтел Санкт-Петербург от 27.10.2025
2025-11-01 21:46:23,629 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,629 main [ INFO]: 2025-10-27 13:41:54
2025-11-01 21:46:23,629 main [ INFO]:
2025-11-01 21:46:23,629 main [ INFO]: []
2025-11-01 21:46:23,629 main [ INFO]: --------------------------------
2025-11-01 21:46:23,629 main [ INFO]: Fwd: Заказ «Сальткрока» от Sigma №686120 на сумму 151434.12 руб !
2025-11-01 21:46:23,629 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,629 main [ INFO]: 2025-10-27 13:42:03
2025-11-01 21:46:23,629 main [ INFO]:
2025-11-01 21:46:23,629 main [ INFO]: []
2025-11-01 21:46:23,629 main [ INFO]: --------------------------------
2025-11-01 21:46:23,629 main [ INFO]: Fwd: Зпт № Зпт-303384 Доставка в Санкт-Петербург (клиентский) Склад: Сальткрока (СПБ) 0-1 день
2025-11-01 21:46:23,629 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,629 main [ INFO]: 2025-10-27 13:42:13
2025-11-01 21:46:23,629 main [ INFO]:
2025-11-01 21:46:23,629 main [ INFO]: []
2025-11-01 21:46:23,629 main [ INFO]: --------------------------------
2025-11-01 21:46:23,629 main [ INFO]: Fwd: Зпт № Зпт-303044 Доставка в Санкт-Петербург (экспресс) Склад: Сальткрока (СПБ) 2-3 дня
2025-11-01 21:46:23,629 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,629 main [ INFO]: 2025-10-27 13:42:18
2025-11-01 21:46:23,629 main [ INFO]:
2025-11-01 21:46:23,629 main [ INFO]: []
2025-11-01 21:46:23,629 main [ INFO]: --------------------------------
2025-11-01 21:46:23,629 main [ INFO]: Fwd: Зпт № Зпт-303041 Доставка в Санкт-Петербург (экспресс) Склад: Сальткрока (СПБ) 5-7 дней НЕТ ВПС
2025-11-01 21:46:23,629 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,630 main [ INFO]: 2025-10-27 13:42:23
2025-11-01 21:46:23,630 main [ INFO]:
2025-11-01 21:46:23,630 main [ INFO]: []
2025-11-01 21:46:23,630 main [ INFO]: --------------------------------
2025-11-01 21:46:23,630 main [ INFO]: Fwd: Зпт № Зпт-301326 Доставка в Санкт-Петербург (клиентский) Склад: Сальткрока (СПБ) 2-3 дня
2025-11-01 21:46:23,630 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,630 main [ INFO]: 2025-10-27 13:42:32
2025-11-01 21:46:23,630 main [ INFO]:
2025-11-01 21:46:23,630 main [ INFO]: []
2025-11-01 21:46:23,630 main [ INFO]: --------------------------------
2025-11-01 21:46:23,630 main [ INFO]: Fwd: Зпт № Зпт-302349 Доставка в Санкт-Петербург (экспресс) Склад: Сальткрока (СПБ) 0-1 день
2025-11-01 21:46:23,630 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,630 main [ INFO]: 2025-10-27 13:42:56
2025-11-01 21:46:23,630 main [ INFO]:
2025-11-01 21:46:23,630 main [ INFO]: []
2025-11-01 21:46:23,630 main [ INFO]: --------------------------------
2025-11-01 21:46:23,630 main [ INFO]: Fwd: Зпт № Зпт-301326 Доставка в Санкт-Петербург (клиентский) Склад: Сальткрока (СПБ) 2-3 дня
2025-11-01 21:46:23,630 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,630 main [ INFO]: 2025-10-27 13:43:10
2025-11-01 21:46:23,630 main [ INFO]:
2025-11-01 21:46:23,630 main [ INFO]: []
2025-11-01 21:46:23,630 main [ INFO]: --------------------------------
2025-11-01 21:46:23,630 main [ INFO]: Fwd: Заказ от ООО "Шате-М Плюс" (CD)_Сальткрока_23.09.25_ 9:52:37
2025-11-01 21:46:23,630 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,630 main [ INFO]: 2025-10-27 13:43:35
2025-11-01 21:46:23,630 main [ INFO]:
2025-11-01 21:46:23,630 main [ INFO]: []
2025-11-01 21:46:23,630 main [ INFO]: --------------------------------
2025-11-01 21:46:23,630 main [ INFO]: Fwd: Заказ от ООО ИНТЕРКАР ИНН: 7448229540 !! почта для ответов zakaz.autoliga174@mail.ru !!!
2025-11-01 21:46:23,630 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,630 main [ INFO]: 2025-10-27 13:43:43
2025-11-01 21:46:23,631 main [ INFO]:
2025-11-01 21:46:23,631 main [ INFO]: []
2025-11-01 21:46:23,631 main [ INFO]: --------------------------------
2025-11-01 21:46:23,631 main [ INFO]: Fwd: Autostels - САЛЬТКРОКА-СПБ - Заказ 271 от 27.10.2025 13:10.
2025-11-01 21:46:23,631 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,631 main [ INFO]: 2025-10-27 13:43:50
2025-11-01 21:46:23,631 main [ INFO]:
2025-11-01 21:46:23,631 main [ INFO]: []
2025-11-01 21:46:23,631 main [ INFO]: --------------------------------
2025-11-01 21:46:23,631 main [ INFO]: Fwd: Autostels - САЛЬТКРОКА_2Д_МСК - Заказ 230 от 27.10.2025 12:20.
2025-11-01 21:46:23,631 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,631 main [ INFO]: 2025-10-27 13:43:55
2025-11-01 21:46:23,631 main [ INFO]:
2025-11-01 21:46:23,631 main [ INFO]: []
2025-11-01 21:46:23,631 main [ INFO]: --------------------------------
2025-11-01 21:46:23,631 main [ INFO]: Fwd: Заказ(ы) Аврора -> Запчастия #235506458#
2025-11-01 21:46:23,631 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,631 main [ INFO]: 2025-10-27 13:44:02
2025-11-01 21:46:23,631 main [ INFO]:
2025-11-01 21:46:23,631 main [ INFO]: []
2025-11-01 21:46:23,631 main [ INFO]: --------------------------------
2025-11-01 21:46:23,631 main [ INFO]: Fwd: Заказ от АО "Автоформула" №А-251022-02437 от 22.10.2025 поставщику ООО "Сальткрока"
2025-11-01 21:46:23,631 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,631 main [ INFO]: 2025-10-27 13:44:09
2025-11-01 21:46:23,631 main [ INFO]:
2025-11-01 21:46:23,631 main [ INFO]: []
2025-11-01 21:46:23,631 main [ INFO]: --------------------------------
2025-11-01 21:46:23,631 main [ INFO]: Fwd: Заказ от E-tape.ru Якорная д. 9А ИП ЮН Станислав Власович
2025-11-01 21:46:23,631 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,631 main [ INFO]: 2025-10-27 13:44:16
2025-11-01 21:46:23,631 main [ INFO]:
2025-11-01 21:46:23,631 main [ INFO]: []
2025-11-01 21:46:23,631 main [ INFO]: --------------------------------
2025-11-01 21:46:23,631 main [ INFO]: Fwd: Заказ со склада ABSTD MSK 966
2025-11-01 21:46:23,631 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,631 main [ INFO]: 2025-10-27 13:44:23
2025-11-01 21:46:23,631 main [ INFO]:
2025-11-01 21:46:23,631 main [ INFO]: []
2025-11-01 21:46:23,631 main [ INFO]: --------------------------------
2025-11-01 21:46:23,631 main [ INFO]: Fwd: Заказ № 5107682 от 21-10-2025
2025-11-01 21:46:23,631 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,632 main [ INFO]: 2025-10-27 13:44:29
2025-11-01 21:46:23,632 main [ INFO]:
2025-11-01 21:46:23,632 main [ INFO]: []
2025-11-01 21:46:23,632 main [ INFO]: --------------------------------
2025-11-01 21:46:23,632 main [ INFO]: Fwd: Заказ от ООО "Рай Авто СПб"
2025-11-01 21:46:23,632 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,632 main [ INFO]: 2025-10-27 13:44:37
2025-11-01 21:46:23,632 main [ INFO]:
2025-11-01 21:46:23,632 main [ INFO]: []
2025-11-01 21:46:23,632 main [ INFO]: --------------------------------
2025-11-01 21:46:23,632 main [ INFO]: Fwd: Заказ ООО "МЕХАНИКА" - поставщик ООО "Сальткрока" ( подтвердите обратным письмом) codeStock:1797936 Заказ поставщику ST000985485/24.10.2025
2025-11-01 21:46:23,632 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:46:23,632 main [ INFO]: 2025-10-27 13:44:45
2025-11-01 21:46:23,632 main [ INFO]:
2025-11-01 21:46:23,632 main [ INFO]: []
2025-11-01 21:46:23,632 main [ INFO]: --------------------------------
2025-11-01 21:46:46,440 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:46:46,440 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:46:46,442 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:46:46,442 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:47:30,413 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:47:30,413 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:47:30,413 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:47:30,413 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:47:30,414 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:47:30,414 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:47:35,112 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:47:35,112 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:47:35,113 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:47:35,113 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:47:51,834 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:47:51,834 log_manager [ INFO]: Logging configuration applied
2025-11-01 21:47:51,835 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:47:51,835 cfg_manager [ INFO]: Update interval set to 2.0 seconds
2025-11-01 21:47:51,835 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:47:51,835 cfg_manager [ INFO]: Work interval set to 2.0 seconds
2025-11-01 21:48:06,117 main [ INFO]: Fwd: Заказ 95 на поставку запчастей Detali.ru
2025-11-01 21:48:06,118 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,118 main [ INFO]: 2025-10-27 13:39:28
2025-11-01 21:48:06,118 main [ INFO]:
2025-11-01 21:48:06,119 main [ INFO]: []
2025-11-01 21:48:06,119 main [ INFO]: --------------------------------
2025-11-01 21:48:06,119 main [ INFO]: Fwd: Заказ поставщику номер 00000056685 (Сальткрока, 000426967) от ООО Нова
2025-11-01 21:48:06,119 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,119 main [ INFO]: 2025-10-27 13:39:36
2025-11-01 21:48:06,120 main [ INFO]:
2025-11-01 21:48:06,120 main [ INFO]: []
2025-11-01 21:48:06,120 main [ INFO]: --------------------------------
2025-11-01 21:48:06,120 main [ INFO]: Fwd: Заказ 00УТ-011202 ЦС 2
2025-11-01 21:48:06,120 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,120 main [ INFO]: 2025-10-27 13:39:42
2025-11-01 21:48:06,120 main [ INFO]:
2025-11-01 21:48:06,120 main [ INFO]: []
2025-11-01 21:48:06,121 main [ INFO]: --------------------------------
2025-11-01 21:48:06,121 main [ INFO]: Fwd: Заказ 00УТ-010792 Наличие
2025-11-01 21:48:06,121 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,121 main [ INFO]: 2025-10-27 13:39:50
2025-11-01 21:48:06,121 main [ INFO]:
2025-11-01 21:48:06,121 main [ INFO]: []
2025-11-01 21:48:06,121 main [ INFO]: --------------------------------
2025-11-01 21:48:06,122 main [ INFO]: Fwd: Заказ поставщику Партерра Сальткрока СПБ на Санкт-Петербург ЦКД
2025-11-01 21:48:06,122 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,122 main [ INFO]: 2025-10-27 13:40:05
2025-11-01 21:48:06,122 main [ INFO]:
2025-11-01 21:48:06,122 main [ INFO]: []
2025-11-01 21:48:06,122 main [ INFO]: --------------------------------
2025-11-01 21:48:06,122 main [ INFO]: Fwd: Заказ поставщику Партерра Сальткрока СПБ 1Д на Санкт-Петербург ЦКД
2025-11-01 21:48:06,122 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,122 main [ INFO]: 2025-10-27 13:40:10
2025-11-01 21:48:06,122 main [ INFO]:
2025-11-01 21:48:06,123 main [ INFO]: []
2025-11-01 21:48:06,123 main [ INFO]: --------------------------------
2025-11-01 21:48:06,123 main [ INFO]: Fwd: FAOrderSPB_56151479_2025-04-02-10-04-25.xlsx
2025-11-01 21:48:06,123 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,123 main [ INFO]: 2025-10-27 13:40:21
2025-11-01 21:48:06,123 main [ INFO]:
2025-11-01 21:48:06,124 main [ INFO]: []
2025-11-01 21:48:06,124 main [ INFO]: --------------------------------
2025-11-01 21:48:06,124 main [ INFO]: Fwd: Заказ компании АвтоСпутник (Автоспутник Санкт-Петербург) № 2087185 от 24.10.2025 склад Наличие
2025-11-01 21:48:06,124 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,124 main [ INFO]: 2025-10-27 13:40:28
2025-11-01 21:48:06,124 main [ INFO]:
2025-11-01 21:48:06,124 main [ INFO]: []
2025-11-01 21:48:06,124 main [ INFO]: --------------------------------
2025-11-01 21:48:06,124 main [ INFO]: Fwd: Заказ компании АвтоСпутник (Автоспутник Санкт-Петербург) № 2085697 от 23.10.2025 склад ЦС 5 дней
2025-11-01 21:48:06,124 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,125 main [ INFO]: 2025-10-27 13:40:32
2025-11-01 21:48:06,125 main [ INFO]:
2025-11-01 21:48:06,125 main [ INFO]: []
2025-11-01 21:48:06,125 main [ INFO]: --------------------------------
2025-11-01 21:48:06,125 main [ INFO]: Fwd: заказ Юником Санкт-Петербург Заказ СПФ00000007980
2025-11-01 21:48:06,125 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,125 main [ INFO]: 2025-10-27 13:40:40
2025-11-01 21:48:06,125 main [ INFO]:
2025-11-01 21:48:06,125 main [ INFO]: []
2025-11-01 21:48:06,125 main [ INFO]: --------------------------------
2025-11-01 21:48:06,126 main [ INFO]: Fwd: заказ Юником Санкт-Петербург Заказ СПФ00000007928
2025-11-01 21:48:06,126 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,126 main [ INFO]: 2025-10-27 13:41:46
2025-11-01 21:48:06,126 main [ INFO]:
2025-11-01 21:48:06,126 main [ INFO]: []
2025-11-01 21:48:06,126 main [ INFO]: --------------------------------
2025-11-01 21:48:06,126 main [ INFO]: Fwd: Заказ ООО Амтел Санкт-Петербург от 27.10.2025
2025-11-01 21:48:06,126 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,126 main [ INFO]: 2025-10-27 13:41:54
2025-11-01 21:48:06,126 main [ INFO]:
2025-11-01 21:48:06,127 main [ INFO]: []
2025-11-01 21:48:06,127 main [ INFO]: --------------------------------
2025-11-01 21:48:06,127 main [ INFO]: Fwd: Заказ «Сальткрока» от Sigma №686120 на сумму 151434.12 руб !
2025-11-01 21:48:06,127 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,127 main [ INFO]: 2025-10-27 13:42:03
2025-11-01 21:48:06,127 main [ INFO]:
2025-11-01 21:48:06,127 main [ INFO]: []
2025-11-01 21:48:06,127 main [ INFO]: --------------------------------
2025-11-01 21:48:06,127 main [ INFO]: Fwd: Зпт № Зпт-303384 Доставка в Санкт-Петербург (клиентский) Склад: Сальткрока (СПБ) 0-1 день
2025-11-01 21:48:06,127 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,127 main [ INFO]: 2025-10-27 13:42:13
2025-11-01 21:48:06,128 main [ INFO]:
2025-11-01 21:48:06,128 main [ INFO]: []
2025-11-01 21:48:06,128 main [ INFO]: --------------------------------
2025-11-01 21:48:06,128 main [ INFO]: Fwd: Зпт № Зпт-303044 Доставка в Санкт-Петербург (экспресс) Склад: Сальткрока (СПБ) 2-3 дня
2025-11-01 21:48:06,128 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,128 main [ INFO]: 2025-10-27 13:42:18
2025-11-01 21:48:06,128 main [ INFO]:
2025-11-01 21:48:06,128 main [ INFO]: []
2025-11-01 21:48:06,128 main [ INFO]: --------------------------------
2025-11-01 21:48:06,128 main [ INFO]: Fwd: Зпт № Зпт-303041 Доставка в Санкт-Петербург (экспресс) Склад: Сальткрока (СПБ) 5-7 дней НЕТ ВПС
2025-11-01 21:48:06,128 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,128 main [ INFO]: 2025-10-27 13:42:23
2025-11-01 21:48:06,128 main [ INFO]:
2025-11-01 21:48:06,128 main [ INFO]: []
2025-11-01 21:48:06,129 main [ INFO]: --------------------------------
2025-11-01 21:48:06,129 main [ INFO]: Fwd: Зпт № Зпт-301326 Доставка в Санкт-Петербург (клиентский) Склад: Сальткрока (СПБ) 2-3 дня
2025-11-01 21:48:06,129 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,129 main [ INFO]: 2025-10-27 13:42:32
2025-11-01 21:48:06,129 main [ INFO]:
2025-11-01 21:48:06,129 main [ INFO]: []
2025-11-01 21:48:06,129 main [ INFO]: --------------------------------
2025-11-01 21:48:06,129 main [ INFO]: Fwd: Зпт № Зпт-302349 Доставка в Санкт-Петербург (экспресс) Склад: Сальткрока (СПБ) 0-1 день
2025-11-01 21:48:06,129 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,129 main [ INFO]: 2025-10-27 13:42:56
2025-11-01 21:48:06,129 main [ INFO]:
2025-11-01 21:48:06,130 main [ INFO]: []
2025-11-01 21:48:06,130 main [ INFO]: --------------------------------
2025-11-01 21:48:06,130 main [ INFO]: Fwd: Зпт № Зпт-301326 Доставка в Санкт-Петербург (клиентский) Склад: Сальткрока (СПБ) 2-3 дня
2025-11-01 21:48:06,130 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,130 main [ INFO]: 2025-10-27 13:43:10
2025-11-01 21:48:06,130 main [ INFO]:
2025-11-01 21:48:06,130 main [ INFO]: []
2025-11-01 21:48:06,130 main [ INFO]: --------------------------------
2025-11-01 21:48:06,130 main [ INFO]: Fwd: Заказ от ООО "Шате-М Плюс" (CD)_Сальткрока_23.09.25_ 9:52:37
2025-11-01 21:48:06,130 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,130 main [ INFO]: 2025-10-27 13:43:35
2025-11-01 21:48:06,130 main [ INFO]:
2025-11-01 21:48:06,130 main [ INFO]: []
2025-11-01 21:48:06,131 main [ INFO]: --------------------------------
2025-11-01 21:48:06,131 main [ INFO]: Fwd: Заказ от ООО ИНТЕРКАР ИНН: 7448229540 !! почта для ответов zakaz.autoliga174@mail.ru !!!
2025-11-01 21:48:06,131 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,131 main [ INFO]: 2025-10-27 13:43:43
2025-11-01 21:48:06,131 main [ INFO]:
2025-11-01 21:48:06,131 main [ INFO]: []
2025-11-01 21:48:06,131 main [ INFO]: --------------------------------
2025-11-01 21:48:06,131 main [ INFO]: Fwd: Autostels - САЛЬТКРОКА-СПБ - Заказ 271 от 27.10.2025 13:10.
2025-11-01 21:48:06,131 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,131 main [ INFO]: 2025-10-27 13:43:50
2025-11-01 21:48:06,131 main [ INFO]:
2025-11-01 21:48:06,131 main [ INFO]: []
2025-11-01 21:48:06,132 main [ INFO]: --------------------------------
2025-11-01 21:48:06,132 main [ INFO]: Fwd: Autostels - САЛЬТКРОКА_2Д_МСК - Заказ 230 от 27.10.2025 12:20.
2025-11-01 21:48:06,132 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,132 main [ INFO]: 2025-10-27 13:43:55
2025-11-01 21:48:06,132 main [ INFO]:
2025-11-01 21:48:06,132 main [ INFO]: []
2025-11-01 21:48:06,132 main [ INFO]: --------------------------------
2025-11-01 21:48:06,132 main [ INFO]: Fwd: Заказ(ы) Аврора -> Запчастия #235506458#
2025-11-01 21:48:06,132 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,132 main [ INFO]: 2025-10-27 13:44:02
2025-11-01 21:48:06,132 main [ INFO]:
2025-11-01 21:48:06,132 main [ INFO]: []
2025-11-01 21:48:06,132 main [ INFO]: --------------------------------
2025-11-01 21:48:06,132 main [ INFO]: Fwd: Заказ от АО "Автоформула" №А-251022-02437 от 22.10.2025 поставщику ООО "Сальткрока"
2025-11-01 21:48:06,132 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,132 main [ INFO]: 2025-10-27 13:44:09
2025-11-01 21:48:06,132 main [ INFO]:
2025-11-01 21:48:06,133 main [ INFO]: []
2025-11-01 21:48:06,133 main [ INFO]: --------------------------------
2025-11-01 21:48:06,133 main [ INFO]: Fwd: Заказ от E-tape.ru Якорная д. 9А ИП ЮН Станислав Власович
2025-11-01 21:48:06,133 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,133 main [ INFO]: 2025-10-27 13:44:16
2025-11-01 21:48:06,133 main [ INFO]:
2025-11-01 21:48:06,133 main [ INFO]: []
2025-11-01 21:48:06,133 main [ INFO]: --------------------------------
2025-11-01 21:48:06,133 main [ INFO]: Fwd: Заказ со склада ABSTD MSK 966
2025-11-01 21:48:06,133 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,133 main [ INFO]: 2025-10-27 13:44:23
2025-11-01 21:48:06,133 main [ INFO]:
2025-11-01 21:48:06,133 main [ INFO]: []
2025-11-01 21:48:06,133 main [ INFO]: --------------------------------
2025-11-01 21:48:06,133 main [ INFO]: Fwd: Заказ № 5107682 от 21-10-2025
2025-11-01 21:48:06,133 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,133 main [ INFO]: 2025-10-27 13:44:29
2025-11-01 21:48:06,134 main [ INFO]:
2025-11-01 21:48:06,134 main [ INFO]: []
2025-11-01 21:48:06,134 main [ INFO]: --------------------------------
2025-11-01 21:48:06,134 main [ INFO]: Fwd: Заказ от ООО "Рай Авто СПб"
2025-11-01 21:48:06,134 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,134 main [ INFO]: 2025-10-27 13:44:37
2025-11-01 21:48:06,134 main [ INFO]:
2025-11-01 21:48:06,134 main [ INFO]: []
2025-11-01 21:48:06,134 main [ INFO]: --------------------------------
2025-11-01 21:48:06,134 main [ INFO]: Fwd: Заказ ООО "МЕХАНИКА" - поставщик ООО "Сальткрока" ( подтвердите обратным письмом) codeStock:1797936 Заказ поставщику ST000985485/24.10.2025
2025-11-01 21:48:06,134 main [ INFO]: Отдел Продаж <sale@zapchastiya.ru>
2025-11-01 21:48:06,134 main [ INFO]: 2025-10-27 13:44:45
2025-11-01 21:48:06,134 main [ INFO]:
2025-11-01 21:48:06,134 main [ INFO]: []
2025-11-01 21:48:06,134 main [ INFO]: --------------------------------
2025-11-01 21:55:49,251 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:55:49,251 cfg_manager [ INFO]: ConfigManager tasks cancelled
2025-11-01 21:55:49,252 cfg_manager [ INFO]: ConfigManager stopped
2025-11-01 21:55:49,252 cfg_manager [ INFO]: ConfigManager stopped

View File

@@ -7,35 +7,49 @@ import os
from dotenv import load_dotenv
from email_client import EmailClient
from email_processor import EmailProcessor
from context import Context
logger = logging.getLogger()
class MailOrderBot(ConfigManager):
def __init__(self, *agrs, **kwargs):
super().__init__(*agrs, **kwargs)
# Объявить почтового клиента
self.email_client = EmailClient(
imap_host=os.getenv('IMAP_HOST'),
smtp_host=os.getenv('SMTP_HOST'),
email=os.getenv('EMAIL_USER'),
password=os.getenv('EMAIL_PASSWORD'),
imap_port=os.getenv('IMAP_PORT'),
smtp_port=os.getenv('SMTP_PORT')
imap_port=int(os.getenv('IMAP_PORT', default="993")),
smtp_port=int(os.getenv('SMTP_PORT', default="587")),
)
# Сохранить почтовый клиент в контекст
self.context = Context()
self.context.email_client = self.email_client
# Обработчик писем
self.email_processor = EmailProcessor()
def execute(self):
logger.debug(f"Check emails for new orders")
emails = self.email_client.get_emails(folder="spareparts", only_unseen=True, mark_as_read=True)
for email in emails:
logger.info(email.subj)
logger.info(email.from_addr)
logger.info(email.dt)
logger.info(email.body)
logger.info(email.first_sender)
logger.info('--------------------------------')
# Получить список айдишников письма
unread_email_ids = self.email_client.get_emails_id(folder="spareparts")
logger.info(f"Новых писем - {len(unread_email_ids)}")
# Обработать каждое письмо по идентификатору
for email_id in unread_email_ids:
logger.debug(f"Обработка письма с идентификатором {email_id}")
# Получить письмо по идентификатору и запустить его обработку
email = self.email_client.get_email(email_id)
self.email_processor.process_email(email)
logger = logging.getLogger()

View File

@@ -0,0 +1,22 @@
import os
from dotenv import load_dotenv
from mail_order_bot.abcp_api.abcp_provider import AbcpProvider
from mail_order_bot.email_processor.order.auto_part_order import AutoPartOrder
from mail_order_bot.email_processor.order.auto_part_position import AutoPartPosition
if __name__ == "__main__":
print(__name__)# подгружаем переменные окружения
load_dotenv()
order = AutoPartOrder()
position = AutoPartPosition(sku="560300054", manufacturer="VST", requested_quantity=1)
order.add_position(position)
provider = AbcpProvider()
provider.get_stock(order)
print(order.positions[0].stock)
print(os.getenv('ABCP_LOGIN'))

View File

@@ -4,6 +4,7 @@ from mail_order_bot.email_client import EmailClient
if __name__ == "__main__":
print(__name__)
# подгружаем переменные окружения
load_dotenv()
@@ -15,14 +16,14 @@ if __name__ == "__main__":
imap_port=os.getenv('IMAP_PORT'),
smtp_port=os.getenv('SMTP_PORT')
)
emails = email_client.get_emails(folder='spareparts', only_unseen=True, mark_as_read=True)
emails = email_client.get_emails(folder='spareparts', only_unseen=True, mark_as_read=False)
for email in emails:
print(email.subj)
print(email.from_addr)
print(email.from_email)
print(email.dt)
print(email.body)
print(email.first_sender)
print('--------------------------------')
email_client.close()
email_client.disconnect()

View File

@@ -0,0 +1,42 @@
# Конфигурационный файл для контрагента mikado-parts.ru
pipeline:
# Обработчик вложений - извлекает из экселя данные
- handler: BasicExcelParser
config:
sheet_name: 0 # Можно указать индекс листа
key_field: "артикул" # Поле, по которому будет определяться заголовок блока с данными и будут отсекаться незаполненные строки
mapping:
article: "артикул"
manufacturer: "бренд"
name: "наименование"
price: "цена"
quantity: "количество"
# Обработчик получает данные со склада о цене и остатках по каждой позиций
- handler: GetStock
config:
max_stock: 2
min_stock: 0
# Обработчик проверяет заказ на возможность автоматической обработки
- handler: CheckOrder
config:
acceptable_price_reduction: 2
refusal_threshold: 0.1
# Создание заказа
- handler: InstantOrderTest
config:
api_key: "8056899069:AAFEfw9QRMvmEwQyH0CI4e_v_sZuOSdNWcE"
chat_id: 211945135
# Отправка уведомлений менеджерам
#- handler: "TestNotifier"

View File

@@ -0,0 +1,27 @@
# Конфигурационный файл для контрагента todx.ru
pipeline:
# Обработчик вложений
- handler: "BasicExcelParser"
config:
sheet_name: 0
key_field: "Код детали"
mapping:
article: "Код детали"
manufacturer: "Производитель"
name: "Наименование"
price: "Цена\nдетали"
quantity: "Кол-\nво"
total: "Сумма"
- handler: InstantOrderTest
config:
api_key: "8056899069:AAFEfw9QRMvmEwQyH0CI4e_v_sZuOSdNWcE"
chat_id: 211945135
- handler: "TestNotifier"

View File

@@ -0,0 +1,60 @@
import os
import chardet # pip install chardet
import traceback
from mail_order_bot.email_processor import EmailProcessor
import datetime
# установим рабочую директорию
import os
os.chdir(os.path.dirname(os.path.abspath(__file__)))
from io import BytesIO
import logging
logger = logging.getLogger(__name__)
logging.basicConfig(level=logging.WARNING, format='%(module)s - %(message)s') # %(asctime)s -
BASE_PATH = './files'
from mail_order_bot.email_client import EmailMessage, EmailAttachment
processor = EmailProcessor("./configs")
for provider_name in os.listdir(BASE_PATH):
provider_folder = os.path.join(BASE_PATH, provider_name)
if os.path.isdir(provider_folder):
for file_name in os.listdir(provider_folder):
file_path = os.path.join(provider_folder, file_name)
if os.path.isfile(file_path):
with open(file_path, 'rb') as file: # бинарный режим
raw_data = file.read()
# Создаем объект EmailAttachment
att = EmailAttachment(file_name, raw_data)
email = EmailMessage(
message=None,
from_addr=provider_name,
from_email='test@gmail.com',
subj='order request',
dt=datetime.datetime.now(),
body= 'body text',
attachments=[att],
first_sender='test@gmail.com'
)
#bio = BytesIO(raw_data)
print("========================================================")
print(f'Обработка: {provider_name} - {file_name}')
try:
positions_a = processor.process(provider_name, att)
except Exception as e:
print(f"Ошибка обработки: {e}", traceback.format_exc())

View File

@@ -0,0 +1,48 @@
import os
import chardet # pip install chardet
import traceback
from mail_order_bot.excel_parcer import ExcelProcessor
# установим рабочую директорию
import os
os.chdir(os.path.dirname(os.path.abspath(__file__)))
from io import BytesIO
import logging
logger = logging.getLogger(__name__)
logging.basicConfig(level=logging.WARNING, format='%(module)s - %(message)s') #%(asctime)s -
BASE_PATH = './files'
processor = ExcelProcessor("./suppliers.yml")
for provider_name in os.listdir(BASE_PATH):
provider_folder = os.path.join(BASE_PATH, provider_name)
if os.path.isdir(provider_folder):
for file_name in os.listdir(provider_folder):
file_path = os.path.join(provider_folder, file_name)
if os.path.isfile(file_path):
with open(file_path, 'rb') as file: # бинарный режим
raw_data = file.read()
bio = BytesIO(raw_data)
print("========================================================")
print(f'Обработка: {provider_name} - {file_name}')
try:
positions_a = processor.process(
file_bytes=bio,
file_name=file_name,
supplier_name=provider_name
)
print(f"\nПолучено {len(positions_a)} позиций от {provider_name}:")
for pos in positions_a: # Первые 5
print(f" - {pos.article}: {pos.name} "
f"({pos.quantity} x {pos.price} = {pos.total})")
except Exception as e:
print(f"Ошибка обработки: {e}", traceback.format_exc())

View File

@@ -0,0 +1,411 @@
suppliers:
# order@stparts.ru
"order@stparts.ru":
sheet_name: "TDSheet" # Название листа Excel
key_field: "Номер"
# Маппинг: внутреннее_поле -> названиеолонки_в_Excel
mapping:
article: "Номер"
manufacturer: "Бренд"
name: "Описание"
price: "Цена"
quantity: "Количество"
#total: "Сумма"
#Вопросы: что за поле "Фактическая_отгрузка"?
EMPTY-FROM:
sheet_name: 0
key_field: "Артикул" # Заголовки во второй строке
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Название"
price: "Цена"
quantity: "Количество"
#total: "Сумма с НДС"
options:
decimal_separator: ","
encoding: "utf-8"
#thousand_separator: ","
# Примечание: гемор - нет имейла
"order@avtoto.ru":
sheet_name: "Заказы" # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Изготовитель"
name: "Наименование товара"
price: "Цена"
quantity: "Кол-во"
total: "Сумма"
"автолига.рф":
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Название детали"
price: "Цена, р."
quantity: "Количество"
total: "Сумма, р."
abstd.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул поставщика"
mapping:
article: "Артикул поставщика"
manufacturer: "Бренд поставщика"
name: "Наименование"
price: "Цена поставщика"
quantity: "Кол-во"
total: "Сумма"
adeo.pro:
sheet_name: 0 # Можно указать индекс листа
key_field: "Каталожный номер"
mapping:
article: "Каталожный номер"
manufacturer: "Производитель"
name: "Наименование"
price: "Цена"
quantity: "Кол-во"
total: "Сумма"
amtel.club:
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер"
mapping:
article: "Номер"
manufacturer: "Фирма"
name: "Наименование"
price: "Цена"
quantity: "Кол-во"
total: "Сумма"
auto-sputnik.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Наименование"
price: "Цена"
quantity: "Кол-во"
total: "Сумма"
autocode.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Бренд"
name: "Наименование"
price: "Цена"
quantity: "Кол-во"
# Надо ли как-то учитывать доп поля типа Кол-во в отказ?
autopiter.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер"
mapping:
article: "Номер"
manufacturer: "Каталог"
price: "Цена"
quantity: "Кол-во"
autostels.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "№ Детали"
mapping:
article: "№ Детали"
manufacturer: "Производитель"
name: "Наименование"
price: "Прайс"
quantity: "Количество"
total: "Сумма"
avtoformula.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "№ Детали"
mapping:
article: "№ Детали"
manufacturer: "Производитель"
name: "Наименование"
price: "Прайс"
quantity: "Количество"
total: "Сумма"
autoeuro.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер Производителя"
mapping:
article: "Номер Производителя"
manufacturer: "Производитель"
price: "Цена"
quantity: "Количество"
avtogut.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Наименование"
price: "Цена, р."
quantity: "Количество"
total: "Сумма, р."
avtokrep.spb.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Бренд"
name: "Наименование"
price: "Цена"
quantity: "Количество"
avtolavka.net:
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер"
mapping:
article: "Номер"
manufacturer: "Бренд"
name: "Описание"
price: "Цена закупки"
quantity: "Количество"
avtoto.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Название"
price: "Цена (рубли)"
quantity: "Кол-во"
detal.msk.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Наименование"
price: "Цена"
quantity: "Количество"
total: "Сумма"
detali.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Код поставщика"
mapping:
article: "Код поставщика"
manufacturer: "Бренд"
name: "Наименование"
price: "Цена"
quantity: "Количество"
e-tape.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Название детали"
price: "Цена, р."
quantity: "Количество"
total: "Сумма, р."
forum-auto.ru:
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер по каталогу"
mapping:
article: "Номер по каталогу"
manufacturer: "Производитель"
name: "Название детали"
price: "Цена"
quantity: "Количество"
"info_avtor@mail.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Бренд"
name: "Товары (работы, услуги)"
price: "Цена"
quantity: "Количество"
total: "Сумма"
"mikado-parts.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "артикул"
mapping:
article: "артикул"
manufacturer: "бренд"
name: "наименование"
price: "цена"
quantity: "количество"
"multikrep.com":
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Бренд"
name: "Наименование"
price: "Цена"
quantity: "Количество"
"only-original.parts":
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер"
mapping:
article: "Номер"
manufacturer: "Бренд"
name: "Описание"
price: "Цена закупки"
quantity: "Количество"
"part-kom.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Код\nпоставщика"
mapping:
article: "Код\nпоставщика"
manufacturer: "Изготовитель"
name: "Наименование товара"
price: "Цена"
quantity: "Кол-во"
total: "Сумма"
"parterra.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул поставщика"
mapping:
article: "Артикул поставщика"
manufacturer: "Производитель Поставщика"
name: "Номенклатура"
price: "Цена"
quantity: "Количество (в единицах хранения)"
total: "Сумма с НДС"
"pmmobile.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер"
mapping:
article: "Номер"
manufacturer: "Бренд"
name: "Описание"
price: "Цена закупки"
quantity: "Количество"
"rmsauto.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер детали"
mapping:
article: "Номер детали"
manufacturer: "Производитель"
name: "Наименование детали"
price: "Цена, рублей (с НДС)"
quantity: "Количество заказанное, штук"
total: "Сумма, рублей (с НДС)"
"rnsprice.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Марка"
name: "Наименование"
price: "Цена"
quantity: "Кол-во"
total: "Сумма"
"stutzen.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Название детали"
price: "Цена, р."
quantity: "Количество"
total: "Сумма, р."
"sz-snab.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Номер"
mapping:
article: "Номер"
manufacturer: "Бренд"
name: "Описание"
price: "Цена закупки"
quantity: "Количество"
"todx.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Код детали"
mapping:
article: "Код детали"
manufacturer: "Производитель"
name: "Наименование"
price: "Цена\nдетали"
quantity: "Кол-\nво"
total: "Сумма"
"uniqom.ru":
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Брэнд"
name: "Наименование товара"
price: "Цена"
quantity: "Заказ, кол-во"
total: "Сумма"
"Рай Авто СПб":
sheet_name: 0 # Можно указать индекс листа
key_field: "Артикул"
mapping:
article: "Артикул"
manufacturer: "Производитель"
name: "Название"
price: "Цена"
quantity: "Количество"

9
tests/site/auth.py Normal file
View File

@@ -0,0 +1,9 @@
from requests_html import HTMLSession
print(1)
session = HTMLSession()
response = session.get("https://zapchastiya.ru/")
print(2)
response.html.render(wait=2) # Ждем выполнения JS, 2 секунды например
print(3)
print(response.html.html) # Выводим страницу после выполнения JS

1
tests/site/test.html Normal file
View File

@@ -0,0 +1 @@
'<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">\n<html>\n<head>\n<title>Robot Check Redirector</title>\n<meta http-equiv="Cache-Control" content="no-cache">\n<META NAME="ROBOTS" CONTENT="NOINDEX, NOFOLLOW">\n<meta name="Document-state" content="Dynamic">\n<meta name="Resource-type" content="document">\n<meta http-equiv="Content-Type" content="text/html; charset=utf-8">\n<script type="text/javascript">\nfunction checkTheRobot() {\n var myurl = window.location.href.toString();\n var mycheckurl = "https://hcaptcha-antibot.nodacdn.net";\n var myparams = "/?cngx=1&original_url=";\n var newurl = mycheckurl.concat(myparams,myurl);\n setTimeout(function(){ window.location.href = newurl ; } , 5000)\n}\n\n</script>\n<title></title>\n</head>\n<body onload="checkTheRobot();" style="font-family: Arial, Sans-Serif; background:#cef0fa">\n\n<p><br></p>\n<center>\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/file-uploader/3.7.0/processing.gif">&nbsp;\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/lightbox2/2.7.1/img/loading.gif">&nbsp;\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/jquery.lazyloadxt/1.0.5/loading.gif">&nbsp;\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/fancybox/2.1.5/fancybox_loading@2x.gif">&nbsp;\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/jquery-mobile/1.4.1/images/ajax-loader.gif">&nbsp;\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/fancybox/2.1.5/fancybox_loading@2x.gif">&nbsp;\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/jquery.lazyloadxt/1.0.5/loading.gif">&nbsp;\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/lightbox2/2.7.1/img/loading.gif">&nbsp;\n<img border="0" src="https://cdnjs.cloudflare.com/ajax/libs/file-uploader/3.7.0/processing.gif">&nbsp;\n\n<p>You will be redirected to Robot Checker. Please enable Javascript in browser.</p>\n</center>\n</body>\n</html>\n'