天气预报采集系统dlg.cpp

利用Boost库的正则表达式从中国气象网取天气预报,并将其写入Oracle数据库

// 天气预报采集系统Dlg.cpp : 实现文件
//

#include "stdafx.h"
#include "天气预报采集系统.h"
#include "天气预报采集系统Dlg.h"
#include "AHttpForCE.h"
#include "CharConvert.h"
#include "URLEncode.h"
#include "ParseHTML.h"
#include "public.h"
#include <list>

extern std::list<CCity >g_list_city;
extern CRITICAL_SECTION g_section_list_city_weather;
#ifdef _DEBUG
#define new DEBUG_NEW
#endif


// 用于应用程序“关于”菜单项的 CAboutDlg 对话框

class CAboutDlg : public CDialog
{
public:
	CAboutDlg();

	// 对话框数据
	enum { IDD = IDD_ABOUTBOX };

protected:
	virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV 支持

	// 实现
protected:
	DECLARE_MESSAGE_MAP()
};

CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
}

void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
}

BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
END_MESSAGE_MAP()


// CTQYBDlg 对话框




CTQYBDlg::CTQYBDlg(CWnd* pParent /*=NULL*/)
: CDialog(CTQYBDlg::IDD, pParent)
{
	m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}
CTQYBDlg::~CTQYBDlg()
{
	delete m_para_insert_weather;
}
void CTQYBDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	DDX_Control(pDX, IDC_EDIT1, m_Now_Time_Edit);
	DDX_Control(pDX, IDC_EDIT2, m_Updata_Time_Edit);
	DDX_Control(pDX, IDC_EDIT3, m_Log_Edit);
	DDX_Control(pDX, IDC_BUTTON1, m_Start_Btn);
	DDX_Control(pDX, IDC_EDIT4, m_updated_log);
}

BEGIN_MESSAGE_MAP(CTQYBDlg, CDialog)
	ON_WM_SYSCOMMAND()
	ON_WM_PAINT()
	ON_WM_QUERYDRAGICON()
	//}}AFX_MSG_MAP
	ON_BN_CLICKED(IDC_BUTTON1, &CTQYBDlg::OnBnClickedButton1)
	ON_WM_TIMER()
END_MESSAGE_MAP()


void CTQYBDlg::ReadCityName()
{
	FILE *dictfd;
	char buffer[256];
	if ((dictfd = fopen ("city.txt", "r")) == NULL)
	{
		return;
	}
	while (fgets (buffer, sizeof (buffer), dictfd) != NULL)
	{
		CString s=buffer;
		s.Trim();
		CCity city_name(s);
		g_list_city.push_back(city_name);
	}
	fclose(dictfd);
}

// CTQYBDlg 消息处理程序

BOOL CTQYBDlg::OnInitDialog()
{
	CDialog::OnInitDialog();

	// 将“关于...”菜单项添加到系统菜单中。

	// IDM_ABOUTBOX 必须在系统命令范围内。
	ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
	ASSERT(IDM_ABOUTBOX < 0xF000);

	CMenu* pSysMenu = GetSystemMenu(FALSE);
	if (pSysMenu != NULL)
	{
		BOOL bNameValid;
		CString strAboutMenu;
		bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);
		ASSERT(bNameValid);
		if (!strAboutMenu.IsEmpty())
		{
			pSysMenu->AppendMenu(MF_SEPARATOR);
			pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
		}
	}

	// 设置此对话框的图标。当应用程序主窗口不是对话框时，框架将自动
	//  执行此操作
	SetIcon(m_hIcon, TRUE);			// 设置大图标
	SetIcon(m_hIcon, FALSE);		// 设置小图标
	SetTimer(1,1000,NULL);
	SetTimer(2,24*60*60*1000,NULL);
	m_Updata_Time_Edit.SetWindowText(_T("03:00:00"));
	InitializeCriticalSection(&g_section_list_city_weather);
		// TODO: 在此添加额外的初始化代码
	CCityWeatherInfo result("北京","请");
	CString city=result.GetCityName();
	char *city_name=city.GetBuffer();
	GetWeatherByCity("曲靖",city);
	ReadCityName(); 
	m_para_insert_weather=new ObjectThreadPara;
	AfxBeginThread(ProcInsertCityWeather,m_para_insert_weather);
	return TRUE;  // 除非将焦点设置到控件，否则返回 TRUE
}

void CTQYBDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
	if ((nID & 0xFFF0) == IDM_ABOUTBOX)
	{
		CAboutDlg dlgAbout;
		dlgAbout.DoModal();
	}
	else
	{
		CDialog::OnSysCommand(nID, lParam);
	}
}

// 如果向对话框添加最小化按钮，则需要下面的代码
//  来绘制该图标。对于使用文档/视图模型的 MFC 应用程序，
//  这将由框架自动完成。

void CTQYBDlg::OnPaint()
{
	if (IsIconic())
	{
		CPaintDC dc(this); // 用于绘制的设备上下文

		SendMessage(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);

		// 使图标在工作区矩形中居中
		int cxIcon = GetSystemMetrics(SM_CXICON);
		int cyIcon = GetSystemMetrics(SM_CYICON);
		CRect rect;
		GetClientRect(&rect);
		int x = (rect.Width() - cxIcon + 1) / 2;
		int y = (rect.Height() - cyIcon + 1) / 2;

		// 绘制图标
		dc.DrawIcon(x, y, m_hIcon);
	}
	else
	{
		CDialog::OnPaint();
	}
}

//当用户拖动最小化窗口时系统调用此函数取得光标
//显示。
HCURSOR CTQYBDlg::OnQueryDragIcon()
{
	return static_cast<HCURSOR>(m_hIcon);
}


void CTQYBDlg::OnBnClickedButton1()
{
	// TODO: 在此添加控件通知处理程序代码
	//m_Start_Btn.EnableWindow(FALSE);
	/*CString str;
	if (GetWeatherByCity("济南",str))
	m_Log_Edit.SetWindowText(str);
	else
	{
		MessageBox("网络出现问题,或者数据站已经更新,无法获取到数据");
	}*/
	ObjectThreadPara *para=new ObjectThreadPara;
	AfxBeginThread(ProcGetCityWeather,para);

}

void CTQYBDlg::OnTimer(UINT_PTR nIDEvent)
{
	// TODO: 在此添加消息处理程序代码和/或调用默认值
	if (nIDEvent==1)
	{
		CTime t;
		t=CTime::GetCurrentTime();
		CString str;
		str=t.Format(_T("%H:%M:%S"));
		m_Now_Time_Edit.SetWindowText(str);

	}
	if (nIDEvent==2)
	{
		ObjectThreadPara *para=new ObjectThreadPara;
		AfxBeginThread(ProcGetCityWeather,para);
	}
	CDialog::OnTimer(nIDEvent);
}
UINT __cdecl CTQYBDlg::WeatherCollectProc1(LPVOID p)
{
	CString weather_update_log;
	CString weather;
	CString temp;

	CStringArray arr1;
	arr1.Add("北京");
	arr1.Add("上海");
	arr1.Add("天津");
	arr1.Add("重庆");
	for (int j=0;j<1000;j++)
	{
	
		for (int i=0;i<arr1.GetCount();i++)
		{
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->GetWeatherByCity(arr1[i],weather);
			weather_update_log.Format("%s\r\n%s",arr1[i],weather);
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_Log_Edit.GetWindowText(temp);
			weather_update_log+="\r\n";
			weather_update_log+=temp;
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_Log_Edit.SetWindowText(weather_update_log);

			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->RecordWeatherByCity(arr1[i],weather);
		}
		j=1000;
	}
		CString updated_temp;
		((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_updated_log.GetWindowText(updated_temp);
		updated_temp+="\r\n已更新 直辖市_1";
		((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_updated_log.SetWindowText(updated_temp);
	
	return TRUE;
}
UINT __cdecl CTQYBDlg::WeatherCollectProc2(LPVOID p)
{
	CString weather_update_log;
	CString weather;
	CString temp;
	
	CStringArray arr2;
	//arr2.Add("香港");
	arr2.Add("澳门");
	/*arr2.Add("台北");
	arr2.Add("高雄");*/
	for (int j=0;j<1000;j++)
	{		

		for (int i=0;i<arr2.GetCount();i++)
		{
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->GetWeatherByCity(arr2[i],weather);
			weather_update_log.Format("%s\r\n%s",arr2[i],weather);
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_Log_Edit.GetWindowText(temp);
			weather_update_log+="\r\n";
			weather_update_log+=temp;
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_Log_Edit.SetWindowText(weather_update_log);
		
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->RecordWeatherByCity(arr2[i],weather);
		}
		j=1000;
	}
	CString updated_temp;
	((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_updated_log.GetWindowText(updated_temp);
	updated_temp+="\r\n已更新 特别行政区_2";
	((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_updated_log.SetWindowText(updated_temp);
	return TRUE;
}
UINT __cdecl CTQYBDlg::WeatherCollectProc3(LPVOID p)
{
	CString weather_update_log;
	CString weather;
	CString temp;

	CStringArray arr3;
	arr3.Add("哈尔滨");
	arr3.Add("齐齐哈尔");
	arr3.Add("牡丹江");
	arr3.Add("大庆");
	arr3.Add("伊春");
	arr3.Add("双鸭山");
	arr3.Add("鹤岗");
	arr3.Add("鸡西");
	arr3.Add("佳木斯");
	arr3.Add("七台河");
	arr3.Add("黑河");
	arr3.Add("绥化");
	arr3.Add("大兴安岭");
	for (int j=0;j<1000;j++)
	{		

		for (int i=0;i<arr3.GetCount();i++)
		{
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->GetWeatherByCity(arr3[i],weather);
			weather_update_log.Format("%s\r\n%s",arr3[i],weather);
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_Log_Edit.GetWindowText(temp);
			weather_update_log+="\r\n";
			weather_update_log+=temp;
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_Log_Edit.SetWindowText(weather_update_log);

			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->RecordWeatherByCity(arr3[i],weather);
		}
		j=1000;
	}
	CString updated_temp;
	((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_updated_log.GetWindowText(updated_temp);
	updated_temp+="\r\n已更新 黑龙江_3";
	((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_updated_log.SetWindowText(updated_temp);
	return TRUE;
}

UINT __cdecl CTQYBDlg::WeatherCollectProc4(LPVOID p)
{
	CString weather_update_log;
	CString weather;
	CString temp;

	CStringArray arr4;
	arr4.Add("长春");
	arr4.Add("延边");
	arr4.Add("吉林");
	arr4.Add("白山");
	arr4.Add("白城");
	arr4.Add("四平");
	arr4.Add("松原");
	arr4.Add("辽源");
	arr4.Add("大安");
	arr4.Add("通化");
	for (int j=0;j<1000;j++)
	{		

		for (int i=0;i<arr4.GetCount();i++)
		{
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->GetWeatherByCity(arr4[i],weather);
			weather_update_log.Format("%s\r\n%s",arr4[i],weather);
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_Log_Edit.GetWindowText(temp);
			weather_update_log+="\r\n";
			weather_update_log+=temp;
			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_Log_Edit.SetWindowText(weather_update_log);

			((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->RecordWeatherByCity(arr4[i],weather);
		}
		j=1000;
	}
	CString updated_temp;
	((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_updated_log.GetWindowText(updated_temp);
	updated_temp+="\r\n已更新 吉林_4";
	((CTQYBDlg*)AfxGetApp()->m_pMainWnd)->m_updated_log.SetWindowText(updated_temp);
	return TRUE;
}

UINT __cdecl CTQYBDlg::WeatherCollectProc5(LPVOID p)
{
	CString weather_update_log;
	CString weather;
	CString temp;

	CStringArray arr5;
	arr5.Add("沈阳");
	arr5.Add("大连");