WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java

 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.util.Utils.Attachment;
 import com.spice.profitmandi.dao.Interface.Campaign;
 import com.spice.profitmandi.dao.convertor.LocalDateTimeJsonConverter;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
+import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.cs.Position;
 import com.spice.profitmandi.dao.entity.dtr.DailyRecharge;
 import com.spice.profitmandi.dao.entity.dtr.NotificationCampaign;
 import com.spice.profitmandi.dao.entity.dtr.NotificationCampaigns;
 import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
 import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
+import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
 import com.spice.profitmandi.dao.entity.transaction.UserWallet;
 import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
 import com.spice.profitmandi.dao.entity.user.Address;
 import com.spice.profitmandi.dao.entity.user.Device;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
+import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import com.spice.profitmandi.dao.model.SimpleCampaign;
 import com.spice.profitmandi.dao.model.SimpleCampaignParams;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.catalog.DeviceRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
+import com.spice.profitmandi.dao.repository.transaction.PriceDropIMEIRepository;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.service.PartnerInvestmentService;
 	@Autowired
 	private PurchaseRepository purchaseRepository;
 	@Autowired
+	private PriceDropIMEIRepository priceDropIMEIRepository;
+	@Autowired
+	PriceDropRepository priceDropRepository;
+	@Autowired
 	private SchemeService schemeService;
+	private static final String[] STOCK_AGEING_MAIL_LIST = new String[] { "amod.sen@smartdukaan.com",
+			"adeel.yazdani@smartdukaan.com", "manoj.singh@smartdukaan.com", "kamini.sharma@smartdukaan.com",
+			"mohinder.mutreja@smartdukaan.com", "	ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com",
+			"chaitnaya.vats@smartdukaan.com", "kuldeep.kumar@smartdukaan.com" };
+	private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[] { "kamini.sharma@smartdukaan.com",
+			"tarun.verma@smartdukaan.com", "chaitnaya.vats@smartdukaan.com", "kuldeep.kumar@smartdukaan.com" };
 	@Autowired
 	private ReporticoService reporticoService;
 	@Autowired
 	private PartnerInvestmentService partnerInvestmentService;
 	@Autowired
 	private JavaMailSender mailSender;
 	@Autowired
-	private PriceDropRepository priceDropRepository;
-	@Autowired
 	private PartnerTargetRepository partnerTargetRepository;
 	@Autowired
 	@Qualifier(value = "googleMailSender")
 	private JavaMailSender googleMailSender;
 		for (Map.Entry<String, Set<String>> storeGuyEntry : csService.getAuthUserPartnerEmailMapping().entrySet()) {
 			List<List<? extends Serializable>> filteredRows = storeGuyEntry.getValue().stream()
 					.map(x -> partnerRow.get(x)).filter(x -> x != null).collect(Collectors.toList());
 			ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, filteredRows);
-			String[] sendToArray = new String[] {storeGuyEntry.getKey()};
+			String[] sendToArray = new String[] { storeGuyEntry.getKey() };
-			Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Partner Investment Summary", "PFA",
+			Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA",
 					fileName, new ByteArrayResource(baos.toByteArray()));
+		}
 		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
 		String[] sendToArray = sendTo.toArray(new String[sendTo.size()]);
