adiciona recalculo do pm quando termina o feeder

cmd/guru.feeder.investor.corporate.actions.go

@@ -18,7 +18,7 @@ func init() {
 func main() {
 	time_zone, _ := time.LoadLocation("America/Sao_Paulo")
 
-	//core.ApplyEvents("Ayqi8gfb")
+	//core.ApplyEvents("fzVzgo8b")
 	//core.ApplyEventsAfterInvestorSync("fzVzgo8b")
 	//core.Run()
 

src/constants/events.go

@@ -22,6 +22,8 @@ const (
 
 const (
 	ManualSourceType = "REGULAR"
+	BonusOMSSourceType = "OMS"
+	BonusInvestorSourceType = "InvestorB3"
 )
 
 const (

src/core/core.go

@@ -60,6 +60,9 @@ func ApplyEvents(customerCode string) {
 	go doProceedsOMSEvents()
 	go doProceedsCEIEvents()
 	wg.Wait()
+
+	go repository.NewWalletConnector().ResyncAveragePrice()
+
 	fmt.Println("Finalizou")
 }
 

src/core/events/manual/inherited_bonus.go

@@ -18,8 +18,8 @@ func ApplyInheritedBonusActionOMS(manualTransaction mapper.ManualTransaction, pr
 		manualTransaction.Price = constants.MinimalValue
 		manualTransaction.Amount = constants.MinimalValue
 		manualTransaction.Side = constants.Purchase
-		manualTransaction.TradeDate = proceed.PaymentDate // TODO - Validar com TOM
-		manualTransaction.SourceType = constants.ManualSourceType
+		manualTransaction.TradeDate = proceed.InitialDate // TODO - Validar com TOM
+		manualTransaction.SourceType = constants.BonusOMSSourceType
 		manualTransaction.EventDate = proceed.InitialDate
 		manualTransaction.EventName = proceed.Event
 
@@ -32,7 +32,7 @@ func ApplyInheritedBonusActionOMS(manualTransaction mapper.ManualTransaction, pr
 			manualTransaction.Price,
 			manualTransaction.Amount,
 			manualTransaction.Side,
-			manualTransaction.TradeDate.Format("02/01/2006"),
+			manualTransaction.TradeDate.String(),
 			manualTransaction.SourceType,
 			manualTransaction.EventDate.String(),
 			manualTransaction.EventName,
@@ -56,8 +56,8 @@ func ApplyInheritedBonusActionCEI(manualTransaction mapper.ManualTransaction, pr
 		manualTransaction.Price = constants.MinimalValue
 		manualTransaction.Amount = constants.MinimalValue
 		manualTransaction.Side = constants.Purchase
-		manualTransaction.TradeDate = proceed.PaymentDate // TODO - Validar com TOM
-		manualTransaction.SourceType = constants.ManualSourceType
+		manualTransaction.TradeDate = proceed.InitialDate // TODO - Validar com TOM
+		manualTransaction.SourceType = constants.BonusInvestorSourceType
 		manualTransaction.EventDate = proceed.InitialDate
 		manualTransaction.EventName = proceed.Event
 
@@ -70,7 +70,7 @@ func ApplyInheritedBonusActionCEI(manualTransaction mapper.ManualTransaction, pr
 			manualTransaction.Price,
 			manualTransaction.Amount,
 			manualTransaction.Side,
-			manualTransaction.TradeDate.Format("02/01/2006"),
+			manualTransaction.TradeDate.String(),
 			manualTransaction.SourceType,
 			manualTransaction.EventDate.String(),
 			manualTransaction.EventName,

src/crossCutting/options/EndPointsOption.go

@@ -0,0 +1,5 @@
+package options
+
+type EndPointsOption struct {
+	WalletSync string `json:"wallet-sync"`
+}

src/crossCutting/options/options.go

@@ -10,7 +10,8 @@ import (
 var OPTIONS Options
 
 type Options struct {
-	DATABASE DatabaseOption `json:"database"`
+	DATABASE  DatabaseOption  `json:"database"`
+	ENDPOINTS EndPointsOption `json:"endpoints"`
 }
 
 func (c *Options) Load() {

src/repository/ConnectionRepository.go

@@ -20,12 +20,13 @@ func (db *DatabaseConnection) connect() {
 
 	DATABASE := options.OPTIONS.DATABASE
 	dsn := fmt.Sprintf(
-		"user=%s password=%s dbname=%s host=%s port=%s",
+		"user=%s password=%s dbname=%s host=%s port=%s timezone=%s",
 		DATABASE.Username,
 		DATABASE.Password,
 		DATABASE.Database,
 		DATABASE.Url,
-		DATABASE.Port)
+		DATABASE.Port,
+		"America/Sao_Paulo")
 
 	newLogger := logger.New(
 		log.New(os.Stdout, "\r\n", log.LstdFlags), // io writer

src/repository/WalletConnector.go

@@ -0,0 +1,31 @@
+package repository
+
+import (
+	"github.com/guru-invest/guru.feeder.investor.corporate.actions/src/crossCutting/options"
+	http_connector "github.com/guru-invest/guru.framework/src/infrastructure/http-connector"
+)
+
+type WalletConnector struct {
+	_baseURL string
+}
+
+func NewWalletConnector() WalletConnector {
+	return WalletConnector{
+		_baseURL: options.OPTIONS.ENDPOINTS.WalletSync,
+	}
+}
+
+func (t WalletConnector) ResyncAveragePrice() error {
+	uri := t._baseURL + "/all/recalcavg"
+	client := http_connector.HttpClient{}
+
+	header := map[string]string{
+		"Content-type": "application/json",
+	}
+	_, err := client.Post(uri, nil, header)
+	if err != nil {
+
+		return err
+	}
+	return nil
+}