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

 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.CommonPaymentService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import com.spice.profitmandi.service.warehouse.WarehouseInventoryService;
 import com.spice.profitmandi.service.warehouse.WarehouseService;
+import com.spice.profitmandi.common.web.client.HttpClientFactory;
+import com.spice.profitmandi.common.web.client.RestClient;
 import in.shop2020.model.v1.order.OrderStatus;
 import in.shop2020.model.v1.order.WalletReferenceType;
+import org.apache.http.client.methods.CloseableHttpResponse;
-import okhttp3.OkHttpClient;
+import org.apache.http.client.methods.HttpDelete;
-import okhttp3.Request;
+import org.apache.http.impl.client.CloseableHttpClient;
-import okhttp3.Response;
+import org.apache.http.util.EntityUtils;
 import org.apache.commons.csv.CSVRecord;
 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;
 @Component
 @Transactional(rollbackFor = Throwable.class)
 public class RunOnceTasks {
     private static final Logger LOGGER = LogManager.getLogger(RunOnceTasks.class);
+    @Autowired
+    private RestClient restClient;
     @Autowired
     private LineItemRepository lineItemRepository;
     @Autowired
     private LeadRepository leadRepository;
         // List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();
         // for (FofoStore fofoStore : fofoStores) {
         // if (fofoStore.getLatitude() != null && fofoStore.getLongitude() != null) {
         CustomRetailer customRetailer = retailerService.getFofoRetailer(175138812);
-        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<Double> crds = new ArrayList<>();
-        // crds.add(Double.parseDouble(fofoStore.getLongitude()));
-        // crds.add(Double.parseDouble(fofoStore.getLatitude()));
         crds.add(79.739197);
         crds.add(27.961215);
-        // crds.add(77.08596155373755);
-        // crds.add(28.64944201113976);
-        // coordinates.put(fofoStore.getLongitude());
-        // coordinates.put(fofoStore.getLatitude());
         geo.put("type", "Point");
         geo.put("coordinates", crds);
         geometry.put("geometry", geo);
         JSONObject metadata = new JSONObject();
         metadata.put("name", customRetailer.getBusinessName());
         geometry.put("metadata", metadata);
         geometry.put("radius", 200);
         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)
+        String responseBody = restClient.postJson("https://v3.api.hypertrack.com/geofences",
-                .addHeader("Authorization", authString).build();
+                geofe.toString(), Collections.singletonMap("Authorization", authString));
-        Response response = client.newCall(request1).execute();
-        JSONArray ja = new JSONArray(response.body().string());
+        JSONArray ja = new JSONArray(responseBody);
         LOGGER.info("geofence" + ja);
         LOGGER.info("jalength" + ja.length());
         /*
          * for (int i = 0; i < ja.length(); i++) { JSONObject c = ja.getJSONObject(i);
          * String geofenceId = c.getString("geofence_id"); LOGGER.info("geofenceId" +
          * }
          */
+    }
-    public void getAllGeofences() throws IOException, ProfitMandiBusinessException {
+    public void getAllGeofences() throws Exception {
-        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")
+        String body = restClient.get("https://v3.api.hypertrack.com/geofences",
-                .addHeader("Authorization", authString).build();
+                null, Collections.singletonMap("Authorization", authString));
-        Response response = client.newCall(request1).execute();
-        LOGGER.info("response" + response.body().string());
+        LOGGER.info("response" + body);
+    }
     public void deleteGeofences(List<String> geofenceIds) throws IOException, ProfitMandiBusinessException {
-        OkHttpClient client = new OkHttpClient();
         String authString = "Basic "
                 + Base64.getEncoder().encodeToString(String.format("%s:%s", ACCOUNT_ID, SECRET_KEY).getBytes());
+        try (CloseableHttpClient client = HttpClientFactory.apacheHttp()) {
-        for (String geofenceId : geofenceIds) {
+            for (String geofenceId : geofenceIds) {
-            Request request1 = new Request.Builder().url("https://v3.api.hypertrack.com/geofences/" + geofenceId)
+                HttpDelete delete = new HttpDelete("https://v3.api.hypertrack.com/geofences/" + geofenceId);
-                    .delete().addHeader("Authorization", authString).build();
+                delete.setHeader("Authorization", authString);
-            LOGGER.info("geofenceId" + geofenceId);
+                LOGGER.info("geofenceId" + geofenceId);
-            Response response = client.newCall(request1).execute();
+                try (CloseableHttpResponse response = client.execute(delete)) {
+                    String body = response.getEntity() != null ? EntityUtils.toString(response.getEntity()) : "";
-            LOGGER.info("response" + response.body().string());
+                    LOGGER.info("response" + body);
+                }
+            }
+        }
+    }
     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 36402 → 36420