From 1c0c586546090cb277a218428aeedf2b39590e6b Mon Sep 17 00:00:00 2001 From: Qin Dong Ming <2720806930@qq.com> Date: Sun, 8 Sep 2024 09:36:45 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AE=B9=E5=99=A8=E5=86=85?= =?UTF-8?q?=E9=83=A8=E8=B7=AF=E5=BE=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/muyu/basic/BasicEngine.java | 23 ------------ .../abstracts/DataEngineRowActuator.java | 23 ------------ .../abstracts/DataEngineValueActuator.java | 30 ---------------- .../muyu/basic/handler/DataEngineHandler.java | 25 ------------- .../basic/handler/DataEngineRowHandler.java | 22 ------------ .../basic/handler/DataEngineValueHandler.java | 33 ------------------ .../src/main/java/com/muyu/test/RuleTest.java | 3 +- .../main/java/com/muyu/test/TestService.java | 4 +-- lib/com/muyu/abstracts/generate.class | Bin 384 -> 384 bytes lib/com/muyu/domain/TableInfo.class | Bin 7606 -> 7606 bytes lib/com/muyu/domain/TableInfoResp.class | Bin 6072 -> 6072 bytes .../muyu/javacomplier/JavaCompilerDemo.class | Bin 4942 -> 4942 bytes .../javacomplier/JavaStringCompiler.class | Bin 3439 -> 3439 bytes .../serviceImpl/EngIneServiceImpl.class | Bin 10220 -> 10220 bytes .../serviceImpl/TableInfoServiceImpl.class | Bin 1884 -> 1884 bytes lib/com/muyu/test/JavaClass.class | Bin 1908 -> 1910 bytes lib/com/muyu/test/RuleTest.class | Bin 4438 -> 4414 bytes lib/com/muyu/test/TestService.class | Bin 6144 -> 6120 bytes 18 files changed, 3 insertions(+), 160 deletions(-) delete mode 100644 cloud-etl-common/src/main/java/com/muyu/basic/BasicEngine.java delete mode 100644 cloud-etl-common/src/main/java/com/muyu/basic/abstracts/DataEngineRowActuator.java delete mode 100644 cloud-etl-common/src/main/java/com/muyu/basic/abstracts/DataEngineValueActuator.java delete mode 100644 cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineHandler.java delete mode 100644 cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineRowHandler.java delete mode 100644 cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineValueHandler.java diff --git a/cloud-etl-common/src/main/java/com/muyu/basic/BasicEngine.java b/cloud-etl-common/src/main/java/com/muyu/basic/BasicEngine.java deleted file mode 100644 index aab8c9f..0000000 --- a/cloud-etl-common/src/main/java/com/muyu/basic/BasicEngine.java +++ /dev/null @@ -1,23 +0,0 @@ -package com.muyu.basic; - - -import com.muyu.basic.handler.DataEngineHandler; - -/** - * @Author: DongZeLiang - * @date: 2024/8/29 - * @Description: 规则引擎基准 - * @Version: 1.0 - */ -public interface BasicEngine { - - public void set(V dataValue); - - public V get(); - - public default void remove() { - DataEngineHandler.remove(); - } - - public void execution(); -} diff --git a/cloud-etl-common/src/main/java/com/muyu/basic/abstracts/DataEngineRowActuator.java b/cloud-etl-common/src/main/java/com/muyu/basic/abstracts/DataEngineRowActuator.java deleted file mode 100644 index c5fd7df..0000000 --- a/cloud-etl-common/src/main/java/com/muyu/basic/abstracts/DataEngineRowActuator.java +++ /dev/null @@ -1,23 +0,0 @@ -package com.muyu.basic.abstracts; - -import com.muyu.basic.BasicEngine; -import com.muyu.basic.handler.DataEngineRowHandler; -import com.muyu.core.domain.DataValue; - -/** - * @Author: DongZeLiang - * @date: 2024/8/29 - * @Description: 数据值处理对象 - * @Version: 1.0 - */ - -public abstract class DataEngineRowActuator implements BasicEngine { - - public void set(DataValue[] dataValue) { - DataEngineRowHandler.set(dataValue); - } - - public DataValue[] get() { - return DataEngineRowHandler.get(); - } -} diff --git a/cloud-etl-common/src/main/java/com/muyu/basic/abstracts/DataEngineValueActuator.java b/cloud-etl-common/src/main/java/com/muyu/basic/abstracts/DataEngineValueActuator.java deleted file mode 100644 index 4d035a0..0000000 --- a/cloud-etl-common/src/main/java/com/muyu/basic/abstracts/DataEngineValueActuator.java +++ /dev/null @@ -1,30 +0,0 @@ -package com.muyu.basic.abstracts; - -import com.muyu.basic.BasicEngine; -import com.muyu.basic.handler.DataEngineValueHandler; -import com.muyu.core.domain.DataValue; - -/** - * @Author: DongZeLiang - * @date: 2024/8/29 - * @Description: 数据值处理对象 - * @Version: 1.0 - */ -public abstract class DataEngineValueActuator implements BasicEngine { - - public void set(DataValue dataValue) { - DataEngineValueHandler.set(dataValue); - } - - public DataValue get() { - return DataEngineValueHandler.get(); - } - - @Override - public void execution() { - this.run(); - this.remove(); - } - - public abstract void run(); -} diff --git a/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineHandler.java b/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineHandler.java deleted file mode 100644 index 2151b7a..0000000 --- a/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineHandler.java +++ /dev/null @@ -1,25 +0,0 @@ -package com.muyu.basic.handler; - -/** - * @Author: DongZeLiang - * @date: 2024/8/29 - * @Description: 规则引擎作用域 - * @Version: 1.0 - */ - -public class DataEngineHandler { - - private static final ThreadLocal dataEngineHandler = new ThreadLocal<>(); - - public static void set(final Object handler) { - dataEngineHandler.set(handler); - } - - public static T get() { - return (T) dataEngineHandler.get(); - } - - public static void remove() { - dataEngineHandler.remove(); - } -} diff --git a/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineRowHandler.java b/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineRowHandler.java deleted file mode 100644 index 93af1c6..0000000 --- a/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineRowHandler.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.muyu.basic.handler; - - -import com.muyu.core.domain.DataValue; - -/** - * @Author: DongZeLiang - * @date: 2024/8/29 - * @Description: 数据记录/行作用域 - * @Version: 1.0 - */ -public class DataEngineRowHandler { - - public static void set(DataValue[] dataValue) { - DataEngineHandler.set(dataValue); - } - - public static DataValue[] get() { - return DataEngineHandler.get(); - } - -} diff --git a/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineValueHandler.java b/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineValueHandler.java deleted file mode 100644 index 2adaff1..0000000 --- a/cloud-etl-common/src/main/java/com/muyu/basic/handler/DataEngineValueHandler.java +++ /dev/null @@ -1,33 +0,0 @@ -package com.muyu.basic.handler; - -import com.muyu.core.domain.DataValue; -import com.muyu.core.utils.Convert; - -/** - * @Author: DongZeLiang - * @date: 2024/8/29 - * @Description: 数据值作用域 - * @Version: 1.0 - */ -public class DataEngineValueHandler { - - public static void set(DataValue dataValue) { - DataEngineHandler.set(dataValue); - } - - public static DataValue get() { - return DataEngineHandler.get(); - } - - public static void remove() { - DataEngineHandler.remove(); - } - - public static Object getValue() { - return get().getValue(); - } - - public static Integer getIntegerValue() { - return Convert.toInt(getValue(), null); - } -} diff --git a/cloud-etl-server/src/main/java/com/muyu/test/RuleTest.java b/cloud-etl-server/src/main/java/com/muyu/test/RuleTest.java index 5bcdaab..6283739 100644 --- a/cloud-etl-server/src/main/java/com/muyu/test/RuleTest.java +++ b/cloud-etl-server/src/main/java/com/muyu/test/RuleTest.java @@ -1,6 +1,5 @@ package com.muyu.test; - -import com.muyu.basic.BasicEngine; +import com.muyu.BasicEngine; import com.muyu.core.domain.DataValue; import com.muyu.domain.EngineVersion; diff --git a/cloud-etl-server/src/main/java/com/muyu/test/TestService.java b/cloud-etl-server/src/main/java/com/muyu/test/TestService.java index 94f4f34..7126b0e 100644 --- a/cloud-etl-server/src/main/java/com/muyu/test/TestService.java +++ b/cloud-etl-server/src/main/java/com/muyu/test/TestService.java @@ -1,7 +1,7 @@ package com.muyu.test; +import com.muyu.BasicEngine; import com.muyu.access.data.base.DataValue; -import com.muyu.basic.BasicEngine; import com.muyu.domain.EngineVersion; import org.springframework.stereotype.Service; @@ -18,7 +18,7 @@ import java.util.concurrent.ConcurrentHashMap; /** * @Author: DongZeLiang - * @date: 2024/8/29 + * @date: 2024com/8/29 * @Description: 测试类 * @Version: 1.0 */ diff --git a/lib/com/muyu/abstracts/generate.class b/lib/com/muyu/abstracts/generate.class index c7d65c00944aa68cf4e6f1ae26d001824edd9012..531bfd7c218c6c12234e61f8972e8d3157cd150c 100644 GIT binary patch delta 43 qcmZo*ZeZS^#mLAtS)0*9mXCp(fq{XCfe}bD0%=|_%?~7*7z6-!5d&iY delta 43 qcmZo*ZeZS^#mLA#S)0*9mY;!}fq{XCfe}bD0%=|_%?~7*7z6-!Q3GWF diff --git a/lib/com/muyu/domain/TableInfo.class b/lib/com/muyu/domain/TableInfo.class index e911b75623d207893b41686387f8f87030bfed4e..1988c0ffd0b0bf8e52f73230fc40ce4f4b006106 100644 GIT binary patch delta 127 zcmdmHz0G>VZ+=y026hG)20jK?22ln#1{nr-24w~h1}z3p215of1``Hv26G1I%?biq zjEpjq?S(`qCkU!D%7a;R1=S}r3W-g=1r*T+i--%UPu>9(2@z6fGzW`J1hQVZ+=w^26hHZ20jKW22loU1{nq$24x0Y1}z3V215pW1``Gc26G0B%?biq zjEqu~?S(`qCkU!D%7R&Qfhz1JUlzlZ~*`_-3!zJ delta 48 ucmdm?ze9h6Ef1s0WJVs*$-zA8jOt+41RzTb%sLBX=>u89n>lzlZ~*`^oeRbQ diff --git a/lib/com/muyu/javacomplier/JavaCompilerDemo.class b/lib/com/muyu/javacomplier/JavaCompilerDemo.class index f798fd4f43df8ce9eb34aa80912e8fb54e3285ba..e06febc152d02e52c771b0b76274406892a32a82 100644 GIT binary patch delta 126 zcmX@7c1~@>a(+hc$t(D8dGawZGw?I8F$ghmGl&9N5RBEnVxQpgo; delta 126 zcmX@7c1~@>a(+gx$t(D8dGazaGw?C6F$gknGl($oGl(-t0HF$lB!dNm41*_wEJFl? z9776&B10yF5<>}4riMY4p_@UIVG@Hb!&C-shG`5s46_*YHlG&IWfU}I;AAiY8feTQ b%3#Q#&R{Z`Q|Kh4>g3Bp4vd_WMTD&YOd%Cg diff --git a/lib/com/muyu/javacomplier/JavaStringCompiler.class b/lib/com/muyu/javacomplier/JavaStringCompiler.class index 5069c969826f6bb6eae59a0c4c2b5bd9df9a5862..13dd7882025b256978fadabe231657a9337731bd 100644 GIT binary patch delta 72 zcmaDa^OV delta 72 zcmaDa^#$e141*Bscv^Q6At1=3@ XFmN)sG6(<_hyZDE2A9bjc=iJT(7y~| diff --git a/lib/com/muyu/service/serviceImpl/EngIneServiceImpl.class b/lib/com/muyu/service/serviceImpl/EngIneServiceImpl.class index a409956e8442ac14ef71496746fcf988559b3cbc..a599d87230d83044a4db43c3663226e13c4a603c 100644 GIT binary patch delta 14 VcmaFk|HglVjvC|4&AMv)838iO1=#=q delta 14 VcmaFk|HglVjvC{v&AMv)838iU1=;`r diff --git a/lib/com/muyu/service/serviceImpl/TableInfoServiceImpl.class b/lib/com/muyu/service/serviceImpl/TableInfoServiceImpl.class index e3f76b2825689347d92067e31b9d7eb1991ab308..84de7f3fc3c203af09dc6e28e911254af67e71e5 100644 GIT binary patch delta 49 zcmcb^cZYAo0aixw$p=|I7^Nn2u|>1WGw?DfOwMA)ajG~k6*yR99 CeG5nc delta 49 zcmcb^cZYAo0aiw_$p=|I7$qlju|>1WG4L|TPtIb?VpRdMRDmq*$t>)aj3Sfm*yR98 C)C)lX diff --git a/lib/com/muyu/test/JavaClass.class b/lib/com/muyu/test/JavaClass.class index d39c67a449736bae57913f78b9473c91936af525..6800e6d7cd0c3eff58a240614ef87eafc3cbce86 100644 GIT binary patch delta 33 kcmeyu_lEl)yW07lOXgv-nLxPTU5AfPB0y?h7*oHA!6VI)Fjrt5Ys2CY(VkO)=_+dB(E zHiJKbM&d^hDBj}Olg`f0v&w#F=N_LwK6n_JBg?jw?%R1q-wA4ly3q`;Jna4}#}0I4 zbC1`WskVW>N9gK4bSIt@2$D!r#7Mi#(BOz$a`ebExOP196aUXwavZBSBHXE*(g4>0W>L4P8h&ma)@dw;1FE;=H delta 238 zcmZ9EKT85}06^bQPdx6RGu=c>kFxxe=cy@bDAC%~+GGada5#j4Ee^Wsa)XZL+9Dh+ z4hju@1UGT$V??0fWb5O-H`kZ?)Fo-bM$0m+cBgGT)SsITN0olvqHcTTq-O_AIpy|+ zZud3&Nv-*+|Dh=x&RV^93BOZ0xDnkDf-nk41c-1 L=WhNWAixd)7uOcg delta 92 zcmaE%-(axe3kSbca(=FUZfRwyeo|s_X7c909HK0YX_JL{wOJtow!9w90x~|R$|m;< S*b6wL3)=FUY~~TX!v+A}#2=af