|
|
|
@ -3,6 +3,7 @@ package com.fr.plugin.decision.integration.filter;
|
|
|
|
|
import com.fr.data.NetworkHelper; |
|
|
|
|
import com.fr.decision.fun.impl.AbstractEmbedRequestFilterProvider; |
|
|
|
|
import com.fr.decision.webservice.Response; |
|
|
|
|
import com.fr.decision.webservice.v10.remote.RemoteDesignService; |
|
|
|
|
import com.fr.invoke.Reflect; |
|
|
|
|
import com.fr.plugin.decision.integration.config.IntegrateConf; |
|
|
|
|
import com.fr.plugin.decision.integration.service.IntegrateAuthService; |
|
|
|
@ -50,12 +51,20 @@ public class RemoteFilter extends AbstractEmbedRequestFilterProvider {
|
|
|
|
|
if (StringUtils.isNotBlank(username) && StringUtils.equals(token_user, username)) { |
|
|
|
|
try { |
|
|
|
|
String token = JwtUtils.createDefaultJWT(username); |
|
|
|
|
StateHubService stateHubService = Reflect.on("com.fr.decision.webservice.v10.remote.RemoteDesignStatusService").call("loginStatusService").get(); |
|
|
|
|
stateHubService.put(token, username, 1209600000); |
|
|
|
|
recordToken(token, username); |
|
|
|
|
WebUtils.printAsString(response, new ObjectMapper().writeValueAsString(Response.ok(token))); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
LogUtils.error(e.getMessage(), e); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void recordToken(String token, String username) throws Exception { |
|
|
|
|
try { |
|
|
|
|
Reflect.on(RemoteDesignService.getInstance()).call("recordTokenStatus", username, token); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
StateHubService stateHubService = Reflect.on("com.fr.decision.webservice.v10.remote.RemoteDesignStatusService").call("loginStatusService").get(); |
|
|
|
|
stateHubService.put(token, username, 1209600000); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|