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

**************************************************************************************************/
#include "pch.h"
#include "PostureDataAngleManager.h"
#include "CppSQLite3.h"
#include "DBFactory.h"
#include "PostureDataAngle.h"

PostureDataAngleManager::PostureDataAngleManager()
{

}

PostureDataAngleManager::~PostureDataAngleManager()
{

}

/**************************************************************************************************
函 数 名 :Query
功能描述 :查询
输出参数 :略
返 回 值 :CppSQLite3Query
**************************************************************************************************/
CppSQLite3Query PostureDataAngleManager::Query(DWORD iTaskId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        char szCmd[256];
        sprintf_s(szCmd, "SELECT * FROM posture_data_angle WHERE task_id=%d;", iTaskId);
        return pDB->execQuery(szCmd);
    }
    catch (CppSQLite3Exception& e)
    {
        LOG::E(e.errorMessage());
    }
}

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

CppSQLite3Query PostureDataAngleManager::Query(DWORD iTaskId, LPCTSTR szEquipCode, LPCTSTR szEquipPlace)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        char szCmd[256];
        sprintf_s(szCmd, "SELECT * FROM posture_data_angle 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 PostureDataAngleManager::Query(DWORD iTaskId, LPCTSTR szEquipCode, LPCTSTR szEquipPlace, DWORD iAngleId)
{
    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();
        char szCmd[256];
        sprintf_s(szCmd, "SELECT * FROM posture_data_angle 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());
    }
}

/**************************************************************************************************
函 数 名 :Add
功能描述 :增加TaskData
输入参数 :点云数据
输出参数 :无
返 回 值 :TRUE 成功；FALSE 失败
**************************************************************************************************/
BOOL PostureDataAngleManager::Add(const PostureDataAngle& data)
{
    DWORD   iTaskId           = data.GetTaskId();
    CString szEquipCode       = data.GetEquipCode();
    CString szEquipPlace      = data.GetEquipPlace();
    DWORD   iLineId           = data.GetLineId();
    CString szLineTitle       = data.GetLineTitle();
    CString szLineCode        = data.GetLineCode();
    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  fAngleEX          = data.GetAngleEX();
    DOUBLE  fAngleEY          = data.GetAngleEY();
    DOUBLE  fAngleEZ          = data.GetAngleEZ();
    DOUBLE  fAngleAX          = data.GetAngleAX();
    DOUBLE  fAngleAY          = data.GetAngleAY();
    DOUBLE  fAngleAZ          = data.GetAngleAZ();
    CString szLineDesc        = data.GetLineDesc();

    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();

        CppSQLite3Buffer bufSQL;
        bufSQL.format("INSERT INTO posture_data_angle"
        " ( task_id,      "
        "   equip_code,   "
        "   equip_place,  "
        "   line_id,      "
        "   line_title,   "
        "   line_code,    "
        "   line_start_x, "
        "   line_start_y, "
        "   line_start_z, " 
        "   line_end_x,   "
        "   line_end_y,   "
        "   line_end_z,   "
        "   angle_e_x,    "
        "   angle_e_y,    "
        "   angle_e_z,    "
        "   angle_a_x,    "
        "   angle_a_y,    "
        "   angle_a_z,    "
        "   line_desc)   "
        " VALUES (%d, %Q, %Q, %d, %Q, %Q, %.3f, %.3f, %.3f,  %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %.3f, %Q);",
            iTaskId, 
            szEquipCode,
            szEquipPlace, 
            iLineId,
            szLineTitle, 
            szLineCode, 
            fLineStartX, 
            fLineStartY, 
            fLineStartZ,
            fLineEndX, 
            fLineEndY, 
            fLineEndZ,
            fAngleEX, 
            fAngleEY, 
            fAngleEZ,
            fAngleAX, 
            fAngleAY, 
            fAngleAZ, 
            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 PostureDataAngleManager::Update(const PostureDataAngle& data)
{
    DWORD   iTaskId         = data.GetTaskId();
    CString szEquipCode     = data.GetEquipCode();
    CString szEquipPlace    = data.GetEquipPlace();
    DWORD   iLineId         = data.GetLineId();
    CString szLineTitle     = data.GetLineTitle();
    CString szLineCode      = data.GetLineCode();
    DOUBLE  fAngelAX        = data.GetAngleAX();
    DOUBLE  fAngelAY        = data.GetAngleAY();
    DOUBLE  fAngelAZ        = data.GetAngleAZ();
    DOUBLE  fAngelEX        = data.GetAngleEX();
    DOUBLE  fAngelEY        = data.GetAngleEY();
    DOUBLE  fAngelEZ        = data.GetAngleEZ();
    CString szLineDesc      = data.GetLineDesc();

    try
    {
        CppSQLite3DB* pDB = DBFactory::GetSQLite();

        CppSQLite3Buffer bufSQL;
        bufSQL.format("UPDATE posture_data_angle "
        " SET line_title=%Q,    "
        "     line_code=%Q,     "
        "     angle_a_x=%.3f,     "
        "     angle_a_y=%.3f,     "
        "     angle_a_z=%.3f,     "
        "     line_desc=%Q      "
        " WHERE equip_code=%Q AND equip_place=%Q AND line_id = %d;  ",
            szLineTitle, 
            szLineCode, 
            fAngelAX, 
            fAngelAY, 
            fAngelAZ, 
            szLineDesc, 
            szEquipCode,
            szEquipPlace,
            iLineId);

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

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

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

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