Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
21615 kshitij.so 1
package com.spice.profitmandi.web.controller;
2
 
25651 tejbeer 3
import java.io.File;
4
import java.io.FileInputStream;
5
import java.io.FileNotFoundException;
24288 amit.gupta 6
import java.time.LocalDate;
24276 amit.gupta 7
import java.time.LocalDateTime;
24880 govind 8
import java.time.LocalTime;
25649 tejbeer 9
import java.time.ZoneOffset;
24339 amit.gupta 10
import java.util.ArrayList;
26027 amit.gupta 11
import java.util.Arrays;
26011 amit.gupta 12
import java.util.HashMap;
26090 amit.gupta 13
import java.util.HashSet;
25136 amit.gupta 14
import java.util.LinkedHashMap;
23884 amit.gupta 15
import java.util.List;
24880 govind 16
import java.util.Map;
26055 tejbeer 17
import java.util.Map.Entry;
26071 tejbeer 18
import java.util.Optional;
26090 amit.gupta 19
import java.util.Set;
24880 govind 20
import java.util.stream.Collectors;
23568 govind 21
 
22086 amit.gupta 22
import javax.servlet.http.HttpServletRequest;
25221 amit.gupta 23
import javax.transaction.Transactional;
22086 amit.gupta 24
 
23786 amit.gupta 25
import org.apache.logging.log4j.LogManager;
23568 govind 26
import org.apache.logging.log4j.Logger;
26158 amit.gupta 27
import org.json.JSONObject;
22481 ashik.ali 28
import org.springframework.beans.factory.annotation.Autowired;
23379 ashik.ali 29
import org.springframework.beans.factory.annotation.Value;
25651 tejbeer 30
import org.springframework.core.io.InputStreamResource;
31
import org.springframework.http.HttpHeaders;
32
import org.springframework.http.HttpStatus;
25649 tejbeer 33
import org.springframework.http.ResponseEntity;
21615 kshitij.so 34
import org.springframework.stereotype.Controller;
22073 ashik.ali 35
import org.springframework.ui.Model;
21615 kshitij.so 36
import org.springframework.web.bind.annotation.RequestMapping;
37
import org.springframework.web.bind.annotation.RequestMethod;
25649 tejbeer 38
import org.springframework.web.bind.annotation.RequestParam;
21615 kshitij.so 39
 
25649 tejbeer 40
import com.google.gson.Gson;
25677 amit.gupta 41
import com.mongodb.DBObject;
25651 tejbeer 42
import com.spice.profitmandi.common.enumuration.ContentType;
25683 tejbeer 43
import com.spice.profitmandi.common.enumuration.MessageType;
26065 amit.gupta 44
import com.spice.profitmandi.common.enumuration.ReporticoProject;
22481 ashik.ali 45
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
25677 amit.gupta 46
import com.spice.profitmandi.common.model.BrandStockPrice;
26055 tejbeer 47
import com.spice.profitmandi.common.model.ChartModel;
26005 amit.gupta 48
import com.spice.profitmandi.common.model.CustomRetailer;
26055 tejbeer 49
import com.spice.profitmandi.common.model.DataModel;
50
import com.spice.profitmandi.common.model.DatasetModel;
51
import com.spice.profitmandi.common.model.LegendModel;
25649 tejbeer 52
import com.spice.profitmandi.common.model.Notification;
26055 tejbeer 53
import com.spice.profitmandi.common.model.OptionsModel;
24203 amit.gupta 54
import com.spice.profitmandi.common.model.ProfitMandiConstants;
26055 tejbeer 55
import com.spice.profitmandi.common.model.TitleModel;
25651 tejbeer 56
import com.spice.profitmandi.common.web.util.ResponseSender;
25649 tejbeer 57
import com.spice.profitmandi.dao.Interface.Campaign;
26011 amit.gupta 58
import com.spice.profitmandi.dao.entity.auth.AuthUser;
59
import com.spice.profitmandi.dao.entity.auth.Menu;
60
import com.spice.profitmandi.dao.entity.cs.Position;
25651 tejbeer 61
import com.spice.profitmandi.dao.entity.dtr.Document;
25649 tejbeer 62
import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;
22654 ashik.ali 63
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
24288 amit.gupta 64
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
25214 amit.gupta 65
import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
25566 tejbeer 66
import com.spice.profitmandi.dao.entity.fofo.PartnerType;
26024 amit.gupta 67
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
25649 tejbeer 68
import com.spice.profitmandi.dao.model.SimpleCampaign;
69
import com.spice.profitmandi.dao.model.SimpleCampaignParams;
25976 amit.gupta 70
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
26011 amit.gupta 71
import com.spice.profitmandi.dao.repository.auth.MenuCategoryRepository;
72
import com.spice.profitmandi.dao.repository.auth.MenuRepository;
26090 amit.gupta 73
import com.spice.profitmandi.dao.repository.cs.CsService;
26011 amit.gupta 74
import com.spice.profitmandi.dao.repository.cs.PositionRepository;
75
import com.spice.profitmandi.dao.repository.cs.TicketCategoryRepository;
25651 tejbeer 76
import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
22481 ashik.ali 77
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
24996 amit.gupta 78
import com.spice.profitmandi.dao.repository.dtr.Mongo;
25649 tejbeer 79
import com.spice.profitmandi.dao.repository.dtr.NotificationCampaignRepository;
80
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
81
import com.spice.profitmandi.dao.repository.dtr.UserCampaignRepository;
24203 amit.gupta 82
import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
24880 govind 83
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
26071 tejbeer 84
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
25649 tejbeer 85
import com.spice.profitmandi.dao.repository.fofo.HygieneDataRepository;
26234 amit.gupta 86
import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
24288 amit.gupta 87
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
25214 amit.gupta 88
import com.spice.profitmandi.dao.repository.fofo.PartnerTargetRepository;
25566 tejbeer 89
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
24336 amit.gupta 90
import com.spice.profitmandi.service.PartnerInvestmentService;
23844 amit.gupta 91
import com.spice.profitmandi.service.authentication.RoleManager;
25677 amit.gupta 92
import com.spice.profitmandi.service.inventory.InventoryService;
26005 amit.gupta 93
import com.spice.profitmandi.service.user.RetailerService;
22481 ashik.ali 94
import com.spice.profitmandi.web.model.LoginDetails;
95
import com.spice.profitmandi.web.util.CookiesProcessor;
96
 
