batch polishing

Author: cppwfs

Diff for: bestcust/src/main/java/io/spring/s1bestcust/config/BestCustomerConfiguration.java

@@ -91,7 +91,7 @@ public FlatFileItemReader<BillEntry> reader(BestCustomerProperties properties)
 
 		DelimitedLineTokenizer tokenizer = new DelimitedLineTokenizer();
 		tokenizer.setDelimiter(",");
-		tokenizer.setNames(new String[]{ "id", "firstName", "lastName", "planId", "planName", "callPrice", "dataPrice", "usageInMinutes", "usageInBytes", "dataBillAmount", "callBillAmount", "totalBillAmount" });
+		tokenizer.setNames(new String[]{ "id", "firstName", "lastName", "planId", "totalBillAmount" });
 
 		DefaultLineMapper lineMapper = new DefaultLineMapper<BillEntry>();
 		lineMapper.setLineTokenizer(tokenizer);

Diff for: billrun/src/main/java/io/spring/billrun/config/BillrunConfiguration.java

@@ -60,7 +60,7 @@ public BillrunProperties properties() {
 	}
 
 	@Bean
-	public Job billRunJob(BillrunProperties properties, Step step) {
+	public Job billRunJob(Step step) {
 		return jobBuilderFactory
 				.get("billRunJob")
 				.incrementer(new RunIdIncrementer())
@@ -70,7 +70,7 @@ public Job billRunJob(BillrunProperties properties, Step step) {
 	}
 
 	@Bean
-	public Step step(BillrunProperties properties, ItemReader itemReader,
+	public Step step(ItemReader itemReader,
 			ItemProcessor itemProcessor,
 			ItemWriter itemWriter) {
 		return stepBuilderFactory.get("step1").<BillEntry, BillEntry>chunk(5)
@@ -81,7 +81,7 @@ public Step step(BillrunProperties properties, ItemReader itemReader,
 	}
 
 	@Bean
-	public ItemReader<BillEntry> reader(BillrunProperties properties) {
+	public ItemReader<BillEntry> reader() {
 		return new JdbcCursorItemReaderBuilder<BillEntry>()
 				.dataSource(this.dataSource)
 				.name("creditReader")
@@ -111,7 +111,7 @@ public ItemWriter<BillEntry> writer(BillrunProperties properties) {
 				.encoding("UTF-16")
 				.saveState(false)
 				.shouldDeleteIfEmpty(true)
-				.append(true)
+				.append(false)
 				.forceSync(true)
 				.shouldDeleteIfEmpty(true)
 				.transactional(false)

Diff for: billrun/src/main/java/io/spring/billrun/entity/BillEntry.java

@@ -18,16 +18,27 @@
 
 public class BillEntry {
 	private int userId;
+
 	private String firstName;
+
 	private String lastName;
+
 	private int planId;
+
 	private String planName;
+
 	private double callPrice;
+
 	private double dataPrice;
+
 	private int usageInMinutes;
+
 	private int usageInBytes;
+
 	private double dataBillAmount;
+
 	private double callBillAmount;
+
 	private double totalBillAmount;
 
 	public int getUserId() {