package youngee_talent_service

import (
	"youngmini_server/app/dao"
	"youngmini_server/app/model"
	"youngmini_server/app/model/youngee_talent_model"

	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/net/ghttp"
	"github.com/gogf/gf/os/gtime"
)

// 上传脚本service
func AddTaskScript(r *ghttp.Request) *TalentHttpResult {
	var scriptInfoReq *youngee_talent_model.AddTaskScriptRequest
	err := r.ParseForm(&scriptInfoReq)
	if err != nil {
		return &TalentHttpResult{Code: -1, Msg: err.Error()}
	}

	scriptInfo := model.YounggeeScriptInfo{
		TaskId:   scriptInfoReq.TaskId,
		Content:  scriptInfoReq.Content,
		CreateAt: gtime.Now(),
		IsReview: 0,
	}
	_, err = g.DB().Model(model.YounggeeScriptInfo{}).Data(scriptInfo).Insert()
	if err != nil {
		return &TalentHttpResult{Code: -2, Msg: "YounggeeScriptInfo insert failed"}
	}

	_, err = g.Model(dao.YoungeeTaskInfo.Table).Where("task_id = ?", scriptInfoReq.TaskId).Increment("script_status", 1)
	if err != nil {
		return &TalentHttpResult{Code: -3, Msg: "Get task info failed"}
	}

	return &TalentHttpResult{Code: 0, Msg: "success"}
}

// 查询脚本service
func GetTaskScript(r *ghttp.Request) *TalentHttpResult {
	taskId := r.Get("task_id")

	res, err := g.DB().Model(dao.YounggeeScriptInfo.Table).All("task_id", taskId)
	if err != nil {
		return &TalentHttpResult{Code: -2, Msg: err.Error()}
	}

	return &TalentHttpResult{Code: 0, Msg: "success", Data: res}
}