|
@@ -877,6 +877,12 @@ func ImportDataByExcel(s_sourceinfo string, mf multipart.File, success *bool, ms
|
|
|
qu.Debug("Load Excel Count:", importDataNum)
|
|
|
if importDataNum > 0 {
|
|
|
GetDataById(idInfoArr, "excel", s_sourceinfo, success, msg, successNum)
|
|
|
+ if *success {
|
|
|
+ if !util.Mgo.CreateIndex(s_sourceinfo, util.SourceInfoIndexArr) { //创建数据源表同时生成字段索引
|
|
|
+ qu.Debug("创建数据源表:", s_sourceinfo, "失败")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
} else {
|
|
|
*success = false
|
|
|
*msg = "查询数据失败"
|
|
@@ -946,6 +952,12 @@ func ImportDataByColl(s_sourceinfo, historyid string, success *bool, msg *string
|
|
|
importDataNum = len(idInfoArr) //查询数据总数
|
|
|
if importDataNum > 0 {
|
|
|
GetDataById(idInfoArr, "coll", s_sourceinfo, success, msg, successNum)
|
|
|
+ if *success {
|
|
|
+ if !util.Mgo.CreateIndex(s_sourceinfo, util.SourceInfoIndexArr) { //创建数据源表同时生成字段索引
|
|
|
+ qu.Debug("创建数据源表:", s_sourceinfo, "失败")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
} else {
|
|
|
*msg = "查询数据失败"
|
|
|
}
|
|
@@ -961,10 +973,6 @@ func GetDataById(idInfoArr []util.Data, importType, s_sourceinfo string, success
|
|
|
lock := &sync.Mutex{}
|
|
|
ch := make(chan bool, 10)
|
|
|
//num := int64(0) //计数
|
|
|
- if !util.Mgo.CreateIndex(s_sourceinfo, util.SourceInfoIndexArr) { //创建数据源表同时生成字段索引
|
|
|
- qu.Debug("创建数据源表:", s_sourceinfo, "失败")
|
|
|
- return
|
|
|
- }
|
|
|
for i, data := range idInfoArr {
|
|
|
wg.Add(1)
|
|
|
ch <- true
|