正在显示
1 个修改的文件
包含
1 行增加
和
1 行删除
@@ -98,7 +98,7 @@ class SyncMailToEs { | @@ -98,7 +98,7 @@ class SyncMailToEs { | ||
98 | // 更新es | 98 | // 更新es |
99 | $lists = db()->all(listsSql::all($this->where,'`id`')); | 99 | $lists = db()->all(listsSql::all($this->where,'`id`')); |
100 | foreach ($lists as $list){ | 100 | foreach ($lists as $list){ |
101 | - redis()->rPush('sync_to_es',$list['id']); | 101 | + redis()->rPush('sync_to_es',$list['id'].'.1'); |
102 | // $id = $list['email_id'].'_'.$list['folder_id'].'_'.$list['uid']; | 102 | // $id = $list['email_id'].'_'.$list['folder_id'].'_'.$list['uid']; |
103 | // $this->es->save($id,$this->getData($list)); | 103 | // $this->es->save($id,$this->getData($list)); |
104 | } | 104 | } |
-
请 注册 或 登录 后发表评论