| /******************************************************************************* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| *******************************************************************************/ |
| package org.apache.ofbiz.accounting.thirdparty.cybersource; |
| |
| import java.math.BigDecimal; |
| import java.util.HashMap; |
| import java.util.List; |
| import java.util.Locale; |
| import java.util.Map; |
| import java.util.Properties; |
| |
| import org.apache.ofbiz.accounting.payment.PaymentGatewayServices; |
| import org.apache.ofbiz.base.util.Debug; |
| import org.apache.ofbiz.base.util.SSLUtil; |
| import org.apache.ofbiz.base.util.StringUtil; |
| import org.apache.ofbiz.base.util.UtilGenerics; |
| import org.apache.ofbiz.base.util.UtilMisc; |
| import org.apache.ofbiz.base.util.UtilNumber; |
| import org.apache.ofbiz.base.util.UtilProperties; |
| import org.apache.ofbiz.base.util.UtilValidate; |
| import org.apache.ofbiz.base.util.string.FlexibleStringExpander; |
| import org.apache.ofbiz.entity.Delegator; |
| import org.apache.ofbiz.entity.GenericEntityException; |
| import org.apache.ofbiz.entity.GenericValue; |
| import org.apache.ofbiz.entity.util.EntityUtilProperties; |
| import org.apache.ofbiz.service.DispatchContext; |
| import org.apache.ofbiz.service.ServiceUtil; |
| |
| import com.cybersource.ws.client.Client; |
| import com.cybersource.ws.client.ClientException; |
| import com.cybersource.ws.client.FaultException; |
| |
| /** |
| * CyberSource WS Integration Services |
| */ |
| public class IcsPaymentServices { |
| |
| public static final String module = IcsPaymentServices.class.getName(); |
| private static int decimals = UtilNumber.getBigDecimalScale("invoice.decimals"); |
| private static int rounding = UtilNumber.getBigDecimalRoundingMode("invoice.rounding"); |
| public final static String resource = "AccountingUiLabels"; |
| |
| // load the JSSE properties |
| static { |
| SSLUtil.loadJsseProperties(); |
| } |
| |
| public static Map<String, Object> ccAuth(DispatchContext dctx, Map<String, ? extends Object> context) { |
| Delegator delegator = dctx.getDelegator(); |
| Locale locale = (Locale) context.get("locale"); |
| // generate the request/properties |
| Properties props = buildCsProperties(context, delegator); |
| if (props == null) { |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorGettingPaymentGatewayConfig", locale)); |
| } |
| |
| Map<String, Object> request = buildAuthRequest(context, delegator); |
| request.put("merchantID", props.get("merchantID")); |
| |
| // transmit the request |
| Map<String, Object> reply; |
| try { |
| reply = UtilGenerics.cast(Client.runTransaction(request, props)); |
| } catch (FaultException e) { |
| Debug.logError(e, "ERROR: Fault from CyberSource", module); |
| Debug.logError(e, "Fault : " + e.getFaultString(), module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } catch (ClientException e) { |
| Debug.logError(e, "ERROR: CyberSource Client exception : " + e.getMessage(), module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } |
| // process the reply |
| Map<String, Object> result = ServiceUtil.returnSuccess(); |
| processAuthResult(reply, result, delegator); |
| return result; |
| } |
| |
| public static Map<String, Object> ccReAuth(DispatchContext dctx, Map<String, ? extends Object> context) { |
| return ServiceUtil.returnSuccess(); |
| } |
| |
| public static Map<String, Object> ccCapture(DispatchContext dctx, Map<String, ? extends Object> context) { |
| Delegator delegator = dctx.getDelegator(); |
| GenericValue orderPaymentPreference = (GenericValue) context.get("orderPaymentPreference"); |
| //lets see if there is a auth transaction already in context |
| GenericValue authTransaction = (GenericValue) context.get("authTrans"); |
| Locale locale = (Locale) context.get("locale"); |
| if (authTransaction == null) { |
| authTransaction = PaymentGatewayServices.getAuthTransaction(orderPaymentPreference); |
| } |
| if (authTransaction == null) { |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingPaymentTransactionAuthorizationNotFoundCannotCapture", locale)); |
| } |
| // generate the request/properties |
| Properties props = buildCsProperties(context, delegator); |
| if (props == null) { |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorGettingPaymentGatewayConfig", locale)); |
| } |
| |
| Map<String, Object> request = buildCaptureRequest(context, authTransaction, delegator); |
| request.put("merchantID", props.get("merchantID")); |
| |
| // transmit the request |
| Map<String, Object> reply; |
| try { |
| reply = UtilGenerics.cast(Client.runTransaction(request, props)); |
| } catch (FaultException e) { |
| Debug.logError(e, "ERROR: Fault from CyberSource", module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } catch (ClientException e) { |
| Debug.logError(e, "ERROR: CyberSource Client exception : " + e.getMessage(), module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } |
| // process the reply |
| Map<String, Object> result = ServiceUtil.returnSuccess(); |
| processCaptureResult(reply, result); |
| return result; |
| } |
| |
| public static Map<String, Object> ccRelease(DispatchContext dctx, Map<String, ? extends Object> context) { |
| Delegator delegator = dctx.getDelegator(); |
| GenericValue orderPaymentPreference = (GenericValue) context.get("orderPaymentPreference"); |
| Locale locale = (Locale) context.get("locale"); |
| GenericValue authTransaction = PaymentGatewayServices.getAuthTransaction(orderPaymentPreference); |
| if (authTransaction == null) { |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingPaymentTransactionAuthorizationNotFoundCannotRelease", locale)); |
| } |
| |
| // generate the request/properties |
| Properties props = buildCsProperties(context, delegator); |
| if (props == null) { |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorGettingPaymentGatewayConfig", locale)); |
| } |
| |
| Map<String, Object> request = buildReleaseRequest(context, authTransaction); |
| request.put("merchantID", props.get("merchantID")); |
| |
| // transmit the request |
| Map<String, Object> reply; |
| try { |
| reply = UtilGenerics.cast(Client.runTransaction(request, props)); |
| } catch (FaultException e) { |
| Debug.logError(e, "ERROR: Fault from CyberSource", module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } catch (ClientException e) { |
| Debug.logError(e, "ERROR: CyberSource Client exception : " + e.getMessage(), module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } |
| // process the reply |
| Map<String, Object> result = ServiceUtil.returnSuccess(); |
| processReleaseResult(reply, result); |
| return result; |
| } |
| |
| public static Map<String, Object> ccRefund(DispatchContext dctx, Map<String, ? extends Object> context) { |
| Delegator delegator = dctx.getDelegator(); |
| GenericValue orderPaymentPreference = (GenericValue) context.get("orderPaymentPreference"); |
| Locale locale = (Locale) context.get("locale"); |
| GenericValue authTransaction = PaymentGatewayServices.getAuthTransaction(orderPaymentPreference); |
| if (authTransaction == null) { |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingPaymentTransactionAuthorizationNotFoundCannotRefund", locale)); |
| } |
| |
| // generate the request/properties |
| Properties props = buildCsProperties(context, delegator); |
| if (props == null) { |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorGettingPaymentGatewayConfig", locale)); |
| } |
| |
| Map<String, Object> request = buildRefundRequest(context, authTransaction, delegator); |
| request.put("merchantID", props.get("merchantID")); |
| |
| // transmit the request |
| Map<String, Object> reply; |
| try { |
| reply = UtilGenerics.cast(Client.runTransaction(request, props)); |
| } catch (FaultException e) { |
| Debug.logError(e, "ERROR: Fault from CyberSource", module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } catch (ClientException e) { |
| Debug.logError(e, "ERROR: CyberSource Client exception : " + e.getMessage(), module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } |
| |
| // process the reply |
| Map<String, Object> result = ServiceUtil.returnSuccess(); |
| processRefundResult(reply, result); |
| return result; |
| } |
| |
| public static Map<String, Object> ccCredit(DispatchContext dctx, Map<String, ? extends Object> context) { |
| Delegator delegator = dctx.getDelegator(); |
| Locale locale = (Locale) context.get("locale"); |
| // generate the request/properties |
| Properties props = buildCsProperties(context, delegator); |
| if (props == null) { |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorGettingPaymentGatewayConfig", locale)); |
| } |
| |
| Map<String, Object> request = buildCreditRequest(context); |
| request.put("merchantID", props.get("merchantID")); |
| |
| // transmit the request |
| Map<String, Object> reply; |
| try { |
| reply = UtilGenerics.cast(Client.runTransaction(request, props)); |
| } catch (FaultException e) { |
| Debug.logError(e, "ERROR: Fault from CyberSource", module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } catch (ClientException e) { |
| Debug.logError(e, "ERROR: CyberSource Client exception : " + e.getMessage(), module); |
| return ServiceUtil.returnError(UtilProperties.getMessage(resource, |
| "AccountingCyberSourceErrorCommunicateWithCyberSource", locale)); |
| } |
| |
| // process the reply |
| Map<String, Object> result = ServiceUtil.returnSuccess(); |
| processCreditResult(reply, result); |
| return result; |
| } |
| |
| private static Properties buildCsProperties(Map<String, ? extends Object> context, Delegator delegator) { |
| String paymentGatewayConfigId = (String) context.get("paymentGatewayConfigId"); |
| String configString = (String) context.get("paymentConfig"); |
| if (configString == null) { |
| configString = "payment.properties"; |
| } |
| String merchantId = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "merchantId", configString, "payment.cybersource.merchantID"); |
| String targetApi = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "apiVersion", configString, "payment.cybersource.api.version"); |
| String production = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "production", configString, "payment.cybersource.production"); |
| String enableLog = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "logEnabled", configString, "payment.cybersource.log"); |
| String logSize = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "logSize", configString, "payment.cybersource.log.size"); |
| String logFile = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "logFile", configString, "payment.cybersource.log.file"); |
| String logDir = FlexibleStringExpander.expandString(getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "logDir", configString, "payment.cybersource.log.dir"), context); |
| String keysDir = FlexibleStringExpander.expandString(getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "keysDir", configString, "payment.cybersource.keysDir"), context); |
| String keysFile = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "keysFile", configString, "payment.cybersource.keysFile"); |
| // some property checking |
| if (UtilValidate.isEmpty(merchantId)) { |
| Debug.logWarning("The merchantId property is not configured", module); |
| return null; |
| } |
| if (UtilValidate.isEmpty(keysDir)) { |
| Debug.logWarning("The keysDir property is not configured", module); |
| return null; |
| } |
| // create some properties for CS Client |
| Properties props = new Properties(); |
| props.put("merchantID", merchantId); |
| props.put("keysDirectory", keysDir); |
| props.put("targetAPIVersion", targetApi); |
| props.put("sendToProduction", production); |
| props.put("enableLog", enableLog); |
| props.put("logDirectory", logDir); |
| props.put("logFilename", logFile); |
| props.put("logMaximumSize", logSize); |
| if (UtilValidate.isNotEmpty(keysFile)) { |
| props.put("alternateKeyFilename", keysFile); |
| } |
| Debug.logInfo("Created CyberSource Properties : " + props, module); |
| return props; |
| } |
| |
| private static Map<String, Object> buildAuthRequest(Map<String, ? extends Object> context, Delegator delegator) { |
| String paymentGatewayConfigId = (String) context.get("paymentGatewayConfigId"); |
| String configString = (String) context.get("paymentConfig"); |
| String currency = (String) context.get("currency"); |
| if (configString == null) { |
| configString = "payment.properties"; |
| } |
| // make the request map |
| String capture = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "autoBill", configString, "payment.cybersource.autoBill", "false"); |
| String orderId = (String) context.get("orderId"); |
| Map<String, Object> request = new HashMap<String, Object>(); |
| request.put("ccAuthService_run", "true"); // run auth service |
| request.put("ccCaptureService_run", capture); // run capture service (i.e. sale) |
| request.put("merchantReferenceCode", orderId); // set the order ref number |
| request.put("purchaseTotals_currency", currency); // set the order currency |
| appendFullBillingInfo(request, context); // add in all address info |
| appendItemLineInfo(request, context, "processAmount"); // add in the item info |
| appendAvsRules(request, context, delegator); // add in the AVS flags and decline codes |
| return request; |
| } |
| |
| private static Map<String, Object> buildCaptureRequest(Map<String, ? extends Object> context, GenericValue authTransaction, Delegator delegator) { |
| GenericValue orderPaymentPreference = (GenericValue) context.get("orderPaymentPreference"); |
| String paymentGatewayConfigId = (String) context.get("paymentGatewayConfigId"); |
| String configString = (String) context.get("paymentConfig"); |
| String currency = (String) context.get("currency"); |
| if (configString == null) { |
| configString = "payment.properties"; |
| } |
| String merchantDesc = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "merchantDescr", configString, "payment.cybersource.merchantDescr", null); |
| String merchantCont = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "merchantContact", configString, "payment.cybersource.merchantContact", null); |
| Map<String, Object> request = new HashMap<String, Object>(); |
| request.put("ccCaptureService_run", "true"); |
| request.put("ccCaptureService_authRequestID", authTransaction.getString("referenceNum")); |
| request.put("item_0_unitPrice", getAmountString(context, "captureAmount")); |
| request.put("merchantReferenceCode", orderPaymentPreference.getString("orderId")); |
| request.put("purchaseTotals_currency", currency); |
| |
| // TODO: add support for verbal authorizations |
| if (merchantDesc != null) { |
| request.put("invoiceHeader_merchantDescriptor", merchantDesc); // merchant description |
| } |
| if (merchantCont != null) { |
| request.put("invoiceHeader_merchantDescriptorContact", merchantCont); // merchant contact info |
| } |
| return request; |
| } |
| |
| private static Map<String, Object> buildReleaseRequest(Map<String, ? extends Object> context, GenericValue authTransaction) { |
| Map<String, Object> request = new HashMap<String, Object>(); |
| GenericValue orderPaymentPreference = (GenericValue) context.get("orderPaymentPreference"); |
| String currency = (String) context.get("currency"); |
| request.put("ccAuthReversalService_run", "true"); |
| request.put("ccAuthReversalService_authRequestID", authTransaction.getString("referenceNum")); |
| request.put("item_0_unitPrice", getAmountString(context, "releaseAmount")); |
| request.put("merchantReferenceCode", orderPaymentPreference.getString("orderId")); |
| request.put("purchaseTotals_currency", currency); |
| return request; |
| } |
| |
| private static Map<String, Object> buildRefundRequest(Map<String, ? extends Object> context, GenericValue authTransaction, Delegator delegator) { |
| GenericValue orderPaymentPreference = (GenericValue) context.get("orderPaymentPreference"); |
| String paymentGatewayConfigId = (String) context.get("paymentGatewayConfigId"); |
| String configString = (String) context.get("paymentConfig"); |
| if (configString == null) { |
| configString = "payment.properties"; |
| } |
| String currency = (String) context.get("currency"); |
| String merchantDesc = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "merchantDescr", configString, "payment.cybersource.merchantDescr", null); |
| String merchantCont = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "merchantContact", configString, "payment.cybersource.merchantContact", null); |
| Map<String, Object> request = new HashMap<String, Object>(); |
| request.put("ccCreditService_run", "true"); |
| request.put("ccCreditService_captureRequestID", authTransaction.getString("referenceNum")); |
| request.put("item_0_unitPrice", getAmountString(context, "refundAmount")); |
| request.put("merchantReferenceCode", orderPaymentPreference.getString("orderId")); |
| request.put("purchaseTotals_currency", currency); |
| if (merchantDesc != null) { |
| request.put("invoiceHeader_merchantDescriptor", merchantDesc); // merchant description |
| } |
| if (merchantCont != null) { |
| request.put("invoiceHeader_merchantDescriptorContact", merchantCont); // merchant contact info |
| } |
| return request; |
| } |
| |
| private static Map<String, Object> buildCreditRequest(Map<String, ? extends Object> context) { |
| String refCode = (String) context.get("referenceCode"); |
| Map<String, Object> request = new HashMap<String, Object>(); |
| request.put("ccCreditService_run", "true"); // run credit service |
| request.put("merchantReferenceCode", refCode); // set the ref number could be order id |
| appendFullBillingInfo(request, context); // add in all address info |
| appendItemLineInfo(request, context, "creditAmount"); // add in the item info |
| return request; |
| } |
| |
| private static void appendAvsRules(Map<String, Object> request, Map<String, ? extends Object> context, Delegator delegator) { |
| String paymentGatewayConfigId = (String) context.get("paymentGatewayConfigId"); |
| String configString = (String) context.get("paymentConfig"); |
| if (configString == null) { |
| configString = "payment.properties"; |
| } |
| String avsCodes = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "avsDeclineCodes", configString, "payment.cybersource.avsDeclineCodes", null); |
| GenericValue party = (GenericValue) context.get("billToParty"); |
| if (party != null) { |
| GenericValue avsOverride = null; |
| try { |
| avsOverride = party.getDelegator().findOne("PartyIcsAvsOverride", |
| UtilMisc.toMap("partyId", party.getString("partyId")), false); |
| } catch (GenericEntityException e) { |
| Debug.logError(e, module); |
| } |
| if (avsOverride != null && avsOverride.get("avsDeclineString") != null) { |
| String overrideString = avsOverride.getString("avsDeclineString"); |
| if (UtilValidate.isNotEmpty(overrideString)) { |
| avsCodes = overrideString; |
| } |
| } |
| } |
| if (UtilValidate.isNotEmpty(avsCodes)) { |
| request.put("businessRules_declineAVSFlags", avsCodes); |
| } |
| String avsIgnore = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, "ignoreAvs", configString, "payment.cybersource.ignoreAvs", "false"); |
| request.put("businessRules_ignoreAVS", avsIgnore); |
| } |
| |
| private static void appendFullBillingInfo(Map<String, Object> request, Map<String, ? extends Object> context) { |
| // contact info |
| GenericValue email = (GenericValue) context.get("billToEmail"); |
| if (email != null) { |
| request.put("billTo_email", email.getString("infoString")); |
| } else { |
| Debug.logWarning("Email not defined; Cybersource will fail.", module); |
| } |
| // phone number seems to not be used; possibly only for reporting. |
| |
| // CC payment info |
| GenericValue creditCard = (GenericValue) context.get("creditCard"); |
| if (creditCard != null) { |
| List<String> expDateList = StringUtil.split(creditCard.getString("expireDate"), "/"); |
| request.put("billTo_firstName", creditCard.getString("firstNameOnCard")); |
| request.put("billTo_lastName", creditCard.getString("lastNameOnCard")); |
| request.put("card_accountNumber", creditCard.getString("cardNumber")); |
| request.put("card_expirationMonth", expDateList.get(0)); |
| request.put("card_expirationYear", expDateList.get(1)); |
| } else { |
| Debug.logWarning("CreditCard not defined; Cybersource will fail.", module); |
| } |
| // CCV info |
| String cvNum = (String) context.get("cardSecurityCode"); |
| String cvSet = UtilValidate.isEmpty(cvNum) ? "1" : "0"; |
| request.put("card_cvIndicator", cvSet); |
| if ("1".equals(cvNum)) { |
| request.put("card_cvNumber", cvNum); |
| } |
| // payment contact info |
| GenericValue billingAddress = (GenericValue) context.get("billingAddress"); |
| |
| if (billingAddress != null) { |
| request.put("billTo_street1", billingAddress.getString("address1")); |
| if (billingAddress.get("address2") != null) { |
| request.put("billTo_street2", billingAddress.getString("address2")); |
| } |
| request.put("billTo_city", billingAddress.getString("city")); |
| String bCountry = billingAddress.get("countryGeoId") != null ? billingAddress.getString("countryGeoId") : "USA"; |
| request.put("billTo_country", bCountry); |
| request.put("billTo_postalCode", billingAddress.getString("postalCode")); |
| if (billingAddress.get("stateProvinceGeoId") != null) { |
| request.put("billTo_state", billingAddress.getString("stateProvinceGeoId")); |
| } |
| } else { |
| Debug.logWarning("BillingAddress not defined; Cybersource will fail.", module); |
| } |
| // order shipping information |
| GenericValue shippingAddress = (GenericValue) context.get("shippingAddress"); |
| if (shippingAddress != null) { |
| if (creditCard != null) { |
| // TODO: this is just a kludge since we don't have a firstName and lastName on the PostalAddress entity, that needs to be done |
| request.put("shipTo_firstName", creditCard.getString("firstNameOnCard")); |
| request.put("shipTo_lastName", creditCard.getString("lastNameOnCard")); |
| } |
| request.put("shipTo_street1", shippingAddress.getString("address1")); |
| if (shippingAddress.get("address2") != null) { |
| request.put("shipTo_street2", shippingAddress.getString("address2")); |
| } |
| request.put("shipTo_city", shippingAddress.getString("city")); |
| String sCountry = shippingAddress.get("countryGeoId") != null ? shippingAddress.getString("countryGeoId") : "USA"; |
| request.put("shipTo_country", sCountry); |
| request.put("shipTo_postalCode", shippingAddress.getString("postalCode")); |
| if (shippingAddress.get("stateProvinceGeoId") != null) { |
| request.put("shipTo_state", shippingAddress.getString("stateProvinceGeoId")); |
| } |
| } |
| } |
| |
| private static void appendItemLineInfo(Map<String, Object> request, Map<String, ? extends Object> context, String amountField) { |
| // send over a line item total offer w/ the total for billing; don't trust CyberSource for calc |
| String currency = (String) context.get("currency"); |
| int lineNumber = 0; |
| request.put("item_" + lineNumber + "_unitPrice", getAmountString(context, amountField)); |
| // the currency |
| request.put("purchaseTotals_currency", currency); |
| // create the offers (one for each line item) |
| List<GenericValue> orderItems = UtilGenerics.cast(context.get("orderItems")); |
| if (orderItems != null) { |
| for (Object orderItem : orderItems) { |
| lineNumber++; |
| GenericValue item = (GenericValue) orderItem; |
| GenericValue product = null; |
| try { |
| product = item.getRelatedOne("Product", false); |
| } catch (GenericEntityException e) { |
| Debug.logError(e, "ERROR: Unable to get Product from OrderItem, not passing info to CyberSource"); |
| } |
| if (product != null) { |
| request.put("item_" + lineNumber + "_productName", product.getString("productName")); |
| request.put("item_" + lineNumber + "_productSKU", product.getString("productId")); |
| } else { |
| // no product; just send the item description -- non product items |
| request.put("item_" + lineNumber + "_productName", item.getString("description")); |
| } |
| // get the quantity.. |
| BigDecimal quantity = item.getBigDecimal("quantity"); |
| // test quantity if INT pass as is; if not pass as 1 |
| if (quantity.scale() > 0) { |
| request.put("item_" + lineNumber + "_quantity", "1"); |
| } else { |
| request.put("", Integer.toString(quantity.intValue())); |
| } |
| // set the amount to 0.0000 -- we will send a total too. |
| request.put("item_" + lineNumber + "_unitPrice", "0.0000"); |
| } |
| } |
| } |
| |
| private static String getAmountString(Map<String, ? extends Object> context, String amountField) { |
| BigDecimal processAmount = (BigDecimal) context.get(amountField); |
| return processAmount.setScale(decimals, rounding).toPlainString(); |
| } |
| |
| private static void processAuthResult(Map<String, Object> reply, Map<String, Object> result, Delegator delegator) { |
| String decision = getDecision(reply); |
| String checkModeStatus = EntityUtilProperties.getPropertyValue("payment", "payment.cybersource.ignoreStatus", delegator); |
| if ("ACCEPT".equalsIgnoreCase(decision)) { |
| result.put("authCode", reply.get("ccAuthReply_authorizationCode")); |
| result.put("authResult", Boolean.TRUE); |
| } else { |
| result.put("authCode", decision); |
| if ("N".equals(checkModeStatus)) { |
| result.put("authResult", Boolean.FALSE); |
| } else { |
| result.put("authResult", Boolean.TRUE); |
| } |
| // TODO: based on reasonCode populate the following flags as applicable: resultDeclined, resultNsf, resultBadExpire, resultBadCardNumber |
| } |
| |
| if (reply.get("ccAuthReply_amount") != null) { |
| result.put("processAmount", new BigDecimal((String) reply.get("ccAuthReply_amount"))); |
| } else { |
| result.put("processAmount", BigDecimal.ZERO); |
| } |
| result.put("authRefNum", reply.get("requestID")); |
| result.put("authFlag", reply.get("ccAuthReply_reasonCode")); |
| result.put("authMessage", reply.get("ccAuthReply_processorResponse")); |
| result.put("cvCode", reply.get("ccAuthReply_cvCode")); |
| result.put("avsCode", reply.get("ccAuthReply_avsCode")); |
| result.put("scoreCode", reply.get("ccAuthReply_authFactorCode")); |
| result.put("captureRefNum", reply.get("requestID")); |
| if (UtilValidate.isNotEmpty(reply.get("ccCaptureReply_reconciliationID"))) { |
| if ("ACCEPT".equalsIgnoreCase(decision)) { |
| result.put("captureResult", Boolean.TRUE); |
| } else { |
| result.put("captureResult", Boolean.FALSE); |
| } |
| result.put("captureCode", reply.get("ccCaptureReply_reconciliationID")); |
| result.put("captureFlag", reply.get("ccCaptureReply_reasonCode")); |
| result.put("captureMessage", reply.get("decision")); |
| } |
| if (Debug.infoOn()) |
| Debug.logInfo("CC [Cybersource] authorization result : " + result, module); |
| } |
| |
| private static void processCaptureResult(Map<String, Object> reply, Map<String, Object> result) { |
| String decision = getDecision(reply); |
| if ("ACCEPT".equalsIgnoreCase(decision)) { |
| result.put("captureResult", Boolean.TRUE); |
| } else { |
| result.put("captureResult", Boolean.FALSE); |
| } |
| if (reply.get("ccCaptureReply_amount") != null) { |
| result.put("captureAmount", new BigDecimal((String) reply.get("ccCaptureReply_amount"))); |
| } else { |
| result.put("captureAmount", BigDecimal.ZERO); |
| } |
| result.put("captureRefNum", reply.get("requestID")); |
| result.put("captureCode", reply.get("ccCaptureReply_reconciliationID")); |
| result.put("captureFlag", reply.get("ccCaptureReply_reasonCode")); |
| result.put("captureMessage", reply.get("decision")); |
| if (Debug.infoOn()) |
| Debug.logInfo("CC [Cybersource] capture result : " + result, module); |
| } |
| |
| private static void processReleaseResult(Map<String, Object> reply, Map<String, Object> result) { |
| String decision = getDecision(reply); |
| if ("ACCEPT".equalsIgnoreCase(decision)) { |
| result.put("releaseResult", Boolean.TRUE); |
| } else { |
| result.put("releaseResult", Boolean.FALSE); |
| } |
| if (reply.get("ccAuthReversalReply_amount") != null) { |
| result.put("releaseAmount", new BigDecimal((String) reply.get("ccAuthReversalReply_amount"))); |
| } else { |
| result.put("releaseAmount", BigDecimal.ZERO); |
| } |
| result.put("releaseRefNum", reply.get("requestID")); |
| result.put("releaseCode", reply.get("ccAuthReversalReply_reasonCode")); |
| result.put("releaseFlag", reply.get("reasonCode")); |
| result.put("releaseMessage", reply.get("decision")); |
| if (Debug.infoOn()) |
| Debug.logInfo("CC [Cybersource] release result : " + result, module); |
| } |
| |
| private static void processRefundResult(Map<String, Object> reply, Map<String, Object> result) { |
| String decision = getDecision(reply); |
| if ("ACCEPT".equalsIgnoreCase(decision)) { |
| result.put("refundResult", Boolean.TRUE); |
| } else { |
| result.put("refundResult", Boolean.FALSE); |
| } |
| if (reply.get("ccCreditReply_amount") != null) { |
| result.put("refundAmount", new BigDecimal((String) reply.get("ccCreditReply_amount"))); |
| } else { |
| result.put("refundAmount", BigDecimal.ZERO); |
| } |
| result.put("refundRefNum", reply.get("requestID")); |
| result.put("refundCode", reply.get("ccCreditReply_reconciliationID")); |
| result.put("refundFlag", reply.get("ccCreditReply_reasonCode")); |
| result.put("refundMessage", reply.get("decision")); |
| if (Debug.infoOn()) |
| Debug.logInfo("CC [Cybersource] refund result : " + result, module); |
| } |
| |
| private static void processCreditResult(Map<String, Object> reply, Map<String, Object> result) { |
| String decision = (String) reply.get("decision"); |
| if ("ACCEPT".equalsIgnoreCase(decision)) { |
| result.put("creditResult", Boolean.TRUE); |
| } else { |
| result.put("creditResult", Boolean.FALSE); |
| } |
| |
| if (reply.get("ccCreditReply_amount") != null) { |
| result.put("creditAmount", new BigDecimal((String) reply.get("ccCreditReply_amount"))); |
| } else { |
| result.put("creditAmount", BigDecimal.ZERO); |
| } |
| |
| result.put("creditRefNum", reply.get("requestID")); |
| result.put("creditCode", reply.get("ccCreditReply_reconciliationID")); |
| result.put("creditFlag", reply.get("ccCreditReply_reasonCode")); |
| result.put("creditMessage", reply.get("decision")); |
| if (Debug.infoOn()) |
| Debug.logInfo("CC [Cybersource] credit result : " + result, module); |
| } |
| |
| private static String getDecision(Map<String, Object> reply) { |
| String decision = (String) reply.get("decision"); |
| String reasonCode = (String) reply.get("reasonCode"); |
| if (!"ACCEPT".equalsIgnoreCase(decision)) { |
| Debug.logInfo("CyberSource : " + decision + " (" + reasonCode + ")", module); |
| Debug.logInfo("Reply Dump : " + reply, module); |
| } |
| return decision; |
| } |
| |
| private static String getPaymentGatewayConfigValue(Delegator delegator, String paymentGatewayConfigId, String paymentGatewayConfigParameterName, |
| String resource, String parameterName) { |
| String returnValue = ""; |
| if (UtilValidate.isNotEmpty(paymentGatewayConfigId)) { |
| try { |
| GenericValue cyberSource = EntityQuery.use(delegator).from("PaymentGatewayCyberSource").where("paymentGatewayConfigId", paymentGatewayConfigId).queryOne(); |
| if (cyberSource != null) { |
| Object cyberSourceField = cyberSource.get(paymentGatewayConfigParameterName); |
| if (cyberSourceField != null) { |
| returnValue = cyberSourceField.toString().trim(); |
| } |
| } |
| } catch (GenericEntityException e) { |
| Debug.logError(e, module); |
| } |
| } else { |
| String value = EntityUtilProperties.getPropertyValue(resource, parameterName, delegator); |
| if (value != null) { |
| returnValue = value.trim(); |
| } |
| } |
| return returnValue; |
| } |
| |
| private static String getPaymentGatewayConfigValue(Delegator delegator, String paymentGatewayConfigId, String paymentGatewayConfigParameterName, |
| String resource, String parameterName, String defaultValue) { |
| String returnValue = getPaymentGatewayConfigValue(delegator, paymentGatewayConfigId, paymentGatewayConfigParameterName, resource, parameterName); |
| if (UtilValidate.isEmpty(returnValue)) { |
| returnValue = defaultValue; |
| } |
| return returnValue; |
| } |
| } |
