From 100c2ca9783fcd97ce428e7e541ca2489f71e541 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, 26 Oct 2020 11:11:23 +0800 Subject: [PATCH] get im rec --- business/model/dao/event.go | 8 ++++---- controllers/event_controller.go | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/business/model/dao/event.go b/business/model/dao/event.go index 0892a1794..87030256e 100644 --- a/business/model/dao/event.go +++ b/business/model/dao/event.go @@ -142,7 +142,7 @@ func GetOperateEvents(db *DaoDB, name string, apiFunctions []string, operateType return operateEventExt, totalCount, err } -func GetImMessageRecord(db *DaoDB, vendorOrderID, userID string, storeID, vendorID int) (msg []*model.ImMessageRecord, err error) { +func GetImMessageRecord(db *DaoDB, groupID int, userID string, storeID, vendorID int) (msg []*model.ImMessageRecord, err error) { sql := ` SELECT * FROM im_message_record @@ -151,9 +151,9 @@ func GetImMessageRecord(db *DaoDB, vendorOrderID, userID string, storeID, vendor sqlParams := []interface{}{ utils.DefaultTimeValue, } - if vendorOrderID != "" { - sql += " AND vendor_order_id = ?" - sqlParams = append(sqlParams, vendorOrderID) + if groupID != 0 { + sql += " AND group_id = ?" + sqlParams = append(sqlParams, groupID) } if userID != "" { sql += " AND user_id = ?" diff --git a/controllers/event_controller.go b/controllers/event_controller.go index 6c9d4d8f8..448e1d5c8 100644 --- a/controllers/event_controller.go +++ b/controllers/event_controller.go @@ -181,13 +181,13 @@ func handleMessages() { // @Title 查询聊天记录 // @Description 查询聊天记录 // @Param token header string true "认证token" -// @Param vendorOrderID query string true "订单号" +// @Param groupID query int true "组ID" // @Success 200 {object} controllers.CallResult // @Failure 200 {object} controllers.CallResult // @router /GetImMessageRecord [get] func (c *EventController) GetImMessageRecord() { c.callGetImMessageRecord(func(params *tEventGetImMessageRecordParams) (retVal interface{}, errCode string, err error) { - retVal, err = dao.GetImMessageRecord(dao.GetDB(), params.VendorOrderID, "", 0, -1) + retVal, err = dao.GetImMessageRecord(dao.GetDB(), params.GroupID, "", 0, -1) return retVal, "", err }) }