excel_info.go 26 KB

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