|
@@ -543,7 +543,6 @@ func (this *CalculateController) Refresh() {
|
|
this.Data["json"] = br
|
|
this.Data["json"] = br
|
|
this.ServeJSON()
|
|
this.ServeJSON()
|
|
}()
|
|
}()
|
|
- source := utils.DATA_SOURCE_LT
|
|
|
|
var req models.RefreshEdbInfoReq
|
|
var req models.RefreshEdbInfoReq
|
|
err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -576,8 +575,9 @@ func (this *CalculateController) Refresh() {
|
|
var errMsg string
|
|
var errMsg string
|
|
endDate := time.Now().Format(utils.FormatDate)
|
|
endDate := time.Now().Format(utils.FormatDate)
|
|
edbInfoId := edbInfo.EdbInfoId
|
|
edbInfoId := edbInfo.EdbInfoId
|
|
|
|
+ source := edbInfo.Source
|
|
|
|
|
|
- switch edbInfo.Source {
|
|
|
|
|
|
+ switch source {
|
|
case utils.DATA_SOURCE_CALCULATE:
|
|
case utils.DATA_SOURCE_CALCULATE:
|
|
startDate = edbInfo.StartDate
|
|
startDate = edbInfo.StartDate
|
|
sTime, err := time.Parse(utils.FormatDate, edbInfo.EndDate)
|
|
sTime, err := time.Parse(utils.FormatDate, edbInfo.EndDate)
|
|
@@ -587,7 +587,7 @@ func (this *CalculateController) Refresh() {
|
|
startDate = sTime.Format(utils.FormatDate)
|
|
startDate = sTime.Format(utils.FormatDate)
|
|
|
|
|
|
var edbInfoIdBytes []string
|
|
var edbInfoIdBytes []string
|
|
- calculateMap, err := models.GetEdbInfoCalculateDetail(edbInfo.EdbInfoId)
|
|
|
|
|
|
+ calculateMap, err := models.GetEdbInfoCalculateDetailList(edbInfo.EdbInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "GetEdbInfoCalculateDetail Err:" + err.Error()
|
|
errMsg = "GetEdbInfoCalculateDetail Err:" + err.Error()
|
|
break
|
|
break
|
|
@@ -602,12 +602,12 @@ func (this *CalculateController) Refresh() {
|
|
edbInfoList = append(edbInfoList, edbInfo)
|
|
edbInfoList = append(edbInfoList, edbInfo)
|
|
}
|
|
}
|
|
err = models.RefreshAllCalculate(edbInfoList, edbInfo.EdbInfoId, source, edbInfo.EdbCode, edbInfo.CalculateFormula, startDate, endDate, edbInfoIdBytes)
|
|
err = models.RefreshAllCalculate(edbInfoList, edbInfo.EdbInfoId, source, edbInfo.EdbCode, edbInfo.CalculateFormula, startDate, endDate, edbInfoIdBytes)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshCalculate Err:" + err.Error()
|
|
errMsg = "RefreshCalculate Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_LJZZY: //刷新累计值转月值
|
|
case utils.DATA_SOURCE_CALCULATE_LJZZY: //刷新累计值转月值
|
|
- calculateLjzzy, err := models.GetEdbInfoCalculateLjzzyDetail(edbInfoId)
|
|
|
|
|
|
+ calculateLjzzy, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "GetEdbInfoCalculateLjzzyDetail Err:" + err.Error()
|
|
errMsg = "GetEdbInfoCalculateLjzzyDetail Err:" + err.Error()
|
|
break
|
|
break
|
|
@@ -620,12 +620,12 @@ func (this *CalculateController) Refresh() {
|
|
startDate = edbInfo.StartDate
|
|
startDate = edbInfo.StartDate
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
err = models.RefreshAllCalculateLjzzy(edbInfoId, source, fromEdbInfo, calculateLjzzy.EdbCode, startDate, endDate)
|
|
err = models.RefreshAllCalculateLjzzy(edbInfoId, source, fromEdbInfo, calculateLjzzy.EdbCode, startDate, endDate)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshAllCalculateLjzzy Err:" + err.Error()
|
|
errMsg = "RefreshAllCalculateLjzzy Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_TBZ: //刷新同比值
|
|
case utils.DATA_SOURCE_CALCULATE_TBZ: //刷新同比值
|
|
- calculateTbz, err := models.GetEdbInfoCalculateTbzDetail(edbInfoId)
|
|
|
|
|
|
+ calculateTbz, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "GetEdbInfoCalculateTbzDetail Err:" + err.Error()
|
|
errMsg = "GetEdbInfoCalculateTbzDetail Err:" + err.Error()
|
|
break
|
|
break
|
|
@@ -638,12 +638,12 @@ func (this *CalculateController) Refresh() {
|
|
startDate = edbInfo.StartDate
|
|
startDate = edbInfo.StartDate
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
err = models.RefreshAllCalculateTbz(edbInfoId, source, fromEdbInfo, calculateTbz.EdbCode, startDate, endDate)
|
|
err = models.RefreshAllCalculateTbz(edbInfoId, source, fromEdbInfo, calculateTbz.EdbCode, startDate, endDate)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshAllCalculateTbz Err:" + err.Error()
|
|
errMsg = "RefreshAllCalculateTbz Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_TCZ: //同差值
|
|
case utils.DATA_SOURCE_CALCULATE_TCZ: //同差值
|
|
- calculateTcz, err := models.GetEdbInfoCalculateTczDetail(edbInfoId)
|
|
|
|
|
|
+ calculateTcz, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "GetEdbInfoCalculateTczDetail Err:" + err.Error()
|
|
errMsg = "GetEdbInfoCalculateTczDetail Err:" + err.Error()
|
|
break
|
|
break
|
|
@@ -656,12 +656,12 @@ func (this *CalculateController) Refresh() {
|
|
startDate = edbInfo.StartDate
|
|
startDate = edbInfo.StartDate
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
err = models.RefreshAllCalculateTcz(edbInfoId, source, fromEdbInfo, calculateTcz.EdbCode, startDate, endDate)
|
|
err = models.RefreshAllCalculateTcz(edbInfoId, source, fromEdbInfo, calculateTcz.EdbCode, startDate, endDate)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshCalculateTcz Err:" + err.Error()
|
|
errMsg = "RefreshCalculateTcz Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_NSZYDPJJS: //N数值移动平均计算
|
|
case utils.DATA_SOURCE_CALCULATE_NSZYDPJJS: //N数值移动平均计算
|
|
- calculateNszydpjjs, err := models.GetEdbInfoCalculateNszydpjjsDetail(edbInfoId)
|
|
|
|
|
|
+ calculateNszydpjjs, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "GetEdbInfoCalculateNszydpjjsDetail Err:" + err.Error()
|
|
errMsg = "GetEdbInfoCalculateNszydpjjsDetail Err:" + err.Error()
|
|
break
|
|
break
|
|
@@ -674,12 +674,12 @@ func (this *CalculateController) Refresh() {
|
|
formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
startDate = edbInfo.StartDate
|
|
startDate = edbInfo.StartDate
|
|
err = models.RefreshAllCalculateNszydpjjs(edbInfoId, edbInfo.Source, formulaInt, fromEdbInfo, calculateNszydpjjs.EdbCode, startDate)
|
|
err = models.RefreshAllCalculateNszydpjjs(edbInfoId, edbInfo.Source, formulaInt, fromEdbInfo, calculateNszydpjjs.EdbCode, startDate)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshCalculateNszydpjjs Err:" + err.Error()
|
|
errMsg = "RefreshCalculateNszydpjjs Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_HBZ: //刷新环比值
|
|
case utils.DATA_SOURCE_CALCULATE_HBZ: //刷新环比值
|
|
- calculateTbz, err := models.GetEdbInfoCalculateHbzDetail(edbInfoId)
|
|
|
|
|
|
+ calculateTbz, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "GetEdbInfoCalculateHbzDetail Err:" + err.Error()
|
|
errMsg = "GetEdbInfoCalculateHbzDetail Err:" + err.Error()
|
|
break
|
|
break
|
|
@@ -693,12 +693,12 @@ func (this *CalculateController) Refresh() {
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
err = models.RefreshAllCalculateHbz(edbInfoId, source, fromEdbInfo, calculateTbz.EdbCode, startDate, endDate, formulaInt)
|
|
err = models.RefreshAllCalculateHbz(edbInfoId, source, fromEdbInfo, calculateTbz.EdbCode, startDate, endDate, formulaInt)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshAllCalculateHbz Err:" + err.Error()
|
|
errMsg = "RefreshAllCalculateHbz Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_HCZ: //刷新环差值
|
|
case utils.DATA_SOURCE_CALCULATE_HCZ: //刷新环差值
|
|
- calculateTbz, err := models.GetEdbInfoCalculateHczDetail(edbInfoId)
|
|
|
|
|
|
+ calculateTbz, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "GetEdbInfoCalculateHczDetail Err:" + err.Error()
|
|
errMsg = "GetEdbInfoCalculateHczDetail Err:" + err.Error()
|
|
break
|
|
break
|
|
@@ -712,12 +712,12 @@ func (this *CalculateController) Refresh() {
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
err = models.RefreshAllCalculateHcz(edbInfoId, source, fromEdbInfo, calculateTbz.EdbCode, startDate, endDate, formulaInt)
|
|
err = models.RefreshAllCalculateHcz(edbInfoId, source, fromEdbInfo, calculateTbz.EdbCode, startDate, endDate, formulaInt)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshAllCalculateHcz Err:" + err.Error()
|
|
errMsg = "RefreshAllCalculateHcz Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_BP: //刷新变频
|
|
case utils.DATA_SOURCE_CALCULATE_BP: //刷新变频
|
|
- calculateTbz, err := models.GetEdbInfoCalculateBpDetail(edbInfoId)
|
|
|
|
|
|
+ calculateTbz, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "GetEdbInfoCalculateTbzDetail Err:" + err.Error()
|
|
errMsg = "GetEdbInfoCalculateTbzDetail Err:" + err.Error()
|
|
break
|
|
break
|
|
@@ -730,7 +730,7 @@ func (this *CalculateController) Refresh() {
|
|
startDate = edbInfo.StartDate
|
|
startDate = edbInfo.StartDate
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
err = models.RefreshAllCalculateBp(edbInfoId, source, fromEdbInfo, calculateTbz.EdbCode, startDate, endDate)
|
|
err = models.RefreshAllCalculateBp(edbInfoId, source, fromEdbInfo, calculateTbz.EdbCode, startDate, endDate)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshAllCalculateBp Err:" + err.Error()
|
|
errMsg = "RefreshAllCalculateBp Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
@@ -749,18 +749,18 @@ func (this *CalculateController) Refresh() {
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
endDate = time.Now().Format(utils.FormatDate)
|
|
formulaInt, _ := strconv.Atoi(calculate.CalculateFormula)
|
|
formulaInt, _ := strconv.Atoi(calculate.CalculateFormula)
|
|
err = models.RefreshAllCalculateTimeShift(edbInfoId, source, formulaInt, calculate.MoveType, fromEdbInfo, calculate.EdbCode, startDate, endDate, calculate.MoveFrequency)
|
|
err = models.RefreshAllCalculateTimeShift(edbInfoId, source, formulaInt, calculate.MoveType, fromEdbInfo, calculate.EdbCode, startDate, endDate, calculate.MoveFrequency)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshAllCalculateTimeShift Err:" + err.Error()
|
|
errMsg = "RefreshAllCalculateTimeShift Err:" + err.Error()
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_ZJPJ: //刷新直接拼接
|
|
case utils.DATA_SOURCE_CALCULATE_ZJPJ: //刷新直接拼接
|
|
err = models.RefreshAllCalculateZjpj(edbInfo)
|
|
err = models.RefreshAllCalculateZjpj(edbInfo)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshAllCalculateZjpj Err:" + err.Error()
|
|
errMsg = "RefreshAllCalculateZjpj Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|
|
case utils.DATA_SOURCE_CALCULATE_LJZTBPJ: //刷新累计值同比拼接
|
|
case utils.DATA_SOURCE_CALCULATE_LJZTBPJ: //刷新累计值同比拼接
|
|
err = models.RefreshAllCalculateLjztbpj(edbInfo)
|
|
err = models.RefreshAllCalculateLjztbpj(edbInfo)
|
|
- if err != nil {
|
|
|
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
errMsg = "RefreshAllCalculateLjztbpj Err:" + err.Error()
|
|
errMsg = "RefreshAllCalculateLjztbpj Err:" + err.Error()
|
|
break
|
|
break
|
|
}
|
|
}
|