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
|
}
|
}
|
