Hướng dẫn tích hợp stockprice.Dist

{ "A": "P", "I": request_id }

// HTTP Keep-Alive (mỗi 60 giây)
setInterval(() => {
  fetch('https://dist.stockprice.vn/v1/P', {
    method: 'POST',
    headers: { 'Id': sessionId }
  }).catch(err => console.error('HTTP keep-alive thất bại:', err));
}, 60000);

// WebSocket Keep-Alive (mỗi 60 giây)
setInterval(() => {
  if (ws.readyState === WebSocket.OPEN) {
    requestId++;
    ws.send(JSON.stringify({ A: 'P', I: requestId }));
  }
}, 60000);

import threading, time, requests, json

def http_keep_alive(session_id):
    while True:
        try:
            requests.post('https://dist.stockprice.vn/v1/P',
                          headers={'Id': session_id})
        except Exception as e:
            print(f'HTTP keep-alive thất bại: {e}')
        time.sleep(60)

def websocket_keep_alive(ws):
    global request_id
    while True:
        try:
            request_id += 1
            ws.send(json.dumps({'A': 'P', 'I': request_id}))
        except Exception as e:
            print(f'WebSocket keep-alive thất bại: {e}')
        time.sleep(60)

threading.Thread(target=http_keep_alive, args=(session_id,), daemon=True).start()
threading.Thread(target=websocket_keep_alive, args=(ws,), daemon=True).start()

{ "A": "action_alias", "P": "parameters", "I": request_id }

{ "C": 0, "D": "data_or_message", "I": request_id }

{ "t": "topic_name", "d": "csv_data" }

{ "t": "topic_name" }

let requestId = 0;

function sendRequest(action, params) {
  requestId++;
  ws.send(JSON.stringify({ A: action, P: params, I: requestId }));
  return requestId;
}

// Yêu cầu
{ "A": "0" }

// Phản hồi
{ "C": 0, "D": "1690207350" }

// Yêu cầu
{ "A": "r" }

// Phản hồi
{ "C": 0, "D": "{\"Exponent\":\"AQAB\",\"Modulus\":\"xqBYwy...vQ==\"}" }

// Yêu cầu
{ "A": "l", "P": "...chuỗi đã mã hóa RSA..." }

// Phản hồi thành công (D = thời gian hết hạn epoch)
{ "C": 0, "D": "1680702231" }

// Phản hồi lỗi
{ "C": 1, "D": "Invalid credentials" }

// Yêu cầu
{ "A": "o" }

// Phản hồi
{ "C": 0, "D": null }

// Yêu cầu
{ "A": "c", "P": "...chuỗi đã mã hóa RSA...", "S": null }

// Phản hồi
{ "C": 0, "D": null }

// Yêu cầu
{ "A": "ss", "I": 1 }

// Phản hồi
{ "C": 0, "D": "success", "I": 1 }

// Tin nhắn dữ liệu
{ "t": "stock_data", "d": "SSI,75.5,78.3,72.7,74.0,100,..." }

// Tín hiệu hoàn thành
{ "t": "stock_data" }

// Yêu cầu
{ "A": "sx", "I": 2 }

// Phản hồi
{ "C": 0, "D": "success", "I": 2 }

// Tin nhắn dữ liệu
{ "t": "index_data", "d": "VNINDEX,1640995200,O,1200.5,1205.5,..." }

// Yêu cầu
{ "A": "ssi", "I": 3 }

// Phản hồi
{ "C": 0, "D": "success", "I": 3 }

// Tin nhắn dữ liệu
{ "t": "stock_info", "d": "SSI,HSX,STK,STX,SSI Securities Inc.,..." }

POST https://dist.stockprice.vn/v1/S HTTP/1.1
Content-Type: application/json
Id: your-session-id

{ "A": "ssi", "P": "SSI,VNM,HDB" }

// Phản hồi thành công
{ "C": 0, "D": "SSI,HSX,STK,STX,...\nVNM,HSX,STK,STX,..." }

