<?php


namespace app\api\logic;

use app\common\model\distribution\Distribution;
use app\common\model\distribution\DistributionLevel;
use app\common\model\goods\GoodsCategory;
use app\common\model\goods\GoodsSubsidy;
use app\common\model\order\Order;
use app\common\model\procurement\Mprocurement;
use app\common\model\procurement\Procurementset;
use app\common\model\shop\ShopFollow;
use app\common\model\user\User;
use app\common\basics\Logic;
use app\common\enum\FootprintEnum;
use app\common\model\distribution\DistributionGoods;
use app\common\model\goods\Goods;
use app\common\model\goods\GoodsCollect;
use app\common\model\goods\GoodsClick;
use app\common\model\goods\GoodsSpec;
use app\common\model\goods\GoodsComment;
use app\common\model\goods\GoodsCommentImage;
use app\common\model\SearchRecord;
use app\common\enum\GoodsEnum;
use app\common\model\seckill\SeckillGoods;
use app\common\model\shop\Shop;
use app\common\model\team\TeamActivity;
use app\common\model\team\TeamFound;
use app\common\model\team\TeamGoods;
use app\common\model\user\UserLevel;
use app\common\model\groupbuy\GroupbuyGoods;
use app\common\server\ConfigServer;
use app\common\server\UrlServer;
use think\facade\Db;


