resistancemonitor/10. tools/HJHWExport/HJHWExport/Device.cpp

#include "stdafx.h"
#include "Device.h"
#include <ODBC/DBConnectPool.h>
#include <Simplelog.h>
#include <assert.h>

using namespace std;

CDevice::CDevice()
{
	memset(&m_sensor_status, (int)SENSOR_STATUS::UNKONW, sizeof(m_sensor_status));
}


CDevice::~CDevice()
{
}


void CDevice::Insert(int index, time_t time, int data0, int data1, int data2)
{
	//if (m_tmMoveDetectTime == 0) m_tmMoveDetectTime = time / 10000 * 10;
	lock_guard<mutex> lock(m_mtx);
	this->imei;
	if (index == 0)
	{
		InsertData(map_resist_idx00, time, data0);
		InsertData(m_mapSecondStatInfo00, time, data0);
		InsertData(map_resist_idx01, time, data1);
		InsertData(m_mapSecondStatInfo01, time, data1);
		InsertData(map_resist_idx02, time, data2);
		InsertData(m_mapSecondStatInfo02, time, data2);
	}
	else if (index == 1)
	{
		InsertData(map_resist_idx10, time, data0);
		InsertData(m_mapSecondStatInfo10, time, data0);
		InsertData(map_resist_idx11, time, data1);
		InsertData(m_mapSecondStatInfo11, time, data1);
		InsertData(map_resist_idx12, time, data2);
		InsertData(m_mapSecondStatInfo12, time, data2);
	}
	else if (index == 2)
	{
		InsertData(map_resist_idx20, time, data0);
		InsertData(m_mapSecondStatInfo20, time, data0);
		InsertData(map_resist_idx21, time, data1);
		InsertData(m_mapSecondStatInfo21, time, data1);
		InsertData(map_resist_idx22, time, data2);
		InsertData(m_mapSecondStatInfo22, time, data2);
	}
	else
	{
		assert(0);
	}
}

void CDevice::LoadHist()
{
	if (imei.length() <= 5) return;
	auto start = chrono::steady_clock::now();
	SYSTEMTIME stNow;
	GetLocalTime(&stNow);
	char tablename[300] = { 0 };
	sprintf_s(tablename, 50, "rm_resistance_%04d%02d%02d", stNow.wYear, stNow.wMonth, stNow.wDay);
	CString  sql;
#ifdef _DEBUG
	sql.Format("SELECT TOP 1000 [acquisitiontime],[idx],[data0],[data1],[data2] FROM %s WHERE IMEI = '%s' order by acquisitiontime, idx", tablename, imei.c_str());
#else
	sql.Format("SELECT [acquisitiontime],[idx],[data0],[data1],[data2] FROM %s WHERE IMEI = '%s' AND acquisitiontime > dateadd(hour,-1,GETDATE()) order by acquisitiontime, idx", tablename, imei.c_str());
#endif // _DEBUG
	
	COdbcStatement stmt;

#ifndef _DEBUG
	if (!CDBConnectPool::Instance()->DBQuery(stmt, sql))
	{
		CSimpleLog::Error("sql语句执行失败:" + sql);
		return;
	}

	TIMESTAMP_STRUCT ts;
	uint8_t idx;
	int data0, data1, data2;
	int nCol = 1;
	stmt.BindTimeStampCol(nCol++, &ts);
	stmt.BindTinyIntCol(nCol++, &idx);
	stmt.BindIntCol(nCol++, &data0);
	stmt.BindIntCol(nCol++, &data1);
	stmt.BindIntCol(nCol++, &data2);

	do 
	{
		if (stmt.FetchNext() != 0)
			break;

		CTime ctTime;
		try
		{
			ctTime = CTime(ts.year, ts.month, ts.day, ts.hour, ts.minute, ts.second);
		}
		catch (...)
		{
			continue;
		}

		time_t tt = ctTime.GetTime() * 1000 + ts.fraction / 1000000;
		Insert(idx, tt, data0, data1, data2);
	} while (true);
	this->map_resist_idx00, this->map_resist_idx01, this->map_resist_idx02;
	auto dif = chrono::duration_cast<chrono::milliseconds>(chrono::steady_clock::now() - start).count();
	if (dif > 100)
	{
		sprintf_s(tablename, 300, "执行语句耗时:(%I64d)ms.(%s)", dif, (LPCSTR)sql);
		CSimpleLog::Info(tablename);
	}
#endif // _DEBUG

	//加载设备心跳时间
	{
		TIMESTAMP_STRUCT ts;
		COdbcStatement stmt;
		sql.Format("SELECT updatetime FROM rm_deviceinfo WHERE IMEI = '%s';", imei.c_str());
		if (CDBConnectPool::Instance()->DBQuery(stmt, sql))
		{
			stmt.BindTimeStampCol(1, &ts);
			if (stmt.FetchNext() == 0)
			{
				try {
					m_ctUpdateTime = CTime(ts.year, ts.month, ts.day, ts.hour, ts.minute, ts.second);
				}
				catch (...) {};
			}
		}
		else
		{
			CSimpleLog::Error("sql语句执行失败:" + sql);
		}
	}
}

