123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441 |
- 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"`
- }
- func MoveReportClassify(firstId, secondId, thirdId int, firstName, secondName, thirdName string, originFirst, originSecond int) (err error) {
- sql := `UPDATE report SET classify_id_first = ?, classify_id_second = ?, classify_id_third = ?, classify_name_first = ?, classify_name_second = ?, classify_name_third = ? WHERE classify_id_first = ? AND classify_id_second = ?`
- err = global.DmSQL["rddp"].Exec(sql, firstId, secondId, thirdId, firstName, secondName, thirdName, originFirst, originSecond).Error
- return
- }
|