Sample Application - Spring Batch - page 344

import com.apress.springbatch.statement.domain.TransactionType;
import com.apress.springbatch.statement.exception.InvalidItemException;
public class CustomerLookupItemProcessor implements ItemProcessor<Object, Object> {
private CustomerDao customerDao;
private TickerDao tickerDao;
private AccountDao accountDao;
public Object process(Object curItem) throws Exception {
if(curItem instanceof Customer) {
doCustomerUpdate((Customer) curItem);
} else if(curItem instanceof Transaction){
doTransactionUpdate((Transaction) curItem);
} else {
throw new InvalidItemException("An invalid item was received: " + curItem);
}
return curItem;
}
private void doTransactionUpdate(Transaction curItem) {
updateTicker(curItem);
updateAccount(curItem);
curItem.setType(TransactionType.STOCK);
}
private void updateAccount(Transaction curItem) {
Account account = accountDao.findAccountByNumber(curItem.getAccountNumber());
curItem.setAccountId(account.getId());
}
private void updateTicker(Transaction curItem) {
Ticker ticker = tickerDao.findTickerBySymbol(curItem.getTicker());
if(ticker == null) {
Ticker newTicker = new Ticker();
newTicker.setTicker(curItem.getTicker());
tickerDao.saveTicker(newTicker);
ticker = tickerDao.findTickerBySymbol(curItem.getTicker());
}
curItem.setTickerId(ticker.getId());
}
private void doCustomerUpdate(Customer curCustomer) {
Customer storedCustomer = customerDao.findCustomerByTaxId(curCustomer.getTaxId());
Account account =
accountDao.findAccountByNumber(curCustomer.getAccount().getAccountNumber());