excel_info.go 44 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125
  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" gorm:"primaryKey" `
  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" gorm:"primaryKey" `
  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...).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. pars = append(pars, startSize)
  314. pars = append(pars, pageSize)
  315. err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
  316. return
  317. }
  318. func GetNoContentExcelInfoListByConditionNoPage(condition string, pars []interface{}) (items []*ExcelInfo, err error) {
  319. //o := orm.NewOrmUsingDB("data")
  320. //sql := `SELECT excel_info_id,excel_classify_id,excel_name,
  321. // 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 `
  322. //if condition != "" {
  323. // sql += condition
  324. //}
  325. //
  326. //sql += ` ORDER BY excel_info_id DESC `
  327. //_, err = o.Raw(sql, pars).QueryRows(&items)
  328. sql := `SELECT excel_info_id,excel_classify_id,excel_name,
  329. 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 `
  330. if condition != "" {
  331. sql += condition
  332. }
  333. sql += ` ORDER BY excel_info_id DESC `
  334. err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
  335. return
  336. }
  337. func GetExcelInfoListByCondition(condition string, pars []interface{}) (items []*ExcelInfo, err error) {
  338. //o := orm.NewOrmUsingDB("data")
  339. //sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  340. //if condition != "" {
  341. // sql += condition
  342. //}
  343. //sql += ` ORDER BY sort asc, excel_info_id asc`
  344. //_, err = o.Raw(sql, pars).QueryRows(&items)
  345. sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  346. if condition != "" {
  347. sql += condition
  348. }
  349. sql += ` ORDER BY sort asc, excel_info_id asc`
  350. err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
  351. return
  352. }
  353. // GetNextExcelInfoByCondition 根据条件获取下一个表格
  354. func GetNextExcelInfoByCondition(condition string, pars []interface{}) (item *ExcelInfo, err error) {
  355. //o := orm.NewOrmUsingDB("data")
  356. //sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  357. //if condition != "" {
  358. // sql += condition
  359. //}
  360. //sql += " ORDER BY sort asc , create_time desc LIMIT 1 "
  361. //err = o.Raw(sql, pars).QueryRow(&item)
  362. sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
  363. if condition != "" {
  364. sql += condition
  365. }
  366. sql += " ORDER BY sort asc , create_time desc LIMIT 1 "
  367. err = global.DmSQL["data"].Raw(sql, pars...).First(&item).Error
  368. return
  369. }
  370. // GetNextExcelInfo 根据分类id获取下一个excel表格
  371. func GetNextExcelInfo(classifyId, classifySort, source int) (item *ExcelInfo, err error) {
  372. //o := orm.NewOrmUsingDB("data")
  373. //sql := ` SELECT b.* FROM excel_classify AS a
  374. // INNER JOIN excel_info AS b ON a.excel_classify_id=b.excel_classify_id
  375. // WHERE (a.sort>? OR (a.sort=? and a.excel_classify_id>?) ) AND a.is_delete=0 AND b.is_delete=0
  376. // AND a.source = ? AND b.source = ?
  377. // ORDER BY a.sort ASC,b.sort asc,b.create_time desc
  378. // LIMIT 1 `
  379. //err = o.Raw(sql, classifySort, classifySort, classifyId, source, source).QueryRow(&item)
  380. sql := ` SELECT b.* FROM excel_classify AS a
  381. INNER JOIN excel_info AS b ON a.excel_classify_id=b.excel_classify_id
  382. WHERE (a.sort>? OR (a.sort=? and a.excel_classify_id>?) ) AND a.is_delete=0 AND b.is_delete=0
  383. AND a.source = ? AND b.source = ?
  384. ORDER BY a.sort ASC,b.sort asc,b.create_time desc
  385. LIMIT 1 `
  386. err = global.DmSQL["data"].Raw(sql, classifySort, classifySort, classifyId, source, source).First(&item).Error
  387. return
  388. }
  389. // EditExcelInfoImage 修改excel表格的图片
  390. func EditExcelInfoImage(excelInfoId int, imageUrl string) (err error) {
  391. //o := orm.NewOrmUsingDB("data")
  392. //
  393. //sql := ` UPDATE excel_info SET excel_image=?, modify_time = NOW() WHERE excel_info_id = ? AND is_delete=0 `
  394. //_, err = o.Raw(sql, imageUrl, excelInfoId).Exec()
  395. //if err != nil {
  396. // fmt.Println("EditExcelInfoImage Err:", err.Error())
  397. // return err
  398. //}
  399. sql := ` UPDATE excel_info SET excel_image=?, modify_time = NOW() WHERE excel_info_id = ? AND is_delete=0 `
  400. err = global.DmSQL["data"].Exec(sql, imageUrl, excelInfoId).Error
  401. if err != nil {
  402. fmt.Println("EditExcelInfoImage Err:", err.Error())
  403. return err
  404. }
  405. return
  406. }
  407. // GetExcelInfoByUniqueCode 根据unique_code来获取excel表格详情
  408. func GetExcelInfoByUniqueCode(uniqueCode string) (item *ExcelInfo, err error) {
  409. //o := orm.NewOrmUsingDB("data")
  410. //sql := ` SELECT * FROM excel_info WHERE unique_code=? AND is_delete=0 `
  411. //err = o.Raw(sql, uniqueCode).QueryRow(&item)
  412. sql := ` SELECT * FROM excel_info WHERE unique_code=? AND is_delete=0 `
  413. err = global.DmSQL["data"].Raw(sql, uniqueCode).First(&item).Error
  414. return
  415. }
  416. // GetFirstExcelInfoByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
  417. func GetFirstExcelInfoByClassifyId(classifyId int) (item *ExcelInfo, err error) {
  418. //o := orm.NewOrmUsingDB("data")
  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 = o.Raw(sql, classifyId).QueryRow(&item)
  421. sql := ` SELECT * FROM excel_info WHERE excel_classify_id=? AND is_delete=0 order by sort asc,excel_info_id desc limit 1`
  422. err = global.DmSQL["data"].Raw(sql, classifyId).First(&item).Error
  423. return
  424. }
  425. // UpdateExcelInfoSortByClassifyId 根据表格id更新排序
  426. func UpdateExcelInfoSortByClassifyId(classifyId, nowSort, prevExcelInfoId int, updateSort string, source int) (err error) {
  427. //o := orm.NewOrmUsingDB("data")
  428. //sql := ` update excel_info set sort = ` + updateSort + ` WHERE excel_classify_id=? AND source=? AND is_delete=0 AND ( sort > ? `
  429. //// todo 前一个兄弟节点后移
  430. //if prevExcelInfoId > 0 {
  431. // sql += ` or (excel_info_id < ` + fmt.Sprint(prevExcelInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
  432. //}
  433. //sql += `)`
  434. //_, err = o.Raw(sql, classifyId, source, nowSort).Exec()
  435. sql := ` update excel_info set sort = ` + updateSort + ` WHERE excel_classify_id=? AND source=? AND is_delete=0 AND ( sort > ? `
  436. // todo 前一个兄弟节点后移
  437. if prevExcelInfoId > 0 {
  438. sql += ` or (excel_info_id < ` + fmt.Sprint(prevExcelInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
  439. }
  440. sql += `)`
  441. err = global.DmSQL["data"].Exec(sql, classifyId, source, nowSort).Error
  442. return
  443. }
  444. type ExcelInfoView struct {
  445. ExcelInfoId int `orm:"column(excel_info_id);pk" gorm:"primaryKey" `
  446. ExcelName string `description:"来源名称"`
  447. ExcelClassifyId int `description:"表格分类id"`
  448. ExcelClassifyName string `description:"表格名称"`
  449. SysUserId int
  450. SysUserRealName string
  451. UniqueCode string `description:"表格唯一编码"`
  452. CreateTime time.Time
  453. ModifyTime time.Time
  454. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"`
  455. StartDate string `description:"自定义开始日期"`
  456. EndDate string `description:"自定义结束日期"`
  457. IsSetName int `description:"设置名称"`
  458. EdbInfoIds string `description:"指标id"`
  459. ExcelType int `description:"生成样式:1:曲线图,2:季节性图"`
  460. Calendar string `description:"公历/农历"`
  461. SeasonStartDate string `description:"季节性图开始日期"`
  462. SeasonEndDate string `description:"季节性图开始日期"`
  463. ExcelImage string `description:"表格图片"`
  464. Sort int `description:"排序字段,数字越小越排前面"`
  465. IsAdd bool `description:"true:已加入我的图库,false:未加入我的图库"`
  466. MyExcelId int
  467. MyExcelClassifyId string `description:"我的表格分类,多个用逗号隔开"`
  468. ExcelClassify []*ExcelClassifyView
  469. EdbEndDate string `description:"指标最新更新日期"`
  470. LeftMin string `description:"表格左侧最小值"`
  471. LeftMax string `description:"表格左侧最大值"`
  472. RightMin string `description:"表格右侧最小值"`
  473. RightMax string `description:"表格右侧最大值"`
  474. }
  475. // GetExcelInfoByClassifyIdAndName 根据分类id和表格名获取表格信息
  476. func GetExcelInfoByClassifyIdAndName(classifyId int, excelName string) (item *ExcelInfo, err error) {
  477. //o := orm.NewOrmUsingDB("data")
  478. //sql := ` SELECT * FROM excel_info WHERE excel_classify_id = ? and excel_name=? AND is_delete=0 `
  479. //err = o.Raw(sql, classifyId, excelName).QueryRow(&item)
  480. sql := ` SELECT * FROM excel_info WHERE excel_classify_id = ? and excel_name=? AND is_delete=0 `
  481. err = global.DmSQL["data"].Raw(sql, classifyId, excelName).First(&item).Error
  482. return
  483. }
  484. // GetNoContentExcelListByCondition 获取没有content的excel表格列表数据
  485. func GetNoContentExcelListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*MyExcelInfoList, err error) {
  486. // o := orm.NewOrmUsingDB("data")
  487. // 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
  488. //FROM excel_info WHERE 1=1 AND is_delete=0 `
  489. // if condition != "" {
  490. // sql += condition
  491. // }
  492. // //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  493. // sql += " ORDER BY create_time DESC LIMIT ?,? "
  494. // _, err = o.Raw(sql, pars...).QueryRows(&item)
  495. 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
  496. FROM excel_info WHERE 1=1 AND is_delete=0 `
  497. if condition != "" {
  498. sql += condition
  499. }
  500. //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  501. sql += " ORDER BY create_time DESC LIMIT ?,? "
  502. pars = append(pars, startSize)
  503. pars = append(pars, pageSize)
  504. err = global.DmSQL["data"].Raw(sql, pars...).Find(&item).Error
  505. return
  506. }
  507. // GetNoContentExcelListByConditionNoPage 获取没有content的excel表格列表数据
  508. func GetNoContentExcelListByConditionNoPage(condition string, pars []interface{}) (item []*MyExcelInfoList, err error) {
  509. // o := orm.NewOrmUsingDB("data")
  510. // 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
  511. //FROM excel_info WHERE 1=1 AND is_delete=0 `
  512. // if condition != "" {
  513. // sql += condition
  514. // }
  515. // //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  516. // sql += " ORDER BY create_time DESC"
  517. // _, err = o.Raw(sql, pars).QueryRows(&item)
  518. 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
  519. FROM excel_info WHERE 1=1 AND is_delete=0 `
  520. if condition != "" {
  521. sql += condition
  522. }
  523. //sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
  524. sql += " ORDER BY create_time DESC"
  525. err = global.DmSQL["data"].Raw(sql, pars...).Find(&item).Error
  526. return
  527. }
  528. func GetExcelListCountByCondition(condition string, pars []interface{}) (count int, err error) {
  529. //o := orm.NewOrmUsingDB("data")
  530. //sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
  531. //if condition != "" {
  532. // sql += condition
  533. //}
  534. //err = o.Raw(sql, pars).QueryRow(&count)
  535. sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
  536. if condition != "" {
  537. sql += condition
  538. }
  539. err = global.DmSQL["data"].Raw(sql, pars...).Scan(&count).Error
  540. return
  541. }
  542. // GetExcelViewInfoByExcelInfoId 根据excelInfoId 获取ETA表格详情
  543. func GetExcelViewInfoByExcelInfoId(excelInfoId int) (item *MyExcelInfoList, err error) {
  544. //o := orm.NewOrmUsingDB("data")
  545. //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 `
  546. //err = o.Raw(sql, excelInfoId).QueryRow(&item)
  547. 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 `
  548. err = global.DmSQL["data"].Raw(sql, excelInfoId).First(&item).Error
  549. return
  550. }
  551. // GetExcelInfoCountByClassifyId 根据分类id获取名下表格数量
  552. func GetExcelInfoCountByClassifyId(classifyId int) (total int64, err error) {
  553. //o := orm.NewOrmUsingDB("data")
  554. //sql := ` SELECT count(1) total FROM excel_info WHERE excel_classify_id = ? AND is_delete=0 `
  555. //err = o.Raw(sql, classifyId).QueryRow(&total)
  556. sql := ` SELECT count(1) total FROM excel_info WHERE excel_classify_id = ? AND is_delete=0 `
  557. err = global.DmSQL["data"].Raw(sql, classifyId).First(&total).Error
  558. return
  559. }
  560. // UpdateExcelInfoClassifyId 更改表格分类
  561. func UpdateExcelInfoClassifyId(classifyId, excelInfoId int) (err error) {
  562. //o := orm.NewOrmUsingDB("data")
  563. //sql := ` update excel_info set excel_classify_id = ? WHERE excel_info_id=? `
  564. //_, err = o.Raw(sql, classifyId, excelInfoId).Exec()
  565. sql := ` update excel_info set excel_classify_id = ? WHERE excel_info_id=? `
  566. err = global.DmSQL["data"].Exec(sql, classifyId, excelInfoId).Error
  567. return
  568. }
  569. // GetNoContentExcelInfoByName 根据名称 获取eta表格详情
  570. func GetNoContentExcelInfoByName(excelName string, source, adminId int) (item *MyExcelInfoList, err error) {
  571. //o := orm.NewOrmUsingDB("data")
  572. //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
  573. //FROM excel_info WHERE excel_name = ? AND source = ? AND is_delete=0 AND sys_user_id = ? `
  574. //err = o.Raw(sql, excelName, source, adminId).QueryRow(&item)
  575. 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
  576. FROM excel_info WHERE excel_name = ? AND source = ? AND is_delete=0 AND sys_user_id = ? `
  577. err = global.DmSQL["data"].Raw(sql, excelName, source, adminId).First(&item).Error
  578. return
  579. }
  580. // GetNoContentExcelInfoByUniqueCode 根据unique_code来获取excel表格详情
  581. func GetNoContentExcelInfoByUniqueCode(uniqueCode string) (item *MyExcelInfoList, err error) {
  582. //o := orm.NewOrmUsingDB("data")
  583. //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
  584. //FROM excel_info WHERE unique_code=? AND is_delete=0 `
  585. //err = o.Raw(sql, uniqueCode).QueryRow(&item)
  586. 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
  587. FROM excel_info WHERE unique_code=? AND is_delete=0 `
  588. err = global.DmSQL["data"].Raw(sql, uniqueCode).First(&item).Error
  589. return
  590. }
  591. // GetNoContentExcelInfoByExcelId 根据表格id来获取excel表格详情
  592. func GetNoContentExcelInfoByExcelId(excelInfoId int) (item *MyExcelInfoList, err error) {
  593. //o := orm.NewOrmUsingDB("data")
  594. //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
  595. //FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  596. //err = o.Raw(sql, excelInfoId).QueryRow(&item)
  597. 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
  598. FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
  599. err = global.DmSQL["data"].Raw(sql, excelInfoId).First(&item).Error
  600. return
  601. }
  602. // AddExcelInfoAndSheet 新增excel
  603. func AddExcelInfoAndSheet(excelInfo *ExcelInfo, sheetParamsList []AddExcelSheetParams) (err error) {
  604. //o, err := orm.NewOrmUsingDB("data").Begin()
  605. //if err != nil {
  606. // return
  607. //}
  608. //defer func() {
  609. // if err != nil {
  610. // _ = o.Rollback()
  611. // } else {
  612. // _ = o.Commit()
  613. // }
  614. //}()
  615. to := global.DmSQL["data"].Begin()
  616. defer func() {
  617. if err != nil {
  618. _ = to.Rollback()
  619. } else {
  620. _ = to.Commit()
  621. }
  622. }()
  623. // 表格信息入库
  624. err = to.Create(excelInfo).Error
  625. if err != nil {
  626. return
  627. }
  628. //excelInfo.ExcelInfoId = int(lastId)
  629. // sheet信息入库
  630. for _, sheetInfo := range sheetParamsList {
  631. dataNum := len(sheetInfo.DataList)
  632. //sheet信息入库
  633. excelSheetInfo := &ExcelSheet{
  634. ExcelSheetId: 0,
  635. ExcelInfoId: excelInfo.ExcelInfoId,
  636. SheetName: sheetInfo.SheetName,
  637. PageNum: dataNum,
  638. Index: sheetInfo.Index,
  639. Sort: sheetInfo.Sort,
  640. Config: sheetInfo.Config,
  641. CalcChain: sheetInfo.CalcChain,
  642. ModifyTime: time.Now(),
  643. CreateTime: time.Now(),
  644. }
  645. //sheetId, tmpErr := o.Insert(excelSheetInfo)
  646. //if tmpErr != nil {
  647. // err = tmpErr
  648. // return
  649. //}
  650. tmpErr := to.Create(excelSheetInfo).Error
  651. if tmpErr != nil {
  652. err = tmpErr
  653. return
  654. }
  655. //excelSheetInfo.ExcelSheetId = int(sheetId)
  656. // data信息入库
  657. if dataNum > 0 {
  658. for k, _ := range sheetInfo.DataList {
  659. sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
  660. sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
  661. }
  662. //_, tmpErr = o.InsertMulti(dataNum, sheetInfo.DataList)
  663. //if tmpErr != nil {
  664. // err = tmpErr
  665. // return
  666. //}
  667. tmpErr = to.CreateInBatches(sheetInfo.DataList, utils.MultiAddNum).Error
  668. if tmpErr != nil {
  669. err = tmpErr
  670. return
  671. }
  672. }
  673. }
  674. return
  675. }
  676. // SaveExcelInfoAndSheet 编辑保存
  677. func SaveExcelInfoAndSheet(excelInfo *ExcelInfo, updateExcelInfoParam []string, sheetParamsList []AddExcelSheetParams) (err error) {
  678. //o, err := orm.NewOrmUsingDB("data").Begin()
  679. //if err != nil {
  680. // return
  681. //}
  682. //defer func() {
  683. // if err != nil {
  684. // _ = o.Rollback()
  685. // } else {
  686. // _ = o.Commit()
  687. // }
  688. //}()
  689. to := global.DmSQL["data"].Begin()
  690. defer func() {
  691. if err != nil {
  692. _ = to.Rollback()
  693. } else {
  694. _ = to.Commit()
  695. }
  696. }()
  697. // 表格信息入库
  698. err = to.Select(updateExcelInfoParam).Updates(excelInfo).Error
  699. if err != nil {
  700. return
  701. }
  702. // 先删除历史的sheet信息
  703. sql := `DELETE FROM excel_sheet WHERE excel_info_id = ?`
  704. err = to.Exec(sql, excelInfo.ExcelInfoId).Error
  705. if err != nil {
  706. return
  707. }
  708. // 再删除历史sheet中的cell data信息
  709. //sql = `DELETE FROM excel_sheet_data WHERE excel_info_id = ?`
  710. //_, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
  711. //if err != nil {
  712. // return
  713. //}
  714. sql = `DELETE FROM excel_sheet_data WHERE excel_info_id = ?`
  715. err = to.Exec(sql, excelInfo.ExcelInfoId).Error
  716. if err != nil {
  717. return
  718. }
  719. // sheet信息入库
  720. for _, sheetInfo := range sheetParamsList {
  721. dataNum := len(sheetInfo.DataList)
  722. //sheet信息入库
  723. excelSheetInfo := &ExcelSheet{
  724. ExcelSheetId: 0,
  725. ExcelInfoId: excelInfo.ExcelInfoId,
  726. SheetName: sheetInfo.SheetName,
  727. PageNum: dataNum,
  728. Index: sheetInfo.Index,
  729. Sort: sheetInfo.Sort,
  730. Config: sheetInfo.Config,
  731. CalcChain: sheetInfo.CalcChain,
  732. ModifyTime: time.Now(),
  733. CreateTime: time.Now(),
  734. }
  735. //sheetId, tmpErr := o.Insert(excelSheetInfo)
  736. //if tmpErr != nil {
  737. // err = tmpErr
  738. // return
  739. //}
  740. //excelSheetInfo.ExcelSheetId = int(sheetId)
  741. tmpErr := to.Create(excelSheetInfo).Error
  742. if tmpErr != nil {
  743. err = tmpErr
  744. return
  745. }
  746. // data信息入库
  747. if dataNum > 0 {
  748. for k, _ := range sheetInfo.DataList {
  749. sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
  750. sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
  751. }
  752. //_, tmpErr = o.InsertMulti(dataNum, sheetInfo.DataList)
  753. //if tmpErr != nil {
  754. // err = tmpErr
  755. // return
  756. //}
  757. tmpErr = to.CreateInBatches(sheetInfo.DataList, utils.MultiAddNum).Error
  758. }
  759. }
  760. return
  761. }
  762. // BatchRefreshExcelReq 批量刷新表格请求
  763. type BatchRefreshExcelReq struct {
  764. ExcelCodes []string `description:"表格编码"`
  765. PrimaryId int `description:"研报/智能研报/PPT主键"`
  766. SubId int `description:"报告章节ID"`
  767. Source string `description:"来源,枚举值:report、english_report、smart_report"`
  768. }
  769. // GetExcelMaxSortByClassifyId 获取当前分类下,且排序数最大的excel
  770. func GetExcelMaxSortByClassifyId(classifyId int, source int) (sort int, err error) {
  771. //o := orm.NewOrmUsingDB("data")
  772. //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`
  773. //err = o.Raw(sql, classifyId, source).QueryRow(&sort)
  774. 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`
  775. err = global.DmSQL["data"].Raw(sql, classifyId, source).Scan(&sort).Error
  776. return
  777. }
  778. // GetNoContentExcelListByExcelInfoIdList
  779. // @Description: 根据ETA表格ID列表获取列表信息
  780. // @param excelInfoIdList []string
  781. // @return items
  782. // @return err
  783. func GetNoContentExcelListByExcelInfoIdList(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
  784. num := len(excelInfoIdList)
  785. if num <= 0 {
  786. return
  787. }
  788. //o := orm.NewOrmUsingDB("data")
  789. //sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  790. //_, err = o.Raw(sql, excelInfoIdList).QueryRows(&items)
  791. sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  792. err = global.DmSQL["data"].Raw(sql, excelInfoIdList).Find(&items).Error
  793. return
  794. }
  795. func GetNoContentExcelListByExcelInfoIdAndParentId(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
  796. num := len(excelInfoIdList)
  797. if num <= 0 {
  798. return
  799. }
  800. //o := orm.NewOrmUsingDB("data")
  801. //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 `
  802. //_, err = o.Raw(sql, excelInfoIdList, excelInfoIdList).QueryRows(&items)
  803. 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 `
  804. err = global.DmSQL["data"].Raw(sql, excelInfoIdList, excelInfoIdList).Find(&items).Error
  805. return
  806. }
  807. // GetNoContentExcelListByUserId
  808. // @Description: 根据ETA表格ID列表获取列表信息
  809. // @param userIdList []int
  810. // @return items
  811. // @return err
  812. func GetNoContentExcelListByUserId(userIdList []int) (items []*MyExcelInfoList, err error) {
  813. num := len(userIdList)
  814. if num <= 0 {
  815. return
  816. }
  817. //o := orm.NewOrmUsingDB("data")
  818. //sql := ` SELECT * FROM excel_info WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  819. //_, err = o.Raw(sql, userIdList).QueryRows(&items)
  820. sql := ` SELECT * FROM excel_info WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
  821. err = global.DmSQL["data"].Raw(sql, userIdList).Find(&items).Error
  822. return
  823. }
  824. // ModifyExcelInfoUserIdByCodeList
  825. // @Description: 根据编码列表修改表格信息
  826. // @author: Roc
  827. // @datetime 2024-03-26 14:16:30
  828. // @param excelIdList []string
  829. // @param userId int
  830. // @param userName string
  831. // @return err error
  832. func ModifyExcelInfoUserIdByCodeList(excelIdList []string, userId int, userName string) (err error) {
  833. num := len(excelIdList)
  834. if num <= 0 {
  835. return
  836. }
  837. //o := orm.NewOrmUsingDB("data")
  838. //sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) `
  839. //_, err = o.Raw(sql, userId, userName, excelIdList).Exec()
  840. sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) `
  841. err = global.DmSQL["data"].Exec(sql, userId, userName, excelIdList).Error
  842. return
  843. }
  844. // ModifyExcelInfoUserIdByOldUserId
  845. // @Description: 根据旧的用户id修改创建人
  846. // @author: Roc
  847. // @datetime 2024-03-25 19:14:59
  848. // @param oldUserId int
  849. // @param userId int
  850. // @param userName string
  851. // @return err error
  852. func ModifyExcelInfoUserIdByOldUserId(oldUserIdList []int, userId int, userName string) (err error) {
  853. num := len(oldUserIdList)
  854. if num <= 0 {
  855. return
  856. }
  857. //o := orm.NewOrmUsingDB("data")
  858. //sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE is_delete=0 AND sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
  859. //_, err = o.Raw(sql, userId, userName, oldUserIdList).Exec()
  860. sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE is_delete=0 AND sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
  861. err = global.DmSQL["data"].Exec(sql, userId, userName, oldUserIdList).Error
  862. return
  863. }
  864. func GetExcelBaseInfoByExcelInfoIdList(excelInfoIdList []int) (items []*data_manage.ExcelBaseInfo, err error) {
  865. num := len(excelInfoIdList)
  866. if num <= 0 {
  867. return
  868. }
  869. //o := orm.NewOrmUsingDB("data")
  870. //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 `
  871. //_, err = o.Raw(sql, excelInfoIdList).QueryRows(&items)
  872. 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 `
  873. err = global.DmSQL["data"].Raw(sql, excelInfoIdList).Find(&items).Error
  874. return
  875. }
  876. // ReplaceEdbInExcel 替换表格中的指标
  877. func ReplaceEdbInExcel(oldEdbInfoId, newEdbInfoId int, updateExcelList []*ExcelInfo) (err error) {
  878. var errmsg string
  879. logMsg := `` // 记录替换的日志
  880. replaceTotal := 0
  881. //o := orm.NewOrmUsingDB("data")
  882. //to, err := o.Begin()
  883. //if err != nil {
  884. // return
  885. //}
  886. //defer func() {
  887. // if err != nil {
  888. // _ = to.Rollback()
  889. // } else {
  890. // _ = to.Commit()
  891. // if logMsg != `` {
  892. // utils.FileLog.Info(fmt.Sprintf("替换表格中的指标记录,替换总表格数:%d,旧的指标id:%d,新的指标id:%d;%s", replaceTotal, oldEdbInfoId, newEdbInfoId, logMsg))
  893. // }
  894. // }
  895. // if errmsg != "" {
  896. // fmt.Println("errmsg:" + errmsg)
  897. // }
  898. // if err != nil && errmsg != "" {
  899. // //go alarm_msg.SendAlarmMsg("替换替换配置中的指标记录失败提醒,errmsg:"+errmsg, 3)
  900. // }
  901. //}()
  902. to := global.DmSQL["data"].Begin()
  903. defer func() {
  904. if err != nil {
  905. _ = to.Rollback()
  906. } else {
  907. _ = to.Commit()
  908. if logMsg != `` {
  909. utils.FileLog.Info(fmt.Sprintf("替换表格中的指标记录,替换总表格数:%d,旧的指标id:%d,新的指标id:%d;%s", replaceTotal, oldEdbInfoId, newEdbInfoId, logMsg))
  910. }
  911. }
  912. if errmsg != "" {
  913. fmt.Println("errmsg:" + errmsg)
  914. }
  915. if err != nil && errmsg != "" {
  916. //go alarm_msg.SendAlarmMsg("替换替换配置中的指标记录失败提醒,errmsg:"+errmsg, 3)
  917. }
  918. }()
  919. // 替换表格中的内容
  920. for _, excelInfo := range updateExcelList {
  921. //更新配置中的指标A
  922. //sql := `UPDATE excel_info SET content=?, modify_time=? WHERE excel_info_id=?`
  923. //_, err = to.Raw(sql, excelInfo.Content, time.Now(), excelInfo.ExcelInfoId).Exec()
  924. //if err != nil {
  925. // errmsg = "更新表格内容失败:Err:" + err.Error()
  926. // return
  927. //}
  928. sql := `UPDATE excel_info SET content=?, modify_time=? WHERE excel_info_id=?`
  929. err = to.Exec(sql, excelInfo.Content, time.Now(), excelInfo.ExcelInfoId).Error
  930. if err != nil {
  931. errmsg = "更新表格内容失败:Err:" + err.Error()
  932. return
  933. }
  934. //更新配置中的指标B
  935. // 判断是否已存在绑定,如果存在则删除
  936. sql = `DELETE FROM excel_edb_mapping WHERE excel_info_id=? and edb_info_id=?`
  937. err = to.Exec(sql, excelInfo.ExcelInfoId, newEdbInfoId).Error
  938. if err != nil {
  939. errmsg = "删除指标B关联图表配置信息失败:Err:" + err.Error()
  940. return
  941. }
  942. // 插入新的绑定
  943. //sql = `UPDATE excel_edb_mapping SET edb_info_id=?, modify_time=? WHERE excel_info_id=? and edb_info_id=?`
  944. //_, err = to.Raw(sql, newEdbInfoId, time.Now(), excelInfo.ExcelInfoId, oldEdbInfoId).Exec()
  945. //if err != nil {
  946. // errmsg = "更新指标B关联图表配置信息失败:Err:" + err.Error()
  947. // return
  948. //}
  949. sql = `UPDATE excel_edb_mapping SET edb_info_id=?, modify_time=? WHERE excel_info_id=? and edb_info_id=?`
  950. err = to.Exec(sql, newEdbInfoId, time.Now(), excelInfo.ExcelInfoId, oldEdbInfoId).Error
  951. if err != nil {
  952. errmsg = "更新指标B关联图表配置信息失败:Err:" + err.Error()
  953. return
  954. }
  955. logMsg += `涉及到的表格id:` + strconv.Itoa(excelInfo.ExcelInfoId) + ";"
  956. replaceTotal += 1
  957. }
  958. return
  959. }
  960. // GetChildExcelInfoByParentId 根据id 获取eta表格详情
  961. func GetChildExcelInfoByParentId(parentId int) (items []*ExcelInfo, err error) {
  962. //o := orm.NewOrmUsingDB("data")
  963. //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`
  964. //_, err = o.Raw(sql, parentId).QueryRows(&items)
  965. 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`
  966. err = global.DmSQL["data"].Raw(sql, parentId).Find(&items).Error
  967. return
  968. }
  969. // ExcelInfoDetailButton 操作按钮
  970. type ExcelInfoDetailButton struct {
  971. RefreshButton bool `description:"是否可刷新"`
  972. CopyButton bool `description:"是否可另存为"`
  973. DownloadButton bool `description:"是否可下载"`
  974. OpButton bool `description:"是否可编辑"`
  975. DeleteButton bool `description:"是否可删除"`
  976. OpEdbButton bool `description:"是否可生成指标"`
  977. RefreshEdbButton bool `description:"是否可刷新指标"`
  978. OpWorkerButton bool `description:"是否修改协作人"`
  979. }
  980. func UpdateExcelInfoClassifyIdByIds(classifyId int, excelIds []int) (err error) {
  981. if len(excelIds) == 0 {
  982. return
  983. }
  984. //o := orm.NewOrmUsingDB("data")
  985. //sql := fmt.Sprintf(`UPDATE excel_info SET excel_classify_id = ? WHERE excel_info_id IN (%s)`, utils.GetOrmInReplace(len(excelIds)))
  986. //_, err = o.Raw(sql, classifyId, excelIds).Exec()
  987. sql := fmt.Sprintf(`UPDATE excel_info SET excel_classify_id = ? WHERE excel_info_id IN (%s)`, utils.GetOrmInReplace(len(excelIds)))
  988. err = global.DmSQL["data"].Exec(sql, classifyId, excelIds).Error
  989. return
  990. }