excel_info.go 44 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119
  1. package excel
  2. import (
  3. "eta_gn/eta_api/global"
  4. "eta_gn/eta_api/models/data_manage"
  5. "eta_gn/eta_api/utils"
  6. "fmt"
  7. "strconv"
  8. "time"
  9. )
  10. // ExcelInfo excel表格详情表
  11. type ExcelInfo struct {
  12. ExcelInfoId int `orm:"column(excel_info_id);pk"`
  13. Source int `description:"表格来源,1:excel插件的表格,2:自定义表格,3:混合表格,4:自定义分析,默认:1"`
  14. ExcelType int `description:"表格类型,1:指标列,2:日期列,默认:1"`
  15. ExcelName string `description:"表格名称"`
  16. UniqueCode string `description:"表格唯一编码"`
  17. ExcelClassifyId int `description:"表格分类id"`
  18. SysUserId int `description:"操作人id"`
  19. SysUserRealName string `description:"操作人真实姓名"`
  20. Content string `description:"表格内容"`
  21. ExcelImage string `description:"表格图片"`
  22. FileUrl string `description:"表格下载地址"`
  23. Sort int `description:"排序字段,数字越小越排前面"`
  24. IsDelete int `description:"是否删除,0:未删除,1:已删除"`
  25. ModifyTime time.Time `description:"最近修改日期"`
  26. CreateTime time.Time `description:"创建日期"`
  27. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
  28. ParentId int `description:"表格的父级id"`
  29. BalanceType int `description:"平衡表类型:0 动态表,1静态表"`
  30. UpdateUserId int `description:"更新人id"`
  31. UpdateUserRealName string `description:"更新人真实姓名"`
  32. RelExcelInfoId int `description:"平衡表里静态表关联的动态表excel id"`
  33. VersionName string `description:"静态表版本名称"`
  34. SourcesFrom string `description:"图表来源"`
  35. }
  36. // Update 更新 excel表格基础信息
  37. func (excelInfo *ExcelInfo) Update(cols []string) (err error) {
  38. //o := orm.NewOrmUsingDB("data")
  39. //_, err = o.Update(excelInfo, cols...)
  40. err = global.DmSQL["data"].Select(cols).Updates(excelInfo).Error
  41. return
  42. }
  43. type MyExcelInfoList struct {
  44. ExcelInfoId int `orm:"column(excel_info_id);pk"`
  45. Source int `description:"表格来源,1:excel插件的表格,2:自定义表格,默认:1"`
  46. ExcelType int `description:"表格类型,1:指标列,2:日期列,默认:1"`
  47. ExcelName string `description:"表格名称"`
  48. UniqueCode string `description:"表格唯一编码"`
  49. ExcelClassifyId int `description:"表格分类id"`
  50. SysUserId int `description:"操作人id"`
  51. SysUserRealName string `description:"操作人真实姓名"`
  52. ExcelImage string `description:"表格图片"`
  53. FileUrl string `description:"表格下载地址"`
  54. Sort int `description:"排序字段,数字越小越排前面"`
  55. ModifyTime time.Time `description:"最近修改日期"`
  56. CreateTime time.Time `description:"创建日期"`
  57. IsJoinPermission int `description:"是否加入权限管控,0:不加入;1:加入;默认:0"`
  58. HaveOperaAuth bool `description:"是否有数据权限"`
  59. UpdateUserId int `description:"更新人id"`
  60. UpdateUserRealName string `description:"更新人真实姓名"`
  61. Button ExcelInfoDetailButton `description:"操作权限"`
  62. CanEdit bool `description:"是否可编辑"`
  63. Editor string `description:"编辑人"`
  64. }
  65. // AddExcelInfo 新增表格
  66. func AddExcelInfo(excelInfo *ExcelInfo, excelEdbMappingList []*ExcelEdbMapping, childExcel *ExcelInfo) (err error) {
  67. //o, err := orm.NewOrmUsingDB("data").Begin()
  68. //if err != nil {
  69. // return
  70. //}
  71. //defer func() {
  72. // if err != nil {
  73. // _ = o.Rollback()
  74. // } else {
  75. // _ = o.Commit()
  76. // }
  77. //}()
  78. to := global.DmSQL["data"].Begin()
  79. defer func() {
  80. if err != nil {
  81. _ = to.Rollback()
  82. } else {
  83. _ = to.Commit()
  84. }
  85. }()
  86. // 表格信息入库
  87. err = to.Create(excelInfo).Error
  88. if err != nil {
  89. return
  90. }
  91. //excelInfo.ExcelInfoId = excelInfo.ExcelInfoId
  92. // todo 判断如果是平衡表的父级,则新增一个名叫平衡表的子表, 内容为空
  93. if childExcel != nil {
  94. // 表格信息入库
  95. childExcel.ParentId = excelInfo.ExcelInfoId
  96. //_, err = o.Insert(childExcel)
  97. //if err != nil {
  98. // err = fmt.Errorf("新增子表失败:%v", err)
  99. // return
  100. //}
  101. err = to.Create(childExcel).Error
  102. if err != nil {
  103. err = fmt.Errorf("新增子表失败:%v", err)
  104. return
  105. }
  106. }
  107. // excel与指标的关联关系
  108. dataNum := len(excelEdbMappingList)
  109. if dataNum > 0 {
  110. for k, v := range excelEdbMappingList {
  111. v.ExcelInfoId = excelInfo.ExcelInfoId
  112. excelEdbMappingList[k] = v
  113. }
  114. //_, err = o.InsertMulti(dataNum, excelEdbMappingList)
  115. err = to.CreateInBatches(excelEdbMappingList, utils.MultiAddNum).Error
  116. }
  117. return
  118. }
  119. // EditExcelInfo 编辑表格
  120. func EditExcelInfo(excelInfo *ExcelInfo, updateExcelInfoParams []string, excelEdbMappingList []*ExcelEdbMapping) (err error) {
  121. //o, err := orm.NewOrmUsingDB("data").Begin()
  122. //if err != nil {
  123. // return
  124. //}
  125. //defer func() {
  126. // if err != nil {
  127. // _ = o.Rollback()
  128. // } else {
  129. // _ = o.Commit()
  130. // }
  131. //}()
  132. to := global.DmSQL["data"].Begin()
  133. defer func() {
  134. if err != nil {
  135. _ = to.Rollback()
  136. } else {
  137. _ = to.Commit()
  138. }
  139. }()
  140. // ETA表格信息变更
  141. err = to.Select(updateExcelInfoParams).Updates(excelInfo).Error
  142. if err != nil {
  143. return
  144. }
  145. //更新父级分类时,同时更新子集分类
  146. if excelInfo.Source == utils.BALANCE_TABLE && excelInfo.ParentId == 0 {
  147. // 同步更新子表分类
  148. //sql := `UPDATE FROM excel_info set excel_classify_id = ? WHERE parent_id=? `
  149. //_, err = o.Raw(sql, excelInfo.ExcelClassifyId, excelInfo.ExcelInfoId).Exec()
  150. sql := `UPDATE FROM excel_info set excel_classify_id = ? WHERE parent_id=? `
  151. err = to.Exec(sql, excelInfo.ExcelClassifyId, excelInfo.ExcelInfoId).Error
  152. }
  153. // 删除关系表
  154. //sql := `DELETE FROM excel_edb_mapping WHERE excel_info_id=? `
  155. //_, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
  156. sql := `DELETE FROM excel_edb_mapping WHERE excel_info_id=? `
  157. err = to.Exec(sql, excelInfo.ExcelInfoId).Error
  158. // excel与指标的关联关系
  159. dataNum := len(excelEdbMappingList)
  160. if dataNum > 0 {
  161. for k, v := range excelEdbMappingList {
  162. v.ExcelInfoId = excelInfo.ExcelInfoId
  163. excelEdbMappingList[k] = v
  164. }
  165. //_, err = o.InsertMulti(dataNum, excelEdbMappingList)
  166. err = to.CreateInBatches(excelEdbMappingList, utils.MultiAddNum).Error
  167. }
  168. return
  169. }
  170. // GetExcelInfoAll 获取所有表格列表,用于分类展示
  171. func GetExcelInfoAll() (items []*ExcelClassifyItems, err error) {
  172. //o := orm.NewOrmUsingDB("data")
  173. //sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  174. // unique_code,sys_user_id,sys_user_real_name,is_join_permission
  175. // FROM excel_info where is_delete=0 ORDER BY sort asc,create_time ASC `
  176. //_, err = o.Raw(sql).QueryRows(&items)
  177. sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  178. unique_code,sys_user_id,sys_user_real_name,is_join_permission
  179. FROM excel_info where is_delete=0 ORDER BY sort asc,create_time ASC `
  180. err = global.DmSQL["data"].Raw(sql).Find(&items).Error
  181. return
  182. }
  183. // GetNoContentExcelInfoAll 获取不含content的表格列表 用于分类展示
  184. func GetNoContentExcelInfoAll(source, userId int) (items []*ExcelClassifyItems, err error) {
  185. //o := orm.NewOrmUsingDB("data")
  186. //sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  187. // unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission
  188. // FROM excel_info where is_delete=0 AND source = ? `
  189. //
  190. //pars := []interface{}{source}
  191. //
  192. //if userId > 0 {
  193. // sql += ` AND sys_user_id = ? `
  194. // pars = append(pars, userId)
  195. //}
  196. //sql += ` ORDER BY sort asc,excel_info_id desc `
  197. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  198. sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  199. unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission
  200. FROM excel_info where is_delete=0 AND source = ? `
  201. pars := []interface{}{source}
  202. if userId > 0 {
  203. sql += ` AND sys_user_id = ? `
  204. pars = append(pars, userId)
  205. }
  206. sql += ` ORDER BY sort asc,excel_info_id desc `
  207. err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
  208. return
  209. }
  210. // GetBalanceNoContentExcelInfoAll 获取不含content的平衡表表格列表 用于分类展示
  211. func GetBalanceNoContentExcelInfoAll(source int, excelInfoIds []int, userId int) (items []*ExcelClassifyItems, err error) {
  212. //o := orm.NewOrmUsingDB("data")
  213. //sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  214. // unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission
  215. // FROM excel_info where is_delete=0 AND source = ? AND parent_id = 0 AND balance_type=0 `
  216. //
  217. //pars := []interface{}{source}
  218. //
  219. //if userId > 0 {
  220. // if len(excelInfoIds) > 0 {
  221. // sql += ` AND (excel_info_id in (` + utils.GetOrmInReplace(len(excelInfoIds)) + `) or sys_user_id = ?)`
  222. // pars = append(pars, excelInfoIds, userId)
  223. // } else {
  224. // sql += ` AND sys_user_id = ? `
  225. // pars = append(pars, userId)
  226. // }
  227. //}
  228. //
  229. //sql += ` ORDER BY sort asc,excel_info_id desc `
  230. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  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
  233. FROM excel_info where is_delete=0 AND source = ? AND parent_id = 0 AND balance_type=0 `
  234. pars := []interface{}{source}
  235. if userId > 0 {
  236. if len(excelInfoIds) > 0 {
  237. sql += ` AND (excel_info_id in (` + utils.GetOrmInReplace(len(excelInfoIds)) + `) or sys_user_id = ?)`
  238. pars = append(pars, excelInfoIds, userId)
  239. } else {
  240. sql += ` AND sys_user_id = ? `
  241. pars = append(pars, userId)
  242. }
  243. }
  244. sql += ` ORDER BY sort asc,excel_info_id desc `
  245. err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
  246. return
  247. }
  248. // GetAllExcelInfoBySource 根据来源获取包含content的表格列表
  249. func GetAllExcelInfoBySource(source int) (items []*ExcelInfo, err error) {
  250. //o := orm.NewOrmUsingDB("data")
  251. //sql := ` SELECT * FROM excel_info where is_delete=0 AND source = ? ORDER BY sort asc,create_time desc `
  252. //_, err = o.Raw(sql, source).QueryRows(&items)
  253. sql := ` SELECT * FROM excel_info where is_delete=0 AND source = ? ORDER BY sort asc,create_time desc `
  254. err = global.DmSQL["data"].Raw(sql, source).Find(&items).Error
  255. return
  256. }
  257. // GetExcelInfoById 根据id 获取eta表格详情
  258. func GetExcelInfoById(excelInfoId int) (item *ExcelInfo, err error) {
  259. //o := orm.NewOrmUsingDB("data")
  260. //sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  261. //err = o.Raw(sql, excelInfoId).QueryRow(&item)
  262. sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  263. err = global.DmSQL["data"].Raw(sql, excelInfoId).First(&item).Error
  264. return
  265. }
  266. // GetExcelInfoByUnicode 编码获取表格
  267. func GetExcelInfoByUnicode(unicode string) (item *ExcelInfo, err error) {
  268. //o := orm.NewOrmUsingDB("data")
  269. //sql := ` SELECT * FROM excel_info WHERE unique_code = ? AND is_delete = 0 `
  270. //err = o.Raw(sql, unicode).QueryRow(&item)
  271. sql := ` SELECT * FROM excel_info WHERE unique_code = ? AND is_delete = 0 `
  272. err = global.DmSQL["data"].Raw(sql, unicode).First(&item).Error
  273. return
  274. }
  275. func GetExcelInfoViewById(excelInfoId int) (item *ExcelInfoView, err error) {
  276. //o := orm.NewOrmUsingDB("data")
  277. //sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  278. //err = o.Raw(sql, excelInfoId).QueryRow(&item)
  279. sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  280. err = global.DmSQL["data"].Raw(sql, excelInfoId).First(&item).Error
  281. return
  282. }
  283. func GetExcelInfoCountByCondition(condition string, pars []interface{}) (count int, err error) {
  284. //o := orm.NewOrmUsingDB("data")
  285. //sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
  286. //if condition != "" {
  287. // sql += condition
  288. //}
  289. //err = o.Raw(sql, pars).QueryRow(&count)
  290. sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
  291. if condition != "" {
  292. sql += condition
  293. }
  294. err = global.DmSQL["data"].Raw(sql, pars).Scan(&count).Error
  295. return
  296. }
  297. func GetNoContentExcelInfoListByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*ExcelClassifyItems, err error) {
  298. //o := orm.NewOrmUsingDB("data")
  299. //sql := `SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  300. // unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission FROM excel_info WHERE 1=1 `
  301. //if condition != "" {
  302. // sql += condition
  303. //}
  304. //
  305. //sql += ` AND is_delete=0 ORDER BY excel_info_id DESC LIMIT ?,? `
  306. //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  307. sql := `SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
  308. unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission FROM excel_info WHERE 1=1 `
  309. if condition != "" {
  310. sql += condition
  311. }
  312. sql += ` AND is_delete=0 ORDER BY excel_info_id DESC LIMIT ?,? `
  313. err = global.DmSQL["data"].Raw(sql, pars, startSize, pageSize).Find(&items).Error
  314. return
  315. }
  316. func GetNoContentExcelInfoListByConditionNoPage(condition string, pars []interface{}) (items []*ExcelInfo, err error) {
  317. //o := orm.NewOrmUsingDB("data")
  318. //sql := `SELECT excel_info_id,excel_classify_id,excel_name,
  319. // 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 `
  320. //if condition != "" {
  321. // sql += condition
  322. //}
  323. //
  324. //sql += ` ORDER BY excel_info_id DESC `
  325. //_, err = o.Raw(sql, pars).QueryRows(&items)
  326. sql := `SELECT excel_info_id,excel_classify_id,excel_name,
  327. 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 `
  328. if condition != "" {
  329. sql += condition
  330. }
  331. sql += ` ORDER BY excel_info_id DESC `
  332. err = global.DmSQL["data"].Raw(sql, pars).Find(&items).Error
  333. return
  334. }
  335. func GetExcelInfoListByCondition(condition string, pars []interface{}) (items []*ExcelInfo, err error) {
  336. //o := orm.NewOrmUsingDB("data")
  337. //sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  338. //if condition != "" {
  339. // sql += condition
  340. //}
  341. //sql += ` ORDER BY sort asc, excel_info_id asc`
  342. //_, err = o.Raw(sql, pars).QueryRows(&items)
  343. sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  344. if condition != "" {
  345. sql += condition
  346. }
  347. sql += ` ORDER BY sort asc, excel_info_id asc`
  348. err = global.DmSQL["data"].Raw(sql, pars).Find(&items).Error
  349. return
  350. }
  351. // GetNextExcelInfoByCondition 根据条件获取下一个表格
  352. func GetNextExcelInfoByCondition(condition string, pars []interface{}) (item *ExcelInfo, err error) {
  353. //o := orm.NewOrmUsingDB("data")
  354. //sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  355. //if condition != "" {
  356. // sql += condition
  357. //}
  358. //sql += " ORDER BY sort asc , create_time desc LIMIT 1 "
  359. //err = o.Raw(sql, pars).QueryRow(&item)
  360. sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  361. if condition != "" {
  362. sql += condition
  363. }
  364. sql += " ORDER BY sort asc , create_time desc LIMIT 1 "
  365. err = global.DmSQL["data"].Raw(sql, pars).First(&item).Error
  366. return
  367. }
  368. // GetNextExcelInfo 根据分类id获取下一个excel表格
  369. func GetNextExcelInfo(classifyId, classifySort, source int) (item *ExcelInfo, err error) {
  370. //o := orm.NewOrmUsingDB("data")
  371. //sql := ` SELECT b.* FROM excel_classify AS a
  372. // INNER JOIN excel_info AS b ON a.excel_classify_id=b.excel_classify_id
  373. // WHERE (a.sort>? OR (a.sort=? and a.excel_classify_id>?) ) AND a.is_delete=0 AND b.is_delete=0
  374. // AND a.source = ? AND b.source = ?
  375. // ORDER BY a.sort ASC,b.sort asc,b.create_time desc
  376. // LIMIT 1 `
  377. //err = o.Raw(sql, classifySort, classifySort, classifyId, source, source).QueryRow(&item)
  378. sql := ` SELECT b.* FROM excel_classify AS a
  379. INNER JOIN excel_info AS b ON a.excel_classify_id=b.excel_classify_id
  380. WHERE (a.sort>? OR (a.sort=? and a.excel_classify_id>?) ) AND a.is_delete=0 AND b.is_delete=0
  381. AND a.source = ? AND b.source = ?
  382. ORDER BY a.sort ASC,b.sort asc,b.create_time desc
  383. LIMIT 1 `
  384. err = global.DmSQL["data"].Raw(sql, classifySort, classifySort, classifyId, source, source).First(&item).Error
  385. return
  386. }
  387. // EditExcelInfoImage 修改excel表格的图片
  388. func EditExcelInfoImage(excelInfoId int, imageUrl string) (err error) {
  389. //o := orm.NewOrmUsingDB("data")
  390. //
  391. //sql := ` UPDATE excel_info SET excel_image=?, modify_time = NOW() WHERE excel_info_id = ? AND is_delete=0 `
  392. //_, err = o.Raw(sql, imageUrl, excelInfoId).Exec()
  393. //if err != nil {
  394. // fmt.Println("EditExcelInfoImage Err:", err.Error())
  395. // return err
  396. //}
  397. sql := ` UPDATE excel_info SET excel_image=?, modify_time = NOW() WHERE excel_info_id = ? AND is_delete=0 `
  398. err = global.DmSQL["data"].Exec(sql, imageUrl, excelInfoId).Error
  399. if err != nil {
  400. fmt.Println("EditExcelInfoImage Err:", err.Error())
  401. return err
  402. }
  403. return
  404. }
  405. // GetExcelInfoByUniqueCode 根据unique_code来获取excel表格详情
  406. func GetExcelInfoByUniqueCode(uniqueCode string) (item *ExcelInfo, err error) {
  407. //o := orm.NewOrmUsingDB("data")
  408. //sql := ` SELECT * FROM excel_info WHERE unique_code=? AND is_delete=0 `
  409. //err = o.Raw(sql, uniqueCode).QueryRow(&item)
  410. sql := ` SELECT * FROM excel_info WHERE unique_code=? AND is_delete=0 `
  411. err = global.DmSQL["data"].Raw(sql, uniqueCode).First(&item).Error
  412. return
  413. }
  414. // GetFirstExcelInfoByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
  415. func GetFirstExcelInfoByClassifyId(classifyId int) (item *ExcelInfo, err error) {
  416. //o := orm.NewOrmUsingDB("data")
  417. //sql := ` SELECT * FROM excel_info WHERE excel_classify_id=? AND is_delete=0 order by sort asc,excel_info_id desc limit 1`
  418. //err = o.Raw(sql, classifyId).QueryRow(&item)
  419. sql := ` SELECT * FROM excel_info WHERE excel_classify_id=? AND is_delete=0 order by sort asc,excel_info_id desc limit 1`
  420. err = global.DmSQL["data"].Raw(sql, classifyId).First(&item).Error
  421. return
  422. }
  423. // UpdateExcelInfoSortByClassifyId 根据表格id更新排序
  424. func UpdateExcelInfoSortByClassifyId(classifyId, nowSort, prevExcelInfoId int, updateSort string, source int) (err error) {
  425. //o := orm.NewOrmUsingDB("data")
  426. //sql := ` update excel_info set sort = ` + updateSort + ` WHERE excel_classify_id=? AND source=? AND is_delete=0 AND ( sort > ? `
  427. //// todo 前一个兄弟节点后移
  428. //if prevExcelInfoId > 0 {
  429. // sql += ` or (excel_info_id < ` + fmt.Sprint(prevExcelInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
  430. //}
  431. //sql += `)`
  432. //_, err = o.Raw(sql, classifyId, source, nowSort).Exec()
  433. sql := ` update excel_info set sort = ` + updateSort + ` WHERE excel_classify_id=? AND source=? AND is_delete=0 AND ( sort > ? `
  434. // todo 前一个兄弟节点后移
  435. if prevExcelInfoId > 0 {
  436. sql += ` or (excel_info_id < ` + fmt.Sprint(prevExcelInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
  437. }
  438. sql += `)`
  439. err = global.DmSQL["data"].Exec(sql, classifyId, source, nowSort).Error
  440. return
  441. }
  442. type ExcelInfoView struct {
  443. ExcelInfoId int `orm:"column(excel_info_id);pk"`
  444. ExcelName string `description:"来源名称"`
  445. ExcelClassifyId int `description:"表格分类id"`
  446. ExcelClassifyName string `description:"表格名称"`
  447. SysUserId int
  448. SysUserRealName string
  449. UniqueCode string `description:"表格唯一编码"`
  450. CreateTime time.Time
  451. ModifyTime time.Time
  452. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"`
  453. StartDate string `description:"自定义开始日期"`
  454. EndDate string `description:"自定义结束日期"`
  455. IsSetName int `description:"设置名称"`
  456. EdbInfoIds string `description:"指标id"`
  457. ExcelType int `description:"生成样式:1:曲线图,2:季节性图"`
  458. Calendar string `description:"公历/农历"`
  459. SeasonStartDate string `description:"季节性图开始日期"`
  460. SeasonEndDate string `description:"季节性图开始日期"`
  461. ExcelImage string `description:"表格图片"`
  462. Sort int `description:"排序字段,数字越小越排前面"`
  463. IsAdd bool `description:"true:已加入我的图库,false:未加入我的图库"`
  464. MyExcelId int
  465. MyExcelClassifyId string `description:"我的表格分类,多个用逗号隔开"`
  466. ExcelClassify []*ExcelClassifyView
  467. EdbEndDate string `description:"指标最新更新日期"`
  468. LeftMin string `description:"表格左侧最小值"`
  469. LeftMax string `description:"表格左侧最大值"`
  470. RightMin string `description:"表格右侧最小值"`
  471. RightMax string `description:"表格右侧最大值"`
  472. }
  473. // GetExcelInfoByClassifyIdAndName 根据分类id和表格名获取表格信息
  474. func GetExcelInfoByClassifyIdAndName(classifyId int, excelName string) (item *ExcelInfo, err error) {
  475. //o := orm.NewOrmUsingDB("data")
  476. //sql := ` SELECT * FROM excel_info WHERE excel_classify_id = ? and excel_name=? AND is_delete=0 `
  477. //err = o.Raw(sql, classifyId, excelName).QueryRow(&item)
  478. sql := ` SELECT * FROM excel_info WHERE excel_classify_id = ? and excel_name=? AND is_delete=0 `
  479. err = global.DmSQL["data"].Raw(sql, classifyId, excelName).First(&item).Error
  480. return
  481. }
  482. // GetNoContentExcelListByCondition 获取没有content的excel表格列表数据
  483. func GetNoContentExcelListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*MyExcelInfoList, err error) {
  484. // o := orm.NewOrmUsingDB("data")
  485. // 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
  486. //FROM excel_info WHERE 1=1 AND is_delete=0 `
  487. // if condition != "" {
  488. // sql += condition
  489. // }
  490. // //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  491. // sql += " ORDER BY create_time DESC LIMIT ?,? "
  492. // _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&item)
  493. 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
  494. FROM excel_info WHERE 1=1 AND is_delete=0 `
  495. if condition != "" {
  496. sql += condition
  497. }
  498. //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  499. sql += " ORDER BY create_time DESC LIMIT ?,? "
  500. err = global.DmSQL["data"].Raw(sql, pars, startSize, pageSize).Find(&item).Error
  501. return
  502. }
  503. // GetNoContentExcelListByConditionNoPage 获取没有content的excel表格列表数据
  504. func GetNoContentExcelListByConditionNoPage(condition string, pars []interface{}) (item []*MyExcelInfoList, err error) {
  505. // o := orm.NewOrmUsingDB("data")
  506. // 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
  507. //FROM excel_info WHERE 1=1 AND is_delete=0 `
  508. // if condition != "" {
  509. // sql += condition
  510. // }
  511. // //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  512. // sql += " ORDER BY create_time DESC"
  513. // _, err = o.Raw(sql, pars).QueryRows(&item)
  514. 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
  515. FROM excel_info WHERE 1=1 AND is_delete=0 `
  516. if condition != "" {
  517. sql += condition
  518. }
  519. //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  520. sql += " ORDER BY create_time DESC"
  521. err = global.DmSQL["data"].Raw(sql, pars).Find(&item).Error
  522. return
  523. }
  524. func GetExcelListCountByCondition(condition string, pars []interface{}) (count int, err error) {
  525. //o := orm.NewOrmUsingDB("data")
  526. //sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
  527. //if condition != "" {
  528. // sql += condition
  529. //}
  530. //err = o.Raw(sql, pars).QueryRow(&count)
  531. sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
  532. if condition != "" {
  533. sql += condition
  534. }
  535. err = global.DmSQL["data"].Raw(sql, pars).Scan(&count).Error
  536. return
  537. }
  538. // GetExcelViewInfoByExcelInfoId 根据excelInfoId 获取ETA表格详情
  539. func GetExcelViewInfoByExcelInfoId(excelInfoId int) (item *MyExcelInfoList, err error) {
  540. //o := orm.NewOrmUsingDB("data")
  541. //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 `
  542. //err = o.Raw(sql, excelInfoId).QueryRow(&item)
  543. 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 `
  544. err = global.DmSQL["data"].Raw(sql, excelInfoId).First(&item).Error
  545. return
  546. }
  547. // GetExcelInfoCountByClassifyId 根据分类id获取名下表格数量
  548. func GetExcelInfoCountByClassifyId(classifyId int) (total int64, err error) {
  549. //o := orm.NewOrmUsingDB("data")
  550. //sql := ` SELECT count(1) total FROM excel_info WHERE excel_classify_id = ? AND is_delete=0 `
  551. //err = o.Raw(sql, classifyId).QueryRow(&total)
  552. sql := ` SELECT count(1) total FROM excel_info WHERE excel_classify_id = ? AND is_delete=0 `
  553. err = global.DmSQL["data"].Raw(sql, classifyId).First(&total).Error
  554. return
  555. }
  556. // UpdateExcelInfoClassifyId 更改表格分类
  557. func UpdateExcelInfoClassifyId(classifyId, excelInfoId int) (err error) {
  558. //o := orm.NewOrmUsingDB("data")
  559. //sql := ` update excel_info set excel_classify_id = ? WHERE excel_info_id=? `
  560. //_, err = o.Raw(sql, classifyId, excelInfoId).Exec()
  561. sql := ` update excel_info set excel_classify_id = ? WHERE excel_info_id=? `
  562. err = global.DmSQL["data"].Exec(sql, classifyId, excelInfoId).Error
  563. return
  564. }
  565. // GetNoContentExcelInfoByName 根据名称 获取eta表格详情
  566. func GetNoContentExcelInfoByName(excelName string, source, adminId int) (item *MyExcelInfoList, err error) {
  567. //o := orm.NewOrmUsingDB("data")
  568. //sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name
  569. //FROM excel_info WHERE excel_name = ? AND source = ? AND is_delete=0 AND sys_user_id = ? `
  570. //err = o.Raw(sql, excelName, source, adminId).QueryRow(&item)
  571. 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
  572. FROM excel_info WHERE excel_name = ? AND source = ? AND is_delete=0 AND sys_user_id = ? `
  573. err = global.DmSQL["data"].Raw(sql, excelName, source, adminId).First(&item).Error
  574. return
  575. }
  576. // GetNoContentExcelInfoByUniqueCode 根据unique_code来获取excel表格详情
  577. func GetNoContentExcelInfoByUniqueCode(uniqueCode string) (item *MyExcelInfoList, err error) {
  578. //o := orm.NewOrmUsingDB("data")
  579. //sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name
  580. //FROM excel_info WHERE unique_code=? AND is_delete=0 `
  581. //err = o.Raw(sql, uniqueCode).QueryRow(&item)
  582. 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
  583. FROM excel_info WHERE unique_code=? AND is_delete=0 `
  584. err = global.DmSQL["data"].Raw(sql, uniqueCode).First(&item).Error
  585. return
  586. }
  587. // GetNoContentExcelInfoByExcelId 根据表格id来获取excel表格详情
  588. func GetNoContentExcelInfoByExcelId(excelInfoId int) (item *MyExcelInfoList, err error) {
  589. //o := orm.NewOrmUsingDB("data")
  590. //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
  591. //FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  592. //err = o.Raw(sql, excelInfoId).QueryRow(&item)
  593. 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
  594. FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  595. err = global.DmSQL["data"].Raw(sql, excelInfoId).First(&item).Error
  596. return
  597. }
  598. // AddExcelInfoAndSheet 新增excel
  599. func AddExcelInfoAndSheet(excelInfo *ExcelInfo, sheetParamsList []AddExcelSheetParams) (err error) {
  600. //o, err := orm.NewOrmUsingDB("data").Begin()
  601. //if err != nil {
  602. // return
  603. //}
  604. //defer func() {
  605. // if err != nil {
  606. // _ = o.Rollback()
  607. // } else {
  608. // _ = o.Commit()
  609. // }
  610. //}()
  611. to := global.DmSQL["data"].Begin()
  612. defer func() {
  613. if err != nil {
  614. _ = to.Rollback()
  615. } else {
  616. _ = to.Commit()
  617. }
  618. }()
  619. // 表格信息入库
  620. err = to.Create(excelInfo).Error
  621. if err != nil {
  622. return
  623. }
  624. //excelInfo.ExcelInfoId = int(lastId)
  625. // sheet信息入库
  626. for _, sheetInfo := range sheetParamsList {
  627. dataNum := len(sheetInfo.DataList)
  628. //sheet信息入库
  629. excelSheetInfo := &ExcelSheet{
  630. ExcelSheetId: 0,
  631. ExcelInfoId: excelInfo.ExcelInfoId,
  632. SheetName: sheetInfo.SheetName,
  633. PageNum: dataNum,
  634. Index: sheetInfo.Index,
  635. Sort: sheetInfo.Sort,
  636. Config: sheetInfo.Config,
  637. CalcChain: sheetInfo.CalcChain,
  638. ModifyTime: time.Now(),
  639. CreateTime: time.Now(),
  640. }
  641. //sheetId, tmpErr := o.Insert(excelSheetInfo)
  642. //if tmpErr != nil {
  643. // err = tmpErr
  644. // return
  645. //}
  646. tmpErr := to.Create(excelSheetInfo).Error
  647. if tmpErr != nil {
  648. err = tmpErr
  649. return
  650. }
  651. //excelSheetInfo.ExcelSheetId = int(sheetId)
  652. // data信息入库
  653. if dataNum > 0 {
  654. for k, _ := range sheetInfo.DataList {
  655. sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
  656. sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
  657. }
  658. //_, tmpErr = o.InsertMulti(dataNum, sheetInfo.DataList)
  659. //if tmpErr != nil {
  660. // err = tmpErr
  661. // return
  662. //}
  663. tmpErr = to.CreateInBatches(sheetInfo.DataList, utils.MultiAddNum).Error
  664. if tmpErr != nil {
  665. err = tmpErr
  666. return
  667. }
  668. }
  669. }
  670. return
  671. }
  672. // SaveExcelInfoAndSheet 编辑保存
  673. func SaveExcelInfoAndSheet(excelInfo *ExcelInfo, updateExcelInfoParam []string, sheetParamsList []AddExcelSheetParams) (err error) {
  674. //o, err := orm.NewOrmUsingDB("data").Begin()
  675. //if err != nil {
  676. // return
  677. //}
  678. //defer func() {
  679. // if err != nil {
  680. // _ = o.Rollback()
  681. // } else {
  682. // _ = o.Commit()
  683. // }
  684. //}()
  685. to := global.DmSQL["data"].Begin()
  686. defer func() {
  687. if err != nil {
  688. _ = to.Rollback()
  689. } else {
  690. _ = to.Commit()
  691. }
  692. }()
  693. // 表格信息入库
  694. err = to.Select(updateExcelInfoParam).Updates(excelInfo).Error
  695. if err != nil {
  696. return
  697. }
  698. // 先删除历史的sheet信息
  699. sql := `DELETE FROM excel_sheet WHERE excel_info_id = ?`
  700. err = to.Exec(sql, excelInfo.ExcelInfoId).Error
  701. if err != nil {
  702. return
  703. }
  704. // 再删除历史sheet中的cell data信息
  705. //sql = `DELETE FROM excel_sheet_data WHERE excel_info_id = ?`
  706. //_, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
  707. //if err != nil {
  708. // return
  709. //}
  710. sql = `DELETE FROM excel_sheet_data WHERE excel_info_id = ?`
  711. err = to.Exec(sql, excelInfo.ExcelInfoId).Error
  712. if err != nil {
  713. return
  714. }
  715. // sheet信息入库
  716. for _, sheetInfo := range sheetParamsList {
  717. dataNum := len(sheetInfo.DataList)
  718. //sheet信息入库
  719. excelSheetInfo := &ExcelSheet{
  720. ExcelSheetId: 0,
  721. ExcelInfoId: excelInfo.ExcelInfoId,
  722. SheetName: sheetInfo.SheetName,
  723. PageNum: dataNum,
  724. Index: sheetInfo.Index,
  725. Sort: sheetInfo.Sort,
  726. Config: sheetInfo.Config,
  727. CalcChain: sheetInfo.CalcChain,
  728. ModifyTime: time.Now(),
  729. CreateTime: time.Now(),
  730. }
  731. //sheetId, tmpErr := o.Insert(excelSheetInfo)
  732. //if tmpErr != nil {
  733. // err = tmpErr
  734. // return
  735. //}
  736. //excelSheetInfo.ExcelSheetId = int(sheetId)
  737. tmpErr := to.Create(excelSheetInfo).Error
  738. if tmpErr != nil {
  739. err = tmpErr
  740. return
  741. }
  742. // data信息入库
  743. if dataNum > 0 {
  744. for k, _ := range sheetInfo.DataList {
  745. sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
  746. sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
  747. }
  748. //_, tmpErr = o.InsertMulti(dataNum, sheetInfo.DataList)
  749. //if tmpErr != nil {
  750. // err = tmpErr
  751. // return
  752. //}
  753. tmpErr = to.CreateInBatches(sheetInfo.DataList, utils.MultiAddNum).Error
  754. }
  755. }
  756. return
  757. }
  758. // BatchRefreshExcelReq 批量刷新表格请求
  759. type BatchRefreshExcelReq struct {
  760. ExcelCodes []string `description:"表格编码"`
  761. PrimaryId int `description:"研报/智能研报/PPT主键"`
  762. SubId int `description:"报告章节ID"`
  763. Source string `description:"来源,枚举值:report、english_report、smart_report"`
  764. }
  765. // GetExcelMaxSortByClassifyId 获取当前分类下,且排序数最大的excel
  766. func GetExcelMaxSortByClassifyId(classifyId int, source int) (sort int, err error) {
  767. //o := orm.NewOrmUsingDB("data")
  768. //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`
  769. //err = o.Raw(sql, classifyId, source).QueryRow(&sort)
  770. 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`
  771. err = global.DmSQL["data"].Raw(sql, classifyId, source).Scan(&sort).Error
  772. return
  773. }
  774. // GetNoContentExcelListByExcelInfoIdList
  775. // @Description: 根据ETA表格ID列表获取列表信息
  776. // @param excelInfoIdList []string
  777. // @return items
  778. // @return err
  779. func GetNoContentExcelListByExcelInfoIdList(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
  780. num := len(excelInfoIdList)
  781. if num <= 0 {
  782. return
  783. }
  784. //o := orm.NewOrmUsingDB("data")
  785. //sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  786. //_, err = o.Raw(sql, excelInfoIdList).QueryRows(&items)
  787. sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  788. err = global.DmSQL["data"].Raw(sql, excelInfoIdList).Find(&items).Error
  789. return
  790. }
  791. func GetNoContentExcelListByExcelInfoIdAndParentId(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
  792. num := len(excelInfoIdList)
  793. if num <= 0 {
  794. return
  795. }
  796. //o := orm.NewOrmUsingDB("data")
  797. //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 `
  798. //_, err = o.Raw(sql, excelInfoIdList, excelInfoIdList).QueryRows(&items)
  799. 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 `
  800. err = global.DmSQL["data"].Raw(sql, excelInfoIdList, excelInfoIdList).Find(&items).Error
  801. return
  802. }
  803. // GetNoContentExcelListByUserId
  804. // @Description: 根据ETA表格ID列表获取列表信息
  805. // @param userIdList []int
  806. // @return items
  807. // @return err
  808. func GetNoContentExcelListByUserId(userIdList []int) (items []*MyExcelInfoList, err error) {
  809. num := len(userIdList)
  810. if num <= 0 {
  811. return
  812. }
  813. //o := orm.NewOrmUsingDB("data")
  814. //sql := ` SELECT * FROM excel_info WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  815. //_, err = o.Raw(sql, userIdList).QueryRows(&items)
  816. sql := ` SELECT * FROM excel_info WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  817. err = global.DmSQL["data"].Raw(sql, userIdList).Find(&items).Error
  818. return
  819. }
  820. // ModifyExcelInfoUserIdByCodeList
  821. // @Description: 根据编码列表修改表格信息
  822. // @author: Roc
  823. // @datetime 2024-03-26 14:16:30
  824. // @param excelIdList []string
  825. // @param userId int
  826. // @param userName string
  827. // @return err error
  828. func ModifyExcelInfoUserIdByCodeList(excelIdList []string, userId int, userName string) (err error) {
  829. num := len(excelIdList)
  830. if num <= 0 {
  831. return
  832. }
  833. //o := orm.NewOrmUsingDB("data")
  834. //sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) `
  835. //_, err = o.Raw(sql, userId, userName, excelIdList).Exec()
  836. sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) `
  837. err = global.DmSQL["data"].Exec(sql, userId, userName, excelIdList).Error
  838. return
  839. }
  840. // ModifyExcelInfoUserIdByOldUserId
  841. // @Description: 根据旧的用户id修改创建人
  842. // @author: Roc
  843. // @datetime 2024-03-25 19:14:59
  844. // @param oldUserId int
  845. // @param userId int
  846. // @param userName string
  847. // @return err error
  848. func ModifyExcelInfoUserIdByOldUserId(oldUserIdList []int, userId int, userName string) (err error) {
  849. num := len(oldUserIdList)
  850. if num <= 0 {
  851. return
  852. }
  853. //o := orm.NewOrmUsingDB("data")
  854. //sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE is_delete=0 AND sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
  855. //_, err = o.Raw(sql, userId, userName, oldUserIdList).Exec()
  856. sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE is_delete=0 AND sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
  857. err = global.DmSQL["data"].Exec(sql, userId, userName, oldUserIdList).Error
  858. return
  859. }
  860. func GetExcelBaseInfoByExcelInfoIdList(excelInfoIdList []int) (items []*data_manage.ExcelBaseInfo, err error) {
  861. num := len(excelInfoIdList)
  862. if num <= 0 {
  863. return
  864. }
  865. //o := orm.NewOrmUsingDB("data")
  866. //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 `
  867. //_, err = o.Raw(sql, excelInfoIdList).QueryRows(&items)
  868. 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 `
  869. err = global.DmSQL["data"].Raw(sql, excelInfoIdList).Find(&items).Error
  870. return
  871. }
  872. // ReplaceEdbInExcel 替换表格中的指标
  873. func ReplaceEdbInExcel(oldEdbInfoId, newEdbInfoId int, updateExcelList []*ExcelInfo) (err error) {
  874. var errmsg string
  875. logMsg := `` // 记录替换的日志
  876. replaceTotal := 0
  877. //o := orm.NewOrmUsingDB("data")
  878. //to, err := o.Begin()
  879. //if err != nil {
  880. // return
  881. //}
  882. //defer func() {
  883. // if err != nil {
  884. // _ = to.Rollback()
  885. // } else {
  886. // _ = to.Commit()
  887. // if logMsg != `` {
  888. // utils.FileLog.Info(fmt.Sprintf("替换表格中的指标记录,替换总表格数:%d,旧的指标id:%d,新的指标id:%d;%s", replaceTotal, oldEdbInfoId, newEdbInfoId, logMsg))
  889. // }
  890. // }
  891. // if errmsg != "" {
  892. // fmt.Println("errmsg:" + errmsg)
  893. // }
  894. // if err != nil && errmsg != "" {
  895. // //go alarm_msg.SendAlarmMsg("替换替换配置中的指标记录失败提醒,errmsg:"+errmsg, 3)
  896. // }
  897. //}()
  898. to := global.DmSQL["data"].Begin()
  899. defer func() {
  900. if err != nil {
  901. _ = to.Rollback()
  902. } else {
  903. _ = to.Commit()
  904. if logMsg != `` {
  905. utils.FileLog.Info(fmt.Sprintf("替换表格中的指标记录,替换总表格数:%d,旧的指标id:%d,新的指标id:%d;%s", replaceTotal, oldEdbInfoId, newEdbInfoId, logMsg))
  906. }
  907. }
  908. if errmsg != "" {
  909. fmt.Println("errmsg:" + errmsg)
  910. }
  911. if err != nil && errmsg != "" {
  912. //go alarm_msg.SendAlarmMsg("替换替换配置中的指标记录失败提醒,errmsg:"+errmsg, 3)
  913. }
  914. }()
  915. // 替换表格中的内容
  916. for _, excelInfo := range updateExcelList {
  917. //更新配置中的指标A
  918. //sql := `UPDATE excel_info SET content=?, modify_time=? WHERE excel_info_id=?`
  919. //_, err = to.Raw(sql, excelInfo.Content, time.Now(), excelInfo.ExcelInfoId).Exec()
  920. //if err != nil {
  921. // errmsg = "更新表格内容失败:Err:" + err.Error()
  922. // return
  923. //}
  924. sql := `UPDATE excel_info SET content=?, modify_time=? WHERE excel_info_id=?`
  925. err = to.Exec(sql, excelInfo.Content, time.Now(), excelInfo.ExcelInfoId).Error
  926. if err != nil {
  927. errmsg = "更新表格内容失败:Err:" + err.Error()
  928. return
  929. }
  930. //更新配置中的指标B
  931. // 判断是否已存在绑定,如果存在则删除
  932. sql = `DELETE FROM excel_edb_mapping WHERE excel_info_id=? and edb_info_id=?`
  933. err = to.Exec(sql, excelInfo.ExcelInfoId, newEdbInfoId).Error
  934. if err != nil {
  935. errmsg = "删除指标B关联图表配置信息失败:Err:" + err.Error()
  936. return
  937. }
  938. // 插入新的绑定
  939. //sql = `UPDATE excel_edb_mapping SET edb_info_id=?, modify_time=? WHERE excel_info_id=? and edb_info_id=?`
  940. //_, err = to.Raw(sql, newEdbInfoId, time.Now(), excelInfo.ExcelInfoId, oldEdbInfoId).Exec()
  941. //if err != nil {
  942. // errmsg = "更新指标B关联图表配置信息失败:Err:" + err.Error()
  943. // return
  944. //}
  945. sql = `UPDATE excel_edb_mapping SET edb_info_id=?, modify_time=? WHERE excel_info_id=? and edb_info_id=?`
  946. err = to.Exec(sql, newEdbInfoId, time.Now(), excelInfo.ExcelInfoId, oldEdbInfoId).Error
  947. if err != nil {
  948. errmsg = "更新指标B关联图表配置信息失败:Err:" + err.Error()
  949. return
  950. }
  951. logMsg += `涉及到的表格id:` + strconv.Itoa(excelInfo.ExcelInfoId) + ";"
  952. replaceTotal += 1
  953. }
  954. return
  955. }
  956. // GetChildExcelInfoByParentId 根据id 获取eta表格详情
  957. func GetChildExcelInfoByParentId(parentId int) (items []*ExcelInfo, err error) {
  958. //o := orm.NewOrmUsingDB("data")
  959. //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`
  960. //_, err = o.Raw(sql, parentId).QueryRows(&items)
  961. 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`
  962. err = global.DmSQL["data"].Raw(sql, parentId).Find(&items).Error
  963. return
  964. }
  965. // ExcelInfoDetailButton 操作按钮
  966. type ExcelInfoDetailButton struct {
  967. RefreshButton bool `description:"是否可刷新"`
  968. CopyButton bool `description:"是否可另存为"`
  969. DownloadButton bool `description:"是否可下载"`
  970. OpButton bool `description:"是否可编辑"`
  971. DeleteButton bool `description:"是否可删除"`
  972. OpEdbButton bool `description:"是否可生成指标"`
  973. RefreshEdbButton bool `description:"是否可刷新指标"`
  974. OpWorkerButton bool `description:"是否修改协作人"`
  975. }
  976. func UpdateExcelInfoClassifyIdByIds(classifyId int, excelIds []int) (err error) {
  977. if len(excelIds) == 0 {
  978. return
  979. }
  980. //o := orm.NewOrmUsingDB("data")
  981. //sql := fmt.Sprintf(`UPDATE excel_info SET excel_classify_id = ? WHERE excel_info_id IN (%s)`, utils.GetOrmInReplace(len(excelIds)))
  982. //_, err = o.Raw(sql, classifyId, excelIds).Exec()
  983. sql := fmt.Sprintf(`UPDATE excel_info SET excel_classify_id = ? WHERE excel_info_id IN (%s)`, utils.GetOrmInReplace(len(excelIds)))
  984. err = global.DmSQL["data"].Exec(sql, classifyId, excelIds).Error
  985. return
  986. }