Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.time.LocalDateTime;
import java.util.List;

import javax.servlet.http.HttpServletRequest;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import com.spice.profitmandi.common.enumuration.SchemeType;
import com.spice.profitmandi.common.web.client.RestClient;
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
import com.spice.profitmandi.dao.entity.fofo.Purchase;
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
import com.spice.profitmandi.service.scheme.SchemeService;
import com.spice.profitmandi.web.util.MVCResponseSender;

@Controller
@Transactional(rollbackFor=Throwable.class)
public class CronController {

        @Autowired
        PurchaseRepository purchaseRepository;

        @Autowired
        SchemeService schemeService;

        @Autowired
        FofoOrderRepository fofoOrderRepository;
        
        @Autowired
        private RestClient restClient;

        @Autowired
        private MVCResponseSender mvcResponseSender;
        
        @Value("${prod}")
        private boolean prod;
        

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

        @Scheduled(cron = "0 45 6 * * *")
        public void executeJob() throws Exception {
                if(prod) {
                        String uri = "/cron/process-schemes";
                        restClient.get(SchemeType.HTTP, "localhost", 8080, uri, null);
                }
        }
        
        @RequestMapping(value = "/cron/process-schemes", method = RequestMethod.GET)
        public String createScheme(HttpServletRequest request, Model model) throws Exception {
                LocalDateTime fromDate = LocalDateTime.now().minusDays(15);
                LOGGER.info("Started execution at {}", LocalDateTime.now());
                List<Purchase> purchases = purchaseRepository.selectFromPurchaseCompleteDate(fromDate);
                for (Purchase purchase : purchases) {
                        try {
                                schemeService.processSchemeIn(purchase.getId(), purchase.getFofoId());
                        } catch (Exception e) {
                                LOGGER.error("Error while processing purchase {} for scheme In ", purchase.getId());
                                e.printStackTrace();
                                
                        }
                }
                List<FofoOrder> fofoOrders = fofoOrderRepository.selectFromSaleDate(fromDate);
                for (FofoOrder fofoOrder: fofoOrders) {
                        try {
                                schemeService.processSchemeOut(fofoOrder.getId(), fofoOrder.getFofoId());
                        } catch (Exception e) {
                                LOGGER.error("Error while processing sale order {} for scheme Out", fofoOrder.getId());
                        }
                }
                model.addAttribute("response", mvcResponseSender.createResponseString(true));
                return "response";
        }

}