Files

32 lines
786 B
Go

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)
}