无法使用Apache Camel Bindy

编程问答 2022-06-22

问题描述

我正在尝试创建带有页眉和页脚记录以及json有效内容作为主体的文件。 页眉和页脚属性值将基于时间戳和记录总数而动态变化 （目前，我正计划使用属性的静态值来实现）。 我正在使用FixedLengthDataFormat实现此目的。 但是，页眉和页脚记录未添加到文件中，该文件仅具有json有效内容作为主体。 有人可以帮助我实现这一目标吗？

我已经复制了下面的所有课程文件。

@Component
public class EmployeePackageRoute extends RouteBuilder {

    @Autowired
    private Header header;
    
    private Trailer footer;
    
    @SuppressWarnings("deprecation")
    @Override
    public final void configure() {
        System.out.println("fetching employee details from employee api");
        try {
            
            from("jetty://http://localhost:8084/employee-package/getEmployee")
            .unmarshal().json(JsonLibrary.Jackson,RecurringPaymentResults.class)
            .process(
                    ex -> {
                        System.out.println("+++++++++++++++++ "+ex.getIn().getBody());
                        RecurringPaymentResults result = ex.getIn().getBody(RecurringPaymentResults.class);
                        List<RecurringPaymentsDeduct> employee = result.getResults();
                        ex.getOut().setBody(employee);
                        System.out.println("**** Header ** "+header);
                    })
            .to("seda:employeeFeed");
            
            final DataFormat bindy = new BindyFixedLengthDataFormat(RecurringPaymentsDeduct.class);
            
            footer = new Trailer("TRAILER",3);
            
            Map<String,Object> headerObjMap = new HashMap<String,Object>();
            headerObjMap.put(Header.class.getName(),header);
            
            Map<String,Object> footerObjMap = new HashMap<String,Object>();
            footerObjMap.put(Trailer.class.getName(),footer);
            
            from("seda:employeeFeed")
            .log("process csv")
            .marshal(bindy)
            .log("csv processed")
            .process(
                    ex -> {
                        System.out.println("******************** "+ex.getIn().getBody());
                        
                        //ex.getOut().setHeader("header",header);
                        ex.getOut().setHeader(BindyFixedLengthDataFormat.CAMEL_BINDY_FIXED_LENGTH_HEADER,headerObjMap);
                        ex.getOut().setBody(ex.getIn().getBody());
                        ex.getOut().setHeader(BindyFixedLengthDataFormat.CAMEL_BINDY_FIXED_LENGTH_FOOTER,footerObjMap);
                        
                    }).to("file://C:\Users\testfolder?fileName=test.txt")
            .end();
            
                        
        } catch(Exception e) {
            System.out.println("Error occurred while processing employee data: "+e.getMessage());
            e.printStackTrace();
        }
    }
}

    @Data
    @Section(number = 2)
    @FixedLengthRecord(header = Header.class,footer = Trailer.class)
    public class RecurringPaymentsDeduct implements Serializable {
    
        private static final long serialVersionUID = 1L;
        
        @DataField(pos = 1,length = 10)
        public String RECTY;
        
        @DataField(pos = 2,length = 10)
        public String CLIID;
        
        @DataField(pos = 3,length = 10)
        public String INTCA;
        
        @DataField(pos = 4,length = 10)
        public String ORDNO;
        
        @DataField(pos = 5,length = 10)
        public String IOPER;
        
        @DataField(pos = 6,length = 10)
        public String INFTY;
        
        @DataField(pos = 7,length = 10)
        public String SUBTY;
        
        @DataField(pos = 8,length = 10)
        public String BEGDA;
        
        @DataField(pos = 9,length = 10)
        public String ENDDA;
        
        @DataField(pos = 10,length = 10)
        public String OBJPS;
        
    }


@Configuration
@EnableConfigurationProperties
@ConfigurationProperties("test")
@Data
@Section(number = 1)
@FixedLengthRecord()
public class Header implements Serializable {

    private static final long serialVersionUID = 1L;

    @DataField(pos = 1,length = 5)
    private String header1;
    
    @DataField(pos = 2,length = 5)
    private String header2;
    
    @DataField(pos = 3,length = 15)
    private String header3;
    
    @DataField(pos = 4,length = 60)
    private String header4;
    
    @DataField(pos = 5,length = 15)
    private String header5;
    
    @DataField(pos = 6,length = 30)
    private String header6;
    
