You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
360 lines
13 KiB
360 lines
13 KiB
4 years ago
|
<?php
|
||
|
|
// +----------------------------------------------------------------------
|
||
|
|
// | Description: 商业智能-员工业绩分析
|
||
|
|
// +----------------------------------------------------------------------
|
||
|
|
// | Author: Michael_xu | gengxiaoxu@5kcrm.com
|
||
|
|
// +----------------------------------------------------------------------
|
||
|
|
|
||
|
|
namespace app\bi\controller;
|
||
|
|
|
||
|
|
use app\admin\controller\ApiCommon;
|
||
|
|
use app\bi\traits\SortTrait;
|
||
|
|
use app\crm\model\Contract as ContractModel;
|
||
|
|
use app\crm\model\Receivables as ReceivablesModel;
|
||
|
|
use think\Db;
|
||
|
|
use think\Hook;
|
||
|
|
use think\Request;
|
||
|
|
use app\bi\logic\ExcelLogic;
|
||
|
|
class Contract extends ApiCommon
|
||
|
|
{
|
||
|
|
use SortTrait;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 用于判断权限
|
||
|
|
* @permission 无限制
|
||
|
|
* @allow 登录用户可访问
|
||
|
|
* @other 其他根据系统设置
|
||
|
|
**/
|
||
|
|
public function _initialize()
|
||
|
|
{
|
||
|
|
$action = [
|
||
|
|
'permission' => [''],
|
||
|
|
'allow' => [
|
||
|
|
'analysis',
|
||
|
|
'summary',
|
||
|
|
'invoice',
|
||
|
|
'excelexport'
|
||
|
|
]
|
||
|
|
];
|
||
|
|
Hook::listen('check_auth', $action);
|
||
|
|
$request = Request::instance();
|
||
|
|
$a = strtolower($request->action());
|
||
|
|
if (!in_array($a, $action['permission'])) {
|
||
|
|
parent::_initialize();
|
||
|
|
}
|
||
|
|
if (!checkPerByAction('bi', 'contract', 'read')) {
|
||
|
|
header('Content-Type:application/json; charset=utf-8');
|
||
|
|
exit(json_encode(['code' => 102, 'error' => '无权操作']));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 合同数量分析/金额分析/回款金额分析
|
||
|
|
*
|
||
|
|
* @param string $param
|
||
|
|
* @return array|\think\response\Json
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
* @throws \think\exception\DbException
|
||
|
|
*/
|
||
|
|
public function analysis($param='')
|
||
|
|
{
|
||
|
|
$userModel = new \app\admin\model\User();
|
||
|
|
$adminModel = new \app\admin\model\Admin();
|
||
|
|
if ($param['excel_type'] != 1) {
|
||
|
|
$param = $this->param;
|
||
|
|
}
|
||
|
|
|
||
|
|
$perUserIds = $userModel->getUserByPer('bi', 'contract', 'read'); // 权限范围内userIds
|
||
|
|
$whereArr = $adminModel->getWhere($param, '', $perUserIds); // 统计条件
|
||
|
|
$userIds = $whereArr['userIds'];
|
||
|
|
|
||
|
|
$year = !empty($param['year']) ? $param['year'] : date('Y');
|
||
|
|
$start_time = strtotime(date(($year - 1) . '-01-01'));
|
||
|
|
$end_time = strtotime('+2 year', $start_time) - 1;
|
||
|
|
$time = getTimeArray($start_time, $end_time);
|
||
|
|
|
||
|
|
if ($param['type'] == 'back' || $param['excel_type'] == 'back') {
|
||
|
|
$model = new ReceivablesModel;
|
||
|
|
$time_field = 'return_time';
|
||
|
|
} else {
|
||
|
|
$model = new ContractModel;
|
||
|
|
$time_field = 'order_date';
|
||
|
|
}
|
||
|
|
if ($param['type'] == 'count' || $param['$excel_type'] == 'count') {
|
||
|
|
$field['COUNT(*)'] = 'total';
|
||
|
|
} else {
|
||
|
|
$field['SUM(`money`)'] = 'total';
|
||
|
|
}
|
||
|
|
$between_time = [date('Y-m-d', $time['between'][0]), date('Y-m-d', $time['between'][1])];
|
||
|
|
$field["SUBSTR(`{$time_field}`, 1, 7)"] = 'type';
|
||
|
|
$sql = $model->field($field)
|
||
|
|
->where([
|
||
|
|
'owner_user_id' => ['IN', $userIds],
|
||
|
|
'check_status' => 2,
|
||
|
|
$time_field => ['BETWEEN', $between_time]
|
||
|
|
])
|
||
|
|
->group('type')
|
||
|
|
->fetchSql()
|
||
|
|
->select();
|
||
|
|
$res = queryCache($sql);
|
||
|
|
$res = array_column($res, null, 'type');
|
||
|
|
|
||
|
|
$data = [];
|
||
|
|
for ($i = 12; $i < 24; $i++) {
|
||
|
|
$k = $time['list'][$i]['type'];
|
||
|
|
$k2 = $time['list'][$i - 1]['type'];
|
||
|
|
$k3 = $time['list'][$i - 12]['type'];
|
||
|
|
$item['month'] = ($i - 11) < 10 ? $param['year']. '0' . $i - 11 : $param['year'] . $i - 11;
|
||
|
|
|
||
|
|
$item['thisMonth'] = $res[$k] ? $res[$k]['total'] : 0; # 本月
|
||
|
|
$item['lastMonthGrowth'] = $res[$k2] ? $res[$k2]['total'] : 0; # 上月
|
||
|
|
$item['lastYearGrowth'] = $res[$k3] ? $res[$k3]['total'] : 0; # 上年本月
|
||
|
|
|
||
|
|
# 环比
|
||
|
|
$item['chain_ratio'] = $item['thisMonth'] && $item['lastMonthGrowth'] ? round(($item['thisMonth'] / $item['lastMonthGrowth']) * 100, 4) : 0;
|
||
|
|
# 同比
|
||
|
|
$item['year_on_year'] = $item['thisMonth'] && $item['lastYearGrowth'] ? round(($item['thisMonth'] / $item['lastYearGrowth']) * 100, 4) : 0;
|
||
|
|
|
||
|
|
$data[] = $item;
|
||
|
|
}
|
||
|
|
//导出使用
|
||
|
|
if (!empty($param['excel_type'])) {
|
||
|
|
return $data;
|
||
|
|
}
|
||
|
|
return resultArray(['data' => $data]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 合同汇总表
|
||
|
|
*
|
||
|
|
* @return \think\response\Json
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
* @throws \think\exception\DbException
|
||
|
|
*/
|
||
|
|
public function summary($param='')
|
||
|
|
{
|
||
|
|
$userModel = new \app\admin\model\User();
|
||
|
|
$adminModel = new \app\admin\model\Admin();
|
||
|
|
if($param['excel_type']!=1){
|
||
|
|
$param = $this->param;
|
||
|
|
}
|
||
|
|
|
||
|
|
$perUserIds = $userModel->getUserByPer('bi', 'contract', 'read'); //权限范围内userIds
|
||
|
|
$whereArr = $adminModel->getWhere($param, '', $perUserIds); //统计条件
|
||
|
|
$userIds = $whereArr['userIds'];
|
||
|
|
|
||
|
|
if (empty($param['type']) && empty($param['start_time'])) {
|
||
|
|
$param['type'] = 'month';
|
||
|
|
}
|
||
|
|
|
||
|
|
$sortField = !empty($param['sort_field']) ? $param['sort_field'] : '';
|
||
|
|
$sortValue = !empty($param['sort_value']) ? $param['sort_value'] : '';
|
||
|
|
unset($param['sort_field']);
|
||
|
|
unset($param['sort_value']);
|
||
|
|
|
||
|
|
$year = !empty($param['year']) ? $param['year'] : date('Y');
|
||
|
|
$start_time = strtotime($year . '-01-01');
|
||
|
|
$end_time = strtotime('+1 year', $start_time) - 1;
|
||
|
|
$time = getTimeArray($start_time, $end_time);
|
||
|
|
$ax = 7;
|
||
|
|
if ($time['time_format'] == '%Y-%m-%d') {
|
||
|
|
$ax = 10;
|
||
|
|
}
|
||
|
|
$between_time = [date('Y-m-d', $time['between'][0]), date('Y-m-d', $time['between'][1])];
|
||
|
|
$sql = ContractModel::field([
|
||
|
|
'SUBSTR(`order_date`, 1, ' . $ax . ')' => 'type',
|
||
|
|
'COUNT(*)' => 'count',
|
||
|
|
'SUM(`money`)' => 'money'
|
||
|
|
])
|
||
|
|
->where([
|
||
|
|
'owner_user_id' => ['IN', $userIds],
|
||
|
|
'check_status' => 2,
|
||
|
|
'order_date' => ['BETWEEN', $between_time]
|
||
|
|
])
|
||
|
|
->group('type')
|
||
|
|
->fetchSql()
|
||
|
|
->select();
|
||
|
|
$contract_data = queryCache($sql);
|
||
|
|
$contract_data = array_column($contract_data, null, 'type');
|
||
|
|
$sql = ReceivablesModel::field([
|
||
|
|
'SUBSTR(`return_time`, 1, ' . $ax . ')' => 'type',
|
||
|
|
'SUM(`money`)' => 'money'
|
||
|
|
])
|
||
|
|
->where([
|
||
|
|
'owner_user_id' => ['IN', $userIds],
|
||
|
|
'check_status' => 2,
|
||
|
|
'return_time' => ['BETWEEN', $between_time]
|
||
|
|
])
|
||
|
|
->group('type')
|
||
|
|
->fetchSql()
|
||
|
|
->select();
|
||
|
|
$receivables_data = queryCache($sql);
|
||
|
|
$receivables_data = array_column($receivables_data, null, 'type');
|
||
|
|
|
||
|
|
$items = [];
|
||
|
|
$count_zong = 0;
|
||
|
|
$money_zong = 0;
|
||
|
|
$back_zong = 0;
|
||
|
|
foreach ($time['list'] as $val) {
|
||
|
|
$item = ['type' => $val['type']];
|
||
|
|
$count_zong += $item['count'] = $contract_data[$val['type']]['count'] ?: 0;
|
||
|
|
$money_zong += $item['money'] = $contract_data[$val['type']]['money'] ?: 0;
|
||
|
|
$back_zong += $item['back'] = $receivables_data[$val['type']]['money'] ?: 0;
|
||
|
|
$items[] = $item;
|
||
|
|
}
|
||
|
|
$data = [
|
||
|
|
'list' => $items,
|
||
|
|
'count_zong' => $count_zong,
|
||
|
|
'money_zong' => $money_zong,
|
||
|
|
'back_zong' => $back_zong,
|
||
|
|
'w_back_zong' => $money_zong - $back_zong,
|
||
|
|
];
|
||
|
|
|
||
|
|
if (!empty($data['list'])) $data['list'] = $this->sortCommon($data['list'], $sortField, $sortValue);
|
||
|
|
//导出使用
|
||
|
|
if (!empty($param['excel_type'])) return $data;
|
||
|
|
return resultArray(['data' => $data]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 发票统计分析
|
||
|
|
*
|
||
|
|
* @return \think\response\Json
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
* @throws \think\exception\DbException
|
||
|
|
*/
|
||
|
|
public function invoice($param='')
|
||
|
|
{
|
||
|
|
$userModel = new \app\admin\model\User();
|
||
|
|
$adminModel = new \app\admin\model\Admin();
|
||
|
|
if($param['excel_type']!=1){
|
||
|
|
$param = $this->param;
|
||
|
|
}
|
||
|
|
|
||
|
|
$perUserIds = $userModel->getUserByPer('bi', 'contract', 'read'); //权限范围内userIds
|
||
|
|
$whereArr = $adminModel->getWhere($param, '', $perUserIds); //统计条件
|
||
|
|
$userIds = $whereArr['userIds'];
|
||
|
|
if (empty($param['type']) && empty($param['start_time'])) {
|
||
|
|
$param['type'] = 'month';
|
||
|
|
}
|
||
|
|
|
||
|
|
$sortField = !empty($param['sort_field']) ? $param['sort_field'] : '';
|
||
|
|
$sortValue = !empty($param['sort_value']) ? $param['sort_value'] : '';
|
||
|
|
unset($param['sort_field']);
|
||
|
|
unset($param['sort_value']);
|
||
|
|
|
||
|
|
$time = getTimeArray();
|
||
|
|
$ax = 7;
|
||
|
|
if ($time['time_format'] == '%Y-%m-%d') {
|
||
|
|
$ax = 10;
|
||
|
|
}
|
||
|
|
$between_time = [date('Y-m-d', $time['between'][0]), date('Y-m-d', $time['between'][1])];
|
||
|
|
$sql = Db::name('crm_invoice')->field([
|
||
|
|
'SUBSTR(`invoice_date`, 1, ' . $ax . ')' => 'type',
|
||
|
|
'SUM(`invoice_money`)' => 'money'
|
||
|
|
])
|
||
|
|
->where([
|
||
|
|
'owner_user_id' => ['IN', $userIds],
|
||
|
|
'check_status' => 2,
|
||
|
|
'invoice_status' => 1,
|
||
|
|
'invoice_date' => ['BETWEEN', $between_time]
|
||
|
|
])
|
||
|
|
->group('type')
|
||
|
|
->fetchSql()
|
||
|
|
->select();
|
||
|
|
$invoice_data = queryCache($sql);
|
||
|
|
$invoice_data = array_column($invoice_data, null, 'type');
|
||
|
|
|
||
|
|
$sql = ReceivablesModel::field([
|
||
|
|
'SUBSTR(`return_time`, 1, ' . $ax . ')' => 'type',
|
||
|
|
'SUM(`money`)' => 'money'
|
||
|
|
])
|
||
|
|
->where([
|
||
|
|
'owner_user_id' => ['IN', $userIds],
|
||
|
|
'check_status' => 2,
|
||
|
|
'return_time' => ['BETWEEN', $between_time]
|
||
|
|
])
|
||
|
|
->group('type')
|
||
|
|
->fetchSql()
|
||
|
|
->select();
|
||
|
|
$receivables_data = queryCache($sql);
|
||
|
|
$receivables_data = array_column($receivables_data, null, 'type');
|
||
|
|
|
||
|
|
$items = [];
|
||
|
|
$invoiceCount = 0;
|
||
|
|
$receivablesCount = 0;
|
||
|
|
foreach ($time['list'] as $val) {
|
||
|
|
$receivablesModel = !empty($receivables_data[$val['type']]['money']) ? $receivables_data[$val['type']]['money'] : 0;
|
||
|
|
$invoiceModel = !empty($invoice_data[$val['type']]['money']) ? $invoice_data[$val['type']]['money'] : 0;
|
||
|
|
|
||
|
|
$items[] = [
|
||
|
|
'type' => $val['type'],
|
||
|
|
'receivables_money' => $receivablesModel,
|
||
|
|
'invoice_money' => $invoiceModel,
|
||
|
|
'not_invoice' => $receivablesModel - $invoiceModel > 0 ? $receivablesModel - $invoiceModel : 0,
|
||
|
|
'not_receivables' => $invoiceModel - $receivablesModel > 0 ? $invoiceModel - $receivablesModel : 0
|
||
|
|
];
|
||
|
|
|
||
|
|
$invoiceCount += $invoiceModel;
|
||
|
|
$receivablesCount += $receivablesModel;
|
||
|
|
|
||
|
|
}
|
||
|
|
$data = [
|
||
|
|
'list' => $items,
|
||
|
|
'receivables_count' => $receivablesCount,
|
||
|
|
'invoice_count' => $invoiceCount
|
||
|
|
];
|
||
|
|
|
||
|
|
if (!empty($data['list'])) $data['list'] = $this->sortCommon($data['list'], $sortField, $sortValue);
|
||
|
|
//导出使用
|
||
|
|
if (!empty($param['excel_type'])) return $data;
|
||
|
|
return resultArray(['data' => $data]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 导出
|
||
|
|
* @param $type
|
||
|
|
* @param $types
|
||
|
|
*/
|
||
|
|
public function excelExport()
|
||
|
|
{
|
||
|
|
|
||
|
|
$param = $this->param;
|
||
|
|
$excel_type = $param['excel_type'];
|
||
|
|
$type=[];
|
||
|
|
$type['excel_types']=$param['excel_types'];
|
||
|
|
|
||
|
|
switch ($param['excel_types']) {
|
||
|
|
case 'analysis':
|
||
|
|
if ($param['type'] == 'count') {
|
||
|
|
$type['type'] = '合同数量分析';
|
||
|
|
|
||
|
|
} elseif ($param['type'] == 'back') {
|
||
|
|
$type['type'] = '回款金额分析';
|
||
|
|
} else {
|
||
|
|
$type['type'] = '金额分析';
|
||
|
|
}
|
||
|
|
$list = $this->analysis($param);
|
||
|
|
break;
|
||
|
|
case 'summary':
|
||
|
|
$list = $this->summary($excel_type);
|
||
|
|
$type['type'] = '合同汇总表';
|
||
|
|
break;
|
||
|
|
case 'invoice':
|
||
|
|
$list = $this->invoice($excel_type);
|
||
|
|
$type['type'] = '发票统计分析表';
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
if(empty($list)){
|
||
|
|
return resultArray(['data'=>'数据不存在']);
|
||
|
|
}
|
||
|
|
$excelLogic = new ExcelLogic();
|
||
|
|
$data = $excelLogic->contractExcel($type, $list);
|
||
|
|
return $data;
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|