金蝶对接模型创建

zhangmeiyang
1 parent ff9c90b3
Showing 6 changed files with 18 additions and 31 deletions
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/demarcate/TypeMarketInterface.java
etrade-thirdparty/src/main/java/com/diligrp/etrade/thirdparty/exec/ZrHolder.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
 package com.diligrp.etrade.thirdparty.demarcate;
-import com.diligrp.etrade.thirdparty.type.BusinessEnum;
+import com.diligrp.etrade.core.util.JsonUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
-public abstract class AbstractBusinessHandler<T> {
+public abstract class AbstractBusinessHandler<T> implements TypeMarketInterface{
    public void handle(String json){
-      T t = this.covertData(json);
-      this.handle(t);
+      this.handle(this.covertData(json));
+   }
+   protected T covertData(String json){
+      return JsonUtils.fromJsonString(json,new TypeReference<>() {});
    }
    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();
-
+public interface ErrorHandler extends TypeMarketInterface {
+    void saveAndRecordError(String json, String errorMessage);
 }
+package com.diligrp.etrade.thirdparty.demarcate;
+
+import com.diligrp.etrade.thirdparty.type.BusinessEnum;
+
+public interface TypeMarketInterface {
+    BusinessEnum getType();
+}
@@ -31,8 +31,8 @@ public class ZrHolder implements InitializingBean, DisposableBean {
     @Override
     public void afterPropertiesSet() throws Exception {
-        businessHandlers.forEach(e-> CONTEXT.put(e.getType(), e));
-        errorHandlers.forEach(e-> ERROR_HANDLER_CONTEXT.put(e.getBusinessType(), e));
+        businessHandlers.forEach(e -> CONTEXT.put(e.getType(), e));
+        errorHandlers.forEach(e -> ERROR_HANDLER_CONTEXT.put(e.getType(), e));
     }
     @Override
 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;
@@ -18,10 +17,6 @@ public class ErrorBusinessHandler extends AbstractBusinessHandler&lt;ErrorMessageCo
     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
     public BusinessEnum getType() {
 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;
@@ -18,20 +17,11 @@ public class TestBusinessHandler extends AbstractBusinessHandler&lt;TestCo&gt; impleme
     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);