instrument_manager.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <string>
#include <unordered_map>
#include <optional>
#include <mutex>
#include <vector>
#include "app/model/instrument.hpp"
 
namespace fix40 {
 
class InstrumentManager {
public:
    // -------------------------------------------------------------------------
    // 构造函数
    // -------------------------------------------------------------------------
 
    InstrumentManager() = default;
 
    ~InstrumentManager() = default;
 
    // 禁用拷贝
    InstrumentManager(const InstrumentManager&) = delete;
    InstrumentManager& operator=(const InstrumentManager&) = delete;
 
    // -------------------------------------------------------------------------
    // 加载方法
    // -------------------------------------------------------------------------
 
    bool loadFromConfig(const std::string& configPath);
 
    void addInstrument(const Instrument& instrument);
 
    void addInstruments(const std::vector<Instrument>& instruments);
 
    // -------------------------------------------------------------------------
    // 查询方法
    // -------------------------------------------------------------------------
 
    const Instrument* getInstrument(const std::string& instrumentId) const;
 
    std::optional<Instrument> getInstrumentCopy(const std::string& instrumentId) const;
 
    bool hasInstrument(const std::string& instrumentId) const;
 
    std::vector<std::string> getAllInstrumentIds() const;
 
    size_t size() const;
 
    std::vector<std::string> searchByPrefix(const std::string& prefix, size_t limit = 10) const;
 
    std::vector<std::string> getInstrumentsByProduct(const std::string& productId) const;
 
    std::vector<std::string> getInstrumentsByExchange(const std::string& exchangeId) const;
 
    // -------------------------------------------------------------------------
    // 更新方法
    // -------------------------------------------------------------------------
 
    bool updateLimitPrices(const std::string& instrumentId,
                           double upperLimit, double lowerLimit);
 
    bool updatePreSettlementPrice(const std::string& instrumentId,
                                   double preSettlementPrice);
 
    // -------------------------------------------------------------------------
    // 清理方法
    // -------------------------------------------------------------------------
 
    void clear();
 
private:
    std::unordered_map<std::string, Instrument> instruments_;
 
    mutable std::mutex mutex_;
};
 
} // namespace fix40