hongze_cygx/services/askserie_video.go

package services

import (
	"errors"
	"fmt"
	"hongze/hongze_cygx/models"
	"hongze/hongze_cygx/utils"
	"strconv"
	"time"
)

// 记录用户活动音频播放记录
func AddAskserieVideoHistoryRecord(user *models.WxUserItem, askserieVideoId, playSeconds int) {
	var err error
	defer func() {
		if err != nil {
			go utils.SendAlarmMsg(fmt.Sprint("记录用户活动音频播放记录失败 AddAskserieVideoHistoryRecord Err:", err.Error(), "askserieVideoId：", askserieVideoId, "UserId：", user.UserId), 2)
		}
	}()
	item := new(models.CygxAskserieVideoHistoryRecord)
	item.UserId = user.UserId
	item.AskserieVideoId = askserieVideoId
	item.VideoDuration = 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.AddCygxAskserieVideoHistoryRecord(item)
	if e != nil {
		err = errors.New("AddCygxAskserieVideoHistoryRecord, Err: " + e.Error())
		return
	}
	//播放记录加1
	e = models.UpdateAskserieVideoCounts(askserieVideoId)
	if e != nil {
		err = errors.New("UpdateAskserieVideoCounts, Err: " + e.Error())
		return
	}

	if playSeconds != 0 {
		lastItem, e := models.GetLastCygxAskserieVideoHistoryRecord(askserieVideoId, user.UserId)
		if e != nil {
			err = errors.New("GetLastCygxActivityVideoHistory, Err: " + e.Error())
			return
		}
		//更新播放时间
		e = models.UpdateLastCygxActivityVideoHistory(strconv.Itoa(playSeconds), lastItem.Id)
		if e != nil {
			err = errors.New("UpdateLastCygxActivityVideoHistory, Err: " + e.Error())
			return
		}
		//播放记录加1
		e = models.UpdateActivityVideoCounts(askserieVideoId)
		if e != nil {
			err = errors.New("UpdateActivityVideoCounts, Err: " + e.Error())
			return
		}
	} else {
		//添加记录
		e = models.AddCygxActivityVideoHistory(item)
		if e != nil {
			err = errors.New("AddCygxActivityVideoHistory, Err: " + e.Error())
			return
		}
	}

	return
}

// 系列问答视频留言记录
func AddCygxAskserieVideoCollection(user *models.WxUserItem, askserieVideoId int, content string) {
	var err error
	defer func() {
		if err != nil {
			go utils.SendAlarmMsg(fmt.Sprint("记录用户活动音频播放记录失败 AddAskserieVideoHistoryRecord Err:", err.Error(), "askserieVideoId：", askserieVideoId, "UserId：", user.UserId), 2)
		}
	}()
	item := new(models.CygxAskserieVideoCollection)
	item.UserId = user.UserId
	item.AskserieVideoId = askserieVideoId
	item.Content = content
	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.AddCygxAskserieVideoCollection(item)
	if e != nil {
		err = errors.New("AddCygxAskserieVideoCollection, Err: " + e.Error())
		return
	}
	//播放记录加1
	e = models.UpdateAskserieVideoCommentNum(askserieVideoId)
	if e != nil {
		err = errors.New("UpdateAskserieVideoCommentNum, Err: " + e.Error())
		return
	}
	return
}