幸运拼系统代码幸运拼团系统源码分享

/**
 * TODO 拼团产品Model
 * Class StoreCombination
 * @package appmodelsstore
 */
class StoreCombination extends BaseModel
{
    /**
     * 数据表主键
     * @var string
     */
    protected $pk = 'id';

    /**
     * 模型名称
     * @var string
     */
    protected $name = 'store_combination';

    use ModelTrait;

    public function getDescriptionAttr($value)
    {
        return htmlspecialchars_decode($value);
    }

    /**
     * @param $where
     * @return array
     */
    public static function get_list($length = 10)
    {
        if ($post = input('post.')) {
            $where = $post['where'];
            $model = new self();
            $model = $model->alias('c');
            $model = $model->join('StoreProduct s', 's.id=c.product_id');
            $model = $model->where('c.is_show', 1)->where('c.is_del', 0)->where('c.start_time', '<', time())->where('c.stop_time', '>', time());
            if (!empty($where['search'])) {
                $model = $model->where('c.title', 'like', "%{$where['search']}%");
                $model = $model->whereOr('s.keyword', 'like', "{$where['search']}%");
            }
            $model = $model->field('c.*,s.price as product_price');
            if ($where['key']) {
                if ($where['sales'] == 1) {
                    $model = $model->order('c.sales desc');
                } else if ($where['sales'] == 2) {
                    $model = $model->order('c.sales asc');
                }
                if ($where['price'] == 1) {
                    $model = $model->order('c.price desc');
                } else if ($where['price'] == 2) {
                    $model = $model->order('c.price asc');
                }
                if ($where['people'] == 1) {
                    $model = $model->order('c.people asc');
                }
                if ($where['default'] == 1) {
                    $model = $model->order('c.sort desc,c.id desc');
                }
            } else {
                $model = $model->order('c.sort desc,c.id desc');
            }
            $page = is_string($where['page']) ? (int)$where['page'] + 1 : $where['page'] + 1;
            $list = $model->page($page, $length)->select()->toArray();
            return ['list' => $list, 'page' => $page];
        }
    }

    /**
     * 获取拼团数据
     * @param int $page
     * @param int $limit
     * @return mixed
     */
    public static function getAll($page = 0, $limit = 20)
    {
        $model = new self();
        $model = $model->alias('c');
        $model = $model->join('StoreProduct s', 's.id=c.product_id');
        $model = $model->field('c.*,s.price as product_price');
        $model = $model->order('c.sort desc,c.id desc');
        $model = $model->where('c.is_show', 1);
        $model = $model->where('c.is_del', 0);
        $model = $model->where('c.start_time', '<', time());
        $model = $model->where('c.stop_time', '>', time());
        if ($page) $model = $model->page($page, $limit);
        return $model->select()->each(function ($item) {
            $item['image'] = set_file_url($item['image']);
        });
    }

    /**
     * 获取是否有拼团产品
     * */
    public static function getPinkIsOpen()
    {
        return self::alias('c')->join('StoreProduct s', 's.id=c.product_id')->where('c.is_show', 1)->where('c.is_del', 0)
            ->where('c.start_time', '<', time())->where('c.stop_time', '>', time())->count();
    }

    /**
     * 获取一条拼团数据
     * @param $id
     * @return mixed
     */
    public static function getCombinationOne($id)
    {
        $model = new self();
        $model = $model->alias('c');
        $model = $model->join('StoreProduct s', 's.id=c.product_id');
        $model = $model->field('c.*,s.price as product_price,SUM(s.sales+s.ficti) as total');
        $model = $model->where('c.is_show', 1);
        $model = $model->where('c.is_del', 0);
        $model = $model->where('c.id', $id);
        $model = $model->where('c.start_time', '<', time());
        $model = $model->where('c.stop_time', '>', time() - 86400);
        $info = $model->find();
        if ($info['id']) {
            return $info;
        } else {
            return [];
        }
    }

