Hidistro.SqlDal/Settings/CustomerServiceDao.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

namespace Hidistro.SqlDal.Settings
{
    using Hidistro.Core;
    using Hidistro.Entities;
    using Hidistro.Entities.Settings;
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using System;
    using System.Data;
    using System.Data.Common;
    using System.Text;

    public class CustomerServiceDao
    {
        private Database database = DatabaseFactory.CreateDatabase();
        public string Error = "";

        public int CreateCustomer(CustomerServiceInfo info, ref string msg)
        {
            msg = "未知错误";
            try
            {
                DbCommand sqlStringCommand = this.database.GetSqlStringCommand("SELECT userver  FROM MeiQia_Userver WHERE userver=@Name");
                this.database.AddInParameter(sqlStringCommand, "Name", DbType.String, info.userver);
                if (Convert.ToInt32(this.database.ExecuteScalar(sqlStringCommand)) >= 1)
                {
                    msg = "登录手机号重复";
                    return 0;
                }
                sqlStringCommand = this.database.GetSqlStringCommand("INSERT INTO [MeiQia_Userver]([unit],[userver],[password],[nickname],[realname],[level],[tel]) VALUES (@unit,@userver,@password,@nickname,@realname,@level,@tel); SELECT CAST(scope_identity() AS int);");
                this.database.AddInParameter(sqlStringCommand, "unit", DbType.String, info.unit);
                this.database.AddInParameter(sqlStringCommand, "userver", DbType.String, info.userver);
                this.database.AddInParameter(sqlStringCommand, "password", DbType.String, info.password);
                this.database.AddInParameter(sqlStringCommand, "nickname", DbType.String, info.nickname);
                this.database.AddInParameter(sqlStringCommand, "realname", DbType.String, info.realname);
                this.database.AddInParameter(sqlStringCommand, "level", DbType.String, info.level);
                this.database.AddInParameter(sqlStringCommand, "tel", DbType.String, info.tel);
                int num = (int) this.database.ExecuteScalar(sqlStringCommand);
                msg = "";
                return num;
            }
            catch (Exception exception)
            {
                msg = exception.Message;
                return 0;
            }
        }

        public bool DeletCustomer(int id)
        {
            try
            {
                DbCommand sqlStringCommand = this.database.GetSqlStringCommand("Delete  FROM MeiQia_Userver WHERE id = @ID");
                this.database.AddInParameter(sqlStringCommand, "ID", DbType.Int32, id);
                return (this.database.ExecuteNonQuery(sqlStringCommand) > 0);
            }
            catch (Exception)
            {
                return false;
            }
        }