blog_post_param.php

См. документацию.

<?php
 
class CBlogUserOptions
{
    protected static $__USER_OPTIONS_CACHE;
 
    public static function GetList($arOrder = array("ID" => "ASC"), $arFilter = array(), $arAddParams = array())
    {
        global $DB;
 
        $ownerId = (int) ($arOrder["OWNER_ID"] ?? 0);
 
        $arFields = array(
            "ID" => array("FIELD" => "BPP.ID", "TYPE" => "int"),
            "POST_ID" => array("FIELD" => "BPP.POST_ID", "TYPE" => "int"),
            "USER_ID" => array("FIELD" => "BPP.USER_ID", "TYPE" => "int"),
            "NAME" => array("FIELD" => "BPP.NAME", "TYPE" => "string"),
            "VALUE" => array("FIELD" => "BPP.VALUE", "TYPE" => "string"),
            "RANK" => ($ownerId > 0 ? array(
                "FIELD" => "RV0.USER_RANK",
                "TYPE" => "int",
                "FROM" =>
                    "\n\tLEFT JOIN (\n\t\t".
                        "SELECT MAX(RV2.VOTE_WEIGHT) as VOTE_WEIGHT, RV2.ENTITY_ID \n\t\t".
                        "FROM b_rating_user RV2 \n\t\t".
                        (isset($arFilter["POST_ID"]) && !is_array($arFilter["POST_ID"]) && intval($arFilter["POST_ID"]) > 0 ? " WHERE RV2.ENTITY_ID IN (SELECT BPP.USER_ID as USER_ID FROM b_blog_post_param BPP WHERE BPP.POST_ID = ".intval($arFilter["POST_ID"]).")\n\t\t" : "").
                        "GROUP BY RV2.ENTITY_ID) RV ON (RV.ENTITY_ID = BPP.USER_ID)\n\t".
                    "LEFT JOIN (\n\t\t".
                        "SELECT RV1.OWNER_ID, SUM(case when RV1.ID is not null then 1 else 0 end) as USER_RANK \n\t\t".
                        "FROM b_rating_vote RV1 \n\t\t".
                        "WHERE RV1.USER_ID = ".$ownerId.(isset($arFilter["POST_ID"]) && !is_array($arFilter["POST_ID"]) && intval($arFilter["POST_ID"]) > 0 ? " AND RV1.OWNER_ID IN (SELECT BPP.USER_ID as USER_ID FROM b_blog_post_param BPP WHERE BPP.POST_ID = ".intval($arFilter["POST_ID"]).")" : "")."\n\t\t".
                        "GROUP BY RV1.OWNER_ID) RV0 ON (RV0.OWNER_ID = BPP.USER_ID)"
                ) : array (
                    "FIELD" => "RV.USER_RANK",
                    "TYPE" => "string",
                    "FROM" =>
                        "\n\tLEFT JOIN (".
                        "\n\t\tSELECT MAX(RV2.VOTE_WEIGHT) as VOTE_WEIGHT, RV2.ENTITY_ID, 0 as USER_RANK ".
                        "\n\t\tFROM b_rating_user RV2".
                        "\n\t\tGROUP BY RV2.ENTITY_ID) RV ON (RV.ENTITY_ID = BPP.USER_ID)")),
            "USER_ACTIVE" => array("FIELD" => "U.ACTIVE", "TYPE" => "string", "FROM" => "\n\tINNER JOIN b_user U ON (BPP.USER_ID = U.ID)"),
            "USER_NAME" => array("FIELD" => "U.NAME", "TYPE" => "string", "FROM" => "\n\tINNER JOIN b_user U ON (BPP.USER_ID = U.ID)"),
            "USER_LAST_NAME" => array("FIELD" => "U.LAST_NAME", "TYPE" => "string", "FROM" => "\n\tINNER JOIN b_user U ON (BPP.USER_ID = U.ID)"),
            "USER_SECOND_NAME" => array("FIELD" => "U.SECOND_NAME", "TYPE" => "string", "FROM" => "\n\tINNER JOIN b_user U ON (BPP.USER_ID = U.ID)"),
            "USER_LOGIN" => array("FIELD" => "U.LOGIN", "TYPE" => "string", "FROM" => "\n\tINNER JOIN b_user U ON (BPP.USER_ID = U.ID)"),
            "USER_PERSONAL_PHOTO" => array("FIELD" => "U.PERSONAL_PHOTO", "TYPE" => "string", "FROM" => "\n\tINNER JOIN b_user U ON (BPP.USER_ID = U.ID)")
        );
        $arSelect = array_diff(array_keys($arFields), array("RANK"));
        $arSelect = (
            (
                isset($arAddParams["SELECT"])
                && is_array($arAddParams["SELECT"])
                && !empty($arAddParams["SELECT"])
            )
                ? array_intersect($arAddParams["SELECT"], $arSelect)
                : $arSelect
        );
 
        $arSql = CBlog::PrepareSql($arFields, array(), $arFilter, false, $arSelect);
 
        $arSql["SELECT"] = (str_replace("%%_DISTINCT_%%", "", $arSql["SELECT"]));
 
        $iCnt = 0;
        if (
            ($arAddParams["bCount"] ?? null)
            || array_key_exists("bDescPageNumbering", $arAddParams)
        )
        {
            $strSql = "SELECT COUNT(BPP.ID) AS CNT  \n".
                "FROM b_blog_post_param BPP ".$arSql["FROM"]."\n".
                (empty($arSql["GROUPBY"]) ? "" : "GROUP BY ".$arSql["GROUPBY"]."\n").
                "WHERE ".(empty($arSql["WHERE"]) ? "1 = 1" : $arSql["WHERE"]);
            $db_res = $DB->Query($strSql);
            if ($arAddParams["bCount"] ?? null)
                return $db_res;
            $iCnt = ($db_res && ($res = $db_res->Fetch()) ? intval($res["CNT"]) : 0);
        }
 
        // ORDER BY -->
        $arSqlOrder = Array();
        foreach ($arOrder as $by => $order)
        {
            $by = mb_strtoupper($by);
            $order = (mb_strtoupper($order) != "ASC" ? "DESC" : "ASK");
            if (array_key_exists($by, $arFields) && !array_key_exists($by, $arSqlOrder))
            {
                if($DB->type == "ORACLE")
                    $order .= ($order == "ASC" ? " NULLS FIRST" : " NULLS LAST");
 
                if (isset($arFields[$by]["FROM"]) && !empty($arFields[$by]["FROM"]) && mb_strpos($arSql["FROM"], $arFields[$by]["FROM"]) === false)
                    $arSql["FROM"] .= " ".$arFields[$by]["FROM"];
                if ($by == "RANK")
                {
                    $arSql["SELECT"] .= ", ".$arFields["RANK"]["FIELD"];
                    $arSqlOrder[$by] = (IsModuleInstalled("intranet") ? "RV.VOTE_WEIGHT ".$order.", USER_RANK ".$order :
                        "USER_RANK ".$order.", RV.VOTE_WEIGHT ".$order);
                }
                else
                    $arSqlOrder[$by] = (array_key_exists("ORDER", $arFields[$by])? $arFields[$by]["ORDER"]: $arFields[$by]["FIELD"])." ".$order;
            }
        }
        DelDuplicateSort($arSqlOrder);
        $arSql["ORDERBY"] = implode(", ", $arSqlOrder);
        // <-- ORDER BY
 
        $strSql =
            "SELECT ".$arSql["SELECT"]."\n".
            "FROM b_blog_post_param BPP".$arSql["FROM"]."\n".
            "WHERE ".(empty($arSql["WHERE"]) ? "1 = 1" : $arSql["WHERE"]).
            (empty($arSql["ORDERBY"]) ? "" : "\nORDER BY ".$arSql["ORDERBY"]);
 
        if (is_set($arAddParams, "bDescPageNumbering")) {
            $db_res =  new CDBResult();
            $db_res->NavQuery($strSql, $iCnt, $arAddParams);
        } else {
            $db_res = $DB->Query($strSql);
        }
 
        return $db_res;
    }
 
