599 lines
20 KiB
PHP
599 lines
20 KiB
PHP
<?php
|
|
/**
|
|
* @copyright Copyright (c) 2021 勾股工作室
|
|
* @license https://opensource.org/licenses/GPL-3.0
|
|
* @link https://www.gougucms.com
|
|
*/
|
|
|
|
declare (strict_types = 1);
|
|
|
|
namespace app\customer\controller;
|
|
|
|
use app\base\BaseController;
|
|
use app\customer\model\Customer as CustomerList;
|
|
use app\customer\validate\CustomerCheck;
|
|
use think\exception\ValidateException;
|
|
use think\facade\Db;
|
|
use think\facade\View;
|
|
|
|
class Index extends BaseController
|
|
{
|
|
public function index()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$param = get_params();
|
|
$tab = isset($param['tab']) ? $param['tab'] : 0;
|
|
$where = array();
|
|
$whereOr = array();
|
|
if (!empty($param['keywords'])) {
|
|
$where[] = ['a.id|a.name|cc.name|cc.mobile', 'like', '%' . $param['keywords'] . '%'];
|
|
}
|
|
if (!empty($param['status'])) {
|
|
$where[] = ['a.status', '=', $param['status']];
|
|
}
|
|
if (!empty($param['grade_id'])) {
|
|
$where[] = ['a.grade_id', '=', $param['grade_id']];
|
|
}
|
|
if (!empty($param['source_id'])) {
|
|
$where[] = ['a.source_id', '=', $param['source_id']];
|
|
}
|
|
if (!empty($param['type'])) {
|
|
$where[] = ['a.intent_status', '=', $param['type']];
|
|
}
|
|
if (!empty($param['follow_time'])) {
|
|
$follow_time =explode('~', $param['follow_time']);
|
|
$where[] = ['ct.follow_time', 'between', [strtotime(urldecode($follow_time[0])),strtotime(urldecode($follow_time[1]))]];
|
|
}
|
|
if (!empty($param['next_time'])) {
|
|
$next_time =explode('~', $param['next_time']);
|
|
$where[] = ['ct.next_time', 'between', [strtotime(urldecode($next_time[0])),strtotime(urldecode($next_time[1]))]];
|
|
}
|
|
|
|
$where[] = ['a.delete_time', '=', 0];
|
|
|
|
$uid = $this->uid;
|
|
$auth = isAuth($uid,'customer_admin');
|
|
if (!empty($param['uid']) && $auth == 1) {
|
|
$where[] =['a.belong_uid', '=', $param['uid']];
|
|
}
|
|
else{
|
|
$dids = get_department_role($uid);
|
|
if($auth == 0){
|
|
if($tab == 1){
|
|
$whereOr[] =['a.belong_uid', '=', $uid];
|
|
}
|
|
else if($tab == 2){
|
|
if(!empty($dids)){
|
|
$whereOr[] =['a.belong_did', 'in', $dids];
|
|
}
|
|
else{
|
|
$whereOr[] =['a.belong_did', '=', 0];
|
|
$where[] =['a.belong_uid', '>', 0];
|
|
}
|
|
}
|
|
else if($tab == 3){
|
|
$whereOr[] = ['', 'exp', Db::raw("FIND_IN_SET('{$uid}',a.share_ids)")];
|
|
}
|
|
else{
|
|
$whereOr[] =['a.belong_uid', '=', $uid];
|
|
if(!empty($dids)){
|
|
$whereOr[] =['a.belong_did', 'in', $dids];
|
|
}
|
|
$whereOr[] = ['', 'exp', Db::raw("FIND_IN_SET('{$uid}',a.share_ids)")];
|
|
}
|
|
}
|
|
else if($auth ==1 ){
|
|
if($tab == 1){
|
|
$whereOr[] =['a.belong_uid', '=', $uid];
|
|
}
|
|
else if($tab == 2){
|
|
if(!empty($dids)){
|
|
$whereOr[] =['a.belong_did', 'in', $dids];
|
|
}
|
|
else{
|
|
$whereOr[] =['a.belong_did', '=', 0];
|
|
$where[] =['a.belong_uid', '>', 0];
|
|
}
|
|
}
|
|
else if($tab == 3){
|
|
$whereOr[] = ['', 'exp', Db::raw("FIND_IN_SET('{$uid}',a.share_ids)")];
|
|
}
|
|
else{
|
|
$whereOr[] =['a.belong_uid', '>', 0];
|
|
}
|
|
}
|
|
}
|
|
$cc_sql= Db::name('CustomerContact')->group('cid,name,mobile,qq,wechat,email')->field('cid,name,mobile,qq,wechat,email')->buildSql();
|
|
$ct_sql= Db::name('CustomerTrace')->group('cid')->field('cid,MAX(follow_time) AS follow_time,MAX(next_time) AS next_time')->buildSql();
|
|
$orderby = 'ct.next_time desc,a.create_time desc';
|
|
if(isset($param['orderby'])){
|
|
$orderby = 'ct.'.$param['orderby'];
|
|
}
|
|
$rows = empty($param['limit']) ? get_config('app.page_size') : $param['limit'];
|
|
$content = CustomerList::where($where)
|
|
->where(function ($query) use($whereOr) {
|
|
$query->whereOr($whereOr);
|
|
})
|
|
->field('a.*,d.title as belong_department,g.title as grade,s.title as source,i.title as industry,ct.follow_time,ct.next_time')
|
|
->alias('a')
|
|
->join('customer_source s', 'a.source_id = s.id')
|
|
->join('customer_grade g', 'a.grade_id = g.id')
|
|
->join('industry i', 'a.industry_id = i.id')
|
|
->join('department d', 'a.belong_did = d.id')
|
|
->join($ct_sql.' ct', 'ct.cid = a.id','left')
|
|
->join($cc_sql.' cc', 'a.id = cc.cid','left')
|
|
->group('a.id')
|
|
->order($orderby)
|
|
->paginate($rows, false, ['query' => $param])
|
|
->each(function ($item, $key) {
|
|
$item->belong_name = Db::name('Admin')->where(['id' => $item->belong_uid])->value('name');
|
|
$item->create_time = date('Y-m-d H:i', $item->create_time);
|
|
if($item->update_time == 0){
|
|
$item->update_time='-';
|
|
}
|
|
else{
|
|
$item->update_time = date('Y-m-d H:i', $item->update_time);
|
|
}
|
|
$item->intent_status_name = CustomerList::$IntentStatus[(int) $item->intent_status];
|
|
$item->status_name = CustomerList::$Status[(int) $item->status];
|
|
$contact = Db::name('CustomerContact')->where(['is_default'=>1,'cid' => $item->id])->find();
|
|
if(!empty($contact)){
|
|
$item->user = $contact['name'];
|
|
$item->mobile = $contact['mobile'];
|
|
$item->qq = $contact['qq'];
|
|
$item->wechat = $contact['wechat'];
|
|
}
|
|
|
|
if($item->services_id == 0){
|
|
$item->services_name = '-';
|
|
}
|
|
else{
|
|
$item->services_name = Db::name('Services')->where(['id' => $item->services_id])->value('title');
|
|
}
|
|
|
|
if(empty($item->follow_time)){
|
|
$item->follow_time = '-';
|
|
}
|
|
else{
|
|
$item->follow_time = date('Y-m-d H:i:s', $item->follow_time);
|
|
}
|
|
if(empty($item->next_time)){
|
|
$item->next_time = '-';
|
|
}
|
|
else{
|
|
$item->next_time = date('Y-m-d H:i:s', $item->next_time);
|
|
}
|
|
});
|
|
return table_assign(0, '', $content);
|
|
} else {
|
|
$uid = $this->uid;
|
|
$auth = isAuth($uid,'customer_admin');
|
|
View::assign('auth', $auth);
|
|
return view();
|
|
}
|
|
}
|
|
|
|
//公海客户
|
|
public function sea()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$param = get_params();
|
|
$where = array();
|
|
if (!empty($param['keywords'])) {
|
|
$where[] = ['a.id|a.name', 'like', '%' . $param['keywords'] . '%'];
|
|
}
|
|
if (!empty($param['status'])) {
|
|
$where[] = ['a.status', '=', $param['status']];
|
|
}
|
|
if (!empty($param['industry_id'])) {
|
|
$where[] = ['a.industry_id', '=', $param['industry_id']];
|
|
}
|
|
if (!empty($param['source_id'])) {
|
|
$where[] = ['a.source_id', '=', $param['source_id']];
|
|
}
|
|
$where[] = ['a.delete_time', '=', 0];
|
|
$where[] = ['a.belong_uid', '=', 0];
|
|
|
|
$rows = empty($param['limit']) ? get_config('app.page_size') : $param['limit'];
|
|
$content = CustomerList::where($where)
|
|
->field('a.*,d.title as belong_department,g.title as grade,s.title as source,i.title as industry')
|
|
->alias('a')
|
|
->join('customer_source s', 'a.source_id = s.id')
|
|
->join('customer_grade g', 'a.grade_id = g.id')
|
|
->join('industry i', 'a.industry_id = i.id')
|
|
->join('department d', 'a.belong_did = d.id','LEFT')
|
|
->order('a.create_time desc')
|
|
->paginate($rows, false, ['query' => $param])
|
|
->each(function ($item, $key) {
|
|
$item->belong_name = Db::name('Admin')->where(['id' => $item->belong_uid])->value('name');
|
|
$item->create_time = date('Y-m-d H:i', $item->create_time);
|
|
if($item->update_time == 0){
|
|
$item->update_time='-';
|
|
}
|
|
else{
|
|
$item->update_time = date('Y-m-d H:i', $item->update_time);
|
|
}
|
|
$item->intent_status_name = CustomerList::$IntentStatus[(int) $item->intent_status];
|
|
$item->status_name = CustomerList::$Status[(int) $item->status];
|
|
$contact = Db::name('CustomerContact')->where(['is_default'=>1,'cid' => $item->id])->find();
|
|
if(!empty($contact)){
|
|
$item->user = $contact['name'];
|
|
$item->mobile = $contact['mobile'];
|
|
$item->qq = $contact['qq'];
|
|
$item->wechat = $contact['wechat'];
|
|
}
|
|
|
|
if($item->services_id == 0){
|
|
$item->services_name = '-';
|
|
}
|
|
else{
|
|
$item->services_name = Db::name('Services')->where(['id' => $item->services_id])->value('title');
|
|
}
|
|
});
|
|
return table_assign(0, '', $content);
|
|
} else {
|
|
return view();
|
|
}
|
|
}
|
|
|
|
//移入公海
|
|
public function to_sea()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$id = get_params("id");
|
|
$uid = $this->uid;
|
|
//是否有权限
|
|
$customer = customer_auth($uid,$id,1,1);
|
|
$data['id'] = $id;
|
|
$data['belong_uid'] = 0;
|
|
$data['belong_did'] = 0;
|
|
$data['belong_time'] = 0;
|
|
if (Db::name('Customer')->update($data) !== false) {
|
|
add_log('tosea', $id);
|
|
$log_data = array(
|
|
'field' => 'belong',
|
|
'action' => 'tosea',
|
|
'type' => 0,
|
|
'customer_id' => $data['id'],
|
|
'admin_id' => $this->uid,
|
|
'create_time' => time(),
|
|
);
|
|
Db::name('CustomerLog')->strict(false)->field(true)->insert($log_data);
|
|
return to_assign(0, "操作成功");
|
|
} else {
|
|
return to_assign(1, "操作失败");
|
|
}
|
|
} else {
|
|
return to_assign(1, "错误的请求");
|
|
}
|
|
}
|
|
|
|
//废池客户
|
|
public function trash()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$param = get_params();
|
|
$where = array();
|
|
if (!empty($param['keywords'])) {
|
|
$where[] = ['a.id|a.name|c.title', 'like', '%' . $param['keywords'] . '%'];
|
|
}
|
|
if (!empty($param['status'])) {
|
|
$where[] = ['a.status', '=', $param['status']];
|
|
}
|
|
$where[] = ['a.delete_time', '>', 0];
|
|
$where[] = ['a.belong_uid', '=', 0];
|
|
|
|
$rows = empty($param['limit']) ? get_config('app.page_size') : $param['limit'];
|
|
$content = CustomerList::where($where)
|
|
->field('a.*,d.title as belong_department,g.title as grade,s.title as source,i.title as industry')
|
|
->alias('a')
|
|
->join('customer_source s', 'a.source_id = s.id')
|
|
->join('customer_grade g', 'a.grade_id = g.id')
|
|
->join('industry i', 'a.industry_id = i.id')
|
|
->join('department d', 'a.belong_did = d.id','LEFT')
|
|
->order('a.create_time desc')
|
|
->paginate($rows, false, ['query' => $param])
|
|
->each(function ($item, $key) {
|
|
$item->belong_name = Db::name('Admin')->where(['id' => $item->belong_uid])->value('name');
|
|
$item->create_time = date('Y-m-d H:i', $item->create_time);
|
|
if($item->update_time == 0){
|
|
$item->update_time='-';
|
|
}
|
|
else{
|
|
$item->update_time = date('Y-m-d H:i', $item->update_time);
|
|
}
|
|
$item->intent_status_name = CustomerList::$IntentStatus[(int) $item->intent_status];
|
|
$item->status_name = CustomerList::$Status[(int) $item->status];
|
|
$contact = Db::name('CustomerContact')->where(['is_default'=>1,'cid' => $item->id])->find();
|
|
if(!empty($contact)){
|
|
$item->user = $contact['name'];
|
|
$item->mobile = $contact['mobile'];
|
|
$item->qq = $contact['qq'];
|
|
$item->wechat = $contact['wechat'];
|
|
}
|
|
|
|
if($item->services_id == 0){
|
|
$item->services_name = '-';
|
|
}
|
|
else{
|
|
$item->services_name = Db::name('Services')->where(['id' => $item->services_id])->value('title');
|
|
}
|
|
});
|
|
return table_assign(0, '', $content);
|
|
} else {
|
|
return view();
|
|
}
|
|
}
|
|
|
|
//抢客宝
|
|
public function rush()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$param = get_params();
|
|
$where = array();
|
|
$where[] = ['a.delete_time', '=', 0];
|
|
$where[] = ['a.belong_uid', '=', 0];
|
|
$content = CustomerList::where($where)
|
|
->field('a.*,d.title as belong_department,g.title as grade,s.title as source,i.title as industry')
|
|
->alias('a')
|
|
->join('customer_source s', 'a.source_id = s.id')
|
|
->join('customer_grade g', 'a.grade_id = g.id')
|
|
->join('industry i', 'a.industry_id = i.id')
|
|
->join('department d', 'a.belong_did = d.id','LEFT')
|
|
->orderRaw('rand()')
|
|
->limit(10)
|
|
->paginate()
|
|
->each(function ($item, $key) {
|
|
$item->create_time = date('Y-m-d H:i:s', (int) $item->create_time);
|
|
$contact = Db::name('CustomerContact')->where(['is_default'=>1,'cid' => $item->id])->find();
|
|
if(!empty($contact)){
|
|
$item->user = $contact['name'];
|
|
$item->mobile = $contact['mobile'];
|
|
$item->qq = $contact['qq'];
|
|
$item->wechat = $contact['wechat'];
|
|
}
|
|
if($item->services_id == 0){
|
|
$item->services_name = '-';
|
|
}
|
|
else{
|
|
$item->services_name = Db::name('Services')->where(['id' => $item->services_id])->value('title');
|
|
}
|
|
});
|
|
return table_assign(0, '', $content);
|
|
} else {
|
|
$time = strtotime(date('Y-m-d')." 00:00:00");
|
|
$max_num = Db::name('DataAuth')->where('name','customer_admin')->value('expected_1');
|
|
$count = Db::name('Customer')->where([['belong_time','>',$time],['belong_uid','=',$this->uid]])->count();
|
|
View::assign('max_num', $max_num);
|
|
View::assign('count', $count);
|
|
return view();
|
|
}
|
|
}
|
|
|
|
//添加&&编辑
|
|
public function add()
|
|
{
|
|
$param = get_params();
|
|
if (request()->isAjax()) {
|
|
if (!empty($param['id']) && $param['id'] > 0) {
|
|
try {
|
|
validate(CustomerCheck::class)->scene($param['scene'])->check($param);
|
|
} catch (ValidateException $e) {
|
|
// 验证失败 输出错误信息
|
|
return to_assign(1, $e->getError());
|
|
}
|
|
$customer = customer_auth($this->uid,$param['id'],1);
|
|
$param['update_time'] = time();
|
|
$res = customerList::strict(false)->field(true)->update($param);
|
|
if ($res) {
|
|
add_log('edit', $param['id'], $param);
|
|
to_log($this->uid,0,$param,$customer);
|
|
return to_assign();
|
|
} else {
|
|
return to_assign(1, '操作失败');
|
|
}
|
|
} else {
|
|
try {
|
|
validate(CustomerCheck::class)->scene('add')->check($param);
|
|
} catch (ValidateException $e) {
|
|
// 验证失败 输出错误信息
|
|
return to_assign(1, $e->getError());
|
|
}
|
|
$param['create_time'] = time();
|
|
$param['admin_id'] = $this->uid;
|
|
$cid = CustomerList::strict(false)->field(true)->insertGetId($param);
|
|
|
|
$contact = [
|
|
'name' => $param['c_name'],
|
|
'mobile' => $param['c_mobile'],
|
|
'sex' => $param['c_sex'],
|
|
'qq' => $param['c_qq'],
|
|
'wechat' => $param['c_wechat'],
|
|
'email' => $param['c_email'],
|
|
'cid' => $cid,
|
|
'is_default' => 1,
|
|
'create_time' => time(),
|
|
'admin_id' => $this->uid
|
|
];
|
|
Db::name('CustomerContact')->strict(false)->field(true)->insert($contact);
|
|
if ($cid) {
|
|
add_log('add', $cid, $param);
|
|
$log_data = array(
|
|
'field' => 'new',
|
|
'action' => 'add',
|
|
'type' => 0,
|
|
'customer_id' => $cid,
|
|
'admin_id' => $param['admin_id'],
|
|
'create_time' => time(),
|
|
);
|
|
Db::name('CustomerLog')->strict(false)->field(true)->insert($log_data);
|
|
return to_assign();
|
|
} else {
|
|
return to_assign(1, '操作失败');
|
|
}
|
|
}
|
|
} else {
|
|
if (!empty($param['id']) && $param['id'] > 0) {
|
|
$sea = isset($param['sea']) ? $param['sea'] : 0;
|
|
//查看权限判断
|
|
$customer = customer_auth($this->uid,$param['id']);
|
|
$detail = (new CustomerList())->detail($param['id']);
|
|
View::assign('sea', $sea);
|
|
View::assign('detail', $detail);
|
|
return view('edit');
|
|
}
|
|
else{
|
|
$sea = isset($param['sea']) ? $param['sea'] : 0;
|
|
View::assign('sea', $sea);
|
|
View::assign('userinfo', get_admin($this->uid));
|
|
return view();
|
|
}
|
|
}
|
|
}
|
|
|
|
//查看
|
|
public function view()
|
|
{
|
|
$id = get_params("id");
|
|
//查看权限判断
|
|
$customer = customer_auth($this->uid,$id);
|
|
|
|
$detail = (new CustomerList())->detail($id);
|
|
$contact = Db::name('CustomerContact')->where(['is_default'=>1,'cid'=>$id])->find();
|
|
//是否是客户管理员
|
|
$auth = isAuth($this->uid,'customer_admin');
|
|
View::assign('auth', $auth);
|
|
View::assign('contact', $contact);
|
|
View::assign('detail', $detail);
|
|
return view();
|
|
}
|
|
|
|
//获取客户
|
|
public function get()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$id = get_params("id");
|
|
$time = strtotime(date('Y-m-d')." 00:00:00");
|
|
$max_num = Db::name('DataAuth')->where('name','customer_admin')->value('expected_1');
|
|
$count = Db::name('Customer')->where([['belong_time','>',$time],['belong_uid','=',$this->uid]])->count();
|
|
if($count>=$max_num){
|
|
return to_assign(1, "今日领取客户数已到达上限，请明天再来领取");
|
|
}
|
|
$data['id'] = $id;
|
|
$data['belong_uid'] = $this->uid;
|
|
$data['belong_did'] = $this->did;
|
|
$data['belong_time'] = time();
|
|
if (Db::name('Customer')->update($data) !== false) {
|
|
add_log('tosea', $id);
|
|
$log_data = array(
|
|
'field' => 'belong',
|
|
'action' => 'get',
|
|
'type' => 0,
|
|
'customer_id' => $data['id'],
|
|
'admin_id' => $this->uid,
|
|
'create_time' => time(),
|
|
);
|
|
Db::name('CustomerLog')->strict(false)->field(true)->insert($log_data);
|
|
return to_assign(0, "操作成功");
|
|
} else {
|
|
return to_assign(1, "操作失败");
|
|
}
|
|
} else {
|
|
return to_assign(1, "错误的请求");
|
|
}
|
|
}
|
|
|
|
//客户移入废弃池
|
|
public function to_trash()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$params = get_params();
|
|
$data['id'] = $params['id'];
|
|
$log_data = array(
|
|
'field' => 'del',
|
|
'action' => 'delete',
|
|
'type' => 0,
|
|
'customer_id' => $params['id'],
|
|
'admin_id' => $this->uid,
|
|
'create_time' => time(),
|
|
);
|
|
$data['delete_time'] = time();
|
|
$log_data['action'] = 'totrash';
|
|
if (Db::name('Customer')->update($data) !== false) {
|
|
add_log('totrash', $params['id']);
|
|
Db::name('CustomerLog')->strict(false)->field(true)->insert($log_data);
|
|
return to_assign();
|
|
} else {
|
|
return to_assign(1, "操作失败");
|
|
}
|
|
} else {
|
|
return to_assign(1, "错误的请求");
|
|
}
|
|
}
|
|
|
|
//还原客户
|
|
public function revert()
|
|
{
|
|
if (request()->isAjax()) {
|
|
$params = get_params();
|
|
$data['id'] = $params['id'];
|
|
$data['delete_time'] = 0;
|
|
if (Db::name('Customer')->update($data) !== false) {
|
|
add_log('recovery', $params['id']);
|
|
$log_data = array(
|
|
'field' => 'del',
|
|
'action' => 'recovery',
|
|
'type' => 0,
|
|
'customer_id' => $params['id'],
|
|
'admin_id' => $this->uid,
|
|
'create_time' => time(),
|
|
);
|
|
Db::name('CustomerLog')->strict(false)->field(true)->insert($log_data);
|
|
return to_assign();
|
|
} else {
|
|
return to_assign(1, "操作失败");
|
|
}
|
|
} else {
|
|
return to_assign(1, "错误的请求");
|
|
}
|
|
}
|
|
|
|
//彻底删除客户
|
|
public function delete()
|
|
{
|
|
if (request()->isDelete()) {
|
|
$params = get_params();
|
|
//是否是客户管理员
|
|
$auth = isAuth($this->uid,'customer_admin');
|
|
if($auth==0){
|
|
return to_assign(1, "只有客户管理员才有权限操作");
|
|
}
|
|
$data['id'] = $params['id'];
|
|
$data['delete_time'] = -1;
|
|
$log_data = array(
|
|
'field' => 'del',
|
|
'action' => 'delete',
|
|
'type' => 0,
|
|
'customer_id' => $params['id'],
|
|
'admin_id' => $this->uid,
|
|
'create_time' => time()
|
|
);
|
|
if (Db::name('Customer')->update($data) !== false) {
|
|
//删除客户联系人
|
|
Db::name('CustomerContact')->where(['cid' => $params['id']])->update(['delete_time'=>time()]);
|
|
//删除客户机会
|
|
Db::name('CustomerChance')->where(['cid' => $params['id']])->update(['delete_time'=>time()]);
|
|
add_log('delete', $params['id']);
|
|
Db::name('CustomerLog')->strict(false)->field(true)->insert($log_data);
|
|
return to_assign();
|
|
} else {
|
|
return to_assign(1, "操作失败");
|
|
}
|
|
} else {
|
|
return to_assign(1, "错误的请求");
|
|
}
|
|
}
|
|
|
|
|
|
}
|