class GoodsLogic extends Logic
{
    /**
     * 商品详情
     */
    public static function getGoodsDetail($goodsId, $userId,$p_id,$set_id)
    {
        //获取用户折扣
        $discount = 10;
        if($userId){
            $user = User::where('id', $userId)->find();
            if($user && isset($user['level'])){
                $user_discount = UserLevel::where('id', $user['level'])->value('discount');
                if($user_discount && $user_discount > 0 && $user_discount <= 10){
                    $discount = $user_discount;
                }
            }
        }

        $onSaleWhere = "";
        $group_msg = Db::name("groupbuy_goods")->where("goods_id",$goodsId)->where("del",1)->where("status",1)->find();
        if($group_msg==null){
            // 销售中商品：未删除/审核通过/已上架
            $onSaleWhere = [
                'del' => GoodsEnum::DEL_NORMAL, // 未删除
                'status' => GoodsEnum::STATUS_SHELVES, // 上架中
                'audit_status' => GoodsEnum::AUDIT_STATUS_OK, // 审核通过
            ];

        }

        $goodsDetail = Goods::with(['goods_image', 'goods_item', 'shop'])
            ->field('id,type,name,image,video,remark,goods_remark,content,purchase_price,issuing_price,wholesale_price,market_price,min_price,max_price,is_show_stock,stock,sales_actual,sales_virtual,clicks,clicks_virtual,shop_id,poster,subsidy_id')
            ->where($onSaleWhere)
            ->where('id', $goodsId)
            ->findOrEmpty();
//        $goodsDetail['min_price'] = round(0.88*$goodsDetail['min_price'],2);
        if ($goodsDetail->isEmpty()) {
            self::$error = '商品已下架';
            return false;
        }

        Db::startTrans();
        try{
            // 获取返补比例, subsidy_id为0的就传递一个ID为4的固定ID
            $goodsDetail['subsidy'] = (new GoodsSubsidy())->getSubsidyById($goodsDetail['subsidy_id'] > 0 ? $goodsDetail['subsidy_id'] : 4);
            $goodsDetail['subsidy_txt'] = '最高返' . $goodsDetail['subsidy']['subsidy'];

            // 轮播图加域名
            foreach($goodsDetail['goods_image'] as &$item) {
                $item['uri'] = empty($item['uri']) ? '' : UrlServer::getFileUrl($item['uri']);
            }
            // 会员价
            $goodsDetail['member_price'] = 0;
            // 会员价数组
            $member_price = [];
            foreach ($goodsDetail['goods_item'] as &$goods_item) {
                $is_member = Goods::where('id',$goods_item['goods_id'])->value('is_member');
                $goods_item['is_member'] = $is_member;
                if($is_member == 1 && $discount && $userId){
                    $goods_item['member_price'] = round($goods_item['price']* $discount/10,2);
                    $goodsDetail['member_price'] =  round($goods_item['price']* $discount/10,2);
                    $member_price[] = $goodsDetail['member_price'];
                }
                // 规格图片处理
                $goods_item['image'] = empty($goods_item['image']) ? $goodsDetail['image'] : $goods_item['image'];
            }

            !empty($member_price) && $goodsDetail['member_price'] = min($member_price);

            // 增加点击量
            $goodsDetail->clicks += 1;
            $goodsDetail->save();

            // 转数组
            $goodsDetailArr = $goodsDetail->toArray();
            $goodsDetailArr['poster'] = !empty($goodsDetailArr['poster']) ? UrlServer::getFileUrl($goodsDetailArr['poster']) : '';
            foreach ($goodsDetailArr['goods_item'] as &$valItem){
                $valItem['limited_num'] = 0;
            }
            // 新增点击记录
            GoodsClick::create([
                'shop_id' => $goodsDetailArr['shop_id'],
                'user_id' => $userId,
                'goods_id' => $goodsId,
                'create_time' => time()
            ]);
            //店铺信息
            switch ($goodsDetailArr['shop']['type']){
                case 1 :
                    $type_desc = '官方自营';
                    break;
                case 2 :
                    $type_desc = '入驻商家';
                    break;
                default :
                    $type_desc = '入驻商家';
                    break;
            }
            $follow = Db::name('shop_follow')->where(['shop_id' => $goodsDetailArr['shop_id'],'status' => 1])->count('id');
            $goodsDetailArr['shop']['type_desc'] = $type_desc; //商家类型
            $goodsDetailArr['shop']['follow_num'] = $follow; //收藏人数

            //客服二维码
            $customer_image = ConfigServer::get('shop_customer_service','image','',$goodsDetailArr['shop_id']);
            if($customer_image){
                $customer_image = UrlServer::getFileUrl($customer_image);
            }
            $goodsDetailArr['shop']['customer_image'] = $customer_image;
            // 用户是否关注店铺
            $goodsDetailArr['shop']['shop_follow_status'] = 0;
            if($userId) { // 用户已登录
                $shopFollow = ShopFollow::where(['user_id'=>$userId, 'shop_id'=>$goodsDetailArr['shop_id']])->findOrEmpty();
                if(!$shopFollow->isEmpty()) {
                    $goodsDetailArr['shop']['shop_follow_status'] = $shopFollow['status'];
                }
            }

            // 店铺在售商品数量
            $goodsDetailArr['shop']['goods_on_sale'] = Goods::where($onSaleWhere)
                ->where('shop_id', $goodsDetailArr['shop_id'])
                ->count();
            $set = null;
            $w = [];
            $settpye = 0;
            if($p_id != 0&&$set_id!=0){
                $set = Procurementset::where("set_id",$set_id)->where("set_state",1)->find();
                if($set['set_pro']!=0){
                    $w[] = ['purchase_price', '>', 0];
                }else if($set['set_issued']!=0){
                    $w[] = ['issuing_price', '>', 0];
                }else if($set['set_wholesale']!=0){
                    $w[] = ['wholesale_price', '>', 0];
                }
            }
            if($p_id != 0&&$set_id==0){
                $settpye = 1;
                $set = Procurementset::where("u_id",$p_id)->where("set_state",1)->order("set_update desc")->limit(1)->find();
                $w[] = ['purchase_price|issuing_price|wholesale_price', '>', 0];
            }
            // 店铺推荐商品列表(9个)
            $goodsDetailArr['shop']['goods_list'] = Goods::field('id,name,image,market_price,min_price,market_price,purchase_price,issuing_price,wholesale_price, subsidy_id')
                ->where($onSaleWhere)
                ->where($w)
                ->where([
                    'shop_id' => $goodsDetailArr['shop_id'],
                    'is_recommend' => 1, // 推荐
                ])
                ->order([
                    'sales_actual' => 'desc',
                    'id' => 'desc'
                ])
                ->limit(9)
                ->select()
                ->toArray();

            foreach ($goodsDetailArr['shop']['goods_list'] as $key => $value) {
                // 获取返补比例, subsidy_id为0的就传递一个ID为4的固定ID
                $goodsDetailArr['shop']['goods_list'][$key]['subsidy'] = (new GoodsSubsidy())->getSubsidyById($value['subsidy_id'] > 0 ? $value['subsidy_id'] : 4);
                $goodsDetailArr['shop']['goods_list'][$key]['subsidy_txt'] = '最高返' . $goodsDetailArr['shop']['goods_list'][$key]['subsidy']['subsidy'];
            }

            if ($set != null&&$settpye!=1) {
                foreach ($goodsDetailArr['shop']['goods_list'] as $key => $value) {
                    if ($set['set_pro'] != 0) {
                        if ($set['set_pro_type'] == 1) {
                            $goodsDetailArr['shop']['goods_list'][$key]['purchase_price'] = round($value['purchase_price'] * (100 + $set['set_pro']) / 100, 2);
                        }
                        if ($set['set_pro_type'] == 3) {
                            $goodsDetailArr['shop']['goods_list'][$key]['purchase_price'] = round($value['purchase_price'] + $set['set_pro'], 2);
                        }
                    }
                    if ($set['set_issued'] != 0) {
                        if ($set['set_issued_type'] == 1) {
                            $goodsDetailArr['shop']['goods_list'][$key]['issuing_price'] = round($value['issuing_price'] * (100 + $set['set_issued']) / 100, 2);
                        }
                        if ($set['set_issued_type'] == 3) {
                            $goodsDetailArr['shop']['goods_list'][$key]['issuing_price'] = round($value['issuing_price'] + $set['set_issued'], 2);
                        }
                    }
                    if ($set['set_wholesale'] != 0) {
                        if ($set['set_wholesale_type'] == 1) {
                            $goodsDetailArr['shop']['goods_list'][$key]['wholesale_price'] = round($value['wholesale_price'] * (100 + $set['set_wholesale']) / 100, 2);
                        }
                        if ($set['set_wholesale_type'] == 3) {
                            $goodsDetailArr['shop']['goods_list'][$key]['wholesale_price'] = round($value['wholesale_price'] + $set['set_wholesale'], 2);
                        }
                    }
                }
            }
            // 总销量 = 实际销量 + 虚拟销量
            $goodsDetailArr['sales_sum'] = $goodsDetailArr['sales_actual'] + $goodsDetailArr['sales_virtual'];
            // 标识活动信息
            $goodsDetailArr['activity'] = [
                'type' => 0,
                'type_desc' => '普通商品'
            ];

            // 检查商品是否在参与活动，替换商品价格
            $goodsDetailArr = self::checkActivity($goodsDetailArr);
            // 检查商品是否参与抢购活动，替换商品价格、库存。
            $goodsDetailArr = self::rushBuy($goodsDetailArr, $userId);
            // 是否收藏
            $goodsDetailArr['is_collect'] = 0;
            if($userId) { // 非游客
                $goodsCollect = GoodsCollect::where([
                    'user_id' => $userId,
                    'goods_id' => $goodsId
                ])->findOrEmpty();
                if(!$goodsCollect->isEmpty()) {
                    $goodsDetailArr['is_collect'] = $goodsCollect->status ? 1 : 0;
                }
            }
            // 规格项及规格值信息
            $goodsDetailArr['goods_spec'] = GoodsSpec::with('spec_value')
                ->where('goods_id', $goodsId)->select();
            $rst =  Mprocurement::where("user_id",$userId)->where("u_state",1)->where("u_examine_state",1)->where("wholesale_state",2)->find();


            // 商品评价
            $commentCategory = GoodsCommentLogic::category(['goods_id'=>$goodsId]);
            $goodsDetailArr['comment']['percent'] = $commentCategory['percent'];

            $all_comment = Db::name('goods_comment')->where(['goods_id' => $goodsId])->sum('goods_comment');
            $goods_comment_count = Db::name('goods_comment')->where(['goods_id' => $goodsId])->count('id');
            if($goods_comment_count){
                $goods_comment = round($all_comment / $goods_comment_count,2);
                $goodsDetailArr['comment']['goods_comment'] = $goods_comment;
            }else{
                $goodsDetailArr['comment']['goods_comment'] = 0;
            }
            // 最新一条评论
            $one = GoodsComment::alias('gc')
                ->field('gc.id,gc.goods_comment,gc.create_time,gc.comment,u.avatar,u.nickname,g.name as goods_name')
                ->leftJoin('user u', 'u.id=gc.user_id')
                ->leftJoin('goods g', 'g.id=gc.goods_id')
                ->where([
                    ['gc.goods_id', '=', $goodsId],
                    ['gc.del', '=', 0],
                    ['gc.status', '=', 1],
                ])
                ->order('create_time', 'desc')
                ->findOrEmpty();
            if($one->isEmpty()) {
                $one = [];
            }else {
                $one = $one->toArray();
                // 头像
                $one['avatar'] = UrlServer::getFileUrl($one['avatar']);
                // 图片评价
                $one['image'] = GoodsCommentImage::where('goods_comment_id', $one['id'])->column('uri');
                foreach($one['image'] as $subKey => $subItem) {
                    $one['image'][$subKey] = UrlServer::getFileUrl($subItem);
                }
            }
            $goodsDetailArr['comment']['one'] = $one;

            // 判断是否是拼团商品
            $teamActivity = (new TeamActivity())
                ->field(['id,people_num,team_max_price,team_min_price,sales_volume,activity_end_time,share_title,share_intro'])
                ->where([
                    ['goods_id', '=', $goodsId],
                    ['audit', '=', 1],
                    ['status', '=', 1],
                    ['del', '=', 0],
                    ['activity_start_time', '<=', time()],
                    ['activity_end_time', '>=', time()]
                ])->findOrEmpty()->toArray();

            if ($teamActivity) {
                $teamFound = (new TeamFound())->alias('TF')
                    ->field(['TF.*', 'U.nickname,U.avatar'])
                    ->limit(8)
                    ->order('id desc')
                    ->where('TF.team_activity_id', '=', $teamActivity['id'])
                    ->where('TF.people','exp',' > TF.join ')
                    ->where([
                        ['status', '=', 0],
                        ['invalid_time', '>=', time()]
                    ])->join('procurement U', 'U.id=TF.user_id')
                    ->select()->toArray();

                foreach ($teamFound as &$found) {
                    unset($found['shop_id']);
                    unset($found['team_sn']);
                    unset($found['goods_snap']);
                    unset($found['team_end_time']);
                    $found['avatar'] = UrlServer::getFileUrl($found['avatar']);
                    $found['surplus_time'] = intval($found['invalid_time'] - time());
                }

                $teamActivity['share_title'] = !empty($teamActivity['share_title']) ? $teamActivity['share_title'] : $goodsDetailArr['name'];
                $teamActivity['share_intro'] = !empty($teamActivity['share_intro']) ? $teamActivity['share_intro'] : $goodsDetailArr['remark'];

                $goodsDetailArr['activity'] = ['type'=>2, 'type_desc'=>'拼团商品', 'info'=>$teamActivity, 'found'=>$teamFound];
                $teamGoods = (new TeamGoods())->where(['team_id'=>$teamActivity['id']])->select()->toArray();
                foreach ($goodsDetailArr['goods_item'] as &$item) {
                    foreach ($teamGoods as $team) {
                        if ($item['id'] === $team['item_id']) {
                            $item['team_price'] = $team['team_price'];
                        }
                    }
                }
            }

            // 预估佣金(计算出最高可得佣金)
            $goodsDetailArr['distribution'] = self::getDistribution($goodsId, $userId);

            // 虚拟浏览量
            $goodsDetailArr['clicks'] += $goodsDetailArr['clicks_virtual'];

            // 记录访问足迹
            event('Footprint', [
                'type'    => FootprintEnum::BROWSE_GOODS,
                'user_id' => $userId,
                'foreign_id' => $goodsId
            ]);

            Db::commit();
            return $goodsDetailArr;
        }catch(\Exception $e) {
            Db::rollback();
            self::$error = $e->getMessage();
            return false;
        }
    }

