asdf
This commit is contained in:
parent
45c589d225
commit
c9b57f00ea
@ -94,7 +94,7 @@ class PricingService:
|
|||||||
|
|
||||||
def cron_load_prices(self, file: File = None):
|
def cron_load_prices(self, file: File = None):
|
||||||
file_content = self.get_pricing_export_content(file)
|
file_content = self.get_pricing_export_content(file)
|
||||||
self.tcgplayer_service.load_tcgplayer_cards(file)
|
self.tcgplayer_service.load_tcgplayer_cards(file_content)
|
||||||
self.load_pricing_csv_content_to_db(file_content)
|
self.load_pricing_csv_content_to_db(file_content)
|
||||||
|
|
||||||
def get_all_prices_for_products(self, product_ids: List[str]) -> Dict[str, Dict[str, float]]:
|
def get_all_prices_for_products(self, product_ids: List[str]) -> Dict[str, Dict[str, float]]:
|
||||||
|
@ -499,16 +499,10 @@ class TCGPlayerService:
|
|||||||
except SQLAlchemyError as e:
|
except SQLAlchemyError as e:
|
||||||
raise RuntimeError(f"Failed to retrieve group IDs: {str(e)}")
|
raise RuntimeError(f"Failed to retrieve group IDs: {str(e)}")
|
||||||
|
|
||||||
def load_tcgplayer_cards(self) -> File:
|
def load_tcgplayer_cards(self, file_content):
|
||||||
try:
|
try:
|
||||||
# Get pricing export
|
|
||||||
export_csv_file = self.get_pricing_export_for_all_products()
|
|
||||||
export_csv = self.file_service.get_file_content(export_csv_file.id)
|
|
||||||
|
|
||||||
# load to card tcgplayer
|
# load to card tcgplayer
|
||||||
self.load_export_csv_to_card_tcgplayer(export_csv, export_csv_file.id)
|
self.load_export_csv_to_card_tcgplayer(file_content)
|
||||||
|
|
||||||
return export_csv_file
|
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"Failed to load prices: {e}")
|
logger.error(f"Failed to load prices: {e}")
|
||||||
|
Loading…
x
Reference in New Issue
Block a user