作者 yangfu

共创统计服务

@@ -28,13 +28,13 @@ func (svr *CooperationStatisticsService) CooperationContractStatistics(contractS @@ -28,13 +28,13 @@ func (svr *CooperationStatisticsService) CooperationContractStatistics(contractS
28 _ = transactionContext.RollbackTransaction() 28 _ = transactionContext.RollbackTransaction()
29 }() 29 }()
30 30
31 - contractDividendsService, err := factory.CreateNewCooperationStatisticsService(map[string]interface{}{ 31 + statisticsService, err := factory.CreateCooperationStatisticsService(map[string]interface{}{
32 "transactionContext": transactionContext, 32 "transactionContext": transactionContext,
33 }) 33 })
34 var res interface{} 34 var res interface{}
35 switch contractStatisticsQuery.Action { 35 switch contractStatisticsQuery.Action {
36 case domain_service.ContractDividends: 36 case domain_service.ContractDividends:
37 - res, err = contractDividendsService.SearchContractDividends(contractStatisticsQuery.QueryOptions) 37 + res, err = statisticsService.SearchContractDividends(contractStatisticsQuery.QueryOptions)
38 } 38 }
39 if err != nil { 39 if err != nil {
40 return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error()) 40 return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
@@ -22,10 +22,10 @@ func CreateOrganizationService(options map[string]interface{}) (service.OrgServi @@ -22,10 +22,10 @@ func CreateOrganizationService(options map[string]interface{}) (service.OrgServi
22 return domain_service.NewOrganizationService() 22 return domain_service.NewOrganizationService()
23 } 23 }
24 24
25 -func CreateContractDividendsService(options map[string]interface{}) (*domain_service.ContractStatisticsService, error) { 25 +func CreateCooperationStatisticsService(options map[string]interface{}) (*domain_service.CooperationStatisticsService, error) {
26 var transactionContext *pgTransaction.TransactionContext 26 var transactionContext *pgTransaction.TransactionContext
27 if value, ok := options["transactionContext"]; ok { 27 if value, ok := options["transactionContext"]; ok {
28 transactionContext = value.(*pgTransaction.TransactionContext) 28 transactionContext = value.(*pgTransaction.TransactionContext)
29 } 29 }
30 - return domain_service.NewContractStatisticsService(transactionContext) 30 + return domain_service.NewCooperationStatisticsService(transactionContext)
31 } 31 }