no message

controllers/activity.go

@@ -2,7 +2,6 @@ package controllers
 
 import (
 	"encoding/json"
-	"errors"
 	"fmt"
 	"github.com/rdlucklib/rdluck_tools/paging"
 	"hongze/hongze_web_mfyx/models"
@@ -1927,22 +1926,6 @@ func (this *ActivityController) AskAdd() {
 			}
 		}
 		if isSendMsg {
-			listEmail, err := models.GetAskEmail()
-			if err != nil {
-				br.Msg = "提交失败"
-				br.ErrMsg = "提交带问失败,Err:" + err.Error()
-				return
-			}
-			var sendMobile string
-			for _, v := range listEmail {
-				if strings.Index(activityInfo.Host, v.Name) > 0 {
-					sendMobile = v.Mobile
-				}
-			}
-			if activityInfo.ChartPermissionId == 31 {
-				sendMobile = utils.ActSendMsgMobile
-			}
-
 			//获取销售信息
 			sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
 			if err != nil && err.Error() != utils.ErrNoRow() {
@@ -1950,30 +1933,10 @@ func (this *ActivityController) AskAdd() {
 				br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
 				return
 			}
-			//给研究员发送消息
-			if sendMobile != "" {
-				openIpItem, _ := models.GetUserRecordByMobile(4, sendMobile)
-				if openIpItem != nil && openIpItem.OpenId != "" {
-					if sellerItem != nil {
-
-						//services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName, "所属销售："+sellerItem.RealName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo)
-						services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "提问："+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo, int(msgId))
-					}
-				}
-			}
+
 			// 给所属销售发送消息
 			if sellerItem != nil {
-				openIdList, e := models.GetMfyxUserRecordListByMobile(12, sellerItem.Mobile+","+utils.WxMsgTemplateIdAskMsgMobilePublic)
-				if e != nil {
-					err = errors.New("GetUserRecordListByMobile, Err: " + e.Error())
-					return
-				}
-				go services.SendWxCategoryMsgWithAsk(user.RealName, user.CompanyName, sellerItem.RealName, content, openIdList, req.ActivityId)
-
-				//openIpItem, _ := models.GetUserRecordByMobile(4, sellerItem.Mobile)
-				//if openIpItem != nil && openIpItem.OpenId != "" {
-				//services.SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "提问："+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo, int(msgId))
-				//}
+				go services.SendWxCategoryMsgWithAsk(user, activityInfo, content, int(msgId))
 			}
 		}
 	} else {

services/wechat_send_category_template_msg.go

@@ -546,28 +546,58 @@ func SendCommentWxCategoryTemplateMsg(req models.AddCygxArticleCommentReq, user
 	return
 }
 
-// 发送活动提问消息提醒
-func SendWxCategoryMsgWithAsk(realName, companyName, sellerName, askMsg string, openIdList []*models.OpenIdList, askId int) (err error) {
-	if len(openIdList) == 0 {
+// 发送活动提问消息提醒（研选公众号类目模版消息）
+func SendWxCategoryMsgWithAsk(user *models.WxUserItem, activityInfo *models.ActivityDetail, askMsg string, askId int) (err error) {
+	if activityInfo.ChartPermissionId != utils.CHART_PERMISSION_ID_YANXUAN {
 		return
 	}
-	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("发送活动提问消息提醒类目模版消息失败,用户名", realName, "提问ID：", askId), 2)
-			utils.FileLog.Info("发送类目模版消息失败,Err:%s", err.Error())
+			fmt.Println(err)
+			go utils.SendAlarmMsg(fmt.Sprint("发送活动提问消息提醒类目模版消息失败,用户名", user.RealName, "提问ID：", askId), 2)
 		}
-		fmt.Println("line 21", err, msg)
 	}()
+
+	companyId := user.CompanyId
+	var sellerName string
+	//潜在客户、未开权益，已开FICC的客户推给王芳，开通权益的客户推给对应销售
+	mobile := utils.WxMsgTemplateIdAskMsgMobilePublic
+	if companyId > 1 {
+		raiCount, e := models.GetCompanyProductCount(companyId, utils.COMPANY_PRODUCT_RAI_ID)
+		if e != nil {
+			err = errors.New("GetCompanyProductCount, Err: " + e.Error())
+			return
+		}
+		if raiCount > 0 {
+			sealldetail, e := models.GetRaiSellerByCompanyId(companyId)
+			if e != nil {
+				err = errors.New("GetRaiSellerByCompanyId, Err: " + e.Error())
+				return
+			}
+			sellerName = sealldetail.RealName
+			mobile += "," + sealldetail.Mobile
+		}
+	}
+	var mobiles []string
+	mobiles = append(mobiles, utils.RAI_MOBILE_GAO_YI_WEN, utils.RAI_MOBILE_DONG_HENG, utils.RAI_MOBILE_WU_ANG_DI, utils.RAI_MOBILE_GE_LIN) //葛琳、高亦文、董衡、吴昂迪手机号
+	mobile += "," + strings.Join(mobiles, ",")
+	openIdList, e := models.GetMfyxWxOpenIdByMobileList(mobile)
+	if e != nil {
+		err = errors.New("GetMfyxWxOpenIdByMobileList, Err: " + e.Error())
+		return err
+	}
+	if len(openIdList) == 0 {
+		return
+	}
+
 	var keyword1 string
 	var keyword2 string
 	var keyword3 string
 	var keyword4 string
 	var keyword5 string
 
-	keyword1 = realName
-	keyword2 = utils.TruncateActivityNameString(companyName)
+	keyword1 = user.RealName
+	keyword2 = utils.TruncateActivityNameString(user.CompanyName)
 	keyword3 = sellerName
 	keyword4 = time.Now().Format(utils.FormatDateTimeMinute2)
 	keyword5 = utils.TruncateActivityNameString("活动提问：" + askMsg)
@@ -578,9 +608,9 @@ func SendWxCategoryMsgWithAsk(realName, companyName, sellerName, askMsg string,
 	for _, v := range openIdList {
 		openIdArr = append(openIdArr, v.OpenId)
 	}
-	redirectUrl := utils.WX_MSG_PATH_YX_ACTIVITY_DETAIL + strconv.Itoa(askId)
-	//redirectUrl := utils.WX_MSG_PATH_TEMPLATE_MSG + "SourceId=" + strconv.Itoa(askId) + "&SourceType=2"
 
+	redirectUrl := utils.WX_MSG_PATH_TEMPLATE_MSG + "SourceId=" + strconv.Itoa(askId) + "&SourceType=2"
+	//redirectUrl = ""
 	sendInfo := new(SendWxCategoryTemplate)
 	sendInfo.Keywords = keywords
 	sendInfo.TemplateId = utils.WxCategoryMsgTemplateIdApplyXzs

utils/config.go

@@ -52,6 +52,12 @@ var (
 	YiDongHuaWeiYunUrl       string //易董 华为云请求域名
 	YiDonggetOriginalLink    string //易董 短连接转为长链接
 
+	//权益内容组手机号
+	RAI_MOBILE_GAO_YI_WEN string // 权益高亦文手机号
+	RAI_MOBILE_DONG_HENG  string // 权益董衡手机号
+	RAI_MOBILE_WU_ANG_DI  string // 权益吴昂迪手机号
+	RAI_MOBILE_GE_LIN     string // 权益葛琳手机号
+
 )
 
 // 模板消息推送
@@ -138,6 +144,13 @@ func init() {
 		WxCategoryMsgTemplateIdActivitySign = "11rITVC5Gl8qwetxl92NqY887Uk14kg3nPtEA_i_zLo"
 		WxMsgCategoryTemplateIdCompanyApprovalMessageRai = "t1CcxcOkoZkWZrDRs6zYUlceBGYMV3mhkBYUa8a6Mx0" //权益销售签约成功通知买方研选类目模版消息通知-类目模板ID
 		WxMsgCategoryTemplateIdActivityPublishApply = "IBMqiE61lVgUfFM4rsH0XCH57R_G3PbWvRbnzg9JHPI"
+
+		//权益内容组手机号
+		RAI_MOBILE_GAO_YI_WEN = "15000123056" //权益高亦文手机号
+		RAI_MOBILE_DONG_HENG = "15216736473"  // 权益董衡手机号
+		RAI_MOBILE_WU_ANG_DI = "18701809782"  // 权益吴昂迪手机号
+		RAI_MOBILE_GE_LIN = "18258485832"     // 权益葛琳手机号
+
 	} else {
 		WxPublicAppId = "wx9b5d7291e581233a"                                          //弘则投研公众号 开发者ID(AppID)
 		WxPublicAppSecret = "f4d52e34021eee262dce9682b31f8861"                        //弘则投研公众号秘钥
@@ -164,6 +177,12 @@ func init() {
 		WxCategoryMsgTemplateIdActivitySign = "aczgUYZASO97UJiCD_nDmD1eNWZAWudzw3JYcvjJ2x4"
 		WxMsgCategoryTemplateIdCompanyApprovalMessageRai = "wU4x_c5XruwuA44VZelyklRNOfq4XrU9ILckTtDs6hg" //权益销售签约成功通知买方研选类目模版消息通知-类目模板ID
 		WxMsgCategoryTemplateIdActivityPublishApply = "wLeV7tVK4ZJBoAvsmfXkHveVW8yefGAkwnVKQWRi8uQ"
+
+		//权益内容组手机号测试环境没什么用，配合测试切换他们的手机号
+		RAI_MOBILE_GAO_YI_WEN = "17706316791" //权益高亦文手机号
+		RAI_MOBILE_DONG_HENG = "15557270714"  // 权益董衡手机号
+		RAI_MOBILE_WU_ANG_DI = "15557270714"  // 权益吴昂迪手机号
+		RAI_MOBILE_GE_LIN = "15557270714"     // 权益葛琳手机号
 	}
 	HeadimgurlDefault = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202202/20220225/XFBBOUmDC5AXkfxnHiuqKpPtoofH.png"