<?php


/**
 * 取得云购活动信息
 * @param   int $lucky_buy_id 云购活动id
 * @param   int $current_num 本次购买数量（计算当前价时要加上的数量）
 * @return  array
 *                  status          状态：
 */
function lucky_buy_info($lucky_buy_id, $current_num = 0)
{
	/* 取得云购活动信息 */
	$lucky_buy_id = intval($lucky_buy_id);
	$sql = "SELECT *, act_id AS lucky_buy_id, act_desc AS lucky_buy_desc, start_time AS start_date, end_time AS end_date " .
		"FROM " . $GLOBALS['ecs']->table('goods_activity') .
		"WHERE act_id = '$lucky_buy_id' " .
		"AND act_type = '" . GAT_LUCKY_BUY . "'";
	$lucky_buy = $GLOBALS['db']->getRow($sql);

	/* 如果为空，返回空数组 */
	if (empty($lucky_buy)) {
		return array();
	}

	$ext_info = unserialize($lucky_buy['ext_info']);
	$lucky_buy = array_merge($lucky_buy, $ext_info);

	/* 格式化时间 */
	$lucky_buy['formated_start_date'] = local_date('Y-m-d H:i', $lucky_buy['start_time']);
	$lucky_buy['formated_end_date'] = local_date('Y-m-d H:i', $lucky_buy['end_time']);

	/* 格式化保证金 */
	$lucky_buy['formated_deposit'] = price_format($lucky_buy['deposit'], false);

	/* 处理价格阶梯 */
	$price_ladder = $lucky_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'], false);
		}
	}
	$lucky_buy['price_ladder'] = $price_ladder;

	/* 统计信息 */
	$stat = lucky_buy_stat($lucky_buy_id, $lucky_buy['deposit']);
	$lucky_buy = array_merge($lucky_buy, $stat);

	/* 计算当前价 */
	$cur_price = $price_ladder[0]['price']; // 初始化
	$cur_amount = $stat['valid_goods'] + $current_num; // 当前数量
	foreach ($price_ladder as $amount_price) {
		if ($cur_amount >= $amount_price['amount']) {
			$cur_price = $amount_price['price'];
		} else {
			break;
		}
	}
	$lucky_buy['cur_price'] = $cur_price;
	$lucky_buy['formated_cur_price'] = price_format($cur_price, false);

	/* 最终价 */
	$lucky_buy['trans_price'] = $lucky_buy['cur_price'];
	$lucky_buy['formated_trans_price'] = $lucky_buy['formated_cur_price'];
	$lucky_buy['trans_amount'] = $lucky_buy['valid_goods'];

	/* 状态 */
	$lucky_buy['status_no'] = lucky_buy_status($lucky_buy);
	if (isset($GLOBALS['_LANG']['gbs'][$lucky_buy['status']])) {
		$lucky_buy['status_desc'] = $GLOBALS['_LANG']['gbs'][$lucky_buy['status']];
	}

	$lucky_buy['start_time'] = $lucky_buy['formated_start_date'];
	$lucky_buy['end_time'] = $lucky_buy['formated_end_date'];

	return $lucky_buy;
}

/*
 * 取得某云购活动统计信息
 * @param   int     $lucky_buy_id   云购活动id
 * @param   float   $deposit        保证金
 * @return  array   统计信息
 *                  total_order     总订单数
 *                  total_goods     总商品数
 *                  valid_order     有效订单数
 *                  valid_goods     有效商品数
 */
function lucky_buy_stat($lucky_buy_id, $deposit)
{
	$lucky_buy_id = intval($lucky_buy_id);

	/* 取得云购活动商品ID */
	$sql = "SELECT goods_id " .
		"FROM " . $GLOBALS['ecs']->table('goods_activity') .
		"WHERE act_id = '$lucky_buy_id' " .
		"AND act_type = '" . GAT_LUCKY_BUY . "'";
	$lucky_buy_goods_id = $GLOBALS['db']->getOne($sql);

	/* 取得总订单数和总商品数 */
	$sql = "SELECT COUNT(*) AS total_order, SUM(g.goods_number) AS total_goods " .
		"FROM " . $GLOBALS['ecs']->table('order_info') . " AS o, " .
		$GLOBALS['ecs']->table('order_goods') . " AS g " .
		" WHERE o.order_id = g.order_id " .
		"AND o.extension_code = 'lucky_buy' " .
		"AND o.extension_id = '$lucky_buy_id' " .
		"AND g.goods_id = '$lucky_buy_goods_id' " .
		"AND (order_status = '" . OS_CONFIRMED . "' OR order_status = '" . OS_UNCONFIRMED . "')";
	$stat = $GLOBALS['db']->getRow($sql);
	if ($stat['total_order'] == 0) {
		$stat['total_goods'] = 0;
	}

	/* 取得有效订单数和有效商品数 */
	$deposit = floatval($deposit);
	if ($deposit > 0 && $stat['total_order'] > 0) {
		$sql .= " AND (o.money_paid + o.surplus) >= '$deposit'";
		$row = $GLOBALS['db']->getRow($sql);
		$stat['valid_order'] = $row['total_order'];
		if ($stat['valid_order'] == 0) {
			$stat['valid_goods'] = 0;
		} else {
			$stat['valid_goods'] = $row['total_goods'];
		}
	} else {
		$stat['valid_order'] = $stat['total_order'];
		$stat['valid_goods'] = $stat['total_goods'];
	}

	return $stat;
}

