Subversion Repositories SmartDukaan

Rev

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

Rev 25731 Rev 25732
Line 49... Line 49...
49 
import com.spice.profitmandi.common.util.Utils;
 49 
import com.spice.profitmandi.common.util.Utils;
50 
import com.spice.profitmandi.common.util.Utils.Attachment;
 50 
import com.spice.profitmandi.common.util.Utils.Attachment;
51 
import com.spice.profitmandi.dao.entity.catalog.FocusedModel;
 51 
import com.spice.profitmandi.dao.entity.catalog.FocusedModel;
52 
import com.spice.profitmandi.dao.entity.catalog.Item;
 52 
import com.spice.profitmandi.dao.entity.catalog.Item;
53 
import com.spice.profitmandi.dao.entity.catalog.TagListing;
 53 
import com.spice.profitmandi.dao.entity.catalog.TagListing;
54 
import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 - 
 
55 
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 54 
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
56 
import com.spice.profitmandi.dao.entity.fofo.MonthlyPlanned;
 55 
import com.spice.profitmandi.dao.entity.fofo.MonthlyPlanned;
57 
import com.spice.profitmandi.dao.entity.fofo.PlannedDetail;
 56 
import com.spice.profitmandi.dao.entity.fofo.PlannedDetail;
58 
import com.spice.profitmandi.dao.entity.transaction.Order;
 57 
import com.spice.profitmandi.dao.entity.transaction.Order;
59 
import com.spice.profitmandi.dao.entity.user.User;
 58 
import com.spice.profitmandi.dao.entity.user.User;
Line 61... Line 60...
61 
import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 60 
import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
62 
import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 61 
import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
63 
import com.spice.profitmandi.dao.repository.cs.CsService;
 62 
import com.spice.profitmandi.dao.repository.cs.CsService;
64 
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 63 
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
65 
import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 64 
import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
- 
 
 65 
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
66 
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 66 
import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
67 
import com.spice.profitmandi.dao.repository.fofo.MonthlyPlannedRepository;
 67 
import com.spice.profitmandi.dao.repository.fofo.MonthlyPlannedRepository;
68 
import com.spice.profitmandi.dao.repository.fofo.PlannedDetailRepository;
 68 
import com.spice.profitmandi.dao.repository.fofo.PlannedDetailRepository;
69 
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 69 
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
70 
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 70 
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
Line 162... Line 162...
162 
	@Autowired
 162 
	@Autowired
163 
	private MonthlyPlannedRepository monthlyPlannedRepository;
 163 
	private MonthlyPlannedRepository monthlyPlannedRepository;
164 
 
 164 
 
165 
	@Autowired
 165 
	@Autowired
166 
	private FofoOrderRepository fofoOrderRepository;
 166 
	private FofoOrderRepository fofoOrderRepository;
- 
 
 167 
 
- 
 
 168 
	@Autowired
- 
 
 169 
	private FofoOrderItemRepository fofoOrderItemRepository;
- 
 
 170 
 
167 
	@Autowired
 171 
	@Autowired
168 
	private PlannedDetailRepository plannedDetailRepository;
 172 
	private PlannedDetailRepository plannedDetailRepository;
- 
 
 173 
 
169 
	@Autowired
 174 
	@Autowired
170 
	RoleManager roleManager;
 175 
	RoleManager roleManager;
171 
 
 176 
 
172 
	@Autowired
 177 
	@Autowired
173 
	CsService csService;
 178 
	CsService csService;
Line 264... Line 269...
264 
			pm.setFofoId(loginDetails.getFofoId());
 269 
			pm.setFofoId(loginDetails.getFofoId());
265 
			plannedModel.add(pm);
 270 
			plannedModel.add(pm);
266 
			LOGGER.info("plannedModel" + plannedModel);
 271 
			LOGGER.info("plannedModel" + plannedModel);
267 
 
 272 
 
268 
		}
 273 
		}
269 
		// List<String> emails = csService.getAuthUserByPartnerId(fofoId);
 274 
		List<String> emails = csService.getAuthUserByPartnerId(fofoId);
270 
		// emails.add(customRetailer.getEmail());
 275 
		emails.add(customRetailer.getEmail());
271 
 
 276 
 
- 
 
 277 
		/*
272 
		List<String> emails = new ArrayList<>();
 278 
		 * List<String> emails = new ArrayList<>(); emails.add("tejbeer1710@gmail.com");
273 
		emails.add("tejbeer1710@gmail.com");
 279 
		 */
274 
		LOGGER.info("emails" + emails);
 280 
		LOGGER.info("emails" + emails);
275 
		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
 281 
		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
276 
				Arrays.asList("Partner Id", "Partner Name", "Model Name", "Qty"),
 282 
				Arrays.asList("Partner Id", "Partner Name", "Model Name", "Qty"),
277 
				plannedModel.stream()
 283 
				plannedModel.stream()
278 
						.map(x -> Arrays.asList(x.getFofoId(), x.getStoreName(), x.getItemDescription(), x.getQty()))
 284 
						.map(x -> Arrays.asList(x.getFofoId(), x.getStoreName(), x.getItemDescription(), x.getQty()))
Line 487... Line 493...
487 
				.collect(Collectors.toMap(FocusedModel::getCatalogId, Function.identity()));
 493 
				.collect(Collectors.toMap(FocusedModel::getCatalogId, Function.identity()));
488 
		LOGGER.info("fofoId" + loginDetails.getFofoId());
 494 
		LOGGER.info("fofoId" + loginDetails.getFofoId());
