Subversion Repositories SmartDukaan

Rev

Rev 8402 | Rev 8568 | 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>();
8504 manish.sha 189
		orderLoop:for(Order ord: ordersList){
8368 manish.sha 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();
8504 manish.sha 197
					for(TrackEvent tevent : trackEvents){
198
						if("DL".equalsIgnoreCase(tevent.getEventType())){
199
							continue orderLoop;
200
						}
201
					}
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();
8402 manish.sha 223
				SimpleDateFormat dateformat = new SimpleDateFormat("yyyy-MM-dd");
8368 manish.sha 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
}