package nsq

import (
	"apsClient/model"
	"apsClient/pkg/logx"
	"encoding/json"
	"fmt"
)

type MsgHandler interface {
	HandleMessage(data []byte) (err error)
}

type ScheduleTask struct {
}

func (slf *ScheduleTask) HandleMessage(data []byte) (err error) {
	fmt.Println(string(data))

	var tasks = make([]*DeliverScheduleTask, 0)

	err = json.Unmarshal(data, &tasks)
	if err != nil {
		logx.Errorf("ScheduleTask HandleMessage Unmarshal json err: %v", err.Error())
		return err
	}
	for _, task := range tasks {
		taskRecord := model.ScheduleTask{
			Id:          0,
			OrderId:     task.Order.OrderID,
			ProductId:   task.Order.ProductID,
			ProductName: task.Order.ProductName,
			Amount:      task.Order.Amount,
			Unit:        task.Order.Unit,
			StartTime:   task.Order.StartTime,
			EndTime:     task.Order.EndTime,
		}
		jsonStr, err := json.Marshal(task)
		if err != nil {
			logx.Errorf("ScheduleTask HandleMessage Marshal err: %v, old: %#v", err.Error(), task)
			return err
		}
		taskRecord.Data = string(jsonStr)
		err = model.NewScheduleTaskSearch(nil).Create(&taskRecord)
		if err != nil {
			logx.Errorf("ScheduleTask HandleMessage Create taskRecord err: %v,  record: %#v", err.Error(), taskRecord)
			return err
		}
	}
	return nil
}