| | |
| | | } |
| | | |
| | | service.TaskFlagUnset(procedure.Channel) |
| | | |
| | | service.TaskEndTimeSet(procedure.Channel, time.Now().Unix()) //设置工序运行结束时间 |
| | | ctx.Ok() |
| | | } |
| | | |
| | |
| | | return |
| | | } |
| | | |
| | | service.TaskFlagSet(procedure.Channel) |
| | | service.TaskFlagSet(procedure.Channel, int(procedure.ID)) |
| | | service.TaskStartTimeSet(procedure.Channel, time.Now().Unix()) //设置工序运行开始时间 |
| | | service.TaskEndTimeSet(procedure.Channel, 0) //设置工序运行结束时间 |
| | | ctx.Ok() |
| | | } |
| | | |
| | |
| | | // @Produce application/json |
| | | // @Param object query request.TaskListByChannel true "查询参数" |
| | | // @Success 200 {object} contextx.Response{data=map[int32]response.TaskResponse} "成功" |
| | | // @Router /v1/task/listByChannel [get] |
| | | // @Router /v1/task/list [get] |
| | | func (slf *TaskApi) TaskListByChannel(c *gin.Context) { |
| | | var params request.TaskListByChannel |
| | | ctx, ok := contextx.NewContext(c, ¶ms) |