|
@@ -790,21 +790,23 @@ func Subscribe(w ResponseWriter, r *Request) {
|
|
Description: subscribeReply["description"].(string),
|
|
Description: subscribeReply["description"].(string),
|
|
}})
|
|
}})
|
|
//vip消息
|
|
//vip消息
|
|
- preheatingState := config.Sysconfig["preheatingState"].(bool)
|
|
|
|
- if preheatingState {
|
|
|
|
- preheatingReply := config.Sysconfig["preheatingReply"].(map[string]interface{})
|
|
|
|
- u, ok := tools.MQFW.FindOne("user", `{"s_m_openid":"`+openid+`"}`)
|
|
|
|
- if len(*u) > 0 && ok {
|
|
|
|
- if util.Int64All((*u)["i_vip_status"]) == 1 || util.Int64All((*u)["i_vip_status"]) == 2 {
|
|
|
|
- preheatingReply["href"] = preheatingReply["href_vip"]
|
|
|
|
- } else {
|
|
|
|
- preheatingReply["href"] = preheatingReply["href_notvip"]
|
|
|
|
|
|
+ /*
|
|
|
|
+ preheatingState := config.Sysconfig["preheatingState"].(bool)
|
|
|
|
+ if preheatingState {
|
|
|
|
+ preheatingReply := config.Sysconfig["preheatingReply"].(map[string]interface{})
|
|
|
|
+ u, ok := tools.MQFW.FindOne("user", `{"s_m_openid":"`+openid+`"}`)
|
|
|
|
+ if len(*u) > 0 && ok {
|
|
|
|
+ if util.Int64All((*u)["i_vip_status"]) == 1 || util.Int64All((*u)["i_vip_status"]) == 2 {
|
|
|
|
+ preheatingReply["href"] = preheatingReply["href_vip"]
|
|
|
|
+ } else {
|
|
|
|
+ preheatingReply["href"] = preheatingReply["href_notvip"]
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
+ time.AfterFunc(time.Second/2, func() {
|
|
|
|
+ w.PostText(fmt.Sprintf(fmt.Sprint(preheatingReply["content"]), config.Sysconfig["webdomain"].(string)+preheatingReply["href"].(string)))
|
|
|
|
+ })
|
|
}
|
|
}
|
|
- time.AfterFunc(time.Second/2, func() {
|
|
|
|
- w.PostText(fmt.Sprintf(fmt.Sprint(preheatingReply["content"]), config.Sysconfig["webdomain"].(string)+preheatingReply["href"].(string)))
|
|
|
|
- })
|
|
|
|
- }
|
|
|
|
|
|
+ */
|
|
}
|
|
}
|
|
if source != "" && len(source) > 5 {
|
|
if source != "" && len(source) > 5 {
|
|
go saveUserLog(source, openid, activeName, shareflag)
|
|
go saveUserLog(source, openid, activeName, shareflag)
|