From aa15b344b17474fdc45047f645cf83c9a8ecc3ba Mon Sep 17 00:00:00 2001
From: psemenkov <psemenkov@mfd.ru>
Date: Fri, 12 May 2023 18:08:57 +0300
Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-276=20?=
 =?UTF-8?q?=D0=94=D0=B1=D0=B0=D0=B2=D0=B8=D0=BB=20=D0=BE=D0=B1=D1=80=D0=B0?=
 =?UTF-8?q?=D0=B1=D0=BE=D1=82=D0=BA=D1=83=20=D0=BF=D0=BE=D0=BB=D0=B5=D0=B9?=
 =?UTF-8?q?=20=D1=81=D0=BE=D0=B7=D0=B4=D0=B0=D0=BD=D0=B8=D1=8F=20=D0=B7?=
 =?UTF-8?q?=D0=B0=D0=BF=D0=B8=D1=81=D0=B8=20STrades=20=D0=B8=20=D0=B5?=
 =?UTF-8?q?=D0=B5=20=D0=B0=D0=BF=D0=B4=D0=B5=D0=B9=D1=82=D0=B0.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../trade/importer/services/TradeImporterService.java     | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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 551119d24..496b4b391 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
@@ -55,12 +55,18 @@ public class TradeImporterService {
     public void process(boolean byCommand) {
         log.debug("Start process import STrades from DB");
         Collection<STrades> tradesFromDB = jdbcTemplate.query("SELECT * FROM Trades", (resultSet, i) -> readSTrades(resultSet));
+        Instant currentInstant = Instant.now();
 
         log.debug("load from DB STrades: {}", tradesFromDB.size());
         for (STrades tradesDb : tradesFromDB) {
             if (isValidTrades(tradesDb)) {
                 STrades sTrades = getSTradesFromImdg(tradesDb, sTradesImdg);
-                if (sTrades != null) tradesDb.setId(sTrades.getId());
+                if (sTrades != null) {
+                    tradesDb.setId(sTrades.getId());
+                    tradesDb.setUpdated(currentInstant);
+                } else {
+                    tradesDb.setCreated(currentInstant);
+                }
                 sTradesImdg.insert(tradesDb);
             } else {
                 log.warn(messageResolver.resolve(new EnumMessage(sTradesNotValid, tradesDb.getTradeNum())));