21615 kshitij.so 97
@Controller
25222 amit.gupta 98
@Transactional(rollbackOn = Throwable.class)
21615 kshitij.so 99
public class DashboardController {
23923 amit.gupta 100
 
23379 ashik.ali 101
	@Value("${web.api.host}")
102
	private String webApiHost;
23923 amit.gupta 103
 
24072 amit.gupta 104
	@Value("${web.api.scheme}")
105
	private String webApiScheme;
24288 amit.gupta 106
 
24078 amit.gupta 107
	@Value("${web.api.root}")
108
	private String webApiRoot;
109
 
23379 ashik.ali 110
	@Value("${web.api.port}")
111
	private int webApiPort;
21615 kshitij.so 112
 
22481 ashik.ali 113
	@Autowired
22927 ashik.ali 114
	private CookiesProcessor cookiesProcessor;
23923 amit.gupta 115
 
23568 govind 116
	@Autowired
26011 amit.gupta 117
	private MenuRepository menuRepository;
26012 amit.gupta 118
 
26011 amit.gupta 119
	@Autowired
120
	private MenuCategoryRepository menuCategoryRepository;
121
 
122
	@Autowired
26090 amit.gupta 123
	private CsService csService;
124
 
125
	@Autowired
25214 amit.gupta 126
	private PartnerTargetRepository partnerTargetRepository;
127
 
128
	@Autowired
25653 amit.gupta 129
	private ResponseSender<?> responseSender;
26012 amit.gupta 130
 
26005 amit.gupta 131
	@Autowired
132
	RetailerService retailerService;
25214 amit.gupta 133
 
134
	@Autowired
23786 amit.gupta 135
	private RoleManager roleManager;
23923 amit.gupta 136
 
23838 ashik.ali 137
	@Autowired
138
	private FofoStoreRepository fofoStoreRepository;
23884 amit.gupta 139
 
140
	@Autowired
24880 govind 141
	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
23923 amit.gupta 142
 
23884 amit.gupta 143
	@Autowired
24880 govind 144
	private PartnerInvestmentService partnerInvestmentService;
24288 amit.gupta 145
 
23884 amit.gupta 146
	@Autowired
25653 amit.gupta 147
	DocumentRepository documentRepository;
26236 amit.gupta 148
 
26234 amit.gupta 149
	@Autowired
150
	InventoryItemRepository inventoryItemRepository;
25683 tejbeer 151
 
25677 amit.gupta 152
	@Autowired
153
	InventoryService inventoryService;
23923 amit.gupta 154
 
23884 amit.gupta 155
	@Autowired
24203 amit.gupta 156
	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
157
 
24880 govind 158
	@Autowired
159
	private FofoOrderItemRepository fofoOrderItemRepository;
26012 amit.gupta 160
 
26011 amit.gupta 161
	@Autowired
162
	private TicketCategoryRepository ticketCategoryRepository;
24880 govind 163
 
164
	@Autowired
25566 tejbeer 165
	private PartnerTypeChangeService partnerTypeChangeService;
25136 amit.gupta 166
 
24996 amit.gupta 167
	@Autowired
25649 tejbeer 168
	private HygieneDataRepository hygieneDataRepository;
169
 
170
	@Autowired
171
	private UserCampaignRepository userCampaignRepository;
26012 amit.gupta 172
 
26011 amit.gupta 173
	@Autowired
174
	private PositionRepository positionRepository;
25649 tejbeer 175
 
176
	@Autowired
177
	private UserAccountRepository userAccountRepository;
178
 
179
	@Autowired
180
	private NotificationCampaignRepository notificationCampaignRepository;
181
 
182
	@Autowired
24996 amit.gupta 183
	private Mongo mongoClient;
26012 amit.gupta 184
 
25976 amit.gupta 185
	@Autowired
186
	private AuthRepository authRepository;
24880 govind 187
 
25649 tejbeer 188
	@Autowired
26071 tejbeer 189
	private FofoOrderRepository fofoOrderRepository;
190
 
191
	@Autowired
25649 tejbeer 192
	private Gson gson;
193
 
23568 govind 194
	private static final Logger LOGGER = LogManager.getLogger(DashboardController.class);
23923 amit.gupta 195
 
25136 amit.gupta 196
	@RequestMapping(value = "/12dashboard34", method = RequestMethod.GET)
25726 amit.gupta 197
	public String dashboard1(HttpServletRequest request, Model model, @RequestParam int fofoId) throws Exception {
25740 amit.gupta 198
		boolean isAdmin = false;
199
		model.addAttribute("isAdmin", isAdmin);
200
 
201
		model.addAttribute("webApiHost", webApiHost);
202
		model.addAttribute("webApiPort", webApiPort);
203
		model.addAttribute("webApiScheme", webApiScheme);
204
		model.addAttribute("webApiRoot", webApiRoot);
205
		if (isAdmin) {
206
			return "dashboard1";
26236 amit.gupta 207
		}
208
 
209
		FofoStore fofoStore = null;
26234 amit.gupta 210
		try {
211
			CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
212
			fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
213
			if (!fofoStore.isActive()) {
214
				return "redirect:/login";
215
			}
25740 amit.gupta 216
 
26234 amit.gupta 217
			PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoStore.getId(), LocalDate.now());
218
			model.addAttribute("partnerType", partnerType);
219
			model.addAttribute("partnerTypeImage", PartnerType.imageMap.get(partnerType));
220
			model.addAttribute("fofoStore", customRetailer);
221
			model.addAttribute("partnerType", partnerType);
222
			model.addAttribute("hasGift", hasGift(fofoId));
223
			model.addAttribute("giftItemId", ProfitMandiConstants.GIFT_ID);
25740 amit.gupta 224
 
26234 amit.gupta 225
			model.addAttribute("brandStockPrices", this.getBrandStockPrices(fofoId));
226
			model.addAttribute("salesMap", this.getSales(fofoId));
227
			model.addAttribute("activatedImeis", inventoryItemRepository.selectCountByActivatedNotSold(fofoId));
228
			// this.setInvestments
229
			//
230
			model.addAttribute("investments", this.getInvestments(fofoId));
231
			model.addAttribute("isInvestmentOk",
232
					partnerInvestmentService.isInvestmentOk(fofoId, 10, ProfitMandiConstants.CUTOFF_INVESTMENT));
233
		} catch (ProfitMandiBusinessException e) {
234
			LOGGER.error("FofoStore Code not found of fofoId {}", fofoId);
25740 amit.gupta 235
 
236
		}
237
 
238
		LocalDateTime currentMonthStart = LocalDateTime.now().withDayOfMonth(1);
239
		LocalDateTime currentMonthEnd = currentMonthStart.plusMonths(1).withDayOfMonth(1);
26012 amit.gupta 240
		double currentMonthRating = hygieneDataRepository.selectRatingAvg(fofoId, currentMonthStart, currentMonthEnd)
241
				/ 2;
242
		double lastMonthRating = hygieneDataRepository.selectRatingAvg(fofoId, currentMonthStart, currentMonthEnd) / 2;
243
		double ratingTillDate = hygieneDataRepository.selectRatingAvg(fofoId, currentMonthStart, currentMonthEnd) / 2;
25740 amit.gupta 244
		model.addAttribute("currentMonthRating", (float) Math.round(currentMonthRating * 10) / 10);
245
		model.addAttribute("lastMonthRating", (float) Math.round(lastMonthRating * 10) / 10);
246
		model.addAttribute("ratingTillDate", (float) Math.round(ratingTillDate * 10) / 10);
247
 
26012 amit.gupta 248
		long hygieneCount = hygieneDataRepository.selectHygieneCount(fofoId, true, currentMonthStart, currentMonthEnd);
249
 
250
		long invalidHygieneCount = hygieneDataRepository.selectHygieneCount(fofoId, false, currentMonthStart,
25740 amit.gupta 251
				currentMonthEnd);
252
		if (hygieneCount == 0 && invalidHygieneCount == 0) {
253
			invalidHygieneCount = 1;
254
		}
255
		model.addAttribute("hygienePercentage", (hygieneCount * 100) / (invalidHygieneCount + hygieneCount));
256
 
257
		model.addAttribute("monthDays", LocalDate.now().minusDays(1).lengthOfMonth());
258
		model.addAttribute("dayOfMonth", LocalDate.now().minusDays(1).getDayOfMonth());
259
		return "12dashboard34";
25136 amit.gupta 260
	}