    /**
     * 获取推荐的拼团产品
     * @return mixed
     */
    public static function getCombinationHost($limit = 0)
    {
        $model = new self();
        $model = $model->alias('c');
        $model = $model->join('StoreProduct s', 's.id=c.product_id');
        $model = $model->field('c.id,c.image,c.price,c.sales,c.title,c.people,s.price as product_price');
        $model = $model->where('c.is_del', 0);
        $model = $model->where('c.is_host', 1);
        $model = $model->where('c.start_time', '<', time());
        $model = $model->where('c.stop_time', '>', time());
        if ($limit) $model = $model->limit($limit);
        return $model->select();
    }

    /**
     * 修改销量和库存
     * @param $num
     * @param $CombinationId
     * @return bool
     */
    public static function decCombinationStock($num, $CombinationId, $unique)
    {
        $product_id = self::where('id', $CombinationId)->value('product_id');
        if ($unique) {
            $res = false !== StoreProductAttrValue::decProductAttrStock($CombinationId, $unique, $num, 3);
            $res = $res && self::where('id', $CombinationId)->dec('stock', $num)->dec('quota', $num)->inc('sales', $num)->update();
            $sku = StoreProductAttrValue::where('product_id', $CombinationId)->where('unique', $unique)->where('type', 3)->value('suk');
            $res = $res && StoreProductAttrValue::where('product_id', $product_id)->where('suk', $sku)->where('type', 0)->dec('stock', $num)->inc('sales', $num)->update();
        } else {
            $res = false !== self::where('id', $CombinationId)->dec('stock', $num)->inc('sales', $num)->update();
        }
        $res = $res && StoreProduct::where('id', $product_id)->dec('stock', $num)->inc('sales', $num)->update();
        return $res;
    }

    /**
     * 增加库存,减少销量
     * @param $num
     * @param $CombinationId
     * @return bool
     */
    public static function incCombinationStock($num, $CombinationId, $unique = '')
    {

        $combination = self::where('id', $CombinationId)->field(['product_id', 'stock', 'sales', 'quota'])->find();
        if (!$combination) return true;
        if ($combination->sales > 0) $combination->sales = bcsub($combination->sales, $num, 0);
        if ($combination->sales < 0) $combination->sales = 0;
        $res = true;
        if ($unique) {
            $res = false !== StoreProductAttrValue::incProductAttrStock($CombinationId, $unique, $num, 3);
            $sku = StoreProductAttrValue::where('product_id', $CombinationId)->where('unique', $unique)->where('type', 3)->value('suk');
            $res = $res && StoreProductAttrValue::where('product_id', $combination['product_id'])->where('suk', $sku)->where('type', 0)->inc('stock', $num)->dec('sales', $num)->update();
        }
        $combination->stock = bcadd($combination->stock, $num, 0);
        $combination->quota = bcadd($combination->quota, $num, 0);
        $res = $res && $combination->save() && StoreProduct::where('id', $combination['product_id'])->inc('stock', $num)->dec('sales', $num)->update();
        return $res;
    }

    /**
     * 判断库存是否足够
     * @param $id
     * @param $cart_num
     * @return int|mixed
     */
    public static function getCombinationStock($id, $cart_num)
    {
        $stock = self::where('id', $id)->value('stock');
        return $stock > $cart_num ? $stock : 0;
    }

    /**
     * 获取字段值
     * @param $id
     * @param $field
     * @return mixed
     */
    public static function getCombinationField($id, $field = 'title')
    {
        return self::where('id', $id)->value($field);
    }

    /**
     * 获取产品状态
     * @param $id
     * @return mixed
     */
    public static function isValidCombination($id)
    {
        $model = new self();
        $model = $model->where('id', $id);
        $model = $model->where('is_del', 0);
        $model = $model->where('is_show', 1);
        return $model->count();
    }

