Subversion Repositories SmartDukaan

Rev

Rev 9837 | Rev 9931 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 9837 Rev 9883
Line 11... Line 11...
11 
import java.io.InputStreamReader;
 11 
import java.io.InputStreamReader;
12 
import java.io.UnsupportedEncodingException;
 12 
import java.io.UnsupportedEncodingException;
13 
import java.text.SimpleDateFormat;
 13 
import java.text.SimpleDateFormat;
14 
import java.util.ArrayList;
 14 
import java.util.ArrayList;
15 
import java.util.Date;
 15 
import java.util.Date;
- 
 
 16 
import java.util.HashMap;
16 
import java.util.List;
 17 
import java.util.List;
- 
 
 18 
import java.util.Map;
17 
 
 19 
 
18 
import org.apache.http.HttpResponse;
 20 
import org.apache.http.HttpResponse;
19 
import org.apache.http.NameValuePair;
 21 
import org.apache.http.NameValuePair;
20 
import org.apache.http.client.ClientProtocolException;
 22 
import org.apache.http.client.ClientProtocolException;
21 
import org.apache.http.client.HttpClient;
 23 
import org.apache.http.client.HttpClient;
Line 38... Line 40...
38 
		logger = LoggerFactory.getLogger(SnapdealOrderStatusReconciliation.class);
 40 
		logger = LoggerFactory.getLogger(SnapdealOrderStatusReconciliation.class);
39 
		List<OrderStatus> statuses = new ArrayList<OrderStatus>();
 41 
		List<OrderStatus> statuses = new ArrayList<OrderStatus>();
40 
		statuses.add(OrderStatus.SHIPPED_FROM_WH);
 42 
		statuses.add(OrderStatus.SHIPPED_FROM_WH);
41 
		statuses.add(OrderStatus.SHIPPED_TO_LOGST);
 43 
		statuses.add(OrderStatus.SHIPPED_TO_LOGST);
42 
 
 44 
 
- 
 
 45 
		Map<String,List<List<String>>> orderDataMap = new HashMap<String,List<List<String>>>();
43 
		List<List<String>> deliveredOrderDataList = new ArrayList<List<String>>();
 46 
		List<List<String>> deliveredOrderDataList = new ArrayList<List<String>>();
- 
 
 47 
		List<List<String>> cancelledOrderDataList = new ArrayList<List<String>>();
44 
		long minCreationDate = 0l;
 48 
		long minCreationDate = 0l;
45 
		TransactionClient tsc = null;
 49 
		TransactionClient tsc = null;
46 
		try {
 50 
		try {
47 
			tsc = new TransactionClient();
 51 
			tsc = new TransactionClient();
48 
			minCreationDate = tsc.getClient().getMinCreatedTimeStampUndeliveredOrdersForSource(OrderSource.SNAPDEAL.getValue());
 52 
			minCreationDate = tsc.getClient().getMinCreatedTimeStampUndeliveredOrdersForSource(OrderSource.SNAPDEAL.getValue());
Line 221... Line 225...
221 
					logger.error("Unable to add delivered order details for updation regarding snapdeal oneship delivered orders", e);
 225 
					logger.error("Unable to add delivered order details for updation regarding snapdeal oneship delivered orders", e);
222 
				}
 226 
				}
223 
			}
 227 
			}
224 
		}
 228 
		}
225 
 
 229 
 
- 
 
 230 
		logger.info("Getting Information for Cancelled DropShip Snapdeal Orders");
- 
 
 231 
		String dropshipCancelUrl = "http://shipping.snapdeal.com/vendor/DROPSHIP/product-shipment/shippedData/fetch/?shippedStartDate="+startDate+"&shippedEndDate="+endDate+"&specialPanelAccess=&statusCode=CANCELLATION_COMPLETE&statusColumn=cancelledOn&dispatchCategoryId=0&sCode=CANCELLATION_COMPLETE";
- 
 
 232 
		logger.info("Drop Ship Cancel Url "+dropshipCancelUrl);
- 
 
 233 
 
