Subversion Repositories SmartDukaan

Rev

Rev 27612 | Rev 27897 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
22860 ashik.ali 1 
package com.spice.profitmandi.web.controller;
2 
 
23020 ashik.ali 3 
import java.io.ByteArrayInputStream;
4 
import java.io.ByteArrayOutputStream;
5 
import java.io.InputStream;
26674 tejbeer 6 
import java.time.LocalDate;
23020 ashik.ali 7 
import java.time.LocalDateTime;
27876 amit.gupta 8 
import java.time.YearMonth;
23556 amit.gupta 9 
import java.util.Arrays;
23914 govind 10 
import java.util.HashMap;
23556 amit.gupta 11 
import java.util.HashSet;
22860 ashik.ali 12 
import java.util.List;
23020 ashik.ali 13 
import java.util.Map;
25368 amit.gupta 14 
import java.util.Set;
22860 ashik.ali 15 
 
16 
import javax.servlet.http.HttpServletRequest;
25368 amit.gupta 17 
import javax.transaction.Transactional;
22860 ashik.ali 18 
 
23784 ashik.ali 19 
import org.apache.logging.log4j.LogManager;
23568 govind 20 
import org.apache.logging.log4j.Logger;
22860 ashik.ali 21 
import org.springframework.beans.factory.annotation.Autowired;
23784 ashik.ali 22 
import org.springframework.beans.factory.annotation.Qualifier;
23020 ashik.ali 23 
import org.springframework.core.io.InputStreamResource;
24 
import org.springframework.http.HttpHeaders;
25 
import org.springframework.http.HttpStatus;
26 
import org.springframework.http.ResponseEntity;
22860 ashik.ali 27 
import org.springframework.stereotype.Controller;
28 
import org.springframework.ui.Model;
29 
import org.springframework.web.bind.annotation.RequestBody;
30 
import org.springframework.web.bind.annotation.RequestMapping;
31 
import org.springframework.web.bind.annotation.RequestMethod;
32 
import org.springframework.web.bind.annotation.RequestParam;
33 
 
23020 ashik.ali 34 
import com.spice.profitmandi.common.enumuration.DateTimePattern;
22860 ashik.ali 35 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
23914 govind 36 
import com.spice.profitmandi.common.model.MapWrapper;
22860 ashik.ali 37 
import com.spice.profitmandi.common.model.ProfitMandiConstants;
23557 amit.gupta 38 
import com.spice.profitmandi.common.model.SchemeItems;
23020 ashik.ali 39 
import com.spice.profitmandi.common.model.SchemeModel;
40 
import com.spice.profitmandi.common.util.ExcelUtils;
27394 amit.gupta 41 
import com.spice.profitmandi.common.util.FormattingUtils;
23020 ashik.ali 42 
import com.spice.profitmandi.common.util.StringUtils;
23784 ashik.ali 43 
import com.spice.profitmandi.common.web.util.ResponseSender;
22860 ashik.ali 44 
import com.spice.profitmandi.dao.entity.catalog.Scheme;
27389 amit.gupta 45 
import com.spice.profitmandi.dao.entity.catalog.TagListing;
25505 amit.gupta 46 
import com.spice.profitmandi.dao.entity.fofo.PartnerType;
23556 amit.gupta 47 
import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
27389 amit.gupta 48 
import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
27876 amit.gupta 49 
import com.spice.profitmandi.dao.model.CreateOfferRequest;
25505 amit.gupta 50 
import com.spice.profitmandi.dao.model.CreateSchemeRequest;
26674 tejbeer 51 
import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
22860 ashik.ali 52 
import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
27389 amit.gupta 53 
import com.spice.profitmandi.dao.repository.catalog.StateGstRateRepository;
23556 amit.gupta 54 
import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
26588 tejbeer 55 
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
56 
import com.spice.profitmandi.dao.repository.dtr.Mongo;
26674 tejbeer 57 
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
23556 amit.gupta 58 
import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
23798 amit.gupta 59 
import com.spice.profitmandi.service.authentication.RoleManager;
23020 ashik.ali 60 
import com.spice.profitmandi.service.inventory.InventoryService;
27876 amit.gupta 61 
import com.spice.profitmandi.service.offers.OfferService;
22860 ashik.ali 62 
import com.spice.profitmandi.service.scheme.SchemeService;
26588 tejbeer 63 
import com.spice.profitmandi.service.user.RetailerService;
22860 ashik.ali 64 
import com.spice.profitmandi.web.model.LoginDetails;
65 
import com.spice.profitmandi.web.util.CookiesProcessor;
23570 amit.gupta 66 
import com.spice.profitmandi.web.util.MVCResponseSender;
22860 ashik.ali 67 
 
