JKGXPTHT/Map/GISShare/UserService/UserManagerSub.asmx.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Web;
using System.Web.Script.Serialization;
using System.Web.Services;

namespace UserService
{
    /// <summary>
    /// UserManager 的摘要说明
    /// </summary>
    [WebService(Namespace = "http://tempuri.org/")]
    [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
    [System.ComponentModel.ToolboxItem(false)]
    // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消注释以下行。 
    // [System.Web.Script.Services.ScriptService]
    public class UserManagerSub : System.Web.Services.WebService
    {
       
        [WebMethod]
        public string userSynchronize(string users)
        {
            JavaScriptSerializer js = new JavaScriptSerializer();
            List<UserInfo> userlist;
            List<UserResult> resultlist = new List<UserResult>();
            string connstr = System.Configuration.ConfigurationManager.AppSettings["constr"].ToString();
            string dbtype = System.Configuration.ConfigurationManager.AppSettings["database"].ToString();
            DbOperator dbOpe = new DbOperator(connstr, dbtype);
            
            try
            {

               userlist = js.Deserialize<List<UserInfo>>(users);
               if (userlist == null || userlist.Count == 0)
               {
                   return new JavaScriptSerializer().Serialize(resultlist);
               }
               
            }
            catch (Exception ex)
            {
                return new JavaScriptSerializer().Serialize(resultlist);  
            }


            if (!dbOpe.Connect())
            {
                foreach (UserInfo info in userlist)
                {
                    UserResult result = new UserResult(info.username, "0", "数据库连接失败");
                    resultlist.Add(result);

                }
            }
            else
            {
                foreach (UserInfo info in userlist)
                {
                    UserResult result = setUser(info, dbOpe);
                    resultlist.Add(result);
                }
                dbOpe.Close();
            }

            
            return new JavaScriptSerializer().Serialize(resultlist);  

        }

        private UserResult setUser(UserInfo info, DbOperator dbOpe)
        {
            UserResult result;
            
            switch(info.oper)
            {
                case "A":
                    result=  AddUser(info, dbOpe);
                    break;
                case "D":
                    result = DelUser(info, dbOpe);
                    break;
                case "U":
                    result = EditUser(info, dbOpe);
                    break;
                case "Q":
                    result = QueryUser(info, dbOpe);
                    break;
                default:
                    result = new UserResult(info.username);
                    result.res = "0";
                    result.desc = "操作类型不合法";
                    break;

            }
            return result;
        }
        public UserResult AddUser(UserInfo info, DbOperator dbOpe)
        {

            UserResult result = new UserResult(info.username);

            string sql = "SELECT * from [USER_INFO] where [U_NAME]='" + info.username + "'";
            DataTable dt = dbOpe.Select(sql);
            if (dt == null || dt.Rows.Count == 0)
            {
                sql = "insert into [dbo].[USER_INFO] ([U_NAME],[U_DEP],[U_ROLE],[FIRST_NAME],[LAST_NAME],[PRIVACY]) values('" + info.username + "','" + info.department + "','2','" + info.firstname + "','" + info.lastname + "',0);";
                sql += "insert into 日志管理(\"GUID\",操作人,操作,操作页面,更新时间) values(newid(),'统一身份认证','新增用户:" + info.username + "','新增用户',GetDate())";
                int i = dbOpe.Update(sql, ";");
                if (i == 2)
                {
                    result.res = "1";
                    result.desc = "新增成功";
                }
                else
                {
                    result.res = "0";
                    result.desc = "新增失败";
                }
            }
            else if(dt.Rows.Count == 1)
            {
                result.res = "0";
                result.desc = "用户已存在";
            }
            return result;

          

        }
        public UserResult DelUser(UserInfo info, DbOperator dbOpe)
        {
            UserResult result = new UserResult(info.username);
            string sql = "delete from [dbo].[USER_INFO] where  [U_NAME]='" + info.username + "'";
          
            int i = dbOpe.Update(sql, ";");
            if (i >0)
            {
                result.res = "1";
                result.desc = "删除成功";
              
                sql = "insert into 日志管理(\"GUID\",操作人,操作,操作页面,更新时间) values(newid(),'统一身份认证','删除用户:" + info.username + "','删除用户',GetDate())";
               
                dbOpe.Update(sql, ";");
            }
            else
            {
                result.res = "0";
                result.desc = "用户不存在";
            }

            return result;

        }

        public UserResult EditUser(UserInfo info, DbOperator dbOpe)
        {

            UserResult result = new UserResult(info.username);
            string sql = "update [dbo].[USER_INFO] set [FIRST_NAME]='" + info.firstname + "',[LAST_NAME]='" + info.lastname + "',[U_DEP]='" + info.department + "' where [U_NAME]='" + info.username + "'";
          
            int i = dbOpe.Update(sql, ";");
            if (i >0)
            {
                result.res = "1";
                result.desc = "修改成功";
                sql = "insert into 日志管理(\"GUID\",操作人,操作,操作页面,更新时间) values(newid(),'统一身份认证','修改用户:" + info.username + "','修改用户',GetDate())";
               
                dbOpe.Update(sql, ";");
            }
            else
            {
                result.res = "0";
                result.desc = "修改的用户不存在";
            }

            return result;

        }
        public UserResult QueryUser(UserInfo info, DbOperator dbOpe)
        {

            UserResult result = new UserResult(info.username);

            string sql = "SELECT * from [dbo].[USER_INFO] where [U_NAME]='" + info.username + "'";
            DataTable dt = dbOpe.Select(sql);
            if (dt == null || dt.Rows.Count == 0)
            {
                result.res = "0";
                result.desc = "用户不存在";
               
            }
            else if (dt.Rows.Count == 1)
            {
                result.res = "1";
                result.desc = "用户存在";
            }
            return result;



        }
    }
}