Subversion Repositories SmartDukaan

Rev

Rev 23715 | Rev 23784 | 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;
6 
import java.time.LocalDateTime;
23556 amit.gupta 7 
import java.util.Arrays;
8 
import java.util.HashSet;
22860 ashik.ali 9 
import java.util.List;
23020 ashik.ali 10 
import java.util.Map;
22860 ashik.ali 11 
 
12 
import javax.servlet.http.HttpServletRequest;
13 
 
23568 govind 14 
import org.apache.logging.log4j.Logger;
15 
import org.apache.logging.log4j.LogManager;
22860 ashik.ali 16 
import org.springframework.beans.factory.annotation.Autowired;
23020 ashik.ali 17 
import org.springframework.core.io.InputStreamResource;
18 
import org.springframework.http.HttpHeaders;
19 
import org.springframework.http.HttpStatus;
20 
import org.springframework.http.ResponseEntity;
22860 ashik.ali 21 
import org.springframework.stereotype.Controller;
22 
import org.springframework.transaction.annotation.Transactional;
23 
import org.springframework.ui.Model;
24 
import org.springframework.web.bind.annotation.RequestBody;
25 
import org.springframework.web.bind.annotation.RequestMapping;
26 
import org.springframework.web.bind.annotation.RequestMethod;
27 
import org.springframework.web.bind.annotation.RequestParam;
28 
 
23020 ashik.ali 29 
import com.spice.profitmandi.common.enumuration.DateTimePattern;
22860 ashik.ali 30 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
31 
import com.spice.profitmandi.common.model.CreateSchemeRequest;
32 
import com.spice.profitmandi.common.model.ProfitMandiConstants;
23557 amit.gupta 33 
import com.spice.profitmandi.common.model.SchemeItems;
23020 ashik.ali 34 
import com.spice.profitmandi.common.model.SchemeModel;
35 
import com.spice.profitmandi.common.util.ExcelUtils;
36 
import com.spice.profitmandi.common.util.StringUtils;
22860 ashik.ali 37 
import com.spice.profitmandi.dao.entity.catalog.Scheme;
23556 amit.gupta 38 
import com.spice.profitmandi.dao.entity.fofo.SchemeItem;
23343 ashik.ali 39 
import com.spice.profitmandi.dao.enumuration.dtr.RoleType;
22860 ashik.ali 40 
import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
23556 amit.gupta 41 
import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
23506 amit.gupta 42 
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
23556 amit.gupta 43 
import com.spice.profitmandi.dao.repository.fofo.SchemeItemRepository;
23020 ashik.ali 44 
import com.spice.profitmandi.service.inventory.InventoryService;
22860 ashik.ali 45 
import com.spice.profitmandi.service.scheme.SchemeService;
46 
import com.spice.profitmandi.web.model.LoginDetails;
47 
import com.spice.profitmandi.web.util.CookiesProcessor;
23570 amit.gupta 48 
import com.spice.profitmandi.web.util.MVCResponseSender;
22860 ashik.ali 49 
 
