package models import ( "eta_gn/eta_api/global" "eta_gn/eta_api/utils" "time" "github.com/beego/beego/v2/client/orm" ) // ppt目录和ppt 映射表 type PptV2GroupMapping struct { GroupPptId int64 `gorm:"column:group_ppt_id;primaryKey;autoIncrement" description:"自增序号"` GroupId int64 `gorm:"column:group_id" description:"ppt目录ID"` PptSort int64 `gorm:"column:ppt_sort" description:"Ppt的排序"` PptId int64 `gorm:"column:ppt_id" description:"ppt ID"` CreateTime time.Time `gorm:"column:create_time;autoCreateTime" description:"创建时间"` ModifyTime time.Time `gorm:"column:modify_time;autoUpdateTime" description:"修改时间"` AdminId int `gorm:"column:admin_id" description:"移动ppt到该目录的系统用户id"` AdminRealName string `gorm:"column:admin_real_name" description:"系统用户名称"` ChildGroupPptId int64 `gorm:"column:child_group_ppt_id" description:"设置共享后的新映射ID"` IsMoved bool `gorm:"column:is_moved" description:"true表示改PPT被人为移动过"` } // AddPptGroupMapping 新增目录和ppt的映射关系 func AddPptGroupMapping(item *PptV2GroupMapping) (lastId int64, err error) { //o := orm.NewOrmUsingDB("rddp") //lastId, err = o.Insert(item) err = global.DmSQL["rddp"].Create(item).Error lastId = item.GroupId return } // GetPptMappingCountByGroupId 查询目录下,ppt的个数 func GetPptMappingCountByGroupId(groupId int64) (total int64, err error) { //o := orm.NewOrmUsingDB("rddp") sql := `select count(*) from ppt_v2_group_mapping where group_id=?` //err = o.Raw(sql, groupId).QueryRow(&total) err = global.DmSQL["rddp"].Raw(sql, groupId).Scan(&total).Error return } // GetPptMappingListByGroupId 查询目录下,ppt列表 func GetPptMappingListByGroupId(groupId int64) (list []*PptV2GroupMapping, err error) { // o := orm.NewOrmUsingDB("rddp") sql := `select group_ppt_id, group_id, ppt_id, ppt_sort, admin_id, admin_real_name, create_time from ppt_v2_group_mapping where group_id=? order by ppt_sort asc, group_ppt_id asc ` //_, err = o.Raw(sql, groupId).QueryRows(&list) err = global.DmSQL["rddp"].Raw(sql, groupId).Find(&list).Error return } // GetPptMappingListByGroupIds 根据分组ID查找 func GetPptMappingListByGroupIds(groupIds []int64) (list []*PptV2GroupMapping, err error) { //_, err = orm.NewOrmUsingDB("rddp"). // QueryTable("ppt_v2_group_mapping"). // Filter("group_id__in", groupIds). // OrderBy("-ppt_sort", "group_ppt_id"). // All(&list) err = global.DmSQL["rddp"].Table("ppt_v2_group_mapping").Where("group_id in ?", groupIds).Find(&list).Error return } // GetPptMappingByGroupPptId 查询根据映射ID,查询单个映射关系 func GetPptMappingByGroupPptId(groupPptId int64, adminId int) (item *PptV2GroupMapping, err error) { //o := orm.NewOrmUsingDB("rddp") sql := `select * from ppt_v2_group_mapping where group_ppt_id=? and admin_id=?` //err = o.Raw(sql, groupPptId, adminId).QueryRow(&item) err = global.DmSQL["rddp"].Raw(sql, groupPptId, adminId).First(&item).Error return } // GetPptMappingByGroupPptId 查询根据映射ID,查询单个映射关系数量 func GetPptMappingByGroupPptCountId(groupPptId int64, adminId int) (count int, err error) { //o := orm.NewOrmUsingDB("rddp") sql := `select COUNT(*) AS count from ppt_v2_group_mapping where group_ppt_id=? and admin_id=?` //err = o.Raw(sql, groupPptId, adminId).QueryRow(&count) err = global.DmSQL["rddp"].Raw(sql, groupPptId, adminId).Scan(&count).Error return } // GetPptMappingByPptId 查询根据ppt_Id, 查询当映单个映射关系 func GetPptMappingByPptId(pptId int64) (item *PptV2GroupMapping, err error) { //o := orm.NewOrmUsingDB("rddp") sql := ` select * from ppt_v2_group_mapping where ppt_id=? ` //err = o.Raw(sql, pptId).QueryRow(&item) err = global.DmSQL["rddp"].Raw(sql, pptId).First(&item).Error return } // Update 更新ppt目录映射的基本信息 func (item *PptV2GroupMapping) Update(cols []string) (err error) { //o := orm.NewOrmUsingDB("rddp") //_, err = o.Update(item, cols...) err = global.DmSQL["rddp"].Select(cols).Updates(item).Error return } // AddPptGroupMappingMulti 批量新增ppt和目录的映射关系 func AddPptGroupMappingMulti(list []*PptV2GroupMapping) (err error) { //o := orm.NewOrmUsingDB("rddp") //_, err = o.InsertMulti(1, list) err = global.DmSQL["rddp"].CreateInBatches(list, utils.MultiAddNum).Error return } // UpdatePptGroupMappingSortMulti 批量更新初始排序标识 func UpdatePptGroupMappingSortMulti(groupPptIds []int64) (err error) { //o := orm.NewOrmUsingDB("rddp") //p, err := o.Raw("UPDATE ppt_v2_group_mapping SET ppt_sort = group_ppt_id WHERE group_ppt_id = ?").Prepare() //if err != nil { // return //} //defer func() { // _ = p.Close() // 别忘记关闭 statement //}() //for _, v := range groupPptIds { // _, err = p.Exec(v) // if err != nil { // return // } //} tx := global.DmSQL["rddp"].Begin() for _, v := range groupPptIds { err = tx.Exec("UPDATE ppt_v2_group_mapping SET ppt_sort = group_ppt_id WHERE group_ppt_id = ?", v).Error if err != nil { tx.Rollback() return } } tx.Commit() return } // DeletePptGroupMapping 删除ppt目录 func DeletePptGroupMapping(groupId int64, adminId int) (err error) { //o := orm.NewOrmUsingDB("rddp") sql := `DELETE FROM ppt_v2_group_mapping WHERE group_ppt_id=? and admin_id=? ` //_, err = o.Raw(sql, groupId, adminId).Exec() err = global.DmSQL["rddp"].Exec(sql, groupId, adminId).Error return } // DeletePptGroupMappingByPptId 删除ppt目录 func DeletePptGroupMappingByPptId(pptId int) (err error) { //o := orm.NewOrmUsingDB("rddp") sql := `DELETE FROM ppt_v2_group_mapping WHERE ppt_id=?` //_, err = o.Raw(sql, pptId).Exec() err = global.DmSQL["rddp"].Exec(sql, pptId).Error return } // MoveUpGroupPptBySort 往上移动ppt func MoveUpGroupPptBySort(groupId, nextSort, currentSort int64) (err error) { //o := orm.NewOrmUsingDB("rddp") sql := `update ppt_v2_group_mapping set ppt_sort = ppt_sort + 1 where group_id=? and ppt_sort >= ? and ppt_sort< ?` //_, err = o.Raw(sql, groupId, nextSort, currentSort).Exec() err = global.DmSQL["rddp"].Exec(sql, groupId, nextSort, currentSort).Error return } // MoveDownGroupPptBySort 往下移动ppt func MoveDownGroupPptBySort(groupId, prevSort, currentSort int64) (err error) { //o := orm.NewOrmUsingDB("rddp") sql := `update ppt_v2_group_mapping set ppt_sort = ppt_sort - 1 where group_id=? and ppt_sort <= ? and ppt_sort> ? ` //_, err = o.Raw(sql, groupId, prevSort, currentSort).Exec() err = global.DmSQL["rddp"].Exec(sql, groupId, prevSort, currentSort).Error return } // GetGroupPptByPptId 根据pptID 查找各个目录下的ppt func GetGroupPptByPptId(pptId int) (list []*PptV2GroupMapping, err error) { //o := orm.NewOrmUsingDB("rddp") sql := `select * from ppt_v2_group_mapping where ppt_id=?` //_, err = o.Raw(sql, pptId).QueryRows(&list) err = global.DmSQL["rddp"].Raw(sql, pptId).Find(&list).Error return } // GetPublicGroupPptByPptIds 根据pptid查询公共目录下的ppt func GetPublicGroupPptByPptIds(pptIds []string) (list []*PptV2GroupMapping, err error) { qb, _ := orm.NewQueryBuilder("mysql") // 构建查询对象 qb.Select("p.*"). From("ppt_v2_group as g"). InnerJoin("ppt_v2_group_mapping as p").On("g.group_id = p.group_id"). Where("g.is_share = 1 and p.ppt_id").In(pptIds...). OrderBy("g.share_time asc, p.ppt_sort asc") // 导出 SQL 语句 sql := qb.String() // 执行 SQL 语句 //o := orm.NewOrmUsingDB("rddp") //_, err = o.Raw(sql).QueryRows(&list) err = global.DmSQL["rddp"].Raw(sql).Find(&list).Error return }