notify

Documentation

Overview

**************************************************

** @Desc : This file for ...
** @Time : 2019/11/20 1:35
** @Author : yuebin
** @File : order_notify
** @Last Modified by : yuebin
** @Last Modified time: 2019/11/20 1:35
** @Software: GoLand

***************************************************

**************************************************

** @Desc : This file for ...
** @Time : 2019/11/20 1:35
** @Author : yuebin
** @File : payfor_notify
** @Last Modified by : yuebin
** @Last Modified time: 2019/11/20 1:35
** @Software: GoLand

***************************************************

Index

• Constants
• func CreateOrderDelayQueue()
• func CreateOrderNotifyConsumer()
• func GetOrderNotifyMinute(times int) int
• func OrderNotifyTimer(task OrderNotifyTask)
• func SendOrderNotify(bankOrderId string)
• type OrderNotifyTask

Constants

const (
	LimitTimes = 5 //最多通知5次
)

Functions

func CreateOrderDelayQueue

func CreateOrderDelayQueue()

读取一小时之内，未发送成功，并且还没有到达回调限制次数的记录读取，存入延迟队列

func CreateOrderNotifyConsumer

func CreateOrderNotifyConsumer()

创建订单回调消费者

func GetOrderNotifyMinute

func GetOrderNotifyMinute(times int) int

func OrderNotifyTimer

func OrderNotifyTimer(task OrderNotifyTask)

func SendOrderNotify

func SendOrderNotify(bankOrderId string)

给商户发送订单结果

Types

type OrderNotifyTask

type OrderNotifyTask struct {
	Delay           *time.Timer
	MerchantOrderId string
	BankOrderId     string
	FirstNotifyTime string
	NotifyTimes     int
	LimitTimes      int
	Status          string //success-通知成功，其余的为待通知或者通知未完成
}