crm_hdl/application/admin/model/RankingModel.php

<?php
namespace app\admin\model;
use think\Model;
use think\Db;

class RankingModel extends Model
{
    protected $name = 'ranking';
    protected $autoWriteTimestamp = false;   // 开启自动写入时间戳

    /**
     * 设置记录表已回复
     */
    public function set_huifu($id)
    {

        $customer = CustomerModel::where('id',$id)->find(); // 查出用户信息
        $all_company = CustomerModel::where('company',$customer['company'])->select()->toArray();
        foreach ($all_company  as $k=>$v) {
//            $rank = $this->where('c_id',$all_company[$k]['id'])->where('admin_id',$all_company[$k]['spread_id'])->find();
            $rank = $this->where('c_id',$all_company[$k]['id'])->find();
            if ($rank) {
                if ($rank['admin_id'] != $all_company[$k]['spread_id']) {
                    Db::name('ranking')->where('id',$rank['id'])->update(['status' => 0]);
                    Db::name('ranking')->insert(['c_id' => $v['id'], 'admin_id' => $v['spread_id'],'create_time'=>time(),'type' => 1]);
                }
                else{
                    $this->where('id',$rank['id'])->update(['type' => 1,'create_time' => time()]);
                }
            } else {
                Db::name('ranking')->insert(['c_id' => $v['id'], 'admin_id' => $v['spread_id'],'create_time'=>time(),'type' => 1]);
            }
        }
        // 除此客户外查出相同邮箱的客户
        $email = CustomerModel::where('email',$customer['email'])->where('id','neq',$customer['id'])->where('status',0)->select();
        if ($email) {
            foreach ($email as &$v) {
                Db::name('customer')->where('id',$v['id'])->update(['status' => 3]);
                Db::name('admin')->where('id',$v['spread_id'])->setInc('lingzou_count',1);
            }
        }
    }
    /**
     * 设置记录表已成交
     */
    public function set_chengjiao($id)
    {
        $customer = CustomerModel::where('id',$id)->find(); // 查出用户信息
        $all_company = CustomerModel::where('company',$customer['company'])->select()->toArray();
        foreach ($all_company  as $k=>$v) {
            $rank = $this->where('c_id',$all_company[$k]['id'])->find();
            if ($rank) {
                if ($rank['admin_id'] != $all_company[$k]['spread_id']) {
                    Db::name('ranking')->where('id',$rank['id'])->update(['status' => 0]);
                    Db::name('ranking')->insert(['c_id' => $v['id'], 'admin_id' => $v['spread_id'],'create_time'=>time(),'type' => 2]);
                }
                else{
                    $this->where('id',$rank['id'])->update(['type' => 2,'create_time' => time()]);
                }
            } else {
                Db::name('ranking')->insert(['c_id' => $v['id'], 'admin_id' => $v['spread_id'],'create_time'=>time(),'type' => 2]);
            }
            // 除此客户外查出相同邮箱的客户
            $email = CustomerModel::where('email',$customer['email'])->where('id','neq',$customer['id'])->where('status',0)->select();
            if ($email) {
                foreach ($email as &$v) {
                    // 设置被领走
                    Db::name('customer')->where('id',$v['id'])->update(['status' => 3]);
                    Db::name('admin')->where('id',$v['spread_id'])->setInc('lingzou_count',1);
                }
            }
        }
    }
    /**
     * 设置记录表已关联
     */
    public function setGuanlian($id)
    {
        $customer = CustomerModel::where('id',$id)->find(); // 查出用户信息
        $all_company = CustomerModel::where('company',$customer['company'])->select()->toArray();
        foreach ($all_company  as $k=>$v) {
            $rank = $this->where('c_id',$all_company[$k]['id'])->find();
            if ($rank) {
                if ($rank['admin_id'] != $all_company[$k]['spread_id']) {
                    Db::name('ranking')->where('id',$rank['id'])->update(['status' => 0]);
                    Db::name('ranking')->insert(['c_id' => $v['id'], 'admin_id' => $v['spread_id'],'create_time'=>time(),'type' => 3]);
                }
                else{
                    $this->where('id',$rank['id'])->update(['type' => 3,'create_time' => time()]);
                }
            } else {
                Db::name('ranking')->insert(['c_id' => $v['id'], 'admin_id' => $v['spread_id'],'create_time'=>time(),'type' => 3]);
            }
            // 除此客户外查出相同邮箱的客户
            $email = CustomerModel::where('email',$customer['email'])->where('id','neq',$customer['id'])->where('status',0)->select();
            if ($email) {
                foreach ($email as &$v) {
                    // 设置被领走
                    Db::name('customer')->where('id',$v['id'])->update(['status' => 3]);
                    Db::name('admin')->where('id',$v['spread_id'])->setInc('lingzou_count',1);
                }
            }
        }
    }
    /**
     * 添加新建记录
     */
    public function new_customer($c_id,$admin_id)
    {
        $data = [
            'c_id' => $c_id,
            'admin_id' => $admin_id,
            'create_time' => time(),
            'type' => 0,
        ];
        $this->save($data);
    }
    /**
     * 放弃客户后设置记录为失效
     */
    public function giveup($ids,$admin_id)
    {
        $this->where('c_id','in',$ids)->where('admin_id',$admin_id)->update(['status'=>0]);
    }
}