    public static function GetOption($post_id, $name, $default_value = false, $user_id = false)
    {
        global $DB, $USER, $CACHE_MANAGER;
 
        $post_id = intval($post_id);
        if ($user_id === false)
            $user_id = $USER->GetID();
        $user_id = intval($user_id);
        $cache_key = $post_id.":".$name;
 
        if (!isset(self::$__USER_OPTIONS_CACHE[$user_id]))
        {
            $mcache_id = "user_option:$user_id";
            if ($CACHE_MANAGER->read(3600, $mcache_id, "blog_post_param") && false)
            {
                self::$__USER_OPTIONS_CACHE[$user_id] = $CACHE_MANAGER->get($mcache_id);
            }
            else
            {
                $strSql = "
                    SELECT POST_ID, USER_ID, NAME, VALUE
                    FROM b_blog_post_param
                    WHERE (USER_ID=".$user_id." OR USER_ID IS NULL)";
                $db_res = $DB->Query($strSql);
 
                while ($res = $db_res->Fetch())
                {
                    $row_cache_key = $res["POST_ID"].":".$res["NAME"];
                    $res["USER_ID"] = intval($res["USER_ID"]);
 
                    if (!isset(self::$__USER_OPTIONS_CACHE[$res["USER_ID"]][$row_cache_key]))
                        self::$__USER_OPTIONS_CACHE[$res["USER_ID"]][$row_cache_key] = $res["VALUE"];
                }
                $CACHE_MANAGER->Set($mcache_id, (self::$__USER_OPTIONS_CACHE[$user_id] ?? null));
            }
        }
        if (!isset(self::$__USER_OPTIONS_CACHE[$user_id][$cache_key]))
            return $default_value;
        return self::$__USER_OPTIONS_CACHE[$user_id][$cache_key];
    }
 
