<?php



/**

 * ECSHOP 团购商品前台文件

 * ============================================================================

 * * 版权所有 2005-2012 上海商派网络科技有限公司，并保留所有权利。

 * 网站地址: http://www.ecshop.com；

 * ----------------------------------------------------------------------------

 * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和

 * 使用；不允许对程序代码以任何形式任何目的的再发布。

 * ============================================================================

 * $Author: liubo $

 * $Id: group_buy.php 17217 2011-01-19 06:29:08Z liubo $

 */



define('IN_ECTOUCH', true);



require(dirname(__FILE__) . '/include/init.php');



if ((DEBUG_MODE & 2) != 2)

{

    $smarty->caching = true;

}



/*------------------------------------------------------ */

//-- act 操作项的初始化

/*------------------------------------------------------ */

if (empty($_REQUEST['act']))

{

    $_REQUEST['act'] = 'list';

}



/*------------------------------------------------------ */

//-- 团购商品 --> 团购活动商品列表

/*------------------------------------------------------ */

if ($_REQUEST['act'] == 'list')

{

    /* 取得团购活动总数 */

    $count = group_buy_count();

    if ($count > 0)

    {

        /* 取得每页记录数 */

        $size = isset($_CFG['page_size']) && intval($_CFG['page_size']) > 0 ? intval($_CFG['page_size']) : 10;



        /* 计算总页数 */

        $page_count = ceil($count / $size);



        /* 取得当前页 */

        $page = isset($_REQUEST['page']) && intval($_REQUEST['page']) > 0 ? intval($_REQUEST['page']) : 1;

        $page = $page > $page_count ? $page_count : $page;



        /* 缓存id：语言 - 每页记录数 - 当前页 */

        $cache_id = $_CFG['lang'] . '-' . $size . '-' . $page;

        $cache_id = sprintf('%X', crc32($cache_id));

    }

    else

    {

        /* 缓存id：语言 */

        $cache_id = $_CFG['lang'];

        $cache_id = sprintf('%X', crc32($cache_id));

    }



    /* 如果没有缓存，生成缓存 */

    if (!$smarty->is_cached('group_buy_list.dwt', $cache_id))

    {

        if ($count > 0)

        {

            /* 取得当前页的团购活动 */

            $gb_list = group_buy_list($size, $page);

            $smarty->assign('gb_list',  $gb_list);

            // print_r( $gb_list );

            /* 设置分页链接 */

            $pager = get_pager('group_buy.php', array('act' => 'list'), $count, $page, $size);

            $smarty->assign('pager', $pager);

        }



        /* 模板赋值 */

        $smarty->assign('cfg', $_CFG);

        assign_template();

        $position = assign_ur_here();

        $smarty->assign('page_title', $position['title']);    // 页面标题

        $smarty->assign('ur_here',    $position['ur_here']);  // 当前位置

        $smarty->assign('categories', get_categories_tree()); // 分类树

        $smarty->assign('helps',      get_shop_help());       // 网店帮助

        $smarty->assign('top_goods',  get_top10());           // 销售排行

        $smarty->assign('promotion_info', get_promotion_info());

        $smarty->assign('feed_url',         ($_CFG['rewrite'] == 1) ? "feed-typegroup_buy.xml" : 'feed.php?type=group_buy'); // RSS URL



        assign_dynamic('group_buy_list');

    }



    /* 显示模板 */

    $smarty->display('group_buy_list.dwt', $cache_id);

}



/*------------------------------------------------------ */

//-- 团购商品 --> 团购活动商品列表

/*------------------------------------------------------ */

if ($_REQUEST['act'] == 'asynclist')