68 
@Controller
25369 amit.gupta 69 
@Transactional(rollbackOn = Throwable.class)
22860 ashik.ali 70 
public class SchemeController {
71 
 
23568 govind 72 
	private static final Logger LOGGER = LogManager.getLogger(SchemeController.class);
22860 ashik.ali 73 
 
74 
	@Autowired
22927 ashik.ali 75 
	private SchemeService schemeService;
27876 amit.gupta 76 
 
77 
	@Autowired
78 
	private OfferService offerService;
23786 amit.gupta 79 
 
22860 ashik.ali 80 
	@Autowired
27389 amit.gupta 81 
	private StateGstRateRepository stateGstRateRepository;
27612 tejbeer 82 
 
27389 amit.gupta 83 
	@Autowired
27416 amit.gupta 84 
	private ItemRepository itemRepository;
27612 tejbeer 85 
 
27416 amit.gupta 86 
	@Autowired
22927 ashik.ali 87 
	private SchemeRepository schemeRepository;
22860 ashik.ali 88 
 
89 
	@Autowired
23556 amit.gupta 90 
	private SchemeItemRepository schemeItemRepository;
23786 amit.gupta 91 
 
23556 amit.gupta 92 
	@Autowired
23570 amit.gupta 93 
	private MVCResponseSender mvcResponseSender;
23786 amit.gupta 94 
 
23570 amit.gupta 95 
	@Autowired
22927 ashik.ali 96 
	private CookiesProcessor cookiesProcessor;
23786 amit.gupta 97 
 
23020 ashik.ali 98 
	@Autowired
23784 ashik.ali 99 
	@Qualifier("fofoInventoryService")
23020 ashik.ali 100 
	private InventoryService inventoryService;
23556 amit.gupta 101 
 
102 
	@Autowired
103 
	private TagListingRepository tagListingRepository;
23914 govind 104 
 
23798 amit.gupta 105 
	@Autowired
106 
	private RoleManager roleManager;
23786 amit.gupta 107 
 
23506 amit.gupta 108 
	@Autowired
27394 amit.gupta 109 
	private ResponseSender<?> responseSender;
23786 amit.gupta 110 
 
23784 ashik.ali 111 
	@Autowired
27394 amit.gupta 112 
	private FofoStoreRepository fofoStoreRepository;
23786 amit.gupta 113 
 
23784 ashik.ali 114 
	@Autowired
27394 amit.gupta 115 
	private RetailerService retailerService;
22860 ashik.ali 116 
 
27394 amit.gupta 117 
	@Autowired
118 
	private Mongo mongoClient;
26588 tejbeer 119 
 
120 
	@Autowired
26674 tejbeer 121 
	private PartnerTypeChangeService partnerTypeChangeService;
122 
 
22860 ashik.ali 123 
	@RequestMapping(value = "/createScheme", method = RequestMethod.GET)
23786 amit.gupta 124 
	public String createScheme(HttpServletRequest request, Model model) {
125 
		// Map<Integer, String> itemIdItemDescriptionMap =
126 
		// inventoryService.getAllItemIdItemDescriptionMap();
127 
		// model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
25368 amit.gupta 128 
		Set<String> brands = inventoryService.getAllTagListingBrands(ProfitMandiConstants.MOBILE_CATEGORY_ID);
129 
		brands.addAll(inventoryService.getAllTagListingBrands(14206));
130 
		model.addAttribute("brands", brands);
25505 amit.gupta 131 
		model.addAttribute("retailerTypes", PartnerType.values());
22860 ashik.ali 132 
		return "create-scheme";
133 
	}
23786 amit.gupta 134 
 
23914 govind 135 
	@RequestMapping(value = "/getTagListingItemsByBrand", method = RequestMethod.POST)
136 
	public String getTagListingItemsByBrand(HttpServletRequest request, @RequestBody List<String> brands, Model model) {
137 
		Map<Integer, String> itemIdItemDescriptionMap = new HashMap<>();
138 
		LOGGER.info("brands" + brands);
139 
 
140 
		List<MapWrapper<Integer, String>> itemIdItemDescriptionMaplist = inventoryService
141 
				.getAllTagListingItemIdItemDescriptionMap(new HashSet<>(brands));
142 
		for (MapWrapper<Integer, String> mapWrapper : itemIdItemDescriptionMaplist) {
143 
			itemIdItemDescriptionMap.put(mapWrapper.getKey(), mapWrapper.getValue());
144 
		}
23020 ashik.ali 145 
		model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
23786 amit.gupta 146 
		// model.addAttribute("brands", inventoryService.getAllBrands());
23914 govind 147 
 
23419 ashik.ali 148 
		return "tag-listing-items-description";
23020 ashik.ali 149 
	}
23556 amit.gupta 150 
 
151 
	@RequestMapping(value = "/schemes/update-schemes-page", method = RequestMethod.GET)
152 
	public String updateShcemes(HttpServletRequest request) throws ProfitMandiBusinessException {
153 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
23799 amit.gupta 154 
		if (!roleManager.isAdmin(loginDetails.getRoleIds())) {
23556 amit.gupta 155 
			throw new ProfitMandiBusinessException("User", loginDetails.getEmailId(), "Unauthorised access");
156 
		}
157 
		return "update-schemes-page";
158 
	}
25256 amit.gupta 159 
 
23556 amit.gupta 160 
	@RequestMapping(value = "/schemes/update", method = RequestMethod.POST)
23786 amit.gupta 161 
	public String updateShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
162 
			throws Exception {
163 
		for (int schemeId : schemeItems.getSchemeIds()) {
23928 govind 164 
			if (schemeRepository.selectById(schemeId) != null)
165 
				for (int itemId : schemeItems.getItemIds()) {
166 
					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
167 
							new HashSet<>(Arrays.asList(4, 7))).size() > 0) {
168 
						SchemeItem si = new SchemeItem();
169 
						si.setItemId(itemId);
170 
						si.setSchemeId(schemeId);
171 
						try {
172 
							schemeItemRepository.persist(si);
173 
						} catch (Exception e) {
174 
							LOGGER.info("Scheme aleady exist");
175 
						}
176 
						model.addAttribute("response", mvcResponseSender.createResponseString(true));
177 
					} else {
178 
						model.addAttribute("response", mvcResponseSender.createResponseString(false));
179 
						throw new ProfitMandiBusinessException("ItemId", itemId, "Invalid Item Id");
180 
					}
181 
				}
182 
		}