261
 
262
	private Map<String, Object> getInvestments(int fofoId) throws Exception {
263
		Map<String, Object> investments = new LinkedHashMap<>();
26233 amit.gupta 264
		PartnerDailyInvestment investment = partnerInvestmentService.getInvestment(fofoId, 0);
25649 tejbeer 265
		LocalDate currentMonthStart = LocalDate.now().withDayOfMonth(1);
25136 amit.gupta 266
		LocalDate yesterDate = LocalDate.now().minusDays(1);
267
		PartnerDailyInvestment yesterdayInvestment = partnerDailyInvestmentRepository.select(fofoId, yesterDate);
268
		if (yesterdayInvestment == null) {
269
			yesterdayInvestment = new PartnerDailyInvestment();
270
		}
271
 
272
		List<PartnerDailyInvestment> currentMonthInvestments = partnerDailyInvestmentRepository.selectAll(fofoId,
273
				currentMonthStart, currentMonthStart.withDayOfMonth(currentMonthStart.lengthOfMonth()));
274
 
25140 amit.gupta 275
		long okInvestmentDays = currentMonthInvestments.stream().filter(x -> x.getShortPercentage() <= 10)
25136 amit.gupta 276
				.collect(Collectors.counting());
25140 amit.gupta 277
		investments.put("today", investment.getTotalInvestment());
278
		investments.put("investment", investment);
279
		investments.put("inStock", investment.getInStockAmount());
25182 amit.gupta 280
		investments.put("minimum", investment.getMinInvestmentString());
25140 amit.gupta 281
		investments.put("short", investment.getShortPercentage());
25649 tejbeer 282
		investments.put("okDays", okInvestmentDays);
25136 amit.gupta 283
		return investments;
284
	}
285
 
25221 amit.gupta 286
	private Map<String, Object> getSales(int fofoId) {
25653 amit.gupta 287
 
25221 amit.gupta 288
		Map<String, Object> salesMap = new LinkedHashMap<>();
25140 amit.gupta 289
		LocalDateTime curDate = LocalDate.now().atStartOfDay();
25214 amit.gupta 290
		int monthLength = LocalDate.now().lengthOfMonth();
26012 amit.gupta 291
		Double todaySale = fofoOrderItemRepository
292
				.selectSumAmountGroupByRetailer(curDate, curDate.with(LocalTime.MAX), fofoId, false).get(fofoId);
293
		Double mtdSale = fofoOrderItemRepository
294
				.selectSumAmountGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), fofoId, false)
