liquid_feedback_core

changeset 250:7b8966b801e5

Allow "calculate_ranks" to work properly, even if there was a previous counting of votes (due to manual reset of issue state)
author jbe
date Tue May 15 12:46:30 2012 +0200 (2012-05-15)
parents d4c754c4aeaa
children 5ee7eed2f5b0
files core.sql update/core-update.v2.0.8-v2.0.9.sql
line diff
     1.1 --- a/core.sql	Mon May 14 14:36:54 2012 +0200
     1.2 +++ b/core.sql	Tue May 15 12:46:30 2012 +0200
     1.3 @@ -3921,7 +3921,8 @@
     1.4            "multistage_majority"    = "rank_ary"["i"] >= "rank_ary"["dimension_v"],
     1.5            "reverse_beat_path"      = "matrix"["dimension_v"]["i"] >= 0,
     1.6            "eligible"               = FALSE,
     1.7 -          "winner"                 = FALSE
     1.8 +          "winner"                 = FALSE,
     1.9 +          "rank"                   = NULL  -- NOTE: in cases of manual reset of issue state
    1.10            WHERE "id" = "initiative_id_v";
    1.11          "i" := "i" + 1;
    1.12        END LOOP;
     2.1 --- a/update/core-update.v2.0.8-v2.0.9.sql	Mon May 14 14:36:54 2012 +0200
     2.2 +++ b/update/core-update.v2.0.8-v2.0.9.sql	Tue May 15 12:46:30 2012 +0200
     2.3 @@ -388,4 +388,308 @@
     2.4      "member"."id"%TYPE )
     2.5    IS 'Notable information about a delegation chain for unit, area, or issue; See "delegation_info_type" for more information';
     2.6  
     2.7 +CREATE OR REPLACE FUNCTION "calculate_ranks"("issue_id_p" "issue"."id"%TYPE)
     2.8 +  RETURNS VOID
     2.9 +  LANGUAGE 'plpgsql' VOLATILE AS $$
    2.10 +    DECLARE
    2.11 +      "issue_row"         "issue"%ROWTYPE;
    2.12 +      "policy_row"        "policy"%ROWTYPE;
    2.13 +      "dimension_v"       INTEGER;
    2.14 +      "vote_matrix"       INT4[][];  -- absolute votes
    2.15 +      "matrix"            INT8[][];  -- defeat strength / best paths
    2.16 +      "i"                 INTEGER;
    2.17 +      "j"                 INTEGER;
    2.18 +      "k"                 INTEGER;
    2.19 +      "battle_row"        "battle"%ROWTYPE;
    2.20 +      "rank_ary"          INT4[];
    2.21 +      "rank_v"            INT4;
    2.22 +      "done_v"            INTEGER;
    2.23 +      "winners_ary"       INTEGER[];
    2.24 +      "initiative_id_v"   "initiative"."id"%TYPE;
    2.25 +    BEGIN
    2.26 +      SELECT * INTO "issue_row"
    2.27 +        FROM "issue" WHERE "id" = "issue_id_p"
    2.28 +        FOR UPDATE;
    2.29 +      SELECT * INTO "policy_row"
    2.30 +        FROM "policy" WHERE "id" = "issue_row"."policy_id";
    2.31 +      SELECT count(1) INTO "dimension_v"
    2.32 +        FROM "battle_participant" WHERE "issue_id" = "issue_id_p";
    2.33 +      -- Create "vote_matrix" with absolute number of votes in pairwise
    2.34 +      -- comparison:
    2.35 +      "vote_matrix" := array_fill(NULL::INT4, ARRAY["dimension_v", "dimension_v"]);
    2.36 +      "i" := 1;
    2.37 +      "j" := 2;
    2.38 +      FOR "battle_row" IN
    2.39 +        SELECT * FROM "battle" WHERE "issue_id" = "issue_id_p"
    2.40 +        ORDER BY
    2.41 +        "winning_initiative_id" NULLS LAST,
    2.42 +        "losing_initiative_id" NULLS LAST
    2.43 +      LOOP
    2.44 +        "vote_matrix"["i"]["j"] := "battle_row"."count";
    2.45 +        IF "j" = "dimension_v" THEN
    2.46 +          "i" := "i" + 1;
    2.47 +          "j" := 1;
    2.48 +        ELSE
    2.49 +          "j" := "j" + 1;
    2.50 +          IF "j" = "i" THEN
    2.51 +            "j" := "j" + 1;
    2.52 +          END IF;
    2.53 +        END IF;
    2.54 +      END LOOP;
    2.55 +      IF "i" != "dimension_v" OR "j" != "dimension_v" + 1 THEN
    2.56 +        RAISE EXCEPTION 'Wrong battle count (should not happen)';
    2.57 +      END IF;
    2.58 +      -- Store defeat strengths in "matrix" using "defeat_strength"
    2.59 +      -- function:
    2.60 +      "matrix" := array_fill(NULL::INT8, ARRAY["dimension_v", "dimension_v"]);
    2.61 +      "i" := 1;
    2.62 +      LOOP
    2.63 +        "j" := 1;
    2.64 +        LOOP
    2.65 +          IF "i" != "j" THEN
    2.66 +            "matrix"["i"]["j"] := "defeat_strength"(
    2.67 +              "vote_matrix"["i"]["j"],
    2.68 +              "vote_matrix"["j"]["i"]
    2.69 +            );
    2.70 +          END IF;
    2.71 +          EXIT WHEN "j" = "dimension_v";
    2.72 +          "j" := "j" + 1;
    2.73 +        END LOOP;
    2.74 +        EXIT WHEN "i" = "dimension_v";
    2.75 +        "i" := "i" + 1;
    2.76 +      END LOOP;
    2.77 +      -- Find best paths:
    2.78 +      "i" := 1;
    2.79 +      LOOP
    2.80 +        "j" := 1;
    2.81 +        LOOP
    2.82 +          IF "i" != "j" THEN
    2.83 +            "k" := 1;
    2.84 +            LOOP
    2.85 +              IF "i" != "k" AND "j" != "k" THEN
    2.86 +                IF "matrix"["j"]["i"] < "matrix"["i"]["k"] THEN
    2.87 +                  IF "matrix"["j"]["i"] > "matrix"["j"]["k"] THEN
    2.88 +                    "matrix"["j"]["k"] := "matrix"["j"]["i"];
    2.89 +                  END IF;
    2.90 +                ELSE
    2.91 +                  IF "matrix"["i"]["k"] > "matrix"["j"]["k"] THEN
    2.92 +                    "matrix"["j"]["k"] := "matrix"["i"]["k"];
    2.93 +                  END IF;
    2.94 +                END IF;
    2.95 +              END IF;
    2.96 +              EXIT WHEN "k" = "dimension_v";
    2.97 +              "k" := "k" + 1;
    2.98 +            END LOOP;
    2.99 +          END IF;
   2.100 +          EXIT WHEN "j" = "dimension_v";
   2.101 +          "j" := "j" + 1;
   2.102 +        END LOOP;
   2.103 +        EXIT WHEN "i" = "dimension_v";
   2.104 +        "i" := "i" + 1;
   2.105 +      END LOOP;
   2.106 +      -- Determine order of winners:
   2.107 +      "rank_ary" := array_fill(NULL::INT4, ARRAY["dimension_v"]);
   2.108 +      "rank_v" := 1;
   2.109 +      "done_v" := 0;
   2.110 +      LOOP
   2.111 +        "winners_ary" := '{}';
   2.112 +        "i" := 1;
   2.113 +        LOOP
   2.114 +          IF "rank_ary"["i"] ISNULL THEN
   2.115 +            "j" := 1;
   2.116 +            LOOP
   2.117 +              IF
   2.118 +                "i" != "j" AND
   2.119 +                "rank_ary"["j"] ISNULL AND
   2.120 +                "matrix"["j"]["i"] > "matrix"["i"]["j"]
   2.121 +              THEN
   2.122 +                -- someone else is better
   2.123 +                EXIT;
   2.124 +              END IF;
   2.125 +              IF "j" = "dimension_v" THEN
   2.126 +                -- noone is better
   2.127 +                "winners_ary" := "winners_ary" || "i";
   2.128 +                EXIT;
   2.129 +              END IF;
   2.130 +              "j" := "j" + 1;
   2.131 +            END LOOP;
   2.132 +          END IF;
   2.133 +          EXIT WHEN "i" = "dimension_v";
   2.134 +          "i" := "i" + 1;
   2.135 +        END LOOP;
   2.136 +        "i" := 1;
   2.137 +        LOOP
   2.138 +          "rank_ary"["winners_ary"["i"]] := "rank_v";
   2.139 +          "done_v" := "done_v" + 1;
   2.140 +          EXIT WHEN "i" = array_upper("winners_ary", 1);
   2.141 +          "i" := "i" + 1;
   2.142 +        END LOOP;
   2.143 +        EXIT WHEN "done_v" = "dimension_v";
   2.144 +        "rank_v" := "rank_v" + 1;
   2.145 +      END LOOP;
   2.146 +      -- write preliminary results:
   2.147 +      "i" := 1;
   2.148 +      FOR "initiative_id_v" IN
   2.149 +        SELECT "id" FROM "initiative"
   2.150 +        WHERE "issue_id" = "issue_id_p" AND "admitted"
   2.151 +        ORDER BY "id"
   2.152 +      LOOP
   2.153 +        UPDATE "initiative" SET
   2.154 +          "direct_majority" =
   2.155 +            CASE WHEN "policy_row"."direct_majority_strict" THEN
   2.156 +              "positive_votes" * "policy_row"."direct_majority_den" >
   2.157 +              "policy_row"."direct_majority_num" * ("positive_votes"+"negative_votes")
   2.158 +            ELSE
   2.159 +              "positive_votes" * "policy_row"."direct_majority_den" >=
   2.160 +              "policy_row"."direct_majority_num" * ("positive_votes"+"negative_votes")
   2.161 +            END
   2.162 +            AND "positive_votes" >= "policy_row"."direct_majority_positive"
   2.163 +            AND "issue_row"."voter_count"-"negative_votes" >=
   2.164 +                "policy_row"."direct_majority_non_negative",
   2.165 +            "indirect_majority" =
   2.166 +            CASE WHEN "policy_row"."indirect_majority_strict" THEN
   2.167 +              "positive_votes" * "policy_row"."indirect_majority_den" >
   2.168 +              "policy_row"."indirect_majority_num" * ("positive_votes"+"negative_votes")
   2.169 +            ELSE
   2.170 +              "positive_votes" * "policy_row"."indirect_majority_den" >=
   2.171 +              "policy_row"."indirect_majority_num" * ("positive_votes"+"negative_votes")
   2.172 +            END
   2.173 +            AND "positive_votes" >= "policy_row"."indirect_majority_positive"
   2.174 +            AND "issue_row"."voter_count"-"negative_votes" >=
   2.175 +                "policy_row"."indirect_majority_non_negative",
   2.176 +          "schulze_rank"           = "rank_ary"["i"],
   2.177 +          "better_than_status_quo" = "rank_ary"["i"] < "rank_ary"["dimension_v"],
   2.178 +          "worse_than_status_quo"  = "rank_ary"["i"] > "rank_ary"["dimension_v"],
   2.179 +          "multistage_majority"    = "rank_ary"["i"] >= "rank_ary"["dimension_v"],
   2.180 +          "reverse_beat_path"      = "matrix"["dimension_v"]["i"] >= 0,
   2.181 +          "eligible"               = FALSE,
   2.182 +          "winner"                 = FALSE,
   2.183 +          "rank"                   = NULL  -- NOTE: in cases of manual reset of issue state
   2.184 +          WHERE "id" = "initiative_id_v";
   2.185 +        "i" := "i" + 1;
   2.186 +      END LOOP;
   2.187 +      IF "i" != "dimension_v" THEN
   2.188 +        RAISE EXCEPTION 'Wrong winner count (should not happen)';
   2.189 +      END IF;
   2.190 +      -- take indirect majorities into account:
   2.191 +      LOOP
   2.192 +        UPDATE "initiative" SET "indirect_majority" = TRUE
   2.193 +          FROM (
   2.194 +            SELECT "new_initiative"."id" AS "initiative_id"
   2.195 +            FROM "initiative" "old_initiative"
   2.196 +            JOIN "initiative" "new_initiative"
   2.197 +              ON "new_initiative"."issue_id" = "issue_id_p"
   2.198 +              AND "new_initiative"."indirect_majority" = FALSE
   2.199 +            JOIN "battle" "battle_win"
   2.200 +              ON "battle_win"."issue_id" = "issue_id_p"
   2.201 +              AND "battle_win"."winning_initiative_id" = "new_initiative"."id"
   2.202 +              AND "battle_win"."losing_initiative_id" = "old_initiative"."id"
   2.203 +            JOIN "battle" "battle_lose"
   2.204 +              ON "battle_lose"."issue_id" = "issue_id_p"
   2.205 +              AND "battle_lose"."losing_initiative_id" = "new_initiative"."id"
   2.206 +              AND "battle_lose"."winning_initiative_id" = "old_initiative"."id"
   2.207 +            WHERE "old_initiative"."issue_id" = "issue_id_p"
   2.208 +            AND "old_initiative"."indirect_majority" = TRUE
   2.209 +            AND CASE WHEN "policy_row"."indirect_majority_strict" THEN
   2.210 +              "battle_win"."count" * "policy_row"."indirect_majority_den" >
   2.211 +              "policy_row"."indirect_majority_num" *
   2.212 +              ("battle_win"."count"+"battle_lose"."count")
   2.213 +            ELSE
   2.214 +              "battle_win"."count" * "policy_row"."indirect_majority_den" >=
   2.215 +              "policy_row"."indirect_majority_num" *
   2.216 +              ("battle_win"."count"+"battle_lose"."count")
   2.217 +            END
   2.218 +            AND "battle_win"."count" >= "policy_row"."indirect_majority_positive"
   2.219 +            AND "issue_row"."voter_count"-"battle_lose"."count" >=
   2.220 +                "policy_row"."indirect_majority_non_negative"
   2.221 +          ) AS "subquery"
   2.222 +          WHERE "id" = "subquery"."initiative_id";
   2.223 +        EXIT WHEN NOT FOUND;
   2.224 +      END LOOP;
   2.225 +      -- set "multistage_majority" for remaining matching initiatives:
   2.226 +      UPDATE "initiative" SET "multistage_majority" = TRUE
   2.227 +        FROM (
   2.228 +          SELECT "losing_initiative"."id" AS "initiative_id"
   2.229 +          FROM "initiative" "losing_initiative"
   2.230 +          JOIN "initiative" "winning_initiative"
   2.231 +            ON "winning_initiative"."issue_id" = "issue_id_p"
   2.232 +            AND "winning_initiative"."admitted"
   2.233 +          JOIN "battle" "battle_win"
   2.234 +            ON "battle_win"."issue_id" = "issue_id_p"
   2.235 +            AND "battle_win"."winning_initiative_id" = "winning_initiative"."id"
   2.236 +            AND "battle_win"."losing_initiative_id" = "losing_initiative"."id"
   2.237 +          JOIN "battle" "battle_lose"
   2.238 +            ON "battle_lose"."issue_id" = "issue_id_p"
   2.239 +            AND "battle_lose"."losing_initiative_id" = "winning_initiative"."id"
   2.240 +            AND "battle_lose"."winning_initiative_id" = "losing_initiative"."id"
   2.241 +          WHERE "losing_initiative"."issue_id" = "issue_id_p"
   2.242 +          AND "losing_initiative"."admitted"
   2.243 +          AND "winning_initiative"."schulze_rank" <
   2.244 +              "losing_initiative"."schulze_rank"
   2.245 +          AND "battle_win"."count" > "battle_lose"."count"
   2.246 +          AND (
   2.247 +            "battle_win"."count" > "winning_initiative"."positive_votes" OR
   2.248 +            "battle_lose"."count" < "losing_initiative"."negative_votes" )
   2.249 +        ) AS "subquery"
   2.250 +        WHERE "id" = "subquery"."initiative_id";
   2.251 +      -- mark eligible initiatives:
   2.252 +      UPDATE "initiative" SET "eligible" = TRUE
   2.253 +        WHERE "issue_id" = "issue_id_p"
   2.254 +        AND "initiative"."direct_majority"
   2.255 +        AND "initiative"."indirect_majority"
   2.256 +        AND "initiative"."better_than_status_quo"
   2.257 +        AND (
   2.258 +          "policy_row"."no_multistage_majority" = FALSE OR
   2.259 +          "initiative"."multistage_majority" = FALSE )
   2.260 +        AND (
   2.261 +          "policy_row"."no_reverse_beat_path" = FALSE OR
   2.262 +          "initiative"."reverse_beat_path" = FALSE );
   2.263 +      -- mark final winner:
   2.264 +      UPDATE "initiative" SET "winner" = TRUE
   2.265 +        FROM (
   2.266 +          SELECT "id" AS "initiative_id"
   2.267 +          FROM "initiative"
   2.268 +          WHERE "issue_id" = "issue_id_p" AND "eligible"
   2.269 +          ORDER BY
   2.270 +            "schulze_rank",
   2.271 +            "vote_ratio"("positive_votes", "negative_votes"),
   2.272 +            "id"
   2.273 +          LIMIT 1
   2.274 +        ) AS "subquery"
   2.275 +        WHERE "id" = "subquery"."initiative_id";
   2.276 +      -- write (final) ranks:
   2.277 +      "rank_v" := 1;
   2.278 +      FOR "initiative_id_v" IN
   2.279 +        SELECT "id"
   2.280 +        FROM "initiative"
   2.281 +        WHERE "issue_id" = "issue_id_p" AND "admitted"
   2.282 +        ORDER BY
   2.283 +          "winner" DESC,
   2.284 +          "eligible" DESC,
   2.285 +          "schulze_rank",
   2.286 +          "vote_ratio"("positive_votes", "negative_votes"),
   2.287 +          "id"
   2.288 +      LOOP
   2.289 +        UPDATE "initiative" SET "rank" = "rank_v"
   2.290 +          WHERE "id" = "initiative_id_v";
   2.291 +        "rank_v" := "rank_v" + 1;
   2.292 +      END LOOP;
   2.293 +      -- set schulze rank of status quo and mark issue as finished:
   2.294 +      UPDATE "issue" SET
   2.295 +        "status_quo_schulze_rank" = "rank_ary"["dimension_v"],
   2.296 +        "state" =
   2.297 +          CASE WHEN EXISTS (
   2.298 +            SELECT NULL FROM "initiative"
   2.299 +            WHERE "issue_id" = "issue_id_p" AND "winner"
   2.300 +          ) THEN
   2.301 +            'finished_with_winner'::"issue_state"
   2.302 +          ELSE
   2.303 +            'finished_without_winner'::"issue_state"
   2.304 +          END,
   2.305 +        "ranks_available" = TRUE
   2.306 +        WHERE "id" = "issue_id_p";
   2.307 +      RETURN;
   2.308 +    END;
   2.309 +  $$;
   2.310 +
   2.311  COMMIT;

Impressum / About Us