/**
 * scroll方式从es中查数据
 *
 * $fields = [
 *      'ticket_no'
 * ];
 * $query = [
 *      'term' => [
 *              'third_order_id' => $thirdOrderId,
 *      ]
 * ];
 *
 * @param array $fields 要返回的字段名
 * @param array $query 查询条件
 * @param bool $justNo 是否只返回工单号
 * @param array $sort 排序条件
 * @return array
 */
public function getEsDataByScroll(array $fields, array $query, $justNo, array $sort = [])
{
    $result = [];
    $client = $this->connectElasticsearch();
    $esConfig = $this->container->getParameter('elasticsearch_indexs');
    $index = !empty($esConfig['tickets_index']) ? $esConfig['tickets_index'] : '';
    if (empty($sort)) {
        $sort = [
            [
                'create_time' => [
                    'order' => 'desc',
                    'unmapped_type' => 'date'
                ]
            ]
        ];
    }
    $search = [
        'index' => $index,
        'type' => 'tk_tickets',
        'from' => 0,
        'size' => 10000,
        'scroll' => '5m',
        'body' => [
            '_source' => $fields,
            'query' => [
                'bool' => [
                    'must' => $query
                ]
            ],
            'sort' => $sort
        ]
    ];
    $rows = $client->search($search);
    //再次查询，直至取完
    while (!empty($rows['hits']['hits'])) {
        $result = array_merge($result, $rows['hits']['hits']);
        $scrollId = empty($rows['_scroll_id']) ? '' : $rows['_scroll_id'];
        $scrollParam['scroll'] = '5m';
        $scrollParam['scroll_id'] = $scrollId;
        $rows = $client->scroll($scrollParam);
    }

    if (!empty($result) && $justNo) {
        $ticketNos = [];
        foreach ($result as $v) {
            if (!empty($v['_source']['ticket_no'])) {
                array_push($ticketNos, $v['_source']['ticket_no']);
            }
        }
        $result = $ticketNos;
    }

    return $result;
}