|
|
@@ -1,113 +1,109 @@
|
|
|
package com.fs.wxcid.service.impl;
|
|
|
|
|
|
-import com.fs.wxcid.dto.common.ApiResponse;
|
|
|
-import com.fs.wxcid.dto.login.LoginRequest;
|
|
|
+import com.fs.common.core.redis.RedisCache;
|
|
|
+import com.fs.common.exception.CustomException;
|
|
|
+import com.fs.wxcid.dto.common.ApiResponseCommon;
|
|
|
+import com.fs.wxcid.dto.login.LoginQrCodeResponseData;
|
|
|
+import com.fs.wxcid.dto.login.LoginStatusData;
|
|
|
+import com.fs.wxcid.dto.login.LoginStatusResponseData;
|
|
|
import com.fs.wxcid.dto.login.QrCodeRequest;
|
|
|
-import com.fs.wxcid.dto.login.SlideVerifyRequest;
|
|
|
-import com.fs.wxcid.dto.login.VerifyCodeRequest;
|
|
|
import com.fs.wxcid.service.LoginService;
|
|
|
import com.fs.wxwork.utils.WxWorkHttpUtil;
|
|
|
import com.alibaba.fastjson.TypeReference;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import java.util.HashMap;
|
|
|
-import java.util.Map;
|
|
|
|
|
|
+@Slf4j
|
|
|
@Service
|
|
|
public class LoginServiceImpl implements LoginService {
|
|
|
|
|
|
private static final String BASE_URL = "http://114.117.215.244:7006";
|
|
|
|
|
|
- // ------------------ 账号密码登录 ------------------
|
|
|
-
|
|
|
- public ApiResponse a16Login(String authKey, LoginRequest request) {
|
|
|
- return post("/login/A16Login", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse deviceLogin(String authKey, LoginRequest request) {
|
|
|
- return post("/login/DeviceLogin", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- // ------------------ 二维码登录 ------------------
|
|
|
-
|
|
|
- public ApiResponse getLoginQrCodeNew(String authKey, QrCodeRequest request) {
|
|
|
- return post("/login/GetLoginQrCodeNew", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse getLoginQrCodeNewDirect(String authKey, QrCodeRequest request) {
|
|
|
- return post("/login/GetLoginQrCodeNewDirect", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse macLogin(String authKey, QrCodeRequest request) {
|
|
|
- return post("/login/MacLogin", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse carLogin(String authKey, QrCodeRequest request) {
|
|
|
- return post("/login/CarLogin", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse wakeUpLogin(String authKey, QrCodeRequest request) {
|
|
|
- return post("/login/WakeUpLogin", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- // ------------------ 状态检测 ------------------
|
|
|
-
|
|
|
- public ApiResponse checkCanSetAlias(String authKey) {
|
|
|
- return get("/login/CheckCanSetAlias", authKey);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse checkLoginStatus(String authKey) {
|
|
|
- return get("/login/CheckLoginStatus", authKey);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse getLoginStatus(String authKey) {
|
|
|
- return get("/login/GetLoginStatus", authKey);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse get62Data(String authKey) {
|
|
|
- return get("/login/Get62Data", authKey);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse logOut(String authKey) {
|
|
|
- return get("/login/LogOut", authKey);
|
|
|
- }
|
|
|
-
|
|
|
- // ------------------ 验证 ------------------
|
|
|
-
|
|
|
- public ApiResponse verifyCode(String authKey, VerifyCodeRequest request) {
|
|
|
- return post("/login/VerifyCode", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- public ApiResponse verifyCodeSlide(String authKey, SlideVerifyRequest request) {
|
|
|
- return post("/login/VerifyCodeSlide", authKey, request);
|
|
|
- }
|
|
|
-
|
|
|
- // ------------------ 工具方法 ------------------
|
|
|
- /**
|
|
|
- * 通用 POST 请求方法
|
|
|
- *
|
|
|
- * @param path 接口路径，如 "/friend/AgreeAdd"
|
|
|
- * @param authKey 账号唯一标识（query 参数）
|
|
|
- * @param request 请求体对象
|
|
|
- * @return 统一响应结果
|
|
|
- */
|
|
|
- private ApiResponse post(String path, String authKey, Object request) {
|
|
|
- String url = BASE_URL + path + "?key=" + authKey;
|
|
|
- return WxWorkHttpUtil.postWithType(url, request, new TypeReference<ApiResponse>() {});
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 通用 GET 请求方法（无请求体）
|
|
|
- *
|
|
|
- * @param path 接口路径
|
|
|
- * @param authKey 账号唯一标识
|
|
|
- * @return 统一响应结果
|
|
|
- */
|
|
|
- private ApiResponse get(String path, String authKey) {
|
|
|
- String url = BASE_URL + path;
|
|
|
- Map<String, Object> params = new HashMap<>();
|
|
|
- params.put("authKey", authKey);
|
|
|
- String resp = WxWorkHttpUtil.get(url, params);
|
|
|
- return com.alibaba.fastjson.JSON.parseObject(resp, ApiResponse.class);
|
|
|
+ @Autowired
|
|
|
+ RedisCache redisCache;
|
|
|
+
|
|
|
+ public ApiResponseCommon<LoginQrCodeResponseData> getLoginQrCodeNewDirect(String authKey, QrCodeRequest request) {
|
|
|
+ String url = BASE_URL + "/login/GetLoginQrCodeNewDirect?key=" + authKey;
|
|
|
+ ApiResponseCommon<LoginQrCodeResponseData> response = WxWorkHttpUtil.postWithType(
|
|
|
+ url,
|
|
|
+ request,
|
|
|
+ new TypeReference<ApiResponseCommon<LoginQrCodeResponseData>>() {}
|
|
|
+ );
|
|
|
+
|
|
|
+ //先判断是否成功
|
|
|
+ if (response.getCode() != 200 || response.getData() == null) {
|
|
|
+ String errorMsg = response.getText() != null ? response.getText() : "获取二维码失败";
|
|
|
+ throw new CustomException("获取登录二维码失败: " + errorMsg);
|
|
|
+ }
|
|
|
+
|
|
|
+ //安全访问 data
|
|
|
+ log.info("二维码照片url: {}", response.getData().getQrCodeUrl());
|
|
|
+ return response;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public ApiResponseCommon<LoginStatusResponseData> checkLoginStatus(String authKey) {
|
|
|
+ String url = BASE_URL + "/login/CheckLoginStatus?key=" + authKey;
|
|
|
+ ApiResponseCommon<LoginStatusResponseData> response = WxWorkHttpUtil.getWithType(
|
|
|
+ url,
|
|
|
+ new TypeReference<ApiResponseCommon<LoginStatusResponseData>>() {}
|
|
|
+ );
|
|
|
+
|
|
|
+ // 只认 text == "账号已登录"
|
|
|
+ if ("账号已登录".equals(response.getText())) {
|
|
|
+ if (response.getData() == null) {
|
|
|
+ throw new CustomException("登录状态异常：text 显示已登录，但 data 为空");
|
|
|
+ }
|
|
|
+ return response;
|
|
|
+ } else {
|
|
|
+ // 抛出具体的错误原因
|
|
|
+ throw new CustomException("检查登录状态失败: " + (response.getText() != null ? response.getText() : "未知错误"));
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public ApiResponseCommon<LoginStatusData> getLoginStatus(String authKey) {
|
|
|
+ String url = BASE_URL + "/login/GetLoginStatus?key=" + authKey;
|
|
|
+ ApiResponseCommon<LoginStatusData> response = WxWorkHttpUtil.getWithType(
|
|
|
+ url,
|
|
|
+ new TypeReference<ApiResponseCommon<LoginStatusData>>() {}
|
|
|
+ );
|
|
|
+
|
|
|
+ //核心判断：只有 code=200 且 data 不为 null 才算成功
|
|
|
+ if (response.getCode() != 200 || response.getData() == null) {
|
|
|
+ String errorMsg = response.getText() != null
|
|
|
+ ? response.getText()
|
|
|
+ : "获取登录状态失败，未知错误";
|
|
|
+ throw new CustomException("账号未登录或状态异常: " + errorMsg);
|
|
|
+ }
|
|
|
+
|
|
|
+ return response;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ public ApiResponseCommon<Void> logOut(String authKey) {
|
|
|
+ String url = BASE_URL + "/login/LogOut?key=" + authKey;
|
|
|
+ ApiResponseCommon<Void> response = WxWorkHttpUtil.getWithType(
|
|
|
+ url,
|
|
|
+ new TypeReference<ApiResponseCommon<Void>>() {}
|
|
|
+ );
|
|
|
+
|
|
|
+ String text = response.getText();
|
|
|
+ int code = response.getCode();
|
|
|
+
|
|
|
+ //真正的成功退出
|
|
|
+ if (code == 200 && "退出成功！".equals(text)) {
|
|
|
+ return response;
|
|
|
+ }
|
|
|
+ //已经退出过了（幂等，视为成功）
|
|
|
+ else if (code == 300 && "你已退出登录".equals(text)) {
|
|
|
+ return response;
|
|
|
+ }
|
|
|
+ //其他情况一律视为失败
|
|
|
+ else {
|
|
|
+ String errorMsg = text != null ? text : "退出登录失败，未知错误";
|
|
|
+ throw new CustomException("退出登录失败: " + errorMsg);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
