gy_persondal.cs

来自「为了便于企业对客户按照地区进行统计查询分析」· CS 代码 · 共 160 行

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using Model; 

namespace DataAccess.DAL
{
    class Gy_personDAL
    {

        //Comm.Comm c = new Comm.Comm();
        DataAccess.Comm.Comm c = new DataAccess.Comm.Comm();
        /// <summary>
        /// 查找员工设置
        /// </summary>
        /// <param name="Person_code"></param>
        /// <returns></returns>
        public List<Gy_person> SelectGy_person(string Person_code)
        {
            SqlConnection sqlcnn = c.conn();
            SqlCommand sqlcmd = new SqlCommand();
            sqlcmd.CommandText = "SelectGy_person";

            sqlcmd.CommandType = CommandType.StoredProcedure;
            sqlcmd.Parameters.AddWithValue("@Person_code", Person_code);
            sqlcmd.Connection = sqlcnn;
            SqlDataReader reader = null;
            List<Gy_person> list = new List<Gy_person>();

            try
            {
                sqlcnn.Open();
                reader = sqlcmd.ExecuteReader();
                while (reader.Read())
                {
                    Gy_person gy_person = new Gy_person();
                    gy_person.Person_code = reader["Person_code"].ToString();
                    gy_person.Person_name = reader["Person_name"].ToString();
                    gy_person.Person_sex = reader["Person_sex"].ToString();
                    gy_person.Person_age = Convert.ToInt32(reader["Person_age"].ToString());
                    gy_person.Person_email = reader["Person_email"].ToString();
                    gy_person.Person_telephone = reader["Person_telephone"].ToString();
                    gy_person.Person_department = reader["Person_department"].ToString();
                    gy_person.Person_grade = reader["Person_grade"].ToString();
                    gy_person.Person_remark = reader["Person_remark"].ToString();
                    gy_person.Person_password = reader["Person_password"].ToString();
                    list.Add(gy_person);
                }
            }
            catch (SqlException e)
            {
                throw e;
            }
            finally
            {
                if (sqlcnn.State != ConnectionState.Closed)
                {
                    sqlcnn.Close();
                }
            }
            return list;
        }
        /// <summary>
        /// 添加员工设置
        /// </summary>
        /// <param name="Person_code"></param>
        /// <param name="Person_name"></param>
        /// <param name="Person_sex"></param>
        /// <param name="Person_age"></param>
        /// <param name="Person_email"></param>
        /// <param name="Person_telephone"></param>
        /// <param name="Person_department"></param>
        /// <param name="Person_grade"></param>
        /// <param name="Person_remark"></param>
        /// <param name="Person_password"></param>
        //public void InsertGy_person(string Person_code, string Person_name, string Person_sex, int Person_age,
        //            string Person_email, string Person_telephone, string Person_department, string Person_grade,
        //            string Person_remark,string Person_password)
        public void InsertGy_person(Gy_person insert_gy_person)
        {
            SqlParameter[] parameters = {
					new SqlParameter("@Person_code", SqlDbType.VarChar,20),
					new SqlParameter("@Person_name", SqlDbType.VarChar,50),
					new SqlParameter("@Person_sex", SqlDbType.VarChar,50),
					new SqlParameter("@Person_age", SqlDbType.Int,4),
					new SqlParameter("@Person_email", SqlDbType.VarChar,60),
					new SqlParameter("@Person_telephone", SqlDbType.VarChar,50),
					new SqlParameter("@Person_department", SqlDbType.VarChar,20),
					new SqlParameter("@Person_grade", SqlDbType.VarChar,50),
					new SqlParameter("@Person_remark", SqlDbType.VarChar,100),
					new SqlParameter("@Person_password", SqlDbType.VarChar,50)};
            parameters[0].Value = insert_gy_person.Person_code;
            parameters[1].Value = insert_gy_person.Person_name;
            parameters[2].Value = insert_gy_person.Person_sex;
            parameters[3].Value = insert_gy_person.Person_age;
            parameters[4].Value = insert_gy_person.Person_email;
            parameters[5].Value = insert_gy_person.Person_telephone;
            parameters[6].Value = insert_gy_person.Person_department;
            parameters[7].Value = insert_gy_person.Person_grade;
            parameters[8].Value = insert_gy_person.Person_remark;
            parameters[9].Value = insert_gy_person.Person_password;
            c.Excute("InsertGy_person", parameters);
        }

        /// <summary>
        /// 更新员工设置
        /// </summary>
        /// <param name="Person_code"></param>
        /// <param name="Person_name"></param>
        /// <param name="Person_sex"></param>
        /// <param name="Person_age"></param>
        /// <param name="Person_email"></param>
        /// <param name="Person_telephone"></param>
        /// <param name="Person_department"></param>
        /// <param name="Person_grade"></param>
        /// <param name="Person_remark"></param>
        /// <param name="Person_password"></param> 
        public void UpdateGy_person(Gy_person update_gy_person)
        {
            SqlParameter[] parameters = { 
					new SqlParameter("@Person_code", SqlDbType.VarChar,20),
					new SqlParameter("@Person_name", SqlDbType.VarChar,50),
					new SqlParameter("@Person_sex", SqlDbType.VarChar,50),
					new SqlParameter("@Person_age", SqlDbType.Int,4),
					new SqlParameter("@Person_email", SqlDbType.VarChar,60),
					new SqlParameter("@Person_telephone", SqlDbType.VarChar,50),
					new SqlParameter("@Person_department", SqlDbType.VarChar,20),
					new SqlParameter("@Person_grade", SqlDbType.VarChar,50),
					new SqlParameter("@Person_remark", SqlDbType.VarChar,100),
					new SqlParameter("@Person_password", SqlDbType.VarChar,50)}; 
            parameters[0].Value = update_gy_person.Person_code;
            parameters[1].Value = update_gy_person.Person_name;
            parameters[2].Value = update_gy_person.Person_sex;
            parameters[3].Value = update_gy_person.Person_age;
            parameters[4].Value = update_gy_person.Person_email;
            parameters[5].Value = update_gy_person.Person_telephone;
            parameters[6].Value = update_gy_person.Person_department;
            parameters[7].Value = update_gy_person.Person_grade;
            parameters[8].Value = update_gy_person.Person_remark;
            parameters[9].Value = update_gy_person.Person_password;
            c.Excute("UpdateGy_person", parameters);
        }
　　　  
        /// <summary>
        /// 删除员工设置
        /// </summary>
        /// <param name="Person_code"></param>
        public void DeleteGy_person(Gy_person delete_gy_person)
        {
            SqlParameter[] parameters = { 
					new SqlParameter("@Person_code", SqlDbType.VarChar,20) }; 
            parameters[0].Value = delete_gy_person.Person_code;
            c.Excute("DeleteGy_person", parameters);
        }

    }
}