hongze_task/models/roadshow/report_record_permission.go

package roadshow

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

type RsReportRecordPermission struct {
	RsReportRecordPermissionId int64     `orm:"column(rs_report_record_permission_id);pk"`
	CompanyId                  int       `description:"公司id"`
	ProductId                  int       `description:"产品id"`
	ProductName                string    `description:"产品名称"`
	ReportPermissionId         int       `description:"权限id(作废)"`
	Status                     string    `description:"状态"`
	CreatedTime                time.Time `description:"创建时间"`
	ChartPermissionId          int       `description:"大分类ID"`
	StartDate                  string    `description:"合同开始日期"`
	EndDate                    string    `description:"合同结束日期"`
	ModifyTime                 string    `description:"更新时间"`
	IsUpgrade                  int       `description:"是否升级，1是，0否"`
	ExpensiveYx                int       `description:"权益研选: 0-3w; 1-5w"`
	RsCalendarId               int       `description:"路演活动id"`
}

// 根据企业用户id和产品id获取所有正式的权限
func GetCompanyProductReportPermissionList(companyId []int, productId int) (items []*RsReportRecordPermission, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM company_report_permission  WHERE company_id IN (` + utils.GetOrmInReplace(len(companyId)) + `) and product_id=?  `
	_, err = o.Raw(sql, companyId, productId).QueryRows(&items)
	return
}

// 根据路演ID获取已经存在的路演信息
func GetCompanyProductReportPermissionrsCalendarIdList(rsCalendarId []int) (items []*RsReportRecordPermission, err error) {
	o := orm.NewOrm()
	sql := `SELECT rs_calendar_id FROM rs_report_record_permission  WHERE  rs_calendar_id IN (` + utils.GetOrmInReplace(len(rsCalendarId)) + `) `
	_, err = o.Raw(sql, rsCalendarId).QueryRows(&items)
	return
}

func MultiRsReportRecordPermission(items []*RsReportRecordPermission) (err error) {
	o := orm.NewOrm()
	//批量插入
	_, err = o.InsertMulti(len(items), items)
	return
}