限制必须用户下载APP后才给返现

helper/account_helper.php

@@ -326,8 +326,13 @@ class account_helper
 
         $fcode = new user_session\fcode();
         $fcode->onStatus();
-
         QueueClient::push('onAsyncStatus',['member_id' => $member_id]);
+
+        $rewared_inviter = intval($member_info['rewared_inviter']);
+        $inviter_id = intval($member_info['inviter_id']);
+        if(session_helper::isapp() && session_helper::logined() && $rewared_inviter == 0) {
+            QueueClient::push('onAsyncRegister',['user' => $member_id,'inviter' => $inviter_id]);
+        }
     }
 
     public static function onAsyncStatus($member_id)
@@ -364,7 +369,9 @@ class account_helper
         }
 
         $publisher->add_inviter($member_id,$relay_id);
-        QueueClient::push('onAsyncRegister',['user' => $member_id,'inviter' => $relay_id]);
+        if(session_helper::logined() && session_helper::isapp()) {
+            QueueClient::push('onAsyncRegister',['user' => $member_id,'inviter' => $relay_id]);
+        }
     }
 
     public static function onAsyncRegister($user,$inviter)

helper/async/IAsync.php

@@ -25,6 +25,15 @@ abstract class IAsync
         return $result;
     }
 
+    protected function tag_rewarded($user)
+    {
+        $user = intval($user);
+        if($user <=0) return false;
+
+        $mod_member = Model('member');
+        $mod_member->editMember(['member_id' => $user],['rewared_inviter' => 1]);
+    }
+
     protected function add_invitee($user)
     {
         $user = intval($user);

helper/async/register.php

@@ -14,7 +14,6 @@ use bonus;
 use bonus_helper;
 use member_info;
 use Log;
-use Exception;
 
 class register extends IAsync
 {
@@ -27,12 +26,8 @@ class register extends IAsync
         $this->cur_user = $user;
         $this->cur_info = new member_info($user);
         $this->last_inviter = $inviter;
-
-        if($this->cur_info->wxauthored() == false) {
-            throw new Exception("为防止欺诈，微信没授权用户，不能享受红包优惠");
-        }
-
         $this->add_invitee($inviter);
+        $this->tag_rewarded($user);
     }
 
     private function inviters()