数据源明细表刷新

controllers/data_stat/edb_source_stat.go

@@ -491,7 +491,7 @@ func (this *EdbSourceStatController) EdbUpdateStat() {
 			return
 		}
 		endT := startT.AddDate(0, 0, 1)
-		condition += " AND create_time >= ? AND create_time < ?"
+		condition += " AND update_time >= ? AND update_time < ?"
 		pars = append(pars, createTime, endT.Format(utils.FormatDate))
 	}
 
@@ -523,7 +523,7 @@ func (this *EdbSourceStatController) EdbUpdateStat() {
 	if sortParamReq != `` {
 		switch sortParamReq {
 		case "CreateTime":
-			sortParam = "create_time"
+			sortParam = "update_time"
 		case "DataUpdateTime":
 			sortParam = "data_update_time"
 		case "ErDataUpdateDate":
@@ -596,9 +596,9 @@ func (this *EdbSourceStatController) EdbUpdateStat() {
 		if v.ErDataUpdateDate != utils.EmptyDateStr {
 			tmp.ErDataUpdateDate = v.ErDataUpdateDate
 		}
-		tmp.SourceUpdateResult = v.SourceUpdateResult
-		tmp.SourceUpdateFailedReason = v.SourceUpdateFailedReason
-		tmp.SourceUpdateTime = v.SourceUpdateTime
+		tmp.DataUpdateResult = v.DataUpdateResult
+		tmp.DataUpdateFailedReason = v.DataUpdateFailedReason
+		tmp.UpdateTime = v.UpdateTime
 		tmp.IsAdd = v.IsAdd
 		tmp.NeedRefresh = v.NeedRefresh
 		tmp.HasRefresh = v.HasRefresh
@@ -749,8 +749,8 @@ func (this *EdbSourceStatController) EdbSourceStat() {
 }
 
 // EdbUpdateFailedList
-// @Title 查询指标刷新失败详情列表
-// @Description 查询指标刷新失败详情列表
+// @Title 查询指标更新失败详情列表
+// @Description 查询指标更新失败详情列表
 // @Success 200 {object} data_stat.GetEdbUpdateLogResp
 // @router /edb_update_stat/failed [get]
 func (this *EdbSourceStatController) EdbUpdateFailedList() {

models/data_stat/edb_info_update_log.go

@@ -8,34 +8,35 @@ import (
 
 // EdbInfoUpdateLog 指标更新/刷新日志列表
 type EdbInfoUpdateLog struct {
-	Id              uint64 `orm:"column(id);pk"`
-	EdbInfoId       int    `description:"指标ID"`
-	SourceName      string `description:"来源名称"`
-	Source          int    `description:"来源id"`
-	EdbCode         string `description:"指标编码"`
-	EdbName         string `description:"指标名称"`
-	EdbNameSource   string `description:"指标名称来源"`
-	Frequency       string `description:"频率"`
-	Unit            string `description:"单位"`
-	StartDate       string `description:"起始日期"`
-	EndDate         string `description:"终止日期"`
-	SysUserId       int    `description:"创建人ID"`
-	SysUserRealName string `description:"创建人姓名"`
-
-	UniqueCode            string    `description:"指标唯一编码"`
-	EdbCreateTime         time.Time `description:"指标创建时间"`
-	EdbModifyTime         time.Time `description:"指标修改时间"`
-	CreateTime            time.Time
-	UpdateSysUserId       int    `description:"变更人ID"`
-	UpdateSysUserRealName string `description:"变更人姓名"`
-	//UpdateTime         time.Time `description:"刷新/修改时间"`
-	LatestDate         string  `description:"数据最新日期"`
-	LatestValue        float64 `description:"数据最新值"`
-	TerminalCode       string  `description:"终端编码，用于配置在机器上"`
-	DataUpdateTime     string  `description:"最近一次数据发生变化的时间"`
-	ErDataUpdateDate   string  `description:"本次更新，数据发生变化的最早日期"`
-	UpdateResult       int     `description:"本次刷新结果：1成功，2失败"`
-	UpdateFailedReason string  `description:"数据未正常刷新原因"`
+	Id                     uint64    `orm:"column(id);pk"`
+	EdbInfoId              int       `description:"指标ID"`
+	SourceName             string    `description:"来源名称"`
+	Source                 int       `description:"来源id"`
+	EdbCode                string    `description:"指标编码"`
+	EdbName                string    `description:"指标名称"`
+	EdbNameSource          string    `description:"指标名称来源"`
+	Frequency              string    `description:"频率"`
+	Unit                   string    `description:"单位"`
+	StartDate              string    `description:"起始日期"`
+	EndDate                string    `description:"终止日期"`
+	SysUserId              int       `description:"创建人ID"`
+	SysUserRealName        string    `description:"创建人姓名"`
+	UniqueCode             string    `description:"指标唯一编码"`
+	EdbCreateTime          time.Time `description:"指标创建时间"`
+	EdbModifyTime          time.Time `description:"指标修改时间"`
+	CreateTime             time.Time `description:"创建时间"`
+	UpdateSysUserId        int       `description:"变更人ID"`
+	UpdateSysUserRealName  string    `description:"变更人姓名"`
+	LatestDate             string    `description:"数据最新日期"`
+	LatestValue            float64   `description:"数据最新值"`
+	TerminalCode           string    `description:"终端编码，用于配置在机器上"`
+	ErDataUpdateDate       string    `description:"本次更新，数据发生变化的最早日期"`
+	UpdateResult           int       `description:"本次刷新操作结果：1成功，2失败"`
+	UpdateFailedReason     string    `description:"刷新失败原因"`
+	DataUpdateResult       int       `description:"数据更新结果：1成功，2失败"`
+	DataUpdateFailedReason string    `description:"数据未正常更新原因"`
+	DataUpdateTime         string    `description:"数据更新时间"`
+	IsSourceRefresh        int       `description:"是否为终端刷新到数据源的刷新操作：0否，1是"`
 }
 
 type EdbInfoUpdateLogItem struct {

models/data_stat/edb_info_update_stat.go

@@ -8,67 +8,66 @@ import (
 
 // EdbInfoUpdateStat 指标更新/刷新 汇总表（数据源明细表）
 type EdbInfoUpdateStat struct {
-	Id               uint64    `orm:"column(id);pk"`
-	EdbInfoId        int       `description:"指标ID"`
-	SourceName       string    `description:"来源名称"`
-	Source           int       `description:"来源id"`
-	EdbCode          string    `description:"指标编码"`
-	EdbName          string    `description:"指标名称"`
-	EdbNameSource    string    `description:"指标名称来源"`
-	Frequency        string    `description:"频率"`
-	Unit             string    `description:"单位"`
-	StartDate        string    `description:"起始日期"`
-	EndDate          string    `description:"终止日期"`
-	SysUserId        int       `description:"创建人ID"`
-	SysUserRealName  string    `description:"创建人姓名"`
-	UniqueCode       string    `description:"指标唯一编码"`
-	EdbCreateTime    time.Time `description:"指标创建时间"`
-	EdbModifyTime    time.Time `description:"指标修改时间"`
-	CreateTime       time.Time
-	LatestDate       string  `description:"数据最新日期"`
-	LatestValue      float64 `description:"数据最新值"`
-	TerminalCode     string  `description:"终端编码，用于配置在机器上"`
-	DataUpdateTime   string  `description:"最近一次数据发生变化的时间"`
-	ErDataUpdateDate string  `description:"本次更新，数据发生变化的最早日期"`
-	/*UpdateResult       int32     `description:"本次刷新结果：1成功，2失败"`
-	UpdateTime         string    `description:"刷新/修改时间"`
-	UpdateFailedReason string    `description:"数据未正常刷新原因"`*/
-	SourceUpdateResult       int    `description:"从终端刷新到数据源的刷新结果：1成功，2失败"`
-	SourceUpdateFailedReason string `description:"从终端刷新到数据源的数据未正常刷新原因"`
-	SourceUpdateTime         string `description:"从终端刷新到数据源的 刷新时间"`
-	ModifyTime               string `description:"修改时间"`
-	IsAdd                    int8   `description:"是否是当日新增的指标：1是，2否"`
-	NeedRefresh              int8   `description:"今日是否需要定时刷新，1需要，0不需要"` //todo 确认该字段
-	HasRefresh               int8   `description:"今日是否已刷新，1是，0否"`
+	Id                     uint64    `orm:"column(id);pk"`
+	EdbInfoId              int       `description:"指标ID"`
+	SourceName             string    `description:"来源名称"`
+	Source                 int       `description:"来源id"`
+	EdbCode                string    `description:"指标编码"`
+	EdbName                string    `description:"指标名称"`
+	EdbNameSource          string    `description:"指标名称来源"`
+	Frequency              string    `description:"频率"`
+	Unit                   string    `description:"单位"`
+	StartDate              string    `description:"起始日期"`
+	EndDate                string    `description:"终止日期"`
+	SysUserId              int       `description:"创建人ID"`
+	SysUserRealName        string    `description:"创建人姓名"`
+	UniqueCode             string    `description:"指标唯一编码"`
+	EdbCreateTime          time.Time `description:"指标创建时间"`
+	EdbModifyTime          time.Time `description:"指标修改时间"`
+	CreateTime             time.Time
+	UpdateTime             string  `description:"刷新时间"`
+	LatestDate             string  `description:"数据最新日期"`
+	LatestValue            float64 `description:"数据最新值"`
+	TerminalCode           string  `description:"终端编码，用于配置在机器上"`
+	ErDataUpdateDate       string  `description:"本次更新，数据发生变化的最早日期"`
+	DataUpdateResult       int     `description:"数据更新结果：1成功，2失败"`
+	DataUpdateFailedReason string  `description:"数据未正常更新原因"`
+	DataUpdateTime         string  `description:"数据更新时间"`
+	UpdateResult           int     `description:"本次刷新操作结果：1成功，2失败"`
+	UpdateFailedReason     string  `description:"刷新失败原因"`
+	ModifyTime             string  `description:"修改时间"`
+	IsAdd                  int8    `description:"是否是当日新增的指标：1是，2否"`
+	NeedRefresh            int8    `description:"今日是否需要定时刷新，1需要，0不需要"` //todo 确认该字段
+	HasRefresh             int8    `description:"今日是否已刷新，1是，0否"`
 }
 
 type EdbInfoUpdateStatItem struct {
-	Id               uint64  `orm:"column(id);pk"`
-	EdbInfoId        int     `description:"指标ID"`
-	SourceName       string  `description:"来源名称"`
-	Source           int     `description:"来源id"`
-	EdbCode          string  `description:"指标编码"`
-	EdbName          string  `description:"指标名称"`
-	EdbNameSource    string  `description:"指标名称来源"`
-	Frequency        string  `description:"频率"`
-	Unit             string  `description:"单位"`
-	StartDate        string  `description:"起始日期"`
-	SysUserId        int     `description:"创建人ID"`
-	SysUserRealName  string  `description:"创建人姓名"`
-	LatestDate       string  `description:"数据最新日期"`
-	LatestValue      float64 `description:"数据最新值"`
-	TerminalCode     string  `description:"终端编码，用于配置在机器上"`
-	DataUpdateTime   string  `description:"最近一次数据发生变化的时间"`
-	ErDataUpdateDate string  `description:"本次更新，数据发生变化的最早日期"`
-	/*	UpdateResult       int32   `description:"本次刷新结果：1成功，2失败"`
-		UpdateFailedReason string  `description:"数据未正常刷新原因"`
-		UpdateTime         string  `description:"当日刷新/修改时间"`*/
-	SourceUpdateResult       int    `description:"从终端刷新到数据源的刷新结果：1成功，2失败"`
-	SourceUpdateFailedReason string `description:"从终端刷新到数据源的数据未正常刷新原因"`
-	SourceUpdateTime         string `description:"从终端刷新到数据源的 刷新时间"`
-	IsAdd                    int8   `description:"是否是当日新增的指标：1是，2否"`
-	NeedRefresh              int8   `description:"今日是否需要定时刷新，1需要，0不需要"` //todo 确认该字段
-	HasRefresh               int8   `description:"今日是否已刷新，1是，0否"`
+	Id                     uint64  `orm:"column(id);pk"`
+	EdbInfoId              int     `description:"指标ID"`
+	SourceName             string  `description:"来源名称"`
+	Source                 int     `description:"来源id"`
+	EdbCode                string  `description:"指标编码"`
+	EdbName                string  `description:"指标名称"`
+	EdbNameSource          string  `description:"指标名称来源"`
+	Frequency              string  `description:"频率"`
+	Unit                   string  `description:"单位"`
+	StartDate              string  `description:"起始日期"`
+	SysUserId              int     `description:"创建人ID"`
+	SysUserRealName        string  `description:"创建人姓名"`
+	LatestDate             string  `description:"数据最新日期"`
+	CreateTime             string  `description:"创建时间"`
+	LatestValue            float64 `description:"数据最新值"`
+	TerminalCode           string  `description:"终端编码，用于配置在机器上"`
+	ErDataUpdateDate       string  `description:"本次更新，数据发生变化的最早日期"`
+	DataUpdateResult       int     `description:"数据更新结果：1成功，2失败"`
+	DataUpdateFailedReason string  `description:"数据未正常更新原因"`
+	DataUpdateTime         string  `description:"数据更新时间"`
+	UpdateResult           int     `description:"本次刷新操作结果：1成功，2失败"`
+	UpdateFailedReason     string  `description:"刷新失败原因"`
+	UpdateTime             string  `description:"刷新时间"`
+	IsAdd                  int8    `description:"是否是当日新增的指标：1是，2否"`
+	NeedRefresh            int8    `description:"今日是否需要定时刷新，1需要，0不需要"`
+	HasRefresh             int8    `description:"今日是否已刷新，1是，0否"`
 }
 
 type GetEdbUpdateStatResp struct {
@@ -117,30 +116,29 @@ type GetEdbUpdateFailedResp struct {
 	Name             string `description:"终端名称"`
 	TerminalCode     string `description:"终端编码，用于配置在机器上"`
 	DirPath          string `description:"终端存放的文件夹路径"`
-	UpdateSuccessNum int    `description:"今日已刷新成功指标数"`
-	UpdateFailedNum  int    `description:"今日已刷新失败指标数"`
+	UpdateSuccessNum int    `description:"今日已更新成功指标数"`
+	UpdateFailedNum  int    `description:"今日已更新失败指标数"`
 }
 
 func GetEdbUpdateStatFailedGroupByCondition(condition string, pars []interface{}) (item []*EdbUpdateFailedList, err error) {
 	o := orm.NewOrmUsingDB("data")
 	sql := `SELECT
 	terminal_code,
-	source_update_result,
+	data_update_result as source_update_result,
 	frequency,
-	IF(source_update_failed_reason !="" && source_update_failed_reason="未刷新到数据",source_update_failed_reason,"服务异常") as source_update_failed_reason,
+	data_update_failed_reason as source_update_failed_reason,
 	count(*) as num
 FROM
 	edb_info_update_stat 
 WHERE
-    source_update_result != 0 
-	`
+	1 = 1`
 	if condition != "" {
 		sql += condition
 	}
 	sql += ` GROUP BY
-	source_update_result,
+	data_update_result,
 	frequency,
-	update_failed_reason
+	data_update_failed_reason
 	ORDER BY count(*) desc`
 	_, err = o.Raw(sql, pars).QueryRows(&item)
 	return