residual_analysis_service.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642
  1. package residual_analysis_service
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/models/data_manage"
  5. "eta/eta_api/models/residual_analysis_model"
  6. "eta/eta_api/models/system"
  7. "eta/eta_api/utils"
  8. "fmt"
  9. "math"
  10. "strconv"
  11. "time"
  12. )
  13. func ResidualAnalysisPreview(req residual_analysis_model.ResidualAnalysisReq) (residual_analysis_model.ResidualAnalysisResp, error) {
  14. if req.DateType < 0 {
  15. return residual_analysis_model.ResidualAnalysisResp{}, fmt.Errorf("时间类型错误", nil)
  16. }
  17. mappingList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList([]int{req.EdbInfoIdA, req.EdbInfoIdB})
  18. if err != nil {
  19. return residual_analysis_model.ResidualAnalysisResp{}, fmt.Errorf("获取图表,指标信息失败,Err:%s", err.Error())
  20. }
  21. var edbInfoMappingA, edbInfoMappingB *data_manage.ChartEdbInfoMapping
  22. for _, v := range mappingList {
  23. if v.EdbInfoId == req.EdbInfoIdA {
  24. edbInfoMappingA = v
  25. }
  26. if v.EdbInfoId == req.EdbInfoIdB {
  27. edbInfoMappingB = v
  28. }
  29. }
  30. if edbInfoMappingA == nil {
  31. return residual_analysis_model.ResidualAnalysisResp{}, fmt.Errorf("指标A不存在", nil)
  32. }
  33. if edbInfoMappingB == nil {
  34. return residual_analysis_model.ResidualAnalysisResp{}, fmt.Errorf("指标B不存在", nil)
  35. }
  36. // 时间处理
  37. var startDate, endDate string
  38. switch req.DateType {
  39. case 0:
  40. startDate = req.StartDate
  41. endDate = req.EndDate
  42. case 1:
  43. startDate = req.StartDate
  44. endDate = ""
  45. default:
  46. startDate = utils.GetPreYearTime(req.DateType)
  47. endDate = ""
  48. }
  49. resp := residual_analysis_model.ResidualAnalysisResp{}
  50. // 图表基础信息
  51. /*baseChartInfo := new(residual_analysis_model.ResidualAnalysisChartInfo)
  52. baseChartInfo.Calendar = `公历`
  53. baseChartInfo.Source = utils.CHART_SOURCE_DEFAULT
  54. baseChartInfo.DateType = req.DateType
  55. baseChartInfo.StartDate = startDate
  56. baseChartInfo.EndDate = endDate
  57. baseChartInfo.ChartType = utils.CHART_TYPE_CURVE*/
  58. // 原始图表信息
  59. originalEdbList := make([]residual_analysis_model.ResidualAnalysisChartEdbInfoMapping, 0)
  60. originalEdbList, err = fillOriginalChart(req, mappingList, startDate, endDate, edbInfoMappingA, edbInfoMappingB, originalEdbList)
  61. if err != nil {
  62. return residual_analysis_model.ResidualAnalysisResp{}, err
  63. }
  64. originalChartInfo := createChartInfoResp(req, startDate, endDate, edbInfoMappingA.EdbName+"与"+edbInfoMappingB.EdbName)
  65. resp.OriginalChartData = residual_analysis_model.ChartResp{
  66. ChartInfo: originalChartInfo,
  67. EdbInfoList: originalEdbList,
  68. }
  69. dataAList, ok := edbInfoMappingA.DataList.([]*data_manage.EdbDataList)
  70. if !ok {
  71. return residual_analysis_model.ResidualAnalysisResp{}, fmt.Errorf("数据类型转换失败", nil)
  72. }
  73. indexADataMap := map[string]*data_manage.EdbDataList{}
  74. for _, indexData := range dataAList {
  75. indexADataMap[indexData.DataTime] = indexData
  76. }
  77. // 映射图表信息
  78. mappingEdbList, a, b, r, err := fillMappingChartInfo(req, edbInfoMappingA, edbInfoMappingB, originalEdbList, indexADataMap)
  79. if err != nil {
  80. return residual_analysis_model.ResidualAnalysisResp{}, err
  81. }
  82. mappingChartInfo := createChartInfoResp(req, startDate, endDate, edbInfoMappingA.EdbName+"与"+edbInfoMappingB.EdbName+"映射"+edbInfoMappingA.EdbName)
  83. resp.MappingChartData = residual_analysis_model.ChartResp{
  84. ChartInfo: mappingChartInfo,
  85. EdbInfoList: mappingEdbList,
  86. }
  87. // 残差图表信息
  88. residualEdbList, R2, err := fillResidualChartInfo(edbInfoMappingA, edbInfoMappingB, mappingEdbList)
  89. if err != nil {
  90. return residual_analysis_model.ResidualAnalysisResp{}, err
  91. }
  92. residualChartInfo := createChartInfoResp(req, startDate, endDate, edbInfoMappingA.EdbName+"与"+edbInfoMappingA.EdbName+"映射残差/"+edbInfoMappingB.EdbName)
  93. resp.ResidualChartData = residual_analysis_model.ChartResp{
  94. ChartInfo: residualChartInfo,
  95. EdbInfoList: residualEdbList,
  96. }
  97. if req.ResidualType == 2 {
  98. resp.A = a
  99. resp.B = b
  100. resp.R = r
  101. resp.R2 = R2
  102. }
  103. return resp, nil
  104. }
  105. func createChartInfoResp(req residual_analysis_model.ResidualAnalysisReq, startDate, endDate, chartName string) residual_analysis_model.ResidualAnalysisChartInfo {
  106. return residual_analysis_model.ResidualAnalysisChartInfo{
  107. Calendar: `公历`,
  108. Source: utils.CHART_SOURCE_DEFAULT,
  109. DateType: req.DateType,
  110. StartDate: startDate,
  111. EndDate: endDate,
  112. ChartType: utils.CHART_TYPE_CURVE,
  113. ChartName: chartName,
  114. }
  115. }
  116. func fillResidualChartInfo(edbInfoMappingA *data_manage.ChartEdbInfoMapping, edbInfoMappingB *data_manage.ChartEdbInfoMapping, mappingEdbList []residual_analysis_model.ResidualAnalysisChartEdbInfoMapping) ([]residual_analysis_model.ResidualAnalysisChartEdbInfoMapping, float64, error) {
  117. // 计算公式 映射残差 = 因变量指标 - 映射指标
  118. var edbInfoA, edbInfoB residual_analysis_model.ResidualAnalysisChartEdbInfoMapping
  119. if mappingEdbList[0].EdbInfoId == edbInfoMappingA.EdbInfoId {
  120. edbInfoA = mappingEdbList[0]
  121. edbInfoB = mappingEdbList[1]
  122. } else {
  123. edbInfoA = mappingEdbList[1]
  124. edbInfoB = mappingEdbList[0]
  125. }
  126. dataAList, ok := edbInfoA.DataList.([]*data_manage.EdbDataList)
  127. if !ok {
  128. return nil, 0, fmt.Errorf("数据类型转换失败", nil)
  129. }
  130. edbData := dataAList
  131. dataBList, ok := edbInfoB.DataList.([]*data_manage.EdbDataList)
  132. if !ok {
  133. return nil, 0, fmt.Errorf("数据类型转换失败", nil)
  134. }
  135. var indexDataBMap = make(map[string]*data_manage.EdbDataList)
  136. for _, data := range dataBList {
  137. indexDataBMap[data.DataTime] = data
  138. }
  139. // 求R2
  140. var valueB, sumValueA, averageValueA, residualQuadraticSum, totalQuadraticSum, R2 float64
  141. for _, indexData := range edbData {
  142. // 因变量的值总和
  143. sumValueA += indexData.Value
  144. }
  145. // 因变量平均值
  146. averageValueA = sumValueA / float64(len(edbData))
  147. for _, indexData := range edbData {
  148. if dataB, ok := indexDataBMap[indexData.DataTime]; ok {
  149. valueB = dataB.Value
  150. } else {
  151. valueB = 0
  152. }
  153. // 总因变量平方和
  154. totalQuadraticSum += math.Pow(indexData.Value-averageValueA, 2)
  155. // 补全残差值
  156. indexData.Value = indexData.Value - valueB
  157. // 残差平方和
  158. residualQuadraticSum += math.Pow(indexData.Value, 2)
  159. }
  160. // 计算R2 公式:R2=1-SSE/SST R2越大,越符合线性 R2 = 1 - 残差平方和/总平方和
  161. R2 = 1 - residualQuadraticSum/totalQuadraticSum
  162. for _, mapping := range mappingEdbList {
  163. if mapping.EdbInfoId != edbInfoMappingA.EdbInfoId {
  164. mapping.DataList = edbData
  165. mapping.EdbName = edbInfoMappingA.EdbName + "映射残差/" + edbInfoMappingB.EdbName
  166. }
  167. }
  168. return mappingEdbList, R2, nil
  169. }
  170. func fillMappingChartInfo(req residual_analysis_model.ResidualAnalysisReq, edbInfoMappingA *data_manage.ChartEdbInfoMapping, edbInfoMappingB *data_manage.ChartEdbInfoMapping, originalEdbList []residual_analysis_model.ResidualAnalysisChartEdbInfoMapping, indexADataMap map[string]*data_manage.EdbDataList) ([]residual_analysis_model.ResidualAnalysisChartEdbInfoMapping, float64, float64, float64, error) {
  171. // 计算公式:Y=aX+b,Y为映射后的指标,X为自变量指标
  172. // 正序:a=(L2-L1)/(R2-R1) b=L2-R2*a
  173. // 逆序:a=(L2-L1)/(R1-R2) b=L2-R1*a
  174. // L2:左轴下限 R2:右轴上限 L1:左轴上限 R1:右轴下限
  175. var a, b, r float64
  176. // 映射残差 计算a,b
  177. if req.ResidualType == 1 {
  178. if req.IsOrder {
  179. a = (req.LeftIndexMax - req.LeftIndexMin) / (req.RightIndexMax - req.RightIndexMin)
  180. b = req.LeftIndexMax - req.RightIndexMax*a
  181. } else {
  182. a = (req.LeftIndexMax - req.LeftIndexMin) / (req.RightIndexMin - req.RightIndexMax)
  183. b = req.LeftIndexMax - req.RightIndexMin*a
  184. }
  185. }
  186. dataList, ok := edbInfoMappingB.DataList.([]*data_manage.EdbDataList)
  187. if !ok {
  188. return nil, a, b, r, fmt.Errorf("数据类型转换失败", nil)
  189. }
  190. // 领先指标 dataList进行数据处理
  191. if req.IndexType == 2 {
  192. if req.LeadValue < 0 {
  193. return nil, a, b, r, fmt.Errorf("领先值不能小于0", nil)
  194. } else if req.LeadValue > 0 {
  195. for _, indexData := range dataList {
  196. switch req.LeadFrequency {
  197. case "天":
  198. indexData.DataTime = utils.GetNextDayN(indexData.DataTime, req.LeadValue)
  199. case "周":
  200. indexData.DataTime = utils.GetNextDayN(indexData.DataTime, req.LeadValue*7)
  201. case "月":
  202. indexData.DataTime = utils.TimeToString(utils.AddDate(utils.StringToTime(indexData.DataTime), 0, req.LeadValue), utils.YearMonthDay)
  203. case "季":
  204. indexData.DataTime = utils.TimeToString(utils.AddDate(utils.StringToTime(indexData.DataTime), 0, req.LeadValue*3), utils.YearMonthDay)
  205. case "年":
  206. indexData.DataTime = utils.TimeToString(utils.AddDate(utils.StringToTime(indexData.DataTime), req.LeadValue, 0), utils.YearMonthDay)
  207. }
  208. }
  209. }
  210. }
  211. // 指标B数据补充
  212. for index := 0; index < len(dataList)-1; index++ {
  213. // 获取当前数据和下一个数据
  214. beforeIndexData := dataList[index]
  215. afterIndexData := dataList[index+1]
  216. // 从最早时间开始,补充时间为自然日
  217. if utils.IsMoreThanOneDay(beforeIndexData.DataTime, afterIndexData.DataTime) {
  218. // 创建补充数据
  219. replenishIndexData := data_manage.EdbDataList{
  220. DataTime: utils.GetNextDay(beforeIndexData.DataTime),
  221. DataTimestamp: time.Now().UnixMilli(),
  222. Value: beforeIndexData.Value,
  223. }
  224. // 将补充数据插入到数据列表
  225. dataList = append(dataList, &replenishIndexData)
  226. }
  227. }
  228. // 拟合残差 计算a,b
  229. var coordinateList []utils.Coordinate
  230. if req.ResidualType == 2 {
  231. for _, indexData := range dataList {
  232. if _, ok := indexADataMap[indexData.DataTime]; ok {
  233. coordinate := utils.Coordinate{
  234. X: indexData.Value,
  235. Y: indexADataMap[indexData.DataTime].Value,
  236. }
  237. coordinateList = append(coordinateList, coordinate)
  238. }
  239. }
  240. a, b = utils.GetLinearResult(coordinateList)
  241. r = utils.CalculationDecisive(coordinateList)
  242. }
  243. // 根据指标A的时间key,在B的映射指标中筛选出对应的值
  244. var dataBList []*data_manage.EdbDataList
  245. for _, indexData := range dataList {
  246. if _, ok := indexADataMap[indexData.DataTime]; ok {
  247. // 计算指标B映射值
  248. indexData.Value = math.Round(a*indexData.Value+b) / 10000
  249. dataBList = append(dataBList, indexData)
  250. }
  251. }
  252. mappingEdbList := make([]residual_analysis_model.ResidualAnalysisChartEdbInfoMapping, len(originalEdbList))
  253. copy(mappingEdbList, originalEdbList)
  254. for i, mapping := range mappingEdbList {
  255. if mapping.EdbInfoId != req.EdbInfoIdA {
  256. mappingEdbList[i].EdbInfoId = 0
  257. mappingEdbList[i].EdbCode = ""
  258. mappingEdbList[i].EdbName = edbInfoMappingB.EdbName + "映射" + edbInfoMappingA.EdbName
  259. mappingEdbList[i].DataList = dataBList
  260. }
  261. }
  262. return mappingEdbList, a, b, r, nil
  263. }
  264. func fillOriginalChart(req residual_analysis_model.ResidualAnalysisReq, mappingList []*data_manage.ChartEdbInfoMapping, startDate string, endDate string, edbInfoMappingA *data_manage.ChartEdbInfoMapping, edbInfoMappingB *data_manage.ChartEdbInfoMapping, originalEdbList []residual_analysis_model.ResidualAnalysisChartEdbInfoMapping) ([]residual_analysis_model.ResidualAnalysisChartEdbInfoMapping, error) {
  265. for _, v := range mappingList {
  266. var edbInfoMapping residual_analysis_model.ResidualAnalysisChartEdbInfoMapping
  267. edbInfoMapping.EdbInfoType = 1
  268. edbInfoMapping.IsOrder = false
  269. edbInfoMapping.IsAxis = 1
  270. edbInfoMapping.ChartColor = `#00F`
  271. edbInfoMapping.ChartWidth = 3
  272. // 获取图表中的指标数据
  273. dataList, err := data_manage.GetEdbDataList(v.Source, v.SubSource, v.EdbInfoId, startDate, endDate)
  274. if err != nil {
  275. return nil, fmt.Errorf("获取指标数据失败,Err:%s", err.Error())
  276. }
  277. if v.EdbInfoId == req.EdbInfoIdB {
  278. edbInfoMapping.LeadValue = req.LeadValue
  279. edbInfoMapping.LeadUnit = req.LeadFrequency
  280. edbInfoMapping.EdbInfoType = req.IndexType
  281. edbInfoMapping.IsOrder = req.IsOrder
  282. edbInfoMapping.IsAxis = 0
  283. edbInfoMapping.ChartColor = `#F00`
  284. edbInfoMapping.ChartWidth = 1
  285. edbInfoMappingB.DataList = dataList
  286. } else {
  287. edbInfoMappingA.DataList = dataList
  288. }
  289. edbInfoMapping.EdbInfoId = v.EdbInfoId
  290. edbInfoMapping.EdbName = v.EdbName
  291. edbInfoMapping.EdbCode = v.EdbCode
  292. edbInfoMapping.Unit = v.Unit
  293. edbInfoMapping.Frequency = v.Frequency
  294. edbInfoMapping.Source = v.Source
  295. edbInfoMapping.SourceName = v.SourceName
  296. edbInfoMapping.MinValue = v.MinData
  297. edbInfoMapping.MaxValue = v.MaxData
  298. edbInfoMapping.LatestDate = v.LatestDate
  299. edbInfoMapping.LatestValue = v.LatestValue
  300. edbInfoMapping.DataList = dataList
  301. originalEdbList = append(originalEdbList, edbInfoMapping)
  302. }
  303. return originalEdbList, nil
  304. }
  305. func ContrastPreview(indexCode string) (residual_analysis_model.ResidualAnalysisChartEdbInfoMapping, error) {
  306. var condition string
  307. var pars []interface{}
  308. if indexCode != "" {
  309. condition += " and edb_code=?"
  310. pars = append(pars, indexCode)
  311. }
  312. edbInfo, err := data_manage.GetEdbInfoByCondition(condition, pars)
  313. if err != nil {
  314. return residual_analysis_model.ResidualAnalysisChartEdbInfoMapping{}, err
  315. }
  316. if edbInfo == nil {
  317. return residual_analysis_model.ResidualAnalysisChartEdbInfoMapping{}, fmt.Errorf("指标不存在")
  318. }
  319. dataList, err := data_manage.GetEdbDataList(edbInfo.Source, edbInfo.SubSource, edbInfo.EdbInfoId, "", "")
  320. var resp residual_analysis_model.ResidualAnalysisChartEdbInfoMapping
  321. resp.EdbInfoId = edbInfo.EdbInfoId
  322. resp.EdbCode = edbInfo.EdbCode
  323. resp.SourceName = edbInfo.SourceName
  324. resp.EdbName = edbInfo.EdbName
  325. resp.Unit = edbInfo.Unit
  326. resp.Frequency = edbInfo.Frequency
  327. resp.DataList = dataList
  328. return resp, nil
  329. }
  330. func SaveResidualAnalysis(req residual_analysis_model.ResidualAnalysisIndexSaveReq, sysUser *system.Admin) error {
  331. // 验证分类是否存在
  332. classifyCount, err := data_manage.GetEdbClassifyCountById(req.ClassifyId)
  333. if err != nil {
  334. return err
  335. }
  336. if classifyCount <= 0 {
  337. return fmt.Errorf("分类不存在", nil)
  338. }
  339. // 获取指标数据最大值 最小值 最后更新时间 最后更新时间对应的值
  340. var indexMax, indexMin, indexLatestValue float64
  341. var indexLatestDate string
  342. latestTime, _ := time.Parse(utils.YearMonthDay, req.DataList[0].DataTime)
  343. for _, data := range req.DataList {
  344. // 比较最大值
  345. if data.Value > indexMax {
  346. indexMax = data.Value
  347. }
  348. // 比较最小值
  349. if data.Value < indexMin {
  350. indexMin = data.Value
  351. }
  352. // 比较最新时间和对应值
  353. currentTime, err := time.Parse(utils.YearMonthDay, data.DataTime)
  354. if err != nil {
  355. // 时间解析失败,跳过此项
  356. continue
  357. }
  358. // 如果当前时间更晚
  359. if currentTime.After(latestTime) {
  360. latestTime = currentTime
  361. indexLatestDate = data.DataTime
  362. indexLatestValue = data.Value
  363. }
  364. }
  365. var edbInfoId int64
  366. var edbCode string
  367. // 更新or新增
  368. if req.EdbCode != "" {
  369. // 查询指标库指标
  370. edbInfo, err := data_manage.GetEdbInfoByEdbCode(req.Source, req.EdbCode)
  371. if err != nil {
  372. return err
  373. }
  374. if edbInfo == nil {
  375. return fmt.Errorf("指标不存在", nil)
  376. }
  377. edbInfoId = int64(edbInfo.EdbInfoId)
  378. edbCode = edbInfo.EdbCode
  379. // 须补充更新指标最大值,最小值,数据最新时间,数据最新值
  380. edbInfo.MaxValue = indexMax
  381. edbInfo.MinValue = indexMin
  382. edbInfo.LatestDate = indexLatestDate
  383. edbInfo.LatestValue = indexLatestValue
  384. err = edbInfo.Update([]string{"min_value", "max_value", "latest_date", "latest_value"})
  385. if err != nil {
  386. return err
  387. }
  388. // 删除对应得指标数据
  389. err = residual_analysis_model.DeleteResidualAnalysisDataByEdbCode(req.EdbCode)
  390. if err != nil {
  391. return fmt.Errorf("删除指标数据失败", nil)
  392. }
  393. } else {
  394. // 新增指标
  395. edbCode, err = utils.GenerateEdbCode(1, "")
  396. if err != nil {
  397. return err
  398. }
  399. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  400. edbInfoId, err = data_manage.AddEdbInfo(&data_manage.EdbInfo{
  401. EdbCode: edbCode,
  402. UniqueCode: utils.MD5(utils.CHART_PREFIX + "_" + timestamp),
  403. EdbName: req.EdbName,
  404. EdbNameEn: req.EdbNameEn,
  405. ClassifyId: req.ClassifyId,
  406. EdbType: req.EdbType,
  407. Unit: req.Unit,
  408. UnitEn: req.UnitEn,
  409. Frequency: req.Frequency,
  410. Source: req.Source,
  411. SourceName: "残差分析",
  412. })
  413. if err != nil {
  414. return err
  415. }
  416. }
  417. // 新增数据
  418. for i := range req.DataList {
  419. req.DataList[i].EdbDataId = 0
  420. req.DataList[i].EdbInfoId = int(edbInfoId)
  421. req.DataList[i].EdbCode = edbCode
  422. }
  423. _, err = residual_analysis_model.AddResidualAnalysisData(req.DataList)
  424. if err != nil {
  425. return err
  426. }
  427. // 更新保存指标和配置的映射关系
  428. mappingList, err := residual_analysis_model.GetConfigMappingListByConfigId(req.ConfigId)
  429. if err != nil {
  430. return err
  431. }
  432. flag := true
  433. for _, mapping := range mappingList {
  434. if mapping.EdbInfoId == edbInfoId {
  435. flag = false
  436. break
  437. }
  438. }
  439. if flag {
  440. _, err = residual_analysis_model.SaveConfigMapping(residual_analysis_model.CalculateResidualAnalysisConfigMapping{
  441. CalculateResidualAnalysisConfigId: req.ConfigId,
  442. EdbInfoId: edbInfoId,
  443. ResidualType: req.ResidualType,
  444. CreateTime: time.Now(),
  445. ModifyTime: time.Now(),
  446. })
  447. if err != nil {
  448. return err
  449. }
  450. }
  451. return nil
  452. }
  453. func ResidualAnalysisDetail(edbInfoId int) (residual_analysis_model.ResidualAnalysisDetailResp, error) {
  454. // 通过指标配置映射表 拿到配置id,再获取关联的所有指标信息
  455. var condition string
  456. var pars []interface{}
  457. condition += " and edb_info_id=?"
  458. pars = append(pars, edbInfoId)
  459. mappingList, err := residual_analysis_model.GetConfigMappingListByCondition(condition, pars)
  460. if err != nil {
  461. return residual_analysis_model.ResidualAnalysisDetailResp{}, err
  462. }
  463. if len(mappingList) <= 0 {
  464. return residual_analysis_model.ResidualAnalysisDetailResp{}, fmt.Errorf("指标不存在", nil)
  465. }
  466. mapping := mappingList[0]
  467. configMappingList, err := residual_analysis_model.GetConfigMappingListByConfigId(mapping.CalculateResidualAnalysisConfigId)
  468. if err != nil {
  469. return residual_analysis_model.ResidualAnalysisDetailResp{}, err
  470. }
  471. var edbInfoIdList []int64
  472. for _, v := range configMappingList {
  473. edbInfoIdList = append(edbInfoIdList, v.EdbInfoId)
  474. }
  475. condition = ""
  476. pars = []interface{}{}
  477. condition += ` and edb_info_id in(` + utils.GetOrmInReplace(len(edbInfoIdList)) + `)`
  478. for _, id := range edbInfoIdList {
  479. pars = append(pars, id)
  480. }
  481. edbInfoList, err := data_manage.GetEdbInfoListByCond(condition, pars)
  482. if err != nil {
  483. return residual_analysis_model.ResidualAnalysisDetailResp{}, err
  484. }
  485. // 获取配置
  486. configInfo, err := residual_analysis_model.GetResidualAnalysisConfigById(mapping.CalculateResidualAnalysisConfigId)
  487. if err != nil {
  488. return residual_analysis_model.ResidualAnalysisDetailResp{}, err
  489. }
  490. resp := residual_analysis_model.ResidualAnalysisDetailResp{
  491. ConfigInfo: &configInfo,
  492. EdbInfoList: edbInfoList,
  493. }
  494. return resp, nil
  495. }
  496. func SaveResidualAnalysisConfig(req residual_analysis_model.ResidualAnalysisReq, sysUser *system.Admin) error {
  497. config := residual_analysis_model.ResidualAnalysisConfigVo{
  498. DateType: req.DateType,
  499. StartDate: req.StartDate,
  500. EndDate: req.EndDate,
  501. IsOrder: req.IsOrder,
  502. IndexType: req.IndexType,
  503. LeadValue: req.LeadValue,
  504. LeadFrequency: req.LeadFrequency,
  505. LeftIndexMin: req.LeftIndexMin,
  506. LeftIndexMax: req.LeftIndexMax,
  507. RightIndexMin: req.RightIndexMin,
  508. RightIndexMax: req.RightIndexMax,
  509. ResidualIndexMin: req.ResidualIndexMin,
  510. ResidualIndexMax: req.ResidualIndexMax,
  511. ContrastIndexMin: req.ContrastIndexMin,
  512. ContrastIndexMax: req.ContrastIndexMax,
  513. }
  514. // 转换为json格式
  515. configJson, err := json.Marshal(config)
  516. if err != nil {
  517. return err
  518. }
  519. var condition string
  520. var pars []interface{}
  521. // 新增or更新
  522. if req.EdbInfoId > 0 {
  523. condition += " and edb_info_id=?"
  524. pars = append(pars, req.EdbInfoId)
  525. configMappings, err := residual_analysis_model.GetConfigMappingListByCondition(condition, pars)
  526. if err != nil {
  527. return err
  528. }
  529. if len(configMappings) > 0 {
  530. mapping := configMappings[0]
  531. configInfo, err := residual_analysis_model.GetResidualAnalysisConfigById(mapping.CalculateResidualAnalysisConfigId)
  532. if err != nil {
  533. return err
  534. }
  535. configInfo.Config = string(configJson)
  536. err = residual_analysis_model.UpdateResidualAnalysisConfig(configInfo)
  537. if err != nil {
  538. return err
  539. }
  540. }
  541. }
  542. analysisConfig := residual_analysis_model.CalculateResidualAnalysisConfig{
  543. Config: string(configJson),
  544. SysUserId: sysUser.AdminId,
  545. CreateTime: time.Now(),
  546. ModifyTime: time.Now(),
  547. }
  548. _, err = residual_analysis_model.SaveResidualAnalysisConfig(analysisConfig)
  549. if err != nil {
  550. return err
  551. }
  552. return nil
  553. }