Subversion Repositories SmartDukaan

Rev

Rev 8391 | Rev 8402 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
7930 manish.sha 1
package in.shop2020.serving.services;
2
 
3
import in.shop2020.config.ConfigException;
8368 manish.sha 4
import in.shop2020.model.v1.order.Order;
7930 manish.sha 5
import in.shop2020.serving.model.ShipmentUpdate;
6
import in.shop2020.thrift.clients.config.ConfigClient;
7
 
8
import java.text.SimpleDateFormat;
9
import java.util.ArrayList;
8368 manish.sha 10
import java.util.HashMap;
7930 manish.sha 11
import java.util.List;
8368 manish.sha 12
import java.util.Map;
8353 manish.sha 13
 
14
import org.apache.commons.logging.Log;
15
import org.apache.commons.logging.LogFactory;
16
 
7930 manish.sha 17
import com.TrackWebServiceClient;
18
import com.fedex.track.stub.ClientDetail;
19
import com.fedex.track.stub.TrackDetail;
20
import com.fedex.track.stub.TrackEvent;
21
import com.fedex.track.stub.TrackReply;
22
import com.fedex.track.stub.WebAuthenticationCredential;
23
import com.fedex.track.stub.WebAuthenticationDetail;
24
 
25
public class FedExTrackingService {
8353 manish.sha 26
 
27
	private static final Log log = LogFactory.getLog(FedExTrackingService.class);
8368 manish.sha 28
	private ClientDetail clientDetails;
29
	private WebAuthenticationDetail waDetails;
30
	private String endPointAddress;
7930 manish.sha 31
	/**
32
	 * @param args
33
	 */
34
 
8368 manish.sha 35
	public FedExTrackingService(){
36
		clientDetails = getFedExClientDetails();
37
		waDetails = getFedExWebAuthenticationDetails();
38
		endPointAddress = getFedExEndpointAddress();
39
	}
40
 
41
	public ClientDetail getFedExClientDetails(){
42
		ClientDetail clientDetail = new ClientDetail();
43
        String accountNumber ="";
44
        String meterNumber ="";
45
		try {
46
			accountNumber = ConfigClient.getClient().get("fedex_account_number");
47
			meterNumber = ConfigClient.getClient().get("fedex_meter_number");
48
		} catch (ConfigException e) {
49
			log.error("Could not fetch Client Detail", e);
8387 manish.sha 50
		}
51
		log.info("fedex_account_number in Tracking Service"+accountNumber);
52
		log.info("fedex_meter_number in Tracking Service"+meterNumber);
8368 manish.sha 53
        clientDetail.setAccountNumber(accountNumber);
54
        clientDetail.setMeterNumber(meterNumber);
55
		return clientDetail;
56
	}
57
 
58
	public WebAuthenticationDetail getFedExWebAuthenticationDetails(){
59
        WebAuthenticationCredential wac = new WebAuthenticationCredential();
60
        String key="";
61
        String password="";
62
		try {
63
			key = ConfigClient.getClient().get("fedex_authenication_key");
64
			password = ConfigClient.getClient().get("fedex_authenication_password");
65
		} catch (ConfigException e) {
66
			log.error("Could not fetch Web Authenication Detail", e);
67
		}
8387 manish.sha 68
		log.info("fedex_authenication_key in Tracking Service"+key);
69
		log.info("fedex_authenication_password in Tracking Service"+password);
8368 manish.sha 70
        wac.setKey(key);
71
        wac.setPassword(password);
72
		return new WebAuthenticationDetail(wac);
73
	}
74
 
75
	public String getFedExEndpointAddress(){
76
		String endPoint="";
77
		try {
78
			endPoint = ConfigClient.getClient().get("fedex_endpoint_address_track");
79
		} catch (ConfigException e) {
80
			log.error("Could not fetch enpoint Address", e);
81
		}
8387 manish.sha 82
		log.info("fedex_endpoint_address_track in Tracking Service"+endPoint);
8368 manish.sha 83
		return endPoint;
84
	}
85
 
86
	public Map<String,String> readFedExPickupOrdersMap(List<Order> ordersList){
8388 manish.sha 87
		log.info("Into Method to Read Fedex Pickup Orders.... "+ ordersList.size());
8368 manish.sha 88
		Map<String,String> fedexPickupOrdersMap= new HashMap<String,String>();
89
		for(Order ord: ordersList){
8394 manish.sha 90
			log.info("Order Exist");
8368 manish.sha 91
			String awbNumber= ord.getAirwaybill_no();
8394 manish.sha 92
			log.info("Airway Bill No... "+awbNumber);
93
 
8391 manish.sha 94
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
95
			log.info("Track Reply...");
96
			log.info(trackreply);
8368 manish.sha 97
			if(trackreply!=null){
8385 manish.sha 98
				log.info("Successfully get Fedex Pickup Orders Reply");
8368 manish.sha 99
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
100
				SimpleDateFormat dateformat = new SimpleDateFormat("dd-MMM-yyyy");
101
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
102
				for (int i=0; i< trackDetails.length; i++) {
103
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 104
					for(TrackEvent te : trackEvents){
105
						if("PU".equalsIgnoreCase(te.getEventType())){
106
							fedexPickupOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime()));
107
						}	
108
					}
8368 manish.sha 109
				}
110
			}
111
		}
8385 manish.sha 112
		log.info("Read Fedex Pickup Orders");
8368 manish.sha 113
		return fedexPickupOrdersMap;
114
	}
115
 
116
	public Map<String,String> readFedExReachedDestinationOrdersMap(List<Order> ordersList){
8388 manish.sha 117
		log.info("Into Method to Read Fedex Reached Destination Orders.... "+ ordersList.size());
8368 manish.sha 118
		Map<String,String> fedexReachedDestinationOrdersMap= new HashMap<String,String>();
119
		for(Order ord: ordersList){
120
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 121
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 122
			if(trackreply!=null){
8385 manish.sha 123
				log.info("Successfully get Fedex Reached Destination Orders");
8368 manish.sha 124
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
125
				SimpleDateFormat dateformat = new SimpleDateFormat("dd-MMM-yyyy");
126
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
127
				for (int i=0; i< trackDetails.length; i++) {
128
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 129
					for(TrackEvent te : trackEvents){
130
						if("AR".equalsIgnoreCase(te.getEventType())){
8368 manish.sha 131
						fedexReachedDestinationOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime()));
8377 manish.sha 132
						}	
133
					}
8368 manish.sha 134
				}
135
			}
136
		}
8385 manish.sha 137
		log.info("Read Fedex Reached Destination Orders");
8368 manish.sha 138
		return fedexReachedDestinationOrdersMap;
139
	}
140
 
141
	public Map<String,String> readFedExDeliveredOrdersMap(List<Order> ordersList){
8388 manish.sha 142
		log.info("Into Method to Read Fedex Delivered Orders.... "+ ordersList.size());
8368 manish.sha 143
		Map<String,String> fedexDeliveredOrdersMap= new HashMap<String,String>();
144
		for(Order ord: ordersList){
145
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 146
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 147
			if(trackreply!=null){
8385 manish.sha 148
				log.info("Successfully get Fedex Delivered Orders");
8368 manish.sha 149
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
8380 manish.sha 150
				SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd");
8368 manish.sha 151
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
152
				for (int i=0; i< trackDetails.length; i++) {
153
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 154
					for(TrackEvent te : trackEvents){
155
						if("DL".equalsIgnoreCase(te.getEventType())){
8380 manish.sha 156
							fedexDeliveredOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime())+"|"+trackDetails[i].getDeliverySignatureName());
8377 manish.sha 157
						}	
158
					}
8368 manish.sha 159
				}
160
			}
161
		}
8385 manish.sha 162
		log.info("Read Fedex Delivered Orders");
8368 manish.sha 163
		return fedexDeliveredOrdersMap;
164
	}
165
 
166
	public Map<String,String> readFedExReturnedOrdersMap(List<Order> ordersList){
8388 manish.sha 167
		log.info("Into Method to Read Fedex Returned Orders.... "+ ordersList.size());
8368 manish.sha 168
		Map<String,String> fedexReturnedOrdersMap= new HashMap<String,String>();
169
		for(Order ord: ordersList){
170
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 171
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 172
			if(trackreply!=null){
8385 manish.sha 173
				log.info("Successfully get Fedex Returned Orders");
8368 manish.sha 174
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
175
				SimpleDateFormat dateformat = new SimpleDateFormat("dd-MMM-yyyy");
176
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
177
				for (int i=0; i< trackDetails.length; i++) {
178
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 179
					for(TrackEvent te : trackEvents){
180
						if("RS".equalsIgnoreCase(te.getEventType())){
8380 manish.sha 181
							fedexReturnedOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime())+"|"+te.getEventDescription());
8377 manish.sha 182
						}
183
					}
8368 manish.sha 184
				}
185
			}
186
		}
8385 manish.sha 187
		log.info("Read Fedex Returned Orders");
8368 manish.sha 188
		return fedexReturnedOrdersMap;
189
	}
190
 
191
	public Map<String,String> readFedExUnDeliveredOrdersMap(List<Order> ordersList){
8388 manish.sha 192
		log.info("Into Method to Read Fedex Undelivered Orders.... "+ ordersList.size());
8368 manish.sha 193
		Map<String,String> fedexUnDeliveredOrdersMap= new HashMap<String,String>();
194
		for(Order ord: ordersList){
195
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 196
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 197
			if(trackreply!=null){
8385 manish.sha 198
				log.info("Successfully Get Fedex Undelivered Orders");
8368 manish.sha 199
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
200
				for (int i=0; i< trackDetails.length; i++) {
201
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 202
					for(TrackEvent te : trackEvents){
203
						if("DE".equalsIgnoreCase(te.getEventType())){
8380 manish.sha 204
							fedexUnDeliveredOrdersMap.put(awbNumber, te.getEventDescription());
8377 manish.sha 205
						}
206
					}
8368 manish.sha 207
				}
208
			}
209
		}
8385 manish.sha 210
		log.info("Read Fedex Undelivered Orders");
8368 manish.sha 211
		return fedexUnDeliveredOrdersMap;
212
	}
213
 
214
	public Map<String,String> readFedExFirstDeliveryAttemptedOrdersMap(List<Order> ordersList){
8388 manish.sha 215
		log.info("Into Method to Read Fedex First Delivery Attempted Orders.... "+ ordersList.size());
8368 manish.sha 216
		Map<String,String> fedexFirstDeliveryAttemptedOrdersMap= new HashMap<String,String>();
217
		for(Order ord: ordersList){
218
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 219
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 220
			if(trackreply!=null){
8385 manish.sha 221
				log.info("Successfully get Fedex First Delivery Attempted Orders");
8368 manish.sha 222
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
223
				SimpleDateFormat dateformat = new SimpleDateFormat("dd-MMM-yyyy");
224
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
225
				for (int i=0; i< trackDetails.length; i++) {
226
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 227
					for(TrackEvent te : trackEvents){
228
						if("OD".equalsIgnoreCase(te.getEventType())){
8380 manish.sha 229
							if(te.getStatusExceptionCode()!=null){
230
								fedexFirstDeliveryAttemptedOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime())+"|"+te.getStatusExceptionDescription());
231
							}
232
							else{
233
								fedexFirstDeliveryAttemptedOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime())+"|"+te.getEventDescription());
234
							}
8377 manish.sha 235
						}
236
					}
8368 manish.sha 237
				}
238
			}
239
		}
8385 manish.sha 240
		log.info("Read Fedex First Delivery Attempted Orders");
8368 manish.sha 241
		return fedexFirstDeliveryAttemptedOrdersMap;
242
	}
243
 
7930 manish.sha 244
	public List<ShipmentUpdate> getUpdates(String awbNumber){
245
		List<ShipmentUpdate> updates = new ArrayList<ShipmentUpdate>();
8391 manish.sha 246
		TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
7930 manish.sha 247
		if(trackreply!=null){
248
			TrackDetail[] trackDetails=trackreply.getTrackDetails();
249
			SimpleDateFormat dateformat = new SimpleDateFormat("dd-MMM-yyyy");
250
			SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
251
			for (int i=0; i< trackDetails.length; i++) {
252
				TrackEvent trackEvents[]= trackDetails[i].getEvents();
253
				for(TrackEvent te : trackEvents){
254
					ShipmentUpdate shipUpdate = new ShipmentUpdate();
8353 manish.sha 255
					if(te.getAddress()!=null){
256
						if(te.getAddress().getCity()!=null){
257
							shipUpdate.city= te.getAddress().getCity();
258
						}
259
						else{
260
							shipUpdate.city="Unknown";
261
						}
262
					}
263
					else{
264
						shipUpdate.city="Unknown";
265
					}
7930 manish.sha 266
					shipUpdate.date= dateformat.format(te.getTimestamp().getTime());
267
					shipUpdate.time= timeformat.format(te.getTimestamp().getTime());
268
					shipUpdate.description= te.getEventDescription();
269
					updates.add(shipUpdate);
270
				}			
271
			}
272
			return updates;
273
		}
274
		else{
275
			return null;
276
		}
277
	}
278
 
279
	public static void main(String[] args) {
280
		FedExTrackingService trackClient = new FedExTrackingService();
8368 manish.sha 281
		List<ShipmentUpdate> updates = trackClient.getUpdates("796869788166");
7930 manish.sha 282
		for(ShipmentUpdate update: updates){
283
			System.out.println(update.toString());
284
		}
285
	}
286
 
287
}