|
|
<?php
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Description: 产品
|
|
|
// +----------------------------------------------------------------------
|
|
|
// | Author: Michael_xu | gengxiaoxu@5kcrm.com
|
|
|
// +----------------------------------------------------------------------
|
|
|
namespace app\crm\model;
|
|
|
|
|
|
use think\Db;
|
|
|
use app\admin\model\Common;
|
|
|
use app\admin\model\User as UserModel;
|
|
|
use app\admin\model\File as FileModel;
|
|
|
use think\Request;
|
|
|
use think\Validate;
|
|
|
use traits\model\SoftDelete;
|
|
|
|
|
|
class Product extends Common
|
|
|
{
|
|
|
use SoftDelete;
|
|
|
|
|
|
protected $deleteTime = 'delete_time';
|
|
|
|
|
|
/**
|
|
|
* 为了数据库的整洁，同时又不影响Model和Controller的名称
|
|
|
* 我们约定每个模块的数据表都加上相同的前缀，比如CRM模块用crm作为数据表前缀
|
|
|
*/
|
|
|
protected $name = 'crm_product';
|
|
|
protected $createTime = 'create_time';
|
|
|
protected $updateTime = 'update_time';
|
|
|
protected $autoWriteTimestamp = true;
|
|
|
|
|
|
/**
|
|
|
* [getDataList 产品list]
|
|
|
*
|
|
|
* @param $request
|
|
|
* @return array
|
|
|
*/
|
|
|
public function getDataList($request)
|
|
|
{
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$structureModel = new \app\admin\model\Structure();
|
|
|
$fieldModel = new \app\admin\model\Field();
|
|
|
$search = $request['search'];
|
|
|
$user_id = $request['user_id'];
|
|
|
$is_excel = $request['is_excel']; //导出
|
|
|
$scene_id = (int)$request['scene_id'];
|
|
|
$order_field = $request['order_field'];
|
|
|
$order_type = $request['order_type'];
|
|
|
$isStatus = !empty($request['is_status']) ? $request['is_status'] : 0;
|
|
|
unset($request['scene_id']);
|
|
|
unset($request['search']);
|
|
|
unset($request['user_id']);
|
|
|
unset($request['order_field']);
|
|
|
unset($request['order_type']);
|
|
|
unset($request['is_status']);
|
|
|
|
|
|
$request = $this->fmtRequest($request);
|
|
|
$requestMap = $request['map'] ?: [];
|
|
|
|
|
|
$sceneModel = new \app\admin\model\Scene();
|
|
|
if ($scene_id) {
|
|
|
//自定义场景
|
|
|
$sceneMap = $sceneModel->getDataById($scene_id, $user_id, 'product') ?: [];
|
|
|
} else {
|
|
|
//默认场景
|
|
|
$sceneMap = $sceneModel->getDefaultData('crm_product', $user_id) ?: [];
|
|
|
}
|
|
|
if ($search || $search == '0') {
|
|
|
//普通筛选
|
|
|
$sceneMap['name'] = ['condition' => 'contains', 'value' => $search, 'form_type' => 'text', 'name' => '产品名称'];
|
|
|
}
|
|
|
//优先级：普通筛选>高级筛选>场景
|
|
|
$map = $requestMap ? array_merge($sceneMap, $requestMap) : $sceneMap;
|
|
|
//高级筛选
|
|
|
$map = where_arr($map, 'crm', 'product', 'index');
|
|
|
if (!empty($isStatus)) {
|
|
|
$map['product.status'] = '上架';
|
|
|
}
|
|
|
if (empty($map['product.delete_user_id'])) {
|
|
|
$map['product.delete_user_id'] = 0;
|
|
|
}
|
|
|
//权限
|
|
|
$a = 'index';
|
|
|
if ($is_excel) $a = 'excelExport';
|
|
|
$auth_user_ids = $userModel->getUserByPer('crm', 'product', $a);
|
|
|
//过滤权限
|
|
|
if (isset($map['product.owner_user_id']) && $map['product.owner_user_id'][0] != 'like') {
|
|
|
if (!is_array($map['product.owner_user_id'][1])) {
|
|
|
$map['product.owner_user_id'][1] = [$map['product.owner_user_id'][1]];
|
|
|
}
|
|
|
if (in_array($map['product.owner_user_id'][0], ['neq', 'notin'])) {
|
|
|
$auth_user_ids = array_diff($auth_user_ids, $map['product.owner_user_id'][1]) ?: []; //取差集
|
|
|
} else {
|
|
|
$auth_user_ids = array_intersect($map['product.owner_user_id'][1], $auth_user_ids) ?: []; //取交集
|
|
|
}
|
|
|
unset($map['product.owner_user_id']);
|
|
|
}
|
|
|
$auth_user_ids = array_merge(array_unique(array_filter($auth_user_ids))) ?: ['-1'];
|
|
|
//负责人
|
|
|
$authMap['product.owner_user_id'] = ['in', $auth_user_ids];
|
|
|
|
|
|
//列表展示字段
|
|
|
$indexField = $fieldModel->getIndexField('crm_product', $user_id, 1) ?: ['name'];
|
|
|
$userField = $fieldModel->getFieldByFormType('crm_product', 'user'); //人员类型
|
|
|
$structureField = $fieldModel->getFieldByFormType('crm_product', 'structure'); //部门类型
|
|
|
$datetimeField = $fieldModel->getFieldByFormType('crm_product', 'datetime'); //日期时间类型
|
|
|
# 处理人员和部门类型的排序报错问题(前端传来的是包含_name的别名字段)
|
|
|
$temporaryField = str_replace('_name', '', $order_field);
|
|
|
if (in_array($temporaryField, $userField) || in_array($temporaryField, $structureField)) {
|
|
|
$order_field = $temporaryField;
|
|
|
}
|
|
|
//排序
|
|
|
if ($order_type && $order_field) {
|
|
|
$order = $fieldModel->getOrderByFormtype('crm_product', 'product', $order_field, $order_type);
|
|
|
} else {
|
|
|
$order = 'product.update_time desc';
|
|
|
}
|
|
|
|
|
|
$join = [
|
|
|
['__CRM_PRODUCT_CATEGORY__ product_category', 'product_category.category_id = product.category_id', 'LEFT'],
|
|
|
];
|
|
|
$map['product.delete_user_id'] = 0;
|
|
|
$list = db('crm_product')->alias('product')
|
|
|
->join($join)
|
|
|
->where($map)
|
|
|
->where($authMap)
|
|
|
->limit($request['offset'], $request['length'])
|
|
|
->field($indexField)
|
|
|
->field('product.*,product_category.name as category_name')
|
|
|
->orderRaw($order)
|
|
|
->select();
|
|
|
$dataCount = db('crm_product')->alias('product')
|
|
|
->where($map)->where($authMap)
|
|
|
->count('product_id');
|
|
|
foreach ($list as $k => $v) {
|
|
|
$list[$k]['create_user_id_info'] = isset($v['create_user_id']) ? $userModel->getUserById($v['create_user_id']) : [];
|
|
|
$list[$k]['owner_user_id_info'] = isset($v['owner_user_id']) ? $userModel->getUserById($v['owner_user_id']) : [];
|
|
|
$list[$k]['create_user_name'] = !empty($list[$k]['create_user_id_info']['realname']) ? $list[$k]['create_user_id_info']['realname'] : '';
|
|
|
$list[$k]['owner_user_name'] = !empty($list[$k]['owner_user_id_info']['realname']) ? $list[$k]['owner_user_id_info']['realname'] : '';
|
|
|
foreach ($userField as $key => $val) {
|
|
|
$usernameField = !empty($v[$val]) ? db('admin_user')->whereIn('id', stringToArray($v[$val]))->column('realname') : [];
|
|
|
$list[$k][$val . '_name'] = implode($usernameField, ',');
|
|
|
}
|
|
|
foreach ($structureField as $key => $val) {
|
|
|
$structureNameField = !empty($v[$val]) ? db('admin_structure')->whereIn('id', stringToArray($v[$val]))->column('name') : [];
|
|
|
$list[$k][$val . '_name'] = implode($structureNameField, ',');
|
|
|
}
|
|
|
foreach ($datetimeField as $key => $val) {
|
|
|
$list[$k][$val] = !empty($v[$val]) ? date('Y-m-d H:i:s', $v[$val]) : null;
|
|
|
}
|
|
|
//产品类型
|
|
|
$list[$k]['category_id_info'] = $v['category_name'];
|
|
|
# 处理日期格式
|
|
|
$list[$k]['create_time'] = !empty($v['create_time']) ? date('Y-m-d H:i:s', $v['create_time']) : null;
|
|
|
$list[$k]['update_time'] = !empty($v['update_time']) ? date('Y-m-d H:i:s', $v['update_time']) : null;
|
|
|
}
|
|
|
$data = [];
|
|
|
$data['list'] = $list;
|
|
|
$data['dataCount'] = $dataCount ?: 0;
|
|
|
|
|
|
return $data;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 创建产品主表信息
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function createData($param)
|
|
|
{
|
|
|
$fieldModel = new \app\admin\model\Field();
|
|
|
$productCategoryModel = model('ProductCategory');
|
|
|
$dataInfo = db('crm_product')->where(['name' => $param['name'], 'delete_user_id' => 0])->find();
|
|
|
if (isset($dataInfo)) {
|
|
|
// 自动验证
|
|
|
$validateArr = $fieldModel->validateField($this->name); //获取自定义字段验证规则
|
|
|
$validate = new Validate($validateArr['rule'], $validateArr['message']);
|
|
|
|
|
|
$result = $validate->check($param);
|
|
|
if (!$result) {
|
|
|
$this->error = $validate->getError();
|
|
|
return false;
|
|
|
}
|
|
|
}
|
|
|
// 处理部门、员工、附件、多选类型字段
|
|
|
$arrFieldAtt = $fieldModel->getArrayField('crm_product');
|
|
|
foreach ($arrFieldAtt as $k => $v) {
|
|
|
$param[$v] = arrayToString($param[$v]);
|
|
|
}
|
|
|
// 处理日期（date）类型
|
|
|
$dateField = $fieldModel->getFieldByFormType('crm_product', 'date');
|
|
|
if (!empty($dateField)) {
|
|
|
foreach ($param as $key => $value) {
|
|
|
if (in_array($key, $dateField) && empty($value)) $param[$key] = null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//产品分类
|
|
|
$category_id = $param['category_id'];
|
|
|
|
|
|
if (is_array($category_id)) {
|
|
|
$param['category_id'] = $productCategoryModel->getIdByStr($category_id);
|
|
|
$param['category_str'] = arrayToString($category_id);
|
|
|
}
|
|
|
if (!is_int($category_id)) {
|
|
|
$list = db('crm_product_category')->column('category_id', 'name');
|
|
|
foreach ($list as $k => $v) {
|
|
|
if ($k == $param['category_id']) {
|
|
|
$param['category_id'] = $v;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if ($this->data($param)->allowField(true)->isUpdate(false)->save()) {
|
|
|
updateActionLog($param['create_user_id'], 'crm_product', $this->product_id, '', '', '创建了产品');
|
|
|
RecordActionLog($param['create_user_id'], 'crm_product', 'save', $param['name'], '', '', '新增了产品' . $param['name']);
|
|
|
$data = [];
|
|
|
$data['product_id'] = $this->product_id;
|
|
|
return $data;
|
|
|
} else {
|
|
|
$this->error = '添加失败';
|
|
|
return false;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 编辑产品主表信息
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function updateDataById($param, $product_id = '')
|
|
|
{
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$dataInfo = $this->getDataById($product_id);
|
|
|
$productCategoryModel = model('ProductCategory');
|
|
|
if (!$dataInfo) {
|
|
|
$this->error = '数据不存在或已删除';
|
|
|
return false;
|
|
|
}
|
|
|
//判断权限
|
|
|
$auth_user_ids = $userModel->getUserByPer('crm', 'product', 'update');
|
|
|
if (!in_array($dataInfo['owner_user_id'], $auth_user_ids)) {
|
|
|
$this->error = '无权操作';
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
$param['product_id'] = $product_id;
|
|
|
//过滤不能修改的字段
|
|
|
$unUpdateField = ['create_user_id', 'is_deleted'];
|
|
|
foreach ($unUpdateField as $v) {
|
|
|
unset($param[$v]);
|
|
|
}
|
|
|
|
|
|
$fieldModel = new \app\admin\model\Field();
|
|
|
// 自动验证
|
|
|
// $validateArr = $fieldModel->validateField($this->name); //获取自定义字段验证规则
|
|
|
$validateArr = $fieldModel->validateField($this->name, 0, 'update'); //获取自定义字段验证规则
|
|
|
$validate = new Validate($validateArr['rule'], $validateArr['message']);
|
|
|
|
|
|
$result = $validate->check($param);
|
|
|
if (!$result) {
|
|
|
$this->error = $validate->getError();
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
|
|
|
// 处理部门、员工、附件、多选类型字段
|
|
|
$arrFieldAtt = $fieldModel->getArrayField('crm_product');
|
|
|
foreach ($arrFieldAtt as $k => $v) {
|
|
|
if (isset($param[$v])) $param[$v] = arrayToString($param[$v]);
|
|
|
}
|
|
|
// 处理日期（date）类型
|
|
|
$dateField = $fieldModel->getFieldByFormType('crm_product', 'date');
|
|
|
if (!empty($dateField)) {
|
|
|
foreach ($param as $key => $value) {
|
|
|
if (in_array($key, $dateField) && empty($value)) $param[$key] = null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//产品分类
|
|
|
$category_id = $param['category_id'];
|
|
|
// if (is_array($category_id)) {
|
|
|
// $param['category_id'] = $productCategoryModel->getIdByStr($category_id);
|
|
|
// $param['category_str'] = arrayToString($category_id);
|
|
|
// }
|
|
|
if (!is_int($category_id)) {
|
|
|
$list = db('crm_product_category')->column('category_id', 'name');
|
|
|
$param['category_id'] = 1;
|
|
|
foreach ($list as $k => $v) {
|
|
|
if ($k == $category_id) {
|
|
|
$param['category_id'] = $v;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
if ($this->update($param, ['product_id' => $product_id], true)) {
|
|
|
//修改记录
|
|
|
updateActionLog($param['user_id'], 'crm_product', $product_id, $dataInfo, $param);
|
|
|
RecordActionLog($param['user_id'], 'crm_product', 'update', $dataInfo['name'], $dataInfo, $param);
|
|
|
$data = [];
|
|
|
$data['product_id'] = $product_id;
|
|
|
return $data;
|
|
|
} else {
|
|
|
$this->rollback();
|
|
|
$this->error = '编辑失败';
|
|
|
return false;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 产品数据
|
|
|
*
|
|
|
* @param string $id
|
|
|
* @return Common|array|bool|\PDOStatement|string|\think\Model|null
|
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
|
* @throws \think\exception\DbException
|
|
|
*/
|
|
|
public function getDataById($id = '', $userId = 0)
|
|
|
{
|
|
|
$map['product_id'] = $id;
|
|
|
$map['delete_user_id'] = 0;
|
|
|
$dataInfo = db('crm_product')->where($map)->find();
|
|
|
if (!$dataInfo) {
|
|
|
$this->error = '暂无此数据';
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
# 获取封面图片
|
|
|
$dataInfo['cover_images'] = $this->getProductImages($dataInfo['cover_images']);
|
|
|
# 获取详情图片
|
|
|
$dataInfo['details_images'] = $this->getProductImages($dataInfo['details_images']);
|
|
|
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$dataInfo['create_user_id_info'] = $userModel->getUserById($dataInfo['create_user_id']);
|
|
|
$dataInfo['category_id_info'] = db('crm_product_category')->where(['category_id' => $dataInfo['category_id']])->value('name');
|
|
|
# 处理日期格式
|
|
|
$fieldModel = new \app\admin\model\Field();
|
|
|
$datetimeField = $fieldModel->getFieldByFormType('crm_product', 'datetime'); //日期时间类型
|
|
|
foreach ($datetimeField as $key => $val) {
|
|
|
$dataInfo[$val] = !empty($dataInfo[$val]) ? date('Y-m-d H:i:s', $dataInfo[$val]) : null;
|
|
|
}
|
|
|
$dataInfo['create_time'] = !empty($dataInfo['create_time']) ? date('Y-m-d H:i:s', $dataInfo['create_time']) : null;
|
|
|
$dataInfo['update_time'] = !empty($dataInfo['update_time']) ? date('Y-m-d H:i:s', $dataInfo['update_time']) : null;
|
|
|
// 字段授权
|
|
|
if (!empty($userId)) {
|
|
|
$grantData = getFieldGrantData($userId);
|
|
|
$userLevel = isSuperAdministrators($userId);
|
|
|
foreach ($dataInfo as $key => $value) {
|
|
|
if (!$userLevel && !empty($grantData['crm_product'])) {
|
|
|
$status = getFieldGrantStatus($key, $grantData['crm_product']);
|
|
|
|
|
|
# 查看权限
|
|
|
if ($status['read'] == 0) unset($dataInfo[$key]);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
return $dataInfo;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 获取产品图片
|
|
|
*
|
|
|
* @param $fileIds
|
|
|
* @return array
|
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
|
* @throws \think\exception\DbException
|
|
|
*/
|
|
|
private function getProductImages($fileIds)
|
|
|
{
|
|
|
$files = Db::name('admin_file')->whereIn('file_id', $fileIds)->select();
|
|
|
|
|
|
foreach ($files as $key => $value) {
|
|
|
$files[$key]['file_path'] = getFullPath($value['file_path']);
|
|
|
$files[$key]['file_path_thumb'] = getFullPath($value['file_path_thumb']);
|
|
|
$files[$key]['size'] = format_bytes($value['size']);
|
|
|
}
|
|
|
|
|
|
return $files;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 相关产品创建（商机、合同相关产品数据）
|
|
|
* @param types 类型
|
|
|
* @param param['product'] 产品相关数据
|
|
|
* @param price 产品单价
|
|
|
* @param sales_price 销售价格
|
|
|
* @param num 数量
|
|
|
* @param discount 折扣
|
|
|
* @param subtotal 小计（折扣后价格）
|
|
|
* @param unit 单位
|
|
|
* @param total_price 折扣后整单总价
|
|
|
* @param discount_rate 整单折扣
|
|
|
* @param objId 关联对象ID
|
|
|
* @return
|
|
|
*/
|
|
|
public function createObject($types, $param, $objId)
|
|
|
{
|
|
|
switch ($types) {
|
|
|
case 'crm_business' :
|
|
|
$db = 'crm_business_product';
|
|
|
$rDb = 'crm_business';
|
|
|
$db_id = 'business_id';
|
|
|
break;
|
|
|
case 'crm_contract' :
|
|
|
$db = 'crm_contract_product';
|
|
|
$rDb = 'crm_contract';
|
|
|
$db_id = 'contract_id';
|
|
|
break;
|
|
|
default :
|
|
|
$this->error = '参数错误';
|
|
|
return false;
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
$total_price = 0;
|
|
|
|
|
|
if ($param['product']) {
|
|
|
$product = [];
|
|
|
// 启动事务
|
|
|
Db::startTrans();
|
|
|
try {
|
|
|
foreach ($param['product'] as $key => $value) {
|
|
|
$discount = 0;
|
|
|
// $discount = ((100 - $value['discount']) > 0) ? (100 - $value['discount'])/100 : 0; //折扣
|
|
|
$product[$key]['product_id'] = $value['product_id'];
|
|
|
$product[$key]['price'] = $value['price']; //产品单价
|
|
|
$product[$key]['sales_price'] = $value['sales_price']; //售价
|
|
|
$product[$key]['num'] = $value['num']; //数量
|
|
|
$product[$key]['discount'] = $value['discount']; //折扣
|
|
|
$product[$key]['unit'] = $value['unit'] ?: ''; //单位
|
|
|
$product[$key]['subtotal'] = $value['subtotal'];
|
|
|
// $total_price += $product[$key]['subtotal'] = round(($value['price'] * $value['num']) * $discount); //总价
|
|
|
$product[$key][$db_id] = $objId;
|
|
|
}
|
|
|
|
|
|
//删除
|
|
|
db($db)->where([$db_id => $objId])->delete(); //原数据删除
|
|
|
//新增
|
|
|
db($db)->insertAll($product);
|
|
|
|
|
|
$rData = [];
|
|
|
//产品合计
|
|
|
$rData['discount_rate'] = !empty($param['discount_rate']) ? $param['discount_rate'] : 0.00; //整单折扣
|
|
|
$discount_rate = ((100 - $rData['discount_rate']) > 0) ? (100 - $rData['discount_rate']) / 100 : 0;
|
|
|
// $rData['total_price'] = $total_price ? $total_price*$discount_rate : '0.00'; //整单合计
|
|
|
$rData['total_price'] = $param['total_price'] ?: '0.00'; //整单合计
|
|
|
db($rDb)->where([$db_id => $objId])->update($rData);
|
|
|
|
|
|
// 提交事务
|
|
|
Db::commit();
|
|
|
return true;
|
|
|
} catch (\Exception $e) {
|
|
|
$this->error = '产品数据创建出错';
|
|
|
// 回滚事务
|
|
|
Db::rollback();
|
|
|
return false;
|
|
|
}
|
|
|
} else {
|
|
|
//删除产品信息
|
|
|
db($db)->where([$db_id => $objId])->delete();
|
|
|
return true;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* [产品统计]
|
|
|
*
|
|
|
* @param $param
|
|
|
* @return mixed
|
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
|
* @throws \think\exception\DbException
|
|
|
*/
|
|
|
public function getStatistics($param)
|
|
|
{
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$adminModel = new \app\admin\model\Admin();
|
|
|
|
|
|
$perUserIds = $userModel->getUserByPer('bi', 'product', 'read'); //权限范围内userIds
|
|
|
$whereData = $adminModel->getWhere($param, '', $perUserIds); //统计条件
|
|
|
$userIds = $whereData['userIds'];
|
|
|
$between_time = $whereData['between_time'];
|
|
|
$where = [];
|
|
|
//时间段
|
|
|
$where['contract.create_time'] = ['between', $between_time];
|
|
|
$where['contract.owner_user_id'] = ['in', $userIds];
|
|
|
|
|
|
$join = [
|
|
|
['__CRM_CONTRACT__ contract', 'contract.contract_id = a.contract_id', 'LEFT'],
|
|
|
['__CRM_PRODUCT__ product', 'product.product_id = a.product_id', 'LEFT'],
|
|
|
['__CRM_PRODUCT_CATEGORY__ product_category', 'product_category.category_id = product.category_id', 'LEFT'],
|
|
|
];
|
|
|
|
|
|
$sql = db('crm_contract_product')
|
|
|
->alias('a')
|
|
|
->where($where)
|
|
|
->join($join)
|
|
|
->field([
|
|
|
'a.contract_id,
|
|
|
a.product_id,
|
|
|
product.name as product_name,
|
|
|
contract.owner_user_id,
|
|
|
product_category.category_id,
|
|
|
product_category.name as category_id_info,
|
|
|
count(a.r_id) as contract_product_sum,
|
|
|
sum(contract.money)as contract_money,
|
|
|
sum(a.num) as product_sum'
|
|
|
])
|
|
|
->group('product.product_id')
|
|
|
->order('category_id,product_name')
|
|
|
->fetchSql()
|
|
|
->select();
|
|
|
$dataCount=db('crm_contract_product')
|
|
|
->alias('a')
|
|
|
->where($where)
|
|
|
->join($join)
|
|
|
->group('product.category_id')->count();
|
|
|
$list = queryCache($sql);
|
|
|
$contract_product_sum = 0;
|
|
|
$product_sum = 0;
|
|
|
$contract_money = 0;
|
|
|
foreach ($list as $k => $v) {
|
|
|
$contract_product_sum += $v['contract_product_sum'];
|
|
|
$product_sum += (int)$v['product_sum'];
|
|
|
$contract_money += $v['contract_money'];
|
|
|
}
|
|
|
$data=[];
|
|
|
$data['list']=$list;
|
|
|
$data['count']=$dataCount;
|
|
|
$data['total'] = [
|
|
|
'realname' => '总计',
|
|
|
'contract_product_sum' => $contract_product_sum,
|
|
|
'product_sum' => $product_sum,
|
|
|
'contract_money' => $contract_money];
|
|
|
return $data;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 产品销售分析列表
|
|
|
* @param $param
|
|
|
*
|
|
|
* @author alvin guogaobo
|
|
|
* @version 1.0 版本号
|
|
|
* @since 2021/4/20 0020 16:14
|
|
|
*/
|
|
|
public function listProduct($param){
|
|
|
$userModel = new \app\admin\model\User();
|
|
|
$fieldModel = new \app\admin\model\Field();
|
|
|
$receivablesModel = new \app\crm\model\Receivables();
|
|
|
$adminModel = new \app\admin\model\Admin();
|
|
|
$perUserIds = $userModel->getUserByPer('bi', 'product', 'read'); //权限范围内userIds
|
|
|
$whereData = $adminModel->getWhere($param, '', $perUserIds); //统计条件
|
|
|
$userIds = $whereData['userIds'];
|
|
|
$between_time = $whereData['between_time'];
|
|
|
$where = [];
|
|
|
//时间段
|
|
|
$where['contract.create_time'] = ['between', $between_time];
|
|
|
$where['contract.owner_user_id'] = ['in', $userIds];
|
|
|
|
|
|
$search=$param['search'];
|
|
|
$join = [
|
|
|
['__CRM_BUSINESS__ business','contract.business_id = business.business_id','LEFT'],
|
|
|
['CrmReceivables receivables','receivables.contract_id = contract.contract_id AND receivables.check_status = 2','LEFT'],
|
|
|
['__CRM_CONTACTS__ contacts','contract.contacts_id = contacts.contacts_id','LEFT'],
|
|
|
['__CRM_CUSTOMER__ customer','contract.customer_id = customer.customer_id','LEFT'],
|
|
|
];
|
|
|
//列表展示字段
|
|
|
$indexField = $fieldModel->getIndexField('crm_contract', '', 1) ? : array('name');
|
|
|
foreach ($indexField AS $kk => $vv) {
|
|
|
if ($vv == 'contract.customer_name') unset($indexField[(int)$kk]);
|
|
|
if ($vv == 'contract.business_name') unset($indexField[(int)$kk]);
|
|
|
}
|
|
|
if ($search) {
|
|
|
//普通筛选
|
|
|
$searchWhere = function ($query) use ($search) {
|
|
|
$query->where(function ($query) use ($search){
|
|
|
$query->whereLike('customer.name', '%' . $search . '%');
|
|
|
})->whereOr(function ($query) use ($search) {
|
|
|
$query->whereLike('contract.num', '%' . $search . '%');
|
|
|
})->whereOr(function ($query) use ($search) {
|
|
|
$query->whereLike('contract.name', '%' . $search . '%');
|
|
|
});
|
|
|
};
|
|
|
}
|
|
|
$contract_product=db('crm_contract_product')
|
|
|
->where('product_id',$param['product_id'])
|
|
|
->column('contract_id');
|
|
|
$list=db('crm_contract')
|
|
|
->alias('contract')
|
|
|
->join($join)
|
|
|
->where($where)
|
|
|
->where('contract.contract_id',['in',trim(arrayToString($contract_product),',')])
|
|
|
->where($searchWhere)
|
|
|
->field(array_merge($indexField, [
|
|
|
'customer.name' => 'customer_name',
|
|
|
'business.name' => 'business_name',
|
|
|
'contacts.name' => 'contacts_name',
|
|
|
'ifnull(SUM(receivables.money), 0)' => 'done_money',
|
|
|
'(contract.money - ifnull(SUM(receivables.money), 0))' => 'un_money',
|
|
|
]))
|
|
|
->group('contract.contract_id')
|
|
|
->page($param['page'],$param['limit'])
|
|
|
->select();
|
|
|
$dataCount=db('crm_contract')
|
|
|
->alias('contract')
|
|
|
->join($join)
|
|
|
->where($where)
|
|
|
->where('contract.contract_id',['in',trim(arrayToString($contract_product),',')])
|
|
|
->where($searchWhere)
|
|
|
->count();
|
|
|
$userField = $fieldModel->getFieldByFormType('crm_contract', 'user');
|
|
|
$structureField = $fieldModel->getFieldByFormType('crm_contract', 'structure'); //部门类型
|
|
|
$datetimeField = $fieldModel->getFieldByFormType('crm_contract', 'datetime'); //日期时间类型
|
|
|
$readAuthIds = $userModel->getUserByPer('crm', 'contract', 'read');
|
|
|
$updateAuthIds = $userModel->getUserByPer('crm', 'contract', 'update');
|
|
|
$deleteAuthIds = $userModel->getUserByPer('crm', 'contract', 'delete');
|
|
|
foreach ($list as $k=>$v) {
|
|
|
$list[$k]['create_user_id_info'] = isset($v['create_user_id']) ? $userModel->getUserById($v['create_user_id']) : [];
|
|
|
$list[$k]['owner_user_id_info'] = isset($v['owner_user_id']) ? $userModel->getUserById($v['owner_user_id']) : [];
|
|
|
$list[$k]['create_user_name'] = !empty($list[$k]['create_user_id_info']['realname']) ? $list[$k]['create_user_id_info']['realname'] : '';
|
|
|
$list[$k]['owner_user_name'] = !empty($list[$k]['owner_user_id_info']['realname']) ? $list[$k]['owner_user_id_info']['realname'] : '';
|
|
|
foreach ($userField as $key => $val) {
|
|
|
$usernameField = !empty($v[$val]) ? db('admin_user')->whereIn('id', stringToArray($v[$val]))->column('realname') : [];
|
|
|
$list[$k][$val.'_name'] = implode($usernameField, ',');
|
|
|
}
|
|
|
foreach ($structureField as $key => $val) {
|
|
|
$structureNameField = !empty($v[$val]) ? db('admin_structure')->whereIn('id', stringToArray($v[$val]))->column('name') : [];
|
|
|
$list[$k][$val.'_name'] = implode($structureNameField, ',');
|
|
|
}
|
|
|
foreach ($datetimeField as $key => $val) {
|
|
|
$list[$k][$val] = !empty($v[$val]) ? date('Y-m-d H:i:s', $v[$val]) : null;
|
|
|
}
|
|
|
$list[$k]['business_id_info']['business_id'] = $v['business_id'];
|
|
|
$list[$k]['business_id_info']['name'] = $v['business_name'];
|
|
|
$list[$k]['customer_id_info']['customer_id'] = $v['customer_id'];
|
|
|
$list[$k]['customer_id_info']['name'] = $v['customer_name'];
|
|
|
$list[$k]['contacts_id_info']['contacts_id'] = $v['contacts_id'];
|
|
|
$list[$k]['contacts_id_info']['name'] = $v['contacts_name'];
|
|
|
$moneyInfo = [];
|
|
|
$moneyInfo = $receivablesModel->getMoneyByContractId($v['contract_id']);
|
|
|
$list[$k]['unMoney'] = $moneyInfo['doneMoney'] ? : '0.00';
|
|
|
if ($list[$k]['un_money'] < 0) $list[$k]['un_money'] = '0.00';
|
|
|
$planInfo = [];
|
|
|
$planInfo = db('crm_receivables_plan')->where(['contract_id' => $v['contract_id']])->find();
|
|
|
$list[$k]['receivables_id'] = $planInfo['receivables_id'] ? : '';
|
|
|
$list[$k]['remind_date'] = $planInfo['remind_date'] ? : '';
|
|
|
$list[$k]['return_date'] = $planInfo['return_date'] ? : '';
|
|
|
//权限
|
|
|
$roPre = $userModel->rwPre($user_id, $v['ro_user_id'], $v['rw_user_id'], 'read');
|
|
|
$rwPre = $userModel->rwPre($user_id, $v['ro_user_id'], $v['rw_user_id'], 'update');
|
|
|
$permission = [];
|
|
|
$is_read = 0;
|
|
|
$is_update = 0;
|
|
|
$is_delete = 0;
|
|
|
if (in_array($v['owner_user_id'],$readAuthIds) || $roPre || $rwPre) $is_read = 1;
|
|
|
if (in_array($v['owner_user_id'],$updateAuthIds) || $rwPre) $is_update = 1;
|
|
|
if (in_array($v['owner_user_id'],$deleteAuthIds)) $is_delete = 1;
|
|
|
$permission['is_read'] = $is_read;
|
|
|
$permission['is_update'] = $is_update;
|
|
|
$permission['is_delete'] = $is_delete;
|
|
|
$list[$k]['permission'] = $permission;
|
|
|
# 下次联系时间
|
|
|
$list[$k]['next_time'] = !empty($v['next_time']) ? date('Y-m-d H:i:s', $v['next_time']) : null;
|
|
|
# 日期
|
|
|
$list[$k]['create_time'] = !empty($v['create_time']) ? date('Y-m-d H:i:s', $v['create_time']) : null;
|
|
|
$list[$k]['update_time'] = !empty($v['update_time']) ? date('Y-m-d H:i:s', $v['update_time']) : null;
|
|
|
$list[$k]['last_time'] = !empty($v['last_time']) ? date('Y-m-d H:i:s', $v['last_time']) : null;
|
|
|
$list[$k]['order_date'] = ($v['order_date']!='0000-00-00') ? $v['order_date'] : null;
|
|
|
$list[$k]['start_time'] = ($v['start_time']!='0000-00-00') ? $v['start_time'] : null;
|
|
|
$list[$k]['end_time'] = ($v['end_time']!='0000-00-00') ? $v['end_time'] : null;
|
|
|
# 签约人姓名
|
|
|
$orderNames = Db::name('admin_user')->whereIn('id', trim($v['order_user_id'], ','))->column('realname');
|
|
|
$list[$k]['order_user_name'] = implode(',', $orderNames);
|
|
|
}
|
|
|
$data = [];
|
|
|
$data['list'] = $list;
|
|
|
$data['dataCount'] = $dataCount ? : 0;
|
|
|
return $data;
|
|
|
}
|
|
|
/**
|
|
|
* [根据产品类别ID，查询父级ID]
|
|
|
* @param
|
|
|
* @return
|
|
|
* @author Michael_xu
|
|
|
*/
|
|
|
public function getPidStr($category_id, $idArr, $first = '')
|
|
|
{
|
|
|
if ($first == 1) $idArr = [];
|
|
|
$idArr[] = $category_id;
|
|
|
$pid = db('crm_product_category')->where(['category_id' => $category_id])->value('pid');
|
|
|
if ($pid) {
|
|
|
$idArr[] = $pid;
|
|
|
$this->getPidStr($pid, $idArr);
|
|
|
}
|
|
|
$arr = array_reverse($idArr);
|
|
|
$resStr = ',' . implode(',', $arr) . ',';
|
|
|
return $resStr;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 删除当前的记录
|
|
|
*
|
|
|
* @overwrite 重写 traits\model\SoftDelete\delete
|
|
|
* @param boolean $force 是否强制删除
|
|
|
* @return integer
|
|
|
* @author Ymob
|
|
|
* @datetime 2019-10-24 15:02:22
|
|
|
*/
|
|
|
public function delete($force = false)
|
|
|
{
|
|
|
if (false === $this->trigger('before_delete', $this)) {
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
$name = $this->getDeleteTimeField();
|
|
|
if ($name && !$force) {
|
|
|
// 软删除
|
|
|
$this->data[$name] = $this->autoWriteTimestamp($name);
|
|
|
$this->data['delete_user_id'] = UserModel::userInfo('id');
|
|
|
$result = $this->isUpdate()->save();
|
|
|
} else {
|
|
|
// 强制删除当前模型数据
|
|
|
$result = $this->getQuery()->where($this->getWhere())->delete();
|
|
|
}
|
|
|
|
|
|
// 关联删除
|
|
|
if (!empty($this->relationWrite)) {
|
|
|
foreach ($this->relationWrite as $key => $name) {
|
|
|
$name = is_numeric($key) ? $name : $key;
|
|
|
$result = $this->getRelation($name);
|
|
|
if ($result instanceof Model) {
|
|
|
$result->delete();
|
|
|
} elseif ($result instanceof Collection || is_array($result)) {
|
|
|
foreach ($result as $model) {
|
|
|
$model->delete();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$this->trigger('after_delete', $this);
|
|
|
|
|
|
// 清空原始数据
|
|
|
$this->origin = [];
|
|
|
|
|
|
return $result;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 获取系统信息
|
|
|
*
|
|
|
* @param $id
|
|
|
* @return array
|
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
|
* @throws \think\exception\DbException
|
|
|
*/
|
|
|
public function getSystemInfo($id)
|
|
|
{
|
|
|
# 产品
|
|
|
$product = Db::name('crm_product')->field(['create_user_id', 'create_time', 'update_time'])->where('product_id', $id)->find();
|
|
|
# 创建人
|
|
|
$realname = Db::name('admin_user')->where('id', $product['create_user_id'])->value('realname');
|
|
|
|
|
|
return [
|
|
|
'create_user_id' => $realname,
|
|
|
'create_time' => date('Y-m-d H:i:s', $product['create_time']),
|
|
|
'update_time' => date('Y-m-d H:i:s', $product['update_time'])
|
|
|
];
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 转移
|
|
|
*
|
|
|
* @param $param
|
|
|
* @return int|string
|
|
|
* @throws \think\Exception
|
|
|
* @throws \think\exception\PDOException
|
|
|
*/
|
|
|
public function transfer($param)
|
|
|
{
|
|
|
return Db::name('crm_product')->whereIn('product_id', $param['product_id'])->update(['owner_user_id' => $param['owner_user_id']]);
|
|
|
}
|
|
|
}
|
