test/hikyuu2
1
0
Fork 0
mirror of https://gitee.com/fasiondog/hikyuu.git synced 2024-11-30 02:48:57 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fixed 分钟级别K线更新

Browse Source
This commit is contained in:
fasiondog 2024-09-02 23:51:46 +08:00
parent aeaeb6a388
commit 094f124f98
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
hikyuu_cpp/hikyuu/global/GlobalSpotAgent.cpp
View File

@ -131,9 +131,21 @@ static void updateStockMinData(const SpotRecord& spot, KQuery::KType ktype) {
// 非24小时交易品种，且时间和当天零时相同认为无分钟线级别数据
HKU_IF_RETURN(stk.type() != STOCKTYPE_CRYPTO && minute == today, void());
Datetime start_minute = minute - (minute - today) % gap;
Datetime end_minute = start_minute + gap;
KRecordList klist = stk.getKRecordList(KQuery(start_minute, end_minute, ktype));
Datetime end_minute = minute - (minute - today) % gap + gap;
// 处理闭市时最后一条记录
MarketInfo market_info = StockManager::instance().getMarketInfo(stk.market());
Datetime close1 = today + market_info.closeTime1();
Datetime close2 = today + market_info.closeTime2();
Datetime open2 = today + market_info.openTime2();
if (!close2.isNull() && end_minute > close2) {
end_minute = close2;
} else if (!open2.isNull() && !close1.isNull() && end_minute < open2 && end_minute > close1) {
end_minute = close1;
}
// 计算当前之前的累积成交金额、成交量
KRecordList klist = stk.getKRecordList(KQuery(today, end_minute, ktype));
price_t sum_amount = 0.0, sum_volume = 0.0;
for (const auto& k : klist) {
sum_amount += k.transAmount;