allied-creation / sumifcc-discuss · 提交

转到一个项目

作者 tangxvhui
提交 15ccac12d90ce3a8a3567b35798ea299b2f02a8f 2 个父辈 c75c1856 d2827679

Merge branch 'dev' of http://gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss into dev

内嵌 并排对比
正在显示 26 个修改的文件 包含 1849 行增加 和 0 行删除
syntax = "v1"
info(
title: "xx实例"
desc: "xx实例"
author: "author"
email: "email"
version: "v1"
)
@server(
prefix: department/v1
group: department
jwt: JwtAuth
)
service Core {
@handler getDepartment
post /department/:id (DepartmentGetRequest) returns (DepartmentGetResponse)
@handler saveDepartment
post /department (DepartmentSaveRequest) returns (DepartmentSaveResponse)
@handler deleteDepartment
delete /department/:id (DepartmentDeleteRequest) returns (DepartmentDeleteResponse)
@handler updateDepartment
put /department/:id (DepartmentUpdateRequest) returns (DepartmentUpdateResponse)
@handler searchDepartment
post /department/search (DepartmentSearchRequest) returns (DepartmentSearchResponse)
}
type (
DepartmentGetRequest {
Id int64 `path:"id"`
}
DepartmentGetResponse struct{
Department DepartmentItem `json:"department"`
}
DepartmentSaveRequest struct{
Department DepartmentItem `json:"department"`
}
DepartmentSaveResponse struct{}
DepartmentDeleteRequest struct{
Id int64 `path:"id"`
}
DepartmentDeleteResponse struct{}
DepartmentUpdateRequest struct{
Id int64 `path:"id"`
Department DepartmentItem `json:"department"`
}
DepartmentUpdateResponse struct{}
DepartmentSearchRequest struct{
Page int `json:"page"`
Size int `json:"size"`
}
DepartmentSearchResponse{
List []DepartmentItem `json:"list"`
Total int64 `json:"total"`
}
DepartmentItem struct{
}
)
... ...
syntax = "v1"
info(
title: "xx实例"
desc: "xx实例"
author: "author"
email: "email"
version: "v1"
)
@server(
prefix: message_business/v1
group: message_business
jwt: JwtAuth
)
service Core {
@handler getMessageBusiness
post /message_business/:id (MessageBusinessGetRequest) returns (MessageBusinessGetResponse)
@handler saveMessageBusiness
post /message_business (MessageBusinessSaveRequest) returns (MessageBusinessSaveResponse)
@handler deleteMessageBusiness
delete /message_business/:id (MessageBusinessDeleteRequest) returns (MessageBusinessDeleteResponse)
@handler updateMessageBusiness
put /message_business/:id (MessageBusinessUpdateRequest) returns (MessageBusinessUpdateResponse)
@handler searchMessageBusiness
post /message_business/search (MessageBusinessSearchRequest) returns (MessageBusinessSearchResponse)
}
type (
MessageBusinessGetRequest {
Id int64 `path:"id"`
}
MessageBusinessGetResponse struct{
MessageBusiness MessageBusinessItem `json:"message_business"`
}
MessageBusinessSaveRequest struct{
MessageBusiness MessageBusinessItem `json:"message_business"`
}
MessageBusinessSaveResponse struct{}
MessageBusinessDeleteRequest struct{
Id int64 `path:"id"`
}
MessageBusinessDeleteResponse struct{}
MessageBusinessUpdateRequest struct{
Id int64 `path:"id"`
MessageBusiness MessageBusinessItem `json:"message_business"`
}
MessageBusinessUpdateResponse struct{}
MessageBusinessSearchRequest struct{
Page int `json:"page"`
Size int `json:"size"`
}
MessageBusinessSearchResponse{
List []MessageBusinessItem `json:"list"`
Total int64 `json:"total"`
}
MessageBusinessItem struct{
}
)
... ...
syntax = "v1"
info(
title: "xx实例"
desc: "xx实例"
author: "author"
email: "email"
version: "v1"
)
@server(
prefix: message_system/v1
group: message_system
jwt: JwtAuth
)
service Core {
@handler getMessageSystem
post /message_system/:id (MessageSystemGetRequest) returns (MessageSystemGetResponse)
@handler saveMessageSystem
post /message_system (MessageSystemSaveRequest) returns (MessageSystemSaveResponse)
@handler deleteMessageSystem
delete /message_system/:id (MessageSystemDeleteRequest) returns (MessageSystemDeleteResponse)
@handler updateMessageSystem
put /message_system/:id (MessageSystemUpdateRequest) returns (MessageSystemUpdateResponse)
@handler searchMessageSystem
post /message_system/search (MessageSystemSearchRequest) returns (MessageSystemSearchResponse)
}
type (
MessageSystemGetRequest {
Id int64 `path:"id"`
}
MessageSystemGetResponse struct{
MessageSystem MessageSystemItem `json:"message_system"`
}
MessageSystemSaveRequest struct{
MessageSystem MessageSystemItem `json:"message_system"`
}
MessageSystemSaveResponse struct{}
MessageSystemDeleteRequest struct{
Id int64 `path:"id"`
}
MessageSystemDeleteResponse struct{}
MessageSystemUpdateRequest struct{
Id int64 `path:"id"`
MessageSystem MessageSystemItem `json:"message_system"`
}
MessageSystemUpdateResponse struct{}
MessageSystemSearchRequest struct{
Page int `json:"page"`
Size int `json:"size"`
}
MessageSystemSearchResponse{
List []MessageSystemItem `json:"list"`
Total int64 `json:"total"`
}
MessageSystemItem struct{
}
)
... ...
syntax = "v1"
info(
title: "xx实例"
desc: "xx实例"
author: "author"
email: "email"
version: "v1"
)
@server(
prefix: role/v1
group: role
jwt: JwtAuth
)
service Core {
@handler getRole
post /role/:id (RoleGetRequest) returns (RoleGetResponse)
@handler saveRole
post /role (RoleSaveRequest) returns (RoleSaveResponse)
@handler deleteRole
delete /role/:id (RoleDeleteRequest) returns (RoleDeleteResponse)
@handler updateRole
put /role/:id (RoleUpdateRequest) returns (RoleUpdateResponse)
@handler searchRole
post /role/search (RoleSearchRequest) returns (RoleSearchResponse)
}
type (
RoleGetRequest {
Id int64 `path:"id"`
}
RoleGetResponse struct{
Role RoleItem `json:"role"`
}
RoleSaveRequest struct{
Role RoleItem `json:"role"`
}
RoleSaveResponse struct{}
RoleDeleteRequest struct{
Id int64 `path:"id"`
}
RoleDeleteResponse struct{}
RoleUpdateRequest struct{
Id int64 `path:"id"`
Role RoleItem `json:"role"`
}
RoleUpdateResponse struct{}
RoleSearchRequest struct{
Page int `json:"page"`
Size int `json:"size"`
}
RoleSearchResponse{
List []RoleItem `json:"list"`
Total int64 `json:"total"`
}
RoleItem struct{
}
)
... ...
syntax = "v1"
info(
title: "xx实例"
desc: "xx实例"
author: "author"
email: "email"
version: "v1"
)
@server(
prefix: user/v1
group: user
jwt: JwtAuth
)
service Core {
@handler getUser
post /user/:id (UserGetRequest) returns (UserGetResponse)
@handler saveUser
post /user (UserSaveRequest) returns (UserSaveResponse)
@handler deleteUser
delete /user/:id (UserDeleteRequest) returns (UserDeleteResponse)
@handler updateUser
put /user/:id (UserUpdateRequest) returns (UserUpdateResponse)
@handler searchUser
post /user/search (UserSearchRequest) returns (UserSearchResponse)
}
type (
UserGetRequest {
Id int64 `path:"id"`
}
UserGetResponse struct{
User UserItem `json:"user"`
}
UserSaveRequest struct{
User UserItem `json:"user"`
}
UserSaveResponse struct{}
UserDeleteRequest struct{
Id int64 `path:"id"`
}
UserDeleteResponse struct{}
UserUpdateRequest struct{
Id int64 `path:"id"`
User UserItem `json:"user"`
}
UserUpdateResponse struct{}
UserSearchRequest struct{
Page int `json:"page"`
Size int `json:"size"`
}
UserSearchResponse{
List []UserItem `json:"list"`
Total int64 `json:"total"`
}
UserItem struct{
}
)
... ...
syntax = "proto3";
option go_package ="./pb";
package pb;
message DepartmentGetReq {
int64 Id = 1;
}
message DepartmentGetResp{
DepartmentItem User = 1;
}
message DepartmentSaveReq {
}
message DepartmentSaveResp{
}
message DepartmentDeleteReq {
int64 Id = 1;
}
message DepartmentDeleteResp{
}
message DepartmentUpdateReq {
int64 Id = 1;
}
message DepartmentUpdateResp{
}
message DepartmentSearchReq {
int64 PageNumber = 1;
int64 PageSize = 2;
}
message DepartmentSearchResp{
repeated DepartmentItem List =1;
int64 Total =2;
}
message DepartmentItem {
}
service DepartmentService {
rpc DepartmentGet(DepartmentGetReq) returns(DepartmentGetResp);
rpc DepartmentSave(DepartmentSaveReq) returns(DepartmentSaveResp);
rpc DepartmentDelete(DepartmentDeleteReq) returns(DepartmentDeleteResp);
rpc DepartmentUpdate(DepartmentUpdateReq) returns(DepartmentUpdateResp);
rpc DepartmentSearch(DepartmentSearchReq) returns(DepartmentSearchResp);
}
... ...
syntax = "proto3";
option go_package ="./pb";
package pb;
message MessageBusinessGetReq {
int64 Id = 1;
}
message MessageBusinessGetResp{
MessageBusinessItem User = 1;
}
message MessageBusinessSaveReq {
}
message MessageBusinessSaveResp{
}
message MessageBusinessDeleteReq {
int64 Id = 1;
}
message MessageBusinessDeleteResp{
}
message MessageBusinessUpdateReq {
int64 Id = 1;
}
message MessageBusinessUpdateResp{
}
message MessageBusinessSearchReq {
int64 PageNumber = 1;
int64 PageSize = 2;
}
message MessageBusinessSearchResp{
repeated MessageBusinessItem List =1;
int64 Total =2;
}
message MessageBusinessItem {
}
service MessageBusinessService {
rpc MessageBusinessGet(MessageBusinessGetReq) returns(MessageBusinessGetResp);
rpc MessageBusinessSave(MessageBusinessSaveReq) returns(MessageBusinessSaveResp);
rpc MessageBusinessDelete(MessageBusinessDeleteReq) returns(MessageBusinessDeleteResp);
rpc MessageBusinessUpdate(MessageBusinessUpdateReq) returns(MessageBusinessUpdateResp);
rpc MessageBusinessSearch(MessageBusinessSearchReq) returns(MessageBusinessSearchResp);
}
... ...
syntax = "proto3";
option go_package ="./pb";
package pb;
message MessageSystemGetReq {
int64 Id = 1;
}
message MessageSystemGetResp{
MessageSystemItem User = 1;
}
message MessageSystemSaveReq {
}
message MessageSystemSaveResp{
}
message MessageSystemDeleteReq {
int64 Id = 1;
}
message MessageSystemDeleteResp{
}
message MessageSystemUpdateReq {
int64 Id = 1;
}
message MessageSystemUpdateResp{
}
message MessageSystemSearchReq {
int64 PageNumber = 1;
int64 PageSize = 2;
}
message MessageSystemSearchResp{
repeated MessageSystemItem List =1;
int64 Total =2;
}
message MessageSystemItem {
}
service MessageSystemService {
rpc MessageSystemGet(MessageSystemGetReq) returns(MessageSystemGetResp);
rpc MessageSystemSave(MessageSystemSaveReq) returns(MessageSystemSaveResp);
rpc MessageSystemDelete(MessageSystemDeleteReq) returns(MessageSystemDeleteResp);
rpc MessageSystemUpdate(MessageSystemUpdateReq) returns(MessageSystemUpdateResp);
rpc MessageSystemSearch(MessageSystemSearchReq) returns(MessageSystemSearchResp);
}
... ...
syntax = "proto3";
option go_package ="./pb";
package pb;
message RoleGetReq {
int64 Id = 1;
}
message RoleGetResp{
RoleItem User = 1;
}
message RoleSaveReq {
}
message RoleSaveResp{
}
message RoleDeleteReq {
int64 Id = 1;
}
message RoleDeleteResp{
}
message RoleUpdateReq {
int64 Id = 1;
}
message RoleUpdateResp{
}
message RoleSearchReq {
int64 PageNumber = 1;
int64 PageSize = 2;
}
message RoleSearchResp{
repeated RoleItem List =1;
int64 Total =2;
}
message RoleItem {
}
service RoleService {
rpc RoleGet(RoleGetReq) returns(RoleGetResp);
rpc RoleSave(RoleSaveReq) returns(RoleSaveResp);
rpc RoleDelete(RoleDeleteReq) returns(RoleDeleteResp);
rpc RoleUpdate(RoleUpdateReq) returns(RoleUpdateResp);
rpc RoleSearch(RoleSearchReq) returns(RoleSearchResp);
}
... ...
syntax = "proto3";
option go_package ="./pb";
package pb;
message UserGetReq {
int64 Id = 1;
}
message UserGetResp{
UserItem User = 1;
}
message UserSaveReq {
}
message UserSaveResp{
}
message UserDeleteReq {
int64 Id = 1;
}
message UserDeleteResp{
}
message UserUpdateReq {
int64 Id = 1;
}
message UserUpdateResp{
}
message UserSearchReq {
int64 PageNumber = 1;
int64 PageSize = 2;
}
message UserSearchResp{
repeated UserItem List =1;
int64 Total =2;
}
message UserItem {
}
service UserService {
rpc UserGet(UserGetReq) returns(UserGetResp);
rpc UserSave(UserSaveReq) returns(UserSaveResp);
rpc UserDelete(UserDeleteReq) returns(UserDeleteResp);
rpc UserUpdate(UserUpdateReq) returns(UserUpdateResp);
rpc UserSearch(UserSearchReq) returns(UserSearchResp);
}
... ...
package models
import (
"fmt"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
"gorm.io/gorm"
)
type Department struct {
Id int64 // 唯一标识
CreatedAt int64 `json:"createdAt,omitempty"`
UpdatedAt int64 `json:"updatedAt,omitempty"`
DeletedAt int64 `json:"deletedAt,omitempty"`
Version int `json:"version,omitempty"`
}
func (m *Department) TableName() string {
return "department"
}
func (m *Department) BeforeCreate(tx *gorm.DB) (err error) {
// m.CreatedAt = time.Now().Unix()
// m.UpdatedAt = time.Now().Unix()
return
}
func (m *Department) BeforeUpdate(tx *gorm.DB) (err error) {
// m.UpdatedAt = time.Now().Unix()
return
}
func (m *Department) CacheKeyFunc() string {
if m.Id == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:id:%v", domain.ProjectName, m.TableName(), m.Id)
}
func (m *Department) CacheKeyFuncByObject(obj interface{}) string {
if v, ok := obj.(*Department); ok {
return v.CacheKeyFunc()
}
return ""
}
func (m *Department) CachePrimaryKeyFunc() string {
if len("") == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:primarykey:%v", domain.ProjectName, m.TableName(), "key")
}
... ...
package models
import (
"fmt"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
"gorm.io/gorm"
"gorm.io/plugin/soft_delete"
)
type MessageBusiness struct {
Id int64 // 唯一标识
Type int `json:"type"` // 分类 （1回复 2点赞 3被采纳）
OptType int `json:"optType"` // 操作类型（1针对文章、1针对评论、2针对圆桌）
TriggerId int64 `json:"triggerId"` // 触发者ID
RecipientId int64 `json:"recipientId"` // 接收者ID
ArticleId int64 `json:"articleId"` // 文章ID
CommentId int64 `json:"commentId"` // 评论ID
DiscussionId int64 `json:"discussionId"` // 圆桌ID
DiscussionOpinionId int64 `json:"discussionOpinionId"` // 观点ID
Content string `json:"content"` // 消息内容
CreatedAt int64 `json:",omitempty"`
UpdatedAt int64 `json:",omitempty"`
DeletedAt int64 `json:",omitempty"`
Version int `json:",omitempty"`
IsDel soft_delete.DeletedAt `gorm:"softDelete:flag,DeletedAtField:DeletedAt"`
}
func (m *MessageBusiness) TableName() string {
return "message_business"
}
func (m *MessageBusiness) BeforeCreate(tx *gorm.DB) (err error) {
// m.CreatedAt = time.Now().Unix()
// m.UpdatedAt = time.Now().Unix()
return
}
func (m *MessageBusiness) BeforeUpdate(tx *gorm.DB) (err error) {
// m.UpdatedAt = time.Now().Unix()
return
}
func (m *MessageBusiness) CacheKeyFunc() string {
if m.Id == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:id:%v", domain.ProjectName, m.TableName(), m.Id)
}
func (m *MessageBusiness) CacheKeyFuncByObject(obj interface{}) string {
if v, ok := obj.(*MessageBusiness); ok {
return v.CacheKeyFunc()
}
return ""
}
func (m *MessageBusiness) CachePrimaryKeyFunc() string {
if len("") == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:primarykey:%v", domain.ProjectName, m.TableName(), "key")
}
... ...
package models
import (
"fmt"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
"gorm.io/gorm"
"gorm.io/plugin/soft_delete"
)
type MessageSystem struct {
Id int64 // 唯一标识
RecipientId int64 `json:"recipientId"` // 接收者ID
Type int `json:"type"` // 系统分类（0待定、1业务正常通知、2业务异常通知）
Title string `json:"title"` // 标题
Content string `json:"content"` // 内容
CreatedAt int64 `json:",omitempty"`
UpdatedAt int64 `json:",omitempty"`
DeletedAt int64 `json:",omitempty"`
Version int `json:",omitempty"`
IsDel soft_delete.DeletedAt `gorm:"softDelete:flag,DeletedAtField:DeletedAt"`
}
func (m *MessageSystem) TableName() string {
return "message_system"
}
func (m *MessageSystem) BeforeCreate(tx *gorm.DB) (err error) {
// m.CreatedAt = time.Now().Unix()
// m.UpdatedAt = time.Now().Unix()
return
}
func (m *MessageSystem) BeforeUpdate(tx *gorm.DB) (err error) {
// m.UpdatedAt = time.Now().Unix()
return
}
func (m *MessageSystem) CacheKeyFunc() string {
if m.Id == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:id:%v", domain.ProjectName, m.TableName(), m.Id)
}
func (m *MessageSystem) CacheKeyFuncByObject(obj interface{}) string {
if v, ok := obj.(*MessageSystem); ok {
return v.CacheKeyFunc()
}
return ""
}
func (m *MessageSystem) CachePrimaryKeyFunc() string {
if len("") == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:primarykey:%v", domain.ProjectName, m.TableName(), "key")
}
... ...
package models
import (
"fmt"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
"gorm.io/gorm"
"time"
)
type Role struct {
Id int64 // 唯一标识
CreatedAt int64 `json:"createdAt,omitempty"`
UpdatedAt int64 `json:"updatedAt,omitempty"`
DeletedAt int64 `json:"deletedAt,omitempty"`
Version int `json:"version,omitempty"`
}
func (m *Role) TableName() string {
return "role"
}
func (m *Role) BeforeCreate(tx *gorm.DB) (err error) {
m.CreatedAt = time.Now().Unix()
m.UpdatedAt = time.Now().Unix()
return
}
func (m *Role) BeforeUpdate(tx *gorm.DB) (err error) {
m.UpdatedAt = time.Now().Unix()
return
}
func (m *Role) CacheKeyFunc() string {
if m.Id == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:id:%v", domain.ProjectName, m.TableName(), m.Id)
}
func (m *Role) CacheKeyFuncByObject(obj interface{}) string {
if v, ok := obj.(*Role); ok {
return v.CacheKeyFunc()
}
return ""
}
func (m *Role) CachePrimaryKeyFunc() string {
if len("") == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:primarykey:%v", domain.ProjectName, m.TableName(), "key")
}
... ...
package models
import (
"fmt"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
"gorm.io/gorm"
"time"
)
type User struct {
Id int64 // 唯一标识
CreatedAt int64 `json:"createdAt,omitempty"`
UpdatedAt int64 `json:"updatedAt,omitempty"`
DeletedAt int64 `json:"deletedAt,omitempty"`
Version int `json:"version,omitempty"`
}
func (m *User) TableName() string {
return "user"
}
func (m *User) BeforeCreate(tx *gorm.DB) (err error) {
m.CreatedAt = time.Now().Unix()
m.UpdatedAt = time.Now().Unix()
return
}
func (m *User) BeforeUpdate(tx *gorm.DB) (err error) {
m.UpdatedAt = time.Now().Unix()
return
}
func (m *User) CacheKeyFunc() string {
if m.Id == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:id:%v", domain.ProjectName, m.TableName(), m.Id)
}
func (m *User) CacheKeyFuncByObject(obj interface{}) string {
if v, ok := obj.(*User); ok {
return v.CacheKeyFunc()
}
return ""
}
func (m *User) CachePrimaryKeyFunc() string {
if len("") == 0 {
return ""
}
return fmt.Sprintf("%v:cache:%v:primarykey:%v", domain.ProjectName, m.TableName(), "key")
}
... ...
package repository
import (
"context"
"github.com/jinzhu/copier"
"github.com/pkg/errors"
"github.com/tiptok/gocomm/pkg/cache"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/models"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
"gorm.io/gorm"
)
type DepartmentRepository struct {
*cache.CachedRepository
}
func (repository *DepartmentRepository) Insert(ctx context.Context, conn transaction.Conn, dm *domain.Department) (*domain.Department, error) {
var (
err error
m = &models.Department{}
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
if tx = tx.Model(m).Save(m); tx.Error != nil {
return nil, tx.Error
}
dm.Id = m.Id
return repository.ModelToDomainModel(m)
}
func (repository *DepartmentRepository) Update(ctx context.Context, conn transaction.Conn, dm *domain.Department) (*domain.Department, error) {
var (
err error
m *models.Department
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Updates(m)
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *DepartmentRepository) UpdateWithVersion(ctx context.Context, transaction transaction.Conn, dm *domain.Department) (*domain.Department, error) {
var (
err error
m *models.Department
tx = transaction.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
oldVersion := dm.Version
m.Version += 1
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Select("*").Where("id = ?", m.Id).Where("version = ?", oldVersion).Updates(m)
if tx.RowsAffected == 0 {
return nil, domain.ErrUpdateFail
}
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *DepartmentRepository) Delete(ctx context.Context, conn transaction.Conn, dm *domain.Department) (*domain.Department, error) {
var (
tx = conn.DB()
m = &models.Department{Id: dm.Identify().(int64)}
)
queryFunc := func() (interface{}, error) {
tx = tx.Where("id = ?", m.Id).Delete(m)
return m, tx.Error
}
if _, err := repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return dm, err
}
return repository.ModelToDomainModel(m)
}
func (repository *DepartmentRepository) FindOne(ctx context.Context, conn transaction.Conn, id int64) (*domain.Department, error) {
var (
err error
tx = conn.DB()
m = new(models.Department)
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Where("id = ?", id).First(m)
if errors.Is(tx.Error, gorm.ErrRecordNotFound) {
return nil, domain.ErrNotFound
}
return m, tx.Error
}
cacheModel := new(models.Department)
cacheModel.Id = id
if err = repository.QueryCache(cacheModel.CacheKeyFunc, m, queryFunc); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *DepartmentRepository) Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*domain.Department, error) {
var (
tx = conn.DB()
ms []*models.Department
dms = make([]*domain.Department, 0)
total int64
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(&ms).Order("id desc")
if total, tx = transaction.PaginationAndCount(ctx, tx, queryOptions, &ms); tx.Error != nil {
return dms, tx.Error
}
return dms, nil
}
if _, err := repository.Query(queryFunc); err != nil {
return 0, nil, err
}
for _, item := range ms {
if dm, err := repository.ModelToDomainModel(item); err != nil {
return 0, dms, err
} else {
dms = append(dms, dm)
}
}
return total, dms, nil
}
func (repository *DepartmentRepository) ModelToDomainModel(from *models.Department) (*domain.Department, error) {
to := &domain.Department{}
err := copier.Copy(to, from)
return to, err
}
func (repository *DepartmentRepository) DomainModelToModel(from *domain.Department) (*models.Department, error) {
to := &models.Department{}
err := copier.Copy(to, from)
return to, err
}
func NewDepartmentRepository(cache *cache.CachedRepository) domain.DepartmentRepository {
return &DepartmentRepository{CachedRepository: cache}
}
... ...
package repository
import (
"context"
"github.com/jinzhu/copier"
"github.com/pkg/errors"
"github.com/tiptok/gocomm/pkg/cache"
"gorm.io/gorm"
)
type MessageBusinessRepository struct {
*cache.CachedRepository
}
func (repository *MessageBusinessRepository) Insert(ctx context.Context, conn transaction.Conn, dm *domain.MessageBusiness) (*domain.MessageBusiness, error) {
var (
err error
m = &models.MessageBusiness{}
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
if tx = tx.Model(m).Save(m); tx.Error != nil {
return nil, tx.Error
}
dm.Id = m.Id
return repository.ModelToDomainModel(m)
}
func (repository *MessageBusinessRepository) Update(ctx context.Context, conn transaction.Conn, dm *domain.MessageBusiness) (*domain.MessageBusiness, error) {
var (
err error
m *models.MessageBusiness
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Updates(m)
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *MessageBusinessRepository) UpdateWithVersion(ctx context.Context, transaction transaction.Conn, dm *domain.MessageBusiness) (*domain.MessageBusiness, error) {
var (
err error
m *models.MessageBusiness
tx = transaction.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
oldVersion := dm.Version
m.Version += 1
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Select("*").Where("id = ?", m.Id).Where("version = ?", oldVersion).Updates(m)
if tx.RowsAffected == 0 {
return nil, domain.ErrUpdateFail
}
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *MessageBusinessRepository) Delete(ctx context.Context, conn transaction.Conn, dm *domain.MessageBusiness) (*domain.MessageBusiness, error) {
var (
tx = conn.DB()
m = &models.MessageBusiness{Id: dm.Identify().(int64)}
)
queryFunc := func() (interface{}, error) {
tx = tx.Where("id = ?", m.Id).Delete(m)
return m, tx.Error
}
if _, err := repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return dm, err
}
return repository.ModelToDomainModel(m)
}
func (repository *MessageBusinessRepository) FindOne(ctx context.Context, conn transaction.Conn, id int64) (*domain.MessageBusiness, error) {
var (
err error
tx = conn.DB()
m = new(models.MessageBusiness)
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Where("id = ?", id).First(m)
if errors.Is(tx.Error, gorm.ErrRecordNotFound) {
return nil, domain.ErrNotFound
}
return m, tx.Error
}
cacheModel := new(models.MessageBusiness)
cacheModel.Id = id
if err = repository.QueryCache(cacheModel.CacheKeyFunc, m, queryFunc); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *MessageBusinessRepository) Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*domain.MessageBusiness, error) {
var (
tx = conn.DB()
ms []*models.MessageBusiness
dms = make([]*domain.MessageBusiness, 0)
total int64
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(&ms).Order("id desc")
if total, tx = transaction.PaginationAndCount(ctx, tx, queryOptions, &ms); tx.Error != nil {
return dms, tx.Error
}
return dms, nil
}
if _, err := repository.Query(queryFunc); err != nil {
return 0, nil, err
}
for _, item := range ms {
if dm, err := repository.ModelToDomainModel(item); err != nil {
return 0, dms, err
} else {
dms = append(dms, dm)
}
}
return total, dms, nil
}
func (repository *MessageBusinessRepository) ModelToDomainModel(from *models.MessageBusiness) (*domain.MessageBusiness, error) {
to := &domain.MessageBusiness{}
err := copier.Copy(to, from)
return to, err
}
func (repository *MessageBusinessRepository) DomainModelToModel(from *domain.MessageBusiness) (*models.MessageBusiness, error) {
to := &models.MessageBusiness{}
err := copier.Copy(to, from)
return to, err
}
func NewMessageBusinessRepository(cache *cache.CachedRepository) domain.MessageBusinessRepository {
return &MessageBusinessRepository{CachedRepository: cache}
}
... ...
package repository
import (
"context"
"github.com/jinzhu/copier"
"github.com/pkg/errors"
"github.com/tiptok/gocomm/pkg/cache"
"gorm.io/gorm"
)
type MessageSystemRepository struct {
*cache.CachedRepository
}
func (repository *MessageSystemRepository) Insert(ctx context.Context, conn transaction.Conn, dm *domain.MessageSystem) (*domain.MessageSystem, error) {
var (
err error
m = &models.MessageSystem{}
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
if tx = tx.Model(m).Save(m); tx.Error != nil {
return nil, tx.Error
}
dm.Id = m.Id
return repository.ModelToDomainModel(m)
}
func (repository *MessageSystemRepository) Update(ctx context.Context, conn transaction.Conn, dm *domain.MessageSystem) (*domain.MessageSystem, error) {
var (
err error
m *models.MessageSystem
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Updates(m)
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *MessageSystemRepository) UpdateWithVersion(ctx context.Context, transaction transaction.Conn, dm *domain.MessageSystem) (*domain.MessageSystem, error) {
var (
err error
m *models.MessageSystem
tx = transaction.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
oldVersion := dm.Version
m.Version += 1
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Select("*").Where("id = ?", m.Id).Where("version = ?", oldVersion).Updates(m)
if tx.RowsAffected == 0 {
return nil, domain.ErrUpdateFail
}
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *MessageSystemRepository) Delete(ctx context.Context, conn transaction.Conn, dm *domain.MessageSystem) (*domain.MessageSystem, error) {
var (
tx = conn.DB()
m = &models.MessageSystem{Id: dm.Identify().(int64)}
)
queryFunc := func() (interface{}, error) {
tx = tx.Where("id = ?", m.Id).Delete(m)
return m, tx.Error
}
if _, err := repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return dm, err
}
return repository.ModelToDomainModel(m)
}
func (repository *MessageSystemRepository) FindOne(ctx context.Context, conn transaction.Conn, id int64) (*domain.MessageSystem, error) {
var (
err error
tx = conn.DB()
m = new(models.MessageSystem)
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Where("id = ?", id).First(m)
if errors.Is(tx.Error, gorm.ErrRecordNotFound) {
return nil, domain.ErrNotFound
}
return m, tx.Error
}
cacheModel := new(models.MessageSystem)
cacheModel.Id = id
if err = repository.QueryCache(cacheModel.CacheKeyFunc, m, queryFunc); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *MessageSystemRepository) Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*domain.MessageSystem, error) {
var (
tx = conn.DB()
ms []*models.MessageSystem
dms = make([]*domain.MessageSystem, 0)
total int64
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(&ms).Order("id desc")
if total, tx = transaction.PaginationAndCount(ctx, tx, queryOptions, &ms); tx.Error != nil {
return dms, tx.Error
}
return dms, nil
}
if _, err := repository.Query(queryFunc); err != nil {
return 0, nil, err
}
for _, item := range ms {
if dm, err := repository.ModelToDomainModel(item); err != nil {
return 0, dms, err
} else {
dms = append(dms, dm)
}
}
return total, dms, nil
}
func (repository *MessageSystemRepository) ModelToDomainModel(from *models.MessageSystem) (*domain.MessageSystem, error) {
to := &domain.MessageSystem{}
err := copier.Copy(to, from)
return to, err
}
func (repository *MessageSystemRepository) DomainModelToModel(from *domain.MessageSystem) (*models.MessageSystem, error) {
to := &models.MessageSystem{}
err := copier.Copy(to, from)
return to, err
}
func NewMessageSystemRepository(cache *cache.CachedRepository) domain.MessageSystemRepository {
return &MessageSystemRepository{CachedRepository: cache}
}
... ...
package repository
import (
"context"
"github.com/jinzhu/copier"
"github.com/pkg/errors"
"github.com/tiptok/gocomm/pkg/cache"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/models"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
"gorm.io/gorm"
)
type RoleRepository struct {
*cache.CachedRepository
}
func (repository *RoleRepository) Insert(ctx context.Context, conn transaction.Conn, dm *domain.Role) (*domain.Role, error) {
var (
err error
m = &models.Role{}
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
if tx = tx.Model(m).Save(m); tx.Error != nil {
return nil, tx.Error
}
dm.Id = m.Id
return repository.ModelToDomainModel(m)
}
func (repository *RoleRepository) Update(ctx context.Context, conn transaction.Conn, dm *domain.Role) (*domain.Role, error) {
var (
err error
m *models.Role
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Updates(m)
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *RoleRepository) UpdateWithVersion(ctx context.Context, transaction transaction.Conn, dm *domain.Role) (*domain.Role, error) {
var (
err error
m *models.Role
tx = transaction.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
oldVersion := dm.Version
m.Version += 1
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Select("*").Where("id = ?", m.Id).Where("version = ?", oldVersion).Updates(m)
if tx.RowsAffected == 0 {
return nil, domain.ErrUpdateFail
}
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *RoleRepository) Delete(ctx context.Context, conn transaction.Conn, dm *domain.Role) (*domain.Role, error) {
var (
tx = conn.DB()
m = &models.Role{Id: dm.Identify().(int64)}
)
queryFunc := func() (interface{}, error) {
tx = tx.Where("id = ?", m.Id).Delete(m)
return m, tx.Error
}
if _, err := repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return dm, err
}
return repository.ModelToDomainModel(m)
}
func (repository *RoleRepository) FindOne(ctx context.Context, conn transaction.Conn, id int64) (*domain.Role, error) {
var (
err error
tx = conn.DB()
m = new(models.Role)
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Where("id = ?", id).First(m)
if errors.Is(tx.Error, gorm.ErrRecordNotFound) {
return nil, domain.ErrNotFound
}
return m, tx.Error
}
cacheModel := new(models.Role)
cacheModel.Id = id
if err = repository.QueryCache(cacheModel.CacheKeyFunc, m, queryFunc); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *RoleRepository) Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*domain.Role, error) {
var (
tx = conn.DB()
ms []*models.Role
dms = make([]*domain.Role, 0)
total int64
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(&ms).Order("id desc")
if total, tx = transaction.PaginationAndCount(ctx, tx, queryOptions, &ms); tx.Error != nil {
return dms, tx.Error
}
return dms, nil
}
if _, err := repository.Query(queryFunc); err != nil {
return 0, nil, err
}
for _, item := range ms {
if dm, err := repository.ModelToDomainModel(item); err != nil {
return 0, dms, err
} else {
dms = append(dms, dm)
}
}
return total, dms, nil
}
func (repository *RoleRepository) ModelToDomainModel(from *models.Role) (*domain.Role, error) {
to := &domain.Role{}
err := copier.Copy(to, from)
return to, err
}
func (repository *RoleRepository) DomainModelToModel(from *domain.Role) (*models.Role, error) {
to := &models.Role{}
err := copier.Copy(to, from)
return to, err
}
func NewRoleRepository(cache *cache.CachedRepository) domain.RoleRepository {
return &RoleRepository{CachedRepository: cache}
}
... ...
package repository
import (
"context"
"github.com/jinzhu/copier"
"github.com/pkg/errors"
"github.com/tiptok/gocomm/pkg/cache"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/models"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/domain"
"gorm.io/gorm"
)
type UserRepository struct {
*cache.CachedRepository
}
func (repository *UserRepository) Insert(ctx context.Context, conn transaction.Conn, dm *domain.User) (*domain.User, error) {
var (
err error
m = &models.User{}
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
if tx = tx.Model(m).Save(m); tx.Error != nil {
return nil, tx.Error
}
dm.Id = m.Id
return repository.ModelToDomainModel(m)
}
func (repository *UserRepository) Update(ctx context.Context, conn transaction.Conn, dm *domain.User) (*domain.User, error) {
var (
err error
m *models.User
tx = conn.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Updates(m)
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *UserRepository) UpdateWithVersion(ctx context.Context, transaction transaction.Conn, dm *domain.User) (*domain.User, error) {
var (
err error
m *models.User
tx = transaction.DB()
)
if m, err = repository.DomainModelToModel(dm); err != nil {
return nil, err
}
oldVersion := dm.Version
m.Version += 1
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Select("*").Where("id = ?", m.Id).Where("version = ?", oldVersion).Updates(m)
if tx.RowsAffected == 0 {
return nil, domain.ErrUpdateFail
}
return nil, tx.Error
}
if _, err = repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *UserRepository) Delete(ctx context.Context, conn transaction.Conn, dm *domain.User) (*domain.User, error) {
var (
tx = conn.DB()
m = &models.User{Id: dm.Identify().(int64)}
)
queryFunc := func() (interface{}, error) {
tx = tx.Where("id = ?", m.Id).Delete(m)
return m, tx.Error
}
if _, err := repository.Query(queryFunc, m.CacheKeyFunc()); err != nil {
return dm, err
}
return repository.ModelToDomainModel(m)
}
func (repository *UserRepository) FindOne(ctx context.Context, conn transaction.Conn, id int64) (*domain.User, error) {
var (
err error
tx = conn.DB()
m = new(models.User)
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(m).Where("id = ?", id).First(m)
if errors.Is(tx.Error, gorm.ErrRecordNotFound) {
return nil, domain.ErrNotFound
}
return m, tx.Error
}
cacheModel := new(models.User)
cacheModel.Id = id
if err = repository.QueryCache(cacheModel.CacheKeyFunc, m, queryFunc); err != nil {
return nil, err
}
return repository.ModelToDomainModel(m)
}
func (repository *UserRepository) Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*domain.User, error) {
var (
tx = conn.DB()
ms []*models.User
dms = make([]*domain.User, 0)
total int64
)
queryFunc := func() (interface{}, error) {
tx = tx.Model(&ms).Order("id desc")
if total, tx = transaction.PaginationAndCount(ctx, tx, queryOptions, &ms); tx.Error != nil {
return dms, tx.Error
}
return dms, nil
}
if _, err := repository.Query(queryFunc); err != nil {
return 0, nil, err
}
for _, item := range ms {
if dm, err := repository.ModelToDomainModel(item); err != nil {
return 0, dms, err
} else {
dms = append(dms, dm)
}
}
return total, dms, nil
}
func (repository *UserRepository) ModelToDomainModel(from *models.User) (*domain.User, error) {
to := &domain.User{}
err := copier.Copy(to, from)
return to, err
}
func (repository *UserRepository) DomainModelToModel(from *domain.User) (*models.User, error) {
to := &models.User{}
err := copier.Copy(to, from)
return to, err
}
func NewUserRepository(cache *cache.CachedRepository) domain.UserRepository {
return &UserRepository{CachedRepository: cache}
}
... ...
package domain
import (
"context"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
)
type Department struct {
Id int64 `json:"id,omitempty"` // 部门ID
CompanyId int64 `json:"companyId,omitempty"` // 公司ID
ParentId int64 `json:"parentId,omitempty"` // 父级ID
Name string `json:"name,omitempty"` // 部门名称
CreatedAt int64 `json:"createdAt,omitempty"`
UpdatedAt int64 `json:"updatedAt,omitempty"`
DeletedAt int64 `json:"deletedAt,omitempty"`
Version int `json:"version,omitempty"`
}
type DepartmentRepository interface {
Insert(ctx context.Context, conn transaction.Conn, dm *Department) (*Department, error)
Update(ctx context.Context, conn transaction.Conn, dm *Department) (*Department, error)
UpdateWithVersion(ctx context.Context, conn transaction.Conn, dm *Department) (*Department, error)
Delete(ctx context.Context, conn transaction.Conn, dm *Department) (*Department, error)
FindOne(ctx context.Context, conn transaction.Conn, id int64) (*Department, error)
Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*Department, error)
}
func (m *Department) Identify() interface{} {
if m.Id == 0 {
return nil
}
return m.Id
}
... ...
package domain
import (
"context"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
)
type MessageBusiness struct {
Id int64 // 唯一标识
Type int `json:"type"` // 分类 （1回复 2点赞 3被采纳）
OptType int `json:"optType"` // 操作类型（1针对文章、1针对评论、2针对圆桌）
TriggerId int64 `json:"triggerId"` // 触发者ID
RecipientId int64 `json:"recipientId"` // 接收者ID
ArticleId int64 `json:"articleId"` // 文章ID
CommentId int64 `json:"commentId"` // 评论ID
DiscussionId int64 `json:"discussionId"` // 圆桌ID
DiscussionOpinionId int64 `json:"discussionOpinionId"` // 观点ID
Content string `json:"content"` // 消息内容
CreatedAt int64 `json:",omitempty"`
UpdatedAt int64 `json:",omitempty"`
DeletedAt int64 `json:",omitempty"`
Version int `json:",omitempty"`
}
type MessageBusinessRepository interface {
Insert(ctx context.Context, conn transaction.Conn, dm *MessageBusiness) (*MessageBusiness, error)
Update(ctx context.Context, conn transaction.Conn, dm *MessageBusiness) (*MessageBusiness, error)
UpdateWithVersion(ctx context.Context, conn transaction.Conn, dm *MessageBusiness) (*MessageBusiness, error)
Delete(ctx context.Context, conn transaction.Conn, dm *MessageBusiness) (*MessageBusiness, error)
FindOne(ctx context.Context, conn transaction.Conn, id int64) (*MessageBusiness, error)
Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*MessageBusiness, error)
}
func (m *MessageBusiness) Identify() interface{} {
if m.Id == 0 {
return nil
}
return m.Id
}
... ...
package domain
import (
"context"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
)
type MessageSystem struct {
Id int64 // 唯一标识
RecipientId int64 `json:"recipientId"` // 接收者ID
Type int `json:"type"` // 系统分类（0待定、1业务正常通知、2业务异常通知）
Title string `json:"title"` // 标题
Content string `json:"content"` // 内容
CreatedAt int64 `json:",omitempty"`
UpdatedAt int64 `json:",omitempty"`
DeletedAt int64 `json:",omitempty"`
Version int `json:",omitempty"`
}
type MessageSystemRepository interface {
Insert(ctx context.Context, conn transaction.Conn, dm *MessageSystem) (*MessageSystem, error)
Update(ctx context.Context, conn transaction.Conn, dm *MessageSystem) (*MessageSystem, error)
UpdateWithVersion(ctx context.Context, conn transaction.Conn, dm *MessageSystem) (*MessageSystem, error)
Delete(ctx context.Context, conn transaction.Conn, dm *MessageSystem) (*MessageSystem, error)
FindOne(ctx context.Context, conn transaction.Conn, id int64) (*MessageSystem, error)
Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*MessageSystem, error)
}
func (m *MessageSystem) Identify() interface{} {
if m.Id == 0 {
return nil
}
return m.Id
}
... ...
package domain
import (
"context"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
)
type Role struct {
Id int64 `json:"id"` // 角色ID
Name string `json:"name"` // 角色名称
Auths []int64 `json:"auths"` // 角色权限列表
Remark string `json:"remark"` // 备注
Users []int64 `json:"users"` // 绑定的用户
CreatedAt int64 `json:"createdAt,omitempty"`
UpdatedAt int64 `json:"updatedAt,omitempty"`
DeletedAt int64 `json:"deletedAt,omitempty"`
Version int `json:"version,omitempty"`
}
type RoleRepository interface {
Insert(ctx context.Context, conn transaction.Conn, dm *Role) (*Role, error)
Update(ctx context.Context, conn transaction.Conn, dm *Role) (*Role, error)
UpdateWithVersion(ctx context.Context, conn transaction.Conn, dm *Role) (*Role, error)
Delete(ctx context.Context, conn transaction.Conn, dm *Role) (*Role, error)
FindOne(ctx context.Context, conn transaction.Conn, id int64) (*Role, error)
Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*Role, error)
}
func (m *Role) Identify() interface{} {
if m.Id == 0 {
return nil
}
return m.Id
}
... ...
package domain
import (
"context"
"gitlab.fjmaimaimai.com/allied-creation/sumifcc-discuss/cmd/discuss/interanl/pkg/db/transaction"
)
type User struct {
Id int64 `json:"id,omitempty"` // 用户ID
CompanyId int64 `json:"companyId,omitempty"` // 公司ID
DepartmentId int64 `json:"departmentId,omitempty"` // 部门ID
Roles []int64 `json:"roleId,omitempty"` // 角色
Flag int `json:"flag"` // 标识 1:管理员 2:普通用户 （有绑定角色是管理员）
Name string `json:"name,omitempty"` // 名称
Avatar string `json:"avatar,omitempty"` // 头像
Phone string `json:"phone,omitempty"` // 手机号 唯一
Position string `json:"position,omitempty"` // 职位
Enable int `json:"enable,omitempty"` // 启用状态 1:启用 2：禁用
AuditStatus int `json:"auditStatus,omitempty"` // 审核状态 0:待审核 1:审核通过 2:拒绝
CreatedAt int64 `json:"createdAt,omitempty"`
UpdatedAt int64 `json:"updatedAt,omitempty"`
DeletedAt int64 `json:"deletedAt,omitempty"`
Version int `json:"version,omitempty"`
}
type UserRepository interface {
Insert(ctx context.Context, conn transaction.Conn, dm *User) (*User, error)
Update(ctx context.Context, conn transaction.Conn, dm *User) (*User, error)
UpdateWithVersion(ctx context.Context, conn transaction.Conn, dm *User) (*User, error)
Delete(ctx context.Context, conn transaction.Conn, dm *User) (*User, error)
FindOne(ctx context.Context, conn transaction.Conn, id int64) (*User, error)
Find(ctx context.Context, conn transaction.Conn, queryOptions map[string]interface{}) (int64, []*User, error)
}
func (m *User) Identify() interface{} {
if m.Id == 0 {
return nil
}
return m.Id
}
... ...
CREATE TABLE `comment` (
`id` int(0) NOT NULL COMMENT '唯一标识',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
CREATE TABLE `department` (
`id` int(0) NOT NULL COMMENT '唯一标识',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
CREATE TABLE `role` (
`id` int(0) NOT NULL COMMENT '唯一标识',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
CREATE TABLE `user` (
`id` int(0) NOT NULL COMMENT '唯一标识',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
\ No newline at end of file
... ...