|
@@ -365,7 +365,7 @@ func TimedTaskAgency() {
|
|
|
rdb.Do("SELECT", redis_agency_db)
|
|
|
if _, err := redis.String(rdb.Do("GET", erragency)); err == nil {
|
|
|
//增量合并
|
|
|
- Add(tmpId, tmp)
|
|
|
+ AddAgency(tmpId, tmp)
|
|
|
//存在的话删除tmp mongo表
|
|
|
if DeletedCount := FClient.Del("agency_new", bson.M{"_id": bson.ObjectIdHex(tmpId)}); !DeletedCount {
|
|
|
log.Println("删除临时表err:", DeletedCount)
|