Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
25496 tejbeer 1 
package com.spice.profitmandi.web.controller;
2 
 
3 
import java.time.LocalDateTime;
4 
import java.util.ArrayList;
5 
import java.util.List;
6 
import java.util.Map;
25587 tejbeer 7 
import java.util.function.Function;
8 
import java.util.stream.Collector;
25496 tejbeer 9 
import java.util.stream.Collectors;
10 
 
11 
import javax.servlet.http.HttpServletRequest;
12 
 
13 
import org.apache.logging.log4j.LogManager;
14 
import org.apache.logging.log4j.Logger;
15 
import org.json.JSONObject;
16 
import org.springframework.beans.factory.annotation.Autowired;
17 
import org.springframework.stereotype.Controller;
18 
import org.springframework.transaction.annotation.Transactional;
19 
import org.springframework.ui.Model;
20 
import org.springframework.web.bind.annotation.RequestMapping;
21 
import org.springframework.web.bind.annotation.RequestMethod;
22 
import org.springframework.web.bind.annotation.RequestParam;
23 
 
24 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
25 
import com.spice.profitmandi.common.model.CustomRetailer;
26 
import com.spice.profitmandi.dao.entity.user.Refferal;
27 
import com.spice.profitmandi.dao.entity.user.RefferalMonthlyAmount;
28 
import com.spice.profitmandi.dao.entity.user.User;
29 
import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
30 
import com.spice.profitmandi.dao.model.DateRangeModel;
31 
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
32 
import com.spice.profitmandi.dao.repository.dtr.RefferalMonthlyAmountRepository;
33 
import com.spice.profitmandi.dao.repository.dtr.RefferalRepository;
34 
import com.spice.profitmandi.dao.repository.user.UserRepository;
35 
import com.spice.profitmandi.service.user.RetailerService;
36 
import com.spice.profitmandi.service.wallet.WalletService;
37 
import com.spice.profitmandi.web.util.MVCResponseSender;
38 
 
39 
import in.shop2020.model.v1.order.WalletReferenceType;
40 
 
