phone_sel = PhoneSelector(phones, campaign.phone_selection) rot = RotationAssigner(accounts, campaign.rotation_strategy, campaign.rotation_weights, campaign.max_per_account) used_invoice_numbers: set = set() rows: List[CampaignRecipient] = [] plan = [] seq = 0 for r in recipient_rows: seq += 1 cr = CampaignRecipient( campaign_id=campaign.id, recipient_id=r.id, email=r.email, seq=seq, ) # generated values g = GeneratedValues() if var_cfg.get("invoice_date"): g.invoice_date = var_cfg["invoice_date"] else: g.invoice_date = date.today().isoformat() if var_cfg.get("due_date"): g.due_date = var_cfg["due_date"] else: g.due_date = (date.today() + timedelta(days=int(var_cfg.get("due_days", 14)))).isoformat() inv_num = "" tpl = tpl_seq.next_template() if tpl is None and templates: cr.status = "skipped" cr.last_error = "Template sequence exhausted (mode=stop)" body_uses_invoice = any("%RandomInvoiceNumber%" in (t.body_html + (t.body_text or "")) for t in templates) or (tpl and "%RandomInvoiceNumber%" in tpl.body_html) if body_uses_invoice or var_cfg.get("always_generate_invoice", True): inv_num = engine.generate_invoice_number(used_invoice_numbers) used_invoice_numbers.add(inv_num) cr.generated_invoice_number = inv_num g.invoice_number = inv_num if var_cfg.get("amount_enabled", True) or body_uses_invoice: g.amount = engine.generate_amount() cr.generated_amount = g.amount if var_cfg.get("shipping_enabled", True) or "%RandomShippingCharge%" in (tpl.body_html if tpl else ""): g.shipping = engine.generate_shipping() cr.generated_shipping = g.shipping subj = subj_sel.next_subject()