fix:替换报账单号接口状态更新

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);
 }

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 {

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}"/>