295
				.get(fofoId);
296
		Double lmtdSale = fofoOrderItemRepository
297
				.selectSumAmountGroupByRetailer(curDate.withDayOfMonth(1).minusMonths(1),
298
						curDate.with(LocalTime.MAX).minusMonths(1), fofoId, false)
299
				.get(fofoId);
25214 amit.gupta 300
 
301
		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository
302
				.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now());
25544 amit.gupta 303
		if (partnerTargetDetails.isEmpty()) {
25372 tejbeer 304
			partnerTargetDetails = partnerTargetRepository
25653 amit.gupta 305
					.selectAllGeEqAndLeEqStartDateAndEndDate(LocalDateTime.now().minusMonths(3));
25372 tejbeer 306
		}
25214 amit.gupta 307
 
25653 amit.gupta 308
		PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoId, LocalDate.now());
25214 amit.gupta 309
 
25664 amit.gupta 310
		int currentRate = (int) (mtdSale / curDate.getDayOfMonth());
25653 amit.gupta 311
 
312
		salesMap.put("requiredType", partnerType.next());
313
		float reqdAmount = partnerTypeChangeService.getMinimumAmount(partnerType.next());
314
		int requiredRate = (int) ((reqdAmount - mtdSale) / (monthLength - curDate.getDayOfMonth()));
315
		salesMap.put("requiredRate", requiredRate);
316
		salesMap.put("requiredTypeImage", PartnerType.imageMap.get(partnerType.next()));
317
 
25858 amit.gupta 318
		salesMap.put("todaySale", todaySale == null ? 0 : todaySale);
319
		salesMap.put("mtdSale", mtdSale == null ? 0 : mtdSale);
26012 amit.gupta 320
		salesMap.put("lmtdSale", lmtdSale == null ? 0 : lmtdSale);
26065 amit.gupta 321
 
25653 amit.gupta 322
		PartnerType currentType = partnerTypeChangeService.getPartnerTypeByAmount(currentRate * monthLength);
323
		salesMap.put("currentRate", currentRate);
324
		salesMap.put("currentType", currentType);
325
		salesMap.put("currentTypeImage", PartnerType.imageMap.get(currentType));
25136 amit.gupta 326
		return salesMap;
327
	}
328
 
25677 amit.gupta 329
	private List<BrandStockPrice> getBrandStockPrices(int fofoId) throws Exception {
330
		Map<String, BrandStockPrice> brandStockPricesMap = inventoryService.getBrandWiseStockValue(fofoId);
25175 amit.gupta 331
 
25677 amit.gupta 332
		List<DBObject> mobileBrands = mongoClient.getMongoBrands(fofoId, "", 3);
333
		List<BrandStockPrice> brandStockPrices = new ArrayList<>();
334
 
335
		mobileBrands.stream().forEach(x -> {
336
			String brand = (String) x.get("name");
337
			if (brandStockPricesMap.containsKey(brand)) {
338
				BrandStockPrice brandStockPrice = brandStockPricesMap.get(brand);
339
				brandStockPrice.setBrandUrl((String) x.get("url"));
340
				brandStockPrice.setRank(((Double) x.get("rank")).intValue());
341
				brandStockPrices.add(brandStockPrice);
342
			}
343
		});
344
 
345
		return brandStockPrices.stream().filter(x -> x.getTotalQty() > 0).sorted((x, y) -> x.getRank() - y.getRank())
346
				.collect(Collectors.toList());
347
	}
348
 
21615 kshitij.so 349
	@RequestMapping(value = "/dashboard", method = RequestMethod.GET)
