excel_info.go 25 KB

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