{"id":534,"title":"php\u4e2delasticsearch scroll\u65b9\u5f0f\u67e5\u8be2","good":0,"bad":0,"hit":2553,"created_at":"2021-03-25 21:16:50","content":"<p><br\/><\/p><pre class=\"brush:bash;toolbar:false\">\/**\n&nbsp;*&nbsp;scroll\u65b9\u5f0f\u4ecees\u4e2d\u67e5\u6570\u636e\n&nbsp;*\n&nbsp;*&nbsp;$fields&nbsp;=&nbsp;[\n&nbsp;*&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;ticket_no&#39;\n&nbsp;*&nbsp;];\n&nbsp;*&nbsp;$query&nbsp;=&nbsp;[\n&nbsp;*&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;term&#39;&nbsp;=&gt;&nbsp;[\n&nbsp;*&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;third_order_id&#39;&nbsp;=&gt;&nbsp;$thirdOrderId,\n&nbsp;*&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;]\n&nbsp;*&nbsp;];\n&nbsp;*\n&nbsp;*&nbsp;@param&nbsp;array&nbsp;$fields&nbsp;\u8981\u8fd4\u56de\u7684\u5b57\u6bb5\u540d\n&nbsp;*&nbsp;@param&nbsp;array&nbsp;$query&nbsp;\u67e5\u8be2\u6761\u4ef6\n&nbsp;*&nbsp;@param&nbsp;bool&nbsp;$justNo&nbsp;\u662f\u5426\u53ea\u8fd4\u56de\u5de5\u5355\u53f7\n&nbsp;*&nbsp;@param&nbsp;array&nbsp;$sort&nbsp;\u6392\u5e8f\u6761\u4ef6\n&nbsp;*&nbsp;@return&nbsp;array\n&nbsp;*\/\npublic&nbsp;function&nbsp;getEsDataByScroll(array&nbsp;$fields,&nbsp;array&nbsp;$query,&nbsp;$justNo,&nbsp;array&nbsp;$sort&nbsp;=&nbsp;[])\n{\n&nbsp;&nbsp;&nbsp;&nbsp;$result&nbsp;=&nbsp;[];\n&nbsp;&nbsp;&nbsp;&nbsp;$client&nbsp;=&nbsp;$this-&gt;connectElasticsearch();\n&nbsp;&nbsp;&nbsp;&nbsp;$esConfig&nbsp;=&nbsp;$this-&gt;container-&gt;getParameter(&#39;elasticsearch_indexs&#39;);\n&nbsp;&nbsp;&nbsp;&nbsp;$index&nbsp;=&nbsp;!empty($esConfig[&#39;tickets_index&#39;])&nbsp;?&nbsp;$esConfig[&#39;tickets_index&#39;]&nbsp;:&nbsp;&#39;&#39;;\n&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(empty($sort))&nbsp;{\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$sort&nbsp;=&nbsp;[\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;[\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;create_time&#39;&nbsp;=&gt;&nbsp;[\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;order&#39;&nbsp;=&gt;&nbsp;&#39;desc&#39;,\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;unmapped_type&#39;&nbsp;=&gt;&nbsp;&#39;date&#39;\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;]\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;]\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;];\n&nbsp;&nbsp;&nbsp;&nbsp;}\n&nbsp;&nbsp;&nbsp;&nbsp;$search&nbsp;=&nbsp;[\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;index&#39;&nbsp;=&gt;&nbsp;$index,\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;type&#39;&nbsp;=&gt;&nbsp;&#39;tk_tickets&#39;,\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;from&#39;&nbsp;=&gt;&nbsp;0,\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;size&#39;&nbsp;=&gt;&nbsp;10000,\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;scroll&#39;&nbsp;=&gt;&nbsp;&#39;5m&#39;,\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;body&#39;&nbsp;=&gt;&nbsp;[\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;_source&#39;&nbsp;=&gt;&nbsp;$fields,\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;query&#39;&nbsp;=&gt;&nbsp;[\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;bool&#39;&nbsp;=&gt;&nbsp;[\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;must&#39;&nbsp;=&gt;&nbsp;$query\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;]\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;],\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&#39;sort&#39;&nbsp;=&gt;&nbsp;$sort\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;]\n&nbsp;&nbsp;&nbsp;&nbsp;];\n&nbsp;&nbsp;&nbsp;&nbsp;$rows&nbsp;=&nbsp;$client-&gt;search($search);\n&nbsp;&nbsp;&nbsp;&nbsp;\/\/\u518d\u6b21\u67e5\u8be2\uff0c\u76f4\u81f3\u53d6\u5b8c\n&nbsp;&nbsp;&nbsp;&nbsp;while&nbsp;(!empty($rows[&#39;hits&#39;][&#39;hits&#39;]))&nbsp;{\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$result&nbsp;=&nbsp;array_merge($result,&nbsp;$rows[&#39;hits&#39;][&#39;hits&#39;]);\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$scrollId&nbsp;=&nbsp;empty($rows[&#39;_scroll_id&#39;])&nbsp;?&nbsp;&#39;&#39;&nbsp;:&nbsp;$rows[&#39;_scroll_id&#39;];\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$scrollParam[&#39;scroll&#39;]&nbsp;=&nbsp;&#39;5m&#39;;\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$scrollParam[&#39;scroll_id&#39;]&nbsp;=&nbsp;$scrollId;\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$rows&nbsp;=&nbsp;$client-&gt;scroll($scrollParam);\n&nbsp;&nbsp;&nbsp;&nbsp;}\n\n&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!empty($result)&nbsp;&amp;&amp;&nbsp;$justNo)&nbsp;{\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$ticketNos&nbsp;=&nbsp;[];\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;foreach&nbsp;($result&nbsp;as&nbsp;$v)&nbsp;{\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!empty($v[&#39;_source&#39;][&#39;ticket_no&#39;]))&nbsp;{\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;array_push($ticketNos,&nbsp;$v[&#39;_source&#39;][&#39;ticket_no&#39;]);\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}\n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$result&nbsp;=&nbsp;$ticketNos;\n&nbsp;&nbsp;&nbsp;&nbsp;}\n\n&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;$result;\n}<\/pre><p><br\/><\/p>"}