no message

controllers/activity.go

@@ -2,7 +2,6 @@ package controllers
 
 import (
 	"encoding/json"
-	"errors"
 	"fmt"
 	"hongze/hongze_mfyx/models"
 	"hongze/hongze_mfyx/models/order"
@@ -1472,23 +1471,6 @@ func (this *ActivityCoAntroller) 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() {
@@ -1496,28 +1478,9 @@ func (this *ActivityCoAntroller) 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+")", "提问："+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), req.Content, activityInfo.ActivityName, openIpItem, activityInfo, int(msgId))
-				}
-			}
-		}
 		// 给所属销售发送消息
 		if sellerItem != nil {
-			openIdList, e := models.GetUserRecordListByMobile(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))
 		}
 	}
 

models/user_record.go

@@ -3,6 +3,7 @@ package models
 import (
 	"github.com/beego/beego/v2/client/orm"
 	"hongze/hongze_mfyx/utils"
+	"strings"
 	"time"
 )
 
@@ -159,3 +160,29 @@ func GetUserRecordListByMobileArr(mobiles []string) (items []*OpenIdList, err er
 	_, err = o.Raw(sql, pars).QueryRows(&items)
 	return
 }
+
+func GetMfyxWxOpenIdByMobileList(mobile string) (items []*OpenIdList, err error) {
+	sliceMobile := strings.Split(mobile, ",")
+	var mobiles []string
+	for _, v := range sliceMobile {
+		mobiles = append(mobiles, v)
+	}
+	o := orm.NewOrm()
+	lenarr := len(mobiles)
+	if lenarr == 0 {
+		return
+	}
+	var condition string
+	var pars []interface{}
+	condition = ` AND u.cygx_bind_account IN (` + utils.GetOrmInReplace(lenarr) + `)`
+	pars = append(pars, mobiles)
+	sql := `SELECT
+			u.open_id,
+			u.cygx_user_id AS user_id 
+		FROM
+			cygx_mfyx_gzh_user_record AS u 
+		WHERE
+			1 = 1  ` + condition
+	_, err = o.Raw(sql, pars).QueryRows(&items)
+	return
+}

services/wx_category_template_msg.go

@@ -329,31 +329,61 @@ 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 = "活动提问：" + askMsg
+	keyword5 = utils.TruncateActivityNameString("活动提问：" + askMsg)
 
 	keywords := []string{keyword1, keyword2, keyword3, keyword4, keyword5}
 
@@ -361,9 +391,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

@@ -55,6 +55,12 @@ var (
 	WxMsgCategoryTemplateIdCompanyApprovalMessageRai string //权益销售签约成功通知买方研选类目模版消息通知-类目模板ID
 	WxMsgCategoryTemplateIdActivityPublishApply      string //买方研选关注的产业下，单个活动/研选报告发布通知-类目模板ID
 
+	//权益内容组手机号
+	RAI_MOBILE_GAO_YI_WEN string // 权益高亦文手机号
+	RAI_MOBILE_DONG_HENG  string // 权益董衡手机号
+	RAI_MOBILE_WU_ANG_DI  string // 权益吴昂迪手机号
+	RAI_MOBILE_GE_LIN     string // 权益葛琳手机号
+
 )
 
 // 微信公众号配置信息
@@ -260,6 +266,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"     // 权益葛琳手机号
 	} else {
 		//新的模板ID
 		WxPublicIdXzs = "wxb7cb8a15abad5b8e"                                                  //查研观向小助手
@@ -277,6 +289,12 @@ 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"     // 权益葛琳手机号
 	}
 
 	//易董开放api配置