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 }) }