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

**************************************************************************************************/
#include "pch.h"
#include "EquipDataLineManager.h"
#include "CppSQLite3.h"
#include "DBFactory.h"
#include "EquipDataLine.h"

EquipDataLineManager::EquipDataLineManager()
{

}

EquipDataLineManager::~EquipDataLineManager()
{

}

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

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

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

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

CppSQLite3Query EquipDataLineManager::Query(DWORD iTaskId, LPCTSTR szEquipCode, DWORD iItemId, DWORD iSubitemId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        char szCmd[256];
        sprintf_s(szCmd, "SELECT * FROM equip_data_line 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 EquipDataLineManager::Add(const EquipDataLine& data)
{
	DWORD    iTaskId       = data.GetTaskId(); 
    LPCTSTR  szEquipCode   = data.GetEquipCode();
    DWORD    iItemId       = data.GetItemId();
    DWORD    iSubItemId    = data.GetSubItemId();
    LPCTSTR  szLineTitle   = data.GetLineTitle();
    LPCTSTR  szLineCode    = data.GetLineCode();
    DOUBLE   fLineVectorX  = data.GetLineVectorX();
    DOUBLE   fLineVectorY  = data.GetLineVectorY();
    DOUBLE   fLineVectorZ  = data.GetLineVectorZ();
    DOUBLE   fLineStartX   = data.GetLineStartX();
    DOUBLE   fLineStartY   = data.GetLineStartY();
    DOUBLE   fLineStartZ   = data.GetLineStartZ();
    DOUBLE   fLineEndX     = data.GetLineEndX();
    DOUBLE   fLineEndY     = data.GetLineEndY();
    DOUBLE   fLineEndZ     = data.GetLineEndZ();
    DOUBLE   fLineLength   = data.GetLineLength();
    LPCSTR  szLineDesc     = data.GetLineDesc();

    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("INSERT INTO equip_data_line ( "
			                    "  task_id,      "
                                "  equip_code,   "
                                "  item_id,      "
                                "  subitem_id,   "
                                "  line_title,   "
                                "  line_code,    "
                                "  line_vec_x,   "
                                "  line_vec_y,   "
                                "  line_vec_z,   "
                                "  line_start_x, "
                                "  line_start_y, "
                                "  line_start_z, "
                                "  line_end_x,   "
                                "  line_end_y,   "
                                "  line_end_z,   "
                                "  line_length,  "
                                "  line_desc   ) "
                                " VALUES (%d, %Q, %d, %d, %Q, %Q, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %Q); ",
                                   iTaskId,
			                       szEquipCode,
                                   iItemId,
                                   iSubItemId,
                                   szLineTitle,
                                   szLineCode,
                                   fLineVectorX,
                                   fLineVectorY,
                                   fLineVectorZ,
                                   fLineStartX,
                                   fLineStartY,
                                   fLineStartZ,
                                   fLineEndX,
                                   fLineEndY,
                                   fLineEndZ,
                                   fLineLength,
                                   szLineDesc );

        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 EquipDataLineManager::Update(const EquipDataLine& data)
{
	DWORD    iTaskId = data.GetTaskId();
    LPCTSTR  szEquipCode   = data.GetEquipCode();
    DWORD    iItemId        = data.GetItemId();
    DWORD    iSubItemId     = data.GetSubItemId();
    LPCTSTR  szLineTitle   = data.GetLineTitle();
    LPCTSTR  szLineCode    = data.GetLineCode();
    DOUBLE   fLineVectorX  = data.GetLineVectorX();
    DOUBLE   fLineVectorY  = data.GetLineVectorY();
    DOUBLE   fLineVectorZ  = data.GetLineVectorZ();
    DOUBLE   fLineStartX   = data.GetLineStartX();
    DOUBLE   fLineStartY   = data.GetLineStartY();
    DOUBLE   fLineStartZ   = data.GetLineStartZ();
    DOUBLE   fLineEndX     = data.GetLineEndX();
    DOUBLE   fLineEndY     = data.GetLineEndY();
    DOUBLE   fLineEndZ     = data.GetLineEndZ();
    DOUBLE   fLineLength   = data.GetLineLength();
    LPCSTR  szLineDesc     = data.GetLineDesc();

    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("UPDATE equip_data_line    "
                      "SET line_title    = %Q,   "
                        "  line_code     = %Q,   "
                        "  line_vec_x    = %.3f, "
                        "  line_vec_y    = %.3f, "
                        "  line_vec_z    = %.3f, "
                        "  line_start_x  = %.3f, "
                        "  line_start_y  = %.3f, "
                        "  line_start_z  = %.3f, "
                        "  line_end_x    = %.3f, "
                        "  line_end_y    = %.3f, "
                        "  line_end_z    = %.3f, "
                        "  line_length   = %.3f, "
                        "  line_desc     = %Q    "
                    " WHERE task_id=%d AND equip_code=%Q AND item_id=%d AND subitem_id=%d; ",
                        szLineTitle, 
                        szLineCode, 
                        fLineVectorX, 
                        fLineVectorY, 
                        fLineVectorZ, 
                        fLineStartX,
                        fLineStartY,
                        fLineStartZ,
                        fLineEndX,
                        fLineEndY,
                        fLineEndZ,
                        fLineLength,
                        szLineDesc,
			            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 EquipDataLineManager::UpdateTitle(DWORD iTaskId, LPCTSTR szEquipCode, DWORD iItemId, DWORD iSubitemId, LPCTSTR szLineTitle)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("UPDATE equip_data_line SET line_title = %Q WHERE task_id=%d AND equip_code=%Q AND item_id=%d AND subitem_id=%d;",
            szLineTitle, 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 EquipDataLineManager::Delete(DWORD iTaskId)
{
	try
	{
		CppSQLite3DB* pDB = DBFactory::GetSQLite();
		CppSQLite3Buffer bufSQL;
		bufSQL.format("DELETE FROM equip_data_line 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 EquipDataLineManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM equip_data_line 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 EquipDataLineManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode, DWORD iItemId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM equip_data_line 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 EquipDataLineManager::Delete(DWORD iTaskId, LPCTSTR szEquipCode, DWORD iItemId, DWORD iSubitemId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM equip_data_line 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 EquipDataLineManager::ClearAll()
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        CppSQLite3Buffer bufSQL;
        bufSQL.format("DELETE FROM equip_data_line");//删除语句

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

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