excel_info.go 30 KB

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