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

 import java.io.Serializable;
 import java.sql.Timestamp;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
-import java.time.ZoneOffset;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import com.google.gson.GsonBuilder;
 import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.enumuration.RechargeStatus;
 import com.spice.profitmandi.common.enumuration.ReporticoProject;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.model.CatalogIdAggregateValue;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.model.FocusedModelShortageModel;
 import com.spice.profitmandi.common.model.GstRate;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
 import com.spice.profitmandi.common.model.RechargeCredential;
+import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.services.ReporticoService;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.util.Utils.Attachment;
 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.dtr.PushNotifications;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProvider;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProviderCreditWalletHistory;
 import com.spice.profitmandi.dao.entity.dtr.RechargeTransaction;
 import com.spice.profitmandi.dao.entity.dtr.UserCampaign;
-import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
 import com.spice.profitmandi.dao.entity.fofo.CustomerAddress;
 import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 	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",  "prakash.rai@smartdukaan.com" };
+			"chaitnaya.vats@smartdukaan.com", "kuldeep.kumar@smartdukaan.com", "prakash.rai@smartdukaan.com" };
 	private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[] { "kamini.sharma@smartdukaan.com",
-			 "prakash.rai@smartdukaan.com", "tarun.verma@smartdukaan.com", "chaitnaya.vats@smartdukaan.com", "kuldeep.kumar@smartdukaan.com" };
+			"prakash.rai@smartdukaan.com", "tarun.verma@smartdukaan.com", "chaitnaya.vats@smartdukaan.com",
+			"kuldeep.kumar@smartdukaan.com" };
 	private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);
 	@Autowired
 	private ReporticoService reporticoService;
+	}
 	public void sendPartnerInvestmentDetails(List<String> sendTo) throws Exception {
 		if (sendTo == null) {
-			sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",  "prakash.rai@smartdukaan.com",
+			sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",
-					"amit.gupta@shop2020.in", "amod.sen@smartdukaan.com");
+					"prakash.rai@smartdukaan.com", "amit.gupta@shop2020.in", "amod.sen@smartdukaan.com");
+		}
 		LocalDate yesterDay = LocalDate.now().minusDays(1);
 		List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();
 		Map<Integer, CustomRetailer> customRetailerMap = retailerService
 				.getFofoRetailers(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
+			}
+		}
 		String fileName = "TargetVsSales-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
+		/*
-		/*for (Map.Entry<String, Set<String>> storeGuyEntry : csService.getAuthUserPartnerEmailMapping().entrySet()) {
+		 * for (Map.Entry<String, Set<String>> storeGuyEntry :
+		 * csService.getAuthUserPartnerEmailMapping().entrySet()) { List<List<? extends
-			List<List<? extends Serializable>> filteredRows = storeGuyEntry.getValue().stream()
+		 * Serializable>> filteredRows = storeGuyEntry.getValue().stream() .map(x ->
-					.map(x -> partnerRowMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
+		 * partnerRowMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
-			ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, filteredRows);
+		 * ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers,
-			String[] sendToArray = new String[] { storeGuyEntry.getKey() };
+		 * filteredRows); String[] sendToArray = new String[] { storeGuyEntry.getKey()
-			Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Target vs Sales Summary", "PFA",
+		 * }; Utils.sendMailWithAttachment(googleMailSender, sendToArray, null,
+		 * "Target vs Sales Summary", "PFA", fileName, new
-					fileName, new ByteArrayResource(baos.toByteArray()));
+		 * ByteArrayResource(baos.toByteArray())); }
-		}*/
+		 */
 		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
 		String[] sendToArray = sendTo.toArray(new String[sendTo.size()]);
 		Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Target vs Sales Summary", "PFA", fileName,
 				new ByteArrayResource(baos.toByteArray()));
 							partnerTargetDetail.getBrandName());
 					dailyTarget.put(fofoId, dailyAverageSale.get(fofoId));
 					break;
