From 3b5a1fad2c686d0675f29dd25fc26cb365260a08 Mon Sep 17 00:00:00 2001 From: llllon Date: Mon, 20 Oct 2025 14:46:02 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=90=8C=E6=AD=A5=E5=BA=94=E6=94=B6?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E4=BF=AE=E6=94=B9=E4=B8=BA=E6=AF=8F=E6=AC=A1?= =?UTF-8?q?=E6=9B=B4=E6=96=B0=E5=8E=BB=E5=B9=B4=E5=90=8C=E6=9C=9F=E4=B8=8A?= =?UTF-8?q?=E4=B8=80=E5=A4=A9=E7=9A=84=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/SaleDataSyncServiceImpl.class | Bin 42466 -> 41794 bytes .../compileJava/previous-compilation-data.bin | Bin 9396367 -> 9396367 bytes .../service/impl/SaleDataSyncServiceImpl.java | 273 +++++++++++------- 3 files changed, 163 insertions(+), 110 deletions(-) diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.class b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.class index 9ece925b07f0cc04dff0ca8ed4374792fd03587c..656c031387594c2f369ef7193552fb04fe4eb075 100644 GIT binary patch delta 12598 zcma)i34ByV@_$tyGo8sJ$0U>F;C5G z>}B2{o9m-duGE8GFgR!y-=}A#i|rrq}a8JU8mS$#i|us z;$=&Hkk5uGcD<&%L9rWs5XXXw-K5yfiY@c8Ti9~NRz$Lu>{i8AMM58To0r|Lzjr7W zT&!~S9} zVEZ)Mujf^x$9%%ep7g<=Sgm4D>3p4!)w2d4?qdfOJE%(z>4`k8*fWY9_Jd$Y^oU0_ zmydbb^NPLTg9YqG#a`0i1&Y1w#a%uKj%Ba-L9!Em@URn#y{6dfdeAq#>`fosz=rAM zq+)L=_O@d0DE6+Gy{FjwihZEiUlsdMvA-$ykzyY!_IEwlRf_#XPv;ZGKGkhM^MjW) zDfYRZ-WQ6UQtY3Ked!0K$BYQFBZ_^a*tdT0Y4|V2zV|~UJK|$Mupbrs$xre{gl*Uf zUGj@!r~MGcPI%cF#m@R*w`TJ>-FGu>76%{f<)}FGa!!!sfD2tN755Mk_bRS@Jc9d3 z9C)N3qC@=WQN({9?d37F1RkrnpO(Pmv{;YTHSvlEv_KA1Ji*5kc@nXR+d4_s*%Yed zsfwp5o~{eq>LkO4?_;@uU$Q1OfWbdU@Sj{3o`%X|81n~o^nTd%87Cw=@7&zk(S2`3cquXvH- z0~8eOQONYDSoly;}tJee1hUM z(j>(v`}ie%icY5Lqxf9KuT=ah zI&OTP;#VtPq4<0sU%;!sF&}lsg_*?{-x&O2rh7M&7L+FAwFL7kEjB# z_yVD)(>A6@&A5a~7>u4*R#`Qryli1f#mwTes&a(n-<6D>Td}BeY(;r-Sv7+Hca^18 z3lY+OSJ*^8L%tMF_)eoM(sGkS z4Z_($^D7Z}#r*3K0?w<06Qg`H%c{rD8a=7p4k$}20)FwPZ8 zJ%Uj)7A;&@UQwmjZ6+GossN#dHKk=&hgKgK?rPk^@@wbLUsQQMPh2|FRl*;T{*D>B zhVQMqGE0qWX;`+f?CMG{-|sx0oLbW@`Car}j#nVWIcUfEEMCK(uy8z%NC3-ubMM|W@WU8*T?V%`W%R1y)1r^AM*02E&dEY?B&l| z{5gIEq0NA*U@DQEPj+9v-tD;1&hB(Bk`B`%QW_RG}$E;RST;v{tCCL zF2>Z&E325@l@>a;Vz$MP^Ov2b)Ltu){9FE=m;cM+-}8T4{0IJH41bHb|5FSrwD`~b zKNkOmpQeIe>Hisv1^8KupX1F4RnFneET>CmX);-%9D$Z#f?GlesS^*eM|hpBnQi&y z^gWbW)TNQX=@rTn5yEGQNd6w3pQeqEH?4WBvBCMQuHoB*_bk0Z^PCoO98WkM+jWbx zlxSm#C=qRm7!hj;zld`x+6~}--r($OcX5;u@k#`Ug1@6gf)kU~hbM|8XG~Tqw?%Tz z)meF%(5P3;yY=g4i4^{x5~;ewH0ROml#KWAeFT{?a7=NA{`T*eQG_5e`eqanw4R=5{NQFDIz> z?5xCignrKSoL+%^np+2pB{Oa@#)v5QSZqlB_`|dCC;%9&#NhP!o*a5 z%yBx7>~N{Yq`1rymy0Vb<`walm?mib5mQPAjvqaC%!FY|OxI1z9B-%j8GjNpXd6cj zn$|7!=^pxA=oK?9Q7&dVn>rl~&Q@ZMZZcPiE0wrPi|{;4T+Lra$ZtG&Q{(PCnr_?u z#g5fYd)GGZdgSwamVbU*ebZyNx90d~2M#pezC(!$gh90NjjQfIwPjc1od+80pJ-gS zy6N8SpVi&|S=~+4JdYMmU4$BcdvJB*s_B~cvxb#RZ)m!2N2pwh`3ObSQPZZ!8+UGN z-BIHq=MQ=b(VgE3LTYHnPDQ>QTtK^U4gFuJM5SIV*(~30_K_zZd;%0=LCNt*$&w&u5Xr_8P2#GG;+GSKxn9+3igT(ZHx~8CM z)w;&posuqbnIYbVS{iN>|3j3aPP#eQcS&mBn(90PuUKY@Tf}lptPm@mLtP3YZ?(iK zt&wgMxz4#RDe6+3YT;!#)yeESS=^3rp>s`Kj`LBQC}(fir@VKF)d=nLoR53i&dLj7 za81qK7hEmzPDd70de)L_D%RE9Sa2Bmdashp5CYgDsxqHW&PYV|zIyF=J z-p}wZ=XC#Eu@NEN8B&y9Gq`BKXq!@8GOA=kNyd=zV@GFT#^hlo<4fqC-MgB`t-U#Q!;3Qv!DI}Mo(kUCAiNk4}1ZT@=JFQ>Fgt60#2Tmx-E9#t)JB9vf zGgDlg+W{e0&nBj@P*>BOibBZwcC_sjkBP;8&NXA=aJ1=a>zEYE9~zTV^Ya*i1GZS= z9&w+=ipe8jgUK+lK{^@8dU?e*E!W#EHh}acE7AmgHR_`Ydh4Vo>*e$r*8_LdTr=)o z#GOvm`0-;e1`i}_mxQkO$=ZmT?!L3!F~Lr0sfzf?zV4yDta zz2g&dr&E~+kkWQoMyX}6#6RH-$|26ga_V;cP;6 z&=Ke0Ttd5`KVFGfK?KZzWjK$9^uT<$7O%z%@WN!c6X)YXkkrFJ-61rpq*`(>;1jIE zMZn-9sKsmXI^ejNC@&)VP#@L0kD%#fiQ7pfR<|@=+S2rTYI*}Ty$-x*Ak7QxEM$4X z^5TunFbX2Pu-pp)Dh`!-A=V3Vx&&_oXog(y{SOq*@QLY3M0c9_5~ML0-b8#NZ%gyE zCOGjq&8I<=YYd2dCF; zn?@IL5(5TsA#8>bxRFLlfR`Z&HxWvN%i%sF5COOVUdOvhLgR5XOu@~%7B8a~TWAhR z{3PwuJ%rlw(_tiXNtm`$iwrRaJa{kO2W|K!cow%&+jLi9q*?bWhU!` zI|!w+j;uTGqz==>WKf~T(s8>^lMOBCb9az*PgHmiImsO)RUUT-NfUGMiO?8$L`Xi9PepIy+*C;RBtm3pIDAA@Z)55|)NN+943?VH7#9~5P1h_$u&^`%`f+Q{L^&y~YEdw5d^wxR} z(z2oqGSUFta~VEL)AE7GGX?h$ii8NyB>W2@3oK75K8AZC3ZgyZ@NukxXj)VWt^P@p z)*MeE))I<^JWo%2idy&~nD6P1bp+##)R01O_qD!dU+Y`;m5{r0gxpPPfHZe&>IsFm zMxzk(3AtQ500DPtbo}+HX0JnTGdM5K%oPW{xX(GhE!~MNcQbvJrMx+5JLb$n3t^x?eAhr9UKh&T%^pf8 z{hQe-nqsx(2El$Op^*DXQ+@40UEYRBr6Y+WKP?8LdFk9t;Oz4L%P?;CHLRWmz2tg6F z#g}NOv{H^YGN%>r;+6?6Hi|`0aIsNOBy)tcZXlT>q;-QZQ;Y!iGenmWLjp75Z z9h*Cn7!iAA);P@wt**T^j-DAK(TX->b7%{GGq&!%d&}6}Lt~rXNg-cBT~iQI-=z$X zmtT35x*mSje6#4wXbFp<2fj)ZBH4x-Gf4u3^d$8XYVb8$DuWy{6R(rj}19Tvm_1}MTB%`Gy3zVc|Ejs=v;A~SFCO)zlsbQuO`ddh%2x-|OmJ-q@p3_Dp8A~8&{sH_5Kc>~@ zz|Z)1qVqr={9u%;cL-_bukatlDn&Z{6n>)R!>~XLvhMD0Sg#pshNz|?Lfw7Z(p@zv z&KsOL^M|->`Ha>{cSEzzXXa00w9bTu-|BT@44sS}bT&T6FUZ_HN@nF0%{2;ELO1*; zAq&ouX5NTjk_k#_L7iJruNG7sMo@+VzoNF0@EkmVUsGEPPQYgThEN+)MG>L?f_Nod zNNoL<2rtG__#OU>glGyDk7QBL*9J z`4IwVA;t?S##Na?E{k?m78q|umpK<#6;Zmrsyn4et2$EpZB_U4-H~5tBTnP5W+Qqp zI!+r=<5|qn>_j%H)v?go9L^-11Ucq#+E@%djnpKvXectZ$t)QzGD;!l}ak> zMN8JIB#ki`Wm?#{2i`FLO+2yiA)`P7@DW)}ZHuDd8~UCh6dlAUa{kUzH!+w<-pDx; zhFDC-8RiiCF%74iLmbDJx$a~XtYK}9SVzDnmSC))54N*5#!ZTZhnX<`jRkucU^DgH zhMo=bj60=ZFq>x_P)RR0)5!r1YWeTU78?(gM4Z*MY*dZwfhMwhjo%s4(EW)%w2tbQ zb<~qx40T81@AkGt9~kN_*a`e$*Rvn_o+ChoJxlG3{@(E%15y92+Bvc$ zr}udcw2)}8we=tQwDcF}rPB&~=?~x>L{iSlTpGwGvG@;6OKv7E{r6#}F3szC-Z0uB zW*}P6tCjD|$UN$>2=zU!rhaLeBw#%NW<&^vX0N zyurC7C?JQ0MU0SE&!h?nX&;VMHX-f8k&Pv!uLUGVgtQz>;IhQHW*+d$fh>{A6!>I+ zRt<6P?5k;_ zp^ocGkx^4>S>4i-Bwy<#x?Xl_hLI5M{A+y&=iTKoaW|fYBBPj6euXh-NXSSNonC$c zrJYt}QaXCYg=r*5q`9<|q7il@uUa&zhKNDr z5_BRdqX?XqGJrN;(9vs8KHGE2ZbGIz>Y*^+crN08FlcF!sG+MraT3_FvU);r%N~#rrN2bJP@{E ztVS^ihhafs+5t!*y5|bh?X+4rT~F+W!nStX5GlN`ks*yM%&;^3zt+O__rPI7XAG(( z6g+F-9)jl#+DWL{pv`th9D;#sG(-cJQGKRCi)~Q{N4G$koo0(#s4C2~GwYBQwzJ#S zAuq_%A5oaCKe8alPLD%RAj{5fAdi@OeQ~lbQNchKF(aIfu(QL^7szR;urp|gj9OTz zD|a_%*(r8G&zpjh~W9#8*r`zft_6E-)&tgc2$)44owe%G@opkb4*i;i-eG3NHhz(+`xR27E!VwRP zyTo3xQPhgf;*i)Pj#8lJ6{a*^0CZxJH*V=dO}Xz;9e7n}|QUN;V14Krp0bZ8||A zEt^bEa7fDrxZl;XHdn5eO=4xPmW^lSu9gk3Q?8ax;HO+In@-XmQnE?>c~{BW{54m} zCi5Cs$tDK*dRNQF^SfLv8-VY5H=|MG;1n-38r2UoL^4YubruaT^BSXDW5kjc-TI!p z&P@5SyUup9$z5lb{Mt1p+42W>nK^QiSti}pGh`|JWQI$ZBcRy~mnL@7B|wK}Vnr=J z!%|5b`^78xXO>1NPMoArg1$k;iw|)NOD7Z%jku0{61u;O@9`FvK`2rDg4eT5vRz3s z5wBqFsLYn_u#{zy;!P&4JR-=l38r|KxL2T9aVwK7hqZ@jaVMT*xzsquv)*-k$Z&WL zh7AWH*KiPW4F@6Da1e402O-yRc<(KF&jVr0;o0t5jv=0F zUBfZiQ{KvOXjdq-A=MD$u8q{1UK=f~n%w))2-<{%`p_mM)CZZ6Hrj?T4_wepA;6Fg zS+qX(f3+cBtuOdrY)H|DKG}b4L&65+7l>$vea^TQorjWV=moMS+A(VFHc_bw{<-nL zbI{SXTX^FcI6;-CA&PF~)MGPrf><(v9oti1CNA&`#D(n>ywa7vdNylXNhbR)}=vK!XKVRt*;sO6|QywIuGm>qdhsH!v$ zd+59>2<5Y#z8g~`d+Ll)hP|BcHZBVq7&3wW@pW(onWI=+YEzbMC);)%_9kPL;;Y3% zZHwsJr!dVXlpCGZ3FhDzRBKbo0n<&?Ps?QWQNsn*tTW)mzo)G0lRa4 zumSs1t9Eu)i)M!z=dbBE;sz}GJ#9}~WNU%}zb8oOoZo;0&o8w-&y(5p)I!lcj(2k) z*v|H7V?0Px?S>e;b>6IFu-&d6=5jEZVm(vJ*je>tFklM=>?pgPHsSS9!J#ml?2RrF zR5FFz>7{P5o&7v?v9nF1dmy``oo#zk>1Az7|`oGk+s?VTh2`s-RU58MnO8i9)@@QBYLLYx9i{FC&@ zmyj&Jf*kP;6p*REAi?gs& zoP#?=Gi;U!j|L@!V+3B79Nv+U@QG{#KgcLJO?nPwEX6YY7$@T~Q3f!Z^jsI2g#BbP zPL(M%;Z&M#TU;VD@K%|P>tqgYp@`>B*#Y;;j#x)};*ji&&&hmziTu?!ZwnR>5H_54NwY-9D zm1XQ zaw+dGujfN$kdKu&^U3m-AfGOm^SSa?UL|kiOXcl+jaF`J7MqVp7@#FGt z{d%CJ|L4Ga7dP;pfc@OSdm@XX2!sx((=XscC`eF0xP%IyC8VS5sq7m! zP@cvE;XpZstBQ@~p!hfTF_t5lZG~IhwkIi|X4>*c=tq7XX^?jO?H2S?7>O0YjfKn> zPtot+f}O|)=I|c4i*;uCbVKWpTUi%soXm&f2G*5qWeOjQx3dcfrSi$RjCCWF#;0R7 z#r)}MfX~GR>_S3qc@>tkiwI@#rSyvf9k0lw@bd|GGMjKP>p_dl68AzscM2Z`UDIr% zS46r|`$Yb$iPZ;i9baai0TOTvuQpE&iMW$5Fi#ChJe}e^=AA+&{ua|GS$6}#gxr`u zAvdN^$c^a}(q=uVFMs*rm_8vlrccO?=@ZhP0L48CxiNh@Ty9KX=7wYXbO23EUv{SJ zl9?7*GBX_Am+9f?K3$mH=)P1~8w`c_rF6sl`4U=1_s5e977`xv$5}`^>Pb36dripQ z&3gJZUWmO7E$pQ-msbstWG26sJcdvte>3DXQy`LJ7S2Q4+J)lp$G4S)Kw$gA5O`yI zB3(F|;cm!w-YCxw7uq=m<|>)zW#%s&389xX{bUdbWHi%l{ro1K|4WmQ3jol?>T$++ z16`ZJa>};14-b}Tf%YBJFct<`J1QXpD-`8BltAIRwb8|~Rvw9z426DpLz+6+KyMz6-E*}4bP zS`BfgRWqw)2zq8Vw1-&>E0+I4ll_$Ki;29Lb>$N7X<{xNNj3 ztHCkhg0XJFxP8)Mh*@WfKf~kUhk9yXem@8qXf3+Gi=E@|;PJoAgzk z23e!Yd}Y$FP5PZl|83HrP5K{`{u&yJTfB{nx`n#sJ=}Z&)ljFrmr47Yw4X@_nY7rX zSD18(Nh_C{&kZKM(WJ{vx;(T7ertF&d{uZg{5E&k+YRNNCS7OJ^(Nh9(#X!GMMZq-B(mrvyS6ooc7kR65;GZ<2I|5-`(2XVDrZuU2KN>|T1a z1AD1coz~lFgQTQT`KwtWRoj$12^@=>CtnjeroKp9rK+(x(E+F}l+Ugzi?Bd)A5L-R%VCrQ=n8ud?ZLk~TT$KDysQyV3)S!#Q!$ z=T)DF?DPc(Or$SLdRXO;IOtJ&%t7|imn3~zmAs-9IWFm|lD_5yPTx>Ho(u#xebY|= zCh1!asHJa9`i@HHN&0s?dC~#iq4bm!1bx>DHu|ol?@Rhm)#(Rz`k@0B(P4^wB>@(sN3kFC_g^wf(OX?DT6%zftOa zE9rNV{!h~Hogh`80bcrsq(4devlASO{Z-QQP6(uLIOqj>QPN9J^e?O!MBl{{MkJ$7 z2&V7a8JA2rU?b$aR@9%xpjs55-VApa>!wl#XDF6OGFc~Bt?={HU+=2RLR;& zmZl2R70Ix(Ob5J4cOYR|0Z6hH*Iu%m0G7)-s7yzP7ipeiJ4x2r!Md=nc9t($H_5s? zA(W1ntU$7BBaonM~$nmBG)=0oPO=ZNqASXevqQT`$>K$;L^BJ>4ML zjSe<}RVp%3kx7bFNmlKIC^kj1sgg~TY`SDONj5{WnUc+ttVXh0$!?acPO^GjZmdDF z*^O`Br;e=Q=#6i2TI}}+V z*_|rIh24eSt;kA6RyiS#t&wc4%G{&Ky-4Um$xJ82GhE=c4A*uHdqA=WC0p-=1hxJW zy^1E$@lHr)n}P+D3Ym2mLl1Tv_~IjPfPZU zWVdLwyHM1I~7FRY@n`KeaUguTCqbq03t|lN=;e4!1Ag-!ll`@IQvxwpzLZtZ zYY4hZqPaJ!>r9tlqkfi*@&?o+)?cbx=|)$5w)@n`!><2QRW_?;F6vpOw6e76VZId* zV?HJ0ZFY9l&W@RLqB4UFe^+RvN^@hB$J<6}|8P|L$04}7*oN5+`jV^XSLG1zhPj=^4KuMr6CTT|0e-%wXsJEXc{YE4yrh>g7-%1&VNMkwuV zu#@afJNui#-ePat8MgX6J4GPqN-skyYYp}f_O8L+WA7X6pV$-ofPHA@#74z@#6H9x zbln-1v!--F<)_V>VzATreL`$^*T2}ucJ^Q#2kZx8Ei8F8P><|W7zu*)3moEV&PW^m3$DElnL#%-arufgqH8a#kIupkis z83v8vK?V=zAp{!Cf}|Al@x=1zP=n_2FoQd}%i!VMtw;pggGZX~qy#nz({4#cxj(Wq zb{=JL505r@3_D98tmXdQEvuesK4^Zn|KK-=9$L6aSsDlNcXG#cHYUL>AbV~eroT4 zE|PauxqLIRT?f+59M*15&}s57gLlVS;XQbPd8*y@>>Bo~*)c7#*O%nKD5$auVad*W z8oZGAGI$a1jkfO-N=pphm%V22YnA!iczJnsgTaeQmAN`C2A$xHnxGQ%*|fQN{S4lp z4>0&ZKFHvMd8xsNsO&Yoi~#N5AIVD(7d$hqT_;m&!!>>o*SD(l75$2)vlz?%#MEH0D3FZ^w38p=xFS)@Slrc2qMpSwN z0n%RbN&T_#%Vfs)(0;j4H8@CBIEcx}8AZ=6!pbS8O@Aep~bE=bI1g zZC<;wWy9u-g^O|)F3SA;p{32s9zS=-8nbu%IIqDM^Cbpf$`>KpHZNPzvVYm*a8dij&!0D2Hg0b57ZB)SzK|2;^?}F2MJ*e*esgGL%L7g4 z9@u+!<&x%y_bRbyaspjiHauwwU$Og-D*SmfJ6~_`hxo$=-@rE#Xg8^5W^U!&`r69M z`rO&|)pfa*wYBxR6V0;R*t|^!->lGS3(rR=sjr?@RWh@3+KfJvCe_TI)lfEj=EUkc zgH)0U2AN23H58h|Y`Ny^xoKpp`EBl3>=FK``ALTyvaK<=<4i%eo40hWci>@bDc?b$ zdxja)F|IKpe=}i^^CuejcUwS7hMCkYy>U{(Y(k!F{NS1`lssiF=#|cQ5{NgC_lj?P zsn;IPqcR3%n!}?aO9OR;qc?pFae}5)`vL$fX38oqDJ>aUlGty=&>@K=v0^~Uh>}FL zsuBw^tDsLWFO?&Zfzg|b3^X_QjBp3fou=ZkD?v$A#z56!R8Z}V+4cVJ(#&3^k$;gV5lCs32f`Z~cXd`6}izhHr3%a#5%$zbHf)?S>2e?ELwyo12 z4wlB4@q@y#hp55vjh~h}N$=eTf0pkxXeq`mbTDqNbdVwgX>U7!POZKsgAPE5r~Orh zV#QsnD)dpLi1s$SmUSij8*eJxK==XlO0#BYJG0}kEN=zaAX>#wcP-d*>;yZRL1rSiAF{|SQiI$!=tXMD%@6>S zU@@sfC2UXwb4WdD06SE`YBHP51A!90z&=zLikpvLF=m1@WC2+S6uLkYxrHnOMsCIL zU9i4ShF8fb)Ix5vgv=-2)~2_&HeHNOmtfPmV7~xycAys_#SVs@EHz2FD`=@5!tCI( zgIkp(mAkLKs>BX4K_#a*5di1WB+F1dCCkx77&a;cH_k6VrcBgx zRHHW0P6$I|4<>h#yC8&QLn65w%@K-5ebzs87KywJY~&I0Cdj3kE6giUIEhASeTaRIB~F*``qdz-WKfdM2xmNi4`ZUPU84fve(xKd5Mo9Pmm{Z zh^P2KG@N$=c*v)`2U>0dMB5@E(AOP#g3l*Uq5hG?E(*y`{2ET;MH+b;)pC=35lo)J zvIyHi%&GMfj*IU`zcV1GrWSn$IpqRWbIJvn=62ycam9JbZe(#0VMXNwHqEK2wQElK ziqxF;24J>v=xJlo8Em#OWDjzI5MUck8j&-=u$ALTpMzisu?-_lpc|F`ZuZLUb6*+6>kh3P~2*g=aa~L__ z)F{qpeB>;v9R;^FG+g;=LDRP({W6%xCZ_XacCyd>YGR3x$)7aH$1I(6lb=a5Jyn^$ zOuwqBK4wqVKp%6ts?f*uuI`ztWZ7XT{>AN3t^5dUdB21U8&6?s0hn8=`+F5!MkvdZ z7a)eb2$|$CvhN&Gwp|&0SQJPV7vk=`kg9LEuzLoS&t$la$^{u5N z(B6Qe@y=D97q#tgo%%A0zIIxT9`raI!aV3o{(%aipF^VtGh~ocN~$3=l6P^a6x!i# z@g5>DLxsHLeKiE=0Sm}Ku}r{Vm`XmtG8;_Ab^oDSL9O%RD>>?OJT#+}0l}Beyy;nC zKIs1l-5yVTdgwEz_eA}kn4XfVhVI)$vvt3qhs1ycV?{iAYApSBdRMhmq|KPC$FmyO z-e{OiK0&WB;3)1J3LFd=1S`mY$QhjCe0W3yivv9`)^9ZAKK1z&a>~2Vq{yk&&v2rm z^sa!H0K`o`Bh5J4cJMQ4!Fo2xfFCr_+WR3&|CfA@rjm%~=g3**AKC=Um6f9d1W4tz7$7u6rw2?B}48aPmKF8wkhXQSv>uHQ-Hn zkoW*Lr&r~e+0RJTmas@QoZzXUC|u>G$D79l$}vVMAkP? zlC~q4aJGE`j`kP*4GpaQb3)@30* zSJx?OY1`1`GU5e_(-YCT{v=Mso;i%@iAY6+9SZIB+KeKjp`Biv9#Rb5w9`b=5Gc}L zqiHmPo7xIuXa> zNU1{7w!tXCWhjH-zxZq(9qlsTn&&dww!uPoE=H&L*JYTU!g&$CIYyzQy7(;ULp|u7;qU`{g+`+a zPWY1jjm97%hrvnSpT;VO7NJ(OX%}(YW4$%#9Uuny{R+7?*a#pw0B+G)uSW-XLQ|g2DVEt{Yr@8qRS$w#McKm!-WI74-=|jNpY$v8A`QCAvET`^Lq^uB8{D$PS1; zF~33C1@tR~o1SYsBAvN5iK9aontkqRpQKMyzIy0sM0<9O-zk-Anhz}L9*iEQBw01g ze=Ui3;mx6PB7mSATuvz%@(pbaUb>ol_keJb^aJ=V3!V^16Uo4TnFV24 zzRM%rF1Pa_X%A2k?g`%y+w$GIVUFzuNF2l5uKf^IK8CxUIu&lWN)JFsW(h5b@I>$? zl3NhziNFpzXgm%0e}84TieizJmIa$~Q@JecWHknD-~BsW1^ z#g5DO?uUFFNxbv9{m^s(_Hn4tL+I*>J^<4g?0`sF5T=Xr&DD1mc~;w`EfC_N!j@o5 z#+0ke1KJ5zHn!Zggm?$>^>_)rotN>Qc=6oGNAM$j6n~YE=3n#c`A>Wtzr=444n9GI z@k$ZRCyEqaCDM7dXwN5$F39)bQ^a6CU5w>3MHQbVYIu!U&1=OvezVxb>%?QcUOdAa zL=&Ga4)ZzUH9l9o&F6`a`Fzph#seGxe zJ6~oSh-n$WLq+Sf9~6+!Es%=9mF@$nNDLBuAQeR}SRm!0%mS%sveW`8H*;Db~c(`pN)-1MAg48OPC7gkUFcB%?4k!J{2NLI%(@lo!rlC4Fc*mbv*)#7Q%-MFhV@95fTTNc?HT zB|O%7Qy@x&!Ot|Cwnt=&hOaT8!PBuwfo7VET#V=eZ_y4YCRU7vr)ftlixX9_4OLwT z@uCLS>j)vi7G#|e!f=`%ql32j)+a>6Ee6RyK>N#hQ5IruU6N@=tquGC zqc39cnzi}qSA(h#UUe*>U>DD{ka`&d_DGbOZ6020OS`(h-qe4EkYB*~4Tkk5ze2!e z_z{w@dRAB3h1l^Qo{ACDX&3+Bt_s*ykxDQWP&a8xPVHqpdxoi&Y1m31rhf$&h92?R z7%t%BrHV%Zg2OSG%E3+Vv>8(|D}r>@qQb7pE_q3=_(&7n%|kRfxT5mV^|+^`+bYO`$;=Qbj0(t z{AhPH-$G~VkG?Gi5g!3R#^Y(-X<|LGdNYXg#I|k>h~AzUwIL)RmTD%^BRvV8#Dku9~Pc=-=i$?&DgP8NM#fo9VH6+y}`3^?e6~dfMjo z_y&41^-iQSgFIkc-MBU8kSXG2ytbVxj;hq!DhpsW0AB};-qcS5&j|B#XlnZ`DyY3{}(yNKPIp9 zPslsGnS97w@EY_SJ~4kmzUN;N?`8fS4ddVAv-l4*hyP4_@bh#qzd%Q0C^}96ohmq8 zAn+%VB9N{WA@pJ4q>l?X-6JCC%OZ-N5;63Qh^1ePIC@^hGa?e0TO_h5k;Gy|GK&|f zEJb9n43Wt?h-}tXVvazBon6tY#K7kftZWlf@( zy(s#z6Jj7cB?ht6VhH;}3}qKYITvCy4-pkSN{r#j;(FczgOCz2j+coW_;un&3{oaw zAX15e#w5N3gOjyl3STd#@khmU{d}lpExe= z7axfSbjb1~6#w%9;!zsWUvFN~%S!xBs0De(I4=VN&kp4PfyCz-sgm7DM9L_9Fs z9XrVuqwoi9J#bfV&-&9oI&z3%<@l3Q6_muXu{4JkAQ#7`sB3=Y;u#*!Xit=!z~<8s zT8LaCTTZDCRFb@G75Pm^D#@&g{9Q*XDeOgZLPsj8>;!ocBb5~Vq1-9*oDNUY*lDs; zhbQUy7sA`rd!06DY^eQVniNW=B(7NQ0hrcLDK%|6M@5=YJOvr*vFo zh>!40rk`NI5O4cm2*jKI7XooiM@aZWAof`=1l|m>*Lotz5xd&F5RAYu)aQbS(F=S| zb{L)PlzwbM&hm-Fkj;H2KhkP)EVJx)1fsO^_v0be_Zsjbw7ZNKn0WJn0gcOUo}3ux zyVU<`V!SzLgY`(Tbwi!6bo|ChJKkyFJ!H1oaYK?FkEr?;Vf;o~u zru-YPdZ_^aD@CY7y(Ih2(2$1?f)O9svz#9_LGo^7+r0DgT?$7qh}Bi}kpQqczDBF& z=C&<~`jJDw3G-*#)D7{~)z^~<o#pTw`y+^bdpt_d1`r#d~`roEl^!+RK|dVl&SBhUKd$mttbHCKlr)g0gEuj(Gq zxw4#p)_wU^?fu>3L;uz7|HAO_=2gx8-Q$l1tmehmyqUYUxUb9szRzBnuRomw{LO(S z;r}oP(AEf7<^X@ZaMd7ubMPld#Al@|>ezjAh$qV-t-mptq%O7aPmy!!elnyH#C}rd zB12td*a0$}!G1EL5lZ}J<+`kqjPw_bvI@MT)z1^~jRYzFF9JwY5V_i^C5NX5d=a2! zSVrkkG8fZm>@y5s6Xw_g$UemT{k=VW58sE;kcVD}V!Gr1?l1=1Tu;Z+ahiLYK0|j| z+#ZX&o;KoFd~2g8s8=Qb(3$r%{YujxH2qQ2Uo`zq)60r7(3JVQV&TkfaXoxuS)rBh zg&#+JmuR|7)8(43*7QE#7}!Jp(Xfa8qhTAYZa3K-g0{v-AG}$5|wz diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/tmp/compileJava/previous-compilation-data.bin b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/tmp/compileJava/previous-compilation-data.bin index 7d3193675259666903128576be1476616bb8c059..05ae81e9ab39e5fde3d8a0b626d0ce5c5c5810d5 100644 GIT binary patch delta 625 zcmWl~*-{Mv007YGYD3GtSu5N^DO5;Gr9=`^6e`+8X+aB0M9Y#QNBciKYF_xHvVj`=WnGnx6aiht$&@42@Y+3FZkP3`K^CGtD-M7 z8H$7hi{U^F|KCO|am15ABHP))PLfC_g;ausNMjef*~4D;v7dA@$m9SAIYgK&vN_BV zj*>$z$H*g}+IZ7$xJmpkS$pxyY<{~v*;xe^dp^mH6bB*iV zpn;n-(!?!p(@YC@xXV3SX``L{JfMS4y6C2dhxGD@$Mn(969yP$h+&@cjOUCn${6Fk u;3cn^V3OBN@rJid^N#n-Fv}eCMEJl0A6euRpIKs=6;@gM84g58yZ!<944ixb delta 625 zcmWl~Ni&uK007|ep#||pBB>XV7A37nMJP*=R$3%m+GJ^!3SUJkUo*|PIl7qX(9}$) z4*CtQen5wA{eT{aXP)Tdued0mBjM(`*&iLh=Tq92mNUo8dpo~<8I1{lZ3_O)&;I#7 zwNUc6u4Sw`5`-p$Pz)=_5=T6%Sj`&Nl0YI!tRtBe!mKBiG&YdVMl#4`6IpB~n=Nc5 zActJ?*hW4DY^RVN>|__aDPj+MDP|uf?B@UnImBU(P)Zr)9HoL|9Ond;RB@7OYN+KD zr>Uc!1{yiTS(<3(94(yZ0vEZ&Wv= '" + lastYearFirstDayStr + +//// "' AND " + targetTimeField + " < '" + lastYearNextMonthFirstDayStr + "'"; +//// DBSql.update(insertCurrentMonthLastYearSql); +// +// String CurrentMonthLastYearSql = "SELECT * FROM " + targetTable + +// " WHERE " +targetTimeField+">='"+lastYearFirstDayStr+"' AND "+ +// targetTimeField+"<'"+lastYearNextMonthFirstDayStr+"'"; +// LOGGER.info("查询去年同期sql:{}",CurrentMonthLastYearSql); +// ArrayList bos = new ArrayList<>(); +// List maps = DBSql.getMaps(CurrentMonthLastYearSql); +// for (RowMap map : maps) { +// map.remove("ID"); +// map.remove("ORGID"); +// map.remove("CREATEDATE"); +// map.remove("CREATEUSER"); +// map.remove("UPDATEDATE"); +// map.remove("UPDATEUSER"); +// map.remove("ISEND"); +// map.remove("BINDID"); +// BO bo = new BO().setAll(map); +// bos.add(bo); +// } +// // 执行插入操作 +// SDK.getBOAPI().createDataBO(hzb, bos, UserContext.fromUID("admin")); +// LOGGER.info("{}已新增当月去年同期数据",lastYearFirstDayStr); +// +// } catch (Exception e) { +// LOGGER.error("每月1号任务执行失败: {}", e.getMessage(), e); +// } +// } + + + // 修改为每天执行的任务:删除endDated的去年同期上一天的数据,新增endDated的去年同期当天数据 + if (endDated != null) { try { - LOGGER.info("开始执行每月1号的特殊数据处理任务"); + LOGGER.info("开始执行每天的特殊数据处理任务"); - // 计算时间范围 - LocalDate lastYearMonthDate = now.minusYears(1).minusMonths(1); - int lastYearMonthValue = lastYearMonthDate.getMonthValue(); - int lastyear = lastYearMonthDate.getYear(); + // 计算endDated的去年同期日期 + Calendar cal = Calendar.getInstance(); + cal.setTime(endDated); + cal.add(Calendar.YEAR, -1); + Date lastYearEndDate = cal.getTime(); - // 1. 删除当月去年同期全量数据 - String deleteCurrentMonthLastYearSql = "DELETE FROM " + hzb + - " WHERE YEAR = " + lastyear + - " AND MONTH = " + lastYearMonthValue; - int update = DBSql.update(deleteCurrentMonthLastYearSql); - LOGGER.info("已删除去年同期({}-{})的全量数据,删除了{}条数据", lastyear, lastYearMonthValue,update); + // 计算去年同期的上一天 + cal.setTime(lastYearEndDate); + cal.add(Calendar.DAY_OF_MONTH, -1); + Date lastYearEndDateMinusOneDay = cal.getTime(); - // 2. 新增当月去年同期数据 - // 去年日期 - LocalDate minusYears = now.minusYears(1); - // 计算去年同期第一天(当月第一天) - LocalDate firstDayOfLastYearMonth = minusYears.withDayOfMonth(1); - // 计算去年下个月第一天 - LocalDate firstDayOfNextMonthLastYear = minusYears.plusMonths(1).withDayOfMonth(1); - // 格式化日期为字符串(根据数据库格式要求调整) - DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); - String lastYearFirstDayStr = firstDayOfLastYearMonth.format(formatter); - String lastYearNextMonthFirstDayStr = firstDayOfNextMonthLastYear.format(formatter); - //删除清空去年同期数据 - int update1 = DBSql.update("DELETE FROM " + hzb + - " WHERE YEAR = " + firstDayOfLastYearMonth.getYear() + - " AND MONTH = " + firstDayOfLastYearMonth.getMonthValue()); - LOGGER.info("先清空{}去年同期数{}",lastYearFirstDayStr,update1); - // 构建插入SQL(注意:需确保字段匹配且处理可能的主键冲突) + // 格式化日期 + String endDateStr = simpleDateFormat.format(endDated); + String lastYearEndDateStr = simpleDateFormat.format(lastYearEndDate); + String lastYearEndDateMinusOneDayStr = simpleDateFormat.format(lastYearEndDateMinusOneDay); - String CurrentMonthLastYearSql = "SELECT * FROM " + targetTable + - " WHERE " +targetTimeField+">='"+lastYearFirstDayStr+"' AND "+ - targetTimeField+"<'"+lastYearNextMonthFirstDayStr+"'"; - ArrayList bos = new ArrayList<>(); - List maps = DBSql.getMaps(CurrentMonthLastYearSql); - for (RowMap map : maps) { - map.remove("ID"); - map.remove("ORGID"); - map.remove("CREATEDATE"); - map.remove("CREATEUSER"); - map.remove("UPDATEDATE"); - map.remove("UPDATEUSER"); - map.remove("ISEND"); - map.remove("BINDID"); - BO bo = new BO().setAll(map); - bos.add(bo); + // 1. 删除去年同期上一天的数据 + String deleteLastYearMinusOneDaySql = "DELETE FROM " + hzb + + " WHERE " + targetTimeField + " = '" + lastYearEndDateMinusOneDayStr + "'"; + int deleteCount = DBSql.update(deleteLastYearMinusOneDaySql); + LOGGER.info("已删除去年同期上一天({})的数据,删除了{}条数据", lastYearEndDateMinusOneDayStr, deleteCount); + + // 2. 新增去年同期当天的数据 + // 查询原表中去年同期的数据 + String selectLastYearSql = "SELECT * FROM " + targetTable + + " WHERE " + targetTimeField + " = '" + lastYearEndDateStr + "'"; + List lastYearData = DBSql.getMaps(selectLastYearSql); + + List lastYearBos = new ArrayList<>(); + for (RowMap map : lastYearData) { + BO bo = new BO(); + // 复制所有字段(排除系统字段) + for (String key : map.keySet()) { + if (!key.equalsIgnoreCase("ID") && + !key.equalsIgnoreCase("ORGID") && + !key.equalsIgnoreCase("CREATEDATE") && + !key.equalsIgnoreCase("CREATEUSER") && + !key.equalsIgnoreCase("UPDATEDATE") && + !key.equalsIgnoreCase("UPDATEUSER") && + !key.equalsIgnoreCase("ISEND") && + !key.equalsIgnoreCase("BINDID")) { + if (StringUtils.isNotBlank(targetTimeField)) { + String targetTimeField1 = map.getString(targetTimeField); + Date parse = UtilDate.parse(targetTimeField1); + int year = UtilDate.getYear(parse); + String monthFormat = UtilDate.monthFormat(parse); + int day = UtilDate.getDay(parse); + bo.set("YEARMONTH", year + monthFormat); + bo.set("YEAR", year); + bo.set("MONTH", monthFormat); + bo.set("DAY", day); + } + bo.set(key, map.get(key)); + } + } + lastYearBos.add(bo); } - // 执行插入操作 - SDK.getBOAPI().createDataBO(hzb, bos, UserContext.fromUID("admin")); - LOGGER.info("{}已新增当月去年同期数据",lastYearFirstDayStr); + // 执行插入操作 + SDK.getBOAPI().createDataBO(hzb, lastYearBos, UserContext.fromUID("admin")); + LOGGER.info("已新增去年同期当天({})的数据,新增了{}条数据", lastYearEndDateStr, lastYearBos.size()); } catch (Exception e) { - LOGGER.error("每月1号任务执行失败: {}", e.getMessage(), e); + LOGGER.error("每天任务执行失败: {}", e.getMessage(), e); } } }catch (Exception e){ @@ -1315,75 +1394,52 @@ public class SaleDataSyncServiceImpl implements DataSyncService { } } while (hasMore); - //每月1号删除上月去年同期去除每月最后一天的数据,删除当月去年同期全量数据后新增当月去年同期全量数据, - // 每月1号执行的任务 - LocalDate now = LocalDate.now(); - int dayOfMonth = now.getDayOfMonth(); - - if (dayOfMonth == 1) { + // 每天执行的任务:删除去年同期上一天的数据,新增去年同期当天的数据 try { - LOGGER.info("开始执行每月1号的特殊数据处理任务"); + LOGGER.info("开始执行每天的特殊数据处理任务"); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); - // 计算时间范围 - LocalDate lastYearMonthDate = now.minusYears(1).minusMonths(1); - // 计算去年上月期第一天(当月第一天) - LocalDate firstDayOfLastYearLastMonth = lastYearMonthDate.withDayOfMonth(1); - // 计算去年上月个月最后一天 - LocalDate firstDayOfLastMonthLastYear = lastYearMonthDate.plusMonths(1).withDayOfMonth(1); - String lastYearLastMonthFirstDayStr = firstDayOfLastYearLastMonth.format(formatter); - String lastYearLastMonthEndDayStr = firstDayOfLastMonthLastYear.format(formatter); + // 获取结束日期 + String currentDateStr = simpleDateFormat2.format(endDated); + LocalDate currentDate = LocalDate.parse(currentDateStr, formatter); - // 1. 删除当月去年同期全量数据 - String deleteCurrentMonthLastYearSql = "DELETE FROM " + targetTable + - " WHERE RQ >= '" + lastYearLastMonthFirstDayStr + - "' AND RQ < '" + lastYearLastMonthEndDayStr+"'"; - int update = DBSql.update(deleteCurrentMonthLastYearSql); - LOGGER.info("已删除去年同期({}-{})的全量数据,删除了{}条数据", lastYearLastMonthFirstDayStr, lastYearLastMonthEndDayStr,update); + // 计算去年同期日期 + LocalDate lastYearSameDay = currentDate.minusYears(1); + // 计算去年同期前一天 + LocalDate lastYearPreviousDay = lastYearSameDay.minusDays(1); - // 2. 新增当月去年同期数据 - // 去年日期 - LocalDate minusYears = now.minusYears(1); - // 计算去年同期第一天(当月第一天) - LocalDate firstDayOfLastYearMonth = minusYears.withDayOfMonth(1); - // 计算去年下个月第一天 - LocalDate firstDayOfNextMonthLastYear = minusYears.plusMonths(1).withDayOfMonth(1); - // 格式化日期为字符串(根据数据库格式要求调整) + String lastYearSameDayStr = lastYearSameDay.format(formatter); + String lastYearPreviousDayStr = lastYearPreviousDay.format(formatter); - String lastYearFirstDayStr = firstDayOfLastYearMonth.format(formatter); - String lastYearNextMonthFirstDayStr = firstDayOfNextMonthLastYear.format(formatter); + // 1. 删除去年同期前一天的数据 + String deleteLastYearPreviousDaySql = "DELETE FROM " + targetTable + + " WHERE RQ = '" + lastYearPreviousDayStr + "'"; + int deletedCount = DBSql.update(deleteLastYearPreviousDaySql); + LOGGER.info("已删除去年同期前一天({})的数据,删除了{}条数据", lastYearPreviousDayStr, deletedCount); - //删除清空去年同期数据 - int update1 = DBSql.update("DELETE FROM " + targetTable + - " WHERE RQ = '" + lastYearNextMonthFirstDayStr+"'"); - LOGGER.info("先清空{}去年同期数{}",lastYearFirstDayStr,update1); - - // 构建查询去年同期全部数据的SQL + // 2. 新增去年同期当天数据 + // 构建查询去年同期当天数据的SQL String lastYearQuerySql; List lastYearParams = new ArrayList<>(); // 根据不同的数据库类型构建查询语句 if ("ORACLE".equalsIgnoreCase(DBname)) { lastYearQuerySql = "SELECT * FROM " + tableName + - " WHERE TO_DATE(" + timeField + ", 'YYYY-MM-DD') BETWEEN TO_DATE(?, 'YYYY-MM-DD') AND TO_DATE(?, 'YYYY-MM-DD')"; - lastYearParams.add(lastYearFirstDayStr); - lastYearParams.add(lastYearNextMonthFirstDayStr); + " WHERE TO_DATE(" + timeField + ", 'YYYY-MM-DD') = TO_DATE(?, 'YYYY-MM-DD')"; + lastYearParams.add(lastYearSameDayStr); } else if ("POSTGRESQL".equalsIgnoreCase(DBname) || "GAUSS".equalsIgnoreCase(DBname)) { lastYearQuerySql = "SELECT * FROM " + tableName + - " WHERE " + timeField + "::DATE BETWEEN ?::DATE AND ?::DATE"; - lastYearParams.add(lastYearFirstDayStr); - lastYearParams.add(lastYearNextMonthFirstDayStr); + " WHERE " + timeField + "::DATE = ?::DATE"; + lastYearParams.add(lastYearSameDayStr); } else if ("SQLSERVER".equalsIgnoreCase(DBname)) { lastYearQuerySql = "SELECT * FROM " + tableName + - " WHERE CONVERT(DATE, " + timeField + ") BETWEEN CONVERT(DATE, ?) AND CONVERT(DATE, ?)"; - lastYearParams.add(lastYearFirstDayStr); - lastYearParams.add(lastYearNextMonthFirstDayStr); + " WHERE CONVERT(DATE, " + timeField + ") = CONVERT(DATE, ?)"; + lastYearParams.add(lastYearSameDayStr); } else { // 默认处理(如MySQL) lastYearQuerySql = "SELECT * FROM " + tableName + - " WHERE STR_TO_DATE(" + timeField + ", '%Y-%m-%d') BETWEEN STR_TO_DATE(?, '%Y-%m-%d') AND STR_TO_DATE(?, '%Y-%m-%d')"; - lastYearParams.add(lastYearFirstDayStr); - lastYearParams.add(lastYearNextMonthFirstDayStr); + " WHERE STR_TO_DATE(" + timeField + ", '%Y-%m-%d') = STR_TO_DATE(?, '%Y-%m-%d')"; + lastYearParams.add(lastYearSameDayStr); } // 添加分区条件(如果存在) @@ -1395,32 +1451,29 @@ public class SaleDataSyncServiceImpl implements DataSyncService { } } - LOGGER.info("查询去年同期数据SQL: {}", lastYearQuerySql); - LOGGER.info("查询参数: 开始日期={}, 结束日期={}", lastYearFirstDayStr, lastYearNextMonthFirstDayStr); + LOGGER.info("查询去年同期当天数据SQL: {}", lastYearQuerySql); + LOGGER.info("查询参数: 日期={}", lastYearSameDayStr); - // 执行查询去年同期数据 + // 执行查询去年同期当天数据 List lastYearData; if (lastYearParams.isEmpty()) { lastYearData = rdsapi.getMaps(lastYearQuerySql); } else { // 这里需要根据您的rdsapi接口调整参数传递方式 - lastYearData = rdsapi.getMaps(lastYearQuerySql,lastYearFirstDayStr,lastYearNextMonthFirstDayStr); + lastYearData = rdsapi.getMaps(lastYearQuerySql, lastYearSameDayStr); } if (lastYearData != null && !lastYearData.isEmpty()) { - // 批量插入去年同期数据 + // 批量插入去年同期当天数据 int lastYearSuccessCount = this.processAndInsertData(lastYearData, fieldMappings, targetTable); - LOGGER.info("成功插入去年同期数据{}条,时间范围: {}-{}", - lastYearSuccessCount, lastYearFirstDayStr, lastYearNextMonthFirstDayStr); + LOGGER.info("成功插入去年同期当天数据{}条,日期: {}", + lastYearSuccessCount, lastYearSameDayStr); } else { - LOGGER.warn("未查询到去年同期数据,时间范围: {}-{}", - lastYearFirstDayStr, lastYearNextMonthFirstDayStr); + LOGGER.warn("未查询到去年同期当天数据,日期: {}", lastYearSameDayStr); } } catch (Exception e) { - LOGGER.error("每月1号任务执行失败: {}", e.getMessage(), e); - } - + LOGGER.error("每天任务执行失败: {}", e.getMessage(), e); } LOGGER.info("从表[{}]共查询到{}条数据,成功同步{}条数据",