/**
 * 获得云购的状态
 *
 * @access  public
 * @param   array
 * @return  integer
 */
function lucky_buy_status($lucky_buy)
{
	$now = gmtime();
	if ($lucky_buy['is_finished'] == 0) {
		/* 未处理 */
		if ($now < $lucky_buy['start_time']) {
			$status = GBS_PRE_START;
		} elseif ($now > $lucky_buy['end_time']) {
			$status = GBS_FINISHED;
		} else {
			$status = GBS_UNDER_WAY;
		}
	} elseif ($lucky_buy['is_finished'] == 1) {
		/* 已结束 */
		$status = 2;
	}


	return $status;
}


/* 取得用户云购活动总数 */
function user_lucky_buy_count()
{
	$sql = "SELECT COUNT(DISTINCT order_id) " .
		"FROM " . $GLOBALS['ecs']->table('lucky_buy_detail') .
		"WHERE user_id  = '" . $_SESSION['user_id'] . "' ";

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


function get_lucky_buy_detail()
{
	$filter['act_id'] = empty($_REQUEST['act_id']) ? 0 : intval($_REQUEST['act_id']);
	$filter['schedule_id'] = empty($_REQUEST['schedule_id']) ? 0 : intval($_REQUEST['schedule_id']);
	$filter['sort_by'] = empty($_REQUEST['sort_by']) ? 'used_time' : trim($_REQUEST['sort_by']);
	$filter['sort_order'] = empty($_REQUEST['sort_order']) ? 'DESC' : trim($_REQUEST['sort_order']);

	$where = (empty($filter['act_id']) || empty($filter['schedule_id'])) ? '' : " WHERE act_id='$filter[act_id]' and schedule_id='$filter[schedule_id]'";

	/* 获得记录总数以及总页数 */
	$sql = "SELECT count(*) FROM " . $GLOBALS['ecs']->table('lucky_buy_detail') . $where;
	$filter['record_count'] = $GLOBALS['db']->getOne($sql);

	$filter = page_and_size($filter);

	/* 获得活动数据 */
	$sql = "SELECT s.* " .
		" FROM " . $GLOBALS['ecs']->table('lucky_buy_detail') . " AS s " .
		$where .
		" ORDER by " . $filter['sort_by'] . " " . $filter['sort_order'] .
		" LIMIT " . $filter['start'] . ", " . $filter['page_size'];
	$row = $GLOBALS['db']->getAll($sql);

	foreach ($row AS $key => $val) {
		$row[$key]['create_time'] = local_date('Y-m-d H:i', $val['create_time']);
		$row[$key]['used_time'] = local_date('Y-m-d H:i', $val['used_time']);
	}

	$arr = array('info' => $row, 'filter' => $filter, 'page_count' => $filter['page_count'], 'record_count' => $filter['record_count']);

	return $arr;
}

/**
 * 返回活动详细列表
 *
 * @access  public
 *
 * @return array
 */
function get_lucky_buy($id)
{
	$filter['act_id'] = empty($_REQUEST['act_id']) ? 0 : intval($_REQUEST['act_id']);
	$filter['sort_by'] = empty($_REQUEST['sort_by']) ? 'schedule_id' : trim($_REQUEST['sort_by']);
	$filter['sort_order'] = empty($_REQUEST['sort_order']) ? 'DESC' : trim($_REQUEST['sort_order']);

	$where = (empty($filter['act_id'])) ? '' : " WHERE act_id='$filter[act_id]' ";

	/* 获得记录总数以及总页数 */
	$sql = "SELECT count(*) FROM " . $GLOBALS['ecs']->table('lucky_buy') . $where;
	$filter['record_count'] = $GLOBALS['db']->getOne($sql);

	$filter = page_and_size($filter);

	/* 获得活动数据 */
	$sql = "SELECT * " .
		" FROM " . $GLOBALS['ecs']->table('lucky_buy') . $where .
		" ORDER by " . $filter['sort_by'] . " " . $filter['sort_order'] .
		" LIMIT " . $filter['start'] . ", " . $filter['page_size'];
	$row = $GLOBALS['db']->getAll($sql);

	foreach ($row AS $key => $val) {

		$row[$key]['start_time'] = local_date('Y-m-d H:i', $val['start_time']);
		$row[$key]['end_time'] = local_date('Y-m-d H:i', $val['end_time'] > 0 ? $val['end_time'] : 0);

	}

	$arr = array('info' => $row, 'filter' => $filter, 'page_count' => $filter['page_count'], 'record_count' => $filter['record_count']);

	return $arr;
}


/**
 * 取得云购活动数量
 * @return  int
 */
function lucky_buy_count()
{
	$now = gmtime();
	$sql = "SELECT COUNT(*) " .
		"FROM " . $GLOBALS['ecs']->table('goods_activity') .
		"WHERE act_type = '" . GAT_LUCKY_BUY . "' " .
		"AND start_time <= '$now' AND end_time >= '$now' AND is_finished < 1";

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

/**
 * 取得某页的云购活动
 * @param   int $size 每页记录数
 * @param   int $page 当前页
 * @return  array
 */
function lucky_buy_list($size, $page)
{
	$lucky_buy_list = array();
	$lucky_buy_list['finished'] = $lucky_buy_list['finished'] = array();

	$now = gmtime();
	$sql = "SELECT a.*,g.*, IFNULL(g.goods_thumb, '') AS goods_thumb " .
		"FROM " . $GLOBALS['ecs']->table('goods_activity') . " AS a " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('goods') . " AS g ON a.goods_id = g.goods_id " .
		"WHERE a.act_type = '" . GAT_LUCKY_BUY . "' " .
		"AND a.start_time <= '$now' AND a.end_time >= '$now' AND a.is_finished < 1 ORDER BY a.act_id DESC";
	$res = $GLOBALS['db']->selectLimit($sql, $size, ($page - 1) * $size);
	while ($row = $GLOBALS['db']->fetchRow($res)) {
		$ext_info = unserialize($row['ext_info']);
		$lucky_buy = array_merge($row, $ext_info);
		$lucky_buy['status_no'] = lucky_buy_status($lucky_buy);

		$lucky_buy['start_time'] = local_date($GLOBALS['_CFG']['time_format'], $lucky_buy['start_time']);
		$lucky_buy['end_time'] = local_date($GLOBALS['_CFG']['time_format'], $lucky_buy['end_time']);
		$lucky_buy['formated_start_price'] = price_format($lucky_buy['start_price']);
		$lucky_buy['formated_end_price'] = price_format($lucky_buy['end_price']);
		$lucky_buy['formated_deposit'] = price_format($lucky_buy['deposit']);
		$lucky_buy['goods_thumb'] = '../'.get_image_path($row['goods_id'], $row['goods_thumb'], true);
		$lucky_buy['url'] = 'lucky_buy.php?act=view&act_id=' . $row['act_id'] . '&u=' . $_SESSION['user_id'];
		$lucky_buy['shop_price'] = price_format($row['shop_price']);

		if ($lucky_buy['status_no'] < 2) {
			$lucky_buy_list['under_way'][] = $lucky_buy;
		} else {
			$lucky_buy_list['finished'][] = $lucky_buy;
		}
	}

	$lucky_buy_list = @array_merge($lucky_buy_list['under_way'], $lucky_buy_list['finished']);

	return $lucky_buy_list;
}

/**
 * 取得某页的云购活动
 * @param   int $size 每页记录数
 * @param   int $page 当前页
 * @return  array
 */
function lucky_buy_user_list($size, $page, $act_user)
{
	$lucky_buy_list = array();

	$now = gmtime();
	$sql = "SELECT DISTINCT lbd.order_id ,lb.status AS luck_buy_status,lb.*,ga.*,g.*, IFNULL(g.goods_thumb, '') AS goods_thumb  " .
		"FROM  " . $GLOBALS['ecs']->table('lucky_buy_detail') . " AS lbd  " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('lucky_buy') . " AS lb ON lbd.lucky_buy_id   = lb.lucky_buy_id   " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('goods_activity') . " AS ga ON lbd.act_id  = ga.act_id  " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('goods') . " AS g ON ga.goods_id = g.goods_id " .
		"WHERE lbd.user_id=" . $_SESSION['user_id'] . " and lbd.user_id >0 ORDER BY lbd.order_id DESC";
	$res = $GLOBALS['db']->selectLimit($sql, $size, ($page - 1) * $size);
	while ($row = $GLOBALS['db']->fetchRow($res)) {
		$ext_info = unserialize($row['ext_info']);
		$lucky_buy = array_merge($row, $ext_info);
		$lucky_buy['status_no'] = lucky_buy_status($lucky_buy);

		$lucky_buy['start_time'] = local_date($GLOBALS['_CFG']['time_format'], $lucky_buy['start_time']);
		$lucky_buy['end_time'] = local_date($GLOBALS['_CFG']['time_format'], $lucky_buy['end_time']);
		$lucky_buy['formated_start_price'] = price_format($lucky_buy['start_price']);
		$lucky_buy['formated_end_price'] = price_format($lucky_buy['end_price']);
		$lucky_buy['formated_deposit'] = price_format($lucky_buy['deposit']);
		$lucky_buy['goods_thumb'] = '../'.get_image_path($row['goods_id'], $row['goods_thumb'], true);
		$lucky_buy['shop_price'] = price_format($row['shop_price']);

		$lucky_buy['status'] = $row['luck_buy_status'];

		$lucky_buy_list[] = $lucky_buy;


	}

	return $lucky_buy_list;
}

/**
 * 取得云购活动记录
 * @param   int $size 每页记录数
 * @param   int $page 当前页
 * @return  array
 */
function lucky_buy_detail($size, $page, $lucky_buy_id)
{
	$lucky_buy_detail = array();

	$now = gmtime();
	$sql = "SELECT user_id ,used_time, user_name,user_head,used_time,count(code) as total " .
		"  FROM  " . $GLOBALS['ecs']->table('lucky_buy_detail') .
		"  WHERE lucky_buy_id=" . $lucky_buy_id . " and user_id >0 GROUP BY user_id,order_id ORDER BY used_time DESC";
	$res = $GLOBALS['db']->selectLimit($sql, $size, ($page - 1) * $size);
	while ($row = $GLOBALS['db']->fetchRow($res)) {
		$lucky_buy_detail[] = $row;
	}

	return $lucky_buy_detail;
}


/**
 * 取得拼团活动信息
 * @param   int $pintuan_id 拼团活动id
 * @param   int $current_num 本次购买数量（计算当前价时要加上的数量）
 * @return  array
 *                  status          状态：
 */
function pintuan_info($pintuan_id, $current_num = 0)
{
	/* 取得拼团活动信息 */
	$pintuan_id = intval($pintuan_id);
	$sql = "SELECT *, act_id AS pintuan_id, act_desc AS pintuan_desc, start_time AS start_date, end_time AS end_date " .
		"FROM " . $GLOBALS['ecs']->table('goods_activity') .
		"WHERE act_id = '$pintuan_id' " .
		"AND act_type = '" . GAT_PINTUAN . "'";
	$pintuan = $GLOBALS['db']->getRow($sql);

	/* 如果为空，返回空数组 */
	if (empty($pintuan)) {
		return array();
	}

	$ext_info = unserialize($pintuan['ext_info']);
	$pintuan = array_merge($pintuan, $ext_info);

	/* 格式化时间 */
	$pintuan['formated_start_date'] = local_date('Y-m-d H:i', $pintuan['start_time']);
	$pintuan['formated_end_date'] = local_date('Y-m-d H:i', $pintuan['end_time']);

	/* 格式化保证金 */
	$pintuan['formated_deposit'] = price_format($pintuan['deposit'], false);


	/* 处理价格阶梯 */
	$pintuan['org_price_ladder'] = $pintuan['price_ladder'];
	$price_ladder = $pintuan['price_ladder'];
	$i = 0;
	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'], false);
			$price_ladder[$key]['formated_price'] = price_format($amount_price['price'], false);
			$i = $i + 1;
		}
	}
	$pintuan['price_ladder'] = $price_ladder;
	$pintuan['ladder_amount'] = $i;

	/* 统计信息 */
	$stat = pintuan_stat($pintuan_id, $pintuan['deposit']);
	$pintuan = array_merge($pintuan, $stat);

	/* 计算当前价 */
	$cur_price = $price_ladder[0]['price']; // 初始化
	$cur_amount = $stat['valid_goods'] + $current_num; // 当前数量
	foreach ($price_ladder as $amount_price) {
		if ($cur_amount >= $amount_price['amount']) {
			$cur_price = $amount_price['price'];
		} else {
			break;
		}
	}
	$pintuan['cur_price'] = $cur_price;
	$pintuan['formated_cur_price'] = price_format($cur_price, false);

	/* 最终价 */
	$pintuan['trans_price'] = $pintuan['cur_price'];
	$pintuan['formated_trans_price'] = $pintuan['formated_cur_price'];
	$pintuan['trans_amount'] = $pintuan['valid_goods'];

	/* 状态 */
	$pintuan['status'] = pintuan_status($pintuan);
	if (isset($GLOBALS['_LANG']['gbs'][$pintuan['status']])) {
		$pintuan['status_desc'] = $GLOBALS['_LANG']['gbs'][$pintuan['status']];
	}

	$pintuan['start_time'] = $pintuan['formated_start_date'];
	$pintuan['end_time'] = $pintuan['formated_end_date'];

	return $pintuan;
}

