WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java

 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.commons.lang.StringUtils;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
 import org.json.JSONArray;
 import org.json.JSONObject;
 import org.openqa.selenium.Dimension;
 import org.openqa.selenium.OutputType;
 import org.openqa.selenium.TakesScreenshot;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.Offer;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
+import com.spice.profitmandi.dao.entity.dtr.Document;
 import com.spice.profitmandi.dao.entity.dtr.PaymentOptionTransaction;
 import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
 import com.spice.profitmandi.dao.entity.fofo.DebitNote;
+import com.spice.profitmandi.dao.entity.fofo.FofoKyc;
 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;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
+import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 import com.spice.profitmandi.dao.entity.fofo.PrebookingOrder;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
 import com.spice.profitmandi.dao.entity.fofo.PurchaseReturnItem;
 import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 import com.spice.profitmandi.dao.repository.catalog.ManualPaymentRequestRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferRepository;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
+import com.spice.profitmandi.dao.repository.dtr.DocumentRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
+import com.spice.profitmandi.dao.repository.dtr.PartnerOnBoardingPanelRepository;
 import com.spice.profitmandi.dao.repository.dtr.PaymentOptionTransactionRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.fofo.DebitNoteRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoLineItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
 import com.spice.profitmandi.dao.repository.transaction.ReturnOrderRepository;
 import com.spice.profitmandi.dao.repository.transaction.SellerWarehouseRepository;
 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.dao.repository.user.FofoKycRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.dao.repository.warehouse.BrandRegionMappingRepository;
 import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
 import com.spice.profitmandi.dao.repository.warehouse.WarehouseScanRepository;
 import com.spice.profitmandi.service.inventory.InventoryService;
 					hdfcPayment.getTransferMode(), hdfcPayment.getUtr());
 			walletService.addAmountToWallet(retailerId, hdfcPayment.getId(), WalletReferenceType.AUTOMATED_ADVANCE,
 					description, (float) hdfcPayment.getAmount(), hdfcPayment.getCreditTimestamp());
