t_nine/app/Service/ProductService.php

<?php

namespace App\Service;

use App\Model\BasicType;
use App\Model\Employee;
use App\Model\Product;
use App\Model\ProductActivity;
use App\Model\ProductActivityPrice;
use App\Model\ProductCategory;
use App\Model\ProductInfo;
use App\Model\ProductIntroduction;
use App\Model\ProductPriceDetail;
use App\Model\SeeRange;
use Illuminate\Support\Facades\DB;

/**
 * 产品管理
 */
class ProductService extends Service
{
    /**
     * 产品分类编辑
     * @param $data
     * @param $user
     * @return array
     */
    public function productCategoryEdit($data,$user){
        list($status,$msg) = $this->productCategoryRule($data,$user,false);
        if(!$status) return [$status,$msg];

        $update = $msg['data'][0];

        $model = new ProductCategory();
        $model->where('id',$data['id'])->update($update);

        return [true,''];
    }

    /**
     * 产品分类新增
     * @param $data
     * @param $user
     * @return array
     */
    public function productCategoryAdd($data,$user){
        list($status,$msg) = $this->productCategoryRule($data,$user);
        if(!$status) return [$status,$msg];

        ProductCategory::insert($msg['data']);

        return [true,''];
    }

    /**
     * 产品分类删除
     * @param $data
     * @return array
     */
    public function productCategoryDel($data){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];

        $bool = Product::where('del_time',0)
            ->where('product_category_id',$data['id'])
            ->exists();
        if($bool) return [false,'产品分类下已添加产品，操作失败'];

        try {
            DB::beginTransaction();

            ProductCategory::where('id',$data['id'])->update([
                'del_time' => time()
            ]);

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true,''];
    }

    /**
     * 产品分类列表
     * @param $data
     * @param $user
     * @return array
     */
    public function productCategoryList($data,$user){
        $model = ProductCategory::TopClear($user,$data);
        $model = $model->where('del_time',0)
            ->select('title','id','parent_id')
            ->orderby('id','desc');
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');

        $list = $model->get()->toArray();
        $list_tree = $list;
        if(! empty($list_tree)) {
            $list_tree = $this->makeTree(0,$list_tree);
            $list_tree = $this->set_sort_circle($list_tree);
        }

        return [200, ['data' => $list,'tree' => $list_tree]];
    }

    /**
     * 产品分类参数规则
     * @param $data
     * @param $is_add
     * @return array
     */
    public function productCategoryRule($data,$user, $is_add = true){
        if($this->isEmpty($data,'data')) return [false,'数据不能为空！'];

        //所属部门 以及  顶级部门
        if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
        $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;

        $title = array_column($data['data'],'title');
        $title = array_map(function($val) {
            return $val !== null ? $val : 0;
        }, $title);
        $title_count = array_count_values($title);
        foreach ($title as $value){
            if(empty($value)) return [false,'名称不能为空！'];
            if($title_count[$value] > 1) return [false,'名称不能重复'];
        }

        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['upd_time'] = time();

            if($is_add){
                $parent_id = 0;
                if(! empty($value['parent_id'])) {
                    $bool = Product::where('del_time',0)
                        ->where('product_category_id',$value['parent_id'])
                        ->exists();
                    if($bool) {
                        $title = ProductCategory::where('id',$value['parent_id'])->select('title')->value('title');
                        return [false,'产品分类:'. $title .'下已添加产品，不允许添加子分类'];
                    }
                    $parent_id = $value['parent_id'];
                }

                $data['data'][$key]['parent_id'] = $parent_id;
                $data['data'][$key]['crt_time'] = time();
                $data['data'][$key]['depart_id'] = $data['depart_id'];
                $data['data'][$key]['top_depart_id'] = $data['top_depart_id'];

                $bool = ProductCategory::where('title',$value['title'])
                    ->where('top_depart_id',$data['top_depart_id'])
                    ->where('del_time',0)
                    ->exists();
            }else{
                if($this->isEmpty($data,'id')) return [false,'id不能为空！'];
                $top_depart_id = ProductCategory::where('id',$data['id'])->value('top_depart_id');
                $bool = ProductCategory::where('title',$value['title'])
                    ->where('top_depart_id',$top_depart_id)
                    ->where('id','<>',$data['id'])
                    ->where('del_time',0)
                    ->exists();
            }
            if($bool) return [false,'分类名称不能重复'];
        }

        return [true, $data];
    }

    /**
     * 产品编辑
     * @param $data
     * @param $user
     * @return array
     */
    public function productEdit($data,$user){
        list($status,$msg) = $this->productRule($data, $user, false);
        if(!$status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $model = Product::where('id',$data['id'])->first();
            $model->product_category_id = $data['product_category_id'] ?? 0;
            $model->product_category = $data['product_category'] ?? '';
            $model->title = $data['title'];
            $model->code = $data['code'] ?? '';
            $model->warranty_time = $data['warranty_time'] ?? 0;
            $model->install_time = $data['install_time'] ?? 0;
            $model->size = $data['size'] ?? '';
            $model->unit = $data['unit'] ?? 0;
            $model->bar_code = $data['bar_code'] ?? '';
            $model->cost = $data['cost'] ?? 0;
            $model->retail_price = $data['retail_price'] ?? 0;
            $model->mark = $data['mark'] ?? '';
            $model->state = $data['state'] ?? 0;
            $model->save();

            $time = time();

            ProductIntroduction::where('product_id',$data['id'])
                ->where('del_time',0)
                ->update(['del_time' => $time]);
            if(! empty($data['introduction'])){
                $models = new ProductIntroduction();
                $models->product_id = $model->id;
                $models->introduction = $data['introduction'];
                $models->save();
            }

            $old = ProductInfo::where('del_time',0)
                ->where('product_id',$data['id'])
                ->select('file')
                ->get()->toArray();
            $old = array_column($old,'file');
            ProductInfo::where('del_time',0)
                ->where('product_id',$data['id'])
                ->update(['del_time' => $time]);

            $new = [];
            if(! empty($data['img'])){
                $insert = [];
                foreach ($data['img'] as $value){
                    $insert[] = [
                        'product_id' => $model->id,
                        'file' => $value['url'],
                        'type' => ProductInfo::type_one,
                        'name' => $value['name'],
                        'crt_time' => $time,
                    ];
                    $new[] = $value['url'];
                }
                ProductInfo::insert($insert);
            }
            if(! empty($data['file'])){
                $insert = [];
                foreach ($data['file'] as $value){
                    $insert[] = [
                        'product_id' => $model->id,
                        'file' => $value['url'],
                        'type' => ProductInfo::type_two,
                        'name' => $value['name'],
                        'crt_time' => $time,
                    ];
                    $new[] = $value['url'];
                }
                ProductInfo::insert($insert);
            }

            ProductPriceDetail::where('del_time',0)
                ->where('product_id',$data['id'])
                ->update(['del_time' => $time]);

            if(! empty($data['product_price'])){
                $insert = [];
                foreach ($data['product_price'] as $value){
                    $insert[] = [
                        'product_id' => $model->id,
                        'basic_type_id' => $value['basic_type_id'],
                        'price' => $value['price'] ?? 0,
                        'crt_time' => $time,
                    ];
                }
                ProductPriceDetail::insert($insert);
            }

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        $this->delStorageFile($old, $new);

        return [true,''];
    }

    /**
     * 产品新增
     * @param $data
     * @param $user
     * @return array
     */
    public function productAdd($data,$user){
        list($status,$msg) = $this->productRule($data, $user);
        if(!$status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $model = new Product();
            $model->product_category_id = $data['product_category_id'] ?? 0;
            $model->product_category = $data['product_category'] ?? '';
            $model->title = $data['title'];
            $model->code = $data['code'] ?? '';
            $model->warranty_time = $data['warranty_time'] ?? 0;
            $model->install_time = $data['install_time'] ?? 0;
            $model->size = $data['size'] ?? '';
            $model->unit = $data['unit'] ?? 0;
            $model->bar_code = $data['bar_code'] ?? '';
            $model->cost = $data['cost'] ?? 0;
            $model->retail_price = $data['retail_price'] ?? 0;
            $model->mark = $data['mark'] ?? '';
            $model->state = $data['state'] ?? 0;
            $model->crt_id = $user['id'];
            $model->depart_id = $data['depart_id'] ?? 0;
            $model->top_depart_id = $data['top_depart_id'] ?? 0;
            $model->save();

            $time = time();

            if(! empty($data['introduction'])){
                $models = new ProductIntroduction();
                $models->product_id = $model->id;
                $models->introduction = $data['introduction'];
                $models->save();
            }

            if(! empty($data['img'])){
                $insert = [];
                foreach ($data['img'] as $value){
                    $insert[] = [
                        'product_id' => $model->id,
                        'file' => $value['url'],
                        'type' => ProductInfo::type_one,
                        'name' => $value['name'],
                        'crt_time' => $time,
                    ];
                }
                ProductInfo::insert($insert);
            }

            if(! empty($data['file'])){
                $insert = [];
                foreach ($data['file'] as $value){
                    $insert[] = [
                        'product_id' => $model->id,
                        'file' => $value['url'],
                        'type' => ProductInfo::type_two,
                        'name' => $value['name'],
                        'crt_time' => $time,
                    ];
                }
                ProductInfo::insert($insert);
            }

            if(! empty($data['product_price'])){
                $insert = [];
                foreach ($data['product_price'] as $value){
                    $insert[] = [
                        'product_id' => $model->id,
                        'basic_type_id' => $value['basic_type_id'],
                        'price' => $value['price'] ?? 0,
                        'crt_time' => $time,
                    ];
                }
                ProductPriceDetail::insert($insert);
            }

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true,''];
    }

    /**
     * 产品删除
     * @param $data
     * @return array
     */
    public function productDel($data){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];

        try {
            DB::beginTransaction();
            $time = time();

            Product::where('del_time',0)->where('id',$data['id'])->update(['del_time' => $time]);

            ProductIntroduction::where('product_id',$data['id'])
                ->where('del_time',0)
                ->update(['del_time' => $time]);

            ProductInfo::where('del_time',0)
                ->where('product_id',$data['id'])
                ->update(['del_time' => $time]);

            ProductPriceDetail::where('del_time',0)
                ->where('product_id',$data['id'])
                ->update(['del_time' => $time]);

            (new RangeService())->RangeDelete($data['id'],SeeRange::type_four);

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true,''];
    }

    /**
     * 产品详情
     * @param $data
     * @param $user
     * @return array
     */
    public function productDetail($data,$user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        $customer = Product::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'产品不存在或已被删除'];
        $customer = $customer->toArray();
        $customer['product_category'] = ! empty($customer['product_category']) ? json_decode($customer['product_category'],true): [];
        $category = ProductCategory::where('id',$customer['product_category_id'])
            ->value('title');
        $customer['product_category_title'] = $category;
        $customer['introduction'] = "";
        $in = ProductIntroduction::where('del_time',0)
            ->where('product_id',$data['id'])
            ->first();
        if(! empty($in)) $customer['introduction'] = $in->introduction;

        $model = BasicType::TopClear($user,$data);
        $basic = $model->where('del_time',0)
            ->where('type',22)
            ->select('title','id','type')
            ->orderby('id', 'asc')->get()->toArray();

        $detail = ProductPriceDetail::where('del_time',0)
            ->where('product_id',$data['id'])
            ->select('product_id','basic_type_id','price')
            ->get()->toArray();
        $title_map = BasicType::whereIn('id',array_unique(array_merge_recursive(array_column($detail,'basic_type_id'),array_column($basic,'id'))))
            ->pluck('title','id')
            ->toArray();
        //是否总公司
        $is_main = $user['is_all_depart'];
        $top_depart = $user['depart_top'][0] ?? [];
        $customer['is_edit'] = $customer['top_depart_id'] == $top_depart['depart_id'] ? 1 : 0;
        $customer['product_price'] = [];
        //展示金额
        foreach ($detail as $value){
            if(! $is_main && ($top_depart['basic_type_id'] != $value['basic_type_id'])) {
                $is_show = 0;
            }else{
                $is_show = 1;
            }
            $customer['product_price'][$value['basic_type_id']] = [
                'basic_type_id' => $value['basic_type_id'],
                'basic_type_title' => $title_map[$value['basic_type_id']] ?? '',
                'price' => $value['price'],
                'is_show' => $is_show,
            ];
        }

        foreach ($basic as $value){
            if(! $is_main && ($top_depart['basic_type_id'] != $value['id'])) {
                $is_show = 0;
            }else{
                $is_show = 1;
            }
            if(! isset($customer['product_price'][$value['id']])){
                $customer['product_price'][$value['id']] = [
                    'basic_type_id' => $value['id'],
                    'basic_type_title' => $title_map[$value['id']] ?? '',
                    'price' => 0,
                    'is_show' => $is_show,
                ];
            }
        }

        $customer['product_price'] = array_values($customer['product_price']);

        //单位
        $title = BasicType::where('id',$customer['unit'])->value('title');
        $customer['unit_name'] = $title;

        $customer['img'] = $customer['file'] = $customer['depart'] = $customer['employee'] = [];
        $customer_info = ProductInfo::where('del_time',0)
            ->where('product_id',$customer['id'])
            ->select('id','product_id','file','type','name')
            ->get()->toArray();
        foreach ($customer_info as $value){
            $tmp = [
                'url' => $value['file'],
                'name' => $value['name'],
            ];
            if($value['type'] == ProductInfo::type_one){
                $customer['img'][] = $tmp;
            }elseif ($value['type'] == ProductInfo::type_two){
                $customer['file'][] = $tmp;
            }
        }

        $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('emp_name');
        $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
        //可见范围
        $return = (new RangeService())->RangeDetail($data['id'],SeeRange::type_four);
        $customer['depart'] = $return[0] ?? [];
        $customer['employee'] = $return[1] ?? [];

        return [true, $customer];
    }

    /**
     * 产品列表
     * @param $data
     * @param $user
     * @return array
     */
    public function productList($data,$user){
        $model = Product::ProductClear($user,$data);
        $model = $model->where('del_time',0)
            ->select('title','id','product_category_id','code','size','unit','bar_code','retail_price','cost','state','crt_id','crt_time','mark','depart_id','top_depart_id','install_time')
            ->orderby('id', 'desc');

        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(isset($data['state'])) $model->where('state', $data['state']);
        if(! empty($data['product_category_id'])) $model->where('product_category_id', $data['product_category_id']);
        if(! empty($data['product_category'])) {
            $product_category = ProductCategory::where('del_time',0)
                ->where('title', 'LIKE', '%'.$data['product_category'].'%')
                ->select('id')
                ->get()->toArray();
            $model->whereIn('product_category_id',array_unique(array_column($product_category,'id')));
        }
        if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
        if(! empty($data['bar_code'])) $model->where('bar_code', 'LIKE', '%'.$data['bar_code'].'%');
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('crt_time','>=',$return[0]);
            $model->where('crt_time','<=',$return[1]);
        }

        $list = $this->limit($model,'',$data);
        $list = $this->fillData($list,$user,$data);

        return [true, $list];
    }

    public function productList2($data,$user){
        $model = ProductCategory::TopClear($user,$data);
        $model = $model->where('del_time',0)
            ->select('title','id','parent_id')
            ->orderby('id','desc');
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');

        $list = $model->get()->toArray();
        if(! empty($list)) {
            $productList = Product::where('del_time',0)
                ->whereIn('product_category_id',array_column($list,'id'))
                ->select('id','product_category_id','title','code')
                ->get()->toArray();
            $productMap = [];
            foreach ($productList as $value){
                $productMap[$value['product_category_id']][] = $value;
            }
            foreach ($list as $key => $value){
                if(isset($productMap[$value['id']])) $list[$key]['product'] = $productMap[$value['id']];
            }

            $list = $this->makeTree(0,$list);
            $list = $this->set_sort_circle($list);
        }

        return [200, $list];
    }

    /**
     * 产品参数规则
     * @param $data
     * @param $is_add
     * @return array
     */
    public function productRule(&$data, $user, $is_add = true){
        if(empty($data['title'])) return [false,'产品名称不能为空'];
        if(empty($data['product_category_id'])) return [false,'产品分类不能为空'];
        if(empty($data['code'])) return [false,'产品编码不能为空'];
        if(empty($data['cost'])) return [false,'成本不能为空'];
        $res = $this->checkNumber($data['cost']);
        if(! $res) return [false,'成本请输入不超过两位小数并且大于0的数值'];
        if(empty($data['retail_price'])) return [false,'零售价不能为空'];
        $res = $this->checkNumber($data['retail_price']);
        if(! $res) return [false,'零售价格请输入不超过两位小数并且大于0的数值'];
        if(! empty($data['product_price'])){
            $map = BasicType::whereIn('id',array_column($data['product_price'],'basic_type_id'))
                ->pluck('title','id')
                ->toArray();
            foreach ($data['product_price'] as $value){
                if(! empty($value['price'])) {
                    $tmp = $map[$value['basic_type_id']] ?? '';
                    $res = $this->checkNumber($value['price']);
                    if(! $res) return [false, $tmp . '请输入不超过两位小数并且大于0的数值'];
                }
            }
        }
        if(! empty($data['product_category'])) $data['product_category'] = json_encode($data['product_category']);

        //所属部门 以及 顶级部门
        if(empty($data['depart_id'])) {
            $data['depart_id'] = $this->getDepart($user);
            $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
        }

        //总社id
        $top_depart_id = $user['head'] ?? [];
        $top_depart_id = $top_depart_id['id'] ?? 0;
        if($is_add){
            $bool = Product::whereRaw("(binary code = '{$data['code']}' OR title = '{$data['title']}') AND (top_depart_id = {$data['top_depart_id']} OR top_depart_id = {$top_depart_id})")
                ->where('del_time',0)
                ->exists();
        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $bool = Product::whereRaw("(binary code = '{$data['code']}' OR title = '{$data['title']}') AND (top_depart_id = {$data['top_depart_id']} OR top_depart_id = {$top_depart_id})")
                ->where('id','<>',$data['id'])
                ->where('del_time',0)
                ->exists();
        }
        if($bool) return [false,'产品名称、编码不能重复'];

        return [true, $data];
    }

    /**
     * 拼接数据
     * @param $data
     * @return array
     */
    public function fillData($data, $user, $search){
        if(empty($data['data'])) return $data;

        $type = $search['type'] ?? 0;
        $emp = Employee::whereIn('id',array_unique(array_column($data['data'],'crt_id')))
            ->pluck('emp_name','id')
            ->toArray();
        $category = ProductCategory::whereIn('id',array_unique(array_column($data['data'],'product_category_id')))
            ->pluck('title','id')
            ->toArray();
        $basic_map = BasicType::whereIn('id',array_unique(array_column($data['data'],'unit')))
            ->orWhere('type',BasicType::type_22)
            ->pluck('title','id')
            ->toArray();

        //产品使用价格
        $detail_map = $this->getProductPrice(array_column($data['data'],'id'), $type);

        //是否总公司
        $is_main = $user['is_all_depart'];
        $top_depart = $user['depart_top'][0] ?? [];
        foreach ($data['data'] as $key => $value){
            $tmp = [];
            if(isset($detail_map[$value['id']])){
                $d = $detail_map[$value['id']];
                foreach ($d as $v){
                    if(! $is_main && ($top_depart['basic_type_id'] != $v['basic_type_id'])) {
                        $is_show = 0;
                    }else{
                        $is_show = 1;
                    }
                    if($top_depart['basic_type_id'] != $v['basic_type_id']) {
                        $is_use = 0;
                    }else{
                        $is_use = 1;
                    }
                    $tmp[] = [
                        'basic_type_id' => $v['basic_type_id'],
                        'basic_type_title' => $basic_map[$v['basic_type_id']] ?? '',
                        'price' => $v['price'],
                        'is_show' => $is_show,
                        'is_use' => $is_use
                    ];
                }
            }
            $data['data'][$key]['product_price'] = $tmp;
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $data['data'][$key]['product_category_name'] = $category[$value['product_category_id']] ?? '';
            $data['data'][$key]['state_name'] = Product::$state[$value['state']] ?? '';
            $data['data'][$key]['unit_name'] = $basic_map[$value['unit']] ?? '';
        }

        return $data;
    }

    //获取产品字典
    public function getProductDetail($product_id = []){
        if(empty($product_id)) return [];
        $pro = Product::whereIn('id', $product_id)->get()->toArray();
        return array_column($pro,null,'id');
    }

    //获取产品使用价格
    public function getProductPrice($product_id = [], $type = 1){
        //type 1 采购    2 合同 和 活动包

        $detail_map = [];
        $time = time();
        if($type == 1) {
            //供应商活动价格
            $activity = ProductActivityPrice::from('product_activity_price as a')
                ->join('product_activity as b','b.id','a.product_activity_id')
                ->where('a.del_time',0)
                ->whereIn('a.product_id',$product_id)
                ->where('a.start_time','<=',$time)
                ->where('a.end_time','>=',$time)
                ->where('b.type',ProductActivity::type_two)
                ->select('a.product_id','a.basic_type_id','a.price')
                ->get()->toArray();
            foreach ($activity as $value){
                $detail_map[$value['product_id']][] = $value;
            }
            //分社价 没有供应商活动价格使用分社价格
            $detail = ProductPriceDetail::where('del_time',0)
                ->whereIn('product_id',$product_id)
                ->select('product_id','basic_type_id','price')
                ->get()->toArray();
            foreach ($detail as $value){
                if(! isset($detail_map[$value['product_id']])){
                    $detail_map[$value['product_id']][] = $value;
                }
            }
        }else{
            //零售活动价格
            $activity = ProductActivityPrice::from('product_activity_price as a')
                ->join('product_activity as b','b.id','a.product_activity_id')
                ->where('a.del_time',0)
                ->whereIn('a.product_id',$product_id)
                ->where('a.start_time','<=',$time)
                ->where('a.end_time','>=',$time)
                ->where('b.type',ProductActivity::type_one)
                ->select('a.product_id','a.basic_type_id','a.price')
                ->get()->toArray();
            foreach ($activity as $value){
                $detail_map[$value['product_id']][] = $value;
            }
        }

        return $detail_map;
    }

    public function getProductPriceTmp($product_id = []){
        //type 0 采购  1 合同

        //分社价
        $detail = ProductPriceDetail::where('del_time',0)
            ->whereIn('product_id',$product_id)
            ->select('product_id','basic_type_id','price')
            ->get()->toArray();
        $detail_map = [];
        foreach ($detail as $value){
            $detail_map[$value['product_id']][] = $value;
        }
        $return = $detail_map;

        //活动价格
        $time = time();
        $activity = ProductActivityPrice::where('del_time',0)
            ->whereIn('product_id',$product_id)
            ->where('start_time','<=',$time)
            ->where('end_time','>=',$time)
            ->select('product_id','basic_type_id','price')
            ->get()->toArray();
        if(! empty($activity)){
            foreach ($activity as $value){
                if(! isset($detail_map[$value['product_id']])) {
                    $return[$value['product_id']][] = $value;
                }else{
                    $basic_type = array_column($detail_map[$value['product_id']],'basic_type_id');
                    if(! in_array($value['basic_type_id'], $basic_type)){
                        $return[$value['product_id']][] = $value;
                        continue;
                    }
                    foreach ($detail_map[$value['product_id']] as $key => $val){
                        if($value['basic_type_id'] == $val['basic_type_id']) {
                            //活动价格替换
                            $return[$value['product_id']][$key]['price'] = $value['price'];
                        }
                    }
                }
            }
        }unset($detail_map);

        return $return;
    }
}