| Line 15... |
Line 15... |
| 15 |
import sys
|
15 |
import sys
|
| 16 |
|
16 |
|
| 17 |
from thrift.Thrift import TException
|
17 |
from thrift.Thrift import TException
|
| 18 |
import traceback
|
18 |
import traceback
|
| 19 |
from shop2020.thriftpy.logistics.ttypes import PickUpType
|
19 |
from shop2020.thriftpy.logistics.ttypes import PickUpType
|
| 20 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderType
|
20 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderType, OrderSource
|
| 21 |
|
21 |
|
| 22 |
if __name__ == '__main__' and __package__ is None:
|
22 |
if __name__ == '__main__' and __package__ is None:
|
| 23 |
import os
|
23 |
import os
|
| 24 |
sys.path.insert(0, os.getcwd())
|
24 |
sys.path.insert(0, os.getcwd())
|
| 25 |
|
25 |
|
| Line 100... |
Line 100... |
| 100 |
parser.error("Invalid OrderType. Allowed values are B2B, B2C and B2Cbulk")
|
100 |
parser.error("Invalid OrderType. Allowed values are B2B, B2C and B2Cbulk")
|
| 101 |
|
101 |
|
| 102 |
DataService.initialize(db_hostname=options.hostname, echoOn=True)
|
102 |
DataService.initialize(db_hostname=options.hostname, echoOn=True)
|
| 103 |
transaction = DataAccessors.get_transaction(options.txn_id)
|
103 |
transaction = DataAccessors.get_transaction(options.txn_id)
|
| 104 |
if(options.cod):
|
104 |
if(options.cod):
|
| 105 |
DataAccessors.change_transaction_status(options.txn_id, TransactionStatus.COD_IN_PROCESS, "COD payment awaited", PickUpType.COURIER, orderTypeInteger)
|
105 |
DataAccessors.change_transaction_status(options.txn_id, TransactionStatus.COD_IN_PROCESS, "COD payment awaited", PickUpType.COURIER, orderTypeInteger, OrderSource.WEBSITE)
|
| 106 |
else:
|
106 |
else:
|
| 107 |
DataAccessors.change_transaction_status(options.txn_id, TransactionStatus.AUTHORIZED, "Payment received for the order", PickUpType.COURIER, orderTypeInteger)
|
107 |
DataAccessors.change_transaction_status(options.txn_id, TransactionStatus.AUTHORIZED, "Payment received for the order", PickUpType.COURIER, orderTypeInteger, OrderSource.WEBSITE)
|
| 108 |
|
108 |
|
| 109 |
DataAccessors.enqueue_transaction_info_email(options.txn_id)
|
109 |
DataAccessors.enqueue_transaction_info_email(options.txn_id)
|
| 110 |
|
110 |
|
| 111 |
user_service_client = UserClient()
|
111 |
user_service_client = UserClient()
|
| 112 |
reset_cart(transaction, user_service_client)
|
112 |
reset_cart(transaction, user_service_client)
|