Subversion Repositories SmartDukaan

package com.smartdukaan.cron.migrations;

package com.smartdukaan.cron.migrations;

import com.google.gson.Gson;

import com.google.gson.Gson;

import com.smartdukaan.cron.scheduled.SamsungIMEIActivationService;

import com.smartdukaan.cron.scheduled.SamsungIMEIActivationService;

import com.smartdukaan.cron.scheduled.ScheduledTasks;

import com.smartdukaan.cron.scheduled.ScheduledTasks;

import com.spice.profitmandi.common.enumuration.ItemType;

import com.spice.profitmandi.common.enumuration.ItemType;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.CustomRetailer;

import com.spice.profitmandi.common.model.CustomRetailer;

	@Autowired

	@Autowired

	private PaymentOptionTransactionRepository paymentOptionTransactionRepository;

	private PaymentOptionTransactionRepository paymentOptionTransactionRepository;

	@Autowired

	@Autowired

	@Autowired

	@Autowired

	private PrebookingOrderRepository prebookingOrderRepository;

	private PrebookingOrderRepository prebookingOrderRepository;

	@Autowired

	@Autowired

			endDate = LocalDate.now();

			endDate = LocalDate.now();

		} else {

		} else {

			startDate = LocalDate.now().minusMonths(ym);

			startDate = LocalDate.now().minusMonths(ym);

			endDate = startDate.plusMonths(1);

			endDate = startDate.plusMonths(1);

		}

		}

	}

	}

	public void migarateLineItemsToNewTable() throws Exception {

	public void migarateLineItemsToNewTable() throws Exception {

		LOGGER.info("Before Migrated LineItems Successfully");

		LOGGER.info("Before Migrated LineItems Successfully");

		int lineItemImeiId = 0;

		int lineItemImeiId = 0;

		changePartnerInvoices();

		changePartnerInvoices();

		ByteArrayOutputStream baos = FileUtil

		ByteArrayOutputStream baos = FileUtil

				.getCSVByteStream(Arrays.asList("Order id", "Challan", "Invoice", "Quantity"), rows);

				.getCSVByteStream(Arrays.asList("Order id", "Challan", "Invoice", "Quantity"), rows);

		Utils.sendMailWithAttachment(googleMailSender,

		Utils.sendMailWithAttachment(googleMailSender,

				"Challans Converted to Invoice", "PFA", "Challans-To-Invoice.csv",

				"Challans Converted to Invoice", "PFA", "Challans-To-Invoice.csv",

				new ByteArrayResource(baos.toByteArray()));

				new ByteArrayResource(baos.toByteArray()));

		throw new Exception();

		throw new Exception();

	}

	}

		driver.manage().deleteAllCookies();

		driver.manage().deleteAllCookies();

		// Specifiying pageLoadTimeout and Implicit wait

		// Specifiying pageLoadTimeout and Implicit wait

		driver.manage().timeouts().pageLoadTimeout(40, TimeUnit.SECONDS);

		driver.manage().timeouts().pageLoadTimeout(40, TimeUnit.SECONDS);

		driver.manage().timeouts().implicitlyWait(30, TimeUnit.SECONDS);

		driver.manage().timeouts().implicitlyWait(30, TimeUnit.SECONDS);

		Set<Integer> allPartners = new HashSet<>();

		Set<Integer> allPartners = new HashSet<>();

		Map<Integer, File> partnerSnapshotMap = new HashMap<>();

		Map<Integer, File> partnerSnapshotMap = new HashMap<>();

		authUserPartnerIdMapping.values().stream().forEach(x -> allPartners.addAll(x));

		authUserPartnerIdMapping.values().stream().forEach(x -> allPartners.addAll(x));

		for (int fofoId : allPartners) {

		for (int fofoId : allPartners) {

			driver.get("https://partners.smartdukaan.com/12dashboard34?fofoId=" + fofoId);

			driver.get("https://partners.smartdukaan.com/12dashboard34?fofoId=" + fofoId);

			File file = ((TakesScreenshot) driver).getScreenshotAs(OutputType.FILE);

			File file = ((TakesScreenshot) driver).getScreenshotAs(OutputType.FILE);

			partnerSnapshotMap.put(fofoId, file);

			partnerSnapshotMap.put(fofoId, file);

		}

		}

			String email = entry.getKey();

			String email = entry.getKey();

			LOGGER.info("Sending mail start to {}", email);

			LOGGER.info("Sending mail start to {}", email);

			StringBuffer body = new StringBuffer();

			StringBuffer body = new StringBuffer();

			Map<Integer, File> emailSnapshotMap = new HashMap<>();

			Map<Integer, File> emailSnapshotMap = new HashMap<>();

			for (int fofoId : partnerIds) {

			for (int fofoId : partnerIds) {

				body.append(String.format("<br/><img src=\"cid:%d\"/>", fofoId));

				body.append(String.format("<br/><img src=\"cid:%d\"/>", fofoId));

				emailSnapshotMap.put(fofoId, partnerSnapshotMap.get(fofoId));

				emailSnapshotMap.put(fofoId, partnerSnapshotMap.get(fofoId));

			}

			}

					String.format("Franchise Screenshots - %s", FormattingUtils.formatDate(LocalDateTime.now())),

					String.format("Franchise Screenshots - %s", FormattingUtils.formatDate(LocalDateTime.now())),

					body.toString(), emailSnapshotMap);

					body.toString(), emailSnapshotMap);

			LOGGER.info("Sent mail to {}", email);

			LOGGER.info("Sent mail to {}", email);

		}

		}

		driver.quit();

		driver.quit();

				LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(4)));

				LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(4)));

	}

	}

	public void removeDuplicateOrders() throws Exception {

	public void removeDuplicateOrders() throws Exception {

		List<String> invoiceNumbers = Arrays.asList(/*

		List<String> invoiceNumbers = Arrays.asList(/*

				"HRMGH106/1576");

				"HRMGH106/1576");

		int totalAmount = 0;

		int totalAmount = 0;

		float saleAmount = 0;

		float saleAmount = 0;

		float schemeReverseAmount = 0;

		float schemeReverseAmount = 0;

		 * for (int i = 0; i < ja.length(); i++) { JSONObject c = ja.getJSONObject(i);

		 * for (int i = 0; i < ja.length(); i++) { JSONObject c = ja.getJSONObject(i);

		 * String geofenceId = c.getString("geofence_id"); LOGGER.info("geofenceId" +

		 * String geofenceId = c.getString("geofence_id"); LOGGER.info("geofenceId" +

		 * geofenceId); FofoStoreGeofence fsg = new FofoStoreGeofence();

		 * geofenceId); FofoStoreGeofence fsg = new FofoStoreGeofence();

		 * fsg.setFofoId(customRetailer.getPartnerId()); fsg.setGeofenceId(geofenceId);

		 * fsg.setFofoId(customRetailer.getPartnerId()); fsg.setGeofenceId(geofenceId);

		 * fofoStoreGeofenceRepository.persist(fsg); }

		 * fofoStoreGeofenceRepository.persist(fsg); }

		 * }

		 * }

		 * }

		 * }

		 */

		 */

	}

	}

				.collect(Collectors.groupingBy(WarehouseScan::getInventoryItemId));

				.collect(Collectors.groupingBy(WarehouseScan::getInventoryItemId));

		for (Map.Entry<Integer, List<WarehouseScan>> mapEntry : inventoryScansMap.entrySet()) {

		for (Map.Entry<Integer, List<WarehouseScan>> mapEntry : inventoryScansMap.entrySet()) {

			int inventoryItemId = mapEntry.getKey();

			int inventoryItemId = mapEntry.getKey();

			List<WarehouseScan> duplicateScans = mapEntry.getValue().stream().filter(

			List<WarehouseScan> duplicateScans = mapEntry.getValue().stream().filter(

					.collect(Collectors.toList());

					.collect(Collectors.toList());

			WarehouseScan duplicateScan = duplicateScans.stream().skip(1).findFirst().get();

			WarehouseScan duplicateScan = duplicateScans.stream().skip(1).findFirst().get();

			warehouseScanRepository.delete(duplicateScan);

			warehouseScanRepository.delete(duplicateScan);

			warehouseInventoryService.addQuantity(duplicateScan.getInventoryItemId(), duplicateScan.getQuantity());

			warehouseInventoryService.addQuantity(duplicateScan.getInventoryItemId(), duplicateScan.getQuantity());

	@Autowired

	@Autowired

	com.spice.profitmandi.dao.repository.dtr.UserRepository dtrUserRepository;

	com.spice.profitmandi.dao.repository.dtr.UserRepository dtrUserRepository;

	public void mandiiUser(String firstName, String lastName, String pan, String dob, String aadhaar, String gender,

	public void mandiiUser(String firstName, String lastName, String pan, String dob, String aadhaar, String gender,

		FofoStore fs = fofoStoreRepository.selectByPan(pan);

		FofoStore fs = fofoStoreRepository.selectByPan(pan);

		CustomRetailer cr = retailerService.getFofoRetailer(fs.getId());

		CustomRetailer cr = retailerService.getFofoRetailer(fs.getId());

		com.spice.profitmandi.dao.entity.dtr.User dtrUser = dtrUserRepository.selectByEmailId(cr.getEmail());

		com.spice.profitmandi.dao.entity.dtr.User dtrUser = dtrUserRepository.selectByEmailId(cr.getEmail());

		MandiiUser mandiiUser = mandiiService.getUser(dtrUser.getFirstName(), dtrUser.getLastName(), father,

		MandiiUser mandiiUser = mandiiService.getUser(dtrUser.getFirstName(), dtrUser.getLastName(), father,

				Gender.valueOf(gender), cr.getEmail(), pan, cr.getMobileNumber(), LocalDate.parse(dob),

				Gender.valueOf(gender), cr.getEmail(), pan, cr.getMobileNumber(), LocalDate.parse(dob),

			mandiiUser.setAadharNumber(aadhaar);

			mandiiUser.setAadharNumber(aadhaar);

		}

		}

		mandiiUser.setGender(Gender.valueOf(gender));

		mandiiUser.setGender(Gender.valueOf(gender));

		mandiiService.createAccount(cr.getBusinessName(), mandiiUser);

		mandiiService.createAccount(cr.getBusinessName(), mandiiUser);

	}

	}

	@Autowired

	@Autowired

	CreditAccountRepository creditAccountRepository;

	CreditAccountRepository creditAccountRepository;

	public void mandiiUsers() throws Exception {

	public void mandiiUsers() throws Exception {

		List<FofoStore> fsList = fofoStoreRepository.selectByRetailerIds(fofoIds);

		List<FofoStore> fsList = fofoStoreRepository.selectByRetailerIds(fofoIds);

			this.mandiiUsers(store.getPan());

			this.mandiiUsers(store.getPan());

		}

		}

	}

	}

	public void mandiiUsers(String pan) throws Exception {

	public void mandiiUsers(String pan) throws Exception {

		FofoStore fs = fofoStoreRepository.selectByPan(pan);

		FofoStore fs = fofoStoreRepository.selectByPan(pan);

		byte[] bytes = new byte[(int) file.length()];

		byte[] bytes = new byte[(int) file.length()];

		fileInputStreamReader.read(bytes);

		fileInputStreamReader.read(bytes);

		return new String(Base64.getEncoder().encodeToString(bytes));

		return new String(Base64.getEncoder().encodeToString(bytes));

	}

	}

}

}

//7015845171

//7015845171