Check whether discounts and refunds ate your sales

from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http, notify

STORE = "your-store.myshopify.com"

def gql(query, variables=None):
    resp = http.post(f"https://{STORE}/admin/api/2025-07/graphql.json",
                     headers={"X-Shopify-Access-Token": credentials.connection("shopify", "store")},
                     json={"query": query, "variables": variables or {}})
    resp.raise_for_status()
    return resp.json()["data"]

THRESHOLD = 0.15
QUERY = """query($q: String!) { orders(first: 250, query: $q) { nodes { name
  subtotalPriceSet { shopMoney { amount } } totalDiscountsSet { shopMoney { amount } }
  totalRefundedSet { shopMoney { amount } } } } }"""

@on_trigger
def run(event):
    day = date.today() - timedelta(days=1)
    orders = gql(QUERY, {"q": f"created_at:>={day} created_at:<{date.today()}"})["orders"]["nodes"]
    amt = lambda o, k: float(o[k]["shopMoney"]["amount"])
    leak = lambda o: amt(o, "totalDiscountsSet") + amt(o, "totalRefundedSet")
    gross = sum(amt(o, "subtotalPriceSet") + amt(o, "totalDiscountsSet") for o in orders)
    lost = sum(leak(o) for o in orders)
    ratio = lost / gross if gross else 0
    if ratio <= THRESHOLD:
        return {"ratio": round(ratio, 3)}
    worst = sorted(orders, key=leak, reverse=True)[:5]
    notify.slack(f"Discounts + refunds were {ratio:.0%} of gross sales on {day} ({lost:,.2f} of {gross:,.2f})\n" +
                 "\n".join(f"• {o['name']}: {leak(o):,.2f}" for o in worst), channel="#store")
    return {"ratio": round(ratio, 3)}