readdb.cpp

sms sender 察到布局图全貌

				return FALSE;
			}
		}
		if(m_opmuset->IsBOF())
		{
			szopmu=_T("");
			return FALSE;
		}
		if(!m_opmuset->IsEOF())
		{
			m_opmuset->MoveFirst();
			szStationID=m_opmuset->m_station_id;
    		szStationID.TrimLeft();
	    	szStationID.TrimRight();
		}
		//读取数据
		while(!m_opmuset->IsEOF())
		{
			if(szRTU.IsEmpty())
			{
			   szRTU.Format("%s",m_opmuset->m_station_id);
			   szRTU.TrimLeft();
			   szRTU.TrimRight();
			}

			szRTUTmp.Format("%s",m_opmuset->m_station_id);
			szRTUTmp.TrimLeft();
			szRTUTmp.TrimRight();
			if(szRTUTmp==szRTU)
			{
				szTmp.Empty();
				szTmp.Format("(%d;%d)",
					m_opmuset->m_alarm_no,m_opmuset->m_status);
                szResult+=szTmp;
			}				
 	    	m_opmuset->MoveNext();
		}
		m_opmuset->Close();
	}
	catch(CDBException* peDB)
	{
#ifdef MY_DEBUG_MSG
		AfxMessageBox(peDB->m_strError);
#endif
		peDB->Delete();
		szopmu=_T("");
		return FALSE;
	}
	if(szResult.IsEmpty())
		return FALSE;
	if(nSMCodingType==0)//0-英文
		szopmu.Format("OPMU:Warning:(station:%s);(optic_road_no;grade)",szRTU);
	else//1-中文
	{
		CString szaName,szbName,szMoniUnitID;
        GetMoniUnitIDByStationID(szRTU,szMoniUnitID,szaName);
        szopmu.Format("光功率告警:(站:%s);(光路号;等级)",szRTU);
	}

	szopmu+=szResult;
	szopmu.Remove(' ');

	return TRUE;
}


BOOL CReadDB::GetSmsSettingMsg(CString &szSMCIAC, CString &szSMCCode, CString &szMTIAC, CString &szMTCode)
{
	szSMCIAC=_T("");
	szSMCCode=_T("");
	szMTIAC=_T("");
	szMTCode=_T("");
	//连接资料库
	try
	{
//		m_warnset->m_strSort="beg_t desc";
		if(!m_smssetting->IsOpen())
		{
			if(m_smssetting->Open ()==0)
			{
#ifdef MY_DEBUG_MSG
			//	AfxMessageBox("资料库连接失败!");
				CString idgetstr;
	     		idgetstr.LoadString(IDS_DBCONNECT_ERROR);
		    	AfxMessageBox(idgetstr);
#else
#ifdef _DEBUG
	            TRACE("资料库连接失败!");
#endif
#endif
				return FALSE;
			}
		}
		if(m_smssetting->IsBOF())
			return FALSE;
		if(!m_smssetting->IsEOF())
			m_smssetting->MoveFirst();
		//读取数据
		szSMCIAC=m_smssetting->m_smc_iac;
		szSMCCode=m_smssetting->m_smc_servecode;
		szMTIAC=m_smssetting->m_mt_iac;
		szMTCode=m_smssetting->m_manual_mtcode;

		szSMCIAC.Remove(' ');
		szSMCCode.Remove(' ');
		szMTIAC.Remove(' ');
		szMTCode.Remove(' ');

		m_smssetting->Close();
	}
	catch(CDBException* peDB)
	{
#ifdef MY_DEBUG_MSG
		AfxMessageBox(peDB->m_strError);
#endif
		peDB->Delete();
		return FALSE;
	}
	return TRUE;
}

BOOL CReadDB::GetSmsSettingMsg(CString szMoniUnitID,CString &szSMCIAC,CString &szSMCCode,CString &szMTIAC,CString &szMTCode)
{
	szSMCIAC=_T("");
	szSMCCode=_T("");
	szMTIAC=_T("");
	szMTCode=_T("");
//连接资料库
	try
	{
        szMoniUnitID.TrimLeft();
		szMoniUnitID.TrimRight();
		CString tt;
		tt=_T("unit_id='")+szMoniUnitID+_T("'");
		m_smssetting->m_strFilter =tt;
		if(!m_smssetting->IsOpen())
		{
			if(m_smssetting->Open ()==0)
			{
#ifdef MY_DEBUG_MSG
			//	AfxMessageBox("资料库连接失败!");
				CString idgetstr;
	     		idgetstr.LoadString(IDS_DBCONNECT_ERROR);
		    	AfxMessageBox(idgetstr);
#else
#ifdef _DEBUG
	            TRACE("资料库连接失败!");
#endif
#endif
				return FALSE;
			}
		}
		if(m_smssetting->IsBOF())
			return FALSE;
		if(!m_smssetting->IsEOF())
			m_smssetting->MoveFirst();
		//读取数据
		szSMCIAC=m_smssetting->m_smc_iac;
		szSMCCode=m_smssetting->m_smc_servecode;
		szMTIAC=m_smssetting->m_mt_iac;
		szMTCode=m_smssetting->m_manual_mtcode;

		szSMCIAC.Remove(' ');
		szSMCCode.Remove(' ');
		szMTIAC.Remove(' ');
		szMTCode.Remove(' ');

		m_smssetting->Close();
	}
	catch(CDBException* peDB)
	{
#ifdef MY_DEBUG_MSG
		AfxMessageBox(peDB->m_strError);
#endif
		peDB->Delete();
		return FALSE;
	}
	return TRUE;
}

