OCS_TMP/ocs/note.md

# xz_cable_setup_check_tool.py build

```shell
pyinstaller --onefile \
--paths=/home/gyou/NexusBench-baihe-br/nexusbench \
--paths=/home/gyou/NexusBench-baihe-br/nexusbench/log \
--paths=/home/gyou/NexusBench-baihe-br/nexusbench/connection \
--paths=/home/gyou/NexusBench-baihe-br/nexusbench/gpu/biren \
--hidden-import=connection.http_helper \
--runtime-tmpdir=/home/gyou/tmp \
/home/gyou/NexusBench-baihe-br/nexusbench/biren_test.py


# 加了这一行就可以运行了
--runtime-tmpdir=/home/gyou/tmp \

--hidden-import=log.logger \
--hidden-import=connection.ssh_connection_manager \

```


 ./build/whiteriver_exp --host 10.57.216.109 --exp 2 --cmd vcmd --param rev

./vuart -i 10.57.216.109 -e 2 -c vcmd -p ver
./vuart -i 10.57.216.108 -e 4 -c fw-down -p 

./build/whiteriver_exp  -i 10.57.216.108 -e 4 -c fw-down -p 



./build/whiteriver_exp  -i 10.57.216.91 -e 4 -c vcmd -p ver


net use X: \\10.57.216.173\shared /user:root ossdbg1  


PicT1!2@3#4$

 
RCms@Zte3

./build/whiteriver_exp -i 10.57.216.94 -e 4 -c fw-down -p "./whiteriver_exp@1.0.17+2508161844.img"


./build/whiteriver_exp -i 10.57.216.95,10.57.216.96,10.57.216.97,10.57.216.98 



scp /usr/bin/ocs_link_reset root@10.57.216.166


scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.166:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.165:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.187:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.148:/usr/bin/

scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.163:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.139:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.173:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.167:/usr/bin/

scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.134:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.145:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.176:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.180:/usr/bin/

scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.185:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.150:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.168:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.174:/usr/bin/

scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.132:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.189:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.151:/usr/bin/
scp -o "BatchMode=no" -o "StrictHostKeyChecking=no" -i pass.txt /usr/bin/ocs_link_reset root@10.57.216.156:/usr/bin/







//http.cpp
// smbus_http.cpp
#include "smbus_http.h"
#include <iostream>
#include <sstream>
#include <algorithm>

#include "lt_config.h"
#define CONFIG_ENABLE_EXP_REMAP (config_.exp_remap)
#define CONFIG_ENABLE_TRACE (config_.trace_payload)

static std::map<int, int> static_exp_map_ = {{2, 1}, {4, 2}, {6, 3}, {8, 4}};
static std::map<std::string, std::string> headers_ = {
    {"Content-Type", "application/json"},
    {"Accept", "application/json"}
};
#define PRINT(...) do {\
    if (CONFIG_ENABLE_TRACE) printf(__VA_ARGS__); \
} while (0)

SmbusHttp::SmbusHttp(const struct http_t& config, const std::string& token) : config_(config), token_(token)
{
    http_helper_ = std::make_unique<HTTPHelper>(config_.user, config_.pswd);
    
    if (CONFIG_ENABLE_EXP_REMAP) exp_map_ = static_exp_map_;
}

std::vector<uint8_t> SmbusHttp::string_to_bytes(const std::string& hexString)
{
    std::vector<uint8_t> bytes;
    if (hexString.length() % 2 != 0) return bytes; // 返回空vector，表示无效输入
    
    bytes.reserve(hexString.length() / 2);    
    for (size_t i = 0; i < hexString.length(); i += 2) 
    {
        std::string byteString = hexString.substr(i, 2);
        uint8_t byte = static_cast<uint8_t>(std::stoi(byteString, nullptr, 16));
        bytes.push_back(byte);
    }
    return bytes;
}

std::string SmbusHttp::build_user_pwd() 
{
    std::ostringstream json;
    json << "{";
    json << "\"UserName\":\"" << config_.user << "\",";
    json << "\"Password\":\"" << config_.pswd << "\"";
    json << "}";
    return json.str();
}

