diff --git a/app/admin/models/mall.go b/app/admin/models/mall.go index 39e85d2..6ac5e10 100644 --- a/app/admin/models/mall.go +++ b/app/admin/models/mall.go @@ -1700,3 +1700,44 @@ GROUP BY b.goods_id 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) + } + } +} diff --git a/cmd/api/server.go b/cmd/api/server.go index 06847f1..c08c9df 100644 --- a/cmd/api/server.go +++ b/cmd/api/server.go @@ -207,6 +207,18 @@ func run() error { 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() }()