liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

get im rec

Browse Source
This commit is contained in:
苏尹岚
2020-10-26 11:11:23 +08:00
parent 55a43504b6
commit 100c2ca978
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/model/dao/event.go
View File

@@ -142,7 +142,7 @@ func GetOperateEvents(db *DaoDB, name string, apiFunctions []string, operateType
return operateEventExt, totalCount, err 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 := ` sql := `
SELECT * SELECT *
FROM im_message_record FROM im_message_record
@@ -151,9 +151,9 @@ func GetImMessageRecord(db *DaoDB, vendorOrderID, userID string, storeID, vendor
sqlParams := []interface{}{ sqlParams := []interface{}{
utils.DefaultTimeValue, utils.DefaultTimeValue,
} }
if vendorOrderID != "" { if groupID != 0 {
sql += " AND vendor_order_id = ?" sql += " AND group_id = ?"
sqlParams = append(sqlParams, vendorOrderID) sqlParams = append(sqlParams, groupID)
} }
if userID != "" { if userID != "" {
sql += " AND user_id = ?" sql += " AND user_id = ?"

4
controllers/event_controller.go
View File

@@ -181,13 +181,13 @@ func handleMessages() {
// @Title 查询聊天记录 // @Title 查询聊天记录
// @Description 查询聊天记录 // @Description 查询聊天记录
// @Param token header string true "认证token" // @Param token header string true "认证token"
// @Param vendorOrderID query string true "订单号" // @Param groupID query int true "组ID"
// @Success 200 {object} controllers.CallResult // @Success 200 {object} controllers.CallResult
// @Failure 200 {object} controllers.CallResult // @Failure 200 {object} controllers.CallResult
// @router /GetImMessageRecord [get] // @router /GetImMessageRecord [get]
func (c *EventController) GetImMessageRecord() { func (c *EventController) GetImMessageRecord() {
c.callGetImMessageRecord(func(params *tEventGetImMessageRecordParams) (retVal interface{}, errCode string, err error) { 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 return retVal, "", err
}) })
} }