MySociety\TheyWorkForYou\Divisions

Complexity

Total Complexity

92

Size/Duplication

Total Lines	750
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	0

22 Methods

Rating	Name	Duplication	Size	Complexity
A	getParliamentDivisionDetails()	0	10	1
A	getRecentDebatesWithDivisions()	0	47	5
A	getRecentDivisionsForPolicies()	0	25	3
A	getMostRecentDivisionDate()	0	15	3
C	getRecentDivisions()	0	64	15
A	generateSummary()	0	27	6
A	getRecentMemberDivisions()	0	17	2
D	_division_data()	0	115	14
A	getDivisionByGid()	0	11	2
A	__construct()	0	5	1
A	getMemberDivisionsForPolicy()	0	17	2
B	constructVoteDescription()	0	32	9
A	constructYesNoVoteDescription()	0	9	2
A	getDivisionResults()	0	11	2
A	getAllMemberDivisionsByPolicy()	0	3	1
A	getDivisionResultsForMember()	0	20	2
A	keyToVoteAnalysisUrl()	0	28	3
B	getBasicDivisionDetails()	0	54	7
B	getSpeechesForDivision()	0	74	5
A	divisionUrlFromGid()	0	13	2
A	divisionsByPolicy()	0	28	4
A	getDivisionDetails()	0	2	1

<?php
/**
 * Policy Positions
 *
 * @package TheyWorkForYou
 */

namespace MySociety\TheyWorkForYou;

class Divisions {
    /**
     * Member
     */

    private $member;

    /**
     * DB handle
     */
    private $db;

    private $positions;
    private $policies;

    /**
     * Constructor
     *
     * @param Member   $member   The member to get positions for.
     */

    public function __construct(?Member $member = null) {
        $this->member = $member;
        $this->positions = null;
        $this->policies = new Policies();
        $this->db = new \ParlDB();
    }

    public static function getMostRecentDivisionDate() {
        $db = new \ParlDB();
        $q = $db->query(
            "SELECT policy_id, max(division_date) as recent
            FROM policydivisionlink
                JOIN divisions USING(division_id)
            GROUP BY policy_id"
        );

        $policy_maxes = [];
        foreach ($q as $row) {
            $policy_maxes[$row['policy_id']] = $row['recent'];
        }
        $policy_maxes['latest'] = $policy_maxes ? max(array_values($policy_maxes)) : '';
        return $policy_maxes;
    }

    /**
     * @param  int              $number  Number of divisions to return. Optional.
     * @param  string|string[]  $houses  House name (eg: "commons") or array of
     *                                   house names. Optional.
     */
    public function getRecentDivisions($number = 20, $houses = null) {
        $select = '';
        $order = 'ORDER BY division_date DESC, division_number DESC';
        $limit = 'LIMIT :count';
        $params = [
            ':count' => $number,
        ];

        $where = [];
        if ($houses) {
            if (is_string($houses)) {
                $houses = [ $houses ];
            }
            $where[] = 'house IN ("' . implode('", "', $houses) . '")';
        }
        if (!$houses || in_array('senedd', $houses)) {

It seems like $houses can also be of type string; however, parameter $haystack of in_array() does only seem to accept array, maybe add an additional type check?

            if (LANGUAGE == 'cy') {

The condition MySociety\TheyWorkForYou\LANGUAGE == 'cy' is always false.

                $where[] = "divisions.division_id NOT LIKE '%-en-%'";
            } else {
                $where[] = "divisions.division_id NOT LIKE '%-cy-%'";
            }
        }
        $where = 'WHERE ' . join(' AND ', $where);

        if ($this->member) {
            $select = "SELECT divisions.*, vote FROM divisions
                LEFT JOIN persondivisionvotes ON divisions.division_id=persondivisionvotes.division_id AND person_id=:person_id";
            $params[':person_id'] = $this->member->person_id;
        } else {
            $select = "SELECT * FROM divisions";
        }

        $q = $this->db->query(
            sprintf("%s %s %s %s", $select, $where, $order, $limit),
            $params
        );

        $divisions = [];
        foreach ($q as $division) {
            $data = $this->getParliamentDivisionDetails($division);

            $mp_vote = '';
            if (array_key_exists('vote', $division)) {
                if ($division['vote'] == 'aye') {
                    $mp_vote = 'voted in favour';
                } elseif ($division['vote'] == 'tellaye') {
                    $mp_vote = 'voted (as a teller) in favour';
                } elseif ($division['vote'] == 'no') {
                    $mp_vote = 'voted against';
                } elseif ($division['vote'] == 'tellno') {
                    $mp_vote = 'voted (as a teller) against';
                } elseif ($division['vote'] == 'absent') {
                    $mp_vote = ' was absent';
                } elseif ($division['vote'] == 'both') {
                    $mp_vote = ' abstained';
                }
            }
            $data['mp_vote'] = $mp_vote;
            $house = Utility\House::division_house_name_to_number($division['house']);
            $data['members'] = \MySociety\TheyWorkForYou\Utility\House::house_to_members($house);
            $divisions[] = $data;
        }

        return ['divisions' => $divisions];
    }

    /**
     * @param  int              $number  Number of divisions to return. Optional.
     * @param  int|int[]        $majors  Major types (e.g. 1) or array of
     *                                   major types. Optional.
     */
    public function getRecentDebatesWithDivisions($number = 20, $majors = null) {
        global $hansardmajors;

        if (!is_array($majors)) {
            $majors = [$majors];
        }

        $where = '';
        if (count($majors) > 0) {
            $where = 'AND h.major IN (' . implode(', ', $majors) . ')';
        }

        # Fetch any division speech, its subsection gid for the link, and
        # section/subsection bodies to construct a debate title
        $q = $this->db->query(
            "SELECT min(eps.body) as section_body, min(epss.body) as subsection_body,
                min(ss.gid) as debate_gid, min(h.gid) AS gid, min(h.hdate) as hdate,
                min(h.major) as major, count(h.gid) AS c
            FROM hansard h, hansard ss, epobject eps, epobject epss
            WHERE h.section_id = eps.epobject_id
                AND h.subsection_id = epss.epobject_id
                AND h.subsection_id = ss.epobject_id
                AND h.htype=14
            $where
            GROUP BY h.subsection_id
            ORDER BY h.hdate DESC, h.hpos DESC
            LIMIT :count",
            [':count' => $number]
        );

        $debates = [];
        foreach ($q as $debate) {
            $debate_gid = fix_gid_from_db($debate['debate_gid']);
            $anchor = '';
            if ($debate['c'] == 1) {
                $anchor = '#g' . gid_to_anchor(fix_gid_from_db($debate['gid']));
            }
            $url = new Url($hansardmajors[$debate['major']]['page']);
            $url->insert(['gid' => $debate_gid]);
            $debates[] = [
                'url' => $url->generate() . $anchor,
                'title' => "$debate[section_body] : $debate[subsection_body]",
                'date' => $debate['hdate'],
            ];
        }

        return $debates;
    }

    public function getRecentDivisionsForPolicies($policies, $number = 20) {
        $args = [':number' => $number];

        $quoted = [];
        foreach ($policies as $policy) {
            $quoted[] = $this->db->quote($policy);
        }
        $policies_str = implode(',', $quoted);

        $q = $this->db->query(
            "SELECT divisions.*
            FROM policydivisionlink
                JOIN divisions USING(division_id)
            WHERE policy_id in ($policies_str)
            GROUP BY division_id
            ORDER by division_date DESC LIMIT :number",
            $args
        );

        $divisions = [];
        foreach ($q as $row) {
            $divisions[] = $this->getParliamentDivisionDetails($row);
        }

        return $divisions;
    }

    /**
     *
     * Get a list of division votes related to a policy
     *
     * Returns an array with one key ( the policyID ) containing a hash
     * with a policy_id key and a divisions key which contains an array
     * with details of all the divisions.
     *
     * Each division is a hash with the following fields:
     *    division_id, date, vote, gid, url, text, strong
     *
     * @param int|null $policyId The ID of the policy to get divisions for
     */

    public function getMemberDivisionsForPolicy($policyID = null) {
        $where_extra = '';
        $args = [':person_id' => $this->member->person_id];
        if ($policyID) {
            $where_extra = 'AND policy_id = :policy_id';
            $args[':policy_id'] = $policyID;
        }
        $q = $this->db->query(
            "SELECT policy_id, division_id, division_title, yes_text, no_text, division_date, division_number, vote, gid, strength, alignment
            FROM policydivisionlink JOIN persondivisionvotes USING(division_id)
                JOIN divisions USING(division_id)
            WHERE person_id = :person_id AND direction <> 'abstention' $where_extra
            ORDER by policy_id, division_date DESC",
            $args
        );
        # possibly add another query here to get related policies that use the same votes
        return $this->divisionsByPolicy($q);
    }
    public function getDivisionByGid($gid) {
        $args = [
            ':gid' => $gid,
        ];
        $q = $this->db->query("SELECT * FROM divisions WHERE gid = :gid", $args)->first();

        if (!$q) {
            return false;
        }

        return $this->_division_data($q);
    }

    public function getDivisionResults($division_id) {
        $args = [
            ':division_id' => $division_id,
        ];
        $q = $this->db->query("SELECT * FROM divisions WHERE division_id = :division_id", $args)->first();

        if (!$q) {
            return false;
        }

        return $this->_division_data($q);

    }

    private function _division_data($row) {

        $details = $this->getParliamentDivisionDetails($row);

        $house = $row['house'];
        $args['division_id'] = $row['division_id'];

$args was never initialized. Although not strictly required by PHP, it is generally a good practice to add $args = array(); before regardless.

        $args['division_date'] = $row['division_date'];
        $args['house'] = \MySociety\TheyWorkForYou\Utility\House::division_house_name_to_number($house);

        $q = $this->db->query(
            "SELECT pdv.person_id, vote, proxy, title, given_name, family_name, lordofname, party
            FROM persondivisionvotes AS pdv JOIN person_names AS pn ON (pdv.person_id = pn.person_id)
            JOIN member AS m ON (pdv.person_id = m.person_id)
            WHERE division_id = :division_id
            AND house = :house AND entered_house <= :division_date AND left_house >= :division_date
            AND start_date <= :division_date AND end_date >= :division_date
            ORDER by family_name",
            $args
        );

        $votes = [
            'yes_votes' => [],
            'no_votes' => [],
            'absent_votes' => [],
            'both_votes' => [],
        ];

        $party_breakdown = [
            'yes_votes' => [],
            'no_votes' => [],
            'absent_votes' => [],
            'both_votes' => [],
        ];

        # Sort Lords specially
        $data = $q->fetchAll();
        if ($args['house'] == HOUSE_TYPE_LORDS) {
            uasort($data, 'by_peer_name');
        }

        foreach ($data as $vote) {
            $detail = [
                'person_id' => $vote['person_id'],
                'name' => ucfirst(member_full_name(
                    $args['house'],
                    $vote['title'],
                    $vote['given_name'],
                    $vote['family_name'],
                    $vote['lordofname']
                )),
                'party' => $vote['party'],
                'proxy' => false,
                'teller' => false,
            ];

            if (strpos($vote['vote'], 'tell') !== false) {
                $detail['teller'] = true;
            }

            if ($vote['proxy']) {
                $q = $this->db->query(
                    "SELECT title, given_name, family_name, lordofname
                    FROM person_names AS pn
                    WHERE person_id = :person_id
                    AND start_date <= :division_date AND end_date >= :division_date",
                    [ ':person_id' => $vote['proxy'], ':division_date' => $row['division_date'] ]
                )->first();
                $detail['proxy'] = ucfirst(member_full_name(
                    HOUSE_TYPE_COMMONS,
                    $q['title'],
                    $q['given_name'],
                    $q['family_name'],
                    $q['lordofname']
                ));
            }

            if ($vote['vote'] == 'aye' or $vote['vote'] == 'tellaye') {
                $votes['yes_votes'][] = $detail;
                @$party_breakdown['yes_votes'][$detail['party']]++;
            } elseif ($vote['vote'] == 'no' or $vote['vote'] == 'tellno') {
                $votes['no_votes'][] = $detail;
                @$party_breakdown['no_votes'][$detail['party']]++;
            } elseif ($vote['vote'] == 'absent') {
                $votes['absent_votes'][] = $detail;
                @$party_breakdown['absent_votes'][$detail['party']]++;
            } elseif ($vote['vote'] == 'both') {
                $votes['both_votes'][] = $detail;
                @$party_breakdown['both_votes'][$detail['party']]++;
            }
        }

        foreach ($votes as $vote => $count) { // array('yes_votes', 'no_votes', 'absent_votes', 'both_votes') as $vote) {
            $votes[$vote . '_by_party'] = $votes[$vote];
            usort($votes[$vote . '_by_party'], function ($a, $b) {
                return $a['party'] > $b['party'];
            });
        }

        foreach ($party_breakdown as $vote => $parties) {
            $summary = [];
            foreach ($parties as $party => $count) {
                array_push($summary, "$party: $count");
            }

            sort($summary);
            $party_breakdown[$vote] = implode(', ', $summary);
        }

        $details = array_merge($details, $votes);
        $details['party_breakdown'] = $party_breakdown;
        $details['members'] = \MySociety\TheyWorkForYou\Utility\House::house_to_members($args['house']);
        $details['house'] = $house;
        $details['house_number'] = $args['house'];

        return $details;
    }

    public function getDivisionResultsForMember($division_id, $person_id) {
        $args = [
            ':division_id' => $division_id,
            ':person_id' => $person_id,
        ];
        $q = $this->db->query(
            "SELECT division_id, division_title, yes_text, no_text, division_date, division_number, gid, vote
            FROM divisions JOIN persondivisionvotes USING(division_id)
            WHERE division_id = :division_id AND person_id = :person_id",
            $args
        )->first();

        // if the vote was before or after the MP was in Parliament
        // then there won't be a row
        if (!$q) {
            return false;
        }

        $details = $this->getDivisionDetails($q);
        return $details;
    }

    public function generateSummary($votes) {
        $max = $votes['max'];
        $min = $votes['min'];

        $actions = [
            $votes['for'] . ' ' . make_plural('vote', $votes['for']) . ' for',
            $votes['against'] . ' ' . make_plural('vote', $votes['against']) . ' against',
        ];

        if ($votes['agreements_for']) {
            $actions[] = $votes['agreements_for'] . ' ' . make_plural('agreement', $votes['agreements_for']) . ' for';
        }

        if ($votes['agreements_against']) {
            $actions[] = $votes['agreements_against'] . ' ' . make_plural('agreement', $votes['agreements_against']) . ' against';
        }

        if ($votes['both']) {
            $actions[] = $votes['both'] . ' ' . make_plural('abstention', $votes['both']);
        }
        if ($votes['absent']) {
            $actions[] = $votes['absent'] . ' ' . make_plural('absence', $votes['absent']);
        }
        if ($max == $min) {
            return join(', ', $actions) . ', in ' . $max;
        } else {
            return join(', ', $actions) . ', between ' . $min . '&ndash;' . $max;
        }
    }

    /**
     *
     * Get all the divisions a member has voted in keyed by policy
     *
     * Returns an array with keys for each policyID, each of these contains
     * the same structure as getMemberDivisionsForPolicy
     *
     */

    public function getAllMemberDivisionsByPolicy() {
        $policies = $this->getMemberDivisionsForPolicy();
        return Utility\Shuffle::keyValue($policies);
    }


    /**
     * Get the last n votes for a member
     *
     * @param $number int - How many divisions to return. Defaults to 20
     * @param $context string - The context of the page the results are being presented in.
     *    This affects the summary details and can either be 'Parliament' in which case the
     *    overall vote for all MPs is returned, plus additional information on how the MP passed
     *    in to the constructor voted, or the default of 'MP' which is just the vote of the
     *    MP passed in to the constructor.
     *
     * Returns an array of divisions
     */
    public function getRecentMemberDivisions($number = 20) {
        $args = [':person_id' => $this->member->person_id, ':number' => $number];
        $q = $this->db->query(
            "SELECT *
            FROM persondivisionvotes
                JOIN divisions USING(division_id)
            WHERE person_id = :person_id
            ORDER by division_date DESC, division_number DESC, division_id DESC LIMIT :number",
            $args
        );

        $divisions = [];
        foreach ($q as $row) {
            $divisions[] = $this->getDivisionDetails($row);
        }

        return $divisions;
    }

    private function constructYesNoVoteDescription($direction, $title, $short_text) {
        $text = ' ' ;
        if ($short_text) {
            $text .= sprintf(gettext('voted %s'), $short_text);
        } else {
            $text .= sprintf(gettext('voted %s on <em>%s</em>'), $direction, $title);
        }

        return $text;
    }