    /**
     * 热销榜单
     */
    public static  function getHotList($get)
    {
        // 销售中商品：未删除/审核通过/已上架
        $where = [
            ['del', '=', GoodsEnum::DEL_NORMAL],  // 未删除
            ['status', '=', GoodsEnum::STATUS_SHELVES], // 上架中
            ['audit_status', '=', GoodsEnum::AUDIT_STATUS_OK], // 审核通过
        ];
        $order = [
            'sales_total' => 'desc', // 实际销量+虚拟销量倒序
            'sales_actual' => 'desc', // 实际销量倒序
            'id' => 'desc'
        ];

        return self::getGoodsListTemplate($where, $order, $get);
    }

    /**
     * 商品列表
     */
    public static function getGoodsList($get)
    {
        // 销售中商品：未删除/审核通过/已上架
        $where = [
            ['del', '=', GoodsEnum::DEL_NORMAL],  // 未删除
            ['status', '=', GoodsEnum::STATUS_SHELVES], // 上架中
            ['audit_status', '=', GoodsEnum::AUDIT_STATUS_OK], // 审核通过
        ];
        $order = [
            'sort_weight' => 'asc', // 商品权重，数字越小权重越大
            'sort' => 'asc',
            'id' => 'desc'
        ];
        return self::getGoodsListTemplate($where, $order, $get);
    }

