|
|
@@ -377,8 +377,8 @@ func (this *dataExportPackStruct) DoEntPackRepeatCheck(sess *httpsession.Session
|
|
|
exportLock.Unlock()
|
|
|
entLock.Lock()
|
|
|
//开始去重
|
|
|
- _, newCount, _ := dataexport.GetEntDataExportCount(util.MQFW, util.Mgo_bidding, config.Config.Mongobidding.DbName, config.Config.Elasticsearch,
|
|
|
- selectId, entIdInt, entUserId, true, middleGround.JyApiConfig.ApiList.EntDedupUrl, config.ExConf.MsgMaxCount)
|
|
|
+ _, newCount, err := dataexport.GetEntDataExportCountIdArr(util.MQFW, util.Mgo_bidding, config.Config.Mongobidding.DbName, config.Config.Elasticsearch,
|
|
|
+ selectId, entIdInt, entUserId, middleGround.JyApiConfig.ApiList.EntDedupUrl, config.ExConf.MsgMaxCount)
|
|
|
entLock.Unlock()
|
|
|
return newCount, err
|
|
|
}
|
