add http请求

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/api/ApiServiceImpl.java

@@ -0,0 +1,79 @@
+package com.hrsk.cloud.eg.app.api;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-08-02 10:57
+ * @description: 保存api
+ **/
+@RestController
+@RequestMapping("/api")
+public class ApiServiceImpl {
+//    @Resource
+//    private EgApiEndpointMapper egApiEndpointMapper;
+//
+//    @Resource
+//    private ApiGateway apiGateway;
+//
+//    @GetMapping("/save")
+//    public void save(){
+//        EgApiEndpointDo egApiEndpointDo = new EgApiEndpointDo();
+//        egApiEndpointDo.setApiId(1234L);
+//        egApiEndpointDo.setEndpointType("http");
+//        egApiEndpointDo.setCreateUid("100000");
+//        egApiEndpointDo.setCreateUsername("admin");
+//        egApiEndpointDo.setModifyUid("100000");
+//        egApiEndpointDo.setModifyUsername("admin");
+//        egApiEndpointDo.setEndpointConfig(HessianUtils.serialize(createBean()));
+//        egApiEndpointMapper.insert(egApiEndpointDo);
+//    }
+//
+//    @GetMapping("/request")
+//    public void request(){
+//        apiGateway.request();
+//    }
+//
+//    private HttpApiConfig createBean(){
+//        FunctionObject md5 = new FunctionObject();
+//        md5.setCode("md5");
+//        HttpApiConfig hac = new HttpApiConfig()
+//                .setUrl("https://baidu.com");
+//        hac.setContentType(ApiPayloadTypeEnum.APPLICATION_JSON.getCode());
+//        hac.setType("http");
+//        List<KeyValueObject> h = Lists.newArrayList();
+//        KeyValueObject h1 = new KeyValueObject();
+//        h1.setKey("secretKey");
+//        h1.setType("text");
+//        h1.setValue("Khw99%$l%-2gF7P4jXglp_-jQqQirtYnOY5D");
+//        h.add(h1);
+//        KeyValueObject h2 = new KeyValueObject();
+//        h2.setKey("merchantNo");
+//        h2.setType("spel");
+//        h2.setValue("#param.realName");
+//        h.add(h2);
+//        List<ValueObject> p = Lists.newArrayList();
+//        ValueObject p1 = new ValueObject();
+//        p1.setType("text");
+//        p1.setValue("123");
+//        ValueObject p2 = new ValueObject();
+//        p2.setType("text");
+//        p2.setValue("456");
+//        p2.getFunctions().add(md5);
+//        p.add(p1);
+//        p.add(p2);
+//        List<KeyValueObject> s = Lists.newArrayList();
+//        KeyValueObject s1 = new KeyValueObject();
+//        s1.setKey("username");
+//        s1.setType("spel");
+//        s1.setValue("#param.username");
+//        KeyValueObject s2 = new KeyValueObject();
+//        s2.setKey("channel");
+//        s2.setType("spel");
+//        s2.setValue("#param.channel");
+//        s.add(s2);
+//        hac.setPath(p).setSearch(s).setHeader(h).setMethod("GET");
+//        hac.setContent("{\"merchant\":\"xxxxxxfffff\",\"phone\":\"#{\\\"value\\\":\\\"#param.userMobile\\\",\\\"type\\\": \\\"spel\\\",\\\"functions\\\":[ {\\\"code\\\": \\\"md5\\\"}]}\"}");
+//        return hac;
+//    }
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/loan/LoanServiceImpl.java

@@ -0,0 +1,16 @@
+package com.hrsk.cloud.eg.app.loan;
+
+
+import com.hrsk.cloud.eg.api.LoanService;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-07-26 17:20
+ * @description: 贷款服务
+ **/
+public class LoanServiceImpl implements LoanService {
+    @Override
+    public void checkInto() {
+
+    }
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/loan/executor/LoanParallelCheckIntoCmdExe.java

@@ -0,0 +1,15 @@
+package com.hrsk.cloud.eg.app.loan.executor;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-07-26 17:35
+ * @description: 贷款并行撞库CMD执行
+ **/
+@Component
+public class LoanParallelCheckIntoCmdExe {
+    public void execute(){
+
+    }
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/loan/executor/LoanSerialCheckIntoCmdExe.java

@@ -0,0 +1,15 @@
+package com.hrsk.cloud.eg.app.loan.executor;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-07-26 17:33
+ * @description: 贷款撞库CMD
+ **/
+@Component
+public class LoanSerialCheckIntoCmdExe {
+    public void execute(){
+
+    }
+}

egress-gateway-service-client/pom.xml

@@ -20,5 +20,9 @@
             <groupId>com.hrsk.pangu</groupId>
             <artifactId>pangu-component-dto</artifactId>
         </dependency>
+        <dependency>
+            <groupId>javax.validation</groupId>
+            <artifactId>validation-api</artifactId>
+        </dependency>
     </dependencies>
 </project>

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/api/LoanService.java

@@ -0,0 +1,13 @@
+package com.hrsk.cloud.eg.api;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-07-26 13:52
+ * @description: 贷款类服务
+ **/
+public interface LoanService {
+    /**
+     * 撞库
+     */
+    void checkInto();
+}

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/dto/CustomerAddCmd.java

@@ -0,0 +1,22 @@
+package com.hrsk.cloud.eg.dto;
+
+import com.hrsk.cloud.eg.dto.data.CustomerDTO;
+import lombok.Data;
+
+@Data
+public class CustomerAddCmd{
+
+    private CustomerDTO customerDTO;
+
+
+    public static void main(String[] args) {
+        Thread thread = new Thread(new Runnable() {
+            @Override
+            public void run() {
+
+            }
+        });
+        thread.start();
+        thread.interrupt();
+    }
+}

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/dto/CustomerListByNameQry.java

@@ -0,0 +1,9 @@
+package com.hrsk.cloud.eg.dto;
+
+import com.hrsk.pangu.dto.Query;
+import lombok.Data;
+
+@Data
+public class CustomerListByNameQry extends Query {
+   private String name;
+}

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/dto/data/CustomerDTO.java

@@ -0,0 +1,18 @@
+package com.hrsk.cloud.eg.dto.data;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotEmpty;
+
+
+@Data
+public class CustomerDTO{
+    private String customerId;
+    private String memberId;
+    private String customerName;
+    private String customerType;
+    @NotEmpty
+    private String companyName;
+    @NotEmpty
+    private String source;
+}

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/dto/data/ErrorCode.java

@@ -0,0 +1,6 @@
+package com.hrsk.cloud.eg.dto.data;
+
+
+public class ErrorCode {
+    public static final String B_CUSTOMER_companyNameConflict = "B_CUSTOMER_companyNameConflict";
+}

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/dto/data/UserInfoDto.java

@@ -0,0 +1,42 @@
+package com.hrsk.cloud.eg.dto.data;
+
+import lombok.Data;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-08-01 13:48
+ * @description: User信息Dto
+ **/
+@Data
+public class UserInfoDto {
+    private Long userId;
+    private String userMobile;
+    private String idCardNo;
+    private String realName;
+    private String ip;
+    private Integer runPlatform;
+    private String deviceModel;
+    private Integer appId;
+    private String policeSex;
+    private String policeBirthBate;
+    private Integer age;
+    private String companyCity;
+    private Integer socialSecurity;
+    private Integer accumulation;
+    private Integer creditCard;
+    private Integer creditLimit;
+    private Integer sesame;
+    private Integer addressCityCode;
+    private Integer profession;
+    private Integer overdue;
+    private Integer borrowMoney;
+    private Integer borrowLimit;
+    private Integer borrowPurpose;
+    private String phoneMd5;
+    private String cityOfWork;
+    private String cityCode;
+    private String userMobileSalt;
+    private String idCardNoSalt;
+    private String channelCode;
+    private String activeChannelCode;
+}

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/dto/event/CustomerCreatedEvent.java

@@ -0,0 +1,21 @@
+package com.hrsk.cloud.eg.dto.event;
+
+/**
+ * CustomerCreatedEvent
+ *
+ * @author Frank Zhang
+ * @date 2019-01-04 10:32 AM
+ */
+public class CustomerCreatedEvent{
+
+    private String customerId;
+
+    public String getCustomerId() {
+        return customerId;
+    }
+
+    public void setCustomerId(String customerId) {
+        this.customerId = customerId;
+    }
+
+}

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/dto/event/DomainEventConstant.java

@@ -0,0 +1,11 @@
+package com.hrsk.cloud.eg.dto.event;
+
+/**
+ * @author niexiaolong
+ * @date 2019/4/16
+ */
+public class DomainEventConstant {
+
+	public static final String CUSTOMER_CREATED_TOPIC = "CRM_CUSTOMER_CREATED_DOMAIN_EVENT_TOPIC";
+
+}

egress-gateway-service-domain/pom.xml

@@ -17,6 +17,15 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.hrsk.cloud</groupId>
+            <artifactId>egress-gateway-service-client</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>com.hrsk.pangu</groupId>
             <artifactId>pangu-component-domain-starter</artifactId>
@@ -55,5 +64,6 @@
             <groupId>com.google.code.gson</groupId>
             <artifactId>gson</artifactId>
         </dependency>
+
     </dependencies>
 </project>

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/ApiFactory.java

@@ -1,8 +1,8 @@
 package com.hrsk.cloud.eg.domain.api;
 
 import com.alibaba.cola.domain.DomainFactory;
-import com.hrsk.cloud.op.eg.domain.api.common.ApiTypeEnums;
-import com.hrsk.cloud.op.eg.domain.common.BizPreconditions;
+import com.hrsk.cloud.eg.domain.api.common.ApiTypeEnums;
+import com.hrsk.cloud.eg.domain.common.utils.BizPreconditions;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Component;

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/FunctionObject.java

@@ -1,8 +1,8 @@
 package com.hrsk.cloud.eg.domain.api;
 
 import com.google.common.collect.Lists;
-import com.hrsk.cloud.op.eg.domain.api.func.ValueObjectFunctionManager;
-import com.hrsk.cloud.op.eg.domain.api.resolver.vo.ValueObjectResolverManager;
+import com.hrsk.cloud.eg.domain.api.func.ValueObjectFunctionManager;
+import com.hrsk.cloud.eg.domain.api.resolver.vo.ValueObjectResolverManager;
 import lombok.Data;
 import lombok.ToString;
 

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/HttpApi.java

@@ -2,8 +2,8 @@ package com.hrsk.cloud.eg.domain.api;
 
 import com.alibaba.cola.domain.Entity;
 import com.alibaba.cola.exception.BizException;
-import com.hrsk.cloud.op.eg.domain.api.common.ApiPayloadTypeEnum;
-import com.hrsk.cloud.op.eg.domain.api.resolver.payload.ApiPayloadResolverManage;
+import com.hrsk.cloud.eg.domain.api.common.ApiPayloadTypeEnum;
+import com.hrsk.cloud.eg.domain.api.resolver.payload.ApiPayloadResolverManage;
 import lombok.Getter;
 import lombok.ToString;
 import org.apache.commons.lang3.StringUtils;

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/KeyValueObject.java

@@ -1,6 +1,6 @@
 package com.hrsk.cloud.eg.domain.api;
 
-import com.hrsk.cloud.op.eg.domain.common.BizPreconditions;
+import com.hrsk.cloud.eg.domain.common.utils.BizPreconditions;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.ToString;

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/ValueObject.java

@@ -1,7 +1,7 @@
 package com.hrsk.cloud.eg.domain.api;
 
-import com.hrsk.cloud.op.eg.domain.api.resolver.vo.ValueObjectResolverManager;
-import com.hrsk.cloud.op.eg.domain.common.BizPreconditions;
+import com.hrsk.cloud.eg.domain.api.resolver.vo.ValueObjectResolverManager;
+import com.hrsk.cloud.eg.domain.common.utils.BizPreconditions;
 import lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/func/EncryptionFunction.java

@@ -1,6 +1,7 @@
 package com.hrsk.cloud.eg.domain.api.func;
 
-import com.hrsk.cloud.op.eg.domain.api.FunctionParam;
+
+import com.hrsk.cloud.eg.domain.api.FunctionParam;
 
 import java.security.MessageDigest;
 import java.util.Objects;

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/func/ValueObjectFunctionManager.java

@@ -1,7 +1,7 @@
 package com.hrsk.cloud.eg.domain.api.func;
 
 import com.alibaba.cola.exception.BizException;
-import com.hrsk.cloud.op.eg.domain.api.FunctionParam;
+import com.hrsk.cloud.eg.domain.api.FunctionParam;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.HashMap;
@@ -56,7 +56,7 @@ public class ValueObjectFunctionManager {
      * @param functionParam 函数参数
      * @return 函数执行结果
      */
-    public Object apply(String code,FunctionParam functionParam){
+    public Object apply(String code, FunctionParam functionParam){
         Function<FunctionParam,Object> function = FUNCTIONS.get(code);
         if(function == null){
             throw new BizException("不支持的函数编码!");

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/resolver/payload/ApiJsonPayloadResolver.java

@@ -2,9 +2,9 @@ package com.hrsk.cloud.eg.domain.api.resolver.payload;
 
 import com.alibaba.cola.exception.BizException;
 import com.google.gson.*;
-import com.hrsk.cloud.op.eg.domain.api.ApiContext;
-import com.hrsk.cloud.op.eg.domain.api.ValueObject;
-import com.hrsk.cloud.op.eg.domain.common.GsonUtils;
+import com.hrsk.cloud.eg.domain.api.ApiContext;
+import com.hrsk.cloud.eg.domain.api.ValueObject;
+import com.hrsk.cloud.eg.domain.common.utils.GsonUtil;
 import org.apache.commons.lang3.StringUtils;
 
 /**
@@ -29,7 +29,7 @@ public class ApiJsonPayloadResolver implements ApiPayloadResolver {
 
     @Override
     public Object resolve(String jsonTemplate, ApiContext context) {
-        JsonElement jsonElement = GsonUtils.fromJson(jsonTemplate, JsonElement.class);
+        JsonElement jsonElement = GsonUtil.parseJSON(jsonTemplate, JsonElement.class);
         traverseJson(jsonElement,jsonElement,null,context,0);
         return jsonElement.toString();
     }

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/resolver/payload/ApiPayloadResolver.java

@@ -1,6 +1,7 @@
 package com.hrsk.cloud.eg.domain.api.resolver.payload;
 
-import com.hrsk.cloud.op.eg.domain.api.ApiContext;
+
+import com.hrsk.cloud.eg.domain.api.ApiContext;
 
 /**
  * @author: bianlanzhou
@@ -13,5 +14,5 @@ public interface ApiPayloadResolver {
      * @param template payload模版
      * @param context 上下文
      */
-    Object resolve(String template,ApiContext context);
+    Object resolve(String template, ApiContext context);
 }

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/resolver/payload/ApiPayloadResolverManage.java

@@ -1,8 +1,8 @@
 package com.hrsk.cloud.eg.domain.api.resolver.payload;
 
 import com.google.common.collect.Maps;
-import com.hrsk.cloud.op.eg.domain.api.ApiContext;
-import com.hrsk.cloud.op.eg.domain.api.common.ApiPayloadTypeEnum;
+import com.hrsk.cloud.eg.domain.api.ApiContext;
+import com.hrsk.cloud.eg.domain.api.common.ApiPayloadTypeEnum;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.Map;

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/resolver/vo/BasicTypeValueObjectResolver.java

@@ -1,7 +1,8 @@
 package com.hrsk.cloud.eg.domain.api.resolver.vo;
 
-import com.hrsk.cloud.op.eg.domain.api.ApiContext;
-import com.hrsk.cloud.op.eg.domain.api.ValueObject;
+
+import com.hrsk.cloud.eg.domain.api.ApiContext;
+import com.hrsk.cloud.eg.domain.api.ValueObject;
 
 /**
  * @author: bianlanzhou

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/resolver/vo/SpelValueObjectResolver.java

@@ -1,7 +1,7 @@
 package com.hrsk.cloud.eg.domain.api.resolver.vo;
 
-import com.hrsk.cloud.op.eg.domain.api.ApiContext;
-import com.hrsk.cloud.op.eg.domain.api.ValueObject;
+import com.hrsk.cloud.eg.domain.api.ApiContext;
+import com.hrsk.cloud.eg.domain.api.ValueObject;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.expression.ExpressionParser;
 import org.springframework.expression.spel.standard.SpelExpressionParser;

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/resolver/vo/ValueObjectResolver.java

@@ -1,7 +1,8 @@
 package com.hrsk.cloud.eg.domain.api.resolver.vo;
 
-import com.hrsk.cloud.op.eg.domain.api.ApiContext;
-import com.hrsk.cloud.op.eg.domain.api.ValueObject;
+
+import com.hrsk.cloud.eg.domain.api.ApiContext;
+import com.hrsk.cloud.eg.domain.api.ValueObject;
 
 /**
  * @author: bianlanzhou

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/resolver/vo/ValueObjectResolverManager.java

@@ -2,9 +2,9 @@ package com.hrsk.cloud.eg.domain.api.resolver.vo;
 
 import com.alibaba.cola.exception.BizException;
 import com.google.common.collect.Maps;
-import com.hrsk.cloud.op.eg.domain.api.ApiContext;
-import com.hrsk.cloud.op.eg.domain.api.ValueObject;
-import com.hrsk.cloud.op.eg.domain.api.common.ValueObjectTypeEnum;
+import com.hrsk.cloud.eg.domain.api.ApiContext;
+import com.hrsk.cloud.eg.domain.api.ValueObject;
+import com.hrsk.cloud.eg.domain.api.common.ValueObjectTypeEnum;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;