xyzshop/mobile/control/cart.php

<?php
/**
 * 我的购物车
 */

//use Shopnc\Tpl;

defined('InShopNC') or exit('Access Invalid!');

class cartControl extends mobileControl
{
    public function __construct()
    {
        parent::__construct();
    }

    public function listOp()
    {
        $model_cart	= Model('cart');
        $logic_buy_1 = logic('buy_1');

        //购物车列表
        if($_SESSION['is_login'] == 1) {
            $cart_list	= $model_cart->listCart('db',array('buyer_id'=>$_SESSION['member_id']));
        } else {
            $cart_list	= $model_cart->listCart('Session',array('buyer_id'=>$_SESSION['member_id']));
        }

        //购物车列表 [得到最新商品属性及促销信息]
        $cart_list = $logic_buy_1->getGoodsCartList($cart_list);
        if(count($cart_list) == 0) {
            return self::outsuccess(array('carts' => NULL,'mobile_page' => 0));
        }

        $ret = array_chunk($cart_list,$this->page_size());
        $pages = count($ret);
        $page_no = $pages >= $this->page_no() ? $this->page_no() : $pages;
        $cart_list = $ret[$page_no - 1];

        //购物车商品以店铺ID分组显示,并计算商品小计,店铺小计与总价由JS计算得出
        $store_cart_list = array();
        foreach ($cart_list as $cart) {
            $cart['goods_total'] = ncPriceFormat($cart['goods_price'] * $cart['goods_num']);
            $cart['goods_image'] = cthumb($cart['goods_image'], $cart['store_id']);
            $store_cart_list[$cart['store_id']][] = $cart;
        }

        //店铺信息
        $store_list = Model('store')->getStoreMemberIDList(array_keys($store_cart_list),'store_id,member_id,store_name');
        //取得店铺级活动 - 可用的满即送活动
        $mansong_rule_list = $logic_buy_1->getMansongRuleList(array_keys($store_cart_list));
        //取得哪些店铺有满免运费活动
        $free_freight_list = $logic_buy_1->getFreeFreightActiveList(array_keys($store_cart_list));

        if(in_array($_SESSION['client_type'],array('android', 'ios','ajax'))) {
            $data = $this->format_cart($store_cart_list,$store_list,$mansong_rule_list,$free_freight_list);
            self::outsuccess(array('carts' => $data,'mobile_page' => $pages));
        } else {
            $data = $this->format_cart($store_cart_list,$store_list,$mansong_rule_list,$free_freight_list);
            self::outsuccess(array('carts' => $data,'mobile_page' => $pages));
        }
    }

    private function remove_goods(&$goods_info)
    {
        static $ex_goodsfield = array("buyer_id","store_id","store_name","gc_id","transport_id","goods_vat","goods_storage","goods_storage_alarm",
            "is_fcode","promotions_id",);
        static $ex_xsfield = array("xianshi_goods_id","xianshi_id","goods_id","store_id","goods_name","goods_price","goods_image","goods_url",
            "image_url","xianshi_recommend");
        static $ex_gbuyfield = array("groupbuy_id","goods_id","goods_commonid","goods_name","store_id","store_name","goods_price","recommended","views",
               "class_id","s_class_id","is_vr","vr_city_id","vr_area_id","vr_mall_id","vr_class_id","vr_s_class_id","groupbuy_url","goods_url","start_time_text",
               "end_time_text","groupbuy_state_text","reviewable","cancelable","state_flag","button_text","count_down_text","count_down","groupbuy_intro");


        if(is_array($goods_info))
        {
            $store_id = $goods_info['store_id'];
            foreach($ex_goodsfield as $key)
            {
                if(array_key_exists($key,$goods_info)) {
                    unset($goods_info[$key]);
                }
            }

            if(array_key_exists('xianshi_info',$goods_info))
            {
                $xs_info = &$goods_info['xianshi_info'];
                if(is_array($xs_info))
                {
                    foreach($ex_xsfield as $key)
                    {
                        if(array_key_exists($key,$xs_info)) {
                            unset($xs_info[$key]);
                        }
                    }
                }
            }

            if(array_key_exists('groupbuy_info',$goods_info))
            {
                $gbuy_info = &$goods_info['groupbuy_info'];
                if(is_array($gbuy_info))
                {
                    foreach($ex_gbuyfield as $key)
                    {
                        if(array_key_exists($key,$gbuy_info)) {
                            unset($gbuy_info[$key]);
                        }
                    }
                    if(array_key_exists("state",$gbuy_info))
                    {
                        $state = intval($gbuy_info["state"]);
                        if($state == 20) {
                            $gbuy_info["state"] = true;
                        }
                    }
                    if(array_key_exists("groupbuy_image",$gbuy_info)) {
                        $gbuy_info['groupbuy_image'] = cthumb($gbuy_info['groupbuy_image'], $store_id);
                    }
                    if(array_key_exists("groupbuy_image1",$gbuy_info)) {
                        $gbuy_info['groupbuy_image1'] = cthumb($gbuy_info['groupbuy_image1'], $store_id);
                    }
                }
            }
        }
    }

