no message

src/mail_order_bot/__init__.py

@@ -0,0 +1 @@
+from .main import MailOrderBotException

src/mail_order_bot/abcp_api/abcp_provider.py

@@ -29,7 +29,24 @@ class AbcpProvider:
             path = "/search/articles"
 
             params = {"number": sku, "brand": manufacturer, "withOutAnalogs": "1"}
-            return self._execute(path, method, params)
+
+            status_code, payload = self._execute(path, method, params)
+
+            if status_code == 200:
+                response = {"success": True, "data": payload}
+                logger.debug(f"Получены данные об остатках на складе")
+                return response
+
+            elif status_code == 301:
+                response = {"success": True, "data": []}
+                logger.debug(f"Не найдены позиции по запрошенным параметрам")
+                return response
+
+            else:
+                response = {"success": False, "data": payload}
+                logger.debug(f"Ошибка при получении остатков со склада")
+                return response
+
 
         def _execute(self, path, method="GET", params={}, data=None):
             params["userlogin"] = self.login
@@ -37,18 +54,4 @@ class AbcpProvider:
 
             response = requests.request(method, self.HOST+path, data=data, headers=self.HEADERS, params=params)
             payload = response.json()
-            if response.status_code == 200:
-                logger.debug(f"Получены данные об остатках на складе")
-                result = {
-                    "success": True,
-                    "data": payload
-                }
-            else:
-                logger.warning(f"ошибка получения данных об остатках на складе: {payload}")
-
-                result = {
-                    "success": False,
-                    "error": payload
-                }
-            return result
-
+            return response.status_code, payload

src/mail_order_bot/config.yml

@@ -1,17 +1,22 @@
 # Настройки обработки =================================================================
+folder: "spareparts"
+
 clients:
   lesha.spb@gmail.com:
     enabled: true
     client_id: 6148154    # Сейчас стоит айдишник Димы для тестовых заказов
 
+    refusal_threshold: 0.01
+
     pipeline:
       - ExcelExtractor
-      - OrderExtractor
       - DeliveryPeriodFromConfig
+      - OrderExtractor
       - StockSelector
       - UpdateExcelFile
-      - SaveOrderToTelegram
-      - EmailReplyTask
+      - TelegramNotifier
+      #- EmailReplyTask
+      #- EmailForwardErrorTask
 
     excel:
       sheet_name: 0
@@ -39,7 +44,6 @@ clients:
 update_interval: 1
 work_interval: 60
 email_dir: "spareparts"
-
 # Логирование =================================================================
 log:
   version: 1
@@ -47,7 +51,7 @@ log:
 
   formatters:
     standard:
-      format: '%(asctime)s %(module)15s [%(levelname)8s]: %(message)s'
+      format: '%(asctime)s %(module)18s [%(levelname)8s]: %(message)s'
     telegram:
       format: '%(message)s'
 
@@ -78,15 +82,19 @@ log:
   loggers:
     '':
       handlers: [console, file, telegram]
-      level: DEBUG
+      level: INFO
       propagate: False
 
     __main__:
       handlers: [console, file, telegram]
-      level: INFO
+      level: WARNING
       propagate: False
 
     config_manager:
       handlers: [console, file]
+      level: ERROR
+
+    utils:
+      handlers: [ console, file ]
       level: DEBUG
     

src/mail_order_bot/context.py

@@ -1,3 +1,27 @@
+"""
+Структура контекста
+
+  email        : Электронное письмо в формате EmailObject
+  config       : Конфиг для текущего клиента
+  attachments  : [   Список вложений
+    {
+      name    : Имя файла
+      isOrder : Признак что файл является валидным файлом заказа
+      bytes   : содержимое файла в формате BytesIO
+      deliveryPeriod: Int
+      sheet   : Распарсенный лист в формате ExcelFileParcer
+      order   : Файл заказа в формате AutopartOrder
+      log     : Лог сообщений по обработке файла в формате LogMessage
+    }
+  ]
+  status:
+
+
+
+"""
+
+
+
 import threading
 from typing import Any, Dict
 import logging

src/mail_order_bot/deprecated/old_excel_parcer/__init__.py

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

src/mail_order_bot/deprecated/old_excel_parcer/configurable_parser.py

@@ -1,113 +0,0 @@
-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

src/mail_order_bot/deprecated/old_excel_parcer/custom_parser_autoeuro.py

@@ -1,105 +0,0 @@
-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

src/mail_order_bot/deprecated/old_excel_parcer/excel_parser.py

@@ -1,28 +0,0 @@
-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__)
-
-class ExcelParser(ABC):
-    """
-    Абстрактный базовый класс для всех парсеров Excel.
-    Реализует Strategy Pattern - каждый контрагент = своя стратегия.
-    """
-    
-    def __init__(self, config: Dict[str, Any]):
-        self.config = config
-    
-    @abstractmethod
-    def parse(self, file: BytesIO) -> List[OrderPosition]:
-        """
-        Парсит Excel файл и возвращает список позиций.
-        Должен быть реализован в каждом конкретном парсере.
-        """
-        pass

src/mail_order_bot/deprecated/old_excel_parcer/order_position.py

@@ -1,24 +0,0 @@
-from dataclasses import dataclass, field
-from typing import Dict, Any
-from decimal import Decimal
-
-@dataclass
-class OrderPosition:
-    """
-    Унифицированная модель позиции для заказа.
-    Все контрагенты приводятся к этой структуре.
-    """
-    article: str                    # Артикул товара
-    manufacturer: str               # Производитель
-    name: str                       # Наименование
-    price: Decimal                  # Цена за единицу
-    quantity: int                   # Количество
-    total: Decimal                  # Общая сумма
-    additional_attrs: Dict[str, Any] = field(default_factory=dict)
-    
-    def __post_init__(self):
-        """Валидация после инициализации"""
-        if self.quantity < 0:
-            raise ValueError(f"Количество не может быть отрицательным: {self.quantity}")
-        if self.price < 0:
-            raise ValueError(f"Цена не может быть отрицательной: {self.price}")

src/mail_order_bot/deprecated/old_excel_parcer/parser_factory.py

@@ -1,54 +0,0 @@
-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:
-    """
-    Фабрика парсеров (Factory Pattern).
-    Создает нужный парсер на основе названия контрагента.
-    """
-    
-    # Реестр кастомных парсеров
-    CUSTOM_PARSERS = {
-        'autoeuro.ru': CustomExcelParserAutoeuro,
-        # Добавляйте сюда специализированные парсеры
-    }
-    
-    def __init__(self, config: Dict[str, Any]):
-        self.config = config
-
-    def get_parser(self, supplier_name: str) -> ExcelParser:
-        """
-        Возвращает парсер для указанного контрагента.
-        Использует кастомный парсер если есть, иначе конфигурируемый.
-        """
-        if supplier_name not in self.config['suppliers']:
-            raise ValueError(
-                f"Контрагент '{supplier_name}' не найден в конфигурации. "
-                f"Доступные: {list(self.config['suppliers'].keys())}"
-            )
-        
-        config = self.config['suppliers'][supplier_name]
-        
-        # Проверяем, есть ли кастомный парсер
-        if supplier_name in self.CUSTOM_PARSERS:
-            parser_class = self.CUSTOM_PARSERS[supplier_name]
-            logger.debug(f"Используется кастомный парсер для {supplier_name}")
-        else:
-            parser_class = ConfigurableExcelParser
-            logger.debug(f"Используется конфигурируемый парсер для {supplier_name}")
-        
-        return parser_class(config)
-    
-    def list_suppliers(self) -> List[str]:
-        """Возвращает список всех доступных контрагентов"""
-        return list(self.config['suppliers'].keys())

src/mail_order_bot/deprecated/old_excel_parcer/processor.py

