会员升级

app/controller/api/v1/PublicController.php

@@ -72,10 +72,9 @@ class PublicController extends BaseController
 
     public function test()
     {
-        set_time_limit(0);
-        $list = UserIntegral::where('type', 0)->where('status', 0)->order('add_time', 'asc')->select();
-        echo '原消费分共' . count($list) . '条' . '<br>';
-        $last_time = 0;
+        $max_id = CacheService::get('max_id', 0);
+        $list = UserIntegral::where('type', 0)->where('status', 0)->order('add_time', 'asc')->where('id', '>', $max_id)->limit(500)->select();
+        $last_time = CacheService::get('last_time', 0);
         $service = app()->make(AwardIntegralServices::class);
         echo date('Y-m-d', $list[0]['add_time']) . '<br>';
         foreach ($list as $v) {
@@ -89,8 +88,12 @@ class PublicController extends BaseController
             }
             $this->dealOrderIntegral($v['link_id'], $v['uid'], $v['order_price'], $v['add_time']);
             $last_time = $v['add_time'];
+            $max_id = $v['id'];
         }
-        if (strtotime(date('Y-m-d', $last_time)) < strtotime(date('Y-m-d'))) {
+        CacheService::set('max_id', $max_id);
+        CacheService::set('last_time', $last_time);
+
+        if (count($list) < 500 && strtotime(date('Y-m-d', $last_time)) < strtotime(date('Y-m-d'))) {
             echo date('Y-m-d') . '<br>';
             $days = (strtotime(date('Y-m-d')) - strtotime(date('Y-m-d', $last_time))) / (24 * 3600);
             echo '时间间隔' . $days . '天<br>';