    private function format_cart($store_cart_list,$store_list,$mansong_rule_list,$free_freight_list)
    {
        $ret = array();
        foreach($store_cart_list as $key => $val)
        {
            $store_goods = array();
            $store_goods['store_info'] = $store_list[$key];
            $store_goods['free_freight'] = $free_freight_list[$key];
            $store_goods['mansong_rule'] = $mansong_rule_list[$key];

            $store_goods['goods_info'] = array();
            foreach($val as $index => $goods) {
                $this->remove_goods($goods);
                array_push($store_goods['goods_info'],$goods);
            }

            array_push($ret,$store_goods);
        }

        return $ret;
    }

    /**
     * 购物车列表
     */
    public function cart_listOp()
    {
        if($_SESSION['is_login'] != 1) {
            return self::outerr(errcode::ErrUnLogin);
        }

        $page = trim($_GET['page']);
        $curpage = trim($_GET['curpage']);
        if (!isset($_GET['page'])) {
            $page = "100";
            $curpage = "1";
            $this->page = 100;
        }
        initpage($page, $curpage);

        $model_cart = Model('cart');
        $model_goods = Model('goods');

        $condition = array('buyer_id' => $_SESSION['member_id']);
        $cart_list = $model_cart->getCartList($condition, $this->page);
        $page_count = $model_cart->gettotalpage();
        $model_cart->cls();
//        $cart_list = $model_cart->listCart('db', $condition);
        foreach ($cart_list as $key => $value) {
            $goods_id = $value['goods_id'];
            $goods_promotion = $model_goods->getGoodsInfoAndPromotionById($goods_id);
            $goods_storage = $model_goods->getGoodsStorageById($goods_id);
            $promotion_type = '';
            $promotion_price = '0.00';
            if (!empty($goods_promotion['groupbuy_info'])) {
                $promotion_type = '抢购';
                $promotion_price = $goods_promotion['groupbuy_info']['groupbuy_price'];
            }
            if (!empty($goods_promotion['xianshi_info'])) {
                $promotion_type = '限时折扣';
                $promotion_price = $goods_promotion['xianshi_info']['xianshi_price'];
            }
            $goods_spec = unserialize($goods_promotion['goods_spec']);
            $goods_spec_array = array();

            if(!empty($goods_spec))
            {
                foreach ($goods_spec as $val) {
                    array_push($goods_spec_array, $val);
                }
            }

            $cart_list[$key]['goods_storage'] = $goods_storage;
            $cart_list[$key]['goods_spec'] = implode(',', $goods_spec_array);
            $cart_list[$key]['promotion_type'] = $promotion_type;
            $cart_list[$key]['promotion_price'] = $promotion_price;
            $cart_list[$key]['goods_image_url'] = cthumb($value['goods_image'], $value['store_id']);
            $cart_list[$key]['goods_sum'] = ncPriceFormat($value['goods_price'] * $value['goods_num']);
        }

        self::outsuccess(array('cart_list' => $cart_list, 'mobile_page' => mobile_page($page_count)));
    }