    private function constructVoteDescription($vote, $yes_text, $no_text, $division_title) {
        /*
         * for most post 2010 votes we have nice single sentence summaries of
         * what voting for or against means so we use that if it's there, however
         * we don't have anything nice for people being absent or for pre 2010
         * votes so we need to generate some text using the title of the division
         */

        switch (strtolower($vote)) {
            case 'yes':
            case 'aye':
                $description = $this->constructYesNoVoteDescription('yes', $division_title, $yes_text);
                break;
            case 'no':
                $description = $this->constructYesNoVoteDescription('no', $division_title, $no_text);
                break;
            case 'absent':
                $description = ' was absent for a vote on <em>' . $division_title . '</em>';
                break;
            case 'both':
                $description = ' abstained on a vote on <em>' . $division_title . '</em>';
                break;
            case 'tellyes':
            case 'tellno':
            case 'tellaye':
                $description = ' acted as teller for a vote on <em>' . $division_title . '</em>';
                break;
            default:
                $description = $division_title;
        }

        return $description;
    }

    private function getBasicDivisionDetails($row, $vote) {
        $yes_text = $row['yes_text'];
        $no_text = $row['no_text'];

        $division = [
            'division_id' => $row['division_id'],
            'date' => $row['division_date'],
            'gid' => fix_gid_from_db($row['gid']),
            'number' => $row['division_number'],
            'text' => $this->constructVoteDescription($vote, $yes_text, $no_text, $row['division_title']),
            'has_description' => $yes_text && $no_text,
            'vote' => $vote,
        ];

        if ($row['gid']) {
            $division['debate_url'] = $this->divisionUrlFromGid($row['gid']);
        }

        if (isset($row['division_id'])) {
            $division['analysis_url'] = $this->keyToVoteAnalysisUrl($row['division_id']);
        }

        # Policy-related information

        # So one option is just to query for it here
        # we want to add an array of policies aside the current policy
        # and if they have the same or different direction as thie current division
        # in the row

        # fetch related policies from database
        $q = $this->db->query(
            "SELECT policy_id, direction, strength
            FROM policydivisionlink
            WHERE division_id = :division_id",
            [':division_id' => $row['division_id']]
        );
        $division['related_policies'] = [];

        $policy_lookup = $this->policies->getPolicies();
        foreach ($q as $policy) {
            $division['related_policies'][] = [
                'policy_id' => $policy['policy_id'],
                'policy_title' => preg_replace('#</?a[^>]*>#', '', $policy_lookup[$policy['policy_id']]),
                'direction' => $policy['direction'],
                'strong' => strtolower($policy["strength"]) === "strong",
            ];
        }

        // If we have a member, fetch speeches made during the same debate
        if ($this->member && $row['gid']) {
            $division['speeches'] = $this->getSpeechesForDivision($row['gid'], $this->member->person_id);
        }

        return $division;
    }

    private function getDivisionDetails($row) {
        return $this->getBasicDivisionDetails($row, $row['vote']);
    }

    private function getParliamentDivisionDetails($row) {
        $division = $this->getBasicDivisionDetails($row, $row['majority_vote']);

        $division['division_title'] = $row['division_title'];
        $division['for'] = $row['yes_total'];
        $division['against'] = $row['no_total'];
        $division['both'] = $row['both_total'];
        $division['absent'] = $row['absent_total'];

        return $division;
    }

    private function divisionsByPolicy($q) {
        $policies = [];

        # iterate through each division, and adds it to an array of policies
        # if there is only one policy being queried, it will be an array of 1
        foreach ($q as $row) {
            $policy_id = $row['policy_id'];

            # if this policy hasn't come up yet, create the key for it
            if (!array_key_exists($policy_id, $policies)) {
                $policies[$policy_id] = [
                    'policy_id' => $policy_id,
                    'divisions' => [],
                ];
                $policies[$policy_id]['desc'] = $this->policies->getPolicies()[$policy_id];
                $policies[$policy_id]['header'] = $this->policies->getPolicyDetails($policy_id);
                if ($this->positions) {
                    $policies[$policy_id]['position'] = $this->positions->positionsById[$policy_id];
                }
            }


            $division = $this->getDivisionDetails($row);

            $policies[$policy_id]['divisions'][] = $division;
        };

        return $policies;
    }

    private function divisionUrlFromGid($gid) {
        global $hansardmajors;

        $gid = get_canonical_gid($gid);

        $q = $this->db->query("SELECT gid, major FROM hansard WHERE epobject_id = ( SELECT subsection_id FROM hansard WHERE gid = :gid )", [ ':gid' => $gid ])->first();
        if (!$q) {
            return '';
        }
        $parent_gid = fix_gid_from_db($q['gid']);
        $url = new Url($hansardmajors[$q['major']]['page']);
        $url->insert(['gid' => $parent_gid]);
        return $url->generate() . '#g' . gid_to_anchor(fix_gid_from_db($gid));
    }

    /**
     * Get speeches made by an MP in the same debate section as a division
     *
     * @param string $division_gid The GID of the division
     * @param int $person_id The person ID of the MP
     * @return array Array of speech data with gid, body, and URL
     */
    public function getSpeechesForDivision(string $division_gid, int $person_id): array {
        global $hansardmajors;

        // Get the division's hansard details to find the section/subsection
        $q = $this->db->query(
            "SELECT section_id, subsection_id, major, hdate FROM hansard WHERE gid = :gid AND htype = 14",
            [':gid' => get_canonical_gid($division_gid)]
        )->first();

        if (!$q) {
            return [];
        }

        $subsection_id = $q['subsection_id'];
        $major = $q['major'];
        $division_date = $q['hdate'];

        // Get the subsection GID for URL construction
        $subsection_q = $this->db->query(
            "SELECT gid FROM hansard WHERE epobject_id = :subsection_id",
            [':subsection_id' => $subsection_id]
        )->first();

        if ($subsection_q) {
            $subsection_gid = fix_gid_from_db($subsection_q['gid']);
        } else {
            // subsection isn't present
            return [];
        }

        // Find speeches by the MP in the same subsection on the same date
        // We look for htype=12 (speeches) by this person in the same subsection
        $speeches_query = $this->db->query(
            "SELECT h.gid, h.hpos, e.body, h.htime
             FROM hansard h
             JOIN epobject e ON h.epobject_id = e.epobject_id
             WHERE h.person_id = :person_id 
             AND h.subsection_id = :subsection_id
             AND h.htype = 12
             AND h.hdate = :hdate
             ORDER BY h.hpos ASC",
            [
                ':person_id' => $person_id,
                ':subsection_id' => $subsection_id,
                ':hdate' => $division_date,
            ]
        );

        $speeches = [];
        foreach ($speeches_query as $speech) {
            $speech_gid = fix_gid_from_db($speech['gid']);

            // Construct the URL to the speech
            $url = new Url($hansardmajors[$major]['page']);
            $url->insert(['gid' => $subsection_gid]);
            $speech_url = $url->generate() . '#g' . gid_to_anchor($speech_gid);

            // Extract first 100 characters of the speech for preview
            $preview = strip_tags($speech['body']);
            $preview = mb_substr($preview, 0, 100);
            if (mb_strlen($speech['body']) > 100) {
                $preview .= '...';
            }

            $speeches[] = [
                'gid' => $speech_gid,
                'url' => $speech_url,
                'preview' => $preview,
                'time' => $speech['htime'],
                'position' => $speech['hpos'],
            ];
        }

        return $speeches;
    }

    /**
     * Convert a division key to a votes.theyworkforyou.com URL
     *
     * @param string $key The division key (e.g., 'pw-2025-09-11-1-commons')
     * @return string The URL for the vote analysis page
     */
    public function keyToVoteAnalysisUrl($key) {
        // Remove the prefix
        $trimmed = preg_replace('/^pw-/', '', $key);

        // Split into parts
        $parts = explode('-', $trimmed);

        // Extract date
        $date = implode('-', array_slice($parts, 0, 3));

        // Chamber is always the last part
        $chamber = array_pop($parts);

        // The division ID is the first numeric part after the date
        $id = null;
        foreach (array_slice($parts, 3) as $part) {
            if (ctype_digit($part)) {
                $id = $part;
                break;
            }
        }

        // Build URL
        return sprintf(
            "https://votes.theyworkforyou.com/decisions/division/%s/%s/%s",
            $chamber,
            $date,
            $id
        );
    }
}