状态机详解

// 初始化状态机
bool StateMonitor::initialize(const char* filename, WTSBaseDataMgr* bdMgr, DataManager* dtMgr)
{
	_bd_mgr = bdMgr;
	_dt_mgr = dtMgr;

	// 1. 加载配置文件
	WTSVariant* config = WTSCfgLoader::load_from_file(filename, true);

	auto keys = config->memberNames();
	for (const std::string& sid : keys)
	{
		WTSVariant* jItem = config->get(sid.c_str());
		// 2. 获取交易时间段信息
		WTSSessionInfo* ssInfo = _bd_mgr->getSession(sid.c_str());
		if (ssInfo == NULL)
		{
			WTSLogger::error_f("Trading session template [{}] not exists,state control rule skipped", sid);
			continue;
		}

		// 3. 创建状态信息并填充
		StatePtr sInfo(new StateInfo);
		sInfo->_init_time = jItem->getUInt32("inittime");	//初始化时间,初始化以后数据才开始接收
		sInfo->_close_time = jItem->getUInt32("closetime");	//收盘时间,收盘后数据不再接收了
		sInfo->_proc_time = jItem->getUInt32("proctime");	//盘后处理时间,主要把实时数据转到历史去

		strcpy(sInfo->_session, sid.c_str());
		// 4. 填充集合竞价时间段
		auto secInfo = ssInfo->getAuctionSection();//这里面是偏移过的时间,要注意了!!!
		if (secInfo.first != 0 || secInfo.second != 0)
		{}
		// 5. 填充交易时间段
		auto sections = ssInfo->getTradingSections();//这里面是偏移过的时间,要注意了!!!
		for (auto it = sections.begin(); it != sections.end(); it++)
		{}
		// 6. 将状态信息添加到映射 _map 中
		_map[sInfo->_session] = sInfo;
		// 7. 判断对应合约是否在假日
		CodeSet* pCommSet =  _bd_mgr->getSessionComms(sInfo->_session);
		if (pCommSet)
		{
      {
				/* 
					 (offset>0, curDate不在交易时间, (curmin不在交易时间 || prevDate不在交易日期)
					 (offset<=0, offDate不在交易日)
				*/
				if ((ssInfo->getOffsetMins() > 0 &&
					(! _bd_mgr->isTradingDate(pid, curDate) &&
					!(ssInfo->isInTradingTime(curMin) &&  _bd_mgr->isTradingDate(pid, prevDate)))) ||
					(ssInfo->getOffsetMins() <= 0 && ! _bd_mgr->isTradingDate(pid, offDate))
					)
				{
					WTSLogger::info_f("Instrument {} is in holiday", pid);
				}
			}
		}
	}
	return true;
}

case SS_CLOSED:
  {
    uint32_t offTime = mInfo->offsetTime(curMin, true);
    uint32_t offProcTime = mInfo->offsetTime(sInfo->_proc_time, true);
    if (offTime >= offProcTime)
    {
      // 1. 收盘作业是否已完成
      if(!_dt_mgr->isSessionProceeded(sInfo->_session))
      {
        // 收盘 -> 收盘作业
        sInfo->_state = SS_PROCING;
        WTSLogger::info_f("Trading session {}[{}] started processing closing task", mInfo->name(), sInfo->_session);
        // 2. 数据转存储
        _dt_mgr->transHisData(sInfo->_session);
      }
      else
      {
        // 收盘 -> 已处理
        sInfo->_state = SS_PROCED;
      }
    }

// ...

// 状态在==收盘作业!=节日
if (isAllInState(SS_PROCING) && !isAllInState(SS_Holiday))
{
  // 3. 缓存清理
  _dt_mgr->transHisData("CMD_CLEAR_CACHE");
}

// _proc 即Storage/marker.ini内容
auto it = _proc_date.find(sid);
if (it == _proc_date.end())
  return false;

// .ini内日期>=当前日期, 说明收盘作业已完成
return (it->second >= TimeUtils::getCurDate());

	if (_proc_thrd == NULL)
	{
		_proc_thrd.reset(new StdThread(boost::bind(&WtDataWriter::proc_loop, this)));
	}

else if (StrUtil::startsWith(fullcode, "MARK.", false))
{
  //如果指令以MARK.开头,说明是标记指令,要写一条标记
  std::string filename = _base_dir + MARKER_FILE;
  std::string sid = fullcode.substr(5);
  uint32_t curDate = TimeUtils::getCurDate();
  IniHelper iniHelper;
  iniHelper.load(filename.c_str());
  iniHelper.writeInt("markers", sid.c_str(), curDate);
  iniHelper.save();
  pipe_writer_log(_sink, LL_INFO, "ClosingTask mark of Trading session [{}] updated: {}", sid.c_str(), curDate);
}