AI that transforms recruitment in the energy sector

# Education module — pattern applied to all 5 modules
# Return of -1 signals automatic discard to the orchestrator

def _education_module(education: dict | None) -> tuple[float, dict]:
    detail = {"score": 0, "weight": EDUCATION_WEIGHT}
    if not education:
        return 0.0, detail
    level  = education.get("level", "")
    status = education.get("status", "")
    if level == "primary" or (level == "secondary" and status != "complete"):
        return -1.0, detail  # discard: cannot be compensated
    score = 100 if status == "complete" else 60
    return score * EDUCATION_WEIGHT, {**detail, "score": score}

def calculate_score(data: dict, **params) -> tuple[int, str]:
    item = data["items"][0]
    llm_score = item.get("final_score", 3)
    if item.get("discarded") or _discard_by_params(item, params):
        return 0, discard_report(item)
    score_map = {1: 10, 2: 30, 3: 50, 4: 70, 5: 90}
    base = score_map[llm_score]
    base += _customer_service_bonus(item.get("experiences", []))
    base += _fast_food_bonus(item.get("experiences", []))
    scale = _map_to_5_scale(min(100, base))
    return scale, generate_report(base, scale, item)

# Mass sending with isolated partial failures
# One failed message does NOT cancel the entire campaign

@shared_task
def send_mass_campaign(campaign_id: int):
    campaign = Campaign.objects.get(id=campaign_id)
    contacts = set(campaign.contacts.all())
    for label in campaign.labels.all():
        contacts.update(label.contacts.all())

    service = TwilioService()
    for contact in contacts:
        campaign.refresh_from_db()         # check real-time cancellation
        if campaign.status == "cancelled":
            return
        try:
            msg = service.send_template(contact, campaign.template)
            MessageLog.objects.create(
                campaign=campaign, contact=contact,
                twilio_sid=msg.sid, status=msg.status or "queued"
            )
            campaign.sent += 1
        except TwilioRestException as exc:
            MessageLog.objects.create(
                campaign=campaign, contact=contact, status="failed",
                error_code=str(exc.code), error_msg=str(exc.msg)
            )
            campaign.failed += 1
        campaign.save()
        time.sleep(0.1)  # respect Twilio rate limit: ~10 msg/s
    campaign.status = "completed"
    campaign.completed_at = timezone.now()
    campaign.save()