|
...
|
...
|
@@ -2,7 +2,6 @@ package handle |
|
|
|
|
|
|
|
import (
|
|
|
|
"encoding/json"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/position/service"
|
|
|
|
"strconv"
|
|
|
|
|
|
|
|
"github.com/Shopify/sarama"
|
|
...
|
...
|
@@ -89,16 +88,16 @@ func SyncDataBusinessAdmin(msgData *sarama.ConsumerMessage) error { |
|
|
|
return err
|
|
|
|
}
|
|
|
|
case "position":
|
|
|
|
positionSrv := service.SyncDataPositionService{}
|
|
|
|
err = positionSrv.FromBusinessAdmin(&msgBody)
|
|
|
|
if err != nil {
|
|
|
|
log.Logger.Error("处理position消息失败"+err.Error(), map[string]interface{}{
|
|
|
|
"module": msgBody.Module,
|
|
|
|
"action": msgBody.Action,
|
|
|
|
"data": string(msgBody.Data),
|
|
|
|
})
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
//positionSrv := service.SyncDataPositionService{}
|
|
|
|
//err = positionSrv.FromBusinessAdmin(&msgBody)
|
|
|
|
//if err != nil {
|
|
|
|
// log.Logger.Error("处理position消息失败"+err.Error(), map[string]interface{}{
|
|
|
|
// "module": msgBody.Module,
|
|
|
|
// "action": msgBody.Action,
|
|
|
|
// "data": string(msgBody.Data),
|
|
|
|
// })
|
|
|
|
// return err
|
|
|
|
//}
|
|
|
|
}
|
|
|
|
err = msgRepo.SaveMessage(&receivedMsg)
|
|
|
|
if err != nil {
|
...
|
...
|
|
