From 3ad0c123bf455b13da1d70a6331707ba710b888d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B7=AF=E6=98=8E=E6=85=A7?= <1191093413@qq.com> Date: Wed, 11 Sep 2024 16:25:35 +0800 Subject: [PATCH] =?UTF-8?q?feature:=E4=BF=AE=E6=94=B9=E7=94=A8=E5=8F=8B?= =?UTF-8?q?=E6=81=92=E6=AC=A3=E5=9B=9E=E5=86=99=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/YyOrderServiceImpl.java | 35 ++++++++++++------- 1 file changed, 23 insertions(+), 12 deletions(-) diff --git a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/YyOrderServiceImpl.java b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/YyOrderServiceImpl.java index e7ddc33..bd1758b 100644 --- a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/YyOrderServiceImpl.java +++ b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/YyOrderServiceImpl.java @@ -97,6 +97,9 @@ public class YyOrderServiceImpl implements OrderService { @Resource private RedissonService redissonService; + @Value("${exculd.nsrsbh}") + private String exculdNsrsbh; + //订单读入 @Override public R orderRead(ReqParam reqParam) { @@ -309,19 +312,27 @@ public class YyOrderServiceImpl implements OrderService { log.debug("cdlCodeList:{}", JSON.toJSONString(ddhList)); for (String cdlCode : ddhList) { DynamicContextHolder.push(nsrsbh); - List ddbhList = yyOrderMapper.getDdbh(cdlCode); - log.debug("查询到中间表信息:{}", JSON.toJSONString(ddbhList)); - if (CollectionUtils.isNotEmpty(ddbhList)) { - for (InvoiceBpmmap invoiceBpmmap : ddbhList) { - NewTable newTableFull = new NewTable(); - BeanUtil.copyProperties(newTable, newTableFull); - newTableFull.setBpmNo(invoiceBpmmap.getBpmno()); - newTableFull.setBpmlsNo(invoiceBpmmap.getBpmlsno()); - newTableFull.setCDLCode(cdlCode); - DynamicContextHolder.push(ConfigureConstant.MAIN); - count += tInvoiceInvmapMapper.insertBackMsg(newTableFull); - } + if (StringUtils.isNotBlank(exculdNsrsbh) && Arrays.asList(exculdNsrsbh.split(",")).contains(nsrsbh)){ + NewTable newTableFull = new NewTable(); + BeanUtil.copyProperties(newTable, newTableFull); + newTableFull.setCDLCode(cdlCode); + DynamicContextHolder.push(ConfigureConstant.MAIN); + count += tInvoiceInvmapMapper.insertBackMsg(newTableFull); + }else { + List ddbhList = yyOrderMapper.getDdbh(cdlCode); + log.debug("查询到中间表信息:{}", JSON.toJSONString(ddbhList)); + if (CollectionUtils.isNotEmpty(ddbhList)) { + for (InvoiceBpmmap invoiceBpmmap : ddbhList) { + NewTable newTableFull = new NewTable(); + BeanUtil.copyProperties(newTable, newTableFull); + newTableFull.setBpmNo(invoiceBpmmap.getBpmno()); + newTableFull.setBpmlsNo(invoiceBpmmap.getBpmlsno()); + newTableFull.setCDLCode(cdlCode); + DynamicContextHolder.push(ConfigureConstant.MAIN); + count += tInvoiceInvmapMapper.insertBackMsg(newTableFull); + } + } } }