add to local

core/framework/libraries/queue.php

@@ -23,11 +23,11 @@ class QueueClient
         return self::$queuedb->push(serialize(array($key=>$value)));
     }
 
-    public static function async_push($key,$value,$period_minues = 0)
+    public static function async_push($key, $value, $period_secs = 0)
     {
-        if($period_minues > 0) {
+        if($period_secs > 0) {
             $model_cron = Model('cron');
-            $model_cron->addCron(['params' => serialize([$key=>$value]),'type' => 8,'exeid' => 0,'exetime' => time() + $period_minues * 60]);
+            $model_cron->addCron(['params' => serialize([$key=>$value]),'type' => 8,'exeid' => 0,'exetime' => time() + $period_secs]);
         }
         else {
             self::push($key,$value);

helper/account_helper.php

@@ -352,9 +352,9 @@ class account_helper
         $inviter_id = intval($member_info['inviter_id']);
 
         if(session_helper::isapp() && session_helper::logined() && $rewared_inviter == 0) {
-            QueueClient::async_push('onAsyncRegister',['user' => $member_id,'inviter' => $inviter_id],2);
+            QueueClient::async_push('onAsyncRegister',['user' => $member_id,'inviter' => $inviter_id],5);
         }
-        QueueClient::async_push('onAsyncStatus',['member_id' => $member_id],1);
+        QueueClient::async_push('onAsyncStatus',['member_id' => $member_id],10);
     }
 
     public static function onAsyncStatus($member_id)
@@ -398,7 +398,7 @@ class account_helper
 
         $publisher->add_inviter($member_id,$relay_id);
         if(session_helper::logined() && session_helper::isapp()) {
-            QueueClient::async_push('onAsyncRegister',['user' => $member_id,'inviter' => $relay_id],2);
+            QueueClient::async_push('onAsyncRegister',['user' => $member_id,'inviter' => $relay_id],5);
         }
     }
 

helper/async/register.php

@@ -15,6 +15,7 @@ use bonus_helper;
 use member_info;
 use Log;
 use Exception;
+use account_helper;
 
 class register extends IAsync
 {
@@ -146,24 +147,28 @@ class register extends IAsync
 
     private function reward_user()
     {
-        if($this->last_inviter > 0) {
+        if($this->last_inviter > 0)
+        {
             $params = bonus\parameters::user_reigster_fixed();
-        } else {
-            $item = bonus\parameters::invite(0);
-            $params[] = $item;
+            foreach ($params as $param) {
+                $type = bonus_helper::create_type_input($param);
+                $money = $type->getTotal_amount();
+                $ret = bonus_helper::make_bonus($param, $param['rate_money']);
+
+                if ($ret != false) {
+                    $type_sn = $ret['type_sn'];
+                    bonus_helper::send($type_sn, [$this->cur_user]);
+                    push_helper::register_bonus($this->cur_user, $money, $type_sn);
+                } else {
+                    return false;
+                }
+            }
         }
-        
-        foreach ($params as $param) {
-            $type = bonus_helper::create_type_input($param);
-            $money = $type->getTotal_amount();
-            $ret = bonus_helper::make_bonus($param, $param['rate_money']);
-
-            if ($ret != false) {
-                $type_sn = $ret['type_sn'];
+        else {
+            $type_sn = account_helper::invite_bonus(0);
+            if($type_sn != false) {
                 bonus_helper::send($type_sn, [$this->cur_user]);
-                push_helper::register_bonus($this->cur_user, $money, $type_sn);
-            } else {
-                return false;
+                push_helper::register_bonus($this->cur_user, 100, $type_sn);
             }
         }