Subversion Repositories SmartDukaan

Rev

Rev 8394 | Rev 8504 | 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){
90
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 91
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 92
			if(trackreply!=null){
8385 manish.sha 93
				log.info("Successfully get Fedex Pickup Orders Reply");
8368 manish.sha 94
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
8402 manish.sha 95
				SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd");
8368 manish.sha 96
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
97
				for (int i=0; i< trackDetails.length; i++) {
98
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 99
					for(TrackEvent te : trackEvents){
100
						if("PU".equalsIgnoreCase(te.getEventType())){
101
							fedexPickupOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime()));
102
						}	
103
					}
8368 manish.sha 104
				}
105
			}
106
		}
8385 manish.sha 107
		log.info("Read Fedex Pickup Orders");
8368 manish.sha 108
		return fedexPickupOrdersMap;
109
	}
110
 
111
	public Map<String,String> readFedExReachedDestinationOrdersMap(List<Order> ordersList){
8388 manish.sha 112
		log.info("Into Method to Read Fedex Reached Destination Orders.... "+ ordersList.size());
8368 manish.sha 113
		Map<String,String> fedexReachedDestinationOrdersMap= new HashMap<String,String>();
114
		for(Order ord: ordersList){
115
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 116
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 117
			if(trackreply!=null){
8385 manish.sha 118
				log.info("Successfully get Fedex Reached Destination Orders");
8368 manish.sha 119
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
8402 manish.sha 120
				SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd");
8368 manish.sha 121
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
122
				for (int i=0; i< trackDetails.length; i++) {
123
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 124
					for(TrackEvent te : trackEvents){
125
						if("AR".equalsIgnoreCase(te.getEventType())){
8368 manish.sha 126
						fedexReachedDestinationOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime()));
8377 manish.sha 127
						}	
128
					}
8368 manish.sha 129
				}
130
			}
131
		}
8385 manish.sha 132
		log.info("Read Fedex Reached Destination Orders");
8368 manish.sha 133
		return fedexReachedDestinationOrdersMap;
134
	}
135
 
136
	public Map<String,String> readFedExDeliveredOrdersMap(List<Order> ordersList){
8388 manish.sha 137
		log.info("Into Method to Read Fedex Delivered Orders.... "+ ordersList.size());
8368 manish.sha 138
		Map<String,String> fedexDeliveredOrdersMap= new HashMap<String,String>();
139
		for(Order ord: ordersList){
140
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 141
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 142
			if(trackreply!=null){
8385 manish.sha 143
				log.info("Successfully get Fedex Delivered Orders");
8368 manish.sha 144
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
8380 manish.sha 145
				SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd");
8368 manish.sha 146
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
147
				for (int i=0; i< trackDetails.length; i++) {
148
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 149
					for(TrackEvent te : trackEvents){
150
						if("DL".equalsIgnoreCase(te.getEventType())){
8380 manish.sha 151
							fedexDeliveredOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime())+"|"+trackDetails[i].getDeliverySignatureName());
8377 manish.sha 152
						}	
153
					}
8368 manish.sha 154
				}
155
			}
156
		}
8385 manish.sha 157
		log.info("Read Fedex Delivered Orders");
8368 manish.sha 158
		return fedexDeliveredOrdersMap;
159
	}
160
 
161
	public Map<String,String> readFedExReturnedOrdersMap(List<Order> ordersList){
8388 manish.sha 162
		log.info("Into Method to Read Fedex Returned Orders.... "+ ordersList.size());
8368 manish.sha 163
		Map<String,String> fedexReturnedOrdersMap= new HashMap<String,String>();
164
		for(Order ord: ordersList){
165
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 166
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 167
			if(trackreply!=null){
8385 manish.sha 168
				log.info("Successfully get Fedex Returned Orders");
8368 manish.sha 169
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
8402 manish.sha 170
				SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd");
8368 manish.sha 171
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
172
				for (int i=0; i< trackDetails.length; i++) {
173
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 174
					for(TrackEvent te : trackEvents){
175
						if("RS".equalsIgnoreCase(te.getEventType())){
8380 manish.sha 176
							fedexReturnedOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime())+"|"+te.getEventDescription());
8377 manish.sha 177
						}
178
					}
8368 manish.sha 179
				}
180
			}
181
		}
8385 manish.sha 182
		log.info("Read Fedex Returned Orders");
8368 manish.sha 183
		return fedexReturnedOrdersMap;
184
	}
185
 
