frmmain.cs

用于文件传输的Web服务客户端

			//				Dt.Columns.Add(Dc);
			//				Dc=new DataColumn();
			//				Dc.ColumnName="ParamValue";
			//				Dt.Columns.Add(Dc);
			//
			//				DataRow Dr;
			//				for(int i=0;i<ConfigurationSettings.AppSettings.Count;i++)
			//				{
			//					Dr=Dt.NewRow();
			//					Dr["ParamName"]=ConfigurationSettings.AppSettings.Keys[i];
			//					Dr["ParamValue"]=ConfigurationSettings.AppSettings[i].ToString();					
			//					Dt.Rows.Add(Dr);
			//				}				
			////				Grid.DataSource=Dt;
			//				Grid.Lock=true;
			//				Grid.MaxRows=Dt.Rows.Count+Grid.MaxRows;
			//				
			//				for(int i=0;i<Dt.Rows.Count;i++)
			//				{	Grid.Col=1;
			//					Grid.Row=i+2;
			//					Grid.TypeVAlign=FPSpread.TypeVAlignConstants.TypeVAlignCenter;
			//					Grid.TypeHAlign=FPSpread.TypeHAlignConstants.TypeHAlignCenter;
			//					Grid.SetText(1,i+2,i+1);
			//					Grid.SetText(2,i+2,Dt.Rows[i]["ParamName"].ToString());
			//					Grid.SetText(3,i+2,Dt.Rows[i]["ParamValue"].ToString());					
			//				}				
		}
		private void WriteLog()
		{
			if(txtStatus.Text!="")
			{									
				try
				{
					System.IO.FileInfo fi=new System.IO.FileInfo(System.Reflection.Assembly.GetExecutingAssembly().Location);
					if(!System.IO.Directory.Exists(fi.Directory+"\\Log\\"))
					{
						System.IO.Directory.CreateDirectory(fi.Directory+"\\Log\\");
					}
					string LogFile=fi.Directory+"\\Log\\"+DateTime.Now.ToString().Replace(":","'")+".txt";					
					System.IO.StreamWriter sm=System.IO.File.CreateText(LogFile);
					sm.Write(txtStatus.Text);
					sm.Close();	
					txtStatus.Text="";
				}
				catch
				{}					
			}				
		}
		private void CmdClose_Click(object sender, System.EventArgs e)
		{
			try
			{
				WriteLog();
				Application.Exit();
			}
			catch(System.Exception ex)
			{
				string serr=ex.Message;
				serr=serr;
			}			
		}
		private void startTrans()
		{
			string sUrl=ConfigurationSettings.AppSettings["ServiceAddress"];
			string UserName=ConfigurationSettings.AppSettings["UserName"];
			string PassWord=ConfigurationSettings.AppSettings["PassWord"];
			string TransPath=ConfigurationSettings.AppSettings["TransPath"];
			string MovePath=ConfigurationSettings.AppSettings["MovePath"];
			E3.WebService.SZSE.InterFace  svr=new E3.WebService.SZSE.InterFace(sUrl);
			if((UserName!=null&&PassWord!=null)&&(UserName!=""&&PassWord!=""))
			{
				svr.Credentials=new System.Net.NetworkCredential(UserName,PassWord);						
			}
			if(TransPath!=null&&TransPath!="")
			{
				string[] txtPath=Directory.GetFiles(TransPath);
				//if(txtPath.Length==0)
//					MessageBox.Show("No Trans Data In Trans Direction","E3 Message");
				foreach(string f in txtPath)
				{
					try
					{						
						FileInfo fin=new FileInfo(f);

						txtCurrTrans.Text=fin.FullName;
						txtAllText.Text=txtStatus.Text;

						string fileName=fin.Name;
						string sOrgText=txtStatus.Text;
						txtStatus.Text="Current Trans Data:"+fin.FullName+"\r\n"+sOrgText;
						FileStream fs =new FileStream(f,FileMode.Open,FileAccess.Read);
						fs.Seek(0,SeekOrigin.Begin);
						byte[] b =new byte[fs.Length];
						fs.Read(b,0,b.Length);
						fs.Close();					
						svr.Timeout=999999999;
						string sr="";
						try
						{
							sr=svr.TransFile(fileName,b);
						}
						catch
						{}						

						txtCurrTrans.Text=fin.FullName;
						txtAllText.Text=txtStatus.Text;

						txtStatus.Text="("+DateTime.Now+
										")Trans Data:"+fin.FullName+
										"   successed!\r\n"+sOrgText;
						txtStatus.ScrollToCaret();						
						if(sr==""&&MovePath!="")
						{
							try
							{
								if(File.Exists(MovePath+fileName))
								{
									File.Delete(MovePath+fileName);
								}
								fin.MoveTo(MovePath+fileName);
							}
							catch(System.Exception ex)
							{
								string sErr=ex.Message;
								sErr=sErr;
							}							
						}
						else
						{
							fin.Delete();
//							txtStatus.Text+="   failed!("+sr+")\r\n";						
						}						
					}
					catch(System.Exception ex)
					{
						txtStatus.Text="("+DateTime.Now+
											"Trans Data:"+txtCurrTrans.Text+
											"   failed!(超出文件大小或者配置不正确！)\r\n"+txtAllText.Text;
						txtStatus.ScrollToCaret();
						//MessageBox.Show(ex.Message,"E3 Error Messages");
					}						
				}
			}	
		}		
		private void CmdStart_Click(object sender, System.EventArgs e)
		{
			try
			{
				System.Threading.ThreadStart threadStart =new System.Threading.ThreadStart(startTrans);
				System.Threading.Thread thread =new System.Threading.Thread(threadStart);
				thread.IsBackground =true;
				thread.Start();				
//				startTrans();				
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message,"E3 Error Messages");
			}
		}

		private void CmdAutoRun_Click(object sender, System.EventArgs e)
		{
			try
			{				
				System.Threading.ThreadStart threadStart =new System.Threading.ThreadStart(TransThread);
				System.Threading.Thread thread =new System.Threading.Thread(threadStart);
				thread.IsBackground =true;
				thread.Start();
				this.WindowState=System.Windows.Forms.FormWindowState.Minimized;
				CmdAutoRun.Enabled=false;
				this.Visible=false;
			}
			catch
			{}
		}
		private void TransThread()
		{
			while(true)
			{				
				if(DateTime.Now.Minute==0)
					WriteLog();
				startTrans();
				System.Threading.Thread.Sleep(2000);
			}
		}		
		private void FrmMain_SizeChanged(object sender, System.EventArgs e)
		{
			if(this.WindowState==System.Windows.Forms.FormWindowState.Minimized)
			{
				this.Visible=false;
			}
		}	
		private void NoI_Click(object sender, System.EventArgs e)
		{
			try
			{
				this.Visible=true;
				this.Show();
				this.Activate();
				this.WindowState=System.Windows.Forms.FormWindowState.Normal;
			}
			catch
			{}	
		}

		private void CmdTest_Click(object sender, System.EventArgs e)
		{
			string sUrl=ConfigurationSettings.AppSettings["ServiceAddress"];
			string UserName=ConfigurationSettings.AppSettings["UserName"];
			string PassWord=ConfigurationSettings.AppSettings["PassWord"];
			string TransPath=ConfigurationSettings.AppSettings["TransPath"];
			string MovePath=ConfigurationSettings.AppSettings["MovePath"];
			E3.WebService.SZSE.InterFace  svr=new E3.WebService.SZSE.InterFace(sUrl);
			if((UserName!=null&&PassWord!=null)&&(UserName!=""&&PassWord!=""))
			{
				svr.Credentials=new System.Net.NetworkCredential(UserName,PassWord);						
			}			
//			svr.CTLIS();
			DataSet ds=svr.GetGemDataSet("select * from Setting");
			
			dataGrid1.DataSource=ds;
//		this.TestImportExcel();
			
		}

		private void FrmMain_Closed(object sender, System.EventArgs e)
		{
			WriteLog();
		}
		private void TestImportExcel()
		{
//			String sConnectionString = "Provider=SQLOLEDB;Data Source=10.7.1.30;Initial Catalog=Data0527;User ID=sa;Password=daniel;";

			// Create connection object by using the preceding connection string.
			
			String sConnectionString =@"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=E:\测试\JgxxData\JGGX_11_20040331.xls;Extended Properties=Excel 8.0;";
			
			OleDbConnection objConn = new OleDbConnection(sConnectionString);

			// Open connection with the database.
			objConn.Open();

			// The code to follow uses a SQL SELECT command to display the data from the worksheet.

//			// Create new OleDbCommand to return data from worksheet.
//			string StrSql="select * from "	+ "OpenDataSource('Microsoft.Jet.OLEDB.4.0'" +
//					@",'Excel 8.0;HDR=YES;DATABASE=E:\测试\JgxxData\JGGX_11_20040331.xls')...[Sheet1$]"; 

			string StrSql="select * from DataTable";
			OleDbCommand objCmdSelect =new OleDbCommand(StrSql, objConn);

			// Create new OleDbDataAdapter that is used to build a DataSet
			// based on the preceding SQL SELECT statement.
			OleDbDataAdapter objAdapter1 = new OleDbDataAdapter();

			// Pass the Select command to the adapter.
			objAdapter1.SelectCommand = objCmdSelect;

			// Create new DataSet to hold information from the worksheet.
			DataSet objDataset1 = new DataSet();

			// Fill the DataSet with the information from the worksheet.
			objAdapter1.Fill(objDataset1, "XLData");

			// Bind data to DataGrid control.
//			DataGrid1.DataSource = objDataset1.Tables[0].DefaultView;
//			DataGrid1.DataBind();

			// Clean up objects.
			objConn.Close();

		}
		
	}
}