From c26b0a3284a686fbcb4783be3ff1c282cc6e1792 Mon Sep 17 00:00:00 2001 From: zhang chengzhi <3144712872@qq.com> Date: Tue, 10 Sep 2024 08:52:33 +0800 Subject: [PATCH] 544245 --- lib/com/muyu/etl/basic/DataValueBasic.class | Bin 0 -> 337 bytes lib/com/muyu/etl/basic/DataValueBasic.java | 24 ------ lib/com/muyu/etl/basic/TaskBasic.class | Bin 0 -> 377 bytes lib/com/muyu/etl/basic/TaskBasic.java | 11 --- lib/com/muyu/etl/domain/DataValue.class | Bin 0 -> 3498 bytes lib/com/muyu/etl/domain/DataValue.java | 30 -------- lib/com/muyu/etl/enums/DataType.class | Bin 0 -> 3027 bytes lib/com/muyu/etl/enums/DataType.java | 73 ------------------- lib/com/muyu/etl/scope/TaskScopeBasic.class | Bin 0 -> 973 bytes lib/com/muyu/etl/scope/TaskScopeBasic.java | 18 ----- lib/com/muyu/etl/scope/TaskScopeConfig.class | Bin 0 -> 3283 bytes lib/com/muyu/etl/scope/TaskScopeConfig.java | 36 --------- 12 files changed, 192 deletions(-) create mode 100644 lib/com/muyu/etl/basic/DataValueBasic.class delete mode 100644 lib/com/muyu/etl/basic/DataValueBasic.java create mode 100644 lib/com/muyu/etl/basic/TaskBasic.class delete mode 100644 lib/com/muyu/etl/basic/TaskBasic.java create mode 100644 lib/com/muyu/etl/domain/DataValue.class delete mode 100644 lib/com/muyu/etl/domain/DataValue.java create mode 100644 lib/com/muyu/etl/enums/DataType.class delete mode 100644 lib/com/muyu/etl/enums/DataType.java create mode 100644 lib/com/muyu/etl/scope/TaskScopeBasic.class delete mode 100644 lib/com/muyu/etl/scope/TaskScopeBasic.java create mode 100644 lib/com/muyu/etl/scope/TaskScopeConfig.class delete mode 100644 lib/com/muyu/etl/scope/TaskScopeConfig.java diff --git a/lib/com/muyu/etl/basic/DataValueBasic.class b/lib/com/muyu/etl/basic/DataValueBasic.class new file mode 100644 index 0000000000000000000000000000000000000000..36af6b49e8963950c0097247d6897709aa082035 GIT binary patch literal 337 zcmaiwJqiLb5QSg-i~kC?Hfp1dIe^%RSP6oPjnx=~tnRw7nDQP8sW~4aJ^TW3sd&-&yf}t-#wN2CHgej!$go|vH~oUPVL;yTV>uAWF*Xm+0_|>Z{Z}pD>R6z| x^8fncB6N{96VK=GG`^$ula!oGAk8PsYf5u=i9C`W6i|HKC6u`%P~nP48}Miv_uzko6B>svLQRD;oD8$}D zlN9Kr(azp#W_G{6KQ{obaS|iIAVQd64@1JavX!X%w_fP36s@u^TC8OIymZx#Y>gre z3f&PdF0ZoxhUd0^G{r2!KH+q0Fn2Ou)eA<53FEbVm7sD>g{k#@qfX5yH8B z(1cNDYJJyNxo%c6FS#?xtdixuY>eZ7&9HkiE#YiCa`XMc(@=+w!CQXSVq9mY50jabFDHZ`g*rrPxnva@nm|@0e z$0uie(s9ODnQ?ef#=;EFIQoJ!{!JqO&hAaRNn_>3PIvFQ=l;&Q=j)!k`Sb5bzXCXc ziiwDZLxpNNTW;KGWL>Y6U9Og$VkLXp@tj4c)Nqq6>QtjxT6Sx3XwYpKh-!!)FII}) zn;Lp1Qj0NIh?$7n=!LCe@3v|wvgY2=Ff@D1x$R_2PGu##;MIzimAvTLVWS@d+{nAL z?o!umn=-f3DA#=xFLT)!7_#x4>}r&pCATChhHZ>s7df}ZjrN@`EZuSoUOrA(!p10` z*I*T#%9&3aPD#V?M93%wOY9$B^Syl;>=W zIQg@Ffp+yFdVVCW;W*z>j(}WQ?Av?`I?GYGM*3%%0*!>AgS-~Ot$YC9#9N$c(xLh8 z6z=O39_}j4M%_htuv0kERhSLEi}21);k{jjPvUJQoTHNxqiA|^1LjX1PRD%dkpQ8b zme@%SBvz*|-Azy5v+9u?ik{Qm?HPPlJyHXr=M2vBE$L|UYv;4-ks1;`yq*I++Gq5= zm-_BcroV@w-<$j$*0(Tv?oIv%Yc7+1fZhI-#Gd&KUpam15A-JV#~8c|dn%znz*rM8 zo-+s;&qWi4V4{yPbQgUIBM}XOQaO{LRL)A60*l z^n0|rCse>eF4qHZTDiQBcYL3R@g2^ws3Y|KOU#hhgEYRtyQFkt)^MJbfjPLCB^5=9 zv7RGkqK1>0CuQL)p3)1XV)&X7yhtjJ_h`pa^qbaS*kQtYf)Nu3_-|=Xusa}Q|3Y$S zeuAlt9^)vLYDfyix$x->7pl>6&Y(*{LitIf68bsiOiHg0Mj&p%6%HkfB zaS02w)L_6blZr5aH}O8b=)pmTdy$k*^kG~fW#B5`AMlC#Vg3QuQvsN;G>xH!rah(L z<~$;dVHiz76Qj4Y6f7EoZ6Z6l3T(E6H}PE-C_*2vw%XrG`XqgIMA9Ll=ab@-d4wZC zXG;rm9dzOm6*-C6wIIVR%m`<|X!;@E@Y`BCvw^!^fm7j-T*x UvBKF95&WFPD$iAsg;7T0A3ds}y#N3J literal 0 HcmV?d00001 diff --git a/lib/com/muyu/etl/domain/DataValue.java b/lib/com/muyu/etl/domain/DataValue.java deleted file mode 100644 index d65a389..0000000 --- a/lib/com/muyu/etl/domain/DataValue.java +++ /dev/null @@ -1,30 +0,0 @@ -package com.muyu.etl.domain; - -import com.muyu.etl.enums.DataType; -import lombok.AllArgsConstructor; -import lombok.Builder; -import lombok.Data; -import lombok.NoArgsConstructor; - -@Data -@Builder -@AllArgsConstructor -@NoArgsConstructor -public class DataValue { - /** - * 字段名 - */ - private String key; - /** - * 字段类型 - */ - private DataType type; - /** - * 描述 - */ - private String label; - /** - * 值 - */ - private Object value; -} diff --git a/lib/com/muyu/etl/enums/DataType.class b/lib/com/muyu/etl/enums/DataType.class new file mode 100644 index 0000000000000000000000000000000000000000..118ed81a00565ef7dbb683abed59183d2efaef74 GIT binary patch literal 3027 zcmbVOTXz#x6#k~U%p^={I+fBwTPhT6($YWyx%47w6CjvUC7}{faheY4KrWC>iuEoc zUh($kt1rG{k;~F03t#;guH}#L3Elh5w4KygT=pU7%s2b;&A0bHr@uY^=^=nId?TYt z!q!~57%kQoYf-~0M2%9dSdGSYOV2D`F#?d_RpEnQf;LCQALXg8&6Cor(!9#X;q;yro>~JL?$_vVDKpwn;7(F5@$uE z%_=$=@W-dmOr(U(78P63MI8HPVyQEUw1l4X>yiwj2is(Hsp!Si5`4KrxnxkT{&4D& zzMw}7dMO{Bp1ow`tdSsgpijn56}#|^gpI2P2@;EvF6f1tF?~_Ofqs|wWI?Z1M_fSK zs+gtxh&uxZ5Q2qOL@*#BSS{BoIfJ#Ap#9UC1=+1)2vM@N^h(~aY};0st(}=o_o^7? zunKc#!ytkCRUE*xq@UnjmC)NCev(>;a9G9>6(bmx5L#8h{w9Kqt2Mn)P3BAGiZQ8I ziTx(G7|Y*&jtPvbcn(J;G!y%@>wD|fcU%-q5LNquD-l^$I6`o_$laHga(Z=%jWb|5{AS6HqWsd}htOS+ZojSl1${aw)HX8q#a; zR0T6M1j6zxb^NN7$&zK{jf#SEM0(|+MZqidJZI$0qF#`3ftpnK6m@GpI$`GH_8SE{ zb%gs_Q!q!BpVKYFGK+=`YEZj(YnEBy5jPaf6ESHy(vat88t)-&IT_yJ|w^bl*=1aO&tMFj0)p9g4K0@gx%X9R$C1sY3Q?=r( zQOW3(ks7x_g~IDjG>=O;rx#}QipepYK;DvGq=D$Y$OCMD1c~jN>g?YnM76E(mf$4uLFhzaZXCfE`4RnV zox8B=?8DpQ!z8?ecPRzabvqBPb?$B8Y^(4dWqiLOgFS15^fd?)z;%4!(7#Dce8gnv z0rsT^9*%j&ySu(a??CtP5pSoLJ}Gh!2fsyt_k*`@c%<+D`dvH3Sv*3dcHtdH8Cmx0iF^Lm}Ty+HZvCF#2P|JqKUEda9sX(#d*sk=fh`&+JnIFuF*TY9X}5R`4Vxo zN(vufZ%F@{}P(hS$PSebXHkHTRIyes6EYc)laH|Tlm5W z`zvI658V2hf@;S-+6nED7Q2s=ci<7wlvg{Yy`Y^IkSw5#PdlT%q-6yZ6wrCU_OkY> z_L_j21vD#bInB`W0tyMpRJ2Pg;oAgM2>G?5R@SZxv-St5-a#j8Y*XG2h4#%<;f-{> ewBRs8RH;^6p#HBAdXtoEa`gHVUy*GSzWy60<9n+B literal 0 HcmV?d00001 diff --git a/lib/com/muyu/etl/enums/DataType.java b/lib/com/muyu/etl/enums/DataType.java deleted file mode 100644 index aae16d5..0000000 --- a/lib/com/muyu/etl/enums/DataType.java +++ /dev/null @@ -1,73 +0,0 @@ -package com.muyu.etl.enums; - -import java.math.BigDecimal; -import java.util.Date; - -/** - * @Author：zhangzhihao - * @name：DataType - * @Date：2024/8/28 18:38 - * 不准抄代码，添加注释，清楚每一行代码意思 - */ -public enum DataType { - VARCHAR("varchar",String.class,"String"), - BIGINT("bigint", Long.class,"Long"), - INT("int", Integer.class,"Integer"), - DECIMAL("decimal", BigDecimal.class,"BigDecimal"), - DATETIME("datetime", Date.class,"Date"), - TEXT("text", String.class,"String"), - DOUBLE("double", Double.class,"Double"); - - private final String sourceType; - - private final Class targetType; - - private final String javaType; - - public String getSourceType() { - return sourceType; - } - - public Class getTargetType() { - return targetType; - } - - public String getJavaType() { - return javaType; - } - - - public static Class convertType(String type){ - for (DataType dataType : DataType.values()) { - if (dataType.sourceType.equalsIgnoreCase(type)){ - return dataType.targetType; - } - } - return String.class; - } - - public static DataType findBySqlType(String sqlType){ - for (DataType dataType : DataType.values()) { - if (dataType.getSourceType().equalsIgnoreCase(sqlType)){ - return dataType; - } - } - return VARCHAR; - } - - public static String convertTypeString(String type){ - - for (DataType dataType : DataType.values()) { - if (dataType.sourceType.equalsIgnoreCase(type)){ - return dataType.javaType; - } - } - return "String"; - } - - DataType(String sourceType, Class targetType, String javaType) { - this.sourceType = sourceType; - this.targetType = targetType; - this.javaType = javaType; - } -} diff --git a/lib/com/muyu/etl/scope/TaskScopeBasic.class b/lib/com/muyu/etl/scope/TaskScopeBasic.class new file mode 100644 index 0000000000000000000000000000000000000000..55d560599c64d60b69ed0288ea3b4cda988476e3 GIT binary patch literal 973 zcma)*O>fgc5Qg7L(rn_IHvI^N^3gUat&>Xl#wBSFRN@rDAyFib8)r#e92@zg68{RQ z)Jm;{IP;?rv$mxKfkH34-tjZ<%#L6G{B`>sz$s1)6i^f>nOH%YP`i+q()Of3vEPj@ zloJ!mUDtQxGeXg74Xdc2Dqxscg-JMYf|)%_J}0({Jv(xOPs$$1=wn|$y_S*d5DYJH zq?bkrJH2^@=||p9I&?v>`KC}b{Fr@_*B4i zwkBzN^18eoP#WsoK_fCid;s localScope = new ThreadLocal<>(); - - public static void set(final TaskScopeConfig handler) { - localScope.set(handler); - } - - public static TaskScopeConfig get() { - return localScope.get(); - } - - public static void remove(){ - localScope.remove(); - } -} diff --git a/lib/com/muyu/etl/scope/TaskScopeConfig.class b/lib/com/muyu/etl/scope/TaskScopeConfig.class new file mode 100644 index 0000000000000000000000000000000000000000..00e19413cf1d077015b73f078fc7929975142eb5 GIT binary patch literal 3283 zcmbtWZBr9h6n<{9n+;)sh=4?_Ma2RM7;A0S1ki$5v4Ag7tlAfsWFSBft5vh&X6LO+*(^@mPN8g7)-Ia&>t;TIINCHMbhJYk7}@Jafv8a| z3iOWnzHFnimc6>VZWi49=xvGGsiO-?0nMt-Zfv>_xnsnC(ye1ZdIXeB$F>D}Mn>Pn z(9kDv?%l}`wU9Agx9p->O`sS3I#M_&5Sy?nmOJJ7Uy<}4((xV+^MRyoj!ATf{4cpx zl0#l17}Rk@k`gZ%mD&4s!O5bw-&J3Ce!x+&psv|8yk{+`mn&_Vu zFzlK{9n&$66SN9YL&Y3x(6hI44&$Vb4{?fNmyB9zhN|!~pX;W+PV4v>p9mb-Fv?Or z1;f2*xiqTOT%+RF1g?ea8Dz3|HH8ZqqM={vp3nR()9tOtPBqj`S_6CQ@5% zTXs8oFQ9vr1SSKUkch^EvhGDg5<)lvs^gZ-Dyt?L9&!V%>)vW}+TDB@^0t55CbX(v zyD_&gOYAvHziQU%HYwJcNS)p&WFL1OKPiFp|4)@nD6! zqu@GK9(>=2!w(F7(91@pXq&a6dB-W&H}fF{1@#QA?AW;caMRqy{7%R|&|tVH1Be;J zwwEl|%*R1C(k*O^_@$l{V}o+ktjMGo70~A@6|*{H8?~BAlKNWq2FI@kOW^n$zHwBaCMxImvbPhbk?Ig`&X;8WrVq9g;nS#J&`CEgY~9zjzcLy112eH0QkMhh?| ziKu(yWPmus6%~=r3xbX=qK8)*;;8^K?nCbTk!z6<)R7QWJb;?@Y%VeM&v2RhCC;E1 zJ`jI_-doRbK;noHPCI9OV+Gb(-esUFy$-ax+#hnO1}=qsG3~Nhv~KR(b@Lpq1e(VkLXV&7xv<0)keA2cj7Ih7`vTr8zZ zo7hWqKSoDNO~o2UN~=`-j4%5!G&3$?!4qFEmas@cMp(OxxXQICW1qq`juck^2(ELa z(s}?lIEq2aY>?k_@xRfjA@T}+8ix5F7q8Io58L>1m7g>L1Lt^`6;WmCGQ6<-!Ubt) zLF#ys&Loli#0X&i7~1$2vUlZrCa1^;DJ6IkmlX2R zq1~xD?V|?NL~(|cEYqjTv-b;*BJ9+YSYbR-9K!+J7&6vSFtf zihPz#Kf{^y3&h#AXP+V@W&ecInN7H<8s~|`x)osEC03MJ2V1bb9!rnyK<)G_J3Q1b zba)Ln=z9awJ T nextTaskNode(){ - return (T) taskNodeQueue.poll(); - } - -}