"""
低吸数据推送
"""
import json

import requests

import concurrent.futures

__data_push_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=5)
__big_order_data_push_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10)


def push_limit_up_list(datas):
    """
    推送涨停列表信息
    @param datas:
    @return:
    """

    def push():
        requests.post("http://127.0.0.1:9008/upload_limit_up_list", json=json.dumps(datas), timeout=3)

    __data_push_thread_pool.submit(
        lambda: push())


def push_big_order(datas):
    """
    推送大单信息
    @param datas:
    @return:
    """

    def push():
        requests.post("http://127.0.0.1:9008/upload_big_order_datas", json=json.dumps(datas), timeout=3)

    __big_order_data_push_thread_pool.submit(
        lambda: push())


def push_block_in(datas):
    """
    推送板块流入信息
    @param datas:
    @return:
    """

    def push():
        requests.post("http://127.0.0.1:9008/upload_block_in_datas", json=json.dumps(datas), timeout=3)

    __data_push_thread_pool.submit(
        lambda: push())