如何使用Camel Bindy生成带有页眉和页脚的平面文件

提问者：小点点

如何使用Camel Bindy生成带有页眉和页脚的平面文件

目前，我能够使用 Camel Bindy 从 POJO 生成平面文件，但无法将页眉和页脚添加到完整文件中。

但是当我尝试向文件添加页眉/页脚时，它正在添加到每条记录中，但我需要向整个文件而不是文件中的每条记录添加一个页眉/页脚。

下面是代码段：

from("jpa:com.PACKAGENAME.RebatePayout?consumer.namedQuery=REBATE_PAYOUT&consumer.delay=500000&consumeLockEntity=true&consumeDelete=false")
    .routeId("rebateroute")
    .process(new Processor() {
        RebateOutputgenerator rop = new RebateOutputgenerator();
                @Override
                public void process(Exchange exchange) throws Exception {
                    exchange.getIn().setBody(rop.processEntities((RebatePayout) exchange.getIn().getBody()));
                    log.info("the exchange value is ", exchange);                         
                }
        })
        .process(new FahHeaderAndFooterHelper())
        .log("Fixed length format marshal....")
        .marshal(fixedLegth)
        .log("Fixed length format data....${body}")
        .to("file://C:/Users/vvakalap/Desktop/example/New folder?fileExist=Append&fileName=output.txt")
        .log("Data Saved in file...");

进程类为

public class FahHeaderAndFooterHelper implements Processor{
    @Override
    public void process(Exchange exchange) throws Exception {
        Map<String, Object> headerObjMap = new HashMap<String,Object>();
        headerObjMap.put(FahRecordHeader.class.getName(), new FahRecordHeader());
        if(exchange.getOut().getBody() == "null")
            exchange.getOut().setHeader(CAMEL_BINDY_FIXED_LENGTH_HEADER, headerObjMap);
        Map<String, Object> footerObjMap = new HashMap<String,Object>();
        footerObjMap.put(FahRecordFooter.class.getName(), new FahRecordFooter());
        exchange.getOut().setHeader(CAMEL_BINDY_FIXED_LENGTH_FOOTER, footerObjMap);
        exchange.getOut().setBody(exchange.getIn().getBody());
    }

POJO类

@Data
@Section(number=2)
@FixedLengthRecord(header = FahRecordHeader.class, footer = FahRecordFooter.class)
public class RebateFinalRecord implements Serializable {

    private static final long serialVersionUID = 7375828620208233805L;

    @DataField(pos = 1, length = 3)
    private String transactionRecordIdentifier;

    @DataField(pos = 4, length = 10)
    private String transactionNumber;

    @DataField(pos = 14, length = 5)
    private String transactionLineNumber;

    @DataField(pos = 19, length = 20)
    private String transactionDistributionType;

    @DataField(pos = 39, length = 30)
    private String eventTypeName;

    @DataField(pos = 69, length = 8)
    private String transactionDate;

    @DataField(pos = 77, length = 8)
    private String transactionEffectiveDate;

    @DataField(pos = 85, length = 5)
    private String transactingEntityValue;

    @DataField(pos = 90, length = 1)
    private String reciprocationFlag;

}

Bindy类

@Data
public class FahRecordHeader {
    @DataField(pos = 1, length = 3)
    private String fileRecordIdentifier = "000";
    @DataField(pos = 4, length = 15)
    private String controlIdentifierOrSequenceNumber = "LSCD00000000006";
    @DataField(pos = 19, length = 20)
    private String source = "LSCD";
}

@Data
public class FahRecordFooter {

    @DataField(pos = 1, length = 70)
    private String footer = "footervalusforfahrecord for cashrebates";
    /*
     * @DataField(pos = 2, length = 9, align = "R", paddingChar = &#39;0&#39;)
     * private int numberOfRecordsInTheFile;
     */
}

共3个答案

匿名用户

创建一个helper方法，该方法返回MyClass的所有声明字段:

import java.lang.reflect.Field

class AnnotationUtil {

    public static Field[] getDeclaredFields(Class clazz, boolean recursively) {
        List<Field> fields = new LinkedList<Field>();
        Field[] declaredFields = clazz.getDeclaredFields();
        Collections.addAll(fields, declaredFields);

        Class superClass = clazz.getSuperclass();

        if(superClass != null && recursively) {
            Field[] declaredFieldsOfSuper = getDeclaredFields(superClass, recursively);
            if(declaredFieldsOfSuper.length > 0)
                Collections.addAll(fields, declaredFieldsOfSuper);
        }

        return fields.toArray(new Field[fields.size()]);
    }
}

@CsvRecord(separator = "|",  generateHeaderColumns = false)
class MyClass {

    @DataField(pos = 1, columnName = "Column1")
    String orderName;

    @DataField (pos = 2, columnName = "Column2")
    String transactionId
}

然后创建一个处理器：

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.dataformat.bindy.annotation.DataField;
import org.springframework.stereotype.Component;

import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.Arrays;
import java.util.stream.Collectors;

@Component
class CSVHeaderProcessor implements Processor{
    @Override
    public void process(Exchange exchange) throws Exception {
       String fullFilePath = (String) exchange.getIn().getHeader("CSV_FILE_LOCATION");
        String header;
        File csvFile = new File(fullFilePath);

        if(!csvFile.exists()) {
            String headerRow = Arrays.stream((AnnotationUtil.getDeclaredFields(YourClass.class, false))).map(x -> x.getAnnotation(DataField.class).columnName()).collect( Collectors.joining( "," ));
            Files.write(Paths.get(csvFile.getPath()), headerRow.getBytes());
        }

    }
}

然后在您的路线中使用它：

 from("direct:handleCSV")
     .setHeader("CSV_FILE_LOCATION", simple("/tmp/yourfile.csv"))
     .process(csvHeaderProcessor)
     .marshal(bindy)
 .to("file:///tmp?fileName=yourfile.csv&fileExist=append")

匿名用户

您是否尝试将@FixedLengthRecord的 hasHeader 和 hasFooter 属性设置为 true？

@FixedLengthRecord(header = FahRecordHeader.class, 
                   footer = FahRecordFooter.class, 
                   hasHeader = true, 
                   hasFooter = true)

请参阅 https://camel.apache.org/bindy.html#Bindy-4.FixedLengthRecord。

匿名用户

这是在很长一段时间之后，但也许它仍然可以提供帮助。

您可以在FahHeaderAndFurterHelper条件中添加何时添加CAMEL_BINDY_FIXED_LENGTH_HEADER和CAMEL_BINDY_FIXED_LENGTH_FOOTER标头。

例如，如果文件不存在或文件头为空，以及某些条件下文件被认为是完整的。