in cqrs/services/orderinfo/main.py [0:0]
def order_get():
json_data = request.get_json()
customer_id, order_id = None, None
invalid_fields = []
for key in json_data.keys():
if key == 'customer_id':
customer_id = json_data[key]
elif key == 'order_id':
order_id = json_data[key]
else:
invalid_fields.append(key)
if customer_id is None or order_id is None:
return error500()
query = ds_client.query(kind='OrderInformationCQRS')
query.add_filter('customer_id', '=', customer_id)
query.add_filter('order_id', '=', order_id)
resp = None
for result in query.fetch(): # This should return a single entity.
resp = {
'order_id': result['order_id'],
'customer_id': result['customer_id'],
'product_id': result['product_id'],
'product_name': result['product_name'],
'number': result['number'],
'unit_price': result['unit_price'],
'total_price': result['total_price'],
'order_date': result['order_date'],
}
break
if resp is None:
resp = {'message': 'The order does not exist.'}
return resp, 200