agent = $agent; $this->user_id = $agent->user_id; $this->level_name = $level_name; $this->mall_id = $mall_id; $this->order_price = $price; $this->goods_id = $goods_id; $this->num = $num; $this->order_type = $order_type; $this->order_id = $order_id; } /** * 直推代理奖励 */ public function addRewardLog() { $this->getRewardUnitPrice(); //奖励金额,不记录 if (empty($this->reward_unit_price)) return false; //投递到资产队列 $insert_wallet = $this->getInsertWallet(UserWalletEnum::FIRST); if ($insert_wallet) CloudStockTwoAgent::sendUserWalletQueue($insert_wallet); } /** * 代理补货奖励 */ public function addFillRewardLog($order) { if($order['is_first']){ return false; } $this->fill_order = $order; $this->getFillRewardUnitPrice(); //奖励金额,不记录 if (empty($this->reward_unit_price)) return false; //投递到资产队列 $insert_wallet = $this->getInsertWallet(UserWalletEnum::FIRST); if ($insert_wallet) CloudStockTwoAgent::sendUserWalletQueue($insert_wallet); } /** * 获取对应等级商品奖励金额单价 */ protected function getRewardUnitPrice() { $user = User::findOne(['id'=>$this->user_id]); if(!$user || !$user['parent_id']){ $this->reward_unit_price = 0; return false; } $parent_agent = CloudStockTwoAgent::findOne(['user_id' => $user['parent_id'], 'mall_id' => $this->mall_id,'status'=>StatusEnum::ENABLED]); $this->parent_agent = $parent_agent; if(!$parent_agent){ $this->reward_unit_price = 0; return false; } $parent_agent_level = CloudStockTwoLevel::findOne(['mall_id' => $this->mall_id, 'level' => $parent_agent['level'], 'status' => StatusEnum::ENABLED]); if(!$parent_agent_level || empty($parent_agent_level['is_recommender_reward'])){ $this->reward_unit_price = 0; return false; } $agent_setting_info = json_decode($parent_agent_level['agent_setting_info'],true); if(empty($agent_setting_info)){ $this->reward_unit_price = 0; return true; } foreach($agent_setting_info as $info){ if($this->agent['level'] == $info['value']){ if(isset($info['type']) && $info['type'] == 1){ $this->reward_unit_price = $info['value1']; }else{ $agent_price = CloudStockTwoGoods::getReplenshPrice($this->mall_id,$this->parent_agent['level'],[$this->goods_id]) ?? 0; $this->reward_unit_price = $this->order_price - $agent_price * $this->num; } $this->desc = '直推代理(ID:'.$this->user_id.')升级为【'.$this->level_name.'】奖励'; return true; } } $this->reward_unit_price = 0; return true; } /** * 获取对应等级商品奖励金额单价 */ protected function getFillRewardUnitPrice() { $user = User::findOne(['id'=>$this->user_id]); if(!$user || !$user['parent_id']){ $this->reward_unit_price = 0; return false; } $parent_agent = CloudStockTwoAgent::findOne(['user_id' => $user['parent_id'], 'mall_id' => $this->mall_id,'status'=>StatusEnum::ENABLED]); $this->parent_agent = $parent_agent; // 存在上级代理 以及 与上级代理平级 拿直推利润 if(!$parent_agent || $parent_agent['level'] != $this->agent['level']){ $this->reward_unit_price = 0; return false; } $parent_agent_level = CloudStockTwoLevel::findOne(['mall_id' => $this->mall_id, 'level' => $parent_agent['level'], 'status' => StatusEnum::ENABLED]); if(!$parent_agent_level || empty($parent_agent_level['recommender_settle_rate'])){ $this->reward_unit_price = 0; return false; } $this->reward_unit_price = $this->fill_order['pay_money'] * $parent_agent_level['recommender_settle_rate'] / 100; $this->desc = '直推代理(ID:'.$this->user_id.')补货奖励'; if($parent_agent_level['is_recommender_condition'] && $parent_agent_level['recommender_condition_prize']){ $parent_fill_total = CloudStockTwoFillOrder::find()->where(['mall_id'=>$this->mall_id,'user_id'=>$parent_agent['user_id'],'status'=>StatusEnum::ENABLED,'is_pay'=>1])->sum('pay_money'); if($parent_fill_total < $this->reward_unit_price * $parent_agent_level['recommender_condition_prize'] / 100){ $this->reward_unit_price = 0; return false; } } return true; } public function getInsertWallet($capital_type) { $insert_wallet = []; $commission_num = $this->reward_unit_price; if(empty($commission_num)) return $insert_wallet; $is_frozen = false; if ($this->order_type == 'buying') { $source_table = OrderDetail::tableName(); $order_detail = OrderDetail::findOne(['order_id'=>$this->order_id]); $source_table_id = $order_detail->id; $order = Order::findOne(['id'=>$this->order_id]); //订单完成后才结算货款 if($order['order_status']!=OrderStatusEnum::ACCOMPLISH)$is_frozen = true; } else { $source_table = CloudStockTwoFillOrder::tableName(); } $source_table_id = $this->order_id; $configs = \Yii::$app->services->setting->addons->get($this->mall_id, AddonsEnum::ADDONS_NAME_CLOUD_STOCK_TWO, 'basic'); $service_charge = 0; if($configs['platform_fee']){ $service_charge = $commission_num * $configs['platform_fee'] / 100; $service_charge = bcmul($service_charge,1,2); $commission_num = bcsub($commission_num,$service_charge,2); if(empty($commission_num)) return $insert_wallet; $this->desc .= ',平台管理费扣除:'.$service_charge.'元'; } $insert_wallet[] = [ 'mall_id' => $this->mall_id, 'user_id' => $this->parent_agent->user_id, 'is_frozen' => $is_frozen, 'wallet_type' => 'commission', 'money' => $commission_num, 'desc' => $this->desc, 'source_table' => $source_table, 'source_table_id' => $source_table_id, 'from_type' => AddonsEnum::ADDONS_NAME_CLOUD_STOCK_TWO, 'capital_type' => $capital_type, 'service_charge' => $service_charge, ]; return $insert_wallet; } }