std::map<time_t, int>* CDevice::GetMapData(uint8_t idx, uint8_t no)
{
	if (idx > 2 || no > 2)
		return nullptr;
	else if (idx == 0 && no == 0)
		return &map_resist_idx00;
	else if (idx == 0 && no == 1)
		return &map_resist_idx01;
	else if (idx == 0 && no == 2)
		return &map_resist_idx02;
	else if (idx == 1 && no == 0)
		return &map_resist_idx10;
	else if (idx == 1 && no == 1)
		return &map_resist_idx11;
	else if (idx == 1 && no == 2)
		return &map_resist_idx12;
	else if (idx == 2 && no == 0)
		return &map_resist_idx20;
	else if (idx == 2 && no == 1)
		return &map_resist_idx21;
	else if (idx == 2 && no == 2)
		return &map_resist_idx22;
	return nullptr;
}

std::map<time_t, tagSecondStatInfo>* CDevice::GetStatInfo(uint8_t idx, uint8_t no)
{
	if (idx > 2 || no > 2)
		return nullptr;
	else if (idx == 0 && no == 0)
		return &m_mapSecondStatInfo00;
	else if (idx == 0 && no == 1)
		return &m_mapSecondStatInfo01;
	else if (idx == 0 && no == 2)
		return &m_mapSecondStatInfo02;
	else if (idx == 1 && no == 0)
		return &m_mapSecondStatInfo10;
	else if (idx == 1 && no == 1)
		return &m_mapSecondStatInfo11;
	else if (idx == 1 && no == 2)
		return &m_mapSecondStatInfo12;
	else if (idx == 2 && no == 0)
		return &m_mapSecondStatInfo20;
	else if (idx == 2 && no == 1)
		return &m_mapSecondStatInfo21;
	else if (idx == 2 && no == 2)
		return &m_mapSecondStatInfo22;
	return nullptr;
}

BOOL CDevice::IsDeviceOnline(uint8_t idx, time_t tmNow, int inteval)
{
	if (idx == 0)
	{
		if (map_resist_idx00.size() == 0) return FALSE;
		if (tmNow - map_resist_idx00.rbegin()->first < inteval)
			return TRUE;
	}
	else if (idx == 1)
	{
		if (map_resist_idx10.size() == 0) return FALSE;
		auto tt = map_resist_idx10.rbegin()->first;
		if (tmNow -  tt < inteval)
			return TRUE;
	}
	else if (idx == 2)
	{
		if (map_resist_idx20.size() == 0) return FALSE;
		if (tmNow - map_resist_idx20.rbegin()->first < inteval)
			return TRUE;
	}
	return FALSE;
}

CDeviceMng::CDeviceMng()
{
}

CDeviceMng::~CDeviceMng()
{
	lock_guard<mutex> lock(m_mtx);
	for (auto& it : m_map_devices)
	{
		delete it.second;
		it.second = nullptr;
	}
	m_map_devices.clear();
}

CDevice* CDeviceMng::Insert(std::string imei)
{
	lock_guard<mutex> lock(m_mtx);
	auto it = m_map_devices.find(imei);
	if (it == m_map_devices.end())
	{
		auto ret = m_map_devices.insert(make_pair(imei, new CDevice));
		assert(ret.second == true);
		if (ret.second)
		{
			ret.first->second->imei = imei;
			ret.first->second->LoadHist();
			return ret.first->second;
		}
		else delete ret.first->second;
		return nullptr;
	}
	else
	{
		return it->second;
	}
}

CDevice* CDeviceMng::Find(std::string imei)
{
	lock_guard<mutex> lock(m_mtx);
	auto it = m_map_devices.find(imei);
	if (it == m_map_devices.end()) return nullptr;
	else return it->second;
}

BOOL CDeviceMng::IsDeviceOnline(std::string imei, int8_t idx, int interval /*= 180000*/)
{
	time_t tmNow;
	time(&tmNow);
	lock_guard<mutex> lock(m_mtx);
	auto it = m_map_devices.find(imei);
	if (it == m_map_devices.end()) return FALSE;
	return it->second->IsDeviceOnline(idx, tmNow * 1000, interval);
}

CDeviceMng CDeviceMng::obj;