dmsv2/Dms/PostureDataPointManager.cpp

/**************************************************************************************************
                                   版本所有(C), 2021-2022, 北京普达迪泰
***************************************************************************************************
 文 件 名：PostureDataPointManager.cpp
 版 本 号: 1.00初版
 作    者: HYF
 生成日期：2021－12－20
 最近修改:
 功能描述: 位姿动态数据
 函数列表:
 修改历史:
     1.日    期 : 2021－12－20
       作    者 : HYF
       修改内容 : 创建文件

**************************************************************************************************/
#include "pch.h"
#include "PostureDataPointManager.h"
#include "CppSQLite3.h"
#include "DBFactory.h"
#include "PostureDataPoint.h"

PostureDataPointManager::PostureDataPointManager()
{

}

PostureDataPointManager::~PostureDataPointManager()
{

}


/**************************************************************************************************
函 数 名 :QueryByTaskId
功能描述 :查询
输出参数 :无
返 回 值 :CppSQLite3Query
**************************************************************************************************/
CppSQLite3Query PostureDataPointManager::Query(DWORD iTaskId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        char szCmd[256];

        sprintf_s(szCmd, "SELECT * FROM posture_data_point WHERE task_id=%d;", iTaskId);
        return pDB->execQuery(szCmd);
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
    }
}

CppSQLite3Query PostureDataPointManager::Query(DWORD iTaskId, LPCTSTR szEquipCode)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        char szCmd[256];
        sprintf_s(szCmd, "SELECT * FROM posture_data_point WHERE task_id=%d AND equip_code='%s';", iTaskId, szEquipCode);
        return pDB->execQuery(szCmd);
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
    }
}

CppSQLite3Query PostureDataPointManager::Query(DWORD iTaskId, LPCTSTR szEquipCode, LPCTSTR szEquipPlace)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        char szCmd[256];
        sprintf_s(szCmd, "SELECT * FROM posture_data_point WHERE task_id=%d AND equip_code='%s' AND equip_place='%s';", iTaskId, szEquipCode, szEquipPlace);
        return pDB->execQuery(szCmd);
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
    }
}

CppSQLite3Query PostureDataPointManager::Query(DWORD iTaskId, LPCTSTR szEquipCode, LPCTSTR szEquipPlace, DWORD iPointId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        char szCmd[256];
        sprintf_s(szCmd, "SELECT * FROM posture_data_point WHERE task_id=%d AND equip_code='%s' AND equip_place='%s' AND point_id=%d;", iTaskId, szEquipCode, szEquipPlace, iPointId);
        return pDB->execQuery(szCmd);
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
    }
}

CppSQLite3Query PostureDataPointManager::QueryOfReport(DWORD iTaskId)
{
	CString szPoints = AppConfig::GetString(_T("Report"), _T("Dynamic_Points"));
	CStringArray arrPoints;
	Utils::StrSplit(szPoints, ",", arrPoints);

	int iNum = (int)arrPoints.GetCount();
	CString szCond;
	for (int i = 0; i < iNum; i++) {
		if (i > 0) szCond.Append(",");
		szCond.Append("'");
		szCond.Append(arrPoints[i]);
		szCond.Append("'");
	}

	try
	{
		CppSQLite3DB* pDB = DBFactory::GetSQLite();
		char szCmd[256];

		if (iNum > 0) {
			sprintf_s(szCmd, "SELECT * FROM posture_data_point WHERE task_id=%d AND point_code in (%s);", iTaskId, szCond.GetBuffer());
		}
		else {
			sprintf_s(szCmd, "SELECT * FROM posture_data_point WHERE task_id=%d;", iTaskId);
		}
		
		return pDB->execQuery(szCmd);
	}
	catch (CppSQLite3Exception& e)
	{
		LOG::E(e.errorMessage());
	}
}



