#pragma once
|
#include <string>
|
#include <list>
|
#include "json/json.h"
|
#include <THSActionUtil.h>
|
#include "LimitUpCapture.h"
|
#include "TradeListCapture.h"
|
#include "IndustryCapture.h"
|
#include "CurrentPriceCapture.h"
|
#include "TaskChecker.h"
|
|
class JsonUtil {
|
|
public:
|
|
static Json::Value toJson(std::list<TradeData*> dataList) {
|
Json::Value root;
|
|
std::list<TradeData*>::iterator ele;
|
int index = 0;
|
for (ele = dataList.begin();ele != dataList.end();ele++) {
|
Json::Value item;
|
item["time"] = (*ele)->time;
|
item["price"] = (*ele)->price;
|
item["num"] = (*ele)->num;
|
item["limitPrice"] = (*ele)->limitPrice;
|
item["operateType"] = (*ele)->operateType;
|
item["cancelTime"] = (*ele)->cancelTime;
|
item["cancelTimeUnit"] = (*ele)->cancelTimeUnit;
|
root[index++] = item;
|
}
|
return root;
|
}
|
|
|
|
static Json::Value toJson(set<string> dataList) {
|
Json::Value root;
|
|
set<string>::iterator ele;
|
int index = 0;
|
for (ele = dataList.begin();ele != dataList.end();ele++) {
|
root[index++] = *ele;
|
}
|
return root;
|
}
|
|
//json¶ÔÏóתΪ×Ö·û´®
|
static std::string toJsonStr(Json::Value json) {
|
clock_t start_time = clock();
|
Json::StreamWriterBuilder writerBuilder;
|
//²»×Ô¶¯»»ÐÐ
|
writerBuilder.settings_["indentation"] = "";
|
std::ostringstream os;
|
std::unique_ptr<Json::StreamWriter> jsonWriter(writerBuilder.newStreamWriter());
|
jsonWriter->write(json, &os);
|
string jsonStr = os.str();
|
//ÊÍ·Å×ÊÔ´
|
//jsonWriter.reset();
|
//cout << "jsonת×Ö·û´®ºÄʱ:"<< clock()- start_time << endl;
|
return jsonStr;
|
}
|
|
static std::string loadL2Data(int clientID, int channel, string code, long captureTime, long processTime, std::list<TradeData*> dataList) {
|
//Json::Value data;
|
//data["channel"] = channel;
|
//data["code"] = code;
|
//data["captureTime"] = captureTime;
|
//data["processTime"] = processTime;
|
//data["data"] = toJson(dataList);
|
//Json::Value root;
|
//root["type"] = 0;
|
//root["client"] = clientID;
|
//root["data"] = data;
|
//return toJsonStr(root);
|
string st = "{";
|
st.append("\"type\":0,");
|
st.append("\"client\":").append(to_string(clientID)).append(",");
|
st.append("\"data\":{");
|
st.append("\"channel\":").append(to_string(channel)).append(",");
|
st.append("\"code\":").append("\"").append(code).append("\"").append(",");
|
st.append("\"captureTime\":").append(to_string(captureTime)).append(",");
|
st.append("\"processTime\":").append(to_string(channel)).append(",");
|
st.append("\"data\":[");
|
int index = 0;
|
for (std::list<TradeData*>::iterator ele = dataList.begin(); ele != dataList.end(); ele++) {
|
index++;
|
st.append("{");
|
st.append("\"time\":").append("\"").append((*ele)->time).append("\"").append(",");
|
st.append("\"price\":").append("\"").append((*ele)->price).append("\"").append(",");
|
st.append("\"num\":").append(to_string((*ele)->num)).append(",");
|
st.append("\"limitPrice\":").append(to_string((*ele)->limitPrice)).append(",");
|
st.append("\"operateType\":").append(to_string((*ele)->operateType)).append(",");
|
st.append("\"cancelTime\":").append(to_string((*ele)->cancelTime)).append(",");
|
st.append("\"cancelTimeUnit\":").append(to_string((*ele)->cancelTimeUnit));
|
st.append("}");
|
if (index != dataList.size()) {
|
st.append(",");
|
}
|
}
|
st.append("]");
|
st.append("}}");
|
return st;
|
}
|
|
|
static std::string loadTradeQueueData(int clientID, int channel, string code, L2TradeQueue tradeQueue) {
|
Json::Value data;
|
data["channel"] = channel;
|
data["code"] = code;
|
|
Json::Value _data;
|
_data["buyOnePrice"] = tradeQueue.buyOnePrice;
|
_data["buyOneVolumn"] = tradeQueue.buyOneVolumn;
|
_data["buyTime"] = tradeQueue.buyTime;
|
_data["sellOnePrice"] = tradeQueue.sellOnePrice;
|
_data["sellOneVolumn"] = tradeQueue.sellOneVolumn;
|
_data["sellTime"] = tradeQueue.sellTime;
|
Json::Value buyQueue;
|
int index = 0;
|
for (list<string>::iterator ele = tradeQueue.buyQueue.begin(); ele != tradeQueue.buyQueue.end(); ++ele) {
|
buyQueue[index++] = atoi((*ele).c_str());
|
}
|
_data["buyQueue"] = buyQueue;
|
|
|
data["data"] = _data;
|
Json::Value root;
|
root["type"] = 10;
|
root["client"] = clientID;
|
root["data"] = data;
|
return toJsonStr(root);
|
}
|
|
static std::string loadLimitUpData(list<LimitUpData> dataList) {
|
Json::Value root;
|
root["type"] = 2;
|
|
|
Json::Value data;
|
|
std::list<LimitUpData>::iterator ele;
|
int index = 0;
|
for (ele = dataList.begin();ele != dataList.end();ele++) {
|
Json::Value item;
|
item["time"] = (*ele).time;
|
item["price"] = (*ele).price;
|
item["limitMoney"] = (*ele).limitMoney;
|
item["limitMoneyUnit"] = (*ele).limitMoneyUnit;
|
item["limitUpPercent"] = (*ele).limitUpPercent;
|
item["code"] = (*ele).code;
|
data[index++] = item;
|
}
|
|
root["data"] = data;
|
|
|
return toJsonStr(root);
|
}
|
|
|
static std::string loadFirstLimitUpData(list<FirstLimitUpCodeData> dataList) {
|
Json::Value root;
|
root["type"] = 22;
|
|
|
Json::Value data;
|
|
std::list<FirstLimitUpCodeData>::iterator ele;
|
int index = 0;
|
for (ele = dataList.begin(); ele != dataList.end(); ele++) {
|
Json::Value item;
|
item["time"] = (*ele).time;
|
item["price"] = (*ele).price;
|
item["zyltMoney"] = (*ele).zyltMoney;
|
item["zyltMoneyUnit"] = (*ele).zyltMoneyUnit;
|
item["volume"] = (*ele).volume;
|
item["volumeUnit"] = (*ele).volumeUnit;
|
item["limitUpPercent"] = (*ele).limitUpPercent;
|
item["code"] = (*ele).code;
|
data[index++] = item;
|
}
|
|
root["data"] = data;
|
|
|
return toJsonStr(root);
|
}
|
|
|
static std::string loadTradeSuccessData(list<TradeSuccessData> dataList) {
|
Json::Value root;
|
root["type"] = 3;
|
|
|
Json::Value data;
|
|
std::list<TradeSuccessData>::iterator ele;
|
int index = 0;
|
for (ele = dataList.begin();ele != dataList.end();ele++) {
|
Json::Value item;
|
item["price"] = (*ele).price;
|
item["code"] = (*ele).code;
|
item["time"] = (*ele).time;
|
item["num"] = (*ele).num;
|
item["money"] = (*ele).money;
|
item["trade_num"] = (*ele).trade_num;
|
item["type"] = (*ele).type;
|
data[index++] = item;
|
}
|
|
root["data"] = data;
|
|
|
return toJsonStr(root);
|
}
|
|
|
static std::string loadTradeDelegateData(list<TradeDelegateData> dataList) {
|
Json::Value root;
|
root["type"] = 5;
|
|
|
Json::Value data;
|
|
std::list<TradeDelegateData>::iterator ele;
|
int index = 0;
|
for (ele = dataList.begin();ele != dataList.end();ele++) {
|
Json::Value item;
|
item["code"] = (*ele).code;
|
item["time"] = (*ele).time;
|
item["apply_time"] = (*ele).apply_time;
|
item["num"] = (*ele).num;
|
item["type"] = (*ele).type;
|
item["price"] = (*ele).price;
|
item["trade_price"] = (*ele).trade_price;
|
item["trade_num"] = (*ele).trade_num;
|
data[index++] = item;
|
}
|
|
root["data"] = data;
|
|
|
return toJsonStr(root);
|
}
|
|
static std::string loadIndustryData(list<list<IndustryData>> dataList) {
|
Json::Value root;
|
root["type"] = 4;
|
|
|
Json::Value data;
|
|
std::list<list<IndustryData>>::iterator ele;
|
int index = 0;
|
for (ele = dataList.begin();ele != dataList.end();ele++) {
|
Json::Value item;
|
|
int cindex = 0;
|
for (list<IndustryData >::iterator e = (*ele).begin();e != (*ele).end();e++) {
|
Json::Value item_c;
|
item_c["code"] = (*e).code;
|
item_c["zyltgb"] = (*e).zyltMoney;
|
item_c["zyltgb_unit"] = (*e).zyltMoneyUnit;
|
item[cindex++] = item_c;
|
}
|
data[index++] = item;
|
}
|
|
root["data"] = data;
|
|
|
return toJsonStr(root);
|
}
|
|
static std::string loadGPPriceData(std::list<CurrentPriceData> dataList) {
|
Json::Value root;
|
root["type"] = 40;
|
Json::Value data;
|
|
std::list<CurrentPriceData>::iterator ele;
|
int index = 0;
|
for (ele = dataList.begin();ele != dataList.end();ele++) {
|
Json::Value item;
|
item["code"] = (*ele).code;
|
item["price"] = (*ele).price;
|
item["volumn"] = (*ele).volumn;
|
item["volumnUnit"] = (*ele).volumnUnit;
|
data[index++] = item;
|
}
|
root["data"] = data;
|
return toJsonStr(root);
|
}
|
|
|
static std::string loadGPCodeData(std::list<IndustryData> codeList,bool add) {
|
Json::Value root;
|
root["type"] = 1;
|
Json::Value data;
|
|
std::list<IndustryData>::iterator ele;
|
int index = 0;
|
for (ele = codeList.begin();ele != codeList.end();ele++) {
|
Json::Value item;
|
item["code"] = (*ele).code;
|
item["zyltgb"] = (*ele).zyltMoney;
|
item["zyltgb_unit"] = (*ele).zyltMoneyUnit;
|
data[index++] = item;
|
}
|
root["data"] = data;
|
root["add"] = add;
|
return toJsonStr(root);
|
}
|
|
static std::string loadHeartbeatData(int client,string memery,string ownMemery,bool thsDead,string thsDeadMsg) {
|
Json::Value root;
|
root["type"] = 30;
|
Json::Value data;
|
data["client"] = client;
|
data["memery"] = memery;
|
data["own_memery"] = ownMemery;
|
data["thsDead"] = thsDead;
|
data["thsDeadMsg"] = thsDeadMsg;
|
root["data"] = data;
|
return toJsonStr(root);
|
}
|
|
|
|
static std::string loadLoginData(string account,string pwd) {
|
Json::Value root;
|
root["type"] = 20;
|
Json::Value data;
|
data["account"] = account;
|
data["pwd"] = pwd;
|
root["data"] = data;
|
return toJsonStr(root);
|
}
|
|
|
|
|
static std::string loadAvailableMoney(int client,string money) {
|
Json::Value root;
|
root["type"] = 6;
|
Json::Value data;
|
data["client"] = client;
|
data["money"] = money;
|
root["data"] = data;
|
return toJsonStr(root);
|
}
|
|
static std::string loadTradeQueue(int index, string codeName,int volumn,string price,string time) {
|
Json::Value root;
|
root["type"] = 50;
|
Json::Value data;
|
data["index"] = index;
|
data["codeName"] = codeName;
|
data["price"] = price;
|
data["volumn"] = volumn;
|
data["time"] = time;
|
root["data"] = data;
|
return toJsonStr(root);
|
}
|
|
|
// ×Ô¶¯Æô¶¯L2³É¹¦
|
static std::string loadAutoStartL2(int client) {
|
Json::Value root;
|
root["type"] = 60;
|
Json::Value data;
|
data["client"] = client;
|
root["data"] = data;
|
return toJsonStr(root);
|
}
|
// ocrʶ±ð
|
static std::string loadOcrData(int client,cv::Mat mat,string key) {
|
Json::Value data;
|
Json::Value array;
|
int len = mat.rows * mat.cols;
|
for (int i = 0; i < len; i++) {
|
Json::Value d;
|
d[0] = mat.data[i];
|
array[i] = d;
|
}
|
data["data"] = array;
|
data["width"] = mat.cols;
|
data["height"] = mat.rows;
|
data["key"] = key;
|
Json::Value root;
|
root["data"] = data;
|
root["type"] = 100;
|
return toJsonStr(root);
|
}
|
|
static std::string toJson(ClientEnvState state) {
|
Json::Value root;
|
root["ths_l2_win"] = state.ths_l2_win;
|
root["ths_fp_1"] = state.ths_fp_1;
|
root["ths_fp_2"] = state.ths_fp_2;
|
root["ths_trade_success"] = state.ths_trade_success;
|
root["l2_channel_valid_count"] = state.l2_channel_valid_count;
|
root["l2_channel_invalid_count"] = state.l2_channel_invalid_count;
|
root["limitUp"] = state.limitUp;
|
root["tradeSuccess"] = state.tradeSuccess;
|
return toJsonStr(root);
|
}
|
|
|
|
|
static Json::Value parseJson(string data) {
|
Json::Value root;
|
Json::Reader reader;
|
reader.parse(data, root);
|
return root;
|
}
|
|
|
|
|
|
|
static string jsonValue2String(Json::Value value) {
|
Json::FastWriter fastWriter;
|
std::string output = fastWriter.write(value);
|
return output;
|
}
|
|
|
|
|
};
|
