|
@@ -13,6 +13,7 @@ import (
|
|
|
"jfw/public"
|
|
|
"log"
|
|
|
"qfw/util"
|
|
|
+ "qfw/util/jy"
|
|
|
"qfw/util/redis"
|
|
|
"regexp"
|
|
|
|
|
@@ -46,6 +47,7 @@ func (s *Short) Article(stype, id string) error {
|
|
|
return s.Redirect("/jyapp/free/swordfish/about", 302)
|
|
|
}
|
|
|
disWord := s.GetString("disWord")
|
|
|
+ belongUserId := ""
|
|
|
if disWord != "" {
|
|
|
redisDis := redis.GetStr("other", "DIS_"+disWord[1:])
|
|
|
if redisDis != "" {
|
|
@@ -56,7 +58,7 @@ func (s *Short) Article(stype, id string) error {
|
|
|
effectiveTime, _ := strconv.ParseInt(effectiveTimeStr, 10, 64)
|
|
|
//是否计算佣金
|
|
|
if time.Now().Unix() <= effectiveTime {
|
|
|
- belongUserId := strings.Split(redisDis, "##")[1]
|
|
|
+ belongUserId = strings.Split(redisDis, "##")[1]
|
|
|
if public.Mysql.ExecTx("口号使用", func(tx *sql.Tx) bool {
|
|
|
//口号是否使用过
|
|
|
wordInfo := public.Mysql.Find("dis_word", map[string]interface{}{"userId": userId, "password": disWord}, "id", "", 0, 0)
|
|
@@ -78,7 +80,6 @@ func (s *Short) Article(stype, id string) error {
|
|
|
}
|
|
|
return true
|
|
|
}) {
|
|
|
-
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -129,6 +130,18 @@ func (s *Short) Article(stype, id string) error {
|
|
|
var obj map[string]interface{}
|
|
|
obj = wxvisitD(sid, userId)
|
|
|
if len(obj) > 0 {
|
|
|
+ if belongUserId != "" && belongUserId != userId && util.ObjToString(obj["subtype"]) != "拟建" { //分享开打的
|
|
|
+ article_id := util.CommonDecodeArticle(stype, id)[0]
|
|
|
+ if redis.Get("other", fmt.Sprintf("integral_article_%s_%s", belongUserId, article_id)) == nil {
|
|
|
+ err := jy.Publish(public.Mgo_Log, config.Sysconfig["nsq"].(string), jy.Jyweb_article_open, belongUserId, jy.Jyapp_node1)
|
|
|
+ if err != nil {
|
|
|
+ log.Println("nsq队列写入失败-->", jy.Jyweb_article_open, belongUserId)
|
|
|
+ } else {
|
|
|
+ //integral_article_ +userId+ 三级页id
|
|
|
+ redis.Put("other", fmt.Sprintf("integral_article_%s_%s", belongUserId, article_id), "1", 60*60*24)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
//获取打赏文案
|
|
|
//util.ReadConfig(&config.Sysconfig)
|
|
|
s.T["rewardText"], s.T["advertText"] = getRewardText()
|