183 
		return "response";
184 
	}
25256 amit.gupta 185 
 
23928 govind 186 
	@RequestMapping(value = "/addItemToScheme", method = RequestMethod.POST)
187 
	public String updateScheme(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
188 
			throws Exception {
189 
		for (int schemeId : schemeItems.getSchemeIds()) {
23914 govind 190 
			List<Integer> itemIds = schemeItemRepository.selectItemIdsBySchemeId(schemeId);
23786 amit.gupta 191 
			if (schemeRepository.selectById(schemeId) != null)
192 
				for (int itemId : schemeItems.getItemIds()) {
193 
					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
23914 govind 194 
							new HashSet<>(Arrays.asList(4, 7))).size() > 0 && (!(itemIds.contains(itemId)))) {
23786 amit.gupta 195 
						SchemeItem si = new SchemeItem();
196 
						si.setItemId(itemId);
197 
						si.setSchemeId(schemeId);
198 
						try {
199 
							schemeItemRepository.persist(si);
200 
						} catch (Exception e) {
23914 govind 201 
							LOGGER.info("Scheme already exist");
23786 amit.gupta 202 
						}
203 
						model.addAttribute("response", mvcResponseSender.createResponseString(true));
204 
					} else {
205 
						model.addAttribute("response", mvcResponseSender.createResponseString(false));
23556 amit.gupta 206 
					}
207 
				}
208 
		}
209 
		return "response";
210 
	}
23914 govind 211 
 
212 
	@RequestMapping(value = "/schemes/delete", method = RequestMethod.DELETE)
213 
	public String deleteShcemes(HttpServletRequest request,
214 
			@RequestParam(name = "schemeId", required = false, defaultValue = "0") int schemeId,
215 
			@RequestParam(name = "itemId", required = false, defaultValue = "0") int itemId, Model model)
23819 govind 216 
			throws Exception {
23914 govind 217 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
218 
		if (!(schemeId == 0 && itemId == 0) || (!(schemeId == 0 || itemId == 0))) {
219 
			schemeItemRepository.deletebyItemIdsandSchemeIds(itemId, schemeId);
220 
 
221 
			model.addAttribute("response", mvcResponseSender.createResponseString(true));
222 
 
223 
			model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
224 
 
225 
		}
226 
		return "response";
227 
	}
228 
 
229 
	@RequestMapping(value = "/extendAllSchemes", method = RequestMethod.POST)
230 
	public String extendAllScheme(HttpServletRequest request, @RequestBody LocalDateTime extendDatetime, Model model)
