diff --git a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
index 5499fd324..45b111e5b 100644
--- a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
+++ b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
@@ -13,6 +13,7 @@ import ru.clearing.classes.statics.data.misc.STrades;
 import ru.spcex.clearing.imdg.IMDGDistributedNames;
 import ru.spcex.clearing.platform.messaging.domain.cud.utilities.STradesImportedRequest;
 import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
+import ru.spcex.platform.enumeration.Side;
 import ru.spcex.platform.imdg.api.Imdg;
 import ru.spcex.platform.imdg.api.ImdgProvider;
 import ru.spcex.platform.utils.enumeration.EnumMessage;
@@ -122,6 +123,16 @@ public class TradeImporterService {
         }
     }
 
+    private static String mapOperation(String fromDb) {
+        if (fromDb == null) return null;
+        if ("Купля".equalsIgnoreCase(fromDb)) {
+            return Side.BUY.getKey();
+        } else if ("Продажа".equalsIgnoreCase(fromDb)) {
+            return Side.SELL.getKey();
+        }
+        return fromDb;
+    }
+
     public STrades getSTradesFromImdg(STrades tradesDb, Imdg<STrades> sTradesImdg) {
         return sTradesImdg.getSingleObjectByFieldValues(Map.of("tradeDate", tradesDb.getTradeDate(),
                 "tradeNum", tradesDb.getTradeNum(),
@@ -139,7 +150,8 @@ public class TradeImporterService {
     public STrades readSTrades(ResultSet resultSet) throws SQLException {
         STrades sTrades = new STrades();
         sTrades.setTradeNum(resultSet.getObject("TradeNum", Long.class));
-        sTrades.setOperation(resultSet.getObject("Operation", String.class));
+        String operation = resultSet.getObject("Operation", String.class);
+        sTrades.setOperation(mapOperation(operation));
         sTrades.setClassCode(resultSet.getObject("ClassCode", String.class));
         sTrades.setTradeDate(getLocalDateFromSqlDate(resultSet, "TradeDate"));
         sTrades.setSecCode(resultSet.getObject("SecCode", String.class));