xps-server-g5/pkg/bpm/service/wf_ins_service.go

package service

import (
	"xps/cmd/datasource"
	"xps/pkg/base"
	"xps/pkg/bpm/datamodel"
	"xps/pkg/bpm/repository"
	"xps/pkg/bpm/viewmodel"
)

type WfInsService interface {
	GetList(m map[string]interface{}) ([]viewmodel.WfInsInfo, error)
	GetPage(m map[string]interface{}) (*base.PageResult, error)
	GetById(ocId, wfInsId int64) (*viewmodel.WfInsInfo, error)
	Update(user *datamodel.WfIns) error
	Create(user *datamodel.WfIns) error
	Delete(m map[string]interface{}) error
}

type wfInsService struct {
	repo *repository.WfInsRepo
}

func NewWfInsService() WfInsService {
	return &wfInsService{
		repo: repository.NewWfInsRepo(datasource.InstanceMaster()),
	}
}

func (s *wfInsService) GetList(m map[string]interface{}) ([]viewmodel.WfInsInfo, error) {
	return s.repo.GetList(m)
}

func (s *wfInsService) GetPage(m map[string]interface{}) (*base.PageResult, error) {
	return s.repo.GetPage(m)
}

func (s *wfInsService) GetById(ocId, wfInsId int64) (*viewmodel.WfInsInfo, error) {
	return s.repo.GetById(ocId, wfInsId)
}

func (s *wfInsService) Create(data *datamodel.WfIns) error {
	data.WfInsId = NewID()
	return s.repo.Create(data)
}

func (s *wfInsService) Update(data *datamodel.WfIns) error {
	return s.repo.Update(data)
}

func (s *wfInsService) Delete(m map[string]interface{}) error {
	return s.repo.Delete(m)
}