Commit bc96e138 authored by brent's avatar brent

modify task type

parent 1f030fd2
...@@ -2035,6 +2035,15 @@ func (server *TaskController) Enumeration() { ...@@ -2035,6 +2035,15 @@ func (server *TaskController) Enumeration() {
server.respond(http.StatusOK, "", responseData) server.respond(http.StatusOK, "", responseData)
} }
func taskTypeCount() int64 {
qs := mysql.GetMysqlInstace().Ormer.QueryTable("task_type")
count, err := qs.Count()
if err != nil {
return 0
}
return count
}
func initTypeInRedis() []models.TaskHeat { func initTypeInRedis() []models.TaskHeat {
qs := mysql.GetMysqlInstace().Ormer.QueryTable("task_type") qs := mysql.GetMysqlInstace().Ormer.QueryTable("task_type")
count, _ := qs.Count() count, _ := qs.Count()
...@@ -2074,19 +2083,22 @@ func initTypeInRedis() []models.TaskHeat { ...@@ -2074,19 +2083,22 @@ func initTypeInRedis() []models.TaskHeat {
func (server *TaskController) TaskHeat() { func (server *TaskController) TaskHeat() {
data, err := redis.GetDataToString(cronjob.HeatKey) data, err := redis.GetDataToString(cronjob.HeatKey)
if data == "" { if data == "" || err != nil {
response := initTypeInRedis() response := initTypeInRedis()
server.respond(http.StatusOK, "", response) server.respond(http.StatusOK, "", response)
return return
} }
var response []models.TaskHeat var response []models.TaskHeat
err = json.Unmarshal([]byte(data), &response)
if err != nil { if err != nil {
response = initTypeInRedis()
server.respond(http.StatusOK, "", response) server.respond(http.StatusOK, "", response)
return return
} }
err = json.Unmarshal([]byte(data), &response) count := taskTypeCount()
if err != nil { if len(response) < int(count) {
response = initTypeInRedis()
server.respond(http.StatusOK, "", response) server.respond(http.StatusOK, "", response)
return return
} }
......
{"/Users/brent/Documents/wubanWork/ai_developer_admin/controllers":1709549304433646107} {"/Users/brent/Documents/wubanWork/ai_developer_admin/controllers":1709610847935101949}
\ No newline at end of file \ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment