frmmain.cs

太阳神短信跟踪服务系统

			{
				MessageBox.Show("请选择要备份的数据库名!",Application.ProductName.ToString() + "提示");
				return;
			}
			SQLDMO.Backup bakDB = new SQLDMO.BackupClass();
			bakDB.Database=cboDataBase.SelectedItem.ToString();
			bakDB.Files=txbBakPath.Text.Trim();
			bakDB.Action=0;
			bakDB.BackupSetName="apollo database backup";
			bakDB.BackupSetDescription=DateTime.Now.ToString() + "backuped";

			try
			{
				bakDB.SQLBackup(srv);
				MessageBox.Show("成功备份数据库" + cboDataBase.SelectedItem.ToString() + "!" , Application.ProductName.ToString() + "提示");
			}
			catch
			{
			
			}
		}

		private void btnRestore_Click(object sender, System.EventArgs e)
		{
			if(!System.IO.File.Exists(txbResPath.Text.Trim()))
			{
				MessageBox.Show("请输入正确的恢复文件名!",Application.ProductName.ToString() + "提示");
				return;
			}

			if(cboDataBase.SelectedIndex ==-1)
			{
				MessageBox.Show("请选择待恢复的数据库!",Application.ProductName.ToString() + "提示");
				return;
			}

			SQLDMO.Restore resDB = new SQLDMO.RestoreClass();
			resDB.Database=cboDataBase.SelectedItem.ToString();
			resDB.Files=txbResPath.Text.Trim();
			resDB.ReplaceDatabase=true;
			resDB.Action=0;

			try
			{
				resDB.SQLRestore(srv);
				MessageBox.Show("成功恢复数据库" + cboDataBase.SelectedItem.ToString() + "!",Application.ProductName.ToString() + "提示");
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message.ToString(),"恢复失败!");
			}
		}

		private void btnFresh_Click(object sender, System.EventArgs e)
		{
//			if(txtHost.Text.Trim()!="(local)")
//			{
//				Form abc = new frmLogin();
//				abc.Show();
//			}
//			
//			MessageBox.Show(SqlHost.ToString());
//			return;
			try
			{
				srv = new SQLDMO.SQLServerClass();                 
				srv.Connect(SqlHost,SqlName,SqlPWD);

				cboDataBase.Items.Clear();

				foreach(SQLDMO.Database db in srv.Databases) 
				{ 
					if(db.Name!=null) 
						this.cboDataBase.Items.Add(db.Name); 
				}
				srv.Close();
			}
			catch(Exception ex)
			{
				MessageBox.Show( ex.Message.ToString(),"SQL服务参数不正确，请重新设置" );
			}
		}

		private void btnCompress_Click(object sender, System.EventArgs e)
		{
			if(!System.IO.File.Exists(txbResPath.Text.Trim()))
			{
				MessageBox.Show("请输入正确的文件名!",Application.ProductName.ToString() + "提示");
				return;
			}

			string fileName=txbBakPath.Text.Trim();
		
			if(System.IO.File.Exists(fileName.Substring(0,fileName.LastIndexOf(".")) + ".rar"))
			{
				try
				{
					//Common.ExecutePro("D:\\Database\\rar.exe","a "+ dirs[0].Substring(0,dirs[0].LastIndexOf(".")) + ".rar " + dirs[0].ToString());
					Common.ExecutePro("D:\\Database\\rar.exe","a "+ fileName.Substring(0,fileName.LastIndexOf(".")) + ".rar " + fileName.ToString());
				}
				catch(Exception ex)
				{
					throw new Exception("压缩失败!错误原因：" + ex.Message);	
				}
				finally
				{
					if(System.IO.File.Exists(fileName))
						System.IO.File.Delete(fileName);
				}
			}
		}

		private void btnUnCompress_Click(object sender, System.EventArgs e)
		{
			if(!System.IO.File.Exists(txbResPath.Text.Trim()))
			{
				MessageBox.Show("请输入正确的压缩文件名!",Application.ProductName.ToString() + "提示");
				return;
			}
		}

		private void timer1_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
		{

			//每天早上4点提取所有满足条件的记录
			if(DateTime.Now.Hour==4 && DateTime.Now.Minute==0)
			{
				//调用程储过程locateMobile提取所有满足条件的手机号或小灵通号
				DB = new SqlConnection( "server=" + SqlHost + "; uid=" + SqlName + "; pwd=" + SqlPWD + "; database=apollo" );
				//DB.ConnectionString 
				DB.Open();
				SqlCommand Cmd = new SqlCommand("",DB);
				Cmd.CommandType = CommandType.StoredProcedure;
				Cmd.CommandText = "PMsg_GetMobile";
				Cmd.CommandTimeout = 3600;
				//Cmd.ExecuteReader 
				//Cmd.Parameters.Add();
				
				string strLog="--------------"+ DateTime.Now.ToString() + " start write into log----------------";
				Common.writeLog("c:\\ApolloMsgSrv.log",strLog);
				strLog="提取手机号或小灵通号成功!";

				try
				{
					Cmd.ExecuteNonQuery();
				}
				catch
				{
					strLog="提取手机号或小灵通号失败!";
					return;
				}
				DB.Close();
				Common.writeLog(logFilePath,strLog);
				Common.writeLog(logFilePath,"");
			}



			//MessageBox.Show(DateTime.Now.ToString());
		}

		private void btnNew_Click(object sender, System.EventArgs e)
		{

//			if(btnNew.Text=="新增")
//			{
//				cmbMsgType.Items.Add("");
//				txbMsgContent.Text="";
//				btnNew.Text="确定";
//			}
//			else if(btnNew.Text=="确定")
//			{
//			}
		}

		private void btnSrvOption_Click(object sender, System.EventArgs e)
		{
			if(MessageBox.Show("您确定要操作吗",Application.ProductName.ToString() + "提示",MessageBoxButtons.YesNo) == DialogResult.No )
			{
				return;
			}

			if(btnSrvOption.Text.Trim()=="开始服务")
			{
				try
				{
					ApolloMsgSrv.Start();
					btnSrvOption.Text="停止服务";
					ApolloMsgSrv.Refresh();
				}
				catch(Exception ex)
				{
					MessageBox.Show("启动失败" + ex.Message.ToString(),Application.ProductName.ToString() + "提示");
				}
			}
			else if(btnSrvOption.Text.Trim()=="停止服务")
			{
				try
				{
					ApolloMsgSrv.Stop();
					btnSrvOption.Text="开始服务";
					ApolloMsgSrv.Refresh();
				}
				catch(Exception ex)
				{
					MessageBox.Show("停止失败" + ex.Message.ToString(),Application.ProductName.ToString() + "提示");
				}
			}
		}



		private void tabControl1_SelectedIndexChanged(object sender, EventArgs e)
		{
			RegistryKey rk = Registry.LocalMachine.OpenSubKey("SOFTWARE\\Apollo\\ServicePara",true);

			switch (tabControl1.SelectedIndex)
			{
				case 0:
				{
					//从注册表读取短信参数
					//RegistryKey rk = Registry.LocalMachine.OpenSubKey("SOFTWARE\\Apollo\\ServicePara",true);
					try
					{
						textBox1.Text =(string)rk.GetValue("RunningPeriods");
						string connStr=(string)rk.GetValue("ConnectionString");

						string delimStr = ";";
						char [] delimiter = delimStr.ToCharArray();

						//string connStr="server=xzh; uid=sa; pwd=; database=apollo";
						string []connStrArr = connStr.Split(delimiter,4);
						txtSqlHost.Text = connStrArr[0].Substring(connStrArr[0].LastIndexOf("=")+1,connStrArr[0].Length-(connStrArr[0].Substring(0,connStrArr[0].LastIndexOf("=")).Length+1));
						txtSqlName.Text = connStrArr[1].Substring(connStrArr[1].LastIndexOf("=")+1,connStrArr[1].Length-(connStrArr[1].Substring(0,connStrArr[1].LastIndexOf("=")).Length+1));
						txtSqlPWD.Text =  connStrArr[2].Substring(connStrArr[2].LastIndexOf("=")+1,connStrArr[2].Length-(connStrArr[2].Substring(0,connStrArr[2].LastIndexOf("=")).Length+1));

						cboDataBase1.Text= connStrArr[3].Substring(connStrArr[3].LastIndexOf("=")+1,connStrArr[3].Length-(connStrArr[3].Substring(0,connStrArr[3].LastIndexOf("=")).Length+1));
					}

					catch(Exception ex)
					{
						throw new Exception("读注册表失败!原因：" + ex.Message);
					}
					//rk.Close();

					//读取ApolloMsgSrv当前状态
					ApolloMsgSrv.Refresh();
					if(ApolloMsgSrv.Status.ToString()=="Running")
					{
						btnSrvOption.Text="停止服务";
					}
					else
					{
						btnSrvOption.Text="开始服务";
					}
					break;
				}
				case 1:
				{
					//从注册表读取短信参数
					try
					{
						//textBox1.Text =(string)rk.GetValue("RunningPeriods");
						txbJLlogName.Text = (string)rk.GetValue("strJLlogName");
						txbJLlogPWD.Text = (string)rk.GetValue("strJLlogPWD");

						chkNewAdd.Checked=Convert.ToBoolean((int)rk.GetValue("NewAdd"));
						chkBirthday.Checked=Convert.ToBoolean((int)rk.GetValue("Birthday"));
						chkBottleNeck.Checked=Convert.ToBoolean((int)rk.GetValue("BottleNeck"));
						chkFestival.Checked=Convert.ToBoolean((int)rk.GetValue("Festival"));
						chkHaveCadreman.Checked=Convert.ToBoolean((int)rk.GetValue("HaveCadreman"));
						chkLogistics.Checked=Convert.ToBoolean((int)rk.GetValue("Logistics"));
						chkDawnMarginRemind.Checked=Convert.ToBoolean((int)rk.GetValue("DawnMarginRemind"));
						chkCheckRemind.Checked=Convert.ToBoolean((int)rk.GetValue("CheckRemind"));
					}
					catch(Exception ex)
					{
						throw new Exception("读注册表失败!原因：" + ex.Message);
					}
					
					break;
				}
				case 2:
				{
					break;
				}
				case 3:
				{

					break;
				}
				case 4:
				{

					break;
				}
			}
			rk.Close();
		}

		private void btnFresh1_Click(object sender, System.EventArgs e)
		{
			try
			{
				srv = new SQLDMO.SQLServerClass();                 
				//srv.Connect(SqlHost,SqlName,SqlPWD);
				srv.Connect(txtSqlHost.Text.Trim(),txtSqlName.Text.Trim(),txtSqlPWD.Text.Trim());

				cboDataBase1.Items.Clear();

				foreach(SQLDMO.Database db in srv.Databases) 
				{ 
					if(db.Name!=null) 
						this.cboDataBase1.Items.Add(db.Name); 
				}
				srv.Close();

				SqlHost=txtSqlHost.Text.Trim();
				SqlName=txtSqlName.Text.Trim();
				SqlPWD=txtSqlPWD.Text.Trim();
			}
			catch(Exception ex)
			{
				MessageBox.Show( ex.Message.ToString(),"SQL服务参数不正确，请重新输入" );
			}
		}

		private void btnMsgFresh_Click(object sender, System.EventArgs e)
		{
			DB= new SqlConnection("server=" + SqlHost + "; uid=" + SqlName + "; pwd=" + SqlPWD + "; database=apollo");
			SqlDataAdapter sa = new SqlDataAdapter( "select * from dbo.TMsg_msgContent",DB );
			ds = new DataSet();
					
			try
			{
				sa.Fill( ds,"msgContent" );
			}
			catch(Exception ex)
			{
				MessageBox.Show("数据库连接不成功,原因：" + ex.Message.ToString());
			}

			cmbMsgType.Items.Clear();

			for(int i=0;i<ds.Tables["msgContent"].Rows.Count;i++)
			{
				string strValue = ds.Tables["msgContent"].Rows[i]["ID"].ToString();
				string strText = ds.Tables["msgContent"].Rows[i]["msgType"].ToString();

				//System.Windows.Forms.listitem  li = new ListViewItem(

				//item li = new item(strText,strValue);
				
				cmbMsgType.Items.Add(strText);
			}
		}

		private void cmbMsgType_SelectedIndexChanged(object sender, System.EventArgs e)
		{
			//cmbMsgType.SelectedIndex 
			txbMsgContent.Text=ds.Tables["msgContent"].Rows[cmbMsgType.SelectedIndex]["msgContent"].ToString();
		}

		private void button4_Click(object sender, System.EventArgs e)
		{
			

		}

		private void button6_Click(object sender, System.EventArgs e)
		{


		}

		private void button7_Click(object sender, System.EventArgs e)
		{

		}
		
		/// <summary>
		/// 布尔转成整型
		/// </summary>
		/// <author>熊正浩</author>
		/// <date>2006-05-025</date>
		/// <param name="bValue">输入布值</param>
		/// <returns>整型变量1或0</returns>
		private int BooleanToInt(Boolean bValue)
		{
			if(bValue==true)
				return 1;
			else
				return 0;
		}
	}
}