+		}
+	}
-	//Bug in original migrate purchase
+	// Bug in original migrate purchase
 	public void migratePurchase() throws Exception {
 		List<Purchase> purchases = purchaseRepository.selectPurchaseAllPurchasesLessThanZero();
 		for (Purchase purchase : purchases) {
 			List<InventoryItem> inventoryItems = inventoryItemRepository.selectByPurchaseId(purchase.getId());
-			for(InventoryItem ii : inventoryItems) {
+			for (InventoryItem ii : inventoryItems) {
 				List<ScanRecord> scans = scanRecordRepository.selectByInventoryItemId(ii.getId());
-				if(scans.size()==1 && scans.get(0).getQuantity()==0) {
+				if (scans.size() == 1 && scans.get(0).getQuantity() == 0) {
 					scanRecordRepository.delete(scans.get(0));
-					purchase.setNonSerializedQuantity(purchase.getNonSerializedQuantity()-ii.getInitialQuantity());
+					purchase.setNonSerializedQuantity(purchase.getNonSerializedQuantity() - ii.getInitialQuantity());
 					inventoryItemRepository.delete(ii);
+				}
+			}
+		}
+	}
 	public void migratePurchaseFix() throws Exception {
 		List<Purchase> purchases = purchaseRepository.selectPurchaseAllPurchasesLessThanZero();
+		}
+	}
 	public void printPendingLeads() {
-		LOGGER.info("PENDING LEADES {}", leadRepository
+		LOGGER.info("PENDING LEADES {}", leadRepository.selectLeadsScheduledBetweenDate(null,
-				.selectLeadsScheduledBetweenDate(null, LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(4)));
+				LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(4)));
+	}
 	public void removeDuplicateOrders() throws Exception {
 		List<String> invoiceNumbers = Arrays.asList(/*
 													 * "DLWE066/1108", "DLWE066/299", "DLWE066/348", "HRFB004/242",
 	@Autowired
 	PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
 	public void addInvestment() {
-		List<LocalDate> dates = Arrays.asList(
+		List<LocalDate> dates = Arrays.asList(LocalDate.of(2021, 12, 19));
-				LocalDate.of(2021, 12, 19)
-				);
 		// List<Integer> fofoIds = Arrays.asList(175136207, 175138910, 175138967,
 		// 175138990, 175138999);
 		for (LocalDate date : dates) {
 			LOGGER.info("Date - {}", date);
 			Map<Integer, PartnerDailyInvestment> investmentMap = partnerDailyInvestmentRepository
+		}
+	}
 	public void reverseSchemes(String invoiceNumber) throws Exception {
 		FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
-		if(fofoOrder.getCancelledTimestamp()!=null) {
+		if (fofoOrder.getCancelledTimestamp() != null) {
 			orderService.reverseScheme(fofoOrder);
+		}
+	}
 	@Autowired
 	PartnerTypeChangeService partnerTypeChangeService;
 	public void runMe() {
+		System.out.println("runme ==== " + fofoOrderItemRepository.selectSumMopGroupByRetailer(
-		System.out.println("runme ==== " +   fofoOrderItemRepository.selectSumMopGroupByRetailer(LocalDate.of(2021, 11, 1).atStartOfDay(), LocalDate.of(2021, 12, 1).atStartOfDay(), 175138408, false));
+				LocalDate.of(2021, 11, 1).atStartOfDay(), LocalDate.of(2021, 12, 1).atStartOfDay(), 175138408, false));
-		System.out.println("change " +  partnerTypeChangeService.getTypeOnDate(175138408, LocalDate.now()));
+		System.out.println("change " + partnerTypeChangeService.getTypeOnDate(175138408, LocalDate.now()));
+	}
 	public void createOffers(FileInputStream stream) throws Exception {
 		offerService.createOffers(stream);
+	}
 	@Autowired
 	MandiiService mandiiService;
+	@Autowired
+	FofoKycRepository fofoKycRepository;
+	@Autowired
+	PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
+	@Autowired
+	DocumentRepository documentRepository;
 	@Autowired
 	com.spice.profitmandi.dao.repository.dtr.UserRepository dtrUserRepository;
-	public void mandiiUser(String firstName, String lastName, String pan, String dob, String aadhaar, String gender, String father) throws Exception {
+	public void mandiiUser(String firstName, String lastName, String pan, String dob, String aadhaar, String gender,
+			String father) throws Exception {
 		FofoStore fs = fofoStoreRepository.selectByPan(pan);
 		CustomRetailer cr = retailerService.getFofoRetailer(fs.getId());
 		com.spice.profitmandi.dao.entity.dtr.User dtrUser = dtrUserRepository.selectByEmailId(cr.getEmail());
-		MandiiUser mandiiUser = mandiiService.getUser(dtrUser.getFirstName(),dtrUser.getLastName(),cr.getEmail(),pan,cr.getMobileNumber(),
+		MandiiUser mandiiUser = mandiiService.getUser(dtrUser.getFirstName(), dtrUser.getLastName(), father,
+				Gender.valueOf(gender), cr.getEmail(), pan, cr.getMobileNumber(), LocalDate.parse(dob),
-				LocalDate.parse(dob), cr.getAddress().getLine1() + " " + cr.getAddress().getLine2(),cr.getAddress().getCity(), cr.getAddress().getState(), cr.getAddress().getPinCode());
+				cr.getAddress().getLine1() + " " + cr.getAddress().getLine2(), cr.getAddress().getCity(),
+				cr.getAddress().getState(), cr.getAddress().getPinCode());
 		mandiiUser.setFatherName(father);
-		if(StringUtils.isNotEmpty(firstName)) {
+		if (StringUtils.isNotEmpty(firstName)) {
 			mandiiUser.setFirstName(firstName);
 			mandiiUser.setLastName(lastName);
+		}
-		if(StringUtils.isNotEmpty(father)) {
+		if (StringUtils.isNotEmpty(father)) {
 			mandiiUser.setFatherName(father);
+		}
-		if(StringUtils.isNotEmpty(aadhaar)) {
+		if (StringUtils.isNotEmpty(aadhaar)) {
 			mandiiUser.setAadharNumber(aadhaar);
+		}
 		mandiiUser.setGender(Gender.valueOf(gender));
 		mandiiService.createAccount(cr.getBusinessName(), mandiiUser);
+	}
+	public void mandiiUsers(String pan) throws Exception {
+		FofoStore fs = fofoStoreRepository.selectByPan(pan);
+		PartnerOnBoardingPanel pob = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
+		List<FofoKyc> fofoKycs = fofoKycRepository.selectByPartnerOnBoardingId(pob.getId());
+		CustomRetailer cr = retailerService.getFofoRetailer(fs.getId());
+		com.spice.profitmandi.dao.entity.dtr.User dtrUser = dtrUserRepository.selectByEmailId(cr.getEmail());
+		for (FofoKyc fk : fofoKycs) {
+			MandiiUser mandiiUser = mandiiService.getUser(fk.getFirstName(), fk.getLastName(), fk.getFatherName(),
+					fk.getGender(), fk.getEmail(), pan, fk.getMobile(), fk.getDob(),
+					fk.getAddress1() + " " + fk.getAddress2() + " " + fk.getAddress3(), fk.getCity(), fk.getState(),
+					fk.getPincode());
+			LOGGER.info("mandiiUser" + mandiiUser);
+			Document panDoc = documentRepository.selectById(fk.getPanDoc());
+			File fPan = new File(panDoc.getPath() + panDoc.getName());
+			String encodeString = encodeFileToBase64Binary(fPan);
+			LOGGER.info("encodstring" + encodeString);
+			mandiiService.documentUpload(pan, fk.getMobile(), "PAN", encodeString, null);
+			Document adhaarF = documentRepository.selectById(fk.getPoaFront());
+			File adharf = new File(adhaarF.getPath() + adhaarF.getName());
+			String adhaarFEncodstring = encodeFileToBase64Binary(adharf);
+			mandiiService.documentUpload(pan, fk.getMobile(), "AADHAAR", adhaarFEncodstring, "FRONT");
+			Document adhaarB = documentRepository.selectById(fk.getPoaBack());
+			File adharb = new File(adhaarB.getPath() + adhaarF.getName());
+			String adhaarBEncodstring = encodeFileToBase64Binary(adharb);
+			mandiiService.documentUpload(pan, fk.getMobile(), "AADHAAR", adhaarBEncodstring, "BACK");
+			mandiiService.createAccount(cr.getBusinessName(), mandiiUser);
+		}
+	}
+	private static String encodeFileToBase64Binary(File file) throws Exception {
+		FileInputStream fileInputStreamReader = new FileInputStream(file);
+		byte[] bytes = new byte[(int) file.length()];
+		fileInputStreamReader.read(bytes);
+		return new String(Base64.getEncoder().encodeToString(bytes));
+	}
+}
 //7015845171

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java – Rev 29860 → 29863