t_nine/app/Service/ProductService.php

<?php

namespace App\Service;

use App\Jobs\ProcessDataJob;
use App\Model\BasicType;
use App\Model\Depart;
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\ProductInventoryOfTop;
use App\Model\ProductPriceDetail;
use App\Model\Role;
use App\Model\RoleMenuButton;
use App\Model\SeeRange;
use App\Model\Storehouse;
use App\Model\U8Job;
use Illuminate\Support\Facades\DB;

/**
 * 产品管理
 */
class ProductService extends Service
{
    public function setIsEditUnitPrice($data,$user){
        if($this->isEmpty($data,'id')) return [false,'请选择分类！'];
        if(! isset($data['is_edit_unit_price'])) return [false,'请选择受否允许修改采购单价！'];
        $is_edit_unit_price = $data['is_edit_unit_price'] > 0 ? 1 : 0;
        $all_id = $this->getProductCateGory($data['id']);

        ProductCategory::whereIn('id',$all_id)->update([
            'is_edit_unit_price' => $is_edit_unit_price
        ]);

        return [true, ''];
    }

    /**
     * 产品分类编辑
     * @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','is_edit_unit_price')
            ->orderby('id','asc');
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(isset($data['is_edit_unit_price'])) $model->where('is_edit_unit_price', $data['is_edit_unit_price']);

        $list = $model->get()->toArray();
        foreach ($list as $key => $value){
            $list[$key]['is_edit_unit_price_title'] = ProductCategory::$is_edit_unit_price[$value['is_edit_unit_price']] ?? "";
        }

        $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]];
    }

    public function productCategoryList2($data,$user){
        $head_top_depart_id = $user['head']['id'] ?? 0;
        $now_top_depart_id = $this->getDepart($user);

        //总社分类
        $head = ProductCategory::where('del_time',0)
            ->where('top_depart_id', $head_top_depart_id)
            ->select('title','id','parent_id')
            ->orderby('id','asc')
            ->get()->toArray();
        $head_tree = [];
        if(! empty($head)) {
            $head_tree = $this->makeTree(0,$head);
            $head_tree = $this->set_sort_circle($head_tree);
        }

        //我的
        $my_tree = [];
        if($head_top_depart_id != $now_top_depart_id){
            $model = ProductCategory::TopClear($user,$data);
            $model = $model->where('del_time',0)
                ->select('title','id','parent_id')
                ->orderby('id','asc');
            $list = $model->get()->toArray();
            if(! empty($list)) {
                $my_tree = $this->makeTree(0,$list);
                $my_tree = $this->set_sort_circle($my_tree);
            }
        }

        return [200, ['head_tree' => $head_tree, 'my_tree' => $my_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->build_fee = $data['build_fee'] ?? 0;
            $model->item_code = $data['item_code'] ?? "";
            $model->mark = $data['mark'] ?? '';
            $model->state = $data['state'] ?? 0;
            $model->product_attribute = $data['product_attribute'] ?? 0;
            $model->is_use = $data['is_use'] ?? Product::is_use_one;
            $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,
                    ];
                    if(in_array($value['url'], $old)) {
                        foreach ($old as $o_k => $o_v){
                            if($o_v == $value['url']) unset($old[$o_k]);
                        }
                    }else{
                        $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,
                    ];
                    if(in_array($value['url'], $old)) {
                        foreach ($old as $o_k => $o_v){
                            if($o_v == $value['url']) unset($old[$o_k]);
                        }
                    }else{
                        $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()];
        }

        return [true, ['file' => ['new' => $new, 'old' => $old]]];
    }

    /**
     * 产品新增
     * @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->build_fee = $data['build_fee'] ?? 0;
            $model->item_code = $data['item_code'] ?? "";
            $model->mark = $data['mark'] ?? '';
            $model->state = $data['state'] ?? 0;
            $model->product_attribute = $data['product_attribute'] ?? 0;
            $model->crt_id = $user['id'];
            $model->depart_id = $data['depart_id'] ?? 0;
            $model->top_depart_id = $data['top_depart_id'] ?? 0;
            $model->is_use = $data['is_use'] ?? Product::is_use_one;
            $model->save();

            $time = time();

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

            $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,
                    ];
                    if(! empty($value['url'])) $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,
                    ];
                    if(! empty($value['url'])) $new[] = $value['url'];
                }
                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, ['file' => ['new' => $new]]];
    }

    /**
     * 产品删除
     * @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]);

            $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]);

            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, ['file' => ['old' => $old]]];
    }

    /**
     * 产品详情
     * @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_attribute_title'] = Product::$product_attribute[$customer['product_attribute']] ?? "";
        $customer['is_use_title'] = Product::$is_use[$customer['is_use']] ?? "";
        $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;

        $data['top_depart_id'] = $user['head']['id'] ?? 0;
        $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();
        $top_depart = $user['depart_top'][0] ?? [];
        $customer['is_edit'] = $customer['top_depart_id'] == $top_depart['depart_id'] ? 1 : 0;
        $customer['product_price'] = [];

        //特殊功能按钮
        $special_button = $user['special_button'] ?? [];

        //成本
        $is_show_cost = 0;
        if(in_array(RoleMenuButton::special_two,$special_button)) $is_show_cost = 1;
        $customer['cost_show'] = $is_show_cost;

        //所有金额
        foreach ($basic as $value){
            $show = 0;
            if(in_array(RoleMenuButton::special_one,$special_button)){
                $show = 1;
            }else{
                if($top_depart['basic_type_id'] == $value['id']) $show = 1;
            }
            $customer['product_price'][$value['id']] = [
                'basic_type_id' => $value['id'],
                'basic_type_title' => $title_map[$value['id']] ?? '',
                'price' => 0,
                'is_show' => $show,
            ];
        }
        //展示金额
        foreach ($detail as $value){
            if(isset($customer['product_price'][$value['basic_type_id']])) $customer['product_price'][$value['basic_type_id']]['price'] = $value['price'];
        }

        $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();
        $fileUploadService = new FileUploadService();
        foreach ($customer_info as $value){
            $tmp = [
                'url' => $value['file'],
                'name' => $value['name'],
                'show_url' => $fileUploadService->getFileShow($value['file']),
            ];
            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];
    }

    public function productCommon($data,$user, $field = []){
        if(empty($field)){
            $field = ['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','product_attribute','is_use','build_fee','item_code'];
        }

        $model = Product::ProductClear($user,$data);
        $model = $model->where('del_time',0)
            ->select($field)
            ->orderby('product_attribute', 'desc')
            ->orderby('id', 'desc');

        if(! empty($data['title_t'])) {
            // 清理用户输入，去除前后空白并替换多个连续空格为单个空格
            $cleanTitle = preg_replace('/\s+/', ' ', trim($data['title_t']));
            // 构建查询时使用 TRIM 和 REPLACE 来清理数据库字段中的空白字符
            $model->whereRaw("TRIM(REPLACE(title, ' ', '')) LIKE ?", ['%' . str_replace(' ', '', $cleanTitle) . '%'])
                ->orWhere('code', 'LIKE', '%'.$data['title_t'].'%')
                ->orWhere('size', 'LIKE', '%'.$data['title_t'].'%');
        }
        if(! empty($data['title'])) {
            // 清理用户输入，去除前后空白并替换多个连续空格为单个空格
            $cleanTitle = preg_replace('/\s+/', ' ', trim($data['title']));
            // 构建查询时使用 TRIM 和 REPLACE 来清理数据库字段中的空白字符
            $model->whereRaw("TRIM(REPLACE(title, ' ', '')) LIKE ?", ['%' . str_replace(' ', '', $cleanTitle) . '%']);

//            $model->where('title', 'LIKE', '%'.$data['title'].'%');
        }
        if(isset($data['state'])) $model->where('state', $data['state']);
        if(isset($data['is_use'])) $model->where('is_use', $data['is_use']);
        if(isset($data['product_attribute'])) $model->where('product_attribute', $data['product_attribute']);
        if(! empty($data['product_category_id'])) $model->where('product_category_id', $data['product_category_id']);
        if(! empty($data['category'])){
            $id = $this->getProductCateGory($data['category']);
            $model->whereIn('product_category_id', $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['item_code'])) $model->where('item_code', 'LIKE', '%'.$data['item_code'].'%');
        if(! empty($data['bar_code'])) $model->where('bar_code', 'LIKE', '%'.$data['bar_code'].'%');
        if(! empty($data['size'])) $model->where('size', 'LIKE', '%'.$data['size'].'%');
        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]);
        }
        if(! empty($data['product_id'])) $model->whereIn('id',$data['product_id']);

        return $model;
    }

    /**
     * 产品列表
     * @param $data
     * @param $user
     * @return array
     */
    public function productListIndex($data,$user){
        $model = $this->productCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillData($list,$user,$data);

        return [true, $list];
    }

    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','product_attribute','is_use','build_fee','item_code')
            ->where('is_use', Product::is_use_one)
            ->orderby('product_attribute', 'desc')
            ->orderby('id', 'desc');

