excel_info.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674
  1. package excel
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "eta/eta_api/models/data_manage"
  6. "eta/eta_api/models/data_manage/excel"
  7. "eta/eta_api/models/data_manage/excel/request"
  8. "eta/eta_api/models/data_manage/excel/response"
  9. "eta/eta_api/models/system"
  10. "eta/eta_api/services/data"
  11. "eta/eta_api/services/data/data_manage_permission"
  12. "eta/eta_api/utils"
  13. "fmt"
  14. "sort"
  15. "time"
  16. )
  17. // GetExcelDetailInfoByExcelInfoId 根据表格id获取表格详情
  18. func GetExcelDetailInfoByExcelInfoId(excelInfoId, sysUserId int, lang string) (excelDetail response.ExcelInfoDetail, errMsg string, err error) {
  19. errMsg = `获取失败`
  20. //获取eta表格信息
  21. excelInfo, err := excel.GetExcelInfoById(excelInfoId)
  22. if err != nil {
  23. err = errors.New("获取ETA表格信息失败,Err:" + err.Error())
  24. if err.Error() == utils.ErrNoRow() {
  25. errMsg = "ETA表格被删除,请刷新页面"
  26. err = errors.New("ETA表格被删除,请刷新页面,Err:" + err.Error())
  27. }
  28. return
  29. }
  30. return formatExcelInfo2Detail(excelInfo, sysUserId, lang)
  31. }
  32. // GetExcelDetailInfoByUnicode 根据表格编码获取表格详情
  33. func GetExcelDetailInfoByUnicode(unicode string, sysUserId int, lang string) (excelDetail response.ExcelInfoDetail, errMsg string, err error) {
  34. errMsg = `获取失败`
  35. // 获取eta表格信息
  36. excelInfo, err := excel.GetExcelInfoByUnicode(unicode)
  37. if err != nil {
  38. err = errors.New("获取ETA表格信息失败,Err:" + err.Error())
  39. if err.Error() == utils.ErrNoRow() {
  40. errMsg = "ETA表格被删除,请刷新页面"
  41. err = errors.New("ETA表格被删除,请刷新页面,Err:" + err.Error())
  42. }
  43. return
  44. }
  45. return formatExcelInfo2Detail(excelInfo, sysUserId, lang)
  46. }
  47. func formatExcelInfo2Detail(excelInfo *excel.ExcelInfo, sysUserId int, lang string) (excelDetail response.ExcelInfoDetail, errMsg string, err error) {
  48. // 数据权限
  49. haveOperaAuth, err := data_manage_permission.CheckExcelPermissionByExcelInfoId(excelInfo.ExcelInfoId, excelInfo.ExcelClassifyId, excelInfo.IsJoinPermission, sysUserId)
  50. if err != nil {
  51. err = errors.New("获取表格权限信息失败,Err" + err.Error())
  52. return
  53. }
  54. excelDetail = response.ExcelInfoDetail{
  55. ExcelInfoId: excelInfo.ExcelInfoId,
  56. Source: excelInfo.Source,
  57. ExcelType: excelInfo.ExcelType,
  58. ExcelName: excelInfo.ExcelName,
  59. UniqueCode: excelInfo.UniqueCode,
  60. ExcelClassifyId: excelInfo.ExcelClassifyId,
  61. SysUserId: excelInfo.SysUserId,
  62. SysUserRealName: excelInfo.SysUserRealName,
  63. Content: excelInfo.Content,
  64. ExcelImage: excelInfo.ExcelImage,
  65. FileUrl: excelInfo.FileUrl,
  66. Sort: excelInfo.Sort,
  67. IsDelete: excelInfo.IsDelete,
  68. ModifyTime: excelInfo.ModifyTime,
  69. CreateTime: excelInfo.CreateTime,
  70. TableData: nil,
  71. HaveOperaAuth: haveOperaAuth,
  72. }
  73. // 无权限,不需要返回数据
  74. if !haveOperaAuth {
  75. return
  76. }
  77. switch excelInfo.Source {
  78. case utils.TIME_TABLE: // 时间序列表格
  79. var tableDataConfig TableDataConfig
  80. err = json.Unmarshal([]byte(excelDetail.Content), &tableDataConfig)
  81. if err != nil {
  82. err = errors.New("表格json转结构体失败,Err:" + err.Error())
  83. return
  84. }
  85. result, tmpErr := GetDataByTableDataConfig(tableDataConfig)
  86. if tmpErr != nil {
  87. err = errors.New("获取最新的表格数据失败,Err:" + tmpErr.Error())
  88. return
  89. }
  90. if len(result.EdbInfoIdList) > 0 {
  91. classifyIdList := make([]int, 0)
  92. for _, v := range result.Data {
  93. classifyIdList = append(classifyIdList, v.ClassifyId)
  94. }
  95. classifyMap := make(map[int]*data_manage.EdbClassify)
  96. classifyList, tmpErr := data_manage.GetEdbClassifyByIdList(classifyIdList)
  97. if tmpErr != nil {
  98. err = errors.New("获取分类列表失败,Err:" + tmpErr.Error())
  99. return
  100. }
  101. for _, v := range classifyList {
  102. classifyMap[v.ClassifyId] = v
  103. }
  104. // 获取所有有权限的指标和分类
  105. permissionEdbIdList, permissionClassifyIdList, tmpErr := data_manage_permission.GetUserEdbAndClassifyPermissionList(sysUserId, 0, 0)
  106. if err != nil {
  107. err = errors.New("获取所有有权限的指标和分类失败,Err:" + tmpErr.Error())
  108. return
  109. }
  110. for i, v := range result.Data {
  111. if currClassify, ok := classifyMap[v.ClassifyId]; ok {
  112. result.Data[i].HaveOperaAuth = data_manage_permission.CheckEdbPermissionByPermissionIdList(v.IsJoinPermission, currClassify.IsJoinPermission, v.EdbInfoId, v.ClassifyId, permissionEdbIdList, permissionClassifyIdList)
  113. }
  114. }
  115. }
  116. excelDetail.TableData = result
  117. case utils.MIXED_TABLE: // 混合表格
  118. var result request.MixedTableReq
  119. err = json.Unmarshal([]byte(excelDetail.Content), &result)
  120. if err != nil {
  121. err = errors.New("表格json转结构体失败,Err:" + err.Error())
  122. return
  123. }
  124. newData, tmpErr, tmpErrMsg := GetMixedTableCellData(result, lang)
  125. if tmpErr != nil {
  126. errMsg = "获取失败"
  127. if tmpErrMsg != `` {
  128. errMsg = tmpErrMsg
  129. }
  130. err = errors.New("获取最新的数据失败,Err:" + tmpErr.Error())
  131. return
  132. }
  133. result.Data = newData
  134. excelDetail.TableData = result
  135. }
  136. return
  137. }
  138. // GetExcelInfoOpButton 获取ETA表格的操作权限
  139. func GetExcelInfoOpButton(sysUser *system.Admin, belongUserId, source int, haveOperaAuth bool) (button response.ExcelInfoDetailButton) {
  140. // 如果没有数据权限,那么直接返回
  141. if !haveOperaAuth {
  142. return
  143. }
  144. //非管理员角色查看其他用户创建的表格,可刷新、另存为、下载表格;
  145. button.RefreshButton = true
  146. button.CopyButton = true
  147. button.DownloadButton = true
  148. // 1、本用户创建的表格,可编辑、刷新、另存为、下载、删除,删除需二次确认;
  149. // 2、管理员角色对所有表格有如上权限;
  150. // 3、在线excel所有人都能编辑
  151. if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN || sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN || sysUser.AdminId == belongUserId || source == utils.EXCEL_DEFAULT {
  152. button.OpButton = true
  153. button.DeleteButton = true
  154. }
  155. // 自定义分析
  156. if source == utils.CUSTOM_ANALYSIS_TABLE {
  157. if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN || sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN || sysUser.AdminId == belongUserId {
  158. button.OpEdbButton = true // 生成、查看指标按钮
  159. button.RefreshEdbButton = true // 刷新指标按钮
  160. }
  161. }
  162. return
  163. }
  164. // GetFirstEdbDataList 获取第一列的数据
  165. func GetFirstEdbDataList(edbInfo *data_manage.EdbInfo, num int, manualDateList []string) (resultDataList []request.ManualDataReq, err error) {
  166. var dataList []*data_manage.EdbDataList
  167. switch edbInfo.EdbInfoType {
  168. case 0:
  169. dataList, err = data_manage.GetEdbDataList(edbInfo.Source, edbInfo.SubSource, edbInfo.EdbInfoId, ``, ``)
  170. case 1:
  171. _, dataList, _, _, err, _ = data.GetPredictDataListByPredictEdbInfoId(edbInfo.EdbInfoId, ``, ``, false)
  172. default:
  173. err = errors.New(fmt.Sprint("获取失败,指标类型异常", edbInfo.EdbInfoType))
  174. }
  175. if err != nil {
  176. return
  177. }
  178. // 获取需要的期数
  179. lenData := len(dataList)
  180. if lenData <= 0 {
  181. return
  182. }
  183. tmpManualDateNum := 0 // 手工数据的期数
  184. lenManualDate := len(manualDateList)
  185. if lenManualDate > 0 {
  186. sortDateList := manualDateList
  187. baseDateList := utils.StrArr{}
  188. baseDateList = append(baseDateList, sortDateList...)
  189. sort.Sort(baseDateList)
  190. sortDateList = append([]string{}, baseDateList...)
  191. lastData := dataList[lenData-1]
  192. lastDataDate, tmpErr := time.ParseInLocation(utils.FormatDate, lastData.DataTime, time.Local)
  193. if tmpErr != nil {
  194. err = tmpErr
  195. return
  196. }
  197. // 遍历倒序后的日期,然后匹配在实际数据之后日期的个数
  198. for _, tmpDateStr := range sortDateList {
  199. tmpDate, tmpErr := time.ParseInLocation(utils.FormatDate, tmpDateStr, time.Local)
  200. if tmpErr != nil {
  201. err = tmpErr
  202. return
  203. }
  204. if tmpDate.After(lastDataDate) {
  205. tmpManualDateNum++
  206. continue
  207. }
  208. break
  209. }
  210. }
  211. // 需要的期数减去手工数据的期数,这才是A列指标需要的数据
  212. num = num - tmpManualDateNum
  213. if num > lenData {
  214. num = lenData
  215. }
  216. latestDateTime, _ := time.ParseInLocation(utils.FormatDate, edbInfo.LatestDate, time.Local)
  217. for i := 1; i <= num; i++ {
  218. dataTime, _ := time.ParseInLocation(utils.FormatDate, dataList[lenData-i].DataTime, time.Local)
  219. dataType := 1
  220. // 如果是预测指标,且当前值的日期,晚于实际日期,那么是预测值
  221. if edbInfo.EdbInfoType == 1 && dataTime.After(latestDateTime) {
  222. dataType = 5
  223. }
  224. resultDataList = append(resultDataList, request.ManualDataReq{
  225. DataType: dataType,
  226. DataTime: dataList[lenData-i].DataTime,
  227. ShowValue: fmt.Sprint(dataList[lenData-i].Value),
  228. Value: fmt.Sprint(dataList[lenData-i].Value),
  229. DataTimeType: 1,
  230. })
  231. }
  232. return
  233. }
  234. // GetOtherEdbDataList 获取其他列的数据
  235. func GetOtherEdbDataList(edbInfo *data_manage.EdbInfo, dateList []string) (resultDataList []request.ManualDataReq, err error) {
  236. lenDate := len(dateList)
  237. if lenDate <= 0 {
  238. return
  239. }
  240. sortDateList := dateList
  241. baseDateList := utils.StrArr{}
  242. baseDateList = append(baseDateList, sortDateList...)
  243. sort.Sort(baseDateList)
  244. sortDateList = append([]string{}, baseDateList...)
  245. endDateTime, err := time.ParseInLocation(utils.FormatDate, sortDateList[0], time.Local)
  246. if err != nil {
  247. return
  248. }
  249. firstDateTime, err := time.ParseInLocation(utils.FormatDate, sortDateList[lenDate-1], time.Local)
  250. if err != nil {
  251. return
  252. }
  253. var dataList []*data_manage.EdbDataList
  254. switch edbInfo.EdbInfoType {
  255. case 0:
  256. dataList, err = data_manage.GetEdbDataList(edbInfo.Source, edbInfo.SubSource, edbInfo.EdbInfoId, ``, ``)
  257. case 1:
  258. _, dataList, _, _, err, _ = data.GetPredictDataListByPredictEdbInfoId(edbInfo.EdbInfoId, ``, ``, false)
  259. default:
  260. err = errors.New(fmt.Sprint("获取失败,指标类型异常", edbInfo.EdbInfoType))
  261. }
  262. if err != nil {
  263. return
  264. }
  265. // 获取日期内的数据(包含开始日期前一个日期,以及 结束日期后一个日期,目的为了做空日期时的 插值法兼容)
  266. baseDataList := make([]*data_manage.EdbDataList, 0)
  267. var lastData *data_manage.EdbDataList
  268. var isInsert bool
  269. for _, data := range dataList {
  270. tmpDate := data.DataTime
  271. tmpDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, tmpDate, time.Local)
  272. if tmpErr != nil {
  273. err = tmpErr
  274. return
  275. }
  276. if tmpDateTime.Before(firstDateTime) {
  277. lastData = data
  278. continue
  279. }
  280. // 如果是第一次写入数据
  281. if !isInsert && lastData != nil {
  282. baseDataList = append(baseDataList, lastData)
  283. }
  284. if tmpDateTime.After(endDateTime) {
  285. baseDataList = append(baseDataList, data)
  286. break
  287. }
  288. baseDataList = append(baseDataList, data)
  289. isInsert = true
  290. }
  291. // 实际数据的日期map
  292. realValMap := make(map[string]string)
  293. for _, v := range baseDataList {
  294. realValMap[v.DataTime] = v.DataTime
  295. }
  296. // 插值法处理
  297. handleDataMap := make(map[string]float64)
  298. err = data.HandleDataByLinearRegression(baseDataList, handleDataMap)
  299. if err != nil {
  300. return
  301. }
  302. latestDateTime, _ := time.ParseInLocation(utils.FormatDate, edbInfo.LatestDate, time.Local)
  303. // 对于不存在的数据做补充
  304. for _, date := range sortDateList {
  305. dataType := 1
  306. if _, ok := realValMap[date]; !ok {
  307. dataType = 2
  308. } else {
  309. dataTime, _ := time.ParseInLocation(utils.FormatDate, date, time.Local)
  310. // 如果是预测指标,且当前值的日期,晚于实际日期,那么是预测值
  311. if edbInfo.EdbInfoType == 1 && dataTime.After(latestDateTime) {
  312. dataType = 5
  313. }
  314. }
  315. var value, showValue string
  316. if tmpVal, ok := handleDataMap[date]; ok {
  317. value = fmt.Sprint(tmpVal)
  318. showValue = value
  319. } else {
  320. dataType = 3
  321. }
  322. resultDataList = append(resultDataList, request.ManualDataReq{
  323. DataType: dataType,
  324. DataTime: date,
  325. ShowValue: showValue,
  326. Value: value,
  327. })
  328. }
  329. return
  330. }
  331. // GetFirstHistoryEdbDataList 获取指标的历史的数据
  332. func GetFirstHistoryEdbDataList(edbInfo *data_manage.EdbInfo, num int, endDate string) (resultDataList []request.ManualDataReq, err error) {
  333. endDateTime, err := time.ParseInLocation(utils.FormatDate, endDate, time.Local)
  334. if err != nil {
  335. return
  336. }
  337. var dataList []*data_manage.EdbDataList
  338. switch edbInfo.EdbInfoType {
  339. case 0:
  340. dataList, err = data_manage.GetEdbDataList(edbInfo.Source, edbInfo.SubSource, edbInfo.EdbInfoId, ``, endDate)
  341. case 1:
  342. _, dataList, _, _, err, _ = data.GetPredictDataListByPredictEdbInfoId(edbInfo.EdbInfoId, ``, endDate, true)
  343. default:
  344. err = errors.New(fmt.Sprint("获取失败,指标类型异常", edbInfo.EdbInfoType))
  345. }
  346. if err != nil {
  347. return
  348. }
  349. // 获取需要的期数
  350. lenData := len(dataList)
  351. if lenData <= 0 {
  352. return
  353. }
  354. lastData := dataList[lenData-1]
  355. lastDataDateTime, err := time.ParseInLocation(utils.FormatDate, lastData.DataTime, time.Local)
  356. if err != nil {
  357. return
  358. }
  359. if endDateTime.Equal(lastDataDateTime) || lastDataDateTime.After(endDateTime) {
  360. dataList = dataList[:lenData-1]
  361. lenData = len(dataList)
  362. }
  363. if num > lenData {
  364. num = lenData
  365. }
  366. latestDateTime, _ := time.ParseInLocation(utils.FormatDate, edbInfo.LatestDate, time.Local)
  367. for i := 1; i <= num; i++ {
  368. dataTime, _ := time.ParseInLocation(utils.FormatDate, dataList[lenData-i].DataTime, time.Local)
  369. dataType := 1
  370. // 如果是预测指标,且当前值的日期,晚于实际日期,那么是预测值
  371. if edbInfo.EdbInfoType == 1 && dataTime.After(latestDateTime) {
  372. dataType = 5
  373. }
  374. resultDataList = append(resultDataList, request.ManualDataReq{
  375. DataType: dataType,
  376. DataTime: dataList[lenData-i].DataTime,
  377. ShowValue: fmt.Sprint(dataList[lenData-i].Value),
  378. Value: fmt.Sprint(dataList[lenData-i].Value),
  379. })
  380. }
  381. return
  382. }
  383. // GetEdbIdsFromExcelCodes 获取表格中的指标IDs
  384. func GetEdbIdsFromExcelCodes(excelCodes []string, sysUserId int, lang string) (edbIds []int, err error) {
  385. edbIds = make([]int, 0)
  386. edbIdExist := make(map[int]bool)
  387. for _, v := range excelCodes {
  388. // 表格详情
  389. detail, msg, e := GetExcelDetailInfoByUnicode(v, sysUserId, lang)
  390. if e != nil {
  391. err = fmt.Errorf("GetExcelDetailInfoByExcelInfoId err: %s, errMsg: %s", e.Error(), msg)
  392. return
  393. }
  394. // 自定义表格
  395. if detail.Source == utils.TIME_TABLE {
  396. jsonByte, e := json.Marshal(detail.TableData)
  397. if e != nil {
  398. err = fmt.Errorf("JSON格式化自定义表格数据失败, Err: %s", e.Error())
  399. return
  400. }
  401. var tableData request.TableDataReq
  402. if e = json.Unmarshal(jsonByte, &tableData); e != nil {
  403. err = fmt.Errorf("解析自定义表格数据失败, Err: %s", e.Error())
  404. return
  405. }
  406. for _, tv := range tableData.EdbInfoIdList {
  407. if edbIdExist[tv] {
  408. continue
  409. }
  410. edbIdExist[tv] = true
  411. edbIds = append(edbIds, tv)
  412. }
  413. }
  414. // 混合表格
  415. if detail.Source == utils.MIXED_TABLE {
  416. jsonByte, e := json.Marshal(detail.TableData)
  417. if e != nil {
  418. err = fmt.Errorf("JSON格式化混合表格数据失败, Err: %s", e.Error())
  419. return
  420. }
  421. var tableData request.MixedTableReq
  422. if e = json.Unmarshal(jsonByte, &tableData); e != nil {
  423. err = fmt.Errorf("解析混合表格数据失败, Err: %s", e.Error())
  424. return
  425. }
  426. if len(tableData.Data) > 0 {
  427. for _, td := range tableData.Data {
  428. for _, tv := range td {
  429. if tv.EdbInfoId > 0 && !edbIdExist[tv.EdbInfoId] {
  430. edbIdExist[tv.EdbInfoId] = true
  431. edbIds = append(edbIds, tv.EdbInfoId)
  432. }
  433. }
  434. }
  435. }
  436. }
  437. }
  438. return
  439. }
  440. // GetExcelEdbBatchRefreshKey 获取批量刷新表格指标缓存key
  441. func GetExcelEdbBatchRefreshKey(source string, reportId, chapterId int) string {
  442. if source == `` {
  443. return ``
  444. }
  445. return fmt.Sprint("batch_refresh_excel_edb:", source, ":", reportId, ":", chapterId)
  446. }
  447. // ReplaceEdbInExcel 替换表格中的指标
  448. func ReplaceEdbInExcel(oldEdbInfo, newEdbInfo *data_manage.EdbInfo) (err error) {
  449. //查询和指标相关的 表格
  450. mappingList, err := excel.GetExcelEdbMappingByEdbInfoId(oldEdbInfo.EdbInfoId)
  451. if err != nil {
  452. err = fmt.Errorf("查询和指标相关的表格失败,错误:%s", err.Error())
  453. return
  454. }
  455. updateList := make([]*excel.ExcelInfo, 0)
  456. // 循环列表,根据表格类型单独处理
  457. for _, excelMapping := range mappingList {
  458. //查询和指标相关的混合表格
  459. excelInfo, tmpErr := excel.GetExcelInfoById(excelMapping.ExcelInfoId)
  460. if tmpErr != nil {
  461. err = fmt.Errorf("查询和指标相关的混合表格失败,错误:%s", tmpErr.Error())
  462. return
  463. }
  464. // 清除缓存
  465. key := utils.HZ_CHART_LIB_EXCEL_TABLE_DETAIL + ":" + excelInfo.UniqueCode
  466. if utils.Re == nil {
  467. _ = utils.Rc.Delete(key)
  468. }
  469. // 根据表格类型,调用不同的处理函数
  470. switch excelMapping.Source {
  471. case utils.TIME_TABLE: // 时间序列表格
  472. // 替换余额表格中的指标
  473. newExcelInfo, e := replaceEdbInTimeExcel(oldEdbInfo, newEdbInfo, excelInfo)
  474. if e != nil {
  475. err = fmt.Errorf("替换余额表格中的指标失败,错误:%s", e.Error())
  476. return
  477. }
  478. updateList = append(updateList, newExcelInfo)
  479. case utils.MIXED_TABLE:
  480. // 替换余额表格中的指标
  481. newExcelInfo, e := replaceEdbInBalanceExcel(oldEdbInfo, newEdbInfo, excelInfo)
  482. if e != nil {
  483. err = fmt.Errorf("替换余额表格中的指标失败,错误:%s", e.Error())
  484. return
  485. }
  486. updateList = append(updateList, newExcelInfo)
  487. default:
  488. // 其他表格类型的处理逻辑
  489. }
  490. }
  491. err = excel.ReplaceEdbInExcel(oldEdbInfo.EdbInfoId, newEdbInfo.EdbInfoId, updateList)
  492. if err != nil {
  493. err = fmt.Errorf("替换表格中的指标失败,错误:%s", err.Error())
  494. return
  495. }
  496. //todo 是否需要刷新表格中的指标数据
  497. return
  498. }
  499. func replaceEdbInBalanceExcel(oldEdbInfo, newEdbInfo *data_manage.EdbInfo, excelInfo *excel.ExcelInfo) (newExcelInfo *excel.ExcelInfo, err error) {
  500. newExcelInfo = excelInfo
  501. var mixedTableReq request.MixedTableReq
  502. err = json.Unmarshal([]byte(excelInfo.Content), &mixedTableReq)
  503. if err != nil {
  504. err = fmt.Errorf("表格json转结构体失败,Err:" + err.Error())
  505. return
  506. }
  507. // 处理data
  508. configList := mixedTableReq.Data
  509. for ck, rowList := range configList {
  510. for rk, cell := range rowList {
  511. switch cell.DataType {
  512. case request.EdbDT: // 指标信息
  513. if cell.EdbInfoId == oldEdbInfo.EdbInfoId {
  514. //更换成新指标ID
  515. configList[ck][rk].EdbInfoId = newEdbInfo.EdbInfoId
  516. }
  517. case request.InsertDataDT, request.PopInsertDataDT: // 插值、弹框插值
  518. if cell.EdbInfoId == oldEdbInfo.EdbInfoId {
  519. //更换成新指标ID
  520. configList[ck][rk].EdbInfoId = newEdbInfo.EdbInfoId
  521. }
  522. case request.InsertEdbCalculateDataDT: // 插入指标计算公式生成的值
  523. var config request.CalculateConf
  524. err = json.Unmarshal([]byte(cell.Value), &config)
  525. if err != nil {
  526. return
  527. }
  528. if cell.EdbInfoId == oldEdbInfo.EdbInfoId {
  529. //更换成新指标ID
  530. configList[ck][rk].EdbInfoId = newEdbInfo.EdbInfoId
  531. }
  532. if config.EdbInfoId == oldEdbInfo.EdbInfoId {
  533. config.EdbInfoId = newEdbInfo.EdbInfoId
  534. }
  535. var configStr []byte
  536. configStr, err = json.Marshal(config)
  537. if err != nil {
  538. return
  539. }
  540. configList[ck][rk].Value = string(configStr)
  541. case request.DateDT: // 日期类型
  542. // 指标日期类型的单元格需要额外将指标id取出来
  543. if cell.DataTimeType == request.EdbDateDT {
  544. var config request.EdbDateConf
  545. err = json.Unmarshal([]byte(cell.Value), &config)
  546. if err != nil {
  547. return
  548. }
  549. if config.EdbInfoId == oldEdbInfo.EdbInfoId {
  550. config.EdbInfoId = newEdbInfo.EdbInfoId
  551. var configStr []byte
  552. configStr, err = json.Marshal(config)
  553. if err != nil {
  554. return
  555. }
  556. configList[ck][rk].Value = string(configStr)
  557. }
  558. }
  559. }
  560. }
  561. }
  562. mixedTableReq.Data = configList
  563. var newContentByte []byte
  564. newContentByte, err = json.Marshal(mixedTableReq)
  565. if err != nil {
  566. return
  567. }
  568. // 生成的新内容替换原先的旧内容
  569. excelInfo.Content = string(newContentByte)
  570. newExcelInfo = excelInfo
  571. return
  572. }
  573. func replaceEdbInTimeExcel(oldEdbInfo, newEdbInfo *data_manage.EdbInfo, excelInfo *excel.ExcelInfo) (newExcelInfo *excel.ExcelInfo, err error) {
  574. newExcelInfo = excelInfo
  575. var tableDataConfig TableDataConfig
  576. err = json.Unmarshal([]byte(excelInfo.Content), &tableDataConfig)
  577. if err != nil {
  578. err = errors.New("表格json转结构体失败,Err:" + err.Error())
  579. return
  580. }
  581. if len(tableDataConfig.EdbInfoIdList) <= 0 {
  582. return
  583. }
  584. // 实际期数没有的情况下,直接返回吧
  585. if tableDataConfig.Num <= 0 {
  586. return
  587. }
  588. // 先处理edbInfoList
  589. for k, id := range tableDataConfig.EdbInfoIdList {
  590. if id == oldEdbInfo.EdbInfoId {
  591. tableDataConfig.EdbInfoIdList[k] = newEdbInfo.EdbInfoId
  592. }
  593. }
  594. // 先处理tableEdbInfoList
  595. for k, tableEdbInfo := range tableDataConfig.TableEdbInfoList {
  596. if tableEdbInfo.EdbInfoId == oldEdbInfo.EdbInfoId {
  597. tableDataConfig.TableEdbInfoList[k].EdbInfoId = newEdbInfo.EdbInfoId
  598. }
  599. }
  600. var newContentByte []byte
  601. newContentByte, err = json.Marshal(tableDataConfig)
  602. if err != nil {
  603. return
  604. }
  605. // 生成的新内容替换原先的旧内容
  606. excelInfo.Content = string(newContentByte)
  607. newExcelInfo = excelInfo
  608. return
  609. }