@@ -1,110 +0,0 @@
-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.config_path = Path(config_path)
-        self.config = self._load_config()
-        self.factory = ParserFactory(self.config)
-
-    def process(self, file_bytes: BytesIO, file_name: str, supplier_name: str, validate: bool = False) -> List[OrderPosition]:
-        """
-        Обрабатывает Excel файл от контрагента.
-
-        Args:
-            file_bytes: Байты файла
-            file_name: Имя файла
-            supplier_name: Название контрагента (из конфигурации)
-            validate: Выполнять ли дополнительную валидацию
-
-        Returns:
-            Список объектов OrderPosition
-
-        Raises:
-            ValueError: Если контрагент не найден
-        """
-        logger.info(f"Обработка файла: {file_name} для {supplier_name}")
-
-        parser = self.factory.get_parser(supplier_name)
-        positions = parser.parse(file_bytes)
-
-        # Дополнительная валидация если нужна
-        if validate:
-            positions = self._validate_positions(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 = []
-        
-        for pos in positions:
-            try:
-                # Проверка на непустые обязательные поля
-                if not pos.article or not pos.name:
-                    logger.warning(f"Пропущена позиция с пустыми полями: {pos}")
-                    continue
-                
-                # Проверка корректности суммы
-                expected_total = pos.price * pos.quantity
-                if abs(pos.total - expected_total) > Decimal('0.01'):
-                    logger.warning(
-                        f"Несоответствие суммы для {pos.article}: "
-                        f"ожидается {expected_total}, получено {pos.total}"
-                    )
-                
-                valid_positions.append(pos)
-                
-            except Exception as e:
-                logger.error(f"Ошибка валидации позиции: {e}")
-                continue
-        
-        return valid_positions
-    
-    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}")

src/mail_order_bot/email_client/client.py

@@ -14,12 +14,16 @@ import smtplib
 
 import logging
 
+
+
+
 logger = logging.getLogger(__name__)
 
 
 # from .objects import EmailMessage, EmailAttachment
 
 
+
 class EmailClient:
     def __init__(self, imap_host: str, smtp_host: str, email: str, password: str,
                  imap_port: int = 993, smtp_port: int = 587):
@@ -32,7 +36,7 @@ class EmailClient:
         self.imap_conn = None
 
     def connect(self):
-        """Установkение IMAP соединения"""
+        """Установление 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)
@@ -58,18 +62,27 @@ class EmailClient:
 
     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)
+        try:
+            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()
+
+        except Exception as e:
+            logger.error(e)
+            raise
+        else:
+            return email_ids
+
 
-        # ToDo сделать обработку ошибок, подумать нужна ли она!
-        if status != "OK":
-            return []
 
-        email_ids = messages[0].split()
-        return email_ids
 
     def get_email(self, email_id, mark_as_read: bool = True):
         """Получить список новых электронных писем."""

src/mail_order_bot/email_client/utils.py

@@ -23,9 +23,9 @@ class EmailUtils:
     @staticmethod
     def extract_email(text) -> str:
         match = re.search(r'<([^<>]+)>', text)
-        if match:
-            return match.group(1)
-        return None
+        email = match.group(1) if match else None
+        logger.debug(f"Extracted email: {email}")
+        return email
 
     @staticmethod
     def extract_body(msg: email.message.Message) -> str:
@@ -53,7 +53,7 @@ class EmailUtils:
                     body = payload.decode(charset, errors='ignore')
             except Exception:
                 pass
-
+        logger.debug(f"Extracted body: {body}")
         return body
 
     @staticmethod
@@ -78,12 +78,14 @@ class EmailUtils:
                 filename = part.get_filename()
                 if filename:
                     # Декодируем имя файла
-                    filename = decode_header(filename)[0]
+                    filename = decode_header(filename)[0][0]
                     # Получаем содержимое
                     content = part.get_payload(decode=True)
                     if content:
                         #attachments.append(EmailAttachment(filename=filename, content=content))
                         attachments.append({"name": filename, "bytes": content})
+                        logger.debug(f"Extracted attachment {filename}")
+        logger.debug(f"Extracted attachments: {len(attachments)}")
 
         return attachments
 

src/mail_order_bot/main.py

@@ -7,6 +7,7 @@ import os
 from dotenv import load_dotenv
 
 from email_client import EmailClient
+from mail_order_bot.task_processor.abstract_task import AbstractTask
 from task_processor import TaskProcessor
 
 from mail_order_bot.context import Context
@@ -14,11 +15,15 @@ from mail_order_bot.context import Context
 
 logger = logging.getLogger()
 
+class MailOrderBotException(Exception):
+    pass
 
 class MailOrderBot(ConfigManager):
     def __init__(self, *agrs, **kwargs):
         super().__init__(*agrs, **kwargs)
 
+        self.context = Context()
+
         # Объявить почтового клиента
         self.email_client = EmailClient(
             imap_host=os.getenv('IMAP_HOST'),
@@ -30,38 +35,48 @@ class MailOrderBot(ConfigManager):
         )
 
         # Сохранить почтовый клиент в контекст
-        self.context = Context()
         self.context.email_client = self.email_client
-
-
-        # Обработчик писем
-        #self.email_processor = TaskProcessor("./configs")
-        config = self.config.get("clients")
-        self.email_processor = TaskProcessor(config)
+        self.email_processor = None
         logger.warning("MailOrderBot инициализирован")
 
 
-
-
     def execute(self):
-        # Получить список айдишников письма
+        #Получить список айдишников письма
+        email_folder = self.config.get("folder")
+        try:
+            unread_email_ids = self.email_client.get_emails_id(folder=email_folder)
+            logger.warning(f"Новых писем - {len(unread_email_ids)}")
 
-        logger.critical("Запуск приложения critical !!!!!!!!")
-        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:
+                try:
+                    logger.info(f"Обработка письма с идентификатором {email_id}")
+                    # Получить письмо по идентификатору и запустить его обработку
+                    email = self.email_client.get_email(email_id, mark_as_read=False)
+
+                    # Подтягиваем обновленный конфиг
+                    self.email_processor = TaskProcessor(self.config.get("clients"))
+                    self.email_processor.process_email(email)
+
+                except MailOrderBotException as e:
+                    logger.critical(f"Не получилось обработать письмо {e}")
+                    continue
+
+        except MailOrderBotException as e:
+            logger.critical(f"Произошла ошибка в основном цикле {e}")
+
+        except Exception as e:
+            logger.critical(f"Произошла непредвиденная ошибка в основном цикле: {e}")
+            raise Exception from e
+
+        logger.warning("Обработка писем завершена")
 
-        # Обработать каждое письмо по идентификатору
-        for email_id in unread_email_ids:
-            logger.debug(f"==================================================")
-            logger.debug(f"Обработка письма с идентификатором {email_id}")
-            # Получить письмо по идентификатору и запустить его обработку
-            email = self.email_client.get_email(email_id, mark_as_read=False)
-            self.email_processor.process_email(email)
 
 
 logger = logging.getLogger()
 
 async def main():
+    logger.critical("Запуск приложения")
     app = MailOrderBot("config.yml")
     await app.start()
 

src/mail_order_bot/order/auto_part_order.py

@@ -1,4 +1,8 @@
 from typing import List, Optional
+from decimal import Decimal
+
+from openpyxl.pivot.fields import Boolean
+
 from .auto_part_position import AutoPartPosition, PositionStatus
 
 from enum import Enum
@@ -36,18 +40,33 @@ class AutoPartOrder:
     def set_delivery_period(self, delivery_period: int) -> None:
         self.delivery_period = delivery_period
 
-    def check_order(self, config) -> None:
+    def get_refusal_level(self) -> float:
         """ Проверяет заказ на возможность исполнения"""
         # 1. Проверка общего количества отказов
-        order_refusal_threshold = config.get("order_refusal_threshold", 1)
-        refusal_positions_count = len([position for position in self.positions if str(position.status) in
-                                       [PositionStatus.REFUSED, PositionStatus.STOCK_FAILED]])
-
-        order_refusal_rate = refusal_positions_count / len(self.positions)
-        if order_refusal_rate > order_refusal_threshold:
-            self.errors.append(f"Превышен порог отказов в заказе - {order_refusal_rate:.0%} "
-                               f"({refusal_positions_count} из {len(self.positions)})")
-            self.status = OrderStatus.OPERATOR_REQUIRED
+        refusal_positions_count = len([position for position in self.positions if position.status != PositionStatus.READY])
+        order_refusal_rate = float(refusal_positions_count) / len(self.positions)
+        return order_refusal_rate
 
     def __len__(self):
         return len(self.positions)
+
+    def get_order_description(self):
+
+        message = f"Срок доставки: {self.delivery_period} (в часах)\n\n"
+        message += f"Позиции в заказе:\n"
+
+        for position in self.positions:
+            message += f"{position.manufacturer}, {position.name} [{position.sku}] \n"
+            message += f"{position.asking_quantity} шт. x {position.asking_price:.2f} р. = {position.total:.2f} "
+
+            rejected = position.asking_quantity - position.order_quantity
+            if position.order_quantity == 0:
+                message += f" - отказ\n"
+            elif rejected:
+                message += f" - отгружено частично {position.order_quantity}\n" #, (запрошено, {position.asking_quantity}, отказ: {rejected})\n"
+                message += f"Профит {position.profit:.1%}\n"
+            else:
+                message += f" - отгружено\n"
+                message += f"Профит {position.profit:.1%} (закупка: {Decimal(position.order_item.get("price")):.2f})\n"
+            message += "\n"
+        return message

src/mail_order_bot/order/auto_part_position.py

@@ -2,10 +2,10 @@ from typing import List, Optional
 from dataclasses import dataclass, field
 from typing import Dict, Any
 from decimal import Decimal
-from enum import Enum
+from enum import StrEnum
 
 
-class PositionStatus(Enum):
+class PositionStatus(StrEnum):
     NEW = "new"  # Новая позиция
     STOCK_RECIEVED = "stock_received"  # Получен остаток
     STOCK_FAILED = "stock_failed"  # Остаток не получен
@@ -63,8 +63,9 @@ class AutoPartPosition:
         # Устанавливаем актуальный срок доставки
         self.order_delivery_period = self.order_item.get("deliveryPeriod")
 
-        # ФИксируем профит. Для инфо/отчетности
-        self.profit = (self.asking_price - Decimal(self.order_item.get("price"))) * self.order_quantity
+        # Фиксируем профит. Для инфо/отчетности
+        buy_price = Decimal(self.order_item.get("price"))
+        self.profit = (self.asking_price - buy_price)/buy_price * self.order_quantity
 
         # Устанавливаем статус
         self.status = PositionStatus.READY

src/mail_order_bot/parsers/excel_parcer.py

@@ -14,11 +14,7 @@ class ExcelFileParcer:
 
     def _parse_file(self, file_bytes):
         """Парсит вложение в формате эл таблиц"""
-        try:
-            df = pd.read_excel(file_bytes, sheet_name=self.sheet_name, header=None)
-        except Exception as e:
-            df = None
-            logger.warning("Не удалось распарсить значение файла")
+        df = pd.read_excel(file_bytes, sheet_name=self.sheet_name, header=None)
         return df
 
     def set_value(self, sku, manufacturer, column, value):

src/mail_order_bot/task_processor/__init__.py

@@ -1 +1,9 @@
 from .processor import TaskProcessor
+from .message import LogMessage, LogMessageLevel, LogMessageStorage
+
+from .abstract_task import AbstractTask, pass_if_error, handle_errors
+
+from .attachment_status import AttachmentStatus
+
+from .exceptions import TaskException
+

src/mail_order_bot/task_processor/abstract_task.py

@@ -1,11 +1,61 @@
 from abc import ABC, abstractmethod
-from typing import Dict, Any
+import logging
+import functools
 
+from .attachment_status import AttachmentStatus
 from mail_order_bot.context import Context
 
+logger = logging.getLogger(__name__)
+
+
+def handle_errors(func):
+    """
+    Декоратор для обработки ошибок в методе do класса AbstractTask.
+    Оборачивает выполнение метода в try-except, при ошибке устанавливает статус "error",
+    логирует ошибку и пробрасывает исключение дальше.
+    Применяется везде к методу do.
+    """
+    @functools.wraps(func)
+    def wrapper(self, attachment) -> None:
+        file_name = attachment.get("name", "неизвестный файл")
+
+        try:
+            # Выполняем метод do
+            return func(self, attachment)
+
+        except Exception as e:
+            # При ошибке устанавливаем статус и логируем
+            if attachment:
+                attachment["status"] = AttachmentStatus.FAILED
+            logger.error(f"Ошибка при обработке вложения {file_name} на стадии {self.__class__.__name__} \n{e}", exc_info=True)
+            # Пробрасываем исключение дальше
+            # raise
+    return wrapper
+
+
+def pass_if_error(func):
+    """
+    Декоратор для проверки статуса attachment перед выполнением метода do.
+    Если статус attachment["status"] != "ok", метод не выполняется.
+    Применяется опционально в конкретных классах, где нужна проверка статуса.
+    """
+    @functools.wraps(func)
+    def wrapper(self, attachment) -> None:
+        # Проверяем статус перед выполнением
+        if attachment and attachment.get("status") != AttachmentStatus.OK:
+            file_name = attachment.get("name", "неизвестный файл")
+            logger.warning(f"Пропускаем шаг для файла {file_name}, статус {attachment.get('status')}")
+            return
+        
+        # Выполняем метод do
+        return func(self, attachment)
+    
+    return wrapper
+
 
 class AbstractTask():
-    RESULT_SECTION = "section"
+    STEP_NAME = "Название шага обработки"
+
     """
     Абстрактный базовый класс для всех хэндлеров.
     """
@@ -15,7 +65,7 @@ class AbstractTask():
         self.config = self.context.data.get("config", {})
 
     @abstractmethod
-    def do(self) -> None:
+    def do(self, attachment) -> None:
         """
         Выполняет работу над заданием
         Входные и выходные данные - в self.context
