contacter.cs

动易SiteFactory&#8482 网上商店系统1.0源代码

namespace PowerEasy.SqlServerDal.Crm
{
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using PowerEasy.Components;
    using PowerEasy.Enumerations;
    using PowerEasy.IDal.Crm;
    using PowerEasy.Model.Crm;
    using PowerEasy.SqlServerDal;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Data.Common;
    using System.Text;

    public sealed class Contacter : IContacter
    {
        private int m_TotalOfContacter;

        public bool Add(ContacterInfo contacterInfo)
        {
            Parameters parms = new Parameters();
            if (contacterInfo.ContacterId <= 0)
            {
                contacterInfo.ContacterId = DBHelper.GetMaxId("PE_Contacter", "ContacterID") + 1;
            }
            parms.AddInParameter("@ContacterID", DbType.Int32, contacterInfo.ContacterId);
            parms.AddInParameter("@ClientID", DbType.Int32, contacterInfo.ClientId);
            parms.AddInParameter("@ParentID", DbType.Int32, contacterInfo.ParentId);
            parms.AddInParameter("@CreateTime", DbType.DateTime, DateTime.Now);
            parms.AddInParameter("@Owner", DbType.String, contacterInfo.Owner);
            GetContacterParameters(contacterInfo, parms);
            return DBHelper.ExecuteProc("PR_Crm_Contacter_Add", parms);
        }

        private static ContacterInfo ContacterFromrdr(NullableDataReader rdr, int flag)
        {
            ContacterInfo info = new ContacterInfo();
            info.ContacterId = rdr.GetInt32("ContacterID");
            info.ClientId = rdr.GetInt32("ClientID");
            info.UserName = rdr.GetString("UserName");
            info.ParentId = rdr.GetInt32("ParentID");
            info.UserType = (ContacterType) rdr.GetInt32("UserType");
            info.TrueName = rdr.GetString("TrueName");
            info.Sex = (UserSexType) rdr.GetInt32("Sex");
            info.Title = rdr.GetString("Title");
            info.Company = rdr.GetString("Company");
            info.Department = rdr.GetString("Department");
            info.Position = rdr.GetString("Position");
            info.Operation = rdr.GetString("Operation");
            info.CompanyAddress = rdr.GetString("CompanyAddress");
            info.Email = rdr.GetString("Email");
            info.Homepage = rdr.GetString("Homepage");
            info.QQ = rdr.GetString("QQ");
            info.Icq = rdr.GetString("ICQ");
            info.Msn = rdr.GetString("MSN");
            info.Yahoo = rdr.GetString("Yahoo");
            info.UC = rdr.GetString("UC");
            info.Aim = rdr.GetString("Aim");
            info.OfficePhone = rdr.GetString("OfficePhone");
            info.HomePhone = rdr.GetString("HomePhone");
            info.Phs = rdr.GetString("PHS");
            info.Fax = rdr.GetString("Fax");
            info.Mobile = rdr.GetString("Mobile");
            info.Country = rdr.GetString("Country");
            info.Province = rdr.GetString("Province");
            info.City = rdr.GetString("City");
            info.Address = rdr.GetString("Address");
            info.ZipCode = rdr.GetString("ZipCode");
            info.NativePlace = rdr.GetString("NativePlace");
            info.Nation = rdr.GetString("Nation");
            info.Birthday = rdr.GetNullableDateTime("Birthday");
            info.IdCard = rdr.GetString("IDCard");
            info.Marriage = (UserMarriageType) rdr.GetInt32("Marriage");
            info.Family = rdr.GetString("Family");
            info.Income = rdr.GetInt32("Income");
            info.Education = rdr.GetInt32("Education");
            info.GraduateFrom = rdr.GetString("GraduateFrom");
            info.InterestsOfLife = rdr.GetString("InterestsOfLife");
            info.InterestsOfCulture = rdr.GetString("InterestsOfCulture");
            info.InterestsOfAmusement = rdr.GetString("InterestsOfAmusement");
            info.InterestsOfSport = rdr.GetString("InterestsOfSport");
            info.InterestsOfOther = rdr.GetString("InterestsOfOther");
            info.CreateTime = rdr.GetDateTime("CreateTime");
            info.UpdateTime = rdr.GetDateTime("UpdateTime");
            info.Owner = rdr.GetString("Owner");
            if (flag == 1)
            {
                info.ShortedForm = rdr.GetString("ShortedForm");
            }
            return info;
        }

        public bool Delete(string contacterId)
        {
            return DBHelper.ExecuteSql("DELETE PE_Contacter WHERE ContacterID IN (" + contacterId + ")");
        }

        public bool DeleteByUserName(string userName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            return DBHelper.ExecuteSql("DELETE PE_Contacter WHERE UserName = @UserName", cmdParams);
        }

        public bool Exists(int contacterId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ContacterID", DbType.Int32, contacterId);
            return DBHelper.ExistsSql("SELECT Count(*) FROM PE_Contacter WHERE ContacterID=@ContacterID", cmdParams);
        }

        public bool Exists(string userName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            return DBHelper.ExistsSql("SELECT Count(*) FROM PE_Contacter WHERE UserName=@UserName", cmdParams);
        }

        public IList<ContacterInfo> GetAllMobileContacters()
        {
            string strSql = "SELECT * FROM PE_Contacter WHERE (Mobile <>'') OR (PHS <>'')";
            List<ContacterInfo> list = new List<ContacterInfo>();
            using (NullableDataReader reader = new NullableDataReader(DBHelper.ExecuteReaderSql(strSql)))
            {
                while (reader.Read())
                {
                    list.Add(ContacterFromrdr(reader, 0));
                }
            }
            return list;
        }

        public ContacterInfo GetContacterByClientId(int clientId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ClientID", DbType.Int32, clientId);
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("SELECT * FROM PE_Contacter WHERE ClientID=@ClientID", cmdParams))
            {
                if (reader.Read())
                {
                    return ContacterFromrdr(reader, 0);
                }
                return new ContacterInfo(true);
            }
        }

        public ContacterInfo GetContacterById(int contacterId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ContacterID", DbType.Int32, contacterId);
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("SELECT * FROM PE_Contacter WHERE ContacterID=@ContacterID", cmdParams))
            {
                if (reader.Read())
                {
                    return ContacterFromrdr(reader, 0);
                }
                return new ContacterInfo(true);
            }
        }

        public ContacterInfo GetContacterByUserName(string userName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("SELECT * FROM PE_Contacter WHERE userName=@UserName", cmdParams))
            {
                if (reader.Read())
                {
                    return ContacterFromrdr(reader, 0);
                }
                return new ContacterInfo(true);
            }
        }

        public Dictionary<int, string> GetContacterListByClientId(int clientId)
        {
            Dictionary<int, string> dictionary = new Dictionary<int, string>();
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ClientID", DbType.Int32, clientId);
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("SELECT ContacterId, TrueName FROM PE_Contacter WHERE ClientID=@ClientID", cmdParams))
            {
                while (reader.Read())
                {
                    dictionary.Add(reader.GetInt32("ContacterId"), reader.GetString("TrueName"));
                }
            }
            return dictionary;
        }

        private static void GetContacterParameters(ContacterInfo contacterInfo, Parameters parms)
        {
            parms.AddInParameter("@UserType", DbType.Int32, contacterInfo.UserType);
            parms.AddInParameter("@UserName", DbType.String, contacterInfo.UserName);
            parms.AddInParameter("@TrueName", DbType.String, contacterInfo.TrueName);
            parms.AddInParameter("@Country", DbType.String, contacterInfo.Country);
            parms.AddInParameter("@Province", DbType.String, contacterInfo.Province);
            parms.AddInParameter("@City", DbType.String, contacterInfo.City);
            parms.AddInParameter("@ZipCode", DbType.String, contacterInfo.ZipCode);
            parms.AddInParameter("@Address", DbType.String, contacterInfo.Address);
            parms.AddInParameter("@Mobile", DbType.String, contacterInfo.Mobile);
            parms.AddInParameter("@OfficePhone", DbType.String, contacterInfo.OfficePhone);