hongze_mobile_admin/models/tables/company_approval_message/company_approval_message.go

package company_approval_message

import (
	"rdluck_tools/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：合同"`
	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:审批结果"`
}

//添加审批消息
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:审批结果"`
	ApprovalStatus    int    `description:"审批结果:1:待审批，2:已审批，3:已驳回"`
	SourceType        int    `description:"消息来源类型，1:客户，2：合同，3：用印"`
	Remark            string `description:"备注信息"`
	Content           string `description:"消息内容"`
	CompanyName       string `description:"客户名称"`
	CreateTime        string `description:"创建时间"`
	RealName          string `description:"销售名称"`
	CompanyApprovalId int    `description:"审批单id"`
}

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, sourceType, startSize, pageSize int) (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 a.operation_status=1 AND message_status !=2 AND a.source_type=? `
	sql += ` ORDER BY create_time DESC LIMIT ?,? `
	o := orm.NewOrm()
	_, err = o.Raw(sql, sysUserId, sourceType, 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 a.operation_status=1 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 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
}