From: Benoît Pin Date: Fri, 27 Sep 2013 00:33:52 +0000 (+0200) Subject: Début d'intégration de PayPal. X-Git-Url: https://scm.cri.mines-paristech.fr/git/photoprint.git/commitdiff_plain/205a98c2f6e0548ced213fc330c1a0704e9c3c64?hp=063fb5ff0fbf7309b36761708e9ab00f39681246 Début d'intégration de PayPal. --- diff --git a/order.py b/order.py index 80784b9..7b87275 100755 --- a/order.py +++ b/order.py @@ -1,13 +1,22 @@ # -*- coding: utf-8 -*- -############################################################ -# Copyright © 2009 Benoît PIN # -# Cliché - http://luxia.fr # -# # -# This program is free software; you can redistribute it # -# and/or modify it under the terms of the Creative Commons # -# "Attribution-Noncommercial 2.0 Generic" # -# http://creativecommons.org/licenses/by-nc/2.0/ # -############################################################ +####################################################################################### +# Plinn - http://plinn.org # +# Copyright (C) 2009-2013 Benoît PIN # +# # +# This program is free software; you can redistribute it and/or # +# modify it under the terms of the GNU General Public License # +# as published by the Free Software Foundation; either version 2 # +# of the License, or (at your option) any later version. # +# # +# This program is distributed in the hope that it will be useful, # +# but WITHOUT ANY WARRANTY; without even the implied warranty of # +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # +# GNU General Public License for more details. # +# # +# You should have received a copy of the GNU General Public License # +# along with this program; if not, write to the Free Software # +# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. # +####################################################################################### """ Print order classes @@ -23,8 +32,9 @@ from zope.interface import implements from zope.component.factory import Factory from OFS.SimpleItem import SimpleItem from ZTUtils import make_query +from DateTime import DateTime from Products.CMFCore.PortalContent import PortalContent -from Products.CMFCore.permissions import ModifyPortalContent, View +from Products.CMFCore.permissions import ModifyPortalContent, View, ManagePortal from Products.CMFCore.utils import getToolByName, getUtilityByInterfaceName from Products.CMFDefault.DublinCore import DefaultDublinCoreImpl from Products.Plinn.utils import getPreferredLanguages @@ -36,482 +46,606 @@ from utils import translate from xml.dom.minidom import Document from tool import COPIES_COUNTERS from App.config import getConfiguration -try : - from Products.cyberplus import CyberplusConfig - from Products.cyberplus import CyberplusRequester - from Products.cyberplus import CyberplusResponder - from Products.cyberplus import LANGUAGE_VALUES as CYBERPLUS_LANGUAGES -except ImportError: - pass +from paypal.interface import PayPalInterface from logging import getLogger console = getLogger('Products.photoprint.order') -def _getCyberplusConfig() : - zopeConf = getConfiguration() - try : - conf = zopeConf.product_config['cyberplus'] - except KeyError : - EnvironmentError("No cyberplus configuration found in Zope environment.") - - merchant_id = conf['merchant_id'] - bin_path = conf['bin_path'] - path_file = conf['path_file'] - merchant_country = conf['merchant_country'] - - config = CyberplusConfig(merchant_id, - bin_path, - path_file, - merchant_country=merchant_country) - return config +def getPayPalConfig() : + zopeConf = getConfiguration() + try : + conf = zopeConf.product_config['photoprint'] + except KeyError : + EnvironmentError("No photoprint configuration found in Zope environment.") + + ppconf = {'API_ENVIRONMENT' : conf['paypal_api_environment'], + 'API_USERNAME' : conf['paypal_username'], + 'API_PASSWORD' : conf['paypal_password'], + 'API_SIGNATURE' : conf['paypal_signature']} + + return ppconf class PrintOrderTemplate(SimpleItem) : - """ - predefined print order - """ - implements(IPrintOrderTemplate) - - security = ClassSecurityInfo() - - def __init__(self - , id - , title='' - , description='' - , productReference='' - , maxCopies=0 - , price=0 - , VATRate=0) : - self.id = id - self.title = title - self.description = description - self.productReference = productReference - self.maxCopies = maxCopies # 0 means unlimited - self.price = Price(price, VATRate) - - security.declareProtected(ManagePrintOrderTemplate, 'edit') - def edit( self - , title='' - , description='' - , productReference='' - , maxCopies=0 - , price=0 - , VATRate=0 ) : - self.title = title - self.description = description - self.productReference = productReference - self.maxCopies = maxCopies - self.price = Price(price, VATRate) - - security.declareProtected(ManagePrintOrderTemplate, 'formWidgetData') - def formWidgetData(self, REQUEST=None, RESPONSE=None): - """formWidgetData documentation - """ - d = Document() - d.encoding = 'utf-8' - root = d.createElement('formdata') - d.appendChild(root) - - def gua(name) : - return str(getattr(self, name, '')).decode('utf-8') - - id = d.createElement('id') - id.appendChild(d.createTextNode(self.getId())) - root.appendChild(id) - - title = d.createElement('title') - title.appendChild(d.createTextNode(gua('title'))) - root.appendChild(title) - - description = d.createElement('description') - description.appendChild(d.createTextNode(gua('description'))) - root.appendChild(description) - - productReference = d.createElement('productReference') - productReference.appendChild(d.createTextNode(gua('productReference'))) - root.appendChild(productReference) - - maxCopies = d.createElement('maxCopies') - maxCopies.appendChild(d.createTextNode(str(self.maxCopies))) - root.appendChild(maxCopies) - - price = d.createElement('price') - price.appendChild(d.createTextNode(str(self.price.taxed))) - root.appendChild(price) - - vatrate = d.createElement('VATRate') - vatrate.appendChild(d.createTextNode(str(self.price.vat))) - root.appendChild(vatrate) + """ + predefined print order + """ + implements(IPrintOrderTemplate) + + security = ClassSecurityInfo() + + def __init__(self + , id + , title='' + , description='' + , productReference='' + , maxCopies=0 + , price=0 + , VATRate=0) : + self.id = id + self.title = title + self.description = description + self.productReference = productReference + self.maxCopies = maxCopies # 0 means unlimited + self.price = Price(price, VATRate) + + security.declareProtected(ManagePrintOrderTemplate, 'edit') + def edit( self + , title='' + , description='' + , productReference='' + , maxCopies=0 + , price=0 + , VATRate=0 ) : + self.title = title + self.description = description + self.productReference = productReference + self.maxCopies = maxCopies + self.price = Price(price, VATRate) + + security.declareProtected(ManagePrintOrderTemplate, 'formWidgetData') + def formWidgetData(self, REQUEST=None, RESPONSE=None): + """formWidgetData documentation + """ + d = Document() + d.encoding = 'utf-8' + root = d.createElement('formdata') + d.appendChild(root) + + def gua(name) : + return str(getattr(self, name, '')).decode('utf-8') + + id = d.createElement('id') + id.appendChild(d.createTextNode(self.getId())) + root.appendChild(id) + + title = d.createElement('title') + title.appendChild(d.createTextNode(gua('title'))) + root.appendChild(title) + + description = d.createElement('description') + description.appendChild(d.createTextNode(gua('description'))) + root.appendChild(description) + + productReference = d.createElement('productReference') + productReference.appendChild(d.createTextNode(gua('productReference'))) + root.appendChild(productReference) + + maxCopies = d.createElement('maxCopies') + maxCopies.appendChild(d.createTextNode(str(self.maxCopies))) + root.appendChild(maxCopies) + + price = d.createElement('price') + price.appendChild(d.createTextNode(str(self.price.taxed))) + root.appendChild(price) + + vatrate = d.createElement('VATRate') + vatrate.appendChild(d.createTextNode(str(self.price.vat))) + root.appendChild(vatrate) - if RESPONSE is not None : - RESPONSE.setHeader('content-type', 'text/xml; charset=utf-8') - - manager = getToolByName(self, 'caching_policy_manager', None) - if manager is not None: - view_name = 'formWidgetData' - headers = manager.getHTTPCachingHeaders( - self, view_name, {} - ) - - for key, value in headers: - if key == 'ETag': - RESPONSE.setHeader(key, value, literal=1) - else: - RESPONSE.setHeader(key, value) - if headers: - RESPONSE.setHeader('X-Cache-Headers-Set-By', - 'CachingPolicyManager: %s' % - '/'.join(manager.getPhysicalPath())) - - - return d.toxml('utf-8') + if RESPONSE is not None : + RESPONSE.setHeader('content-type', 'text/xml; charset=utf-8') + + manager = getToolByName(self, 'caching_policy_manager', None) + if manager is not None: + view_name = 'formWidgetData' + headers = manager.getHTTPCachingHeaders( + self, view_name, {} + ) + + for key, value in headers: + if key == 'ETag': + RESPONSE.setHeader(key, value, literal=1) + else: + RESPONSE.setHeader(key, value) + if headers: + RESPONSE.setHeader('X-Cache-Headers-Set-By', + 'CachingPolicyManager: %s' % + '/'.join(manager.getPhysicalPath())) + + + return d.toxml('utf-8') - + InitializeClass(PrintOrderTemplate) PrintOrderTemplateFactory = Factory(PrintOrderTemplate) class PrintOrder(PortalContent, DefaultDublinCoreImpl) : - - implements(IPrintOrder) - security = ClassSecurityInfo() - - def __init__( self, id) : - DefaultDublinCoreImpl.__init__(self) - self.id = id - self.items = [] - self.quantity = 0 - self.price = Price(0, 0) - # billing and shipping addresses - self.billing = PersistentMapping() - self.shipping = PersistentMapping() - self.shippingFees = Price(0,0) - self._paymentResponse = PersistentMapping() - - @property - def amountWithFees(self) : - return self.price + self.shippingFees - - - security.declareProtected(ModifyPortalContent, 'editBilling') - def editBilling(self - , name - , address - , city - , zipcode - , country - , phone) : - self.billing['name'] = name - self.billing['address'] = address - self.billing['city'] = city - self.billing['zipcode'] = zipcode - self.billing['country'] = country - self.billing['phone'] = phone - - security.declareProtected(ModifyPortalContent, 'editShipping') - def editShipping(self, name, address, city, zipcode, country) : - self.shipping['name'] = name - self.shipping['address'] = address - self.shipping['city'] = city - self.shipping['zipcode'] = zipcode - self.shipping['country'] = country - - security.declarePrivate('loadCart') - def loadCart(self, cart): - pptool = getToolByName(self, 'portal_photo_print') - uidh = getToolByName(self, 'portal_uidhandler') - mtool = getToolByName(self, 'portal_membership') - - items = [] - for item in cart : - photo = uidh.getObject(item['cmf_uid']) - pOptions = pptool.getPrintingOptionsContainerFor(photo) - template = getattr(pOptions, item['printing_template']) + + implements(IPrintOrder) + security = ClassSecurityInfo() + + def __init__( self, id) : + DefaultDublinCoreImpl.__init__(self) + self.id = id + self.items = [] + self.quantity = 0 + self.price = Price(0, 0) + # billing and shipping addresses + self.billing = PersistentMapping() + self.shipping = PersistentMapping() + self.shippingFees = Price(0,0) + self._paymentResponse = PersistentMapping() + + @property + def amountWithFees(self) : + return self.price + self.shippingFees + + + security.declareProtected(ModifyPortalContent, 'editBilling') + def editBilling(self + , name + , address + , city + , zipcode + , country + , phone) : + self.billing['name'] = name + self.billing['address'] = address + self.billing['city'] = city + self.billing['zipcode'] = zipcode + self.billing['country'] = country + self.billing['phone'] = phone + + security.declareProtected(ModifyPortalContent, 'editShipping') + def editShipping(self, name, address, city, zipcode, country) : + self.shipping['name'] = name + self.shipping['address'] = address + self.shipping['city'] = city + self.shipping['zipcode'] = zipcode + self.shipping['country'] = country + + security.declarePrivate('loadCart') + def loadCart(self, cart): + pptool = getToolByName(self, 'portal_photo_print') + uidh = getToolByName(self, 'portal_uidhandler') + mtool = getToolByName(self, 'portal_membership') + + items = [] + for item in cart : + photo = uidh.getObject(item['cmf_uid']) + pOptions = pptool.getPrintingOptionsContainerFor(photo) + template = getattr(pOptions, item['printing_template']) - reference = template.productReference - quantity = item['quantity'] - uPrice = template.price - self.quantity += quantity - - d = {'cmf_uid' : item['cmf_uid'] - ,'url' : photo.absolute_url() - ,'title' : template.title - ,'description' : template.description - ,'unit_price' : Price(uPrice._taxed, uPrice._rate) - ,'quantity' : quantity - ,'productReference' : reference - } - items.append(d) - self.price += uPrice * quantity - # confirm counters - if template.maxCopies : - counters = getattr(photo, COPIES_COUNTERS) - counters.confirm(reference, quantity) - - self.items = tuple(items) + reference = template.productReference + quantity = item['quantity'] + uPrice = template.price + self.quantity += quantity + + d = {'cmf_uid' : item['cmf_uid'] + ,'url' : photo.absolute_url() + ,'title' : template.title + ,'description' : template.description + ,'unit_price' : Price(uPrice._taxed, uPrice._rate) + ,'quantity' : quantity + ,'productReference' : reference + } + items.append(d) + self.price += uPrice * quantity + # confirm counters + if template.maxCopies : + counters = getattr(photo, COPIES_COUNTERS) + counters.confirm(reference, quantity) + + self.items = tuple(items) - member = mtool.getAuthenticatedMember() - mg = lambda name : member.getProperty(name, '') - billing = {'name' : member.getMemberFullName(nameBefore=0) - ,'address' : mg('billing_address') - ,'city' : mg('billing_city') - ,'zipcode' : mg('billing_zipcode') - ,'country' : mg('country') - ,'phone' : mg('phone') } - self.editBilling(**billing) - - sg = lambda name : cart._shippingInfo.get(name, '') - shipping = {'name' : sg('shipping_fullname') - ,'address' : sg('shipping_address') - ,'city' : sg('shipping_city') - ,'zipcode' : sg('shipping_zipcode') - ,'country' : sg('shipping_country')} - self.editShipping(**shipping) - - self.shippingFees = pptool.getShippingFeesFor(shippable=self) - - cart._confirmed = True - cart.pendingOrderPath = self.getPhysicalPath() - - security.declareProtected(ManagePrintOrders, 'resetCopiesCounters') - def resetCopiesCounters(self) : - pptool = getToolByName(self, 'portal_photo_print') - uidh = getToolByName(self, 'portal_uidhandler') - - for item in self.items : - photo = uidh.getObject(item['cmf_uid']) - counters = getattr(photo, COPIES_COUNTERS, None) - if counters : - counters.cancel(item['productReference'], - item['quantity']) - - security.declareProtected(View, 'getPaymentRequest') - def getPaymentRequest(self) : - config = _getCyberplusConfig() - requester = CyberplusRequester(config) - hereurl = self.absolute_url() - amount = self.price + self.shippingFees - amount = amount.getValues()['taxed'] - amount = amount * 100 - amount = str(int(round(amount, 0))) - pptool = getToolByName(self, 'portal_photo_print') - transaction_id = pptool.getNextTransactionId() - - userLanguages = getPreferredLanguages(self) - for pref in userLanguages : - lang = pref.split('-')[0] - if lang in CYBERPLUS_LANGUAGES : - break - else : - lang = 'en' - - options = { 'amount': amount - ,'cancel_return_url' : '%s/paymentCancelHandler' % hereurl - ,'normal_return_url' : '%s/paymentManualResponseHandler' % hereurl - ,'automatic_response_url' :'%s/paymentAutoResponseHandler' % hereurl - ,'transaction_id' : transaction_id - ,'order_id' : self.getId() - ,'language' : lang - } - req = requester.generateRequest(options) - return req - - def _decodeCyberplusResponse(self, form) : - config = _getCyberplusConfig() - responder = CyberplusResponder(config) - response = responder.getResponse(form) - return response - - def _compareWithAutoResponse(self, manu) : - keys = manu.keys() - auto = self._paymentResponse - autoKeys = auto.keys() - if len(keys) != len(autoKeys) : - console.warn('Manual has not the same keys.\nauto: %r\nmanual: %r' % \ - (sorted(autoKeys), sorted(keys))) - else : - for k, v in manu.items() : - if not auto.has_key(k) : - console.warn('%r field only found in manual response.' % k) - else : - if v != auto[k] : - console.warn('data mismatch for %r\nauto: %r\nmanual: %r' % (k, auto[k], v)) - - def _checkOrderId(self, response) : - expected = self.getId() - assert expected == response['order_id'], \ - "Cyberplus response transaction_id doesn't match the order object:\n" \ - "expected: %s\n" \ - "found: %s" % (expected, response['transaction_id']) - - def _executeOrderWfTransition(self, response) : - if CyberplusResponder.transactionAccepted(response) : - wfaction = 'auto_accept_payment' - elif CyberplusResponder.transactionRefused(response) : - self.resetCopiesCounters() - wfaction = 'auto_refuse_payment' - elif CyberplusResponder.transactionCanceled(response) : - wfaction = 'auto_cancel_order' - else : - # transaction failed - wfaction = 'auto_transaction_failed' + member = mtool.getAuthenticatedMember() + mg = lambda name : member.getProperty(name, '') + billing = {'name' : member.getMemberFullName(nameBefore=0) + ,'address' : mg('billing_address') + ,'city' : mg('billing_city') + ,'zipcode' : mg('billing_zipcode') + ,'country' : mg('country') + ,'phone' : mg('phone') } + self.editBilling(**billing) + + sg = lambda name : cart._shippingInfo.get(name, '') + shipping = {'name' : sg('shipping_fullname') + ,'address' : sg('shipping_address') + ,'city' : sg('shipping_city') + ,'zipcode' : sg('shipping_zipcode') + ,'country' : sg('shipping_country')} + self.editShipping(**shipping) + + self.shippingFees = pptool.getShippingFeesFor(shippable=self) + + cart._confirmed = True + cart.pendingOrderPath = self.getPhysicalPath() + + security.declareProtected(ManagePrintOrders, 'resetCopiesCounters') + def resetCopiesCounters(self) : + pptool = getToolByName(self, 'portal_photo_print') + uidh = getToolByName(self, 'portal_uidhandler') + + for item in self.items : + photo = uidh.getObject(item['cmf_uid']) + counters = getattr(photo, COPIES_COUNTERS, None) + if counters : + counters.cancel(item['productReference'], + item['quantity']) - wtool = getToolByName(self, 'portal_workflow') - wf = wtool.getWorkflowById('order_workflow') - tdef = wf.transitions.get(wfaction) - wf._changeStateOf(self, tdef) - wtool._reindexWorkflowVariables(self) - - security.declarePublic('paymentAutoResponseHandler') - @postonly - def paymentAutoResponseHandler(self, REQUEST) : - """\ - Handle cyberplus payment auto response. - """ - response = self._decodeCyberplusResponse(REQUEST.form) - self._checkOrderId(response) - self._paymentResponse.update(response) - self._executeOrderWfTransition(response) - - @postonly - def paymentManualResponseHandler(self, REQUEST) : - """\ - Handle cyberplus payment manual response. - """ - response = self._decodeCyberplusResponse(REQUEST.form) - self._checkOrderId(response) - - autoResponse = self._paymentResponse - if not autoResponse : - console.warn('Manual response handled before auto response at %s' % '/'.join(self.getPhysicalPath())) - self._paymentResponse.update(response) - self._executeOrderWfTransition(response) - else : - self._compareWithAutoResponse(response) - - url = '%s?%s' % (self.absolute_url(), - make_query(portal_status_message=translate('Your payment is complete.', self).encode('utf-8')) - ) - return REQUEST.RESPONSE.redirect(url) - - @postonly - def paymentCancelHandler(self, REQUEST) : - """\ - Handle cyberplus cancel response. - This handler can be invoqued in two cases: - - the user cancel the payment form - - the payment transaction has been refused - """ - response = self._decodeCyberplusResponse(REQUEST.form) - self._checkOrderId(response) - - if self._paymentResponse : - # normaly, it happens when the transaction is refused by cyberplus. - self._compareWithAutoResponse(response) - - if CyberplusResponder.transactionRefused(response) : - if not self._paymentResponse : - console.warn('Manual response handled before auto response at %s' % '/'.join(self.getPhysicalPath())) - self._paymentResponse.update(response) - self._executeOrderWfTransition(response) - - msg = 'Your payment has been refused.' + def _initPayPalInterface(self) : + config = getPayPalConfig() + config['API_AUTHENTICATION_MODE'] = '3TOKEN' + ppi = PayPalInterface(**config) + return ppi + + + @staticmethod + def recordifyPPResp(response) : + d = {} + d['zopeTime'] = DateTime() + for k, v in response.raw.iteritems() : + if len(v) == 1 : + d[k] = v[0] + else : + d[k] = v + return d + + # paypal api + security.declareProtected(ModifyPortalContent, 'ppSetExpressCheckout') + def ppSetExpressCheckout(self) : + utool = getUtilityByInterfaceName('Products.CMFCore.interfaces.IURLTool') + mtool = getUtilityByInterfaceName('Products.CMFCore.interfaces.IMembershipTool') + portal_url = utool() + portal = utool.getPortalObject() + member = mtool.getAuthenticatedMember() + + options = {#'PAYMENTREQUEST_0_AMT' : '99.55', # todo + 'PAYMENTREQUEST_0_CURRENCYCODE' : 'EUR', + 'PAYMENTREQUEST_0_PAYMENTACTION' : 'Sale', + 'RETURNURL' : '%s/photoprint_order_confirm' % self.absolute_url(), + 'CANCELURL' : '%s/photoprint_order_cancel' % self.absolute_url(), + # 'CALLBACK' : TODO + 'ALLOWNOTE' : 0, # The buyer is unable to enter a note to the merchant. + 'HDRIMG' : '%s/logo.gif' % portal_url, + 'EMAIL' : member.getProperty('email'), + 'SOLUTIONTYPE' : 'Sole', # Buyer does not need to create a PayPal account to check out. This is referred to as PayPal Account Optional. + 'LANDINGPAGE' : 'Billing', # Non-PayPal account + 'BRANDNAME' : portal.getProperty('title'), + 'GIFTMESSAGEENABLE' : 0, + 'GIFTRECEIPTENABLE' : 0, + 'BUYEREMAILOPTINENABLE' : 0, # Do not enable buyer to provide email address. + 'NOSHIPPING' : 1, # PayPal does not display shipping address fields whatsoever. + # 'PAYMENTREQUEST_0_NOTIFYURL' : TODO + + 'PAYMENTREQUEST_0_SHIPTONAME' : self.billing['name'], + 'PAYMENTREQUEST_0_SHIPTOSTREET' : self.billing['address'], + 'PAYMENTREQUEST_0_SHIPTOCITY' : self.billing['city'], + 'PAYMENTREQUEST_0_SHIPTOZIP' : self.billing['zipcode'], + 'PAYMENTREQUEST_0_SHIPTOPHONENUM' : self.billing['phone'], + } + + quantitySum = reduce(lambda a, b : a['quantity'] + b['quantity'], self.items) + priceSum = reduce(lambda a, b : a['unit_price'] * a['quantity'] + b['unit_price'] * b['quantity'], self.items) + priceValues = priceSum.getValues() + total = round(priceValues['taxed'], 2) + basePrice = round(priceValues['value'], 2) + tax = round(total - basePrice, 2) + + options['L_PAYMENTREQUEST_0_NAME0'] = 'Commande realis photo ref. %s' % self.getId() + options['L_PAYMENTREQUEST_0_DESC0'] = 'Commande de %d tirages photo' % quantitySum + options['L_PAYMENTREQUEST_0_AMT0'] = total + # options['L_PAYMENTREQUEST_0_TAXAMT0'] = tax + # options['L_PAYMENTREQUEST_0_QTY%d' % n] = 1 + options['PAYMENTREQUEST_0_AMT'] = total - else : - self._executeOrderWfTransition(response) - msg = 'Your payment has been canceled. You will be able to pay later.' + ppi = self._initPayPalInterface() + response = ppi.set_express_checkout(**options) + response = PrintOrder.recordifyPPResp(response) + # self._paypalLog.append(response) + response['url'] = ppi.generate_express_checkout_redirect_url(response['TOKEN']) + console.info(options) + console.info(response) + return response + + security.declarePrivate('ppGetExpressCheckoutDetails') + def ppGetExpressCheckoutDetails(self, token) : + ppi = self._initPayPalInterface() + response = ppi.get_express_checkout_details(TOKEN=token) + response = Registration.recordifyPPResp(response) + self._paypalLog.append(response) + return response + + security.declarePrivate('ppDoExpressCheckoutPayment') + def ppDoExpressCheckoutPayment(self, token, payerid, amt) : + ppi = self._initPayPalInterface() + response = ppi.do_express_checkout_payment(PAYMENTREQUEST_0_PAYMENTACTION='Sale', + PAYMENTREQUEST_0_AMT=amt, + PAYMENTREQUEST_0_CURRENCYCODE='EUR', + TOKEN=token, + PAYERID=payerid) + response = Registration.recordifyPPResp(response) + self._paypalLog.append(response) + return response + + security.declareProtected(ModifyPortalContent, 'ppPay') + def ppPay(self, token, payerid): + # assure le paiement paypal en une passe : + # récupération des détails et validation de la transaction. + if not self.paid : + details = self.ppGetExpressCheckoutDetails(token) - url = '%s?%s' % (self.absolute_url(), - make_query(portal_status_message= \ - translate(msg, self).encode('utf-8')) - ) - return REQUEST.RESPONSE.redirect(url) - - - def getCustomerSummary(self) : - ' ' - return {'quantity':self.quantity, - 'price':self.price} - - + if payerid != details['PAYERID'] : + return False + + if details['ACK'] == 'Success' : + response = self.ppDoExpressCheckoutPayment(token, + payerid, + details['AMT']) + if response['ACK'] == 'Success' and \ + response['PAYMENTINFO_0_ACK'] == 'Success' and \ + response['PAYMENTINFO_0_PAYMENTSTATUS'] == 'Completed' : + self.paid = (DateTime(), 'paypal') + wtool = getUtilityByInterfaceName('Products.CMFCore.interfaces.IWorkflowTool') + wtool.doActionFor( self + , 'paypal_pay' + , wf_id='jma_registration_workflow' + , comments='Paiement par PayPal') + return True + return False + else : + return True + + security.declareProtected(ModifyPortalContent, 'ppCancel') + def ppCancel(self, token) : + details = self.ppGetExpressCheckoutDetails(token) + + security.declareProtected(ManagePortal, 'getPPLog') + def getPPLog(self) : + return self._paypalLog + + + + # security.declareProtected(View, 'getPaymentRequest') + # def getPaymentRequest(self) : + # config = _getCyberplusConfig() + # requester = CyberplusRequester(config) + # hereurl = self.absolute_url() + # amount = self.price + self.shippingFees + # amount = amount.getValues()['taxed'] + # amount = amount * 100 + # amount = str(int(round(amount, 0))) + # pptool = getToolByName(self, 'portal_photo_print') + # transaction_id = pptool.getNextTransactionId() + # + # userLanguages = getPreferredLanguages(self) + # for pref in userLanguages : + # lang = pref.split('-')[0] + # if lang in CYBERPLUS_LANGUAGES : + # break + # else : + # lang = 'en' + # + # options = { 'amount': amount + # ,'cancel_return_url' : '%s/paymentCancelHandler' % hereurl + # ,'normal_return_url' : '%s/paymentManualResponseHandler' % hereurl + # ,'automatic_response_url' :'%s/paymentAutoResponseHandler' % hereurl + # ,'transaction_id' : transaction_id + # ,'order_id' : self.getId() + # ,'language' : lang + # } + # req = requester.generateRequest(options) + # return req + # + # def _decodeCyberplusResponse(self, form) : + # config = _getCyberplusConfig() + # responder = CyberplusResponder(config) + # response = responder.getResponse(form) + # return response + # + # def _compareWithAutoResponse(self, manu) : + # keys = manu.keys() + # auto = self._paymentResponse + # autoKeys = auto.keys() + # if len(keys) != len(autoKeys) : + # console.warn('Manual has not the same keys.\nauto: %r\nmanual: %r' % \ + # (sorted(autoKeys), sorted(keys))) + # else : + # for k, v in manu.items() : + # if not auto.has_key(k) : + # console.warn('%r field only found in manual response.' % k) + # else : + # if v != auto[k] : + # console.warn('data mismatch for %r\nauto: %r\nmanual: %r' % (k, auto[k], v)) + # + # def _checkOrderId(self, response) : + # expected = self.getId() + # assert expected == response['order_id'], \ + # "Cyberplus response transaction_id doesn't match the order object:\n" \ + # "expected: %s\n" \ + # "found: %s" % (expected, response['transaction_id']) + + # def _executeOrderWfTransition(self, response) : + # if CyberplusResponder.transactionAccepted(response) : + # wfaction = 'auto_accept_payment' + # elif CyberplusResponder.transactionRefused(response) : + # self.resetCopiesCounters() + # wfaction = 'auto_refuse_payment' + # elif CyberplusResponder.transactionCanceled(response) : + # wfaction = 'auto_cancel_order' + # else : + # # transaction failed + # wfaction = 'auto_transaction_failed' + # + # wtool = getToolByName(self, 'portal_workflow') + # wf = wtool.getWorkflowById('order_workflow') + # tdef = wf.transitions.get(wfaction) + # wf._changeStateOf(self, tdef) + # wtool._reindexWorkflowVariables(self) + + # security.declarePublic('paymentAutoResponseHandler') + # @postonly + # def paymentAutoResponseHandler(self, REQUEST) : + # """\ + # Handle cyberplus payment auto response. + # """ + # response = self._decodeCyberplusResponse(REQUEST.form) + # self._checkOrderId(response) + # self._paymentResponse.update(response) + # self._executeOrderWfTransition(response) + # + # @postonly + # def paymentManualResponseHandler(self, REQUEST) : + # """\ + # Handle cyberplus payment manual response. + # """ + # response = self._decodeCyberplusResponse(REQUEST.form) + # self._checkOrderId(response) + # + # autoResponse = self._paymentResponse + # if not autoResponse : + # console.warn('Manual response handled before auto response at %s' % '/'.join(self.getPhysicalPath())) + # self._paymentResponse.update(response) + # self._executeOrderWfTransition(response) + # else : + # self._compareWithAutoResponse(response) + # + # url = '%s?%s' % (self.absolute_url(), + # make_query(portal_status_message=translate('Your payment is complete.', self).encode('utf-8')) + # ) + # return REQUEST.RESPONSE.redirect(url) + # + # @postonly + # def paymentCancelHandler(self, REQUEST) : + # """\ + # Handle cyberplus cancel response. + # This handler can be invoqued in two cases: + # - the user cancel the payment form + # - the payment transaction has been refused + # """ + # response = self._decodeCyberplusResponse(REQUEST.form) + # self._checkOrderId(response) + # + # if self._paymentResponse : + # # normaly, it happens when the transaction is refused by cyberplus. + # self._compareWithAutoResponse(response) + # + # + # if CyberplusResponder.transactionRefused(response) : + # if not self._paymentResponse : + # console.warn('Manual response handled before auto response at %s' % '/'.join(self.getPhysicalPath())) + # self._paymentResponse.update(response) + # self._executeOrderWfTransition(response) + # + # msg = 'Your payment has been refused.' + # + # else : + # self._executeOrderWfTransition(response) + # msg = 'Your payment has been canceled. You will be able to pay later.' + # + # url = '%s?%s' % (self.absolute_url(), + # make_query(portal_status_message= \ + # translate(msg, self).encode('utf-8')) + # ) + # return REQUEST.RESPONSE.redirect(url) + + + def getCustomerSummary(self) : + ' ' + return {'quantity':self.quantity, + 'price':self.price} + + InitializeClass(PrintOrder) PrintOrderFactory = Factory(PrintOrder) class CopiesCounters(Persistent, Implicit) : - def __init__(self): - self._mapping = PersistentMapping() - - def getBrowserId(self): - sdm = self.session_data_manager - bim = sdm.getBrowserIdManager() - browserId = bim.getBrowserId(create=1) - return browserId - - def _checkBrowserId(self, browserId) : - sdm = self.session_data_manager - sd = sdm.getSessionDataByKey(browserId) - return not not sd - - def __setitem__(self, reference, count) : - if not self._mapping.has_key(reference): - self._mapping[reference] = PersistentMapping() - self._mapping[reference]['pending'] = PersistentMapping() - self._mapping[reference]['confirmed'] = 0 - - globalCount = self[reference] - delta = count - globalCount - bid = self.getBrowserId() - if not self._mapping[reference]['pending'].has_key(bid) : - self._mapping[reference]['pending'][bid] = delta - else : - self._mapping[reference]['pending'][bid] += delta - - - def __getitem__(self, reference) : - item = self._mapping[reference] - globalCount = item['confirmed'] - - for browserId, count in item['pending'].items() : - if self._checkBrowserId(browserId) : - globalCount += count - else : - del self._mapping[reference]['pending'][browserId] + def __init__(self): + self._mapping = PersistentMapping() + + def getBrowserId(self): + sdm = self.session_data_manager + bim = sdm.getBrowserIdManager() + browserId = bim.getBrowserId(create=1) + return browserId + + def _checkBrowserId(self, browserId) : + sdm = self.session_data_manager + sd = sdm.getSessionDataByKey(browserId) + return not not sd + + def __setitem__(self, reference, count) : + if not self._mapping.has_key(reference): + self._mapping[reference] = PersistentMapping() + self._mapping[reference]['pending'] = PersistentMapping() + self._mapping[reference]['confirmed'] = 0 + + globalCount = self[reference] + delta = count - globalCount + bid = self.getBrowserId() + if not self._mapping[reference]['pending'].has_key(bid) : + self._mapping[reference]['pending'][bid] = delta + else : + self._mapping[reference]['pending'][bid] += delta + + + def __getitem__(self, reference) : + item = self._mapping[reference] + globalCount = item['confirmed'] + + for browserId, count in item['pending'].items() : + if self._checkBrowserId(browserId) : + globalCount += count + else : + del self._mapping[reference]['pending'][browserId] - return globalCount - - def get(self, reference, default=0) : - if self._mapping.has_key(reference) : - return self[reference] - else : - return default - - def getPendingCounter(self, reference) : - bid = self.getBrowserId() - if not self._checkBrowserId(bid) : - console.warn('BrowserId not found: %s' % bid) - return 0 + return globalCount + + def get(self, reference, default=0) : + if self._mapping.has_key(reference) : + return self[reference] + else : + return default + + def getPendingCounter(self, reference) : + bid = self.getBrowserId() + if not self._checkBrowserId(bid) : + console.warn('BrowserId not found: %s' % bid) + return 0 - count = self._mapping[reference]['pending'].get(bid, None) - if count is None : - console.warn('No pending data found for browserId %s' % bid) - return 0 - else : - return count - - def confirm(self, reference, quantity) : - pending = self.getPendingCounter(reference) - if pending != quantity : - console.warn('Pending quantity mismatch with the confirmed value: (%d, %d)' % (pending, quantity)) + count = self._mapping[reference]['pending'].get(bid, None) + if count is None : + console.warn('No pending data found for browserId %s' % bid) + return 0 + else : + return count + + def confirm(self, reference, quantity) : + pending = self.getPendingCounter(reference) + if pending != quantity : + console.warn('Pending quantity mismatch with the confirmed value: (%d, %d)' % (pending, quantity)) - browserId = self.getBrowserId() - if self._mapping[reference]['pending'].has_key(browserId) : - del self._mapping[reference]['pending'][browserId] - self._mapping[reference]['confirmed'] += quantity - - def cancel(self, reference, quantity) : - self._mapping[reference]['confirmed'] -= quantity - - def __str__(self): - return str(self._mapping) + browserId = self.getBrowserId() + if self._mapping[reference]['pending'].has_key(browserId) : + del self._mapping[reference]['pending'][browserId] + self._mapping[reference]['confirmed'] += quantity + + def cancel(self, reference, quantity) : + self._mapping[reference]['confirmed'] -= quantity + + def __str__(self): + return str(self._mapping) diff --git a/skins/order_view.py b/skins/order_view.py index 5ed50bf..308844c 100755 --- a/skins/order_view.py +++ b/skins/order_view.py @@ -20,8 +20,7 @@ options['wfhistory'] = wtool.getInfoFor(context, 'review_history', 'order_workfl toBePaid = wfstate == 'recorded' if toBePaid : - paymentRequest = context.getPaymentRequest() - options['paymentRequest'] = paymentRequest + options['checkout'] = context.ppSetExpressCheckout() if cart.locked and \ cart.pendingOrderPath == context.getPhysicalPath() : diff --git a/skins/order_view_template.pt b/skins/order_view_template.pt index f5876b7..7582159 100644 --- a/skins/order_view_template.pt +++ b/skins/order_view_template.pt @@ -145,10 +145,10 @@ - +
-
+