t_nine/app/Service/CustomerService.php

<?php

namespace App\Service;

use App\Model\BasicType;
use App\Model\Customer;
use App\Model\CustomerInfo;
use App\Model\Depart;
use App\Model\Employee;
use App\Model\Product;
use Illuminate\Support\Facades\DB;

/**
 * 客户管理相关
 */
class CustomerService extends Service
{
    /**
     * 客户编辑
     * @param $data
     * @param $user
     * @return array
     */
    public function customerEdit($data,$user){
        list($status,$msg) = $this->customerRule($data,false);
        if(!$status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $model = Customer::where('id',$data['id'])->first();
            $model->title = $data['title'];
            $model->model_type = $data['model_type'];
            $model->customer_intention = $data['customer_intention'] ?? 0;
            $model->customer_from = $data['customer_from'] ?? 0;
            $model->customer_type = $data['customer_type'] ?? 0;
            $model->car_type = $data['car_type'] ?? 0;
            $model->consulting_product = $data['consulting_product'] ?? '';
            $model->intention_product = $data['intention_product'] ?? 0;
            $model->progress_stage = $data['progress_stage'] ?? 0;
            $model->address1 = $data['address1'] ? json_encode($data['address1']) : '';
            $model->address2 = $data['address2'] ?? '';
            $model->mark = $data['mark'] ?? '';
            $model->importance = $data['importance'] ?? '';
            $model->company = $data['company'] ?? '';
            $model->company_short_name = $data['company_short_name'] ?? '';
            $model->depart_id = $data['depart_id'] ?? 0;
            $model->top_depart_id = $data['top_depart_id'] ?? 0;
            $model->state_type = $data['state_type'] ?? 0;
            $model->customer_state = $data['customer_state'] ?? 0;
            $model->customer_grade = $data['customer_grade'] ?? 0;
            $model->save();
            $time = time();

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

            if(! empty($data['customer_contact'])){
                $insert = [];
                foreach ($data['customer_contact'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'contact_type' => $value['id'],
                        'contact_info' => $value['info'],
                        'type' => CustomerInfo::type_one,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

            if(! empty($data['employee_one'])){
                $insert = [];
                foreach ($data['employee_one'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_two,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

            if(! empty($data['employee_two'])){
                $insert = [];
                foreach ($data['employee_two'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_three,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

            if(! empty($data['employee_three'])){
                $insert = [];
                foreach ($data['employee_three'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_four,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

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

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

            if(! empty($data['employee'])){
                $insert = [];
                foreach ($data['employee'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_eight,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

            if(! empty($data['depart'])){
                $insert = [];
                foreach ($data['depart'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_seven,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

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

        return [true,''];
    }

    /**
     * 客户新增
     * @param $data
     * @param $user
     * @return array
     */
    public function customerAdd($data,$user){
        list($status,$msg) = $this->customerRule($data);
        if(!$status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $model = new Customer();
            $model->title = $data['title'];
            $model->model_type = $data['model_type'];
            $model->customer_intention = $data['customer_intention'] ?? 0;
            $model->customer_from = $data['customer_from'] ?? 0;
            $model->customer_type = $data['customer_type'] ?? 0;
            $model->car_type = $data['car_type'] ?? 0;
            $model->consulting_product = $data['consulting_product'] ?? '';
            $model->intention_product = $data['intention_product'] ?? 0;
            $model->progress_stage = $data['progress_stage'] ?? 0;
            $model->address1 = $data['address1'] ? json_encode($data['address1']) : '';
            $model->address2 = $data['address2'] ?? '';
            $model->crt_id = $user['id'];
            $model->mark = $data['mark'] ?? '';
            $model->importance = $data['importance'] ?? '';
            $model->company = $data['company'] ?? '';
            $model->company_short_name = $data['company_short_name'] ?? '';
            $model->depart_id = $data['depart_id'] ?? 0;
            $model->top_depart_id = $data['top_depart_id'] ?? 0;
            $model->state_type = $data['state_type'] ?? 0;
            $model->customer_state = $data['customer_state'] ?? 0;
            $model->customer_grade = $data['customer_grade'] ?? 0;
            $model->save();
            $time = time();

            if(! empty($data['customer_contact'])){
                $insert = [];
                foreach ($data['customer_contact'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'contact_type' => $value['id'],
                        'contact_info' => $value['info'],
                        'type' => CustomerInfo::type_one,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

            if(! empty($data['employee_one'])){
                $insert = [];
                foreach ($data['employee_one'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_two,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

            if(! empty($data['employee_two'])){
                $insert = [];
                foreach ($data['employee_two'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_three,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

            if(! empty($data['employee_three'])){
                $insert = [];
                foreach ($data['employee_three'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_four,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

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

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

            if(! empty($data['employee'])){
                $insert = [];
                foreach ($data['employee'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_eight,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

            if(! empty($data['depart'])){
                $insert = [];
                foreach ($data['depart'] as $value){
                    $insert[] = [
                        'customer_id' => $model->id,
                        'data_id' => $value,
                        'type' => CustomerInfo::type_seven,
                        'crt_time' => $time,
                    ];
                }
                CustomerInfo::insert($insert);
            }

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

        return [true,''];
    }

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

        try {
            DB::beginTransaction();

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

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

        return [true,''];
    }

    /**
     * 客户详情
     * @param $data
     * @return array
     */
    public function customerDetail($data){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];

        $customer = Customer::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'客户不存在或已被删除'];
        $customer = $customer->toArray();
        $product = Product::where('id',$customer['intention_product'])->value('title');
        $customer['intention_product_title'] = $product;
        $address = '';
        if(! empty($customer['address1'])) {
            $tmp = json_decode($customer['address1'],true);
            $customer['address1'] = $tmp;
            $tmp = implode(' ',$tmp);
            $tmp .= ' ' . $customer['address2'];
            $address = $tmp;
        }
        $customer['address'] = $address;
        $customer['customer_contact'] = $customer['employee_one'] = $customer['employee_two'] = $customer['employee_three'] = $customer['img'] = $customer['file'] = $customer['employee'] = $customer['depart'] = [];
        $array = [
            $customer['customer_intention'],
            $customer['customer_from'],
            $customer['customer_type'],
            $customer['car_type'],
            $customer['progress_stage'],
            $customer['state_type'],
            $customer['customer_state'],
            $customer['customer_grade'],
        ];
        $basic_map = BasicType::whereIn('id',$array)
            ->pluck('title','id')
            ->toArray();
        $depart_title = Depart::where('id',$customer['depart_id'])->select('title')->value('title');
        $customer = [$customer];
        foreach ($customer as $key => $value){
            $customer[$key]['customer_intention_title'] = $basic_map[$value['customer_intention']] ?? '';
            $customer[$key]['customer_from_title'] = $basic_map[$value['customer_from']] ?? '';
            $customer[$key]['customer_type_title'] = $basic_map[$value['customer_type']] ?? '';
            $customer[$key]['car_type_title'] = $basic_map[$value['car_type']] ?? '';
            $customer[$key]['progress_stage_title'] = $basic_map[$value['progress_stage']] ?? '';
            $customer[$key]['state_type_title'] = $basic_map[$value['state_type']] ?? '';
            $customer[$key]['customer_state_title'] = $basic_map[$value['customer_state']] ?? '';
            $customer[$key]['customer_grade_title'] = $basic_map[$value['customer_grade']] ?? '';
            $customer[$key]['depart_title'] = $depart_title ?? '';
        }
        $customer = $customer[0];

        $customer_info = CustomerInfo::where('del_time',0)
            ->where('customer_id',$customer['id'])
            ->select('id','customer_id','contact_type','contact_info','data_id','file','type','name')
            ->get()->toArray();
        $emp_id = [];
        $emp_id[] = $customer['crt_id'];
        $depart = [];
        foreach ($customer_info as $value){
            if(in_array($value['type'], CustomerInfo::$man)){
                $emp_id[] = $value['data_id'];
            }else{
                if($value['type'] == CustomerInfo::type_seven){
                    $depart[] = $value['data_id'];
                }
            }
        }
        $emp_map = Employee::whereIn('id',array_unique($emp_id))
            ->pluck('emp_name','id')
            ->toArray();
        $basic_map2 = BasicType::whereIn('id',array_unique(array_column($customer_info,'contact_type')))
            ->pluck('title','id')
            ->toArray();
        $depart_map = Depart::whereIn('id',array_unique($depart))
            ->pluck('title','id')
            ->toArray();
        foreach ($customer_info as $value){
            if($value['type'] == CustomerInfo::type_one){
                $tmp = [
                    'id' => $value['contact_type'],
                    'title' => $basic_map2[$value['contact_type']] ?? '',
                    'info' => $value['contact_info']
                ];
                $customer['customer_contact'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_two){
                $tmp = [
                    'id' => $value['data_id'],
                    'name' => $emp_map[$value['data_id']] ?? '',
                ];
                $customer['employee_one'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_three){
                $tmp = [
                    'id' => $value['data_id'],
                    'name' => $emp_map[$value['data_id']] ?? '',
                ];
                $customer['employee_two'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_four){
                $tmp = [
                    'id' => $value['data_id'],
                    'name' => $emp_map[$value['data_id']] ?? '',
                ];
                $customer['employee_three'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_five){
                $tmp = [
                    'url' => $value['file'],
                    'name' => $value['name'],
                ];
                $customer['img'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_six){
                $tmp = [
                    'url' => $value['file'],
                    'name' => $value['name'],
                ];
                $customer['file'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_seven){
                $tmp = [
                    'id' => $value['data_id'],
                    'name' => $depart_map[$value['data_id']],
                ];
                $customer['depart'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_eight){
                $tmp = [
                    'id' => $value['data_id'],
                    'name' => $emp_map[$value['data_id']] ?? '',
                ];
                $customer['employee'][] = $tmp;
            }
        }
        $customer['crt_name'] = $emp_map[$customer['crt_id']] ?? '';
        $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';

        return [true, $customer];
    }

    /**
     * 客户列表
     * @param $data
     * @param $user
     * @return array
     */
    public function customerList($data,$user){
        $model = new Customer(['userData' => $user,'search'=> $data]);
        $model = $model->where('del_time',0)
            ->select('title','id','model_type','customer_intention','customer_from','customer_type','car_type','consulting_product','intention_product','progress_stage','address1','address2','crt_id','crt_time','mark','importance','company','company_short_name','depart_id','state_type','customer_state','customer_grade','pond_state')
            ->orderby('id', 'desc');

        if(empty($data['pond_state'])) { // 未进入公海池的
            //getALL传入后无视设置范围
            if(empty($data['getAll']) && $user['id'] != Employee::SPECIAL_ADMIN) {
                $user_id = $user['id'];
                $depart_id = $user['depart_range'];
                $type = implode(',',CustomerInfo::$man);
                $type2 = CustomerInfo::type_eight;
                $depart_str = implode(',',$depart_id);
                $str = "(data_id = $user_id AND type IN({$type})) OR (data_id IN({$depart_str}) AND type = {$type2})";

                // 销售人员/负责人 3协同人  可见部门 可见人 可以看见
                $customer_id = CustomerInfo::where('del_time',0)
                    ->where(function ($query) use($str) {
                        $query->whereRaw($str);
                    })->select('customer_id')->get()->toArray();
                $emp_id = array_unique(array_column($customer_id,'customer_id'));
                $model->whereIn('id', $emp_id);
            }
        }else{
            $model->where('pond_state', '>',0);
        }
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['time_type'])) {
            if($data['time_type'] == 1) {
                $start = strtotime('today');
                $end = strtotime('tomorrow') - 1;
            }elseif ($data['time_type'] == 2){
                $start = strtotime('this week',strtotime('today'));
                $end = strtotime('this week +6 days 23:59:59', strtotime('today'));
            }
            if(! empty($start) && ! empty($end)) {
                $model->where('crt_time','>=',$start);
                $model->where('crt_time','<=',$end);
            }
        }
        if(! empty($data['model_type'])) $model->where('model_type',$data['model_type']);

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

        return [true, $list];
    }

    /**
     * 客户参数规则
     * @param $data
     * @param $is_add
     * @return array
     */
    public function customerRule(&$data, $is_add = true){
        if(empty($data['model_type'])) return [false,'客户模板类型不能为空'];
        if(! in_array($data['model_type'],Customer::$model_type)) return [false,'客户模板类型错误'];
        if(empty($data['title'])) return [false,'客户名称不能为空'];
        if(! empty($data['depart_id'])) $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
        if($data['model_type'] == Customer::Model_type_one){
            if(empty($data['customer_from'])) return [false,'客户来源不能为空'];
            if(empty($data['customer_type'])) return [false,'客户类别不能为空'];
            if(empty($data['consulting_product'])) return [false,'咨询产品不能为空'];
            if(empty($data['progress_stage'])) return [false,'进展阶段不能为空'];
            if(empty($data['employee_one'])) return [false,'销售SA不能为空'];
        }else{
            if(empty($data['car_type'])) return [false,'车型不能为空'];
            if(empty($data['customer_contact'])) return [false,'客户联系方式不能为空'];
        }

        if($is_add){
            $bool = Customer::where('del_time',0)
                ->where('title',$data['title'])
                ->where('model_type',$data['model_type'])
                ->exists();
        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $bool = Customer::where('del_time',0)
                ->where('id','<>',$data['id'])
                ->where('title',$data['title'])
                ->where('model_type',$data['model_type'])
                ->exists();
        }
        if($bool) return [false,'客户名称不能重复'];

        return [true, ''];
    }

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

        $array = array_unique(array_merge_recursive(array_column($data['data'],'customer_intention'),array_column($data['data'],'customer_from'),array_column($data['data'],'customer_type'),array_column($data['data'],'car_type'),array_column($data['data'],'progress_stage'),array_column($data['data'],'state_type'),array_column($data['data'],'customer_state'),array_column($data['data'],'customer_grade')));
        $basic_map = BasicType::whereIn('id',$array)
            ->pluck('title','id')
            ->toArray();
        $depart_title = Depart::where('id',array_unique(array_column($data['data'],'depart_id')))
            ->pluck('title','id')
            ->toArray();
        $emp = Employee::whereIn('id',array_unique(array_column($data['data'],'crt_id')))
            ->pluck('emp_name','id')
            ->toArray();
        $product = Product::whereIn('id',array_unique(array_column($data['data'],'intention_product')))
            ->pluck('title','id')
            ->toArray();

        foreach ($data['data'] as $key => $value){
            $address = '';
            if(! empty($value['address1'])) {
                $tmp = json_decode($value['address1'],true);
                $tmp = implode(' ',$tmp);
                $tmp .= ' ' . $value['address2'];
                $address = $tmp;
            }
            $data['data'][$key]['address'] = $address;
            $data['data'][$key]['customer_intention_title'] = $basic_map[$value['customer_intention']] ?? '';
            $data['data'][$key]['customer_from_title'] = $basic_map[$value['customer_from']] ?? '';
            $data['data'][$key]['customer_type_title'] = $basic_map[$value['customer_type']] ?? '';
            $data['data'][$key]['car_type_title'] = $basic_map[$value['car_type']] ?? '';
            $data['data'][$key]['intention_product_title'] = $product[$value['intention_product']] ?? '';
            $data['data'][$key]['progress_stage_title'] = $basic_map[$value['progress_stage']] ?? '';
            $data['data'][$key]['state_type_title'] = $basic_map[$value['state_type']] ?? '';
            $data['data'][$key]['customer_state_title'] = $basic_map[$value['customer_state']] ?? '';
            $data['data'][$key]['customer_grade_title'] = $basic_map[$value['customer_grade']] ?? '';
            $data['data'][$key]['depart_title'] = $depart_title[$value['depart_id']] ?? '';
            $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']] ?? '';
        }

        return $data;
    }

    //抢客户
    public function customerGrabbing($data, $user){
        $key = Customer::$limitKey . $data['customer_id'];
        list($status,$msg) = $this->customerGrabbingRule($data,$key);
        if(! $status) return [false,$msg];

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

            //销售/负责/协同人清空
            CustomerInfo::where('del_time',0)
                ->where('customer_id',$data['customer_id'])
                ->whereIn('type', CustomerInfo::$man2)
                ->update(['del_time' => $time]);
            //增加自己为负责人
            $insert[] = [
                'customer_id' => $data['customer_id'],
                'data_id' => $user['id'],
                'type' => CustomerInfo::type_two,
                'crt_time' => $time
            ];
            CustomerInfo::insert($insert);
            Customer::where('id',$data['customer_id'])->update([
                'pond_state' => 0
            ]);

            DB::commit();
        }catch (\Exception $exception){
            //释放锁
            $this->dellimitingSendRequestBackg($key);

            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        //释放锁
        $this->dellimitingSendRequestBackg($key);

        return [true, ''];
    }

    public function customerGrabbingRule($data, $key){
        if(empty($data['customer_id'])) return [false,'请选择客户'];
        //上锁
        list($status,$msg) = $this->limitingSendRequestBackg($key);
        if(! $status) return [false,$msg];

        $customer = Customer::where('del_time',0)->where('id',$data['customer_id'])->first();
        if(empty($customer)) return [false,'客户不存在或已被删除'];
        $customer = $customer->toArray();
        if(empty($customer['pond_state'])) return [false,'客户已退出公海池'];

        return [true,''];
    }
}