package task

import (
	"lone-services/pkg/utils"
	"lone-services/services/wecom/internal/dao"
	"lone-services/services/wecom/internal/model"

	jsoniter "github.com/json-iterator/go"
)

type Service struct{}

func (s Service) Create(job dao.WeComJob, taskId string, detailUrl string) error {
	payload, err := jsoniter.Marshal(job)
	if err != nil {
		return err
	}
	task := &dao.WecomReviewTask{
		TaskId:       taskId,
		ObjId:        job.BizId,
		ObjType:      job.BizType,
		Type:         job.Type,
		Payload:      string(payload),
		DetailUrl:    detailUrl,
		ReviewStatus: dao.WecomReviewPending,
		ResponseCode: utils.StringEmpty,
		AgentId:      utils.GetConfigInt("wecom.review_agent_id"),
		CreatedAt:    utils.Now(),
	}
	return model.ReviewTaskModel{}.Init().Create(task)
}