    /**
     * 购物车添加
     */
    public function addOp()
    {
        $model_goods = Model('goods');
        $logic_buy_1 = Logic('buy_1');

        if (is_numeric($_GET['goods_id']) && is_numeric($_POST['quantity']))
        {
            $goods_id = intval($_POST['goods_id']);
            $quantity = intval($_POST['quantity']);

            if ($goods_id <= 0 || $quantity <= 0) {
                return self::outerr(errcode::ErrInputParam);
            }

            $goods_info = $model_goods->getGoodsOnlineInfoAndPromotionById($goods_id);
            //抢购
            $logic_buy_1->getGroupbuyInfo($goods_info);
            //限时折扣
            $logic_buy_1->getXianshiInfo($goods_info, $quantity);

            $ret = $this->check_goods($goods_info, $quantity);
            if(is_array($ret)) {
                return self::outerr($ret['code'],$ret['msg']);
            }
        }
        elseif (is_numeric($_GET['bl_id']))
        {
            //优惠套装加入购物车(单套)
            if ($_SESSION['is_login'] != 1) {
                return self::outerr(errcode::ErrUnLogin);
            }
            $bl_id = intval($_GET['bl_id']);
            if ($bl_id <= 0) return ;
            $model_bl = Model('p_bundling');
            $bl_info = $model_bl->getBundlingInfo(array('bl_id'=>$bl_id));
            if (empty($bl_info) || $bl_info['bl_state'] == '0') {
                return self::outerr(errcode::ErrBLUnExist);
            }

            //检查每个商品是否符合条件,并重新计算套装总价
            $bl_goods_list = $model_bl->getBundlingGoodsList(array('bl_id'=>$bl_id));
            $goods_id_array = array();
            $bl_amount = 0;
            foreach ($bl_goods_list as $goods) {
                $goods_id_array[] = $goods['goods_id'];
                $bl_amount += $goods['bl_goods_price'];
            }
            $model_goods = Model('goods');
            $goods_list = $model_goods->getGoodsOnlineListAndPromotionByIdArray($goods_id_array);
            foreach ($goods_list as $goods) {
                $this->check_goods($goods,1);
            }

            //优惠套装作为一条记录插入购物车，图片取套装内的第一个商品图
            $goods_info    = array();
            $goods_info['store_id']	= $bl_info['store_id'];
            $goods_info['goods_id']	= $goods_list[0]['goods_id'];
            $goods_info['goods_name'] = $bl_info['bl_name'];
            $goods_info['goods_price'] = $bl_amount;
            $goods_info['goods_num']   = 1;
            $goods_info['goods_image'] = $goods_list[0]['goods_image'];
            $goods_info['store_name'] = $bl_info['store_name'];
            $goods_info['bl_id'] = $bl_id;
            $quantity = 1;
        }

        //已登录状态，存入数据库,未登录时，存入Session
        if($_SESSION['member_id']) {
            $save_type = 'db';
            $goods_info['buyer_id'] = $_SESSION['member_id'];
        } else {
            $save_type = 'Session';
        }

        $model_cart = Model('cart');
        $insert = $model_cart->addCart($goods_info, $save_type , $quantity);
        if ($insert) { //todo 此处返回结果有变化
            $data = array('result' => 1, 'num' => $model_cart->cart_goods_num, 'amount' => ncPriceFormat($model_cart->cart_all_price));
            return self::outsuccess($data);
        } else {
            return self::outerr(errcode::ErrAddCart);
        }
    }

    /**
     * 检查商品是否符合加入购物车条件
     * @param unknown $goods
     * @param number $quantity
     */
    private function check_goods($goods_info, $quantity)
    {
        if(empty($quantity)) {
            return array('code' => errcode::ErrInputParam, 'msg' => errcode::msg(errcode::ErrInputParam));
        }
        if(empty($goods_info)) {
            return array('code' => errcode::ErrGoodsOff, 'msg'=> '商品已下架或不存在');
        }
        if ($goods_info['store_id'] == $_SESSION['store_id']) {
            return array('code' => errcode::ErrCanNotBuyOwn, 'msg'=> errcode::msg(errcode::ErrCanNotBuyOwn));
        }
        if(intval($goods_info['goods_storage']) < 1) {
            return array('code' => errcode::ErrGoodsOutofStock, 'msg' => errcode::msg(errcode::ErrGoodsOutofStock));
        }
        if(intval($goods_info['goods_storage']) < $quantity) {
            return array('code' => errcode::ErrStorageShort, 'msg' => errcode::msg(errcode::ErrStorageShort));
        }
        if ($goods_info['is_virtual'] || $goods_info['is_fcode'] || $goods_info['is_presell']) {
            return array('code' => errcode::ErrGoodsSpecial, 'msg' => errcode::msg(errcode::ErrGoodsSpecial));
        }

        return true;
    }

