审查视图

pkg/application/factory/reposetory.go 10.1 KB
tangxvhui authored
1 2 3 4 5 6 7 8
package factory

import (
	"github.com/linmadan/egglib-go/core/application"
	"github.com/linmadan/egglib-go/transaction/pg"
	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
	pgDB "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/pg"
	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/repository"
9
	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/utils"
tangxvhui authored
10 11 12 13 14 15
)

func CreateTransactionContext(options map[string]interface{}) (application.TransactionContext, error) {
	return pg.NewPGTransactionContext(pgDB.DB), nil
}
16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35
// StartTransaction 事务创建
func StartTransaction() (application.TransactionContext, error) {
	transactionContext, err := CreateTransactionContext(nil)
	if err != nil {
		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
	}
	if err := transactionContext.StartTransaction(); err != nil {
		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
	}
	return transactionContext, nil
}

// ValidateStartTransaction 事务创建并校验入参
func ValidateStartTransaction(in interface{}) (application.TransactionContext, error) {
	if err := utils.ValidateCommand(in); err != nil {
		return nil, application.ThrowError(application.ARG_ERROR, err.Error())
	}
	return StartTransaction()
}
tangxvhui authored
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50
func CreateCompanyRepository(options map[string]interface{}) domain.CompanyRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewCompanyRepository(transactionContext)
}

func CreateUserRepository(options map[string]interface{}) domain.UserRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewUserRepository(transactionContext)
}
tangxvhui authored
51 52 53 54 55 56 57 58

func CreateDepartmentRepository(options map[string]interface{}) domain.DepartmentRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewDepartmentRepository(transactionContext)
}
59
庄敏学 authored
60 61 62 63 64 65 66 67
func CreatePositionRepository(options map[string]interface{}) domain.PositionRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewPositionRepository(transactionContext)
}
68 69 70 71 72 73 74 75 76 77 78 79 80 81 82
func CreateRoleRepository(options map[string]interface{}) domain.RoleRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewRoleRepository(transactionContext)
}

func CreateRoleUserRepository(options map[string]interface{}) domain.RoleUserRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewRoleUserRepository(transactionContext)
}
83
tangxvhui authored
84 85 86 87 88 89 90
func CreateReceivedMessageRepository(options map[string]interface{}) domain.ReceivedMessageRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewReceivedMessageRepository(transactionContext)
}
91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115

func CreateEvaluationRuleRepository(options map[string]interface{}) domain.EvaluationRuleRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewEvaluationRuleRepository(transactionContext)
}

func CreateEvaluationTemplateRepository(options map[string]interface{}) domain.EvaluationTemplateRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewEvaluationTemplateRepository(transactionContext)
}

func CreateEvaluationCycleRepository(options map[string]interface{}) domain.EvaluationCycleRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewEvaluationCycleRepository(transactionContext)
}
116 117 118 119 120 121 122 123
func CreateEvaluationCycleTemplateRepository(options map[string]interface{}) domain.EvaluationCycleTemplateRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewEvaluationCycleTemplateRepository(transactionContext)
}
124 125 126 127 128 129
func CreateEvaluationProjectRepository(options map[string]interface{}) domain.EvaluationProjectRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewEvaluationProjectRepository(transactionContext)
郑周 authored
130 131 132 133 134 135 136 137
}

func CreateNodeTaskRepository(options map[string]interface{}) domain.NodeTaskRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewNodeTaskRepository(transactionContext)
138
}
Your Name authored
139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155

func CreateStaffAssessRepository(options map[string]interface{}) domain.StaffAssessRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewStaffAssessRepository(transactionContext)
}

func CreateStaffAssessContentRepository(options map[string]interface{}) domain.StaffAssessContentRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewStaffAssessContentRepository(transactionContext)
}
Your Name authored
156
func CreateStaffAssessTaskRepository(options map[string]interface{}) domain.StaffAssessTaskRepository {
Your Name authored
157 158 159 160
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
Your Name authored
161
	return repository.NewStaffAssessTaskRepository(transactionContext)
Your Name authored
162
}
tangxvhui authored
163
164 165 166 167 168 169 170
func CreateStaffAssessCacheRepository(options map[string]interface{}) domain.StaffAssessCacheRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewStaffAssessCacheRepository(transactionContext)
}
tangxvhui authored
171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194

func CreateSummaryEvaluationRepository(options map[string]interface{}) domain.SummaryEvaluationRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewSummaryEvaluationRepository(transactionContext)
}

func CreateSummaryEvaluationValueRepository(options map[string]interface{}) domain.SummaryEvaluationValueRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewSummaryEvaluationValueRepository(transactionContext)
}

func CreateEvaluationItemUsedRepository(options map[string]interface{}) domain.EvaluationItemUsedRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewEvaluationItemUsedRepository(transactionContext)
}
郑周 authored
195 196 197 198 199 200 201 202

func CreatePermissionRepository(options map[string]interface{}) domain.PermissionRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewPermissionRepository(transactionContext)
}
tangxvhui authored
203 204 205 206 207 208 209 210

func CreateLogSmsRepository(options map[string]interface{}) domain.LogSmsRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewLogSmsRepository(transactionContext)
}
tangxvhui authored
211 212 213 214 215 216 217 218

func CreateMessagePersonalRepository(options map[string]interface{}) domain.MessagePersonalRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewMessagePersonalRepository(transactionContext)
}
tangxvhui authored
219 220 221 222 223 224 225 226 227 228 229 230 231 232 233
func CreateTaskRepository(options map[string]interface{}) domain.TaskRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewTaskRepository(transactionContext)
}

func CreateTaskStageRepository(options map[string]interface{}) domain.TaskStageRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewTaskStageRepository(transactionContext)
}
tangxvhui authored
234 235 236 237 238 239 240 241

func CreateTaskIgnoreRepository(options map[string]interface{}) domain.TaskIgnoreRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewTaskIgnoreRepository(transactionContext)
}
242 243 244 245 246 247 248 249

func CreateTaskRecordRepository(options map[string]interface{}) domain.TaskRecordRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewTaskRecordRepository(transactionContext)
}
tangxvhui authored
250 251 252 253 254 255 256 257

func CreateTaskLevelRepository(options map[string]interface{}) domain.TaskLevelRepository {
	var transactionContext *pg.TransactionContext
	if value, ok := options["transactionContext"]; ok {
		transactionContext = value.(*pg.TransactionContext)
	}
	return repository.NewTaskLevelRepository(transactionContext)
}