package notify

import (
	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/factory"
	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
)

// 周期评估短信通知
// 条件：周期自评结束前4个小时，且还未完成评估填写
type NotifySummaryEvaluation struct {
}

func (notices *NotifySummaryEvaluation) Init() *NotifySummaryEvaluation {
	return &NotifySummaryEvaluation{}
}

func (notices *NotifySummaryEvaluation) From() string {
	return "SummaryEvaluation"
}

// AddTask 添加待执行的短信通知任务
func (notices *NotifySummaryEvaluation) AddTask(index string, phone string, param map[string]string) error {

	return nil
}

// RunTask 执行短信通知任务
func (notice *NotifySummaryEvaluation) RunTask() error {

	return nil
}

func (notice *NotifySummaryEvaluation) addNewSms(newSms *domain.LogSms) error {
	transactionContext, err := factory.CreateTransactionContext(nil)
	if err != nil {
		return err
	}
	if err := transactionContext.StartTransaction(); err != nil {
		return err
	}
	defer func() {
		_ = transactionContext.RollbackTransaction()
	}()
	logSmsRepo := factory.CreateLogSmsRepository(map[string]interface{}{"transactionContext": transactionContext})
	err = logSmsRepo.Save(newSms)
	if err != nil {
		return err
	}
	if err := transactionContext.CommitTransaction(); err != nil {
		return err
	}
	return nil
}