From 77a5d0b49691eed59891ea3c156381edef871c72 Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期四, 21 九月 2023 18:41:08 +0800
Subject: [PATCH] 同步erp根据账号所属组织查找组织下所有订单

---
 VueWebApi/DLL/DAL/ErpSyncMesDAL.cs |   29 ++++++++++++++++++-----------
 1 files changed, 18 insertions(+), 11 deletions(-)

diff --git a/VueWebApi/DLL/DAL/ErpSyncMesDAL.cs b/VueWebApi/DLL/DAL/ErpSyncMesDAL.cs
index 5ddf6cc..2002ae7 100644
--- a/VueWebApi/DLL/DAL/ErpSyncMesDAL.cs
+++ b/VueWebApi/DLL/DAL/ErpSyncMesDAL.cs
@@ -1,6 +1,7 @@
 锘縰sing Dapper;
 using System;
 using System.Collections.Generic;
+using System.Data;
 using System.Linq;
 using System.Web;
 using VueWebApi.Tools;
@@ -202,21 +203,27 @@
             var dynamicParams = new DynamicParameters();
             try
             {
-                if (stu_torgcode == "" || stu_torgcode == null) 
+                if (stu_torgcode == "" || stu_torgcode == null)
                 {
-                    mes.code = "300";
-                    mes.count = 0;
-                    mes.Message = "绠$悊鍛樿处鍙锋棤鎿嶄綔鏉冮檺,璇蜂娇鐢ㄨ溅闂寸骇璐﹀彿!";
-                    mes.data = null;
-                    return mes;
+                    stu_torgcode = "";
                 }
                 if (stu_torgtypecode == "D")
                 {
-                    mes.code = "300";
-                    mes.count = 0;
-                    mes.Message = "閮ㄩ棬璐﹀彿鏃犳搷浣滄潈闄�,璇蜂娇鐢ㄨ溅闂寸骇璐﹀彿!";
-                    mes.data = null;
-                    return mes;
+                    sql = @" with CTE as (
+                           select id, org_code,org_name, parent_id
+                           from TOrganization A
+                           where org_code =@stu_torgcode
+                           union all
+                           select A.id,A.org_code,A.org_name,A.parent_id
+                           from TOrganization A
+                           inner join CTE on A.parent_id = CTE.id
+                           )
+                           select org_code,org_name from CTE";
+                    dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                    var data = DapperHelper.selectdata(sql, dynamicParams);
+                    stu_torgcode=string.Join(",", data.AsEnumerable().Select(row => row.Field<string>("org_code")));
+                    //stu_torgcode = string.Join(",", data.AsEnumerable().Select(row => $"'{row.Field<string>("org_code")}'"));
+                    //LogHelper.WriteLogData("鑾峰彇杞﹂棿缂栫爜锛�"+stu_torgcode);
                 }
                 //瀛樺偍杩囩▼鍚�
                 sql = @"h_p_IFCLD_ERPMO";

--
Gitblit v1.9.3