// Phản hồi lỗi
{ "C": 1, "D": "Maximum 50 symbols allowed" }

// Yêu cầu
{ "A": "sd", "P": "SSI,1640995200\nVNM,0\nHDB,1641081600", "I": 4 }

// Phản hồi
{ "C": 0, "D": "success", "I": 4 }

// Tin nhắn dữ liệu (cho mỗi mã)
{ "t": "D/SSI", "d": "1640995200,1.0,75.5,76.0,77.0,74.5,5000000,..." }

// Tín hiệu hoàn thành (cho mỗi mã)
{ "t": "D/SSI" }

// Yêu cầu
{ "A": "sm", "P": "SSI,1640995200\nVNM,0", "I": 5 }

// Phản hồi
{ "C": 0, "D": "success", "I": 5 }

// Tin nhắn dữ liệu
{ "t": "M/SSI", "d": "1640995200,75.5,76.0,75.0,75.8,10000,..." }

// Yêu cầu
{ "A": "st", "P": "SSI,1640995200\nVNM,0", "I": 6 }

// Phản hồi thành công
{ "C": 0, "D": "success", "I": 6 }

// Phản hồi lỗi (nếu bao gồm mã chỉ số)
{ "C": 1, "D": "Trade data not available for indices", "I": 6 }

// Tin nhắn dữ liệu
{ "t": "T/SSI", "d": "1640995200,75.5,1000,B\r\n1640995205,75.6,500,S" }

// Hủy đăng ký giá cổ phiếu
{ "A": "us", "I": 7 }

// Hủy đăng ký các mã lịch sử cụ thể
{ "A": "ud", "P": "SSI,VNM,HDB", "I": 9 }

// Hủy đăng ký tất cả dữ liệu theo phút
{ "A": "um", "P": "", "I": 12 }

// Hủy đăng ký tất cả
{ "A": "ua", "I": 15 }

// Yêu cầu HTTP
{ "A": "gs", "P": "12345" }

// Phản hồi
{ "C": 0, "D": "{\"csv\":\"SSI,75.5,...\\nVNM,82.3,...\",\"dataId\":12450}" }

// Yêu cầu HTTP
{ "A": "gi", "P": "0" }

// Phản hồi
{ "C": 0, "D": "{\"csv\":\"VNINDEX,1640995200,O,1200.5,...\",\"dataId\":8920}" }

// Yêu cầu HTTP
{ "A": "gd", "P": "{\"symbol\":\"SSI\",\"lastTime\":1640995200}" }

// Phản hồi (CSV trực tiếp)
{ "C": 0, "D": "1640995200,1.0,75.5,76.0,77.0,74.5,5000000,...\n..." }

// Yêu cầu HTTP
{ "A": "gm", "P": "{\"symbol\":\"SSI\",\"lastTime\":1640995200}" }

// Phản hồi (CSV trực tiếp)
{ "C": 0, "D": "1640995200,75.5,76.0,75.0,75.8,10000,...\n..." }

// Yêu cầu HTTP
{ "A": "gt", "P": "{\"symbol\":\"SSI\",\"lastTime\":1640995200}" }

// Phản hồi
{ "C": 0, "D": "1640995200,75.5,1000,B\n1640995205,75.6,500,S\n..." }

let lastDataId = 0;

async function pollStockData() {
  const response = await fetch('https://dist.stockprice.vn/v1/S', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json', 'Id': sessionId },
    body: JSON.stringify({ A: 'gs', P: lastDataId.toString() })
  });
  const result = await response.json();
  if (result.C === 0) {
    const data = JSON.parse(result.D);
    console.log('Stock CSV:', data.csv);
    lastDataId = data.dataId; // Lưu cho yêu cầu tiếp theo
  }
}

setInterval(pollStockData, 1000);

const ws = new WebSocket('wss://dist.stockprice.vn/v1/ws?Id=' + sessionId);
let requestId = 0;