-		Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Partner Investment Summary", "PFA", fileName,
+		Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA",
-				new ByteArrayResource(baos.toByteArray()));
+				fileName, new ByteArrayResource(baos.toByteArray()));
+	}
 	private Map<String, SaleRoles> getPartnerEmailSalesMap() {
 		Map<String, SaleRoles> partnerEmailSalesMap = new HashMap<>();
 		Map<Integer, AuthUser> authUsersMap = authRepository.selectAllActiveUser().stream()
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
 		Map<Integer, List<CustomRetailer>> positionIdRetailerMap = csService.getPositionCustomRetailerMap(positions);
 		for (Position position : positions) {
 			List<CustomRetailer> crList = positionIdRetailerMap.get(position.getId());
-			if(crList==null) continue;
+			if (crList == null)
+				continue;
 			for (CustomRetailer cr : crList) {
 				if (!partnerEmailSalesMap.containsKey(cr.getEmail())) {
 					partnerEmailSalesMap.put(cr.getEmail(), new SaleRoles());
+				}
 				SaleRoles saleRoles = partnerEmailSalesMap.get(cr.getEmail());
 		Map<Integer, CustomRetailer> customRetailerMap = retailerService
 				.getFofoRetailers(new ArrayList<>(fofoStoresMap.keySet()));
 		Map<String, CustomRetailer> customRetailerEmailMap = customRetailerMap.values().stream()
 				.collect(Collectors.toMap(x -> x.getEmail(), x -> x));
 		Map<String, SaleRoles> partnerEmailSalesMap = this.getPartnerEmailSalesMap();
 		List<String> headers = Arrays.asList("Code", "Firm Name", "Store Name", "Current Category", "State Manager",
 				"Teritory Manager", "Team Leader", "Targeted Category", "Targeted Value", "Target Achieved",
 				"Achived Percentage", "Remaining Target", "Today's Target", "Today's achievement");
 			FofoStore fofoStore = fofoStoresMap.get(retailer.getPartnerId());
 			Serializable code = fofoStore.getCode();
 			Serializable storeName = "SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]", "");
 			Serializable businessName = retailer.getBusinessName();
 			try {
-				Serializable stateManager = StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL2(), ", ");
+				Serializable stateManager = StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL2(),
+						", ");
-				Serializable territoryManager = StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL1(), ", ");
+				Serializable territoryManager = StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL1(),
+						", ");
 				List<Serializable> row = new ArrayList<>(
 						Arrays.asList(code, businessName, storeName, stateManager, territoryManager));
 				if (partnerSalesTargetRowsMap.get(retailer.getEmail()) != null) {
 					row.addAll(partnerSalesTargetRowsMap.get(retailer.getEmail()));
 					partnerRowMap.put(retailer.getEmail(), row);
 				"ItemwiseOverallPendingIndent.xml");
 		Attachment attachment = new Attachment(
 				"ageing-report-" + FormattingUtils.formatDate(LocalDateTime.now().minusDays(1)) + ".csv", isr);
 		Attachment attachment1 = new Attachment(
 				"pending-indent-" + FormattingUtils.formatDate(LocalDateTime.now().minusDays(1)) + ".csv", isr1);
-		Utils.sendMailWithAttachments(googleMailSender, sendTo, null, "Stock Aeging Report", "PFA", attachment,
+		Utils.sendMailWithAttachments(googleMailSender, STOCK_AGEING_MAIL_LIST, null, "Stock Ageing Report", "PFA",
-				attachment1);
+				attachment);
+		Utils.sendMailWithAttachments(googleMailSender, ITEMWISE_PENDING_INDENT_MAIL_LIST, null,
+				"Itemwise Pending indent", "PFA", attachment1);
 		// Reports to be sent to mapped partners
 		Map<String, Set<String>> storeGuysMap = csService.getAuthUserPartnerEmailMapping();
