mirror of
https://github.com/yangjian102621/geekai.git
synced 2025-09-17 16:56:38 +08:00
chore: change xxl-job name
This commit is contained in:
parent
51407abe44
commit
e311a39632
@ -38,13 +38,13 @@ func NewXXLJobExecutor(config *types.AppConfig, db *gorm.DB) *XXLJobExecutor {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (e *XXLJobExecutor) Run() error {
|
func (e *XXLJobExecutor) Run() error {
|
||||||
e.executor.RegTask("ClearOrder", e.ClearOrder)
|
e.executor.RegTask("ClearOrders", e.ClearOrders)
|
||||||
e.executor.RegTask("ResetVipCalls", e.ResetVipCalls)
|
e.executor.RegTask("ResetVipCalls", e.ResetVipCalls)
|
||||||
return e.executor.Run()
|
return e.executor.Run()
|
||||||
}
|
}
|
||||||
|
|
||||||
// ClearOrder 清理未支付的订单,如果没有抛出异常则表示执行成功
|
// ClearOrders 清理未支付的订单,如果没有抛出异常则表示执行成功
|
||||||
func (e *XXLJobExecutor) ClearOrder(cxt context.Context, param *xxl.RunReq) (msg string) {
|
func (e *XXLJobExecutor) ClearOrders(cxt context.Context, param *xxl.RunReq) (msg string) {
|
||||||
logger.Debug("执行清理未支付订单...")
|
logger.Debug("执行清理未支付订单...")
|
||||||
var sysConfig model.Config
|
var sysConfig model.Config
|
||||||
res := e.db.Where("marker", "system").First(&sysConfig)
|
res := e.db.Where("marker", "system").First(&sysConfig)
|
||||||
|
@ -11,6 +11,7 @@ services:
|
|||||||
- CONFIG_FILE=config.toml
|
- CONFIG_FILE=config.toml
|
||||||
ports:
|
ports:
|
||||||
- "5678:5678"
|
- "5678:5678"
|
||||||
|
- "9999:9999"
|
||||||
volumes:
|
volumes:
|
||||||
- /usr/share/zoneinfo/Asia/Shanghai:/etc/localtime
|
- /usr/share/zoneinfo/Asia/Shanghai:/etc/localtime
|
||||||
- ./conf/config.toml:/var/www/app/config.toml
|
- ./conf/config.toml:/var/www/app/config.toml
|
||||||
|
Loading…
Reference in New Issue
Block a user