@@ -23,3 +73,6 @@ class AbstractTask():
         """
         raise NotImplementedError
 
+    def get_name(self) -> str:
+        pass
+

src/mail_order_bot/task_processor/attachment_status.py

@@ -0,0 +1,6 @@
+from enum import StrEnum
+
+class AttachmentStatus(StrEnum):
+    OK = "все в порядке"
+    FAILED = "ошибка"
+    NOT_A_ORDER = "не является заказом"

src/mail_order_bot/task_processor/exceptions.py

@@ -0,0 +1,11 @@
+class TaskException(Exception):
+    """Базовый класс исключений."""
+    pass
+
+class TaskExceptionWithEmailNotify(TaskException):
+    """Базовый класс исключений с уведомлением по почте."""
+    pass
+
+class TaskExceptionSilent(TaskException):
+    """Базовый класс исключений без уведомления."""
+    pass

src/mail_order_bot/task_processor/file_validator.py

@@ -0,0 +1,49 @@
+"""
+Модуль для проверки типов файлов
+"""
+import logging
+
+logger = logging.getLogger(__name__)
+
+
+def is_spreadsheet_file(file_bytes: bytes) -> bool:
+    """
+    Проверяет, является ли файл электронной таблицей (XLS, XLSX, ODS).
+    
+    Проверка выполняется по магическим байтам (magic bytes) в начале файла:
+    - XLSX: начинается с PK (это ZIP архив, который начинается с байтов 50 4B)
+    - XLS: начинается с D0 CF 11 E0 (старый формат Office)
+    - ODS: также ZIP архив, но для нашего случая проверяем только XLS/XLSX
+    
+    Args:
+        file_bytes: Байты файла для проверки
+        
+    Returns:
+        True, если файл является электронной таблицей, False в противном случае
+    """
+    if not file_bytes or len(file_bytes) < 8:
+        return False
+    
+    # Проверка на XLSX (ZIP формат, начинается с PK)
+    # XLSX файлы - это ZIP архивы, которые начинаются с байтов 50 4B 03 04
+    if file_bytes[:2] == b'PK':
+        # Дополнительная проверка: внутри ZIP должен быть файл [Content_Types].xml
+        # Но для простоты проверим, что это действительно ZIP архив
+        # Стандартный ZIP начинается с PK\x03\x04 или PK\x05\x06 (пустой архив)
+        if file_bytes[:4] in (b'PK\x03\x04', b'PK\x05\x06', b'PK\x07\x08'):
+            logger.debug("Обнаружен файл формата XLSX (ZIP/Office Open XML)")
+            return True
+    
+    # Проверка на XLS (старый бинарный формат Office)
+    # XLS файлы начинаются с D0 CF 11 E0 A1 B1 1A E1 (OLE2 compound document)
+    if file_bytes[:8] == b'\xD0\xCF\x11\xE0\xA1\xB1\x1A\xE1':
+        logger.debug("Обнаружен файл формата XLS (старый формат Office)")
+        return True
+    
+    # Более мягкая проверка на XLS - только первые 4 байта
+    if file_bytes[:4] == b'\xD0\xCF\x11\xE0':
+        logger.debug("Обнаружен файл формата XLS (по первым 4 байтам)")
+        return True
+    
+    return False
+

src/mail_order_bot/task_processor/handlers/__init__.py

@@ -1,18 +1,18 @@
 
-
-from .attachment_handler.attachment_handler import AttachmentHandler
-from .abcp.api_get_stock import APIGetStock
-from .destination_time.local_store import DeliveryPeriodLocalStore
-from .destination_time.from_config import DeliveryPeriodFromConfig
-from .notifications.test_notifier import TestNotifier
+#from .abcp._api_get_stock import APIGetStock
+from .delivery_time.local_store import DeliveryPeriodLocalStore
+from .delivery_time.from_config import DeliveryPeriodFromConfig
+from .notifications.test_notifier import TelegramNotifier
 from .excel_parcers.excel_extractor import ExcelExtractor
 from .excel_parcers.order_extractor import OrderExtractor
-from .abcp.api_save_order import SaveOrderToTelegram
+#from .abcp.api_save_order import SaveOrderToTelegram
 
 from .stock_selectors.stock_selector import StockSelector
 
 from .excel_parcers.update_excel_file import UpdateExcelFile
 
-from .email.send_email import EmailReplyTask
+from .email.email_reply_task import EmailReplyTask
+
+from .email.email_forward_error_task import EmailForwardErrorTask
 
 

src/mail_order_bot/task_processor/handlers/abcp/api_get_stock.py

@@ -1,42 +0,0 @@
-"""
-Перебирает аттачменты
-Для каждого ордера в аттачменте перебирает позиции
-Для каждой позиции запрашивает остатки и запускает процедуру выбора оптмальной позиции со склада/
-Возможно логику выбора позиции надо вынести из позиции, но пока так
-"""
-import logging
-
-from mail_order_bot.task_processor.abstract_task import AbstractTask
-from mail_order_bot.abcp_api.abcp_provider import AbcpProvider
-from mail_order_bot.credential_provider import CredentialProvider
-from mail_order_bot.order.auto_part_order import OrderStatus
-
-logger = logging.getLogger(__name__)
-
-
-class APIGetStock(AbstractTask):
-    def __init__(self, *args, **kwargs):
-        super().__init__(*args, **kwargs)
-        credential_provider = CredentialProvider(context=self.context)
-            
-        # Создаем провайдер для учетной записи клиента
-        client_login, client_password = credential_provider.get_client_credentials()
-        self.client_provider = AbcpProvider(login=client_login, password=client_password)
-
-    def do(self) -> None:
-
-        attachments = self.context.data.get("attachments", [])
-        for attachment in attachments:
-
-            order = attachment.get("order", None)
-            for position in order.positions:
-                # Получаем остатки из-под учетной записи клиента
-                client_stock = self.client_provider.get_stock(position.sku, position.manufacturer)
-                position.set_order_item(client_stock)
-                #position.set_order_item()
-
-            logger.info(f"Получены позиции со склада для файла {attachment.get('name', "no name")}")
-
-
-    def get_stock(self, sku: str, manufacturer: str) -> int:
-        return self.client_provider.get_stock(sku, manufacturer)

src/mail_order_bot/task_processor/handlers/abcp/api_save_order.py

@@ -1,60 +0,0 @@
-"""
-Перебирает аттачменты
-Для каждого ордера в аттачменте перебирает позиции
-Для каждой позиции запрашивает остатки и запускает процедуру выбора оптмальной позиции со склада/
-Возможно логику выбора позиции надо вынести из позиции, но пока так
-"""
-import logging
-
-from mail_order_bot.task_processor.abstract_task import AbstractTask
-from mail_order_bot.abcp_api.abcp_provider import AbcpProvider
-from mail_order_bot.credential_provider import CredentialProvider
-
-from mail_order_bot.telegram.client import TelegramClient
-
-logger = logging.getLogger(__name__)
-
-class SaveOrderToTelegram(AbstractTask):
-    def __init__(self, *args, **kwargs):
-        super().__init__(*args, **kwargs)
-
-    def do(self) -> None:
-        client = TelegramClient()
-
-        attachments = self.context.data.get("attachments", [])
-        for attachment in attachments:
-            order = attachment["order"]
-            positions = order.positions
-            message = "\nОбработка заказа {указать название контрагента}\n"
-            message += f"\nПолучено {len(positions)} позиций от {order.client_id}\n"
-            message += "===============================\n"
-            for position in positions:
-                message += f"{position.sku} - {position.manufacturer} - {position.name} \n"
-                message += f"{position.asking_quantity} x {position.asking_price} = {position.total} \n"
-
-                rejected = position.asking_quantity - position.order_quantity
-                if position.order_quantity == 0:
-                    message += f"Отказ\n"
-                elif rejected:
-                    message += (f"Отказ: {rejected}, запрошено, {position.asking_quantity}, "
-                                f"отгружено {position.order_quantity}, профит {position.profit}\n")
-                else:
-                    message += f"Позиция отгружена полностью, профит {position.profit}\n"
-                message += "-------------------------------\n"
-
-            result = client.send_message(message)
-
-            # Отправка экселя в телеграм
-            excel = attachment["excel"]
-            file = excel.get_file_bytes()
-
-            client.send_document(
-                document=file,
-                filename="document.xlsx"
-            )
-            # logger.critical(message)
-
-        #===============================
-
-
-            

src/mail_order_bot/task_processor/handlers/attachment_handler/attachment_handler.py

@@ -1,29 +0,0 @@
-"""
-Извлекает вложения из имейла и складывает их в контекст
-Использует EmailUtils
-"""
-import logging
-
-from mail_order_bot.task_processor.abstract_task import AbstractTask
-from mail_order_bot.email_client.utils import EmailUtils
-
-logger = logging.getLogger(__name__)
-
-class AttachmentHandler(AbstractTask):
-    def __init__(self, *args, **kwargs):
-        super().__init__(*args, **kwargs)
-
-    def do(self) -> None:
-        try:
-            email = self.context.data["email"]
-            attachments = EmailUtils.extract_attachments(email)
-
-        except Exception as e:
-            logger.error(e)
-            self.context.data["error"] = str(e)
-
-        else:
-            self.context.data["attachments"] = attachments
-            logger.info(f"Извлечено вложений: {len(attachments)} ")
-
-

src/mail_order_bot/task_processor/handlers/delivery_time/from_config.py

@@ -5,7 +5,7 @@
 
 import logging
 
-from mail_order_bot.task_processor.abstract_task import AbstractTask
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
 
 logger = logging.getLogger(__name__)
 
@@ -13,14 +13,12 @@ class DeliveryPeriodFromConfig(AbstractTask):
     def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
 
-    def do(self) -> None:
-        attachments = self.context.data["attachments"]
-        for attachment in attachments:
-            delivery_period = self.config.get("delivery_period", 0)
+    @pass_if_error
+    def do(self, attachment) -> None:
+        try:
+            delivery_period = self.config.get("delivery_period")
             attachment["delivery_period"] = delivery_period
-
-        logger.info(f"Доставка только с локального склада, срок 1 день.")
-
-
-
+            logger.warning(f"Срок доставки установлен из конфига - {delivery_period} (ч.)")
+        except Exception as e:
+            raise Exception(f"Ошибка при установке срока доставки из конфига. Детали ошибки: {e}")
 

src/mail_order_bot/task_processor/handlers/delivery_time/from_subject.py

@@ -2,7 +2,7 @@
 Парсер срока доставки из темы письма
 """
 