41 
@Controller
42 
@Transactional(rollbackFor = Throwable.class)
43 
public class RefferalController {
44 
 
45 
	@Autowired
46 
	private RefferalRepository refferalRepository;
47 
 
48 
	@Autowired
49 
	private MVCResponseSender mvcResponseSender;
50 
 
51 
	@Autowired
52 
	private FofoStoreRepository fofoStoreRepository;
53 
 
54 
	@Autowired
55 
	private RetailerService retailerService;
56 
 
57 
	@Autowired
58 
	private WalletService walletService;
59 
 
60 
	@Autowired
61 
	private RefferalMonthlyAmountRepository refferalMonthlyAmountRepository;
62 
 
63 
	@Autowired
64 
	private UserRepository userRepository;
65 
 
66 
	private static final Logger LOGGER = LogManager.getLogger(RefferalRepository.class);
67 
 
68 
	@RequestMapping(value = "/getRefferalsRequest", method = RequestMethod.GET)
69 
	public String getRefferalsRequest(HttpServletRequest request,
70 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
71 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
72 
			throws ProfitMandiBusinessException {
73 
 
74 
		List<Refferal> refferals = null;
75 
		long size = 0;
76 
		refferals = refferalRepository.selectAllRefferalByStatus(offset, limit, RefferalStatus.pending);
77 
		LOGGER.info("refferals" + refferals);
78 
		size = refferalRepository.selectCountByStatus(RefferalStatus.pending);
79 
		if (!refferals.isEmpty()) {
80 
 
81 
			model.addAttribute("refferals", refferals);
82 
			model.addAttribute("start", offset + 1);
83 
			model.addAttribute("rStatus", "pending");
84 
 
85 
			model.addAttribute("size", size);
86 
			model.addAttribute("url", "/getPaginatedRefferalsRequest");
87 
 
88 
			if (refferals.size() < limit) {
89 
				model.addAttribute("end", offset + refferals.size());
90 
			} else {
91 
				model.addAttribute("end", offset + limit);
92 
			}
93 
 
94 
		} else {
95 
 
96 
			model.addAttribute("refferals", refferals);
97 
			model.addAttribute("size", size);
98 
 
99 
		}
100 
 
101 
		return "refferal";
102 
	}
103 
 
104 
	@RequestMapping(value = "/getPaginatedRefferalsRequest", method = RequestMethod.GET)
105 
	public String getPaginatedRefferalsRequest(HttpServletRequest request,
106 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
107 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
108 
		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
109 
		List<Refferal> refferals = null;
110 
		refferals = refferalRepository.selectAllRefferalByStatus(offset, limit, RefferalStatus.pending);
111 
		LOGGER.info("refferals" + refferals);
112 
		if (!refferals.isEmpty()) {
113 
 
114 
			model.addAttribute("refferals", refferals);
115 
			model.addAttribute("rStatus", "pending");
116 
			model.addAttribute("url", "/getPaginatedRefferalsRequest");
117 
 
118 
		} else {
119 
			model.addAttribute("refferals", refferals);
120 
 
121 
		}
122 
 
123 
		return "refferal-paginated";
124 
	}
125 
 
25587 tejbeer 126 
	@RequestMapping(value = "/getValidateRefferals", method = RequestMethod.GET)
127 
	public String getValidateRefferals(HttpServletRequest request,
128 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
129 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
130 
			throws ProfitMandiBusinessException {
131 
 
132 
		List<Refferal> refferals = null;
133 
		long size = 0;
134 
		refferals = refferalRepository.selectAllRefferalByStatus(offset, limit, RefferalStatus.validate);
135 
		LOGGER.info("refferals" + refferals);
136 
		size = refferalRepository.selectCountByStatus(RefferalStatus.validate);
137 
		if (!refferals.isEmpty()) {
138 
 
139 
			model.addAttribute("refferals", refferals);
140 
			model.addAttribute("start", offset + 1);
141 
			model.addAttribute("rStatus", "validate");
142 
 
143 
			model.addAttribute("size", size);
144 
			model.addAttribute("url", "/getPaginatedValidateRefferals");
145 
 
146 
			if (refferals.size() < limit) {
147 
				model.addAttribute("end", offset + refferals.size());
148 
			} else {
149 
				model.addAttribute("end", offset + limit);
150 
			}
151 
 
152 
		} else {
153 
 
154 
			model.addAttribute("refferals", refferals);
155 
			model.addAttribute("size", size);
156 
 
157 
		}
158 
 
159 
		return "refferal";
160 
	}
161 
 
162 
	@RequestMapping(value = "/getPaginatedValidateRefferals", method = RequestMethod.GET)
163 
	public String getPaginatedValidateRefferals(HttpServletRequest request,
164 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
165 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
166 
		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
167 
		List<Refferal> refferals = null;
168 
		refferals = refferalRepository.selectAllRefferalByStatus(offset, limit, RefferalStatus.validate);
169 
		LOGGER.info("refferals" + refferals);
170 
		if (!refferals.isEmpty()) {
171 
 
172 
			model.addAttribute("refferals", refferals);
173 
			model.addAttribute("rStatus", "validate");
174 
			model.addAttribute("url", "/getPaginatedValidateRefferals");
175 
 
176 
		} else {
177 
			model.addAttribute("refferals", refferals);
178 
 
179 
		}
180 
 
181 
		return "refferal-paginated";
182 
	}
183 
 
184 
	@RequestMapping(value = "/validateRefferal", method = RequestMethod.PUT)
185 
	public String validateRefferal(HttpServletRequest request,
186 
			@RequestParam(name = "refferalId", defaultValue = "0") int refferalId, Model model) throws Exception {
187 
 
188 
		Refferal refferal = refferalRepository.selectById(refferalId);
189 
 
190 
		if (refferal.getStatus().equals(RefferalStatus.pending)) {
191 
			refferal.setStatus(RefferalStatus.validate);
192 
			refferal.setUpdatedTimestamp(LocalDateTime.now());
193 
			refferalRepository.persist(refferal);
194 
			model.addAttribute("response", mvcResponseSender.createResponseString(true));
195 
 
196 
		} else {
197 
			model.addAttribute("response", mvcResponseSender.createResponseString(false));
198 
 
199 
		}
200 
 
201 
		return "response";
202 
	}
203 
 
25496 tejbeer 204 
	@RequestMapping(value = "/approveRefferal", method = RequestMethod.PUT)
205 
	public String approveRefferal(HttpServletRequest request,
206 
			@RequestParam(name = "refferalId", defaultValue = "0") int refferalId, Model model) throws Exception {
207 
 
208 
		Refferal refferal = refferalRepository.selectById(refferalId);
209 
 
25587 tejbeer 210 
		if (refferal.getStatus().equals(RefferalStatus.validate)) {
25496 tejbeer 211 
			refferal.setStatus(RefferalStatus.approved);
212 
			refferal.setUpdatedTimestamp(LocalDateTime.now());
213 
			refferal.setApprovedTimestamp(LocalDateTime.now());
214 
			refferalRepository.persist(refferal);
215 
			model.addAttribute("response", mvcResponseSender.createResponseString(true));
216 
 
217 
		} else {
218 
			model.addAttribute("response", mvcResponseSender.createResponseString(false));
219 
 
220 
		}
221 
 
222 
		return "response";
223 
	}
224 
 
225 
	@RequestMapping(value = "/rejectRefferal", method = RequestMethod.PUT)
226 
	public String rejectRefferal(HttpServletRequest request,
227 
			@RequestParam(name = "refferalId", defaultValue = "0") int refferalId, Model model) throws Exception {
228 
 
229 
		Refferal refferal = refferalRepository.selectById(refferalId);
230 
 
231 
		if (refferal.getStatus().equals(RefferalStatus.pending)) {
232 
			refferal.setStatus(RefferalStatus.rejected);
233 
			refferal.setUpdatedTimestamp(LocalDateTime.now());
234 
			refferalRepository.persist(refferal);
235 
			model.addAttribute("response", mvcResponseSender.createResponseString(true));
236 
 
237 
		} else {
238 
			model.addAttribute("response", mvcResponseSender.createResponseString(false));
239 
 
240 
		}
241 
 
242 
		return "response";
243 
	}
244 
 
245 
	@RequestMapping(value = "/approvedRefferals", method = RequestMethod.GET)
246 
	public String approvedRefferals(HttpServletRequest request, Model model) throws Exception {
247 
		DateRangeModel drm = new DateRangeModel();
248 
		drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
249 
		drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
25587 tejbeer 250 
 
25496 tejbeer 251 
		List<Refferal> previousMonthapprovedRefferal = refferalRepository
25587 tejbeer 252 
				.selectByStatusAndDateRanges(RefferalStatus.approved, drm);
253 
 
25496 tejbeer 254 
		drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
255 
		drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
256 
		LocalDateTime currentMonthdate = LocalDateTime.now().withDayOfMonth(1);
25587 tejbeer 257 
 
258 
		List<Refferal> preCurrMonthapproved = refferalRepository
259 
				.selectByStatusAndDateRange(RefferalStatus.approved, drm).stream()
25496 tejbeer 260 
				.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
25587 tejbeer 261 
		preCurrMonthapproved.addAll(previousMonthapprovedRefferal);
25496 tejbeer 262 
 
25587 tejbeer 263 
		Map<String, Long> preApproved = preCurrMonthapproved.stream()
264 
				.collect(Collectors.groupingBy(Refferal::getRefereeEmail, Collectors.counting()));
25496 tejbeer 265 
 
266 
		drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(1));
267 
		drm.setEndDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
25587 tejbeer 268 
 
269 
		LocalDateTime previousMonthdate = LocalDateTime.now().minusMonths(1).withDayOfMonth(1);
270 
		List<Refferal> oldMonthapprovedRefferal = refferalRepository
271 
				.selectByStatusAndDateRanges(RefferalStatus.approved, drm);
272 
 
25496 tejbeer 273 
		drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
274 
		drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
275 
 
25587 tejbeer 276 
		List<Refferal> oldPreMonthapproved = refferalRepository.selectByStatusAndDateRange(RefferalStatus.approved, drm)
277 
				.stream().filter(x -> x.getCreatedTimestamp().isBefore(previousMonthdate)).collect(Collectors.toList());
25496 tejbeer 278 
 
25587 tejbeer 279 
		oldPreMonthapproved.addAll(oldMonthapprovedRefferal);
25496 tejbeer 280 
 
25587 tejbeer 281 
		Map<String, Long> oldApproved = oldPreMonthapproved.stream()
282 
				.collect(Collectors.groupingBy(Refferal::getRefereeEmail, Collectors.counting()));
283 
		LOGGER.info("preApproved" + preApproved);
284 
 
285 
		LOGGER.info("oldApproved" + oldApproved);
25496 tejbeer 286 
		model.addAttribute("oldMonth", LocalDateTime.now().minusMonths(2).getMonth());
25587 tejbeer 287 
		model.addAttribute("oldApproved", oldApproved);
25496 tejbeer 288 
		model.addAttribute("previousMonth", LocalDateTime.now().minusMonths(1).getMonth());
25587 tejbeer 289 
		model.addAttribute("preApproved", preApproved);
290 
 
291 
		return "refferal-approve";
25496 tejbeer 292 
	}
293 
 
294 
	@RequestMapping(value = "/addMoneyToWallet", method = RequestMethod.POST)
295 
	public String addMoneyToWallet(HttpServletRequest request, @RequestParam String refereeEmail,
296 
			@RequestParam int count, @RequestParam int amount, @RequestParam String month, Model model)
297 
			throws Exception {
298 
 
299 
		User user = userRepository.selectByEmailId(refereeEmail);
300 
		if (user != null) {
301 
			RefferalMonthlyAmount rfm = new RefferalMonthlyAmount();
302 
			rfm.setAmount(amount);
303 
			rfm.setCount(count);
25587 tejbeer 304 
			rfm.setRefereeEmail(user.getEmailId());
25496 tejbeer 305 
			rfm.setCreatedTimstamp(LocalDateTime.now());
306 
			refferalMonthlyAmountRepository.persist(rfm);
307 
			walletService.addAmountToWallet(user.getId(), rfm.getId(), WalletReferenceType.CASHBACK,
308 
					count + "refferal of" + month + "Month", amount);
309 
 
310 
			DateRangeModel drm = new DateRangeModel();
311 
			drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(1));
312 
			drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
313 
			List<Refferal> previousMonthapprovedRefferal = refferalRepository
25587 tejbeer 314 
					.selectByEmailIdAndStatusAndDateRanges(user.getEmailId(), RefferalStatus.approved, drm);
25496 tejbeer 315 
			drm.setStartDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
316 
			drm.setEndDate(LocalDateTime.now().withDayOfMonth(16));
317 
			List<Refferal> previousAndcurrentMonthapprovedRefferal = refferalRepository
25587 tejbeer 318 
					.selectByEmailIdAndStatusAndDateRange(user.getEmailId(), RefferalStatus.approved, drm);
25496 tejbeer 319 
			LocalDateTime currentMonthdate = LocalDateTime.now().withDayOfMonth(1);
320 
			List<Refferal> preCurrMonthapproved = previousAndcurrentMonthapprovedRefferal.stream()
321 
					.filter(x -> x.getCreatedTimestamp().isBefore(currentMonthdate)).collect(Collectors.toList());
322 
			List<Refferal> approvedRefferals = new ArrayList<>(previousMonthapprovedRefferal);
323 
			approvedRefferals.addAll(preCurrMonthapproved);
324 
 
325 
			for (Refferal refferl : approvedRefferals) {
326 
				refferl.setStatus(RefferalStatus.transferred);
327 
				refferl.setUpdatedTimestamp(LocalDateTime.now());
328 
			}
329 
 
330 
			model.addAttribute("response", mvcResponseSender.createResponseString(true));
331 
		} else {
332 
			model.addAttribute("response", mvcResponseSender.createResponseString(false));
333 
		}
334 
		return "response";
335 
	}
336 
 
337 
	@RequestMapping(value = "/addMoneyToWalletPreviousMonth", method = RequestMethod.POST)
338 
	public String addMoneyToWalletPrevious(HttpServletRequest request, @RequestParam String refereeEmail,
339 
			@RequestParam int count, @RequestParam int amount, @RequestParam String month, Model model)
340 
			throws Exception {
341 
 
342 
		User user = userRepository.selectByEmailId(refereeEmail);
343 
		if (user != null) {
344 
			RefferalMonthlyAmount rfm = new RefferalMonthlyAmount();
345 
			rfm.setAmount(amount);
346 
			rfm.setCount(count);
25587 tejbeer 347 
			rfm.setRefereeEmail(user.getEmailId());
25496 tejbeer 348 
			rfm.setCreatedTimstamp(LocalDateTime.now());
349 
			refferalMonthlyAmountRepository.persist(rfm);
350 
			walletService.addAmountToWallet(user.getId(), rfm.getId(), WalletReferenceType.CASHBACK,
351 
					count + "refferal of" + month + "Month", amount);
352 
 
353 
			DateRangeModel drm = new DateRangeModel();
354 
			drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(1));
355 
			drm.setEndDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
356 
			List<Refferal> oldMonthapprovedRefferal = refferalRepository
25587 tejbeer 357 
					.selectByEmailIdAndStatusAndDateRanges(user.getEmailId(), RefferalStatus.approved, drm);
358 
			LOGGER.info("oldMonthapprovedRefferal" + oldMonthapprovedRefferal);
359 
 
25496 tejbeer 360 
			drm.setStartDate(LocalDateTime.now().minusMonths(2).withDayOfMonth(16));
361 
			drm.setEndDate(LocalDateTime.now().minusMonths(1).withDayOfMonth(16));
362 
			List<Refferal> oldAndpreviousMonthapprovedRefferal = refferalRepository
25587 tejbeer 363 
					.selectByEmailIdAndStatusAndDateRange(user.getEmailId(), RefferalStatus.approved, drm);
25496 tejbeer 364 
			LocalDateTime previousMonthdate = LocalDateTime.now().minusMonths(1).withDayOfMonth(1);
365 
			List<Refferal> oldPreMonthapproved = oldAndpreviousMonthapprovedRefferal.stream()
366 
					.filter(x -> x.getCreatedTimestamp().isBefore(previousMonthdate)).collect(Collectors.toList());
367 
 
25587 tejbeer 368 
			oldPreMonthapproved.addAll(oldMonthapprovedRefferal);
25496 tejbeer 369 
 
25587 tejbeer 370 
			LOGGER.info("oldPreMonthapproved" + oldPreMonthapproved);
371 
			for (Refferal refferl : oldPreMonthapproved) {
25496 tejbeer 372 
				refferl.setStatus(RefferalStatus.transferred);
373 
				refferl.setUpdatedTimestamp(LocalDateTime.now());
374 
			}
375 
 
376 
			model.addAttribute("response", mvcResponseSender.createResponseString(true));
377 
		} else {
378 
			model.addAttribute("response", mvcResponseSender.createResponseString(false));
379 
		}
380 
		return "response";
381 
	}
