add version

controllers/favorite.go

@@ -196,9 +196,15 @@ func (server *FavoriteController) Lists() {
 
 func (server *FavoriteController) Times() {
 	taskTypeId, err := server.GetInt("task_type_id")
-	if err != nil {
-		server.respond(models.MissingParameter, err.Error())
-		return
+	if err != nil || taskTypeId == 0 {
+		type ResponseType struct {
+			TaskTypeId int `json:"task_type_id,omitempty"`
+		}
+		body := server.Ctx.Input.RequestBody
+		appRequest := ResponseType{}
+		_ = json.Unmarshal(body, &appRequest) //解析body中数据
+		logs.Debug("appRequest", appRequest, string(body))
+		taskTypeId = appRequest.TaskTypeId
 	}
 	if taskTypeId == 0 {
 		server.respond(models.MissingParameter, "Missing task_type_id parameter")

controllers/version.go

+package controllers
+
+import (
+	"ai_developer_admin/libs/mysql"
+	"ai_developer_admin/models"
+	"encoding/json"
+	"github.com/beego/beego/v2/core/logs"
+	"net/http"
+	"time"
+)
+
+type VersionController struct {
+	MainController
+}
+
+func (server *VersionController) Add() {
+	_, err := server.Check()
+	if err != nil {
+		server.respond(http.StatusUnauthorized, err.Error())
+		return
+	}
+
+	body := server.Ctx.Input.RequestBody
+	appRequest := models.TaskTypeVersion{}
+	err = json.Unmarshal(body, &appRequest) //解析body中数据
+	logs.Debug("appRequest", appRequest)
+	if err != nil {
+		server.respond(models.NoRequestBody, err.Error())
+		return
+	}
+	if appRequest.TaskTypeId == 0 {
+		server.respond(models.MissingParameter, "Missing task_type_id parameter")
+		return
+	}
+
+	timestamp := time.Now()
+	appRequest.CreatedTime = timestamp
+	appRequest.UpdatedTime = timestamp
+	appRequest.Deleted = 0
+
+	_, err = mysql.GetMysqlInstace().Ormer.Insert(&appRequest)
+	if err != nil {
+		server.respond(models.BusinessFailed, err.Error())
+		return
+	}
+	server.respond(http.StatusOK, "success")
+}
+
+func (server *VersionController) Update() {
+	_, err := server.Check()
+	if err != nil {
+		server.respond(http.StatusUnauthorized, err.Error())
+		return
+	}
+
+	body := server.Ctx.Input.RequestBody
+	appRequest := models.TaskTypeVersion{}
+	err = json.Unmarshal(body, &appRequest) //解析body中数据
+	logs.Debug("appRequest", appRequest)
+	if err != nil {
+		server.respond(models.NoRequestBody, err.Error())
+		return
+	}
+	if appRequest.Id == 0 {
+		server.respond(models.MissingParameter, "Missing id parameter")
+		return
+	}
+	//if appRequest.TaskTypeId == 0 {
+	//	server.respond(models.MissingParameter, "Missing task_type_id parameter")
+	//	return
+	//}
+
+	checkVersion := &models.TaskTypeVersion{Id: appRequest.Id}
+	err = mysql.GetMysqlInstace().Ormer.Read(checkVersion)
+	if err != nil {
+		server.respond(models.BusinessFailed, err.Error())
+		return
+	}
+
+	timestamp := time.Now()
+	appRequest.CreatedTime = checkVersion.CreatedTime
+	appRequest.UpdatedTime = timestamp
+
+	_, err = mysql.GetMysqlInstace().Ormer.Update(&appRequest)
+	if err != nil {
+		server.respond(models.BusinessFailed, err.Error())
+		return
+	}
+	server.respond(http.StatusOK, "success")
+}
+
+func (server *VersionController) Delete() {
+	_, err := server.Check()
+	if err != nil {
+		server.respond(http.StatusUnauthorized, err.Error())
+		return
+	}
+
+	body := server.Ctx.Input.RequestBody
+	appRequest := models.TaskTypeVersion{}
+	err = json.Unmarshal(body, &appRequest) //解析body中数据
+	logs.Debug("appRequest", appRequest)
+	if err != nil {
+		server.respond(models.NoRequestBody, err.Error())
+		return
+	}
+	if appRequest.Id == 0 {
+		server.respond(models.MissingParameter, "Missing id parameter")
+		return
+	}
+	//if appRequest.TaskTypeId == 0 {
+	//	server.respond(models.MissingParameter, "Missing task_type_id parameter")
+	//	return
+	//}
+
+	checkVersion := &models.TaskTypeVersion{Id: appRequest.Id}
+	err = mysql.GetMysqlInstace().Ormer.Read(checkVersion)
+	if err != nil {
+		server.respond(models.BusinessFailed, err.Error())
+		return
+	}
+
+	timestamp := time.Now()
+	checkVersion.UpdatedTime = timestamp
+	checkVersion.Deleted = 1
+
+	_, err = mysql.GetMysqlInstace().Ormer.Update(&appRequest)
+	if err != nil {
+		server.respond(models.BusinessFailed, err.Error())
+		return
+	}
+	server.respond(http.StatusOK, "success")
+}
+
+func (server *VersionController) Lists() {
+	body := server.Ctx.Input.RequestBody
+	appRequest := models.TaskTypeVersion{}
+	err := json.Unmarshal(body, &appRequest) //解析body中数据
+	logs.Debug("appRequest", appRequest)
+	if err != nil {
+		server.respond(models.NoRequestBody, err.Error())
+		return
+	}
+
+	if appRequest.TaskTypeId == 0 {
+		server.respond(models.MissingParameter, "Missing task_type_id parameter")
+		return
+	}
+
+	qs := mysql.GetMysqlInstace().Ormer.QueryTable("task_type_version").
+		Filter("deleted", 0).Filter("task_type_id", appRequest.TaskTypeId)
+	count, err := qs.Count()
+	var lists []*models.TaskTypeVersion
+	if count > 0 {
+		qs.All(&lists)
+	}
+	server.respond(http.StatusOK, "", lists)
+}

libs/mysql/mysql.go

@@ -46,6 +46,7 @@ func init() {
 	orm.RegisterModel(new(models.Whitelist))
 	orm.RegisterModel(new(models.Computility))
 	orm.RegisterModel(new(models.Favorite))
+	orm.RegisterModel(new(models.TaskTypeVersion))
 
 	logs.Debug("AppConfig", beego.AppConfig)
 

models/task.go

@@ -51,8 +51,21 @@ type Computility struct {
 	Computility int       `json:"computility";orm:"column(computility)"`
 	Type        int       `json:"type";orm:"column(type)"`
 	Brand       string    `json:"brand";orm:"column(brand);"`
-	CreatedTime string `json:"created_time";orm:"column(created_time)"`
-	UpdatedTime string `json:"updated_time";orm:"column(updated_time)"`
+	CreatedTime time.Time `json:"created_time";orm:"column(created_time);type(datetime)"`
+	UpdatedTime time.Time `json:"updated_time";orm:"column(updated_time);type(datetime)"`
+	Deleted     int       `json:"deleted";orm:"column(deleted)"`
+}
+
+type TaskTypeVersion struct {
+	Id          int       `json:"id";orm:"column(id);auto"`
+	Version     string    `json:"version";orm:"column(version)"`
+	VersionCode string    `json:"version_code";orm:"column(version_code)"`
+	Desc        string    `json:"desc";orm:"column(desc)"`
+	Hash        int       `json:"hash";orm:"column(hash)"`
+	TaskTypeId  int       `json:"task_type_id";orm:"column(task_type_id)"`
+	Os          int       `json:"os";orm:"column(os)"`
+	CreatedTime time.Time `json:"created_time";orm:"column(created_time);type(datetime)"`
+	UpdatedTime time.Time `json:"updated_time";orm:"column(updated_time);type(datetime)"`
 	Deleted     int       `json:"deleted";orm:"column(deleted)"`
 }
 

routers/router.go

@@ -16,4 +16,5 @@ func init() {
 	beego.AutoPrefix("admin/api", &controllers.WhitelistController{})
 	beego.AutoPrefix("admin/api", &controllers.FileController{})
 	beego.AutoPrefix("admin/api", &controllers.FavoriteController{})
+	beego.AutoPrefix("admin/api/task", &controllers.VersionController{})
 }