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

 	@Autowired
 	private ItemRepository itemRepository;
 	@Autowired
 	private OrderRepository orderRepository;
 	@Autowired
 	private OrderService orderService;
 	@Autowired
 	private SchemeRepository schemeRepository;
+		}
 		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()));
 		List<String> headers = Arrays.asList("Code", "Firm Name", "Store Name", "State Manager", "Teritory Manager",
 				"Team Leader", "Wallet Amount", "In Stock Amount", "Return In Transit Stock", "Unbilled Amount",
 				"Grn Pending Amount", "Min Investment", "Investment Amount", "Investment Short", "Unbilled Qty");
 		List<List<? extends Serializable>> rows = new ArrayList<>();
 		Map<String, List<? extends Serializable>> partnerRow = new HashMap<>();
 			PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoStore.getId(),
 );
 			partnerDailyInvestment.setDate(yesterDay);
 			partnerDailyInvestmentRepository.persist(partnerDailyInvestment);
-			List<? extends Serializable> row = Arrays.asList(fofoStore.getCode(),
+			List<? extends Serializable> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(),
-					retailer.getBusinessName(), "SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]+", ""),
+					"SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]+", ""),
 					storeManagerMap.get(retailer.getEmail()).get(2), storeManagerMap.get(retailer.getEmail()).get(1),
 					storeManagerMap.get(retailer.getEmail()).get(0), partnerDailyInvestment.getWalletAmount(),
-					partnerDailyInvestment.getInStockAmount(), 0,
+					partnerDailyInvestment.getInStockAmount(), 0, partnerDailyInvestment.getUnbilledAmount(),
-					partnerDailyInvestment.getUnbilledAmount(), partnerDailyInvestment.getGrnPendingAmount(),
+					partnerDailyInvestment.getGrnPendingAmount(), partnerDailyInvestment.getMinInvestment(),
-					partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(),
+					partnerDailyInvestment.getTotalInvestment(), partnerDailyInvestment.getShortInvestment(),
-					partnerDailyInvestment.getShortInvestment(),
 					partnerDailyInvestment.getUnbilledQty());
 			partnerRow.put(retailer.getEmail(), row);
 			rows.add(row);
+		}
 		storeGuyMap.remove("");
 		String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 		for (Map.Entry<String, Set<String>> storeGuyEntry : storeGuyMap.entrySet()) {
 			List<List<? extends Serializable>> filteredRows = storeGuyEntry.getValue().stream()
-					.map(x -> partnerRow.get(x)).filter(x->x!=null).collect(Collectors.toList());
+					.map(x -> partnerRow.get(x)).filter(x -> x != null).collect(Collectors.toList());
 			ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, filteredRows);
 			String[] sendToArray = new String[] { nameEmail.get(storeGuyEntry.getKey()) };
 			Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Partner Investment Summary", "PFA",
 					fileName, new ByteArrayResource(baos.toByteArray()));
+		}
 				if (partnerSalesTargetRowsMap.get(retailer.getEmail()) != null) {
 					row.addAll(partnerSalesTargetRowsMap.get(retailer.getEmail()));
 					partnerRowMap.put(retailer.getEmail(), row);
 					rows.add(row);
+				}
-			} catch(Exception e) {
+			} catch (Exception e) {
 				LOGGER.warn("Could not find partner with email - {}", retailer.getEmail());
+			}
+		}
 		storeGuyMap.remove("");
 		String fileName = "TargetVsSales-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 		for (Map.Entry<String, Set<String>> storeGuyEntry : storeGuyMap.entrySet()) {
 			List<List<? extends Serializable>> filteredRows = storeGuyEntry.getValue().stream()
-					.map(x -> partnerRowMap.get(x)).filter(x->x!=null).collect(Collectors.toList());
+					.map(x -> partnerRowMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
 			ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, filteredRows);
 			String[] sendToArray = new String[] { nameEmail.get(storeGuyEntry.getKey()) };
 			Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Target vs Sales Summary", "PFA",
 					fileName, new ByteArrayResource(baos.toByteArray()));
+		}
 		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");
 		helper.setFrom(senderAddress);
 		mailSender.send(message);
+	}
-	public void sendNotification() throws IOException {
+	public void sendNotification() throws Exception {
 		List<PushNotifications> pushNotifications = pushNotificationRepository.selectAllByTimestamp();
 		if (!pushNotifications.isEmpty()) {
 			for (PushNotifications pushNotification : pushNotifications) {
-				Device devices = deviceRepository.selectById(pushNotification.getDeviceId());
+				Device device = deviceRepository.selectById(pushNotification.getDeviceId());
 				NotificationCampaign notificationCampaign = notificationCampaignRepository
 						.selectById(pushNotification.getNotificationCampaignid());
 				Gson gson = new GsonBuilder().setPrettyPrinting().serializeNulls()
 						.registerTypeAdapter(LocalDateTime.class, new LocalDateTimeJsonConverter()).create();
 				SimpleCampaignParams scp = gson.fromJson(notificationCampaign.getImplementationParams(),
 						SimpleCampaignParams.class);
 				Campaign campaign = new SimpleCampaign(scp);
-				String result_url = campaign.getUrl() + "&user_id=" + devices.getUser_id();
+				String result_url = campaign.getUrl() + "&user_id=" + device.getUser_id();
 				JSONObject json = new JSONObject();
-				json.put("to", devices.getFcmId());
+				json.put("to", device.getFcmId());
 				JSONObject jsonObj = new JSONObject();
 				jsonObj.put("message", campaign.getMessage());
 				jsonObj.put("title", campaign.getTitle());
 				jsonObj.put("type", campaign.getType());
 				jsonObj.put("url", result_url);
 				jsonObj.put("vibrate", 1);
 				jsonObj.put("pid", pushNotification.getId());
 				jsonObj.put("sound", 1);
 				jsonObj.put("priority", "high");
 				json.put("data", jsonObj);
+				try {
+					CloseableHttpClient client = HttpClients.createDefault();
+					HttpPost httpPost = new HttpPost(FCM_URL);
-				CloseableHttpClient client = HttpClients.createDefault();
-				HttpPost httpPost = new HttpPost(FCM_URL);
-				httpPost.setHeader("Content-Type", "application/json; utf-8");
+					httpPost.setHeader("Content-Type", "application/json; utf-8");
-				httpPost.setHeader("authorization", "key=" + FCM_API_KEY);
+					httpPost.setHeader("authorization", "key=" + FCM_API_KEY);
-				StringEntity entity = new StringEntity(json.toString());
+					StringEntity entity = new StringEntity(json.toString());
-				httpPost.setEntity(entity);
+					httpPost.setEntity(entity);
-				CloseableHttpResponse response = client.execute(httpPost);
+					CloseableHttpResponse response = client.execute(httpPost);
-				LOGGER.info("response" + response);
+					LOGGER.info("response" + response);
-				if (response.getStatusLine().getStatusCode() == 200) {
-					pushNotification.setSentTimestamp(LocalDateTime.now());
-				}
+					if (response.getStatusLine().getStatusCode() == 200) {
+						pushNotification.setSentTimestamp(LocalDateTime.now());
-				else {
+					} else {
+						LOGGER.info("message" + "not sent");
+					}
+				} catch (Exception e) {
+					e.printStackTrace();
 					LOGGER.info("message" + "not sent");
+				}
+			}
+		}
+	}
 	public static final Map<String, String> nameEmail = new HashMap<>();

Subversion Repositories SmartDukaan

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