678 lines
32 KiB
PHP
678 lines
32 KiB
PHP
<?php
|
||
/**
|
||
* ThinkShop商城系统 - 团队十年电商经验汇集巨献!
|
||
* =========================================================
|
||
* Copy right 2019-2029 成都云之牛科技有限公司, 保留所有权利。
|
||
* ----------------------------------------------
|
||
* 官方网址: https://www.cdcloudshop.com
|
||
* =========================================================
|
||
*/
|
||
|
||
namespace addon\fenxiao\model;
|
||
|
||
use app\model\BaseModel;
|
||
use app\model\member\MemberAccount;
|
||
use app\model\message\Message;
|
||
use app\model\system\Stat;
|
||
use think\facade\Db;
|
||
use think\facade\Log;
|
||
|
||
/**
|
||
* 分销商品
|
||
*/
|
||
class FenxiaoOrder extends BaseModel
|
||
{
|
||
/***
|
||
* 区域代理结算
|
||
* 月结
|
||
* @return array
|
||
*/
|
||
public function areaMonthlySettlement()
|
||
{
|
||
//本月
|
||
$beginThismonth = mktime(0, 0, 0, date('m'), 1, date('Y'));
|
||
$endThismonth = mktime(23, 59, 59, date('m'), date('t'), date('Y'));
|
||
//上月
|
||
$begin_time = strtotime(date('Y-m-01 00:00:00', strtotime('-1 month')));
|
||
$end_time = strtotime(date("Y-m-d 23:59:59", strtotime(-date('d') . 'day')));
|
||
$fenxiao = Db::name('fenxiao_agent')->alias('a')->join(
|
||
'fenxiao f',
|
||
'a.fenxiao_id = f.fenxiao_id',
|
||
'left'
|
||
)->where([['f.status','=',1]])->column('f.fenxiao_id,f.site_id,member_id,fenxiao_name,agent_level_id,province_id,city_id,district_id,parent', 'f.fenxiao_id');
|
||
//获取分销基础配置
|
||
$config_model = new Config();
|
||
$fenxiao_basic_config = $config_model->getFenxiaoBasicsConfig(1);
|
||
$fenxiao_member_account = new MemberAccount();
|
||
foreach ($fenxiao as $fenxiao_id => $item) {
|
||
$fenxiao_agent_level = Db::name('fenxiao_agent_level')->where('level_id', '=', $item['agent_level_id'])->field('type,flower_multiple,status')->find();
|
||
$where = [
|
||
// ['fo.create_time', 'BETWEEN', [$begin_time, $end_time]],
|
||
['fo.create_time', 'BETWEEN', [$beginThismonth, $endThismonth]],
|
||
['o.'.$fenxiao_agent_level['type'].'_id', '=', $item[$fenxiao_agent_level['type'].'_id']]
|
||
];
|
||
$fenxia_area_order_info = Db::name('fenxiao_order')
|
||
->alias('fo')
|
||
->join('order o','fo.order_id=o.order_id','LEFT')
|
||
->where($where)
|
||
->field('sum(real_goods_money) as real_goods_money')
|
||
->find();
|
||
$money = $fenxia_area_order_info['real_goods_money'] * $fenxiao_agent_level['flower_multiple']/100;
|
||
$fenxiao_member_account->addMemberAccount($item[ 'site_id' ], $item['member_id'], 'balance_money', $money, 'area', '区域代理结算', '区域代理结算');
|
||
|
||
}
|
||
return $this->success();
|
||
}
|
||
|
||
/**
|
||
* 分销订单计算
|
||
* @param unknown $order
|
||
*/
|
||
public function calculate($order)
|
||
{
|
||
//获取分销基础配置
|
||
$config_model = new Config();
|
||
$fenxiao_basic_config = $config_model->getFenxiaoBasicsConfig($order[ 'site_id' ]);
|
||
$level_config = $fenxiao_basic_config[ 'data' ][ 'value' ][ 'level' ];
|
||
if (empty($level_config)) {
|
||
return $this->success();
|
||
}
|
||
//检测分销商上级关系
|
||
$member_info = model("member")->getInfo([ [ 'member_id', '=', $order[ 'member_id' ] ] ], 'fenxiao_id,is_fenxiao');
|
||
//如果没有分销商直接返回不计算,没有考虑首次付款上下级绑定
|
||
if(empty($member_info)){
|
||
return $this->success();
|
||
}
|
||
if ($member_info[ 'fenxiao_id' ] == 0) {
|
||
return $this->success();
|
||
}
|
||
|
||
$fenxiao_id = $member_info[ 'fenxiao_id' ];
|
||
$fenxiao_info = model("fenxiao")->getInfo([ [ 'fenxiao_id', '=', $fenxiao_id ], [ '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, 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' ] ] ]);
|
||
//获取分销等级
|
||
$order['give_diamond'] = 0;
|
||
foreach ($order_goods as $k => $v) {
|
||
//商品信息管理
|
||
$goods_info = model("goods")->getInfo([ [ 'goods_id', '=', $v[ 'goods_id' ] ] ], 'is_fenxiao, fenxiao_type,give_diamond');
|
||
if ($goods_info[ 'is_fenxiao' ] != 1) {
|
||
$order['give_diamond'] += $goods_info['give_diamond'];
|
||
continue;
|
||
}
|
||
|
||
$sku_info = model('goods_sku')->getInfo([ [ 'sku_id', '=', $v[ 'sku_id' ] ] ], 'fenxiao_price');
|
||
if (!empty($sku_info) && $sku_info[ 'fenxiao_price' ] > 0) $v[ 'real_goods_money' ] = $sku_info[ 'fenxiao_price' ] * $v[ 'num' ];
|
||
|
||
$commission = 0;
|
||
$commission_rate = 0;
|
||
$order_fenxiao_data = [];
|
||
|
||
if ($goods_info[ 'fenxiao_type' ] == 2) {
|
||
// 自定义分销规则
|
||
$fenxiao_level = model('fenxiao_goods_sku')->getInfo([ [ 'goods_id', '=', $v[ 'goods_id' ] ], [ 'sku_id', '=', $v[ 'sku_id' ] ], [ 'level_id', '=', $fenxiao_info[ 'level_id' ] ] ]);
|
||
if (empty($fenxiao_level)) continue;
|
||
|
||
if ($fenxiao_info[ 'status' ] == 1) {
|
||
if ($member_info[ 'is_fenxiao' ] == 1) {
|
||
if ($fenxiao_basic_config[ 'data' ][ 'value' ][ 'self_purchase_rebate' ]) {
|
||
if ($fenxiao_level[ 'one_rate' ] > 0) {
|
||
$commission_rate += $order_fenxiao_data[ 'one_rate' ] = $fenxiao_level[ 'one_rate' ];
|
||
$commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$commission_rate += $order_fenxiao_data[ 'one_rate' ] = round($fenxiao_level[ 'one_money' ] * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
|
||
$commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_money' ] * $v[ 'num' ];
|
||
}
|
||
} else {
|
||
$order_fenxiao_data[ 'one_rate' ] = 0;
|
||
$order_fenxiao_data[ 'one_commission' ] = 0;
|
||
}
|
||
} else {
|
||
if ($fenxiao_level[ 'one_rate' ] > 0) {
|
||
$commission_rate += $order_fenxiao_data[ 'one_rate' ] = $fenxiao_level[ 'one_rate' ];
|
||
$commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$commission_rate += $order_fenxiao_data[ 'one_rate' ] = round($fenxiao_level[ 'one_money' ] * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
|
||
$commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_money' ] * $v[ 'num' ];
|
||
}
|
||
}
|
||
}
|
||
if (!empty($parent_fenxiao_info) && $parent_fenxiao_info[ 'status' ] == 1) {
|
||
if ($fenxiao_level[ 'two_rate' ] > 0) {
|
||
$commission_rate += $order_fenxiao_data[ 'two_rate' ] = $fenxiao_level[ 'two_rate' ];
|
||
$commission += $order_fenxiao_data[ 'two_commission' ] = $fenxiao_level[ 'two_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$commission_rate += $order_fenxiao_data[ 'two_rate' ] = round($fenxiao_level[ 'two_money' ] * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
|
||
$commission += $order_fenxiao_data[ 'two_commission' ] = $fenxiao_level[ 'two_money' ] * $v[ 'num' ];
|
||
}
|
||
}
|
||
if (!empty($grand_parent_fenxiao_info) && $grand_parent_fenxiao_info[ 'status' ] == 1) {
|
||
if ($fenxiao_level[ 'three_rate' ] > 0) {
|
||
$commission_rate += $order_fenxiao_data[ 'three_rate' ] = $fenxiao_level[ 'three_rate' ];
|
||
$commission += $order_fenxiao_data[ 'three_commission' ] = $fenxiao_level[ 'three_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$commission_rate += $order_fenxiao_data[ 'three_rate' ] = round($fenxiao_level[ 'three_money' ] * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
|
||
$commission += $order_fenxiao_data[ 'three_commission' ] = $fenxiao_level[ 'three_money' ] * $v[ 'num' ];
|
||
}
|
||
}
|
||
} else {
|
||
// 默认规则
|
||
$fenxiao_level = model('fenxiao_level')->getInfo([ [ 'level_id', '=', $fenxiao_info[ 'level_id' ] ] ]);
|
||
if ($fenxiao_info[ 'status' ] == 1) {
|
||
if ($member_info[ 'is_fenxiao' ] == 1) {
|
||
if ($fenxiao_basic_config[ 'data' ][ 'value' ][ 'self_purchase_rebate' ]) {
|
||
if ($fenxiao_level[ 'one_rate' ] > 0) {
|
||
$commission_rate += $order_fenxiao_data[ 'one_rate' ] = $fenxiao_level[ 'one_rate' ];
|
||
$commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$order_fenxiao_data[ 'one_rate' ] = 0;
|
||
$order_fenxiao_data[ 'one_commission' ] = 0;
|
||
}
|
||
} else {
|
||
$order_fenxiao_data[ 'one_rate' ] = 0;
|
||
$order_fenxiao_data[ 'one_commission' ] = 0;
|
||
}
|
||
} else {
|
||
if ($fenxiao_level[ 'one_rate' ] > 0) {
|
||
$commission_rate += $order_fenxiao_data[ 'one_rate' ] = $fenxiao_level[ 'one_rate' ];
|
||
$commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$order_fenxiao_data[ 'one_rate' ] = 0;
|
||
$order_fenxiao_data[ 'one_commission' ] = 0;
|
||
}
|
||
}
|
||
}
|
||
if (!empty($parent_fenxiao_info) && $parent_fenxiao_info[ 'status' ] == 1) {
|
||
if ($fenxiao_level[ 'two_rate' ] > 0) {
|
||
$commission_rate += $order_fenxiao_data[ 'two_rate' ] = $fenxiao_level[ 'two_rate' ];
|
||
$commission += $order_fenxiao_data[ 'two_commission' ] = $fenxiao_level[ 'two_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$order_fenxiao_data[ 'two_rate' ] = 0;
|
||
$order_fenxiao_data[ 'two_commission' ] = 0;
|
||
}
|
||
}
|
||
if (!empty($grand_parent_fenxiao_info) && $grand_parent_fenxiao_info[ 'status' ] == 1) {
|
||
if ($fenxiao_level[ 'three_rate' ] > 0) {
|
||
$commission_rate += $order_fenxiao_data[ 'three_rate' ] = $fenxiao_level[ 'three_rate' ];
|
||
$commission += $order_fenxiao_data[ 'three_commission' ] = $fenxiao_level[ 'three_rate' ] * $v[ 'real_goods_money' ] / 100;
|
||
} else {
|
||
$order_fenxiao_data[ 'three_rate' ] = 0;
|
||
$order_fenxiao_data[ 'three_commission' ] = 0;
|
||
}
|
||
}
|
||
}
|
||
|
||
//启动分销
|
||
$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' => $order_goods[ $k ][ 'real_goods_money' ],
|
||
'member_id' => $order[ 'member_id' ],
|
||
'member_name' => $order[ 'name' ],
|
||
'member_mobile' => $order[ 'mobile' ],
|
||
'full_address' => $order[ 'full_address' ] . $order[ 'address' ],
|
||
'commission' => $commission,
|
||
'commission_rate' => $commission_rate,
|
||
'one_fenxiao_id' => empty($fenxiao_info) ? 0 : $fenxiao_info[ 'fenxiao_id' ],
|
||
'one_rate' => empty($order_fenxiao_data[ 'one_rate' ]) ? 0 : $order_fenxiao_data[ 'one_rate' ],
|
||
'one_commission' => empty($order_fenxiao_data[ 'one_commission' ]) ? 0 : $order_fenxiao_data[ 'one_commission' ],
|
||
'one_fenxiao_name' => empty($fenxiao_info) ? '' : $fenxiao_info[ 'fenxiao_name' ],
|
||
'two_fenxiao_id' => empty($parent_fenxiao_info) ? 0 : $parent_fenxiao_info[ 'fenxiao_id' ],
|
||
'two_rate' => empty($order_fenxiao_data[ 'two_rate' ]) ? 0 : $order_fenxiao_data[ 'two_rate' ],
|
||
'two_commission' => empty($order_fenxiao_data[ 'two_commission' ]) ? 0 : $order_fenxiao_data[ 'two_commission' ],
|
||
'two_fenxiao_name' => empty($parent_fenxiao_info) ? '' : $parent_fenxiao_info[ 'fenxiao_name' ],
|
||
'three_fenxiao_id' => empty($grand_parent_fenxiao_info) ? '' : $grand_parent_fenxiao_info[ 'fenxiao_id' ],
|
||
'three_rate' => empty($order_fenxiao_data[ 'three_rate' ]) ? 0 : $order_fenxiao_data[ 'three_rate' ],
|
||
'three_commission' => empty($order_fenxiao_data[ 'three_commission' ]) ? 0 : $order_fenxiao_data[ 'three_commission' ],
|
||
'three_fenxiao_name' => empty($grand_parent_fenxiao_info) ? '' : $grand_parent_fenxiao_info[ 'fenxiao_name' ],
|
||
'create_time' => time()
|
||
];
|
||
|
||
model("fenxiao_order")->add($data);
|
||
}
|
||
if($order['promotion_type'] != 'futures'){
|
||
$this->orderGive($order);
|
||
}
|
||
// 分销商检测升级
|
||
event('FenxiaoUpgrade', $member_info[ 'fenxiao_id' ]);
|
||
|
||
return $this->success('Fenxiao');
|
||
}
|
||
|
||
/***
|
||
* 下单赠送
|
||
* @param $order
|
||
* @return array
|
||
*/
|
||
public function orderGive($order)
|
||
{
|
||
$id = model('fenxiao_account')->getValue([
|
||
'type' => 'points',
|
||
'relate_id' => $order['order_id'],
|
||
], 'id');//验证下单重复赠送
|
||
if (!$id) {
|
||
$i_fenxiao = model('fenxiao')->getInfo(['member_id' => $order['member_id'], 'site_id' => $order['site_id']], 'fenxiao_id,fenxiao_name,parent,grand_parent');
|
||
if ($i_fenxiao) {
|
||
$fenxiao_account = new FenxiaoAccount;
|
||
$fenxiao_account->addAccount($i_fenxiao['fenxiao_id'], $i_fenxiao['fenxiao_name'], 'diamond', $order['give_diamond'], $order['order_id'],'diamond', '商品下单赠送');
|
||
}
|
||
}
|
||
return $this->success();
|
||
}
|
||
/**
|
||
* 每日结算
|
||
* @return array
|
||
*/
|
||
public function daySettlement(){
|
||
$fenxiaoList = model('fenxiao')->getList([['status', '=', 1],['points', '>', 0]],'fenxiao_id,fenxiao_name,points,contribution,site_id,member_id');
|
||
$config_model = new Config();
|
||
$menber_account = new MemberAccount();
|
||
$fenxiao_account = new FenxiaoAccount();
|
||
foreach($fenxiaoList as $fenxiao){
|
||
$basic_config = $config_model->getFenxiaoBasicsConfig($fenxiao['site_id'])['data']['value'];
|
||
$point_ratio = $basic_config['settlement_points_to_point_ratio'] / 100;//0.5
|
||
$balance_money_ratio = $basic_config['settlement_points_to_balance_money_ratio'] / 100;//0.5
|
||
$points_ratio = $basic_config['no_contribution_points_ratio'] / 100;//0.0005
|
||
if($fenxiao['contribution'] > 0){
|
||
$points_ratio = $basic_config['contribution_points_ratio'] / 100;//0.001
|
||
}
|
||
$points = $fenxiao['points'] * $points_ratio;
|
||
$point = $points * $point_ratio;
|
||
$balance_money = $points * $balance_money_ratio;
|
||
|
||
$menber_account->addMemberAccount($fenxiao[ 'site_id' ], $fenxiao['member_id'], 'point', $point, 'day_settlement', '每日转换', '每日转换');
|
||
$menber_account->addMemberAccount($fenxiao[ 'site_id' ], $fenxiao['member_id'], 'balance_money', $balance_money, 'day_settlement', '每日转换', '每日转换');
|
||
|
||
$fenxiao_account->addAccount($fenxiao['fenxiao_id'], $fenxiao['fenxiao_name'], 'points', -$points, 0,'points', '每日转换消耗');
|
||
if($fenxiao['contribution'] > 0){
|
||
$fenxiao_account->addAccount($fenxiao['fenxiao_id'],$fenxiao['fenxiao_name'],'contribution',-$points,0,'contribution','每日转换消耗');
|
||
}
|
||
}
|
||
return $this->success();
|
||
}
|
||
|
||
/**
|
||
* 订单退款
|
||
* @param $order_goods_id
|
||
* @return array
|
||
*/
|
||
public function refund($order_goods)
|
||
{
|
||
$order_goods_info = model('order_goods')->getInfo([ 'order_goods_id' => $order_goods[ 'order_goods_id' ] ], 'refund_mode');
|
||
$goode_info = model('goods')->getInfo([['goods_id', '=', $order_goods['goods_id']]]);
|
||
|
||
if ($order_goods_info[ 'refund_mode' ] == 1) {
|
||
$i_fenxiao = model('fenxiao')->getInfo(['member_id' => $order_goods['member_id']], 'fenxiao_id,fenxiao_name,parent,grand_parent');
|
||
if ($i_fenxiao) {
|
||
$fenxiao_account = new FenxiaoAccount;
|
||
$fenxiao_account->addAccount($i_fenxiao['fenxiao_id'], $i_fenxiao['fenxiao_name'], 'diamond', -$goode_info['give_diamond'], $goode_info['order_id'],'diamond', '商品退款扣除');
|
||
}
|
||
$res = model("fenxiao_order")->update([ 'is_refund' => 1 ], [ [ 'order_goods_id', '=', $order_goods[ '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_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');
|
||
$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);
|
||
}
|
||
}
|
||
} |