-from mail_order_bot.task_processor.abstract_task import AbstractTask
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
 
 import logging
 import re
@@ -26,25 +26,30 @@ class DeliveryPeriodFromSubject(AbstractTask):
         - Срок переводится в часы (умножается на 24)
         """
         # Получаем тему письма
-        email_subj = self.context.data.get("email_subj", "")
-        if not email_subj:
-            logger.warning("Тема письма не найдена в контексте")
-            email_subj = ""
 
-        # Парсим срок доставки
-        delivery_days = self._parse_delivery_period(email_subj)
+        try:
+            email_subj = self.context.data.get("email_subj", "")
+            if not email_subj:
+                logger.warning("Тема письма не найдена в контексте")
+                email_subj = ""
 
-        # Переводим в часы
-        delivery_time = delivery_days * 24
+            # Парсим срок доставки
+            delivery_days = self._parse_delivery_period(email_subj)
 
-        logger.info(f"Извлечен срок доставки из темы: {delivery_days} дней ({delivery_time} часов)")
+            # Переводим в часы
+            delivery_time = delivery_days * 24
 
-        # Сохраняем в каждый элемент attachments
-        attachments = self.context.data.get("attachments", [])
-        for attachment in attachments:
-            attachment["delivery_time"] = delivery_time
+            logger.info(f"Извлечен срок доставки из темы: {delivery_days} дней ({delivery_time} часов)")
+
+            # Сохраняем в каждый элемент attachments
+            attachments = self.context.data.get("attachments", [])
+            for attachment in attachments:
+                attachment["delivery_time"] = delivery_time
+                logger.debug(f"Срок доставки для файла {attachment["name"]} установлен как {delivery_time}")
+
+        except Exception as e:
+            logger.error(e)
             
-        logger.debug(f"Срок доставки сохранен в {len(attachments)} вложений")
     
     def _parse_delivery_period(self, subject: str) -> int:
         """

