|
@@ -1,7 +1,9 @@
|
|
|
package swordfish
|
|
|
|
|
|
import (
|
|
|
+ _ "encoding/json"
|
|
|
"gopkg.in/mgo.v2/bson"
|
|
|
+ "qfw/util"
|
|
|
"qfw/util/mongodb"
|
|
|
"qfw/util/redis"
|
|
|
"time"
|
|
@@ -34,8 +36,7 @@ func (s *SwordFish) RssSet() error {
|
|
|
if set["tender"] != nil {
|
|
|
tender, _ := set["tender"].(map[string]interface{})
|
|
|
if tender["l_enddate"] != nil {
|
|
|
- t := tender["l_enddate"].(int64) - time.Now().Unix()
|
|
|
- tender["day"] = t / (60 * 60 * 24)
|
|
|
+ tender["day"] = util.GetSubDay(tender["l_enddate"].(int64))
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -43,15 +44,24 @@ func (s *SwordFish) RssSet() error {
|
|
|
if set["bid"] != nil {
|
|
|
bid, _ := set["bid"].(map[string]interface{})
|
|
|
if bid["l_enddate"] != nil {
|
|
|
- t := bid["l_enddate"].(int64) - time.Now().Unix()
|
|
|
- bid["day"] = t / (60 * 60 * 24)
|
|
|
+ bid["day"] = util.GetSubDay(bid["l_enddate"].(int64))
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- list := mongodb.Find("bidding", nil, `{"comeintime":-1}`, `{"title":1,"href":1,"publishtime":1}`, false, 0, 10)
|
|
|
+ //list := mongodb.Find("bidding", nil, `{"comeintime":-1}`, `{"title":1,"href":1,"publishtime":1}`, false, 0, 10)
|
|
|
+ if ret := redis.Get("other", "swordfish_rsset"); ret != nil {
|
|
|
+ s.T["list"] = ret.([]interface{})
|
|
|
+ } else {
|
|
|
+ now := time.Now()
|
|
|
+ unix := time.Date(now.Year(), now.Month(), now.Day(), now.Hour()-2, now.Minute(), now.Second(), now.Nanosecond(), time.Local).Unix()
|
|
|
+ r := mongodb.Find("bidding", bson.M{"comeintime": bson.M{"$lte": unix}}, `{"comeintime":-1}`, `{"title":1,"href":1,"publishtime":1}`, false, 0, 5)
|
|
|
+ if r != nil {
|
|
|
+ s.T["list"] = *r
|
|
|
+ }
|
|
|
+ redis.Put("other", "swordfish_rsset", *r, 1000) //缓存半个小时
|
|
|
+ }
|
|
|
s.T["msgset"] = msgset
|
|
|
- s.T["list"] = *list
|
|
|
return s.Render("/swordfish/rssset.html", &s.T)
|
|
|
}
|
|
|
|