50 
@Controller
23715 govind 51 
@Transactional(rollbackFor = Throwable.class)
22860 ashik.ali 52 
public class SchemeController {
53 
 
23568 govind 54 
	private static final Logger LOGGER = LogManager.getLogger(SchemeController.class);
22860 ashik.ali 55 
 
56 
	@Autowired
22927 ashik.ali 57 
	private SchemeService schemeService;
23715 govind 58 
 
22860 ashik.ali 59 
	@Autowired
22927 ashik.ali 60 
	private SchemeRepository schemeRepository;
22860 ashik.ali 61 
 
62 
	@Autowired
23556 amit.gupta 63 
	private SchemeItemRepository schemeItemRepository;
23715 govind 64 
 
23556 amit.gupta 65 
	@Autowired
23570 amit.gupta 66 
	private MVCResponseSender mvcResponseSender;
23715 govind 67 
 
23570 amit.gupta 68 
	@Autowired
22927 ashik.ali 69 
	private CookiesProcessor cookiesProcessor;
23715 govind 70 
 
23020 ashik.ali 71 
	@Autowired
72 
	private InventoryService inventoryService;
23556 amit.gupta 73 
 
74 
	@Autowired
75 
	private TagListingRepository tagListingRepository;
23715 govind 76 
 
23506 amit.gupta 77 
	@Autowired
78 
	PurchaseRepository purchaseRepository;
22860 ashik.ali 79 
 
80 
	@RequestMapping(value = "/createScheme", method = RequestMethod.GET)
23715 govind 81 
	public String createScheme(HttpServletRequest request, Model model) {
82 
		// Map<Integer, String> itemIdItemDescriptionMap =
83 
		// inventoryService.getAllItemIdItemDescriptionMap();
84 
		// model.addAttribute("itemIdItemDescriptionMap",
85 
		// itemIdItemDescriptionMap);
23419 ashik.ali 86 
		model.addAttribute("brands", inventoryService.getAllTagListingBrands());
22860 ashik.ali 87 
		return "create-scheme";
88 
	}
23715 govind 89 
 
23419 ashik.ali 90 
	@RequestMapping(value = "/getTagListingItemsByBrand", method = RequestMethod.GET)
23715 govind 91 
	public String getTagListingItemsByBrand(HttpServletRequest request,
92 
			@RequestParam(name = ProfitMandiConstants.BRAND) String brand, Model model) {
93 
		Map<Integer, String> itemIdItemDescriptionMap = inventoryService
94 
				.getAllTagListingItemIdItemDescriptionMap(brand);
23020 ashik.ali 95 
		model.addAttribute("itemIdItemDescriptionMap", itemIdItemDescriptionMap);
23715 govind 96 
		// model.addAttribute("brands", inventoryService.getAllBrands());
23419 ashik.ali 97 
		return "tag-listing-items-description";
23020 ashik.ali 98 
	}
23556 amit.gupta 99 
 
100 
	@RequestMapping(value = "/schemes/update-schemes-page", method = RequestMethod.GET)
101 
	public String updateShcemes(HttpServletRequest request) throws ProfitMandiBusinessException {
102 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
23715 govind 103 
		if (!loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
23556 amit.gupta 104 
			throw new ProfitMandiBusinessException("User", loginDetails.getEmailId(), "Unauthorised access");
105 
		}
106 
		return "update-schemes-page";
107 
	}
23715 govind 108 
 
23556 amit.gupta 109 
	@RequestMapping(value = "/schemes/update", method = RequestMethod.POST)
23715 govind 110 
	public String updateShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
111 
			throws Exception {
112 
		for (int schemeId : schemeItems.getSchemeIds()) {
113 
			if (schemeRepository.selectById(schemeId) != null)
114 
				for (int itemId : schemeItems.getItemIds()) {
115 
					if (tagListingRepository.selectByItemIdsAndTagIds(new HashSet<>(Arrays.asList(itemId)),
116 
							new HashSet<>(Arrays.asList(4, 7))).size() > 0) {
117 
						SchemeItem si = new SchemeItem();
118 
						si.setItemId(itemId);
119 
						si.setSchemeId(schemeId);
120 
						try {
121 
							schemeItemRepository.persist(si);
122 
						} catch (Exception e) {
123 
							LOGGER.info("Scheme aleady exist");
124 
						}
125 
						model.addAttribute("response", mvcResponseSender.createResponseString(true));
126 
					} else {
127 
						model.addAttribute("response", mvcResponseSender.createResponseString(false));
128 
						throw new ProfitMandiBusinessException("ItemId", itemId, "Invalid Item Id");
23556 amit.gupta 129 
					}
23715 govind 130 
				}
131 
		}
132 
		return "response";
133 
	}
23752 govind 134 
 
23715 govind 135 
	@RequestMapping(value = "/schemes/delete", method = RequestMethod.POST)
136 
	public String deleteShcemes(HttpServletRequest request, @RequestBody SchemeItems schemeItems, Model model)
137 
			throws Exception {
23752 govind 138 
		if (schemeItemRepository.selectBySchemeIdsAndItemIds(new HashSet<>(schemeItems.getSchemeIds()),
139 
				new HashSet<>(schemeItems.getItemIds())).size() > 0) {
140 
			for (int schemeId : schemeItems.getSchemeIds()) {
141 
				for (int itemId : schemeItems.getItemIds()) {
23715 govind 142 
					schemeItemRepository.deletebyItemIdsandSchemeIds(itemId, schemeId);
23570 amit.gupta 143 
					model.addAttribute("response", mvcResponseSender.createResponseString(true));
23556 amit.gupta 144 
				}
145 
			}
23752 govind 146 
		} else {
147 
			throw new ProfitMandiBusinessException("ItemId", schemeItems.getItemIds(), "invalid Item Id");
23556 amit.gupta 148 
		}
149 
		return "response";
150 
	}
23752 govind 151 
 
22860 ashik.ali 152 
	@RequestMapping(value = "/createScheme", method = RequestMethod.POST)
23715 govind 153 
	public String createScheme(HttpServletRequest request, @RequestBody CreateSchemeRequest createSchemeRequest,
154 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
23752 govind 155 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
156 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
157 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm, Model model)
23715 govind 158 
			throws ProfitMandiBusinessException {
22927 ashik.ali 159 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
22860 ashik.ali 160 
		LOGGER.info("CreateSchemeRequest {}", createSchemeRequest);
22927 ashik.ali 161 
		schemeService.saveScheme(loginDetails.getFofoId(), createSchemeRequest);
162 
		LOGGER.info("Scheme saved successfully");
23271 ashik.ali 163 
		long size = schemeRepository.selectAllCount();
22927 ashik.ali 164 
		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
165 
		model.addAttribute("schemes", schemes);
166 
		model.addAttribute("start", offset + 1);
23271 ashik.ali 167 
		model.addAttribute("size", size);
23752 govind 168 
		model.addAttribute("searchItem", searchItem);
169 
		model.addAttribute("searchTerm", searchTerm);
23715 govind 170 
		if (schemes.size() < limit) {
22927 ashik.ali 171 
			model.addAttribute("end", offset + schemes.size());
23715 govind 172 
		} else {
22927 ashik.ali 173 
			model.addAttribute("end", offset + limit);
174 
		}
175 
		return "schemes";
23715 govind 176 
 
22860 ashik.ali 177 
	}
23715 govind 178 
 
22860 ashik.ali 179 
	@RequestMapping(value = "/getSchemes", method = RequestMethod.GET)
23715 govind 180 
	public String getSchemes(HttpServletRequest request, @RequestParam(name = "offset", defaultValue = "0") int offset,
23752 govind 181 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
182 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem,
183 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm, Model model)
23715 govind 184 
			throws ProfitMandiBusinessException {
23343 ashik.ali 185 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
186 
		List<Scheme> schemes = null;
187 
		long size = 0;
23715 govind 188 
		if (loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
23343 ashik.ali 189 
			schemes = schemeRepository.selectAll(offset, limit);
190 
			size = schemeRepository.selectAllCount();
23715 govind 191 
		} else {
23343 ashik.ali 192 
			schemes = schemeRepository.selectActiveAll(offset, limit);
193 
			size = schemeRepository.selectAllActiveCount();
194 
		}
22860 ashik.ali 195 
		model.addAttribute("schemes", schemes);
196 
		model.addAttribute("start", offset + 1);
23271 ashik.ali 197 
		model.addAttribute("size", size);
23752 govind 198 
		model.addAttribute("searchItem", searchItem);
199 
		model.addAttribute("searchTerm", searchTerm);
23715 govind 200 
		if (schemes.size() < limit) {
22860 ashik.ali 201 
			model.addAttribute("end", offset + schemes.size());
23715 govind 202 
		} else {
22860 ashik.ali 203 
			model.addAttribute("end", offset + limit);
204 
		}
23715 govind 205 
		// model.addAttribute("roleTypes", loginDetails.getRoleTypes());
22860 ashik.ali 206 
		return "schemes";
207 
	}
23715 govind 208 
 
22860 ashik.ali 209 
	@RequestMapping(value = "/getPaginatedSchemes", method = RequestMethod.GET)
23715 govind 210 
	public String getPaginatedSchemes(HttpServletRequest request,
211 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
212 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
213 
			throws ProfitMandiBusinessException {
23343 ashik.ali 214 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
23271 ashik.ali 215 
		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
23343 ashik.ali 216 
		List<Scheme> schemes = null;
23715 govind 217 
		if (loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
23343 ashik.ali 218 
			schemes = schemeRepository.selectAll(offset, limit);
23715 govind 219 
		} else {
23343 ashik.ali 220 
			schemes = schemeRepository.selectActiveAll(offset, limit);
221 
		}
22860 ashik.ali 222 
		model.addAttribute("schemes", schemes);
23343 ashik.ali 223 
		model.addAttribute("roleTypes", loginDetails.getRoleTypes());
22860 ashik.ali 224 
		return "schemes-paginated";
225 
	}
23715 govind 226 
 
23020 ashik.ali 227 
	@RequestMapping(value = "/schemes/downloadPage", method = RequestMethod.GET)
23715 govind 228 
	public String downloadPage(HttpServletRequest request, Model model) {
23020 ashik.ali 229 
		return "schemes-download";
230 
	}
23715 govind 231 
 
23020 ashik.ali 232 
	@RequestMapping(value = "/schemes/download", method = RequestMethod.GET)
23715 govind 233 
	public ResponseEntity<?> downloadInventoryItemAgingByInterval(HttpServletRequest request,
234 
			@RequestParam(name = ProfitMandiConstants.START_DATE_TIME) String startDateTimeString,
235 
			@RequestParam(name = ProfitMandiConstants.END_DATE_TIME) String endDateTimeString, Model model)
236 
			throws ProfitMandiBusinessException {
237 
		LocalDateTime startDateTime = StringUtils.toDateTime(startDateTimeString,
238 
				DateTimePattern.DD_MM_YYYY_T_HH_MM_SS);
23020 ashik.ali 239 
		LocalDateTime endDateTime = StringUtils.toDateTime(endDateTimeString, DateTimePattern.DD_MM_YYYY_T_HH_MM_SS);
23715 govind 240 
 
23020 ashik.ali 241 
		List<SchemeModel> schemeModels = schemeService.getAllSchemeModels(startDateTime, endDateTime);
23715 govind 242 
 
23020 ashik.ali 243 
		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
244 
		ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
23715 govind 245 
 
246 
		final HttpHeaders headers = new HttpHeaders();
247 
		headers.set("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
23020 ashik.ali 248 
		headers.set("Content-disposition", "inline; filename=SchemesReport.xlsx");
23715 govind 249 
		headers.setContentLength(byteArrayOutputStream.toByteArray().length);
250 
		final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
251 
		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
252 
		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
253 
 
254 
		// return
255 
		// responseSender.ok(ResponseCodeHolder.getMessage("ITM_AGNG_OK_1000"));
23020 ashik.ali 256 
	}
23715 govind 257 
 
22860 ashik.ali 258 
	@RequestMapping(value = "/getSchemeById", method = RequestMethod.GET)
23715 govind 259 
	public String getSchemeById(HttpServletRequest request,
260 
			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId, Model model)
261 
			throws ProfitMandiBusinessException {
23343 ashik.ali 262 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
22860 ashik.ali 263 
		Scheme scheme = schemeService.getSchemeById(schemeId);
264 
		model.addAttribute("scheme", scheme);
23343 ashik.ali 265 
		model.addAttribute("roleTypes", loginDetails.getRoleTypes());
22860 ashik.ali 266 
		return "scheme-details";
267 
	}
23715 govind 268 
 
22860 ashik.ali 269 
	@RequestMapping(value = "/activeSchemeById", method = RequestMethod.PUT)
23715 govind 270 
	public String activeSchemeById(HttpServletRequest request,
271 
			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
272 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
273 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
274 
			throws ProfitMandiBusinessException {
22860 ashik.ali 275 
		schemeService.activeSchemeById(schemeId);
276 
		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
277 
		model.addAttribute("schemes", schemes);
278 
		return "schemes-paginated";
279 
	}
23715 govind 280 
 
22860 ashik.ali 281 
	@RequestMapping(value = "/expireSchemeById", method = RequestMethod.PUT)
23715 govind 282 
	public String expireSchemeById(HttpServletRequest request,
283 
			@RequestParam(name = ProfitMandiConstants.SCHEME_ID) int schemeId,
284 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
285 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
286 
			throws ProfitMandiBusinessException {
22860 ashik.ali 287 
		schemeService.expireSchemeById(schemeId);
288 
		List<Scheme> schemes = schemeRepository.selectAll(offset, limit);
289 
		model.addAttribute("schemes", schemes);
290 
		return "schemes-paginated";
291 
	}
23506 amit.gupta 292 
 
23752 govind 293 
	@RequestMapping(value = "/searchScheme")
294 
	public String getSchemeBySchemeId(HttpServletRequest request,
295 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
296 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
297 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm,
298 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem, Model model)
299 
			throws ProfitMandiBusinessException {
300 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
301 
		List<Scheme> schemes = null;
302 
		long size = 0;
303 
		if (!(searchTerm.equals("")) && searchItem.equals("")) {
304 
			schemes = schemeRepository.selectBySearchTerm(searchTerm, offset, limit);
305 
			if(!(schemes.size()==0))
306 
			{
307 
			size = schemeRepository.selectAllCount();
308 
			LOGGER.info("schemes" + schemes);
309 
			model.addAttribute("schemes", schemes);
310 
			model.addAttribute("start", offset + 1);
311 
			model.addAttribute("size", size);
312 
			model.addAttribute("searchTerm", searchTerm);
313 
			model.addAttribute("searchItem", searchItem);
314 
			if (schemes.size() < limit) {
315 
				model.addAttribute("end", offset + schemes.size());
316 
			} else {
317 
				model.addAttribute("end", offset + limit);
318 
			}
319 
			}
320 
			else
321 
			{
322 
				throw new ProfitMandiBusinessException("SchemeId",searchTerm,"SchemeId Not Found");
323 
			}
324 
		} else if (!(searchItem.equals("")) && searchTerm.equals("")) {
325 
			List<Integer> schemeIds = schemeItemRepository.selectSchemeIdByItemId(Integer.parseInt(searchItem));
326 
			if (!(schemeIds.size()==0)) {
327 
				LOGGER.info("schemeIds in searchItemScheme" + schemeIds);
328 
				schemes = schemeRepository.selectBySchemeIds(schemeIds, offset, limit);
329 
				size = schemeIds.size();
330 
				LOGGER.info("Size" + size);
331 
				model.addAttribute("schemes", schemes);
332 
				model.addAttribute("start", offset + 1);
333 
				model.addAttribute("size", size);
334 
				model.addAttribute("searchItem", searchItem);
335 
				model.addAttribute("searchTerm", searchTerm);
336 
				if (schemes.size() < limit) {
337 
					model.addAttribute("end", offset + schemes.size());
338 
				} else {
339 
					model.addAttribute("end", offset + limit);
340 
				}
341 
 
342 
			} else {
343 
				throw new ProfitMandiBusinessException("SchemeIds", searchItem, "SchemeId Not Found");
344 
			}
345 
		} else {
346 
			if (loginDetails.getRoleTypes().contains(RoleType.FOFO_ADMIN)) {
347 
				schemes = schemeRepository.selectAll(offset, limit);
348 
				size = schemeRepository.selectAllCount();
349 
			} else {
350 
				schemes = schemeRepository.selectActiveAll(offset, limit);
351 
				size = schemeRepository.selectAllActiveCount();
352 
			}
353 
			model.addAttribute("schemes", schemes);
354 
			model.addAttribute("start", offset + 1);
355 
			model.addAttribute("size", size);
356 
			model.addAttribute("searchItem", searchItem);
357 
			model.addAttribute("searchTerm", searchTerm);
358 
			if (schemes.size() < limit) {
359 
				model.addAttribute("end", offset + schemes.size());
360 
			} else {
361 
				model.addAttribute("end", offset + limit);
362 
			}
363 
		}
364 
		return "schemes";
365 
	}
366 
 
367 
	@RequestMapping(value = "/searchItemSchemePanigated")
368 
	public String getSchemeByItemPanigated(HttpServletRequest request,
369 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
370 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
371 
			@RequestParam(name = "searchItem", required = false, defaultValue = "") String searchItem, Model model)
372 
			throws ProfitMandiBusinessException {
373 
		LOGGER.info("In search Item....");
374 
		List<Scheme> schemes = null;
375 
		if (!searchItem.equals("")) {
376 
			List<Integer> schemeIds = schemeItemRepository.selectSchemeIdByItemId(Integer.parseInt(searchItem));
377 
			if (schemeIds != null) {
378 
				LOGGER.info(schemeIds);
379 
				schemes = schemeRepository.selectBySchemeIds(schemeIds, offset, limit);
380 
 
381 
			}
382 
		}
383 
		model.addAttribute("schemes", schemes);
384 
		model.addAttribute("searchItem", searchItem);
385 
		return "schemes-paginated";
386 
 
387 
	}
388 
 
22860 ashik.ali 389 
}