Spring批处理创建多个文件。基于Gradle的项目

Question

我需要创建3个单独的文件。

我的批处理作业应该从Mongo读取，然后解析信息并找到“业务”列（3种业务类型：retAIL、HPP、SAX），然后为它们各自的业务创建一个文件。该文件应该创建任何一个retAIL formattedDate；HPP formattedDate；SAX formattedDate作为文件名和在txt文件中的DB中找到的信息。此外，我需要将.资源（new FileSystemResources（"C：\fileWrit\index.txt））设置为将信息发送到正确位置的东西，现在硬编码可以工作，但只创建一个. txt文件。

示例：

 @Bean
public FlatFileItemWriter<PaymentAudit> writer() {
    LOG.debug("Mongo-writer");      
    FlatFileItemWriter<PaymentAudit> flatFile = new 
    FlatFileItemWriterBuilder<PaymentAudit>()
            .name("flatFileItemWriter")
            .resource(new FileSystemResource("C:\\filewriter\\index.txt)) 
         //trying to create a path instead of hard coding it
            .lineAggregator(createPaymentPortalLineAggregator())
            .build();
    String exportFileHeader = 
   "CREATE_DTTM";
    StringHeaderWriter headerWriter = new 
    StringHeaderWriter(exportFileHeader);
    flatFile.setHeaderCallback(headerWriter);
    return flatFile;

}

我的想法是，但不确定要去哪里：

public Map<String, List<PaymentAudit>> getPaymentPortalRecords() {
List<PaymentAudit> recentlyCreated = 
PaymentPortalRepository.findByCreateDttmBetween(yesterdayMidnight,
        yesterdayEndOfDay);

List<PaymentAudit> retailList = new ArrayList<>();
List<PaymentAudit> saxList = new ArrayList<>();
List<PaymentAudit> hppList = new ArrayList<>();
//String exportFilePath = "C://filewriter/";??????
recentlyCreated.parallelStream().forEach(paymentAudit -> {
    if (paymentAudit.getBusiness().equalsIgnoreCase(RETAIL)) {
        retailList.add(paymentAudit);
    } else if 
(paymentAudit.getBusiness().equalsIgnoreCase(SAX)) {
        saxList.add(paymentAudit);
    } else if 
(paymentAudit.getBusiness().equalsIgnoreCase(HPP)) {
        hppList.add(paymentAudit);
    }
});

Answer 1

要为每个业务对象类型创建文件，可以使用ClassifierCompositeItemWriter。在您的情况下，可以为每种类型创建一个编写器，并将它们作为委托添加到复合项编写器中。

根据动态创建文件名，您需要使用步骤范围的编写器。参考文档的步骤范围部分中有一个示例。

希望这有帮助。