    /**
     * 商品列表模板
     * 作用：代码复用
     */
    public static function getGoodsListTemplate($where, $order, $get)
    {
        $wh = "";
        if (!empty(self::filterShopsIds())) {
            // 过滤已删除、已冻结、已暂停营业、已到期的店铺
            $where[] = ['shop_id', 'not in', self::filterShopsIds()];
        }
        // 平台分类
        if(isset($get['platform_cate_id']) && !empty($get['platform_cate_id']) && filter_var($get['platform_cate_id'], FILTER_VALIDATE_INT)) {
            $category_msg = GoodsCategory::where("id",$get['platform_cate_id'])->find();
            if($category_msg['pid'] == 0){
                $wh = "find_in_set(".$get['platform_cate_id'].", first_cate_id)";
            }else{
                $category_second_msg = GoodsCategory::where("pid",$category_msg['id'])->find();
                if($category_second_msg==null){
                    $wh = "find_in_set(".$get['platform_cate_id'].", second_cate_id)";
                }else{
                    $wh = "find_in_set(".$get['platform_cate_id'].", third_cate_id)";
                }
            }

        }

        // 品牌
        if(isset($get['brand_id']) && !empty($get['brand_id']) && filter_var($get['brand_id'], FILTER_VALIDATE_INT)) {
            $where[] = ['brand_id', '=', $get['brand_id']];
        }

        // 关键词
        if(isset($get['keyword']) && !empty($get['keyword'])) {
            $where[] = ['name', 'like', '%'.trim($get['keyword']).'%'];
            if($get['user_id']) { // 记录关键词
                self::recordKeyword(trim($get['keyword']), $get['user_id']);
            }
        }

        // 店铺id
        if(isset($get['shop_id']) && !empty($get['shop_id']) && filter_var($get['shop_id'], FILTER_VALIDATE_INT)) {
            $where[] = ['shop_id', '=', $get['shop_id']];
        }

        // 店铺分类
        if(isset($get['shop_cate_id']) && !empty($get['shop_cate_id']) && filter_var($get['shop_cate_id'], FILTER_VALIDATE_INT)) {
            $where[] = ['shop_cate_id', '=', $get['shop_cate_id']];
        }

        // 销量排序(实际销量 + 虚拟销量)
        if(isset($get['sort_by_sales']) && !empty($get['sort_by_sales'])) {
            $elt = ['sales_total'=> trim($get['sort_by_sales'])];
            $order = array_merge($elt, $order);
        }

        // 价格排序
        if(isset($get['sort_by_price']) && !empty($get['sort_by_price'])) {
            $elt = ['min_price'=> trim($get['sort_by_price'])];
            $order = array_merge($elt, $order);
        }

        // 新品排序
        if(isset($get['sort_by_create']) && !empty($get['sort_by_create'])) {
            $elt = ['create_time'=> trim($get['sort_by_create'])];
            $order = array_merge($elt, $order);
        }
        if(isset($get['p_id'])){
            $p_id= $get['p_id'];
        }else{
            $p_id= 0;
        }
        if(isset($get['set'])){
            $set_id = $get['set'];
        }else{
            $set_id= 0;
        }
        $set = null;
        $settpye = 0;
        if($p_id != 0&&$set_id!=0){
            $set = Procurementset::where("set_id",$set_id)->where("set_state",1)->find();
            // $where[] = ['second_cate_id', 'in', $set['goods_twotype']];
            $set_array = json_decode($set['goods_onetype'], true);
            $w = ['second_cate_id', 'in', $set_array[0]['child_id']];
            if(isset($get['platform_cate_id'])){
                foreach($set_array as $key=>$value){
                    if($value['id'] == $get['platform_cate_id']){
                        $w = ['second_cate_id', 'in', $value['child_id']];
                    }
                }
            }

            $where[] = $w;
            if($set != null){
                if($set['set_pro']!=0){
                    $where[] = ['purchase_price', '>', 0];
                }else if($set['set_issued']!=0){
                    $where[] = ['issuing_price', '>', 0];
                }else if($set['set_wholesale']!=0){
                    $where[] = ['wholesale_price', '>', 0];
                }
            }
        }
        if($p_id != 0&&$set_id==0){
            $settpye = 1;
            $set = Procurementset::where("u_id",$p_id)->where("set_state",1)->order("set_update desc")->limit(1)->find();
            if($set != null){
                $where[] = ['purchase_price|issuing_price|wholesale_price', '>', 0];
            }
        }
        $field = 'id,image,name,wholesale_price,min_price,market_price,sales_actual,first_cate_id,
        second_cate_id,third_cate_id,sort_weight,brand_id,shop_id,sales_virtual,
        (sales_actual + sales_virtual) as sales_total,purchase_price,issuing_price,subsidy_id';

        // dump($wh);
        // dump($where);
        //  dump($order);die;
        $list = Goods::with(['shop'])
            ->field($field)
            ->where($wh)
            ->where($where)
            ->order($order)
            ->page($get['page_no'], $get['page_size'])
            ->select();
//        foreach ($list as &$v) {
//            $v['market_price'] = round($v['min_price'],2);
//            $v['min_price'] = round(0.88*$v['min_price'],2);
//        }
        $set_price_type = 0;
        foreach ($list as $k => $item) {
            // 获取返补比例, subsidy_id为0的就传递一个ID为4的固定ID
            $list[$k]['subsidy'] = (new GoodsSubsidy())->getSubsidyById($item['subsidy_id'] > 0 ? $item['subsidy_id'] : 4);
            $list[$k]['subsidy_txt'] = '最高返' . $list[$k]['subsidy']['subsidy'];

            $item['shop_type'] = $item['shop']['type'];
            unset($item['shop']);
            if($set != null&&$settpye!=1){
                if($set['price_type']==1){
                    $set_price_type = 1;
                }
                if($set['price_type']==2){
                    $set_price_type = 2;
                }
                if($set['price_type']==3){
                    $set_price_type = 3;
                }
                if($set['set_pro']!=0){
                    // $set_price_type = 1;
                    //min_price
                    if($set['set_pro_type'] == 1){
                        $item['purchase_price'] = round($item['purchase_price']*(100+$set['set_pro'])/100,2);
                    }
                    if($set['set_pro_type'] == 3){
                        if($item['purchase_price'] >0){
                            $item['purchase_price'] = round($item['purchase_price']+$set['set_pro'],2);
                        }else{
                            $item['purchase_price'] = "0.00";
                        }
                    }
                }
                if($set['set_issued']!=0){
                    // $set_price_type = 2;
                    //market_price
                    if($set['set_issued_type'] == 1){
                        $item['issuing_price'] = round($item['issuing_price']*(100+$set['set_issued'])/100,2);
                    }
                    if($set['set_issued_type'] == 3) {
                        if ($item['issuing_price'] > 0) {
                            $item['issuing_price'] = round($item['issuing_price'] + $set['set_issued'], 2);
                        }else{
                            $item['issuing_price'] = "0.00";
                        }
                    }
                }
                if($set['set_wholesale']!=0){
                    // $set_price_type = 3;
                    //market_price
                    if($set['set_wholesale_type'] == 1){
                        $item['wholesale_price'] = round($item['wholesale_price']*(100+$set['set_wholesale'])/100,2);
                    }
                    if($set['set_wholesale_type'] == 3) {
                        if ($item['wholesale_price'] > 0) {
                            $item['wholesale_price'] = round($item['wholesale_price'] + $set['set_wholesale'], 2);
                        }else{
                            $item['wholesale_price'] = "0.00";
                        }
                    }
                }
            }
        }

        $count = Goods::where($where)->where($wh)->count();

        $list = $list ? $list->toArray() : [];

        $more = is_more($count, $get['page_no'], $get['page_size']);

        $data = [
            'lists'         => $list,
            'page_no'       => $get['page_no'],
            'page_size'     => $get['page_size'],
            'count'         => $count,
            'more'          => $more,
            'set_price_type'=> $set_price_type
        ];
        return $data;
    }

