WebSVN – SmartDukaan – Diff – /trunk/JungleeOrders/src/main/java/com/amazonservices/mws/orders/samples/FetchOrderUpdatesJob.java

 import java.security.DigestInputStream;
 import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;
 import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.Calendar;
 import java.util.GregorianCalendar;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Random;
 /**
  * This sample illustrates continuous order updates retrieval. It contains a
  * order updates fetcher job that fetches updates every 15 minutes.
  */
-public class FetchOrderUpdatesJobandAcknowledge {
+public class FetchOrderUpdatesJob {
 	/*
 	 * Add required parameters in OrdersConfig.java before trying out this
 	 * sample.
 	 */
-	public static final Log log = LogFactory.getLog(OrderFetcherSample.class);
-	private volatile boolean keepRunning = true;
+	public static final Log log = LogFactory.getLog(OrderFetcherSample.class);
+	//private volatile boolean keepRunning = true;
+	private boolean keepRunning = true;
 	/*************************************
 	 * Throttling Limits in Milliseconds *
 	 *************************************/
 	// 1 call per 10 mins
 	static final long LIST_ORDERS_THROTTLE_LIMIT = 600000L;
 	// 1 call per 12 secs
 	static final long LIST_ORDER_ITEMS_THROTTLE_LIMIT = 12000L;
+	final public static String AMAZON_ORDER_ACKNOWLEDGEMENT_XML = "/home/vikram/OrderAcknowledgeMent.xml";
-	public String AMAZON_ORDER_ACKNOWLEDGEMENT_XML;
-	static final int INTERVAL_IN_MINS = 1; // 15-minute update interval
+	static final int INTERVAL_IN_MINS = 30; // 1-minute update interval
 	//static final int INTERVAL_IN_MINS = 15; // 15-minute update interval
 	protected MarketplaceWebServiceOrders service;
 	protected String sellerId = null;
 	protected MarketplaceIdList marketplaceIdList = null;
 	private File file;
-	public FetchOrderUpdatesJobandAcknowledge(
+	public FetchOrderUpdatesJob(
 			MarketplaceWebServiceOrders marketplaceWebServiceOrdersClient,
 			String sellerId, MarketplaceIdList marketplaceIdList) {
 		if (marketplaceWebServiceOrdersClient == null) {
 			throw new IllegalArgumentException(
 			"MarketplaceWebServiceOrders object cannot be null.");
 				OrdersConfig.accessKeyId,
 				OrdersConfig.secretAccessKey,
 				OrdersConfig.applicationName,
 				OrdersConfig.applicationVersion,
 				OrdersConfig.config);
-		final FetchOrderUpdatesJobandAcknowledge orderFetcher = new FetchOrderUpdatesJobandAcknowledge(
+		final FetchOrderUpdatesJob orderFetcher = new FetchOrderUpdatesJob(
 				client, OrdersConfig.sellerId,
 				OrdersConfig.marketplaceIdList);
 		/*	Thread fetchOrderUpdatesJobThread = new Thread(new Runnable() {
 			public void run() {
+		}
 		TransactionClient tcl=null;
 		long time=0;
 		try {
 			tcl = new TransactionClient();
-			time = tcl.getClient().getSourceDetail(10).getLastUpdatedOn();
+			time = tcl.getClient().getSourceDetail(3).getLastUpdatedOn();
 		} catch (TException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
 			 * from the loop as the job is lagging far behind in getting new
 			 * orders.
 			 */
 			//if (timeWaited > 24 * 4 * INTERVAL_IN_MINS * 60L * 1000L) {
 			if (timeWaited > 100000 * 60L * 1000L) {
-				//keepRunning = false;
+				keepRunning = false;
 				System.out.println("Setting keep running to false");
-				log
-				.info("timeWaited is greater than 30 times the interval. This a too large a time interval for which to fetch orders.");
+				log.info("timeWaited is greater than 30 times the interval. This a too large a time interval for which to fetch orders.");
+			}
 			/*
 			 * If the time lapsed is greater than or equal to 15 mins, we will
 			 * try to fetchOrderUpdates giving it a startTime.
 			 */
 			else if (timeWaited >= INTERVAL_IN_MINS * 60L * 1000L) {
 				log.info("Time to fetch new order updates.");
 				XMLGregorianCalendar endTime = fetchOrderUpdatesSince(startTime);
 				//System.out.println("End Time is : " + endTime.getDay() +"-"+ endTime.getMonth()+"-" + endTime.getHour()+":"+endTime.getMinute());
+				//createandsubmitOrderAcknowlegementFeed();
 				if (endTime != null) {
 					startTime = endTime;
 					try {
-						tcl = new TransactionClient();
-						tcl.getClient().updateSourceDetailTimestamp(3,endTime.toGregorianCalendar().getTimeInMillis() - 7*24*60*60*1000);
+						tcl.getClient().updateSourceDetailTimestamp(3,endTime.toGregorianCalendar().getTimeInMillis());
 					} catch (TException e) {
 						// TODO Auto-generated catch block
 						e.printStackTrace();
+					}
 				} else {
 	 * it will terminate the job only after the call returns with valid results.
 	 * If this method is called while the thread is sleeping, because a request
 	 * was throttled, the job will terminate after it wakes up.
 	 */
 	public void stopSynch() {
-		keepRunning = false;
+		//keepRunning = false;
+	}
 	/**
 	 * Gets all orders updated between the given startTime and the calculated
 	 * endTime. The endTime is calculated by the service as server's system
 			System.out.println("Request ID: " + ex.getRequestId());
 			System.out.print("XML: " + ex.getXML());
 			return null;
+		}
+	}
+	//This method will create Order Acknowledgement FEED
+	public void createandsubmitOrderAcknowlegementFeed() {
+		TransactionClient tcl=null;
+		List<AmazonOrdersToAcknowledge> amazonOrdersToAcknowledge=null;
+		try {
+			tcl = new TransactionClient();
+			amazonOrdersToAcknowledge = tcl.getClient().getAmazonOrdersToAcknowledge();
+		} catch (TTransportException e2) {
+			// TODO Auto-generated catch block
+			e2.printStackTrace();
+		} catch (TException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		if(amazonOrdersToAcknowledge!=null && amazonOrdersToAcknowledge.size() > 0){
+			file = new File(AMAZON_ORDER_ACKNOWLEDGEMENT_XML);
+			AmazonEnvelope amazonenvelope = new AmazonEnvelope();
+			Header header = new Header();
+			header.setDocumentVersion("1.0");
+			header.setMerchantIdentifier("AF6E3O0VE0X4D");
+			header.setOverrideReleaseId(null);
+			amazonenvelope.setHeader(header);
+			amazonenvelope.setMessageType("OrderAcknowledgement");
+			amazonenvelope.setMarketplaceName(null);
+			List<Message> messages = amazonenvelope.getMessage();
+			Map<String,Long> amazonOrdertxnMap = new HashMap<String,Long>();
+			Map<String,List<String>> amazonOrderIdOrderItemMap = new HashMap<String,List<String>>();
+			Map<String,Integer> amazonOrderItemSuccessMap = new HashMap<String,Integer>();
+			Map<String,Integer> amazonOrderItemFailureMap = new HashMap<String,Integer>();
+			for(AmazonOrdersToAcknowledge amazonOrderToAcknowledge:amazonOrdersToAcknowledge ){
+				if(!amazonOrdertxnMap.containsKey(amazonOrderToAcknowledge.getAmazonOrderId())){
+					amazonOrdertxnMap.put(amazonOrderToAcknowledge.getAmazonOrderId(),amazonOrderToAcknowledge.getTransaction_id());
+				}
+				if(!amazonOrderIdOrderItemMap.containsKey(amazonOrderToAcknowledge.getAmazonOrderId())){
+					List<String> orderItemsList = new ArrayList<String>();
+					orderItemsList.add(amazonOrderToAcknowledge.getAmazonOrderItemId());
+					amazonOrderIdOrderItemMap.put(amazonOrderToAcknowledge.getAmazonOrderId(),orderItemsList);
+				}
+				else{
+					if(!amazonOrderIdOrderItemMap.get(amazonOrderToAcknowledge.getAmazonOrderId()).contains(amazonOrderToAcknowledge.getAmazonOrderItemId()))
+						amazonOrderIdOrderItemMap.get(amazonOrderToAcknowledge.getAmazonOrderId()).add(amazonOrderToAcknowledge.getAmazonOrderItemId());
+				}
+				if(amazonOrderToAcknowledge.getStatus().equals("Order-Payment-Success")){
+					amazonOrderItemSuccessMap.put(amazonOrderToAcknowledge.getAmazonOrderId()+amazonOrderToAcknowledge.getAmazonOrderItemId(),amazonOrderToAcknowledge.getCount());
+				}
+				if(amazonOrderToAcknowledge.getStatus().equals("Order-Payment-Failure")){
+					amazonOrderItemFailureMap.put(amazonOrderToAcknowledge.getAmazonOrderId()+amazonOrderToAcknowledge.getAmazonOrderItemId(),amazonOrderToAcknowledge.getCount());
+				}
+			}
+			JAXBContext context;
+			Marshaller m=null;
+			try {
+				context = JAXBContext.newInstance(AmazonEnvelope.class);
+				m = context.createMarshaller();
+			} catch (JAXBException e1) {
+				// TODO Auto-generated catch block
+				e1.printStackTrace();
+			}
+			for (Map.Entry<String,List<String>> entry : amazonOrderIdOrderItemMap.entrySet()){
+				OrderAcknowledgement orderAcknowLedgement = new OrderAcknowledgement();
+				List<OrderAcknowledgement.Item> acknowledgementItems = orderAcknowLedgement.getItem();
+				String orderid = entry.getKey();
+				orderAcknowLedgement.setAmazonOrderID(orderid);
+				orderAcknowLedgement.setMerchantOrderID(amazonOrdertxnMap.get(orderid).toString());
+				orderAcknowLedgement.setStatusCode("Failure");
+				for(String orderItemId :entry.getValue()){
+					OrderAcknowledgement.Item orderAcknowledgementItem = new OrderAcknowledgement.Item();
+					if(amazonOrderItemSuccessMap.get(orderid+orderItemId)!=null && amazonOrderItemSuccessMap.get(orderid+orderItemId) > 0){
+						orderAcknowledgementItem.setAmazonOrderItemCode(orderItemId);
+						orderAcknowLedgement.setStatusCode("Success");
+					}
+					else{
+						orderAcknowledgementItem.setAmazonOrderItemCode(orderItemId);
+						orderAcknowledgementItem.setCancelReason("ShippingAddressUndeliverable");
+					}
+					acknowledgementItems.add(orderAcknowledgementItem);
+				}
+				AmazonEnvelope.Message message = new AmazonEnvelope.Message();
+				Random rand = new Random();
+				message.setMessageID(BigInteger.valueOf(Math.abs(rand.nextInt())));
+				message.setOrderAcknowledgement(orderAcknowLedgement);
+				messages.add(message);
+			}
+			System.out.println("Messages is " + messages);
+			try {
+				m.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
+				m.marshal(amazonenvelope, file);
+				m.marshal(amazonenvelope, System.out);
+			} catch (Exception e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			if(submitAcknowledgementFeed()==0);
+			//if(true)
+			{
+				for (Map.Entry<String,Long> entry : amazonOrdertxnMap.entrySet()){
+					try {
+						tcl.getClient().changeAmazonOrderStatus(entry.getKey(),"Acknowledgement-Sent");
+					} catch (TException e) {
+						// TODO Auto-generated catch block
+						e.printStackTrace();
+					}
+				}
+			}
+//			GmailUtils  gm = GmailUtils();
+//			gm.sendSSLMessage(arg0, arg1, arg2, arg3, arg4, arg5)
+		}
+	}
 	/*
 	 * listOrders call. If a request is throttled, this method calls the
 	 * throttling handler and sets the retry flag to true.
 	 */
 				return true;
+			}
 			else{
 				return false;
+			}
 		} catch (TException e) {
 			e.printStackTrace();
+		}
 		return false;
+	}
 				i++;
+			}
 			//if(order.getFulfillmentChannel().equals(FulfillmentChannelEnum.MFN) && (order.getOrderStatus().equals(OrderStatusEnum.UNSHIPPED) || order.getOrderStatus().equals(OrderStatusEnum.CANCELED))){
 			//if(order.getFulfillmentChannel().equals(FulfillmentChannelEnum.MFN) && (order.getOrderStatus().equals(OrderStatusEnum.UNSHIPPED) || order.getOrderStatus().equals(OrderStatusEnum.PARTIALLY_SHIPPED))){
 			if(order.getFulfillmentChannel().equals(FulfillmentChannelEnum.MFN) && order.getOrderStatus().equals(OrderStatusEnum.UNSHIPPED) && order.getSellerOrderId()==null ){
 				String userEmail = order.getBuyerEmail();
 		    	User user = new User();
 		    	user.setCommunicationEmail(userEmail);
 		    	user.setEmail(userEmail);
 		    	user.setName(order.getBuyerName());
 		    	user.setMobileNumber(order.getShippingAddress().getPhone());
-		    	user.setPassword("junglee");
+		    	user.setPassword("amazon");
-		    	user.setSourceId(10);
 		    	try {
 		    		UserClient ucl = new UserClient();
 		    		user = ucl.getClient().createUser(user);
 		    	} catch(Exception e) {
 		    		//////////////log.error("Unable to get default source", e);
+		    	}
 		    	long userId = user.getUserId();
 				AmazonOrder amazonOrder = new AmazonOrder();
 				long txnId = amazonOrder.persistTransaction(userId, user.getActiveCartId(), user.getEmail(), order, orderItems);
 				TransactionClient tcl=null;
 				InventoryClient icl = null;
 				PaymentClient pcl = null;
 				Map<Long,Double> saholicItemMap = new HashMap<Long,Double>();
 				if (txnId != -1){
 					List<in.shop2020.model.v1.order.AmazonOrder> amazonOrders = new ArrayList<in.shop2020.model.v1.order.AmazonOrder>();
 					try {
 						tcl = new TransactionClient();
 						icl = new InventoryClient();
 						pcl = new PaymentClient();;
 						System.out.println("temp id is" +userId);
 						List<in.shop2020.model.v1.order.Order>  saholicOrders =tcl.getClient().getOrdersForTransaction(txnId,userId);
 							aOrder.setAmazonOrderItemCode(orderItemSkuMap.get(Long.toString(itemId)));
 							aOrder.setItem_id(itemId);
 							aOrder.setOrderId(saholicOrder.getId());
 							aOrder.setTransactionId(txnId);
 							aOrder.setStatus("Order-Creation-Success");
-							aOrder.setPurchaseDateOnAmazon(order.getPurchaseDate().toGregorianCalendar().getTimeInMillis());
 							tcl.getClient().addAmazonOrder(aOrder);
 							amazonOrders.add(aOrder);
+						}
 						long merchantPaymentId = pcl.getClient().createPayment(userId, Double.parseDouble(order.getOrderTotal().getAmount()), 15, txnId, false);
 						pcl.getClient().updatePaymentDetails(merchantPaymentId, "", "", "15", "", "", "", "", "", PaymentStatus.SUCCESS, "", null);
 						if(success){
 							for(in.shop2020.model.v1.order.AmazonOrder aorder:amazonOrders){
 								AmazonInventorySnapshot amazonInventorySnapshot=icl.getClient().getAmazonInventoryForItem(aorder.getItem_id());
 								long reserved = (amazonInventorySnapshot.getReserved()+1);
 								amazonInventorySnapshot.setReserved(reserved);
-								icl.getClient().addOrUpdateAmazonInventoryForItem(amazonInventorySnapshot,0);
+								icl.getClient().addOrUpdateAmazonInventoryForItem((amazonInventorySnapshot),0);
 								tcl.getClient().updateAmazonOrderStatus(aorder.getOrderId(),"Order-Payment-Success");
-								java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
-								Calendar cal=GregorianCalendar.getInstance();
-								String emailFromAddress = "build@shop2020.in";
-								String emailSubjectTxt = "Order Created Payment Success "+sdf.format(cal.getTime())+" Amazon Order ID : "+aorder.getAmazonOrderCode();
-								String sendTo[] = new String[]{ "anikendra.das@shop2020.in","sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in","khushal.bhatia@shop2020.in","rajveer.singh@saholic.com","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com"};
-								String password = "cafe@nes";
-								String text = "Order is now available for processing on Order Management Dashboard";
-								GmailUtils mailer = new GmailUtils();
-								try {
-									System.out.println("Before Send mail order success");
-									mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
-								}
-								catch (Exception e) {
-									e.printStackTrace();
-								}
+							}
+						}
+					}
 					catch (TTransportException e) {
+						try{
+							tcl = new TransactionClient();
+						}
-						// TODO Auto-generated catch block
+						catch (TTransportException ex) {
+						}
 						for(in.shop2020.model.v1.order.AmazonOrder aorder:amazonOrders){
 							try {
-								try {
-									tcl = new TransactionClient();
-								} catch (TException excep) {
-									// TODO Auto-generated catch block
-									e.printStackTrace();
-								}
 								tcl.getClient().updateAmazonOrderStatus(aorder.getOrderId(),"Order-Payment-Failure");
-								in.shop2020.model.v1.order.Order saOrder= tcl.getClient().getOrder(aorder.getOrderId());
-								String customer_details = saOrder.getCustomer_address1()+" "+saOrder.getCustomer_address2()+"\n"+saOrder.getCustomer_city()+"\n"+saOrder.getCustomer_state()+"\n"+saOrder.getCustomer_pincode();
-								java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
-								Calendar cal=GregorianCalendar.getInstance();
-								String emailFromAddress = "build@shop2020.in";
-								String emailSubjectTxt = "Order Payment Failure Location not Serviciable "+sdf.format(cal.getTime())+" Amazon Order ID :"+aorder.getAmazonOrderCode();
-								String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in","khushal.bhatia@shop2020.in","rajveer.singh@saholic.com","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com"};
-								String password = "cafe@nes";
-								String text = "Order payment failed because of non serviceable location"+"\n"+customer_details;
-								GmailUtils mailer = new GmailUtils();
-								try {
-									System.out.println("Before Send mail order failure");
-									mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
-								}
-								catch (Exception exc) {
-									exc.printStackTrace();
-								}
 							} catch (TException e1) {
 								// TODO Auto-generated catch block
 								e1.printStackTrace();
+							}
-							catch (TransactionServiceException tex) {
-								// TODO Auto-generated catch block
-								tex.printStackTrace();
-							}
+						}
 						//e.printStackTrace();
 					} catch (TException e) {
 						// TODO Auto-generated catch block
 						e.printStackTrace();
 					} catch (PaymentException e) {

Subversion Repositories SmartDukaan

(root)/trunk/JungleeOrders/src/main/java/com/amazonservices/mws/orders/samples/FetchOrderUpdatesJob.java @ 12579 – Rev 12573 → 12577