notify

package
v0.0.0-...-fab86cd Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 21, 2019 License: GPL-3.0 Imports: 11 Imported by: 0

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

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

Variables

This section is empty.

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-通知成功,其余的为待通知或者通知未完成
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL