refactor: 第三方登录接口

1、参数由openid改为code
2、后台先调用小程序接口获取openid
3、再用openid获取平台用户信息

@@ -5,6 +5,8 @@ import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
 import org.jetbrains.annotations.NotNull;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 import org.thingsboard.server.common.data.StringUtils;
@@ -76,11 +78,15 @@ public class YtThirdPlatformController extends BaseController {
         return thirdService.unbindUser(getCurrentUser().getCurrentTenantId(), dto.getAppUserId(),dto.getThirdUserId());
     }
 
-    @GetMapping("login/{thirdId}")
+    @GetMapping("login/{loginCode}")
     @ApiOperation("第三方登录")
-    public JwtTokenPair login(@PathVariable("thirdId") String thirdId)
+    public JwtTokenPair login(@PathVariable("loginCode") String loginCode)
             throws ThingsboardException {
-        UserDTO userDto = thirdService.login(thirdId);
+        String thirdUserId = thirdService.thirdLogin(loginCode);
+        UserDTO userDto = thirdService.login(thirdUserId);
+        if(userDto == null){
+            return new JwtTokenPair("", thirdUserId);
+        }
         return buildJwtToken(userDto);
     }
 

@@ -61,6 +61,7 @@ public enum ErrorMessage {
   DEVICE_USED_SCENE_REACT(400041,"场景联动【%s】正在使用该设备"),
   SCENE_REACT_USED_ALARM_PROFILE(400042,"场景联动正在使用该告警配置"),
   APP_USER_BINDED(400043,"平台用户【%s】已被其它账号绑定"),
+  THIRD_PLATFORM_EXCEPTION(400044,"【%s】，第三方异常【%s】"),
   HAVE_NO_PERMISSION(500002,"没有修改权限");
   private final int code;
   private String message;

@@ -6,12 +6,15 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.fasterxml.jackson.databind.JsonNode;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
 import org.springframework.security.authentication.BadCredentialsException;
 import org.springframework.security.core.userdetails.UsernameNotFoundException;
 import org.springframework.security.crypto.password.PasswordEncoder;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.client.RestTemplate;
 import org.thingsboard.server.common.data.StringUtils;
+import org.thingsboard.server.common.data.yunteng.config.third.WechatProperties;
 import org.thingsboard.server.common.data.yunteng.core.cache.CacheUtils;
 import org.thingsboard.server.common.data.yunteng.core.exception.YtDataValidationException;
 import org.thingsboard.server.common.data.yunteng.core.message.ErrorMessage;
@@ -23,6 +26,7 @@ import org.thingsboard.server.common.data.yunteng.dto.request.CodeTTL;
 import org.thingsboard.server.common.data.yunteng.enums.MessageTypeEnum;
 import org.thingsboard.server.common.data.yunteng.enums.MsgTemplatePurposeEnum;
 import org.thingsboard.server.common.data.yunteng.enums.ThirdPlatformEnum;
+import org.thingsboard.server.common.data.yunteng.utils.JacksonUtil;
 import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
 import org.thingsboard.server.dao.yunteng.entities.User;
 import org.thingsboard.server.dao.yunteng.entities.YtThirdUserEntity;
@@ -47,6 +51,9 @@ public class YtThirdPlatformServiceImpl extends AbstractBaseService<YtThirdPlatf
     private final CacheUtils cacheUtils;
     private final PasswordEncoder passwordEncoder;
 
+    private final RestTemplate restTemplate = new RestTemplate();
+    private final WechatProperties wechatProperties;
+
     @Override
     public YtPageData<YtThirdUserDTO> pageDatas(IPage<YtThirdUserEntity> pageInfrom, ThirdPlatformEnum platformName, String name) {
         Wrapper pageFilter = new QueryWrapper<YtThirdUserEntity>()
@@ -171,6 +178,19 @@ public class YtThirdPlatformServiceImpl extends AbstractBaseService<YtThirdPlatf
         return baseMapper.delete(filter) > 0;
     }
 
+    private static final String loginApi="/sns/jscode2session?appid={appid}&secret={appid}&js_code={appid}&grant_type=authorization_code";
+    @Override
+    public String thirdLogin(String loginCode) {
+        String response = restTemplate.getForObject(wechatProperties.getUrl()+loginApi,String.class, wechatProperties.getAppId(),wechatProperties.getAppSecret(),loginCode);
+        JsonNode result = JacksonUtil.toJsonNode(response);
+
+        if(result.has("errcode")){
+            throw new YtDataValidationException(String.format(ErrorMessage.THIRD_PLATFORM_EXCEPTION.getMessage(),ThirdPlatformEnum.WECHAT,result.get("errmsg").asText()));
+        }
+        String thirdUserId = result.get("openid").asText();
+        return thirdUserId;
+    }
+
     @Override
     public UserDTO login(String thirdUserId) {
         User user = baseMapper.login(thirdUserId);
@@ -186,4 +206,7 @@ public class YtThirdPlatformServiceImpl extends AbstractBaseService<YtThirdPlatf
     public JsonNode message(String receiver, JsonNode message) {
         return null;
     }
+
+
+
 }

@@ -44,6 +44,14 @@ public interface YtThirdPlatformService extends BaseService<YtThirdUserEntity> {
     /**
      * 第三方登录
      *
+     * @param loginCode
+     * @return
+     */
+    String thirdLogin(String loginCode);
+
+    /**
+     * 第三方登录
+     *
      * @param thirdUserId
      * @return
      */