src/mail_order_bot/task_processor/handlers/delivery_time/local_store.py

@@ -5,7 +5,7 @@
 
 import logging
 
-from mail_order_bot.task_processor.abstract_task import AbstractTask
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
 
 logger = logging.getLogger(__name__)
 
@@ -17,8 +17,4 @@ class DeliveryPeriodLocalStore(AbstractTask):
         attachments = self.context.data["attachments"]
         for attachment in attachments:
             attachment["delivery_period"] = 0
-        logger.info(f"Доставка только с локального склада, срок 1 день.")
-
-
-
-
+            logger.info(f"Срок доставки для файла {attachment["name"]} - только из наличия")

src/mail_order_bot/task_processor/handlers/email/email_forward_error_task.py

@@ -0,0 +1,100 @@
+import logging
+
+from email.mime.multipart import MIMEMultipart
+from email.mime.text import MIMEText
+from email.mime.message import MIMEMessage
+from email.utils import formatdate
+
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
+from ...attachment_status import AttachmentStatus
+
+
+logger = logging.getLogger(__name__)
+
+
+class EmailForwardErrorTaskException(Exception):
+    pass
+
+
+class EmailForwardErrorTask(AbstractTask):
+    STEP_NAME = "Уведомление сотрудника об ошибке"
+
+    """Пересылает письмо как вложение на заданный адрес при ошибке обработки"""
+    EMAIL = "zosimovaa@yandex.ru"  # Адрес получателя пересылки
+    ERROR_RECIPIENT = "lesha.spb@gmail.com"  # Адрес для пересылки ошибок
+
+    #@handle_errors
+    def do(self, attachment=None):
+        """
+        Пересылает письмо из контекста как вложение на заданный адрес
+        
+        Args:
+            attachment: Не используется, оставлен для совместимости с AbstractTask
+        """
+
+        if attachment: # and attachment.get("status") == AttachmentStatus.FAILED:
+
+            email = self.context.data.get("email")
+
+            if not email:
+                raise ValueError("В контексте нет входящего сообщения")
+
+            email_subj = f"[ОШИБКА СОЗДАНИЯ ЗАКАЗА] - {self.context.data.get("email_subj", "Без темы")}]"
+
+            # Создаем новое сообщение для пересылки
+            forward_message = MIMEMultipart()
+
+            forward_message["From"] = self.EMAIL
+            forward_message["To"] = self.ERROR_RECIPIENT
+            forward_message["Subject"] = email_subj
+            forward_message["Date"] = formatdate(localtime=True)
+
+            # Добавляем текстовый комментарий в тело письма
+
+            body = "Ошибка обработки письма\n"
+            body += f"{attachment.get("error", "Нет данных по ошибке")}\n"
+            order = attachment.get("order")
+            if order is not None:
+                body += order.get_order_description()
+            else:
+                body += "Заказ не был распарсен"
+
+            forward_message.attach(MIMEText(body, "plain", "utf-8"))
+
+            # Прикрепляем исходное письмо как вложение
+            self._attach_email(forward_message, email)
+
+            # Отправляем письмо
+            self.context.email_client.send_email(forward_message)
+
+            logger.warning(f"Письмо переслано как вложение на {self.ERROR_RECIPIENT}")
+
+        else:
+            logger.warning(f"Все окей, никуда ничего пересылать не надо")
+
+    def _attach_email(self, forward_message, email_message):
+        """
+        Прикрепляет исходное письмо как вложение к сообщению
+        
+        Args:
+            forward_message: MIMEMultipart сообщение, к которому прикрепляем
+            email_message: email.message.Message - исходное письмо для пересылки
+        """
+        try:
+            # Создаем MIMEMessage из исходного письма
+            msg_part = MIMEMessage(email_message)
+            
+            # Устанавливаем имя файла для вложения
+            email_subj = self.context.data.get("email_subj", "message")
+            # Очищаем тему от недопустимых символов для имени файла
+            safe_subj = "".join(c if c.isalnum() or c in (' ', '-', '_') else '_' for c in email_subj[:50])
+            msg_part.add_header(
+                "Content-Disposition",
+                f'attachment; filename="forwarded_email_{safe_subj}.eml"'
+            )
+
+            forward_message.attach(msg_part)
+
+        except Exception as e:
+            raise Exception(f"Ошибка при прикреплении письма: {str(e)}")
+

src/mail_order_bot/task_processor/handlers/email/email_parcer.py

@@ -4,40 +4,56 @@
 """
 import logging
 
-from mail_order_bot.task_processor.abstract_task import AbstractTask
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
 from mail_order_bot.email_client.utils import EmailUtils
 
+
 logger = logging.getLogger(__name__)
 
+class EmailParcerException(Exception):
+    pass
+
+
 class EmailParcer(AbstractTask):
     def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
 
     def do(self) -> None:
         # Определить клиента
-        email = self.context.data.get("email", None)
-        if email is not None:
-            email_body = EmailUtils.extract_body(email)
-            self.context.data["email_body"] = email_body
+        try:
+            email = self.context.data.get("email", None)
+            if email is not None:
+                email_body = EmailUtils.extract_body(email)
+                self.context.data["email_body"] = email_body
 
-            # todo при переводе на основной ящик переделать на другую функцию
-            header_from = EmailUtils.extract_header(email, "From")
-            email_from = EmailUtils.extract_email(header_from)
-            #email_from = EmailUtils.extract_first_sender(email_body)
-            self.context.data["email_from"] = email_from
+                # todo при переводе на основной ящик переделать на другую функцию
+                header_from = EmailUtils.extract_header(email, "From")
+                email_from = EmailUtils.extract_email(header_from)
+                #email_from = EmailUtils.extract_first_sender(email_body)
+                self.context.data["email_from"] = email_from
 
-            email_from_domain = EmailUtils.extract_domain(email_from)
-            self.context.data["email_from_domain"] = email_from_domain
+                email_from_domain = EmailUtils.extract_domain(email_from)
+                self.context.data["email_from_domain"] = email_from_domain
 
-            email_subj = EmailUtils.extract_header(email, "subj")
-            self.context.data["email_subj"] = email_subj
+                email_subj = EmailUtils.extract_header(email, "subject")
+                self.context.data["email_subj"] = email_subj
 
-            client = EmailUtils.extract_domain(email_from)
-            self.context.data["client"] = client
+                client = EmailUtils.extract_domain(email_from)
+                self.context.data["client"] = client
 
-            attachments = EmailUtils.extract_attachments(email)
-            self.context.data["attachments"] = attachments
-            logger.info(f"Извлечено вложений: {len(attachments)} ")
+                attachments = EmailUtils.extract_attachments(email)
+
+                self.context.data["attachments"] = attachments
+                logger.info(f"Извлечено вложений: {len(attachments)} ")
+
+        except Exception as e:
+            logger.error(e)
+
+            self.context.data["error"].add(
+               "переделать ошибку на нормальную"
+            )
+
+            #raise EmailParcerException(f"Ошибка при парсинге письма {e}") from e
 
 
 

src/mail_order_bot/task_processor/handlers/email/email_reply_task.py

@@ -1,24 +1,30 @@
-
-import smtplib
+import logging
+import os
 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
 
-from mail_order_bot.task_processor.abstract_task import AbstractTask
+
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
+
+logger = logging.getLogger(__name__)
+
+class EmailReplyTaskException(Exception):
+    pass
+
 
 class EmailReplyTask(AbstractTask):
     """Формирует ответ на входящее письмо с запросом на заказ°"""
     EMAIl = "zosimovaa@yandex.ru" #"noreply@zapchastiya.ru"
 
-    def do(self):
+    @pass_if_error
+    #@handle_errors
+    def do(self, attachment):
 
         email = self.context.data.get("email")
 
-
         if not email:
             raise ValueError("В контексте нет входящего сообщения")
 
@@ -31,7 +37,7 @@ class EmailReplyTask(AbstractTask):
 
         email_subj = self.context.data.get("email_subj")
 
-        reply_message["From"] = self.EMAIl
+        reply_message["From"] = os.environ.get("EMAIL_USER")
         reply_message["To"] = email_from
         #reply_message["Cc"] = self.config.get("reply_to", "")
         reply_message["Subject"] = f"Re: {email_subj}"
@@ -40,12 +46,14 @@ class EmailReplyTask(AbstractTask):
         body = "Автоматический ответ на создание заказа"
         reply_message.attach(MIMEText(body, "plain", "utf-8"))
 
-        attachments = self.context.data.get("attachments")
-        for attachment in attachments:
-            self._attach_file(reply_message, attachment)
+
+        self._attach_file(reply_message, attachment)
 
         self.context.email_client.send_email(reply_message)
 
+        logger.warning(f"Сформирован ответ на заказ на email")
+
+
     def _attach_file(self, reply_message, attachment):
         """
         Args:
