zoumaliveServer/mapi/lib/svideo.action.php

<?php


class svideoModule extends baseModule
{
    public function index()
    {
        if (!$GLOBALS['user_info']) {
            $user_id = 0;
        } else {
            $user_id = intval($GLOBALS['user_info']['id']);
        }
        $page = intval($_REQUEST['page']) ? intval($_REQUEST['page']) : 1;

        $root = array(
            'has_next' => 1,
            'page' => $page,
            'status' => 1,
            'error' => ''
        );
        $page_size = 20;
        $list = load_auto_cache("svideo_select_weibo_recommend",
            array('page' => $page, 'page_size' => $page_size, 'user_id' => $user_id, 'type' => 'video'));
        $root['list'] = $list;
        for($i=0;$i<count($root['list']);$i++)
        {
            $root['list'][$i]['nick_name'] = emoji_decode($root['list'][$i]['nick_name']);
        }
        
        if (count($list) == $page_size) {
            $root['has_next'] = 1;
        } else {
            $root['has_next'] = 0;
        }

        api_ajax_return($root);
    }

    public function video()
    {
        if (!$GLOBALS['user_info']['id']) {
            //有这个参数： user_login_status = 0 时，表示服务端未登陆、要求登陆，操作
            return api_ajax_return(array(
                'error' => '用户未登陆,请先登陆.',
                'status' => 0,
                'user_login_status' => 0,
            ));
        }

        $user_id = intval($GLOBALS['user_info']['id']);
        $to_user_id = intval($_REQUEST['to_user_id']);//被查看的用户ID
        if (!$to_user_id) {
            $to_user_id = $user_id;
        }

        $page = intval($_REQUEST['page']); //取第几页数据
        $page = $page >= 1 ? $page : 1;
        $page_size = 10;

        fanwe_require(APP_ROOT_PATH . 'mapi/lib/redis/UserFollwRedisService.php');

        if ($user_id == $to_user_id) {
            $list = load_auto_cache("edu_select_weibo_list",
                array('page' => $page, 'page_size' => $page_size, 'user_id' => $user_id, 'type' => 'video'));
            foreach ($list as $k => $v)
            {
                $list[$k]['nick_name'] = emoji_decode($list[$k]['nick_name']);
                $list[$k]['content'] = emoji_decode($list[$k]['content']);
            }
        } else {
            $list = load_auto_cache("select_weibo_other_list",
                array('page' => $page, 'page_size' => $page_size, 'to_user_id' => $to_user_id, 'type' => 'video'));
            if ($user_id > 0) {
                $pay_digg_list = load_auto_cache("select_user_pay_list",
                    array('page' => $page, 'page_size' => $page_size, 'user_id' => $user_id));
                $diggs_array = $pay_digg_list['digg'];

                $user_redis = new UserFollwRedisService($user_id);
                $root['is_focus'] = intval($user_redis->is_following($to_user_id));
            } else {
                $diggs_array = array();
            }

            foreach ($list as $k => $v) {
                if (in_array($v['weibo_id'], $diggs_array)) {
                    $list[$k]['has_digg'] = 1;
                }
                if ($user_id != $v['user_id']) {
                    $list[$k]['is_top'] = 0;
                }
                $list[$k]['nick_name'] = emoji_decode($list[$k]['nick_name']);
                $list[$k]['content'] = emoji_decode($list[$k]['content']);
            }
        }

        return api_ajax_return(array(
            'status' => 1,
            'list' => $list,
            'has_next' => count($list) == $page_size ? 1 : 0,
            'page' => $page,
        ));
    }


    public function add_favor()
    {
        if (!$GLOBALS['user_info']['id']) {
            //有这个参数： user_login_status = 0 时，表示服务端未登陆、要求登陆，操作
            return api_ajax_return(array(
                'error' => '用户未登陆,请先登陆.',
                'status' => 0,
                'user_login_status' => 0,
            ));
        }
        $user_id = $GLOBALS['user_info']['id'];
        $weibo_id = intval($_REQUEST['weibo_id']);

        if ($weibo_id > 0) {
            $weibo_exists = $GLOBALS['db']->getOne("select count(*) from fanwe_weibo where id = " . $weibo_id);
            if (!$weibo_exists) {
                return api_ajax_return(array('status' => 0, 'error' => '小视频不存在'));
            }

            $exists = $GLOBALS['db']->getOne("select count(*) from " . DB_PREFIX . "qk_svideo_favor f where user_id = {$user_id} and weibo_id = {$weibo_id}");
            if (!$exists) {
                $GLOBALS['db']->autoExecute(DB_PREFIX . "qk_svideo_favor",
                    array('user_id' => $user_id, 'weibo_id' => $weibo_id, 'create_time' => NOW_TIME), 'INSERT');
            } else {
                $this->del_favor();
            }
        }

        return api_ajax_return(array('status' => 1, 'has_favor' => 1));
    }

    public function del_favor()
    {
        if (!$GLOBALS['user_info']['id']) {
            //有这个参数： user_login_status = 0 时，表示服务端未登陆、要求登陆，操作
            return api_ajax_return(array(
                'error' => '用户未登陆,请先登陆.',
                'status' => 0,
                'user_login_status' => 0,
            ));
        }
        $user_id = $GLOBALS['user_info']['id'];
        $weibo_id = intval($_REQUEST['weibo_id']);

        $GLOBALS['db']->query("delete from " . DB_PREFIX . "qk_svideo_favor where user_id = {$user_id} and weibo_id = {$weibo_id}");

        return api_ajax_return(array('status' => 1, 'has_favor' => 0));
    }


    //我的收藏
    public function favor()
    {
        if (!$GLOBALS['user_info']['id']) {
            //有这个参数： user_login_status = 0 时，表示服务端未登陆、要求登陆，操作
            return api_ajax_return(array(
                'error' => '用户未登陆,请先登陆.',
                'status' => 0,
                'user_login_status' => 0,
            ));
        }
        $user_id = $GLOBALS['user_info']['id'];
        $page_size = 20;

        $page = intval($_REQUEST['page']) ? intval($_REQUEST['page']) : 1;
        $limit = (($page - 1) * $page_size) . "," . $page_size;
        $sql = "SELECT w.user_id,w.id as weibo_id,u.head_image,u.is_authentication,w.content,w.red_count,w.digg_count,w.comment_count,w.video_count,w.data,u.nick_name,w.sort_num,w.photo_image,w.is_top ,u.city,w.price,w.type,w.create_time,w.city,w.province,w.address
FROM
    " . DB_PREFIX . "qk_svideo_favor as f join " . DB_PREFIX . "weibo as w on f.weibo_id = w.id
    left join " . DB_PREFIX . "user as u on w.user_id = u.id 
WHERE f.user_id = {$user_id} order by f.id desc limit {$limit}";

        fanwe_require(APP_ROOT_PATH . 'mapi/xr/core/common.php');
        $items = $GLOBALS['db']->getAll($sql);
        foreach ($items as &$item) {
            $item['head_image'] = deal_weio_image($item['head_image'], 'head_image');
            $item['photo_image'] = deal_weio_image($item['photo_image'], $item['type']);
        }
        unset($item);

        api_ajax_return(array(
            'items' => $items,
            'has_next' => count($items) == $page_size ? 1 : 0,
            'page' => $page,
            'status' => 1,
            'error' => ''
        ));
    }
}