Subversion Repositories SmartDukaan

package com.smartdukaan.cron.migrations;

import com.spice.profitmandi.dao.entity.transaction.Order;
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
import com.spice.profitmandi.service.transaction.invoicing.InvoiceService;
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.Propagation;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * Re-files the e-invoice for an invoice NIC rejected (irn_generated = 0) once its data is corrected. The reset to
 * pending and the filing happen in one transaction: the scheduled IRN job only sees committed pending invoices, so it
 * cannot race this one, and a fresh process reads the corrected item master rather than a cached copy.
 */
@Component
public class IrnRetrier {

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

    @Autowired
    private OrderRepository orderRepository;

    @Autowired
    private InvoiceService invoiceService;

    /** Returns the invoice's irn_generated afterwards; on any failure everything rolls back to how it was. */
    @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Throwable.class)
    public Boolean retry(String invoiceNumber) throws Exception {
        List<Order> orders = orderRepository.selectByInvoiceNumber(invoiceNumber);
        if (orders.isEmpty()) {
            throw new IllegalArgumentException("No orders for invoice " + invoiceNumber);
        }
        if (!Boolean.FALSE.equals(orders.get(0).isIrnGenerated())) {
            throw new IllegalStateException(invoiceNumber + " is not a rejected e-invoice (irn_generated="
                    + orders.get(0).isIrnGenerated() + ")");
        }
        for (Order order : orders) {
            order.setIrnGenerated(null);
        }
        invoiceService.saveInvoice(orders);
        Boolean result = orders.get(0).isIrnGenerated();
        if (!Boolean.TRUE.equals(result)) {
            throw new IllegalStateException(invoiceNumber + " still not filed (irn_generated=" + result + ")");
        }
        return result;
    }

    public void retryAll(List<String> invoiceNumbers) {
        for (String invoiceNumber : invoiceNumbers) {
            try {
                LOGGER.info("IRN RETRY {} : irn_generated={}", invoiceNumber, this.self().retry(invoiceNumber));
            } catch (Exception e) {
                LOGGER.error("IRN RETRY {} FAILED, left as it was - {}", invoiceNumber, e.getMessage(), e);
            }
        }
    }

    @Autowired
    private IrnRetrier self;

    private IrnRetrier self() {
        return self;
    }
}