    @DataField(pos = 7,length = 30)
    private String header7;
    
    @DataField(pos = 8,length =  8,pattern = "YYYYMMDD")
    private String header8;
    
    @DataField(pos = 9,length = 6)
    private String header9;
    
    @DataField(pos = 10,length = 1)
    private String header10;
    
    @DataField(pos = 11,length = 2)
    private String header11;
    
    @DataField(pos = 12,length = 10)
    private String header12;
    
    @DataField(pos = 13,length = 10)
    private String header13;
    
    @DataField(pos = 14,length = 10)
    private String header14;
}


@Section(number = 3)
@FixedLengthRecord
public class Trailer implements Serializable {

    private static final long serialVersionUID = 1L;

    @DataField(pos = 1,length = 7)
    private String trailer;
    
    @DataField(pos = 2,length = 2)
    private int count;
    
    public String getTrailer() {
        return trailer;
    }
    public void setTrailer(String trailer) {
        this.trailer = trailer;
    }
    public int getCount() {
        return count;
    }
    public void setCount(int count) {
        this.count = count;
    }
}

解决方法

我找到了答案。 该解决方案解决了我在各个阶段遇到的许多问题。

问题1）使用BindyFixedLengthDataFormat将动态页眉和页脚添加到平面文件中。顾名思义，它是固定长度。生成主体后，我必须分配最大长度并修剪空白。 （我仍然可能需要使用其他类或方法来修剪空白）。

问题2）我需要用|“替换管道定界符。

问题3）我使用了rest配置，以便不再使用硬编码来主机名，并且可以将其部署到任何环境，而不是使用jetty公开将进行硬编码的端点url。

    @Component
    public class EmployeePackageRoute extends RouteBuilder {
    
        @Autowired
        private Header header;
        
        private Trailer footer;
        
        private String file_name;
        
        @SuppressWarnings("deprecation")
        @Override
        public final void configure() {
            
            System.out.println("fetching employee details from employee api");
            
            final SimpleDateFormat TARGET_DATE_FORMAT = new SimpleDateFormat("YYYYMMDDHHMMSS");
            String date = TARGET_DATE_FORMAT.format(new Date());
            
            String year = date.substring(0,8);
            String hr = date.substring(9,13);
    
            try {
                restConfiguration().component("jetty").port(8000).bindingMode(RestBindingMode.json);
                rest("/api/test/getTestResponse")
                .get().consumes(MediaType.APPLICATION_JSON_VALUE).route().setBody().constant("return test response");
                
                rest("/api/bcr/recurringPaymentsDeduct")
                .post().consumes(MediaType.APPLICATION_JSON_VALUE).type(RecurringPaymentResults.class).outType(ResponseEntity.class).route()
                .process(
                        ex -> {
                            
                            RecurringPaymentResults result = ex.getIn().getBody(RecurringPaymentResults.class);
                            List<RecurringPaymentsDeduct> employee = result.getResults();
                            file_name = Constants.FILE_NUMBER_DEV+"_"+date+"_"+Constants.AUMBCR_HRMD+result.getSequenceNumber()+"_"+Constants.DUT8G2I+".SAP";
                            header.setHeader7(Constants.FILE_NUMBER_DEV+"_"+date+"_"+Constants.AUMBCR_HRMD+result.getSequenceNumber()+"_"+Constants.DUT8G2I+".SAP");
                            
                            header.setHeader8(year);
                            header.setHeader9(hr);
                            header.setHeader10(Constants.ENVIRONMENT);
                            
                            footer = new Footer("Footer",(employee.size()+2));
                            
                            ex.getOut().setBody(employee);
                        })
                .to("seda:recurringPaymentsFeed");
                
                final DataFormat recurringPaymentsBindy = new BindyFixedLengthDataFormat(RecurringPaymentsDeduct.class);
                
                from("seda:recurringPaymentsFeed")
                .startupOrder(2)
                .log("add footer to the file")
                .process(
                        ex -> {
                            
                            Map<String,Object> headerObjMap = new HashMap<String,Object>();
                            headerObjMap.put(Header.class.getName(),header);
                            System.out.println(" *** file_name 1 - "+file_name);
                            Map<String,Object> footerObjMap = new HashMap<String,Object>();
                            footerObjMap.put(Footer.class.getName(),footer);
                            
                            ex.getOut().setHeader(BindyFixedLengthDataFormat.CAMEL_BINDY_FIXED_LENGTH_HEADER,headerObjMap);
                            ex.getOut().setBody(ex.getIn().getBody());
                            ex.getOut().setHeader(BindyFixedLengthDataFormat.CAMEL_BINDY_FIXED_LENGTH_FOOTER,footerObjMap);
                            
                        })
                .marshal(recurringPaymentsBindy)
                .convertBodyTo(byte[].class,"iso-8859-1")
                .setBody(body().regexReplaceAll("\\|","\\|\""))
                .log("csv processed")
                .to("file://app/bcr-files?fileName=recurringPaymentsDeduct.SAP")
                .end();
                
                
            } catch(Exception e) {
                System.out.println("Error occurred while processing employee data: "+e.getMessage());
                e.printStackTrace();
            }
        }
        
    }

