main.cpp

#include <chrono>
#include <map>
#include <shared_mutex>
#include <thread>
#include <unordered_map>

#include "GPSTimeAlgorithm.h"
#include "LigDataApi.h"
#include "Params.h"
#include "WorkThreads.h"
#include "log.h"
//#include "glog/logging.h"

using namespace std;
shared_mutex rwMutex;
std::string str = (".\\config.yaml");

int main() {
  std::string configFile = str;
  YAML::Node config;
  try {
    config = YAML::LoadFile(configFile);
  } catch (const YAML::Exception &e) {
    std::cerr << e.what() << "\n";
    return 1;
  }
  std::string file_path = config["LogPath"].as<string>();
  if (Logger::Init(file_path)) {
    LOG_INFO("Logger init successfully!" << endl);
  } else {
    LOG_WARN("Cannot open log file!");
  }
  LigDataApi LigDataApi(configFile);
  // sites 不用重复获取，一段时间内获取一次即可
  vector<StationInfo> sites = LigDataApi.GetStationData();

  unordered_map<int, StationInfo> siteMap;
  for (auto &site : sites) {
    siteMap[site.stationID] = site;
  }

  unordered_map<int, unordered_map<int, double>> siteDistMap, siteTimeMap;

  for (auto &site1 : sites) {
    for (auto &site2 : sites) {
      siteDistMap[site1.stationID][site2.stationID] =
          Stadistance(site1.latitude, site1.longitude, site2.latitude, site2.longitude);
      siteTimeMap[site1.stationID][site2.stationID] =
          siteDistMap[site1.stationID][site2.stationID] / cVeo;
    }
  }

  thread loader, locThread;
  // allTriggers 要求每30s刷新，
  deque<TriggerInfo> allTriggers;
  deque<TriggerInfo> transTriggers;
  bool keep_loading{true};

  // 开始定位
  locThread = thread([&]() {
    ThreadLoc(allTriggers, transTriggers, siteMap, siteTimeMap, rwMutex, config, keep_loading);
  });
  loader =
      thread([&]() { threadLoadData(transTriggers, LigDataApi, rwMutex, config, keep_loading); });

  locThread.join();
  loader.join();
  return 0;
}