/*
 * 取得某拼团活动统计信息
 * @param   int     $pintuan_id   拼团活动id
 * @param   float   $deposit        保证金
 * @return  array   统计信息
 *                  total_order     总订单数
 *                  total_goods     总商品数
 *                  valid_order     有效订单数
 *                  valid_goods     有效商品数
 */
function pintuan_stat($pintuan_id, $deposit)
{
	$pintuan_id = intval($pintuan_id);

	/* 取得拼团活动商品ID */
	$sql = "SELECT goods_id " .
		"FROM " . $GLOBALS['ecs']->table('goods_activity') .
		"WHERE act_id = '$pintuan_id' " .
		"AND act_type = '" . GAT_PINTUAN . "'";
	$pintuan_goods_id = $GLOBALS['db']->getOne($sql);

	/* 取得总订单数和总商品数 */
	$sql = "SELECT COUNT(*) AS total_order, SUM(g.goods_number) AS total_goods " .
		"FROM " . $GLOBALS['ecs']->table('order_info') . " AS o, " .
		$GLOBALS['ecs']->table('order_goods') . " AS g " .
		" WHERE o.order_id = g.order_id " .
		"AND o.extension_code = 'pintuan' " .
		"AND o.extension_id = '$pintuan_id' " .
		"AND g.goods_id = '$pintuan_goods_id' " .
		"AND (order_status = '" . OS_CONFIRMED . "' OR order_status = '" . OS_UNCONFIRMED . "')";
	$stat = $GLOBALS['db']->getRow($sql);
	if ($stat['total_order'] == 0) {
		$stat['total_goods'] = 0;
	}

	/* 取得有效订单数和有效商品数 */
	$deposit = floatval($deposit);
	if ($deposit > 0 && $stat['total_order'] > 0) {
		$sql .= " AND (o.money_paid + o.surplus) >= '$deposit'";
		$row = $GLOBALS['db']->getRow($sql);
		$stat['valid_order'] = $row['total_order'];
		if ($stat['valid_order'] == 0) {
			$stat['valid_goods'] = 0;
		} else {
			$stat['valid_goods'] = $row['total_goods'];
		}
	} else {
		$stat['valid_order'] = $stat['total_order'];
		$stat['valid_goods'] = $stat['total_goods'];
	}

	return $stat;
}

