From 15317f5e1ef5ee907efb0c1bcd3e95af83a331d4 Mon Sep 17 00:00:00 2001 From: "HUOJIN\\92525" <925258474@qq.com> Date: Sun, 28 Apr 2024 16:27:16 +0800 Subject: [PATCH] no message --- .../java/com/youchain/service/LogService.java | 22 ++++-- .../youchain/service/impl/LogServiceImpl.java | 21 ++++++ .../com/youchain/service/LogService.class | Bin 1359 -> 1542 bytes .../service/impl/LogServiceImpl.class | Bin 13650 -> 14499 bytes .../service/mapstruct/LogErrorMapperImpl.java | 2 +- .../service/mapstruct/LogSmallMapperImpl.java | 2 +- .../businessdata/inputJson/MoInfo.java | 7 -- .../businessdata/inputJson/MoParams.java | 11 +++ .../businessdata/rest/KMReSController.java | 50 ++++---------- .../businessdata/service/AgvTaskService.java | 2 +- .../businessdata/service/TaskService.java | 6 +- .../service/impl/AgvTaskServiceImpl.java | 6 +- .../service/impl/MlsServiceImpl.java | 63 +++++++++++------- .../service/impl/TaskServiceImpl.java | 6 +- .../youchain/modules/quartz/task/moTask.java | 21 ++++-- .../modules/quartz/task/orderTask.java | 17 +++-- .../main/java/com/youchain/utils/UrlApi.java | 4 +- 17 files changed, 145 insertions(+), 95 deletions(-) diff --git a/youchain-logging/src/main/java/com/youchain/service/LogService.java b/youchain-logging/src/main/java/com/youchain/service/LogService.java index 8b3f27b..d10ba84 100644 --- a/youchain-logging/src/main/java/com/youchain/service/LogService.java +++ b/youchain-logging/src/main/java/com/youchain/service/LogService.java @@ -34,6 +34,7 @@ public interface LogService { /** * 分页查询 + * * @param criteria 查询条件 * @param pageable 分页参数 * @return / @@ -42,6 +43,7 @@ public interface LogService { /** * 查询全部数据 + * * @param criteria 查询条件 * @return / */ @@ -49,6 +51,7 @@ public interface LogService { /** * 查询用户日志 + * * @param criteria 查询条件 * @param pageable 分页参数 * @return - @@ -57,19 +60,25 @@ public interface LogService { /** * 保存日志数据 - * @param username 用户 - * @param browser 浏览器 - * @param ip 请求IP + * + * @param username 用户 + * @param browser 浏览器 + * @param ip 请求IP * @param joinPoint / - * @param log 日志实体 + * @param log 日志实体 */ @Async - void save(String url,String returnValue,String username, String browser, String ip, JoinPoint joinPoint, Log log); + void save(String url, String returnValue, String username, String browser, String ip, JoinPoint joinPoint, Log log); @Async void saveLog(Log log); + + @Async + void saveLogInfo(Object object, String url, String resultJson, String description, long time); + /** * 查询异常详情 + * * @param id 日志ID * @return Object */ @@ -77,7 +86,8 @@ public interface LogService { /** * 导出日志 - * @param logs 待导出的数据 + * + * @param logs 待导出的数据 * @param response / * @throws IOException / */ diff --git a/youchain-logging/src/main/java/com/youchain/service/impl/LogServiceImpl.java b/youchain-logging/src/main/java/com/youchain/service/impl/LogServiceImpl.java index 82a20d3..d09b3cf 100644 --- a/youchain-logging/src/main/java/com/youchain/service/impl/LogServiceImpl.java +++ b/youchain-logging/src/main/java/com/youchain/service/impl/LogServiceImpl.java @@ -19,6 +19,7 @@ import cn.hutool.core.lang.Dict; import cn.hutool.core.util.ObjectUtil; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; +import com.alibaba.fastjson.JSON; import com.youchain.domain.Log; import com.youchain.repository.LogRepository; import com.youchain.service.LogService; @@ -43,6 +44,7 @@ import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.lang.reflect.Method; import java.lang.reflect.Parameter; +import java.sql.Timestamp; import java.util.*; /** @@ -120,6 +122,25 @@ public class LogServiceImpl implements LogService { logRepository.save(log_data); } + @Override + @Transactional(rollbackFor = Exception.class) + public void saveLogInfo(Object object,String url, String resultJson, String description, long time) { + // 设置日志信息 + Log log_data = new Log(); + log_data.setDescription(description); + log_data.setLogType("INFO"); + log_data.setMethod(url); + log_data.setParams(JSON.toJSONString(object)); + log_data.setReturnData(resultJson); + log_data.setRequestIp("127.0.0.1"); + log_data.setTime(time); + log_data.setUsername("admin"); + log_data.setAddress("内网IP"); + log_data.setBrowser("Chrome 123"); + log_data.setCreateTime(new Timestamp(new Date().getTime())); + logRepository.save(log_data); + } + /** * 根据方法和传入的参数获取请求参数 */ diff --git a/youchain-logging/target/classes/com/youchain/service/LogService.class b/youchain-logging/target/classes/com/youchain/service/LogService.class index 46b4f6921b55e977cbb8f7d4196c58e1e28091fd..2812d398b787e03167f21a946c20d4d283ad0d8b 100644 GIT binary patch delta 266 zcmX@l)y5-m>ff$?3=9k=42J9sdh87P8wJ)gDRLJlmZkdSr+en5ff$?3=9k=4BG4r8te?38wJ)gO?GFV!l7;er_#RkcV08$u|BV>ppLxZ?Rh6S-$hU?mqLEIomMIbUNB%@_aP{ztJ z5tt2PvTPLWd;I?a*!I#=khKqV~WF%)xF)P7g}8)C8qg>bM+}Ts8p-v&{mR{hSAyQ%*@x^bg%6KK%`@}QpZkR#n4>E}qcl6LFxup^Hs({M!| zb>uOf|KP|Toga7P37wyGq=&cVDJxGq@=Q>kl|NctdrqF$OnSk}i&pkFoo3!O{+DQ3 z)8xRdCj5kzKQT7UC@U{BpW+7o^lJ zSXQ~PK@f@Go0`!-xU#aovAUt8zOGgfT2xuTaAnoIC?BVp5kM$SO0j@kIZ(DiCm3QSmL16N%S!J_a zd0+Oq@_~Hl;+Oc9D<8>Ux$Wbye9}2p{uY)`UHMG@ZsjEx@5?`|eD2B@@+DcmQaO=- z68e{mP1qckua)(i_>}NyS2AQj9qG!q@?HGOaDnf8IS_v^+$Z&ASALL#g0AtadvuK{ zU&J*mb8C!id{o8wO@J;sTwro?U6Z0DtAiu^U6ZOqQ1)39a=9VRHJxO?z*kUE;F`|5 z7}g=(L|nX!_gvFOmjl&xOR8#Jlc91lO_nuXUDM4(hYMg$ch~eVJ?V4T^fJ9&bC`1V zF@0Ur&t$u%zX}|{0lVZAReZ%^U1N;p)ag^oTr-e%nnA9~G1-FDAwx$TegyvwvGSU0 za!sCV^37l>P_d|{iV5KCyXe9XAGl`f35{O$C0{=Sfp>iX|9>h+%aXQRCSx-nwe&nmDgP} zTjkF&61QDO_B&qou~0s^>Z*?(+UA;a#Zo`me$_`?FWI;84%f_;eesGe-FyY6IDU4Q zK6xjYdDfihnv*2pnv>PVr?}=+jmv4O@O&LARLBro8I8Y@)vbqX7APUqP&Z>`<)W&E zp2rp{X;b|3euLuUGS>JO@t6lP3PP1CX|WkA$i23E&-hq>TD*5=c9$itS!$}RS>~G4 zO|^@SxT$GQ<_K|XOf5UVVd>A$iTCyAH$9S7F1{MGJRa`dFMev84TQ`JvoiipbX3#2 zZfRmSn0mov@}_3SH)jT@U^M=8w2N3*3e}1!gy_tg2nY&akSYy0Nlsv7k#%Np7i^A=MSNOA1Tt zYL|@SI^}8#>H1GswO83C-ug%~_;PYfn8p-CdK&jlTvsB!FcfE*v#mMDHRsAFuJj{Cx=WAv$Jrz0 zyr%5_TgAUtFd#mz|A6?H1NtAi0XIN!BmC&DK4+_nfPKxI*^|7P4Tf_%`EJ3jFxV0= z9atK>jkGKTIF94mcw}M%`eGuE#$?=1>Tqvu6n>4Z#DGz_1HYjRh3>>%l#`A;{1(51 zk9!B=ZrnpHwsGAhS90xMuH8pU2yy^NTQphRkL@I+nh3>#g7~bVS_v|4iRTXLJ4w|_ z@s26+)X3sNK)79vaH|?Bh0atVJNPr$$xY3z_FXxs$g?l#Z7!oWGdy8=)DXyR7na*@ zQ*OIW-CAurWQkJLlBD7t^xlOQ)tje}q~J7~k`=X&BdrDL^O}ltBH}4A3mH7LobH^9 z&X|WDI1&AE5{|&Bn2!onV8RGW;CwS0v z7SCI}VDX~GUd;e_uIy#0Ca52%8K@Je4X6jG0q_!kooK|L_CL}PCgh>hH zahjaKAWl;fI67)uP&}^%$5Qar1WI<`xCBb`?uSHeGe#NAy_Y8&Xjv4|LSQZ9a6Sv- zf*87D9eUwH7T-k}jEgZ0mtYJo#UxyY<8V1<;R-CpdNkll&nd?;tTdzDDUJ9G-k?*I zrWvD^)`&L=F--`)MM&M-h_~?$osh~*OeTkxLM$`D{qTbLCg->Kdz-(17dWFY3d-NY z1bdG%gXC*z!8BSueR_TZWkr79QGv`r)c@eEI4A1Q3=ECTNMPn}%qU8UrtCqdg2ALU zV-`J`U?_xxONoHtn%+en7g#KP~{ zvZ6SOoaRR=A`4hh3kffpz7t1ADqFC49-Y5rBV(`?PAoDkfu%c8mB0v%htCT~ zvLS4vZug=e?HEMM)vd|aU)=7aVjRE^)F}%?7_2?iYY_T?uj^LpC&C=$P3KnwMYMy7 zAtpXr=3p@Y#}3kjAFl^GuIq-@Tk3$CFMd&@wFJJR`C5v5+e@Gs%LGOKsJ|JfYyKq^ zsup&}(M5q4)UZ%$wGtwA(Le%6HDjJH#!5(uELVJh;vTv}(Ut9Jy`l~6XrrR5+R-x< zUEPkJsSZ}sBG1Vo52T~p{M^pCMpw>?CGmo2O0s~q9-LAzcqh)*hLtRhvAplVs&RNR z4`hG~nU7<6UrpnUbu#1_UMXyT=8{`ax@Kg{O;6tAIY*=1g2Of+s|nec^t(r7uP zP|9syv^3vid)tG#S5lbVn(%wYisL2x)4VJ-;Wah-a83&Ol0uX#MS|paKrRWjhP(p) z0|;v(i+hlDX}#nomX@S>*Vujyx#qtU!+HnnH3@!(G0@8B@i7~|K{hWQb&l{(Nmd6H z2eYg75hGzPr3?RdqiMp1Z#<)1t&#{6;vB=QZo3X*$=A)(yn~7ny-KyVXlQq4Tpo0C0(hJmRB=*e4Oj^ z5{Q+WF}z^Ti{CXQyVu$TQZ}NmZ_HNo%#WP!VO{*hI^{<$h<`F9C$=t}vKe1;--VHj z61aFHJ|uie zmY%GY-u(3mgNO1%>AyQP`Bjm;4O$QFa3;_H9}eaB+JATGxc_fyheJD@$vgc&S_(({ zvx2=e=hvE+2S27F8+PKlCS0$TCEhKVbTGe4WB_SK270eDQe_a)Gf89nGiR8XSkincSC|7cv==KtRf-n3agE1`=dfOh6;DRINmaF&GFY0mW(u5G-9R ztz)aGMT*#L#-4#az+qoGAtx#%5WHZCG=u{cODh*PDGDT-N zGE?XCmHL99l*@$P1>pv;lE+>XjT1;48M7c2QCI$WwA_?nf=f*2=7s_%R& z6+yXN#)M>nEVNQ-<%%FCNtG@ZhcJ;!QqGkjsg^}bbCnJ?IxJRZOCktJT~O+!!OAj~ zvD}es97NlKa;>b;h3g#ox|QpLa)W$BogUR;rE*vmlGSpf4r{Ee4dPNMa^xmQzUjz1 zee+w6d|T)5IPzVcZ+7H+I&wO>SSHLN++!b0p-5 zt7~`YaHk`8DOEp3e(cCbo$q#Jlg>YJWV6oqIO5lNi%qkl^x87*eK`zrd7!=NO-5kAv)S~@52_a#V!k7 zZksILv$Ct{nUIy2e`6P_F8Fm&Q5SUV4KC|4F$7G)?`{i*L z-@|%WekM=wwV#LO$<$|#X?aD9ZSFt5&1-@71wb;hA0nr_<{90ZY^jcK0yrQtCVo6oug$;Gp zOR6R=tFBpCS;sf=r7OP?dgcvReyhs8DQ^j6sK8|Bxbiz)`n?Ws%RyJ((curW&&s>5 zw8>#tj>tiQub`m7mG^Y>k2<_BAGml9(dS+HlkNvhTIgfeXBfNk=mpr>cbvWDuK!U=VC6)Q@s>l<9d zP9YdxTUS+Bzf|qJqOM|bZ>A3z zmThvZ$#qR0K6FjK`r3c)jHxrNDR9kDI?@!XNoVLVOt}q<_3u55x}T{?sG;`!y2^#s z3o05aT{B$v#jeiSk~BiMvSStgjMy2O8KIHNWt4FRIb6$$t;ihQbF^#5n6s=Ya?M!7 z{QEY()3iNvv^d44giX?nZ~Cy;TJaT|vtw8F9~3L;VFMvE!Ay*e>pQmTt*jLBtu>Qk zNBd0YJh^FH-)sC$H3ND`P`gQypl^0g?4_ivrrQS|5XV+kHq5GCT-mf>@FFv4ifg8t z>8`lK0G?+`ttoTO40+O(5Ld(}{@Bse#>n|i*+UvdE{MH!dg;iuSO>wk;71?Tl*JhV zE7_Y_h2G4P;v6R3Er`M3*4PEvrO_X9EfWEbB}l_~WZ-NJ!~~p$N%#?0M|gWTl43AkZH3V|HnB{cYl+$HX?+%+zTB0jzNkZ{%dT+x6syC&NA>$O9l9^?n zMoKHv<~5b(M#NL19O)D~i|)J#shESln2S>}4`<*K%*SP@K?Uk@IaXo;1udk*DzO_? zcoA3PbyVXp7U39b#D~R_j3ttRTF;m@l=wOZ<3T(`ms579S%kJT7z|aE;0}UxA)%dw z*uM!q?8Qo_H10D*G|^q7}(hxebrtQ3R=Y9FOtckQd*f zFsbeM0ItP8hPdlD*Ms(3JZ|wbizh68t{DK&mHjN$1oZmCekhAxSZ72A`2_JrA?nsm#{k2D)F@SL3(%^Fn|7& zB*PZ}JpIPt$~)v9q?FcHjGNbt;u(2yloa`+zEOdUK$icp&A1`UpAk4SGCq#8_hWof zQdZJa=uwc*wH8b;n3LF^=xt9dvRU>iOm4-bd4Xn3E^@rxIHnXOXW14^6}o-e9dJ7k zt~y!C30~*;FsC5PNidDB2}oo6s)81rt96hR8NP$?bau&22p9NTaGoKjF^#YVoYc*J zXmw3zi(qOnuq)}ZRdm^n$i^BJU@gY5olIjpDP=R6&2}=M&15m#$#S-mH9VVdCVh;5 zchND?yXk4|6j#tYvoRV6@B*36C!-gc8OdZ?iI?y)vuYZq;uRcZR;6Jzeu-asy`{A) zI;~!QF=3fyui`cO-C-{Ln(6JMiVxy9I7H>OBDEbPWWAvlB*=bCvU|8$0_OzMEZ($u zOO9cP#qUm_*y8sVZ!_=O`F4_*p-jYgI>>-85C~;X(!A^_@V#X9Dj&fg@NOap2nDDC zFfDf%B(DXf2GPAJ(^Q?YA2ZAH<2XNZL8Lry4=yA;YsMaoj9k=;+4Jc9IU5**MmUk- zam;PTyf{W{IDB3>5*d6ab-N3L*Z@vvM^&#TdeyWpA5CNJ9i~p17{=fq1^7(703IDhq=)P_7erH*UfF?0lOomXU|pN#IXUEk-5lNZ;v(I-DuEVcB_#@|v3+Vm{vOn5 z_eqpS2^%z+N)ER0M7tM-^hXH~r!s71v%U{k@r1b!+gKnE;Nd6}^KtgxXW7OMu#LUK zHl~3qVZs;kIMH%QBAYEe`#k~S}*oY|Gy^Iyd-#AW3Kt{;AZ|b3H}2ev*9Ei zv*9zIE`OtRKP7+GSsh2Y@DZP_VGahLbMFft6?(1MF+4rG*m&LCc)6W8f8#tQnmyO( z%|P!5iNpNgclcuoW~3`3Q;%M2F0!Nr|AzM?jw|tAXKCuFbt2jk`x~)!rTjU zF&qw}oy6kRQwvFaMCxyhg{_(j4uM84s{PY{kqR(f!At}l*N z`>}d2dn9(}DWm8<^_ DrO)b^ diff --git a/youchain-logging/target/generated-sources/annotations/com/youchain/service/mapstruct/LogErrorMapperImpl.java b/youchain-logging/target/generated-sources/annotations/com/youchain/service/mapstruct/LogErrorMapperImpl.java index 5b4730e..3c1ebdc 100644 --- a/youchain-logging/target/generated-sources/annotations/com/youchain/service/mapstruct/LogErrorMapperImpl.java +++ b/youchain-logging/target/generated-sources/annotations/com/youchain/service/mapstruct/LogErrorMapperImpl.java @@ -9,7 +9,7 @@ import org.springframework.stereotype.Component; @Generated( value = "org.mapstruct.ap.MappingProcessor", - date = "2024-04-24T17:39:34+0800", + date = "2024-04-28T13:35:56+0800", comments = "version: 1.4.2.Final, compiler: javac, environment: Java 1.8.0_202 (Oracle Corporation)" ) @Component diff --git a/youchain-logging/target/generated-sources/annotations/com/youchain/service/mapstruct/LogSmallMapperImpl.java b/youchain-logging/target/generated-sources/annotations/com/youchain/service/mapstruct/LogSmallMapperImpl.java index 720c971..b8aba1b 100644 --- a/youchain-logging/target/generated-sources/annotations/com/youchain/service/mapstruct/LogSmallMapperImpl.java +++ b/youchain-logging/target/generated-sources/annotations/com/youchain/service/mapstruct/LogSmallMapperImpl.java @@ -9,7 +9,7 @@ import org.springframework.stereotype.Component; @Generated( value = "org.mapstruct.ap.MappingProcessor", - date = "2024-04-24T17:39:34+0800", + date = "2024-04-28T13:35:56+0800", comments = "version: 1.4.2.Final, compiler: javac, environment: Java 1.8.0_202 (Oracle Corporation)" ) @Component diff --git a/youchain-system/src/main/java/com/youchain/businessdata/inputJson/MoInfo.java b/youchain-system/src/main/java/com/youchain/businessdata/inputJson/MoInfo.java index fe86680..5267e86 100644 --- a/youchain-system/src/main/java/com/youchain/businessdata/inputJson/MoInfo.java +++ b/youchain-system/src/main/java/com/youchain/businessdata/inputJson/MoInfo.java @@ -17,13 +17,6 @@ public class MoInfo { @Schema(example = "WQ") String sourceSystem; - @ApiModelProperty(value = "当前页码") - @Schema(example = "1") - int pageNo; - - @ApiModelProperty(value = "每页记录数") - @Schema(example = "100") - int pageSize; @ApiModelProperty(value = "参数") MoParams params; diff --git a/youchain-system/src/main/java/com/youchain/businessdata/inputJson/MoParams.java b/youchain-system/src/main/java/com/youchain/businessdata/inputJson/MoParams.java index 59659d4..113dfef 100644 --- a/youchain-system/src/main/java/com/youchain/businessdata/inputJson/MoParams.java +++ b/youchain-system/src/main/java/com/youchain/businessdata/inputJson/MoParams.java @@ -24,6 +24,17 @@ public class MoParams { @Schema(example = "2023-07-03 23:59:59") String endTime; + @ApiModelProperty(value = "检验结果") + String iqcResult; + + @ApiModelProperty(value = "当前页码") + @Schema(example = "1") + int pageNo; + + @ApiModelProperty(value = "每页记录数") + @Schema(example = "100") + int pageSize; + public MoParams() { } diff --git a/youchain-system/src/main/java/com/youchain/businessdata/rest/KMReSController.java b/youchain-system/src/main/java/com/youchain/businessdata/rest/KMReSController.java index 41e1edb..7fc0f65 100644 --- a/youchain-system/src/main/java/com/youchain/businessdata/rest/KMReSController.java +++ b/youchain-system/src/main/java/com/youchain/businessdata/rest/KMReSController.java @@ -112,32 +112,29 @@ public class KMReSController { /** * 回传MO信息 * - * @param orderNumber + * @param billCode */ - public void returnMo(String orderNumber) { - OrderDto orderDto = orderService.findByBarcodeNumber(orderNumber); + public void returnMo(String billCode) { + OrderDto orderDto = orderService.findByBarcodeNumber(billCode); if (orderDto == null) { - throw new RuntimeException("系统无此送货单号: " + orderNumber); + throw new RuntimeException("系统无此送货单号: " + billCode); } - double receivedQty = agvTaskService.queryOrderNumberSum(orderNumber); - if (receivedQty == orderDto.getReceivedQty()) { - List tasks = taskService.findByOrderNumber(orderNumber); + double receivedQty = agvTaskService.queryBillCodeSum(billCode); + if (receivedQty == orderDto.getDeliveryQty()) { + List tasks = taskService.findByBillCode(billCode); ReturnMoInfo returnMoInfo = getReturnMoInfo(tasks); long startTime = System.currentTimeMillis(); //调用接口 String resultJson = mlsService.returnMo(returnMoInfo); long endTime = System.currentTimeMillis(); long time = endTime - startTime; - - JSONObject resulObject = JSON.parseObject(resultJson); - if (resulObject == null) { - throw new RuntimeException("按MO票入库接口返回数据为空!"); - } - // 保存日志 - saveLogInfo(returnMoInfo, resultJson, "按MO票入库", time); + logService.saveLogInfo(returnMoInfo,UrlApi.publicApi, resultJson, "按MO票入库", time); + + + } } @@ -153,35 +150,16 @@ public class KMReSController { String resultJson = mlsService.returnIssue(returnIssueInfo); long endTime = System.currentTimeMillis(); long time = endTime - startTime; - JSONObject resulObject = JSON.parseObject(resultJson); - if (resulObject == null) { - throw new RuntimeException("叫料结果回传接口返回数据为空!"); - } // 保存日志 - saveLogInfo(returnIssueInfo, resultJson, "叫料结果回传", time); + logService.saveLogInfo(returnIssueInfo,UrlApi.publicApi, resultJson, "叫料结果回传", time); } - public void saveLogInfo(Object object, String resultJson, String description, long time) { - // 设置日志信息 - com.youchain.domain.Log newlogs = new com.youchain.domain.Log(); - newlogs.setDescription(description); - newlogs.setLogType("INFO"); - newlogs.setMethod(UrlApi.publicApi); - newlogs.setParams(JSON.toJSONString(object)); - newlogs.setReturnData(resultJson); - newlogs.setRequestIp("127.0.0.1"); - newlogs.setTime(time); - newlogs.setUsername("admin"); - newlogs.setAddress("内网IP"); - newlogs.setBrowser("Chrome 123"); - newlogs.setCreateTime(new Timestamp(new Date().getTime())); - logService.saveLog(newlogs); - } + public static ReturnMoInfo getReturnMoInfo(List tasks) { ReturnMoParams params = new ReturnMoParams(); - params.setOrgId(100059); + params.setOrgId(808); params.setInvCode("MA2111"); Set labelNos = new HashSet<>(); for (Task task : tasks) { diff --git a/youchain-system/src/main/java/com/youchain/businessdata/service/AgvTaskService.java b/youchain-system/src/main/java/com/youchain/businessdata/service/AgvTaskService.java index a452107..3cc3097 100644 --- a/youchain-system/src/main/java/com/youchain/businessdata/service/AgvTaskService.java +++ b/youchain-system/src/main/java/com/youchain/businessdata/service/AgvTaskService.java @@ -153,7 +153,7 @@ public interface AgvTaskService { List findById(List ids); - double queryOrderNumberSum(String orderNumber); + double queryBillCodeSum(String billCode); /** *根据组号+料箱号招找到对应的AGV diff --git a/youchain-system/src/main/java/com/youchain/businessdata/service/TaskService.java b/youchain-system/src/main/java/com/youchain/businessdata/service/TaskService.java index a60e73f..34c3e4b 100644 --- a/youchain-system/src/main/java/com/youchain/businessdata/service/TaskService.java +++ b/youchain-system/src/main/java/com/youchain/businessdata/service/TaskService.java @@ -130,10 +130,10 @@ public interface TaskService { List findByLabelNo(String labelNo); /** - * 根据工单号号查询任务 - * @param orderNumber 条件参数 + * 根据送货单条码号查询任务 + * @param billCode 条件参数 * @return List */ - List findByOrderNumber(String orderNumber); + List findByBillCode(String billCode); } diff --git a/youchain-system/src/main/java/com/youchain/businessdata/service/impl/AgvTaskServiceImpl.java b/youchain-system/src/main/java/com/youchain/businessdata/service/impl/AgvTaskServiceImpl.java index 4f57e81..76c22fc 100644 --- a/youchain-system/src/main/java/com/youchain/businessdata/service/impl/AgvTaskServiceImpl.java +++ b/youchain-system/src/main/java/com/youchain/businessdata/service/impl/AgvTaskServiceImpl.java @@ -535,10 +535,10 @@ public class AgvTaskServiceImpl implements AgvTaskService { @Override - public double queryOrderNumberSum(String orderNumber) { - String hql = "select sum(task.moveQty) from Task task where task.billCode= :orderNumber"; + public double queryBillCodeSum(String billCode) { + String hql = "select sum(task.moveQty) from Task task where task.billCode= :billCode"; Query query = entityMapper.createQuery(hql); - query.setParameter("orderNumber", orderNumber); + query.setParameter("billCode", billCode); List orderNumberSumList = query.getResultList(); if (orderNumberSumList.size() > 0) { return orderNumberSumList.get(0); diff --git a/youchain-system/src/main/java/com/youchain/businessdata/service/impl/MlsServiceImpl.java b/youchain-system/src/main/java/com/youchain/businessdata/service/impl/MlsServiceImpl.java index 5102098..6c8c9e5 100644 --- a/youchain-system/src/main/java/com/youchain/businessdata/service/impl/MlsServiceImpl.java +++ b/youchain-system/src/main/java/com/youchain/businessdata/service/impl/MlsServiceImpl.java @@ -41,6 +41,7 @@ public class MlsServiceImpl implements MlsService { private final AgvTaskService agvTaskService; private final PickDetailService pickDetailService; private final InventoryService inventoryService; + private final RedisUtils redisUtils; /** @@ -209,7 +210,9 @@ public class MlsServiceImpl implements MlsService { * @param detail */ private Order updateOrder(Order order, JSONObject detail) { + order.setReceivedQty(detail.getDouble("receivedQty") == null ? 0 : detail.getDouble("receivedQty")); order.setDeliveryStatus(detail.getString("deliveryStatus")); + order.setMlsUpdateTime(detail.getString("updateTime") == null ? null : DateUtil.parse(detail.getString("updateTime")).toTimestamp()); return order; } @@ -280,32 +283,42 @@ public class MlsServiceImpl implements MlsService { //获取已存在的MO票 Map existingMos = moService.findBylabelNos(labelNos); + Dept dept = null; + boolean flag = redisUtils.hasKey("dept"); + if (flag) { + dept = (Dept) redisUtils.get("dept"); + } else { + DeptDto deptDto = deptService.findById(7L); + dept = deptService.toEntity(deptDto); + redisUtils.set("dept", dept, 0); + } + + //循环处理每个MO票 for (int i = 0; i < details.size(); i++) { JSONObject detail = details.getJSONObject(i); String labelState = detail.getString("labelState");//标签状态 - if ("PRINTED".equals(labelState)) { - //物料编码 - String itemCode = detail.getString("itemCode"); - Item item = null; - if (existingItems.containsKey(itemCode)) { - item = existingItems.get(itemCode); - } else { - //新增物料 - item = createItem(detail); - } + //物料编码 + String itemCode = detail.getString("itemCode").trim(); + Item item = null; + if (existingItems.containsKey(itemCode)) { + item = existingItems.get(itemCode); + } else { + //新增物料 + item = createItem(detail, dept); + existingItems.put(itemCode, item); + } - //MO票 - String labelNo = detail.getString("labelNo"); - //判断是否已存在MO票 - if (existingMos.containsKey(labelNo)) { - Mo existingMo = existingMos.get(labelNo); - //更新MO票信息 - mosToUpdate.add(updateMo(existingMo, detail)); - } else { - //新增MO票 - mosToCreate.add(createMo(detail, item)); - } + //MO票 + String labelNo = detail.getString("labelNo"); + //判断是否已存在MO票 + if (existingMos.containsKey(labelNo)) { + Mo existingMo = existingMos.get(labelNo); + //更新MO票信息 + mosToUpdate.add(updateMo(existingMo, detail)); + } else { + //新增MO票 + mosToCreate.add(createMo(detail, item)); } } @@ -326,7 +339,7 @@ public class MlsServiceImpl implements MlsService { * @param detail * @return */ - private Item createItem(JSONObject detail) { + private Item createItem(JSONObject detail, Dept dept) { String itemCode = detail.getString("itemCode");//物料编码 String itemDesc = detail.getString("itemDesc");//物料描述 @@ -334,8 +347,9 @@ public class MlsServiceImpl implements MlsService { String sourceSystem = detail.getString("sourceSystem");//来源系统 Long itemId = detail.getLong("itemId");//物料id + //创建 - Item Item = new Item(itemCode, itemDesc, uom, UserUtils.getDept(), sourceSystem, itemId); + Item Item = new Item(itemCode, itemDesc, uom, dept, sourceSystem, itemId); itemService.create(Item); return Item; } @@ -381,8 +395,7 @@ public class MlsServiceImpl implements MlsService { } private Mo updateMo(Mo mo, JSONObject detail) { - mo.setCheckResult(detail.getString("checkResult")); - mo.setDeleteFlag(Boolean.parseBoolean(detail.getString("deleteFlag"))); + mo.setLabelState(detail.getString("labelState")); mo.setMlsUpdateTime(detail.getString("updateTime") == null ? null : DateUtil.parse(detail.getString("updateTime")).toTimestamp()); mo.setUpdateUserCode(detail.getString("updateUserCode")); return mo; diff --git a/youchain-system/src/main/java/com/youchain/businessdata/service/impl/TaskServiceImpl.java b/youchain-system/src/main/java/com/youchain/businessdata/service/impl/TaskServiceImpl.java index 3191672..e54de7f 100644 --- a/youchain-system/src/main/java/com/youchain/businessdata/service/impl/TaskServiceImpl.java +++ b/youchain-system/src/main/java/com/youchain/businessdata/service/impl/TaskServiceImpl.java @@ -267,10 +267,10 @@ public class TaskServiceImpl implements TaskService { } @Override - public List findByOrderNumber(String orderNumber) { - String hql = "from Task t where t.itemKey.orderNumber = :orderNumber"; + public List findByBillCode(String billCode) { + String hql = "from Task t where t.billCode = :billCode"; Query query = entityMapper.createQuery(hql); - query.setParameter("orderNumber", orderNumber); // 工单号 + query.setParameter("billCode", billCode); // 工单号 List tasks = query.getResultList(); return tasks; } diff --git a/youchain-system/src/main/java/com/youchain/modules/quartz/task/moTask.java b/youchain-system/src/main/java/com/youchain/modules/quartz/task/moTask.java index 9a063b3..4b7ae65 100644 --- a/youchain-system/src/main/java/com/youchain/modules/quartz/task/moTask.java +++ b/youchain-system/src/main/java/com/youchain/modules/quartz/task/moTask.java @@ -4,6 +4,8 @@ import com.youchain.businessdata.inputJson.MoInfo; import com.youchain.businessdata.inputJson.MoParams; import com.youchain.businessdata.rest.MlsController; import com.youchain.businessdata.service.MlsService; +import com.youchain.service.LogService; +import com.youchain.utils.UrlApi; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -22,10 +24,17 @@ public class moTask { @Autowired public MlsService mlsService; + @Autowired + public LogService logService; + public void moTask() { + long startTime = System.currentTimeMillis(); MoInfo moInfo = getMoInfo(); - String moJson = mlsService.getMoJson(moInfo); - mlsService.getMoInfo(moJson); + String resultJson = mlsService.getMoJson(moInfo); + mlsService.getMoInfo(resultJson); + long time = System.currentTimeMillis() - startTime; + // 保存日志 + logService.saveLogInfo(moInfo, UrlApi.publicApi, resultJson, "获取MO票信息", time); } public MoInfo getMoInfo() { @@ -36,12 +45,16 @@ public class moTask { invCodes.add("MA2111"); params.setInvCodes(invCodes); //DateUtil.format(DateUtil.beginOfDay(new Date()), "yyyy-MM-dd HH:mm:ss") - params.setStartTime("2024-04-11 00:00:00"); - params.setEndTime("2024-04-11 23:59:59"); + params.setIqcResult(""); + params.setStartTime("2024-04-28 00:00:00"); + params.setEndTime("2024-04-28 23:59:59"); + params.setPageNo(1); + params.setPageSize(100); MoInfo moInfo = new MoInfo(); moInfo.setIfaceCode("MLS-WQ-003"); moInfo.setSourceSystem("WQ"); moInfo.setParams(params); + return moInfo; } } diff --git a/youchain-system/src/main/java/com/youchain/modules/quartz/task/orderTask.java b/youchain-system/src/main/java/com/youchain/modules/quartz/task/orderTask.java index 9fa3235..80f03c0 100644 --- a/youchain-system/src/main/java/com/youchain/modules/quartz/task/orderTask.java +++ b/youchain-system/src/main/java/com/youchain/modules/quartz/task/orderTask.java @@ -9,6 +9,8 @@ import com.youchain.businessdata.inputJson.ReturnIssueInfo; import com.youchain.businessdata.inputJson.ReturnIssueInfoParams; import com.youchain.businessdata.rest.MlsController; import com.youchain.businessdata.service.MlsService; +import com.youchain.service.LogService; +import com.youchain.utils.UrlApi; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.ResponseEntity; @@ -34,11 +36,18 @@ public class orderTask { @Autowired public MlsService mlsService; + @Autowired + public LogService logService; + public void orderTask() { + long startTime = System.currentTimeMillis(); OrderInfo orderInfo = getOrderInfo(); - String orderJson = mlsService.getOrderJson(orderInfo); - mlsService.getOrderInfo(orderJson); + String resultJson = mlsService.getOrderJson(orderInfo); + mlsService.getOrderInfo(resultJson); + long time = System.currentTimeMillis() - startTime; + // 保存日志 + logService.saveLogInfo(orderInfo, UrlApi.publicApi, resultJson, "获取送货单信息", time); } @@ -51,8 +60,8 @@ public class orderTask { params.setInvCodes(invCodes); params.setIqcResult(""); //DateUtil.format(DateUtil.beginOfDay(new Date()), "yyyy-MM-dd HH:mm:ss") - params.setStartTime("2024-04-10 00:00:00"); - params.setEndTime("2024-04-10 23:59:59"); + params.setStartTime("2024-04-27 00:00:00"); + params.setEndTime("2024-04-27 23:59:59"); params.setPageNo(1); params.setPageSize(100); OrderInfo orderInfo = new OrderInfo(); diff --git a/youchain-system/src/main/java/com/youchain/utils/UrlApi.java b/youchain-system/src/main/java/com/youchain/utils/UrlApi.java index 60a8725..b459eba 100644 --- a/youchain-system/src/main/java/com/youchain/utils/UrlApi.java +++ b/youchain-system/src/main/java/com/youchain/utils/UrlApi.java @@ -38,7 +38,9 @@ public class UrlApi { /** * MLS接口 + * https://apiuat.midea.com/mls/mlsapi/public/publicApi + * https://apisit.midea.com/mls/mlsapi/public/publicApi */ - public static String publicApi="https://apiuat.midea.com/mls/mlsapi/public/publicApi"; + public static String publicApi="https://apisit.midea.com/mls/mlsapi/public/publicApi"; }