|
@@ -280,8 +280,8 @@ func (p *ProjectTask) taskQl(udpInfo map[string]interface{}) {
|
|
q["_id"] = idmap
|
|
q["_id"] = idmap
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- if util.ObjToString(udpInfo["coll"]) != "" {
|
|
|
|
- BiddingColl = "bidding_back"
|
|
|
|
|
|
+ if c := util.ObjToString(udpInfo["coll"]); c != "" {
|
|
|
|
+ BiddingColl = c
|
|
} else {
|
|
} else {
|
|
BiddingColl = config.Conf.DB.MongoB.Coll
|
|
BiddingColl = config.Conf.DB.MongoB.Coll
|
|
}
|
|
}
|
|
@@ -298,9 +298,10 @@ func (p *ProjectTask) taskZl(udpInfo map[string]interface{}) {
|
|
if db == "" {
|
|
if db == "" {
|
|
db = MgoB.DbName
|
|
db = MgoB.DbName
|
|
}
|
|
}
|
|
- coll, _ := udpInfo["coll"].(string)
|
|
|
|
- if coll == "" {
|
|
|
|
- BiddingColl = "bidding"
|
|
|
|
|
|
+ if c := util.ObjToString(udpInfo["coll"]); c != "" {
|
|
|
|
+ BiddingColl = c
|
|
|
|
+ } else {
|
|
|
|
+ BiddingColl = config.Conf.DB.MongoB.Coll
|
|
}
|
|
}
|
|
thread := util.IntAllDef(Thread, 1)
|
|
thread := util.IntAllDef(Thread, 1)
|
|
if thread > 0 {
|
|
if thread > 0 {
|