| Line 226... |
Line 226... |
| 226 |
} catch (DatatypeConfigurationException e) {
|
226 |
} catch (DatatypeConfigurationException e) {
|
| 227 |
log.error(e.getMessage(), e);
|
227 |
log.error(e.getMessage(), e);
|
| 228 |
}
|
228 |
}
|
| 229 |
TransactionClient tcl=null;
|
229 |
TransactionClient tcl=null;
|
| 230 |
long time=0;
|
230 |
long time=0;
|
| 231 |
try {
|
231 |
try {
|
| 232 |
tcl = new TransactionClient();
|
232 |
tcl = new TransactionClient();
|
| 233 |
time = tcl.getClient().getSourceDetail(3).getLastUpdatedOn();
|
233 |
time = tcl.getClient().getSourceDetail(3).getLastUpdatedOn();
|
| 234 |
} catch (TException e) {
|
234 |
} catch (TException e) {
|
| 235 |
// TODO Auto-generated catch block
|
235 |
// TODO Auto-generated catch block
|
| 236 |
e.printStackTrace();
|
236 |
e.printStackTrace();
|
| 237 |
}
|
237 |
}
|
| - |
|
238 |
|
| 238 |
|
239 |
|
| 239 |
|
- |
|
| 240 |
GregorianCalendar Time = new GregorianCalendar();
|
240 |
GregorianCalendar Time = new GregorianCalendar();
|
| 241 |
Time.setTimeInMillis(time);
|
241 |
Time.setTimeInMillis(time);
|
| 242 |
XMLGregorianCalendar startTime = df.newXMLGregorianCalendar(Time);
|
242 |
XMLGregorianCalendar startTime = df.newXMLGregorianCalendar(Time);
|
| 243 |
// endTime = now -2. So, startTime = now - 2 - INTERVAL_IN_MINS.
|
243 |
// endTime = now -2. So, startTime = now - 2 - INTERVAL_IN_MINS.
|
| 244 |
System.out.println("Sync job start time." + startTime.getDay() +"-"+ startTime.getMonth()+"-" + startTime.getHour()+":"+startTime.getMinute());
|
244 |
System.out.println("Sync job start time." + startTime.getDay() +"-"+ startTime.getMonth()+"-" + startTime.getHour()+":"+startTime.getMinute());
|
| Line 275... |
Line 275... |
| 275 |
* If the time lapsed is greater than or equal to 15 mins, we will
|
275 |
* If the time lapsed is greater than or equal to 15 mins, we will
|
| 276 |
* try to fetchOrderUpdates giving it a startTime.
|
276 |
* try to fetchOrderUpdates giving it a startTime.
|
| 277 |
*/
|
277 |
*/
|
| 278 |
else if (timeWaited >= INTERVAL_IN_MINS * 60L * 1000L) {
|
278 |
else if (timeWaited >= INTERVAL_IN_MINS * 60L * 1000L) {
|
| 279 |
log.info("Time to fetch new order updates.");
|
279 |
log.info("Time to fetch new order updates.");
|
| 280 |
|
280 |
|
| 281 |
XMLGregorianCalendar endTime = fetchOrderUpdatesSince(startTime);
|
281 |
XMLGregorianCalendar endTime = fetchOrderUpdatesSince(startTime);
|
| 282 |
//System.out.println("End Time is : " + endTime.getDay() +"-"+ endTime.getMonth()+"-" + endTime.getHour()+":"+endTime.getMinute());
|
282 |
//System.out.println("End Time is : " + endTime.getDay() +"-"+ endTime.getMonth()+"-" + endTime.getHour()+":"+endTime.getMinute());
|
| 283 |
//createandsubmitOrderAcknowlegementFeed();
|
283 |
//createandsubmitOrderAcknowlegementFeed();
|
| 284 |
if (endTime != null) {
|
284 |
if (endTime != null) {
|
| 285 |
startTime = endTime;
|
285 |
startTime = endTime;
|
| 286 |
|
286 |
|
| 287 |
try {
|
287 |
try {
|
| 288 |
tcl.getClient().updateSourceDetailTimestamp(3,endTime.getMillisecond());
|
288 |
tcl.getClient().updateSourceDetailTimestamp(3,endTime.toGregorianCalendar().getTimeInMillis());
|
| 289 |
} catch (TException e) {
|
289 |
} catch (TException e) {
|
| 290 |
// TODO Auto-generated catch block
|
290 |
// TODO Auto-generated catch block
|
| 291 |
e.printStackTrace();
|
291 |
e.printStackTrace();
|
| 292 |
}
|
292 |
}
|
| 293 |
} else {
|
293 |
} else {
|
| 294 |
log.info("endTime returned is null. Sleeping for "
|
294 |
log.info("endTime returned is null. Sleeping for "
|
| 295 |
+ INTERVAL_IN_MINS + " minutes.");
|
295 |
+ INTERVAL_IN_MINS + " minutes.");
|
| 296 |
try {
|
296 |
try {
|
| 297 |
Thread.sleep(INTERVAL_IN_MINS * 60L * 1000L);
|
297 |
Thread.sleep(INTERVAL_IN_MINS * 60L * 1000L);
|
| 298 |
} catch (InterruptedException e) {
|
298 |
} catch (InterruptedException e) {
|