querylist.cpp

口通信 VC 完整串口通信程序Vc++源代码 串口通讯 vc++ 源代码 vc 串口通信 串口通信 mfc 通信 发送程序 vc++ 串口 VC 串口通信程序 完整串口通信程序Vc 源代码 VC串口通

// Querylist.cpp : implementation file
//

#include "stdafx.h"
#include "GSMTest.h"
#include "Querylist.h"
#include "winsock.h"
#include <mysql.h>
#include "database.h"
#include "QueryDlg.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

/////////////////////////////////////////////////////////////////////////////
// CQuerylist dialog


CQuerylist::CQuerylist(CWnd* pParent /*=NULL*/)
	: CDialog(CQuerylist::IDD, pParent)
{
	//{{AFX_DATA_INIT(CQuerylist)
		// NOTE: the ClassWizard will add member initialization here
	//}}AFX_DATA_INIT
}


void CQuerylist::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CQuerylist)
	DDX_Control(pDX, IDC_LIST1, m_query);
	//}}AFX_DATA_MAP
}


BEGIN_MESSAGE_MAP(CQuerylist, CDialog)
	//{{AFX_MSG_MAP(CQuerylist)
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CQuerylist message handlers

BOOL CQuerylist::OnInitDialog() 
{
	CDialog::OnInitDialog();
	
	// TODO: Add extra initialization here
		m_query.InsertColumn(0,"ID",LVCFMT_CENTER,30,2);
	m_query.InsertColumn(1,"变压器ID",LVCFMT_CENTER,120,2);	
	m_query.InsertColumn(2,"工作状态",LVCFMT_LEFT,100,2);
	m_query.InsertColumn(3,"地点",LVCFMT_LEFT,300,2);
	m_query.InsertColumn(4,"时间",LVCFMT_LEFT,300,2);
	m_query.SetExtendedStyle(LVS_EX_FULLROWSELECT|LVS_EX_GRIDLINES|LVS_EX_SUBITEMIMAGES);


		ShowWindow(SW_MAXIMIZE);
		showquery();
	return TRUE;  // return TRUE unless you set the focus to a control
	              // EXCEPTION: OCX Property Pages should return FALSE
}

void CQuerylist::showquery()
{
	CDatabase1 database;
	database.ConnectDB();
		//AfxMessageBox("连接服务器成功!");			
		
		CString charset="set names 'gb2312'";//使之正常显示中文,或用set character_set_results=gb2312;
		database.ExecuteSQL(charset,charset.GetLength());//执行语句.
		CString def;
		if(k==1)
        def="TIME like '%年"+year+"月%'";
		if(k==2)
        def="TIME like '%月"+year+"日%'";
		if(k==3)
        def="TIME like '%"+year+"%'";
		if(k==4)
        def="trans_id like '%"+year+"%'";
		if(k==5)
        def="remark like '%"+year+"%'";
		if(k<4)
	{
		Data_Param result;	
		result.tab_name="alarm_log";
		result.select_exp="ALARM_ID,TRANS_ID,CONTENT,place,TIME";
//			def.Format("STAT_TIME like '%+%s+%'",year);
//		def="BINARY STAT_TIME like '%日11%'";


		result.where_def=def.GetBuffer(30);
		
		if(database.SelectRecord(&result))
		{
            int count=(int)database.GetRowNum();
			for(int i=0;i<count;i++)			
			{
				database.SeekData(i);				
				MYSQL_ROW row=database.GetRecord();	
				m_query.InsertItem(i,row[0]);
				m_query.SetItemText(i,1,row[1]);
								m_query.SetItemText(i,2,row[2]);
								m_query.SetItemText(i,3,row[3]);
								m_query.SetItemText(i,4,row[4]);
			}
		}
	}
		//地点和型号查询
		if(k>3)
		{
//			CDatabase1 database;
//	database.ConnectDB();
		//AfxMessageBox("连接服务器成功!");			
		
//		CString charset="set names 'gb2312'";//使之正常显示中文,或用set character_set_results=gb2312;
//		database.ExecuteSQL(charset,charset.GetLength());//执行语句.
		Data_Param result_tel;	
		result_tel.tab_name="trans_info";
		result_tel.select_exp="trans_id";
		result_tel.where_def=def.GetBuffer(30);
		if(database.SelectRecord(&result_tel))
		{
            int count=(int)database.GetRowNum();
			for(int j=0;j<count;j++)			
			{
				database.SeekData(j);				
				MYSQL_ROW row1=database.GetRecord();	

					Data_Param result1;	
		result1.tab_name="alarm_log";
		result1.select_exp="ALARM_ID,TRANS_ID,CONTENT,place,TIME";
        CString def1,def3;
		def3=row1[0];
//		def1=row1[0];
//		def1="trans_id="+def1;
		def1.Format("trans_id='%s'",def3);
		result1.where_def=def1.GetBuffer(30);
		//变压器电话的获取
		CDatabase1 database1;
	    database1.ConnectDB();
		//AfxMessageBox("连接服务器成功!");			
		
		CString charset1="set names 'gb2312'";//使之正常显示中文,或用set character_set_results=gb2312;
		database1.ExecuteSQL(charset1,charset1.GetLength());//执行语句.
		if(database1.SelectRecord(&result1))
		{ 
			int count1=(int)database1.GetRowNum();
				for(int i=0;i<count1;i++)			
			{
			database1.SeekData(i);
			MYSQL_ROW row=database1.GetRecord();	
				m_query.InsertItem(i,row[0]);
								m_query.SetItemText(i,1,row[1]);
								m_query.SetItemText(i,2,row[2]);
								m_query.SetItemText(i,3,row[3]);
								m_query.SetItemText(i,4,row[4]);
				}

		}
			}
		}






		}
}