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.IOException;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.temporal.ChronoUnit;
 import java.time.temporal.Temporal;
 import java.time.temporal.TemporalUnit;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Base64;
 import java.util.Collections;
 import java.util.Comparator;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
+import javax.servlet.http.HttpServletRequest;
 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.solr.common.util.Hash;
+import org.json.JSONArray;
+import org.json.JSONObject;
 import org.openqa.selenium.Dimension;
 import org.openqa.selenium.OutputType;
 import org.openqa.selenium.TakesScreenshot;
 import org.openqa.selenium.WebDriver;
 import org.openqa.selenium.chrome.ChromeDriver;
 import org.openqa.selenium.chrome.ChromeOptions;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.core.io.ByteArrayResource;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
 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.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.Scheme;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import in.shop2020.model.v1.order.OrderStatus;
 import in.shop2020.model.v1.order.WalletReferenceType;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
 @Component
 @Transactional(rollbackFor = Throwable.class)
 public class RunOnceTasks {
 	@Autowired
 	private CsService csService;
 	@Autowired
 	private Mongo mongoClient;
 	@Autowired
 	private PaymentOptionTransactionRepository paymentOptionTransactionRepository;
 	@Autowired
 	private SamsungIMEIActivationService samsungActivationService;
 	@Autowired
 	private SellerWarehouseRepository sellerWarehouseRepository;
 	@Autowired
 	private FofoOrderItemRepository fofoOrderItemRepository;
 	@Autowired
 	private FofoLineItemRepository fofoLineItemRepository;
 	@Autowired
 	private FofoOrderRepository fofoOrderRepository;
 	@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();
+		}
 		LOGGER.info("Total Sale Amount Reversal - {}, Total Wallet Amount Reversal {}, Total Scheme Reversal Amount - {}", saleAmount, totalAmount, schemeReverseAmount);
 		//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();
+				coordinates.put(fofoStore.getLongitude());
+				coordinates.put(fofoStore.getLatitude());
+				geo.put("type", "Point");
+				geo.put("coordinates", coordinates);
+				geometry.put("geometry", geo);
+				JSONObject metadata = new JSONObject();
+				metadata.put("name", customRetailer.getBusinessName());
+				metadata.put("city", customRetailer.getAddress().getCity());
+				geometry.put("metadata", metadata);
+				geometry.put("radius", 500);
+				geofences.put(geometry);
+				geofe.put("geofences", geofences);
+				okhttp3.RequestBody body = okhttp3.RequestBody.create(mediaType, geofe.toString());
+				String authString = "Basic "
+						+ Base64.getEncoder().encodeToString(String.format("%s:%s", ACCOUNT_ID, SECRET_KEY).getBytes());
+				Request request1 = new Request.Builder().url("https://v3.api.hypertrack.com/geofences").post(body)
+						.addHeader("Authorization", authString).build();
+				Response response = client.newCall(request1).execute();
+				LOGGER.info("response" + response.body().string());
+			}
+		}
+	}
+	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);
+	}
+}

Subversion Repositories SmartDukaan

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