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

**************************************************************************************************/
#include "pch.h"
#include "EquipDataPlaneManager.h"
#include "CppSQLite3.h"
#include "DBFactory.h"
#include "EquipDataPlane.h"

EquipDataPlaneManager::EquipDataPlaneManager()
{

}

EquipDataPlaneManager::~EquipDataPlaneManager()
{

}

/**************************************************************************************************
函 数 名 :QueryAll
功能描述 :查询
输出参数 :略
返 回 值 :CppSQLite3Query
**************************************************************************************************/
CppSQLite3Query EquipDataPlaneManager::Query()
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        return pDB->execQuery(_T("SELECT * FROM equip_data_plane;"));
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
    }
}

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

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

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

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

/**************************************************************************************************
函 数 名 :Add
功能描述 :增加
输入参数 :略
输出参数 :略
返 回 值 :TRUE 成功；FALSE 失败
**************************************************************************************************/
BOOL EquipDataPlaneManager::Add(const EquipDataPlane& data)
{
	DWORD   iTaskId        = data.GetTaskId();
    CString szEquipCode    = data.GetEquipCode();
    DWORD   iItemId        = data.GetItemId();
    DWORD   iSubItemId     = data.GetSubItemId();
    CString szPlaneTitle   = data.GetPlaneTitle();
    CString szPlaneCode    = data.GetPlaneCode();
    DOUBLE  fPlaneA        = data.GetPlaneA();
    DOUBLE  fPlaneB        = data.GetPlaneB();
    DOUBLE  fPlaneC        = data.GetPlaneC();
    DOUBLE  fPlaneD        = data.GetPlaneD();
    DOUBLE  fPlaneRMS      = data.GetPlaneRMS();
	DOUBLE  fPlaneFlatness = data.GetPlaneFlatness();
    CString szPlaneDesc    = data.GetPlaneDesc();

    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("INSERT INTO equip_data_plane ("
			            " task_id,      "
                        " equip_code,   "
                        " item_id,      "
                        " subitem_id,   "
                        " plane_title,  "
                        " plane_code,   "
                        " plane_a,      "
                        " plane_b,      "
                        " plane_c,      "
                        " plane_d,      "
                        " plane_rms,    "
			            " plane_flatness, "
                        " plane_desc  ) "
                " VALUES (%d, %Q, %d, %d, %Q, %Q, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %Q); ",
			            iTaskId,
                        szEquipCode,
                        iItemId,
                        iSubItemId,
                        szPlaneTitle,
                        szPlaneCode,
                        fPlaneA,
                        fPlaneB,
                        fPlaneC,
                        fPlaneD,
                        fPlaneRMS,
			            fPlaneFlatness,
                        szPlaneDesc );

        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 EquipDataPlaneManager::Update(const EquipDataPlane& data)
{
	DWORD   iTaskId        = data.GetTaskId();
    CString szEquipCode    = data.GetEquipCode();
    DWORD   iItemId        = data.GetItemId();
    DWORD   iSubItemId     = data.GetSubItemId();
    CString szPlaneTitle   = data.GetPlaneTitle();
    CString szPlaneCode    = data.GetPlaneCode();
    DOUBLE  fPlaneA        = data.GetPlaneA();
    DOUBLE  fPlaneB        = data.GetPlaneB();
    DOUBLE  fPlaneC        = data.GetPlaneC();
    DOUBLE  fPlaneD        = data.GetPlaneD();
    DOUBLE  fPlaneRMS      = data.GetPlaneRMS();
	DOUBLE  fPlaneFlatness = data.GetPlaneFlatness();
    CString  szPlaneDesc   = data.GetPlaneDesc();
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("UPDATE equip_data_plane "
                      "SET plane_title= %Q, "
                      "    plane_code = %Q, "
                      "    plane_a    = %.3f, "
                      "    plane_b    = %.3f, "
                      "    plane_c    = %.3f, "
                      "    plane_d    = %.3f, "
                      "    plane_rms  = %.3f, "
			          "    plane_flatness = %.3f, "
                      "    plane_desc = %Q  "
                      " WHERE task_id=%d AND equip_code=%Q AND item_id=%d AND subitem_id = %d;",
                        szPlaneTitle, 
                        szPlaneCode, 
                        fPlaneA, 
                        fPlaneB, 
                        fPlaneC, 
                        fPlaneD, 
                        fPlaneRMS, 
			            fPlaneFlatness,
                        szPlaneDesc, 
			            iTaskId,
                        szEquipCode,
                        iItemId,
                        iSubItemId);

        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;
}

/**************************************************************************************************
函 数 名 :Update
功能描述 :更新
输入参数 :略
输出参数 :略
返 回 值 :TRUE 成功；FALSE 失败
**************************************************************************************************/
BOOL EquipDataPlaneManager::UpdateTitle(DWORD iTaskId, LPCTSTR szEquipCode, DWORD iItemId, DWORD iSubitemId, LPCTSTR szCircleTitle)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("UPDATE equip_data_plane SET plane_title = %Q WHERE task_id=%d AND equip_code=%Q AND item_id=%d AND subitem_id=%d;",
            szCircleTitle, iTaskId, szEquipCode, iItemId, iSubitemId);

        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 EquipDataPlaneManager::Delete(DWORD iTaskId)
{
	try
	{
		CppSQLite3DB* pDB = DBFactory::GetSQLite();
		CppSQLite3Buffer bufSQL;
		bufSQL.format("DELETE FROM equip_data_plane 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 EquipDataPlaneManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM equip_data_plane 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 EquipDataPlaneManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode, DWORD iItemId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM equip_data_plane WHERE task_id=%d AND equip_code=%Q AND item_id=%d;", iTaskId, szEquipCode, iItemId);

        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 EquipDataPlaneManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode, DWORD iItemId, DWORD iSubitemId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM equip_data_plane WHERE task_id=%d AND equip_code=%Q AND item_id=%d AND subitem_id = %d;", iTaskId, szEquipCode, iItemId, iSubitemId);

        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 EquipDataPlaneManager::ClearAll()
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM equip_data_plane");//删除语句

        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 EquipDataPlaneManager::Count(DWORD iTaskId)
{
	int iCount = 0;

	try
	{
		CppSQLite3DB* pDB = DBFactory::GetSQLite();
		char szCmd[256];
		sprintf_s(szCmd, "SELECT COUNT(*) AS NUM FROM equip_data_plane 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;
}