|
@@ -2,10 +2,11 @@ package models
|
|
|
|
|
|
import (
|
|
|
"errors"
|
|
|
+ "eta/eta_index_lib/global"
|
|
|
"eta/eta_index_lib/utils"
|
|
|
"fmt"
|
|
|
- "github.com/beego/beego/v2/client/orm"
|
|
|
"github.com/shopspring/decimal"
|
|
|
+ "gorm.io/gorm"
|
|
|
"math"
|
|
|
"strings"
|
|
|
"time"
|
|
@@ -13,15 +14,15 @@ import (
|
|
|
|
|
|
// EdbDataCalculateNhcc 拟合残差数据结构体
|
|
|
type EdbDataCalculateNhcc struct {
|
|
|
- EdbDataId int `orm:"column(edb_data_id);pk"`
|
|
|
- EdbInfoId int
|
|
|
- EdbCode string
|
|
|
- DataTime string
|
|
|
- Value float64
|
|
|
- Status int
|
|
|
- CreateTime time.Time
|
|
|
- ModifyTime time.Time
|
|
|
- DataTimestamp int64
|
|
|
+ EdbDataId int `gorm:"primaryKey;autoIncrement;column:edb_data_id"`
|
|
|
+ EdbInfoId int `gorm:"column:edb_info_id" description:"指标ID"`
|
|
|
+ EdbCode string `gorm:"column:edb_code" description:"指标编码"`
|
|
|
+ DataTime string `gorm:"column:data_time" description:"数据日期"`
|
|
|
+ Value float64 `gorm:"column:value" description:"数据值"`
|
|
|
+ Status int `gorm:"column:status" description:"状态"`
|
|
|
+ CreateTime time.Time `gorm:"column:create_time" description:"创建时间"`
|
|
|
+ ModifyTime time.Time `gorm:"column:modify_time" description:"修改时间"`
|
|
|
+ DataTimestamp int64 `gorm:"column:data_timestamp" description:"数据日期时间戳"`
|
|
|
}
|
|
|
|
|
|
// NhccDate 拟合残差的开始、结束日期
|
|
@@ -32,17 +33,12 @@ type NhccDate struct {
|
|
|
|
|
|
// AddCalculateNhcc 新增拟合残差数据
|
|
|
func AddCalculateNhcc(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdbInfo *EdbInfo, edbCode, uniqueCode string, nhccDate NhccDate, sysUserId int, sysUserRealName string) (edbInfo *EdbInfo, err error, errMsg string) {
|
|
|
- o := orm.NewOrm()
|
|
|
- to, err := o.Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ to := global.DEFAULT_DB.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
- fmt.Println("AddCalculateNhcc,Err:" + err.Error())
|
|
|
- _ = to.Rollback()
|
|
|
+ to.Rollback()
|
|
|
} else {
|
|
|
- _ = to.Commit()
|
|
|
+ to.Commit()
|
|
|
}
|
|
|
}()
|
|
|
if req.EdbInfoId <= 0 {
|
|
@@ -68,12 +64,12 @@ func AddCalculateNhcc(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
|
|
|
EdbType: 2,
|
|
|
Sort: GetAddEdbMaxSortByClassifyId(req.ClassifyId, utils.EDB_INFO_TYPE),
|
|
|
}
|
|
|
- newEdbInfoId, tmpErr := to.Insert(edbInfo)
|
|
|
+ tmpErr := to.Create(edbInfo).Error
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
return
|
|
|
}
|
|
|
- edbInfo.EdbInfoId = int(newEdbInfoId)
|
|
|
+
|
|
|
} else {
|
|
|
edbInfo, err = GetEdbInfoById(req.EdbInfoId)
|
|
|
if err != nil {
|
|
@@ -98,14 +94,14 @@ func AddCalculateNhcc(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
|
|
|
fmt.Println("dataTableName:" + dataTableName)
|
|
|
deleteSql := ` DELETE FROM %s WHERE edb_info_id=? `
|
|
|
deleteSql = fmt.Sprintf(deleteSql, dataTableName)
|
|
|
- _, err = to.Raw(deleteSql, req.EdbInfoId).Exec()
|
|
|
+ err = to.Exec(deleteSql, req.EdbInfoId).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
//删除指标关系
|
|
|
sql := ` DELETE FROM edb_info_calculate_mapping WHERE edb_info_id=? `
|
|
|
- _, err = to.Raw(sql, edbInfo.EdbInfoId).Exec()
|
|
|
+ err = to.Exec(sql, edbInfo.EdbInfoId).Error
|
|
|
}
|
|
|
|
|
|
//关联关系
|
|
@@ -131,12 +127,12 @@ func AddCalculateNhcc(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
|
|
|
ModifyTime: time.Now(),
|
|
|
FromSubSource: firstEdbInfo.SubSource,
|
|
|
}
|
|
|
- insertId, tmpErr := to.Insert(existItemA)
|
|
|
+ tmpErr := to.Create(existItemA).Error
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
return
|
|
|
}
|
|
|
- existItemA.EdbInfoCalculateMappingId = int(insertId)
|
|
|
+
|
|
|
}
|
|
|
|
|
|
//第二个指标
|
|
@@ -159,12 +155,12 @@ func AddCalculateNhcc(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
|
|
|
ModifyTime: time.Now(),
|
|
|
FromSubSource: secondEdbInfo.SubSource,
|
|
|
}
|
|
|
- insertId, tmpErr := to.Insert(existItemB)
|
|
|
+ tmpErr := to.Create(existItemB).Error
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
return
|
|
|
}
|
|
|
- existItemB.EdbInfoCalculateMappingId = int(insertId)
|
|
|
+
|
|
|
}
|
|
|
|
|
|
//拼接数据
|
|
@@ -175,17 +171,12 @@ func AddCalculateNhcc(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
|
|
|
|
|
|
// EditCalculateNhcc 编辑拟合残差数据
|
|
|
func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo, secondEdbInfo *EdbInfo, nhccDate NhccDate) (err error, errMsg string) {
|
|
|
- o := orm.NewOrm()
|
|
|
- to, err := o.Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ to := global.DEFAULT_DB.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
- fmt.Println("EditCalculateNhcc,Err:" + err.Error())
|
|
|
- _ = to.Rollback()
|
|
|
+ to.Rollback()
|
|
|
} else {
|
|
|
- _ = to.Commit()
|
|
|
+ to.Commit()
|
|
|
}
|
|
|
}()
|
|
|
|
|
@@ -201,7 +192,7 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
|
|
|
edbInfo.EdbNameEn = req.EdbNameEn
|
|
|
edbInfo.UnitEn = req.UnitEn
|
|
|
edbInfo.ModifyTime = time.Now()
|
|
|
- _, err = to.Update(edbInfo, "EdbName", "EdbNameSource", "Frequency", "Unit", "ClassifyId", "CalculateFormula", "ModifyTime", "EdbNameEn", "UnitEn")
|
|
|
+ err = to.Model(edbInfo).Select([]string{"EdbName", "EdbNameSource", "Frequency", "Unit", "ClassifyId", "CalculateFormula", "ModifyTime", "EdbNameEn", "UnitEn"}).Updates(edbInfo).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -240,7 +231,7 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
|
|
|
if existItemA.FromEdbInfoId != firstEdbInfo.EdbInfoId {
|
|
|
//删除之前的A指标关联关系
|
|
|
sql := ` DELETE FROM edb_info_calculate_mapping WHERE edb_info_id = ? and from_edb_info_id = ?`
|
|
|
- _, err = to.Raw(sql, edbInfo.EdbInfoId, existItemA.FromEdbInfoId).Exec()
|
|
|
+ err = to.Exec(sql, edbInfo.EdbInfoId, existItemA.FromEdbInfoId).Error
|
|
|
if err != nil {
|
|
|
err = fmt.Errorf("删除指标A关联关系失败,Err:" + err.Error())
|
|
|
return
|
|
@@ -251,7 +242,7 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
|
|
|
if existItemB.FromEdbInfoId != secondEdbInfo.EdbInfoId {
|
|
|
//删除之前的B指标关联关系
|
|
|
sql := ` DELETE FROM edb_info_calculate_mapping WHERE edb_info_id = ? and from_edb_info_id = ?`
|
|
|
- _, err = to.Raw(sql, edbInfo.EdbInfoId, existItemB.FromEdbInfoId).Exec()
|
|
|
+ err = to.Exec(sql, edbInfo.EdbInfoId, existItemB.FromEdbInfoId).Error
|
|
|
if err != nil {
|
|
|
err = fmt.Errorf("删除指标B关联关系失败,Err:" + err.Error())
|
|
|
return
|
|
@@ -283,12 +274,11 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
|
|
|
ModifyTime: time.Now(),
|
|
|
FromSubSource: firstEdbInfo.SubSource,
|
|
|
}
|
|
|
- insertId, tmpErr := to.Insert(existItemA)
|
|
|
+ tmpErr := to.Create(existItemA).Error
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
return
|
|
|
}
|
|
|
- existItemA.EdbInfoCalculateMappingId = int(insertId)
|
|
|
|
|
|
isNeedCalculateData = true
|
|
|
}
|
|
@@ -296,7 +286,7 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
|
|
|
// 如果平移天数不一致的话,
|
|
|
existItemA.ModifyTime = time.Now()
|
|
|
existItemA.MoveValue = req.EdbInfoIdArr[0].MoveValue
|
|
|
- _, err = to.Update(existItemA, "ModifyTime", "MoveValue")
|
|
|
+ err = to.Model(existItemA).Select([]string{"ModifyTime", "MoveValue"}).Updates(existItemA).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -327,19 +317,18 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
|
|
|
ModifyTime: time.Now(),
|
|
|
FromSubSource: secondEdbInfo.SubSource,
|
|
|
}
|
|
|
- insertId, tmpErr := to.Insert(existItemB)
|
|
|
+ tmpErr := to.Create(existItemB).Error
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
return
|
|
|
}
|
|
|
- existItemB.EdbInfoCalculateMappingId = int(insertId)
|
|
|
|
|
|
isNeedCalculateData = true
|
|
|
} else if existItemB.MoveValue != req.EdbInfoIdArr[1].MoveValue {
|
|
|
// 如果平移天数不一致的话,
|
|
|
existItemB.ModifyTime = time.Now()
|
|
|
existItemB.MoveValue = req.EdbInfoIdArr[1].MoveValue
|
|
|
- _, err = to.Update(existItemB, "ModifyTime", "MoveValue")
|
|
|
+ err = to.Model(existItemB).Select([]string{"ModifyTime", "MoveValue"}).Updates(existItemB).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -353,7 +342,7 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
|
|
|
|
|
|
tableName := GetEdbDataTableName(edbInfo.Source, edbInfo.SubSource)
|
|
|
sql := fmt.Sprintf(` DELETE FROM %s WHERE edb_info_id = ? `, tableName)
|
|
|
- _, err = to.Raw(sql, edbInfo.EdbInfoId).Exec()
|
|
|
+ err = to.Exec(sql, edbInfo.EdbInfoId).Error
|
|
|
if err != nil {
|
|
|
err = fmt.Errorf("删除历史数据失败,Err:" + err.Error())
|
|
|
return
|
|
@@ -367,14 +356,12 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
|
|
|
|
|
|
// RefreshAllCalculateNhcc 刷新所有 拟合残差 数据
|
|
|
func RefreshAllCalculateNhcc(edbInfo *EdbInfo) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- to, err := o.Begin()
|
|
|
+ to := global.DEFAULT_DB.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
- fmt.Println("RefreshAllCalculateNhcc,Err:" + err.Error())
|
|
|
- _ = to.Rollback()
|
|
|
+ to.Rollback()
|
|
|
} else {
|
|
|
- _ = to.Commit()
|
|
|
+ to.Commit()
|
|
|
}
|
|
|
}()
|
|
|
//查询关联指标信息
|
|
@@ -420,23 +407,25 @@ func RefreshAllCalculateNhcc(edbInfo *EdbInfo) (err error) {
|
|
|
}
|
|
|
|
|
|
// refreshAllCalculateNhcc 刷新所有 拟合残差 数据
|
|
|
-func refreshAllCalculateNhcc(to orm.TxOrmer, edbInfo *EdbInfo, existItemA, existItemB *EdbInfoCalculateMapping, nhccDate NhccDate) (err error, errMsg string) {
|
|
|
+func refreshAllCalculateNhcc(to *gorm.DB, edbInfo *EdbInfo, existItemA, existItemB *EdbInfoCalculateMapping, nhccDate NhccDate) (err error, errMsg string) {
|
|
|
//查询当前指标现有的数据
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
|
condition += " AND edb_info_id=? "
|
|
|
pars = append(pars, edbInfo.EdbInfoId)
|
|
|
|
|
|
- var dataList []*EdbDataCalculateNhcc
|
|
|
- sql := ` SELECT * FROM edb_data_calculate_nhcc WHERE edb_info_id=? ORDER BY data_time DESC `
|
|
|
- _, err = to.Raw(sql, edbInfo.EdbInfoId).QueryRows(&dataList)
|
|
|
+ //获取年化指标所有数据
|
|
|
+ existDataList, err := GetAllEdbDataListByTo(to, edbInfo.EdbInfoId, edbInfo.Source, edbInfo.SubSource)
|
|
|
+ //var dataList []*EdbDataCalculateNhcc
|
|
|
+ //sql := ` SELECT * FROM edb_data_calculate_nhcc WHERE edb_info_id=? ORDER BY data_time DESC `
|
|
|
+ //err = to.Raw(sql, edbInfo.EdbInfoId).Scan(&dataList).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
var dateArr []string
|
|
|
- dataMap := make(map[string]*EdbDataCalculateNhcc)
|
|
|
+ dataMap := make(map[string]*EdbData)
|
|
|
removeDataTimeMap := make(map[string]int) //需要移除的日期数据
|
|
|
- for _, v := range dataList {
|
|
|
+ for _, v := range existDataList {
|
|
|
dateArr = append(dateArr, v.DataTime)
|
|
|
dataMap[v.DataTime] = v
|
|
|
removeDataTimeMap[v.DataTime] = 1
|
|
@@ -444,76 +433,6 @@ func refreshAllCalculateNhcc(to orm.TxOrmer, edbInfo *EdbInfo, existItemA, exist
|
|
|
|
|
|
addDataList := make([]*EdbDataCalculateNhcc, 0)
|
|
|
|
|
|
- ////第一个指标
|
|
|
- //aDataList := make([]EdbInfoSearchData, 0)
|
|
|
- //aDataMap := make(map[string]float64)
|
|
|
- //{
|
|
|
- // var condition string
|
|
|
- // var pars []interface{}
|
|
|
- //
|
|
|
- // condition += " AND edb_info_id=? "
|
|
|
- // pars = append(pars, existItemA.FromEdbInfoId)
|
|
|
- //
|
|
|
- // //第一个指标的数据列表
|
|
|
- // firstDataList, tmpErr := GetEdbDataListAllByTo(to, condition, pars, existItemA.FromSource, 0)
|
|
|
- // if tmpErr != nil {
|
|
|
- // return tmpErr
|
|
|
- // }
|
|
|
- // aDataList, aDataMap = handleNhccData(firstDataList, existItemA.MoveValue)
|
|
|
- //
|
|
|
- //}
|
|
|
- //
|
|
|
- ////第二个指标
|
|
|
- //bDataList := make([]EdbInfoSearchData, 0)
|
|
|
- //secondDataList := make([]*EdbInfoSearchData, 0)
|
|
|
- //bDataMap := make(map[string]float64)
|
|
|
- //{
|
|
|
- // condition = ``
|
|
|
- // pars = make([]interface{}, 0)
|
|
|
- //
|
|
|
- // condition += " AND edb_info_id = ? "
|
|
|
- // pars = append(pars, existItemB.FromEdbInfoId)
|
|
|
- //
|
|
|
- // //第二个指标的数据列表
|
|
|
- // secondDataList, err = GetEdbDataListAllByTo(to, condition, pars, existItemB.FromSource, 0)
|
|
|
- // if err != nil {
|
|
|
- // return
|
|
|
- // }
|
|
|
- // bDataList, bDataMap = handleNhccData(secondDataList, existItemB.MoveValue)
|
|
|
- //}
|
|
|
- //
|
|
|
- //if len(aDataList) <= 0 {
|
|
|
- // err = errors.New("指标A没有数据")
|
|
|
- // return
|
|
|
- //}
|
|
|
- //if len(bDataList) <= 0 {
|
|
|
- // err = errors.New("指标B没有数据")
|
|
|
- // return
|
|
|
- //}
|
|
|
- //// 拟合残差计算的结束日期判断
|
|
|
- //{
|
|
|
- // endAData := aDataList[len(aDataList)-1]
|
|
|
- // tmpEndDate, tmpErr := time.ParseInLocation(utils.FormatDate, endAData.DataTime, time.Local)
|
|
|
- // if tmpErr != nil {
|
|
|
- // err = tmpErr
|
|
|
- // return
|
|
|
- // }
|
|
|
- // // 如果A指标的最新数据日期早于拟合残差的结束日期,那么就用A指标的最新数据日期
|
|
|
- // if tmpEndDate.Before(nhccDate.EndDate) {
|
|
|
- // nhccDate.EndDate = tmpEndDate
|
|
|
- // }
|
|
|
- // endBData := bDataList[len(bDataList)-1]
|
|
|
- // tmpEndDate, tmpErr = time.ParseInLocation(utils.FormatDate, endBData.DataTime, time.Local)
|
|
|
- // if tmpErr != nil {
|
|
|
- // err = tmpErr
|
|
|
- // return
|
|
|
- // }
|
|
|
- // // 如果B指标的最新数据日期早于拟合残差的结束日期,那么就用A指标的最新数据日期
|
|
|
- // if tmpEndDate.Before(nhccDate.EndDate) {
|
|
|
- // nhccDate.EndDate = tmpEndDate
|
|
|
- // }
|
|
|
- //}
|
|
|
-
|
|
|
aDataList, secondDataList, aDataMap, bDataMap, nhccDate, err, errMsg := getNhccData(to, existItemA, existItemB, nhccDate)
|
|
|
if err != nil {
|
|
|
return
|
|
@@ -583,7 +502,8 @@ func refreshAllCalculateNhcc(to orm.TxOrmer, edbInfo *EdbInfo, existItemA, exist
|
|
|
bDecimal := decimal.NewFromFloat(bData.Value)
|
|
|
b2Decimal := decimal.NewFromFloat(b2Val)
|
|
|
|
|
|
- val, _ := bDecimal.Sub(b2Decimal).Round(4).Float64()
|
|
|
+ valDeci := bDecimal.Sub(b2Decimal)
|
|
|
+ val, _ := valDeci.Round(4).Float64()
|
|
|
|
|
|
// 判断之前有没有该数据
|
|
|
existData, ok := dataMap[currDate]
|
|
@@ -603,9 +523,15 @@ func refreshAllCalculateNhcc(to orm.TxOrmer, edbInfo *EdbInfo, existItemA, exist
|
|
|
addDataList = append(addDataList, edbDataNhcc)
|
|
|
} else {
|
|
|
// 如果有的话,还需要判断值是否一致,一致则不处理,不一致则修改
|
|
|
- if existData.Value != val {
|
|
|
- existData.Value = val
|
|
|
- _, err = to.Update(existData, "Value")
|
|
|
+
|
|
|
+ tmpExistVal, tmpErr := decimal.NewFromString(existData.Value)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if !tmpExistVal.Equal(valDeci) {
|
|
|
+ err = ModifyEdbDataById(edbInfo.Source, edbInfo.SubSource, existData.EdbDataId, valDeci.String())
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -624,7 +550,7 @@ func refreshAllCalculateNhcc(to orm.TxOrmer, edbInfo *EdbInfo, existItemA, exist
|
|
|
//如果拼接指标变更了,那么需要删除所有的指标数据
|
|
|
tableName := GetEdbDataTableName(edbInfo.Source, edbInfo.SubSource)
|
|
|
sql := fmt.Sprintf(` DELETE FROM %s WHERE edb_info_id = ? and data_time in (`+utils.GetOrmInReplace(removeNum)+`) `, tableName)
|
|
|
- _, err = to.Raw(sql, edbInfo.EdbInfoId, removeDateList).Exec()
|
|
|
+ err = to.Exec(sql, edbInfo.EdbInfoId, removeDateList).Error
|
|
|
if err != nil {
|
|
|
err = fmt.Errorf("删除不存在的拟合残差指标数据失败,Err:" + err.Error())
|
|
|
return
|
|
@@ -640,7 +566,7 @@ func refreshAllCalculateNhcc(to orm.TxOrmer, edbInfo *EdbInfo, existItemA, exist
|
|
|
tmpAddDataList = append(tmpAddDataList, v)
|
|
|
i++
|
|
|
if i >= 500 {
|
|
|
- _, err = to.InsertMulti(len(tmpAddDataList), tmpAddDataList)
|
|
|
+ err = to.CreateInBatches(tmpAddDataList, 500).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -650,7 +576,7 @@ func refreshAllCalculateNhcc(to orm.TxOrmer, edbInfo *EdbInfo, existItemA, exist
|
|
|
}
|
|
|
|
|
|
if len(tmpAddDataList) > 0 {
|
|
|
- _, err = to.InsertMulti(len(tmpAddDataList), tmpAddDataList)
|
|
|
+ err = to.CreateInBatches(tmpAddDataList, 500).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -698,14 +624,12 @@ func CalculateComputeCorrelation(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- o := orm.NewOrm()
|
|
|
- to, err := o.Begin()
|
|
|
+ to := global.DEFAULT_DB.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
- fmt.Println("RefreshAllCalculateNhcc,Err:" + err.Error())
|
|
|
- _ = to.Rollback()
|
|
|
+ to.Rollback()
|
|
|
} else {
|
|
|
- _ = to.Commit()
|
|
|
+ to.Commit()
|
|
|
}
|
|
|
}()
|
|
|
// 获取相关数据
|
|
@@ -746,7 +670,7 @@ func CalculateComputeCorrelation(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo
|
|
|
}
|
|
|
|
|
|
// getNhccData 获取拟合残差需要的数据
|
|
|
-func getNhccData(to orm.TxOrmer, existItemA, existItemB *EdbInfoCalculateMapping, nhccDate NhccDate) (aDataList []EdbInfoSearchData, secondDataList []*EdbInfoSearchData, aDataMap, bDataMap map[string]float64, newNhccDate NhccDate, err error, errMsg string) {
|
|
|
+func getNhccData(to *gorm.DB, existItemA, existItemB *EdbInfoCalculateMapping, nhccDate NhccDate) (aDataList []EdbInfoSearchData, secondDataList []*EdbInfoSearchData, aDataMap, bDataMap map[string]float64, newNhccDate NhccDate, err error, errMsg string) {
|
|
|
newNhccDate = nhccDate
|
|
|
//第一个指标
|
|
|
aDataList = make([]EdbInfoSearchData, 0)
|