sale.cs

分布式数据库系统的分系统

using System;
using System.Data.SqlClient;
using System.Data;
using System.Windows.Forms;

namespace RemotingClass
{
	/// <summary>
	/// Class1 的摘要说明。
	/// </summary>
	/// 
	
	public class Sale: MarshalByRefObject
	{
		SqlConnection mySqlConnection;

		public Sale()
		{
			string connectString="workstation id=7B1EE60547FB453;packet size=4096;integrated security=SSPI;initial catalog=branchyf;persist security info=False";
			mySqlConnection=new SqlConnection(connectString);
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}
		public Sale(string sqlid,string tableid)
		{
			string connectString="workstation id="+sqlid+";packet size=4096;integrated security=SSPI;initial catalog="+tableid+";persist security info=False";
			mySqlConnection=new SqlConnection(connectString);
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}
		public void SetSQL(string sqlid,string tableid)
		{
			string connectString="workstation id="+sqlid+";packet size=4096;integrated security=SSPI;initial catalog="+tableid+";persist security info=False";
			mySqlConnection=new SqlConnection(connectString);
			MessageBox.Show("SetSql()!");
			return;
			
		}

		public double ComputeOD(DateTime t)
		{
			string vcommand="select * from Vendition where vendtime='"+t.Date+"'";
			return Compute(vcommand);
		}

		public double ComputeOM(DateTime t)
		{
			DateTime max=new DateTime(t.Year,t.Month,31);
			DateTime min=new DateTime(t.Year,t.Month,1);
			string vcommand="select * from Vendition where vendtime<='"+max.Date+"'and vendtime>= '"+min.Date+"'";
			return Compute(vcommand);
		}

		public double ComputeOY(DateTime t)
		{
			DateTime max=new DateTime(t.Year,12,31);
			DateTime min=new DateTime(t.Year,1,1);
			string vcommand="select * from Vendition where vendtime<='"+max.Date+"'and vendtime>= '"+min.Date+"'";
			return Compute(vcommand);
		}

		public double Compute(string command)
		{
			DataRow item;
			double gain=0;
			SqlDataAdapter sqlDataAdapter_Vendition=new SqlDataAdapter(command,mySqlConnection);
			DataSet dataSet_Vendition=new DataSet();
			sqlDataAdapter_Vendition.Fill(dataSet_Vendition);
			DataTable Vendition=dataSet_Vendition.Tables[0];
			for(int i=0;i<Vendition.Rows.Count;i++)
			{
				item=Vendition.Rows[i];
				gain+=Decimal.ToDouble((Decimal)item["saleprice"]*(Decimal)item["commstock"]);
			}
			return gain;
		}

	
	}
}