{

    /* 取得团购活动总数 */

    $count = group_buy_count();

    if ($count > 0)

    {

        /* 取得每页记录数 */

        $size = isset($_CFG['page_size']) && intval($_CFG['page_size']) > 0 ? intval($_CFG['page_size']) : 10;



        /* 计算总页数 */

        $page_count = ceil($count / $size);



        /* 取得当前页 */

        $page = isset($_REQUEST['page']) && intval($_REQUEST['page']) > 0 ? intval($_REQUEST['page']) : 1;

        $page = $page > $page_count ? $page_count : $page;



        /* 缓存id：语言 - 每页记录数 - 当前页 */

        $cache_id = $_CFG['lang'] . '-' . $size . '-' . $page;

        $cache_id = sprintf('%X', crc32($cache_id));

    }

    else

    {

        /* 缓存id：语言 */

        $cache_id = $_CFG['lang'];

        $cache_id = sprintf('%X', crc32($cache_id));

    }



     /*

     * 异步显示商品列表 by wang

     */

    if ($_GET['act'] == 'asynclist') {

        $asyn_last = intval($_POST['last']) + 1;

        $size = $_POST['amount'];

        $page = ($asyn_last > 0) ? ceil($asyn_last / $size) : 1;

    }

    $goodslist = group_buy_list($size, $page);

    $sayList = array();

    if (is_array($goodslist)) {

        foreach ($goodslist as $vo) {

            $sayList[] = array(

                'pro-inner' => '

        <div class="proImg-wrap"> <a href="' . $vo['url'] . '" > <img src="' . $config['site_url'] . $vo['goods_thumb'] . '" alt="' . $vo['goods_name'] . '"> </a> </div>

        <div class="proInfo-wrap">

          <div class="proTitle"> <a href="' . $vo['url'] . '" >' . $vo['goods_name'] . '</a> </div>

          <div class="proSKU"></div>

          <div class="proPrice">

            <em>' . $vo['lowest_price'] . '</em> 

          </div>

        </div>'

            );

        }

    }

   //  print_r( $goodslist  );

    echo json_encode($sayList);

    exit;

    /*

     * 异步显示商品列表 by wang end

     */



    /* 如果没有缓存，生成缓存 */

    if (!$smarty->is_cached('group_buy_list.dwt', $cache_id))

    {

        if ($count > 0)

        {

            /* 取得当前页的团购活动 */

            $gb_list = group_buy_list($size, $page);

            $smarty->assign('gb_list',  $gb_list);

            // print_r( $gb_list );

            /* 设置分页链接 */

            $pager = get_pager('group_buy.php', array('act' => 'list'), $count, $page, $size);

            $smarty->assign('pager', $pager);

        }



        /* 模板赋值 */

        $smarty->assign('cfg', $_CFG);

        assign_template();

        $position = assign_ur_here();

        $smarty->assign('page_title', $position['title']);    // 页面标题

        $smarty->assign('ur_here',    $position['ur_here']);  // 当前位置

        $smarty->assign('categories', get_categories_tree()); // 分类树

        $smarty->assign('helps',      get_shop_help());       // 网店帮助

        $smarty->assign('top_goods',  get_top10());           // 销售排行

        $smarty->assign('promotion_info', get_promotion_info());

        $smarty->assign('feed_url',         ($_CFG['rewrite'] == 1) ? "feed-typegroup_buy.xml" : 'feed.php?type=group_buy'); // RSS URL



        assign_dynamic('group_buy_list');

    }



    /* 显示模板 */

    $smarty->display('group_buy_list.dwt', $cache_id);

}



/*------------------------------------------------------ */

//-- 团购商品 --> 商品详情

/*------------------------------------------------------ */

elseif ($_REQUEST['act'] == 'view')

