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

 package com.smartdukaan.cron.migrations;
 import java.io.File;
 import java.io.FileInputStream;
 import java.io.IOException;
-import java.io.InputStream;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.Month;
 import java.time.temporal.ChronoUnit;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
-import java.util.stream.IntStream;
 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.apache.poi.ss.usermodel.CellType;
-import org.apache.poi.ss.usermodel.Row.MissingCellPolicy;
-import org.apache.poi.xssf.usermodel.XSSFRow;
-import org.apache.poi.xssf.usermodel.XSSFSheet;
-import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 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.smartdukaan.cron.scheduled.SamsungIMEIActivationService;
 import com.smartdukaan.cron.scheduled.ScheduledTasks;
 import com.spice.profitmandi.common.enumuration.ItemType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.CustomRetailer;
-import com.spice.profitmandi.common.model.PartnerTargetModel;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.common.services.mandii.Gender;
+import com.spice.profitmandi.common.services.mandii.MandiiService;
+import com.spice.profitmandi.common.services.mandii.MandiiUser;
 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.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.catalog.TargetSlab;
 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.FofoLineItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.model.ContentPojo;
-import com.spice.profitmandi.dao.model.CreateOfferRequest;
 import com.spice.profitmandi.dao.model.MediaPojo;
 import com.spice.profitmandi.dao.repository.GenericRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.ManualPaymentRequestRepository;
 import com.spice.profitmandi.dao.repository.catalog.OfferRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.InventoryItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.InvoiceNumberGenerationSequenceRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerTargetRepository;
+import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
 import com.spice.profitmandi.dao.repository.fofo.PrebookingOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseReturnItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
 		List<WarehouseInventoryItem> lavaInventoryItems = warehouseInventoryItemRepository.getSerialNumbers("Lava",
 				LocalDate.of(2020, Month.SEPTEMBER, 1).atStartOfDay(), LocalDateTime.now());
 		LOGGER.info("Lava Inventory Size is {}", lavaInventoryItems.size());
