hongze_mobile_admin/models/tables/company_approval_message/company_approval_message.go

package company_approval_message

import (
	"github.com/beego/beego/v2/client/orm"
	"time"
)

type CompanyApprovalMessage struct {
	Id                int       `orm:"column(id);pk"`
	CreateUserId      int       `description:"申请者id"`
	ReceiveUserId     int       `description:"审批者id"`
	MessageStatus     int       `description:"消息状态:0未读，1:已读，2：作废"`
	SourceType        int       `description:"消息来源类型，1:客户，2：合同，3：用印"`
	Remark            string    `description:"备注信息"`
	Content           string    `description:"消息内容"`
	CompanyId         int       `description:"客户id"`
	CompanyName       string    `description:"客户名称"`
	CreateTime        time.Time `description:"创建时间"`
	ModifyTime        time.Time `description:"修改时间"`
	CompanyApprovalId int       `description:"审批单id"`
	ApprovalStatus    int       `description:"审批结果:1:待审批，2:已审批，3:已驳回"`
	OperationStatus   int       `description:"消息状态:1:待审批，2:已审批"`
	MessageType       int       `description:"1:申请消息，2:审批结果"`
	MessageInfo       string    `description:"消息主要内容，json数据"`
}

//添加审批消息
func AddCompanyApprovalMessage(item *CompanyApprovalMessage) (err error) {
	o := orm.NewOrm()
	_, err = o.Insert(item)
	return
}

//修改审批消息
func ModifyCompanyApprovalMessage(companyApprovalId, sourceType int) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE company_approval_message SET operation_status=2,modify_time=NOW() 
WHERE company_approval_id=? AND source_type=?  AND message_type=1 AND operation_status=1 `
	_, err = o.Raw(sql, companyApprovalId, sourceType).Exec()
	return
}

//消息列表结果
type CompanyApprovalMessageList struct {
	Id                int          `orm:"column(id);pk"`
	CreateUserId      int          `description:"申请者id"`
	MessageStatus     int          `description:"消息状态:0未读，1:已读，2：作废"`
	MessageType       int          `description:"1:申请消息，2:审批结果，3:文字消息"`
	ApprovalStatus    int          `description:"审批结果:1:待审批，2:已审批，3:已驳回"`
	SourceType        int          `description:"消息来源类型，1:客户，2：合同，3：用印"`
	Remark            string       `description:"备注信息"`
	Content           string       `description:"消息内容"`
	CompanyName       string       `description:"客户名称"`
	CreateTime        time.Time    `description:"创建时间"`
	RealName          string       `description:"销售名称"`
	CompanyApprovalId int          `description:"审批单id"`
	MessageInfo       string       `description:"消息主要内容，json数据" json:"-"`
	ApprovalInfo      ApprovalInfo `description:"审批单信息"`
}

//消息审批单信息
type ApprovalInfo struct {
	ApplyName    string    `description:"申请人姓名"`
	Type         string    `description:"类型"`
	Title        string    `description:"主题内容"`
	Content      string    `description:"主体内容"`
	CompanyName  string    `description:"客户信息"`
	ApplyTime    time.Time `description:"提交时间"`
	ApprovalTime time.Time `description:"审批时间"`
	Extra        string    `description:"附加字段: 比如视频评论的标签"`
}

type CompanyApprovalMessageListResp struct {
	List  []*CompanyApprovalMessageList
	Total int `description:"总数据条数"`
}

//待办消息列表
type CompanyApprovalMessageListV2Resp struct {
	Company  CompanyApprovalMessageListResp `description:"客户"`
	Contract CompanyApprovalMessageListResp `description:"合同"`
}

//获取消息列表总数据
func GetCompanyApprovalMessageCount(sysUserId, sourceType int) (count int, err error) {
	sql := `SELECT COUNT(1) AS count FROM company_approval_message AS a
			INNER JOIN admin AS b ON a.create_user_id=b.admin_id
			WHERE receive_user_id=? AND a.operation_status=1 AND message_status !=2 AND a.source_type=? `
	o := orm.NewOrm()
	err = o.Raw(sql, sysUserId, sourceType).QueryRow(&count)
	return
}

//消息列表页
func GetCompanyApprovalMessageList(sysUserId, startSize, pageSize int, sourceType string) (items []*CompanyApprovalMessageList, err error) {
	sql := `SELECT
				a.*, b.real_name
			FROM
				company_approval_message AS a
			INNER JOIN admin AS b ON a.create_user_id = b.admin_id
			WHERE
				receive_user_id =? AND message_status != 2 AND a.source_type IN (` + sourceType + `)`
	sql += ` ORDER BY create_time DESC LIMIT ?,? `
	o := orm.NewOrm()
	_, err = o.Raw(sql, sysUserId, startSize, pageSize).QueryRows(&items)
	return
}

//获取最近一条消息
func GetLastMessage(sysUserId, sourceType int) (item *CompanyApprovalMessageList, err error) {
	sql := `SELECT a.*,b.real_name FROM company_approval_message AS a
			INNER JOIN admin AS b ON a.create_user_id=b.admin_id
			WHERE receive_user_id=? AND message_status !=2 AND source_type=?`
	sql += ` ORDER BY create_time DESC `
	o := orm.NewOrm()
	err = o.Raw(sql, sysUserId, sourceType).QueryRow(&item)
	return
}

//获取未读消息数
func GetNotReadMessageTotal(sysUserId, sourceType int) (total int64, err error) {
	sql := `SELECT count(*) total FROM company_approval_message AS a
			INNER JOIN admin AS b ON a.create_user_id=b.admin_id
			WHERE receive_user_id=? AND a.operation_status=1 AND a.message_status =0 AND source_type=?`
	o := orm.NewOrm()
	err = o.Raw(sql, sysUserId, sourceType).QueryRow(&total)
	return
}

//申请服务更新请求参数
type CompanyApprovalMessageReadReq struct {
	Id int `description:"消息id"`
}

//变更为消息已读状态
func ModifyCompanyApprovalMessageStatus(companyApprovalMessageId int) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE company_approval_message SET message_status=1,modify_time=NOW() WHERE id=?`
	_, err = o.Raw(sql, companyApprovalMessageId).Exec()
	return
}

//变更当前类型下所有未读消息为消息已读状态
func ModifyAllCompanyApprovalMessageStatus(receiveUserId, sourceType int) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE company_approval_message SET message_status=1,modify_time=NOW() WHERE receive_user_id = ? and source_type=? and message_status=0`
	_, err = o.Raw(sql, receiveUserId, sourceType).Exec()
	return
}

// CancelCompanyApprovalMessage 消息作废
func CancelCompanyApprovalMessage(companyApprovalId, sourceType int) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE company_approval_message SET message_status=2,modify_time=NOW() 
WHERE company_approval_id=? AND source_type=?  AND message_type=1 AND operation_status=1 `
	//sql := `UPDATE company_approval_message SET message_status=1,modify_time=NOW() WHERE id=?`
	_, err = o.Raw(sql, companyApprovalId, sourceType).Exec()
	return
}