diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go index fdd38a07d..fd17971e4 100644 --- a/business/jxstore/cms/job.go +++ b/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 { diff --git a/business/model/dao/dao_job.go b/business/model/dao/dao_job.go index bc3a2fb4d..9ef3d2623 100644 --- a/business/model/dao/dao_job.go +++ b/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 *