1.1 --- a/update/core-update.v2.2.5-v2.2.6.sql	Mon Oct 14 19:36:33 2013 +0200
     1.2 +++ b/update/core-update.v2.2.5-v2.2.6.sql	Mon Dec 23 20:22:32 2013 +0100
     1.3 @@ -33,4 +33,307 @@
     1.4  
     1.5  COMMENT ON VIEW "issue_supporter_in_admission_state" IS 'Helper view for "lf_update_issue_order" to allow a (proportional) ordering of issues within an area';
     1.6  
     1.7 +COMMENT ON COLUMN "initiative"."schulze_rank"           IS 'Schulze-Ranking';
     1.8 +COMMENT ON COLUMN "initiative"."better_than_status_quo" IS 'TRUE, if initiative has a schulze-ranking better than the status quo';
     1.9 +COMMENT ON COLUMN "initiative"."worse_than_status_quo"  IS 'TRUE, if initiative has a schulze-ranking worse than the status quo (DEPRECATED, since schulze-ranking is unique per issue; use "better_than_status_quo"=FALSE)';
    1.10 +COMMENT ON COLUMN "initiative"."winner"                 IS 'Winner is the "eligible" initiative with best "schulze_rank"';
    1.11 +
    1.12 +CREATE OR REPLACE FUNCTION "calculate_ranks"("issue_id_p" "issue"."id"%TYPE)
    1.13 +  RETURNS VOID
    1.14 +  LANGUAGE 'plpgsql' VOLATILE AS $$
    1.15 +    DECLARE
    1.16 +      "issue_row"         "issue"%ROWTYPE;
    1.17 +      "policy_row"        "policy"%ROWTYPE;
    1.18 +      "dimension_v"       INTEGER;
    1.19 +      "vote_matrix"       INT4[][];  -- absolute votes
    1.20 +      "matrix"            INT8[][];  -- defeat strength / best paths
    1.21 +      "i"                 INTEGER;
    1.22 +      "j"                 INTEGER;
    1.23 +      "k"                 INTEGER;
    1.24 +      "battle_row"        "battle"%ROWTYPE;
    1.25 +      "rank_ary"          INT4[];
    1.26 +      "rank_v"            INT4;
    1.27 +      "initiative_id_v"   "initiative"."id"%TYPE;
    1.28 +    BEGIN
    1.29 +      PERFORM "require_transaction_isolation"();
    1.30 +      SELECT * INTO "issue_row"
    1.31 +        FROM "issue" WHERE "id" = "issue_id_p";
    1.32 +      SELECT * INTO "policy_row"
    1.33 +        FROM "policy" WHERE "id" = "issue_row"."policy_id";
    1.34 +      SELECT count(1) INTO "dimension_v"
    1.35 +        FROM "battle_participant" WHERE "issue_id" = "issue_id_p";
    1.36 +      -- Create "vote_matrix" with absolute number of votes in pairwise
    1.37 +      -- comparison:
    1.38 +      "vote_matrix" := array_fill(NULL::INT4, ARRAY["dimension_v", "dimension_v"]);
    1.39 +      "i" := 1;
    1.40 +      "j" := 2;
    1.41 +      FOR "battle_row" IN
    1.42 +        SELECT * FROM "battle" WHERE "issue_id" = "issue_id_p"
    1.43 +        ORDER BY
    1.44 +        "winning_initiative_id" NULLS FIRST,
    1.45 +        "losing_initiative_id" NULLS FIRST
    1.46 +      LOOP
    1.47 +        "vote_matrix"["i"]["j"] := "battle_row"."count";
    1.48 +        IF "j" = "dimension_v" THEN
    1.49 +          "i" := "i" + 1;
    1.50 +          "j" := 1;
    1.51 +        ELSE
    1.52 +          "j" := "j" + 1;
    1.53 +          IF "j" = "i" THEN
    1.54 +            "j" := "j" + 1;
    1.55 +          END IF;
    1.56 +        END IF;
    1.57 +      END LOOP;
    1.58 +      IF "i" != "dimension_v" OR "j" != "dimension_v" + 1 THEN
    1.59 +        RAISE EXCEPTION 'Wrong battle count (should not happen)';
    1.60 +      END IF;
    1.61 +      -- Store defeat strengths in "matrix" using "defeat_strength"
    1.62 +      -- function:
    1.63 +      "matrix" := array_fill(NULL::INT8, ARRAY["dimension_v", "dimension_v"]);
    1.64 +      "i" := 1;
    1.65 +      LOOP
    1.66 +        "j" := 1;
    1.67 +        LOOP
    1.68 +          IF "i" != "j" THEN
    1.69 +            "matrix"["i"]["j"] := "defeat_strength"(
    1.70 +              "vote_matrix"["i"]["j"],
    1.71 +              "vote_matrix"["j"]["i"]
    1.72 +            );
    1.73 +          END IF;
    1.74 +          EXIT WHEN "j" = "dimension_v";
    1.75 +          "j" := "j" + 1;
    1.76 +        END LOOP;
    1.77 +        EXIT WHEN "i" = "dimension_v";
    1.78 +        "i" := "i" + 1;
    1.79 +      END LOOP;
    1.80 +      -- Find best paths:
    1.81 +      "i" := 1;
    1.82 +      LOOP
    1.83 +        "j" := 1;
    1.84 +        LOOP
    1.85 +          IF "i" != "j" THEN
    1.86 +            "k" := 1;
    1.87 +            LOOP
    1.88 +              IF "i" != "k" AND "j" != "k" THEN
    1.89 +                IF "matrix"["j"]["i"] < "matrix"["i"]["k"] THEN
    1.90 +                  IF "matrix"["j"]["i"] > "matrix"["j"]["k"] THEN
    1.91 +                    "matrix"["j"]["k"] := "matrix"["j"]["i"];
    1.92 +                  END IF;
    1.93 +                ELSE
    1.94 +                  IF "matrix"["i"]["k"] > "matrix"["j"]["k"] THEN
    1.95 +                    "matrix"["j"]["k"] := "matrix"["i"]["k"];
    1.96 +                  END IF;
    1.97 +                END IF;
    1.98 +              END IF;
    1.99 +              EXIT WHEN "k" = "dimension_v";
   1.100 +              "k" := "k" + 1;
   1.101 +            END LOOP;
   1.102 +          END IF;
   1.103 +          EXIT WHEN "j" = "dimension_v";
   1.104 +          "j" := "j" + 1;
   1.105 +        END LOOP;
   1.106 +        EXIT WHEN "i" = "dimension_v";
   1.107 +        "i" := "i" + 1;
   1.108 +      END LOOP;
   1.109 +      -- Determine order of winners:
   1.110 +      "rank_ary" := array_fill(NULL::INT4, ARRAY["dimension_v"]);
   1.111 +      "rank_v" := 1;
   1.112 +      LOOP
   1.113 +        "i" := 1;
   1.114 +        LOOP
   1.115 +          IF "rank_ary"["i"] ISNULL THEN
   1.116 +            "j" := 1;
   1.117 +            LOOP
   1.118 +              IF
   1.119 +                "i" != "j" AND
   1.120 +                "rank_ary"["j"] ISNULL AND
   1.121 +                ( "matrix"["j"]["i"] > "matrix"["i"]["j"] OR
   1.122 +                  -- tie-breaking by "id"
   1.123 +                  ( "matrix"["j"]["i"] = "matrix"["i"]["j"] AND
   1.124 +                    "j" < "i" ) )
   1.125 +              THEN
   1.126 +                -- someone else is better
   1.127 +                EXIT;
   1.128 +              END IF;
   1.129 +              "j" := "j" + 1;
   1.130 +              IF "j" = "dimension_v" + 1 THEN
   1.131 +                -- noone is better
   1.132 +                "rank_ary"["i"] := "rank_v";
   1.133 +                EXIT;
   1.134 +              END IF;
   1.135 +            END LOOP;
   1.136 +            EXIT WHEN "j" = "dimension_v" + 1;
   1.137 +          END IF;
   1.138 +          "i" := "i" + 1;
   1.139 +          IF "i" > "dimension_v" THEN
   1.140 +            RAISE EXCEPTION 'Schulze ranking does not compute (should not happen)';
   1.141 +          END IF;
   1.142 +        END LOOP;
   1.143 +        EXIT WHEN "rank_v" = "dimension_v";
   1.144 +        "rank_v" := "rank_v" + 1;
   1.145 +      END LOOP;
   1.146 +      -- write preliminary results:
   1.147 +      "i" := 2;  -- omit status quo with "i" = 1
   1.148 +      FOR "initiative_id_v" IN
   1.149 +        SELECT "id" FROM "initiative"
   1.150 +        WHERE "issue_id" = "issue_id_p" AND "admitted"
   1.151 +        ORDER BY "id"
   1.152 +      LOOP
   1.153 +        UPDATE "initiative" SET
   1.154 +          "direct_majority" =
   1.155 +            CASE WHEN "policy_row"."direct_majority_strict" THEN
   1.156 +              "positive_votes" * "policy_row"."direct_majority_den" >
   1.157 +              "policy_row"."direct_majority_num" * ("positive_votes"+"negative_votes")
   1.158 +            ELSE
   1.159 +              "positive_votes" * "policy_row"."direct_majority_den" >=
   1.160 +              "policy_row"."direct_majority_num" * ("positive_votes"+"negative_votes")
   1.161 +            END
   1.162 +            AND "positive_votes" >= "policy_row"."direct_majority_positive"
   1.163 +            AND "issue_row"."voter_count"-"negative_votes" >=
   1.164 +                "policy_row"."direct_majority_non_negative",
   1.165 +            "indirect_majority" =
   1.166 +            CASE WHEN "policy_row"."indirect_majority_strict" THEN
   1.167 +              "positive_votes" * "policy_row"."indirect_majority_den" >
   1.168 +              "policy_row"."indirect_majority_num" * ("positive_votes"+"negative_votes")
   1.169 +            ELSE
   1.170 +              "positive_votes" * "policy_row"."indirect_majority_den" >=
   1.171 +              "policy_row"."indirect_majority_num" * ("positive_votes"+"negative_votes")
   1.172 +            END
   1.173 +            AND "positive_votes" >= "policy_row"."indirect_majority_positive"
   1.174 +            AND "issue_row"."voter_count"-"negative_votes" >=
   1.175 +                "policy_row"."indirect_majority_non_negative",
   1.176 +          "schulze_rank"           = "rank_ary"["i"],
   1.177 +          "better_than_status_quo" = "rank_ary"["i"] < "rank_ary"[1],
   1.178 +          "worse_than_status_quo"  = "rank_ary"["i"] > "rank_ary"[1],
   1.179 +          "multistage_majority"    = "rank_ary"["i"] >= "rank_ary"[1],
   1.180 +          "reverse_beat_path"      = "matrix"[1]["i"] >= 0,
   1.181 +          "eligible"               = FALSE,
   1.182 +          "winner"                 = FALSE,
   1.183 +          "rank"                   = NULL  -- NOTE: in cases of manual reset of issue state
   1.184 +          WHERE "id" = "initiative_id_v";
   1.185 +        "i" := "i" + 1;
   1.186 +      END LOOP;
   1.187 +      IF "i" != "dimension_v" + 1 THEN
   1.188 +        RAISE EXCEPTION 'Wrong winner count (should not happen)';
   1.189 +      END IF;
   1.190 +      -- take indirect majorities into account:
   1.191 +      LOOP
   1.192 +        UPDATE "initiative" SET "indirect_majority" = TRUE
   1.193 +          FROM (
   1.194 +            SELECT "new_initiative"."id" AS "initiative_id"
   1.195 +            FROM "initiative" "old_initiative"
   1.196 +            JOIN "initiative" "new_initiative"
   1.197 +              ON "new_initiative"."issue_id" = "issue_id_p"
   1.198 +              AND "new_initiative"."indirect_majority" = FALSE
   1.199 +            JOIN "battle" "battle_win"
   1.200 +              ON "battle_win"."issue_id" = "issue_id_p"
   1.201 +              AND "battle_win"."winning_initiative_id" = "new_initiative"."id"
   1.202 +              AND "battle_win"."losing_initiative_id" = "old_initiative"."id"
   1.203 +            JOIN "battle" "battle_lose"
   1.204 +              ON "battle_lose"."issue_id" = "issue_id_p"
   1.205 +              AND "battle_lose"."losing_initiative_id" = "new_initiative"."id"
   1.206 +              AND "battle_lose"."winning_initiative_id" = "old_initiative"."id"
   1.207 +            WHERE "old_initiative"."issue_id" = "issue_id_p"
   1.208 +            AND "old_initiative"."indirect_majority" = TRUE
   1.209 +            AND CASE WHEN "policy_row"."indirect_majority_strict" THEN
   1.210 +              "battle_win"."count" * "policy_row"."indirect_majority_den" >
   1.211 +              "policy_row"."indirect_majority_num" *
   1.212 +              ("battle_win"."count"+"battle_lose"."count")
   1.213 +            ELSE
   1.214 +              "battle_win"."count" * "policy_row"."indirect_majority_den" >=
   1.215 +              "policy_row"."indirect_majority_num" *
   1.216 +              ("battle_win"."count"+"battle_lose"."count")
   1.217 +            END
   1.218 +            AND "battle_win"."count" >= "policy_row"."indirect_majority_positive"
   1.219 +            AND "issue_row"."voter_count"-"battle_lose"."count" >=
   1.220 +                "policy_row"."indirect_majority_non_negative"
   1.221 +          ) AS "subquery"
   1.222 +          WHERE "id" = "subquery"."initiative_id";
   1.223 +        EXIT WHEN NOT FOUND;
   1.224 +      END LOOP;
   1.225 +      -- set "multistage_majority" for remaining matching initiatives:
   1.226 +      UPDATE "initiative" SET "multistage_majority" = TRUE
   1.227 +        FROM (
   1.228 +          SELECT "losing_initiative"."id" AS "initiative_id"
   1.229 +          FROM "initiative" "losing_initiative"
   1.230 +          JOIN "initiative" "winning_initiative"
   1.231 +            ON "winning_initiative"."issue_id" = "issue_id_p"
   1.232 +            AND "winning_initiative"."admitted"
   1.233 +          JOIN "battle" "battle_win"
   1.234 +            ON "battle_win"."issue_id" = "issue_id_p"
   1.235 +            AND "battle_win"."winning_initiative_id" = "winning_initiative"."id"
   1.236 +            AND "battle_win"."losing_initiative_id" = "losing_initiative"."id"
   1.237 +          JOIN "battle" "battle_lose"
   1.238 +            ON "battle_lose"."issue_id" = "issue_id_p"
   1.239 +            AND "battle_lose"."losing_initiative_id" = "winning_initiative"."id"
   1.240 +            AND "battle_lose"."winning_initiative_id" = "losing_initiative"."id"
   1.241 +          WHERE "losing_initiative"."issue_id" = "issue_id_p"
   1.242 +          AND "losing_initiative"."admitted"
   1.243 +          AND "winning_initiative"."schulze_rank" <
   1.244 +              "losing_initiative"."schulze_rank"
   1.245 +          AND "battle_win"."count" > "battle_lose"."count"
   1.246 +          AND (
   1.247 +            "battle_win"."count" > "winning_initiative"."positive_votes" OR
   1.248 +            "battle_lose"."count" < "losing_initiative"."negative_votes" )
   1.249 +        ) AS "subquery"
   1.250 +        WHERE "id" = "subquery"."initiative_id";
   1.251 +      -- mark eligible initiatives:
   1.252 +      UPDATE "initiative" SET "eligible" = TRUE
   1.253 +        WHERE "issue_id" = "issue_id_p"
   1.254 +        AND "initiative"."direct_majority"
   1.255 +        AND "initiative"."indirect_majority"
   1.256 +        AND "initiative"."better_than_status_quo"
   1.257 +        AND (
   1.258 +          "policy_row"."no_multistage_majority" = FALSE OR
   1.259 +          "initiative"."multistage_majority" = FALSE )
   1.260 +        AND (
   1.261 +          "policy_row"."no_reverse_beat_path" = FALSE OR
   1.262 +          "initiative"."reverse_beat_path" = FALSE );
   1.263 +      -- mark final winner:
   1.264 +      UPDATE "initiative" SET "winner" = TRUE
   1.265 +        FROM (
   1.266 +          SELECT "id" AS "initiative_id"
   1.267 +          FROM "initiative"
   1.268 +          WHERE "issue_id" = "issue_id_p" AND "eligible"
   1.269 +          ORDER BY
   1.270 +            "schulze_rank",
   1.271 +            "id"
   1.272 +          LIMIT 1
   1.273 +        ) AS "subquery"
   1.274 +        WHERE "id" = "subquery"."initiative_id";
   1.275 +      -- write (final) ranks:
   1.276 +      "rank_v" := 1;
   1.277 +      FOR "initiative_id_v" IN
   1.278 +        SELECT "id"
   1.279 +        FROM "initiative"
   1.280 +        WHERE "issue_id" = "issue_id_p" AND "admitted"
   1.281 +        ORDER BY
   1.282 +          "winner" DESC,
   1.283 +          "eligible" DESC,
   1.284 +          "schulze_rank",
   1.285 +          "id"
   1.286 +      LOOP
   1.287 +        UPDATE "initiative" SET "rank" = "rank_v"
   1.288 +          WHERE "id" = "initiative_id_v";
   1.289 +        "rank_v" := "rank_v" + 1;
   1.290 +      END LOOP;
   1.291 +      -- set schulze rank of status quo and mark issue as finished:
   1.292 +      UPDATE "issue" SET
   1.293 +        "status_quo_schulze_rank" = "rank_ary"[1],
   1.294 +        "state" =
   1.295 +          CASE WHEN EXISTS (
   1.296 +            SELECT NULL FROM "initiative"
   1.297 +            WHERE "issue_id" = "issue_id_p" AND "winner"
   1.298 +          ) THEN
   1.299 +            'finished_with_winner'::"issue_state"
   1.300 +          ELSE
   1.301 +            'finished_without_winner'::"issue_state"
   1.302 +          END,
   1.303 +        "closed" = "phase_finished",
   1.304 +        "phase_finished" = NULL
   1.305 +        WHERE "id" = "issue_id_p";
   1.306 +      RETURN;
   1.307 +    END;
   1.308 +  $$;
   1.309 +
   1.310  COMMIT;