    /**
     * 增加浏览量
     * @param int $id
     * @return bool
     */
    public static function editIncBrowse($id = 0)
    {
        if (!$id) return false;
        $browse = self::where('id', $id)->value('browse');
        $browse = bcadd($browse, 1, 0);
        self::edit(['browse' => $browse], $id);
    }

    public static function completeGroup()
    {
        $fpff = fopen("./fflock.txt", "w+");

        if(flock($fpff,LOCK_EX)){

            $pinkListEndWin = self::pinkListEndWin();

            if (!$pinkListEndWin) return true;
            $pinkListEndWin = $pinkListEndWin->toArray();
            foreach ($pinkListEndWin as $key => $value) {
                $countPeople = (int)bcadd(StorePink::where('k_id', $value['id'])->count(), 1, 0);
                //如果拼团人数未达到
                if ($countPeople < $value['people']){
                    continue;
                }

                $pinkLists = StorePink::where('k_id', $value['id'])->column('id', 'id');
                $pinkLists[] = $value['id'];
                $pinkLists = array_values($pinkLists);

                //随机出中奖者
                $win_id_index = array_rand($pinkLists,1);
                //$win_id_index = 12;
                $win_id = $pinkLists[$win_id_index];
                if( !$win_id )
                    continue;

                try{
                    self::beginTrans();

                    //设置未已开奖
                    StorePink::where('id','IN',$pinkLists)->update(['is_win'=>1]);

                    /** ::todo 中奖处理开始 */
                    //拼团中奖
                    unset($pinkLists[$win_id_index]);
                    $win_info = StorePink::get($win_id);
                    if( ! $win_info )
                        continue;
                    $win_info = $win_info->toArray();

                    //发放中奖的推荐奖励
                    self::sendRecommendReward($win_info['uid'],$win_info['price'],$win_info['cid'],0);

                    //修改订单状态
                    $update_info = [
                        'status' => 2, //订单状态，
                    ];
                    StoreOrder::update($update_info,['order_id'=>$win_info['order_id']]);
                    /** ::todo 未中奖处理开始 */
                    self::failRefundPink($pinkLists);//申请退款

                    self::commitTrans();
                } catch (Exception $e)
                {
                    self::rollbackTrans();
                    var_dump($e->getMessage());
                    continue;
                }
            }
            flock($fpff,LOCK_UN);
        }

        fclose($fpff);
    }

    /**
     * 获取拼团数据
     * @return 	hinkCollection
     * @throws 	hinkdbexceptionDataNotFoundException
     * @throws 	hinkdbexceptionDbException
     * @throws 	hinkdbexceptionModelNotFoundException
     */
    public static function pinkListEndWin()
    {
        $model = StorePink::field('id,people');//开团编号
        $model = $model->where('stop_time', '<=', time());//小于当前时间
        $model = $model->where('status', 2);//进行中的拼团
        $model = $model->where('k_id', 0);//团长
        $model = $model->where('is_win', 0);//是否开奖
        $model = $model->where('is_refund', 0);//未退款
        return $model->select();
    }

    /**
     * 发放推广奖励
     * @param $uid
     * @param $price
     * @param $cid
     * @param int $type
     * @return mixed
     * @throws 	hinkException
     * @throws 	hinkdbexceptionDataNotFoundException
     * @throws 	hinkdbexceptionDbException
     * @throws 	hinkdbexceptionModelNotFoundException
     */
    public static function sendRecommendReward($uid,$price,$cid,$type=0)
    {
        $user_info = User::getUserInfo($uid);
        if( $user_info['spread_uid'] > 0 )
        {
            $combination_info = self::find($cid);
            if( $combination_info )
                $combination_info = $combination_info->toArray();

            $spreadUserInfo = User::getUserInfo($user_info['spread_uid']);
            if( $spreadUserInfo )
            {
                $reward_rate = $type ? $combination_info['indirect_recommend_tate'] : $combination_info['direct_recommend_tate'];
                $reward_num = bcmul($price,$reward_rate/100,2);
                if($reward_num){

                    $note = $type ? '间推奖励' : '直推奖励';
                    User::bcInc($spreadUserInfo['uid'], 'now_money', $reward_num, 'uid');
                    UserBill::income($note, $spreadUserInfo['uid'], 'now_money', 'product_profits', $reward_num, $combination_info['product_id'], bcadd($spreadUserInfo['now_money'], $reward_num, 2), $note . floatval($price) . '元');
                    if( $spreadUserInfo['spread_uid'] > 0 && $type == 0 )
                        return self::sendRecommendReward($spreadUserInfo['uid'],$price,$cid,1);

                }
            }
        }
    }