@Data
@Section(number = 2)
@FixedLengthRecord(header = Header.class,footer = Trailer.class)
public class RecurringPaymentsDeduct implements Serializable {

    private static final long serialVersionUID = 1L;
    
    @DataField(pos = 1,length = 10,delimiter = "|",trim = true)
    public String RECTY;
    
    @DataField(pos = 2,trim = true)
    public String CLIID;
    
    @DataField(pos = 3,trim = true)
    public String INTCA;
    
    @DataField(pos = 4,trim = true)
    public String ORDNO;
    
    @DataField(pos = 5,trim = true)
    public String IOPER;
    
    @DataField(pos = 6,trim = true)
    public String INFTY;
    
    @DataField(pos = 7,trim = true)
    public String SUBTY;
    
    @DataField(pos = 8,trim = true)
    public String BEGDA;
    
    @DataField(pos = 9,trim = true)
    public String ENDDA;
    
    @DataField(pos = 10,trim = true)
    public String OBJPS;
        
}

@Configuration
@EnableConfigurationProperties
@ConfigurationProperties("adp")
@Data
@Section(number = 1)
@FixedLengthRecord()
public class Header implements Serializable {

    private static final long serialVersionUID = 1L;

    @DataField(pos = 1,length = 5,trim = true)
    private String header1;
    
    @DataField(pos = 2,trim = true)
    private String header2;
    
    @DataField(pos = 3,length = 15,trim = true)
    private String header3;
    
    @DataField(pos = 4,length = 60,trim = true)
    private String header4;
    
    @DataField(pos = 5,trim = true)
    private String header5;
    
    @DataField(pos = 6,length = 30,trim = true)
    private String header6;
    
    @DataField(pos = 7,trim = true)
    private String header7;
    
    @DataField(pos = 8,length =  8,pattern = "YYYYMMDD",trim = true)
    private String header8;
    
    @DataField(pos = 9,length = 6,trim = true)
    private String header9;
    
    @DataField(pos = 10,length = 1,trim = true)
    private String header10;
    
    @DataField(pos = 11,length = 2,trim = true)
    private String header11;
    
    @DataField(pos = 12,trim = true)
    private String header12;
    
    @DataField(pos = 13,trim = true)
    private String header13;
    
    @DataField(pos = 14,align = "L",trim = true)
    private String header14;
}

@Data
@Section(number = 3)
@FixedLengthRecord()
public class Footer implements Serializable {

    private static final long serialVersionUID = 1L;

    @DataField(pos = 1,length = 7,trim = true)
    private String trailer;
    
    @DataField(pos = 2,trim = true)
    private int count;
    
    public Footer() {
        
    }
    
    public Footer(String trailer,int count) {
        this.trailer = trailer;
        this.count = count;
    }
}
apache-camelapache-commonsbindyjavajavaspring-boot

相关问答

matplotlib报错：AttributeError: module 'backend_interagg' has no attribute 'FigureCanvas'. Did you mean: 'FigureCanvasAgg'?
使用本地python环境可以成功执行 import pandas as pd impor...
gitlab登录失败，报错：This challenge page was accidentally cached by an intermediary and is no longer available.
设置时间 控制面板
后端开发常见错误
错误1：Request method ‘DELETE‘ not supported 错误还原：...
docker常见错误
错误1：启动docker镜像时报错：Error response from daemon:...
idea常见错误
错误1：private field ‘xxx‘ is never assigned 按Alt...
pip安装依赖失败
报错如下，通过源不能下载，最后警告pip需升级版本 Requirem...