Merge remote-tracking branch 'origin/master'

api/v1/task/central_control_conf.go

@@ -27,7 +27,7 @@ func (a *CentralControlApi) CreateCentralControlConf (c *gin.Context)  {
 		response.FailWithMessage("请传入脚本名称", c)
 		return
 	}
-	if err := utils.Verify(conf, utils.GameChannelVerify); err != nil {
+	if err := utils.Verify(conf, utils.CentralControlConfVerify); err != nil {
 		response.FailWithMessage(err.Error(), c)
 		return
 	}

api/v1/task/urgent_task_conf.go

@@ -25,13 +25,32 @@ func (a *UrgentTaskApi) GetUnusedPc (c *gin.Context)  {
 
 //创建紧急任务
 func (a *UrgentTaskApi) CreateUrgentTask (c *gin.Context)  {
-	var task1 task.UrgentTaskConf
+	var task1 task.CreateAndUpdateUrgentTaskConf
 	_ = c.ShouldBindJSON(&task1)
-	if err := utils.Verify(task1, utils.UrgentTaskVerify); err != nil {
-		response.FailWithMessage(err.Error(), c)
+	var pcCodeString string
+	if task1.TaskId == 0 {
+		response.FailWithMessage("请传入任务id", c)
 		return
 	}
-	if err := urgentTaskService.CreateUrgentTask(task1); err != nil {
+	if len(task1.PcCode) == 0 {
+		response.FailWithMessage("请传入租机列表", c)
+		return
+	}
+	//处理pc_code数组
+	for k,pcCode := range task1.PcCode{
+		if k != len(task1.PcCode) - 1 {
+			pcCodeString = pcCodeString + pcCode + ","
+		} else {
+			pcCodeString = pcCodeString + pcCode
+		}
+	}
+	//创建实体
+	entity := task.UrgentTaskConf {
+		Id: task1.Id,
+		TaskId: task1.TaskId,
+		PcCode: pcCodeString,
+	}
+	if err := urgentTaskService.CreateUrgentTask(entity); err != nil {
 		global.GVA_LOG.Error("创建失败!", zap.Error(err))
 		response.FailWithMessage(err.Error(), c)
 	} else {
@@ -69,13 +88,34 @@ func (a *UrgentTaskApi) DeleteUrgentTaskByIds (c *gin.Context) {
 
 //更新紧急任务
 func (a *UrgentTaskApi) UpdateUrgentTask (c *gin.Context)  {
-	var task1 task.UrgentTaskConf
+	var task1 task.CreateAndUpdateUrgentTaskConf
 	_ = c.ShouldBindJSON(&task1)
-	if err := utils.Verify(task1, utils.UrgentTaskVerify); err != nil{
-		response.FailWithMessage(err.Error(), c)
+	var pcCodeString string
+	if task1.TaskId == 0 {
+		response.FailWithMessage("请传入任务id", c)
+		return
+	}
+	if len(task1.PcCode) == 0 {
+		response.FailWithMessage("请传入租机列表", c)
 		return
 	}
-	if err := urgentTaskService.UpdateUrgentTask(task1); err != nil{
+	//处理pc_code数组
+	for k,pcCode := range task1.PcCode{
+		if k != len(task1.PcCode) - 1 {
+			pcCodeString = pcCodeString + pcCode + ","
+		} else {
+			pcCodeString = pcCodeString + pcCode
+		}
+	}
+	//创建实体
+	entity := task.UrgentTaskConf {
+		Id: task1.Id,
+		TaskId: task1.TaskId,
+		PcCode: pcCodeString,
+		CreateDate: task1.CreateDate[:10],
+	}
+
+	if err := urgentTaskService.UpdateUrgentTask(entity); err != nil{
 		global.GVA_LOG.Error("更新失败!", zap.Error(err))
 		response.FailWithMessage("更新失败", c)
 	} else {

model/task/central_control_conf.go

@@ -6,8 +6,8 @@ type CentralControlConf struct {
 	Id            int                  `json:"id"`
 	Mirror        string               `json:"mirror"`         //镜像
 	Script        string               `json:"script"`         //脚本
-	CloneMode     string               `json:"clone_mode"`     //克隆模式
-	SimulatorType string               `json:"simulator_type"` //模拟器类型
+	CloneMode     int                  `json:"clone_mode"`     //克隆模式
+	SimulatorType int                  `json:"simulator_type"` //模拟器类型
 	Resolution    string               `json:"resolution"`     //分辨率
 	Zoom          string               `json:"zoom"`           //缩放
 	Timeout       int                  `json:"timeout"`        //超时时间
@@ -16,7 +16,7 @@ type CentralControlConf struct {
 	TaskId        int                  `json:"task_id"`        //任务id
 	GameId        int                  `json:"game_id"`        //游戏id
 	Priority      string               `json:"priority"`       //优先级
-	GameType      int                  `json:"game_type"`   //任务类型
+	GameType      int                  `json:"game_type"`      //任务类型
 	TxChannel     string               `json:"tx_channel"`     //'腾讯渠道号',
 	TxGameId      string               `json:"tx_game_id"`     //'腾讯游戏id',
 	MzChannel     string               `json:"mz_channel"`     //'魅族渠道号',
@@ -28,4 +28,4 @@ type CentralControlConf struct {
 
 func (CentralControlConf) TableName() string {
 	return "central_control_conf"
-}
+}

model/task/urgent_task_conf.go

@@ -11,6 +11,15 @@ type UrgentTaskConf struct {
 	UpdateTime typeManage.LocalTime `json:"update_time"`
 }
 
+type CreateAndUpdateUrgentTaskConf struct {
+	Id         int                  `json:"id"`
+	TaskId     int                  `json:"task_id"`     //任务id
+	PcCode     []string             `json:"pc_code"`     //电脑编号
+	CreateDate string               `json:"create_date"` //创建日期
+	CreateTime typeManage.LocalTime `json:"create_time"`
+	UpdateTime typeManage.LocalTime `json:"update_time"`
+}
+
 //紧急任务请求
 type UrgentTaskConfRequest struct {
 	Id         int                  `json:"id"`

service/task/central_control_conf.go

@@ -49,7 +49,7 @@ func (s *CentralControlService) UpdateCentralControlConf(conf task.CentralContro
 	if !errors.Is(err, gorm.ErrRecordNotFound) {
 		return errors.New("已存在相同的task_id，无法更改")
 	}
-	return global.GVA_DB.Model(&task.CentralControlConf{}).Where("id", conf.Id).Updates(&conf).Error
+	return global.GVA_DB.Model(&task.CentralControlConf{}).Where("id", conf.Id).Save(&conf).Error
 }
 
 //通过id获取单条配置

service/task/urgent_task_conf.go

@@ -52,7 +52,7 @@ func (s *UrgentTaskService) DeleteUrgentTaskByIds(ids []int) (err error){
 func (s *UrgentTaskService) UpdateUrgentTask(task1 task.UrgentTaskConf) (err error) {
 	//查找此task_id是否存在，如果存在不更新，否则更新
 	var entity task.UrgentTaskConf
-	err = global.GVA_DB.Model(&task.UrgentTaskConf{}).Where("task_id = ? and id != ?", task1.TaskId, task1.Id).First(&entity).Error
+	err = global.GVA_DB.Model(&task.UrgentTaskConf{}).Where("task_id = ? and id != ? and create_date = ?", task1.TaskId, task1.Id, task1.CreateDate).First(&entity).Error
 	if !errors.Is(err , gorm.ErrRecordNotFound) {
 		return errors.New("已存在此task_id的任务，更新失败")
 	}
@@ -118,8 +118,8 @@ func (s *UrgentTaskService) GetUrgentTaskList(conf task.UrgentTaskConfRequest, i
 		}
 	}
 	//遍历更改日期格式
-	//for i, _ := range confList {
-	//	confList[i].CreateDate = confList[i].CreateDate[:10]
-	//}
+	for i, _ := range confList {
+		confList[i].CreateDate = confList[i].CreateDate[:10]
+	}
 	return confList, total, err
 }