package biz

import (
	"context"
	"fmt"
	"github.com/go-kratos/kratos/v2/log"
	"time"
	v1 "voucher/api/v1"
	"voucher/internal/biz/bo"
	"voucher/internal/biz/vo"
	"voucher/internal/pkg/lock"
)

func (this *VoucherBiz) CmbQuery(ctx context.Context, orderNo string) (resp *v1.CmbQueryReply, err error) {

	c := vo.CmbQueryLockKey.BuildCache([]string{orderNo})

	err = lock.NewMutex(this.rdb.Rdb, c.TTL).Lock(ctx, c.Key, func(ctx context.Context) error {

		order, err3 := this.OrderRepo.GetByOrderNo(ctx, orderNo)
		if err3 != nil {
			return err3
		}

		if err = this.Query(ctx, order); err != nil {
			return err
		}

		status, err3 := order.Status.GetCmbStatusText()
		if err3 != nil {
			return err3
		}

		resp = &v1.CmbQueryReply{
			Ticket:    order.OrderNo,
			Status:    status.GetValue(),
			TransDate: time.Now().Format("20060102150405"),
			OrgNo:     this.bc.Cmb.OrgNo,
			Ext:       "",
		}

		return nil
	})

	return
}

func (this *VoucherBiz) Query(ctx context.Context, order *bo.OrderBo) error {

	status, err := this.WechatCpnRepo.Query(ctx, order)
	if err != nil {
		return err
	}

	if order.Status == status {
		log.Warnf("券状态未改变:%s，忽略不处理,orderNo:%s", order.Status.GetText(), order.OrderNo)
		return nil
	}

	if err = this.UpdateOrderStatus(ctx, order.ID, status); err != nil {
		return err
	}

	order.Status = status

	return nil
}

func (this *VoucherBiz) QueryOrder(ctx context.Context, orderNo string) (string, error) {

	order, err3 := this.OrderRepo.GetByOrderNo(ctx, orderNo)
	if err3 != nil {
		return "", err3
	}

	status, err := this.WechatCpnRepo.Query(ctx, order)
	if err != nil {
		return "", err
	}

	return fmt.Sprintf("orderNo:%s,订单状态:%s,微信查询返回状态:%s", orderNo, order.Status.GetText(), status.GetText()), nil
}