diff --git a/crmeb/jobs/SupplyChainOrderBrokerAgeJob.php b/crmeb/jobs/SupplyChainOrderBrokerAgeJob.php index a961e6ba..86833cfc 100644 --- a/crmeb/jobs/SupplyChainOrderBrokerAgeJob.php +++ b/crmeb/jobs/SupplyChainOrderBrokerAgeJob.php @@ -87,45 +87,46 @@ class SupplyChainOrderBrokerAgeJob implements JobInterface // 增加小组服务佣金 $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')->whereIn('parent_code', [$village_id, $street_id, $area_id, $city_code]) - ->select(); // 获取关联上级团队 + + // 后台分组用户开始 + $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')->whereIn('parent_code', [$village_id, $street_id, $area_id, $city_code]) + ->select(); // 获取关联上级团队 - if($supplyChainTeam) - { - // 进行分佣 - foreach ($supplyChainTeam as $v) { + if($supplyChainTeam) + { + // 进行分佣 + foreach ($supplyChainTeam as $v) { - // 可获得金额 - $usrPrice = floatval(($price/100)*$v['level']['rate']); + // 可获得金额 + $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' => $supplyTeam['id'], // 供应链团队ID - 'brokerage_rate' => $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); - } + // 储存小组服务分佣记录 + SupplyChainBorkerage::create($dataArr); + } + } } \think\facade\Log::record('供应链佣金分布执行完毕');