hongze_cygx/services/rai_serve_count.go

package services

import (
	"fmt"
	"hongze/hongze_cygx/models/rai_serve"
	"hongze/hongze_cygx/utils"
	"time"
)

//权益服务统计

// Redis对列消息中的结构体
type RaiServeBillRedis struct {
	Content          string    `comment:"服务内容说明"`
	UserId           int       `comment:"用户ID"`
	ComapnyId        int       `comment:"公司ID"`
	SourceId         int       `comment:"来源ID"`
	Source           string    `comment:"来源"`
	RegisterPlatform int       `comment:"来源 1小程序，2：网页"`
	ViewTime         time.Time `comment:"浏览时间"`
}

// 权益服务统计添加到Redis队列中
func CygxRaiServeBillRedisAdd(content, source string, userId, comapnyId, sourceId, registerPlatform int, viewTime time.Time) (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			msg := fmt.Sprint("source:", source, "userId:", userId, "sourceId", sourceId)
			go utils.SendAlarmMsg("权益服务统计添加到Redis队列中，写入Redis队列消息失败 CygxRaiServeBillRedisAdd："+err.Error()+msg, 2)
		}
	}()
	log := &rai_serve.RaiServeBillRedis{Content: content, UserId: userId, ComapnyId: comapnyId, SourceId: sourceId, RegisterPlatform: registerPlatform, ViewTime: viewTime}
	if utils.Re == nil {
		err := utils.Rc.LPush(utils.CYGX_RAI_SERVE_BILL_KEY, log)
		if err != nil {
			fmt.Println("RaiServeBillRedis LPush Err:" + err.Error())
		}
	}
	return
}