etreschenkov 2023-07-07 14:07:10 +03:00
parent 02b870f95b
commit ac10bc4fb2

View file

@ -2,7 +2,6 @@ package ru.spcex.clearing.swt.exporter.services.exportimpl;
import com.hazelcast.aws.utility.StringUtil;
import org.springframework.stereotype.Service;
import ru.clearing.classes.statics.data.sdf.SDf11;
import ru.clearing.classes.statics.data.sdf.SDf12;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
@ -59,8 +58,6 @@ public class DF12Exporter extends AbstractExporterService<SDf12> {
@Override
protected String convertRecord(SDf12 record, ConvertionContext context) {
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.append(context.getCountOfRecord()).append(lineSeparator);
stringBuilder.append(context.getTotalCountOfRecords()).append(lineSeparator);
if (!Objects.equals(lastHeader20, record.getOutDocument())) { // header
stringBuilder.append(":20:").append(record.getOutDocument()).append(lineSeparator);
lastHeader20 = record.getOutDocument();
@ -70,6 +67,8 @@ public class DF12Exporter extends AbstractExporterService<SDf12> {
stringBuilder.append(":35B:ISIN ").append(record.getSecurityCode()).append(lineSeparator);
stringBuilder.append(":82D:").append(record.getDepoCodeSender()).append(lineSeparator);
stringBuilder.append(":87C:").append(record.getDepoCodeAdressee()).append(lineSeparator);
stringBuilder.append(context.getCountOfRecord()).append(lineSeparator);
stringBuilder.append(context.getTotalCountOfRecords()).append(lineSeparator);
return stringBuilder.toString();
}
@ -99,7 +98,5 @@ public class DF12Exporter extends AbstractExporterService<SDf12> {
protected void writeFooter(PrintWriter out, Collection<SDf12> records, int counter) {
String footerCheckSum = counter + lineSeparator + records.size() + lineSeparator;
out.print(footerCheckSum);
String shsCheckSum = "SHS" + countIssues(records);
out.print(shsCheckSum);
}
}