+	}
-	public void createOffers(String fileName) throws Exception {
-		Map<CreateOfferRequest, List<PartnerTargetModel>> offerPartnerTargetMap = this.parseFromExcel(fileName);
-		for(Map.Entry<CreateOfferRequest, List<PartnerTargetModel>> partnerTargetEntry: offerPartnerTargetMap.entrySet()) {
-			CreateOfferRequest createOfferRequest = partnerTargetEntry.getKey();
-			Map<List<Integer>, List<Integer>> targetPartnerMap = partnerTargetEntry.getValue().stream().collect(Collectors.groupingBy(PartnerTargetModel::getTargets, Collectors.mapping(PartnerTargetModel::getFofoId, Collectors.toList())));
-					for (Map.Entry<List<Integer>, List<Integer>> targetPartnersEntry : targetPartnerMap.entrySet()) {
-						List<Integer> fofoIds = createOfferRequest.getPartnerCriteria().getFofoIds();
-						List<Integer> filterFofoIds = targetPartnersEntry.getValue().stream().filter(x->!fofoIds.contains(x)).collect(Collectors.toList());
-						List<Integer> targets = targetPartnersEntry.getKey();
-						createOfferRequest.getPartnerCriteria().setFofoIds(filterFofoIds);
-						int counter = 0;
-						for (com.spice.profitmandi.dao.model.TargetSlab targetSlab : createOfferRequest.getTargetSlabs()) {
-							targetSlab.setOnwardsAmount(targets.get(counter));
-							counter++;
-						}
-						offerService.addOfferService(createOfferRequest);
-						LOGGER.info(createOfferRequest.getPartnerCriteria().getFofoIds());
-						LOGGER.info(createOfferRequest.getTargetSlabs());
-					}
-		}
-	}
-	private Map<CreateOfferRequest, List<PartnerTargetModel>> parseFromExcel(String fileName) throws ProfitMandiBusinessException {
-		Map<CreateOfferRequest, List<PartnerTargetModel>> offerPartnerTargetMap =  new HashMap<>();
-		XSSFWorkbook myWorkBook = null;
-		try {
-			FileInputStream fileInputStream = new FileInputStream(fileName);
-			myWorkBook = new XSSFWorkbook(fileInputStream);
-			myWorkBook.setMissingCellPolicy(MissingCellPolicy.RETURN_BLANK_AS_NULL);
-			for(int i=0; i< myWorkBook.getNumberOfSheets();i++) {
-				XSSFSheet mySheet = myWorkBook.getSheetAt(i);
-				int offerId = Integer.parseInt(mySheet.getSheetName());
-				CreateOfferRequest existingOffer = offerService.getOffer(offerId);
-				List<PartnerTargetModel> partnerTargetModels = new ArrayList<>();
-				offerPartnerTargetMap.put(existingOffer, partnerTargetModels);
-				LOGGER.info("rowCellNum {}", mySheet.getLastRowNum());
-				for (int rowNumber = 1; rowNumber <= mySheet.getLastRowNum(); rowNumber++) {
-					XSSFRow row = mySheet.getRow(rowNumber);
-					LOGGER.info("row {}", row);
-					PartnerTargetModel partnerTargetModel = new PartnerTargetModel();
-					if (row.getCell(0) != null && row.getCell(0).getCellTypeEnum() == CellType.NUMERIC) {
-						partnerTargetModel.setFofoId((int) row.getCell(0).getNumericCellValue());
-					} else {
-						ProfitMandiBusinessException profitMandiBusinessException = new ProfitMandiBusinessException(
-								"FOFO ID", row.getCell(0).toString(), "TGLSTNG_VE_1010");
-						LOGGER.error("Excel file parse error : ", profitMandiBusinessException);
-						throw profitMandiBusinessException;
-					}
-					List<Integer> targets = new ArrayList<>();
-					for (int cellNumber = 1; cellNumber <= existingOffer.getTargetSlabs().size(); cellNumber++) {
-						if (row.getCell(cellNumber) != null
-								&& row.getCell(cellNumber).getCellTypeEnum() == CellType.NUMERIC) {
-							targets.add((int) row.getCell(cellNumber).getNumericCellValue());
-						} else {
-							ProfitMandiBusinessException profitMandiBusinessException = new ProfitMandiBusinessException(
-									"Target Column issue at " + rowNumber + ", " + cellNumber, row.getCell(cellNumber),
-									"Invalid target");
-							LOGGER.error("Excel file parse error : ", profitMandiBusinessException);
-							throw profitMandiBusinessException;
-						}
-					}
-					partnerTargetModel.setTargets(targets);
-					partnerTargetModels.add(partnerTargetModel);
-				}
-			}
-			myWorkBook.close();
-		} catch ( ProfitMandiBusinessException pbse) {
-			throw pbse;
-		} catch (IOException ioException) {
-			ioException.printStackTrace();
-			throw new ProfitMandiBusinessException(ProfitMandiConstants.EXCEL_FILE, ioException.getMessage(),
-					"EXL_VE_1000");
-		} finally {
-			if (myWorkBook != null) {
-				try {
-					myWorkBook.close();
-				} catch (IOException e) {
-					// TODO Auto-generated catch block
-					e.printStackTrace();
-				}
-			}
-		}
-		LOGGER.info("offerPartnerTargetMap {}", offerPartnerTargetMap);
-		return offerPartnerTargetMap;
-	}
 	@Autowired
 	private WarehouseScanRepository warehouseScanRepository;
 	@Autowired
 	private WarehouseInventoryService warehouseInventoryService;
 	@Autowired
 	PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
 	public void addInvestment() {
 		List<LocalDate> dates = Arrays.asList(
-				LocalDate.of(2021, 11, 26)
+				LocalDate.of(2021, 12, 19)
 				);
 		// List<Integer> fofoIds = Arrays.asList(175136207, 175138910, 175138967,
 		// 175138990, 175138999);
 		for (LocalDate date : dates) {
 			LOGGER.info("Date - {}", date);
 		if(fofoOrder.getCancelledTimestamp()!=null) {
 			orderService.reverseScheme(fofoOrder);
+		}
+	}
+	@Autowired
+	PartnerTypeChangeService partnerTypeChangeService;
+	public void runMe() {
+		System.out.println("runme ==== " +   fofoOrderItemRepository.selectSumMopGroupByRetailer(LocalDate.of(2021, 11, 1).atStartOfDay(), LocalDate.of(2021, 12, 1).atStartOfDay(), 175138408, false));
+		System.out.println("change " +
+	private Map<CreateOfferRequest, List<PartnerTargetModel>> parseFromExcel(String fileName) throws ProfitMandiBusinessException {
+		Map<CreateOfferRequest, List<PartnerTargetModel>> offerPartnerTargetMap =  new HashMap<>();
+		XSSFWorkbook myWorkBook = null;
+		try {
+			FileInputStream fileInputStream = new FileInputStream(fileName);
+			myWorkBook = new XSSFWorkbook(fileInputStream);
+			myWorkBook.setMissingCellPolicy(MissingCellPolicy.RETURN_BLANK_AS_NULL);
+			for(int i=0; i< myWorkBook.getNumberOfSheets();i++) {
+				XSSFSheet mySheet = myWorkBook.getSheetAt(i);
+				int offerId = Integer.parseInt(mySheet.getSheetName());
+				CreateOfferRequest existingOffer = offerService.getOffer(offerId);
+				List<PartnerTargetModel> partnerTargetModels = new ArrayList<>();
+				offerPartnerTargetMap.put(existingOffer, partnerTargetModels);
+				LOGGER.info("rowCellNum {}", mySheet.getLastRowNum());
+				for (int rowNumber = 1; rowNumber <= mySheet.getLastRowNum(); rowNumber++) {
+					XSSFRow row = mySheet.getRow(rowNumber);
+					LOGGER.info("row {}", row);
+					PartnerTargetModel partnerTargetModel = new PartnerTargetModel();
+					if (row.getCell(0) != null && row.getCell(0).getCellTypeEnum() == CellType.NUMERIC) {
+						partnerTargetModel.setFofoId((int) row.getCell(0).getNumericCellValue());
+					} else {
+						ProfitMandiBusinessException profitMandiBusinessException = new ProfitMandiBusinessException(
+								"FOFO ID", row.getCell(0).toString(), "TGLSTNG_VE_1010");
+						LOGGER.error("Excel file parse error : ", profitMandiBusinessException);
+						throw profitMandiBusinessException;
+					}
+					List<Integer> targets = new ArrayList<>();
+					for (int cellNumber = 1; cellNumber <= existingOffer.getTargetSlabs().size(); cellNumber++) {
+						if (row.getCell(cellNumber) != null
+								&& row.getCell(cellNumber).getCellTypeEnum() == CellType.NUMERIC) {
+							targets.add((int) row.getCell(cellNumber).getNumericCellValue());
+						} else {
+							ProfitMandiBusinessException profitMandiBusinessException = new ProfitMandiBusinessException(
+									"Target Column issue at " + rowNumber + ", " + cellNumber, row.getCell(cellNumber),
+									"Invalid target");
+							LOGGER.error("Excel file parse error : ", profitMandiBusinessException);
+							throw profitMandiBusinessException;
+						}
+					}
+					partnerTargetModel.setTargets(targets);
+					partnerTargetModels.add(partnerTargetModel);
+				}
+			}
+			myWorkBook.close();
+		} catch ( ProfitMandiBusinessException pbse) {
+			throw pbse;
+		} catch (IOException ioException) {
+			ioException.printStackTrace();
+			throw new ProfitMandiBusinessException(ProfitMandiConstants.EXCEL_FILE, ioException.getMessage(),
+					"EXL_VE_1000");
+		} finally {
+			if (myWorkBook != null) {
+				try {
+					myWorkBook.close();
+				} catch (IOException e) {
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+				}
+			}
+		}
+		LOGGER.info("offerPartnerTargetMap {}", offerPartnerTargetMap);
+		return offerPartnerTargetMap;
+	}
+  partnerTypeChangeService.getTypeOnDate(175138408, LocalDate.now()));
+	}
+	public void createOffers(FileInputStream stream) throws Exception {
+		offerService.createOffers(stream);
+	}
+	@Autowired
+	MandiiService mandiiService;
+	@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 {
+		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(),
+				LocalDate.parse(dob), cr.getAddress().getLine1() + " " + cr.getAddress().getLine2(),cr.getAddress().getCity(), cr.getAddress().getState(), cr.getAddress().getPinCode());
+		mandiiUser.setFatherName(father);
+		if(StringUtils.isNotEmpty(firstName)) {
+			mandiiUser.setFirstName(firstName);
+			mandiiUser.setLastName(lastName);
+		}
+		if(StringUtils.isNotEmpty(father)) {
+			mandiiUser.setFatherName(father);
+		}
+		if(StringUtils.isNotEmpty(aadhaar)) {
+			mandiiUser.setAadharNumber(aadhaar);
+		}
+		mandiiUser.setGender(Gender.valueOf(gender));
+		mandiiService.createAccount(cr.getBusinessName(), mandiiUser);
+	}
+}
 //7015845171

Subversion Repositories SmartDukaan

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