mtmber

business/jxstore/event/event.go

@@ -396,3 +396,17 @@ func SendSysMessage(ctx *jxcontext.Context, imMessageRecord *model.ImMessageReco
 	err = dao.CreateEntity(db, imMessageRecord)
 	return err
 }
+
+func DeleteMessageRecord(ctx *jxcontext.Context) (err error) {
+	var (
+		db = dao.GetDB()
+	)
+	sql := `
+		DELETE FROM im_message_record WHERE created_at < ? AND group_id <> ?
+	`
+	sqlParams := []interface{}{
+		time.Now().AddDate(0, 0, -3), model.SysGroupID,
+	}
+	_, err = dao.ExecuteSQL(db, sql, sqlParams)
+	return err
+}

business/jxstore/misc/misc.go

@@ -3,6 +3,8 @@ package misc
 import (
 	"time"
 
+	"git.rosy.net.cn/jx-callback/business/jxstore/event"
+
 	"git.rosy.net.cn/jx-callback/business/jxstore/cms"
 	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
 
@@ -29,6 +31,8 @@ func doDailyWork() {
 	cms.RefreshJobStatus(jxcontext.AdminCtx)
 	//刷新用户会员时间
 	cms.RefreshUserMemberStatus(jxcontext.AdminCtx)
+	//删除聊天记录
+	event.DeleteMessageRecord(jxcontext.AdminCtx)
 }
 
 // 按时间序列循环

business/model/dao/dao_job.go

@@ -379,10 +379,13 @@ func GetJobTimers(db *DaoDB, status int) (jobTimers []*model.JobTimer, err error
 	return jobTimers, err
 }
 
-func GetMtMembers(db *DaoDB) (mtMembers []*model.MtMember, err error) {
+func GetMtMembers(db *DaoDB) (num int, err error) {
+	var mtMembers []*model.MtMember
 	sql := `
-		SELECT * FROM mt_member
+		SELECT * FROM mt_member WHERE deleted_at = ? 
 	`
-	err = GetRows(db, &mtMembers, sql, nil)
+	sqlParams := []interface{}{utils.DefaultTimeValue}
-	return mtMembers, err
+	err = GetRows(db, &mtMembers, sql, sqlParams)
+	num = len(mtMembers)
+	return num, err
 }

controllers/job_controller.go

@@ -227,10 +227,10 @@ func (c *JobController) RechargeMtMembers() {
 
 // @Title 查看美团会员
 // @Description 查看美团会员
-// @Param	token			header		string	true	"认证token"
+// @Param	token			header		string	false	"认证token"
 // @Success 200 {object} controllers.CallResult
 // @Failure 200 {object} controllers.CallResult
-// @router /GetMtMembers [post]
+// @router /GetMtMembers [get]
 func (c *JobController) GetMtMembers() {
 	c.callGetMtMembers(func(params *tJobGetMtMembersParams) (retVal interface{}, errCode string, err error) {
 		retVal, err = dao.GetMtMembers(dao.GetDB())