no message

controllers/yanxuan_special.go

@@ -427,7 +427,7 @@ func (this *YanxuanSpecialController) Enable() {
 	if req.Status == 1 {
 		go services.SendWxMsgSpecialFollow(req.Id)
 	}
-	go services.SendWxMsgSpecialAuthor(req.Id, status)
+	go services.SendWxMsgSpecialAuthor(req.Id, req.Status)
 	go services.UpdateYanxuanSpecialResourceData(req.Id) //  写入首页最新  cygx_resource_data 表
 	go services.EsAddYanxuanSpecial(req.Id)              //  写入es 综合搜索
 	br.Msg = "审批成功"

services/cygx_yanxuan_special.go

@@ -12,12 +12,9 @@ import (
 
 // 研选专栏有新内容审核通过时，给关注此专栏的客户发送模板消息
 func SendWxMsgSpecialFollow(specialId int) (err error) {
-	var msg string
 	defer func() {
 		if err != nil {
-			go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
-			go utils.SendAlarmMsg(fmt.Sprint("研选专栏有新内容审核通过时，给关注此专栏的客户发送模板消息失败", specialId, ", specialId"), 2)
-			utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
+			go utils.SendAlarmMsg(fmt.Sprint("研选专栏有新内容审核通过时，给关注此专栏的客户发送模板消息失败", specialId, ", specialId", err.Error()), 2)
 		}
 	}()
 	var first string
@@ -32,7 +29,9 @@ func SendWxMsgSpecialFollow(specialId int) (err error) {
 		err = errors.New("GetYanxuanSpecialFollowUserById, Err: " + e.Error())
 		return
 	}
-
+	if len(followers) == 0 {
+		return
+	}
 	specialItem, e := models.GetYanxuanSpecialItemById(specialId)
 	if e != nil {
 		err = errors.New("GetYanxuanSpecialFollowUserById, Err: " + e.Error())
@@ -63,6 +62,9 @@ func SendWxMsgSpecialFollow(specialId int) (err error) {
 		err = errors.New("GetSellerByAdminId, Err: " + e.Error())
 		return
 	}
+	if len(openIdList) == 0 {
+		return
+	}
 
 	//first =
 	keyword1 = "研选专栏：" + specialItem.SpecialName
@@ -101,7 +103,7 @@ func SendWxMsgSpecialFollow(specialId int) (err error) {
 func SendReviewTemplateMsgAdmin(specialId int) (err error) {
 	defer func() {
 		if err != nil {
-			go utils.SendAlarmMsg("处理试用申请给王芳，汪洋发消息失败, ErrMsg: "+err.Error(), 3)
+			go utils.SendAlarmMsg(fmt.Sprint("处理试用申请给王芳，汪洋发消息失败, specialId:", specialId, "ErrMsg", err.Error()), 2)
 		}
 	}()
 	var configCode string
@@ -123,7 +125,7 @@ func SendReviewTemplateMsgAdmin(specialId int) (err error) {
 		return
 	}
 	user, e := models.GetWxUserItemByUserId(specialItem.UserId)
-	if e != nil && e.Error() != utils.ErrNoRow() {
+	if e != nil {
 		err = errors.New("GetWxUserItemByUserId, Err: " + e.Error())
 		return err
 	}
@@ -165,12 +167,9 @@ func SendReviewTemplateMsgAdmin(specialId int) (err error) {
 
 // 研选专栏审核完成时，给提交人发送模板消息
 func SendWxMsgSpecialAuthor(specialId, status int) (err error) {
-	var msg string
 	defer func() {
 		if err != nil {
-			go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
-			go utils.SendAlarmMsg(fmt.Sprint("研选专栏审核完成时，给提交人发送模板消息", specialId, ", specialId"), 2)
-			utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
+			go utils.SendAlarmMsg(fmt.Sprint("研选专栏审核完成时，给提交人发送模板消息", specialId, ", specialId", err.Error()), 2)
 		}
 	}()
 	var first string
@@ -187,7 +186,7 @@ func SendWxMsgSpecialAuthor(specialId, status int) (err error) {
 		return
 	}
 	user, e := models.GetWxUserItemByUserId(specialItem.UserId)
-	if e != nil && e.Error() != utils.ErrNoRow() {
+	if e != nil {
 		err = errors.New("GetWxUserItemByUserId, Err: " + e.Error())
 		return err
 	}
@@ -197,7 +196,6 @@ func SendWxMsgSpecialAuthor(specialId, status int) (err error) {
 		return err
 	}
 
-	//first =
 	keyword1 = "研选专栏内容审核"
 	if status == 1 {
 		keyword2 = "已通过审核，点击查看详情"
@@ -210,9 +208,7 @@ func SendWxMsgSpecialAuthor(specialId, status int) (err error) {
 			redirectUrl = utils.WX_MSG_PATH_YX_SPECIAL_CENTER
 		}
 	}
-
 	keyword3 = "-"
-	//keyword4 = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
 	openIdArr := make([]string, 0)
 	for _, v := range openIdList {
 		openIdArr = append(openIdArr, v.OpenId)
@@ -224,7 +220,7 @@ func SendWxMsgSpecialAuthor(specialId, status int) (err error) {
 	sendInfo.Keyword3 = keyword3
 	sendInfo.Keyword4 = keyword4
 	sendInfo.Remark = remark
-	sendInfo.TemplateId = utils.WxMsgTemplateIdAskMsgXzs
+	sendInfo.TemplateId = utils.WxMsgTemplateIdArticleUserRemind
 	sendInfo.RedirectUrl = redirectUrl
 	sendInfo.RedirectTarget = 3
 	sendInfo.Resource = strconv.Itoa(specialId)
@@ -246,7 +242,7 @@ func UpdateYanxuanSpecialResourceData(sourceId int) {
 	var err error
 	defer func() {
 		if err != nil {
-			go utils.SendAlarmMsg(fmt.Sprint("更新研选专栏失败ourceId: ", sourceId), 2)
+			go utils.SendAlarmMsg(fmt.Sprint("更新研选专栏失败sourceId: ", sourceId, "ErrMsg", err.Error()), 2)
 		}
 	}()
 	var source = utils.CYGX_OBJ_YANXUANSPECIAL