009_DI-Elec/Learun.Application.Organization/Post/PostBLL.cs

using Learun.Cache.Base;
using Learun.Cache.Factory;
using Learun.Util;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;

namespace Learun.Application.Organization
{
    /// <summary>
    /// 版 本 PIT-ADMS V7.0.3 敏捷开发框架
    /// Copyright (c) 2013-2018 Hexagon PPM
    /// 创建人：研发部
    /// 日 期：2017.03.04
    /// 描 述：岗位管理
    /// </summary>
    public class PostBLL : PostIBLL
    {
        private PostService postService = new PostService();
        private DepartmentIBLL departmentIBLL = new DepartmentBLL();

        #region 缓存定义
        private ICache cache = CacheFactory.CaChe();
        private string cacheKey = "learun_adms_post_"; // +公司主键
        #endregion

        #region 获取数据
        /// <summary>
        /// 获取岗位数据列表（根据公司列表）
        /// </summary>
        /// <param name="companyId">公司主键</param>
        /// <returns></returns>
        public List<PostEntity> GetList(string companyId)
        {
            try
            {
                List<PostEntity> list = cache.Read<List<PostEntity>>(cacheKey + companyId, CacheId.post);
                if (list == null)
                {
                    list = postService.GetList(companyId);
                    cache.Write<List<PostEntity>>(cacheKey + companyId, list, CacheId.post);
                }
                return list;
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }
        /// <summary>
        /// 获取岗位数据列表（根据公司列表）
        /// </summary>
        /// <param name="companyId">公司主键</param>
        /// <param name="keyword">关键词</param>
        /// <param name="keyword">部门Id</param>
        /// <returns></returns>
        public List<PostEntity> GetPostList(Pagination paginationobj, string queryJson)
        {
            try
            {
                List<PostEntity> list = postService.GetPostList(paginationobj, queryJson);
                return list.OrderBy(pe => pe.F_EnCode).ToList();
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }
        /// <summary>
        /// 获取岗位数据列表(根据主键串)
        /// </summary>
        /// <param name="postIds">根据主键串</param>
        /// <returns></returns>
        public IEnumerable<PostEntity> GetListByPostIds(string postIds)
        {
            try
            {
                return postService.GetListByPostIds(postIds);
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }
        /// <summary>
        /// 获取树形结构数据
        /// </summary>
        /// <param name="companyId">公司主键</param>
        /// <returns></returns>
        public List<PostEntity> GetTree(string companyId)
        {
            try
            {
                List<PostEntity> list = GetList(companyId);
                return list;
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }
        /// <summary>
        /// 获取单位级树形结构数据
        /// </summary>
        /// <param name="companyId">公司主键</param>
        /// <returns></returns>
        public List<PostEntity> GetCompanyTree()
        {
            try
            {

                var list =  postService.GetPostListByProjectId("");
                list = list.FindAll(t => t.ProjectId == "" || t.ProjectId == null).OrderBy(pe => pe.F_EnCode).ToList();
                return list;
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }

        /// <summary>
        /// 获取项目组织树形结构数据
        /// </summary>
        /// <param name="ProjectId">项目id</param>
        /// <returns></returns>
        public List<PostEntity> GetOrganizationTree(string ProjectId)
        {
            try
            {
                var list = postService.GetPostListByProjectId(ProjectId).OrderBy(pe => pe.F_EnCode).ToList();
                return list;
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }

        /// <summary>
        /// 获取岗位实体数据
        /// </summary>
        /// <param name="keyValue">主键</param>
        /// <returns></returns>
        public PostEntity GetEntity(string keyValue)
        {
            try
            {
                return postService.GetEntity(keyValue);
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }
        //查找具体项目下公司人员对应的岗位
        public DataTable GetPostByProjectId(string ProjectId)
        {
            try
            {
                return postService.GetPostByProjectId(ProjectId);
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }
        #endregion

        #region 提交数据
        /// <summary>
        /// 虚拟删除
        /// </summary>
        /// <param name="keyValue">主键</param>
        public void VirtualDelete(string keyValue)
        {
            try
            {
                PostEntity entity = GetEntity(keyValue);
                cache.Remove(cacheKey + entity.F_CompanyId, CacheId.post);
                postService.VirtualDelete(keyValue);
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }
        }
        /// <summary>
        /// 保存岗位（新增、修改）
        /// </summary>
        /// <param name="keyValue">主键值</param>
        /// <param name="postEntity">岗位实体</param>
        /// <returns></returns>
        public void SaveEntity(string keyValue, PostEntity postEntity)
        {
            try
            {
                cache.Remove(cacheKey + postEntity.F_CompanyId, CacheId.post);
                postService.SaveEntity(keyValue, postEntity);
            }
            catch (Exception ex)
            {
                if (ex is ExceptionEx)
                {
                    throw;
                }
                else
                {
                    throw ExceptionEx.ThrowBusinessException(ex);
                }
            }

        }
        #endregion

        #region 扩展方法
        /// <summary>
        /// 判断是否是有关联
        /// </summary>
        /// <param name="beginId"></param>
        /// <param name="list"></param>
        /// <returns></returns>
        private bool HasRelation(string beginId, Dictionary<string, int> map)
        {
            bool res = false;
            var entity = postService.GetEntity(beginId);
            if (entity == null || entity.F_ParentId == "0")
            {
                res = false;
            }
            else if (map.ContainsKey(entity.F_ParentId))
            {
                res = true;
            }
            else
            {
                res = HasRelation(entity.F_ParentId, map);
            }
            return res;
        }

        /// <summary>
        /// 判断是否是上级
        /// </summary>
        /// <param name="myId">自己的岗位</param>
        /// <param name="otherId">对方的岗位</param>
        /// <returns></returns>
        public bool IsUp(string myId, string otherId)
        {
            bool res = false;
            if (!string.IsNullOrEmpty(myId) && !string.IsNullOrEmpty(otherId))
            {
                string[] myList = myId.Split(',');
                string[] otherList = myId.Split(',');
                Dictionary<string, int> map = new Dictionary<string, int>();
                foreach (var otherItem in otherList)
                {
                    if (!map.ContainsKey(otherItem))
                    {
                        map.Add(otherItem, 1);
                    }
                }
                foreach (var myItem in myList)
                {
                    if (HasRelation(myItem, map))
                    {
                        res = true;
                        break;
                    }
                }
            }
            return res;
        }
        /// <summary>
        /// 判断是否是下级
        /// </summary>
        /// <param name="myId">自己的岗位</param>
        /// <param name="otherId">对方的岗位</param>
        /// <returns></returns>
        public bool IsDown(string myId, string otherId)
        {
            bool res = false;
            if (!string.IsNullOrEmpty(myId) && !string.IsNullOrEmpty(otherId))
            {
                string[] myList = myId.Split(',');
                string[] otherList = myId.Split(',');
                Dictionary<string, int> map = new Dictionary<string, int>();
                foreach (var myItem in myList)
                {
                    if (!map.ContainsKey(myItem))
                    {
                        map.Add(myItem, 1);
                    }
                }
                foreach (var otherItem in otherList)
                {
                    if (HasRelation(otherItem, map))
                    {
                        res = true;
                        break;
                    }
                }
            }
            return res;
        }
        /// <summary>
        /// 获取上级岗位人员ID
        /// </summary>
        /// <param name="strPostIds">岗位id</param>
        /// <param name="level">级数</param>
        /// <returns></returns>
        public List<string> GetUpIdList(string strPostIds, int level)
        {
            List<string> res = new List<string>();
            if (!string.IsNullOrEmpty(strPostIds) && level > 0 && level < 6)
            {// 现在支持1-5级查找
                string[] postIdList = strPostIds.Split(',');
                bool isHave = false; // 判断是否指定级数的职位
                foreach (var postId in postIdList)
                {
                    isHave = false;
                    var entity = postService.GetEntity(postId);
                    if (entity != null)
                    {
                        string parentId = entity.F_ParentId;
                        PostEntity parentEntity = null;
                        for (int i = 0; i < level; i++)
                        {
                            parentEntity = postService.GetEntity(parentId);
                            if (parentEntity != null)
                            {
                                parentId = parentEntity.F_ParentId;
                                if (i == (level - 1))
                                {
                                    isHave = true;
                                }
                            }
                            else
                            {
                                break;
                            }
                        }
                        if (isHave)
                        {
                            if (parentEntity != null)
                            {
                                res.Add(parentEntity.F_PostId);
                            }
                        }
                    }
                }
            }
            return res;
        }
        /// <summary>
        /// 获取下级岗位人员ID
        /// </summary>
        /// <param name="strPostIds">岗位id</param>
        /// <param name="level">级数</param>
        /// <returns></returns>
        public List<string> GetDownIdList(string strPostIds, int level)
        {
            List<string> res = new List<string>();
            if (!string.IsNullOrEmpty(strPostIds) && level > 0 && level < 6)
            {// 现在支持1-5级查找
                string[] postIdList = strPostIds.Split(',');
                bool isHave = false; // 判断是否指定级数的职位
                List<string> parentList = new List<string>();
                parentList.AddRange(postIdList);
                for (int i = 0; i < level; i++)
                {
                    parentList = postService.GetIdList(parentList);
                    if (parentList.Count > 0)
                    {
                        if (i == (level - 1))
                        {
                            isHave = true;
                        }
                    }
                    else
                    {
                        break;
                    }
                }
                if (isHave)
                {
                    res.AddRange(parentList);
                }
            }
            return res;
        }
        #endregion
    }
}