/**************************************************************************************************
函 数 名 :Add
功能描述 :增加TaskData
输入参数 :点云数据
输出参数 :无
返 回 值 :TRUE 成功；FALSE 失败
**************************************************************************************************/
BOOL PostureDataPointManager::Add(const PostureDataPoint& data)
{
    DWORD   iTaskId      = data.GetTaskId();
    CString szEquipCode  = data.GetEquipCode();
    CString szEquipPlace = data.GetEquipPlace();
    DWORD   iPointId     = data.GetPointId();
    CString szPointTitle = data.GetPointTitle();
    CString szPointCode  = data.GetPointCode();
    DOUBLE  fPointEX     = data.GetPointEX();
    DOUBLE  fPointEY     = data.GetPointEY();
    DOUBLE  fPointEZ     = data.GetPointEZ();
    DOUBLE  fPointAX     = data.GetPointAX();
    DOUBLE  fPointAY     = data.GetPointAY();
    DOUBLE  fPointAZ     = data.GetPointAZ();
    CString szPointDesc  = data.GetPointDesc();

    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("INSERT INTO posture_data_point "
        " ( task_id,     "
        "   equip_code,  "
        "   equip_place, "
        "   point_id,    "
        "   point_title, "
        "   point_code,  "
        "   point_e_x,   "
        "   point_e_y,   "
        "   point_e_z,   "
        "   point_a_x,   "
        "   point_a_y,   "
        "   point_a_z,   "
        "   point_desc)  "
        " VALUES (%d, %Q, %Q, %d, %Q, %Q, %f, %f, %f, %f, %f, %f, %Q);",
            iTaskId, 
            szEquipCode,
            szEquipPlace, 
            iPointId,
            szPointTitle, 
            szPointCode, 
            fPointEX, 
            fPointEY, 
            fPointEZ, 
            fPointAX, 
            fPointAY, 
            fPointAZ, 
            szPointDesc );

        pDB->execDML("begin transaction;");
        pDB->execDML(bufSQL);
        pDB->execDML("commit transaction;");
        bufSQL.clear();

    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
        return FALSE;
    }
    return TRUE;
}

/**************************************************************************************************
函 数 名 :Update
功能描述 :更新
输入参数 :略
输出参数 :无
返 回 值 :TRUE 成功；FALSE 失败
**************************************************************************************************/
BOOL PostureDataPointManager::Update(const PostureDataPoint& data)
{
    DWORD   iTaskId      = data.GetTaskId();
    CString szEquipCode  = data.GetEquipCode();
    CString szEquipPlace = data.GetEquipPlace();
    DWORD   iPointId     = data.GetPointId();
    CString szPointTitle = data.GetPointTitle();
    CString szPointCode  = data.GetPointCode();
    DOUBLE  fPointEX     = data.GetPointEX();
    DOUBLE  fPointEY     = data.GetPointEY();
    DOUBLE  fPointEZ     = data.GetPointEZ();
    DOUBLE  fPointAX     = data.GetPointAX();
    DOUBLE  fPointAY     = data.GetPointAY();
    DOUBLE  fPointAZ     = data.GetPointAZ();
    CString szPointDesc  = data.GetPointDesc();

    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("UPDATE posture_data_point "
        " SET point_title=%Q, "
        "     point_code=%Q,  "
        "     point_e_x=%f,   "
        "     point_e_y=%f,   "
        "     point_e_z=%f,   "
        "     point_a_x=%f,   "
        "     point_a_y=%f,   "
        "     point_a_z=%f,   "
        "     point_desc=%Q   "
        " WHERE task_id=%d AND equip_code=%Q AND equip_place=%Q AND point_id = %d;",
              szPointTitle, 
              szPointCode, 
              fPointEX, 
              fPointEY, 
              fPointEZ, 
              fPointAX, 
              fPointAY, 
              fPointAZ, 
              szPointDesc, 
              iTaskId,
              szEquipCode,
              szEquipPlace,
              iPointId);

        pDB->execDML("begin transaction;");
        int affected = pDB->execDML(bufSQL);
        pDB->execDML("commit transaction;");

        bufSQL.clear();

    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
        return FALSE;
    }
    return TRUE;
}

/**************************************************************************************************
函 数 名 :Delete
功能描述 :删除
输入参数 :主键
输出参数 :无
返 回 值 :TRUE 成功；FALSE 失败
**************************************************************************************************/
BOOL PostureDataPointManager::Delete(DWORD iTaskId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM posture_data_point WHERE task_id = %d;", iTaskId);

        pDB->execDML("begin transaction;");
        pDB->execDML(bufSQL);
        pDB->execDML("commit transaction;");

        bufSQL.clear();
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
        return FALSE;
    }
    return TRUE;
}