    public function cart_editOp()
    {
        if($_SESSION['is_login'] != 1) {
            return self::outerr(errcode::ErrUnLogin);
        }

        $cart_list = explode(',', urldecode($_POST['cart_list']));
        $new_cart_list = array();
        if (is_array($cart_list))
        {
            foreach ($cart_list as $value) {
                if (preg_match_all('/^(\d{1,10})\|(\d{1,6})$/', $value, $match)) {
                    if (intval($match[2][0]) > 0) {
                        $new_cart_list[$match[1][0]] = $match[2][0];
                    }
                }
            }

            $model_cart = Model('cart');
            $condition = array('buyer_id' => $_SESSION['member_id']);
            $original_cart_list = $model_cart->listCart('db', $condition);
            $quantity_error = array();
            foreach ($original_cart_list as $key => $value)
            {
                if (array_key_exists($value['cart_id'], $new_cart_list))
                {
                    $quantity = intval($new_cart_list[$value['cart_id']]);
                    if (intval($value['goods_num']) !== $quantity)
                    {
                        if (!$this->_check_goods_storage($value, $quantity, $_SESSION['member_id'])) {
                            array_push($quantity_error, array('cart_id' => $value['cart_id'], 'quantity' => $quantity, 'err_info' => '库存不足'));
                        } else {
                            $data = array();
                            $data['goods_num'] = $quantity;
                            $update = $model_cart->editCart($data, array('cart_id' => $value['cart_id']));
                            if (!$update) {
                                return self::outerr(errcode::ErrCart, '购物车修改失败');
                            }
                        }
                    }
                }
                else
                {
                    $delete = $model_cart->delCart('db', array('cart_id' => $value['cart_id']));
                    if (!$delete) {
                        return self::outerr(errcode::ErrCart, '购物车修改失败');
                    }
                }
            }

            if (count($quantity_error) > 0) {
                self::outsuccess(array('result' => '0', 'quantity_error' => $quantity_error));
            } else {
                self::outsuccess(array('result' => '1','quantity_error' => NULL));
            }
        }
        else {
            return self::outerr(errcode::ErrCart, '购物车列表格式错误');
        }
    }

    /**
     * 购物车更新商品数量
     */

    public function editOp()
    {
        $cart_list = explode(',', urldecode($_POST['cart_list']));
        if (!is_array($cart_list)) {
            return self::outerr(errcode::ErrCart, '修改购物车列表参数格式错误');
        }

        $new_cart_list = array();
        foreach ($cart_list as $value)
        {
            if (preg_match_all('/^(\d{1,10})\|(\d{1,6})$/', $value, $match)) {
                if (intval($match[2][0]) > 0) {
                    $new_cart_list[$match[1][0]] = $match[2][0];
                }
            }
        }
        if(empty($new_cart_list)) {
            return self::outerr(errcode::ErrCart, '修改购物车列表参数格式错误');
        }

        $errors = array();
        foreach($new_cart_list as $cart_id => $quantity)
        {
            if($quantity == 0) {
                $quantity = 1;
                $ret = $this->do_edit(intval(abs($cart_id)),intval(abs($quantity)));
            }
            else {
                $ret = $this->do_del($cart_id);
            }
            //删除购物车在分页的情况下，删除会导致页面计算出问题.
//            if($quantity > 0) {
//                $ret = $this->do_edit(intval(abs($cart_id)),intval(abs($quantity)));
//            }
//            else {
//                $ret = $this->do_del($cart_id);
//            }
            if(is_array($ret)) {
                array_push($errors,$ret);
            }
        }

        if (count($errors) > 0) {
            self::outerr(array('result' => '0', 'quantity_error' => $errors));
        } else {
            self::outsuccess(array('result' => '1'));
        }
    }

