log-server/api/v1/newCentralControl/computer_task.go

package newCentralControl

import (
	"github.com/gin-gonic/gin"
	"go.uber.org/zap"
	"log-server/global"
	"log-server/model/common/request"
	"log-server/model/common/response"
	"log-server/model/newCentralControl"
	newCentralControlRequest "log-server/model/newCentralControl/request"
	"log-server/utils"
)

type ComputerTaskApi struct {
}

//创建电脑任务
func (a *ComputerTaskApi) CreateComputerTask (c *gin.Context) {
	var task newCentralControl.ComputerTask
	_ = c.ShouldBindJSON(&task)
	if err := utils.Verify(task, utils.ComputerTaskVerify); err != nil {
		response.FailWithMessage(err.Error(), c)
		return
	}
	if err := computerTaskService.CreateComputerTask(task); err != nil {
		global.GVA_LOG.Error("创建失败!", zap.Error(err))
		response.FailWithMessage("创建失败", c)
	} else {
		response.OkWithMessage("创建成功", c)
	}
}

//删除电脑任务列表
func (a *ComputerTaskApi) DeleteComputerTask (c *gin.Context) {
	var task newCentralControl.ComputerTask
	_ = c.ShouldBindJSON(&task)
	//数据校验
	if err := utils.Verify(task, utils.ComputerTaskVerify); err != nil {
		response.FailWithMessage(err.Error(), c)
		return
	}
	if err := computerTaskService.DeleteComputerTask(task); err != nil {
		global.GVA_LOG.Error("删除失败!", zap.Error(err))
		response.FailWithMessage("删除失败", c)
	} else {
		response.OkWithMessage("删除成功", c)
	}

}

//更新电脑任务列表
func (a *ComputerTaskApi) UpdateComputerTask (c *gin.Context) {
	var task newCentralControl.ComputerTask
	_ = c.ShouldBindJSON(&task)
	//数据校验
	if err := utils.Verify(task, utils.ComputerTaskVerify); err != nil {
		response.FailWithMessage(err.Error(), c)
		return
	}
	if err := computerTaskService.UpdateComputerTask(task); err != nil {
		global.GVA_LOG.Error("更新失败!", zap.Error(err))
		response.FailWithMessage("更新失败", c)
	} else {
		response.OkWithMessage("更新成功", c)
	}
}

//通过id单独获取电脑任务
func (a *ComputerTaskApi) GetComputerTaskById (c *gin.Context)  {
	var id request.GetById
	_ = c.ShouldBindJSON(&id)
	if err := utils.Verify(id, utils.IdVerify); err != nil {
		response.FailWithMessage(err.Error(), c)
		return
	}
	if task, err := computerTaskService.GetComputerTaskById(id.ID); err != nil {
		global.GVA_LOG.Error("获取失败!", zap.Error(err))
		response.FailWithMessage("获取失败", c)
	}else {
		response.OkWithDetailed(task, "获取成功", c)
	}
}

//更改任务状态
func (a *ComputerTaskApi) StatusChange (c *gin.Context)  {
	var paramsInfo newCentralControlRequest.UpdateTaskStatus
	_ = c.ShouldBindJSON(&paramsInfo)
	if paramsInfo.Status == 0 {
		response.FailWithMessage("状态值不能为空", c)
		return
	}
	if paramsInfo.Id == 0 {
		response.FailWithMessage("Id不能为空", c)
		return
	}
	if err := computerTaskService.UpdateTaskStatus(paramsInfo); err != nil {
		global.GVA_LOG.Error("修改失败!", zap.Error(err))
		response.FailWithMessage(err.Error(), c)
	} else {
		response.OkWithMessage("修改成功", c)
	}
}

//显示电脑任务列表
func (a *ComputerTaskApi) GetComputerTaskList (c *gin.Context) {
	var pageInfo newCentralControlRequest.SearchComputerTaskParams
	_ = c.ShouldBindJSON(&pageInfo)
	//页面信息校验
	if err := utils.Verify(pageInfo.PageInfo, utils.PageInfoVerify); err != nil{
		response.FailWithMessage(err.Error(), c)
		return
	}
	if list, total, err := computerTaskService.GetComputerTaskList(pageInfo.ComputerTask, pageInfo.PageInfo, pageInfo.OrderKey, pageInfo.Desc); err != nil {
		global.GVA_LOG.Error("获取失败!", zap.Error(err))
		response.FailWithMessage("获取失败", c)
	} else {
		response.OkWithDetailed(response.PageResult{
			List:     list,
			Total:    total,
			Page:     pageInfo.Page,
			PageSize: pageInfo.PageSize,
		}, "获取成功", c)
	}
}

//获取游戏配置项
func (a *ComputerTaskApi) GetGameConfInfo (c * gin.Context) {
	info, err := computerTaskService.GetGameConfInfo()
	if err != nil {
		global.GVA_LOG.Error("获取失败!", zap.Error(err))
		response.FailWithMessage("获取失败", c)
	}else {
		response.OkWithDetailed(info, "获取成功", c)
	}
}

//获取下发任务
func (a *ComputerTaskApi) GetRunningTasks(c *gin.Context) {
	pcCode := c.Query("pc_code")
	if pcCode == "" {
		response.FailWithMessage("电脑编号不能为空", c)
		return
	}
	err, list := computerTaskService.GetRunningTasks(pcCode)
	if err != nil {
		global.GVA_LOG.Error("获取失败!", zap.Error(err))
		response.FailWithMessage("获取失败", c)
	} else {
		response.OkWithDetailed(list, "获取成功", c)
	}
}

//上传租机编号
func (a *ComputerTaskApi) UploadPcInfo(c *gin.Context) {
	pcCode := c.Query("pc_code")
	pcName := c.Query("pc_name")
	user := c.Query("user")
	if pcCode == "" {
		response.FailWithMessage("电脑编号不能为空", c)
		return
	}
	if pcName == "" {
		response.FailWithMessage("电脑名不能为空", c)
		return
	}
	if user == "" {
		response.FailWithMessage("负责人不能为空", c)
		return
	}
	if err := computerTaskService.UploadPcInfo(pcCode, pcName, user); err!= nil {
		global.GVA_LOG.Error("上传失败!", zap.Error(err))
		response.FailWithMessage("上传失败", c)
	} else {
		response.OkWithMessage("上传成功", c)
	}

}