-		Utils.sendMailWithAttachments(googleMailSender, storeGuysMap.keySet().toArray(new String[0]), null, "Stock Aeging Report", "PFA", attachment);
 		for (Map.Entry<String, Set<String>> storeGuyEntry : storeGuysMap.entrySet()) {
 			Map<String, String> params = new HashMap<>();
 			if (storeGuyEntry.getValue().size() == 0)
 				continue;
 			params.put("MANUAL_email", String.join(",", storeGuyEntry.getValue()));
 			InputStreamSource isr3 = reporticoService.getReportInputStreamSource(ReporticoProject.FOCO,
 					"focostockreport.xml", params);
 			Attachment attache = new Attachment(
-					"partner-stock-report" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv", isr3);
+					"Franchise-stock-report" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv", isr3);
 			System.out.println(storeGuyEntry.getValue());
-			Utils.sendMailWithAttachments(googleMailSender, storeGuyEntry.getValue().toArray(new String[0]), null,
+			Utils.sendMailWithAttachments(googleMailSender, new String[] { storeGuyEntry.getKey() }, null,
-					"Partner Stock Report", "PFA", attache);
+					"Franchise Stock Report", "PFA", attache);
+		}
+	}
 	public void sendAgeingReport() throws Exception {
 		sendAgeingReport("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com",
-				"chaitnaya.vats@smartdukaan.com", "amod.sen@smartdukaan.com");
+				"chaitnaya.vats@smartdukaan.com");
+	}
 	public void moveImeisToPriceDropImeis() throws Exception {
 		List<PriceDrop> priceDrops = priceDropRepository.selectAll();
 		for (PriceDrop priceDrop : priceDrops) {
+			}
+		}
+	}
 	public void grouping() throws Exception {
+		DateTimeFormatter dtf = DateTimeFormatter.ofPattern("MM-dd-yyyy hh:mm");
+		List<PriceDropIMEI> priceDropImeis = priceDropIMEIRepository.selectByStatus(PriceDropImeiStatus.APPROVED);
+		System.out.println(String.join("\t",
+				Arrays.asList("IMEI", "ItemId", "Brand", "Model Name", "Model Number", "Franchise Id", "Franchise Name",
+						"Grn On", "Price Dropped On", "Approved On", "Dropped Value", "Returned On", "Is Doa")));
+		Map<Integer, CustomRetailer> retailersMap = retailerService.getFofoRetailers();
+		for (PriceDropIMEI priceDropIMEI : priceDropImeis) {
+			HashSet<String> imeis = new HashSet<>();
+			PriceDrop priceDrop = priceDropRepository.selectById(priceDropIMEI.getPriceDropId());
+			imeis.add(priceDropIMEI.getImei());
+			List<InventoryItem> inventoryItems = inventoryItemRepository
+					.selectByFofoIdSerialNumbers(priceDropIMEI.getPartnerId(), imeis, false);
+			InventoryItem inventoryItem = inventoryItems.get(0);
+			CustomRetailer customRetailer = retailersMap.get(inventoryItem.getFofoId());
+			if (inventoryItem.getLastScanType().equals(ScanType.DOA_OUT)
+					|| inventoryItem.getLastScanType().equals(ScanType.PURCHASE_RET)) {
+				// check if pricedrop has been rolled out
+				List<UserWalletHistory> uwh = walletService.getAllByReference(inventoryItem.getFofoId(),
+						priceDropIMEI.getPriceDropId(), WalletReferenceType.PRICE_DROP);
+				if (uwh.size() > 0) {
+					Item item = itemRepository.selectById(inventoryItem.getId());
+					System.out.println(String.join("\t",
+							Arrays.asList(priceDropIMEI.getImei(), inventoryItem.getItemId() + "", item.getBrand(),
+									item.getModelName(), item.getModelNumber(), inventoryItem.getFofoId() + "",
+									customRetailer.getBusinessName(), inventoryItem.getCreateTimestamp().format(dtf),
+									priceDrop.getAffectedOn().format(dtf),
+									priceDropIMEI.getUpdateTimestamp().format(dtf),
+									inventoryItem.getUpdateTimestamp().format(dtf),
+									inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));
+				}
+			}
+		}
 		/*
 		 * for (FofoStore fofoStore : fofoStoreRepository.selectAll()) {
 		 * LOGGER.info("{}, {}", fofoStore.getId(),
 		 * partnerTypeChangeService.getTypeOnDate(fofoStore.getId(),
 		 * LocalDate.now().plusDays(1))); UserWallet userWallet =
 		 * if(userWallet==null) continue;
 		 * System.out.printf("Store Code %s, Wallet amount %d, Sum amount %f%n",
 		 * fofoStore.getCode(), userWallet.getAmount(),
 		 * walletService.getWalletAmount(fofoStore.getId())); }
 		 */
+		/*
+		 * for (Map.Entry<String, Set<String>> storeGuyEntry :
-		for (Map.Entry<String, Set<String>> storeGuyEntry : csService.getAuthUserPartnerEmailMapping().entrySet()) {
+		 * csService.getAuthUserPartnerEmailMapping().entrySet()) {
-			System.out.println(storeGuyEntry.getKey() + " = " + storeGuyEntry.getValue());
+		 * System.out.println(storeGuyEntry.getKey() + " = " +
+		 * storeGuyEntry.getValue()); }
-		}
+		 */
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 25605 → 25609