qyadmin/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\FollowUpRecord;
use App\Model\Product;
use App\Model\SeeRange;
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,$user, false);
        if(!$status) return [$status,$msg];

        $params = $this->getDataFile($data);
        (new OperationLogService())->setOperationList($params,$user,2);

        try {
            DB::beginTransaction();

            $model = Customer::where('id',$data['id'])->first();
            $model->title = $data['title'] ?? "";
            $model->relationship_level = $data['relationship_level'] ?? 0;
            $model->is_company = $data['is_company'] ?? 0;
            $model->address1 = ! empty($data['address1']) ? json_encode($data['address1']) : '';
            $model->address2 = $data['address2'] ?? '';
            $model->mark = $data['mark'] ?? '';
            $model->intention = $data['intention'] ?? '';
            $model->customer_type = $data['customer_type'] ?? '';
            $model->save();
            $time = time();

            $old = CustomerInfo::where('del_time',0)
                ->where('customer_id',$data['id'])
                ->whereIn('type',[CustomerInfo::type_five,CustomerInfo::type_six])
                ->select('file')
                ->get()->toArray();
            $old = array_column($old,'file');
            CustomerInfo::where('del_time',0)
                ->where('customer_id',$data['id'])
                ->where('type','<>',CustomerInfo::type_two)
                ->update(['del_time' => $time]);

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

            $new = [];
            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,
                    ];
                    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'];
                    }
                }
                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,
                    ];
                    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'];
                    }
                }
                CustomerInfo::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 customerAdd($data,$user){
        list($status,$msg) = $this->customerRule($data, $user);
        if(! $status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $model = new Customer();
            $model->order_number = $data['order_number'];
            $model->title = $data['title'] ?? "";
            $model->relationship_level = $data['relationship_level'] ?? 0;
            $model->is_company = $data['is_company'] ?? 0;
            $model->address1 = ! empty($data['address1']) ? json_encode($data['address1']) : '';
            $model->address2 = $data['address2'] ?? '';
            $model->mark = $data['mark'] ?? '';
            $model->intention = $data['intention'] ?? '';
            $model->customer_type = $data['customer_type'] ?? '';
            $model->crt_id = $user['id'];
            $model->save();
            $time = time();

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

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

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

        (new OperationLogService())->setOperationList($data,$user);

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

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

        if($data['id'] < 0) return [false, '系统数据，操作失败！'];
        try {
            DB::beginTransaction();

            Customer::where('id',$data['id'])->update([
                'del_time'=> time()
            ]);
            $old = CustomerInfo::where('del_time',0)
                ->where('customer_id',$data['id'])
                ->whereIn('type',[CustomerInfo::type_five,CustomerInfo::type_six])
                ->select('file')
                ->get()->toArray();
            $old = array_column($old,'file');

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

    /**
     * 客户详情
     * @param $data
     * @return array
     */
    public function customerDetail($data,$user){
        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();

        //地址
        $address_map = config('address');
        $address_str = [];
        if(! empty($customer['address1'])) {
            $tmp = json_decode($customer['address1'],true);
            $this->findLabelsByValue($address_map,$tmp,$address_str);
            $customer['address1'] = $tmp;
            $tmp = implode(' ',$address_str);
            $tmp .= ' ' . $customer['address2'];
            $address = $tmp;
        }else{
            $address = $customer['address2'];
        }
        $customer['address'] = $address;
        $customer['customer_contact'] = $customer['img'] = $customer['file'] = [];

        //详情
        $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'];

        $emp_map = Employee::whereIn('id',array_unique($emp_id))
            ->pluck('emp_name','id')
            ->toArray();

        $fileUploadService = new FileUploadService();
        foreach ($customer_info as $value){
            if($value['type'] == CustomerInfo::type_one){
                $tmp = [
                    'id' => $value['contact_type'],
                    'type' => $value['contact_type'],
                    'info' => $value['contact_info']
                ];
                $customer['customer_contact'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_five){
                $tmp = [
                    'url' => $value['file'],
                    'name' => $value['name'],
                    'show_url' => $fileUploadService->getFileShow($value['file']),
                ];
                $customer['img'][] = $tmp;
            }elseif ($value['type'] == CustomerInfo::type_six){
                $tmp = [
                    'url' => $value['file'],
                    'name' => $value['name'],
                    'show_url' => $fileUploadService->getFileShow($value['file']),
                ];
                $customer['file'][] = $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 = Customer::where('del_time',0)
            ->select('title','id','order_number','intention','customer_type','address1','address2','crt_id','crt_time','mark','relationship_level','is_company')
            ->orderby('id', 'desc');

        if(! empty($data['id'])) $model->where('id', $data['id']);
        if(isset($data['relationship_level'])) $model->where('relationship_level', $data['relationship_level']);
        if(isset($data['is_company'])) $model->where('is_company', $data['is_company']);
        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['mark'])) $model->where('mark','LIKE', '%'.$data['mark'].'%');
        if(! empty($data['intention'])) $model->where('intention',$data['intention']);
        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['contact_info'])){
            $customer_info = CustomerInfo::where('del_time',0)
                ->where("type",CustomerInfo::type_one)
                ->where('contact_info','LIKE', '%'.$data['contact_info'].'%')
                ->select('customer_id')
                ->get()->toArray();
            $model->whereIn('id',array_column($customer_info,'customer_id'));
        }

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

        return [true, $list];
    }

    /**
     * 客户参数规则
     * @param $data
     * @param $is_add
     * @return array
     */
    public function customerRule(&$data, $user, $is_add = true){
        if(empty($data['title'])) return [false,'客户名称不能为空'];

        if($is_add){
            $data['order_number'] = (new OrderNoService())->createOrderNumber(Customer::$prefix);
            $bool = Customer::where('del_time',0)
                ->where('title',$data['title'])
                ->exists();
            if(! empty($data['customer_contact'])) {
                $search = [];
                foreach ($data['customer_contact'] as $value){
                    $search[] = $value['info'];
                }
                $boolean = CustomerInfo::from('customer_info as a')
                    ->join('customer as b','b.id','a.customer_id')
                    ->where('a.del_time',0)
                    ->where('b.del_time',0)
                    ->whereIn('a.contact_info', $search)
                    ->exists();
                if($boolean) return [false,'客户联系内容已存在'];
            }
        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $bool = Customer::where('del_time',0)
                ->where('id','<>',$data['id'])
                ->where('title',$data['title'])
                ->exists();

            if(! empty($data['customer_contact'])) {
                $search = [];
                foreach ($data['customer_contact'] as $value){
                    $search[] = $value['info'];
                }
                $boolean = CustomerInfo::from('customer_info as a')
                    ->join('customer as b','b.id','a.customer_id')
                    ->where('b.id','<>',$data['id'])
                    ->where('a.del_time',0)
                    ->where('b.del_time',0)
                    ->whereIn('a.contact_info', $search)
                    ->exists();
                if($boolean) return [false,'客户联系内容已存在'];
            }
        }
        if($bool) return [false,'客户名称不能重复'];

        return [true, ''];
    }

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

        $emp = Employee::whereIn('id',array_unique(array_column($data['data'],'crt_id')))
            ->pluck('emp_name','id')
            ->toArray();

        //跟进记录
        $record_array = (new FollowUpRecordService())->getVisitDataOfTime(array_column($data['data'],'id'), FollowUpRecord::type_one);

        $customer_info = CustomerInfo::where('del_time',0)
            ->whereIn('customer_id',array_column($data['data'],'id'))
            ->whereIn('type',[CustomerInfo::type_one])
            ->select('type','contact_type','contact_info','customer_id','data_id')
            ->get()->toArray();

        //客户的联系方式
        $customer_info_map = [];
        foreach ($customer_info as $value){
            $customer_info_map[$value['customer_id']][] = $value;
        }

        $address_map = config('address');
        foreach ($data['data'] as $key => $value){
            $address_str = [];
            if(! empty($value['address1'])) {
                $tmp = json_decode($value['address1'],true);
                $this->findLabelsByValue($address_map,$tmp,$address_str);
                $tmp = implode(' ',$address_str);
                $tmp .= ' ' . $value['address2'];
                $address = $tmp;
            }else{
                $address = $value['address2'];
            }
            $data['data'][$key]['address'] = $address;
            $data['data'][$key]['is_company_title'] = $value['customer_intention'] ? '是' : '否';
            $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']] ?? '';
            $record_tmp = $record_array[$value['id']] ?? "";
            $data['data'][$key]['has_record'] = $record_tmp ? "查看" : "无记录";
            $data['data'][$key]['follow_record'] = $record_array[$value['id']] ?? "";
            $customer_tmp = $customer_info_map[$value['id']] ?? [];
            $data['data'][$key]['customer_detail'] = $customer_tmp;
        }

        return $data;
    }
}