25653 amit.gupta 350
	public String dashboard(HttpServletRequest request, Model model) throws Exception {
22927 ashik.ali 351
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
26011 amit.gupta 352
		String email = loginDetails.getEmailId();
25180 amit.gupta 353
		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
354
		model.addAttribute("isAdmin", isAdmin);
23923 amit.gupta 355
 
25274 amit.gupta 356
		model.addAttribute("webApiHost", webApiHost);
357
		model.addAttribute("webApiPort", webApiPort);
358
		model.addAttribute("webApiScheme", webApiScheme);
25544 amit.gupta 359
		model.addAttribute("webApiRoot", webApiRoot);
25183 amit.gupta 360
		if (isAdmin) {
26011 amit.gupta 361
			return adminPanel(loginDetails.getFofoId(), email, model);
25180 amit.gupta 362
		} else {
25740 amit.gupta 363
			FofoStore fofoStore = null;
25180 amit.gupta 364
			try {
365
				fofoStore = fofoStoreRepository.selectByRetailerId(loginDetails.getFofoId());
25544 amit.gupta 366
				if (!fofoStore.isActive()) {
367
					return "redirect:/login";
368
				}
25649 tejbeer 369
 
25740 amit.gupta 370
				PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fofoStore.getId(), LocalDate.now());
25566 tejbeer 371
				model.addAttribute("partnerType", partnerType);
25653 amit.gupta 372
				model.addAttribute("partnerTypeImage", PartnerType.imageMap.get(partnerType));
25180 amit.gupta 373
				model.addAttribute("fofoStore", fofoStore);
25566 tejbeer 374
				model.addAttribute("partnerType", partnerType);
25180 amit.gupta 375
				model.addAttribute("hasGift", hasGift(loginDetails.getFofoId()));
376
				model.addAttribute("giftItemId", ProfitMandiConstants.GIFT_ID);
26222 tejbeer 377
				model.addAttribute("retailers", new JSONObject().append("code", fofoStore.getCode())
26162 amit.gupta 378
						.append("partnerId", fofoStore.getId()).toString());
26237 amit.gupta 379
				model.addAttribute("activatedImeis", inventoryItemRepository.selectCountByActivatedNotSold(loginDetails.getFofoId()));
26071 tejbeer 380
				LocalDateTime curDate = LocalDate.now().atStartOfDay();
381
				Map<Integer, Double> accesoriesmtdsale = fofoOrderRepository
382
						.selectSumSaleGroupByFofoIdsForMobileOrAccessories(loginDetails.getFofoId(),
383
								curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), Optional.of(false));
384
				LOGGER.info("accesoriesmtdsale" + accesoriesmtdsale);
385
				Double accesoriesStock = currentInventorySnapshotRepository
386
						.selectSumStockGroupByFofoIdsForMobileOrAccessories(loginDetails.getFofoId(),
387
								Optional.of(false))
388
						.get(loginDetails.getFofoId());
25180 amit.gupta 389
 
26071 tejbeer 390
				model.addAttribute("accesoriesStock", String.format("%.0f", accesoriesStock));
26065 amit.gupta 391
				model.addAttribute("brandStockPrices", this.getBrandStockPrices(loginDetails.getFofoId()));
25180 amit.gupta 392
				model.addAttribute("salesMap", this.getSales(loginDetails.getFofoId()));
26055 tejbeer 393
				ChartModel cm = this.getBrandChart(loginDetails.getFofoId());
394
 
395
				LOGGER.info("chartMap" + gson.toJson(cm));
396
				model.addAttribute("chartMap", gson.toJson(cm));
25544 amit.gupta 397
				// this.setInvestments
398
				//
25180 amit.gupta 399
				model.addAttribute("investments", this.getInvestments(loginDetails.getFofoId()));
25544 amit.gupta 400
				model.addAttribute("isInvestmentOk", partnerInvestmentService.isInvestmentOk(loginDetails.getFofoId(),
401
						10, ProfitMandiConstants.CUTOFF_INVESTMENT));
25180 amit.gupta 402
			} catch (ProfitMandiBusinessException e) {
403
				LOGGER.error("FofoStore Code not found of fofoId {}", loginDetails.getFofoId());
404
 
405
			}
22481 ashik.ali 406
		}
25649 tejbeer 407
 
408
		LocalDateTime currentMonthStart = LocalDateTime.now().withDayOfMonth(1);
25747 amit.gupta 409
		LocalDateTime lastMonthStart = currentMonthStart.minusMonths(1);
25653 amit.gupta 410
		LocalDateTime currentMonthEnd = currentMonthStart.plusMonths(1).withDayOfMonth(1);
411
		double currentMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), currentMonthStart,
25677 amit.gupta 412
				currentMonthEnd) / 2;
25747 amit.gupta 413
		double lastMonthRating = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), lastMonthStart,
414
				currentMonthStart) / 2;
415
		double ratingTillDate = hygieneDataRepository.selectRatingAvg(loginDetails.getFofoId(), LocalDateTime.MIN,
25677 amit.gupta 416
				currentMonthEnd) / 2;
417
		model.addAttribute("currentMonthRating", (float) Math.round(currentMonthRating * 10) / 10);
418
		model.addAttribute("lastMonthRating", (float) Math.round(lastMonthRating * 10) / 10);
419
		model.addAttribute("ratingTillDate", (float) Math.round(ratingTillDate * 10) / 10);
25649 tejbeer 420
 
25653 amit.gupta 421
		long hygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), true, currentMonthStart,
422
				currentMonthEnd);
25651 tejbeer 423
 
25653 amit.gupta 424
		long invalidHygieneCount = hygieneDataRepository.selectHygieneCount(loginDetails.getFofoId(), false,
425
				currentMonthStart, currentMonthEnd);
426
		if (hygieneCount == 0 && invalidHygieneCount == 0) {
427
			invalidHygieneCount = 1;
428
		}
429
		model.addAttribute("hygienePercentage", (hygieneCount * 100) / (invalidHygieneCount + hygieneCount));
25651 tejbeer 430
 
25197 amit.gupta 431
		model.addAttribute("monthDays", LocalDate.now().minusDays(1).lengthOfMonth());
432
		model.addAttribute("dayOfMonth", LocalDate.now().minusDays(1).getDayOfMonth());
25140 amit.gupta 433
		return "dashboard1";
21615 kshitij.so 434
	}
23923 amit.gupta 435
 
26055 tejbeer 436
	private ChartModel getBrandChart(int fofoId) {
437
 
438
		LocalDateTime curDate = LocalDate.now().atStartOfDay();
439
 
440
		LOGGER.info("cur Date" + curDate.withDayOfMonth(1));
441
 
442
		LOGGER.info("curDateYear" + curDate.with(LocalTime.MAX));
443
 
444
		Map<String, Double> brandwisesale = fofoOrderItemRepository
445
				.selectSumAmountGroupByBrand(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), fofoId);
26244 tejbeer 446
 
447
		Map<Integer, Double> accesoriesmtdsale = fofoOrderRepository.selectSumSaleGroupByFofoIdsForMobileOrAccessories(
448
				fofoId, curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), Optional.of(false));
449
 
450
		LOGGER.info("accesoriesmtdsale" + accesoriesmtdsale);
451
 
26055 tejbeer 452
		LOGGER.info("brandwisesale" + brandwisesale);
453
 
454
		Map<String, Double> lmtdBrandWiseSale = fofoOrderItemRepository.selectSumAmountGroupByBrand(
455
				curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), fofoId);
456
 
