Spaces:

Ninad077
/

Alerter

Running

App Files Files Community

Ninad077 commited on Sep 17, 2024

Commit

70d47eb

verified ·

1 Parent(s): 47cb35c

Upload 3 files

Browse files

Files changed (3) hide show

app.py +6 -1
query_seller_sale.py +58 -0
seller.py +204 -0

app.py CHANGED Viewed

@@ -63,7 +63,8 @@ menu_options = [
     {"label": "External users", "icon": "📊", "description": "Schedule an email with BigQuery data"},
     {"label": "Recon checking", "icon": "📊", "description": "Schedule an email with BigQuery data"},
     {"label": "Manual BQ upload", "icon": "📊", "description": "Schedule an email with BigQuery data"},
-    {"label": "Invoice splitter", "icon": "📊", "description": "Schedule an email with BigQuery data"}
 ]
 # Create the custom option menu
@@ -398,5 +399,9 @@ elif selected_option == "Invoice splitter":
     with open('splitter.py') as file:
         exec(file.read())

     {"label": "External users", "icon": "📊", "description": "Schedule an email with BigQuery data"},
     {"label": "Recon checking", "icon": "📊", "description": "Schedule an email with BigQuery data"},
     {"label": "Manual BQ upload", "icon": "📊", "description": "Schedule an email with BigQuery data"},
+    {"label": "Invoice splitter", "icon": "📊", "description": "Schedule an email with BigQuery data"},
+    {"label": "Seller sale validation", "icon": "📊", "description": "Schedule an email with BigQuery data"}
 ]
 # Create the custom option menu
     with open('splitter.py') as file:
         exec(file.read())
+elif selected_option == "Seller sale validation":
+    with open('seller.py') as file:
+        exec(file.read())

query_seller_sale.py ADDED Viewed

	@@ -0,0 +1,58 @@

+# query_seller_sale.py
+queries = {
+    "query": """
+    select
+        *,
+        (seller_sale_cc - tds_cc - tcs_cc) as seller_net_cc,
+        round((seller_sale_cc - tds_cc - tcs_cc - seller_net_collection),2) as net_diff_cc,
+        Concat(bag_id,",")as conccat,
+        COUNT(bag_cc) as comment,
+        concat(company_id,'_',segement_code, '_', settlement_model_code, '_', order_type) as ledger_name
+    from
+    (
+        select
+        company_id,
+        company_name,
+        ordering_channel,
+        segement_code,
+        sales_channel,
+        settlement_model,
+        settlement_model_code,
+        order_type,
+        recon_status,
+        fiscal_Year,
+        bag_id,
+        settlement_type,
+        Concat(bag_id,settlement_type) as bag_cc ,
+        mrp,
+        seller_discounts,
+        store_discount_amount,
+        bca,
+        vog,
+        tds_on_bca,
+        tcs_on_vog,
+        seller_fees,
+        seller_tender_value,
+        seller_net_collection,
+        mrp - seller_discounts -store_discount_amount as bca_cc,
+        bca - (mrp - seller_discounts -store_discount_amount) as diff_bca_cc,
+        round((mrp - seller_discounts -store_discount_amount)*100/(100 +product_gst_perc),2) as vog_cc,
+        vog - (round((mrp - seller_discounts -store_discount_amount)*100/(100 +product_gst_perc),2)) as diff_vog_cc,
+        CASE
+        WHEN segement_code = 'FY' or segement_code = 'UN' THEN (mrp - seller_discounts -store_discount_amount)*0.01
+        ELSE 0
+        END as tds_cc,
+        CASE
+        WHEN segement_code = 'FY' or segement_code = 'UN' THEN (round((mrp - seller_discounts -store_discount_amount)*100/(100 +product_gst_perc),2))*0.005
+        ELSE 0
+        END as tcs_cc,
+        (mrp - seller_discounts -store_discount_amount - seller_tender_value + seller_fees) as seller_sale_cc
+    from
+        `fynd-db.finance_recon_tool_asia.09_seller_net_collection_daily`
+    where
+        expected_payout_date between "2024-09-03"
+        and "2024-09-09"
+    ) as A
+    group by all
+    """
+}

seller.py ADDED Viewed

	@@ -0,0 +1,204 @@

