From 7140080df50a69bb37bbd432fb7c220ce8185f9b Mon Sep 17 00:00:00 2001
From: wangshuai <iyuki0430@msn.com>
Date: Mon, 28 Sep 2020 16:56:23 +0800
Subject: [PATCH 1/2] 'commit'

---
 .../DataEX/DataexService/DataexService.go     | 20 ++++++++-----------
 .../DataSource/DatasourceDAO/DatasourceDAO.go | 15 +++++++++++++-
 2 files changed, 22 insertions(+), 13 deletions(-)

diff --git a/dsDataex/MyService/DataEX/DataexService/DataexService.go b/dsDataex/MyService/DataEX/DataexService/DataexService.go
index 862a890c..3eebf4be 100644
--- a/dsDataex/MyService/DataEX/DataexService/DataexService.go
+++ b/dsDataex/MyService/DataEX/DataexService/DataexService.go
@@ -415,20 +415,10 @@ func DataexSetBatch(systemID string, datas []MySwagger.Data,datasource *models.T
 			json.Unmarshal([]byte(datas[no].Data), &jsonData)
 
 			esData2.DataContent=jsonData
-			//re, datasourceId := ValidationUtil.GetDatasourceIdByCode(esData2.DatasourceId)
-			//var r = false
-			//if re == true {
-			//	r, _ = ValidationUtil.ValidESDataContent(datasourceId, esData2.DataContent)
-			//}
 
 			//数据校验：1、机构校验
-			flag,_,data,_:= DataexDAO.CheckProvideOrgID(datasource.ProvideType,datasource.ProvideOrgid,datas[no].OrgID)
-
-			//fmt.Println("flag::", flag)
-
+			flag, _, data, _ := DataexDAO.CheckProvideOrgID(datasource.ProvideType,datasource.ProvideOrgid,datas[no].OrgID)
 			if flag==true {
-
-				//result, failMessages := ValidationUtil.ValidESDataContent(datasourceId, esData2.DataContent)
 				var result=true
 				var failMessages=""
 
@@ -480,8 +470,14 @@ func DataexSetBatch(systemID string, datas []MySwagger.Data,datasource *models.T
 		}
 
 		if indexData==nil {
+			if len(failIDs)>0{
+				var failResults []MySwagger.FailResult
+				for no:=0;no< len(failIDs);no++{
+					failResults=append(failResults,MySwagger.FailResult{FailID: failIDs[no],FailReason: "数据机构权限全部不正确",	})
+				}
+				DataexDAO.SaveDataError(failResults, datas, systemID, datasource.DatasourceCode )
+			}
 			failIDs=nil
-			DataexDAO.SaveDataError(nil, datas, systemID, datasource.DatasourceCode )
 			return false,"数据机构权限全部不正确",nil,nil
 		}
 
diff --git a/dsSupport/MyModel/DataSource/DatasourceDAO/DatasourceDAO.go b/dsSupport/MyModel/DataSource/DatasourceDAO/DatasourceDAO.go
index a962a9a9..930786ca 100644
--- a/dsSupport/MyModel/DataSource/DatasourceDAO/DatasourceDAO.go
+++ b/dsSupport/MyModel/DataSource/DatasourceDAO/DatasourceDAO.go
@@ -2,6 +2,7 @@ package DatasourceDAO
 
 import (
 	"dsSupport/MyModel/MySwagger"
+	"dsSupport/Utils/CommonUtil"
 	"dsSupport/Utils/DbUtil"
 	"dsSupport/Utils/ErrorConst"
 	"dsSupport/Utils/LogUtil"
@@ -44,7 +45,19 @@ func GetDatasourceResults(query MySwagger.DatasourceQuery) (bool, string, int, [
 	//分页数据
 	list, err := DbUtil.Engine.SQL(pageSql, limit, offset).Query().List()
 	if list != nil {
-		return true, "数据获取成功", count, list, err
+		listJson, _ :=json.Marshal(list)
+
+		sql1 := "SELECT * FROM t_dataex_orgtree"
+		//var offset1 = (query.Page - 1) * 10
+		//conditionSql1 := fmt.Sprintf("%s", " limit ? offset ? ")
+		//pageSql1 := fmt.Sprintf("%s %s", sql1, conditionSql1)
+		joinList1, _ := DbUtil.Engine.SQL(sql1).Query().List()
+		joinListJson1, _ := json.Marshal(joinList1)
+		mergedList := CommonUtil.ListMerge(string(listJson), string(joinListJson1), "provide_orgid", "id", "provide_orgname", "org_name")
+		var datas []map[string]interface{}
+
+		json.Unmarshal([]byte(mergedList), &datas)
+		return true, "数据获取成功", count, datas, err
 	} else {
 		return false, "数据获取失败，数据源不存在", count, nil, nil
 	}

From 8ac6afd2cfe4466ebe54e82cce09b659b50280fd Mon Sep 17 00:00:00 2001
From: wangshuai <iyuki0430@msn.com>
Date: Mon, 28 Sep 2020 16:57:14 +0800
Subject: [PATCH 2/2] 'commit'

---
 dsDataex/MyService/DataEX/DataexService/DataexService.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dsDataex/MyService/DataEX/DataexService/DataexService.go b/dsDataex/MyService/DataEX/DataexService/DataexService.go
index 3eebf4be..e24a717a 100644
--- a/dsDataex/MyService/DataEX/DataexService/DataexService.go
+++ b/dsDataex/MyService/DataEX/DataexService/DataexService.go
@@ -470,6 +470,7 @@ func DataexSetBatch(systemID string, datas []MySwagger.Data,datasource *models.T
 		}
 
 		if indexData==nil {
+			// modify by wangshuai 2020-09-28
 			if len(failIDs)>0{
 				var failResults []MySwagger.FailResult
 				for no:=0;no< len(failIDs);no++{