    /**
     * 根据商品栏目获取商品列表
     */
    public static function getGoodsListByColumnId($columnId, $page_no, $page_size,$p_id,$set_id)
    {

        // 销售中商品：未删除/审核通过/已上架
        $onSaleWhere = [
            ['del', '=', GoodsEnum::DEL_NORMAL],
            ['status', '=', GoodsEnum::STATUS_SHELVES],
            ['audit_status', '=', GoodsEnum::AUDIT_STATUS_OK],
        ];

        if (!empty(self::filterShopsIds())) {
            // 过滤已删除、已冻结、已暂停营业、已到期的店铺
            $onSaleWhere[] = ['shop_id', 'not in', self::filterShopsIds()];
        }

        $order = [
            'sort_weight' => 'asc', // 数字越小，权重越大
            'sales_actual' => 'desc',
            'id' => 'desc'
        ];
        $set = null;
        $where = [];
        $settpye = 0;
        if($p_id != 0&&$set_id!=0){
            $set = Procurementset::where("set_id",$set_id)->where("set_state",1)->find();
            if($set != null){
                if($set['set_pro']!=0){
                    $where[] = ['purchase_price', '>', 0];
                }else if($set['set_issued']!=0){
                    $where[] = ['issuing_price', '>', 0];
                }else if($set['set_wholesale']!=0){
                    $where[] = ['wholesale_price', '>', 0];
                }
            }
        }
        if($p_id != 0&&$set_id==0){
            $settpye = 1;
            if($set != null) {
                $set = Procurementset::where("u_id", $p_id)->where("set_state", 1)->order("set_update desc")->limit(1)->find();
                $where[] = ['purchase_price|issuing_price|wholesale_price', '>', 0];
            }
        }
        $list = Goods::field('id,name,image,market_price,min_price,wholesale_price,purchase_price,issuing_price,sales_actual,column_ids,sort_weight,sales_virtual,(sales_actual + sales_virtual) as sales_total, subsidy_id')
            ->where($onSaleWhere)
            ->where($where)
            ->whereFindInSet('column_ids', $columnId)
            ->order($order)
            ->page($page_no, $page_size)
            ->select();
//        foreach ($list as &$v) {
//            $v['market_price'] = round($v['min_price'],2);
//            $v['min_price'] = round(0.88*$v['min_price'],2);
//        }
        $set_price_type = 0;
        if ($set != null&&$settpye!=1) {
            foreach ($list as $key => $value) {
                if($set['price_type']==1){
                    $set_price_type = 1;
                }
                if($set['price_type']==2){
                    $set_price_type = 2;
                }
                if($set['price_type']==3){
                    $set_price_type = 3;
                }
                if ($set['set_pro'] != 0) {
                    // $set_price_type = 1;
                    if ($set['set_pro_type'] == 1) {
                        $list[$key]['purchase_price'] = round($value['purchase_price'] * (100 + $set['set_pro']) / 100, 2);
                    }
                    if ($set['set_pro_type'] == 3) {
                        $list[$key]['purchase_price'] = round($value['purchase_price'] + $set['set_pro'], 2);
                    }
                }
                if ($set['set_issued'] != 0) {
                    // $set_price_type = 2;
                    if ($set['set_issued_type'] == 1) {
                        $list[$key]['issuing_price'] = round($value['issuing_price'] * (100 + $set['set_issued']) / 100, 2);
                    }
                    if ($set['set_issued_type'] == 3) {
                        $list[$key]['issuing_price'] = round($value['issuing_price'] + $set['set_issued'], 2);
                    }
                }
                if ($set['set_wholesale'] != 0) {
                    // $set_price_type = 3;
                    if ($set['set_wholesale_type'] == 1) {
                        $list[$key]['wholesale_price'] = round($value['wholesale_price'] * (100 + $set['set_wholesale']) / 100, 2);
                    }
                    if ($set['set_wholesale_type'] == 3) {
                        $list[$key]['wholesale_price'] = round($value['wholesale_price'] + $set['set_wholesale'], 2);
                    }
                }
            }
        }

        foreach ($list as $k => $v) {
            // 获取返补比例, subsidy_id为0的就传递一个ID为4的固定ID
            $list[$k]['subsidy'] = (new GoodsSubsidy())->getSubsidyById($v['subsidy_id'] > 0 ? $v['subsidy_id'] : 4);
            $list[$k]['subsidy_txt'] = '最高返' . $list[$k]['subsidy']['subsidy'];
        }

        $count = Goods::where($onSaleWhere)
            ->where($where)
            ->whereFindInSet('column_ids', $columnId)
            ->count();

        $list = $list ? $list->toArray() : [];

        $more = is_more($count, $page_no, $page_size);

        $data = [
            'lists'          => $list,
            'page_no'       => $page_no,
            'page_size'     => $page_size,
            'count'         => $count,
            'more'          => $more,
            'set_price_type' => $set_price_type
        ];
        return $data;
    }