- 
 
 234 
		get = new HttpGet(dropshipCancelUrl);
- 
 
 235
- 
 
 236 
		try {
- 
 
 237 
			response = client.execute(get);
- 
 
 238 
		} catch (Exception e) {
- 
 
 239 
			logger.error("Unable to get Http Response for snapdeal dropship cancelled orders", e);
- 
 
 240 
		}
- 
 
 241 
 
- 
 
 242 
		try {
- 
 
 243 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
- 
 
 244 
		} catch (Exception e) {
- 
 
 245 
			logger.error("Unable to read Http Response for snapdeal dropship cancelled orders", e);
- 
 
 246 
		}
- 
 
 247
- 
 
 248 
		try {
- 
 
 249 
			while ((line1 = rd.readLine()) != null) {
- 
 
 250 
				if(line1.contains("jsonString")){
- 
 
 251 
					String jsonString = line1.substring(line1.indexOf("["), line1.indexOf("'/>"));
- 
 
 252 
					logger.info("Response get from SnapDeal DropShip Cancelled Orders.. ");
- 
 
 253 
					jsonDataShip = new JSONArray(jsonString);
- 
 
 254 
					break;
- 
 
 255 
				}
- 
 
 256 
			}
- 
 
 257 
		} catch (Exception e) {
- 
 
 258 
			logger.error("Unable to extract Http Response for snapdeal dropship cancelled orders", e);
- 
 
 259 
		}
- 
 
 260 
 