/**
 * 获得拼团的状态
 *
 * @access  public
 * @param   array
 * @return  integer
 */
function pintuan_status($pintuan)
{
	$now = gmtime();
	if ($pintuan['is_finished'] == 0) {
		/* 未处理 */
		if ($now < $pintuan['start_time']) {
			$status = GBS_PRE_START;
		} elseif ($now > $pintuan['end_time']) {
			$status = GBS_FINISHED;
		} else {
			if ($pintuan['restrict_amount'] == 0 || $pintuan['valid_goods'] < $pintuan['restrict_amount']) {
				$status = GBS_UNDER_WAY;
			} else {
				$status = GBS_FINISHED;
			}
		}
	} elseif ($pintuan['is_finished'] == GBS_SUCCEED) {
		/* 已处理，拼团成功 */
		$status = GBS_SUCCEED;
	} elseif ($pintuan['is_finished'] == GBS_FAIL) {
		/* 已处理，拼团失败 */
		$status = GBS_FAIL;
	}

	return $status;
}

/**
 *
 * @access  public
 */
function update_pintuan_info($pt_id = 0)
{

	//处理拼团数据  Start
	$now = gmtime();
	$sql = "SELECT a.* " .
		"FROM " . $GLOBALS['ecs']->table('pintuan') . " AS a " .
		"WHERE status=0  " .
		"ORDER BY a.create_time asc ";
	$row = $GLOBALS['db']->getAll($sql);

	foreach ($row AS $key => $val) {
		if ($val['create_succeed'] == 1) {//处理开团成功的拼团及订单

			if ($val['available_people'] == 0) {// 所需人数剩余0 开团成功
				$sql = 'UPDATE ' . $GLOBALS['ecs']->table('pintuan') . ' SET status =1 ' .
					"WHERE pt_id = '" . $val['pt_id'] . "'";
				$GLOBALS['db']->query($sql);
			} else {//所需人数大于零
				$sql = "SELECT count(*) " .
					"FROM  " . $GLOBALS['ecs']->table('pintuan_orders') . " AS pto  " .
					"LEFT JOIN " . $GLOBALS['ecs']->table('order_info') . " AS o ON pto.order_id    = o.order_id    " .
					"WHERE pto.pt_id=" . $val['pt_id'] .
					"  and o.pay_status =2 ";
				$valid_orders = $GLOBALS['db']->getOne($sql);
				$sql = 'UPDATE ' . $GLOBALS['ecs']->table('pintuan') . ' SET `available_people` =`need_people`-' . $valid_orders .
					" WHERE pt_id = '" . $val['pt_id'] . "'";
				$GLOBALS['db']->query($sql);
				if ($val['need_people'] <= $valid_orders) {
					$sql = 'UPDATE ' . $GLOBALS['ecs']->table('pintuan') . ' SET status =1 ' .
						"WHERE pt_id = '" . $val['pt_id'] . "'";
					$GLOBALS['db']->query($sql);
				} else {
					$sql = 'UPDATE ' . $GLOBALS['ecs']->table('pintuan') . ' SET status =2 ' .
						"WHERE pt_id = '" . $val['pt_id'] . "' and end_time<$now ";
					$GLOBALS['db']->query($sql);
				}
			}

		} else {//处理开团中的拼团及订单
			if ($val['end_time'] > $now) {//未开团 未超时
				$sql = "SELECT pto.*,o.order_status,o.shipping_status,o.pay_status " .
					"FROM  " . $GLOBALS['ecs']->table('pintuan_orders') . " AS pto  " .
					"LEFT JOIN " . $GLOBALS['ecs']->table('order_info') . " AS o ON pto.order_id    = o.order_id    " .
					"WHERE pto.pt_id=" . $val['pt_id'] . " and pto.follow_user=pto.act_user and o.pay_status =2";
				$act_user_order = $GLOBALS['db']->getRow($sql);
				if ($act_user_order) {
					$sql = 'UPDATE ' . $GLOBALS['ecs']->table('pintuan') . ' SET create_succeed =1 ' .
						"WHERE pt_id = '" . $val['pt_id'] . "'";
					$GLOBALS['db']->query($sql);
				}
			} else {//未开团，已超时
				$sql = 'UPDATE ' . $GLOBALS['ecs']->table('pintuan') . ' SET status =2 ' .
					"WHERE pt_id = '" . $val['pt_id'] . "'";
				$GLOBALS['db']->query($sql);
			}
		}

	}
	//处理拼团数据  End

	//拼团订单数据  Start
	$sql = "SELECT pto.order_id " .
		"FROM  " . $GLOBALS['ecs']->table('pintuan') . " AS pt  " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('pintuan_orders') . " AS pto ON pto.pt_id    = pt.pt_id    " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('order_info') . " AS o ON pto.order_id    = o.order_id    " .
		"WHERE pt.status!=0 AND o.pay_status <2 and order_status<2 ";
	$row = $GLOBALS['db']->getAll($sql);
	foreach ($row AS $key => $val) {
		$sql = 'UPDATE ' . $GLOBALS['ecs']->table('order_info') . ' SET order_status =2 ' .
			"WHERE order_id = '" . $val['order_id'] . "'";
		$GLOBALS['db']->query($sql);
	}

	//拼团订单数据  End


}

