作者 yangfu

Merge remote-tracking branch 'origin/dev' into test

@@ -180,6 +180,7 @@ func getStatistics(userId int64, transactionContext *transaction.TransactionCont @@ -180,6 +180,7 @@ func getStatistics(userId int64, transactionContext *transaction.TransactionCont
180 Statistics["developOrdersMoney"] = 0 180 Statistics["developOrdersMoney"] = 0
181 Statistics["appDividend"] = 0 181 Statistics["appDividend"] = 0
182 Statistics["appOrdersMoney"] = 0 182 Statistics["appOrdersMoney"] = 0
  183 + Statistics["totalCount"] = len(partnerIds)
183 return Statistics, nil 184 return Statistics, nil
184 } 185 }
185 186
1 package event 1 package event
2 2
3 -import (  
4 - "github.com/tiptok/gocomm/xa/eda"  
5 - "gitlab.fjmaimaimai.com/mmm-go/partner/pkg/application/event/subscriber"  
6 - devent "gitlab.fjmaimaimai.com/mmm-go/partner/pkg/domain/event"  
7 -)  
8 -  
9 func InitEventCenter() { 3 func InitEventCenter() {
10 - eda.RegisterSubscribe(&devent.AccessTokenEvent{}, &subscriber.AuthCacheSubscribe{})  
11 - eda.RegisterSubscribe(&devent.RefreshTokenEvent{}, &subscriber.AuthCacheSubscribe{}) 4 + //eda.RegisterSubscribe(&devent.AccessTokenEvent{}, &subscriber.AuthCacheSubscribe{})
  5 + //eda.RegisterSubscribe(&devent.RefreshTokenEvent{}, &subscriber.AuthCacheSubscribe{})
12 } 6 }
@@ -204,7 +204,7 @@ func (svr *PgLoginService) GetCompanyList(funcGetCompanyIds func() []int64) []*d @@ -204,7 +204,7 @@ func (svr *PgLoginService) GetCompanyList(funcGetCompanyIds func() []int64) []*d
204 if len(companies) == 0 { 204 if len(companies) == 0 {
205 return companyList 205 return companyList
206 } 206 }
207 - if _, v, e := CompanyRepository.Find(map[string]interface{}{"inCompanyIds": companies, "status": 1, "sortByCreateTime": domain.DESC}); e != nil { 207 + if _, v, e := CompanyRepository.Find(map[string]interface{}{"inCompanyIds": companies, "enable": 1, "sortByCreateTime": domain.DESC}); e != nil {
208 log.Error(e) 208 log.Error(e)
209 return companyList 209 return companyList
210 } else { 210 } else {
@@ -69,7 +69,8 @@ func (repository *CompanyRepository) Find(queryOptions map[string]interface{}) ( @@ -69,7 +69,8 @@ func (repository *CompanyRepository) Find(queryOptions map[string]interface{}) (
69 companyIds, _ := companies.([]int64) 69 companyIds, _ := companies.([]int64)
70 query.Where("id in (?)", pg.In(companyIds)) 70 query.Where("id in (?)", pg.In(companyIds))
71 } 71 }
72 - query.SetWhere("status = ?", "status") 72 + //query.SetWhere("status = ?", "status")
  73 + query.SetWhere(`enable = ?`, "enable")
73 query.SetOrder(`create_at`, "sortByCreateTime") 74 query.SetOrder(`create_at`, "sortByCreateTime")
74 var err error 75 var err error
75 if query.AffectRow, err = query.SelectAndCount(); err != nil { 76 if query.AffectRow, err = query.SelectAndCount(); err != nil {
@@ -12,6 +12,6 @@ func init() { @@ -12,6 +12,6 @@ func init() {
12 beego.InsertFilter("/*", beego.BeforeExec, middleware.CreateRequstLogFilter(Logger)) 12 beego.InsertFilter("/*", beego.BeforeExec, middleware.CreateRequstLogFilter(Logger))
13 beego.InsertFilter("/*", beego.AfterExec, middleware.CreateResponseLogFilter(Logger), false) 13 beego.InsertFilter("/*", beego.AfterExec, middleware.CreateResponseLogFilter(Logger), false)
14 14
15 - beego.InsertFilter("/v1/*", beego.BeforeExec, middleware.CheckJWTToken)  
16 - beego.InsertFilter("/v2/*", beego.BeforeExec, middleware.CheckJWTToken) 15 + //beego.InsertFilter("/v1/*", beego.BeforeExec, middleware.CheckJWTToken)
  16 + //beego.InsertFilter("/v2/*", beego.BeforeExec, middleware.CheckJWTToken)
17 } 17 }