resistancemonitor/4.Data/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()
{
}
// 写入传感器的状态信息
bool CDevice::InsertStatus(const SENSOR_STATUS st[9][2], const int dt[9][2])
{
	CString sql;
	sql.Format("UPDATE RM_DEVICEINFO "
		"set st0 = %d,"
		"st1 = %d,"
		"st2 = %d,"
		"st3 = %d,"
		"st4 = %d,"
		"st5 = %d,"
		"st6 = %d,"
		"st7 = %d,"
		"st8 = %d,"
		"dt0 = %d,"
		"dt1 = %d,"
		"dt2 = %d,"
		"dt3 = %d,"
		"dt4 = %d,"
		"dt5 = %d,"
		"dt6 = %d,"
		"dt7 = %d,"
		"dt8 = %d"
		" where imei = '%s';",
		st[0][0], st[1][0], st[2][0], st[3][0],
		st[4][0], st[5][0], st[6][0], st[7][0],
		st[8][0],
		dt[0][0], dt[1][0], dt[2][0], dt[3][0],
		dt[4][0], dt[5][0], dt[6][0], dt[7][0],
		dt[8][0],
		this->imei.c_str());
	if (false == CDBConnectPool::Instance()->DBExecuteSQL(sql))
	{
		CSimpleLog::Error("执行语句失败" + sql);
		return false;
	}
	return true;
}

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;
	CString  sql;
	/*
	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);
#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 (tmNow - m_tmUpdateTime0 < inteval)
			return TRUE;
	}
	else if (idx == 1)
	{
		if (tmNow - m_tmUpdateTime0 < inteval)
			return TRUE;
	}
	else if (idx == 2)
	{
		if (tmNow - m_tmUpdateTime0 < 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, interval);
}

CDeviceMng CDeviceMng::obj;