Subversion Repositories SmartDukaan

#!/usr/bin/python
'''

@author: Rajveer
'''
import sys
import imaplib
import email
from shop2020.model.v1.order.impl import DataAccessors, DataService
from shop2020.model.v1.order.impl.DataService import Order
from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus

if __name__ == '__main__' and __package__ is None:
    import os
    sys.path.insert(0, os.getcwd())

from_user = 'cnc.center@shop2020.in'
from_pwd = '5h0p2o2o'
to = ['cnc.center@shop2020.in', "amit.sirohi@shop2020.in", "sandeep.sachdeva@shop2020.in", "parmod.kumar@shop2020.in"]

def process_store_price_approval(orderId):
    subject = str(orderId)
    user = 'cnc.center@shop2020.in'
    pwd = '5h0p2o2o'
    
    # connecting to the gmail imap server
    m = imaplib.IMAP4_SSL("imap.gmail.com")
    m.login(user,pwd)
    m.select("Inbox", True)  # use m.list() to get all the mailboxes
    
    # you could filter using the IMAP rules here (check http://www.example-code.com/csharp/imap-search-critera.asp)
    resp, items = m.search(None, 'SUBJECT', subject, 'UNKEYWORD', 'processed')
    items = items[0].split() # getting the mail ids
    
    for emailid in reversed(items):
        # fetching the mail, "`(RFC822)`" means "get the whole stuff", but you can ask for headers only, etc
        resp, data = m.fetch(emailid, "(RFC822)")
        email_body = data[0][1] # getting the mail content
        mail = email.message_from_string(email_body) # parsing the mail content to get a mail object
        for part in mail.walk():
            if part.get_content_type() == "multipart/alternative":
                continue
            btext = part.get_payload(decode=1)
            btext = btext.strip()
            if btext.lower().startswith('approved'):
                DataAccessors.verify_order(orderId)
            if btext.lower().startswith('approved'):
                DataAccessors.refund_order(orderId, "Automatically", "Pricing not approved by approving authority")

def main():
    DataService.initialize()
    #DataService.initialize('transaction', '192.168.190.114')
    orders = Order.query.filter(Order.status == OrderStatus.COD_VERIFICATION_PENDING).filter(Order.source == 2).all()
    if orders:
        for order in orders:
            process_store_price_approval(order.id)

if __name__ == '__main__':
    main()