From e1f80d538e17f52db59f29e3a9cdefa27abdac8d Mon Sep 17 00:00:00 2001 From: lcc <805383944@qq.com> Date: Fri, 1 Aug 2025 13:29:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=AE=A2=E5=8D=95=E5=AE=8C?= =?UTF-8?q?=E7=BB=93=E5=88=86=E4=BD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/controllers/plan/Plan.php | 5 +- api/controllers/plan/agent/Commission.php | 51 ++++++++++-- api/core/HD_Model.php | 30 ++++--- .../entity/ReceiverOrderSubsidyEntity.php | 79 +++++++++++-------- .../agent/Receiver_order_subsidy_model.php | 6 ++ common/models/biz/Biz_accountLog_model.php | 2 + 6 files changed, 119 insertions(+), 54 deletions(-) diff --git a/api/controllers/plan/Plan.php b/api/controllers/plan/Plan.php index 5c733349..e11aa20d 100644 --- a/api/controllers/plan/Plan.php +++ b/api/controllers/plan/Plan.php @@ -37,8 +37,9 @@ class Plan extends CI_Controller $plan[] = array('url' => base_url(array('plan', 'score', 'mergeBiz')), 'interval' => 1); //合并上月门店分数日志 $plan[] = array('url' => base_url(array('plan', 'score', 'mergeAvgUser')), 'interval' => 1); //合并本月个人分数日志 $plan[] = array('url' => base_url(array('plan', 'score', 'mergeAvgBiz')), 'interval' => 1); //合并本月门店分数日志 - //线索分佣 - $plan[] = array('url' => base_url(array('plan', 'agent/commission', 'bizClues')), 'interval' => 1); //合并本月门店分数日志 + + $plan[] = array('url' => base_url(array('plan', 'agent/commission', 'bizClues')), 'interval' => 1);//线索分佣 + $plan[] = array('url' => base_url(array('plan', 'agent/commission', 'orderSubsidy')), 'interval' => 1);//订单完结分佣 $plan[] = array('url' => base_url(array('plan', 'report', 'index')), 'interval' => 20); //门店日报 diff --git a/api/controllers/plan/agent/Commission.php b/api/controllers/plan/agent/Commission.php index 7a3be16d..9f87b526 100644 --- a/api/controllers/plan/agent/Commission.php +++ b/api/controllers/plan/agent/Commission.php @@ -1,11 +1,5 @@ load->model('receiver/receiver_clues_model', 'clues_model'); $this->load->model('biz/biz_account_model', 'account_model'); $this->load->model('biz/biz_accountLog_model', 'bizAccountLog'); + $this->load->model('receiver/order/receiver_orders_model'); + + $this->load->model('agent/receiver_order_subsidy_model'); + $this->load->model('agent/auto_product_coupon_model'); + $this->load->model('agent/auto_product_model'); + $this->load->model('agent/pingan/pingan_users_cmmssn_model'); + $this->load->model('agent/organization/organization_cmmssn_model', 'mdOrganizationCmmssn'); + $this->load->model('agent/organization/organization_model'); + $this->load->model('agent/pingan/pingan_users_model'); + $this->receiver_order_subsidy_model->set_db('agentdb'); + $this->auto_product_coupon_model->set_db('agentdb'); + $this->auto_product_model->set_db('agentdb'); + $this->pingan_users_cmmssn_model->set_db('agentdb'); + $this->mdOrganizationCmmssn->set_db('agentdb'); + $this->organization_model->set_db('agentdb'); + $this->pingan_users_model->set_db('agentdb'); + $this->load->library('myResponse'); $this->dir = 'commission'; } /** - * 店铺线索分佣 + * 线索分佣 * @return void */ public function bizClues() @@ -54,4 +65,30 @@ class Commission extends HD_Controller debug_log($e->getMessage(), $log_path, $this->dir); } } + + /** + * 订单分佣 + * @return void + */ + public function orderSubsidy() + { + $log_path = 'order_subsidy.log'; + try { + $page = 1; + $size = 20; + $where = ['commStatus' => Receiver_order_subsidy_model::COMM_STATUS_WAIT]; + /** @var ReceiverOrderSubsidyEntity[] $rows */ + $rows = $this->receiver_order_subsidy_model->select($where, 'id asc', $page, $size, '', 'ReceiverOrderSubsidyEntity'); + if (!$rows) { + throw new Exception('没有需要分佣的记录'); + } + foreach ($rows as $row) { + debug_log('开始分佣，ID:' . $row->id, $log_path, $this->dir); + $result = $row->commission(); + debug_log("分佣结束:" . $result->getMessage(), $log_path, $this->dir); + } + } catch (Exception $e) { + debug_log($e->getMessage(), $log_path, $this->dir); + } + } } \ No newline at end of file diff --git a/api/core/HD_Model.php b/api/core/HD_Model.php index 93c150ca..e6aa9991 100644 --- a/api/core/HD_Model.php +++ b/api/core/HD_Model.php @@ -156,7 +156,7 @@ class HD_Model extends CI_Model { * @param $data * @return mixed */ - public function replace($data) + public function replace($data) { if($data) { @@ -202,7 +202,7 @@ class HD_Model extends CI_Model { return $this->db->query($sql); } } - + /** * 获取单条数据 * @param $where @@ -271,16 +271,24 @@ class HD_Model extends CI_Model { $this->db->from($this->table_name); $this->db->limit($limit, $offset); $query = $this->db->get(); - $result = $query ? $query->result_array() : []; - if($obj && file_exists($class = APPPATH.'libraries/entity/'.ucfirst($obj).'.php')) + if($obj) { - require_once $class; - if(class_exists($obj)) - { - $result = $this->db->get($this->table_name, $limit, $offset)->custom_result_object($obj); + if(file_exists($class = APPPATH.'libraries/entity/'.ucfirst($obj).'.php')){ + require_once $class; + if(class_exists($obj)) + { + return $query->custom_result_object($obj); + } + } + if(file_exists($class = COMMPATH.'libraries/entity/'.ucfirst($obj).'.php')){ + require_once $class; + if(class_exists($obj)) + { + return $query->custom_result_object($obj); + } } } - return $result; + return $query ? $query->result_array() : []; } /** @@ -549,7 +557,7 @@ class HD_Model extends CI_Model { * @param array $param * @return mixed */ - public function un_file_cache($func, $param =array()) + public function un_file_cache($func, $param =array()) { if(IF_FILE_CACHE) { @@ -565,7 +573,7 @@ class HD_Model extends CI_Model { * @param $type * @return bool */ - public function del_cache($method, $type, $skey = '') + public function del_cache($method, $type, $skey = '') { $cache = & load_cache($type); $db = $this->load->database('default', true); diff --git a/common/libraries/entity/ReceiverOrderSubsidyEntity.php b/common/libraries/entity/ReceiverOrderSubsidyEntity.php index 2e8ac49e..b87dee5d 100644 --- a/common/libraries/entity/ReceiverOrderSubsidyEntity.php +++ b/common/libraries/entity/ReceiverOrderSubsidyEntity.php @@ -21,8 +21,8 @@ class ReceiverOrderSubsidyEntity $ci = &get_instance(); $ci->load->helper('string'); $ci->load->model('agent/auto_product_coupon_model'); - $ci->load->model('agent/auto_product_model'); $ci->load->model('agent/receiver_order_subsidy_model'); + $ci->load->model('agent/auto_product_model'); $ci->load->model('agent/pingan/pingan_users_cmmssn_model'); $ci->load->model('agent/pingan/pingan_users_model'); $ci->load->model('agent/organization/organization_cmmssn_model', 'mdOrganizationCmmssn'); @@ -31,10 +31,6 @@ class ReceiverOrderSubsidyEntity $ci->load->model('receiver/receiver_clues_model'); $ci->load->model('biz/biz_account_model', 'account_model'); $ci->load->model('biz/biz_accountLog_model', 'accountlog_model'); - $ci->receiver_orders_model->set_db('ssdb'); - $ci->receiver_clues_model->set_db('ssdb'); - $ci->account_model->set_db('ssdb'); - $ci->accountlog_model->set_db('ssdb'); } /** @@ -46,6 +42,10 @@ class ReceiverOrderSubsidyEntity public function ifCheckSubsidy($status, $reason = '') { $ci = &get_instance(); + $ci->receiver_orders_model->set_db('ssdb'); + $ci->receiver_clues_model->set_db('ssdb'); + $ci->account_model->set_db('ssdb'); + $ci->accountlog_model->set_db('ssdb'); $ci->receiver_order_subsidy_model->db->trans_begin(); $ci->account_model->db->trans_begin(); try { @@ -143,17 +143,32 @@ class ReceiverOrderSubsidyEntity } } - public function cmmssn() + /** + * 分佣 + * @return MyResponse + */ + public function commission() { + $log_path = 'commission.log'; + $log_dir = 'order_subsidy'; $ci = &get_instance(); try { - $log_path = 'cmmssn.log'; - $log_dir = 'pingan'; debug_log("开始分佣:" . $this->id, $log_path, $log_dir); - $cmmssn = $ci->pingan_users_cmmssn_model->get(['orderId' => $this->orderId]); + $cmmssn = $ci->pingan_users_cmmssn_model->get(['cfId' => $this->orderId, 'cfType' => Pingan_users_cmmssn_model::CF_TYPE_ORDER_OWN]); if ($cmmssn) { throw new Exception("订单已经存在分佣记录"); } + $productCoupon = $ci->auto_product_coupon_model->get(['id' => $this->couponId]); + $product = $ci->auto_product_model->get(['id' => $productCoupon['product_id']]); + if (!$product) { + throw new Exception("产品不存在"); + } + $money = $product['orderCommission']; + debug_log("订单分佣金额:" . $money, $log_path, $log_dir); + if ($money <= 0) { //不需要分佣 + $ci->receiver_order_subsidy_model->update(['commStatus' => Receiver_order_subsidy_model::COMM_STATUS_NOT], ['id' => $this->id]); + return new MyResponse(EXIT_SUCCESS, "不需要分佣,分佣金额为:{$money}"); + } $order = $ci->receiver_orders_model->get(['id' => $this->orderId]); if (!$order) { throw new Exception("订单不存在"); @@ -170,102 +185,98 @@ class ReceiverOrderSubsidyEntity throw new Exception("线索不存在绑定用户关系"); } //获取分佣配置 - $cmmssn = $ci->mdOrganizationCmmssn->get(['teamId' => $pinanUser['orgTeamId'], 'status' => 1]); + $cmmssn = $ci->mdOrganizationCmmssn->get(['teamId' => $pinanUser['orgTeamId'], 'status' => 0]); if (!$cmmssn) { throw new Exception("分佣配置不存在"); } //团队设置分佣等级 $level = $ci->organization_model->getTeamLevel($pinanUser['orgTeamId']); - $brokerage1 = $brokerage2 = $brokerage3 = $brokerage4 = 0; - $sourceId = 0; - if ($clues['cf2_id'] == 39) { //产品来源 - $product = $ci->auto_product_model->get(['id' => $clues['out_id']]); - $brokerage1 = $product['orderCommission'] * ($cmmssn['orderLevel1'] / 100) ?: 0; - $brokerage2 = $product['orderCommission'] * ($cmmssn['orderLevel2'] / 100) ?: 0; - $brokerage3 = $product['orderCommission'] * ($cmmssn['orderLevel3'] / 100) ?: 0; - $brokerage4 = $product['orderCommission'] * ($cmmssn['orderLevel4'] / 100) ?: 0; - $sourceId = $product['id'] ?: 0; - } elseif ($clues['cf2_id'] == 40) { //活动获取分佣配置 - - } + $brokerage1 = $money * ($cmmssn['cluesLevel1'] / 100) ?: 0; + $brokerage2 = $money * ($cmmssn['cluesLevel2'] / 100) ?: 0; + $brokerage3 = $money * ($cmmssn['cluesLevel3'] / 100) ?: 0; + $brokerage4 = $money * ($cmmssn['cluesLevel4'] / 100) ?: 0; + debug_log('分佣金额:' . json_encode([$brokerage1, $brokerage2, $brokerage3, $brokerage4]), $log_path, $log_dir); $add_data = []; if ($brokerage1 && $clues['area_id']) { //一级佣金 $add_data[] = [ 'cfId' => $this->orderId, - 'sourceId' => $sourceId, 'cfType' => Pingan_users_cmmssn_model::CF_TYPE_ORDER_TEAM, 'money' => $brokerage1, 'pinganUserId' => $clues['area_id'], 'teamId' => 0, 'depId' => 0, 'areaId' => $clues['area_id'], - 'createTime' => date('Y-m-d H:i:s') + 'createTime' => date('Y-m-d H:i:s'), + 'bizId' => $this->bizId ]; } if ($brokerage2 && $clues['dep_id']) { //二级佣金 $add_data[] = [ 'cfId' => $this->orderId, - 'sourceId' => $sourceId, 'cfType' => Pingan_users_cmmssn_model::CF_TYPE_ORDER_TEAM, 'money' => $brokerage2, 'pinganUserId' => $clues['dep_id'], 'teamId' => 0, 'depId' => $clues['dep_id'], 'areaId' => $clues['area_id'] ?: 0, - 'createTime' => date('Y-m-d H:i:s') + 'createTime' => date('Y-m-d H:i:s'), + 'bizId' => $this->bizId ]; } if ($level >= 4) { //4级 if ($brokerage3 && $clues['team_id']) { $add_data[] = [ 'cfId' => $this->orderId, - 'sourceId' => $sourceId, 'cfType' => Pingan_users_cmmssn_model::CF_TYPE_ORDER_TEAM, 'money' => $brokerage3, 'pinganUserId' => $clues['team_id'], 'teamId' => $clues['team_id'], 'depId' => $clues['dep_id'], 'areaId' => $clues['area_id'] ?: 0, - 'createTime' => date('Y-m-d H:i:s') + 'createTime' => date('Y-m-d H:i:s'), + 'bizId' => $this->bizId ]; } if ($brokerage4 && $clues['pingan_user_id']) { $add_data[] = [ 'cfId' => $this->orderId, - 'sourceId' => $sourceId, 'cfType' => Pingan_users_cmmssn_model::CF_TYPE_ORDER_OWN, 'money' => $brokerage4, 'pinganUserId' => $clues['pingan_user_id'], 'teamId' => $clues['team_id'], 'depId' => $clues['dep_id'], 'areaId' => $clues['area_id'] ?: 0, - 'createTime' => date('Y-m-d H:i:s') + 'createTime' => date('Y-m-d H:i:s'), + 'bizId' => $this->bizId ]; } } else { //三级 if ($brokerage3 && $clues['pingan_user_id']) { $add_data[] = [ 'cfId' => $this->orderId, - 'sourceId' => $sourceId, - 'cfType' => Pingan_users_cmmssn_model::CF_TYPE_ORDER_TEAM, + 'cfType' => Pingan_users_cmmssn_model::CF_TYPE_ORDER_OWN, 'money' => $brokerage3, 'pinganUserId' => $clues['team_id'], 'teamId' => 0, 'depId' => $clues['dep_id'], 'areaId' => $clues['area_id'] ?: 0, - 'createTime' => date('Y-m-d H:i:s') + 'createTime' => date('Y-m-d H:i:s'), + 'bizId' => $this->bizId ]; } } - + debug_log('分佣数据:' . json_encode($add_data, JSON_UNESCAPED_UNICODE), $log_path, $log_dir); if (count($add_data)) { $result = $ci->pingan_users_cmmssn_model->add_batch($add_data); if (!$result) { throw new Exception("保存失败"); } } + $ci->receiver_order_subsidy_model->update(['commStatus' => Receiver_order_subsidy_model::COMM_STATUS_SUCCESS], ['id' => $this->id]); + debug_log('分佣结束', $log_path, $log_dir); return new MyResponse(EXIT_SUCCESS, '保存成功'); } catch (Exception $e) { + $ci->receiver_order_subsidy_model->update(['commStatus' => Receiver_order_subsidy_model::COMM_STATUS_FAIL], ['id' => $this->id]); debug_log($e->getMessage(), $log_path, $log_dir); return new MyResponse(EXIT_ERROR, $e->getMessage()); } diff --git a/common/models/agent/Receiver_order_subsidy_model.php b/common/models/agent/Receiver_order_subsidy_model.php index df352448..6af8860e 100644 --- a/common/models/agent/Receiver_order_subsidy_model.php +++ b/common/models/agent/Receiver_order_subsidy_model.php @@ -24,6 +24,12 @@ class Receiver_order_subsidy_model extends HD_Model self::STATUS_FAIL => '发放失败' ]; + //分佣状态 + const COMM_STATUS_WAIT = 0; //待处理 + const COMM_STATUS_SUCCESS = 1; //成功 + const COMM_STATUS_FAIL = 2;//失败 + const COMM_STATUS_NOT = 3;//不需要分佣 + public function __construct() { parent::__construct($this->table_name, 'default'); diff --git a/common/models/biz/Biz_accountLog_model.php b/common/models/biz/Biz_accountLog_model.php index 33e54be9..f284473d 100644 --- a/common/models/biz/Biz_accountLog_model.php +++ b/common/models/biz/Biz_accountLog_model.php @@ -15,4 +15,6 @@ class Biz_accountLog_model extends HD_Model { parent::__construct($this->table_name, 'default'); } + + }