excel_info.go 24 KB

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