正在显示
1 个修改的文件
包含
6 行增加
和
0 行删除
| @@ -30,8 +30,14 @@ class AutoMail { | @@ -30,8 +30,14 @@ class AutoMail { | ||
| 30 | echo "\n"; | 30 | echo "\n"; |
| 31 | if(redis()->get('resync_to_es_inbox') == 1){ | 31 | if(redis()->get('resync_to_es_inbox') == 1){ |
| 32 | 32 | ||
| 33 | + redis()->set('resync_to_es_inbox',2); | ||
| 34 | + | ||
| 33 | $post_ids = fob_mysql()->all("select `post_id` from `e_mail_binds` group by `post_id`"); | 35 | $post_ids = fob_mysql()->all("select `post_id` from `e_mail_binds` group by `post_id`"); |
| 34 | 36 | ||
| 37 | + if($post_ids){ | ||
| 38 | + $post_ids = array_column($post_ids,'post_id','post_id'); | ||
| 39 | + } | ||
| 40 | + | ||
| 35 | $this->es = es(); | 41 | $this->es = es(); |
| 36 | 42 | ||
| 37 | foreach ($post_ids as $post_id){ | 43 | foreach ($post_ids as $post_id){ |
-
请 注册 或 登录 后发表评论