excel_info.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669
  1. package excel
  2. import (
  3. "eta/eta_api/utils"
  4. "fmt"
  5. "github.com/beego/beego/v2/client/orm"
  6. "time"
  7. )
  8. // ExcelInfo excel表格详情表
  9. type ExcelInfo struct {
  10. ExcelInfoId int `orm:"column(excel_info_id);pk"`
  11. Source int `description:"表格来源,1:excel插件的表格,2:自定义表格,3:混合表格,4:自定义分析,默认:1"`
  12. ExcelType int `description:"表格类型,1:指标列,2:日期列,默认:1"`
  13. ExcelName string `description:"表格名称"`
  14. UniqueCode string `description:"表格唯一编码"`
  15. ExcelClassifyId int `description:"表格分类id"`
  16. SysUserId int `description:"操作人id"`
  17. SysUserRealName string `description:"操作人真实姓名"`
  18. Content string `description:"表格内容"`
  19. ExcelImage string `description:"表格图片"`
  20. FileUrl string `description:"表格下载地址"`
  21. Sort int `description:"排序字段,数字越小越排前面"`
  22. IsDelete int `description:"是否删除,0:未删除,1:已删除"`
  23. ModifyTime time.Time `description:"最近修改日期"`
  24. CreateTime time.Time `description:"创建日期"`
  25. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
  26. ParentId int `description:"表格的父级id"`
  27. BalanceType int `description:"平衡表类型:0 动态表,1静态表"`
  28. UpdateUserId int `description:"更新人id"`
  29. UpdateUserRealName string `description:"更新人真实姓名"`
  30. }
  31. // Update 更新 excel表格基础信息
  32. func (excelInfo *ExcelInfo) Update(cols []string) (err error) {
  33. o := orm.NewOrmUsingDB("data")
  34. _, err = o.Update(excelInfo, cols...)
  35. return
  36. }
  37. type MyExcelInfoList struct {
  38. ExcelInfoId int `orm:"column(excel_info_id);pk"`
  39. Source int `description:"表格来源,1:excel插件的表格,2:自定义表格,默认:1"`
  40. ExcelType int `description:"表格类型,1:指标列,2:日期列,默认:1"`
  41. ExcelName string `description:"表格名称"`
  42. UniqueCode string `description:"表格唯一编码"`
  43. ExcelClassifyId int `description:"表格分类id"`
  44. SysUserId int `description:"操作人id"`
  45. SysUserRealName string `description:"操作人真实姓名"`
  46. ExcelImage string `description:"表格图片"`
  47. FileUrl string `description:"表格下载地址"`
  48. Sort int `description:"排序字段,数字越小越排前面"`
  49. ModifyTime time.Time `description:"最近修改日期"`
  50. CreateTime time.Time `description:"创建日期"`
  51. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
  52. HaveOperaAuth bool `description:"是否有数据权限"`
  53. UpdateUserId int `description:"更新人id"`
  54. UpdateUserRealName string `description:"更新人真实姓名"`
  55. }
  56. // AddExcelInfo 新增表格
  57. func AddExcelInfo(excelInfo *ExcelInfo, excelEdbMappingList []*ExcelEdbMapping, childExcel *ExcelInfo) (err error) {
  58. o, err := orm.NewOrmUsingDB("data").Begin()
  59. if err != nil {
  60. return
  61. }
  62. defer func() {
  63. if err != nil {
  64. _ = o.Rollback()
  65. } else {
  66. _ = o.Commit()
  67. }
  68. }()
  69. // 表格信息入库
  70. lastId, err := o.Insert(excelInfo)
  71. if err != nil {
  72. return
  73. }
  74. excelInfo.ExcelInfoId = int(lastId)
  75. // todo 判断如果是平衡表的父级,则新增一个名叫平衡表的子表, 内容为空
  76. if childExcel != nil {
  77. // 表格信息入库
  78. childExcel.ParentId = excelInfo.ExcelInfoId
  79. _, err = o.Insert(childExcel)
  80. if err != nil {
  81. err = fmt.Errorf("新增子表失败:%v", err)
  82. return
  83. }
  84. }
  85. // excel与指标的关联关系
  86. dataNum := len(excelEdbMappingList)
  87. if dataNum > 0 {
  88. for k, v := range excelEdbMappingList {
  89. v.ExcelInfoId = excelInfo.ExcelInfoId
  90. excelEdbMappingList[k] = v
  91. }
  92. _, err = o.InsertMulti(dataNum, excelEdbMappingList)
  93. }
  94. return
  95. }
  96. // EditExcelInfo 编辑表格
  97. func EditExcelInfo(excelInfo *ExcelInfo, updateExcelInfoParams []string, excelEdbMappingList []*ExcelEdbMapping) (err error) {
  98. o, err := orm.NewOrmUsingDB("data").Begin()
  99. if err != nil {
  100. return
  101. }
  102. defer func() {
  103. if err != nil {
  104. _ = o.Rollback()
  105. } else {
  106. _ = o.Commit()
  107. }
  108. }()
  109. // ETA表格信息变更
  110. _, err = o.Update(excelInfo, updateExcelInfoParams...)
  111. if err != nil {
  112. return
  113. }
  114. //更新父级分类时,同时更新子集分类
  115. if excelInfo.Source == utils.BALANCE_TABLE && excelInfo.ParentId == 0 {
  116. // 同步更新子表分类
  117. sql := `UPDATE FROM excel_info set excel_classify_id = ? WHERE parent_id=? `
  118. _, err = o.Raw(sql, excelInfo.ExcelClassifyId, excelInfo.ExcelInfoId).Exec()
  119. }
  120. // 删除关系表
  121. sql := `DELETE FROM excel_edb_mapping WHERE excel_info_id=? `
  122. _, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
  123. // excel与指标的关联关系
  124. dataNum := len(excelEdbMappingList)
  125. if dataNum > 0 {
  126. for k, v := range excelEdbMappingList {
  127. v.ExcelInfoId = excelInfo.ExcelInfoId
  128. excelEdbMappingList[k] = v
  129. }
  130. _, err = o.InsertMulti(dataNum, excelEdbMappingList)
  131. }
  132. return
  133. }
  134. // GetExcelInfoAll 获取所有表格列表,用于分类展示
  135. func GetExcelInfoAll() (items []*ExcelClassifyItems, err error) {
  136. o := orm.NewOrmUsingDB("data")
  137. sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  138. unique_code,sys_user_id,sys_user_real_name,is_join_permission
  139. FROM excel_info where is_delete=0 ORDER BY sort asc,create_time ASC `
  140. _, err = o.Raw(sql).QueryRows(&items)
  141. return
  142. }
  143. // GetNoContentExcelInfoAll 获取不含content的表格列表 用于分类展示
  144. func GetNoContentExcelInfoAll(source, userId int) (items []*ExcelClassifyItems, err error) {
  145. o := orm.NewOrmUsingDB("data")
  146. sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  147. unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission
  148. FROM excel_info where is_delete=0 AND source = ? `
  149. pars := []interface{}{source}
  150. if userId > 0 {
  151. sql += ` AND sys_user_id = ? `
  152. pars = append(pars, userId)
  153. }
  154. if source == utils.BALANCE_TABLE { //平衡表的列表只显示动态表的一级表(不显示子表和静态表)
  155. sql += " AND parent_id = 0 AND balance_type=0 "
  156. }
  157. sql += ` ORDER BY sort asc,excel_info_id desc `
  158. _, err = o.Raw(sql, pars...).QueryRows(&items)
  159. return
  160. }
  161. // GetAllExcelInfoBySource 根据来源获取包含content的表格列表
  162. func GetAllExcelInfoBySource(source int) (items []*ExcelInfo, err error) {
  163. o := orm.NewOrmUsingDB("data")
  164. sql := ` SELECT * FROM excel_info where is_delete=0 AND source = ? ORDER BY sort asc,create_time desc `
  165. _, err = o.Raw(sql, source).QueryRows(&items)
  166. return
  167. }
  168. // GetExcelInfoById 根据id 获取eta表格详情
  169. func GetExcelInfoById(excelInfoId int) (item *ExcelInfo, err error) {
  170. o := orm.NewOrmUsingDB("data")
  171. sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  172. err = o.Raw(sql, excelInfoId).QueryRow(&item)
  173. return
  174. }
  175. // GetExcelInfoByUnicode 编码获取表格
  176. func GetExcelInfoByUnicode(unicode string) (item *ExcelInfo, err error) {
  177. o := orm.NewOrmUsingDB("data")
  178. sql := ` SELECT * FROM excel_info WHERE unique_code = ? AND is_delete = 0 `
  179. err = o.Raw(sql, unicode).QueryRow(&item)
  180. return
  181. }
  182. func GetExcelInfoViewById(excelInfoId int) (item *ExcelInfoView, err error) {
  183. o := orm.NewOrmUsingDB("data")
  184. sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  185. err = o.Raw(sql, excelInfoId).QueryRow(&item)
  186. return
  187. }
  188. func GetExcelInfoCountByCondition(condition string, pars []interface{}) (count int, err error) {
  189. o := orm.NewOrmUsingDB("data")
  190. sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
  191. if condition != "" {
  192. sql += condition
  193. }
  194. err = o.Raw(sql, pars).QueryRow(&count)
  195. return
  196. }
  197. func GetNoContentExcelInfoListByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*ExcelClassifyItems, err error) {
  198. o := orm.NewOrmUsingDB("data")
  199. sql := `SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  200. unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission FROM excel_info WHERE 1=1 `
  201. if condition != "" {
  202. sql += condition
  203. }
  204. sql += ` AND is_delete=0 ORDER BY excel_info_id DESC LIMIT ?,? `
  205. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  206. return
  207. }
  208. func GetExcelInfoByCondition(condition string, pars []interface{}) (item *ExcelInfo, err error) {
  209. o := orm.NewOrmUsingDB("data")
  210. sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  211. if condition != "" {
  212. sql += condition
  213. }
  214. err = o.Raw(sql, pars).QueryRow(&item)
  215. return
  216. }
  217. // GetNextExcelInfoByCondition 根据条件获取下一个表格
  218. func GetNextExcelInfoByCondition(condition string, pars []interface{}) (item *ExcelInfo, err error) {
  219. o := orm.NewOrmUsingDB("data")
  220. sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  221. if condition != "" {
  222. sql += condition
  223. }
  224. sql += " ORDER BY sort asc , create_time desc LIMIT 1 "
  225. err = o.Raw(sql, pars).QueryRow(&item)
  226. return
  227. }
  228. // GetNextExcelInfo 根据分类id获取下一个excel表格
  229. func GetNextExcelInfo(classifyId, classifySort, source int) (item *ExcelInfo, err error) {
  230. o := orm.NewOrmUsingDB("data")
  231. sql := ` SELECT b.* FROM excel_classify AS a
  232. INNER JOIN excel_info AS b ON a.excel_classify_id=b.excel_classify_id
  233. WHERE (a.sort>? OR (a.sort=? and a.excel_classify_id>?) ) AND a.is_delete=0 AND b.is_delete=0
  234. AND a.source = ? AND b.source = ?
  235. ORDER BY a.sort ASC,b.sort asc,b.create_time desc
  236. LIMIT 1 `
  237. err = o.Raw(sql, classifySort, classifySort, classifyId, source, source).QueryRow(&item)
  238. return
  239. }
  240. // EditExcelInfoImage 修改excel表格的图片
  241. func EditExcelInfoImage(excelInfoId int, imageUrl string) (err error) {
  242. o := orm.NewOrmUsingDB("data")
  243. sql := ` UPDATE excel_info SET excel_image=?, modify_time = NOW() WHERE excel_info_id = ? AND is_delete=0 `
  244. _, err = o.Raw(sql, imageUrl, excelInfoId).Exec()
  245. if err != nil {
  246. fmt.Println("EditExcelInfoImage Err:", err.Error())
  247. return err
  248. }
  249. return
  250. }
  251. // GetExcelInfoByUniqueCode 根据unique_code来获取excel表格详情
  252. func GetExcelInfoByUniqueCode(uniqueCode string) (item *ExcelInfo, err error) {
  253. o := orm.NewOrmUsingDB("data")
  254. sql := ` SELECT * FROM excel_info WHERE unique_code=? AND is_delete=0 `
  255. err = o.Raw(sql, uniqueCode).QueryRow(&item)
  256. return
  257. }
  258. // GetFirstExcelInfoByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
  259. func GetFirstExcelInfoByClassifyId(classifyId int) (item *ExcelInfo, err error) {
  260. o := orm.NewOrmUsingDB("data")
  261. sql := ` SELECT * FROM excel_info WHERE excel_classify_id=? AND is_delete=0 order by sort asc,excel_info_id desc limit 1`
  262. err = o.Raw(sql, classifyId).QueryRow(&item)
  263. return
  264. }
  265. // UpdateExcelInfoSortByClassifyId 根据表格id更新排序
  266. func UpdateExcelInfoSortByClassifyId(classifyId, nowSort, prevExcelInfoId int, updateSort string, source int) (err error) {
  267. o := orm.NewOrmUsingDB("data")
  268. sql := ` update excel_info set sort = ` + updateSort + ` WHERE excel_classify_id=? AND source=? AND is_delete=0 AND ( sort > ? `
  269. // todo 前一个兄弟节点后移
  270. if prevExcelInfoId > 0 {
  271. sql += ` or (excel_info_id < ` + fmt.Sprint(prevExcelInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
  272. }
  273. sql += `)`
  274. _, err = o.Raw(sql, classifyId, source, nowSort).Exec()
  275. return
  276. }
  277. type ExcelInfoView struct {
  278. ExcelInfoId int `orm:"column(excel_info_id);pk"`
  279. ExcelName string `description:"来源名称"`
  280. ExcelClassifyId int `description:"表格分类id"`
  281. ExcelClassifyName string `description:"表格名称"`
  282. SysUserId int
  283. SysUserRealName string
  284. UniqueCode string `description:"表格唯一编码"`
  285. CreateTime time.Time
  286. ModifyTime time.Time
  287. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"`
  288. StartDate string `description:"自定义开始日期"`
  289. EndDate string `description:"自定义结束日期"`
  290. IsSetName int `description:"设置名称"`
  291. EdbInfoIds string `description:"指标id"`
  292. ExcelType int `description:"生成样式:1:曲线图,2:季节性图"`
  293. Calendar string `description:"公历/农历"`
  294. SeasonStartDate string `description:"季节性图开始日期"`
  295. SeasonEndDate string `description:"季节性图开始日期"`
  296. ExcelImage string `description:"表格图片"`
  297. Sort int `description:"排序字段,数字越小越排前面"`
  298. IsAdd bool `description:"true:已加入我的图库,false:未加入我的图库"`
  299. MyExcelId int
  300. MyExcelClassifyId string `description:"我的表格分类,多个用逗号隔开"`
  301. ExcelClassify []*ExcelClassifyView
  302. EdbEndDate string `description:"指标最新更新日期"`
  303. LeftMin string `description:"表格左侧最小值"`
  304. LeftMax string `description:"表格左侧最大值"`
  305. RightMin string `description:"表格右侧最小值"`
  306. RightMax string `description:"表格右侧最大值"`
  307. }
  308. // GetExcelInfoByClassifyIdAndName 根据分类id和表格名获取表格信息
  309. func GetExcelInfoByClassifyIdAndName(classifyId int, excelName string) (item *ExcelInfo, err error) {
  310. o := orm.NewOrmUsingDB("data")
  311. sql := ` SELECT * FROM excel_info WHERE excel_classify_id = ? and excel_name=? AND is_delete=0 `
  312. err = o.Raw(sql, classifyId, excelName).QueryRow(&item)
  313. return
  314. }
  315. // GetNoContentExcelListByCondition 获取没有content的excel表格列表数据
  316. func GetNoContentExcelListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*MyExcelInfoList, err error) {
  317. o := orm.NewOrmUsingDB("data")
  318. sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name
  319. FROM excel_info WHERE 1=1 AND is_delete=0 `
  320. if condition != "" {
  321. sql += condition
  322. }
  323. //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  324. sql += " ORDER BY create_time DESC LIMIT ?,? "
  325. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&item)
  326. return
  327. }
  328. func GetExcelListCountByCondition(condition string, pars []interface{}) (count int, err error) {
  329. o := orm.NewOrmUsingDB("data")
  330. sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
  331. if condition != "" {
  332. sql += condition
  333. }
  334. err = o.Raw(sql, pars).QueryRow(&count)
  335. return
  336. }
  337. // GetExcelViewInfoByExcelInfoId 根据excelInfoId 获取ETA表格详情
  338. func GetExcelViewInfoByExcelInfoId(excelInfoId int) (item *MyExcelInfoList, err error) {
  339. o := orm.NewOrmUsingDB("data")
  340. sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission FROM excel_info WHERE excel_info_id = ? AND is_delete=0 `
  341. err = o.Raw(sql, excelInfoId).QueryRow(&item)
  342. return
  343. }
  344. // GetExcelInfoCountByClassifyId 根据分类id获取名下表格数量
  345. func GetExcelInfoCountByClassifyId(classifyId int) (total int64, err error) {
  346. o := orm.NewOrmUsingDB("data")
  347. sql := ` SELECT count(1) total FROM excel_info WHERE excel_classify_id = ? AND is_delete=0 `
  348. err = o.Raw(sql, classifyId).QueryRow(&total)
  349. return
  350. }
  351. // UpdateExcelInfoClassifyId 更改表格分类
  352. func UpdateExcelInfoClassifyId(classifyId, excelInfoId int) (err error) {
  353. o := orm.NewOrmUsingDB("data")
  354. sql := ` update excel_info set excel_classify_id = ? WHERE excel_info_id=? `
  355. _, err = o.Raw(sql, classifyId, excelInfoId).Exec()
  356. return
  357. }
  358. // GetNoContentExcelInfoByName 根据名称 获取eta表格详情
  359. func GetNoContentExcelInfoByName(excelName string, source int) (item *MyExcelInfoList, err error) {
  360. o := orm.NewOrmUsingDB("data")
  361. sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name
  362. FROM excel_info WHERE excel_name = ? AND source = ? AND is_delete=0 `
  363. err = o.Raw(sql, excelName, source).QueryRow(&item)
  364. return
  365. }
  366. // GetNoContentExcelInfoByUniqueCode 根据unique_code来获取excel表格详情
  367. func GetNoContentExcelInfoByUniqueCode(uniqueCode string) (item *MyExcelInfoList, err error) {
  368. o := orm.NewOrmUsingDB("data")
  369. sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name
  370. FROM excel_info WHERE unique_code=? AND is_delete=0 `
  371. err = o.Raw(sql, uniqueCode).QueryRow(&item)
  372. return
  373. }
  374. // GetNoContentExcelInfoByExcelId 根据表格id来获取excel表格详情
  375. func GetNoContentExcelInfoByExcelId(excelInfoId int) (item *MyExcelInfoList, err error) {
  376. o := orm.NewOrmUsingDB("data")
  377. sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name
  378. FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  379. err = o.Raw(sql, excelInfoId).QueryRow(&item)
  380. return
  381. }
  382. // AddExcelInfoAndSheet 新增excel
  383. func AddExcelInfoAndSheet(excelInfo *ExcelInfo, sheetParamsList []AddExcelSheetParams) (err error) {
  384. o, err := orm.NewOrmUsingDB("data").Begin()
  385. if err != nil {
  386. return
  387. }
  388. defer func() {
  389. if err != nil {
  390. _ = o.Rollback()
  391. } else {
  392. _ = o.Commit()
  393. }
  394. }()
  395. // 表格信息入库
  396. lastId, err := o.Insert(excelInfo)
  397. if err != nil {
  398. return
  399. }
  400. excelInfo.ExcelInfoId = int(lastId)
  401. // sheet信息入库
  402. for _, sheetInfo := range sheetParamsList {
  403. dataNum := len(sheetInfo.DataList)
  404. //sheet信息入库
  405. excelSheetInfo := &ExcelSheet{
  406. ExcelSheetId: 0,
  407. ExcelInfoId: excelInfo.ExcelInfoId,
  408. SheetName: sheetInfo.SheetName,
  409. PageNum: dataNum,
  410. Index: sheetInfo.Index,
  411. Sort: sheetInfo.Sort,
  412. Config: sheetInfo.Config,
  413. CalcChain: sheetInfo.CalcChain,
  414. ModifyTime: time.Now(),
  415. CreateTime: time.Now(),
  416. }
  417. sheetId, tmpErr := o.Insert(excelSheetInfo)
  418. if tmpErr != nil {
  419. err = tmpErr
  420. return
  421. }
  422. excelSheetInfo.ExcelSheetId = int(sheetId)
  423. // data信息入库
  424. if dataNum > 0 {
  425. for k, _ := range sheetInfo.DataList {
  426. sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
  427. sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
  428. }
  429. _, tmpErr = o.InsertMulti(dataNum, sheetInfo.DataList)
  430. if tmpErr != nil {
  431. err = tmpErr
  432. return
  433. }
  434. }
  435. }
  436. return
  437. }
  438. // SaveExcelInfoAndSheet 编辑保存
  439. func SaveExcelInfoAndSheet(excelInfo *ExcelInfo, updateExcelInfoParam []string, sheetParamsList []AddExcelSheetParams) (err error) {
  440. o, err := orm.NewOrmUsingDB("data").Begin()
  441. if err != nil {
  442. return
  443. }
  444. defer func() {
  445. if err != nil {
  446. _ = o.Rollback()
  447. } else {
  448. _ = o.Commit()
  449. }
  450. }()
  451. // 表格信息入库
  452. _, err = o.Update(excelInfo, updateExcelInfoParam...)
  453. if err != nil {
  454. return
  455. }
  456. // 先删除历史的sheet信息
  457. sql := `DELETE FROM excel_sheet WHERE excel_info_id = ?`
  458. _, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
  459. if err != nil {
  460. return
  461. }
  462. // 再删除历史sheet中的cell data信息
  463. sql = `DELETE FROM excel_sheet_data WHERE excel_info_id = ?`
  464. _, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
  465. if err != nil {
  466. return
  467. }
  468. // sheet信息入库
  469. for _, sheetInfo := range sheetParamsList {
  470. dataNum := len(sheetInfo.DataList)
  471. //sheet信息入库
  472. excelSheetInfo := &ExcelSheet{
  473. ExcelSheetId: 0,
  474. ExcelInfoId: excelInfo.ExcelInfoId,
  475. SheetName: sheetInfo.SheetName,
  476. PageNum: dataNum,
  477. Index: sheetInfo.Index,
  478. Sort: sheetInfo.Sort,
  479. Config: sheetInfo.Config,
  480. CalcChain: sheetInfo.CalcChain,
  481. ModifyTime: time.Now(),
  482. CreateTime: time.Now(),
  483. }
  484. sheetId, tmpErr := o.Insert(excelSheetInfo)
  485. if tmpErr != nil {
  486. err = tmpErr
  487. return
  488. }
  489. excelSheetInfo.ExcelSheetId = int(sheetId)
  490. // data信息入库
  491. if dataNum > 0 {
  492. for k, _ := range sheetInfo.DataList {
  493. sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
  494. sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
  495. }
  496. _, tmpErr = o.InsertMulti(dataNum, sheetInfo.DataList)
  497. if tmpErr != nil {
  498. err = tmpErr
  499. return
  500. }
  501. }
  502. }
  503. return
  504. }
  505. // BatchRefreshExcelReq 批量刷新表格请求
  506. type BatchRefreshExcelReq struct {
  507. ExcelCodes []string `description:"表格编码"`
  508. ReportId int `description:"报告ID"`
  509. ReportChapterId int `description:"报告章节ID"`
  510. Source string `description:"来源,枚举值:report、english_report、smart_report"`
  511. }
  512. // GetExcelMaxSortByClassifyId 获取当前分类下,且排序数最大的excel
  513. func GetExcelMaxSortByClassifyId(classifyId int, source int) (sort int, err error) {
  514. o := orm.NewOrmUsingDB("data")
  515. sql := ` SELECT Max(sort) AS sort FROM excel_info WHERE excel_classify_id=? AND source = ? AND is_delete=0 order by sort desc,excel_info_id desc limit 1`
  516. err = o.Raw(sql, classifyId, source).QueryRow(&sort)
  517. return
  518. }
  519. // GetNoContentExcelListByExcelInfoIdList
  520. // @Description: 根据ETA表格ID列表获取列表信息
  521. // @param excelInfoIdList []string
  522. // @return items
  523. // @return err
  524. func GetNoContentExcelListByExcelInfoIdList(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
  525. num := len(excelInfoIdList)
  526. if num <= 0 {
  527. return
  528. }
  529. o := orm.NewOrmUsingDB("data")
  530. sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  531. _, err = o.Raw(sql, excelInfoIdList).QueryRows(&items)
  532. return
  533. }
  534. func GetNoContentExcelListByExcelInfoIdAndParentId(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
  535. num := len(excelInfoIdList)
  536. if num <= 0 {
  537. return
  538. }
  539. o := orm.NewOrmUsingDB("data")
  540. sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) OR parent_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  541. _, err = o.Raw(sql, excelInfoIdList, excelInfoIdList).QueryRows(&items)
  542. return
  543. }
  544. // GetNoContentExcelListByUserId
  545. // @Description: 根据ETA表格ID列表获取列表信息
  546. // @param userIdList []int
  547. // @return items
  548. // @return err
  549. func GetNoContentExcelListByUserId(userIdList []int) (items []*MyExcelInfoList, err error) {
  550. num := len(userIdList)
  551. if num <= 0 {
  552. return
  553. }
  554. o := orm.NewOrmUsingDB("data")
  555. sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  556. _, err = o.Raw(sql, userIdList).QueryRows(&items)
  557. return
  558. }
  559. // ModifyExcelInfoUserIdByCodeList
  560. // @Description: 根据编码列表修改表格信息
  561. // @author: Roc
  562. // @datetime 2024-03-26 14:16:30
  563. // @param excelIdList []string
  564. // @param userId int
  565. // @param userName string
  566. // @return err error
  567. func ModifyExcelInfoUserIdByCodeList(excelIdList []string, userId int, userName string) (err error) {
  568. num := len(excelIdList)
  569. if num <= 0 {
  570. return
  571. }
  572. o := orm.NewOrmUsingDB("data")
  573. sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) `
  574. _, err = o.Raw(sql, userId, userName, excelIdList).Exec()
  575. return
  576. }
  577. // ModifyExcelInfoUserIdByOldUserId
  578. // @Description: 根据旧的用户id修改创建人
  579. // @author: Roc
  580. // @datetime 2024-03-25 19:14:59
  581. // @param oldUserId int
  582. // @param userId int
  583. // @param userName string
  584. // @return err error
  585. func ModifyExcelInfoUserIdByOldUserId(oldUserIdList []int, userId int, userName string) (err error) {
  586. num := len(oldUserIdList)
  587. if num <= 0 {
  588. return
  589. }
  590. o := orm.NewOrmUsingDB("data")
  591. sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE is_delete=0 AND sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
  592. _, err = o.Raw(sql, userId, userName, oldUserIdList).Exec()
  593. return
  594. }
  595. // GetChildExcelInfoByParentId 根据id 获取eta表格详情
  596. func GetChildExcelInfoByParentId(parentId int) (items []*ExcelInfo, err error) {
  597. o := orm.NewOrmUsingDB("data")
  598. sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission, parent_id, balance_type, update_user_id,update_user_real_name FROM excel_info WHERE parent_id=? AND is_delete=0 order by sort asc, excel_info_id asc`
  599. _, err = o.Raw(sql, parentId).QueryRows(&items)
  600. return
  601. }