489 
		Map<Integer, Item> items = itemRepository
 495 
		Map<Integer, Item> items = itemRepository
490 
				.selectByIds(tagListings.stream().map(x -> x.getItemId()).collect(Collectors.toSet())).stream()
 496 
				.selectByIds(tagListings.stream().map(x -> x.getItemId()).collect(Collectors.toSet())).stream()
491 
				.collect(Collectors.toMap(x -> x.getId(), x -> x));
 497 
				.collect(Collectors.toMap(x -> x.getId(), x -> x));
492 
		Map<Integer, Integer> fofoOrderMap = null;
 - 
 
493 
		/*Map<Integer, Integer> fofoOrderMap = fofoOrderRepository
 - 
 
494 
				.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(), LocalDateTime.now().minusDays(15),
 - 
 
495 
						LocalDateTime.now())
 - 
 
496 
				.stream().collect(Collectors.groupingBy(y -> y.getOrderItem().getItemId(),
 - 
 
497 
						Collectors.summingInt(y -> y.getOrderItem().getQuantity())));*/
 - 
 
498 
 
 498 
 
- 
 
 499 
		List<Integer> fofoOrderIds = fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(loginDetails.getFofoId(),
- 
 
 500 
				LocalDateTime.now().minusDays(15), LocalDateTime.now()).stream().map(x -> x.getId())
- 
 
 501 
				.collect(Collectors.toList());
- 
 
 502 
 
- 
 
 503 
		Map<Integer, Integer> fofoOrderMap = fofoOrderItemRepository.selectByOrderIds(fofoOrderIds).stream()
- 
 
 504 
				.collect(Collectors.groupingBy(y -> y.getItemId(), Collectors.summingInt(y -> y.getQuantity())));
499 
		LOGGER.info("fofoOrderMap" + fofoOrderMap);
 505 
		LOGGER.info("fofoOrderMap" + fofoOrderMap);
500 
		Map<Integer, Integer> last15DaysMap = null;
 506 
		Map<Integer, Integer> last15DaysMap = null;
501 
		/*if (!fofoOrderMap.isEmpty()) {
 507 
		if (!fofoOrderMap.isEmpty()) {
502 
			last15DaysMap = itemRepository.selectByIds(fofoOrderMap.keySet()).stream().collect(Collectors
 508 
			last15DaysMap = itemRepository.selectByIds(fofoOrderMap.keySet()).stream().collect(Collectors
503 
					.groupingBy(x -> x.getCatalogItemId(), Collectors.summingInt(x -> fofoOrderMap.get(x.getId()))));
 509 
					.groupingBy(x -> x.getCatalogItemId(), Collectors.summingInt(x -> fofoOrderMap.get(x.getId()))));
504 
		}*/
 510 
		}
505 
 
 - 
 
- 
 
 511 
		LOGGER.info("last15DaysMap" + last15DaysMap);
506 
		MonthlyPlanned monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(loginDetails.getFofoId(),
 512 
		MonthlyPlanned monthlyPlanned = monthlyPlannedRepository.selectByFofoIdYearMonth(loginDetails.getFofoId(),
507 
				LocalDate.now().withDayOfMonth(1));
 513 
				LocalDate.now().withDayOfMonth(1));
508 
		Map<Integer, Integer> plannedDetailMap = null;
 514 
		Map<Integer, Integer> plannedDetailMap = null;
509 
		if (monthlyPlanned != null) {
 515 
		if (monthlyPlanned != null) {
510 
			plannedDetailMap = plannedDetailRepository.selectByPlannedId(monthlyPlanned.getId()).stream()
 516 
			plannedDetailMap = plannedDetailRepository.selectByPlannedId(monthlyPlanned.getId()).stream()
Line 615... Line 621...
615 
 
 621 
 
616 
		List<CatalogListingModel> catalogModelList = new ArrayList<>(catalogListingMap.values());
 622 
		List<CatalogListingModel> catalogModelList = new ArrayList<>(catalogListingMap.values());
617 
		List<CatalogListingModel> catalogModel = catalogModelList.stream()
 623 
		List<CatalogListingModel> catalogModel = catalogModelList.stream()
618 
				.filter(x -> !(x.getBrand().equals("Live Demo"))).collect(Collectors.toList());
 624 
				.filter(x -> !(x.getBrand().equals("Live Demo"))).collect(Collectors.toList());
619 
 
 625 
 
620 
		LOGGER.info("item" + catalogModelList);
 - 
 
621 
		Comparator<CatalogListingModel> firstCmp = Comparator.comparing(CatalogListingModel::getMinimumQty,
 626 
		Comparator<CatalogListingModel> firstCmp = Comparator.comparing(CatalogListingModel::getMinimumQty,
622 
				Comparator.reverseOrder());
 627 
				Comparator.reverseOrder());
623 
		LOGGER.info("monthlyPlanned" + monthlyPlanned);
 628 
		LOGGER.info("monthlyPlanned" + monthlyPlanned);
624 
		model.addAttribute("catalogTagListings", catalogModel.stream().sorted(firstCmp).collect(Collectors.toList()));
 629 
		model.addAttribute("catalogTagListings", catalogModel.stream().sorted(firstCmp).collect(Collectors.toList()));
625 
		model.addAttribute("isAdmin", roleManager.isAdmin(roleIds));
 630 
		model.addAttribute("isAdmin", roleManager.isAdmin(roleIds));