    /**
     * @notes 获取已删除、已冻结、已暂停营业、已到期店铺的id
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     * @author Tab
     * @date 2021/7/20 14:29
     */
    public static function filterShopsIds()
    {
        // 已删除、已冻结、已暂停营业的店铺
        $invalidShops = Shop::field('id,name')->whereOr([
            ['del', '=', 1], // 已删除
            ['is_freeze', '=', 1], // 已冻结
            ['is_run', '=', 0] // 暂停营业
        ])->select()->toArray();

        // 已过期的店铺
        $expiredShops = Shop::field('id,name')->where([
            ['expire_time', '<>', 0],
            ['expire_time', '<=', time()],
        ])->select()->toArray();

        $filterShops = array_merge($invalidShops, $expiredShops);
        $filterShopsIds = array_column($filterShops, 'id');
        return $filterShopsIds;
    }

    /**
     * 记录关键词
     */
    public static function recordKeyword($keyword, $user_id)
    {
        $record = SearchRecord::where(['user_id'=>$user_id,'keyword'=>$keyword,'del'=>0])->find();
        if($record){
            // 有该关键词记录, 更新
            return SearchRecord::where(['id'=>$record['id']])->update(['count'=>Db::raw('count+1'),'update_time'=>time()]);
        }
        // 无该关键词记录 > 新增
        return SearchRecord::create([
            'user_id'=>$user_id,
            'keyword'=>$keyword,
            'count' => 1,
            'update_time' => time(),
            'del' => 0
        ]);
    }

    //检查商品是否正在参加活动
    public static function checkActivity($goods){
        // 获取正在秒杀的时段
        $seckill_time = SeckillGoodsLogic::getSeckillTimeIng();
        if($seckill_time === false) {
            // 不在秒杀时段，直接返回
            return $goods;
        }
        // 判断是否是秒杀中的商品
        $seckill_goods = SeckillGoods::where([
            ['del', '=', 0],
            ['seckill_id', '=', $seckill_time['id']],
            ['goods_id', '=', $goods['id']],
            ['review_status', '=', 1],
        ])->select()->toArray();
        if(!$seckill_goods) {
            // 不是秒杀商品
            return $goods;
        }
        // 判断参与日期是否包含今天
        $flag = false;
        $now = time();
        foreach($seckill_goods as $item) {
            $start_date_time = strtotime($item['start_date'].' 00:00:00');
            $end_date_time = strtotime($item['end_date'].' 00:00:00');
            if($start_date_time < $now && $end_date_time > $now) {
                $flag = true;
                // 获取该商品的秒杀信息
                $seckill_goods_info = SeckillGoods::where([
                    'goods_id' => $goods['id'],
                    'seckill_id' => $seckill_time['id'],
                    'start_date' => $item['start_date'],
                    'end_date' => $item['end_date'],
                ])->column('goods_id,item_id,price', 'item_id');
                break;
            }
        }
        if($flag === false) {
            // 参与日期不在今天
            return $goods;
        }
        // 确定是秒杀中的商品
        // 先将商品市场价换成原SKU最小价
        $goods['market_price'] = $goods['min_price'];
        // 替换活动价
        foreach($goods['goods_item'] as &$item) {
            // 商品价格替换为最小的秒杀价
            if($goods['min_price'] > $seckill_goods_info[$item['id']]['price']) {
                $goods['min_price'] = $seckill_goods_info[$item['id']]['price'];
            }
            // 原市场价替换为原SKU售价
            $item['market_price'] = $item['price'];
            // SKU替换秒杀价
            $item['price'] = $seckill_goods_info[$item['id']]['price'];
        }
        $today_date = date('Y-m-d');
        $goods['activity'] = [
            'type' => 1,
            'type_desc' => '秒杀商品',
            'end_time' => strtotime($today_date.' '.$seckill_time['end_time'])
        ];
        return $goods;

    }

    /**
     * @notes 获取商品分销信息
     * @param $goodsId
     * @param $userId
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     * @author Tab
     * @date 2021/9/6 18:48
     */
    public static function getDistribution($goodsId, $userId)
    {
        $earnings = 0;
        $goods = Goods::findOrEmpty($goodsId)->toArray();
        $distributionGoods = DistributionGoods::where('goods_id', $goodsId)->select()->toArray();
        if(!empty($distributionGoods) && $distributionGoods[0]['is_distribution'] && $distributionGoods[0]['rule'] == 2) {
            foreach($distributionGoods as $item) {
                $earnings = max($earnings, round($goods['max_price'] * $item['first_ratio'] / 100, 2));
                $earnings = max($earnings, round($goods['max_price'] * $item['second_ratio'] / 100, 2));
            }
        }
        if(!empty($distributionGoods) && $distributionGoods[0]['is_distribution'] && $distributionGoods[0]['rule'] == 1) {
            $levels = DistributionLevel::select()->toArray();
            foreach($levels as $item) {
                $earnings = max($earnings, round($goods['max_price'] * $item['first_ratio'] / 100, 2));
                $earnings = max($earnings, round($goods['max_price'] * $item['second_ratio'] / 100, 2));
            }
        }

        // 详情页是否显示佣金
        $isShow = ConfigServer::get('distribution', 'is_show_earnings', 0);
        // 系统总分销开关
        $distributionOpen = ConfigServer::get('distribution', 'is_open', 0);
        // 商家信息-获取商家是否被禁用分销功能(is_distribution)
        $shop = Shop::findOrEmpty($goods['shop_id'])->toArray();

        if ($distributionOpen && $shop['is_distribution'] && $isShow) {
            //详情页佣金可见用户 0-全部用户 1-分销商
            $scope = ConfigServer::get('distribution', 'show_earnings_scope', 0);
            $user = Distribution::where(['user_id' => $userId])->findOrEmpty()->toArray();
            if ($scope && empty($user['is_distribution'])) {
                $isShow = 0;
            }
        } else {
            $isShow = 0;
        }

        return [
            'is_show' => $isShow,
            'earnings' => $earnings
        ];
    }

    public static function searchByName($shop_name, $user_id)
    {
        if (!$shop_name) {
            return [];
        }

        SearchRecord::create([
            'user_id'=>$user_id,
            'keyword'=>$shop_name,
            'count' => 1,
            'update_time' => time(),
            'del' => 0
        ]);

        $category = GoodsCategory::where(['is_show' => 1, 'del' => 0])
            ->where([['name', 'like', '%' . trim($shop_name) . '%']])
            ->field('id')
            ->select()
            ->toArray();

        $onSaleWhere = [
            'del' => GoodsEnum::DEL_NORMAL, // 未删除
            'status' => GoodsEnum::STATUS_SHELVES, // 上架中
            'audit_status' => GoodsEnum::AUDIT_STATUS_OK, // 审核通过
        ];

        $where = [];
        if (!empty(self::filterShopsIds())) {
            // 过滤已删除、已冻结、已暂停营业、已到期的店铺
            $where[] = ['shop_id', 'not in', self::filterShopsIds()];
        }

        $where[] = ['name', 'like', '%' . trim($shop_name) . '%'];

        if (empty($category)) {
            $goods = Goods::field('id, name')
                ->where($onSaleWhere)
                ->where($where)
                ->order('sort_weight asc, sort asc, id desc')
                ->select()->toArray();

        } else {
            foreach ($category as &$v) {
                $goods = Goods::where([['first_cate_id|second_cate_id|third_cate_id', 'like', '%' . $v['id'] . '%']])
                    ->where($onSaleWhere)
                    ->order('sort_weight asc, sort asc, id desc')
                    ->select()
                    ->toArray();
            }
        }

        if ($goods) {
            return $goods;
        }

        return [];
    }

    public static function hotList($page, $size)
    {
        $hot_list = [];
        if ($page == 1) {
            $hot_list = Db::name('hot_list')
                ->alias('hl')
                ->join('goods g', 'hl.goods_id = g.id')
                ->where('delete_time', 0)
                ->field('hl.id as hl_id, g.id as id, g.name, g.image, g.issuing_price, g.market_price, g.min_price, g.purchase_price, g.wholesale_price, g.subsidy_id')
                ->select()
                ->toArray();
            foreach ($hot_list as $k => &$v) {
                if (isset($v['image'])) {
                    $v['image'] = UrlServer::getFileUrl($v['image']);
                }

                // 获取返补比例, subsidy_id为0的就传递一个ID为4的固定ID
                $hot_list[$k]['subsidy'] = (new GoodsSubsidy())->getSubsidyById($v['subsidy_id'] > 0 ? $v['subsidy_id'] : 4);
                $hot_list[$k]['subsidy_txt'] = '最高返' . $hot_list[$k]['subsidy']['subsidy'];
            }
        }

        $shopWhere = [];
        if (!empty(self::filterShopsIds())) {
            // 过滤已删除、已冻结、已暂停营业、已到期的店铺
            $shopWhere[] = ['og.shop_id', 'not in', self::filterShopsIds()];
        }

        $onSaleWhere = [
            'del' => GoodsEnum::DEL_NORMAL, // 未删除
            'status' => GoodsEnum::STATUS_SHELVES, // 上架中
            'audit_status' => GoodsEnum::AUDIT_STATUS_OK, // 审核通过
        ];

        $order_goods = Db::name('order_goods')
            ->alias('og')
            ->join('goods g', 'og.goods_id = g.id')
            ->where($onSaleWhere)
            ->where($shopWhere)
            ->field('og.goods_id, og.create_time, count(*) as count, g.id as gid, g.name, g.image, g.issuing_price, g.market_price, g.min_price, g.purchase_price, g.wholesale_price, g.subsidy_id')
            ->group('og.goods_id')
            ->order('og.create_time desc, count desc')
            ->page($page, $size)
            ->select()
            ->toArray();

        $count = Db::name('order_goods')
            ->alias('og')
            ->join('goods g', 'og.goods_id = g.id')
            ->where($onSaleWhere)
            ->where($shopWhere)
            ->group('og.goods_id')
            ->count();

        foreach ($order_goods as $k => &$v) {
            if (isset($v['image'])) {
                $v['image'] = UrlServer::getFileUrl($v['image']);
            }

            // 获取返补比例, subsidy_id为0的就传递一个ID为4的固定ID
            $order_goods[$k]['subsidy'] = (new GoodsSubsidy())->getSubsidyById($v['subsidy_id'] > 0 ? $v['subsidy_id'] : 4);
            $order_goods[$k]['subsidy_txt'] = '最高返' . $order_goods[$k]['subsidy']['subsidy'];
        }

        $more = is_more($count, $page, $size);  //是否有下一页

        $list = $order_goods;
        if ($page == 1) {
            $list = array_merge($hot_list, $order_goods);
        }

        $data = [
            'lists' => $list,
            'hot_list' => $hot_list,
            'page_no' => $page,
            'page_size' => $size,
            'count' => $count,
            'more' => $more
        ];

        return $data;
    }

