login registerByMobile

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetWechatLoginServiceImpl.java

@@ -3,12 +3,17 @@ package com.liquidnet.service.sweet.service.impl;
 import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
 import cn.binarywang.wx.miniapp.bean.WxMaPhoneNumberInfo;
 import com.liquidnet.commons.lang.util.CollectionUtil;
+import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.base.ResponseDto;
 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.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
 
 import java.util.HashMap;
 import java.util.Objects;
@@ -28,6 +33,9 @@ public class SweetWechatLoginServiceImpl {
     @Autowired
     private SweetWechatService sweetWechatService;
 
+    @Value("${liquidnet.service.adam.url}")
+    private String adamUrl;
+
     public ResponseDto userInfo(String code, String encryptedData, String iv, Integer type) {
         log.info("\n参数code：[{}] ", code);
         log.info("\n参数encryptedData：[{}] ", encryptedData);
@@ -47,6 +55,8 @@ public class SweetWechatLoginServiceImpl {
                 return ResponseDto.failure("解密手机号码信息错误");
             }
 
+            registerByMobile(wxMaPhoneNumberInfo.getPurePhoneNumber());
+
             String unionId = sessionInfo.getUnionid();
             String openId = sessionInfo.getOpenid();
 
@@ -64,4 +74,15 @@ public class SweetWechatLoginServiceImpl {
         }
     }
 
+    @Async
+    public void registerByMobile(String mobile) {
+        try {
+            MultiValueMap<String, String> params = new LinkedMultiValueMap();
+            params.add("mobile", mobile);
+            HttpUtil.post(adamUrl.concat("/adam/rsc/reg/mobile"), params);
+        } catch (Exception e) {
+            log.error("registerByMobile失败", e);
+        }
+    }
+
 }