WebSVN – SmartDukaan – Diff – /trunk/Website/src/main/java/in/shop2020/serving/controllers/PayuPayResponseController.java

 package in.shop2020.serving.controllers;
 import in.shop2020.config.ConfigException;
-import in.shop2020.datalogger.EventType;
+import in.shop2020.model.v1.order.RechargeOrder;
+import in.shop2020.model.v1.order.RechargeOrderStatus;
 import in.shop2020.payments.Attribute;
 import in.shop2020.payments.Payment;
 import in.shop2020.payments.PaymentException;
 import in.shop2020.payments.PaymentStatus;
 import in.shop2020.serving.services.CommonPaymentService;
 import in.shop2020.thrift.clients.PaymentClient;
 import in.shop2020.thrift.clients.TransactionClient;
-import in.shop2020.thrift.clients.UserClient;
 import in.shop2020.thrift.clients.config.ConfigClient;
-import in.shop2020.utils.DataLogger;
 import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 import java.util.Map;
 import java.util.TreeMap;
 import javax.servlet.http.HttpServletRequest;
 @SuppressWarnings("serial")
 public class PayuPayResponseController extends BaseController{
 	private static Logger log = Logger.getLogger(Class.class);
-	private static final String BANK_REF_ID = "BankRefId";
 	private static final String UNMAPPED_STATUS = "UnMappedStatus";
 	private static String successUrl;
 	private static String errorUrl;
+	private static String rechargeResultUri;
 	/**
 	 * The secret key used to decode RC4 encoded data.
 	 */
 	private static String accountKey;
 	private static String salt;
 	private String redirectUrl;
+	private String eurl;
+	private String surl;
 	static{
 		try {
+			ConfigClient cc = ConfigClient.getClient();
-			successUrl = ConfigClient.getClient().get("ebs_success_url");
+			successUrl = cc.get("payu_success_url");
-			errorUrl = ConfigClient.getClient().get("ebs_error_url");
+			errorUrl = cc.get("payu_error_url");
-			accountKey = ConfigClient.getClient().get("payu_account_id");
+			accountKey = cc.get("payu_account_id");
+			salt = cc.get("payu_secret_key");
-			salt = ConfigClient.getClient().get("payu_secret_key");
+			rechargeResultUri = ConfigClient.getClient().get("recharge_result_uri");
 		} catch (ConfigException e) {
 			log.error("Unable to get success and error usr info from config server.");
+		}
+	}
 	private Map<String, String> paymentParams = new TreeMap<String, String>();
-	public String create() {
+	public String index() {
-//		String gatewayTxnId = request.getParameter("mihpayid");
-//		String status = request.getParameter("status");
-//		String key = request.getParameter("key");
+		eurl = errorUrl;
-//		String mode = request.getParameter("mode");
+		surl = successUrl;
-//		String txnid = request.getParameter("txnid");
-//		String amount = request.getParameter("amount");
-//		String hash  = request.getParameter("hash");
-//		String bank_ref_num  = request.getParameter("bank_ref_num");
-//		String PG_TYPE  = request.getParameter("PG_TYPE");
-//		String Error  = request.getParameter("Error");
-//		String unmappedstatus  = request.getParameter("unmappedstatus");
-//
 		updatePaymentParams(request.getParameterMap());
 		PaymentClient paymentServiceClient = null;
 		TransactionClient transactionServiceClient = null;
-		UserClient userServiceClient = null;
 		try {
 			paymentServiceClient = new PaymentClient();
 			transactionServiceClient = new TransactionClient();
-			userServiceClient = new UserClient();
 		} catch (Exception e) {
 			log.error("Unable to initialize one of the clients", e);
+		}
 		String bankRefId = paymentParams.get("bank_ref_num");
 		String unmappedStatus  = paymentParams.get("unmappedstatus");
 		List<Attribute> attributes = new ArrayList<Attribute>();
-		attributes.add(new Attribute(BANK_REF_ID, bankRefId));
 		attributes.add(new Attribute(UNMAPPED_STATUS, unmappedStatus));
 		Payment payment = null;
 		Long txnId = null;
 		try {
 		} catch (PaymentException e1) {
 			log.error("Payment exception. It is serious, check merchant payment id + " + merchantPaymentId, e1);
 		} catch (TException e1) {
 			log.error("Thrift exception. Check payment id "+ merchantPaymentId, e1);
+		}
+		if(payment.getStatus() != PaymentStatus.INIT){
+			// We have already processed a response for this payment. Processing
+			// it again may fail his orders. So, let's ask him to check his
+			// account.
+			return "ebs-pay-response-maybe";
+		}
+		if(payment.isIsDigital()){
+			eurl = rechargeResultUri;
+			surl = rechargeResultUri;
+		}
 		if(!validatePaymentParams(amount, payment, hash)){
-			this.redirectUrl = errorUrl + "?paymentId=" + merchantPaymentId;
+			this.redirectUrl = eurl + "?paymentId=" + merchantPaymentId;
 			return "index";
+		}
 		if(gatewayTxnStatus.equalsIgnoreCase("SUCCESS")){
-			//Update payment status as authorized if payment is authorized.
 			try {
 				paymentServiceClient.getClient().updatePaymentDetails(merchantPaymentId, gatewayPaymentId,
-						"", gatewayTxnStatus, "Transaction Authorized at PG", "", "", "", "", PaymentStatus.AUTHORIZED, "", attributes);
+						"", gatewayTxnStatus, unmappedStatus.equals("captured") ? "Transaction captured at PG":"Transaction Authorized at PG",
+						"", "", bankRefId, "", unmappedStatus.equals("captured") ? PaymentStatus.SUCCESS : PaymentStatus.AUTHORIZED, new SimpleDateFormat().format(new Date()), attributes);
 			} catch (PaymentException e) {
-				log.error("Unable to mark the payment as authorized", e);
+				this.redirectUrl = eurl + "?paymentId=" + merchantPaymentId;
+				return "index";
 			} catch (TException e) {
-			    log.error("Unable to mark the payment as authorized", e);
+				this.redirectUrl = eurl + "?paymentId=" + merchantPaymentId;
+				return "index";
+			}
+            if(payment.isIsDigital()){
+            	RechargeOrder rechargeOrder = null;
+                try {
-			//CommonPaymentService.processSuccessfulTxn(txnId, userServiceClient, transactionServiceClient, false);
+                    rechargeOrder = transactionServiceClient.getClient().getRechargeOrdersForTransaction(txnId);
+                } catch (Exception e1) {
+                    log.error("Problem with txn client while getting recharge object", e1);
-            this.redirectUrl = successUrl + "?paymentId=" + merchantPaymentId;
+    				this.redirectUrl = eurl + "?paymentId=" + merchantPaymentId;
+    				return "index";
+                }
+		        try {
+		            PaymentClient pcl = new PaymentClient();
+		            boolean isCaptured = pcl.getClient().capturePayment(txnId, true);
+		            //Retry in case we are not able to capture first time
+		            if(!isCaptured){
+		            	Thread.sleep(2000);
+		            	isCaptured = pcl.getClient().capturePayment(txnId, true);
+		            }
+		            if(!isCaptured){
+		            	Thread.sleep(2000);
+		            	isCaptured = pcl.getClient().capturePayment(txnId, true);
+		            }
+		            if(isCaptured) {
+		                transactionServiceClient.getClient().updateRechargeOrderStatus(rechargeOrder.getId(), RechargeOrderStatus.PAYMENT_SUCCESSFUL);
+		            } else {
+                        transactionServiceClient.getClient().updateRechargeOrderStatus(rechargeOrder.getId(), RechargeOrderStatus.PAYMENT_FAILED);
+		            }
+		        } catch (Exception e) {
+		            log.error("Problem with txn client while trying to recharge", e);
+		        }
+            }
 		}else{
 			try {
 				paymentServiceClient.getClient().updatePaymentDetails(merchantPaymentId, gatewayPaymentId,
-						"", gatewayTxnStatus, "Payment Failed at PG", "", "", "", "", PaymentStatus.FAILED, "", attributes);
+						"", gatewayTxnStatus, "Payment Failed at PG", "", "", "", "", PaymentStatus.FAILED, new SimpleDateFormat().format(new Date()), attributes);
 			} catch (PaymentException e) {
 			    log.error("Unable to mark the payment as failed", e);
 			} catch (TException e) {
 			    log.error("Unable to mark the payment as failed", e);
+			}
 			CommonPaymentService.processFailedTxn(txnId, transactionServiceClient);
-//			DataLogger.logData(EventType.PAYMENT_FAILURE, getSessionId(), userinfo.getUserId(), userinfo.getEmail(), Long.toString(merchantPaymentId), gatewayPaymentId,
-//                    gatewayTxnStatus, "Payment Failed at PG");
 			this.redirectUrl = errorUrl + "?paymentId=" + merchantPaymentId;
+		}
-		log.info("User will be redirected to: " + this.redirectUrl);
+		log.info("User will be redirected to: " + "?paymentId=" + merchantPaymentId);
+		this.redirectUrl = surl + "?paymentId=" + merchantPaymentId;
 		return "index";
+	}
 	private boolean validatePaymentParams(double returnedAmount, Payment payment, String hash){
 		if(!(payment != null && Math.abs(payment.getAmount() - returnedAmount) <= 0.50 && hash.equals(getSecureHash()))){

Subversion Repositories SmartDukaan

(root)/trunk/Website/src/main/java/in/shop2020/serving/controllers/PayuPayResponseController.java – Rev 12788 → 13372