"""SQL queries for populate passthru_processed table."""

SELECT_PT_TEMP_DATA_SQL = """
SELECT
  psds.statement_detail_id, psds.date, psds.upc, psds.cd, psds.track_id,
  psds.qty, psds.trans_type, psds.original_price
FROM accountingflat.passthru_sales_detail psds
INNER JOIN accountingflat.passthru_detail pd
 ON psds.statement_id = pd.statement_id
LIMIT {row_count} OFFSET {offset};
"""

SELECT_VENDORS_SQL = """
SELECT
  v.vendor_id,
  r.upc
FROM art_relations.vendor v,
  art_relations.artist_info a, art_relations.releases r
WHERE r.upc IN ({upcs}) AND a.artist_id = r. artist_id
  AND v.vendor_id = a.vendor_id;
"""

SELECT_VENDORS_EXCHANGE_RATE_SQL = """
SELECT vcs.vendor_id, ex.currency_to_id AS payout_currency_id,
  ex.exchange_rate AS fx_adjusted_exchange_rate
FROM  art_relations.currency_exchange_rates ex
INNER JOIN
  (SELECT MAX(id), vendor_id, currency_id FROM art_relations.vendor_contract vc
      WHERE vc.vendor_id IN ({vendors_ids})
      AND cont_end > CURDATE() AND cont_start < CURDATE()
      GROUP BY vc.vendor_id) vcs
ON ex.period_id = {period_id} AND ex.currency_to_id = vcs.currency_id;
"""