|
@@ -274,22 +274,17 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
|
//source := bv.Source
|
|
|
//edbInfoId := bv.EdbInfoId
|
|
|
//edbCode := bv.EdbCode
|
|
|
- if bv.StartDate == "0000-00-00" {
|
|
|
+ fmt.Println(bv.StartDate)
|
|
|
+ if utils.TimeToFormatDate(bv.StartDate) == "0000-00-00" {
|
|
|
continue
|
|
|
}
|
|
|
//开始时间
|
|
|
startDate = ``
|
|
|
if refreshAll { //刷新所有数据,用开始时间作为起始日期去刷新
|
|
|
- sTime, err := time.Parse(utils.FormatDate, bv.StartDate)
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
+ sTime := bv.StartDate
|
|
|
startDate = sTime.Format(utils.FormatDate)
|
|
|
} else {
|
|
|
- sTime, err := time.Parse(utils.FormatDate, bv.EndDate)
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
+ sTime := bv.EndDate
|
|
|
frequency := bv.Frequency
|
|
|
var limitDay int
|
|
|
switch frequency {
|
|
@@ -346,16 +341,13 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
|
//计算指标就不用开始时间了吧,因为存在说开始时间变更的情况
|
|
|
startDate = ``
|
|
|
if !refreshAll { //如果不是全部更新,那么以指标的开始时间作为刷新
|
|
|
- startDate = edbInfo.StartDate
|
|
|
+ startDate = utils.TimeToFormatDate(edbInfo.StartDate)
|
|
|
source := edbInfo.Source
|
|
|
if startDate == "" || startDate == "0000-00-00" { //如果没有开始日期,说明还没有计算出来数据,那么就往前面推40年吧(也意味着重新计算了)
|
|
|
startDate = time.Now().AddDate(-40, 0, 0).Format(utils.FormatDate)
|
|
|
} else {
|
|
|
if source == utils.DATA_SOURCE_CALCULATE {
|
|
|
- sTime, err := time.Parse(utils.FormatDate, edbInfo.EndDate)
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
+ sTime := edbInfo.EndDate
|
|
|
frequency := edbInfo.Frequency
|
|
|
var limitDay int
|
|
|
switch frequency {
|
|
@@ -396,7 +388,7 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
|
if edbInfo == nil {
|
|
|
return err
|
|
|
}
|
|
|
- startDate = edbInfo.StartDate
|
|
|
+ startDate = utils.TimeToFormatDate(edbInfo.StartDate)
|
|
|
source := edbInfo.Source
|
|
|
if startDate == "" || startDate == "0000-00-00" { //如果没有开始日期,说明还没有计算出来数据,那么就往前面推40年吧(也意味着重新计算了)
|
|
|
startDate = time.Now().AddDate(-40, 0, 0).Format(utils.FormatDate)
|
|
@@ -404,12 +396,9 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
|
if source == utils.DATA_SOURCE_PREDICT_CALCULATE {
|
|
|
startDate = ``
|
|
|
if refreshAll { //刷新所有数据,用开始时间作为起始日期去刷新
|
|
|
- startDate = edbInfo.StartDate
|
|
|
+ startDate = utils.TimeToFormatDate(edbInfo.StartDate)
|
|
|
} else {
|
|
|
- sTime, err := time.Parse(utils.FormatDate, edbInfo.EndDate)
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
+ sTime := edbInfo.EndDate
|
|
|
frequency := edbInfo.Frequency
|
|
|
var limitDay int
|
|
|
switch frequency {
|
|
@@ -478,7 +467,7 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
|
if edbInfo == nil {
|
|
|
return err
|
|
|
}
|
|
|
- startDate = edbInfo.StartDate
|
|
|
+ startDate = utils.TimeToFormatDate(edbInfo.StartDate)
|
|
|
source := edbInfo.Source
|
|
|
if startDate == "" || startDate == "0000-00-00" { //如果没有开始日期,说明还没有计算出来数据,那么就往前面推40年吧(也意味着重新计算了)
|
|
|
startDate = time.Now().AddDate(-40, 0, 0).Format(utils.FormatDate)
|
|
@@ -486,12 +475,9 @@ func edbInfoRefreshAll(refreshAll bool, newBaseEdbInfoArr, newBasePredictEdbInfo
|
|
|
if source == utils.DATA_SOURCE_PREDICT_CALCULATE {
|
|
|
startDate = ``
|
|
|
if refreshAll { //刷新所有数据,用开始时间作为起始日期去刷新
|
|
|
- startDate = edbInfo.StartDate
|
|
|
+ startDate = utils.TimeToFormatDate(edbInfo.StartDate)
|
|
|
} else {
|
|
|
- sTime, err := time.Parse(utils.FormatDate, edbInfo.EndDate)
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
+ sTime := edbInfo.EndDate
|
|
|
frequency := edbInfo.Frequency
|
|
|
var limitDay int
|
|
|
switch frequency {
|
|
@@ -1875,8 +1861,23 @@ func EdbInfoAdd(source, subSource, classifyId int, edbCode, edbName, frequency,
|
|
|
edbInfo.Frequency = frequency
|
|
|
edbInfo.Unit = unit
|
|
|
edbInfo.UnitEn = unit
|
|
|
- edbInfo.StartDate = startDate
|
|
|
- edbInfo.EndDate = endDate
|
|
|
+ if startDate != `` {
|
|
|
+ startDateTime, tmpErr := utils.FormatDateStrToTime(startDate)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfo.StartDate = startDateTime
|
|
|
+ }
|
|
|
+ if endDate != `` {
|
|
|
+ endDateTime, tmpErr := utils.FormatDateStrToTime(endDate)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfo.EndDate = endDateTime
|
|
|
+ }
|
|
|
+
|
|
|
edbInfo.ClassifyId = classifyId
|
|
|
edbInfo.SysUserId = sysUserId
|
|
|
edbInfo.SysUserRealName = sysUserRealName
|
|
@@ -2324,18 +2325,12 @@ func getEdbRuleTitle(edbInfo, parentEdbInfo *data_manage.EdbInfo, childList []da
|
|
|
}
|
|
|
for _, v := range childEdbInfoIdList {
|
|
|
if childEdbInfo, ok := edbInfoMap[v]; ok {
|
|
|
- tmpStartDate, tmpErr := time.ParseInLocation(utils.FormatDate, childEdbInfo.StartDate, time.Local)
|
|
|
- if tmpErr != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ tmpStartDate := childEdbInfo.StartDate
|
|
|
if startDate.IsZero() || startDate.After(tmpStartDate) {
|
|
|
startDate = tmpStartDate
|
|
|
}
|
|
|
|
|
|
- tmpEndDate, tmpErr := time.ParseInLocation(utils.FormatDate, childEdbInfo.EndDate, time.Local)
|
|
|
- if tmpErr != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ tmpEndDate := childEdbInfo.EndDate
|
|
|
if endDate.IsZero() || endDate.Before(tmpEndDate) {
|
|
|
endDate = tmpEndDate
|
|
|
}
|