excel_info.go 28 KB

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