"""Find encoding order discrepancies."""

from src.connection import snowflake as connection
from src.sql.encoding_order_discrepancies import SQL_ENCODING_ORDER


def run(start_date, end_date):
    """Find encoding order discrepancies."""
    records = connection.query(SQL_ENCODING_ORDER.format(start_date, end_date))
    if records.rowcount:
        return False, format_message(records)
    return True, None


def format_message(records):
    """Format error message from records."""
    messages = []
    for row in records:
        messages.append(
            f"ENCODING_ORDER_ID: {row['ENCODING_ORDER_ID']}, "
            f"encoding_order_detail_total: {row['EO_UPCS_COUNT']}, "
            f"encoding_queue_detail_total: {row['EQ_UPCS_COUNT']}, "
            f"created_by: {row['CREATED_BY']}, "
            f"UPC_LIST: {row['UPC_LIST']}"
        )
    return "\n".join(messages)