添加项目文件。

yl

2024-10-21 0285fdd48ffdf4b671a3af2e0379985f2df9445b

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
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&& data.Rows[0]["torg_codelist"].ToString()!="")
                {
                    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
    }
}