common_statistics.go
4.6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
package service
import (
"github.com/linmadan/egglib-go/core/application"
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/application/factory"
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/application/statistics/query"
)
// CommonStatisticsService 通用的统计服务
type CommonStatisticsService struct {
}
// CommonStatisticsService 通用的统计服务
func (svr *CommonStatisticsService) CommonStatisticsService(contractStatisticsQuery *query.CommonStatisticsQuery) (interface{}, error) {
if err := contractStatisticsQuery.ValidateQuery(); err != nil {
return nil, application.ThrowError(application.ARG_ERROR, err.Error())
}
var err error
transactionContext, err := factory.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())
}
defer func() {
_ = transactionContext.RollbackTransaction()
}()
//statisticsService, err := factory.CreateCooperationStatisticsService(map[string]interface{}{
// "transactionContext": transactionContext,
//})
//var res interface{}
//switch contractStatisticsQuery.Action {
//case domain_service.SearchContractDividends:
// res, err = statisticsService.SearchContractDividends(contractStatisticsQuery.QueryOptions)
//case domain_service.GetContractDividends:
// res, err = statisticsService.GetContractDividends(contractStatisticsQuery.QueryOptions)
//case domain_service.CooperationGoodsStatistics:
// res, err = statisticsService.CooperationGoodsStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.CooperationModeStatistics:
// res, err = statisticsService.CooperationModeStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.CompanyDividendsStatistics:
// res, err = statisticsService.CompanyDividendsStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.CompanyCooperationUsersStatistics:
// res, err = statisticsService.CompanyCooperationUsersStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.CompanyPaymentHistoryStatistics:
// res, err = statisticsService.CompanyPaymentHistoryStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.CompanyCooperationProjectContracts:
// res, err = statisticsService.CompanyCooperationProjectContracts(contractStatisticsQuery.QueryOptions)
//case domain_service.PaymentHistoryHistogramStatistics:
// res, err = statisticsService.PaymentHistoryHistogramStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.CooperationUserModeStatistics:
// res, err = statisticsService.CooperationUserModeStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.DividendsStatistics:
// res, err = statisticsService.DividendsStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.SearchDividendsEstimates:
// res, err = statisticsService.SearchDividendsEstimates(contractStatisticsQuery.QueryOptions)
//case domain_service.CooperationCompanyStatistics:
// res, err = statisticsService.CooperationCompanyStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.PersonCooperationContractStatistics:
// res, err = statisticsService.PersonCooperationContractStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.PersonCompanyPaymentHistoryStatistics:
// res, err = statisticsService.PersonCompanyPaymentHistoryStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.PersonCooperationProjectSharedInfo:
// res, err = statisticsService.PersonCooperationProjectSharedInfo(contractStatisticsQuery.QueryOptions)
//case domain_service.PersonCooperationProjectSharedInfoAttachment:
// res, err = statisticsService.PersonCooperationProjectSharedInfoAttachment(contractStatisticsQuery.QueryOptions)
//case domain_service.PersonCooperationCompany:
// res, err = statisticsService.PersonCooperationCompany(contractStatisticsQuery.QueryOptions)
//case domain_service.CreditAccountStatistics:
// res, err = statisticsService.CreditAccountStatistics(contractStatisticsQuery.QueryOptions)
//case domain_service.RelevantCooperationContractNumbers:
// res, err = statisticsService.RelevantCooperationContractNumbers(contractStatisticsQuery.QueryOptions)
//}
if err != nil {
return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
}
if err := transactionContext.CommitTransaction(); err != nil {
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
}
return struct {
}{}, nil
}