26244 tejbeer 457
		Map<Integer, Double> accesorieslmtdsale = fofoOrderRepository.selectSumSaleGroupByFofoIdsForMobileOrAccessories(
458
				fofoId, curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1),
459
				Optional.of(false));
460
		LOGGER.info("accesorieslmtdsale" + accesorieslmtdsale);
26055 tejbeer 461
		ChartModel cm = new ChartModel();
462
 
463
		List<String> labels = new ArrayList<>();
464
		labels.addAll(brandwisesale.keySet());
26244 tejbeer 465
		labels.add("accessories");
26055 tejbeer 466
		List<Double> values = new ArrayList<>();
467
		values.addAll(brandwisesale.values());
26244 tejbeer 468
		values.addAll(accesoriesmtdsale.values());
26055 tejbeer 469
 
470
		List<Double> lmtdValues = new ArrayList<>();
471
		lmtdValues.addAll(lmtdBrandWiseSale.values());
26244 tejbeer 472
		lmtdValues.addAll(accesorieslmtdsale.values());
26055 tejbeer 473
 
474
		DatasetModel dsm = new DatasetModel();
475
		dsm.setLabel("mtd sales");
476
 
477
		List<String> backgroundColor = new ArrayList<>();
478
		for (Entry<String, Double> bs : brandwisesale.entrySet()) {
479
			backgroundColor.add("#3e95cd");
480
		}
26244 tejbeer 481
		backgroundColor.add("#3e95cd");
26055 tejbeer 482
		dsm.setBackgroundColor(backgroundColor);
483
		dsm.setData(values);
484
 
485
		DatasetModel lmtddsm = new DatasetModel();
486
		lmtddsm.setLabel("lmtd sales");
487
 
488
		List<String> background = new ArrayList<>();
489
		for (Entry<String, Double> bs : lmtdBrandWiseSale.entrySet()) {
490
			background.add("#8e5ea2");
491
		}
26244 tejbeer 492
		background.add("#8e5ea2");
26055 tejbeer 493
		lmtddsm.setBackgroundColor(background);
494
		lmtddsm.setData(lmtdValues);
495
 
496
		List<DatasetModel> datasets = new ArrayList<>();
497
		datasets.add(dsm);
498
		datasets.add(lmtddsm);
499
 
500
		DataModel dm = new DataModel();
501
		dm.setDatasets(datasets);
502
		dm.setLabels(labels);
503
 
504
		LegendModel lm = new LegendModel();
505
		lm.setDisplay(true);
506
 
507
		TitleModel tm = new TitleModel();
508
		tm.setText("Brand Wise Sale Graph");
509
		tm.setDisplay(true);
510
 
511
		OptionsModel om = new OptionsModel();
512
		om.setLegend(lm);
513
		om.setTitle(tm);
514
 
515
		cm.setType("bar");
516
		cm.setData(dm);
517
		cm.setOptions(om);
518
 
519
		return cm;
520
 
521
	}
522
 
26011 amit.gupta 523
	private String adminPanel(int fofoId, String email, Model model) throws ProfitMandiBusinessException {
26022 amit.gupta 524
		List<Menu> menus = null;
26011 amit.gupta 525
		try {
526
			AuthUser authUser = authRepository.selectByEmailOrMobile(email);
527
			List<Position> positions = positionRepository.selectAll(authUser.getId());
26090 amit.gupta 528
			if (Arrays.asList("amit.gupta@shop2020.in", "tejbeer.kaur@shop2020.in").contains(email)) {
26029 amit.gupta 529
				menus = menuRepository.selectAll();
530
			} else if (positions.size() > 0) {
531
				if (positions.stream().filter(x -> x.getEscalationType().equals(EscalationType.L4)).count() > 0) {
26028 amit.gupta 532
					menus = menuRepository.selectAll();
533
				} else {
534
					List<Integer> menuIds = menuCategoryRepository.selectAllByPositions(positions).stream()
535
							.map(x -> x.getMenuId()).collect(Collectors.toList());
536
					LOGGER.info("Menu Ids are {}", menuIds);
537
					if (menuIds.size() > 0) {
538
						menus = menuRepository.selectAllByIds(menuIds);
539
					}
26022 amit.gupta 540
				}
26090 amit.gupta 541
				List<Position> salesPositions = positions.stream()
542
						.filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES)
543
						.collect(Collectors.toList());
544
				if (salesPositions.size() > 0) {
545
					Set<CustomRetailer> positionRetailers = new HashSet<>();
26100 amit.gupta 546
					csService.getPositionCustomRetailerMap(salesPositions).values().forEach(customRetailers -> {
26090 amit.gupta 547
						positionRetailers.addAll(customRetailers);
548
					});
549
					model.addAttribute("retailers", gson.toJson(positionRetailers));
550
					model.addAttribute("reporticoProjectMap", ReporticoProject.salesReporticoProjectMap);
26152 amit.gupta 551
					model.addAttribute("warehouses", getWarehouses(positionRetailers));
26090 amit.gupta 552
				}
26114 amit.gupta 553
				List<Position> warehousePositions = positions.stream()
554
						.filter(x -> x.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_WAREHOUSE)
555
						.collect(Collectors.toList());
556
				if (warehousePositions.size() > 0) {
557
					Set<CustomRetailer> positionRetailers = new HashSet<>();
26123 amit.gupta 558
					csService.getPositionCustomRetailerMap(warehousePositions).values().forEach(customRetailers -> {
26114 amit.gupta 559
						positionRetailers.addAll(customRetailers);
560
					});
561
					model.addAttribute("reporticoProjectMap", ReporticoProject.warehouseReporticoMap);
562
					model.addAttribute("retailers", gson.toJson(positionRetailers));
26123 amit.gupta 563
					model.addAttribute("warehouses", getWarehouses(positionRetailers));
26114 amit.gupta 564
				}
26142 amit.gupta 565
				model.addAttribute("authId", authUser.getId());
26028 amit.gupta 566
 
26022 amit.gupta 567
			}
26012 amit.gupta 568
		} catch (ProfitMandiBusinessException e) {
26011 amit.gupta 569
		}
