diff --git a/order-management-order/src/main/java/com/dxhy/order/consumer/dao/SkOrderMapper.java b/order-management-order/src/main/java/com/dxhy/order/consumer/dao/SkOrderMapper.java index 5d07f18..86138a2 100644 --- a/order-management-order/src/main/java/com/dxhy/order/consumer/dao/SkOrderMapper.java +++ b/order-management-order/src/main/java/com/dxhy/order/consumer/dao/SkOrderMapper.java @@ -1,6 +1,7 @@ package com.dxhy.order.consumer.dao; import com.dxhy.order.consumer.modules.bespoke.model.req.ReqParam; +import com.dxhy.order.consumer.modules.bespoke.model.sk.BackDjbh; import com.dxhy.order.consumer.modules.bespoke.model.sk.BackProduct; import com.dxhy.order.consumer.modules.bespoke.model.sk.SkOrderInfo; import com.dxhy.order.consumer.modules.bespoke.model.sk.SkOrderItemInfo; @@ -18,4 +19,6 @@ public interface SkOrderMapper { int updateOrder(SkOrderInfo skOrderInfo); void callProcedure(BackProduct backProduct); + + BackDjbh selectBackDjbh(String originDdh); } diff --git a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/model/sk/BackDjbh.java b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/model/sk/BackDjbh.java new file mode 100644 index 0000000..104b9d4 --- /dev/null +++ b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/model/sk/BackDjbh.java @@ -0,0 +1,13 @@ +package com.dxhy.order.consumer.modules.bespoke.model.sk; + +import lombok.Data; + +@Data +public class BackDjbh { + + private String djbh; + + private String bpmlsNo; + + private String bpmNo; +} diff --git a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/model/sk/BackProduct.java b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/model/sk/BackProduct.java index 45c1093..17d480a 100644 --- a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/model/sk/BackProduct.java +++ b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/model/sk/BackProduct.java @@ -2,6 +2,8 @@ package com.dxhy.order.consumer.modules.bespoke.model.sk; import lombok.Data; +import java.math.BigDecimal; + @Data public class BackProduct { @@ -17,15 +19,15 @@ public class BackProduct { private String kpr; - private String spsl; + private BigDecimal spsl; - private String dj; + private BigDecimal dj; - private String je; + private BigDecimal je; - private String sl; + private BigDecimal sl; - private String se; + private BigDecimal se; private String mark; } diff --git a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/OrderHandleServiceImpl.java b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/OrderHandleServiceImpl.java index 0ec1271..b352539 100644 --- a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/OrderHandleServiceImpl.java +++ b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/OrderHandleServiceImpl.java @@ -419,7 +419,7 @@ public class OrderHandleServiceImpl implements OrderHandleService { public boolean test() { ByteArrayInputStream utf8Stream = IoUtil.toUtf8Stream("独有英雄驱虎豹，更无豪杰怕熊罴"); - boolean flag = ftpProcessor.uploadFile(ftpProperties.getBasePath()+"/test", "poem.txt", utf8Stream); + boolean flag = ftpProcessor.uploadFile(ftpProperties.getBasePath(),"poem.txt", utf8Stream); return flag; } diff --git a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/SkOrderServiceImpl.java b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/SkOrderServiceImpl.java index fbc23a5..9cc59c5 100644 --- a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/SkOrderServiceImpl.java +++ b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/SkOrderServiceImpl.java @@ -26,6 +26,7 @@ import com.dxhy.order.consumer.dao.TInvoiceInvmapMapper; import com.dxhy.order.consumer.modules.bespoke.config.datasource.config.DynamicContextHolder; import com.dxhy.order.consumer.modules.bespoke.model.req.FileModel; import com.dxhy.order.consumer.modules.bespoke.model.req.ReqParam; +import com.dxhy.order.consumer.modules.bespoke.model.sk.BackDjbh; import com.dxhy.order.consumer.modules.bespoke.model.sk.BackProduct; import com.dxhy.order.consumer.modules.bespoke.model.sk.SkOrderInfo; import com.dxhy.order.consumer.modules.bespoke.model.sk.SkOrderItemInfo; @@ -190,34 +191,45 @@ public class SkOrderServiceImpl implements OrderService { backProduct.setDjbh(orderOriginExtendInfo.getOriginDdh()); backProduct.setMxxh(orderItemInfo.getSphxh()); backProduct.setKprq(DateUtil.formatDate(orderInvoiceInfo.getKprq())); - backProduct.setBz(orderItemInfo.getBz()); - backProduct.setKpr(orderInvoiceInfo.getKpr()); - backProduct.setSpsl(orderItemInfo.getXmsl()); - backProduct.setDj(orderItemInfo.getXmdj()); - backProduct.setJe(orderItemInfo.getXmje()); - backProduct.setSl(orderItemInfo.getSl()); - backProduct.setSe(orderItemInfo.getSe()); + backProduct.setBz(orderItemInfo.getBz()==null?"":orderItemInfo.getBz()); + backProduct.setKpr(orderInvoiceInfo.getKpr()==null?"":orderInvoiceInfo.getKpr()); + backProduct.setSpsl(new BigDecimal(orderItemInfo.getXmsl())); + backProduct.setDj(new BigDecimal(orderItemInfo.getXmdj())); + backProduct.setJe(new BigDecimal(orderItemInfo.getXmje())); + backProduct.setSl(new BigDecimal(orderItemInfo.getSl())); + backProduct.setSe(new BigDecimal(orderItemInfo.getSe())); backProduct.setMark(ConfigureConstant.KP); if (ConfigureConstant.STRING_1.equals(orderInvoiceInfo.getKplx())){ - backProduct.setDjbh(ddh); + backProduct.setDjbh(orderItemInfo.getByzd2()); backProduct.setMark(ConfigureConstant.CH); } DynamicContextHolder.push(orderInvoiceInfo.getXhfNsrsbh()); + log.info("调用存储过程参数：{}", JSON.toJSONString(backProduct)); skOrderMapper.callProcedure(backProduct); - //回写创建表 - DynamicContextHolder.push(ConfigureConstant.MAIN); - NewTable newTable = new NewTable(); - newTable.setCDLCode(orderOriginExtendInfo.getOriginDdh()); - newTable.setInvoiceCode(orderInvoiceInfo.getSdfphm()); - newTable.setInvoiceTime(orderInvoiceInfo.getKprq()); - newTable.setInvoiceAmount(orderInvoiceInfo.getKphjje()); - newTable.setInvoicePhoto(fileModel.getFilePath()); - newTable.setInvoiceFilename(fileModel.getFileName()); - newTable.setOperater(orderInvoiceInfo.getKpr()); - newTable.setOperateDate(orderInvoiceInfo.getKprq()); - tInvoiceInvmapMapper.deleteBackMsg(newTable.getCDLCode()); - tInvoiceInvmapMapper.insertBackMsg(newTable); + if (ConfigureConstant.STRING_0.equals(orderInvoiceInfo.getKplx())){ + //回写创建表 + DynamicContextHolder.push(orderInvoiceInfo.getXhfNsrsbh()); + BackDjbh backDjbh = skOrderMapper.selectBackDjbh(orderItemInfo.getByzd2()); + NewTable newTable = new NewTable(); + if (backDjbh != null){ + newTable.setCDLCode(backDjbh.getDjbh()); + newTable.setBpmNo(backDjbh.getBpmNo()); + newTable.setBpmlsNo(backDjbh.getBpmlsNo()); + } + + newTable.setInvoiceNo(orderInvoiceInfo.getSdfphm()); + newTable.setInvoiceTime(orderInvoiceInfo.getKprq()); + newTable.setInvoiceAmount(orderInvoiceInfo.getKphjje()); + newTable.setInvoicePhoto(fileModel.getFilePath()); + newTable.setInvoiceFilename(fileModel.getFileName()); + newTable.setOperater(orderInvoiceInfo.getKpr()); + newTable.setOperateDate(orderInvoiceInfo.getKprq()); + DynamicContextHolder.push(ConfigureConstant.MAIN); + tInvoiceInvmapMapper.deleteBackMsg(newTable.getCDLCode()); + tInvoiceInvmapMapper.insertBackMsg(newTable); + } + } } @@ -341,7 +353,6 @@ public class SkOrderServiceImpl implements OrderService { taxAmount = DecimalCalculateUtil.bigDecimalAdd(taxAmount, orderItemInfo.getSe(), ConfigureConstant.INT_2); //设置红字回写订单号 ddmxxxBO.setBYZD2(orderItemInfo.getXgdjbh()); - ddtxxBO.setBYZD1(orderItemInfo.getXgdjbh()); ddmxxxBOList.add(ddmxxxBO); } //金额、税额、价税合计 diff --git a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/InvoiceDataServiceImpl.java b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/InvoiceDataServiceImpl.java index 5573f24..f7500c4 100644 --- a/order-management-order/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/InvoiceDataServiceImpl.java +++ b/order-management-order/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/InvoiceDataServiceImpl.java @@ -1,6 +1,7 @@ package com.dxhy.order.consumer.modules.manager.service.impl; import cn.hutool.core.util.ObjectUtil; +import com.alibaba.fastjson2.JSON; import com.dxhy.base.common.constant.ConfigureConstant; import com.dxhy.base.common.constant.OrderInfoEnum; import com.dxhy.base.common.model.OrderInfo; @@ -14,6 +15,7 @@ import com.dxhy.order.baseservice.model.OrderInvoiceInfo; import com.dxhy.order.baseservice.model.queue.CommonTsMqData; import com.dxhy.order.baseservice.model.queue.FpTsMqData; import com.dxhy.order.baseservice.utils.OrderCommonUtils; +import com.dxhy.order.consumer.modules.bespoke.service.OrderHandleService; import com.dxhy.order.consumer.modules.manager.model.ProcessInvoiceData; import com.dxhy.order.consumer.modules.manager.service.InvoiceDataService; import com.dxhy.order.consumer.modules.order.service.OrderInfoService; @@ -61,6 +63,9 @@ public class InvoiceDataServiceImpl implements InvoiceDataService { @Resource private OrderInvoiceInfoService orderInvoiceInfoService; + @Resource + private OrderHandleService orderHandleService; + /** * 发票状态手动回推 */ @@ -107,7 +112,9 @@ public class InvoiceDataServiceImpl implements InvoiceDataService { commonTsMqData.setNsrsbh(orderInvoiceInfo.getXhfNsrsbh()); commonTsMqData.setEntId(orderInvoiceInfo.getEntId()); commonTsMqData.setFpTsMqData(fpTsMqData); - rabbitMqSendMessageService.autoSendRabbitMqMessageForBusiness(NsrQueueEnum.PUSH_MESSAGE.getValue(), JsonUtils.getInstance().toJsonString(commonTsMqData)); +// rabbitMqSendMessageService.autoSendRabbitMqMessageForBusiness(NsrQueueEnum.PUSH_MESSAGE.getValue(), JsonUtils.getInstance().toJsonString(commonTsMqData)); + + orderHandleService.backMsg(JSON.toJSONString(commonTsMqData)); successCount++; } diff --git a/order-management-order/src/main/resources/mybatis/mapper/SkOrderItemInfoMapper.xml b/order-management-order/src/main/resources/mybatis/mapper/SkOrderItemInfoMapper.xml index dab0419..4355c89 100644 --- a/order-management-order/src/main/resources/mybatis/mapper/SkOrderItemInfoMapper.xml +++ b/order-management-order/src/main/resources/mybatis/mapper/SkOrderItemInfoMapper.xml @@ -14,10 +14,11 @@ + - select id, order_id, cpmc, xh, cpdw, cpsl, hsdj, hsje, sl, se, create_time, update_time from sk_order_item_info + select id, order_id, cpmc, xh, cpdw, cpsl, hsdj, hsje, sl, se, create_time, update_time,xgdjbh from sk_order_item_info diff --git a/order-management-order/src/main/resources/mybatis/mapper/SkOrderMapper.xml b/order-management-order/src/main/resources/mybatis/mapper/SkOrderMapper.xml index 40538ef..8a1f21b 100644 --- a/order-management-order/src/main/resources/mybatis/mapper/SkOrderMapper.xml +++ b/order-management-order/src/main/resources/mybatis/mapper/SkOrderMapper.xml @@ -41,8 +41,17 @@ - { call js_jiekou ( - #{fphm},#{djbh},#{mxxh},#{kprq},#{bz},#{kpr},#{spsl},#{dj},#{je},#{sl},#{se},#{mark} - )} + call js_jiekou ( + #{fphm},#{djbh},#{mxxh},#{kprq},#{bz},#{kpr},#{spsl,jdbcType=DECIMAL,mode=IN},#{dj,jdbcType=DECIMAL,mode=IN},#{je,jdbcType=DECIMAL,mode=IN},#{sl,jdbcType=DECIMAL,mode=IN},#{se,jdbcType=DECIMAL,mode=IN},#{mark} + ) + +