<?php

// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------


namespace crmeb\jobs;


use app\common\repositories\user\UserBrokerageRepository;
use app\common\repositories\user\UserRepository;
use crmeb\interfaces\JobInterface;
use think\facade\Log;
use app\common\model\system\supplychain\SupplyChainBorkerage;
use app\common\model\system\supplychain\SupplyChainTeam;
use app\common\model\system\supplychain\SupplyChainLevel;
use app\common\model\system\supplychain\SupplyChainLinkMerchant;
use app\common\repositories\user\UserBillRepository;
use app\common\model\user\User;
use app\common\model\store\GeoArea;

/**
 * 
 * 供应链分佣队列
 * 
 */
class SupplyChainOrderBrokerAgeJob implements JobInterface
{
    public function fire($job, $data)
    {
        try {
            return false;
            // 获取当前用户
            $user = app()->make(UserRepository::class)->get($data['uid']);
            $supplyTeam = SupplyChainTeam::find($user['fa_supply_team_id']); 
            $supplyTeamId = SupplyChainLinkMerchant::where('eb_merchant_id', $data['mer_id'])->value('fa_supply_chain_id'); // 获取供应链团队ID
            $supplyLevel = SupplyChainLevel::find($supplyTeam['supply_level_id']); // 获取供应链等级
            $price = $data['brokerage_price']; // 待分润金额 == 订单佣金金额

            // 判断 存在数据的话，进行分润
            if($supplyTeam)
            {   
                // 可获得金额
                $usrPrice = floatval(($price/100)*$supplyLevel['rate']);

                // 分润数据
                $dataArr = [
                    'user_id' => $data['uid'],  // 用户ID
                    'pay_price' => $data['inc'], // 订单金额
                    'price' => $price, // 订单分佣金额
                    'order_sn' =>  $data['order_sn'], // 订单编号
                    'supply_sn' =>  $data['order_sn'], // 订单编号
                    'order_id' =>  $data['order_id'], // 订单ID
                    'mer_id' =>  $data['mer_id'], // 商户ID
                    'status' => 1,
                    'supply_level_id' =>  $supplyLevel['id'], // 分佣等级ID
                    'brokerage_price' =>  $usrPrice, // 获取的佣金金额
                    'user_info' =>  $user['nickname'], // 用户名
                    'fa_supply_chain_id' =>  $supplyTeamId, // 供应链团队ID
                    'brokerage_rate' => $supplyLevel['rate'] // 分佣比例
                ];

                // 储存小组服务分佣记录
                SupplyChainBorkerage::create($dataArr);
                // 写入冻结佣金
                $userBillRepository = app()->make(UserBillRepository::class);
                
                // 加入账单记录 佣金明细
                $userBillRepository->incBill($data['uid'], 'brokerage', 'order_one', [
                    'link_id' => $data['order_id'],
                    'status' => 0,
                    'title' => '获得采购佣金',
                    'number' => $usrPrice, // 增加金额
                    'mark' => $data['order_sn'] . '采购：' . $data['inc'] . '元,获得采购佣金' . $usrPrice,
                    'balance' => 0,
                    'source' => 1  // 1 小组采购 2 普通商品
                ]);

                $userRepository = app()->make(UserRepository::class);

                // 增加小组服务佣金
                $userRepository->incSupplyBrokerage($data['uid'], $price);
            
                // 后台分组用户开始
                $userInfo = User::with('nkUserMsg')->find($data['uid']); // 当前用户信息
                $nkUserMsg = $userInfo['nkUserMsg']; // 当前用户关联上级街道、区县等信息

                $brigade_id = $nkUserMsg['brigade_id']; // 大队
                $village_id = $nkUserMsg['village_id']; // 村
                $street_id = $nkUserMsg['street_id']; //镇
                $area_id = $nkUserMsg['area_id']; // 区域
                $city_code = GeoArea::where('area_code', $area_id)->value('city_code'); // 市
                
                // 获取供应链团队
                $supplyChainTeam = SupplyChainTeam::with('level')
                    ->where('parent_code', 'in', [$brigade_id, $village_id, $street_id, $area_id, $city_code])
                    ->select(); // 获取关联上级团队

                if($supplyChainTeam)
                {
                    // 进行分佣
                    foreach ($supplyChainTeam as $v) {

                        // 可获得金额
                        $usrPrice = floatval(($price/100)*$v['level']['rate']);

                        // 分润数据
                        $dataArr = [
                            'supply_team_id' => $v['id'],  // 团队ID
                            'pay_price' => $data['inc'], // 订单金额
                            'price' => $price, // 订单分佣金额
                            'order_sn' =>  $data['order_sn'], // 订单编号
                            'supply_sn' =>  $data['order_sn'], // 订单编号
                            'order_id' =>  $data['order_id'], // 订单ID
                            'mer_id' =>  $data['mer_id'], // 商户ID
                            'supply_level_id' =>  $v['supply_level_id'], // 分佣等级ID
                            'brokerage_price' =>  $usrPrice, // 获取的佣金金额
                            'fa_supply_chain_id' =>  $supplyTeamId, // 供应链团队ID
                            'brokerage_rate' => $v['level']['rate'] // 分佣比例
                        ];

                        SupplyChainBorkerage::create($dataArr); // 储存小组服务分佣记录
                        SupplyChainTeam::where('id', $v['id'])->inc('free_brokerage', $usrPrice)->update(); // 增加冻结佣金
                    }   
                }
            }
            
            \think\facade\Log::record('供应链佣金分布执行完毕');

        } catch (\Exception $e) {
            Log::info('小组服务佣金同步失败: ' . var_export($data, 1) . $e->getMessage());
        }

        $job->delete();

    }

    public function failed($data)
    {
    }
}