charles
/
wkcrm
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

商机审批

Browse Source
pull/3/head
张萌 2 years ago
parent c19d6f30d0
commit d1c10f83ff
1 changed files with 156 additions and 110 deletions
Show Stats Download Patch File Download Diff File

266
application/crm/controller/Business.php
Unescape View File

@ -17,7 +17,7 @@ use think\Db;
class Business extends ApiCommon class Business extends ApiCommon
{ {
use StarTrait, SearchConditionTrait; use StarTrait, SearchConditionTrait;
/** /**
* 用于判断权限 * 用于判断权限
* @permission 无限制 * @permission 无限制
@ -37,7 +37,7 @@ class Business extends ApiCommon
parent::_initialize(); parent::_initialize();
} }
} }
/** /**
* 商机列表 * 商机列表
* @return * @return
@ -52,7 +52,7 @@ class Business extends ApiCommon
$data = $businessModel->getDataList($param); $data = $businessModel->getDataList($param);
return resultArray(['data' => $data]); return resultArray(['data' => $data]);
} }
/** /**
* 添加商机 * 添加商机
* @param * @param
@ -66,14 +66,14 @@ class Business extends ApiCommon
$userInfo = $this->userInfo; $userInfo = $this->userInfo;
$param['create_user_id'] = $userInfo['id']; $param['create_user_id'] = $userInfo['id'];
$param['owner_user_id'] = $userInfo['id']; $param['owner_user_id'] = $userInfo['id'];
if ($businessModel->createData($param)) { if ($businessModel->createData($param)) {
return resultArray(['data' => '添加成功']); return resultArray(['data' => '添加成功']);
} else { } else {
return resultArray(['error' => $businessModel->getError()]); return resultArray(['error' => $businessModel->getError()]);
} }
} }
/** /**
* 商机详情 * 商机详情
* @param * @param
@ -108,7 +108,7 @@ class Business extends ApiCommon
} }
return resultArray(['data' => $data]); return resultArray(['data' => $data]);
} }
/** /**
* 编辑商机 * 编辑商机
* @param * @param
@ -137,7 +137,7 @@ class Business extends ApiCommon
return resultArray(['error' => $businessModel->getError()]); return resultArray(['error' => $businessModel->getError()]);
} }
} }
/** /**
* 删除商机（逻辑删） * 删除商机（逻辑删）
* @param * @param
@ -159,7 +159,7 @@ class Business extends ApiCommon
} }
$delIds = []; $delIds = [];
$errorMessage = []; $errorMessage = [];
//数据权限判断 //数据权限判断
$userModel = new \app\admin\model\User(); $userModel = new \app\admin\model\User();
$auth_user_ids = $userModel->getUserByPer('crm', 'business', 'delete'); $auth_user_ids = $userModel->getUserByPer('crm', 'business', 'delete');
@ -198,7 +198,7 @@ class Business extends ApiCommon
$fileModel->delRFileByModule('crm_business', $delIds); $fileModel->delRFileByModule('crm_business', $delIds);
//删除关联操作记录 //删除关联操作记录
$actionRecordModel->delDataById(['types' => 'crm_business', 'action_id' => $delIds]); $actionRecordModel->delDataById(['types' => 'crm_business', 'action_id' => $delIds]);
$dataInfo = $businessModel->where('business_id',['in',$delIds])->select(); $dataInfo = $businessModel->where('business_id', ['in', $delIds])->select();
foreach ($dataInfo as $k => $v) { foreach ($dataInfo as $k => $v) {
RecordActionLog($userInfo['id'], 'crm_business', 'delete', $v['name'], '', '', '删除了商机：' . $v['name']); RecordActionLog($userInfo['id'], 'crm_business', 'delete', $v['name'], '', '', '删除了商机：' . $v['name']);
} }
@ -209,7 +209,7 @@ class Business extends ApiCommon
return resultArray(['data' => '删除成功']); return resultArray(['data' => '删除成功']);
} }
} }
/** /**
* 符合条件的商机状态组 * 符合条件的商机状态组
* @param * @param
@ -223,10 +223,10 @@ class Business extends ApiCommon
$list = cache($key); $list = cache($key);
if (!$list) { if (!$list) {
$userInfo = $this->userInfo; $userInfo = $this->userInfo;
$authMap = function($query) use ($userInfo){ $authMap = function ($query) use ($userInfo) {
$query->where(['structure_id' => ['like', '%,' . $userInfo['structure_id'] . ',%'],'is_display'=> 1,'status'=> 1]) $query->where(['structure_id' => ['like', '%,' . $userInfo['structure_id'] . ',%'], 'is_display' => 1, 'status' => 1])
->whereOr(function ($query) use ($userInfo) { ->whereOr(function ($query) use ($userInfo) {
$query->where(['structure_id' => ''])->where(['is_display'=> 1,'status'=> 1]); $query->where(['structure_id' => ''])->where(['is_display' => 1, 'status' => 1]);
}); });
}; };
$list = db('crm_business_type') $list = db('crm_business_type')
@ -237,13 +237,13 @@ class Business extends ApiCommon
$list[$k]['statusList'] = $businessStatusModel->getDataList($v['type_id']); $list[$k]['statusList'] = $businessStatusModel->getDataList($v['type_id']);
} }
cache($key, $list, config('business_status_cache_time')); cache($key, $list, config('business_status_cache_time'));
}else{ } else {
cache($key, NULL); cache($key, NULL);
} }
return resultArray(['data' => $list]); return resultArray(['data' => $list]);
} }
/** /**
* 商机转移 * 商机转移
* @param owner_user_id 变更负责人 * @param owner_user_id 变更负责人
@ -266,30 +266,30 @@ class Business extends ApiCommon
if (!$param['business_id'] || !is_array($param['business_id'])) { if (!$param['business_id'] || !is_array($param['business_id'])) {
return resultArray(['error' => '请选择需要转移的商机']); return resultArray(['error' => '请选择需要转移的商机']);
} }
$is_remove = $param['is_remove'] == 2 ? 2 : 1; $is_remove = $param['is_remove'] == 2 ? 2 : 1;
$type = $param['type'] == 2 ? 2 : 1; $type = $param['type'] == 2 ? 2 : 1;
$data = []; $data = [];
$data['owner_user_id'] = $param['owner_user_id']; $data['owner_user_id'] = $param['owner_user_id'];
$data['update_time'] = time(); $data['update_time'] = time();
$ownerUserName = $userModel->getUserNameById($param['owner_user_id']); $ownerUserName = $userModel->getUserNameById($param['owner_user_id']);
$errorMessage = []; $errorMessage = [];
foreach ($param['business_id'] as $business_id) { foreach ($param['business_id'] as $business_id) {
$businessInfo = $businessModel->getDataById($business_id); $businessInfo = $businessModel->getDataById($business_id);
if (!$businessInfo) { if (!$businessInfo) {
$errorMessage[] = '名称:为《' . $businessInfo['name'] . '》的商机转移失败，错误原因：数据不存在；'; $errorMessage[] = '名称:为《' . $businessInfo['name'] . '》的商机转移失败，错误原因：数据不存在；';
continue; continue;
} }
//权限判断 //权限判断
if (!in_array($businessInfo['owner_user_id'], $authIds)) { if (!in_array($businessInfo['owner_user_id'], $authIds)) {
$errorMessage[] = $businessInfo['name'] . '"转移失败，错误原因：无权限；'; $errorMessage[] = $businessInfo['name'] . '"转移失败，错误原因：无权限；';
continue; continue;
} }
//团队成员 //团队成员
teamUserId( teamUserId(
$param, $param,
@ -300,7 +300,7 @@ class Business extends ApiCommon
$is_remove, $is_remove,
0 0
); );
$resBusiness = db('crm_business')->where(['business_id' => $business_id])->update($data); $resBusiness = db('crm_business')->where(['business_id' => $business_id])->update($data);
if (!$resBusiness) { if (!$resBusiness) {
$errorMessage[] = $businessInfo['name'] . '"转移失败，错误原因：数据出错；'; $errorMessage[] = $businessInfo['name'] . '"转移失败，错误原因：数据出错；';
@ -318,11 +318,11 @@ class Business extends ApiCommon
} }
db('crm_business')->where('business_id', $business_id)->update($businessArray); db('crm_business')->where('business_id', $business_id)->update($businessArray);
} }
//修改记录 //修改记录
updateActionLog($userInfo['id'], 'crm_business', $business_id, '', '', '将商机转移给：' . $ownerUserName); updateActionLog($userInfo['id'], 'crm_business', $business_id, '', '', '将商机转移给：' . $ownerUserName);
RecordActionLog($userInfo['id'], 'crm_business', 'transfer', $businessInfo['name'], '', '', '将商机：' . $businessInfo['name'] . '转移给：' . $ownerUserName); RecordActionLog($userInfo['id'], 'crm_business', 'transfer', $businessInfo['name'], '', '', '将商机：' . $businessInfo['name'] . '转移给：' . $ownerUserName);
} }
if (!$errorMessage) { if (!$errorMessage) {
return resultArray(['data' => '转移成功']); return resultArray(['data' => '转移成功']);
@ -330,7 +330,7 @@ class Business extends ApiCommon
return resultArray(['error' => $errorMessage]); return resultArray(['error' => $errorMessage]);
} }
} }
/** /**
* 相关产品 * 相关产品
* @param * @param
@ -370,7 +370,7 @@ class Business extends ApiCommon
$list['discount_rate'] = $businessInfo['discount_rate'] ?: '0.00'; $list['discount_rate'] = $businessInfo['discount_rate'] ?: '0.00';
return resultArray(['data' => $list]); return resultArray(['data' => $list]);
} }
/** /**
* 商机状态推进 * 商机状态推进
* @param business_id 商机ID * @param business_id 商机ID
@ -392,73 +392,23 @@ class Business extends ApiCommon
if ($businessInfo['is_end']) { if ($businessInfo['is_end']) {
return resultArray(['error' => '已结束，不能推进']); return resultArray(['error' => '已结束，不能推进']);
} }
//判断权限
$auth_user_ids = $userModel->getUserByPer('crm', 'business', 'update');
//读写权限
$rwPre = $userModel->rwPre($userInfo['id'], $businessInfo['ro_user_id'], $businessInfo['rw_user_id'], 'update');
if (!in_array($businessInfo['owner_user_id'], $auth_user_ids) && !$rwPre) {
header('Content-Type:application/json; charset=utf-8');
exit(json_encode(['code' => 102, 'error' => '无权操作']));
}
$status_id = $param['status_id'] ?: $businessInfo['status_id'];
$statusInfo = db('crm_business_status')->where(['type_id' => $businessInfo['type_id'], 'status_id' => $status_id])->find();
if (!$statusInfo && !$is_end) {
return resultArray(['error' => '参数错误']);
}
$data = []; $data = [];
$data['update_time'] = time(); $data['update_time'] = time();
$data['is_end'] = $is_end; $data['is_end'] = $is_end;
$data['remark'] = $remark; $data['remark'] = $remark;
// if ($is_end) { $data['check_status'] = 1;
// $status_id = $is_end; $data['flow_id'] = 13;
// } $data['check_user_id'] = $param['check_user_id'];
$data['status_id'] = $status_id; $data['flow_user_id'] = $param['check_user_id'];
$data['status_time'] = time();
$res = db('crm_business')->where(['business_id' => $param['business_id']])->update($data); $res = db('crm_business')->where(['business_id' => $param['business_id']])->update($data);
if (!$res) { if (!$res) {
return resultArray(['error' => '推进失败，请重试']); return resultArray(['error' => '推进失败，请重试']);
} else {
# 商机变更后的名称
$businessStatusName = Db::name('crm_business_status')->where('status_id', $param['status_id'])->value('name');
if (empty($businessStatusName) && $is_end == 1) $businessStatusName = '赢单';
if (empty($businessStatusName) && $is_end == 2) $businessStatusName = '输单';
if (empty($businessStatusName) && $is_end == 3) $businessStatusName = '无效';
# 添加活动记录
Db::name('crm_activity')->insert([
'type' => 3,
'activity_type' => 5,
'activity_type_id' => $businessInfo['business_id'],
'content' => '阶段变更为 ' . $businessStatusName,
'create_user_id' => $businessInfo['owner_user_id'],
'update_time' => time(),
'create_time' => time(),
'customer_ids' => ',' . $businessInfo['customer_id'] . ','
]);
//推进记录添加
$temp['status_id'] = $status_id ?: 0;
$temp['is_end'] = $is_end ?: 0;
$temp['business_id'] = $param['business_id'];
$temp['create_time'] = time();
$temp['owner_user_id'] = $userInfo['id'];
$temp['remark'] = $param['statusRemark'] ?: '';
Db::name('CrmBusinessLog')->insert($temp);
# 返回商机阶段数据
$typeId = db('crm_business')->where('business_id', $param['business_id'])->value('type_id');
$businessStatus = db('crm_business_status')->where('type_id', $typeId)->select();
$result = [
'business_id' => $param['business_id'],
'type_id' => $typeId,
'status_id' => $param['status_id'],
'status_list' => $businessStatus
];
return resultArray(['data' => $result]);
} }
return resultArray(['success' => '提交成功']);
} }
/** /**
* 商机导出 * 商机导出
* @param * @param
@ -476,14 +426,14 @@ class Business extends ApiCommon
$param['is_excel'] = 1; $param['is_excel'] = 1;
$action_name = '导出选中'; $action_name = '导出选中';
} }
$excelModel = new \app\admin\model\Excel(); $excelModel = new \app\admin\model\Excel();
// 导出的字段列表 // 导出的字段列表
$fieldModel = new \app\admin\model\Field(); $fieldModel = new \app\admin\model\Field();
$field_list = $fieldModel->getIndexFieldConfig('crm_business', $userInfo['id']); $field_list = $fieldModel->getIndexFieldConfig('crm_business', $userInfo['id']);
// 文件名 // 文件名
$file_name = '5kcrm_business_' . date('Ymd'); $file_name = '5kcrm_business_' . date('Ymd');
$model = model('Business'); $model = model('Business');
$temp_file = $param['temp_file']; $temp_file = $param['temp_file'];
unset($param['temp_file']); unset($param['temp_file']);
@ -499,7 +449,7 @@ class Business extends ApiCommon
return $data; return $data;
}); });
} }
/** /**
* 设置关注 * 设置关注
* *
@ -512,16 +462,16 @@ class Business extends ApiCommon
$userId = $this->userInfo['id']; $userId = $this->userInfo['id'];
$targetId = $this->param['target_id']; $targetId = $this->param['target_id'];
$type = $this->param['type']; $type = $this->param['type'];
if (empty($userId) || empty($targetId) || empty($type)) return resultArray(['error' => '缺少必要参数！']); if (empty($userId) || empty($targetId) || empty($type)) return resultArray(['error' => '缺少必要参数！']);
if (!$this->setStar($type, $userId, $targetId)) { if (!$this->setStar($type, $userId, $targetId)) {
return resultArray(['error' => '设置关注失败！']); return resultArray(['error' => '设置关注失败！']);
} }
return resultArray(['data' => '设置关注成功！']); return resultArray(['data' => '设置关注成功！']);
} }
/** /**
* 系统信息 * 系统信息
* *
@ -533,14 +483,14 @@ class Business extends ApiCommon
public function system() public function system()
{ {
if (empty($this->param['id'])) return resultArray(['error' => '参数错误！']); if (empty($this->param['id'])) return resultArray(['error' => '参数错误！']);
$businessModel = new \app\crm\model\Business(); $businessModel = new \app\crm\model\Business();
$data = $businessModel->getSystemInfo($this->param['id']); $data = $businessModel->getSystemInfo($this->param['id']);
return resultArray(['data' => $data]); return resultArray(['data' => $data]);
} }
/** /**
* table栏数量统计 * table栏数量统计
* *
@ -552,39 +502,39 @@ class Business extends ApiCommon
public function count() public function count()
{ {
if (empty($this->param['business_id'])) return resultArray(['error' => '参数错误！']); if (empty($this->param['business_id'])) return resultArray(['error' => '参数错误！']);
$businessId = $this->param['business_id']; $businessId = $this->param['business_id'];
$userInfo = $this->userInfo; $userInfo = $this->userInfo;
# 查询联系人和商机关联数据 # 查询联系人和商机关联数据
$contactsIds = Db::name('crm_contacts_business')->where('business_id', $businessId)->column('contacts_id'); $contactsIds = Db::name('crm_contacts_business')->where('business_id', $businessId)->column('contacts_id');
# 联系人 # 联系人
$contactsAuth = $this->getContactsSearchWhere($userInfo['id']); $contactsAuth = $this->getContactsSearchWhere($userInfo['id']);
$contactsCount = Db::name('crm_contacts')->whereIn('contacts_id', $contactsIds)->where($contactsAuth)->count(); $contactsCount = Db::name('crm_contacts')->whereIn('contacts_id', $contactsIds)->where($contactsAuth)->count();
# 合同 # 合同
$contractAuth = $this->getContractSearchWhere($userInfo['id']); $contractAuth = $this->getContractSearchWhere($userInfo['id']);
$contractCount = Db::name('crm_contract')->where('business_id', $businessId)->where($contractAuth)->count(); $contractCount = Db::name('crm_contract')->where('business_id', $businessId)->where($contractAuth)->count();
# 查询商机和产品的关联表 # 查询商机和产品的关联表
$productIds = Db::name('crm_business_product')->where('business_id', $businessId)->column('product_id'); $productIds = Db::name('crm_business_product')->where('business_id', $businessId)->column('product_id');
# 产品 # 产品
$productAuth = $this->getProductSearchWhere(); $productAuth = $this->getProductSearchWhere();
$productCount = Db::name('crm_product')->whereIn('product_id', $productIds)->whereIn('owner_user_id', $productAuth)->count(); $productCount = Db::name('crm_product')->whereIn('product_id', $productIds)->whereIn('owner_user_id', $productAuth)->count();
# 附件 # 附件
$fileCount = Db::name('crm_business_file')->alias('business')->join('__ADMIN_FILE__ file', 'file.file_id = business.file_id', 'LEFT')->where('business_id', $businessId)->count(); $fileCount = Db::name('crm_business_file')->alias('business')->join('__ADMIN_FILE__ file', 'file.file_id = business.file_id', 'LEFT')->where('business_id', $businessId)->count();
# 团队 # 团队
$business = Db::name('crm_business')->field(['owner_user_id', 'ro_user_id', 'rw_user_id'])->where('business_id', $businessId)->find(); $business = Db::name('crm_business')->field(['owner_user_id', 'ro_user_id', 'rw_user_id'])->where('business_id', $businessId)->find();
$business['ro_user_id'] = explode(',', trim($business['ro_user_id'], ',')); $business['ro_user_id'] = explode(',', trim($business['ro_user_id'], ','));
$business['rw_user_id'] = explode(',', trim($business['rw_user_id'], ',')); $business['rw_user_id'] = explode(',', trim($business['rw_user_id'], ','));
$business['owner_user_id'] = [$business['owner_user_id']]; $business['owner_user_id'] = [$business['owner_user_id']];
$teamCount = array_filter(array_unique(array_merge($business['ro_user_id'], $business['rw_user_id'], $business['owner_user_id']))); $teamCount = array_filter(array_unique(array_merge($business['ro_user_id'], $business['rw_user_id'], $business['owner_user_id'])));
$data = [ $data = [
'contactCount' => $contactsCount, 'contactCount' => $contactsCount,
'contractCount' => $contractCount, 'contractCount' => $contractCount,
@ -592,10 +542,10 @@ class Business extends ApiCommon
'memberCount' => count($teamCount), 'memberCount' => count($teamCount),
'productCount' => $productCount 'productCount' => $productCount
]; ];
return resultArray(['data' => $data]); return resultArray(['data' => $data]);
} }
/** /**
* 设置首要联系人 * 设置首要联系人
* *
@ -607,13 +557,109 @@ class Business extends ApiCommon
{ {
$businessId = $this->param['business_id']; $businessId = $this->param['business_id'];
$contactsId = $this->param['contacts_id']; $contactsId = $this->param['contacts_id'];
if (empty($businessId) || empty($contactsId)) return resultArray(['error' => '参数错误！']); if (empty($businessId) || empty($contactsId)) return resultArray(['error' => '参数错误！']);
if (!Db::name('crm_business')->where('business_id', $businessId)->update(['contacts_id' => $contactsId])) { if (!Db::name('crm_business')->where('business_id', $businessId)->update(['contacts_id' => $contactsId])) {
return resultArray(['error' => '操作失败！']); return resultArray(['error' => '操作失败！']);
} }
return resultArray(['data' => '操作成功！']); return resultArray(['data' => '操作成功！']);
} }
public function check()
{
$param = $this->param;
$userInfo = $this->userInfo;
$userModel = new \app\admin\model\User();
// $is_end = $param['is_end'] ?: 0; //1赢单2输单3无效
// $remark = $param['statusRemark'];
$check_status = $param['check_status'];
if (!$param['business_id']) {
return resultArray(['error' => '参数错误']);
}
if ($check_status == 2) {
$businessInfo = db('crm_business')->where(['business_id' => $param['business_id']])->find();
// if ($businessInfo['is_end']) {
// return resultArray(['error' => '已结束，不能推进']);
// }
//判断权限
$auth_user_ids = $userModel->getUserByPer('crm', 'business', 'update');
//读写权限
$rwPre = $userModel->rwPre($userInfo['id'], $businessInfo['ro_user_id'], $businessInfo['rw_user_id'], 'update');
if (!in_array($businessInfo['owner_user_id'], $auth_user_ids) && !$rwPre) {
header('Content-Type:application/json; charset=utf-8');
exit(json_encode(['code' => 102, 'error' => '无权操作']));
}
$status_id = $param['status_id'] ?: $businessInfo['status_id'];
$statusInfo = db('crm_business_status')->where(['type_id' => $businessInfo['type_id'], 'status_id' => $status_id])->find();
if (!$statusInfo && $businessInfo['is_end']) {
return resultArray(['error' => '参数错误']);
}
$data = [];
$data['update_time'] = time();
// $data['is_end'] = $is_end;
// $data['remark'] = $remark;
$data['check_status'] = $check_status;
$data['status_id'] = $status_id;
$data['status_time'] = time();
$res = db('crm_business')->where(['business_id' => $param['business_id']])->update($data);
if (!$res) {
return resultArray(['error' => '推进失败，请重试']);
} else {
# 商机变更后的名称
$businessStatusName = Db::name('crm_business_status')->where('status_id', $param['status_id'])->value('name');
if (empty($businessStatusName) && $businessInfo['is_end'] == 1) $businessStatusName = '赢单';
if (empty($businessStatusName) && $businessInfo['is_end'] == 2) $businessStatusName = '输单';
if (empty($businessStatusName) && $businessInfo['is_end'] == 3) $businessStatusName = '无效';
# 添加活动记录
Db::name('crm_activity')->insert([
'type' => 3,
'activity_type' => 5,
'activity_type_id' => $businessInfo['business_id'],
'content' => '阶段变更为 ' . $businessStatusName,
'create_user_id' => $businessInfo['owner_user_id'],
'update_time' => time(),
'create_time' => time(),
'customer_ids' => ',' . $businessInfo['customer_id'] . ','
]);
//推进记录添加
$temp['status_id'] = $status_id ?: 0;
$temp['is_end'] = $businessInfo['is_end'] ?: 0;
$temp['business_id'] = $param['business_id'];
$temp['create_time'] = time();
$temp['owner_user_id'] = $userInfo['id'];
$temp['remark'] = $param['statusRemark'] ?: '';
Db::name('CrmBusinessLog')->insert($temp);
# 返回商机阶段数据
$typeId = db('crm_business')->where('business_id', $param['business_id'])->value('type_id');
$businessStatus = db('crm_business_status')->where('type_id', $typeId)->select();
$result = [
'business_id' => $param['business_id'],
'type_id' => $typeId,
'status_id' => $param['status_id'],
'status_list' => $businessStatus
];
return resultArray(['data' => $result]);
}
} else {
$data = [];
$data['update_time'] = time();
$data['is_end'] = 0;
$data['remark'] = '';
$data['check_status'] = $check_status;
$res = db('crm_business')->where(['business_id' => $param['business_id']])->update($data);
if (!$res) {
return resultArray(['error' => '推进失败，请重试']);
}
}
}
} }

Write Preview
Loading…
Cancel
Save