89 lines
3.0 KiB
Java
89 lines
3.0 KiB
Java
package com.dengqn.igps2xingzhe.controller;
|
|
|
|
import cn.hutool.crypto.KeyUtil;
|
|
import cn.hutool.crypto.SecureUtil;
|
|
import cn.hutool.crypto.asymmetric.AsymmetricAlgorithm;
|
|
import cn.hutool.crypto.asymmetric.KeyType;
|
|
import cn.hutool.crypto.asymmetric.RSA;
|
|
import cn.hutool.json.JSONUtil;
|
|
import com.dengqn.igps2xingzhe.config.XingZhe;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.apache.catalina.security.SecurityUtil;
|
|
import org.apache.hc.client5.http.classic.HttpClient;
|
|
import org.apache.hc.client5.http.cookie.Cookie;
|
|
import org.apache.hc.client5.http.cookie.CookieStore;
|
|
import org.apache.hc.core5.http.ContentType;
|
|
import org.apache.hc.core5.http.HttpResponse;
|
|
import org.apache.hc.core5.http.io.entity.BasicHttpEntity;
|
|
import org.apache.hc.core5.http.io.support.ClassicRequestBuilder;
|
|
import org.apache.hc.core5.http.message.BasicHttpResponse;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.http.ResponseEntity;
|
|
import org.springframework.web.bind.annotation.GetMapping;
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
|
import java.io.ByteArrayInputStream;
|
|
import java.io.IOException;
|
|
import java.nio.charset.StandardCharsets;
|
|
import java.security.KeyFactory;
|
|
import java.security.NoSuchAlgorithmException;
|
|
import java.security.PublicKey;
|
|
import java.security.spec.InvalidKeySpecException;
|
|
import java.security.spec.RSAPublicKeySpec;
|
|
import java.security.spec.X509EncodedKeySpec;
|
|
import java.util.HashMap;
|
|
import java.util.Map;
|
|
|
|
/**
|
|
* 同步
|
|
*
|
|
* @author dengqn
|
|
* @since 2024/7/20 11:21
|
|
*/
|
|
@Slf4j
|
|
@RestController
|
|
@RequestMapping("/api/trigger")
|
|
public class Trigger {
|
|
|
|
@Autowired
|
|
private HttpClient httpClient;
|
|
@Autowired
|
|
private CookieStore cookieStore;
|
|
|
|
|
|
@Autowired
|
|
private XingZhe xingZhe;
|
|
|
|
@GetMapping("/sync/igps2xingzhe")
|
|
public ResponseEntity<String> onSyncIGPS2XingZhe() throws IOException, NoSuchAlgorithmException, InvalidKeySpecException {
|
|
|
|
// 1、获取行者平台的cookie
|
|
HttpResponse executed = httpClient.execute(ClassicRequestBuilder.get("https://www.imxingzhe.com/user/login").build());
|
|
System.out.println(executed.getCode());
|
|
// 2、计算加密后的密码参数
|
|
|
|
RSA rsa = new RSA(AsymmetricAlgorithm.RSA_ECB_PKCS1.getValue(), null, xingZhe.getPubKey());
|
|
String rd = cookieStore.getCookies()
|
|
.stream().filter(a -> a.getName().equals("rd")).findFirst()
|
|
.map(Cookie::getValue).orElse("");
|
|
String encryptBase64 = rsa.encryptBase64(xingZhe.getPassword() + ";" + rd, KeyType.PublicKey);
|
|
|
|
Map<String, Object> loginData = new HashMap<>();
|
|
loginData.put("account", xingZhe.getUsername());
|
|
loginData.put("password", encryptBase64);
|
|
loginData.put("source", "web");
|
|
|
|
BasicHttpResponse response = (BasicHttpResponse) httpClient.execute(ClassicRequestBuilder
|
|
.post("https://www.imxingzhe.com/api/v4/account/login")
|
|
.setEntity(JSONUtil.toJsonPrettyStr(loginData), ContentType.APPLICATION_JSON)
|
|
.build());
|
|
log.info("xingzhe login: {}", response);
|
|
|
|
return ResponseEntity.ok("ok");
|
|
}
|
|
|
|
|
|
|
|
}
|