#include "HGPdtToolDb.h"
#include "HGPdtToolDbImpl.hpp"
#include "base/HGInc.h"

HGResult HGAPI HGPdtToolDb_CreateUserMgr(const HGChar* host, HGUShort port, const HGChar* userName,
	const HGChar* pwd, HGPdtToolDbUserMgr* userMgr)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = new HGPdtToolDbUserMgrImpl;
	HGResult ret = userMgrImpl->Create(host, port, userName, pwd);
	if (HGBASE_ERR_OK != ret)
	{
		delete userMgrImpl;
		return ret;
	}

	*userMgr = (HGPdtToolDbUserMgr)userMgrImpl;
	return HGBASE_ERR_OK;
}

HGResult HGAPI HGPdtToolDb_DestroyUserMgr(HGPdtToolDbUserMgr userMgr)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	HGResult ret = userMgrImpl->Destroy();
	if (HGBASE_ERR_OK != ret)
	{
		return ret;
	}

	delete userMgrImpl;
	return HGBASE_ERR_OK;
}

HGResult HGAPI HGPdtToolDb_GetUserStatus(HGPdtToolDbUserMgr userMgr, HGUInt* userStatus)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->GetUserStatus(userStatus);
}

HGResult HGAPI HGPdtToolDb_GetUserType(HGPdtToolDbUserMgr userMgr, HGUInt* userType)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->GetUserType(userType);
}

HGResult HGAPI HGPdtToolDb_GetUserName(HGPdtToolDbUserMgr userMgr, HGChar* userName, HGUInt maxLen)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->GetUserName(userName, maxLen);
}

HGResult HGAPI HGPdtToolDb_RefuseUser(HGPdtToolDbUserMgr userMgr, HGChar* userName)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->RefuseUser(userName);
}

HGResult HGAPI HGPdtToolDb_GetUserList(HGPdtToolDbUserMgr userMgr, HGChar** userNameList, HGUInt maxLen, HGUInt* count)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->GetUserList(userNameList, maxLen, count);
}

HGResult HGAPI HGPdtToolDb_ReleaseUserList(HGChar** userNameList, HGUInt count)
{
	return HGPdtToolDbUserMgrImpl::ReleaseUserList(userNameList, count);
}

HGResult HGAPI HGPdtToolDb_CreateUser(HGPdtToolDbUserMgr userMgr, const HGChar* userName, const HGChar* defPwd)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->CreateUser(userName, defPwd);
}

HGResult HGAPI HGPdtToolDb_DestroyUser(HGPdtToolDbUserMgr userMgr, const HGChar* userName)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->DestroyUser(userName);
}

HGResult HGAPI HGPdtToolDb_SetPassword(HGPdtToolDbUserMgr userMgr, const HGChar* userName, const HGChar* pwd)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->SetPassword(userName, pwd);
}

HGResult HGAPI HGPdtToolDb_ModifyPassword(HGPdtToolDbUserMgr userMgr, const HGChar* oldPwd, const HGChar* newPwd)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->ModifyPassword(oldPwd, newPwd);
}

HGResult HGAPI HGPdtToolDb_UploadFile(HGPdtToolDbUserMgr userMgr, const HGChar* tag, const HGChar* fileName)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->UploadFile(tag, fileName);
}

HGResult HGAPI HGPdtToolDb_DownloadFile(HGPdtToolDbUserMgr userMgr, const HGChar* tag, const HGChar* fileName)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->DownloadFile(tag, fileName);
}

HGResult HGAPI HGPdtToolDb_Export(HGPdtToolDbUserMgr userMgr, const HGChar* xlsPath)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->Export(xlsPath);
}

HGResult HGAPI HGPdtToolDb_GetUserConfig(HGPdtToolDbUserMgr userMgr, const HGChar* key, HGChar* value, HGUInt maxLen)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->GetConfig(key, value, maxLen);
}

HGResult HGAPI HGPdtToolDb_SetUserConfig(HGPdtToolDbUserMgr userMgr, const HGChar* key, const HGChar* value)
{
	if (NULL == userMgr)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	return userMgrImpl->SetConfig(key, value);
}

HGResult HGAPI HGPdtToolDb_OpenDevice(HGPdtToolDbUserMgr userMgr, const HGChar* sn, HGPdtToolDbDevice* device)
{
	if (NULL == userMgr || NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbUserMgrImpl* userMgrImpl = (HGPdtToolDbUserMgrImpl*)userMgr;
	HGPdtToolDbDeviceImpl* deviceImpl = NULL;
	HGResult ret = userMgrImpl->OpenDevice(sn, &deviceImpl);
	if (HGBASE_ERR_OK != ret)
	{
		return ret;
	}

	*device = (HGPdtToolDbDevice)deviceImpl;
	return HGBASE_ERR_OK;
}

HGResult HGAPI HGPdtToolDb_CloseDevice(HGPdtToolDbDevice device)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	delete deviceImpl;
	return HGBASE_ERR_OK;
}

HGResult HGAPI HGPdtToolDb_GetDeviceName(HGPdtToolDbDevice device, HGChar* name, HGUInt maxLen)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->GetName(name, maxLen);
}

HGResult HGAPI HGPdtToolDb_SetDeviceName(HGPdtToolDbDevice device, const HGChar* name)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->SetName(name);
}

HGResult HGAPI HGPdtToolDb_GetDeviceType(HGPdtToolDbDevice device, HGChar* type, HGUInt maxLen)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->GetType(type, maxLen);
}

HGResult HGAPI HGPdtToolDb_SetDeviceType(HGPdtToolDbDevice device, const HGChar* type)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->SetType(type);
}

HGResult HGAPI HGPdtToolDb_GetDeviceVersion(HGPdtToolDbDevice device, HGChar* version, HGUInt maxLen)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->GetVersion(version, maxLen);
}

HGResult HGAPI HGPdtToolDb_SetDeviceVersion(HGPdtToolDbDevice device, const HGChar* version)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->SetVersion(version);
}

HGResult HGAPI HGPdtToolDb_GetDeviceCurrEntry(HGPdtToolDbDevice device, HGUInt* entryName)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->GetCurrEntry(entryName);
}

HGResult HGAPI HGPdtToolDb_SetDeviceCurrEntry(HGPdtToolDbDevice device, HGUInt entryName)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->SetCurrEntry(entryName);
}

HGResult HGAPI HGPdtToolDb_GetDeviceEntryStatus(HGPdtToolDbDevice device, HGUInt entryName, HGUInt* entryStatus)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->GetEntryStatus(entryName, entryStatus);
}

HGResult HGAPI HGPdtToolDb_GetDeviceEntryExcepDesc(HGPdtToolDbDevice device, HGUInt entryName, HGChar* excepDesc, HGUInt maxLen)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->GetEntryExcepDesc(entryName, excepDesc, maxLen);
}

HGResult HGAPI HGPdtToolDb_SetDeviceEntryStatus(HGPdtToolDbDevice device, HGUInt entryName, HGUInt entryStatus)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->SetEntryStatus(entryName, entryStatus);
}

HGResult HGAPI HGPdtToolDb_SetDeviceEntryExcepDesc(HGPdtToolDbDevice device, HGUInt entryName, const HGChar* excepDesc)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->SetEntryExcepDesc(entryName, excepDesc);
}

HGResult HGAPI HGPdtToolDb_DownloadDeviceEntryImage(HGPdtToolDbDevice device, HGUInt entryName,
	const HGChar* ftpHost, HGUShort ftpPort, const HGChar* fileName)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->DownloadEntryImage(entryName, ftpHost, ftpPort, fileName);
}

HGResult HGAPI HGPdtToolDb_CheckDeviceEntryImage(HGPdtToolDbDevice device, HGUInt entryName)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->CheckEntryImage(entryName);
}

HGResult HGAPI HGPdtToolDb_UploadDeviceEntryImage(HGPdtToolDbDevice device, HGUInt entryName,
	const HGChar* ftpHost, HGUShort ftpPort, const HGChar* fileName)
{
	if (NULL == device)
	{
		return HGBASE_ERR_INVALIDARG;
	}

	HGPdtToolDbDeviceImpl* deviceImpl = (HGPdtToolDbDeviceImpl*)device;
	return deviceImpl->UploadEntryImage(entryName, ftpHost, ftpPort, fileName);
}