| | |
| | | } |
| | | } |
| | | |
| | | type TaskStatusVo struct { |
| | | TaskId string `json:"taskId"` |
| | | Enable bool `json:"enable"` |
| | | } |
| | | |
| | | // @Summary 更新任务状态 |
| | | // @Description (算法不变,只更新任务状态) |
| | | // @Produce json |
| | | // @Tags task |
| | | // @Param taskId path string true "任务id" |
| | | // @Param taskName path string true "任务名称" |
| | | // @Param isAlarm path bool true "是否报警" |
| | | // @Param isEnable path bool true "是否停用" |
| | | // @Param taskStatus body controllers.TaskStatusVo true "参数" |
| | | // @Success 200 {string} json "{"code":200, msg:"请求处理成功",data:"",success:true}" |
| | | // @Failure 500 {string} json "{"code":500, msg:"请求失败",data:"",success:false}" |
| | | // @Router /data/api-v/task/updateTaskStatus [POST] |
| | | func (tc TaskController) UpdateTaskStatus(c *gin.Context) { |
| | | var tsvo TaskStatusVo |
| | | err := c.BindJSON(&tsvo) |
| | | if err !=nil { |
| | | util.ResponseFormat(c,code.RequestParamError,"参数有误") |
| | | return |
| | | } |
| | | var taskApi dbapi.TaskApi |
| | | paramBody :=make(map[string]string,0) |
| | | paramBody["taskId"] = c.Query("taskId") |
| | | paramBody["taskName"] = c.Query("taskName") |
| | | paramBody["isAlarm"] = c.Query("isAlarm") |
| | | paramBody["isEnable"] = c.Query("isEnable") |
| | | paramBody := util.Struct2Map(tsvo) |
| | | flag, data := taskApi.UpdateTaskStatus(paramBody) |
| | | if flag { |
| | | util.ResponseFormat(c,code.Success,data) |
| | |
| | | util.ResponseFormat(c,code.ComError,data) |
| | | } |
| | | } |
| | | |
| | | |
| | | // @Summary 删除任务 |
| | | // @Description 根据任务id删除任务 |
| | |
| | | } |
| | | |
| | | } |
| | | |
| | | type TaskSdkRules struct { |
| | | rules []TaskSdkRuleVo `json:"rules"` |
| | | } |
| | | |
| | | type TaskSdkRuleVo struct { |
| | | Id string `json:"id"` |
| | | TaskSdkId string `json:"task_sdk_id"` |
| | | SdkArgAlias string `json:"sdk_arg_alias"` |
| | | Operator string `json:"operator"` |
| | | SdkArgValue string `json:"sdk_arg_value"` |
| | | } |
| | | |
| | | // @Summary 保存算法规则 |
| | | // @Description 保存算法规则 |
| | | // @Accept json |
| | | // @Produce json |
| | | // @Tags 算法规则 |
| | | // @Param sdkrules body controllers.TaskSdkRules true "算法参数规则" |
| | | // @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}" |
| | | // @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}" |
| | | // @Router /data/api-v/task/saveTaskSdkRule [post] |
| | | func (tc TaskController) SaveTaskSdkRule(c *gin.Context) { |
| | | var rules TaskSdkRules |
| | | err := c.BindJSON(&rules) |
| | | if err !=nil { |
| | | util.ResponseFormat(c,code.RequestParamError,"参数有误") |
| | | return |
| | | } |
| | | paramBody := util.Struct2Map(rules) |
| | | var api dbapi.TaskSdkRuleApi |
| | | b,d := api.SaveTaskSdkRule(paramBody) |
| | | if b { |
| | | util.ResponseFormat(c,code.Success,d) |
| | | } else { |
| | | util.ResponseFormat(c,code.ComError,"保存失败") |
| | | } |
| | | } |
| | | |
| | | // @Summary 查询算法规则 |
| | | // @Description 查询算法规则 |
| | | // @Produce json |
| | | // @Tags 算法规则 |
| | | // @Param taskId path string true "任务id" |
| | | // @Param sdkId path string true "算法id" |
| | | // @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}" |
| | | // @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}" |
| | | // @Router /data/api-v/task/getRulesByTaskSdk [get] |
| | | func (tc TaskController) GetRulesByTaskSdk(c *gin.Context) { |
| | | taskId := c.Query("taskId") |
| | | sdkId := c.Query("sdkId") |
| | | if taskId == "" || sdkId == ""{ |
| | | util.ResponseFormat(c,code.RequestParamError,"参数有误") |
| | | return |
| | | } |
| | | var taskSdkApi dbapi.TaskSdkRuleApi |
| | | b, d := taskSdkApi.GetRulesByTaskSdk(taskId, sdkId) |
| | | if b { |
| | | util.ResponseFormat(c,code.Success,d) |
| | | } else { |
| | | util.ResponseFormat(c,code.ComError,"查询失败") |
| | | } |
| | | } |