shares 和stockAnalyse

#include "StockDataReader.h" #include <QtSql> #include <QApplication> #include <QString> #include "../StockAnalyse/StockAnalyse_global.h" #include "../StockAnalyse/stockanalyse.h" // 静态成员变量需要在类体的外面进行初始化 //StocksDataReader* StocksDataReader::m_pInstance = NULL; StocksDataReader* StocksDataReader::m_pInstance=NULL; QMutex StocksDataReader::m_Mutex; static QString strhttp_kline = "https://quotes.sina.cn/cn/api/json_v2.php/CN_MarketDataService.getKLineData?symbol="; //绘制实时的分时图需要下列两个网址相结合，腾讯的网址获取今日的历史分时图，新浪的网址实时的该股票行情，进行对今日分时图刷新 //http://data.gtimg.cn/flashdata/hushen/minute/sz000001.js?maxage=110&0.28163905744440854 static QString strhttp_realtime = "http://hq.sinajs.cn/list="; static QString strhttp_timeline = "http://data.gtimg.cn/flashdata/hushen/minute/"; static QString strhttp_4daytimeline = "http://data.gtimg.cn/flashdata/hushen/4day/"; //+sz/或sh/ //https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=sh600519 //新的链接 static QString strhttp_timeline_new = "https://web.ifzq.gtimg.cn/appstock/app/minute/query?code="; static QString strhttp_4daytimeline_new = "https://web.ifzq.gtimg.cn/appstock/app/day/query?code="; //获取最新行情 static QString strhttp_realtime_all = "http://qt.gtimg.cn/q=";//sh600000,sz000001 sh500038 //可以选这个数据多，不用计算可以直接用 //获取实时资金流向 //http://qt.gtimg.cn/q=ff_sh600519 //参考链接https://www.jianshu.com/p/e14b01990ff4 static QString strhttp_realtimemoney = "http://qt.gtimg.cn/q="; //获取简要信息 //http://qt.gtimg.cn/q=s_sh600519,s_sh600000,s_sz000001 //获取港股最新行情 //http://qt.gtimg.cn/q=r_hk09988 //获取美股最新行情 //http://qt.gtimg.cn/?q=s_usBABA //一些链接 // https://www.cnblogs.com/jackljf/p/3589216.html //获取所有股票代码 (sign会不定期调整) //http://api.k780.com/?app=finance.stock_list&category=hs&appkey=10003&sign=b59bc3ef6191eb9f747dd4e83c99f2a4&format=json static QString strhttp_allSharescode = "http://api.k780.com/?app=finance.stock_list&category=hs&appkey=10003&sign=b59bc3ef6191eb9f747dd4e83c99f2a4&format=json"; //参考文章 //https://blog.csdn.net/dangfm/article/details/25079471 //获取股票的交易明细(p为分页，每页70条数据) //https://stock.gtimg.cn/data/index.php?appn=detail&action=data&c=sz002451&p=0 //返回的格式: v_detail_data_sz002451=[0,"0/09:25:01/6.21/0.01/20/12420/B|1/09:30:01/6.25/0.04/81/50621/B] static QString strhttp_tradeDetail = "https://stock.gtimg.cn/data/index.php?appn=detail&action=data&c="; StocksDataReader::StocksDataReader() { manager = new QNetworkAccessManager(this); qDebug() << manager->supportedSchemes(); m_SharesCodelist = new QVariantList(); m_templist = new QVariantList(); m_timelinelist = new QVector<QStringList>; m_pMap5DayTimeLine = new QMap<QString,QVector<QStringList>*>(); //m_AllRealtimelist = new QVector<QStringList>; m_SharesOlderList = new QMap<int,QVector<SharesOlderData>*>(); m_AllRealtimeMoneylist = new QVector<QStringList>; m_timer = new QTimer(this); connect(m_timer, &QTimer::timeout, this, [=](){ if(m_SharesAllCode.size()> 0){ PreGetAllRealtimeData(m_SharesAllCode); PreGetAllRealtimeMoney(m_SharesAllCode); //qDebug()<<"实时刷新正在运行..."; } }); m_timer->start(1000); m_currentPage = 0; m_bGetDetailFinished = false; m_currentIndex = 0; m_bGetAllKLineStart = false; m_bGetAllKLineFinished = false; } void StocksDataReader::StartWorking() { qDebug()<<"StocksDataReader"<<QThread::currentThread(); //得到所有的股票代码(有两种方式1.本地数据库 2.http方式) //StartGetAllSharesCodeFromHttp(m_SharesCodelist); //用于搜索框的数据源 //StartGetKLineDataFromHttp("sz000001",TYPE_DAY_KLINE,-1,m_templist); GetAllSharesCodeFromDB(); getChooseSharelistFromDB(); //必须要m_SharesAllCode中已经插入所有股票代码 //PreGetAllRealtimeData(m_SharesAllCode); // // StartGetTimelineDataFromHttp("sz000001" ,m_timelinelist); // // StartGetTradeDetailFromHttp("sz002425",0); //腾讯的最新获取分时线方法 //StartGetRealtimeDataFromHttp_new("sz000001" ,m_timelinelist); //ReadAllKLineFromLocalFile(); } void StocksDataReader::Running(QString strcode) { //先要清除相关容器 StartGetKLineDataFromHttp(strcode,TYPE_DAY_KLINE,-1,m_templist); //StartGetTimelineDataFromHttp(strcode ,m_timelinelist); StartGetTimelineDataFromHttp_new(strcode ,m_timelinelist); StartGetTimelineData_5DayFromHttp_new(strcode,m_pMap5DayTimeLine); //交易明细 PreGetTradeDetail(strcode); } // void StocksDataReader::SetFlashStatus(bool flag) { if(flag){ //qDebug()<<"开市了"; if(!m_timer->isActive()) { qDebug()<<m_timer->isActive()<<"开启定时任务获取实时数据"; m_timer->start(1000); } }else{ // qDebug()<<"还没开市!"; if(m_timer->isActive()) { qDebug()<<"关闭定时获取实时数据任务"; m_timer->stop(); } } // m_timer->start(1000); } void StocksDataReader::UpdateAllCodeFromHttpToDB() { //m_SharesCodelist函数内没用到 //qDebug()<<__FUNCTION__; StartGetAllSharesCodeFromHttp(m_SharesCodelist); } StocksDataReader::~StocksDataReader() { manager->deleteLater(); } void StocksDataReader::StartGetKLineDataFromHttp(QString SharesCode,int type,int num,QVariantList* list) { QNetworkRequest request; // 发送https请求前准备工作; QSslConfiguration config; QSslConfiguration conf = request.sslConfiguration(); conf.setPeerVerifyMode(QSslSocket::VerifyNone); conf.setProtocol(QSsl::TlsV1SslV3); request.setSslConfiguration(conf); QString strType,strCode,strNum; switch(type){ case TYPE_5MIN_KLINE: strType = "5"; break; case TYPE_10MIN_KLINE: strType = "10"; break; case TYPE_10DAY_KLINE: strType = "2400"; break; case TYPE_5DAY_KLINE: strType = "1200"; break; case TYPE_15MIN_KLINE: strType = "15"; break; case TYPE_30MIN_KLINE: strType = "30"; break; case TYPE_60MIN_KLINE: strType = "60"; break; case TYPE_DAY_KLINE: strType = "240"; break; default: strType = "240"; break; } strNum = QString::number(num); //默认5，10，20，30均线都请求 request.setUrl(QUrl(strhttp_kline+SharesCode+"&scale="+strType+"&ma=5,10,20,30"+"&datalen="+strNum)); // //start QNetworkReply *pReply = manager->get(request); connect(pReply , SIGNAL(finished()) , this , SLOT(onFinished_GetKLine())); connect(pReply , SIGNAL(error(QNetworkReply::NetworkError)) , this , SLOT(onError_GetKLine(QNetworkReply::NetworkError))); } void StocksDataReader::StartGetAllKLineDataFromHttp() { m_currentCodeforAllKLine = m_SharesAllCode.at(m_currentIndex); m_bGetAllKLineStart = true; StartGetKLineDataFromHttp(m_currentCodeforAllKLine,TYPE_DAY_KLINE,-1,m_templist);//通过改第三个参数来决定获得多少天的数据 } void StocksDataReader::StartGetRealtimeDataFromHttp(QString SharesCode, QVector<QStringList> *list) { } //新的腾讯分时api void StocksDataReader::StartGetTimelineDataFromHttp_new(QString SharesCode, QVector<QStringList> *list) { QNetworkRequest request; // 发送https请求前准备工作; QSslConfiguration config; QSslConfiguration conf = request.sslConfiguration(); conf.setPeerVerifyMode(QSslSocket::