- 
 
 261 
		if(jsonDataShip!=null && jsonDataShip.length()>0){
- 
 
 262 
			for(int i=0; i< jsonDataShip.length(); i++){
- 
 
 263 
				JSONObject jsonObj = null;
- 
 
 264 
				try {
- 
 
 265 
					jsonObj = jsonDataShip.getJSONObject(i);
- 
 
 266 
 
- 
 
 267 
					if(jsonObj!=null){
- 
 
 268 
						//System.out.println(jsonObj);
- 
 
 269 
						String subOrderCode =(String) jsonObj.get("suborderCode");
- 
 
 270 
						String referenceNumber =(String) jsonObj.get("referenceNumber");
- 
 
 271 
						//System.out.println("Snapdeal Dropship Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber);
- 
 
 272 
						logger.info("Snapdeal Dropship Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber);
- 
 
 273 
						List<String> cancelledOrdelList = new ArrayList<String>();
- 
 
 274 
						cancelledOrdelList.add(referenceNumber);
- 
 
 275 
						cancelledOrdelList.add(subOrderCode);
- 
 
 276 
						cancelledOrderDataList.add(cancelledOrdelList);
- 
 
 277 
					}
- 
 
 278 
				} catch (Exception e) {
- 
 
 279 
					logger.error("Unable to add cancelled order details for updation regarding snapdeal dropship orders", e);
- 
 
 280 
				}
- 
 
 281 
			}
- 
 
 282 
		}
- 
 
 283
- 
 
 284 
		logger.info("Getting Information for OneShip Snapdeal Cancelled Orders");
- 
 
 285 
		String oneShipCancelUrl = "http://shipping.snapdeal.com/vendor/ONESHIP/product-shipment/shippedData/fetch/?shippedStartDate="+startDate+"&shippedEndDate="+endDate+"&specialPanelAccess=&statusCode=CANCELLATION_COMPLETE&statusColumn=cancelledOn&dispatchCategoryId=0&sCode=CANCELLATION_COMPLETE";
- 
 
 286 
		logger.info("One Ship Cancel Url "+oneShipCancelUrl);
- 
 
 287
- 
 
 288 
		get = new HttpGet(oneShipCancelUrl);
- 
 
 289
- 
 
 290 
		try {
- 
 
 291 
			response = client.execute(get);
- 
 
 292 
		} catch (Exception e) {
- 
 
 293 
			logger.error("Unable to get Http Response for snapdeal oneship cancelled orders", e);
- 
 
 294 
		}
- 
 
 295 
 
- 
 
 296 
		try {
- 
 
 297 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
- 
 
 298 
		} catch (Exception e) {
- 
 
 299 
			logger.error("Unable to read Http Response for snapdeal oneship cancelled orders", e);
- 
 
 300 
		}
- 
 
 301
- 
 
 302 
		try {
- 
 
 303 
			while ((line1 = rd.readLine()) != null) {
- 
 
 304 
				if(line1.contains("jsonString")){
- 
 
 305 
					String jsonString = line1.substring(line1.indexOf("["), line1.indexOf("'/>"));
- 
 
 306 
					logger.info("Response get from SnapDeal OneShip Cancelled Orders.. ");
- 
 
 307 
					jsonDataShip = new JSONArray(jsonString);
- 
 
 308 
					break;
- 
 
 309 
				}
- 
 
 310 
			}
- 
 
 311 
		} catch (Exception e) {
- 
 
 312 
			logger.error("Unable to extract Http Response for snapdeal oneship cancelled orders", e);
- 
 
 313 
		}
- 
 
 314
- 
 
 315 
		if(jsonDataShip!=null && jsonDataShip.length()>0){
- 
 
 316 
			for(int i=0; i< jsonDataShip.length(); i++){
- 
 
 317 
				JSONObject jsonObj = null;
- 
 
 318 
				try {
- 
 
 319 
					jsonObj = jsonDataShip.getJSONObject(i);
- 
 
 320 
 
- 
 
 321 
					if(jsonObj!=null){
- 
 
 322 
						//System.out.println(jsonObj);
- 
 
 323 
						String subOrderCode =(String) jsonObj.get("suborderCode");
- 
 
 324 
						String referenceNumber =(String) jsonObj.get("referenceNumber");
- 
 
 325 
						//System.out.println("Snapdeal OneShip Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber);
- 
 
 326 
						logger.info("Snapdeal OneShip Order Details...suborderCode... "+subOrderCode+" ...referenceNumber... "+ referenceNumber);
- 
 
 327 
						List<String> cancelledOrdelList = new ArrayList<String>();
- 
 
 328 
						cancelledOrdelList.add(referenceNumber);
- 
 
 329 
						cancelledOrdelList.add(subOrderCode);
- 
 
 330 
						cancelledOrderDataList.add(cancelledOrdelList);
- 
 
 331 
					}
- 
 
 332 
				} catch (Exception e) {
- 
 
 333 
					logger.error("Unable to add cancelled order details for updation regarding snapdeal oneship orders", e);
- 
 
 334 
				}
- 
 
 335 
			}
- 
 
 336 
		}
- 
 
 337
226 
		if(deliveredOrderDataList!=null && deliveredOrderDataList.size()>0){
 338 
		if(deliveredOrderDataList!=null && deliveredOrderDataList.size()>0){
227 
			logger.info("Delivered Orders Size .. "+deliveredOrderDataList.size());
 339 
			logger.info("Delivered Orders Size .. "+deliveredOrderDataList.size());
- 
 
 340 
			orderDataMap.put("Delivered", deliveredOrderDataList);
- 
 
 341 
		}
- 
 
 342
- 
 
 343 
		if(cancelledOrderDataList!=null && cancelledOrderDataList.size()>0){
- 
 
 344 
			logger.info("Cancelled Orders Size .. "+cancelledOrderDataList.size());
- 
 
 345 
			orderDataMap.put("Cancelled", cancelledOrderDataList);
- 
 
 346 
		}
- 
 
 347
- 
 
 348 
		if(orderDataMap!=null && orderDataMap.size()>0){
228 
			try{
 349 
			try{
229 
				new TransactionClient().getClient().updateSnapdealOrdersStatus(deliveredOrderDataList);
 350 
				new TransactionClient().getClient().updateSnapdealOrdersStatus(orderDataMap);
230 
			} catch(Exception e){
 351 
			} catch(Exception e){
231 
				logger.error("Unable to update delivery information for snapdeal orders", e);
 352 
				logger.error("Unable to update delivery information for snapdeal orders", e);
232 
			}
 353 
			}
233 
		}
 354 
		}
234 
 
 355