aa

business/jxstore/cms/job.go

@@ -9,6 +9,7 @@ import (
 
 	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
 
+	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
 	"git.rosy.net.cn/baseapi/platformapi/jdeclpapi"
 
 	"git.rosy.net.cn/jx-callback/globals"
@@ -635,9 +636,9 @@ func RechargeMtMembers(ctx *jxcontext.Context, phone int) (errCode string, err e
 			dao.Commit(db)
 		}
 	}()
-	mtMembers, err := dao.GetMtMembers(db)
-	if len(mtMembers) < 10 {
-		ddmsg.SendUserMessage(msgType, userID, title, content)
+	nums, err := dao.GetMtMembers(db)
+	if nums < 10 {
+		ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "F4836F9238F611EB9101525400C36BDA", "美团会员券", "美团会员券仅剩"+utils.Int2Str(nums)+"张了！")
 	}
 	mtMember, err := dao.GetMtMember(db)
 	if mtMember == nil {

business/model/dao/dao_job.go

@@ -368,17 +368,6 @@ func GetMtMember(db *DaoDB) (mtMember *model.MtMember, err error) {
 	return mtMember, err
 }
 
-func GetMtMembers(db *DaoDB) (mtMembers []*model.MtMember, err error) {
-	sql := `
-		SELECT *
-		  FROM mt_member
-		 WHERE deleted_at = ?  
-	`
-	sqlParams := []interface{}{utils.DefaultTimeValue}
-	err = GetRow(db, &mtMembers, sql, sqlParams)
-	return mtMembers, err
-}
-
 func GetJobTimers(db *DaoDB, status int) (jobTimers []*model.JobTimer, err error) {
 	sql := `
 		SELECT *