orders.py

# -*- coding: utf-8 -*-

'''
Copyright 2012-2019 eBay Inc.
Authored by: Tim Keefer
Licensed under CDDL 1.0
'''

from datetime import datetime, timedelta

from ebaysdk.trading import Connection as Trading
from ebaysdk.poller import parse_args, file_lock
from ebaysdk import log


class Storage(object):

    def set(self, order):
        data = [
            ("ID", order.OrderID),
            ("Status", order.OrderStatus),
            ("Seller Email", order.SellerEmail),
            ("Title", order.TransactionArray.Transaction[0].Item.Title),
            ("ItemID", order.TransactionArray.Transaction[0].Item.ItemID),
            ("QTY", order.TransactionArray.Transaction[0].QuantityPurchased),
            ("Payment Method", order.CheckoutStatus.PaymentMethod),
            ("Payment Date", getattr(order, 'PaidTime', 'Not Paid')),
            ("Total", (order.Total._currencyID + ' ' + order.Total.value))
        ]

        if order.TransactionArray.Transaction[0].get('Variation', None):
            data.append(
                ("SKU", order.TransactionArray.Transaction[0].Variation.SKU)),

        data.extend([
            ("Shipped Time", getattr(order, 'ShippedTime', 'Not Shipped')),
            ("Shipping Service", getattr(order, 'ShippingServiceSelected', 'N/A'))
        ])

        if order.ShippingDetails.get('ShipmentTrackingDetails', None):
            data.extend([
                ("Min Shipping Days",
                 order.ShippingDetails.ShippingServiceOptions.ShippingTimeMin),
                ("Max Shipping Days",
                 order.ShippingDetails.ShippingServiceOptions.ShippingTimeMax),
                ("Tracking", order.ShippingDetails.ShipmentTrackingDetails.ShipmentTrackingNumber),
                ("Carrier", order.ShippingDetails.ShipmentTrackingDetails.ShippingCarrierUsed),
                ("Cost", (order.ShippingDetails.ShippingServiceOptions.ShippingServiceCost._currencyID,
                          order.ShippingDetails.ShippingServiceOptions.ShippingServiceCost.value))
            ])

        values_array = map((lambda x: "%s=%s" % (x[0], x[1])), data)
        log.debug(", ".join(values_array))


class Poller(object):

    def __init__(self, opts, storage=None):
        self.opts = opts
        self.storage = storage

    def run(self):

        with file_lock("/tmp/.ebaysdk-poller-orders.lock"):
            log.debug("Started poller %s" % __file__)

            to_time = datetime.utcnow()  # - timedelta(days=4)

            from_time = to_time - timedelta(hours=self.opts.hours,
                                            minutes=self.opts.minutes)

            ebay_api = Trading(debug=self.opts.debug, config_file=self.opts.yaml,
                               appid=self.opts.appid, certid=self.opts.certid,
                               devid=self.opts.devid, siteid=self.opts.siteid,
                               warnings=False)

            ebay_api.build_request('GetOrders', {
                'DetailLevel': 'ReturnAll',
                'OrderRole': self.opts.OrderRole,
                'OrderStatus': self.opts.OrderStatus,
                'Pagination': {
                    'EntriesPerPage': 25,
                    'PageNumber': 1,
                },
                'ModTimeFrom': from_time.strftime('%Y-%m-%dT%H:%M:%S.000Z'),
                'ModTimeTo': to_time.strftime('%Y-%m-%dT%H:%M:%S.000Z'),
            }, None)

            for resp in ebay_api.pages():

                if resp.reply.OrderArray:

                    for order in resp.reply.OrderArray.Order:
                        if self.storage:
                            self.storage.set(order)
                        else:
                            log.debug("storage object not defined")
                else:
                    log.debug("no orders to process")


if __name__ == '__main__':
    (opts, args) = parse_args(
        "usage: python -m ebaysdk.poller.orders [options]")

    poller = Poller(opts, Storage())
    poller.run()