no message

services/wechat_send_category_template_msg.go

@@ -203,7 +203,6 @@ func SendWxCategoryMsgSpecialFollow(specialId int) (err error) {
 	return
 }
 
-
 // SendReviewCategoryTemplateMsgAdmin 提交审核时给王芳，汪洋发消息
 func SendReviewCategoryTemplateMsgAdmin(specialId int) (err error) {
 	defer func() {
@@ -261,7 +260,6 @@ func SendReviewCategoryTemplateMsgAdmin(specialId int) (err error) {
 	return
 }
 
-
 // 发送用户操作活动消息提醒
 func SendWxCategoryMsgWithActivityUserRemind(keyWord1, keyWord2, keyWord3, keyWord4, redirectUrl string, openIdList []*models.OpenIdList, activityId int) (err error) {
 	if len(openIdList) == 0 {
@@ -408,25 +406,30 @@ func SendNeiRongZuActivitieSignCategoryTemplateMsg(user *models.WxUserItem, acti
 }
 
 func SendActivitieCancelSignCategoryTemplateMsg(user *models.WxUserItem, activityDetail *models.ActivityDetail) (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("发送用户操作活动消息提醒,文章ID：", activityDetail.ActivityId), 2)
-			utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
+			fmt.Println(err)
+			go utils.SendAlarmMsg(fmt.Sprint("发送用户操作活动消息提醒,活动ID：", activityDetail.ActivityId), 2)
 		}
 	}()
-	accessToken, err := models.GetWxAccessTokenByXzs()
+
+	accessToken, e := models.GetWxAccessTokenByXzs()
 	if err != nil {
-		msg = "GetWxAccessToken Err:" + err.Error()
+		err = errors.New("GetWxAccessTokenByXzs, Err: " + e.Error())
 		return
 	}
 	if accessToken == "" {
-		msg = "accessToken is empty"
+		err = errors.New("accessToken is empty ")
 		return
 	}
-	sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
-	if err != nil && err.Error() != utils.ErrNoRow() {
+	sellerItemQy, e := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetSellerByCompanyIdCheckFicc, Err: " + e.Error())
+		return
+	}
+	if sellerItemQy == nil {
+		err = nil
 		return
 	}
 	configCode := utils.TPL_MSG_NEI_RONG_ZU
@@ -440,6 +443,10 @@ func SendActivitieCancelSignCategoryTemplateMsg(user *models.WxUserItem, activit
 		err = errors.New("GetUserRecordListByMobile, Err: " + e.Error() + cnf.ConfigValue)
 		return
 	}
+	if len(openIdList) == 0 {
+		err = nil
+		return
+	}
 
 	openIdArr := make([]string, 0)
 	for _, v := range openIdList {
@@ -529,7 +536,7 @@ func SendCommentWxCategoryTemplateMsg(req models.AddCygxArticleCommentReq, user
 }
 
 // 发送活动提问消息提醒
-func SendWxCategoryMsgWithAsk(realName,companyName, sellerName, askMsg string, openIdList []*models.OpenIdList, askId int) (err error) {
+func SendWxCategoryMsgWithAsk(realName, companyName, sellerName, askMsg string, openIdList []*models.OpenIdList, askId int) (err error) {
 	if len(openIdList) == 0 {
 		return
 	}
@@ -636,7 +643,7 @@ func SendActivitieSignCategoryTemplateMsg(user *models.WxUserItem, activityDetai
 func SendWxCategoryMsgInteractive(user *models.WxUserItem, interactive string, articleId int, title string) (err error) {
 	if interactive == "阅读报告" {
 		//30秒内阅读同一篇报告不做重复推送
-		key := "CYGX_" + utils.CYGX_OBJ_RESEARCHSUMMARY + "_READ" + strconv.Itoa(articleId) + "_" + strconv.Itoa(user.UserId)+ "_CATEGORY"
+		key := "CYGX_" + utils.CYGX_OBJ_RESEARCHSUMMARY + "_READ" + strconv.Itoa(articleId) + "_" + strconv.Itoa(user.UserId) + "_CATEGORY"
 		if utils.Rc.IsExist(key) {
 			return
 		}
@@ -811,4 +818,3 @@ func SendWxCategoryMsgWithActivityAsk(companyName, realName, sellerName, askTime
 	}
 	return
 }
-