BOOL PostureDataPointManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM posture_data_point WHERE task_id = %d AND equip_code=%Q;", iTaskId, szEquipCode);

        pDB->execDML("begin transaction;");
        pDB->execDML(bufSQL);
        pDB->execDML("commit transaction;");

        bufSQL.clear();
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
        return FALSE;
    }
    return TRUE;
}

BOOL PostureDataPointManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode, LPCTSTR szEquipPlace)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM posture_data_point WHERE task_id = %d AND equip_code=%Q AND equip_place=%Q;", iTaskId, szEquipCode, szEquipPlace);

        pDB->execDML("begin transaction;");
        pDB->execDML(bufSQL);
        pDB->execDML("commit transaction;");

        bufSQL.clear();
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
        return FALSE;
    }
    return TRUE;
}

BOOL PostureDataPointManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode, LPCTSTR szEquipPlace, DWORD iPointId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM posture_data_point WHERE task_id = %d AND equip_code=%Q AND equip_place=%Q AND point_id=%d;", iTaskId, szEquipCode, szEquipPlace, iPointId);

        pDB->execDML("begin transaction;");
        pDB->execDML(bufSQL);
        pDB->execDML("commit transaction;");

        bufSQL.clear();
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
        return FALSE;
    }
    return TRUE;
}

/**************************************************************************************************
函 数 名 :ClearAll
功能描述 :清除数据
输入参数 :略
输出参数 :略
返 回 值 :TRUE 成功；FALSE 失败
**************************************************************************************************/
BOOL PostureDataPointManager::ClearAll()
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM posture_data_point;");//删除语句

        pDB->execDML("begin transaction;");
        pDB->execDML(bufSQL);
        pDB->execDML("commit transaction;");

        bufSQL.clear();
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
        return FALSE;
    }
    return TRUE;
}

/**************************************************************************************************
函 数 名 :Count
功能描述 :根据条件查询记录数目
输入参数 :略
输出参数 :略
返 回 值 :TRUE 成功；FALSE 失败
**************************************************************************************************/
int PostureDataPointManager::Count(DWORD iTaskId)
{
	int iCount = 0;

	try
	{
		CppSQLite3DB* pDB = DBFactory::GetSQLite();
		char szCmd[256];
		sprintf_s(szCmd, "SELECT COUNT(*) AS NUM FROM posture_data_point WHERE task_id = %d;", iTaskId);
		CppSQLite3Query q = pDB->execQuery(szCmd);
		iCount = q.getIntField("NUM");
		q.finalize();
	}
	catch (CppSQLite3Exception& e)
	{
		LOG::E(e.errorMessage());
		iCount = 0;
	}

	return iCount;
}

int PostureDataPointManager::CountOfReport(DWORD iTaskId)
{

	CString szPoints = AppConfig::GetString(_T("Report"), _T("Dynamic_Points"));
	CStringArray arrPoints;
	Utils::StrSplit(szPoints, ",", arrPoints);

	int iNum = (int)arrPoints.GetCount();
	CString szCond;
	for (int i = 0; i < iNum; i++) {
		if (i > 0) szCond.Append(",");
		szCond.Append("'");
		szCond.Append(arrPoints[i]);
		szCond.Append("'");
	}

	int iCount = 0;
	try
	{
		CppSQLite3DB* pDB = DBFactory::GetSQLite();
		char szCmd[256];
		if (iNum > 0) {
			sprintf_s(szCmd, "SELECT COUNT(*) AS NUM FROM posture_data_point WHERE task_id = %d AND point_code in (%s);", iTaskId, szCond.GetBuffer());
		}
		else {
			sprintf_s(szCmd, "SELECT COUNT(*) AS NUM FROM posture_data_point WHERE task_id = %d;", iTaskId);
		}
		
		CppSQLite3Query q = pDB->execQuery(szCmd);
		iCount = q.getIntField("NUM");
		q.finalize();
	}
	catch (CppSQLite3Exception& e)
	{
		LOG::E(e.errorMessage());
		iCount = 0;
	}

	return iCount;
}