并发工具

Author: beston123

src/main/java/code/biz/bcp/BcpExecutor.java

@@ -0,0 +1,33 @@
+package code.biz.bcp;
+
+import org.springframework.util.Assert;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/3
+ */
+public class BcpExecutor {
+
+    private DataSeeker seeker = new TestDataSeeker();
+
+    private Checker checker = new TestChecker();
+
+    public boolean execute(Map<String, Object> left){
+        Map<String, Object> right = seeker.seek(left);
+        return checker.check(left, right);
+    }
+
+    public static void main(String[] args) {
+        BcpExecutor bcpExecutor = new BcpExecutor();
+        Map<String, Object> map = new HashMap<>();
+        map.put("loanId", -1L);
+
+        Assert.isTrue(bcpExecutor.execute(map), "对账不平");
+    }
+}

src/main/java/code/biz/bcp/Checker.java

@@ -0,0 +1,16 @@
+package code.biz.bcp;
+
+import java.util.Map;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/3
+ */
+public interface Checker {
+
+    boolean check(Map<String, Object> left, Map<String, Object> right);
+
+}

src/main/java/code/biz/bcp/DataSeeker.java

@@ -0,0 +1,16 @@
+package code.biz.bcp;
+
+import java.util.Map;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/3
+ */
+public interface DataSeeker {
+
+    Map<String,Object> seek(Map<String,Object> left);
+
+}

src/main/java/code/biz/bcp/Event.java

@@ -0,0 +1,13 @@
+package code.biz.bcp;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/4
+ */
+public class Event {
+
+    
+}

src/main/java/code/biz/bcp/Extractor.java

@@ -0,0 +1,15 @@
+package code.biz.bcp;
+
+import java.util.Map;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/3
+ */
+public interface Extractor {
+
+    Map<String, Object> extract(Map<String, Object> param);
+}

src/main/java/code/biz/bcp/TestChecker.java

@@ -0,0 +1,22 @@
+package code.biz.bcp;
+
+import java.util.Map;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/3
+ */
+public class TestChecker implements Checker {
+
+    @Override
+    public boolean check(Map<String, Object> left, Map<String, Object> right) {
+        if(right == null){
+            return false;
+        }
+        return true;
+    }
+
+}

src/main/java/code/biz/bcp/TestDataSeeker.java

@@ -0,0 +1,23 @@
+package code.biz.bcp;
+
+import java.util.Map;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/3
+ */
+public class TestDataSeeker implements DataSeeker {
+
+    private Extractor extractor = new TestExtractor();
+
+    private Transformer transformer = new TestTransformer();
+
+    @Override
+    public Map<String, Object> seek(Map<String, Object> left) {
+        return transformer.transform(extractor.extract(left));
+    }
+
+}

src/main/java/code/biz/bcp/TestEnv.java

@@ -0,0 +1,19 @@
+package code.biz.bcp;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/4
+ */
+public class TestEnv {
+
+    public static void main(String[] args) {
+        System.out.println("SYS_TTT:"+System.getenv("SYS_TTT"));
+        System.getenv().forEach((key, value)->{
+            System.out.println(key+" => "+value);
+        });
+    }
+
+}

src/main/java/code/biz/bcp/TestExtractor.java

@@ -0,0 +1,25 @@
+package code.biz.bcp;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/3
+ */
+public class TestExtractor implements Extractor {
+
+    @Override
+    public Map<String, Object> extract(Map<String, Object> param) {
+        if((Long)param.get("loanId") < 0){
+            return null;
+        }
+        Map<String, Object> map = new HashMap<>();
+        map.put("loanId", param.get("loanId"));
+        return map;
+    }
+
+}

src/main/java/code/biz/bcp/TestTransformer.java

@@ -0,0 +1,22 @@
+package code.biz.bcp;
+
+import java.util.Map;
+
+/**
+ * 〈一句话功能简述〉<p>
+ * 〈功能详细描述〉
+ *
+ * @author zixiao
+ * @date 2019/9/3
+ */
+public class TestTransformer implements Transformer{
+
+    @Override
+    public Map<String, Object> transform(Map<String, Object> source) {
+        if(source == null){
+            return null;
+        }
+        source.put("tag", "1");
+        return source;
+    }
+}