26028 amit.gupta 570
		List<Menu> menuList = (menus != null) ? this.prepareMenu(menus) : new ArrayList<>();
26012 amit.gupta 571
 
26022 amit.gupta 572
		model.addAttribute("menu", menuList);
26012 amit.gupta 573
		return "admin";
574
	}
575
 
26114 amit.gupta 576
	private String getWarehouses(Set<CustomRetailer> positionRetailers) {
577
		Map<Integer, String> warehouses = new HashMap<>();
26222 tejbeer 578
		positionRetailers.stream().forEach(x -> {
579
			if (x.getWarehouseId() != 0) {
26171 amit.gupta 580
				warehouses.put(x.getWarehouseId(), ProfitMandiConstants.WAREHOUSE_MAP.get(x.getWarehouseId()));
581
			}
582
		});
26114 amit.gupta 583
		return gson.toJson(warehouses);
584
 
585
	}
586
 
26012 amit.gupta 587
	private List<Menu> prepareMenu(List<Menu> menus) {
588
		List<Menu> returnMenu = new ArrayList<>();
589
		Map<Menu, List<Menu>> subMenuMap = new HashMap<Menu, List<Menu>>();
590
		for (Menu menu : menus) {
591
			if (menu.get_parent() == null) {
26014 amit.gupta 592
				if (!subMenuMap.containsKey(menu)) {
26012 amit.gupta 593
					subMenuMap.put(menu, new ArrayList<>());
26011 amit.gupta 594
				}
595
			} else {
26012 amit.gupta 596
				Menu parentMenu = menu.get_parent();
597
				if (!subMenuMap.containsKey(parentMenu)) {
598
					subMenuMap.put(parentMenu, new ArrayList<>());
26011 amit.gupta 599
				}
26012 amit.gupta 600
				subMenuMap.get(parentMenu).add(menu);
26011 amit.gupta 601
			}
602
		}
26012 amit.gupta 603
		subMenuMap.entrySet().stream().forEach(entry -> {
604
			entry.getKey().setSubMenus(entry.getValue());
605
			returnMenu.add(entry.getKey());
606
		});
607
		return returnMenu;
26005 amit.gupta 608
	}
609
 
24288 amit.gupta 610
	// This method is currently hardcoded to faciliate watches sold as gift.
24203 amit.gupta 611
	private boolean hasGift(int fofoId) {
612
		try {
24288 amit.gupta 613
			return currentInventorySnapshotRepository.selectByItemIdAndFofoId(ProfitMandiConstants.GIFT_ID, fofoId)
614
					.getAvailability() > 0;
24203 amit.gupta 615
		} catch (ProfitMandiBusinessException e) {
616
			return false;
617
		}
618
	}
24288 amit.gupta 619
 
22354 ashik.ali 620
	@RequestMapping(value = "/contactUs", method = RequestMethod.GET)
23923 amit.gupta 621
	public String contactUs(HttpServletRequest request, Model model) throws Throwable {
22354 ashik.ali 622
		model.addAttribute("appContextPath", request.getContextPath());
623
		return "contact-us";
624
	}
23923 amit.gupta 625
 
25649 tejbeer 626
	@RequestMapping(value = "/notifications", method = RequestMethod.GET)
25683 tejbeer 627
	public String getNotificationsWithType(HttpServletRequest request,
628
			@RequestParam(required = false) MessageType messageType,
25649 tejbeer 629
			@RequestParam(name = "offset", defaultValue = "0") int offset,
630
			@RequestParam(name = "limit", defaultValue = "20") int limit, Model model) throws Exception {
631
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
26060 tejbeer 632
		int userId = 0;
633
		boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
634
		if (isAdmin) {
635
			userId = loginDetails.getFofoId();
636
		} else {
637
			userId = userAccountRepository.selectUserIdByRetailerId(loginDetails.getFofoId());
638
		}
25683 tejbeer 639
		List<Notification> notifications = null;
640
 
26086 tejbeer 641
		List<NotificationCampaign> notificationCampaigns = notificationCampaignRepository.getNotifications(messageType,
642
				userId, offset, limit);
643
		LOGGER.info("messageType" + messageType);
644
		notifications = getNotifications(notificationCampaigns, messageType);
645
 
25683 tejbeer 646
		model.addAttribute("notifications", notifications);
647
 
648
		LOGGER.info("notifications" + notifications);
649
		return "notification-template";
650
	}
651
 
652
	public List<Notification> getNotifications(List<NotificationCampaign> nc, MessageType messageType)
