|
@@ -71,30 +71,30 @@ func (rs *ReplyStruct) SubscribeAction() (ReplyText string, ri int) {
|
|
|
if param.Projectname != "" {
|
|
|
var url = fmt.Sprintf(config.Sysconfig["proxysess"].(string), se.EncodeString(fmt.Sprintf(moduleEncode, "myfollow")))
|
|
|
rep := tools.MyFollow(param)
|
|
|
+ pchints := config.Sysconfig["pchints"].(map[string]interface{})
|
|
|
if rep == "" {
|
|
|
- pchints := config.Sysconfig["pchints"].(map[string]interface{})
|
|
|
ReplyText = fmt.Sprintf(fmt.Sprint(pchints["project_fail"]), param.Projectname, url)
|
|
|
} else if rep == "repeat" { //重复
|
|
|
- pchints := config.Sysconfig["pchints"].(map[string]interface{})
|
|
|
ReplyText = fmt.Sprintf(fmt.Sprint(pchints["project_repeat"]), param.Projectname, url)
|
|
|
} else {
|
|
|
- pchints := config.Sysconfig["pchints"].(map[string]interface{})
|
|
|
- ReplyText = fmt.Sprintf(fmt.Sprint(pchints["project_success"]), param.Projectname, fmt.Sprintf(config.Sysconfig["proxysess"].(string), se.EncodeString(fmt.Sprintf(moduleEncode, "pcmyfollow"))))
|
|
|
+ url = fmt.Sprintf(config.Sysconfig["proxysess"].(string), se.EncodeString(fmt.Sprintf(moduleEncode, "pcmyfollow"))) + "__" + util.EncodeArticleId2ByCheck(rep)
|
|
|
+ ReplyText = fmt.Sprintf(fmt.Sprint(pchints["project_success"]), param.Projectname, url)
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
+ log.Println(fmt.Sprintf(moduleEncode, "pcmyfollow"), "ReplyText:", ReplyText)
|
|
|
case "18": //扫码关注企业
|
|
|
rs.Subkey = redis.GetStr("sso", "pc_subscribe_"+rs.Source) //企业名称
|
|
|
s_id := Findent(rs.Subkey) //查询s_id
|
|
|
if rs.Subkey != "" {
|
|
|
userId := FindUserId(rs.Openid) //查询userid
|
|
|
var url = fmt.Sprintf(config.Sysconfig["proxysess"].(string), se.EncodeString(fmt.Sprintf(moduleEncode, "entListFollow")))
|
|
|
+ pchints := config.Sysconfig["company"].(map[string]interface{})
|
|
|
if tools.MQFW.Count("jylab_followent", `{"s_userid":"`+userId+`","s_id":"`+s_id+`"}`) > 0 {
|
|
|
//已经关注过此企业
|
|
|
- pchints := config.Sysconfig["company"].(map[string]interface{})
|
|
|
ReplyText = fmt.Sprintf(fmt.Sprint(pchints["company_repeat"]), rs.Subkey, url)
|
|
|
} else if tools.MQFW.Count("jylab_followent", `{"s_userid":"`+userId+`"}`) >= util.IntAll(config.Sysconfig["followCompany"]) {
|
|
|
//超过最大关注数
|
|
|
- pchints := config.Sysconfig["company"].(map[string]interface{})
|
|
|
ReplyText = fmt.Sprintf(fmt.Sprint(pchints["company_fail"]), rs.Subkey, url)
|
|
|
} else {
|
|
|
//关注成功
|
|
@@ -107,7 +107,6 @@ func (rs *ReplyStruct) SubscribeAction() (ReplyText string, ri int) {
|
|
|
data["l_lastpushtime"] = time.Now().Unix()
|
|
|
data["s_id"] = s_id
|
|
|
if followId := tools.MQFW.Save("jylab_followent", data); len(followId) > 0 {
|
|
|
- pchints := config.Sysconfig["company"].(map[string]interface{})
|
|
|
ReplyText = fmt.Sprintf(fmt.Sprint(pchints["company_success"]), rs.Subkey, fmt.Sprintf(config.Sysconfig["proxysess"].(string), se.EncodeString(fmt.Sprintf(moduleEncode, "newInfoFollow")))+"__"+rs.Subkey+"__"+util.EncodeArticleId2ByCheck(s_id))
|
|
|
}
|
|
|
}
|