231 
			throws Exception {
232 
 
233 
		List<Scheme> schemes = schemeRepository.selectActiveAll();
234 
		if (schemes.size() > 0) {
235 
			for (Scheme scheme : schemes) {
25261 amit.gupta 236 
				if (scheme.getExpireTimestamp() == null) {
23914 govind 237 
					scheme.setEndDateTime(extendDatetime);
238 
					schemeRepository.persist(scheme);
23819 govind 239 
				}
240 
			}
23914 govind 241 
			model.addAttribute("response", mvcResponseSender.createResponseString(true));
242 
			return "response";
23819 govind 243 
		}
23914 govind 244 
		model.addAttribute("response", mvcResponseSender.createResponseString(false));
23819 govind 245 
		return "response";
246 
	}
23786 amit.gupta 247 
 
23914 govind 248 
	@RequestMapping(value = "/extendSchemeById", method = RequestMethod.POST)
249 
	public String extendSchemeById(HttpServletRequest request,
23819 govind 250 
 
23914 govind 251 
			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
252 
			@RequestBody LocalDateTime extendDatetime, Model model) throws Exception {
253 
 
254 
		LOGGER.info("ExtendDatetime" + extendDatetime);
255 
		LOGGER.info("schemeId" + schemeId);
256 
		Scheme scheme = schemeRepository.selectById(schemeId);
257 
		if ((!(scheme.getActiveTimestamp() == null)) && scheme.getExpireTimestamp() == null) {
258 
			scheme.setEndDateTime(extendDatetime);
259 
			schemeRepository.persist(scheme);
260 
			model.addAttribute("response", mvcResponseSender.createResponseString(true));
261 
			return "response";
262 
		}
263 
		model.addAttribute("response", mvcResponseSender.createResponseString(false));
264 
		return "response";
265 
	}
266 
 
22860 ashik.ali 267 
	@RequestMapping(value = "/createScheme", method = RequestMethod.POST)
23715 govind 268 
	public String createScheme(HttpServletRequest request, @RequestBody CreateSchemeRequest createSchemeRequest,
269 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
23752 govind 270 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
271 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
272 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm, Model model)
23715 govind 273 
			throws ProfitMandiBusinessException {
22927 ashik.ali 274 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
22860 ashik.ali 275 
		LOGGER.info("CreateSchemeRequest {}", createSchemeRequest);
22927 ashik.ali 276 
		schemeService.saveScheme(loginDetails.getFofoId(), createSchemeRequest);
277 
		LOGGER.info("Scheme saved successfully");
23271 ashik.ali 278 
		long size = schemeRepository.selectAllCount();
22927 ashik.ali 279 
		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
280 
		model.addAttribute("schemes", schemes);
281 
		model.addAttribute("start", offset + 1);
23271 ashik.ali 282 
		model.addAttribute("size", size);
23752 govind 283 
		model.addAttribute("searchItem", searchItem);
284 
		model.addAttribute("searchTerm", searchTerm);
23914 govind 285 
		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
23715 govind 286 
		if (schemes.size() < limit) {
22927 ashik.ali 287 
			model.addAttribute("end", offset + schemes.size());
23786 amit.gupta 288 
		} else {
22927 ashik.ali 289 
			model.addAttribute("end", offset + limit);
290 
		}
291 
		return "schemes";
23786 amit.gupta 292 
 
22860 ashik.ali 293 
	}
23786 amit.gupta 294 
 
22860 ashik.ali 295 
	@RequestMapping(value = "/getSchemes", method = RequestMethod.GET)
23715 govind 296 
	public String getSchemes(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset,
27876 amit.gupta 297 
			@RequestParam(required = false) LocalDate date,
23752 govind 298 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
299 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
26802 tejbeer 300 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
301 
			@RequestParam(name = "partnerType", required = false, defaultValue = "") PartnerType partnerType,
302 
			Model model) throws ProfitMandiBusinessException {
23343 ashik.ali 303 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
26802 tejbeer 304 
		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
27876 amit.gupta 305 
		if (date == null) {
306 
			date = LocalDate.now();
307 
		}
308 
		model.addAttribute("date", date);
26802 tejbeer 309 
 
23343 ashik.ali 310 
		List<Scheme> schemes = null;
311 
		long size = 0;
27876 amit.gupta 312 
 
26802 tejbeer 313 
		if (partnerType == null) {
27876 amit.gupta 314 
			partnerType = partnerTypeChangeService.getTypeOnDate(loginDetails.getFofoId(),
315 
					date.isAfter(LocalDate.now()) ? LocalDate.now() : date);
23343 ashik.ali 316 
		}
27394 amit.gupta 317 
		if (!(searchTerm.equals(""))) {
26802 tejbeer 318 
			schemes = schemeRepository.selectBySearchTerm(searchTerm, offset, limit);
27612 tejbeer 319 
			for (Scheme scheme : schemes) {
320 
				if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
27394 amit.gupta 321 
					scheme.setAmountModel(scheme.getAmount() + "%");
322 
				} else {
323 
					scheme.setAmountModel(scheme.getAmount() + "");
324 
				}
325 
			}
27876 amit.gupta 326 
			if (schemes.size() > 0) {
26802 tejbeer 327 
				size = schemeRepository.selectAllCount();
328 
				LOGGER.info("schemes" + schemes);
329 
				model.addAttribute("schemes", schemes);
330 
				model.addAttribute("start", offset + 1);
331 
				model.addAttribute("size", size);
332 
				if (schemes.size() < limit) {
333 
					model.addAttribute("end", offset + schemes.size());
27876 amit.gupta 334 
				} else {
26802 tejbeer 335 
					model.addAttribute("end", offset + limit);
336 
				}
27612 tejbeer 337 
			}
338 
 
339 
			else {
26802 tejbeer 340 
				throw new ProfitMandiBusinessException("SchemeId", searchTerm, "SchemeId Not Found");
341 
			}
27612 tejbeer 342 
		}
