using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WMS.IData.IBase;

using WMS.Model.Base;
using WMS.IData;using Oracle.ManagedDataAccess.Client;
using System.Data;

namespace WMS.SqlServerData.BaseData
{
    public class UserDepartData : IUserDepart
    {
        #region  查询
        /// <summary>
        /// 查询
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public DataTable GetList(UserDepartModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("select a.DEP_ID,a.USER_ID,b.name,c.com_name,c.GROUP_ID,c.COM_DPC,c.COM_TYPE ");
            strSql.Append(" FROM T_BASE_USERDEPART a  ");
            strSql.Append(" left join t_base_userinfo b on a.user_id=b.user_id  ");
            strSql.Append(" left join T_BASE_COMPANY c on a.dep_id = c.com_id where 1=1 ");
            if (!string.IsNullOrEmpty(model.DEP_ID))
            {
                strSql.Append(" and a.DEP_ID ='" + model.DEP_ID + "'");
            }
            if (!string.IsNullOrEmpty(model.USER_ID))
            {
                strSql.Append(" and a.USER_ID ='" + model.USER_ID + "'");
            }

            return SystemDataObject.Instance.GetDataSet(strSql.ToString()).Tables[0];
        }
        #endregion

        #region 增加一条数据
        /// <summary>
        /// 增加一条数据
        /// </summary>
        public void AddRoleDepart(List<UserDepartModel> list)
        {

            StringBuilder strSql = new StringBuilder();
            List<string> list_str = new List<string>();
            List<OracleParameter[]> list_par = new List<OracleParameter[]>();
            foreach (UserDepartModel model in list)
            {
                strSql = new StringBuilder();
                strSql.Append("insert into T_BASE_USERDEPART(");
                strSql.Append("USER_ID,DEP_ID)");
                strSql.Append(" values (");
                strSql.Append(":USER_ID,:DEP_ID)");
                OracleParameter[] parameters = {
					new OracleParameter(":USER_ID",OracleDbType.Varchar2),
                    new OracleParameter(":DEP_ID",OracleDbType.Varchar2)};
                parameters[0].Value = model.USER_ID;
                parameters[1].Value = model.DEP_ID;

                list_str.Add(strSql.ToString());
                list_par.Add(parameters);
            }
            SystemDataObject.Instance.ExecuteList(list_str, list_par);
        }
        #endregion

        public void UpdateRoleDepart(List<UserDepartModel> list)
        {
            throw new NotImplementedException();
        }

        #region 删除
        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="model"></param>
        public void DeleteRoleDepart(UserDepartModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("delete from T_BASE_USERDEPART ");
            strSql.Append(" where DEP_ID=:DEP_ID and USER_ID=:USER_ID ");
            OracleParameter[] parameters = {
					new OracleParameter(":DEP_ID",OracleDbType.Varchar2),
					new OracleParameter(":USER_ID",OracleDbType.Varchar2)};
            parameters[0].Value = model.USER_ID;
            parameters[1].Value = model.DEP_ID;

            SystemDataObject.Instance.ExecuteSql(strSql.ToString());
        }
        #endregion
    }
}