|
|
@@ -4,6 +4,8 @@ import (
|
|
|
"fmt"
|
|
|
"time"
|
|
|
|
|
|
+ "app.yhyue.com/moapp/jybase/redis"
|
|
|
+
|
|
|
util "app.yhyue.com/moapp/jybase/common"
|
|
|
"app.yhyue.com/moapp/jybase/logger"
|
|
|
. "app.yhyue.com/moapp/jybase/mongodb"
|
|
|
@@ -68,7 +70,15 @@ func Match(msl *Mysql, mgoMain, mgoLog *MongodbSim, ui *UserInfo, sl *SortList,
|
|
|
if oms[buyer] == nil {
|
|
|
continue
|
|
|
}
|
|
|
- result[buyer] = oms[buyer]
|
|
|
+ if result[buyer] == nil {
|
|
|
+ result[buyer] = oms[buyer]
|
|
|
+ }
|
|
|
+ _id, _ := v.Info["_id"].(string)
|
|
|
+ key := fmt.Sprintf("ownermonitor_%s_%s_%s", userId, buyer, _id)
|
|
|
+ if exists, _ := redis.Exists("pushcache_1", key); exists {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ redis.Put("pushcache_1", key, 1, ThreeDay)
|
|
|
result[buyer].Infos = append(result[buyer].Infos, v.Info)
|
|
|
}
|
|
|
omis := []*OwnerMonitor{}
|
