作者 tangxvhui

更新

@@ -8,8 +8,10 @@ import ( @@ -8,8 +8,10 @@ import (
8 8
9 "github.com/linmadan/egglib-go/core/application" 9 "github.com/linmadan/egglib-go/core/application"
10 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/factory" 10 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/factory"
  11 + "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/constant"
11 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain" 12 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
12 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/dao" 13 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/dao"
  14 + "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/serviceGateway"
13 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/log" 15 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/log"
14 ) 16 )
15 17
@@ -138,13 +140,13 @@ func appMessageSend() error { @@ -138,13 +140,13 @@ func appMessageSend() error {
138 appMessage = append(appMessage, messageList...) 140 appMessage = append(appMessage, messageList...)
139 } 141 }
140 142
141 - // openApi := serviceGateway.NewHttplibMmmOpenApiServiceGateway()  
142 - // for _, val := range appMessage {  
143 - // _, err := openApi.PushInfo(1, constant.APP_MESSAGE_KEY, []int64{int64(val.TargetUserId)}, val.Title, val.Content)  
144 - // if err != nil {  
145 - // log.Logger.Error("发送远端openApi关于里程碑异常的消息通知:" + err.Error())  
146 - // }  
147 - // } 143 + openApi := serviceGateway.NewHttplibMmmOpenApiServiceGateway()
  144 + for _, val := range appMessage {
  145 + _, err := openApi.PushInfo(1, constant.APP_MESSAGE_KEY, []int64{int64(val.TargetUserId)}, val.Title, val.Content)
  146 + if err != nil {
  147 + log.Logger.Error("发送远端openApi关于里程碑异常的消息通知:" + err.Error())
  148 + }
  149 + }
148 150
149 err = saveAllMessagePersonal(appMessage) 151 err = saveAllMessagePersonal(appMessage)
150 if err != nil { 152 if err != nil {