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

 	@Autowired
 	private ScanRecordRepository scanRecordRepository;
 	@Autowired
 	private JavaMailSender mailSender;
 	private static final String ACCOUNT_ID = "aZ6flHhrgPIEl18buHdPBdueEN4";
 	private static final String SECRET_KEY = "a7rsX5B4UNNfTTx1-IJ19qdH48BT4YvBKlQJg3n3_KKNe7WWych55g";
 	public void populateGrnTimestamp() {
 		List<Purchase> allPurchases = purchaseRepository.selectAll();
 		for (Purchase p : allPurchases) {
 			String invoiceNumber = p.getPurchaseReference();
 			if (p.getCompleteTimestamp() == null) {
 		LOGGER.info("PENDING LEADES {}", leadRepository
 				.selectLeadsScheduledBetweenDate(LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(4)));
+	}
 	public void removeDuplicateOrders() throws Exception {
+		List<String> invoiceNumbers = Arrays.asList(/*
-		List<String> invoiceNumbers = Arrays.asList(/*"DLWE066/1108", "DLWE066/299", "DLWE066/348", "HRFB004/242",
+													 * "DLWE066/1108", "DLWE066/299", "DLWE066/348", "HRFB004/242",
-				"HRFB004/243", "HRFB004/514", "HRFTB155/29", "HRJND076/1146", "HRJND076/966", "HRKA134/295",
+													 * "HRFB004/243", "HRFB004/514", "HRFTB155/29", "HRJND076/1146",
+													 * "HRJND076/966", "HRKA134/295", "HRKA134/421", "HRKK091/381",
-				"HRKA134/421", "HRKK091/381", "HRMGH106/576", "HRSP056/139", "HRYN030/103", "UPGZ019/395",
+													 * "HRMGH106/576", "HRSP056/139", "HRYN030/103", "UPGZ019/395",
-				"UPHRD130/1299", "UPHRD130/456", "UPHRD130/634", "UPLKO063/897", "UPMRT149/54", "UPSJP119/748",
+													 * "UPHRD130/1299", "UPHRD130/456", "UPHRD130/634", "UPLKO063/897",
+													 * "UPMRT149/54", "UPSJP119/748", "UPSJP119/980", "UPSTP065/1218",
-				"UPSJP119/980", "UPSTP065/1218", "UPSTP065/2039", "UPSTP090/437", "UPSTP120/164", */
+													 * "UPSTP065/2039", "UPSTP090/437", "UPSTP120/164",
+													 */
 				"HRMGH106/1576");
 		int totalAmount = 0;
 		float saleAmount = 0;
 		float schemeReverseAmount = 0;
-		for(String invoiceNumber : invoiceNumbers) {
+		for (String invoiceNumber : invoiceNumbers) {
 			List<FofoOrder> orders = fofoOrderRepository.selectByInvoiceNumberLike(invoiceNumber);
 			orders = orders.stream().skip(1).collect(Collectors.toList());
 			for (FofoOrder fofoOrder : orders) {
 				LOGGER.info("Fofo Order Id - {}, Invoice {}", fofoOrder.getId(), invoiceNumber);
 				int inventoryItemId = 0;
 				saleAmount += fofoOrder.getTotalAmount();
 				fofoOrderRepository.delete(fofoOrder);
 				LOGGER.info("Fofo Order Id - {}, Invoice {}", fofoOrder.getId(), invoiceNumber);
 				List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
-				List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository.selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
+				List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
+						.selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
-				for(PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
+				for (PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
 					paymentOptionTransactionRepository.delete(paymentOptionTransaction);
+				}
-				for(FofoOrderItem foi : fofoOrderItems) {
+				for (FofoOrderItem foi : fofoOrderItems) {
 					List<FofoLineItem> flis = fofoLineItemRepository.selectByFofoOrderItemId(foi.getId());
 					fofoOrderItemRepository.delete(foi);
-					for(FofoLineItem fli : flis) {
+					for (FofoLineItem fli : flis) {
 						inventoryItemId = fli.getInventoryItemId();
 						fofoLineItemRepository.delete(fli);
+					}
+				}
-				//Rollback entry with reversal reason
+				// Rollback entry with reversal reason
-				if(fofoOrder.getCreateTimestamp().isAfter(LocalDate.of(2020, 4, 1).atStartOfDay())) {
+				if (fofoOrder.getCreateTimestamp().isAfter(LocalDate.of(2020, 4, 1).atStartOfDay())) {
 					float invoiceSchemeReversalAmount = 0;
+					List<UserWalletHistory> userWalletHistory = userWalletHistoryRepository
-					List<UserWalletHistory> userWalletHistory = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(fofoOrder.getId(), WalletReferenceType.SCHEME_OUT);
+							.selectAllByreferenceIdandreferenceType(fofoOrder.getId(), WalletReferenceType.SCHEME_OUT);
-					float invoiceWalletAmount =  userWalletHistory.stream().collect(Collectors.summingInt(y->y.getAmount()));
+					float invoiceWalletAmount = userWalletHistory.stream()
+							.collect(Collectors.summingInt(y -> y.getAmount()));
 					totalAmount += invoiceWalletAmount;
 					try {
-					walletService.rollbackAmountFromWallet(fofoOrder.getFofoId(), invoiceWalletAmount, fofoOrder.getId(), WalletReferenceType.SCHEME_OUT,
+						walletService.rollbackAmountFromWallet(fofoOrder.getFofoId(), invoiceWalletAmount,
+								fofoOrder.getId(), WalletReferenceType.SCHEME_OUT,
-							"Same order for Invoice-"+ invoiceNumber + "created twice, duplicate invoice rollback", fofoOrder.getCancelledTimestamp());
+								"Same order for Invoice-" + invoiceNumber + "created twice, duplicate invoice rollback",
+								fofoOrder.getCancelledTimestamp());
 					} catch (Exception e) {
 						LOGGER.info("Failed wallet update Reson [{}]", e.getMessage());
+					}
 					LOGGER.info("inventoryItemId - {}", inventoryItemId);
+					List<SchemeInOut> schemeInOuts = schemeInOutRepository
-					List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId)));
+							.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId)));
 					Set<Integer> schemeIds = new HashSet<>();
 					Set<Integer> schemeIdsRolledback = new HashSet<>();
-					for(SchemeInOut sio : schemeInOuts) {
+					for (SchemeInOut sio : schemeInOuts) {
-						if(Math.abs(sio.getCreateTimestamp().until(fofoOrder.getCreateTimestamp(), ChronoUnit.MINUTES)) <= 35 && sio.getRolledBackTimestamp() == null) {
+						if (Math.abs(sio.getCreateTimestamp().until(fofoOrder.getCreateTimestamp(),
+								ChronoUnit.MINUTES)) <= 35 && sio.getRolledBackTimestamp() == null) {
 							LOGGER.info(sio);
-							if(!schemeIds.contains(sio.getSchemeId())) {
+							if (!schemeIds.contains(sio.getSchemeId())) {
 								schemeIds.add(sio.getSchemeId());
 							} else if (!schemeIdsRolledback.contains(sio.getSchemeId())) {
 								schemeIdsRolledback.add(sio.getSchemeId());
 								sio.setRolledBackTimestamp(LocalDateTime.now());
 								schemeReverseAmount += sio.getAmount();
 								invoiceSchemeReversalAmount += sio.getAmount();
+							}
+						}
+					}
-					if(Math.abs(invoiceWalletAmount - invoiceSchemeReversalAmount) > 3) {
+					if (Math.abs(invoiceWalletAmount - invoiceSchemeReversalAmount) > 3) {
 						LOGGER.info("No Matchhhh");
+					}
- 					LOGGER.info("invoiceWalletAmount - {}, invoiceSchemeReversalAmount {}", invoiceWalletAmount, invoiceSchemeReversalAmount);
+					LOGGER.info("invoiceWalletAmount - {}, invoiceSchemeReversalAmount {}", invoiceWalletAmount,
+							invoiceSchemeReversalAmount);
 				}
+			}
+		}
+		LOGGER.info(
-		LOGGER.info("Total Sale Amount Reversal - {}, Total Wallet Amount Reversal {}, Total Scheme Reversal Amount - {}", saleAmount, totalAmount, schemeReverseAmount);
+				"Total Sale Amount Reversal - {}, Total Wallet Amount Reversal {}, Total Scheme Reversal Amount - {}",
+				saleAmount, totalAmount, schemeReverseAmount);
-		//throw new Exception();
+		// throw new Exception();
+	}
 	public void createGeofence() throws IOException, ProfitMandiBusinessException {
 		List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();
 		for (FofoStore fofoStore : fofoStores) {
 			if (fofoStore.getLatitude() != null && fofoStore.getLongitude() != null) {
 				CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoStore.getId());
 				OkHttpClient client = new OkHttpClient();
 				okhttp3.MediaType mediaType = okhttp3.MediaType.parse("application/json");
 				JSONObject geofe = new JSONObject();
 				JSONArray geofences = new JSONArray();
 				JSONObject geometry = new JSONObject();
 				JSONObject geo = new JSONObject();
 				JSONArray coordinates = new JSONArray();
+				ArrayList<String> crds = new ArrayList<>();
+				crds.add(fofoStore.getLongitude());
+				crds.add(fofoStore.getLatitude());
 				coordinates.put(fofoStore.getLongitude());
 				coordinates.put(fofoStore.getLatitude());
 				geo.put("type", "Point");
-				geo.put("coordinates", coordinates);
+				geo.put("coordinates", crds);
 				geometry.put("geometry", geo);
 				JSONObject metadata = new JSONObject();
 				metadata.put("name", customRetailer.getBusinessName());
 				metadata.put("city", customRetailer.getAddress().getCity());
 				geometry.put("metadata", metadata);
+			}
+		}
+	}
-	public void getAllGeofences()
-			throws IOException, ProfitMandiBusinessException {
+	public void getAllGeofences() throws IOException, ProfitMandiBusinessException {
 		OkHttpClient client = new OkHttpClient();
 		String authString = "Basic "
 				+ Base64.getEncoder().encodeToString(String.format("%s:%s", ACCOUNT_ID, SECRET_KEY).getBytes());
 		// Get geofences created for all app users
 		Request request1 = new Request.Builder().url("https://v3.api.hypertrack.com/geofences")
 				.addHeader("Authorization", authString).build();
 		Response response = client.newCall(request1).execute();
 		LOGGER.info("response" + response.body().string());
+	}
 	public void processSchemeOut(int fofoId, int orderId) throws Exception {
 		schemeService.processSchemeOut(orderId, fofoId);
+	}
+}
 //7015845171

Subversion Repositories SmartDukaan

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