    /**
     * 拼团未中 申请退款
     * @param $pinkList
     * @return bool
     * @throws 	hinkException
     * @throws 	hinkdbexceptionDataNotFoundException
     * @throws 	hinkdbexceptionModelNotFoundException
     */
    public static function failRefundPink($pinkList)
    {

        $refundPinkList = StorePink::where('id', 'IN', $pinkList)->column('order_id,uid,price,id,cid,people,pid', 'id');

        if (!count($refundPinkList)) return true;

        foreach ($refundPinkList as $key => $item) {
            $fail_rebate_rate = self::where('id', $item['cid'])->value('fail_rebate_rate');
            if( $fail_rebate_rate < 0 )
                return false;

            $refund_price = bcdiv($item['price']*$fail_rebate_rate/100,$item['people']-1,2);

            $user_info = User::getUserInfo($item['uid']);

            //拼团未中奖返点
            User::bcInc($item['uid'], 'now_money', $refund_price, 'uid');
            UserBill::income('拼团未中奖', $item['uid'], 'now_money', 'product_profits', $refund_price, $item['pid'], bcadd($user_info['now_money'], $refund_price, 2), '拼团未中奖' . floatval($refund_price) . '元');

            User::bcInc($item['uid'], 'now_money', $item['price'], 'uid');
            UserBill::income('拼团未中奖退款', $item['uid'], 'now_money', 'product_profits', $item['price'], $item['pid'], bcadd($item['price'],bcadd($user_info['now_money'], $refund_price, 2),2), '拼团未中奖退款' . floatval($refund_price) . '元');

            //退款
            self::ptorderApplyRefund($item['order_id'], $item['uid'], '拼团未中奖');//申请退款

            //修改拼团订单状态
            StorePink::where('id', $item['id'])->update(['status' => 3]);

        }
    }

    /**
     * 退款处理
     * @param $uni
     * @param $uid
     * @param string $refundReasonWap
     * @param string $refundReasonWapExplain
     * @param array $refundReasonWapImg
     * @return bool
     * @throws 	hinkdbexceptionDataNotFoundException
     * @throws 	hinkdbexceptionModelNotFoundException
     */
    public static function ptorderApplyRefund($uni, $uid, $refundReasonWap = '', $refundReasonWapExplain = '', $refundReasonWapImg = [])
    {
        $order = StoreOrder::getUserOrderDetail($uid, $uni);
        if (!$order) return self::setErrorInfo('支付订单不存在!');
        if ($order['refund_status'] == 2) return self::setErrorInfo('订单已退款!');
        if ($order['refund_status'] == 1) return self::setErrorInfo('正在申请退款中!');
        if ($order['status'] == 1) return self::setErrorInfo('订单当前无法退款!');

        $res1 = false !== StoreOrderStatus::status($order['id'], 'apply_refund', '用户申请退款，原因：' . $refundReasonWap);
        $res2 = false !== StoreOrder::edit(['status'=>'-1','refund_status' => 2, 'refund_reason_time' => time(), 'refund_reason_wap' => $refundReasonWap, 'refund_reason_wap_explain' => $refundReasonWapExplain, 'refund_reason_wap_img' => json_encode($refundReasonWapImg)], $order['id'], 'id');
        return true;
    }