package service import ( "context" "dashoo.cn/micro/app/dao" "dashoo.cn/micro/app/model" "github.com/gogf/gf/errors/gerror" "github.com/gogf/gf/frame/g" "github.com/gogf/gf/util/gconv" ) type postService struct { *contextService Dao *dao.SysPostDao } func NewPostService(ctx context.Context) (svc *postService, err error) { svc = new(postService) if svc.contextService, err = svc.Init(ctx); err != nil { return nil, err } svc.Dao = dao.NewSysPostDao(svc.Tenant) svc.Table = svc.Dao.Table return svc, nil } func (s *postService) GetList(req *model.SysPostSearchParams) (total int, list []*model.SysPost, err error) { db := s.Dao.M if req != nil { if req.PostCode != "" { db = db.WhereLike(s.Dao.Columns.PostCode, req.PostCode) } if req.PostName != "" { db = db.WhereLike(s.Dao.Columns.PostName, req.PostName) } if req.Status != "" { db = db.Where(s.Dao.Columns.Status, req.Status) } } total, err = db.Count() if err != nil { g.Log().Error(err) err = gerror.New("获取总行数失败") } err = db.Page(req.GetPage()).Order(s.Dao.Columns.Sort + " asc," + s.Dao.Columns.Id + " asc").Scan(&list) if err != nil { g.Log().Error(err) err = gerror.New("获取数据失败") } return } func (s *postService) GetEntity(id int64) (post *model.SysPost, err error) { err = s.Dao.WherePri(id).Scan(&post) return } func (s *postService) Create(params *model.SysPostReq) error { data := new(model.SysPost) if err := gconv.Struct(params, data); err != nil { return err } SetCreatedInfo(data, s.GetCxtUserId(), s.GetCxtUserName()) _, err := s.Dao.Insert(data) return err } func (s *postService) UpdateById(params *model.UpdateSysPostReq) (err error) { data := new(model.SysPost) if err := gconv.Struct(params, data); err != nil { return err } SetUpdatedInfo(data, s.GetCxtUserId(), s.GetCxtUserName()) _, err = s.Dao.FieldsEx(UpdateFieldEx...).WherePri(params.Id).Update(data) return err } func (s *postService) DeleteByIds(ids []int64) error { _, err := s.Dao.WhereIn(s.Dao.Columns.Id, ids).Delete() return err }