初始化项目

src/main/java/com/jqtx/windows/common/base/RuntimeContext.java

@@ -9,8 +9,6 @@ public class RuntimeContext {
 
     private String requestBody;
 
-    private String userId;
-
     private String ipAddress;
 
 }

src/main/java/com/jqtx/windows/common/factory/AbstractCommand.java

+package com.jqtx.windows.common.factory;
+
+import com.jqtx.windows.infrastructure.enums.ExceptionCodeEnum;
+import com.jqtx.windows.web.response.JsonResult;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+
+@Service
+@Slf4j
+public abstract class AbstractCommand{
+
+    public JsonResult doAction(){
+        try{
+            return this.execute();
+        }catch (Exception e){
+            log.error("[处理异常:{}]",e.getMessage(),e);
+        }
+        return JsonResult.error(ExceptionCodeEnum.SYSTEM_ERROR);
+    }
+
+    public abstract <R> R execute();
+
+
+}

src/main/java/com/jqtx/windows/common/factory/ChannelConfig.java

+package com.jqtx.windows.common.factory;
+
+import lombok.Data;
+
+/*
+ * @ClassName ChannelConfig
+ * @Author liuzicheng
+ * @Description //TODO
+ * @Date 2021/12/20 14:32
+ */
+@Data
+public class ChannelConfig {
+
+    private String appId;
+
+}

src/main/java/com/jqtx/windows/common/factory/CommandProxy.java

+package com.jqtx.windows.common.factory;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.alibaba.fastjson.JSONObject;
+import com.jqtx.windows.common.exception.BizException;
+import com.jqtx.windows.infrastructure.enums.ExceptionCodeEnum;
+import com.jqtx.windows.utils.AbcRsaUtil;
+import com.jqtx.windows.web.config.RouterConfig;
+import com.jqtx.windows.web.response.JsonResult;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+@Service
+public class CommandProxy {
+
+    @Value("${abc.publicKey}")
+    private String publicKey;
+
+    @Value("${abc.yy_privateKey}")
+    private String YyPpivateKey;
+
+    public JsonResult call(String request,String method){
+        AbstractCommand command = RouterConfig.getCommand(method);
+        if(ObjectUtil.isNull(command)){
+            return JsonResult.success(ExceptionCodeEnum.SYSTEM_ERROR);
+        }
+        JSONObject jsonObject = JSONObject.parseObject(request);
+        String requestBody = jsonObject.getString("content");
+        String sign = jsonObject.getString("sign");
+        String appId = jsonObject.getString("appId");
+        String decodeBody = AbcRsaUtil.decodeParam(requestBody, sign, YyPpivateKey, publicKey);
+        if(StringUtils.isBlank(decodeBody)){
+            throw new BizException(ExceptionCodeEnum.BIZ_AUTH_ERROR);
+        }
+        ChannelConfig channelConfig = new ChannelConfig();
+        channelConfig.setAppId(appId);
+        this.setLocalContext(requestBody,channelConfig);
+        return  command.doAction();
+    }
+
+    public void setLocalContext(String requestBody, ChannelConfig channelConfig) {
+        RuntimeContext context = RuntimeContextHolder.currentRuntimeContext();
+        if (context == null) {
+            context = new RuntimeContext();
+        }
+        context.setRequestBody(requestBody);
+        context.setChannelConfig(channelConfig);
+        RuntimeContextHolder.setCurrentRuntimeContext(context);
+    }
+}

src/main/java/com/jqtx/windows/common/factory/RuntimeContext.java

+package com.jqtx.windows.common.factory;
+
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Data
+public class RuntimeContext {
+
+    private String requestBody;
+
+    private ChannelConfig channelConfig;
+}

src/main/java/com/jqtx/windows/common/factory/RuntimeContextHolder.java

+package com.jqtx.windows.common.factory;
+
+
+public class RuntimeContextHolder {
+
+    /** 上下文信息 */
+    private static final ThreadLocal<RuntimeContext> CURRENT_RUNTIME_CONTEXT = new ThreadLocal<RuntimeContext>();
+
+    /**
+     * 获取当前线程下的上下文信息.
+     * @return       上下文信息
+     */
+    public static RuntimeContext currentRuntimeContext() {
+        return CURRENT_RUNTIME_CONTEXT.get();
+    }
+
+
+    /**
+     * 设置当前线程下的上下文信息
+     * @param runtimeContext   上下文信息
+     */
+    public static void setCurrentRuntimeContext(RuntimeContext runtimeContext) {
+        CURRENT_RUNTIME_CONTEXT.set(runtimeContext);
+    }
+
+    /**
+     *  清空当前线程下的上下文信息
+     */
+    public static void clear() {
+        CURRENT_RUNTIME_CONTEXT.set(null);
+    }
+
+}

src/main/java/com/jqtx/windows/utils/AbcBase64Utils.java