343 
 
344 
		else if (!searchItem.equals("")) {
26802 tejbeer 345 
			int itemId = 0;
27394 amit.gupta 346 
			TagListing tagListing = null;
347 
			if (!searchItem.equals("")) {
26802 tejbeer 348 
				itemId = Integer.parseInt(searchItem);
27394 amit.gupta 349 
				tagListing = tagListingRepository.selectByItemId(itemId);
27612 tejbeer 350 
				if (tagListing != null) {
27424 tejbeer 351 
					model.addAttribute("dp", tagListing.getSellingPrice());
352 
					model.addAttribute("mop", tagListing.getMop());
27416 amit.gupta 353 
				}
26802 tejbeer 354 
			}
27876 amit.gupta 355 
			schemes = schemeService.selectSchemeByPartnerType(partnerType, date, itemId, isAdmin, offset, limit);
27424 tejbeer 356 
			model.addAttribute("schemes", schemes);
27612 tejbeer 357 
			if (schemes.size() == 0) {
27424 tejbeer 358 
				return "schemes";
359 
			}
27612 tejbeer 360 
 
361 
			for (Scheme scheme : schemes) {
362 
				if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
363 
					if (tagListing != null) {
27394 amit.gupta 364 
						float taxRate = stateGstRateRepository.getIgstTaxRate(Arrays.asList(itemId)).get(itemId);
365 
						float taxableSellingPrice = tagListing.getSellingPrice() / (1 + taxRate / 100);
366 
						float amount = taxableSellingPrice * scheme.getAmount() / 100;
27612 tejbeer 367 
						scheme.setAmountModel(
368 
								FormattingUtils.formatDecimalTwoDigits(amount) + " (" + scheme.getAmount() + "%)");
27424 tejbeer 369 
					}
27612 tejbeer 370 
 
27424 tejbeer 371 
					else {
27394 amit.gupta 372 
						scheme.setAmountModel(scheme.getAmount() + "%");
373 
					}
27389 amit.gupta 374 
				} else {
375 
					scheme.setAmountModel(scheme.getAmount() + "");
376 
				}
377 
			}
27876 amit.gupta 378 
			size = schemeService.selectSchemeCount(partnerType, date, itemId, isAdmin);
26802 tejbeer 379 
			model.addAttribute("start", offset + 1);
380 
			model.addAttribute("size", size);
381 
			if (schemes.size() < limit) {
382 
				model.addAttribute("end", offset + schemes.size());
383 
			} else {
384 
				model.addAttribute("end", offset + limit);
385 
			}
22860 ashik.ali 386 
		}
27876 amit.gupta 387 
		model.addAttribute("searchItem", searchItem);
388 
		model.addAttribute("searchTerm", searchTerm);
389 
		model.addAttribute("partnerType", partnerType);
390 
		model.addAttribute("isAdmin", isAdmin);
27612 tejbeer 391 
		model.addAttribute("schemes", schemes);
27876 amit.gupta 392 
		LOGGER.info("schemes" + schemes);
23786 amit.gupta 393 
		// model.addAttribute("roleTypes", loginDetails.getRoleTypes());
27876 amit.gupta 394 
		if (isAdmin)
395 
			return "schemes";
396 
		else {
397 
			List<CreateOfferRequest> offers = offerService.getPublishedOffers(date, loginDetails.getFofoId(), Integer.parseInt(searchItem));
398 
			model.addAttribute("offers", offers);
399 
			return "schemes-partner";
400 
		}
22860 ashik.ali 401 
	}
23786 amit.gupta 402 
 
22860 ashik.ali 403 
	@RequestMapping(value = "/getPaginatedSchemes", method = RequestMethod.GET)
