1、新增商城订单检测的定时任务,用来提醒运营人员发货;

This commit is contained in:
chenlin 2025-02-28 16:46:48 +08:00
parent a7ec104290
commit 195ad99c81
2 changed files with 53 additions and 0 deletions

View File

@ -1700,3 +1700,44 @@ GROUP BY b.goods_id
return list return list
} }
// CheckOnDeliverMall 检测有无待发货的订单,及时提醒运营同事
func CheckOnDeliverMall() {
var orders []GoodsOrder
err := orm.Eloquent.Table("goods_order").Where("state = ?", GoodsOrderStateOnDeliver).Find(&orders).Error
if err != nil {
logger.Errorf("Failed to query orders: %v", err)
return
}
if len(orders) == 0 {
logger.Info("No pending delivery orders.")
return
}
// 获取需要通知的手机号列表
var phoneNumbers = []string{"15019230751", "18025373706"} // 示例多个手机号
// 短信通知逻辑
message := fmt.Sprintf("【明慧科技】温馨提示:小程序商城有%d个待发货订单请及时处理。", len(orders))
err = GtSendMessage(phoneNumbers, message)
status := 1
if err != nil {
status = 2
logger.Error(err.Error())
}
// 记录短信发送情况
for _, phone := range phoneNumbers {
smsSend := &ExpireMemberSmsSend{
Message: message,
SendTime: time.Now(),
Tel: phone,
Status: uint32(status),
}
err = orm.Eloquent.Create(&smsSend).Error
if err != nil {
logger.Errorf("Failed to create SMS record: ", err)
}
}
}

View File

@ -207,6 +207,18 @@ func run() error {
fmt.Println("err:", err) fmt.Println("err:", err)
} }
// 检测小程序商城有无待发货订单
err = s.Every(1).Day().At("09:00").Do(models.CheckOnDeliverMall)
if err != nil {
fmt.Println("err:", err)
}
// 检测小程序商城有无待发货订单
err = s.Every(1).Day().At("14:00").Do(models.CheckOnDeliverMall)
if err != nil {
fmt.Println("err:", err)
}
<-s.Start() <-s.Start()
}() }()