Subversion Repositories SmartDukaan

package com.smartdukaan.cron.migrations;

import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.util.Arrays;
import java.util.List;

import org.apache.commons.lang.StringUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import com.spice.profitmandi.dao.entity.transaction.LineItemImei;
import com.spice.profitmandi.dao.entity.transaction.Order;
import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;

@Component
@Transactional(rollbackFor = Throwable.class)
public class RunOnceTasks {

        private static final Logger LOGGER = LogManager.getLogger(RunOnceTasks.class);

        private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
        @Autowired
        private OrderRepository orderRepository;
        
        @Autowired
        private LineItemImeisRepository lineItemImeisRepository;

        public void migarateLineItemsToNewTable() {
                LOGGER.info("Before Migrated LineItems Successfully");
                LocalDateTime endDate = LocalDateTime.now();
                LocalDateTime startDate = LocalDateTime.of(LocalDate.of(2017, 07, 1), LocalTime.MIDNIGHT);
                List<Order> orders = orderRepository.selectAllByDatesBetween(startDate,  endDate);
                for (Order order : orders) {
                        String serialNumbers = order.getLineItem().getSerialNumber();
                        if(!StringUtils.isEmpty(serialNumbers)) {
                                List<String> serialNumberList = Arrays.asList(serialNumbers.split(","));
                                for(String serialNumber : serialNumberList) {
                                        int lineItemId=order.getLineItem().getId();
                                        LineItemImei lineItemImei = new LineItemImei();
                                        lineItemImei.setSerialNumber(serialNumber);
                                        lineItemImei.setLineItemId(lineItemId);
                                        lineItemImeisRepository.persist(lineItemImei);
                                }
                        } else {
                                LOGGER.info("Serial Numbers dont exist for Order {}", order.getId());
                        }
                }
                LOGGER.info("Migrated LineItems Successfully");
        }
}