首板买入打分机制

Administrator

2023-03-23 96dc1a4cc38b588f39387b5a85b9677100e357f1

 third_data/hot_block.py

@@ -12,6 +12,15 @@


def __parseData(driver):
    date_element = \
        driver.find_element(by=By.ID, value="nuxt-layout-container").find_elements(by=By.TAG_NAME, value="time")[0]
    date_elements = date_element.find_elements(by=By.TAG_NAME, value="span")
    month = date_elements[0].text.split(' ')[0][:-1]
    day = date_elements[1].text
    # 获取当前的年
    year = datetime.datetime.now().strftime("%Y")
    day_str = "{0}-{1:0>2}-{2:0>2}".format(year, int(month), int(day))

    items = driver.find_element(by=By.ID, value="nuxt-layout-container").find_element(by=By.CLASS_NAME,
                                                                                      value="topgainer-content-left").find_elements(
        by=By.CLASS_NAME,
@@ -44,7 +53,7 @@
        data_list.append((title, total_rate, codes_list))
        print("----------------------")

    return data_list
    return day_str, data_list


# 获取热门板块
@@ -66,17 +75,17 @@
        if int("113000") < int(time_str) < int("130000"):
            continue
        try:
            result = __parseData(driver)
            callback(result)
            day, result = __parseData(driver)
            callback(day, result)
        except Exception as e:
            logging.exception(e)


def upload_data(datas):
def upload_data(day, datas):
    client = socket.socket()  # 生成socket，连接server
    ip_port = ("192.168.3.252", 9001)  # server地址和端口号（最好是10000以后）
    client.connect(ip_port)
    data = {"type": 70, "data": datas}
    data = {"type": 70, "day": day, "data": datas}
    client.send(json.dumps(data).encode("gbk"))
    client.close()

@@ -85,8 +94,8 @@
# cd D:\workspace\trade\third_data
# C:\Users\Administrator\AppData\Roaming\Python\Python37\Scripts\pyinstaller.exe hot_block.spec
if __name__ == "__main__":
    def callback(result):
        upload_data(result)
    def callback(day, result):
        upload_data(day, result)
        pass