refactoring SDF*executors

clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java

@@ -61,6 +61,7 @@ public class StatementService extends QueueConsumer implements InitializingBean
                 .forDestination(Consts.STATEMENT_PROCESS, callbacks::put);
         init();
     }
+
     private void process(BaseRequest<StatementRequest> systemRequest) {
         StatementRequest statementRequest = systemRequest.getRequestPayload();
         Collection<? extends SpcexObjectBase> sdfGroup;
@@ -75,19 +76,16 @@ public class StatementService extends QueueConsumer implements InitializingBean
                     .map(part -> sdfImdg.getSingleObjectByID(part.getSdfId()))
                     .collect(Collectors.toList());
         }
-//        sdf01Group = sdf01Group
+
-//                .stream()
-//                .sorted(Comparator.comparing(SpcexObjectBase::getId))
-//                .collect(Collectors.toList());
         AbstractExecutor service = executorsMap.get(table);
         Result res = service.execute(sdfGroup, statementRequest);
-        if (res.getAccountRequests().size() == 0) {
+        if (res.getAccountRequests().size() != 0) {
+            kafkaSender.sendRequestToQueue(Consts.ACCOUNT_NEW_SDF01, createAccountsRequest(statementRequest.getGroupId(), res.getAccountRequests()));
+        } else if (service.isNeedToSendCommandToExport()) {
             ExportToFileRequest exportRequest = new ExportToFileRequest();
             exportRequest.setSdfGroupId(res.getGenerationId());
             exportRequest.setNameOfTable(service.exportTableName());
             kafkaSender.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest);
-        } else {
-            kafkaSender.sendRequestToQueue(Consts.ACCOUNT_NEW_SDF01, createAccountsRequest(statementRequest.getGroupId(), res.getAccountRequests()));
         }
     }
 
@@ -97,12 +95,4 @@ public class StatementService extends QueueConsumer implements InitializingBean
         r.setAccounts(accountRequests);
         return r;
     }
-
-    private Imdg<?> defineImdgByTableName(SdfTable table){
-        switch (table){
-            case SDF_01 -> imdgProvider.getImdg(IMDGDistributedNames.Map_SDf01, SDf01.class);
-            case SDF_57 -> imdgProvider.getImdg(IMDGDistributedNames.Map_SDf57, SDf57.class);
-        }
-        return null;
-    }
 }

clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/AbstractExecutor.java

@@ -8,4 +8,5 @@ import java.util.Collection;
 public abstract class AbstractExecutor<T> {
     public abstract Result execute(Collection<T> sdf, StatementRequest statementRequest);
     public abstract String exportTableName();
+    public abstract boolean isNeedToSendCommandToExport();
 }

clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf01Executor.java

@@ -64,6 +64,11 @@ public class Sdf01Executor extends AbstractExecutor<SDf01> {
         return "DF-02";
     }
 
+    @Override
+    public boolean isNeedToSendCommandToExport() {
+        return true;
+    }
+
     public Result execute(Collection<SDf01> sdf, StatementRequest statementRequest) {
         Result result = new Result();
         Long generationIdForGroup = imdgProvider.getImdgIdGenerator().nextId();

clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf57Executor.java

@@ -65,8 +65,13 @@ public class Sdf57Executor extends AbstractExecutor<SDf57> {
 
     @Override
     public String exportTableName() {
-        return "DF-57";
+        return null;
-    } //no need...
+    }
+
+    @Override
+    public boolean isNeedToSendCommandToExport() {
+        return false;
+    }//no need...
 
     //V - Изменение statement по sDf57
     //