+from google.cloud import bigquery
+import functions_framework
+from query_seller_sale import queries
+from google.oauth2 import service_account
+import json
+import requests
+import streamlit as st
+import pyperclip
+from ap import send_message_via_webhook, Webhook_urls
+import pandas as pd
+import io
+import time
+# Dropdown for channels/members
+# webhook_url = list(Webhook_urls.keys())
+html_subject = """
+<html>
+<head>
+<style>
+    .button {
+        display: inline-block;
+        padding: 10px 20px;
+        border-radius: 12px;
+        background: linear-gradient(to bottom, #f8f9fa, #e0e0e0);
+        box-shadow:
+            0 6px 12px rgba(0, 0, 0, 0.3),
+            0 8px 16px rgba(0, 0, 0, 0.2),
+            inset 0 -2px 4px rgba(255, 255, 255, 0.6);
+        text-align: center;
+        position: relative;
+        transform: translateY(4px);
+        transition: transform 0.2s ease-in-out, box-shadow 0.2s ease-in-out;
+        cursor: pointer;
+        user-select: none;
+    }
+    .button:hover {
+        box-shadow:
+            0 8px 16px rgba(0, 0, 0, 0.3),
+            0 12px 24px rgba(0, 0, 0, 0.2);
+        transform: translateY(2px);
+    }
+    .button:active {
+        box-shadow:
+            0 4px 8px rgba(0, 0, 0, 0.3),
+            0 6px 12px rgba(0, 0, 0, 0.2);
+        transform: translateY(0);
+    }
+    .progress-bar {
+        height: 20px; /* Adjusted thickness */
+        width: 100%;
+        background: linear-gradient(to bottom, #f8f9fa, #e0e0e0);
+        border-radius: 12px;
+        position: relative;
+        overflow: hidden;
+    }
+    .progress-bar span {
+        display: block;
+        height: 100%;
+        width: 0%;
+        background: linear-gradient(to right, #ff0000, #ff4d4d); /* Red gradient */
+        transition: width 0.3s ease;
+    }
+</style>
+</head>
+</html>
+"""
+st.markdown(html_subject, unsafe_allow_html=True)
+# selection = st.multiselect("", webhook_url)
+def check_duplicates(credentials_file):
+    """Check for duplicates using BigQuery with the provided credentials file."""
+    results = {}
+    credentials = service_account.Credentials.from_service_account_info(json.loads(credentials_file))
+    client = bigquery.Client(credentials=credentials, project=credentials.project_id)
+    query = queries["query"]  # Access the query string from the dictionary
+    # Show a loading spinner
+    with st.spinner(":red[Performing seller sale validation...]"):
+        # Create a custom progress bar
+        progress_bar = st.empty()
+        progress_bar.markdown(
+            """
+            <div class="progress-bar">
+                <span id="progress"></span>
+            </div>
+            """, unsafe_allow_html=True
+        )
+        try:
+            query_job = client.query(query)
+            # Simulate loading progress
+            for percent_complete in range(0, 101, 10):
+                time.sleep(0.1)  # Simulate work being done
+                progress_bar.markdown(
+                    f"""
+                    <div class="progress-bar">
+                        <span style="width: {percent_complete}%;"></span>
+                    </div>
+                    """, unsafe_allow_html=True
+                )
+            df = query_job.result().to_dataframe()
+            st.write("", df)
+        except Exception as e:
+            st.error(f"An error occurred: {e}")
+            return results
+    if not df.empty:
+        results["Query Result"] = df
+    return results
+# Streamlit UI
+html_subject = """
+    <html>
+    <head>
+    <style>
+        .button {
+            display: inline-block;
+            padding: 10px 20px;
+            border-radius: 12px;
+            background: linear-gradient(to bottom, #f8f9fa, #e0e0e0);
+            box-shadow:
+                0 6px 12px rgba(0, 0, 0, 0.3),
+                0 8px 16px rgba(0, 0, 0, 0.2),
+                inset 0 -2px 4px rgba(255, 255, 255, 0.6);
+            text-align: center;
+            position: relative;
+            transform: translateY(4px);
+            transition: transform 0.2s ease-in-out, box-shadow 0.2s ease-in-out;
+            cursor: pointer;
+            user-select: none;
+        }
+        .button:hover {
+            box-shadow:
+                0 8px 16px rgba(0, 0, 0, 0.3),
+                0 12px 24px rgba(0, 0, 0, 0.2);
+            transform: translateY(2px);
+        }
+        .button:active {
+            box-shadow:
+                0 4px 8px rgba(0, 0, 0, 0.3),
+                0 6px 12px rgba(0, 0, 0, 0.2);
+            transform: translateY(0);
+        }
+    </style>
+    </head>
+    <body>
+        <div class="button">
+            <h3 style="
+                font-size: 20px;
+                color: #ffffff;
+                background-image: linear-gradient(to right, #800000, #ff0000, #ffdab9);
+                background-clip: text;
+                -webkit-background-clip: text;
+                text-fill-color: transparent;
+                -webkit-text-fill-color: transparent;
+                margin: 0;
+                text-shadow: 0 2px 5px rgba(0, 0, 0, 0.4);
+            ">Upload service a/c credentials</h3>
+        </div>
+    </body>
+    </html>
+    """
+st.markdown(html_subject, unsafe_allow_html=True)
+# Upload credentials file
+credentials_file = st.file_uploader("", type="json")
+if credentials_file is not None:
+    # Read the credentials file
+    credentials_data = credentials_file.read().decode("utf-8")
+    # Check for duplicates
+    results = check_duplicates(credentials_data)
+    if "Query Result" in results:
+        df = results["Query Result"]
+        # Download buttons
+        csv = df.to_csv(index=False)
+        excel = io.BytesIO()
+        with pd.ExcelWriter(excel, engine='openpyxl') as writer:
+            df.to_excel(writer, index=False)
+        excel.seek(0)
+        col1, col2 = st.columns([0.125, 0.5])
+        with col1:
+            st.download_button(
+                label=":red[Download CSV]",
+                data=csv,
+                file_name="seller_sale_recon.csv",
+                mime="text/csv"
+            )
+        with col2:
+            st.download_button(
+                label=":red[Download Excel]",
+                data=excel,
+                file_name="seller_sale_recon.xlsx",
+                mime="application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"
+        )