{

    /* 取得参数：团购活动id */

    $group_buy_id = isset($_REQUEST['id']) ? intval($_REQUEST['id']) : 0;

    if ($group_buy_id <= 0)

    {

        ecs_header("Location: ./\n");

        exit;

    }



    /* 取得团购活动信息 */

    $group_buy = group_buy_info($group_buy_id);



    if (empty($group_buy))

    {

        ecs_header("Location: ./\n");

        exit;

    }

//    elseif ($group_buy['is_on_sale'] == 0 || $group_buy['is_alone_sale'] == 0)

//    {

//        header("Location: ./\n");

//        exit;

//    }



    /* 缓存id：语言，团购活动id，状态，（如果是进行中）当前数量和是否登录 */

    $cache_id = $_CFG['lang'] . '-' . $group_buy_id . '-' . $group_buy['status'];

    if ($group_buy['status'] == GBS_UNDER_WAY)

    {

        $cache_id = $cache_id . '-' . $group_buy['valid_goods'] . '-' . intval($_SESSION['user_id'] > 0);

    }

    $cache_id = sprintf('%X', crc32($cache_id));



    /* 如果没有缓存，生成缓存 */

    if (!$smarty->is_cached('group_buy_goods.dwt', $cache_id))

    {

        $group_buy['gmt_end_date'] = $group_buy['end_date'];

        $smarty->assign('group_buy', $group_buy);



        /* 取得团购商品信息 */

        $goods_id = $group_buy['goods_id'];

        $goods = goods_info($goods_id);

        if (empty($goods))

        {

            ecs_header("Location: ./\n");

            exit;

        }

        $goods['url'] = build_uri('goods', array('gid' => $goods_id), $goods['goods_name']);

        $smarty->assign('gb_goods', $goods);



        /* 取得商品的规格 */

        $properties = get_goods_properties($goods_id);

        $smarty->assign('specification', $properties['spe']); // 商品规格



        //模板赋值

       // print_r( $_CFG['show_goodssn'] );

        $smarty->assign('cfg', $_CFG);

        assign_template();



        $position = assign_ur_here(0, $goods['goods_name']);

        $smarty->assign('page_title', $position['title']);    // 页面标题

        $smarty->assign('ur_here',    $position['ur_here']);  // 当前位置



        $smarty->assign('categories', get_categories_tree()); // 分类树

        $smarty->assign('helps',      get_shop_help());       // 网店帮助

        $smarty->assign('top_goods',  get_top10());           // 销售排行

        $smarty->assign('promotion_info', get_promotion_info());

        assign_dynamic('group_buy_goods');

    }



    //更新商品点击次数

    $sql = 'UPDATE ' . $ecs->table('goods') . ' SET click_count = click_count + 1 '.

           "WHERE goods_id = '" . $group_buy['goods_id'] . "'";

    $db->query($sql);



    $smarty->assign('now_time',  gmtime());           // 当前系统时间

    $smarty->display('group_buy_goods.dwt', $cache_id);

}



/*------------------------------------------------------ */

//-- 团购商品 --> 购买

/*------------------------------------------------------ */



elseif ($_REQUEST['act'] == 'buy')

