no message

models/wx_template_msg.go

@@ -3,6 +3,7 @@ package models
 import (
 	"github.com/beego/beego/v2/client/orm"
 	"hongze/hongze_mfyx/utils"
+	"strings"
 )
 
 type SendTemplateResponse struct {
@@ -31,11 +32,28 @@ func GetOpenIdList() (items []*OpenIdList, err error) {
 }
 
 func GetWxOpenIdByMobileList(mobile string) (items []*OpenIdList, err error) {
-	sql := ` SELECT
-				union_id,open_id,
-				cygx_user_id AS user_id
-				FROM cygx_mfyx_gzh_user_record	WHERE	1 = 1	AND cygx_bind_account IN (` + mobile + `)`
-	_, err = orm.NewOrm().Raw(sql).QueryRows(&items)
+	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_user_record AS u 
+		WHERE
+			1 = 1  ` + condition
+	_, err = o.Raw(sql, pars).QueryRows(&items)
 	return
 }
 

services/activity.go

@@ -1193,93 +1193,6 @@ func GetActivityVideoResp(mapActivityId []int) (mapItem map[int]*models.CygxActi
 	return
 }
 
-// 用户音视频回放操作操作行为，模板消息推送
-func ActivityVideoUserRmind(user *models.WxUserItem, activityId, fileType int) (err error) {
-	defer func() {
-		if err != nil {
-			go utils.SendAlarmMsg("用户音视频回放操作操作行为，模板消息推送失败"+err.Error(), 2)
-		}
-	}()
-	countUser, err := models.GetUserRemind(user.UserId)
-	if err != nil {
-		return err
-	}
-	if countUser == 0 {
-		return err
-	}
-	var first string
-	var keyword1 string
-	var keyword2 string
-	var keyword3 string
-	var keyword4 string
-	var remark string
-	//获取销售手机号
-	sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
-	if err != nil && err.Error() != utils.ErrNoRow() {
-		return err
-	}
-	if sellerItemQy != nil {
-		openIdList, e := models.GetWxOpenIdByMobileList(sellerItemQy.Mobile)
-		if e != nil {
-			err = errors.New("GetSellerByAdminId, Err: " + e.Error())
-			return
-		}
-		//TripStatus            int    `description:"行程进行状态 1：预报名，2：确定行程"`
-		if fileType == 1 {
-			activityInfo, e := models.GetCygxActivityVideoByActivityId(activityId)
-			if e != nil {
-				err = errors.New("GetCygxActivitySpecialDetailById, Err: " + e.Error())
-				return
-			}
-			if activityInfo == nil {
-				return
-			}
-			keyword1 = activityInfo.VideoName
-			keyword2 = fmt.Sprint("互动：播放视频,", user.RealName, "--", user.CompanyName)
-			first = fmt.Sprint(user.RealName, "--", user.CompanyName, ",有新的互动：播放视频")
-
-		} else {
-			activityInfo, e := models.GetCygxActivityVoiceByActivityId(activityId)
-			if e != nil {
-				err = errors.New("GetCygxActivitySpecialDetailById, Err: " + e.Error())
-				return
-			}
-			if activityInfo == nil {
-				return
-			}
-			keyword1 = activityInfo.VoiceName
-			keyword2 = fmt.Sprint("互动：播放音频,", user.RealName, "--", user.CompanyName)
-			first = fmt.Sprint(user.RealName, "--", user.CompanyName, ",有新的互动：播放音频")
-		}
-
-		//keyword2 = "__"
-		//remark = "点击查看活动详情"
-		openIdArr := make([]string, 0)
-		for _, v := range openIdList {
-			openIdArr = append(openIdArr, v.OpenId)
-		}
-		redirectUrl := utils.WX_MSG_PATH_ACTIVITY_SPECIAL_DETAIL + strconv.Itoa(activityId)
-		sendInfo := new(SendWxTemplate)
-		sendInfo.First = first
-		sendInfo.Keyword1 = keyword1
-		sendInfo.Keyword2 = keyword2
-		sendInfo.Keyword3 = keyword3
-		sendInfo.Keyword4 = keyword4
-		sendInfo.Remark = remark
-		sendInfo.TemplateId = utils.WxMsgTemplateIdArticleUserRemind
-		sendInfo.RedirectUrl = redirectUrl
-		sendInfo.RedirectTarget = 3
-		sendInfo.Resource = strconv.Itoa(activityId)
-		sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
-		sendInfo.OpenIdArr = openIdArr
-		err = PublicSendTemplateMsg(sendInfo)
-		if err != nil {
-			return
-		}
-	}
-	return
-}
-
 // 解析活动填写的报告链接
 func GetActivityReportLinkToArticleList(item *models.ActivityDetail) (items []*models.ActivityArticleResp, err error) {
 	reportLink := item.ReportLink

services/cygx_activity_video_history.go

@@ -1,105 +1 @@
 package services
-
-import (
-	"errors"
-	"fmt"
-	"hongze/hongze_mfyx/models"
-	"hongze/hongze_mfyx/utils"
-	"strconv"
-	"time"
-)
-
-// 记录用户活动音频播放记录
-func AddActivityVoiceHistory(user *models.WxUserItem, activityId, playSeconds int) {
-	if playSeconds == 0 {
-		return
-	}
-	key := utils.CYGX_VIDEO_HISTORY_KEY + utils.CYGX_OBJ_ACTIVITYVOICE + strconv.Itoa(activityId) + "_" + strconv.Itoa(user.UserId)
-
-	var err error
-	defer func() {
-		if err != nil {
-			go utils.SendAlarmMsg(fmt.Sprint("记录用户活动音频播放记录失败 AddActivityVoiceHistory Err:", err.Error(), "活动ID：", activityId, "UserId：", user.UserId), 2)
-		}
-	}()
-	item := new(models.CygxActivityVoiceHistory)
-	item.UserId = user.UserId
-	item.RealName = user.RealName
-	item.ActivityId = activityId
-	item.PlaySeconds = strconv.Itoa(playSeconds)
-	item.Mobile = user.Mobile
-	item.Email = user.Email
-	item.CompanyId = user.CompanyId
-	item.CompanyName = user.CompanyName
-	item.CreateTime = time.Now()
-	item.ModifyTime = time.Now()
-	item.RegisterPlatform = utils.REGISTER_PLATFORM
-	sellerItem, e := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
-	if e != nil && e.Error() != utils.ErrNoRow() {
-		err = errors.New("GetSellerByCompanyIdCheckFicc, Err: " + e.Error())
-		return
-	}
-	if sellerItem != nil {
-		item.SellerName = sellerItem.RealName
-	}
-
-	if !utils.Rc.IsExist(key) {
-		//添加记录
-		e = models.AddCygxActivityVoiceHistory(item)
-		if e != nil {
-			err = errors.New("AddCygxActivityVoiceHistory, Err: " + e.Error())
-			return
-		}
-		//播放记录加1
-		e = models.UpdateCygxActivityVoiceCounts(activityId)
-		if e != nil {
-			err = errors.New("UpdateCygxActivityVoiceCounts, Err: " + e.Error())
-			return
-		}
-		utils.Rc.Put(key, 1, 10*time.Minute)
-		//设置消息提醒
-		go ActivityVideoUserRmind(user, activityId, 2)
-	} else {
-		lastItem, e := models.GetLastCygxActivityVoiceHistory(activityId, user.UserId)
-		if e != nil {
-			err = errors.New("GetLastCygxActivityVoiceHistory, Err: " + e.Error())
-			return
-		}
-		e = models.UpdateLastCygxActivityVoiceHistory(strconv.Itoa(playSeconds), lastItem.Id)
-		if e != nil {
-			err = errors.New("UpdateLastCygxActivityVoiceHistory, Err: " + e.Error())
-			return
-		}
-	}
-
-	//小程序端的回传两次，第一次没有播放时长，第二次有播放时长
-	//if playSeconds != 0 {
-	//	lastItem, e := models.GetLastCygxActivityVoiceHistory(activityId, user.UserId)
-	//	if e != nil {
-	//		err = errors.New("GetLastCygxActivityVoiceHistory, Err: " + e.Error())
-	//		return
-	//	}
-	//	e = models.UpdateLastCygxActivityVoiceHistory(strconv.Itoa(playSeconds), lastItem.Id)
-	//	if e != nil {
-	//		err = errors.New("UpdateLastCygxActivityVoiceHistory, Err: " + e.Error())
-	//		return
-	//	}
-	//	utils.Rc.Put(key, 1, 10*time.Second)
-	//} else {
-	//	//添加记录
-	//	e = models.AddCygxActivityVoiceHistory(item)
-	//	if e != nil {
-	//		err = errors.New("AddCygxActivityVoiceHistory, Err: " + e.Error())
-	//		return
-	//	}
-	//	//播放记录加1
-	//	e = models.UpdateCygxActivityVoiceCounts(activityId)
-	//	if e != nil {
-	//		err = errors.New("UpdateCygxActivityVoiceCounts, Err: " + e.Error())
-	//		return
-	//	}
-	//	//设置消息提醒
-	//	go ActivityVideoUserRmind(user, activityId, 2)
-	//}
-	return
-}