edb_data_calculate_zsxy.go 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381
  1. package models
  2. import (
  3. "errors"
  4. "eta/eta_index_lib/utils"
  5. "fmt"
  6. "github.com/beego/beego/v2/client/orm"
  7. "github.com/shopspring/decimal"
  8. "reflect"
  9. "strconv"
  10. "strings"
  11. "time"
  12. )
  13. // ExponentialSmoothing 指数修匀
  14. type ExponentialSmoothing struct{}
  15. // Add 添加
  16. func (obj ExponentialSmoothing) Add(params AddCalculateBatchParams) (edbInfo *EdbInfo, err error, errMsg string) {
  17. req := params.Req
  18. fromEdbInfo := params.FromEdbInfo
  19. edbCode := params.EdbCode
  20. o := orm.NewOrm()
  21. to, err := o.Begin()
  22. if err != nil {
  23. return
  24. }
  25. defer func() {
  26. if err != nil {
  27. _ = to.Rollback()
  28. fmt.Println(reflect.TypeOf(obj).Name(), ";Add,Err:"+err.Error())
  29. } else {
  30. _ = to.Commit()
  31. }
  32. }()
  33. edbInfo = new(EdbInfo)
  34. edbInfo.Source = obj.GetSource()
  35. edbInfo.SourceName = obj.GetSourceName()
  36. edbInfo.EdbCode = edbCode
  37. edbInfo.EdbName = req.EdbName
  38. edbInfo.EdbNameSource = req.EdbName
  39. edbInfo.Frequency = req.Frequency
  40. edbInfo.Unit = req.Unit
  41. edbInfo.ClassifyId = req.ClassifyId
  42. edbInfo.SysUserId = params.SysUserId
  43. edbInfo.SysUserRealName = params.SysUserRealName
  44. edbInfo.CreateTime = time.Now()
  45. edbInfo.ModifyTime = time.Now()
  46. edbInfo.UniqueCode = params.UniqueCode
  47. edbInfo.CalculateFormula = req.Formula
  48. edbInfo.EdbType = 2
  49. newEdbInfoId, tmpErr := to.Insert(edbInfo)
  50. if tmpErr != nil {
  51. err = tmpErr
  52. return
  53. }
  54. edbInfo.EdbInfoId = int(newEdbInfoId)
  55. //关联关系
  56. {
  57. calculateMappingItem := new(EdbInfoCalculateMapping)
  58. calculateMappingItem.CreateTime = time.Now()
  59. calculateMappingItem.ModifyTime = time.Now()
  60. calculateMappingItem.Sort = 1
  61. calculateMappingItem.EdbCode = edbCode
  62. calculateMappingItem.EdbInfoId = edbInfo.EdbInfoId
  63. calculateMappingItem.FromEdbInfoId = fromEdbInfo.EdbInfoId
  64. calculateMappingItem.FromEdbCode = fromEdbInfo.EdbCode
  65. calculateMappingItem.FromEdbName = fromEdbInfo.EdbName
  66. calculateMappingItem.FromSource = fromEdbInfo.Source
  67. calculateMappingItem.FromSourceName = fromEdbInfo.SourceName
  68. calculateMappingItem.FromTag = ""
  69. calculateMappingItem.Source = edbInfo.Source
  70. calculateMappingItem.SourceName = edbInfo.SourceName
  71. _, err = to.Insert(calculateMappingItem)
  72. if err != nil {
  73. return
  74. }
  75. }
  76. //计算数据
  77. err = obj.refresh(to, edbInfo, fromEdbInfo, edbInfo.EdbCode)
  78. return
  79. }
  80. // Edit 编辑
  81. func (obj ExponentialSmoothing) Edit(params EditCalculateBatchParams) (err error, errMsg string) {
  82. req := params.Req
  83. edbInfo := params.EdbInfo
  84. fromEdbInfo := params.FromEdbInfo
  85. o := orm.NewOrm()
  86. to, err := o.Begin()
  87. if err != nil {
  88. return
  89. }
  90. defer func() {
  91. if err != nil {
  92. _ = to.Rollback()
  93. fmt.Println(reflect.TypeOf(obj).Name(), ";Edit,Err:"+err.Error())
  94. } else {
  95. _ = to.Commit()
  96. }
  97. }()
  98. tableName := GetEdbDataTableName(edbInfo.Source)
  99. oldEdbInfo := *edbInfo
  100. //修改指标信息
  101. edbInfo.EdbName = req.EdbName
  102. edbInfo.EdbNameSource = req.EdbName
  103. edbInfo.Frequency = req.Frequency
  104. edbInfo.Unit = req.Unit
  105. edbInfo.ClassifyId = req.ClassifyId
  106. edbInfo.CalculateFormula = req.Formula
  107. edbInfo.ModifyTime = time.Now()
  108. _, err = to.Update(edbInfo, "EdbName", "EdbNameSource", "Frequency", "Unit", "ClassifyId", "CalculateFormula", "ModifyTime")
  109. if err != nil {
  110. return
  111. }
  112. var existCondition string
  113. var existPars []interface{}
  114. existCondition += " AND edb_info_id=? AND from_edb_info_id=? "
  115. existPars = append(existPars, edbInfo.EdbInfoId, req.FromEdbInfoId)
  116. //判断计算指标是否被更换
  117. count, err := GetEdbInfoCalculateCountByCondition(existCondition, existPars)
  118. if err != nil {
  119. err = errors.New("判断指标是否改变失败,Err:" + err.Error())
  120. return
  121. }
  122. if count > 0 { // 指标未被替换,无需处理逻辑
  123. // 如果相关配置更改了,那么重新计算
  124. if oldEdbInfo.CalculateFormula != edbInfo.CalculateFormula {
  125. err = obj.refresh(to, edbInfo, fromEdbInfo, edbInfo.EdbCode)
  126. }
  127. return
  128. }
  129. //删除,计算指标关联的,基础指标的关联关系
  130. sql := ` DELETE FROM edb_info_calculate_mapping WHERE edb_info_id = ? `
  131. _, err = to.Raw(sql, edbInfo.EdbInfoId).Exec()
  132. if err != nil {
  133. return
  134. }
  135. //清空原有数据
  136. sql = ` DELETE FROM ` + tableName + ` WHERE edb_info_id = ? `
  137. _, err = to.Raw(sql, edbInfo.EdbInfoId).Exec()
  138. if err != nil {
  139. return
  140. }
  141. //关联关系
  142. {
  143. calculateMappingItem := &EdbInfoCalculateMapping{
  144. EdbInfoCalculateMappingId: 0,
  145. EdbInfoId: edbInfo.EdbInfoId,
  146. Source: obj.GetSource(),
  147. SourceName: obj.GetSourceName(),
  148. EdbCode: edbInfo.EdbCode,
  149. FromEdbInfoId: fromEdbInfo.EdbInfoId,
  150. FromEdbCode: fromEdbInfo.EdbCode,
  151. FromEdbName: fromEdbInfo.EdbName,
  152. FromSource: fromEdbInfo.Source,
  153. FromSourceName: fromEdbInfo.SourceName,
  154. FromTag: "",
  155. Sort: 1,
  156. CreateTime: time.Now(),
  157. ModifyTime: time.Now(),
  158. }
  159. _, err = to.Insert(calculateMappingItem)
  160. if err != nil {
  161. return
  162. }
  163. }
  164. //计算数据
  165. err = obj.refresh(to, edbInfo, fromEdbInfo, edbInfo.EdbCode)
  166. return
  167. }
  168. // Refresh 刷新
  169. func (obj ExponentialSmoothing) Refresh(params RefreshParams) (err error, errMsg string) {
  170. calculateMapping, err := GetEdbInfoCalculateMappingDetail(params.EdbInfo.EdbInfoId)
  171. if err != nil {
  172. errMsg = "GetEdbInfoCalculateLjzzyDetail Err:" + err.Error()
  173. return
  174. }
  175. fromEdbInfo, err := GetEdbInfoById(calculateMapping.FromEdbInfoId)
  176. if err != nil {
  177. errMsg = "GetEdbInfoById Err:" + err.Error()
  178. return
  179. }
  180. o := orm.NewOrm()
  181. to, err := o.Begin()
  182. if err != nil {
  183. return
  184. }
  185. defer func() {
  186. if err != nil {
  187. _ = to.Rollback()
  188. fmt.Println(reflect.TypeOf(obj).Name(), ";Refresh,Err:"+err.Error())
  189. } else {
  190. _ = to.Commit()
  191. }
  192. }()
  193. // 计算数据
  194. err = obj.refresh(to, params.EdbInfo, fromEdbInfo, params.EdbInfo.EdbCode)
  195. return
  196. }
  197. // GetSource 获取来源编码id
  198. func (obj ExponentialSmoothing) GetSource() int {
  199. return utils.DATA_SOURCE_CALCULATE_ZSXY
  200. }
  201. // GetSourceName 获取来源名称
  202. func (obj ExponentialSmoothing) GetSourceName() string {
  203. return utils.DATA_SOURCE_NAME_CALCULATE_ZSXY
  204. }
  205. func (obj ExponentialSmoothing) refresh(to orm.TxOrmer, edbInfo, fromEdbInfo *EdbInfo, edbCode string) (err error) {
  206. edbInfoId := edbInfo.EdbInfoId
  207. dataTableName := GetEdbDataTableName(edbInfo.Source)
  208. edbInfoIdStr := strconv.Itoa(edbInfoId)
  209. // 获取标准差图表的指标数据
  210. fromDataList, err := CalculateExponentialSmoothingData(fromEdbInfo, edbInfo.CalculateFormula)
  211. if err != nil {
  212. return err
  213. }
  214. //获取指标所有数据
  215. existDataList := make([]*EdbData, 0)
  216. sql := `SELECT * FROM %s WHERE edb_info_id=? `
  217. sql = fmt.Sprintf(sql, dataTableName)
  218. _, err = to.Raw(sql, edbInfoId).QueryRows(&existDataList)
  219. if err != nil {
  220. return err
  221. }
  222. existDataMap := make(map[string]string)
  223. removeDataTimeMap := make(map[string]int) //需要移除的日期数据
  224. for _, v := range existDataList {
  225. existDataMap[v.DataTime] = v.Value
  226. removeDataTimeMap[v.DataTime] = 1
  227. }
  228. needAddDateMap := make(map[time.Time]int)
  229. addSql := ` INSERT INTO ` + dataTableName + `(edb_info_id,edb_code,data_time,value,create_time,modify_time,data_timestamp) values `
  230. var isAdd bool
  231. for _, tmpData := range fromDataList {
  232. currDateStr := tmpData.DataTime
  233. currTime, tmpErr := time.ParseInLocation(utils.FormatDate, currDateStr, time.Local)
  234. if tmpErr != nil {
  235. err = tmpErr
  236. return
  237. }
  238. // 当前的实际值
  239. saveValue := decimal.NewFromFloat(tmpData.Value).Round(4).String()
  240. existVal, ok := existDataMap[currDateStr]
  241. // 如果库中已经存在该数据的话,那么就进行值的变更操作
  242. if ok {
  243. //校验待删除日期数据里面是否存在该元素,如果存在的话,那么移除该日期
  244. delete(removeDataTimeMap, currDateStr)
  245. if existVal != saveValue {
  246. sql := ` UPDATE %s SET value=?,modify_time=NOW() WHERE edb_info_id=? AND data_time=? `
  247. sql = fmt.Sprintf(sql, dataTableName)
  248. _, err = to.Raw(sql, saveValue, edbInfoId, currDateStr).Exec()
  249. if err != nil {
  250. return
  251. }
  252. }
  253. continue
  254. }
  255. // 库中不存在该日期的数据
  256. timestamp := currTime.UnixNano() / 1e6
  257. timeStr := fmt.Sprintf("%d", timestamp)
  258. if _, existOk := needAddDateMap[currTime]; !existOk {
  259. addSql += GetAddSql(edbInfoIdStr, edbCode, currDateStr, timeStr, saveValue)
  260. isAdd = true
  261. }
  262. needAddDateMap[currTime] = 1
  263. }
  264. //删除已经不存在的指标数据(由于该指标当日的数据删除了)
  265. {
  266. removeDateList := make([]string, 0)
  267. for dateTime := range removeDataTimeMap {
  268. removeDateList = append(removeDateList, dateTime)
  269. }
  270. removeNum := len(removeDateList)
  271. if removeNum > 0 {
  272. sql := fmt.Sprintf(` DELETE FROM %s WHERE edb_info_id = ? and data_time in (`+utils.GetOrmInReplace(removeNum)+`) `, dataTableName)
  273. _, err = to.Raw(sql, edbInfo.EdbInfoId, removeDateList).Exec()
  274. if err != nil {
  275. fmt.Println(reflect.TypeOf(obj).Name(), " add data ;delete Err", err.Error())
  276. err = fmt.Errorf("删除不存在的指标数据失败,Err:" + err.Error())
  277. return
  278. }
  279. }
  280. }
  281. if isAdd {
  282. addSql = strings.TrimRight(addSql, ",")
  283. _, err = to.Raw(addSql).Exec()
  284. if err != nil {
  285. fmt.Println(reflect.TypeOf(obj).Name(), " add data Err", err.Error())
  286. return
  287. }
  288. }
  289. return
  290. }
  291. // CalculateExponentialSmoothingData 计算指数修匀
  292. func CalculateExponentialSmoothingData(fromEdbInfo *EdbInfo, strAlpha string) (newDataList []EdbInfoSearchData, err error) {
  293. alpha, _ := strconv.ParseFloat(strAlpha, 64)
  294. if alpha <= 0 || alpha >= 1 {
  295. err = fmt.Errorf("alpha值有误: %v", alpha)
  296. return
  297. }
  298. // 获取时间基准指标在时间区间内的值
  299. dataList := make([]*EdbInfoSearchData, 0)
  300. switch fromEdbInfo.EdbInfoType {
  301. case 0:
  302. var condition string
  303. var pars []interface{}
  304. condition += " AND edb_info_id=? "
  305. pars = append(pars, fromEdbInfo.EdbInfoId)
  306. //获取来源指标的数据
  307. dataList, err = GetEdbDataListAll(condition, pars, fromEdbInfo.Source, 1)
  308. case 1:
  309. dataList, err = GetPredictEdbDataListAllByStartDate(fromEdbInfo, 1, "")
  310. default:
  311. err = errors.New(fmt.Sprint("获取失败,指标base类型异常", fromEdbInfo.EdbInfoType))
  312. return
  313. }
  314. var preVal float64
  315. alphaDecimal := decimal.NewFromFloat(alpha)
  316. subAlpha := decimal.NewFromFloat(1).Sub(alphaDecimal)
  317. for k, d := range dataList {
  318. // 首期的值以原始值作为指数修匀的计算值
  319. if k == 0 {
  320. newDataList = append(newDataList, EdbInfoSearchData{
  321. EdbDataId: k,
  322. DataTime: dataList[k].DataTime,
  323. Value: d.Value,
  324. })
  325. preVal = d.Value
  326. continue
  327. }
  328. // 上一期的值参与计算
  329. preDecimal := decimal.NewFromFloat(preVal)
  330. valDecimal := decimal.NewFromFloat(d.Value)
  331. partA := alphaDecimal.Mul(valDecimal)
  332. partB := subAlpha.Mul(preDecimal)
  333. res, _ := (partA.Add(partB)).Float64()
  334. preVal = res
  335. newDataList = append(newDataList, EdbInfoSearchData{
  336. EdbDataId: k,
  337. DataTime: dataList[k].DataTime,
  338. Value: res,
  339. })
  340. }
  341. return
  342. }