查询聊天记录

business/model/dao/event.go

@@ -141,3 +141,30 @@ 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) {
+	sql := `
+		SELECT * 
+		  FROM im_message_record
+		 WHERE 1 = 1 
+	`
+	sqlParams := []interface{}{}
+	if vendorOrderID != "" {
+		sql += " AND vendor_order_id = ?"
+		sqlParams = append(sqlParams, vendorOrderID)
+	}
+	if userID != "" {
+		sql += " AND user_id = ?"
+		sqlParams = append(sqlParams, userID)
+	}
+	if storeID != 0 {
+		sql += " AND store_id = ?"
+		sqlParams = append(sqlParams, storeID)
+	}
+	if vendorID >= 0 {
+		sql += " AND vendor_id = ?"
+		sqlParams = append(sqlParams, vendorID)
+	}
+	err = GetRows(db, &msg, sql, sqlParams)
+	return msg, err
+}