cmd

package
v0.0.0-...-8be382e Latest Latest
Warning

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

Go to latest
Published: Oct 19, 2020 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AlertOverdueAftersales

func AlertOverdueAftersales(job *work.Job) error

AlertOverdueAftersales 超时告警

func AlertToAudit

func AlertToAudit(job *work.Job) error

AlertToAudit 待审核告警

func AutoAudit

func AutoAudit(job *work.Job) error

AutoAudit demo模式下自动审批

func AutoAward

func AutoAward(job *work.Job) error

AutoAward demo模式下自动增加奖金

func AutoCreateAftersale

func AutoCreateAftersale(job *work.Job) error

AutoCreateAftersale 创建order_items之后自动创建一个售后订单

func AutoDeliverOrders

func AutoDeliverOrders(job *work.Job) error

AutoDeliverOrders 自动妥投配送时间小于当前时间的订单

func AutoFine

func AutoFine(job *work.Job) error

AutoFine demo模式下自动罚款

func AutoFinish

func AutoFinish(job *work.Job) error

AutoFinish demo模式下自动完成

func AutoGenerateAftersales

func AutoGenerateAftersales(job *work.Job) error

AutoGenerateAftersales demo模式下自动创建服务单

func AutoInquire

func AutoInquire(job *work.Job) error

AutoInquire demo模式下自动预约

func AutoProcess

func AutoProcess(job *work.Job) error

AutoProcess demo模式下自动接单

func AutoSchedule

func AutoSchedule(job *work.Job) error

AutoSchedule demo模式下自动派单

func AutoWithdraw

func AutoWithdraw(job *work.Job) error

AutoWithdraw demo模式下自动提现

func Compile

func Compile()

func Evaluate

func Evaluate()

func EvaluateOrder

func EvaluateOrder(order orders.Order, knowledgeBase *model.KnowledgeBase, engine *engine.Grool)

func ExpireAftersales

func ExpireAftersales(job *work.Job) error

ExpireAftersales 任务指派后 after_sale的状态为scheduled, 如果师傅20分钟之内没有响应,自动变为overdue状态

func ExportMobilePhones

func ExportMobilePhones(job *work.Job) error

ExportMobilePhones 定时导出昨日电话号码

func ExportOrderDetails

func ExportOrderDetails(job *work.Job) error

ExportOrderDetails 定时导出订单详情

func ExportOrderFees

func ExportOrderFees(job *work.Job) error

ExportOrderFees 定时导出订单运费结算

func ExportOrderFollowUps

func ExportOrderFollowUps(job *work.Job) error

ExportOrderFollowUps 定时导出订单回访

func FreezeAftersales

func FreezeAftersales(job *work.Job) error

FreezeAftersales 已审核的服务单冻结7天才能结算

func Log

func Log(job *work.Job, next work.NextMiddlewareFunc) error

Log 开始执行任务的时候输出日志

func RandomString

func RandomString(n int) string

func SendWechatTemplateMsg

func SendWechatTemplateMsg(job *work.Job) error

SendWechatTemplateMsg 发送微信模版消息(当任务指派给师傅或者订单解冻了,需要给师傅推送一条微信模板消息)

func StartFaktoryWorker

func StartFaktoryWorker()

StartFaktoryWorker start faktory worker just run `go StartFaktoryWorker()` in main.go

func StartHealthCheck

func StartHealthCheck()

StartHealthCheck start health check just run go StartHealthCheck() in main.go

func StartWebhookd

func StartWebhookd()

StartWebhookd start webhookd just run `go StartWebhookd()` in main.go

func StartWorkWebUI

func StartWorkWebUI()

StartWorkWebUI serves gocraft/work UI https://github.com/gocraft/work/blob/master/cmd/workwebui/main.go

func StartWorkerPool

func StartWorkerPool()

StartWorkerPool start gocraft/work worker pool just run `go StartWorkerPool()` in main.go run workwebui -redis="redis:6379" -ns="qor" -listen=":5040" open localhost:5040 to view jobs ui https://crontab.guru/ https://crontab.guru/examples.html

func UnclutterOldNotifications

func UnclutterOldNotifications(job *work.Job) error

UnclutterOldNotifications 干掉太久的已读通知

func UnfreezeAftersales

func UnfreezeAftersales(job *work.Job) error

UnfreezeAftersales 解冻超过7天的,自动结算,金额算到师傅名下

func UpdateBalance

func UpdateBalance(job *work.Job) error

UpdateBalance 计算并更新某个师傅的账户额度

func UpdateBalances

func UpdateBalances(job *work.Job) error

UpdateBalances 统计每个师傅的冻结金额和可结算金额并更新到Balances表

func UpdateOrderItems

func UpdateOrderItems(job *work.Job) error

UpdateOrderItems 更新ordre_items 的 order_id

Types

type Context

type Context struct {
	// contains filtered or unexported fields
}

Context For gocraft/work

type Helper

type Helper struct {
}

func (*Helper) Contains

func (h *Helper) Contains(s1 string, s2 string) bool

func (*Helper) ContainsAll

func (h *Helper) ContainsAll(s1 string, s2 []string) bool

func (*Helper) ContainsAny

func (h *Helper) ContainsAny(s1 string, s2 string) bool

func (*Helper) GetCategory

func (h *Helper) GetCategory(s1 string) string

func (*Helper) NotContains

func (h *Helper) NotContains(s1 string, s2 string) bool

func (*Helper) RandomRuleName

func (h *Helper) RandomRuleName() string

type Item

type Item struct {
	OrderID uint

	Quantity uint
	Price    float32

	// 单件商品的配送费 根据规则推断出来的
	DeliveryFee float32

	ProductNo string `json:"product_no"`
	OrderNo   string `json:"order_no"`
	ItemName  string `json:"product_name"`

	CustomerAddress string
}

type OrderPayload

type OrderPayload struct {
	UUID  string `json:"uuid"`
	Order struct {
		OrderNo              string      `json:"order_no"`
		CustomerAddress      string      `json:"customer_address"`
		CustomerName         string      `json:"customer_name"`
		CustomerPhone        string      `json:"customer_phone"`
		ReservedDeliveryTime string      `json:"reserved_delivery_time"`
		ReservedSetupTime    string      `json:"reserved_setup_time"`
		IsDeliveryAndSetup   string      `json:"is_delivery_and_setup"`
		CreatedAt            time.Time   `json:"created_at"`
		UpdatedAt            time.Time   `json:"updated_at"`
		Receivables          json.Number `json:"receivables"`
		OrderItems           []struct {
			OrderNo     string      `json:"order_no"`
			ProductNo   string      `json:"product_no"`
			ProductName string      `json:"product_name"`
			Quantity    json.Number `json:"quantity"`
			Install     string      `json:"install"`
			Volume      json.Number `json:"volume"`
			Weight      json.Number `json:"weight"`
			CreatedAt   time.Time   `json:"created_at"`
			UpdatedAt   time.Time   `json:"updated_at"`
		} `json:"order_items"`
	} `json:"order"`
}

OrderPayload 函数用来接收并发送消息到Pubsub的结构体

type TemplateMsgResp

type TemplateMsgResp struct {
	ErrCode int    `json:"errcode"`
	ErrMsg  string `json:"errmsg"`
	MsgID   int64  `json:"msgid"`
}

TemplateMsgResp 发送模板消息返回结果

Jump to

Keyboard shortcuts

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