        if(! empty($data['title_t'])) {
            // 清理用户输入，去除前后空白并替换多个连续空格为单个空格
            $cleanTitle = preg_replace('/\s+/', ' ', trim($data['title_t']));
            // 构建查询时使用 TRIM 和 REPLACE 来清理数据库字段中的空白字符
            $model->whereRaw("TRIM(REPLACE(title, ' ', '')) LIKE ?", ['%' . str_replace(' ', '', $cleanTitle) . '%'])
                ->orWhere('code', 'LIKE', '%'.$data['title_t'].'%')
                ->orWhere('size', 'LIKE', '%'.$data['title_t'].'%');
        }
        if(! empty($data['title'])){
            // 清理用户输入，去除前后空白并替换多个连续空格为单个空格
            $cleanTitle = preg_replace('/\s+/', ' ', trim($data['title']));
            // 构建查询时使用 TRIM 和 REPLACE 来清理数据库字段中的空白字符
            $model->whereRaw("TRIM(REPLACE(title, ' ', '')) LIKE ?", ['%' . str_replace(' ', '', $cleanTitle) . '%']);
//            $model->where('title', 'LIKE', '%'.$data['title'].'%');
        }
        if(isset($data['state'])) $model->where('state', $data['state']);
        if(isset($data['product_attribute'])) $model->where('product_attribute', $data['product_attribute']);
        if(! empty($data['product_category_id'])) $model->where('product_category_id', $data['product_category_id']);
        if(! empty($data['category'])){
            $id = $this->getProductCateGory($data['category']);
            $model->whereIn('product_category_id', $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['size'])) $model->where('size', 'LIKE', '%'.$data['size'].'%');
        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]);
        }
        if(! empty($data['product_id'])) $model->whereIn('id',$data['product_id']);
        if(isset($data['is_head'])){
            if($data['is_head'] == 1){
                $head = $user['head']['id'] ?? 0;
                $model->where('top_depart_id', $head);
            }else{
                $top_depart_id = $user['depart_top'][0] ?? [];
                $top_depart_id = $top_depart_id['depart_id'] ?? 0;
                $model->where('top_depart_id', $top_depart_id);
            }
        }

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

        return [true, $list];
    }

    public function productList2($data,$user){
        $model = ProductCategory::ProductClear($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(! isset($data['cost'])) return [false, '请填写成本'];
        if(! isset($data['retail_price'])) return [false, '请填写零售价'];
        $res = $this->checkNumber($data['cost']);
        if(! $res) return [false,'成本请输入不超过两位小数并且大于等于0的数值'];
        $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']}') 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']}') 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')))
            ->select('title','id','is_edit_unit_price')
            ->get()
            ->toArray();
        $category = array_column($category,null,'id');
        $basic_map = BasicType::whereIn('id',array_unique(array_column($data['data'],'unit')))
            ->orWhere('type',BasicType::type_22)
            ->pluck('title','id')
            ->toArray();

        $depart_map = Depart::whereIn('id',array_unique(array_column($data['data'],'top_depart_id')))->pluck('title','id')->toArray();

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

        //获取产品图片
        $img = $this->getProductImg($product_id);

        //当前门店
        $top_depart = $user['depart_top'][0] ?? [];
        //特殊功能按钮
        $special_button = $user['special_button'] ?? [];

        //库存
        $stock_map = [];
        if(! empty($search['storehouse_id'])){
            $stock = ProductInventoryService::getRealStock($product_id, $search['storehouse_id']);
            foreach ($stock as $value){
                $stock_map[$value['product_id']] = $value;
            }unset($stock);
        }

        //分社价格
        $product_fs = [];
        if(! empty($search['fs_price_get'])) $product_fs = $this->getProductPriceDetail(['id' => $product_id], $user);

        foreach ($data['data'] as $key => $value){
            $tmp = [];
            if(isset($detail_map[$value['id']])){
                $d = $detail_map[$value['id']];
                foreach ($d as $v){
                    $is_show = 0;
                    if(in_array(RoleMenuButton::special_one,$special_button)) $is_show = 1;
                    $is_use = 0;
                    if($top_depart['basic_type_id'] == $v['basic_type_id']) $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;
            $price_tmp = $product_fs[$value['id']] ?? [];
            foreach ($price_tmp as $t_k => $t){
                $data['data'][$key][$t_k] = $t;
            }
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['is_use_title'] = Product::$is_use[$value['is_use']] ?? "";
            $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $category_tmp = $category[$value['product_category_id']] ?? [];
            $data['data'][$key]['product_category_name'] = $category_tmp['title'] ?? '';
            $data['data'][$key]['is_edit_unit_price'] = $category_tmp['is_edit_unit_price'] ?? 0;
            $data['data'][$key]['state_name'] = Product::$state[$value['state']] ?? '';
            $data['data'][$key]['unit_name'] = $basic_map[$value['unit']] ?? '';
            $data['data'][$key]['belong_to'] = $depart_map[$value['top_depart_id']] ?? '';
            $data['data'][$key]['product_attribute_title'] = Product::$product_attribute[$value['product_attribute']] ?? "";
            $data['data'][$key]['color'] = Product::$product_attribute_color[$value['product_attribute']] ?? [];
            $data['data'][$key]['img'] = $img[$value['id']] ?? "";
            //库存
            $data['data'][$key]['stock'] = $stock_map[$value['id']] ?? (object)[];
            //成本
            $data['data'][$key]['cost_show'] = $value['cost'];
        }

        return $data;
    }

    public function getProductCateGory($category){
        $product_category = ProductCategory::where('del_time',0)
            ->select('id','parent_id')
            ->get()->toArray();
        $result = array_merge($this->getAllDescendants($product_category,$category),[$category]);
        return $result;
    }

    public function getProductImg($product_id = []){
        if(empty($product_id)) return [];

        $img = [];
        $customer_info = ProductInfo::where('del_time',0)
            ->whereIn('product_id',$product_id)
            ->where('type',ProductInfo::type_one)
            ->select('product_id','file','type','name')
            ->get()->toArray();
        $fileUploadService = new FileUploadService();
        foreach ($customer_info as $value){
            if(isset($img[$value['product_id']])) continue;
            $url = "";
            if(! empty($value['file'])) $url = $fileUploadService->getFileShow($value['file']);
            $img[$value['product_id']] = $url;
        }

        return $img;
    }

    public function batchUploadImg($data){
        if(empty($data['product_id'])) return [false, '请选择产品'];

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

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

            $new['origin'] = $data['img_url'] ?? "";
            $new['img_list'] = [];
            $img = str_replace(FileUploadService::string . FileUploadService::string2, '', $data['img_url']);
            $img = explode('.', $img);

            $insert = [];
            if(! empty($data['img_url'])){
                foreach ($data['product_id'] as $key => $value){
                    $copy = $img[0] . 'C' . $key . '.' . $img[1];
                    $copy = FileUploadService::string . FileUploadService::string2 . $copy;
                    $insert[] = [
                        'product_id' => $value,
                        'file' => $copy,
                        'type' => ProductInfo::type_one,
                        'name' => $data['img_name'] ?? "",
                        'crt_time' => $time,
                    ];
                    $new['img_list'][] = $copy;
                }
                if(! empty($insert)) ProductInfo::insert($insert);
            }

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

        return [true, ['is_batch' => true, 'file' => ['new' => $new, 'old' => $old]]];
    }

    public function batchBuildFee($data){
        if(empty($data['product_id'])) return [false, '请选择产品'];
        if(! isset($data['build_fee'])) return [false, '请填写安装费'];
        $res = $this->checkNumber($data['build_fee']);
        if(! $res) return [false,'安装费请输入不超过两位小数并且大于等于0的数值'];

        try {
            DB::beginTransaction();

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

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

        return [true, ''];
    }

    //获取产品字典
    public function getProductDetail($product_id = []){
        if(empty($product_id)) return [];
        $pro = Product::whereIn('id', $product_id)->get()->toArray();
        $category = ProductCategory::whereIn('id',array_unique(array_column($pro,'product_category_id')))
            ->pluck('is_edit_unit_price','id')
            ->toArray();
        foreach ($pro as $key => $value){
            $pro[$key]['is_edit_unit_price'] = $category[$value['product_category_id']] ?? 0;
        }
        return array_column($pro,null,'id');
    }

    //获取产品使用价格
    public function getProductPrice($product_id = [], $type = 1, $basic_type_id_for = 0){
        if(! is_array($product_id)) $product_id = [$product_id];
        //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)
                ->when(! empty($basic_type_id_for), function ($query) use ($basic_type_id_for) {
                    return $query->where('a.basic_type_id',$basic_type_id_for);
                })
                ->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)
                ->when(! empty($basic_type_id_for), function ($query) use ($basic_type_id_for) {
                    return $query->where('basic_type_id',$basic_type_id_for);
                })
                ->select('product_id','basic_type_id','price')
                ->get()->toArray();
            foreach ($detail as $value){
                if(! isset($detail_map[$value['product_id']][$value['basic_type_id']])){
                    $detail_map[$value['product_id']][$value['basic_type_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;
    }

    //获取产品分社价格
    public function getProductPriceDetail($data, $user){
        $data['top_depart_id'] = $user['head']['id'] ?? 0;
        $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)
            ->whereIn('product_id',$data['id'])
            ->select('product_id','basic_type_id','price')
            ->get()->toArray();
        $product_price = [];

        //所有金额
        foreach ($basic as $value){
            $product_price[$value['id']] = "0";
        }

        $return = [];
        foreach ($data['id'] as $value){
            $return[$value] = $product_price;
        }

        //展示金额
        foreach ($detail as $value){
            if(isset($return[$value['product_id']][$value['basic_type_id']])) $return[$value['product_id']][$value['basic_type_id']] = $value['price'];
        }

        return $return;
    }

    public function productGroupByList($data,$user){
        $model = Product::ProductClear($user,$data);
        $model = $model->where('del_time',0)
            ->where('item_code','<>',"")
            ->select('title','id','product_category_id','product_category','retail_price','product_attribute','item_code','unit','size','code','bar_code')
            ->where('is_use', Product::is_use_one)
            ->groupBy('item_code')
            ->orderby('product_attribute', 'desc');

        if(! empty($data['title_t'])) {
            // 清理用户输入，去除前后空白并替换多个连续空格为单个空格
            $cleanTitle = preg_replace('/\s+/', ' ', trim($data['title_t']));
            // 构建查询时使用 TRIM 和 REPLACE 来清理数据库字段中的空白字符
            $model->whereRaw("TRIM(REPLACE(title, ' ', '')) LIKE ?", ['%' . str_replace(' ', '', $cleanTitle) . '%'])
                ->orWhere('code', 'LIKE', '%'.$data['title_t'].'%')
                ->orWhere('size', 'LIKE', '%'.$data['title_t'].'%');
        }
        if(! empty($data['title'])){
            // 清理用户输入，去除前后空白并替换多个连续空格为单个空格
            $cleanTitle = preg_replace('/\s+/', ' ', trim($data['title']));
            // 构建查询时使用 TRIM 和 REPLACE 来清理数据库字段中的空白字符
            $model->whereRaw("TRIM(REPLACE(title, ' ', '')) LIKE ?", ['%' . str_replace(' ', '', $cleanTitle) . '%']);
//            $model->where('title', 'LIKE', '%'.$data['title'].'%');
        }
        if(isset($data['state'])) $model->where('state', $data['state']);
        if(isset($data['product_attribute'])) $model->where('product_attribute', $data['product_attribute']);
        if(! empty($data['product_category_id'])) $model->where('product_category_id', $data['product_category_id']);
        if(! empty($data['category'])){
            $id = $this->getProductCateGory($data['category']);
            $model->whereIn('product_category_id', $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['size'])) $model->where('size', 'LIKE', '%'.$data['size'].'%');
        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]);
        }
        if(! empty($data['product_id'])) $model->whereIn('id',$data['product_id']);

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

        return [true, $list];
    }

    public function productGroupByListData($data, $user, $search){
        if(empty($data['data'])) return $data;

        $type = $search['type'] ?? 1;
        $category = ProductCategory::whereIn('id',array_unique(array_column($data['data'],'product_category_id')))
            ->select('title','id')
            ->get()
            ->toArray();
        $category = array_column($category,null,'id');
        $basic_map = BasicType::whereIn('id',array_unique(array_column($data['data'], 'unit')))
            ->OrWhere('type',BasicType::type_22)
            ->pluck('title','id')
            ->toArray();

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

        //获取产品图片
        $img = $this->getProductImg($product_id);

        //当前门店
        $top_depart = $user['depart_top'][0] ?? [];

        $stock = ProductInventoryOfTop::where('del_time',0)
            ->whereIn('product_id',$product_id)
            ->pluck('number','product_id')
            ->toArray();
        foreach ($data['data'] as $key => $value){
            $arr = json_decode($value['product_category'], true);
            $arr = array_flip($arr);
            if (isset($arr[112])) {
                $data['data'][$key]['is_roll'] = true;
            }else{
                $data['data'][$key]['is_roll'] = false;
            }

            $data['data'][$key]['img'] = $img[$value['id']] ?? "";
            $tmp = $this->fillProductPrice($detail_map, $value, $top_depart,$basic_map);
            $data['data'][$key]['product_price'] = $tmp;
            $category_tmp = $category[$value['product_category_id']] ?? [];
            $data['data'][$key]['product_category_name'] = $category_tmp['title'] ?? '';
            $data['data'][$key]['product_attribute_title'] = Product::$product_attribute[$value['product_attribute']] ?? "";
            $data['data'][$key]['stock'] = $this->returnStock($stock, $value);
            $data['data'][$key]['unit_title'] = $basic_map[$value['unit']] ?? "";
        }

        return $data;
    }

    public function productGroupByListDetail($data, $user){
        if(empty($data['item_code'])) return [false, '商品编码不能为空'];
        $type = $data['type'] ?? 1;

        //获取相同itemCode的产品
        $product = $this->getProductByItemCode([$data['item_code']], $user);

        $category = ProductCategory::whereIn('id',array_unique(array_column($product,'product_category_id')))
            ->pluck('title','id')
            ->toArray();

        $basic_map = BasicType::whereIn('id',array_unique(array_column($product, 'unit')))
            ->OrWhere('type',BasicType::type_22)
            ->pluck('title','id')
            ->toArray();

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

        //获取产品图片
        $img = $this->getProductImg($product_id);

        //当前门店
        $top_depart = $user['depart_top'][0] ?? [];

        $stock = ProductInventoryOfTop::where('del_time',0)
            ->whereIn('product_id',$product_id)
            ->pluck('number','product_id')
            ->toArray();
        foreach ($product as $key => $value){
            $tmp = $this->fillProductPrice($detail_map, $value, $top_depart,$basic_map);
            $product[$key]['product_price'] = $tmp;
            $product[$key]['img'] = $img[$value['id']] ?? "";
            $product[$key]['product_category_name'] = $category[$value['product_category_id']] ?? '';
            $product[$key]['product_attribute_title'] = Product::$product_attribute[$value['product_attribute']] ?? "";
            $product[$key]['stock'] = $this->returnStock($stock, $value);
            $product[$key]['unit_title'] = $basic_map[$value['unit']] ?? "";
            $arr = json_decode($value['product_category'], true);
            $arr = array_flip($arr);
            if (isset($arr[112])) {
                $product[$key]['is_roll'] = true;
            }else{
                $product[$key]['is_roll'] = false;
            }
        }

        return [true, $product];
    }

    public function getProductByItemCode($item_code,$user){
        if(empty($item_code)) return [];

        $model = Product::ProductClear($user,[]);
        $product = $model->where('del_time',0)
            ->whereIn('item_code', $item_code)
            ->where('is_use', Product::is_use_one)
            ->select('title','id','product_category_id','retail_price','product_attribute','item_code','size','unit','code','bar_code','product_category')
            ->orderby('product_attribute', 'desc')
            ->get()->toArray();

        return $product;
    }

    public function fillProductPrice($detail_map, $value, $top_depart,$basic_map = []){
        $tmp = [];
        if(isset($detail_map[$value['id']])){
            $d = $detail_map[$value['id']];
            foreach ($d as $v){
                if($top_depart['basic_type_id'] != $v['basic_type_id']) continue;
                $tmp = [
                    'basic_type_id' => $v['basic_type_id'],
                    'basic_type_title' => $basic_map[$v['basic_type_id']] ?? '',
                    'price' => $v['price']
                ];
            }
        }
        if(empty($tmp)) $tmp = (object)$tmp;

        return $tmp;
    }

    public function updateTopStock($data, $user){
        $limit_key = "updateTopStockFromYy";
//        list($status, $msg) = $this->limitingSendRequestBackg($limit_key);
//        if(! $status) return [false, '正在获取T9杭州总仓库存货库存,请勿重复操作'];

        //总店
        $head = $user['head']['id'] ?? 0;
        $storehouse_id = Storehouse::where('top_depart_id', $head)->where('del_time',0)->value('id') ?? 0;

        $time = time();
        DB::table('product')
            ->where('del_time', 0)
            ->where('top_depart_id', $head)
            ->select('id','code')
            ->orderBy('id')
            ->chunk(200, function ($data) use($head,$storehouse_id,$time){
                $data = Collect($data)->map(function ($object) {
                    return (array)$object;
                })->toArray();

                $map = array_column($data,'id','code');
                $id = array_unique(array_column($data,'id'));
                $code = array_unique(array_column($data,'code'));
                $post = [
                    'urlFromT9' => 'getStock',
                    'code' => $code,
                    'warehouse' => '001',
                ];
                $post = json_encode($post);
                $header = ['Content-Type:application/json'];
                list($status, $msg) = $this->post_helper("https://workapi.qingyaokeji.com/api/updateTopStock",$post, $header);
                if($msg['code'] != 200) return [false, $msg['msg']];
                $msg = $msg['data'] ?? [];

                $insert = [];
                foreach ($msg as $value){
                    $insert[] = [
                        'product_id' => $map[$value['product_no']] ?? 0,
                        'storehouse_id' => $storehouse_id,
                        'top_depart_id' => $head,
                        'number' => $value['number'],
                        'crt_time' => $time,
                    ];
                }

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

                if(! empty($insert)) ProductInventoryOfTop::insert($insert);
            });

        return [true, ''];

        try{
            $job = ProcessDataJob::dispatch(['head' => $head, 'storehouse_id' => $storehouse_id, 'type' => U8Job::three,'limit_key' => $limit_key])->onQueue(U8Job::job3);
            if(! $job) {
                $this->dellimitingSendRequestBackg($limit_key);
                return [false,'T9杭州总仓库存货库存任务没有进入队列！'];
            }
        }catch (\Throwable $e){
            $this->dellimitingSendRequestBackg($limit_key);
            return [false,$e->getMessage()];
        }

        return [true, 'T9杭州总仓库存货库存任务正在后台执行,请等待'];
    }

    private function returnStock($stock, $value){
        if(isset($stock[$value['id']])){
            $number = $stock[$value['id']];
            if($number <= 0){
                $stock = "售罄";
            } elseif($number <= 15){
                $stock = " 库存紧张";
            }else{
                $stock = " 库存充足";
            }
        }else{
            $stock = "联系客服";
        }

        return $stock;
    }

    public function writeStock($data){
        try {
            $head = $data['head'];
            $storehouse_id = $data['storehouse_id'];
            $limit_key = $data['limit_key'];

            DB::enableQueryLog();

            $service = new U8ServerService(true);
            if(! empty($service->error)) return [false, $service->error];

            $time = time();
            DB::table('product')
                ->where('del_time', 0)
                ->where('top_depart_id', $head)
                ->select('id','code')
                ->orderBy('id')
                ->chunk(200, function ($data) use($head,$storehouse_id,$time){
                    $data = Collect($data)->map(function ($object) {
                        return (array)$object;
                    })->toArray();

                    $map = array_column($data,'id','code');
                    $id = array_unique(array_column($data,'id'));
                    $code = array_unique(array_column($data,'code'));
                    $post = [
                        'urlFromT9' => 'getStock',
                        'code' => $code,
                        'warehouse' => '001',
                    ];
                    $post = json_encode($post);
                    $header = ['Content-Type:application/json'];
                    list($status, $msg) = $this->post_helper("https://workapi.qingyaokeji.com/api/updateTopStock",$post, $header);
                    if($msg['code'] != 200) return [false, $msg['msg']];
                    $msg = $msg['data'] ?? [];

                    $insert = [];
                    foreach ($msg as $value){
                        $insert[] = [
                            'product_id' => $map[$value['product_no']] ?? 0,
                            'storehouse_id' => $storehouse_id,
                            'top_depart_id' => $head,
                            'number' => $value['number'],
                            'crt_time' => $time,
                        ];
                    }

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

                    if(! empty($insert)) ProductInventoryOfTop::insert($insert);
                });

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

        return [true, ''];
    }

    public function post_helper($url, $data, $header = [], $timeout = 20){
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch,  CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_ENCODING, '');
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);

        if(!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        $r = curl_exec($ch);

        if ($r === false) {
            // 获取错误号
            $errorNumber = curl_errno($ch);
            // 获取错误信息
            $errorMessage = curl_error($ch);
            $message = "cURL Error #{$errorNumber}: {$errorMessage}";

            return [false, $message];
        }
        curl_close($ch);

        return [true, json_decode($r, true)];
    }
}