|
@@ -30,7 +30,8 @@ class SyncToEsCmd { |
|
@@ -30,7 +30,8 @@ class SyncToEsCmd { |
|
30
|
$es = (new Lib\Es\Es('hg_ai_emails'));
|
30
|
$es = (new Lib\Es\Es('hg_ai_emails'));
|
|
31
|
$db = db();
|
31
|
$db = db();
|
|
32
|
|
32
|
|
|
33
|
- while (1){
|
33
|
+ $maxNum = 10000; // 最大执行数量
|
|
|
|
34
|
+ while ($maxNum > 0){
|
|
34
|
// 检查是否接收到信号
|
35
|
// 检查是否接收到信号
|
|
35
|
pcntl_signal_dispatch();
|
36
|
pcntl_signal_dispatch();
|
|
36
|
|
37
|
|
|
@@ -38,14 +39,12 @@ class SyncToEsCmd { |
|
@@ -38,14 +39,12 @@ class SyncToEsCmd { |
|
38
|
_echo('已退出进程');
|
39
|
_echo('已退出进程');
|
|
39
|
break;
|
40
|
break;
|
|
40
|
}
|
41
|
}
|
|
41
|
-
|
42
|
+ $maxNum--;
|
|
42
|
$id = redis()->lPop('sync_to_es');
|
43
|
$id = redis()->lPop('sync_to_es');
|
|
43
|
if($id){
|
44
|
if($id){
|
|
44
|
$data = $db->first(\Model\listsSql::first('`id` = '.$id));
|
45
|
$data = $db->first(\Model\listsSql::first('`id` = '.$id));
|
|
45
|
if($data){
|
46
|
if($data){
|
|
46
|
// 设置 进程 是否在运行
|
47
|
// 设置 进程 是否在运行
|
|
47
|
- redis()->set('sync_my_pid:'.getmypid(),time(),86400);
|
|
|
|
48
|
-
|
|
|
|
49
|
$data['is_auto']=$db->count('select count(*) from `lists_auto` where `list_id` = '.$data['id']) ? 1 : 0;
|
48
|
$data['is_auto']=$db->count('select count(*) from `lists_auto` where `list_id` = '.$data['id']) ? 1 : 0;
|
|
50
|
|
49
|
|
|
51
|
$data = $this->getEsData($data);
|
50
|
$data = $this->getEsData($data);
|
|
@@ -63,7 +62,6 @@ class SyncToEsCmd { |
|
@@ -63,7 +62,6 @@ class SyncToEsCmd { |
|
63
|
}
|
62
|
}
|
|
64
|
|
63
|
|
|
65
|
echo '没有找到数据'.PHP_EOL;
|
64
|
echo '没有找到数据'.PHP_EOL;
|
|
66
|
- sleep(1);
|
|
|
|
67
|
}
|
65
|
}
|
|
68
|
|
66
|
|
|
69
|
}
|
67
|
}
|