ws.onopen = function() {
  // Đăng ký dữ liệu cổ phiếu
  requestId++;
  ws.send(JSON.stringify({ A: 'ss', I: requestId }));

  // Đăng ký dữ liệu lịch sử theo ngày
  requestId++;
  ws.send(JSON.stringify({ A: 'sd', P: 'SSI,0\nVNM,0', I: requestId }));
};

ws.onmessage = function(event) {
  const msg = JSON.parse(event.data);

  // Phản hồi action
  if ('C' in msg) {
    if (msg.C === 0) console.log('OK:', msg.I, msg.D);
    else console.error('Lỗi:', msg.I, msg.D);
    return;
  }

  // Tin nhắn dữ liệu
  if ('t' in msg) {
    if ('d' in msg) {
      const lines = msg.d.split('\n');
      lines.forEach(line => {
        if (!line) return;
        const fields = line.split(',');
        console.log(msg.t, fields[0], fields);
      });
    } else {
      console.log('Hoàn thành:', msg.t);
    }
  }
};

function subscribeAll(ws) {
  // Giá cổ phiếu thời gian thực
  ws.send(JSON.stringify({ A: 'ss', I: ++requestId }));
  // Chỉ số thời gian thực
  ws.send(JSON.stringify({ A: 'sx', I: ++requestId }));
  // Thông tin cổ phiếu
  ws.send(JSON.stringify({ A: 'ssi', I: ++requestId }));
  // Lịch sử theo ngày
  ws.send(JSON.stringify({ A: 'sd', P: 'SSI,1640995200\nVNM,0', I: ++requestId }));
  // Lịch sử theo phút
  ws.send(JSON.stringify({ A: 'sm', P: 'SSI,1640995200', I: ++requestId }));
  // Giao dịch (chỉ cổ phiếu)
  ws.send(JSON.stringify({ A: 'st', P: 'SSI,0\nVNM,0', I: ++requestId }));
}

import websocket
import json
import threading

request_id = 0

def get_next_id():
    global request_id
    request_id += 1
    return request_id

def on_message(ws, message):
    msg = json.loads(message)
    if 'C' in msg:
        print(f"{'OK' if msg['C']==0 else 'Lỗi'} ({msg.get('I')}): {msg.get('D')}")
    elif 't' in msg:
        if 'd' in msg:
            lines = msg['d'].split('\n')
            for line in lines:
                if line:
                    fields = line.split(',')
                    print(f"  {msg['t']}: {fields[:5]}...")
        else:
            print(f"  Hoàn thành: {msg['t']}")

def on_open(ws):
    # Đăng ký dữ liệu cổ phiếu
    ws.send(json.dumps({'A': 'ss', 'I': get_next_id()}))
    # Đăng ký lịch sử
    ws.send(json.dumps({'A': 'sd', 'P': 'SSI,0\nVNM,0', 'I': get_next_id()}))

ws = websocket.WebSocketApp(
    f'wss://dist.stockprice.vn/v1/ws?Id={session_id}',
    on_message=on_message,
    on_open=on_open,
    on_error=lambda ws, e: print(f'Lỗi: {e}'),
    on_close=lambda ws, c, m: print('Đã đóng')
)
ws.run_forever()

import requests, json

def get_historical(session_id, symbol, action, last_time=0):
    """action: 'gd' (ngày), 'gm' (phút), 'gt' (giao dịch)"""
    params = {"symbol": symbol, "lastTime": last_time}
    resp = requests.post(
        'https://dist.stockprice.vn/v1/S',
        headers={'Content-Type': 'application/json', 'Id': session_id},
        json={'A': action, 'P': json.dumps(params)}
    )
    result = resp.json()
    if result['C'] == 0:
        for line in result['D'].split('\n'):
            if line:
                print(line.split(','))
    else:
        print(f"Lỗi: {result['D']}")

# Sử dụng
get_historical(session_id, 'SSI', 'gd', 0)   # Theo ngày
get_historical(session_id, 'VNM', 'gm', 0)   # Theo phút
get_historical(session_id, 'HDB', 'gt', 0)   # Giao dịch