<?php


namespace Module\Vendor\Provider\Recommend;

abstract class AbstractRecommendBiz
{
    abstract public function name();

    abstract public function title();

    abstract public function providerName();

    /**
     * 批量同步
     * @param $nextId int 下一个ID
     * @param $param array 参数
     * @return array
     * @returnExample
     * {
     *  "code": 0,
     *  "msg": "ok"
     *  "data": {
     *    "nextId": 0,
     *    "records:[
     *      {
     *        "biz": "cms",
     *        "bizId": 1,
     *        "sceneId": 1,
     *        "tags": ["tag1", "tag2"],
     *        "param": {}
     *      }
     *    ]
     * }
     */
    abstract public function syncBatch($nextId, $param = []);


    public static function itemUpdate($bizId, $sceneId = 0, $tags = [], $param = [])
    {
        $biz = RecommendBiz::getByName(static::NAME);
        if (!$biz) {
            return;
        }
        foreach (RecommendProvider::listAll() as $provider) {
            if ($biz->providerName() != $provider->name()) {
                continue;
            }
            $provider->itemUpdate(
                $biz->name(),
                $bizId,
                $sceneId,
                $tags,
                $param
            );
        }
    }

    public static function itemDelete($bizId, $param = [])
    {
        $biz = RecommendBiz::getByName(static::NAME);
        if (!$biz) {
            return;
        }
        foreach (RecommendProvider::listAll() as $provider) {
            if ($biz->providerName() != $provider->name()) {
                continue;
            }
            $provider->itemDelete(
                $biz->name(),
                $bizId,
                $param
            );
        }
    }

    public static function itemTrash($param = [])
    {
        $biz = RecommendBiz::getByName(static::NAME);
        if (!$biz) {
            return;
        }
        foreach (RecommendProvider::listAll() as $provider) {
            if ($biz->providerName() != $provider->name()) {
                continue;
            }
            $provider->itemTrash($biz->name(), $param);
        }
    }

    public static function itemCount($param = [])
    {
        $biz = RecommendBiz::getByName(static::NAME);
        if (!$biz) {
            return;
        }
        foreach (RecommendProvider::listAll() as $provider) {
            if ($biz->providerName() != $provider->name()) {
                continue;
            }
            $provider->itemCount($biz->name(), $param);
        }
    }

    public static function itemFeedback($bizId, $userId, $type, $param = [])
    {
        $biz = RecommendBiz::getByName(static::NAME);
        if (!$biz) {
            return;
        }
        foreach (RecommendProvider::listAll() as $provider) {
            if ($biz->providerName() != $provider->name()) {
                continue;
            }
            $provider->itemFeedback(
                $biz->name(),
                $bizId,
                $userId,
                $type,
                $param
            );
        }
    }

    public static function itemFeedbackVisit($bizId, $userId, $param = [])
    {
        self::itemFeedback($bizId, $userId, RecommendUserFeedbackType::VISIT, $param);
    }

    public static function itemFeedbackLike($bizId, $userId, $param = [])
    {
        self::itemFeedback($bizId, $userId, RecommendUserFeedbackType::LIKE, $param);
    }

    public static function itemFeedbackDislike($bizId, $userId, $param = [])
    {
        self::itemFeedback($bizId, $userId, RecommendUserFeedbackType::DISLIKE, $param);
    }

    public static function randomItemsFromCallback($itemIdsToItemsCallback, $idKey = 'id', $userId = 0, $limit = 1, $sceneIds = [], $tags = [], $exceptBizIds = [], $param = [])
    {
        $itemIds = static::randomItemIds($userId, $limit, $sceneIds, $tags, $exceptBizIds, $param);
        if (empty($itemIds)) {
            return [];
        }
        $items = call_user_func_array($itemIdsToItemsCallback, [$itemIds]);
        if (empty($items)) {
            return [];
        }
        $validItemIds = [];
        foreach ($items as $item) {
            if (isset($item[$idKey]) && in_array($item[$idKey], $itemIds)) {
                $validItemIds[] = $item[$idKey];
            }
        }
        foreach ($itemIds as $itemId) {
            if (!in_array($itemId, $validItemIds)) {
                static::itemDelete($itemId, $param);
            }
        }
        return $items;
    }

    public static function randomItemIds($userId, $limit = 1, $sceneIds = [], $tags = [], $exceptBizIds = [], $param = [])
    {
        $biz = RecommendBiz::getByName(static::NAME);
        if (!$biz) {
            return [];
        }
        $provider = RecommendProvider::getByName($biz->providerName());
        if (!$provider) {
            return [];
        }
        $ret = $provider->randomItem(
            $biz->name(),
            $userId,
            $limit,
            $sceneIds,
            $tags,
            $exceptBizIds,
            $param
        );
        if (isset($ret['data']['bizIds'])) {
            return $ret['data']['bizIds'];
        }
        return [];
    }
}