{

    /* 查询：判断是否登录 */

    if ($_SESSION['user_id'] <= 0)

    {

        show_message($_LANG['gb_error_login'], '', '', 'error');

    }



    /* 查询：取得参数：团购活动id */

    $group_buy_id = isset($_POST['group_buy_id']) ? intval($_POST['group_buy_id']) : 0;

    if ($group_buy_id <= 0)

    {

        ecs_header("Location: ./\n");

        exit;

    }



    /* 查询：取得数量 */

    $number = isset($_POST['number']) ? intval($_POST['number']) : 1;

    $number = $number < 1 ? 1 : $number;



    /* 查询：取得团购活动信息 */

    $group_buy = group_buy_info($group_buy_id, $number);

    if (empty($group_buy))

    {

        ecs_header("Location: ./\n");

        exit;

    }



    /* 查询：检查团购活动是否是进行中 */

    if ($group_buy['status'] != GBS_UNDER_WAY)

    {

        show_message($_LANG['gb_error_status'], '', '', 'error');

    }



    /* 查询：取得团购商品信息 */

    $goods = goods_info($group_buy['goods_id']);

    if (empty($goods))

    {

        ecs_header("Location: ./\n");

        exit;

    }



    /* 查询：判断数量是否足够 */

    if (($group_buy['restrict_amount'] > 0 && $number > ($group_buy['restrict_amount'] - $group_buy['valid_goods'])) || $number > $goods['goods_number'])

    {

        show_message($_LANG['gb_error_goods_lacking'], '', '', 'error');

    }



    /* 查询：取得规格 */

    $specs = '';

    foreach ($_POST as $key => $value)

    {

        if (strpos($key, 'spec_') !== false)

        {

            $specs .= ',' . intval($value);

        }

    }

    $specs = trim($specs, ',');



    /* 查询：如果商品有规格则取规格商品信息 配件除外 */

    if ($specs)

    {

        $_specs = explode(',', $specs);

        $product_info = get_products_info($goods['goods_id'], $_specs);

    }



    empty($product_info) ? $product_info = array('product_number' => 0, 'product_id' => 0) : '';



    /* 查询：判断指定规格的货品数量是否足够 */

    if ($specs && $number > $product_info['product_number'])

    {

        show_message($_LANG['gb_error_goods_lacking'], '', '', 'error');

    }



    /* 查询：查询规格名称和值，不考虑价格 */

    $attr_list = array();

    $sql = "SELECT a.attr_name, g.attr_value " .

            "FROM " . $ecs->table('goods_attr') . " AS g, " .

                $ecs->table('attribute') . " AS a " .

            "WHERE g.attr_id = a.attr_id " .

            "AND g.goods_attr_id " . db_create_in($specs);

    $res = $db->query($sql);

    while ($row = $db->fetchRow($res))

    {

        $attr_list[] = $row['attr_name'] . ': ' . $row['attr_value'];

    }

    $goods_attr = join(chr(13) . chr(10), $attr_list);



    /* 更新：清空购物车中所有团购商品 */

    include_once(ROOT_PATH . 'include/lib_order.php');

    clear_cart(CART_GROUP_BUY_GOODS);



    /* 更新：加入购物车 */

    $goods_price = $group_buy['deposit'] > 0 ? $group_buy['deposit'] : $group_buy['cur_price'];

    $cart = array(

        'user_id'        => $_SESSION['user_id'],

        'session_id'     => SESS_ID,

        'goods_id'       => $group_buy['goods_id'],

        'product_id'     => $product_info['product_id'],

        'goods_sn'       => addslashes($goods['goods_sn']),

        'goods_name'     => addslashes($goods['goods_name']),
		
		'is_shipping'       => $group_buy['is_shipping'],

        'market_price'   => $goods['market_price'],

        'goods_price'    => $goods_price,

        'goods_number'   => $number,

        'goods_attr'     => addslashes($goods_attr),

        'goods_attr_id'  => $specs,

        'is_real'        => $goods['is_real'],

        'extension_code' => addslashes($goods['extension_code']),

        'parent_id'      => 0,

        'rec_type'       => CART_GROUP_BUY_GOODS,

        'is_gift'        => 0

    );

    $db->autoExecute($ecs->table('cart'), $cart, 'INSERT');



    /* 更新：记录购物流程类型：团购 */

 	$_SESSION['sel_cartgoods'] = $db->insert_id();//增加购物车选择性结算

    $_SESSION['flow_type'] = CART_GROUP_BUY_GOODS;

    $_SESSION['extension_code'] = 'group_buy';

    $_SESSION['extension_id'] = $group_buy_id;



    /* 进入收货人页面 */

    ecs_header("Location: ./flow.php?step=consignee\n");

    exit;

}

/**

 * 团购商品加入购物车

 */ 