/* 取得拼团活动总数 */
function pintuan_count()
{
	$now = gmtime();
	$sql = "SELECT COUNT(*) " .
		"FROM " . $GLOBALS['ecs']->table('goods_activity') .
		"WHERE act_type = '" . GAT_PINTUAN . "' " .
		"AND start_time <= '$now' AND is_finished < 3";

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

/* 取得用户拼团活动总数 */
function user_pintuan_count()
{
	$sql = "SELECT COUNT(*) " .
		"FROM " . $GLOBALS['ecs']->table('pintuan_orders') .
		"WHERE follow_user  = '" . $_SESSION['user_id'] . "' ";

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

/**
 * 取得某页的所有拼团活动
 * @param   int $size 每页记录数
 * @param   int $page 当前页
 * @return  array
 */
function pintuan_list($size, $page)
{
	/* 取得拼团活动 */
	$pt_list = array();
	$now = gmtime();
	$sql = "SELECT b.*, IFNULL(g.goods_thumb, '') AS goods_thumb, g.*,b.act_id AS pintuan_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_PINTUAN . "' " .
		"AND b.start_time <= '$now' AND b.end_time > '$now'  ORDER BY b.act_id DESC";
	$res = $GLOBALS['db']->selectLimit($sql, $size, ($page - 1) * $size);
	while ($pintuan = $GLOBALS['db']->fetchRow($res)) {
		$ext_info = unserialize($pintuan['ext_info']);
		$pintuan = array_merge($pintuan, $ext_info);

		/* 格式化时间 */
		$pintuan['formated_start_date'] = local_date($GLOBALS['_CFG']['time_format'], $pintuan['start_date']);
		$pintuan['formated_end_date'] = local_date($GLOBALS['_CFG']['time_format'], $pintuan['end_date']);

		/* 格式化保证金 */
		$pintuan['formated_deposit'] = price_format($pintuan['deposit'], false);
		/* 处理价格阶梯 */
		$price_ladder = $pintuan['price_ladder'];
		$i = 0;
		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']);
				$i = $i + 1;
			}
		}
		$pintuan['price_ladder'] = $price_ladder;
		$pintuan['lowest_price'] = price_format(get_lowest_price($price_ladder));
		$pintuan['lowest_amount'] = get_lowest_amount($price_ladder);
		$pintuan['ladder_amount'] = $i;
		$pintuan['sold'] = $pintuan['virtual_sold'] + $pintuan['sales_count'];

		/* 处理图片 */
		if (empty($pintuan['goods_thumb'])) {
			$pintuan['goods_thumb'] = '../'.get_image_path($pintuan['goods_id'], $pintuan['goods_thumb'], true);
		}
		/* 处理链接 */
		$pintuan['url'] = 'pintuan.php?act=view&act_id=' . $pintuan['pintuan_id'] . '&u=' . $_SESSION['user_id'];
		/* 加入数组 */
		$pt_list[] = $pintuan;
	}

	return $pt_list;
}

