order_check.go

package unipay

import (
	"das_sub_account/notify"
	"das_sub_account/tables"
	"fmt"
	"github.com/dotbitHQ/das-lib/http_api"
	"time"
)

func (t *ToolUniPay) RunOrderCheck() {
	tickerOrder := time.NewTicker(time.Minute)
	t.Wg.Add(1)
	go func() {
		defer http_api.RecoverPanic()
		for {
			select {
			case <-tickerOrder.C:
				log.Info("RunOrderCheck start ...")
				if err := t.doOrderCheck(); err != nil {
					log.Error("doOrderCheck err:", err.Error())
					notify.SendLarkErrNotify("doOrderCheck", err.Error())
				}
				log.Info("RunOrderCheck end ...")
			case <-t.Ctx.Done():
				log.Info("RunOrderCheck done")
				t.Wg.Done()
				return
			}
		}
	}()
}

func (t *ToolUniPay) doOrderCheck() error {
	list, err := t.DbDao.GetNeedCheckOrderList()
	if err != nil {
		return fmt.Errorf("GetNeedCheckOrderList err: %s", err.Error())
	}
	for _, v := range list {
		switch v.ActionType {
		case tables.ActionTypeMint:
			smtRecord, err := t.DbDao.GetSmtRecordByOrderId(v.OrderId)
			if err != nil {
				return fmt.Errorf("GetSmtRecordByOrderId err: %s", err.Error())
			}
			acc, err := t.DbDao.GetAccountInfoByAccountId(v.AccountId)
			if err != nil {
				return fmt.Errorf("GetAccountInfoByAccountId err: %s", err.Error())
			} else if acc.Id == 0 {
				if smtRecord.Id == 0 {
					continue
				} else if smtRecord.RecordType == tables.RecordTypeClosed {
					notify.SendLarkErrNotify("doOrderCheck", v.OrderId)
				}
			} else {
				newStatus := tables.OrderStatusSuccess
				if smtRecord.Id == 0 || smtRecord.RecordType == tables.RecordTypeClosed {
					newStatus = tables.OrderStatusFail
				}
				if err := t.DbDao.UpdateOrderStatusForCheckMint(v.OrderId, tables.OrderStatusDefault, newStatus); err != nil {
					return fmt.Errorf("UpdateOrderStatusForCheckMint err: %s[%s]", err.Error(), v.OrderId)
				}
			}
		case tables.ActionTypeRenew:
			acc, err := t.DbDao.GetAccountInfoByAccountId(v.AccountId)
			if err != nil {
				return fmt.Errorf("GetAccountInfoByAccountId err: %s", err.Error())
			}
			if acc.Id == 0 {
				notify.SendLarkErrNotify("doRenewOrderCheck", fmt.Sprintf("[%s][%s]", v.OrderId, v.AccountId))
				continue
			}

			smtRecord, err := t.DbDao.GetSmtRecordByOrderId(v.OrderId)
			if err != nil {
				return fmt.Errorf("GetSmtRecordByOrderId err: %s", err.Error())
			}
			if smtRecord.Id == 0 {
				continue
			}
			if smtRecord.RecordType == tables.RecordTypeDefault {
				continue
			}

			newStatus := tables.OrderStatusSuccess
			if smtRecord.RecordType == tables.RecordTypeClosed {
				newStatus = tables.OrderStatusFail
			}
			if err := t.DbDao.UpdateOrderStatusForCheckRenew(v.OrderId, tables.OrderStatusDefault, newStatus); err != nil {
				return fmt.Errorf("UpdateOrderStatusForCheckRenew err: %s[%s]", err.Error(), v.OrderId)
			}
		case tables.ActionTypeCouponCreate:
		default:
			notify.SendLarkErrNotify("doOrderCheck", fmt.Sprintf("doOrderCheck unsupport action %d", v.ActionType))
		}
	}
	return nil
}