elseif ($_REQUEST['act'] == 'buy_to_cart') {

    

        

   /* 查询：判断是否登录 */

    if ($_SESSION['user_id'] <= 0)

    {

         $result['error'] = 8; // 没有登录 

         $result['goods_id'] = $goods->goods_id;

         $result['parent'] = $goods->parent;

         $result['message'] = $spe_array;

         die($json->encode($result));

    }

    include_once('include/cls_json.php');

    $_POST['goods'] = strip_tags(urldecode($_POST['goods']));

    $_POST['goods'] = json_str_iconv($_POST['goods']);



    if (!empty($_REQUEST['goods_id']) && empty($_POST['goods'])) {

        if (!is_numeric($_REQUEST['goods_id']) || intval($_REQUEST['goods_id']) <= 0) {

            ecs_header("Location:./\n");

        }

        $goods_id = intval($_REQUEST['goods_id']);

        exit;

    } 

    $result = array('error' => 0, 'message' => '', 'content' => '', 'goods_id' => '');

    $json = new JSON;



    if (empty($_POST['goods'])) {

        $result['error'] = 1;

        die($json->encode($result));

    }



    $goods = $json->decode($_POST['goods']);

    /* 查询：取得团购活动信息 */

    $group_buy = group_buy_info($goods->goods_id, $goods->number);

    if (empty($group_buy))

    {

        ecs_header("Location: ./\n");

        exit;   

    }

    /* 查询：检查团购活动是否是进行中 */

    if ($group_buy['status'] != GBS_UNDER_WAY)

    {

        $result['error'] = 10; //该活动已结束 

        $result['goods_id'] = $goods->goods_id;

        $result['parent'] = $goods->parent;

        $result['message'] = $spe_array;

        die($json->encode($result));

    }

     /* 查询：取得团购商品信息 */

    $goods = goods_info( $group_buy['goods_id'] );

    if (empty($goods))

    {

        ecs_header("Location: ./\n");

        exit;

    }

     /* 检查：如果商品有规格，而post的数据没有规格，把商品的规格属性通过JSON传到前台 */

    if (empty($goods->spec) AND empty($goods->quick))

    {

        $sql = "SELECT a.attr_id, a.attr_name, a.attr_type, ".

            "g.goods_attr_id, g.attr_value, g.attr_price " .

        'FROM ' . $GLOBALS['ecs']->table('goods_attr') . ' AS g ' .

        'LEFT JOIN ' . $GLOBALS['ecs']->table('attribute') . ' AS a ON a.attr_id = g.attr_id ' .

        "WHERE a.attr_type != 0 AND g.goods_id = '" . $goods->goods_id . "' " .

        'ORDER BY a.sort_order, g.attr_price, g.goods_attr_id';



        $res = $GLOBALS['db']->getAll($sql);



        if (!empty($res))

        {

            $spe_arr = array();

            foreach ($res AS $row)

            {

                $spe_arr[$row['attr_id']]['attr_type'] = $row['attr_type'];

                $spe_arr[$row['attr_id']]['name']     = $row['attr_name'];

                $spe_arr[$row['attr_id']]['attr_id']     = $row['attr_id'];

                $spe_arr[$row['attr_id']]['values'][] = array(

                                                            'label'        => $row['attr_value'],

                                                            'price'        => $row['attr_price'],

                                                            'format_price' => price_format($row['attr_price'], false),

                                                            'id'           => $row['goods_attr_id']);

            }

            $i = 0;

            $spe_array = array();

            foreach ($spe_arr AS $row)

            {

                $spe_array[]=$row;

            }

            $result['error']   = ERR_NEED_SELECT_ATTR;

            $result['goods_id'] = $goods->goods_id;

            $result['parent'] = $goods->parent;

            $result['message'] = $spe_array;



            die($json->encode($result));

        }

    }



    /* 查询：如果商品有规格则取规格商品信息 配件除外 */

    if ($specs)

    {

        $_specs = explode(',', $specs);

        $product_info = get_products_info($goods['goods_id'], $_specs);

    }



    empty($product_info) ? $product_info = array('product_number' => 0, 'product_id' => 0) : '';

      /* 查询：判断指定规格的货品数量是否足够 */

    if ($specs && $number > $product_info['product_number'])

    {

        $result['error']   = ERR_NEED_SELECT_ATTR;

        $result['goods_id'] = $goods->goods_id;

        $result['parent'] = $goods->parent;

        $result['message'] = $spe_array;

        die($json->encode($result));

    }  

    

    /* 查询：查询规格名称和值，不考虑价格 */

    $attr_list = array();

    $sql = "SELECT a.attr_name, g.attr_value " .

            "FROM " . $ecs->table('goods_attr') . " AS g, " .

                $ecs->table('attribute') . " AS a " .

            "WHERE g.attr_id = a.attr_id " .

            "AND g.goods_attr_id " . db_create_in($specs);

    $res = $db->query($sql);

    while ($row = $db->fetchRow($res))

    {

        $attr_list[] = $row['attr_name'] . ': ' . $row['attr_value'];

    }

    $goods_attr = join(chr(13) . chr(10), $attr_list);



    /* 更新：清空购物车中所有团购商品 */

    include_once(ROOT_PATH . 'includes/lib_order.php');

    clear_cart(CART_GROUP_BUY_GOODS);

    /* 更新：加入购物车 */

    $goods_price = $group_buy['deposit'] > 0 ? $group_buy['deposit'] : $group_buy['cur_price'];

    $cart = array(

       'user_id'        => $_SESSION['user_id'],

       'session_id'     => SESS_ID,

       'goods_id'       => $group_buy['goods_id'],

       'product_id'     => $product_info['product_id'],

       'goods_sn'       => addslashes($goods['goods_sn']),

       'goods_name'     => addslashes($goods['goods_name']),

       'market_price'   => $goods['market_price'],

       'goods_price'    => $goods_price,

       'goods_number'   => $number,

       'goods_attr'     => addslashes($goods_attr),

       'goods_attr_id'  => $specs,

       'is_real'        => $goods['is_real'],

       'extension_code' => addslashes($goods['extension_code']),

       'parent_id'      => 0,

       'rec_type'       => CART_GROUP_BUY_GOODS,

       'is_gift'        => 0

    );

    $db->autoExecute($ecs->table('cart'), $cart, 'INSERT');

    /* 更新：记录购物流程类型：团购 */

    $_SESSION['flow_type'] = CART_GROUP_BUY_GOODS;

    $_SESSION['extension_code'] = 'group_buy';

    $_SESSION['extension_id'] = $group_buy_id;

        

    $result['confirm_type'] = !empty($_CFG['cart_confirm']) ? $_CFG['cart_confirm'] : 2;

    die($json->encode($result));

}