std::string SmbusHttp::build_get_register_json(int exp_id, int cmd_id, int read_len)
{
    std::ostringstream json;
    json << "{";
    json << "\"ExpanderId\":" << exp_id << ",";
    json << "\"CmdId\":" << cmd_id << ",";
    json << "\"ReadLen\":" << read_len;
    json << "}";
    return json.str();
}

std::string SmbusHttp::build_set_register_json(int exp_id, int cmd_id, int write_len, const std::string& value)
{
    std::ostringstream json;
    json << "{";
    json << "\"ExpanderId\":" << exp_id << ",";
    json << "\"CmdId\":" << cmd_id << ",";
    json << "\"WriteLen\":" << write_len << ",";
    json << "\"Value\":\"" << value << "\"";
    json << "}";
    return json.str();
}

std::string SmbusHttp::build_get_base_info_json(int exp_id, int addr, int read_len)
{
    std::ostringstream json;
    json << "{";
    json << "\"ExpanderId\":" << exp_id << ",";
    json << "\"Addr\":" << addr << ",";
    json << "\"ReadLen\":" << read_len;
    json << "}";
    return json.str();
}

int SmbusHttp::get_register(int exp_id, int cmd_id, int read_len, std::vector<uint8_t>& bytes)
{
    exp_id = remap(exp_id);
    
    std::string url = config_.host + config_.get_register;
    std::string json_payload = build_get_register_json(exp_id, cmd_id, read_len);

    PRINT("get_register:\nurl: %s\n", url.c_str());
    PRINT("Payload: %s\n", json_payload.c_str());
    
    std::string response_str = http_helper_->post(url, json_payload, headers_, true);

    PRINT("Response: %s\n", response_str.c_str());

    if (!response_str.empty()) 
    {
        auto result = parse_response(response_str);
        if (result.first == 0) 
        {
            bytes = string_to_bytes(result.second);
            return 0;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    
    return -1;
}

int SmbusHttp::set_register(int exp_id, int cmd_id, int write_len, const std::vector<uint8_t>& value) 
{
    exp_id = remap(exp_id);
    std::string url = config_.host + config_.set_register;
    
    std::string hexString(value.size() * 2, '0');
    for (size_t i = 0; i < value.size(); ++i) 
        sprintf(&hexString[i * 2], "%02X", value[i]);

    std::string json_payload = build_set_register_json(exp_id, cmd_id, write_len, hexString);

    PRINT("set_register\nurl: %s\n", url.c_str());
    PRINT("Payload: %s\n", json_payload.c_str());
    
    std::string response_str = http_helper_->post(url, json_payload, headers_, true);
    
    PRINT("Response: %s\n", response_str.c_str());

    if (!response_str.empty()) 
    {
        auto result = parse_response(response_str);
        if (result.first == 0) 
        {
            return 0;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    
    return -1;
}

int SmbusHttp::get_fru(int exp_id, uint8_t addr, int num, std::vector<uint8_t>& bytes) 
{
    exp_id = remap(exp_id);

    std::string url = config_.host + config_.get_fru;
    std::string json_payload = build_get_base_info_json(exp_id, static_cast<int>(addr), num);

    PRINT("get_fru\nurl: %s\n", url.c_str());
    PRINT("Payload: %s\n", json_payload.c_str());
    
    std::string response_str = http_helper_->post(url, json_payload, headers_, true);

    PRINT("Response: %s\n", response_str.c_str());
    
    if (!response_str.empty()) 
    {
        auto result = parse_response(response_str);
        if (result.first == 0) 
        {
            return 0;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    if (!response_str.empty()) 
    {
        auto result = parse_response(response_str);
        if (result.first == 0) 
        {
            bytes = string_to_bytes(result.second);
            return 0;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    
    return -1;
}

SmbusHttpBiren::SmbusHttpBiren(const struct http_t& config, const std::string& token) : SmbusHttp(config, token) 
{
    if (0 == token_.length())
    {
        token_ = get_token();
    }\
    if (token_.length()) http_helper_->set_token(token_);
}

int SmbusHttpBiren::lock(int exp_id, int seconds)
{
    exp_id = remap(exp_id);
    std::string url = config_.host + config_.access_lock;

    std::string json_payload = build_lock(exp_id);

    PRINT("lock\nurl: %s\n", url.c_str());
    PRINT("Payload: %s\n", json_payload.c_str());
    
    std::string response_str = http_helper_->post(url, json_payload, headers_, true);
    
    PRINT("Response: %s\n", response_str.c_str());

    if (!response_str.empty()) 
    {
        auto result = parse_response(response_str);
        if (result.first == 0) 
        {
            return 0;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    
    return -1;
}

int SmbusHttpBiren::unlock(int exp_id)
{
    exp_id = remap(exp_id);
    std::string url = config_.host + config_.access_unlock;

    std::string json_payload = build_unlock(exp_id);

    PRINT("unlock\nurl: %s\n", url.c_str());
    PRINT("Payload: %s\n", json_payload.c_str());
    
    std::string response_str = http_helper_->post(url, json_payload, headers_, true);
    
    PRINT("Response: %s\n", response_str.c_str());

    if (!response_str.empty()) 
    {
        auto result = parse_response(response_str);
        if (result.first == 0) 
        {
            return 0;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    
    return -1;
}

std::string SmbusHttpBiren::build_lock(int exp_id)
{
    std::ostringstream json;
    json << "{";
    json << "\"ExpanderId\":" << exp_id;
    json << "}";
    return json.str();
}
std::string SmbusHttpBiren::build_unlock(int exp_id)
{
    std::ostringstream json;
    json << "{";
    json << "\"ExpanderId\":" << exp_id;
    json << "}";
    return json.str();
}

std::pair<int, std::string> SmbusHttpBiren::parse_response(const std::string& response)
{
    int CompletionCode = -1;
    json j = json::parse(response);
    if (j.contains("Status"))
    {
        if ("OK" == j["Status"].get<std::string>())
        {
            if (j.contains("Data") && j["Data"].contains("Value"))
                return std::make_pair(0, j["Data"]["Value"].get<std::string>());
            return std::make_pair(0, "");
        }
    }
    return std::make_pair(CompletionCode, "Invalid Response");
}

std::pair<int, std::string> SmbusHttpBiren::parse_token(const std::string& response)
{
    int CompletionCode = -1;
    json j = json::parse(response);
    if (j.contains("X-Auth-Token"))
    {
        CompletionCode = 0;
        return std::make_pair(CompletionCode, j["X-Auth-Token"].get<std::string>());
    }
    return std::make_pair(CompletionCode, "Invalid Response");
}

int SmbusHttpBiren::remap(int exp_id)
{
    if (!token_.empty() && !exp_map_.empty()) 
    {
        auto it = exp_map_.find(exp_id);
        if (it != exp_map_.end()) return it->second;
    }
    return exp_id;
}

std::string SmbusHttpBiren::get_token()
{
    std::string url = config_.host + config_.get_token;
    std::string json_payload = build_user_pwd();

    PRINT("get_token:\nurl: %s\n", url.c_str());
    PRINT("Payload: %s\n", json_payload.c_str());
    
    std::string response_str = http_helper_->post(url, json_payload, headers_, true, true);

    PRINT("Response: %s\n", response_str.c_str());
    
    if (!response_str.empty()) 
    {
        auto result = parse_token(response_str);
        if (result.first == 0) 
        {
            return result.second;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    
    return "";
}

int SmbusHttpH3C::lock(int exp_id, int seconds)
{
    exp_id = remap(exp_id);

    std::string url = config_.host + config_.access_lock;
    std::string json_payload = build_lock(exp_id, seconds);

    PRINT("lock\nurl: %s\n", url.c_str());
    PRINT("Payload: %s\n", json_payload.c_str());
    
    std::string response_str = http_helper_->post(url, json_payload, headers_, true);

    PRINT("Response: %s\n", response_str.c_str());
    
    if (!response_str.empty()) 
    {
        auto result = parse_response(response_str);
        if (result.first == 0) 
        {
            return 0;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    
    return -1;
}

int SmbusHttpH3C::unlock(int exp_id)
{
    exp_id = remap(exp_id);

    std::string url = config_.host + config_.access_unlock;
    std::string json_payload = build_unlock(exp_id);

    PRINT("unlock\nurl: %s\n", url.c_str());
    PRINT("Payload: %s\n", json_payload.c_str());
    
    std::string response_str = http_helper_->post(url, json_payload, headers_, true);

    PRINT("Response: %s\n", response_str.c_str());
    
    if (!response_str.empty()) 
    {
        auto result = parse_response(response_str);
        if (result.first == 0) 
        {
            return 0;
        }
        else
        {
            std::cerr << __PRETTY_FUNCTION__ << " failed, Code: " << result.first << ", Desc:" << result.second << std::endl;
            exit(1);
        }
    }
    
    return -1;
}

std::pair<int, std::string> SmbusHttpH3C::parse_response(const std::string& response)
{
    int CompletionCode = -1;
    json j = json::parse(response);
    if (j.contains("Oem") && j["Oem"].contains("Public") && j["Oem"]["Public"].contains("CompletionCode") && j["Oem"]["Public"].contains("Description"))
    {
        CompletionCode = j["Oem"]["Public"]["CompletionCode"].get<int>();
        if (CompletionCode == 0 && j.contains("Data") && j["Data"].contains("RegisterValue"))
            return std::make_pair(CompletionCode, j["Data"]["RegisterValue"].get<std::string>());
        return std::make_pair(CompletionCode, j["Oem"]["Public"]["Description"].get<std::string>());
    }
    return std::make_pair(CompletionCode, "Invalid Response");
}
std::string SmbusHttpH3C::build_lock(int exp_id, int seconds)
{
    std::ostringstream json;
    json << "{";
    json << "\"ExpanderId\":" << exp_id << ",";
    json << "\"timeout\":" << seconds;
    json << "}";
    return json.str();
}

std::string SmbusHttpH3C::build_unlock(int exp_id)
{
    std::ostringstream json;
    json << "{";
    json << "\"ExpanderId\":" << exp_id << ",";
    json << "}";
    return json.str();
}

//http.h

// smbus_http_util.h
#ifndef SMBUS_HTTP_H
#define SMBUS_HTTP_H

#include <string>
#include <memory>
#include <utility>
#include <map>
#include <vector>
#include "http_helper.h"
#include "lt_config.h"

class SmbusHttp
{

public:
    SmbusHttp(const struct http_t& config, const std::string& token);
    
    virtual int lock(int exp_id, int seconds) { return 0; }
    virtual int unlock(int exp_id) { return 0; }
    virtual std::string get_token() { return ""; }
    virtual int get_register(int exp_id, int cmd_id, int read_len, std::vector<uint8_t>& bytes);
    virtual int set_register(int exp_id, int cmd_id, int write_len, const std::vector<uint8_t>& value);
    virtual int get_fru(int exp_id, uint8_t addr, int num, std::vector<uint8_t>& bytes);
    
protected:
    struct http_t config_;
    std::unique_ptr<HTTPHelper> http_helper_;

    virtual int remap(int exp_id) { return exp_id; }
    std::map<int, int> exp_map_;

    // 手动构建JSON字符串
    std::vector<uint8_t> string_to_bytes(const std::string& hexString);
    std::string build_user_pwd();
    std::string build_get_register_json(int exp_id, int cmd_id, int read_len);
    std::string build_set_register_json(int exp_id, int cmd_id, int write_len, const std::string& value);
    std::string build_get_base_info_json(int exp_id, int addr, int read_len);
    
    // 解析响应中的Status和Data字段
    virtual std::pair<int, std::string> parse_response(const std::string& response) = 0;
    std::string token_;
};

class SmbusHttpBiren : public SmbusHttp
{
public:
    SmbusHttpBiren(const struct http_t& config, const std::string& token);
    int lock(int exp_id, int seconds) override;
    int unlock(int exp_id) override;
    std::string get_token() override;
protected:
    int remap(int exp_id) override;
    std::pair<int, std::string> parse_token(const std::string& response);
    std::pair<int, std::string> parse_response(const std::string& response);
    std::string build_lock(int exp_id);
    std::string build_unlock(int exp_id);
};

class SmbusHttpH3C : public SmbusHttp
{
public:
    SmbusHttpH3C(const struct http_t& config, const std::string& token) : SmbusHttp(config, token) {}
    int lock(int exp_id, int seconds) override;
    int unlock(int exp_id) override;
protected:
    std::string build_lock(int exp_id, int seconds);
    std::string build_unlock(int exp_id);
    std::pair<int, std::string> parse_response(const std::string& response);
};

#endif // SMBUS_HTTP_UTIL_H