267 lines
12 KiB
Python
267 lines
12 KiB
Python
#!/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 os
|
|
import sys
|
|
|
|
# Allow both supported invocation styles:
|
|
# python -m scripts.create_deficiency_source_campaigns
|
|
# python3 scripts/create_deficiency_source_campaigns.py
|
|
ROOT = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
|
|
if ROOT not in sys.path:
|
|
sys.path.insert(0, ROOT)
|
|
|
|
from scripts 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
|
|
SOURCE_LIST_ID = 8 # same placeholder list used by the MCS-150/inactive source drafts
|
|
REPLY_TO = "info@performancewest.net"
|
|
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": [SOURCE_LIST_ID], # 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",
|
|
"headers": [{"name": "Reply-To", "value": REPLY_TO}],
|
|
}
|
|
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())
|