<?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;
use addon\fenxiao\model\Config as ConfigModel;
/**
 * 分销商品
 */
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' => [],
                'weight_money' => 0,
                // 'weight_fenxiao_id' => [],
                'is_weight'    => 0
            ];

            $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'],$goods_info['fenxiao_type']);

            if(($order_fenxiao_data['commission'] && $order_fenxiao_data['commission_rate']) || $order_fenxiao_data['wholesale_rate'] || $order_fenxiao_data['founder_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']),
                    'is_weight'                => $order_fenxiao_data['is_weight'],
                    // 'weight_fenxiao_id'        => json_encode($order_fenxiao_data['weight_fenxiao_id']),
                    'weight_money'             => $order_fenxiao_data['weight_money'],
                    'create_time'        => time()
                ];

                model("fenxiao_order")->add($data);
            }
        }
        // // 分销商检测升级
        event('FenxiaoUpgrade', [
            'fenxiao_id' => $member_info[ 'fenxiao_id' ],
        ]);
        //检测升级
        if($fenxiao_info['parent']){
            // 分销商检测升级
            event('FenxiaoUpgrade', [
                'fenxiao_id' => $fenxiao_info['parent']
            ]);
        }
        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,$fenxiao_type = 1){
        //不是报单商品才有自购
        if($config['self_purchase_rebate'] && $fenxiao_info['level_num'] > 0 && $goods_kind === 0){
            $rate = $this->getLevelRate(0,$v['site_id'],$v['goods_id'],$v['sku_id'],$fenxiao_info['level_id'],$config,$fenxiao_type);

            $order_fenxiao_data['wholesale_fenxiao_id'][] = $fenxiao_info['fenxiao_id'];
            $order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'wholesale_rate' ] = $rate;

            $commission = $rate * $v[ '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,l.is_weight')
                ->select(); //获取上级用户
            $nodeUser = $nodeUser ? $nodeUser->toArray() : [];
            if(count($nodeUser) > 0){
                $order_fenxiao_data = $this->getWholesaleCommission($nodeUser,$v,$order_fenxiao_data,$chain,$config,$goods_kind,$fenxiao_type);
            }
        }

        return $order_fenxiao_data;
    }

    protected function getWholesaleCommission($nodeUser,$v,&$order_fenxiao_data,$chain,$config,$goods_kind,$fenxiao_type){
        //不考虑商品单独规则
        $fenxiao_user_id =  array_column($nodeUser,'fenxiao_id');
        $max_level_num = (int)model('fenxiao_level')->stat([['site_id' ,'=' , $v['site_id']]],'max','level_num');
        $one_fenxiao_id = $order_fenxiao_data['one_fenxiao_id'];
        $two_fenxiao_id = $order_fenxiao_data['two_fenxiao_id'];
        foreach($chain as $k => $value){
            $key = array_search($value,$fenxiao_user_id);
            $user = $nodeUser[$key];

            $rank = $goods_kind ? count($order_fenxiao_data['wholesale_fenxiao_id']) + 1 : count($order_fenxiao_data['wholesale_fenxiao_id']);
            //直推和间推也需要计算
            if(!empty($user) && $rank < $user['rank'] && $rank <= 4){
                $rate = $this->getLevelRate($rank,$v['site_id'],$v['goods_id'],$v[ 'sku_id' ],$user['level_id'],$config,$fenxiao_type);
                if($user['rank'] == 1 && ($one_fenxiao_id != $user['fenxiao_id'] && $two_fenxiao_id != $user['fenxiao_id'])){
                    $order_fenxiao_data['wholesale_fenxiao_id'][] = $user['fenxiao_id'];
                    $order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'wholesale_rate' ] += $rate;
                    $commission = $rate * $v[ '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];
                }else if($user['rank'] > 1){
                    $order_fenxiao_data['wholesale_fenxiao_id'][] = $user['fenxiao_id'];
                    $order_fenxiao_data['commission_rate'] += $order_fenxiao_data[ 'wholesale_rate' ] += $rate;
                    $commission = $rate * $v[ '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[ '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];
            }
            //计算加权分红
            if(!$order_fenxiao_data['is_weight'] && $goods_kind === 0){
                $is_weight = $user['is_weight'];
                if($is_weight){

                    $weight_money = $config['weight_rate'] * $v[ 'goods_money' ] / 100;
                    $order_fenxiao_data['weight_money'] = $weight_money;
                }
                $order_fenxiao_data['is_weight'] = $is_weight;
            }
        }
        return $order_fenxiao_data;
    }


    protected function getLevelRate($rank,$site_id,$goods_id,$sku_id,$level_id,$config,$fenxiao_type){
        if($fenxiao_type == 2){
            $fenxiao_level = model('fenxiao_goods_sku')->getInfo([ [ 'goods_id', '=', $goods_id ], [ 'sku_id', '=', $sku_id ], [ 'level_id', '=', $level_id ] ]);
            $rates = [
                $fenxiao_level['one_rate'] ?? 0,
                $fenxiao_level['two_rate'] ?? 0,
                $fenxiao_level['three_rate'] ?? 0,
                $fenxiao_level['four_rate'] ?? 0,
            ];
        }else{
            $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' ],$site_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' ],$site_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' ],$site_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');
        $alias = 'a';
        $join = [
            ['goods g', 'a.goods_id = g.goods_id', 'right']
        ];
        $order_goods = model('order_goods')->getList([ [ 'a.order_id', '=', $order_id ], [ 'a.is_fenxiao', '=', 1 ] ],'a.goods_id,a.member_id,a.real_goods_money,a.sku_id,g.goods_kind_id','',$alias,$join);
        if($order_goods){
            foreach($order_goods as $k => $v){
                $fenxiao_order_info = model('fenxiao_order')->getFirstData([ [ 'order_id', '=', $order_id ],['sku_id', '=' ,$v['sku_id']] ], 'one_fenxiao_id,wholesale_fenxiao_id');

                if($v['goods_kind_id'] == 1){
                    $one_fenxiao_id = $fenxiao_order_info['two_fenxiao_id'];
                }else{
                    //进货产品不会产生直推奖，也就没有一级分销商ID
                    $json = json_decode($fenxiao_order_info['wholesale_fenxiao_id'],true);
                    $one_fenxiao_id = isset($json[1]) ? $json[1] : 0;
                }
                $one_fenxiao_total_order = model('fenxiao_order')->getSum([ [ 'order_id', '=', $order_id ] ], 'real_goods_money');
                if($one_fenxiao_id){
                    model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $one_fenxiao_id ] ], 'one_fenxiao_total_order', $one_fenxiao_total_order);
                    // 分销商检测升级
                    event('FenxiaoUpgrade', [
                        'fenxiao_id' => $one_fenxiao_id
                    ]);
                }
            }
        }
        //需要重新找上级，因为进货订单
        if (!empty($fenxiao_order_info)) {

            model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order_info[ 'one_fenxiao_id' ] ] ], 'one_fenxiao_order_num');
            $one_commission_sum = model('fenxiao_order')->getSum([ [ 'order_id', '=', $order_id ] ], 'one_commission');
            model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $one_fenxiao_id ] ], 'one_fenxiao_order_money', $one_commission_sum);

            // 分销商检测升级
            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',$or = [])
    {
        $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
        ,fo.wholesale_fenxiao_id,fo.wholesale_fenxiao_detail,fo.founder_fenxiao_id,fo.founder_fenxiao_detail';

        $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,null,null,$or);
        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 getFenxiaoOrderList($condition, $field = '*')
    {
        $fenxiao_order_info = model('fenxiao_order')->getList($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);
        }
    }
}