    public function do_edit($cart_id,$quantity)
    {
        $model_cart = Model('cart');
        $model_goods= Model('goods');
        $logic_buy_1 = logic('buy_1');

        //存放返回信息
        $cart_info = $model_cart->getCartInfo(array('cart_id'=>$cart_id,'buyer_id'=>$_SESSION['member_id']));
        if ($cart_info['bl_id'] == '0')
        {
            //普通商品
            $goods_id = intval($cart_info['goods_id']);
            $goods_info	= $logic_buy_1->getGoodsOnlineInfo($goods_id,$quantity);
            if(empty($goods_info))
            {
                if($_SESSION['is_login'] == 1) {
                    QueueClient::push('delCart', array('buyer_id'=>$_SESSION['member_id'],'cart_ids'=>array($cart_id)));
                }
                return array('cart_id' => $cart_id, 'quantity' => $quantity, 'err_info' => '商品已被下架');
            }

            //抢购
            $logic_buy_1->getGroupbuyInfo($goods_info);
            //限时折扣
            $logic_buy_1->getXianshiInfo($goods_info,$quantity);

            $quantity = $goods_info['goods_num'];
            if(intval($goods_info['goods_storage']) < $quantity) {
                $model_cart->editCart(array('goods_num'=>$goods_info['goods_storage']),array('cart_id'=>$cart_id,'buyer_id'=>$_SESSION['member_id']));
                return array('cart_id' => $cart_id, 'quantity' => $goods_info['goods_storage'], 'err_info' => '库存不足，已将您购物车更新为库存数量.');
            }
        }
        else
        {
            //优惠套装商品
            $model_bl = Model('p_bundling');
            $bl_goods_list = $model_bl->getBundlingGoodsList(array('bl_id'=>$cart_info['bl_id']));
            $goods_id_array = array();
            foreach ($bl_goods_list as $goods) {
                $goods_id_array[] = $goods['goods_id'];
            }
            $goods_list = $model_goods->getGoodsOnlineListAndPromotionByIdArray($goods_id_array);

            //如果其中有商品下架，删除
            if (count($goods_list) != count($goods_id_array)) {
                QueueClient::push('delCart', array('buyer_id'=>$_SESSION['member_id'],'cart_ids'=>array($cart_id)));
                return array('cart_id' => $cart_id, 'quantity' => 0, 'err_info' => '该优惠套装已经无效，建议您购买单个商品.');
            }

            //如果有商品库存不足，更新购买数量到目前最大库存
            foreach ($goods_list as $goods_info)
            {
                if ($quantity > $goods_info['goods_storage']) {
                    $model_cart->editCart(array('goods_num'=>$goods_info['goods_storage']),array('cart_id'=>$cart_id,'buyer_id'=>$_SESSION['member_id']));
                    return array('cart_id' => $cart_id, 'quantity' => $goods_info['goods_storage'], 'err_info' => '该优惠套装部分商品库存不足，建议您降低购买数量或购买库存足够的单个商品.');
                }
            }
            $goods_info['goods_price'] = $cart_info['goods_price'];
        }

        $data = array();
        $data['goods_num'] = $quantity;
        $data['goods_price'] = $goods_info['goods_price'];

        $update = $model_cart->editCart($data,array('cart_id'=>$cart_id,'buyer_id'=>$_SESSION['member_id']));
        if ($update) {
            return true;
        } else {
            return array('cart_id' => $cart_id, 'quantity' => 0, 'err_info' => '更新购物车失败.');
        }
    }


    private function do_del($cart_id)
    {
        $model_cart	= Model('cart');
        if ($_SESSION['member_id']) {
            //登录状态下删除数据库内容
            $delete	= $model_cart->delCart('db',array('cart_id'=>$cart_id,'buyer_id'=>$_SESSION['member_id']));
            return $delete;
        } else {
            //未登录时删除cookie的购物车信息
            $delete	= $model_cart->delCart('Session',array('goods_id'=>$cart_id));
            return $delete;
        }
    }

    public function delOp()
    {
        $cart_id = intval($_POST['cart_id']);
        if($cart_id <=0 ) {
            return self::outerr(errcode::ErrInputParam);
        }

        $ret = $this->do_del($cart_id);
        if($ret) {
            return self::outsuccess(array('result' => '1'));
        } else {
            return self::outerr(errcode::ErrCartDelError);
        }
    }

    /**
     * 购物车删除
     */
    public function cart_delOp()
    {
        if($_SESSION['is_login'] != 1) {
            return self::outerr(errcode::ErrUnLogin);
        }

        $cart_id = intval($_POST['cart_id']);
        $model_cart = Model('cart');
        if ($cart_id > 0) {
            $condition = array();
            $condition['buyer_id'] = $_SESSION['member_id'];
            $condition['cart_id'] = $cart_id;

            $model_cart->delCart('db', $condition);
        }

        self::outsuccess(array('result' => '1'));
    }

     /**
     * 检查库存是否充足
     */
    private function _check_goods_storage($cart_info, $quantity, $member_id)
    {
        $model_goods = Model('goods');
        $model_bl = Model('p_bundling');
        $logic_buy_1 = Logic('buy_1');

        if ($cart_info['bl_id'] == '0') {
            //普通商品
            $goods_info = $model_goods->getGoodsOnlineInfoAndPromotionById($cart_info['goods_id']);

            //抢购
            $logic_buy_1->getGroupbuyInfo($goods_info);

            //限时折扣
            $logic_buy_1->getXianshiInfo($goods_info, $quantity);

            if (intval($goods_info['goods_storage']) < $quantity) {
                return false;
            }
        } else {
            //优惠套装商品
            $bl_goods_list = $model_bl->getBundlingGoodsList(array('bl_id' => $cart_info['bl_id']));
            $goods_id_array = array();
            foreach ($bl_goods_list as $goods) {
                $goods_id_array[] = $goods['goods_id'];
            }
            $bl_goods_list = $model_goods->getGoodsOnlineListAndPromotionByIdArray($goods_id_array);

            //如果有商品库存不足，更新购买数量到目前最大库存
            foreach ($bl_goods_list as $goods_info) {
                if (intval($goods_info['goods_storage']) < $quantity) {
                    return false;
                }
            }
        }
        return true;
    }
}