382 
 
383 
	@RequestMapping(value = "/getTransferredRefferals", method = RequestMethod.GET)
384 
	public String getTransferredRefferals(HttpServletRequest request,
385 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
386 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
387 
			throws ProfitMandiBusinessException {
388 
 
389 
		List<Refferal> refferals = null;
390 
		long size = 0;
391 
		refferals = refferalRepository.selectAllRefferalByStatus(offset, limit, RefferalStatus.transferred);
392 
		LOGGER.info("refferals" + refferals);
393 
		size = refferalRepository.selectCountByStatus(RefferalStatus.transferred);
394 
		if (!refferals.isEmpty()) {
395 
 
396 
			model.addAttribute("refferals", refferals);
397 
			model.addAttribute("start", offset + 1);
398 
			model.addAttribute("size", size);
399 
			model.addAttribute("url", "/getPaginatedTransferredRefferals");
400 
 
401 
			if (refferals.size() < limit) {
402 
				model.addAttribute("end", offset + refferals.size());
403 
			} else {
404 
				model.addAttribute("end", offset + limit);
405 
			}
406 
 
407 
		} else {
408 
 
409 
			model.addAttribute("refferals", refferals);
410 
			model.addAttribute("size", size);
411 
 
412 
		}
413 
 
414 
		return "refferal";
415 
	}
416 
 
417 
	@RequestMapping(value = "/getPaginatedTransferredRefferals", method = RequestMethod.GET)
418 
	public String getPaginatedTransferredRefferals(HttpServletRequest request,
419 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
420 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model) throws Exception {
421 
		LOGGER.info("requested offset=[{}], limit = [{}]", offset, limit);
422 
		List<Refferal> refferals = null;
423 
		refferals = refferalRepository.selectAllRefferalByStatus(offset, limit, RefferalStatus.transferred);
424 
		LOGGER.info("refferals" + refferals);
425 
		if (!refferals.isEmpty()) {
426 
 
427 
			model.addAttribute("refferals", refferals);
428 
			model.addAttribute("url", "/getPaginatedTransferredRefferals");
429 
 
430 
		} else {
431 
			model.addAttribute("refferals", refferals);
432 
 
433 
		}
434 
 
435 
		return "refferal-paginated";
436 
	}
437 
}