123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329 |
- package models
- import (
- "errors"
- "eta_gn/eta_api/global"
- "eta_gn/eta_api/models/report"
- "eta_gn/eta_api/utils"
- )
- func AddReportAndChapter(reportItem *Report, allGrantUserList []*report.ReportGrant, addReportChapterList []AddReportChapter) (reportId int64, err error) {
- to := global.DmSQL["rddp"].Begin()
- defer func() {
- if err != nil {
- _ = to.Rollback()
- } else {
- _ = to.Commit()
- }
- }()
- err = to.Create(reportItem).Error
- reportId = int64(reportItem.Id)
- if err != nil {
- return
- }
- reportItem.Id = int(reportId)
- if len(allGrantUserList) > 0 {
- for _, v := range allGrantUserList {
- v.ReportId = reportItem.Id
- }
- err = to.CreateInBatches(allGrantUserList, utils.MultiAddNum).Error
- if err != nil {
- return
- }
- }
- if len(addReportChapterList) > 0 {
- for _, addReportChapter := range addReportChapterList {
- chapterItem := addReportChapter.ReportChapter
- chapterItem.ReportId = int(reportId)
- tmpErr := to.Create(chapterItem).Error
- if tmpErr != nil {
- err = tmpErr
- return
- }
- cpId := chapterItem.ReportChapterId
- chapterItem.ReportChapterId = int(cpId)
- if len(addReportChapter.GrantList) > 0 {
- grantList := addReportChapter.GrantList
- for _, v := range grantList {
- v.ReportChapterId = chapterItem.ReportChapterId
- }
- err = to.CreateInBatches(grantList, utils.MultiAddNum).Error
- if err != nil {
- return
- }
- }
- if len(addReportChapter.GrantPermissionList) > 0 {
- permissionList := addReportChapter.GrantPermissionList
- for _, v := range permissionList {
- v.ReportChapterId = chapterItem.ReportChapterId
- }
- err = to.CreateInBatches(permissionList, utils.MultiAddNum).Error
- if err != nil {
- return
- }
- }
- }
- }
- return
- }
- func EditReportAndPermission(reportInfo *Report, updateCols []string, addReportGrantList []*report.ReportGrant, delReportGrantIdList []int) (err error) {
- to := global.DmSQL["rddp"].Begin()
- defer func() {
- if err != nil {
- _ = to.Rollback()
- } else {
- _ = to.Commit()
- }
- }()
- if len(updateCols) > 0 {
- err = to.Select(updateCols).Updates(reportInfo).Error
- if err != nil {
- return
- }
- }
- if len(addReportGrantList) > 0 {
- err = to.CreateInBatches(addReportGrantList, utils.MultiAddNum).Error
- if err != nil {
- return
- }
- }
- delNum := len(delReportGrantIdList)
- if delNum > 0 {
- sql := `DELETE FROM report_grant WHERE grant_id IN (` + utils.GetOrmInReplace(delNum) + `)`
- err = to.Exec(sql, delReportGrantIdList).Error
- if err != nil {
- return
- }
- }
- return
- }
- func AddChapterBaseInfoAndPermission(reportChapterInfo *ReportChapter, addReportChapterGrantList []*report.ReportChapterGrant, addChapterPermissionMap []*report.ReportChapterPermissionMapping) (err error) {
- to := global.DmSQL["rddp"].Begin()
- defer func() {
- if err != nil {
- _ = to.Rollback()
- } else {
- _ = to.Commit()
- }
- }()
- err = to.Create(reportChapterInfo).Error
- if err != nil {
- return
- }
- lastId := reportChapterInfo.ReportChapterId
- reportChapterInfo.ReportChapterId = int(lastId)
- if len(addReportChapterGrantList) > 0 {
- for k, _ := range addReportChapterGrantList {
- addReportChapterGrantList[k].ReportChapterId = reportChapterInfo.ReportChapterId
- }
- err = to.CreateInBatches(addReportChapterGrantList, utils.MultiAddNum).Error
- if err != nil {
- return
- }
- }
- if len(addChapterPermissionMap) > 0 {
- for k, _ := range addChapterPermissionMap {
- addChapterPermissionMap[k].ReportChapterId = reportChapterInfo.ReportChapterId
- }
- err = to.CreateInBatches(addChapterPermissionMap, utils.MultiAddNum).Error
- if err != nil {
- return
- }
- }
- return
- }
- func EditChapterBaseInfoAndPermission(reportInfo *Report, reportChapterInfo *ReportChapter, updateCols []string, addReportChapterGrantList []*report.ReportChapterGrant, addChapterPermissionMap []*report.ReportChapterPermissionMapping, delReportChapterGrantIdList, delChapterPermissionMappingIdList []int) (err error) {
- to := global.DmSQL["rddp"].Begin()
- defer func() {
- if err != nil {
- _ = to.Rollback()
- } else {
- _ = to.Commit()
- }
- }()
- {
- err = to.Select("LastModifyAdminId", "LastModifyAdminName", "ModifyTime").Updates(reportInfo).Error
- if err != nil {
- return
- }
- }
- if len(updateCols) > 0 {
- err = to.Select(updateCols).Updates(reportChapterInfo).Error
- if err != nil {
- return
- }
- }
- if len(addReportChapterGrantList) > 0 {
- err = to.CreateInBatches(addReportChapterGrantList, utils.MultiAddNum).Error
- if err != nil {
- return
- }
- }
- delNum := len(delReportChapterGrantIdList)
- if delNum > 0 {
- sql := `DELETE FROM report_chapter_grant WHERE grant_id IN (` + utils.GetOrmInReplace(delNum) + `)`
- err = to.Exec(sql, delReportChapterGrantIdList).Error
- if err != nil {
- return
- }
- }
- if len(addChapterPermissionMap) > 0 {
- err = to.CreateInBatches(addChapterPermissionMap, utils.MultiAddNum).Error
- if err != nil {
- return
- }
- }
- delNum = len(delChapterPermissionMappingIdList)
- if delNum > 0 {
- sql := `DELETE FROM report_chapter_permission_mapping WHERE report_chapter_permission_mapping_id IN (` + utils.GetOrmInReplace(delNum) + `)`
- err = to.Exec(sql, delChapterPermissionMappingIdList).Error
- if err != nil {
- return
- }
- }
- return
- }
- func DelChapterAndPermission(reportInfo *Report, updateReportCols []string, reportChapterInfo *ReportChapter) (err error) {
- to := global.DmSQL["rddp"].Begin()
- defer func() {
- if err != nil {
- _ = to.Rollback()
- } else {
- _ = to.Commit()
- }
- }()
- if len(updateReportCols) > 0 {
- err = to.Select(updateReportCols).Updates(reportInfo).Error
- if err != nil {
- return
- }
- }
- {
- err = to.Delete(reportChapterInfo).Error
- if err != nil {
- return
- }
- }
- {
- sql := `DELETE FROM report_chapter_grant WHERE report_chapter_id = ? `
- err = to.Exec(sql, reportChapterInfo.ReportChapterId).Error
- if err != nil {
- return
- }
- }
- {
- sql := `DELETE FROM report_chapter_permission_mapping WHERE report_chapter_id = ? `
- err = to.Exec(sql, reportChapterInfo.ReportChapterId).Error
- if err != nil {
- return
- }
- }
- return
- }
- func GetReportListCountByAuthorized(condition string, pars []interface{}) (count int, err error) {
- sql := `SELECT COUNT(1) AS count FROM report as a
- WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
- return
- }
- func GetReportListByAuthorized(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
- sql := `SELECT id,classify_id_first,classify_name_first,classify_id_second,classify_name_second,classify_id_third,classify_name_third,title,stage,create_time,author,report_layout,collaborate_type,is_public_publish,abstract,has_chapter,publish_time,report_create_time FROM report as a WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- sql += ` GROUP BY id,classify_id_first,classify_name_first,classify_id_second,classify_name_second,classify_id_third,classify_name_third,title,stage,create_time,author,report_layout,collaborate_type,is_public_publish,abstract,has_chapter,publish_time,report_create_time
- ORDER BY report_create_time DESC LIMIT ?,?`
- pars = append(pars, startSize)
- pars = append(pars, pageSize)
- err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
- return
- }
- func ModifyReportClassifyAndReportChapterTypeByCondition(condition string, pars []interface{}, updateStr string, chapterTypeIdMap map[int]int, oldClassifyId, currClassifyId int, currClassifyName string) (err error) {
- to := global.DmSQL["rddp"].Begin()
- defer func() {
- if err != nil {
- _ = to.Rollback()
- } else {
- _ = to.Commit()
- }
- }()
- if condition == `` {
- err = errors.New("condition不能为空")
- return
- }
- sql := `UPDATE report as a SET ` + updateStr + ` WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- err = to.Exec(sql, pars...).Error
- if err != nil {
- return
- }
- sql = `UPDATE report_chapter set classify_id_first=?,classify_name_first=? where classify_id_first = ?`
- err = to.Exec(sql, currClassifyId, currClassifyName, oldClassifyId).Error
- if err != nil {
- return
- }
- for currTypeId, oldTypeId := range chapterTypeIdMap {
- if oldTypeId == 0 {
- continue
- }
- tmpSql := `UPDATE report_chapter set type_id=? where type_id = ?`
- err = to.Exec(tmpSql, currTypeId, oldTypeId).Error
- if err != nil {
- return
- }
- }
- return
- }
- type EditLayoutImgReq struct {
- ReportId int64 `description:"报告id"`
- HeadImg string `description:"报告头图地址"`
- EndImg string `description:"报告尾图地址"`
- CanvasColor string `description:"画布颜色"`
- HeadResourceId int `description:"版头资源ID"`
- EndResourceId int `description:"版尾资源ID"`
- }
|