@@ -62,7 +70,7 @@ class EmailReplyTask(AbstractTask):
 
             encoders.encode_base64(part)
 
-            file_name = attachment["name"][0]
+            file_name = attachment["name"]
             part.add_header(
                 "Content-Disposition",
                 f"attachment; filename= {file_name}"

src/mail_order_bot/task_processor/handlers/excel_parcers/deprecated/order_parser.py

@@ -1,122 +0,0 @@
-import logging
-import pandas as pd
-from typing import Dict, Any, Optional
-from decimal import Decimal
-from io import BytesIO
-#from mail_order_bot.task_processor.handlers.order_position import OrderPosition
-from mail_order_bot.task_processor.abstract_task import AbstractTask
-
-from mail_order_bot.task_processor.order.auto_part_position import AutoPartPosition
-from mail_order_bot.task_processor.order.auto_part_order import AutoPartOrder
-
-logger = logging.getLogger(__name__)
-
-
-class OrderParser(AbstractTask):
-    """
-    Универсальный парсер, настраиваемый через конфигурацию.
-    Подходит для большинства стандартных случаев.
-    """
-    def __init__(self, *args, **kwargs):
-        super().__init__(*args, **kwargs)
-
-    def do(self) -> None:
-
-        # todo сделать проверку на наличие файла и его тип
-
-        attachments = self.context.data.get("attachments", [])
-        for attachment in attachments:
-            file_bytes = BytesIO(attachment['bytes']) # self.context.get("attachment") #
-            delivery_period = attachment.get("delivery_period", 0)
-            #try:
-            df = self._make_dataframe(file_bytes)
-            mapping = self.config["mapping"]
-            client_id = self.config["client_id"]
-            order = AutoPartOrder()
-            attachment["order"] = order
-
-            # Парсим строки
-            positions = []
-            for idx, row in df.iterrows():
-                position = self._parse_row(row, mapping)
-                if position:
-                    position.order_delivery_period = delivery_period
-                    order.add_position(position)
-
-            logger.info(f"Успешно обработано {len(order)} позиций из {len(df)} строк")
-
-            #except Exception as e:
-             #   logger.error(f"Ошибка при обработке файла: {e}")
-            #else:
-            attachment["order"] = order
-
-
-
-    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 "name" in mapping:
-            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

src/mail_order_bot/task_processor/handlers/excel_parcers/deprecated/sheet_parcer.py

@@ -1,118 +0,0 @@
-import logging
-import pandas as pd
-from typing import Dict, Any, Optional
-from decimal import Decimal
-from io import BytesIO
-#from mail_order_bot.task_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

src/mail_order_bot/task_processor/handlers/excel_parcers/excel_extractor.py

@@ -1,15 +1,13 @@
 import logging
-import pandas as pd
 from io import BytesIO
-#from mail_order_bot.task_processor.handlers.order_position import OrderPosition
-from mail_order_bot.task_processor.abstract_task import AbstractTask
-
-from mail_order_bot.parsers.excel_parcer import ExcelFileParcer
+from mail_order_bot.task_processor.abstract_task import AbstractTask, pass_if_error, handle_errors
+from mail_order_bot.task_processor.handlers.excel_parcers.order_extractor import ExcelFileParcer
 
 logger = logging.getLogger(__name__)
 
 
 class ExcelExtractor(AbstractTask):
+    STEP_NAME = "Парсинг эксель файла"
     """
     Хендлер для каждого вложения считывает эксель файл и сохраняет его контекст
     """
@@ -17,19 +15,10 @@ class ExcelExtractor(AbstractTask):
         super().__init__(*args, **kwargs)
         self.excel_config = self.config.get("excel", {})
 
-    def do(self) -> None:
-
-        # todo сделать проверку на наличие файла и его тип
-
-        attachments = self.context.data.get("attachments", [])
-        for attachment in attachments:
-            file_bytes = BytesIO(attachment['bytes'])
-
-            excel_file = ExcelFileParcer(file_bytes, self.excel_config)
-            attachment["excel"] = excel_file
-
-            
-            
-
-
-
+    @pass_if_error
+    #@handle_errors
+    def do(self, attachment) -> None:
+        file_bytes = BytesIO(attachment['bytes'])
+        excel_file = ExcelFileParcer(file_bytes, self.excel_config)
+        attachment["excel"] = excel_file
+        logger.warning(f"Произведен успешный парсинг файла {attachment.get('name', 'неизвестный файл')}")

src/mail_order_bot/task_processor/handlers/excel_parcers/order_extractor.py

@@ -2,7 +2,7 @@ import logging
 import pandas as pd
 from io import BytesIO
 from mail_order_bot.parsers.order_parcer import OrderParser
-from mail_order_bot.task_processor.abstract_task import AbstractTask
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
 
 from mail_order_bot.parsers.excel_parcer import ExcelFileParcer
 
@@ -10,6 +10,7 @@ logger = logging.getLogger(__name__)
 
 
 class OrderExtractor(AbstractTask):
+    STEP_NAME = "Парсинг заказа"
     """
     Хендлер для каждого вложения считывает эксель файл и сохраняет его контекст
     """
@@ -17,26 +18,24 @@ class OrderExtractor(AbstractTask):
         super().__init__(*args, **kwargs)
         self.excel_config = self.config.get("excel", {})
 
-
-    def do(self) -> None:
-
+    @pass_if_error
+    #@handle_errors
+    def do(self, attachment) -> None:
         # todo сделать проверку на наличие файла и его тип
+        delivery_period = attachment.get("delivery_period", 0)
+        mapping = self.excel_config.get("mapping")
 
-        attachments = self.context.data.get("attachments", [])
-        for attachment in attachments:
+        excel_file = attachment.get("excel")
+        client_id = self.config.get("client_id")
 
-            delivery_period = attachment.get("delivery_period", 0)
-            mapping = self.excel_config.get("mapping")
+        order_parcer = OrderParser(mapping, delivery_period, client_id)
 
-            excel_file = attachment.get("excel")
-            client_id = self.config.get("client_id")
-            order_parcer = OrderParser(mapping, delivery_period, client_id)
+        order_dataframe = excel_file.get_order_rows()
+        order = order_parcer.parse(order_dataframe)
 
-            order_dataframe = excel_file.get_order_rows()
-
-            order = order_parcer.parse(order_dataframe)
-            attachment["order"] = order
+        attachment["order"] = order
 
+        logger.warning(f"Файл заказа обработан успешно, извлечено {len(order.positions)} позиций")
 
 
 

src/mail_order_bot/task_processor/handlers/excel_parcers/update_excel_file.py

@@ -1,17 +1,12 @@
 import logging
-import pandas as pd
-from io import BytesIO
-# from mail_order_bot.task_processor.handlers.order_position import OrderPosition
-from mail_order_bot.task_processor.abstract_task import AbstractTask
-
-
-from mail_order_bot.order.auto_part_position import PositionStatus
-from mail_order_bot.parsers.excel_parcer import ExcelFileParcer
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
 
 logger = logging.getLogger(__name__)
 
 
 class UpdateExcelFile(AbstractTask):
+    STEP_NAME = "Обновление файла заказа"
+
     """
     Хендлер для каждого вложения считывает эксель файл и сохраняет его контекст
     """
@@ -20,32 +15,31 @@ class UpdateExcelFile(AbstractTask):
         super().__init__(*args, **kwargs)
         self.excel_config = self.config.get("excel", {})
 
-    def do(self) -> None:
+    @pass_if_error
+    #@handle_errors
+    def do(self, attachment) -> None:
         # todo сделать проверку на наличие файла и его тип
+        excel_file = attachment.get("excel")
+        order = attachment.get("order")
+        config = self.context.data.get("config", {})
+        excel_config = config.get("excel", {})
+        updatable_fields = excel_config.get("updatable_fields", {})
 
-        attachments = self.context.data.get("attachments", [])
-        for attachment in attachments:
-            excel_file = attachment.get("excel")
-            order = attachment.get("order")
-            config = self.context.data.get("config", {})
-            excel_config = config.get("excel", {})
-            updatable_fields = excel_config.get("updatable_fields", {})
+        for position in order.positions:
 
-            for position in order.positions:
+            sku = position.sku
+            manufacturer = position.manufacturer
 
-                sku = position.sku
-                manufacturer = position.manufacturer
+            for key, value in updatable_fields.items():
 
-                for key, value in updatable_fields.items():
-
-                    if key == "ordered_quantity":
-                        column = value
-                        value = position.order_quantity
-                        excel_file.set_value(sku, manufacturer, column, value)
-
-                    if key == "ordered_price":
-                        column = value
-                        value = position.order_price
-                        excel_file.set_value(sku, manufacturer, column, value)
+                if key == "ordered_quantity":
+                    column = value
+                    value = position.order_quantity
+                    excel_file.set_value(sku, manufacturer, column, value)
 
+                if key == "ordered_price":
+                    column = value
+                    value = position.order_price
+                    excel_file.set_value(sku, manufacturer, column, value)
 
+        logger.warning(f"Файла {attachment.get('name', 'неизвестный файл')} отредактирован")

src/mail_order_bot/task_processor/handlers/notifications/test_notifier.py

@@ -1,15 +1,58 @@
+"""
+Перебирает аттачменты
+Для каждого ордера в аттачменте перебирает позиции
+Для каждой позиции запрашивает остатки и запускает процедуру выбора оптмальной позиции со склада/
+Возможно логику выбора позиции надо вынести из позиции, но пока так
+"""
 import logging
 
-from mail_order_bot.task_processor.abstract_task import AbstractTask
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
+from mail_order_bot.abcp_api.abcp_provider import AbcpProvider
+from mail_order_bot.credential_provider import CredentialProvider
+
+from mail_order_bot.telegram.client import TelegramClient
 
 logger = logging.getLogger(__name__)
 
-class TestNotifier(AbstractTask):
-    def do(self) -> None:
 
-        positions = self.context["positions"]
+class TelegramNotifier(AbstractTask):
+    def __init__(self, *args, **kwargs):
+        super().__init__(*args, **kwargs)
+
+    @pass_if_error
+    # @handle_errors
+    def do(self, attachment) -> None:
+        message = self.build_message(attachment)
+
+        client = TelegramClient()
+        result = client.send_message(message)
+
+        # Отправка экселя в телеграм
+        excel = attachment["excel"]
+        file = excel.get_file_bytes()
+        client.send_document(
+            document=file,
+            filename=attachment.get("name", "document.xlsx")
+        )
+
+        logger.warning("Инфо по заказу отправлено в телеграм")
+
+    def build_message(self, attachment):
+        order = attachment["order"]
+        file_name = attachment["name"]
+        # positions = order.positions
+
+        sender_email = self.context.data.get("email_from")
+        email_subject = self.context.data.get("email_subj")
+
+        message = "=============================\n"
+        message += f"Обработка заказа от {sender_email}\n"
+        message += f"тема письма: {email_subject}\n"
+        message += f"файл: {file_name}\n"
+
+        message += order.get_order_description()
+        return message
+    # ===============================
+
+
 
-        print(f"\nПолучено {len(positions)} позиций от {self.context["client"]}:")
-        for pos in positions:  # Первые 5
-            print(f"  - {pos.sku}: {pos.name} "
-                  f"({pos.asking_quantity} x {pos.asking_price} = {pos.total})")

src/mail_order_bot/task_processor/handlers/stock_selectors/stock_selector.py

@@ -10,17 +10,24 @@ from mail_order_bot.order.auto_part_position import AutoPartPosition, PositionSt
 from mail_order_bot.parsers.excel_parcer import ExcelFileParcer
 from decimal import Decimal
 
-from mail_order_bot.task_processor.abstract_task import AbstractTask
+from ...abstract_task import AbstractTask, pass_if_error, handle_errors
 from mail_order_bot.abcp_api.abcp_provider import AbcpProvider
 from mail_order_bot.credential_provider import CredentialProvider
 from mail_order_bot.order.auto_part_order import OrderStatus
 
+from ...exceptions import TaskException
 
 from typing import Dict, Any
 from typing import List, Optional
 
 logger = logging.getLogger(__name__)
 
+class StockSelectorException(TaskException):
+    pass
+
+class RefusalLevelExceededException(TaskException):
+    pass
+
 
 class StockSelector(AbstractTask):
     DISTRIBUTOR_ID = 1577730  # ID локального склада
@@ -35,36 +42,43 @@ class StockSelector(AbstractTask):
         client_login, client_password = credential_provider.get_system_credentials()
         self.client_provider = AbcpProvider(login=client_login, password=client_password)
 
-    def do(self) -> None:
+    @pass_if_error
+    #@handle_errors
+    def do(self, attachment) -> None:
         # todo сделать проверку на наличие файла и его тип
-        attachments = self.context.data.get("attachments", [])
-        for attachment in attachments:
-            order = attachment.get("order", None)
-            delivery_period = attachment.get("delivery_period")
-            for position in order.positions:
+        order = attachment.get("order", None)
+        delivery_period = attachment.get("delivery_period")
+        for position in order.positions:
 
-                #1. Получаем остатки со складов
-                stock_data = self.client_provider.get_stock(position.sku, position.manufacturer)
+            #1. Получаем остатки со складов
+            stock_data = self.client_provider.get_stock(position.sku, position.manufacturer)
 
-                #2. Из данных остатков выбираем оптимальное значение по стратегии
-                if stock_data["success"]:
-                    stock_list = stock_data.get("data", [])
-                    asking_price = position.asking_price
-                    asking_quantity = position.asking_quantity
+            #2. Из данных остатков выбираем оптимальное значение по стратегии
+            if stock_data["success"]:
+                stock_list = stock_data.get("data", [])
+                asking_price = position.asking_price
+                asking_quantity = position.asking_quantity
 
 
-                    optimal_stock_positions = self.get_optimal_stock(stock_list, asking_price, asking_quantity, delivery_period)
+                optimal_stock_positions = self.get_optimal_stock(stock_list, asking_price, asking_quantity, delivery_period)
 
-                    # 3. Устанавливаем выбранное значение в позицию
-                    if len(optimal_stock_positions):
-                        position.set_order_item(optimal_stock_positions[0])
-                    else:
-                        position.status = PositionStatus.NO_AVAILABLE_STOCK
-                # Мне не очень нравится управление статусами в этом месте, кажется что лучше это делать внутри AutoPartPosition
+                # 3. Устанавливаем выбранное значение в позицию
+                if len(optimal_stock_positions):
+                    position.set_order_item(optimal_stock_positions[0])
                 else:
-                    position.status = PositionStatus.STOCK_FAILED
+                    position.status = PositionStatus.NO_AVAILABLE_STOCK
+            # Мне не очень нравится управление статусами в этом месте, кажется что лучше это делать внутри AutoPartPosition
+            else:
+                position.status = PositionStatus.STOCK_FAILED
 
+        refusal_threshold = self.config.get("refusal_threshold", 1)
+        refusal_level = order.get_refusal_level()
 
+        if refusal_level > refusal_threshold:
+            raise RefusalLevelExceededException(f"Превышен лимит по отказам, необходима ручная обработка. "
+                            f"Уровень отказов: {refusal_level:.2%}, допустимый лимит: {refusal_threshold:.2%}")
+
+        logger.warning("Определены оптимальные позиции со складов")
 
     def get_optimal_stock(self, stock_list, asking_price, asking_quantity, delivery_period):
         """Выбирает позицию для заказа"""
@@ -73,7 +87,7 @@ class StockSelector(AbstractTask):
         stock_list = self._br1_only_local_stock(stock_list)
 
         # BR-2. Цена не должна превышать цену из заказа
-        #stock_list = self._br2_price_below_asked_price(stock_list, asking_price)
+        stock_list = self._br2_price_below_asked_price(stock_list, asking_price)
 
         # BR-3. Срок доставки не должен превышать ожидаемый
         stock_list = self._br3_delivery_time_shorted_asked_time(stock_list, delivery_period)

src/mail_order_bot/task_processor/message.py

@@ -0,0 +1,44 @@
+
+from enum import Enum
+
+
+class LogMessageLevel(Enum):
+    SUCCESS = "SUCCESS"
+    WARNING = "WARNING"
+    ERROR = "ERROR"
+
+class LogMessage:
+    def __init__(self, handler=None, level=None, message=None, error_data=None):
+        self.handler = handler
+        self.level = level
+        self.message = message
+        self.error_data = error_data
+
+    def __str__(self):
+        return self.message
+
+class LogMessageStorage:
+    def __init__(self, filename=None):
+        self.filename = filename
+        self.messages = []
+
+    def append(self, message):
+        self.messages.append(message)
+
+    def check_errors(self) -> bool:
+        fatal_statuses = [message.level == LogMessageLevel.ERROR for message in self.messages]
+        return bool(sum(fatal_statuses))
+
+    def get_messages_log(self) -> str:
+        response = ""
+
+        if self.filename is not None:
+            response += f" Лог обработки файла: {self.filename}"
+
+        for message in self.messages:
+            if len(response):
+                response += "\n"
+            response += f"{message.handler} [{message.level}]: {message.message}"
+            if message.error_data is not None:
+                response += f"\n{message.error_data}"
+

src/mail_order_bot/task_processor/processor.py

@@ -1,37 +1,62 @@
-import os
-import yaml
+"""
+Общая логика обработки писем следующая
+
+1. Общая часть
+   - скачиваем письмо
+   - складываем в контекст
+   - обработчик и парсим данные - тело, тема, отправитель
+
+2. Запускаем паплайн
+    - прогоняем обработчик для каждого вложения
+    - каждый обработчик для вложения докидывает результат своей работы
+    - каждый обработчик анализирует общий лог на наличие фатальных ошибок. Если есть - пропускаем шаг.
+    Последний обработчик направляет лог ошибок на администратора
+
+Ограничения:
+- каждое вложение воспринимается как "отдельное письмо", т.е. если клиент в одном письме направит несколько вложений,
+то они будут обрабатываться как отдельные письма, и на каждое будет дан ответ (если он требуется).
+
+
+Исключительные ситуации:
+ - При невозможности создать заказ - пересылаем письмо на администратора с логом обработки вложения
+ - Вложения, которые не являются файлами заказа игнорируем.
+
+
+todo
+ [ ] Нужен класс, который будет хранить сообщения от обработчиков
+    - метод для добавления сообщения
+    - метод для проверки фатальных ошибок
+    - метод для извлечения лога
+
+"""
+
+
 import logging
-from typing import Dict, Any, List
-from pathlib import Path
-import threading
+from typing import Dict, Any
+
 from mail_order_bot.context import Context
 from mail_order_bot.email_client.utils import EmailUtils
-from enum import Enum
-
 from mail_order_bot.task_processor.handlers import *
-from mail_order_bot.task_processor.handlers import AttachmentHandler
-from mail_order_bot.task_processor.handlers.email.email_parcer import EmailParcer
+
+from .attachment_status import AttachmentStatus
+
+
+from .handlers.email.email_parcer import EmailParcer
+
+from .file_validator import is_spreadsheet_file
+
 
 logger = logging.getLogger(__name__)
 
 
-class RequestStatus(Enum):
-    NEW = "new"
-    IN_PROGRESS = "in progress"
-    FAILED = "failed"
-    EXECUTED = "executed"
-    OPERATOR_REQUIRED = "operator required"
-    INVALID = "invalid"
 
 
 class TaskProcessor:
     #def __init__(self, configs_path: str):
     def __init__(self, config: Dict[str, Any]):
         super().__init__()
-        self.context = Context()
-        #self.configs_path = configs_path
         self.config = config
-        self.status = RequestStatus.NEW
+        self.context = Context()
 
     def process_email(self, email):
         # Очистить контекст и запушить туда письмо
@@ -39,45 +64,75 @@ class TaskProcessor:
         self.context.data["email"] = email
 
         # Парсинг письма
-        email_parcer = EmailParcer()
-        email_parcer.do()
+        #email_parcer = EmailParcer()
+        #email_parcer.do()
+        self.parse_email(email)
 
-        email_from = self.context.data.get("email_from")
-        #client = EmailUtils.extract_domain(email_from)
-        #self.context.data["client"] = client
+        # Определить конфиг для пайплайна
+        email_sender = self.context.data.get("email_from")
+        config = self._load_config(email_sender)
+        self.context.data["config"] = config
 
-        try:
-            # Определить конфиг для пайплайна
-            config = self._load_config(email_from)
-            self.context.data["config"] = config
+        if config.get("enabled", False) == True:
+            attachments = self.context.data.get("attachments", [])
 
-            # Запустить обработку пайплайна
-            pipeline = config["pipeline"]
-            for stage in pipeline:
-                handler_name = stage
-                logger.info(f"Processing handler: {handler_name}")
-                task = globals()[handler_name]()
-                task.do()
+            if not len(attachments):
+                logger.warning(f"В письме от {email_sender} нет вложений, пропускаем обработку")
 
-        except FileNotFoundError:
-            logger.error(f"Конфиг для клиента {email_from} не найден")
+            for attachment in attachments:
+                try:
+                    file_name = attachment.get("name", "неизвестный файл")
+                    logger.warning(f"==================================================")
+                    logger.warning(f"Начата обработка файла: {file_name}")
 
-        for attachment in self.context.data["attachments"]:
-            print(attachment["order"].__dict__)
-        #except Exception as e:
-        #    logger.error(f"Произошла другая ошибка: {e}")
+                    # Проверка на тип файла - должен быть файлом электронных таблиц
+                    file_bytes = attachment.get("bytes")
+                    if not file_bytes or not is_spreadsheet_file(file_bytes):
+                        logger.warning(f"Файл {file_name} не является файлом электронных таблиц, пропускаем обработку")
+                        attachment["status"] = AttachmentStatus.NOT_A_ORDER
+                        continue
 
+                    attachment["status"] = AttachmentStatus.OK
 
-    def _load_config(self, email_from) -> Dict[str, Any]:
-        if email_from in self.config:
-            return self.config[email_from]
+                    # Запустить обработку пайплайна
+                    pipeline = config["pipeline"]
 
-        email_from_domain = EmailUtils.extract_domain(email_from)
-        if email_from_domain in self.config:
-            return self.config[email_from_domain]
+                    for handler_name in pipeline:
+                        logger.info(f"Processing handler: {handler_name}")
+                        task = globals()[handler_name]()
+                        task.do(attachment)
 
-        raise FileNotFoundError
+                except Exception as e:
+                    logger.error(f"Ошибка при обработке файла {file_name}: {e}")
+                    attachment["error"] = e
+                    notifier = EmailForwardErrorTask()
+                    notifier.do(attachment)
+
+        else:
+            logger.info(f"Обработка писем для {email_sender} отключена. Значение в конфиге: {config.get("enabled")}")
+
+    def _load_config(self, sender_email) -> Dict[str, Any]:
+        if sender_email in self.config:
+            return self.config[sender_email]
+
+        sender_domain = EmailUtils.extract_domain(sender_email)
+        if sender_domain in self.config:
+            return self.config[sender_domain]
+
+        # Для всех ненастроенных клиентов возвращаем конфиг с "отключенной" обработкой
+        return {}
+
+    def parse_email(self, email):
+        # todo при переводе на основной ящик переделать на другую функцию
+        header_from = EmailUtils.extract_header(email, "From")
+        email_from = EmailUtils.extract_email(header_from)
+        # email_from = EmailUtils.extract_first_sender(email_body)
+        self.context.data["email_from"] = email_from
+
+        self.context.data["email_body"] = EmailUtils.extract_body(email)
+        self.context.data["email_from_domain"] = EmailUtils.extract_domain(email_from)
+        self.context.data["email_subj"] = EmailUtils.extract_header(email, "subject")
+        self.context.data["client"] = EmailUtils.extract_domain(email_from)
+        self.context.data["attachments"] = EmailUtils.extract_attachments(email)
+        logger.info(f"Извлечено вложений: {len(self.context.data["attachments"])}")
 
-        #path = os.path.join(self.configs_path, client + '.yml')
-        #with open(path, 'r', encoding='utf-8') as f:
-        #    return yaml.safe_load(f)