Subversion Repositories SmartDukaan

Rev

Rev 23506 | Rev 23530 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 23506 Rev 23511
Line 1... Line 1...
1 
package com.spice.profitmandi.web.controller;
 1 
package com.spice.profitmandi.web.controller;
2 
 
 2 
 
3 
import java.time.LocalDateTime;
 3 
import java.time.LocalDateTime;
- 
 
 4 
import java.util.ArrayList;
4 
import java.util.List;
 5 
import java.util.List;
5 
 
 6 
 
6 
import javax.servlet.http.HttpServletRequest;
 7 
import javax.servlet.http.HttpServletRequest;
7 
 
 8 
 
8 
import org.slf4j.Logger;
 9 
import org.slf4j.Logger;
Line 15... Line 16...
15 
import org.springframework.ui.Model;
 16 
import org.springframework.ui.Model;
16 
import org.springframework.web.bind.annotation.RequestMapping;
 17 
import org.springframework.web.bind.annotation.RequestMapping;
17 
import org.springframework.web.bind.annotation.RequestMethod;
 18 
import org.springframework.web.bind.annotation.RequestMethod;
18 
 
 19 
 
19 
import com.spice.profitmandi.common.enumuration.SchemeType;
 20 
import com.spice.profitmandi.common.enumuration.SchemeType;
20 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 - 
 
21 
import com.spice.profitmandi.common.web.client.RestClient;
 21 
import com.spice.profitmandi.common.web.client.RestClient;
- 
 
 22 
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
22 
import com.spice.profitmandi.dao.entity.fofo.Purchase;
 23 
import com.spice.profitmandi.dao.entity.fofo.Purchase;
- 
 
 24 
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
23 
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 25 
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
- 
 
 26 
import com.spice.profitmandi.service.order.OrderService;
24 
import com.spice.profitmandi.service.scheme.SchemeService;
 27 
import com.spice.profitmandi.service.scheme.SchemeService;
25 
import com.spice.profitmandi.web.util.MVCResponseSender;
 28 
import com.spice.profitmandi.web.util.MVCResponseSender;
26 
 
 29 
 
27 
@Controller
 30 
@Controller
28 
@Transactional
 31 
@Transactional(rollbackFor=Throwable.class)
29 
public class CronController {
 32 
public class CronController {
30 
 
 33 
 
31 
	@Autowired
 34 
	@Autowired
32 
	PurchaseRepository purchaseRepository;
 35 
	PurchaseRepository purchaseRepository;
33 
 
 36 
 
34 
	@Autowired
 37 
	@Autowired
35 
	SchemeService schemeService;
 38 
	SchemeService schemeService;
36 
 
 39 
 
37 
	@Autowired
 40 
	@Autowired
- 
 
 41 
	FofoOrderRepository fofoOrderRepository;
- 
 
 42 
 
- 
 
 43 
	@Autowired
38 
	private MVCResponseSender mvcResponseSender;
 44 
	private MVCResponseSender mvcResponseSender;
39
45
40 
	@Value("${prod}")
 46 
	@Value("${prod}")
41 
	private boolean prod;
 47 
	private boolean prod;
42
48
Line 64... Line 70...
64 
				LOGGER.error("Error while processing purchase {} for scheme In ", purchase.getId());
 70 
				LOGGER.error("Error while processing purchase {} for scheme In ", purchase.getId());
65 
				e.printStackTrace();
 71 
				e.printStackTrace();
66
72
67 
			}
 73 
			}
68 
		}
 74 
		}
- 
 
 75 
		List<FofoOrder> fofoOrders = fofoOrderRepository.selectFromSaleDate(fromDate);
- 
 
 76 
		for (FofoOrder fofoOrder: fofoOrders) {
- 
 
 77 
			try {
- 
 
 78 
				schemeService.processSchemeOut(fofoOrder.getId(), fofoOrder.getFofoId());
- 
 
 79 
			} catch (Exception e) {
- 
 
 80 
				LOGGER.error("Error while processing sale order {} for scheme Out", fofoOrder.getId());
- 
 
 81 
			}
- 
 
 82 
		}
69 
		model.addAttribute("response", mvcResponseSender.createResponseString(true));
 83 
		model.addAttribute("response", mvcResponseSender.createResponseString(true));
70 
		return "response";
 84 
		return "response";
71 
	}
 85 
	}
72 
 
 86 
 
73 
}
 87 
}