opms_backend/opms_admin/app/service/sys_message.go

package service

import (
	"context"
	"dashoo.cn/micro/app/dao"
	"dashoo.cn/micro/app/model"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/os/gtime"
	"github.com/gogf/gf/util/gconv"
	"strings"
)

type MessageService struct {
	*contextService
	Dao    *dao.SysMessageDao
	logDao *dao.SysMessageLogDao
}

func NewMessageService(ctx context.Context) (svc *MessageService, err error) {
	svc = new(MessageService)
	if svc.contextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = dao.NewSysMessageDao(svc.Tenant)
	svc.logDao = dao.NewSysMessageLogDao(svc.Tenant)
	svc.Table = svc.Dao.Table
	return svc, nil
}

func (s *MessageService) GetList(req *model.SysMessageSearchReq) (total int, list []*model.SysMessage, err error) {
	m := s.Dao.M
	if req != nil {
		if req.MsgTitle != "" {
			m = m.WhereLike(s.Dao.Columns.MsgTitle, "%"+req.MsgTitle+"%")
		}
		if req.MsgType != "" {
			m = m.Where(s.Dao.Columns.MsgType, req.MsgType)
		}
	}
	total, err = m.Count()
	if err != nil {
		return
	}
	err = m.Page(req.GetPage()).OrderDesc("id").Scan(&list)
	if err != nil {
		return
	}
	return
}

func (s *MessageService) GetEntityById(id int64) (msg *model.SysMessage, err error) {
	msg, err = s.Dao.WherePri(id).One()
	if err != nil {
		return nil, err
	}
	data := g.Map{
		s.logDao.Columns.IsRead:   "20",
		s.logDao.Columns.ReadTime: gtime.Now(),
	}
	_, err = s.logDao.Where(s.logDao.Columns.MsgId, id).Where(s.logDao.Columns.UserId, s.GetCxtUserId()).Data(data).Update()
	return
}

// Create 添加操作
func (s *MessageService) Create(req *model.CreateSysMessageReq) (err error) {
	data := new(model.SysMessage)
	if err := gconv.Struct(req, data); err != nil {
		return err
	}
	SetCreatedInfo(data, s.GetCxtUserId(), s.GetCxtUserName())
	lastId, err := s.Dao.InsertAndGetId(data)
	if err != nil {
		return err
	}
	data.Id = int(lastId)
	userIds := strings.Split(data.RecvUserIds, ",")
	for _, uid := range userIds {
		if uid == "" {
			continue
		}
		log := g.Map{
			s.logDao.Columns.MsgId:  lastId,
			s.logDao.Columns.UserId: uid,
			s.logDao.Columns.IsRead: "10",
		}
		s.logDao.Data(log).Insert()
		MessageNotify(uid, *data)
	}
	return
}

// UpdateById 修改系统参数
func (s *MessageService) UpdateById(req *model.UpdateSysMessageReq) (err error) {
	data := new(model.SysMessage)
	if err := gconv.Struct(req, data); err != nil {
		return err
	}
	SetUpdatedInfo(data, s.GetCxtUserId(), s.GetCxtUserName())
	_, err = s.Dao.FieldsEx(UpdateFieldEx...).WherePri(req.Id).Data(data).Update()
	s.logDao.Where(s.logDao.Columns.MsgId, data.Id).Delete()
	userIds := strings.Split(data.RecvUserIds, ",")
	for _, uid := range userIds {
		if uid == "" {
			continue
		}
		log := g.Map{
			s.logDao.Columns.MsgId:  data.Id,
			s.logDao.Columns.UserId: uid,
			s.logDao.Columns.IsRead: "10",
		}
		s.logDao.Data(log).Insert()
	}
	return
}

// DeleteByIds 删除
func (s *MessageService) DeleteByIds(ids []int64) error {
	_, err := s.Dao.WhereIn(s.Dao.Columns.Id, ids).Delete()
	return err
}

// 全部已读
func (s *MessageService) AllRead() error {
	data := g.Map{
		s.logDao.Columns.IsRead:   "20",
		s.logDao.Columns.ReadTime: gtime.Now(),
	}
	_, err := s.logDao.Where(s.logDao.Columns.UserId, s.GetCxtUserId()).Data(data).Update()
	return err
}