no message

controllers/micro_roadshow.go

@@ -254,6 +254,7 @@ func (this *MicroRoadShowController) VideoHistoryAdd() {
 	} else if sourceType == 4 {
 		go services.AddAskserieVideoHistoryRecord(user, sourceId, playSeconds)
 	}
+	go services.AddAllCygxVoiceAndVideoHistory(user, sourceId, sourceType, playSeconds)
 	br.Ret = 200
 	br.Success = true
 	br.Msg = "操作成功"

models/db.go

@@ -183,6 +183,7 @@ func init() {
 		new(CygxAskserieVideoHistoryRecord),
 		new(CygxAskserieVideoCollection),
 		new(CygxAskserieVideoCollect),
+		new(CygxVoiceAndVideoHistory),
 	)
 	// 记录ORM查询日志
 	orm.Debug = true

models/voice_and_video_history.go

@@ -0,0 +1,31 @@
+package models
+
+import (
+	"github.com/beego/beego/v2/client/orm"
+	"time"
+)
+
+type CygxVoiceAndVideoHistory struct {
+	Id               int `orm:"column(id);pk"`
+	SourceId         int `description:"资源ID"`
+	SourceType       int `description:"资源类型 1：活动音频、2 活动视频 、3 产业视频 、 4 问答系列 "`
+	UserId           int
+	CreateTime       time.Time
+	Mobile           string    `description:"手机号"`
+	Email            string    `description:"邮箱"`
+	CompanyId        int       `description:"公司id"`
+	CompanyName      string    `description:"公司名称"`
+	ModifyTime       time.Time `description:"修改时间"`
+	RealName         string    `description:"用户实际名称"`
+	SellerName       string    `description:"所属销售"`
+	RegisterPlatform int       `description:"来源 1小程序，2：网页"`
+	PlaySeconds      string    `description:"播放时间 单位s"`
+}
+
+// 添加历史信息
+func AddCygxVoiceAndVideoHistory(item *CygxVoiceAndVideoHistory) (lastId int64, err error) {
+	o := orm.NewOrm()
+	item.ModifyTime = time.Now()
+	lastId, err = o.Insert(item)
+	return
+}

services/micro_roadshow.go

@@ -1061,3 +1061,40 @@ func AddMicroRoadshowVideoRecord(user *models.WxUserItem, videoId, playSeconds i
 
 	return
 }
+
+// 记录所有微路演音视频播放记录
+func AddAllCygxVoiceAndVideoHistory(user *models.WxUserItem, sourceId, sourceType, playSeconds int) {
+	var err error
+	defer func() {
+		if err != nil {
+			go utils.SendAlarmMsg(fmt.Sprint("记录所有微路演音视频播放记录失败 AddAllCygxVoiceAndVideoHistory Err:", err.Error(), "sourceId：", sourceId, "UserId：", user.UserId), 2)
+		}
+	}()
+	item := new(models.CygxVoiceAndVideoHistory)
+	item.UserId = user.UserId
+	item.RealName = user.RealName
+	item.SourceId = sourceId
+	item.SourceType = sourceType
+	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
+	}
+	_, e = models.AddCygxVoiceAndVideoHistory(item)
+	if e != nil {
+		err = errors.New("AddCygxVoiceAndVideoHistory, Err: " + e.Error())
+		return
+	}
+	return
+}