正在显示
2 个修改的文件
包含
2 行增加
和
2 行删除
@@ -41,7 +41,7 @@ while (1){ | @@ -41,7 +41,7 @@ while (1){ | ||
41 | $doc_id = $data['email_id'].'_'.$data['folder_id'].'_'.$data['uid']; | 41 | $doc_id = $data['email_id'].'_'.$data['folder_id'].'_'.$data['uid']; |
42 | 42 | ||
43 | $code = $es->save($doc_id,$data); | 43 | $code = $es->save($doc_id,$data); |
44 | - if($code!=200){ | 44 | + if($code!==200){ |
45 | sleep(1); | 45 | sleep(1); |
46 | $code = $es->save($doc_id,$data); // 重试一次 | 46 | $code = $es->save($doc_id,$data); // 重试一次 |
47 | } | 47 | } |
@@ -141,7 +141,7 @@ class Es { | @@ -141,7 +141,7 @@ class Es { | ||
141 | $response = $this->client->index($params); | 141 | $response = $this->client->index($params); |
142 | }catch (\Throwable $e) { | 142 | }catch (\Throwable $e) { |
143 | logs("创建或者修改es:".$e->getMessage()); | 143 | logs("创建或者修改es:".$e->getMessage()); |
144 | - return 500; | 144 | + return $e->getMessage(); |
145 | } | 145 | } |
146 | 146 | ||
147 | return $response['_shards']['successful']?200:500; | 147 | return $response['_shards']['successful']?200:500; |
-
请 注册 或 登录 后发表评论