master
wangshuai 5 years ago
parent fc96a10a42
commit bf873a1b41

@ -9,7 +9,6 @@ import (
"dsDataex/Utils/CommonUtil" "dsDataex/Utils/CommonUtil"
"dsDataex/Utils/ES7Util" "dsDataex/Utils/ES7Util"
"dsDataex/Utils/KafkaUtil" "dsDataex/Utils/KafkaUtil"
"dsDataex/Utils/ValidationUtil"
"encoding/json" "encoding/json"
"fmt" "fmt"
"strconv" "strconv"
@ -387,11 +386,11 @@ func DataexSetBatch(systemID string, datas []MySwagger.Data,datasource *models.T
//校验ESDataContent //校验ESDataContent
//add by wangshuai 2020-09-16 //add by wangshuai 2020-09-16
_, _, successDatas, failureIDs := ValidationUtil.ValidESDataContent(esData.DatasourceId, datas) //_, _, successDatas, failureIDs := ValidationUtil.ValidESDataContent(esData.DatasourceId, datas)
//将校验通过数据赋值给datas //将校验通过数据赋值给datas
datas = successDatas //datas = successDatas
//将校验失败数据赋值给failIDs //将校验失败数据赋值给failIDs
dataContentFailIDs = failureIDs //dataContentFailIDs = failureIDs
//四、循环添加索引文档 //四、循环添加索引文档
for no:=0;no< len(datas) && no<1000 ;no++{ for no:=0;no< len(datas) && no<1000 ;no++{

Loading…
Cancel
Save