27876 amit.gupta 404 
	public String getPaginatedSchemes(HttpServletRequest request, @RequestParam(required = false) LocalDate date,
23786 amit.gupta 405 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
26802 tejbeer 406 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
27876 amit.gupta 407 
			@RequestParam(name = "partnerType", required = false, defaultValue = "ALL") PartnerType partnerType,
26802 tejbeer 408 
			Model model) throws ProfitMandiBusinessException {
409 
 
23343 ashik.ali 410 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
26802 tejbeer 411 
		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
27876 amit.gupta 412 
		if (date == null) {
413 
			date = LocalDate.now();
414 
		}
23271 ashik.ali 415 
		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
27876 amit.gupta 416 
		List<Scheme> schemes = schemeRepository.selectAll();
26802 tejbeer 417 
		int itemId = 0;
27394 amit.gupta 418 
		TagListing tagListing = null;
27876 amit.gupta 419 
 
27612 tejbeer 420 
		for (Scheme scheme : schemes) {
421 
			if (scheme.getAmountType().equals(AmountType.PERCENTAGE)) {
422 
				if (itemId > 0) {
27394 amit.gupta 423 
					float taxRate = stateGstRateRepository.getIgstTaxRate(Arrays.asList(itemId)).get(itemId);
424 
					float taxableSellingPrice = tagListing.getSellingPrice() / (1 + taxRate / 100);
425 
					float amount = taxableSellingPrice * scheme.getAmount() / 100;
27612 tejbeer 426 
					scheme.setAmountModel(
427 
							FormattingUtils.formatDecimalTwoDigits(amount) + " (" + scheme.getAmount() + "%)");
27394 amit.gupta 428 
				} else {
429 
					scheme.setAmountModel(scheme.getAmount() + "%");
430 
				}
431 
			} else {
27876 amit.gupta 432 
				scheme.setAmountModel("" + scheme.getAmount());
27394 amit.gupta 433 
			}
434 
		}
26802 tejbeer 435 
 
22860 ashik.ali 436 
		model.addAttribute("schemes", schemes);
26912 tejbeer 437 
		model.addAttribute("partnerType", partnerType);
23914 govind 438 
		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
22860 ashik.ali 439 
		return "schemes-paginated";
440 
	}
23786 amit.gupta 441 
 
23020 ashik.ali 442 
	@RequestMapping(value = "/schemes/downloadPage", method = RequestMethod.GET)
23786 amit.gupta 443 
	public String downloadPage(HttpServletRequest request, Model model) {
23020 ashik.ali 444 
		return "schemes-download";
445 
	}
23786 amit.gupta 446 
 
23020 ashik.ali 447 
	@RequestMapping(value = "/schemes/download", method = RequestMethod.GET)
23786 amit.gupta 448 
	public ResponseEntity<?> downloadInventoryItemAgingByInterval(HttpServletRequest request,
23914 govind 449 
			@RequestParam(name = ProfitMandiConstants.START_DATE_TIME) String startDateTimeString,
450 
			@RequestParam(name = ProfitMandiConstants.END_DATE_TIME) String endDateTimeString, Model model)
23786 amit.gupta 451 
			throws ProfitMandiBusinessException {
23914 govind 452 
		LocalDateTime startDateTime = StringUtils.toDateTime(startDateTimeString,
24406 amit.gupta 453 
				DateTimePattern.DD_MM_yyyy_T_HH_MM_SS);
454 
		LocalDateTime endDateTime = StringUtils.toDateTime(endDateTimeString, DateTimePattern.DD_MM_yyyy_T_HH_MM_SS);
23914 govind 455 
 
23020 ashik.ali 456 
		List<SchemeModel> schemeModels = schemeService.getAllSchemeModels(startDateTime, endDateTime);
23786 amit.gupta 457 
 
23020 ashik.ali 458 
		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
459 
		ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
23786 amit.gupta 460 
 
461 
		final HttpHeaders headers = new HttpHeaders();
462 
		headers.set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
23020 ashik.ali 463 
		headers.set("Content-disposition", "inline; filename=SchemesReport.xlsx");
23786 amit.gupta 464 
		headers.setContentLength(byteArrayOutputStream.toByteArray().length);
465 
		final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
466 
		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
467 
		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
23020 ashik.ali 468 
	}
23786 amit.gupta 469 
 
22860 ashik.ali 470 
	@RequestMapping(value = "/getSchemeById", method = RequestMethod.GET)
23786 amit.gupta 471 
	public String getSchemeById(HttpServletRequest request,
472 
			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)
473 
			throws ProfitMandiBusinessException {
23343 ashik.ali 474 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
22860 ashik.ali 475 
		Scheme scheme = schemeService.getSchemeById(schemeId);
476 
		model.addAttribute("scheme", scheme);
24445 amit.gupta 477 
		model.addAttribute("isAdmin", roleManager.isAdmin(loginDetails.getRoleIds()));
22860 ashik.ali 478 
		return "scheme-details";
23914 govind 479 
 
22860 ashik.ali 480 
	}
23786 amit.gupta 481 
 
22860 ashik.ali 482 
	@RequestMapping(value = "/activeSchemeById", method = RequestMethod.PUT)
23786 amit.gupta 483 
	public String activeSchemeById(HttpServletRequest request,
484 
			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
485 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
486 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
487 
			throws ProfitMandiBusinessException {
22860 ashik.ali 488 
		schemeService.activeSchemeById(schemeId);
489 
		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
490 
		model.addAttribute("schemes", schemes);
491 
		return "schemes-paginated";
492 
	}
23786 amit.gupta 493 
 
22860 ashik.ali 494 
	@RequestMapping(value = "/expireSchemeById", method = RequestMethod.PUT)
23786 amit.gupta 495 
	public String expireSchemeById(HttpServletRequest request,
496 
			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
25069 amit.gupta 497 
			@RequestParam(name = ProfitMandiConstants.EXPIRE_TIMESTAMP) LocalDateTime expiryTimestamp,
23786 amit.gupta 498 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
499 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
500 
			throws ProfitMandiBusinessException {
25069 amit.gupta 501 
		schemeService.expireSchemeById(schemeId, expiryTimestamp);
22860 ashik.ali 502 
		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
503 
		model.addAttribute("schemes", schemes);
504 
		return "schemes-paginated";
505 
	}
23786 amit.gupta 506 
 
23784 ashik.ali 507 
	@RequestMapping(value = "/getSchemesJson", method = RequestMethod.GET)
23786 amit.gupta 508 
	public ResponseEntity<?> getSchemesJson(HttpServletRequest request,
509 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
510 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
511 
			throws ProfitMandiBusinessException {
23784 ashik.ali 512 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
513 
		return responseSender.ok(schemeService.getSchemes(loginDetails.getRoleIds(), offset, limit));
514 
	}
26802 tejbeer 515 
 
26763 tejbeer 516 
	@RequestMapping(value = "/searchSchemeByCategory")
517 
	public String getSchemeByCategory(HttpServletRequest request,
518 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
519 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
520 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
521 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
522 
			@RequestParam(name = "category", required = true, defaultValue = "") PartnerType category, Model model)
523 
			throws ProfitMandiBusinessException {
524 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
525 
		List<Scheme> schemes = null;
526 
		long size = 0;
26802 tejbeer 527 
 
528 
		schemes = schemeRepository.selectByPartnerType(category, offset, limit);
529 
 
530 
		if (!(schemes.size() == 0)) {
531 
			size = schemeRepository.selectAllCount();
532 
			LOGGER.info("schemes" + schemes);
533 
			model.addAttribute("schemes", schemes);
534 
			model.addAttribute("start", offset + 1);
535 
			model.addAttribute("size", size);
536 
			model.addAttribute("searchTerm", searchTerm);
537 
			model.addAttribute("searchItem", searchItem);
538 
			model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
539 
			if (schemes.size() < limit) {
540 
				model.addAttribute("end", offset + schemes.size());
541 
			} else {
542 
				model.addAttribute("end", offset + limit);
26763 tejbeer 543 
			}
26802 tejbeer 544 
		}
545 
 
26763 tejbeer 546 
		return "schemes";
547 
	}
26802 tejbeer 548 
 
26763 tejbeer 549 
	@RequestMapping(value = "/getSchemeByCategoryPaginated")
550 
	public String getSchemeByCategoryPaginated(HttpServletRequest request,
551 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
552 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
553 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
554 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
555 
			@RequestParam(name = "category", required = true, defaultValue = "") PartnerType category, Model model)
556 
			throws ProfitMandiBusinessException {
557 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
558 
		LOGGER.info("In search Item....");
559 
		List<Scheme> schemes = null;
26802 tejbeer 560 
 
26763 tejbeer 561 
		schemes = schemeRepository.selectByPartnerType(category, offset, limit);
23506 amit.gupta 562 
 
26763 tejbeer 563 
		model.addAttribute("schemes", schemes);
564 
		model.addAttribute("searchItem", searchItem);
565 
		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
566 
		return "schemes-paginated";
567 
	}
568 
 
23752 govind 569 
	@RequestMapping(value = "/searchScheme")
570 
	public String getSchemeBySchemeId(HttpServletRequest request,
571 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
572 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
573 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
574 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem, Model model)
575 
			throws ProfitMandiBusinessException {
576 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
577 
		List<Scheme> schemes = null;
578 
		long size = 0;
579 
		if (!(searchTerm.equals("")) && searchItem.equals("")) {
580 
			schemes = schemeRepository.selectBySearchTerm(searchTerm, offset, limit);
23786 amit.gupta 581 
			if (!(schemes.size() == 0)) {
582 
				size = schemeRepository.selectAllCount();
583 
				LOGGER.info("schemes" + schemes);
584 
				model.addAttribute("schemes", schemes);
585 
				model.addAttribute("start", offset + 1);
586 
				model.addAttribute("size", size);
587 
				model.addAttribute("searchTerm", searchTerm);
588 
				model.addAttribute("searchItem", searchItem);
23914 govind 589 
				model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
23786 amit.gupta 590 
				if (schemes.size() < limit) {
591 
					model.addAttribute("end", offset + schemes.size());
592 
				} else {
593 
					model.addAttribute("end", offset + limit);
594 
				}
23752 govind 595 
			} else {
23786 amit.gupta 596 
				throw new ProfitMandiBusinessException("SchemeId", searchTerm, "SchemeId Not Found");
23752 govind 597 
			}
598 
		} else if (!(searchItem.equals("")) && searchTerm.equals("")) {
599 
			List<Integer> schemeIds = schemeItemRepository.selectSchemeIdByItemId(Integer.parseInt(searchItem));
23786 amit.gupta 600 
			if (!(schemeIds.size() == 0)) {
23752 govind 601 
				LOGGER.info("schemeIds in searchItemScheme" + schemeIds);
602 
				schemes = schemeRepository.selectBySchemeIds(schemeIds, offset, limit);
603 
				size = schemeIds.size();
604 
				LOGGER.info("Size" + size);
605 
				model.addAttribute("schemes", schemes);
606 
				model.addAttribute("start", offset + 1);
607 
				model.addAttribute("size", size);
608 
				model.addAttribute("searchItem", searchItem);
609 
				model.addAttribute("searchTerm", searchTerm);
23914 govind 610 
				model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
23752 govind 611 
				if (schemes.size() < limit) {
612 
					model.addAttribute("end", offset + schemes.size());
613 
				} else {
614 
					model.addAttribute("end", offset + limit);
615 
				}
616 
 
617 
			} else {
618 
				throw new ProfitMandiBusinessException("SchemeIds", searchItem, "SchemeId Not Found");
619 
			}
620 
		} else {
23798 amit.gupta 621 
			if (roleManager.isAdmin(loginDetails.getRoleIds())) {
23752 govind 622 
				schemes = schemeRepository.selectAll(offset, limit);
623 
				size = schemeRepository.selectAllCount();
624 
			} else {
625 
				schemes = schemeRepository.selectActiveAll(offset, limit);
626 
				size = schemeRepository.selectAllActiveCount();
627 
			}
628 
			model.addAttribute("schemes", schemes);
629 
			model.addAttribute("start", offset + 1);
630 
			model.addAttribute("size", size);
631 
			model.addAttribute("searchItem", searchItem);
632 
			model.addAttribute("searchTerm", searchTerm);
23914 govind 633 
			model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
23752 govind 634 
			if (schemes.size() < limit) {
635 
				model.addAttribute("end", offset + schemes.size());
636 
			} else {
637 
				model.addAttribute("end", offset + limit);
638 
			}
639 
		}
640 
		return "schemes";
641 
	}
642 
 
643 
	@RequestMapping(value = "/searchItemSchemePanigated")
644 
	public String getSchemeByItemPanigated(HttpServletRequest request,
645 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
646 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
647 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem, Model model)
648 
			throws ProfitMandiBusinessException {
23914 govind 649 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
23752 govind 650 
		LOGGER.info("In search Item....");
651 
		List<Scheme> schemes = null;
652 
		if (!searchItem.equals("")) {
653 
			List<Integer> schemeIds = schemeItemRepository.selectSchemeIdByItemId(Integer.parseInt(searchItem));
654 
			if (schemeIds != null) {
655 
				LOGGER.info(schemeIds);
656 
				schemes = schemeRepository.selectBySchemeIds(schemeIds, offset, limit);
657 
 
658 
			}
659 
		}
660 
		model.addAttribute("schemes", schemes);
661 
		model.addAttribute("searchItem", searchItem);
23914 govind 662 
		model.addAttribute("roleType", roleManager.isAdmin(loginDetails.getRoleIds()));
23752 govind 663 
		return "schemes-paginated";
664 
 
665 
	}
22860 ashik.ali 666 
}