+IM设置推送昵称;

liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-easemob/src/main/java/com/liquidnet/common/third/easemob/util/EasemobUtil.java

@@ -18,6 +18,8 @@ import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 import org.springframework.web.client.HttpClientErrorException;
 
+import java.nio.charset.StandardCharsets;
+
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
  * @version V1.0
@@ -36,6 +38,9 @@ public class EasemobUtil{
     @Autowired
     private RedisUtil redisUtil;
 
+    private static MultiValueMap<String, String> commonHeader = new LinkedMultiValueMap();
+    private static MultiValueMap<String, String> commonParams = new LinkedMultiValueMap();
+
     private String getAccessToken(){
 
         //构造请求参数
@@ -76,7 +81,8 @@ public class EasemobUtil{
     }
 
     public String createUser(String userName, String password, String nickName){
-        MultiValueMap<String, String> commonHeader = new LinkedMultiValueMap();
+//        MultiValueMap<String, String> commonHeader = new LinkedMultiValueMap();
+        commonHeader.clear();
         commonHeader.add("Authorization", "Bearer "+this.getAccessToken());
 
         JSONObject json = new JSONObject();
@@ -114,4 +120,22 @@ public class EasemobUtil{
         //result
 //        {application=c785eced-c603-41c3-afe8-13ee3378540c, access_token=YWMt_rE7Rg8DEeyy6gf--JvBcwAAAAAAAAAAAAAAAAAAAAHHheztxgNBw6_oE-4zeFQMAgMAAAF7utOj1gBPGgANws4VZcHltyc-SPep4q09E0mqitzKe5IA6Npu-MqLBg, expires_in=5184000}
     }
+
+    public void settingNoticeNickname(String nickname, String username) {
+        try {
+            commonHeader.clear();
+            commonHeader.add("Authorization", "Bearer " + this.getAccessToken());
+            commonParams.clear();
+            commonParams.add("nickname", nickname);
+
+            String url = easemobConfig.getPreUrl().concat(EasemobConstant.CREATE_USER_URL).concat("/").concat(username);
+            String response = HttpUtil.put(url, commonParams, commonHeader);
+            log.info("IM setting notice.nickname:[url={},nickname={},response={}]", url, nickname, response);
+        } catch (HttpClientErrorException e) {
+            String responseBodyAsString = e.getResponseBodyAsString(StandardCharsets.UTF_8);
+            log.error("IM setting notice.nickname error:[request.status=400,msg={}]", responseBodyAsString);
+        } catch (Exception e) {
+            log.error("IM setting notice.nickname exception", e);
+        }
+    }
 }

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserInfoServiceImpl.java

@@ -18,6 +18,7 @@ import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.feign.adam.rsc.FeignAdamChimeClient;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
@@ -92,8 +93,6 @@ public class AdamUserInfoServiceImpl implements IAdamUserInfoService {
 
                     syncChimeRegisterFlg = true;
                 }
-            } else if (isComplete == 11) {// 同步IM信息
-                // TODO: 2021/9/17 暂未接入
             }
 
             syncChimeFlg = true;
@@ -101,6 +100,12 @@ public class AdamUserInfoServiceImpl implements IAdamUserInfoService {
             tagMe = existUserInfoVo.getTagMe();
         }
 
+        String beforeNickname = existUserInfoVo.getNickname();
+        if (StringUtils.isEmpty(beforeNickname) || !beforeNickname.equals(parameter.getNickname())) {
+            // IM设置推送昵称
+            easemobUtil.settingNoticeNickname(parameter.getNickname(), existUserInfoVo.getUid());
+        }
+
         existUserInfoVo.setAvatar(parameter.getAvatar());
         existUserInfoVo.setBackground(parameter.getBackground());
         existUserInfoVo.setNickname(parameter.getNickname());