@@ -211,6 +211,9 @@ func (d *DataExport) SieveData() {
}
list := dataexport.FormatExportData(public.Mgo_Ent, &res_screen, config.Sysconfig["webdomain"].(string), dataType, true)
+ if msgCount > 20000 {
+ msgCount = 20000
+ }
_res["data"] = map[string]interface{}{
"list": subUrl(list, dataType),
"_id": util.SE.Encode2Hex(_id),
@@ -205,6 +205,9 @@ func (w *WxDataExport) SaveData() error {
_id := mongodb.Save(dataexport.ExportTable, saveData)
msgCount := dataexport.GetDataExportSearchCountByScdId(public.MQFW, public.Mgo_Bidding, public.DbConf.Mongodb.Bidding.DbName, public.DbConf.Elasticsearch.Main.Address, _id)
w.ServeJson(bson.M{"_id": util.SE.Encode2Hex(_id), "total": msgCount})
return nil
@@ -211,6 +211,9 @@ func (w *WxDataExport) SaveData() error {