From b25c14cb88a925ba985a643e5e17544c02e8f988 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Mon, 23 Nov 2020 17:04:28 +0800
Subject: [PATCH] mtmber

---
 business/jxstore/event/event.go | 14 ++++++++++++++
 business/jxstore/misc/misc.go   |  4 ++++
 business/model/dao/dao_job.go   | 11 +++++++----
 controllers/job_controller.go   |  4 ++--
 4 files changed, 27 insertions(+), 6 deletions(-)

diff --git a/business/jxstore/event/event.go b/business/jxstore/event/event.go
index 818ac0332..ab6e6f00c 100644
--- a/business/jxstore/event/event.go
+++ b/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
+}
diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go
index 8dab2c450..e35a45350 100644
--- a/business/jxstore/misc/misc.go
+++ b/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)
 }
 
 // 按时间序列循环
diff --git a/business/model/dao/dao_job.go b/business/model/dao/dao_job.go
index d5f9c1c69..df2678689 100644
--- a/business/model/dao/dao_job.go
+++ b/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)
-	return mtMembers, err
+	sqlParams := []interface{}{utils.DefaultTimeValue}
+	err = GetRows(db, &mtMembers, sql, sqlParams)
+	num = len(mtMembers)
+	return num, err
 }
diff --git a/controllers/job_controller.go b/controllers/job_controller.go
index e28bf9f00..aafed210e 100644
--- a/controllers/job_controller.go
+++ b/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())