2023-09-06 14:20:28 +02:00
|
|
|
import logging
|
2023-08-03 18:13:51 +02:00
|
|
|
from typing import Dict, Collection
|
2023-08-03 14:55:41 +02:00
|
|
|
|
2023-09-06 14:23:41 +02:00
|
|
|
from camisatoshi_wordpress_reports.constants import (
|
|
|
|
|
order_keys,
|
|
|
|
|
custom_meta_data_keys,
|
|
|
|
|
)
|
2023-08-03 18:13:51 +02:00
|
|
|
from camisatoshi_wordpress_reports.utils import safe_zero_division
|
2023-08-03 14:55:41 +02:00
|
|
|
|
|
|
|
|
|
2023-08-03 16:33:53 +02:00
|
|
|
class Order:
|
2023-08-03 14:55:41 +02:00
|
|
|
def __init__(self, raw_data: Dict):
|
|
|
|
|
self.raw_data = raw_data
|
|
|
|
|
|
|
|
|
|
def __getitem__(self, item):
|
|
|
|
|
return self.raw_data[item]
|
|
|
|
|
|
2023-08-03 16:22:20 +02:00
|
|
|
@property
|
|
|
|
|
def meta_data_entries(self):
|
2023-08-03 16:33:53 +02:00
|
|
|
return {
|
|
|
|
|
meta_data_entry["key"]: meta_data_entry["value"]
|
|
|
|
|
for meta_data_entry in self.raw_data[order_keys.meta_data]
|
|
|
|
|
}
|
2023-08-03 16:22:20 +02:00
|
|
|
|
2023-08-03 18:13:51 +02:00
|
|
|
def units_of_sku(self, sku: str) -> int:
|
|
|
|
|
units = 0
|
|
|
|
|
for line in self[order_keys.line_items]:
|
|
|
|
|
if line[order_keys.line_item_keys.sku] == sku:
|
|
|
|
|
units += line[order_keys.line_item_keys.quantity]
|
|
|
|
|
return units
|
|
|
|
|
|
|
|
|
|
def sales_of_sku(self, sku: str) -> float:
|
|
|
|
|
sales = 0
|
|
|
|
|
for line in self[order_keys.line_items]:
|
|
|
|
|
if line[order_keys.line_item_keys.sku] == sku:
|
|
|
|
|
sales += float(line[order_keys.line_item_keys.total])
|
|
|
|
|
return sales
|
|
|
|
|
|
|
|
|
|
def sats_received_for_sku(self, sku: str) -> float:
|
|
|
|
|
total_order_eur = float(self[order_keys.total])
|
|
|
|
|
eur_of_sku = self.sales_of_sku(sku)
|
|
|
|
|
|
2023-09-06 14:23:41 +02:00
|
|
|
monetary_weight_of_sku_in_order = safe_zero_division(
|
|
|
|
|
eur_of_sku, total_order_eur
|
|
|
|
|
)
|
2023-08-03 18:13:51 +02:00
|
|
|
total_order_sats_received = float(
|
|
|
|
|
self.meta_data_entries[custom_meta_data_keys.sats_received]
|
|
|
|
|
)
|
|
|
|
|
sats_received_for_sku = (
|
|
|
|
|
monetary_weight_of_sku_in_order * total_order_sats_received
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
return sats_received_for_sku
|
|
|
|
|
|
2023-08-03 14:58:26 +02:00
|
|
|
def contains_sku(self, sku: str) -> bool:
|
2023-08-03 16:33:53 +02:00
|
|
|
for item in self[order_keys.line_items]:
|
|
|
|
|
if item[order_keys.line_item_keys.sku] == sku:
|
2023-08-03 14:58:26 +02:00
|
|
|
return True
|
|
|
|
|
return False
|
|
|
|
|
|
2023-08-03 15:01:27 +02:00
|
|
|
def contains_meta_data_entry(self, meta_data_entry_key: str) -> bool:
|
2023-08-03 16:22:20 +02:00
|
|
|
if meta_data_entry_key in self.meta_data_entries.keys():
|
2023-08-03 15:01:27 +02:00
|
|
|
return True
|
|
|
|
|
return False
|
|
|
|
|
|
2023-08-03 16:22:20 +02:00
|
|
|
def is_settled_with_um(self):
|
2023-08-03 16:33:53 +02:00
|
|
|
is_settled = self.meta_data_entries.get(
|
2023-08-04 00:09:53 +02:00
|
|
|
custom_meta_data_keys.is_settled_um, None
|
2023-08-03 16:33:53 +02:00
|
|
|
)
|
2023-08-03 16:22:20 +02:00
|
|
|
|
|
|
|
|
return bool(is_settled)
|
|
|
|
|
|
2023-08-03 14:55:41 +02:00
|
|
|
@classmethod
|
|
|
|
|
def from_api_response(cls, raw_data) -> "Order":
|
|
|
|
|
return Order(raw_data)
|
2023-08-03 16:38:24 +02:00
|
|
|
|
|
|
|
|
|
|
|
|
|
class Orders:
|
|
|
|
|
def __init__(self, orders: Collection[Order]):
|
2023-08-03 16:50:40 +02:00
|
|
|
self._orders = orders
|
|
|
|
|
|
|
|
|
|
def __len__(self):
|
|
|
|
|
return len(self._orders)
|
|
|
|
|
|
2023-08-03 17:24:42 +02:00
|
|
|
def __iter__(self):
|
|
|
|
|
self._index = 0
|
|
|
|
|
return self
|
|
|
|
|
|
|
|
|
|
def __next__(self):
|
|
|
|
|
if self._index < len(self._orders):
|
|
|
|
|
next_order = self._orders[self._index]
|
|
|
|
|
self._index += 1
|
|
|
|
|
return next_order
|
|
|
|
|
raise StopIteration
|
|
|
|
|
|
2023-08-03 18:13:51 +02:00
|
|
|
def filter_orders_by_sku(self, sku: str) -> "Orders":
|
2023-08-03 16:50:40 +02:00
|
|
|
filtered_orders = []
|
|
|
|
|
|
2023-08-03 17:24:42 +02:00
|
|
|
for order in self:
|
2023-08-03 18:13:51 +02:00
|
|
|
if order.contains_sku(sku):
|
|
|
|
|
filtered_orders.append(order)
|
2023-08-03 16:50:40 +02:00
|
|
|
|
|
|
|
|
return Orders(filtered_orders)
|
|
|
|
|
|
|
|
|
|
def filter_orders_without_sats_received(self) -> "Orders":
|
|
|
|
|
orders_without_sats_received = []
|
|
|
|
|
|
2023-08-03 17:24:42 +02:00
|
|
|
for order in self:
|
2023-09-06 14:23:41 +02:00
|
|
|
if not order.contains_meta_data_entry(
|
|
|
|
|
custom_meta_data_keys.sats_received
|
|
|
|
|
):
|
2023-08-03 16:50:40 +02:00
|
|
|
orders_without_sats_received.append(order)
|
|
|
|
|
continue
|
|
|
|
|
|
|
|
|
|
return Orders(orders_without_sats_received)
|
|
|
|
|
|
|
|
|
|
def filter_unsettled_orders(self) -> "Orders":
|
|
|
|
|
unsettled_orders = []
|
|
|
|
|
|
2023-08-03 17:24:42 +02:00
|
|
|
for order in self:
|
2023-09-03 05:05:22 +02:00
|
|
|
if not order.is_settled_with_um():
|
2023-08-03 16:50:40 +02:00
|
|
|
unsettled_orders.append(order)
|
|
|
|
|
|
|
|
|
|
return Orders(unsettled_orders)
|
2023-09-05 11:47:38 +02:00
|
|
|
|
|
|
|
|
def filter_orders_by_metadata_value(self, key, value):
|
|
|
|
|
orders_with_metadata_value = []
|
|
|
|
|
|
|
|
|
|
for order in self:
|
2023-09-06 14:23:41 +02:00
|
|
|
if (
|
|
|
|
|
order.contains_meta_data_entry(key)
|
|
|
|
|
and order.meta_data_entries[key] == value
|
|
|
|
|
):
|
2023-09-05 11:47:38 +02:00
|
|
|
orders_with_metadata_value.append(order)
|
|
|
|
|
|
|
|
|
|
return Orders(orders_with_metadata_value)
|