📄 logindaoimpl.cs
字号:
using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using DaFanRongMIS.Model.Common;
namespace DaFanRongMIS.Model.LoginOper
{
class LoginDAOImpl : LoginDAO
{
#region 保存用户信息
public string AddLogin(LoginEntity login)
{
SqlCommand sqlCmd = new SqlCommand();
sqlCmd.Connection = ConnectionDataBase.getConOpen();
//判断主键是否重复
sqlCmd.CommandText = "select count(*) from Login where UserID=@userid ";
sqlCmd.Parameters.Add("@userid", login.Userid);
int count = (int)sqlCmd.ExecuteScalar();
if (count == 0)
{ //保存数据
sqlCmd.CommandText = "insert into login values(@userid,@password,@idcard,@cashregisterid,@status,@createtime,@outtime)";
//sqlCmd.Parameters.Add("@userid", login.Userid);
sqlCmd.Parameters.Add("@password", login.Password);
sqlCmd.Parameters.Add("@idcard", login.Idcard);
sqlCmd.Parameters.Add("@cashregisterid", login.Cashregisterid);
sqlCmd.Parameters.Add("@status", login.Status);
sqlCmd.Parameters.Add("@createtime", login.Createtime);
sqlCmd.Parameters.Add("@outtime", "1900-01-01");
int i = sqlCmd.ExecuteNonQuery();
sqlCmd.Dispose();
ConnectionDataBase.getConClose();
if (i == 1)
return "OK";
else
return "Error";
}
else
{
sqlCmd.Dispose();
ConnectionDataBase.getConClose();
return "数据重复";
}
}
#endregion
#region 更新用户信息
public string UpdateLogin(LoginEntity login)
{
SqlCommand sqlCmd = new SqlCommand();
sqlCmd.Connection = ConnectionDataBase.getConOpen();
sqlCmd.CommandText = "update login set password=@password,idcard=@idcard,cashregisterid=@cashregisterid,status=@status,createtime=@createtime,outtime=@outtime where userid=@userid";
sqlCmd.Parameters.Add("@userid", login.Userid);
sqlCmd.Parameters.Add("@password", login.Password);
sqlCmd.Parameters.Add("@idcard", login.Idcard);
sqlCmd.Parameters.Add("@cashregisterid", login.Cashregisterid);
sqlCmd.Parameters.Add("@status", login.Status);
sqlCmd.Parameters.Add("@createtime", login.Createtime);
sqlCmd.Parameters.Add("@outtime", login.Outtime);
int i = sqlCmd.ExecuteNonQuery();
sqlCmd.Dispose();
ConnectionDataBase.getConClose();
if (i == 1)
return "OK";
else
return "Error";
}
#endregion
#region 删除数据
public string DeleteLogin(LoginEntity login)
{
SqlCommand sqlCmd = new SqlCommand();
sqlCmd.Connection = ConnectionDataBase.getConOpen();
sqlCmd.CommandText = "delete from login where userid=@userid";
sqlCmd.Parameters.Add("@userid", login.Userid);
int i=sqlCmd.ExecuteNonQuery();
sqlCmd.Dispose();
ConnectionDataBase.getConClose();
if (i == 1)
return "OK";
else
return "Error";
}
#endregion
#region 查询返回所需数据
public DataTable selectInfo(string userid)
{
SqlConnection sqlCon = ConnectionDataBase.getConOpen();
SqlCommand sqlCmd = new SqlCommand();
sqlCmd.Connection = sqlCon;
sqlCmd.CommandText = "SELECT CashRegister.Name AS cName, Employee.Name AS eName, " +
" Login.UserID , Login.Password, Login.IDCard, Login.CashRegisterID, Login.Status, Login.CreateTime, Login.OutTime" +
" FROM Login, Employee ,CashRegister where Login.IDCard = Employee.IDCard and login.CashRegisterID=CashRegister.ID and userid like '%" + userid + "%'";
SqlDataAdapter da = new SqlDataAdapter();
DataSet ds = new DataSet();
da.SelectCommand = sqlCmd;
da.Fill(ds, "login");
ConnectionDataBase.getConClose();
sqlCmd.Dispose();
return ds.Tables["login"];
}
#endregion
#region
public int getUserPassword(string pwd)
{
SqlCommand sqlCmd = new SqlCommand();
sqlCmd.Connection = ConnectionDataBase.getConOpen();
sqlCmd.CommandText = "select count(*) from login where userid=@userid and password=@pwd";
sqlCmd.Parameters.Add("@userid", ConnectionDataBase.Userid);
sqlCmd.Parameters.Add("@pwd", pwd);
int count =Convert.ToInt32(sqlCmd.ExecuteScalar());
sqlCmd.Dispose();
ConnectionDataBase.getConClose();
return count;
}
#endregion
#region
public string setUserPassword(string pwd)
{
string retval = "";
SqlCommand sqlCmd = new SqlCommand();
sqlCmd.Connection = ConnectionDataBase.getConOpen();
sqlCmd.CommandText = "update login set password =@password where userid=@userid";
sqlCmd.Parameters.Add("@userid", ConnectionDataBase.Userid);
sqlCmd.Parameters.Add("@password", pwd);
int i = sqlCmd.ExecuteNonQuery();
sqlCmd.Dispose();
ConnectionDataBase.getConClose();
if (i == 1)
return "OK";
else
return "Error";
}
#endregion
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -