cooperation_statistics.go
4.5 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
package service
import (
"github.com/linmadan/egglib-go/core/application"
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/application/cooperationStatistics/query"
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/application/factory"
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/domain_service"
)
// ContractDividendStatistics 合约分红统计
type CooperationStatisticsService struct {
}
// CooperationContractStatistics 共创合约统计
func (svr *CooperationStatisticsService) CooperationContractStatistics(contractStatisticsQuery *query.CooperationStatisticsQuery) (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.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 res, nil
}