W17cxBGSpUYm
include<iostream> include<queue> include<mutex> include<condition_variable> include<shared_mutex> template<typenameT> classThreadSafeQueue{ private: std::queue<T>queue_; mutablestd::mutexmutex_; std::condition_variablecond_; public: voidPush(constT&v...
//SizeSignal.h pragmaonce include<onepiece/models/TickData.h> include<queue> classSizeSignal { public: SizeSignal()=delete; SizeSignal(unsignedintwindows); SizeSignal(); voidUpdateTick(TickSPtrtickSPtr); intSumBidSize(); intSumAskSize(); intSumDiff(); intSumVolume(); doubleAvgB...
include<memory> include<onepiece/datacore/DataCore.h> include<spdlog/spdlog.h> include<spdlog/sinks/basic_file_sink.h> include<memory> usingnamespacestd; intmain(intargc,constcharargv[]){ //testspdlog. cout<<"ワンピースは実在する."<<endl; autologger=std::make_s...
importos importre importgc importpandas fromtqz_extern.pandas_operatorimportpandas fromtqz_extern.json_operatorimportTQZJsonOperator importwarnings warnings.filterwarnings("ignore") classMarketDataParser: session_map=TQZJsonOperator.tqz_load_jsonfile(jsonfile='../trading_time/source_trading_ti...
pragmaonce include<vector> include<string> include<iostream> include<atomic> include<onepiece/api/ctp/ThostFtdcMdApi.h> include<onepiece/models/AccountModel.h> include<onepiece/templates/ICoreListener.h> include<onepiece/templates/IMarketApi.h> u...
//VWAP.h pragmaonce include<onepiece/models/TickData.h> include<queue> classVWAP { public: VWAP()=delete; VWAP(unsignedintwindows); VWAP(); voidUpdateTick(TickSPtrtickSPtr); doubleValue(); boolCheck(); private: unsignedintm_windows; doublem_sumLastPriceValue; doublem_sumSizeV...
//SMA.h pragmaonce include<onepiece/models/TickData.h> include<queue> classSMA { public: SMA()=delete; SMA(unsignedintwindows); SMA(); voidUpdateTick(TickSPtrtickSPtr); doubleValue(); boolCheck(); private: unsignedintm_windows; doublem_sumValue; queue<TickSPtr>m_ticks;...
linux执行命令:crontab-e 051-5sudo/sbin/shutdown-rnow 0171-5sudo/sbin/shutdown-rnow 4581-5cd/home/ubuntu/onepiece/bin/datacore&&./datacore 45201-5cd/home/ubuntu/onepiece/bin/datacore&&./datacore 以上是四条自动化执行的定时任务，因为太简单了，我就不细说明了；接下来是验证服务器确实重启过的linux命令。 who-b
fromtqz_extern.json_operatorimportTQZJsonOperator importos fromdatetimeimportdatetime,timedelta fromtqz_extern.tqz_constantimportTQZTradingTimeType classMakeTradingTime: DAY:str='day' NIGHT:str='night' day_close_times:list=["1500","1515"] night_close_times:list=["2300","0100","0230"] @classm...
fromtqz_extern.json_operatorimportTQZJsonOperator importos classMakeConfig: DAY:str='day' NIGHT:str='night' @classmethod defreset_trading_time_json(cls,source_trading_time_json:str,target_trading_time_json:str): assertos.path.exists(path=source_trading_time_json),f'Badpath:{source_trading_time_...
CMAKE_MINIMUM_REQUIRED(VERSION3.0) PROJECT(marketctp) SET(CMAKE_CXX_STANDARD17) INCLUDE_DIRECTORIES(${CMAKE_CURRENT_SOURCE_DIR}/../../include) SET(srcMarketCTP.cc) FIND_PACKAGE(ThreadsREQUIRED) SET(LIBS boost_filesystem ${CMAKE_CURRENT_SOURCE_DIR}/../../lib/libthostmduserapi_se.so ${CMAKE_THRE...
!/bin/bash project_path=$(pwd) build_path=$project_path/build project_name="marketctp" if[-d"$build_path"];then echo"path:$build_pathisexist." rm-rf$build_path fi mkdir$build_path cd$build_path cmake.. if[$?-eq0];then echo"cmakeproject$project_namesuccess." traderctp_include_path=$project_pat...
//ICoreListener.h pragmaonce include<onepiece/models/TickData.h> include<onepiece/models/OrderData.h> include<onepiece/models/TradeData.h> include<onepiece/models/StatusInfoFieldData.h> include<memory> include<onepiece/templates/IMarketApi.h> include<onep...