edit

service/agent/database/order.php

@@ -36,7 +36,7 @@ $status = array
     1 => '待业务初审',
     2 => '待财务终审',
     3 => '待权益发放',
-    4 => '已完成',
+    4 => array('name' => '已完成', 'style' => 'font-weight:bold;color:green'),
     5 => '驳回',
     6 => '挂起',
 );

service/agent/lib/Import.php

@@ -265,19 +265,46 @@ class Import
     }
 
     # 设置邀请关系 要跑完所有数据才能设置
-    public function relation()
+    public function relation_api()
     {
-        $data = Dever::db('invite/relation')->all(array('level' => 1));
-        if ($data) {
-            foreach ($data as $k => $v) {
-                $order = Dever::db('agent/order')->find(array('id' => $v['to_uid'], 'status' => 4, 'clear' => true));
+        Dever::config('base')->hook = true;
+
+        $state = 1;
+        while($state) {
+            $state = $this->setRelation($state);
+        }
+
+        return 'ok';
+    }
+
+    private function setRelation($index)
+    {
+        # 获取已审核通过、权益已发放的用户
+        $index = $index - 1;
+        $limit = 1000;
+        
+        $data = Dever::db('invite/relation')->fetchAll('select * from {table} where level = 1 order by id desc limit ' . $index . ', ' . $limit);
+
+        if (!$data) {
+            return false;
+        }
+
+        //$data = Dever::db('invite/relation')->all(array('level' => 1));
+        foreach ($data as $k => $v) {
+            $check = Dever::db('invite/relation')->one(array('to_uid' => $v['to_uid'], 'level' => 2, 'clear' => true));
+            if (!$check) {
+                $order = Dever::db('agent/order')->find(array('id' => $v['to_uid'], 'status' => 4));
                 if ($order) {
                     $this->addRelation($v['to_uid'], $v['uid'], 2, $order);
                 }
-                echo $v['id'];
-                echo "\r\n";
             }
+            
+            echo $v['id'];
+            echo "\r\n";
         }
+
+        $index = $index + 1;
+        return $index + $limit;
     }
 
     private function addRelation($cur, $parent, $level, $order)