前端代码修改/添加L1数据接口

admin

2024-04-15 73e0c886d5cab285eaddfa79653c622efa5fe980

前端代码修改/添加L1数据接口

 kp_html/kp/js/code_list.js

@@ -43,6 +43,7 @@
            passive_buy_codes: null,
            data_type: 0,
            trade_progress_index: -1,
            trade_progress_percent: 0,
            real_order_indexes: new Array(),
            hidden_canceled: true,
            //隐藏撤单
@@ -133,6 +134,8 @@
                        console.log("成交进度", res.data);
                        if (!res.data.is_default) {
                            app.trade_progress_index = res.data.trade_progress;
							
                            app.trade_progress_percent = res.data.percent;
                        }
                    }
                });
@@ -291,7 +294,7 @@
            reset_l2_height: function() {
                var height = document.documentElement.clientHeight;
                console.log("屏幕：", height);
                $(".l2-content").eq(0).css("height", (height - 370 - 66 * app
                $(".l2-content").eq(0).css("height", (height - 380 - 66 * app
                        .delegated_buy_code_infos.length - 24 * app.latest_cancel_orders.length
                        ) + "px");
            },
@@ -482,7 +485,7 @@
                if (app.hidden_cancel && (item[2][6].indexOf('买撤') >= 0)) {
                    return false;
                }
                if (app.hidden_little_money && parseFloat(item[2][3]) < 50) {
                if (app.hidden_little_money && parseFloat(item[2][3]) < 5) {
                    return false;
                }
                

 utils/l1_data_api.py

New file
@@ -0,0 +1,72 @@
"""
L1数据接口
"""
import hashlib
import json
import socket
import time


class SocketUtil:

    @classmethod
    def md5_encrypt(cls, value):
        md5 = hashlib.md5()
        md5.update(value.encode('utf-8'))
        return md5.hexdigest()

    @classmethod
    def create_socket(cls, addr, port):
        client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 生成socket，连接server
        client.connect((addr, port))
        return client

    @classmethod
    def load_header(cls, data_bytes):
        slen = '##%08d' % len(data_bytes)
        return slen.encode("utf-8") + data_bytes

    @classmethod
    # 接收数据，去除头
    def recv_data(cls, sk):
        data = ""
        header_size = 10
        buf = sk.recv(1024)
        header_str = buf[:header_size]
        if buf:
            buf = buf.decode('utf-8')
            if buf.startswith("##"):
                content_length = int(buf[2:10])
                received_size = 0
                # 加上读取头的数据
                received_size += len(buf[header_size:])
                data += buf[header_size:]
                while not received_size == content_length:
                    r_data = sk.recv(10240)
                    received_size += len(r_data)
                    data += r_data.decode('utf-8')
            else:
                data = sk.recv(1024 * 1024)
                data = buf + data.decode('utf-8')
        return data, header_str


def get_current_info():
    """
    获取当前L1信息
    :return: [(代码,昨日收盘价,最新价,总成交量,总成交额,更新时间)]
    """
    sk = SocketUtil.create_socket("43.138.167.68", 11008)
    params_bytes = SocketUtil.load_header(json.dumps({"type": "get_l1_data","sign":''}).encode("utf-8"))
    sk.send(params_bytes)
    result_str, header = SocketUtil.recv_data(sk)
    result_json = json.loads(result_str)
    if result_json['code'] == 0:
        return result_json['data']
    return []


if __name__ == "__main__":
    while True:
        print( get_current_info())
        time.sleep(3)