Browse Source

改到loginkit里面了

Signed-off-by: lidongy <1879087903@qq.com>
pull/1/head
lidongy 5 years ago
parent
commit
f2ccbba2aa
  1. 20
      src/main/java/com/fanruan/api/decision/AppearanceKit.java
  2. 30
      src/main/java/com/fanruan/api/decision/login/LoginKit.java
  3. 11
      src/main/java/com/fanruan/api/decision/webservice/Response.java
  4. 25
      src/main/java/com/fanruan/api/decision/webservice/WebServiceKit.java
  5. 43
      src/test/java/com/fanruan/api/decision/AppearenceKitTest.java
  6. 26
      src/test/java/com/fanruan/api/decision/webservice/ResponseTest.java
  7. 54
      src/test/java/com/fanruan/api/decision/webservice/WebServiceKitTest.java

20
src/main/java/com/fanruan/api/decision/AppearanceKit.java

@ -1,20 +0,0 @@
package com.fanruan.api.decision;
import com.fr.decision.config.AppearanceConfig;
/**
* @author lidongy
* @version 10.0
* Created by lidongy on 2019/10/24
*/
public class AppearanceKit {
/**
* 获取选择的登录页插件id
*
* @return id
*/
public static String getLoginPageId() {
return AppearanceConfig.getInstance().getLoginPageId();
}
}

30
src/main/java/com/fanruan/api/decision/login/LoginKit.java

@ -2,8 +2,11 @@ package com.fanruan.api.decision.login;
import com.fr.decision.authorize.Passport;
import com.fr.decision.authorize.impl.HttpPassport;
import com.fr.decision.config.AppearanceConfig;
import com.fr.decision.config.FSConfig;
import com.fr.decision.webservice.Response;
import com.fr.decision.webservice.v10.login.LoginService;
import com.fr.third.socketio.SocketIOClient;
import org.jetbrains.annotations.Nullable;
import javax.servlet.http.HttpServletRequest;
@ -74,4 +77,31 @@ public class LoginKit {
public static OpenLoginResponse login(HttpServletRequest req, HttpServletResponse res, OpenLoginRequest loginRequest) throws Exception {
return OpenLoginResponse.wrap(LoginService.getInstance().login(req, res, loginRequest.select()));
}
/**
* 刷新用户名对应的token如果非保持登录会使用tokenTimeout参数设置时长
*
* @param oldJwt 老的token
* @param socketIOClient socket客户端
* @param tokenTimeout 设置的超时时长仅对非保持登录有用0<= tokenTimeOut <= LoginConfig.LoginTimeOut
* @return 新的token
* @throws Exception 异常
*/
public static Object refreshToken(String oldJwt, long tokenTimeout, SocketIOClient socketIOClient, Object responseData, String errorCode, String errorMsg) throws Exception{
Response response = new Response();
response = LoginService.getInstance().refreshToken(oldJwt, tokenTimeout, socketIOClient);
responseData = response.getData();
errorCode = response.getErrorCode();
errorMsg = response.getErrorMsg();
return response;
}
/**
* 获取选择的登录页插件id
*
* @return id
*/
public static String getLoginPageId() {
return AppearanceConfig.getInstance().getLoginPageId();
}
}

11
src/main/java/com/fanruan/api/decision/webservice/Response.java

@ -1,11 +0,0 @@
package com.fanruan.api.decision.webservice;
/**
* @author lidongy
* @version 10.0
* Created by lidongy on 2019/10/24
*/
public class Response extends com.fr.decision.webservice.Response {
public Response() {
}
}

25
src/main/java/com/fanruan/api/decision/webservice/WebServiceKit.java

@ -1,25 +0,0 @@
package com.fanruan.api.decision.webservice;
import com.fr.decision.webservice.v10.login.LoginService;
import com.fr.third.socketio.SocketIOClient;
/**
* @author lidongy
* @version 10.0
* Created by lidongy on 2019/10/24
*/
public class WebServiceKit {
/**
* 刷新用户名对应的token如果非保持登录会使用tokenTimeout参数设置时长
*
* @param oldJwt 老的token
* @param socketIOClient socket客户端
* @param tokenTimeout 设置的超时时长仅对非保持登录有用0<= tokenTimeOut <= LoginConfig.LoginTimeOut
* @return 新的token
* @throws Exception 异常
*/
public static Response refreshToken(String oldJwt, long tokenTimeout, SocketIOClient socketIOClient) throws Exception{
return (Response) LoginService.getInstance().refreshToken(oldJwt, tokenTimeout, socketIOClient);
}
}

