source: WAeUP_SRP/base/skins/waeup_epayment/upgradePayments.py @ 2891

## Script (Python) "upgradePayments.py"
##bind container=container
##bind context=context
##bind namespace=
##bind script=script
##bind subpath=traverse_subpath
##parameters=
##title=
##
# $Id: upgradePayments.py 2886 2007-12-08 16:19:06Z joachim $
"""
"""
try:
    from Products.zdb import set_trace
except:
    def set_trace():
        pass

mtool = context.portal_membership
member = mtool.getAuthenticatedMember()
if str(member) not in ('admin','joachim'):
    return


import logging
import DateTime
logger = logging.getLogger('Skins.upgradePayments')
from Products.AdvancedQuery import Eq, Between, Le,In
aq_portal = context.portal_catalog_real.evalAdvancedQuery
aq_student = context.students_catalog.evalAdvancedQuery
students_folder = context.portal_url.getPortalObject().campus.students

request = context.REQUEST
session = request.SESSION
response = request.RESPONSE
setheader = request.RESPONSE.setHeader
def rwrite(s):
    response.setHeader('Content-type','text/html; charset=ISO-8859-15')
    response.write("%s<br>\n\r" % s)

count = 1
d = {}
l = []
sum_total = 0.0
log_after = 100
logger.info("start")
query = Eq('portal_type','Payment')
payments = aq_portal(query,sortSpecs=('container_path',))
total = len(payments)
logger.info("found %d payments" % total)
sid = "xxx"
#set_trace()
count = 1
commit_after = 5
commit_count = 0

set_trace()
for payment_brain in payments:
    payment = payment_brain.getObject()
    payment['updatePayment']()
    # student_id = payment.getPath().split('/')[-3]
    # student_brain = context.students_catalog.getRecordByKey(student_id)
    # if student_brain is None:
    #     logger.info("student %s not in students_catalog" % student_id)
    #     continue
    # d = {}
    # doc = payment.getObject().getContent()
    # d['key'] = payment.getId
    # d['amount'] = doc.amount
    # d['description'] = d['type_description'] = doc.type_description
    # subject = ''
    # if doc.type_description.startswith('School'):
    #     subject = 'schoolfee'
    # sp = doc.type_description.rfind('/')
    # d['session_id'] = doc.type_description[sp-2:sp]
    # d['subject'] = subject # zb. schoolfee
    # d['target'] = "%s" % (student_brain.course)  # faculty departmen course
    # while True:
    #     if doc.resp_code == "SC":
    #         p_type = "sc"
    #         p_status = "paid"
    #         break
    #     if doc.resp_code == "00":
    #         p_type = "onl"
    #         p_status = "paid"
    #         break
    #     p_type = "ONL"
    #     p_status = "open"
    #     break
    # d['key'] = payment.getId
    # d['type'] = p_type  # scratch card
    # d['status'] = p_status
    # d['resp_approved_amount'] = getattr(doc,'resp_approved_amount',None)
    # d['resp_pay_reference'] = doc.resp_pay_reference
    # d['resp_desc'] = doc.resp_desc
    # d['order_id'] = doc.order_id
    # d['resp_code'] = doc.resp_code
    # d['resp_card_num'] = doc.resp_card_num
    # d['date'] = getattr(doc,'date',None)
    # d['resp_date'] = getattr(doc,'resp_date',None)
    # doc.edit(mapping = d)
    # msg = " ".join(["%s: %s" % (key,value) for key,value in d.items()])
    # rwrite(msg)
    logger.info('upgraded student %s payment %s' % (student_id,d['key']))
    if not count % commit_after:
        logger.info("committing %d total %d" % (commit_after,count))
        commit_count += 1
        # if not commit_count % 2:
        #     break
    count += 1
logger.info("%d of %d upgraded" % (count,total))