|
|
<?php
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Description: 商机
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Author: Michael_xu | gengxiaoxu@5kcrm.com
|
|
|
// +----------------------------------------------------------------------
|
|
|
|
|
|
namespace app\crm\controller;
|
|
|
|
|
|
use app\admin\controller\ApiCommon;
|
|
|
use app\crm\traits\SearchConditionTrait;
|
|
|
use app\crm\traits\StarTrait;
|
|
|
use think\Hook;
|
|
|
use think\Request;
|
|
|
use think\Db;
|
|
|
|
|
|
class Business extends ApiCommon
|
|
|
{
|
|
|
use StarTrait, SearchConditionTrait;
|
|
|
|
|
|
/**
|
|
|
* 用于判断权限
|
|
|
* @permission 无限制
|
|
|
* @allow 登录用户可访问
|
|
|
* @other 其他根据系统设置
|
|
|
**/
|
|
|
public function _initialize()
|
|
|
{
|
|
|
$action = [
|
|
|
'permission' => [''],
|
|
|
'allow' => ['statuslist', 'advance', 'product', 'system', 'count', 'setprimary']
|
|
|
];
|
|
|
Hook::listen('check_auth', $action);
|
|
|
$request = Request::instance();
|
|
|
$a = strtolower($request->action());
|
|
|
if (!in_array($a, $action['permission'])) {
|
|
|
parent::_initialize();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 商机列表
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function index()
|
|
|
{
|
|
|
$businessModel = model('Business');
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
$param['user_id'] = $userInfo['id'];
|
|
|
$data = $businessModel->getDataList($param);
|
|
|
return resultArray(['data' => $data]);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 添加商机
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function save()
|
|
|
{
|
|
|
$businessModel = model('Business');
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
$param['create_user_id'] = $userInfo['id'];
|
|
|
$param['owner_user_id'] = $userInfo['id'];
|
|
|
|
|
|
if ($businessModel->createData($param)) {
|
|
|
return resultArray(['data' => '添加成功']);
|
|
|
} else {
|
|
|
return resultArray(['error' => $businessModel->getError()]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 商机详情
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function read()
|
|
|
{
|
|
|
$businessModel = model('Business');
|
|
|
$businessStatusModel = model('BusinessStatus');
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
$data = $businessModel->getDataById($param['id'], $userInfo['id']);
|
|
|
//判断权限
|
|
|
$auth_user_ids = $userModel->getUserByPer('crm', 'business', 'read');
|
|
|
//读权限
|
|
|
$roPre = $userModel->rwPre($userInfo['id'], $data['ro_user_id'], $data['rw_user_id'], 'read');
|
|
|
$rwPre = $userModel->rwPre($userInfo['id'], $data['ro_user_id'], $data['rw_user_id'], 'update');
|
|
|
if (!in_array($data['owner_user_id'], $auth_user_ids) && !$rwPre && !$roPre) {
|
|
|
$authData['dataAuth'] = (int)0;
|
|
|
return resultArray(['data' => $authData]);
|
|
|
}
|
|
|
//商机状态组
|
|
|
$data['status_list'] = $businessStatusModel->getDataById($data['type_id']);
|
|
|
$data['lose_reason'] = Db::name('CrmBusinessLog')
|
|
|
->where(['business_id' => $data['business_id']])
|
|
|
->order(['id' => 'DESC'])
|
|
|
->value('remark');
|
|
|
if (!$data) {
|
|
|
return resultArray(['error' => $businessModel->getError()]);
|
|
|
}
|
|
|
return resultArray(['data' => $data]);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 编辑商机
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function update()
|
|
|
{
|
|
|
$businessModel = model('Business');
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
$param['user_id'] = $userInfo['id'];
|
|
|
//判断权限
|
|
|
$data = $businessModel->getDataById($param['id']);
|
|
|
$auth_user_ids = $userModel->getUserByPer('crm', 'business', 'update');
|
|
|
//读写权限
|
|
|
$rwPre = $userModel->rwPre($userInfo['id'], $data['ro_user_id'], $data['rw_user_id'], 'update');
|
|
|
if (!in_array($data['owner_user_id'], $auth_user_ids) && !$rwPre) {
|
|
|
header('Content-Type:application/json; charset=utf-8');
|
|
|
exit(json_encode(['code' => 102, 'error' => '无权操作']));
|
|
|
}
|
|
|
if ($businessModel->updateDataById($param, $param['id'])) {
|
|
|
return resultArray(['data' => '编辑成功']);
|
|
|
} else {
|
|
|
return resultArray(['error' => $businessModel->getError()]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 删除商机（逻辑删）
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function delete()
|
|
|
{
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
$businessModel = model('Business');
|
|
|
$recordModel = new \app\admin\model\Record();
|
|
|
$fileModel = new \app\admin\model\File();
|
|
|
$actionRecordModel = new \app\admin\model\ActionRecord();
|
|
|
if (!is_array($param['id'])) {
|
|
|
$business_id[] = $param['id'];
|
|
|
} else {
|
|
|
$business_id = $param['id'];
|
|
|
}
|
|
|
$delIds = [];
|
|
|
$errorMessage = [];
|
|
|
|
|
|
//数据权限判断
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$auth_user_ids = $userModel->getUserByPer('crm', 'business', 'delete');
|
|
|
foreach ($business_id as $k => $v) {
|
|
|
$isDel = true;
|
|
|
//数据详情
|
|
|
$data = $businessModel->getDataById($v);
|
|
|
if (!$data) {
|
|
|
$isDel = false;
|
|
|
$errorMessage[] = 'id为' . $v . '的商机删除失败,错误原因：' . $businessModel->getError();
|
|
|
}
|
|
|
if (!in_array($data['owner_user_id'], $auth_user_ids)) {
|
|
|
$isDel = false;
|
|
|
$errorMessage[] = '名称为' . $data['name'] . '的商机删除失败,错误原因：无权操作';
|
|
|
}
|
|
|
if ($isDel) {
|
|
|
if (db('crm_contract')->where(['business_id' => $v, 'check_status' => ['in', '0,1,2']])->value('contract_id')) {
|
|
|
$isDel = false;
|
|
|
$errorMessage[] = '名称为' . $data['name'] . '的商机删除失败,错误原因：商机下关联的有合同，无法删除！';
|
|
|
}
|
|
|
}
|
|
|
if ($isDel) {
|
|
|
$delIds[] = $v;
|
|
|
}
|
|
|
}
|
|
|
if ($delIds) {
|
|
|
$data = $businessModel->delDatas($delIds);
|
|
|
if (!$data) {
|
|
|
return resultArray(['error' => $businessModel->getError()]);
|
|
|
}
|
|
|
// 删除客户扩展数据
|
|
|
db('crm_business_data')->whereIn('business_id', $delIds)->delete();
|
|
|
//删除跟进记录
|
|
|
$recordModel->delDataByTypes(5, $delIds);
|
|
|
//删除关联附件
|
|
|
$fileModel->delRFileByModule('crm_business', $delIds);
|
|
|
//删除关联操作记录
|
|
|
$actionRecordModel->delDataById(['types' => 'crm_business', 'action_id' => $delIds]);
|
|
|
$dataInfo = $businessModel->where('business_id', ['in', $delIds])->select();
|
|
|
foreach ($dataInfo as $k => $v) {
|
|
|
RecordActionLog($userInfo['id'], 'crm_business', 'delete', $v['name'], '', '', '删除了商机：' . $v['name']);
|
|
|
}
|
|
|
}
|
|
|
if ($errorMessage) {
|
|
|
return resultArray(['error' => $errorMessage]);
|
|
|
} else {
|
|
|
return resultArray(['data' => '删除成功']);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 符合条件的商机状态组
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function statusList()
|
|
|
{
|
|
|
$businessStatusModel = model('BusinessStatus');
|
|
|
$key = 'BI_queryCache_StatusList_Data';
|
|
|
$list = cache($key);
|
|
|
if (!$list) {
|
|
|
$userInfo = $this->userInfo;
|
|
|
$authMap = function ($query) use ($userInfo) {
|
|
|
$query->where(['structure_id' => ['like', '%,' . $userInfo['structure_id'] . ',%'], 'is_display' => 1, 'status' => 1])
|
|
|
->whereOr(function ($query) use ($userInfo) {
|
|
|
$query->where(['structure_id' => ''])->where(['is_display' => 1, 'status' => 1]);
|
|
|
});
|
|
|
};
|
|
|
$list = db('crm_business_type')
|
|
|
->field(['name', 'status', 'structure_id', 'type_id'])
|
|
|
->where($authMap)
|
|
|
->select();
|
|
|
foreach ($list as $k => $v) {
|
|
|
$list[$k]['statusList'] = $businessStatusModel->getDataList($v['type_id']);
|
|
|
}
|
|
|
cache($key, $list, config('business_status_cache_time'));
|
|
|
} else {
|
|
|
cache($key, NULL);
|
|
|
}
|
|
|
|
|
|
return resultArray(['data' => $list]);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 商机转移
|
|
|
* @param owner_user_id 变更负责人
|
|
|
* @param is_remove 1移出，2转为团队成员
|
|
|
* @param type 权限 1只读2读写
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function transfer()
|
|
|
{
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
$businessModel = model('Business');
|
|
|
$settingModel = model('Setting');
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$authIds = $userModel->getUserByPer(); //权限范围的user_id
|
|
|
if (!$param['owner_user_id']) {
|
|
|
return resultArray(['error' => '变更负责人不能为空']);
|
|
|
}
|
|
|
if (!$param['business_id'] || !is_array($param['business_id'])) {
|
|
|
return resultArray(['error' => '请选择需要转移的商机']);
|
|
|
}
|
|
|
|
|
|
$is_remove = $param['is_remove'] == 2 ? 2 : 1;
|
|
|
$type = $param['type'] == 2 ? 2 : 1;
|
|
|
|
|
|
$data = [];
|
|
|
$data['owner_user_id'] = $param['owner_user_id'];
|
|
|
$data['update_time'] = time();
|
|
|
|
|
|
$ownerUserName = $userModel->getUserNameById($param['owner_user_id']);
|
|
|
$errorMessage = [];
|
|
|
foreach ($param['business_id'] as $business_id) {
|
|
|
$businessInfo = $businessModel->getDataById($business_id);
|
|
|
|
|
|
if (!$businessInfo) {
|
|
|
$errorMessage[] = '名称:为《' . $businessInfo['name'] . '》的商机转移失败，错误原因：数据不存在；';
|
|
|
continue;
|
|
|
}
|
|
|
//权限判断
|
|
|
if (!in_array($businessInfo['owner_user_id'], $authIds)) {
|
|
|
|
|
|
$errorMessage[] = $businessInfo['name'] . '"转移失败，错误原因：无权限；';
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
//团队成员
|
|
|
teamUserId(
|
|
|
$param,
|
|
|
'crm_business',
|
|
|
$business_id,
|
|
|
$type,
|
|
|
[$businessInfo['owner_user_id']],
|
|
|
$is_remove,
|
|
|
0
|
|
|
);
|
|
|
|
|
|
$resBusiness = db('crm_business')->where(['business_id' => $business_id])->update($data);
|
|
|
if (!$resBusiness) {
|
|
|
$errorMessage[] = $businessInfo['name'] . '"转移失败，错误原因：数据出错；';
|
|
|
continue;
|
|
|
} else {
|
|
|
$businessArray = [];
|
|
|
$teamBusiness = db('crm_business')->field(['owner_user_id', 'ro_user_id', 'rw_user_id'])->where('business_id', $business_id)->find();
|
|
|
if (!empty($teamBusiness['ro_user_id'])) {
|
|
|
$businessRo = arrayToString(array_diff(stringToArray($teamBusiness['ro_user_id']), [$teamBusiness['owner_user_id']]));
|
|
|
$businessArray['ro_user_id'] = $businessRo;
|
|
|
}
|
|
|
if (!empty($teamBusiness['rw_user_id'])) {
|
|
|
$businessRo = arrayToString(array_diff(stringToArray($teamBusiness['rw_user_id']), [$teamBusiness['owner_user_id']]));
|
|
|
$businessArray['rw_user_id'] = $businessRo;
|
|
|
}
|
|
|
db('crm_business')->where('business_id', $business_id)->update($businessArray);
|
|
|
}
|
|
|
|
|
|
//修改记录
|
|
|
updateActionLog($userInfo['id'], 'crm_business', $business_id, '', '', '将商机转移给：' . $ownerUserName);
|
|
|
RecordActionLog($userInfo['id'], 'crm_business', 'transfer', $businessInfo['name'], '', '', '将商机：' . $businessInfo['name'] . '转移给：' . $ownerUserName);
|
|
|
|
|
|
}
|
|
|
if (!$errorMessage) {
|
|
|
return resultArray(['data' => '转移成功']);
|
|
|
} else {
|
|
|
return resultArray(['error' => $errorMessage]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 相关产品
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function product()
|
|
|
{
|
|
|
$productModel = model('Product');
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
if (!$param['business_id']) {
|
|
|
return resultArray(['error' => '参数错误']);
|
|
|
}
|
|
|
$businessInfo = db('crm_business')->where(['business_id' => $param['business_id']])->find();
|
|
|
//判断权限
|
|
|
$auth_user_ids = $userModel->getUserByPer('crm', 'business', 'read');
|
|
|
//读写权限
|
|
|
$roPre = $userModel->rwPre($userInfo['id'], $businessInfo['ro_user_id'], $businessInfo['rw_user_id'], 'read');
|
|
|
$rwPre = $userModel->rwPre($userInfo['id'], $businessInfo['ro_user_id'], $businessInfo['rw_user_id'], 'update');
|
|
|
if (!in_array($businessInfo['owner_user_id'], $auth_user_ids) && !$roPre && !$rwPre) {
|
|
|
header('Content-Type:application/json; charset=utf-8');
|
|
|
exit(json_encode(['code' => 102, 'error' => '无权操作']));
|
|
|
}
|
|
|
$dataList = db('crm_business_product')->where(['business_id' => $param['business_id']])->select();
|
|
|
foreach ($dataList as $k => $v) {
|
|
|
$where = [];
|
|
|
$where['product_id'] = $v['product_id'];
|
|
|
$productInfo = db('crm_product')->where($where)->field('name,category_id')->find();
|
|
|
$category_name = db('crm_product_category')->where(['category_id' => $productInfo['category_id']])->value('name');
|
|
|
$dataList[$k]['name'] = $productInfo['name'] ?: '';
|
|
|
$dataList[$k]['category_id_info'] = $category_name ?: '';
|
|
|
}
|
|
|
$list['list'] = $dataList ?: [];
|
|
|
$list['total_price'] = $businessInfo['total_price'] ?: '0.00';
|
|
|
$list['discount_rate'] = $businessInfo['discount_rate'] ?: '0.00';
|
|
|
return resultArray(['data' => $list]);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 商机状态推进
|
|
|
* @param business_id 商机ID
|
|
|
* @param status_id 推进商机状态ID
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function advance()
|
|
|
{
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$is_end = $param['is_end'] ?: 0; //1赢单2输单3无效
|
|
|
$remark = $param['statusRemark'];
|
|
|
if (!$param['business_id']) {
|
|
|
return resultArray(['error' => '参数错误']);
|
|
|
}
|
|
|
$businessInfo = db('crm_business')->where(['business_id' => $param['business_id']])->find();
|
|
|
if ($businessInfo['is_end']) {
|
|
|
return resultArray(['error' => '已结束，不能推进']);
|
|
|
}
|
|
|
|
|
|
$data = [];
|
|
|
$data['update_time'] = time();
|
|
|
$data['is_end'] = $is_end;
|
|
|
$data['remark'] = $remark;
|
|
|
$data['check_status'] = 1;
|
|
|
$data['flow_id'] = 13;
|
|
|
$data['check_user_id'] = $param['check_user_id'];
|
|
|
$data['flow_user_id'] = $param['check_user_id'];
|
|
|
|
|
|
$res = db('crm_business')->where(['business_id' => $param['business_id']])->update($data);
|
|
|
if (!$res) {
|
|
|
return resultArray(['error' => '推进失败，请重试']);
|
|
|
}
|
|
|
return resultArray(['success' => '提交成功']);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 商机导出
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function excelExport()
|
|
|
{
|
|
|
$param = $this->param;
|
|
|
$userInfo = $this->userInfo;
|
|
|
$param['user_id'] = $userInfo['id'];
|
|
|
$action_name = '导出全部';
|
|
|
if ($param['business_id']) {
|
|
|
$param['business_id'] = ['condition' => 'in', 'value' => $param['business_id'], 'form_type' => 'text', 'name' => ''];
|
|
|
$param['is_excel'] = 1;
|
|
|
$action_name = '导出选中';
|
|
|
}
|
|
|
|
|
|
$excelModel = new \app\admin\model\Excel();
|
|
|
// 导出的字段列表
|
|
|
$fieldModel = new \app\admin\model\Field();
|
|
|
$field_list = $fieldModel->getIndexFieldConfig('crm_business', $userInfo['id']);
|
|
|
// 文件名
|
|
|
$file_name = '5kcrm_business_' . date('Ymd');
|
|
|
|
|
|
$model = model('Business');
|
|
|
$temp_file = $param['temp_file'];
|
|
|
unset($param['temp_file']);
|
|
|
$page = $param['page'] ?: 1;
|
|
|
unset($param['page']);
|
|
|
unset($param['export_queue_index']);
|
|
|
RecordActionLog($userInfo['id'], 'crm_customer', 'excelexport', $action_name, '', '', '导出商机');
|
|
|
return $excelModel->batchExportCsv($file_name, $temp_file, $field_list, $page, function ($page, $limit) use ($model, $param, $field_list) {
|
|
|
$param['page'] = $page;
|
|
|
$param['limit'] = $limit;
|
|
|
$data = $model->getDataList($param);
|
|
|
$data['list'] = $model->exportHandle($data['list'], $field_list, 'business');
|
|
|
return $data;
|
|
|
});
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 设置关注
|
|
|
*
|
|
|
* @return \think\response\Json
|
|
|
* @throws \think\Exception
|
|
|
* @throws \think\exception\PDOException
|
|
|
*/
|
|
|
public function star()
|
|
|
{
|
|
|
$userId = $this->userInfo['id'];
|
|
|
$targetId = $this->param['target_id'];
|
|
|
$type = $this->param['type'];
|
|
|
|
|
|
if (empty($userId) || empty($targetId) || empty($type)) return resultArray(['error' => '缺少必要参数！']);
|
|
|
|
|
|
if (!$this->setStar($type, $userId, $targetId)) {
|
|
|
return resultArray(['error' => '设置关注失败！']);
|
|
|
}
|
|
|
|
|
|
return resultArray(['data' => '设置关注成功！']);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 系统信息
|
|
|
*
|
|
|
* @return \think\response\Json
|
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
|
* @throws \think\exception\DbException
|
|
|
*/
|
|
|
public function system()
|
|
|
{
|
|
|
if (empty($this->param['id'])) return resultArray(['error' => '参数错误！']);
|
|
|
|
|
|
$businessModel = new \app\crm\model\Business();
|
|
|
|
|
|
$data = $businessModel->getSystemInfo($this->param['id']);
|
|
|
|
|
|
return resultArray(['data' => $data]);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* table栏数量统计
|
|
|
*
|
|
|
* @return \think\response\Json
|
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
|
* @throws \think\exception\DbException
|
|
|
*/
|
|
|
public function count()
|
|
|
{
|
|
|
if (empty($this->param['business_id'])) return resultArray(['error' => '参数错误！']);
|
|
|
|
|
|
$businessId = $this->param['business_id'];
|
|
|
|
|
|
$userInfo = $this->userInfo;
|
|
|
|
|
|
# 查询联系人和商机关联数据
|
|
|
$contactsIds = Db::name('crm_contacts_business')->where('business_id', $businessId)->column('contacts_id');
|
|
|
|
|
|
# 联系人
|
|
|
$contactsAuth = $this->getContactsSearchWhere($userInfo['id']);
|
|
|
$contactsCount = Db::name('crm_contacts')->whereIn('contacts_id', $contactsIds)->where($contactsAuth)->count();
|
|
|
|
|
|
# 合同
|
|
|
$contractAuth = $this->getContractSearchWhere($userInfo['id']);
|
|
|
$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');
|
|
|
|
|
|
# 产品
|
|
|
$productAuth = $this->getProductSearchWhere();
|
|
|
$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();
|
|
|
|
|
|
# 团队
|
|
|
$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['rw_user_id'] = explode(',', trim($business['rw_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'])));
|
|
|
|
|
|
$data = [
|
|
|
'contactCount' => $contactsCount,
|
|
|
'contractCount' => $contractCount,
|
|
|
'fileCount' => $fileCount,
|
|
|
'memberCount' => count($teamCount),
|
|
|
'productCount' => $productCount
|
|
|
];
|
|
|
|
|
|
return resultArray(['data' => $data]);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 设置首要联系人
|
|
|
*
|
|
|
* @return \think\response\Json
|
|
|
* @throws \think\Exception
|
|
|
* @throws \think\exception\PDOException
|
|
|
*/
|
|
|
public function setPrimary()
|
|
|
{
|
|
|
$businessId = $this->param['business_id'];
|
|
|
$contactsId = $this->param['contacts_id'];
|
|
|
|
|
|
if (empty($businessId) || empty($contactsId)) return resultArray(['error' => '参数错误！']);
|
|
|
|
|
|
if (!Db::name('crm_business')->where('business_id', $businessId)->update(['contacts_id' => $contactsId])) {
|
|
|
return resultArray(['error' => '操作失败！']);
|
|
|
}
|
|
|
|
|
|
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' => '推进失败，请重试']);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
