金蝶对接模型创建

zhangmeiyang
1 parent a5e982ef
Showing 12 changed files with 145 additions and 79 deletions
etrade-core/src/main/java/com/diligrp/etrade/core/util/JsonUtils.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/co/ErrorMessageCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/co/TestCo.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/AbstractBusinessHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/demarcate/ErrorHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/exec/ZrHolder.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/exec/ZrReceiver.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/AbstractBusinessHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/ErrorBusinessHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/handler/TestBusinessHandler.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/co/BaseCo.java → etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/message/GeneralMessage.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/type/BusinessEnum.java
@@ -26,7 +26,7 @@ import java.util.TimeZone;
 public class JsonUtils {
-    private static ObjectMapper objectMapper = initObjectMapper();
+    private static final ObjectMapper objectMapper = initObjectMapper();
     private static ObjectMapper initObjectMapper(){
         Jackson2ObjectMapperBuilder jackson2ObjectMapperBuilder = new Jackson2ObjectMapperBuilder();
@@ -82,6 +82,14 @@ public class JsonUtils {
         }
     }
+    public static <T> T fromJsonString(String json, JavaType javaType){
+        try {
+            return objectMapper.readValue(json, javaType);
+        } catch (JsonProcessingException ex) {
+            throw new IllegalArgumentException("Deserialize json array exception", ex);
+        }
+    }
+
     public static <T> String toJsonString(T object) {
         try {
             return objectMapper.writeValueAsString(object);
 package com.diligrp.etrade.thirdparty.co;
+import com.diligrp.etrade.thirdparty.type.BusinessEnum;
+
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2024-09-10 11:32
  * @Version: todo
  */
-public class ErrorMessageCo extends BaseCo{
+public class ErrorMessageCo {
+    private String errorMessage;
+
+    private String content;
+
+    private BusinessEnum business;
+
+    public String getContent() {
+        return content;
+    }
+
+    public void setContent(String content) {
+        this.content = content;
+    }
+
+    public String getErrorMessage() {
+        return errorMessage;
+    }
+
+    public void setErrorMessage(String errorMessage) {
+        this.errorMessage = errorMessage;
+    }
+
+    public BusinessEnum getBusiness() {
+        return business;
+    }
+    public void setBusiness(BusinessEnum business) {
+        this.business = business;
+    }
 }
@@ -5,7 +5,7 @@ package com.diligrp.etrade.thirdparty.co;
  * @CreateTime: 2024-09-10 15:06
  * @Version: todo
  */
-public class TestCo extends BaseCo{
+public class TestCo{
     private String name;
     public String getName() {
+package com.diligrp.etrade.thirdparty.demarcate;
+
+import com.diligrp.etrade.thirdparty.type.BusinessEnum;
+
+public abstract class AbstractBusinessHandler<T> {
+   public void handle(String json){
+      T t = this.covertData(json);
+      this.handle(t);
+   }
+
+   protected abstract void handle(T t);
+
+   protected abstract T covertData(String json);
+
+   public abstract BusinessEnum getType();
+}
+package com.diligrp.etrade.thirdparty.demarcate;
+
+import com.diligrp.etrade.thirdparty.type.BusinessEnum;
+
+public interface ErrorHandler {
+    void saveAndRecordError(String json,String errorMessage);
+    BusinessEnum getBusinessType();
+
+}
 package com.diligrp.etrade.thirdparty.exec;
-import com.diligrp.etrade.thirdparty.handler.AbstractBusinessHandler;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBusinessHandler;
+import com.diligrp.etrade.thirdparty.demarcate.ErrorHandler;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import jakarta.annotation.Resource;
 import org.springframework.beans.factory.DisposableBean;
@@ -19,16 +20,19 @@ import java.util.concurrent.ConcurrentHashMap;
 @Component
 public class ZrHolder implements InitializingBean, DisposableBean {
-    public final static Map<BusinessEnum, AbstractBusinessHandler> CONTEXT = new ConcurrentHashMap<>();
+    public final static Map<BusinessEnum, AbstractBusinessHandler<?>> CONTEXT = new ConcurrentHashMap<>();
+    public final static Map<BusinessEnum, ErrorHandler> ERROR_HANDLER_CONTEXT = new ConcurrentHashMap<>();
     @Resource
-    private List<AbstractBusinessHandler> abstractBusinessHandlerList;
+    private List<AbstractBusinessHandler<?>> abstractBusinessHandlerList;
+
+    @Resource
+    private List<ErrorHandler> errorHandlers;
     @Override
     public void afterPropertiesSet() throws Exception {
-        abstractBusinessHandlerList.forEach(e->{
-            CONTEXT.put(e.getType(), e);
-        });
+        abstractBusinessHandlerList.forEach(e-> CONTEXT.put(e.getType(), e));
+        errorHandlers.forEach(e-> ERROR_HANDLER_CONTEXT.put(e.getBusinessType(), e));
     }
     @Override
 package com.diligrp.etrade.thirdparty.exec;
 import com.diligrp.etrade.core.util.JsonUtils;
-import com.diligrp.etrade.thirdparty.co.BaseCo;
+import com.diligrp.etrade.thirdparty.co.ErrorMessageCo;
+import com.diligrp.etrade.thirdparty.message.GeneralMessage;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import com.rabbitmq.client.Channel;
 import jakarta.annotation.Resource;
@@ -37,34 +38,36 @@ public class ZrReceiver {
     @RabbitListener(bindings = @QueueBinding(value = @Queue(value = ZR_NORMAL_QUEUE, autoDelete = "false"), exchange = @Exchange(value = ZR_NORMAL_EXCHANGE), key = ZR_NORMAL_ROUTING), ackMode = "MANUAL")
     public void receiveMessage(Channel channel, Message message) throws IOException {
         var content = new String(message.getBody(), StandardCharsets.UTF_8);
-        BaseCo baseCo = JsonUtils.fromJsonString(content, BaseCo.class);
+        GeneralMessage msg = JsonUtils.fromJsonString(content, GeneralMessage.class);
         try {
-            ZrHolder.CONTEXT.get(baseCo.getBusinessEnum()).handle(content);
+            ZrHolder.CONTEXT.get(msg.getBusiness()).handle(msg.getData());
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         } catch (Exception e) {
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-            var t = baseCo.getBusinessEnum().getBusinessParam(content);
-            t.setRetryCount(baseCo.getRetryCount() + 1);
-            sendDelayMsg(DELAY, JsonUtils.toJsonString(t));
+            msg.setRetryCount(msg.getRetryCount()+1);
+            sendDelayMsg(DELAY, JsonUtils.toJsonString(msg));
         }
     }
     @RabbitListener(queues = ZR_DEAD_QUEUE, ackMode = "MANUAL")
     public void handleCustomDelayMsg(Channel channel, Message message) throws IOException {
         var content = new String(message.getBody(), StandardCharsets.UTF_8);
-        BaseCo baseCo = JsonUtils.fromJsonString(content, BaseCo.class);
+        GeneralMessage msg = JsonUtils.fromJsonString(content, GeneralMessage.class);
         try {
-            ZrHolder.CONTEXT.get(baseCo.getBusinessEnum()).handle(content);
+            ZrHolder.CONTEXT.get(msg.getBusiness()).handle(msg.getData());
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         } catch (Exception e) {
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-            var t = baseCo.getBusinessEnum().getBusinessParam(content);
-            t.setRetryCount(baseCo.getRetryCount() + 1);
-            if (t.getRetryCount() > 3) {
-                t.setErrorMessage(e.fillInStackTrace().getMessage());
-                t.setBusinessEnum(BusinessEnum.ERROR);
+            msg.setRetryCount(msg.getRetryCount() + 1);
+            if (msg.getRetryCount() > 3) {
+                ErrorMessageCo errorMessageCo = new ErrorMessageCo();
+                errorMessageCo.setContent(msg.getData());
+                errorMessageCo.setErrorMessage(e.fillInStackTrace().getMessage());
+                errorMessageCo.setBusiness(msg.getBusiness());
+                msg.setData(JsonUtils.toJsonString(errorMessageCo));
+                msg.setBusiness(BusinessEnum.ERROR);
             }
-            sendDelayMsg(DELAY, JsonUtils.toJsonString(t));
+            sendDelayMsg(DELAY, JsonUtils.toJsonString(msg));
         }
     }
-package com.diligrp.etrade.thirdparty.handler;
-
-import com.diligrp.etrade.thirdparty.type.BusinessEnum;
-
-public abstract class AbstractBusinessHandler {
-
-   public abstract void handle(String json);
-
-   public abstract BusinessEnum getType();
-}
@@ -2,6 +2,8 @@ package com.diligrp.etrade.thirdparty.handler;
 import com.diligrp.etrade.core.util.JsonUtils;
 import com.diligrp.etrade.thirdparty.co.ErrorMessageCo;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBusinessHandler;
+import com.diligrp.etrade.thirdparty.exec.ZrHolder;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import org.springframework.stereotype.Component;
@@ -11,11 +13,14 @@ import org.springframework.stereotype.Component;
  * @Version: todo
  */
 @Component
-public class ErrorBusinessHandler extends AbstractBusinessHandler {
+public class ErrorBusinessHandler extends AbstractBusinessHandler<ErrorMessageCo> {
     @Override
-    public void handle(String json) {
-        ErrorMessageCo co = JsonUtils.fromJsonString(json, ErrorMessageCo.class);
-        System.out.println(co.getErrorMessage());
+    protected void handle(ErrorMessageCo co) {
+        ZrHolder.ERROR_HANDLER_CONTEXT.get(co.getBusiness()).saveAndRecordError(co.getContent(),co.getErrorMessage());
+    }
+    @Override
+    protected ErrorMessageCo covertData(String json) {
+        return JsonUtils.fromJsonString(json, ErrorMessageCo.class);
     }
     @Override
@@ -2,6 +2,8 @@ package com.diligrp.etrade.thirdparty.handler;
 import com.diligrp.etrade.core.util.JsonUtils;
 import com.diligrp.etrade.thirdparty.co.TestCo;
+import com.diligrp.etrade.thirdparty.demarcate.AbstractBusinessHandler;
+import com.diligrp.etrade.thirdparty.demarcate.ErrorHandler;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 import org.springframework.stereotype.Component;
@@ -11,15 +13,29 @@ import org.springframework.stereotype.Component;
  * @Version: todo
  */
 @Component
-public class TestBusinessHandler extends AbstractBusinessHandler{
+public class TestBusinessHandler extends AbstractBusinessHandler<TestCo> implements ErrorHandler {
     @Override
-    public void handle(String json) {
-        TestCo testCo = JsonUtils.fromJsonString(json, TestCo.class);
+    protected void handle(TestCo t) {
         var s =  1/0;
     }
+    @Override
+    protected TestCo covertData(String json) {
+        return JsonUtils.fromJsonString(json, TestCo.class);
+    }
     @Override
     public BusinessEnum getType() {
         return BusinessEnum.TEST;
     }
+
+    @Override
+    public BusinessEnum getBusinessType() {
+        return BusinessEnum.TEST;
+    }
+    @Override
+    public void saveAndRecordError(String json,String errorMessage) {
+        System.out.println(json);
+        System.out.println(errorMessage);
+        System.out.println("save db");
+    }
 }
-package com.diligrp.etrade.thirdparty.co;
+package com.diligrp.etrade.thirdparty.message;
 import com.diligrp.etrade.thirdparty.type.BusinessEnum;
 /**
  * @Author: zhangmeiyang
- * @CreateTime: 2024-09-10 11:30
+ * @CreateTime: 2024-09-12 14:45
  * @Version: todo
  */
-public class BaseCo {
-    private String errorMessage;
+public class GeneralMessage {
+    private BusinessEnum business;
+    private String data;
     private Integer retryCount;
-    private BusinessEnum businessEnum;
-    public BaseCo() {
+    public GeneralMessage() {
         this.retryCount = 0;
     }
-    public BusinessEnum getBusinessEnum() {
-        return businessEnum;
+    public BusinessEnum getBusiness() {
+        return business;
     }
-    public void setBusinessEnum(BusinessEnum businessEnum) {
-        this.businessEnum = businessEnum;
+    public void setBusiness(BusinessEnum business) {
+        this.business = business;
     }
-    public Integer getRetryCount() {
-        return retryCount;
+    public String getData() {
+        return data;
     }
-    public void setRetryCount(Integer retryCount) {
-        this.retryCount = retryCount;
+    public void setData(String data) {
+        this.data = data;
     }
-    public String getErrorMessage() {
-        return errorMessage;
+    public Integer getRetryCount() {
+        return retryCount;
     }
-    public void setErrorMessage(String errorMessage) {
-        this.errorMessage = errorMessage;
+    public void setRetryCount(Integer retryCount) {
+        this.retryCount = retryCount;
     }
 }
 package com.diligrp.etrade.thirdparty.type;
-import com.diligrp.etrade.core.util.JsonUtils;
-import com.diligrp.etrade.thirdparty.co.BaseCo;
 import com.diligrp.etrade.thirdparty.co.ErrorMessageCo;
 import com.diligrp.etrade.thirdparty.co.TestCo;
@@ -10,30 +8,17 @@ import com.diligrp.etrade.thirdparty.co.TestCo;
  * @CreateTime: 2024-09-10 10:53
  * @Version: todo
  */
-public enum BusinessEnum implements BusinessKlass{
+public enum BusinessEnum{
-    ERROR("ERROR"){
-        @Override
-        public ErrorMessageCo getBusinessParam(String content) {
-            return JsonUtils.fromJsonString(content,ErrorMessageCo.class);
-        }
-    },
+    ERROR("ERROR", ErrorMessageCo.class),
-    TEST("TEST"){
-        @Override
-        public TestCo getBusinessParam(String content) {
-            return JsonUtils.fromJsonString(content,TestCo.class);
-        }
-    };
+    TEST("TEST",TestCo.class);
     public final String code;
+    public final Class<?> clazz;
-    BusinessEnum(String code) {
+    BusinessEnum(String code, Class<?> clazz) {
         this.code = code;
+        this.clazz = clazz;
     }
 }
-
-interface BusinessKlass<T extends BaseCo> {
-    T getBusinessParam(String content);
-
-}