excel_info.go 28 KB

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