    public static function goodsList($type, $page, $size) {
        $shopWhere = [];
        if (!empty(self::filterShopsIds())) {
            // 过滤已删除、已冻结、已暂停营业、已到期的店铺
            $shopWhere[] = ['shop_id', 'not in', self::filterShopsIds()];
        }

        $onSaleWhere = [
            'del' => GoodsEnum::DEL_NORMAL, // 未删除
            'status' => GoodsEnum::STATUS_SHELVES, // 上架中
            'audit_status' => GoodsEnum::AUDIT_STATUS_OK, // 审核通过
        ];

        $list = $goods = [];

        if ($type == 'recommend') {
            $list = Db::name('new_goods')
                ->alias('ng')
                ->join('goods g', 'ng.goods_id = g.id')
                ->where($onSaleWhere)
                ->where($shopWhere)
                ->where('delete_time', 0)
                ->field('ng.id as ng_id, g.id as id, g.name, g.image, g.issuing_price, g.market_price, g.min_price, g.purchase_price, g.wholesale_price, g.subsidy_id')
                ->limit(4)
                ->select()
                ->toArray();
            $count = count($list);

            if ($count < 4) {
                $goods = Db::name('goods')
                    ->where($onSaleWhere)
                    ->where($shopWhere)
                    ->limit(4 - $count)
                    ->order('create_time desc')
                    ->select()
                    ->toArray();
            }

            $result = array_merge($list, $goods);
            foreach ($result as $k => &$v) {
//                $v['market_price'] = round($v['min_price'],2);
//                $v['min_price'] = round(0.88*$v['min_price'],2);
                if (isset($v['image'])) {
                    $v['image'] = UrlServer::getFileUrl($v['image']);
                }

                // 获取返补比例, subsidy_id为0的就传递一个ID为4的固定ID
                $result[$k]['subsidy'] = (new GoodsSubsidy())->getSubsidyById($v['subsidy_id'] > 0 ? $v['subsidy_id'] : 4);
                $result[$k]['subsidy_txt'] = '最高返' . $result[$k]['subsidy']['subsidy'];
            }
            return $result;
        } else if ($type == 'all') {
            $list = Db::name('new_goods')
                ->alias('ng')
                ->join('goods g', 'ng.goods_id = g.id')
                ->where($shopWhere)
                ->where($onSaleWhere)
                ->where('delete_time', 0)
                ->field('ng.id as ng_id, g.id as id, g.name, g.image, g.issuing_price, g.market_price, g.min_price, g.purchase_price, g.wholesale_price, g.subsidy_id')
                ->select()
                ->toArray();
            $goods = Db::name('goods')
                ->where($onSaleWhere)
                ->where($shopWhere)
                ->order('create_time desc')
                ->page($page, $size)
                ->select()
                ->toArray();

            $count = Db::name('goods')
                ->where($onSaleWhere)
                ->count();

            $result = array_merge($list, $goods);

            foreach ($result as $k => &$v) {
//                $result[$k]['market_price'] = round($v['min_price'],2);
//                $result[$k]['min_price'] = round(0.88*$v['min_price'],2);
                if (isset($v['image'])) {
                    $v['image'] = UrlServer::getFileUrl($v['image']);
                }

                // 获取返补比例, subsidy_id为0的就传递一个ID为4的固定ID
                $result[$k]['subsidy'] = (new GoodsSubsidy())->getSubsidyById($v['subsidy_id'] > 0 ? $v['subsidy_id'] : 4);
                $result[$k]['subsidy_txt'] = '最高返' . $result[$k]['subsidy']['subsidy'];
            }

            $more = is_more($count, $page, $size);  //是否有下一页

            return [
                'lists' => $result,
                'page_no' => $page,
                'page_size' => $size,
                'count' => $count,
                'more' => $more
            ];
        }
    }

    public static function rushBuy($goods, $userId){

        // 判断是否是抢购中的商品
        $GroupbuyGoods = GroupbuyGoods::where([
            ['del', '=', 1],
            ['goods_id', '=', $goods['id']],
            ['status', '=', 1],
        ])->select()->toArray();

        // 判断此商品是否为抢购商品
        if(!$GroupbuyGoods){
            return $goods;
        }

        foreach($GroupbuyGoods as $item) {
            // 获取该商品的秒杀信息
            $GroupbuyGoods_info = GroupbuyGoods::where([
                'goods_id' => $goods['id'],
            ])->column('goods_id,item_id,activity_price,stock,limited_num', 'item_id');
        }

        // 确定是抢购商品 先将商品市场价换成原SKU最小价
        $goods['market_price'] = $goods['min_price'];
        // 替换活动价
        foreach($goods['goods_item'] as &$item) {

            // 商品价格替换为最小的秒杀价
            if($goods['min_price'] > $GroupbuyGoods_info[$item['id']]['activity_price']) {
                $goods['min_price'] = $GroupbuyGoods_info[$item['id']]['activity_price'];
            }
            // 原市场价替换为原SKU售价
            $item['market_price'] = $item['price'];
            // SKU替换抢购价
            $item['price'] = $GroupbuyGoods_info[$item['id']]['activity_price'];
            // SKU库存替换抢购库存
            $item['stock'] = $GroupbuyGoods_info[$item['id']]['stock'];
            $item['limited_num'] =$GroupbuyGoods_info[$item['id']]['limited_num'];
        }

        // 如果当前用户参与了抢购的活动（则不允许再次抢购）
//        $in_activity = Order::where(['user_id' => $userId, 'order_type' => 4])->where('order_status', '<', 4)->find();
//
//        $goods['activity'] = [
//            'type' => 4,
//            'type_desc' => '抢购商品',
//            'in_groupbuy_activity' => (bool)$in_activity,
//            'msg' => '您已参与过本次活动，无法再次参与！'
//        ];

        // 2024-11-29 更改规则：活动中的每件商品用户都能购买，但是只能买一件
        $in_activity = Order::alias('a')
            ->join('order_goods og', 'a.id = og.order_id')
            ->where(['a.user_id' => $userId, 'a.order_type' => 4, 'og.goods_id' => $goods['id']])
            ->where('a.order_status', '<', 4)
            ->find();

        $goods['activity'] = [
            'type' => 4,
            'type_desc' => '抢购商品',
            'in_groupbuy_activity' => !empty($in_activity),
            'msg' => '您已购买过此商品！'
        ];

        return $goods;
    }
}