655 lines
32 KiB
PHP
655 lines
32 KiB
PHP
<?php
|
||
/**
|
||
* SaaSMall商城系统 - 团队十年电商经验汇集巨献!
|
||
* =========================================================
|
||
* Copy right 2019-2029 成都SAAS云科技有限公司, 保留所有权利。
|
||
* ----------------------------------------------
|
||
* 官方网址: https://www.gobuysaas.com
|
||
* =========================================================
|
||
*/
|
||
namespace addon\fenxiao\model;
|
||
use app\model\BaseModel;
|
||
use app\model\message\Message;
|
||
use app\model\system\Stat;
|
||
use think\facade\Db;
|
||
|
||
/**
|
||
* 分销商品
|
||
*/
|
||
class FenxiaoOrder extends BaseModel
|
||
{
|
||
|
||
/**
|
||
* 分销订单计算
|
||
* @param unknown $order
|
||
*/
|
||
public function calculate($order)
|
||
{
|
||
//获取分销基础配置
|
||
$config_model = new Config();
|
||
$fenxiao_basic_config = $config_model->getFenxiaoBasicsConfig($order[ 'site_id' ])[ 'data' ][ 'value' ];
|
||
if (!$fenxiao_basic_config['level']) return $this->success();
|
||
// //检测分销商上级关系
|
||
$member_info = model("member")->getInfo([ [ 'member_id', '=', $order[ 'member_id' ] ] ], 'fenxiao_id,is_fenxiao,nickname,mobile');
|
||
// 本人是分销商 触发购买指定商品升级
|
||
if($member_info['is_fenxiao'] == 1 && $member_info['fenxiao_id'] > 0){
|
||
event('FenxiaoUpgrade', [
|
||
'fenxiao_id' => $member_info[ 'fenxiao_id' ],
|
||
'order_id' => $order[ 'order_id' ]
|
||
]);
|
||
$member_info = model("member")->getInfo([ [ 'member_id', '=', $order[ 'member_id' ] ] ], 'fenxiao_id,is_fenxiao,nickname,mobile');
|
||
}
|
||
// //如果没有分销商直接返回不计算,没有考虑首次付款上下级绑定
|
||
if (empty($member_info)) return $this->success();
|
||
if ($member_info[ 'fenxiao_id' ] == 0) return $this->success();
|
||
$fenxiao_id = $member_info[ 'fenxiao_id' ];
|
||
$field = 'f.fenxiao_id,f.fenxiao_name,f.member_id,f.level_id,f.site_id,f.status,f.parent,f.grand_parent,f.chain,l.level_num,l.one_rate,l.two_rate';
|
||
$join = [
|
||
['fenxiao_level l', 'f.level_id = l.level_id', 'right']
|
||
];
|
||
$fenxiao_info = model("fenxiao")->getInfo([ [ 'f.fenxiao_id', '=', $fenxiao_id ], [ 'f.is_delete', '=', 0 ] ],$field,'f',$join);
|
||
if (empty($fenxiao_info)) return $this->success();
|
||
// 如果购买人是分销商 并且未开启分销商自购
|
||
if ($member_info[ 'is_fenxiao' ] && $fenxiao_basic_config[ 'self_purchase_rebate' ] == 0) {
|
||
if (empty($fenxiao_info[ 'parent' ])) return $this->success();
|
||
$fenxiao_info = model("fenxiao")->getInfo([ [ 'fenxiao_id', '=', $fenxiao_info[ 'parent' ] ], [ 'is_delete', '=', 0 ] ]);
|
||
if (empty($fenxiao_info)) return $this->success();
|
||
}
|
||
|
||
// //判断几级分销
|
||
// $parent_fenxiao_info = $level_config >= 2 ? model('fenxiao')->getInfo([ [ 'fenxiao_id', '=', $fenxiao_info[ 'parent' ] ], [ 'is_delete', '=', 0 ] ], 'fenxiao_id, fenxiao_name, status, parent') : [];
|
||
// $grand_parent_fenxiao_info = $level_config >= 3 && !empty($parent_fenxiao_info[ 'parent' ]) ? model('fenxiao')->getInfo([ [ 'fenxiao_id', '=', $parent_fenxiao_info[ 'parent' ] ], [ 'is_delete', '=', 0 ] ], 'fenxiao_id, fenxiao_name, status') : [];
|
||
$order_goods = model('order_goods')->getList([ [ 'order_id', '=', $order[ 'order_id' ] ], [ 'is_fenxiao', '=', 1 ] ], 'order_goods_id, goods_id , site_id, sku_id, sku_name, sku_image, sku_no, is_virtual, price, cost_price, num, goods_money, cost_money, delivery_no, delivery_status, real_goods_money');
|
||
if (empty($order_goods)) return $this->success();
|
||
model('fenxiao_order')->delete([ [ 'order_id', '=', $order[ 'order_id' ] ] ]);
|
||
|
||
foreach($order_goods as $k => $v){
|
||
$order_fenxiao_data = [
|
||
'commission' => 0,
|
||
'commission_rate' => 0,
|
||
'one_rate' => 0,
|
||
'one_commission' => 0,
|
||
'one_fenxiao_id' => 0,
|
||
'one_fenxiao_name' => '',
|
||
'two_rate' => 0,
|
||
'two_commission' => 0,
|
||
'two_fenxiao_id' => 0,
|
||
'two_fenxiao_name' => '',
|
||
'wholesale_fenxiao_id' => [],
|
||
'wholesale_rate' => 0,
|
||
'wholesale_commission' => 0,
|
||
'wholesale_fenxiao_detail' => [],
|
||
'founder_fenxiao_id' => [],
|
||
'founder_rate' => 0,
|
||
'founder_commission' => 0,
|
||
'founder_fenxiao_detail' => [],
|
||
];
|
||
|
||
$goods_info = model('goods')->getInfo([['goods_id','=',$v['goods_id']]],'is_fenxiao, fenxiao_type,goods_kind_id');
|
||
//报单商品才有直推和间推
|
||
if($goods_info['goods_kind_id']){
|
||
$order_fenxiao_data = $this->getPushFenXiaoCommission($fenxiao_info,$v,$order_fenxiao_data,$goods_info['fenxiao_type'],$fenxiao_basic_config);
|
||
}
|
||
$order_fenxiao_data = $this->getWholesaleFenXiaoCommission($fenxiao_info,$v,$order_fenxiao_data,$fenxiao_basic_config,$goods_info['goods_kind_id']);
|
||
if($order_fenxiao_data['commission'] && $order_fenxiao_data['commission_rate']){
|
||
$data = [
|
||
'order_id' => $order['order_id'],
|
||
'order_no' => $order['order_no'],
|
||
'order_goods_id' => $v['order_goods_id'],
|
||
'site_id' => $order['site_id'],
|
||
'site_name' => $order['site_name'],
|
||
'goods_id' => $v['goods_id'],
|
||
'sku_id' => $v['sku_id'],
|
||
'sku_name' => $v['sku_name'],
|
||
'sku_image' => $v['sku_image'],
|
||
'price' => $v['price'],
|
||
'num' => $v['num'],
|
||
'real_goods_money' => $v['real_goods_money'],
|
||
'member_id' => $order['member_id'],
|
||
'member_name' => !empty($order['name']) ? $order['name'] : $member_info['nickname'],
|
||
'member_mobile' => !empty($order['mobile']) ? $order['mobile'] : $member_info['mobile'],
|
||
'full_address' => $order['full_address'].$order['address'],
|
||
'commission' => $order_fenxiao_data['commission'],
|
||
'commission_rate' => $order_fenxiao_data['commission_rate'],
|
||
'one_fenxiao_id' => $order_fenxiao_data['one_fenxiao_id'],
|
||
'one_rate' => $order_fenxiao_data['one_rate'],
|
||
'one_commission' => $order_fenxiao_data['one_commission'],
|
||
'one_fenxiao_name' => $order_fenxiao_data['one_fenxiao_name'],
|
||
'two_fenxiao_id' => $order_fenxiao_data['two_fenxiao_id'],
|
||
'two_rate' => $order_fenxiao_data['two_rate'],
|
||
'two_commission' => $order_fenxiao_data['two_commission'],
|
||
'two_fenxiao_name' => $order_fenxiao_data['two_fenxiao_name'],
|
||
'wholesale_fenxiao_id' => json_encode($order_fenxiao_data['wholesale_fenxiao_id']),
|
||
'wholesale_rate' => $order_fenxiao_data['wholesale_rate'],
|
||
'wholesale_commission' => $order_fenxiao_data['wholesale_commission'],
|
||
'wholesale_fenxiao_detail' => json_encode($order_fenxiao_data['wholesale_fenxiao_detail']),
|
||
'founder_fenxiao_id' => json_encode($order_fenxiao_data['founder_fenxiao_id']),
|
||
'founder_rate' => $order_fenxiao_data['founder_rate'],
|
||
'founder_commission' => $order_fenxiao_data['founder_commission'],
|
||
'founder_fenxiao_detail' => json_encode($order_fenxiao_data['founder_fenxiao_detail']),
|
||
'create_time' => time()
|
||
];
|
||
model("fenxiao_order")->add($data);
|
||
}
|
||
}
|
||
// // 分销商检测升级
|
||
event('FenxiaoUpgrade', [
|
||
'fenxiao_id' => $member_info[ 'fenxiao_id' ],
|
||
]);
|
||
return $this->success();
|
||
}
|
||
|
||
private function getPushFenXiaoCommission($fenxiao_info,$v,&$order_fenxiao_data,$type,$config){
|
||
$one_rate = $config['direct_rate'];
|
||
$two_rate = $config['indirect_rate'];
|
||
$one_money = $two_money = 0;
|
||
$parent_fenxiao_info = $fenxiao_info['parent'] > 0 ? model('fenxiao')->getInfo([ [ 'fenxiao_id', '=', $fenxiao_info[ 'parent' ] ], [ 'is_delete', '=', 0 ] ], 'fenxiao_id, fenxiao_name, status, parent,level_id') : [];
|
||
$g_parent_fenxiao_info = $fenxiao_info['grand_parent'] > 0 ? model('fenxiao')->getInfo([ [ 'fenxiao_id', '=', $fenxiao_info[ 'grand_parent' ] ], [ 'is_delete', '=', 0 ] ], 'fenxiao_id, fenxiao_name, status, parent,level_id') : [];
|
||
if (!empty($parent_fenxiao_info) && $parent_fenxiao_info[ 'status' ] == 1) {
|
||
if($type == 2){
|
||
$fenxiao_level = model('fenxiao_goods_sku')->getInfo([ [ 'goods_id', '=', $v[ 'goods_id' ] ], [ 'sku_id', '=', $v[ 'sku_id' ] ], [ 'level_id', '=', $parent_fenxiao_info[ 'level_id' ] ] ]);
|
||
if (empty($fenxiao_level)) return false;
|
||
$one_rate = $fenxiao_level['direct_rate'];
|
||
$one_money = $fenxiao_level['direct_money'];
|
||
}
|
||
if ($one_rate > 0) {
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'one_rate' ] = $one_rate;
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'one_commission' ] = $one_rate * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'one_rate' ] = round($one_money * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'one_commission' ] = $one_money * $v[ 'num' ];
|
||
}
|
||
$order_fenxiao_data['one_fenxiao_id'] = $parent_fenxiao_info['fenxiao_id'];
|
||
$order_fenxiao_data['one_fenxiao_name'] = $parent_fenxiao_info['fenxiao_name'];
|
||
}
|
||
if (!empty($g_parent_fenxiao_info) && $g_parent_fenxiao_info[ 'status' ] == 1) {
|
||
if($type == 2){
|
||
$fenxiao_level = model('fenxiao_goods_sku')->getInfo([ [ 'goods_id', '=', $v[ 'goods_id' ] ], [ 'sku_id', '=', $v[ 'sku_id' ] ], [ 'level_id', '=', $g_parent_fenxiao_info[ 'level_id' ] ] ]);
|
||
if (empty($fenxiao_level)) return false;
|
||
$two_rate = $fenxiao_level['indirect_rate'];
|
||
$two_money = $fenxiao_level['indirect_money'];
|
||
}
|
||
if ($two_rate > 0) {
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'two_rate' ] = $two_rate;
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'two_commission' ] = $two_rate * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'two_rate' ] = round($two_money * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'two_commission' ] = $two_money * $v[ 'num' ];
|
||
}
|
||
$order_fenxiao_data['two_fenxiao_id'] = $g_parent_fenxiao_info['fenxiao_id'];
|
||
$order_fenxiao_data['two_fenxiao_name'] = $g_parent_fenxiao_info['fenxiao_name'];
|
||
}
|
||
|
||
return $order_fenxiao_data;
|
||
}
|
||
|
||
private function getWholesaleFenXiaoCommission($fenxiao_info,$v,&$order_fenxiao_data,$config,$goods_kind = 0){
|
||
//不是报单商品才有自购
|
||
if($config['self_purchase_rebate'] && $fenxiao_info['level_num'] > 0 && $goods_kind === 0){
|
||
$order_fenxiao_data['wholesale_fenxiao_id'][] = $fenxiao_info['fenxiao_id'];
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'wholesale_rate' ] = $fenxiao_info[ 'one_rate' ];
|
||
$commission = $fenxiao_info[ 'one_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'wholesale_commission' ] = $commission;
|
||
$order_fenxiao_data['wholesale_fenxiao_detail'][] = ['name' => $fenxiao_info['fenxiao_name'], 'commission' => $commission];
|
||
}
|
||
if($fenxiao_info['chain']){
|
||
$data = explode(',', $fenxiao_info['chain']);
|
||
$chain = array_filter($data, function ($value) {
|
||
return !empty($value);
|
||
});
|
||
$count = count($chain);
|
||
|
||
//要删除最后一个数据，最后一个数据是自己的分销商ID
|
||
unset($chain[$count - 1]);
|
||
$chain = array_values($chain);
|
||
$chain = array_reverse($chain);
|
||
|
||
$nodeUser = Db::name('fenxiao')
|
||
->where('f.is_delete', '=', 0)
|
||
->alias('f')
|
||
->join('fenxiao_level l', 'f.level_id = l.level_id', 'right')
|
||
->where('f.fenxiao_id', '<>', $fenxiao_info['fenxiao_id'])
|
||
->whereIn('f.fenxiao_id', $chain)
|
||
->field('f.fenxiao_id,f.fenxiao_name,f.member_id,f.level_id,f.site_id,f.fenxiao_name,f.status,l.level_num,l.rank')
|
||
->select(); //获取上级用户
|
||
$nodeUser = $nodeUser ? $nodeUser->toArray() : [];
|
||
if(count($nodeUser) > 0){
|
||
$order_fenxiao_data = $this->getWholesaleCommission($nodeUser,$v,$order_fenxiao_data,$chain,$config,$goods_kind);
|
||
}
|
||
}
|
||
|
||
return $order_fenxiao_data;
|
||
}
|
||
|
||
protected function getWholesaleCommission($nodeUser,$v,&$order_fenxiao_data,$chain,$config,$goods_kind){
|
||
//不考虑商品单独规则
|
||
$fenxiao_user_id = array_column($nodeUser,'fenxiao_id');
|
||
$max_level_num = (int)model('fenxiao_level')->stat([['site_id' ,'=' , $v['site_id']]],'max','level_num');
|
||
foreach($chain as $k => $value){
|
||
$key = array_search($value,$fenxiao_user_id);
|
||
$user = $nodeUser[$key];
|
||
$rank = count($order_fenxiao_data['wholesale_fenxiao_id']);
|
||
if(!empty($user) && $rank < $user['rank'] && $rank <= 4){
|
||
$rate = $this->getLevelRate($rank,$v['site_id'],$config);
|
||
$order_fenxiao_data['wholesale_fenxiao_id'][] = $user['fenxiao_id'];
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'wholesale_rate' ] += $rate;
|
||
$commission = $rate * $v[ 'real_goods_money' ] / 100;
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'wholesale_commission' ] += $commission;
|
||
$order_fenxiao_data['wholesale_fenxiao_detail'][] = ['name' => $user['fenxiao_name'], 'commission' => $commission];
|
||
}
|
||
//联合创始人分红
|
||
if(isset($user) && !empty($user) && $max_level_num == $user['level_num'] && $config['founder_rate'] && $goods_kind === 0){
|
||
$order_fenxiao_data['founder_fenxiao_id'][] = $user['fenxiao_id'];
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'founder_rate' ] += $config['founder_rate'];
|
||
$commission = $config['founder_rate'] * $v[ 'real_goods_money' ] / 100;
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'founder_commission' ] += $commission;
|
||
$order_fenxiao_data['founder_fenxiao_detail'][] = ['name' => $user['fenxiao_name'], 'commission' => $commission];
|
||
}
|
||
}
|
||
return $order_fenxiao_data;
|
||
}
|
||
|
||
protected function getWholesaleCommissions($nodeUser,$v,&$order_fenxiao_data,$chain,$leve_num,$type,$config){
|
||
//不考虑商品单独规则
|
||
$fenxiao_user_id = array_column($nodeUser,'fenxiao_id');
|
||
$max_level_num = (int)model('fenxiao_level')->stat([['site_id' ,'=' , $v['site_id']]],'max','level_num');
|
||
foreach($chain as $k => $value){
|
||
$key = array_search($value,$fenxiao_user_id);
|
||
$user = $nodeUser[$key];
|
||
if(isset($user) && !empty($user) && $user['level_num'] == $leve_num && $leve_num > 1){
|
||
//独立设置的佣金
|
||
if($type == 2){
|
||
|
||
}else{
|
||
|
||
}
|
||
$order_fenxiao_data['wholesale_fenxiao_id'][] = $user['fenxiao_id'];
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'wholesale_rate' ] += $user[ 'two_rate' ];
|
||
$commission = $user[ 'two_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'wholesale_commission' ] += $commission;
|
||
$order_fenxiao_data['wholesale_fenxiao_detail'][] = ['name' => $user['fenxiao_name'], 'commission' => $commission];
|
||
++$leve_num;
|
||
}
|
||
//联合创始人分红
|
||
if(isset($user) && !empty($user) && $max_level_num == $user['level_num'] && $config['founder_rate']){
|
||
$order_fenxiao_data['founder_fenxiao_id'][] = $user['fenxiao_id'];
|
||
$order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'founder_rate' ] += $config['founder_rate'];
|
||
$commission = $config['founder_rate'] * $v[ 'real_goods_money' ] / 100;
|
||
$order_fenxiao_data['commission'] += $order_fenxiao_data[ 'founder_commission' ] += $commission;
|
||
$order_fenxiao_data['founder_fenxiao_detail'][] = ['name' => $user['fenxiao_name'], 'commission' => $commission];
|
||
}
|
||
}
|
||
return $order_fenxiao_data;
|
||
}
|
||
|
||
protected function getLevelRate($rank,$site_id,$config){
|
||
$level_config = model('fenxiao_level')->getInfo([['site_id' ,'=',$site_id],['level_num' ,'=' ,0],['is_default', '=' ,1]],'one_rate,two_rate,three_rate');
|
||
$rates = [
|
||
$level_config['one_rate'] ?? 0,
|
||
$level_config['two_rate'] ?? 0,
|
||
$level_config['three_rate'] ?? 0,
|
||
$config['four_rate'] ?? 0,
|
||
];
|
||
return $rates[$rank];
|
||
}
|
||
|
||
/**
|
||
* 订单退款
|
||
* @param $order_goods_id
|
||
* @return array
|
||
*/
|
||
public function refund($order_goods_id)
|
||
{
|
||
$order_goods_info = model('order_goods')->getInfo([ 'order_goods_id' => $order_goods_id ], 'refund_mode');
|
||
if ($order_goods_info[ 'refund_mode' ] == 1) {
|
||
$res = model("fenxiao_order")->update([ 'is_refund' => 1 ], [ [ 'order_goods_id', '=', $order_goods_id ] ]);
|
||
return $this->success($res);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 订单结算
|
||
* @param $order_id
|
||
*/
|
||
public function settlement($order_id)
|
||
{
|
||
//获取未退款的和未结算的分销订单
|
||
$fenxiao_orders = model("fenxiao_order")->getList([ [ 'order_id', '=', $order_id ], [ 'is_settlement', '=', 0 ], [ 'is_refund', '=', 0 ] ], '*');
|
||
//同时修改分销订单状态为已结算
|
||
model("fenxiao_order")->startTrans();
|
||
try {
|
||
model('fenxiao_order')->update([ 'is_settlement' => 1 ], [ [ 'order_id', '=', $order_id ] ]);
|
||
$commission = 0;
|
||
$fenxiao_account = new FenxiaoAccount();
|
||
$site_id = 0;
|
||
foreach ($fenxiao_orders as $fenxiao_order) {
|
||
$site_id = $fenxiao_order[ 'site_id' ];
|
||
$commission += $fenxiao_order[ 'one_commission' ];
|
||
$fenxiao_account->addAccount($fenxiao_order[ 'one_fenxiao_id' ], $fenxiao_order[ 'one_fenxiao_name' ], 'order', $fenxiao_order[ 'one_commission' ], $fenxiao_order[ 'fenxiao_order_id' ]);
|
||
|
||
// 分销佣金发放通知
|
||
( new Message() )->sendMessage([
|
||
'keywords' => 'COMMISSION_GRANT',
|
||
'order_id' => $fenxiao_order[ 'fenxiao_order_id' ],
|
||
'site_id' => $fenxiao_order[ 'site_id' ],
|
||
'level' => 'one',
|
||
]);
|
||
|
||
model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order[ 'one_fenxiao_id' ] ] ], 'total_commission', $fenxiao_order[ 'one_commission' ]);
|
||
|
||
if ($fenxiao_order[ 'two_commission' ] > 0) {
|
||
$commission += $fenxiao_order[ 'two_commission' ];
|
||
$fenxiao_account->addAccount($fenxiao_order[ 'two_fenxiao_id' ], $fenxiao_order[ 'two_fenxiao_name' ], 'order', $fenxiao_order[ 'two_commission' ], $fenxiao_order[ 'fenxiao_order_id' ]);
|
||
|
||
// 分销佣金发放通知
|
||
( new Message() )->sendMessage([
|
||
'keywords' => 'COMMISSION_GRANT',
|
||
'order_id' => $fenxiao_order[ 'fenxiao_order_id' ],
|
||
'site_id' => $fenxiao_order[ 'site_id' ],
|
||
'level' => 'two',
|
||
]);
|
||
|
||
model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order[ 'two_fenxiao_id' ] ] ], 'total_commission', $fenxiao_order[ 'two_commission' ]);
|
||
}
|
||
if ($fenxiao_order[ 'three_commission' ] > 0) {
|
||
$commission += $fenxiao_order[ 'three_commission' ];
|
||
$fenxiao_account->addAccount($fenxiao_order[ 'three_fenxiao_id' ], $fenxiao_order[ 'three_fenxiao_name' ], 'order', $fenxiao_order[ 'three_commission' ], $fenxiao_order[ 'fenxiao_order_id' ]);
|
||
// 分销佣金发放通知
|
||
( new Message() )->sendMessage([
|
||
'keywords' => 'COMMISSION_GRANT',
|
||
'order_id' => $fenxiao_order[ 'fenxiao_order_id' ],
|
||
'site_id' => $fenxiao_order[ 'site_id' ],
|
||
'level' => 'three',
|
||
]);
|
||
model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order[ 'three_fenxiao_id' ] ] ], 'total_commission', $fenxiao_order[ 'three_commission' ]);
|
||
}
|
||
}
|
||
$stat_model = new Stat();
|
||
$stat_model->switchStat([ 'type' => 'fenxiao_order', 'data' => [ 'order_id' => $order_id, 'site_id' => $site_id ] ]);
|
||
//增加订单佣金结算
|
||
model('order')->setInc([ [ 'order_id', '=', $order_id ] ], 'commission', $commission);
|
||
model("fenxiao_order")->commit();
|
||
return $this->success();
|
||
} catch (\Exception $e) {
|
||
model("fenxiao_order")->rollback();
|
||
return $this->error($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* calculateOrder 计算对应分销商的第一次订单数量&&金额
|
||
* @param $order_id
|
||
*/
|
||
public function calculateOrder($order_id)
|
||
{
|
||
$fenxiao_order_info = model('fenxiao_order')->getFirstData([ [ 'order_id', '=', $order_id ] ], 'one_fenxiao_id');
|
||
if (!empty($fenxiao_order_info)) {
|
||
$one_commission_sum = model('fenxiao_order')->getSum([ [ 'order_id', '=', $order_id ] ], 'one_commission');
|
||
$one_fenxiao_total_order = model('fenxiao_order')->getSum([ [ 'order_id', '=', $order_id ] ], 'real_goods_money');
|
||
model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order_info[ 'one_fenxiao_id' ] ] ], 'one_fenxiao_order_num');
|
||
model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order_info[ 'one_fenxiao_id' ] ] ], 'one_fenxiao_order_money', $one_commission_sum);
|
||
model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order_info[ 'one_fenxiao_id' ] ] ], 'one_fenxiao_total_order', $one_fenxiao_total_order);
|
||
// 分销商检测升级
|
||
event('FenxiaoUpgrade', [
|
||
'fenxiao_id' => $fenxiao_order_info[ 'one_fenxiao_id' ]
|
||
]);
|
||
}
|
||
return $this->success();
|
||
}
|
||
|
||
/**
|
||
* 获取分销订单列表
|
||
* @param unknown $condition
|
||
* @param number $page
|
||
* @param string $page_size
|
||
* @param string $order
|
||
*/
|
||
public function getFenxiaoOrderPageList($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = 'fo.order_id DESC')
|
||
{
|
||
$field = '
|
||
fo.fenxiao_order_id,fo.order_no,fo.site_id,fo.site_name,fo.sku_id,fo.sku_name,fo.sku_image,fo.price,fo.num,fo.real_goods_money,fo.member_name,
|
||
fo.member_mobile,fo.one_fenxiao_name,fo.is_settlement,fo.commission,fo.is_refund,
|
||
o.order_status_name,o.create_time,fo.one_fenxiao_id,fo.two_fenxiao_id,fo.three_fenxiao_id,fo.one_commission,fo.two_commission,fo.three_commission
|
||
';
|
||
|
||
$alias = 'fo';
|
||
$join = [
|
||
[
|
||
'order o',
|
||
'fo.order_id = o.order_id',
|
||
'inner'
|
||
]
|
||
];
|
||
$list = model('fenxiao_order')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
|
||
return $this->success($list);
|
||
}
|
||
|
||
/**
|
||
* 查询订单信息
|
||
* @param $condition
|
||
* @param string $field
|
||
* @return array
|
||
*/
|
||
public function getFenxiaoOrderInfo($condition, $field = '*')
|
||
{
|
||
$fenxiao_order_info = model('fenxiao_order')->getInfo($condition, $field);
|
||
return $this->success($fenxiao_order_info);
|
||
}
|
||
|
||
/**
|
||
* 查询订单信息
|
||
* @param $condition
|
||
* @param string $field
|
||
* @return array
|
||
*/
|
||
public function getFenxiaoOrderInfoNew($condition, $field = '*')
|
||
{
|
||
$alias = "fo";
|
||
$join = [
|
||
[
|
||
'order o',
|
||
'o.order_id = fo.order_id',
|
||
'left'
|
||
]
|
||
];
|
||
$fenxiao_order_info = model('fenxiao_order')->getInfo($condition, $field, $alias, $join);
|
||
return $this->success($fenxiao_order_info);
|
||
}
|
||
|
||
/**
|
||
* 查询分销订单列表(管理端调用)
|
||
*/
|
||
public function getFenxiaoOrderPage($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = 'order_id DESC')
|
||
{
|
||
$field = 'order_id,order_no,site_name,member_name,create_time,is_settlement,fenxiao_order_id';
|
||
$list = model('fenxiao_order')->pageList($condition, $field, $order, $page, $page_size, 'fo', [], 'order_id');
|
||
if (!empty($list[ 'list' ])) {
|
||
foreach ($list[ 'list' ] as $k => $item) {
|
||
$order_info = model('order')->getInfo([ [ 'order_id', '=', $item[ 'order_id' ] ] ], 'name,full_address,mobile,order_status_name,order_from_name,pay_type_name');
|
||
$list[ 'list' ][ $k ] = array_merge($list[ 'list' ][ $k ], $order_info);
|
||
|
||
$order_goods = model('fenxiao_order')->getList([ [ 'order_id', '=', $item[ 'order_id' ] ] ]);
|
||
$list[ 'list' ][ $k ][ 'order_goods' ] = $order_goods;
|
||
}
|
||
}
|
||
return $this->success($list);
|
||
}
|
||
|
||
/**
|
||
* 获取分销订单详情
|
||
* @param $order_id
|
||
*/
|
||
public function getFenxiaoOrderDetail($condition, $field = '*')
|
||
{
|
||
$order_info = model('order')->getInfo($condition, $field);
|
||
if (!empty($order_info)) {
|
||
$order_goods = model('fenxiao_order')->getList([ [ 'order_id', '=', $order_info[ 'order_id' ] ] ]);
|
||
$member_info = model("member")->getInfo([ 'member_id' => $order_info[ 'member_id' ] ], "nickname");
|
||
$order_info[ 'order_goods' ] = $order_goods;
|
||
$order_info[ 'nickname' ] = $member_info[ 'nickname' ];
|
||
}
|
||
return $this->success($order_info);
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取分销订单数量
|
||
* @param $condition
|
||
*/
|
||
public function getFenxiaoOrderCount($condition)
|
||
{
|
||
$count = model('fenxiao_order')->getCount($condition);
|
||
return $this->success($count);
|
||
}
|
||
|
||
/**
|
||
* 获取分销订单总和
|
||
* @param array $condition
|
||
* @param string $field
|
||
* @param string $alias
|
||
* @param null $join
|
||
* @return array
|
||
*/
|
||
public function getFenxiaoOrderSum(array $condition, $field = '', $alias = 'a', $join = null)
|
||
{
|
||
$data = model('fenxiao_order')->getSum($condition, $field, $alias, $join);
|
||
return $this->success($data);
|
||
}
|
||
|
||
/**
|
||
* 查询订单数据并导出
|
||
* @param $condition
|
||
*/
|
||
public function orderExport($condition, $site_id = 0)
|
||
{
|
||
|
||
$field = [
|
||
'order_no' => '订单编号',
|
||
'site_name' => '站点名称',
|
||
'sku_name' => '商品名称',
|
||
'member_name' => '购买人',
|
||
'member_mobile' => '购买人电话',
|
||
'commission' => '总佣金',
|
||
'one_rate' => '一级分销比例',
|
||
'one_commission' => '一级分销佣金',
|
||
'one_fenxiao_name' => '一级分销商名',
|
||
'two_rate' => '二级分销比例',
|
||
'two_commission' => '二级分销佣金',
|
||
'two_fenxiao_name' => '二级分销商名',
|
||
'three_rate' => '三级分销比例',
|
||
'three_commission' => '三级分销佣金',
|
||
'three_fenxiao_name' => '三级分销商名',
|
||
'is_settlement' => '是否结算',
|
||
'is_refund' => '是否退款',
|
||
'province_name' => '省',
|
||
'city_name' => '市',
|
||
'district_name' => '县',
|
||
'full_address' => '详细地址',
|
||
'order_status_name' => '订单状态'
|
||
];
|
||
|
||
$fields = 'fo.*,o.address,o.full_address,o.order_status_name';
|
||
$alias = 'fo';
|
||
$join = [
|
||
[
|
||
'order o',
|
||
'o.order_id = fo.order_id',
|
||
'left'
|
||
]
|
||
];
|
||
|
||
$list = model('fenxiao_order')->getList($condition, $fields, '', $alias, $join);
|
||
$head_html = [];
|
||
$line_html = [];
|
||
foreach ($field as $k => $v) {
|
||
$head_html[] = $v;
|
||
$line_html[] = $k;
|
||
}
|
||
|
||
$temp_line = implode(',', $head_html) . "\n";
|
||
$html = str_replace("\n", '', $temp_line) . "\n";
|
||
$line = implode(',', $line_html);
|
||
$html .= str_replace("\n", '', $line) . "\n";
|
||
|
||
$temp = [];
|
||
foreach ($line_html as $temp_line_k => $temp_line_v) {
|
||
$temp[] = "{\$$temp_line_v}";
|
||
}
|
||
|
||
$tempLine = implode(',', $temp) . "\n";
|
||
|
||
foreach ($list as $item) {
|
||
$new_line_value = $tempLine;
|
||
$address_arr = explode("-", $item[ 'full_address' ]);
|
||
$item[ 'province_name' ] = !empty($address_arr[ 0 ]) ? $address_arr[ 0 ] : "";
|
||
$item[ 'city_name' ] = !empty($address_arr[ 1 ]) ? $address_arr[ 1 ] : "";
|
||
$item[ 'district_name' ] = !empty($address_arr[ 2 ]) ? $address_arr[ 2 ] : "";
|
||
$item[ 'is_settlement' ] = $item[ 'is_settlement' ] == 0 ? "否" : "是";
|
||
$item[ 'is_refund' ] = $item[ 'is_refund' ] == 0 ? "否" : "是";
|
||
|
||
foreach ($item as $key => $val) {
|
||
if ($key == 'full_address') {
|
||
$address = $item[ 'address' ] ?? '';
|
||
$val = $val . $address;
|
||
}
|
||
|
||
//CSV比较简单，记得转义 逗号就好
|
||
$values = str_replace(',', '\\', $val . "\t");
|
||
$values = str_replace("\n", '', $values);
|
||
$new_line_value = str_replace("{\$$key}", $values, $new_line_value);
|
||
|
||
}
|
||
|
||
$html .= $new_line_value;
|
||
}
|
||
|
||
$filename = date('YmdHis') . '.csv'; //设置文件名
|
||
header("Content-type:text/csv");
|
||
header("Content-Disposition:attachment;filename=" . $filename);
|
||
header('Cache-Control:must-revalidate,post-check=0,pre-check=0');
|
||
header('Expires:0');
|
||
header('Pragma:public');
|
||
exit(mb_convert_encoding($html, "GBK", "UTF-8"));
|
||
|
||
}
|
||
|
||
/**
|
||
* 给csv写入新的数据
|
||
* @param $item_list
|
||
* @param $field_key
|
||
* @param $temp_line
|
||
* @param $fp
|
||
*/
|
||
public function itemExport($item_list, $field_key, $temp_line, $fp)
|
||
{
|
||
$item_list = $item_list->toArray();
|
||
foreach ($item_list as $k => $item_v) {
|
||
$new_line_value = $temp_line;
|
||
//省市县
|
||
$address_arr = explode("-", $item_v[ 'full_address' ]);
|
||
|
||
$item_v[ 'province_name' ] = $address_arr[ 0 ] ? $address_arr[ 0 ] : "";
|
||
$item_v[ 'city_name' ] = $address_arr[ 1 ] ? $address_arr[ 1 ] : "";
|
||
$item_v[ 'district_name' ] = $address_arr[ 2 ] ? $address_arr[ 2 ] : "";
|
||
|
||
foreach ($item_v as $key => $value) {
|
||
|
||
if ($key == 'full_address') {
|
||
$address = $item_v[ 'address' ] ?? '';
|
||
$value = $value . $address;
|
||
}
|
||
//CSV比较简单，记得转义 逗号就好
|
||
$values = str_replace(',', '\\', $value . "\t");
|
||
$values = str_replace("\n", '', $values);
|
||
$new_line_value = str_replace("{\$$key}", $values, $new_line_value);
|
||
}
|
||
//写入第一行表头
|
||
fwrite($fp, $new_line_value);
|
||
dump($new_line_value);
|
||
exit;
|
||
//销毁变量, 防止内存溢出
|
||
unset($new_line_value);
|
||
}
|
||
}
|
||
}
|