crm_hdl/application/admin/model/CustomerModel.php

<?php
namespace app\admin\model;

use think\Db;
use think\Model;

class CustomerModel extends Model
{
    protected $name = 'customer';

    /**
     * 销售总后台 获取 客户信息
     */
    public function getCustomersByWhere($map,$od, $Nowpage, $limits,$whereOr = [])
    {
        $res =  $this->alias ('a')
            ->join('admin ad', 'ad.id = a.spread_id','left')
            ->join('type t','t.id = a.type','left')
            ->field('a.*, ad.username username,ad.nickname nickname,t.name type_name')
            ->where($map)
            ->where(function ($query) use($whereOr) {
                foreach ($whereOr as $k => $v) {
                    $query->whereOr($whereOr[$k][0],$whereOr[$k][1],$whereOr[$k][2]);
                }
            })
            ->page($Nowpage, $limits)
            ->order($od)
            ->select();
        return $res;
    }
    /**
     * 客户总后台 获取 客户信息
     */
    public function getCustomerssByWhere($map,$od, $Nowpage, $limits,$whereOr = [])
    {
        $res =  $this->alias ('a')
            ->where($map)
            ->where(function ($query) use($whereOr) {
                foreach ($whereOr as $k => $v) {
                    $query->whereOr($whereOr[$k][0],$whereOr[$k][1],$whereOr[$k][2]);
                }
            })
            ->page($Nowpage, $limits)
            ->order($od)
            ->select();
        return $res;
    }
    /*
     * 销售后台总页面数
     */
    public function getCustomerCount($map,$wherOr=[]){
//        return $this->alias('a')
////            ->join('auth_group ag', 'a.groupid = ag.id','left')
//            ->where($map)
//            ->count();
        $count =  $this->alias('a')
            ->where($map)
            ->where(function ($query) use ($wherOr){
                foreach ($wherOr as $k => $v) {
                    $query->whereOr($wherOr[$k][0],$wherOr[$k][1],$wherOr[$k][2]);
                }
            })
            ->select();
        return count($count);
    }
    /*
     * 销售后台总页面数
     */
    public function getCustomerCounts($map,$wherOr = []){
        $count =  $this->alias('a')
            ->where($map)
            ->where(function ($query) use ($wherOr){
                foreach ($wherOr as $k => $v) {
                    $query->whereOr($wherOr[$k][0],$wherOr[$k][1],$wherOr[$k][2]);
                }
            })
            ->select();
        return count($count);
    }
    /**
     * 未建交添加
     */
    public function add_customer($data)
    {
        // 检测用户是否存在
         $where = [
//             'name' => $data['name'],
             'email' => $data['email'],
             'company' => $data['company'],
//             'country' => $data['country'],
             'website' => $data['website'],
             'phone' => $data['phone'],
         ];
         $checkEmail = $this->where('email',$data['email'])->where('spread_id',session('uid'))->find();
         if ($checkEmail) return json(['cdoe' => 100, 'msg' => '你已创建过此邮箱的客户了']);
         $isset = $this->where($where)->find();
         if ($isset) return json(['cdoe' => 100, 'msg' => '此客户已存在']);
         $data['type'] = ','.$data['type'].',';
         $data['product'] = ','.$data['product'].',';
         $add = $this->save($data);
         if ($add) {
             $rankingmodel = new RankingModel();
             $rankingmodel->new_customer($this->id,$data['spread_id']);
             self::people_set($data['name'],$data['email']);
             return json(['code' => 200,'msg' => '添加成功']);
         } else {
             return json(['code' => 100,'msg' => '添加失败']);
         }
    }
    /**
     * 检测邮箱
     */
    public function checkEmail($email)
    {
        $res = $this->where('email',$email)->where('status','in','1,2,3')->find();
        if ($res) {
            return json(['code' => 100, 'msg' => '此邮箱客户被领走']);
        } else {
            return json(['code' => 200,'msg' => '']);
        }
    }
    /**
     * 批量导入检测邮箱
     */
    public function checkEmails($email)
    {
        return  $this->where('email',$email)->where('status','in','1,2,3')->find();
    }
    /**
     * 建档人数检测
     */
    public function people_set($username , $eamil)
    {
        $peoples = $this->where('email',$eamil)->column('id');
        if ($peoples) {
            $time = time();
            $num = count($peoples);
//            foreach ($peoples as &$v) {
                $this->save(['other_follow_time' => $time, 'people' => $num],['id' => ['in',$peoples]]);
//            }
        }
    }
    /**
     * 查看客户信息
     */
    public function see($id)
    {
        $data = $this->alias('c')
            ->join('countries t','t.id=c.country','left')
            ->where('c.id',$id)
            ->field('c.*,t.country c_name')
            ->find()
            ->toArray();
        return $data;

    }
    /**
     * 批量导入储存所有数据并且处理建档人数
     */
    public function add_all($data)
    {

        foreach ($data as &$v)
        {
            Db::name('customer')->insert($v);
            $v['type'] = ','.$v['type'].',';
            $v['product'] = ','.$v['product'].',';
            $id = $this->getLastInsID();
            $ranhdata[] = [
                'c_id' => $id,
                'admin_id' => session('uid'),
                'create_time' => time(),
                'type' => 0,
            ];
            // 查出所有对此用户建档的id
            $jiandang = Db::name('customer')->where('email',$v['email'])->column('id');
            $num = count($jiandang);
            $ids = implode(',',$jiandang);
            $this->where('id','in',$ids)->update([
                'other_follow_time' => time(),
                'other_follow_num' => $num,
            ]);
            // 建档人数id
            $ids = Db::name('customer')->whereOr('name',$v['name'])->whereOr('email',$v['email'])->column('id');
            $count = count($ids);
            // 更新建档人数
            $ids_str = implode(',',$ids);
            Db::name('customer')->where('id','in',$ids)->update(['people' => $count]);
        }
        Db::name('ranking')->insertAll($ranhdata);
    }
    /***
     * 操作员修改数据写入日志
     */
    public function caozuo_update($param)
    {
        $status = 100;
        $msg = '修改失败！';
        $customer = $this->where('id',$param['id'])->find()->toArray();
        if (isset($param['name'])){
            $upd_name = $this->where('id',$param['id'])->update(['name' => $param['name']]);
            if ($upd_name) {
                writelog('操作员'.session('nickname').'修改客户'.$customer['name'].'的用户名为'.$param['name'],200);
                $status = 200;
                $msg = '修改成功!';
            }
        }
        if (isset($param['email'])){
            $upd_email = $this->where('id',$param['id'])->update(['email' => $param['email']]);
            if ($upd_email) {
                writelog('操作员'.session('nickname').'修改客户'.$customer['name'].'的邮箱为'.$param['email'],200);
                $status = 200;
                $msg = '修改成功!';
            }
        }
        if (isset($param['company'])){
            $upd_company = $this->where('id',$param['id'])->update(['company' => $param['company']]);
            if ($upd_company) {
                writelog('操作员'.session('nickname').'修改客户'.$customer['name'].'的公司为'.$param['company'],200);
                $status = 200;
                $msg = '修改成功!';
            }
        }
        if (isset($param['website'])){
            $upd_website = $this->where('id',$param['id'])->update(['website' => $param['website']]);
            if ($upd_website) {
                writelog('操作员'.session('nickname').'修改客户'.$customer['name'].'的网站为'.$param['website'],200);
                $status = 200;
                $msg = '修改成功!';
            }
        }
        if (isset($param['phone'])){
            $upd_phone = $this->where('id',$param['id'])->update(['phone' => $param['phone']]);
            if ($upd_phone) {
                writelog('操作员'.session('nickname').'修改客户'.$customer['name'].'的电话为'.$param['phone'],200);
                $status = 200;
                $msg = '修改成功!';
            }
        }
        return json(['code' => $status,'msg'=>$msg]);
    }
    /**
     * 邮件发送成功更新各种跟进状态
     */
    public function upd_follow($email,$id)
    {
        $customer = $this->where('id',$id)->find();
        $customerEmail = $this->where('email',$email)->where('id','neq',$id)->select()->toArray();
        if ($customer) {
            $this->where('id',$id)->update(['shang_follow_time' => $customer['follow_time'] , 'follow_time' => time()]);
            Db::name('customer')->where('id',$id)->setInc('follow_num',1);
        }
        if ($customerEmail) {
            foreach ($customerEmail as &$v) {
                Db::name('customer')->where('id',$v['id'])->update(['shang_other_follow_time' => $customer['other_follow_time'] , 'other_follow_time' => time()]);
                Db::name('customer')->where('id',$v['id'])->setInc('other_follow_num',1);
            }
        }
    }
    /**
     * 状态获取器
     */
    public function getStatusAttr($value)
    {
        $arr = ['0'=>'未联系',1=>'已联系',2=>'已成交',3=>'关联中'];
        return $arr[$value];
    }

    /**
     * @param $value
     * @return false|string
     * 时间获取器
     */
    public function getFollowTimeAttr($value)
    {
        return $value = date('Y-m-d H:i',$value);
    }
    /**
     * @param $value
     * @return false|string
     * 时间获取器
     */
    public function getOtherFollowTimeAttr($value)
    {
        return $value = date('Y-m-d H:i',$value);
    }
}