From 6d53c11f6f79ffe90e2ff8623e0b1b2dae19109f Mon Sep 17 00:00:00 2001
From: kane <kane@qq.com>
Date: Fri, 1 Dec 2023 16:09:28 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E6=9B=BF=E6=8D=A2=E6=8A=A5=E8=B4=A6?=
 =?UTF-8?q?=E5=8D=95=E5=8F=B7=E6=8E=A5=E5=8F=A3=E7=8A=B6=E6=80=81=E6=9B=B4?=
 =?UTF-8?q?=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dxhy/order/consumer/dao/OrderProcessInfoMapper.java   | 8 ++++++++
 .../modules/order/service/impl/OrderInfoServiceImpl.java  | 7 +++++++
 .../resources/mybatis/mapper/OrderProcessInfoMapper.xml   | 4 ++++
 3 files changed, 19 insertions(+)

diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/dao/OrderProcessInfoMapper.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/dao/OrderProcessInfoMapper.java
index a4ac2e0c..b407c08d 100644
--- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/dao/OrderProcessInfoMapper.java
+++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/dao/OrderProcessInfoMapper.java
@@ -182,4 +182,12 @@ public interface OrderProcessInfoMapper {
      * @return : int
      */
     int deleteByOrderId(@Param("orderId") String orderId);
+
+    /**
+     * 功能描述: 根据处理单号更新订单状态
+     * @param ddzt
+     * @param processId
+     * @return : int
+     */
+    int updateByProcessId(@Param("ddzt") String ddzt,@Param("processId") String processId);
 }
diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java
index afa5aa8f..788fe8e2 100644
--- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java
+++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java
@@ -2403,6 +2403,13 @@ public class OrderInfoServiceImpl implements OrderInfoService {
                     commonTsMqData.setFpTsMqData(fpTsMqData);
                     rabbitMqSendMessageService.autoSendRabbitMqMessageForBusiness(NsrQueueEnum.PUSH_MESSAGE.getValue(), JsonUtils.getInstance().toJsonString(commonTsMqData));
                     log.info("{}替换报账单号发票推送成功，推送信息：{}", LOGGER_MSG, JsonUtils.getInstance().toJsonString(commonTsMqData));
+                    int countProcess = orderProcessInfoMapper.updateByProcessId("5",yOrderInfo.getProcessId());
+                    if (countProcess > 0){
+                        log.info("{}替换报账单号接口，更新处理状态开票成功，更新成功", LOGGER_MSG);
+                    }else {
+                        log.error("{}替换报账单号接口，更新处理状态开票成功，更新失败", LOGGER_MSG);
+                    }
+
                 }
                 return R.ok("替换成功");
             } else {
diff --git a/order-management-consumer/src/main/resources/mybatis/mapper/OrderProcessInfoMapper.xml b/order-management-consumer/src/main/resources/mybatis/mapper/OrderProcessInfoMapper.xml
index 7f079468..0affbccf 100644
--- a/order-management-consumer/src/main/resources/mybatis/mapper/OrderProcessInfoMapper.xml
+++ b/order-management-consumer/src/main/resources/mybatis/mapper/OrderProcessInfoMapper.xml
@@ -425,6 +425,10 @@
         </where>
     </update>
 
+    <update id="updateByProcessId" parameterType="java.lang.String">
+        update order_process_info set ddzt = #{ddzt} where id = #{processId}
+    </update>
+
     <select id="queryOrderInfo" resultMap="BaseResultMap"
             parameterType="java.util.Map">
         <bind name="dataType" value="${dataType}"/>