|
@@ -208,8 +208,11 @@ func GetEntDataExportCountIdArr(sim, bid mg.MongodbSim, bidMgoDBName, elasticAdd
|
|
log.Println("GetEntDataExportCountIdArr 企业数据导出错误 ", entId, entUserId, err)
|
|
log.Println("GetEntDataExportCountIdArr 企业数据导出错误 ", entId, entUserId, err)
|
|
return 0, 0, fmt.Errorf("企业数据导出错误")
|
|
return 0, 0, fmt.Errorf("企业数据导出错误")
|
|
}
|
|
}
|
|
- m, _ := NoRepeatData(dataPkgRemoveRepeatAddr, map[string]interface{}{"entid": entId, "ids": ids})
|
|
|
|
- newCount = len(m)
|
|
|
|
|
|
+ if m, e := NoRepeatData(dataPkgRemoveRepeatAddr, map[string]interface{}{"entid": entId, "ids": ids}); e == nil {
|
|
|
|
+ newCount = len(m)
|
|
|
|
+ } else {
|
|
|
|
+ newCount = len(ids)
|
|
|
|
+ }
|
|
log.Printf("GetEntDataExportCountIdArr 企业数据导出--数据遍历完成:entId:%v,entUserId:%v,newCount:%v,Since:%v \n", entId, entUserId, newCount)
|
|
log.Printf("GetEntDataExportCountIdArr 企业数据导出--数据遍历完成:entId:%v,entUserId:%v,newCount:%v,Since:%v \n", entId, entUserId, newCount)
|
|
return
|
|
return
|
|
}
|
|
}
|