+				}
+			}
-			NotificationCampaigns notification = new NotificationCampaigns();
+			SendNotificationModel sendNotificationModel = new SendNotificationModel();
-			notification.setName("Daily Sales");
-			notification.setTitle("Daily Sale Update");
+			sendNotificationModel.setCampaignName("Sales update alert");
 			if (dailyAverageSale != null && dailyAverageSale.get(fofoId) != null) {
-				notification.setMessage(String.format("Rs.%.0f till %s. Today's Target is Rs.%.0f", sale,
+				sendNotificationModel.setMessage(String.format("Rs.%.0f till %s. Today's Target is Rs.%.0f", sale,
 						now.format(timeFormatter), dailyAverageSale.get(fofoId)));
 			} else {
-				notification.setMessage(String.format("Rs.%.0f till %s", sale, now.format(timeFormatter)));
+				sendNotificationModel.setMessage(String.format("Rs.%.0f till %s", sale, now.format(timeFormatter)));
+			}
-			// notification.setMessage("Your sale is "+salesbyfofoId.get(fofoId));
-			notification.setType("url");
+			sendNotificationModel.setType("url");
-			notification.setUrl("http://app.profitmandi.com/pages/home/notifications");
+			sendNotificationModel.setUrl("http://app.profitmandi.com/pages/home/notifications");
-			LOGGER.info("UserID" + userAccountRepository.selectUserIdByRetailerId(fofoId));
-			notification.setSql("SELECT distinct d1.user_id from devices d1 left join devices d2 on"
-					+ "(d1.imeinumber = d2.imeinumber and d1.created < d2.created) "
-					+ " where d2.id is null and d1.user_id = "
-					+ userAccountRepository.selectUserIdByRetailerId(fofoId));
-			LOGGER.info("SELECT distinct d1.user_id from devices d1 left join devices d2 on"
-					+ "(d1.imeinumber = d2.imeinumber and d1.created < d2.created) "
-					+ " where d2.id is null and d1.user_id = "
-					+ userAccountRepository.selectUserIdByRetailerId(fofoId));
-			notification.setExpiresat(LocalDateTime.now().plusDays(1).toEpochSecond(ZoneOffset.UTC) * 1000);
+			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
-			notification.setStatus("active");
-			notification.setSmsprocessed(0);
-			notification.setNotification_processed(0);
-			notification.setNotification_type("GENERAL_NOTIFICATION");
-			mongoClient.persistNotificationCmpInfo(notification);
+			sendNotificationModel.setMessageType(MessageType.notification);
 			salesByFofoIdMap.put(fofoId, sale);
 			LOGGER.info(sale);
+		}
 		String saleReport = this.getDailySalesReportByPartnerId(salesByFofoIdMap, dailyTarget);
 		LOGGER.info(saleReport);
-		String cc[] = { "Tarun.verma@smartdukaan.com", "Kamini.sharma@smartdukaan.com",  "prakash.rai@smartdukaan.com",
+		String cc[] =  {};/*{ "tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com", "prakash.rai@smartdukaan.com",
-				"chaitnaya.vats@smartdukaan.com", "adeel.yazdani@smartdukaan.com", "mohinder.mutreja@smartdukaan.com" };
+				"chaitnaya.vats@smartdukaan.com", "adeel.yazdani@smartdukaan.com", "mohinder.mutreja@smartdukaan.com" };*/
 		String subject = "sale report till" + " " + now.format(timeFormatter);
+		this.sendMailOfHtmlFomat("amit.gupta@shop2020.in", saleReport, cc, subject);
-		this.sendMailOfHtmlFomat("amod.sen@smartdukaan.com", saleReport, cc, subject);
+		//this.sendMailOfHtmlFomat("amod.sen@smartdukaan.com", saleReport, cc, subject);
+	}
 	public String getDailySalesReportByPartnerId(Map<Integer, Double> salesByFofoIdMap, Map<Integer, Float> dailyTarget)
 			throws ProfitMandiBusinessException {
 		StringBuilder sb = new StringBuilder();

Subversion Repositories SmartDukaan

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