653
			throws ProfitMandiBusinessException {
654
		List<Notification> notifications = new ArrayList<>();
655
		Document document = null;
656
		if (messageType != null) {
657
			for (NotificationCampaign notificationCampaign : nc) {
658
				if (notificationCampaign.getMessageType() == messageType) {
25649 tejbeer 659
					Notification ns = new Notification();
660
					SimpleCampaignParams scp = gson.fromJson(notificationCampaign.getImplementationParams(),
661
							SimpleCampaignParams.class);
662
					Campaign campaign = new SimpleCampaign(scp);
663
					LocalDateTime expire = campaign.getExpireTimestamp();
664
					ns.setCid(Integer.toString(notificationCampaign.getId()));
665
					ns.setType(campaign.getType());
666
					ns.setMessage(campaign.getMessage());
667
					ns.setTitle(campaign.getTitle());
25651 tejbeer 668
					if (notificationCampaign.getDocumentId() != null) {
669
						document = documentRepository.selectById(notificationCampaign.getDocumentId());
670
						ns.setDocumentName(document.getDisplayName());
671
					}
25683 tejbeer 672
					ns.setUrl(campaign.getUrl());
25649 tejbeer 673
					ns.setShowImage(campaign.getShowImage());
674
					ns.setImageUrl(campaign.getImageUrl());
25683 tejbeer 675
					ns.setDocumentId(notificationCampaign.getDocumentId());
676
					ns.setMessageType(notificationCampaign.getMessageType());
25649 tejbeer 677
					ns.setCreated(
678
							notificationCampaign.getCreatedTimestamp().toEpochSecond(ZoneOffset.ofHoursMinutes(5, 30))
679
									* 1000);
680
					if (LocalDateTime.now().isAfter(expire)) {
681
						ns.setExpired(true);
682
					} else {
683
						ns.setExpired(false);
684
					}
685
					notifications.add(ns);
686
				}
687
			}
25683 tejbeer 688
		} else {
689
			for (NotificationCampaign notificationCampaign : nc) {
690
 
691
				Notification ns = new Notification();
692
				SimpleCampaignParams scp = gson.fromJson(notificationCampaign.getImplementationParams(),
693
						SimpleCampaignParams.class);
694
				Campaign campaign = new SimpleCampaign(scp);
695
				LocalDateTime expire = campaign.getExpireTimestamp();
696
				ns.setCid(Integer.toString(notificationCampaign.getId()));
697
				ns.setType(campaign.getType());
698
				ns.setMessage(campaign.getMessage());
699
				ns.setTitle(campaign.getTitle());
700
				if (notificationCampaign.getDocumentId() != null) {
701
					document = documentRepository.selectById(notificationCampaign.getDocumentId());
702
					ns.setDocumentName(document.getDisplayName());
703
				}
704
				ns.setUrl(campaign.getUrl());
705
				ns.setShowImage(campaign.getShowImage());
706
				ns.setImageUrl(campaign.getImageUrl());
707
				ns.setDocumentId(notificationCampaign.getDocumentId());
708
				ns.setMessageType(notificationCampaign.getMessageType());
709
				ns.setCreated(notificationCampaign.getCreatedTimestamp().toEpochSecond(ZoneOffset.ofHoursMinutes(5, 30))
710
						* 1000);
711
				if (LocalDateTime.now().isAfter(expire)) {
712
					ns.setExpired(true);
713
				} else {
714
					ns.setExpired(false);
715
				}
716
				notifications.add(ns);
717
			}
718
 
25649 tejbeer 719
		}
25683 tejbeer 720
		return notifications;
25651 tejbeer 721
 
722
	}
25649 tejbeer 723
 
25651 tejbeer 724
	@RequestMapping(value = "/notifyDocument/documentId", method = RequestMethod.GET)
725
	public ResponseEntity<?> retailerDocumentById(HttpServletRequest request,
726
			@RequestParam(name = ProfitMandiConstants.DOCUMENT_ID) int documentId, @RequestParam int cid)
727
			throws ProfitMandiBusinessException {
728
		Document document = documentRepository.selectById(documentId);
729
		NotificationCampaign nc = notificationCampaignRepository.selectById(cid);
730
		if (nc.getDocumentId() == null) {
731
			throw new ProfitMandiBusinessException("cid", nc.getId(), "not available");
732
		}
733
		if (nc.getDocumentId() != documentId) {
734
			throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, documentId, "RTLR_1014");
735
		}
736
		return responseSender.ok(document);
25649 tejbeer 737
	}
738
 
25651 tejbeer 739
	@RequestMapping(value = "/notifyDocument/download", method = RequestMethod.GET)
740
	public ResponseEntity<?> downloadRetailerDocument(HttpServletRequest request, @RequestParam int cid, Model model)
741
			throws ProfitMandiBusinessException {
742
 
743
		NotificationCampaign nc = notificationCampaignRepository.selectById(cid);
744
 
745
		if (nc.getDocumentId() == null) {
746
			throw new ProfitMandiBusinessException("cid", nc.getId(), "not available");
747
		}
748
 
749
		Document document = documentRepository.selectById(nc.getDocumentId());
750
 
751
		FileInputStream file = null;
752
		try {
753
			file = new FileInputStream(document.getPath() + File.separator + document.getName());
754
		} catch (FileNotFoundException e) {
755
			LOGGER.error("Retailer Document file not found : ", e);
756
			throw new ProfitMandiBusinessException(ProfitMandiConstants.DOCUMENT_ID, document.getId(), "RTLR_1013");
757
		}
758
		// ByteArrayOutputStream byteArrayOutputStream = new
759
		// ByteArrayOutputStream();
760
		// ExcelUtils.writeSchemeModels(schemeModels, byteArrayOutputStream);
761
 
762
		final HttpHeaders headers = new HttpHeaders();
763
		String contentType = "";
764
		if (document.getContentType() == ContentType.JPEG) {
765
			contentType = "image/jpeg";
766
		} else if (document.getContentType() == ContentType.PNG) {
767
			contentType = "image/png";
768
		} else if (document.getContentType() == ContentType.PDF) {
769
			contentType = "application/pdf";
770
		}
771
		headers.set("Content-Type", contentType);
772
		headers.set("Content-disposition", "inline; filename=" + document.getName());
773
		headers.setContentLength(document.getSize());
774
		final InputStreamResource inputStreamResource = new InputStreamResource(file);
775
		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
776
	}
777
 
21615 kshitij.so 778
}