BOOL CReadDB::SaveSmsSettingMsgToDB(CString &szUnit_id,CString &szSMCIAC, CString &szSMCCode, CString &szMTIAC, CString &szMTCode)
{
	szUnit_id.Remove(' ');
	szSMCIAC.Remove(' ');
	szSMCCode.Remove(' ');
	szMTIAC.Remove(' ');
	szMTCode.Remove(' ');
	try
	{
		//连接资料库
		CString tt;
		tt=_T("unit_id='")+szUnit_id.Left(10)+_T("'");
		m_smssetting->m_strFilter =tt;
  	  	if(!m_smssetting->IsOpen())
		{
			if(m_smssetting->Open()==0)
			{
#ifdef MY_DEBUG_MSG
				CString idgetstr;
				idgetstr.LoadString(IDS_DBCONNECT_ERROR);
				AfxMessageBox(idgetstr);
#else
#ifdef _DEBUG
	            TRACE("资料库连接失败!");
#endif
#endif
				return FALSE;
			}
		}
		//更新数据
	    if(m_smssetting->IsBOF())
		{
			m_smssetting->AddNew();
		}
		else if(!m_smssetting->IsEOF())
		{
			m_smssetting->MoveFirst();
			while(!m_smssetting->IsEOF())
			{
				m_smssetting->Delete();
				m_smssetting->MoveNext();
			}
            m_smssetting->MoveLast();
			m_smssetting->AddNew();
		}
		//数据赋值
		if(m_smssetting->CanAppend())
		{
			m_smssetting->m_unit_id=szUnit_id.Left(10);
			m_smssetting->m_smc_iac=szSMCIAC.Left(5);
			m_smssetting->m_mt_iac=szMTIAC.Left(5);
			m_smssetting->m_smc_servecode=szSMCCode.Left(20);
			m_smssetting->m_manual_mtcode=szMTCode.Left(15);
		}
		if(m_smssetting->CanUpdate())
			m_smssetting->Update();
		m_smssetting->Close();
	}
	catch(CDBException* peDB)
	{
#ifdef MY_DEBUG_MSG
		AfxMessageBox(peDB->m_strError);
#endif
		peDB->Delete();
		return FALSE;
	}
	return TRUE;
}

BOOL CReadDB::GetMoniUnitIDByStationID(CString szStationID,CString &szMoniUnitID,CString &szStationName)
{
	szMoniUnitID=_T("");
	szStationName=_T("");
	try
	{
		//连接资料库
        szStationID.TrimLeft();
		szStationID.TrimRight();
		CString tt;
		tt=_T("station_id='")+szStationID+_T("'");
		m_stationset->m_strFilter =tt;
  	  	if(!m_stationset->IsOpen())
		{
			if(m_stationset->Open()==0)
			{
#ifdef MY_DEBUG_MSG
				CString idgetstr;
				idgetstr.LoadString(IDS_DBCONNECT_ERROR);
				AfxMessageBox(idgetstr);
#else
#ifdef _DEBUG
	            TRACE("资料库连接失败!");
#endif
#endif
				return FALSE;
			}
		}
		//更新数据
	    if(m_stationset->IsBOF())
			return FALSE;
		if(!m_stationset->IsEOF())
			m_stationset->MoveFirst();
		//数据赋值
        szMoniUnitID=m_stationset->m_super_moniunit_id;
		szStationName=m_stationset->m_station_name;
		m_stationset->Close();
	}
	catch(CDBException* peDB)
	{
#ifdef MY_DEBUG_MSG
		AfxMessageBox(peDB->m_strError);
#endif
		peDB->Delete();
		return FALSE;
	}
	return TRUE;
}

BOOL CReadDB::GetMoniUnitIDByMoniUnitName(CString szMoniUnitName,CString &szMoniUnitID)
{
	szMoniUnitID=_T("");
	try
	{
		//连接资料库
        szMoniUnitName.TrimLeft();
		szMoniUnitName.TrimRight();
		CString tt;
		tt=_T("unit_name='")+szMoniUnitName+_T("'");
		m_moniunitset->m_strFilter =tt;
  	  	if(!m_moniunitset->IsOpen())
		{
			if(m_moniunitset->Open()==0)
			{
#ifdef MY_DEBUG_MSG
				CString idgetstr;
				idgetstr.LoadString(IDS_DBCONNECT_ERROR);
				AfxMessageBox(idgetstr);
#else
#ifdef _DEBUG
	            TRACE("资料库连接失败!");
#endif
#endif
				return FALSE;
			}
		}
		//更新数据
	    if(m_moniunitset->IsBOF())
			return FALSE;
		if(!m_moniunitset->IsEOF())
			m_moniunitset->MoveFirst();
		//数据赋值
        szMoniUnitID=m_moniunitset->m_unit_id;
		m_moniunitset->Close();
	}
	catch(CDBException* peDB)
	{
#ifdef MY_DEBUG_MSG
		AfxMessageBox(peDB->m_strError);
#endif
		peDB->Delete();
		return FALSE;
	}
	return TRUE;
}

BOOL CReadDB::GetMoniUnitNameByMoniUnitID(CString szMoniUnitID,CString &szMoniUnitName)
{
	szMoniUnitName=_T("");
	try
	{
		//连接资料库
        szMoniUnitID.TrimLeft();
		szMoniUnitID.TrimRight();
		CString tt;
		tt=_T("unit_id='")+szMoniUnitID+_T("'");
		m_moniunitset->m_strFilter =tt;
  	  	if(!m_moniunitset->IsOpen())
		{
			if(m_moniunitset->Open()==0)
			{
#ifdef MY_DEBUG_MSG
				CString idgetstr;
				idgetstr.LoadString(IDS_DBCONNECT_ERROR);
				AfxMessageBox(idgetstr);
#else
#ifdef _DEBUG
	            TRACE("资料库连接失败!");
#endif
#endif
				return FALSE;
			}
		}
		//更新数据
	    if(m_moniunitset->IsBOF())
			return FALSE;
		if(!m_moniunitset->IsEOF())
			m_moniunitset->MoveFirst();
		//数据赋值
        szMoniUnitName=m_moniunitset->m_unit_name;
		m_moniunitset->Close();
	}
	catch(CDBException* peDB)
	{
#ifdef MY_DEBUG_MSG
		AfxMessageBox(peDB->m_strError);
#endif
		peDB->Delete();
		return FALSE;
	}
	return TRUE;
}

BOOL CReadDB::GetMoniUnitName(CStringList *szMoniUnitNameList)
{
	try
	{
		if(szMoniUnitNameList==NULL) return FALSE;
	    szMoniUnitNameList->RemoveAll();
		//连接资料库
  	  	if(!m_moniunitset->IsOpen())
		{
			if(m_moniunitset->Open()==0)
			{
#ifdef MY_DEBUG_MSG
				CString idgetstr;
				idgetstr.LoadString(IDS_DBCONNECT_ERROR);
				AfxMessageBox(idgetstr);
#else
#ifdef _DEBUG
	            TRACE("资料库连接失败!");
#endif
#endif
				return FALSE;
			}
		}
		//更新数据
	    if(m_moniunitset->IsBOF())
			return FALSE;
		if(!m_moniunitset->IsEOF())
			m_moniunitset->MoveFirst();
		//数据赋值
		CString szName;
		while(!m_moniunitset->IsEOF())
		{
    		if(szMoniUnitNameList!=NULL)	
			{
				szName=m_moniunitset->m_unit_name;
				szName.TrimLeft();
				szName.TrimRight();
	    		szMoniUnitNameList->AddTail (szName);
    			POSITION pos;
    			pos=szMoniUnitNameList->GetHeadPosition();
    			for(int i=0;i<szMoniUnitNameList->GetCount()-1;i++)
				{
    				if(szMoniUnitNameList->GetAt(pos)==szName)
	    				szMoniUnitNameList->RemoveTail();
	    			szMoniUnitNameList->GetNext(pos);
				}
			}
	    	m_moniunitset->MoveNext();
		}
		m_moniunitset->Close();
	}
	catch(CDBException* peDB)
	{
#ifdef MY_DEBUG_MSG
		AfxMessageBox(peDB->m_strError);
#endif
		peDB->Delete();
		return FALSE;
	}
	return TRUE;
}