/**
 * 取得某用户的所有拼团活动
 * @param   int $size 每页记录数
 * @param   int $page 当前页
 * @return  array
 */
function pintuan_user_list($size, $page)
{
	/* 取得拼团活动 */
	$pt_list = array();
	$now = gmtime();

	$sql = "SELECT ga.*,g.*, IFNULL(g.goods_thumb, '') AS goods_thumb, pto.order_id ,pt.status,pt.need_people,pt.pt_id,pt.price as pt_price " .
		"FROM  " . $GLOBALS['ecs']->table('pintuan_orders') . " AS pto  " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('pintuan') . " AS pt ON pto.pt_id   = pt.pt_id   " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('goods_activity') . " AS ga ON pt.act_id  = ga.act_id  " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('goods') . " AS g ON ga.goods_id = g.goods_id " .
		"WHERE pto.follow_user=" . $_SESSION['user_id'] . "  ORDER BY pto.order_id DESC";
	$res = $GLOBALS['db']->selectLimit($sql, $size, ($page - 1) * $size);
	while ($pintuan = $GLOBALS['db']->fetchRow($res)) {
		$ext_info = unserialize($pintuan['ext_info']);
		$pintuan = array_merge($pintuan, $ext_info);

		/* 格式化时间 */
		$pintuan['formated_start_date'] = local_date($GLOBALS['_CFG']['time_format'], $pintuan['start_date']);
		$pintuan['formated_end_date'] = local_date($GLOBALS['_CFG']['time_format'], $pintuan['end_date']);
		$pintuan['price'] = price_format($pintuan['pt_price'], false);

		/* 格式化保证金 */
		$pintuan['formated_deposit'] = price_format($pintuan['deposit'], false);
		/* 处理价格阶梯 */
		$price_ladder = $pintuan['price_ladder'];
		$i = 0;
		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']);
				$i = $i + 1;
			}
		}
		$pintuan['price_ladder'] = $price_ladder;
		$pintuan['lowest_price'] = price_format(get_lowest_price($price_ladder));
		$pintuan['lowest_amount'] = get_lowest_amount($price_ladder);
		$pintuan['ladder_amount'] = $i;
		$pintuan['sold'] = $pintuan['virtual_sold'] + $pintuan['sales_count'];

		/* 处理图片 */
		if (empty($pintuan['goods_thumb'])) {
			$pintuan['goods_thumb'] = '../'.get_image_path($pintuan['goods_id'], $pintuan['goods_thumb'], true);
		}
		/* 处理链接 */
		$pintuan['url'] = 'pintuan.php?act=view&act_id=' . $pintuan['pintuan_id'] . '&u=' . $_SESSION['user_id'];
		/* 加入数组 */
		$pt_list[] = $pintuan;
	}

	return $pt_list;
}


