车辆资产管理：工具同步站坪的用户帐号信息的片段代码

2017-10-11 18:31:37  访问(1469) 赞(0) 踩(0)

        /// <summary>
        /// 
        /// </summary>
        protected string dbConn
        {
            get
            {
                return "Data Source=xxxx;User ID=xxx;Password=xxxx;";
            }
        }

        /// <summary>
        /// 
        /// </summary>
        protected string wgssDbConn
        {
            get
            {
                return "Data Source=xxxx;User ID=xxx;Password=xxx;";
            }
        }


        /// <summary>
        /// 
        /// </summary>
        /// <param name="strName"></param>
        /// <param name="xdbHelper"></param>
        /// <returns></returns>
        protected DataSet GetSysUser(string strName, DBHelper xdbHelper)
        {
            DataSet theResult = null;

            bool bIsCreate = true;

            if (xdbHelper == null)
            {
                xdbHelper
                    =
                    SlowX.DAL.Helpers.DBHelper.CreateDBHelper
                    (
                        wgssDbConn, 
                        SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper.Oracle, 
                        1
                    );
            }
            else
            {
                // 没有打开链接 //
                bIsCreate = xdbHelper.IsNotOpen();
            }

            try
            {
                if (bIsCreate)
                    xdbHelper.OpenDBHelper();

                string sql = "select * from sys_user t where t.UserName = '" + strName.Replace("'", "''") + "'";
                
                theResult = xdbHelper.ExecuteDataSet(sql);


                if (bIsCreate)
                    xdbHelper.EndDBHelper();

            }
            catch (Exception err)
            {
                if (bIsCreate)
                    xdbHelper.TranDBHelper();

                throw err;
            }
            finally
            {
                if (bIsCreate)
                    xdbHelper.FinallyDBHelper();
            }

            return theResult;
        }
 

        /// <summary>
        /// 
        /// </summary>
        /// <param name="xdbHelper"></param>
        protected void btnLoadUserNameClick(DBHelper xdbHelper)
        {

           
            bool bIsCreate = true;

            if (xdbHelper == null)
            {
                xdbHelper
                    =
                    SlowX.DAL.Helpers.DBHelper.CreateDBHelper
                    (
                        dbConn, SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper.Oracle,1
                    );
            }
            else
            {
                // 没有打开链接 //
                bIsCreate = xdbHelper.IsNotOpen();
            }

            try
            {
                if (bIsCreate)
                    xdbHelper.OpenDBHelper();

                eKing.EkVehicleLib.Business.CommonModule.User.BPMS_USER
                    bll
                    =
                    eKing.EkVehicleLib.Business.CommonModule.User.BPMS_USER.instance;

                eKing.EkVehicleLib.Entity.CommonModule.User.BPMS_USER
                    entity
                    =
                    new eKing.EkVehicleLib.Entity.CommonModule.User.BPMS_USER();

                ISaveDriver isave = entity;
                IQueryDriver iq = entity;
                iq.AddIQueryItemWithEntityFieldInfo
                    (
                        entity._Account, 
                        SlowX.DAL.Enums.SqlLink.EmSqlLink.Like_, "_ml_"
                        );

                List<BaseModel> theList
                    = 
                    bll.ListBaseModel(entity, xdbHelper);

                StringBuilder theResult = new StringBuilder();

                StringBuilder sbAddOne = new StringBuilder();
                StringBuilder sbAddTwo = new StringBuilder();
                StringBuilder sbNoAdd = new StringBuilder();
                StringBuilder sbNoEqual = new StringBuilder();

                DataSet dsUser = null;

                string strRealName = null;
                string strId = null;

                foreach (eKing.EkVehicleLib.Model.CommonModule.User.BPMS_USER
                    model in theList)
                {
                    dsUser = GetSysUser(model.RealName, null);

                    if (dsUser == null || dsUser.Tables.Count == 0 || dsUser.Tables[0].Rows.Count == 0)
                    {
                        sbNoAdd.AppendLine(model.RealName);
                        continue;
                    }

                    int iCount = dsUser.Tables[0].Rows.Count;

                    if (iCount > 2)
                    {
                        sbNoEqual.AppendLine(model.RealName + "#####" + iCount.ToString());
                        continue;
                    }

                    isave.ClearAllISaveItem();
                    iq.ClearAllIQueryItem();

                    iq.WhereAddStr(entity._UserId, model.UserId);

                    for (int i = 0; i < iCount; ++i)
                    {
                        if (i == 0)
                        {
                            isave.AddISaveItem(entity._Ml_Account, dsUser.Tables[0].Rows[0]["ACCOUNT"].ToString());
                        }
                        else
                        {
                            isave.AddISaveItem(entity._Ml_Account2, dsUser.Tables[0].Rows[1]["ACCOUNT"].ToString());
                        }

                    }

                    bll.Update(entity, xdbHelper);

                    if (iCount == 1)
                        sbAddOne.AppendLine(model.RealName);
                    else
                        sbAddTwo.AppendLine(model.RealName);
                }

                StringBuilder sb = new StringBuilder();
                sb.AppendLine("sbAddOne");
                sb.AppendLine(sbAddOne.ToString());
                sb.AppendLine();

                sb.AppendLine("sbAddTwo");
                sb.AppendLine(sbAddTwo.ToString());
                sb.AppendLine();

                sb.AppendLine("sbNoAdd");
                sb.AppendLine(sbNoAdd.ToString());
                sb.AppendLine();

                sb.AppendLine("sbNoEqual");
                sb.AppendLine(sbNoEqual.ToString());
                sb.AppendLine();


                TextBox1.Text = sb.ToString();

                if (bIsCreate)
                    xdbHelper.EndDBHelper();

            }
            catch (Exception err)
            {
                if (bIsCreate)
                    xdbHelper.TranDBHelper();

                throw err;
            }
            finally
            {
                if (bIsCreate)
                    xdbHelper.FinallyDBHelper();
            }
             

        }

上一条：

下一条：

相关评论

发表评论

类型：	留言 建议 疑问
内容：
	(Alt+Enter)