php
/
zhjwxt
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

分润

master
王泽彦 10 months ago
parent
72682313b0
commit
2da1bf2d0e
3 changed files with 312 additions and 1 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 8
      niucloud/app/event.php
  2. 180
      niucloud/app/listener/custom/CoachPerformanceListener.php
  3. 125
      niucloud/app/listener/custom/SalesPerformanceListener.php

8
niucloud/app/event.php
View File

@ -115,11 +115,17 @@ $system_event = [
'app\listener\system\ShowAppListener'
],
//计算业绩
//计算市场人员业绩
'CalculatePerformance' => [ 'app\listener\personnel\CalculatePerformance' ],
//学员
'Student' => [ 'app\listener\personnel\Student' ],
//计算销售人员业绩
'SalesPerformance' => [ 'app\listener\custom\SalesPerformanceListener' ],
//计算教练业绩
'CoachPerformance' => [ 'app\listener\custom\CoachPerformanceListener' ],
],
'subscribe' => [
],

180
niucloud/app/listener/custom/CoachPerformanceListener.php
View File

@ -0,0 +1,180 @@
<?php
// +----------------------------------------------------------------------
// | Niucloud-admin 企业快速开发的多应用管理平台
// +----------------------------------------------------------------------
// | 官方网址：https://www.niucloud.com
// +----------------------------------------------------------------------
// | niucloud团队 版权所有 开源版本可自由商用
// +----------------------------------------------------------------------
// | Author: Niucloud Team
// +----------------------------------------------------------------------
namespace app\listener\custom;
use app\model\performance_records\PerformanceRecords;
use app\model\course\Course;
use app\model\personnel\Personnel;
use app\model\student\Student;
/**
* 计算教练业绩事件
* Class CoachPerformanceListener
* @package app\listener\custom
*/
class CoachPerformanceListener
{
/**
* 处理教练业绩计算
* @param array $params
* $params['course_id'] 课程ID
* $params['coach_id'] 教练ID
* $params['student_id'] 学员ID
* $params['performance_type'] 业绩类型，可选值：'course'=课程授课,'private'=私教,'assessment'=考核评估
*/
public function handle(array $params)
{
// 检查必要参数
if (empty($params['course_id']) || empty($params['coach_id'])) {
return false;
}
// 获取课程信息
$courseInfo = (new Course())->find($params['course_id']);
if (empty($courseInfo)) {
return false;
}
// 检查教练是否存在
$personnel = (new Personnel())->find($params['coach_id']);
if (empty($personnel)) {
return false;
}
// 业绩类型，默认为课程授课
$performanceType = $params['performance_type'] ?? 'course';
// 计算业绩值
$performanceValue = $this->calculatePerformanceValue($courseInfo, $performanceType, $params);
// 记录业绩
return $this->recordPerformance([
'staff_id' => $params['coach_id'],
'course_id' => $params['course_id'],
'student_id' => $params['student_id'] ?? 0,
'performance_type' => $performanceType,
'performance_value' => $performanceValue,
'remarks' => '系统自动计算教练业绩',
]);
}
/**
* 计算业绩值
* @param object $courseInfo 课程信息
* @param string $performanceType 业绩类型
* @param array $params 额外参数
* @return float 业绩值
*/
protected function calculatePerformanceValue($courseInfo, $performanceType, $params)
{
$value = 0;
// 获取课程时长（小时）
$courseDuration = floatval($courseInfo['duration'] ?? 1);
// 根据业绩类型计算业绩值
switch ($performanceType) {
case 'course':
// 普通课程授课业绩，按照课时和课程基础系数计算
$baseRate = 50; // 每小时基本业绩值
$value = $courseDuration * $baseRate;
// 如果有学员参数，增加学员数量系数
if (!empty($params['student_count'])) {
$studentCount = intval($params['student_count']);
// 每多一名学员，业绩系数增加5%
$studentFactor = 1 + (($studentCount - 1) * 0.05);
$value = $value * $studentFactor;
}
break;
case 'private':
// 私教课程业绩，私教课程通常有更高的业绩系数
$privateRate = 150; // 每小时私教业绩值
$value = $courseDuration * $privateRate;
// 检查学员等级，高级别学员可以提高业绩
if (!empty($params['student_id'])) {
$student = (new Student())->find($params['student_id']);
if (!empty($student) && !empty($student['level'])) {
// 根据学员等级增加业绩系数
$levelFactor = 1 + (intval($student['level']) * 0.1);
$value = $value * $levelFactor;
}
}
break;
case 'assessment':
// 考核评估业绩，固定业绩值加上考核难度系数
$assessmentBaseValue = 100; // 基础考核业绩值
$difficultyLevel = intval($params['difficulty_level'] ?? 1); // 难度等级1-5
$value = $assessmentBaseValue * $difficultyLevel;
break;
default:
// 默认按课时计算
$value = $courseDuration * 50;
}
return $value;
}
/**
* 记录业绩
* @param array $data 业绩数据
* @return bool
*/
protected function recordPerformance(array $data)
{
// 准备记录数据
$recordData = [
'staff_id' => $data['staff_id'],
'performance_type' => $data['performance_type'],
'performance_value' => $data['performance_value'],
'remarks' => $data['remarks']
];
// 如果有课程ID，记录到扩展字段
if (!empty($data['course_id'])) {
$recordData['extend_id'] = $data['course_id'];
$recordData['extend_type'] = 'course';
}
// 如果有学员ID，记录到相关字段
if (!empty($data['student_id'])) {
$recordData['resource_id'] = $data['student_id'];
}
// 查询是否已存在该课程的业绩记录
$exists = (new PerformanceRecords())->where([
['extend_id', '=', $data['course_id'] ?? 0],
['staff_id', '=', $data['staff_id']],
['performance_type', '=', $data['performance_type']]
])->find();
if ($exists) {
// 更新已有记录
return (new PerformanceRecords())->where('id', $exists['id'])->update([
'performance_value' => $data['performance_value'],
'remarks' => $data['remarks'],
'updated_at' => date('Y-m-d H:i:s')
]);
} else {
// 创建新记录
$recordData['created_at'] = date('Y-m-d H:i:s');
$recordData['updated_at'] = date('Y-m-d H:i:s');
$model = new PerformanceRecords();
$result = $model->create($recordData);
return !empty($result->id);
}
}
}