function pintuan_detail_info($pintuan_id)
{
	$sql = "SELECT ga.*,IFNULL(g.goods_thumb, '') AS goods_thumb, pt.*,g.* " .
		"FROM  " . $GLOBALS['ecs']->table('pintuan') . " AS pt  " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('goods_activity') . " AS ga ON pt.act_id  = ga.act_id  " .
		"LEFT JOIN " . $GLOBALS['ecs']->table('goods') . " AS g ON ga.goods_id = g.goods_id " .
		"WHERE pt.pt_id=" . $pintuan_id . "  ";
	$pintuan = $GLOBALS['db']->getRow($sql);
	$ext_info = unserialize($pintuan['ext_info']);
	$pintuan = array_merge($pintuan, $ext_info);

	/* 格式化时间 */
	$pintuan['create_time'] = local_date($GLOBALS['_CFG']['time_format'], $pintuan['create_time']);
	$pintuan['price'] = price_format($pintuan['price'], false);

	/* 处理图片 */
	if (empty($pintuan['goods_thumb'])) {
		$pintuan['goods_thumb'] = '../'.get_image_path($pintuan['goods_id'], $pintuan['goods_thumb'], true);
	}
	/* 处理链接 */
	$pintuan['url'] = 'pintuan.php?act=view&act_id=' . $pintuan['act_id'] . '&u=' . $_SESSION['user_id'];
	/* 加入数组 */

	return $pintuan;
}

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];

	}

}

function get_lowest_amount($price_ladder)
{

	if (is_array($price_ladder)) {

		$aa = array();
		foreach ($price_ladder as $key => $value) {

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


		}
		sort($aa);

		return $aa[0];

	}

}

/**
 * @param   int $act_id 活动id
 * @return  array
 */