+package com.jqtx.windows.utils;
+
+import org.apache.commons.codec.binary.Base64;
+
+import java.io.*;
+
+
+public class AbcBase64Utils {
+  
+    /** *//** 
+     * 文件读取缓冲区大小 
+     */  
+    private static final int CACHE_SIZE = 1024;  
+      
+    /** *//** 
+     * <p> 
+     * BASE64字符串解码为二进制数据 
+     * </p> 
+     *  
+     * @param base64 
+     * @return 
+     * @throws Exception 
+     */  
+    public static byte[] decode(String base64) throws Exception {  
+        return new Base64().decode(base64);  
+    }  
+      
+    /** *//** 
+     * <p> 
+     * 二进制数据编码为BASE64字符串 
+     * </p> 
+     *  
+     * @param bytes 
+     * @return 
+     * @throws Exception 
+     */  
+    public static String encode(byte[] bytes) throws Exception {  
+        return new Base64().encodeToString(bytes);
+    }  
+      
+    /** *//** 
+     * <p> 
+     * 将文件编码为BASE64字符串 
+     * </p> 
+     * <p> 
+     * 大文件慎用，可能会导致内存溢出 
+     * </p> 
+     *  
+     * @param filePath 文件绝对路径 
+     * @return 
+     * @throws Exception 
+     */  
+    public static String encodeFile(String filePath) throws Exception {  
+        byte[] bytes = fileToByte(filePath);  
+        return encode(bytes);  
+    }  
+      
+    /** *//** 
+     * <p> 
+     * BASE64字符串转回文件 
+     * </p> 
+     *  
+     * @param filePath 文件绝对路径 
+     * @param base64 编码字符串 
+     * @throws Exception 
+     */  
+    public static void decodeToFile(String filePath, String base64) throws Exception {  
+        byte[] bytes = decode(base64);  
+        byteArrayToFile(bytes, filePath);  
+    }  
+      
+    /** *//** 
+     * <p> 
+     * 文件转换为二进制数组 
+     * </p> 
+     *  
+     * @param filePath 文件路径 
+     * @return 
+     * @throws Exception 
+     */  
+    public static byte[] fileToByte(String filePath) {
+        byte[] data = new byte[0];  
+        File file = new File(filePath);  
+        if ( !file.exists() ) {
+            return data;
+        }
+
+        FileInputStream in = null;
+        ByteArrayOutputStream out = null;
+        try {
+            in = new FileInputStream(file);
+            out = new ByteArrayOutputStream(2048);
+            byte[] cache = new byte[CACHE_SIZE];
+            int nRead = 0;
+            while ((nRead = in.read(cache)) != -1) {
+                out.write(cache, 0, nRead);
+                out.flush();
+            }
+
+            return out.toByteArray();
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        } finally {
+            if ( out != null ) {
+                try {
+                    out.close();
+                } catch (IOException e) {
+                }
+            }
+
+            if ( in != null ) {
+                try {
+                    in.close();
+                } catch (IOException e) {
+                }
+            }
+        }
+
+
+    }  
+      
+    /** *//** 
+     * <p> 
+     * 二进制数据写文件 
+     * </p> 
+     *  
+     * @param bytes 二进制数据 
+     * @param filePath 文件生成目录 
+     */  
+    public static void byteArrayToFile(byte[] bytes, String filePath) {
+        InputStream in = new ByteArrayInputStream(bytes);     
+        File destFile = new File(filePath);  
+        if (!destFile.getParentFile().exists()) {  
+            destFile.getParentFile().mkdirs();  
+        }
+
+        OutputStream out = null;
+        try {
+            destFile.createNewFile();
+            out = new FileOutputStream(destFile);
+            byte[] cache = new byte[CACHE_SIZE];
+            int nRead = 0;
+            while ((nRead = in.read(cache)) != -1) {
+                out.write(cache, 0, nRead);
+                out.flush();
+            }
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        } finally {
+            if ( out != null ) {
+                try {
+                    out.close();
+                } catch (IOException e) {
+                }
+            }
+
+            if ( in != null ) {
+                try {
+                    in.close();
+                } catch (IOException e) {
+                }
+            }
+        }
+    }  
+      
+      
+}  

src/main/java/com/jqtx/windows/web/CreditController.java

+package com.jqtx.windows.web;
+
+
+import com.jqtx.windows.common.factory.CommandProxy;
+import com.jqtx.windows.web.response.JsonResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+
+@RestController
+@RequestMapping("/zhenong/v1")
+@Api(tags = "授信接口")
+public class CreditController {
+
+    @Autowired
+    private CommandProxy commandProxy;
+
+    @ApiOperation(value = "提交授信")
+    @PostMapping("/credit_submit")
+    public JsonResult creditSubmit(HttpServletRequest request, String requestBody) {
+        return commandProxy.call(requestBody,request.getRequestURI());
+    }
+}

src/main/java/com/jqtx/windows/web/config/RouterConfig.java

+package com.jqtx.windows.web.config;
+
+import com.jqtx.windows.common.factory.AbstractCommand;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+
+@Component
+@Slf4j
+public class RouterConfig implements CommandLineRunner {
+
+    private static HashMap<String, AbstractCommand> commandHashMap = new HashMap<>();
+
+    public static AbstractCommand getCommand(String method) {
+        if (!commandHashMap.containsKey(method)) {
+            return null;
+        }
+        return commandHashMap.get(method);
+    }
+
+    @Override
+    public void run(String... args) throws Exception {
+        commandHashMap.put("check_user",null);
+    }
+}

src/main/java/com/jqtx/windows/web/request/AbcRequest.java

+package com.jqtx.windows.web.request;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+@ApiModel(description = "调第三方请求参数基类")
+public class AbcRequest {
+    @ApiModelProperty(name = "签名")
+    private String sign;
+
+    @ApiModelProperty(name = "appId")
+    private String appId;
+
+    @ApiModelProperty(name = "内容")
+    private String content;
+}