186
	public Map<String,String> readFedExUnDeliveredOrdersMap(List<Order> ordersList){
8388 manish.sha 187
		log.info("Into Method to Read Fedex Undelivered Orders.... "+ ordersList.size());
8368 manish.sha 188
		Map<String,String> fedexUnDeliveredOrdersMap= new HashMap<String,String>();
189
		for(Order ord: ordersList){
190
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 191
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 192
			if(trackreply!=null){
8385 manish.sha 193
				log.info("Successfully Get Fedex Undelivered Orders");
8368 manish.sha 194
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
195
				for (int i=0; i< trackDetails.length; i++) {
196
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 197
					for(TrackEvent te : trackEvents){
198
						if("DE".equalsIgnoreCase(te.getEventType())){
8380 manish.sha 199
							fedexUnDeliveredOrdersMap.put(awbNumber, te.getEventDescription());
8377 manish.sha 200
						}
201
					}
8368 manish.sha 202
				}
203
			}
204
		}
8385 manish.sha 205
		log.info("Read Fedex Undelivered Orders");
8368 manish.sha 206
		return fedexUnDeliveredOrdersMap;
207
	}
208
 
209
	public Map<String,String> readFedExFirstDeliveryAttemptedOrdersMap(List<Order> ordersList){
8388 manish.sha 210
		log.info("Into Method to Read Fedex First Delivery Attempted Orders.... "+ ordersList.size());
8368 manish.sha 211
		Map<String,String> fedexFirstDeliveryAttemptedOrdersMap= new HashMap<String,String>();
212
		for(Order ord: ordersList){
213
			String awbNumber= ord.getAirwaybill_no();
8391 manish.sha 214
			TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
8368 manish.sha 215
			if(trackreply!=null){
8385 manish.sha 216
				log.info("Successfully get Fedex First Delivery Attempted Orders");
8368 manish.sha 217
				TrackDetail[] trackDetails=trackreply.getTrackDetails();
8402 manish.sha 218
				SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd");
8368 manish.sha 219
				SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
220
				for (int i=0; i< trackDetails.length; i++) {
221
					TrackEvent trackEvents[]= trackDetails[i].getEvents();
8377 manish.sha 222
					for(TrackEvent te : trackEvents){
223
						if("OD".equalsIgnoreCase(te.getEventType())){
8380 manish.sha 224
							if(te.getStatusExceptionCode()!=null){
225
								fedexFirstDeliveryAttemptedOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime())+"|"+te.getStatusExceptionDescription());
226
							}
227
							else{
228
								fedexFirstDeliveryAttemptedOrdersMap.put(awbNumber, dateformat.format(te.getTimestamp().getTime())+" "+timeformat.format(te.getTimestamp().getTime())+"|"+te.getEventDescription());
229
							}
8377 manish.sha 230
						}
231
					}
8368 manish.sha 232
				}
233
			}
234
		}
8385 manish.sha 235
		log.info("Read Fedex First Delivery Attempted Orders");
8368 manish.sha 236
		return fedexFirstDeliveryAttemptedOrdersMap;
237
	}
238
 
7930 manish.sha 239
	public List<ShipmentUpdate> getUpdates(String awbNumber){
240
		List<ShipmentUpdate> updates = new ArrayList<ShipmentUpdate>();
8391 manish.sha 241
		TrackReply trackreply = TrackWebServiceClient.getTrackingUpdates(awbNumber, clientDetails, waDetails, endPointAddress);
7930 manish.sha 242
		if(trackreply!=null){
243
			TrackDetail[] trackDetails=trackreply.getTrackDetails();
244
			SimpleDateFormat dateformat = new SimpleDateFormat("dd-MMM-yyyy");
245
			SimpleDateFormat timeformat = new SimpleDateFormat("HH:mm:ss");
246
			for (int i=0; i< trackDetails.length; i++) {
247
				TrackEvent trackEvents[]= trackDetails[i].getEvents();
248
				for(TrackEvent te : trackEvents){
249
					ShipmentUpdate shipUpdate = new ShipmentUpdate();
8353 manish.sha 250
					if(te.getAddress()!=null){
251
						if(te.getAddress().getCity()!=null){
252
							shipUpdate.city= te.getAddress().getCity();
253
						}
254
						else{
255
							shipUpdate.city="Unknown";
256
						}
257
					}
258
					else{
259
						shipUpdate.city="Unknown";
260
					}
7930 manish.sha 261
					shipUpdate.date= dateformat.format(te.getTimestamp().getTime());
262
					shipUpdate.time= timeformat.format(te.getTimestamp().getTime());
263
					shipUpdate.description= te.getEventDescription();
264
					updates.add(shipUpdate);
265
				}			
266
			}
267
			return updates;
268
		}
269
		else{
270
			return null;
271
		}
272
	}
273
 
274
	public static void main(String[] args) {
275
		FedExTrackingService trackClient = new FedExTrackingService();
8368 manish.sha 276
		List<ShipmentUpdate> updates = trackClient.getUpdates("796869788166");
7930 manish.sha 277
		for(ShipmentUpdate update: updates){
278
			System.out.println(update.toString());
279
		}
280
	}
281
 
282
}