天眼日志添加

back_recharge
duhui 2021-10-28 13:20:24 +08:00
parent d5dc87e1cd
commit 0b0f021bf5
1 changed files with 8 additions and 8 deletions

View File

@ -487,14 +487,13 @@ public class MessageUtil {
v3.setFrom(buildChatUser(me));
v3.setContent(msg);
if (skyEyeExtraMap.isEmpty()){
String url = Optional.ofNullable(ConfigurableApplicationContextManager.getBean(SkyEyeAutoConfigration.class))
.map(SkyEyeAutoConfigration::getSkyEyeProperties)
.map(SkyEyeProperties::getGmAddress)
.orElse("");
skyEyeExtraMap.put("url",url);
}
v3.setExtra(JSONObject.toJSONString(skyEyeExtraMap));
JSONObject object = new JSONObject();
String url = Optional.ofNullable(ConfigurableApplicationContextManager.getBean(SkyEyeAutoConfigration.class))
.map(SkyEyeAutoConfigration::getSkyEyeProperties)
.map(SkyEyeProperties::getGmAddress)
.orElse("");
object.put("url",url);
v3.setExtra(object.toJSONString());
ISession iSession = OnlineUserManager.getSessionByUid(me.getId());
String ip = Optional.ofNullable(iSession).map(v->v.getChannel().getLocalAddress().getHostString()).orElse("");
@ -524,6 +523,7 @@ public class MessageUtil {
* @param chatV3
*/
private static void skyEyeSendMsg(ChatProto.ChatV3 chatV3){
LOGGER.info("天眼上报,参数:【{}】",chatV3.toBuilder().toString());
SkyEyeAutoConfigration netServerConfig = ConfigurableApplicationContextManager.getBean(SkyEyeAutoConfigration.class);
SkyEyeProperties properties = netServerConfig.getSkyEyeProperties();
if(properties == null){