package consumer

import (
	"encoding/json"
	"fmt"

	"github.com/Shopify/sarama"
	"github.com/astaxie/beego/logs"
	syncOrderCmd "gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/application/syncOrder/command"
	syncOrderSrv "gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/application/syncOrder/service"
)

//SyncBestshopOrder 同步
func SyncBestshopOrder(message *sarama.ConsumerMessage) error {
	logs.Info("Done Message claimed:  timestamp = %v, topic = %s offset = %v value = %v \n",
		message.Timestamp, message.Topic, message.Offset, string(message.Value))
	var (
		cmd syncOrderCmd.CreateOrderFromBestshop
		err error
	)
	err = json.Unmarshal(message.Value, &cmd)
	if err != nil {
		return fmt.Errorf("[Consumer][SyncBestshopOrder] 解析kafka数据失败；%s", err)
	}
	if cmd.PartnerId <= 0 {
		logs.Info("[Consumer][SyncBestshopOrder] PartnerId<=0 ,不处理消息")
		return nil
	}
	srv := syncOrderSrv.NewOrderInfoService(nil)
	err = srv.SyncOrderFromBestshop(cmd)
	if err != nil {
		e := fmt.Errorf("[Consumer][SyncBestshopOrder] %s", err)
		return e
	}
	return err
}