Commit 44df8edd authored by Liuwj's avatar Liuwj

回调

parent 3e73caeb
Pipeline #128 canceled with stages
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.5/apache-maven-3.9.5-bin.zip
wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.2.0/maven-wrapper-3.2.0.jar
# 美团回调
## 默认信息
> port: 80
## 获取url
### 基础信息
> 请求路径:/api/url
>
> Get
>
### 响应数据
|名称|类型|
|---|---|
|url|请求地址|
## 回调接口
### 基础信息
> 请求路径:/api/token
>
\ No newline at end of file
This diff is collapsed.
@REM ----------------------------------------------------------------------------
@REM Licensed to the Apache Software Foundation (ASF) under one
@REM or more contributor license agreements. See the NOTICE file
@REM distributed with this work for additional information
@REM regarding copyright ownership. The ASF licenses this file
@REM to you under the Apache License, Version 2.0 (the
@REM "License"); you may not use this file except in compliance
@REM with the License. You may obtain a copy of the License at
@REM
@REM https://www.apache.org/licenses/LICENSE-2.0
@REM
@REM Unless required by applicable law or agreed to in writing,
@REM software distributed under the License is distributed on an
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@REM KIND, either express or implied. See the License for the
@REM specific language governing permissions and limitations
@REM under the License.
@REM ----------------------------------------------------------------------------
@REM ----------------------------------------------------------------------------
@REM Apache Maven Wrapper startup batch script, version 3.2.0
@REM
@REM Required ENV vars:
@REM JAVA_HOME - location of a JDK home dir
@REM
@REM Optional ENV vars
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
@REM e.g. to debug Maven itself, use
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
@REM ----------------------------------------------------------------------------
@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
@echo off
@REM set title of command window
title %0
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
@REM set %HOME% to equivalent of $HOME
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
@REM Execute a user defined script before this one
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
:skipRcPre
@setlocal
set ERROR_CODE=0
@REM To isolate internal variables from possible post scripts, we use another setlocal
@setlocal
@REM ==== START VALIDATION ====
if not "%JAVA_HOME%" == "" goto OkJHome
echo.
echo Error: JAVA_HOME not found in your environment. >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
:OkJHome
if exist "%JAVA_HOME%\bin\java.exe" goto init
echo.
echo Error: JAVA_HOME is set to an invalid directory. >&2
echo JAVA_HOME = "%JAVA_HOME%" >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
@REM ==== END VALIDATION ====
:init
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
@REM Fallback to current working directory if not found.
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
set EXEC_DIR=%CD%
set WDIR=%EXEC_DIR%
:findBaseDir
IF EXIST "%WDIR%"\.mvn goto baseDirFound
cd ..
IF "%WDIR%"=="%CD%" goto baseDirNotFound
set WDIR=%CD%
goto findBaseDir
:baseDirFound
set MAVEN_PROJECTBASEDIR=%WDIR%
cd "%EXEC_DIR%"
goto endDetectBaseDir
:baseDirNotFound
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
cd "%EXEC_DIR%"
:endDetectBaseDir
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
@setlocal EnableExtensions EnableDelayedExpansion
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
:endReadAdditionalConfig
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
set WRAPPER_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.2.0/maven-wrapper-3.2.0.jar"
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
IF "%%A"=="wrapperUrl" SET WRAPPER_URL=%%B
)
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
if exist %WRAPPER_JAR% (
if "%MVNW_VERBOSE%" == "true" (
echo Found %WRAPPER_JAR%
)
) else (
if not "%MVNW_REPOURL%" == "" (
SET WRAPPER_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.2.0/maven-wrapper-3.2.0.jar"
)
if "%MVNW_VERBOSE%" == "true" (
echo Couldn't find %WRAPPER_JAR%, downloading it ...
echo Downloading from: %WRAPPER_URL%
)
powershell -Command "&{"^
"$webclient = new-object System.Net.WebClient;"^
"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
"}"^
"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%WRAPPER_URL%', '%WRAPPER_JAR%')"^
"}"
if "%MVNW_VERBOSE%" == "true" (
echo Finished downloading %WRAPPER_JAR%
)
)
@REM End of extension
@REM If specified, validate the SHA-256 sum of the Maven wrapper jar file
SET WRAPPER_SHA_256_SUM=""
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
IF "%%A"=="wrapperSha256Sum" SET WRAPPER_SHA_256_SUM=%%B
)
IF NOT %WRAPPER_SHA_256_SUM%=="" (
powershell -Command "&{"^
"$hash = (Get-FileHash \"%WRAPPER_JAR%\" -Algorithm SHA256).Hash.ToLower();"^
"If('%WRAPPER_SHA_256_SUM%' -ne $hash){"^
" Write-Output 'Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised.';"^
" Write-Output 'Investigate or delete %WRAPPER_JAR% to attempt a clean download.';"^
" Write-Output 'If you updated your Maven version, you need to update the specified wrapperSha256Sum property.';"^
" exit 1;"^
"}"^
"}"
if ERRORLEVEL 1 goto error
)
@REM Provide a "standardized" way to retrieve the CLI args that will
@REM work with both Windows and non-Windows executions.
set MAVEN_CMD_LINE_ARGS=%*
%MAVEN_JAVA_EXE% ^
%JVM_CONFIG_MAVEN_PROPS% ^
%MAVEN_OPTS% ^
%MAVEN_DEBUG_OPTS% ^
-classpath %WRAPPER_JAR% ^
"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
%WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
if ERRORLEVEL 1 goto error
goto end
:error
set ERROR_CODE=1
:end
@endlocal & set ERROR_CODE=%ERROR_CODE%
if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
@REM check for post script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
:skipRcPost
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
if "%MAVEN_BATCH_PAUSE%"=="on" pause
if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
cmd /C exit /B %ERROR_CODE%
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.6.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>demo</name>
<description>demo</description>
<properties>
<java.version>8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.3.1</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.28</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.59</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.19</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
<version>2.1.2.RELEASE</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.9.2</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.9.2</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
package com.example.demo;
import com.example.demo.meituan.clients.MeituanClientConfiguration;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Configuration;
@SpringBootApplication
@MapperScan(basePackages = "com.example.demo.meituan.mapper")
@EnableFeignClients
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
}
package com.example.demo.meituan.clients;
import com.example.demo.meituan.pojo.AccessToken;
import com.example.demo.meituan.pojo.ResultResponse;
import com.example.demo.meituan.pojo.ResultToken;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
@FeignClient(name = "maokuClient", url = "https://api-open-cater.meituan.com",configuration = MeituanClientConfiguration.class)
public interface MeituanClient {
@RequestMapping(value = "/oauth/token", method = RequestMethod.POST,consumes =
MediaType.APPLICATION_FORM_URLENCODED_VALUE)
ResultResponse<ResultToken> resourcesGet(AccessToken accessToken);
}
package com.example.demo.meituan.clients;
import com.alibaba.fastjson.JSON;
import com.example.demo.meituan.pojo.AccessToken;
import com.example.demo.meituan.util.BaseUtil;
import com.example.demo.meituan.util.SignUtil;
import com.example.demo.meituan.util.URLUtils;
import feign.Request;
import feign.RequestInterceptor;
import feign.RequestTemplate;
import lombok.extern.slf4j.Slf4j;
import java.io.UnsupportedEncodingException;
import java.util.Map;
@Slf4j
public class MeituanClientConfiguration implements RequestInterceptor {
private final static String DEFAULT = "Binary data";
@Override
public void apply(RequestTemplate requestTemplate) {
Request.Body body = requestTemplate.requestBody();
String requestBodyJson = DEFAULT.equals(body.asString()) ? "" : body.asString();
Map urlParams = URLUtils.getUrlParams(requestBodyJson);
AccessToken accessToken = JSON.parseObject(JSON.toJSONString(urlParams), AccessToken.class);
String signKey = "nvm3kbuntv2y85a7";//你的signkey,注意替换
//下方的参数为每次调用api需要的参数
try{
Map<String,String> param = BaseUtil.getSortedParamMap(accessToken);
String sign = SignUtil.getSign(signKey, param);//获得sign ceb760af62431e20fd2e4aa1bbf21d2c17012dc0
param.put("sign", sign);
String paramStr = BaseUtil.getSortedParamStr(param);
//统一头部
requestTemplate.body(paramStr);
}catch (UnsupportedEncodingException e){
log.warn("getParamStr", e);
}
}
}
package com.example.demo.meituan.config;
import feign.Logger;
import feign.codec.Encoder;
import feign.form.spring.SpringFormEncoder;
import org.springframework.beans.factory.ObjectFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
import org.springframework.cloud.openfeign.support.SpringEncoder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class FeignMultipartSupportConfig {
@Autowired
private ObjectFactory<HttpMessageConverters> messageConverters;
@Bean
public Encoder multipartFormEncoder() {
return new SpringFormEncoder(new SpringEncoder(messageConverters));
}
@Bean
public Logger.Level feignLoggerLevel() {
return Logger.Level.FULL;
}
}
package com.example.demo.meituan.controller;
import com.alibaba.fastjson.JSON;
import com.example.demo.meituan.pojo.*;
import com.example.demo.meituan.service.INrApiPlatformConfigParametersService;
import com.example.demo.meituan.util.BaseUtil;
import com.example.demo.meituan.clients.MeituanClient;
import com.example.demo.meituan.util.SignUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping("/api")
@Validated
public class TokenCotroller {
@Autowired
private MeituanClient meituanClient;
@Autowired
private INrApiPlatformConfigParametersService nrApiPlatformConfigParametersServiceImpl;
private final static String signKey = "nvm3kbuntv2y85a7";
@GetMapping("/token")
public void authToken(String code,String sign,Long developerId,Integer businessId,String state){
AccessToken accessToken = new AccessToken();
Long timeStamp = System.currentTimeMillis();
accessToken.setCode(code);
accessToken.setBusinessId(businessId);
accessToken.setDeveloperId(developerId);
accessToken.setCharset("UTF-8");
accessToken.setGrantType("authorization_code");
accessToken.setTimestamp(timeStamp);
NrApiPlatformConfigParameters nrApiPlatformConfigParameters = BaseUtil.getNrApiPlatformConfigParameters("authorization_code",code);
nrApiPlatformConfigParametersServiceImpl.save(nrApiPlatformConfigParameters);
try {
Map<String,String> signs =BaseUtil.getSortedParamMap(accessToken);
String signParam = SignUtil.getSign(signKey, signs);
accessToken.setSign(signParam);
ResultResponse<ResultToken> resultToken = meituanClient.resourcesGet(accessToken);
String codeParam = resultToken.getCode();
if("0".equals(codeParam)){
NrApiPlatformConfigParameters nrApi = BaseUtil.getNrApiPlatformConfigParameters("msg",resultToken.getMsg());
nrApiPlatformConfigParametersServiceImpl.save(nrApi);
return;
}
ResultToken data = resultToken.getData();
List<NrApiPlatformConfigParameters> nrApiPlatformConfigParametersList = BaseUtil.getNrApiPlatformConfigParametersList(data);
nrApiPlatformConfigParametersServiceImpl.saveBatch(nrApiPlatformConfigParametersList);
}catch (Exception e){
throw new RuntimeException(e);
}
}
@GetMapping("/url")
public Map<String,Object> getUrl(){
UrlParam urlParam = new UrlParam();
Map<String,Object> result = new HashMap<>();
Long timeStamp = System.currentTimeMillis();
urlParam.setDeveloperId(107905);
urlParam.setBusinessId(18);
urlParam.setTimestamp(timeStamp);
urlParam.setCharset("UTF-8");
urlParam.setState("meiTuan");
urlParam.setScope("");
try {
Map<String,String> signs =BaseUtil.getSortedParamMap(urlParam);
String sign = SignUtil.getSign(signKey, signs);
urlParam.setSign(sign);
String url = BaseUtil.getUrl(urlParam);
result.put("url",url);
}catch (Exception e){
throw new RuntimeException(e);
}
return result;
}
}
package com.example.demo.meituan.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.demo.meituan.pojo.NrApiPlatformConfigParameters;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface NrApiPlatformConfigParametersMapper extends BaseMapper<NrApiPlatformConfigParameters> {
}
package com.example.demo.meituan.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.demo.meituan.pojo.UrlParam;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface UrlParamMapper extends BaseMapper<UrlParam> {
}
package com.example.demo.meituan.pojo;
import io.swagger.annotations.ApiModel;
import lombok.Data;
@Data
@ApiModel("授权post请求体")
public class AccessToken {
private Integer businessId;
private String charset;
private String code;
private Long developerId;
private String grantType;
private String sign;
private Long timestamp;
}
package com.example.demo.meituan.pojo;
import io.swagger.annotations.ApiModel;
import lombok.Data;
@Data
@ApiModel("回调参数")
public class AuthorizationCode {
private String code;
private String sign;
private Long developerId;
private Integer businessId;
private String state;
}
package com.example.demo.meituan.pojo;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModel;
import lombok.Data;
import springfox.documentation.schema.Model;
@Data
@ApiModel("数据库参数实体表")
public class NrApiPlatformConfigParameters{
// @TableId(value = "id", type = IdType.AUTO)
private Long id;
private Integer configId;
private String parameterKey;
private String parameterValue;
private String parameterType;
private Integer tenantId;
}
package com.example.demo.meituan.pojo;
import lombok.Data;
@Data
public class ResultResponse<T> {
private String code;
private String message;
private String msg;
private String traceId;
private T data;
}
package com.example.demo.meituan.pojo;
import io.swagger.annotations.ApiModel;
import lombok.Data;
@Data
@ApiModel("post请求返回值")
public class ResultToken {
private String accessToken;
private Long expireIn;
private String refreshToken;
private String scope;
private String opBizCode;
}
package com.example.demo.meituan.pojo;
import io.swagger.annotations.ApiModel;
import lombok.Data;
@Data
@ApiModel("拼装url参数")
public class UrlParam {
private Integer developerId;
private Integer businessId;
private Long timestamp;
private String charset;
private String state;
private String scope;
private String sign;
}
package com.example.demo.meituan.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.demo.meituan.pojo.NrApiPlatformConfigParameters;
public interface INrApiPlatformConfigParametersService extends IService<NrApiPlatformConfigParameters> {
}
package com.example.demo.meituan.service;
public interface UrlParamService {
}
package com.example.demo.meituan.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.demo.meituan.mapper.NrApiPlatformConfigParametersMapper;
import com.example.demo.meituan.pojo.NrApiPlatformConfigParameters;
import com.example.demo.meituan.service.INrApiPlatformConfigParametersService;
import org.springframework.stereotype.Service;
@Service
public class NrApiPlatformConfigParametersServiceImpl extends ServiceImpl<NrApiPlatformConfigParametersMapper, NrApiPlatformConfigParameters> implements INrApiPlatformConfigParametersService {
}
package com.example.demo.meituan.service.impl;
import com.example.demo.meituan.service.UrlParamService;
import org.springframework.stereotype.Service;
@Service
public class UrlParamServiceImpl implements UrlParamService {
}
package com.example.demo.meituan.util;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.example.demo.meituan.pojo.NrApiPlatformConfigParameters;
import com.example.demo.meituan.pojo.ResultToken;
import com.example.demo.meituan.pojo.UrlParam;
import java.io.UnsupportedEncodingException;
import java.util.*;
public class BaseUtil {
public static String getSortedParamStr(Map<String, String> params) throws UnsupportedEncodingException {
Set<String> sortedParams = new TreeSet<>(params.keySet());
StringBuilder strB = new StringBuilder();
int i = 0;
for (String key : sortedParams) {
String value = params.get(key);
if (!StringUtils.isNotEmpty(value)) {
continue;
}
if(strB.length()>0){
strB.append("&");
}
strB.append(key).append("=").append(value);
}
return strB.toString();
}
public static Map<String,String> getSortedParamMap(Object params) throws UnsupportedEncodingException {
Map map = JSON.parseObject(JSON.toJSONString(params), Map.class);
Map<String,String> signs = new HashMap<>();
map.forEach((key,value)->{
signs.put(String.valueOf(key),String.valueOf(value));
});
return signs;
}
public static String getUrl(UrlParam urlParam) {
Map map = JSON.parseObject(JSON.toJSONString(urlParam), Map.class);
Map<String,String> urlMap = new HashMap<>();
map.forEach((key,value)->{
urlMap.put(String.valueOf(key),String.valueOf(value));
});
String url = "";
try{
url = BaseUtil.getSortedParamStr(urlMap);
url = "https://open-erp.meituan.com/general/auth?" + url;
}catch (Exception e){
throw new RuntimeException(e);
}
return url;
}
public static List<NrApiPlatformConfigParameters> getNrApiPlatformConfigParametersList(ResultToken resultToken) {
List<NrApiPlatformConfigParameters> list = new ArrayList<>();
for (int i = 0; i < 3; i++) {
NrApiPlatformConfigParameters nrApiPlatformConfigParameters = new NrApiPlatformConfigParameters();
nrApiPlatformConfigParameters.setConfigId(107905);
nrApiPlatformConfigParameters.setParameterType("String");
nrApiPlatformConfigParameters.setTenantId(1000001);
if (i == 0) {
nrApiPlatformConfigParameters.setParameterKey("accessToken");
nrApiPlatformConfigParameters.setParameterValue(resultToken.getAccessToken());
}
if (i == 1) {
nrApiPlatformConfigParameters.setParameterKey("expireIn");
nrApiPlatformConfigParameters.setParameterValue(String.valueOf(resultToken.getExpireIn()));
}
if (i == 2) {
nrApiPlatformConfigParameters.setParameterKey("refreshToken");
nrApiPlatformConfigParameters.setParameterValue(resultToken.getRefreshToken());
}
list.add(nrApiPlatformConfigParameters);
}
return list;
}
public static NrApiPlatformConfigParameters getNrApiPlatformConfigParameters(String key,String code) {
NrApiPlatformConfigParameters nrApiPlatformConfigParameters = new NrApiPlatformConfigParameters();
nrApiPlatformConfigParameters.setConfigId(107905);
nrApiPlatformConfigParameters.setParameterType("String");
nrApiPlatformConfigParameters.setTenantId(1000001);
nrApiPlatformConfigParameters.setParameterKey(key);
nrApiPlatformConfigParameters.setParameterValue(code);
return nrApiPlatformConfigParameters;
}
}
package com.example.demo.meituan.util;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.logging.Log;
import org.springframework.beans.factory.annotation.Autowired;
import java.io.UnsupportedEncodingException;
import java.security.MessageDigest;
import java.util.Map;
import java.util.Set;
import java.util.TreeSet;
@Slf4j
public class SignUtil {
private SignUtil() {}
public static String getSign(String signKey, Map<String, String> params) {
try {
String sortedStr = getSortedParamStr(params);
String paraStr = signKey + sortedStr;
return createSign(paraStr);
} catch (UnsupportedEncodingException e) {
log.warn("getSign UnsupportedEncodingException ", e);
}
return StringUtils.EMPTY;
}
/**
* 构造自然排序请求参数
*
* @param params 请求
* @return 字符串
*/
private static String getSortedParamStr(Map<String, String> params) throws UnsupportedEncodingException {
Set<String> sortedParams = new TreeSet<>(params.keySet());
StringBuilder strB = new StringBuilder();
// 排除sign和空值参数
for (String key : sortedParams) {
if ("sign".equalsIgnoreCase(key)) {
continue;
}
String value = params.get(key);
if (StringUtils.isNotEmpty(value)) {
strB.append(key).append(value);
}
}
return strB.toString();
}
/**
* 生成新sign
*
* @param str 字符串
* @return String
*/
private static String createSign(String str) {
if (str == null || str.length() == 0) {
return null;
}
char[] hexDigits = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
try {
MessageDigest mdTemp = MessageDigest.getInstance("SHA1");
mdTemp.update(str.getBytes("UTF-8"));
byte[] md = mdTemp.digest();
int j = md.length;
char[] buf = new char[j * 2];
int k = 0;
int i = 0;
while (i < j) {
byte byte0 = md[i];
buf[k++] = hexDigits[byte0 >>> 4 & 0xf];
buf[k++] = hexDigits[byte0 & 0xf];
i++;
}
return new String(buf);
} catch (Exception e) {
log.warn("create sign was failed", e);
return null;
}
}
}
package com.example.demo.meituan.util;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
/**
* urlencode工具类
*/
@Slf4j
public class URLUtils {
private static URLUtils instance = new URLUtils();
private URLUtils() {
}
public static URLUtils getInstance() {
return instance;
}
private String DEFAULT = "utf-8";
public String urlEncode(String source) throws UnsupportedEncodingException {
return urlEncode(source, DEFAULT);
}
public String urlEncode(String source, String type) throws UnsupportedEncodingException {
return URLEncoder.encode(source, type);
}
public static Map getUrlParams(String param) {
Map map = new HashMap(0);
if (StringUtils.isBlank(param)) {
return map;
}
String[] params = param.split("&");
for (int i = 0; i < params.length; i++) {
String[] p = params[i].split("=");
if (p.length == 2) {
if (Objects.equals("pageHeader", p[0])) {
String encode = "";
try {
encode = URLDecoder.decode(p[1], "UTF-8");
} catch (Exception e) {
log.error("url解码失败 ->> {},{}", e.getMessage(), e);
}
map.put(p[0], encode);
}else{
map.put(p[0], p[1]);
}
}
}
return map;
}
}
spring:
datasource:
url: jdbc:mysql://39.101.70.58:3306/shenbiuat?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&rewriteBatchedStatements=TRUE&allowMultiQueries=true&serverTimezone=GMT%2B8
username: magicwitest
password: magicwitest
driver-class-name: com.mysql.cj.jdbc.Driver
server:
port: 80
mybatis-plus:
configuration:
map-underscore-to-camel-case: true
feign:
hystrix:
enabled: true
\ No newline at end of file
package com.example.demo;
import com.example.demo.meituan.mapper.NrApiPlatformConfigParametersMapper;
import com.example.demo.meituan.pojo.NrApiPlatformConfigParameters;
import com.example.demo.meituan.service.INrApiPlatformConfigParametersService;
import org.junit.jupiter.api.Test;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import javax.annotation.Resource;
@SpringBootTest
@MapperScan(basePackages = "com.example.demo")
class DemoApplicationTests {
@Autowired
// @Resource(name = "nrApiPlatformConfigParametersServiceImpl")
private INrApiPlatformConfigParametersService nrApiPlatformConfigParametersServiceImpl;
@Autowired
private NrApiPlatformConfigParametersMapper nrApiPlatformConfigParametersMapper;
@Test
void contextLoads() {
NrApiPlatformConfigParameters nrApiPlatformConfigParameters = new NrApiPlatformConfigParameters();
nrApiPlatformConfigParameters.setConfigId(107905);
nrApiPlatformConfigParameters.setParameterType("String");
nrApiPlatformConfigParameters.setTenantId(1000001);
nrApiPlatformConfigParameters.setParameterKey("authorization_code");
nrApiPlatformConfigParameters.setParameterValue("123345");
// nrApiPlatformConfigParametersMapper.insert(nrApiPlatformConfigParameters);
nrApiPlatformConfigParametersServiceImpl.save(nrApiPlatformConfigParameters);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment