DAL/AchieveDAL/UserDepartmentDAL.cs

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

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

using AchieveCommon;
using AchieveEntity;
using AchieveInterfaceDAL;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Text;

namespace AchieveDAL
{
    public class UserDepartmentDAL : IUserDepartmentDAL
    {
        /// <summary>
        /// 设置用户部门（单个用户）
        /// </summary>
        /// <param name="dep_addList">要增加的</param>
        /// <param name="dep_deleteList">要删除的</param>
        public bool SetDepartmentSingle(List<UserDepartmentEntity> dep_addList, List<UserDepartmentEntity> dep_deleteList)
        {
            Hashtable sqlStringList = new Hashtable();
            for (int i = 0; i < dep_deleteList.Count; i++)  //删除的用户角色
            {
                StringBuilder sb = new StringBuilder();
                sb.Append("delete from tbUserDepartment ");
                sb.Append("where UserId=@UserId and DepartmentId=@DepartmentId");
                SqlParameter[] para1 = {
                                       new SqlParameter("@UserId", SqlDbType.Int,10),
                                       new SqlParameter("@DepartmentId", SqlDbType.Int,10)
                                       };
                para1[0].Value = dep_deleteList[i].UserId;
                para1[1].Value = dep_deleteList[i].DepartmentId;
                sqlStringList.Add(sb, para1);
            }
            for (int i = 0; i < dep_addList.Count; i++)  //新增的用户角色
            {
                StringBuilder sb = new StringBuilder();
                sb.Append("insert into tbUserDepartment(");
                sb.Append("UserId,DepartmentId)");
                sb.Append(" values (");
                sb.Append("@UserId,@DepartmentId)");
                sb.Append(";select @@IDENTITY");
                SqlParameter[] para2 = {
                                       new SqlParameter("@UserId", SqlDbType.Int,10),
                                       new SqlParameter("@DepartmentId", SqlDbType.Int,10)
                                       };
                para2[0].Value = dep_addList[i].UserId;
                para2[1].Value = dep_addList[i].DepartmentId;
                sqlStringList.Add(sb, para2);
            }
            try
            {
                SqlHelper.ExecuteNonQuery(SqlHelper.connStr, sqlStringList);   //批量插入（事务）
                return true;
            }
            catch
            {
                return false;
            }
        }