datasync.cs

windows mobile 2005 上可以运行的资产管理系统

			

		}

		private void timer1_Tick(object sender, System.EventArgs e)
		{
			//sync();
			sql_conn = new SqlConnection(connSql);
			sql_cmd = new SqlCommand();

			sql_conn2 = new SqlConnection(connSql);
			sql_cmd2 = new SqlCommand();
			try 
			{
				sql_conn.Open();
				label1.Text="数据库连接成功";
				pictureBox1.Visible=true;
//			}
//			catch(SqlException  ex) 
//			{
//				label1.Text="数据库连接出错："+ex.Message;
//				timer1.Enabled=false;
//			}
//			try
//			{
				lcounter=0;
				i=0;
				SqlDataReader myReader;
				sql_cmd.CommandText="SELECT COUNT(*) AS rCount FROM zcgl.dbo.table1";
				sql_cmd.Connection=sql_conn;
				myReader=sql_cmd.ExecuteReader();
				myReader.Read();
				lcounter=Convert.ToInt32(myReader[0]);
				progressBar1.Minimum=0;
				progressBar1.Maximum=lcounter;



				textID=File.OpenText(fname);
				lc_sql_cmd="";
				//sql_cmd.Connection=sql_conn;
				lc_sql_cmd="delete from LISsync.dbo.syncData";
				sql_cmd.CommandText=lc_sql_cmd;
				sql_cmd.ExecuteNonQuery();


				
				sql_cmd2.CommandText="select * from zcgl.dbo.table1";
				myReader2=sql_cmd2.ExecuteReader();
				StreamWriter sw = File.CreateText(fname);
				sw.Write("");
				sw.Close();


//					SqlDataReader myReader;
//					sql_cmd.CommandText="select * from LISsync.dbo.ID";
//					myReader=sql_cmd.ExecuteReader();
//					while(myReader.Read())
//					{
//						string str="";
//						str=myReader["UserID"].ToString()+"*"+myReader["password"].ToString()+"*"+myReader["name"].ToString();
//
//						if (File.Exists(fname2)) 
//						{
//							//System.IO.File.Delete(fname2);
//							StreamWriter sw = File.CreateText(fname2);
//							sw.WriteLine (str);
//							sw.Close();
//						}
//						else
//						{
//							StreamWriter sw = File.CreateText(fname2);
//							sw.WriteLine (str);
//							sw.Close();
//						}
//						
//					}
				






				
				if (updateUser())
					pictureBox2.Visible=true;
				
				timer2.Interval=100;
				timer2.Enabled=true;

				//Thread thd_update=new Thread(new ThreadStart(this.update));
				//thd_update.Start();
				


				timer1.Enabled=false;
			}
			catch(SqlException ex)
			{
				label1.Text="数据库读取出错："+ex.Message;
				timer1.Enabled=false;
				CloseButton.Enabled=true;
			}
			

		}
//		private void sync()
//		{
//			sql_conn = new SqlConnection(connSql);
//			SqlCommand sql_cmd = new SqlCommand();
//			try 
//			{
//				sql_conn.Open();
//				label1.Text="数据库连接成功";
//				pictureBox1.Visible=true;
//			}
//			catch(SqlException ex) 
//			{
//				label1.Text="数据库连接出错："+ex.Message;
//			}
//			try
//			{
//				int lcounter=0;
//				int i=0;
//				StreamReader lineCount=File.OpenText(fname);
//				while (lineCount.ReadLine() != null) 
//				{
//					lcounter++;
//				}
//				lineCount.Close();
//				progressBar1.Minimum=0;
//				progressBar1.Maximum=lcounter;
//				StreamReader textID=File.OpenText(fname);
//				string lc_sql_cmd="";
//				string line;
//				string[] sArray;
//				sql_cmd.Connection=sql_conn;
//				lc_sql_cmd="delete from LISsync.dbo.syncData";
//				sql_cmd.CommandText=lc_sql_cmd;
//				sql_cmd.ExecuteNonQuery();
//				while ((line = textID.ReadLine()) != null) 
//				{
//					sArray=line.Split('*');
//					lc_sql_cmd="insert into LISsync.dbo.syncData(code, uid, department, scantime)values('"+sArray[0]+"','"+sArray[1]+"','"+sArray[2]+"','"+sArray[3]+"')";
//					sql_cmd.CommandText=lc_sql_cmd;
//					sql_cmd.ExecuteNonQuery();
//					i++;
//					label2.Text=""+i.ToString().Trim()+"条记录上传同步成功。";
//					progressBar1.Value=progressBar1.Value+1;
//					
//				}
//				textID.Close();
//				
//				
//				
//				
//				
//				label1.Text="同步上传成功";
//				pictureBox3.Visible=true;
//				
//				sql_conn.Close();
//			}
//			catch (SqlException ex) 
//			{
//				//MessageBox.Show( "Error connecting to the server: " + ex.Message );
//				//MessageBox.Show("网络故障，连接中断，请重起程序。");
//				//MessageBox.Show(this.connSql.ToString());
//				label1.Text="数据库写入出错："+ex.Message;
//			}
//		
//		}
		

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

		private void timer2_Tick(object sender, System.EventArgs e)
		{
			
			try
			{
				if (myReader2.Read() && finishFlag)
				{
					try
					{
						string str="";
							//str=myReader["UserID"].ToString()+"*"+myReader["password"].ToString()+"*"+myReader["name"].ToString();
						for(int i=0;i<myReader2.FieldCount-1;i++)
						{
							str+=myReader2[i];
							str+="*";
						}
						str+=myReader2[myReader2.FieldCount-1];

						StreamWriter sw2 = File.AppendText(fname);
						sw2.WriteLine (str);
						sw2.Close();
						
						progressBar1.Value++;
					}
					catch
					{
						finishFlag=false;
						MessageBox.Show("同步上传中断，请检查计算机与移动PC的连接，然后重新上传！");
					}
				}
				else
				{
					timer2.Enabled=false;
					if (i==lcounter)
					{
						label1.Text="同步上传成功";
						pictureBox3.Visible=true;
					}
					else
					{
						label1.Text="同步上传中断，请检查计算机与移动PC的连接，然后重新上传！";
						pictureBox3.Visible=false;
					}
					textID.Close();
					//label1.Text="同步上传成功";
					//pictureBox3.Visible=true;
					//timer2.Enabled=false;
					CloseButton.Enabled=true;
				}
			}
			catch(SqlException ex)
			{
				label1.Text="数据库写入出错："+ex.Message;
				timer1.Enabled=false;
				CloseButton.Enabled=true;
			}
		}
		private Boolean updateUser()
		{
			try
			{
				SqlDataReader myReader;
				sql_cmd.CommandText="select * from zcgl.dbo.ID";
				myReader=sql_cmd.ExecuteReader();
				StreamWriter sw = File.CreateText(fname2);
				sw.Write("");
				sw.Close();
				while(myReader.Read())
				{
					string str="";
					str=myReader["UserID"].ToString()+"*"+myReader["password"].ToString()+"*"+myReader["name"].ToString();
					StreamWriter sw2 = File.AppendText(fname2);
					sw2.WriteLine (str);
					sw2.Close();
				}
				myReader.Close();
				return true;
			}
			catch(Exception ex)
			{
				MessageBox.Show("用户更新失败"+ex.ToString());
				return false;
			}
		}

		private void update()
		{
			while(true)
			{
				try
				{
					SqlDataReader myReader;
					sql_cmd.CommandText="select * from zcgl.dbo.table1";
					myReader=sql_cmd.ExecuteReader();
					StreamWriter sw = File.CreateText(fname);
					sw.Write("");
					sw.Close();
					while(myReader.Read())
					{
						string str="";
						//str=myReader["UserID"].ToString()+"*"+myReader["password"].ToString()+"*"+myReader["name"].ToString();

						for(int i=0;i<myReader.FieldCount-1;i++)
						{
							str+=myReader[i];
							str+="*";
						}
						str+=myReader[myReader.FieldCount-1];

						StreamWriter sw2 = File.AppendText(fname);
						sw2.WriteLine (str);
						sw2.Close();
					}
					myReader.Close();
					progressBar1.Value++;
				}
				catch
				{
					MessageBox.Show("数据更新失败");
					
				}
				Thread.Sleep(50);
			}
		
		}

	}
}