sys messaged

business/jxstore/event/event.go

@@ -212,7 +212,9 @@ func GetMessageGroupByUser(ctx *jxcontext.Context, userID string) (messageGroupR
 	var (
 		db = dao.GetDB()
 	)
-	messageGroups, err := dao.GetMessageGroups(db, userID, 0, 0, true, "")
+	messageGroups, err := dao.GetMessageGroups(db, "", model.SysGroupID, 0, false, "")
+	messageGroups2, err := dao.GetMessageGroups(db, userID, 0, 0, true, "")
+	messageGroups = append(messageGroups, messageGroups2...)
 	messageGroupMembers, err := dao.GetMessageGroupMembers(db, 0, 0, userID)
 	for _, v := range messageGroupMembers {
 		if messageGroupList, err := dao.GetMessageGroups(db, "", v.GroupID, 0, false, ""); err == nil {
@@ -374,3 +376,23 @@ func DeleteMessageGroup(ctx *jxcontext.Context, groupID int, userID string) (err
 	}
 	return errCode, err
 }
+
+func SendSysMessage(ctx *jxcontext.Context, imMessageRecord *model.ImMessageRecord) (err error) {
+	var (
+		db     = dao.GetDB()
+		userID = imMessageRecord.UserID
+	)
+	if userID == "" {
+		return fmt.Errorf("系统用户不存在！")
+	}
+	user, err := dao.GetUserByID(db, "user_id", userID)
+	if err != nil {
+		return err
+	}
+	if user.Type != model.UserTypeBoss {
+		return fmt.Errorf("抱歉只有系统管理员才能发系统消息！")
+	}
+	dao.WrapAddIDCULDEntity(imMessageRecord, ctx.GetUserName())
+	err = dao.CreateEntity(db, imMessageRecord)
+	return err
+}

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, groupID int, userID string, storeID, vendorID, offset, pageSize int) (pagedInfo *model.PagedInfo, err error) {
+func GetImMessageRecord(db *DaoDB, groupID int, userID string, storeID, vendorID int, fromTime, toTime time.Time, offset, pageSize int) (pagedInfo *model.PagedInfo, err error) {
 	var msg []*model.ImMessageRecord
 	sql := `
 		SELECT SQL_CALC_FOUND_ROWS * 
@@ -168,6 +168,14 @@ func GetImMessageRecord(db *DaoDB, groupID int, userID string, storeID, vendorID
 		sql += " AND vendor_id = ?"
 		sqlParams = append(sqlParams, vendorID)
 	}
+	if fromTime != utils.ZeroTimeValue {
+		sql += " AND created_at >= ?"
+		sqlParams = append(sqlParams, fromTime)
+	}
+	if toTime != utils.ZeroTimeValue {
+		sql += " AND created_at <= ?"
+		sqlParams = append(sqlParams, toTime)
+	}
 	sql += ` 
 	 ORDER BY created_at DESC
 	 LIMIT ? OFFSET ?

business/model/event.go

@@ -2,6 +2,10 @@ package model
 
 import "time"
 
+const (
+	SysGroupID = 666666
+)
+
 type OperateEvent struct {
 	ID           int64     `orm:"column(id)" json:"id"`
 	CreatedAt    time.Time `orm:"auto_now_add;type(datetime)" json:"createdAt"`