using Dapper;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace VueWebCoreApi.Tools
{
    public class TOrganizationRecursion
    {
        public static ToMessage mes = new ToMessage(); //定义全局返回信息对象

        #region [根据当前组织编码获取所有子节点组织(包含自身,带单引号)]
        /// <summary>
        /// 根据当前组织编码获取所有子节点组织(包含自身,带单引号)
        /// </summary>
        /// <param name="torg_code">组织编码</param>
        /// <returns></returns>
        public static ToMessage TOrgCodeSeach(string torg_code)
        {
            string sql;
            var dynamicParams = new DynamicParameters();
            try
            {
                sql = @" WITH RecursiveCTE AS (
                          SELECT id, parent_id, torg_code, torg_name, status, leve, torg_seq 
                          FROM TOrganization 
                          WHERE torg_code = @torg_code 
                          UNION ALL 
                          SELECT o.id, o.parent_id, o.torg_code, o.torg_name, o.status, o.leve, o.torg_seq 
                          FROM TOrganization o 
                          INNER JOIN RecursiveCTE r ON r.torg_code = o.parent_id 
                          ) 
                          SELECT STUFF((SELECT ',' + QUOTENAME(torg_code, '''')  FROM RecursiveCTE 
                          FOR XML PATH('')), 1, 1, '') AS torg_codelist";
                dynamicParams.Add("@torg_code", torg_code);
                var data = DapperHelper.selectdata(sql, dynamicParams);
                if (data.Rows.Count > 0&&data.Rows[0]["torg_codelist"].ToString()!=null)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.message = "查询成功!";
                    mes.data = data.Rows[0]["torg_codelist"].ToString();
                }
                else
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.message = "当前用户所属组织编码【" + torg_code + "】不存在!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion

        #region [根据当前组织编码获取所有子节点组织(包含自身,不带单引号)]
        /// <summary>
        /// 根据当前组织编码获取所有子节点组织(包含自身,不带单引号)
        /// </summary>
        /// <param name="torg_code">组织编码</param>
        /// <returns></returns>
        public static ToMessage TOrgCodeSeachNo(string torg_code)
        {
            string sql;
            var dynamicParams = new DynamicParameters();
            try
            {
                sql = @" WITH RecursiveCTE AS (
                      SELECT id, parent_id, torg_code, torg_name, status, leve, torg_seq 
                      FROM TOrganization 
                      WHERE torg_code = @torg_code
                      UNION ALL 
                      SELECT o.id, o.parent_id, o.torg_code, o.torg_name, o.status, o.leve, o.torg_seq 
                      FROM TOrganization o 
                      INNER JOIN RecursiveCTE r ON r.torg_code = o.parent_id 
                  ) 
                  SELECT STUFF((SELECT ',' + torg_code FROM RecursiveCTE 
                  FOR XML PATH('')), 1, 1, '') AS torg_codelist";
                dynamicParams.Add("@torg_code", torg_code);
                var data = DapperHelper.selectdata(sql, dynamicParams);
                if (data.Rows.Count > 0 && data.Rows[0]["torg_codelist"].ToString() != null)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.message = "查询成功!";
                    mes.data = data.Rows[0]["torg_codelist"].ToString();
                }
                else
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.message = "当前用户所属组织编码【" + torg_code + "】不存在!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
    }
}