|
@@ -3,6 +3,8 @@ package external
|
|
|
import (
|
|
import (
|
|
|
"context"
|
|
"context"
|
|
|
"os"
|
|
"os"
|
|
|
|
|
+
|
|
|
|
|
+ "github.com/rs/zerolog/log"
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
@@ -31,10 +33,12 @@ func RequestToPHP(receiverType string, receiverID int32, count int) error {
|
|
|
MsgCount: count,
|
|
MsgCount: count,
|
|
|
}
|
|
}
|
|
|
huaZhangGuiClient := NewHuaZhangGuiClient(url)
|
|
huaZhangGuiClient := NewHuaZhangGuiClient(url)
|
|
|
- _, err := huaZhangGuiClient.PostUnReadMessage(ctx, reqData)
|
|
|
|
|
|
|
+ res, err := huaZhangGuiClient.PostUnReadMessage(ctx, reqData)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
|
|
+ log.Error().Str("receiverType", receiverType).Int32("receiverID", receiverID).Int("count", count).Err(err).Msg("向 PHP 服务发送未读消息通知失败")
|
|
|
return err
|
|
return err
|
|
|
}
|
|
}
|
|
|
|
|
+ log.Info().Str("receiverType", receiverType).Int32("receiverID", receiverID).Int("count", count).Str("res", res).Msg("向 PHP 服务发送未读消息通知成功")
|
|
|
|
|
|
|
|
case "huaHuiBao":
|
|
case "huaHuiBao":
|
|
|
url := os.Getenv("HUA_HUI_BAO_URL")
|
|
url := os.Getenv("HUA_HUI_BAO_URL")
|
|
@@ -44,10 +48,12 @@ func RequestToPHP(receiverType string, receiverID int32, count int) error {
|
|
|
MsgCount: count,
|
|
MsgCount: count,
|
|
|
}
|
|
}
|
|
|
huaHuiBaoClient := NewHuaHuiBaoClient(url)
|
|
huaHuiBaoClient := NewHuaHuiBaoClient(url)
|
|
|
- _, err := huaHuiBaoClient.PostUnReadMessage(ctx, reqData)
|
|
|
|
|
|
|
+ res, err := huaHuiBaoClient.PostUnReadMessage(ctx, reqData)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
|
|
+ log.Error().Str("receiverType", receiverType).Int32("receiverID", receiverID).Int("count", count).Err(err).Msg("向 PHP 服务发送未读消息通知失败")
|
|
|
return err
|
|
return err
|
|
|
}
|
|
}
|
|
|
|
|
+ log.Info().Str("receiverType", receiverType).Int32("receiverID", receiverID).Int("count", count).Str("res", res).Msg("向 PHP 服务发送未读消息通知成功")
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
return nil
|