/* 取得团购活动总数 */

function group_buy_count()

{

    $now = gmtime();

    $sql = "SELECT COUNT(*) " .

            "FROM " . $GLOBALS['ecs']->table('goods_activity') .

            "WHERE act_type = '" . GAT_GROUP_BUY . "' " .

            "AND start_time <= '$now' AND is_finished < 3";



    return $GLOBALS['db']->getOne($sql);

}



/**

 * 取得某页的所有团购活动

 * @param   int     $size   每页记录数

 * @param   int     $page   当前页

 * @return  array

 */

function group_buy_list($size, $page)

{

    /* 取得团购活动 */

    $gb_list = array();

    $now = gmtime();

    $sql = "SELECT b.*, IFNULL(g.goods_thumb, '') AS goods_thumb, b.act_id AS group_buy_id, ".

                "b.start_time AS start_date, b.end_time AS end_date " .

            "FROM " . $GLOBALS['ecs']->table('goods_activity') . " AS b " .

                "LEFT JOIN " . $GLOBALS['ecs']->table('goods') . " AS g ON b.goods_id = g.goods_id " .

            "WHERE b.act_type = '" . GAT_GROUP_BUY . "' " .

            "AND b.start_time <= '$now' AND b.is_finished < 3 ORDER BY b.act_id DESC";

    $res = $GLOBALS['db']->selectLimit($sql, $size, ($page - 1) * $size);

    while ($group_buy = $GLOBALS['db']->fetchRow($res))

    {

        $ext_info = unserialize($group_buy['ext_info']);

        $group_buy = array_merge($group_buy, $ext_info);



        /* 格式化时间 */

        $group_buy['formated_start_date']   = local_date($GLOBALS['_CFG']['time_format'], $group_buy['start_date']);

        $group_buy['formated_end_date']     = local_date($GLOBALS['_CFG']['time_format'], $group_buy['end_date']);



        /* 格式化保证金 */

        $group_buy['formated_deposit'] = price_format($group_buy['deposit'], false);

        /* 处理价格阶梯 */

        $price_ladder = $group_buy['price_ladder'];

        if (!is_array($price_ladder) || empty($price_ladder))

        {

            $price_ladder = array(array('amount' => 0, 'price' => 0));

        }

        else

        {

            foreach ($price_ladder as $key => $amount_price)

            {

                $price_ladder[$key]['formated_price'] = price_format($amount_price['price']);

            }

        }

        $group_buy['price_ladder'] = $price_ladder;

        $group_buy['lowest_price'] = price_format(get_lowest_price( $price_ladder ));

                 

        /* 处理图片 */

        if (empty($group_buy['goods_thumb']))

        {

            $group_buy['goods_thumb'] = get_image_path($group_buy['goods_id'], $group_buy['goods_thumb'], true);

        }

        /* 处理链接 */

        $group_buy['url'] = build_uri('group_buy', array('gbid'=>$group_buy['group_buy_id']));

        /* 加入数组 */

        $gb_list[] = $group_buy;

    }



    return $gb_list;

}



function get_lowest_price( $price_ladder ){

    

   if(is_array( $price_ladder)){

       

      $aa = array();

      foreach( $price_ladder as $key => $value){

          

           $aa[] = $value['price'];

          

          

      }

      sort($aa);

    

      return $aa[0];

       

   }

    

}

?>