eta_api/models/english_report_email_log.go

package models

import (
	"eta/eta_api/utils"
	"github.com/beego/beego/v2/client/orm"
	"github.com/rdlucklib/rdluck_tools/paging"
	"time"
)

const (
	EnglishReportEmailLogSourceAli     = 1 // 来源-阿里云
	EnglishReportEmailLogSourceTencent = 2 // 来源-腾讯云

	EnglishReportEmailLogStatusIng     = -1 // 推送状态-已发送
	EnglishReportEmailLogStatusFail    = 0  // 推送状态-发送失败
	EnglishReportEmailLogStatusSuccess = 1  // 推送状态-发送成功
)

// EnglishReportEmailLog 英文研报-邮件推送记录
type EnglishReportEmailLog struct {
	Id           int       `orm:"column(id);pk;auto" description:"邮箱ID"`
	ReportId     int       `description:"报告ID或者线上路演ID"`
	ReportType   int       `description:"类型：0英文研报，1英文线上路演"`
	EmailId      int       `description:"邮箱ID"`
	Email        string    `description:"邮箱地址"`
	SendData     string    `description:"请求信息"`
	Result       string    `description:"响应信息"`
	SendStatus   int       `description:"发送状态：-1-已发送(一个中间状态,重新推送时可能会产生这种状态)；0-发送失败；1-发送成功"`
	CreateTime   time.Time `description:"请求时间"`
	Source       int       `description:"服务商：1-阿里云；2-腾讯云"`
	IsDeleted    int       `description:"是否已删除: 0-正常; 1-已删除"`
	CallbackData string    `description:"回调信息"`
	ErrMsg       string    `description:"错误信息"`
}

func (item *EnglishReportEmailLog) TableName() string {
	return "english_report_email_log"
}

func (item *EnglishReportEmailLog) Create() (err error) {
	o := orm.NewOrmUsingDB("rddp")
	id, e := o.Insert(item)
	if e != nil {
		err = e
		return
	}
	item.Id = int(id)
	return
}

func (item *EnglishReportEmailLog) Update(cols []string) (err error) {
	o := orm.NewOrmUsingDB("rddp")
	_, err = o.Update(item, cols...)
	return
}

func (item *EnglishReportEmailLog) InsertMulti(items []*EnglishReportEmailLog) (err error) {
	o := orm.NewOrmUsingDB("rddp")
	_, err = o.InsertMulti(len(items), items)
	return
}

// GetEnglishReportEmailLogList 获取日志列表
func GetEnglishReportEmailLogList(condition string, pars []interface{}) (list []*EnglishReportEmailLog, err error) {
	o := orm.NewOrmUsingDB("rddp")
	sql := `SELECT * FROM english_report_email_log WHERE is_deleted = 0 `
	if condition != `` {
		sql += condition
	}
	_, err = o.Raw(sql, pars).QueryRows(&list)
	return
}

// EnglishReportEmailLogPageListResp 英文研报-邮件推送记录分页列表响应体
type EnglishReportEmailLogPageListResp struct {
	List   []*EnglishReportEmailLogPageList `description:"列表数据"`
	Paging *paging.PagingItem               `description:"分页数据"`
}

// EnglishReportEmailLogPageList 英文研报-邮件推送记录分页列表
type EnglishReportEmailLogPageList struct {
	SendId     int    `description:"推送ID"`
	ReportId   int    `description:"报告ID"`
	EmailId    int    `description:"邮箱ID"`
	Email      string `description:"邮箱地址"`
	ResultMsg  string `description:"结果详情"`
	SendStatus int    `description:"发送状态：-1-已发送；0-发送失败；1-发送成功"`
	Source     int    `description:"服务商：1-阿里云；2-腾讯云"`
	CreateTime string `description:"创建时间"`
}

// GetEnglishReportEmailLogPageList 获取日志列表-分页
func GetEnglishReportEmailLogPageList(condition string, pars []interface{}, order string, startSize, pageSize int) (total int, list []*EnglishReportEmailLog, err error) {
	o := orm.NewOrmUsingDB("rddp")
	sql := `SELECT * FROM english_report_email_log WHERE is_deleted = 0 `
	sql += condition
	if order != "" {
		sql += order
	} else {
		sql += ` ORDER BY send_status ASC, create_time DESC`
	}
	totalSQl := `SELECT COUNT(1) total FROM (` + sql + `) z`
	if err = o.Raw(totalSQl, pars).QueryRow(&total); err != nil {
		return
	}
	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
	return
}

// GetEnglishReportEmailLogById 主键获取日志
func GetEnglishReportEmailLogById(id int) (item *EnglishReportEmailLog, err error) {
	o := orm.NewOrmUsingDB("rddp")
	sql := `SELECT * FROM english_report_email_log WHERE is_deleted = 0 AND id = ? LIMIT 1`
	err = o.Raw(sql, id).QueryRow(&item)
	return
}

// DeleteEnglishReportEmailLogByIds IDs删除日志
func DeleteEnglishReportEmailLogByIds(logIds []int) (err error) {
	if len(logIds) == 0 {
		return
	}
	o := orm.NewOrmUsingDB("rddp")
	sql := `DELETE FROM english_report_email_log WHERE id IN (` + utils.GetOrmInReplace(len(logIds)) + `)`
	//sql := `UPDATE english_report_email_log SET is_deleted = 1 WHERE id IN (` + utils.GetOrmInReplace(len(logIds)) + `)`
	_, err = o.Raw(sql, logIds).Exec()
	return
}

// EnglishReportEmailLogFail 群发消息日志失败列表
type EnglishReportEmailLogFail struct {
	HasFail  int `description:"是否有失败记录: 0-无; 1-有"`
	ReportId int `description:"报告ID"`
}

// GetEnglishReportEmailLogFailList 获取群发消息日志失败列表
func GetEnglishReportEmailLogFailList(reportType int) (list []*EnglishReportEmailLogFail, err error) {
	o := orm.NewOrmUsingDB("rddp")
	sql := `SELECT 1 AS has_fail, report_id FROM english_report_email_log WHERE report_type=? and is_deleted = 0 AND send_status = 0 GROUP BY report_id`
	_, err = o.Raw(sql, reportType).QueryRows(&list)
	return
}

// GetEnglishReportEmailLog 获取邮件推送日志
func GetEnglishReportEmailLog(condition string, pars []interface{}) (item *EnglishReportEmailLog, err error) {
	o := orm.NewOrmUsingDB("rddp")
	sql := `SELECT * FROM english_report_email_log WHERE 1 = 1 `
	sql += condition
	sql += ` ORDER BY id DESC LIMIT 1`
	err = o.Raw(sql, pars).QueryRow(&item)
	return
}

func (item *EnglishReportEmailLog) MultiUpdateResult(items []*EnglishReportEmailLog) (err error) {
	o := orm.NewOrmUsingDB("rddp")
	p, err := o.Raw("UPDATE english_report_email_log SET send_data = ?, result = ?, send_status = ?, err_msg = ? WHERE id = ?").Prepare()
	if err != nil {
		return
	}
	defer func() {
		_ = p.Close()
	}()
	for _, v := range items {
		_, err = p.Exec(v.SendData, v.Result, v.SendStatus, v.ErrMsg, v.Id)
		if err != nil {
			return
		}
	}
	return
}