125
niucloud/app/listener/custom/SalesPerformanceListener.php
View File

@ -0,0 +1,125 @@
<?php
// +----------------------------------------------------------------------
// | Niucloud-admin 企业快速开发的多应用管理平台
// +----------------------------------------------------------------------
// | 官方网址：https://www.niucloud.com
// +----------------------------------------------------------------------
// | niucloud团队 版权所有 开源版本可自由商用
// +----------------------------------------------------------------------
// | Author: Niucloud Team
// +----------------------------------------------------------------------
namespace app\listener\custom;
use app\model\performance_records\PerformanceRecords;
use app\model\order_table\OrderTable;
use app\model\personnel\Personnel;
/**
* 计算销售人员业绩事件
* Class SalesPerformanceListener
* @package app\listener\custom
*/
class SalesPerformanceListener
{
/**
* 处理销售业绩计算
* @param array $params
* $params['order_id'] 订单ID
* $params['staff_id'] 销售人员ID
* $params['performance_type'] 业绩类型，可选值：'sales'=销售,'commission'=佣金
*/
public function handle(array $params)
{
// 检查必要参数
if (empty($params['order_id']) || empty($params['staff_id'])) {
return false;
}
// 获取订单信息
$orderInfo = (new OrderTable())->find($params['order_id']);
if (empty($orderInfo)) {
return false;
}
// 检查销售人员是否存在
$personnel = (new Personnel())->find($params['staff_id']);
if (empty($personnel)) {
return false;
}
// 业绩类型，默认为销售
$performanceType = $params['performance_type'] ?? 'sales';
// 计算业绩值
$performanceValue = $this->calculatePerformanceValue($orderInfo, $performanceType);
// 记录业绩
return $this->recordPerformance([
'staff_id' => $params['staff_id'],
'order_id' => $params['order_id'],
'resource_id' => $orderInfo['resource_id'] ?? 0,
'order_status' => $orderInfo['status'],
'performance_type' => $performanceType,
'performance_value' => $performanceValue,
'remarks' => '系统自动计算销售业绩',
]);
}
/**
* 计算业绩值
* @param object $orderInfo 订单信息
* @param string $performanceType 业绩类型
* @return float 业绩值
*/
protected function calculatePerformanceValue($orderInfo, $performanceType)
{
$value = 0;
// 根据订单金额和业绩类型计算业绩值
$orderAmount = floatval($orderInfo['total_amount'] ?? 0);
if ($performanceType == 'sales') {
// 销售业绩直接等于订单金额
$value = $orderAmount;
} elseif ($performanceType == 'commission') {
// 佣金业绩，假设为订单金额的10%
$commissionRate = 0.1; // 佣金比例，可以从配置中获取
$value = $orderAmount * $commissionRate;
}
return $value;
}
/**
* 记录业绩
* @param array $data 业绩数据
* @return bool
*/
protected function recordPerformance(array $data)
{
// 查询是否已存在该订单的业绩记录
$exists = (new PerformanceRecords())->where([
['order_id', '=', $data['order_id']],
['staff_id', '=', $data['staff_id']],
['performance_type', '=', $data['performance_type']]
])->find();
if ($exists) {
// 更新已有记录
return (new PerformanceRecords())->where('id', $exists['id'])->update([
'performance_value' => $data['performance_value'],
'order_status' => $data['order_status'],
'remarks' => $data['remarks'],
'updated_at' => date('Y-m-d H:i:s')
]);
} else {
// 创建新记录
$data['created_at'] = date('Y-m-d H:i:s');
$data['updated_at'] = date('Y-m-d H:i:s');
$model = new PerformanceRecords();
$result = $model->create($data);
return !empty($result->id);
}
}
}
Write Preview
Loading…
Cancel
Save