|
@@ -94,7 +94,7 @@ func (n *NoMsgTipJob) Execute(taskType, hour int) {
|
|
|
logger.Info("无消息提醒任务结束。。。", taskType, hour)
|
|
|
}
|
|
|
|
|
|
-//提醒
|
|
|
+// 提醒
|
|
|
func (n *NoMsgTipJob) tip(taskType, hour int, user *UserInfo) {
|
|
|
now := time.Now()
|
|
|
if user.VipStatus != 1 && user.MemberStatus != 1 && user.NicheStatus != 1 {
|
|
@@ -200,7 +200,7 @@ func (n *NoMsgTipJob) tip(taskType, hour int, user *UserInfo) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-//推送微信
|
|
|
+// 推送微信
|
|
|
func (n *NoMsgTipJob) sendWeixin(user *UserInfo, ut3, firstTitle, area, jcly string, infoCount int) bool {
|
|
|
tmplData := map[string]*qrpc.TmplItem{
|
|
|
"thing3": &qrpc.TmplItem{
|
|
@@ -229,7 +229,6 @@ func (n *NoMsgTipJob) sendWeixin(user *UserInfo, ut3, firstTitle, area, jcly str
|
|
|
return ok
|
|
|
}
|
|
|
|
|
|
-//
|
|
|
func (n *NoMsgTipJob) SubRecommend(user *UserInfo) (string, string, string, string, int, int64, string, bool) {
|
|
|
n.selectPool <- true
|
|
|
defer func() {
|
|
@@ -238,7 +237,6 @@ func (n *NoMsgTipJob) SubRecommend(user *UserInfo) (string, string, string, stri
|
|
|
return VarRecommend.SubRecommend(PushMysql, Config.JianyuDomain, user.Id, Config.NoMsgTip.Mail.Content, user.PushSet.SubSet.MailPush, 10)
|
|
|
}
|
|
|
|
|
|
-//
|
|
|
func (n *NoMsgTipJob) pushCount(user *UserInfo, start, end int64) int64 {
|
|
|
n.selectPool <- true
|
|
|
defer func() {
|
|
@@ -247,11 +245,10 @@ func (n *NoMsgTipJob) pushCount(user *UserInfo, start, end int64) int64 {
|
|
|
return PushMysql.CountBySql(`select count(1) from pushentniche where userid=? and date>=? and date<=?`, user.Entniche.UserId, start, end)
|
|
|
}
|
|
|
|
|
|
-//
|
|
|
func (n *NoMsgTipJob) saveLog(userId string, autoId int64) {
|
|
|
n.savePool <- true
|
|
|
defer func() {
|
|
|
<-n.savePool
|
|
|
}()
|
|
|
- VarRecommend.SaveLog(Mgo_Log, userId, autoId)
|
|
|
+ VarRecommend.SaveLog(Mgo_Log, userId, autoId, "entniche", false, false)
|
|
|
}
|