feat(campaigns): create 6 Listmonk source templates for deficiency segments
This commit is contained in:
justin
parent
b85be726b7
commit
73b03769a5
1 changed files with 256 additions and 0 deletions
256
scripts/create_deficiency_source_campaigns.py
Normal file
256
scripts/create_deficiency_source_campaigns.py
Normal file
|
|
@ -0,0 +1,256 @@
|
|||
#!/usr/bin/env python3
|
||||
"""Create the 6 Listmonk *source* campaigns for the deficiency-flag segments.
|
||||
|
||||
These are draft templates that build_trucking_campaigns.py clones for each
|
||||
timezone blast (subject + body + template_id are copied). They are created as
|
||||
DRAFTS (never scheduled) and live in the same Listmonk install.
|
||||
|
||||
After running, the script prints the `CAMPAIGN_*_ID` env lines to paste into the
|
||||
workers service env. Idempotent-ish: pass --dry-run to preview, and it skips a
|
||||
segment if a campaign with the same name already exists (prints its id instead).
|
||||
|
||||
Usage (inside the workers container on prod):
|
||||
python3 scripts/create_deficiency_source_campaigns.py [--dry-run]
|
||||
"""
|
||||
from __future__ import annotations
|
||||
|
||||
import argparse
|
||||
import sys
|
||||
|
||||
import build_trucking_campaigns as b # reuse lm_api + auth + segment defs
|
||||
|
||||
FROM_EMAIL = "Performance West <noreply@performancewest.net>"
|
||||
TEMPLATE_ID = 6 # same wrapper template as the MCS-150 source campaign
|
||||
PHONE = "(888) 411-0383"
|
||||
PHONE_TEL = "8884110383"
|
||||
|
||||
# Shared chrome (header + footer). The middle is segment-specific.
|
||||
_HEADER = (
|
||||
'<div style="font-family:-apple-system,system-ui,sans-serif;max-width:600px;margin:0 auto">'
|
||||
'<div style="background:#1a2744;padding:24px;text-align:center;border-radius:12px 12px 0 0">'
|
||||
'<img src="https://performancewest.net/images/logo.png" alt="Performance West" style="height:40px">'
|
||||
'</div>'
|
||||
'<div style="background:#fff;border:1px solid #e2e8f0;padding:32px;border-radius:0 0 12px 12px">'
|
||||
'<p style="font-size:15px;color:#374151;line-height:1.6">{{ .Subscriber.Attribs.company }},<br>'
|
||||
'DOT# {{ .Subscriber.Attribs.dot_number }}</p>'
|
||||
)
|
||||
|
||||
_FOOTER = (
|
||||
'<p style="font-size:14px;color:#64748b;line-height:1.6">Or call us directly at '
|
||||
f'<a href="tel:{PHONE_TEL}" style="color:#f97316;font-weight:600">{PHONE}</a>.</p>'
|
||||
'<p style="font-size:14px;color:#64748b">Performance West Inc.<br>DOT Compliance Services</p>'
|
||||
'</div>'
|
||||
'<div style="text-align:center;padding:16px;font-size:11px;color:#94a3b8">'
|
||||
'<a href="https://performancewest.net" style="color:#94a3b8">performancewest.net</a> · '
|
||||
f'{PHONE}</div>'
|
||||
'<div style="text-align:center;padding:0 16px 18px;font-size:11px;color:#94a3b8;line-height:1.7">'
|
||||
'Gotta hit a 10-100 and pull off this channel? '
|
||||
'<a href="{{ UnsubscribeURL }}" style="color:#94a3b8;text-decoration:underline">Unsubscribe here</a>.<br>'
|
||||
'Performance West Inc. · 525 Randall Ave Ste 100-1195, Cheyenne, WY 82001</div>'
|
||||
'</div>'
|
||||
)
|
||||
|
||||
|
||||
def _alert(color_border, color_text, lines_html):
|
||||
return (
|
||||
f'<div style="background:#fef2f2;border:2px solid {color_border};border-radius:10px;'
|
||||
f'padding:18px;margin:18px 0">{lines_html}</div>'
|
||||
)
|
||||
|
||||
|
||||
def _price_box(headline, sub):
|
||||
return (
|
||||
'<div style="background:#f0fdf4;border:2px solid #86efac;border-radius:10px;'
|
||||
'padding:20px;margin:20px 0;text-align:center">'
|
||||
f'<p style="font-size:18px;font-weight:700;color:#166534;margin:0 0 4px">{headline}</p>'
|
||||
f'<p style="font-size:14px;color:#15803d;margin:0">{sub}</p></div>'
|
||||
)
|
||||
|
||||
|
||||
def _cta(label):
|
||||
# Clicks land on the per-subscriber order page (resolved per row, incl.
|
||||
# per-state overrides) via the lp_link attrib, with UTM tracking.
|
||||
return (
|
||||
'<div style="text-align:center;margin:24px 0">'
|
||||
'<a href="{{ .Subscriber.Attribs.lp_link }}?dot={{ .Subscriber.Attribs.dot_number }}'
|
||||
'&utm_source=listmonk&utm_medium=email&utm_campaign=deficiency@TrackLink" '
|
||||
'style="display:inline-block;padding:14px 36px;background:#f97316;color:#fff;'
|
||||
f'font-weight:700;border-radius:8px;text-decoration:none;font-size:16px">{label} →</a></div>'
|
||||
)
|
||||
|
||||
|
||||
def _body(headline, intro, bullets, price_headline, price_sub, cta_label):
|
||||
bullet_html = "".join(f"<li>{x}</li>" for x in bullets)
|
||||
alert = _alert(
|
||||
"#fca5a5", "#991b1b",
|
||||
f'<h1 style="font-size:21px;color:#dc2626;margin:0 0 10px">{headline}</h1>'
|
||||
f'<p style="font-size:15px;color:#374151;line-height:1.6;margin:0 0 8px">{intro}</p>'
|
||||
f'<ul style="font-size:15px;color:#374151;line-height:1.8;margin:0">{bullet_html}</ul>'
|
||||
)
|
||||
reassure = (
|
||||
'<div style="background:#f8fafc;border:1px solid #e2e8f0;border-radius:8px;padding:16px;margin:20px 0">'
|
||||
'<p style="font-size:14px;color:#374151;margin:0 0 6px"><strong>Not tech savvy? No problem.</strong></p>'
|
||||
'<p style="font-size:13px;color:#64748b;margin:0;line-height:1.6">One simple form, from your phone or '
|
||||
'computer. No Login.gov, no government portals, no hours on hold. We handle the paperwork so you can get '
|
||||
'back to trucking and making money.</p></div>'
|
||||
)
|
||||
return _HEADER + alert + _price_box(price_headline, price_sub) + reassure + _cta(cta_label) + _FOOTER
|
||||
|
||||
|
||||
# ── Per-segment copy ────────────────────────────────────────────────────────
|
||||
SEGMENTS = {
|
||||
"for_hire_boc3": {
|
||||
"env": "CAMPAIGN_FOR_HIRE_ID",
|
||||
"name": "For-Hire Carrier — BOC-3 + UCR Required",
|
||||
"subject": "DOT# {{ .Subscriber.Attribs.dot_number }} - For-hire carriers must file BOC-3 & UCR",
|
||||
"headline": "You're operating for-hire without a BOC-3 process agent on file.",
|
||||
"intro": "Our records show you run for-hire authority but are missing required filings. Without them you face:",
|
||||
"bullets": [
|
||||
"<strong>Authority suspension</strong> by the FMCSA",
|
||||
"UCR penalties of <strong>up to $5,000</strong>",
|
||||
"Loads refused at the scale and by brokers",
|
||||
],
|
||||
"price_headline": "We file your BOC-3 process agents nationwide.",
|
||||
"price_sub": "Plus UCR registration if you need it. We handle everything.",
|
||||
"cta": "Fix My BOC-3 & UCR",
|
||||
},
|
||||
"irp_ifta": {
|
||||
"env": "CAMPAIGN_IRP_IFTA_ID",
|
||||
"name": "Interstate Carrier — IRP / IFTA Registration",
|
||||
"subject": "DOT# {{ .Subscriber.Attribs.dot_number }} - You need IRP plates & an IFTA license",
|
||||
"headline": "Running interstate without IRP apportioned plates or an IFTA license?",
|
||||
"intro": "If you cross state lines over 26,000 lbs you must be registered. Missing it means:",
|
||||
"bullets": [
|
||||
"<strong>Fines and citations</strong> at every weigh station",
|
||||
"Trip permits that cost far more than apportioned plates",
|
||||
"Quarterly IFTA penalties and interest",
|
||||
],
|
||||
"price_headline": "We set up your IRP plates and IFTA license.",
|
||||
"price_sub": "Base-state registration done for you, no DMV lines.",
|
||||
"cta": "Get IRP & IFTA Done",
|
||||
},
|
||||
"intrastate_authority": {
|
||||
"env": "CAMPAIGN_INTRASTATE_ID",
|
||||
"name": "Intrastate Operating Authority Required",
|
||||
"subject": "DOT# {{ .Subscriber.Attribs.dot_number }} - Your state requires intrastate authority",
|
||||
"headline": "You're hauling inside your state without intrastate operating authority.",
|
||||
"intro": "Most states require their own authority on top of your USDOT. Without it:",
|
||||
"bullets": [
|
||||
"<strong>Out-of-service orders</strong> at state inspections",
|
||||
"Citations and impound risk on intrastate loads",
|
||||
"Insurance filings rejected by the state",
|
||||
],
|
||||
"price_headline": "We file your state intrastate authority.",
|
||||
"price_sub": "Application, insurance filings, and BOC-3 if required.",
|
||||
"cta": "Get My State Authority",
|
||||
},
|
||||
"state_weight_tax": {
|
||||
"env": "CAMPAIGN_WEIGHT_TAX_ID",
|
||||
"name": "State Weight-Distance Tax Registration",
|
||||
"subject": "DOT# {{ .Subscriber.Attribs.dot_number }} - You owe a state weight-distance tax",
|
||||
"headline": "You operate in a state with a weight-distance / highway-use tax.",
|
||||
"intro": "OR, NY, KY, NM and CT charge a per-mile tax that requires its own account. Skipping it means:",
|
||||
"bullets": [
|
||||
"<strong>Back taxes plus penalties and interest</strong>",
|
||||
"Permits pulled at the border",
|
||||
"Audit exposure on every mile run unregistered",
|
||||
],
|
||||
"price_headline": "We register your weight-distance tax account.",
|
||||
"price_sub": "OR WMT, NY HUT, KY KYU, NM WDT, or CT HUF, done for you.",
|
||||
"cta": "Register My Tax Account",
|
||||
},
|
||||
"state_emissions": {
|
||||
"env": "CAMPAIGN_EMISSIONS_ID",
|
||||
"name": "State Clean-Truck / Emissions Compliance",
|
||||
"subject": "DOT# {{ .Subscriber.Attribs.dot_number }} - New clean-truck rules apply to you",
|
||||
"headline": "Your state has new clean-truck / emissions reporting you may be missing.",
|
||||
"intro": "CA, NY, CO, MD, NJ and MA now require fleet emissions registration. Non-compliance means:",
|
||||
"bullets": [
|
||||
"<strong>Registration holds</strong> on affected vehicles",
|
||||
"Penalties under state clean-truck (ACT) rules",
|
||||
"Loss of access to ports and regulated lanes",
|
||||
],
|
||||
"price_headline": "We handle your clean-truck / emissions registration.",
|
||||
"price_sub": "CARB, ACT and state reporting set up for your fleet.",
|
||||
"cta": "Check My Emissions Status",
|
||||
},
|
||||
"hazmat": {
|
||||
"env": "CAMPAIGN_HAZMAT_ID",
|
||||
"name": "Hazmat PHMSA Registration Required",
|
||||
"subject": "DOT# {{ .Subscriber.Attribs.dot_number }} - Hazmat haulers must register with PHMSA",
|
||||
"headline": "You haul hazardous materials but may be missing PHMSA registration.",
|
||||
"intro": "Carriers of placardable hazmat must register annually with PHMSA. Without it:",
|
||||
"bullets": [
|
||||
"<strong>Civil penalties up to $89,678 per violation</strong>",
|
||||
"Loads refused by shippers who verify your registration",
|
||||
"Out-of-service orders for unregistered hazmat transport",
|
||||
],
|
||||
"price_headline": "We file your PHMSA hazmat registration.",
|
||||
"price_sub": "Annual registration handled, government fee billed at cost.",
|
||||
"cta": "Register My Hazmat",
|
||||
},
|
||||
}
|
||||
|
||||
|
||||
def find_existing(name: str) -> int | None:
|
||||
try:
|
||||
res = b.lm_api("/campaigns?query=" + name.replace(" ", "+") + "&per_page=100")
|
||||
for c in res.get("data", {}).get("results", []):
|
||||
if c.get("name") == name:
|
||||
return c["id"]
|
||||
except Exception:
|
||||
pass
|
||||
return None
|
||||
|
||||
|
||||
def create_draft(seg_key: str, cfg: dict, dry: bool) -> int | None:
|
||||
existing = find_existing(cfg["name"])
|
||||
if existing:
|
||||
print(f" [{seg_key}] already exists -> id {existing} (skipping create)")
|
||||
return existing
|
||||
body = _body(cfg["headline"], cfg["intro"], cfg["bullets"],
|
||||
cfg["price_headline"], cfg["price_sub"], cfg["cta"])
|
||||
if dry:
|
||||
print(f" [{seg_key}] DRY-RUN would create '{cfg['name']}' (body {len(body)} chars)")
|
||||
return None
|
||||
payload = {
|
||||
"name": cfg["name"],
|
||||
"subject": cfg["subject"],
|
||||
"lists": [1], # placeholder list; clones override with the real per-TZ list
|
||||
"from_email": FROM_EMAIL,
|
||||
"type": "regular",
|
||||
"content_type": "html",
|
||||
"body": body,
|
||||
"template_id": TEMPLATE_ID,
|
||||
"tags": ["trucking", "deficiency", "source"],
|
||||
"messenger": "email",
|
||||
}
|
||||
res = b.lm_api("/campaigns", payload, "POST")
|
||||
cid = res["data"]["id"]
|
||||
print(f" [{seg_key}] created '{cfg['name']}' -> id {cid}")
|
||||
return cid
|
||||
|
||||
|
||||
def main() -> int:
|
||||
ap = argparse.ArgumentParser()
|
||||
ap.add_argument("--dry-run", action="store_true")
|
||||
args = ap.parse_args()
|
||||
|
||||
print(f"Listmonk: {b.LISTMONK_URL}")
|
||||
print(f"Creating {len(SEGMENTS)} deficiency source campaigns "
|
||||
f"({'DRY-RUN' if args.dry_run else 'LIVE'}):\n")
|
||||
env_lines = []
|
||||
for key, cfg in SEGMENTS.items():
|
||||
cid = create_draft(key, cfg, args.dry_run)
|
||||
if cid:
|
||||
env_lines.append(f"{cfg['env']}={cid}")
|
||||
|
||||
if env_lines:
|
||||
print("\n=== Add these to the workers service environment ===")
|
||||
for line in env_lines:
|
||||
print(line)
|
||||
return 0
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
sys.exit(main())
|
||||
Loading…
Add table
Add a link
Reference in a new issue