43
src/test/java/com/fanruan/api/decision/AppearenceKitTest.java

@ -1,43 +0,0 @@
package com.fanruan.api.decision;
import com.fr.config.dao.DaoContext;
import com.fr.config.dao.impl.LocalClassHelperDao;
import com.fr.config.dao.impl.LocalEntityDao;
import com.fr.config.dao.impl.LocalXmlEntityDao;
import com.fr.decision.config.AppearanceConfig;
import com.fr.runtime.FineRuntime;
import com.fr.store.StateHubManager;
import com.fr.store.impl.MemoryLock;
import com.fr.store.impl.MemoryStore;
import com.fr.transaction.Configurations;
import com.fr.transaction.LocalConfigurationHelper;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
/**
* @author lidongy
* @version 10.0
* Created by lidongy on 2019/10/24
*/
public class AppearenceKitTest {
@Before
public void start() {
FineRuntime.start();
DaoContext.setEntityDao(new LocalEntityDao());
DaoContext.setClassHelperDao(new LocalClassHelperDao());
DaoContext.setXmlEntityDao(new LocalXmlEntityDao());
Configurations.setHelper(new LocalConfigurationHelper());
StateHubManager.setStorage(new MemoryStore());
StateHubManager.setLock(new MemoryLock());
}
@Test
public void TestGetLoginPageId() {
AppearanceConfig.getInstance().setLoginPageId("111");
Assert.assertEquals(AppearanceKit.getLoginPageId(), "111");
AppearanceConfig.getInstance().setLoginPageId("aaa");
Assert.assertEquals(AppearanceKit.getLoginPageId(), "aaa");
}
}

26
src/test/java/com/fanruan/api/decision/webservice/ResponseTest.java

@ -1,26 +0,0 @@
package com.fanruan.api.decision.webservice;
import org.junit.Assert;
import org.junit.Test;
/**
* @author lidongy
* @version 10.0
* Created by lidongy on 2019/10/25
*/
public class ResponseTest {
@Test
public void testResponse() throws Exception{
Response response = new Response();
response.setData("data");
response.setErrorCode("404");
response.setErrorMsg("fail to connect");
response.setStatus(3);
Assert.assertEquals(response.getData(), "data");
Assert.assertEquals(response.getErrorCode(), "404");
Assert.assertEquals(response.getErrorMsg(), "fail to connect");
Assert.assertEquals(response.getStatus(), 3);
}
}

54
src/test/java/com/fanruan/api/decision/webservice/WebServiceKitTest.java

@ -1,54 +0,0 @@
package com.fanruan.api.decision.webservice;
import com.fanruan.api.security.JwtKit;
import com.fr.config.dao.DaoContext;
import com.fr.config.dao.impl.LocalClassHelperDao;
import com.fr.config.dao.impl.LocalEntityDao;
import com.fr.config.dao.impl.LocalXmlEntityDao;
import com.fr.decision.webservice.bean.authentication.LoginClientBean;
import com.fr.decision.webservice.exception.login.LoginInfoNotAvailableException;
import com.fr.decision.webservice.utils.DecisionStatusService;
import com.fr.runtime.FineRuntime;
import com.fr.store.StateHubManager;
import com.fr.store.impl.MemoryLock;
import com.fr.store.impl.MemoryStore;
import com.fr.transaction.Configurations;
import com.fr.transaction.LocalConfigurationHelper;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
/**
* @author lidongy
* @version 10.0
* Created by lidongy on 2019/10/24
*/
public class WebServiceKitTest {
@Before
public void start() {
FineRuntime.start();
DaoContext.setEntityDao(new LocalEntityDao());
DaoContext.setClassHelperDao(new LocalClassHelperDao());
DaoContext.setXmlEntityDao(new LocalXmlEntityDao());
Configurations.setHelper(new LocalConfigurationHelper());
StateHubManager.setStorage(new MemoryStore());
StateHubManager.setLock(new MemoryLock());
}
@Test
public void testRefreshToken() throws Exception{
String jwtString = JwtKit.createDefaultJWT("123");
try {
Response response = WebServiceKit.refreshToken(jwtString, 1000 * 60, null);
} catch (Exception e) {
Assert.assertTrue(e instanceof LoginInfoNotAvailableException);
}
LoginClientBean loginClientBean = new LoginClientBean();
DecisionStatusService.loginStatusService().put(jwtString, loginClientBean);
try {
Response response = WebServiceKit.refreshToken(jwtString, 1000 * 60, null);
} catch (Exception e) {
Assert.assertFalse(e instanceof LoginInfoNotAvailableException);
}
}
}
Loading…
Cancel
Save