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

 import okhttp3.Response;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.commons.lang.StringUtils;
 import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpPost;
+import org.apache.http.conn.HttpHostConnectException;
 import org.apache.http.entity.StringEntity;
 import org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.http.impl.client.HttpClients;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import javax.mail.MessagingException;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
 import java.io.*;
 import java.math.BigDecimal;
+import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.sql.Timestamp;
 import java.text.DecimalFormat;
 import java.time.*;
 				// 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.getItemId());
-					System.out.println(String.join("\t", Arrays.asList(priceDropIMEI.getImei(),
+					System.out.println(String.join("\t",
+							Arrays.asList(priceDropIMEI.getImei(), inventoryItem.getItemId() + "", item.getBrand(),
-							inventoryItem.getItemId() + "", item.getBrand(), item.getModelName(), item.getModelNumber(),
+									item.getModelName(), item.getModelNumber(), inventoryItem.getFofoId() + "",
-							inventoryItem.getFofoId() + "", customRetailer.getBusinessName(),
+									customRetailer.getBusinessName(), inventoryItem.getCreateTimestamp().format(dtf),
-							inventoryItem.getCreateTimestamp().format(dtf), priceDrop.getAffectedOn().format(dtf),
+									priceDrop.getAffectedOn().format(dtf),
-							priceDropIMEI.getUpdateTimestamp().format(dtf),
+									priceDropIMEI.getUpdateTimestamp().format(dtf),
+									inventoryItem.getUpdateTimestamp().format(dtf),
-							inventoryItem.getUpdateTimestamp().format(dtf), priceDrop.getAutoPartnerPayout(inventoryItem.getUpdateTimestamp()) + "",
+									priceDrop.getAutoPartnerPayout(inventoryItem.getUpdateTimestamp()) + "",
-							inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));
+									inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));
+				}
+			}
+		}
+	}
+					}
 					SendNotificationModel sendNotificationModel = new SendNotificationModel();
 					sendNotificationModel.setCampaignName("Order Delivered");
 					sendNotificationModel.setTitle("Order Delivered");
-					sendNotificationModel.setMessage(String.format("Dear partner, your SmartDukaan ORDER " + aws
+					sendNotificationModel.setMessage(String.format("Dear partner, your SmartDukaan Order " + aws
 							+ "has been delivered to you in a safe sealed bag" + "."));
 					sendNotificationModel.setType("url");
 					sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
 					sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
 					sendNotificationModel.setMessageType(MessageType.notification);
 		uwh.setDescription("Amount adjusted against loan");
 		userWalletHistoryRepository.persist(uwh);
+	}
-	public void dailyLoanAlert() throws ProfitMandiBusinessException {
+	public void dailyLoanAlert()
+			throws ProfitMandiBusinessException, HttpHostConnectException, UnsupportedEncodingException {
 		List<Loan> loans = loanRepository.selectAllActiveLoan();
 		Map<Integer, Double> partnerLoanAmount = new HashMap<>();
 		if (!loans.isEmpty()) {
 			for (Entry<Integer, Double> partnerLoanAmountEnrty : partnerLoanAmount.entrySet()) {
 				int fofoId = partnerLoanAmountEnrty.getKey();
+				com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(fofoId);
+				Address address = addressRepository.selectById(user.getAddressId());
-				String title = "Alert! Credit o/s";
+				String title = "Alert Credit Outstanding!";
 				String url = "http://app.smartdukaan.com/pages/home/credit";
-				String message = "Your total pending Loan amount is Rs."
+				String message = "Your total pending Loan amount is Rs. "
 						+ FormattingUtils.formatDecimal(Math.abs(partnerLoanAmountEnrty.getValue()));
 				notificationService.sendNotification(fofoId, title, MessageType.notification, title, message, url);
+				// notificationService.sendWhatsappMessage(message, title,
+				// address.getPhoneNumber());
+			}
+		}
+	}
 			sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
 			CreditAccount creditAccount = creditAccountRepository
 					.selectByFofoIdAndGateway(sdCreditRequirement.getFofoId(), Gateway.SDDIRECT);
-			if (creditAccount == null) {
+			if (creditAccount != null) {
-				creditAccount = new CreditAccount();
-				creditAccount.setFofoId(sdCreditRequirement.getFofoId());
-				creditAccount.setGateway(Gateway.SDDIRECT);
-				creditAccount.setCreditStatus(CreditStatus.SANCTIONED);
-				creditAccount.setActive(false);
+				creditAccount.setInterestRate(sdCreditRequirement.getInterestRate().floatValue());
+				creditAccount.setSanctionedAmount(sdCreditRequirement.getLimit().floatValue());
+				creditAccount.setAvailableAmount(availableLimit.floatValue());
+				creditAccount.setFreeDays(sdCreditRequirement.getFreeDays());
 				creditAccount.setUpdatedOn(LocalDateTime.now());
-				creditAccountRepository.persist(creditAccount);
+			}
-			creditAccount.setInterestRate(sdCreditRequirement.getInterestRate().floatValue());
-			creditAccount.setSanctionedAmount(sdCreditRequirement.getLimit().floatValue());
-			creditAccount.setAvailableAmount(availableLimit.floatValue());
-			creditAccount.setFreeDays(sdCreditRequirement.getFreeDays());
-			creditAccount.setUpdatedOn(LocalDateTime.now());
+		}
+	}
 	public void notifyDefaultLoans() throws ProfitMandiBusinessException, MessagingException, IOException {
 			String title = "Loan amount overdue!";
 			String url = "http://app.smartdukaan.com/pages/home/credit";
 			String message = "Your loan due date ("
 					+ defaultLoan.getDueDate().toLocalDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy"))
 					+ ") has been exceeded. Additional penal interest of " + defaultLoan.getInterestRate()
-					+ "%  + Rs.100 shall be levied on daily basis. " + "Your total pending Loan amount is Rs."
+					+ "%  + and Rs.100 shall be levied on daily basis. " + "Your total pending Loan amount is Rs."
 					+ FormattingUtils.formatDecimal(Math.abs(amount)) + ". !!Pay Now!!";
 			notificationService.sendNotification(defaultLoan.getFofoId(), title, MessageType.notification, title,
 					message, url);
+		}
 				if (noOfdaysBetween <= 4 && noOfdaysBetween >= 0) {
 					List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());
 					double amount = loanStatements.stream().map(x -> x.getAmount())
 							.collect(Collectors.summingDouble(x -> x.doubleValue()));
-					String title = "Alert! Credit o/s";
+					String title = "Alert!";
 					String url = "http://app.smartdukaan.com/pages/home/credit";
 					String message = null;
 					if (noOfdaysBetween == 0) {
 						message = "Your total pending Loan amount is Rs."

Subversion Repositories SmartDukaan

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