重置付费

api/v1/task/game_task.go

@@ -398,3 +398,26 @@ func (s *GameTaskApi) GameList(c *gin.Context) {
 		}, "获取成功", c)
 	}
 }
+
+// @Tags gameTask
+// @Summary 重置付费
+// @Security ApiKeyAuth
+// @accept application/json
+// @Produce application/json
+// @Param data body request.GameTaskRequest true
+// @Success 200 {object} response.Response{msg=string} "更新游戏任务目标"
+// @Router /gameTask/taskResetFee [post]
+func (s *GameTaskApi) TaskResetFee(c *gin.Context) {
+	var api request.GameTaskRequest
+	_ = c.ShouldBindJSON(&api)
+	if err := utils.Verify(api, utils.TaskIdVerify); err != nil {
+		response.FailWithMessage(err.Error(), c)
+		return
+	}
+	if err := taskService.TaskResetFee(api); err != nil {
+		global.GVA_LOG.Error("重置付费失败!", zap.Error(err))
+		response.FailWithMessage("重置付费失败 "+err.Error(), c)
+	} else {
+		response.OkWithMessage("重置付费成功", c)
+	}
+}

router/task/game_task.go

@@ -31,5 +31,6 @@ func (e *GameTaskRouter) InitGameTaskRouter(Router *gin.RouterGroup) {
 		GameTaskRouter1.POST("update", GameTaskApi.UpdateGameTask)
 		GameTaskRouter1.POST("delete", GameTaskApi.DeleteGameTask)
 		GameTaskRouter1.POST("updateTarget", GameTaskApi.UpdateGameTaskTarget)
+		GameTaskRouter1.POST("taskResetFee", GameTaskApi.TaskResetFee)
 	}
 }

service/task/game_task.go

@@ -341,6 +341,8 @@ func (c *GameTask) GetGameTaskById(id int) (gameTask request.GameTaskRequest, er
 	gameTask.PayTarget = requestData.PayTarget
 	gameTask.RetainedTarget = requestData.RetainedTarget
 	gameTask.PayPrice = requestData.PayPrice
+	gameTask.RetainedTargetH = requestData.RetainedTargetH
+	gameTask.NewTargetH = requestData.NewTargetH
 	return
 }
 
@@ -910,3 +912,38 @@ func (s *GameTask) GameStatisticsList(rq request.GameListRequest) (gameTarget []
 	}
 	return
 }
+
+//
+func (s *GameTask) ResetFeeUploadXjf(gameId int) (err error) {
+	url := global.GVA_CONFIG.ExtranetDomain.Control + "/v1/task_statistics/rerun_retained"
+	requestData := map[string]string{
+		"game_id": strconv.Itoa(gameId),
+	}
+	data, code, err := utils.HttpGetReplyCode(url, requestData)
+	if err != nil {
+		return err
+	}
+	fmt.Println(code)
+	if code != 200 {
+		return errors.New(string(data))
+	}
+	return
+}
+
+//@function: TaskResetFee
+//@description: 重置付费
+//@param: api task.GameTask
+//@return: err error
+func (s *GameTask) TaskResetFee(api request.GameTaskRequest) (err error) {
+	var entity task.GameTask
+	err = global.GVA_DB.Where("task_id = ?", api.TaskId).First(&entity).Error
+	if errors.Is(err, gorm.ErrRecordNotFound) {
+		return err
+	}
+	err = s.ResetFeeUploadXjf(api.TaskId)
+	if err != nil {
+		global.GVA_LOG.Error("请求群控数据报错: ", zap.Error(err))
+		return errors.New("请求群控数据报错")
+	}
+	return
+}