function get_new_pintuan($act_id)
{
	$new_pintuan = array();
	$sql = "SELECT a.* " .
		"FROM " . $GLOBALS['ecs']->table('pintuan') . " AS a " .
		"WHERE act_id = '$act_id' and status=0 and create_succeed=1 " .
		"ORDER BY a.create_time desc LIMIT 10";
	$res = $GLOBALS['db']->query($sql);
	while ($row = $GLOBALS['db']->fetchRow($res)) {
		$row['create_time'] = local_date($GLOBALS['_CFG']['time_format'], $row['create_time']);
		$row['price'] = price_format($row['price'], false);
		$new_pintuan[] = $row;
	}

	return $new_pintuan;
}


/**
 * 返回活动详细列表
 *
 * @access  public
 *
 * @return array
 */
function get_pintuan()
{
	$filter['act_id'] = empty($_REQUEST['act_id']) ? 0 : intval($_REQUEST['act_id']);
	$filter['sort_by'] = empty($_REQUEST['sort_by']) ? 'create_time' : trim($_REQUEST['sort_by']);
	$filter['sort_order'] = empty($_REQUEST['sort_order']) ? 'DESC' : trim($_REQUEST['sort_order']);

	$where = empty($filter['act_id']) ? '' : " WHERE act_id='$filter[act_id]' ";

	/* 获得记录总数以及总页数 */
	$sql = "SELECT count(*) FROM " . $GLOBALS['ecs']->table('pintuan') . $where;
	$filter['record_count'] = $GLOBALS['db']->getOne($sql);

	$filter = page_and_size($filter);

	/* 获得活动数据 */
	$sql = "SELECT * " .
		" FROM " . $GLOBALS['ecs']->table('pintuan') . $where .
		" ORDER by " . $filter['sort_by'] . " " . $filter['sort_order'] .
		" LIMIT " . $filter['start'] . ", " . $filter['page_size'];
	$row = $GLOBALS['db']->getAll($sql);

	foreach ($row AS $key => $val) {
		$row[$key]['create_time'] = local_date('Y-m-d H:i', $val['create_time']);
		$row[$key]['end_time'] = local_date('Y-m-d H:i', $val['end_time']);

	}

	$arr = array('pintuan' => $row, 'filter' => $filter, 'page_count' => $filter['page_count'], 'record_count' => $filter['record_count']);

	return $arr;
}


/**
 * 返回活动详细列表
 *
 * @access  public
 *
 * @return array
 */
function get_pintuan_detail()
{
	$filter['pt_id'] = empty($_REQUEST['pt_id']) ? 0 : intval($_REQUEST['pt_id']);
	$filter['sort_by'] = empty($_REQUEST['sort_by']) ? 'follow_time' : trim($_REQUEST['sort_by']);
	$filter['sort_order'] = empty($_REQUEST['sort_order']) ? 'DESC' : trim($_REQUEST['sort_order']);

	$where = empty($filter['pt_id']) ? '' : " WHERE pt_id='$filter[pt_id]' ";

	/* 获得记录总数以及总页数 */
	$sql = "SELECT count(*) FROM " . $GLOBALS['ecs']->table('pintuan_orders') . $where;
	$filter['record_count'] = $GLOBALS['db']->getOne($sql);

	$filter = page_and_size($filter);

	/* 获得活动数据 */
	$sql = "SELECT s.* " .
		" FROM " . $GLOBALS['ecs']->table('pintuan_orders') . " AS s " .
		$where .
		" ORDER by " . $filter['sort_by'] . " " . $filter['sort_order'] .
		" LIMIT " . $filter['start'] . ", " . $filter['page_size'];
	$row = $GLOBALS['db']->getAll($sql);

	foreach ($row AS $key => $val) {
		$row[$key]['follow_time'] = local_date('Y-m-d H:i', $val['follow_time']);

	}

	$arr = array('pintuan' => $row, 'filter' => $filter, 'page_count' => $filter['page_count'], 'record_count' => $filter['record_count']);

	return $arr;
}

/**
 * 获取指定id pintuan 的信息
 */
function get_pintuan_info($id)
{
	global $ecs, $db, $_CFG;

	$sql = "SELECT act_id, act_name AS cut_name, goods_id, product_id, goods_name, start_time, end_time, act_desc, ext_info" .
		" FROM " . $GLOBALS['ecs']->table('goods_activity') .
		" WHERE act_id='$id' AND act_type = " . GAT_PINTUAN;

	$cut = $db->GetRow($sql);


	/* 将时间转成可阅读格式 */
	$cut['start_time'] = local_date('Y-m-d H:i', $cut['start_time']);
	$cut['end_time'] = local_date('Y-m-d H:i', $cut['end_time']);
	$row = unserialize($cut['ext_info']);
	unset($cut['ext_info']);
	if ($row) {
		foreach ($row as $key => $val) {
			$cut[$key] = $val;
		}
	}

	return $cut;
}

//拼团
function get_pintuan_by_ptid($pt_id)
{
	$sql = "SELECT pt.* " .
		" FROM  " . $GLOBALS['ecs']->table('pintuan') . " AS pt  " .
		" WHERE pt.pt_id=" . $pt_id . "  ";
	return $GLOBALS['db']->getRow($sql);
}