zhongshen_project/addon/pintuan/model/Pintuan.php

<?php
/**
 * Niushop商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.niushop.com
 * =========================================================
 */

namespace addon\pintuan\model;

use addon\weapp\model\Message as WeappMessage;
use addon\wechat\model\Message as WechatMessage;
use app\model\BaseModel;
use app\model\goods\Goods;
use app\model\member\Member;
use app\model\message\Sms;
use app\model\system\Config as ConfigModel;
use app\model\system\Cron;
use think\facade\Cache;
use think\facade\Db;

/**
 * 拼团活动
 */
class Pintuan extends BaseModel
{
    /**
     * 添加拼团
     * @param $pintuan_data
     * @param $goods
     * @param $sku_list
     * @return array
     */
    public function addPintuan($pintuan_data, $goods, $sku_list)
    {
        if (empty($goods[ 'sku_ids' ])) {
            return $this->error('', '该活动至少需要一个商品参与');
        }
        $pintuan_data[ 'create_time' ] = time();
        if ($pintuan_data[ 'pintuan_time' ] == 0) {
            return $this->error('', "拼团有效期时长不能为0");
        }

        //查询该商品是否存在拼团
        $pintuan_info = model('promotion_pintuan_goods')->getInfo(
            [
                [ 'ppg.site_id', '=', $pintuan_data[ 'site_id' ] ],
                [ 'pp.status', 'in', '0,1' ],
                [ 'ppg.goods_id', 'in', $goods[ 'goods_ids' ] ],
                [ '', 'exp', Db::raw('not ( (`start_time` > ' . $pintuan_data[ 'end_time' ] . ' and `start_time` > ' . $pintuan_data[ 'start_time' ] . ' )  or (`end_time` < ' . $pintuan_data[ 'start_time' ] . ' and `end_time` < ' . $pintuan_data[ 'end_time' ] . '))') ]
            ], 'ppg.id', 'ppg', [ [ 'promotion_pintuan pp', 'pp.pintuan_id = ppg.pintuan_id', 'left' ] ]
        );

        if (!empty($pintuan_info)) {
            return $this->error('', "当前商品在当前时间段内已经存在拼团活动");
        }

        if (time() > $pintuan_data[ 'end_time' ]) {
            return $this->error('', '当前时间不能大于结束时间');
        }
        if ($pintuan_data[ 'start_time' ] <= time()) {
            $pintuan_data[ 'status' ] = 1;
        } else {
            $pintuan_data[ 'status' ] = 0;
        }
        model("promotion_pintuan")->startTrans();
        try {

            foreach ($goods[ 'goods_ids' ] as $goods_id) {

                //添加拼团活动
                $pintuan_data[ 'goods_id' ] = $goods_id;
                $pintuan_id = model("promotion_pintuan")->add($pintuan_data);

                $sku_list_data = [];
                foreach ($sku_list as $k => $sku) {
                    if ($sku[ 'goods_id' ] == $goods_id) {

                        $promotion_price = $sku[ 'pintuan_price' ];
                        if (isset($pintuan_data[ 'is_promotion' ]) && $pintuan_data[ 'is_promotion' ] == 1) {
                            $promotion_price = $sku[ 'promotion_price' ];
                        }
                        $sku_list_data[] = [
                            'site_id' => $pintuan_data[ 'site_id' ],
                            'pintuan_id' => $pintuan_id,
                            'goods_id' => $pintuan_data[ 'goods_id' ],
                            'sku_id' => $sku[ 'sku_id' ],
                            'pintuan_price' => $sku[ 'pintuan_price' ],
                            'promotion_price' => $promotion_price,
                            'pintuan_price_2' => $sku[ 'pintuan_price_2' ],
                            'pintuan_price_3' => $sku[ 'pintuan_price_3' ],
                        ];
                    }
                }
                array_multisort(array_column($sku_list_data, 'pintuan_price'), SORT_ASC, $sku_list_data);
                model('promotion_pintuan_goods')->addList($sku_list_data);

                model('promotion_pintuan')->update([ 'pintuan_price' => $sku_list_data[ 0 ][ 'pintuan_price' ] ], [ [ 'pintuan_id', '=', $pintuan_id ] ]);

                $cron = new Cron();
                if ($pintuan_data[ 'status' ] == 1) {
                    $goods = new Goods();
                    $goods->modifyPromotionAddon($goods_id, [ 'pintuan' => $pintuan_id ]);
                    $cron->addCron(1, 0, "拼团活动关闭", "ClosePintuan", $pintuan_data[ 'end_time' ], $pintuan_id);
                } else {
                    $cron->addCron(1, 0, "拼团活动开启", "OpenPintuan", $pintuan_data[ 'start_time' ], $pintuan_id);
                    $cron->addCron(1, 0, "拼团活动关闭", "ClosePintuan", $pintuan_data[ 'end_time' ], $pintuan_id);
                }
            }

            model('promotion_pintuan')->commit();
            return $this->success();
        } catch (\Exception $e) {
            model('promotion_pintuan')->rollback();
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 编辑拼团
     * @param $pintuan_data
     * @param $goods
     * @param $sku_list
     * @return array
     */
    public function editPintuan($pintuan_data, $goods, $sku_list)
    {
        if (empty($goods[ 'sku_ids' ])) {
            return $this->error('', '该活动至少需要一个商品参与');
        }
        //查询该商品是否存在拼团
        $pintuan_info = model('promotion_pintuan_goods')->getInfo(
            [
                [ 'ppg.site_id', '=', $pintuan_data[ 'site_id' ] ],
                [ 'pp.status', 'in', '0,1' ],
                [ 'pp.pintuan_id', '<>', $pintuan_data[ 'pintuan_id' ] ],
                [ 'ppg.sku_id', 'in', $goods[ 'sku_ids' ] ],
                [ '', 'exp', Db::raw('not ( (`start_time` > ' . $pintuan_data[ 'end_time' ] . ' and `start_time` > ' . $pintuan_data[ 'start_time' ] . ' )  or (`end_time` < ' . $pintuan_data[ 'start_time' ] . ' and `end_time` < ' . $pintuan_data[ 'end_time' ] . '))') ]
            ], 'ppg.id', 'ppg', [ [ 'promotion_pintuan pp', 'pp.pintuan_id = ppg.pintuan_id', 'left' ] ]
        );
        if (!empty($pintuan_info)) {
            return $this->error('', "当前商品在当前时间段内已经存在拼团活动");
        }

        $pintuan_count = model("promotion_pintuan")->getCount([ [ 'pintuan_id', '=', $pintuan_data[ 'pintuan_id' ] ], [ 'site_id', '=', $pintuan_data[ 'site_id' ] ] ]);
        if ($pintuan_count == 0) {
            return $this->error('', '该拼团活动不存在');
        }

        $cron = new Cron();
        if (time() > $pintuan_data[ 'end_time' ]) {
            return $this->error('', '当前时间不能大于结束时间');
        }
        if ($pintuan_data[ 'start_time' ] <= time()) {
            $pintuan_data[ 'status' ] = 1;
        } else {
            $pintuan_data[ 'status' ] = 0;
        }

        $pintuan_data[ 'modify_time' ] = time();

        model('promotion_pintuan')->startTrans();
        try {
            $sku_list_data = [];
            foreach ($sku_list as $k => $sku) {
                $count = model('promotion_pintuan_goods')->getCount([ [ 'sku_id', '=', $sku[ 'sku_id' ] ], [ 'pintuan_id', '=', $pintuan_data[ 'pintuan_id' ] ] ]);
                $is_delete = $sku[ 'is_delete' ];
                unset($sku[ 'is_delete' ]);
                if ($is_delete == 2) {//是否参与  1参与  2不参与
                    if ($count) {
                        model('promotion_pintuan_goods')->delete([ [ 'sku_id', '=', $sku[ 'sku_id' ] ], [ 'pintuan_id', '=', $pintuan_data[ 'pintuan_id' ] ] ]);
                    }
                } else {

                    $promotion_price = $sku[ 'pintuan_price' ];
                    if (isset($pintuan_data[ 'is_promotion' ]) && $pintuan_data[ 'is_promotion' ] == 1) {
                        $promotion_price = $sku[ 'promotion_price' ];
                    }
                    $sku_data = [
                        'site_id' => $pintuan_data[ 'site_id' ],
                        'pintuan_id' => $pintuan_data[ 'pintuan_id' ],
                        'goods_id' => $sku[ 'goods_id' ],
                        'sku_id' => $sku[ 'sku_id' ],
                        'pintuan_price' => $sku[ 'pintuan_price' ],
                        'promotion_price' => $promotion_price,
                        'pintuan_price_2' => $sku[ 'pintuan_price_2' ],
                        'pintuan_price_3' => $sku[ 'pintuan_price_3' ],
                    ];
                    $sku_list_data[] = $sku_data;
                    if ($count > 0) {
                        model('promotion_pintuan_goods')->update($sku_data, [ [ 'sku_id', '=', $sku[ 'sku_id' ] ], [ 'pintuan_id', '=', $pintuan_data[ 'pintuan_id' ] ] ]);
                    } else {
                        model('promotion_pintuan_goods')->add($sku_data);
                    }
                }
            }

            array_multisort(array_column($sku_list_data, 'pintuan_price'), SORT_ASC, $sku_list_data);
            model("promotion_pintuan")->update(
                array_merge($pintuan_data, [ 'pintuan_price' => $sku_list_data[ 0 ][ 'pintuan_price' ] ]),
                [ [ 'pintuan_id', '=', $pintuan_data[ 'pintuan_id' ] ] ]
            );

            if ($pintuan_data[ 'start_time' ] <= time()) {
                $goods = new Goods();
                $goods->modifyPromotionAddon($pintuan_data[ 'goods_id' ], [ 'pintuan' => $pintuan_data[ 'pintuan_id' ] ]);
                //活动商品启动
                $this->cronOpenPintuan($pintuan_data[ 'pintuan_id' ]);
                $cron->deleteCron([ [ 'event', '=', 'OpenPintuan' ], [ 'relate_id', '=', $pintuan_data[ 'pintuan_id' ] ] ]);
                $cron->deleteCron([ [ 'event', '=', 'ClosePintuan' ], [ 'relate_id', '=', $pintuan_data[ 'pintuan_id' ] ] ]);

                $cron->addCron(1, 0, "拼团活动关闭", "ClosePintuan", $pintuan_data[ 'end_time' ], $pintuan_data[ 'pintuan_id' ]);
            } else {
                $cron->deleteCron([ [ 'event', '=', 'OpenPintuan' ], [ 'relate_id', '=', $pintuan_data[ 'pintuan_id' ] ] ]);
                $cron->deleteCron([ [ 'event', '=', 'ClosePintuan' ], [ 'relate_id', '=', $pintuan_data[ 'pintuan_id' ] ] ]);

                $cron->addCron(1, 0, "拼团活动开启", "OpenPintuan", $pintuan_data[ 'start_time' ], $pintuan_data[ 'pintuan_id' ]);
                $cron->addCron(1, 0, "拼团活动关闭", "ClosePintuan", $pintuan_data[ 'end_time' ], $pintuan_data[ 'pintuan_id' ]);
            }

            // 清除分享图片
            ( new Poster() )->clearShareImg($pintuan_data[ 'pintuan_id' ]);

            model('promotion_pintuan')->commit();
            return $this->success();
        } catch (\Exception $e) {
            model('promotion_pintuan')->rollback();
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 增加拼团组人数及购买人数
     * @param array $data
     * @param array $condition
     * @return array
     */
    public function editPintuanNum($data = [], $condition = [])
    {
        $res = model('promotion_pintuan')->update($data, $condition);
        return $this->success($res);
    }

    /**
     * 删除拼团
     * @param unknown $pintuan_id
     * @param unknown $site_id
     */
    public function deletePintuan($pintuan_id, $site_id)
    {
        $pintuan_info = model("promotion_pintuan")->getInfo([ [ 'pintuan_id', '=', $pintuan_id ], [ 'site_id', '=', $site_id ] ]);
        if ($pintuan_info[ 'status' ] == 1) {
            return $this->error('', "当前活动再进行中，不能删除");
        }
        $res = model("promotion_pintuan")->delete([ [ 'pintuan_id', '=', $pintuan_id ], [ 'site_id', '=', $site_id ] ]);
        if ($res) {
            //删除拼团商品
            model("promotion_pintuan_goods")->delete([ [ 'pintuan_id', '=', $pintuan_id ] ]);
            //删除拼团组
            model('promotion_pintuan_group')->delete([ [ 'pintuan_id', '=', $pintuan_id ] ]);
            $goods = new Goods();
            $goods->modifyPromotionAddon($pintuan_info[ 'goods_id' ], [ 'pintuan' => $pintuan_id ], true);
            $cron = new Cron();
            $cron->deleteCron([ [ 'event', '=', 'OpenPintuan' ], [ 'relate_id', '=', $pintuan_id ] ]);
            $cron->deleteCron([ [ 'event', '=', 'ClosePintuan' ], [ 'relate_id', '=', $pintuan_id ] ]);
        }
        return $this->success($res);
    }

    /**
     * 拼团失效
     * @param unknown $pintuan_id
     * @param unknown $site_id
     */
    public function invalidPintuan($pintuan_id, $site_id)
    {
        model('promotion_pintuan')->startTrans();
        try {
            $pintuan_info = model("promotion_pintuan")->getInfo([ [ 'pintuan_id', '=', $pintuan_id ], [ 'site_id', '=', $site_id ] ]);

            $res = model("promotion_pintuan")->update(
                [ 'status' => 3, 'modify_time' => time() ],
                [ [ 'pintuan_id', '=', $pintuan_id ], [ 'site_id', '=', $site_id ] ]
            );

            if ($pintuan_info[ 'group_num' ] > 0) {//有人拼团
                //查询所有拼团组
                $group_model = new PintuanGroup();
                //$group_info = $group_model->getPintuanGroupList([ [ 'pintuan_id', '=', $pintuan_id ] ], 'group_id');
//                $group_list = model("promotion_pintuan_group")->pageList([ [ 'pintuan_id', '=', $pintuan_id, 'status', '<>', 1 ] ], 'group_id', "",1, 50);
                $group_list = model("promotion_pintuan_group")->pageList([ [ 'pintuan_id', '=', $pintuan_id ], [ 'status', '<>', 1 ] ], 'group_id', "", 1, 50);
                if ((int) $group_list[ 'page_count' ] > 1) {
                    //新增事件
                    $cron = new Cron();
                    $cron->addCron(1, 0, "拼团活动关闭", "ClosePintuan", $pintuan_info[ 'end_time' ], $pintuan_id);
                }
                $group = $group_list[ 'list' ];

                if (!empty($group)) {
                    foreach ($group as $v) {

                        $result = $group_model->cronClosePintuanGroup($v[ 'group_id' ]);
                        if ($result[ 'code' ] < 0) {
                            model('promotion_pintuan')->rollback();
                            return $result;
                        }
                    }
                }
            }

            $goods = new Goods();
            $goods->modifyPromotionAddon($pintuan_info[ 'goods_id' ], [ 'pintuan' => $pintuan_id ], true);

            model('promotion_pintuan')->commit();
            return $this->success($res);
        } catch (\Exception $e) {
            model('promotion_pintuan')->rollback();
            return $this->error($e->getMessage());
        }

    }

    /**
     * 获取拼团信息
     * @param array $condition
     * @param string $field
     * @return array
     */
    public function getPintuanInfo($condition = [], $field = '*', $alias = '', $join = '')
    {
        $pintuan_info = model("promotion_pintuan")->getInfo($condition, $field, $alias, $join);
        return $this->success($pintuan_info);
    }

    /**
     * 获取拼团详细信息
     * @param $pintuan_id
     * @param $site_id
     * @return array
     */
    public function getPintuanDetail($pintuan_id, $site_id)
    {
        //拼团信息
        $alias = 'p';
        $join = [
            [
                'goods g',
                'g.goods_id = p.goods_id',
                'inner'
            ]
        ];
        $pintuan_info = model("promotion_pintuan")->getInfo(
            [
                [ 'p.pintuan_id', '=', $pintuan_id ], [ 'p.site_id', '=', $site_id ],
                [ 'g.goods_state', '=', 1 ], [ 'g.is_delete', '=', 0 ]
            ], 'p.*', $alias, $join
        );
        if (!empty($pintuan_info)) {
            //商品sku信息
            $goods_list = model('goods_sku')->getList(
                [ [ 'goods_id', '=', $pintuan_info[ 'goods_id' ] ] ],
                'goods_id,sku_id,sku_name,price,sku_images,stock,sku_image,goods_name'
            );
            foreach ($goods_list as $k => $v) {
                $v[ 'stock' ] = numberFormat($v[ 'stock' ]);

                $pintuan_goods = model('promotion_pintuan_goods')->getInfo(
                    [ [ 'pintuan_id', '=', $pintuan_id ], [ 'sku_id', '=', $v[ 'sku_id' ] ] ],
                    'pintuan_price,promotion_price,pintuan_price_2,pintuan_price_3'
                );
                if (empty($pintuan_goods)) {
                    $pintuan_goods = [
                        'pintuan_price' => 0,
                        'promotion_price' => 0,
                        'pintuan_price_2' => 0,
                        'pintuan_price_3' => 0,
                    ];
                }
                $goods_list[ $k ] = array_merge($v, $pintuan_goods);
            }
            array_multisort(array_column($goods_list, 'pintuan_price'), SORT_DESC, $goods_list);
            $pintuan_info[ 'sku_list' ] = $goods_list;
        }
        return $this->success($pintuan_info);
    }

    /**
     * 获取拼团详细信息
     * @param $pintuan_id
     * @param $site_id
     * @return array
     */
    public function getPintuanJoinGoodsList($pintuan_id, $site_id)
    {
        //拼团信息
        $alias = 'p';
        $join = [
            [ 'goods g', 'g.goods_id = p.goods_id', 'inner' ]
        ];
        $pintuan_info = model("promotion_pintuan")->getInfo(
            [
                [ 'p.pintuan_id', '=', $pintuan_id ], [ 'p.site_id', '=', $site_id ],
                [ 'g.goods_state', '=', 1 ], [ 'g.is_delete', '=', 0 ]
            ], 'p.*', $alias, $join
        );
        if (!empty($pintuan_info)) {
            $goods_list = model('promotion_pintuan_goods')->getList(
                [ [ 'ppg.pintuan_id', '=', $pintuan_info[ 'pintuan_id' ] ] ],
                'ppg.pintuan_price,ppg.pintuan_price_2,ppg.pintuan_price_3,ppg.promotion_price,sku.sku_id,sku.sku_name,sku.price,sku.sku_image,sku.stock',
                '', 'ppg', [ [ 'goods_sku sku', 'sku.sku_id = ppg.sku_id', 'inner' ] ]
            );
            foreach ($goods_list as $k => $v) {
                $goods_list[ $k ][ 'stock' ] = numberFormat($goods_list[ $k ][ 'stock' ]);
            }
            $pintuan_info[ 'sku_list' ] = $goods_list;
        }
        return $this->success($pintuan_info);
    }

    /**
     * 拼团商品详情
     * @param array $condition
     * @param string $field
     * @return array
     */
    public function getPintuanGoodsDetail($condition = [], $field = '')
    {
        $alias = 'ppg';
        if (empty($field)) {
            $field = 'pp.order_num,ppg.id,ppg.pintuan_id,ppg.goods_id,ppg.sku_id,ppg.pintuan_price,ppg.promotion_price,pp.pintuan_name,pp.pintuan_num,pp.start_time,pp.end_time,pp.buy_num,pp.is_single_buy,pp.is_promotion,pp.group_num,pp.order_num,sku.site_id,sku.sku_name,sku.sku_spec_format,sku.price,sku.promotion_type,sku.stock,sku.click_num,(g.sale_num + g.virtual_sale) as sale_num,sku.collect_num,sku.sku_image,sku.sku_images,sku.site_id,sku.goods_content,sku.goods_state,sku.is_virtual,sku.is_free_shipping,sku.goods_spec_format,sku.goods_attr_format,sku.introduction,sku.unit,sku.video_url,g.evaluate,sku.goods_service_ids,sku.support_trade_type,g.goods_image,g.goods_stock,g.goods_name,sku.qr_id,g.stock_show,g.sale_show,g.label_name,ppg.pintuan_price_2,ppg.pintuan_price_3,pp.pintuan_num_2,pp.pintuan_num_3,pp.pintuan_type,pp.remark';
        }
        $join = [
            [ 'goods_sku sku', 'ppg.sku_id = sku.sku_id', 'inner' ],
            [ 'goods g', 'g.goods_id = sku.goods_id', 'inner' ],
            [ 'promotion_pintuan pp', 'ppg.pintuan_id = pp.pintuan_id', 'inner' ],
        ];
        $pintuan_goods_info = model('promotion_pintuan_goods')->getInfo($condition, $field, $alias, $join);
        if (!empty($pintuan_goods_info)) {
            if (isset($pintuan_goods_info[ 'stock' ])) {
                $pintuan_goods_info[ 'stock' ] = numberFormat($pintuan_goods_info[ 'stock' ]);
            }
            if (isset($pintuan_goods_info[ 'sale_num' ])) {
                $pintuan_goods_info[ 'sale_num' ] = numberFormat($pintuan_goods_info[ 'sale_num' ]);
            }
            if (isset($pintuan_goods_info[ 'goods_stock' ])) {
                $pintuan_goods_info[ 'goods_stock' ] = numberFormat($pintuan_goods_info[ 'goods_stock' ]);
            }
            if (isset($pintuan_goods_info[ 'virtual_sale' ])) {
                $pintuan_goods_info[ 'virtual_sale' ] = numberFormat($pintuan_goods_info[ 'virtual_sale' ]);
            }
        }
        return $this->success($pintuan_goods_info);
    }

    /**
     * 拼团商品详情
     * @param array $condition
     * @return array
     */
    public function getPintuanGoodsSkuList($condition = [])
    {
        $alias = 'ppg';
        $field = 'pp.order_num,ppg.id,ppg.pintuan_id,ppg.goods_id,ppg.sku_id,ppg.pintuan_price,ppg.promotion_price,
        pp.pintuan_name,pp.pintuan_num,pp.start_time,pp.end_time,pp.buy_num,pp.is_single_buy,pp.is_promotion,pp.group_num,pp.order_num,
        sku.sku_name,sku.sku_spec_format,sku.price,sku.stock,sku.sku_image,sku.sku_images,sku.goods_spec_format,g.goods_image
        ,ppg.pintuan_price_2,ppg.pintuan_price_3,pp.pintuan_num_2,pp.pintuan_num_3,pp.pintuan_type';
        $join = [
            [ 'goods_sku sku', 'ppg.sku_id = sku.sku_id', 'inner' ],
            [ 'goods g', 'g.goods_id = sku.goods_id', 'inner' ],
            [ 'promotion_pintuan pp', 'ppg.pintuan_id = pp.pintuan_id', 'inner' ],
        ];
        $list = model('promotion_pintuan_goods')->getList($condition, $field, 'ppg.id asc', $alias, $join);
        foreach ($list as $k => $v) {
            $list[ $k ][ 'stock' ] = numberFormat($list[ $k ][ 'stock' ]);
        }
        return $this->success($list);
    }

    /**
     * 获取拼团分页列表
     * @param array $condition
     * @param number $page
     * @param string $page_size
     * @param string $order
     * @param string $field
     */
    public function getPintuanPageList($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = '')
    {
        $field = 'p.*,g.goods_name,g.goods_image,g.price';
        $alias = 'p';
        $join = [
            [
                'goods g',
                'p.goods_id = g.goods_id',
                'inner'
            ]
        ];
        $res = model('promotion_pintuan')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
        return $this->success($res);
    }

    /**
     * 获取拼团商品列表
     * @param $bargain_id
     * @param $site_id
     * @return array
     */
    public function getPintuanGoodsList($pintuan_id, $site_id)
    {
        $field = 'pbg.*,sku.sku_name,sku.price,sku.sku_image,sku.stock';
        $alias = 'pbg';
        $join = [
            [
                'goods g',
                'g.goods_id = pbg.goods_id',
                'inner'
            ],
            [
                'goods_sku sku',
                'sku.sku_id = pbg.sku_id',
                'inner'
            ]
        ];
        $condition = [
            [ 'pbg.pintuan_id', '=', $pintuan_id ], [ 'pbg.site_id', '=', $site_id ],
            [ 'g.is_delete', '=', 0 ], [ 'g.goods_state', '=', 1 ]
        ];

        $list = model('promotion_pintuan_goods')->getList($condition, $field, '', $alias, $join);
        foreach ($list as $k => $v) {
            $list[ $k ][ 'stock' ] = numberFormat($list[ $k ][ 'stock' ]);
        }
        return $this->success($list);
    }

    /**
     * 获取拼团商品数量
     * @param array $where
     * @param string $field
     * @param string $alias
     * @param null $join
     * @return array
     */
    public function getPintuanGoodsCount($where = [], $field = '*', $alias = 'a', $join = null, $group = null)
    {
        $count = model('promotion_pintuan_goods')->getCount($where, $field, $alias, $join, $group);
        return $this->success($count);
    }

    /**
     * 获取拼团商品详情
     * @param array $where
     * @param string $field
     * @param string $alias
     * @param null $join
     * @return array
     */
    public function getPintuanGoodsInfo($where = [], $field = '*', $alias = 'a', $join = null, $group = null)
    {
        $count = model('promotion_pintuan_goods')->getInfo($where, $field, $alias, $join, $group);
        return $this->success($count);
    }

    /**
     * 获取拼团商品分页列表
     * @param array $condition
     * @param number $page
     * @param string $page_size
     * @param string $order
     * @param string $field
     */
    public function getPintuanGoodsPageList($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = 'pp.pintuan_id desc', $field = '')
    {
        if (empty($field)) {
            $field = 'pp.order_num,pp.pintuan_id,pp.site_id,pp.pintuan_name,pp.is_virtual_goods,pp.pintuan_num,pp.pintuan_price,pp.pintuan_time,
            pp.is_recommend,pp.group_num,pp.order_num,g.price,g.goods_id,g.goods_name,g.goods_image,(g.sale_num + g.virtual_sale) as sale_num,g.unit,g.goods_stock,g.recommend_way,g.price';
        }
        $alias = 'pp';
        $join = [
            [ 'goods g', 'pp.goods_id = g.goods_id', 'inner' ],
        ];
        $res = model('promotion_pintuan')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
        foreach ($res[ 'list' ] as $k => $v) {
            if (isset($v[ 'sale_num' ])) {
                $res[ 'list' ][ $k ][ 'sale_num' ] = numberFormat($res[ 'list' ][ $k ][ 'sale_num' ]);
            }
            if (isset($v[ 'goods_stock' ])) {
                $res[ 'list' ][ $k ][ 'goods_stock' ] = numberFormat($res[ 'list' ][ $k ][ 'goods_stock' ]);
            }
            if (isset($v[ 'virtual_sale' ])) {
                $res[ 'list' ][ $k ][ 'virtual_sale' ] = numberFormat($res[ 'list' ][ $k ][ 'virtual_sale' ]);
            }
        }
        return $this->success($res);
    }

    /**
     * 获取拼团商品列表
     * @param array $condition
     * @param string $order
     * @param string $field
     */
    public function getPintuanList($condition = [], $field = '', $order = 'pp.pintuan_id desc', $limit = null)
    {
        if (empty($field)) {
            $field = 'pp.order_num,pp.pintuan_id,pp.site_id,pp.pintuan_name,pp.is_virtual_goods,pp.pintuan_num,pp.pintuan_price,pp.pintuan_time,pp.is_recommend,pp.group_num,pp.order_num,g.price,g.goods_id,g.goods_name,g.goods_image,(g.sale_num + g.virtual_sale) as sale_num,g.unit,g.goods_stock,g.recommend_way,g.price';
        }
        $alias = 'pp';
        $join = [
            [ 'goods g', 'pp.goods_id = g.goods_id', 'inner' ],
        ];
        $list = model('promotion_pintuan')->getList($condition, $field, $order, $alias, $join, '', $limit);
        foreach ($list as $k => $v) {
            if (isset($v[ 'goods_stock' ])) {
                $list[ $k ][ 'goods_stock' ] = numberFormat($list[ $k ][ 'goods_stock' ]);
            }
            if (isset($v[ 'sale_num' ])) {
                $list[ $k ][ 'sale_num' ] = numberFormat($list[ $k ][ 'sale_num' ]);
            }
        }
        return $this->success($list);
    }

    /**
     * 开启拼团活动
     * @param $pintuan_id
     * @return array|\multitype
     */
    public function cronOpenPintuan($pintuan_id)
    {
        $pintuan_info = model('promotion_pintuan')->getInfo([ [ 'pintuan_id', '=', $pintuan_id ] ], 'start_time,status,goods_id');
        if (!empty($pintuan_info)) {
            $goods = new Goods();
            $goods->modifyPromotionAddon($pintuan_info[ 'goods_id' ], [ 'pintuan' => $pintuan_id ]);
            if ($pintuan_info[ 'start_time' ] <= time() && $pintuan_info[ 'status' ] == 0) {
                $res = model('promotion_pintuan')->update([ 'status' => 1 ], [ [ 'pintuan_id', '=', $pintuan_id ] ]);
                return $this->success($res);
            } else {
                return $this->error("", "拼团活动已开启或者关闭");
            }

        } else {
            return $this->error("", "拼团活动不存在");
        }

    }

    /**
     * 关闭拼团活动
     * @param $pintuan_id
     * @return array|\multitype
     */
    public function cronClosePintuan($pintuan_id)
    {
        $pintuan_info = model('promotion_pintuan')->getInfo([ [ 'pintuan_id', '=', $pintuan_id ] ], 'site_id,start_time,status');
        if (!empty($pintuan_info)) {
            return $this->invalidPintuan($pintuan_id, $pintuan_info[ 'site_id' ]);
        } else {
            return $this->error("", "拼团活动不存在");
        }
    }

    /**
     * 判断规格值是否禁用
     * @param $bargain_id
     * @param $site_id
     * @param $goods
     * @return false|string
     */
    public function getGoodsSpecFormat($pintuan_id, $site_id, $goods_spec_format = '', $sku_id = 0)
    {
        //获取活动参与的商品sku_ids
        $sku_ids = model('promotion_pintuan_goods')->getColumn([ [ 'pintuan_id', '=', $pintuan_id ], [ 'site_id', '=', $site_id ] ], 'sku_id');
        $goods_model = new Goods();
        if ($sku_id == 0) {
            $res = $goods_model->getGoodsSpecFormat($sku_ids, $goods_spec_format);
        } else {
            $res = $goods_model->getEmptyGoodsSpecFormat($sku_ids, $sku_id);
        }
        return $res;
    }

    /**
     * 拼团失效
     * @param unknown $pintuan_id
     * @param unknown $site_id
     */
    public function invalidPintuanTo($pintuan_id, $site_id)
    {
        model('promotion_pintuan')->startTrans();
        try {
            $pintuan_info = model("promotion_pintuan")->getInfo([ [ 'pintuan_id', '=', $pintuan_id ], [ 'site_id', '=', $site_id ] ]);

            $res = model("promotion_pintuan")->update(
                [ 'status' => 3, 'modify_time' => time() ],
                [ [ 'pintuan_id', '=', $pintuan_id ], [ 'site_id', '=', $site_id ] ]
            );

            if ($pintuan_info[ 'group_num' ] > 0) {//有人拼团
                //查询所有拼团组
                $group_model = new PintuanGroup();
                $group_info = $group_model->getPintuanGroupList([ [ 'pintuan_id', '=', $pintuan_id ] ], 'group_id');
//                $group_list = model("promotion_pintuan_group")->pageList([ [ 'pintuan_id', '=', $pintuan_id, 'status', '<>', 1 ] ], 'group_id', "",1, 50);
//                if($group_list['count'] > 1){
//                    //新增事件
//                    $cron = new Cron();
//                    $cron->addCron(1, 0, "拼团活动关闭", "ClosePintuan", $pintuan_info[ 'end_time' ], $pintuan_id);
//                }
                $group = $group_info[ 'data' ];

                if (!empty($group)) {
                    foreach ($group as $v) {

                        $result = $group_model->cronClosePintuanGroup($v[ 'group_id' ]);
                        if ($result[ 'code' ] < 0) {
                            model('promotion_pintuan')->rollback();
                            return $result;
                        }
                    }
                }
            }

            $goods = new Goods();
            $goods->modifyPromotionAddon($pintuan_info[ 'goods_id' ], [ 'pintuan' => $pintuan_id ], true);

            model('promotion_pintuan')->commit();
            return $this->success($res);
        } catch (\Exception $e) {
            model('promotion_pintuan')->rollback();
            return $this->error($e->getMessage());
        }

    }

    /**
     * 生成拼团二维码
     * @param $pintuan_id
     * @param string $name
     * @param string $type 类型 create创建 get获取
     * @return mixed|array
     */
    public function qrcode($pintuan_id, $name, $site_id, $type = 'create')
    {
        $data = [
            'site_id' => $site_id,
            'app_type' => "all", // all为全部
            'type' => $type, // 类型 create创建 get获取
            'data' => [
                'pintuan_id' => $pintuan_id
            ],
            'page' => '/pages_promotion/pintuan/detail',
            'qrcode_path' => 'upload/qrcode/pintuan',
            'qrcode_name' => "pintuan_qrcode_" . $pintuan_id
        ];

        event('Qrcode', $data, true);
        $app_type_list = config('app_type');
        $path = [];
        foreach ($app_type_list as $k => $v) {
            switch ( $k ) {
                case 'h5':
                    $wap_domain = getH5Domain();
                    $path[ $k ][ 'status' ] = 1;
                    $path[ $k ][ 'url' ] = $wap_domain . $data[ 'page' ] . '?id=' . $pintuan_id;
                    $path[ $k ][ 'img' ] = "upload/qrcode/pintuan/pintuan_qrcode_" . $pintuan_id . "_" . $k . ".png";
                    break;
                case 'weapp' :
                    $config = new ConfigModel();
                    $res = $config->getConfig([ [ 'site_id', '=', $site_id ], [ 'app_module', '=', 'shop' ], [ 'config_key', '=', 'WEAPP_CONFIG' ] ]);
                    if (!empty($res[ 'data' ])) {
                        if (empty($res[ 'data' ][ 'value' ][ 'qrcode' ])) {
                            $path[ $k ][ 'status' ] = 2;
                            $path[ $k ][ 'message' ] = '未配置微信小程序';
                        } else {
                            $path[ $k ][ 'status' ] = 1;
                            $path[ $k ][ 'img' ] = $res[ 'data' ][ 'value' ][ 'qrcode' ];
                        }

                    } else {
                        $path[ $k ][ 'status' ] = 2;
                        $path[ $k ][ 'message' ] = '未配置微信小程序';
                    }
                    break;
                case 'wechat' :
                    $config = new ConfigModel();
                    $res = $config->getConfig([ [ 'site_id', '=', $site_id ], [ 'app_module', '=', 'shop' ], [ 'config_key', '=', 'WECHAT_CONFIG' ] ]);
                    if (!empty($res[ 'data' ])) {
                        if (empty($res[ 'data' ][ 'value' ][ 'qrcode' ])) {
                            $path[ $k ][ 'status' ] = 2;
                            $path[ $k ][ 'message' ] = '未配置微信公众号';
                        } else {
                            $path[ $k ][ 'status' ] = 1;
                            $path[ $k ][ 'img' ] = $res[ 'data' ][ 'value' ][ 'qrcode' ];
                        }
                    } else {
                        $path[ $k ][ 'status' ] = 2;
                        $path[ $k ][ 'message' ] = '未配置微信公众号';
                    }
                    break;
            }

        }

        $return = [
            'path' => $path,
            'name' => $name,
        ];

        return $this->success($return);
    }

    /**
     * 商品用到的分类
     * @param $condition
     * @return array
     */
    public function getGoodsCategoryIds($condition)
    {
        $cache_name = "shop_pintuan_goods_category_" . md5(json_encode($condition));
        $cache_time = 60;
        $cache_res = Cache::get($cache_name);
        if (empty($cache_res) || time() - $cache_res[ 'time' ] > $cache_time) {
            $list = Db::name('promotion_pintuan')
                ->alias('pp')
                ->join('goods g', 'pp.goods_id = g.goods_id', 'inner')
                ->where($condition)
                ->group('g.category_id')
                ->column('g.category_id');
            $category_ids = trim(join('0', $list), ',');
            $category_id_arr = array_unique(explode(',', $category_ids));
            Cache::set($cache_name, [ 'time' => time(), 'data' => $category_id_arr ]);
        } else {
            $category_id_arr = $cache_res[ 'data' ];
        }
        return $this->success($category_id_arr);
    }

    public function urlQrcode($page, $qrcode_param, $promotion_type, $site_id)
    {
        $params = [
            'site_id' => $site_id,
            'data' => $qrcode_param,
            'page' => $page,
            'promotion_type' => $promotion_type,
            'h5_path' => $page . '?id=' . $qrcode_param[ 'id' ],
            'qrcode_path' => 'upload/qrcode/pintuan',
            'qrcode_name' => 'pintuan_qrcode_' . $promotion_type . '_' . $qrcode_param[ 'id' ] . '_' . $site_id,
        ];

        $solitaire = event('ExtensionInformation', $params, true);
        return $this->success($solitaire);
    }

    /**
     * 获取拼团价格
     * @param $params
     */
    public function getPintuanPrice($params)
    {
        $pintuan_type = $params[ 'pintuan_type' ];
        $price = 0;
        switch ( $pintuan_type ) {
            case 'ordinary'://默认拼团方式
                //判断是否是开团 团长
                if ($params[ "group_id" ] > 0) {
                    $price = $params[ "pintuan_price" ];//参团价
                } else {
                    $price = $params[ "promotion_price" ];//开团价
                }
                break;
            case 'ladder'://阶梯拼团
                $pintuan_num = $params[ 'pintuan_num' ];
                $pintuan_num_2 = $params[ 'pintuan_num_2' ];
                $pintuan_num_3 = $params[ 'pintuan_num_3' ];
                $pintuan_ladder = $params[ 'pintuan_ladder' ];
                switch ( $pintuan_ladder ) {
                    case $pintuan_num:
                        $price = $params[ "pintuan_price" ];//一级参团价
                        break;
                    case $pintuan_num_2:
                        $price = $params[ "pintuan_price_2" ];//二级参团价
                        break;
                    case $pintuan_num_3:
                        $price = $params[ "pintuan_price_3" ];//三级参团价
                        break;
                }
                break;
        }

        return $price;

    }

    /**
     * 拼团失败消息
     * @param $data
     */
    public function pintuanFailMessage($data)
    {
        //发送短信
        $sms_model = new Sms();
        $order_id = $data[ "order_id" ];
        $time = $data[ 'time' ] ?? time();
        $order_info = model('order')->getInfo([ [ "order_id", "=", $order_id ] ]);
        $pintuan_order_id = model('promotion_pintuan_order')->getValue([ [ 'order_id', '=', $order_id ] ], 'id');

        $member_model = new Member();
        $member_info_result = $member_model->getMemberInfo([ [ "member_id", "=", $order_info[ "member_id" ] ] ]);
        $member_info = $member_info_result[ "data" ];

        $var_parse = array (
            "sku_name" => $order_info[ "order_name" ],//商品名称
        );
        $data[ "sms_account" ] = $member_info[ "mobile" ];//手机号
        $data[ "var_parse" ] = $var_parse;
        $sms_model->sendMessage($data);

        if (!empty($member_info) && !empty($member_info[ "wx_openid" ])) {
            $wechat_model = new WechatMessage();
            $data[ "openid" ] = $member_info[ "wx_openid" ];
            $data[ "template_data" ] = [
                'keyword1' => str_sub($order_info[ 'order_name' ]),
                'keyword2' => $order_info[ 'refund_money' ],
            ];
            $data[ "page" ] = 'pages_promotion/pintuan/share?id=' . $pintuan_order_id;
            $wechat_model->sendMessage($data);
        }

        //发送订阅消息
        if (!empty($member_info) && !empty($member_info[ "weapp_openid" ])) {
            $weapp_model = new WeappMessage();
            $data[ "openid" ] = $member_info[ "weapp_openid" ];
            $data[ "template_data" ] = [
                'thing1' => [
                    'value' => str_sub($order_info[ 'order_name' ])
                ],

                'amount3' => [
                    'value' => $order_info[ 'refund_money' ]
                ],
            ];
            $data[ "page" ] = 'pages_promotion/pintuan/share?id=' . $pintuan_order_id;
            $weapp_model->sendMessage($data);
        }

    }

    /**
     * 拼团成功消息
     * @param $data
     */
    public function pintuanCompleteMessage($data)
    {
        //发送短信
        $sms_model = new Sms();
        $order_id = $data[ "order_id" ];
        $time = $data[ 'time' ] ?? time();
        $order_info = model('order')->getInfo([ [ "order_id", "=", $order_id ] ]);

        $pintuan_order_id = model('promotion_pintuan_order')->getValue([ [ 'order_id', '=', $order_id ] ], 'id');
        $member_model = new Member();
        $member_info_result = $member_model->getMemberInfo([ [ "member_id", "=", $order_info[ "member_id" ] ] ]);
        $member_info = $member_info_result[ "data" ];

        $var_parse = array (
            "sku_name" => $order_info[ "order_name" ],//商品名称
        );
        $data[ "sms_account" ] = $member_info[ "mobile" ];//手机号
        $data[ "var_parse" ] = $var_parse;
        $sms_model->sendMessage($data);

        if (!empty($member_info) && !empty($member_info[ "wx_openid" ])) {
            $wechat_model = new WechatMessage();
            $data[ "openid" ] = $member_info[ "wx_openid" ];
            $data[ "template_data" ] = [
                'keyword1' => str_sub($order_info[ 'order_name' ]),
                'keyword2' => time_to_date($time),
            ];
            $data[ "page" ] = 'pages_promotion/pintuan/share?id=' . $pintuan_order_id;
            $wechat_model->sendMessage($data);
        }

        //发送订阅消息
        if (!empty($member_info) && !empty($member_info[ "weapp_openid" ])) {
            $weapp_model = new WeappMessage();
            $data[ "openid" ] = $member_info[ "weapp_openid" ];
            $data[ "template_data" ] = [
                'thing5' => [
                    'value' => str_sub($order_info[ 'order_name' ])
                ],
                'time7' => [
                    'value' => time_to_date($time)
                ],
            ];
            $data[ "page" ] = 'pages_promotion/pintuan/share?id=' . $pintuan_order_id;
            $weapp_model->sendMessage($data);
        }

    }
}