    public static function SetOption($post_id, $name, $value, $user_id = false)
    {
        global $DB, $USER;
 
        $post_id = intval($post_id);
        if ($user_id === false)
            $user_id = $USER->GetID();
 
        $user_id = intval($user_id);
        $arFields = array(
            "POST_ID" => ($post_id > 0 ? $post_id : false),
            "USER_ID" => ($user_id > 0 ? $user_id : false),
            "NAME" => $name,
            "VALUE" => $value
        );
        $res = $DB->Query(
            "SELECT ID FROM b_blog_post_param
            WHERE
            ".($post_id <= 0 ? "POST_ID IS NULL" : "POST_ID=".$post_id)." AND
            ".($user_id <= 0 ? "USER_ID IS NULL" : "USER_ID=".$user_id)." AND
            NAME='".$DB->ForSql($name, 50)."'");
            if ($res_array = $res->Fetch())
        {
            $strUpdate = $DB->PrepareUpdate("b_blog_post_param", $arFields);
            if ($strUpdate != "")
            {
                $strSql = "UPDATE b_blog_post_param SET ".$strUpdate." WHERE ID=".$res_array["ID"];
                if (!$DB->QueryBind($strSql, array() ))
                    return false;
            }
        }
        else
        {
            if (!$DB->Add("b_blog_post_param", $arFields, array()))
                return false;
        }
 
        self::_clear_cache($user_id);
        return true;
    }
 
    public static function DeleteOption($post_id, $name, $user_id = false)
    {
        global $DB, $USER;
        $post_id = intval($post_id);
        if ($user_id === false)
            $user_id = $USER->GetID();
        $user_id = intval($user_id);
 
        $strSql = "
            DELETE FROM b_blog_post_param
            WHERE
                ".($post_id <= 0 ? "POST_ID IS NULL " : "POST_ID=".$post_id)."
            AND ".($user_id <= 0 ? "USER_ID IS NULL " : "USER_ID=".$user_id)."
            AND NAME='".$DB->ForSql($name, 50)."'
        ";
        if ($DB->Query($strSql))
        {
            self::_clear_cache($user_id);
            return true;
        }
        return false;
    }
 
    public static function DeleteUsersOptions($user_id=false)
    {
        global $DB;
        $user_id = intval($user_id);
        if ($DB->Query("DELETE FROM b_blog_post_param WHERE ".($user_id <= 0 ? "USER_ID IS NULL" : "USER_ID=".$user_id)))
        {
            self::_clear_cache($user_id);
            return true;
        }
        return false;
    }
 
    //*****************************
    // Events
    //*****************************
 
    //user deletion event
    public static function OnUserDelete($user_id)
    {
        global $DB;
        $user_id = intval($user_id);
 
        if ($DB->Query("DELETE FROM b_user_option WHERE USER_ID=". $user_id))
        {
            self::_clear_cache($user_id);
            return true;
        }
        return false;
    }
 
    protected static function _clear_cache($user_id = 0)
    {
        global $CACHE_MANAGER;
 
        self::$__USER_OPTIONS_CACHE = array();
 
        if ($user_id > 0)
            $CACHE_MANAGER->cleanDir("blog_post_param");
        else
            $CACHE_MANAGER->clean("user_option:$user_id", "blog_post_param");
    }
}
?>